service_http

Jun 22, 2022

Changes in this version

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

type Config

+ Balance string

+ Discovery eosc.RequireId

+ Nodes []string

+ Service string

+ func (c *Config) String() string

+ type Upstream struct

+ 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 struct

+ 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

Jan 14, 2022

Changes in this version

+ var DriverName = "service_http"

+ var ErrorInvalidUpstream = errors.New("not upstream")

+ var ErrorNeedUpstream = errors.New("need upstream")

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

+ func NewFactory() eosc.IExtenderDriverFactory

+ func Register(register eosc.IExtenderDriverRegister)

+ type AnonymousConfig struct

+ Config string

+ Type string

+ type Config struct

+ Desc string

+ Driver string

+ Name string

+ PluginConfig map[string]*plugin.Config

+ ProxyMethod string

+ Retry int

+ Scheme string

+ Timeout int64

+ Upstream eosc.RequireId

+ UpstreamAnonymous *AnonymousConfig

+ type Handlers struct

+ 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 interface

+ Del func(id string) (*ServiceHandler, bool)

+ List func() []*ServiceHandler

+ Set func(id string, handler *ServiceHandler)

+ type Service struct

+ 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 struct

+ 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)