cmd

Documentation

Index

• Constants
• func NewCommand() *cobra.Command
• type Runner
  • func NewRunner() *Runner
  • func (r *Runner) Err() chan error
  • func (r *Runner) Start(ctx context.Context) error

Constants

const (
	FlagLogLevel    = "log-level"
	FlagConfig      = "config"
	FlagConfigShort = "c"

	FlagQueueSize    = "queue-size"
	FlagWorkers      = "workers"
	FlagPerWorkerQPS = "per-worker-qps"
	FlagMaxRetry     = "max-retry"
	FlagRetryDelay   = "retry-delay"
	FlagActionRetry  = "action-retry"
	FlagTimeout      = "timeout"

	FlagRegistrySize = "registry-size"

	FlagLeaderElect                 = "leader-elect"
	FlagLeaderElectionLeaseDuration = "leader-election-lease-duration"
	FlagLeaderElectionRenewDeadline = "leader-election-renew-deadline"
	FlagLeaderElectionRetryPeriod   = "leader-election-retry-period"
)

nolint:revive

Functions

func NewCommand

func NewCommand() *cobra.Command

NewCommand news a command

Types

type Runner

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

Runner manages the task execution.

func NewRunner

func NewRunner() *Runner

NewRunner new a Runner

func (*Runner) Err

func (r *Runner) Err() chan error

Err return the runner's runtime error

func (*Runner) Start

func (r *Runner) Start(ctx context.Context) error

Start the task.