kube

package

v0.49.1 Latest Latest Go to latest Published: Nov 30, 2023 License: Apache-2.0 Imports: 22 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewController(
	log logrus.FieldLogger,
	f informers.SharedInformerFactory,
	k8sVersion version.Version,
) *Controller

func (c *Controller) AddSubscribers(subs ...ObjectSubscriber)

func (c *Controller) GetPodOwnerID(pod *corev1.Pod) string

GetPodOwnerID returns last pod owner ID. In most cases for pod it will search for Deployment or CronJob uid if exists.

func (c *Controller) NeedLeaderElection() bool

func (c *Controller) Start(ctx context.Context) error

type Event string

const (
	EventAdd    Event = "add"
	EventDelete Event = "delete"
	EventUpdate Event = "update"
)

type Object interface {
	runtime.Object
	metav1.Object
}

type ObjectSubscriber interface {
	ResourceEventHandler
	Run(ctx context.Context) error
	RequiredInformers() []reflect.Type
}

type ResourceEventHandler interface {
	OnAdd(obj Object)
	OnUpdate(obj Object)
	OnDelete(obj Object)
}