events

Documentation

Index

• type Handlers
  • func NewHandlers(conf *config.Config) *Handlers
  • func (h *Handlers) GoStart() error
  • func (h *Handlers) PushRequest(ctx context.Context, req *protocol.Request) (*protocol.Response, error)
  • func (h *Handlers) Register(server transport.Server)
  • func (h *Handlers) Start() error
  • func (h *Handlers) Stop() error

Types

type Handlers

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

Handlers is a map of event queues, one for each topic as well as one for non-blocking requests.

func NewHandlers

func NewHandlers(conf *config.Config) *Handlers

NewHandlers returns a new instance of *Handlers.

func (*Handlers) GoStart

func (h *Handlers) GoStart() error

GoStart begins handling messages

func (*Handlers) PushRequest

func (h *Handlers) PushRequest(ctx context.Context, req *protocol.Request) (*protocol.Response, error)

PushRequest implements transport.RequestHandler.

func (*Handlers) Register

func (h *Handlers) Register(server transport.Server)

Register adds a server to the event queue. The queue should be stopped when Register is called.

func (*Handlers) Start

func (h *Handlers) Start() error

func (*Handlers) Stop

func (h *Handlers) Stop() error