queue

Oct 30, 2018

Changes in this version

type ReqEvent

+ EventType ReqEventType

+ Time time.Time

+ type ReqEventType int

Jul 17, 2018

Changes in this version

+ const RequestQueueAdminPort

+ const RequestQueueAdminPortName

+ const RequestQueueHealthPath

+ const RequestQueuePort

+ const RequestQueuePortName

+ const RequestQueueQuitPath

+ type Breaker struct

+ func NewBreaker(queueDepth, maxConcurrency int32) *Breaker

+ func (b *Breaker) Maybe(thunk func()) bool

+ type Channels struct

+ QuantizationChan <-chan time.Time

+ ReportChan <-chan time.Time

+ ReqChan chan ReqEvent

+ StatChan chan *autoscaler.Stat

+ type ReqEvent int

+ const ReqIn

+ const ReqOut

+ type Stats struct

+ func NewStats(podName string, channels Channels) *Stats