Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

crdt

package

Go to main page

Versions in this module

v0

v0.3.0

Jan 13, 2021

Changes in this version

+ type UnsafeTckCrdtServer interface

v0.2.2

Jan 12, 2021

v0.2.1

Nov 15, 2020

v0.2.0

Nov 10, 2020

Changes in this version

+ var CrdtClock_name = map[int32]string

+ var CrdtClock_value = map[string]int32

+ var File_tck_crdt_proto protoreflect.FileDescriptor

+ func RegisterTckCrdtServer(s *grpc.Server, srv TckCrdtServer)

+ type AnySupportType struct

+ Value isAnySupportType_Value

+ func (*AnySupportType) Descriptor() ([]byte, []int)

+ func (*AnySupportType) ProtoMessage()

+ func (m *AnySupportType) GetValue() isAnySupportType_Value

+ func (x *AnySupportType) GetAnyValue() *any.Any

+ func (x *AnySupportType) GetBoolValue() bool

+ func (x *AnySupportType) GetBytesValue() []byte

+ func (x *AnySupportType) GetDoubleValue() float64

+ func (x *AnySupportType) GetFloatValue() float32

+ func (x *AnySupportType) GetInt32Value() int32

+ func (x *AnySupportType) GetInt64Value() int64

+ func (x *AnySupportType) GetStringValue() string

+ func (x *AnySupportType) ProtoReflect() protoreflect.Message

+ func (x *AnySupportType) Reset()

+ func (x *AnySupportType) String() string

+ type AnySupportType_AnyValue struct

+ AnyValue *any.Any

+ type AnySupportType_BoolValue struct

+ BoolValue bool

+ type AnySupportType_BytesValue struct

+ BytesValue []byte

+ type AnySupportType_DoubleValue struct

+ DoubleValue float64

+ type AnySupportType_FloatValue struct

+ FloatValue float32

+ type AnySupportType_Int32Value struct

+ Int32Value int32

+ type AnySupportType_Int64Value struct

+ Int64Value int64

+ type AnySupportType_StringValue struct

+ StringValue string

+ type CrdtClock int32

+ const CrdtClock_CUSTOM

+ const CrdtClock_CUSTOM_AUTO_INCREMENT

+ const CrdtClock_DEFAULT

+ const CrdtClock_REVERSE

+ func (CrdtClock) Descriptor() protoreflect.EnumDescriptor

+ func (CrdtClock) EnumDescriptor() ([]byte, []int)

+ func (CrdtClock) Type() protoreflect.EnumType

+ func (x CrdtClock) Enum() *CrdtClock

+ func (x CrdtClock) Number() protoreflect.EnumNumber

+ func (x CrdtClock) String() string

+ type Delete struct

+ FailWith string

+ Key string

+ func (*Delete) Descriptor() ([]byte, []int)

+ func (*Delete) ProtoMessage()

+ func (x *Delete) GetFailWith() string

+ func (x *Delete) GetKey() string

+ func (x *Delete) ProtoReflect() protoreflect.Message

+ func (x *Delete) Reset()

+ func (x *Delete) String() string

+ type FlagEnable struct

+ FailWith string

+ Key string

+ func (*FlagEnable) Descriptor() ([]byte, []int)

+ func (*FlagEnable) ProtoMessage()

+ func (x *FlagEnable) GetFailWith() string

+ func (x *FlagEnable) GetKey() string

+ func (x *FlagEnable) ProtoReflect() protoreflect.Message

+ func (x *FlagEnable) Reset()

+ func (x *FlagEnable) String() string

+ type FlagRequest struct

+ Actions []*FlagRequestAction

+ Id string

+ func (*FlagRequest) Descriptor() ([]byte, []int)

+ func (*FlagRequest) ProtoMessage()

+ func (x *FlagRequest) GetActions() []*FlagRequestAction

+ func (x *FlagRequest) GetId() string

+ func (x *FlagRequest) ProtoReflect() protoreflect.Message

+ func (x *FlagRequest) Reset()

+ func (x *FlagRequest) String() string

+ type FlagRequestAction struct

+ Action isFlagRequestAction_Action

+ func (*FlagRequestAction) Descriptor() ([]byte, []int)

+ func (*FlagRequestAction) ProtoMessage()

+ func (m *FlagRequestAction) GetAction() isFlagRequestAction_Action

+ func (x *FlagRequestAction) GetDelete() *Delete

+ func (x *FlagRequestAction) GetEnable() *FlagEnable

+ func (x *FlagRequestAction) GetGet() *Get

+ func (x *FlagRequestAction) ProtoReflect() protoreflect.Message

+ func (x *FlagRequestAction) Reset()

+ func (x *FlagRequestAction) String() string

+ type FlagRequestAction_Delete struct

+ Delete *Delete

+ type FlagRequestAction_Enable struct

+ Enable *FlagEnable

+ type FlagRequestAction_Get struct

+ Get *Get

+ type FlagResponse struct

+ Value *FlagValue

+ func (*FlagResponse) Descriptor() ([]byte, []int)

+ func (*FlagResponse) ProtoMessage()

+ func (x *FlagResponse) GetValue() *FlagValue

+ func (x *FlagResponse) ProtoReflect() protoreflect.Message

+ func (x *FlagResponse) Reset()

+ func (x *FlagResponse) String() string

+ type FlagValue struct

+ Value bool

+ func (*FlagValue) Descriptor() ([]byte, []int)

+ func (*FlagValue) ProtoMessage()

+ func (x *FlagValue) GetValue() bool

+ func (x *FlagValue) ProtoReflect() protoreflect.Message

+ func (x *FlagValue) Reset()

+ func (x *FlagValue) String() string

+ type GCounterIncrement struct

+ FailWith string

+ Key string

+ Value uint64

+ func (*GCounterIncrement) Descriptor() ([]byte, []int)

+ func (*GCounterIncrement) ProtoMessage()

+ func (x *GCounterIncrement) GetFailWith() string

+ func (x *GCounterIncrement) GetKey() string

+ func (x *GCounterIncrement) GetValue() uint64

+ func (x *GCounterIncrement) ProtoReflect() protoreflect.Message

+ func (x *GCounterIncrement) Reset()

+ func (x *GCounterIncrement) String() string

+ type GCounterRequest struct

+ Actions []*GCounterRequestAction

+ Id string

+ func (*GCounterRequest) Descriptor() ([]byte, []int)

+ func (*GCounterRequest) ProtoMessage()

+ func (x *GCounterRequest) GetActions() []*GCounterRequestAction

+ func (x *GCounterRequest) GetId() string

+ func (x *GCounterRequest) ProtoReflect() protoreflect.Message

+ func (x *GCounterRequest) Reset()

+ func (x *GCounterRequest) String() string

+ type GCounterRequestAction struct

+ Action isGCounterRequestAction_Action

+ func (*GCounterRequestAction) Descriptor() ([]byte, []int)

+ func (*GCounterRequestAction) ProtoMessage()

+ func (m *GCounterRequestAction) GetAction() isGCounterRequestAction_Action

+ func (x *GCounterRequestAction) GetDelete() *Delete

+ func (x *GCounterRequestAction) GetGet() *Get

+ func (x *GCounterRequestAction) GetIncrement() *GCounterIncrement

+ func (x *GCounterRequestAction) ProtoReflect() protoreflect.Message

+ func (x *GCounterRequestAction) Reset()

+ func (x *GCounterRequestAction) String() string

+ type GCounterRequestAction_Delete struct

+ Delete *Delete

+ type GCounterRequestAction_Get struct

+ Get *Get

+ type GCounterRequestAction_Increment struct

+ Increment *GCounterIncrement

+ type GCounterResponse struct

+ Value *GCounterValue

+ func (*GCounterResponse) Descriptor() ([]byte, []int)

+ func (*GCounterResponse) ProtoMessage()

+ func (x *GCounterResponse) GetValue() *GCounterValue

+ func (x *GCounterResponse) ProtoReflect() protoreflect.Message

+ func (x *GCounterResponse) Reset()

+ func (x *GCounterResponse) String() string

+ type GCounterValue struct

+ Value uint64

+ func (*GCounterValue) Descriptor() ([]byte, []int)

+ func (*GCounterValue) ProtoMessage()

+ func (x *GCounterValue) GetValue() uint64

+ func (x *GCounterValue) ProtoReflect() protoreflect.Message

+ func (x *GCounterValue) Reset()

+ func (x *GCounterValue) String() string

+ type GSetAdd struct

+ FailWith string

+ Key string

+ Value *AnySupportType

+ func (*GSetAdd) Descriptor() ([]byte, []int)

+ func (*GSetAdd) ProtoMessage()

+ func (x *GSetAdd) GetFailWith() string

+ func (x *GSetAdd) GetKey() string

+ func (x *GSetAdd) GetValue() *AnySupportType

+ func (x *GSetAdd) ProtoReflect() protoreflect.Message

+ func (x *GSetAdd) Reset()

+ func (x *GSetAdd) String() string

+ type GSetRequest struct

+ Actions []*GSetRequestAction

+ Id string

+ func (*GSetRequest) Descriptor() ([]byte, []int)

+ func (*GSetRequest) ProtoMessage()

+ func (x *GSetRequest) GetActions() []*GSetRequestAction

+ func (x *GSetRequest) GetId() string

+ func (x *GSetRequest) ProtoReflect() protoreflect.Message

+ func (x *GSetRequest) Reset()

+ func (x *GSetRequest) String() string

+ type GSetRequestAction struct

+ Action isGSetRequestAction_Action

+ func (*GSetRequestAction) Descriptor() ([]byte, []int)

+ func (*GSetRequestAction) ProtoMessage()

+ func (m *GSetRequestAction) GetAction() isGSetRequestAction_Action

+ func (x *GSetRequestAction) GetAdd() *GSetAdd

+ func (x *GSetRequestAction) GetDelete() *Delete

+ func (x *GSetRequestAction) GetGet() *Get

+ func (x *GSetRequestAction) ProtoReflect() protoreflect.Message

+ func (x *GSetRequestAction) Reset()

+ func (x *GSetRequestAction) String() string

+ type GSetRequestAction_Add struct

+ Add *GSetAdd

+ type GSetRequestAction_Delete struct

+ Delete *Delete

+ type GSetRequestAction_Get struct

+ Get *Get

+ type GSetResponse struct

+ Value *GSetValue

+ func (*GSetResponse) Descriptor() ([]byte, []int)

+ func (*GSetResponse) ProtoMessage()

+ func (x *GSetResponse) GetValue() *GSetValue

+ func (x *GSetResponse) ProtoReflect() protoreflect.Message

+ func (x *GSetResponse) Reset()

+ func (x *GSetResponse) String() string

+ type GSetValue struct

+ Values []*AnySupportType

+ func (*GSetValue) Descriptor() ([]byte, []int)

+ func (*GSetValue) ProtoMessage()

+ func (x *GSetValue) GetValues() []*AnySupportType

+ func (x *GSetValue) ProtoReflect() protoreflect.Message

+ func (x *GSetValue) Reset()

+ func (x *GSetValue) String() string

+ type GSetValueAnySupport struct

+ Values []*AnySupportType

+ func (*GSetValueAnySupport) Descriptor() ([]byte, []int)

+ func (*GSetValueAnySupport) ProtoMessage()

+ func (x *GSetValueAnySupport) GetValues() []*AnySupportType

+ func (x *GSetValueAnySupport) ProtoReflect() protoreflect.Message

+ func (x *GSetValueAnySupport) Reset()

+ func (x *GSetValueAnySupport) String() string

+ type Get struct

+ FailWith string

+ Key string

+ func (*Get) Descriptor() ([]byte, []int)

+ func (*Get) ProtoMessage()

+ func (x *Get) GetFailWith() string

+ func (x *Get) GetKey() string

+ func (x *Get) ProtoReflect() protoreflect.Message

+ func (x *Get) Reset()

+ func (x *Get) String() string

+ type LWWRegisterRequest struct

+ Actions []*LWWRegisterRequestAction

+ Id string

+ func (*LWWRegisterRequest) Descriptor() ([]byte, []int)

+ func (*LWWRegisterRequest) ProtoMessage()

+ func (x *LWWRegisterRequest) GetActions() []*LWWRegisterRequestAction

+ func (x *LWWRegisterRequest) GetId() string

+ func (x *LWWRegisterRequest) ProtoReflect() protoreflect.Message

+ func (x *LWWRegisterRequest) Reset()

+ func (x *LWWRegisterRequest) String() string

+ type LWWRegisterRequestAction struct

+ Action isLWWRegisterRequestAction_Action

+ func (*LWWRegisterRequestAction) Descriptor() ([]byte, []int)

+ func (*LWWRegisterRequestAction) ProtoMessage()

+ func (m *LWWRegisterRequestAction) GetAction() isLWWRegisterRequestAction_Action

+ func (x *LWWRegisterRequestAction) GetDelete() *Delete

+ func (x *LWWRegisterRequestAction) GetGet() *Get

+ func (x *LWWRegisterRequestAction) GetSet() *LWWRegisterSet

+ func (x *LWWRegisterRequestAction) GetSetWithClock() *LWWRegisterSetWithClock

+ func (x *LWWRegisterRequestAction) ProtoReflect() protoreflect.Message

+ func (x *LWWRegisterRequestAction) Reset()

+ func (x *LWWRegisterRequestAction) String() string

+ type LWWRegisterRequestAction_Delete struct

+ Delete *Delete

+ type LWWRegisterRequestAction_Get struct

+ Get *Get

+ type LWWRegisterRequestAction_Set struct

+ Set *LWWRegisterSet

+ type LWWRegisterRequestAction_SetWithClock struct

+ SetWithClock *LWWRegisterSetWithClock

+ type LWWRegisterResponse struct

+ Value *LWWRegisterValue

+ func (*LWWRegisterResponse) Descriptor() ([]byte, []int)

+ func (*LWWRegisterResponse) ProtoMessage()

+ func (x *LWWRegisterResponse) GetValue() *LWWRegisterValue

+ func (x *LWWRegisterResponse) ProtoReflect() protoreflect.Message

+ func (x *LWWRegisterResponse) Reset()

+ func (x *LWWRegisterResponse) String() string

+ type LWWRegisterSet struct

+ FailWith string

+ Key string

+ Value *AnySupportType

+ func (*LWWRegisterSet) Descriptor() ([]byte, []int)

+ func (*LWWRegisterSet) ProtoMessage()

+ func (x *LWWRegisterSet) GetFailWith() string

+ func (x *LWWRegisterSet) GetKey() string

+ func (x *LWWRegisterSet) GetValue() *AnySupportType

+ func (x *LWWRegisterSet) ProtoReflect() protoreflect.Message

+ func (x *LWWRegisterSet) Reset()

+ func (x *LWWRegisterSet) String() string

+ type LWWRegisterSetWithClock struct

+ Clock CrdtClock

+ CustomClockValue int64

+ FailWith string

+ Key string

+ Value *AnySupportType

+ func (*LWWRegisterSetWithClock) Descriptor() ([]byte, []int)

+ func (*LWWRegisterSetWithClock) ProtoMessage()

+ func (x *LWWRegisterSetWithClock) GetClock() CrdtClock

+ func (x *LWWRegisterSetWithClock) GetCustomClockValue() int64

+ func (x *LWWRegisterSetWithClock) GetFailWith() string

+ func (x *LWWRegisterSetWithClock) GetKey() string

+ func (x *LWWRegisterSetWithClock) GetValue() *AnySupportType

+ func (x *LWWRegisterSetWithClock) ProtoReflect() protoreflect.Message

+ func (x *LWWRegisterSetWithClock) Reset()

+ func (x *LWWRegisterSetWithClock) String() string

+ type LWWRegisterValue struct

+ Value *any.Any

+ func (*LWWRegisterValue) Descriptor() ([]byte, []int)

+ func (*LWWRegisterValue) ProtoMessage()

+ func (x *LWWRegisterValue) GetValue() *any.Any

+ func (x *LWWRegisterValue) ProtoReflect() protoreflect.Message

+ func (x *LWWRegisterValue) Reset()

+ func (x *LWWRegisterValue) String() string

+ type ORMapActionRequest struct

+ EntryKey *any.Any

+ FailWith string

+ Key string

+ Request isORMapActionRequest_Request

+ func (*ORMapActionRequest) Descriptor() ([]byte, []int)

+ func (*ORMapActionRequest) ProtoMessage()

+ func (m *ORMapActionRequest) GetRequest() isORMapActionRequest_Request

+ func (x *ORMapActionRequest) GetEntryKey() *any.Any

+ func (x *ORMapActionRequest) GetFailWith() string

+ func (x *ORMapActionRequest) GetFlagRequest() *FlagRequest

+ func (x *ORMapActionRequest) GetGCounterRequest() *GCounterRequest

+ func (x *ORMapActionRequest) GetGsetRequest() *GSetRequest

+ func (x *ORMapActionRequest) GetKey() string

+ func (x *ORMapActionRequest) GetLwwRegisterRequest() *LWWRegisterRequest

+ func (x *ORMapActionRequest) GetOrMapRequest() *ORMapRequest

+ func (x *ORMapActionRequest) GetOrSetRequest() *ORSetRequest

+ func (x *ORMapActionRequest) GetPnCounterRequest() *PNCounterRequest

+ func (x *ORMapActionRequest) GetVoteRequest() *VoteRequest

+ func (x *ORMapActionRequest) ProtoReflect() protoreflect.Message

+ func (x *ORMapActionRequest) Reset()

+ func (x *ORMapActionRequest) String() string

+ type ORMapActionRequest_FlagRequest struct

+ FlagRequest *FlagRequest

+ type ORMapActionRequest_GCounterRequest struct

+ GCounterRequest *GCounterRequest

+ type ORMapActionRequest_GsetRequest struct

+ GsetRequest *GSetRequest

+ type ORMapActionRequest_LwwRegisterRequest struct

+ LwwRegisterRequest *LWWRegisterRequest

+ type ORMapActionRequest_OrMapRequest struct

+ OrMapRequest *ORMapRequest

+ type ORMapActionRequest_OrSetRequest struct

+ OrSetRequest *ORSetRequest

+ type ORMapActionRequest_PnCounterRequest struct

+ PnCounterRequest *PNCounterRequest

+ type ORMapActionRequest_VoteRequest struct

+ VoteRequest *VoteRequest

+ type ORMapDelete struct

+ EntryKey *any.Any

+ FailWith string

+ Key string

+ func (*ORMapDelete) Descriptor() ([]byte, []int)

+ func (*ORMapDelete) ProtoMessage()

+ func (x *ORMapDelete) GetEntryKey() *any.Any

+ func (x *ORMapDelete) GetFailWith() string

+ func (x *ORMapDelete) GetKey() string

+ func (x *ORMapDelete) ProtoReflect() protoreflect.Message

+ func (x *ORMapDelete) Reset()

+ func (x *ORMapDelete) String() string

+ type ORMapEntries struct

+ Values []*ORMapEntry

+ func (*ORMapEntries) Descriptor() ([]byte, []int)

+ func (*ORMapEntries) ProtoMessage()

+ func (x *ORMapEntries) GetValues() []*ORMapEntry

+ func (x *ORMapEntries) ProtoReflect() protoreflect.Message

+ func (x *ORMapEntries) Reset()

+ func (x *ORMapEntries) String() string

+ type ORMapEntry struct

+ EntryKey *any.Any

+ Value *any.Any

+ func (*ORMapEntry) Descriptor() ([]byte, []int)

+ func (*ORMapEntry) ProtoMessage()

+ func (x *ORMapEntry) GetEntryKey() *any.Any

+ func (x *ORMapEntry) GetValue() *any.Any

+ func (x *ORMapEntry) ProtoReflect() protoreflect.Message

+ func (x *ORMapEntry) Reset()

+ func (x *ORMapEntry) String() string

+ type ORMapKeys struct

+ Values []*any.Any

+ func (*ORMapKeys) Descriptor() ([]byte, []int)

+ func (*ORMapKeys) ProtoMessage()

+ func (x *ORMapKeys) GetValues() []*any.Any

+ func (x *ORMapKeys) ProtoReflect() protoreflect.Message

+ func (x *ORMapKeys) Reset()

+ func (x *ORMapKeys) String() string

+ type ORMapRequest struct

+ Actions []*ORMapRequestAction

+ Id string

+ func (*ORMapRequest) Descriptor() ([]byte, []int)

+ func (*ORMapRequest) ProtoMessage()

+ func (x *ORMapRequest) GetActions() []*ORMapRequestAction

+ func (x *ORMapRequest) GetId() string

+ func (x *ORMapRequest) ProtoReflect() protoreflect.Message

+ func (x *ORMapRequest) Reset()

+ func (x *ORMapRequest) String() string

+ type ORMapRequestAction struct

+ Action isORMapRequestAction_Action

+ func (*ORMapRequestAction) Descriptor() ([]byte, []int)

+ func (*ORMapRequestAction) ProtoMessage()

+ func (m *ORMapRequestAction) GetAction() isORMapRequestAction_Action

+ func (x *ORMapRequestAction) GetDelete() *Delete

+ func (x *ORMapRequestAction) GetDeleteKey() *ORMapDelete

+ func (x *ORMapRequestAction) GetGet() *Get

+ func (x *ORMapRequestAction) GetRequest() *ORMapActionRequest

+ func (x *ORMapRequestAction) GetSetKey() *ORMapSet

+ func (x *ORMapRequestAction) ProtoReflect() protoreflect.Message

+ func (x *ORMapRequestAction) Reset()

+ func (x *ORMapRequestAction) String() string

+ type ORMapRequestAction_Delete struct

+ Delete *Delete

+ type ORMapRequestAction_DeleteKey struct

+ DeleteKey *ORMapDelete

+ type ORMapRequestAction_Get struct

+ Get *Get

+ type ORMapRequestAction_Request struct

+ Request *ORMapActionRequest

+ type ORMapRequestAction_SetKey struct

+ SetKey *ORMapSet

+ type ORMapResponse struct

+ Entries *ORMapEntries

+ Keys *ORMapKeys

+ func (*ORMapResponse) Descriptor() ([]byte, []int)

+ func (*ORMapResponse) ProtoMessage()

+ func (x *ORMapResponse) GetEntries() *ORMapEntries

+ func (x *ORMapResponse) GetKeys() *ORMapKeys

+ func (x *ORMapResponse) ProtoReflect() protoreflect.Message

+ func (x *ORMapResponse) Reset()

+ func (x *ORMapResponse) String() string

+ type ORMapSet struct

+ EntryKey *any.Any

+ FailWith string

+ Key string

+ Request isORMapSet_Request

+ Value *any.Any

+ func (*ORMapSet) Descriptor() ([]byte, []int)

+ func (*ORMapSet) ProtoMessage()

+ func (m *ORMapSet) GetRequest() isORMapSet_Request

+ func (x *ORMapSet) GetEntryKey() *any.Any

+ func (x *ORMapSet) GetFailWith() string

+ func (x *ORMapSet) GetFlagRequest() *FlagRequest

+ func (x *ORMapSet) GetGCounterRequest() *GCounterRequest

+ func (x *ORMapSet) GetGsetRequest() *GSetRequest

+ func (x *ORMapSet) GetKey() string

+ func (x *ORMapSet) GetLwwRegisterRequest() *LWWRegisterRequest

+ func (x *ORMapSet) GetOrMapRequest() *ORMapRequest

+ func (x *ORMapSet) GetOrSetRequest() *ORSetRequest

+ func (x *ORMapSet) GetPnCounterRequest() *PNCounterRequest

+ func (x *ORMapSet) GetValue() *any.Any

+ func (x *ORMapSet) GetVoteRequest() *VoteRequest

+ func (x *ORMapSet) ProtoReflect() protoreflect.Message

+ func (x *ORMapSet) Reset()

+ func (x *ORMapSet) String() string

+ type ORMapSet_FlagRequest struct

+ FlagRequest *FlagRequest

+ type ORMapSet_GCounterRequest struct

+ GCounterRequest *GCounterRequest

+ type ORMapSet_GsetRequest struct

+ GsetRequest *GSetRequest

+ type ORMapSet_LwwRegisterRequest struct

+ LwwRegisterRequest *LWWRegisterRequest

+ type ORMapSet_OrMapRequest struct

+ OrMapRequest *ORMapRequest

+ type ORMapSet_OrSetRequest struct

+ OrSetRequest *ORSetRequest

+ type ORMapSet_PnCounterRequest struct

+ PnCounterRequest *PNCounterRequest

+ type ORMapSet_VoteRequest struct

+ VoteRequest *VoteRequest

+ type ORSetAdd struct

+ FailWith string

+ Key string

+ Value *AnySupportType

+ func (*ORSetAdd) Descriptor() ([]byte, []int)

+ func (*ORSetAdd) ProtoMessage()

+ func (x *ORSetAdd) GetFailWith() string

+ func (x *ORSetAdd) GetKey() string

+ func (x *ORSetAdd) GetValue() *AnySupportType

+ func (x *ORSetAdd) ProtoReflect() protoreflect.Message

+ func (x *ORSetAdd) Reset()

+ func (x *ORSetAdd) String() string

+ type ORSetRemove struct

+ FailWith string

+ Key string

+ Value *AnySupportType

+ func (*ORSetRemove) Descriptor() ([]byte, []int)

+ func (*ORSetRemove) ProtoMessage()

+ func (x *ORSetRemove) GetFailWith() string

+ func (x *ORSetRemove) GetKey() string

+ func (x *ORSetRemove) GetValue() *AnySupportType

+ func (x *ORSetRemove) ProtoReflect() protoreflect.Message

+ func (x *ORSetRemove) Reset()

+ func (x *ORSetRemove) String() string

+ type ORSetRequest struct

+ Actions []*ORSetRequestAction

+ Id string

+ func (*ORSetRequest) Descriptor() ([]byte, []int)

+ func (*ORSetRequest) ProtoMessage()

+ func (x *ORSetRequest) GetActions() []*ORSetRequestAction

+ func (x *ORSetRequest) GetId() string

+ func (x *ORSetRequest) ProtoReflect() protoreflect.Message

+ func (x *ORSetRequest) Reset()

+ func (x *ORSetRequest) String() string

+ type ORSetRequestAction struct

+ Action isORSetRequestAction_Action

+ func (*ORSetRequestAction) Descriptor() ([]byte, []int)

+ func (*ORSetRequestAction) ProtoMessage()

+ func (m *ORSetRequestAction) GetAction() isORSetRequestAction_Action

+ func (x *ORSetRequestAction) GetAdd() *ORSetAdd

+ func (x *ORSetRequestAction) GetDelete() *Delete

+ func (x *ORSetRequestAction) GetGet() *Get

+ func (x *ORSetRequestAction) GetRemove() *ORSetRemove

+ func (x *ORSetRequestAction) ProtoReflect() protoreflect.Message

+ func (x *ORSetRequestAction) Reset()

+ func (x *ORSetRequestAction) String() string

+ type ORSetRequestAction_Add struct

+ Add *ORSetAdd

+ type ORSetRequestAction_Delete struct

+ Delete *Delete

+ type ORSetRequestAction_Get struct

+ Get *Get

+ type ORSetRequestAction_Remove struct

+ Remove *ORSetRemove

+ type ORSetResponse struct

+ Value *ORSetValue

+ func (*ORSetResponse) Descriptor() ([]byte, []int)

+ func (*ORSetResponse) ProtoMessage()

+ func (x *ORSetResponse) GetValue() *ORSetValue

+ func (x *ORSetResponse) ProtoReflect() protoreflect.Message

+ func (x *ORSetResponse) Reset()

+ func (x *ORSetResponse) String() string

+ type ORSetValue struct

+ Values []*any.Any

+ func (*ORSetValue) Descriptor() ([]byte, []int)

+ func (*ORSetValue) ProtoMessage()

+ func (x *ORSetValue) GetValues() []*any.Any

+ func (x *ORSetValue) ProtoReflect() protoreflect.Message

+ func (x *ORSetValue) Reset()

+ func (x *ORSetValue) String() string

+ type PNCounterDecrement struct

+ FailWith string

+ Key string

+ Value int64

+ func (*PNCounterDecrement) Descriptor() ([]byte, []int)

+ func (*PNCounterDecrement) ProtoMessage()

+ func (x *PNCounterDecrement) GetFailWith() string

+ func (x *PNCounterDecrement) GetKey() string

+ func (x *PNCounterDecrement) GetValue() int64

+ func (x *PNCounterDecrement) ProtoReflect() protoreflect.Message

+ func (x *PNCounterDecrement) Reset()

+ func (x *PNCounterDecrement) String() string

+ type PNCounterIncrement struct

+ FailWith string

+ Key string

+ Value int64

+ func (*PNCounterIncrement) Descriptor() ([]byte, []int)

+ func (*PNCounterIncrement) ProtoMessage()

+ func (x *PNCounterIncrement) GetFailWith() string

+ func (x *PNCounterIncrement) GetKey() string

+ func (x *PNCounterIncrement) GetValue() int64

+ func (x *PNCounterIncrement) ProtoReflect() protoreflect.Message

+ func (x *PNCounterIncrement) Reset()

+ func (x *PNCounterIncrement) String() string

+ type PNCounterRequest struct

+ Actions []*PNCounterRequestAction

+ Id string

+ func (*PNCounterRequest) Descriptor() ([]byte, []int)

+ func (*PNCounterRequest) ProtoMessage()

+ func (x *PNCounterRequest) GetActions() []*PNCounterRequestAction

+ func (x *PNCounterRequest) GetId() string

+ func (x *PNCounterRequest) ProtoReflect() protoreflect.Message

+ func (x *PNCounterRequest) Reset()

+ func (x *PNCounterRequest) String() string

+ type PNCounterRequestAction struct

+ Action isPNCounterRequestAction_Action

+ func (*PNCounterRequestAction) Descriptor() ([]byte, []int)

+ func (*PNCounterRequestAction) ProtoMessage()

+ func (m *PNCounterRequestAction) GetAction() isPNCounterRequestAction_Action

+ func (x *PNCounterRequestAction) GetDecrement() *PNCounterDecrement

+ func (x *PNCounterRequestAction) GetDelete() *Delete

+ func (x *PNCounterRequestAction) GetGet() *Get

+ func (x *PNCounterRequestAction) GetIncrement() *PNCounterIncrement

+ func (x *PNCounterRequestAction) ProtoReflect() protoreflect.Message

+ func (x *PNCounterRequestAction) Reset()

+ func (x *PNCounterRequestAction) String() string

+ type PNCounterRequestAction_Decrement struct

+ Decrement *PNCounterDecrement

+ type PNCounterRequestAction_Delete struct

+ Delete *Delete

+ type PNCounterRequestAction_Get struct

+ Get *Get

+ type PNCounterRequestAction_Increment struct

+ Increment *PNCounterIncrement

+ type PNCounterResponse struct

+ Value *PNCounterValue

+ func (*PNCounterResponse) Descriptor() ([]byte, []int)

+ func (*PNCounterResponse) ProtoMessage()

+ func (x *PNCounterResponse) GetValue() *PNCounterValue

+ func (x *PNCounterResponse) ProtoReflect() protoreflect.Message

+ func (x *PNCounterResponse) Reset()

+ func (x *PNCounterResponse) String() string

+ type PNCounterValue struct

+ Value int64

+ func (*PNCounterValue) Descriptor() ([]byte, []int)

+ func (*PNCounterValue) ProtoMessage()

+ func (x *PNCounterValue) GetValue() int64

+ func (x *PNCounterValue) ProtoReflect() protoreflect.Message

+ func (x *PNCounterValue) Reset()

+ func (x *PNCounterValue) String() string

+ type TckCrdtClient interface

+ ProcessFlag func(ctx context.Context, in *FlagRequest, opts ...grpc.CallOption) (*FlagResponse, error)

+ ProcessGCounter func(ctx context.Context, in *GCounterRequest, opts ...grpc.CallOption) (*GCounterResponse, error)

+ ProcessGCounterStreamed func(ctx context.Context, in *GCounterRequest, opts ...grpc.CallOption) (TckCrdt_ProcessGCounterStreamedClient, error)

+ ProcessGSet func(ctx context.Context, in *GSetRequest, opts ...grpc.CallOption) (*GSetResponse, error)

+ ProcessLWWRegister func(ctx context.Context, in *LWWRegisterRequest, opts ...grpc.CallOption) (*LWWRegisterResponse, error)

+ ProcessORMap func(ctx context.Context, in *ORMapRequest, opts ...grpc.CallOption) (*ORMapResponse, error)

+ ProcessORSet func(ctx context.Context, in *ORSetRequest, opts ...grpc.CallOption) (*ORSetResponse, error)

+ ProcessPNCounter func(ctx context.Context, in *PNCounterRequest, opts ...grpc.CallOption) (*PNCounterResponse, error)

+ ProcessVote func(ctx context.Context, in *VoteRequest, opts ...grpc.CallOption) (*VoteResponse, error)

+ func NewTckCrdtClient(cc grpc.ClientConnInterface) TckCrdtClient

+ type TckCrdtServer interface

+ ProcessFlag func(context.Context, *FlagRequest) (*FlagResponse, error)

+ ProcessGCounter func(context.Context, *GCounterRequest) (*GCounterResponse, error)

+ ProcessGCounterStreamed func(*GCounterRequest, TckCrdt_ProcessGCounterStreamedServer) error

+ ProcessGSet func(context.Context, *GSetRequest) (*GSetResponse, error)

+ ProcessLWWRegister func(context.Context, *LWWRegisterRequest) (*LWWRegisterResponse, error)

+ ProcessORMap func(context.Context, *ORMapRequest) (*ORMapResponse, error)

+ ProcessORSet func(context.Context, *ORSetRequest) (*ORSetResponse, error)

+ ProcessPNCounter func(context.Context, *PNCounterRequest) (*PNCounterResponse, error)

+ ProcessVote func(context.Context, *VoteRequest) (*VoteResponse, error)

+ type TckCrdt_ProcessGCounterStreamedClient interface

+ Recv func() (*GCounterResponse, error)

+ type TckCrdt_ProcessGCounterStreamedServer interface

+ Send func(*GCounterResponse) error

+ type TestModel struct

+ func NewEntity(id crdt.EntityID) *TestModel

+ func (s *TestModel) Default(c *crdt.Context) (crdt.CRDT, error)

+ func (s *TestModel) HandleCommand(cc *crdt.CommandContext, name string, cmd proto.Message) (*any.Any, error)

+ func (s *TestModel) Set(_ *crdt.Context, c crdt.CRDT) error

+ type UnimplementedTckCrdtServer struct

+ func (*UnimplementedTckCrdtServer) ProcessFlag(context.Context, *FlagRequest) (*FlagResponse, error)

+ func (*UnimplementedTckCrdtServer) ProcessGCounter(context.Context, *GCounterRequest) (*GCounterResponse, error)

+ func (*UnimplementedTckCrdtServer) ProcessGCounterStreamed(*GCounterRequest, TckCrdt_ProcessGCounterStreamedServer) error

+ func (*UnimplementedTckCrdtServer) ProcessGSet(context.Context, *GSetRequest) (*GSetResponse, error)

+ func (*UnimplementedTckCrdtServer) ProcessLWWRegister(context.Context, *LWWRegisterRequest) (*LWWRegisterResponse, error)

+ func (*UnimplementedTckCrdtServer) ProcessORMap(context.Context, *ORMapRequest) (*ORMapResponse, error)

+ func (*UnimplementedTckCrdtServer) ProcessORSet(context.Context, *ORSetRequest) (*ORSetResponse, error)

+ func (*UnimplementedTckCrdtServer) ProcessPNCounter(context.Context, *PNCounterRequest) (*PNCounterResponse, error)

+ func (*UnimplementedTckCrdtServer) ProcessVote(context.Context, *VoteRequest) (*VoteResponse, error)

+ type VoteRequest struct

+ Actions []*VoteRequestAction

+ Id string

+ func (*VoteRequest) Descriptor() ([]byte, []int)

+ func (*VoteRequest) ProtoMessage()

+ func (x *VoteRequest) GetActions() []*VoteRequestAction

+ func (x *VoteRequest) GetId() string

+ func (x *VoteRequest) ProtoReflect() protoreflect.Message

+ func (x *VoteRequest) Reset()

+ func (x *VoteRequest) String() string

+ type VoteRequestAction struct

+ Action isVoteRequestAction_Action

+ func (*VoteRequestAction) Descriptor() ([]byte, []int)

+ func (*VoteRequestAction) ProtoMessage()

+ func (m *VoteRequestAction) GetAction() isVoteRequestAction_Action

+ func (x *VoteRequestAction) GetDelete() *Delete

+ func (x *VoteRequestAction) GetGet() *Get

+ func (x *VoteRequestAction) GetVote() *VoteVote

+ func (x *VoteRequestAction) ProtoReflect() protoreflect.Message

+ func (x *VoteRequestAction) Reset()

+ func (x *VoteRequestAction) String() string

+ type VoteRequestAction_Delete struct

+ Delete *Delete

+ type VoteRequestAction_Get struct

+ Get *Get

+ type VoteRequestAction_Vote struct

+ Vote *VoteVote

+ type VoteResponse struct

+ SelfVote bool

+ Voters uint32

+ VotesFor uint32

+ func (*VoteResponse) Descriptor() ([]byte, []int)

+ func (*VoteResponse) ProtoMessage()

+ func (x *VoteResponse) GetSelfVote() bool

+ func (x *VoteResponse) GetVoters() uint32

+ func (x *VoteResponse) GetVotesFor() uint32

+ func (x *VoteResponse) ProtoReflect() protoreflect.Message

+ func (x *VoteResponse) Reset()

+ func (x *VoteResponse) String() string

+ type VoteVote struct

+ FailWith string

+ Key string

+ Value bool

+ func (*VoteVote) Descriptor() ([]byte, []int)

+ func (*VoteVote) ProtoMessage()

+ func (x *VoteVote) GetFailWith() string

+ func (x *VoteVote) GetKey() string

+ func (x *VoteVote) GetValue() bool

+ func (x *VoteVote) ProtoReflect() protoreflect.Message

+ func (x *VoteVote) Reset()

+ func (x *VoteVote) String() string