loader

type Event[T differ.Resource] struct {
	Type     operatorv1pb.ResourceEventType
	Resource T
}

type Interface interface {
	Run(context.Context) error
	Components() Loader[compapi.Component]
	Subscriptions() Loader[subapi.Subscription]
	MCPServers() Loader[mcpserverapi.MCPServer]
	Configurations() Loader[configapi.Configuration]
	HTTPEndpoints() Loader[httpendpointapi.HTTPEndpoint]
	Resiliencies() Loader[resiliencyapi.Resiliency]
	WorkflowAccessPolicies() Loader[wfaclapi.WorkflowAccessPolicy]
}

type Loader[T differ.Resource] interface {
	List(context.Context) (*differ.LocalRemoteResources[T], error)
	Stream(context.Context) (*StreamConn[T], error)
}

type StreamConn[T differ.Resource] struct {
	EventCh     chan *Event[T]
	ReconcileCh chan struct{}
}