operator

Documentation

Index

• func AdaptEnvForSnapshotBackup(ctx context.Context, cfg *PauseGcConfig) error
• func DefineFlagsForPrepareSnapBackup(f *pflag.FlagSet)
• type AdaptEnvForSnapshotBackupContext
  • func (cx *AdaptEnvForSnapshotBackupContext) Close()
  • func (cx *AdaptEnvForSnapshotBackupContext) GetBackOffer(operation string) utils.Backoffer
  • func (cx *AdaptEnvForSnapshotBackupContext) ReadyL(name string, notes ...zap.Field)
• 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 DefineFlagsForPrepareSnapBackup

func DefineFlagsForPrepareSnapBackup(f *pflag.FlagSet)

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 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.