command

Documentation

Index

• func Execute(config conf.Config, args []string) error
• type QueryCommand
  • func (c *QueryCommand) Run(args []string) error
• type Runner
  • func NewQueryCommand(client proto.WorkerServiceClient) Runner
  • func NewStartCommand(client proto.WorkerServiceClient) Runner
  • func NewStopCommand(client proto.WorkerServiceClient) Runner
  • func NewStreamCommand(client proto.WorkerServiceClient) Runner
• type StartCommand
  • func (c *StartCommand) Run(args []string) error
• type StopCommand
  • func (c *StopCommand) Run(args []string) error
• type StreamCommand
  • func (c *StreamCommand) Run(args []string) error

Functions

func Execute

func Execute(config conf.Config, args []string) error

Types

type QueryCommand

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

func (*QueryCommand) Run

func (c *QueryCommand) Run(args []string) error

type Runner

type Runner interface {
	// Run runs a initialized runner.
	Run(args []string) error
}

func NewQueryCommand

func NewQueryCommand(client proto.WorkerServiceClient) Runner

func NewStartCommand

func NewStartCommand(client proto.WorkerServiceClient) Runner

func NewStopCommand

func NewStopCommand(client proto.WorkerServiceClient) Runner

func NewStreamCommand

func NewStreamCommand(client proto.WorkerServiceClient) Runner

type StartCommand

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

func (*StartCommand) Run

func (c *StartCommand) Run(args []string) error

type StopCommand

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

func (*StopCommand) Run

func (c *StopCommand) Run(args []string) error

type StreamCommand

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

func (*StreamCommand) Run

func (c *StreamCommand) Run(args []string) error