【文件属性】：
文件名称：pipes:Nanomsg 管道使用 Etcd 进行服务发现
文件大小：9KB
文件格式：ZIP
更新时间：2021-06-03 11:27:25
Go
管道
Nanomsg 管道使用 Etcd 进行服务发现
描述
这是一个非常早期的版本，没有所有功能。 到目前为止， destination 、 group和pipe结构和成员函数已经创建。 我可能会也可能不会重组/重命名这些结构及其公共功能
destination
使用pipes.NewDestination(etcd_client, destination_name)创建目的地实例
目的地由发送者注册（ destination.Register() ），在 Etcd 中创建一个目录，“/streams/destinations/[name]”。 注册目的地后，将启动几个 goroutine：
maintainDestination()目的地maintainDestination() - 在 Etcd 中维护目的地（更新其 TTL 并重新创建目录，如果它从调用进程下删除）。
watc
【文件预览】：
pipes-master
----pipe.go(1KB)
----destination.go(6KB)
----destination()
--------main.go(1KB)
----README.md(4KB)
----group.go(7KB)
----group()
--------main.go(642B)
----main()
--------main.go(2KB)