runtime

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

type Config struct {
	Rest              *rest.Config
	Namespace         string
	FieldSelector     fields.Selector
	LabelSelector     labels.Selector
	ByObject          map[client.Object]cache.ByObject
	GVKThreadiness    map[schema.GroupVersionKind]int
	GVKQueueSplitters map[schema.GroupVersionKind]WorkerQueueSplitter
}

type Controller interface {
	Enqueue(namespace, name string)
	EnqueueAfter(namespace, name string, delay time.Duration)
	EnqueueKey(key string)
	EnqueueKeyAfter(key string, delay time.Duration)
	Cache() (cache.Cache, error)
	Start(ctx context.Context, workers int) error
}

type Handler interface {
	OnChange(ctx context.Context, key string, obj runtime.Object) error
}

type HandlerFunc func(key string, obj runtime.Object) error

type HandlerTransaction struct {
	context.Context
	// contains filtered or unexported fields
}

type Options struct {
	RateLimiter   workqueue.TypedRateLimiter[any]
	QueueSplitter WorkerQueueSplitter
}

type ResourceVersionGetter interface {
	GetResourceVersion() string
}

type Runtime struct {
	Backend *Backend
}

type SharedController interface {
	Controller

	RegisterHandler(ctx context.Context, name string, handler SharedControllerHandler) error
}

type SharedControllerFactory interface {
	ForKind(ctx context.Context, gvk schema.GroupVersionKind) (SharedController, error)
	Preload(ctx context.Context) error
	Start(ctx context.Context) error
}

type SharedControllerFactoryOptions struct {
	DefaultRateLimiter workqueue.TypedRateLimiter[any]
	DefaultWorkers     int

	KindRateLimiter   map[schema.GroupVersionKind]workqueue.TypedRateLimiter[any]
	KindWorkers       map[schema.GroupVersionKind]int
	KindQueueSplitter map[schema.GroupVersionKind]WorkerQueueSplitter
}

type SharedControllerHandler interface {
	OnChange(ctx context.Context, key string, obj runtime.Object) (runtime.Object, error)
}

type SharedControllerHandlerFunc func(ctx context.Context, key string, obj runtime.Object) (runtime.Object, error)

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

type WorkerQueueSplitter interface {
	Queues() int
	Split(key string) int
}