Documentation
¶
Overview ¶
Package roachpb is a generated protocol buffer package.
It is generated from these files:
cockroach/pkg/roachpb/api.proto cockroach/pkg/roachpb/app_stats.proto cockroach/pkg/roachpb/data.proto cockroach/pkg/roachpb/errors.proto cockroach/pkg/roachpb/internal.proto cockroach/pkg/roachpb/internal_raft.proto cockroach/pkg/roachpb/metadata.proto
It has these top-level messages:
RangeInfo ResponseHeader GetRequest GetResponse PutRequest PutResponse ConditionalPutRequest ConditionalPutResponse InitPutRequest InitPutResponse IncrementRequest IncrementResponse DeleteRequest DeleteResponse DeleteRangeRequest DeleteRangeResponse ScanRequest ScanResponse ReverseScanRequest ReverseScanResponse CheckConsistencyRequest CheckConsistencyResponse BeginTransactionRequest BeginTransactionResponse EndTransactionRequest EndTransactionResponse AdminSplitRequest AdminSplitResponse AdminMergeRequest AdminMergeResponse AdminTransferLeaseRequest AdminTransferLeaseResponse AdminChangeReplicasRequest AdminChangeReplicasResponse RangeLookupRequest RangeLookupResponse HeartbeatTxnRequest HeartbeatTxnResponse GCRequest GCResponse PushTxnRequest PushTxnResponse QueryTxnRequest QueryTxnResponse ResolveIntentRequest ResolveIntentResponse ResolveIntentRangeRequest NoopResponse NoopRequest ResolveIntentRangeResponse MergeRequest MergeResponse TruncateLogRequest TruncateLogResponse RequestLeaseRequest TransferLeaseRequest LeaseInfoRequest LeaseInfoResponse RequestLeaseResponse ComputeChecksumRequest ComputeChecksumResponse DeprecatedVerifyChecksumRequest DeprecatedVerifyChecksumResponse ExportStorage WriteBatchRequest WriteBatchResponse ExportRequest ExportResponse ImportRequest ImportResponse AdminScatterRequest AdminScatterResponse RequestUnion ResponseUnion Header BatchRequest BatchResponse StatementStatistics NumericStat Span Value KeyValue StoreIdent SplitTrigger MergeTrigger ChangeReplicasTrigger ModifiedSpanTrigger InternalCommitTrigger ObservedTimestamp Transaction Intent Lease AbortCacheEntry NotLeaseHolderError NodeUnavailableError RangeNotFoundError RangeKeyMismatchError ReadWithinUncertaintyIntervalError TransactionAbortedError TransactionPushError TransactionRetryError TransactionReplayError TransactionStatusError WriteIntentError WriteTooOldError OpRequiresTxnError ConditionFailedError LeaseRejectedError SendError AmbiguousResultError RaftGroupDeletedError ReplicaCorruptionError ReplicaTooOldError StoreNotFoundError ErrorDetail ErrPosition Error UnhandledRetryableError HandledRetryableTxnError InternalTimeSeriesData InternalTimeSeriesSample RaftTruncatedState RaftTombstone RaftSnapshotData Attributes ReplicationTarget ReplicaDescriptor ReplicaIdent RangeDescriptor StoreCapacity NodeDescriptor StoreDescriptor StoreDeadReplicas Locality Tier
Index ¶
- Constants
- Variables
- func BytesNext(b []byte) []byte
- func ConsultsTimestampCache(args Request) bool
- func ErrorUnexpectedlySet(culprit, response interface{}) string
- func IsRange(args Request) bool
- func IsReadOnly(args Request) bool
- func IsTransactionWrite(args Request) bool
- func MakePriority(userPriority UserPriority) int32
- func RegisterExternalServer(s *grpc.Server, srv ExternalServer)
- func RegisterInternalServer(s *grpc.Server, srv InternalServer)
- func TxnIDEqual(a, b *uuid.UUID) bool
- func UpdatesTimestampCache(args Request) bool
- type AbortCacheEntry
- func (*AbortCacheEntry) Descriptor() ([]byte, []int)
- func (m *AbortCacheEntry) Marshal() (dAtA []byte, err error)
- func (m *AbortCacheEntry) MarshalTo(dAtA []byte) (int, error)
- func (*AbortCacheEntry) ProtoMessage()
- func (m *AbortCacheEntry) Reset()
- func (m *AbortCacheEntry) Size() (n int)
- func (m *AbortCacheEntry) String() string
- func (m *AbortCacheEntry) Unmarshal(dAtA []byte) error
- type AdminChangeReplicasRequest
- func (*AdminChangeReplicasRequest) Descriptor() ([]byte, []int)
- func (m *AdminChangeReplicasRequest) Marshal() (dAtA []byte, err error)
- func (m *AdminChangeReplicasRequest) MarshalTo(dAtA []byte) (int, error)
- func (*AdminChangeReplicasRequest) Method() Method
- func (*AdminChangeReplicasRequest) ProtoMessage()
- func (m *AdminChangeReplicasRequest) Reset()
- func (acrr *AdminChangeReplicasRequest) ShallowCopy() Request
- func (m *AdminChangeReplicasRequest) Size() (n int)
- func (m *AdminChangeReplicasRequest) String() string
- func (m *AdminChangeReplicasRequest) Unmarshal(dAtA []byte) error
- type AdminChangeReplicasResponse
- func (*AdminChangeReplicasResponse) Descriptor() ([]byte, []int)
- func (m *AdminChangeReplicasResponse) Marshal() (dAtA []byte, err error)
- func (m *AdminChangeReplicasResponse) MarshalTo(dAtA []byte) (int, error)
- func (*AdminChangeReplicasResponse) ProtoMessage()
- func (m *AdminChangeReplicasResponse) Reset()
- func (m *AdminChangeReplicasResponse) Size() (n int)
- func (m *AdminChangeReplicasResponse) String() string
- func (m *AdminChangeReplicasResponse) Unmarshal(dAtA []byte) error
- type AdminMergeRequest
- func (*AdminMergeRequest) Descriptor() ([]byte, []int)
- func (m *AdminMergeRequest) Marshal() (dAtA []byte, err error)
- func (m *AdminMergeRequest) MarshalTo(dAtA []byte) (int, error)
- func (*AdminMergeRequest) Method() Method
- func (*AdminMergeRequest) ProtoMessage()
- func (m *AdminMergeRequest) Reset()
- func (amr *AdminMergeRequest) ShallowCopy() Request
- func (m *AdminMergeRequest) Size() (n int)
- func (m *AdminMergeRequest) String() string
- func (m *AdminMergeRequest) Unmarshal(dAtA []byte) error
- type AdminMergeResponse
- func (*AdminMergeResponse) Descriptor() ([]byte, []int)
- func (m *AdminMergeResponse) Marshal() (dAtA []byte, err error)
- func (m *AdminMergeResponse) MarshalTo(dAtA []byte) (int, error)
- func (*AdminMergeResponse) ProtoMessage()
- func (m *AdminMergeResponse) Reset()
- func (m *AdminMergeResponse) Size() (n int)
- func (m *AdminMergeResponse) String() string
- func (m *AdminMergeResponse) Unmarshal(dAtA []byte) error
- type AdminScatterRequest
- func (*AdminScatterRequest) Descriptor() ([]byte, []int)
- func (m *AdminScatterRequest) Marshal() (dAtA []byte, err error)
- func (m *AdminScatterRequest) MarshalTo(dAtA []byte) (int, error)
- func (*AdminScatterRequest) Method() Method
- func (*AdminScatterRequest) ProtoMessage()
- func (m *AdminScatterRequest) Reset()
- func (r *AdminScatterRequest) ShallowCopy() Request
- func (m *AdminScatterRequest) Size() (n int)
- func (m *AdminScatterRequest) String() string
- func (m *AdminScatterRequest) Unmarshal(dAtA []byte) error
- type AdminScatterResponse
- func (*AdminScatterResponse) Descriptor() ([]byte, []int)
- func (m *AdminScatterResponse) Marshal() (dAtA []byte, err error)
- func (m *AdminScatterResponse) MarshalTo(dAtA []byte) (int, error)
- func (*AdminScatterResponse) ProtoMessage()
- func (m *AdminScatterResponse) Reset()
- func (m *AdminScatterResponse) Size() (n int)
- func (m *AdminScatterResponse) String() string
- func (m *AdminScatterResponse) Unmarshal(dAtA []byte) error
- type AdminScatterResponse_Range
- func (*AdminScatterResponse_Range) Descriptor() ([]byte, []int)
- func (m *AdminScatterResponse_Range) Marshal() (dAtA []byte, err error)
- func (m *AdminScatterResponse_Range) MarshalTo(dAtA []byte) (int, error)
- func (*AdminScatterResponse_Range) ProtoMessage()
- func (m *AdminScatterResponse_Range) Reset()
- func (m *AdminScatterResponse_Range) Size() (n int)
- func (m *AdminScatterResponse_Range) String() string
- func (m *AdminScatterResponse_Range) Unmarshal(dAtA []byte) error
- type AdminSplitRequest
- func (*AdminSplitRequest) Descriptor() ([]byte, []int)
- func (m *AdminSplitRequest) Marshal() (dAtA []byte, err error)
- func (m *AdminSplitRequest) MarshalTo(dAtA []byte) (int, error)
- func (*AdminSplitRequest) Method() Method
- func (*AdminSplitRequest) ProtoMessage()
- func (m *AdminSplitRequest) Reset()
- func (asr *AdminSplitRequest) ShallowCopy() Request
- func (m *AdminSplitRequest) Size() (n int)
- func (m *AdminSplitRequest) String() string
- func (m *AdminSplitRequest) Unmarshal(dAtA []byte) error
- type AdminSplitResponse
- func (*AdminSplitResponse) Descriptor() ([]byte, []int)
- func (m *AdminSplitResponse) Marshal() (dAtA []byte, err error)
- func (m *AdminSplitResponse) MarshalTo(dAtA []byte) (int, error)
- func (*AdminSplitResponse) ProtoMessage()
- func (m *AdminSplitResponse) Reset()
- func (m *AdminSplitResponse) Size() (n int)
- func (m *AdminSplitResponse) String() string
- func (m *AdminSplitResponse) Unmarshal(dAtA []byte) error
- type AdminTransferLeaseRequest
- func (*AdminTransferLeaseRequest) Descriptor() ([]byte, []int)
- func (m *AdminTransferLeaseRequest) Marshal() (dAtA []byte, err error)
- func (m *AdminTransferLeaseRequest) MarshalTo(dAtA []byte) (int, error)
- func (*AdminTransferLeaseRequest) Method() Method
- func (*AdminTransferLeaseRequest) ProtoMessage()
- func (m *AdminTransferLeaseRequest) Reset()
- func (atlr *AdminTransferLeaseRequest) ShallowCopy() Request
- func (m *AdminTransferLeaseRequest) Size() (n int)
- func (m *AdminTransferLeaseRequest) String() string
- func (m *AdminTransferLeaseRequest) Unmarshal(dAtA []byte) error
- type AdminTransferLeaseResponse
- func (*AdminTransferLeaseResponse) Descriptor() ([]byte, []int)
- func (m *AdminTransferLeaseResponse) Marshal() (dAtA []byte, err error)
- func (m *AdminTransferLeaseResponse) MarshalTo(dAtA []byte) (int, error)
- func (*AdminTransferLeaseResponse) ProtoMessage()
- func (m *AdminTransferLeaseResponse) Reset()
- func (m *AdminTransferLeaseResponse) Size() (n int)
- func (m *AdminTransferLeaseResponse) String() string
- func (m *AdminTransferLeaseResponse) Unmarshal(dAtA []byte) error
- type AmbiguousResultError
- func (*AmbiguousResultError) Descriptor() ([]byte, []int)
- func (e *AmbiguousResultError) Error() string
- func (m *AmbiguousResultError) Marshal() (dAtA []byte, err error)
- func (m *AmbiguousResultError) MarshalTo(dAtA []byte) (int, error)
- func (*AmbiguousResultError) ProtoMessage()
- func (m *AmbiguousResultError) Reset()
- func (m *AmbiguousResultError) Size() (n int)
- func (m *AmbiguousResultError) String() string
- func (m *AmbiguousResultError) Unmarshal(dAtA []byte) error
- type Attributes
- func (*Attributes) Descriptor() ([]byte, []int)
- func (a Attributes) IsSubset(b Attributes) bool
- func (m *Attributes) Marshal() (dAtA []byte, err error)
- func (m *Attributes) MarshalTo(dAtA []byte) (int, error)
- func (*Attributes) ProtoMessage()
- func (m *Attributes) Reset()
- func (m *Attributes) Size() (n int)
- func (a Attributes) SortedString() string
- func (a Attributes) String() string
- func (m *Attributes) Unmarshal(dAtA []byte) error
- type BatchRequest
- func (ba *BatchRequest) Add(requests ...Request)
- func (ba *BatchRequest) CreateReply() *BatchResponse
- func (*BatchRequest) Descriptor() ([]byte, []int)
- func (ba *BatchRequest) GetArg(method Method) (Request, bool)
- func (ba *BatchRequest) GetPrevLeaseForLeaseRequest() *Lease
- func (*BatchRequest) GetUser() string
- func (ba *BatchRequest) IntentSpanIterate(br *BatchResponse, fn func(key, endKey Key))
- func (ba *BatchRequest) IsAdmin() bool
- func (ba *BatchRequest) IsLeaseRequest() bool
- func (ba *BatchRequest) IsPossibleTransaction() bool
- func (ba *BatchRequest) IsReadOnly() bool
- func (ba *BatchRequest) IsReverse() bool
- func (ba *BatchRequest) IsSinglePushTxnRequest() bool
- func (ba *BatchRequest) IsSingleRequest() bool
- func (ba *BatchRequest) IsSingleSkipLeaseCheckRequest() bool
- func (ba *BatchRequest) IsTransactionWrite() bool
- func (ba *BatchRequest) IsWrite() bool
- func (m *BatchRequest) Marshal() (dAtA []byte, err error)
- func (m *BatchRequest) MarshalTo(dAtA []byte) (int, error)
- func (ba *BatchRequest) Methods() []Method
- func (*BatchRequest) ProtoMessage()
- func (m *BatchRequest) Reset()
- func (ba *BatchRequest) SetActiveTimestamp(nowFn func() hlc.Timestamp) error
- func (ba *BatchRequest) SetNewRequest()
- func (m *BatchRequest) Size() (n int)
- func (ba BatchRequest) Split(canSplitET bool) [][]RequestUnion
- func (ba BatchRequest) String() string
- func (ba *BatchRequest) Summary() string
- func (m *BatchRequest) Unmarshal(dAtA []byte) error
- func (ba *BatchRequest) UpdateTxn(otherTxn *Transaction)
- type BatchResponse
- func (br *BatchResponse) Add(reply Response)
- func (br *BatchResponse) Combine(otherBatch *BatchResponse) error
- func (*BatchResponse) Descriptor() ([]byte, []int)
- func (m *BatchResponse) Marshal() (dAtA []byte, err error)
- func (m *BatchResponse) MarshalTo(dAtA []byte) (int, error)
- func (*BatchResponse) ProtoMessage()
- func (m *BatchResponse) Reset()
- func (m *BatchResponse) Size() (n int)
- func (br *BatchResponse) String() string
- func (m *BatchResponse) Unmarshal(dAtA []byte) error
- type BatchResponse_Header
- func (*BatchResponse_Header) Descriptor() ([]byte, []int)
- func (m *BatchResponse_Header) Marshal() (dAtA []byte, err error)
- func (m *BatchResponse_Header) MarshalTo(dAtA []byte) (int, error)
- func (*BatchResponse_Header) ProtoMessage()
- func (m *BatchResponse_Header) Reset()
- func (m *BatchResponse_Header) Size() (n int)
- func (m *BatchResponse_Header) String() string
- func (m *BatchResponse_Header) Unmarshal(dAtA []byte) error
- type BeginTransactionRequest
- func (*BeginTransactionRequest) Descriptor() ([]byte, []int)
- func (m *BeginTransactionRequest) Marshal() (dAtA []byte, err error)
- func (m *BeginTransactionRequest) MarshalTo(dAtA []byte) (int, error)
- func (*BeginTransactionRequest) Method() Method
- func (*BeginTransactionRequest) ProtoMessage()
- func (m *BeginTransactionRequest) Reset()
- func (btr *BeginTransactionRequest) ShallowCopy() Request
- func (m *BeginTransactionRequest) Size() (n int)
- func (m *BeginTransactionRequest) String() string
- func (m *BeginTransactionRequest) Unmarshal(dAtA []byte) error
- type BeginTransactionResponse
- func (*BeginTransactionResponse) Descriptor() ([]byte, []int)
- func (m *BeginTransactionResponse) Marshal() (dAtA []byte, err error)
- func (m *BeginTransactionResponse) MarshalTo(dAtA []byte) (int, error)
- func (*BeginTransactionResponse) ProtoMessage()
- func (m *BeginTransactionResponse) Reset()
- func (m *BeginTransactionResponse) Size() (n int)
- func (m *BeginTransactionResponse) String() string
- func (m *BeginTransactionResponse) Unmarshal(dAtA []byte) error
- type ChangeReplicasTrigger
- func (*ChangeReplicasTrigger) Descriptor() ([]byte, []int)
- func (m *ChangeReplicasTrigger) Marshal() (dAtA []byte, err error)
- func (m *ChangeReplicasTrigger) MarshalTo(dAtA []byte) (int, error)
- func (*ChangeReplicasTrigger) ProtoMessage()
- func (m *ChangeReplicasTrigger) Reset()
- func (m *ChangeReplicasTrigger) Size() (n int)
- func (m *ChangeReplicasTrigger) String() string
- func (m *ChangeReplicasTrigger) Unmarshal(dAtA []byte) error
- type CheckConsistencyRequest
- func (*CheckConsistencyRequest) Descriptor() ([]byte, []int)
- func (m *CheckConsistencyRequest) Marshal() (dAtA []byte, err error)
- func (m *CheckConsistencyRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CheckConsistencyRequest) Method() Method
- func (*CheckConsistencyRequest) ProtoMessage()
- func (m *CheckConsistencyRequest) Reset()
- func (ccr *CheckConsistencyRequest) ShallowCopy() Request
- func (m *CheckConsistencyRequest) Size() (n int)
- func (m *CheckConsistencyRequest) String() string
- func (m *CheckConsistencyRequest) Unmarshal(dAtA []byte) error
- type CheckConsistencyResponse
- func (*CheckConsistencyResponse) Descriptor() ([]byte, []int)
- func (m *CheckConsistencyResponse) Marshal() (dAtA []byte, err error)
- func (m *CheckConsistencyResponse) MarshalTo(dAtA []byte) (int, error)
- func (*CheckConsistencyResponse) ProtoMessage()
- func (m *CheckConsistencyResponse) Reset()
- func (m *CheckConsistencyResponse) Size() (n int)
- func (m *CheckConsistencyResponse) String() string
- func (m *CheckConsistencyResponse) Unmarshal(dAtA []byte) error
- type ComputeChecksumRequest
- func (*ComputeChecksumRequest) Descriptor() ([]byte, []int)
- func (m *ComputeChecksumRequest) Marshal() (dAtA []byte, err error)
- func (m *ComputeChecksumRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ComputeChecksumRequest) Method() Method
- func (*ComputeChecksumRequest) ProtoMessage()
- func (m *ComputeChecksumRequest) Reset()
- func (ccr *ComputeChecksumRequest) ShallowCopy() Request
- func (m *ComputeChecksumRequest) Size() (n int)
- func (m *ComputeChecksumRequest) String() string
- func (m *ComputeChecksumRequest) Unmarshal(dAtA []byte) error
- type ComputeChecksumResponse
- func (*ComputeChecksumResponse) Descriptor() ([]byte, []int)
- func (m *ComputeChecksumResponse) Marshal() (dAtA []byte, err error)
- func (m *ComputeChecksumResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ComputeChecksumResponse) ProtoMessage()
- func (m *ComputeChecksumResponse) Reset()
- func (m *ComputeChecksumResponse) Size() (n int)
- func (m *ComputeChecksumResponse) String() string
- func (m *ComputeChecksumResponse) Unmarshal(dAtA []byte) error
- type ConditionFailedError
- func (*ConditionFailedError) Descriptor() ([]byte, []int)
- func (e *ConditionFailedError) Error() string
- func (m *ConditionFailedError) Marshal() (dAtA []byte, err error)
- func (m *ConditionFailedError) MarshalTo(dAtA []byte) (int, error)
- func (*ConditionFailedError) ProtoMessage()
- func (m *ConditionFailedError) Reset()
- func (m *ConditionFailedError) Size() (n int)
- func (m *ConditionFailedError) String() string
- func (m *ConditionFailedError) Unmarshal(dAtA []byte) error
- type ConditionalPutRequest
- func (*ConditionalPutRequest) Descriptor() ([]byte, []int)
- func (m *ConditionalPutRequest) Marshal() (dAtA []byte, err error)
- func (m *ConditionalPutRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ConditionalPutRequest) Method() Method
- func (*ConditionalPutRequest) ProtoMessage()
- func (m *ConditionalPutRequest) Reset()
- func (cpr *ConditionalPutRequest) ShallowCopy() Request
- func (m *ConditionalPutRequest) Size() (n int)
- func (m *ConditionalPutRequest) String() string
- func (m *ConditionalPutRequest) Unmarshal(dAtA []byte) error
- type ConditionalPutResponse
- func (*ConditionalPutResponse) Descriptor() ([]byte, []int)
- func (m *ConditionalPutResponse) Marshal() (dAtA []byte, err error)
- func (m *ConditionalPutResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ConditionalPutResponse) ProtoMessage()
- func (m *ConditionalPutResponse) Reset()
- func (m *ConditionalPutResponse) Size() (n int)
- func (m *ConditionalPutResponse) String() string
- func (m *ConditionalPutResponse) Unmarshal(dAtA []byte) error
- type DeleteRangeRequest
- func (*DeleteRangeRequest) Descriptor() ([]byte, []int)
- func (m *DeleteRangeRequest) Marshal() (dAtA []byte, err error)
- func (m *DeleteRangeRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteRangeRequest) Method() Method
- func (*DeleteRangeRequest) ProtoMessage()
- func (m *DeleteRangeRequest) Reset()
- func (drr *DeleteRangeRequest) ShallowCopy() Request
- func (m *DeleteRangeRequest) Size() (n int)
- func (m *DeleteRangeRequest) String() string
- func (m *DeleteRangeRequest) Unmarshal(dAtA []byte) error
- type DeleteRangeResponse
- func (*DeleteRangeResponse) Descriptor() ([]byte, []int)
- func (m *DeleteRangeResponse) Marshal() (dAtA []byte, err error)
- func (m *DeleteRangeResponse) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteRangeResponse) ProtoMessage()
- func (m *DeleteRangeResponse) Reset()
- func (m *DeleteRangeResponse) Size() (n int)
- func (m *DeleteRangeResponse) String() string
- func (m *DeleteRangeResponse) Unmarshal(dAtA []byte) error
- type DeleteRequest
- func (*DeleteRequest) Descriptor() ([]byte, []int)
- func (m *DeleteRequest) Marshal() (dAtA []byte, err error)
- func (m *DeleteRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteRequest) Method() Method
- func (*DeleteRequest) ProtoMessage()
- func (m *DeleteRequest) Reset()
- func (dr *DeleteRequest) ShallowCopy() Request
- func (m *DeleteRequest) Size() (n int)
- func (m *DeleteRequest) String() string
- func (m *DeleteRequest) Unmarshal(dAtA []byte) error
- type DeleteResponse
- func (*DeleteResponse) Descriptor() ([]byte, []int)
- func (m *DeleteResponse) Marshal() (dAtA []byte, err error)
- func (m *DeleteResponse) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteResponse) ProtoMessage()
- func (m *DeleteResponse) Reset()
- func (m *DeleteResponse) Size() (n int)
- func (m *DeleteResponse) String() string
- func (m *DeleteResponse) Unmarshal(dAtA []byte) error
- type DeprecatedVerifyChecksumRequest
- func (*DeprecatedVerifyChecksumRequest) Descriptor() ([]byte, []int)
- func (m *DeprecatedVerifyChecksumRequest) Marshal() (dAtA []byte, err error)
- func (m *DeprecatedVerifyChecksumRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DeprecatedVerifyChecksumRequest) Method() Method
- func (*DeprecatedVerifyChecksumRequest) ProtoMessage()
- func (m *DeprecatedVerifyChecksumRequest) Reset()
- func (dvcr *DeprecatedVerifyChecksumRequest) ShallowCopy() Request
- func (m *DeprecatedVerifyChecksumRequest) Size() (n int)
- func (m *DeprecatedVerifyChecksumRequest) String() string
- func (m *DeprecatedVerifyChecksumRequest) Unmarshal(dAtA []byte) error
- type DeprecatedVerifyChecksumResponse
- func (*DeprecatedVerifyChecksumResponse) Descriptor() ([]byte, []int)
- func (m *DeprecatedVerifyChecksumResponse) Marshal() (dAtA []byte, err error)
- func (m *DeprecatedVerifyChecksumResponse) MarshalTo(dAtA []byte) (int, error)
- func (*DeprecatedVerifyChecksumResponse) ProtoMessage()
- func (m *DeprecatedVerifyChecksumResponse) Reset()
- func (m *DeprecatedVerifyChecksumResponse) Size() (n int)
- func (m *DeprecatedVerifyChecksumResponse) String() string
- func (m *DeprecatedVerifyChecksumResponse) Unmarshal(dAtA []byte) error
- type EndTransactionRequest
- func (*EndTransactionRequest) Descriptor() ([]byte, []int)
- func (m *EndTransactionRequest) Marshal() (dAtA []byte, err error)
- func (m *EndTransactionRequest) MarshalTo(dAtA []byte) (int, error)
- func (*EndTransactionRequest) Method() Method
- func (*EndTransactionRequest) ProtoMessage()
- func (m *EndTransactionRequest) Reset()
- func (etr *EndTransactionRequest) ShallowCopy() Request
- func (m *EndTransactionRequest) Size() (n int)
- func (m *EndTransactionRequest) String() string
- func (m *EndTransactionRequest) Unmarshal(dAtA []byte) error
- type EndTransactionResponse
- func (*EndTransactionResponse) Descriptor() ([]byte, []int)
- func (m *EndTransactionResponse) Marshal() (dAtA []byte, err error)
- func (m *EndTransactionResponse) MarshalTo(dAtA []byte) (int, error)
- func (*EndTransactionResponse) ProtoMessage()
- func (m *EndTransactionResponse) Reset()
- func (m *EndTransactionResponse) Size() (n int)
- func (m *EndTransactionResponse) String() string
- func (m *EndTransactionResponse) Unmarshal(dAtA []byte) error
- type ErrPosition
- func (*ErrPosition) Descriptor() ([]byte, []int)
- func (m *ErrPosition) Marshal() (dAtA []byte, err error)
- func (m *ErrPosition) MarshalTo(dAtA []byte) (int, error)
- func (*ErrPosition) ProtoMessage()
- func (m *ErrPosition) Reset()
- func (m *ErrPosition) Size() (n int)
- func (m *ErrPosition) String() string
- func (m *ErrPosition) Unmarshal(dAtA []byte) error
- type Error
- func (*Error) Descriptor() ([]byte, []int)
- func (e *Error) GetDetail() ErrorDetailInterface
- func (e *Error) GetTxn() *Transaction
- func (e *Error) GoError() error
- func (m *Error) Marshal() (dAtA []byte, err error)
- func (m *Error) MarshalTo(dAtA []byte) (int, error)
- func (*Error) ProtoMessage()
- func (m *Error) Reset()
- func (e *Error) SetErrorIndex(index int32)
- func (e *Error) SetTxn(txn *Transaction)
- func (m *Error) Size() (n int)
- func (e *Error) String() string
- func (m *Error) Unmarshal(dAtA []byte) error
- func (e *Error) UpdateTxn(o *Transaction)
- type ErrorDetail
- func (*ErrorDetail) Descriptor() ([]byte, []int)
- func (this *ErrorDetail) GetValue() interface{}
- func (m *ErrorDetail) Marshal() (dAtA []byte, err error)
- func (m *ErrorDetail) MarshalTo(dAtA []byte) (int, error)
- func (*ErrorDetail) ProtoMessage()
- func (m *ErrorDetail) Reset()
- func (this *ErrorDetail) SetValue(value interface{}) bool
- func (m *ErrorDetail) Size() (n int)
- func (m *ErrorDetail) String() string
- func (m *ErrorDetail) Unmarshal(dAtA []byte) error
- type ErrorDetailInterface
- type ExportRequest
- func (*ExportRequest) Descriptor() ([]byte, []int)
- func (m *ExportRequest) Marshal() (dAtA []byte, err error)
- func (m *ExportRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ExportRequest) Method() Method
- func (*ExportRequest) ProtoMessage()
- func (m *ExportRequest) Reset()
- func (ekr *ExportRequest) ShallowCopy() Request
- func (m *ExportRequest) Size() (n int)
- func (m *ExportRequest) String() string
- func (m *ExportRequest) Unmarshal(dAtA []byte) error
- type ExportResponse
- func (*ExportResponse) Descriptor() ([]byte, []int)
- func (m *ExportResponse) Marshal() (dAtA []byte, err error)
- func (m *ExportResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ExportResponse) ProtoMessage()
- func (m *ExportResponse) Reset()
- func (m *ExportResponse) Size() (n int)
- func (m *ExportResponse) String() string
- func (m *ExportResponse) Unmarshal(dAtA []byte) error
- type ExportResponse_File
- func (*ExportResponse_File) Descriptor() ([]byte, []int)
- func (m *ExportResponse_File) Marshal() (dAtA []byte, err error)
- func (m *ExportResponse_File) MarshalTo(dAtA []byte) (int, error)
- func (*ExportResponse_File) ProtoMessage()
- func (m *ExportResponse_File) Reset()
- func (m *ExportResponse_File) Size() (n int)
- func (m *ExportResponse_File) String() string
- func (m *ExportResponse_File) Unmarshal(dAtA []byte) error
- type ExportStorage
- func (*ExportStorage) Descriptor() ([]byte, []int)
- func (m *ExportStorage) Marshal() (dAtA []byte, err error)
- func (m *ExportStorage) MarshalTo(dAtA []byte) (int, error)
- func (*ExportStorage) ProtoMessage()
- func (m *ExportStorage) Reset()
- func (m *ExportStorage) Size() (n int)
- func (m *ExportStorage) String() string
- func (m *ExportStorage) Unmarshal(dAtA []byte) error
- type ExportStorageProvider
- type ExportStorage_Azure
- func (*ExportStorage_Azure) Descriptor() ([]byte, []int)
- func (m *ExportStorage_Azure) Marshal() (dAtA []byte, err error)
- func (m *ExportStorage_Azure) MarshalTo(dAtA []byte) (int, error)
- func (*ExportStorage_Azure) ProtoMessage()
- func (m *ExportStorage_Azure) Reset()
- func (m *ExportStorage_Azure) Size() (n int)
- func (m *ExportStorage_Azure) String() string
- func (m *ExportStorage_Azure) Unmarshal(dAtA []byte) error
- type ExportStorage_GCS
- func (*ExportStorage_GCS) Descriptor() ([]byte, []int)
- func (m *ExportStorage_GCS) Marshal() (dAtA []byte, err error)
- func (m *ExportStorage_GCS) MarshalTo(dAtA []byte) (int, error)
- func (*ExportStorage_GCS) ProtoMessage()
- func (m *ExportStorage_GCS) Reset()
- func (m *ExportStorage_GCS) Size() (n int)
- func (m *ExportStorage_GCS) String() string
- func (m *ExportStorage_GCS) Unmarshal(dAtA []byte) error
- type ExportStorage_Http
- func (*ExportStorage_Http) Descriptor() ([]byte, []int)
- func (m *ExportStorage_Http) Marshal() (dAtA []byte, err error)
- func (m *ExportStorage_Http) MarshalTo(dAtA []byte) (int, error)
- func (*ExportStorage_Http) ProtoMessage()
- func (m *ExportStorage_Http) Reset()
- func (m *ExportStorage_Http) Size() (n int)
- func (m *ExportStorage_Http) String() string
- func (m *ExportStorage_Http) Unmarshal(dAtA []byte) error
- type ExportStorage_LocalFilePath
- func (*ExportStorage_LocalFilePath) Descriptor() ([]byte, []int)
- func (m *ExportStorage_LocalFilePath) Marshal() (dAtA []byte, err error)
- func (m *ExportStorage_LocalFilePath) MarshalTo(dAtA []byte) (int, error)
- func (*ExportStorage_LocalFilePath) ProtoMessage()
- func (m *ExportStorage_LocalFilePath) Reset()
- func (m *ExportStorage_LocalFilePath) Size() (n int)
- func (m *ExportStorage_LocalFilePath) String() string
- func (m *ExportStorage_LocalFilePath) Unmarshal(dAtA []byte) error
- type ExportStorage_S3
- func (*ExportStorage_S3) Descriptor() ([]byte, []int)
- func (b *ExportStorage_S3) Keys() s3gof3r.Keys
- func (m *ExportStorage_S3) Marshal() (dAtA []byte, err error)
- func (m *ExportStorage_S3) MarshalTo(dAtA []byte) (int, error)
- func (*ExportStorage_S3) ProtoMessage()
- func (m *ExportStorage_S3) Reset()
- func (m *ExportStorage_S3) Size() (n int)
- func (m *ExportStorage_S3) String() string
- func (m *ExportStorage_S3) Unmarshal(dAtA []byte) error
- type ExternalClient
- type ExternalServer
- type GCRequest
- func (*GCRequest) Descriptor() ([]byte, []int)
- func (m *GCRequest) Marshal() (dAtA []byte, err error)
- func (m *GCRequest) MarshalTo(dAtA []byte) (int, error)
- func (*GCRequest) Method() Method
- func (*GCRequest) ProtoMessage()
- func (m *GCRequest) Reset()
- func (gcr *GCRequest) ShallowCopy() Request
- func (m *GCRequest) Size() (n int)
- func (m *GCRequest) String() string
- func (m *GCRequest) Unmarshal(dAtA []byte) error
- type GCRequest_GCKey
- func (*GCRequest_GCKey) Descriptor() ([]byte, []int)
- func (m *GCRequest_GCKey) Marshal() (dAtA []byte, err error)
- func (m *GCRequest_GCKey) MarshalTo(dAtA []byte) (int, error)
- func (*GCRequest_GCKey) ProtoMessage()
- func (m *GCRequest_GCKey) Reset()
- func (m *GCRequest_GCKey) Size() (n int)
- func (m *GCRequest_GCKey) String() string
- func (m *GCRequest_GCKey) Unmarshal(dAtA []byte) error
- type GCResponse
- func (*GCResponse) Descriptor() ([]byte, []int)
- func (m *GCResponse) Marshal() (dAtA []byte, err error)
- func (m *GCResponse) MarshalTo(dAtA []byte) (int, error)
- func (*GCResponse) ProtoMessage()
- func (m *GCResponse) Reset()
- func (m *GCResponse) Size() (n int)
- func (m *GCResponse) String() string
- func (m *GCResponse) Unmarshal(dAtA []byte) error
- type GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)
- func (m *GetRequest) Marshal() (dAtA []byte, err error)
- func (m *GetRequest) MarshalTo(dAtA []byte) (int, error)
- func (*GetRequest) Method() Method
- func (*GetRequest) ProtoMessage()
- func (m *GetRequest) Reset()
- func (gr *GetRequest) ShallowCopy() Request
- func (m *GetRequest) Size() (n int)
- func (m *GetRequest) String() string
- func (m *GetRequest) Unmarshal(dAtA []byte) error
- type GetResponse
- func (*GetResponse) Descriptor() ([]byte, []int)
- func (m *GetResponse) Marshal() (dAtA []byte, err error)
- func (m *GetResponse) MarshalTo(dAtA []byte) (int, error)
- func (*GetResponse) ProtoMessage()
- func (m *GetResponse) Reset()
- func (m *GetResponse) Size() (n int)
- func (m *GetResponse) String() string
- func (m *GetResponse) Unmarshal(dAtA []byte) error
- func (gr *GetResponse) Verify(req Request) error
- type HandledRetryableTxnError
- func (*HandledRetryableTxnError) Descriptor() ([]byte, []int)
- func (e *HandledRetryableTxnError) Error() string
- func (m *HandledRetryableTxnError) Marshal() (dAtA []byte, err error)
- func (m *HandledRetryableTxnError) MarshalTo(dAtA []byte) (int, error)
- func (*HandledRetryableTxnError) ProtoMessage()
- func (m *HandledRetryableTxnError) Reset()
- func (m *HandledRetryableTxnError) Size() (n int)
- func (m *HandledRetryableTxnError) String() string
- func (m *HandledRetryableTxnError) Unmarshal(dAtA []byte) error
- type Header
- func (*Header) Descriptor() ([]byte, []int)
- func (h Header) GetTxnID() *uuid.UUID
- func (m *Header) Marshal() (dAtA []byte, err error)
- func (m *Header) MarshalTo(dAtA []byte) (int, error)
- func (*Header) ProtoMessage()
- func (m *Header) Reset()
- func (m *Header) Size() (n int)
- func (m *Header) String() string
- func (m *Header) Unmarshal(dAtA []byte) error
- type HeartbeatTxnRequest
- func (*HeartbeatTxnRequest) Descriptor() ([]byte, []int)
- func (m *HeartbeatTxnRequest) Marshal() (dAtA []byte, err error)
- func (m *HeartbeatTxnRequest) MarshalTo(dAtA []byte) (int, error)
- func (*HeartbeatTxnRequest) Method() Method
- func (*HeartbeatTxnRequest) ProtoMessage()
- func (m *HeartbeatTxnRequest) Reset()
- func (htr *HeartbeatTxnRequest) ShallowCopy() Request
- func (m *HeartbeatTxnRequest) Size() (n int)
- func (m *HeartbeatTxnRequest) String() string
- func (m *HeartbeatTxnRequest) Unmarshal(dAtA []byte) error
- type HeartbeatTxnResponse
- func (*HeartbeatTxnResponse) Descriptor() ([]byte, []int)
- func (m *HeartbeatTxnResponse) Marshal() (dAtA []byte, err error)
- func (m *HeartbeatTxnResponse) MarshalTo(dAtA []byte) (int, error)
- func (*HeartbeatTxnResponse) ProtoMessage()
- func (m *HeartbeatTxnResponse) Reset()
- func (m *HeartbeatTxnResponse) Size() (n int)
- func (m *HeartbeatTxnResponse) String() string
- func (m *HeartbeatTxnResponse) Unmarshal(dAtA []byte) error
- type ImportRequest
- func (*ImportRequest) Descriptor() ([]byte, []int)
- func (m *ImportRequest) Marshal() (dAtA []byte, err error)
- func (m *ImportRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ImportRequest) Method() Method
- func (*ImportRequest) ProtoMessage()
- func (m *ImportRequest) Reset()
- func (r *ImportRequest) ShallowCopy() Request
- func (m *ImportRequest) Size() (n int)
- func (m *ImportRequest) String() string
- func (m *ImportRequest) Unmarshal(dAtA []byte) error
- type ImportRequest_File
- func (*ImportRequest_File) Descriptor() ([]byte, []int)
- func (m *ImportRequest_File) Marshal() (dAtA []byte, err error)
- func (m *ImportRequest_File) MarshalTo(dAtA []byte) (int, error)
- func (*ImportRequest_File) ProtoMessage()
- func (m *ImportRequest_File) Reset()
- func (m *ImportRequest_File) Size() (n int)
- func (m *ImportRequest_File) String() string
- func (m *ImportRequest_File) Unmarshal(dAtA []byte) error
- type ImportRequest_TableRekey
- func (*ImportRequest_TableRekey) Descriptor() ([]byte, []int)
- func (m *ImportRequest_TableRekey) Marshal() (dAtA []byte, err error)
- func (m *ImportRequest_TableRekey) MarshalTo(dAtA []byte) (int, error)
- func (*ImportRequest_TableRekey) ProtoMessage()
- func (m *ImportRequest_TableRekey) Reset()
- func (m *ImportRequest_TableRekey) Size() (n int)
- func (m *ImportRequest_TableRekey) String() string
- func (m *ImportRequest_TableRekey) Unmarshal(dAtA []byte) error
- type ImportResponse
- func (*ImportResponse) Descriptor() ([]byte, []int)
- func (m *ImportResponse) Marshal() (dAtA []byte, err error)
- func (m *ImportResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ImportResponse) ProtoMessage()
- func (m *ImportResponse) Reset()
- func (m *ImportResponse) Size() (n int)
- func (m *ImportResponse) String() string
- func (m *ImportResponse) Unmarshal(dAtA []byte) error
- type IncrementRequest
- func (*IncrementRequest) Descriptor() ([]byte, []int)
- func (m *IncrementRequest) Marshal() (dAtA []byte, err error)
- func (m *IncrementRequest) MarshalTo(dAtA []byte) (int, error)
- func (*IncrementRequest) Method() Method
- func (*IncrementRequest) ProtoMessage()
- func (m *IncrementRequest) Reset()
- func (ir *IncrementRequest) ShallowCopy() Request
- func (m *IncrementRequest) Size() (n int)
- func (m *IncrementRequest) String() string
- func (m *IncrementRequest) Unmarshal(dAtA []byte) error
- type IncrementResponse
- func (*IncrementResponse) Descriptor() ([]byte, []int)
- func (m *IncrementResponse) Marshal() (dAtA []byte, err error)
- func (m *IncrementResponse) MarshalTo(dAtA []byte) (int, error)
- func (*IncrementResponse) ProtoMessage()
- func (m *IncrementResponse) Reset()
- func (m *IncrementResponse) Size() (n int)
- func (m *IncrementResponse) String() string
- func (m *IncrementResponse) Unmarshal(dAtA []byte) error
- type InitPutRequest
- func (*InitPutRequest) Descriptor() ([]byte, []int)
- func (m *InitPutRequest) Marshal() (dAtA []byte, err error)
- func (m *InitPutRequest) MarshalTo(dAtA []byte) (int, error)
- func (*InitPutRequest) Method() Method
- func (*InitPutRequest) ProtoMessage()
- func (m *InitPutRequest) Reset()
- func (pr *InitPutRequest) ShallowCopy() Request
- func (m *InitPutRequest) Size() (n int)
- func (m *InitPutRequest) String() string
- func (m *InitPutRequest) Unmarshal(dAtA []byte) error
- type InitPutResponse
- func (*InitPutResponse) Descriptor() ([]byte, []int)
- func (m *InitPutResponse) Marshal() (dAtA []byte, err error)
- func (m *InitPutResponse) MarshalTo(dAtA []byte) (int, error)
- func (*InitPutResponse) ProtoMessage()
- func (m *InitPutResponse) Reset()
- func (m *InitPutResponse) Size() (n int)
- func (m *InitPutResponse) String() string
- func (m *InitPutResponse) Unmarshal(dAtA []byte) error
- type Intent
- func (*Intent) Descriptor() ([]byte, []int)
- func (m *Intent) Marshal() (dAtA []byte, err error)
- func (m *Intent) MarshalTo(dAtA []byte) (int, error)
- func (*Intent) ProtoMessage()
- func (m *Intent) Reset()
- func (m *Intent) Size() (n int)
- func (m *Intent) String() string
- func (m *Intent) Unmarshal(dAtA []byte) error
- type InternalClient
- type InternalCommitTrigger
- func (*InternalCommitTrigger) Descriptor() ([]byte, []int)
- func (m *InternalCommitTrigger) GetChangeReplicasTrigger() *ChangeReplicasTrigger
- func (m *InternalCommitTrigger) GetMergeTrigger() *MergeTrigger
- func (m *InternalCommitTrigger) GetModifiedSpanTrigger() *ModifiedSpanTrigger
- func (m *InternalCommitTrigger) GetSplitTrigger() *SplitTrigger
- func (m *InternalCommitTrigger) Marshal() (dAtA []byte, err error)
- func (m *InternalCommitTrigger) MarshalTo(dAtA []byte) (int, error)
- func (*InternalCommitTrigger) ProtoMessage()
- func (m *InternalCommitTrigger) Reset()
- func (m *InternalCommitTrigger) Size() (n int)
- func (m *InternalCommitTrigger) String() string
- func (m *InternalCommitTrigger) Unmarshal(dAtA []byte) error
- type InternalServer
- type InternalTimeSeriesData
- func (*InternalTimeSeriesData) Descriptor() ([]byte, []int)
- func (m *InternalTimeSeriesData) Marshal() (dAtA []byte, err error)
- func (m *InternalTimeSeriesData) MarshalTo(dAtA []byte) (int, error)
- func (*InternalTimeSeriesData) ProtoMessage()
- func (m *InternalTimeSeriesData) Reset()
- func (m *InternalTimeSeriesData) Size() (n int)
- func (m *InternalTimeSeriesData) String() string
- func (m *InternalTimeSeriesData) Unmarshal(dAtA []byte) error
- type InternalTimeSeriesSample
- func (samp InternalTimeSeriesSample) Average() float64
- func (*InternalTimeSeriesSample) Descriptor() ([]byte, []int)
- func (m *InternalTimeSeriesSample) Marshal() (dAtA []byte, err error)
- func (m *InternalTimeSeriesSample) MarshalTo(dAtA []byte) (int, error)
- func (samp InternalTimeSeriesSample) Maximum() float64
- func (samp InternalTimeSeriesSample) Minimum() float64
- func (*InternalTimeSeriesSample) ProtoMessage()
- func (m *InternalTimeSeriesSample) Reset()
- func (m *InternalTimeSeriesSample) Size() (n int)
- func (m *InternalTimeSeriesSample) String() string
- func (samp InternalTimeSeriesSample) Summation() float64
- func (m *InternalTimeSeriesSample) Unmarshal(dAtA []byte) error
- type Key
- type KeyValue
- func (*KeyValue) Descriptor() ([]byte, []int)
- func (m *KeyValue) Marshal() (dAtA []byte, err error)
- func (m *KeyValue) MarshalTo(dAtA []byte) (int, error)
- func (*KeyValue) ProtoMessage()
- func (m *KeyValue) Reset()
- func (m *KeyValue) Size() (n int)
- func (m *KeyValue) String() string
- func (m *KeyValue) Unmarshal(dAtA []byte) error
- type KeyValueByKey
- type Lease
- func (*Lease) Descriptor() ([]byte, []int)
- func (l Lease) Equivalent(ol Lease) error
- func (m *Lease) Marshal() (dAtA []byte, err error)
- func (m *Lease) MarshalTo(dAtA []byte) (int, error)
- func (l Lease) OwnedBy(storeID StoreID) bool
- func (*Lease) ProtoMessage()
- func (m *Lease) Reset()
- func (m *Lease) Size() (n int)
- func (l Lease) String() string
- func (l Lease) Type() LeaseType
- func (m *Lease) Unmarshal(dAtA []byte) error
- type LeaseInfoRequest
- func (*LeaseInfoRequest) Descriptor() ([]byte, []int)
- func (m *LeaseInfoRequest) Marshal() (dAtA []byte, err error)
- func (m *LeaseInfoRequest) MarshalTo(dAtA []byte) (int, error)
- func (*LeaseInfoRequest) Method() Method
- func (*LeaseInfoRequest) ProtoMessage()
- func (m *LeaseInfoRequest) Reset()
- func (lt *LeaseInfoRequest) ShallowCopy() Request
- func (m *LeaseInfoRequest) Size() (n int)
- func (m *LeaseInfoRequest) String() string
- func (m *LeaseInfoRequest) Unmarshal(dAtA []byte) error
- type LeaseInfoResponse
- func (*LeaseInfoResponse) Descriptor() ([]byte, []int)
- func (m *LeaseInfoResponse) Marshal() (dAtA []byte, err error)
- func (m *LeaseInfoResponse) MarshalTo(dAtA []byte) (int, error)
- func (*LeaseInfoResponse) ProtoMessage()
- func (m *LeaseInfoResponse) Reset()
- func (m *LeaseInfoResponse) Size() (n int)
- func (m *LeaseInfoResponse) String() string
- func (m *LeaseInfoResponse) Unmarshal(dAtA []byte) error
- type LeaseRejectedError
- func (*LeaseRejectedError) Descriptor() ([]byte, []int)
- func (e *LeaseRejectedError) Error() string
- func (m *LeaseRejectedError) Marshal() (dAtA []byte, err error)
- func (m *LeaseRejectedError) MarshalTo(dAtA []byte) (int, error)
- func (*LeaseRejectedError) ProtoMessage()
- func (m *LeaseRejectedError) Reset()
- func (m *LeaseRejectedError) Size() (n int)
- func (m *LeaseRejectedError) String() string
- func (m *LeaseRejectedError) Unmarshal(dAtA []byte) error
- type LeaseType
- type Locality
- func (*Locality) Descriptor() ([]byte, []int)
- func (l Locality) DiversityScore(other Locality) float64
- func (m *Locality) Marshal() (dAtA []byte, err error)
- func (m *Locality) MarshalTo(dAtA []byte) (int, error)
- func (*Locality) ProtoMessage()
- func (m *Locality) Reset()
- func (l *Locality) Set(value string) error
- func (m *Locality) Size() (n int)
- func (l Locality) String() string
- func (Locality) Type() string
- func (m *Locality) Unmarshal(dAtA []byte) error
- type MergeRequest
- func (*MergeRequest) Descriptor() ([]byte, []int)
- func (m *MergeRequest) Marshal() (dAtA []byte, err error)
- func (m *MergeRequest) MarshalTo(dAtA []byte) (int, error)
- func (*MergeRequest) Method() Method
- func (*MergeRequest) ProtoMessage()
- func (m *MergeRequest) Reset()
- func (mr *MergeRequest) ShallowCopy() Request
- func (m *MergeRequest) Size() (n int)
- func (m *MergeRequest) String() string
- func (m *MergeRequest) Unmarshal(dAtA []byte) error
- type MergeResponse
- func (*MergeResponse) Descriptor() ([]byte, []int)
- func (m *MergeResponse) Marshal() (dAtA []byte, err error)
- func (m *MergeResponse) MarshalTo(dAtA []byte) (int, error)
- func (*MergeResponse) ProtoMessage()
- func (m *MergeResponse) Reset()
- func (m *MergeResponse) Size() (n int)
- func (m *MergeResponse) String() string
- func (m *MergeResponse) Unmarshal(dAtA []byte) error
- type MergeTrigger
- func (*MergeTrigger) Descriptor() ([]byte, []int)
- func (m *MergeTrigger) Marshal() (dAtA []byte, err error)
- func (m *MergeTrigger) MarshalTo(dAtA []byte) (int, error)
- func (*MergeTrigger) ProtoMessage()
- func (m *MergeTrigger) Reset()
- func (m *MergeTrigger) Size() (n int)
- func (m *MergeTrigger) String() string
- func (m *MergeTrigger) Unmarshal(dAtA []byte) error
- type Method
- type ModifiedSpanTrigger
- func (*ModifiedSpanTrigger) Descriptor() ([]byte, []int)
- func (m *ModifiedSpanTrigger) Marshal() (dAtA []byte, err error)
- func (m *ModifiedSpanTrigger) MarshalTo(dAtA []byte) (int, error)
- func (*ModifiedSpanTrigger) ProtoMessage()
- func (m *ModifiedSpanTrigger) Reset()
- func (m *ModifiedSpanTrigger) Size() (n int)
- func (m *ModifiedSpanTrigger) String() string
- func (m *ModifiedSpanTrigger) Unmarshal(dAtA []byte) error
- type NodeDescriptor
- func (*NodeDescriptor) Descriptor() ([]byte, []int)
- func (m *NodeDescriptor) Marshal() (dAtA []byte, err error)
- func (m *NodeDescriptor) MarshalTo(dAtA []byte) (int, error)
- func (*NodeDescriptor) ProtoMessage()
- func (m *NodeDescriptor) Reset()
- func (m *NodeDescriptor) Size() (n int)
- func (m *NodeDescriptor) String() string
- func (m *NodeDescriptor) Unmarshal(dAtA []byte) error
- type NodeID
- type NodeUnavailableError
- func (*NodeUnavailableError) Descriptor() ([]byte, []int)
- func (e *NodeUnavailableError) Error() string
- func (m *NodeUnavailableError) Marshal() (dAtA []byte, err error)
- func (m *NodeUnavailableError) MarshalTo(dAtA []byte) (int, error)
- func (*NodeUnavailableError) ProtoMessage()
- func (m *NodeUnavailableError) Reset()
- func (m *NodeUnavailableError) Size() (n int)
- func (m *NodeUnavailableError) String() string
- func (m *NodeUnavailableError) Unmarshal(dAtA []byte) error
- type NoopRequest
- func (*NoopRequest) Descriptor() ([]byte, []int)
- func (*NoopRequest) Header() Span
- func (m *NoopRequest) Marshal() (dAtA []byte, err error)
- func (m *NoopRequest) MarshalTo(dAtA []byte) (int, error)
- func (*NoopRequest) Method() Method
- func (*NoopRequest) ProtoMessage()
- func (m *NoopRequest) Reset()
- func (*NoopRequest) SetHeader(_ Span)
- func (nr *NoopRequest) ShallowCopy() Request
- func (m *NoopRequest) Size() (n int)
- func (m *NoopRequest) String() string
- func (m *NoopRequest) Unmarshal(dAtA []byte) error
- type NoopResponse
- func (*NoopResponse) Descriptor() ([]byte, []int)
- func (*NoopResponse) Header() ResponseHeader
- func (m *NoopResponse) Marshal() (dAtA []byte, err error)
- func (m *NoopResponse) MarshalTo(dAtA []byte) (int, error)
- func (*NoopResponse) ProtoMessage()
- func (m *NoopResponse) Reset()
- func (*NoopResponse) SetHeader(_ ResponseHeader)
- func (m *NoopResponse) Size() (n int)
- func (m *NoopResponse) String() string
- func (m *NoopResponse) Unmarshal(dAtA []byte) error
- func (*NoopResponse) Verify(_ Request) error
- type NotLeaseHolderError
- func (*NotLeaseHolderError) Descriptor() ([]byte, []int)
- func (e *NotLeaseHolderError) Error() string
- func (m *NotLeaseHolderError) Marshal() (dAtA []byte, err error)
- func (m *NotLeaseHolderError) MarshalTo(dAtA []byte) (int, error)
- func (*NotLeaseHolderError) ProtoMessage()
- func (m *NotLeaseHolderError) Reset()
- func (m *NotLeaseHolderError) Size() (n int)
- func (m *NotLeaseHolderError) String() string
- func (m *NotLeaseHolderError) Unmarshal(dAtA []byte) error
- type NumericStat
- func (*NumericStat) Descriptor() ([]byte, []int)
- func (l *NumericStat) GetVariance(count int64) float64
- func (m *NumericStat) Marshal() (dAtA []byte, err error)
- func (m *NumericStat) MarshalTo(dAtA []byte) (int, error)
- func (*NumericStat) ProtoMessage()
- func (l *NumericStat) Record(count int64, val float64)
- func (m *NumericStat) Reset()
- func (m *NumericStat) Size() (n int)
- func (m *NumericStat) String() string
- func (m *NumericStat) Unmarshal(dAtA []byte) error
- type ObservedTimestamp
- func (*ObservedTimestamp) Descriptor() ([]byte, []int)
- func (m *ObservedTimestamp) Marshal() (dAtA []byte, err error)
- func (m *ObservedTimestamp) MarshalTo(dAtA []byte) (int, error)
- func (*ObservedTimestamp) ProtoMessage()
- func (m *ObservedTimestamp) Reset()
- func (m *ObservedTimestamp) Size() (n int)
- func (m *ObservedTimestamp) String() string
- func (m *ObservedTimestamp) Unmarshal(dAtA []byte) error
- type OpRequiresTxnError
- func (*OpRequiresTxnError) Descriptor() ([]byte, []int)
- func (e *OpRequiresTxnError) Error() string
- func (m *OpRequiresTxnError) Marshal() (dAtA []byte, err error)
- func (m *OpRequiresTxnError) MarshalTo(dAtA []byte) (int, error)
- func (*OpRequiresTxnError) ProtoMessage()
- func (m *OpRequiresTxnError) Reset()
- func (m *OpRequiresTxnError) Size() (n int)
- func (m *OpRequiresTxnError) String() string
- func (m *OpRequiresTxnError) Unmarshal(dAtA []byte) error
- type PushTxnRequest
- func (*PushTxnRequest) Descriptor() ([]byte, []int)
- func (m *PushTxnRequest) Marshal() (dAtA []byte, err error)
- func (m *PushTxnRequest) MarshalTo(dAtA []byte) (int, error)
- func (*PushTxnRequest) Method() Method
- func (*PushTxnRequest) ProtoMessage()
- func (m *PushTxnRequest) Reset()
- func (ptr *PushTxnRequest) ShallowCopy() Request
- func (m *PushTxnRequest) Size() (n int)
- func (m *PushTxnRequest) String() string
- func (m *PushTxnRequest) Unmarshal(dAtA []byte) error
- type PushTxnResponse
- func (*PushTxnResponse) Descriptor() ([]byte, []int)
- func (m *PushTxnResponse) Marshal() (dAtA []byte, err error)
- func (m *PushTxnResponse) MarshalTo(dAtA []byte) (int, error)
- func (*PushTxnResponse) ProtoMessage()
- func (m *PushTxnResponse) Reset()
- func (m *PushTxnResponse) Size() (n int)
- func (m *PushTxnResponse) String() string
- func (m *PushTxnResponse) Unmarshal(dAtA []byte) error
- type PushTxnType
- type PutRequest
- func (*PutRequest) Descriptor() ([]byte, []int)
- func (m *PutRequest) Marshal() (dAtA []byte, err error)
- func (m *PutRequest) MarshalTo(dAtA []byte) (int, error)
- func (*PutRequest) Method() Method
- func (*PutRequest) ProtoMessage()
- func (m *PutRequest) Reset()
- func (pr *PutRequest) ShallowCopy() Request
- func (m *PutRequest) Size() (n int)
- func (m *PutRequest) String() string
- func (m *PutRequest) Unmarshal(dAtA []byte) error
- type PutResponse
- func (*PutResponse) Descriptor() ([]byte, []int)
- func (m *PutResponse) Marshal() (dAtA []byte, err error)
- func (m *PutResponse) MarshalTo(dAtA []byte) (int, error)
- func (*PutResponse) ProtoMessage()
- func (m *PutResponse) Reset()
- func (m *PutResponse) Size() (n int)
- func (m *PutResponse) String() string
- func (m *PutResponse) Unmarshal(dAtA []byte) error
- type QueryTxnRequest
- func (*QueryTxnRequest) Descriptor() ([]byte, []int)
- func (m *QueryTxnRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryTxnRequest) MarshalTo(dAtA []byte) (int, error)
- func (*QueryTxnRequest) Method() Method
- func (*QueryTxnRequest) ProtoMessage()
- func (m *QueryTxnRequest) Reset()
- func (qtr *QueryTxnRequest) ShallowCopy() Request
- func (m *QueryTxnRequest) Size() (n int)
- func (m *QueryTxnRequest) String() string
- func (m *QueryTxnRequest) Unmarshal(dAtA []byte) error
- type QueryTxnResponse
- func (*QueryTxnResponse) Descriptor() ([]byte, []int)
- func (m *QueryTxnResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryTxnResponse) MarshalTo(dAtA []byte) (int, error)
- func (*QueryTxnResponse) ProtoMessage()
- func (m *QueryTxnResponse) Reset()
- func (m *QueryTxnResponse) Size() (n int)
- func (m *QueryTxnResponse) String() string
- func (m *QueryTxnResponse) Unmarshal(dAtA []byte) error
- type RKey
- type RSpan
- func (rs RSpan) ContainsExclusiveEndKey(key RKey) bool
- func (rs RSpan) ContainsKey(key RKey) bool
- func (rs RSpan) ContainsKeyRange(start, end RKey) bool
- func (rs RSpan) Equal(o RSpan) bool
- func (rs RSpan) Intersect(desc *RangeDescriptor) (RSpan, error)
- func (rs RSpan) Overlaps(other RSpan) bool
- func (rs RSpan) String() string
- type RaftGroupDeletedError
- func (*RaftGroupDeletedError) Descriptor() ([]byte, []int)
- func (e *RaftGroupDeletedError) Error() string
- func (m *RaftGroupDeletedError) Marshal() (dAtA []byte, err error)
- func (m *RaftGroupDeletedError) MarshalTo(dAtA []byte) (int, error)
- func (*RaftGroupDeletedError) ProtoMessage()
- func (m *RaftGroupDeletedError) Reset()
- func (m *RaftGroupDeletedError) Size() (n int)
- func (m *RaftGroupDeletedError) String() string
- func (m *RaftGroupDeletedError) Unmarshal(dAtA []byte) error
- type RaftSnapshotData
- func (*RaftSnapshotData) Descriptor() ([]byte, []int)
- func (m *RaftSnapshotData) Marshal() (dAtA []byte, err error)
- func (m *RaftSnapshotData) MarshalTo(dAtA []byte) (int, error)
- func (*RaftSnapshotData) ProtoMessage()
- func (m *RaftSnapshotData) Reset()
- func (m *RaftSnapshotData) Size() (n int)
- func (m *RaftSnapshotData) String() string
- func (m *RaftSnapshotData) Unmarshal(dAtA []byte) error
- type RaftSnapshotData_KeyValue
- func (*RaftSnapshotData_KeyValue) Descriptor() ([]byte, []int)
- func (m *RaftSnapshotData_KeyValue) Marshal() (dAtA []byte, err error)
- func (m *RaftSnapshotData_KeyValue) MarshalTo(dAtA []byte) (int, error)
- func (*RaftSnapshotData_KeyValue) ProtoMessage()
- func (m *RaftSnapshotData_KeyValue) Reset()
- func (m *RaftSnapshotData_KeyValue) Size() (n int)
- func (m *RaftSnapshotData_KeyValue) String() string
- func (m *RaftSnapshotData_KeyValue) Unmarshal(dAtA []byte) error
- type RaftTombstone
- func (*RaftTombstone) Descriptor() ([]byte, []int)
- func (m *RaftTombstone) Marshal() (dAtA []byte, err error)
- func (m *RaftTombstone) MarshalTo(dAtA []byte) (int, error)
- func (*RaftTombstone) ProtoMessage()
- func (m *RaftTombstone) Reset()
- func (m *RaftTombstone) Size() (n int)
- func (m *RaftTombstone) String() string
- func (m *RaftTombstone) Unmarshal(dAtA []byte) error
- type RaftTruncatedState
- func (*RaftTruncatedState) Descriptor() ([]byte, []int)
- func (m *RaftTruncatedState) Marshal() (dAtA []byte, err error)
- func (m *RaftTruncatedState) MarshalTo(dAtA []byte) (int, error)
- func (*RaftTruncatedState) ProtoMessage()
- func (m *RaftTruncatedState) Reset()
- func (m *RaftTruncatedState) Size() (n int)
- func (m *RaftTruncatedState) String() string
- func (m *RaftTruncatedState) Unmarshal(dAtA []byte) error
- type RangeDescriptor
- func (r RangeDescriptor) ContainsExclusiveEndKey(key RKey) bool
- func (r RangeDescriptor) ContainsKey(key RKey) bool
- func (r RangeDescriptor) ContainsKeyRange(start, end RKey) bool
- func (*RangeDescriptor) Descriptor() ([]byte, []int)
- func (this *RangeDescriptor) Equal(that interface{}) bool
- func (r RangeDescriptor) GetReplicaDescriptor(storeID StoreID) (ReplicaDescriptor, bool)
- func (r RangeDescriptor) GetReplicaDescriptorByID(replicaID ReplicaID) (ReplicaDescriptor, bool)
- func (r RangeDescriptor) IsInitialized() bool
- func (m *RangeDescriptor) Marshal() (dAtA []byte, err error)
- func (m *RangeDescriptor) MarshalTo(dAtA []byte) (int, error)
- func (*RangeDescriptor) ProtoMessage()
- func (r RangeDescriptor) RSpan() RSpan
- func (m *RangeDescriptor) Reset()
- func (m *RangeDescriptor) Size() (n int)
- func (r RangeDescriptor) String() string
- func (m *RangeDescriptor) Unmarshal(dAtA []byte) error
- func (r RangeDescriptor) Validate() error
- type RangeID
- type RangeIDSlice
- type RangeInfo
- func (*RangeInfo) Descriptor() ([]byte, []int)
- func (m *RangeInfo) Marshal() (dAtA []byte, err error)
- func (m *RangeInfo) MarshalTo(dAtA []byte) (int, error)
- func (*RangeInfo) ProtoMessage()
- func (m *RangeInfo) Reset()
- func (m *RangeInfo) Size() (n int)
- func (m *RangeInfo) String() string
- func (m *RangeInfo) Unmarshal(dAtA []byte) error
- type RangeKeyMismatchError
- func (*RangeKeyMismatchError) Descriptor() ([]byte, []int)
- func (e *RangeKeyMismatchError) Error() string
- func (m *RangeKeyMismatchError) Marshal() (dAtA []byte, err error)
- func (m *RangeKeyMismatchError) MarshalTo(dAtA []byte) (int, error)
- func (*RangeKeyMismatchError) ProtoMessage()
- func (m *RangeKeyMismatchError) Reset()
- func (m *RangeKeyMismatchError) Size() (n int)
- func (m *RangeKeyMismatchError) String() string
- func (m *RangeKeyMismatchError) Unmarshal(dAtA []byte) error
- type RangeLookupRequest
- func (*RangeLookupRequest) Descriptor() ([]byte, []int)
- func (m *RangeLookupRequest) Marshal() (dAtA []byte, err error)
- func (m *RangeLookupRequest) MarshalTo(dAtA []byte) (int, error)
- func (*RangeLookupRequest) Method() Method
- func (*RangeLookupRequest) ProtoMessage()
- func (m *RangeLookupRequest) Reset()
- func (rlr *RangeLookupRequest) ShallowCopy() Request
- func (m *RangeLookupRequest) Size() (n int)
- func (m *RangeLookupRequest) String() string
- func (m *RangeLookupRequest) Unmarshal(dAtA []byte) error
- type RangeLookupResponse
- func (*RangeLookupResponse) Descriptor() ([]byte, []int)
- func (m *RangeLookupResponse) Marshal() (dAtA []byte, err error)
- func (m *RangeLookupResponse) MarshalTo(dAtA []byte) (int, error)
- func (*RangeLookupResponse) ProtoMessage()
- func (m *RangeLookupResponse) Reset()
- func (m *RangeLookupResponse) Size() (n int)
- func (m *RangeLookupResponse) String() string
- func (m *RangeLookupResponse) Unmarshal(dAtA []byte) error
- type RangeNotFoundError
- func (*RangeNotFoundError) Descriptor() ([]byte, []int)
- func (e *RangeNotFoundError) Error() string
- func (m *RangeNotFoundError) Marshal() (dAtA []byte, err error)
- func (m *RangeNotFoundError) MarshalTo(dAtA []byte) (int, error)
- func (*RangeNotFoundError) ProtoMessage()
- func (m *RangeNotFoundError) Reset()
- func (m *RangeNotFoundError) Size() (n int)
- func (m *RangeNotFoundError) String() string
- func (m *RangeNotFoundError) Unmarshal(dAtA []byte) error
- type ReadConsistencyType
- type ReadWithinUncertaintyIntervalError
- func (*ReadWithinUncertaintyIntervalError) Descriptor() ([]byte, []int)
- func (e *ReadWithinUncertaintyIntervalError) Error() string
- func (m *ReadWithinUncertaintyIntervalError) Marshal() (dAtA []byte, err error)
- func (m *ReadWithinUncertaintyIntervalError) MarshalTo(dAtA []byte) (int, error)
- func (*ReadWithinUncertaintyIntervalError) ProtoMessage()
- func (m *ReadWithinUncertaintyIntervalError) Reset()
- func (m *ReadWithinUncertaintyIntervalError) Size() (n int)
- func (m *ReadWithinUncertaintyIntervalError) String() string
- func (m *ReadWithinUncertaintyIntervalError) Unmarshal(dAtA []byte) error
- type ReplicaChangeType
- type ReplicaCorruptionError
- func (*ReplicaCorruptionError) Descriptor() ([]byte, []int)
- func (e *ReplicaCorruptionError) Error() string
- func (m *ReplicaCorruptionError) Marshal() (dAtA []byte, err error)
- func (m *ReplicaCorruptionError) MarshalTo(dAtA []byte) (int, error)
- func (*ReplicaCorruptionError) ProtoMessage()
- func (m *ReplicaCorruptionError) Reset()
- func (m *ReplicaCorruptionError) Size() (n int)
- func (m *ReplicaCorruptionError) String() string
- func (m *ReplicaCorruptionError) Unmarshal(dAtA []byte) error
- type ReplicaDescriptor
- func (*ReplicaDescriptor) Descriptor() ([]byte, []int)
- func (this *ReplicaDescriptor) Equal(that interface{}) bool
- func (m *ReplicaDescriptor) Marshal() (dAtA []byte, err error)
- func (m *ReplicaDescriptor) MarshalTo(dAtA []byte) (int, error)
- func (*ReplicaDescriptor) ProtoMessage()
- func (m *ReplicaDescriptor) Reset()
- func (m *ReplicaDescriptor) Size() (n int)
- func (r ReplicaDescriptor) String() string
- func (m *ReplicaDescriptor) Unmarshal(dAtA []byte) error
- func (r ReplicaDescriptor) Validate() error
- type ReplicaID
- type ReplicaIdent
- func (*ReplicaIdent) Descriptor() ([]byte, []int)
- func (m *ReplicaIdent) Marshal() (dAtA []byte, err error)
- func (m *ReplicaIdent) MarshalTo(dAtA []byte) (int, error)
- func (*ReplicaIdent) ProtoMessage()
- func (m *ReplicaIdent) Reset()
- func (m *ReplicaIdent) Size() (n int)
- func (m *ReplicaIdent) String() string
- func (m *ReplicaIdent) Unmarshal(dAtA []byte) error
- type ReplicaTooOldError
- func (*ReplicaTooOldError) Descriptor() ([]byte, []int)
- func (e *ReplicaTooOldError) Error() string
- func (m *ReplicaTooOldError) Marshal() (dAtA []byte, err error)
- func (m *ReplicaTooOldError) MarshalTo(dAtA []byte) (int, error)
- func (*ReplicaTooOldError) ProtoMessage()
- func (m *ReplicaTooOldError) Reset()
- func (m *ReplicaTooOldError) Size() (n int)
- func (m *ReplicaTooOldError) String() string
- func (m *ReplicaTooOldError) Unmarshal(dAtA []byte) error
- type ReplicationTarget
- func (*ReplicationTarget) Descriptor() ([]byte, []int)
- func (m *ReplicationTarget) Marshal() (dAtA []byte, err error)
- func (m *ReplicationTarget) MarshalTo(dAtA []byte) (int, error)
- func (*ReplicationTarget) ProtoMessage()
- func (m *ReplicationTarget) Reset()
- func (m *ReplicationTarget) Size() (n int)
- func (r ReplicationTarget) String() string
- func (m *ReplicationTarget) Unmarshal(dAtA []byte) error
- type Request
- func NewCheckConsistency(key, endKey Key, withDiff bool) Request
- func NewConditionalPut(key Key, value, expValue Value) Request
- func NewDelete(key Key) Request
- func NewDeleteRange(startKey, endKey Key, returnKeys bool) Request
- func NewGet(key Key) Request
- func NewIncrement(key Key, increment int64) Request
- func NewInitPut(key Key, value Value) Request
- func NewPut(key Key, value Value) Request
- func NewPutInline(key Key, value Value) Request
- func NewReverseScan(key, endKey Key) Request
- func NewScan(key, endKey Key) Request
- type RequestLeaseRequest
- func (*RequestLeaseRequest) Descriptor() ([]byte, []int)
- func (m *RequestLeaseRequest) Marshal() (dAtA []byte, err error)
- func (m *RequestLeaseRequest) MarshalTo(dAtA []byte) (int, error)
- func (*RequestLeaseRequest) Method() Method
- func (*RequestLeaseRequest) ProtoMessage()
- func (m *RequestLeaseRequest) Reset()
- func (rlr *RequestLeaseRequest) ShallowCopy() Request
- func (m *RequestLeaseRequest) Size() (n int)
- func (m *RequestLeaseRequest) String() string
- func (m *RequestLeaseRequest) Unmarshal(dAtA []byte) error
- type RequestLeaseResponse
- func (*RequestLeaseResponse) Descriptor() ([]byte, []int)
- func (m *RequestLeaseResponse) Marshal() (dAtA []byte, err error)
- func (m *RequestLeaseResponse) MarshalTo(dAtA []byte) (int, error)
- func (*RequestLeaseResponse) ProtoMessage()
- func (m *RequestLeaseResponse) Reset()
- func (m *RequestLeaseResponse) Size() (n int)
- func (m *RequestLeaseResponse) String() string
- func (m *RequestLeaseResponse) Unmarshal(dAtA []byte) error
- type RequestUnion
- func (*RequestUnion) Descriptor() ([]byte, []int)
- func (ru RequestUnion) GetInner() Request
- func (this *RequestUnion) GetValue() interface{}
- func (m *RequestUnion) Marshal() (dAtA []byte, err error)
- func (m *RequestUnion) MarshalTo(dAtA []byte) (int, error)
- func (ru *RequestUnion) MustSetInner(args Request)
- func (*RequestUnion) ProtoMessage()
- func (m *RequestUnion) Reset()
- func (this *RequestUnion) SetValue(value interface{}) bool
- func (m *RequestUnion) Size() (n int)
- func (m *RequestUnion) String() string
- func (m *RequestUnion) Unmarshal(dAtA []byte) error
- type ResolveIntentRangeRequest
- func (*ResolveIntentRangeRequest) Descriptor() ([]byte, []int)
- func (m *ResolveIntentRangeRequest) Marshal() (dAtA []byte, err error)
- func (m *ResolveIntentRangeRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ResolveIntentRangeRequest) Method() Method
- func (*ResolveIntentRangeRequest) ProtoMessage()
- func (m *ResolveIntentRangeRequest) Reset()
- func (rirr *ResolveIntentRangeRequest) ShallowCopy() Request
- func (m *ResolveIntentRangeRequest) Size() (n int)
- func (m *ResolveIntentRangeRequest) String() string
- func (m *ResolveIntentRangeRequest) Unmarshal(dAtA []byte) error
- type ResolveIntentRangeResponse
- func (*ResolveIntentRangeResponse) Descriptor() ([]byte, []int)
- func (m *ResolveIntentRangeResponse) Marshal() (dAtA []byte, err error)
- func (m *ResolveIntentRangeResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ResolveIntentRangeResponse) ProtoMessage()
- func (m *ResolveIntentRangeResponse) Reset()
- func (m *ResolveIntentRangeResponse) Size() (n int)
- func (m *ResolveIntentRangeResponse) String() string
- func (m *ResolveIntentRangeResponse) Unmarshal(dAtA []byte) error
- type ResolveIntentRequest
- func (*ResolveIntentRequest) Descriptor() ([]byte, []int)
- func (m *ResolveIntentRequest) Marshal() (dAtA []byte, err error)
- func (m *ResolveIntentRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ResolveIntentRequest) Method() Method
- func (*ResolveIntentRequest) ProtoMessage()
- func (m *ResolveIntentRequest) Reset()
- func (rir *ResolveIntentRequest) ShallowCopy() Request
- func (m *ResolveIntentRequest) Size() (n int)
- func (m *ResolveIntentRequest) String() string
- func (m *ResolveIntentRequest) Unmarshal(dAtA []byte) error
- type ResolveIntentResponse
- func (*ResolveIntentResponse) Descriptor() ([]byte, []int)
- func (m *ResolveIntentResponse) Marshal() (dAtA []byte, err error)
- func (m *ResolveIntentResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ResolveIntentResponse) ProtoMessage()
- func (m *ResolveIntentResponse) Reset()
- func (m *ResolveIntentResponse) Size() (n int)
- func (m *ResolveIntentResponse) String() string
- func (m *ResolveIntentResponse) Unmarshal(dAtA []byte) error
- type Response
- type ResponseHeader
- func (*ResponseHeader) Descriptor() ([]byte, []int)
- func (rh ResponseHeader) Header() ResponseHeader
- func (m *ResponseHeader) Marshal() (dAtA []byte, err error)
- func (m *ResponseHeader) MarshalTo(dAtA []byte) (int, error)
- func (*ResponseHeader) ProtoMessage()
- func (m *ResponseHeader) Reset()
- func (rh *ResponseHeader) SetHeader(other ResponseHeader)
- func (m *ResponseHeader) Size() (n int)
- func (m *ResponseHeader) String() string
- func (m *ResponseHeader) Unmarshal(dAtA []byte) error
- func (rh *ResponseHeader) Verify(req Request) error
- type ResponseUnion
- func (*ResponseUnion) Descriptor() ([]byte, []int)
- func (ru ResponseUnion) GetInner() Response
- func (this *ResponseUnion) GetValue() interface{}
- func (m *ResponseUnion) Marshal() (dAtA []byte, err error)
- func (m *ResponseUnion) MarshalTo(dAtA []byte) (int, error)
- func (ru *ResponseUnion) MustSetInner(reply Response)
- func (*ResponseUnion) ProtoMessage()
- func (m *ResponseUnion) Reset()
- func (this *ResponseUnion) SetValue(value interface{}) bool
- func (m *ResponseUnion) Size() (n int)
- func (m *ResponseUnion) String() string
- func (m *ResponseUnion) Unmarshal(dAtA []byte) error
- type ReverseScanRequest
- func (*ReverseScanRequest) Descriptor() ([]byte, []int)
- func (m *ReverseScanRequest) Marshal() (dAtA []byte, err error)
- func (m *ReverseScanRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ReverseScanRequest) Method() Method
- func (*ReverseScanRequest) ProtoMessage()
- func (m *ReverseScanRequest) Reset()
- func (rsr *ReverseScanRequest) ShallowCopy() Request
- func (m *ReverseScanRequest) Size() (n int)
- func (m *ReverseScanRequest) String() string
- func (m *ReverseScanRequest) Unmarshal(dAtA []byte) error
- type ReverseScanResponse
- func (*ReverseScanResponse) Descriptor() ([]byte, []int)
- func (m *ReverseScanResponse) Marshal() (dAtA []byte, err error)
- func (m *ReverseScanResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ReverseScanResponse) ProtoMessage()
- func (m *ReverseScanResponse) Reset()
- func (m *ReverseScanResponse) Size() (n int)
- func (m *ReverseScanResponse) String() string
- func (m *ReverseScanResponse) Unmarshal(dAtA []byte) error
- func (sr *ReverseScanResponse) Verify(req Request) error
- type ScanRequest
- func (*ScanRequest) Descriptor() ([]byte, []int)
- func (m *ScanRequest) Marshal() (dAtA []byte, err error)
- func (m *ScanRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ScanRequest) Method() Method
- func (*ScanRequest) ProtoMessage()
- func (m *ScanRequest) Reset()
- func (sr *ScanRequest) ShallowCopy() Request
- func (m *ScanRequest) Size() (n int)
- func (m *ScanRequest) String() string
- func (m *ScanRequest) Unmarshal(dAtA []byte) error
- type ScanResponse
- func (*ScanResponse) Descriptor() ([]byte, []int)
- func (m *ScanResponse) Marshal() (dAtA []byte, err error)
- func (m *ScanResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ScanResponse) ProtoMessage()
- func (m *ScanResponse) Reset()
- func (m *ScanResponse) Size() (n int)
- func (m *ScanResponse) String() string
- func (m *ScanResponse) Unmarshal(dAtA []byte) error
- func (sr *ScanResponse) Verify(req Request) error
- type SendError
- func (*SendError) Descriptor() ([]byte, []int)
- func (s SendError) Error() string
- func (m *SendError) Marshal() (dAtA []byte, err error)
- func (m *SendError) MarshalTo(dAtA []byte) (int, error)
- func (*SendError) ProtoMessage()
- func (m *SendError) Reset()
- func (m *SendError) Size() (n int)
- func (m *SendError) String() string
- func (m *SendError) Unmarshal(dAtA []byte) error
- type Span
- func (s Span) AsRange() interval.Range
- func (s Span) Contains(o Span) bool
- func (*Span) Descriptor() ([]byte, []int)
- func (s Span) Equal(o Span) bool
- func (rh Span) Header() Span
- func (m *Span) Marshal() (dAtA []byte, err error)
- func (m *Span) MarshalTo(dAtA []byte) (int, error)
- func (s Span) Overlaps(o Span) bool
- func (*Span) ProtoMessage()
- func (m *Span) Reset()
- func (rh *Span) SetHeader(other Span)
- func (m *Span) Size() (n int)
- func (s Span) String() string
- func (m *Span) Unmarshal(dAtA []byte) error
- type Spans
- type SplitTrigger
- func (*SplitTrigger) Descriptor() ([]byte, []int)
- func (m *SplitTrigger) Marshal() (dAtA []byte, err error)
- func (m *SplitTrigger) MarshalTo(dAtA []byte) (int, error)
- func (*SplitTrigger) ProtoMessage()
- func (m *SplitTrigger) Reset()
- func (m *SplitTrigger) Size() (n int)
- func (m *SplitTrigger) String() string
- func (m *SplitTrigger) Unmarshal(dAtA []byte) error
- type StatementStatistics
- func (*StatementStatistics) Descriptor() ([]byte, []int)
- func (m *StatementStatistics) Marshal() (dAtA []byte, err error)
- func (m *StatementStatistics) MarshalTo(dAtA []byte) (int, error)
- func (*StatementStatistics) ProtoMessage()
- func (m *StatementStatistics) Reset()
- func (m *StatementStatistics) Size() (n int)
- func (m *StatementStatistics) String() string
- func (m *StatementStatistics) Unmarshal(dAtA []byte) error
- type StoreCapacity
- func (*StoreCapacity) Descriptor() ([]byte, []int)
- func (sc StoreCapacity) FractionUsed() float64
- func (m *StoreCapacity) Marshal() (dAtA []byte, err error)
- func (m *StoreCapacity) MarshalTo(dAtA []byte) (int, error)
- func (*StoreCapacity) ProtoMessage()
- func (m *StoreCapacity) Reset()
- func (m *StoreCapacity) Size() (n int)
- func (m *StoreCapacity) String() string
- func (m *StoreCapacity) Unmarshal(dAtA []byte) error
- type StoreDeadReplicas
- func (*StoreDeadReplicas) Descriptor() ([]byte, []int)
- func (m *StoreDeadReplicas) Marshal() (dAtA []byte, err error)
- func (m *StoreDeadReplicas) MarshalTo(dAtA []byte) (int, error)
- func (*StoreDeadReplicas) ProtoMessage()
- func (m *StoreDeadReplicas) Reset()
- func (m *StoreDeadReplicas) Size() (n int)
- func (m *StoreDeadReplicas) String() string
- func (m *StoreDeadReplicas) Unmarshal(dAtA []byte) error
- type StoreDescriptor
- func (s StoreDescriptor) CombinedAttrs() *Attributes
- func (*StoreDescriptor) Descriptor() ([]byte, []int)
- func (m *StoreDescriptor) Marshal() (dAtA []byte, err error)
- func (m *StoreDescriptor) MarshalTo(dAtA []byte) (int, error)
- func (*StoreDescriptor) ProtoMessage()
- func (m *StoreDescriptor) Reset()
- func (m *StoreDescriptor) Size() (n int)
- func (m *StoreDescriptor) String() string
- func (m *StoreDescriptor) Unmarshal(dAtA []byte) error
- type StoreID
- type StoreIDSlice
- type StoreIdent
- func (*StoreIdent) Descriptor() ([]byte, []int)
- func (m *StoreIdent) Marshal() (dAtA []byte, err error)
- func (m *StoreIdent) MarshalTo(dAtA []byte) (int, error)
- func (*StoreIdent) ProtoMessage()
- func (m *StoreIdent) Reset()
- func (m *StoreIdent) Size() (n int)
- func (m *StoreIdent) String() string
- func (m *StoreIdent) Unmarshal(dAtA []byte) error
- type StoreNotFoundError
- func (*StoreNotFoundError) Descriptor() ([]byte, []int)
- func (e *StoreNotFoundError) Error() string
- func (m *StoreNotFoundError) Marshal() (dAtA []byte, err error)
- func (m *StoreNotFoundError) MarshalTo(dAtA []byte) (int, error)
- func (*StoreNotFoundError) ProtoMessage()
- func (m *StoreNotFoundError) Reset()
- func (m *StoreNotFoundError) Size() (n int)
- func (m *StoreNotFoundError) String() string
- func (m *StoreNotFoundError) Unmarshal(dAtA []byte) error
- type Tier
- func (*Tier) Descriptor() ([]byte, []int)
- func (t *Tier) FromString(tier string) error
- func (m *Tier) Marshal() (dAtA []byte, err error)
- func (m *Tier) MarshalTo(dAtA []byte) (int, error)
- func (*Tier) ProtoMessage()
- func (m *Tier) Reset()
- func (m *Tier) Size() (n int)
- func (t Tier) String() string
- func (m *Tier) Unmarshal(dAtA []byte) error
- type Transaction
- func (t Transaction) Clone() Transaction
- func (*Transaction) Descriptor() ([]byte, []int)
- func (t *Transaction) Equal(s *Transaction) bool
- func (t Transaction) GetObservedTimestamp(nodeID NodeID) (hlc.Timestamp, bool)
- func (t *Transaction) IsInitialized() bool
- func (t Transaction) LastActive() hlc.Timestamp
- func (m *Transaction) Marshal() (dAtA []byte, err error)
- func (m *Transaction) MarshalTo(dAtA []byte) (int, error)
- func (*Transaction) ProtoMessage()
- func (m *Transaction) Reset()
- func (t *Transaction) ResetObservedTimestamps()
- func (t *Transaction) Restart(userPriority UserPriority, upgradePriority int32, timestamp hlc.Timestamp)
- func (m *Transaction) Size() (n int)
- func (t Transaction) String() string
- func (m *Transaction) Unmarshal(dAtA []byte) error
- func (t *Transaction) Update(o *Transaction)
- func (t *Transaction) UpdateObservedTimestamp(nodeID NodeID, maxTS hlc.Timestamp)
- func (t *Transaction) UpgradePriority(minPriority int32)
- type TransactionAbortedError
- func (*TransactionAbortedError) Descriptor() ([]byte, []int)
- func (e *TransactionAbortedError) Error() string
- func (m *TransactionAbortedError) Marshal() (dAtA []byte, err error)
- func (m *TransactionAbortedError) MarshalTo(dAtA []byte) (int, error)
- func (*TransactionAbortedError) ProtoMessage()
- func (m *TransactionAbortedError) Reset()
- func (m *TransactionAbortedError) Size() (n int)
- func (m *TransactionAbortedError) String() string
- func (m *TransactionAbortedError) Unmarshal(dAtA []byte) error
- type TransactionPushError
- func (*TransactionPushError) Descriptor() ([]byte, []int)
- func (e *TransactionPushError) Error() string
- func (m *TransactionPushError) Marshal() (dAtA []byte, err error)
- func (m *TransactionPushError) MarshalTo(dAtA []byte) (int, error)
- func (*TransactionPushError) ProtoMessage()
- func (m *TransactionPushError) Reset()
- func (m *TransactionPushError) Size() (n int)
- func (m *TransactionPushError) String() string
- func (m *TransactionPushError) Unmarshal(dAtA []byte) error
- type TransactionReplayError
- func (*TransactionReplayError) Descriptor() ([]byte, []int)
- func (e *TransactionReplayError) Error() string
- func (m *TransactionReplayError) Marshal() (dAtA []byte, err error)
- func (m *TransactionReplayError) MarshalTo(dAtA []byte) (int, error)
- func (*TransactionReplayError) ProtoMessage()
- func (m *TransactionReplayError) Reset()
- func (m *TransactionReplayError) Size() (n int)
- func (m *TransactionReplayError) String() string
- func (m *TransactionReplayError) Unmarshal(dAtA []byte) error
- type TransactionRestart
- type TransactionRetryError
- func (*TransactionRetryError) Descriptor() ([]byte, []int)
- func (e *TransactionRetryError) Error() string
- func (m *TransactionRetryError) Marshal() (dAtA []byte, err error)
- func (m *TransactionRetryError) MarshalTo(dAtA []byte) (int, error)
- func (*TransactionRetryError) ProtoMessage()
- func (m *TransactionRetryError) Reset()
- func (m *TransactionRetryError) Size() (n int)
- func (m *TransactionRetryError) String() string
- func (m *TransactionRetryError) Unmarshal(dAtA []byte) error
- type TransactionRetryReason
- type TransactionStatus
- type TransactionStatusError
- func (*TransactionStatusError) Descriptor() ([]byte, []int)
- func (e *TransactionStatusError) Error() string
- func (m *TransactionStatusError) Marshal() (dAtA []byte, err error)
- func (m *TransactionStatusError) MarshalTo(dAtA []byte) (int, error)
- func (*TransactionStatusError) ProtoMessage()
- func (m *TransactionStatusError) Reset()
- func (m *TransactionStatusError) Size() (n int)
- func (m *TransactionStatusError) String() string
- func (m *TransactionStatusError) Unmarshal(dAtA []byte) error
- type TransferLeaseRequest
- func (*TransferLeaseRequest) Descriptor() ([]byte, []int)
- func (m *TransferLeaseRequest) Marshal() (dAtA []byte, err error)
- func (m *TransferLeaseRequest) MarshalTo(dAtA []byte) (int, error)
- func (*TransferLeaseRequest) Method() Method
- func (*TransferLeaseRequest) ProtoMessage()
- func (m *TransferLeaseRequest) Reset()
- func (tlr *TransferLeaseRequest) ShallowCopy() Request
- func (m *TransferLeaseRequest) Size() (n int)
- func (m *TransferLeaseRequest) String() string
- func (m *TransferLeaseRequest) Unmarshal(dAtA []byte) error
- type TruncateLogRequest
- func (*TruncateLogRequest) Descriptor() ([]byte, []int)
- func (m *TruncateLogRequest) Marshal() (dAtA []byte, err error)
- func (m *TruncateLogRequest) MarshalTo(dAtA []byte) (int, error)
- func (*TruncateLogRequest) Method() Method
- func (*TruncateLogRequest) ProtoMessage()
- func (m *TruncateLogRequest) Reset()
- func (tlr *TruncateLogRequest) ShallowCopy() Request
- func (m *TruncateLogRequest) Size() (n int)
- func (m *TruncateLogRequest) String() string
- func (m *TruncateLogRequest) Unmarshal(dAtA []byte) error
- type TruncateLogResponse
- func (*TruncateLogResponse) Descriptor() ([]byte, []int)
- func (m *TruncateLogResponse) Marshal() (dAtA []byte, err error)
- func (m *TruncateLogResponse) MarshalTo(dAtA []byte) (int, error)
- func (*TruncateLogResponse) ProtoMessage()
- func (m *TruncateLogResponse) Reset()
- func (m *TruncateLogResponse) Size() (n int)
- func (m *TruncateLogResponse) String() string
- func (m *TruncateLogResponse) Unmarshal(dAtA []byte) error
- type UnhandledRetryableError
- func (*UnhandledRetryableError) Descriptor() ([]byte, []int)
- func (e *UnhandledRetryableError) Error() string
- func (m *UnhandledRetryableError) Marshal() (dAtA []byte, err error)
- func (m *UnhandledRetryableError) MarshalTo(dAtA []byte) (int, error)
- func (*UnhandledRetryableError) ProtoMessage()
- func (m *UnhandledRetryableError) Reset()
- func (m *UnhandledRetryableError) Size() (n int)
- func (m *UnhandledRetryableError) String() string
- func (m *UnhandledRetryableError) Unmarshal(dAtA []byte) error
- type UserPriority
- type Value
- func (v *Value) ClearChecksum()
- func (*Value) Descriptor() ([]byte, []int)
- func (v Value) GetBool() (bool, error)
- func (v Value) GetBytes() ([]byte, error)
- func (v Value) GetDecimal() (*apd.Decimal, error)
- func (v Value) GetDuration() (duration.Duration, error)
- func (v Value) GetFloat() (float64, error)
- func (v Value) GetInt() (int64, error)
- func (v Value) GetProto(msg proto.Message) error
- func (v Value) GetTag() ValueType
- func (v Value) GetTime() (time.Time, error)
- func (v Value) GetTimeseries() (InternalTimeSeriesData, error)
- func (v Value) GetTuple() ([]byte, error)
- func (v *Value) InitChecksum(key []byte)
- func (m *Value) Marshal() (dAtA []byte, err error)
- func (m *Value) MarshalTo(dAtA []byte) (int, error)
- func (v Value) PrettyPrint() string
- func (*Value) ProtoMessage()
- func (m *Value) Reset()
- func (v *Value) SetBool(b bool)
- func (v *Value) SetBytes(b []byte)
- func (v *Value) SetDecimal(dec *apd.Decimal) error
- func (v *Value) SetDuration(t duration.Duration) error
- func (v *Value) SetFloat(f float64)
- func (v *Value) SetInt(i int64)
- func (v *Value) SetProto(msg proto.Message) error
- func (v *Value) SetString(s string)
- func (v *Value) SetTime(t time.Time)
- func (v *Value) SetTuple(data []byte)
- func (v *Value) ShallowClone() *Value
- func (m *Value) Size() (n int)
- func (m *Value) String() string
- func (m *Value) Unmarshal(dAtA []byte) error
- func (v Value) Verify(key []byte) error
- type ValueType
- type WriteBatchRequest
- func (*WriteBatchRequest) Descriptor() ([]byte, []int)
- func (m *WriteBatchRequest) Marshal() (dAtA []byte, err error)
- func (m *WriteBatchRequest) MarshalTo(dAtA []byte) (int, error)
- func (*WriteBatchRequest) Method() Method
- func (*WriteBatchRequest) ProtoMessage()
- func (m *WriteBatchRequest) Reset()
- func (r *WriteBatchRequest) ShallowCopy() Request
- func (m *WriteBatchRequest) Size() (n int)
- func (m *WriteBatchRequest) String() string
- func (m *WriteBatchRequest) Unmarshal(dAtA []byte) error
- type WriteBatchResponse
- func (*WriteBatchResponse) Descriptor() ([]byte, []int)
- func (m *WriteBatchResponse) Marshal() (dAtA []byte, err error)
- func (m *WriteBatchResponse) MarshalTo(dAtA []byte) (int, error)
- func (*WriteBatchResponse) ProtoMessage()
- func (m *WriteBatchResponse) Reset()
- func (m *WriteBatchResponse) Size() (n int)
- func (m *WriteBatchResponse) String() string
- func (m *WriteBatchResponse) Unmarshal(dAtA []byte) error
- type WriteIntentError
- func (*WriteIntentError) Descriptor() ([]byte, []int)
- func (e *WriteIntentError) Error() string
- func (m *WriteIntentError) Marshal() (dAtA []byte, err error)
- func (m *WriteIntentError) MarshalTo(dAtA []byte) (int, error)
- func (*WriteIntentError) ProtoMessage()
- func (m *WriteIntentError) Reset()
- func (m *WriteIntentError) Size() (n int)
- func (m *WriteIntentError) String() string
- func (m *WriteIntentError) Unmarshal(dAtA []byte) error
- type WriteTooOldError
- func (*WriteTooOldError) Descriptor() ([]byte, []int)
- func (e *WriteTooOldError) Error() string
- func (m *WriteTooOldError) Marshal() (dAtA []byte, err error)
- func (m *WriteTooOldError) MarshalTo(dAtA []byte) (int, error)
- func (*WriteTooOldError) ProtoMessage()
- func (m *WriteTooOldError) Reset()
- func (m *WriteTooOldError) Size() (n int)
- func (m *WriteTooOldError) String() string
- func (m *WriteTooOldError) Unmarshal(dAtA []byte) error
Constants ¶
const ( // MinUserPriority is the minimum allowed user priority. MinUserPriority = 0.001 // UnspecifiedUserPriority means NormalUserPriority. UnspecifiedUserPriority = 0 // NormalUserPriority is set to 1, meaning ops run through the database // are all given equal weight when a random priority is chosen. This can // be set specifically via client.NewDBWithPriority(). NormalUserPriority = 1 // MaxUserPriority is the maximum allowed user priority. MaxUserPriority = 1000 )
const ( // MinTxnPriority is the minimum allowed txn priority. MinTxnPriority = 0 // MaxTxnPriority is the maximum allowed txn priority. MaxTxnPriority = math.MaxInt32 )
Variables ¶
var ( ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowApi = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthAppStats = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowAppStats = fmt.Errorf("proto: integer overflow") )
var ( // RKeyMin is a minimum key value which sorts before all other keys. RKeyMin = RKey("") // KeyMin is a minimum key value which sorts before all other keys. KeyMin = Key(RKeyMin) // RKeyMax is a maximum key value which sorts after all other keys. RKeyMax = RKey{0xff, 0xff} // KeyMax is a maximum key value which sorts after all other keys. KeyMax = Key(RKeyMax) // PrettyPrintKey prints a key in human readable format. It's // implemented in package git.com/cockroachdb/cockroach/keys to avoid // package circle import. PrettyPrintKey func(key Key) string // PrettyPrintRange prints a key range in human readable format. It's // implemented in package git.com/cockroachdb/cockroach/keys to avoid // package circle import. PrettyPrintRange func(start, end Key, maxChars int) string )
var ( ErrInvalidLengthData = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowData = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthErrors = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowErrors = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthInternal = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowInternal = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthInternalRaft = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowInternalRaft = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthMetadata = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMetadata = fmt.Errorf("proto: integer overflow") )
var ExportStorageProvider_name = map[int32]string{
0: "Unknown",
1: "LocalFile",
2: "Http",
3: "S3",
4: "GoogleCloud",
5: "Azure",
}
var ExportStorageProvider_value = map[string]int32{
"Unknown": 0,
"LocalFile": 1,
"Http": 2,
"S3": 3,
"GoogleCloud": 4,
"Azure": 5,
}
var PushTxnType_name = map[int32]string{
0: "PUSH_TIMESTAMP",
1: "PUSH_ABORT",
2: "PUSH_TOUCH",
3: "PUSH_QUERY",
}
var PushTxnType_value = map[string]int32{
"PUSH_TIMESTAMP": 0,
"PUSH_ABORT": 1,
"PUSH_TOUCH": 2,
"PUSH_QUERY": 3,
}
var ReadConsistencyType_name = map[int32]string{
0: "CONSISTENT",
1: "CONSENSUS",
2: "INCONSISTENT",
}
var ReadConsistencyType_value = map[string]int32{
"CONSISTENT": 0,
"CONSENSUS": 1,
"INCONSISTENT": 2,
}
var ReplicaChangeType_name = map[int32]string{
0: "ADD_REPLICA",
1: "REMOVE_REPLICA",
}
var ReplicaChangeType_value = map[string]int32{
"ADD_REPLICA": 0,
"REMOVE_REPLICA": 1,
}
var TransactionRestart_name = map[int32]string{
0: "NONE",
1: "BACKOFF",
2: "IMMEDIATE",
}
var TransactionRestart_value = map[string]int32{
"NONE": 0,
"BACKOFF": 1,
"IMMEDIATE": 2,
}
var TransactionRetryReason_name = map[int32]string{
0: "RETRY_REASON_UNKNOWN",
1: "RETRY_WRITE_TOO_OLD",
2: "RETRY_DELETE_RANGE",
3: "RETRY_SERIALIZABLE",
4: "RETRY_POSSIBLE_REPLAY",
}
var TransactionRetryReason_value = map[string]int32{
"RETRY_REASON_UNKNOWN": 0,
"RETRY_WRITE_TOO_OLD": 1,
"RETRY_DELETE_RANGE": 2,
"RETRY_SERIALIZABLE": 3,
"RETRY_POSSIBLE_REPLAY": 4,
}
var TransactionStatus_name = map[int32]string{
0: "PENDING",
1: "COMMITTED",
2: "ABORTED",
}
var TransactionStatus_value = map[string]int32{
"PENDING": 0,
"COMMITTED": 1,
"ABORTED": 2,
}
var ValueType_name = map[int32]string{
0: "UNKNOWN",
7: "NULL",
1: "INT",
2: "FLOAT",
3: "BYTES",
8: "DELIMITED_BYTES",
4: "TIME",
5: "DECIMAL",
9: "DELIMITED_DECIMAL",
6: "DURATION",
10: "TUPLE",
100: "TIMESERIES",
}
var ValueType_value = map[string]int32{
"UNKNOWN": 0,
"NULL": 7,
"INT": 1,
"FLOAT": 2,
"BYTES": 3,
"DELIMITED_BYTES": 8,
"TIME": 4,
"DECIMAL": 5,
"DELIMITED_DECIMAL": 9,
"DURATION": 6,
"TUPLE": 10,
"TIMESERIES": 100,
}
Functions ¶
func BytesNext ¶
BytesNext returns the next possible byte slice, using the extra capacity of the provided slice if possible, and if not, appending an \x00.
func ConsultsTimestampCache ¶
ConsultsTimestampCache returns whether the command must consult the timestamp cache to determine whether a mutation is safe at a proposed timestamp or needs to move to a higher timestamp to avoid re-writing history.
func ErrorUnexpectedlySet ¶
func ErrorUnexpectedlySet(culprit, response interface{}) string
ErrorUnexpectedlySet creates a string to panic with when a response (typically a roachpb.BatchResponse) unexpectedly has Error set in its response header.
func IsRange ¶
IsRange returns true if the command is range-based and must include a start and an end key.
func IsReadOnly ¶
IsReadOnly returns true iff the request is read-only.
func IsTransactionWrite ¶
IsTransactionWrite returns true if the request produces write intents when used within a transaction.
func MakePriority ¶
func MakePriority(userPriority UserPriority) int32
MakePriority generates a random priority value, biased by the specified userPriority. If userPriority=100, the random priority will be 100x more likely to be greater than if userPriority=1. If userPriority = 0.1, the random priority will be 1/10th as likely to be greater than if userPriority=NormalUserPriority ( = 1). Balance is achieved when userPriority=NormalUserPriority, in which case the priority chosen is unbiased.
If userPriority is less than or equal to MinUserPriority, returns MinTxnPriority; if greater than or equal to MaxUserPriority, returns MaxTxnPriority. If userPriority is 0, returns NormalUserPriority.
func RegisterExternalServer ¶
func RegisterExternalServer(s *grpc.Server, srv ExternalServer)
func RegisterInternalServer ¶
func RegisterInternalServer(s *grpc.Server, srv InternalServer)
func TxnIDEqual ¶
TxnIDEqual returns whether the transaction IDs are equal.
func UpdatesTimestampCache ¶
UpdatesTimestampCache returns whether the command must update the timestamp cache in order to set a low water mark for the timestamp at which mutations to overlapping key(s) can write such that they don't re-write history.
Types ¶
type AbortCacheEntry ¶
type AbortCacheEntry struct { // The key of the associated transaction. Key Key `protobuf:"bytes,1,opt,name=key,casttype=Key" json:"key,omitempty"` // The candidate commit timestamp the transaction record held at the time // it was aborted. Timestamp cockroach_util_hlc.Timestamp `protobuf:"bytes,2,opt,name=timestamp" json:"timestamp"` // The priority of the transaction. Priority int32 `protobuf:"varint,3,opt,name=priority" json:"priority"` }
AbortCacheEntry contains information about a transaction which has been aborted. It's written to a range's abort cache if the range may have contained intents of the aborted txn. In the event that the same transaction attempts to read keys it may have written previously, this entry informs the transaction that it has aborted and must start fresh with an updated priority.
func NewPopulatedAbortCacheEntry ¶
func NewPopulatedAbortCacheEntry(r randyData, easy bool) *AbortCacheEntry
func (*AbortCacheEntry) Descriptor ¶
func (*AbortCacheEntry) Descriptor() ([]byte, []int)
func (*AbortCacheEntry) Marshal ¶
func (m *AbortCacheEntry) Marshal() (dAtA []byte, err error)
func (*AbortCacheEntry) ProtoMessage ¶
func (*AbortCacheEntry) ProtoMessage()
func (*AbortCacheEntry) Reset ¶
func (m *AbortCacheEntry) Reset()
func (*AbortCacheEntry) Size ¶
func (m *AbortCacheEntry) Size() (n int)
func (*AbortCacheEntry) String ¶
func (m *AbortCacheEntry) String() string
func (*AbortCacheEntry) Unmarshal ¶
func (m *AbortCacheEntry) Unmarshal(dAtA []byte) error
type AdminChangeReplicasRequest ¶
type AdminChangeReplicasRequest struct { Span `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"` ChangeType ReplicaChangeType `protobuf:"varint,2,opt,name=change_type,json=changeType,enum=cockroach.roachpb.ReplicaChangeType" json:"change_type"` Targets []ReplicationTarget `protobuf:"bytes,3,rep,name=targets" json:"targets"` }
An AdminChangeReplicasRequest is the argument to the AdminChangeReplicas() method. A change replicas operation allows adding or removing a set of replicas for a range.
func (*AdminChangeReplicasRequest) Descriptor ¶
func (*AdminChangeReplicasRequest) Descriptor() ([]byte, []int)
func (*AdminChangeReplicasRequest) Marshal ¶
func (m *AdminChangeReplicasRequest) Marshal() (dAtA []byte, err error)
func (*AdminChangeReplicasRequest) MarshalTo ¶
func (m *AdminChangeReplicasRequest) MarshalTo(dAtA []byte) (int, error)
func (*AdminChangeReplicasRequest) Method ¶
func (*AdminChangeReplicasRequest) Method() Method
Method implements the Request interface.
func (*AdminChangeReplicasRequest) ProtoMessage ¶
func (*AdminChangeReplicasRequest) ProtoMessage()
func (*AdminChangeReplicasRequest) Reset ¶
func (m *AdminChangeReplicasRequest) Reset()
func (*AdminChangeReplicasRequest) ShallowCopy ¶
func (acrr *AdminChangeReplicasRequest) ShallowCopy() Request
ShallowCopy implements the Request interface.
func (*AdminChangeReplicasRequest) Size ¶
func (m *AdminChangeReplicasRequest) Size() (n int)
func (*AdminChangeReplicasRequest) String ¶
func (m *AdminChangeReplicasRequest) String() string
func (*AdminChangeReplicasRequest) Unmarshal ¶
func (m *AdminChangeReplicasRequest) Unmarshal(dAtA []byte) error
type AdminChangeReplicasResponse ¶
type AdminChangeReplicasResponse struct {
ResponseHeader `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
}
func (*AdminChangeReplicasResponse) Descriptor ¶
func (*AdminChangeReplicasResponse) Descriptor() ([]byte, []int)
func (*AdminChangeReplicasResponse) Marshal ¶
func (m *AdminChangeReplicasResponse) Marshal() (dAtA []byte, err error)
func (*AdminChangeReplicasResponse) MarshalTo ¶
func (m *AdminChangeReplicasResponse) MarshalTo(dAtA []byte) (int, error)
func (*AdminChangeReplicasResponse) ProtoMessage ¶
func (*AdminChangeReplicasResponse) ProtoMessage()
func (*AdminChangeReplicasResponse) Reset ¶
func (m *AdminChangeReplicasResponse) Reset()
func (*AdminChangeReplicasResponse) Size ¶
func (m *AdminChangeReplicasResponse) Size() (n int)
func (*AdminChangeReplicasResponse) String ¶
func (m *AdminChangeReplicasResponse) String() string
func (*AdminChangeReplicasResponse) Unmarshal ¶
func (m *AdminChangeReplicasResponse) Unmarshal(dAtA []byte) error
type AdminMergeRequest ¶
type AdminMergeRequest struct {
Span `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
}
An AdminMergeRequest is the argument to the AdminMerge() method. A merge is performed by calling AdminMerge on the left-hand range of two consecutive ranges (i.e. the range which contains keys which sort first). This range will be the subsuming range and the right hand range will be subsumed. After the merge operation, the subsumed range will no longer exist and the subsuming range will now encompass all keys from its original start key to the end key of the subsumed range. If AdminMerge is called on the final range in the key space, it is a noop.
func (*AdminMergeRequest) Descriptor ¶
func (*AdminMergeRequest) Descriptor() ([]byte, []int)
func (*AdminMergeRequest) Marshal ¶
func (m *AdminMergeRequest) Marshal() (dAtA []byte, err error)
func (*AdminMergeRequest) MarshalTo ¶
func (m *AdminMergeRequest) MarshalTo(dAtA []byte) (int, error)
func (*AdminMergeRequest) Method ¶
func (*AdminMergeRequest) Method() Method
Method implements the Request interface.
func (*AdminMergeRequest) ProtoMessage ¶
func (*AdminMergeRequest) ProtoMessage()
func (*AdminMergeRequest) Reset ¶
func (m *AdminMergeRequest) Reset()
func (*AdminMergeRequest) ShallowCopy ¶
func (amr *AdminMergeRequest) ShallowCopy() Request
ShallowCopy implements the Request interface.
func (*AdminMergeRequest) Size ¶
func (m *AdminMergeRequest) Size() (n int)
func (*AdminMergeRequest) String ¶
func (m *AdminMergeRequest) String() string
func (*AdminMergeRequest) Unmarshal ¶
func (m *AdminMergeRequest) Unmarshal(dAtA []byte) error
type AdminMergeResponse ¶
type AdminMergeResponse struct {
ResponseHeader `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
}
An AdminMergeResponse is the return value from the AdminMerge() method.
func (*AdminMergeResponse) Descriptor ¶
func (*AdminMergeResponse) Descriptor() ([]byte, []int)
func (*AdminMergeResponse) Marshal ¶
func (m *AdminMergeResponse) Marshal() (dAtA []byte, err error)
func (*AdminMergeResponse) MarshalTo ¶
func (m *AdminMergeResponse) MarshalTo(dAtA []byte) (int, error)
func (*AdminMergeResponse) ProtoMessage ¶
func (*AdminMergeResponse) ProtoMessage()
func (*AdminMergeResponse) Reset ¶
func (m *AdminMergeResponse) Reset()
func (*AdminMergeResponse) Size ¶
func (m *AdminMergeResponse) Size() (n int)
func (*AdminMergeResponse) String ¶
func (m *AdminMergeResponse) String() string
func (*AdminMergeResponse) Unmarshal ¶
func (m *AdminMergeResponse) Unmarshal(dAtA []byte) error
type AdminScatterRequest ¶
type AdminScatterRequest struct {
Span `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
}
AdminScatterRequest is the argument to the AdminScatter() method, which moves replicas and leaseholders for a selection of ranges. Scatter is best-effort; ranges that cannot be moved will include an error detail in the response and won't fail the request.
func (*AdminScatterRequest) Descriptor ¶
func (*AdminScatterRequest) Descriptor() ([]byte, []int)
func (*AdminScatterRequest) Marshal ¶
func (m *AdminScatterRequest) Marshal() (dAtA []byte, err error)
func (*AdminScatterRequest) MarshalTo ¶
func (m *AdminScatterRequest) MarshalTo(dAtA []byte) (int, error)
func (*AdminScatterRequest) Method ¶
func (*AdminScatterRequest) Method() Method
Method implements the Request interface.
func (*AdminScatterRequest) ProtoMessage ¶
func (*AdminScatterRequest) ProtoMessage()
func (*AdminScatterRequest) Reset ¶
func (m *AdminScatterRequest) Reset()
func (*AdminScatterRequest) ShallowCopy ¶
func (r *AdminScatterRequest) ShallowCopy() Request
ShallowCopy implements the Request interface.
func (*AdminScatterRequest) Size ¶
func (m *AdminScatterRequest) Size() (n int)
func (*AdminScatterRequest) String ¶
func (m *AdminScatterRequest) String() string
func (*AdminScatterRequest) Unmarshal ¶
func (m *AdminScatterRequest) Unmarshal(dAtA []byte) error
type AdminScatterResponse ¶
type AdminScatterResponse struct { ResponseHeader `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"` Ranges []AdminScatterResponse_Range `protobuf:"bytes,2,rep,name=ranges" json:"ranges"` }
ScatterResponse is the response to a Scatter() operation.
func (*AdminScatterResponse) Descriptor ¶
func (*AdminScatterResponse) Descriptor() ([]byte, []int)
func (*AdminScatterResponse) Marshal ¶
func (m *AdminScatterResponse) Marshal() (dAtA []byte, err error)
func (*AdminScatterResponse) MarshalTo ¶
func (m *AdminScatterResponse) MarshalTo(dAtA []byte) (int, error)
func (*AdminScatterResponse) ProtoMessage ¶
func (*AdminScatterResponse) ProtoMessage()
func (*AdminScatterResponse) Reset ¶
func (m *AdminScatterResponse) Reset()
func (*AdminScatterResponse) Size ¶
func (m *AdminScatterResponse) Size() (n int)
func (*AdminScatterResponse) String ¶
func (m *AdminScatterResponse) String() string
func (*AdminScatterResponse) Unmarshal ¶
func (m *AdminScatterResponse) Unmarshal(dAtA []byte) error
type AdminScatterResponse_Range ¶
type AdminScatterResponse_Range struct { Span Span `protobuf:"bytes,1,opt,name=span" json:"span"` // Error will be nil if this range was successfully scattered. Error *Error `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"` }
func (*AdminScatterResponse_Range) Descriptor ¶
func (*AdminScatterResponse_Range) Descriptor() ([]byte, []int)
func (*AdminScatterResponse_Range) Marshal ¶
func (m *AdminScatterResponse_Range) Marshal() (dAtA []byte, err error)
func (*AdminScatterResponse_Range) MarshalTo ¶
func (m *AdminScatterResponse_Range) MarshalTo(dAtA []byte) (int, error)
func (*AdminScatterResponse_Range) ProtoMessage ¶
func (*AdminScatterResponse_Range) ProtoMessage()
func (*AdminScatterResponse_Range) Reset ¶
func (m *AdminScatterResponse_Range) Reset()
func (*AdminScatterResponse_Range) Size ¶
func (m *AdminScatterResponse_Range) Size() (n int)
func (*AdminScatterResponse_Range) String ¶
func (m *AdminScatterResponse_Range) String() string
func (*AdminScatterResponse_Range) Unmarshal ¶
func (m *AdminScatterResponse_Range) Unmarshal(dAtA []byte) error
type AdminSplitRequest ¶
type AdminSplitRequest struct { Span `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"` SplitKey Key `protobuf:"bytes,2,opt,name=split_key,json=splitKey,casttype=Key" json:"split_key,omitempty"` }
An AdminSplitRequest is the argument to the AdminSplit() method. The existing range which contains header.key is split by split_key. If split_key is not specified, then this method will determine a split key that is roughly halfway through the range. The existing range is resized to cover only its start key to the split key. The new range created by the split starts at the split key and extends to the original range's end key. If split_key is known, header.key should also be set to split_key.
New range IDs for each of the split range's replica and a new Raft ID are generated by the operation. Split requests are done in the context of a distributed transaction which updates range addressing records, range metadata and finally, provides a commit trigger to update bookkeeping and instantiate the new range on commit.
The new range contains range replicas located on the same stores; no range data is moved during this operation. The split can be thought of as a mostly logical operation, though some other metadata (e.g. sequence cache and range stats must be copied or recomputed).
func (*AdminSplitRequest) Descriptor ¶
func (*AdminSplitRequest) Descriptor() ([]byte, []int)
func (*AdminSplitRequest) Marshal ¶
func (m *AdminSplitRequest) Marshal() (dAtA []byte, err error)
func (*AdminSplitRequest) MarshalTo ¶
func (m *AdminSplitRequest) MarshalTo(dAtA []byte) (int, error)
func (*AdminSplitRequest) Method ¶
func (*AdminSplitRequest) Method() Method
Method implements the Request interface.
func (*AdminSplitRequest) ProtoMessage ¶
func (*AdminSplitRequest) ProtoMessage()
func (*AdminSplitRequest) Reset ¶
func (m *AdminSplitRequest) Reset()
func (*AdminSplitRequest) ShallowCopy ¶
func (asr *AdminSplitRequest) ShallowCopy() Request
ShallowCopy implements the Request interface.
func (*AdminSplitRequest) Size ¶
func (m *AdminSplitRequest) Size() (n int)
func (*AdminSplitRequest) String ¶
func (m *AdminSplitRequest) String() string
func (*AdminSplitRequest) Unmarshal ¶
func (m *AdminSplitRequest) Unmarshal(dAtA []byte) error
type AdminSplitResponse ¶
type AdminSplitResponse struct {
ResponseHeader `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
}
An AdminSplitResponse is the return value from the AdminSplit() method.
func (*AdminSplitResponse) Descriptor ¶
func (*AdminSplitResponse) Descriptor() ([]byte, []int)
func (*AdminSplitResponse) Marshal ¶
func (m *AdminSplitResponse) Marshal() (dAtA []byte, err error)
func (*AdminSplitResponse) MarshalTo ¶
func (m *AdminSplitResponse) MarshalTo(dAtA []byte) (int, error)
func (*AdminSplitResponse) ProtoMessage ¶
func (*AdminSplitResponse) ProtoMessage()
func (*AdminSplitResponse) Reset ¶
func (m *AdminSplitResponse) Reset()
func (*AdminSplitResponse) Size ¶
func (m *AdminSplitResponse) Size() (n int)
func (*AdminSplitResponse) String ¶
func (m *AdminSplitResponse) String() string
func (*AdminSplitResponse) Unmarshal ¶
func (m *AdminSplitResponse) Unmarshal(dAtA []byte) error
type AdminTransferLeaseRequest ¶
type AdminTransferLeaseRequest struct { Span `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"` Target StoreID `protobuf:"varint,2,opt,name=target,casttype=StoreID" json:"target"` }
An AdminTransferLeaseRequest is the argument to the AdminTransferLease() method. A lease transfer allows an external entity to control the lease holder for a range. The target of the lease transfer needs to be a valid replica of the range.
func (*AdminTransferLeaseRequest) Descriptor ¶
func (*AdminTransferLeaseRequest) Descriptor() ([]byte, []int)
func (*AdminTransferLeaseRequest) Marshal ¶
func (m *AdminTransferLeaseRequest) Marshal() (dAtA []byte, err error)
func (*AdminTransferLeaseRequest) MarshalTo ¶
func (m *AdminTransferLeaseRequest) MarshalTo(dAtA []byte) (int, error)
func (*AdminTransferLeaseRequest) Method ¶
func (*AdminTransferLeaseRequest) Method() Method
Method implements the Request interface.
func (*AdminTransferLeaseRequest) ProtoMessage ¶
func (*AdminTransferLeaseRequest) ProtoMessage()
func (*AdminTransferLeaseRequest) Reset ¶
func (m *AdminTransferLeaseRequest) Reset()
func (*AdminTransferLeaseRequest) ShallowCopy ¶
func (atlr *AdminTransferLeaseRequest) ShallowCopy() Request
ShallowCopy implements the Request interface.
func (*AdminTransferLeaseRequest) Size ¶
func (m *AdminTransferLeaseRequest) Size() (n int)
func (*AdminTransferLeaseRequest) String ¶
func (m *AdminTransferLeaseRequest) String() string
func (*AdminTransferLeaseRequest) Unmarshal ¶
func (m *AdminTransferLeaseRequest) Unmarshal(dAtA []byte) error
type AdminTransferLeaseResponse ¶
type AdminTransferLeaseResponse struct {
ResponseHeader `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
}
func (*AdminTransferLeaseResponse) Descriptor ¶
func (*AdminTransferLeaseResponse) Descriptor() ([]byte, []int)
func (*AdminTransferLeaseResponse) Marshal ¶
func (m *AdminTransferLeaseResponse) Marshal() (dAtA []byte, err error)
func (*AdminTransferLeaseResponse) MarshalTo ¶
func (m *AdminTransferLeaseResponse) MarshalTo(dAtA []byte) (int, error)
func (*AdminTransferLeaseResponse) ProtoMessage ¶
func (*AdminTransferLeaseResponse) ProtoMessage()
func (*AdminTransferLeaseResponse) Reset ¶
func (m *AdminTransferLeaseResponse) Reset()
func (*AdminTransferLeaseResponse) Size ¶
func (m *AdminTransferLeaseResponse) Size() (n int)
func (*AdminTransferLeaseResponse) String ¶
func (m *AdminTransferLeaseResponse) String() string
func (*AdminTransferLeaseResponse) Unmarshal ¶
func (m *AdminTransferLeaseResponse) Unmarshal(dAtA []byte) error
type AmbiguousResultError ¶
type AmbiguousResultError struct { Message string `protobuf:"bytes,1,opt,name=message" json:"message"` // This can be set to give extra information about which error was converted // into an AmbiguousResultError. Useful for tests. WrappedErr *Error `protobuf:"bytes,2,opt,name=wrapped_err,json=wrappedErr" json:"wrapped_err,omitempty"` }
An AmbiguousResultError indicates that a request may have succeeded or failed, but the response was not received and the final result is ambiguous.
func NewAmbiguousResultError ¶
func NewAmbiguousResultError(msg string) *AmbiguousResultError
NewAmbiguousResultError initializes a new AmbiguousResultError with an explanatory message.
func (*AmbiguousResultError) Descriptor ¶
func (*AmbiguousResultError) Descriptor() ([]byte, []int)
func (*AmbiguousResultError) Error ¶
func (e *AmbiguousResultError) Error() string
func (*AmbiguousResultError) Marshal ¶
func (m *AmbiguousResultError) Marshal() (dAtA []byte, err error)
func (*AmbiguousResultError) MarshalTo ¶
func (m *AmbiguousResultError) MarshalTo(dAtA []byte) (int, error)
func (*AmbiguousResultError) ProtoMessage ¶
func (*AmbiguousResultError) ProtoMessage()
func (*AmbiguousResultError) Reset ¶
func (m *AmbiguousResultError) Reset()
func (*AmbiguousResultError) Size ¶
func (m *AmbiguousResultError) Size() (n int)
func (*AmbiguousResultError) String ¶
func (m *AmbiguousResultError) String() string
func (*AmbiguousResultError) Unmarshal ¶
func (m *AmbiguousResultError) Unmarshal(dAtA []byte) error
type Attributes ¶
type Attributes struct {
Attrs []string `protobuf:"bytes,1,rep,name=attrs" json:"attrs,omitempty" yaml:"attrs,flow"`
}
Attributes specifies a list of arbitrary strings describing node topology, store type, and machine capabilities.
func (*Attributes) Descriptor ¶
func (*Attributes) Descriptor() ([]byte, []int)
func (Attributes) IsSubset ¶
func (a Attributes) IsSubset(b Attributes) bool
IsSubset returns whether attributes list a is a subset of attributes list b.
func (*Attributes) Marshal ¶
func (m *Attributes) Marshal() (dAtA []byte, err error)
func (*Attributes) ProtoMessage ¶
func (*Attributes) ProtoMessage()
func (*Attributes) Reset ¶
func (m *Attributes) Reset()
func (*Attributes) Size ¶
func (m *Attributes) Size() (n int)
func (Attributes) SortedString ¶
func (a Attributes) SortedString() string
SortedString returns a sorted, de-duplicated, comma-separated list of the attributes.
func (Attributes) String ¶
func (a Attributes) String() string
func (*Attributes) Unmarshal ¶
func (m *Attributes) Unmarshal(dAtA []byte) error
type BatchRequest ¶
type BatchRequest struct { Header `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"` Requests []RequestUnion `protobuf:"bytes,2,rep,name=requests" json:"requests"` }
A BatchRequest contains one or more requests to be executed in parallel, or if applicable (based on write-only commands and range-locality), as a single update.
func (*BatchRequest) Add ¶
func (ba *BatchRequest) Add(requests ...Request)
Add adds a request to the batch request. It's a convenience method; requests may also be added directly into the slice.
func (*BatchRequest) CreateReply ¶
func (ba *BatchRequest) CreateReply() *BatchResponse
CreateReply creates replies for each of the contained requests, wrapped in a BatchResponse. The response objects are batch allocated to minimize allocation overhead.
func (*BatchRequest) Descriptor ¶
func (*BatchRequest) Descriptor() ([]byte, []int)
func (*BatchRequest) GetArg ¶
func (ba *BatchRequest) GetArg(method Method) (Request, bool)
GetArg returns a request of the given type if one is contained in the Batch. The request returned is the first of its kind, with the exception of EndTransaction, where it examines the very last request only.
func (*BatchRequest) GetPrevLeaseForLeaseRequest ¶
func (ba *BatchRequest) GetPrevLeaseForLeaseRequest() *Lease
GetPrevLeaseForLeaseRequest returns the previous lease, at the time of proposal, for a request lease or transfer lease request. If the batch does not contain a single lease request, this method will panic.
func (*BatchRequest) GetUser ¶
func (*BatchRequest) GetUser() string
GetUser implements security.RequestWithUser. KV messages are always sent by the node user.
func (*BatchRequest) IntentSpanIterate ¶
func (ba *BatchRequest) IntentSpanIterate(br *BatchResponse, fn func(key, endKey Key))
IntentSpanIterate calls the passed method with the key ranges of the transactional writes contained in the batch. Usually the key spans contained in the requests are used, but when a response contains a ResumeSpan the ResumeSpan is subtracted from the request span to provide a more minimal span of keys affected by the request.
func (*BatchRequest) IsAdmin ¶
func (ba *BatchRequest) IsAdmin() bool
IsAdmin returns true iff the BatchRequest contains an admin request.
func (*BatchRequest) IsLeaseRequest ¶
func (ba *BatchRequest) IsLeaseRequest() bool
IsLeaseRequest returns whether the batch consists of a single RequestLease request. Note that TransferLease requests return false. RequestLease requests are special because they're the only type of requests a non-lease-holder can propose.
func (*BatchRequest) IsPossibleTransaction ¶
func (ba *BatchRequest) IsPossibleTransaction() bool
IsPossibleTransaction returns true iff the BatchRequest contains requests that can be part of a transaction.
func (*BatchRequest) IsReadOnly ¶
func (ba *BatchRequest) IsReadOnly() bool
IsReadOnly returns true if all requests within are read-only.
func (*BatchRequest) IsReverse ¶
func (ba *BatchRequest) IsReverse() bool
IsReverse returns true iff the BatchRequest contains a reverse request.
func (*BatchRequest) IsSinglePushTxnRequest ¶
func (ba *BatchRequest) IsSinglePushTxnRequest() bool
IsSinglePushTxnRequest returns true iff the batch contains a single request, and that request is for a PushTxn.
func (*BatchRequest) IsSingleRequest ¶
func (ba *BatchRequest) IsSingleRequest() bool
IsSingleRequest returns true iff the BatchRequest contains a single request.
func (*BatchRequest) IsSingleSkipLeaseCheckRequest ¶
func (ba *BatchRequest) IsSingleSkipLeaseCheckRequest() bool
IsSingleSkipLeaseCheckRequest returns true iff the batch contains a single request, and that request has the skipLeaseCheck flag set.
func (*BatchRequest) IsTransactionWrite ¶
func (ba *BatchRequest) IsTransactionWrite() bool
IsTransactionWrite returns true iff the BatchRequest contains a txn write.
func (*BatchRequest) IsWrite ¶
func (ba *BatchRequest) IsWrite() bool
IsWrite returns true iff the BatchRequest contains a write.
func (*BatchRequest) Marshal ¶
func (m *BatchRequest) Marshal() (dAtA []byte, err error)
func (*BatchRequest) Methods ¶
func (ba *BatchRequest) Methods() []Method
Methods returns a slice of the contained methods.
func (*BatchRequest) ProtoMessage ¶
func (*BatchRequest) ProtoMessage()
func (*BatchRequest) Reset ¶
func (m *BatchRequest) Reset()
func (*BatchRequest) SetActiveTimestamp ¶
func (ba *BatchRequest) SetActiveTimestamp(nowFn func() hlc.Timestamp) error
SetActiveTimestamp sets the correct timestamp at which the request is to be carried out. For transactional requests, ba.Timestamp must be zero initially and it will be set to txn.OrigTimestamp. For non-transactional requests, if no timestamp is specified, nowFn is used to create and set one.
func (*BatchRequest) SetNewRequest ¶
func (ba *BatchRequest) SetNewRequest()
SetNewRequest increases the internal sequence counter of this batch request. The sequence counter is used for replay and reordering protection. At the Store, a sequence counter less than or equal to the last observed one incurs a transaction restart (if the request is transactional).
func (*BatchRequest) Size ¶
func (m *BatchRequest) Size() (n int)
func (BatchRequest) Split ¶
func (ba BatchRequest) Split(canSplitET bool) [][]RequestUnion
Split separates the requests contained in a batch so that each subset of requests can be executed by a Store (without changing order). In particular, Admin requests are always singled out and mutating requests separated from reads. The boolean parameter indicates whether EndTransaction should be special-cased: If false, an EndTransaction request will never be split into a new chunk (otherwise, it is treated according to its flags). This allows sending a whole transaction in a single Batch when addressing a single range.
func (BatchRequest) String ¶
func (ba BatchRequest) String() string
String gives a brief summary of the contained requests and keys in the batch. TODO(tschottdorf): the key range is useful information, but requires `keys`. See #2198.
func (*BatchRequest) Summary ¶
func (ba *BatchRequest) Summary() string
Summary prints a short summary of the requests in a batch.
func (*BatchRequest) Unmarshal ¶
func (m *BatchRequest) Unmarshal(dAtA []byte) error
func (*BatchRequest) UpdateTxn ¶
func (ba *BatchRequest) UpdateTxn(otherTxn *Transaction)
UpdateTxn updates the batch transaction from the supplied one in a copy-on-write fashion, i.e. without mutating an existing Transaction struct.
type BatchResponse ¶
type BatchResponse struct { BatchResponse_Header `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"` Responses []ResponseUnion `protobuf:"bytes,2,rep,name=responses" json:"responses"` }
A BatchResponse contains one or more responses, one per request corresponding to the requests in the matching BatchRequest. The error in the response header is set to the first error from the slice of responses, if applicable.
func (*BatchResponse) Add ¶
func (br *BatchResponse) Add(reply Response)
Add adds a response to the batch response. It's a convenience method; responses may also be added directly.
func (*BatchResponse) Combine ¶
func (br *BatchResponse) Combine(otherBatch *BatchResponse) error
Combine implements the Combinable interface. It combines each slot of the given request into the corresponding slot of the base response. The number of slots must be equal and the respective slots must be combinable. On error, the receiver BatchResponse is in an invalid state. TODO(tschottdorf): write tests.
func (*BatchResponse) Descriptor ¶
func (*BatchResponse) Descriptor() ([]byte, []int)
func (*BatchResponse) Marshal ¶
func (m *BatchResponse) Marshal() (dAtA []byte, err error)
func (*BatchResponse) ProtoMessage ¶
func (*BatchResponse) ProtoMessage()
func (*BatchResponse) Reset ¶
func (m *BatchResponse) Reset()
func (*BatchResponse) Size ¶
func (m *BatchResponse) Size() (n int)
func (*BatchResponse) String ¶
func (br *BatchResponse) String() string
func (*BatchResponse) Unmarshal ¶
func (m *BatchResponse) Unmarshal(dAtA []byte) error
type BatchResponse_Header ¶
type BatchResponse_Header struct { // error is non-nil if an error occurred. Error *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` // timestamp is set only for non-transactional responses and denotes the // highest timestamp at which a command from the batch executed. At the // time of writing, it is used solely for informational purposes and tests. Timestamp cockroach_util_hlc.Timestamp `protobuf:"bytes,2,opt,name=Timestamp" json:"Timestamp"` // txn is non-nil if the request specified a non-nil // transaction. The transaction timestamp and/or priority may have // been updated, depending on the outcome of the request. Txn *Transaction `protobuf:"bytes,3,opt,name=txn" json:"txn,omitempty"` // collected_spans is a binary representation of the trace spans // generated during the execution of this request. CollectedSpans [][]byte `protobuf:"bytes,4,rep,name=collected_spans,json=collectedSpans" json:"collected_spans,omitempty"` // now is the current time at the node sending the response, // which can be used by the receiver to update its local HLC. Now cockroach_util_hlc.Timestamp `protobuf:"bytes,5,opt,name=now" json:"now"` }
func (*BatchResponse_Header) Descriptor ¶
func (*BatchResponse_Header) Descriptor() ([]byte, []int)
func (*BatchResponse_Header) Marshal ¶
func (m *BatchResponse_Header) Marshal() (dAtA []byte, err error)
func (*BatchResponse_Header) MarshalTo ¶
func (m *BatchResponse_Header) MarshalTo(dAtA []byte) (int, error)
func (*BatchResponse_Header) ProtoMessage ¶
func (*BatchResponse_Header) ProtoMessage()
func (*BatchResponse_Header) Reset ¶
func (m *BatchResponse_Header) Reset()
func (*BatchResponse_Header) Size ¶
func (m *BatchResponse_Header) Size() (n int)
func (*BatchResponse_Header) String ¶
func (m *BatchResponse_Header) String() string
func (*BatchResponse_Header) Unmarshal ¶
func (m *BatchResponse_Header) Unmarshal(dAtA []byte) error
type BeginTransactionRequest ¶
type BeginTransactionRequest struct {
Span `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
}
A BeginTransactionRequest is the argument to the BeginTransaction() method.
func (*BeginTransactionRequest) Descriptor ¶
func (*BeginTransactionRequest) Descriptor() ([]byte, []int)
func (*BeginTransactionRequest) Marshal ¶
func (m *BeginTransactionRequest) Marshal() (dAtA []byte, err error)
func (*BeginTransactionRequest) MarshalTo ¶
func (m *BeginTransactionRequest) MarshalTo(dAtA []byte) (int, error)
func (*BeginTransactionRequest) Method ¶
func (*BeginTransactionRequest) Method() Method
Method implements the Request interface.
func (*BeginTransactionRequest) ProtoMessage ¶
func (*BeginTransactionRequest) ProtoMessage()
func (*BeginTransactionRequest) Reset ¶
func (m *BeginTransactionRequest) Reset()
func (*BeginTransactionRequest) ShallowCopy ¶
func (btr *BeginTransactionRequest) ShallowCopy() Request
ShallowCopy implements the Request interface.
func (*BeginTransactionRequest) Size ¶
func (m *BeginTransactionRequest) Size() (n int)
func (*BeginTransactionRequest) String ¶
func (m *BeginTransactionRequest) String() string
func (*BeginTransactionRequest) Unmarshal ¶
func (m *BeginTransactionRequest) Unmarshal(dAtA []byte) error
type BeginTransactionResponse ¶
type BeginTransactionResponse struct {
ResponseHeader `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
}
A BeginTransactionResponse is the return value from the BeginTransaction() method.
func (*BeginTransactionResponse) Descriptor ¶
func (*BeginTransactionResponse) Descriptor() ([]byte, []int)
func (*BeginTransactionResponse) Marshal ¶
func (m *BeginTransactionResponse) Marshal() (dAtA []byte, err error)
func (*BeginTransactionResponse) MarshalTo ¶
func (m *BeginTransactionResponse) MarshalTo(dAtA []byte) (int, error)
func (*BeginTransactionResponse) ProtoMessage ¶
func (*BeginTransactionResponse) ProtoMessage()
func (*BeginTransactionResponse) Reset ¶
func (m *BeginTransactionResponse) Reset()
func (*BeginTransactionResponse) Size ¶
func (m *BeginTransactionResponse) Size() (n int)
func (*BeginTransactionResponse) String ¶
func (m *BeginTransactionResponse) String() string
func (*BeginTransactionResponse) Unmarshal ¶
func (m *BeginTransactionResponse) Unmarshal(dAtA []byte) error
type ChangeReplicasTrigger ¶
type ChangeReplicasTrigger struct { ChangeType ReplicaChangeType `protobuf:"varint,1,opt,name=change_type,json=changeType,enum=cockroach.roachpb.ReplicaChangeType" json:"change_type"` // The replica being modified. Replica ReplicaDescriptor `protobuf:"bytes,2,opt,name=replica" json:"replica"` // The new replica list with this change applied. UpdatedReplicas []ReplicaDescriptor `protobuf:"bytes,3,rep,name=updated_replicas,json=updatedReplicas" json:"updated_replicas"` NextReplicaID ReplicaID `protobuf:"varint,4,opt,name=next_replica_id,json=nextReplicaId,casttype=ReplicaID" json:"next_replica_id"` }
func (*ChangeReplicasTrigger) Descriptor ¶
func (*ChangeReplicasTrigger) Descriptor() ([]byte, []int)
func (*ChangeReplicasTrigger) Marshal ¶
func (m *ChangeReplicasTrigger) Marshal() (dAtA []byte, err error)
func (*ChangeReplicasTrigger) MarshalTo ¶
func (m *ChangeReplicasTrigger) MarshalTo(dAtA []byte) (int, error)
func (*ChangeReplicasTrigger) ProtoMessage ¶
func (*ChangeReplicasTrigger) ProtoMessage()
func (*ChangeReplicasTrigger) Reset ¶
func (m *ChangeReplicasTrigger) Reset()
func (*ChangeReplicasTrigger) Size ¶
func (m *ChangeReplicasTrigger) Size() (n int)
func (*ChangeReplicasTrigger) String ¶
func (m *ChangeReplicasTrigger) String() string
func (*ChangeReplicasTrigger) Unmarshal ¶
func (m *ChangeReplicasTrigger) Unmarshal(dAtA []byte) error
type CheckConsistencyRequest ¶
type CheckConsistencyRequest struct { Span `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"` // log a diff of inconsistencies if such inconsistencies are found. WithDiff bool `protobuf:"varint,2,opt,name=with_diff,json=withDiff" json:"with_diff"` }
A CheckConsistencyRequest is the argument to the CheckConsistency() method. It specifies the start and end keys for a span of ranges to which a consistency check should be applied. A consistency check on a range involves running a ComputeChecksum on the range followed by a storage.CollectChecksum.
func (*CheckConsistencyRequest) Descriptor ¶
func (*CheckConsistencyRequest) Descriptor() ([]byte, []int)
func (*CheckConsistencyRequest) Marshal ¶
func (m *CheckConsistencyRequest) Marshal() (dAtA []byte, err error)
func (*CheckConsistencyRequest) MarshalTo ¶
func (m *CheckConsistencyRequest) MarshalTo(dAtA []byte) (int, error)
func (*CheckConsistencyRequest) Method ¶
func (*CheckConsistencyRequest) Method() Method
Method implements the Request interface.
func (*CheckConsistencyRequest) ProtoMessage ¶
func (*CheckConsistencyRequest) ProtoMessage()
func (*CheckConsistencyRequest) Reset ¶
func (m *CheckConsistencyRequest) Reset()
func (*CheckConsistencyRequest) ShallowCopy ¶
func (ccr *CheckConsistencyRequest) ShallowCopy() Request
ShallowCopy implements the Request interface.
func (*CheckConsistencyRequest) Size ¶
func (m *CheckConsistencyRequest) Size() (n int)
func (*CheckConsistencyRequest) String ¶
func (m *CheckConsistencyRequest) String() string
func (*CheckConsistencyRequest) Unmarshal ¶
func (m *CheckConsistencyRequest) Unmarshal(dAtA []byte) error
type CheckConsistencyResponse ¶
type CheckConsistencyResponse struct {
ResponseHeader `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
}
A CheckConsistencyResponse is the return value from the CheckConsistency() method. If a replica finds itself to be inconsistent with its lease holder it will panic.
func (*CheckConsistencyResponse) Descriptor ¶
func (*CheckConsistencyResponse) Descriptor() ([]byte, []int)
func (*CheckConsistencyResponse) Marshal ¶
func (m *CheckConsistencyResponse) Marshal() (dAtA []byte, err error)
func (*CheckConsistencyResponse) MarshalTo ¶
func (m *CheckConsistencyResponse) MarshalTo(dAtA []byte) (int, error)
func (*CheckConsistencyResponse) ProtoMessage ¶
func (*CheckConsistencyResponse) ProtoMessage()
func (*CheckConsistencyResponse) Reset ¶
func (m *CheckConsistencyResponse) Reset()
func (*CheckConsistencyResponse) Size ¶
func (m *CheckConsistencyResponse) Size() (n int)
func (*CheckConsistencyResponse) String ¶
func (m *CheckConsistencyResponse) String() string
func (*CheckConsistencyResponse) Unmarshal ¶
func (m *CheckConsistencyResponse) Unmarshal(dAtA []byte) error
type ComputeChecksumRequest ¶
type ComputeChecksumRequest struct { Span `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"` // The version used to pick the checksum method. It allows us to use a // consistent checksumming method across replicas. Version uint32 `protobuf:"varint,2,opt,name=version" json:"version"` // A unique identifier to match a future storage.CollectChecksumRequest with // this request. ChecksumID github_com_cockroachdb_cockroach_pkg_util_uuid.UUID `` /* 137-byte string literal not displayed */ // Compute a checksum along with a snapshot of the entire range, that will be // used in logging a diff during checksum verification. Snapshot bool `protobuf:"varint,4,opt,name=snapshot" json:"snapshot"` }
A ComputeChecksumRequest is arguments to the ComputeChecksum() method, to start computing the checksum for the specified range at the snapshot for this request command. A response is returned without the checksum. The computed checksum is retrieved via a storage.CollectChecksumRequest.
func (*ComputeChecksumRequest) Descriptor ¶
func (*ComputeChecksumRequest) Descriptor() ([]byte, []int)
func (*ComputeChecksumRequest) Marshal ¶
func (m *ComputeChecksumRequest) Marshal() (dAtA []byte, err error)
func (*ComputeChecksumRequest) MarshalTo ¶
func (m *ComputeChecksumRequest) MarshalTo(dAtA []byte) (int, error)
func (*ComputeChecksumRequest) Method ¶
func (*ComputeChecksumRequest) Method() Method
Method implements the Request interface.
func (*ComputeChecksumRequest) ProtoMessage ¶
func (*ComputeChecksumRequest) ProtoMessage()
func (*ComputeChecksumRequest) Reset ¶
func (m *ComputeChecksumRequest) Reset()
func (*ComputeChecksumRequest) ShallowCopy ¶
func (ccr *ComputeChecksumRequest) ShallowCopy() Request
ShallowCopy implements the Request interface.
func (*ComputeChecksumRequest) Size ¶
func (m *ComputeChecksumRequest) Size() (n int)
func (*ComputeChecksumRequest) String ¶
func (m *ComputeChecksumRequest) String() string
func (*ComputeChecksumRequest) Unmarshal ¶
func (m *ComputeChecksumRequest) Unmarshal(dAtA []byte) error
type ComputeChecksumResponse ¶
type ComputeChecksumResponse struct {
ResponseHeader `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
}
A ComputeChecksumResponse is the response to a ComputeChecksum() operation.
func (*ComputeChecksumResponse) Descriptor ¶
func (*ComputeChecksumResponse) Descriptor() ([]byte, []int)
func (*ComputeChecksumResponse) Marshal ¶
func (m *ComputeChecksumResponse) Marshal() (dAtA []byte, err error)
func (*ComputeChecksumResponse) MarshalTo ¶
func (m *ComputeChecksumResponse) MarshalTo(dAtA []byte) (int, error)
func (*ComputeChecksumResponse) ProtoMessage ¶
func (*ComputeChecksumResponse) ProtoMessage()
func (*ComputeChecksumResponse) Reset ¶
func (m *ComputeChecksumResponse) Reset()
func (*ComputeChecksumResponse) Size ¶
func (m *ComputeChecksumResponse) Size() (n int)
func (*ComputeChecksumResponse) String ¶
func (m *ComputeChecksumResponse) String() string
func (*ComputeChecksumResponse) Unmarshal ¶
func (m *ComputeChecksumResponse) Unmarshal(dAtA []byte) error
type ConditionFailedError ¶
type ConditionFailedError struct {
ActualValue *Value `protobuf:"bytes,1,opt,name=actual_value,json=actualValue" json:"actual_value,omitempty"`
}
A ConditionFailedError indicates that the expected value of a ConditionalPutRequest was not found, either because it was missing or was not equal. The error will contain the actual value found.
func (*ConditionFailedError) Descriptor ¶
func (*ConditionFailedError) Descriptor() ([]byte, []int)
func (*ConditionFailedError) Error ¶
func (e *ConditionFailedError) Error() string
func (*ConditionFailedError) Marshal ¶
func (m *ConditionFailedError) Marshal() (dAtA []byte, err error)
func (*ConditionFailedError) MarshalTo ¶
func (m *ConditionFailedError) MarshalTo(dAtA []byte) (int, error)
func (*ConditionFailedError) ProtoMessage ¶
func (*ConditionFailedError) ProtoMessage()
func (*ConditionFailedError) Reset ¶
func (m *ConditionFailedError) Reset()
func (*ConditionFailedError) Size ¶
func (m *ConditionFailedError) Size() (n int)
func (*ConditionFailedError) String ¶
func (m *ConditionFailedError) String() string
func (*ConditionFailedError) Unmarshal ¶
func (m *ConditionFailedError) Unmarshal(dAtA []byte) error
type ConditionalPutRequest ¶
type ConditionalPutRequest struct { Span `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"` // The value to put. Value Value `protobuf:"bytes,2,opt,name=value" json:"value"` // Set exp_value.bytes empty to test for non-existence. Specify as nil // to indicate there should be no existing entry. This is different // from the expectation that the value exists but is empty. ExpValue *Value `protobuf:"bytes,3,opt,name=exp_value,json=expValue" json:"exp_value,omitempty"` // NOTE: For internal use only! Set to indicate that the put is // writing to virgin keyspace and no reads are necessary to // rationalize MVCC. Blind bool `protobuf:"varint,4,opt,name=blind" json:"blind"` }
A ConditionalPutRequest is the argument to the ConditionalPut() method.
- Returns true and sets value if exp_value equals existing value. - If key doesn't exist and exp_value is nil, sets value. - If key exists, but value is empty and exp_value is not nil but empty, sets value. - Otherwise, returns error and the actual value of the key in the response.
func (*ConditionalPutRequest) Descriptor ¶
func (*ConditionalPutRequest) Descriptor() ([]byte, []int)
func (*ConditionalPutRequest) Marshal ¶
func (m *ConditionalPutRequest) Marshal() (dAtA []byte, err error)
func (*ConditionalPutRequest) MarshalTo ¶
func (m *ConditionalPutRequest) MarshalTo(dAtA []byte) (int, error)
func (*ConditionalPutRequest) Method ¶
func (*ConditionalPutRequest) Method() Method
Method implements the Request interface.
func (*ConditionalPutRequest) ProtoMessage ¶
func (*ConditionalPutRequest) ProtoMessage()
func (*ConditionalPutRequest) Reset ¶
func (m *ConditionalPutRequest) Reset()
func (*ConditionalPutRequest) ShallowCopy ¶
func (cpr *ConditionalPutRequest) ShallowCopy() Request
ShallowCopy implements the Request interface.
func (*ConditionalPutRequest) Size ¶
func (m *ConditionalPutRequest) Size() (n int)
func (*ConditionalPutRequest) String ¶
func (m *ConditionalPutRequest) String() string
func (*ConditionalPutRequest) Unmarshal ¶
func (m *ConditionalPutRequest) Unmarshal(dAtA []byte) error
type ConditionalPutResponse ¶
type ConditionalPutResponse struct {
ResponseHeader `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
}
A ConditionalPutResponse is the return value from the ConditionalPut() method.
func (*ConditionalPutResponse) Descriptor ¶
func (*ConditionalPutResponse) Descriptor() ([]byte, []int)
func (*ConditionalPutResponse) Marshal ¶
func (m *ConditionalPutResponse) Marshal() (dAtA []byte, err error)
func (*ConditionalPutResponse) MarshalTo ¶
func (m *ConditionalPutResponse) MarshalTo(dAtA []byte) (int, error)
func (*ConditionalPutResponse) ProtoMessage ¶
func (*ConditionalPutResponse) ProtoMessage()
func (*ConditionalPutResponse) Reset ¶
func (m *ConditionalPutResponse) Reset()
func (*ConditionalPutResponse) Size ¶
func (m *ConditionalPutResponse) Size() (n int)
func (*ConditionalPutResponse) String ¶
func (m *ConditionalPutResponse) String() string
func (*ConditionalPutResponse) Unmarshal ¶
func (m *ConditionalPutResponse) Unmarshal(dAtA []byte) error
type DeleteRangeRequest ¶
type DeleteRangeRequest struct { Span `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"` // return the keys that are deleted in the response. ReturnKeys bool `protobuf:"varint,3,opt,name=return_keys,json=returnKeys" json:"return_keys"` // delete "inline" keys which are stored without MVCC timestamps. Note that // an "inline" DeleteRange will fail if it attempts to delete any keys which // contain timestamped (non-inline) values; this option should only be used on // keys which are known to store inline values, such as data in cockroach's // time series system. // // Similarly, attempts to delete keys with inline values will fail unless this // flag is set to true; the setting must match the data being deleted. // // Inline values cannot be deleted transactionally; a DeleteRange with // "inline" set to true will fail if it is executed within a transaction. Inline bool `protobuf:"varint,4,opt,name=inline" json:"inline"` }
A DeleteRangeRequest is the argument to the DeleteRange() method. It specifies the range of keys to delete.
func (*DeleteRangeRequest) Descriptor ¶
func (*DeleteRangeRequest) Descriptor() ([]byte, []int)
func (*DeleteRangeRequest) Marshal ¶
func (m *DeleteRangeRequest) Marshal() (dAtA []byte, err error)
func (*DeleteRangeRequest) MarshalTo ¶
func (m *DeleteRangeRequest) MarshalTo(dAtA []byte) (int, error)
func (*DeleteRangeRequest) Method ¶
func (*DeleteRangeRequest) Method() Method
Method implements the Request interface.
func (*DeleteRangeRequest) ProtoMessage ¶
func (*DeleteRangeRequest) ProtoMessage()
func (*DeleteRangeRequest) Reset ¶
func (m *DeleteRangeRequest) Reset()
func (*DeleteRangeRequest) ShallowCopy ¶
func (drr *DeleteRangeRequest) ShallowCopy() Request
ShallowCopy implements the Request interface.
func (*DeleteRangeRequest) Size ¶
func (m *DeleteRangeRequest) Size() (n int)
func (*DeleteRangeRequest) String ¶
func (m *DeleteRangeRequest) String() string
func (*DeleteRangeRequest) Unmarshal ¶
func (m *DeleteRangeRequest) Unmarshal(dAtA []byte) error
type DeleteRangeResponse ¶
type DeleteRangeResponse struct { ResponseHeader `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"` // All the deleted keys if return_keys is set. Keys []Key `protobuf:"bytes,2,rep,name=keys,casttype=Key" json:"keys,omitempty"` }
A DeleteRangeResponse is the return value from the DeleteRange() method.
func (*DeleteRangeResponse) Descriptor ¶
func (*DeleteRangeResponse) Descriptor() ([]byte, []int)
func (*DeleteRangeResponse) Marshal ¶
func (m *DeleteRangeResponse) Marshal() (dAtA []byte, err error)
func (*DeleteRangeResponse) MarshalTo ¶
func (m *DeleteRangeResponse) MarshalTo(dAtA []byte) (int, error)
func (*DeleteRangeResponse) ProtoMessage ¶
func (*DeleteRangeResponse) ProtoMessage()
func (*DeleteRangeResponse) Reset ¶
func (m *DeleteRangeResponse) Reset()
func (*DeleteRangeResponse) Size ¶
func (m *DeleteRangeResponse) Size() (n int)
func (*DeleteRangeResponse) String ¶
func (m *DeleteRangeResponse) String() string
func (*DeleteRangeResponse) Unmarshal ¶
func (m *DeleteRangeResponse) Unmarshal(dAtA []byte) error
type DeleteRequest ¶
type DeleteRequest struct {
Span `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
}
A DeleteRequest is the argument to the Delete() method.
func (*DeleteRequest) Descriptor ¶
func (*DeleteRequest) Descriptor() ([]byte, []int)
func (*DeleteRequest) Marshal ¶
func (m *DeleteRequest) Marshal() (dAtA []byte, err error)
func (*DeleteRequest) Method ¶
func (*DeleteRequest) Method() Method
Method implements the Request interface.
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) Reset ¶
func (m *DeleteRequest) Reset()
func (*DeleteRequest) ShallowCopy ¶
func (dr *DeleteRequest) ShallowCopy() Request
ShallowCopy implements the Request interface.
func (*DeleteRequest) Size ¶
func (m *DeleteRequest) Size() (n int)
func (*DeleteRequest) String ¶
func (m *DeleteRequest) String() string
func (*DeleteRequest) Unmarshal ¶
func (m *DeleteRequest) Unmarshal(dAtA []byte) error
type DeleteResponse ¶
type DeleteResponse struct {
ResponseHeader `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
}
A DeleteResponse is the return value from the Delete() method.
func (*DeleteResponse) Descriptor ¶
func (*DeleteResponse) Descriptor() ([]byte, []int)
func (*DeleteResponse) Marshal ¶
func (m *DeleteResponse) Marshal() (dAtA []byte, err error)
func (*DeleteResponse) ProtoMessage ¶
func (*DeleteResponse) ProtoMessage()
func (*DeleteResponse) Reset ¶
func (m *DeleteResponse) Reset()
func (*DeleteResponse) Size ¶
func (m *DeleteResponse) Size() (n int)
func (*DeleteResponse) String ¶
func (m *DeleteResponse) String() string
func (*DeleteResponse) Unmarshal ¶
func (m *DeleteResponse) Unmarshal(dAtA []byte) error
type DeprecatedVerifyChecksumRequest ¶
type DeprecatedVerifyChecksumRequest struct {
Span `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
}
func (*DeprecatedVerifyChecksumRequest) Descriptor ¶
func (*DeprecatedVerifyChecksumRequest) Descriptor() ([]byte, []int)
func (*DeprecatedVerifyChecksumRequest) Marshal ¶
func (m *DeprecatedVerifyChecksumRequest) Marshal() (dAtA []byte, err error)
func (*DeprecatedVerifyChecksumRequest) MarshalTo ¶
func (m *DeprecatedVerifyChecksumRequest) MarshalTo(dAtA []byte) (int, error)
func (*DeprecatedVerifyChecksumRequest) Method ¶
func (*DeprecatedVerifyChecksumRequest) Method() Method
Method implements the Request interface.
func (*DeprecatedVerifyChecksumRequest) ProtoMessage ¶
func (*DeprecatedVerifyChecksumRequest) ProtoMessage()
func (*DeprecatedVerifyChecksumRequest) Reset ¶
func (m *DeprecatedVerifyChecksumRequest) Reset()
func (*DeprecatedVerifyChecksumRequest) ShallowCopy ¶
func (dvcr *DeprecatedVerifyChecksumRequest) ShallowCopy() Request
ShallowCopy implements the Request interface.
func (*DeprecatedVerifyChecksumRequest) Size ¶
func (m *DeprecatedVerifyChecksumRequest) Size() (n int)
func (*DeprecatedVerifyChecksumRequest) String ¶
func (m *DeprecatedVerifyChecksumRequest) String() string
func (*DeprecatedVerifyChecksumRequest) Unmarshal ¶
func (m *DeprecatedVerifyChecksumRequest) Unmarshal(dAtA []byte) error
type DeprecatedVerifyChecksumResponse ¶
type DeprecatedVerifyChecksumResponse struct {
ResponseHeader `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
}
func (*DeprecatedVerifyChecksumResponse) Descriptor ¶
func (*DeprecatedVerifyChecksumResponse) Descriptor() ([]byte, []int)
func (*DeprecatedVerifyChecksumResponse) Marshal ¶
func (m *DeprecatedVerifyChecksumResponse) Marshal() (dAtA []byte, err error)
func (*DeprecatedVerifyChecksumResponse) MarshalTo ¶
func (m *DeprecatedVerifyChecksumResponse) MarshalTo(dAtA []byte) (int, error)
func (*DeprecatedVerifyChecksumResponse) ProtoMessage ¶
func (*DeprecatedVerifyChecksumResponse) ProtoMessage()
func (*DeprecatedVerifyChecksumResponse) Reset ¶
func (m *DeprecatedVerifyChecksumResponse) Reset()
func (*DeprecatedVerifyChecksumResponse) Size ¶
func (m *DeprecatedVerifyChecksumResponse) Size() (n int)
func (*DeprecatedVerifyChecksumResponse) String ¶
func (m *DeprecatedVerifyChecksumResponse) String() string
func (*DeprecatedVerifyChecksumResponse) Unmarshal ¶
func (m *DeprecatedVerifyChecksumResponse) Unmarshal(dAtA []byte) error
type EndTransactionRequest ¶
type EndTransactionRequest struct { Span `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"` // False to abort and rollback. Commit bool `protobuf:"varint,2,opt,name=commit" json:"commit"` // The deadline by which the transaction must commit, if present. Deadline *cockroach_util_hlc.Timestamp `protobuf:"bytes,3,opt,name=deadline" json:"deadline,omitempty"` // Optional commit triggers. Note that commit triggers are for // internal use only and will cause an error if requested through the // external-facing KV API. InternalCommitTrigger *InternalCommitTrigger `protobuf:"bytes,4,opt,name=internal_commit_trigger,json=internalCommitTrigger" json:"internal_commit_trigger,omitempty"` // List of intents written by the transaction. IntentSpans []Span `protobuf:"bytes,5,rep,name=intent_spans,json=intentSpans" json:"intent_spans"` // Requires that the transaction completes as a 1 phase commit. This // guarantees that all writes are to the same range and that no // intents are left in the event of an error. Require1PC bool `protobuf:"varint,6,opt,name=require_1pc,json=require1pc" json:"require_1pc"` }
An EndTransactionRequest is the argument to the EndTransaction() method. It specifies whether to commit or roll back an extant transaction.
func (*EndTransactionRequest) Descriptor ¶
func (*EndTransactionRequest) Descriptor() ([]byte, []int)
func (*EndTransactionRequest) Marshal ¶
func (m *EndTransactionRequest) Marshal() (dAtA []byte, err error)
func (*EndTransactionRequest) MarshalTo ¶
func (m *EndTransactionRequest) MarshalTo(dAtA []byte) (int, error)
func (*EndTransactionRequest) Method ¶
func (*EndTransactionRequest) Method() Method
Method implements the Request interface.
func (*EndTransactionRequest) ProtoMessage ¶
func (*EndTransactionRequest) ProtoMessage()
func (*EndTransactionRequest) Reset ¶
func (m *EndTransactionRequest) Reset()
func (*EndTransactionRequest) ShallowCopy ¶
func (etr *EndTransactionRequest) ShallowCopy() Request
ShallowCopy implements the Request interface.
func (*EndTransactionRequest) Size ¶
func (m *EndTransactionRequest) Size() (n int)
func (*EndTransactionRequest) String ¶
func (m *EndTransactionRequest) String() string
func (*EndTransactionRequest) Unmarshal ¶
func (m *EndTransactionRequest) Unmarshal(dAtA []byte) error
type EndTransactionResponse ¶
type EndTransactionResponse struct { ResponseHeader `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"` // True if the transaction committed on the one phase commit path. // This means that all writes which were part of the transaction // were written as a single, atomic write batch to just one range. OnePhaseCommit bool `protobuf:"varint,4,opt,name=one_phase_commit,json=onePhaseCommit" json:"one_phase_commit"` }
An EndTransactionResponse is the return value from the EndTransaction() method. The final transaction record is returned as part of the response header. In particular, transaction status and timestamp will be updated to reflect final committed values. Clients may propagate the transaction timestamp as the final txn commit timestamp in order to preserve causal ordering between subsequent transactions.
func (*EndTransactionResponse) Descriptor ¶
func (*EndTransactionResponse) Descriptor() ([]byte, []int)
func (*EndTransactionResponse) Marshal ¶
func (m *EndTransactionResponse) Marshal() (dAtA []byte, err error)
func (*EndTransactionResponse) MarshalTo ¶
func (m *EndTransactionResponse) MarshalTo(dAtA []byte) (int, error)
func (*EndTransactionResponse) ProtoMessage ¶
func (*EndTransactionResponse) ProtoMessage()
func (*EndTransactionResponse) Reset ¶
func (m *EndTransactionResponse) Reset()
func (*EndTransactionResponse) Size ¶
func (m *EndTransactionResponse) Size() (n int)
func (*EndTransactionResponse) String ¶
func (m *EndTransactionResponse) String() string
func (*EndTransactionResponse) Unmarshal ¶
func (m *EndTransactionResponse) Unmarshal(dAtA []byte) error
type ErrPosition ¶
type ErrPosition struct {
Index int32 `protobuf:"varint,1,opt,name=index" json:"index"`
}
ErrPosition describes the position of an error in a Batch. A simple nullable primitive field would break compatibility with proto3, where primitive fields are no longer allowed to be nullable.
func (*ErrPosition) Descriptor ¶
func (*ErrPosition) Descriptor() ([]byte, []int)
func (*ErrPosition) Marshal ¶
func (m *ErrPosition) Marshal() (dAtA []byte, err error)
func (*ErrPosition) ProtoMessage ¶
func (*ErrPosition) ProtoMessage()
func (*ErrPosition) Reset ¶
func (m *ErrPosition) Reset()
func (*ErrPosition) Size ¶
func (m *ErrPosition) Size() (n int)
func (*ErrPosition) String ¶
func (m *ErrPosition) String() string
func (*ErrPosition) Unmarshal ¶
func (m *ErrPosition) Unmarshal(dAtA []byte) error