Skip to content

Commit e1b1235

Browse files
committed
Add BufferedChannelQueue Getters of Settings.
1 parent 8decc14 commit e1b1235

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[T]) SetFreeNodeHookPoolIntervalDuration(duration t
600600
return q
601601
}
602602

603+
// GetBufferSizeMaximum Get MaximumBufferSize(maximum number of buffered items outside the ChannelQueue)
604+
func (q *BufferedChannelQueue[T]) GetBufferSizeMaximum() int {
605+
return q.bufferSizeMaximum
606+
}
607+
608+
// GetNodeHookPoolSize Get nodeHookPoolSize(the buffering node hooks ideal size)
609+
func (q *BufferedChannelQueue[T]) 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[T]) 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[T]) GetFreeNodeHookPoolIntervalDuration() time.Duration {
620+
return q.freeNodeHookPoolIntervalDuration
621+
}
622+
603623
// IsClosed Is the BufferedChannelQueue closed
604624
func (q *BufferedChannelQueue[T]) IsClosed() bool {
605625
return q.isClosed.Get()

0 commit comments

Comments
 (0)