Versions in this module Expand all Collapse all v0 v0.1.0 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
Go to main page