deploy

Documentation

Index

• Constants
• func NewRestartCommand(ctx *cmdcontext.RWContext, streams genericclioptions.IOStreams) *cobra.Command
• func NewResumeCommand(ctx *cmdcontext.RWContext, streams genericclioptions.IOStreams) *cobra.Command
• func NewScaleCommand(ctx *cmdcontext.RWContext, streams genericclioptions.IOStreams) *cobra.Command
• func NewStopCommand(ctx *cmdcontext.RWContext, streams genericclioptions.IOStreams) *cobra.Command
• type GroupReplicas
• type ReplicaInfo
• type RestartOptions
  • func (o *RestartOptions) Run(ctx *cmdcontext.RWContext, cmd *cobra.Command, args []string) error
  • func (o *RestartOptions) Validate(ctx *cmdcontext.RWContext, cmd *cobra.Command, args []string) error
• type ResumeOptions
  • func (o *ResumeOptions) Run(ctx *cmdcontext.RWContext, cmd *cobra.Command, args []string) error
• type ScaleOptions
  • func (o *ScaleOptions) Run(ctx *cmdcontext.RWContext, cmd *cobra.Command, args []string) error
• type StopOptions
  • func (o *StopOptions) Run(ctx *cmdcontext.RWContext, cmd *cobra.Command, args []string) error
  • func (o *StopOptions) Validate(ctx *cmdcontext.RWContext, cmd *cobra.Command, args []string) error

Constants

const (
	ReplicaAnnotation       = "replicas.old"
	GlobalReplicaAnnotation = "replicas.global.old"
)

const (
	RestartLongDesc = `
Restart the risingwave instances.
`
	RestartExample = `` /* 192-byte string literal not displayed */

)

const (
	ResumeLongDesc = `
Start the risingwave instances.
`
	ResumeExample = `` /* 188-byte string literal not displayed */

)

const (
	ScaleLongDesc = `
Scale the risingwave instances.
`
	ScaleExample = `` /* 411-byte string literal not displayed */

)

const (
	StopLongDesc = `
Stop the risingwave instances.
`
	StopExample = `` /* 180-byte string literal not displayed */

)

Functions

func NewRestartCommand

func NewRestartCommand(ctx *cmdcontext.RWContext, streams genericclioptions.IOStreams) *cobra.Command

NewRestartCommand creates the restart command.

func NewResumeCommand

func NewResumeCommand(ctx *cmdcontext.RWContext, streams genericclioptions.IOStreams) *cobra.Command

NewCommand creates the resume command.

func NewScaleCommand

func NewScaleCommand(ctx *cmdcontext.RWContext, streams genericclioptions.IOStreams) *cobra.Command

NewCommand creates the scale command which can scale the risingwave components.

func NewStopCommand

func NewStopCommand(ctx *cmdcontext.RWContext, streams genericclioptions.IOStreams) *cobra.Command

NewCommand creates the stop command.

Types

type GroupReplicas

type GroupReplicas struct {
	Compute   []ReplicaInfo
	Frontend  []ReplicaInfo
	Compactor []ReplicaInfo
	Meta      []ReplicaInfo
	Connector []ReplicaInfo
}

type ReplicaInfo

type ReplicaInfo struct {
	GroupName string
	Replicas  int32
}

type RestartOptions

type RestartOptions struct {
	*cmdcontext.BasicOptions
}

func (*RestartOptions) Run

func (o *RestartOptions) Run(ctx *cmdcontext.RWContext, cmd *cobra.Command, args []string) error

func (*RestartOptions) Validate

func (o *RestartOptions) Validate(ctx *cmdcontext.RWContext, cmd *cobra.Command, args []string) error

type ResumeOptions

type ResumeOptions struct {
	*cmdcontext.BasicOptions
}

func (*ResumeOptions) Run

func (o *ResumeOptions) Run(ctx *cmdcontext.RWContext, cmd *cobra.Command, args []string) error

type ScaleOptions

type ScaleOptions struct {
	*cmdcontext.BasicOptions
	// contains filtered or unexported fields
}

func (*ScaleOptions) Run

func (o *ScaleOptions) Run(ctx *cmdcontext.RWContext, cmd *cobra.Command, args []string) error

type StopOptions

type StopOptions struct {
	*cmdcontext.BasicOptions
}

func (*StopOptions) Run

func (o *StopOptions) Run(ctx *cmdcontext.RWContext, cmd *cobra.Command, args []string) error

func (*StopOptions) Validate

func (o *StopOptions) Validate(ctx *cmdcontext.RWContext, cmd *cobra.Command, args []string) error