ctrl

type Entry struct {
	GroupKind  schema.GroupKind
	Forwarders []schema.GroupKind
	Funcs      Funcs
}

type Event struct {
	Name      string
	Namespace string
	schema.GroupKind
	// contains filtered or unexported fields
}

type Funcs struct {
	Handler  HandleFunc
	Teardown func()
}

type HandleFunc func(context.Context, Event) (Result, error)

type Instance struct {
	Params
	// contains filtered or unexported fields
}

type Params struct {
	Client      *k8s.Client
	Logger      *slog.Logger
	Concurrency int
}

type Queue[T fmt.Stringer] struct {
	C    chan T
	Stop func()
	// contains filtered or unexported fields
}

type ResourceCache[T any] struct {
	// contains filtered or unexported fields
}

type Result struct {
	Requeue      bool
	RequeueAfter time.Duration
}