etcd

Documentation

Index

• type Cluster
  • func NewCluster(client *v3.Client, root string, ttl time.Duration) *Cluster
  • func (c *Cluster) Close()
  • func (c *Cluster) CreateMembership() (cluster.Membership, error)
  • func (c *Cluster) GetMembers(_ context.Context) ([]cluster.Member, error)
  • func (c *Cluster) WatchMembers(ctx context.Context) <-chan []cluster.Member
• type Membership
  • func (m *Membership) Data() string
  • func (m *Membership) Deregister(ctx context.Context) error
  • func (m *Membership) ID() string
  • func (m *Membership) Register(ctx context.Context) error
  • func (m *Membership) SetData(data string) error

Types

type Cluster

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

func NewCluster

func NewCluster(client *v3.Client, root string, ttl time.Duration) *Cluster

func (*Cluster) Close

func (c *Cluster) Close()

func (*Cluster) CreateMembership

func (c *Cluster) CreateMembership() (cluster.Membership, error)

func (*Cluster) GetMembers

func (c *Cluster) GetMembers(_ context.Context) ([]cluster.Member, error)

func (*Cluster) WatchMembers

func (c *Cluster) WatchMembers(ctx context.Context) <-chan []cluster.Member

type Membership

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

func (*Membership) Data

func (m *Membership) Data() string

func (*Membership) Deregister

func (m *Membership) Deregister(ctx context.Context) error

func (*Membership) ID

func (m *Membership) ID() string

func (*Membership) Register

func (m *Membership) Register(ctx context.Context) error

func (*Membership) SetData

func (m *Membership) SetData(data string) error