delayqueue

May 3, 2020

Changes in this version

+ const SlotsNum

type Options

+ func (o *Options) Frequency() time.Duration

May 3, 2020

Changes in this version

+ const SlotsCount

+ type Element struct

+ func NewElement(t time.Time, cycleNum int, data interface{}) *Element

+ type Elements struct

+ func NewElements() *Elements

+ func (e *Elements) Append(ele *Element)

+ func (e *Elements) Detection(ch chan<- Entry)

+ func (e *Elements) Empty() bool

+ func (e *Elements) Len() int

+ type Entry struct

+ func NewEntry(bt time.Time, body interface{}) Entry

+ func (e Entry) Body() interface{}

+ func (e Entry) BornTime() time.Time

+ func (e Entry) ConsumeTime() time.Time

+ type Option func(*Options)

+ func WithFrequency(frequency time.Duration) Option

+ type Options struct

+ func NewQueueOptions(opts ...Option) *Options

+ type Queue struct

+ func New() *Queue

+ func (q *Queue) Debug(b bool)

+ func (q *Queue) Put(t time.Time, data interface{})

+ func (q *Queue) Run(f func(entry Entry))