agent

package

v1.0.5 Latest Latest Go to latest Published: Mar 29, 2024 License: GPL-3.0 Imports: 25 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

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) HandleHTTP(w http.ResponseWriter, r *http.Request)

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