rolling

Documentation

Index

• Constants
• type Executer
  • func NewExecuter(opts *RestartOptions, logger *zap.SugaredLogger, cmsClient cms.Client, ...) Executer
• type MajorToMinors
• type RestartOptions
  • func (o *RestartOptions) DefineFlags(fs *pflag.FlagSet)
  • func (o *RestartOptions) GetRestartDuration(nNodes int) *durationpb.Duration
  • func (o *RestartOptions) Validate() error
• type Rolling
  • func (r *Rolling) DoRestart(ctx context.Context) error

Constants

const (
	DefaultRetryCount              = 3
	DefaultCMSQueryIntervalSeconds = 10
	DefaultRestartDurationSeconds  = 60
	DefaultNodesInflight           = 1
	DefaultDelayBetweenRestarts    = time.Second
)

const (
	RestartTaskPrefix = "rolling-restart-"
)

Types

type Executer

type Executer interface {
	Execute() error
}

func NewExecuter

func NewExecuter(
	opts *RestartOptions,
	logger *zap.SugaredLogger,
	cmsClient cms.Client,
	discoveryClient discovery.Client,
	rst restarters.Restarter,
) Executer

type MajorToMinors

type MajorToMinors map[int]map[int]bool

type RestartOptions

type RestartOptions struct {
	options.TargetingOptions

	RestartRetryNumber         int
	CMSQueryInterval           int
	NodesInflight              int
	DelayBetweenRestarts       time.Duration
	SuppressCompatibilityCheck bool
	CleanupOnExit              bool

	RestartDuration int

	SSHArgs []string

	CustomSystemdUnitName string
}

func (*RestartOptions) DefineFlags

func (o *RestartOptions) DefineFlags(fs *pflag.FlagSet)

func (*RestartOptions) GetRestartDuration

func (o *RestartOptions) GetRestartDuration(nNodes int) *durationpb.Duration

func (*RestartOptions) Validate

func (o *RestartOptions) Validate() error

type Rolling

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

func (*Rolling) DoRestart

func (r *Rolling) DoRestart(ctx context.Context) error