worker

Documentation

Index

• func Run()
• func RunWorker(jobs string, concurrency int) (string, error)
• func RunWorkerCommand(args *Args)
• func SetupRootCommand() *cobra.Command
• type Args
• type Batch
  • func (b *Batch) IsValid() error
  • func (b *Batch) Key() string
• type Client
  • func (c *Client) Batch(b *Batch) ([]*Result, error)
• type Request
  • func (r *Request) Address() string
  • func (r *Request) Command() []string
• type Result
  • func IssueBatch(batch *Batch, concurrency int) []*Result
  • func IssueRequest(r *Request) *Result
  • func IssueRequestWithRetries(r *Request, retries int) *Result
  • func (r *Result) IsSuccess() bool

Functions

func Run

func Run()

func RunWorker

func RunWorker(jobs string, concurrency int) (string, error)

func RunWorkerCommand

func RunWorkerCommand(args *Args)

func SetupRootCommand

func SetupRootCommand() *cobra.Command

Types

type Args

type Args struct {
	//Verbosity string
	Jobs        string
	Concurrency int
}

type Batch

type Batch struct {
	Namespace string
	Pod       string
	Container string
	Requests  []*Request
}

func (*Batch) IsValid

func (b *Batch) IsValid() error

func (*Batch) Key

func (b *Batch) Key() string

type Client

type Client struct {
	Kubernetes kube.IKubernetes
}

func (*Client) Batch

func (c *Client) Batch(b *Batch) ([]*Result, error)

type Request

type Request struct {
	Key      string
	Protocol v1.Protocol
	Host     string
	Port     int
}

func (*Request) Address

func (r *Request) Address() string

func (*Request) Command

func (r *Request) Command() []string

type Result

type Result struct {
	Request *Request
	Output  string
	Error   string
}

func IssueBatch

func IssueBatch(batch *Batch, concurrency int) []*Result

func IssueRequest

func IssueRequest(r *Request) *Result

func IssueRequestWithRetries

func IssueRequestWithRetries(r *Request, retries int) *Result

func (*Result) IsSuccess

func (r *Result) IsSuccess() bool