manager

package
v0.14.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 27, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrorTimeoutComplete = errors.New("complete timeout")
)

Functions

func Dubbo2ErrorResult

func Dubbo2ErrorResult(err error) protocol.RPCResult

func NewManager

func NewManager() *dubboManger

Types

type AppendRule

type AppendRule = router.AppendRule

type Complete

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

func NewComplete

func NewComplete(retry int, timeOut time.Duration) *Complete

func (*Complete) Complete

func (h *Complete) Complete(org eocontext.EoContext) error

type CompleteCaller

type CompleteCaller struct {
}

func NewCompleteCaller

func NewCompleteCaller() *CompleteCaller

func (*CompleteCaller) Destroy

func (h *CompleteCaller) Destroy()

func (*CompleteCaller) DoFilter

func (h *CompleteCaller) DoFilter(ctx eocontext.EoContext, next eocontext.IChain) (err error)

type ErrHandler

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

func NewErrHandler

func NewErrHandler(err error) *ErrHandler

func (*ErrHandler) Complete

func (e *ErrHandler) Complete(ctx eoscContext.EoContext) error

func (*ErrHandler) Finish

func (e *ErrHandler) Finish(ctx eoscContext.EoContext) error

type IManger

type IManger interface {
	Set(id string, port int, serviceName, methodName string, rule []AppendRule, handler router.IRouterHandler) error
	Delete(id string)
}

type IRouterData

type IRouterData interface {
	Set(id string, port int, service string, method string, append []AppendRule, router router.IRouterHandler) IRouterData
	Delete(id string) IRouterData
	Parse() (router.IMatcher, error)
}

type Router

type Router struct {
	Id      string
	Port    int
	Service string
	Method  string
	Appends []AppendRule
	Router  router.IRouterHandler
}

type RouterData

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

func (*RouterData) Delete

func (rs *RouterData) Delete(id string) IRouterData

func (*RouterData) Parse

func (rs *RouterData) Parse() (router.IMatcher, error)

func (*RouterData) Set

func (rs *RouterData) Set(id string, port int, service string, method string, append []AppendRule, router router.IRouterHandler) IRouterData

Jump to

Keyboard shortcuts

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