http

Documentation

Overview

Package http handles GraphQL HTTP Requests including WebSocket Upgrades.

Index

• func HandleWebsocket(done chan bool, errChan chan error, conn net.Conn, ...)
• func HandleWebsocketWithInitFunc(done chan bool, errChan chan error, conn net.Conn, ...)
• func NewGraphqlHTTPHandlerFunc(executionHandler *execution.Handler, logger log.Logger, ...) http.Handler
• type GraphQLHTTPRequestHandler
  • func (g *GraphQLHTTPRequestHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type WebsocketSubscriptionClient
  • func NewWebsocketSubscriptionClient(logger abstractlogger.Logger, clientConn net.Conn) *WebsocketSubscriptionClient
  • func (w *WebsocketSubscriptionClient) Disconnect() error
  • func (w *WebsocketSubscriptionClient) IsConnected() bool
  • func (w *WebsocketSubscriptionClient) ReadFromClient() (message *subscription.Message, err error)
  • func (w *WebsocketSubscriptionClient) WriteToClient(message subscription.Message) error

Functions

func HandleWebsocket

func HandleWebsocket(done chan bool, errChan chan error, conn net.Conn, executorPool subscription.ExecutorPool, logger abstractlogger.Logger)

func HandleWebsocketWithInitFunc

func HandleWebsocketWithInitFunc(
	done chan bool,
	errChan chan error,
	conn net.Conn,
	executorPool subscription.ExecutorPool,
	logger abstractlogger.Logger,
	initFunc subscription.WebsocketInitFunc,
)

func NewGraphqlHTTPHandlerFunc

func NewGraphqlHTTPHandlerFunc(executionHandler *execution.Handler, logger log.Logger, upgrader *ws.HTTPUpgrader) http.Handler

Types

type GraphQLHTTPRequestHandler

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

func (*GraphQLHTTPRequestHandler) ServeHTTP

func (g *GraphQLHTTPRequestHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type WebsocketSubscriptionClient

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

WebsocketSubscriptionClient is an actual implementation of the subscritpion client interface.

func NewWebsocketSubscriptionClient

func NewWebsocketSubscriptionClient(logger abstractlogger.Logger, clientConn net.Conn) *WebsocketSubscriptionClient

NewWebsocketSubscriptionClient will create a new websocket subscription client.

func (*WebsocketSubscriptionClient) Disconnect

func (w *WebsocketSubscriptionClient) Disconnect() error

Disconnect will close the websocket connection.

func (*WebsocketSubscriptionClient) IsConnected

func (w *WebsocketSubscriptionClient) IsConnected() bool

IsConnected will indicate if the websocket conenction is still established.

func (*WebsocketSubscriptionClient) ReadFromClient

func (w *WebsocketSubscriptionClient) ReadFromClient() (message *subscription.Message, err error)

ReadFromClient will read a subscription message from the websocket client.

func (*WebsocketSubscriptionClient) WriteToClient

func (w *WebsocketSubscriptionClient) WriteToClient(message subscription.Message) error

WriteToClient will write a subscription message to the websocket client.