cherryRouter

Documentation

Index

• type NodeRouter
  • func NewNodeRouter() *NodeRouter
  • func (r *NodeRouter) AddRoute(nodeType string, routingFunction RoutingFunc)
  • func (r *NodeRouter) Route(ctx context.Context, nodeType string, msg *cherryMessage.Message) (cherryFacade.IMember, error)
• type RoutingFunc

Types

type NodeRouter

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

func NewNodeRouter

func NewNodeRouter() *NodeRouter

func (*NodeRouter) AddRoute

func (r *NodeRouter) AddRoute(nodeType string, routingFunction RoutingFunc)

func (*NodeRouter) Route

func (r *NodeRouter) Route(ctx context.Context, nodeType string, msg *cherryMessage.Message) (cherryFacade.IMember, error)

type RoutingFunc

type RoutingFunc func(
	ctx context.Context,
	nodeType string,
	msg *cherryMessage.Message,
) (cherryFacade.IMember, error)