cmd

package
v0.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 21, 2023 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source
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

Variables

This section is empty.

Functions

func NewCommand

func NewCommand() *cobra.Command

NewCommand news a command

Types

type Runner added in v0.1.1

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

Runner manages the task execution.

func NewRunner added in v0.1.1

func NewRunner() *Runner

NewRunner new a Runner

func (*Runner) Err added in v0.1.1

func (r *Runner) Err() chan error

Err return the runner's runtime error

func (*Runner) Start added in v0.1.1

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

Start the task.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL