migrations

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

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

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

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

type AnnotationSetter interface {
	SetAnnotation(ctx context.Context, obj runtime.Object, key, value string) (runtime.Object, error)
}

type CPURequestSetter interface {
	SetCPURequest(ctx context.Context, stSet *appsv1.StatefulSet, cpuRequest *resource.Quantity) (*appsv1.StatefulSet, error)
}

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

type JobsClient interface {
	SetAnnotation(ctx context.Context, job *batchv1.Job, key, value string) (*batchv1.Job, error)
	List(ctx context.Context, includeCompleted bool) ([]batchv1.Job, error)
}

type MigrationProvider interface {
	Provide() []MigrationStep
	GetLatestMigrationIndex() int
}

type MigrationStep interface {
	Apply(ctx context.Context, obj runtime.Object) error
	SequenceID() int
	AppliesTo() ObjectType
}

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

type ObjectType string

type PDBClient interface {
	Get(ctx context.Context, namespace, name string) (*v1beta1.PodDisruptionBudget, error)
	SetOwner(ctx context.Context, pdb *v1beta1.PodDisruptionBudget, owner *appsv1.StatefulSet) (*v1beta1.PodDisruptionBudget, error)
}

type SecretsClient interface {
	Get(ctx context.Context, namespace, name string) (*corev1.Secret, error)
	SetOwner(ctx context.Context, secret *corev1.Secret, owner metav1.Object) (*corev1.Secret, error)
}

type StatefulsetsClient interface {
	GetBySourceType(ctx context.Context, sourceType string) ([]appsv1.StatefulSet, error)
	SetAnnotation(ctx context.Context, statefulSet *appsv1.StatefulSet, key, value string) (*appsv1.StatefulSet, error)
}