cosmosmigration

Documentation

Index

• func MigrateAllSubscriptionsOrDie(ctx context.Context, resourcesDBClient corecosmosstorage.ResourcesDBClient, ...)
• func NewCosmosMigrationController(resourcesDBClient corecosmosstorage.ResourcesDBClient, ...) controllerutils.Controller

Functions

func MigrateAllSubscriptionsOrDie

func MigrateAllSubscriptionsOrDie(ctx context.Context, resourcesDBClient corecosmosstorage.ResourcesDBClient, kubeApplierDBClients kubeappliercosmosstorage.KubeApplierDBClients)

MigrateAllSubscriptionsOrDie runs the Cosmos migration once across every subscription currently in the Resources container and panics on the first unrecoverable error. It is intended for integration-test setup where the long-running subscription-watching controller is not wired in; production migration runs as the controller returned by NewCosmosMigrationController.

func NewCosmosMigrationController

func NewCosmosMigrationController(
	resourcesDBClient corecosmosstorage.ResourcesDBClient,
	kubeApplierDBClients kubeappliercosmosstorage.KubeApplierDBClients,
	backendInformers coreinformers.BackendInformers,
	resyncDuration time.Duration,
) controllerutils.Controller

NewCosmosMigrationController creates a subscription-watching controller that iterates depth-first through every named document type in the Resources container and the per-management-cluster kube-applier containers, performing a read/write cycle to force Cosmos DB re-serialization.