acceptor

Documentation

Index

• func BetterBatchingAcceptorNew(file stablestore.StableStore, durable bool, emulatedSS bool, ...) *betterBatching
• func PrewritePromiseAcceptorNew(file stablestore.StableStore, durable bool, emulatedSS bool, ...) *prewritePromiseAcceptor
• func PrewriterNew(promiseLeasesRet chan PromiseLease, iWriteAhead int32, ...) *prewriter
• func StandardAcceptorNew(file stablestore.StableStore, durable bool, emulatedSS bool, ...) *standard
• type Acceptor
• type AcceptorBookkeeping
• type ConfigAcceptor
• type ConfigHolder
• type InstanceStatus
• type LWCAcceptorBookkeeping
• type Message
• type PrewritePromiseBatchingAcceptor
  • func PrewrittenBatcherAcceptorNew(file stablestore.StableStore, durable bool, emulatedSS bool, ...) *PrewritePromiseBatchingAcceptor
  • func (a *PrewritePromiseBatchingAcceptor) RecvAcceptRemote(accept *stdpaxosproto.Accept) <-chan Message
  • func (a *PrewritePromiseBatchingAcceptor) RecvCommitRemote(commit *stdpaxosproto.Commit) <-chan struct{}
  • func (a *PrewritePromiseBatchingAcceptor) RecvCommitShortRemote(commit *stdpaxosproto.CommitShort) <-chan struct{}
  • func (a *PrewritePromiseBatchingAcceptor) RecvPrepareRemote(prepare *stdpaxosproto.Prepare) <-chan Message
• type PromiseLease
  • func (p PromiseLease) Marshal(wire io.Writer)
  • func (p *PromiseLease) New() fastrpc.Serializable
  • func (p PromiseLease) Unmarshal(rr io.Reader) error

Functions

func BetterBatchingAcceptorNew

func BetterBatchingAcceptorNew(file stablestore.StableStore, durable bool, emulatedSS bool, emulatedWriteTime time.Duration, id int32, maxBatchWait time.Duration, proposerIDs []int32, prepareReplyRPC uint8, acceptReplyRPC uint8, commitRPC uint8, commitShortRPC uint8, catchupOnProceedingCommits bool) *betterBatching

func PrewritePromiseAcceptorNew

func PrewritePromiseAcceptorNew(file stablestore.StableStore, durable bool, emulatedSS bool, emulatedWriteTime time.Duration, id int32, prepareReplyRPC uint8, acceptReplyRPC uint8, commitRPC uint8, commitShortRPC uint8, catchupOnProceedingCommits bool, promiseLeasesRet chan PromiseLease, iWriteAhead int32, proactivePreemptOnNewB bool, disklessnoops bool) *prewritePromiseAcceptor

func PrewriterNew

func PrewriterNew(promiseLeasesRet chan PromiseLease, iWriteAhead int32, stableStore stablestore.StableStore) *prewriter

func StandardAcceptorNew

func StandardAcceptorNew(file stablestore.StableStore, durable bool, emulatedSS bool, emulatedWriteTime time.Duration, id int32, prepareReplyRPC uint8, acceptReplyRPC uint8, commitRPC uint8, commitShortRPC uint8, catchupOnProceedingCommits bool) *standard

Types

type Acceptor

type Acceptor interface {
	//RecvPrepareLocal(prepare *stdpaxosproto.Prepare) <-chan bool // bool
	RecvPrepareRemote(prepare *stdpaxosproto.Prepare) <-chan Message
	//	RecvAcceptLocal(accept *stdpaxosproto.Accept) <-chan bool
	RecvAcceptRemote(accept *stdpaxosproto.Accept) <-chan Message
	//	RecvCommitLocal(commit *stdpaxosproto.Commit) <-chan struct{}           // bool
	RecvCommitRemote(commit *stdpaxosproto.Commit) <-chan struct{} // bool
	//	RecvCommitShortLocal(short *stdpaxosproto.CommitShort) <-chan struct{}  // bool
	RecvCommitShortRemote(short *stdpaxosproto.CommitShort) <-chan struct{} // bool
}

type AcceptorBookkeeping

type AcceptorBookkeeping struct {
	// contains filtered or unexported fields
}

type ConfigAcceptor

type ConfigAcceptor interface {
	RecvPrepareRemote(prepare *lwcproto.Prepare) <-chan Message
	RecvAcceptRemote(accept *lwcproto.Accept) <-chan Message
	RecvCommitRemote(commit *lwcproto.Commit) <-chan struct{}          // bool
	RecvCommitShortRemote(short *lwcproto.CommitShort) <-chan struct{} // bool
}

type ConfigHolder

type ConfigHolder interface {
	// contains filtered or unexported methods
}

type InstanceStatus

type InstanceStatus int

const (
	NOT_STARTED InstanceStatus = iota
	PREPARED
	ACCEPTED
	COMMITTED
)

type LWCAcceptorBookkeeping

type LWCAcceptorBookkeeping struct {
	AcceptorBookkeeping
	// contains filtered or unexported fields
}

type Message

type Message interface {
	ToWhom() int32
	GetType() uint8
	IsNegative() bool
	GetSerialisable() fastrpc.Serializable
	fastrpc.Serializable
}

type PrewritePromiseBatchingAcceptor

type PrewritePromiseBatchingAcceptor struct {
	ProposerIDs []int32
	// contains filtered or unexported fields
}

func PrewrittenBatcherAcceptorNew

func PrewrittenBatcherAcceptorNew(file stablestore.StableStore, durable bool, emulatedSS bool, emulatedWriteTime time.Duration, id int32, maxBatchWait time.Duration, proposerIDs []int32, prepareReplyRPC uint8, acceptReplyRPC uint8, commitRPC uint8, commitShortRPC uint8, catchupOnProceedingCommits bool, promiseLeasesRet chan PromiseLease, iWriteAhead int32) *PrewritePromiseBatchingAcceptor

func (*PrewritePromiseBatchingAcceptor) RecvAcceptRemote

func (a *PrewritePromiseBatchingAcceptor) RecvAcceptRemote(accept *stdpaxosproto.Accept) <-chan Message

func (*PrewritePromiseBatchingAcceptor) RecvCommitRemote

func (a *PrewritePromiseBatchingAcceptor) RecvCommitRemote(commit *stdpaxosproto.Commit) <-chan struct{}

func (*PrewritePromiseBatchingAcceptor) RecvCommitShortRemote

func (a *PrewritePromiseBatchingAcceptor) RecvCommitShortRemote(commit *stdpaxosproto.CommitShort) <-chan struct{}

func (*PrewritePromiseBatchingAcceptor) RecvPrepareRemote

func (a *PrewritePromiseBatchingAcceptor) RecvPrepareRemote(prepare *stdpaxosproto.Prepare) <-chan Message

type PromiseLease

type PromiseLease struct {
	From           int32 // inclusive
	MaxBalPromises stdpaxosproto.Ballot
}

func (PromiseLease) Marshal

func (p PromiseLease) Marshal(wire io.Writer)

func (*PromiseLease) New

func (p *PromiseLease) New() fastrpc.Serializable

func (PromiseLease) Unmarshal

func (p PromiseLease) Unmarshal(rr io.Reader) error