executor

Jul 20, 2025

Changes in this version

+ var ErrHostUnset = errors.New("host is not set in the connection configuration")

Jul 20, 2025

Changes in this version

type ConnectionState

+ MaxParallel int

+ TaskCount int

+ TaskCountMutex sync.Mutex

+ func (cs *ConnectionState) FinishedTask()

May 27, 2025

Changes in this version

+ func AnsibleExecute[I AnsibleExecuteArgs, O AnsibleExecuteReturn](ctx context.Context, connection *types.Connection, args I, preview bool) (O, error)

+ func PreviewUnreachable(ctx context.Context, connection *types.Connection, preview bool) bool

+ func StageFile(ctx context.Context, connection *types.Connection, f io.Reader) (string, error)

+ type AnsibleExecuteArgs interface

+ ToRPCCall func() (rpc.RPCCall[rpc.AnsibleExecuteArgs], error)

+ type AnsibleExecuteReturn interface

+ GetMsg func() string

+ IsChanged func() bool

type ConnectionState

+ CanConnectMutex sync.Mutex

+ SetupAgentMutex sync.Mutex

+ Unreachable bool

May 23, 2025

Changes in this version

+ var AgentPool = syncmap.Map[uint64, *ConnectionState]

+ var ErrUnreachable = errors.New("host is unreachable")

+ func DisconnectAll(ctx context.Context) error

+ type ConnectionState struct

+ Agent *midagent.Agent

+ Connection *types.Connection

+ ID uint64

+ Mutex sync.Mutex

+ Reachable bool

+ func Acquire(ctx context.Context, connection *types.Connection) (*ConnectionState, error)

+ func (cs *ConnectionState) SetupAgent(ctx context.Context) error

May 13, 2025

Changes in this version

+ var Tracer = otel.Tracer("mid/provider/executor")

+ func CallAgent[I any, O any](ctx context.Context, a *agent.Agent, call rpc.RPCCall[I]) (rpc.RPCResult[O], error)

+ func CanConnect(ctx context.Context, connection *types.Connection, maxAttempts int) (bool, error)

+ func ConnectionToSSHClientConfig(connection *types.Connection) (*ssh.ClientConfig, string, error)

+ func DialWithRetry[T any](ctx context.Context, msg string, maxAttempts int, f func() (T, error)) (T, error)

+ func StartAgent(ctx context.Context, connection *types.Connection) (*agent.Agent, error)

Apr 26, 2025

Changes in this version

+ func GetTaskResult[T any](playOutput PlayOutput, play int, task int) (T, error)

+ func RunPlaybook(ctx context.Context, connection *types.Connection, playbook []byte) ([]byte, error)

+ type Play struct

+ Become bool

+ Check bool

+ GatherFacts bool

+ Tasks []any

+ type PlayOutput struct

+ CustomStats map[string]any

+ GlobalCustomStats map[string]any

+ Results []PlayOutputResult

+ Stats map[string]PlayOutputStats

+ func RunPlay(ctx context.Context, connection *types.Connection, plays ...Play) (PlayOutput, error)

+ type PlayOutputItemMetadata struct

+ Duration PlayOutputItemMetadataDuration

+ Id string

+ Name string

+ Path string

+ type PlayOutputItemMetadataDuration struct

+ End time.Time

+ Start time.Time

+ type PlayOutputResult struct

+ Play PlayOutputItemMetadata

+ Tasks []PlayOutputTask

+ type PlayOutputStats struct

+ Changed uint

+ Failures uint

+ Ignored uint

+ Ok uint

+ Rescued uint

+ Skipped uint

+ Unreachable uint

+ type PlayOutputTask struct

+ Hosts map[string]any

+ Task PlayOutputItemMetadata