dubbo2_router

Documentation

Index

• func Check(v *Config, workers map[eosc.RequireId]eosc.IWorker) error
• func Create(id, name string, v *Config, workers map[eosc.RequireId]eosc.IWorker) (eosc.IWorker, error)
• func Register(register eosc.IExtenderDriverRegister)
• type Config
• type DubboRouter
  • func (h *DubboRouter) CheckSkill(skill string) bool
  • func (h *DubboRouter) Destroy() error
  • func (h *DubboRouter) Id() string
  • func (h *DubboRouter) Reset(conf interface{}, workers map[eosc.RequireId]eosc.IWorker) error
  • func (h *DubboRouter) Start() error
  • func (h *DubboRouter) Stop() error
• type RouterDriverFactory
  • func NewRouterDriverFactory() *RouterDriverFactory
  • func (r *RouterDriverFactory) Create(profession string, name string, label string, desc string, ...) (eosc.IExtenderDriver, error)
• type Rule

Functions

func Check

func Check(v *Config, workers map[eosc.RequireId]eosc.IWorker) error

func Create

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

Create 创建一个http路由驱动实例

func Register

func Register(register eosc.IExtenderDriverRegister)

Register 注册grpc路由驱动工厂

Types

type Config

type Config struct {
	Listen int `json:"listen" yaml:"listen" title:"port" description:"使用端口" default:"80" label:"端口号" maximum:"65535"`

	ServiceName string         `json:"service_name" yaml:"service_name" label:"服务名"`
	MethodName  string         `json:"method_name" yaml:"method_name" label:"方法名"`
	Rules       []Rule         `json:"rules" yaml:"rules" label:"路由规则"`
	Service     eosc.RequireId `` /* 126-byte string literal not displayed */
	Template    eosc.RequireId `` /* 132-byte string literal not displayed */
	Disable     bool           `json:"disable" yaml:"disable" label:"禁用路由"`
	Plugins     plugin.Plugins `json:"plugins" yaml:"plugins" label:"插件配置"`
	Retry       int            `json:"retry" label:"重试次数" yaml:"retry"`
	TimeOut     int            `json:"time_out" label:"超时时间"`
}

type DubboRouter

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

func (*DubboRouter) CheckSkill

func (h *DubboRouter) CheckSkill(skill string) bool

func (*DubboRouter) Destroy

func (h *DubboRouter) Destroy() error

func (*DubboRouter) Id

func (h *DubboRouter) Id() string

func (*DubboRouter) Reset

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

func (*DubboRouter) Start

func (h *DubboRouter) Start() error

func (*DubboRouter) Stop

func (h *DubboRouter) Stop() error

type RouterDriverFactory

type RouterDriverFactory struct {
	eosc.IExtenderDriverFactory
}

RouterDriverFactory dubbo路由驱动工厂结构体

func NewRouterDriverFactory

func NewRouterDriverFactory() *RouterDriverFactory

NewRouterDriverFactory 创建一个http路由驱动工厂

func (*RouterDriverFactory) Create

func (r *RouterDriverFactory) Create(profession string, name string, label string, desc string, params map[string]interface{}) (eosc.IExtenderDriver, error)

Create 创建http路由驱动

type Rule

type Rule struct {
	Type  string `json:"type" yaml:"type" label:"类型" enum:"header"`
	Name  string `json:"name" yaml:"name" label:"参数名"`
	Value string `json:"value" yaml:"value" label:"值规" `
}

Rule 规则