Documentation ¶
Index ¶
- type 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()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) ElectionLoop ¶
ElectionLoop start leader election loop
func (*Member) GetEtcdLeader ¶
GetEtcdLeader returns the etcd leader ID.
func (*Member) GetLeadership ¶
func (m *Member) GetLeadership() *election.Leadership
GetLeadership returns the leadership of the prophet member.
func (*Member) IsLeader ¶
IsLeader returns whether the server is prophet leader or not by checking its leadership's lease and leader info.
func (*Member) MemberInfo ¶
MemberInfo initializes the member info.
func (*Member) MemberValue ¶
MemberValue returns the member value.
Click to show internal directories.
Click to hide internal directories.