stream

Documentation

Index

• func NewBus(w messaging.Writer, r messaging.Reader, mapper *ControllerMapper) *messaging.Bus
• type Controller
• type ControllerMapper
  • func NewControllerMapper() *ControllerMapper
  • func (h *ControllerMapper) Add(cc ...Controller)
  • func (h *ControllerMapper) RegisterSubscribers(b *messaging.Bus)
• type UserController
  • func NewUserController() UserController
  • func (u UserController) MapStreams(b *messaging.Bus)

Functions

func NewBus

func NewBus(w messaging.Writer, r messaging.Reader, mapper *ControllerMapper) *messaging.Bus

Types

type Controller

type Controller interface {
	MapStreams(b *messaging.Bus)
}

type ControllerMapper

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

func NewControllerMapper

func NewControllerMapper() *ControllerMapper

func (*ControllerMapper) Add

func (h *ControllerMapper) Add(cc ...Controller)

func (*ControllerMapper) RegisterSubscribers

func (h *ControllerMapper) RegisterSubscribers(b *messaging.Bus)

type UserController

type UserController struct {
}

func NewUserController

func NewUserController() UserController

func (UserController) MapStreams

func (u UserController) MapStreams(b *messaging.Bus)