route

Documentation

Index

• Constants
• Variables
• func ParseAliases(in string) (names []string, err error)
• func ReverseHostPort(s string) string
• func SetMetricsProvider(p metrics.Provider)
• func SetTable(t Table)
• type Cmd
• type GlobCache
  • func NewGlobCache(size int) *GlobCache
  • func (c *GlobCache) Get(pattern string) (glob.Glob, error)
• type Route
  • func (r *Route) TargetConfig(t *Target, addWeight bool) string
• type RouteDef
  • func Parse(in *bytes.Buffer) (defs []*RouteDef, err error)
• type Routes
  • func (rt Routes) Len() int
  • func (rt Routes) Less(i, j int) bool
  • func (rt Routes) Swap(i, j int)
• type Table
  • func GetTable() Table
  • func NewTable(b *bytes.Buffer) (t Table, err error)
  • func NewTableCustom(defs *[]RouteDef) (t Table, err error)
  • func (t Table) Dump() string
  • func (t Table) Lookup(req *http.Request, trace string, pick picker, match matcher, ...) (target *Target)
  • func (t Table) LookupHost(host string, pick picker) *Target
  • func (t Table) String() string
• type Target
  • func (t *Target) AccessDeniedHTTP(r *http.Request) bool
  • func (t *Target) AccessDeniedTCP(c net.Conn) bool
  • func (t *Target) Authorized(r *http.Request, w http.ResponseWriter, authSchemes map[string]auth.AuthScheme) bool
  • func (t *Target) BuildRedirectURL(requestURL *url.URL)
  • func (t *Target) ProcessAccessRules() error

Constants

const Commands = `` /* 1974-byte string literal not displayed */

Variables

var Matcher = map[string]matcher{
	"prefix":  prefixMatcher,
	"glob":    globMatcher,
	"iprefix": iPrefixMatcher,
}

Matcher contains the available matcher functions. Update config/load.go#load after updating.

var Picker = map[string]picker{
	"rnd": rndPicker,
	"rr":  rrPicker,
}

Picker contains the available picker functions. Update config/load.go#load after updating.

Functions

func ParseAliases

func ParseAliases(in string) (names []string, err error)

ParseAliases scans a set of route commands for the "register" option and returns a list of services which should be registered by the backend.

func ReverseHostPort

func ReverseHostPort(s string) string

ReverseHostPort returns its argument string reversed rune-wise left to right. If s includes a port, only the host part is reversed.

func SetMetricsProvider

func SetMetricsProvider(p metrics.Provider)

func SetTable

func SetTable(t Table)

SetTable sets the active routing table. A nil value logs a warning and is ignored. The function is safe to be called from multiple goroutines.

Types

type Cmd

type Cmd string

const (
	RouteAddCmd    Cmd = "route add"
	RouteDelCmd    Cmd = "route del"
	RouteWeightCmd Cmd = "route weight"
)

type GlobCache

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

GlobCache implements an LRU cache for compiled glob patterns.

func NewGlobCache

func NewGlobCache(size int) *GlobCache

func (*GlobCache) Get

func (c *GlobCache) Get(pattern string) (glob.Glob, error)

Get returns the compiled glob pattern if it compiled without error. Otherwise, the function returns nil. If the pattern is not in the cache it will be added.

type Route

type Route struct {
	// Host contains the host of the route.
	// not used for routing but for config generation
	// Table has a map with the host as key
	// for faster lookup and smaller search space.
	Host string

	// Path is the path prefix from a request uri
	Path string

	// Targets contains the list of URLs
	Targets []*Target

	// Glob represents compiled pattern.
	Glob glob.Glob
	// contains filtered or unexported fields
}

Route maps a path prefix to one or more target URLs. routes can have a weight value which describes the amount of traffic this route should get. You can specify that a route should get a fixed percentage of the traffic independent of how many instances are running.

func (*Route) TargetConfig

func (r *Route) TargetConfig(t *Target, addWeight bool) string

type RouteDef

type RouteDef struct {
	Cmd     Cmd               `json:"cmd"`
	Service string            `json:"service"`
	Src     string            `json:"src"`
	Dst     string            `json:"dst"`
	Weight  float64           `json:"weight"`
	Tags    []string          `json:"tags,omitempty"`
	Opts    map[string]string `json:"opts,omitempty"`
}

func Parse

func Parse(in *bytes.Buffer) (defs []*RouteDef, err error)

Parse loads a routing table from a set of route commands.

The commands are parsed in order and order matters. Deleting a route that has not been created yet yields a different result than the other way around.

type Routes

type Routes []*Route

Routes stores a list of routes usually for a single host.

func (Routes) Len

func (rt Routes) Len() int

sort by path in reverse order (most to least specific)

func (Routes) Less

func (rt Routes) Less(i, j int) bool

func (Routes) Swap

func (rt Routes) Swap(i, j int)

type Table

type Table map[string]Routes

Table contains a set of routes grouped by host. The host routes are sorted from most to least specific by sorting the routes in reverse order by path.

func GetTable

func GetTable() Table

GetTable returns the active routing table. The function is safe to be called from multiple goroutines and the value is never nil.

func NewTable

func NewTable(b *bytes.Buffer) (t Table, err error)

func NewTableCustom

func NewTableCustom(defs *[]RouteDef) (t Table, err error)

func (Table) Dump

func (t Table) Dump() string

Dump returns the routing table as a detailed

func (Table) Lookup

func (t Table) Lookup(req *http.Request, trace string, pick picker, match matcher, globCache *GlobCache, globDisabled bool) (target *Target)

Lookup finds a target url based on the current matcher and picker or nil if there is none. It first checks the routes for the host and if none matches then it falls back to generic routes without a host. This is useful for a catch-all '/' rule.

func (Table) LookupHost

func (t Table) LookupHost(host string, pick picker) *Target

func (Table) String

func (t Table) String() string

String returns the routing table as config file which can be read by Parse() again.

type Target

type Target struct {
	// Service is the name of the service the targetURL points to
	Service string

	// Tags are the list of tags for this target
	Tags []string

	// Opts is the raw options for the target.
	Opts map[string]string

	// StripPath will be removed from the front of the outgoing
	// request path
	StripPath string

	// PrependPath will be added to the front of the outgoing
	// request path (after StripPath has been removed)
	PrependPath string

	// TLSSkipVerify disables certificate validation for upstream
	// TLS connections.
	TLSSkipVerify bool

	// Host signifies what the proxy will set the Host header to.
	// The proxy does not modify the Host header by default.
	// When Host is set to 'dst' the proxy will use the host name
	// of the target host for the outgoing request.
	Host string

	// URL is the endpoint the service instance listens on
	URL *url.URL

	// RedirectCode is the HTTP status code used for redirects.
	// When set to a value > 0 the client is redirected to the target url.
	RedirectCode int

	// RedirectURL is the redirect target based on the request.
	// This is cached here to prevent multiple generations per request.
	RedirectURL *url.URL

	// FixedWeight is the weight assigned to this target.
	// If the value is 0 the targets weight is dynamic.
	FixedWeight float64

	// Weight is the actual weight for this service in percent.
	Weight float64

	// Histogram measures throughput and latency of this target
	Timer gkm.Histogram

	// Counters for rx and tx
	RxCounter gkm.Counter
	TxCounter gkm.Counter

	// name of the auth handler for this target
	AuthScheme string

	// ProxyProto enables PROXY Protocol on upstream connection
	ProxyProto bool

	// Transport allows for different types of transports
	Transport *http.Transport
	// contains filtered or unexported fields
}

func (*Target) AccessDeniedHTTP

func (t *Target) AccessDeniedHTTP(r *http.Request) bool

AccessDeniedHTTP checks rules on the target for HTTP proxy routes.

func (*Target) AccessDeniedTCP

func (t *Target) AccessDeniedTCP(c net.Conn) bool

AccessDeniedTCP checks rules on the target for TCP proxy routes.

func (*Target) Authorized

func (t *Target) Authorized(r *http.Request, w http.ResponseWriter, authSchemes map[string]auth.AuthScheme) bool

func (*Target) BuildRedirectURL

func (t *Target) BuildRedirectURL(requestURL *url.URL)

func (*Target) ProcessAccessRules

func (t *Target) ProcessAccessRules() error

ProcessAccessRules processes access rules from options specified on the target route