wrapper

Documentation

Index

• type B
• type Ctx
• type E
• type N
• type OK
• type RelayInterface
• type RelayWrapper
  • func (w RelayWrapper) Publish(c Ctx, evt *event.T) (err E)
  • func (w RelayWrapper) QuerySync(c Ctx, f *filter.T, opts ...ws.SubscriptionOption) ([]*event.T, E)
• type Req
• type Responder
• type S
• type SubID
• type WS

Types

type B

type B = []byte

type Ctx

type Ctx = context.T

type E

type E = error

type N

type N = int

type OK

type OK = okenvelope.T

type RelayInterface

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

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

type RelayWrapper

type RelayWrapper struct {
	store.I
}

func (RelayWrapper) Publish

func (w RelayWrapper) Publish(c Ctx, evt *event.T) (err E)

func (RelayWrapper) QuerySync

func (w RelayWrapper) QuerySync(c Ctx, f *filter.T,
	opts ...ws.SubscriptionOption) ([]*event.T, E)

type Req

type Req = *http.Request

type Responder

type Responder = http.ResponseWriter

type S

type S = string

type SubID

type SubID = subscription.Id

type WS

type WS = *ws.Serv