Documentation
¶
Index ¶
- func AssertContains(t *testing.T, s, substr, msg string)
- func AssertEqual(t *testing.T, expected, actual any, msg string)
- func AssertEventuallyTrue(t *testing.T, condition func() bool, timeout time.Duration, msg string)
- func AssertNoError(t *testing.T, err error, msg string)
- func CreateTestAgentDef(name, role, model string) agent.AgentDef
- func CreateTestMessage(id, msgType, payload string) *agent.Message
- type MockE2EProvider
- func (m *MockE2EProvider) AddResponse(resp *provider.CompletionResponse)
- func (m *MockE2EProvider) AddTextResponse(content string)
- func (m *MockE2EProvider) AddToolCallResponse(toolName string, args map[string]any)
- func (m *MockE2EProvider) CreateCompletion(ctx context.Context, req provider.CompletionRequest) (*provider.CompletionResponse, error)
- func (m *MockE2EProvider) CreateStreaming(ctx context.Context, req provider.CompletionRequest) (provider.Stream, error)
- func (m *MockE2EProvider) CreateStructured(ctx context.Context, req provider.StructuredRequest) (*provider.StructuredResponse, error)
- func (m *MockE2EProvider) GetCalls() []provider.CompletionRequest
- func (m *MockE2EProvider) Name() string
- func (m *MockE2EProvider) Reset()
- type MockE2ERuntime
- func (m *MockE2ERuntime) Close()
- func (m *MockE2ERuntime) GetSendCalls() []SendCall
- func (m *MockE2ERuntime) Recv(source string) (<-chan *agent.Message, error)
- func (m *MockE2ERuntime) Send(target string, msg *agent.Message) error
- func (m *MockE2ERuntime) SendMessage(source string, msg *agent.Message)
- type MockMCPServer
- type MockStream
- type SendCall
- type TestEnvironment
- func (e *TestEnvironment) AuditLogger() *security.InMemoryAuditLogger
- func (e *TestEnvironment) Cleanup()
- func (e *TestEnvironment) Context() context.Context
- func (e *TestEnvironment) MCPServer() *MockMCPServer
- func (e *TestEnvironment) Provider() *MockE2EProvider
- func (e *TestEnvironment) Runtime() *MockE2ERuntime
- type ToolCall
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AssertContains ¶
AssertContains fails if substr is not in s
func AssertEqual ¶
AssertEqual fails if expected != actual
func AssertEventuallyTrue ¶
AssertEventuallyTrue waits for a condition to become true
func AssertNoError ¶
AssertNoError fails if err is not nil
func CreateTestAgentDef ¶
CreateTestAgentDef creates a test agent definition
func CreateTestMessage ¶
CreateTestMessage creates a test message
Types ¶
type MockE2EProvider ¶
type MockE2EProvider struct {
// contains filtered or unexported fields
}
MockE2EProvider is a mock LLM provider for E2E testing
func NewMockE2EProvider ¶
func NewMockE2EProvider() *MockE2EProvider
NewMockE2EProvider creates a new mock provider
func (*MockE2EProvider) AddResponse ¶
func (m *MockE2EProvider) AddResponse(resp *provider.CompletionResponse)
AddResponse adds a response
func (*MockE2EProvider) AddTextResponse ¶
func (m *MockE2EProvider) AddTextResponse(content string)
AddTextResponse adds a text response
func (*MockE2EProvider) AddToolCallResponse ¶
func (m *MockE2EProvider) AddToolCallResponse(toolName string, args map[string]any)
AddToolCallResponse adds a response with tool calls
func (*MockE2EProvider) CreateCompletion ¶
func (m *MockE2EProvider) CreateCompletion(ctx context.Context, req provider.CompletionRequest) (*provider.CompletionResponse, error)
CreateCompletion implements provider.Provider
func (*MockE2EProvider) CreateStreaming ¶
func (m *MockE2EProvider) CreateStreaming(ctx context.Context, req provider.CompletionRequest) (provider.Stream, error)
CreateStreaming implements provider.Provider
func (*MockE2EProvider) CreateStructured ¶
func (m *MockE2EProvider) CreateStructured(ctx context.Context, req provider.StructuredRequest) (*provider.StructuredResponse, error)
CreateStructured implements provider.Provider
func (*MockE2EProvider) GetCalls ¶
func (m *MockE2EProvider) GetCalls() []provider.CompletionRequest
GetCalls returns all calls made
func (*MockE2EProvider) Name ¶
func (m *MockE2EProvider) Name() string
Name implements provider.Provider
type MockE2ERuntime ¶
type MockE2ERuntime struct {
// contains filtered or unexported fields
}
MockE2ERuntime is a comprehensive mock runtime for E2E testing
func NewMockE2ERuntime ¶
func NewMockE2ERuntime() *MockE2ERuntime
NewMockE2ERuntime creates a new mock runtime
func (*MockE2ERuntime) GetSendCalls ¶
func (m *MockE2ERuntime) GetSendCalls() []SendCall
GetSendCalls returns all send calls
func (*MockE2ERuntime) Recv ¶
func (m *MockE2ERuntime) Recv(source string) (<-chan *agent.Message, error)
Recv implements agent.Runtime
func (*MockE2ERuntime) Send ¶
func (m *MockE2ERuntime) Send(target string, msg *agent.Message) error
Send implements agent.Runtime
func (*MockE2ERuntime) SendMessage ¶
func (m *MockE2ERuntime) SendMessage(source string, msg *agent.Message)
SendMessage sends a message to a channel
type MockMCPServer ¶
type MockMCPServer struct {
// contains filtered or unexported fields
}
MockMCPServer is a mock MCP server for E2E testing
func NewMockMCPServer ¶
func NewMockMCPServer() *MockMCPServer
NewMockMCPServer creates a new mock MCP server
func (*MockMCPServer) CallTool ¶
func (s *MockMCPServer) CallTool(ctx context.Context, name string, args map[string]any) (any, error)
CallTool calls a tool
func (*MockMCPServer) GetCalls ¶
func (s *MockMCPServer) GetCalls() []ToolCall
GetCalls returns all tool calls
func (*MockMCPServer) GetTools ¶
func (s *MockMCPServer) GetTools() []mcp.Tool
GetTools returns all registered tools
func (*MockMCPServer) RegisterTool ¶
func (s *MockMCPServer) RegisterTool(name, description string, handler mcp.ToolHandler)
RegisterTool registers a tool
type MockStream ¶
type MockStream struct {
// contains filtered or unexported fields
}
MockStream implements provider.Stream
func (*MockStream) Recv ¶
func (s *MockStream) Recv() (*provider.StreamChunk, error)
Recv implements provider.Stream
type TestEnvironment ¶
type TestEnvironment struct {
// contains filtered or unexported fields
}
TestEnvironment provides a complete test environment for E2E tests
func NewTestEnvironment ¶
func NewTestEnvironment(t *testing.T) *TestEnvironment
NewTestEnvironment creates a new test environment
func (*TestEnvironment) AuditLogger ¶
func (e *TestEnvironment) AuditLogger() *security.InMemoryAuditLogger
AuditLogger returns the audit logger
func (*TestEnvironment) Cleanup ¶
func (e *TestEnvironment) Cleanup()
Cleanup cleans up the test environment
func (*TestEnvironment) Context ¶
func (e *TestEnvironment) Context() context.Context
Context returns the test context
func (*TestEnvironment) MCPServer ¶
func (e *TestEnvironment) MCPServer() *MockMCPServer
MCPServer returns the mock MCP server
func (*TestEnvironment) Provider ¶
func (e *TestEnvironment) Provider() *MockE2EProvider
Provider returns the mock provider
func (*TestEnvironment) Runtime ¶
func (e *TestEnvironment) Runtime() *MockE2ERuntime
Runtime returns the mock runtime