service_http

package

v0.6.0 Latest Latest Go to latest Published: Jun 17, 2022 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/eolinker/apinto

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func NewFactory() eosc.IExtenderDriverFactory
func Register(register eosc.IExtenderDriverRegister)
type AnonymousConfig
type Config
type Handlers
- func NewHandlers() *Handlers
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

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrorStructType      = errors.New("error struct type")
	ErrorNeedUpstream    = errors.New("need upstream")
	ErrorInvalidUpstream = errors.New("not upstream")
)

View Source

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 AnonymousConfig ¶

type AnonymousConfig struct {
	Type   string `json:"type" enum:"round-robin" label:"负载算法"`
	Config string `json:"config" label:"配置" description:"{ip}:{port} {weight}"`
}

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"`
	Upstream          eosc.RequireId            `` /* 144-byte string literal not displayed */
	UpstreamAnonymous *AnonymousConfig          `json:"anonymous" label:"匿名上游" switch:"upstream===''" `
	PluginConfig      map[string]*plugin.Config `json:"plugins" label:"插件"`
}

Config service_http驱动配置

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)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL