locator

Documentation

Index

• type RpcLocator
  • func NewRpcLocator(ctx context.Context, term raftterm.RaftTerm, raftMember raftmember.RaftMember, ...) RpcLocator
• type ServiceLocator
  • func NewServiceLocator(context context.Context, config rconfig.Config) ServiceLocator

Types

type RpcLocator

type RpcLocator interface {
	GetAppendEntrySvc() raftrpc.RaftRpc
	GetRequestVoteSvc() raftrpc.RaftRpc
	GetClientCommandSvc() raftrpc.RaftRpc
}

func NewRpcLocator

func NewRpcLocator(
	ctx context.Context,
	term raftterm.RaftTerm,
	raftMember raftmember.RaftMember,
	raftIndex *raftstate.RaftIndex,
	raftLog raftlog.RaftLog,
	raftSender raftsender.RequestSender) RpcLocator

type ServiceLocator

type ServiceLocator interface {
	GetRpcLocator() RpcLocator
	GetRaftState() raftstate.RaftState
	GetRaftTerm() raftterm.RaftTerm
	GetRaftTimer() rafttimer.RaftTimer
	GetRaftVoter() raftvoter.RaftVoter
	GetRaftMember() raftmember.RaftMember
	GetRaftHeartbeat() raftheartbeat.RaftHeartbeat
	GetRaftRequestSender() raftsender.RequestSender
}

func NewServiceLocator

func NewServiceLocator(context context.Context, config rconfig.Config) ServiceLocator