NewHandler creates a new subscription handler.

NewUniversalProtocolHandler creates a new UniversalProtocolHandler.

NewUniversalProtocolHandlerWithOptions creates a new UniversalProtocolHandler.

TimeOutChecker is a function that can be used in a go routine to perform a time-out action after a specific duration or prevent the time-out action by canceling the time-out context before.

ErrTransportClientClosedConnection is an error to indicate that the transport client is using closed connection.

ExecutorEngine is an implementation of Engine and works with subscription.Executor.

ExecutorV2Pool - provides reusable executors.

Handler is the actual subscription handler which will keep track on how to handle messages coming from the client.

Message defines the actual subscription message which will be passed from client to server and vice versa.

TimeOutParams is a struct to configure a TimeOutChecker.

UniversalProtocolHandler can handle any protocol by using the Protocol interface.

UniversalProtocolHandlerOptions is struct that defines options for the UniversalProtocolHandler.

Client provides an interface which can be implemented by any possible subscription client like websockets, mqtt, etc.

Engine defines the function for a subscription engine.

EventHandler is an interface that handles subscription events.

Executor is an abstraction for executing a GraphQL engine.

ExecutorPool is an abstraction for creating executors.

Protocol defines an interface for a subscription protocol decoupled from the underlying transport.

TransportClient provides an interface that can be implemented by any possible subscription client like websockets, mqtt, etc.

EventType can be used to define subscription events decoupled from any protocols.

InitPayload is a structure that is parsed from the websocket init message payload.

WebsocketInitFunc is called when the server receives connection init message from the client.