Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Accept ¶
type Accept struct { LeaderId int32 Instance int32 Ballot int32 Command []state.Command LeaseInstance int32 OriginReplica int32 PropId int32 }
func (*Accept) BinarySize ¶
func (*Accept) New ¶
func (t *Accept) New() fastrpc.Serializable
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 OK uint8 Ballot int32 LeaseInstance int32 OriginReplica int32 PropId 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
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 ¶
func (*Commit) BinarySize ¶
func (*Commit) New ¶
func (t *Commit) New() fastrpc.Serializable
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 ¶
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
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 Forward ¶
func (*Forward) BinarySize ¶
func (*Forward) New ¶
func (t *Forward) New() fastrpc.Serializable
type ForwardCache ¶
type ForwardCache struct {
// contains filtered or unexported fields
}
func NewForwardCache ¶
func NewForwardCache() *ForwardCache
func (*ForwardCache) Get ¶
func (p *ForwardCache) Get() *Forward
func (*ForwardCache) Put ¶
func (p *ForwardCache) Put(t *Forward)
type ForwardReply ¶
func (*ForwardReply) BinarySize ¶
func (t *ForwardReply) BinarySize() (nbytes int, sizeKnown bool)
func (*ForwardReply) Marshal ¶
func (t *ForwardReply) Marshal(wire io.Writer)
func (*ForwardReply) New ¶
func (t *ForwardReply) New() fastrpc.Serializable
type ForwardReplyCache ¶
type ForwardReplyCache struct {
// contains filtered or unexported fields
}
func NewForwardReplyCache ¶
func NewForwardReplyCache() *ForwardReplyCache
func (*ForwardReplyCache) Get ¶
func (p *ForwardReplyCache) Get() *ForwardReply
func (*ForwardReplyCache) Put ¶
func (p *ForwardReplyCache) Put(t *ForwardReply)
type Prepare ¶
func (*Prepare) BinarySize ¶
func (*Prepare) New ¶
func (t *Prepare) New() fastrpc.Serializable
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 ¶
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
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)
Click to show internal directories.
Click to hide internal directories.