paxosproto

Documentation

Index

• Constants
• 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 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 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)

Constants

const (
	PREPARE uint8 = iota
	PREPARE_REPLY
	ACCEPT
	ACCEPT_REPLY
	COMMIT
	COMMIT_SHORT
)

Types

type Accept

type Accept struct {
	LeaderId int32
	Instance int32
	Ballot   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
	Ballot   int32
	Who      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 Commit

type Commit struct {
	LeaderId int32
	Instance int32
	Ballot   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
	Count    int32
	Ballot   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 Prepare

type Prepare struct {
	LeaderId int32
	Instance int32
	Ballot   int32
}

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 {
	LBallot       int32
	Instance      int32
	Ballot        int32
	VBallot       int32
	DefaultBallot int32
	AcceptorId    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)