graphql_websocket_subscription

Documentation

Index

• type Config
• type GraphQLWebsocketSubscriptionStream
  • func New() *GraphQLWebsocketSubscriptionStream
  • func (g *GraphQLWebsocketSubscriptionStream) Start(input []byte, next chan<- []byte, stop <-chan struct{})
  • func (g *GraphQLWebsocketSubscriptionStream) UniqueIdentifier() []byte
• type Subscription
  • func (s *Subscription) Next(done <-chan struct{}) (data []byte, ok bool)
• type WebsocketClient
  • func (w *WebsocketClient) Close()
  • func (w *WebsocketClient) CloseIfNoSubscriptions() (closed bool)
  • func (w *WebsocketClient) Open(url string, header http.Header) (err error)
  • func (w *WebsocketClient) Subscribe(payload []byte) (subscription Subscription, ok bool)
  • func (w *WebsocketClient) Unsubscribe(subscription Subscription)

Types

type Config

type Config struct {
	Scheme string
	Host   string
	Path   string
	Body   json.RawMessage
	Header http.Header
}

type GraphQLWebsocketSubscriptionStream

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

func New

func New() *GraphQLWebsocketSubscriptionStream

func (*GraphQLWebsocketSubscriptionStream) Start

func (g *GraphQLWebsocketSubscriptionStream) Start(input []byte, next chan<- []byte, stop <-chan struct{})

func (*GraphQLWebsocketSubscriptionStream) UniqueIdentifier

func (g *GraphQLWebsocketSubscriptionStream) UniqueIdentifier() []byte

type Subscription

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

func (*Subscription) Next

func (s *Subscription) Next(done <-chan struct{}) (data []byte, ok bool)

type WebsocketClient

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

func (*WebsocketClient) Close

func (w *WebsocketClient) Close()

func (*WebsocketClient) CloseIfNoSubscriptions

func (w *WebsocketClient) CloseIfNoSubscriptions() (closed bool)

func (*WebsocketClient) Open

func (w *WebsocketClient) Open(url string, header http.Header) (err error)

func (*WebsocketClient) Subscribe

func (w *WebsocketClient) Subscribe(payload []byte) (subscription Subscription, ok bool)

func (*WebsocketClient) Unsubscribe

func (w *WebsocketClient) Unsubscribe(subscription Subscription)