runtime

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

type Config struct {
	Rest      *rest.Config
	Namespace string
}

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

type Handler interface {
	OnChange(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.RateLimiter
}

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(gvk schema.GroupVersionKind) (SharedController, error)
	Start(ctx context.Context, workers int) error
}

type SharedControllerFactoryOptions struct {
	DefaultRateLimiter workqueue.RateLimiter
	DefaultWorkers     int

	KindRateLimiter map[schema.GroupVersionKind]workqueue.RateLimiter
	KindWorkers     map[schema.GroupVersionKind]int
}

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

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

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