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

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 (*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) ProcessGCounter

func (UnimplementedTckCrdtServer) ProcessGCounterStreamed

func (UnimplementedTckCrdtServer) ProcessGSet

func (UnimplementedTckCrdtServer) ProcessLWWRegister

func (UnimplementedTckCrdtServer) ProcessORMap

func (UnimplementedTckCrdtServer) ProcessORSet

func (UnimplementedTckCrdtServer) ProcessPNCounter

func (UnimplementedTckCrdtServer) ProcessVote

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL