etcd

Documentation

Index

• Variables
• func ParseDSNURL(dsnURL *url.URL) (addr string, namespace string, err error)
• type Etcd
  • func New(dsnURL *url.URL) (*Etcd, error)
  • func (d *Etcd) Close() error
  • func (d *Etcd) Peers() (out []*dmesh.SearchPeer)
  • func (d *Etcd) PublishNow(peer dmesh.Peer) error
  • func (d *Etcd) PublishWithin(peer dmesh.Peer, timeout time.Duration)
  • func (d *Etcd) Start(ctx context.Context, watchServices []string) error

Variables

var DefaultGrantTTL = 5

var DefaultPeerPublishInterval = 1 * time.Second

Functions

func ParseDSNURL

func ParseDSNURL(dsnURL *url.URL) (addr string, namespace string, err error)

Types

type Etcd

type Etcd struct {
	// contains filtered or unexported fields
}

func New

func New(dsnURL *url.URL) (*Etcd, error)

DNS example: `etcd://etcd.dmesh:2379/eos-dev1` DNS example: `etcd://<etcd-host>:<etcd-port>/<etcd-namespace>`

func (*Etcd) Close

func (d *Etcd) Close() error

func (*Etcd) Peers

func (d *Etcd) Peers() (out []*dmesh.SearchPeer)

func (*Etcd) PublishNow

func (d *Etcd) PublishNow(peer dmesh.Peer) error

func (*Etcd) PublishWithin

func (d *Etcd) PublishWithin(peer dmesh.Peer, timeout time.Duration)

publishWithin 5 minutes durationToNext = 10 years I was waiting for 10 years interrupted:

you're asking for 5 minutes?
that's shorter than 10 years!
let's make the durationToNextPublish = 5 minutes

PublishWithin(5 * time.Minute)

func (*Etcd) Start

func (d *Etcd) Start(ctx context.Context, watchServices []string) error