lpaxos

Documentation

Index

• Constants
• type Instance
• type InstanceStatus
• type LeaderBookkeeping
• type Replica
  • func NewReplica(id int, peerAddrList []string, thrifty bool, exec bool, dreply bool, ...) *Replica
  • func (r *Replica) BeTheLeader()
  • func (r *Replica) ProposeLeaseChange(updates []qleaseproto.LeaseMetadata) bool

Constants

const CHAN_BUFFER_SIZE = 2000

const FALSE = uint8(0)

const MAX_BATCH = 5000

const TRUE = uint8(1)

Types

type Instance

type Instance struct {
	Updates []qleaseproto.LeaseMetadata

	Status InstanceStatus
	// contains filtered or unexported fields
}

type InstanceStatus

type InstanceStatus int

const (
	PREPARING InstanceStatus = iota
	PREPARED
	ACCEPTED
	COMMITTED
)

type LeaderBookkeeping

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

type Replica

type Replica struct {
	*genericsmr.Replica // extends a generic Paxos replica
	ProposeLeaseChan    chan fastrpc.Serializable

	IsLeader      bool        // does this replica think it is the leader
	InstanceSpace []*Instance // the space of all instances (used and not yet used)

	Shutdown bool

	LeaderId        int32
	LatestCommitted int32
	// contains filtered or unexported fields
}

func NewReplica

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

func (*Replica) BeTheLeader

func (r *Replica) BeTheLeader()

func (*Replica) ProposeLeaseChange

func (r *Replica) ProposeLeaseChange(updates []qleaseproto.LeaseMetadata) bool