Versions in this module Expand all Collapse all v2 v2.1.0 Apr 30, 2026 Changes in this version + var ErrAckNotReceived = errors.New("expected connection_ack") + var ErrAckTimeout = errors.New("connection_ack timeout") + var ErrConnectionError = errors.New("connection error from server") + func NewGraphQLTransportWS() *graphqlTransportWS + func NewGraphQLWS() *graphqlWS + type Pinger interface + Ping func(ctx context.Context, conn *websocket.Conn) error + Pong func(ctx context.Context, conn *websocket.Conn) error + type Protocol interface + Init func(ctx context.Context, conn *websocket.Conn, payload map[string]any) error + Read func(ctx context.Context, conn *websocket.Conn) (*WireMessage, error) + Subscribe func(ctx context.Context, conn *websocket.Conn, id string, req *common.Request) error + Unsubscribe func(ctx context.Context, conn *websocket.Conn, id string) error + type WireMessage struct + Err error + ID string + Payload *common.ExecutionResult + Type WireMessageType + func (m *WireMessage) IntoClientMessage() *common.Message + type WireMessageType uint8 + const MessageComplete + const MessageData + const MessageError + const MessagePing + const MessagePong + func (t WireMessageType) String() string
Go to main page