Versions in this module Expand all Collapse all v1 v1.0.0 Feb 17, 2022 Changes in this version + const NoMax + type FlexList struct + func NewFlexList() *FlexList + func (l *FlexList) Has(index string) bool + func (l *FlexList) Len() int + func (l *FlexList) Pull(index string) (interface{}, bool) + func (l *FlexList) PullBack() (string, interface{}, bool) + func (l *FlexList) PullFront() (string, interface{}, bool) + func (l *FlexList) PushBack(index string, item interface{}) bool + func (l *FlexList) PushFront(index string, item interface{}) bool + func (l *FlexList) Read(index string) (interface{}, bool) + func (l *FlexList) ReadBack() (string, interface{}, bool) + func (l *FlexList) ReadFront() (string, interface{}, bool) + func (l *FlexList) Remove(index string) bool + func (l *FlexList) Update(index string, item interface{}) bool + type FlexQueue struct + func NewFlexQueue() *FlexQueue + func (q *FlexQueue) Has(digest string) bool + func (q *FlexQueue) IsEmpty() bool + func (q *FlexQueue) IsFull() bool + func (q *FlexQueue) Len() int + func (q *FlexQueue) Max() int + func (q *FlexQueue) Prune() bool + func (q *FlexQueue) Pull(digest string) (interface{}, bool) + func (q *FlexQueue) PullBack() (string, interface{}, bool) + func (q *FlexQueue) PullFront() (string, interface{}, bool) + func (q *FlexQueue) PushBack(digest string, message interface{}) bool + func (q *FlexQueue) PushBackTTL(digest string, message interface{}, ttl time.Duration, ...) bool + func (q *FlexQueue) PushFront(digest string, message interface{}) bool + func (q *FlexQueue) PushFrontTTL(digest string, message interface{}, ttl time.Duration, ...) bool + func (q *FlexQueue) Read(digest string) (interface{}, bool) + func (q *FlexQueue) ReadBack() (string, interface{}, bool) + func (q *FlexQueue) ReadFront() (string, interface{}, bool) + func (q *FlexQueue) Remove(digest string) bool + func (q *FlexQueue) SetMax(max int) *FlexQueue + func (q *FlexQueue) Update(digest string, message interface{}) bool + type ItemWrapper struct + type TTL struct + Callback func(digest string, message interface{}) + Expires time.Time + func NewTTL(ttl time.Duration, callback func(digest string, message interface{})) *TTL + func (ttl *TTL) Expired() bool