member

Documentation

Index

• type Member
  • func NewMember(client *clientv3.Client, etcd *embed.Etcd, elector election.Elector, ...) *Member
  • func (m *Member) Client() *clientv3.Client
  • func (m *Member) ElectionLoop(ctx context.Context)
  • func (m *Member) GetEtcdLeader() uint64
  • func (m *Member) GetLeader() *metapb.Member
  • func (m *Member) GetLeadership() *election.Leadership
  • func (m *Member) ID() uint64
  • func (m *Member) IsLeader() bool
  • func (m *Member) Member() *metapb.Member
  • func (m *Member) MemberInfo(name, addr string)
  • func (m *Member) MemberValue() string
  • func (m *Member) Stop()

Types

type Member

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

Member is used for the election related logic.

func NewMember

func NewMember(client *clientv3.Client, etcd *embed.Etcd, elector election.Elector, candidate bool, becomeLeaderFunc, becomeFollowerFunc func() error) *Member

NewMember create a new Member.

func (*Member) Client

func (m *Member) Client() *clientv3.Client

Client etcd client

func (*Member) ElectionLoop

func (m *Member) ElectionLoop(ctx context.Context)

ElectionLoop start leader election loop

func (*Member) GetEtcdLeader

func (m *Member) GetEtcdLeader() uint64

GetEtcdLeader returns the etcd leader ID.

func (*Member) GetLeader

func (m *Member) GetLeader() *metapb.Member

GetLeader returns current PD leader of PD cluster.

func (*Member) GetLeadership

func (m *Member) GetLeadership() *election.Leadership

GetLeadership returns the leadership of the prophet member.

func (*Member) ID

func (m *Member) ID() uint64

ID returns the unique etcd ID for this server in etcd cluster.

func (*Member) IsLeader

func (m *Member) IsLeader() bool

IsLeader returns whether the server is prophet leader or not by checking its leadership's lease and leader info.

func (*Member) Member

func (m *Member) Member() *metapb.Member

Member returns the member.

func (*Member) MemberInfo

func (m *Member) MemberInfo(name, addr string)

MemberInfo initializes the member info.

func (*Member) MemberValue

func (m *Member) MemberValue() string

MemberValue returns the member value.

func (*Member) Stop

func (m *Member) Stop()

Stop loop