proxy

Documentation

Index

• type AggCanonicalizingSet
  • func (a AggCanonicalizingSet) ClassID() (classID int32)
  • func (a AggCanonicalizingSet) FactoryID() int32
  • func (a *AggCanonicalizingSet) ReadData(input serialization.DataInput)
  • func (a AggCanonicalizingSet) WriteData(output serialization.DataOutput)
• type AggregateFactory
  • func (a AggregateFactory) Create(id int32) serialization.IdentifiedDataSerializable
  • func (a AggregateFactory) FactoryID() int32
• type ReferenceIDGenerator
  • func NewReferenceIDGenerator(nextID int64) *ReferenceIDGenerator
  • func (gen *ReferenceIDGenerator) NextID() int64
• type VectorClock
  • func NewVectorClock() VectorClock
  • func NewVectorClockFromPairs(pairs []proto.Pair) VectorClock
  • func (vc VectorClock) After(other VectorClock) bool
  • func (vc VectorClock) EntrySet() []proto.Pair
  • func (vc VectorClock) SetReplicaTimestamp(id types.UUID, ts int64)
  • func (vc VectorClock) Size() int

Types

type AggCanonicalizingSet

type AggCanonicalizingSet []interface{}

func (AggCanonicalizingSet) ClassID

func (a AggCanonicalizingSet) ClassID() (classID int32)

func (AggCanonicalizingSet) FactoryID

func (a AggCanonicalizingSet) FactoryID() int32

func (*AggCanonicalizingSet) ReadData

func (a *AggCanonicalizingSet) ReadData(input serialization.DataInput)

func (AggCanonicalizingSet) WriteData

func (a AggCanonicalizingSet) WriteData(output serialization.DataOutput)

type AggregateFactory

type AggregateFactory struct {
}

func (AggregateFactory) Create

func (a AggregateFactory) Create(id int32) serialization.IdentifiedDataSerializable

func (AggregateFactory) FactoryID

func (a AggregateFactory) FactoryID() int32

type ReferenceIDGenerator

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

func NewReferenceIDGenerator

func NewReferenceIDGenerator(nextID int64) *ReferenceIDGenerator

func (*ReferenceIDGenerator) NextID

func (gen *ReferenceIDGenerator) NextID() int64

type VectorClock

type VectorClock map[types.UUID]int64

VectorClock consists of distinct replica logical clocks.

The vector clock may be read from different thread but concurrent updates must be synchronized externally. There is no guarantee for concurrent updates.

See Also: https://en.wikipedia.org/wiki/Vector_clock

func NewVectorClock

func NewVectorClock() VectorClock

func NewVectorClockFromPairs

func NewVectorClockFromPairs(pairs []proto.Pair) VectorClock

func (VectorClock) After

func (vc VectorClock) After(other VectorClock) bool

After returns true if this vector clock is causally strictly after the provided vector clock. This means that it the provided clock is neither equal to, greater than or concurrent to this vector clock.

func (VectorClock) EntrySet

func (vc VectorClock) EntrySet() []proto.Pair

func (VectorClock) SetReplicaTimestamp

func (vc VectorClock) SetReplicaTimestamp(id types.UUID, ts int64)

func (VectorClock) Size

func (vc VectorClock) Size() int