eocontext

type Attrs map[string]string

type BalanceHandler interface {
	Select(ctx EoContext) (INode, error)
}

type CompleteHandler interface {
	Complete(ctx EoContext) error
}

type EoApp interface {
	Nodes() []INode
	Scheme() string
	TimeOut() time.Duration
}

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)
	GetApp() EoApp
	SetApp(app EoApp)
	GetBalance() BalanceHandler
	SetBalance(handler BalanceHandler)
	GetUpstreamHostHandler() UpstreamHostHandler
	SetUpstreamHostHandler(handler UpstreamHostHandler)

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

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

type Filters []IFilter

type FinishHandler interface {
	Finish(ctx EoContext) error
}

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

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

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

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

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

type NodeStatus int

type PassHostMod int

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