router

Documentation

Index

• type Router
  • func NewRouter(rmId common.RMId, logger log.Logger) *Router
  • func (r Router) Dispatch(sender common.RMId, msgType msgs.Message_Which, msg msgs.Message)
  • func (r Router) Send(b []byte)
  • func (r Router) ShutdownSync()
  • func (r Router) Status(sc *status.StatusConsumer)

Types

type Router

type Router struct {
	*paxos.Dispatchers
	ConnectionManager connectionmanager.ConnectionManager
	Transmogrifier    topology.TopologyTransmogrifier
	// contains filtered or unexported fields
}

func NewRouter

func NewRouter(rmId common.RMId, logger log.Logger) *Router

func (Router) Dispatch

func (r Router) Dispatch(sender common.RMId, msgType msgs.Message_Which, msg msgs.Message)

func (Router) Send

func (r Router) Send(b []byte)

func (Router) ShutdownSync

func (r Router) ShutdownSync()

func (Router) Status

func (r Router) Status(sc *status.StatusConsumer)