task

Documentation

Index

• type Client
  • func (c Client) Create(ctx context.Context, params *CreateParams) error
  • func (c Client) Delete(ctx context.Context, params *DeleteParams) error
  • func (c Client) Find(ctx context.Context, params *FindParams) error
  • func (c Client) FindLogs(ctx context.Context, params *LogFindParams) error
  • func (c Client) FindRuns(ctx context.Context, params *RunFindParams) error
  • func (c Client) RetryFailed(ctx context.Context, params *RetryFailedParams) error
  • func (c Client) RetryRun(ctx context.Context, params *RunRetryParams) error
  • func (c Client) Update(ctx context.Context, params *UpdateParams) error
• type CreateParams
• type DeleteParams
• type FindParams
• type LogFindParams
• type NameOrID
  • func (n NameOrID) IDOrNil() *string
  • func (n NameOrID) NameOrNil() *string
• type RetryFailedParams
• type RunFilter
• type RunFindParams
• type RunRetryParams
• type UpdateParams

Types

type Client

type Client struct {
	clients.CLI
	api.TasksApi
	// AllowEmptyOrg will be useful for Kapacitor which doesn't use org / orgID
	AllowEmptyOrg bool
}

func (Client) Create

func (c Client) Create(ctx context.Context, params *CreateParams) error

func (Client) Delete

func (c Client) Delete(ctx context.Context, params *DeleteParams) error

func (Client) Find

func (c Client) Find(ctx context.Context, params *FindParams) error

func (Client) FindLogs

func (c Client) FindLogs(ctx context.Context, params *LogFindParams) error

func (Client) FindRuns

func (c Client) FindRuns(ctx context.Context, params *RunFindParams) error

func (Client) RetryFailed

func (c Client) RetryFailed(ctx context.Context, params *RetryFailedParams) error

func (Client) RetryRun

func (c Client) RetryRun(ctx context.Context, params *RunRetryParams) error

func (Client) Update

func (c Client) Update(ctx context.Context, params *UpdateParams) error

type CreateParams

type CreateParams struct {
	clients.OrgParams
	FluxQuery    string
	Name         string
	Every        string
	Cron         string
	ScriptID     string
	ScriptParams map[string]interface{}
}

type DeleteParams

type DeleteParams struct {
	TaskID string
}

type FindParams

type FindParams struct {
	clients.OrgParams
	TaskID   string
	UserID   string
	ScriptID string
	Limit    int
}

type LogFindParams

type LogFindParams struct {
	TaskID string
	RunID  string
}

type NameOrID

type NameOrID struct {
	Name string
	ID   string
}

func (NameOrID) IDOrNil

func (n NameOrID) IDOrNil() *string

func (NameOrID) NameOrNil

func (n NameOrID) NameOrNil() *string

type RetryFailedParams

type RetryFailedParams struct {
	clients.OrgParams
	TaskID    string
	DryRun    bool
	TaskLimit int
	RunFilter RunFilter
}

type RunFilter

type RunFilter struct {
	After  string
	Before string
	Limit  int
	Status string
}

type RunFindParams

type RunFindParams struct {
	TaskID string
	RunID  string
	Filter RunFilter
}

type RunRetryParams

type RunRetryParams struct {
	TaskID string
	RunID  string
}

type UpdateParams

type UpdateParams struct {
	FluxQuery    string
	TaskID       string
	Status       string
	ScriptID     string
	ScriptParams map[string]interface{}
}