manager

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

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

type PodControllerOption func(*podReconciler)

type PodHandler interface {
	// Handle a status update with the associated pod. Changes made to
	// the pod object will be applied after all handlers have been called.
	// Pod status updates are ignored and won't be applied.
	Handle(context.Context, *v1.ContainerStatus, *corev1.Pod) error
}

type PodHandlerWithClient interface {
	PodHandler
	InjectClient(v1.ShimClient)
}

type PodHandlerWithKubeClient interface {
	PodHandler
	InjectKubeClient(client.Client)
}

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

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

type Redirector struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type SubscriberConfig struct {
	Log       *slog.Logger
	Kube      client.Client
	Collector *Collector
}