Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var DefaultEtcdHeartBeatInterval = time.Second * 3
Functions ¶
This section is empty.
Types ¶
type ServicesManager ¶
type ServicesManager struct {
ListenAddr string
Addr string // 节点提供rpc服务的地址
// contains filtered or unexported fields
}
func New ¶
func New(listenAddr, exposeAddr string, etcdServerAddrs []string) (*ServicesManager, error)
New 创建一个服务 service:服务器名称 addr:当前节点服务对外可以访问的地址，不是监听地址，必须为"ip+:+port"格式 etcdServerAddrs:etcd服务地址
func NewWithKey ¶
func NewWithKey(key string, listenAddr, exposeAddr string, etcdServerAddrs []string) (*ServicesManager, error)
NewWithKey 创建一个带主键的服务，用于点对点通信 service:服务器名称 addr:当前节点服务对外可以访问的地址，不是监听地址，必须为"ip+:+port"格式 etcdServerAddrs:etcd服务地址
func (*ServicesManager) RegisterOneService ¶
func (m *ServicesManager) RegisterOneService(service string, handler interface{}, metaKVs map[string]string) error
RegisterOneService 注册一个服务 service：服务名 handler：回调处理
func (*ServicesManager) Run ¶
func (m *ServicesManager) Run() error
Run 启动rpc服务 addr：监听地址，可以忽略ip，例如":8888"格式 注意：register过程必须在start之前
func (*ServicesManager) Stop ¶
func (m *ServicesManager) Stop()
Source Files
Click to show internal directories.
Click to hide internal directories.