upstream_http

Documentation

Index

• Variables
• func NewFactory() eosc.IExtenderDriverFactory
• func Register(register eosc.IExtenderDriverRegister)
• type Config
• type SendAddr
  • func NewSendAddr(addr string, timeout time.Duration) *SendAddr
  • func (s *SendAddr) Destroy()
  • func (s *SendAddr) DoFilter(ctx http_service.IHttpContext, next http_service.IChain) (err error)
• type Upstream
  • func NewUpstream(scheme string, app discovery.IApp, handler balance.IBalanceHandler) *Upstream
  • func (up *Upstream) Create(id string, retry int, timeout time.Duration) (upstream.IUpstreamHandler, error)
  • func (up *Upstream) Reset(scheme string, app discovery.IApp, handler balance.IBalanceHandler)
• type UpstreamHandler
  • func NewUpstreamHandler(id string, upstream *Upstream, retry int, timeout time.Duration) *UpstreamHandler
  • func (u *UpstreamHandler) Destroy()
  • func (u *UpstreamHandler) DoChain(ctx http_service.IHttpContext) error

Variables

var (
	ErrorStructType = errors.New("error struct type")

	ErrorUpstreamNotInit = errors.New("upstream not init")
)

Functions

func NewFactory

func NewFactory() eosc.IExtenderDriverFactory

NewFactory 创建http_proxy驱动工厂

func Register

func Register(register eosc.IExtenderDriverRegister)

Register 注册http_proxy驱动工厂

Types

type Config

type Config struct {
	Scheme    string         `json:"scheme" enum:"HTTP,HTTPS" label:"请求协议"`
	Type      string         `json:"type" enum:"round-robin" label:"负载算法"`
	Config    string         `json:"config" label:"配置"`
	Discovery eosc.RequireId `json:"discovery" required:"true" label:"服务发现" skill:"github.com/eolinker/apinto/discovery.discovery.IDiscovery"`
}

Config http-service-proxy驱动配置结构体

type SendAddr

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

func NewSendAddr

func NewSendAddr(addr string, timeout time.Duration) *SendAddr

func (*SendAddr) Destroy

func (s *SendAddr) Destroy()

func (*SendAddr) DoFilter

func (s *SendAddr) DoFilter(ctx http_service.IHttpContext, next http_service.IChain) (err error)

type Upstream

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

func NewUpstream

func NewUpstream(scheme string, app discovery.IApp, handler balance.IBalanceHandler) *Upstream

func (up *Upstream) Merge(configs map[string]*plugin.Config) map[string]*plugin.Config {
	return plugin.MergeConfig(configs, up.pluginConf)
}

func (*Upstream) Create

func (up *Upstream) Create(id string, retry int, timeout time.Duration) (upstream.IUpstreamHandler, error)

func (*Upstream) Reset

func (up *Upstream) Reset(scheme string, app discovery.IApp, handler balance.IBalanceHandler)

Reset reset

type UpstreamHandler

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

func NewUpstreamHandler

func NewUpstreamHandler(id string, upstream *Upstream, retry int, timeout time.Duration) *UpstreamHandler

func (*UpstreamHandler) Destroy

func (u *UpstreamHandler) Destroy()

func (*UpstreamHandler) DoChain

func (u *UpstreamHandler) DoChain(ctx http_service.IHttpContext) error

DoChain 请求发送