Documentation ¶
Index ¶
- func Init(rs *rpc.Server)
- type DoViewChangeRequest
- type Impl
- func (impl *Impl) AdvanceView()
- func (impl *Impl) DoViewChange(req *DoViewChangeRequest, res *clientrpc.EmptyResponse) error
- func (impl *Impl) GetState(req *viewreplication.GetStateRequest, res *viewreplication.NewStateResponse) error
- func (impl *Impl) MonitorActivity()
- func (impl *Impl) ProcessDoViewChangeRequests()
- func (impl *Impl) RequestViewChange(view int)
- func (impl *Impl) SendDoViewChangeRequest()
- func (impl *Impl) SendPrepareMessages(clientId string, requestId int, op log2.Operation)
- func (impl *Impl) SendStartViewChangeRequests()
- func (impl *Impl) StartView(req *StartViewRequest, res *clientrpc.EmptyResponse) error
- func (impl *Impl) StartViewChange(req *StartViewChangeRequest, res *clientrpc.EmptyResponse) error
- func (impl *Impl) WaitForCluster()
- type LockingRequests
- type StartViewChangeRequest
- type StartViewRequest
- type ViewManager
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type DoViewChangeRequest ¶
type DoViewChangeRequest struct { View int Ops []log2.Operation LatestNormalView int OpId int CommitId int ReplicaId int DestId int }
func (*DoViewChangeRequest) LogRequest ¶
func (req *DoViewChangeRequest) LogRequest(recv bool)
type Impl ¶
type Impl struct { *viewreplication.Impl LatestNormalView int // contains filtered or unexported fields }
func (*Impl) AdvanceView ¶
func (impl *Impl) AdvanceView()
func (*Impl) DoViewChange ¶
func (impl *Impl) DoViewChange(req *DoViewChangeRequest, res *clientrpc.EmptyResponse) error
func (*Impl) GetState ¶
func (impl *Impl) GetState(req *viewreplication.GetStateRequest, res *viewreplication.NewStateResponse) error
func (*Impl) MonitorActivity ¶
func (impl *Impl) MonitorActivity()
func (*Impl) ProcessDoViewChangeRequests ¶
func (impl *Impl) ProcessDoViewChangeRequests()
func (*Impl) RequestViewChange ¶
func (*Impl) SendDoViewChangeRequest ¶
func (impl *Impl) SendDoViewChangeRequest()
func (*Impl) SendPrepareMessages ¶
func (*Impl) SendStartViewChangeRequests ¶
func (impl *Impl) SendStartViewChangeRequests()
func (*Impl) StartView ¶
func (impl *Impl) StartView(req *StartViewRequest, res *clientrpc.EmptyResponse) error
func (*Impl) StartViewChange ¶
func (impl *Impl) StartViewChange(req *StartViewChangeRequest, res *clientrpc.EmptyResponse) error
func (*Impl) WaitForCluster ¶
func (impl *Impl) WaitForCluster()
type LockingRequests ¶
type StartViewChangeRequest ¶
func (*StartViewChangeRequest) LogRequest ¶
func (s *StartViewChangeRequest) LogRequest(recv bool)
type StartViewRequest ¶
type StartViewRequest struct { View int Ops []log2.Operation OpId int CommitId int ReplicaId int DestId int }
func (*StartViewRequest) LogRequest ¶
func (s *StartViewRequest) LogRequest(recv bool)
type ViewManager ¶
type ViewManager interface { StartView(req *StartViewRequest, res *clientrpc.EmptyResponse) error StartViewChange(req *StartViewChangeRequest, res *clientrpc.EmptyResponse) error DoViewChange(req *DoViewChangeRequest, res *clientrpc.EmptyResponse) error GetState(req *viewreplication.GetStateRequest, res *viewreplication.NewStateResponse) error }
Click to show internal directories.
Click to hide internal directories.