operator

Documentation

Index

• func AdaptEnvForSnapshotBackup(ctx context.Context, cfg *PauseGcConfig) error
• func Base64ify(ctx context.Context, cfg Base64ifyConfig) error
• func DefineFlagsForBase64ifyConfig(flags *pflag.FlagSet)
• func DefineFlagsForListMigrationConfig(flags *pflag.FlagSet)
• func DefineFlagsForMigrateToConfig(flags *pflag.FlagSet)
• func DefineFlagsForPrepareSnapBackup(f *pflag.FlagSet)
• func RunListMigrations(ctx context.Context, cfg ListMigrationConfig) error
• func RunMigrateTo(ctx context.Context, cfg MigrateToConfig) error
• type AdaptEnvForSnapshotBackupContext
  • func (cx *AdaptEnvForSnapshotBackupContext) Close()
  • func (cx *AdaptEnvForSnapshotBackupContext) GetBackOffer(operation string) utils.Backoffer
  • func (cx *AdaptEnvForSnapshotBackupContext) ReadyL(name string, notes ...zap.Field)
• type Base64ifyConfig
  • func (cfg *Base64ifyConfig) ParseFromFlags(flags *pflag.FlagSet) error
• type ListMigrationConfig
  • func (cfg *ListMigrationConfig) ParseFromFlags(flags *pflag.FlagSet) error
• type MigrateToConfig
  • func (cfg *MigrateToConfig) ParseFromFlags(flags *pflag.FlagSet) error
  • func (cfg *MigrateToConfig) Verify() error
• type PauseGcConfig
  • func (cfg *PauseGcConfig) ParseFromFlags(flags *pflag.FlagSet) error

Functions

func AdaptEnvForSnapshotBackup

func AdaptEnvForSnapshotBackup(ctx context.Context, cfg *PauseGcConfig) error

AdaptEnvForSnapshotBackup blocks the current goroutine and pause the GC safepoint and remove the scheduler by the config. This function will block until the context being canceled.

func Base64ify

func Base64ify(ctx context.Context, cfg Base64ifyConfig) error

func DefineFlagsForBase64ifyConfig

func DefineFlagsForBase64ifyConfig(flags *pflag.FlagSet)

func DefineFlagsForListMigrationConfig

func DefineFlagsForListMigrationConfig(flags *pflag.FlagSet)

func DefineFlagsForMigrateToConfig

func DefineFlagsForMigrateToConfig(flags *pflag.FlagSet)

func DefineFlagsForPrepareSnapBackup

func DefineFlagsForPrepareSnapBackup(f *pflag.FlagSet)

func RunListMigrations

func RunListMigrations(ctx context.Context, cfg ListMigrationConfig) error

func RunMigrateTo

func RunMigrateTo(ctx context.Context, cfg MigrateToConfig) error

Types

type AdaptEnvForSnapshotBackupContext

type AdaptEnvForSnapshotBackupContext struct {
	context.Context
	// contains filtered or unexported fields
}

func (*AdaptEnvForSnapshotBackupContext) Close

func (cx *AdaptEnvForSnapshotBackupContext) Close()

func (*AdaptEnvForSnapshotBackupContext) GetBackOffer

func (cx *AdaptEnvForSnapshotBackupContext) GetBackOffer(operation string) utils.Backoffer

func (*AdaptEnvForSnapshotBackupContext) ReadyL

func (cx *AdaptEnvForSnapshotBackupContext) ReadyL(name string, notes ...zap.Field)

type Base64ifyConfig

type Base64ifyConfig struct {
	storage.BackendOptions
	StorageURI string
	LoadCerd   bool
}

func (*Base64ifyConfig) ParseFromFlags

func (cfg *Base64ifyConfig) ParseFromFlags(flags *pflag.FlagSet) error

type ListMigrationConfig

type ListMigrationConfig struct {
	storage.BackendOptions
	StorageURI string
	JSONOutput bool
}

func (*ListMigrationConfig) ParseFromFlags

func (cfg *ListMigrationConfig) ParseFromFlags(flags *pflag.FlagSet) error

type MigrateToConfig

type MigrateToConfig struct {
	storage.BackendOptions
	StorageURI string
	Recent     bool
	MigrateTo  int
	Base       bool

	Yes    bool
	DryRun bool
}

func (*MigrateToConfig) ParseFromFlags

func (cfg *MigrateToConfig) ParseFromFlags(flags *pflag.FlagSet) error

func (*MigrateToConfig) Verify

func (cfg *MigrateToConfig) Verify() error

type PauseGcConfig

type PauseGcConfig struct {
	task.Config

	SafePoint uint64        `json:"safepoint" yaml:"safepoint"`
	TTL       time.Duration `json:"ttl" yaml:"ttl"`

	OnAllReady func() `json:"-" yaml:"-"`
	OnExit     func() `json:"-" yaml:"-"`
}

func (*PauseGcConfig) ParseFromFlags

func (cfg *PauseGcConfig) ParseFromFlags(flags *pflag.FlagSet) error

ParseFromFlags fills the config via the flags.