viewmanager

package
v0.0.0-...-fea0aa2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 8, 2020 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Init

func Init(rs *rpc.Server)

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 GetImpl

func GetImpl() *Impl

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) MonitorActivity

func (impl *Impl) MonitorActivity()

func (*Impl) ProcessDoViewChangeRequests

func (impl *Impl) ProcessDoViewChangeRequests()

func (*Impl) RequestViewChange

func (impl *Impl) RequestViewChange(view int)

func (*Impl) SendDoViewChangeRequest

func (impl *Impl) SendDoViewChangeRequest()

func (*Impl) SendPrepareMessages

func (impl *Impl) SendPrepareMessages(clientId string, requestId int, op log2.Operation)

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 LockingRequests struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type StartViewChangeRequest

type StartViewChangeRequest struct {
	ReplicaId int
	View      int
	DestId    int
}

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL