agent

Documentation

Index

• type Agent
  • func New(requestID string, dag *digraph.DAG, logDir string, logFile string, ...) *Agent
  • func (a *Agent) HandleHTTP(ctx context.Context) sock.HTTPHandlerFunc
  • func (a *Agent) PrintSummary(ctx context.Context)
  • func (a *Agent) Run(ctx context.Context) error
  • func (a *Agent) Signal(ctx context.Context, sig os.Signal)
  • func (a *Agent) Status() model.Status
• type Options
• type Sender

Types

type Agent

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

Agent is responsible for running the DAG and handling communication via the unix socket. The agent performs the following tasks: 1. Start the DAG execution. 2. Propagate a signal to the running processes. 3. Handle the HTTP request via the unix socket. 4. Write the log and status to the data store.

func New

func New(
	requestID string,
	dag *digraph.DAG,
	logDir string,
	logFile string,
	cli client.Client,
	dagStore persistence.DAGStore,
	historyStore persistence.HistoryStore,
	opts Options,
) *Agent

New creates a new Agent.

func (*Agent) HandleHTTP

func (a *Agent) HandleHTTP(ctx context.Context) sock.HTTPHandlerFunc

HandleHTTP handles HTTP requests via unix socket.

func (*Agent) PrintSummary

func (a *Agent) PrintSummary(ctx context.Context)

func (*Agent) Run

func (a *Agent) Run(ctx context.Context) error

Run setups the scheduler and runs the DAG.

func (*Agent) Signal

func (a *Agent) Signal(ctx context.Context, sig os.Signal)

Signal sends the signal to the processes running

func (*Agent) Status

func (a *Agent) Status() model.Status

Status collects the current running status of the DAG and returns it.

type Options

type Options struct {
	// Dry is a dry-run mode. It does not execute the actual command.
	// Dry run does not create history data.
	Dry bool
	// RetryTarget is the target status (history of execution) to retry.
	// If it's specified the agent will execute the DAG with the same
	// configuration as the specified history.
	RetryTarget *model.Status
}

Options is the configuration for the Agent.

type Sender

type Sender interface {
	Send(ctx context.Context, from string, to []string, subject, body string, attachments []string) error
}

Sender is a mailer interface.