testexecutor

Mar 20, 2026

Changes in this version

+ func NewWithControlChannels() (*TestAgentExecutor, *ControlChannels)

+ type ControlChannels struct

+ CancelCalled <-chan struct{}

+ ContinueCancel chan<- struct{}

+ ExecEvent chan<- a2a.Event

+ ReqCtx <-chan *a2asrv.RequestContext

type TestAgentExecutor

+ func NewCanceler() *TestAgentExecutor

Mar 11, 2026

Changes in this version

type TestAgentExecutor

+ CleanupFn func(context.Context, *a2asrv.RequestContext, a2a.SendMessageResult, error)

+ func (e *TestAgentExecutor) Cleanup(ctx context.Context, reqCtx *a2asrv.RequestContext, ...)

Nov 4, 2025

Changes in this version

+ type TestAgentExecutor struct

+ CancelFn func(context.Context, *a2asrv.RequestContext, eventqueue.Queue) error

+ Emitted []a2a.Event

+ ExecuteFn func(context.Context, *a2asrv.RequestContext, eventqueue.Queue) error

+ func FromEventGenerator(generator func(reqCtx *a2asrv.RequestContext) []a2a.Event) *TestAgentExecutor

+ func FromFunction(fn func(context.Context, *a2asrv.RequestContext, eventqueue.Queue) error) *TestAgentExecutor

+ func (e *TestAgentExecutor) Cancel(ctx context.Context, reqCtx *a2asrv.RequestContext, q eventqueue.Queue) error

+ func (e *TestAgentExecutor) Execute(ctx context.Context, reqCtx *a2asrv.RequestContext, q eventqueue.Queue) error