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 LeaseUpdate []qleaseproto.LeaseMetadata }
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 ¶
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 ¶
type Commit struct { LeaderId int32 Instance int32 Ballot int32 LeaseUpdate []qleaseproto.LeaseMetadata }
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 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 ¶
type PrepareReply struct { Instance int32 OK uint8 Ballot int32 LeaseUpdate []qleaseproto.LeaseMetadata }
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)
type ProposeLease ¶
type ProposeLease struct { ReplicaId int32 Updates []qleaseproto.LeaseMetadata }
func (*ProposeLease) BinarySize ¶
func (t *ProposeLease) BinarySize() (nbytes int, sizeKnown bool)
func (*ProposeLease) Marshal ¶
func (t *ProposeLease) Marshal(wire io.Writer)
func (*ProposeLease) New ¶
func (t *ProposeLease) New() fastrpc.Serializable
type ProposeLeaseCache ¶
type ProposeLeaseCache struct {
// contains filtered or unexported fields
}
func NewProposeLeaseCache ¶
func NewProposeLeaseCache() *ProposeLeaseCache
func (*ProposeLeaseCache) Get ¶
func (p *ProposeLeaseCache) Get() *ProposeLease
func (*ProposeLeaseCache) Put ¶
func (p *ProposeLeaseCache) Put(t *ProposeLease)
Click to show internal directories.
Click to hide internal directories.