agent

Oct 22, 2026

Changes in this version

+ const LogResumeMetadataKey

+ const LogResumedHeaderKey

Oct 12, 2026

Changes in this version

type WarmRunner

+ StreamHeartbeat time.Duration

Oct 6, 2026

Changes in this version

type CommandRunner

+ func NewExecRunnerRecordingGroup(path string) CommandRunner

type Runner

+ HomeDir string

type WarmRunner

+ AttemptHome bool

+ SharedMemDir string

+ SharedTmpDir string

Oct 3, 2026

Changes in this version

+ const DefaultHeartbeatInterval

+ func AttemptTokenTTL(interval time.Duration) time.Duration

+ func Backoff(attempt int) (delay time.Duration, ok bool)

+ func BuildCommand(operator, entrypoint, operatorClass string) ([]string, error)

+ func ClassifyBootstrapFailure(stage BootstrapStage, err error) string

+ func ExchangeToken(ctx context.Context, client agentv1.AgentServiceClient, tokens *TokenSource) error

+ func NewReturnValuePath() (path string, cleanup func() error, err error)

+ func ReadReturnValue(path string) (value []byte, ok bool, err error)

+ func ReadTokenFile(path string) (string, error)

+ func ReportBootstrapFailure(path string, stage BootstrapStage, err error)

+ func ResolverFromEnv(getenv func(string) string) (secretsource.SecretResolver, secretsource.Backend, error)

+ func XComEnvVar(name string, value []byte) string

+ type BootstrapStage int

+ const StageDial

+ const StageExchange

+ const StageToken

+ type CommandRunner interface

+ Run func(ctx context.Context, argv, env []string, stdout, stderr io.Writer) (exitCode int, err error)

+ func NewExecRunner() CommandRunner

+ type LogSink interface

+ Close func() error

+ Send func(line *agentv1.LogLine) error

+ func OpenLogSink(ctx context.Context, client agentv1.AgentServiceClient) (LogSink, error)

+ type NoopLogSink struct

+ func (NoopLogSink) Close() error

+ func (NoopLogSink) Send(*agentv1.LogLine) error

+ type Runner struct

+ BeforeReport func(agentv1.TaskState)

+ Client agentv1.AgentServiceClient

+ Cmd CommandRunner

+ Env []string

+ HeartbeatInterval time.Duration

+ Hostname string

+ LinksPath string

+ PushesPath string

+ ReschedulePath string

+ Resolver secretsource.SecretResolver

+ ReturnPath string

+ SecretBackend secretsource.Backend

+ Sink LogSink

+ TerminationLogPath string

+ TmpDir string

+ Token tokenSetter

+ Version string

+ func (r *Runner) Run(ctx context.Context) error

+ type TokenSource struct

+ func Dial(addr, token string, allowInsecure bool, caFile string) (agentv1.AgentServiceClient, *grpc.ClientConn, *TokenSource, error)

+ func NewTokenSource(token string) *TokenSource

+ func (s *TokenSource) Set(token string)

+ func (s *TokenSource) Token() string

+ type WarmRunner struct

+ AttemptTokens *TokenSource

+ AttemptWatchdog time.Duration

+ Cmd CommandRunner

+ Env []string

+ ExchangeBootstrap bool

+ HeartbeatInterval time.Duration

+ Hostname string

+ IdleTTL time.Duration

+ MaxAttempts int

+ MaxLifetime time.Duration

+ MaxReconnects int

+ NewSink func(ctx context.Context) (LogSink, error)

+ PodName string

+ ReconnectBackoff time.Duration

+ ReconnectMaxBackoff time.Duration

+ Redial func() (agentv1.AgentServiceClient, *TokenSource, io.Closer, error)

+ ScratchDir string

+ StreamClient agentv1.AgentServiceClient

+ StreamTokens *TokenSource

+ TerminationLogPath string

+ Version string

+ WorkClient agentv1.AgentServiceClient

+ func (w *WarmRunner) Run(ctx context.Context, dagVersionID string) error