agent

package

v0.2.0-beta1 Latest Latest Go to latest Published: Apr 13, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

Details

This section is empty.

View Source

var ErrShuttingDown = fmt.Errorf("runner is being terminated")

func IsErrorOfInterest(err error) bool

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

func NewAgent(ctx context.Context, conn *websocket.Conn, instance params.Instance, store runner.AgentStoreOps) (*Agent, error)

func (a *Agent) CreateShellSession(ctx context.Context, sessionID uuid.UUID, clientConn *websocket.Conn) (*ClientSession, error)

func (a *Agent) Done() <-chan struct{}

func (a *Agent) IsRunning() bool

func (a *Agent) RemoveClientSession(sessionID uuid.UUID, safe bool) error

func (a *Agent) Start() error

func (a *Agent) Stop() error

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

func NewClientSession(ctx context.Context, clientConn *websocket.Conn, agentWriter writeMessage, sessionID uuid.UUID) (*ClientSession, error)

func (c *ClientSession) Done() chan struct{}

func (c *ClientSession) Start() error

func (c *ClientSession) Stop() error

func (c *ClientSession) Write(msg []byte) error

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

func NewHub(ctx context.Context) (*Hub, error)

func (a *Hub) GetAgent(agentID string) (*Agent, error)

func (a *Hub) RegisterAgent(agent *Agent) error

func (a *Hub) Start() error

func (a *Hub) Stop() error

func (a *Hub) UnregisterAgent(agentID string) error

Path	Synopsis
messaging