upstream

Documentation

Index

• type Policy
• type Result
  • func BuildUpstreamsFromRules(policy Policy, rules config.Rules, dialer proxy.Dialer) (*Result, error)
• type Upstream
  • func (u *Upstream) MaskedKey() string
  • func (u *Upstream) MaskedServer() string
  • func (u *Upstream) Name() string
• type Upstreams
  • func NewUpstreams(policy Policy) *Upstreams
  • func (u *Upstreams) Add(upstream *Upstream)
  • func (u *Upstreams) All() []*Upstream
  • func (u *Upstreams) Init() error
  • func (u *Upstreams) Len() int
  • func (u *Upstreams) Next(excludeIndex ...int) (*Upstream, int)
  • func (u *Upstreams) Print()

Types

type Policy

type Policy string

const (
	RandomPolicy     Policy = "random"
	RoundRobinPolicy Policy = "round_robin"
	WeightPolicy     Policy = "weight"
)

type Result

type Result struct {
	Upstreams map[string]*Upstreams
	Default   *Upstreams
	ExprRules []config.Rule
}

func BuildUpstreamsFromRules

func BuildUpstreamsFromRules(policy Policy, rules config.Rules, dialer proxy.Dialer) (*Result, error)

type Upstream

type Upstream struct {
	Rule        config.Rule
	Index       int
	Handler     base.Handler
	ServerIndex int
	KeyIndex    int
}

func (*Upstream) MaskedKey

func (u *Upstream) MaskedKey() string

func (*Upstream) MaskedServer

func (u *Upstream) MaskedServer() string

func (*Upstream) Name

func (u *Upstream) Name() string

type Upstreams

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

func NewUpstreams

func NewUpstreams(policy Policy) *Upstreams

func (*Upstreams) Add

func (u *Upstreams) Add(upstream *Upstream)

func (*Upstreams) All

func (u *Upstreams) All() []*Upstream

func (*Upstreams) Init

func (u *Upstreams) Init() error

func (*Upstreams) Len

func (u *Upstreams) Len() int

func (*Upstreams) Next

func (u *Upstreams) Next(excludeIndex ...int) (*Upstream, int)

func (*Upstreams) Print

func (u *Upstreams) Print()