Versions in this module Expand all Collapse all v1 v1.0.5 Aug 17, 2017 v1.0.4 Jul 20, 2017 v1.0.3 Jul 6, 2017 v1.0.2 Jun 7, 2017 v1.0.1 May 18, 2017 Changes in this version + const MaxTxnPriority + const MaxUserPriority + const MinTxnPriority + const MinUserPriority + const NormalUserPriority + const UnspecifiedUserPriority + var ErrIntOverflowApi = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowAppStats = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowData = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowErrors = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowInternal = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowInternalRaft = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowMetadata = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthAppStats = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthData = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthErrors = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthInternal = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthInternalRaft = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthMetadata = fmt.Errorf("proto: negative length found during unmarshaling") + var ExportStorageProvider_name = map[int32]string + var ExportStorageProvider_value = map[string]int32 + var KeyMax = Key(RKeyMax) + var KeyMin = Key(RKeyMin) + var PrettyPrintKey func(key Key) string + var PrettyPrintRange func(start, end Key, maxChars int) string + var PushTxnType_name = map[int32]string + var PushTxnType_value = map[string]int32 + var RKeyMax = RKey + var RKeyMin = RKey("") + var ReadConsistencyType_name = map[int32]string + var ReadConsistencyType_value = map[string]int32 + var ReplicaChangeType_name = map[int32]string + var ReplicaChangeType_value = map[string]int32 + var TransactionRestart_name = map[int32]string + var TransactionRestart_value = map[string]int32 + var TransactionRetryReason_name = map[int32]string + var TransactionRetryReason_value = map[string]int32 + var TransactionStatus_name = map[int32]string + var TransactionStatus_value = map[string]int32 + var ValueType_name = map[int32]string + var ValueType_value = map[string]int32 + 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 struct + Key Key + Priority int32 + Timestamp cockroach_util_hlc.Timestamp + func NewPopulatedAbortCacheEntry(r randyData, easy bool) *AbortCacheEntry + func (*AbortCacheEntry) Descriptor() ([]byte, []int) + func (*AbortCacheEntry) ProtoMessage() + func (m *AbortCacheEntry) Marshal() (dAtA []byte, err error) + func (m *AbortCacheEntry) MarshalTo(dAtA []byte) (int, error) + func (m *AbortCacheEntry) Reset() + func (m *AbortCacheEntry) Size() (n int) + func (m *AbortCacheEntry) String() string + func (m *AbortCacheEntry) Unmarshal(dAtA []byte) error + type AdminChangeReplicasRequest struct + ChangeType ReplicaChangeType + Targets []ReplicationTarget + func (*AdminChangeReplicasRequest) Descriptor() ([]byte, []int) + func (*AdminChangeReplicasRequest) Method() Method + func (*AdminChangeReplicasRequest) ProtoMessage() + func (acrr *AdminChangeReplicasRequest) ShallowCopy() Request + func (m *AdminChangeReplicasRequest) Marshal() (dAtA []byte, err error) + func (m *AdminChangeReplicasRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AdminChangeReplicasRequest) Reset() + func (m *AdminChangeReplicasRequest) Size() (n int) + func (m *AdminChangeReplicasRequest) String() string + func (m *AdminChangeReplicasRequest) Unmarshal(dAtA []byte) error + type AdminChangeReplicasResponse struct + func (*AdminChangeReplicasResponse) Descriptor() ([]byte, []int) + func (*AdminChangeReplicasResponse) ProtoMessage() + func (m *AdminChangeReplicasResponse) Marshal() (dAtA []byte, err error) + func (m *AdminChangeReplicasResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AdminChangeReplicasResponse) Reset() + func (m *AdminChangeReplicasResponse) Size() (n int) + func (m *AdminChangeReplicasResponse) String() string + func (m *AdminChangeReplicasResponse) Unmarshal(dAtA []byte) error + type AdminMergeRequest struct + func (*AdminMergeRequest) Descriptor() ([]byte, []int) + func (*AdminMergeRequest) Method() Method + func (*AdminMergeRequest) ProtoMessage() + func (amr *AdminMergeRequest) ShallowCopy() Request + func (m *AdminMergeRequest) Marshal() (dAtA []byte, err error) + func (m *AdminMergeRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AdminMergeRequest) Reset() + func (m *AdminMergeRequest) Size() (n int) + func (m *AdminMergeRequest) String() string + func (m *AdminMergeRequest) Unmarshal(dAtA []byte) error + type AdminMergeResponse struct + func (*AdminMergeResponse) Descriptor() ([]byte, []int) + func (*AdminMergeResponse) ProtoMessage() + func (m *AdminMergeResponse) Marshal() (dAtA []byte, err error) + func (m *AdminMergeResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AdminMergeResponse) Reset() + func (m *AdminMergeResponse) Size() (n int) + func (m *AdminMergeResponse) String() string + func (m *AdminMergeResponse) Unmarshal(dAtA []byte) error + type AdminScatterRequest struct + func (*AdminScatterRequest) Descriptor() ([]byte, []int) + func (*AdminScatterRequest) Method() Method + func (*AdminScatterRequest) ProtoMessage() + func (m *AdminScatterRequest) Marshal() (dAtA []byte, err error) + func (m *AdminScatterRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AdminScatterRequest) Reset() + func (m *AdminScatterRequest) Size() (n int) + func (m *AdminScatterRequest) String() string + func (m *AdminScatterRequest) Unmarshal(dAtA []byte) error + func (r *AdminScatterRequest) ShallowCopy() Request + type AdminScatterResponse struct + Ranges []AdminScatterResponse_Range + func (*AdminScatterResponse) Descriptor() ([]byte, []int) + func (*AdminScatterResponse) ProtoMessage() + func (m *AdminScatterResponse) Marshal() (dAtA []byte, err error) + func (m *AdminScatterResponse) MarshalTo(dAtA []byte) (int, error) + 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 struct + Error *Error + Span Span + func (*AdminScatterResponse_Range) Descriptor() ([]byte, []int) + func (*AdminScatterResponse_Range) ProtoMessage() + func (m *AdminScatterResponse_Range) Marshal() (dAtA []byte, err error) + func (m *AdminScatterResponse_Range) MarshalTo(dAtA []byte) (int, error) + 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 struct + SplitKey Key + func (*AdminSplitRequest) Descriptor() ([]byte, []int) + func (*AdminSplitRequest) Method() Method + func (*AdminSplitRequest) ProtoMessage() + func (asr *AdminSplitRequest) ShallowCopy() Request + func (m *AdminSplitRequest) Marshal() (dAtA []byte, err error) + func (m *AdminSplitRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AdminSplitRequest) Reset() + func (m *AdminSplitRequest) Size() (n int) + func (m *AdminSplitRequest) String() string + func (m *AdminSplitRequest) Unmarshal(dAtA []byte) error + type AdminSplitResponse struct + func (*AdminSplitResponse) Descriptor() ([]byte, []int) + func (*AdminSplitResponse) ProtoMessage() + func (m *AdminSplitResponse) Marshal() (dAtA []byte, err error) + func (m *AdminSplitResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AdminSplitResponse) Reset() + func (m *AdminSplitResponse) Size() (n int) + func (m *AdminSplitResponse) String() string + func (m *AdminSplitResponse) Unmarshal(dAtA []byte) error + type AdminTransferLeaseRequest struct + Target StoreID + func (*AdminTransferLeaseRequest) Descriptor() ([]byte, []int) + func (*AdminTransferLeaseRequest) Method() Method + func (*AdminTransferLeaseRequest) ProtoMessage() + func (atlr *AdminTransferLeaseRequest) ShallowCopy() Request + func (m *AdminTransferLeaseRequest) Marshal() (dAtA []byte, err error) + func (m *AdminTransferLeaseRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AdminTransferLeaseRequest) Reset() + func (m *AdminTransferLeaseRequest) Size() (n int) + func (m *AdminTransferLeaseRequest) String() string + func (m *AdminTransferLeaseRequest) Unmarshal(dAtA []byte) error + type AdminTransferLeaseResponse struct + func (*AdminTransferLeaseResponse) Descriptor() ([]byte, []int) + func (*AdminTransferLeaseResponse) ProtoMessage() + func (m *AdminTransferLeaseResponse) Marshal() (dAtA []byte, err error) + func (m *AdminTransferLeaseResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AdminTransferLeaseResponse) Reset() + func (m *AdminTransferLeaseResponse) Size() (n int) + func (m *AdminTransferLeaseResponse) String() string + func (m *AdminTransferLeaseResponse) Unmarshal(dAtA []byte) error + type AmbiguousResultError struct + Message string + WrappedErr *Error + func NewAmbiguousResultError(msg string) *AmbiguousResultError + func (*AmbiguousResultError) Descriptor() ([]byte, []int) + func (*AmbiguousResultError) ProtoMessage() + func (e *AmbiguousResultError) Error() string + func (m *AmbiguousResultError) Marshal() (dAtA []byte, err error) + func (m *AmbiguousResultError) MarshalTo(dAtA []byte) (int, error) + func (m *AmbiguousResultError) Reset() + func (m *AmbiguousResultError) Size() (n int) + func (m *AmbiguousResultError) String() string + func (m *AmbiguousResultError) Unmarshal(dAtA []byte) error + type Attributes struct + Attrs []string + func (*Attributes) Descriptor() ([]byte, []int) + func (*Attributes) ProtoMessage() + func (a Attributes) IsSubset(b Attributes) bool + func (a Attributes) SortedString() string + func (a Attributes) String() string + func (m *Attributes) Marshal() (dAtA []byte, err error) + func (m *Attributes) MarshalTo(dAtA []byte) (int, error) + func (m *Attributes) Reset() + func (m *Attributes) Size() (n int) + func (m *Attributes) Unmarshal(dAtA []byte) error + type BatchRequest struct + Requests []RequestUnion + func (*BatchRequest) Descriptor() ([]byte, []int) + func (*BatchRequest) GetUser() string + func (*BatchRequest) ProtoMessage() + func (ba *BatchRequest) Add(requests ...Request) + func (ba *BatchRequest) CreateReply() *BatchResponse + func (ba *BatchRequest) GetArg(method Method) (Request, bool) + func (ba *BatchRequest) GetPrevLeaseForLeaseRequest() *Lease + 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 (ba *BatchRequest) Methods() []Method + func (ba *BatchRequest) SetActiveTimestamp(nowFn func() hlc.Timestamp) error + func (ba *BatchRequest) SetNewRequest() + func (ba *BatchRequest) Summary() string + func (ba *BatchRequest) UpdateTxn(otherTxn *Transaction) + func (ba BatchRequest) Split(canSplitET bool) [][]RequestUnion + func (ba BatchRequest) String() string + func (m *BatchRequest) Marshal() (dAtA []byte, err error) + func (m *BatchRequest) MarshalTo(dAtA []byte) (int, error) + func (m *BatchRequest) Reset() + func (m *BatchRequest) Size() (n int) + func (m *BatchRequest) Unmarshal(dAtA []byte) error + type BatchResponse struct + Responses []ResponseUnion + func (*BatchResponse) Descriptor() ([]byte, []int) + func (*BatchResponse) ProtoMessage() + func (br *BatchResponse) Add(reply Response) + func (br *BatchResponse) Combine(otherBatch *BatchResponse) error + func (br *BatchResponse) String() string + func (m *BatchResponse) Marshal() (dAtA []byte, err error) + func (m *BatchResponse) MarshalTo(dAtA []byte) (int, error) + func (m *BatchResponse) Reset() + func (m *BatchResponse) Size() (n int) + func (m *BatchResponse) Unmarshal(dAtA []byte) error + type BatchResponse_Header struct + CollectedSpans [][]byte + Error *Error + Now cockroach_util_hlc.Timestamp + Timestamp cockroach_util_hlc.Timestamp + Txn *Transaction + func (*BatchResponse_Header) Descriptor() ([]byte, []int) + func (*BatchResponse_Header) ProtoMessage() + func (m *BatchResponse_Header) Marshal() (dAtA []byte, err error) + func (m *BatchResponse_Header) MarshalTo(dAtA []byte) (int, error) + 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 struct + func (*BeginTransactionRequest) Descriptor() ([]byte, []int) + func (*BeginTransactionRequest) Method() Method + func (*BeginTransactionRequest) ProtoMessage() + func (btr *BeginTransactionRequest) ShallowCopy() Request + func (m *BeginTransactionRequest) Marshal() (dAtA []byte, err error) + func (m *BeginTransactionRequest) MarshalTo(dAtA []byte) (int, error) + func (m *BeginTransactionRequest) Reset() + func (m *BeginTransactionRequest) Size() (n int) + func (m *BeginTransactionRequest) String() string + func (m *BeginTransactionRequest) Unmarshal(dAtA []byte) error + type BeginTransactionResponse struct + func (*BeginTransactionResponse) Descriptor() ([]byte, []int) + func (*BeginTransactionResponse) ProtoMessage() + func (m *BeginTransactionResponse) Marshal() (dAtA []byte, err error) + func (m *BeginTransactionResponse) MarshalTo(dAtA []byte) (int, error) + func (m *BeginTransactionResponse) Reset() + func (m *BeginTransactionResponse) Size() (n int) + func (m *BeginTransactionResponse) String() string + func (m *BeginTransactionResponse) Unmarshal(dAtA []byte) error + type ChangeReplicasTrigger struct + ChangeType ReplicaChangeType + NextReplicaID ReplicaID + Replica ReplicaDescriptor + UpdatedReplicas []ReplicaDescriptor + func (*ChangeReplicasTrigger) Descriptor() ([]byte, []int) + func (*ChangeReplicasTrigger) ProtoMessage() + func (m *ChangeReplicasTrigger) Marshal() (dAtA []byte, err error) + func (m *ChangeReplicasTrigger) MarshalTo(dAtA []byte) (int, error) + func (m *ChangeReplicasTrigger) Reset() + func (m *ChangeReplicasTrigger) Size() (n int) + func (m *ChangeReplicasTrigger) String() string + func (m *ChangeReplicasTrigger) Unmarshal(dAtA []byte) error + type CheckConsistencyRequest struct + WithDiff bool + func (*CheckConsistencyRequest) Descriptor() ([]byte, []int) + func (*CheckConsistencyRequest) Method() Method + func (*CheckConsistencyRequest) ProtoMessage() + func (ccr *CheckConsistencyRequest) ShallowCopy() Request + func (m *CheckConsistencyRequest) Marshal() (dAtA []byte, err error) + func (m *CheckConsistencyRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CheckConsistencyRequest) Reset() + func (m *CheckConsistencyRequest) Size() (n int) + func (m *CheckConsistencyRequest) String() string + func (m *CheckConsistencyRequest) Unmarshal(dAtA []byte) error + type CheckConsistencyResponse struct + func (*CheckConsistencyResponse) Descriptor() ([]byte, []int) + func (*CheckConsistencyResponse) ProtoMessage() + func (m *CheckConsistencyResponse) Marshal() (dAtA []byte, err error) + func (m *CheckConsistencyResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CheckConsistencyResponse) Reset() + func (m *CheckConsistencyResponse) Size() (n int) + func (m *CheckConsistencyResponse) String() string + func (m *CheckConsistencyResponse) Unmarshal(dAtA []byte) error + type ComputeChecksumRequest struct + ChecksumID github_com_cockroachdb_cockroach_pkg_util_uuid.UUID + Snapshot bool + Version uint32 + func (*ComputeChecksumRequest) Descriptor() ([]byte, []int) + func (*ComputeChecksumRequest) Method() Method + func (*ComputeChecksumRequest) ProtoMessage() + func (ccr *ComputeChecksumRequest) ShallowCopy() Request + func (m *ComputeChecksumRequest) Marshal() (dAtA []byte, err error) + func (m *ComputeChecksumRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ComputeChecksumRequest) Reset() + func (m *ComputeChecksumRequest) Size() (n int) + func (m *ComputeChecksumRequest) String() string + func (m *ComputeChecksumRequest) Unmarshal(dAtA []byte) error + type ComputeChecksumResponse struct + func (*ComputeChecksumResponse) Descriptor() ([]byte, []int) + func (*ComputeChecksumResponse) ProtoMessage() + func (m *ComputeChecksumResponse) Marshal() (dAtA []byte, err error) + func (m *ComputeChecksumResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ComputeChecksumResponse) Reset() + func (m *ComputeChecksumResponse) Size() (n int) + func (m *ComputeChecksumResponse) String() string + func (m *ComputeChecksumResponse) Unmarshal(dAtA []byte) error + type ConditionFailedError struct + ActualValue *Value + func (*ConditionFailedError) Descriptor() ([]byte, []int) + func (*ConditionFailedError) ProtoMessage() + func (e *ConditionFailedError) Error() string + func (m *ConditionFailedError) Marshal() (dAtA []byte, err error) + func (m *ConditionFailedError) MarshalTo(dAtA []byte) (int, error) + func (m *ConditionFailedError) Reset() + func (m *ConditionFailedError) Size() (n int) + func (m *ConditionFailedError) String() string + func (m *ConditionFailedError) Unmarshal(dAtA []byte) error + type ConditionalPutRequest struct + Blind bool + ExpValue *Value + Value Value + func (*ConditionalPutRequest) Descriptor() ([]byte, []int) + func (*ConditionalPutRequest) Method() Method + func (*ConditionalPutRequest) ProtoMessage() + func (cpr *ConditionalPutRequest) ShallowCopy() Request + func (m *ConditionalPutRequest) Marshal() (dAtA []byte, err error) + func (m *ConditionalPutRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ConditionalPutRequest) Reset() + func (m *ConditionalPutRequest) Size() (n int) + func (m *ConditionalPutRequest) String() string + func (m *ConditionalPutRequest) Unmarshal(dAtA []byte) error + type ConditionalPutResponse struct + func (*ConditionalPutResponse) Descriptor() ([]byte, []int) + func (*ConditionalPutResponse) ProtoMessage() + func (m *ConditionalPutResponse) Marshal() (dAtA []byte, err error) + func (m *ConditionalPutResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ConditionalPutResponse) Reset() + func (m *ConditionalPutResponse) Size() (n int) + func (m *ConditionalPutResponse) String() string + func (m *ConditionalPutResponse) Unmarshal(dAtA []byte) error + type DeleteRangeRequest struct + Inline bool + ReturnKeys bool + func (*DeleteRangeRequest) Descriptor() ([]byte, []int) + func (*DeleteRangeRequest) Method() Method + func (*DeleteRangeRequest) ProtoMessage() + func (drr *DeleteRangeRequest) ShallowCopy() Request + func (m *DeleteRangeRequest) Marshal() (dAtA []byte, err error) + func (m *DeleteRangeRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteRangeRequest) Reset() + func (m *DeleteRangeRequest) Size() (n int) + func (m *DeleteRangeRequest) String() string + func (m *DeleteRangeRequest) Unmarshal(dAtA []byte) error + type DeleteRangeResponse struct + Keys []Key + func (*DeleteRangeResponse) Descriptor() ([]byte, []int) + func (*DeleteRangeResponse) ProtoMessage() + func (m *DeleteRangeResponse) Marshal() (dAtA []byte, err error) + func (m *DeleteRangeResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteRangeResponse) Reset() + func (m *DeleteRangeResponse) Size() (n int) + func (m *DeleteRangeResponse) String() string + func (m *DeleteRangeResponse) Unmarshal(dAtA []byte) error + type DeleteRequest struct + func (*DeleteRequest) Descriptor() ([]byte, []int) + func (*DeleteRequest) Method() Method + func (*DeleteRequest) ProtoMessage() + func (dr *DeleteRequest) ShallowCopy() Request + func (m *DeleteRequest) Marshal() (dAtA []byte, err error) + func (m *DeleteRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteRequest) Reset() + func (m *DeleteRequest) Size() (n int) + func (m *DeleteRequest) String() string + func (m *DeleteRequest) Unmarshal(dAtA []byte) error + type DeleteResponse struct + func (*DeleteResponse) Descriptor() ([]byte, []int) + func (*DeleteResponse) ProtoMessage() + func (m *DeleteResponse) Marshal() (dAtA []byte, err error) + func (m *DeleteResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteResponse) Reset() + func (m *DeleteResponse) Size() (n int) + func (m *DeleteResponse) String() string + func (m *DeleteResponse) Unmarshal(dAtA []byte) error + type DeprecatedVerifyChecksumRequest struct + func (*DeprecatedVerifyChecksumRequest) Descriptor() ([]byte, []int) + func (*DeprecatedVerifyChecksumRequest) Method() Method + func (*DeprecatedVerifyChecksumRequest) ProtoMessage() + func (dvcr *DeprecatedVerifyChecksumRequest) ShallowCopy() Request + func (m *DeprecatedVerifyChecksumRequest) Marshal() (dAtA []byte, err error) + func (m *DeprecatedVerifyChecksumRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeprecatedVerifyChecksumRequest) Reset() + func (m *DeprecatedVerifyChecksumRequest) Size() (n int) + func (m *DeprecatedVerifyChecksumRequest) String() string + func (m *DeprecatedVerifyChecksumRequest) Unmarshal(dAtA []byte) error + type DeprecatedVerifyChecksumResponse struct + func (*DeprecatedVerifyChecksumResponse) Descriptor() ([]byte, []int) + func (*DeprecatedVerifyChecksumResponse) ProtoMessage() + func (m *DeprecatedVerifyChecksumResponse) Marshal() (dAtA []byte, err error) + func (m *DeprecatedVerifyChecksumResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DeprecatedVerifyChecksumResponse) Reset() + func (m *DeprecatedVerifyChecksumResponse) Size() (n int) + func (m *DeprecatedVerifyChecksumResponse) String() string + func (m *DeprecatedVerifyChecksumResponse) Unmarshal(dAtA []byte) error + type EndTransactionRequest struct + Commit bool + Deadline *cockroach_util_hlc.Timestamp + IntentSpans []Span + InternalCommitTrigger *InternalCommitTrigger + Require1PC bool + func (*EndTransactionRequest) Descriptor() ([]byte, []int) + func (*EndTransactionRequest) Method() Method + func (*EndTransactionRequest) ProtoMessage() + func (etr *EndTransactionRequest) ShallowCopy() Request + func (m *EndTransactionRequest) Marshal() (dAtA []byte, err error) + func (m *EndTransactionRequest) MarshalTo(dAtA []byte) (int, error) + func (m *EndTransactionRequest) Reset() + func (m *EndTransactionRequest) Size() (n int) + func (m *EndTransactionRequest) String() string + func (m *EndTransactionRequest) Unmarshal(dAtA []byte) error + type EndTransactionResponse struct + OnePhaseCommit bool + func (*EndTransactionResponse) Descriptor() ([]byte, []int) + func (*EndTransactionResponse) ProtoMessage() + func (m *EndTransactionResponse) Marshal() (dAtA []byte, err error) + func (m *EndTransactionResponse) MarshalTo(dAtA []byte) (int, error) + func (m *EndTransactionResponse) Reset() + func (m *EndTransactionResponse) Size() (n int) + func (m *EndTransactionResponse) String() string + func (m *EndTransactionResponse) Unmarshal(dAtA []byte) error + type ErrPosition struct + Index int32 + func (*ErrPosition) Descriptor() ([]byte, []int) + func (*ErrPosition) ProtoMessage() + func (m *ErrPosition) Marshal() (dAtA []byte, err error) + func (m *ErrPosition) MarshalTo(dAtA []byte) (int, error) + func (m *ErrPosition) Reset() + func (m *ErrPosition) Size() (n int) + func (m *ErrPosition) String() string + func (m *ErrPosition) Unmarshal(dAtA []byte) error + type Error struct + Detail *ErrorDetail + Index *ErrPosition + Message string + Now cockroach_util_hlc.Timestamp + OriginNode NodeID + TransactionRestart TransactionRestart + UnexposedTxn *Transaction + func NewError(err error) *Error + func NewErrorWithTxn(err error, txn *Transaction) *Error + func NewErrorf(format string, a ...interface{}) *Error + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (e *Error) GetDetail() ErrorDetailInterface + func (e *Error) GetTxn() *Transaction + func (e *Error) GoError() error + func (e *Error) SetErrorIndex(index int32) + func (e *Error) SetTxn(txn *Transaction) + func (e *Error) String() string + func (e *Error) UpdateTxn(o *Transaction) + func (m *Error) Marshal() (dAtA []byte, err error) + func (m *Error) MarshalTo(dAtA []byte) (int, error) + func (m *Error) Reset() + func (m *Error) Size() (n int) + func (m *Error) Unmarshal(dAtA []byte) error + type ErrorDetail struct + AmbiguousResult *AmbiguousResultError + ConditionFailed *ConditionFailedError + HandledRetryableTxnError *HandledRetryableTxnError + LeaseRejected *LeaseRejectedError + NodeUnavailable *NodeUnavailableError + NotLeaseHolder *NotLeaseHolderError + OpRequiresTxn *OpRequiresTxnError + RaftGroupDeleted *RaftGroupDeletedError + RangeKeyMismatch *RangeKeyMismatchError + RangeNotFound *RangeNotFoundError + ReadWithinUncertaintyInterval *ReadWithinUncertaintyIntervalError + ReplicaCorruption *ReplicaCorruptionError + ReplicaTooOld *ReplicaTooOldError + Send *SendError + StoreNotFound *StoreNotFoundError + TransactionAborted *TransactionAbortedError + TransactionPush *TransactionPushError + TransactionReplay *TransactionReplayError + TransactionRetry *TransactionRetryError + TransactionStatus *TransactionStatusError + WriteIntent *WriteIntentError + WriteTooOld *WriteTooOldError + func (*ErrorDetail) Descriptor() ([]byte, []int) + func (*ErrorDetail) ProtoMessage() + func (m *ErrorDetail) Marshal() (dAtA []byte, err error) + func (m *ErrorDetail) MarshalTo(dAtA []byte) (int, error) + func (m *ErrorDetail) Reset() + func (m *ErrorDetail) Size() (n int) + func (m *ErrorDetail) String() string + func (m *ErrorDetail) Unmarshal(dAtA []byte) error + func (this *ErrorDetail) GetValue() interface{} + func (this *ErrorDetail) SetValue(value interface{}) bool + type ErrorDetailInterface interface + type ExportRequest struct + StartTime cockroach_util_hlc.Timestamp + Storage ExportStorage + func (*ExportRequest) Descriptor() ([]byte, []int) + func (*ExportRequest) Method() Method + func (*ExportRequest) ProtoMessage() + func (ekr *ExportRequest) ShallowCopy() Request + func (m *ExportRequest) Marshal() (dAtA []byte, err error) + func (m *ExportRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ExportRequest) Reset() + func (m *ExportRequest) Size() (n int) + func (m *ExportRequest) String() string + func (m *ExportRequest) Unmarshal(dAtA []byte) error + type ExportResponse struct + Files []ExportResponse_File + func (*ExportResponse) Descriptor() ([]byte, []int) + func (*ExportResponse) ProtoMessage() + func (m *ExportResponse) Marshal() (dAtA []byte, err error) + func (m *ExportResponse) MarshalTo(dAtA []byte) (int, error) + 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 struct + DataSize int64 + Path string + Sha512 []byte + Span Span + func (*ExportResponse_File) Descriptor() ([]byte, []int) + func (*ExportResponse_File) ProtoMessage() + func (m *ExportResponse_File) Marshal() (dAtA []byte, err error) + func (m *ExportResponse_File) MarshalTo(dAtA []byte) (int, error) + 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 struct + AzureConfig *ExportStorage_Azure + GoogleCloudConfig *ExportStorage_GCS + HttpPath ExportStorage_Http + LocalFile ExportStorage_LocalFilePath + Provider ExportStorageProvider + S3Config *ExportStorage_S3 + func (*ExportStorage) Descriptor() ([]byte, []int) + func (*ExportStorage) ProtoMessage() + func (m *ExportStorage) Marshal() (dAtA []byte, err error) + func (m *ExportStorage) MarshalTo(dAtA []byte) (int, error) + func (m *ExportStorage) Reset() + func (m *ExportStorage) Size() (n int) + func (m *ExportStorage) String() string + func (m *ExportStorage) Unmarshal(dAtA []byte) error + type ExportStorageProvider int32 + const ExportStorageProvider_Azure + const ExportStorageProvider_GoogleCloud + const ExportStorageProvider_Http + const ExportStorageProvider_LocalFile + const ExportStorageProvider_S3 + const ExportStorageProvider_Unknown + func (ExportStorageProvider) EnumDescriptor() ([]byte, []int) + func (x *ExportStorageProvider) UnmarshalJSON(data []byte) error + func (x ExportStorageProvider) Enum() *ExportStorageProvider + func (x ExportStorageProvider) String() string + type ExportStorage_Azure struct + AccountKey string + AccountName string + Container string + Prefix string + func (*ExportStorage_Azure) Descriptor() ([]byte, []int) + func (*ExportStorage_Azure) ProtoMessage() + func (m *ExportStorage_Azure) Marshal() (dAtA []byte, err error) + func (m *ExportStorage_Azure) MarshalTo(dAtA []byte) (int, error) + 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 struct + Bucket string + Prefix string + func (*ExportStorage_GCS) Descriptor() ([]byte, []int) + func (*ExportStorage_GCS) ProtoMessage() + func (m *ExportStorage_GCS) Marshal() (dAtA []byte, err error) + func (m *ExportStorage_GCS) MarshalTo(dAtA []byte) (int, error) + 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 struct + BaseUri string + func (*ExportStorage_Http) Descriptor() ([]byte, []int) + func (*ExportStorage_Http) ProtoMessage() + func (m *ExportStorage_Http) Marshal() (dAtA []byte, err error) + func (m *ExportStorage_Http) MarshalTo(dAtA []byte) (int, error) + 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 struct + Path string + func (*ExportStorage_LocalFilePath) Descriptor() ([]byte, []int) + func (*ExportStorage_LocalFilePath) ProtoMessage() + func (m *ExportStorage_LocalFilePath) Marshal() (dAtA []byte, err error) + func (m *ExportStorage_LocalFilePath) MarshalTo(dAtA []byte) (int, error) + 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 struct + AccessKey string + Bucket string + Prefix string + Secret string + TempToken string + func (*ExportStorage_S3) Descriptor() ([]byte, []int) + func (*ExportStorage_S3) ProtoMessage() + 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 (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 interface + Batch func(ctx context.Context, in *BatchRequest, opts ...grpc.CallOption) (*BatchResponse, error) + func NewExternalClient(cc *grpc.ClientConn) ExternalClient + type ExternalServer interface + Batch func(context.Context, *BatchRequest) (*BatchResponse, error) + type GCRequest struct + Keys []GCRequest_GCKey + Threshold cockroach_util_hlc.Timestamp + TxnSpanGCThreshold cockroach_util_hlc.Timestamp + func (*GCRequest) Descriptor() ([]byte, []int) + func (*GCRequest) Method() Method + func (*GCRequest) ProtoMessage() + func (gcr *GCRequest) ShallowCopy() Request + func (m *GCRequest) Marshal() (dAtA []byte, err error) + func (m *GCRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GCRequest) Reset() + func (m *GCRequest) Size() (n int) + func (m *GCRequest) String() string + func (m *GCRequest) Unmarshal(dAtA []byte) error + type GCRequest_GCKey struct + Key Key + Timestamp cockroach_util_hlc.Timestamp + func (*GCRequest_GCKey) Descriptor() ([]byte, []int) + func (*GCRequest_GCKey) ProtoMessage() + func (m *GCRequest_GCKey) Marshal() (dAtA []byte, err error) + func (m *GCRequest_GCKey) MarshalTo(dAtA []byte) (int, error) + 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 struct + func (*GCResponse) Descriptor() ([]byte, []int) + func (*GCResponse) ProtoMessage() + func (m *GCResponse) Marshal() (dAtA []byte, err error) + func (m *GCResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GCResponse) Reset() + func (m *GCResponse) Size() (n int) + func (m *GCResponse) String() string + func (m *GCResponse) Unmarshal(dAtA []byte) error + type GetRequest struct + func (*GetRequest) Descriptor() ([]byte, []int) + func (*GetRequest) Method() Method + func (*GetRequest) ProtoMessage() + func (gr *GetRequest) ShallowCopy() Request + func (m *GetRequest) Marshal() (dAtA []byte, err error) + func (m *GetRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetRequest) Reset() + func (m *GetRequest) Size() (n int) + func (m *GetRequest) String() string + func (m *GetRequest) Unmarshal(dAtA []byte) error + type GetResponse struct + Value *Value + func (*GetResponse) Descriptor() ([]byte, []int) + func (*GetResponse) ProtoMessage() + func (gr *GetResponse) Verify(req Request) error + func (m *GetResponse) Marshal() (dAtA []byte, err error) + func (m *GetResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetResponse) Reset() + func (m *GetResponse) Size() (n int) + func (m *GetResponse) String() string + func (m *GetResponse) Unmarshal(dAtA []byte) error + type HandledRetryableTxnError struct + Msg string + Transaction *Transaction + TxnID *github_com_cockroachdb_cockroach_pkg_util_uuid.UUID + func NewHandledRetryableTxnError(msg string, txnID *uuid.UUID, txn Transaction) *HandledRetryableTxnError + func (*HandledRetryableTxnError) Descriptor() ([]byte, []int) + func (*HandledRetryableTxnError) ProtoMessage() + func (e *HandledRetryableTxnError) Error() string + func (m *HandledRetryableTxnError) Marshal() (dAtA []byte, err error) + func (m *HandledRetryableTxnError) MarshalTo(dAtA []byte) (int, error) + func (m *HandledRetryableTxnError) Reset() + func (m *HandledRetryableTxnError) Size() (n int) + func (m *HandledRetryableTxnError) String() string + func (m *HandledRetryableTxnError) Unmarshal(dAtA []byte) error + type Header struct + DistinctSpans bool + GatewayNodeID NodeID + MaxSpanRequestKeys int64 + RangeID RangeID + ReadConsistency ReadConsistencyType + Replica ReplicaDescriptor + ReturnRangeInfo bool + Timestamp cockroach_util_hlc.Timestamp + TraceContext *cockroach_util_tracing.SpanContextCarrier + Txn *Transaction + UserPriority UserPriority + func (*Header) Descriptor() ([]byte, []int) + func (*Header) ProtoMessage() + func (h Header) GetTxnID() *uuid.UUID + func (m *Header) Marshal() (dAtA []byte, err error) + func (m *Header) MarshalTo(dAtA []byte) (int, error) + func (m *Header) Reset() + func (m *Header) Size() (n int) + func (m *Header) String() string + func (m *Header) Unmarshal(dAtA []byte) error + type HeartbeatTxnRequest struct + Now cockroach_util_hlc.Timestamp + func (*HeartbeatTxnRequest) Descriptor() ([]byte, []int) + func (*HeartbeatTxnRequest) Method() Method + func (*HeartbeatTxnRequest) ProtoMessage() + func (htr *HeartbeatTxnRequest) ShallowCopy() Request + func (m *HeartbeatTxnRequest) Marshal() (dAtA []byte, err error) + func (m *HeartbeatTxnRequest) MarshalTo(dAtA []byte) (int, error) + func (m *HeartbeatTxnRequest) Reset() + func (m *HeartbeatTxnRequest) Size() (n int) + func (m *HeartbeatTxnRequest) String() string + func (m *HeartbeatTxnRequest) Unmarshal(dAtA []byte) error + type HeartbeatTxnResponse struct + func (*HeartbeatTxnResponse) Descriptor() ([]byte, []int) + func (*HeartbeatTxnResponse) ProtoMessage() + func (m *HeartbeatTxnResponse) Marshal() (dAtA []byte, err error) + func (m *HeartbeatTxnResponse) MarshalTo(dAtA []byte) (int, error) + func (m *HeartbeatTxnResponse) Reset() + func (m *HeartbeatTxnResponse) Size() (n int) + func (m *HeartbeatTxnResponse) String() string + func (m *HeartbeatTxnResponse) Unmarshal(dAtA []byte) error + type ImportRequest struct + DataSpan Span + Files []ImportRequest_File + Rekeys []ImportRequest_TableRekey + func (*ImportRequest) Descriptor() ([]byte, []int) + func (*ImportRequest) Method() Method + func (*ImportRequest) ProtoMessage() + func (m *ImportRequest) Marshal() (dAtA []byte, err error) + func (m *ImportRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ImportRequest) Reset() + func (m *ImportRequest) Size() (n int) + func (m *ImportRequest) String() string + func (m *ImportRequest) Unmarshal(dAtA []byte) error + func (r *ImportRequest) ShallowCopy() Request + type ImportRequest_File struct + Dir ExportStorage + Path string + Sha512 []byte + func (*ImportRequest_File) Descriptor() ([]byte, []int) + func (*ImportRequest_File) ProtoMessage() + func (m *ImportRequest_File) Marshal() (dAtA []byte, err error) + func (m *ImportRequest_File) MarshalTo(dAtA []byte) (int, error) + 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 struct + NewDesc []byte + OldID uint32 + func (*ImportRequest_TableRekey) Descriptor() ([]byte, []int) + func (*ImportRequest_TableRekey) ProtoMessage() + func (m *ImportRequest_TableRekey) Marshal() (dAtA []byte, err error) + func (m *ImportRequest_TableRekey) MarshalTo(dAtA []byte) (int, error) + 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 struct + DataSize int64 + func (*ImportResponse) Descriptor() ([]byte, []int) + func (*ImportResponse) ProtoMessage() + func (m *ImportResponse) Marshal() (dAtA []byte, err error) + func (m *ImportResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ImportResponse) Reset() + func (m *ImportResponse) Size() (n int) + func (m *ImportResponse) String() string + func (m *ImportResponse) Unmarshal(dAtA []byte) error + type IncrementRequest struct + Increment int64 + func (*IncrementRequest) Descriptor() ([]byte, []int) + func (*IncrementRequest) Method() Method + func (*IncrementRequest) ProtoMessage() + func (ir *IncrementRequest) ShallowCopy() Request + func (m *IncrementRequest) Marshal() (dAtA []byte, err error) + func (m *IncrementRequest) MarshalTo(dAtA []byte) (int, error) + func (m *IncrementRequest) Reset() + func (m *IncrementRequest) Size() (n int) + func (m *IncrementRequest) String() string + func (m *IncrementRequest) Unmarshal(dAtA []byte) error + type IncrementResponse struct + NewValue int64 + func (*IncrementResponse) Descriptor() ([]byte, []int) + func (*IncrementResponse) ProtoMessage() + func (m *IncrementResponse) Marshal() (dAtA []byte, err error) + func (m *IncrementResponse) MarshalTo(dAtA []byte) (int, error) + func (m *IncrementResponse) Reset() + func (m *IncrementResponse) Size() (n int) + func (m *IncrementResponse) String() string + func (m *IncrementResponse) Unmarshal(dAtA []byte) error + type InitPutRequest struct + Blind bool + Value Value + func (*InitPutRequest) Descriptor() ([]byte, []int) + func (*InitPutRequest) Method() Method + func (*InitPutRequest) ProtoMessage() + func (m *InitPutRequest) Marshal() (dAtA []byte, err error) + func (m *InitPutRequest) MarshalTo(dAtA []byte) (int, error) + func (m *InitPutRequest) Reset() + func (m *InitPutRequest) Size() (n int) + func (m *InitPutRequest) String() string + func (m *InitPutRequest) Unmarshal(dAtA []byte) error + func (pr *InitPutRequest) ShallowCopy() Request + type InitPutResponse struct + func (*InitPutResponse) Descriptor() ([]byte, []int) + func (*InitPutResponse) ProtoMessage() + func (m *InitPutResponse) Marshal() (dAtA []byte, err error) + func (m *InitPutResponse) MarshalTo(dAtA []byte) (int, error) + func (m *InitPutResponse) Reset() + func (m *InitPutResponse) Size() (n int) + func (m *InitPutResponse) String() string + func (m *InitPutResponse) Unmarshal(dAtA []byte) error + type Intent struct + Status TransactionStatus + Txn cockroach_storage_engine_enginepb.TxnMeta + func AsIntents(spans []Span, txn *Transaction) []Intent + func (*Intent) Descriptor() ([]byte, []int) + func (*Intent) ProtoMessage() + func (m *Intent) Marshal() (dAtA []byte, err error) + func (m *Intent) MarshalTo(dAtA []byte) (int, error) + func (m *Intent) Reset() + func (m *Intent) Size() (n int) + func (m *Intent) String() string + func (m *Intent) Unmarshal(dAtA []byte) error + type InternalClient interface + Batch func(ctx context.Context, in *BatchRequest, opts ...grpc.CallOption) (*BatchResponse, error) + func NewInternalClient(cc *grpc.ClientConn) InternalClient + type InternalCommitTrigger struct + ChangeReplicasTrigger *ChangeReplicasTrigger + MergeTrigger *MergeTrigger + ModifiedSpanTrigger *ModifiedSpanTrigger + SplitTrigger *SplitTrigger + func (*InternalCommitTrigger) Descriptor() ([]byte, []int) + func (*InternalCommitTrigger) ProtoMessage() + 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 (m *InternalCommitTrigger) Reset() + func (m *InternalCommitTrigger) Size() (n int) + func (m *InternalCommitTrigger) String() string + func (m *InternalCommitTrigger) Unmarshal(dAtA []byte) error + type InternalServer interface + Batch func(context.Context, *BatchRequest) (*BatchResponse, error) + type InternalTimeSeriesData struct + SampleDurationNanos int64 + Samples []InternalTimeSeriesSample + StartTimestampNanos int64 + func (*InternalTimeSeriesData) Descriptor() ([]byte, []int) + func (*InternalTimeSeriesData) ProtoMessage() + func (m *InternalTimeSeriesData) Marshal() (dAtA []byte, err error) + func (m *InternalTimeSeriesData) MarshalTo(dAtA []byte) (int, error) + func (m *InternalTimeSeriesData) Reset() + func (m *InternalTimeSeriesData) Size() (n int) + func (m *InternalTimeSeriesData) String() string + func (m *InternalTimeSeriesData) Unmarshal(dAtA []byte) error + type InternalTimeSeriesSample struct + Count uint32 + Max *float64 + Min *float64 + Offset int32 + Sum float64 + func (*InternalTimeSeriesSample) Descriptor() ([]byte, []int) + func (*InternalTimeSeriesSample) ProtoMessage() + func (m *InternalTimeSeriesSample) Marshal() (dAtA []byte, err error) + func (m *InternalTimeSeriesSample) MarshalTo(dAtA []byte) (int, error) + func (m *InternalTimeSeriesSample) Reset() + func (m *InternalTimeSeriesSample) Size() (n int) + func (m *InternalTimeSeriesSample) String() string + func (m *InternalTimeSeriesSample) Unmarshal(dAtA []byte) error + func (samp InternalTimeSeriesSample) Average() float64 + func (samp InternalTimeSeriesSample) Maximum() float64 + func (samp InternalTimeSeriesSample) Minimum() float64 + func (samp InternalTimeSeriesSample) Summation() float64 + type Key []byte + func (k Key) Compare(b Key) int + func (k Key) Equal(l Key) bool + func (k Key) Format(f fmt.State, verb rune) + func (k Key) IsPrev(m Key) bool + func (k Key) Next() Key + func (k Key) PrefixEnd() Key + func (k Key) String() string + type KeyValue struct + Key Key + Value Value + func (*KeyValue) Descriptor() ([]byte, []int) + func (*KeyValue) ProtoMessage() + func (m *KeyValue) Marshal() (dAtA []byte, err error) + func (m *KeyValue) MarshalTo(dAtA []byte) (int, error) + func (m *KeyValue) Reset() + func (m *KeyValue) Size() (n int) + func (m *KeyValue) String() string + func (m *KeyValue) Unmarshal(dAtA []byte) error + type KeyValueByKey []KeyValue + func (kv KeyValueByKey) Len() int + func (kv KeyValueByKey) Less(i, j int) bool + func (kv KeyValueByKey) Swap(i, j int) + type Lease struct + DeprecatedStartStasis cockroach_util_hlc.Timestamp + Epoch *int64 + Expiration cockroach_util_hlc.Timestamp + ProposedTS *cockroach_util_hlc.Timestamp + Replica ReplicaDescriptor + Start cockroach_util_hlc.Timestamp + func NewPopulatedLease(r randyData, easy bool) *Lease + func (*Lease) Descriptor() ([]byte, []int) + func (*Lease) ProtoMessage() + func (l Lease) Equivalent(ol Lease) error + func (l Lease) OwnedBy(storeID StoreID) bool + func (l Lease) String() string + func (l Lease) Type() LeaseType + func (m *Lease) Marshal() (dAtA []byte, err error) + func (m *Lease) MarshalTo(dAtA []byte) (int, error) + func (m *Lease) Reset() + func (m *Lease) Size() (n int) + func (m *Lease) Unmarshal(dAtA []byte) error + type LeaseInfoRequest struct + func (*LeaseInfoRequest) Descriptor() ([]byte, []int) + func (*LeaseInfoRequest) Method() Method + func (*LeaseInfoRequest) ProtoMessage() + func (lt *LeaseInfoRequest) ShallowCopy() Request + func (m *LeaseInfoRequest) Marshal() (dAtA []byte, err error) + func (m *LeaseInfoRequest) MarshalTo(dAtA []byte) (int, error) + func (m *LeaseInfoRequest) Reset() + func (m *LeaseInfoRequest) Size() (n int) + func (m *LeaseInfoRequest) String() string + func (m *LeaseInfoRequest) Unmarshal(dAtA []byte) error + type LeaseInfoResponse struct + Lease *Lease + func (*LeaseInfoResponse) Descriptor() ([]byte, []int) + func (*LeaseInfoResponse) ProtoMessage() + func (m *LeaseInfoResponse) Marshal() (dAtA []byte, err error) + func (m *LeaseInfoResponse) MarshalTo(dAtA []byte) (int, error) + func (m *LeaseInfoResponse) Reset() + func (m *LeaseInfoResponse) Size() (n int) + func (m *LeaseInfoResponse) String() string + func (m *LeaseInfoResponse) Unmarshal(dAtA []byte) error + type LeaseRejectedError struct + Existing Lease + Message string + Requested Lease + func (*LeaseRejectedError) Descriptor() ([]byte, []int) + func (*LeaseRejectedError) ProtoMessage() + func (e *LeaseRejectedError) Error() string + func (m *LeaseRejectedError) Marshal() (dAtA []byte, err error) + func (m *LeaseRejectedError) MarshalTo(dAtA []byte) (int, error) + func (m *LeaseRejectedError) Reset() + func (m *LeaseRejectedError) Size() (n int) + func (m *LeaseRejectedError) String() string + func (m *LeaseRejectedError) Unmarshal(dAtA []byte) error + type LeaseType int + const LeaseEpoch + const LeaseExpiration + const LeaseNone + type Locality struct + Tiers []Tier + func (*Locality) Descriptor() ([]byte, []int) + func (*Locality) ProtoMessage() + func (Locality) Type() string + func (l *Locality) Set(value string) error + func (l Locality) DiversityScore(other Locality) float64 + func (l Locality) String() string + func (m *Locality) Marshal() (dAtA []byte, err error) + func (m *Locality) MarshalTo(dAtA []byte) (int, error) + func (m *Locality) Reset() + func (m *Locality) Size() (n int) + func (m *Locality) Unmarshal(dAtA []byte) error + type MergeRequest struct + Value Value + func (*MergeRequest) Descriptor() ([]byte, []int) + func (*MergeRequest) Method() Method + func (*MergeRequest) ProtoMessage() + func (m *MergeRequest) Marshal() (dAtA []byte, err error) + func (m *MergeRequest) MarshalTo(dAtA []byte) (int, error) + func (m *MergeRequest) Reset() + func (m *MergeRequest) Size() (n int) + func (m *MergeRequest) String() string + func (m *MergeRequest) Unmarshal(dAtA []byte) error + func (mr *MergeRequest) ShallowCopy() Request + type MergeResponse struct + func (*MergeResponse) Descriptor() ([]byte, []int) + func (*MergeResponse) ProtoMessage() + func (m *MergeResponse) Marshal() (dAtA []byte, err error) + func (m *MergeResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MergeResponse) Reset() + func (m *MergeResponse) Size() (n int) + func (m *MergeResponse) String() string + func (m *MergeResponse) Unmarshal(dAtA []byte) error + type MergeTrigger struct + LeftDesc RangeDescriptor + RightDesc RangeDescriptor + func (*MergeTrigger) Descriptor() ([]byte, []int) + func (*MergeTrigger) ProtoMessage() + func (m *MergeTrigger) Marshal() (dAtA []byte, err error) + func (m *MergeTrigger) MarshalTo(dAtA []byte) (int, error) + func (m *MergeTrigger) Reset() + func (m *MergeTrigger) Size() (n int) + func (m *MergeTrigger) String() string + func (m *MergeTrigger) Unmarshal(dAtA []byte) error + type Method int + const AdminChangeReplicas + const AdminMerge + const AdminScatter + const AdminSplit + const AdminTransferLease + const BeginTransaction + const CheckConsistency + const ComputeChecksum + const ConditionalPut + const Delete + const DeleteRange + const DeprecatedVerifyChecksum + const EndTransaction + const Export + const GC + const Get + const HeartbeatTxn + const Import + const Increment + const InitPut + const LeaseInfo + const Merge + const Noop + const PushTxn + const Put + const QueryTxn + const RangeLookup + const RequestLease + const ResolveIntent + const ResolveIntentRange + const ReverseScan + const Scan + const TransferLease + const TruncateLog + const WriteBatch + func (i Method) String() string + type ModifiedSpanTrigger struct + NodeLivenessSpan *Span + SystemConfigSpan bool + func (*ModifiedSpanTrigger) Descriptor() ([]byte, []int) + func (*ModifiedSpanTrigger) ProtoMessage() + func (m *ModifiedSpanTrigger) Marshal() (dAtA []byte, err error) + func (m *ModifiedSpanTrigger) MarshalTo(dAtA []byte) (int, error) + func (m *ModifiedSpanTrigger) Reset() + func (m *ModifiedSpanTrigger) Size() (n int) + func (m *ModifiedSpanTrigger) String() string + func (m *ModifiedSpanTrigger) Unmarshal(dAtA []byte) error + type NodeDescriptor struct + Address cockroach_util.UnresolvedAddr + Attrs Attributes + Locality Locality + NodeID NodeID + func (*NodeDescriptor) Descriptor() ([]byte, []int) + func (*NodeDescriptor) ProtoMessage() + func (m *NodeDescriptor) Marshal() (dAtA []byte, err error) + func (m *NodeDescriptor) MarshalTo(dAtA []byte) (int, error) + func (m *NodeDescriptor) Reset() + func (m *NodeDescriptor) Size() (n int) + func (m *NodeDescriptor) String() string + func (m *NodeDescriptor) Unmarshal(dAtA []byte) error + type NodeID int32 + func (n NodeID) String() string + type NodeUnavailableError struct + func (*NodeUnavailableError) Descriptor() ([]byte, []int) + func (*NodeUnavailableError) ProtoMessage() + func (e *NodeUnavailableError) Error() string + func (m *NodeUnavailableError) Marshal() (dAtA []byte, err error) + func (m *NodeUnavailableError) MarshalTo(dAtA []byte) (int, error) + func (m *NodeUnavailableError) Reset() + func (m *NodeUnavailableError) Size() (n int) + func (m *NodeUnavailableError) String() string + func (m *NodeUnavailableError) Unmarshal(dAtA []byte) error + type NoopRequest struct + func (*NoopRequest) Descriptor() ([]byte, []int) + func (*NoopRequest) Header() Span + func (*NoopRequest) Method() Method + func (*NoopRequest) ProtoMessage() + func (*NoopRequest) SetHeader(_ Span) + func (m *NoopRequest) Marshal() (dAtA []byte, err error) + func (m *NoopRequest) MarshalTo(dAtA []byte) (int, error) + func (m *NoopRequest) Reset() + func (m *NoopRequest) Size() (n int) + func (m *NoopRequest) String() string + func (m *NoopRequest) Unmarshal(dAtA []byte) error + func (nr *NoopRequest) ShallowCopy() Request + type NoopResponse struct + func (*NoopResponse) Descriptor() ([]byte, []int) + func (*NoopResponse) Header() ResponseHeader + func (*NoopResponse) ProtoMessage() + func (*NoopResponse) SetHeader(_ ResponseHeader) + func (*NoopResponse) Verify(_ Request) error + func (m *NoopResponse) Marshal() (dAtA []byte, err error) + func (m *NoopResponse) MarshalTo(dAtA []byte) (int, error) + func (m *NoopResponse) Reset() + func (m *NoopResponse) Size() (n int) + func (m *NoopResponse) String() string + func (m *NoopResponse) Unmarshal(dAtA []byte) error + type NotLeaseHolderError struct + CustomMsg string + Lease *Lease + LeaseHolder *ReplicaDescriptor + RangeID RangeID + Replica ReplicaDescriptor + func (*NotLeaseHolderError) Descriptor() ([]byte, []int) + func (*NotLeaseHolderError) ProtoMessage() + func (e *NotLeaseHolderError) Error() string + func (m *NotLeaseHolderError) Marshal() (dAtA []byte, err error) + func (m *NotLeaseHolderError) MarshalTo(dAtA []byte) (int, error) + func (m *NotLeaseHolderError) Reset() + func (m *NotLeaseHolderError) Size() (n int) + func (m *NotLeaseHolderError) String() string + func (m *NotLeaseHolderError) Unmarshal(dAtA []byte) error + type NumericStat struct + Mean float64 + SquaredDiffs float64 + func (*NumericStat) Descriptor() ([]byte, []int) + func (*NumericStat) ProtoMessage() + func (l *NumericStat) GetVariance(count int64) float64 + func (l *NumericStat) Record(count int64, val float64) + func (m *NumericStat) Marshal() (dAtA []byte, err error) + func (m *NumericStat) MarshalTo(dAtA []byte) (int, error) + func (m *NumericStat) Reset() + func (m *NumericStat) Size() (n int) + func (m *NumericStat) String() string + func (m *NumericStat) Unmarshal(dAtA []byte) error + type ObservedTimestamp struct + NodeID NodeID + Timestamp cockroach_util_hlc.Timestamp + func NewPopulatedObservedTimestamp(r randyData, easy bool) *ObservedTimestamp + func (*ObservedTimestamp) Descriptor() ([]byte, []int) + func (*ObservedTimestamp) ProtoMessage() + func (m *ObservedTimestamp) Marshal() (dAtA []byte, err error) + func (m *ObservedTimestamp) MarshalTo(dAtA []byte) (int, error) + func (m *ObservedTimestamp) Reset() + func (m *ObservedTimestamp) Size() (n int) + func (m *ObservedTimestamp) String() string + func (m *ObservedTimestamp) Unmarshal(dAtA []byte) error + type OpRequiresTxnError struct + func (*OpRequiresTxnError) Descriptor() ([]byte, []int) + func (*OpRequiresTxnError) ProtoMessage() + func (e *OpRequiresTxnError) Error() string + func (m *OpRequiresTxnError) Marshal() (dAtA []byte, err error) + func (m *OpRequiresTxnError) MarshalTo(dAtA []byte) (int, error) + func (m *OpRequiresTxnError) Reset() + func (m *OpRequiresTxnError) Size() (n int) + func (m *OpRequiresTxnError) String() string + func (m *OpRequiresTxnError) Unmarshal(dAtA []byte) error + type PushTxnRequest struct + Force bool + NewPriorities bool + Now cockroach_util_hlc.Timestamp + PushTo cockroach_util_hlc.Timestamp + PushType PushTxnType + PusheeTxn cockroach_storage_engine_enginepb.TxnMeta + PusherTxn Transaction + func (*PushTxnRequest) Descriptor() ([]byte, []int) + func (*PushTxnRequest) Method() Method + func (*PushTxnRequest) ProtoMessage() + func (m *PushTxnRequest) Marshal() (dAtA []byte, err error) + func (m *PushTxnRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PushTxnRequest) Reset() + func (m *PushTxnRequest) Size() (n int) + func (m *PushTxnRequest) String() string + func (m *PushTxnRequest) Unmarshal(dAtA []byte) error + func (ptr *PushTxnRequest) ShallowCopy() Request + type PushTxnResponse struct + PusheeTxn Transaction + func (*PushTxnResponse) Descriptor() ([]byte, []int) + func (*PushTxnResponse) ProtoMessage() + func (m *PushTxnResponse) Marshal() (dAtA []byte, err error) + func (m *PushTxnResponse) MarshalTo(dAtA []byte) (int, error) + func (m *PushTxnResponse) Reset() + func (m *PushTxnResponse) Size() (n int) + func (m *PushTxnResponse) String() string + func (m *PushTxnResponse) Unmarshal(dAtA []byte) error + type PushTxnType int32 + const PUSH_ABORT + const PUSH_QUERY + const PUSH_TIMESTAMP + const PUSH_TOUCH + func (PushTxnType) EnumDescriptor() ([]byte, []int) + func (x *PushTxnType) UnmarshalJSON(data []byte) error + func (x PushTxnType) Enum() *PushTxnType + func (x PushTxnType) String() string + type PutRequest struct + Blind bool + Inline bool + Value Value + func (*PutRequest) Descriptor() ([]byte, []int) + func (*PutRequest) Method() Method + func (*PutRequest) ProtoMessage() + func (m *PutRequest) Marshal() (dAtA []byte, err error) + func (m *PutRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PutRequest) Reset() + func (m *PutRequest) Size() (n int) + func (m *PutRequest) String() string + func (m *PutRequest) Unmarshal(dAtA []byte) error + func (pr *PutRequest) ShallowCopy() Request + type PutResponse struct + func (*PutResponse) Descriptor() ([]byte, []int) + func (*PutResponse) ProtoMessage() + func (m *PutResponse) Marshal() (dAtA []byte, err error) + func (m *PutResponse) MarshalTo(dAtA []byte) (int, error) + func (m *PutResponse) Reset() + func (m *PutResponse) Size() (n int) + func (m *PutResponse) String() string + func (m *PutResponse) Unmarshal(dAtA []byte) error + type QueryTxnRequest struct + Txn cockroach_storage_engine_enginepb.TxnMeta + func (*QueryTxnRequest) Descriptor() ([]byte, []int) + func (*QueryTxnRequest) Method() Method + func (*QueryTxnRequest) ProtoMessage() + func (m *QueryTxnRequest) Marshal() (dAtA []byte, err error) + func (m *QueryTxnRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryTxnRequest) Reset() + func (m *QueryTxnRequest) Size() (n int) + func (m *QueryTxnRequest) String() string + func (m *QueryTxnRequest) Unmarshal(dAtA []byte) error + func (qtr *QueryTxnRequest) ShallowCopy() Request + type QueryTxnResponse struct + QueriedTxn Transaction + WaitingTxns []github_com_cockroachdb_cockroach_pkg_util_uuid.UUID + func (*QueryTxnResponse) Descriptor() ([]byte, []int) + func (*QueryTxnResponse) ProtoMessage() + func (m *QueryTxnResponse) Marshal() (dAtA []byte, err error) + func (m *QueryTxnResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryTxnResponse) Reset() + func (m *QueryTxnResponse) Size() (n int) + func (m *QueryTxnResponse) String() string + func (m *QueryTxnResponse) Unmarshal(dAtA []byte) error + type RKey Key + func (rk RKey) AsRawKey() Key + func (rk RKey) Equal(other []byte) bool + func (rk RKey) Less(otherRK RKey) bool + func (rk RKey) Next() RKey + func (rk RKey) PrefixEnd() RKey + func (rk RKey) String() string + type RSpan struct + EndKey RKey + Key RKey + 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 struct + func (*RaftGroupDeletedError) Descriptor() ([]byte, []int) + func (*RaftGroupDeletedError) ProtoMessage() + func (e *RaftGroupDeletedError) Error() string + func (m *RaftGroupDeletedError) Marshal() (dAtA []byte, err error) + func (m *RaftGroupDeletedError) MarshalTo(dAtA []byte) (int, error) + func (m *RaftGroupDeletedError) Reset() + func (m *RaftGroupDeletedError) Size() (n int) + func (m *RaftGroupDeletedError) String() string + func (m *RaftGroupDeletedError) Unmarshal(dAtA []byte) error + type RaftSnapshotData struct + KV []RaftSnapshotData_KeyValue + LogEntries [][]byte + RangeDescriptor RangeDescriptor + func (*RaftSnapshotData) Descriptor() ([]byte, []int) + func (*RaftSnapshotData) ProtoMessage() + func (m *RaftSnapshotData) Marshal() (dAtA []byte, err error) + func (m *RaftSnapshotData) MarshalTo(dAtA []byte) (int, error) + 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 struct + Key []byte + Timestamp cockroach_util_hlc.Timestamp + Value []byte + func (*RaftSnapshotData_KeyValue) Descriptor() ([]byte, []int) + func (*RaftSnapshotData_KeyValue) ProtoMessage() + func (m *RaftSnapshotData_KeyValue) Marshal() (dAtA []byte, err error) + func (m *RaftSnapshotData_KeyValue) MarshalTo(dAtA []byte) (int, error) + 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 struct + NextReplicaID ReplicaID + func (*RaftTombstone) Descriptor() ([]byte, []int) + func (*RaftTombstone) ProtoMessage() + func (m *RaftTombstone) Marshal() (dAtA []byte, err error) + func (m *RaftTombstone) MarshalTo(dAtA []byte) (int, error) + func (m *RaftTombstone) Reset() + func (m *RaftTombstone) Size() (n int) + func (m *RaftTombstone) String() string + func (m *RaftTombstone) Unmarshal(dAtA []byte) error + type RaftTruncatedState struct + Index uint64 + Term uint64 + func NewPopulatedRaftTruncatedState(r randyInternalRaft, easy bool) *RaftTruncatedState + func (*RaftTruncatedState) Descriptor() ([]byte, []int) + func (*RaftTruncatedState) ProtoMessage() + func (m *RaftTruncatedState) Marshal() (dAtA []byte, err error) + func (m *RaftTruncatedState) MarshalTo(dAtA []byte) (int, error) + func (m *RaftTruncatedState) Reset() + func (m *RaftTruncatedState) Size() (n int) + func (m *RaftTruncatedState) String() string + func (m *RaftTruncatedState) Unmarshal(dAtA []byte) error + type RangeDescriptor struct + EndKey RKey + NextReplicaID ReplicaID + RangeID RangeID + Replicas []ReplicaDescriptor + StartKey RKey + func (*RangeDescriptor) Descriptor() ([]byte, []int) + func (*RangeDescriptor) ProtoMessage() + func (m *RangeDescriptor) Marshal() (dAtA []byte, err error) + func (m *RangeDescriptor) MarshalTo(dAtA []byte) (int, error) + func (m *RangeDescriptor) Reset() + func (m *RangeDescriptor) Size() (n int) + func (m *RangeDescriptor) Unmarshal(dAtA []byte) error + func (r RangeDescriptor) ContainsExclusiveEndKey(key RKey) bool + func (r RangeDescriptor) ContainsKey(key RKey) bool + func (r RangeDescriptor) ContainsKeyRange(start, end RKey) bool + func (r RangeDescriptor) GetReplicaDescriptor(storeID StoreID) (ReplicaDescriptor, bool) + func (r RangeDescriptor) GetReplicaDescriptorByID(replicaID ReplicaID) (ReplicaDescriptor, bool) + func (r RangeDescriptor) IsInitialized() bool + func (r RangeDescriptor) RSpan() RSpan + func (r RangeDescriptor) String() string + func (r RangeDescriptor) Validate() error + func (this *RangeDescriptor) Equal(that interface{}) bool + type RangeID int64 + func (r RangeID) String() string + type RangeIDSlice []RangeID + func (r RangeIDSlice) Len() int + func (r RangeIDSlice) Less(i, j int) bool + func (r RangeIDSlice) Swap(i, j int) + type RangeInfo struct + Desc RangeDescriptor + Lease Lease + func InsertRangeInfo(ris []RangeInfo, ri RangeInfo) []RangeInfo + func (*RangeInfo) Descriptor() ([]byte, []int) + func (*RangeInfo) ProtoMessage() + func (m *RangeInfo) Marshal() (dAtA []byte, err error) + func (m *RangeInfo) MarshalTo(dAtA []byte) (int, error) + func (m *RangeInfo) Reset() + func (m *RangeInfo) Size() (n int) + func (m *RangeInfo) String() string + func (m *RangeInfo) Unmarshal(dAtA []byte) error + type RangeKeyMismatchError struct + MismatchedRange *RangeDescriptor + RequestEndKey Key + RequestStartKey Key + SuggestedRange *RangeDescriptor + func NewRangeKeyMismatchError(start, end Key, desc *RangeDescriptor) *RangeKeyMismatchError + func (*RangeKeyMismatchError) Descriptor() ([]byte, []int) + func (*RangeKeyMismatchError) ProtoMessage() + func (e *RangeKeyMismatchError) Error() string + func (m *RangeKeyMismatchError) Marshal() (dAtA []byte, err error) + func (m *RangeKeyMismatchError) MarshalTo(dAtA []byte) (int, error) + func (m *RangeKeyMismatchError) Reset() + func (m *RangeKeyMismatchError) Size() (n int) + func (m *RangeKeyMismatchError) String() string + func (m *RangeKeyMismatchError) Unmarshal(dAtA []byte) error + type RangeLookupRequest struct + MaxRanges int32 + Reverse bool + func (*RangeLookupRequest) Descriptor() ([]byte, []int) + func (*RangeLookupRequest) Method() Method + func (*RangeLookupRequest) ProtoMessage() + func (m *RangeLookupRequest) Marshal() (dAtA []byte, err error) + func (m *RangeLookupRequest) MarshalTo(dAtA []byte) (int, error) + func (m *RangeLookupRequest) Reset() + func (m *RangeLookupRequest) Size() (n int) + func (m *RangeLookupRequest) String() string + func (m *RangeLookupRequest) Unmarshal(dAtA []byte) error + func (rlr *RangeLookupRequest) ShallowCopy() Request + type RangeLookupResponse struct + PrefetchedRanges []RangeDescriptor + Ranges []RangeDescriptor + func (*RangeLookupResponse) Descriptor() ([]byte, []int) + func (*RangeLookupResponse) ProtoMessage() + func (m *RangeLookupResponse) Marshal() (dAtA []byte, err error) + func (m *RangeLookupResponse) MarshalTo(dAtA []byte) (int, error) + func (m *RangeLookupResponse) Reset() + func (m *RangeLookupResponse) Size() (n int) + func (m *RangeLookupResponse) String() string + func (m *RangeLookupResponse) Unmarshal(dAtA []byte) error + type RangeNotFoundError struct + RangeID RangeID + func NewRangeNotFoundError(rangeID RangeID) *RangeNotFoundError + func (*RangeNotFoundError) Descriptor() ([]byte, []int) + func (*RangeNotFoundError) ProtoMessage() + func (e *RangeNotFoundError) Error() string + func (m *RangeNotFoundError) Marshal() (dAtA []byte, err error) + func (m *RangeNotFoundError) MarshalTo(dAtA []byte) (int, error) + func (m *RangeNotFoundError) Reset() + func (m *RangeNotFoundError) Size() (n int) + func (m *RangeNotFoundError) String() string + func (m *RangeNotFoundError) Unmarshal(dAtA []byte) error + type ReadConsistencyType int32 + const CONSENSUS + const CONSISTENT + const INCONSISTENT + func (ReadConsistencyType) EnumDescriptor() ([]byte, []int) + func (x *ReadConsistencyType) UnmarshalJSON(data []byte) error + func (x ReadConsistencyType) Enum() *ReadConsistencyType + func (x ReadConsistencyType) String() string + type ReadWithinUncertaintyIntervalError struct + ExistingTimestamp cockroach_util_hlc.Timestamp + ReadTimestamp cockroach_util_hlc.Timestamp + func NewReadWithinUncertaintyIntervalError(readTS, existingTS hlc.Timestamp) *ReadWithinUncertaintyIntervalError + func (*ReadWithinUncertaintyIntervalError) Descriptor() ([]byte, []int) + func (*ReadWithinUncertaintyIntervalError) ProtoMessage() + func (e *ReadWithinUncertaintyIntervalError) Error() string + func (m *ReadWithinUncertaintyIntervalError) Marshal() (dAtA []byte, err error) + func (m *ReadWithinUncertaintyIntervalError) MarshalTo(dAtA []byte) (int, error) + func (m *ReadWithinUncertaintyIntervalError) Reset() + func (m *ReadWithinUncertaintyIntervalError) Size() (n int) + func (m *ReadWithinUncertaintyIntervalError) String() string + func (m *ReadWithinUncertaintyIntervalError) Unmarshal(dAtA []byte) error + type ReplicaChangeType int32 + const ADD_REPLICA + const REMOVE_REPLICA + func (ReplicaChangeType) EnumDescriptor() ([]byte, []int) + func (x *ReplicaChangeType) UnmarshalJSON(data []byte) error + func (x ReplicaChangeType) Enum() *ReplicaChangeType + func (x ReplicaChangeType) String() string + type ReplicaCorruptionError struct + ErrorMsg string + Processed bool + func (*ReplicaCorruptionError) Descriptor() ([]byte, []int) + func (*ReplicaCorruptionError) ProtoMessage() + func (e *ReplicaCorruptionError) Error() string + func (m *ReplicaCorruptionError) Marshal() (dAtA []byte, err error) + func (m *ReplicaCorruptionError) MarshalTo(dAtA []byte) (int, error) + func (m *ReplicaCorruptionError) Reset() + func (m *ReplicaCorruptionError) Size() (n int) + func (m *ReplicaCorruptionError) String() string + func (m *ReplicaCorruptionError) Unmarshal(dAtA []byte) error + type ReplicaDescriptor struct + NodeID NodeID + ReplicaID ReplicaID + StoreID StoreID + func NewPopulatedReplicaDescriptor(r randyMetadata, easy bool) *ReplicaDescriptor + func (*ReplicaDescriptor) Descriptor() ([]byte, []int) + func (*ReplicaDescriptor) ProtoMessage() + func (m *ReplicaDescriptor) Marshal() (dAtA []byte, err error) + func (m *ReplicaDescriptor) MarshalTo(dAtA []byte) (int, error) + func (m *ReplicaDescriptor) Reset() + func (m *ReplicaDescriptor) Size() (n int) + func (m *ReplicaDescriptor) Unmarshal(dAtA []byte) error + func (r ReplicaDescriptor) String() string + func (r ReplicaDescriptor) Validate() error + func (this *ReplicaDescriptor) Equal(that interface{}) bool + type ReplicaID int32 + func (r ReplicaID) String() string + type ReplicaIdent struct + RangeID RangeID + Replica ReplicaDescriptor + func (*ReplicaIdent) Descriptor() ([]byte, []int) + func (*ReplicaIdent) ProtoMessage() + func (m *ReplicaIdent) Marshal() (dAtA []byte, err error) + func (m *ReplicaIdent) MarshalTo(dAtA []byte) (int, error) + func (m *ReplicaIdent) Reset() + func (m *ReplicaIdent) Size() (n int) + func (m *ReplicaIdent) String() string + func (m *ReplicaIdent) Unmarshal(dAtA []byte) error + type ReplicaTooOldError struct + ReplicaID ReplicaID + func NewReplicaTooOldError(replicaID ReplicaID) *ReplicaTooOldError + func (*ReplicaTooOldError) Descriptor() ([]byte, []int) + func (*ReplicaTooOldError) ProtoMessage() + func (e *ReplicaTooOldError) Error() string + func (m *ReplicaTooOldError) Marshal() (dAtA []byte, err error) + func (m *ReplicaTooOldError) MarshalTo(dAtA []byte) (int, error) + func (m *ReplicaTooOldError) Reset() + func (m *ReplicaTooOldError) Size() (n int) + func (m *ReplicaTooOldError) String() string + func (m *ReplicaTooOldError) Unmarshal(dAtA []byte) error + type ReplicationTarget struct + NodeID NodeID + StoreID StoreID + func (*ReplicationTarget) Descriptor() ([]byte, []int) + func (*ReplicationTarget) ProtoMessage() + func (m *ReplicationTarget) Marshal() (dAtA []byte, err error) + func (m *ReplicationTarget) MarshalTo(dAtA []byte) (int, error) + func (m *ReplicationTarget) Reset() + func (m *ReplicationTarget) Size() (n int) + func (m *ReplicationTarget) Unmarshal(dAtA []byte) error + func (r ReplicationTarget) String() string + type Request interface + Header func() Span + Method func() Method + SetHeader func(Span) + ShallowCopy func() 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 struct + Lease Lease + PrevLease *Lease + func (*RequestLeaseRequest) Descriptor() ([]byte, []int) + func (*RequestLeaseRequest) Method() Method + func (*RequestLeaseRequest) ProtoMessage() + func (m *RequestLeaseRequest) Marshal() (dAtA []byte, err error) + func (m *RequestLeaseRequest) MarshalTo(dAtA []byte) (int, error) + func (m *RequestLeaseRequest) Reset() + func (m *RequestLeaseRequest) Size() (n int) + func (m *RequestLeaseRequest) String() string + func (m *RequestLeaseRequest) Unmarshal(dAtA []byte) error + func (rlr *RequestLeaseRequest) ShallowCopy() Request + type RequestLeaseResponse struct + func (*RequestLeaseResponse) Descriptor() ([]byte, []int) + func (*RequestLeaseResponse) ProtoMessage() + func (m *RequestLeaseResponse) Marshal() (dAtA []byte, err error) + func (m *RequestLeaseResponse) MarshalTo(dAtA []byte) (int, error) + func (m *RequestLeaseResponse) Reset() + func (m *RequestLeaseResponse) Size() (n int) + func (m *RequestLeaseResponse) String() string + func (m *RequestLeaseResponse) Unmarshal(dAtA []byte) error + type RequestUnion struct + AdminChangeReplicas *AdminChangeReplicasRequest + AdminMerge *AdminMergeRequest + AdminScatter *AdminScatterRequest + AdminSplit *AdminSplitRequest + AdminTransferLease *AdminTransferLeaseRequest + BeginTransaction *BeginTransactionRequest + CheckConsistency *CheckConsistencyRequest + ComputeChecksum *ComputeChecksumRequest + ConditionalPut *ConditionalPutRequest + Delete *DeleteRequest + DeleteRange *DeleteRangeRequest + DeprecatedVerifyChecksum *DeprecatedVerifyChecksumRequest + EndTransaction *EndTransactionRequest + Export *ExportRequest + Gc *GCRequest + Get *GetRequest + HeartbeatTxn *HeartbeatTxnRequest + Import *ImportRequest + Increment *IncrementRequest + InitPut *InitPutRequest + LeaseInfo *LeaseInfoRequest + Merge *MergeRequest + Noop *NoopRequest + PushTxn *PushTxnRequest + Put *PutRequest + QueryTxn *QueryTxnRequest + RangeLookup *RangeLookupRequest + RequestLease *RequestLeaseRequest + ResolveIntent *ResolveIntentRequest + ResolveIntentRange *ResolveIntentRangeRequest + ReverseScan *ReverseScanRequest + Scan *ScanRequest + TransferLease *TransferLeaseRequest + TruncateLog *TruncateLogRequest + WriteBatch *WriteBatchRequest + func (*RequestUnion) Descriptor() ([]byte, []int) + func (*RequestUnion) ProtoMessage() + func (m *RequestUnion) Marshal() (dAtA []byte, err error) + func (m *RequestUnion) MarshalTo(dAtA []byte) (int, error) + func (m *RequestUnion) Reset() + func (m *RequestUnion) Size() (n int) + func (m *RequestUnion) String() string + func (m *RequestUnion) Unmarshal(dAtA []byte) error + func (ru *RequestUnion) MustSetInner(args Request) + func (ru RequestUnion) GetInner() Request + func (this *RequestUnion) GetValue() interface{} + func (this *RequestUnion) SetValue(value interface{}) bool + type ResolveIntentRangeRequest struct + IntentTxn cockroach_storage_engine_enginepb.TxnMeta + Poison bool + Status TransactionStatus + func (*ResolveIntentRangeRequest) Descriptor() ([]byte, []int) + func (*ResolveIntentRangeRequest) Method() Method + func (*ResolveIntentRangeRequest) ProtoMessage() + func (m *ResolveIntentRangeRequest) Marshal() (dAtA []byte, err error) + func (m *ResolveIntentRangeRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ResolveIntentRangeRequest) Reset() + func (m *ResolveIntentRangeRequest) Size() (n int) + func (m *ResolveIntentRangeRequest) String() string + func (m *ResolveIntentRangeRequest) Unmarshal(dAtA []byte) error + func (rirr *ResolveIntentRangeRequest) ShallowCopy() Request + type ResolveIntentRangeResponse struct + func (*ResolveIntentRangeResponse) Descriptor() ([]byte, []int) + func (*ResolveIntentRangeResponse) ProtoMessage() + func (m *ResolveIntentRangeResponse) Marshal() (dAtA []byte, err error) + func (m *ResolveIntentRangeResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ResolveIntentRangeResponse) Reset() + func (m *ResolveIntentRangeResponse) Size() (n int) + func (m *ResolveIntentRangeResponse) String() string + func (m *ResolveIntentRangeResponse) Unmarshal(dAtA []byte) error + type ResolveIntentRequest struct + IntentTxn cockroach_storage_engine_enginepb.TxnMeta + Poison bool + Status TransactionStatus + func (*ResolveIntentRequest) Descriptor() ([]byte, []int) + func (*ResolveIntentRequest) Method() Method + func (*ResolveIntentRequest) ProtoMessage() + func (m *ResolveIntentRequest) Marshal() (dAtA []byte, err error) + func (m *ResolveIntentRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ResolveIntentRequest) Reset() + func (m *ResolveIntentRequest) Size() (n int) + func (m *ResolveIntentRequest) String() string + func (m *ResolveIntentRequest) Unmarshal(dAtA []byte) error + func (rir *ResolveIntentRequest) ShallowCopy() Request + type ResolveIntentResponse struct + func (*ResolveIntentResponse) Descriptor() ([]byte, []int) + func (*ResolveIntentResponse) ProtoMessage() + func (m *ResolveIntentResponse) Marshal() (dAtA []byte, err error) + func (m *ResolveIntentResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ResolveIntentResponse) Reset() + func (m *ResolveIntentResponse) Size() (n int) + func (m *ResolveIntentResponse) String() string + func (m *ResolveIntentResponse) Unmarshal(dAtA []byte) error + type Response interface + Header func() ResponseHeader + SetHeader func(ResponseHeader) + Verify func(req Request) error + type ResponseHeader struct + NumKeys int64 + RangeInfos []RangeInfo + ResumeSpan *Span + Txn *Transaction + func (*ResponseHeader) Descriptor() ([]byte, []int) + func (*ResponseHeader) ProtoMessage() + func (m *ResponseHeader) Marshal() (dAtA []byte, err error) + func (m *ResponseHeader) MarshalTo(dAtA []byte) (int, error) + func (m *ResponseHeader) Reset() + func (m *ResponseHeader) Size() (n int) + func (m *ResponseHeader) String() string + func (m *ResponseHeader) Unmarshal(dAtA []byte) error + func (rh *ResponseHeader) SetHeader(other ResponseHeader) + func (rh *ResponseHeader) Verify(req Request) error + func (rh ResponseHeader) Header() ResponseHeader + type ResponseUnion struct + AdminChangeReplicas *AdminChangeReplicasResponse + AdminMerge *AdminMergeResponse + AdminScatter *AdminScatterResponse + AdminSplit *AdminSplitResponse + AdminTransferLease *AdminTransferLeaseResponse + BeginTransaction *BeginTransactionResponse + CheckConsistency *CheckConsistencyResponse + ComputeChecksum *ComputeChecksumResponse + ConditionalPut *ConditionalPutResponse + Delete *DeleteResponse + DeleteRange *DeleteRangeResponse + DeprecatedVerifyChecksum *DeprecatedVerifyChecksumResponse + EndTransaction *EndTransactionResponse + Export *ExportResponse + Gc *GCResponse + Get *GetResponse + HeartbeatTxn *HeartbeatTxnResponse + Import *ImportResponse + Increment *IncrementResponse + InitPut *InitPutResponse + LeaseInfo *LeaseInfoResponse + Merge *MergeResponse + Noop *NoopResponse + PushTxn *PushTxnResponse + Put *PutResponse + QueryTxn *QueryTxnResponse + RangeLookup *RangeLookupResponse + RequestLease *RequestLeaseResponse + ResolveIntent *ResolveIntentResponse + ResolveIntentRange *ResolveIntentRangeResponse + ReverseScan *ReverseScanResponse + Scan *ScanResponse + TruncateLog *TruncateLogResponse + WriteBatch *WriteBatchResponse + func (*ResponseUnion) Descriptor() ([]byte, []int) + func (*ResponseUnion) ProtoMessage() + func (m *ResponseUnion) Marshal() (dAtA []byte, err error) + func (m *ResponseUnion) MarshalTo(dAtA []byte) (int, error) + func (m *ResponseUnion) Reset() + func (m *ResponseUnion) Size() (n int) + func (m *ResponseUnion) String() string + func (m *ResponseUnion) Unmarshal(dAtA []byte) error + func (ru *ResponseUnion) MustSetInner(reply Response) + func (ru ResponseUnion) GetInner() Response + func (this *ResponseUnion) GetValue() interface{} + func (this *ResponseUnion) SetValue(value interface{}) bool + type ReverseScanRequest struct + func (*ReverseScanRequest) Descriptor() ([]byte, []int) + func (*ReverseScanRequest) Method() Method + func (*ReverseScanRequest) ProtoMessage() + func (m *ReverseScanRequest) Marshal() (dAtA []byte, err error) + func (m *ReverseScanRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ReverseScanRequest) Reset() + func (m *ReverseScanRequest) Size() (n int) + func (m *ReverseScanRequest) String() string + func (m *ReverseScanRequest) Unmarshal(dAtA []byte) error + func (rsr *ReverseScanRequest) ShallowCopy() Request + type ReverseScanResponse struct + Rows []KeyValue + func (*ReverseScanResponse) Descriptor() ([]byte, []int) + func (*ReverseScanResponse) ProtoMessage() + func (m *ReverseScanResponse) Marshal() (dAtA []byte, err error) + func (m *ReverseScanResponse) MarshalTo(dAtA []byte) (int, error) + 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 struct + func (*ScanRequest) Descriptor() ([]byte, []int) + func (*ScanRequest) Method() Method + func (*ScanRequest) ProtoMessage() + func (m *ScanRequest) Marshal() (dAtA []byte, err error) + func (m *ScanRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ScanRequest) Reset() + func (m *ScanRequest) Size() (n int) + func (m *ScanRequest) String() string + func (m *ScanRequest) Unmarshal(dAtA []byte) error + func (sr *ScanRequest) ShallowCopy() Request + type ScanResponse struct + Rows []KeyValue + func (*ScanResponse) Descriptor() ([]byte, []int) + func (*ScanResponse) ProtoMessage() + func (m *ScanResponse) Marshal() (dAtA []byte, err error) + func (m *ScanResponse) MarshalTo(dAtA []byte) (int, error) + 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 struct + Message string + func NewSendError(msg string) *SendError + func (*SendError) Descriptor() ([]byte, []int) + func (*SendError) ProtoMessage() + func (m *SendError) Marshal() (dAtA []byte, err error) + func (m *SendError) MarshalTo(dAtA []byte) (int, error) + func (m *SendError) Reset() + func (m *SendError) Size() (n int) + func (m *SendError) String() string + func (m *SendError) Unmarshal(dAtA []byte) error + func (s SendError) Error() string + type Span struct + EndKey Key + Key Key + func MergeSpans(spans []Span) ([]Span, bool) + func NewPopulatedSpan(r randyData, easy bool) *Span + func (*Span) Descriptor() ([]byte, []int) + func (*Span) ProtoMessage() + func (m *Span) Marshal() (dAtA []byte, err error) + func (m *Span) MarshalTo(dAtA []byte) (int, error) + func (m *Span) Reset() + func (m *Span) Size() (n int) + func (m *Span) Unmarshal(dAtA []byte) error + func (rh *Span) SetHeader(other Span) + func (rh Span) Header() Span + func (s Span) AsRange() interval.Range + func (s Span) Contains(o Span) bool + func (s Span) Equal(o Span) bool + func (s Span) Overlaps(o Span) bool + func (s Span) String() string + type Spans []Span + func (a Spans) Len() int + func (a Spans) Less(i, j int) bool + func (a Spans) Swap(i, j int) + type SplitTrigger struct + LeftDesc RangeDescriptor + RightDesc RangeDescriptor + func (*SplitTrigger) Descriptor() ([]byte, []int) + func (*SplitTrigger) ProtoMessage() + func (m *SplitTrigger) Marshal() (dAtA []byte, err error) + func (m *SplitTrigger) MarshalTo(dAtA []byte) (int, error) + func (m *SplitTrigger) Reset() + func (m *SplitTrigger) Size() (n int) + func (m *SplitTrigger) String() string + func (m *SplitTrigger) Unmarshal(dAtA []byte) error + type StatementStatistics struct + Count int64 + FirstAttemptCount int64 + LastErr string + MaxRetries int64 + NumRows NumericStat + OverheadLat NumericStat + ParseLat NumericStat + PlanLat NumericStat + RunLat NumericStat + ServiceLat NumericStat + func (*StatementStatistics) Descriptor() ([]byte, []int) + func (*StatementStatistics) ProtoMessage() + func (m *StatementStatistics) Marshal() (dAtA []byte, err error) + func (m *StatementStatistics) MarshalTo(dAtA []byte) (int, error) + func (m *StatementStatistics) Reset() + func (m *StatementStatistics) Size() (n int) + func (m *StatementStatistics) String() string + func (m *StatementStatistics) Unmarshal(dAtA []byte) error + type StoreCapacity struct + Available int64 + Capacity int64 + LeaseCount int32 + RangeCount int32 + func (*StoreCapacity) Descriptor() ([]byte, []int) + func (*StoreCapacity) ProtoMessage() + func (m *StoreCapacity) Marshal() (dAtA []byte, err error) + func (m *StoreCapacity) MarshalTo(dAtA []byte) (int, error) + func (m *StoreCapacity) Reset() + func (m *StoreCapacity) Size() (n int) + func (m *StoreCapacity) String() string + func (m *StoreCapacity) Unmarshal(dAtA []byte) error + func (sc StoreCapacity) FractionUsed() float64 + type StoreDeadReplicas struct + Replicas []ReplicaIdent + StoreID StoreID + func (*StoreDeadReplicas) Descriptor() ([]byte, []int) + func (*StoreDeadReplicas) ProtoMessage() + func (m *StoreDeadReplicas) Marshal() (dAtA []byte, err error) + func (m *StoreDeadReplicas) MarshalTo(dAtA []byte) (int, error) + func (m *StoreDeadReplicas) Reset() + func (m *StoreDeadReplicas) Size() (n int) + func (m *StoreDeadReplicas) String() string + func (m *StoreDeadReplicas) Unmarshal(dAtA []byte) error + type StoreDescriptor struct + Attrs Attributes + Capacity StoreCapacity + Node NodeDescriptor + StoreID StoreID + func (*StoreDescriptor) Descriptor() ([]byte, []int) + func (*StoreDescriptor) ProtoMessage() + func (m *StoreDescriptor) Marshal() (dAtA []byte, err error) + func (m *StoreDescriptor) MarshalTo(dAtA []byte) (int, error) + func (m *StoreDescriptor) Reset() + func (m *StoreDescriptor) Size() (n int) + func (m *StoreDescriptor) String() string + func (m *StoreDescriptor) Unmarshal(dAtA []byte) error + func (s StoreDescriptor) CombinedAttrs() *Attributes + type StoreID int32 + func (n StoreID) String() string + type StoreIDSlice []StoreID + func (s StoreIDSlice) Len() int + func (s StoreIDSlice) Less(i, j int) bool + func (s StoreIDSlice) Swap(i, j int) + type StoreIdent struct + ClusterID github_com_cockroachdb_cockroach_pkg_util_uuid.UUID + NodeID NodeID + StoreID StoreID + func (*StoreIdent) Descriptor() ([]byte, []int) + func (*StoreIdent) ProtoMessage() + func (m *StoreIdent) Marshal() (dAtA []byte, err error) + func (m *StoreIdent) MarshalTo(dAtA []byte) (int, error) + func (m *StoreIdent) Reset() + func (m *StoreIdent) Size() (n int) + func (m *StoreIdent) String() string + func (m *StoreIdent) Unmarshal(dAtA []byte) error + type StoreNotFoundError struct + StoreID StoreID + func NewStoreNotFoundError(storeID StoreID) *StoreNotFoundError + func (*StoreNotFoundError) Descriptor() ([]byte, []int) + func (*StoreNotFoundError) ProtoMessage() + func (e *StoreNotFoundError) Error() string + func (m *StoreNotFoundError) Marshal() (dAtA []byte, err error) + func (m *StoreNotFoundError) MarshalTo(dAtA []byte) (int, error) + func (m *StoreNotFoundError) Reset() + func (m *StoreNotFoundError) Size() (n int) + func (m *StoreNotFoundError) String() string + func (m *StoreNotFoundError) Unmarshal(dAtA []byte) error + type Tier struct + Key string + Value string + func (*Tier) Descriptor() ([]byte, []int) + func (*Tier) ProtoMessage() + func (m *Tier) Marshal() (dAtA []byte, err error) + func (m *Tier) MarshalTo(dAtA []byte) (int, error) + func (m *Tier) Reset() + func (m *Tier) Size() (n int) + func (m *Tier) Unmarshal(dAtA []byte) error + func (t *Tier) FromString(tier string) error + func (t Tier) String() string + type Transaction struct + Intents []Span + LastHeartbeat cockroach_util_hlc.Timestamp + MaxTimestamp cockroach_util_hlc.Timestamp + Name string + ObservedTimestamps []ObservedTimestamp + OrigTimestamp cockroach_util_hlc.Timestamp + RetryOnPush bool + Status TransactionStatus + WriteTooOld bool + Writing bool + func NewPopulatedTransaction(r randyData, easy bool) *Transaction + func NewTransaction(name string, baseKey Key, userPriority UserPriority, ...) *Transaction + func PrepareTransactionForRetry(ctx context.Context, pErr *Error, pri UserPriority) Transaction + func (*Transaction) Descriptor() ([]byte, []int) + func (*Transaction) ProtoMessage() + func (m *Transaction) Marshal() (dAtA []byte, err error) + func (m *Transaction) MarshalTo(dAtA []byte) (int, error) + func (m *Transaction) Reset() + func (m *Transaction) Size() (n int) + func (m *Transaction) Unmarshal(dAtA []byte) error + func (t *Transaction) Equal(s *Transaction) bool + func (t *Transaction) IsInitialized() bool + func (t *Transaction) ResetObservedTimestamps() + func (t *Transaction) Restart(userPriority UserPriority, upgradePriority int32, timestamp hlc.Timestamp) + func (t *Transaction) Update(o *Transaction) + func (t *Transaction) UpdateObservedTimestamp(nodeID NodeID, maxTS hlc.Timestamp) + func (t *Transaction) UpgradePriority(minPriority int32) + func (t Transaction) Clone() Transaction + func (t Transaction) GetObservedTimestamp(nodeID NodeID) (hlc.Timestamp, bool) + func (t Transaction) LastActive() hlc.Timestamp + func (t Transaction) String() string + type TransactionAbortedError struct + func NewTransactionAbortedError() *TransactionAbortedError + func (*TransactionAbortedError) Descriptor() ([]byte, []int) + func (*TransactionAbortedError) ProtoMessage() + func (e *TransactionAbortedError) Error() string + func (m *TransactionAbortedError) Marshal() (dAtA []byte, err error) + func (m *TransactionAbortedError) MarshalTo(dAtA []byte) (int, error) + func (m *TransactionAbortedError) Reset() + func (m *TransactionAbortedError) Size() (n int) + func (m *TransactionAbortedError) String() string + func (m *TransactionAbortedError) Unmarshal(dAtA []byte) error + type TransactionPushError struct + PusheeTxn Transaction + func NewTransactionPushError(pusheeTxn Transaction) *TransactionPushError + func (*TransactionPushError) Descriptor() ([]byte, []int) + func (*TransactionPushError) ProtoMessage() + func (e *TransactionPushError) Error() string + func (m *TransactionPushError) Marshal() (dAtA []byte, err error) + func (m *TransactionPushError) MarshalTo(dAtA []byte) (int, error) + func (m *TransactionPushError) Reset() + func (m *TransactionPushError) Size() (n int) + func (m *TransactionPushError) String() string + func (m *TransactionPushError) Unmarshal(dAtA []byte) error + type TransactionReplayError struct + func NewTransactionReplayError() *TransactionReplayError + func (*TransactionReplayError) Descriptor() ([]byte, []int) + func (*TransactionReplayError) ProtoMessage() + func (e *TransactionReplayError) Error() string + func (m *TransactionReplayError) Marshal() (dAtA []byte, err error) + func (m *TransactionReplayError) MarshalTo(dAtA []byte) (int, error) + func (m *TransactionReplayError) Reset() + func (m *TransactionReplayError) Size() (n int) + func (m *TransactionReplayError) String() string + func (m *TransactionReplayError) Unmarshal(dAtA []byte) error + type TransactionRestart int32 + const TransactionRestart_BACKOFF + const TransactionRestart_IMMEDIATE + const TransactionRestart_NONE + func (TransactionRestart) EnumDescriptor() ([]byte, []int) + func (x *TransactionRestart) UnmarshalJSON(data []byte) error + func (x TransactionRestart) Enum() *TransactionRestart + func (x TransactionRestart) String() string + type TransactionRetryError struct + Reason TransactionRetryReason + func NewTransactionRetryError(reason TransactionRetryReason) *TransactionRetryError + func (*TransactionRetryError) Descriptor() ([]byte, []int) + func (*TransactionRetryError) ProtoMessage() + func (e *TransactionRetryError) Error() string + func (m *TransactionRetryError) Marshal() (dAtA []byte, err error) + func (m *TransactionRetryError) MarshalTo(dAtA []byte) (int, error) + func (m *TransactionRetryError) Reset() + func (m *TransactionRetryError) Size() (n int) + func (m *TransactionRetryError) String() string + func (m *TransactionRetryError) Unmarshal(dAtA []byte) error + type TransactionRetryReason int32 + const RETRY_DELETE_RANGE + const RETRY_POSSIBLE_REPLAY + const RETRY_REASON_UNKNOWN + const RETRY_SERIALIZABLE + const RETRY_WRITE_TOO_OLD + func (TransactionRetryReason) EnumDescriptor() ([]byte, []int) + func (x *TransactionRetryReason) UnmarshalJSON(data []byte) error + func (x TransactionRetryReason) Enum() *TransactionRetryReason + func (x TransactionRetryReason) String() string + type TransactionStatus int32 + const ABORTED + const COMMITTED + const PENDING + func (TransactionStatus) EnumDescriptor() ([]byte, []int) + func (x *TransactionStatus) UnmarshalJSON(data []byte) error + func (x TransactionStatus) Enum() *TransactionStatus + func (x TransactionStatus) String() string + type TransactionStatusError struct + Msg string + func NewTransactionStatusError(msg string) *TransactionStatusError + func (*TransactionStatusError) Descriptor() ([]byte, []int) + func (*TransactionStatusError) ProtoMessage() + func (e *TransactionStatusError) Error() string + func (m *TransactionStatusError) Marshal() (dAtA []byte, err error) + func (m *TransactionStatusError) MarshalTo(dAtA []byte) (int, error) + func (m *TransactionStatusError) Reset() + func (m *TransactionStatusError) Size() (n int) + func (m *TransactionStatusError) String() string + func (m *TransactionStatusError) Unmarshal(dAtA []byte) error + type TransferLeaseRequest struct + Lease Lease + PrevLease *Lease + func (*TransferLeaseRequest) Descriptor() ([]byte, []int) + func (*TransferLeaseRequest) Method() Method + func (*TransferLeaseRequest) ProtoMessage() + func (m *TransferLeaseRequest) Marshal() (dAtA []byte, err error) + func (m *TransferLeaseRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TransferLeaseRequest) Reset() + func (m *TransferLeaseRequest) Size() (n int) + func (m *TransferLeaseRequest) String() string + func (m *TransferLeaseRequest) Unmarshal(dAtA []byte) error + func (tlr *TransferLeaseRequest) ShallowCopy() Request + type TruncateLogRequest struct + Index uint64 + RangeID RangeID + func (*TruncateLogRequest) Descriptor() ([]byte, []int) + func (*TruncateLogRequest) Method() Method + func (*TruncateLogRequest) ProtoMessage() + func (m *TruncateLogRequest) Marshal() (dAtA []byte, err error) + func (m *TruncateLogRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TruncateLogRequest) Reset() + func (m *TruncateLogRequest) Size() (n int) + func (m *TruncateLogRequest) String() string + func (m *TruncateLogRequest) Unmarshal(dAtA []byte) error + func (tlr *TruncateLogRequest) ShallowCopy() Request + type TruncateLogResponse struct + func (*TruncateLogResponse) Descriptor() ([]byte, []int) + func (*TruncateLogResponse) ProtoMessage() + func (m *TruncateLogResponse) Marshal() (dAtA []byte, err error) + func (m *TruncateLogResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TruncateLogResponse) Reset() + func (m *TruncateLogResponse) Size() (n int) + func (m *TruncateLogResponse) String() string + func (m *TruncateLogResponse) Unmarshal(dAtA []byte) error + type UnhandledRetryableError struct + PErr Error + func (*UnhandledRetryableError) Descriptor() ([]byte, []int) + func (*UnhandledRetryableError) ProtoMessage() + func (e *UnhandledRetryableError) Error() string + func (m *UnhandledRetryableError) Marshal() (dAtA []byte, err error) + func (m *UnhandledRetryableError) MarshalTo(dAtA []byte) (int, error) + func (m *UnhandledRetryableError) Reset() + func (m *UnhandledRetryableError) Size() (n int) + func (m *UnhandledRetryableError) String() string + func (m *UnhandledRetryableError) Unmarshal(dAtA []byte) error + type UserPriority float64 + func (up UserPriority) String() string + type Value struct + RawBytes []byte + Timestamp cockroach_util_hlc.Timestamp + func MakeValueFromBytes(bs []byte) Value + func MakeValueFromBytesAndTimestamp(bs []byte, t hlc.Timestamp) Value + func MakeValueFromString(s string) Value + func (*Value) Descriptor() ([]byte, []int) + func (*Value) ProtoMessage() + func (m *Value) Marshal() (dAtA []byte, err error) + func (m *Value) MarshalTo(dAtA []byte) (int, error) + func (m *Value) Reset() + func (m *Value) Size() (n int) + func (m *Value) String() string + func (m *Value) Unmarshal(dAtA []byte) error + func (v *Value) ClearChecksum() + func (v *Value) InitChecksum(key []byte) + 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 (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) PrettyPrint() string + func (v Value) Verify(key []byte) error + type ValueType int32 + const ValueType_BYTES + const ValueType_DECIMAL + const ValueType_DELIMITED_BYTES + const ValueType_DELIMITED_DECIMAL + const ValueType_DURATION + const ValueType_FLOAT + const ValueType_INT + const ValueType_NULL + const ValueType_TIME + const ValueType_TIMESERIES + const ValueType_TUPLE + const ValueType_UNKNOWN + func (ValueType) EnumDescriptor() ([]byte, []int) + func (x *ValueType) UnmarshalJSON(data []byte) error + func (x ValueType) Enum() *ValueType + func (x ValueType) String() string + type WriteBatchRequest struct + Data []byte + DataSpan Span + func (*WriteBatchRequest) Descriptor() ([]byte, []int) + func (*WriteBatchRequest) Method() Method + func (*WriteBatchRequest) ProtoMessage() + func (m *WriteBatchRequest) Marshal() (dAtA []byte, err error) + func (m *WriteBatchRequest) MarshalTo(dAtA []byte) (int, error) + func (m *WriteBatchRequest) Reset() + func (m *WriteBatchRequest) Size() (n int) + func (m *WriteBatchRequest) String() string + func (m *WriteBatchRequest) Unmarshal(dAtA []byte) error + func (r *WriteBatchRequest) ShallowCopy() Request + type WriteBatchResponse struct + func (*WriteBatchResponse) Descriptor() ([]byte, []int) + func (*WriteBatchResponse) ProtoMessage() + func (m *WriteBatchResponse) Marshal() (dAtA []byte, err error) + func (m *WriteBatchResponse) MarshalTo(dAtA []byte) (int, error) + func (m *WriteBatchResponse) Reset() + func (m *WriteBatchResponse) Size() (n int) + func (m *WriteBatchResponse) String() string + func (m *WriteBatchResponse) Unmarshal(dAtA []byte) error + type WriteIntentError struct + Intents []Intent + func (*WriteIntentError) Descriptor() ([]byte, []int) + func (*WriteIntentError) ProtoMessage() + func (e *WriteIntentError) Error() string + func (m *WriteIntentError) Marshal() (dAtA []byte, err error) + func (m *WriteIntentError) MarshalTo(dAtA []byte) (int, error) + func (m *WriteIntentError) Reset() + func (m *WriteIntentError) Size() (n int) + func (m *WriteIntentError) String() string + func (m *WriteIntentError) Unmarshal(dAtA []byte) error + type WriteTooOldError struct + ActualTimestamp cockroach_util_hlc.Timestamp + Timestamp cockroach_util_hlc.Timestamp + func (*WriteTooOldError) Descriptor() ([]byte, []int) + func (*WriteTooOldError) ProtoMessage() + func (e *WriteTooOldError) Error() string + func (m *WriteTooOldError) Marshal() (dAtA []byte, err error) + func (m *WriteTooOldError) MarshalTo(dAtA []byte) (int, error) + func (m *WriteTooOldError) Reset() + func (m *WriteTooOldError) Size() (n int) + func (m *WriteTooOldError) String() string + func (m *WriteTooOldError) Unmarshal(dAtA []byte) error