cooldownqueue

Documentation

Index

• Variables
• type CooldownQueue
  • func NewCooldownQueue() *CooldownQueue
  • func (q *CooldownQueue) Closed() bool
  • func (q *CooldownQueue) Enqueue(e watch.Event)
  • func (q *CooldownQueue) Stop()

Variables

var (
	DefaultExpiration = 5 * time.Second
	EvictionInterval  = 1 * time.Second
)

Types

type CooldownQueue

type CooldownQueue struct {

	// public channel for reading events
	ResultChan <-chan watch.Event
	// contains filtered or unexported fields
}

func NewCooldownQueue

func NewCooldownQueue() *CooldownQueue

NewCooldownQueue returns a new Cooldown Queue

func (*CooldownQueue) Closed

func (q *CooldownQueue) Closed() bool

func (*CooldownQueue) Enqueue

func (q *CooldownQueue) Enqueue(e watch.Event)

Enqueue enqueues an event in the Cooldown Queue

func (*CooldownQueue) Stop

func (q *CooldownQueue) Stop()