rolling

Documentation

Index

• Constants
• type Executer
  • func NewExecuter(opts *RestartOptions, logger *zap.SugaredLogger, cmsClient cms.Client, ...) Executer
• type RestartOptions
  • func (o *RestartOptions) DefineFlags(fs *pflag.FlagSet)
  • func (o *RestartOptions) GetAvailabilityMode() Ydb_Maintenance.AvailabilityMode
  • func (o *RestartOptions) GetNodeFQDNs() ([]string, error)
  • func (o *RestartOptions) GetNodeIds() ([]uint32, error)
  • func (o *RestartOptions) GetRestartDuration() *durationpb.Duration
  • func (o *RestartOptions) Validate() error
• type Rolling
  • func (r *Rolling) DoRestart() error
  • func (r *Rolling) DoRestartPrevious() error

Constants

const (
	DefaultRetryCount              = 3
	DefaultRestartDurationSeconds  = 60
	DefaultCMSQueryIntervalSeconds = 10
)

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 RestartOptions

type RestartOptions struct {
	AvailabilityMode   string
	Hosts              []string
	ExcludeHosts       []string
	RestartDuration    int
	RestartRetryNumber int
	Version            string
	CMSQueryInterval   int

	StartedTime *options.StartedTime
	VersionSpec options.VersionSpec

	Continue bool

	Storage    bool
	Tenant     bool
	TenantList []string

	SSHArgs []string

	CustomSystemdUnitName string

	KubeconfigPath string
	K8sNamespace   string

	MaxStaticNodeId int
}

func (*RestartOptions) DefineFlags

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

func (*RestartOptions) GetAvailabilityMode

func (o *RestartOptions) GetAvailabilityMode() Ydb_Maintenance.AvailabilityMode

func (*RestartOptions) GetNodeFQDNs

func (o *RestartOptions) GetNodeFQDNs() ([]string, error)

func (*RestartOptions) GetNodeIds

func (o *RestartOptions) GetNodeIds() ([]uint32, error)

func (*RestartOptions) GetRestartDuration

func (o *RestartOptions) GetRestartDuration() *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() error

func (*Rolling) DoRestartPrevious

func (r *Rolling) DoRestartPrevious() error