internal

Documentation

Index

• func Run(parent context.Context, version string, opts options.Options) error
• type Agent
  • func NewAgent(parent context.Context, version string, opts options.Options) *Agent
  • func (a *Agent) Wait() error
• type MasterWebsocket

Functions

func Run

func Run(parent context.Context, version string, opts options.Options) error

Run runs a new agent system and actor with the provided options.

Types

type Agent

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

Agent is the manager for all other routines in the agent. It launches the container manager, and all external connections, to Docker and the master. Once launched, it takes actions directed by the master and monitors the subroutines for failure. The agent fails and enters the recovery flow on the failure of any component.

func NewAgent

func NewAgent(parent context.Context, version string, opts options.Options) *Agent

NewAgent constructs and runs a new agent according to the provided configuration.

func (*Agent) Wait

func (a *Agent) Wait() error

Wait for the agent to exit, returning an error indicating the reason.

type MasterWebsocket

type MasterWebsocket = ws.WebSocket[*aproto.AgentMessage, *aproto.MasterMessage]

MasterWebsocket is the type for a websocket which communicates with the master.