test

Jun 2, 2025

Changes in this version

type MockTransport

+ func (m *MockTransport) GetLogger() *slog.Logger

+ func (m *MockTransport) GetProtocolVersion() string

+ func (m *MockTransport) Initialize() error

+ func (m *MockTransport) Receive() ([]byte, error)

+ func (m *MockTransport) SetDebugHandler(handler transport.DebugHandler)

+ func (m *MockTransport) SetLogger(logger *slog.Logger)

+ func (m *MockTransport) SetMessageHandler(handler transport.MessageHandler)

+ func (m *MockTransport) SetProtocolVersion(version string)

+ func (m *MockTransport) Start() error

+ func (m *MockTransport) Stop() error

May 18, 2025

Changes in this version

+ func NewServer(name string) server.Server

+ func WithLogger(logger *slog.Logger) server.Option

+ type ClientInfo struct

+ ProtocolVersion string

+ SamplingCaps SamplingCapabilities

+ SamplingSupported bool

+ type ClientSession struct

+ ClientInfo ClientInfo

+ ID SessionID

+ Metadata map[string]interface{}

+ type Context struct

+ Metadata map[string]interface{}

+ Request *Request

+ Response *Response

+ Version string

+ type MockTransport struct

+ func NewMockTransport() *MockTransport

+ func (m *MockTransport) ClearMessages()

+ func (m *MockTransport) ClearRequestHistory()

+ func (m *MockTransport) Connect() error

+ func (m *MockTransport) ConnectWithContext(ctx context.Context) error

+ func (m *MockTransport) Disconnect() error

+ func (m *MockTransport) GetMessages() [][]byte

+ func (m *MockTransport) GetRequestHistory() [][]byte

+ func (m *MockTransport) GetSendHandler() func([]byte)

+ func (m *MockTransport) RegisterNotificationHandler(handler func(method string, params []byte))

+ func (m *MockTransport) Send(message []byte) ([]byte, error)

+ func (m *MockTransport) SendAsync(ctx context.Context, message []byte) error

+ func (m *MockTransport) SendWithContext(ctx context.Context, message []byte) ([]byte, error)

+ func (m *MockTransport) SetConnectionTimeout(timeout time.Duration)

+ func (m *MockTransport) SetHandler(handler func([]byte))

+ func (m *MockTransport) SetRequestTimeout(timeout time.Duration)

+ func (m *MockTransport) SetResponseDelay(delay time.Duration)

+ func (m *MockTransport) SetSendCallback(callback func(message []byte) ([]byte, error))

+ func (m *MockTransport) SetSendFunc(sendFunc func(data []byte) error)

+ func (m *MockTransport) SimulateMessage(message []byte)

+ type Request struct

+ ID interface{}

+ JSONRPC string

+ Method string

+ Params map[string]interface{}

+ ToolArgs map[string]interface{}

+ ToolName string

+ type RequestSamplingOptions struct

+ ForceSession bool

+ IgnoreCapability bool

+ MaxRetries int

+ RetryInterval time.Duration

+ Timeout time.Duration

+ func DefaultSamplingOptions() RequestSamplingOptions

+ type Response struct

+ Error interface{}

+ ID interface{}

+ JSONRPC string

+ Result interface{}

+ type SamplingCapabilities struct

+ AudioSupport bool

+ ImageSupport bool

+ Supported bool

+ TextSupport bool

+ func DetectClientCapabilities(protocolVersion string) SamplingCapabilities

+ type SamplingMessage struct

+ Content SamplingMessageContent

+ Role string

+ func CreateAudioSamplingMessage(role, audioData, mimeType string) SamplingMessage

+ func CreateImageSamplingMessage(role, imageData, mimeType string) SamplingMessage

+ func CreateTextSamplingMessage(role, text string) SamplingMessage

+ type SamplingMessageContent struct

+ Data string

+ MimeType string

+ Text string

+ Type string

+ func (c SamplingMessageContent) IsValidForVersion(version string) bool

+ type SamplingModelHint struct

+ Name string

+ type SamplingModelPreferences struct

+ CostPriority *float64

+ Hints []SamplingModelHint

+ IntelligencePriority *float64

+ SpeedPriority *float64

+ type SamplingResponse struct

+ Content SamplingMessageContent

+ Model string

+ Role string

+ StopReason string

+ type SessionID string

+ type SessionManager struct

+ func NewSessionManager() *SessionManager

+ func (sm *SessionManager) CloseSession(id SessionID) bool

+ func (sm *SessionManager) CreateSession(clientInfo ClientInfo, protocolVersion string) *ClientSession

+ func (sm *SessionManager) GetSession(id SessionID) (*ClientSession, bool)

+ func (sm *SessionManager) UpdateClientCapabilities(id SessionID, caps SamplingCapabilities) bool

+ func (sm *SessionManager) UpdateSession(id SessionID, updateFn func(*ClientSession)) bool

+ type ToolHandler func(*Context, interface{}) (interface{}, error)