controller

Documentation

Index

• func ObjectHash(obj Object) (string, error)
• func ObjectKey(obj Object) string
• type Controller
  • func New(log logrus.FieldLogger, f informers.SharedInformerFactory, ...) *Controller
  • func (c *Controller) Run(ctx context.Context) error
• type Event
• type Object
• type ObjectSubscriber
• type ResourceEventHandler

Functions

func ObjectHash

func ObjectHash(obj Object) (string, error)

func ObjectKey

func ObjectKey(obj Object) string

Types

type Controller

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

func New

func New(
	log logrus.FieldLogger,
	f informers.SharedInformerFactory,
	subscribers []ObjectSubscriber,
	k8sVersion version.Version,
) *Controller

func (*Controller) Run

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

type Event

type Event string

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

type Object

type Object interface {
	runtime.Object
	metav1.Object
}

type ObjectSubscriber

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

type ResourceEventHandler

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