v1

Documentation

Index

• type EtcdLeader
  • func NewEtcdLeader(endpoints []string, timeout time.Duration) (*EtcdLeader, error)
  • func (e *EtcdLeader) Close() error
  • func (e *EtcdLeader) ElectLeader(ctx context.Context) error
  • func (e *EtcdLeader) GetLeader(ctx context.Context) (string, error)
  • func (e *EtcdLeader) ResignLeadership(ctx context.Context) error

Types

type EtcdLeader

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

func NewEtcdLeader

func NewEtcdLeader(endpoints []string, timeout time.Duration) (*EtcdLeader, error)

func (*EtcdLeader) Close

func (e *EtcdLeader) Close() error

func (*EtcdLeader) ElectLeader

func (e *EtcdLeader) ElectLeader(ctx context.Context) error

func (*EtcdLeader) GetLeader

func (e *EtcdLeader) GetLeader(ctx context.Context) (string, error)

func (*EtcdLeader) ResignLeadership

func (e *EtcdLeader) ResignLeadership(ctx context.Context) error