transport

type BaseTransport struct {
	// contains filtered or unexported fields
}

type DebugHandler func(message string)

type MessageHandler func(message []byte) ([]byte, error)

type Transport interface {
	// Initialize initializes the transport
	Initialize() error

	// Start starts the transport
	Start() error

	// Stop stops the transport
	Stop() error

	// Send sends a message over the transport.
	Send(message []byte) error

	// Receive receives a message from the transport.
	Receive() ([]byte, error)

	// SetMessageHandler sets the message handler
	SetMessageHandler(handler MessageHandler)

	// SetDebugHandler sets a handler for debug messages
	SetDebugHandler(handler DebugHandler)

	// SetLogger sets the structured logger
	SetLogger(logger *slog.Logger)

	// GetLogger returns the current logger
	GetLogger() *slog.Logger

	// SetProtocolVersion sets the negotiated MCP protocol version
	SetProtocolVersion(version string)

	// GetProtocolVersion returns the current protocol version
	GetProtocolVersion() string
}