transport

type ClientReceiverF func(ctx context.Context, msg []byte) error

type ClientTransport interface {
	// Start initiates the transport connection
	Start() error

	// Send transmits a message
	Send(ctx context.Context, msg Message) error

	// SetReceiver sets the handler for messages from the peer
	SetReceiver(receiver clientReceiver)

	// Close terminates the transport connection
	Close() error
}

type Message []byte

type SSEClientTransportOption func(*sseClientTransport)

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

type SSEServerTransportAndHandlerOption func(*sseServerTransport)

type SSEServerTransportOption func(*sseServerTransport)

type ServerReceiverF func(ctx context.Context, sessionID string, msg []byte) error

type ServerTransport interface {
	// Run starts listening for requests, this is synchronous, and cannot return before Shutdown is called
	Run() error

	// Send transmits a message
	Send(ctx context.Context, sessionID string, msg Message) error

	// SetReceiver sets the handler for messages from the peer
	SetReceiver(serverReceiver)

	SetSessionManager(manager sessionManager)

	// Shutdown gracefully closes, the internal implementation needs to stop receiving messages first,
	// then wait for serverCtx to be canceled, while using userCtx to control timeout.
	// userCtx is used to control the timeout of the server shutdown.
	// serverCtx is used to coordinate the internal cleanup sequence:
	// 1. turn off message listen
	// 2. Wait for serverCtx to be done (indicating server shutdown is complete)
	// 3. Cancel the transport's context to stop all ongoing operations
	// 4. Wait for all in-flight sends to complete
	// 5. Close all session
	Shutdown(userCtx context.Context, serverCtx context.Context) error
}

type StdioClientTransportOption func(*stdioClientTransport)

type StdioServerTransportOption func(*stdioServerTransport)