Versions in this module Expand all Collapse all v2 v2.1.0 Apr 30, 2026 Changes in this version + const MessageTypeComplete + const MessageTypeConnectionError + const MessageTypeData + const MessageTypeError + const MessageTypeUnknown + const SSEMethodGET + const SSEMethodPOST + const SubprotocolAuto + const SubprotocolGraphQLTransportWS + const SubprotocolGraphQLWS + const TransportSSE + const TransportWS + var ErrAckNotReceived = protocol.ErrAckNotReceived + var ErrAckTimeout = protocol.ErrAckTimeout + var ErrClientClosed = errors.New("client closed") + var ErrConnectionClosed = common.ErrConnectionClosed + var ErrConnectionError = protocol.ErrConnectionError + var ErrDialFailed = transport.ErrDialFailed + var ErrInitFailed = transport.ErrInitFailed + var ErrSubscriptionExists = transport.ErrSubscriptionExists + type Client struct + func New(ctx context.Context, cfg Config) *Client + func (c *Client) Stats() Stats + func (c *Client) Subscribe(ctx context.Context, req *common.Request, opts common.Options, ...) (func(), error) + type Config struct + AckTimeout time.Duration + Logger abstractlogger.Logger + PingInterval time.Duration + PingTimeout time.Duration + ReadLimit int64 + StreamingClient *http.Client + UpgradeClient *http.Client + WSIdleTimeout time.Duration + WriteTimeout time.Duration + type ErrFailedUpgrade = transport.ErrFailedUpgrade + type ErrInvalidSubprotocol = transport.ErrInvalidSubprotocol + type ExecutionResult = common.ExecutionResult + type Handler = common.Handler + type Message = common.Message + type MessageType = common.MessageType + type Options = common.Options + type Request = common.Request + type SSEMethod = common.SSEMethod + type Stats struct + SSEConns int + WSConns int + type TransportType = common.TransportType + type WSSubprotocol = common.WSSubprotocol
Go to main page