client

Documentation

Index

• type DatadogClient
  • func NewDatadogClient(apiKey, appKey string) *DatadogClient
  • func (c *DatadogClient) GetRequestCounts(ctx context.Context, monitoringRange int) (*RequestCountsResult, error)
• type IstioClient
  • func NewIstioClient(namespace, internalDestinationHost, externalDestinationHost string, ...) (*IstioClient, error)
  • func (c *IstioClient) CreateVirtualService(ctx context.Context, host string, internalWeight, bufferWeight int) error
  • func (c *IstioClient) DeleteVirtualService(ctx context.Context, host string) error
  • func (c *IstioClient) ListVirtualService(ctx context.Context) (*v1alpha3.VirtualServiceList, error)
  • func (c *IstioClient) UpdateVirtualService(ctx context.Context, host, currentResourceVersion string, ...) error
• type KubernetesClient
  • func NewKubernetesClient(namespace string, config *rest.Config) (*KubernetesClient, error)
  • func (c *KubernetesClient) ListHPA(ctx context.Context) (*v1.HorizontalPodAutoscalerList, error)
• type RequestCountsResult
  • func (r *RequestCountsResult) GetCounts(host string) float64
  • func (r *RequestCountsResult) String() string

Types

type DatadogClient

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

func NewDatadogClient

func NewDatadogClient(apiKey, appKey string) *DatadogClient

func (*DatadogClient) GetRequestCounts

func (c *DatadogClient) GetRequestCounts(ctx context.Context, monitoringRange int) (*RequestCountsResult, error)

type IstioClient

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

func NewIstioClient

func NewIstioClient(namespace, internalDestinationHost, externalDestinationHost string, config *rest.Config) (*IstioClient, error)

func (*IstioClient) CreateVirtualService

func (c *IstioClient) CreateVirtualService(ctx context.Context, host string, internalWeight, bufferWeight int) error

func (*IstioClient) DeleteVirtualService

func (c *IstioClient) DeleteVirtualService(ctx context.Context, host string) error

func (*IstioClient) ListVirtualService

func (c *IstioClient) ListVirtualService(ctx context.Context) (*v1alpha3.VirtualServiceList, error)

func (*IstioClient) UpdateVirtualService

func (c *IstioClient) UpdateVirtualService(ctx context.Context, host, currentResourceVersion string, internalWeight, bufferWeight int) error

type KubernetesClient

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

func NewKubernetesClient

func NewKubernetesClient(namespace string, config *rest.Config) (*KubernetesClient, error)

func (*KubernetesClient) ListHPA

func (c *KubernetesClient) ListHPA(ctx context.Context) (*v1.HorizontalPodAutoscalerList, error)

type RequestCountsResult

type RequestCountsResult struct {
	TotalCounts float64
	MaxHost     string
	// contains filtered or unexported fields
}

func (*RequestCountsResult) GetCounts

func (r *RequestCountsResult) GetCounts(host string) float64

func (*RequestCountsResult) String

func (r *RequestCountsResult) String() string