canaryconfigmgr

Documentation

Index

• func MakeCanaryConfigMgr(logger *zap.Logger, fissionClient *crd.FissionClient, ...) (*canaryConfigMgr, error)
• type CanaryProcessingInfo
• type PrometheusApiClient
  • func MakePrometheusClient(logger *zap.Logger, prometheusSvc string) (*PrometheusApiClient, error)
  • func (promApiClient *PrometheusApiClient) GetFunctionFailurePercentage(path, method, funcName, funcNs string, window string) (float64, error)
  • func (promApiClient *PrometheusApiClient) GetRequestsToFuncInWindow(path string, method string, funcName string, funcNs string, window string) (float64, error)
  • func (promApiClient *PrometheusApiClient) GetTotalFailedRequestsToFuncInWindow(funcName string, funcNs string, path string, method string, window string) (float64, error)

Functions

func MakeCanaryConfigMgr

func MakeCanaryConfigMgr(logger *zap.Logger, fissionClient *crd.FissionClient, kubeClient *kubernetes.Clientset, crdClient rest.Interface, prometheusSvc string) (*canaryConfigMgr, error)

Types

type CanaryProcessingInfo

type CanaryProcessingInfo struct {
	CancelFunc *context.CancelFunc
	Ticker     *time.Ticker
}

type PrometheusApiClient

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

func MakePrometheusClient

func MakePrometheusClient(logger *zap.Logger, prometheusSvc string) (*PrometheusApiClient, error)

func (*PrometheusApiClient) GetFunctionFailurePercentage

func (promApiClient *PrometheusApiClient) GetFunctionFailurePercentage(path, method, funcName, funcNs string, window string) (float64, error)

func (*PrometheusApiClient) GetRequestsToFuncInWindow

func (promApiClient *PrometheusApiClient) GetRequestsToFuncInWindow(path string, method string, funcName string, funcNs string, window string) (float64, error)

func (*PrometheusApiClient) GetTotalFailedRequestsToFuncInWindow

func (promApiClient *PrometheusApiClient) GetTotalFailedRequestsToFuncInWindow(funcName string, funcNs string, path string, method string, window string) (float64, error)