redis

Documentation

Index

• Variables
• type Dialer
  • func NewDialer(protocol, address string, options ...redis.DialOption) Dialer
• type SubscriptionHandler
  • func NewSubscriptionHandler(conn *graphqlws.Conn, dialer Dialer) SubscriptionHandler

Variables

var (
	// ConnectionContextKey is the key for keeping the connection reference on
	// the context.
	ConnectionContextKey graphqlWSContextKey = "connection"

	// SubscriptionContextKey is the key for keeping the subscription reference
	// on the context.
	SubscriptionContextKey graphqlWSContextKey = "subscription"
)

Types

type Dialer

type Dialer interface {
	Dial() (redis.Conn, error)
}

Dialer is responsible for creating new redis connections.

As connections are being used for subscriptions, it won't be pooled.

func NewDialer

func NewDialer(protocol, address string, options ...redis.DialOption) Dialer

NewDialer dials for a new connection. It will return the default implementation of the `Dialer` interface.

type SubscriptionHandler

type SubscriptionHandler interface {
	graphqlws.SubscriptionStartHandler
	graphqlws.SubscriptionStopHandler
	graphqlws.WebsocketCloseHandler
}

func NewSubscriptionHandler

func NewSubscriptionHandler(conn *graphqlws.Conn, dialer Dialer) SubscriptionHandler

NewSubscriptionHandler returns a new instance of a `SubscriptionHandler` that will add the logic for registering