k8s

Documentation

Index

• func CalculateMaxConnLimit(configParams *config.Config, numTyphas, numNodes, numSyncerTypes int) (target int, reason string)
• func PollK8sForConnectionLimit(cxt context.Context, configParams *config.Config, tickerC <-chan time.Time, ...)
• type K8sAPI
• type MaxConnsAPI
• type RealK8sAPI
  • func NewK8sAPI(nc *calc.NodeCounter) *RealK8sAPI
  • func (r *RealK8sAPI) GetNumNodes() (int, error)
  • func (r *RealK8sAPI) GetNumTyphas(ctx context.Context, namespace, serviceName, portName string) (int, error)

Functions

func CalculateMaxConnLimit

func CalculateMaxConnLimit(configParams *config.Config, numTyphas, numNodes, numSyncerTypes int) (target int, reason string)

func PollK8sForConnectionLimit

func PollK8sForConnectionLimit(
	cxt context.Context,
	configParams *config.Config,
	tickerC <-chan time.Time,
	k8sAPI K8sAPI,
	server MaxConnsAPI,
	numSyncerTypes int,
)

Types

type K8sAPI

type K8sAPI interface {
	GetNumTyphas(ctx context.Context, namespace, serviceName, portName string) (int, error)
	GetNumNodes() (int, error)
}

type MaxConnsAPI

type MaxConnsAPI interface {
	SetMaxConns(numConns int)
}

type RealK8sAPI

type RealK8sAPI struct {
	// contains filtered or unexported fields
}

func NewK8sAPI

func NewK8sAPI(nc *calc.NodeCounter) *RealK8sAPI

func (*RealK8sAPI) GetNumNodes

func (r *RealK8sAPI) GetNumNodes() (int, error)

func (*RealK8sAPI) GetNumTyphas

func (r *RealK8sAPI) GetNumTyphas(ctx context.Context, namespace, serviceName, portName string) (int, error)