wrapper

Documentation

Index

• type OK
• type Relay
  • func (w Relay) Publish(c cx, evt *event.T) (err er)
  • func (w Relay) QuerySync(c cx, f *filter.T, opts ...ws.SubscriptionOption) ([]*event.T, er)
• type RelayInterface
• type Req
• type Responder
• type SubID
• type WS

Types

type OK

type OK = okenvelope.T

type Relay

type Relay struct {
	store.I
}

func (Relay) Publish

func (w Relay) Publish(c cx, evt *event.T) (err er)

func (Relay) QuerySync

func (w Relay) QuerySync(c cx, f *filter.T,
	opts ...ws.SubscriptionOption) ([]*event.T, er)

type RelayInterface

type RelayInterface interface {
	Publish(c cx, evt *event.T) er
	QuerySync(c cx, f *filter.T, opts ...ws.SubscriptionOption) ([]*event.T, er)
}

RelayInterface is a wrapper thing that unifies Store and Relay under a common API.

type Req

type Req = *http.Request

type Responder

type Responder = http.ResponseWriter

type SubID

type SubID = subscription.Id

type WS

type WS = *ws.Serv