traffic

Documentation

Index

• type CanaryHeaders
• type Cluster
• type ClusterWrapper
• type Config
• type Filter
  • func (f *Filter) Decode(ctx *http.HttpContext) filter.FilterStatus
• type FilterFactory
  • func (factory *FilterFactory) Apply() error
  • func (factory *FilterFactory) Config() interface{}
  • func (factory *FilterFactory) PrepareFilterChain(ctx *http.HttpContext, chain filter.FilterChain) error
• type Plugin
  • func (p *Plugin) CreateFilterFactory() (filter.HttpFilterFactory, error)
  • func (p *Plugin) Kind() string

Types

type CanaryHeaders

type CanaryHeaders string

type Cluster

type Cluster struct {
	Name           string `yaml:"name" json:"name" mapstructure:"name"`
	Router         string `yaml:"router" json:"router" mapstructure:"router"`
	CanaryByHeader string `yaml:"canary-by-header" json:"canary-by-header" mapstructure:"canary-by-header"`
	CanaryWeight   int    `yaml:"canary-weight" json:"canary-weight" mapstructure:"canary-weight"`
}

type ClusterWrapper

type ClusterWrapper struct {
	Cluster *Cluster
	// contains filtered or unexported fields
}

type Config

type Config struct {
	Traffics []*Cluster `yaml:"traffics" json:"traffics" mapstructure:"traffics"`
}

type Filter

type Filter struct {
	Rules []*ClusterWrapper
	// contains filtered or unexported fields
}

func (*Filter) Decode

func (f *Filter) Decode(ctx *http.HttpContext) filter.FilterStatus

type FilterFactory

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

func (*FilterFactory) Apply

func (factory *FilterFactory) Apply() error

func (*FilterFactory) Config

func (factory *FilterFactory) Config() interface{}

func (*FilterFactory) PrepareFilterChain

func (factory *FilterFactory) PrepareFilterChain(ctx *http.HttpContext, chain filter.FilterChain) error

type Plugin

type Plugin struct {
}

func (*Plugin) CreateFilterFactory

func (p *Plugin) CreateFilterFactory() (filter.HttpFilterFactory, error)

func (*Plugin) Kind

func (p *Plugin) Kind() string