db

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Jul 23, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ContinueListDirection_name = map[int32]string{
		0: "CONTINUE_LIST_FORWARD",
		1: "CONTINUE_LIST_BACKWARD",
	}
	ContinueListDirection_value = map[string]int32{
		"CONTINUE_LIST_FORWARD":  0,
		"CONTINUE_LIST_BACKWARD": 1,
	}
)

Enum value maps for ContinueListDirection.

View Source 
var (
	SortableProperty_name = map[int32]string{
		0:  "SORTABLE_PROPERTY_KEY_PATH",
		1:  "SORTABLE_PROPERTY_LAST_MODIFIED_VERSION",
		8:  "SORTABLE_PROPERTY_GROUP_LOCAL_INDEX_1",
		9:  "SORTABLE_PROPERTY_GROUP_LOCAL_INDEX_2",
		10: "SORTABLE_PROPERTY_GROUP_LOCAL_INDEX_3",
		11: "SORTABLE_PROPERTY_GROUP_LOCAL_INDEX_4",
	}
	SortableProperty_value = map[string]int32{
		"SORTABLE_PROPERTY_KEY_PATH":              0,
		"SORTABLE_PROPERTY_LAST_MODIFIED_VERSION": 1,
		"SORTABLE_PROPERTY_GROUP_LOCAL_INDEX_1":   8,
		"SORTABLE_PROPERTY_GROUP_LOCAL_INDEX_2":   9,
		"SORTABLE_PROPERTY_GROUP_LOCAL_INDEX_3":   10,
		"SORTABLE_PROPERTY_GROUP_LOCAL_INDEX_4":   11,
	}
)

Enum value maps for SortableProperty.

View Source 
var (
	SortDirection_name = map[int32]string{
		0: "SORT_ASCENDING",
		1: "SORT_DESCENDING",
	}
	SortDirection_value = map[string]int32{
		"SORT_ASCENDING":  0,
		"SORT_DESCENDING": 1,
	}
)

Enum value maps for SortDirection.

View Source 
var File_db_continue_list_proto protoreflect.FileDescriptor
View Source 
var File_db_delete_proto protoreflect.FileDescriptor
View Source 
var File_db_get_proto protoreflect.FileDescriptor
View Source 
var File_db_item_property_proto protoreflect.FileDescriptor
View Source 
var File_db_item_proto protoreflect.FileDescriptor
View Source 
var File_db_list_proto protoreflect.FileDescriptor
View Source 
var File_db_list_token_proto protoreflect.FileDescriptor
View Source 
var File_db_put_proto protoreflect.FileDescriptor
View Source 
var File_db_scan_root_paths_proto protoreflect.FileDescriptor
View Source 
var File_db_service_proto protoreflect.FileDescriptor
View Source 
var File_db_sync_list_proto protoreflect.FileDescriptor
View Source 
var File_db_transaction_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BeginListRequest 

type BeginListRequest struct {

	// store_id is a globally unique Store ID, which can be looked up from the
	// console or CLI.
	StoreId uint64 `protobuf:"varint,1,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
	// key_path_prefix is the a prefix that limits what items we will return. This
	// must contain at least a root segment. See Item#key_path for more details.
	KeyPathPrefix string `protobuf:"bytes,2,opt,name=key_path_prefix,json=keyPathPrefix,proto3" json:"key_path_prefix,omitempty"`
	// limit is the maximum number of items to return. If this is not specified or
	// set to 0, it will default to unlimited. Fewer items than the limit may be
	// returned even if there are more items to get - make sure to check
	// token.can_continue.
	Limit uint32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// allow_stale indicates that you're okay with getting slightly stale items -
	// that is, if you had just changed an item and then call a List operation,
	// you might get the old version of the item. This can result in improved
	// performance, availability, and cost.
	AllowStale bool `protobuf:"varint,4,opt,name=allow_stale,json=allowStale,proto3" json:"allow_stale,omitempty"`
	// sort_property is the property of the item to sort the results by. If this
	// is not set, we will sort by key path.
	SortProperty SortableProperty `` /* 131-byte string literal not displayed */
	// sort_direction is the direction to sort the results in. If this is not set,
	// we will sort in ascending order.
	SortDirection SortDirection `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*BeginListRequest) CloneMessageVT 

func (m *BeginListRequest) CloneMessageVT() proto.Message

func (*BeginListRequest) CloneVT 

func (m *BeginListRequest) CloneVT() *BeginListRequest

func (*BeginListRequest) Descriptor deprecated 

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

Deprecated: Use BeginListRequest.ProtoReflect.Descriptor instead.

func (*BeginListRequest) EqualMessageVT 

func (this *BeginListRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*BeginListRequest) EqualVT 

func (this *BeginListRequest) EqualVT(that *BeginListRequest) bool

func (*BeginListRequest) GetAllowStale 

func (x *BeginListRequest) GetAllowStale() bool

func (*BeginListRequest) GetKeyPathPrefix 

func (x *BeginListRequest) GetKeyPathPrefix() string

func (*BeginListRequest) GetLimit 

func (x *BeginListRequest) GetLimit() uint32

func (*BeginListRequest) GetSortDirection 

func (x *BeginListRequest) GetSortDirection() SortDirection

func (*BeginListRequest) GetSortProperty 

func (x *BeginListRequest) GetSortProperty() SortableProperty

func (*BeginListRequest) GetStoreId 

func (x *BeginListRequest) GetStoreId() uint64

func (*BeginListRequest) MarshalToSizedBufferVT 

func (m *BeginListRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BeginListRequest) MarshalToVT 

func (m *BeginListRequest) MarshalToVT(dAtA []byte) (int, error)

func (*BeginListRequest) MarshalVT 

func (m *BeginListRequest) MarshalVT() (dAtA []byte, err error)

func (*BeginListRequest) ProtoMessage 

func (*BeginListRequest) ProtoMessage()

func (*BeginListRequest) ProtoReflect 

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

func (*BeginListRequest) Reset 

func (x *BeginListRequest) Reset()

func (*BeginListRequest) SizeVT 

func (m *BeginListRequest) SizeVT() (n int)

func (*BeginListRequest) String 

func (x *BeginListRequest) String() string

func (*BeginListRequest) UnmarshalVT 

func (m *BeginListRequest) UnmarshalVT(dAtA []byte) error

type ContinueListDirection 

type ContinueListDirection int32

ContinueListDirection is used to indicate whether we are expanding the result set (paginating) forward (in the direction of the original List operation) or backward (in the opposite direction). 

const (
	ContinueListDirection_CONTINUE_LIST_FORWARD  ContinueListDirection = 0 // this is the default
	ContinueListDirection_CONTINUE_LIST_BACKWARD ContinueListDirection = 1
)

func (ContinueListDirection) Descriptor 

func (ContinueListDirection) Descriptor() protoreflect.EnumDescriptor

func (ContinueListDirection) Enum 

func (x ContinueListDirection) Enum() *ContinueListDirection

func (ContinueListDirection) EnumDescriptor deprecated 

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

Deprecated: Use ContinueListDirection.Descriptor instead.

func (ContinueListDirection) Number 

func (x ContinueListDirection) Number() protoreflect.EnumNumber

func (ContinueListDirection) String 

func (x ContinueListDirection) String() string

func (ContinueListDirection) Type 

func (ContinueListDirection) Type() protoreflect.EnumType

type ContinueListRequest 

type ContinueListRequest struct {

	// token_data is an opaque list continuation token returned by a previous call to
	// BeginList, ContinueList, or SyncList.
	TokenData []byte `protobuf:"bytes,1,opt,name=token_data,json=tokenData,proto3" json:"token_data,omitempty"`
	// direction indicates whether we are expanding the result set (paginating)
	// forward (in the direction of the original List operation) or backward (in
	// the opposite direction). The default is to expand forward.
	Direction ContinueListDirection `protobuf:"varint,2,opt,name=direction,proto3,enum=stately.db.ContinueListDirection" json:"direction,omitempty"`
	// contains filtered or unexported fields
}

func (*ContinueListRequest) CloneMessageVT 

func (m *ContinueListRequest) CloneMessageVT() proto.Message

func (*ContinueListRequest) CloneVT 

func (m *ContinueListRequest) CloneVT() *ContinueListRequest

func (*ContinueListRequest) Descriptor deprecated 

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

Deprecated: Use ContinueListRequest.ProtoReflect.Descriptor instead.

func (*ContinueListRequest) EqualMessageVT 

func (this *ContinueListRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*ContinueListRequest) EqualVT 

func (this *ContinueListRequest) EqualVT(that *ContinueListRequest) bool

func (*ContinueListRequest) GetDirection 

func (x *ContinueListRequest) GetDirection() ContinueListDirection

func (*ContinueListRequest) GetTokenData 

func (x *ContinueListRequest) GetTokenData() []byte

func (*ContinueListRequest) MarshalToSizedBufferVT 

func (m *ContinueListRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ContinueListRequest) MarshalToVT 

func (m *ContinueListRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ContinueListRequest) MarshalVT 

func (m *ContinueListRequest) MarshalVT() (dAtA []byte, err error)

func (*ContinueListRequest) ProtoMessage 

func (*ContinueListRequest) ProtoMessage()

func (*ContinueListRequest) ProtoReflect 

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

func (*ContinueListRequest) Reset 

func (x *ContinueListRequest) Reset()

func (*ContinueListRequest) SizeVT 

func (m *ContinueListRequest) SizeVT() (n int)

func (*ContinueListRequest) String 

func (x *ContinueListRequest) String() string

func (*ContinueListRequest) UnmarshalVT 

func (m *ContinueListRequest) UnmarshalVT(dAtA []byte) error

type DeleteItem 

type DeleteItem struct {

	// key_path is the full path to the item. See Item#key_path for more details.
	KeyPath string `protobuf:"bytes,1,opt,name=key_path,json=keyPath,proto3" json:"key_path,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteItem) CloneMessageVT 

func (m *DeleteItem) CloneMessageVT() proto.Message

func (*DeleteItem) CloneVT 

func (m *DeleteItem) CloneVT() *DeleteItem

func (*DeleteItem) Descriptor deprecated 

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

Deprecated: Use DeleteItem.ProtoReflect.Descriptor instead.

func (*DeleteItem) EqualMessageVT 

func (this *DeleteItem) EqualMessageVT(thatMsg proto.Message) bool

func (*DeleteItem) EqualVT 

func (this *DeleteItem) EqualVT(that *DeleteItem) bool

func (*DeleteItem) GetKeyPath 

func (x *DeleteItem) GetKeyPath() string

func (*DeleteItem) MarshalToSizedBufferVT 

func (m *DeleteItem) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteItem) MarshalToVT 

func (m *DeleteItem) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteItem) MarshalVT 

func (m *DeleteItem) MarshalVT() (dAtA []byte, err error)

func (*DeleteItem) ProtoMessage 

func (*DeleteItem) ProtoMessage()

func (*DeleteItem) ProtoReflect 

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

func (*DeleteItem) Reset 

func (x *DeleteItem) Reset()

func (*DeleteItem) SizeVT 

func (m *DeleteItem) SizeVT() (n int)

func (*DeleteItem) String 

func (x *DeleteItem) String() string

func (*DeleteItem) UnmarshalVT 

func (m *DeleteItem) UnmarshalVT(dAtA []byte) error

type DeleteRequest 

type DeleteRequest struct {

	// store_id is a globally unique Store ID, which can be looked up from the
	// console or CLI.
	StoreId uint64 `protobuf:"varint,1,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
	// deletes is one or more items to be deleted from the Group.
	Deletes []*DeleteItem `protobuf:"bytes,3,rep,name=deletes,proto3" json:"deletes,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) CloneMessageVT 

func (m *DeleteRequest) CloneMessageVT() proto.Message

func (*DeleteRequest) CloneVT 

func (m *DeleteRequest) CloneVT() *DeleteRequest

func (*DeleteRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) EqualMessageVT 

func (this *DeleteRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*DeleteRequest) EqualVT 

func (this *DeleteRequest) EqualVT(that *DeleteRequest) bool

func (*DeleteRequest) GetDeletes 

func (x *DeleteRequest) GetDeletes() []*DeleteItem

func (*DeleteRequest) GetStoreId 

func (x *DeleteRequest) GetStoreId() uint64

func (*DeleteRequest) MarshalToSizedBufferVT 

func (m *DeleteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteRequest) MarshalToVT 

func (m *DeleteRequest) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteRequest) MarshalVT 

func (m *DeleteRequest) MarshalVT() (dAtA []byte, err error)

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

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

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) SizeVT 

func (m *DeleteRequest) SizeVT() (n int)

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

func (*DeleteRequest) UnmarshalVT 

func (m *DeleteRequest) UnmarshalVT(dAtA []byte) error

type DeleteResponse 

type DeleteResponse struct {

	// results is the result of each delete operation, whether it succeeded or failed.
	Results []*DeleteResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteResponse) CloneMessageVT 

func (m *DeleteResponse) CloneMessageVT() proto.Message

func (*DeleteResponse) CloneVT 

func (m *DeleteResponse) CloneVT() *DeleteResponse

func (*DeleteResponse) Descriptor deprecated 

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) EqualMessageVT 

func (this *DeleteResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*DeleteResponse) EqualVT 

func (this *DeleteResponse) EqualVT(that *DeleteResponse) bool

func (*DeleteResponse) GetResults 

func (x *DeleteResponse) GetResults() []*DeleteResult

func (*DeleteResponse) MarshalToSizedBufferVT 

func (m *DeleteResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteResponse) MarshalToVT 

func (m *DeleteResponse) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteResponse) MarshalVT 

func (m *DeleteResponse) MarshalVT() (dAtA []byte, err error)

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect 

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

func (*DeleteResponse) Reset 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) SizeVT 

func (m *DeleteResponse) SizeVT() (n int)

func (*DeleteResponse) String 

func (x *DeleteResponse) String() string

func (*DeleteResponse) UnmarshalVT 

func (m *DeleteResponse) UnmarshalVT(dAtA []byte) error

type DeleteResult 

type DeleteResult struct {

	// The key_path of the item that was deleted.
	KeyPath string `protobuf:"bytes,1,opt,name=key_path,json=keyPath,proto3" json:"key_path,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteResult) CloneMessageVT 

func (m *DeleteResult) CloneMessageVT() proto.Message

func (*DeleteResult) CloneVT 

func (m *DeleteResult) CloneVT() *DeleteResult

func (*DeleteResult) Descriptor deprecated 

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

Deprecated: Use DeleteResult.ProtoReflect.Descriptor instead.

func (*DeleteResult) EqualMessageVT 

func (this *DeleteResult) EqualMessageVT(thatMsg proto.Message) bool

func (*DeleteResult) EqualVT 

func (this *DeleteResult) EqualVT(that *DeleteResult) bool

func (*DeleteResult) GetKeyPath 

func (x *DeleteResult) GetKeyPath() string

func (*DeleteResult) MarshalToSizedBufferVT 

func (m *DeleteResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteResult) MarshalToVT 

func (m *DeleteResult) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteResult) MarshalVT 

func (m *DeleteResult) MarshalVT() (dAtA []byte, err error)

func (*DeleteResult) ProtoMessage 

func (*DeleteResult) ProtoMessage()

func (*DeleteResult) ProtoReflect 

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

func (*DeleteResult) Reset 

func (x *DeleteResult) Reset()

func (*DeleteResult) SizeVT 

func (m *DeleteResult) SizeVT() (n int)

func (*DeleteResult) String 

func (x *DeleteResult) String() string

func (*DeleteResult) UnmarshalVT 

func (m *DeleteResult) UnmarshalVT(dAtA []byte) error

type DeletedItem 

type DeletedItem struct {

	// Since the item was deleted, only the key is provided.
	KeyPath string `protobuf:"bytes,1,opt,name=key_path,json=keyPath,proto3" json:"key_path,omitempty"`
	// contains filtered or unexported fields
}

func (*DeletedItem) CloneMessageVT 

func (m *DeletedItem) CloneMessageVT() proto.Message

func (*DeletedItem) CloneVT 

func (m *DeletedItem) CloneVT() *DeletedItem

func (*DeletedItem) Descriptor deprecated 

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

Deprecated: Use DeletedItem.ProtoReflect.Descriptor instead.

func (*DeletedItem) EqualMessageVT 

func (this *DeletedItem) EqualMessageVT(thatMsg proto.Message) bool

func (*DeletedItem) EqualVT 

func (this *DeletedItem) EqualVT(that *DeletedItem) bool

func (*DeletedItem) GetKeyPath 

func (x *DeletedItem) GetKeyPath() string

func (*DeletedItem) MarshalToSizedBufferVT 

func (m *DeletedItem) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeletedItem) MarshalToVT 

func (m *DeletedItem) MarshalToVT(dAtA []byte) (int, error)

func (*DeletedItem) MarshalVT 

func (m *DeletedItem) MarshalVT() (dAtA []byte, err error)

func (*DeletedItem) ProtoMessage 

func (*DeletedItem) ProtoMessage()

func (*DeletedItem) ProtoReflect 

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

func (*DeletedItem) Reset 

func (x *DeletedItem) Reset()

func (*DeletedItem) SizeVT 

func (m *DeletedItem) SizeVT() (n int)

func (*DeletedItem) String 

func (x *DeletedItem) String() string

func (*DeletedItem) UnmarshalVT 

func (m *DeletedItem) UnmarshalVT(dAtA []byte) error

type GeneratedID 

type GeneratedID struct {

	// Right now we only ever generate uint or bytes values from our id generators
	// (initialValue). If neither is set, this represents a put that didn't
	// generate any ID (e.g. it was fully specified in the input).
	//
	// Types that are assignable to Value:
	//
	//	*GeneratedID_Uint
	//	*GeneratedID_Bytes
	Value isGeneratedID_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

GeneratedID represents a unique ID that was generated by the server for a new item.

func (*GeneratedID) CloneMessageVT 

func (m *GeneratedID) CloneMessageVT() proto.Message

func (*GeneratedID) CloneVT 

func (m *GeneratedID) CloneVT() *GeneratedID

func (*GeneratedID) Descriptor deprecated 

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

Deprecated: Use GeneratedID.ProtoReflect.Descriptor instead.

func (*GeneratedID) EqualMessageVT 

func (this *GeneratedID) EqualMessageVT(thatMsg proto.Message) bool

func (*GeneratedID) EqualVT 

func (this *GeneratedID) EqualVT(that *GeneratedID) bool

func (*GeneratedID) GetBytes 

func (x *GeneratedID) GetBytes() []byte

func (*GeneratedID) GetUint 

func (x *GeneratedID) GetUint() uint64

func (*GeneratedID) GetValue 

func (m *GeneratedID) GetValue() isGeneratedID_Value

func (*GeneratedID) MarshalToSizedBufferVT 

func (m *GeneratedID) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GeneratedID) MarshalToVT 

func (m *GeneratedID) MarshalToVT(dAtA []byte) (int, error)

func (*GeneratedID) MarshalVT 

func (m *GeneratedID) MarshalVT() (dAtA []byte, err error)

func (*GeneratedID) ProtoMessage 

func (*GeneratedID) ProtoMessage()

func (*GeneratedID) ProtoReflect 

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

func (*GeneratedID) Reset 

func (x *GeneratedID) Reset()

func (*GeneratedID) SizeVT 

func (m *GeneratedID) SizeVT() (n int)

func (*GeneratedID) String 

func (x *GeneratedID) String() string

func (*GeneratedID) UnmarshalVT 

func (m *GeneratedID) UnmarshalVT(dAtA []byte) error

type GeneratedID_Bytes 

type GeneratedID_Bytes struct {
	Bytes []byte `protobuf:"bytes,2,opt,name=bytes,proto3,oneof"`
}

func (*GeneratedID_Bytes) CloneVT 

func (m *GeneratedID_Bytes) CloneVT() isGeneratedID_Value

func (*GeneratedID_Bytes) EqualVT 

func (this *GeneratedID_Bytes) EqualVT(thatIface isGeneratedID_Value) bool

func (*GeneratedID_Bytes) MarshalToSizedBufferVT 

func (m *GeneratedID_Bytes) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GeneratedID_Bytes) MarshalToVT 

func (m *GeneratedID_Bytes) MarshalToVT(dAtA []byte) (int, error)

func (*GeneratedID_Bytes) SizeVT 

func (m *GeneratedID_Bytes) SizeVT() (n int)

type GeneratedID_Uint 

type GeneratedID_Uint struct {
	Uint uint64 `protobuf:"varint,1,opt,name=uint,proto3,oneof"`
}

func (*GeneratedID_Uint) CloneVT 

func (m *GeneratedID_Uint) CloneVT() isGeneratedID_Value

func (*GeneratedID_Uint) EqualVT 

func (this *GeneratedID_Uint) EqualVT(thatIface isGeneratedID_Value) bool

func (*GeneratedID_Uint) MarshalToSizedBufferVT 

func (m *GeneratedID_Uint) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GeneratedID_Uint) MarshalToVT 

func (m *GeneratedID_Uint) MarshalToVT(dAtA []byte) (int, error)

func (*GeneratedID_Uint) SizeVT 

func (m *GeneratedID_Uint) SizeVT() (n int)

type GetItem 

type GetItem struct {

	// key_path is the full path to the item. See Item#key_path for more details.
	KeyPath string `protobuf:"bytes,1,opt,name=key_path,json=keyPath,proto3" json:"key_path,omitempty"`
	// contains filtered or unexported fields
}

func (*GetItem) CloneMessageVT 

func (m *GetItem) CloneMessageVT() proto.Message

func (*GetItem) CloneVT 

func (m *GetItem) CloneVT() *GetItem

func (*GetItem) Descriptor deprecated 

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

Deprecated: Use GetItem.ProtoReflect.Descriptor instead.

func (*GetItem) EqualMessageVT 

func (this *GetItem) EqualMessageVT(thatMsg proto.Message) bool

func (*GetItem) EqualVT 

func (this *GetItem) EqualVT(that *GetItem) bool

func (*GetItem) GetKeyPath 

func (x *GetItem) GetKeyPath() string

func (*GetItem) MarshalToSizedBufferVT 

func (m *GetItem) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetItem) MarshalToVT 

func (m *GetItem) MarshalToVT(dAtA []byte) (int, error)

func (*GetItem) MarshalVT 

func (m *GetItem) MarshalVT() (dAtA []byte, err error)

func (*GetItem) ProtoMessage 

func (*GetItem) ProtoMessage()

func (*GetItem) ProtoReflect 

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

func (*GetItem) Reset 

func (x *GetItem) Reset()

func (*GetItem) SizeVT 

func (m *GetItem) SizeVT() (n int)

func (*GetItem) String 

func (x *GetItem) String() string

func (*GetItem) UnmarshalVT 

func (m *GetItem) UnmarshalVT(dAtA []byte) error

type GetRequest 

type GetRequest struct {

	// store_id is a globally unique Store ID, which can be looked up from the
	// console or CLI.
	StoreId uint64 `protobuf:"varint,1,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
	// gets is one or more requests to get an item its key path.
	Gets []*GetItem `protobuf:"bytes,2,rep,name=gets,proto3" json:"gets,omitempty"`
	// allow_stale indicates that you're okay with getting a slightly stale item -
	// that is, if you had just changed an item and then call GetItem, you might
	// get the old version of the item. This can result in improved performance,
	// availability, and cost.
	AllowStale bool `protobuf:"varint,3,opt,name=allow_stale,json=allowStale,proto3" json:"allow_stale,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) CloneMessageVT 

func (m *GetRequest) CloneMessageVT() proto.Message

func (*GetRequest) CloneVT 

func (m *GetRequest) CloneVT() *GetRequest

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) EqualMessageVT 

func (this *GetRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*GetRequest) EqualVT 

func (this *GetRequest) EqualVT(that *GetRequest) bool

func (*GetRequest) GetAllowStale 

func (x *GetRequest) GetAllowStale() bool

func (*GetRequest) GetGets 

func (x *GetRequest) GetGets() []*GetItem

func (*GetRequest) GetStoreId 

func (x *GetRequest) GetStoreId() uint64

func (*GetRequest) MarshalToSizedBufferVT 

func (m *GetRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetRequest) MarshalToVT 

func (m *GetRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetRequest) MarshalVT 

func (m *GetRequest) MarshalVT() (dAtA []byte, err error)

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

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

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) SizeVT 

func (m *GetRequest) SizeVT() (n int)

func (*GetRequest) String 

func (x *GetRequest) String() string

func (*GetRequest) UnmarshalVT 

func (m *GetRequest) UnmarshalVT(dAtA []byte) error

type GetResponse 

type GetResponse struct {

	// results is a list that contains one entry for each Item that was found.
	Items []*Item `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) CloneMessageVT 

func (m *GetResponse) CloneMessageVT() proto.Message

func (*GetResponse) CloneVT 

func (m *GetResponse) CloneVT() *GetResponse

func (*GetResponse) Descriptor deprecated 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) EqualMessageVT 

func (this *GetResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*GetResponse) EqualVT 

func (this *GetResponse) EqualVT(that *GetResponse) bool

func (*GetResponse) GetItems 

func (x *GetResponse) GetItems() []*Item

func (*GetResponse) MarshalToSizedBufferVT 

func (m *GetResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetResponse) MarshalToVT 

func (m *GetResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetResponse) MarshalVT 

func (m *GetResponse) MarshalVT() (dAtA []byte, err error)

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

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

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) SizeVT 

func (m *GetResponse) SizeVT() (n int)

func (*GetResponse) String 

func (x *GetResponse) String() string

func (*GetResponse) UnmarshalVT 

func (m *GetResponse) UnmarshalVT(dAtA []byte) error

type Item 

type Item struct {

	// item_type is the schema type of the item. It must correspond to one of the
	// schema's `itemType` declarations.
	ItemType string `protobuf:"bytes,1,opt,name=item_type,json=itemType,proto3" json:"item_type,omitempty"`
	// The payload is the actual data of the item. Its structure is dictated by
	// your store's schema for this item type.
	//
	// Types that are assignable to Payload:
	//
	//	*Item_Proto
	//	*Item_Json
	Payload isItem_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

Item represents data stored in StatelyDB.

func (*Item) CloneMessageVT 

func (m *Item) CloneMessageVT() proto.Message

func (*Item) CloneVT 

func (m *Item) CloneVT() *Item

func (*Item) Descriptor deprecated 

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

Deprecated: Use Item.ProtoReflect.Descriptor instead.

func (*Item) EqualMessageVT 

func (this *Item) EqualMessageVT(thatMsg proto.Message) bool

func (*Item) EqualVT 

func (this *Item) EqualVT(that *Item) bool

func (*Item) GetItemType 

func (x *Item) GetItemType() string

func (*Item) GetJson 

func (x *Item) GetJson() *structpb.Struct

func (*Item) GetPayload 

func (m *Item) GetPayload() isItem_Payload

func (*Item) GetProto 

func (x *Item) GetProto() []byte

func (*Item) MarshalToSizedBufferVT 

func (m *Item) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Item) MarshalToVT 

func (m *Item) MarshalToVT(dAtA []byte) (int, error)

func (*Item) MarshalVT 

func (m *Item) MarshalVT() (dAtA []byte, err error)

func (*Item) ProtoMessage 

func (*Item) ProtoMessage()

func (*Item) ProtoReflect 

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

func (*Item) Reset 

func (x *Item) Reset()

func (*Item) SizeVT 

func (m *Item) SizeVT() (n int)

func (*Item) String 

func (x *Item) String() string

func (*Item) UnmarshalVT 

func (m *Item) UnmarshalVT(dAtA []byte) error

type Item_Json 

type Item_Json struct {
	// json is the JSON representation of the item's payload, as an alternative
	// to the binary proto representation. It exists only to support clients
	// that speak the Connect-JSON protocol. Using google.protobuf.Struct means
	// the JSON is embedded inline instead of being a string, and most languages
	// should have special support for it.
	Json *structpb.Struct `protobuf:"bytes,3,opt,name=json,proto3,oneof"`
}

func (*Item_Json) CloneVT 

func (m *Item_Json) CloneVT() isItem_Payload

func (*Item_Json) EqualVT 

func (this *Item_Json) EqualVT(thatIface isItem_Payload) bool

func (*Item_Json) MarshalToSizedBufferVT 

func (m *Item_Json) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Item_Json) MarshalToVT 

func (m *Item_Json) MarshalToVT(dAtA []byte) (int, error)

func (*Item_Json) SizeVT 

func (m *Item_Json) SizeVT() (n int)

type Item_Proto 

type Item_Proto struct {
	// proto is a serialized binary proto message, following the schema for this
	// item type. Clients will need to map the item_type to a protobuf message
	// descriptor to be able to unmarshal this.
	Proto []byte `protobuf:"bytes,2,opt,name=proto,proto3,oneof"`
}

func (*Item_Proto) CloneVT 

func (m *Item_Proto) CloneVT() isItem_Payload

func (*Item_Proto) EqualVT 

func (this *Item_Proto) EqualVT(thatIface isItem_Payload) bool

func (*Item_Proto) MarshalToSizedBufferVT 

func (m *Item_Proto) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Item_Proto) MarshalToVT 

func (m *Item_Proto) MarshalToVT(dAtA []byte) (int, error)

func (*Item_Proto) SizeVT 

func (m *Item_Proto) SizeVT() (n int)

type ListFinished 

type ListFinished struct {

	// token is always set and represents an updated list continuation token that
	// can be used in subsequent calls to ContinueList or SyncList.
	Token *ListToken `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFinished) CloneMessageVT 

func (m *ListFinished) CloneMessageVT() proto.Message

func (*ListFinished) CloneVT 

func (m *ListFinished) CloneVT() *ListFinished

func (*ListFinished) Descriptor deprecated 

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

Deprecated: Use ListFinished.ProtoReflect.Descriptor instead.

func (*ListFinished) EqualMessageVT 

func (this *ListFinished) EqualMessageVT(thatMsg proto.Message) bool

func (*ListFinished) EqualVT 

func (this *ListFinished) EqualVT(that *ListFinished) bool

func (*ListFinished) GetToken 

func (x *ListFinished) GetToken() *ListToken

func (*ListFinished) MarshalToSizedBufferVT 

func (m *ListFinished) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListFinished) MarshalToVT 

func (m *ListFinished) MarshalToVT(dAtA []byte) (int, error)

func (*ListFinished) MarshalVT 

func (m *ListFinished) MarshalVT() (dAtA []byte, err error)

func (*ListFinished) ProtoMessage 

func (*ListFinished) ProtoMessage()

func (*ListFinished) ProtoReflect 

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

func (*ListFinished) Reset 

func (x *ListFinished) Reset()

func (*ListFinished) SizeVT 

func (m *ListFinished) SizeVT() (n int)

func (*ListFinished) String 

func (x *ListFinished) String() string

func (*ListFinished) UnmarshalVT 

func (m *ListFinished) UnmarshalVT(dAtA []byte) error

type ListPartialResult 

type ListPartialResult struct {

	// results is a list that contains one entry for each Item that was found.
	Items []*Item `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPartialResult) CloneMessageVT 

func (m *ListPartialResult) CloneMessageVT() proto.Message

func (*ListPartialResult) CloneVT 

func (m *ListPartialResult) CloneVT() *ListPartialResult

func (*ListPartialResult) Descriptor deprecated 

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

Deprecated: Use ListPartialResult.ProtoReflect.Descriptor instead.

func (*ListPartialResult) EqualMessageVT 

func (this *ListPartialResult) EqualMessageVT(thatMsg proto.Message) bool

func (*ListPartialResult) EqualVT 

func (this *ListPartialResult) EqualVT(that *ListPartialResult) bool

func (*ListPartialResult) GetItems 

func (x *ListPartialResult) GetItems() []*Item

func (*ListPartialResult) MarshalToSizedBufferVT 

func (m *ListPartialResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListPartialResult) MarshalToVT 

func (m *ListPartialResult) MarshalToVT(dAtA []byte) (int, error)

func (*ListPartialResult) MarshalVT 

func (m *ListPartialResult) MarshalVT() (dAtA []byte, err error)

func (*ListPartialResult) ProtoMessage 

func (*ListPartialResult) ProtoMessage()

func (*ListPartialResult) ProtoReflect 

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

func (*ListPartialResult) Reset 

func (x *ListPartialResult) Reset()

func (*ListPartialResult) SizeVT 

func (m *ListPartialResult) SizeVT() (n int)

func (*ListPartialResult) String 

func (x *ListPartialResult) String() string

func (*ListPartialResult) UnmarshalVT 

func (m *ListPartialResult) UnmarshalVT(dAtA []byte) error

type ListResponse 

type ListResponse struct {

	// Types that are assignable to Response:
	//
	//	*ListResponse_Result
	//	*ListResponse_Finished
	Response isListResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

These are stream messages, so multiple responses may be sent.

func (*ListResponse) CloneMessageVT 

func (m *ListResponse) CloneMessageVT() proto.Message

func (*ListResponse) CloneVT 

func (m *ListResponse) CloneVT() *ListResponse

func (*ListResponse) Descriptor deprecated 

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) EqualMessageVT 

func (this *ListResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*ListResponse) EqualVT 

func (this *ListResponse) EqualVT(that *ListResponse) bool

func (*ListResponse) GetFinished 

func (x *ListResponse) GetFinished() *ListFinished

func (*ListResponse) GetResponse 

func (m *ListResponse) GetResponse() isListResponse_Response

func (*ListResponse) GetResult 

func (x *ListResponse) GetResult() *ListPartialResult

func (*ListResponse) MarshalToSizedBufferVT 

func (m *ListResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListResponse) MarshalToVT 

func (m *ListResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ListResponse) MarshalVT 

func (m *ListResponse) MarshalVT() (dAtA []byte, err error)

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect 

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

func (*ListResponse) Reset 

func (x *ListResponse) Reset()

func (*ListResponse) SizeVT 

func (m *ListResponse) SizeVT() (n int)

func (*ListResponse) String 

func (x *ListResponse) String() string

func (*ListResponse) UnmarshalVT 

func (m *ListResponse) UnmarshalVT(dAtA []byte) error

type ListResponse_Finished 

type ListResponse_Finished struct {
	// Finished is sent when there are no more results in this operation, and
	// there will only be one.
	Finished *ListFinished `protobuf:"bytes,2,opt,name=finished,proto3,oneof"`
}

func (*ListResponse_Finished) CloneVT 

func (m *ListResponse_Finished) CloneVT() isListResponse_Response

func (*ListResponse_Finished) EqualVT 

func (this *ListResponse_Finished) EqualVT(thatIface isListResponse_Response) bool

func (*ListResponse_Finished) MarshalToSizedBufferVT 

func (m *ListResponse_Finished) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListResponse_Finished) MarshalToVT 

func (m *ListResponse_Finished) MarshalToVT(dAtA []byte) (int, error)

func (*ListResponse_Finished) SizeVT 

func (m *ListResponse_Finished) SizeVT() (n int)

type ListResponse_Result 

type ListResponse_Result struct {
	// Result is a segment of the result set - multiple of these may be returned
	// in a stream before the final "finished" message.
	Result *ListPartialResult `protobuf:"bytes,1,opt,name=result,proto3,oneof"`
}

func (*ListResponse_Result) CloneVT 

func (m *ListResponse_Result) CloneVT() isListResponse_Response

func (*ListResponse_Result) EqualVT 

func (this *ListResponse_Result) EqualVT(thatIface isListResponse_Response) bool

func (*ListResponse_Result) MarshalToSizedBufferVT 

func (m *ListResponse_Result) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListResponse_Result) MarshalToVT 

func (m *ListResponse_Result) MarshalToVT(dAtA []byte) (int, error)

func (*ListResponse_Result) SizeVT 

func (m *ListResponse_Result) SizeVT() (n int)

type ListToken 

type ListToken struct {

	// token_data will always be returned, and can be used to expand the result
	// set via ContinueList (if can_continue is true), or to get changed items
	// within the result set via SyncList (if can_sync is true). The token_data
	// itself is opaque and cannot be parsed or modified by clients.
	TokenData []byte `protobuf:"bytes,1,opt,name=token_data,json=tokenData,proto3" json:"token_data,omitempty"`
	// can_continue indicates that there are more results available by expanding
	// the pagination window by calling ContinueList with this token.
	CanContinue bool `protobuf:"varint,2,opt,name=can_continue,json=canContinue,proto3" json:"can_continue,omitempty"`
	// can_sync indicates that you could call SyncList with this token later to
	// get updated items. This is determined by the type of store you're listing
	// from.
	CanSync bool `protobuf:"varint,3,opt,name=can_sync,json=canSync,proto3" json:"can_sync,omitempty"`
	// contains filtered or unexported fields
}

ListToken is an opaque token that can be used to continue (paginate) or sync results from a previous List operation.

func (*ListToken) CloneMessageVT 

func (m *ListToken) CloneMessageVT() proto.Message

func (*ListToken) CloneVT 

func (m *ListToken) CloneVT() *ListToken

func (*ListToken) Descriptor deprecated 

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

Deprecated: Use ListToken.ProtoReflect.Descriptor instead.

func (*ListToken) EqualMessageVT 

func (this *ListToken) EqualMessageVT(thatMsg proto.Message) bool

func (*ListToken) EqualVT 

func (this *ListToken) EqualVT(that *ListToken) bool

func (*ListToken) GetCanContinue 

func (x *ListToken) GetCanContinue() bool

func (*ListToken) GetCanSync 

func (x *ListToken) GetCanSync() bool

func (*ListToken) GetTokenData 

func (x *ListToken) GetTokenData() []byte

func (*ListToken) MarshalToSizedBufferVT 

func (m *ListToken) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListToken) MarshalToVT 

func (m *ListToken) MarshalToVT(dAtA []byte) (int, error)

func (*ListToken) MarshalVT 

func (m *ListToken) MarshalVT() (dAtA []byte, err error)

func (*ListToken) ProtoMessage 

func (*ListToken) ProtoMessage()

func (*ListToken) ProtoReflect 

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

func (*ListToken) Reset 

func (x *ListToken) Reset()

func (*ListToken) SizeVT 

func (m *ListToken) SizeVT() (n int)

func (*ListToken) String 

func (x *ListToken) String() string

func (*ListToken) UnmarshalVT 

func (m *ListToken) UnmarshalVT(dAtA []byte) error

type PutItem 

type PutItem struct {

	// item is the data to be put, including its item_type.
	Item *Item `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
	// contains filtered or unexported fields
}

func (*PutItem) CloneMessageVT 

func (m *PutItem) CloneMessageVT() proto.Message

func (*PutItem) CloneVT 

func (m *PutItem) CloneVT() *PutItem

func (*PutItem) Descriptor deprecated 

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

Deprecated: Use PutItem.ProtoReflect.Descriptor instead.

func (*PutItem) EqualMessageVT 

func (this *PutItem) EqualMessageVT(thatMsg proto.Message) bool

func (*PutItem) EqualVT 

func (this *PutItem) EqualVT(that *PutItem) bool

func (*PutItem) GetItem 

func (x *PutItem) GetItem() *Item

func (*PutItem) MarshalToSizedBufferVT 

func (m *PutItem) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PutItem) MarshalToVT 

func (m *PutItem) MarshalToVT(dAtA []byte) (int, error)

func (*PutItem) MarshalVT 

func (m *PutItem) MarshalVT() (dAtA []byte, err error)

func (*PutItem) ProtoMessage 

func (*PutItem) ProtoMessage()

func (*PutItem) ProtoReflect 

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

func (*PutItem) Reset 

func (x *PutItem) Reset()

func (*PutItem) SizeVT 

func (m *PutItem) SizeVT() (n int)

func (*PutItem) String 

func (x *PutItem) String() string

func (*PutItem) UnmarshalVT 

func (m *PutItem) UnmarshalVT(dAtA []byte) error

type PutRequest 

type PutRequest struct {

	// store_id is a globally unique Store ID, which can be looked up from the
	// console or CLI.
	StoreId uint64 `protobuf:"varint,1,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
	// puts is one or more items to be put into the Store.
	Puts []*PutItem `protobuf:"bytes,2,rep,name=puts,proto3" json:"puts,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRequest) CloneMessageVT 

func (m *PutRequest) CloneMessageVT() proto.Message

func (*PutRequest) CloneVT 

func (m *PutRequest) CloneVT() *PutRequest

func (*PutRequest) Descriptor deprecated 

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

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) EqualMessageVT 

func (this *PutRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*PutRequest) EqualVT 

func (this *PutRequest) EqualVT(that *PutRequest) bool

func (*PutRequest) GetPuts 

func (x *PutRequest) GetPuts() []*PutItem

func (*PutRequest) GetStoreId 

func (x *PutRequest) GetStoreId() uint64

func (*PutRequest) MarshalToSizedBufferVT 

func (m *PutRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PutRequest) MarshalToVT 

func (m *PutRequest) MarshalToVT(dAtA []byte) (int, error)

func (*PutRequest) MarshalVT 

func (m *PutRequest) MarshalVT() (dAtA []byte, err error)

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect 

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

func (*PutRequest) Reset 

func (x *PutRequest) Reset()

func (*PutRequest) SizeVT 

func (m *PutRequest) SizeVT() (n int)

func (*PutRequest) String 

func (x *PutRequest) String() string

func (*PutRequest) UnmarshalVT 

func (m *PutRequest) UnmarshalVT(dAtA []byte) error

type PutResponse 

type PutResponse struct {

	// items is the full result of each put operation. The response items are in
	// the same order as the request items. Each item is fully "filled out" - for
	// example, `initialValue` and `fromMetadata` fields are resolved.
	Items []*Item `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*PutResponse) CloneMessageVT 

func (m *PutResponse) CloneMessageVT() proto.Message

func (*PutResponse) CloneVT 

func (m *PutResponse) CloneVT() *PutResponse

func (*PutResponse) Descriptor deprecated 

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

Deprecated: Use PutResponse.ProtoReflect.Descriptor instead.

func (*PutResponse) EqualMessageVT 

func (this *PutResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*PutResponse) EqualVT 

func (this *PutResponse) EqualVT(that *PutResponse) bool

func (*PutResponse) GetItems 

func (x *PutResponse) GetItems() []*Item

func (*PutResponse) MarshalToSizedBufferVT 

func (m *PutResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PutResponse) MarshalToVT 

func (m *PutResponse) MarshalToVT(dAtA []byte) (int, error)

func (*PutResponse) MarshalVT 

func (m *PutResponse) MarshalVT() (dAtA []byte, err error)

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) ProtoReflect 

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

func (*PutResponse) Reset 

func (x *PutResponse) Reset()

func (*PutResponse) SizeVT 

func (m *PutResponse) SizeVT() (n int)

func (*PutResponse) String 

func (x *PutResponse) String() string

func (*PutResponse) UnmarshalVT 

func (m *PutResponse) UnmarshalVT(dAtA []byte) error

type ScanRootPathResult 

type ScanRootPathResult struct {

	// key_path is a single root key path. Users can Query by this root path to
	// get all of the items under it.
	KeyPath string `protobuf:"bytes,1,opt,name=key_path,json=keyPath,proto3" json:"key_path,omitempty"`
	// contains filtered or unexported fields
}

func (*ScanRootPathResult) CloneMessageVT 

func (m *ScanRootPathResult) CloneMessageVT() proto.Message

func (*ScanRootPathResult) CloneVT 

func (m *ScanRootPathResult) CloneVT() *ScanRootPathResult

func (*ScanRootPathResult) Descriptor deprecated 

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

Deprecated: Use ScanRootPathResult.ProtoReflect.Descriptor instead.

func (*ScanRootPathResult) EqualMessageVT 

func (this *ScanRootPathResult) EqualMessageVT(thatMsg proto.Message) bool

func (*ScanRootPathResult) EqualVT 

func (this *ScanRootPathResult) EqualVT(that *ScanRootPathResult) bool

func (*ScanRootPathResult) GetKeyPath 

func (x *ScanRootPathResult) GetKeyPath() string

func (*ScanRootPathResult) MarshalToSizedBufferVT 

func (m *ScanRootPathResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ScanRootPathResult) MarshalToVT 

func (m *ScanRootPathResult) MarshalToVT(dAtA []byte) (int, error)

func (*ScanRootPathResult) MarshalVT 

func (m *ScanRootPathResult) MarshalVT() (dAtA []byte, err error)

func (*ScanRootPathResult) ProtoMessage 

func (*ScanRootPathResult) ProtoMessage()

func (*ScanRootPathResult) ProtoReflect 

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

func (*ScanRootPathResult) Reset 

func (x *ScanRootPathResult) Reset()

func (*ScanRootPathResult) SizeVT 

func (m *ScanRootPathResult) SizeVT() (n int)

func (*ScanRootPathResult) String 

func (x *ScanRootPathResult) String() string

func (*ScanRootPathResult) UnmarshalVT 

func (m *ScanRootPathResult) UnmarshalVT(dAtA []byte) error

type ScanRootPathsRequest 

type ScanRootPathsRequest struct {

	// store_id is a globally unique Store ID, which can be looked up from the
	// console or CLI.
	StoreId uint64 `protobuf:"varint,1,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
	// Limit sets an upper bound on how many root paths to return.
	Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// pagination_token is an optional token to continue retrieving the next page of results.
	// This value must be read from a ScanRootPathsResponse and passed with a clone of the
	// previous request to fetch the next page of data
	PaginationToken []byte `protobuf:"bytes,3,opt,name=pagination_token,json=paginationToken,proto3" json:"pagination_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ScanRootPathsRequest) CloneMessageVT 

func (m *ScanRootPathsRequest) CloneMessageVT() proto.Message

func (*ScanRootPathsRequest) CloneVT 

func (m *ScanRootPathsRequest) CloneVT() *ScanRootPathsRequest

func (*ScanRootPathsRequest) Descriptor deprecated 

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

Deprecated: Use ScanRootPathsRequest.ProtoReflect.Descriptor instead.

func (*ScanRootPathsRequest) EqualMessageVT 

func (this *ScanRootPathsRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*ScanRootPathsRequest) EqualVT 

func (this *ScanRootPathsRequest) EqualVT(that *ScanRootPathsRequest) bool

func (*ScanRootPathsRequest) GetLimit 

func (x *ScanRootPathsRequest) GetLimit() uint32

func (*ScanRootPathsRequest) GetPaginationToken 

func (x *ScanRootPathsRequest) GetPaginationToken() []byte

func (*ScanRootPathsRequest) GetStoreId 

func (x *ScanRootPathsRequest) GetStoreId() uint64

func (*ScanRootPathsRequest) MarshalToSizedBufferVT 

func (m *ScanRootPathsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ScanRootPathsRequest) MarshalToVT 

func (m *ScanRootPathsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ScanRootPathsRequest) MarshalVT 

func (m *ScanRootPathsRequest) MarshalVT() (dAtA []byte, err error)

func (*ScanRootPathsRequest) ProtoMessage 

func (*ScanRootPathsRequest) ProtoMessage()

func (*ScanRootPathsRequest) ProtoReflect 

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

func (*ScanRootPathsRequest) Reset 

func (x *ScanRootPathsRequest) Reset()

func (*ScanRootPathsRequest) SizeVT 

func (m *ScanRootPathsRequest) SizeVT() (n int)

func (*ScanRootPathsRequest) String 

func (x *ScanRootPathsRequest) String() string

func (*ScanRootPathsRequest) UnmarshalVT 

func (m *ScanRootPathsRequest) UnmarshalVT(dAtA []byte) error

type ScanRootPathsResponse 

type ScanRootPathsResponse struct {

	// results is a list that contains one entry for each root path that was found.
	Results []*ScanRootPathResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// This field is optional and will be set if there are more query results to fetch.
	// To fetch the next page of results you must make the exact same ScanRootPathsRequest as before
	// but set ScanRootPathsRequest.pagination_token to the value returned here.
	PaginationToken []byte `protobuf:"bytes,2,opt,name=pagination_token,json=paginationToken,proto3" json:"pagination_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ScanRootPathsResponse) CloneMessageVT 

func (m *ScanRootPathsResponse) CloneMessageVT() proto.Message

func (*ScanRootPathsResponse) CloneVT 

func (m *ScanRootPathsResponse) CloneVT() *ScanRootPathsResponse

func (*ScanRootPathsResponse) Descriptor deprecated 

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

Deprecated: Use ScanRootPathsResponse.ProtoReflect.Descriptor instead.

func (*ScanRootPathsResponse) EqualMessageVT 

func (this *ScanRootPathsResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*ScanRootPathsResponse) EqualVT 

func (this *ScanRootPathsResponse) EqualVT(that *ScanRootPathsResponse) bool

func (*ScanRootPathsResponse) GetPaginationToken 

func (x *ScanRootPathsResponse) GetPaginationToken() []byte

func (*ScanRootPathsResponse) GetResults 

func (x *ScanRootPathsResponse) GetResults() []*ScanRootPathResult

func (*ScanRootPathsResponse) MarshalToSizedBufferVT 

func (m *ScanRootPathsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ScanRootPathsResponse) MarshalToVT 

func (m *ScanRootPathsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ScanRootPathsResponse) MarshalVT 

func (m *ScanRootPathsResponse) MarshalVT() (dAtA []byte, err error)

func (*ScanRootPathsResponse) ProtoMessage 

func (*ScanRootPathsResponse) ProtoMessage()

func (*ScanRootPathsResponse) ProtoReflect 

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

func (*ScanRootPathsResponse) Reset 

func (x *ScanRootPathsResponse) Reset()

func (*ScanRootPathsResponse) SizeVT 

func (m *ScanRootPathsResponse) SizeVT() (n int)

func (*ScanRootPathsResponse) String 

func (x *ScanRootPathsResponse) String() string

func (*ScanRootPathsResponse) UnmarshalVT 

func (m *ScanRootPathsResponse) UnmarshalVT(dAtA []byte) error

type SortDirection 

type SortDirection int32

SortDirection represents the direction of iteration. 

const (
	SortDirection_SORT_ASCENDING  SortDirection = 0 // This is the default
	SortDirection_SORT_DESCENDING SortDirection = 1
)

func (SortDirection) Descriptor 

func (SortDirection) Descriptor() protoreflect.EnumDescriptor

func (SortDirection) Enum 

func (x SortDirection) Enum() *SortDirection

func (SortDirection) EnumDescriptor deprecated 

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

Deprecated: Use SortDirection.Descriptor instead.

func (SortDirection) Number 

func (x SortDirection) Number() protoreflect.EnumNumber

func (SortDirection) String 

func (x SortDirection) String() string

func (SortDirection) Type 

func (SortDirection) Type() protoreflect.EnumType

type SortableProperty 

type SortableProperty int32

SortableProperty is used to reference a sortable (i.e. locally indexed) property within an item. These properties are either built in, or they must be explicitly declared in the schema / store config so they can be populated when items are written/updated. 

const (
	// SORTABLE_PROPERTY_KEY_PATH is the full key path of the item. This is the
	// default sort property if none is specified. TODO: Document how these are ordered.
	SortableProperty_SORTABLE_PROPERTY_KEY_PATH SortableProperty = 0
	// SORTABLE_PROPERTY_LAST_MODIFIED_VERSION sorts by the last modified version
	// of the items, with ascending order being from oldest to newest. This is
	// only available if the store / item is configured to track last modified
	// versions.
	SortableProperty_SORTABLE_PROPERTY_LAST_MODIFIED_VERSION SortableProperty = 1
	// SORTABLE_PROPERTY_GROUP_LOCAL_INDEX_1 through
	// SORTABLE_PROPERTY_GROUP_LOCAL_INDEX_4 are user-specified sortable
	// properties which may be defined in the schema. The maximum supported number
	// of group local indexes currently depends on the store configuration and the
	// underlying database platform.
	SortableProperty_SORTABLE_PROPERTY_GROUP_LOCAL_INDEX_1 SortableProperty = 8
	SortableProperty_SORTABLE_PROPERTY_GROUP_LOCAL_INDEX_2 SortableProperty = 9
	SortableProperty_SORTABLE_PROPERTY_GROUP_LOCAL_INDEX_3 SortableProperty = 10
	SortableProperty_SORTABLE_PROPERTY_GROUP_LOCAL_INDEX_4 SortableProperty = 11
)

func (SortableProperty) Descriptor 

func (SortableProperty) Descriptor() protoreflect.EnumDescriptor

func (SortableProperty) Enum 

func (x SortableProperty) Enum() *SortableProperty

func (SortableProperty) EnumDescriptor deprecated 

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

Deprecated: Use SortableProperty.Descriptor instead.

func (SortableProperty) Number 

func (x SortableProperty) Number() protoreflect.EnumNumber

func (SortableProperty) String 

func (x SortableProperty) String() string

func (SortableProperty) Type 

func (SortableProperty) Type() protoreflect.EnumType

type SyncListPartialResponse 

type SyncListPartialResponse struct {

	// Items in the token window that were added or updated since the last
	// sync/list.
	ChangedItems []*Item `protobuf:"bytes,1,rep,name=changed_items,json=changedItems,proto3" json:"changed_items,omitempty"`
	// Items in the token window that were deleted since the last sync/list.
	DeletedItems []*DeletedItem `protobuf:"bytes,2,rep,name=deleted_items,json=deletedItems,proto3" json:"deleted_items,omitempty"`
	// Items that were changed but which do not currently use the CustomSortProperty
	// that the list window is based on. This can only be populated when using a
	// CustomSortProperty (in the original BeginList request).
	// It may be that these items have never been in the CustomSortProperty,
	// or that they were in the CustomSortProperty at some point in time but are not now,
	// or that they are in the CustomSortProperty but have moved position and are no longer
	// in the sync able window identified by a token.
	UpdatedItemKeysOutsideListWindow []string `` /* 165-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SyncListPartialResponse) CloneMessageVT 

func (m *SyncListPartialResponse) CloneMessageVT() proto.Message

func (*SyncListPartialResponse) CloneVT 

func (m *SyncListPartialResponse) CloneVT() *SyncListPartialResponse

func (*SyncListPartialResponse) Descriptor deprecated 

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

Deprecated: Use SyncListPartialResponse.ProtoReflect.Descriptor instead.

func (*SyncListPartialResponse) EqualMessageVT 

func (this *SyncListPartialResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*SyncListPartialResponse) EqualVT 

func (this *SyncListPartialResponse) EqualVT(that *SyncListPartialResponse) bool

func (*SyncListPartialResponse) GetChangedItems 

func (x *SyncListPartialResponse) GetChangedItems() []*Item

func (*SyncListPartialResponse) GetDeletedItems 

func (x *SyncListPartialResponse) GetDeletedItems() []*DeletedItem

func (*SyncListPartialResponse) GetUpdatedItemKeysOutsideListWindow 

func (x *SyncListPartialResponse) GetUpdatedItemKeysOutsideListWindow() []string

func (*SyncListPartialResponse) MarshalToSizedBufferVT 

func (m *SyncListPartialResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SyncListPartialResponse) MarshalToVT 

func (m *SyncListPartialResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SyncListPartialResponse) MarshalVT 

func (m *SyncListPartialResponse) MarshalVT() (dAtA []byte, err error)

func (*SyncListPartialResponse) ProtoMessage 

func (*SyncListPartialResponse) ProtoMessage()

func (*SyncListPartialResponse) ProtoReflect 

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

func (*SyncListPartialResponse) Reset 

func (x *SyncListPartialResponse) Reset()

func (*SyncListPartialResponse) SizeVT 

func (m *SyncListPartialResponse) SizeVT() (n int)

func (*SyncListPartialResponse) String 

func (x *SyncListPartialResponse) String() string

func (*SyncListPartialResponse) UnmarshalVT 

func (m *SyncListPartialResponse) UnmarshalVT(dAtA []byte) error

type SyncListRequest 

type SyncListRequest struct {

	// token_data is an opaque list continuation token returned by a previous call to
	// List, ContinueList, or SyncList.
	TokenData []byte `protobuf:"bytes,1,opt,name=token_data,json=tokenData,proto3" json:"token_data,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncListRequest) CloneMessageVT 

func (m *SyncListRequest) CloneMessageVT() proto.Message

func (*SyncListRequest) CloneVT 

func (m *SyncListRequest) CloneVT() *SyncListRequest

func (*SyncListRequest) Descriptor deprecated 

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

Deprecated: Use SyncListRequest.ProtoReflect.Descriptor instead.

func (*SyncListRequest) EqualMessageVT 

func (this *SyncListRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*SyncListRequest) EqualVT 

func (this *SyncListRequest) EqualVT(that *SyncListRequest) bool

func (*SyncListRequest) GetTokenData 

func (x *SyncListRequest) GetTokenData() []byte

func (*SyncListRequest) MarshalToSizedBufferVT 

func (m *SyncListRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SyncListRequest) MarshalToVT 

func (m *SyncListRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SyncListRequest) MarshalVT 

func (m *SyncListRequest) MarshalVT() (dAtA []byte, err error)

func (*SyncListRequest) ProtoMessage 

func (*SyncListRequest) ProtoMessage()

func (*SyncListRequest) ProtoReflect 

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

func (*SyncListRequest) Reset 

func (x *SyncListRequest) Reset()

func (*SyncListRequest) SizeVT 

func (m *SyncListRequest) SizeVT() (n int)

func (*SyncListRequest) String 

func (x *SyncListRequest) String() string

func (*SyncListRequest) UnmarshalVT 

func (m *SyncListRequest) UnmarshalVT(dAtA []byte) error

type SyncListReset 

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

SyncListReset is returned if the provided token is too far behind to be able to report deleted items, and subsequent results will start over with a fresh result set. Clients should discard any cached data from this result set and start re-populating it.

func (*SyncListReset) CloneMessageVT 

func (m *SyncListReset) CloneMessageVT() proto.Message

func (*SyncListReset) CloneVT 

func (m *SyncListReset) CloneVT() *SyncListReset

func (*SyncListReset) Descriptor deprecated 

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

Deprecated: Use SyncListReset.ProtoReflect.Descriptor instead.

func (*SyncListReset) EqualMessageVT 

func (this *SyncListReset) EqualMessageVT(thatMsg proto.Message) bool

func (*SyncListReset) EqualVT 

func (this *SyncListReset) EqualVT(that *SyncListReset) bool

func (*SyncListReset) MarshalToSizedBufferVT 

func (m *SyncListReset) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SyncListReset) MarshalToVT 

func (m *SyncListReset) MarshalToVT(dAtA []byte) (int, error)

func (*SyncListReset) MarshalVT 

func (m *SyncListReset) MarshalVT() (dAtA []byte, err error)

func (*SyncListReset) ProtoMessage 

func (*SyncListReset) ProtoMessage()

func (*SyncListReset) ProtoReflect 

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

func (*SyncListReset) Reset 

func (x *SyncListReset) Reset()

func (*SyncListReset) SizeVT 

func (m *SyncListReset) SizeVT() (n int)

func (*SyncListReset) String 

func (x *SyncListReset) String() string

func (*SyncListReset) UnmarshalVT 

func (m *SyncListReset) UnmarshalVT(dAtA []byte) error

type SyncListResponse 

type SyncListResponse struct {

	// Types that are assignable to Response:
	//
	//	*SyncListResponse_Reset_
	//	*SyncListResponse_Result
	//	*SyncListResponse_Finished
	Response isSyncListResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

These are stream messages, so multiple responses may be sent.

func (*SyncListResponse) CloneMessageVT 

func (m *SyncListResponse) CloneMessageVT() proto.Message

func (*SyncListResponse) CloneVT 

func (m *SyncListResponse) CloneVT() *SyncListResponse

func (*SyncListResponse) Descriptor deprecated 

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

Deprecated: Use SyncListResponse.ProtoReflect.Descriptor instead.

func (*SyncListResponse) EqualMessageVT 

func (this *SyncListResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*SyncListResponse) EqualVT 

func (this *SyncListResponse) EqualVT(that *SyncListResponse) bool

func (*SyncListResponse) GetFinished 

func (x *SyncListResponse) GetFinished() *ListFinished

func (*SyncListResponse) GetReset_ 

func (x *SyncListResponse) GetReset_() *SyncListReset

func (*SyncListResponse) GetResponse 

func (m *SyncListResponse) GetResponse() isSyncListResponse_Response

func (*SyncListResponse) GetResult 

func (x *SyncListResponse) GetResult() *SyncListPartialResponse

func (*SyncListResponse) MarshalToSizedBufferVT 

func (m *SyncListResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SyncListResponse) MarshalToVT 

func (m *SyncListResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SyncListResponse) MarshalVT 

func (m *SyncListResponse) MarshalVT() (dAtA []byte, err error)

func (*SyncListResponse) ProtoMessage 

func (*SyncListResponse) ProtoMessage()

func (*SyncListResponse) ProtoReflect 

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

func (*SyncListResponse) Reset 

func (x *SyncListResponse) Reset()

func (*SyncListResponse) SizeVT 

func (m *SyncListResponse) SizeVT() (n int)

func (*SyncListResponse) String 

func (x *SyncListResponse) String() string

func (*SyncListResponse) UnmarshalVT 

func (m *SyncListResponse) UnmarshalVT(dAtA []byte) error

type SyncListResponse_Finished 

type SyncListResponse_Finished struct {
	// Finished is sent when the sync is complete, and there will only be one.
	Finished *ListFinished `protobuf:"bytes,3,opt,name=finished,proto3,oneof"`
}

func (*SyncListResponse_Finished) CloneVT 

func (m *SyncListResponse_Finished) CloneVT() isSyncListResponse_Response

func (*SyncListResponse_Finished) EqualVT 

func (this *SyncListResponse_Finished) EqualVT(thatIface isSyncListResponse_Response) bool

func (*SyncListResponse_Finished) MarshalToSizedBufferVT 

func (m *SyncListResponse_Finished) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SyncListResponse_Finished) MarshalToVT 

func (m *SyncListResponse_Finished) MarshalToVT(dAtA []byte) (int, error)

func (*SyncListResponse_Finished) SizeVT 

func (m *SyncListResponse_Finished) SizeVT() (n int)

type SyncListResponse_Reset_ 

type SyncListResponse_Reset_ struct {
	// SyncListReset is returned if the provided token is too far behind to be able to
	// report deleted items, and subsequent results will start over with a fresh result
	// set. Clients should discard any cached data from this result set and start re-populating it.
	Reset_ *SyncListReset `protobuf:"bytes,1,opt,name=reset,proto3,oneof"`
}

func (*SyncListResponse_Reset_) CloneVT 

func (m *SyncListResponse_Reset_) CloneVT() isSyncListResponse_Response

func (*SyncListResponse_Reset_) EqualVT 

func (this *SyncListResponse_Reset_) EqualVT(thatIface isSyncListResponse_Response) bool

func (*SyncListResponse_Reset_) MarshalToSizedBufferVT 

func (m *SyncListResponse_Reset_) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SyncListResponse_Reset_) MarshalToVT 

func (m *SyncListResponse_Reset_) MarshalToVT(dAtA []byte) (int, error)

func (*SyncListResponse_Reset_) SizeVT 

func (m *SyncListResponse_Reset_) SizeVT() (n int)

type SyncListResponse_Result 

type SyncListResponse_Result struct {
	// Result is a segment of sync results - multiple of these may be returned.
	Result *SyncListPartialResponse `protobuf:"bytes,2,opt,name=result,proto3,oneof"`
}

func (*SyncListResponse_Result) CloneVT 

func (m *SyncListResponse_Result) CloneVT() isSyncListResponse_Response

func (*SyncListResponse_Result) EqualVT 

func (this *SyncListResponse_Result) EqualVT(thatIface isSyncListResponse_Response) bool

func (*SyncListResponse_Result) MarshalToSizedBufferVT 

func (m *SyncListResponse_Result) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SyncListResponse_Result) MarshalToVT 

func (m *SyncListResponse_Result) MarshalToVT(dAtA []byte) (int, error)

func (*SyncListResponse_Result) SizeVT 

func (m *SyncListResponse_Result) SizeVT() (n int)

type TransactionBegin 

type TransactionBegin struct {

	// store_id is a globally unique Store ID, which can be looked up from the
	// console or CLI.
	StoreId uint64 `protobuf:"varint,1,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
	// contains filtered or unexported fields
}

TransactionBegin opens a transaction and sets various options that will be used throughout the transaction.

func (*TransactionBegin) CloneMessageVT 

func (m *TransactionBegin) CloneMessageVT() proto.Message

func (*TransactionBegin) CloneVT 

func (m *TransactionBegin) CloneVT() *TransactionBegin

func (*TransactionBegin) Descriptor deprecated 

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

Deprecated: Use TransactionBegin.ProtoReflect.Descriptor instead.

func (*TransactionBegin) EqualMessageVT 

func (this *TransactionBegin) EqualMessageVT(thatMsg proto.Message) bool

func (*TransactionBegin) EqualVT 

func (this *TransactionBegin) EqualVT(that *TransactionBegin) bool

func (*TransactionBegin) GetStoreId 

func (x *TransactionBegin) GetStoreId() uint64

func (*TransactionBegin) MarshalToSizedBufferVT 

func (m *TransactionBegin) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionBegin) MarshalToVT 

func (m *TransactionBegin) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionBegin) MarshalVT 

func (m *TransactionBegin) MarshalVT() (dAtA []byte, err error)

func (*TransactionBegin) ProtoMessage 

func (*TransactionBegin) ProtoMessage()

func (*TransactionBegin) ProtoReflect 

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

func (*TransactionBegin) Reset 

func (x *TransactionBegin) Reset()

func (*TransactionBegin) SizeVT 

func (m *TransactionBegin) SizeVT() (n int)

func (*TransactionBegin) String 

func (x *TransactionBegin) String() string

func (*TransactionBegin) UnmarshalVT 

func (m *TransactionBegin) UnmarshalVT(dAtA []byte) error

type TransactionBeginList 

type TransactionBeginList struct {

	// key_path_prefix is the a prefix that limits what items we will return. This
	// must contain at least a root segment. See Item#key_path for more details.
	KeyPathPrefix string `protobuf:"bytes,1,opt,name=key_path_prefix,json=keyPathPrefix,proto3" json:"key_path_prefix,omitempty"`
	// limit is the maximum number of items to return. If this is not specified or
	// set to 0, it will be unlimited. Fewer items than the limit may be
	// returned even if there are more items to get - make sure to check
	// token.can_continue.
	Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// sort_property is the property of the item to sort the results by. If this
	// is not set, we will sort by key path.
	SortProperty SortableProperty `` /* 131-byte string literal not displayed */
	// sort_direction is the direction to sort the results in. If this is not set,
	// we will sort in ascending order.
	SortDirection SortDirection `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

TransactionBeginList is a subset of the ListRequest message, for listing within the context of a transaction.

func (*TransactionBeginList) CloneMessageVT 

func (m *TransactionBeginList) CloneMessageVT() proto.Message

func (*TransactionBeginList) CloneVT 

func (m *TransactionBeginList) CloneVT() *TransactionBeginList

func (*TransactionBeginList) Descriptor deprecated 

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

Deprecated: Use TransactionBeginList.ProtoReflect.Descriptor instead.

func (*TransactionBeginList) EqualMessageVT 

func (this *TransactionBeginList) EqualMessageVT(thatMsg proto.Message) bool

func (*TransactionBeginList) EqualVT 

func (this *TransactionBeginList) EqualVT(that *TransactionBeginList) bool

func (*TransactionBeginList) GetKeyPathPrefix 

func (x *TransactionBeginList) GetKeyPathPrefix() string

func (*TransactionBeginList) GetLimit 

func (x *TransactionBeginList) GetLimit() uint32

func (*TransactionBeginList) GetSortDirection 

func (x *TransactionBeginList) GetSortDirection() SortDirection

func (*TransactionBeginList) GetSortProperty 

func (x *TransactionBeginList) GetSortProperty() SortableProperty

func (*TransactionBeginList) MarshalToSizedBufferVT 

func (m *TransactionBeginList) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionBeginList) MarshalToVT 

func (m *TransactionBeginList) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionBeginList) MarshalVT 

func (m *TransactionBeginList) MarshalVT() (dAtA []byte, err error)

func (*TransactionBeginList) ProtoMessage 

func (*TransactionBeginList) ProtoMessage()

func (*TransactionBeginList) ProtoReflect 

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

func (*TransactionBeginList) Reset 

func (x *TransactionBeginList) Reset()

func (*TransactionBeginList) SizeVT 

func (m *TransactionBeginList) SizeVT() (n int)

func (*TransactionBeginList) String 

func (x *TransactionBeginList) String() string

func (*TransactionBeginList) UnmarshalVT 

func (m *TransactionBeginList) UnmarshalVT(dAtA []byte) error

type TransactionContinueList 

type TransactionContinueList struct {

	// token is an opaque list continuation token returned by a previous call to
	// TransactionBeginList or TransactionContinueList.
	TokenData []byte `protobuf:"bytes,1,opt,name=token_data,json=tokenData,proto3" json:"token_data,omitempty"`
	// direction indicates whether we are expanding the result set (paginating)
	// forward (in the direction of the original List operation) or backward (in
	// the opposite direction). The default is to expand forward.
	Direction ContinueListDirection `protobuf:"varint,4,opt,name=direction,proto3,enum=stately.db.ContinueListDirection" json:"direction,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionContinueList) CloneMessageVT 

func (m *TransactionContinueList) CloneMessageVT() proto.Message

func (*TransactionContinueList) CloneVT 

func (m *TransactionContinueList) CloneVT() *TransactionContinueList

func (*TransactionContinueList) Descriptor deprecated 

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

Deprecated: Use TransactionContinueList.ProtoReflect.Descriptor instead.

func (*TransactionContinueList) EqualMessageVT 

func (this *TransactionContinueList) EqualMessageVT(thatMsg proto.Message) bool

func (*TransactionContinueList) EqualVT 

func (this *TransactionContinueList) EqualVT(that *TransactionContinueList) bool

func (*TransactionContinueList) GetDirection 

func (x *TransactionContinueList) GetDirection() ContinueListDirection

func (*TransactionContinueList) GetTokenData 

func (x *TransactionContinueList) GetTokenData() []byte

func (*TransactionContinueList) MarshalToSizedBufferVT 

func (m *TransactionContinueList) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionContinueList) MarshalToVT 

func (m *TransactionContinueList) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionContinueList) MarshalVT 

func (m *TransactionContinueList) MarshalVT() (dAtA []byte, err error)

func (*TransactionContinueList) ProtoMessage 

func (*TransactionContinueList) ProtoMessage()

func (*TransactionContinueList) ProtoReflect 

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

func (*TransactionContinueList) Reset 

func (x *TransactionContinueList) Reset()

func (*TransactionContinueList) SizeVT 

func (m *TransactionContinueList) SizeVT() (n int)

func (*TransactionContinueList) String 

func (x *TransactionContinueList) String() string

func (*TransactionContinueList) UnmarshalVT 

func (m *TransactionContinueList) UnmarshalVT(dAtA []byte) error

type TransactionDelete 

type TransactionDelete struct {

	// deletes is one or more items to be deleted from the Group.
	Deletes []*DeleteItem `protobuf:"bytes,1,rep,name=deletes,proto3" json:"deletes,omitempty"`
	// contains filtered or unexported fields
}

TransactionDelete is a subset of the DeleteRequest message, for performing deletes within the context of a transaction. These will not be acknowledged until the transaction is finished.

func (*TransactionDelete) CloneMessageVT 

func (m *TransactionDelete) CloneMessageVT() proto.Message

func (*TransactionDelete) CloneVT 

func (m *TransactionDelete) CloneVT() *TransactionDelete

func (*TransactionDelete) Descriptor deprecated 

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

Deprecated: Use TransactionDelete.ProtoReflect.Descriptor instead.

func (*TransactionDelete) EqualMessageVT 

func (this *TransactionDelete) EqualMessageVT(thatMsg proto.Message) bool

func (*TransactionDelete) EqualVT 

func (this *TransactionDelete) EqualVT(that *TransactionDelete) bool

func (*TransactionDelete) GetDeletes 

func (x *TransactionDelete) GetDeletes() []*DeleteItem

func (*TransactionDelete) MarshalToSizedBufferVT 

func (m *TransactionDelete) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionDelete) MarshalToVT 

func (m *TransactionDelete) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionDelete) MarshalVT 

func (m *TransactionDelete) MarshalVT() (dAtA []byte, err error)

func (*TransactionDelete) ProtoMessage 

func (*TransactionDelete) ProtoMessage()

func (*TransactionDelete) ProtoReflect 

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

func (*TransactionDelete) Reset 

func (x *TransactionDelete) Reset()

func (*TransactionDelete) SizeVT 

func (m *TransactionDelete) SizeVT() (n int)

func (*TransactionDelete) String 

func (x *TransactionDelete) String() string

func (*TransactionDelete) UnmarshalVT 

func (m *TransactionDelete) UnmarshalVT(dAtA []byte) error

type TransactionFinished 

type TransactionFinished struct {

	// Did the commit finish (the alternative is that it was aborted/rolled back)
	Committed bool `protobuf:"varint,1,opt,name=committed,proto3" json:"committed,omitempty"`
	// put_results contains the full result of each Put operation. This only comes
	// back with the TransactionFinished message because full metadata isn't
	// available until then.
	PutResults []*Item `protobuf:"bytes,2,rep,name=put_results,json=putResults,proto3" json:"put_results,omitempty"`
	// delete_results contains the full result of each Delete operation. This only
	// comes back with the TransactionFinished message because full metadata isn't
	// available until then.
	DeleteResults []*DeleteResult `protobuf:"bytes,3,rep,name=delete_results,json=deleteResults,proto3" json:"delete_results,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionFinished) CloneMessageVT 

func (m *TransactionFinished) CloneMessageVT() proto.Message

func (*TransactionFinished) CloneVT 

func (m *TransactionFinished) CloneVT() *TransactionFinished

func (*TransactionFinished) Descriptor deprecated 

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

Deprecated: Use TransactionFinished.ProtoReflect.Descriptor instead.

func (*TransactionFinished) EqualMessageVT 

func (this *TransactionFinished) EqualMessageVT(thatMsg proto.Message) bool

func (*TransactionFinished) EqualVT 

func (this *TransactionFinished) EqualVT(that *TransactionFinished) bool

func (*TransactionFinished) GetCommitted 

func (x *TransactionFinished) GetCommitted() bool

func (*TransactionFinished) GetDeleteResults 

func (x *TransactionFinished) GetDeleteResults() []*DeleteResult

func (*TransactionFinished) GetPutResults 

func (x *TransactionFinished) GetPutResults() []*Item

func (*TransactionFinished) MarshalToSizedBufferVT 

func (m *TransactionFinished) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionFinished) MarshalToVT 

func (m *TransactionFinished) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionFinished) MarshalVT 

func (m *TransactionFinished) MarshalVT() (dAtA []byte, err error)

func (*TransactionFinished) ProtoMessage 

func (*TransactionFinished) ProtoMessage()

func (*TransactionFinished) ProtoReflect 

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

func (*TransactionFinished) Reset 

func (x *TransactionFinished) Reset()

func (*TransactionFinished) SizeVT 

func (m *TransactionFinished) SizeVT() (n int)

func (*TransactionFinished) String 

func (x *TransactionFinished) String() string

func (*TransactionFinished) UnmarshalVT 

func (m *TransactionFinished) UnmarshalVT(dAtA []byte) error

type TransactionGet 

type TransactionGet struct {

	// gets is one or more requests to get an item its key path.
	Gets []*GetItem `protobuf:"bytes,1,rep,name=gets,proto3" json:"gets,omitempty"`
	// contains filtered or unexported fields
}

TransactionGet is a subset of the GetRequest message, for performing point gets within the context of a transaction.

func (*TransactionGet) CloneMessageVT 

func (m *TransactionGet) CloneMessageVT() proto.Message

func (*TransactionGet) CloneVT 

func (m *TransactionGet) CloneVT() *TransactionGet

func (*TransactionGet) Descriptor deprecated 

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

Deprecated: Use TransactionGet.ProtoReflect.Descriptor instead.

func (*TransactionGet) EqualMessageVT 

func (this *TransactionGet) EqualMessageVT(thatMsg proto.Message) bool

func (*TransactionGet) EqualVT 

func (this *TransactionGet) EqualVT(that *TransactionGet) bool

func (*TransactionGet) GetGets 

func (x *TransactionGet) GetGets() []*GetItem

func (*TransactionGet) MarshalToSizedBufferVT 

func (m *TransactionGet) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionGet) MarshalToVT 

func (m *TransactionGet) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionGet) MarshalVT 

func (m *TransactionGet) MarshalVT() (dAtA []byte, err error)

func (*TransactionGet) ProtoMessage 

func (*TransactionGet) ProtoMessage()

func (*TransactionGet) ProtoReflect 

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

func (*TransactionGet) Reset 

func (x *TransactionGet) Reset()

func (*TransactionGet) SizeVT 

func (m *TransactionGet) SizeVT() (n int)

func (*TransactionGet) String 

func (x *TransactionGet) String() string

func (*TransactionGet) UnmarshalVT 

func (m *TransactionGet) UnmarshalVT(dAtA []byte) error

type TransactionGetResponse 

type TransactionGetResponse struct {

	// items is a list that contains one entry for each Item that was found.
	Items []*Item `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

TransactionGetResponse is a subset of the GetResponse message, for returning results during the execution of a transaction.

func (*TransactionGetResponse) CloneMessageVT 

func (m *TransactionGetResponse) CloneMessageVT() proto.Message

func (*TransactionGetResponse) CloneVT 

func (m *TransactionGetResponse) CloneVT() *TransactionGetResponse

func (*TransactionGetResponse) Descriptor deprecated 

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

Deprecated: Use TransactionGetResponse.ProtoReflect.Descriptor instead.

func (*TransactionGetResponse) EqualMessageVT 

func (this *TransactionGetResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*TransactionGetResponse) EqualVT 

func (this *TransactionGetResponse) EqualVT(that *TransactionGetResponse) bool

func (*TransactionGetResponse) GetItems 

func (x *TransactionGetResponse) GetItems() []*Item

func (*TransactionGetResponse) MarshalToSizedBufferVT 

func (m *TransactionGetResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionGetResponse) MarshalToVT 

func (m *TransactionGetResponse) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionGetResponse) MarshalVT 

func (m *TransactionGetResponse) MarshalVT() (dAtA []byte, err error)

func (*TransactionGetResponse) ProtoMessage 

func (*TransactionGetResponse) ProtoMessage()

func (*TransactionGetResponse) ProtoReflect 

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

func (*TransactionGetResponse) Reset 

func (x *TransactionGetResponse) Reset()

func (*TransactionGetResponse) SizeVT 

func (m *TransactionGetResponse) SizeVT() (n int)

func (*TransactionGetResponse) String 

func (x *TransactionGetResponse) String() string

func (*TransactionGetResponse) UnmarshalVT 

func (m *TransactionGetResponse) UnmarshalVT(dAtA []byte) error

type TransactionListResponse 

type TransactionListResponse struct {

	// Types that are assignable to Response:
	//
	//	*TransactionListResponse_Result
	//	*TransactionListResponse_Finished
	Response isTransactionListResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

TransactionListResponse is a subset of the ListResponse message, for returning results during the execution of a transaction.

func (*TransactionListResponse) CloneMessageVT 

func (m *TransactionListResponse) CloneMessageVT() proto.Message

func (*TransactionListResponse) CloneVT 

func (m *TransactionListResponse) CloneVT() *TransactionListResponse

func (*TransactionListResponse) Descriptor deprecated 

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

Deprecated: Use TransactionListResponse.ProtoReflect.Descriptor instead.

func (*TransactionListResponse) EqualMessageVT 

func (this *TransactionListResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*TransactionListResponse) EqualVT 

func (this *TransactionListResponse) EqualVT(that *TransactionListResponse) bool

func (*TransactionListResponse) GetFinished 

func (x *TransactionListResponse) GetFinished() *ListFinished

func (*TransactionListResponse) GetResponse 

func (m *TransactionListResponse) GetResponse() isTransactionListResponse_Response

func (*TransactionListResponse) GetResult 

func (x *TransactionListResponse) GetResult() *ListPartialResult

func (*TransactionListResponse) MarshalToSizedBufferVT 

func (m *TransactionListResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionListResponse) MarshalToVT 

func (m *TransactionListResponse) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionListResponse) MarshalVT 

func (m *TransactionListResponse) MarshalVT() (dAtA []byte, err error)

func (*TransactionListResponse) ProtoMessage 

func (*TransactionListResponse) ProtoMessage()

func (*TransactionListResponse) ProtoReflect 

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

func (*TransactionListResponse) Reset 

func (x *TransactionListResponse) Reset()

func (*TransactionListResponse) SizeVT 

func (m *TransactionListResponse) SizeVT() (n int)

func (*TransactionListResponse) String 

func (x *TransactionListResponse) String() string

func (*TransactionListResponse) UnmarshalVT 

func (m *TransactionListResponse) UnmarshalVT(dAtA []byte) error

type TransactionListResponse_Finished 

type TransactionListResponse_Finished struct {
	// Finished is sent when there are no more results in this operation, and
	// there will only be one.
	Finished *ListFinished `protobuf:"bytes,2,opt,name=finished,proto3,oneof"`
}

func (*TransactionListResponse_Finished) CloneVT 

func (m *TransactionListResponse_Finished) CloneVT() isTransactionListResponse_Response

func (*TransactionListResponse_Finished) EqualVT 

func (this *TransactionListResponse_Finished) EqualVT(thatIface isTransactionListResponse_Response) bool

func (*TransactionListResponse_Finished) MarshalToSizedBufferVT 

func (m *TransactionListResponse_Finished) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionListResponse_Finished) MarshalToVT 

func (m *TransactionListResponse_Finished) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionListResponse_Finished) SizeVT 

func (m *TransactionListResponse_Finished) SizeVT() (n int)

type TransactionListResponse_Result 

type TransactionListResponse_Result struct {
	// Result is a segment of the result set - multiple of these may be returned
	// in a stream before the final "finished" message.
	Result *ListPartialResult `protobuf:"bytes,1,opt,name=result,proto3,oneof"`
}

func (*TransactionListResponse_Result) CloneVT 

func (m *TransactionListResponse_Result) CloneVT() isTransactionListResponse_Response

func (*TransactionListResponse_Result) EqualVT 

func (this *TransactionListResponse_Result) EqualVT(thatIface isTransactionListResponse_Response) bool

func (*TransactionListResponse_Result) MarshalToSizedBufferVT 

func (m *TransactionListResponse_Result) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionListResponse_Result) MarshalToVT 

func (m *TransactionListResponse_Result) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionListResponse_Result) SizeVT 

func (m *TransactionListResponse_Result) SizeVT() (n int)

type TransactionPut 

type TransactionPut struct {

	// puts is one or more items to be put into the Store.
	Puts []*PutItem `protobuf:"bytes,1,rep,name=puts,proto3" json:"puts,omitempty"`
	// contains filtered or unexported fields
}

TransactionPut is a subset of the PutRequest message, for performing puts within the context of a transaction. These will not be acknowledged until the transaction is finished.

func (*TransactionPut) CloneMessageVT 

func (m *TransactionPut) CloneMessageVT() proto.Message

func (*TransactionPut) CloneVT 

func (m *TransactionPut) CloneVT() *TransactionPut

func (*TransactionPut) Descriptor deprecated 

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

Deprecated: Use TransactionPut.ProtoReflect.Descriptor instead.

func (*TransactionPut) EqualMessageVT 

func (this *TransactionPut) EqualMessageVT(thatMsg proto.Message) bool

func (*TransactionPut) EqualVT 

func (this *TransactionPut) EqualVT(that *TransactionPut) bool

func (*TransactionPut) GetPuts 

func (x *TransactionPut) GetPuts() []*PutItem

func (*TransactionPut) MarshalToSizedBufferVT 

func (m *TransactionPut) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionPut) MarshalToVT 

func (m *TransactionPut) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionPut) MarshalVT 

func (m *TransactionPut) MarshalVT() (dAtA []byte, err error)

func (*TransactionPut) ProtoMessage 

func (*TransactionPut) ProtoMessage()

func (*TransactionPut) ProtoReflect 

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

func (*TransactionPut) Reset 

func (x *TransactionPut) Reset()

func (*TransactionPut) SizeVT 

func (m *TransactionPut) SizeVT() (n int)

func (*TransactionPut) String 

func (x *TransactionPut) String() string

func (*TransactionPut) UnmarshalVT 

func (m *TransactionPut) UnmarshalVT(dAtA []byte) error

type TransactionPutAck 

type TransactionPutAck struct {

	// generated_ids is a list of generated identifiers for the items in a
	// TransactionPut. IDs are returned in the same order of the PutItems provided
	// in TransactionPut#puts. For each item where an ID was chosen via its
	// "initialValue" property, the chosen value is represented in the returned
	// GeneratedID. There is only at most one generated ID per Put, because we
	// only allow a single ID property to be generated per item. If the Put didn't
	// need any generated IDs, the GeneratedID in its position will be empty.
	//
	// Clients can use these IDs in subsequent Put operations (e.g. to insert
	// child or related items). If the transaction is aborted, the item(s) will
	// not be added and other item(s) could be created with the same IDs.
	GeneratedIds []*GeneratedID `protobuf:"bytes,1,rep,name=generated_ids,json=generatedIds,proto3" json:"generated_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionPutAck) CloneMessageVT 

func (m *TransactionPutAck) CloneMessageVT() proto.Message

func (*TransactionPutAck) CloneVT 

func (m *TransactionPutAck) CloneVT() *TransactionPutAck

func (*TransactionPutAck) Descriptor deprecated 

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

Deprecated: Use TransactionPutAck.ProtoReflect.Descriptor instead.

func (*TransactionPutAck) EqualMessageVT 

func (this *TransactionPutAck) EqualMessageVT(thatMsg proto.Message) bool

func (*TransactionPutAck) EqualVT 

func (this *TransactionPutAck) EqualVT(that *TransactionPutAck) bool

func (*TransactionPutAck) GetGeneratedIds 

func (x *TransactionPutAck) GetGeneratedIds() []*GeneratedID

func (*TransactionPutAck) MarshalToSizedBufferVT 

func (m *TransactionPutAck) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionPutAck) MarshalToVT 

func (m *TransactionPutAck) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionPutAck) MarshalVT 

func (m *TransactionPutAck) MarshalVT() (dAtA []byte, err error)

func (*TransactionPutAck) ProtoMessage 

func (*TransactionPutAck) ProtoMessage()

func (*TransactionPutAck) ProtoReflect 

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

func (*TransactionPutAck) Reset 

func (x *TransactionPutAck) Reset()

func (*TransactionPutAck) SizeVT 

func (m *TransactionPutAck) SizeVT() (n int)

func (*TransactionPutAck) String 

func (x *TransactionPutAck) String() string

func (*TransactionPutAck) UnmarshalVT 

func (m *TransactionPutAck) UnmarshalVT(dAtA []byte) error

type TransactionRequest 

type TransactionRequest struct {

	// message_id should be set to a unique number per request in this
	// transaction. It will be returned with responses to make it easier to match
	// up specific responses with their requests.
	MessageId uint32 `protobuf:"varint,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// Types that are assignable to Command:
	//
	//	*TransactionRequest_Begin
	//	*TransactionRequest_GetItems
	//	*TransactionRequest_BeginList
	//	*TransactionRequest_ContinueList
	//	*TransactionRequest_PutItems
	//	*TransactionRequest_DeleteItems
	//	*TransactionRequest_Commit
	//	*TransactionRequest_Abort
	Command isTransactionRequest_Command `protobuf_oneof:"command"`
	// contains filtered or unexported fields
}

This is a streaming request, so the client may send several of them

func (*TransactionRequest) CloneMessageVT 

func (m *TransactionRequest) CloneMessageVT() proto.Message

func (*TransactionRequest) CloneVT 

func (m *TransactionRequest) CloneVT() *TransactionRequest

func (*TransactionRequest) Descriptor deprecated 

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

Deprecated: Use TransactionRequest.ProtoReflect.Descriptor instead.

func (*TransactionRequest) EqualMessageVT 

func (this *TransactionRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*TransactionRequest) EqualVT 

func (this *TransactionRequest) EqualVT(that *TransactionRequest) bool

func (*TransactionRequest) GetAbort 

func (x *TransactionRequest) GetAbort() *emptypb.Empty

func (*TransactionRequest) GetBegin 

func (x *TransactionRequest) GetBegin() *TransactionBegin

func (*TransactionRequest) GetBeginList 

func (x *TransactionRequest) GetBeginList() *TransactionBeginList

func (*TransactionRequest) GetCommand 

func (m *TransactionRequest) GetCommand() isTransactionRequest_Command

func (*TransactionRequest) GetCommit 

func (x *TransactionRequest) GetCommit() *emptypb.Empty

func (*TransactionRequest) GetContinueList 

func (x *TransactionRequest) GetContinueList() *TransactionContinueList

func (*TransactionRequest) GetDeleteItems 

func (x *TransactionRequest) GetDeleteItems() *TransactionDelete

func (*TransactionRequest) GetGetItems 

func (x *TransactionRequest) GetGetItems() *TransactionGet

func (*TransactionRequest) GetMessageId 

func (x *TransactionRequest) GetMessageId() uint32

func (*TransactionRequest) GetPutItems 

func (x *TransactionRequest) GetPutItems() *TransactionPut

func (*TransactionRequest) MarshalToSizedBufferVT 

func (m *TransactionRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionRequest) MarshalToVT 

func (m *TransactionRequest) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionRequest) MarshalVT 

func (m *TransactionRequest) MarshalVT() (dAtA []byte, err error)

func (*TransactionRequest) ProtoMessage 

func (*TransactionRequest) ProtoMessage()

func (*TransactionRequest) ProtoReflect 

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

func (*TransactionRequest) Reset 

func (x *TransactionRequest) Reset()

func (*TransactionRequest) SizeVT 

func (m *TransactionRequest) SizeVT() (n int)

func (*TransactionRequest) String 

func (x *TransactionRequest) String() string

func (*TransactionRequest) UnmarshalVT 

func (m *TransactionRequest) UnmarshalVT(dAtA []byte) error

type TransactionRequest_Abort 

type TransactionRequest_Abort struct {
	// The client is requesting to abort/rollback the transaction.
	Abort *emptypb.Empty `protobuf:"bytes,9,opt,name=abort,proto3,oneof"`
}

func (*TransactionRequest_Abort) CloneVT 

func (m *TransactionRequest_Abort) CloneVT() isTransactionRequest_Command

func (*TransactionRequest_Abort) EqualVT 

func (this *TransactionRequest_Abort) EqualVT(thatIface isTransactionRequest_Command) bool

func (*TransactionRequest_Abort) MarshalToSizedBufferVT 

func (m *TransactionRequest_Abort) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionRequest_Abort) MarshalToVT 

func (m *TransactionRequest_Abort) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionRequest_Abort) SizeVT 

func (m *TransactionRequest_Abort) SizeVT() (n int)

type TransactionRequest_Begin 

type TransactionRequest_Begin struct {
	// begin sets up options for the transaction, such as what store we're
	// operating on. It is not acknowledged unless there is an error, which
	// kills the whole transaction.
	Begin *TransactionBegin `protobuf:"bytes,2,opt,name=begin,proto3,oneof"`
}

func (*TransactionRequest_Begin) CloneVT 

func (m *TransactionRequest_Begin) CloneVT() isTransactionRequest_Command

func (*TransactionRequest_Begin) EqualVT 

func (this *TransactionRequest_Begin) EqualVT(thatIface isTransactionRequest_Command) bool

func (*TransactionRequest_Begin) MarshalToSizedBufferVT 

func (m *TransactionRequest_Begin) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionRequest_Begin) MarshalToVT 

func (m *TransactionRequest_Begin) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionRequest_Begin) SizeVT 

func (m *TransactionRequest_Begin) SizeVT() (n int)

type TransactionRequest_BeginList 

type TransactionRequest_BeginList struct {
	// The client is requesting a list of a path prefix. The results will be
	// returned in TransactionResponse#list.
	BeginList *TransactionBeginList `protobuf:"bytes,4,opt,name=begin_list,json=beginList,proto3,oneof"`
}

func (*TransactionRequest_BeginList) CloneVT 

func (m *TransactionRequest_BeginList) CloneVT() isTransactionRequest_Command

func (*TransactionRequest_BeginList) EqualVT 

func (this *TransactionRequest_BeginList) EqualVT(thatIface isTransactionRequest_Command) bool

func (*TransactionRequest_BeginList) MarshalToSizedBufferVT 

func (m *TransactionRequest_BeginList) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionRequest_BeginList) MarshalToVT 

func (m *TransactionRequest_BeginList) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionRequest_BeginList) SizeVT 

func (m *TransactionRequest_BeginList) SizeVT() (n int)

type TransactionRequest_Commit 

type TransactionRequest_Commit struct {
	// The client is requesting to commit the transaction. The final results of
	// the transaction will be returned in TransactionResponse#finished.
	Commit *emptypb.Empty `protobuf:"bytes,8,opt,name=commit,proto3,oneof"`
}

func (*TransactionRequest_Commit) CloneVT 

func (m *TransactionRequest_Commit) CloneVT() isTransactionRequest_Command

func (*TransactionRequest_Commit) EqualVT 

func (this *TransactionRequest_Commit) EqualVT(thatIface isTransactionRequest_Command) bool

func (*TransactionRequest_Commit) MarshalToSizedBufferVT 

func (m *TransactionRequest_Commit) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionRequest_Commit) MarshalToVT 

func (m *TransactionRequest_Commit) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionRequest_Commit) SizeVT 

func (m *TransactionRequest_Commit) SizeVT() (n int)

type TransactionRequest_ContinueList 

type TransactionRequest_ContinueList struct {
	// ContinueList takes the token from a BeginList call and returns the next
	// "page" of results based on the original query parameters and pagination
	// options. It has few options because it is a continuation of a previous
	// list operation. It will return a new  token which can be used for
	// another ContinueList call, and so on. Each time you call either
	// ContinueList, you should pass the latest version of the token, and then
	// use the new token from the result in subsequent calls. Calls to
	// ContinueList are tied to the authorization of the original BeginList
	// call, so if the original BeginList call was allowed, ContinueList with
	// its token should also be allowed.
	ContinueList *TransactionContinueList `protobuf:"bytes,5,opt,name=continue_list,json=continueList,proto3,oneof"`
}

func (*TransactionRequest_ContinueList) CloneVT 

func (m *TransactionRequest_ContinueList) CloneVT() isTransactionRequest_Command

func (*TransactionRequest_ContinueList) EqualVT 

func (this *TransactionRequest_ContinueList) EqualVT(thatIface isTransactionRequest_Command) bool

func (*TransactionRequest_ContinueList) MarshalToSizedBufferVT 

func (m *TransactionRequest_ContinueList) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionRequest_ContinueList) MarshalToVT 

func (m *TransactionRequest_ContinueList) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionRequest_ContinueList) SizeVT 

func (m *TransactionRequest_ContinueList) SizeVT() (n int)

type TransactionRequest_DeleteItems 

type TransactionRequest_DeleteItems struct {
	// The client is requesting to delete items. It is not acknowledged unless
	// there is an error, which kills the whole transaction. The final result of
	// all deletes will be returned in TransactionFinished#delete_results.
	DeleteItems *TransactionDelete `protobuf:"bytes,7,opt,name=delete_items,json=deleteItems,proto3,oneof"`
}

func (*TransactionRequest_DeleteItems) CloneVT 

func (m *TransactionRequest_DeleteItems) CloneVT() isTransactionRequest_Command

func (*TransactionRequest_DeleteItems) EqualVT 

func (this *TransactionRequest_DeleteItems) EqualVT(thatIface isTransactionRequest_Command) bool

func (*TransactionRequest_DeleteItems) MarshalToSizedBufferVT 

func (m *TransactionRequest_DeleteItems) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionRequest_DeleteItems) MarshalToVT 

func (m *TransactionRequest_DeleteItems) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionRequest_DeleteItems) SizeVT 

func (m *TransactionRequest_DeleteItems) SizeVT() (n int)

type TransactionRequest_GetItems 

type TransactionRequest_GetItems struct {
	// The client is requesting to get one or more items. The results will be
	// returned in TransactionResponse#get_results.
	GetItems *TransactionGet `protobuf:"bytes,3,opt,name=get_items,json=getItems,proto3,oneof"`
}

func (*TransactionRequest_GetItems) CloneVT 

func (m *TransactionRequest_GetItems) CloneVT() isTransactionRequest_Command

func (*TransactionRequest_GetItems) EqualVT 

func (this *TransactionRequest_GetItems) EqualVT(thatIface isTransactionRequest_Command) bool

func (*TransactionRequest_GetItems) MarshalToSizedBufferVT 

func (m *TransactionRequest_GetItems) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionRequest_GetItems) MarshalToVT 

func (m *TransactionRequest_GetItems) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionRequest_GetItems) SizeVT 

func (m *TransactionRequest_GetItems) SizeVT() (n int)

type TransactionRequest_PutItems 

type TransactionRequest_PutItems struct {
	// The client is requesting to create new items. This is acknowledged in
	// TransactionResponse#put_ack which contains the item's tentative full path
	// (pending the transaction's commit). The final result of all puts will be
	// returned in TransactionFinished#put_results.
	PutItems *TransactionPut `protobuf:"bytes,6,opt,name=put_items,json=putItems,proto3,oneof"`
}

func (*TransactionRequest_PutItems) CloneVT 

func (m *TransactionRequest_PutItems) CloneVT() isTransactionRequest_Command

func (*TransactionRequest_PutItems) EqualVT 

func (this *TransactionRequest_PutItems) EqualVT(thatIface isTransactionRequest_Command) bool

func (*TransactionRequest_PutItems) MarshalToSizedBufferVT 

func (m *TransactionRequest_PutItems) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionRequest_PutItems) MarshalToVT 

func (m *TransactionRequest_PutItems) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionRequest_PutItems) SizeVT 

func (m *TransactionRequest_PutItems) SizeVT() (n int)

type TransactionResponse 

type TransactionResponse struct {

	// message_id is the same as the message_id of the request that triggered this
	// response. This makes it easier to distinguish between multiple responses to
	// different requests..
	MessageId uint32 `protobuf:"varint,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// Types that are assignable to Result:
	//
	//	*TransactionResponse_GetResults
	//	*TransactionResponse_PutAck
	//	*TransactionResponse_ListResults
	//	*TransactionResponse_Finished
	Result isTransactionResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

This is a streaming response, so the server may send several of them

func (*TransactionResponse) CloneMessageVT 

func (m *TransactionResponse) CloneMessageVT() proto.Message

func (*TransactionResponse) CloneVT 

func (m *TransactionResponse) CloneVT() *TransactionResponse

func (*TransactionResponse) Descriptor deprecated 

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

Deprecated: Use TransactionResponse.ProtoReflect.Descriptor instead.

func (*TransactionResponse) EqualMessageVT 

func (this *TransactionResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*TransactionResponse) EqualVT 

func (this *TransactionResponse) EqualVT(that *TransactionResponse) bool

func (*TransactionResponse) GetFinished 

func (x *TransactionResponse) GetFinished() *TransactionFinished

func (*TransactionResponse) GetGetResults 

func (x *TransactionResponse) GetGetResults() *TransactionGetResponse

func (*TransactionResponse) GetListResults 

func (x *TransactionResponse) GetListResults() *TransactionListResponse

func (*TransactionResponse) GetMessageId 

func (x *TransactionResponse) GetMessageId() uint32

func (*TransactionResponse) GetPutAck 

func (x *TransactionResponse) GetPutAck() *TransactionPutAck

func (*TransactionResponse) GetResult 

func (m *TransactionResponse) GetResult() isTransactionResponse_Result

func (*TransactionResponse) MarshalToSizedBufferVT 

func (m *TransactionResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionResponse) MarshalToVT 

func (m *TransactionResponse) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionResponse) MarshalVT 

func (m *TransactionResponse) MarshalVT() (dAtA []byte, err error)

func (*TransactionResponse) ProtoMessage 

func (*TransactionResponse) ProtoMessage()

func (*TransactionResponse) ProtoReflect 

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

func (*TransactionResponse) Reset 

func (x *TransactionResponse) Reset()

func (*TransactionResponse) SizeVT 

func (m *TransactionResponse) SizeVT() (n int)

func (*TransactionResponse) String 

func (x *TransactionResponse) String() string

func (*TransactionResponse) UnmarshalVT 

func (m *TransactionResponse) UnmarshalVT(dAtA []byte) error

type TransactionResponse_Finished 

type TransactionResponse_Finished struct {
	// Final information about the transaction, regardless of whether it was committed or aborted.
	Finished *TransactionFinished `protobuf:"bytes,5,opt,name=finished,proto3,oneof"`
}

func (*TransactionResponse_Finished) CloneVT 

func (m *TransactionResponse_Finished) CloneVT() isTransactionResponse_Result

func (*TransactionResponse_Finished) EqualVT 

func (this *TransactionResponse_Finished) EqualVT(thatIface isTransactionResponse_Result) bool

func (*TransactionResponse_Finished) MarshalToSizedBufferVT 

func (m *TransactionResponse_Finished) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionResponse_Finished) MarshalToVT 

func (m *TransactionResponse_Finished) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionResponse_Finished) SizeVT 

func (m *TransactionResponse_Finished) SizeVT() (n int)

type TransactionResponse_GetResults 

type TransactionResponse_GetResults struct {
	// The server is responding to a GetItem request
	GetResults *TransactionGetResponse `protobuf:"bytes,2,opt,name=get_results,json=getResults,proto3,oneof"`
}

func (*TransactionResponse_GetResults) CloneVT 

func (m *TransactionResponse_GetResults) CloneVT() isTransactionResponse_Result

func (*TransactionResponse_GetResults) EqualVT 

func (this *TransactionResponse_GetResults) EqualVT(thatIface isTransactionResponse_Result) bool

func (*TransactionResponse_GetResults) MarshalToSizedBufferVT 

func (m *TransactionResponse_GetResults) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionResponse_GetResults) MarshalToVT 

func (m *TransactionResponse_GetResults) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionResponse_GetResults) SizeVT 

func (m *TransactionResponse_GetResults) SizeVT() (n int)

type TransactionResponse_ListResults 

type TransactionResponse_ListResults struct {
	// list_results is the result of a list request.
	ListResults *TransactionListResponse `protobuf:"bytes,4,opt,name=list_results,json=listResults,proto3,oneof"`
}

func (*TransactionResponse_ListResults) CloneVT 

func (m *TransactionResponse_ListResults) CloneVT() isTransactionResponse_Result

func (*TransactionResponse_ListResults) EqualVT 

func (this *TransactionResponse_ListResults) EqualVT(thatIface isTransactionResponse_Result) bool

func (*TransactionResponse_ListResults) MarshalToSizedBufferVT 

func (m *TransactionResponse_ListResults) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionResponse_ListResults) MarshalToVT 

func (m *TransactionResponse_ListResults) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionResponse_ListResults) SizeVT 

func (m *TransactionResponse_ListResults) SizeVT() (n int)

type TransactionResponse_PutAck 

type TransactionResponse_PutAck struct {
	// put_ack contains provisionally updated items from a put, including
	// tentative IDs (pending transaction commit).
	PutAck *TransactionPutAck `protobuf:"bytes,3,opt,name=put_ack,json=putAck,proto3,oneof"`
}

func (*TransactionResponse_PutAck) CloneVT 

func (m *TransactionResponse_PutAck) CloneVT() isTransactionResponse_Result

func (*TransactionResponse_PutAck) EqualVT 

func (this *TransactionResponse_PutAck) EqualVT(thatIface isTransactionResponse_Result) bool

func (*TransactionResponse_PutAck) MarshalToSizedBufferVT 

func (m *TransactionResponse_PutAck) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TransactionResponse_PutAck) MarshalToVT 

func (m *TransactionResponse_PutAck) MarshalToVT(dAtA []byte) (int, error)

func (*TransactionResponse_PutAck) SizeVT 

func (m *TransactionResponse_PutAck) SizeVT() (n int)

Source Files

View all Source files

Directories

Path Synopsis

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.