stdpaxosproto

Documentation

Index

• type Accept
  • func (t *Accept) BinarySize() (nbytes int, sizeKnown bool)
  • func (t *Accept) Marshal(wire io.Writer)
  • func (t *Accept) New() fastrpc.Serializable
  • func (t *Accept) Unmarshal(rr io.Reader) error
• type AcceptCache
  • func NewAcceptCache() *AcceptCache
  • func (p *AcceptCache) Get() *Accept
  • func (p *AcceptCache) Put(t *Accept)
• type AcceptReply
  • func (t *AcceptReply) BinarySize() (nbytes int, sizeKnown bool)
  • func (t *AcceptReply) Marshal(wire io.Writer)
  • func (t *AcceptReply) New() fastrpc.Serializable
  • func (t *AcceptReply) Unmarshal(wire io.Reader) error
• type AcceptReplyCache
  • func NewAcceptReplyCache() *AcceptReplyCache
  • func (p *AcceptReplyCache) Get() *AcceptReply
  • func (p *AcceptReplyCache) Put(t *AcceptReply)
• type Ballot
  • func (bal Ballot) Equal(cmp Ballot) bool
  • func (bal Ballot) GreaterThan(cmp Ballot) bool
  • func (bal Ballot) IsZero() bool
• type Commit
  • func (t *Commit) BinarySize() (nbytes int, sizeKnown bool)
  • func (t *Commit) Marshal(wire io.Writer)
  • func (t *Commit) New() fastrpc.Serializable
  • func (t *Commit) Unmarshal(rr io.Reader) error
• type CommitCache
  • func NewCommitCache() *CommitCache
  • func (p *CommitCache) Get() *Commit
  • func (p *CommitCache) Put(t *Commit)
• type CommitShort
  • func (t *CommitShort) BinarySize() (nbytes int, sizeKnown bool)
  • func (t *CommitShort) Marshal(wire io.Writer)
  • func (t *CommitShort) New() fastrpc.Serializable
  • func (t *CommitShort) Unmarshal(wire io.Reader) error
• type CommitShortCache
  • func NewCommitShortCache() *CommitShortCache
  • func (p *CommitShortCache) Get() *CommitShort
  • func (p *CommitShortCache) Put(t *CommitShort)
• type Phase
• type Prepare
  • func (t *Prepare) BinarySize() (nbytes int, sizeKnown bool)
  • func (t *Prepare) Marshal(wire io.Writer)
  • func (t *Prepare) New() fastrpc.Serializable
  • func (t *Prepare) Unmarshal(wire io.Reader) error
• type PrepareCache
  • func NewPrepareCache() *PrepareCache
  • func (p *PrepareCache) Get() *Prepare
  • func (p *PrepareCache) Put(t *Prepare)
• type PrepareReply
  • func (t *PrepareReply) BinarySize() (nbytes int, sizeKnown bool)
  • func (t *PrepareReply) Marshal(wire io.Writer)
  • func (t *PrepareReply) New() fastrpc.Serializable
  • func (t *PrepareReply) Unmarshal(rr io.Reader) error
• type PrepareReplyCache
  • func NewPrepareReplyCache() *PrepareReplyCache
  • func (p *PrepareReplyCache) Get() *PrepareReply
  • func (p *PrepareReplyCache) Put(t *PrepareReply)

Types

type Accept

type Accept struct {
	LeaderId int32
	Instance int32
	Ballot
	WhoseCmd int32
	Command  []*state.Command
}

func (*Accept) BinarySize

func (t *Accept) BinarySize() (nbytes int, sizeKnown bool)

func (*Accept) Marshal

func (t *Accept) Marshal(wire io.Writer)

func (*Accept) New

func (t *Accept) New() fastrpc.Serializable

func (*Accept) Unmarshal

func (t *Accept) Unmarshal(rr io.Reader) error

type AcceptCache

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

func NewAcceptCache

func NewAcceptCache() *AcceptCache

func (*AcceptCache) Get

func (p *AcceptCache) Get() *Accept

func (*AcceptCache) Put

func (p *AcceptCache) Put(t *Accept)

type AcceptReply

type AcceptReply struct {
	Instance   int32
	AcceptorId int32
	Cur        Ballot
	Req        Ballot
	CurPhase   Phase
	WhoseCmd   int32
}

func (*AcceptReply) BinarySize

func (t *AcceptReply) BinarySize() (nbytes int, sizeKnown bool)

func (*AcceptReply) Marshal

func (t *AcceptReply) Marshal(wire io.Writer)

func (*AcceptReply) New

func (t *AcceptReply) New() fastrpc.Serializable

func (*AcceptReply) Unmarshal

func (t *AcceptReply) Unmarshal(wire io.Reader) error

type AcceptReplyCache

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

func NewAcceptReplyCache

func NewAcceptReplyCache() *AcceptReplyCache

func (*AcceptReplyCache) Get

func (p *AcceptReplyCache) Get() *AcceptReply

func (*AcceptReplyCache) Put

func (p *AcceptReplyCache) Put(t *AcceptReply)

type Ballot

type Ballot struct {
	Number int32
	PropID int16
}

func (Ballot) Equal

func (bal Ballot) Equal(cmp Ballot) bool

func (Ballot) GreaterThan

func (bal Ballot) GreaterThan(cmp Ballot) bool

func (Ballot) IsZero

func (bal Ballot) IsZero() bool

type Commit

type Commit struct {
	LeaderId int32
	Instance int32
	Ballot
	WhoseCmd   int32
	MoreToCome int32
	Command    []*state.Command
}

func (*Commit) BinarySize

func (t *Commit) BinarySize() (nbytes int, sizeKnown bool)

func (*Commit) Marshal

func (t *Commit) Marshal(wire io.Writer)

func (*Commit) New

func (t *Commit) New() fastrpc.Serializable

func (*Commit) Unmarshal

func (t *Commit) Unmarshal(rr io.Reader) error

type CommitCache

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

func NewCommitCache

func NewCommitCache() *CommitCache

func (*CommitCache) Get

func (p *CommitCache) Get() *Commit

func (*CommitCache) Put

func (p *CommitCache) Put(t *Commit)

type CommitShort

type CommitShort struct {
	LeaderId int32
	Instance int32
	Ballot
	Count    int32
	WhoseCmd int32
}

func (*CommitShort) BinarySize

func (t *CommitShort) BinarySize() (nbytes int, sizeKnown bool)

func (*CommitShort) Marshal

func (t *CommitShort) Marshal(wire io.Writer)

func (*CommitShort) New

func (t *CommitShort) New() fastrpc.Serializable

func (*CommitShort) Unmarshal

func (t *CommitShort) Unmarshal(wire io.Reader) error

type CommitShortCache

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

func NewCommitShortCache

func NewCommitShortCache() *CommitShortCache

func (*CommitShortCache) Get

func (p *CommitShortCache) Get() *CommitShort

func (*CommitShortCache) Put

func (p *CommitShortCache) Put(t *CommitShort)

type Phase

type Phase int32

const (
	//	NIL
	PROMISE Phase = iota
	ACCEPTANCE
	UNKNOWN
)

type Prepare

type Prepare struct {
	LeaderId int32
	Instance int32
	Ballot
}

func (*Prepare) BinarySize

func (t *Prepare) BinarySize() (nbytes int, sizeKnown bool)

func (*Prepare) Marshal

func (t *Prepare) Marshal(wire io.Writer)

func (*Prepare) New

func (t *Prepare) New() fastrpc.Serializable

func (*Prepare) Unmarshal

func (t *Prepare) Unmarshal(wire io.Reader) error

type PrepareCache

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

func NewPrepareCache

func NewPrepareCache() *PrepareCache

func (*PrepareCache) Get

func (p *PrepareCache) Get() *Prepare

func (*PrepareCache) Put

func (p *PrepareCache) Put(t *Prepare)

type PrepareReply

type PrepareReply struct {
	Instance   int32
	Req        Ballot
	Cur        Ballot
	CurPhase   Phase
	VBal       Ballot
	AcceptorId int32
	WhoseCmd   int32
	Command    []*state.Command
}

func (*PrepareReply) BinarySize

func (t *PrepareReply) BinarySize() (nbytes int, sizeKnown bool)

func (*PrepareReply) Marshal

func (t *PrepareReply) Marshal(wire io.Writer)

func (*PrepareReply) New

func (t *PrepareReply) New() fastrpc.Serializable

func (*PrepareReply) Unmarshal

func (t *PrepareReply) Unmarshal(rr io.Reader) error

type PrepareReplyCache

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

func NewPrepareReplyCache

func NewPrepareReplyCache() *PrepareReplyCache

func (*PrepareReplyCache) Get

func (p *PrepareReplyCache) Get() *PrepareReply

func (*PrepareReplyCache) Put

func (p *PrepareReplyCache) Put(t *PrepareReply)