workflow

Documentation

Index

• func CancelCmd(ch *cmdutil.Helper) *cobra.Command
• func CompleteCmd(ch *cmdutil.Helper) *cobra.Command
• func CreateCmd(ch *cmdutil.Helper) *cobra.Command
• func CutoverCmd(ch *cmdutil.Helper) *cobra.Command
• func ListCmd(ch *cmdutil.Helper) *cobra.Command
• func RetryCmd(ch *cmdutil.Helper) *cobra.Command
• func ReverseCutoverCmd(ch *cmdutil.Helper) *cobra.Command
• func ReverseTrafficCmd(ch *cmdutil.Helper) *cobra.Command
• func ShowCmd(ch *cmdutil.Helper) *cobra.Command
• func SwitchTrafficCmd(ch *cmdutil.Helper) *cobra.Command
• func VerifyDataCmd(ch *cmdutil.Helper) *cobra.Command
• func WorkflowCmd(ch *cmdutil.Helper) *cobra.Command
• type MinimalWorkflow
  • func (w *MinimalWorkflow) MarshalCSVValue() interface{}
  • func (w *MinimalWorkflow) MarshalJSON() ([]byte, error)
• type Workflow
  • func (w *Workflow) MarshalCSVValue() interface{}
  • func (w *Workflow) MarshalJSON() ([]byte, error)

Functions

func CancelCmd

func CancelCmd(ch *cmdutil.Helper) *cobra.Command

func CompleteCmd

func CompleteCmd(ch *cmdutil.Helper) *cobra.Command

func CreateCmd

func CreateCmd(ch *cmdutil.Helper) *cobra.Command

func CutoverCmd

func CutoverCmd(ch *cmdutil.Helper) *cobra.Command

func ListCmd

func ListCmd(ch *cmdutil.Helper) *cobra.Command

func RetryCmd

func RetryCmd(ch *cmdutil.Helper) *cobra.Command

func ReverseCutoverCmd

func ReverseCutoverCmd(ch *cmdutil.Helper) *cobra.Command

func ReverseTrafficCmd

func ReverseTrafficCmd(ch *cmdutil.Helper) *cobra.Command

func ShowCmd

func ShowCmd(ch *cmdutil.Helper) *cobra.Command

func SwitchTrafficCmd

func SwitchTrafficCmd(ch *cmdutil.Helper) *cobra.Command

func VerifyDataCmd

func VerifyDataCmd(ch *cmdutil.Helper) *cobra.Command

func WorkflowCmd

func WorkflowCmd(ch *cmdutil.Helper) *cobra.Command

Types

type MinimalWorkflow

type MinimalWorkflow struct {
	Number      uint64 `header:"number"`
	Name        string `header:"name"`
	State       string `header:"state"`
	CreatedAt   int64  `header:"created_at,timestamp(ms|utc|human)" json:"created_at"`
	CompletedAt *int64 `header:"completed_at,timestamp(ms|utc|human)" json:"completed_at"`
	Duration    int64  `header:"duration,unixduration" json:"duration"`
	// contains filtered or unexported fields
}

func (*MinimalWorkflow) MarshalCSVValue

func (w *MinimalWorkflow) MarshalCSVValue() interface{}

func (*MinimalWorkflow) MarshalJSON

func (w *MinimalWorkflow) MarshalJSON() ([]byte, error)

type Workflow

type Workflow struct {
	Number uint64 `header:"number"`
	Name   string `header:"name"`
	State  string `header:"state"`
	Actor  string `header:"actor"`
	Branch string `header:"branch"`

	Tables []string `header:"tables" json:"tables"`

	SourceKeyspace string `header:"source keyspace"`
	TargetKeyspace string `header:"target keyspace"`

	CreatedAt int64 `header:"created_at,timestamp(ms|utc|human)" json:"created_at"`

	CopyDuration int64 `header:"copy duration,unixduration"`
	Duration     int64 `header:"total duration,unixduration" json:"duration"`

	TrafficServing string `header:"traffic serving"`

	FinishedAt *int64 `header:"finished at,timestamp(ms|utc|human)" json:"finished_at"`
	// contains filtered or unexported fields
}

func (*Workflow) MarshalCSVValue

func (w *Workflow) MarshalCSVValue() interface{}

func (*Workflow) MarshalJSON

func (w *Workflow) MarshalJSON() ([]byte, error)