Documentation ¶
Index ¶
- Constants
- func Client() *etcd.Client
- func IsKeyAlreadyExistError(err error) bool
- func IsKeyNotFoundError(err error) bool
- func Register(service string, host *Host, stop chan bool) (chan struct{}, error)
- func Subscribe(service string) (<-chan *etcd.Response, <-chan *etcd.EtcdError)
- func SubscribeDown(service string) (<-chan string, <-chan *etcd.EtcdError)
- func SubscribeNew(service string) (<-chan *Host, <-chan *etcd.EtcdError)
- func SubscribeUpdate(service string) (<-chan *Host, <-chan *etcd.EtcdError)
- type Host
- type Ports
Constants ¶
View Source
const (
HEARTBEAT_DURATION = 5
)
Variables ¶
This section is empty.
Functions ¶
func IsKeyAlreadyExistError ¶
func IsKeyNotFoundError ¶
Types ¶
Source Files ¶
Click to show internal directories.
Click to hide internal directories.