agent

Documentation

Overview

Package agent provides multi-conduit orchestration for ore agent applications. An Agent coordinates multiple conduit.Conduit instances, running them concurrently with a shared session.Manager.

Use New to create an Agent, Add to register conduits, and Run to start all registered conduits. Run blocks until the context is cancelled or any conduit returns a non-nil error.

Index

• type Agent
  • func New(mgr *session.Manager) *Agent
  • func (a *Agent) Add(c conduit.Conduit)
  • func (a *Agent) Run(ctx context.Context) error

Types

type Agent

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

Agent orchestrates multiple conduits with a shared session manager.

func New

func New(mgr *session.Manager) *Agent

New creates an Agent with the given session manager.

func (*Agent) Add

func (a *Agent) Add(c conduit.Conduit)

Add registers a conduit to be started by Run. Nil conduits are ignored.

func (*Agent) Run

func (a *Agent) Run(ctx context.Context) error

Run starts all registered conduits concurrently and blocks until ctx is cancelled or any conduit returns a non-nil error. When an error occurs, the context is cancelled to signal remaining conduits to shut down.