gss

type CanSendToUserFunc func(conn *graphqlws.Connection, reqData *RequestData) bool

type ChannelSerializer interface {
	Serialize(field string, args QueryArgsMap) string
}

type GraphQLContextKey string

type NotificationHandler struct {
	// contains filtered or unexported fields
}

type NotificationResponse struct {
	Success bool     `json:"success"`
	Errors  []string `json:"errors"`
}

type QueryArgsMap map[string]string

type RequestData struct {
	Users   []string    `json:"users"`
	Channel string      `json:"channel"`
	Payload interface{} `json:"payload"`
}

type SubscribeFilter interface {
	RegisterConnectionIDFromDocument(connID string, subID string, doc *ast.Document, variables map[string]interface{})
	RemoveSubscriptionIDFromConnectionID(connID, subID string)
	RemoveConnectionIDFromChannels(connID string)
	GetChannelRegisteredConnectionIDs(channel string) SubscriptionIDByConnectionID
}

type SubscribeService struct {
	graphqlws.SubscriptionManager
	Schema *graphql.Schema
	Pool   graphqlws.SubscriptionManager
	Filter SubscribeFilter
	// contains filtered or unexported fields
}

type SubscriptionIDByConnectionID map[string]string