Versions in this module Expand all Collapse all v1 v1.2.0 Sep 29, 2021 v1.1.8 Sep 29, 2021 Changes in this version + var TimeToLive = timeToLive + type EtcdConf struct + Hosts []string + Key string + func (c EtcdConf) Validate() error + type Publisher struct + func NewPublisher(endpoints []string, key, value string, opts ...PublisherOption) *Publisher + func (p *Publisher) KeepAlive() error + func (p *Publisher) Pause() + func (p *Publisher) Resume() + func (p *Publisher) Stop() + type PublisherOption func(client *Publisher) + func WithId(id int64) PublisherOption + type SubOption func(opts *subOptions) + func Exclusive() SubOption + type Subscriber struct + func NewSubscriber(endpoints []string, key string, opts ...SubOption) (*Subscriber, error) + func (s *Subscriber) AddListener(listener func()) + func (s *Subscriber) Values() []string
Go to main page