link

package

v0.0.1 Latest Latest Go to latest Published: Aug 23, 2018 License: MIT Imports: 4 Imported by: 1

Details

This section is empty.

This section is empty.

func NewRouter(name string, params core.Params) (core.Link, error)

type Router struct {
	Name string

	*core.Connector
	*sync.Mutex
	// contains filtered or unexported fields
}

func (r *Router) AddRoute(routeKey string, routeDst core.Link) error

func (r *Router) ConnectTo(core.Link) error

func (r *Router) DropRoute(routeKey string) (core.Link, error)

func (r *Router) GetRoutes() map[string]core.Link

func (r *Router) Recv(msg *core.Message) error

func (r *Router) RouteTo(routes map[string]core.Link) error