acceptor

Documentation

Index

• type AcceptorRole
  • func Construct(roleId uint64, log *replicatedlog.Log) *AcceptorRole
  • func (this *AcceptorRole) Accept(proposal *ProposalReq, reply *ProposalResp) error
  • func (this *AcceptorRole) Prepare(req *PrepareReq, reply *PrepareResp) error
  • func (this *AcceptorRole) Success(info *SuccessNotify, reply *int) error
• type PrepareReq
• type PrepareResp
• type ProposalReq
• type ProposalResp
• type SuccessNotify

Types

type AcceptorRole

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

* Acceptor Role

func Construct

func Construct(roleId uint64, log *replicatedlog.Log) *AcceptorRole

Constructor for AcceptorRole

func (*AcceptorRole) Accept

func (this *AcceptorRole) Accept(proposal *ProposalReq, reply *ProposalResp) error

func (*AcceptorRole) Prepare

func (this *AcceptorRole) Prepare(req *PrepareReq, reply *PrepareResp) error

func (*AcceptorRole) Success

func (this *AcceptorRole) Success(info *SuccessNotify, reply *int) error

type PrepareReq

type PrepareReq struct {
	ProposalId proposal.Id
	Index      int
}

Request sent out by proposer during prepare phase

type PrepareResp

type PrepareResp struct {
	PromiseAccepted    bool
	AcceptedProposalId proposal.Id
	AcceptedValue      string
	NoMoreAccepted     bool
	RoleId             uint64
}

Response sent by acceptors during prepare phase

type ProposalReq

type ProposalReq struct {
	ProposalId         proposal.Id
	Index              int
	Value              string
	FirstUnchosenIndex int
}

Request sent out by proposer during proposal phase

type ProposalResp

type ProposalResp struct {
	AcceptedId         proposal.Id
	RoleId             uint64
	FirstUnchosenIndex int
}

Response sent by acceptors during proposal phase

type SuccessNotify

type SuccessNotify struct {
	Index int
	Value string
}