runtime

Feb 8, 2026

Changes in this version

type TLSConfig

+ ExternalTLS bool

Feb 8, 2026

Changes in this version

+ type DistributedOption func(*DistributedRuntime)

+ func WithDistributedSessionManager(sm session.Manager) DistributedOption

+ func WithTLS(cfg *TLSConfig) DistributedOption

type DistributedRuntime

+ func (r *DistributedRuntime) CallWithSession(ctx context.Context, target string, input *publicAgent.Message, ...) (*publicAgent.Message, error)

+ func (r *DistributedRuntime) Config() RuntimeConfig

+ func (r *DistributedRuntime) GetChannelStats(name string) (capacity, length int, err error)

+ func (r *DistributedRuntime) ListenAddr() string

+ func (r *DistributedRuntime) MessagesSent() uint64

+ func (r *DistributedRuntime) SessionManager() session.Manager

+ func (r *DistributedRuntime) SetSessionManager(sm session.Manager)

type DistributedRuntimeConfig

+ TLS *TLSConfig

type Option

+ func WithSendTimeout(timeout time.Duration) Option

+ func WithTracing(enabled bool) Option

type RuntimeConfig

+ ChannelFullWarningThreshold int

+ EnableTracing bool

+ SendTimeout time.Duration

+ type TLSConfig struct

+ CAFile string

+ CertFile string

+ Enabled bool

+ InsecureSkipVerify bool

+ KeyFile string

+ ServerName string

Jan 2, 2026

Changes in this version

type DistributedRuntime

+ func (r *DistributedRuntime) StartAgentsPhased(ctx context.Context, agentDefs map[string]agent.AgentDef) error

type LocalRuntime

+ func (r *LocalRuntime) StartAgentsPhased(ctx context.Context, agentDefs map[string]agent.AgentDef) error

type Option

+ func WithAgentStartTimeout(timeout time.Duration) Option

type RuntimeConfig

+ AgentStartTimeout time.Duration

Dec 6, 2025

Changes in this version

+ var ErrAgentAlreadyRegistered = errors.New("agent already registered")

+ var ErrAgentNotFound = errors.New("agent not found")

+ var ErrAgentNotReady = errors.New("agent not ready")

+ var ErrRuntimeAlreadyStarted = errors.New("runtime already started")

+ var ErrRuntimeNotStarted = errors.New("runtime not started")

+ type DistributedRuntime struct

+ func NewDistributedRuntime(listenAddr string, opts ...Option) *DistributedRuntime

+ func (r *DistributedRuntime) Broadcast(msg *agent.Message) error

+ func (r *DistributedRuntime) Call(ctx context.Context, target string, input *agent.Message) (*agent.Message, error)

+ func (r *DistributedRuntime) CallParallel(ctx context.Context, targets []string, input *agent.Message) (map[string]*agent.Message, map[string]error)

+ func (r *DistributedRuntime) Connect(name, addr string) error

+ func (r *DistributedRuntime) Get(name string) (agent.Agent, error)

+ func (r *DistributedRuntime) List() []string

+ func (r *DistributedRuntime) Recv(source string) (<-chan *agent.Message, error)

+ func (r *DistributedRuntime) Register(a agent.Agent) error

+ func (r *DistributedRuntime) Send(target string, msg *agent.Message) error

+ func (r *DistributedRuntime) Start(ctx context.Context) error

+ func (r *DistributedRuntime) Stop(ctx context.Context) error

+ func (r *DistributedRuntime) Unregister(name string) error

+ type DistributedRuntimeConfig struct

+ ListenAddr string

+ type LocalRuntime struct

+ func NewLocalRuntime(opts ...Option) *LocalRuntime

+ func (r *LocalRuntime) Broadcast(msg *agent.Message) error

+ func (r *LocalRuntime) Call(ctx context.Context, target string, input *agent.Message) (*agent.Message, error)

+ func (r *LocalRuntime) CallParallel(ctx context.Context, targets []string, input *agent.Message) (map[string]*agent.Message, map[string]error)

+ func (r *LocalRuntime) Get(name string) (agent.Agent, error)

+ func (r *LocalRuntime) GetChannelStats(name string) (capacity, length int, err error)

+ func (r *LocalRuntime) List() []string

+ func (r *LocalRuntime) Recv(source string) (<-chan *agent.Message, error)

+ func (r *LocalRuntime) Register(a agent.Agent) error

+ func (r *LocalRuntime) Send(target string, msg *agent.Message) error

+ func (r *LocalRuntime) Start(ctx context.Context) error

+ func (r *LocalRuntime) Stop(ctx context.Context) error

+ func (r *LocalRuntime) Unregister(name string) error

+ type Option func(*RuntimeConfig)

+ func WithChannelBufferSize(size int) Option

+ func WithMaxConcurrentCalls(max int) Option

+ func WithMetrics(enabled bool) Option

+ type RuntimeConfig struct

+ ChannelBufferSize int

+ EnableMetrics bool

+ MaxConcurrentCalls int

+ func DefaultConfig() *RuntimeConfig