wsgraphql

Jun 18, 2023

Changes in this version

+ var ContextKeyOperationExecuted = contextKeyOperationExecutedT

+ var ContextKeyOperationParams = contextKeyOperationParamsT

+ func ContextOperationExecuted(ctx context.Context) bool

+ func ContextOperationParams(ctx context.Context) (res *graphql.Params)

+ func FormatError(err error) gqlerrors.FormattedError

+ type HandlerHTTPRequest func(ctx context.Context, w http.ResponseWriter, r *http.Request) error

+ type HandlerInit func(ctx context.Context, init apollows.PayloadInit) error

+ type HandlerOperation func(ctx context.Context, payload *apollows.PayloadOperation) error

+ type HandlerOperationExecute func(ctx context.Context, payload *apollows.PayloadOperation) (chan *graphql.Result, error)

+ type HandlerOperationParse func(ctx context.Context, payload *apollows.PayloadOperation) error

+ type InterceptorHTTPRequest func(ctx context.Context, w http.ResponseWriter, r *http.Request, ...) error

+ func InterceptorHTTPRequestChain(interceptors ...InterceptorHTTPRequest) InterceptorHTTPRequest

+ type InterceptorInit func(ctx context.Context, init apollows.PayloadInit, handler HandlerInit) error

+ func InterceptorInitChain(interceptors ...InterceptorInit) InterceptorInit

+ type InterceptorOperation func(ctx context.Context, payload *apollows.PayloadOperation, ...) error

+ func InterceptorOperationChain(interceptors ...InterceptorOperation) InterceptorOperation

+ type InterceptorOperationExecute func(ctx context.Context, payload *apollows.PayloadOperation, ...) (chan *graphql.Result, error)

+ func InterceptorOperationExecuteChain(interceptors ...InterceptorOperationExecute) InterceptorOperationExecute

+ type InterceptorOperationParse func(ctx context.Context, payload *apollows.PayloadOperation, ...) error

+ func InterceptorOperationParseChain(interceptors ...InterceptorOperationParse) InterceptorOperationParse

+ type Interceptors struct

+ HTTPRequest InterceptorHTTPRequest

+ Init InterceptorInit

+ Operation InterceptorOperation

+ OperationExecute InterceptorOperationExecute

+ OperationParse InterceptorOperationParse

+ type ResultError struct

+ func (r ResultError) Error() string

+ type ResultProcessor func(ctx context.Context, payload *apollows.PayloadOperation, ...) *graphql.Result

type ServerOption

+ func WithExtraInterceptors(interceptors Interceptors) ServerOption

+ func WithInterceptors(interceptors Interceptors) ServerOption

+ func WithResultProcessor(proc ResultProcessor) ServerOption

Sep 1, 2022

Changes in this version

type Conn

+ Subprotocol func() string

Jun 12, 2022

Changes in this version

+ const WebsocketSubprotocolGraphqlTransportWS

+ const WebsocketSubprotocolGraphqlWS

+ var ContextKeyHTTPResponseStarted = contextKeyHTTPResponseStartedT

+ var ContextKeyOperationID = contextKeyOperationIDT

+ func ContextHTTPResponseStarted(ctx context.Context) bool

+ func ContextOperationID(ctx context.Context) string

type Callbacks

+ OnOperationValidation func(opctx mutable.Context, payload *apollows.PayloadOperation, ...) error

type ServerOption

+ func WithConnectTimeout(timeout time.Duration) ServerOption

+ func WithProtocol(protocol apollows.Protocol) ServerOption

+ func WithRootObject(rootObject map[string]interface{}) ServerOption

Jun 12, 2022

Changes in this version

type Callbacks

+ OnDisconnect func(reqctx mutable.Context, origerr error) error

Jun 11, 2022

Changes in this version

+ const WebsocketSubprotocol

+ var ContextKeyAST = contextKeyAstT

+ var ContextKeyHTTPRequest = contextKeyHTTPRequestT

+ var ContextKeyHTTPResponseWriter = contextKeyHTTPResponseWriterT

+ var ContextKeyOperationContext = contextKeyOperationContextT

+ var ContextKeyOperationStopped = contextKeyOperationStoppedT

+ var ContextKeyRequestContext = contextKeyRequestContextT

+ var ContextKeySubscription = contextKeySubscriptionT

+ var ContextKeyWebsocketConnection = contextKeyWebsocketConnectionT

+ func ContextAST(ctx context.Context) *ast.Document

+ func ContextHTTPRequest(ctx context.Context) *http.Request

+ func ContextHTTPResponseWriter(ctx context.Context) http.ResponseWriter

+ func ContextOperationStopped(ctx context.Context) bool

+ func ContextSubscription(ctx context.Context) bool

+ func OperationContext(ctx context.Context) (mutctx mutable.Context)

+ func RequestContext(ctx context.Context) (mutctx mutable.Context)

+ func WriteError(ctx context.Context, w http.ResponseWriter, err error)

+ type Callbacks struct

+ OnConnect func(reqctx mutable.Context, init apollows.PayloadInit) error

+ OnOperation func(opctx mutable.Context, payload *apollows.PayloadOperation) error

+ OnOperationDone func(opctx mutable.Context, payload *apollows.PayloadOperation, err error) error

+ OnOperationResult func(opctx mutable.Context, payload *apollows.PayloadOperation, ...) error

+ OnRequest func(reqctx mutable.Context, r *http.Request, w http.ResponseWriter) error

+ OnRequestDone func(reqctx mutable.Context, r *http.Request, w http.ResponseWriter, err error)

+ type Conn interface

+ Close func() error

+ ReadJSON func(v interface{}) error

+ WriteJSON func(v interface{}) error

+ func ContextWebsocketConnection(ctx context.Context) Conn

+ type Server interface

+ func NewServer(schema graphql.Schema, rootObject map[string]interface{}, ...) (Server, error)

+ type ServerOption func(config *serverConfig) error

+ func WithCallbacks(callbacks Callbacks) ServerOption

+ func WithKeepalive(interval time.Duration) ServerOption

+ func WithUpgrader(upgrader Upgrader) ServerOption

+ func WithoutHTTPQueries() ServerOption

+ type Upgrader interface

+ Upgrade func(w http.ResponseWriter, r *http.Request, responseHeader http.Header) (Conn, error)