agent

package

v1.0.0 Latest Latest Go to latest Published: May 31, 2024 License: GPL-3.0 Imports: 28 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Agent is the interface to run / cancel / signal / status / etc.

func New(config *Config, e engine.Engine, ds persistence.DataStoreFactory) *Agent

func (a *Agent) Handle(server *runtime.RuntimeServer, event *runtime.Event)

func (a *Agent) Kill()

Kill sends KILL signal to all child processes.

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

Run starts the dags execution.

func (a *Agent) Signal(sig os.Signal)

Signal sends the signal to the processes running if processes do not terminate after MaxCleanUp time, it will send KILL signal.

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

Status returns the current status of the dags.

type Config struct {
	DAG *dag.DAG
	Dry bool

	// RetryTarget is the status to retry.
	RetryTarget *model.Status
}

Config contains the configuration for an Agent.

type HTTPError struct {
	Code    int
	Message string
}

func (e *HTTPError) Error() string