router

package

Go to main page

Versions in this module

v1

v1.8.23

Aug 11, 2024

v1.8.22

Jul 22, 2024

v1.8.21

Jul 20, 2024

v1.8.20

Jul 18, 2024

v1.8.19

Jul 17, 2024

v1.8.18

Jul 17, 2024

v1.8.16

Jul 9, 2024

Changes in this version

+ func RemoveDuplicateRule(users []string) []string

type RandomStrategy

+ FallbackTag string

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

type RoundRobinStrategy

+ FallbackTag string

+ func (s *RoundRobinStrategy) GetPrincipleTarget(strings []string) []string

+ func (s *RoundRobinStrategy) InjectContext(ctx context.Context)

type Router

+ func (r *Router) AddUserRule(tag string, email []string)

+ func (r *Router) RemoveUserRule(Users []string)

v1.8.10

Apr 11, 2024

v1.8.9

Apr 12, 2024

v1.8.8

Apr 12, 2024

Changes in this version

type Balancer

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

+ type BalancingPrincipleTarget interface

+ GetPrincipleTarget func([]string) []string

type BalancingRule

+ FallbackTag string

+ StrategySettings *serial.TypedMessage

+ func (x *BalancingRule) GetFallbackTag() string

+ func (x *BalancingRule) GetStrategySettings() *serial.TypedMessage

+ type LeastLoadStrategy struct

+ func NewLeastLoadStrategy(settings *StrategyLeastLoadConfig) *LeastLoadStrategy

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

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

+ func (s *LeastLoadStrategy) PickOutbound(candidates []string) string

type LeastPingStrategy

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

type RandomStrategy

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

+ type RoundRobinStrategy struct

+ func (s *RoundRobinStrategy) PickOutbound(tags []string) string

type Router

+ func (r *Router) AddRule(config *serial.TypedMessage, shouldAppend bool) error

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

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

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

+ func (r *Router) ReloadRules(config *Config, shouldAppend bool) error

+ func (r *Router) RemoveRule(tag string) error

+ func (r *Router) RuleExists(tag string) bool

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

type RoutingRule

+ RuleTag string

+ func (x *RoutingRule) GetRuleTag() string

type Rule

+ RuleTag string

+ type StrategyLeastLoadConfig struct

+ Baselines []int64

+ Costs []*StrategyWeight

+ Expected int32

+ MaxRTT int64

+ Tolerance float32

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

+ func (*StrategyLeastLoadConfig) ProtoMessage()

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

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

+ func (x *StrategyLeastLoadConfig) GetExpected() int32

+ func (x *StrategyLeastLoadConfig) GetMaxRTT() int64

+ func (x *StrategyLeastLoadConfig) GetTolerance() float32

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

+ func (x *StrategyLeastLoadConfig) Reset()

+ func (x *StrategyLeastLoadConfig) String() string

+ type StrategyWeight struct

+ Match string

+ Regexp bool

+ Value float32

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

+ func (*StrategyWeight) ProtoMessage()

+ func (x *StrategyWeight) GetMatch() string

+ func (x *StrategyWeight) GetRegexp() bool

+ func (x *StrategyWeight) GetValue() float32

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

+ func (x *StrategyWeight) Reset()

+ func (x *StrategyWeight) String() string

+ type WeightManager struct

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

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

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

v1.8.6

Sep 30, 2023

v1.8.5

Sep 3, 2023

v1.8.4

Sep 3, 2023

v1.8.3

Jul 12, 2023

Changes in this version

+ var Config_DomainStrategy_name = map[int32]string

+ var Config_DomainStrategy_value = map[string]int32

+ var Domain_Type_name = map[int32]string

+ var Domain_Type_value = map[string]int32

+ var File_app_router_config_proto protoreflect.FileDescriptor

+ func Romvededuplicate(users []string) []string

+ type AttributeMatcher struct

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

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

+ type Balancer struct

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

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

+ type BalancingRule struct

+ OutboundSelector []string

+ Strategy string

+ Tag string

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

+ func (*BalancingRule) ProtoMessage()

+ func (br *BalancingRule) Build(ohm outbound.Manager) (*Balancer, error)

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

+ func (x *BalancingRule) GetStrategy() string

+ func (x *BalancingRule) GetTag() string

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

+ func (x *BalancingRule) Reset()

+ func (x *BalancingRule) String() string

+ type BalancingStrategy interface

+ PickOutbound func([]string) string

+ type CIDR struct

+ Ip []byte

+ Prefix uint32

+ func (*CIDR) Descriptor() ([]byte, []int)

+ func (*CIDR) ProtoMessage()

+ func (x *CIDR) GetIp() []byte

+ func (x *CIDR) GetPrefix() uint32

+ func (x *CIDR) ProtoReflect() protoreflect.Message

+ func (x *CIDR) Reset()

+ func (x *CIDR) String() string

+ type CIDRList []*CIDR

+ func (l *CIDRList) Len() int

+ func (l *CIDRList) Less(i int, j int) bool

+ func (l *CIDRList) Swap(i int, j int)

+ type Condition interface

+ Apply func(ctx routing.Context) bool

+ type ConditionChan []Condition

+ func NewConditionChan() *ConditionChan

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

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

+ func (v *ConditionChan) Len() int

+ type Config struct

+ BalancingRule []*BalancingRule

+ DomainStrategy Config_DomainStrategy

+ Rule []*RoutingRule

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

+ func (*Config) ProtoMessage()

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

+ func (x *Config) GetDomainStrategy() Config_DomainStrategy

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

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

+ func (x *Config) Reset()

+ func (x *Config) String() string

+ type Config_DomainStrategy int32

+ const Config_AsIs

+ const Config_IpIfNonMatch

+ const Config_IpOnDemand

+ const Config_UseIp

+ func (Config_DomainStrategy) Descriptor() protoreflect.EnumDescriptor

+ func (Config_DomainStrategy) EnumDescriptor() ([]byte, []int)

+ func (Config_DomainStrategy) Type() protoreflect.EnumType

+ func (x Config_DomainStrategy) Enum() *Config_DomainStrategy

+ func (x Config_DomainStrategy) Number() protoreflect.EnumNumber

+ func (x Config_DomainStrategy) String() string

+ type Domain struct

+ Attribute []*Domain_Attribute

+ Type Domain_Type

+ Value string

+ func (*Domain) Descriptor() ([]byte, []int)

+ func (*Domain) ProtoMessage()

+ func (x *Domain) GetAttribute() []*Domain_Attribute

+ func (x *Domain) GetType() Domain_Type

+ func (x *Domain) GetValue() string

+ func (x *Domain) ProtoReflect() protoreflect.Message

+ func (x *Domain) Reset()

+ func (x *Domain) String() string

+ type DomainMatcher struct

+ func NewDomainMatcher(domains []*Domain) (*DomainMatcher, error)

+ func NewMphMatcherGroup(domains []*Domain) (*DomainMatcher, error)

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

+ func (m *DomainMatcher) ApplyDomain(domain string) bool

+ type Domain_Attribute struct

+ Key string

+ TypedValue isDomain_Attribute_TypedValue

+ func (*Domain_Attribute) Descriptor() ([]byte, []int)

+ func (*Domain_Attribute) ProtoMessage()

+ func (m *Domain_Attribute) GetTypedValue() isDomain_Attribute_TypedValue

+ func (x *Domain_Attribute) GetBoolValue() bool

+ func (x *Domain_Attribute) GetIntValue() int64

+ func (x *Domain_Attribute) GetKey() string

+ func (x *Domain_Attribute) ProtoReflect() protoreflect.Message

+ func (x *Domain_Attribute) Reset()

+ func (x *Domain_Attribute) String() string

+ type Domain_Attribute_BoolValue struct

+ BoolValue bool

+ type Domain_Attribute_IntValue struct

+ IntValue int64

+ type Domain_Type int32

+ const Domain_Domain

+ const Domain_Full

+ const Domain_Plain

+ const Domain_Regex

+ func (Domain_Type) Descriptor() protoreflect.EnumDescriptor

+ func (Domain_Type) EnumDescriptor() ([]byte, []int)

+ func (Domain_Type) Type() protoreflect.EnumType

+ func (x Domain_Type) Enum() *Domain_Type

+ func (x Domain_Type) Number() protoreflect.EnumNumber

+ func (x Domain_Type) String() string

+ type GeoIP struct

+ Cidr []*CIDR

+ CountryCode string

+ ReverseMatch bool

+ func (*GeoIP) Descriptor() ([]byte, []int)

+ func (*GeoIP) ProtoMessage()

+ func (x *GeoIP) GetCidr() []*CIDR

+ func (x *GeoIP) GetCountryCode() string

+ func (x *GeoIP) GetReverseMatch() bool

+ func (x *GeoIP) ProtoReflect() protoreflect.Message

+ func (x *GeoIP) Reset()

+ func (x *GeoIP) String() string

+ type GeoIPList struct

+ Entry []*GeoIP

+ func (*GeoIPList) Descriptor() ([]byte, []int)

+ func (*GeoIPList) ProtoMessage()

+ func (x *GeoIPList) GetEntry() []*GeoIP

+ func (x *GeoIPList) ProtoReflect() protoreflect.Message

+ func (x *GeoIPList) Reset()

+ func (x *GeoIPList) String() string

+ type GeoIPMatcher struct

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

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

+ func (m *GeoIPMatcher) SetReverseMatch(isReverseMatch bool)

+ type GeoIPMatcherContainer struct

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

+ type GeoSite struct

+ CountryCode string

+ Domain []*Domain

+ func (*GeoSite) Descriptor() ([]byte, []int)

+ func (*GeoSite) ProtoMessage()

+ func (x *GeoSite) GetCountryCode() string

+ func (x *GeoSite) GetDomain() []*Domain

+ func (x *GeoSite) ProtoReflect() protoreflect.Message

+ func (x *GeoSite) Reset()

+ func (x *GeoSite) String() string

+ type GeoSiteList struct

+ Entry []*GeoSite

+ func (*GeoSiteList) Descriptor() ([]byte, []int)

+ func (*GeoSiteList) ProtoMessage()

+ func (x *GeoSiteList) GetEntry() []*GeoSite

+ func (x *GeoSiteList) ProtoReflect() protoreflect.Message

+ func (x *GeoSiteList) Reset()

+ func (x *GeoSiteList) String() string

+ type InboundTagMatcher struct

+ func NewInboundTagMatcher(tags []string) *InboundTagMatcher

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

+ type LeastPingStrategy struct

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

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

+ type MultiGeoIPMatcher struct

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

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

+ type NetworkMatcher struct

+ func NewNetworkMatcher(network []net.Network) NetworkMatcher

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

+ type PortMatcher struct

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

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

+ type ProtocolMatcher struct

+ func NewProtocolMatcher(protocols []string) *ProtocolMatcher

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

+ type RandomStrategy struct

+ func (s *RandomStrategy) PickOutbound(tags []string) string

+ type Route struct

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

+ func (r *Route) GetOutboundTag() string

+ type Router struct

+ func NewRouter() *Router

+ func (*Router) Close() error

+ func (*Router) Start() error

+ func (*Router) Type() interface{}

+ func (r *Router) AddUsers(tag string, emails []string)

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

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

+ func (r *Router) RemoveUsers(Users []string)

+ type RoutingRule struct

+ Attributes map[string]string

+ Cidr []*CIDR

+ Domain []*Domain

+ DomainMatcher string

+ Geoip []*GeoIP

+ InboundTag []string

+ NetworkList *net.NetworkList

+ Networks []net.Network

+ PortList *net.PortList

+ PortRange *net.PortRange

+ Protocol []string

+ SourceCidr []*CIDR

+ SourceGeoip []*GeoIP

+ SourcePortList *net.PortList

+ TargetTag isRoutingRule_TargetTag

+ UserEmail []string

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

+ func (*RoutingRule) ProtoMessage()

+ func (m *RoutingRule) GetTargetTag() isRoutingRule_TargetTag

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

+ func (x *RoutingRule) GetAttributes() map[string]string

+ func (x *RoutingRule) GetBalancingTag() string

+ func (x *RoutingRule) GetCidr() []*CIDR

+ func (x *RoutingRule) GetDomain() []*Domain

+ func (x *RoutingRule) GetDomainMatcher() string

+ func (x *RoutingRule) GetGeoip() []*GeoIP

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

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

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

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

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

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

+ func (x *RoutingRule) GetSourceCidr() []*CIDR

+ func (x *RoutingRule) GetSourceGeoip() []*GeoIP

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

+ func (x *RoutingRule) GetTag() string

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

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

+ func (x *RoutingRule) Reset()

+ func (x *RoutingRule) String() string

+ type RoutingRule_BalancingTag struct

+ BalancingTag string

+ type RoutingRule_Tag struct

+ Tag string

+ type Rule struct

+ Balancer *Balancer

+ Condition Condition

+ Tag string

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

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

+ type UserMatcher struct

+ func NewUserMatcher(users []string) *UserMatcher

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL