Documentation ¶
Index ¶
- func Init()
- type Impl
- func (impl *Impl) AppendOp(req *common.ClientRequest, opId int) log2.Operation
- func (impl *Impl) PrepareOk(req *viewreplication.PrepareOkRequest, res *clientrpc.EmptyResponse) error
- func (impl *Impl) ProcessClientRequests()
- func (impl *Impl) Request(req *common.ClientRequest, res *clientrpc.EmptyResponse) error
- func (impl *Impl) UpdateClientState(req *common.ClientRequest) *viewreplication.OpResponse
- type Page
- type Service
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Impl ¶
type Impl struct { *viewmanager.Impl WorkQueue chan *common.ClientRequest }
func (*Impl) PrepareOk ¶
func (impl *Impl) PrepareOk(req *viewreplication.PrepareOkRequest, res *clientrpc.EmptyResponse) error
func (*Impl) ProcessClientRequests ¶
func (impl *Impl) ProcessClientRequests()
func (*Impl) Request ¶
func (impl *Impl) Request(req *common.ClientRequest, res *clientrpc.EmptyResponse) error
func (*Impl) UpdateClientState ¶
func (impl *Impl) UpdateClientState(req *common.ClientRequest) *viewreplication.OpResponse
type Service ¶
type Service interface {
Request(req *common.ClientRequest, res *common.ClientReply) error
}
Click to show internal directories.
Click to hide internal directories.