crdt

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 13, 2021 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	CrdtClock_name = map[int32]string{
		0: "DEFAULT",
		1: "REVERSE",
		2: "CUSTOM",
		3: "CUSTOM_AUTO_INCREMENT",
	}
	CrdtClock_value = map[string]int32{
		"DEFAULT":               0,
		"REVERSE":               1,
		"CUSTOM":                2,
		"CUSTOM_AUTO_INCREMENT": 3,
	}
)

Enum value maps for CrdtClock.

View Source 
var File_tck_crdt_proto protoreflect.FileDescriptor

Functions

func RegisterTckCrdtServer 

func RegisterTckCrdtServer(s grpc.ServiceRegistrar, srv TckCrdtServer)

Types

type AnySupportType 

type AnySupportType struct {

	// Types that are assignable to Value:
	//	*AnySupportType_AnyValue
	//	*AnySupportType_StringValue
	//	*AnySupportType_BytesValue
	//	*AnySupportType_Int32Value
	//	*AnySupportType_Int64Value
	//	*AnySupportType_FloatValue
	//	*AnySupportType_DoubleValue
	//	*AnySupportType_BoolValue
	Value isAnySupportType_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*AnySupportType) Descriptor deprecated 

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

Deprecated: Use AnySupportType.ProtoReflect.Descriptor instead.

func (*AnySupportType) GetAnyValue 

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

func (*AnySupportType) GetBoolValue 

func (x *AnySupportType) GetBoolValue() bool

func (*AnySupportType) GetBytesValue 

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

func (*AnySupportType) GetDoubleValue 

func (x *AnySupportType) GetDoubleValue() float64

func (*AnySupportType) GetFloatValue 

func (x *AnySupportType) GetFloatValue() float32

func (*AnySupportType) GetInt32Value 

func (x *AnySupportType) GetInt32Value() int32

func (*AnySupportType) GetInt64Value 

func (x *AnySupportType) GetInt64Value() int64

func (*AnySupportType) GetStringValue 

func (x *AnySupportType) GetStringValue() string

func (*AnySupportType) GetValue 

func (m *AnySupportType) GetValue() isAnySupportType_Value

func (*AnySupportType) ProtoMessage 

func (*AnySupportType) ProtoMessage()

func (*AnySupportType) ProtoReflect 

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

func (*AnySupportType) Reset 

func (x *AnySupportType) Reset()

func (*AnySupportType) String 

func (x *AnySupportType) String() string

type AnySupportType_AnyValue 

type AnySupportType_AnyValue struct {
	AnyValue *any.Any `protobuf:"bytes,3,opt,name=any_value,json=anyValue,proto3,oneof"`
}

type AnySupportType_BoolValue 

type AnySupportType_BoolValue struct {
	BoolValue bool `protobuf:"varint,10,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

type AnySupportType_BytesValue 

type AnySupportType_BytesValue struct {
	BytesValue []byte `protobuf:"bytes,5,opt,name=bytes_value,json=bytesValue,proto3,oneof"`
}

type AnySupportType_DoubleValue 

type AnySupportType_DoubleValue struct {
	DoubleValue float64 `protobuf:"fixed64,9,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type AnySupportType_FloatValue 

type AnySupportType_FloatValue struct {
	FloatValue float32 `protobuf:"fixed32,8,opt,name=float_value,json=floatValue,proto3,oneof"`
}

type AnySupportType_Int32Value 

type AnySupportType_Int32Value struct {
	Int32Value int32 `protobuf:"varint,6,opt,name=int32_value,json=int32Value,proto3,oneof"`
}

type AnySupportType_Int64Value 

type AnySupportType_Int64Value struct {
	Int64Value int64 `protobuf:"varint,7,opt,name=int64_value,json=int64Value,proto3,oneof"`
}

type AnySupportType_StringValue 

type AnySupportType_StringValue struct {
	StringValue string `protobuf:"bytes,4,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type CrdtClock 

type CrdtClock int32

copy from crdt.proto 

const (
	// Use the default clock for deciding the last write, which is the system clocks
	// milliseconds since epoch.
	CrdtClock_DEFAULT CrdtClock = 0
	// Use the reverse semantics with the default clock, to enable first write wins.
	CrdtClock_REVERSE CrdtClock = 1
	// Use a custom clock value, set using custom_clock_value.
	CrdtClock_CUSTOM CrdtClock = 2
	// Use a custom clock value, but automatically increment it by one if the clock
	// value from the current value is equal to the custom_clock_value.
	CrdtClock_CUSTOM_AUTO_INCREMENT CrdtClock = 3
)

func (CrdtClock) Descriptor 

func (CrdtClock) Descriptor() protoreflect.EnumDescriptor

func (CrdtClock) Enum 

func (x CrdtClock) Enum() *CrdtClock

func (CrdtClock) EnumDescriptor deprecated 

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

Deprecated: Use CrdtClock.Descriptor instead.

func (CrdtClock) Number 

func (x CrdtClock) Number() protoreflect.EnumNumber

func (CrdtClock) String 

func (x CrdtClock) String() string

func (CrdtClock) Type 

func (CrdtClock) Type() protoreflect.EnumType

type Delete 

type Delete struct {
	Key      string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	FailWith string `protobuf:"bytes,2,opt,name=failWith,proto3" json:"failWith,omitempty"`
	// contains filtered or unexported fields
}

func (*Delete) Descriptor deprecated 

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

Deprecated: Use Delete.ProtoReflect.Descriptor instead.

func (*Delete) GetFailWith 

func (x *Delete) GetFailWith() string

func (*Delete) GetKey 

func (x *Delete) GetKey() string

func (*Delete) ProtoMessage 

func (*Delete) ProtoMessage()

func (*Delete) ProtoReflect 

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

func (*Delete) Reset 

func (x *Delete) Reset()

func (*Delete) String 

func (x *Delete) String() string

type FlagEnable 

type FlagEnable struct {
	Key      string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	FailWith string `protobuf:"bytes,2,opt,name=failWith,proto3" json:"failWith,omitempty"`
	// contains filtered or unexported fields
}

func (*FlagEnable) Descriptor deprecated 

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

Deprecated: Use FlagEnable.ProtoReflect.Descriptor instead.

func (*FlagEnable) GetFailWith 

func (x *FlagEnable) GetFailWith() string

func (*FlagEnable) GetKey 

func (x *FlagEnable) GetKey() string

func (*FlagEnable) ProtoMessage 

func (*FlagEnable) ProtoMessage()

func (*FlagEnable) ProtoReflect 

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

func (*FlagEnable) Reset 

func (x *FlagEnable) Reset()

func (*FlagEnable) String 

func (x *FlagEnable) String() string

type FlagRequest 

type FlagRequest struct {
	Id      string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Actions []*FlagRequestAction `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions,omitempty"`
	// contains filtered or unexported fields
}

func (*FlagRequest) Descriptor deprecated 

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

Deprecated: Use FlagRequest.ProtoReflect.Descriptor instead.

func (*FlagRequest) GetActions 

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

func (*FlagRequest) GetId 

func (x *FlagRequest) GetId() string

func (*FlagRequest) ProtoMessage 

func (*FlagRequest) ProtoMessage()

func (*FlagRequest) ProtoReflect 

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

func (*FlagRequest) Reset 

func (x *FlagRequest) Reset()

func (*FlagRequest) String 

func (x *FlagRequest) String() string

type FlagRequestAction 

type FlagRequestAction struct {

	// Types that are assignable to Action:
	//	*FlagRequestAction_Get
	//	*FlagRequestAction_Delete
	//	*FlagRequestAction_Enable
	Action isFlagRequestAction_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

func (*FlagRequestAction) Descriptor deprecated 

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

Deprecated: Use FlagRequestAction.ProtoReflect.Descriptor instead.

func (*FlagRequestAction) GetAction 

func (m *FlagRequestAction) GetAction() isFlagRequestAction_Action

func (*FlagRequestAction) GetDelete 

func (x *FlagRequestAction) GetDelete() *Delete

func (*FlagRequestAction) GetEnable 

func (x *FlagRequestAction) GetEnable() *FlagEnable

func (*FlagRequestAction) GetGet 

func (x *FlagRequestAction) GetGet() *Get

func (*FlagRequestAction) ProtoMessage 

func (*FlagRequestAction) ProtoMessage()

func (*FlagRequestAction) ProtoReflect 

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

func (*FlagRequestAction) Reset 

func (x *FlagRequestAction) Reset()

func (*FlagRequestAction) String 

func (x *FlagRequestAction) String() string

type FlagRequestAction_Delete 

type FlagRequestAction_Delete struct {
	Delete *Delete `protobuf:"bytes,2,opt,name=delete,proto3,oneof"`
}

type FlagRequestAction_Enable 

type FlagRequestAction_Enable struct {
	Enable *FlagEnable `protobuf:"bytes,3,opt,name=enable,proto3,oneof"`
}

type FlagRequestAction_Get 

type FlagRequestAction_Get struct {
	Get *Get `protobuf:"bytes,1,opt,name=get,proto3,oneof"`
}

type FlagResponse 

type FlagResponse struct {
	Value *FlagValue `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*FlagResponse) Descriptor deprecated 

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

Deprecated: Use FlagResponse.ProtoReflect.Descriptor instead.

func (*FlagResponse) GetValue 

func (x *FlagResponse) GetValue() *FlagValue

func (*FlagResponse) ProtoMessage 

func (*FlagResponse) ProtoMessage()

func (*FlagResponse) ProtoReflect 

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

func (*FlagResponse) Reset 

func (x *FlagResponse) Reset()

func (*FlagResponse) String 

func (x *FlagResponse) String() string

type FlagValue 

type FlagValue struct {
	Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*FlagValue) Descriptor deprecated 

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

Deprecated: Use FlagValue.ProtoReflect.Descriptor instead.

func (*FlagValue) GetValue 

func (x *FlagValue) GetValue() bool

func (*FlagValue) ProtoMessage 

func (*FlagValue) ProtoMessage()

func (*FlagValue) ProtoReflect 

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

func (*FlagValue) Reset 

func (x *FlagValue) Reset()

func (*FlagValue) String 

func (x *FlagValue) String() string

type GCounterIncrement 

type GCounterIncrement struct {
	Key      string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	FailWith string `protobuf:"bytes,2,opt,name=failWith,proto3" json:"failWith,omitempty"`
	Value    uint64 `protobuf:"varint,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*GCounterIncrement) Descriptor deprecated 

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

Deprecated: Use GCounterIncrement.ProtoReflect.Descriptor instead.

func (*GCounterIncrement) GetFailWith 

func (x *GCounterIncrement) GetFailWith() string

func (*GCounterIncrement) GetKey 

func (x *GCounterIncrement) GetKey() string

func (*GCounterIncrement) GetValue 

func (x *GCounterIncrement) GetValue() uint64

func (*GCounterIncrement) ProtoMessage 

func (*GCounterIncrement) ProtoMessage()

func (*GCounterIncrement) ProtoReflect 

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

func (*GCounterIncrement) Reset 

func (x *GCounterIncrement) Reset()

func (*GCounterIncrement) String 

func (x *GCounterIncrement) String() string

type GCounterRequest 

type GCounterRequest struct {
	Id      string                   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Actions []*GCounterRequestAction `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions,omitempty"`
	// contains filtered or unexported fields
}

func (*GCounterRequest) Descriptor deprecated 

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

Deprecated: Use GCounterRequest.ProtoReflect.Descriptor instead.

func (*GCounterRequest) GetActions 

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

func (*GCounterRequest) GetId 

func (x *GCounterRequest) GetId() string

func (*GCounterRequest) ProtoMessage 

func (*GCounterRequest) ProtoMessage()

func (*GCounterRequest) ProtoReflect 

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

func (*GCounterRequest) Reset 

func (x *GCounterRequest) Reset()

func (*GCounterRequest) String 

func (x *GCounterRequest) String() string

type GCounterRequestAction 

type GCounterRequestAction struct {

	// Types that are assignable to Action:
	//	*GCounterRequestAction_Get
	//	*GCounterRequestAction_Delete
	//	*GCounterRequestAction_Increment
	Action isGCounterRequestAction_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

func (*GCounterRequestAction) Descriptor deprecated 

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

Deprecated: Use GCounterRequestAction.ProtoReflect.Descriptor instead.

func (*GCounterRequestAction) GetAction 

func (m *GCounterRequestAction) GetAction() isGCounterRequestAction_Action

func (*GCounterRequestAction) GetDelete 

func (x *GCounterRequestAction) GetDelete() *Delete

func (*GCounterRequestAction) GetGet 

func (x *GCounterRequestAction) GetGet() *Get

func (*GCounterRequestAction) GetIncrement 

func (x *GCounterRequestAction) GetIncrement() *GCounterIncrement

func (*GCounterRequestAction) ProtoMessage 

func (*GCounterRequestAction) ProtoMessage()

func (*GCounterRequestAction) ProtoReflect 

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

func (*GCounterRequestAction) Reset 

func (x *GCounterRequestAction) Reset()

func (*GCounterRequestAction) String 

func (x *GCounterRequestAction) String() string

type GCounterRequestAction_Delete 

type GCounterRequestAction_Delete struct {
	Delete *Delete `protobuf:"bytes,2,opt,name=delete,proto3,oneof"`
}

type GCounterRequestAction_Get 

type GCounterRequestAction_Get struct {
	Get *Get `protobuf:"bytes,1,opt,name=get,proto3,oneof"`
}

type GCounterRequestAction_Increment 

type GCounterRequestAction_Increment struct {
	Increment *GCounterIncrement `protobuf:"bytes,3,opt,name=increment,proto3,oneof"`
}

type GCounterResponse 

type GCounterResponse struct {
	Value *GCounterValue `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*GCounterResponse) Descriptor deprecated 

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

Deprecated: Use GCounterResponse.ProtoReflect.Descriptor instead.

func (*GCounterResponse) GetValue 

func (x *GCounterResponse) GetValue() *GCounterValue

func (*GCounterResponse) ProtoMessage 

func (*GCounterResponse) ProtoMessage()

func (*GCounterResponse) ProtoReflect 

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

func (*GCounterResponse) Reset 

func (x *GCounterResponse) Reset()

func (*GCounterResponse) String 

func (x *GCounterResponse) String() string

type GCounterValue 

type GCounterValue struct {
	Value uint64 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*GCounterValue) Descriptor deprecated 

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

Deprecated: Use GCounterValue.ProtoReflect.Descriptor instead.

func (*GCounterValue) GetValue 

func (x *GCounterValue) GetValue() uint64

func (*GCounterValue) ProtoMessage 

func (*GCounterValue) ProtoMessage()

func (*GCounterValue) ProtoReflect 

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

func (*GCounterValue) Reset 

func (x *GCounterValue) Reset()

func (*GCounterValue) String 

func (x *GCounterValue) String() string

type GSetAdd 

type GSetAdd struct {
	Key      string          `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	FailWith string          `protobuf:"bytes,2,opt,name=failWith,proto3" json:"failWith,omitempty"`
	Value    *AnySupportType `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*GSetAdd) Descriptor deprecated 

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

Deprecated: Use GSetAdd.ProtoReflect.Descriptor instead.

func (*GSetAdd) GetFailWith 

func (x *GSetAdd) GetFailWith() string

func (*GSetAdd) GetKey 

func (x *GSetAdd) GetKey() string

func (*GSetAdd) GetValue 

func (x *GSetAdd) GetValue() *AnySupportType

func (*GSetAdd) ProtoMessage 

func (*GSetAdd) ProtoMessage()

func (*GSetAdd) ProtoReflect 

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

func (*GSetAdd) Reset 

func (x *GSetAdd) Reset()

func (*GSetAdd) String 

func (x *GSetAdd) String() string

type GSetRequest 

type GSetRequest struct {
	Id      string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Actions []*GSetRequestAction `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions,omitempty"`
	// contains filtered or unexported fields
}

func (*GSetRequest) Descriptor deprecated 

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

Deprecated: Use GSetRequest.ProtoReflect.Descriptor instead.

func (*GSetRequest) GetActions 

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

func (*GSetRequest) GetId 

func (x *GSetRequest) GetId() string

func (*GSetRequest) ProtoMessage 

func (*GSetRequest) ProtoMessage()

func (*GSetRequest) ProtoReflect 

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

func (*GSetRequest) Reset 

func (x *GSetRequest) Reset()

func (*GSetRequest) String 

func (x *GSetRequest) String() string

type GSetRequestAction 

type GSetRequestAction struct {

	// Types that are assignable to Action:
	//	*GSetRequestAction_Get
	//	*GSetRequestAction_Delete
	//	*GSetRequestAction_Add
	Action isGSetRequestAction_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

func (*GSetRequestAction) Descriptor deprecated 

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

Deprecated: Use GSetRequestAction.ProtoReflect.Descriptor instead.

func (*GSetRequestAction) GetAction 

func (m *GSetRequestAction) GetAction() isGSetRequestAction_Action

func (*GSetRequestAction) GetAdd 

func (x *GSetRequestAction) GetAdd() *GSetAdd

func (*GSetRequestAction) GetDelete 

func (x *GSetRequestAction) GetDelete() *Delete

func (*GSetRequestAction) GetGet 

func (x *GSetRequestAction) GetGet() *Get

func (*GSetRequestAction) ProtoMessage 

func (*GSetRequestAction) ProtoMessage()

func (*GSetRequestAction) ProtoReflect 

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

func (*GSetRequestAction) Reset 

func (x *GSetRequestAction) Reset()

func (*GSetRequestAction) String 

func (x *GSetRequestAction) String() string

type GSetRequestAction_Add 

type GSetRequestAction_Add struct {
	Add *GSetAdd `protobuf:"bytes,3,opt,name=add,proto3,oneof"`
}

type GSetRequestAction_Delete 

type GSetRequestAction_Delete struct {
	Delete *Delete `protobuf:"bytes,2,opt,name=delete,proto3,oneof"`
}

type GSetRequestAction_Get 

type GSetRequestAction_Get struct {
	Get *Get `protobuf:"bytes,1,opt,name=get,proto3,oneof"`
}

type GSetResponse 

type GSetResponse struct {
	Value *GSetValue `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*GSetResponse) Descriptor deprecated 

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

Deprecated: Use GSetResponse.ProtoReflect.Descriptor instead.

func (*GSetResponse) GetValue 

func (x *GSetResponse) GetValue() *GSetValue

func (*GSetResponse) ProtoMessage 

func (*GSetResponse) ProtoMessage()

func (*GSetResponse) ProtoReflect 

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

func (*GSetResponse) Reset 

func (x *GSetResponse) Reset()

func (*GSetResponse) String 

func (x *GSetResponse) String() string

type GSetValue 

type GSetValue struct {
	Values []*AnySupportType `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*GSetValue) Descriptor deprecated 

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

Deprecated: Use GSetValue.ProtoReflect.Descriptor instead.

func (*GSetValue) GetValues 

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

func (*GSetValue) ProtoMessage 

func (*GSetValue) ProtoMessage()

func (*GSetValue) ProtoReflect 

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

func (*GSetValue) Reset 

func (x *GSetValue) Reset()

func (*GSetValue) String 

func (x *GSetValue) String() string

type GSetValueAnySupport 

type GSetValueAnySupport struct {
	Values []*AnySupportType `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*GSetValueAnySupport) Descriptor deprecated 

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

Deprecated: Use GSetValueAnySupport.ProtoReflect.Descriptor instead.

func (*GSetValueAnySupport) GetValues 

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

func (*GSetValueAnySupport) ProtoMessage 

func (*GSetValueAnySupport) ProtoMessage()

func (*GSetValueAnySupport) ProtoReflect 

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

func (*GSetValueAnySupport) Reset 

func (x *GSetValueAnySupport) Reset()

func (*GSetValueAnySupport) String 

func (x *GSetValueAnySupport) String() string

type Get 

type Get struct {
	Key      string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	FailWith string `protobuf:"bytes,2,opt,name=failWith,proto3" json:"failWith,omitempty"`
	// contains filtered or unexported fields
}

func (*Get) Descriptor deprecated 

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

Deprecated: Use Get.ProtoReflect.Descriptor instead.

func (*Get) GetFailWith 

func (x *Get) GetFailWith() string

func (*Get) GetKey 

func (x *Get) GetKey() string

func (*Get) ProtoMessage 

func (*Get) ProtoMessage()

func (*Get) ProtoReflect 

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

func (*Get) Reset 

func (x *Get) Reset()

func (*Get) String 

func (x *Get) String() string

type LWWRegisterRequest 

type LWWRegisterRequest struct {
	Id      string                      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Actions []*LWWRegisterRequestAction `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions,omitempty"`
	// contains filtered or unexported fields
}

func (*LWWRegisterRequest) Descriptor deprecated 

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

Deprecated: Use LWWRegisterRequest.ProtoReflect.Descriptor instead.

func (*LWWRegisterRequest) GetActions 

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

func (*LWWRegisterRequest) GetId 

func (x *LWWRegisterRequest) GetId() string

func (*LWWRegisterRequest) ProtoMessage 

func (*LWWRegisterRequest) ProtoMessage()

func (*LWWRegisterRequest) ProtoReflect 

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

func (*LWWRegisterRequest) Reset 

func (x *LWWRegisterRequest) Reset()

func (*LWWRegisterRequest) String 

func (x *LWWRegisterRequest) String() string

type LWWRegisterRequestAction 

type LWWRegisterRequestAction struct {

	// Types that are assignable to Action:
	//	*LWWRegisterRequestAction_Get
	//	*LWWRegisterRequestAction_Delete
	//	*LWWRegisterRequestAction_Set
	//	*LWWRegisterRequestAction_SetWithClock
	Action isLWWRegisterRequestAction_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

func (*LWWRegisterRequestAction) Descriptor deprecated 

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

Deprecated: Use LWWRegisterRequestAction.ProtoReflect.Descriptor instead.

func (*LWWRegisterRequestAction) GetAction 

func (m *LWWRegisterRequestAction) GetAction() isLWWRegisterRequestAction_Action

func (*LWWRegisterRequestAction) GetDelete 

func (x *LWWRegisterRequestAction) GetDelete() *Delete

func (*LWWRegisterRequestAction) GetGet 

func (x *LWWRegisterRequestAction) GetGet() *Get

func (*LWWRegisterRequestAction) GetSet 

func (x *LWWRegisterRequestAction) GetSet() *LWWRegisterSet

func (*LWWRegisterRequestAction) GetSetWithClock 

func (x *LWWRegisterRequestAction) GetSetWithClock() *LWWRegisterSetWithClock

func (*LWWRegisterRequestAction) ProtoMessage 

func (*LWWRegisterRequestAction) ProtoMessage()

func (*LWWRegisterRequestAction) ProtoReflect 

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

func (*LWWRegisterRequestAction) Reset 

func (x *LWWRegisterRequestAction) Reset()

func (*LWWRegisterRequestAction) String 

func (x *LWWRegisterRequestAction) String() string

type LWWRegisterRequestAction_Delete 

type LWWRegisterRequestAction_Delete struct {
	Delete *Delete `protobuf:"bytes,2,opt,name=delete,proto3,oneof"`
}

type LWWRegisterRequestAction_Get 

type LWWRegisterRequestAction_Get struct {
	Get *Get `protobuf:"bytes,1,opt,name=get,proto3,oneof"`
}

type LWWRegisterRequestAction_Set 

type LWWRegisterRequestAction_Set struct {
	Set *LWWRegisterSet `protobuf:"bytes,3,opt,name=set,proto3,oneof"`
}

type LWWRegisterRequestAction_SetWithClock 

type LWWRegisterRequestAction_SetWithClock struct {
	SetWithClock *LWWRegisterSetWithClock `protobuf:"bytes,4,opt,name=setWithClock,proto3,oneof"`
}

type LWWRegisterResponse 

type LWWRegisterResponse struct {
	Value *LWWRegisterValue `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*LWWRegisterResponse) Descriptor deprecated 

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

Deprecated: Use LWWRegisterResponse.ProtoReflect.Descriptor instead.

func (*LWWRegisterResponse) GetValue 

func (x *LWWRegisterResponse) GetValue() *LWWRegisterValue

func (*LWWRegisterResponse) ProtoMessage 

func (*LWWRegisterResponse) ProtoMessage()

func (*LWWRegisterResponse) ProtoReflect 

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

func (*LWWRegisterResponse) Reset 

func (x *LWWRegisterResponse) Reset()

func (*LWWRegisterResponse) String 

func (x *LWWRegisterResponse) String() string

type LWWRegisterSet 

type LWWRegisterSet struct {
	Key      string          `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	FailWith string          `protobuf:"bytes,2,opt,name=failWith,proto3" json:"failWith,omitempty"`
	Value    *AnySupportType `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*LWWRegisterSet) Descriptor deprecated 

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

Deprecated: Use LWWRegisterSet.ProtoReflect.Descriptor instead.

func (*LWWRegisterSet) GetFailWith 

func (x *LWWRegisterSet) GetFailWith() string

func (*LWWRegisterSet) GetKey 

func (x *LWWRegisterSet) GetKey() string

func (*LWWRegisterSet) GetValue 

func (x *LWWRegisterSet) GetValue() *AnySupportType

func (*LWWRegisterSet) ProtoMessage 

func (*LWWRegisterSet) ProtoMessage()

func (*LWWRegisterSet) ProtoReflect 

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

func (*LWWRegisterSet) Reset 

func (x *LWWRegisterSet) Reset()

func (*LWWRegisterSet) String 

func (x *LWWRegisterSet) String() string

type LWWRegisterSetWithClock 

type LWWRegisterSetWithClock struct {
	Key              string          `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	FailWith         string          `protobuf:"bytes,2,opt,name=failWith,proto3" json:"failWith,omitempty"`
	Value            *AnySupportType `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Clock            CrdtClock       `protobuf:"varint,4,opt,name=clock,proto3,enum=crdt.CrdtClock" json:"clock,omitempty"`
	CustomClockValue int64           `protobuf:"varint,5,opt,name=custom_clock_value,json=customClockValue,proto3" json:"custom_clock_value,omitempty"`
	// contains filtered or unexported fields
}

func (*LWWRegisterSetWithClock) Descriptor deprecated 

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

Deprecated: Use LWWRegisterSetWithClock.ProtoReflect.Descriptor instead.

func (*LWWRegisterSetWithClock) GetClock 

func (x *LWWRegisterSetWithClock) GetClock() CrdtClock

func (*LWWRegisterSetWithClock) GetCustomClockValue 

func (x *LWWRegisterSetWithClock) GetCustomClockValue() int64

func (*LWWRegisterSetWithClock) GetFailWith 

func (x *LWWRegisterSetWithClock) GetFailWith() string

func (*LWWRegisterSetWithClock) GetKey 

func (x *LWWRegisterSetWithClock) GetKey() string

func (*LWWRegisterSetWithClock) GetValue 

func (x *LWWRegisterSetWithClock) GetValue() *AnySupportType

func (*LWWRegisterSetWithClock) ProtoMessage 

func (*LWWRegisterSetWithClock) ProtoMessage()

func (*LWWRegisterSetWithClock) ProtoReflect 

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

func (*LWWRegisterSetWithClock) Reset 

func (x *LWWRegisterSetWithClock) Reset()

func (*LWWRegisterSetWithClock) String 

func (x *LWWRegisterSetWithClock) String() string

type LWWRegisterValue 

type LWWRegisterValue struct {
	Value *any.Any `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*LWWRegisterValue) Descriptor deprecated 

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

Deprecated: Use LWWRegisterValue.ProtoReflect.Descriptor instead.

func (*LWWRegisterValue) GetValue 

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

func (*LWWRegisterValue) ProtoMessage 

func (*LWWRegisterValue) ProtoMessage()

func (*LWWRegisterValue) ProtoReflect 

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

func (*LWWRegisterValue) Reset 

func (x *LWWRegisterValue) Reset()

func (*LWWRegisterValue) String 

func (x *LWWRegisterValue) String() string

type ORMapActionRequest 

type ORMapActionRequest struct {
	Key      string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	FailWith string   `protobuf:"bytes,2,opt,name=failWith,proto3" json:"failWith,omitempty"`
	EntryKey *any.Any `protobuf:"bytes,3,opt,name=entry_key,json=entryKey,proto3" json:"entry_key,omitempty"`
	// Types that are assignable to Request:
	//	*ORMapActionRequest_GCounterRequest
	//	*ORMapActionRequest_PnCounterRequest
	//	*ORMapActionRequest_GsetRequest
	//	*ORMapActionRequest_OrSetRequest
	//	*ORMapActionRequest_FlagRequest
	//	*ORMapActionRequest_LwwRegisterRequest
	//	*ORMapActionRequest_OrMapRequest
	//	*ORMapActionRequest_VoteRequest
	Request isORMapActionRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

func (*ORMapActionRequest) Descriptor deprecated 

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

Deprecated: Use ORMapActionRequest.ProtoReflect.Descriptor instead.

func (*ORMapActionRequest) GetEntryKey 

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

func (*ORMapActionRequest) GetFailWith 

func (x *ORMapActionRequest) GetFailWith() string

func (*ORMapActionRequest) GetFlagRequest 

func (x *ORMapActionRequest) GetFlagRequest() *FlagRequest

func (*ORMapActionRequest) GetGCounterRequest 

func (x *ORMapActionRequest) GetGCounterRequest() *GCounterRequest

func (*ORMapActionRequest) GetGsetRequest 

func (x *ORMapActionRequest) GetGsetRequest() *GSetRequest

func (*ORMapActionRequest) GetKey 

func (x *ORMapActionRequest) GetKey() string

func (*ORMapActionRequest) GetLwwRegisterRequest 

func (x *ORMapActionRequest) GetLwwRegisterRequest() *LWWRegisterRequest

func (*ORMapActionRequest) GetOrMapRequest 

func (x *ORMapActionRequest) GetOrMapRequest() *ORMapRequest

func (*ORMapActionRequest) GetOrSetRequest 

func (x *ORMapActionRequest) GetOrSetRequest() *ORSetRequest

func (*ORMapActionRequest) GetPnCounterRequest 

func (x *ORMapActionRequest) GetPnCounterRequest() *PNCounterRequest

func (*ORMapActionRequest) GetRequest 

func (m *ORMapActionRequest) GetRequest() isORMapActionRequest_Request

func (*ORMapActionRequest) GetVoteRequest 

func (x *ORMapActionRequest) GetVoteRequest() *VoteRequest

func (*ORMapActionRequest) ProtoMessage 

func (*ORMapActionRequest) ProtoMessage()

func (*ORMapActionRequest) ProtoReflect 

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

func (*ORMapActionRequest) Reset 

func (x *ORMapActionRequest) Reset()

func (*ORMapActionRequest) String 

func (x *ORMapActionRequest) String() string

type ORMapActionRequest_FlagRequest 

type ORMapActionRequest_FlagRequest struct {
	FlagRequest *FlagRequest `protobuf:"bytes,8,opt,name=flagRequest,proto3,oneof"`
}

type ORMapActionRequest_GCounterRequest 

type ORMapActionRequest_GCounterRequest struct {
	GCounterRequest *GCounterRequest `protobuf:"bytes,4,opt,name=gCounterRequest,proto3,oneof"`
}

type ORMapActionRequest_GsetRequest 

type ORMapActionRequest_GsetRequest struct {
	GsetRequest *GSetRequest `protobuf:"bytes,6,opt,name=gsetRequest,proto3,oneof"`
}

type ORMapActionRequest_LwwRegisterRequest 

type ORMapActionRequest_LwwRegisterRequest struct {
	LwwRegisterRequest *LWWRegisterRequest `protobuf:"bytes,9,opt,name=lwwRegisterRequest,proto3,oneof"`
}

type ORMapActionRequest_OrMapRequest 

type ORMapActionRequest_OrMapRequest struct {
	OrMapRequest *ORMapRequest `protobuf:"bytes,10,opt,name=orMapRequest,proto3,oneof"`
}

type ORMapActionRequest_OrSetRequest 

type ORMapActionRequest_OrSetRequest struct {
	OrSetRequest *ORSetRequest `protobuf:"bytes,7,opt,name=orSetRequest,proto3,oneof"`
}

type ORMapActionRequest_PnCounterRequest 

type ORMapActionRequest_PnCounterRequest struct {
	PnCounterRequest *PNCounterRequest `protobuf:"bytes,5,opt,name=pnCounterRequest,proto3,oneof"`
}

type ORMapActionRequest_VoteRequest 

type ORMapActionRequest_VoteRequest struct {
	VoteRequest *VoteRequest `protobuf:"bytes,11,opt,name=voteRequest,proto3,oneof"`
}

type ORMapDelete 

type ORMapDelete struct {
	Key      string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	FailWith string   `protobuf:"bytes,2,opt,name=failWith,proto3" json:"failWith,omitempty"`
	EntryKey *any.Any `protobuf:"bytes,3,opt,name=entry_key,json=entryKey,proto3" json:"entry_key,omitempty"`
	// contains filtered or unexported fields
}

func (*ORMapDelete) Descriptor deprecated 

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

Deprecated: Use ORMapDelete.ProtoReflect.Descriptor instead.

func (*ORMapDelete) GetEntryKey 

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

func (*ORMapDelete) GetFailWith 

func (x *ORMapDelete) GetFailWith() string

func (*ORMapDelete) GetKey 

func (x *ORMapDelete) GetKey() string

func (*ORMapDelete) ProtoMessage 

func (*ORMapDelete) ProtoMessage()

func (*ORMapDelete) ProtoReflect 

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

func (*ORMapDelete) Reset 

func (x *ORMapDelete) Reset()

func (*ORMapDelete) String 

func (x *ORMapDelete) String() string

type ORMapEntries 

type ORMapEntries struct {
	Values []*ORMapEntry `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ORMapEntries) Descriptor deprecated 

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

Deprecated: Use ORMapEntries.ProtoReflect.Descriptor instead.

func (*ORMapEntries) GetValues 

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

func (*ORMapEntries) ProtoMessage 

func (*ORMapEntries) ProtoMessage()

func (*ORMapEntries) ProtoReflect 

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

func (*ORMapEntries) Reset 

func (x *ORMapEntries) Reset()

func (*ORMapEntries) String 

func (x *ORMapEntries) String() string

type ORMapEntry 

type ORMapEntry struct {
	EntryKey *any.Any `protobuf:"bytes,1,opt,name=entry_key,json=entryKey,proto3" json:"entry_key,omitempty"`
	Value    *any.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ORMapEntry) Descriptor deprecated 

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

Deprecated: Use ORMapEntry.ProtoReflect.Descriptor instead.

func (*ORMapEntry) GetEntryKey 

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

func (*ORMapEntry) GetValue 

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

func (*ORMapEntry) ProtoMessage 

func (*ORMapEntry) ProtoMessage()

func (*ORMapEntry) ProtoReflect 

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

func (*ORMapEntry) Reset 

func (x *ORMapEntry) Reset()

func (*ORMapEntry) String 

func (x *ORMapEntry) String() string

type ORMapKeys 

type ORMapKeys struct {
	Values []*any.Any `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ORMapKeys) Descriptor deprecated 

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

Deprecated: Use ORMapKeys.ProtoReflect.Descriptor instead.

func (*ORMapKeys) GetValues 

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

func (*ORMapKeys) ProtoMessage 

func (*ORMapKeys) ProtoMessage()

func (*ORMapKeys) ProtoReflect 

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

func (*ORMapKeys) Reset 

func (x *ORMapKeys) Reset()

func (*ORMapKeys) String 

func (x *ORMapKeys) String() string

type ORMapRequest 

type ORMapRequest struct {
	Id      string                `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Actions []*ORMapRequestAction `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions,omitempty"`
	// contains filtered or unexported fields
}

func (*ORMapRequest) Descriptor deprecated 

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

Deprecated: Use ORMapRequest.ProtoReflect.Descriptor instead.

func (*ORMapRequest) GetActions 

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

func (*ORMapRequest) GetId 

func (x *ORMapRequest) GetId() string

func (*ORMapRequest) ProtoMessage 

func (*ORMapRequest) ProtoMessage()

func (*ORMapRequest) ProtoReflect 

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

func (*ORMapRequest) Reset 

func (x *ORMapRequest) Reset()

func (*ORMapRequest) String 

func (x *ORMapRequest) String() string

type ORMapRequestAction 

type ORMapRequestAction struct {

	// Types that are assignable to Action:
	//	*ORMapRequestAction_Get
	//	*ORMapRequestAction_Delete
	//	*ORMapRequestAction_SetKey
	//	*ORMapRequestAction_DeleteKey
	//	*ORMapRequestAction_Request
	Action isORMapRequestAction_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

func (*ORMapRequestAction) Descriptor deprecated 

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

Deprecated: Use ORMapRequestAction.ProtoReflect.Descriptor instead.

func (*ORMapRequestAction) GetAction 

func (m *ORMapRequestAction) GetAction() isORMapRequestAction_Action

func (*ORMapRequestAction) GetDelete 

func (x *ORMapRequestAction) GetDelete() *Delete

func (*ORMapRequestAction) GetDeleteKey 

func (x *ORMapRequestAction) GetDeleteKey() *ORMapDelete

func (*ORMapRequestAction) GetGet 

func (x *ORMapRequestAction) GetGet() *Get

func (*ORMapRequestAction) GetRequest 

func (x *ORMapRequestAction) GetRequest() *ORMapActionRequest

func (*ORMapRequestAction) GetSetKey 

func (x *ORMapRequestAction) GetSetKey() *ORMapSet

func (*ORMapRequestAction) ProtoMessage 

func (*ORMapRequestAction) ProtoMessage()

func (*ORMapRequestAction) ProtoReflect 

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

func (*ORMapRequestAction) Reset 

func (x *ORMapRequestAction) Reset()

func (*ORMapRequestAction) String 

func (x *ORMapRequestAction) String() string

type ORMapRequestAction_Delete 

type ORMapRequestAction_Delete struct {
	Delete *Delete `protobuf:"bytes,2,opt,name=delete,proto3,oneof"`
}

type ORMapRequestAction_DeleteKey 

type ORMapRequestAction_DeleteKey struct {
	DeleteKey *ORMapDelete `protobuf:"bytes,4,opt,name=deleteKey,proto3,oneof"`
}

type ORMapRequestAction_Get 

type ORMapRequestAction_Get struct {
	Get *Get `protobuf:"bytes,1,opt,name=get,proto3,oneof"`
}

type ORMapRequestAction_Request 

type ORMapRequestAction_Request struct {
	Request *ORMapActionRequest `protobuf:"bytes,5,opt,name=request,proto3,oneof"`
}

type ORMapRequestAction_SetKey 

type ORMapRequestAction_SetKey struct {
	SetKey *ORMapSet `protobuf:"bytes,3,opt,name=setKey,proto3,oneof"`
}

type ORMapResponse 

type ORMapResponse struct {
	Keys    *ORMapKeys    `protobuf:"bytes,1,opt,name=keys,proto3" json:"keys,omitempty"`
	Entries *ORMapEntries `protobuf:"bytes,2,opt,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*ORMapResponse) Descriptor deprecated 

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

Deprecated: Use ORMapResponse.ProtoReflect.Descriptor instead.

func (*ORMapResponse) GetEntries 

func (x *ORMapResponse) GetEntries() *ORMapEntries

func (*ORMapResponse) GetKeys 

func (x *ORMapResponse) GetKeys() *ORMapKeys

func (*ORMapResponse) ProtoMessage 

func (*ORMapResponse) ProtoMessage()

func (*ORMapResponse) ProtoReflect 

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

func (*ORMapResponse) Reset 

func (x *ORMapResponse) Reset()

func (*ORMapResponse) String 

func (x *ORMapResponse) String() string

type ORMapSet 

type ORMapSet struct {
	Key      string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	FailWith string   `protobuf:"bytes,2,opt,name=failWith,proto3" json:"failWith,omitempty"`
	EntryKey *any.Any `protobuf:"bytes,3,opt,name=entry_key,json=entryKey,proto3" json:"entry_key,omitempty"`
	Value    *any.Any `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// Types that are assignable to Request:
	//	*ORMapSet_GCounterRequest
	//	*ORMapSet_PnCounterRequest
	//	*ORMapSet_GsetRequest
	//	*ORMapSet_OrSetRequest
	//	*ORMapSet_FlagRequest
	//	*ORMapSet_LwwRegisterRequest
	//	*ORMapSet_OrMapRequest
	//	*ORMapSet_VoteRequest
	Request isORMapSet_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

func (*ORMapSet) Descriptor deprecated 

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

Deprecated: Use ORMapSet.ProtoReflect.Descriptor instead.

func (*ORMapSet) GetEntryKey 

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

func (*ORMapSet) GetFailWith 

func (x *ORMapSet) GetFailWith() string

func (*ORMapSet) GetFlagRequest 

func (x *ORMapSet) GetFlagRequest() *FlagRequest

func (*ORMapSet) GetGCounterRequest 

func (x *ORMapSet) GetGCounterRequest() *GCounterRequest

func (*ORMapSet) GetGsetRequest 

func (x *ORMapSet) GetGsetRequest() *GSetRequest

func (*ORMapSet) GetKey 

func (x *ORMapSet) GetKey() string

func (*ORMapSet) GetLwwRegisterRequest 

func (x *ORMapSet) GetLwwRegisterRequest() *LWWRegisterRequest

func (*ORMapSet) GetOrMapRequest 

func (x *ORMapSet) GetOrMapRequest() *ORMapRequest

func (*ORMapSet) GetOrSetRequest 

func (x *ORMapSet) GetOrSetRequest() *ORSetRequest

func (*ORMapSet) GetPnCounterRequest 

func (x *ORMapSet) GetPnCounterRequest() *PNCounterRequest

func (*ORMapSet) GetRequest 

func (m *ORMapSet) GetRequest() isORMapSet_Request

func (*ORMapSet) GetValue 

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

func (*ORMapSet) GetVoteRequest 

func (x *ORMapSet) GetVoteRequest() *VoteRequest

func (*ORMapSet) ProtoMessage 

func (*ORMapSet) ProtoMessage()

func (*ORMapSet) ProtoReflect 

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

func (*ORMapSet) Reset 

func (x *ORMapSet) Reset()

func (*ORMapSet) String 

func (x *ORMapSet) String() string

type ORMapSet_FlagRequest 

type ORMapSet_FlagRequest struct {
	FlagRequest *FlagRequest `protobuf:"bytes,9,opt,name=flagRequest,proto3,oneof"`
}

type ORMapSet_GCounterRequest 

type ORMapSet_GCounterRequest struct {
	GCounterRequest *GCounterRequest `protobuf:"bytes,5,opt,name=gCounterRequest,proto3,oneof"`
}

type ORMapSet_GsetRequest 

type ORMapSet_GsetRequest struct {
	GsetRequest *GSetRequest `protobuf:"bytes,7,opt,name=gsetRequest,proto3,oneof"`
}

type ORMapSet_LwwRegisterRequest 

type ORMapSet_LwwRegisterRequest struct {
	LwwRegisterRequest *LWWRegisterRequest `protobuf:"bytes,10,opt,name=lwwRegisterRequest,proto3,oneof"`
}

type ORMapSet_OrMapRequest 

type ORMapSet_OrMapRequest struct {
	OrMapRequest *ORMapRequest `protobuf:"bytes,11,opt,name=orMapRequest,proto3,oneof"`
}

type ORMapSet_OrSetRequest 

type ORMapSet_OrSetRequest struct {
	OrSetRequest *ORSetRequest `protobuf:"bytes,8,opt,name=orSetRequest,proto3,oneof"`
}

type ORMapSet_PnCounterRequest 

type ORMapSet_PnCounterRequest struct {
	PnCounterRequest *PNCounterRequest `protobuf:"bytes,6,opt,name=pnCounterRequest,proto3,oneof"`
}

type ORMapSet_VoteRequest 

type ORMapSet_VoteRequest struct {
	VoteRequest *VoteRequest `protobuf:"bytes,12,opt,name=voteRequest,proto3,oneof"`
}

type ORSetAdd 

type ORSetAdd struct {
	Key      string          `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	FailWith string          `protobuf:"bytes,2,opt,name=failWith,proto3" json:"failWith,omitempty"`
	Value    *AnySupportType `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ORSetAdd) Descriptor deprecated 

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

Deprecated: Use ORSetAdd.ProtoReflect.Descriptor instead.

func (*ORSetAdd) GetFailWith 

func (x *ORSetAdd) GetFailWith() string

func (*ORSetAdd) GetKey 

func (x *ORSetAdd) GetKey() string

func (*ORSetAdd) GetValue 

func (x *ORSetAdd) GetValue() *AnySupportType

func (*ORSetAdd) ProtoMessage 

func (*ORSetAdd) ProtoMessage()

func (*ORSetAdd) ProtoReflect 

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

func (*ORSetAdd) Reset 

func (x *ORSetAdd) Reset()

func (*ORSetAdd) String 

func (x *ORSetAdd) String() string

type ORSetRemove 

type ORSetRemove struct {
	Key      string          `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	FailWith string          `protobuf:"bytes,2,opt,name=failWith,proto3" json:"failWith,omitempty"`
	Value    *AnySupportType `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ORSetRemove) Descriptor deprecated 

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

Deprecated: Use ORSetRemove.ProtoReflect.Descriptor instead.

func (*ORSetRemove) GetFailWith 

func (x *ORSetRemove) GetFailWith() string

func (*ORSetRemove) GetKey 

func (x *ORSetRemove) GetKey() string

func (*ORSetRemove) GetValue 

func (x *ORSetRemove) GetValue() *AnySupportType

func (*ORSetRemove) ProtoMessage 

func (*ORSetRemove) ProtoMessage()

func (*ORSetRemove) ProtoReflect 

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

func (*ORSetRemove) Reset 

func (x *ORSetRemove) Reset()

func (*ORSetRemove) String 

func (x *ORSetRemove) String() string

type ORSetRequest 

type ORSetRequest struct {
	Id      string                `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Actions []*ORSetRequestAction `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions,omitempty"`
	// contains filtered or unexported fields
}

func (*ORSetRequest) Descriptor deprecated 

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

Deprecated: Use ORSetRequest.ProtoReflect.Descriptor instead.

func (*ORSetRequest) GetActions 

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

func (*ORSetRequest) GetId 

func (x *ORSetRequest) GetId() string

func (*ORSetRequest) ProtoMessage 

func (*ORSetRequest) ProtoMessage()

func (*ORSetRequest) ProtoReflect 

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

func (*ORSetRequest) Reset 

func (x *ORSetRequest) Reset()

func (*ORSetRequest) String 

func (x *ORSetRequest) String() string

type ORSetRequestAction 

type ORSetRequestAction struct {

	// Types that are assignable to Action:
	//	*ORSetRequestAction_Get
	//	*ORSetRequestAction_Delete
	//	*ORSetRequestAction_Add
	//	*ORSetRequestAction_Remove
	Action isORSetRequestAction_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

func (*ORSetRequestAction) Descriptor deprecated 

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

Deprecated: Use ORSetRequestAction.ProtoReflect.Descriptor instead.

func (*ORSetRequestAction) GetAction 

func (m *ORSetRequestAction) GetAction() isORSetRequestAction_Action

func (*ORSetRequestAction) GetAdd 

func (x *ORSetRequestAction) GetAdd() *ORSetAdd

func (*ORSetRequestAction) GetDelete 

func (x *ORSetRequestAction) GetDelete() *Delete

func (*ORSetRequestAction) GetGet 

func (x *ORSetRequestAction) GetGet() *Get

func (*ORSetRequestAction) GetRemove 

func (x *ORSetRequestAction) GetRemove() *ORSetRemove

func (*ORSetRequestAction) ProtoMessage 

func (*ORSetRequestAction) ProtoMessage()

func (*ORSetRequestAction) ProtoReflect 

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

func (*ORSetRequestAction) Reset 

func (x *ORSetRequestAction) Reset()

func (*ORSetRequestAction) String 

func (x *ORSetRequestAction) String() string

type ORSetRequestAction_Add 

type ORSetRequestAction_Add struct {
	Add *ORSetAdd `protobuf:"bytes,3,opt,name=add,proto3,oneof"`
}

type ORSetRequestAction_Delete 

type ORSetRequestAction_Delete struct {
	Delete *Delete `protobuf:"bytes,2,opt,name=delete,proto3,oneof"`
}

type ORSetRequestAction_Get 

type ORSetRequestAction_Get struct {
	Get *Get `protobuf:"bytes,1,opt,name=get,proto3,oneof"`
}

type ORSetRequestAction_Remove 

type ORSetRequestAction_Remove struct {
	Remove *ORSetRemove `protobuf:"bytes,4,opt,name=remove,proto3,oneof"`
}

type ORSetResponse 

type ORSetResponse struct {
	Value *ORSetValue `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ORSetResponse) Descriptor deprecated 

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

Deprecated: Use ORSetResponse.ProtoReflect.Descriptor instead.

func (*ORSetResponse) GetValue 

func (x *ORSetResponse) GetValue() *ORSetValue

func (*ORSetResponse) ProtoMessage 

func (*ORSetResponse) ProtoMessage()

func (*ORSetResponse) ProtoReflect 

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

func (*ORSetResponse) Reset 

func (x *ORSetResponse) Reset()

func (*ORSetResponse) String 

func (x *ORSetResponse) String() string

type ORSetValue 

type ORSetValue struct {
	Values []*any.Any `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ORSetValue) Descriptor deprecated 

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

Deprecated: Use ORSetValue.ProtoReflect.Descriptor instead.

func (*ORSetValue) GetValues 

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

func (*ORSetValue) ProtoMessage 

func (*ORSetValue) ProtoMessage()

func (*ORSetValue) ProtoReflect 

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

func (*ORSetValue) Reset 

func (x *ORSetValue) Reset()

func (*ORSetValue) String 

func (x *ORSetValue) String() string

type PNCounterDecrement 

type PNCounterDecrement struct {
	Key      string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	FailWith string `protobuf:"bytes,2,opt,name=failWith,proto3" json:"failWith,omitempty"`
	Value    int64  `protobuf:"varint,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*PNCounterDecrement) Descriptor deprecated 

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

Deprecated: Use PNCounterDecrement.ProtoReflect.Descriptor instead.

func (*PNCounterDecrement) GetFailWith 

func (x *PNCounterDecrement) GetFailWith() string

func (*PNCounterDecrement) GetKey 

func (x *PNCounterDecrement) GetKey() string

func (*PNCounterDecrement) GetValue 

func (x *PNCounterDecrement) GetValue() int64

func (*PNCounterDecrement) ProtoMessage 

func (*PNCounterDecrement) ProtoMessage()

func (*PNCounterDecrement) ProtoReflect 

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

func (*PNCounterDecrement) Reset 

func (x *PNCounterDecrement) Reset()

func (*PNCounterDecrement) String 

func (x *PNCounterDecrement) String() string

type PNCounterIncrement 

type PNCounterIncrement struct {
	Key      string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	FailWith string `protobuf:"bytes,2,opt,name=failWith,proto3" json:"failWith,omitempty"`
	Value    int64  `protobuf:"varint,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*PNCounterIncrement) Descriptor deprecated 

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

Deprecated: Use PNCounterIncrement.ProtoReflect.Descriptor instead.

func (*PNCounterIncrement) GetFailWith 

func (x *PNCounterIncrement) GetFailWith() string

func (*PNCounterIncrement) GetKey 

func (x *PNCounterIncrement) GetKey() string

func (*PNCounterIncrement) GetValue 

func (x *PNCounterIncrement) GetValue() int64

func (*PNCounterIncrement) ProtoMessage 

func (*PNCounterIncrement) ProtoMessage()

func (*PNCounterIncrement) ProtoReflect 

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

func (*PNCounterIncrement) Reset 

func (x *PNCounterIncrement) Reset()

func (*PNCounterIncrement) String 

func (x *PNCounterIncrement) String() string

type PNCounterRequest 

type PNCounterRequest struct {
	Id      string                    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Actions []*PNCounterRequestAction `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions,omitempty"`
	// contains filtered or unexported fields
}

func (*PNCounterRequest) Descriptor deprecated 

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

Deprecated: Use PNCounterRequest.ProtoReflect.Descriptor instead.

func (*PNCounterRequest) GetActions 

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

func (*PNCounterRequest) GetId 

func (x *PNCounterRequest) GetId() string

func (*PNCounterRequest) ProtoMessage 

func (*PNCounterRequest) ProtoMessage()

func (*PNCounterRequest) ProtoReflect 

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

func (*PNCounterRequest) Reset 

func (x *PNCounterRequest) Reset()

func (*PNCounterRequest) String 

func (x *PNCounterRequest) String() string

type PNCounterRequestAction 

type PNCounterRequestAction struct {

	// Types that are assignable to Action:
	//	*PNCounterRequestAction_Get
	//	*PNCounterRequestAction_Delete
	//	*PNCounterRequestAction_Increment
	//	*PNCounterRequestAction_Decrement
	Action isPNCounterRequestAction_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

func (*PNCounterRequestAction) Descriptor deprecated 

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

Deprecated: Use PNCounterRequestAction.ProtoReflect.Descriptor instead.

func (*PNCounterRequestAction) GetAction 

func (m *PNCounterRequestAction) GetAction() isPNCounterRequestAction_Action

func (*PNCounterRequestAction) GetDecrement 

func (x *PNCounterRequestAction) GetDecrement() *PNCounterDecrement

func (*PNCounterRequestAction) GetDelete 

func (x *PNCounterRequestAction) GetDelete() *Delete

func (*PNCounterRequestAction) GetGet 

func (x *PNCounterRequestAction) GetGet() *Get

func (*PNCounterRequestAction) GetIncrement 

func (x *PNCounterRequestAction) GetIncrement() *PNCounterIncrement

func (*PNCounterRequestAction) ProtoMessage 

func (*PNCounterRequestAction) ProtoMessage()

func (*PNCounterRequestAction) ProtoReflect 

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

func (*PNCounterRequestAction) Reset 

func (x *PNCounterRequestAction) Reset()

func (*PNCounterRequestAction) String 

func (x *PNCounterRequestAction) String() string

type PNCounterRequestAction_Decrement 

type PNCounterRequestAction_Decrement struct {
	Decrement *PNCounterDecrement `protobuf:"bytes,4,opt,name=decrement,proto3,oneof"`
}

type PNCounterRequestAction_Delete 

type PNCounterRequestAction_Delete struct {
	Delete *Delete `protobuf:"bytes,2,opt,name=delete,proto3,oneof"`
}

type PNCounterRequestAction_Get 

type PNCounterRequestAction_Get struct {
	Get *Get `protobuf:"bytes,1,opt,name=get,proto3,oneof"`
}

type PNCounterRequestAction_Increment 

type PNCounterRequestAction_Increment struct {
	Increment *PNCounterIncrement `protobuf:"bytes,3,opt,name=increment,proto3,oneof"`
}

type PNCounterResponse 

type PNCounterResponse struct {
	Value *PNCounterValue `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*PNCounterResponse) Descriptor deprecated 

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

Deprecated: Use PNCounterResponse.ProtoReflect.Descriptor instead.

func (*PNCounterResponse) GetValue 

func (x *PNCounterResponse) GetValue() *PNCounterValue

func (*PNCounterResponse) ProtoMessage 

func (*PNCounterResponse) ProtoMessage()

func (*PNCounterResponse) ProtoReflect 

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

func (*PNCounterResponse) Reset 

func (x *PNCounterResponse) Reset()

func (*PNCounterResponse) String 

func (x *PNCounterResponse) String() string

type PNCounterValue 

type PNCounterValue struct {
	Value int64 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*PNCounterValue) Descriptor deprecated 

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

Deprecated: Use PNCounterValue.ProtoReflect.Descriptor instead.

func (*PNCounterValue) GetValue 

func (x *PNCounterValue) GetValue() int64

func (*PNCounterValue) ProtoMessage 

func (*PNCounterValue) ProtoMessage()

func (*PNCounterValue) ProtoReflect 

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

func (*PNCounterValue) Reset 

func (x *PNCounterValue) Reset()

func (*PNCounterValue) String 

func (x *PNCounterValue) String() string

type TckCrdtClient 

type TckCrdtClient interface {
	ProcessGCounter(ctx context.Context, in *GCounterRequest, opts ...grpc.CallOption) (*GCounterResponse, error)
	ProcessGCounterStreamed(ctx context.Context, in *GCounterRequest, opts ...grpc.CallOption) (TckCrdt_ProcessGCounterStreamedClient, error)
	ProcessPNCounter(ctx context.Context, in *PNCounterRequest, opts ...grpc.CallOption) (*PNCounterResponse, error)
	ProcessGSet(ctx context.Context, in *GSetRequest, opts ...grpc.CallOption) (*GSetResponse, error)
	ProcessORSet(ctx context.Context, in *ORSetRequest, opts ...grpc.CallOption) (*ORSetResponse, error)
	ProcessFlag(ctx context.Context, in *FlagRequest, opts ...grpc.CallOption) (*FlagResponse, error)
	ProcessLWWRegister(ctx context.Context, in *LWWRegisterRequest, opts ...grpc.CallOption) (*LWWRegisterResponse, error)
	ProcessORMap(ctx context.Context, in *ORMapRequest, opts ...grpc.CallOption) (*ORMapResponse, error)
	ProcessVote(ctx context.Context, in *VoteRequest, opts ...grpc.CallOption) (*VoteResponse, error)
}

TckCrdtClient is the client API for TckCrdt service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTckCrdtClient 

func NewTckCrdtClient(cc grpc.ClientConnInterface) TckCrdtClient

type TckCrdtServer 

type TckCrdtServer interface {
	ProcessGCounter(context.Context, *GCounterRequest) (*GCounterResponse, error)
	ProcessGCounterStreamed(*GCounterRequest, TckCrdt_ProcessGCounterStreamedServer) error
	ProcessPNCounter(context.Context, *PNCounterRequest) (*PNCounterResponse, error)
	ProcessGSet(context.Context, *GSetRequest) (*GSetResponse, error)
	ProcessORSet(context.Context, *ORSetRequest) (*ORSetResponse, error)
	ProcessFlag(context.Context, *FlagRequest) (*FlagResponse, error)
	ProcessLWWRegister(context.Context, *LWWRegisterRequest) (*LWWRegisterResponse, error)
	ProcessORMap(context.Context, *ORMapRequest) (*ORMapResponse, error)
	ProcessVote(context.Context, *VoteRequest) (*VoteResponse, error)
	// contains filtered or unexported methods
}

TckCrdtServer is the server API for TckCrdt service. All implementations must embed UnimplementedTckCrdtServer for forward compatibility

type TckCrdt_ProcessGCounterStreamedClient 

type TckCrdt_ProcessGCounterStreamedClient interface {
	Recv() (*GCounterResponse, error)
	grpc.ClientStream
}

type TckCrdt_ProcessGCounterStreamedServer 

type TckCrdt_ProcessGCounterStreamedServer interface {
	Send(*GCounterResponse) error
	grpc.ServerStream
}

type TestModel 

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

func NewEntity 

func NewEntity(id crdt.EntityID) *TestModel

func (*TestModel) Default 

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

func (*TestModel) HandleCommand 

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

func (*TestModel) Set 

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

type UnimplementedTckCrdtServer 

type UnimplementedTckCrdtServer struct {
}

UnimplementedTckCrdtServer must be embedded to have forward compatible implementations.

func (UnimplementedTckCrdtServer) ProcessFlag 

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

func (UnimplementedTckCrdtServer) ProcessGCounter 

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

func (UnimplementedTckCrdtServer) ProcessGCounterStreamed 

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

func (UnimplementedTckCrdtServer) ProcessGSet 

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

func (UnimplementedTckCrdtServer) ProcessLWWRegister 

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

func (UnimplementedTckCrdtServer) ProcessORMap 

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

func (UnimplementedTckCrdtServer) ProcessORSet 

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

func (UnimplementedTckCrdtServer) ProcessPNCounter 

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

func (UnimplementedTckCrdtServer) ProcessVote 

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

type UnsafeTckCrdtServer added in v0.3.0 

type UnsafeTckCrdtServer interface {
	// contains filtered or unexported methods
}

UnsafeTckCrdtServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TckCrdtServer will result in compilation errors.

type VoteRequest 

type VoteRequest struct {
	Id      string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Actions []*VoteRequestAction `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions,omitempty"`
	// contains filtered or unexported fields
}

func (*VoteRequest) Descriptor deprecated 

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

Deprecated: Use VoteRequest.ProtoReflect.Descriptor instead.

func (*VoteRequest) GetActions 

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

func (*VoteRequest) GetId 

func (x *VoteRequest) GetId() string

func (*VoteRequest) ProtoMessage 

func (*VoteRequest) ProtoMessage()

func (*VoteRequest) ProtoReflect 

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

func (*VoteRequest) Reset 

func (x *VoteRequest) Reset()

func (*VoteRequest) String 

func (x *VoteRequest) String() string

type VoteRequestAction 

type VoteRequestAction struct {

	// Types that are assignable to Action:
	//	*VoteRequestAction_Get
	//	*VoteRequestAction_Delete
	//	*VoteRequestAction_Vote
	Action isVoteRequestAction_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

func (*VoteRequestAction) Descriptor deprecated 

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

Deprecated: Use VoteRequestAction.ProtoReflect.Descriptor instead.

func (*VoteRequestAction) GetAction 

func (m *VoteRequestAction) GetAction() isVoteRequestAction_Action

func (*VoteRequestAction) GetDelete 

func (x *VoteRequestAction) GetDelete() *Delete

func (*VoteRequestAction) GetGet 

func (x *VoteRequestAction) GetGet() *Get

func (*VoteRequestAction) GetVote 

func (x *VoteRequestAction) GetVote() *VoteVote

func (*VoteRequestAction) ProtoMessage 

func (*VoteRequestAction) ProtoMessage()

func (*VoteRequestAction) ProtoReflect 

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

func (*VoteRequestAction) Reset 

func (x *VoteRequestAction) Reset()

func (*VoteRequestAction) String 

func (x *VoteRequestAction) String() string

type VoteRequestAction_Delete 

type VoteRequestAction_Delete struct {
	Delete *Delete `protobuf:"bytes,2,opt,name=delete,proto3,oneof"`
}

type VoteRequestAction_Get 

type VoteRequestAction_Get struct {
	Get *Get `protobuf:"bytes,1,opt,name=get,proto3,oneof"`
}

type VoteRequestAction_Vote 

type VoteRequestAction_Vote struct {
	Vote *VoteVote `protobuf:"bytes,3,opt,name=vote,proto3,oneof"`
}

type VoteResponse 

type VoteResponse struct {
	SelfVote bool   `protobuf:"varint,1,opt,name=selfVote,proto3" json:"selfVote,omitempty"`
	Voters   uint32 `protobuf:"varint,2,opt,name=voters,proto3" json:"voters,omitempty"`
	VotesFor uint32 `protobuf:"varint,3,opt,name=votesFor,proto3" json:"votesFor,omitempty"`
	// contains filtered or unexported fields
}

func (*VoteResponse) Descriptor deprecated 

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

Deprecated: Use VoteResponse.ProtoReflect.Descriptor instead.

func (*VoteResponse) GetSelfVote 

func (x *VoteResponse) GetSelfVote() bool

func (*VoteResponse) GetVoters 

func (x *VoteResponse) GetVoters() uint32

func (*VoteResponse) GetVotesFor 

func (x *VoteResponse) GetVotesFor() uint32

func (*VoteResponse) ProtoMessage 

func (*VoteResponse) ProtoMessage()

func (*VoteResponse) ProtoReflect 

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

func (*VoteResponse) Reset 

func (x *VoteResponse) Reset()

func (*VoteResponse) String 

func (x *VoteResponse) String() string

type VoteVote 

type VoteVote struct {
	Key      string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	FailWith string `protobuf:"bytes,2,opt,name=failWith,proto3" json:"failWith,omitempty"`
	Value    bool   `protobuf:"varint,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*VoteVote) Descriptor deprecated 

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

Deprecated: Use VoteVote.ProtoReflect.Descriptor instead.

func (*VoteVote) GetFailWith 

func (x *VoteVote) GetFailWith() string

func (*VoteVote) GetKey 

func (x *VoteVote) GetKey() string

func (*VoteVote) GetValue 

func (x *VoteVote) GetValue() bool

func (*VoteVote) ProtoMessage 

func (*VoteVote) ProtoMessage()

func (*VoteVote) ProtoReflect 

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

func (*VoteVote) Reset 

func (x *VoteVote) Reset()

func (*VoteVote) String 

func (x *VoteVote) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.