runtime

Oct 20, 2026

Changes in this version

type ExternalResource

+ Type reflect.Type

+ func NewExternal(name, contract string, value any) ExternalResource

Oct 12, 2026

Changes in this version

type ReloadOption

+ func WithReloadExternals(externals []ExternalResource) ReloadOption

+ func WithReloadHostFactory(decorator HostFactoryDecorator) ReloadOption

+ func WithReloadResolver(resolver *resource.ReferenceResolver) ReloadOption

+ func WithReloadResultHostFactory(decorator ResultHostFactoryDecorator) ReloadOption

Oct 9, 2026

Changes in this version

+ type AgentConfig struct

+ RemoveTimeout time.Duration

type Config

+ Agents AgentConfig

type Runtime

+ func (r *Runtime) AgentRemoveTimeout() (time.Duration, bool)

Sep 7, 2026

Changes in this version

type Builder

+ func (b *Builder) WithResolver(resolver *resource.ReferenceResolver) error

Sep 7, 2026

Changes in this version

type Builder

+ func (b *Builder) WithExternalResource(ext ExternalResource) error

+ func (b *Builder) WithExternalResources(externals []ExternalResource) error

type Config

+ ExternalDeps []ExternalDependency

+ type ExternalDependency struct

+ Contract string

+ Name string

+ func (d ExternalDependency) Validate() error

+ type ExternalResource struct

+ Value any

+ func (e ExternalResource) Validate() error

Sep 5, 2026

Changes in this version

type Runtime

+ func (r *Runtime) Drain(ctx context.Context) error

Aug 25, 2026

Changes in this version

+ type StreamExportRegistry struct

+ func NewStreamExportRegistry(buses map[string]event.Bus) *StreamExportRegistry

+ func (r *StreamExportRegistry) ConversationSink(contextID string) (agent.StreamSink, bool)

+ func (r *StreamExportRegistry) Exporter(spec session.SinkSpec) (delegation.StreamTarget, bool)

+ func (r *StreamExportRegistry) RegisterConversation(contextID string, sink agent.StreamSink)

+ func (r *StreamExportRegistry) Resolver(ctx context.Context, target delegation.StreamTarget) (agent.StreamSink, error)

+ func (r *StreamExportRegistry) UnregisterConversation(contextID string)

Aug 21, 2026

Changes in this version

type AgentRegistry

+ func (r *AgentRegistry) DynamicNames() []string

Aug 18, 2026

Changes in this version

+ func PatternRuntimeRebuild() event.Pattern

+ func SubjectRuntimeRebuildCompleted() event.Subject

+ func SubjectRuntimeRebuildFailed() event.Subject

+ func SubjectRuntimeRebuildStarted() event.Subject

type AgentRegistry

+ func (r *AgentRegistry) Dynamic(id string) (*agent.Agent, bool)

+ func (r *AgentRegistry) Entries() map[string]dynamicAgentEntry

+ func (r *AgentRegistry) Replace(entries map[string]dynamicAgentEntry, deployed *deploy.Result)

type Builder

+ func (b *Builder) WithResultHostFactory(decorator ResultHostFactoryDecorator) error

+ type Generation struct

+ type ReloadOption func(*reloadOptions) error

+ type ReloadResult struct

+ DrainedAgents []string

+ GenerationID uint64

+ PreviousID uint64

+ ReboundAgents []string

+ type ResultHostFactoryDecorator func(result *deploy.Result, factory session.HostFactory) (session.HostFactory, error)

type Runtime

+ func (r *Runtime) Reload(ctx context.Context, doc deploy.Document, opts ...ReloadOption) (*ReloadResult, error)

+ func (r *Runtime) Resource(name string) (any, bool)

+ type RuntimeRebuildEvent struct

+ DrainedAgents []string

+ Error string

+ GenerationID uint64

+ PreviousGenerationID uint64

+ ReboundAgents []string

Aug 15, 2026

Changes in this version

+ func PatternAgentLifecycle() event.Pattern

+ func SubjectAgentRegistered(id string) event.Subject

+ func SubjectAgentRemoved(id string) event.Subject

+ type AgentLifecycleEvent struct

+ AgentID string

+ Description string

+ Name string

+ type AgentRegistry struct

+ func (r *AgentRegistry) Agent(id string) (*agent.Agent, bool)

+ func (r *AgentRegistry) AgentNames() []string

+ func (r *AgentRegistry) Close() error

+ func (r *AgentRegistry) Delete(id string) (*agent.Agent, bool)

+ func (r *AgentRegistry) Instance(id string) (*agent.Agent, bool)

+ func (r *AgentRegistry) Put(id string, instance *agent.Agent) error

+ type RegisterAgentOption func(*registerOptions) error

+ func WithToolAssembly(resourceName string) RegisterAgentOption

type Runtime

+ func (r *Runtime) Agent(name string) (*agent.Agent, bool)

+ func (r *Runtime) AgentNames() []string

+ func (r *Runtime) RegisterAgent(ctx context.Context, name string, def agent.Definition, ...) (*agent.Agent, error)

+ func (r *Runtime) UnregisterAgent(ctx context.Context, name string, opts ...UnregisterAgentOption) error

+ type UnregisterAgentOption func(*removeOptions) error

+ func WithRemoveTimeout(d time.Duration) UnregisterAgentOption

Aug 13, 2026

Changes in this version

type Runtime

+ func (r *Runtime) Attach(ctx context.Context, pattern event.Pattern, sink event.Sink, ...) (func(), error)

Aug 13, 2026

Changes in this version

+ var ErrBuilderUsed = errdefs.Conflictf("runtime Builder has already been used")

+ type Builder struct

+ func NewBuilder(reg *resource.Registry) *Builder

+ func (b *Builder) Build(ctx context.Context, doc deploy.Document) (*Runtime, error)

+ func (b *Builder) WithHostFactory(decorator HostFactoryDecorator) error

+ func (b *Builder) WithLoader(loader *resource.Loader) error

+ type Config struct

+ CheckpointStore string

+ DynamicCatalog *DynamicCatalogConfig

+ EventBus string

+ Sessions SessionConfig

+ func DecodeConfig(doc deploy.Document) (Config, error)

+ type DynamicCatalogConfig struct

+ Tools map[string]string

+ type HostFactoryDecorator func(session.HostFactory) (session.HostFactory, error)

+ type Runtime struct

+ func (r *Runtime) Close() error

+ func (r *Runtime) Sessions() *session.Manager

+ type SessionConfig struct

+ DeliveryConcurrency int

+ IdleTimeout time.Duration

+ MaxSessions int

+ Resume bool

+ SinkBuffer int

+ SpeculativeBufferBytes int

+ SpeculativeBufferEvents int