router

package
v0.0.0-...-53b40aa Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 22, 2018 License: AGPL-3.0, AGPL-3.0-only Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL