Versions in this module Expand all Collapse all v0 v0.0.1 Aug 3, 2024 Changes in this version + var TimeToLive = timeToLive + func RegisterAccount(endpoints []string, user, pass string) + func RegisterTLS(endpoints []string, certFile, certKeyFile, caFile string, ...) error + type EtcdConf struct + CACertFile string + CertFile string + CertKeyFile string + Hosts []string + ID int64 + InsecureSkipVerify bool + Key string + Pass string + User string + func (c EtcdConf) HasAccount() bool + func (c EtcdConf) HasID() bool + func (c EtcdConf) HasTLS() bool + func (c EtcdConf) Validate() error + type PubOption func(client *Publisher) + func WithId(id int64) PubOption + func WithPubEtcdAccount(user, pass string) PubOption + func WithPubEtcdTLS(certFile, certKeyFile, caFile string, insecureSkipVerify bool) PubOption + type Publisher struct + func NewPublisher(endpoints []string, key, value string, opts ...PubOption) *Publisher + func (p *Publisher) KeepAlive() error + func (p *Publisher) Pause() + func (p *Publisher) Resume() + func (p *Publisher) Stop() + type SubOption func(sub *Subscriber) + func Exclusive() SubOption + func WithSubEtcdAccount(user, pass string) SubOption + func WithSubEtcdTLS(certFile, certKeyFile, caFile string, insecureSkipVerify bool) 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