queue

Documentation

Index

• type Queue
  • func NewQueue[T any](nlimit int, tlimit time.Duration, handler func([]T)) *Queue[T]
  • func (q *Queue[T]) Done() <-chan struct{}
  • func (q *Queue[T]) HasStopped() <-chan struct{}
  • func (q *Queue[T]) Push(item T) bool
  • func (q *Queue[T]) Run()
  • func (q *Queue[T]) Stop()
• type QueueConfig

Types

type Queue

type Queue[T any] struct {
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue[T any](nlimit int, tlimit time.Duration, handler func([]T)) *Queue[T]

func (*Queue[T]) Done

func (q *Queue[T]) Done() <-chan struct{}

func (*Queue[T]) HasStopped

func (q *Queue[T]) HasStopped() <-chan struct{}

func (*Queue[T]) Push

func (q *Queue[T]) Push(item T) bool

func (*Queue[T]) Run

func (q *Queue[T]) Run()

func (*Queue[T]) Stop

func (q *Queue[T]) Stop()

type QueueConfig

type QueueConfig[T any] struct {
	Handler       func([]T)
	FlushInterval time.Duration
	FlushCount    int
}