routing

Documentation

Index

• Variables
• func ConditionExpression(rule *entities.EndpointRule) (func(source string) bool, error)
• func ConditionSource(rule *entities.EndpointRule, msg *entities.Message) string
• func MatchAny() string
• func MatchEqual(value string) string
• func MatchPrefix(value string) string
• func NewRequest(timer timer.Timer, msg *entities.Message, ep *entities.Endpoint, ...) *entities.Request
• func PlanRequest(timer timer.Timer, msg *entities.Message, route *Route) (*entities.Request, []any)
• func PlanRequests(timer timer.Timer, msg *entities.Message, routes []Route) (map[string]*entities.Request, [][]any)
• type Route

Variables

var (
	ConditionExpressionDivider = "::"
	ConditionExpressionAny     = "any"
	ConditionExpressionEqual   = "equal"
	ConditionExpressionPrefix  = "prefix"
)

var (
	ErrConditionExpressionMalformed = errors.New("ROUTING.CONDITION.EXPRESSION.MALFORMED.ERROR")
	ErrConditionExpressionUnknown   = errors.New("ROUTING.CONDITION.EXPRESSION.UNKNOWN.ERROR")
)

var (
	ConditionSourceType  = "type"
	ConditionSourceAppId = "app_id"
)

Functions

func ConditionExpression

func ConditionExpression(rule *entities.EndpointRule) (func(source string) bool, error)

func ConditionSource

func ConditionSource(rule *entities.EndpointRule, msg *entities.Message) string

func MatchAny

func MatchAny() string

func MatchEqual

func MatchEqual(value string) string

func MatchPrefix

func MatchPrefix(value string) string

func NewRequest

func NewRequest(
	timer timer.Timer,
	msg *entities.Message,
	ep *entities.Endpoint,
	epr *entities.EndpointRule,
) *entities.Request

func PlanRequest

func PlanRequest(
	timer timer.Timer,
	msg *entities.Message,
	route *Route,
) (*entities.Request, []any)

func PlanRequests

func PlanRequests(
	timer timer.Timer,
	msg *entities.Message,
	routes []Route,
) (map[string]*entities.Request, [][]any)

Types

type Route

type Route struct {
	Endpoint *entities.Endpoint
	Rules    []entities.EndpointRule
}