mencius

Documentation

Index

• Constants
• type DelayedSkip
• type Instance
• type InstanceStatus
• type LeaderBookkeeping
• type Replica
  • func NewReplica(replica *genericsmr.Replica, id int, peerAddrList []string, thrifty bool, ...) *Replica
  • func (r *Replica) BatchingEnabled() bool
  • func (r *Replica) CloseUp()

Constants

const CHAN_BUFFER_SIZE = 200000

const FALSE = uint8(0)

const MAX_SKIPS_WAITING = 500

const NB_INST_TO_SKIP = 100000

const TRUE = uint8(1)

const WAIT_BEFORE_SKIP_MS = 250

Types

type DelayedSkip

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

type Instance

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

type InstanceStatus

type InstanceStatus int

const (
	PREPARING InstanceStatus = iota
	ACCEPTED
	READY
	COMMITTED
	EXECUTED
)

type LeaderBookkeeping

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

type Replica

type Replica struct {
	*genericsmr.Replica // extends a generic Paxos replica

	Shutdown bool
	// contains filtered or unexported fields
}

func NewReplica

func NewReplica(replica *genericsmr.Replica, id int, peerAddrList []string, thrifty bool, exec bool, lread bool, dreply bool, durable bool, failures int, storageLoc string, emulatedSS bool, emulatedWriteTime time.Duration, deadTime int32, batchwait int, skipwaitMs int, maxSkipsAwaiting int, batch bool) *Replica

func (*Replica) BatchingEnabled

func (r *Replica) BatchingEnabled() bool

func (*Replica) CloseUp

func (r *Replica) CloseUp()