lwcproto

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 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 ConfigBal
  • func GetNilConfigBal() ConfigBal
  • func (configBal ConfigBal) Equal(cmp ConfigBal) bool
  • func (configBal ConfigBal) GreaterThan(cmp ConfigBal) bool
  • func (confBal ConfigBal) IsZero() bool
• type Configuration
• type ConfigurationRound
• 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)
• type Round

Types

type Accept

type Accept struct {
	LeaderId int32
	Instance int32
	ConfigBal
	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        ConfigBal
	Req        ConfigBal
	CurPhase   stdpaxosproto.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 Commit

type Commit struct {
	LeaderId int32
	Instance int32
	ConfigBal
	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
	ConfigBal
	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 ConfigBal

type ConfigBal struct {
	Config int32
	stdpaxosproto.Ballot
}

func GetNilConfigBal

func GetNilConfigBal() ConfigBal

func (ConfigBal) Equal

func (configBal ConfigBal) Equal(cmp ConfigBal) bool

func (ConfigBal) GreaterThan

func (configBal ConfigBal) GreaterThan(cmp ConfigBal) bool

func (ConfigBal) IsZero

func (confBal ConfigBal) IsZero() bool

type Configuration

type Configuration interface {
	GetConfiguration() Configuration
}

type ConfigurationRound

type ConfigurationRound interface {
	GetConfiguration() ConfigurationRound
	GetRound() Round
}

type Prepare

type Prepare struct {
	LeaderId int32
	Instance int32
	ConfigBal
}

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        ConfigBal
	Cur        ConfigBal
	CurPhase   stdpaxosproto.Phase
	VBal       ConfigBal
	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)

type Round

type Round interface {
	GetRound() Round
}