bufferqueue

type BufferQueue interface {
	PushItem(i *Item)

	Push(any interface{})

	Pop() interface{}

	Len() int

	Workings() int32

	SetLimit(n int64)

	GraceFullStop(ctx context.Context)
}

type Item struct {
	// contains filtered or unexported fields
}

type Options struct {
	Limit int64
}

type TimeSortedQueue []*Item

type WorkHandler interface {
	Handle()
}