controller

Documentation

Index

• Constants
• Variables
• func DependentFactoryKey(namespace string) typed.FactoryKey
• func NewPauseHandler(patchStatus func(ctx context.Context, patch *v1alpha1.SpiceDBCluster) error, ...) handler.Handler
• func NewSecretAdoptionHandler(recorder record.EventRecorder, ...) handler.Handler
• func NewSelfPauseHandler(patch func(ctx context.Context, patch *v1alpha1.SpiceDBCluster) error, ...) handler.Handler
• func OwnedFactoryKey(namespace string) typed.FactoryKey
• type ConfigChangedHandler
  • func (c *ConfigChangedHandler) Handle(ctx context.Context)
• type Controller
  • func NewController(ctx context.Context, registry *typed.Registry, dclient dynamic.Interface, ...) (*Controller, error)
  • func (c *Controller) Handle(ctx context.Context)
  • func (c *Controller) Patch(ctx context.Context, patch *v1alpha1.SpiceDBCluster) error
  • func (c *Controller) PatchStatus(ctx context.Context, patch *v1alpha1.SpiceDBCluster) error
• type DeploymentHandler
  • func (m *DeploymentHandler) Handle(ctx context.Context)
• type JobCleanupHandler
  • func (s *JobCleanupHandler) Handle(ctx context.Context)
• type MigrationCheckHandler
  • func (m *MigrationCheckHandler) Handle(ctx context.Context)
• type MigrationRunHandler
  • func (m *MigrationRunHandler) Handle(ctx context.Context)
• type ValidateConfigHandler
  • func (c *ValidateConfigHandler) Handle(ctx context.Context)
• type WaitForMigrationsHandler
  • func (m *WaitForMigrationsHandler) Handle(ctx context.Context)

Constants

const (
	EventRunningMigrations = "RunningMigrations"

	HandlerDeploymentKey        handler.Key = "deploymentChain"
	HandlerMigrationRunKey      handler.Key = "runMigration"
	HandlerWaitForMigrationsKey handler.Key = "waitForMigrationChain"
)

const EventInvalidSpiceDBConfig = "InvalidSpiceDBConfig"

const EventMigrationsComplete = "MigrationsCompleted"

const EventSecretAdoptedBySpiceDBCluster = "SecretAdoptedBySpiceDB"

const HandlerSelfPauseKey handler.Key = "nextSelfPause"

Variables

var (
	QueueOps                  = queue.NewQueueOperationsCtx()
	CtxOperatorConfig         = typedctx.WithDefault[*config.OperatorConfig](nil)
	CtxCacheNamespace         = typedctx.WithDefault("")
	CtxClusterNN              = typedctx.WithDefault(types.NamespacedName{})
	CtxSecretNN               = typedctx.WithDefault(types.NamespacedName{})
	CtxSecret                 = typedctx.WithDefault[*corev1.Secret](nil)
	CtxSecretHash             = typedctx.WithDefault("")
	CtxCluster                = typedctx.WithDefault[*v1alpha1.SpiceDBCluster](nil)
	CtxConfig                 = typedctx.WithDefault[*config.Config](nil)
	CtxMigrationHash          = typedctx.WithDefault("")
	CtxDeployments            = typedctx.Boxed(make([]*appsv1.Deployment, 0))
	CtxJobs                   = typedctx.Boxed(make([]*batchv1.Job, 0))
	CtxCurrentMigrationJob    = typedctx.WithDefault[*batchv1.Job](nil)
	CtxCurrentSpiceDeployment = typedctx.WithDefault[*appsv1.Deployment](nil)
	CtxSelfPauseObject        = typedctx.WithDefault(new(v1alpha1.SpiceDBCluster))
)

Functions

func DependentFactoryKey

func DependentFactoryKey(namespace string) typed.FactoryKey

func NewPauseHandler

func NewPauseHandler(
	patchStatus func(ctx context.Context, patch *v1alpha1.SpiceDBCluster) error,
	next handler.ContextHandler,
) handler.Handler

func NewSecretAdoptionHandler

func NewSecretAdoptionHandler(recorder record.EventRecorder, getFromCache func(ctx context.Context) (*corev1.Secret, error), missingFunc func(ctx context.Context, err error), secretIndexer *typed.Indexer[*corev1.Secret], secretApplyFunc adopt.ApplyFunc[*corev1.Secret, *applycorev1.SecretApplyConfiguration], existsFunc func(ctx context.Context, name types.NamespacedName) error, next handler.Handler) handler.Handler

func NewSelfPauseHandler

func NewSelfPauseHandler(
	patch func(ctx context.Context, patch *v1alpha1.SpiceDBCluster) error,
	patchStatus func(ctx context.Context, patch *v1alpha1.SpiceDBCluster) error,
) handler.Handler

func OwnedFactoryKey

func OwnedFactoryKey(namespace string) typed.FactoryKey

Types

type ConfigChangedHandler

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

func (*ConfigChangedHandler) Handle

func (c *ConfigChangedHandler) Handle(ctx context.Context)

type Controller

type Controller struct {
	*manager.OwnedResourceController
	// contains filtered or unexported fields
}

func NewController

func NewController(ctx context.Context, registry *typed.Registry, dclient dynamic.Interface, kclient kubernetes.Interface, resources openapi.Resources, configFilePath string, broadcaster record.EventBroadcaster, namespaces []string) (*Controller, error)

func (*Controller) Handle

func (c *Controller) Handle(ctx context.Context)

Handle inspects the current SpiceDBCluster object and ensures the desired state is persisted on the cluster.

func (*Controller) Patch

func (c *Controller) Patch(ctx context.Context, patch *v1alpha1.SpiceDBCluster) error

func (*Controller) PatchStatus

func (c *Controller) PatchStatus(ctx context.Context, patch *v1alpha1.SpiceDBCluster) error

type DeploymentHandler

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

func (*DeploymentHandler) Handle

func (m *DeploymentHandler) Handle(ctx context.Context)

type JobCleanupHandler

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

func (*JobCleanupHandler) Handle

func (s *JobCleanupHandler) Handle(ctx context.Context)

type MigrationCheckHandler

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

func (*MigrationCheckHandler) Handle

func (m *MigrationCheckHandler) Handle(ctx context.Context)

type MigrationRunHandler

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

func (*MigrationRunHandler) Handle

func (m *MigrationRunHandler) Handle(ctx context.Context)

type ValidateConfigHandler

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

func (*ValidateConfigHandler) Handle

func (c *ValidateConfigHandler) Handle(ctx context.Context)

type WaitForMigrationsHandler

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

func (*WaitForMigrationsHandler) Handle

func (m *WaitForMigrationsHandler) Handle(ctx context.Context)