e2e

package
v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 14, 2026 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AssertContains

func AssertContains(t *testing.T, s, substr, msg string)

AssertContains fails if substr is not in s

func AssertEqual

func AssertEqual(t *testing.T, expected, actual any, msg string)

AssertEqual fails if expected != actual

func AssertEventuallyTrue

func AssertEventuallyTrue(t *testing.T, condition func() bool, timeout time.Duration, msg string)

AssertEventuallyTrue waits for a condition to become true

func AssertNoError

func AssertNoError(t *testing.T, err error, msg string)

AssertNoError fails if err is not nil

func CreateTestAgentDef

func CreateTestAgentDef(name, role, model string) agent.AgentDef

CreateTestAgentDef creates a test agent definition

func CreateTestMessage

func CreateTestMessage(id, msgType, payload string) *agent.Message

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

CreateCompletion implements provider.Provider

func (*MockE2EProvider) CreateStreaming

CreateStreaming implements provider.Provider

func (*MockE2EProvider) CreateStructured

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

func (*MockE2EProvider) Reset

func (m *MockE2EProvider) Reset()

Reset resets the mock

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) Close

func (m *MockE2ERuntime) Close()

Close closes all channels

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) Close

func (s *MockStream) Close() error

Close implements provider.Stream

func (*MockStream) Recv

func (s *MockStream) Recv() (*provider.StreamChunk, error)

Recv implements provider.Stream

type SendCall

type SendCall struct {
	Target  string
	Message *agent.Message
}

SendCall records a Send call

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

type ToolCall

type ToolCall struct {
	Name string
	Args map[string]any
}

ToolCall records a tool call

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL