Skip to content

Commit ad3e1be

Browse files
committed
Add BufferedChannelQueue Getters of Settings.
1 parent dd6a592 commit ad3e1be

File tree

1 file changed

+20
-0
lines changed

1 file changed

+20
-0
lines changed

queue.go

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -600,6 +600,26 @@ func (q *BufferedChannelQueue) SetFreeNodeHookPoolIntervalDuration(duration time
600600
return q
601601
}
602602

603+
// GetBufferSizeMaximum Get MaximumBufferSize(maximum number of buffered items outside the ChannelQueue)
604+
func (q *BufferedChannelQueue) GetBufferSizeMaximum() int {
605+
return q.bufferSizeMaximum
606+
}
607+
608+
// GetNodeHookPoolSize Get nodeHookPoolSize(the buffering node hooks ideal size)
609+
func (q *BufferedChannelQueue) GetNodeHookPoolSize() int {
610+
return q.nodeHookPoolSize
611+
}
612+
613+
// GetLoadFromPoolDuration Get loadFromPoolDuration(the interval to take buffered items into the ChannelQueue)
614+
func (q *BufferedChannelQueue) GetLoadFromPoolDuration() time.Duration {
615+
return q.loadFromPoolDuration
616+
}
617+
618+
// GetFreeNodeHookPoolIntervalDuration Get freeNodeHookPoolIntervalDuration(the interval to clear buffering node hooks down to nodeHookPoolSize)
619+
func (q *BufferedChannelQueue) GetFreeNodeHookPoolIntervalDuration() time.Duration {
620+
return q.freeNodeHookPoolIntervalDuration
621+
}
622+
603623
// IsClosed Is the BufferedChannelQueue closed
604624
func (q *BufferedChannelQueue) IsClosed() bool {
605625
return q.isClosed.Get()

0 commit comments

Comments
 (0)