yatch

Documentation

Index

• Constants
• type Exec
  • func (e *Exec) ExecuteCommand(replica int32, round int32) bool
• type LeaderBookkeeping
• type Log
• type RecievedMessage
• type Replica
  • func NewReplica(id int, peerAddrList []string, thrifty bool, exec bool, dreply bool, ...) *Replica
  • func (r *Replica) ExecuteCommand(replica int32, round int32) bool
  • func (r *Replica) ProposeCommand(q int, round int32, value int32)
  • func (r *Replica) ProposeCommands(round int32, value int32, cmds []state.Command, bookkeeping *LeaderBookkeeping)

Constants

const ADAPT_TIME_SEC = 10

const DS = 3

const FALSE = uint8(0)

const MAX_BATCH = 1000

const MAX_DEPTH_DEP = 10

const TRUE = uint8(1)

Types

type Exec

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

func (*Exec) ExecuteCommand

func (e *Exec) ExecuteCommand(replica int32, round int32) bool

type LeaderBookkeeping

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

type Log

type Log struct {
	Status     int8
	LengthCmds int32
	Cmds       []state.Command
	Value      int32
	// contains filtered or unexported fields
}

type RecievedMessage

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

type Replica

type Replica struct {
	*genericsmr.Replica

	CommittedIndex int32   // highest committed instance per replica that this replica knows about
	ExecedUpTo     []int32 // instance up to which all commands have been executed (including itself)
	// contains filtered or unexported fields
}

func NewReplica

func NewReplica(id int, peerAddrList []string, thrifty bool, exec bool, dreply bool, beacon bool, durable bool) *Replica

func (*Replica) ExecuteCommand

func (r *Replica) ExecuteCommand(replica int32, round int32) bool

func (*Replica) ProposeCommand

func (r *Replica) ProposeCommand(q int, round int32, value int32)

func (*Replica) ProposeCommands

func (r *Replica) ProposeCommands(round int32, value int32, cmds []state.Command, bookkeeping *LeaderBookkeeping)