discovery

Documentation

Index

• Constants
• Variables
• func CheckSkill(skill string) bool
• func NewNode(INode INode, label Attrs) eocontext.INode
• type Attrs
• type IApp
• type IAppAgent
• type IAppContainer
  • func NewAppContainer() IAppContainer
• type IDiscovery
• type IHealthChecker
• type INode
• type INodes
• type Node
  • func (n *Node) GetAttrByName(name string) (string, bool)
  • func (n *Node) GetAttrs() eocontext.Attrs
• type NodeInfo
• type NodeStatus

Constants

const (
	//Running 节点运行中状态
	Running = eocontext.Running
	//Down 节点不可用状态
	Down = eocontext.Down
	//Leave 节点离开状态
	Leave = eocontext.Leave
)

Variables

var (
	ErrDiscoveryDown = errors.New("discovery down")
)

Functions

func CheckSkill

func CheckSkill(skill string) bool

CheckSkill 检查目标技能是否符合

func NewNode

func NewNode(INode INode, label Attrs) eocontext.INode

Types

type Attrs

type Attrs = eocontext.Attrs

Attrs 属性集合

type IApp

type IApp interface {
	Nodes() []eocontext.INode
	Close()
}

type IAppAgent

type IAppAgent interface {
	Agent() IApp
	// contains filtered or unexported methods
}

type IAppContainer

type IAppContainer interface {
	INodes
	Set(id string, info []NodeInfo) (app IAppAgent)
	Reset(info map[string][]NodeInfo)
	GetApp(id string) (IAppAgent, bool)
	Keys() []string
}

func NewAppContainer

func NewAppContainer() IAppContainer

type IDiscovery

type IDiscovery interface {
	GetApp(config string) (IApp, error)
}

IDiscovery 服务发现接口

type IHealthChecker

type IHealthChecker interface {
	Check(nodes INodes)
	Reset(conf interface{}) error
	Stop()
}

IHealthChecker 健康检查接口

type INode

type INode interface {
	IP() string
	ID() string
	Addr() string
	Port() int
	Status() NodeStatus
	Last() time.Time
	Up()
	Down()
	Leave()
}

type INodes

type INodes interface {
	Get(ip string, port int) INode
	All() []INode
	SetHealthCheck(isHealthCheck bool)
}

type Node

type Node struct {
	INode
	// contains filtered or unexported fields
}

func (*Node) GetAttrByName

func (n *Node) GetAttrByName(name string) (string, bool)

func (*Node) GetAttrs

func (n *Node) GetAttrs() eocontext.Attrs

type NodeInfo

type NodeInfo struct {
	Ip     string
	Port   int
	Labels map[string]string
}

type NodeStatus

type NodeStatus = eocontext.NodeStatus

NodeStatus 节点状态类型