Documentation ¶
Index ¶
- Variables
- type AppendItem
- func (m *AppendItem) CloneMessageVT() proto.Message
- func (m *AppendItem) CloneVT() *AppendItem
- func (*AppendItem) Descriptor() ([]byte, []int)deprecated
- func (this *AppendItem) EqualMessageVT(thatMsg proto.Message) bool
- func (this *AppendItem) EqualVT(that *AppendItem) bool
- func (x *AppendItem) GetIdAssignment() AppendItem_IDAssignment
- func (x *AppendItem) GetItemType() string
- func (x *AppendItem) GetJson() *structpb.Struct
- func (x *AppendItem) GetProto() []byte
- func (m *AppendItem) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *AppendItem) MarshalToVT(dAtA []byte) (int, error)
- func (m *AppendItem) MarshalVT() (dAtA []byte, err error)
- func (*AppendItem) ProtoMessage()
- func (x *AppendItem) ProtoReflect() protoreflect.Message
- func (x *AppendItem) Reset()
- func (m *AppendItem) SizeVT() (n int)
- func (x *AppendItem) String() string
- func (m *AppendItem) UnmarshalVT(dAtA []byte) error
- type AppendItemResult
- func (m *AppendItemResult) CloneMessageVT() proto.Message
- func (m *AppendItemResult) CloneVT() *AppendItemResult
- func (*AppendItemResult) Descriptor() ([]byte, []int)deprecated
- func (this *AppendItemResult) EqualMessageVT(thatMsg proto.Message) bool
- func (this *AppendItemResult) EqualVT(that *AppendItemResult) bool
- func (x *AppendItemResult) GetError() *common.OperationError
- func (x *AppendItemResult) GetKeyPath() string
- func (x *AppendItemResult) GetMetadata() *ItemMetadata
- func (m *AppendItemResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *AppendItemResult) MarshalToVT(dAtA []byte) (int, error)
- func (m *AppendItemResult) MarshalVT() (dAtA []byte, err error)
- func (*AppendItemResult) ProtoMessage()
- func (x *AppendItemResult) ProtoReflect() protoreflect.Message
- func (x *AppendItemResult) Reset()
- func (m *AppendItemResult) SizeVT() (n int)
- func (x *AppendItemResult) String() string
- func (m *AppendItemResult) UnmarshalVT(dAtA []byte) error
- type AppendItem_IDAssignment
- func (AppendItem_IDAssignment) Descriptor() protoreflect.EnumDescriptor
- func (x AppendItem_IDAssignment) Enum() *AppendItem_IDAssignment
- func (AppendItem_IDAssignment) EnumDescriptor() ([]byte, []int)deprecated
- func (x AppendItem_IDAssignment) Number() protoreflect.EnumNumber
- func (x AppendItem_IDAssignment) String() string
- func (AppendItem_IDAssignment) Type() protoreflect.EnumType
- type AppendRequest
- func (m *AppendRequest) CloneMessageVT() proto.Message
- func (m *AppendRequest) CloneVT() *AppendRequest
- func (*AppendRequest) Descriptor() ([]byte, []int)deprecated
- func (this *AppendRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *AppendRequest) EqualVT(that *AppendRequest) bool
- func (x *AppendRequest) GetAppends() []*AppendItem
- func (x *AppendRequest) GetAtomic() bool
- func (x *AppendRequest) GetParentPath() string
- func (x *AppendRequest) GetStoreId() uint64
- func (m *AppendRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *AppendRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *AppendRequest) MarshalVT() (dAtA []byte, err error)
- func (*AppendRequest) ProtoMessage()
- func (x *AppendRequest) ProtoReflect() protoreflect.Message
- func (x *AppendRequest) Reset()
- func (m *AppendRequest) SizeVT() (n int)
- func (x *AppendRequest) String() string
- func (m *AppendRequest) UnmarshalVT(dAtA []byte) error
- type AppendResponse
- func (m *AppendResponse) CloneMessageVT() proto.Message
- func (m *AppendResponse) CloneVT() *AppendResponse
- func (*AppendResponse) Descriptor() ([]byte, []int)deprecated
- func (this *AppendResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *AppendResponse) EqualVT(that *AppendResponse) bool
- func (x *AppendResponse) GetResults() []*AppendItemResult
- func (m *AppendResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *AppendResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *AppendResponse) MarshalVT() (dAtA []byte, err error)
- func (*AppendResponse) ProtoMessage()
- func (x *AppendResponse) ProtoReflect() protoreflect.Message
- func (x *AppendResponse) Reset()
- func (m *AppendResponse) SizeVT() (n int)
- func (x *AppendResponse) String() string
- func (m *AppendResponse) UnmarshalVT(dAtA []byte) error
- type BeginListRequest
- func (m *BeginListRequest) CloneMessageVT() proto.Message
- func (m *BeginListRequest) CloneVT() *BeginListRequest
- func (*BeginListRequest) Descriptor() ([]byte, []int)deprecated
- func (this *BeginListRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *BeginListRequest) EqualVT(that *BeginListRequest) bool
- func (x *BeginListRequest) GetAllowStale() bool
- func (x *BeginListRequest) GetKeyPathPrefix() string
- func (x *BeginListRequest) GetLimit() uint32
- func (x *BeginListRequest) GetSortDirection() SortDirection
- func (x *BeginListRequest) GetSortProperty() SortableProperty
- func (x *BeginListRequest) GetStoreId() uint64
- func (m *BeginListRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *BeginListRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *BeginListRequest) MarshalVT() (dAtA []byte, err error)
- func (*BeginListRequest) ProtoMessage()
- func (x *BeginListRequest) ProtoReflect() protoreflect.Message
- func (x *BeginListRequest) Reset()
- func (m *BeginListRequest) SizeVT() (n int)
- func (x *BeginListRequest) String() string
- func (m *BeginListRequest) UnmarshalVT(dAtA []byte) error
- type ContinueListDirection
- func (ContinueListDirection) Descriptor() protoreflect.EnumDescriptor
- func (x ContinueListDirection) Enum() *ContinueListDirection
- func (ContinueListDirection) EnumDescriptor() ([]byte, []int)deprecated
- func (x ContinueListDirection) Number() protoreflect.EnumNumber
- func (x ContinueListDirection) String() string
- func (ContinueListDirection) Type() protoreflect.EnumType
- type ContinueListRequest
- func (m *ContinueListRequest) CloneMessageVT() proto.Message
- func (m *ContinueListRequest) CloneVT() *ContinueListRequest
- func (*ContinueListRequest) Descriptor() ([]byte, []int)deprecated
- func (this *ContinueListRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *ContinueListRequest) EqualVT(that *ContinueListRequest) bool
- func (x *ContinueListRequest) GetDirection() ContinueListDirection
- func (x *ContinueListRequest) GetTokenData() []byte
- func (m *ContinueListRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ContinueListRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *ContinueListRequest) MarshalVT() (dAtA []byte, err error)
- func (*ContinueListRequest) ProtoMessage()
- func (x *ContinueListRequest) ProtoReflect() protoreflect.Message
- func (x *ContinueListRequest) Reset()
- func (m *ContinueListRequest) SizeVT() (n int)
- func (x *ContinueListRequest) String() string
- func (m *ContinueListRequest) UnmarshalVT(dAtA []byte) error
- type DeleteItem
- func (m *DeleteItem) CloneMessageVT() proto.Message
- func (m *DeleteItem) CloneVT() *DeleteItem
- func (*DeleteItem) Descriptor() ([]byte, []int)deprecated
- func (this *DeleteItem) EqualMessageVT(thatMsg proto.Message) bool
- func (this *DeleteItem) EqualVT(that *DeleteItem) bool
- func (x *DeleteItem) GetKeyPath() string
- func (m *DeleteItem) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *DeleteItem) MarshalToVT(dAtA []byte) (int, error)
- func (m *DeleteItem) MarshalVT() (dAtA []byte, err error)
- func (*DeleteItem) ProtoMessage()
- func (x *DeleteItem) ProtoReflect() protoreflect.Message
- func (x *DeleteItem) Reset()
- func (m *DeleteItem) SizeVT() (n int)
- func (x *DeleteItem) String() string
- func (m *DeleteItem) UnmarshalVT(dAtA []byte) error
- type DeleteRequest
- func (m *DeleteRequest) CloneMessageVT() proto.Message
- func (m *DeleteRequest) CloneVT() *DeleteRequest
- func (*DeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (this *DeleteRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *DeleteRequest) EqualVT(that *DeleteRequest) bool
- func (x *DeleteRequest) GetAtomic() bool
- func (x *DeleteRequest) GetDeletes() []*DeleteItem
- func (x *DeleteRequest) GetStoreId() uint64
- func (m *DeleteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *DeleteRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *DeleteRequest) MarshalVT() (dAtA []byte, err error)
- func (*DeleteRequest) ProtoMessage()
- func (x *DeleteRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteRequest) Reset()
- func (m *DeleteRequest) SizeVT() (n int)
- func (x *DeleteRequest) String() string
- func (m *DeleteRequest) UnmarshalVT(dAtA []byte) error
- type DeleteResponse
- func (m *DeleteResponse) CloneMessageVT() proto.Message
- func (m *DeleteResponse) CloneVT() *DeleteResponse
- func (*DeleteResponse) Descriptor() ([]byte, []int)deprecated
- func (this *DeleteResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *DeleteResponse) EqualVT(that *DeleteResponse) bool
- func (x *DeleteResponse) GetResults() []*DeleteResult
- func (m *DeleteResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *DeleteResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *DeleteResponse) MarshalVT() (dAtA []byte, err error)
- func (*DeleteResponse) ProtoMessage()
- func (x *DeleteResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteResponse) Reset()
- func (m *DeleteResponse) SizeVT() (n int)
- func (x *DeleteResponse) String() string
- func (m *DeleteResponse) UnmarshalVT(dAtA []byte) error
- type DeleteResult
- func (m *DeleteResult) CloneMessageVT() proto.Message
- func (m *DeleteResult) CloneVT() *DeleteResult
- func (*DeleteResult) Descriptor() ([]byte, []int)deprecated
- func (this *DeleteResult) EqualMessageVT(thatMsg proto.Message) bool
- func (this *DeleteResult) EqualVT(that *DeleteResult) bool
- func (x *DeleteResult) GetError() *common.OperationError
- func (x *DeleteResult) GetKeyPath() string
- func (m *DeleteResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *DeleteResult) MarshalToVT(dAtA []byte) (int, error)
- func (m *DeleteResult) MarshalVT() (dAtA []byte, err error)
- func (*DeleteResult) ProtoMessage()
- func (x *DeleteResult) ProtoReflect() protoreflect.Message
- func (x *DeleteResult) Reset()
- func (m *DeleteResult) SizeVT() (n int)
- func (x *DeleteResult) String() string
- func (m *DeleteResult) UnmarshalVT(dAtA []byte) error
- type DeletedItem
- func (m *DeletedItem) CloneMessageVT() proto.Message
- func (m *DeletedItem) CloneVT() *DeletedItem
- func (*DeletedItem) Descriptor() ([]byte, []int)deprecated
- func (this *DeletedItem) EqualMessageVT(thatMsg proto.Message) bool
- func (this *DeletedItem) EqualVT(that *DeletedItem) bool
- func (x *DeletedItem) GetKeyPath() string
- func (m *DeletedItem) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *DeletedItem) MarshalToVT(dAtA []byte) (int, error)
- func (m *DeletedItem) MarshalVT() (dAtA []byte, err error)
- func (*DeletedItem) ProtoMessage()
- func (x *DeletedItem) ProtoReflect() protoreflect.Message
- func (x *DeletedItem) Reset()
- func (m *DeletedItem) SizeVT() (n int)
- func (x *DeletedItem) String() string
- func (m *DeletedItem) UnmarshalVT(dAtA []byte) error
- type GetItem
- func (m *GetItem) CloneMessageVT() proto.Message
- func (m *GetItem) CloneVT() *GetItem
- func (*GetItem) Descriptor() ([]byte, []int)deprecated
- func (this *GetItem) EqualMessageVT(thatMsg proto.Message) bool
- func (this *GetItem) EqualVT(that *GetItem) bool
- func (x *GetItem) GetKeyPath() string
- func (m *GetItem) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *GetItem) MarshalToVT(dAtA []byte) (int, error)
- func (m *GetItem) MarshalVT() (dAtA []byte, err error)
- func (*GetItem) ProtoMessage()
- func (x *GetItem) ProtoReflect() protoreflect.Message
- func (x *GetItem) Reset()
- func (m *GetItem) SizeVT() (n int)
- func (x *GetItem) String() string
- func (m *GetItem) UnmarshalVT(dAtA []byte) error
- type GetRequest
- func (m *GetRequest) CloneMessageVT() proto.Message
- func (m *GetRequest) CloneVT() *GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)deprecated
- func (this *GetRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *GetRequest) EqualVT(that *GetRequest) bool
- func (x *GetRequest) GetAllowStale() bool
- func (x *GetRequest) GetAtomic() bool
- func (x *GetRequest) GetGets() []*GetItem
- func (x *GetRequest) GetStoreId() uint64
- func (m *GetRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *GetRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *GetRequest) MarshalVT() (dAtA []byte, err error)
- func (*GetRequest) ProtoMessage()
- func (x *GetRequest) ProtoReflect() protoreflect.Message
- func (x *GetRequest) Reset()
- func (m *GetRequest) SizeVT() (n int)
- func (x *GetRequest) String() string
- func (m *GetRequest) UnmarshalVT(dAtA []byte) error
- type GetResponse
- func (m *GetResponse) CloneMessageVT() proto.Message
- func (m *GetResponse) CloneVT() *GetResponse
- func (*GetResponse) Descriptor() ([]byte, []int)deprecated
- func (this *GetResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *GetResponse) EqualVT(that *GetResponse) bool
- func (x *GetResponse) GetItems() []*Item
- func (m *GetResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *GetResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *GetResponse) MarshalVT() (dAtA []byte, err error)
- func (*GetResponse) ProtoMessage()
- func (x *GetResponse) ProtoReflect() protoreflect.Message
- func (x *GetResponse) Reset()
- func (m *GetResponse) SizeVT() (n int)
- func (x *GetResponse) String() string
- func (m *GetResponse) UnmarshalVT(dAtA []byte) error
- type IsTransactionCommand
- type IsTransactionResponseResult
- type Item
- func (m *Item) CloneMessageVT() proto.Message
- func (m *Item) CloneVT() *Item
- func (*Item) Descriptor() ([]byte, []int)deprecated
- func (this *Item) EqualMessageVT(thatMsg proto.Message) bool
- func (this *Item) EqualVT(that *Item) bool
- func (x *Item) GetJson() *structpb.Struct
- func (x *Item) GetKeyPath() string
- func (x *Item) GetMetadata() *ItemMetadata
- func (x *Item) GetProto() []byte
- func (m *Item) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Item) MarshalToVT(dAtA []byte) (int, error)
- func (m *Item) MarshalVT() (dAtA []byte, err error)
- func (*Item) ProtoMessage()
- func (x *Item) ProtoReflect() protoreflect.Message
- func (x *Item) Reset()
- func (m *Item) SizeVT() (n int)
- func (x *Item) String() string
- func (m *Item) UnmarshalVT(dAtA []byte) error
- type ItemMetadata
- func (m *ItemMetadata) CloneMessageVT() proto.Message
- func (m *ItemMetadata) CloneVT() *ItemMetadata
- func (*ItemMetadata) Descriptor() ([]byte, []int)deprecated
- func (this *ItemMetadata) EqualMessageVT(thatMsg proto.Message) bool
- func (this *ItemMetadata) EqualVT(that *ItemMetadata) bool
- func (x *ItemMetadata) GetCreatedAtMicros() uint64
- func (x *ItemMetadata) GetCreatedAtVersion() uint64
- func (x *ItemMetadata) GetLastModifiedAtMicros() uint64
- func (x *ItemMetadata) GetLastModifiedAtVersion() uint64
- func (m *ItemMetadata) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ItemMetadata) MarshalToVT(dAtA []byte) (int, error)
- func (m *ItemMetadata) MarshalVT() (dAtA []byte, err error)
- func (*ItemMetadata) ProtoMessage()
- func (x *ItemMetadata) ProtoReflect() protoreflect.Message
- func (x *ItemMetadata) Reset()
- func (m *ItemMetadata) SizeVT() (n int)
- func (x *ItemMetadata) String() string
- func (m *ItemMetadata) UnmarshalVT(dAtA []byte) error
- type ListFinished
- func (m *ListFinished) CloneMessageVT() proto.Message
- func (m *ListFinished) CloneVT() *ListFinished
- func (*ListFinished) Descriptor() ([]byte, []int)deprecated
- func (this *ListFinished) EqualMessageVT(thatMsg proto.Message) bool
- func (this *ListFinished) EqualVT(that *ListFinished) bool
- func (x *ListFinished) GetToken() *ListToken
- func (*ListFinished) IsListResponder()
- func (m *ListFinished) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ListFinished) MarshalToVT(dAtA []byte) (int, error)
- func (m *ListFinished) MarshalVT() (dAtA []byte, err error)
- func (*ListFinished) ProtoMessage()
- func (x *ListFinished) ProtoReflect() protoreflect.Message
- func (x *ListFinished) Reset()
- func (m *ListFinished) SizeVT() (n int)
- func (x *ListFinished) String() string
- func (m *ListFinished) UnmarshalVT(dAtA []byte) error
- type ListPartialResult
- func (m *ListPartialResult) CloneMessageVT() proto.Message
- func (m *ListPartialResult) CloneVT() *ListPartialResult
- func (*ListPartialResult) Descriptor() ([]byte, []int)deprecated
- func (this *ListPartialResult) EqualMessageVT(thatMsg proto.Message) bool
- func (this *ListPartialResult) EqualVT(that *ListPartialResult) bool
- func (x *ListPartialResult) GetItems() []*Item
- func (*ListPartialResult) IsListResponder()
- func (m *ListPartialResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ListPartialResult) MarshalToVT(dAtA []byte) (int, error)
- func (m *ListPartialResult) MarshalVT() (dAtA []byte, err error)
- func (*ListPartialResult) ProtoMessage()
- func (x *ListPartialResult) ProtoReflect() protoreflect.Message
- func (x *ListPartialResult) Reset()
- func (m *ListPartialResult) SizeVT() (n int)
- func (x *ListPartialResult) String() string
- func (m *ListPartialResult) UnmarshalVT(dAtA []byte) error
- type ListResponder
- type ListResponse
- func (m *ListResponse) CloneMessageVT() proto.Message
- func (m *ListResponse) CloneVT() *ListResponse
- func (*ListResponse) Descriptor() ([]byte, []int)deprecated
- func (this *ListResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *ListResponse) EqualVT(that *ListResponse) bool
- func (x *ListResponse) GetFinished() *ListFinished
- func (t *ListResponse) GetListResponse() ListResponder
- func (m *ListResponse) GetResponse() isListResponse_Response
- func (x *ListResponse) GetResult() *ListPartialResult
- func (m *ListResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ListResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *ListResponse) MarshalVT() (dAtA []byte, err error)
- func (*ListResponse) ProtoMessage()
- func (x *ListResponse) ProtoReflect() protoreflect.Message
- func (x *ListResponse) Reset()
- func (m *ListResponse) SizeVT() (n int)
- func (x *ListResponse) String() string
- func (m *ListResponse) UnmarshalVT(dAtA []byte) error
- type ListResponse_Finished
- func (m *ListResponse_Finished) CloneVT() isListResponse_Response
- func (this *ListResponse_Finished) EqualVT(thatIface isListResponse_Response) bool
- func (m *ListResponse_Finished) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ListResponse_Finished) MarshalToVT(dAtA []byte) (int, error)
- func (m *ListResponse_Finished) SizeVT() (n int)
- type ListResponse_Result
- func (m *ListResponse_Result) CloneVT() isListResponse_Response
- func (this *ListResponse_Result) EqualVT(thatIface isListResponse_Response) bool
- func (m *ListResponse_Result) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ListResponse_Result) MarshalToVT(dAtA []byte) (int, error)
- func (m *ListResponse_Result) SizeVT() (n int)
- type ListToken
- func (m *ListToken) CloneMessageVT() proto.Message
- func (m *ListToken) CloneVT() *ListToken
- func (*ListToken) Descriptor() ([]byte, []int)deprecated
- func (this *ListToken) EqualMessageVT(thatMsg proto.Message) bool
- func (this *ListToken) EqualVT(that *ListToken) bool
- func (x *ListToken) GetCanContinue() bool
- func (x *ListToken) GetCanSync() bool
- func (x *ListToken) GetTokenData() []byte
- func (m *ListToken) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ListToken) MarshalToVT(dAtA []byte) (int, error)
- func (m *ListToken) MarshalVT() (dAtA []byte, err error)
- func (*ListToken) ProtoMessage()
- func (x *ListToken) ProtoReflect() protoreflect.Message
- func (x *ListToken) Reset()
- func (m *ListToken) SizeVT() (n int)
- func (x *ListToken) String() string
- func (m *ListToken) UnmarshalVT(dAtA []byte) error
- type PutItem
- func (m *PutItem) CloneMessageVT() proto.Message
- func (m *PutItem) CloneVT() *PutItem
- func (*PutItem) Descriptor() ([]byte, []int)deprecated
- func (this *PutItem) EqualMessageVT(thatMsg proto.Message) bool
- func (this *PutItem) EqualVT(that *PutItem) bool
- func (x *PutItem) GetItem() *Item
- func (m *PutItem) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *PutItem) MarshalToVT(dAtA []byte) (int, error)
- func (m *PutItem) MarshalVT() (dAtA []byte, err error)
- func (*PutItem) ProtoMessage()
- func (x *PutItem) ProtoReflect() protoreflect.Message
- func (x *PutItem) Reset()
- func (m *PutItem) SizeVT() (n int)
- func (x *PutItem) String() string
- func (m *PutItem) UnmarshalVT(dAtA []byte) error
- type PutRequest
- func (m *PutRequest) CloneMessageVT() proto.Message
- func (m *PutRequest) CloneVT() *PutRequest
- func (*PutRequest) Descriptor() ([]byte, []int)deprecated
- func (this *PutRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *PutRequest) EqualVT(that *PutRequest) bool
- func (x *PutRequest) GetAtomic() bool
- func (x *PutRequest) GetPuts() []*PutItem
- func (x *PutRequest) GetStoreId() uint64
- func (m *PutRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *PutRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *PutRequest) MarshalVT() (dAtA []byte, err error)
- func (*PutRequest) ProtoMessage()
- func (x *PutRequest) ProtoReflect() protoreflect.Message
- func (x *PutRequest) Reset()
- func (m *PutRequest) SizeVT() (n int)
- func (x *PutRequest) String() string
- func (m *PutRequest) UnmarshalVT(dAtA []byte) error
- type PutResponse
- func (m *PutResponse) CloneMessageVT() proto.Message
- func (m *PutResponse) CloneVT() *PutResponse
- func (*PutResponse) Descriptor() ([]byte, []int)deprecated
- func (this *PutResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *PutResponse) EqualVT(that *PutResponse) bool
- func (x *PutResponse) GetResults() []*PutResult
- func (m *PutResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *PutResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *PutResponse) MarshalVT() (dAtA []byte, err error)
- func (*PutResponse) ProtoMessage()
- func (x *PutResponse) ProtoReflect() protoreflect.Message
- func (x *PutResponse) Reset()
- func (m *PutResponse) SizeVT() (n int)
- func (x *PutResponse) String() string
- func (m *PutResponse) UnmarshalVT(dAtA []byte) error
- type PutResult
- func (m *PutResult) CloneMessageVT() proto.Message
- func (m *PutResult) CloneVT() *PutResult
- func (*PutResult) Descriptor() ([]byte, []int)deprecated
- func (this *PutResult) EqualMessageVT(thatMsg proto.Message) bool
- func (this *PutResult) EqualVT(that *PutResult) bool
- func (x *PutResult) GetError() *common.OperationError
- func (x *PutResult) GetKeyPath() string
- func (x *PutResult) GetMetadata() *ItemMetadata
- func (m *PutResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *PutResult) MarshalToVT(dAtA []byte) (int, error)
- func (m *PutResult) MarshalVT() (dAtA []byte, err error)
- func (*PutResult) ProtoMessage()
- func (x *PutResult) ProtoReflect() protoreflect.Message
- func (x *PutResult) Reset()
- func (m *PutResult) SizeVT() (n int)
- func (x *PutResult) String() string
- func (m *PutResult) UnmarshalVT(dAtA []byte) error
- type ScanRootPathResult
- func (m *ScanRootPathResult) CloneMessageVT() proto.Message
- func (m *ScanRootPathResult) CloneVT() *ScanRootPathResult
- func (*ScanRootPathResult) Descriptor() ([]byte, []int)deprecated
- func (this *ScanRootPathResult) EqualMessageVT(thatMsg proto.Message) bool
- func (this *ScanRootPathResult) EqualVT(that *ScanRootPathResult) bool
- func (x *ScanRootPathResult) GetKeyPath() string
- func (m *ScanRootPathResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ScanRootPathResult) MarshalToVT(dAtA []byte) (int, error)
- func (m *ScanRootPathResult) MarshalVT() (dAtA []byte, err error)
- func (*ScanRootPathResult) ProtoMessage()
- func (x *ScanRootPathResult) ProtoReflect() protoreflect.Message
- func (x *ScanRootPathResult) Reset()
- func (m *ScanRootPathResult) SizeVT() (n int)
- func (x *ScanRootPathResult) String() string
- func (m *ScanRootPathResult) UnmarshalVT(dAtA []byte) error
- type ScanRootPathsRequest
- func (m *ScanRootPathsRequest) CloneMessageVT() proto.Message
- func (m *ScanRootPathsRequest) CloneVT() *ScanRootPathsRequest
- func (*ScanRootPathsRequest) Descriptor() ([]byte, []int)deprecated
- func (this *ScanRootPathsRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *ScanRootPathsRequest) EqualVT(that *ScanRootPathsRequest) bool
- func (x *ScanRootPathsRequest) GetLimit() uint32
- func (x *ScanRootPathsRequest) GetPaginationToken() []byte
- func (x *ScanRootPathsRequest) GetStoreId() uint64
- func (m *ScanRootPathsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ScanRootPathsRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *ScanRootPathsRequest) MarshalVT() (dAtA []byte, err error)
- func (*ScanRootPathsRequest) ProtoMessage()
- func (x *ScanRootPathsRequest) ProtoReflect() protoreflect.Message
- func (x *ScanRootPathsRequest) Reset()
- func (m *ScanRootPathsRequest) SizeVT() (n int)
- func (x *ScanRootPathsRequest) String() string
- func (m *ScanRootPathsRequest) UnmarshalVT(dAtA []byte) error
- type ScanRootPathsResponse
- func (m *ScanRootPathsResponse) CloneMessageVT() proto.Message
- func (m *ScanRootPathsResponse) CloneVT() *ScanRootPathsResponse
- func (*ScanRootPathsResponse) Descriptor() ([]byte, []int)deprecated
- func (this *ScanRootPathsResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *ScanRootPathsResponse) EqualVT(that *ScanRootPathsResponse) bool
- func (x *ScanRootPathsResponse) GetPaginationToken() []byte
- func (x *ScanRootPathsResponse) GetResults() []*ScanRootPathResult
- func (m *ScanRootPathsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ScanRootPathsResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *ScanRootPathsResponse) MarshalVT() (dAtA []byte, err error)
- func (*ScanRootPathsResponse) ProtoMessage()
- func (x *ScanRootPathsResponse) ProtoReflect() protoreflect.Message
- func (x *ScanRootPathsResponse) Reset()
- func (m *ScanRootPathsResponse) SizeVT() (n int)
- func (x *ScanRootPathsResponse) String() string
- func (m *ScanRootPathsResponse) UnmarshalVT(dAtA []byte) error
- type SortDirection
- func (SortDirection) Descriptor() protoreflect.EnumDescriptor
- func (x SortDirection) Enum() *SortDirection
- func (SortDirection) EnumDescriptor() ([]byte, []int)deprecated
- func (x SortDirection) Number() protoreflect.EnumNumber
- func (x SortDirection) String() string
- func (SortDirection) Type() protoreflect.EnumType
- type SortableProperty
- func (SortableProperty) Descriptor() protoreflect.EnumDescriptor
- func (x SortableProperty) Enum() *SortableProperty
- func (SortableProperty) EnumDescriptor() ([]byte, []int)deprecated
- func (x SortableProperty) Number() protoreflect.EnumNumber
- func (x SortableProperty) String() string
- func (SortableProperty) Type() protoreflect.EnumType
- type SyncListPartialResponse
- func (m *SyncListPartialResponse) CloneMessageVT() proto.Message
- func (m *SyncListPartialResponse) CloneVT() *SyncListPartialResponse
- func (*SyncListPartialResponse) Descriptor() ([]byte, []int)deprecated
- func (this *SyncListPartialResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *SyncListPartialResponse) EqualVT(that *SyncListPartialResponse) bool
- func (x *SyncListPartialResponse) GetChangedItems() []*Item
- func (x *SyncListPartialResponse) GetDeletedItems() []*DeletedItem
- func (x *SyncListPartialResponse) GetUpdatedItemKeysOutsideListWindow() []string
- func (m *SyncListPartialResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *SyncListPartialResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *SyncListPartialResponse) MarshalVT() (dAtA []byte, err error)
- func (*SyncListPartialResponse) ProtoMessage()
- func (x *SyncListPartialResponse) ProtoReflect() protoreflect.Message
- func (x *SyncListPartialResponse) Reset()
- func (m *SyncListPartialResponse) SizeVT() (n int)
- func (x *SyncListPartialResponse) String() string
- func (m *SyncListPartialResponse) UnmarshalVT(dAtA []byte) error
- type SyncListRequest
- func (m *SyncListRequest) CloneMessageVT() proto.Message
- func (m *SyncListRequest) CloneVT() *SyncListRequest
- func (*SyncListRequest) Descriptor() ([]byte, []int)deprecated
- func (this *SyncListRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *SyncListRequest) EqualVT(that *SyncListRequest) bool
- func (x *SyncListRequest) GetTokenData() []byte
- func (m *SyncListRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *SyncListRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *SyncListRequest) MarshalVT() (dAtA []byte, err error)
- func (*SyncListRequest) ProtoMessage()
- func (x *SyncListRequest) ProtoReflect() protoreflect.Message
- func (x *SyncListRequest) Reset()
- func (m *SyncListRequest) SizeVT() (n int)
- func (x *SyncListRequest) String() string
- func (m *SyncListRequest) UnmarshalVT(dAtA []byte) error
- type SyncListReset
- func (m *SyncListReset) CloneMessageVT() proto.Message
- func (m *SyncListReset) CloneVT() *SyncListReset
- func (*SyncListReset) Descriptor() ([]byte, []int)deprecated
- func (this *SyncListReset) EqualMessageVT(thatMsg proto.Message) bool
- func (this *SyncListReset) EqualVT(that *SyncListReset) bool
- func (m *SyncListReset) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *SyncListReset) MarshalToVT(dAtA []byte) (int, error)
- func (m *SyncListReset) MarshalVT() (dAtA []byte, err error)
- func (*SyncListReset) ProtoMessage()
- func (x *SyncListReset) ProtoReflect() protoreflect.Message
- func (x *SyncListReset) Reset()
- func (m *SyncListReset) SizeVT() (n int)
- func (x *SyncListReset) String() string
- func (m *SyncListReset) UnmarshalVT(dAtA []byte) error
- type SyncListResponse
- func (m *SyncListResponse) CloneMessageVT() proto.Message
- func (m *SyncListResponse) CloneVT() *SyncListResponse
- func (*SyncListResponse) Descriptor() ([]byte, []int)deprecated
- func (this *SyncListResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *SyncListResponse) EqualVT(that *SyncListResponse) bool
- func (x *SyncListResponse) GetFinished() *ListFinished
- func (x *SyncListResponse) GetReset_() *SyncListReset
- func (m *SyncListResponse) GetResponse() isSyncListResponse_Response
- func (x *SyncListResponse) GetResult() *SyncListPartialResponse
- func (m *SyncListResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *SyncListResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *SyncListResponse) MarshalVT() (dAtA []byte, err error)
- func (*SyncListResponse) ProtoMessage()
- func (x *SyncListResponse) ProtoReflect() protoreflect.Message
- func (x *SyncListResponse) Reset()
- func (m *SyncListResponse) SizeVT() (n int)
- func (x *SyncListResponse) String() string
- func (m *SyncListResponse) UnmarshalVT(dAtA []byte) error
- type SyncListResponse_Finished
- func (m *SyncListResponse_Finished) CloneVT() isSyncListResponse_Response
- func (this *SyncListResponse_Finished) EqualVT(thatIface isSyncListResponse_Response) bool
- func (m *SyncListResponse_Finished) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *SyncListResponse_Finished) MarshalToVT(dAtA []byte) (int, error)
- func (m *SyncListResponse_Finished) SizeVT() (n int)
- type SyncListResponse_Reset_
- func (m *SyncListResponse_Reset_) CloneVT() isSyncListResponse_Response
- func (this *SyncListResponse_Reset_) EqualVT(thatIface isSyncListResponse_Response) bool
- func (m *SyncListResponse_Reset_) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *SyncListResponse_Reset_) MarshalToVT(dAtA []byte) (int, error)
- func (m *SyncListResponse_Reset_) SizeVT() (n int)
- type SyncListResponse_Result
- func (m *SyncListResponse_Result) CloneVT() isSyncListResponse_Response
- func (this *SyncListResponse_Result) EqualVT(thatIface isSyncListResponse_Response) bool
- func (m *SyncListResponse_Result) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *SyncListResponse_Result) MarshalToVT(dAtA []byte) (int, error)
- func (m *SyncListResponse_Result) SizeVT() (n int)
- type TransactionAppend
- func (m *TransactionAppend) CloneMessageVT() proto.Message
- func (m *TransactionAppend) CloneVT() *TransactionAppend
- func (*TransactionAppend) Descriptor() ([]byte, []int)deprecated
- func (this *TransactionAppend) EqualMessageVT(thatMsg proto.Message) bool
- func (this *TransactionAppend) EqualVT(that *TransactionAppend) bool
- func (x *TransactionAppend) GetAppends() []*AppendItem
- func (x *TransactionAppend) GetParentPath() string
- func (m *TransactionAppend) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionAppend) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionAppend) MarshalVT() (dAtA []byte, err error)
- func (*TransactionAppend) ProtoMessage()
- func (x *TransactionAppend) ProtoReflect() protoreflect.Message
- func (x *TransactionAppend) Reset()
- func (m *TransactionAppend) SizeVT() (n int)
- func (x *TransactionAppend) String() string
- func (m *TransactionAppend) UnmarshalVT(dAtA []byte) error
- type TransactionAppendAck
- func (m *TransactionAppendAck) CloneMessageVT() proto.Message
- func (m *TransactionAppendAck) CloneVT() *TransactionAppendAck
- func (*TransactionAppendAck) Descriptor() ([]byte, []int)deprecated
- func (this *TransactionAppendAck) EqualMessageVT(thatMsg proto.Message) bool
- func (this *TransactionAppendAck) EqualVT(that *TransactionAppendAck) bool
- func (x *TransactionAppendAck) GetKeyPaths() []string
- func (m *TransactionAppendAck) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionAppendAck) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionAppendAck) MarshalVT() (dAtA []byte, err error)
- func (*TransactionAppendAck) ProtoMessage()
- func (x *TransactionAppendAck) ProtoReflect() protoreflect.Message
- func (x *TransactionAppendAck) Reset()
- func (m *TransactionAppendAck) SizeVT() (n int)
- func (x *TransactionAppendAck) String() string
- func (m *TransactionAppendAck) UnmarshalVT(dAtA []byte) error
- type TransactionBegin
- func (m *TransactionBegin) CloneMessageVT() proto.Message
- func (m *TransactionBegin) CloneVT() *TransactionBegin
- func (*TransactionBegin) Descriptor() ([]byte, []int)deprecated
- func (this *TransactionBegin) EqualMessageVT(thatMsg proto.Message) bool
- func (this *TransactionBegin) EqualVT(that *TransactionBegin) bool
- func (x *TransactionBegin) GetStoreId() uint64
- func (m *TransactionBegin) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionBegin) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionBegin) MarshalVT() (dAtA []byte, err error)
- func (*TransactionBegin) ProtoMessage()
- func (x *TransactionBegin) ProtoReflect() protoreflect.Message
- func (x *TransactionBegin) Reset()
- func (m *TransactionBegin) SizeVT() (n int)
- func (x *TransactionBegin) String() string
- func (m *TransactionBegin) UnmarshalVT(dAtA []byte) error
- type TransactionBeginList
- func (m *TransactionBeginList) CloneMessageVT() proto.Message
- func (m *TransactionBeginList) CloneVT() *TransactionBeginList
- func (*TransactionBeginList) Descriptor() ([]byte, []int)deprecated
- func (this *TransactionBeginList) EqualMessageVT(thatMsg proto.Message) bool
- func (this *TransactionBeginList) EqualVT(that *TransactionBeginList) bool
- func (x *TransactionBeginList) GetKeyPathPrefix() string
- func (x *TransactionBeginList) GetLimit() uint32
- func (x *TransactionBeginList) GetSortDirection() SortDirection
- func (x *TransactionBeginList) GetSortProperty() SortableProperty
- func (m *TransactionBeginList) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionBeginList) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionBeginList) MarshalVT() (dAtA []byte, err error)
- func (*TransactionBeginList) ProtoMessage()
- func (x *TransactionBeginList) ProtoReflect() protoreflect.Message
- func (x *TransactionBeginList) Reset()
- func (m *TransactionBeginList) SizeVT() (n int)
- func (x *TransactionBeginList) String() string
- func (m *TransactionBeginList) UnmarshalVT(dAtA []byte) error
- type TransactionContinueList
- func (m *TransactionContinueList) CloneMessageVT() proto.Message
- func (m *TransactionContinueList) CloneVT() *TransactionContinueList
- func (*TransactionContinueList) Descriptor() ([]byte, []int)deprecated
- func (this *TransactionContinueList) EqualMessageVT(thatMsg proto.Message) bool
- func (this *TransactionContinueList) EqualVT(that *TransactionContinueList) bool
- func (x *TransactionContinueList) GetDirection() ContinueListDirection
- func (x *TransactionContinueList) GetTokenData() []byte
- func (m *TransactionContinueList) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionContinueList) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionContinueList) MarshalVT() (dAtA []byte, err error)
- func (*TransactionContinueList) ProtoMessage()
- func (x *TransactionContinueList) ProtoReflect() protoreflect.Message
- func (x *TransactionContinueList) Reset()
- func (m *TransactionContinueList) SizeVT() (n int)
- func (x *TransactionContinueList) String() string
- func (m *TransactionContinueList) UnmarshalVT(dAtA []byte) error
- type TransactionDelete
- func (m *TransactionDelete) CloneMessageVT() proto.Message
- func (m *TransactionDelete) CloneVT() *TransactionDelete
- func (*TransactionDelete) Descriptor() ([]byte, []int)deprecated
- func (this *TransactionDelete) EqualMessageVT(thatMsg proto.Message) bool
- func (this *TransactionDelete) EqualVT(that *TransactionDelete) bool
- func (x *TransactionDelete) GetDeletes() []*DeleteItem
- func (m *TransactionDelete) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionDelete) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionDelete) MarshalVT() (dAtA []byte, err error)
- func (*TransactionDelete) ProtoMessage()
- func (x *TransactionDelete) ProtoReflect() protoreflect.Message
- func (x *TransactionDelete) Reset()
- func (m *TransactionDelete) SizeVT() (n int)
- func (x *TransactionDelete) String() string
- func (m *TransactionDelete) UnmarshalVT(dAtA []byte) error
- type TransactionFinished
- func (m *TransactionFinished) CloneMessageVT() proto.Message
- func (m *TransactionFinished) CloneVT() *TransactionFinished
- func (*TransactionFinished) Descriptor() ([]byte, []int)deprecated
- func (this *TransactionFinished) EqualMessageVT(thatMsg proto.Message) bool
- func (this *TransactionFinished) EqualVT(that *TransactionFinished) bool
- func (x *TransactionFinished) GetAppendResults() []*AppendItemResult
- func (x *TransactionFinished) GetCommitted() bool
- func (x *TransactionFinished) GetDeleteResults() []*DeleteResult
- func (x *TransactionFinished) GetPutResults() []*PutResult
- func (m *TransactionFinished) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionFinished) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionFinished) MarshalVT() (dAtA []byte, err error)
- func (*TransactionFinished) ProtoMessage()
- func (x *TransactionFinished) ProtoReflect() protoreflect.Message
- func (x *TransactionFinished) Reset()
- func (m *TransactionFinished) SizeVT() (n int)
- func (x *TransactionFinished) String() string
- func (m *TransactionFinished) UnmarshalVT(dAtA []byte) error
- type TransactionGet
- func (m *TransactionGet) CloneMessageVT() proto.Message
- func (m *TransactionGet) CloneVT() *TransactionGet
- func (*TransactionGet) Descriptor() ([]byte, []int)deprecated
- func (this *TransactionGet) EqualMessageVT(thatMsg proto.Message) bool
- func (this *TransactionGet) EqualVT(that *TransactionGet) bool
- func (x *TransactionGet) GetGets() []*GetItem
- func (m *TransactionGet) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionGet) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionGet) MarshalVT() (dAtA []byte, err error)
- func (*TransactionGet) ProtoMessage()
- func (x *TransactionGet) ProtoReflect() protoreflect.Message
- func (x *TransactionGet) Reset()
- func (m *TransactionGet) SizeVT() (n int)
- func (x *TransactionGet) String() string
- func (m *TransactionGet) UnmarshalVT(dAtA []byte) error
- type TransactionGetResponse
- func (m *TransactionGetResponse) CloneMessageVT() proto.Message
- func (m *TransactionGetResponse) CloneVT() *TransactionGetResponse
- func (*TransactionGetResponse) Descriptor() ([]byte, []int)deprecated
- func (this *TransactionGetResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *TransactionGetResponse) EqualVT(that *TransactionGetResponse) bool
- func (x *TransactionGetResponse) GetItems() []*Item
- func (m *TransactionGetResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionGetResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionGetResponse) MarshalVT() (dAtA []byte, err error)
- func (*TransactionGetResponse) ProtoMessage()
- func (x *TransactionGetResponse) ProtoReflect() protoreflect.Message
- func (x *TransactionGetResponse) Reset()
- func (m *TransactionGetResponse) SizeVT() (n int)
- func (x *TransactionGetResponse) String() string
- func (m *TransactionGetResponse) UnmarshalVT(dAtA []byte) error
- type TransactionListResponse
- func (m *TransactionListResponse) CloneMessageVT() proto.Message
- func (m *TransactionListResponse) CloneVT() *TransactionListResponse
- func (*TransactionListResponse) Descriptor() ([]byte, []int)deprecated
- func (this *TransactionListResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *TransactionListResponse) EqualVT(that *TransactionListResponse) bool
- func (x *TransactionListResponse) GetFinished() *ListFinished
- func (t *TransactionListResponse) GetListResponse() ListResponder
- func (m *TransactionListResponse) GetResponse() isTransactionListResponse_Response
- func (x *TransactionListResponse) GetResult() *ListPartialResult
- func (m *TransactionListResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionListResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionListResponse) MarshalVT() (dAtA []byte, err error)
- func (*TransactionListResponse) ProtoMessage()
- func (x *TransactionListResponse) ProtoReflect() protoreflect.Message
- func (x *TransactionListResponse) Reset()
- func (m *TransactionListResponse) SizeVT() (n int)
- func (x *TransactionListResponse) String() string
- func (m *TransactionListResponse) UnmarshalVT(dAtA []byte) error
- type TransactionListResponse_Finished
- func (m *TransactionListResponse_Finished) CloneVT() isTransactionListResponse_Response
- func (this *TransactionListResponse_Finished) EqualVT(thatIface isTransactionListResponse_Response) bool
- func (m *TransactionListResponse_Finished) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionListResponse_Finished) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionListResponse_Finished) SizeVT() (n int)
- type TransactionListResponse_Result
- func (m *TransactionListResponse_Result) CloneVT() isTransactionListResponse_Response
- func (this *TransactionListResponse_Result) EqualVT(thatIface isTransactionListResponse_Response) bool
- func (m *TransactionListResponse_Result) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionListResponse_Result) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionListResponse_Result) SizeVT() (n int)
- type TransactionPut
- func (m *TransactionPut) CloneMessageVT() proto.Message
- func (m *TransactionPut) CloneVT() *TransactionPut
- func (*TransactionPut) Descriptor() ([]byte, []int)deprecated
- func (this *TransactionPut) EqualMessageVT(thatMsg proto.Message) bool
- func (this *TransactionPut) EqualVT(that *TransactionPut) bool
- func (x *TransactionPut) GetPuts() []*PutItem
- func (m *TransactionPut) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionPut) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionPut) MarshalVT() (dAtA []byte, err error)
- func (*TransactionPut) ProtoMessage()
- func (x *TransactionPut) ProtoReflect() protoreflect.Message
- func (x *TransactionPut) Reset()
- func (m *TransactionPut) SizeVT() (n int)
- func (x *TransactionPut) String() string
- func (m *TransactionPut) UnmarshalVT(dAtA []byte) error
- type TransactionRequest
- func (m *TransactionRequest) CloneMessageVT() proto.Message
- func (m *TransactionRequest) CloneVT() *TransactionRequest
- func (*TransactionRequest) Descriptor() ([]byte, []int)deprecated
- func (this *TransactionRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *TransactionRequest) EqualVT(that *TransactionRequest) bool
- func (x *TransactionRequest) GetAbort() *emptypb.Empty
- func (x *TransactionRequest) GetAppendItems() *TransactionAppend
- func (x *TransactionRequest) GetBegin() *TransactionBegin
- func (x *TransactionRequest) GetBeginList() *TransactionBeginList
- func (m *TransactionRequest) GetCommand() isTransactionRequest_Command
- func (x *TransactionRequest) GetCommit() *emptypb.Empty
- func (x *TransactionRequest) GetContinueList() *TransactionContinueList
- func (x *TransactionRequest) GetDeleteItems() *TransactionDelete
- func (x *TransactionRequest) GetGetItems() *TransactionGet
- func (x *TransactionRequest) GetMessageId() uint32
- func (x *TransactionRequest) GetPutItems() *TransactionPut
- func (m *TransactionRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionRequest) MarshalVT() (dAtA []byte, err error)
- func (*TransactionRequest) ProtoMessage()
- func (x *TransactionRequest) ProtoReflect() protoreflect.Message
- func (x *TransactionRequest) Reset()
- func (m *TransactionRequest) SizeVT() (n int)
- func (x *TransactionRequest) String() string
- func (m *TransactionRequest) UnmarshalVT(dAtA []byte) error
- type TransactionRequest_Abort
- func (m *TransactionRequest_Abort) CloneVT() isTransactionRequest_Command
- func (this *TransactionRequest_Abort) EqualVT(thatIface isTransactionRequest_Command) bool
- func (m *TransactionRequest_Abort) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionRequest_Abort) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionRequest_Abort) SizeVT() (n int)
- type TransactionRequest_AppendItems
- func (m *TransactionRequest_AppendItems) CloneVT() isTransactionRequest_Command
- func (this *TransactionRequest_AppendItems) EqualVT(thatIface isTransactionRequest_Command) bool
- func (m *TransactionRequest_AppendItems) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionRequest_AppendItems) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionRequest_AppendItems) SizeVT() (n int)
- type TransactionRequest_Begin
- func (m *TransactionRequest_Begin) CloneVT() isTransactionRequest_Command
- func (this *TransactionRequest_Begin) EqualVT(thatIface isTransactionRequest_Command) bool
- func (m *TransactionRequest_Begin) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionRequest_Begin) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionRequest_Begin) SizeVT() (n int)
- type TransactionRequest_BeginList
- func (m *TransactionRequest_BeginList) CloneVT() isTransactionRequest_Command
- func (this *TransactionRequest_BeginList) EqualVT(thatIface isTransactionRequest_Command) bool
- func (m *TransactionRequest_BeginList) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionRequest_BeginList) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionRequest_BeginList) SizeVT() (n int)
- type TransactionRequest_Commit
- func (m *TransactionRequest_Commit) CloneVT() isTransactionRequest_Command
- func (this *TransactionRequest_Commit) EqualVT(thatIface isTransactionRequest_Command) bool
- func (m *TransactionRequest_Commit) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionRequest_Commit) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionRequest_Commit) SizeVT() (n int)
- type TransactionRequest_ContinueList
- func (m *TransactionRequest_ContinueList) CloneVT() isTransactionRequest_Command
- func (this *TransactionRequest_ContinueList) EqualVT(thatIface isTransactionRequest_Command) bool
- func (m *TransactionRequest_ContinueList) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionRequest_ContinueList) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionRequest_ContinueList) SizeVT() (n int)
- type TransactionRequest_DeleteItems
- func (m *TransactionRequest_DeleteItems) CloneVT() isTransactionRequest_Command
- func (this *TransactionRequest_DeleteItems) EqualVT(thatIface isTransactionRequest_Command) bool
- func (m *TransactionRequest_DeleteItems) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionRequest_DeleteItems) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionRequest_DeleteItems) SizeVT() (n int)
- type TransactionRequest_GetItems
- func (m *TransactionRequest_GetItems) CloneVT() isTransactionRequest_Command
- func (this *TransactionRequest_GetItems) EqualVT(thatIface isTransactionRequest_Command) bool
- func (m *TransactionRequest_GetItems) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionRequest_GetItems) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionRequest_GetItems) SizeVT() (n int)
- type TransactionRequest_PutItems
- func (m *TransactionRequest_PutItems) CloneVT() isTransactionRequest_Command
- func (this *TransactionRequest_PutItems) EqualVT(thatIface isTransactionRequest_Command) bool
- func (m *TransactionRequest_PutItems) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionRequest_PutItems) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionRequest_PutItems) SizeVT() (n int)
- type TransactionResponse
- func (m *TransactionResponse) CloneMessageVT() proto.Message
- func (m *TransactionResponse) CloneVT() *TransactionResponse
- func (*TransactionResponse) Descriptor() ([]byte, []int)deprecated
- func (this *TransactionResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *TransactionResponse) EqualVT(that *TransactionResponse) bool
- func (x *TransactionResponse) GetAppendAck() *TransactionAppendAck
- func (x *TransactionResponse) GetFinished() *TransactionFinished
- func (x *TransactionResponse) GetGetResults() *TransactionGetResponse
- func (x *TransactionResponse) GetListResults() *TransactionListResponse
- func (x *TransactionResponse) GetMessageId() uint32
- func (m *TransactionResponse) GetResult() isTransactionResponse_Result
- func (m *TransactionResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionResponse) MarshalVT() (dAtA []byte, err error)
- func (*TransactionResponse) ProtoMessage()
- func (x *TransactionResponse) ProtoReflect() protoreflect.Message
- func (x *TransactionResponse) Reset()
- func (m *TransactionResponse) SizeVT() (n int)
- func (x *TransactionResponse) String() string
- func (m *TransactionResponse) UnmarshalVT(dAtA []byte) error
- type TransactionResponse_AppendAck
- func (m *TransactionResponse_AppendAck) CloneVT() isTransactionResponse_Result
- func (this *TransactionResponse_AppendAck) EqualVT(thatIface isTransactionResponse_Result) bool
- func (m *TransactionResponse_AppendAck) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionResponse_AppendAck) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionResponse_AppendAck) SizeVT() (n int)
- type TransactionResponse_Finished
- func (m *TransactionResponse_Finished) CloneVT() isTransactionResponse_Result
- func (this *TransactionResponse_Finished) EqualVT(thatIface isTransactionResponse_Result) bool
- func (m *TransactionResponse_Finished) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionResponse_Finished) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionResponse_Finished) SizeVT() (n int)
- type TransactionResponse_GetResults
- func (m *TransactionResponse_GetResults) CloneVT() isTransactionResponse_Result
- func (this *TransactionResponse_GetResults) EqualVT(thatIface isTransactionResponse_Result) bool
- func (m *TransactionResponse_GetResults) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionResponse_GetResults) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionResponse_GetResults) SizeVT() (n int)
- type TransactionResponse_ListResults
- func (m *TransactionResponse_ListResults) CloneVT() isTransactionResponse_Result
- func (this *TransactionResponse_ListResults) EqualVT(thatIface isTransactionResponse_Result) bool
- func (m *TransactionResponse_ListResults) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransactionResponse_ListResults) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransactionResponse_ListResults) SizeVT() (n int)
Constants ¶
This section is empty.
Variables ¶
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.
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.
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.
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.
var File_data_append_proto protoreflect.FileDescriptor
var File_data_continue_list_proto protoreflect.FileDescriptor
var File_data_delete_proto protoreflect.FileDescriptor
var File_data_get_proto protoreflect.FileDescriptor
var File_data_item_property_proto protoreflect.FileDescriptor
var File_data_item_proto protoreflect.FileDescriptor
var File_data_list_proto protoreflect.FileDescriptor
var File_data_list_token_proto protoreflect.FileDescriptor
var File_data_put_proto protoreflect.FileDescriptor
var File_data_scan_root_paths_proto protoreflect.FileDescriptor
var File_data_service_proto protoreflect.FileDescriptor
var File_data_sync_list_proto protoreflect.FileDescriptor
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) Descriptor() protoreflect.EnumDescriptor
func (AppendItem_IDAssignment) Enum ¶
func (x AppendItem_IDAssignment) Enum() *AppendItem_IDAssignment
func (AppendItem_IDAssignment) EnumDescriptor
deprecated
func (AppendItem_IDAssignment) EnumDescriptor() ([]byte, []int)
Deprecated: Use AppendItem_IDAssignment.Descriptor instead.
func (AppendItem_IDAssignment) Number ¶
func (x AppendItem_IDAssignment) Number() protoreflect.EnumNumber
func (AppendItem_IDAssignment) String ¶
func (x AppendItem_IDAssignment) String() string
func (AppendItem_IDAssignment) Type ¶
func (AppendItem_IDAssignment) Type() protoreflect.EnumType
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) Descriptor() protoreflect.EnumDescriptor
func (ContinueListDirection) Enum ¶
func (x ContinueListDirection) Enum() *ContinueListDirection
func (ContinueListDirection) EnumDescriptor
deprecated
func (ContinueListDirection) EnumDescriptor() ([]byte, []int)
Deprecated: Use ContinueListDirection.Descriptor instead.
func (ContinueListDirection) Number ¶
func (x ContinueListDirection) Number() protoreflect.EnumNumber
func (ContinueListDirection) String ¶
func (x ContinueListDirection) String() string
func (ContinueListDirection) Type ¶
func (ContinueListDirection) Type() protoreflect.EnumType
type ContinueListRequest ¶
type ContinueListRequest struct { // token_data is an opaque list continuation token returned by a previous call to // BeginList, ContinueList, or SyncList. TokenData []byte `protobuf:"bytes,1,opt,name=token_data,json=tokenData,proto3" json:"token_data,omitempty"` // direction indicates whether we are expanding the result set (paginating) // forward (in the direction of the original List operation) or backward (in // the opposite direction). The default is to expand forward. Direction ContinueListDirection `protobuf:"varint,2,opt,name=direction,proto3,enum=stately.ContinueListDirection" json:"direction,omitempty"` // contains filtered or unexported fields }
func (*ContinueListRequest) CloneMessageVT ¶
func (m *ContinueListRequest) CloneMessageVT() proto.Message
func (*ContinueListRequest) CloneVT ¶
func (m *ContinueListRequest) CloneVT() *ContinueListRequest
func (*ContinueListRequest) Descriptor
deprecated
func (*ContinueListRequest) Descriptor() ([]byte, []int)
Deprecated: Use ContinueListRequest.ProtoReflect.Descriptor instead.
func (*ContinueListRequest) EqualMessageVT ¶
func (this *ContinueListRequest) EqualMessageVT(thatMsg proto.Message) bool
func (*ContinueListRequest) EqualVT ¶
func (this *ContinueListRequest) EqualVT(that *ContinueListRequest) bool
func (*ContinueListRequest) GetDirection ¶
func (x *ContinueListRequest) GetDirection() ContinueListDirection
func (*ContinueListRequest) GetTokenData ¶
func (x *ContinueListRequest) GetTokenData() []byte
func (*ContinueListRequest) MarshalToSizedBufferVT ¶
func (m *ContinueListRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ContinueListRequest) MarshalToVT ¶
func (m *ContinueListRequest) MarshalToVT(dAtA []byte) (int, error)
func (*ContinueListRequest) MarshalVT ¶
func (m *ContinueListRequest) MarshalVT() (dAtA []byte, err error)
func (*ContinueListRequest) ProtoMessage ¶
func (*ContinueListRequest) ProtoMessage()
func (*ContinueListRequest) ProtoReflect ¶
func (x *ContinueListRequest) ProtoReflect() protoreflect.Message
func (*ContinueListRequest) Reset ¶
func (x *ContinueListRequest) Reset()
func (*ContinueListRequest) SizeVT ¶
func (m *ContinueListRequest) SizeVT() (n int)
func (*ContinueListRequest) String ¶
func (x *ContinueListRequest) String() string
func (*ContinueListRequest) UnmarshalVT ¶
func (m *ContinueListRequest) UnmarshalVT(dAtA []byte) error
type DeleteItem ¶
type DeleteItem struct { // key_path is the full path to the item. See Item#key_path for more details. KeyPath string `protobuf:"bytes,1,opt,name=key_path,json=keyPath,proto3" json:"key_path,omitempty"` // contains filtered or unexported fields }
func (*DeleteItem) CloneMessageVT ¶
func (m *DeleteItem) CloneMessageVT() proto.Message
func (*DeleteItem) CloneVT ¶
func (m *DeleteItem) CloneVT() *DeleteItem
func (*DeleteItem) Descriptor
deprecated
func (*DeleteItem) Descriptor() ([]byte, []int)
Deprecated: Use DeleteItem.ProtoReflect.Descriptor instead.
func (*DeleteItem) EqualMessageVT ¶
func (this *DeleteItem) EqualMessageVT(thatMsg proto.Message) bool
func (*DeleteItem) EqualVT ¶
func (this *DeleteItem) EqualVT(that *DeleteItem) bool
func (*DeleteItem) GetKeyPath ¶
func (x *DeleteItem) GetKeyPath() string
func (*DeleteItem) MarshalToSizedBufferVT ¶
func (m *DeleteItem) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*DeleteItem) MarshalToVT ¶
func (m *DeleteItem) MarshalToVT(dAtA []byte) (int, error)
func (*DeleteItem) MarshalVT ¶
func (m *DeleteItem) MarshalVT() (dAtA []byte, err error)
func (*DeleteItem) ProtoMessage ¶
func (*DeleteItem) ProtoMessage()
func (*DeleteItem) ProtoReflect ¶
func (x *DeleteItem) ProtoReflect() protoreflect.Message
func (*DeleteItem) Reset ¶
func (x *DeleteItem) Reset()
func (*DeleteItem) SizeVT ¶
func (m *DeleteItem) SizeVT() (n int)
func (*DeleteItem) String ¶
func (x *DeleteItem) String() string
func (*DeleteItem) UnmarshalVT ¶
func (m *DeleteItem) UnmarshalVT(dAtA []byte) error
type DeleteRequest ¶
type DeleteRequest struct { // store_id is a globally unique Store ID, which can be looked up from the // console or CLI. StoreId uint64 `protobuf:"varint,1,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"` // deletes is one or more items to be deleted from the Group. Deletes []*DeleteItem `protobuf:"bytes,3,rep,name=deletes,proto3" json:"deletes,omitempty"` // 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 (*GetItem) Descriptor
deprecated
func (*GetItem) GetKeyPath ¶
func (*GetItem) MarshalToSizedBufferVT ¶
func (*GetItem) ProtoMessage ¶
func (*GetItem) ProtoMessage()
func (*GetItem) ProtoReflect ¶
func (x *GetItem) ProtoReflect() protoreflect.Message
func (*GetItem) UnmarshalVT ¶
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 (*Item) Descriptor
deprecated
func (*Item) GetKeyPath ¶
func (*Item) GetMetadata ¶
func (x *Item) GetMetadata() *ItemMetadata
func (*Item) MarshalToSizedBufferVT ¶
func (*Item) ProtoMessage ¶
func (*Item) ProtoMessage()
func (*Item) ProtoReflect ¶
func (x *Item) ProtoReflect() protoreflect.Message
func (*Item) UnmarshalVT ¶
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 (*ListToken) Descriptor
deprecated
func (*ListToken) EqualMessageVT ¶
func (*ListToken) GetCanContinue ¶
func (*ListToken) GetCanSync ¶
func (*ListToken) GetTokenData ¶
func (*ListToken) MarshalToSizedBufferVT ¶
func (*ListToken) ProtoMessage ¶
func (*ListToken) ProtoMessage()
func (*ListToken) ProtoReflect ¶
func (x *ListToken) ProtoReflect() protoreflect.Message
func (*ListToken) UnmarshalVT ¶
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 (*PutItem) Descriptor
deprecated
func (*PutItem) MarshalToSizedBufferVT ¶
func (*PutItem) ProtoMessage ¶
func (*PutItem) ProtoMessage()
func (*PutItem) ProtoReflect ¶
func (x *PutItem) ProtoReflect() protoreflect.Message
func (*PutItem) UnmarshalVT ¶
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 (*PutResult) Descriptor
deprecated
func (*PutResult) EqualMessageVT ¶
func (*PutResult) GetError ¶
func (x *PutResult) GetError() *common.OperationError
func (*PutResult) GetKeyPath ¶
func (*PutResult) GetMetadata ¶
func (x *PutResult) GetMetadata() *ItemMetadata
func (*PutResult) MarshalToSizedBufferVT ¶
func (*PutResult) ProtoMessage ¶
func (*PutResult) ProtoMessage()
func (*PutResult) ProtoReflect ¶
func (x *PutResult) ProtoReflect() protoreflect.Message
func (*PutResult) UnmarshalVT ¶
type ScanRootPathResult ¶
type ScanRootPathResult struct { // key_path is a single root key path. Users can Query by this root path to // get all of the items under it. KeyPath string `protobuf:"bytes,1,opt,name=key_path,json=keyPath,proto3" json:"key_path,omitempty"` // contains filtered or unexported fields }
func (*ScanRootPathResult) CloneMessageVT ¶
func (m *ScanRootPathResult) CloneMessageVT() proto.Message
func (*ScanRootPathResult) CloneVT ¶
func (m *ScanRootPathResult) CloneVT() *ScanRootPathResult
func (*ScanRootPathResult) Descriptor
deprecated
func (*ScanRootPathResult) Descriptor() ([]byte, []int)
Deprecated: Use ScanRootPathResult.ProtoReflect.Descriptor instead.
func (*ScanRootPathResult) EqualMessageVT ¶
func (this *ScanRootPathResult) EqualMessageVT(thatMsg proto.Message) bool
func (*ScanRootPathResult) EqualVT ¶
func (this *ScanRootPathResult) EqualVT(that *ScanRootPathResult) bool
func (*ScanRootPathResult) GetKeyPath ¶
func (x *ScanRootPathResult) GetKeyPath() string
func (*ScanRootPathResult) MarshalToSizedBufferVT ¶
func (m *ScanRootPathResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ScanRootPathResult) MarshalToVT ¶
func (m *ScanRootPathResult) MarshalToVT(dAtA []byte) (int, error)
func (*ScanRootPathResult) MarshalVT ¶
func (m *ScanRootPathResult) MarshalVT() (dAtA []byte, err error)
func (*ScanRootPathResult) ProtoMessage ¶
func (*ScanRootPathResult) ProtoMessage()
func (*ScanRootPathResult) ProtoReflect ¶
func (x *ScanRootPathResult) ProtoReflect() protoreflect.Message
func (*ScanRootPathResult) Reset ¶
func (x *ScanRootPathResult) Reset()
func (*ScanRootPathResult) SizeVT ¶
func (m *ScanRootPathResult) SizeVT() (n int)
func (*ScanRootPathResult) String ¶
func (x *ScanRootPathResult) String() string
func (*ScanRootPathResult) UnmarshalVT ¶
func (m *ScanRootPathResult) UnmarshalVT(dAtA []byte) error
type ScanRootPathsRequest ¶
type ScanRootPathsRequest struct { // store_id is a globally unique Store ID, which can be looked up from the // console or CLI. StoreId uint64 `protobuf:"varint,1,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"` // Limit sets an upper bound on how many root paths to return. Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` // pagination_token is an optional token to continue retrieving the next page of results. // This value must be read from a ScanRootPathsResponse and passed with a clone of the // previous request to fetch the next page of data PaginationToken []byte `protobuf:"bytes,3,opt,name=pagination_token,json=paginationToken,proto3" json:"pagination_token,omitempty"` // contains filtered or unexported fields }
func (*ScanRootPathsRequest) CloneMessageVT ¶
func (m *ScanRootPathsRequest) CloneMessageVT() proto.Message
func (*ScanRootPathsRequest) CloneVT ¶
func (m *ScanRootPathsRequest) CloneVT() *ScanRootPathsRequest
func (*ScanRootPathsRequest) Descriptor
deprecated
func (*ScanRootPathsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ScanRootPathsRequest.ProtoReflect.Descriptor instead.
func (*ScanRootPathsRequest) EqualMessageVT ¶
func (this *ScanRootPathsRequest) EqualMessageVT(thatMsg proto.Message) bool
func (*ScanRootPathsRequest) EqualVT ¶
func (this *ScanRootPathsRequest) EqualVT(that *ScanRootPathsRequest) bool
func (*ScanRootPathsRequest) GetLimit ¶
func (x *ScanRootPathsRequest) GetLimit() uint32
func (*ScanRootPathsRequest) GetPaginationToken ¶
func (x *ScanRootPathsRequest) GetPaginationToken() []byte
func (*ScanRootPathsRequest) GetStoreId ¶
func (x *ScanRootPathsRequest) GetStoreId() uint64
func (*ScanRootPathsRequest) MarshalToSizedBufferVT ¶
func (m *ScanRootPathsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ScanRootPathsRequest) MarshalToVT ¶
func (m *ScanRootPathsRequest) MarshalToVT(dAtA []byte) (int, error)
func (*ScanRootPathsRequest) MarshalVT ¶
func (m *ScanRootPathsRequest) MarshalVT() (dAtA []byte, err error)
func (*ScanRootPathsRequest) ProtoMessage ¶
func (*ScanRootPathsRequest) ProtoMessage()
func (*ScanRootPathsRequest) ProtoReflect ¶
func (x *ScanRootPathsRequest) ProtoReflect() protoreflect.Message
func (*ScanRootPathsRequest) Reset ¶
func (x *ScanRootPathsRequest) Reset()
func (*ScanRootPathsRequest) SizeVT ¶
func (m *ScanRootPathsRequest) SizeVT() (n int)
func (*ScanRootPathsRequest) String ¶
func (x *ScanRootPathsRequest) String() string
func (*ScanRootPathsRequest) UnmarshalVT ¶
func (m *ScanRootPathsRequest) UnmarshalVT(dAtA []byte) error
type ScanRootPathsResponse ¶
type ScanRootPathsResponse struct { // results is a list that contains one entry for each root path that was found. Results []*ScanRootPathResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"` // This field is optional and will be set if there are more query results to fetch. // To fetch the next page of results you must make the exact same ScanRootPathsRequest as before // but set ScanRootPathsRequest.pagination_token to the value returned here. PaginationToken []byte `protobuf:"bytes,2,opt,name=pagination_token,json=paginationToken,proto3" json:"pagination_token,omitempty"` // contains filtered or unexported fields }
func (*ScanRootPathsResponse) CloneMessageVT ¶
func (m *ScanRootPathsResponse) CloneMessageVT() proto.Message
func (*ScanRootPathsResponse) CloneVT ¶
func (m *ScanRootPathsResponse) CloneVT() *ScanRootPathsResponse
func (*ScanRootPathsResponse) Descriptor
deprecated
func (*ScanRootPathsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ScanRootPathsResponse.ProtoReflect.Descriptor instead.
func (*ScanRootPathsResponse) EqualMessageVT ¶
func (this *ScanRootPathsResponse) EqualMessageVT(thatMsg proto.Message) bool
func (*ScanRootPathsResponse) EqualVT ¶
func (this *ScanRootPathsResponse) EqualVT(that *ScanRootPathsResponse) bool
func (*ScanRootPathsResponse) GetPaginationToken ¶
func (x *ScanRootPathsResponse) GetPaginationToken() []byte
func (*ScanRootPathsResponse) GetResults ¶
func (x *ScanRootPathsResponse) GetResults() []*ScanRootPathResult
func (*ScanRootPathsResponse) MarshalToSizedBufferVT ¶
func (m *ScanRootPathsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ScanRootPathsResponse) MarshalToVT ¶
func (m *ScanRootPathsResponse) MarshalToVT(dAtA []byte) (int, error)
func (*ScanRootPathsResponse) MarshalVT ¶
func (m *ScanRootPathsResponse) MarshalVT() (dAtA []byte, err error)
func (*ScanRootPathsResponse) ProtoMessage ¶
func (*ScanRootPathsResponse) ProtoMessage()
func (*ScanRootPathsResponse) ProtoReflect ¶
func (x *ScanRootPathsResponse) ProtoReflect() protoreflect.Message
func (*ScanRootPathsResponse) Reset ¶
func (x *ScanRootPathsResponse) Reset()
func (*ScanRootPathsResponse) SizeVT ¶
func (m *ScanRootPathsResponse) SizeVT() (n int)
func (*ScanRootPathsResponse) String ¶
func (x *ScanRootPathsResponse) String() string
func (*ScanRootPathsResponse) UnmarshalVT ¶
func (m *ScanRootPathsResponse) UnmarshalVT(dAtA []byte) error
type SortDirection ¶
type SortDirection int32
SortDirection represents the direction of iteration.
const ( SortDirection_SORT_ASCENDING SortDirection = 0 // This is the default SortDirection_SORT_DESCENDING SortDirection = 1 )
func (SortDirection) Descriptor ¶
func (SortDirection) Descriptor() protoreflect.EnumDescriptor
func (SortDirection) Enum ¶
func (x SortDirection) Enum() *SortDirection
func (SortDirection) EnumDescriptor
deprecated
func (SortDirection) EnumDescriptor() ([]byte, []int)
Deprecated: Use SortDirection.Descriptor instead.
func (SortDirection) Number ¶
func (x SortDirection) Number() protoreflect.EnumNumber
func (SortDirection) String ¶
func (x SortDirection) String() string
func (SortDirection) Type ¶
func (SortDirection) Type() protoreflect.EnumType
type SortableProperty ¶
type SortableProperty int32
SortableProperty is used to reference a sortable (i.e. locally indexed) property within an item. These properties are either built in, or they must be explicitly declared in the schema / store config so they can be populated when items are written/updated.
const ( // SORTABLE_PROPERTY_KEY_PATH is the full key path of the item. This is the // default sort property if none is specified. TODO: Document how these are ordered. SortableProperty_SORTABLE_PROPERTY_KEY_PATH SortableProperty = 0 // SORTABLE_PROPERTY_LAST_MODIFIED_VERSION sorts by the last modified version // of the items, with ascending order being from oldest to newest. This is // only available if the store / item is configured to track last modified // versions. SortableProperty_SORTABLE_PROPERTY_LAST_MODIFIED_VERSION SortableProperty = 1 // SORTABLE_PROPERTY_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) Descriptor() protoreflect.EnumDescriptor
func (SortableProperty) Enum ¶
func (x SortableProperty) Enum() *SortableProperty
func (SortableProperty) EnumDescriptor
deprecated
func (SortableProperty) EnumDescriptor() ([]byte, []int)
Deprecated: Use SortableProperty.Descriptor instead.
func (SortableProperty) Number ¶
func (x SortableProperty) Number() protoreflect.EnumNumber
func (SortableProperty) String ¶
func (x SortableProperty) String() string
func (SortableProperty) Type ¶
func (SortableProperty) Type() protoreflect.EnumType
type SyncListPartialResponse ¶
type SyncListPartialResponse struct { // Items in the token window that were added or updated since the last // sync/list. ChangedItems []*Item `protobuf:"bytes,1,rep,name=changed_items,json=changedItems,proto3" json:"changed_items,omitempty"` // Items in the token window that were deleted since the last sync/list. DeletedItems []*DeletedItem `protobuf:"bytes,2,rep,name=deleted_items,json=deletedItems,proto3" json:"deleted_items,omitempty"` // Items that were changed but which do not currently use the CustomSortProperty // that the list window is based on. This can only be populated when using a // CustomSortProperty (in the original BeginList request). // It may be that these items have never been in the CustomSortProperty, // or that they were in the CustomSortProperty at some point in time but are not now, // or that they are in the CustomSortProperty but have moved position and are no longer // in the sync able window identified by a token. UpdatedItemKeysOutsideListWindow []string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*SyncListPartialResponse) CloneMessageVT ¶
func (m *SyncListPartialResponse) CloneMessageVT() proto.Message
func (*SyncListPartialResponse) CloneVT ¶
func (m *SyncListPartialResponse) CloneVT() *SyncListPartialResponse
func (*SyncListPartialResponse) Descriptor
deprecated
func (*SyncListPartialResponse) Descriptor() ([]byte, []int)
Deprecated: Use SyncListPartialResponse.ProtoReflect.Descriptor instead.
func (*SyncListPartialResponse) EqualMessageVT ¶
func (this *SyncListPartialResponse) EqualMessageVT(thatMsg proto.Message) bool
func (*SyncListPartialResponse) EqualVT ¶
func (this *SyncListPartialResponse) EqualVT(that *SyncListPartialResponse) bool
func (*SyncListPartialResponse) GetChangedItems ¶
func (x *SyncListPartialResponse) GetChangedItems() []*Item
func (*SyncListPartialResponse) GetDeletedItems ¶
func (x *SyncListPartialResponse) GetDeletedItems() []*DeletedItem
func (*SyncListPartialResponse) GetUpdatedItemKeysOutsideListWindow ¶
func (x *SyncListPartialResponse) GetUpdatedItemKeysOutsideListWindow() []string
func (*SyncListPartialResponse) MarshalToSizedBufferVT ¶
func (m *SyncListPartialResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*SyncListPartialResponse) MarshalToVT ¶
func (m *SyncListPartialResponse) MarshalToVT(dAtA []byte) (int, error)
func (*SyncListPartialResponse) MarshalVT ¶
func (m *SyncListPartialResponse) MarshalVT() (dAtA []byte, err error)
func (*SyncListPartialResponse) ProtoMessage ¶
func (*SyncListPartialResponse) ProtoMessage()
func (*SyncListPartialResponse) ProtoReflect ¶
func (x *SyncListPartialResponse) ProtoReflect() protoreflect.Message
func (*SyncListPartialResponse) Reset ¶
func (x *SyncListPartialResponse) Reset()
func (*SyncListPartialResponse) SizeVT ¶
func (m *SyncListPartialResponse) SizeVT() (n int)
func (*SyncListPartialResponse) String ¶
func (x *SyncListPartialResponse) String() string
func (*SyncListPartialResponse) UnmarshalVT ¶
func (m *SyncListPartialResponse) UnmarshalVT(dAtA []byte) error
type SyncListRequest ¶
type SyncListRequest struct { // token_data is an opaque list continuation token returned by a previous call to // List, ContinueList, or SyncList. TokenData []byte `protobuf:"bytes,1,opt,name=token_data,json=tokenData,proto3" json:"token_data,omitempty"` // contains filtered or unexported fields }
func (*SyncListRequest) CloneMessageVT ¶
func (m *SyncListRequest) CloneMessageVT() proto.Message
func (*SyncListRequest) CloneVT ¶
func (m *SyncListRequest) CloneVT() *SyncListRequest
func (*SyncListRequest) Descriptor
deprecated
func (*SyncListRequest) Descriptor() ([]byte, []int)
Deprecated: Use SyncListRequest.ProtoReflect.Descriptor instead.
func (*SyncListRequest) EqualMessageVT ¶
func (this *SyncListRequest) EqualMessageVT(thatMsg proto.Message) bool
func (*SyncListRequest) EqualVT ¶
func (this *SyncListRequest) EqualVT(that *SyncListRequest) bool
func (*SyncListRequest) GetTokenData ¶
func (x *SyncListRequest) GetTokenData() []byte
func (*SyncListRequest) MarshalToSizedBufferVT ¶
func (m *SyncListRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*SyncListRequest) MarshalToVT ¶
func (m *SyncListRequest) MarshalToVT(dAtA []byte) (int, error)
func (*SyncListRequest) MarshalVT ¶
func (m *SyncListRequest) MarshalVT() (dAtA []byte, err error)
func (*SyncListRequest) ProtoMessage ¶
func (*SyncListRequest) ProtoMessage()
func (*SyncListRequest) ProtoReflect ¶
func (x *SyncListRequest) ProtoReflect() protoreflect.Message
func (*SyncListRequest) Reset ¶
func (x *SyncListRequest) Reset()
func (*SyncListRequest) SizeVT ¶
func (m *SyncListRequest) SizeVT() (n int)
func (*SyncListRequest) String ¶
func (x *SyncListRequest) String() string
func (*SyncListRequest) UnmarshalVT ¶
func (m *SyncListRequest) UnmarshalVT(dAtA []byte) error
type SyncListReset ¶
type SyncListReset struct {
// contains filtered or unexported fields
}
SyncListReset is returned if the provided token is too far behind to be able to report deleted items, and subsequent results will start over with a fresh result set. Clients should discard any cached data from this result set and start re-populating it.
func (*SyncListReset) CloneMessageVT ¶
func (m *SyncListReset) CloneMessageVT() proto.Message
func (*SyncListReset) CloneVT ¶
func (m *SyncListReset) CloneVT() *SyncListReset
func (*SyncListReset) Descriptor
deprecated
func (*SyncListReset) Descriptor() ([]byte, []int)
Deprecated: Use SyncListReset.ProtoReflect.Descriptor instead.
func (*SyncListReset) EqualMessageVT ¶
func (this *SyncListReset) EqualMessageVT(thatMsg proto.Message) bool
func (*SyncListReset) EqualVT ¶
func (this *SyncListReset) EqualVT(that *SyncListReset) bool
func (*SyncListReset) MarshalToSizedBufferVT ¶
func (m *SyncListReset) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*SyncListReset) MarshalToVT ¶
func (m *SyncListReset) MarshalToVT(dAtA []byte) (int, error)
func (*SyncListReset) MarshalVT ¶
func (m *SyncListReset) MarshalVT() (dAtA []byte, err error)
func (*SyncListReset) ProtoMessage ¶
func (*SyncListReset) ProtoMessage()
func (*SyncListReset) ProtoReflect ¶
func (x *SyncListReset) ProtoReflect() protoreflect.Message
func (*SyncListReset) Reset ¶
func (x *SyncListReset) Reset()
func (*SyncListReset) SizeVT ¶
func (m *SyncListReset) SizeVT() (n int)
func (*SyncListReset) String ¶
func (x *SyncListReset) String() string
func (*SyncListReset) UnmarshalVT ¶
func (m *SyncListReset) UnmarshalVT(dAtA []byte) error
type SyncListResponse ¶
type SyncListResponse struct { // Types that are assignable to Response: // // *SyncListResponse_Reset_ // *SyncListResponse_Result // *SyncListResponse_Finished Response isSyncListResponse_Response `protobuf_oneof:"response"` // contains filtered or unexported fields }
These are stream messages, so multiple responses may be sent.
func (*SyncListResponse) CloneMessageVT ¶
func (m *SyncListResponse) CloneMessageVT() proto.Message
func (*SyncListResponse) CloneVT ¶
func (m *SyncListResponse) CloneVT() *SyncListResponse
func (*SyncListResponse) Descriptor
deprecated
func (*SyncListResponse) Descriptor() ([]byte, []int)
Deprecated: Use SyncListResponse.ProtoReflect.Descriptor instead.
func (*SyncListResponse) EqualMessageVT ¶
func (this *SyncListResponse) EqualMessageVT(thatMsg proto.Message) bool
func (*SyncListResponse) EqualVT ¶
func (this *SyncListResponse) EqualVT(that *SyncListResponse) bool
func (*SyncListResponse) GetFinished ¶
func (x *SyncListResponse) GetFinished() *ListFinished
func (*SyncListResponse) GetReset_ ¶
func (x *SyncListResponse) GetReset_() *SyncListReset
func (*SyncListResponse) GetResponse ¶
func (m *SyncListResponse) GetResponse() isSyncListResponse_Response
func (*SyncListResponse) GetResult ¶
func (x *SyncListResponse) GetResult() *SyncListPartialResponse
func (*SyncListResponse) MarshalToSizedBufferVT ¶
func (m *SyncListResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*SyncListResponse) MarshalToVT ¶
func (m *SyncListResponse) MarshalToVT(dAtA []byte) (int, error)
func (*SyncListResponse) MarshalVT ¶
func (m *SyncListResponse) MarshalVT() (dAtA []byte, err error)
func (*SyncListResponse) ProtoMessage ¶
func (*SyncListResponse) ProtoMessage()
func (*SyncListResponse) ProtoReflect ¶
func (x *SyncListResponse) ProtoReflect() protoreflect.Message
func (*SyncListResponse) Reset ¶
func (x *SyncListResponse) Reset()
func (*SyncListResponse) SizeVT ¶
func (m *SyncListResponse) SizeVT() (n int)
func (*SyncListResponse) String ¶
func (x *SyncListResponse) String() string
func (*SyncListResponse) UnmarshalVT ¶
func (m *SyncListResponse) UnmarshalVT(dAtA []byte) error
type SyncListResponse_Finished ¶
type SyncListResponse_Finished struct { // Finished is sent when the sync is complete, and there will only be one. Finished *ListFinished `protobuf:"bytes,3,opt,name=finished,proto3,oneof"` }
func (*SyncListResponse_Finished) CloneVT ¶
func (m *SyncListResponse_Finished) CloneVT() isSyncListResponse_Response
func (*SyncListResponse_Finished) EqualVT ¶
func (this *SyncListResponse_Finished) EqualVT(thatIface isSyncListResponse_Response) bool
func (*SyncListResponse_Finished) MarshalToSizedBufferVT ¶
func (m *SyncListResponse_Finished) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*SyncListResponse_Finished) MarshalToVT ¶
func (m *SyncListResponse_Finished) MarshalToVT(dAtA []byte) (int, error)
func (*SyncListResponse_Finished) SizeVT ¶
func (m *SyncListResponse_Finished) SizeVT() (n int)
type SyncListResponse_Reset_ ¶
type SyncListResponse_Reset_ struct { // SyncListReset is returned if the provided token is too far behind to be able to // report deleted items, and subsequent results will start over with a fresh result // set. Clients should discard any cached data from this result set and start re-populating it. Reset_ *SyncListReset `protobuf:"bytes,1,opt,name=reset,proto3,oneof"` }
func (*SyncListResponse_Reset_) CloneVT ¶
func (m *SyncListResponse_Reset_) CloneVT() isSyncListResponse_Response
func (*SyncListResponse_Reset_) EqualVT ¶
func (this *SyncListResponse_Reset_) EqualVT(thatIface isSyncListResponse_Response) bool
func (*SyncListResponse_Reset_) MarshalToSizedBufferVT ¶
func (m *SyncListResponse_Reset_) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*SyncListResponse_Reset_) MarshalToVT ¶
func (m *SyncListResponse_Reset_) MarshalToVT(dAtA []byte) (int, error)
func (*SyncListResponse_Reset_) SizeVT ¶
func (m *SyncListResponse_Reset_) SizeVT() (n int)
type SyncListResponse_Result ¶
type SyncListResponse_Result struct { // Result is a segment of sync results - multiple of these may be returned. Result *SyncListPartialResponse `protobuf:"bytes,2,opt,name=result,proto3,oneof"` }
func (*SyncListResponse_Result) CloneVT ¶
func (m *SyncListResponse_Result) CloneVT() isSyncListResponse_Response
func (*SyncListResponse_Result) EqualVT ¶
func (this *SyncListResponse_Result) EqualVT(thatIface isSyncListResponse_Response) bool
func (*SyncListResponse_Result) MarshalToSizedBufferVT ¶
func (m *SyncListResponse_Result) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*SyncListResponse_Result) MarshalToVT ¶
func (m *SyncListResponse_Result) MarshalToVT(dAtA []byte) (int, error)
func (*SyncListResponse_Result) SizeVT ¶
func (m *SyncListResponse_Result) SizeVT() (n int)
type 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 (m *TransactionAppendAck) CloneVT() *TransactionAppendAck
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 (m *TransactionBeginList) CloneVT() *TransactionBeginList
func (*TransactionBeginList) Descriptor
deprecated
func (*TransactionBeginList) Descriptor() ([]byte, []int)
Deprecated: Use TransactionBeginList.ProtoReflect.Descriptor instead.
func (*TransactionBeginList) EqualMessageVT ¶
func (this *TransactionBeginList) EqualMessageVT(thatMsg proto.Message) bool
func (*TransactionBeginList) EqualVT ¶
func (this *TransactionBeginList) EqualVT(that *TransactionBeginList) bool
func (*TransactionBeginList) GetKeyPathPrefix ¶
func (x *TransactionBeginList) GetKeyPathPrefix() string
func (*TransactionBeginList) GetLimit ¶
func (x *TransactionBeginList) GetLimit() uint32
func (*TransactionBeginList) GetSortDirection ¶
func (x *TransactionBeginList) GetSortDirection() SortDirection
func (*TransactionBeginList) GetSortProperty ¶
func (x *TransactionBeginList) GetSortProperty() SortableProperty
func (*TransactionBeginList) MarshalToSizedBufferVT ¶
func (m *TransactionBeginList) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*TransactionBeginList) MarshalToVT ¶
func (m *TransactionBeginList) MarshalToVT(dAtA []byte) (int, error)
func (*TransactionBeginList) MarshalVT ¶
func (m *TransactionBeginList) MarshalVT() (dAtA []byte, err error)
func (*TransactionBeginList) ProtoMessage ¶
func (*TransactionBeginList) ProtoMessage()
func (*TransactionBeginList) ProtoReflect ¶
func (x *TransactionBeginList) ProtoReflect() protoreflect.Message
func (*TransactionBeginList) Reset ¶
func (x *TransactionBeginList) Reset()
func (*TransactionBeginList) SizeVT ¶
func (m *TransactionBeginList) SizeVT() (n int)
func (*TransactionBeginList) String ¶
func (x *TransactionBeginList) String() string
func (*TransactionBeginList) UnmarshalVT ¶
func (m *TransactionBeginList) UnmarshalVT(dAtA []byte) error
type TransactionContinueList ¶
type TransactionContinueList struct { // token is an opaque list continuation token returned by a previous call to // TransactionBeginList or TransactionContinueList. TokenData []byte `protobuf:"bytes,1,opt,name=token_data,json=tokenData,proto3" json:"token_data,omitempty"` // direction indicates whether we are expanding the result set (paginating) // forward (in the direction of the original List operation) or backward (in // the opposite direction). The default is to expand forward. Direction ContinueListDirection `protobuf:"varint,4,opt,name=direction,proto3,enum=stately.ContinueListDirection" json:"direction,omitempty"` // contains filtered or unexported fields }
func (*TransactionContinueList) CloneMessageVT ¶
func (m *TransactionContinueList) CloneMessageVT() proto.Message
func (*TransactionContinueList) CloneVT ¶
func (m *TransactionContinueList) CloneVT() *TransactionContinueList
func (*TransactionContinueList) Descriptor
deprecated
func (*TransactionContinueList) Descriptor() ([]byte, []int)
Deprecated: Use TransactionContinueList.ProtoReflect.Descriptor instead.
func (*TransactionContinueList) EqualMessageVT ¶
func (this *TransactionContinueList) EqualMessageVT(thatMsg proto.Message) bool
func (*TransactionContinueList) EqualVT ¶
func (this *TransactionContinueList) EqualVT(that *TransactionContinueList) bool
func (*TransactionContinueList) GetDirection ¶
func (x *TransactionContinueList) GetDirection() ContinueListDirection
func (*TransactionContinueList) GetTokenData ¶
func (x *TransactionContinueList) GetTokenData() []byte
func (*TransactionContinueList) MarshalToSizedBufferVT ¶
func (m *TransactionContinueList) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*TransactionContinueList) MarshalToVT ¶
func (m *TransactionContinueList) MarshalToVT(dAtA []byte) (int, error)
func (*TransactionContinueList) MarshalVT ¶
func (m *TransactionContinueList) MarshalVT() (dAtA []byte, err error)
func (*TransactionContinueList) ProtoMessage ¶
func (*TransactionContinueList) ProtoMessage()
func (*TransactionContinueList) ProtoReflect ¶
func (x *TransactionContinueList) ProtoReflect() protoreflect.Message
func (*TransactionContinueList) Reset ¶
func (x *TransactionContinueList) Reset()
func (*TransactionContinueList) SizeVT ¶
func (m *TransactionContinueList) SizeVT() (n int)
func (*TransactionContinueList) String ¶
func (x *TransactionContinueList) String() string
func (*TransactionContinueList) UnmarshalVT ¶
func (m *TransactionContinueList) UnmarshalVT(dAtA []byte) error
type TransactionDelete ¶
type TransactionDelete struct { // deletes is one or more items to be deleted from the Group. Deletes []*DeleteItem `protobuf:"bytes,1,rep,name=deletes,proto3" json:"deletes,omitempty"` // contains filtered or unexported fields }
TransactionDelete is a subset of the DeleteRequest message, for performing deletes within the context of a transaction. These will not be acknowledged until the transaction is finished.
func (*TransactionDelete) CloneMessageVT ¶
func (m *TransactionDelete) CloneMessageVT() proto.Message
func (*TransactionDelete) CloneVT ¶
func (m *TransactionDelete) CloneVT() *TransactionDelete
func (*TransactionDelete) Descriptor
deprecated
func (*TransactionDelete) Descriptor() ([]byte, []int)
Deprecated: Use TransactionDelete.ProtoReflect.Descriptor instead.
func (*TransactionDelete) EqualMessageVT ¶
func (this *TransactionDelete) EqualMessageVT(thatMsg proto.Message) bool
func (*TransactionDelete) EqualVT ¶
func (this *TransactionDelete) EqualVT(that *TransactionDelete) bool
func (*TransactionDelete) GetDeletes ¶
func (x *TransactionDelete) GetDeletes() []*DeleteItem
func (*TransactionDelete) MarshalToSizedBufferVT ¶
func (m *TransactionDelete) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*TransactionDelete) MarshalToVT ¶
func (m *TransactionDelete) MarshalToVT(dAtA []byte) (int, error)
func (*TransactionDelete) MarshalVT ¶
func (m *TransactionDelete) MarshalVT() (dAtA []byte, err error)
func (*TransactionDelete) ProtoMessage ¶
func (*TransactionDelete) ProtoMessage()
func (*TransactionDelete) ProtoReflect ¶
func (x *TransactionDelete) ProtoReflect() protoreflect.Message
func (*TransactionDelete) Reset ¶
func (x *TransactionDelete) Reset()
func (*TransactionDelete) SizeVT ¶
func (m *TransactionDelete) SizeVT() (n int)
func (*TransactionDelete) String ¶
func (x *TransactionDelete) String() string
func (*TransactionDelete) UnmarshalVT ¶
func (m *TransactionDelete) UnmarshalVT(dAtA []byte) error
type TransactionFinished ¶
type TransactionFinished struct { // Did the commit finish (the alternative is that it was aborted/rolled back) Committed bool `protobuf:"varint,1,opt,name=committed,proto3" json:"committed,omitempty"` // put_results contains the full result of each Put operation. This only comes // back with the TransactionFinished message because full metadata isn't // available until then. PutResults []*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 (m *TransactionFinished) CloneVT() *TransactionFinished
func (*TransactionFinished) Descriptor
deprecated
func (*TransactionFinished) Descriptor() ([]byte, []int)
Deprecated: Use TransactionFinished.ProtoReflect.Descriptor instead.
func (*TransactionFinished) EqualMessageVT ¶
func (this *TransactionFinished) EqualMessageVT(thatMsg proto.Message) bool
func (*TransactionFinished) EqualVT ¶
func (this *TransactionFinished) EqualVT(that *TransactionFinished) bool
func (*TransactionFinished) 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 (m *TransactionGetResponse) CloneVT() *TransactionGetResponse
func (*TransactionGetResponse) Descriptor
deprecated
func (*TransactionGetResponse) Descriptor() ([]byte, []int)
Deprecated: Use TransactionGetResponse.ProtoReflect.Descriptor instead.
func (*TransactionGetResponse) EqualMessageVT ¶
func (this *TransactionGetResponse) EqualMessageVT(thatMsg proto.Message) bool
func (*TransactionGetResponse) EqualVT ¶
func (this *TransactionGetResponse) EqualVT(that *TransactionGetResponse) bool
func (*TransactionGetResponse) GetItems ¶
func (x *TransactionGetResponse) GetItems() []*Item
func (*TransactionGetResponse) MarshalToSizedBufferVT ¶
func (m *TransactionGetResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*TransactionGetResponse) MarshalToVT ¶
func (m *TransactionGetResponse) MarshalToVT(dAtA []byte) (int, error)
func (*TransactionGetResponse) MarshalVT ¶
func (m *TransactionGetResponse) MarshalVT() (dAtA []byte, err error)
func (*TransactionGetResponse) ProtoMessage ¶
func (*TransactionGetResponse) ProtoMessage()
func (*TransactionGetResponse) ProtoReflect ¶
func (x *TransactionGetResponse) ProtoReflect() protoreflect.Message
func (*TransactionGetResponse) Reset ¶
func (x *TransactionGetResponse) Reset()
func (*TransactionGetResponse) SizeVT ¶
func (m *TransactionGetResponse) SizeVT() (n int)
func (*TransactionGetResponse) String ¶
func (x *TransactionGetResponse) String() string
func (*TransactionGetResponse) UnmarshalVT ¶
func (m *TransactionGetResponse) UnmarshalVT(dAtA []byte) error
type TransactionListResponse ¶
type TransactionListResponse struct { // Types that are assignable to Response: // // *TransactionListResponse_Result // *TransactionListResponse_Finished Response isTransactionListResponse_Response `protobuf_oneof:"response"` // contains filtered or unexported fields }
TransactionListResponse is a subset of the ListResponse message, for returning results during the execution of a transaction.
func (*TransactionListResponse) CloneMessageVT ¶
func (m *TransactionListResponse) CloneMessageVT() proto.Message
func (*TransactionListResponse) CloneVT ¶
func (m *TransactionListResponse) CloneVT() *TransactionListResponse
func (*TransactionListResponse) Descriptor
deprecated
func (*TransactionListResponse) Descriptor() ([]byte, []int)
Deprecated: Use TransactionListResponse.ProtoReflect.Descriptor instead.
func (*TransactionListResponse) EqualMessageVT ¶
func (this *TransactionListResponse) EqualMessageVT(thatMsg proto.Message) bool
func (*TransactionListResponse) EqualVT ¶
func (this *TransactionListResponse) EqualVT(that *TransactionListResponse) bool
func (*TransactionListResponse) GetFinished ¶
func (x *TransactionListResponse) GetFinished() *ListFinished
func (*TransactionListResponse) 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 (x *TransactionListResponse) GetResult() *ListPartialResult
func (*TransactionListResponse) MarshalToSizedBufferVT ¶
func (m *TransactionListResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*TransactionListResponse) MarshalToVT ¶
func (m *TransactionListResponse) MarshalToVT(dAtA []byte) (int, error)
func (*TransactionListResponse) MarshalVT ¶
func (m *TransactionListResponse) MarshalVT() (dAtA []byte, err error)
func (*TransactionListResponse) ProtoMessage ¶
func (*TransactionListResponse) ProtoMessage()
func (*TransactionListResponse) ProtoReflect ¶
func (x *TransactionListResponse) ProtoReflect() protoreflect.Message
func (*TransactionListResponse) Reset ¶
func (x *TransactionListResponse) Reset()
func (*TransactionListResponse) SizeVT ¶
func (m *TransactionListResponse) SizeVT() (n int)
func (*TransactionListResponse) String ¶
func (x *TransactionListResponse) String() string
func (*TransactionListResponse) UnmarshalVT ¶
func (m *TransactionListResponse) UnmarshalVT(dAtA []byte) error
type TransactionListResponse_Finished ¶
type TransactionListResponse_Finished struct { // Finished is sent when there are no more results in this operation, and // there will only be one. Finished *ListFinished `protobuf:"bytes,2,opt,name=finished,proto3,oneof"` }
func (*TransactionListResponse_Finished) CloneVT ¶
func (m *TransactionListResponse_Finished) CloneVT() isTransactionListResponse_Response
func (*TransactionListResponse_Finished) EqualVT ¶
func (this *TransactionListResponse_Finished) EqualVT(thatIface isTransactionListResponse_Response) bool
func (*TransactionListResponse_Finished) MarshalToSizedBufferVT ¶
func (m *TransactionListResponse_Finished) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*TransactionListResponse_Finished) MarshalToVT ¶
func (m *TransactionListResponse_Finished) MarshalToVT(dAtA []byte) (int, error)
func (*TransactionListResponse_Finished) SizeVT ¶
func (m *TransactionListResponse_Finished) SizeVT() (n int)
type TransactionListResponse_Result ¶
type TransactionListResponse_Result struct { // Result is a segment of the result set - multiple of these may be returned // in a stream before the final "finished" message. Result *ListPartialResult `protobuf:"bytes,1,opt,name=result,proto3,oneof"` }
func (*TransactionListResponse_Result) CloneVT ¶
func (m *TransactionListResponse_Result) CloneVT() isTransactionListResponse_Response
func (*TransactionListResponse_Result) EqualVT ¶
func (this *TransactionListResponse_Result) EqualVT(thatIface isTransactionListResponse_Response) bool
func (*TransactionListResponse_Result) MarshalToSizedBufferVT ¶
func (m *TransactionListResponse_Result) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*TransactionListResponse_Result) MarshalToVT ¶
func (m *TransactionListResponse_Result) MarshalToVT(dAtA []byte) (int, error)
func (*TransactionListResponse_Result) SizeVT ¶
func (m *TransactionListResponse_Result) SizeVT() (n int)
type TransactionPut ¶
type TransactionPut struct { // puts is one or more items to be put into the Store. Puts []*PutItem `protobuf:"bytes,1,rep,name=puts,proto3" json:"puts,omitempty"` // contains filtered or unexported fields }
TransactionPut is a subset of the PutRequest message, for performing puts within the context of a transaction. These will not be acknowledged until the transaction is finished.
func (*TransactionPut) CloneMessageVT ¶
func (m *TransactionPut) CloneMessageVT() proto.Message
func (*TransactionPut) CloneVT ¶
func (m *TransactionPut) CloneVT() *TransactionPut
func (*TransactionPut) Descriptor
deprecated
func (*TransactionPut) Descriptor() ([]byte, []int)
Deprecated: Use TransactionPut.ProtoReflect.Descriptor instead.
func (*TransactionPut) EqualMessageVT ¶
func (this *TransactionPut) EqualMessageVT(thatMsg proto.Message) bool
func (*TransactionPut) EqualVT ¶
func (this *TransactionPut) EqualVT(that *TransactionPut) bool
func (*TransactionPut) GetPuts ¶
func (x *TransactionPut) GetPuts() []*PutItem
func (*TransactionPut) MarshalToSizedBufferVT ¶
func (m *TransactionPut) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*TransactionPut) MarshalToVT ¶
func (m *TransactionPut) MarshalToVT(dAtA []byte) (int, error)
func (*TransactionPut) MarshalVT ¶
func (m *TransactionPut) MarshalVT() (dAtA []byte, err error)
func (*TransactionPut) ProtoMessage ¶
func (*TransactionPut) ProtoMessage()
func (*TransactionPut) ProtoReflect ¶
func (x *TransactionPut) ProtoReflect() protoreflect.Message
func (*TransactionPut) Reset ¶
func (x *TransactionPut) Reset()
func (*TransactionPut) SizeVT ¶
func (m *TransactionPut) SizeVT() (n int)
func (*TransactionPut) String ¶
func (x *TransactionPut) String() string
func (*TransactionPut) UnmarshalVT ¶
func (m *TransactionPut) UnmarshalVT(dAtA []byte) error
type 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 (m *TransactionResponse) CloneVT() *TransactionResponse
func (*TransactionResponse) Descriptor
deprecated
func (*TransactionResponse) Descriptor() ([]byte, []int)
Deprecated: Use TransactionResponse.ProtoReflect.Descriptor instead.
func (*TransactionResponse) EqualMessageVT ¶
func (this *TransactionResponse) EqualMessageVT(thatMsg proto.Message) bool
func (*TransactionResponse) EqualVT ¶
func (this *TransactionResponse) EqualVT(that *TransactionResponse) bool
func (*TransactionResponse) 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)
Source Files ¶
- append.pb.go
- append_vtproto.pb.go
- continue-list.pb.go
- continue-list_vtproto.pb.go
- delete.pb.go
- delete_vtproto.pb.go
- get.pb.go
- get_vtproto.pb.go
- item-property.pb.go
- item.pb.go
- item_vtproto.pb.go
- list-token.pb.go
- list-token_vtproto.pb.go
- list.pb.go
- list_vtproto.pb.go
- oneof_exporters.go
- put.pb.go
- put_vtproto.pb.go
- scan-root-paths.pb.go
- scan-root-paths_vtproto.pb.go
- service.pb.go
- sync-list.pb.go
- sync-list_vtproto.pb.go
- transaction.pb.go
- transaction_vtproto.pb.go