telemetry

Documentation

Index

• func PushInterruptionEvent(ctx context.Context, clusterIDHash string, node *corev1.Node)
• func PushTelemetryClusterResourceInfo(ctx context.Context, clusterIDHash string, kubeclient client.Client, ...)
• type ClusterResourcesInfo
• type Controller
  • func NewController(kubeClient client.Client, metricClient metricsclientset.Interface) *Controller
  • func (c *Controller) Reconcile(ctx context.Context, node *corev1.Node) (reconcile.Result, error)
  • func (c *Controller) Register(ctx context.Context, m manager.Manager) error
• type InterruptionEvent

Functions

func PushInterruptionEvent

func PushInterruptionEvent(ctx context.Context, clusterIDHash string, node *corev1.Node)

func PushTelemetryClusterResourceInfo

func PushTelemetryClusterResourceInfo(ctx context.Context, clusterIDHash string, kubeclient client.Client, metricClient metricsclientset.Interface)

Types

type ClusterResourcesInfo

type ClusterResourcesInfo struct {
	CPUUsage    int64 `json:"cpuUsage"`
	MemoryUsage int64 `json:"memoryUsage"`

	CPURequest    int64 `json:"cpuRequest"`
	MemoryRequest int64 `json:"memoryRequest"`

	CPUCapacity    int64 `json:"cpuCapacity"`
	MemoryCapacity int64 `json:"memoryCapacity"`

	InstanceTypes []string `json:"instanceTypes"`
}

type Controller

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

func NewController

func NewController(kubeClient client.Client, metricClient metricsclientset.Interface) *Controller

func (*Controller) Reconcile

func (c *Controller) Reconcile(ctx context.Context, node *corev1.Node) (reconcile.Result, error)

func (*Controller) Register

func (c *Controller) Register(ctx context.Context, m manager.Manager) error

type InterruptionEvent

type InterruptionEvent struct {
	CloudProvider           string    `json:"cloudProvider"`
	Timestamp               time.Time `json:"timestamp"`
	Region                  string    `json:"region"`
	Zone                    string    `json:"zone"`
	InstanceType            string    `json:"instanceType"`
	InstanceCreateTimestamp time.Time `json:"instanceCreateTimestamp"`
}