discovery

Documentation

Index

• Constants
• Variables
• type Client
  • func NewClient(hostAddr, namespace string) *Client
  • func (c *Client) Close()
  • func (c *Client) DelKey(ctx context.Context, name string) error
  • func (c *Client) GetLeaseTTL(ctx context.Context, leaseId int64) (int, error)
  • func (c *Client) GetNode(ctx context.Context, name string) (Node, error)
  • func (c *Client) GrantLease(ctx context.Context, ttl int) (int64, error)
  • func (c *Client) Init() error
  • func (c *Client) IsClosing() bool
  • func (c *Client) IsNodeExist(ctx context.Context, name string) (bool, error)
  • func (c *Client) KeepAlive(ctx context.Context, leaseId int64) (chan struct{}, error)
  • func (c *Client) ListDir(ctx context.Context, dir string) ([]Node, error)
  • func (c *Client) PutNode(ctx context.Context, name string, value interface{}, leaseId int64) error
  • func (c *Client) RegisterAndKeepAliveForever(ctx context.Context, name string, value interface{}, ttl int) error
  • func (c *Client) RegisterNode(rootCtx context.Context, name string, value interface{}, ttl int) (int64, error)
  • func (c *Client) RevokeLease(ctx context.Context, leaseId int64) error
  • func (c *Client) SetVerbose(v int32)
  • func (c *Client) WatchDir(ctx context.Context, dir string) <-chan *NodeEvent
  • func (c *Client) WatchDirTo(ctx context.Context, dir string, nodeMap *NodeMap)
• type INode
• type Node
  • func NewNode(nodeType string, id uint16) Node
  • func (n Node) Get(key string) interface{}
  • func (n Node) GetInt(key string) int
  • func (n Node) GetStr(key string) string
  • func (n Node) ID() uint16
  • func (n Node) Interface() string
  • func (n Node) Set(key string, val interface{})
  • func (n Node) String() string
  • func (n Node) Type() string
• type NodeEvent
• type NodeEventType
  • func (e NodeEventType) String() string
• type NodeMap
  • func NewNodeMap() *NodeMap
  • func (m *NodeMap) Clear()
  • func (m *NodeMap) Count() int
  • func (m *NodeMap) DeleteNode(nodeType string, id uint16)
  • func (m *NodeMap) DeleteNodes(nodeType string)
  • func (m *NodeMap) GetKeys() []string
  • func (m *NodeMap) GetNodes(nodeType string) NodeSet
  • func (m *NodeMap) InsertNode(node Node)
  • func (m *NodeMap) String() string
• type NodeSet

Constants

const (
	EventChanCapacity = 1000
	OpTimeout         = 3

	VerboseLv1 = 1
	VerboseLv2 = 2
)

const (
	NODE_KEY_ID        = "ID"
	NODE_KEY_TYPE      = "Type"
	NODE_KEY_INTERFACE = "Interface"
	NODE_KEY_PID       = "PID"
	NODE_KEY_HOST      = "Host"
)

Variables

var (
	ErrEmptyLeasePointer   = errors.New("empty lease pointer")
	ErrNodeKeyAlreadyExist = errors.New("node key already exist")
	ErrNoKeyDeleted        = errors.New("no key deleted")
)

Types

type Client

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

基于etcd的服务发现

func NewClient

func NewClient(hostAddr, namespace string) *Client

func (*Client) Close

func (c *Client) Close()

func (*Client) DelKey

func (c *Client) DelKey(ctx context.Context, name string) error

删除一个key

func (*Client) GetLeaseTTL

func (c *Client) GetLeaseTTL(ctx context.Context, leaseId int64) (int, error)

func (*Client) GetNode

func (c *Client) GetNode(ctx context.Context, name string) (Node, error)

获取节点信息

func (*Client) GrantLease

func (c *Client) GrantLease(ctx context.Context, ttl int) (int64, error)

申请一个lease

func (*Client) Init

func (c *Client) Init() error

func (*Client) IsClosing

func (c *Client) IsClosing() bool

func (*Client) IsNodeExist

func (c *Client) IsNodeExist(ctx context.Context, name string) (bool, error)

节点是否存在

func (*Client) KeepAlive

func (c *Client) KeepAlive(ctx context.Context, leaseId int64) (chan struct{}, error)

lease保活，返回一个channel，当lease撤销时此channel被激活

func (*Client) ListDir

func (c *Client) ListDir(ctx context.Context, dir string) ([]Node, error)

列出目录下的所有节点

func (*Client) PutNode

func (c *Client) PutNode(ctx context.Context, name string, value interface{}, leaseId int64) error

设置节点信息

func (*Client) RegisterAndKeepAliveForever

func (c *Client) RegisterAndKeepAliveForever(ctx context.Context, name string, value interface{}, ttl int) error

注册一个节点，并永久保活

func (*Client) RegisterNode

func (c *Client) RegisterNode(rootCtx context.Context, name string, value interface{}, ttl int) (int64, error)

注册一个节点信息，并返回一个ttl秒的lease

func (*Client) RevokeLease

func (c *Client) RevokeLease(ctx context.Context, leaseId int64) error

撤销一个lease

func (*Client) SetVerbose

func (c *Client) SetVerbose(v int32)

func (*Client) WatchDir

func (c *Client) WatchDir(ctx context.Context, dir string) <-chan *NodeEvent

订阅目录下的节点变化

func (*Client) WatchDirTo

func (c *Client) WatchDirTo(ctx context.Context, dir string, nodeMap *NodeMap)

订阅目录下的所有节点变化, 并把节点变化更新到nodeMap

type INode

type INode interface {
	ID() int16
	Type() string
	Interface() string
}

type Node

type Node map[string]interface{}

一个节点信息

func NewNode

func NewNode(nodeType string, id uint16) Node

func (Node) Get

func (n Node) Get(key string) interface{}

func (Node) GetInt

func (n Node) GetInt(key string) int

func (Node) GetStr

func (n Node) GetStr(key string) string

func (Node) ID

func (n Node) ID() uint16

节点ID

func (Node) Interface

func (n Node) Interface() string

节点接口地址

func (Node) Set

func (n Node) Set(key string, val interface{})

func (Node) String

func (n Node) String() string

func (Node) Type

func (n Node) Type() string

节点类型

type NodeEvent

type NodeEvent struct {
	Type NodeEventType
	Key  string
	Node Node
}

节点事件

type NodeEventType

type NodeEventType int

const (
	EventUnknown NodeEventType = 0
	EventCreate  NodeEventType = 1
	EventUpdate  NodeEventType = 2
	EventDelete  NodeEventType = 3
)

func (NodeEventType) String

func (e NodeEventType) String() string

type NodeMap

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

按服务类型区分的节点信息

func NewNodeMap

func NewNodeMap() *NodeMap

func (*NodeMap) Clear

func (m *NodeMap) Clear()

func (*NodeMap) Count

func (m *NodeMap) Count() int

所有节点数量

func (*NodeMap) DeleteNode

func (m *NodeMap) DeleteNode(nodeType string, id uint16)

删除一个节点

func (*NodeMap) DeleteNodes

func (m *NodeMap) DeleteNodes(nodeType string)

删除某一类型的所有节点

func (*NodeMap) GetKeys

func (m *NodeMap) GetKeys() []string

func (*NodeMap) GetNodes

func (m *NodeMap) GetNodes(nodeType string) NodeSet

所有本类型的节点，不要修改返回值

func (*NodeMap) InsertNode

func (m *NodeMap) InsertNode(node Node)

添加一个节点

func (*NodeMap) String

func (m *NodeMap) String() string

type NodeSet

type NodeSet []Node

节点列表