link

Documentation

Index

• func New(name string, params core.Params) (core.Link, error)
• type Router
  • 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

Functions

func New

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

Types

type Router

type Router struct {
	Name string

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

func (*Router) AddRoute

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

func (*Router) ConnectTo

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

func (*Router) DropRoute

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

func (*Router) GetRoutes

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

func (*Router) Recv

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

func (*Router) RouteTo

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