service

Documentation

Index

• Variables
• func Create(id, name string, v *Config, workers map[eosc.RequireId]eosc.IWorker) (eosc.IWorker, error)
• func NewFactory() eosc.IExtenderDriverFactory
• func Register(register eosc.IExtenderDriverRegister)
• type Config
  • func (c *Config) String() string
• type Service
  • func (s *Service) Nodes() []eocontext.INode
  • func (s *Service) PassHost() (eocontext.PassHostMod, string)
  • func (s *Service) Reset(conf interface{}, workers map[eosc.RequireId]eosc.IWorker) error
  • func (s *Service) Scheme() string
  • func (s *Service) TimeOut() time.Duration

Variables

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

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

var DriverName = "service_http"

Functions

func Create

func Create(id, name string, v *Config, workers map[eosc.RequireId]eosc.IWorker) (eosc.IWorker, error)

Create 创建service_http驱动的实例

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:"负载均衡算法"`
	PassHost     string         `` /* 251-byte string literal not displayed */
	UpstreamHost string         `` /* 163-byte string literal not displayed */
}

Config service_http驱动配置

func (*Config) String

func (c *Config) String() string

type Service

type Service struct {
	eocontext.BalanceHandler
	// contains filtered or unexported fields
}

func (*Service) Nodes

func (s *Service) Nodes() []eocontext.INode

func (*Service) PassHost

func (s *Service) PassHost() (eocontext.PassHostMod, string)

func (*Service) Reset

func (s *Service) Reset(conf interface{}, workers map[eosc.RequireId]eosc.IWorker) error

Reset 重置服务实例的配置

func (*Service) Scheme

func (s *Service) Scheme() string

func (*Service) TimeOut

func (s *Service) TimeOut() time.Duration