service_http

Documentation

Index

• Variables
• func NewFactory() eosc.IExtenderDriverFactory
• func Register(register eosc.IExtenderDriverRegister)
• type Config
  • func (c *Config) String() string
• type Handlers
  • func NewHandlers() *Handlers
  • func (h *Handlers) Del(id string) (*ServiceHandler, bool)
  • func (h *Handlers) List() []*ServiceHandler
  • func (h *Handlers) Set(id string, handler *ServiceHandler)
• type IHandlers
• type Service
  • func (s *Service) Create(id string, configs map[string]*plugin.Config) service.IService
  • func (s *Service) Merge(config map[string]*plugin.Config) map[string]*plugin.Config
• type ServiceHandler
  • func (s *ServiceHandler) Destroy()
  • func (s *ServiceHandler) DoChain(ctx http_service.IHttpContext) error
  • func (s *ServiceHandler) 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 (
	ErrorNeedUpstream = errors.New("need upstream")

	ErrorInvalidDiscovery = errors.New("invalid Discovery")
)

var DriverName = "service_http"

Functions

func NewFactory

func NewFactory() eosc.IExtenderDriverFactory

NewFactory 创建service_http驱动工厂

func Register

func Register(register eosc.IExtenderDriverRegister)

Register 注册service_http驱动工厂

Types

type Config

type Config struct {
	Timeout      int64                     `json:"timeout" label:"请求超时时间" default:"2000" minimum:"1" description:"单位：ms，最小值：1"`
	Retry        int                       `json:"retry" label:"失败重试次数"`
	Scheme       string                    `json:"scheme" label:"请求协议" enum:"HTTP,HTTPS"`
	Discovery    eosc.RequireId            `` /* 153-byte string literal not displayed */
	Service      string                    `json:"service" required:"false" label:"服务名 or 配置" switch:"discovery !==''"`
	Nodes        []string                  `json:"nodes" label:"静态配置" switch:"discovery===''"`
	Balance      string                    `json:"balance" enum:"round-robin" label:"负载均衡算法"`
	PluginConfig map[string]*plugin.Config `json:"plugins" label:"插件"`
}

Config service_http驱动配置

func (*Config) String

func (c *Config) String() string

type Handlers

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

func NewHandlers

func NewHandlers() *Handlers

func (*Handlers) Del

func (h *Handlers) Del(id string) (*ServiceHandler, bool)

func (*Handlers) List

func (h *Handlers) List() []*ServiceHandler

func (*Handlers) Set

func (h *Handlers) Set(id string, handler *ServiceHandler)

type IHandlers

type IHandlers interface {
	Set(id string, handler *ServiceHandler)
	Del(id string) (*ServiceHandler, bool)
	List() []*ServiceHandler
}

type Service

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

func (*Service) Create

func (s *Service) Create(id string, configs map[string]*plugin.Config) service.IService

func (*Service) Merge

func (s *Service) Merge(config map[string]*plugin.Config) map[string]*plugin.Config

type ServiceHandler

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

func (*ServiceHandler) Destroy

func (s *ServiceHandler) Destroy()

func (*ServiceHandler) DoChain

func (s *ServiceHandler) DoChain(ctx http_service.IHttpContext) error

func (*ServiceHandler) DoFilter

func (s *ServiceHandler) 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 (*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 请求发送