migrations

Documentation

Overview

Package migrations organises required migrations of eirini managed k8s objects

Index

• Constants
• type AdjustCPURequest
  • func NewAdjustCPURequest(cpuRequestSetter CPURequestSetter) AdjustCPURequest
  • func (m AdjustCPURequest) AppliesTo() ObjectType
  • func (m AdjustCPURequest) Apply(ctx context.Context, o runtime.Object) error
  • func (m AdjustCPURequest) SequenceID() int
• type AdoptJobRegistrySecret
  • func NewAdoptJobRegistrySecret(secretsClient SecretsClient) AdoptJobRegistrySecret
  • func (m AdoptJobRegistrySecret) AppliesTo() ObjectType
  • func (m AdoptJobRegistrySecret) Apply(ctx context.Context, obj runtime.Object) error
  • func (m AdoptJobRegistrySecret) SequenceID() int
• type AdoptPDB
  • func NewAdoptPDB(pdbClient PDBClient) AdoptPDB
  • func (m AdoptPDB) AppliesTo() ObjectType
  • func (m AdoptPDB) Apply(ctx context.Context, obj runtime.Object) error
  • func (m AdoptPDB) SequenceID() int
• type AdoptStatefulsetRegistrySecret
  • func NewAdoptStatefulsetRegistrySecret(secretsClient SecretsClient) AdoptStatefulsetRegistrySecret
  • func (m AdoptStatefulsetRegistrySecret) AppliesTo() ObjectType
  • func (m AdoptStatefulsetRegistrySecret) Apply(ctx context.Context, obj runtime.Object) error
  • func (m AdoptStatefulsetRegistrySecret) SequenceID() int
• type AnnotationSetter
• type CPURequestSetter
• type Executor
  • func NewExecutor(stSetClient StatefulsetsClient, jobsClient JobsClient, ...) *Executor
  • func (e *Executor) Migrate(ctx context.Context, logger lager.Logger) error
• type JobsClient
• type MigrationProvider
  • func CreateMigrationStepsProvider(stSetClient *client.StatefulSet, pdbClient *client.PodDisruptionBudget, ...) MigrationProvider
• type MigrationStep
• type MigrationStepsProvider
  • func NewMigrationStepsProvider(migrationSteps []MigrationStep) MigrationStepsProvider
  • func (p MigrationStepsProvider) GetLatestMigrationIndex() int
  • func (p MigrationStepsProvider) Provide() []MigrationStep
• type ObjectType
• type PDBClient
• type SecretsClient
• type StatefulsetsClient

Constants

const (
	AdjustCPUResourceSequenceID = 1
	AdoptPDBSequenceID          = 2
	AdoptStSetSecretSequenceID  = 3
	AdoptJobSecretSequenceID    = 4
)

Types

type AdjustCPURequest

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

func NewAdjustCPURequest

func NewAdjustCPURequest(cpuRequestSetter CPURequestSetter) AdjustCPURequest

func (AdjustCPURequest) AppliesTo

func (m AdjustCPURequest) AppliesTo() ObjectType

func (AdjustCPURequest) Apply

func (m AdjustCPURequest) Apply(ctx context.Context, o runtime.Object) error

func (AdjustCPURequest) SequenceID

func (m AdjustCPURequest) SequenceID() int

type AdoptJobRegistrySecret

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

func NewAdoptJobRegistrySecret

func NewAdoptJobRegistrySecret(secretsClient SecretsClient) AdoptJobRegistrySecret

func (AdoptJobRegistrySecret) AppliesTo

func (m AdoptJobRegistrySecret) AppliesTo() ObjectType

func (AdoptJobRegistrySecret) Apply

func (m AdoptJobRegistrySecret) Apply(ctx context.Context, obj runtime.Object) error

func (AdoptJobRegistrySecret) SequenceID

func (m AdoptJobRegistrySecret) SequenceID() int

type AdoptPDB

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

func NewAdoptPDB

func NewAdoptPDB(pdbClient PDBClient) AdoptPDB

func (AdoptPDB) AppliesTo

func (m AdoptPDB) AppliesTo() ObjectType

func (AdoptPDB) Apply

func (m AdoptPDB) Apply(ctx context.Context, obj runtime.Object) error

func (AdoptPDB) SequenceID

func (m AdoptPDB) SequenceID() int

type AdoptStatefulsetRegistrySecret

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

func NewAdoptStatefulsetRegistrySecret

func NewAdoptStatefulsetRegistrySecret(secretsClient SecretsClient) AdoptStatefulsetRegistrySecret

func (AdoptStatefulsetRegistrySecret) AppliesTo

func (m AdoptStatefulsetRegistrySecret) AppliesTo() ObjectType

func (AdoptStatefulsetRegistrySecret) Apply

func (m AdoptStatefulsetRegistrySecret) Apply(ctx context.Context, obj runtime.Object) error

func (AdoptStatefulsetRegistrySecret) SequenceID

func (m AdoptStatefulsetRegistrySecret) SequenceID() int

type AnnotationSetter

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

type CPURequestSetter

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

type Executor

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

func NewExecutor

func NewExecutor(stSetClient StatefulsetsClient, jobsClient JobsClient, migrationStepProvider MigrationProvider) *Executor

func (*Executor) Migrate

func (e *Executor) Migrate(ctx context.Context, logger lager.Logger) error

type JobsClient

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

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

func CreateMigrationStepsProvider

func CreateMigrationStepsProvider(stSetClient *client.StatefulSet, pdbClient *client.PodDisruptionBudget, secretsClient *client.Secret, workloadsNamespace string) MigrationProvider

type MigrationStep

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

type MigrationStepsProvider

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

func NewMigrationStepsProvider

func NewMigrationStepsProvider(migrationSteps []MigrationStep) MigrationStepsProvider

func (MigrationStepsProvider) GetLatestMigrationIndex

func (p MigrationStepsProvider) GetLatestMigrationIndex() int

func (MigrationStepsProvider) Provide

func (p MigrationStepsProvider) Provide() []MigrationStep

type ObjectType

type ObjectType string

const (
	StatefulSetObjectType ObjectType = "StatefulSet"
	JobObjectType         ObjectType = "Job"
)

type PDBClient

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

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

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)
}