eocontext

Documentation

Index

• Variables
• func DoChain(ctx EoContext, orgfilter Filters, append ...IFilter) error
• type Attrs
• type BalanceHandler
• type CompleteHandler
• type EoApp
• type EoContext
• type Filters
  • func (fs Filters) Destroy()
  • func (fs Filters) DoChain(ctx EoContext) error
• type FinishHandler
• type IAttributes
• type IChain
• type IChainPro
• type IFilter
  • func ToFilter(chain IChain) IFilter
• type INode
• type NodeStatus
• type PassHostMod
• type UpstreamHostHandler

Variables

var ErrEoCtxUnCloneable = errors.New("EoContext is UnCloneable. ")

var (
	FilterSkillName = config.TypeNameOf((*IFilter)(nil))
)

Functions

func DoChain

func DoChain(ctx EoContext, orgfilter Filters, append ...IFilter) error

Types

type Attrs

type Attrs map[string]string

Attrs 属性集合

type BalanceHandler

type BalanceHandler interface {
	Select(ctx EoContext) (INode, int, error)
	Scheme() string
	TimeOut() time.Duration
	EoApp
}

type CompleteHandler

type CompleteHandler interface {
	Complete(ctx EoContext) error
}

type EoApp

type EoApp interface {
	Nodes() []INode
}

type EoContext

type EoContext interface {
	RequestId() string
	AcceptTime() time.Time
	Context() context.Context
	Value(key interface{}) interface{}
	WithValue(key, val interface{})

	Scheme() string
	Assert(i interface{}) error

	SetLabel(name, value string)
	GetLabel(name string) string
	Labels() map[string]string

	GetComplete() CompleteHandler
	SetCompleteHandler(handler CompleteHandler)
	GetFinish() FinishHandler
	SetFinish(handler FinishHandler)
	GetBalance() BalanceHandler
	SetBalance(handler BalanceHandler)
	GetUpstreamHostHandler() UpstreamHostHandler
	SetUpstreamHostHandler(handler UpstreamHostHandler)

	RealIP() string
	LocalIP() net.IP
	LocalAddr() net.Addr
	LocalPort() int

	IsCloneable() bool
	Clone() (EoContext, error)
}

type Filters

type Filters []IFilter

func (Filters) Destroy

func (fs Filters) Destroy()

func (Filters) DoChain

func (fs Filters) DoChain(ctx EoContext) error

type FinishHandler

type FinishHandler interface {
	Finish(ctx EoContext) error
}

type IAttributes

type IAttributes interface {
	GetAttrs() Attrs
	GetAttrByName(name string) (string, bool)
}

IAttributes 属性接口

type IChain

type IChain interface {
	DoChain(ctx EoContext) error
	Destroy()
}

type IChainPro

type IChainPro interface {
	Destroy()
	Chain(ctx EoContext, append ...IFilter) error
}

type IFilter

type IFilter interface {
	DoFilter(ctx EoContext, next IChain) (err error)
	Destroy()
}

func ToFilter

func ToFilter(chain IChain) IFilter

type INode

type INode interface {
	IAttributes
	ID() string
	IP() string
	Port() int
	Addr() string
	Status() NodeStatus
	Up()
	Down()
	Leave()
}

INode 节点接口

type NodeStatus

type NodeStatus int

NodeStatus 节点状态类型

const (
	//Running 节点运行中状态
	Running NodeStatus = 1
	//Down 节点不可用状态
	Down NodeStatus = 2
	//Leave 节点离开状态
	Leave NodeStatus = 3
)

type PassHostMod

type PassHostMod int

const (
	PassHost PassHostMod = iota
	NodeHost
	ReWriteHost
)

type UpstreamHostHandler

type UpstreamHostHandler interface {
	PassHost() (PassHostMod, string)
}