router

Documentation

Index

• type PreRouteHookFunc
• type Router
  • func New() *Router
  • func (r *Router) AddPreRouteHook(hook PreRouteHookFunc)
  • func (r *Router) AddRoute(serverType string, routingFunction RoutingFunc)
  • func (r *Router) PreRouteHook(msg *message.Message)
  • func (r *Router) Route(ctx context.Context, rpcType protos.RPCType, svType string, route *route.Route, ...) (*cluster.Server, error)
• type RoutingFunc

Types

type PreRouteHookFunc

type PreRouteHookFunc func(msg *message.Message)

type Router

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

Router struct

func New

func New() *Router

New returns the router

func (*Router) AddPreRouteHook

func (r *Router) AddPreRouteHook(hook PreRouteHookFunc)

func (*Router) AddRoute

func (r *Router) AddRoute(
	serverType string,
	routingFunction RoutingFunc,
)

AddRoute adds a routing function to a server type

func (*Router) PreRouteHook

func (r *Router) PreRouteHook(
	msg *message.Message,
)

func (*Router) Route

func (r *Router) Route(
	ctx context.Context,
	rpcType protos.RPCType,
	svType string,
	route *route.Route,
	msg *message.Message,
) (*cluster.Server, error)

Route gets the right server to use in the call

type RoutingFunc

type RoutingFunc func(
	ctx context.Context,
	route *route.Route,
	payload []byte,
	rpcType protos.RPCType,
) (*cluster.Server, error)

RoutingFunc defines a routing function