Versions in this module Expand all Collapse all v1 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