agent

package

v0.0.0-...-6a3170c Latest Latest Go to latest Published: Apr 17, 2025 License: GPL-3.0 Imports: 24 Imported by: 0

Details

View Source

const (
	None abortedReason = iota
	TimeoutAbortReason
	HeartbeatAbortReason
)

View Source

var StopError = util.StringError("agent is closed")

This section is empty.

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

func NewAgent(engine engine.Engine, client api.ServerClient, label string) *Agent

func (a *Agent) GracefulShutdown()

GracefulShutdown stops to accept new jobs and await all accepted jobs to be completed and to exit.

func (a *Agent) Run(ctx context.Context, concurrency int, fetchInterval time.Duration) error

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

func NewExecution(engine engine.Engine, job *api.Job, client api.ServerClient) *Execution

func (e *Execution) CreateLogWriter(ctx context.Context, logName string) io.WriteCloser

func (e *Execution) Execute(ctx context.Context) error

Execute executes the job.

func (e *Execution) GetDefaultLogWriter(ctx context.Context) io.WriteCloser

Path	Synopsis
dag