Versions in this module Expand all Collapse all v0 v0.7.4 May 29, 2018 Changes in this version + func CalculateMaxConnLimit(configParams *config.Config, numTyphas, numNodes int) (target int, reason string) + func PollK8sForConnectionLimit(cxt context.Context, configParams *config.Config, tickerC <-chan time.Time, ...) + type K8sAPI interface + GetNumNodes func() (int, error) + GetNumTyphas func(namespace, serviceName, portName string) (int, error) + type MaxConnsAPI interface + SetMaxConns func(numConns int) + type RealK8sAPI struct + func NewK8sAPI() *RealK8sAPI + func (r *RealK8sAPI) GetNumNodes() (int, error) + func (r *RealK8sAPI) GetNumTyphas(namespace, serviceName, portName string) (int, error)