protocol

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