leaderetcd

Documentation

Overview

Package leaderetcd provides a etcd driver for package leader

Index

• type EtcdDriver
  • func NewEtcdDriver(client *clientv3.Client, keyer contract.Keyer) *EtcdDriver
  • func (e *EtcdDriver) Campaign(ctx context.Context) error
  • func (e *EtcdDriver) Resign(ctx context.Context) error

Types

type EtcdDriver

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

EtcdDriver implements the Driver. It is used for leader election.

func NewEtcdDriver

func NewEtcdDriver(client *clientv3.Client, keyer contract.Keyer) *EtcdDriver

NewEtcdDriver returns a newly constructed *EtcdDriver

func (*EtcdDriver) Campaign

func (e *EtcdDriver) Campaign(ctx context.Context) error

Campaign starts the leader election using ETCD. It will bock until this node becomes leader or the context is expired.

func (*EtcdDriver) Resign

func (e *EtcdDriver) Resign(ctx context.Context) error

Resign gives up the leadership using ETCD. If the current node is not a leader, this is a no op.