qleaseproto

Documentation

Index

• type Guard
  • func (t *Guard) BinarySize() (nbytes int, sizeKnown bool)
  • func (t *Guard) Marshal(wire io.Writer)
  • func (t *Guard) New() fastrpc.Serializable
  • func (t *Guard) Unmarshal(wire io.Reader) error
• type GuardCache
  • func NewGuardCache() *GuardCache
  • func (p *GuardCache) Get() *Guard
  • func (p *GuardCache) Put(t *Guard)
• type GuardReply
  • func (t *GuardReply) BinarySize() (nbytes int, sizeKnown bool)
  • func (t *GuardReply) Marshal(wire io.Writer)
  • func (t *GuardReply) New() fastrpc.Serializable
  • func (t *GuardReply) Unmarshal(wire io.Reader) error
• type GuardReplyCache
  • func NewGuardReplyCache() *GuardReplyCache
  • func (p *GuardReplyCache) Get() *GuardReply
  • func (p *GuardReplyCache) Put(t *GuardReply)
• type LeaseMetadata
  • func (t *LeaseMetadata) BinarySize() (nbytes int, sizeKnown bool)
  • func (t *LeaseMetadata) Marshal(wire io.Writer)
  • func (t *LeaseMetadata) New() fastrpc.Serializable
  • func (t *LeaseMetadata) Unmarshal(rr io.Reader) error
• type LeaseMetadataCache
  • func NewLeaseMetadataCache() *LeaseMetadataCache
  • func (p *LeaseMetadataCache) Get() *LeaseMetadata
  • func (p *LeaseMetadataCache) Put(t *LeaseMetadata)
• type Promise
  • func (t *Promise) BinarySize() (nbytes int, sizeKnown bool)
  • func (t *Promise) Marshal(wire io.Writer)
  • func (t *Promise) New() fastrpc.Serializable
  • func (t *Promise) Unmarshal(wire io.Reader) error
• type PromiseCache
  • func NewPromiseCache() *PromiseCache
  • func (p *PromiseCache) Get() *Promise
  • func (p *PromiseCache) Put(t *Promise)
• type PromiseReply
  • func (t *PromiseReply) BinarySize() (nbytes int, sizeKnown bool)
  • func (t *PromiseReply) Marshal(wire io.Writer)
  • func (t *PromiseReply) New() fastrpc.Serializable
  • func (t *PromiseReply) Unmarshal(wire io.Reader) error
• type PromiseReplyCache
  • func NewPromiseReplyCache() *PromiseReplyCache
  • func (p *PromiseReplyCache) Get() *PromiseReply
  • func (p *PromiseReplyCache) Put(t *PromiseReply)

Types

type Guard

type Guard struct {
	ReplicaId     int32
	TimestampNs   int64
	GuardDuration int64
}

The guard message is used before non-renewal lease promises to bound the lease expiry time for the grantor.

func (*Guard) BinarySize

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

func (*Guard) Marshal

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

func (*Guard) New

func (t *Guard) New() fastrpc.Serializable

func (*Guard) Unmarshal

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

type GuardCache

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

func NewGuardCache

func NewGuardCache() *GuardCache

func (*GuardCache) Get

func (p *GuardCache) Get() *Guard

func (*GuardCache) Put

func (p *GuardCache) Put(t *Guard)

type GuardReply

type GuardReply struct {
	ReplicaId   int32
	TimestampNs int64
}

func (*GuardReply) BinarySize

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

func (*GuardReply) Marshal

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

func (*GuardReply) New

func (t *GuardReply) New() fastrpc.Serializable

func (*GuardReply) Unmarshal

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

type GuardReplyCache

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

func NewGuardReplyCache

func NewGuardReplyCache() *GuardReplyCache

func (*GuardReplyCache) Get

func (p *GuardReplyCache) Get() *GuardReply

func (*GuardReplyCache) Put

func (p *GuardReplyCache) Put(t *GuardReply)

type LeaseMetadata

type LeaseMetadata struct {
	Quorum            []int32
	ObjectKeys        []state.Key
	IgnoreReplicas    uint8 // flag indicating that the replica(s) in Quorum should be excluded from all their current quorums
	ReinstateReplicas uint8 // flag indicating that the replica(s) in Quorum are to be reinstated as replicas of their quorums
}

func (*LeaseMetadata) BinarySize

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

func (*LeaseMetadata) Marshal

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

func (*LeaseMetadata) New

func (t *LeaseMetadata) New() fastrpc.Serializable

func (*LeaseMetadata) Unmarshal

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

type LeaseMetadataCache

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

func NewLeaseMetadataCache

func NewLeaseMetadataCache() *LeaseMetadataCache

func (*LeaseMetadataCache) Get

func (p *LeaseMetadataCache) Get() *LeaseMetadata

func (*LeaseMetadataCache) Put

func (p *LeaseMetadataCache) Put(t *LeaseMetadata)

type Promise

type Promise struct {
	ReplicaId          int32
	LeaseInstance      int32
	TimestampNs        int64
	DurationNs         int64
	LatestAcceptedInst int32
}

func (*Promise) BinarySize

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

func (*Promise) Marshal

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

func (*Promise) New

func (t *Promise) New() fastrpc.Serializable

func (*Promise) Unmarshal

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

type PromiseCache

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

func NewPromiseCache

func NewPromiseCache() *PromiseCache

func (*PromiseCache) Get

func (p *PromiseCache) Get() *Promise

func (*PromiseCache) Put

func (p *PromiseCache) Put(t *Promise)

type PromiseReply

type PromiseReply struct {
	ReplicaId     int32
	LeaseInstance int32
	TimestampNs   int64
}

func (*PromiseReply) BinarySize

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

func (*PromiseReply) Marshal

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

func (*PromiseReply) New

func (t *PromiseReply) New() fastrpc.Serializable

func (*PromiseReply) Unmarshal

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

type PromiseReplyCache

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

func NewPromiseReplyCache

func NewPromiseReplyCache() *PromiseReplyCache

func (*PromiseReplyCache) Get

func (p *PromiseReplyCache) Get() *PromiseReply

func (*PromiseReplyCache) Put

func (p *PromiseReplyCache) Put(t *PromiseReply)