k8s

Documentation

Index

• type PodTracker
  • func NewPodTracker(k8sClient kubernetes.Interface, logger *log.Logger) *PodTracker
  • func (t *PodTracker) TrackPods(ctx context.Context, node string) (<-chan exporter.PodEvent, error)

Types

type PodTracker

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

PodTracker tracks pods using Kubernetes API client.

func NewPodTracker

func NewPodTracker(k8sClient kubernetes.Interface, logger *log.Logger) *PodTracker

NewPodTracker creates a new PodTracker that watches pods using specified kuberneter API client.

func (*PodTracker) TrackPods

func (t *PodTracker) TrackPods(ctx context.Context, node string) (<-chan exporter.PodEvent, error)

TrackPods starts tracking pod events on a specified node. Returns a channel of PodEvents that can be used to fetch corresponding events.