manager

package
v0.12.2 Latest Latest
Warning

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

Go to latest
Published: Mar 9, 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

This section is empty.

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 eocontext.EoContext) error

func (*ErrHandler) Finish

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

type IManger

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

type IRouterData

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

type Manager

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

func NewManager

func NewManager() *Manager

NewManager 创建路由管理器

func (*Manager) Delete

func (m *Manager) Delete(id string)

func (*Manager) FastHandler

func (m *Manager) FastHandler(port int, srv interface{}, stream grpc.ServerStream) error

func (*Manager) Set

func (m *Manager) Set(id string, port int, hosts []string, service string, method string, append []AppendRule, router router.IRouterHandler) error

func (*Manager) SetGlobalFilters

func (m *Manager) SetGlobalFilters(globalFilters *eocontext.IChainPro)

type Router

type Router struct {
	Id         string
	Port       int
	Hosts      []string
	Service    string
	Method     string
	Appends    []AppendRule
	GrpcRouter 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, hosts []string, 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