router

Documentation

Index

• Variables
• type Router
  • func NewRouter(messenger messenger.Messenger, storage storage.Storage, config RouterConfig) *Router
  • func (r *Router) Start()
  • func (r *Router) Stop()
• type RouterConfig
• type TopicNames

Variables

var Logger = logrus.New()

Logger logs but can be replaced

Types

type Router

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

Router handles all incoming messages and uses storage to reroute those messages

func NewRouter

func NewRouter(messenger messenger.Messenger, storage storage.Storage, config RouterConfig) *Router

NewRouter returns a new router that routes messages in/out of messenger based on storage

func (*Router) Start

func (r *Router) Start()

Start begins the message routing Careful! Calling this multiple times will queue starts which can unexpectedly cancel out a stop calls

func (*Router) Stop

func (r *Router) Stop()

Stop stops message routing

type RouterConfig

type RouterConfig struct {
	TopicNames TopicNames
}

type TopicNames

type TopicNames map[string]string

TopicNames maps a routable type to a topic