Versions in this module Expand all Collapse all v1 v1.1.0 May 12, 2026 v1.0.13 May 12, 2026 v1.0.12 Apr 23, 2026 v1.0.11 Apr 23, 2026 v1.0.10 Apr 21, 2026 v1.0.9 Apr 7, 2026 v1.0.8 Apr 6, 2026 v1.0.7 Mar 30, 2026 v1.0.6 Mar 29, 2026 v1.0.5 Mar 29, 2026 v1.0.4 Mar 29, 2026 v1.0.3 Mar 22, 2026 v1.0.2 Mar 22, 2026 v1.0.1 Mar 22, 2026 v1.0.0 Mar 22, 2026 Changes in this version + func IDToString(id any) string + func NewErrorData(err error) any + type Code int + const InternalError + const InvalidParams + const InvalidRequest + const MethodNotFound + const ParseError + type ErrorData struct + Fault bool + ID string + Name string + Remedy *goa.ErrorRemedy + Temporary bool + Timeout bool + type ErrorResponse struct + Code Code + Data any + Message string + func (e *ErrorResponse) Error() string + type RawErrorResponse struct + Code int + Data json.RawMessage + Message string + func (e *RawErrorResponse) Error() string + type RawRequest struct + HasID bool + ID any + JSONRPC string + Method string + Params json.RawMessage + func (r *RawRequest) UnmarshalJSON(data []byte) error + type RawResponse struct + Error *RawErrorResponse + ID any + JSONRPC string + Result json.RawMessage + type Request struct + ID any + JSONRPC string + Method string + Params any + func MakeNotification(method string, params any) *Request + type Response struct + Error *ErrorResponse + ID any + JSONRPC string + Result any + func MakeErrorResponse(id any, code Code, message string, data any) *Response + func MakeSuccessResponse(id any, result any) *Response + type StreamConfig struct + CloseTimeout time.Duration + ConnectionTimeout time.Duration + EnableCompression bool + ErrorHandler StreamErrorHandler + MaxRetries int + PingInterval time.Duration + ReadBufferSize int + RequestTimeout time.Duration + ResultChannelBuffer int + RetryBackoffBase time.Duration + RetryBackoffMax time.Duration + WriteBufferSize int + func NewStreamConfig(opts ...StreamConfigOption) *StreamConfig + func (c *StreamConfig) Validate() *StreamConfig + type StreamConfigOption func(*StreamConfig) + func WithCloseTimeout(timeout time.Duration) StreamConfigOption + func WithCompression(enabled bool) StreamConfigOption + func WithConnectionTimeout(timeout time.Duration) StreamConfigOption + func WithErrorHandler(handler StreamErrorHandler) StreamConfigOption + func WithPingInterval(interval time.Duration) StreamConfigOption + func WithRequestTimeout(timeout time.Duration) StreamConfigOption + func WithResultChannelBuffer(size int) StreamConfigOption + func WithRetryConfig(maxRetries int, baseDelay, maxDelay time.Duration) StreamConfigOption + func WithWebSocketBuffers(readSize, writeSize int) StreamConfigOption + type StreamErrorHandler func(ctx context.Context, errorType StreamErrorType, err error, ...) + type StreamErrorType int + const StreamErrorConnection + const StreamErrorNotification + const StreamErrorOrphaned + const StreamErrorParsing + const StreamErrorProtocol + const StreamErrorTimeout
Go to main page