data

package
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: Apr 11, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	AppendItem_IDAssignment_name = map[int32]string{
		0: "ID_ASSIGNMENT_UNSPECIFIED",
		1: "SEQUENCE",
		2: "UUID",
		3: "RAND53",
	}
	AppendItem_IDAssignment_value = map[string]int32{
		"ID_ASSIGNMENT_UNSPECIFIED": 0,
		"SEQUENCE":                  1,
		"UUID":                      2,
		"RAND53":                    3,
	}
)

Enum value maps for AppendItem_IDAssignment.

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_CUSTOM_1",
		9:  "SORTABLE_PROPERTY_CUSTOM_2",
		10: "SORTABLE_PROPERTY_CUSTOM_3",
		11: "SORTABLE_PROPERTY_CUSTOM_4",
	}
	SortableProperty_value = map[string]int32{
		"SORTABLE_PROPERTY_KEY_PATH":              0,
		"SORTABLE_PROPERTY_LAST_MODIFIED_VERSION": 1,
		"SORTABLE_PROPERTY_CUSTOM_1":              8,
		"SORTABLE_PROPERTY_CUSTOM_2":              9,
		"SORTABLE_PROPERTY_CUSTOM_3":              10,
		"SORTABLE_PROPERTY_CUSTOM_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_data_append_proto protoreflect.FileDescriptor
View Source
var File_data_continue_list_proto protoreflect.FileDescriptor
View Source
var File_data_delete_proto protoreflect.FileDescriptor
View Source
var File_data_get_proto protoreflect.FileDescriptor
View Source
var File_data_item_property_proto protoreflect.FileDescriptor
View Source
var File_data_item_proto protoreflect.FileDescriptor
View Source
var File_data_list_proto protoreflect.FileDescriptor
View Source
var File_data_list_token_proto protoreflect.FileDescriptor
View Source
var File_data_put_proto protoreflect.FileDescriptor
View Source
var File_data_scan_root_paths_proto protoreflect.FileDescriptor
View Source
var File_data_service_proto protoreflect.FileDescriptor
View Source
var File_data_sync_list_proto protoreflect.FileDescriptor
View Source
var File_data_transaction_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AppendItem

type AppendItem struct {

	// item_type is the type of item to be appended. All items must have a type.
	ItemType string `protobuf:"bytes,1,opt,name=item_type,json=itemType,proto3" json:"item_type,omitempty"`
	// id_assignment chooses how the item's ID will be assigned. Not all options
	// are applicable for all types of items or store configurations.
	IdAssignment AppendItem_IDAssignment `` /* 135-byte string literal not displayed */
	// json is a proto-encoded JSON object, to support storing JSON documents, or
	// to support storing the remainder of data that cannot be represented as
	// proto.
	// TODO: We may want to replace this with something a bit more powerful such
	// as BSON - still a map of string key to value, but with a larger vocabulary
	// of value types.
	Json *structpb.Struct `protobuf:"bytes,3,opt,name=json,proto3" json:"json,omitempty"`
	// proto is an arbitrary binary proto message, following the schema for this
	// item type (TBD). It is entirely possible for an item to store both proto
	// data AND json data - for example, if only a subset of its data has a
	// defined proto schema that informs its representation. We don't use the Any
	// type here because it is both inefficient (it encodes the entire type name
	// as a string), but also we should know via external schema what type of
	// proto this is.
	Proto []byte `protobuf:"bytes,4,opt,name=proto,proto3" json:"proto,omitempty"`
	// contains filtered or unexported fields
}

AppendItem is the payload to be appended. This is mostly a copy of Item except we have a parent_key_path and item_type, but no item ID, since the resulting full key_path is determined by the parent_key_path plus an auto-assigned ID.

func (*AppendItem) CloneMessageVT

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

func (*AppendItem) CloneVT

func (m *AppendItem) CloneVT() *AppendItem

func (*AppendItem) Descriptor deprecated

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

Deprecated: Use AppendItem.ProtoReflect.Descriptor instead.

func (*AppendItem) EqualMessageVT

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

func (*AppendItem) EqualVT

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

func (*AppendItem) GetIdAssignment

func (x *AppendItem) GetIdAssignment() AppendItem_IDAssignment

func (*AppendItem) GetItemType

func (x *AppendItem) GetItemType() string

func (*AppendItem) GetJson

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

func (*AppendItem) GetProto

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

func (*AppendItem) MarshalToSizedBufferVT

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

func (*AppendItem) MarshalToVT

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

func (*AppendItem) MarshalVT

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

func (*AppendItem) ProtoMessage

func (*AppendItem) ProtoMessage()

func (*AppendItem) ProtoReflect

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

func (*AppendItem) Reset

func (x *AppendItem) Reset()

func (*AppendItem) SizeVT

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

func (*AppendItem) String

func (x *AppendItem) String() string

func (*AppendItem) UnmarshalVT

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

type AppendItemResult

type AppendItemResult struct {

	// key_path is the full path to the newly appended item, if it was able to be
	// saved. See Item#key_path for more details.
	KeyPath string `protobuf:"bytes,1,opt,name=key_path,json=keyPath,proto3" json:"key_path,omitempty"`
	// error is the error that occurred while appending this item, if any.
	// error is not set if the item was successfully saved.
	Error *common.OperationError `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// metadata is the version and timestamp metadata for the item that was appended.
	Metadata *ItemMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendItemResult) CloneMessageVT

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

func (*AppendItemResult) CloneVT

func (m *AppendItemResult) CloneVT() *AppendItemResult

func (*AppendItemResult) Descriptor deprecated

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

Deprecated: Use AppendItemResult.ProtoReflect.Descriptor instead.

func (*AppendItemResult) EqualMessageVT

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

func (*AppendItemResult) EqualVT

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

func (*AppendItemResult) GetError

func (x *AppendItemResult) GetError() *common.OperationError

func (*AppendItemResult) GetKeyPath

func (x *AppendItemResult) GetKeyPath() string

func (*AppendItemResult) GetMetadata

func (x *AppendItemResult) GetMetadata() *ItemMetadata

func (*AppendItemResult) MarshalToSizedBufferVT

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

func (*AppendItemResult) MarshalToVT

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

func (*AppendItemResult) MarshalVT

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

func (*AppendItemResult) ProtoMessage

func (*AppendItemResult) ProtoMessage()

func (*AppendItemResult) ProtoReflect

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

func (*AppendItemResult) Reset

func (x *AppendItemResult) Reset()

func (*AppendItemResult) SizeVT

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

func (*AppendItemResult) String

func (x *AppendItemResult) String() string

func (*AppendItemResult) UnmarshalVT

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

type AppendItem_IDAssignment

type AppendItem_IDAssignment int32
const (
	AppendItem_ID_ASSIGNMENT_UNSPECIFIED AppendItem_IDAssignment = 0
	// SEQUENCE will assign the item a monotonically increasing, contiguous ID
	// that is unique *within the parent path and item type*. This is only valid
	// for non-root items and when atomic = true (or within a transaction).
	AppendItem_SEQUENCE AppendItem_IDAssignment = 1
	// UUID will assign the item a globally unique 128-bit UUID. This will be
	// encoded in the item key path as a binary ID. This is usable anywhere, in
	// any store config.
	AppendItem_UUID AppendItem_IDAssignment = 2
	// RAND53 will assign the item a random 53-bit numeric ID that
	// is unique *within the parent path and item type*, but is not globally
	// unique. This is usable anywhere, in any store config. We use 53 bits
	// instead of 64 because 53 bits is still a lot of bits, and it's the largest
	// integer that can be represented exactly in JavaScript.
	AppendItem_RAND53 AppendItem_IDAssignment = 3
)

func (AppendItem_IDAssignment) Descriptor

func (AppendItem_IDAssignment) Enum

func (AppendItem_IDAssignment) EnumDescriptor deprecated

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

Deprecated: Use AppendItem_IDAssignment.Descriptor instead.

func (AppendItem_IDAssignment) Number

func (AppendItem_IDAssignment) String

func (x AppendItem_IDAssignment) String() string

func (AppendItem_IDAssignment) Type

type AppendRequest

type AppendRequest 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"`
	// parent_path is the full path, in the form
	// /item_type-item_id/[{sub_item_type}-{sub_item_id}...}], under which each
	// item will be appended. The item will be appended as a direct child of this
	// path. Note that the path *may* be "/" to create root-level items, though
	// some ID assignment options may not be available in that case.
	ParentPath string `protobuf:"bytes,2,opt,name=parent_path,json=parentPath,proto3" json:"parent_path,omitempty"`
	// appends is one or more items to be appended under the parent path.
	Appends []*AppendItem `protobuf:"bytes,3,rep,name=appends,proto3" json:"appends,omitempty"`
	// atomic indicates that all appends must succeed or none will (i.e. that they
	// are applied in a transaction), and that other operations will be serialized
	// ahead or behind this operation. Some store configurations may ignore this
	// option and will always apply the whole batch in a transaction (such as in
	// version-tracking stores). Note that this has no effect if there is only one
	// append. Enabling this option increases cost and latency, and may result in
	// the operation failing if it conflicts with another atomic operation. Also,
	// some ID assignment options may not be available depending on this option -
	// e.g. you cannot do SEQUENTIAL appends with atomic = false.
	Atomic bool `protobuf:"varint,4,opt,name=atomic,proto3" json:"atomic,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendRequest) CloneMessageVT

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

func (*AppendRequest) CloneVT

func (m *AppendRequest) CloneVT() *AppendRequest

func (*AppendRequest) Descriptor deprecated

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

Deprecated: Use AppendRequest.ProtoReflect.Descriptor instead.

func (*AppendRequest) EqualMessageVT

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

func (*AppendRequest) EqualVT

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

func (*AppendRequest) GetAppends

func (x *AppendRequest) GetAppends() []*AppendItem

func (*AppendRequest) GetAtomic

func (x *AppendRequest) GetAtomic() bool

func (*AppendRequest) GetParentPath

func (x *AppendRequest) GetParentPath() string

func (*AppendRequest) GetStoreId

func (x *AppendRequest) GetStoreId() uint64

func (*AppendRequest) MarshalToSizedBufferVT

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

func (*AppendRequest) MarshalToVT

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

func (*AppendRequest) MarshalVT

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

func (*AppendRequest) ProtoMessage

func (*AppendRequest) ProtoMessage()

func (*AppendRequest) ProtoReflect

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

func (*AppendRequest) Reset

func (x *AppendRequest) Reset()

func (*AppendRequest) SizeVT

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

func (*AppendRequest) String

func (x *AppendRequest) String() string

func (*AppendRequest) UnmarshalVT

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

type AppendResponse

type AppendResponse struct {

	// results are in the same order as the appends in the request, one per append.
	Results []*AppendItemResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendResponse) CloneMessageVT

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

func (*AppendResponse) CloneVT

func (m *AppendResponse) CloneVT() *AppendResponse

func (*AppendResponse) Descriptor deprecated

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

Deprecated: Use AppendResponse.ProtoReflect.Descriptor instead.

func (*AppendResponse) EqualMessageVT

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

func (*AppendResponse) EqualVT

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

func (*AppendResponse) GetResults

func (x *AppendResponse) GetResults() []*AppendItemResult

func (*AppendResponse) MarshalToSizedBufferVT

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

func (*AppendResponse) MarshalToVT

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

func (*AppendResponse) MarshalVT

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

func (*AppendResponse) ProtoMessage

func (*AppendResponse) ProtoMessage()

func (*AppendResponse) ProtoReflect

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

func (*AppendResponse) Reset

func (x *AppendResponse) Reset()

func (*AppendResponse) SizeVT

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

func (*AppendResponse) String

func (x *AppendResponse) String() string

func (*AppendResponse) UnmarshalVT

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

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 `` /* 128-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 `` /* 128-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) Enum

func (ContinueListDirection) EnumDescriptor deprecated

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

Deprecated: Use ContinueListDirection.Descriptor instead.

func (ContinueListDirection) Number

func (ContinueListDirection) String

func (x ContinueListDirection) String() string

func (ContinueListDirection) Type

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.ContinueListDirection" json:"direction,omitempty"`
	// contains filtered or unexported fields
}

func (*ContinueListRequest) CloneMessageVT

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

func (*ContinueListRequest) CloneVT

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"`
	// atomic indicates that all deletes must succeed or none will (i.e. that they
	// are applied in a transaction), and that other operations will be serialized
	// ahead or behind this operation. Some store configurations may ignore this
	// option and will always apply the whole batch in a transaction (such as in
	// version-tracking stores). Note that this has no effect if there is only one
	// delete. Enabling this option increases cost and latency, and may result in
	// the operation failing if it conflicts with another atomic operation.
	Atomic bool `protobuf:"varint,4,opt,name=atomic,proto3" json:"atomic,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) GetAtomic

func (x *DeleteRequest) GetAtomic() 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"`
	// error is the error that occurred while deleting this item, if any. error is
	// not set if the item was successfully deleted (or didn't exist in the first
	// place).
	Error *common.OperationError `protobuf:"bytes,2,opt,name=error,proto3" json:"error,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) GetError

func (x *DeleteResult) GetError() *common.OperationError

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 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"`
	// Atomic indicates that all gets in this request should be executed
	// atomically relative to other requests - that is, it will retrieve the items
	// as they were at the same point in time. If this is false (the default),
	// then each get will be executed independently, meaning each get may be
	// interleaved with modifications by other requests. See
	// https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/transaction-apis.html#transaction-isolation
	// for an example of why you'd want to use this. Note that this has no effect
	// if there is only one get. Also, allow_stale may not be true if atomic is
	// true. Enabling this option increases cost and latency, and may result in
	// the operation failing if it conflicts with another atomic operation.
	Atomic bool `protobuf:"varint,4,opt,name=atomic,proto3" json:"atomic,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) GetAtomic

func (x *GetRequest) GetAtomic() 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 IsTransactionCommand

type IsTransactionCommand = isTransactionRequest_Command

IsTransactionCommand is a type that exports a private type that proto people refuse to export. Exporting this makes life significantly easier. https://github.com/golang/protobuf/pull/588 https://github.com/golang/protobuf/issues/261#issuecomment-430496210

type IsTransactionResponseResult

type IsTransactionResponseResult = isTransactionResponse_Result

IsTransactionResponseResult is a type that exports a private type that proto people refuse to export. Exporting this makes life significantly easier.

type Item

type Item struct {

	// key_path is the full path to this item, in the form
	// /item_type-item_id/[{sub_item_type}-{sub_item_id}...}]. It must contain at
	// least one segment with item type and ID, as the first segment identifies a
	// "root path" that forms the partition key for data.
	//
	// For example, to store information about Jedi, you might have /jedi-luke, or
	// to have a sub-item of that item, you could use the path
	// /jedi-luke/equipment-lightsaber. The "type" of this item is the last item
	// type in the path, and the last ID is optional if this is a singleton item.
	KeyPath string `protobuf:"bytes,1,opt,name=key_path,json=keyPath,proto3" json:"key_path,omitempty"`
	// json is a proto-encoded JSON object, to support storing JSON documents, or
	// to support storing the remainder of data that cannot be represented as
	// proto.
	// TODO: We may want to replace this with something a bit more powerful such
	// as BSON - still a map of string key to value, but with a larger vocabulary
	// of value types.
	Json *structpb.Struct `protobuf:"bytes,2,opt,name=json,proto3" json:"json,omitempty"`
	// proto is an arbitrary binary proto message, following the schema for this
	// item type (TBD). It is entirely possible for an item to store both proto
	// data AND json data - for example, if only a subset of its data has a
	// defined proto schema that informs its representation. We don't use the Any
	// type here because it is both inefficient (it encodes the entire type name
	// as a string), but also we should know via external schema what type of
	// proto this is.
	Proto []byte `protobuf:"bytes,3,opt,name=proto,proto3" json:"proto,omitempty"`
	// metadata is extra metadata about this item, such as its version numbers and
	// timestamps. This must not be present when the item is being used in
	// PutItem, but will be populated when items are returned from the service.
	Metadata *ItemMetadata `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Item represents an entire Item - all of its fields and values, its key path, and extra metadata (when this is an Item appearing in an operation's response).

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) GetJson

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

func (*Item) GetKeyPath

func (x *Item) GetKeyPath() string

func (*Item) GetMetadata

func (x *Item) GetMetadata() *ItemMetadata

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 ItemMetadata

type ItemMetadata struct {

	// created_at_micros is the time at which this item was created, as a Unix
	// microsecond timestamp.
	CreatedAtMicros uint64 `protobuf:"varint,1,opt,name=created_at_micros,json=createdAtMicros,proto3" json:"created_at_micros,omitempty"`
	// last_modified_at_micros is the time at which this item was last modified,
	// as a Unix microsecond timestamp.
	LastModifiedAtMicros uint64 `` /* 126-byte string literal not displayed */
	// created_at_version is the group version of the item at the time it was
	// created. This is only populated in stores that are configured to track
	// versions.
	CreatedAtVersion uint64 `protobuf:"varint,3,opt,name=created_at_version,json=createdAtVersion,proto3" json:"created_at_version,omitempty"`
	// last_modified_at_version is the group version of the item when it was last
	// modified. This is only populated in stores that are configured to track
	// versions.
	LastModifiedAtVersion uint64 `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

ItemMetadata contains server-maintained metadata about the item and its lifecycle, such as timestamps and version numbers.

func (*ItemMetadata) CloneMessageVT

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

func (*ItemMetadata) CloneVT

func (m *ItemMetadata) CloneVT() *ItemMetadata

func (*ItemMetadata) Descriptor deprecated

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

Deprecated: Use ItemMetadata.ProtoReflect.Descriptor instead.

func (*ItemMetadata) EqualMessageVT

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

func (*ItemMetadata) EqualVT

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

func (*ItemMetadata) GetCreatedAtMicros

func (x *ItemMetadata) GetCreatedAtMicros() uint64

func (*ItemMetadata) GetCreatedAtVersion

func (x *ItemMetadata) GetCreatedAtVersion() uint64

func (*ItemMetadata) GetLastModifiedAtMicros

func (x *ItemMetadata) GetLastModifiedAtMicros() uint64

func (*ItemMetadata) GetLastModifiedAtVersion

func (x *ItemMetadata) GetLastModifiedAtVersion() uint64

func (*ItemMetadata) MarshalToSizedBufferVT

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

func (*ItemMetadata) MarshalToVT

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

func (*ItemMetadata) MarshalVT

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

func (*ItemMetadata) ProtoMessage

func (*ItemMetadata) ProtoMessage()

func (*ItemMetadata) ProtoReflect

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

func (*ItemMetadata) Reset

func (x *ItemMetadata) Reset()

func (*ItemMetadata) SizeVT

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

func (*ItemMetadata) String

func (x *ItemMetadata) String() string

func (*ItemMetadata) UnmarshalVT

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

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) IsListResponder

func (*ListFinished) IsListResponder()

IsListResponder is a type that binds ListFinished to the ListResponder interface.

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) IsListResponder

func (*ListPartialResult) IsListResponder()

IsListResponder is a type that binds ListPartialResult to the ListResponder interface.

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 ListResponder

type ListResponder interface {
	IsListResponder()
}

ListResponder allows us to conform both txn and non-txn list apis to a common interface which makes the SDK simpler.

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) GetListResponse

func (t *ListResponse) GetListResponse() ListResponder

GetListResponse returns the ListResponder from the ListResponse.

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 full item to be put, including its key_path.
	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"`
	// atomic indicates that all puts must succeed or none will (i.e. that they
	// are applied in a transaction), and that other operations will be serialized
	// ahead or behind this operation. Some store configurations may ignore this
	// option and will always apply the whole batch in a transaction (such as in
	// version-tracking stores). Note that this has no effect if there is only one
	// put. Enabling this option increases cost and latency, and may result in the
	// operation failing if it conflicts with another atomic operation.
	Atomic bool `protobuf:"varint,3,opt,name=atomic,proto3" json:"atomic,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) GetAtomic

func (x *PutRequest) GetAtomic() 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 {

	// results is the result of each put operation (whether it succeeded or failed).
	Results []*PutResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,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) GetResults

func (x *PutResponse) GetResults() []*PutResult

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 PutResult

type PutResult struct {

	// The key_path of the item that was put.
	KeyPath string `protobuf:"bytes,1,opt,name=key_path,json=keyPath,proto3" json:"key_path,omitempty"`
	// error is the error that occurred while putting this item, if any.
	// error is not set if the item was successfully put.
	Error *common.OperationError `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// metadata is the version and timestamp metadata for the item that was put.
	Metadata *ItemMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*PutResult) CloneMessageVT

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

func (*PutResult) CloneVT

func (m *PutResult) CloneVT() *PutResult

func (*PutResult) Descriptor deprecated

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

Deprecated: Use PutResult.ProtoReflect.Descriptor instead.

func (*PutResult) EqualMessageVT

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

func (*PutResult) EqualVT

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

func (*PutResult) GetError

func (x *PutResult) GetError() *common.OperationError

func (*PutResult) GetKeyPath

func (x *PutResult) GetKeyPath() string

func (*PutResult) GetMetadata

func (x *PutResult) GetMetadata() *ItemMetadata

func (*PutResult) MarshalToSizedBufferVT

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

func (*PutResult) MarshalToVT

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

func (*PutResult) MarshalVT

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

func (*PutResult) ProtoMessage

func (*PutResult) ProtoMessage()

func (*PutResult) ProtoReflect

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

func (*PutResult) Reset

func (x *PutResult) Reset()

func (*PutResult) SizeVT

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

func (*PutResult) String

func (x *PutResult) String() string

func (*PutResult) UnmarshalVT

func (m *PutResult) 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 (*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 (*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) Enum

func (x SortDirection) Enum() *SortDirection

func (SortDirection) EnumDescriptor deprecated

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

Deprecated: Use SortDirection.Descriptor instead.

func (SortDirection) Number

func (SortDirection) String

func (x SortDirection) String() string

func (SortDirection) Type

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_CUSTOM_1 through SORTABLE_PROPERTY_CUSTOM_4 are user-specified sortable
	// properties which may be defined in the schema. The maximum supported number
	// of custom properties currently depends on the store configuration and the
	// underlying database platform.
	SortableProperty_SORTABLE_PROPERTY_CUSTOM_1 SortableProperty = 8
	SortableProperty_SORTABLE_PROPERTY_CUSTOM_2 SortableProperty = 9
	SortableProperty_SORTABLE_PROPERTY_CUSTOM_3 SortableProperty = 10
	SortableProperty_SORTABLE_PROPERTY_CUSTOM_4 SortableProperty = 11
)

func (SortableProperty) Descriptor

func (SortableProperty) Enum

func (SortableProperty) EnumDescriptor deprecated

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

Deprecated: Use SortableProperty.Descriptor instead.

func (SortableProperty) Number

func (SortableProperty) String

func (x SortableProperty) String() string

func (SortableProperty) Type

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 (*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 (*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 TransactionAppend

type TransactionAppend struct {

	// parent_path is the full path, in the form
	// /item_type-item_id/[{sub_item_type}-{sub_item_id}...}], under which each
	// item will be appended. The item will be appended as a direct child of this
	// path. Note that the path *may* be "/" to create root-level items, though
	// some ID assignment options may not be available in that case.
	ParentPath string `protobuf:"bytes,1,opt,name=parent_path,json=parentPath,proto3" json:"parent_path,omitempty"`
	// appends is one or more items to be appended under the parent path.
	Appends []*AppendItem `protobuf:"bytes,2,rep,name=appends,proto3" json:"appends,omitempty"`
	// contains filtered or unexported fields
}

TransactionAppend is a subset of the AppendRequest message, for performing appends within the context of a transaction. These will be acknowledged with TransactionAppendAck messages that contain the item's new ID.

func (*TransactionAppend) CloneMessageVT

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

func (*TransactionAppend) CloneVT

func (m *TransactionAppend) CloneVT() *TransactionAppend

func (*TransactionAppend) Descriptor deprecated

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

Deprecated: Use TransactionAppend.ProtoReflect.Descriptor instead.

func (*TransactionAppend) EqualMessageVT

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

func (*TransactionAppend) EqualVT

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

func (*TransactionAppend) GetAppends

func (x *TransactionAppend) GetAppends() []*AppendItem

func (*TransactionAppend) GetParentPath

func (x *TransactionAppend) GetParentPath() string

func (*TransactionAppend) MarshalToSizedBufferVT

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

func (*TransactionAppend) MarshalToVT

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

func (*TransactionAppend) MarshalVT

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

func (*TransactionAppend) ProtoMessage

func (*TransactionAppend) ProtoMessage()

func (*TransactionAppend) ProtoReflect

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

func (*TransactionAppend) Reset

func (x *TransactionAppend) Reset()

func (*TransactionAppend) SizeVT

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

func (*TransactionAppend) String

func (x *TransactionAppend) String() string

func (*TransactionAppend) UnmarshalVT

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

type TransactionAppendAck

type TransactionAppendAck struct {

	// key_paths is the list of complete path(s) that the newly appended item(s) will use on a
	// successful commit of the transaction. Keys are returned in the same order of the appended
	// items provided in TransactionAppend#appends.
	// These paths are provisional until the transaction is committed - if the
	// transaction is aborted, the item(s) will not be added and other item(s) could
	// be created with the same IDs.
	KeyPaths []string `protobuf:"bytes,1,rep,name=key_paths,json=keyPaths,proto3" json:"key_paths,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionAppendAck) CloneMessageVT

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

func (*TransactionAppendAck) CloneVT

func (*TransactionAppendAck) Descriptor deprecated

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

Deprecated: Use TransactionAppendAck.ProtoReflect.Descriptor instead.

func (*TransactionAppendAck) EqualMessageVT

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

func (*TransactionAppendAck) EqualVT

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

func (*TransactionAppendAck) GetKeyPaths

func (x *TransactionAppendAck) GetKeyPaths() []string

func (*TransactionAppendAck) MarshalToSizedBufferVT

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

func (*TransactionAppendAck) MarshalToVT

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

func (*TransactionAppendAck) MarshalVT

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

func (*TransactionAppendAck) ProtoMessage

func (*TransactionAppendAck) ProtoMessage()

func (*TransactionAppendAck) ProtoReflect

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

func (*TransactionAppendAck) Reset

func (x *TransactionAppendAck) Reset()

func (*TransactionAppendAck) SizeVT

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

func (*TransactionAppendAck) String

func (x *TransactionAppendAck) String() string

func (*TransactionAppendAck) UnmarshalVT

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

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 `` /* 128-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 `` /* 128-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 (*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.ContinueListDirection" json:"direction,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionContinueList) CloneMessageVT

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

func (*TransactionContinueList) CloneVT

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 (*TransactionContinueList) GetDirection

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 []*PutResult `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"`
	// append_results contains the full result of each Append operation. This only
	// comes back with the TransactionFinished message because full metadata isn't
	// available until then.
	AppendResults []*AppendItemResult `protobuf:"bytes,4,rep,name=append_results,json=appendResults,proto3" json:"append_results,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionFinished) CloneMessageVT

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

func (*TransactionFinished) CloneVT

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) GetAppendResults

func (x *TransactionFinished) GetAppendResults() []*AppendItemResult

func (*TransactionFinished) GetCommitted

func (x *TransactionFinished) GetCommitted() bool

func (*TransactionFinished) GetDeleteResults

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

func (*TransactionFinished) GetPutResults

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

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 (*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 (*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 (*TransactionListResponse) GetFinished

func (x *TransactionListResponse) GetFinished() *ListFinished

func (*TransactionListResponse) GetListResponse

func (t *TransactionListResponse) GetListResponse() ListResponder

GetListResponse returns the ListResponder from the TransactionListResponse.

func (*TransactionListResponse) GetResponse

func (m *TransactionListResponse) GetResponse() isTransactionListResponse_Response

func (*TransactionListResponse) GetResult

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 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_AppendItems
	//	*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) GetAppendItems

func (x *TransactionRequest) GetAppendItems() *TransactionAppend

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,10,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_AppendItems

type TransactionRequest_AppendItems struct {
	// The client is requesting to append new items. This is acknowledged in
	// TransactionResponse#append_ack which contains the item's tentative full
	// path (pending the transaction's commit). The final result of all appends
	// will be returned in TransactionFinished#append_results.
	AppendItems *TransactionAppend `protobuf:"bytes,7,opt,name=append_items,json=appendItems,proto3,oneof"`
}

func (*TransactionRequest_AppendItems) CloneVT

func (m *TransactionRequest_AppendItems) CloneVT() isTransactionRequest_Command

func (*TransactionRequest_AppendItems) EqualVT

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

func (*TransactionRequest_AppendItems) MarshalToSizedBufferVT

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

func (*TransactionRequest_AppendItems) MarshalToVT

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

func (*TransactionRequest_AppendItems) SizeVT

func (m *TransactionRequest_AppendItems) 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,9,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,8,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. It is not acknowledged
	// unless there is an error, which kills the whole transaction. 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_AppendAck
	//	*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 (*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) GetAppendAck

func (x *TransactionResponse) GetAppendAck() *TransactionAppendAck

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) 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_AppendAck

type TransactionResponse_AppendAck struct {
	// append_ack contains some information about an append operation, like its
	// tentative ID (pending transaction commit).
	AppendAck *TransactionAppendAck `protobuf:"bytes,3,opt,name=append_ack,json=appendAck,proto3,oneof"`
}

func (*TransactionResponse_AppendAck) CloneVT

func (m *TransactionResponse_AppendAck) CloneVT() isTransactionResponse_Result

func (*TransactionResponse_AppendAck) EqualVT

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

func (*TransactionResponse_AppendAck) MarshalToSizedBufferVT

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

func (*TransactionResponse_AppendAck) MarshalToVT

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

func (*TransactionResponse_AppendAck) SizeVT

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

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)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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