subprotocol

type GraphQLWS struct {
	Origin            GraphQLWSOrigin
	Cluster           GraphQLWSCluster
	KeepAliveInterval time.Duration
	Logger            logrus.FieldLogger
	// contains filtered or unexported fields
}

type GraphQLWSCluster interface {
	Address() wss.Address

	SendGraphQLWSServiceRequest(address wss.Address, r *GraphQLWSServiceRequest) error
}

type GraphQLWSOrigin interface {
	SendGraphQLWSOriginRequest(*GraphQLWSOriginRequest) (*GraphQLWSOriginResponse, error)
}

type GraphQLWSOriginFunc func(*GraphQLWSOriginRequest) (*GraphQLWSOriginResponse, error)

type GraphQLWSOriginRequest struct {
	Sender wss.Address

	StartRequest *GraphQLWSStartRequest

	SubscriptionQueryRequest *GraphQLWSSubscriptionQueryRequest

	SubscriptionKeepAliveRequest *GraphQLWSSubscriptionKeepAliveRequest
}

type GraphQLWSOriginResponse struct {
	Error        string
	Result       *GraphQLWSResult
	Subscription *GraphQLWSSubscription
}

type GraphQLWSPublishRequest struct {
	Subscribers []wss.Address
	Keys        []string
	Context     json.RawMessage
}

type GraphQLWSResult struct {
	Data   json.RawMessage
	Errors json.RawMessage `json:"Errors,omitempty"`
}

type GraphQLWSServiceRequest struct {
	WebSocketServiceRequest *wss.ServiceRequest

	PublishRequest *GraphQLWSPublishRequest
}

type GraphQLWSStartRequest struct {
	Query         string
	Variables     json.RawMessage
	OperationName string
}

type GraphQLWSSubscription struct {
	// A digest that uniquely identifies the inputs to the query. This is used to batch query
	// execution.  Generally, this should be a hash of the normalized query, variables, and
	// operation name.
	InputDigest string

	InputContext json.RawMessage

	// A list of keys that will be used to trigger this subscription's execution in the future.
	Keys []string
}

type GraphQLWSSubscriptionKeepAliveRequest struct {
	Keys []string
}

type GraphQLWSSubscriptionQueryRequest struct {
	Query         string
	Variables     json.RawMessage
	OperationName string
	Context       json.RawMessage
	InputContext  json.RawMessage
}