insights

Documentation

Index

• type K8sCollector
  • func NewK8sCollector(k8sCli kubernetes.Interface, reporter heartbeat.HeartbeatReporter, ...) *K8sCollector
  • func (k *K8sCollector) Start(ctx context.Context) error

Types

type K8sCollector

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

func NewK8sCollector

func NewK8sCollector(k8sCli kubernetes.Interface, reporter heartbeat.HeartbeatReporter, logger logrus.FieldLogger, interval, maxRetries int) *K8sCollector

func (*K8sCollector) Start

func (k *K8sCollector) Start(ctx context.Context) error

Start collects k8s insights, and it returns error once it cannot collect k8s node count.