queue

Jan 8, 2019

Changes in this version

+ const AverageConcurrentRequestsM

+ const AverageConcurrentRequestsN

+ const LameDuckM

+ const LameDuckN

+ const OperationsPerSecondM

+ const OperationsPerSecondN

+ const ReportingPeriod

+ func TimeToFirstByteTimeoutHandler(h http.Handler, dt time.Duration, msg string) http.Handler

+ type Measurement int

+ type Reporter struct

+ Initialized bool

+ func NewStatsReporter(namespace string, config string, revision string, pod string) (*Reporter, error)

+ func (r *Reporter) Report(lameDuck bool, operationsPerSecond float64, averageConcurrentRequests float64) error

+ func (r *Reporter) UnregisterViews() error

+ type Semaphore struct

+ func NewSemaphore(maxCapacity, initialCapacity int32) *Semaphore

+ func (s *Semaphore) Acquire()

+ func (s *Semaphore) AddCapacity(size int32)

+ func (s *Semaphore) ReduceCapacity(size int32) error

+ func (s *Semaphore) Release()

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