gpaxosproto

Documentation

Index

• Constants
• type Commit
  • func (t *Commit) BinarySize() (nbytes int, sizeKnown bool)
  • func (t *Commit) Marshal(wire io.Writer)
  • 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 M_1a
  • func (t *M_1a) BinarySize() (nbytes int, sizeKnown bool)
  • func (t *M_1a) Marshal(wire io.Writer)
  • func (t *M_1a) Unmarshal(wire io.Reader) error
• type M_1aCache
  • func NewM_1aCache() *M_1aCache
  • func (p *M_1aCache) Get() *M_1a
  • func (p *M_1aCache) Put(t *M_1a)
• type M_1b
  • func (t *M_1b) BinarySize() (nbytes int, sizeKnown bool)
  • func (t *M_1b) Marshal(wire io.Writer)
  • func (t *M_1b) Unmarshal(rr io.Reader) error
• type M_1bCache
  • func NewM_1bCache() *M_1bCache
  • func (p *M_1bCache) Get() *M_1b
  • func (p *M_1bCache) Put(t *M_1b)
• type M_2a
  • func (t *M_2a) BinarySize() (nbytes int, sizeKnown bool)
  • func (t *M_2a) Marshal(wire io.Writer)
  • func (t *M_2a) Unmarshal(rr io.Reader) error
• type M_2aCache
  • func NewM_2aCache() *M_2aCache
  • func (p *M_2aCache) Get() *M_2a
  • func (p *M_2aCache) Put(t *M_2a)
• type M_2b
  • func (t *M_2b) BinarySize() (nbytes int, sizeKnown bool)
  • func (t *M_2b) Marshal(wire io.Writer)
  • func (t *M_2b) Unmarshal(rr io.Reader) error
• type M_2bCache
  • func NewM_2bCache() *M_2bCache
  • func (p *M_2bCache) Get() *M_2b
  • func (p *M_2bCache) Put(t *M_2b)
• type Prepare
  • func (t *Prepare) BinarySize() (nbytes int, sizeKnown bool)
  • func (t *Prepare) Marshal(wire io.Writer)
  • 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) 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
	M1A
	M1B
	M2A
	M2B
	COMMIT
)

Types

type Commit

type Commit struct {
	Cstruct []int32
}

func (*Commit) BinarySize

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

func (*Commit) Marshal

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

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 M_1a

type M_1a struct {
	LeaderId int32
	Balnum   int32
	Fast     uint8
}

func (*M_1a) BinarySize

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

func (*M_1a) Marshal

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

func (*M_1a) Unmarshal

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

type M_1aCache

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

func NewM_1aCache

func NewM_1aCache() *M_1aCache

func (*M_1aCache) Get

func (p *M_1aCache) Get() *M_1a

func (*M_1aCache) Put

func (p *M_1aCache) Put(t *M_1a)

type M_1b

type M_1b struct {
	ReplicaId int32
	Balnum    int32
	Cstruct   []int32
}

func (*M_1b) BinarySize

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

func (*M_1b) Marshal

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

func (*M_1b) Unmarshal

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

type M_1bCache

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

func NewM_1bCache

func NewM_1bCache() *M_1bCache

func (*M_1bCache) Get

func (p *M_1bCache) Get() *M_1b

func (*M_1bCache) Put

func (p *M_1bCache) Put(t *M_1b)

type M_2a

type M_2a struct {
	LeaderId int32
	Balnum   int32
	Cstruct  []int32
}

func (*M_2a) BinarySize

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

func (*M_2a) Marshal

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

func (*M_2a) Unmarshal

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

type M_2aCache

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

func NewM_2aCache

func NewM_2aCache() *M_2aCache

func (*M_2aCache) Get

func (p *M_2aCache) Get() *M_2a

func (*M_2aCache) Put

func (p *M_2aCache) Put(t *M_2a)

type M_2b

type M_2b struct {
	ReplicaId int32
	Balnum    int32
	Cstruct   []int32
	Cids      []int32
}

func (*M_2b) BinarySize

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

func (*M_2b) Marshal

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

func (*M_2b) Unmarshal

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

type M_2bCache

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

func NewM_2bCache

func NewM_2bCache() *M_2bCache

func (*M_2bCache) Get

func (p *M_2bCache) Get() *M_2b

func (*M_2bCache) Put

func (p *M_2bCache) Put(t *M_2b)

type Prepare

type Prepare struct {
	LeaderId int32
	Balnum   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) 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 {
	Balnum  int32
	OK      uint8
	Ballot  int32
	Cstruct []int32
}

func (*PrepareReply) BinarySize

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

func (*PrepareReply) Marshal

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

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)