router

package
v5.15.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 18, 2024 License: MIT Imports: 40 Imported by: 9

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	DomainStrategy_name = map[int32]string{
		0: "AsIs",
		1: "UseIp",
		2: "IpIfNonMatch",
		3: "IpOnDemand",
	}
	DomainStrategy_value = map[string]int32{
		"AsIs":         0,
		"UseIp":        1,
		"IpIfNonMatch": 2,
		"IpOnDemand":   3,
	}
)

Enum value maps for DomainStrategy.

View Source 
var File_app_router_config_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AttributeMatcher 

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

func NewAttributeMatcher 

func NewAttributeMatcher(code string) (*AttributeMatcher, error)

func (*AttributeMatcher) Apply 

func (m *AttributeMatcher) Apply(ctx routing.Context) bool

Apply implements Condition.

func (*AttributeMatcher) Match 

func (m *AttributeMatcher) Match(attrs map[string]string) bool

Match implements attributes matching.

type Balancer 

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

func (*Balancer) InjectContext 

func (b *Balancer) InjectContext(ctx context.Context)

func (*Balancer) PickOutbound 

func (b *Balancer) PickOutbound() (string, error)

PickOutbound picks the tag of an outbound

func (*Balancer) SelectOutbounds 

func (b *Balancer) SelectOutbounds() ([]string, error)

SelectOutbounds select outbounds with selectors of the Balancer

type BalancingPrincipleTarget 

type BalancingPrincipleTarget interface {
	GetPrincipleTarget([]string) []string
}

type BalancingRule 

type BalancingRule struct {
	Tag              string   `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	OutboundSelector []string `protobuf:"bytes,2,rep,name=outbound_selector,json=outboundSelector,proto3" json:"outbound_selector,omitempty"`
	Strategy         string   `protobuf:"bytes,3,opt,name=strategy,proto3" json:"strategy,omitempty"`
	StrategySettings *any.Any `protobuf:"bytes,4,opt,name=strategy_settings,json=strategySettings,proto3" json:"strategy_settings,omitempty"`
	FallbackTag      string   `protobuf:"bytes,5,opt,name=fallback_tag,json=fallbackTag,proto3" json:"fallback_tag,omitempty"`
	// contains filtered or unexported fields
}

func (*BalancingRule) Build 

func (br *BalancingRule) Build(ohm outbound.Manager, dispatcher routing.Dispatcher) (*Balancer, error)

Build builds the balancing rule

func (*BalancingRule) Descriptor deprecated 

func (*BalancingRule) Descriptor() ([]byte, []int)

Deprecated: Use BalancingRule.ProtoReflect.Descriptor instead.

func (*BalancingRule) GetFallbackTag 

func (x *BalancingRule) GetFallbackTag() string

func (*BalancingRule) GetOutboundSelector 

func (x *BalancingRule) GetOutboundSelector() []string

func (*BalancingRule) GetStrategy 

func (x *BalancingRule) GetStrategy() string

func (*BalancingRule) GetStrategySettings 

func (x *BalancingRule) GetStrategySettings() *any.Any

func (*BalancingRule) GetTag 

func (x *BalancingRule) GetTag() string

func (*BalancingRule) ProtoMessage 

func (*BalancingRule) ProtoMessage()

func (*BalancingRule) ProtoReflect 

func (x *BalancingRule) ProtoReflect() protoreflect.Message

func (*BalancingRule) Reset 

func (x *BalancingRule) Reset()

func (*BalancingRule) String 

func (x *BalancingRule) String() string

func (*BalancingRule) UnmarshalJSONPB 

func (br *BalancingRule) UnmarshalJSONPB(unmarshaler *jsonpb.Unmarshaler, bytes []byte) error

type BalancingStrategy 

type BalancingStrategy interface {
	PickOutbound([]string) string
}

type Condition 

type Condition interface {
	Apply(ctx routing.Context) bool
}

type ConditionChan 

type ConditionChan []Condition

func NewConditionChan 

func NewConditionChan() *ConditionChan

func (*ConditionChan) Add 

func (v *ConditionChan) Add(cond Condition) *ConditionChan

func (*ConditionChan) Apply 

func (v *ConditionChan) Apply(ctx routing.Context) bool

Apply applies all conditions registered in this chan.

func (*ConditionChan) Len 

func (v *ConditionChan) Len() int

type Config 

type Config struct {
	DomainStrategy DomainStrategy   `` /* 146-byte string literal not displayed */
	Rule           []*RoutingRule   `protobuf:"bytes,2,rep,name=rule,proto3" json:"rule,omitempty"`
	BalancingRule  []*BalancingRule `protobuf:"bytes,3,rep,name=balancing_rule,json=balancingRule,proto3" json:"balancing_rule,omitempty"`
	// contains filtered or unexported fields
}

func (*Config) Descriptor deprecated 

func (*Config) Descriptor() ([]byte, []int)

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetBalancingRule 

func (x *Config) GetBalancingRule() []*BalancingRule

func (*Config) GetDomainStrategy 

func (x *Config) GetDomainStrategy() DomainStrategy

func (*Config) GetRule 

func (x *Config) GetRule() []*RoutingRule

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) ProtoReflect 

func (x *Config) ProtoReflect() protoreflect.Message

func (*Config) Reset 

func (x *Config) Reset()

func (*Config) String 

func (x *Config) String() string

type DomainMatcher 

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

func NewDomainMatcher 

func NewDomainMatcher(matcherType string, domains []*routercommon.Domain) (*DomainMatcher, error)

func (*DomainMatcher) Apply 

func (m *DomainMatcher) Apply(ctx routing.Context) bool

Apply implements Condition.

func (*DomainMatcher) Match 

func (m *DomainMatcher) Match(domain string) bool

type DomainStrategy 

type DomainStrategy int32
const (
	// Use domain as is.
	DomainStrategy_AsIs DomainStrategy = 0
	// Always resolve IP for domains.
	DomainStrategy_UseIp DomainStrategy = 1
	// Resolve to IP if the domain doesn't match any rules.
	DomainStrategy_IpIfNonMatch DomainStrategy = 2
	// Resolve to IP if any rule requires IP matching.
	DomainStrategy_IpOnDemand DomainStrategy = 3
)

func (DomainStrategy) Descriptor 

func (DomainStrategy) Descriptor() protoreflect.EnumDescriptor

func (DomainStrategy) Enum 

func (x DomainStrategy) Enum() *DomainStrategy

func (DomainStrategy) EnumDescriptor deprecated 

func (DomainStrategy) EnumDescriptor() ([]byte, []int)

Deprecated: Use DomainStrategy.Descriptor instead.

func (DomainStrategy) Number 

func (x DomainStrategy) Number() protoreflect.EnumNumber

func (DomainStrategy) String 

func (x DomainStrategy) String() string

func (DomainStrategy) Type 

func (DomainStrategy) Type() protoreflect.EnumType

type GeoIPMatcher 

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

func (*GeoIPMatcher) Init 

func (m *GeoIPMatcher) Init(cidrs []*routercommon.CIDR) error

func (*GeoIPMatcher) Match 

func (m *GeoIPMatcher) Match(ip net.IP) bool

Match returns true if the given ip is included by the GeoIP.

func (*GeoIPMatcher) SetReverseMatch 

func (m *GeoIPMatcher) SetReverseMatch(isReverseMatch bool)

type GeoIPMatcherContainer 

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

GeoIPMatcherContainer is a container for GeoIPMatchers. It keeps unique copies of GeoIPMatcher by country code.

func (*GeoIPMatcherContainer) Add 

func (c *GeoIPMatcherContainer) Add(geoip *routercommon.GeoIP) (*GeoIPMatcher, error)

Add adds a new GeoIP set into the container. If the country code of GeoIP is not empty, GeoIPMatcherContainer will try to find an existing one, instead of adding a new one.

type InboundTagMatcher 

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

func NewInboundTagMatcher 

func NewInboundTagMatcher(tags []string) *InboundTagMatcher

func (*InboundTagMatcher) Apply 

func (v *InboundTagMatcher) Apply(ctx routing.Context) bool

Apply implements Condition.

type LeastLoadStrategy 

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

LeastLoadStrategy represents a least load balancing strategy

func NewLeastLoadStrategy 

func NewLeastLoadStrategy(settings *StrategyLeastLoadConfig) *LeastLoadStrategy

NewLeastLoadStrategy creates a new LeastLoadStrategy with settings

func (*LeastLoadStrategy) GetPrincipleTarget 

func (l *LeastLoadStrategy) GetPrincipleTarget(strings []string) []string

func (*LeastLoadStrategy) InjectContext 

func (l *LeastLoadStrategy) InjectContext(ctx context.Context)

func (*LeastLoadStrategy) PickOutbound 

func (l *LeastLoadStrategy) PickOutbound(candidates []string) string

type LeastPingStrategy 

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

func (*LeastPingStrategy) GetPrincipleTarget 

func (l *LeastPingStrategy) GetPrincipleTarget(strings []string) []string

func (*LeastPingStrategy) InjectContext 

func (l *LeastPingStrategy) InjectContext(ctx context.Context)

func (*LeastPingStrategy) PickOutbound 

func (l *LeastPingStrategy) PickOutbound(strings []string) string

type MultiGeoIPMatcher 

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

func NewMultiGeoIPMatcher 

func NewMultiGeoIPMatcher(geoips []*routercommon.GeoIP, onSource bool) (*MultiGeoIPMatcher, error)

func (*MultiGeoIPMatcher) Apply 

func (m *MultiGeoIPMatcher) Apply(ctx routing.Context) bool

Apply implements Condition.

type NetworkMatcher 

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

func NewNetworkMatcher 

func NewNetworkMatcher(network []net.Network) NetworkMatcher

func (NetworkMatcher) Apply 

func (v NetworkMatcher) Apply(ctx routing.Context) bool

Apply implements Condition.

type PortMatcher 

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

func NewPortMatcher 

func NewPortMatcher(list *net.PortList, onSource bool) *PortMatcher

NewPortMatcher creates a new port matcher that can match source or destination port

func (*PortMatcher) Apply 

func (v *PortMatcher) Apply(ctx routing.Context) bool

Apply implements Condition.

type ProtocolMatcher 

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

func NewProtocolMatcher 

func NewProtocolMatcher(protocols []string) *ProtocolMatcher

func (*ProtocolMatcher) Apply 

func (m *ProtocolMatcher) Apply(ctx routing.Context) bool

Apply implements Condition.

type RandomStrategy 

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

RandomStrategy represents a random balancing strategy

func NewRandomStrategy added in v5.15.0 

func NewRandomStrategy(settings *StrategyRandomConfig) *RandomStrategy

NewRandomStrategy creates a new RandomStrategy with settings

func (*RandomStrategy) GetPrincipleTarget 

func (s *RandomStrategy) GetPrincipleTarget(strings []string) []string

func (*RandomStrategy) InjectContext added in v5.15.0 

func (s *RandomStrategy) InjectContext(ctx context.Context)

func (*RandomStrategy) PickOutbound 

func (s *RandomStrategy) PickOutbound(candidates []string) string

type Route 

type Route struct {
	routing.Context
	// contains filtered or unexported fields
}

Route is an implementation of routing.Route.

func (*Route) GetOutboundGroupTags 

func (r *Route) GetOutboundGroupTags() []string

GetOutboundGroupTags implements routing.Route.

func (*Route) GetOutboundTag 

func (r *Route) GetOutboundTag() string

GetOutboundTag implements routing.Route.

type Router 

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

Router is an implementation of routing.Router.

func (*Router) Close 

func (r *Router) Close() error

Close implements common.Closable.

func (*Router) GetOverrideTarget 

func (r *Router) GetOverrideTarget(tag string) (string, error)

GetOverrideTarget implements routing.BalancerOverrider

func (*Router) GetPrincipleTarget 

func (r *Router) GetPrincipleTarget(tag string) ([]string, error)

GetPrincipleTarget implements routing.BalancerPrincipleTarget

func (*Router) Init 

func (r *Router) Init(ctx context.Context, config *Config, d dns.Client, ohm outbound.Manager, dispatcher routing.Dispatcher) error

Init initializes the Router.

func (*Router) OverrideBalancer 

func (r *Router) OverrideBalancer(balancer string, target string) error

func (*Router) PickRoute 

func (r *Router) PickRoute(ctx routing.Context) (routing.Route, error)

PickRoute implements routing.Router.

func (*Router) SetOverrideTarget 

func (r *Router) SetOverrideTarget(tag, target string) error

SetOverrideTarget implements routing.BalancerOverrider

func (*Router) Start 

func (r *Router) Start() error

Start implements common.Runnable.

func (*Router) Type 

func (*Router) Type() interface{}

Type implements common.HasType.

type RoutingRule 

type RoutingRule struct {

	// Types that are assignable to TargetTag:
	//	*RoutingRule_Tag
	//	*RoutingRule_BalancingTag
	TargetTag isRoutingRule_TargetTag `protobuf_oneof:"target_tag"`
	// List of domains for target domain matching.
	Domain []*routercommon.Domain `protobuf:"bytes,2,rep,name=domain,proto3" json:"domain,omitempty"`
	// List of CIDRs for target IP address matching.
	// Deprecated. Use geoip below.
	//
	// Deprecated: Do not use.
	Cidr []*routercommon.CIDR `protobuf:"bytes,3,rep,name=cidr,proto3" json:"cidr,omitempty"`
	// List of GeoIPs for target IP address matching. If this entry exists, the
	// cidr above will have no effect. GeoIP fields with the same country code are
	// supposed to contain exactly same content. They will be merged during
	// runtime. For customized GeoIPs, please leave country code empty.
	Geoip []*routercommon.GeoIP `protobuf:"bytes,10,rep,name=geoip,proto3" json:"geoip,omitempty"`
	// A range of port [from, to]. If the destination port is in this range, this
	// rule takes effect. Deprecated. Use port_list.
	//
	// Deprecated: Do not use.
	PortRange *net.PortRange `protobuf:"bytes,4,opt,name=port_range,json=portRange,proto3" json:"port_range,omitempty"`
	// List of ports.
	PortList *net.PortList `protobuf:"bytes,14,opt,name=port_list,json=portList,proto3" json:"port_list,omitempty"`
	// List of networks. Deprecated. Use networks.
	//
	// Deprecated: Do not use.
	NetworkList *net.NetworkList `protobuf:"bytes,5,opt,name=network_list,json=networkList,proto3" json:"network_list,omitempty"`
	// List of networks for matching.
	Networks []net.Network `protobuf:"varint,13,rep,packed,name=networks,proto3,enum=v2ray.core.common.net.Network" json:"networks,omitempty"`
	// List of CIDRs for source IP address matching.
	//
	// Deprecated: Do not use.
	SourceCidr []*routercommon.CIDR `protobuf:"bytes,6,rep,name=source_cidr,json=sourceCidr,proto3" json:"source_cidr,omitempty"`
	// List of GeoIPs for source IP address matching. If this entry exists, the
	// source_cidr above will have no effect.
	SourceGeoip []*routercommon.GeoIP `protobuf:"bytes,11,rep,name=source_geoip,json=sourceGeoip,proto3" json:"source_geoip,omitempty"`
	// List of ports for source port matching.
	SourcePortList *net.PortList `protobuf:"bytes,16,opt,name=source_port_list,json=sourcePortList,proto3" json:"source_port_list,omitempty"`
	UserEmail      []string      `protobuf:"bytes,7,rep,name=user_email,json=userEmail,proto3" json:"user_email,omitempty"`
	InboundTag     []string      `protobuf:"bytes,8,rep,name=inbound_tag,json=inboundTag,proto3" json:"inbound_tag,omitempty"`
	Protocol       []string      `protobuf:"bytes,9,rep,name=protocol,proto3" json:"protocol,omitempty"`
	Attributes     string        `protobuf:"bytes,15,opt,name=attributes,proto3" json:"attributes,omitempty"`
	DomainMatcher  string        `protobuf:"bytes,17,opt,name=domain_matcher,json=domainMatcher,proto3" json:"domain_matcher,omitempty"`
	// geo_domain instruct simplified config loader to load geo domain rule and fill in domain field.
	GeoDomain []*routercommon.GeoSite `protobuf:"bytes,68001,rep,name=geo_domain,json=geoDomain,proto3" json:"geo_domain,omitempty"`
	// contains filtered or unexported fields
}

func (*RoutingRule) BuildCondition 

func (rr *RoutingRule) BuildCondition() (Condition, error)

func (*RoutingRule) Descriptor deprecated 

func (*RoutingRule) Descriptor() ([]byte, []int)

Deprecated: Use RoutingRule.ProtoReflect.Descriptor instead.

func (*RoutingRule) GetAttributes 

func (x *RoutingRule) GetAttributes() string

func (*RoutingRule) GetBalancingTag 

func (x *RoutingRule) GetBalancingTag() string

func (*RoutingRule) GetCidr deprecated 

func (x *RoutingRule) GetCidr() []*routercommon.CIDR

Deprecated: Do not use.

func (*RoutingRule) GetDomain 

func (x *RoutingRule) GetDomain() []*routercommon.Domain

func (*RoutingRule) GetDomainMatcher 

func (x *RoutingRule) GetDomainMatcher() string

func (*RoutingRule) GetGeoDomain 

func (x *RoutingRule) GetGeoDomain() []*routercommon.GeoSite

func (*RoutingRule) GetGeoip 

func (x *RoutingRule) GetGeoip() []*routercommon.GeoIP

func (*RoutingRule) GetInboundTag 

func (x *RoutingRule) GetInboundTag() []string

func (*RoutingRule) GetNetworkList deprecated 

func (x *RoutingRule) GetNetworkList() *net.NetworkList

Deprecated: Do not use.

func (*RoutingRule) GetNetworks 

func (x *RoutingRule) GetNetworks() []net.Network

func (*RoutingRule) GetPortList 

func (x *RoutingRule) GetPortList() *net.PortList

func (*RoutingRule) GetPortRange deprecated 

func (x *RoutingRule) GetPortRange() *net.PortRange

Deprecated: Do not use.

func (*RoutingRule) GetProtocol 

func (x *RoutingRule) GetProtocol() []string

func (*RoutingRule) GetSourceCidr deprecated 

func (x *RoutingRule) GetSourceCidr() []*routercommon.CIDR

Deprecated: Do not use.

func (*RoutingRule) GetSourceGeoip 

func (x *RoutingRule) GetSourceGeoip() []*routercommon.GeoIP

func (*RoutingRule) GetSourcePortList 

func (x *RoutingRule) GetSourcePortList() *net.PortList

func (*RoutingRule) GetTag 

func (x *RoutingRule) GetTag() string

func (*RoutingRule) GetTargetTag 

func (m *RoutingRule) GetTargetTag() isRoutingRule_TargetTag

func (*RoutingRule) GetUserEmail 

func (x *RoutingRule) GetUserEmail() []string

func (*RoutingRule) ProtoMessage 

func (*RoutingRule) ProtoMessage()

func (*RoutingRule) ProtoReflect 

func (x *RoutingRule) ProtoReflect() protoreflect.Message

func (*RoutingRule) Reset 

func (x *RoutingRule) Reset()

func (*RoutingRule) String 

func (x *RoutingRule) String() string

type RoutingRule_BalancingTag 

type RoutingRule_BalancingTag struct {
	// Tag of routing balancer.
	BalancingTag string `protobuf:"bytes,12,opt,name=balancing_tag,json=balancingTag,proto3,oneof"`
}

type RoutingRule_Tag 

type RoutingRule_Tag struct {
	// Tag of outbound that this rule is pointing to.
	Tag string `protobuf:"bytes,1,opt,name=tag,proto3,oneof"`
}

type Rule 

type Rule struct {
	Tag       string
	Balancer  *Balancer
	Condition Condition
}

func (*Rule) Apply 

func (r *Rule) Apply(ctx routing.Context) bool

Apply checks rule matching of current routing context.

func (*Rule) GetTag 

func (r *Rule) GetTag() (string, error)

type SimplifiedConfig 

type SimplifiedConfig struct {
	DomainStrategy DomainStrategy           `` /* 146-byte string literal not displayed */
	Rule           []*SimplifiedRoutingRule `protobuf:"bytes,2,rep,name=rule,proto3" json:"rule,omitempty"`
	BalancingRule  []*BalancingRule         `protobuf:"bytes,3,rep,name=balancing_rule,json=balancingRule,proto3" json:"balancing_rule,omitempty"`
	// contains filtered or unexported fields
}

func (*SimplifiedConfig) Descriptor deprecated 

func (*SimplifiedConfig) Descriptor() ([]byte, []int)

Deprecated: Use SimplifiedConfig.ProtoReflect.Descriptor instead.

func (*SimplifiedConfig) GetBalancingRule 

func (x *SimplifiedConfig) GetBalancingRule() []*BalancingRule

func (*SimplifiedConfig) GetDomainStrategy 

func (x *SimplifiedConfig) GetDomainStrategy() DomainStrategy

func (*SimplifiedConfig) GetRule 

func (x *SimplifiedConfig) GetRule() []*SimplifiedRoutingRule

func (*SimplifiedConfig) ProtoMessage 

func (*SimplifiedConfig) ProtoMessage()

func (*SimplifiedConfig) ProtoReflect 

func (x *SimplifiedConfig) ProtoReflect() protoreflect.Message

func (*SimplifiedConfig) Reset 

func (x *SimplifiedConfig) Reset()

func (*SimplifiedConfig) String 

func (x *SimplifiedConfig) String() string

type SimplifiedRoutingRule 

type SimplifiedRoutingRule struct {

	// Types that are assignable to TargetTag:
	//	*SimplifiedRoutingRule_Tag
	//	*SimplifiedRoutingRule_BalancingTag
	TargetTag isSimplifiedRoutingRule_TargetTag `protobuf_oneof:"target_tag"`
	// List of domains for target domain matching.
	Domain []*routercommon.Domain `protobuf:"bytes,2,rep,name=domain,proto3" json:"domain,omitempty"`
	// List of GeoIPs for target IP address matching. If this entry exists, the
	// cidr above will have no effect. GeoIP fields with the same country code are
	// supposed to contain exactly same content. They will be merged during
	// runtime. For customized GeoIPs, please leave country code empty.
	Geoip []*routercommon.GeoIP `protobuf:"bytes,10,rep,name=geoip,proto3" json:"geoip,omitempty"`
	// List of ports.
	PortList string `protobuf:"bytes,14,opt,name=port_list,json=portList,proto3" json:"port_list,omitempty"`
	// List of networks for matching.
	Networks *net.NetworkList `protobuf:"bytes,13,opt,name=networks,proto3" json:"networks,omitempty"`
	// List of GeoIPs for source IP address matching. If this entry exists, the
	// source_cidr above will have no effect.
	SourceGeoip []*routercommon.GeoIP `protobuf:"bytes,11,rep,name=source_geoip,json=sourceGeoip,proto3" json:"source_geoip,omitempty"`
	// List of ports for source port matching.
	SourcePortList string   `protobuf:"bytes,16,opt,name=source_port_list,json=sourcePortList,proto3" json:"source_port_list,omitempty"`
	UserEmail      []string `protobuf:"bytes,7,rep,name=user_email,json=userEmail,proto3" json:"user_email,omitempty"`
	InboundTag     []string `protobuf:"bytes,8,rep,name=inbound_tag,json=inboundTag,proto3" json:"inbound_tag,omitempty"`
	Protocol       []string `protobuf:"bytes,9,rep,name=protocol,proto3" json:"protocol,omitempty"`
	Attributes     string   `protobuf:"bytes,15,opt,name=attributes,proto3" json:"attributes,omitempty"`
	DomainMatcher  string   `protobuf:"bytes,17,opt,name=domain_matcher,json=domainMatcher,proto3" json:"domain_matcher,omitempty"`
	// geo_domain instruct simplified config loader to load geo domain rule and fill in domain field.
	GeoDomain []*routercommon.GeoSite `protobuf:"bytes,68001,rep,name=geo_domain,json=geoDomain,proto3" json:"geo_domain,omitempty"`
	// contains filtered or unexported fields
}

func (*SimplifiedRoutingRule) Descriptor deprecated 

func (*SimplifiedRoutingRule) Descriptor() ([]byte, []int)

Deprecated: Use SimplifiedRoutingRule.ProtoReflect.Descriptor instead.

func (*SimplifiedRoutingRule) GetAttributes 

func (x *SimplifiedRoutingRule) GetAttributes() string

func (*SimplifiedRoutingRule) GetBalancingTag 

func (x *SimplifiedRoutingRule) GetBalancingTag() string

func (*SimplifiedRoutingRule) GetDomain 

func (x *SimplifiedRoutingRule) GetDomain() []*routercommon.Domain

func (*SimplifiedRoutingRule) GetDomainMatcher 

func (x *SimplifiedRoutingRule) GetDomainMatcher() string

func (*SimplifiedRoutingRule) GetGeoDomain 

func (x *SimplifiedRoutingRule) GetGeoDomain() []*routercommon.GeoSite

func (*SimplifiedRoutingRule) GetGeoip 

func (x *SimplifiedRoutingRule) GetGeoip() []*routercommon.GeoIP

func (*SimplifiedRoutingRule) GetInboundTag 

func (x *SimplifiedRoutingRule) GetInboundTag() []string

func (*SimplifiedRoutingRule) GetNetworks 

func (x *SimplifiedRoutingRule) GetNetworks() *net.NetworkList

func (*SimplifiedRoutingRule) GetPortList 

func (x *SimplifiedRoutingRule) GetPortList() string

func (*SimplifiedRoutingRule) GetProtocol 

func (x *SimplifiedRoutingRule) GetProtocol() []string

func (*SimplifiedRoutingRule) GetSourceGeoip 

func (x *SimplifiedRoutingRule) GetSourceGeoip() []*routercommon.GeoIP

func (*SimplifiedRoutingRule) GetSourcePortList 

func (x *SimplifiedRoutingRule) GetSourcePortList() string

func (*SimplifiedRoutingRule) GetTag 

func (x *SimplifiedRoutingRule) GetTag() string

func (*SimplifiedRoutingRule) GetTargetTag 

func (m *SimplifiedRoutingRule) GetTargetTag() isSimplifiedRoutingRule_TargetTag

func (*SimplifiedRoutingRule) GetUserEmail 

func (x *SimplifiedRoutingRule) GetUserEmail() []string

func (*SimplifiedRoutingRule) ProtoMessage 

func (*SimplifiedRoutingRule) ProtoMessage()

func (*SimplifiedRoutingRule) ProtoReflect 

func (x *SimplifiedRoutingRule) ProtoReflect() protoreflect.Message

func (*SimplifiedRoutingRule) Reset 

func (x *SimplifiedRoutingRule) Reset()

func (*SimplifiedRoutingRule) String 

func (x *SimplifiedRoutingRule) String() string

type SimplifiedRoutingRule_BalancingTag 

type SimplifiedRoutingRule_BalancingTag struct {
	// Tag of routing balancer.
	BalancingTag string `protobuf:"bytes,12,opt,name=balancing_tag,json=balancingTag,proto3,oneof"`
}

type SimplifiedRoutingRule_Tag 

type SimplifiedRoutingRule_Tag struct {
	// Tag of outbound that this rule is pointing to.
	Tag string `protobuf:"bytes,1,opt,name=tag,proto3,oneof"`
}

type StrategyLeastLoadConfig 

type StrategyLeastLoadConfig struct {

	// weight settings
	Costs []*StrategyWeight `protobuf:"bytes,2,rep,name=costs,proto3" json:"costs,omitempty"`
	// RTT baselines for selecting, int64 values of time.Duration
	Baselines []int64 `protobuf:"varint,3,rep,packed,name=baselines,proto3" json:"baselines,omitempty"`
	// expected nodes count to select
	Expected int32 `protobuf:"varint,4,opt,name=expected,proto3" json:"expected,omitempty"`
	// max acceptable rtt, filter away high delay nodes. defalut 0
	MaxRTT int64 `protobuf:"varint,5,opt,name=maxRTT,proto3" json:"maxRTT,omitempty"`
	// acceptable failure rate
	Tolerance   float32 `protobuf:"fixed32,6,opt,name=tolerance,proto3" json:"tolerance,omitempty"`
	ObserverTag string  `protobuf:"bytes,7,opt,name=observer_tag,json=observerTag,proto3" json:"observer_tag,omitempty"`
	// contains filtered or unexported fields
}

func (*StrategyLeastLoadConfig) Descriptor deprecated 

func (*StrategyLeastLoadConfig) Descriptor() ([]byte, []int)

Deprecated: Use StrategyLeastLoadConfig.ProtoReflect.Descriptor instead.

func (*StrategyLeastLoadConfig) GetBaselines 

func (x *StrategyLeastLoadConfig) GetBaselines() []int64

func (*StrategyLeastLoadConfig) GetCosts 

func (x *StrategyLeastLoadConfig) GetCosts() []*StrategyWeight

func (*StrategyLeastLoadConfig) GetExpected 

func (x *StrategyLeastLoadConfig) GetExpected() int32

func (*StrategyLeastLoadConfig) GetMaxRTT 

func (x *StrategyLeastLoadConfig) GetMaxRTT() int64

func (*StrategyLeastLoadConfig) GetObserverTag 

func (x *StrategyLeastLoadConfig) GetObserverTag() string

func (*StrategyLeastLoadConfig) GetTolerance 

func (x *StrategyLeastLoadConfig) GetTolerance() float32

func (*StrategyLeastLoadConfig) ProtoMessage 

func (*StrategyLeastLoadConfig) ProtoMessage()

func (*StrategyLeastLoadConfig) ProtoReflect 

func (x *StrategyLeastLoadConfig) ProtoReflect() protoreflect.Message

func (*StrategyLeastLoadConfig) Reset 

func (x *StrategyLeastLoadConfig) Reset()

func (*StrategyLeastLoadConfig) String 

func (x *StrategyLeastLoadConfig) String() string

type StrategyLeastPingConfig 

type StrategyLeastPingConfig struct {
	ObserverTag string `protobuf:"bytes,7,opt,name=observer_tag,json=observerTag,proto3" json:"observer_tag,omitempty"`
	// contains filtered or unexported fields
}

func (*StrategyLeastPingConfig) Descriptor deprecated 

func (*StrategyLeastPingConfig) Descriptor() ([]byte, []int)

Deprecated: Use StrategyLeastPingConfig.ProtoReflect.Descriptor instead.

func (*StrategyLeastPingConfig) GetObserverTag 

func (x *StrategyLeastPingConfig) GetObserverTag() string

func (*StrategyLeastPingConfig) ProtoMessage 

func (*StrategyLeastPingConfig) ProtoMessage()

func (*StrategyLeastPingConfig) ProtoReflect 

func (x *StrategyLeastPingConfig) ProtoReflect() protoreflect.Message

func (*StrategyLeastPingConfig) Reset 

func (x *StrategyLeastPingConfig) Reset()

func (*StrategyLeastPingConfig) String 

func (x *StrategyLeastPingConfig) String() string

type StrategyRandomConfig 

type StrategyRandomConfig struct {
	ObserverTag string `protobuf:"bytes,7,opt,name=observer_tag,json=observerTag,proto3" json:"observer_tag,omitempty"`
	AliveOnly   bool   `protobuf:"varint,8,opt,name=alive_only,json=aliveOnly,proto3" json:"alive_only,omitempty"`
	// contains filtered or unexported fields
}

func (*StrategyRandomConfig) Descriptor deprecated 

func (*StrategyRandomConfig) Descriptor() ([]byte, []int)

Deprecated: Use StrategyRandomConfig.ProtoReflect.Descriptor instead.

func (*StrategyRandomConfig) GetAliveOnly added in v5.15.0 

func (x *StrategyRandomConfig) GetAliveOnly() bool

func (*StrategyRandomConfig) GetObserverTag added in v5.15.0 

func (x *StrategyRandomConfig) GetObserverTag() string

func (*StrategyRandomConfig) ProtoMessage 

func (*StrategyRandomConfig) ProtoMessage()

func (*StrategyRandomConfig) ProtoReflect 

func (x *StrategyRandomConfig) ProtoReflect() protoreflect.Message

func (*StrategyRandomConfig) Reset 

func (x *StrategyRandomConfig) Reset()

func (*StrategyRandomConfig) String 

func (x *StrategyRandomConfig) String() string

type StrategyWeight 

type StrategyWeight struct {
	Regexp bool    `protobuf:"varint,1,opt,name=regexp,proto3" json:"regexp,omitempty"`
	Match  string  `protobuf:"bytes,2,opt,name=match,proto3" json:"match,omitempty"`
	Value  float32 `protobuf:"fixed32,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*StrategyWeight) Descriptor deprecated 

func (*StrategyWeight) Descriptor() ([]byte, []int)

Deprecated: Use StrategyWeight.ProtoReflect.Descriptor instead.

func (*StrategyWeight) GetMatch 

func (x *StrategyWeight) GetMatch() string

func (*StrategyWeight) GetRegexp 

func (x *StrategyWeight) GetRegexp() bool

func (*StrategyWeight) GetValue 

func (x *StrategyWeight) GetValue() float32

func (*StrategyWeight) ProtoMessage 

func (*StrategyWeight) ProtoMessage()

func (*StrategyWeight) ProtoReflect 

func (x *StrategyWeight) ProtoReflect() protoreflect.Message

func (*StrategyWeight) Reset 

func (x *StrategyWeight) Reset()

func (*StrategyWeight) String 

func (x *StrategyWeight) String() string

type UserMatcher 

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

func NewUserMatcher 

func NewUserMatcher(users []string) *UserMatcher

func (*UserMatcher) Apply 

func (v *UserMatcher) Apply(ctx routing.Context) bool

Apply implements Condition.

type WeightManager 

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

WeightManager manages weights for specific settings

func NewWeightManager 

func NewWeightManager(s []*StrategyWeight, defaultWeight float64, scaler weightScaler) *WeightManager

NewWeightManager creates a new WeightManager with settings

func (*WeightManager) Apply 

func (s *WeightManager) Apply(tag string, value float64) float64

Apply applies weight to the value

func (*WeightManager) Get 

func (s *WeightManager) Get(tag string) float64

Get gets the weight of specified tag

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.