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()
Click to show internal directories.
Click to hide internal directories.