cmd

Documentation

Overview

Package cmd provides default implementation for command-line-like actions.

Index

• type ResyncAction
  • func (c *ResyncAction) GetName() string
  • func (c *ResyncAction) Init(job *jobs.Job, cl client.Client, action *jobs.Action) error
  • func (c *ResyncAction) Run(ctx context.Context, channels *actions.RunnableChannels, ...) (jobs.ActionMessage, error)
  • func (c *ResyncAction) SetTask(task *jobs.Task)
• type RpcAction
  • func (c *RpcAction) GetName() string
  • func (c *RpcAction) Init(job *jobs.Job, cl client.Client, action *jobs.Action) error
  • func (c *RpcAction) Run(ctx context.Context, channels *actions.RunnableChannels, ...) (jobs.ActionMessage, error)
• type ShellAction
  • func (c *ShellAction) GetName() string
  • func (c *ShellAction) Init(job *jobs.Job, cl client.Client, action *jobs.Action) error
  • func (c *ShellAction) Run(ctx context.Context, channels *actions.RunnableChannels, ...) (jobs.ActionMessage, error)
• type WGetAction
  • func (w *WGetAction) GetName() string
  • func (w *WGetAction) Init(job *jobs.Job, cl client.Client, action *jobs.Action) error
  • func (w *WGetAction) Run(ctx context.Context, channels *actions.RunnableChannels, ...) (jobs.ActionMessage, error)

Types

type ResyncAction

type ResyncAction struct {
	ServiceName string
	Path        string
	DryRun      bool
	CrtTask     *jobs.Task
}

func (*ResyncAction) GetName

func (c *ResyncAction) GetName() string

Unique identifier

func (*ResyncAction) Init

func (c *ResyncAction) Init(job *jobs.Job, cl client.Client, action *jobs.Action) error

Pass parameters

func (*ResyncAction) Run

func (c *ResyncAction) Run(ctx context.Context, channels *actions.RunnableChannels, input jobs.ActionMessage) (jobs.ActionMessage, error)

Run the actual action code

func (*ResyncAction) SetTask

func (c *ResyncAction) SetTask(task *jobs.Task)

Implement TaskUpdaterDelegateAction as the target service will update the task status on its side.

type RpcAction

type RpcAction struct {
	Client      client.Client
	ServiceName string
	MethodName  string
	JsonRequest interface{}
}

func (*RpcAction) GetName

func (c *RpcAction) GetName() string

Unique identifier

func (*RpcAction) Init

func (c *RpcAction) Init(job *jobs.Job, cl client.Client, action *jobs.Action) error

Pass parameters

func (*RpcAction) Run

func (c *RpcAction) Run(ctx context.Context, channels *actions.RunnableChannels, input jobs.ActionMessage) (jobs.ActionMessage, error)

Run the actual action code

type ShellAction

type ShellAction struct {
	Client          client.Client
	Router          *views.Router
	CmdBin          string
	CmdParameters   []string
	TemporaryFolder string
	ExitOnError     bool

	// Input via tmp file or via StdIn
	StreamToStdIn      bool
	UseTemporaryFolder bool
	// Output (if any) from tmp file or from StdOut
	OutputNodePlaceHolder string
	StreamFromStdOut      bool
	// Output result
	ResultPlaceHolder string
}

func (*ShellAction) GetName

func (c *ShellAction) GetName() string

Unique identifier

func (*ShellAction) Init

func (c *ShellAction) Init(job *jobs.Job, cl client.Client, action *jobs.Action) error

Pass parameters

func (*ShellAction) Run

func (c *ShellAction) Run(ctx context.Context, channels *actions.RunnableChannels, input jobs.ActionMessage) (jobs.ActionMessage, error)

Run the actual action code

type WGetAction

type WGetAction struct {
	Router    *views.Router
	SourceUrl *url.URL
}

WGetAction performs a wget command with the provided URL

func (*WGetAction) GetName

func (w *WGetAction) GetName() string

GetName returns the unique identifier of this action

func (*WGetAction) Init

func (w *WGetAction) Init(job *jobs.Job, cl client.Client, action *jobs.Action) error

Init passes parameters

func (*WGetAction) Run

func (w *WGetAction) Run(ctx context.Context, channels *actions.RunnableChannels, input jobs.ActionMessage) (jobs.ActionMessage, error)

Run the actual action code