migrator

Documentation

Index

• Constants
• func Migrate(ctx context.Context, logger logr.Logger, c client.Client, poolNamespace string) error
• type Migrator
  • func (m *Migrator) NeedLeaderElection() bool
  • func (m *Migrator) Start(ctx context.Context) error

Constants

const (
	// EnvDisableMigration contains the name of the environment variable which can be used
	// to disable migration
	EnvDisableMigration = "MIGRATOR_DISABLE_MIGRATION"
	// EnvConfigMapName contains the name of the environment variable which can be used
	// to specify the ConfigMap name containing the configuration to migrate from
	EnvConfigMapName = "CONFIGMAP_NAME"
	// EnvConfigMapNamespace contains the name of the environment variable which can be used
	// to specify the namespace of the ConfigMap containing the configuration to migrate from
	EnvConfigMapNamespace = "CONFIGMAP_NAMESPACE"
	// DefaultConfigMapName is the default ConfigMap name used to read the configuration to
	// migrate from
	DefaultConfigMapName = "nvidia-k8s-ipam-config"
)

Functions

func Migrate

func Migrate(ctx context.Context, logger logr.Logger, c client.Client, poolNamespace string) error

Migrate reads the ConfigMap with the IPAM configuration, reads the allocations from the Nodes annotation, create IPPool CRs and delete the ConfigMap and annotations

Types

type Migrator

type Migrator struct {
	K8sClient        client.Client
	IPPoolsNamespace string
	MigrationCh      chan struct{}
	LeaderElection   bool
	Logger           logr.Logger
}

Migrator migrate from CM config to IPPool CR

func (*Migrator) NeedLeaderElection

func (m *Migrator) NeedLeaderElection() bool

Implements manager.NeedLeaderElection

func (*Migrator) Start

func (m *Migrator) Start(ctx context.Context) error

Implements manager.Runnable