k8s

type Controller interface {
	// StartController starts the controller. Will block the calling routine
	StartController(dataStore cache.Indexer, stopChanel chan struct{})
	// GetDataStore returns the data store once it has synced with the API Server
	GetDataStore() cache.Indexer
}

type Converter interface {
	// ConvertObject takes an object or delete tombstone and returns
	// the modified object which will be stored in the data store
	ConvertObject(originalObj interface{}) (convertedObj interface{}, err error)
	// ConvertList takes an object and returns the modified list of objects which
	// will be returned to the Simple Pager function to aggregate the list pagination
	// response
	ConvertList(originalList interface{}) (convertedList interface{}, err error)
	// Resource returns the K8s resource name to list/watch
	Resource() string
	// ResourceType returns the k8s object to list/watch
	ResourceType() runtime.Object
}

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

type EventType int

type FinalizerManager interface {
	AddFinalizers(ctx context.Context, obj client.Object, finalizers ...string) error
	RemoveFinalizers(ctx context.Context, obj client.Object, finalizers ...string) error
}

type GenericEvent struct {
	EventType

	// Object is the object from the incoming request
	Object client.Object

	// OldObject is the existing object. Only populated for DELETE and UPDATE requests.
	OldObject client.Object
}

type NotificationChannel struct {
	Source <-chan GenericEvent
	// contains filtered or unexported fields
}

type PodsRepository interface {
	GetPod(namespace string, name string) (*v1.Pod, error)
	ListPodsWithMatchingLabels(opts client.ListOptions) (*v1.PodList, error)
}