streamline

type EventSubscriber func(event watch.Event)

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

type NamespaceCache interface {
	// HandleNamespaceEvent handles namespace events to keep the namespace cache in sync with the cluster state.
	HandleNamespaceEvent(e watch.Event)

	// EnsureNamespace ensures that the namespace exists with the desired metadata.
	// It can be a no-op based on the provided sync config.
	EnsureNamespace(ctx context.Context, namespace string, syncConfig *console.ServiceDeploymentForAgent_SyncConfig) error

	// DeleteNamespace deletes the namespace.
	// It can be a no-op based on the provided sync config.
	DeleteNamespace(ctx context.Context, namespace string, syncConfig *console.ServiceDeploymentForAgent_SyncConfig) error
}

type Option func(*Supervisor)

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

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

type Synchronizer interface {
	Start(ctx context.Context) error
	Stop()
	Started() bool
}