krt

type BuilderOption func(opt CollectionOption) OptionsBuilder

type Collection[T any] interface {
	GetKey(k string) *T
	List() []T
	EventStream[T]
	Metadata() Metadata
}

type CollectionDump struct {
	// Map of output key -> output
	Outputs map[string]any `json:"outputs,omitempty"`
	// Name of the input collection
	InputCollection string `json:"inputCollection,omitempty"`
	// Map of input key -> info
	Inputs map[string]InputDump `json:"inputs,omitempty"`
	// Synced returns whether the collection is synced or not
	Synced bool `json:"synced"`
}

type CollectionOption func(*collectionOptions)

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

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

type Equaler[K any] interface {
	Equals(k K) bool
}

type Event[T any] struct {
	Old   *T
	New   *T
	Event controllers.EventType
}

type EventStream[T any] interface {
	Syncer
	Register(f func(o Event[T])) HandlerRegistration
	RegisterBatch(f func(o []Event[T]), runExistingState bool) HandlerRegistration
}

type FetchOption func(*dependency)

type HandlerContext interface {
	DiscardResult()
	// contains filtered or unexported methods
}

type HandlerRegistration interface {
	Syncer
	UnregisterHandler()
}

type Index[K comparable, O any] interface {
	Lookup(k K) []O
	AsCollection(opts ...CollectionOption) Collection[IndexObject[K, O]]
	// contains filtered or unexported methods
}

type IndexObject[K comparable, O any] struct {
	Key     K
	Objects []O
}

type InputDump struct {
	Outputs      []string `json:"outputs,omitempty"`
	Dependencies []string `json:"dependencies,omitempty"`
}

type Key[O any] string

type LabelSelectorer interface {
	GetLabelSelector() map[string]string
}

type Labeler interface {
	GetLabels() map[string]string
}

type Metadata map[string]any

type Named struct {
	Name, Namespace string
}

type ObjectDecorator interface {
	GetObjectKeyable() any
}

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

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

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

type ResourceNamer interface {
	ResourceName() string
}

type Singleton[T any] interface {
	Get() *T
	Register(f func(o Event[T])) HandlerRegistration
	AsCollection() Collection[T]
	Metadata() Metadata
}

type StaticSingleton[T any] interface {
	Singleton[T]
	Set(*T)
	MarkSynced()
}

type Syncer interface {
	WaitUntilSynced(stop <-chan struct{}) bool
	HasSynced() bool
}

type TransformationEmpty[T any] func(ctx HandlerContext) *T

type TransformationMulti[I, O any] func(ctx HandlerContext, i I) []O

type TransformationSingle[I, O any] func(ctx HandlerContext, i I) *O