paxos

Documentation

Index

• Constants
• type Instance
• type InstanceStatus
• type LeaderBookkeeping
• type ReadStats
  • func NewReadStats(N int, leaderId int32) *ReadStats
  • func (rs *ReadStats) AddRead(key state.Key, replicaId int32)
  • func (rs *ReadStats) GetQuorums() []qleaseproto.LeaseMetadata
• type Replica
  • func NewReplica(id int, peerAddrList []string, thrifty bool, exec bool, dreply bool, ...) *Replica
  • func (r *Replica) BeTheLeader(args *genericsmrproto.BeTheLeaderArgs, reply *genericsmrproto.BeTheLeaderReply) error

Constants

const CHAN_BUFFER_SIZE = 500000

const FALSE = uint8(0)

const GRACE_PERIOD = 5 * 1e9

const HT_INIT_SIZE = 150000

const MAX_BATCH = 1

const READ_CHAN_SIZE = 1100000

const TICKS_TO_RECONF_LEASE = 20

var hackflag int = 2

const TRUE = uint8(1)

Types

type Instance

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

type InstanceStatus

type InstanceStatus int8

const (
	NONE InstanceStatus = iota
	PREPARING
	PREPARED
	ACCEPTED
	COMMITTED
)

type LeaderBookkeeping

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

type ReadStats

type ReadStats struct {
	N int
	// contains filtered or unexported fields
}

func NewReadStats

func NewReadStats(N int, leaderId int32) *ReadStats

func (*ReadStats) AddRead

func (rs *ReadStats) AddRead(key state.Key, replicaId int32)

func (*ReadStats) GetQuorums

func (rs *ReadStats) GetQuorums() []qleaseproto.LeaseMetadata

type Replica

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

	IsLeader bool // does this replica think it is the leader

	Shutdown bool
	// contains filtered or unexported fields
}

func NewReplica

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

func (*Replica) BeTheLeader

func (r *Replica) BeTheLeader(args *genericsmrproto.BeTheLeaderArgs, reply *genericsmrproto.BeTheLeaderReply) error