roachpb

package

Go to main page

Versions in this module

v1

v1.1.9

Oct 1, 2018

v1.1.9-rc.1

Sep 24, 2018

v1.1.8

Apr 19, 2018

v1.1.7

Mar 20, 2018

v1.1.6

Mar 2, 2018

v1.1.5

Jan 29, 2018

v1.1.4

Jan 1, 2018

Changes in this version

type RSpan

+ func (rs RSpan) ContainsKeyInverted(key RKey) bool

type RangeDescriptor

+ func (r RangeDescriptor) ContainsKeyInverted(key RKey) bool

v1.1.3

Nov 21, 2017

v1.1.2

Oct 26, 2017

v1.1.1

Oct 16, 2017

v1.1.0

Oct 4, 2017

Changes in this version

+ const MaxDiversityScore

+ type AddSSTableRequest struct

+ Data []byte

+ func (*AddSSTableRequest) Descriptor() ([]byte, []int)

+ func (*AddSSTableRequest) Method() Method

+ func (*AddSSTableRequest) ProtoMessage()

+ func (m *AddSSTableRequest) Marshal() (dAtA []byte, err error)

+ func (m *AddSSTableRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *AddSSTableRequest) Reset()

+ func (m *AddSSTableRequest) Size() (n int)

+ func (m *AddSSTableRequest) String() string

+ func (m *AddSSTableRequest) Unmarshal(dAtA []byte) error

+ func (r *AddSSTableRequest) ShallowCopy() Request

+ func (this *AddSSTableRequest) Equal(that interface{}) bool

+ type AddSSTableResponse struct

+ func (*AddSSTableResponse) Descriptor() ([]byte, []int)

+ func (*AddSSTableResponse) ProtoMessage()

+ func (m *AddSSTableResponse) Marshal() (dAtA []byte, err error)

+ func (m *AddSSTableResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *AddSSTableResponse) Reset()

+ func (m *AddSSTableResponse) Size() (n int)

+ func (m *AddSSTableResponse) String() string

+ func (m *AddSSTableResponse) Unmarshal(dAtA []byte) error

type AdminChangeReplicasRequest

+ func (this *AdminChangeReplicasRequest) Equal(that interface{}) bool

type AdminMergeRequest

+ func (this *AdminMergeRequest) Equal(that interface{}) bool

type AdminScatterRequest

+ func (this *AdminScatterRequest) Equal(that interface{}) bool

type AdminSplitRequest

+ func (this *AdminSplitRequest) Equal(that interface{}) bool

type AdminTransferLeaseRequest

+ func (this *AdminTransferLeaseRequest) Equal(that interface{}) bool

type AmbiguousResultError

+ func (this *AmbiguousResultError) Equal(that interface{}) bool

type BatchRequest

+ func (ba *BatchRequest) IsSingleQueryTxnRequest() bool

type BeginTransactionRequest

+ func (this *BeginTransactionRequest) Equal(that interface{}) bool

+ type BulkOpSummary struct

+ DataSize int64

+ IndexEntries int64

+ Rows int64

+ SystemRecords int64

+ func (*BulkOpSummary) Descriptor() ([]byte, []int)

+ func (*BulkOpSummary) ProtoMessage()

+ func (b *BulkOpSummary) Add(other BulkOpSummary)

+ func (m *BulkOpSummary) Marshal() (dAtA []byte, err error)

+ func (m *BulkOpSummary) MarshalTo(dAtA []byte) (int, error)

+ func (m *BulkOpSummary) Reset()

+ func (m *BulkOpSummary) Size() (n int)

+ func (m *BulkOpSummary) String() string

+ func (m *BulkOpSummary) Unmarshal(dAtA []byte) error

+ type CSVOptions struct

+ Comma int32

+ Comment int32

+ Nullif *string

+ func (*CSVOptions) Descriptor() ([]byte, []int)

+ func (*CSVOptions) ProtoMessage()

+ func (m *CSVOptions) Marshal() (dAtA []byte, err error)

+ func (m *CSVOptions) MarshalTo(dAtA []byte) (int, error)

+ func (m *CSVOptions) Reset()

+ func (m *CSVOptions) Size() (n int)

+ func (m *CSVOptions) String() string

+ func (m *CSVOptions) Unmarshal(dAtA []byte) error

type ChangeReplicasTrigger

+ func (this *ChangeReplicasTrigger) Equal(that interface{}) bool

type CheckConsistencyRequest

+ func (this *CheckConsistencyRequest) Equal(that interface{}) bool

+ type CollectedStatementStatistics struct

+ Key StatementStatisticsKey

+ Stats StatementStatistics

+ func (*CollectedStatementStatistics) Descriptor() ([]byte, []int)

+ func (*CollectedStatementStatistics) ProtoMessage()

+ func (m *CollectedStatementStatistics) Marshal() (dAtA []byte, err error)

+ func (m *CollectedStatementStatistics) MarshalTo(dAtA []byte) (int, error)

+ func (m *CollectedStatementStatistics) Reset()

+ func (m *CollectedStatementStatistics) Size() (n int)

+ func (m *CollectedStatementStatistics) String() string

+ func (m *CollectedStatementStatistics) Unmarshal(dAtA []byte) error

type ComputeChecksumRequest

+ func (this *ComputeChecksumRequest) Equal(that interface{}) bool

type ConditionFailedError

+ func (this *ConditionFailedError) Equal(that interface{}) bool

type ConditionalPutRequest

+ func (this *ConditionalPutRequest) Equal(that interface{}) bool

type DeleteRangeRequest

+ func (this *DeleteRangeRequest) Equal(that interface{}) bool

type DeleteRequest

+ func (this *DeleteRequest) Equal(that interface{}) bool

type DeprecatedVerifyChecksumRequest

+ func (this *DeprecatedVerifyChecksumRequest) Equal(that interface{}) bool

type EndTransactionRequest

+ func (this *EndTransactionRequest) Equal(that interface{}) bool

type ErrPosition

+ func (this *ErrPosition) Equal(that interface{}) bool

type Error

+ func (this *Error) Equal(that interface{}) bool

type ErrorDetail

+ TxnAbortedAsyncErr *TxnPrevAttemptError

+ UntrackedTxnError *UntrackedTxnError

+ func (this *ErrorDetail) Equal(that interface{}) bool

type ExportRequest

+ func (this *ExportRequest) Equal(that interface{}) bool

type ExportResponse_File

+ Exported BulkOpSummary

type ExportStorage

+ func (this *ExportStorage) Equal(that interface{}) bool

type ExportStorage_Azure

+ func (this *ExportStorage_Azure) Equal(that interface{}) bool

type ExportStorage_GCS

+ func (this *ExportStorage_GCS) Equal(that interface{}) bool

type ExportStorage_Http

+ func (this *ExportStorage_Http) Equal(that interface{}) bool

type ExportStorage_LocalFilePath

+ func (this *ExportStorage_LocalFilePath) Equal(that interface{}) bool

type ExportStorage_S3

+ func (this *ExportStorage_S3) Equal(that interface{}) bool

type GCRequest

+ func (this *GCRequest) Equal(that interface{}) bool

type GCRequest_GCKey

+ func (this *GCRequest_GCKey) Equal(that interface{}) bool

type GetRequest

+ func (this *GetRequest) Equal(that interface{}) bool

type HandledRetryableTxnError

+ func (this *HandledRetryableTxnError) Equal(that interface{}) bool

type HeartbeatTxnRequest

+ func (this *HeartbeatTxnRequest) Equal(that interface{}) bool

type ImportRequest

+ func (this *ImportRequest) Equal(that interface{}) bool

type ImportRequest_File

+ func (this *ImportRequest_File) Equal(that interface{}) bool

type ImportRequest_TableRekey

+ func (this *ImportRequest_TableRekey) Equal(that interface{}) bool

type ImportResponse

+ Imported BulkOpSummary

type IncrementRequest

+ func (this *IncrementRequest) Equal(that interface{}) bool

type InitPutRequest

+ FailOnTombstones bool

+ func (this *InitPutRequest) Equal(that interface{}) bool

type Intent

+ func (this *Intent) Equal(that interface{}) bool

type InternalCommitTrigger

+ func (this *InternalCommitTrigger) Equal(that interface{}) bool

type Lease

+ func (this *Lease) Equal(that interface{}) bool

type LeaseInfoRequest

+ func (this *LeaseInfoRequest) Equal(that interface{}) bool

type LeaseRejectedError

+ func (this *LeaseRejectedError) Equal(that interface{}) bool

type MergeRequest

+ func (this *MergeRequest) Equal(that interface{}) bool

type MergeTrigger

+ func (this *MergeTrigger) Equal(that interface{}) bool

type Method

+ const AddSSTable

type ModifiedSpanTrigger

+ func (this *ModifiedSpanTrigger) Equal(that interface{}) bool

type NodeDescriptor

+ ServerVersion Version

type NodeUnavailableError

+ func (this *NodeUnavailableError) Equal(that interface{}) bool

type NotLeaseHolderError

+ func (this *NotLeaseHolderError) Equal(that interface{}) bool

type NumericStat

+ func AddNumericStats(a, b NumericStat, countA, countB int64) NumericStat

+ func (l *NumericStat) Add(b NumericStat, countA, countB int64)

type ObservedTimestamp

+ func (this *ObservedTimestamp) Equal(that interface{}) bool

type OpRequiresTxnError

+ func (this *OpRequiresTxnError) Equal(that interface{}) bool

+ type Percentiles struct

+ P10 float64

+ P25 float64

+ P50 float64

+ P75 float64

+ P90 float64

+ func PercentilesFromData(data []float64) Percentiles

+ func (*Percentiles) Descriptor() ([]byte, []int)

+ func (*Percentiles) ProtoMessage()

+ func (m *Percentiles) Marshal() (dAtA []byte, err error)

+ func (m *Percentiles) MarshalTo(dAtA []byte) (int, error)

+ func (m *Percentiles) Reset()

+ func (m *Percentiles) Size() (n int)

+ func (m *Percentiles) Unmarshal(dAtA []byte) error

+ func (p Percentiles) String() string

type PushTxnRequest

+ func (this *PushTxnRequest) Equal(that interface{}) bool

type PutRequest

+ func (this *PutRequest) Equal(that interface{}) bool

type QueryTxnRequest

+ KnownWaitingTxns []github_com_cockroachdb_cockroach_pkg_util_uuid.UUID

+ WaitForUpdate bool

+ func (this *QueryTxnRequest) Equal(that interface{}) bool

type RaftGroupDeletedError

+ func (this *RaftGroupDeletedError) Equal(that interface{}) bool

type RaftTruncatedState

+ func (this *RaftTruncatedState) Equal(that interface{}) bool

type RangeKeyMismatchError

+ func (this *RangeKeyMismatchError) Equal(that interface{}) bool

type RangeLookupRequest

+ func (this *RangeLookupRequest) Equal(that interface{}) bool

type RangeNotFoundError

+ func (this *RangeNotFoundError) Equal(that interface{}) bool

type ReadWithinUncertaintyIntervalError

+ func (this *ReadWithinUncertaintyIntervalError) Equal(that interface{}) bool

type ReplicaCorruptionError

+ func (this *ReplicaCorruptionError) Equal(that interface{}) bool

type ReplicaTooOldError

+ func (this *ReplicaTooOldError) Equal(that interface{}) bool

type ReplicationTarget

+ func (this *ReplicationTarget) Equal(that interface{}) bool

type RequestLeaseRequest

+ func (this *RequestLeaseRequest) Equal(that interface{}) bool

type RequestUnion

+ AddSstable *AddSSTableRequest

type ResolveIntentRangeRequest

+ func (this *ResolveIntentRangeRequest) Equal(that interface{}) bool

type ResolveIntentRequest

+ func (this *ResolveIntentRequest) Equal(that interface{}) bool

type ResponseUnion

+ AddSstable *AddSSTableResponse

type ReverseScanRequest

+ func (this *ReverseScanRequest) Equal(that interface{}) bool

type ScanRequest

+ func (this *ScanRequest) Equal(that interface{}) bool

type SendError

+ func (this *SendError) Equal(that interface{}) bool

type Span

+ func (s Span) EqualValue(o Span) bool

type SplitTrigger

+ func (this *SplitTrigger) Equal(that interface{}) bool

+ type StatementStatisticsKey struct

+ App string

+ DistSQL bool

+ Failed bool

+ Query string

+ func (*StatementStatisticsKey) Descriptor() ([]byte, []int)

+ func (*StatementStatisticsKey) ProtoMessage()

+ func (m *StatementStatisticsKey) Marshal() (dAtA []byte, err error)

+ func (m *StatementStatisticsKey) MarshalTo(dAtA []byte) (int, error)

+ func (m *StatementStatisticsKey) Reset()

+ func (m *StatementStatisticsKey) Size() (n int)

+ func (m *StatementStatisticsKey) String() string

+ func (m *StatementStatisticsKey) Unmarshal(dAtA []byte) error

type StoreCapacity

+ BytesPerReplica Percentiles

+ LogicalBytes int64

+ Used int64

+ WritesPerReplica Percentiles

+ WritesPerSecond float64

type StoreNotFoundError

+ func (this *StoreNotFoundError) Equal(that interface{}) bool

type Transaction

+ func MakeTransaction(name string, baseKey Key, userPriority UserPriority, ...) Transaction

+ func (t *Transaction) AssertInitialized(ctx context.Context)

+ func (t *Transaction) BumpEpoch()

type TransactionAbortedError

+ func (this *TransactionAbortedError) Equal(that interface{}) bool

type TransactionPushError

+ func (this *TransactionPushError) Equal(that interface{}) bool

type TransactionReplayError

+ func (this *TransactionReplayError) Equal(that interface{}) bool

type TransactionRetryError

+ func (this *TransactionRetryError) Equal(that interface{}) bool

type TransactionStatusError

+ func (this *TransactionStatusError) Equal(that interface{}) bool

type TransferLeaseRequest

+ func (this *TransferLeaseRequest) Equal(that interface{}) bool

type TruncateLogRequest

+ func (this *TruncateLogRequest) Equal(that interface{}) bool

+ type TxnPrevAttemptError struct

+ func (*TxnPrevAttemptError) Descriptor() ([]byte, []int)

+ func (*TxnPrevAttemptError) ProtoMessage()

+ func (e *TxnPrevAttemptError) Error() string

+ func (m *TxnPrevAttemptError) Marshal() (dAtA []byte, err error)

+ func (m *TxnPrevAttemptError) MarshalTo(dAtA []byte) (int, error)

+ func (m *TxnPrevAttemptError) Reset()

+ func (m *TxnPrevAttemptError) Size() (n int)

+ func (m *TxnPrevAttemptError) String() string

+ func (m *TxnPrevAttemptError) Unmarshal(dAtA []byte) error

+ func (this *TxnPrevAttemptError) Equal(that interface{}) bool

+ type UntrackedTxnError struct

+ func (*UntrackedTxnError) Descriptor() ([]byte, []int)

+ func (*UntrackedTxnError) ProtoMessage()

+ func (e *UntrackedTxnError) Error() string

+ func (m *UntrackedTxnError) Marshal() (dAtA []byte, err error)

+ func (m *UntrackedTxnError) MarshalTo(dAtA []byte) (int, error)

+ func (m *UntrackedTxnError) Reset()

+ func (m *UntrackedTxnError) Size() (n int)

+ func (m *UntrackedTxnError) String() string

+ func (m *UntrackedTxnError) Unmarshal(dAtA []byte) error

+ func (this *UntrackedTxnError) Equal(that interface{}) bool

type Value

+ func (this *Value) Equal(that interface{}) bool

+ func (v *Value) IsPresent() bool

+ type Version struct

+ Major int32

+ Minor int32

+ Patch int32

+ Unstable int32

+ func MustParseVersion(s string) Version

+ func ParseVersion(s string) (Version, error)

+ func (*Version) Descriptor() ([]byte, []int)

+ func (*Version) ProtoMessage()

+ func (m *Version) Marshal() (dAtA []byte, err error)

+ func (m *Version) MarshalTo(dAtA []byte) (int, error)

+ func (m *Version) Reset()

+ func (m *Version) Size() (n int)

+ func (m *Version) Unmarshal(dAtA []byte) error

+ func (v Version) CanBump(o Version) bool

+ func (v Version) Less(otherV Version) bool

+ func (v Version) String() string

type WriteBatchRequest

+ func (this *WriteBatchRequest) Equal(that interface{}) bool

type WriteIntentError

+ func (this *WriteIntentError) Equal(that interface{}) bool

type WriteTooOldError

+ func (this *WriteTooOldError) Equal(that interface{}) bool

v1.1.0-rc.1

Oct 4, 2017

v1.0.7

Feb 11, 2018

v1.0.6

Sep 9, 2017

v1.0.5

Aug 17, 2017

v1.0.4

Jul 20, 2017

v1.0.3

Jul 6, 2017

v1.0.2

Jun 7, 2017

v1.0.1

May 18, 2017

Changes in this version

+ const MaxTxnPriority

+ const MaxUserPriority

+ const MinTxnPriority

+ const MinUserPriority

+ const NormalUserPriority

+ const UnspecifiedUserPriority

+ var ErrIntOverflowApi = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowAppStats = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowData = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowErrors = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowInternal = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowInternalRaft = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowMetadata = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthAppStats = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthData = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthErrors = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthInternal = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthInternalRaft = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthMetadata = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ExportStorageProvider_name = map[int32]string

+ var ExportStorageProvider_value = map[string]int32

+ var KeyMax = Key(RKeyMax)

+ var KeyMin = Key(RKeyMin)

+ var PrettyPrintKey func(key Key) string

+ var PrettyPrintRange func(start, end Key, maxChars int) string

+ var PushTxnType_name = map[int32]string

+ var PushTxnType_value = map[string]int32

+ var RKeyMax = RKey

+ var RKeyMin = RKey("")

+ var ReadConsistencyType_name = map[int32]string

+ var ReadConsistencyType_value = map[string]int32

+ var ReplicaChangeType_name = map[int32]string

+ var ReplicaChangeType_value = map[string]int32

+ var TransactionRestart_name = map[int32]string

+ var TransactionRestart_value = map[string]int32

+ var TransactionRetryReason_name = map[int32]string

+ var TransactionRetryReason_value = map[string]int32

+ var TransactionStatus_name = map[int32]string

+ var TransactionStatus_value = map[string]int32

+ var ValueType_name = map[int32]string

+ var ValueType_value = map[string]int32

+ func BytesNext(b []byte) []byte

+ func ConsultsTimestampCache(args Request) bool

+ func ErrorUnexpectedlySet(culprit, response interface{}) string

+ func IsRange(args Request) bool

+ func IsReadOnly(args Request) bool

+ func IsTransactionWrite(args Request) bool

+ func MakePriority(userPriority UserPriority) int32

+ func RegisterExternalServer(s *grpc.Server, srv ExternalServer)

+ func RegisterInternalServer(s *grpc.Server, srv InternalServer)

+ func TxnIDEqual(a, b *uuid.UUID) bool

+ func UpdatesTimestampCache(args Request) bool

+ type AbortCacheEntry struct

+ Key Key

+ Priority int32

+ Timestamp cockroach_util_hlc.Timestamp

+ func NewPopulatedAbortCacheEntry(r randyData, easy bool) *AbortCacheEntry

+ func (*AbortCacheEntry) Descriptor() ([]byte, []int)

+ func (*AbortCacheEntry) ProtoMessage()

+ func (m *AbortCacheEntry) Marshal() (dAtA []byte, err error)

+ func (m *AbortCacheEntry) MarshalTo(dAtA []byte) (int, error)

+ func (m *AbortCacheEntry) Reset()

+ func (m *AbortCacheEntry) Size() (n int)

+ func (m *AbortCacheEntry) String() string

+ func (m *AbortCacheEntry) Unmarshal(dAtA []byte) error

+ type AdminChangeReplicasRequest struct

+ ChangeType ReplicaChangeType

+ Targets []ReplicationTarget

+ func (*AdminChangeReplicasRequest) Descriptor() ([]byte, []int)

+ func (*AdminChangeReplicasRequest) Method() Method

+ func (*AdminChangeReplicasRequest) ProtoMessage()

+ func (acrr *AdminChangeReplicasRequest) ShallowCopy() Request

+ func (m *AdminChangeReplicasRequest) Marshal() (dAtA []byte, err error)

+ func (m *AdminChangeReplicasRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *AdminChangeReplicasRequest) Reset()

+ func (m *AdminChangeReplicasRequest) Size() (n int)

+ func (m *AdminChangeReplicasRequest) String() string

+ func (m *AdminChangeReplicasRequest) Unmarshal(dAtA []byte) error

+ type AdminChangeReplicasResponse struct

+ func (*AdminChangeReplicasResponse) Descriptor() ([]byte, []int)

+ func (*AdminChangeReplicasResponse) ProtoMessage()

+ func (m *AdminChangeReplicasResponse) Marshal() (dAtA []byte, err error)

+ func (m *AdminChangeReplicasResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *AdminChangeReplicasResponse) Reset()

+ func (m *AdminChangeReplicasResponse) Size() (n int)

+ func (m *AdminChangeReplicasResponse) String() string

+ func (m *AdminChangeReplicasResponse) Unmarshal(dAtA []byte) error

+ type AdminMergeRequest struct

+ func (*AdminMergeRequest) Descriptor() ([]byte, []int)

+ func (*AdminMergeRequest) Method() Method

+ func (*AdminMergeRequest) ProtoMessage()

+ func (amr *AdminMergeRequest) ShallowCopy() Request

+ func (m *AdminMergeRequest) Marshal() (dAtA []byte, err error)

+ func (m *AdminMergeRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *AdminMergeRequest) Reset()

+ func (m *AdminMergeRequest) Size() (n int)

+ func (m *AdminMergeRequest) String() string

+ func (m *AdminMergeRequest) Unmarshal(dAtA []byte) error

+ type AdminMergeResponse struct

+ func (*AdminMergeResponse) Descriptor() ([]byte, []int)

+ func (*AdminMergeResponse) ProtoMessage()

+ func (m *AdminMergeResponse) Marshal() (dAtA []byte, err error)

+ func (m *AdminMergeResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *AdminMergeResponse) Reset()

+ func (m *AdminMergeResponse) Size() (n int)

+ func (m *AdminMergeResponse) String() string

+ func (m *AdminMergeResponse) Unmarshal(dAtA []byte) error

+ type AdminScatterRequest struct

+ func (*AdminScatterRequest) Descriptor() ([]byte, []int)

+ func (*AdminScatterRequest) Method() Method

+ func (*AdminScatterRequest) ProtoMessage()

+ func (m *AdminScatterRequest) Marshal() (dAtA []byte, err error)

+ func (m *AdminScatterRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *AdminScatterRequest) Reset()

+ func (m *AdminScatterRequest) Size() (n int)

+ func (m *AdminScatterRequest) String() string

+ func (m *AdminScatterRequest) Unmarshal(dAtA []byte) error

+ func (r *AdminScatterRequest) ShallowCopy() Request

+ type AdminScatterResponse struct

+ Ranges []AdminScatterResponse_Range

+ func (*AdminScatterResponse) Descriptor() ([]byte, []int)

+ func (*AdminScatterResponse) ProtoMessage()

+ func (m *AdminScatterResponse) Marshal() (dAtA []byte, err error)

+ func (m *AdminScatterResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *AdminScatterResponse) Reset()

+ func (m *AdminScatterResponse) Size() (n int)

+ func (m *AdminScatterResponse) String() string

+ func (m *AdminScatterResponse) Unmarshal(dAtA []byte) error

+ type AdminScatterResponse_Range struct

+ Error *Error

+ Span Span

+ func (*AdminScatterResponse_Range) Descriptor() ([]byte, []int)

+ func (*AdminScatterResponse_Range) ProtoMessage()

+ func (m *AdminScatterResponse_Range) Marshal() (dAtA []byte, err error)

+ func (m *AdminScatterResponse_Range) MarshalTo(dAtA []byte) (int, error)

+ func (m *AdminScatterResponse_Range) Reset()

+ func (m *AdminScatterResponse_Range) Size() (n int)

+ func (m *AdminScatterResponse_Range) String() string

+ func (m *AdminScatterResponse_Range) Unmarshal(dAtA []byte) error

+ type AdminSplitRequest struct

+ SplitKey Key

+ func (*AdminSplitRequest) Descriptor() ([]byte, []int)

+ func (*AdminSplitRequest) Method() Method

+ func (*AdminSplitRequest) ProtoMessage()

+ func (asr *AdminSplitRequest) ShallowCopy() Request

+ func (m *AdminSplitRequest) Marshal() (dAtA []byte, err error)

+ func (m *AdminSplitRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *AdminSplitRequest) Reset()

+ func (m *AdminSplitRequest) Size() (n int)

+ func (m *AdminSplitRequest) String() string

+ func (m *AdminSplitRequest) Unmarshal(dAtA []byte) error

+ type AdminSplitResponse struct

+ func (*AdminSplitResponse) Descriptor() ([]byte, []int)

+ func (*AdminSplitResponse) ProtoMessage()

+ func (m *AdminSplitResponse) Marshal() (dAtA []byte, err error)

+ func (m *AdminSplitResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *AdminSplitResponse) Reset()

+ func (m *AdminSplitResponse) Size() (n int)

+ func (m *AdminSplitResponse) String() string

+ func (m *AdminSplitResponse) Unmarshal(dAtA []byte) error

+ type AdminTransferLeaseRequest struct

+ Target StoreID

+ func (*AdminTransferLeaseRequest) Descriptor() ([]byte, []int)

+ func (*AdminTransferLeaseRequest) Method() Method

+ func (*AdminTransferLeaseRequest) ProtoMessage()

+ func (atlr *AdminTransferLeaseRequest) ShallowCopy() Request

+ func (m *AdminTransferLeaseRequest) Marshal() (dAtA []byte, err error)

+ func (m *AdminTransferLeaseRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *AdminTransferLeaseRequest) Reset()

+ func (m *AdminTransferLeaseRequest) Size() (n int)

+ func (m *AdminTransferLeaseRequest) String() string

+ func (m *AdminTransferLeaseRequest) Unmarshal(dAtA []byte) error

+ type AdminTransferLeaseResponse struct

+ func (*AdminTransferLeaseResponse) Descriptor() ([]byte, []int)

+ func (*AdminTransferLeaseResponse) ProtoMessage()

+ func (m *AdminTransferLeaseResponse) Marshal() (dAtA []byte, err error)

+ func (m *AdminTransferLeaseResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *AdminTransferLeaseResponse) Reset()

+ func (m *AdminTransferLeaseResponse) Size() (n int)

+ func (m *AdminTransferLeaseResponse) String() string

+ func (m *AdminTransferLeaseResponse) Unmarshal(dAtA []byte) error

+ type AmbiguousResultError struct

+ Message string

+ WrappedErr *Error

+ func NewAmbiguousResultError(msg string) *AmbiguousResultError

+ func (*AmbiguousResultError) Descriptor() ([]byte, []int)

+ func (*AmbiguousResultError) ProtoMessage()

+ func (e *AmbiguousResultError) Error() string

+ func (m *AmbiguousResultError) Marshal() (dAtA []byte, err error)

+ func (m *AmbiguousResultError) MarshalTo(dAtA []byte) (int, error)

+ func (m *AmbiguousResultError) Reset()

+ func (m *AmbiguousResultError) Size() (n int)

+ func (m *AmbiguousResultError) String() string

+ func (m *AmbiguousResultError) Unmarshal(dAtA []byte) error

+ type Attributes struct

+ Attrs []string

+ func (*Attributes) Descriptor() ([]byte, []int)

+ func (*Attributes) ProtoMessage()

+ func (a Attributes) IsSubset(b Attributes) bool

+ func (a Attributes) SortedString() string

+ func (a Attributes) String() string

+ func (m *Attributes) Marshal() (dAtA []byte, err error)

+ func (m *Attributes) MarshalTo(dAtA []byte) (int, error)

+ func (m *Attributes) Reset()

+ func (m *Attributes) Size() (n int)

+ func (m *Attributes) Unmarshal(dAtA []byte) error

+ type BatchRequest struct

+ Requests []RequestUnion

+ func (*BatchRequest) Descriptor() ([]byte, []int)

+ func (*BatchRequest) GetUser() string

+ func (*BatchRequest) ProtoMessage()

+ func (ba *BatchRequest) Add(requests ...Request)

+ func (ba *BatchRequest) CreateReply() *BatchResponse

+ func (ba *BatchRequest) GetArg(method Method) (Request, bool)

+ func (ba *BatchRequest) GetPrevLeaseForLeaseRequest() *Lease

+ func (ba *BatchRequest) IntentSpanIterate(br *BatchResponse, fn func(key, endKey Key))

+ func (ba *BatchRequest) IsAdmin() bool

+ func (ba *BatchRequest) IsLeaseRequest() bool

+ func (ba *BatchRequest) IsPossibleTransaction() bool

+ func (ba *BatchRequest) IsReadOnly() bool

+ func (ba *BatchRequest) IsReverse() bool

+ func (ba *BatchRequest) IsSinglePushTxnRequest() bool

+ func (ba *BatchRequest) IsSingleRequest() bool

+ func (ba *BatchRequest) IsSingleSkipLeaseCheckRequest() bool

+ func (ba *BatchRequest) IsTransactionWrite() bool

+ func (ba *BatchRequest) IsWrite() bool

+ func (ba *BatchRequest) Methods() []Method

+ func (ba *BatchRequest) SetActiveTimestamp(nowFn func() hlc.Timestamp) error

+ func (ba *BatchRequest) SetNewRequest()

+ func (ba *BatchRequest) Summary() string

+ func (ba *BatchRequest) UpdateTxn(otherTxn *Transaction)

+ func (ba BatchRequest) Split(canSplitET bool) [][]RequestUnion

+ func (ba BatchRequest) String() string

+ func (m *BatchRequest) Marshal() (dAtA []byte, err error)

+ func (m *BatchRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *BatchRequest) Reset()

+ func (m *BatchRequest) Size() (n int)

+ func (m *BatchRequest) Unmarshal(dAtA []byte) error

+ type BatchResponse struct

+ Responses []ResponseUnion

+ func (*BatchResponse) Descriptor() ([]byte, []int)

+ func (*BatchResponse) ProtoMessage()

+ func (br *BatchResponse) Add(reply Response)

+ func (br *BatchResponse) Combine(otherBatch *BatchResponse) error

+ func (br *BatchResponse) String() string

+ func (m *BatchResponse) Marshal() (dAtA []byte, err error)

+ func (m *BatchResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *BatchResponse) Reset()

+ func (m *BatchResponse) Size() (n int)

+ func (m *BatchResponse) Unmarshal(dAtA []byte) error

+ type BatchResponse_Header struct

+ CollectedSpans [][]byte

+ Error *Error

+ Now cockroach_util_hlc.Timestamp

+ Timestamp cockroach_util_hlc.Timestamp

+ Txn *Transaction

+ func (*BatchResponse_Header) Descriptor() ([]byte, []int)

+ func (*BatchResponse_Header) ProtoMessage()

+ func (m *BatchResponse_Header) Marshal() (dAtA []byte, err error)

+ func (m *BatchResponse_Header) MarshalTo(dAtA []byte) (int, error)

+ func (m *BatchResponse_Header) Reset()

+ func (m *BatchResponse_Header) Size() (n int)

+ func (m *BatchResponse_Header) String() string

+ func (m *BatchResponse_Header) Unmarshal(dAtA []byte) error

+ type BeginTransactionRequest struct

+ func (*BeginTransactionRequest) Descriptor() ([]byte, []int)

+ func (*BeginTransactionRequest) Method() Method

+ func (*BeginTransactionRequest) ProtoMessage()

+ func (btr *BeginTransactionRequest) ShallowCopy() Request

+ func (m *BeginTransactionRequest) Marshal() (dAtA []byte, err error)

+ func (m *BeginTransactionRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *BeginTransactionRequest) Reset()

+ func (m *BeginTransactionRequest) Size() (n int)

+ func (m *BeginTransactionRequest) String() string

+ func (m *BeginTransactionRequest) Unmarshal(dAtA []byte) error

+ type BeginTransactionResponse struct

+ func (*BeginTransactionResponse) Descriptor() ([]byte, []int)

+ func (*BeginTransactionResponse) ProtoMessage()

+ func (m *BeginTransactionResponse) Marshal() (dAtA []byte, err error)

+ func (m *BeginTransactionResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *BeginTransactionResponse) Reset()

+ func (m *BeginTransactionResponse) Size() (n int)

+ func (m *BeginTransactionResponse) String() string

+ func (m *BeginTransactionResponse) Unmarshal(dAtA []byte) error

+ type ChangeReplicasTrigger struct

+ ChangeType ReplicaChangeType

+ NextReplicaID ReplicaID

+ Replica ReplicaDescriptor

+ UpdatedReplicas []ReplicaDescriptor

+ func (*ChangeReplicasTrigger) Descriptor() ([]byte, []int)

+ func (*ChangeReplicasTrigger) ProtoMessage()

+ func (m *ChangeReplicasTrigger) Marshal() (dAtA []byte, err error)

+ func (m *ChangeReplicasTrigger) MarshalTo(dAtA []byte) (int, error)

+ func (m *ChangeReplicasTrigger) Reset()

+ func (m *ChangeReplicasTrigger) Size() (n int)

+ func (m *ChangeReplicasTrigger) String() string

+ func (m *ChangeReplicasTrigger) Unmarshal(dAtA []byte) error

+ type CheckConsistencyRequest struct

+ WithDiff bool

+ func (*CheckConsistencyRequest) Descriptor() ([]byte, []int)

+ func (*CheckConsistencyRequest) Method() Method

+ func (*CheckConsistencyRequest) ProtoMessage()

+ func (ccr *CheckConsistencyRequest) ShallowCopy() Request

+ func (m *CheckConsistencyRequest) Marshal() (dAtA []byte, err error)

+ func (m *CheckConsistencyRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *CheckConsistencyRequest) Reset()

+ func (m *CheckConsistencyRequest) Size() (n int)

+ func (m *CheckConsistencyRequest) String() string

+ func (m *CheckConsistencyRequest) Unmarshal(dAtA []byte) error

+ type CheckConsistencyResponse struct

+ func (*CheckConsistencyResponse) Descriptor() ([]byte, []int)

+ func (*CheckConsistencyResponse) ProtoMessage()

+ func (m *CheckConsistencyResponse) Marshal() (dAtA []byte, err error)

+ func (m *CheckConsistencyResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *CheckConsistencyResponse) Reset()

+ func (m *CheckConsistencyResponse) Size() (n int)

+ func (m *CheckConsistencyResponse) String() string

+ func (m *CheckConsistencyResponse) Unmarshal(dAtA []byte) error

+ type ComputeChecksumRequest struct

+ ChecksumID github_com_cockroachdb_cockroach_pkg_util_uuid.UUID

+ Snapshot bool

+ Version uint32

+ func (*ComputeChecksumRequest) Descriptor() ([]byte, []int)

+ func (*ComputeChecksumRequest) Method() Method

+ func (*ComputeChecksumRequest) ProtoMessage()

+ func (ccr *ComputeChecksumRequest) ShallowCopy() Request

+ func (m *ComputeChecksumRequest) Marshal() (dAtA []byte, err error)

+ func (m *ComputeChecksumRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ComputeChecksumRequest) Reset()

+ func (m *ComputeChecksumRequest) Size() (n int)

+ func (m *ComputeChecksumRequest) String() string

+ func (m *ComputeChecksumRequest) Unmarshal(dAtA []byte) error

+ type ComputeChecksumResponse struct

+ func (*ComputeChecksumResponse) Descriptor() ([]byte, []int)

+ func (*ComputeChecksumResponse) ProtoMessage()

+ func (m *ComputeChecksumResponse) Marshal() (dAtA []byte, err error)

+ func (m *ComputeChecksumResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ComputeChecksumResponse) Reset()

+ func (m *ComputeChecksumResponse) Size() (n int)

+ func (m *ComputeChecksumResponse) String() string

+ func (m *ComputeChecksumResponse) Unmarshal(dAtA []byte) error

+ type ConditionFailedError struct

+ ActualValue *Value

+ func (*ConditionFailedError) Descriptor() ([]byte, []int)

+ func (*ConditionFailedError) ProtoMessage()

+ func (e *ConditionFailedError) Error() string

+ func (m *ConditionFailedError) Marshal() (dAtA []byte, err error)

+ func (m *ConditionFailedError) MarshalTo(dAtA []byte) (int, error)

+ func (m *ConditionFailedError) Reset()

+ func (m *ConditionFailedError) Size() (n int)

+ func (m *ConditionFailedError) String() string

+ func (m *ConditionFailedError) Unmarshal(dAtA []byte) error

+ type ConditionalPutRequest struct

+ Blind bool

+ ExpValue *Value

+ Value Value

+ func (*ConditionalPutRequest) Descriptor() ([]byte, []int)

+ func (*ConditionalPutRequest) Method() Method

+ func (*ConditionalPutRequest) ProtoMessage()

+ func (cpr *ConditionalPutRequest) ShallowCopy() Request

+ func (m *ConditionalPutRequest) Marshal() (dAtA []byte, err error)

+ func (m *ConditionalPutRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ConditionalPutRequest) Reset()

+ func (m *ConditionalPutRequest) Size() (n int)

+ func (m *ConditionalPutRequest) String() string

+ func (m *ConditionalPutRequest) Unmarshal(dAtA []byte) error

+ type ConditionalPutResponse struct

+ func (*ConditionalPutResponse) Descriptor() ([]byte, []int)

+ func (*ConditionalPutResponse) ProtoMessage()

+ func (m *ConditionalPutResponse) Marshal() (dAtA []byte, err error)

+ func (m *ConditionalPutResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ConditionalPutResponse) Reset()

+ func (m *ConditionalPutResponse) Size() (n int)

+ func (m *ConditionalPutResponse) String() string

+ func (m *ConditionalPutResponse) Unmarshal(dAtA []byte) error

+ type DeleteRangeRequest struct

+ Inline bool

+ ReturnKeys bool

+ func (*DeleteRangeRequest) Descriptor() ([]byte, []int)

+ func (*DeleteRangeRequest) Method() Method

+ func (*DeleteRangeRequest) ProtoMessage()

+ func (drr *DeleteRangeRequest) ShallowCopy() Request

+ func (m *DeleteRangeRequest) Marshal() (dAtA []byte, err error)

+ func (m *DeleteRangeRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeleteRangeRequest) Reset()

+ func (m *DeleteRangeRequest) Size() (n int)

+ func (m *DeleteRangeRequest) String() string

+ func (m *DeleteRangeRequest) Unmarshal(dAtA []byte) error

+ type DeleteRangeResponse struct

+ Keys []Key

+ func (*DeleteRangeResponse) Descriptor() ([]byte, []int)

+ func (*DeleteRangeResponse) ProtoMessage()

+ func (m *DeleteRangeResponse) Marshal() (dAtA []byte, err error)

+ func (m *DeleteRangeResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeleteRangeResponse) Reset()

+ func (m *DeleteRangeResponse) Size() (n int)

+ func (m *DeleteRangeResponse) String() string

+ func (m *DeleteRangeResponse) Unmarshal(dAtA []byte) error

+ type DeleteRequest struct

+ func (*DeleteRequest) Descriptor() ([]byte, []int)

+ func (*DeleteRequest) Method() Method

+ func (*DeleteRequest) ProtoMessage()

+ func (dr *DeleteRequest) ShallowCopy() Request

+ func (m *DeleteRequest) Marshal() (dAtA []byte, err error)

+ func (m *DeleteRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeleteRequest) Reset()

+ func (m *DeleteRequest) Size() (n int)

+ func (m *DeleteRequest) String() string

+ func (m *DeleteRequest) Unmarshal(dAtA []byte) error

+ type DeleteResponse struct

+ func (*DeleteResponse) Descriptor() ([]byte, []int)

+ func (*DeleteResponse) ProtoMessage()

+ func (m *DeleteResponse) Marshal() (dAtA []byte, err error)

+ func (m *DeleteResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeleteResponse) Reset()

+ func (m *DeleteResponse) Size() (n int)

+ func (m *DeleteResponse) String() string

+ func (m *DeleteResponse) Unmarshal(dAtA []byte) error

+ type DeprecatedVerifyChecksumRequest struct

+ func (*DeprecatedVerifyChecksumRequest) Descriptor() ([]byte, []int)

+ func (*DeprecatedVerifyChecksumRequest) Method() Method

+ func (*DeprecatedVerifyChecksumRequest) ProtoMessage()

+ func (dvcr *DeprecatedVerifyChecksumRequest) ShallowCopy() Request

+ func (m *DeprecatedVerifyChecksumRequest) Marshal() (dAtA []byte, err error)

+ func (m *DeprecatedVerifyChecksumRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeprecatedVerifyChecksumRequest) Reset()

+ func (m *DeprecatedVerifyChecksumRequest) Size() (n int)

+ func (m *DeprecatedVerifyChecksumRequest) String() string

+ func (m *DeprecatedVerifyChecksumRequest) Unmarshal(dAtA []byte) error

+ type DeprecatedVerifyChecksumResponse struct

+ func (*DeprecatedVerifyChecksumResponse) Descriptor() ([]byte, []int)

+ func (*DeprecatedVerifyChecksumResponse) ProtoMessage()

+ func (m *DeprecatedVerifyChecksumResponse) Marshal() (dAtA []byte, err error)

+ func (m *DeprecatedVerifyChecksumResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeprecatedVerifyChecksumResponse) Reset()

+ func (m *DeprecatedVerifyChecksumResponse) Size() (n int)

+ func (m *DeprecatedVerifyChecksumResponse) String() string

+ func (m *DeprecatedVerifyChecksumResponse) Unmarshal(dAtA []byte) error

+ type EndTransactionRequest struct

+ Commit bool

+ Deadline *cockroach_util_hlc.Timestamp

+ IntentSpans []Span

+ InternalCommitTrigger *InternalCommitTrigger

+ Require1PC bool

+ func (*EndTransactionRequest) Descriptor() ([]byte, []int)

+ func (*EndTransactionRequest) Method() Method

+ func (*EndTransactionRequest) ProtoMessage()

+ func (etr *EndTransactionRequest) ShallowCopy() Request

+ func (m *EndTransactionRequest) Marshal() (dAtA []byte, err error)

+ func (m *EndTransactionRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *EndTransactionRequest) Reset()

+ func (m *EndTransactionRequest) Size() (n int)

+ func (m *EndTransactionRequest) String() string

+ func (m *EndTransactionRequest) Unmarshal(dAtA []byte) error

+ type EndTransactionResponse struct

+ OnePhaseCommit bool

+ func (*EndTransactionResponse) Descriptor() ([]byte, []int)

+ func (*EndTransactionResponse) ProtoMessage()

+ func (m *EndTransactionResponse) Marshal() (dAtA []byte, err error)

+ func (m *EndTransactionResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *EndTransactionResponse) Reset()

+ func (m *EndTransactionResponse) Size() (n int)

+ func (m *EndTransactionResponse) String() string

+ func (m *EndTransactionResponse) Unmarshal(dAtA []byte) error

+ type ErrPosition struct

+ Index int32

+ func (*ErrPosition) Descriptor() ([]byte, []int)

+ func (*ErrPosition) ProtoMessage()

+ func (m *ErrPosition) Marshal() (dAtA []byte, err error)

+ func (m *ErrPosition) MarshalTo(dAtA []byte) (int, error)

+ func (m *ErrPosition) Reset()

+ func (m *ErrPosition) Size() (n int)

+ func (m *ErrPosition) String() string

+ func (m *ErrPosition) Unmarshal(dAtA []byte) error

+ type Error struct

+ Detail *ErrorDetail

+ Index *ErrPosition

+ Message string

+ Now cockroach_util_hlc.Timestamp

+ OriginNode NodeID

+ TransactionRestart TransactionRestart

+ UnexposedTxn *Transaction

+ func NewError(err error) *Error

+ func NewErrorWithTxn(err error, txn *Transaction) *Error

+ func NewErrorf(format string, a ...interface{}) *Error

+ func (*Error) Descriptor() ([]byte, []int)

+ func (*Error) ProtoMessage()

+ func (e *Error) GetDetail() ErrorDetailInterface

+ func (e *Error) GetTxn() *Transaction

+ func (e *Error) GoError() error

+ func (e *Error) SetErrorIndex(index int32)

+ func (e *Error) SetTxn(txn *Transaction)

+ func (e *Error) String() string

+ func (e *Error) UpdateTxn(o *Transaction)

+ func (m *Error) Marshal() (dAtA []byte, err error)

+ func (m *Error) MarshalTo(dAtA []byte) (int, error)

+ func (m *Error) Reset()

+ func (m *Error) Size() (n int)

+ func (m *Error) Unmarshal(dAtA []byte) error

+ type ErrorDetail struct

+ AmbiguousResult *AmbiguousResultError

+ ConditionFailed *ConditionFailedError

+ HandledRetryableTxnError *HandledRetryableTxnError

+ LeaseRejected *LeaseRejectedError

+ NodeUnavailable *NodeUnavailableError

+ NotLeaseHolder *NotLeaseHolderError

+ OpRequiresTxn *OpRequiresTxnError

+ RaftGroupDeleted *RaftGroupDeletedError

+ RangeKeyMismatch *RangeKeyMismatchError

+ RangeNotFound *RangeNotFoundError

+ ReadWithinUncertaintyInterval *ReadWithinUncertaintyIntervalError

+ ReplicaCorruption *ReplicaCorruptionError

+ ReplicaTooOld *ReplicaTooOldError

+ Send *SendError

+ StoreNotFound *StoreNotFoundError

+ TransactionAborted *TransactionAbortedError

+ TransactionPush *TransactionPushError

+ TransactionReplay *TransactionReplayError

+ TransactionRetry *TransactionRetryError

+ TransactionStatus *TransactionStatusError

+ WriteIntent *WriteIntentError

+ WriteTooOld *WriteTooOldError

+ func (*ErrorDetail) Descriptor() ([]byte, []int)

+ func (*ErrorDetail) ProtoMessage()

+ func (m *ErrorDetail) Marshal() (dAtA []byte, err error)

+ func (m *ErrorDetail) MarshalTo(dAtA []byte) (int, error)

+ func (m *ErrorDetail) Reset()

+ func (m *ErrorDetail) Size() (n int)

+ func (m *ErrorDetail) String() string

+ func (m *ErrorDetail) Unmarshal(dAtA []byte) error

+ func (this *ErrorDetail) GetValue() interface{}

+ func (this *ErrorDetail) SetValue(value interface{}) bool

+ type ErrorDetailInterface interface

+ type ExportRequest struct

+ StartTime cockroach_util_hlc.Timestamp

+ Storage ExportStorage

+ func (*ExportRequest) Descriptor() ([]byte, []int)

+ func (*ExportRequest) Method() Method

+ func (*ExportRequest) ProtoMessage()

+ func (ekr *ExportRequest) ShallowCopy() Request

+ func (m *ExportRequest) Marshal() (dAtA []byte, err error)

+ func (m *ExportRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ExportRequest) Reset()

+ func (m *ExportRequest) Size() (n int)

+ func (m *ExportRequest) String() string

+ func (m *ExportRequest) Unmarshal(dAtA []byte) error

+ type ExportResponse struct

+ Files []ExportResponse_File

+ func (*ExportResponse) Descriptor() ([]byte, []int)

+ func (*ExportResponse) ProtoMessage()

+ func (m *ExportResponse) Marshal() (dAtA []byte, err error)

+ func (m *ExportResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ExportResponse) Reset()

+ func (m *ExportResponse) Size() (n int)

+ func (m *ExportResponse) String() string

+ func (m *ExportResponse) Unmarshal(dAtA []byte) error

+ type ExportResponse_File struct

+ DataSize int64

+ Path string

+ Sha512 []byte

+ Span Span

+ func (*ExportResponse_File) Descriptor() ([]byte, []int)

+ func (*ExportResponse_File) ProtoMessage()

+ func (m *ExportResponse_File) Marshal() (dAtA []byte, err error)

+ func (m *ExportResponse_File) MarshalTo(dAtA []byte) (int, error)

+ func (m *ExportResponse_File) Reset()

+ func (m *ExportResponse_File) Size() (n int)

+ func (m *ExportResponse_File) String() string

+ func (m *ExportResponse_File) Unmarshal(dAtA []byte) error

+ type ExportStorage struct

+ AzureConfig *ExportStorage_Azure

+ GoogleCloudConfig *ExportStorage_GCS

+ HttpPath ExportStorage_Http

+ LocalFile ExportStorage_LocalFilePath

+ Provider ExportStorageProvider

+ S3Config *ExportStorage_S3

+ func (*ExportStorage) Descriptor() ([]byte, []int)

+ func (*ExportStorage) ProtoMessage()

+ func (m *ExportStorage) Marshal() (dAtA []byte, err error)

+ func (m *ExportStorage) MarshalTo(dAtA []byte) (int, error)

+ func (m *ExportStorage) Reset()

+ func (m *ExportStorage) Size() (n int)

+ func (m *ExportStorage) String() string

+ func (m *ExportStorage) Unmarshal(dAtA []byte) error

+ type ExportStorageProvider int32

+ const ExportStorageProvider_Azure

+ const ExportStorageProvider_GoogleCloud

+ const ExportStorageProvider_Http

+ const ExportStorageProvider_LocalFile

+ const ExportStorageProvider_S3

+ const ExportStorageProvider_Unknown

+ func (ExportStorageProvider) EnumDescriptor() ([]byte, []int)

+ func (x *ExportStorageProvider) UnmarshalJSON(data []byte) error

+ func (x ExportStorageProvider) Enum() *ExportStorageProvider

+ func (x ExportStorageProvider) String() string

+ type ExportStorage_Azure struct

+ AccountKey string

+ AccountName string

+ Container string

+ Prefix string

+ func (*ExportStorage_Azure) Descriptor() ([]byte, []int)

+ func (*ExportStorage_Azure) ProtoMessage()

+ func (m *ExportStorage_Azure) Marshal() (dAtA []byte, err error)

+ func (m *ExportStorage_Azure) MarshalTo(dAtA []byte) (int, error)

+ func (m *ExportStorage_Azure) Reset()

+ func (m *ExportStorage_Azure) Size() (n int)

+ func (m *ExportStorage_Azure) String() string

+ func (m *ExportStorage_Azure) Unmarshal(dAtA []byte) error

+ type ExportStorage_GCS struct

+ Bucket string

+ Prefix string

+ func (*ExportStorage_GCS) Descriptor() ([]byte, []int)

+ func (*ExportStorage_GCS) ProtoMessage()

+ func (m *ExportStorage_GCS) Marshal() (dAtA []byte, err error)

+ func (m *ExportStorage_GCS) MarshalTo(dAtA []byte) (int, error)

+ func (m *ExportStorage_GCS) Reset()

+ func (m *ExportStorage_GCS) Size() (n int)

+ func (m *ExportStorage_GCS) String() string

+ func (m *ExportStorage_GCS) Unmarshal(dAtA []byte) error

+ type ExportStorage_Http struct

+ BaseUri string

+ func (*ExportStorage_Http) Descriptor() ([]byte, []int)

+ func (*ExportStorage_Http) ProtoMessage()

+ func (m *ExportStorage_Http) Marshal() (dAtA []byte, err error)

+ func (m *ExportStorage_Http) MarshalTo(dAtA []byte) (int, error)

+ func (m *ExportStorage_Http) Reset()

+ func (m *ExportStorage_Http) Size() (n int)

+ func (m *ExportStorage_Http) String() string

+ func (m *ExportStorage_Http) Unmarshal(dAtA []byte) error

+ type ExportStorage_LocalFilePath struct

+ Path string

+ func (*ExportStorage_LocalFilePath) Descriptor() ([]byte, []int)

+ func (*ExportStorage_LocalFilePath) ProtoMessage()

+ func (m *ExportStorage_LocalFilePath) Marshal() (dAtA []byte, err error)

+ func (m *ExportStorage_LocalFilePath) MarshalTo(dAtA []byte) (int, error)

+ func (m *ExportStorage_LocalFilePath) Reset()

+ func (m *ExportStorage_LocalFilePath) Size() (n int)

+ func (m *ExportStorage_LocalFilePath) String() string

+ func (m *ExportStorage_LocalFilePath) Unmarshal(dAtA []byte) error

+ type ExportStorage_S3 struct

+ AccessKey string

+ Bucket string

+ Prefix string

+ Secret string

+ TempToken string

+ func (*ExportStorage_S3) Descriptor() ([]byte, []int)

+ func (*ExportStorage_S3) ProtoMessage()

+ func (b *ExportStorage_S3) Keys() s3gof3r.Keys

+ func (m *ExportStorage_S3) Marshal() (dAtA []byte, err error)

+ func (m *ExportStorage_S3) MarshalTo(dAtA []byte) (int, error)

+ func (m *ExportStorage_S3) Reset()

+ func (m *ExportStorage_S3) Size() (n int)

+ func (m *ExportStorage_S3) String() string

+ func (m *ExportStorage_S3) Unmarshal(dAtA []byte) error

+ type ExternalClient interface

+ Batch func(ctx context.Context, in *BatchRequest, opts ...grpc.CallOption) (*BatchResponse, error)

+ func NewExternalClient(cc *grpc.ClientConn) ExternalClient

+ type ExternalServer interface

+ Batch func(context.Context, *BatchRequest) (*BatchResponse, error)

+ type GCRequest struct

+ Keys []GCRequest_GCKey

+ Threshold cockroach_util_hlc.Timestamp

+ TxnSpanGCThreshold cockroach_util_hlc.Timestamp

+ func (*GCRequest) Descriptor() ([]byte, []int)

+ func (*GCRequest) Method() Method

+ func (*GCRequest) ProtoMessage()

+ func (gcr *GCRequest) ShallowCopy() Request

+ func (m *GCRequest) Marshal() (dAtA []byte, err error)

+ func (m *GCRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GCRequest) Reset()

+ func (m *GCRequest) Size() (n int)

+ func (m *GCRequest) String() string

+ func (m *GCRequest) Unmarshal(dAtA []byte) error

+ type GCRequest_GCKey struct

+ Key Key

+ Timestamp cockroach_util_hlc.Timestamp

+ func (*GCRequest_GCKey) Descriptor() ([]byte, []int)

+ func (*GCRequest_GCKey) ProtoMessage()

+ func (m *GCRequest_GCKey) Marshal() (dAtA []byte, err error)

+ func (m *GCRequest_GCKey) MarshalTo(dAtA []byte) (int, error)

+ func (m *GCRequest_GCKey) Reset()

+ func (m *GCRequest_GCKey) Size() (n int)

+ func (m *GCRequest_GCKey) String() string

+ func (m *GCRequest_GCKey) Unmarshal(dAtA []byte) error

+ type GCResponse struct

+ func (*GCResponse) Descriptor() ([]byte, []int)

+ func (*GCResponse) ProtoMessage()

+ func (m *GCResponse) Marshal() (dAtA []byte, err error)

+ func (m *GCResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GCResponse) Reset()

+ func (m *GCResponse) Size() (n int)

+ func (m *GCResponse) String() string

+ func (m *GCResponse) Unmarshal(dAtA []byte) error

+ type GetRequest struct

+ func (*GetRequest) Descriptor() ([]byte, []int)

+ func (*GetRequest) Method() Method

+ func (*GetRequest) ProtoMessage()

+ func (gr *GetRequest) ShallowCopy() Request

+ func (m *GetRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetRequest) Reset()

+ func (m *GetRequest) Size() (n int)

+ func (m *GetRequest) String() string

+ func (m *GetRequest) Unmarshal(dAtA []byte) error

+ type GetResponse struct

+ Value *Value

+ func (*GetResponse) Descriptor() ([]byte, []int)

+ func (*GetResponse) ProtoMessage()

+ func (gr *GetResponse) Verify(req Request) error

+ func (m *GetResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetResponse) Reset()

+ func (m *GetResponse) Size() (n int)

+ func (m *GetResponse) String() string

+ func (m *GetResponse) Unmarshal(dAtA []byte) error

+ type HandledRetryableTxnError struct

+ Msg string

+ Transaction *Transaction

+ TxnID *github_com_cockroachdb_cockroach_pkg_util_uuid.UUID

+ func NewHandledRetryableTxnError(msg string, txnID *uuid.UUID, txn Transaction) *HandledRetryableTxnError

+ func (*HandledRetryableTxnError) Descriptor() ([]byte, []int)

+ func (*HandledRetryableTxnError) ProtoMessage()

+ func (e *HandledRetryableTxnError) Error() string

+ func (m *HandledRetryableTxnError) Marshal() (dAtA []byte, err error)

+ func (m *HandledRetryableTxnError) MarshalTo(dAtA []byte) (int, error)

+ func (m *HandledRetryableTxnError) Reset()

+ func (m *HandledRetryableTxnError) Size() (n int)

+ func (m *HandledRetryableTxnError) String() string

+ func (m *HandledRetryableTxnError) Unmarshal(dAtA []byte) error

+ type Header struct

+ DistinctSpans bool

+ GatewayNodeID NodeID

+ MaxSpanRequestKeys int64

+ RangeID RangeID

+ ReadConsistency ReadConsistencyType

+ Replica ReplicaDescriptor

+ ReturnRangeInfo bool

+ Timestamp cockroach_util_hlc.Timestamp

+ TraceContext *cockroach_util_tracing.SpanContextCarrier

+ Txn *Transaction

+ UserPriority UserPriority

+ func (*Header) Descriptor() ([]byte, []int)

+ func (*Header) ProtoMessage()

+ func (h Header) GetTxnID() *uuid.UUID

+ func (m *Header) Marshal() (dAtA []byte, err error)

+ func (m *Header) MarshalTo(dAtA []byte) (int, error)

+ func (m *Header) Reset()

+ func (m *Header) Size() (n int)

+ func (m *Header) String() string

+ func (m *Header) Unmarshal(dAtA []byte) error

+ type HeartbeatTxnRequest struct

+ Now cockroach_util_hlc.Timestamp

+ func (*HeartbeatTxnRequest) Descriptor() ([]byte, []int)

+ func (*HeartbeatTxnRequest) Method() Method

+ func (*HeartbeatTxnRequest) ProtoMessage()

+ func (htr *HeartbeatTxnRequest) ShallowCopy() Request

+ func (m *HeartbeatTxnRequest) Marshal() (dAtA []byte, err error)

+ func (m *HeartbeatTxnRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *HeartbeatTxnRequest) Reset()

+ func (m *HeartbeatTxnRequest) Size() (n int)

+ func (m *HeartbeatTxnRequest) String() string

+ func (m *HeartbeatTxnRequest) Unmarshal(dAtA []byte) error

+ type HeartbeatTxnResponse struct

+ func (*HeartbeatTxnResponse) Descriptor() ([]byte, []int)

+ func (*HeartbeatTxnResponse) ProtoMessage()

+ func (m *HeartbeatTxnResponse) Marshal() (dAtA []byte, err error)

+ func (m *HeartbeatTxnResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *HeartbeatTxnResponse) Reset()

+ func (m *HeartbeatTxnResponse) Size() (n int)

+ func (m *HeartbeatTxnResponse) String() string

+ func (m *HeartbeatTxnResponse) Unmarshal(dAtA []byte) error

+ type ImportRequest struct

+ DataSpan Span

+ Files []ImportRequest_File

+ Rekeys []ImportRequest_TableRekey

+ func (*ImportRequest) Descriptor() ([]byte, []int)

+ func (*ImportRequest) Method() Method

+ func (*ImportRequest) ProtoMessage()

+ func (m *ImportRequest) Marshal() (dAtA []byte, err error)

+ func (m *ImportRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ImportRequest) Reset()

+ func (m *ImportRequest) Size() (n int)

+ func (m *ImportRequest) String() string

+ func (m *ImportRequest) Unmarshal(dAtA []byte) error

+ func (r *ImportRequest) ShallowCopy() Request

+ type ImportRequest_File struct

+ Dir ExportStorage

+ Path string

+ Sha512 []byte

+ func (*ImportRequest_File) Descriptor() ([]byte, []int)

+ func (*ImportRequest_File) ProtoMessage()

+ func (m *ImportRequest_File) Marshal() (dAtA []byte, err error)

+ func (m *ImportRequest_File) MarshalTo(dAtA []byte) (int, error)

+ func (m *ImportRequest_File) Reset()

+ func (m *ImportRequest_File) Size() (n int)

+ func (m *ImportRequest_File) String() string

+ func (m *ImportRequest_File) Unmarshal(dAtA []byte) error

+ type ImportRequest_TableRekey struct

+ NewDesc []byte

+ OldID uint32

+ func (*ImportRequest_TableRekey) Descriptor() ([]byte, []int)

+ func (*ImportRequest_TableRekey) ProtoMessage()

+ func (m *ImportRequest_TableRekey) Marshal() (dAtA []byte, err error)

+ func (m *ImportRequest_TableRekey) MarshalTo(dAtA []byte) (int, error)

+ func (m *ImportRequest_TableRekey) Reset()

+ func (m *ImportRequest_TableRekey) Size() (n int)

+ func (m *ImportRequest_TableRekey) String() string

+ func (m *ImportRequest_TableRekey) Unmarshal(dAtA []byte) error

+ type ImportResponse struct

+ DataSize int64

+ func (*ImportResponse) Descriptor() ([]byte, []int)

+ func (*ImportResponse) ProtoMessage()

+ func (m *ImportResponse) Marshal() (dAtA []byte, err error)

+ func (m *ImportResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ImportResponse) Reset()

+ func (m *ImportResponse) Size() (n int)

+ func (m *ImportResponse) String() string

+ func (m *ImportResponse) Unmarshal(dAtA []byte) error

+ type IncrementRequest struct

+ Increment int64

+ func (*IncrementRequest) Descriptor() ([]byte, []int)

+ func (*IncrementRequest) Method() Method

+ func (*IncrementRequest) ProtoMessage()

+ func (ir *IncrementRequest) ShallowCopy() Request

+ func (m *IncrementRequest) Marshal() (dAtA []byte, err error)

+ func (m *IncrementRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *IncrementRequest) Reset()

+ func (m *IncrementRequest) Size() (n int)

+ func (m *IncrementRequest) String() string

+ func (m *IncrementRequest) Unmarshal(dAtA []byte) error

+ type IncrementResponse struct

+ NewValue int64

+ func (*IncrementResponse) Descriptor() ([]byte, []int)

+ func (*IncrementResponse) ProtoMessage()

+ func (m *IncrementResponse) Marshal() (dAtA []byte, err error)

+ func (m *IncrementResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *IncrementResponse) Reset()

+ func (m *IncrementResponse) Size() (n int)

+ func (m *IncrementResponse) String() string

+ func (m *IncrementResponse) Unmarshal(dAtA []byte) error

+ type InitPutRequest struct

+ Blind bool

+ Value Value

+ func (*InitPutRequest) Descriptor() ([]byte, []int)

+ func (*InitPutRequest) Method() Method

+ func (*InitPutRequest) ProtoMessage()

+ func (m *InitPutRequest) Marshal() (dAtA []byte, err error)

+ func (m *InitPutRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *InitPutRequest) Reset()

+ func (m *InitPutRequest) Size() (n int)

+ func (m *InitPutRequest) String() string

+ func (m *InitPutRequest) Unmarshal(dAtA []byte) error

+ func (pr *InitPutRequest) ShallowCopy() Request

+ type InitPutResponse struct

+ func (*InitPutResponse) Descriptor() ([]byte, []int)

+ func (*InitPutResponse) ProtoMessage()

+ func (m *InitPutResponse) Marshal() (dAtA []byte, err error)

+ func (m *InitPutResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *InitPutResponse) Reset()

+ func (m *InitPutResponse) Size() (n int)

+ func (m *InitPutResponse) String() string

+ func (m *InitPutResponse) Unmarshal(dAtA []byte) error

+ type Intent struct

+ Status TransactionStatus

+ Txn cockroach_storage_engine_enginepb.TxnMeta

+ func AsIntents(spans []Span, txn *Transaction) []Intent

+ func (*Intent) Descriptor() ([]byte, []int)

+ func (*Intent) ProtoMessage()

+ func (m *Intent) Marshal() (dAtA []byte, err error)

+ func (m *Intent) MarshalTo(dAtA []byte) (int, error)

+ func (m *Intent) Reset()

+ func (m *Intent) Size() (n int)

+ func (m *Intent) String() string

+ func (m *Intent) Unmarshal(dAtA []byte) error

+ type InternalClient interface

+ Batch func(ctx context.Context, in *BatchRequest, opts ...grpc.CallOption) (*BatchResponse, error)

+ func NewInternalClient(cc *grpc.ClientConn) InternalClient

+ type InternalCommitTrigger struct

+ ChangeReplicasTrigger *ChangeReplicasTrigger

+ MergeTrigger *MergeTrigger

+ ModifiedSpanTrigger *ModifiedSpanTrigger

+ SplitTrigger *SplitTrigger

+ func (*InternalCommitTrigger) Descriptor() ([]byte, []int)

+ func (*InternalCommitTrigger) ProtoMessage()

+ func (m *InternalCommitTrigger) GetChangeReplicasTrigger() *ChangeReplicasTrigger

+ func (m *InternalCommitTrigger) GetMergeTrigger() *MergeTrigger

+ func (m *InternalCommitTrigger) GetModifiedSpanTrigger() *ModifiedSpanTrigger

+ func (m *InternalCommitTrigger) GetSplitTrigger() *SplitTrigger

+ func (m *InternalCommitTrigger) Marshal() (dAtA []byte, err error)

+ func (m *InternalCommitTrigger) MarshalTo(dAtA []byte) (int, error)

+ func (m *InternalCommitTrigger) Reset()

+ func (m *InternalCommitTrigger) Size() (n int)

+ func (m *InternalCommitTrigger) String() string

+ func (m *InternalCommitTrigger) Unmarshal(dAtA []byte) error

+ type InternalServer interface

+ Batch func(context.Context, *BatchRequest) (*BatchResponse, error)

+ type InternalTimeSeriesData struct

+ SampleDurationNanos int64

+ Samples []InternalTimeSeriesSample

+ StartTimestampNanos int64

+ func (*InternalTimeSeriesData) Descriptor() ([]byte, []int)

+ func (*InternalTimeSeriesData) ProtoMessage()

+ func (m *InternalTimeSeriesData) Marshal() (dAtA []byte, err error)

+ func (m *InternalTimeSeriesData) MarshalTo(dAtA []byte) (int, error)

+ func (m *InternalTimeSeriesData) Reset()

+ func (m *InternalTimeSeriesData) Size() (n int)

+ func (m *InternalTimeSeriesData) String() string

+ func (m *InternalTimeSeriesData) Unmarshal(dAtA []byte) error

+ type InternalTimeSeriesSample struct

+ Count uint32

+ Max *float64

+ Min *float64

+ Offset int32

+ Sum float64

+ func (*InternalTimeSeriesSample) Descriptor() ([]byte, []int)

+ func (*InternalTimeSeriesSample) ProtoMessage()

+ func (m *InternalTimeSeriesSample) Marshal() (dAtA []byte, err error)

+ func (m *InternalTimeSeriesSample) MarshalTo(dAtA []byte) (int, error)

+ func (m *InternalTimeSeriesSample) Reset()

+ func (m *InternalTimeSeriesSample) Size() (n int)

+ func (m *InternalTimeSeriesSample) String() string

+ func (m *InternalTimeSeriesSample) Unmarshal(dAtA []byte) error

+ func (samp InternalTimeSeriesSample) Average() float64

+ func (samp InternalTimeSeriesSample) Maximum() float64

+ func (samp InternalTimeSeriesSample) Minimum() float64

+ func (samp InternalTimeSeriesSample) Summation() float64

+ type Key []byte

+ func (k Key) Compare(b Key) int

+ func (k Key) Equal(l Key) bool

+ func (k Key) Format(f fmt.State, verb rune)

+ func (k Key) IsPrev(m Key) bool

+ func (k Key) Next() Key

+ func (k Key) PrefixEnd() Key

+ func (k Key) String() string

+ type KeyValue struct

+ Key Key

+ Value Value

+ func (*KeyValue) Descriptor() ([]byte, []int)

+ func (*KeyValue) ProtoMessage()

+ func (m *KeyValue) Marshal() (dAtA []byte, err error)

+ func (m *KeyValue) MarshalTo(dAtA []byte) (int, error)

+ func (m *KeyValue) Reset()

+ func (m *KeyValue) Size() (n int)

+ func (m *KeyValue) String() string

+ func (m *KeyValue) Unmarshal(dAtA []byte) error

+ type KeyValueByKey []KeyValue

+ func (kv KeyValueByKey) Len() int

+ func (kv KeyValueByKey) Less(i, j int) bool

+ func (kv KeyValueByKey) Swap(i, j int)

+ type Lease struct

+ DeprecatedStartStasis cockroach_util_hlc.Timestamp

+ Epoch *int64

+ Expiration cockroach_util_hlc.Timestamp

+ ProposedTS *cockroach_util_hlc.Timestamp

+ Replica ReplicaDescriptor

+ Start cockroach_util_hlc.Timestamp

+ func NewPopulatedLease(r randyData, easy bool) *Lease

+ func (*Lease) Descriptor() ([]byte, []int)

+ func (*Lease) ProtoMessage()

+ func (l Lease) Equivalent(ol Lease) error

+ func (l Lease) OwnedBy(storeID StoreID) bool

+ func (l Lease) String() string

+ func (l Lease) Type() LeaseType

+ func (m *Lease) Marshal() (dAtA []byte, err error)

+ func (m *Lease) MarshalTo(dAtA []byte) (int, error)

+ func (m *Lease) Reset()

+ func (m *Lease) Size() (n int)

+ func (m *Lease) Unmarshal(dAtA []byte) error

+ type LeaseInfoRequest struct

+ func (*LeaseInfoRequest) Descriptor() ([]byte, []int)

+ func (*LeaseInfoRequest) Method() Method

+ func (*LeaseInfoRequest) ProtoMessage()

+ func (lt *LeaseInfoRequest) ShallowCopy() Request

+ func (m *LeaseInfoRequest) Marshal() (dAtA []byte, err error)

+ func (m *LeaseInfoRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *LeaseInfoRequest) Reset()

+ func (m *LeaseInfoRequest) Size() (n int)

+ func (m *LeaseInfoRequest) String() string

+ func (m *LeaseInfoRequest) Unmarshal(dAtA []byte) error

+ type LeaseInfoResponse struct

+ Lease *Lease

+ func (*LeaseInfoResponse) Descriptor() ([]byte, []int)

+ func (*LeaseInfoResponse) ProtoMessage()

+ func (m *LeaseInfoResponse) Marshal() (dAtA []byte, err error)

+ func (m *LeaseInfoResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *LeaseInfoResponse) Reset()

+ func (m *LeaseInfoResponse) Size() (n int)

+ func (m *LeaseInfoResponse) String() string

+ func (m *LeaseInfoResponse) Unmarshal(dAtA []byte) error

+ type LeaseRejectedError struct

+ Existing Lease

+ Message string

+ Requested Lease

+ func (*LeaseRejectedError) Descriptor() ([]byte, []int)

+ func (*LeaseRejectedError) ProtoMessage()

+ func (e *LeaseRejectedError) Error() string

+ func (m *LeaseRejectedError) Marshal() (dAtA []byte, err error)

+ func (m *LeaseRejectedError) MarshalTo(dAtA []byte) (int, error)

+ func (m *LeaseRejectedError) Reset()

+ func (m *LeaseRejectedError) Size() (n int)

+ func (m *LeaseRejectedError) String() string

+ func (m *LeaseRejectedError) Unmarshal(dAtA []byte) error

+ type LeaseType int

+ const LeaseEpoch

+ const LeaseExpiration

+ const LeaseNone

+ type Locality struct

+ Tiers []Tier

+ func (*Locality) Descriptor() ([]byte, []int)

+ func (*Locality) ProtoMessage()

+ func (Locality) Type() string

+ func (l *Locality) Set(value string) error

+ func (l Locality) DiversityScore(other Locality) float64

+ func (l Locality) String() string

+ func (m *Locality) Marshal() (dAtA []byte, err error)

+ func (m *Locality) MarshalTo(dAtA []byte) (int, error)

+ func (m *Locality) Reset()

+ func (m *Locality) Size() (n int)

+ func (m *Locality) Unmarshal(dAtA []byte) error

+ type MergeRequest struct

+ Value Value

+ func (*MergeRequest) Descriptor() ([]byte, []int)

+ func (*MergeRequest) Method() Method

+ func (*MergeRequest) ProtoMessage()

+ func (m *MergeRequest) Marshal() (dAtA []byte, err error)

+ func (m *MergeRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *MergeRequest) Reset()

+ func (m *MergeRequest) Size() (n int)

+ func (m *MergeRequest) String() string

+ func (m *MergeRequest) Unmarshal(dAtA []byte) error

+ func (mr *MergeRequest) ShallowCopy() Request

+ type MergeResponse struct

+ func (*MergeResponse) Descriptor() ([]byte, []int)

+ func (*MergeResponse) ProtoMessage()

+ func (m *MergeResponse) Marshal() (dAtA []byte, err error)

+ func (m *MergeResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *MergeResponse) Reset()

+ func (m *MergeResponse) Size() (n int)

+ func (m *MergeResponse) String() string

+ func (m *MergeResponse) Unmarshal(dAtA []byte) error

+ type MergeTrigger struct

+ LeftDesc RangeDescriptor

+ RightDesc RangeDescriptor

+ func (*MergeTrigger) Descriptor() ([]byte, []int)

+ func (*MergeTrigger) ProtoMessage()

+ func (m *MergeTrigger) Marshal() (dAtA []byte, err error)

+ func (m *MergeTrigger) MarshalTo(dAtA []byte) (int, error)

+ func (m *MergeTrigger) Reset()

+ func (m *MergeTrigger) Size() (n int)

+ func (m *MergeTrigger) String() string

+ func (m *MergeTrigger) Unmarshal(dAtA []byte) error

+ type Method int

+ const AdminChangeReplicas

+ const AdminMerge

+ const AdminScatter

+ const AdminSplit

+ const AdminTransferLease

+ const BeginTransaction

+ const CheckConsistency

+ const ComputeChecksum

+ const ConditionalPut

+ const Delete

+ const DeleteRange

+ const DeprecatedVerifyChecksum

+ const EndTransaction

+ const Export

+ const GC

+ const Get

+ const HeartbeatTxn

+ const Import

+ const Increment

+ const InitPut

+ const LeaseInfo

+ const Merge

+ const Noop

+ const PushTxn

+ const Put

+ const QueryTxn

+ const RangeLookup

+ const RequestLease

+ const ResolveIntent

+ const ResolveIntentRange

+ const ReverseScan

+ const Scan

+ const TransferLease

+ const TruncateLog

+ const WriteBatch

+ func (i Method) String() string

+ type ModifiedSpanTrigger struct

+ NodeLivenessSpan *Span

+ SystemConfigSpan bool

+ func (*ModifiedSpanTrigger) Descriptor() ([]byte, []int)

+ func (*ModifiedSpanTrigger) ProtoMessage()

+ func (m *ModifiedSpanTrigger) Marshal() (dAtA []byte, err error)

+ func (m *ModifiedSpanTrigger) MarshalTo(dAtA []byte) (int, error)

+ func (m *ModifiedSpanTrigger) Reset()

+ func (m *ModifiedSpanTrigger) Size() (n int)

+ func (m *ModifiedSpanTrigger) String() string

+ func (m *ModifiedSpanTrigger) Unmarshal(dAtA []byte) error

+ type NodeDescriptor struct

+ Address cockroach_util.UnresolvedAddr

+ Attrs Attributes

+ Locality Locality

+ NodeID NodeID

+ func (*NodeDescriptor) Descriptor() ([]byte, []int)

+ func (*NodeDescriptor) ProtoMessage()

+ func (m *NodeDescriptor) Marshal() (dAtA []byte, err error)

+ func (m *NodeDescriptor) MarshalTo(dAtA []byte) (int, error)

+ func (m *NodeDescriptor) Reset()

+ func (m *NodeDescriptor) Size() (n int)

+ func (m *NodeDescriptor) String() string

+ func (m *NodeDescriptor) Unmarshal(dAtA []byte) error

+ type NodeID int32

+ func (n NodeID) String() string

+ type NodeUnavailableError struct

+ func (*NodeUnavailableError) Descriptor() ([]byte, []int)

+ func (*NodeUnavailableError) ProtoMessage()

+ func (e *NodeUnavailableError) Error() string

+ func (m *NodeUnavailableError) Marshal() (dAtA []byte, err error)

+ func (m *NodeUnavailableError) MarshalTo(dAtA []byte) (int, error)

+ func (m *NodeUnavailableError) Reset()

+ func (m *NodeUnavailableError) Size() (n int)

+ func (m *NodeUnavailableError) String() string

+ func (m *NodeUnavailableError) Unmarshal(dAtA []byte) error

+ type NoopRequest struct

+ func (*NoopRequest) Descriptor() ([]byte, []int)

+ func (*NoopRequest) Header() Span

+ func (*NoopRequest) Method() Method

+ func (*NoopRequest) ProtoMessage()

+ func (*NoopRequest) SetHeader(_ Span)

+ func (m *NoopRequest) Marshal() (dAtA []byte, err error)

+ func (m *NoopRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *NoopRequest) Reset()

+ func (m *NoopRequest) Size() (n int)

+ func (m *NoopRequest) String() string

+ func (m *NoopRequest) Unmarshal(dAtA []byte) error

+ func (nr *NoopRequest) ShallowCopy() Request

+ type NoopResponse struct

+ func (*NoopResponse) Descriptor() ([]byte, []int)

+ func (*NoopResponse) Header() ResponseHeader

+ func (*NoopResponse) ProtoMessage()

+ func (*NoopResponse) SetHeader(_ ResponseHeader)

+ func (*NoopResponse) Verify(_ Request) error

+ func (m *NoopResponse) Marshal() (dAtA []byte, err error)

+ func (m *NoopResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *NoopResponse) Reset()

+ func (m *NoopResponse) Size() (n int)

+ func (m *NoopResponse) String() string

+ func (m *NoopResponse) Unmarshal(dAtA []byte) error

+ type NotLeaseHolderError struct

+ CustomMsg string

+ Lease *Lease

+ LeaseHolder *ReplicaDescriptor

+ RangeID RangeID

+ Replica ReplicaDescriptor

+ func (*NotLeaseHolderError) Descriptor() ([]byte, []int)

+ func (*NotLeaseHolderError) ProtoMessage()

+ func (e *NotLeaseHolderError) Error() string

+ func (m *NotLeaseHolderError) Marshal() (dAtA []byte, err error)

+ func (m *NotLeaseHolderError) MarshalTo(dAtA []byte) (int, error)

+ func (m *NotLeaseHolderError) Reset()

+ func (m *NotLeaseHolderError) Size() (n int)

+ func (m *NotLeaseHolderError) String() string

+ func (m *NotLeaseHolderError) Unmarshal(dAtA []byte) error

+ type NumericStat struct

+ Mean float64

+ SquaredDiffs float64

+ func (*NumericStat) Descriptor() ([]byte, []int)

+ func (*NumericStat) ProtoMessage()

+ func (l *NumericStat) GetVariance(count int64) float64

+ func (l *NumericStat) Record(count int64, val float64)

+ func (m *NumericStat) Marshal() (dAtA []byte, err error)

+ func (m *NumericStat) MarshalTo(dAtA []byte) (int, error)

+ func (m *NumericStat) Reset()

+ func (m *NumericStat) Size() (n int)

+ func (m *NumericStat) String() string

+ func (m *NumericStat) Unmarshal(dAtA []byte) error

+ type ObservedTimestamp struct

+ NodeID NodeID

+ Timestamp cockroach_util_hlc.Timestamp

+ func NewPopulatedObservedTimestamp(r randyData, easy bool) *ObservedTimestamp

+ func (*ObservedTimestamp) Descriptor() ([]byte, []int)

+ func (*ObservedTimestamp) ProtoMessage()

+ func (m *ObservedTimestamp) Marshal() (dAtA []byte, err error)

+ func (m *ObservedTimestamp) MarshalTo(dAtA []byte) (int, error)

+ func (m *ObservedTimestamp) Reset()

+ func (m *ObservedTimestamp) Size() (n int)

+ func (m *ObservedTimestamp) String() string

+ func (m *ObservedTimestamp) Unmarshal(dAtA []byte) error

+ type OpRequiresTxnError struct

+ func (*OpRequiresTxnError) Descriptor() ([]byte, []int)

+ func (*OpRequiresTxnError) ProtoMessage()

+ func (e *OpRequiresTxnError) Error() string

+ func (m *OpRequiresTxnError) Marshal() (dAtA []byte, err error)

+ func (m *OpRequiresTxnError) MarshalTo(dAtA []byte) (int, error)

+ func (m *OpRequiresTxnError) Reset()

+ func (m *OpRequiresTxnError) Size() (n int)

+ func (m *OpRequiresTxnError) String() string

+ func (m *OpRequiresTxnError) Unmarshal(dAtA []byte) error

+ type PushTxnRequest struct

+ Force bool

+ NewPriorities bool

+ Now cockroach_util_hlc.Timestamp

+ PushTo cockroach_util_hlc.Timestamp

+ PushType PushTxnType

+ PusheeTxn cockroach_storage_engine_enginepb.TxnMeta

+ PusherTxn Transaction

+ func (*PushTxnRequest) Descriptor() ([]byte, []int)

+ func (*PushTxnRequest) Method() Method

+ func (*PushTxnRequest) ProtoMessage()

+ func (m *PushTxnRequest) Marshal() (dAtA []byte, err error)

+ func (m *PushTxnRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *PushTxnRequest) Reset()

+ func (m *PushTxnRequest) Size() (n int)

+ func (m *PushTxnRequest) String() string

+ func (m *PushTxnRequest) Unmarshal(dAtA []byte) error

+ func (ptr *PushTxnRequest) ShallowCopy() Request

+ type PushTxnResponse struct

+ PusheeTxn Transaction

+ func (*PushTxnResponse) Descriptor() ([]byte, []int)

+ func (*PushTxnResponse) ProtoMessage()

+ func (m *PushTxnResponse) Marshal() (dAtA []byte, err error)

+ func (m *PushTxnResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *PushTxnResponse) Reset()

+ func (m *PushTxnResponse) Size() (n int)

+ func (m *PushTxnResponse) String() string

+ func (m *PushTxnResponse) Unmarshal(dAtA []byte) error

+ type PushTxnType int32

+ const PUSH_ABORT

+ const PUSH_QUERY

+ const PUSH_TIMESTAMP

+ const PUSH_TOUCH

+ func (PushTxnType) EnumDescriptor() ([]byte, []int)

+ func (x *PushTxnType) UnmarshalJSON(data []byte) error

+ func (x PushTxnType) Enum() *PushTxnType

+ func (x PushTxnType) String() string

+ type PutRequest struct

+ Blind bool

+ Inline bool

+ Value Value

+ func (*PutRequest) Descriptor() ([]byte, []int)

+ func (*PutRequest) Method() Method

+ func (*PutRequest) ProtoMessage()

+ func (m *PutRequest) Marshal() (dAtA []byte, err error)

+ func (m *PutRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *PutRequest) Reset()

+ func (m *PutRequest) Size() (n int)

+ func (m *PutRequest) String() string

+ func (m *PutRequest) Unmarshal(dAtA []byte) error

+ func (pr *PutRequest) ShallowCopy() Request

+ type PutResponse struct

+ func (*PutResponse) Descriptor() ([]byte, []int)

+ func (*PutResponse) ProtoMessage()

+ func (m *PutResponse) Marshal() (dAtA []byte, err error)

+ func (m *PutResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *PutResponse) Reset()

+ func (m *PutResponse) Size() (n int)

+ func (m *PutResponse) String() string

+ func (m *PutResponse) Unmarshal(dAtA []byte) error

+ type QueryTxnRequest struct

+ Txn cockroach_storage_engine_enginepb.TxnMeta

+ func (*QueryTxnRequest) Descriptor() ([]byte, []int)

+ func (*QueryTxnRequest) Method() Method

+ func (*QueryTxnRequest) ProtoMessage()

+ func (m *QueryTxnRequest) Marshal() (dAtA []byte, err error)

+ func (m *QueryTxnRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *QueryTxnRequest) Reset()

+ func (m *QueryTxnRequest) Size() (n int)

+ func (m *QueryTxnRequest) String() string

+ func (m *QueryTxnRequest) Unmarshal(dAtA []byte) error

+ func (qtr *QueryTxnRequest) ShallowCopy() Request

+ type QueryTxnResponse struct

+ QueriedTxn Transaction

+ WaitingTxns []github_com_cockroachdb_cockroach_pkg_util_uuid.UUID

+ func (*QueryTxnResponse) Descriptor() ([]byte, []int)

+ func (*QueryTxnResponse) ProtoMessage()

+ func (m *QueryTxnResponse) Marshal() (dAtA []byte, err error)

+ func (m *QueryTxnResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *QueryTxnResponse) Reset()

+ func (m *QueryTxnResponse) Size() (n int)

+ func (m *QueryTxnResponse) String() string

+ func (m *QueryTxnResponse) Unmarshal(dAtA []byte) error

+ type RKey Key

+ func (rk RKey) AsRawKey() Key

+ func (rk RKey) Equal(other []byte) bool

+ func (rk RKey) Less(otherRK RKey) bool

+ func (rk RKey) Next() RKey

+ func (rk RKey) PrefixEnd() RKey

+ func (rk RKey) String() string

+ type RSpan struct

+ EndKey RKey

+ Key RKey

+ func (rs RSpan) ContainsExclusiveEndKey(key RKey) bool

+ func (rs RSpan) ContainsKey(key RKey) bool

+ func (rs RSpan) ContainsKeyRange(start, end RKey) bool

+ func (rs RSpan) Equal(o RSpan) bool

+ func (rs RSpan) Intersect(desc *RangeDescriptor) (RSpan, error)

+ func (rs RSpan) Overlaps(other RSpan) bool

+ func (rs RSpan) String() string

+ type RaftGroupDeletedError struct

+ func (*RaftGroupDeletedError) Descriptor() ([]byte, []int)

+ func (*RaftGroupDeletedError) ProtoMessage()

+ func (e *RaftGroupDeletedError) Error() string

+ func (m *RaftGroupDeletedError) Marshal() (dAtA []byte, err error)

+ func (m *RaftGroupDeletedError) MarshalTo(dAtA []byte) (int, error)

+ func (m *RaftGroupDeletedError) Reset()

+ func (m *RaftGroupDeletedError) Size() (n int)

+ func (m *RaftGroupDeletedError) String() string

+ func (m *RaftGroupDeletedError) Unmarshal(dAtA []byte) error

+ type RaftSnapshotData struct

+ KV []RaftSnapshotData_KeyValue

+ LogEntries [][]byte

+ RangeDescriptor RangeDescriptor

+ func (*RaftSnapshotData) Descriptor() ([]byte, []int)

+ func (*RaftSnapshotData) ProtoMessage()

+ func (m *RaftSnapshotData) Marshal() (dAtA []byte, err error)

+ func (m *RaftSnapshotData) MarshalTo(dAtA []byte) (int, error)

+ func (m *RaftSnapshotData) Reset()

+ func (m *RaftSnapshotData) Size() (n int)

+ func (m *RaftSnapshotData) String() string

+ func (m *RaftSnapshotData) Unmarshal(dAtA []byte) error

+ type RaftSnapshotData_KeyValue struct

+ Key []byte

+ Timestamp cockroach_util_hlc.Timestamp

+ Value []byte

+ func (*RaftSnapshotData_KeyValue) Descriptor() ([]byte, []int)

+ func (*RaftSnapshotData_KeyValue) ProtoMessage()

+ func (m *RaftSnapshotData_KeyValue) Marshal() (dAtA []byte, err error)

+ func (m *RaftSnapshotData_KeyValue) MarshalTo(dAtA []byte) (int, error)

+ func (m *RaftSnapshotData_KeyValue) Reset()

+ func (m *RaftSnapshotData_KeyValue) Size() (n int)

+ func (m *RaftSnapshotData_KeyValue) String() string

+ func (m *RaftSnapshotData_KeyValue) Unmarshal(dAtA []byte) error

+ type RaftTombstone struct

+ NextReplicaID ReplicaID

+ func (*RaftTombstone) Descriptor() ([]byte, []int)

+ func (*RaftTombstone) ProtoMessage()

+ func (m *RaftTombstone) Marshal() (dAtA []byte, err error)

+ func (m *RaftTombstone) MarshalTo(dAtA []byte) (int, error)

+ func (m *RaftTombstone) Reset()

+ func (m *RaftTombstone) Size() (n int)

+ func (m *RaftTombstone) String() string

+ func (m *RaftTombstone) Unmarshal(dAtA []byte) error

+ type RaftTruncatedState struct

+ Index uint64

+ Term uint64

+ func NewPopulatedRaftTruncatedState(r randyInternalRaft, easy bool) *RaftTruncatedState

+ func (*RaftTruncatedState) Descriptor() ([]byte, []int)

+ func (*RaftTruncatedState) ProtoMessage()

+ func (m *RaftTruncatedState) Marshal() (dAtA []byte, err error)

+ func (m *RaftTruncatedState) MarshalTo(dAtA []byte) (int, error)

+ func (m *RaftTruncatedState) Reset()

+ func (m *RaftTruncatedState) Size() (n int)

+ func (m *RaftTruncatedState) String() string

+ func (m *RaftTruncatedState) Unmarshal(dAtA []byte) error

+ type RangeDescriptor struct

+ EndKey RKey

+ NextReplicaID ReplicaID

+ RangeID RangeID

+ Replicas []ReplicaDescriptor

+ StartKey RKey

+ func (*RangeDescriptor) Descriptor() ([]byte, []int)

+ func (*RangeDescriptor) ProtoMessage()

+ func (m *RangeDescriptor) Marshal() (dAtA []byte, err error)

+ func (m *RangeDescriptor) MarshalTo(dAtA []byte) (int, error)

+ func (m *RangeDescriptor) Reset()

+ func (m *RangeDescriptor) Size() (n int)

+ func (m *RangeDescriptor) Unmarshal(dAtA []byte) error

+ func (r RangeDescriptor) ContainsExclusiveEndKey(key RKey) bool

+ func (r RangeDescriptor) ContainsKey(key RKey) bool

+ func (r RangeDescriptor) ContainsKeyRange(start, end RKey) bool

+ func (r RangeDescriptor) GetReplicaDescriptor(storeID StoreID) (ReplicaDescriptor, bool)

+ func (r RangeDescriptor) GetReplicaDescriptorByID(replicaID ReplicaID) (ReplicaDescriptor, bool)

+ func (r RangeDescriptor) IsInitialized() bool

+ func (r RangeDescriptor) RSpan() RSpan

+ func (r RangeDescriptor) String() string

+ func (r RangeDescriptor) Validate() error

+ func (this *RangeDescriptor) Equal(that interface{}) bool

+ type RangeID int64

+ func (r RangeID) String() string

+ type RangeIDSlice []RangeID

+ func (r RangeIDSlice) Len() int

+ func (r RangeIDSlice) Less(i, j int) bool

+ func (r RangeIDSlice) Swap(i, j int)

+ type RangeInfo struct

+ Desc RangeDescriptor

+ Lease Lease

+ func InsertRangeInfo(ris []RangeInfo, ri RangeInfo) []RangeInfo

+ func (*RangeInfo) Descriptor() ([]byte, []int)

+ func (*RangeInfo) ProtoMessage()

+ func (m *RangeInfo) Marshal() (dAtA []byte, err error)

+ func (m *RangeInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *RangeInfo) Reset()

+ func (m *RangeInfo) Size() (n int)

+ func (m *RangeInfo) String() string

+ func (m *RangeInfo) Unmarshal(dAtA []byte) error

+ type RangeKeyMismatchError struct

+ MismatchedRange *RangeDescriptor

+ RequestEndKey Key

+ RequestStartKey Key

+ SuggestedRange *RangeDescriptor

+ func NewRangeKeyMismatchError(start, end Key, desc *RangeDescriptor) *RangeKeyMismatchError

+ func (*RangeKeyMismatchError) Descriptor() ([]byte, []int)

+ func (*RangeKeyMismatchError) ProtoMessage()

+ func (e *RangeKeyMismatchError) Error() string

+ func (m *RangeKeyMismatchError) Marshal() (dAtA []byte, err error)

+ func (m *RangeKeyMismatchError) MarshalTo(dAtA []byte) (int, error)

+ func (m *RangeKeyMismatchError) Reset()

+ func (m *RangeKeyMismatchError) Size() (n int)

+ func (m *RangeKeyMismatchError) String() string

+ func (m *RangeKeyMismatchError) Unmarshal(dAtA []byte) error

+ type RangeLookupRequest struct

+ MaxRanges int32

+ Reverse bool

+ func (*RangeLookupRequest) Descriptor() ([]byte, []int)

+ func (*RangeLookupRequest) Method() Method

+ func (*RangeLookupRequest) ProtoMessage()

+ func (m *RangeLookupRequest) Marshal() (dAtA []byte, err error)

+ func (m *RangeLookupRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RangeLookupRequest) Reset()

+ func (m *RangeLookupRequest) Size() (n int)

+ func (m *RangeLookupRequest) String() string

+ func (m *RangeLookupRequest) Unmarshal(dAtA []byte) error

+ func (rlr *RangeLookupRequest) ShallowCopy() Request

+ type RangeLookupResponse struct

+ PrefetchedRanges []RangeDescriptor

+ Ranges []RangeDescriptor

+ func (*RangeLookupResponse) Descriptor() ([]byte, []int)

+ func (*RangeLookupResponse) ProtoMessage()

+ func (m *RangeLookupResponse) Marshal() (dAtA []byte, err error)

+ func (m *RangeLookupResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *RangeLookupResponse) Reset()

+ func (m *RangeLookupResponse) Size() (n int)

+ func (m *RangeLookupResponse) String() string

+ func (m *RangeLookupResponse) Unmarshal(dAtA []byte) error

+ type RangeNotFoundError struct

+ RangeID RangeID

+ func NewRangeNotFoundError(rangeID RangeID) *RangeNotFoundError

+ func (*RangeNotFoundError) Descriptor() ([]byte, []int)

+ func (*RangeNotFoundError) ProtoMessage()

+ func (e *RangeNotFoundError) Error() string

+ func (m *RangeNotFoundError) Marshal() (dAtA []byte, err error)

+ func (m *RangeNotFoundError) MarshalTo(dAtA []byte) (int, error)

+ func (m *RangeNotFoundError) Reset()

+ func (m *RangeNotFoundError) Size() (n int)

+ func (m *RangeNotFoundError) String() string

+ func (m *RangeNotFoundError) Unmarshal(dAtA []byte) error

+ type ReadConsistencyType int32

+ const CONSENSUS

+ const CONSISTENT

+ const INCONSISTENT

+ func (ReadConsistencyType) EnumDescriptor() ([]byte, []int)

+ func (x *ReadConsistencyType) UnmarshalJSON(data []byte) error

+ func (x ReadConsistencyType) Enum() *ReadConsistencyType

+ func (x ReadConsistencyType) String() string

+ type ReadWithinUncertaintyIntervalError struct

+ ExistingTimestamp cockroach_util_hlc.Timestamp

+ ReadTimestamp cockroach_util_hlc.Timestamp

+ func NewReadWithinUncertaintyIntervalError(readTS, existingTS hlc.Timestamp) *ReadWithinUncertaintyIntervalError

+ func (*ReadWithinUncertaintyIntervalError) Descriptor() ([]byte, []int)

+ func (*ReadWithinUncertaintyIntervalError) ProtoMessage()

+ func (e *ReadWithinUncertaintyIntervalError) Error() string

+ func (m *ReadWithinUncertaintyIntervalError) Marshal() (dAtA []byte, err error)

+ func (m *ReadWithinUncertaintyIntervalError) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReadWithinUncertaintyIntervalError) Reset()

+ func (m *ReadWithinUncertaintyIntervalError) Size() (n int)

+ func (m *ReadWithinUncertaintyIntervalError) String() string

+ func (m *ReadWithinUncertaintyIntervalError) Unmarshal(dAtA []byte) error

+ type ReplicaChangeType int32

+ const ADD_REPLICA

+ const REMOVE_REPLICA

+ func (ReplicaChangeType) EnumDescriptor() ([]byte, []int)

+ func (x *ReplicaChangeType) UnmarshalJSON(data []byte) error

+ func (x ReplicaChangeType) Enum() *ReplicaChangeType

+ func (x ReplicaChangeType) String() string

+ type ReplicaCorruptionError struct

+ ErrorMsg string

+ Processed bool

+ func (*ReplicaCorruptionError) Descriptor() ([]byte, []int)

+ func (*ReplicaCorruptionError) ProtoMessage()

+ func (e *ReplicaCorruptionError) Error() string

+ func (m *ReplicaCorruptionError) Marshal() (dAtA []byte, err error)

+ func (m *ReplicaCorruptionError) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReplicaCorruptionError) Reset()

+ func (m *ReplicaCorruptionError) Size() (n int)

+ func (m *ReplicaCorruptionError) String() string

+ func (m *ReplicaCorruptionError) Unmarshal(dAtA []byte) error

+ type ReplicaDescriptor struct

+ NodeID NodeID

+ ReplicaID ReplicaID

+ StoreID StoreID

+ func NewPopulatedReplicaDescriptor(r randyMetadata, easy bool) *ReplicaDescriptor

+ func (*ReplicaDescriptor) Descriptor() ([]byte, []int)

+ func (*ReplicaDescriptor) ProtoMessage()

+ func (m *ReplicaDescriptor) Marshal() (dAtA []byte, err error)

+ func (m *ReplicaDescriptor) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReplicaDescriptor) Reset()

+ func (m *ReplicaDescriptor) Size() (n int)

+ func (m *ReplicaDescriptor) Unmarshal(dAtA []byte) error

+ func (r ReplicaDescriptor) String() string

+ func (r ReplicaDescriptor) Validate() error

+ func (this *ReplicaDescriptor) Equal(that interface{}) bool

+ type ReplicaID int32

+ func (r ReplicaID) String() string

+ type ReplicaIdent struct

+ RangeID RangeID

+ Replica ReplicaDescriptor

+ func (*ReplicaIdent) Descriptor() ([]byte, []int)

+ func (*ReplicaIdent) ProtoMessage()

+ func (m *ReplicaIdent) Marshal() (dAtA []byte, err error)

+ func (m *ReplicaIdent) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReplicaIdent) Reset()

+ func (m *ReplicaIdent) Size() (n int)

+ func (m *ReplicaIdent) String() string

+ func (m *ReplicaIdent) Unmarshal(dAtA []byte) error

+ type ReplicaTooOldError struct

+ ReplicaID ReplicaID

+ func NewReplicaTooOldError(replicaID ReplicaID) *ReplicaTooOldError

+ func (*ReplicaTooOldError) Descriptor() ([]byte, []int)

+ func (*ReplicaTooOldError) ProtoMessage()

+ func (e *ReplicaTooOldError) Error() string

+ func (m *ReplicaTooOldError) Marshal() (dAtA []byte, err error)

+ func (m *ReplicaTooOldError) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReplicaTooOldError) Reset()

+ func (m *ReplicaTooOldError) Size() (n int)

+ func (m *ReplicaTooOldError) String() string

+ func (m *ReplicaTooOldError) Unmarshal(dAtA []byte) error

+ type ReplicationTarget struct

+ NodeID NodeID

+ StoreID StoreID

+ func (*ReplicationTarget) Descriptor() ([]byte, []int)

+ func (*ReplicationTarget) ProtoMessage()

+ func (m *ReplicationTarget) Marshal() (dAtA []byte, err error)

+ func (m *ReplicationTarget) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReplicationTarget) Reset()

+ func (m *ReplicationTarget) Size() (n int)

+ func (m *ReplicationTarget) Unmarshal(dAtA []byte) error

+ func (r ReplicationTarget) String() string

+ type Request interface

+ Header func() Span

+ Method func() Method

+ SetHeader func(Span)

+ ShallowCopy func() Request

+ func NewCheckConsistency(key, endKey Key, withDiff bool) Request

+ func NewConditionalPut(key Key, value, expValue Value) Request

+ func NewDelete(key Key) Request

+ func NewDeleteRange(startKey, endKey Key, returnKeys bool) Request

+ func NewGet(key Key) Request

+ func NewIncrement(key Key, increment int64) Request

+ func NewInitPut(key Key, value Value) Request

+ func NewPut(key Key, value Value) Request

+ func NewPutInline(key Key, value Value) Request

+ func NewReverseScan(key, endKey Key) Request

+ func NewScan(key, endKey Key) Request

+ type RequestLeaseRequest struct

+ Lease Lease

+ PrevLease *Lease

+ func (*RequestLeaseRequest) Descriptor() ([]byte, []int)

+ func (*RequestLeaseRequest) Method() Method

+ func (*RequestLeaseRequest) ProtoMessage()

+ func (m *RequestLeaseRequest) Marshal() (dAtA []byte, err error)

+ func (m *RequestLeaseRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RequestLeaseRequest) Reset()

+ func (m *RequestLeaseRequest) Size() (n int)

+ func (m *RequestLeaseRequest) String() string

+ func (m *RequestLeaseRequest) Unmarshal(dAtA []byte) error

+ func (rlr *RequestLeaseRequest) ShallowCopy() Request

+ type RequestLeaseResponse struct

+ func (*RequestLeaseResponse) Descriptor() ([]byte, []int)

+ func (*RequestLeaseResponse) ProtoMessage()

+ func (m *RequestLeaseResponse) Marshal() (dAtA []byte, err error)

+ func (m *RequestLeaseResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *RequestLeaseResponse) Reset()

+ func (m *RequestLeaseResponse) Size() (n int)

+ func (m *RequestLeaseResponse) String() string

+ func (m *RequestLeaseResponse) Unmarshal(dAtA []byte) error

+ type RequestUnion struct

+ AdminChangeReplicas *AdminChangeReplicasRequest

+ AdminMerge *AdminMergeRequest

+ AdminScatter *AdminScatterRequest

+ AdminSplit *AdminSplitRequest

+ AdminTransferLease *AdminTransferLeaseRequest

+ BeginTransaction *BeginTransactionRequest

+ CheckConsistency *CheckConsistencyRequest

+ ComputeChecksum *ComputeChecksumRequest

+ ConditionalPut *ConditionalPutRequest

+ Delete *DeleteRequest

+ DeleteRange *DeleteRangeRequest

+ DeprecatedVerifyChecksum *DeprecatedVerifyChecksumRequest

+ EndTransaction *EndTransactionRequest

+ Export *ExportRequest

+ Gc *GCRequest

+ Get *GetRequest

+ HeartbeatTxn *HeartbeatTxnRequest

+ Import *ImportRequest

+ Increment *IncrementRequest

+ InitPut *InitPutRequest

+ LeaseInfo *LeaseInfoRequest

+ Merge *MergeRequest

+ Noop *NoopRequest

+ PushTxn *PushTxnRequest

+ Put *PutRequest

+ QueryTxn *QueryTxnRequest

+ RangeLookup *RangeLookupRequest

+ RequestLease *RequestLeaseRequest

+ ResolveIntent *ResolveIntentRequest

+ ResolveIntentRange *ResolveIntentRangeRequest

+ ReverseScan *ReverseScanRequest

+ Scan *ScanRequest

+ TransferLease *TransferLeaseRequest

+ TruncateLog *TruncateLogRequest

+ WriteBatch *WriteBatchRequest

+ func (*RequestUnion) Descriptor() ([]byte, []int)

+ func (*RequestUnion) ProtoMessage()

+ func (m *RequestUnion) Marshal() (dAtA []byte, err error)

+ func (m *RequestUnion) MarshalTo(dAtA []byte) (int, error)

+ func (m *RequestUnion) Reset()

+ func (m *RequestUnion) Size() (n int)

+ func (m *RequestUnion) String() string

+ func (m *RequestUnion) Unmarshal(dAtA []byte) error

+ func (ru *RequestUnion) MustSetInner(args Request)

+ func (ru RequestUnion) GetInner() Request

+ func (this *RequestUnion) GetValue() interface{}

+ func (this *RequestUnion) SetValue(value interface{}) bool

+ type ResolveIntentRangeRequest struct

+ IntentTxn cockroach_storage_engine_enginepb.TxnMeta

+ Poison bool

+ Status TransactionStatus

+ func (*ResolveIntentRangeRequest) Descriptor() ([]byte, []int)

+ func (*ResolveIntentRangeRequest) Method() Method

+ func (*ResolveIntentRangeRequest) ProtoMessage()

+ func (m *ResolveIntentRangeRequest) Marshal() (dAtA []byte, err error)

+ func (m *ResolveIntentRangeRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ResolveIntentRangeRequest) Reset()

+ func (m *ResolveIntentRangeRequest) Size() (n int)

+ func (m *ResolveIntentRangeRequest) String() string

+ func (m *ResolveIntentRangeRequest) Unmarshal(dAtA []byte) error

+ func (rirr *ResolveIntentRangeRequest) ShallowCopy() Request

+ type ResolveIntentRangeResponse struct

+ func (*ResolveIntentRangeResponse) Descriptor() ([]byte, []int)

+ func (*ResolveIntentRangeResponse) ProtoMessage()

+ func (m *ResolveIntentRangeResponse) Marshal() (dAtA []byte, err error)

+ func (m *ResolveIntentRangeResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ResolveIntentRangeResponse) Reset()

+ func (m *ResolveIntentRangeResponse) Size() (n int)

+ func (m *ResolveIntentRangeResponse) String() string

+ func (m *ResolveIntentRangeResponse) Unmarshal(dAtA []byte) error

+ type ResolveIntentRequest struct

+ IntentTxn cockroach_storage_engine_enginepb.TxnMeta

+ Poison bool

+ Status TransactionStatus

+ func (*ResolveIntentRequest) Descriptor() ([]byte, []int)

+ func (*ResolveIntentRequest) Method() Method

+ func (*ResolveIntentRequest) ProtoMessage()

+ func (m *ResolveIntentRequest) Marshal() (dAtA []byte, err error)

+ func (m *ResolveIntentRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ResolveIntentRequest) Reset()

+ func (m *ResolveIntentRequest) Size() (n int)

+ func (m *ResolveIntentRequest) String() string

+ func (m *ResolveIntentRequest) Unmarshal(dAtA []byte) error

+ func (rir *ResolveIntentRequest) ShallowCopy() Request

+ type ResolveIntentResponse struct

+ func (*ResolveIntentResponse) Descriptor() ([]byte, []int)

+ func (*ResolveIntentResponse) ProtoMessage()

+ func (m *ResolveIntentResponse) Marshal() (dAtA []byte, err error)

+ func (m *ResolveIntentResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ResolveIntentResponse) Reset()

+ func (m *ResolveIntentResponse) Size() (n int)

+ func (m *ResolveIntentResponse) String() string

+ func (m *ResolveIntentResponse) Unmarshal(dAtA []byte) error

+ type Response interface

+ Header func() ResponseHeader

+ SetHeader func(ResponseHeader)

+ Verify func(req Request) error

+ type ResponseHeader struct

+ NumKeys int64

+ RangeInfos []RangeInfo

+ ResumeSpan *Span

+ Txn *Transaction

+ func (*ResponseHeader) Descriptor() ([]byte, []int)

+ func (*ResponseHeader) ProtoMessage()

+ func (m *ResponseHeader) Marshal() (dAtA []byte, err error)

+ func (m *ResponseHeader) MarshalTo(dAtA []byte) (int, error)

+ func (m *ResponseHeader) Reset()

+ func (m *ResponseHeader) Size() (n int)

+ func (m *ResponseHeader) String() string

+ func (m *ResponseHeader) Unmarshal(dAtA []byte) error

+ func (rh *ResponseHeader) SetHeader(other ResponseHeader)

+ func (rh *ResponseHeader) Verify(req Request) error

+ func (rh ResponseHeader) Header() ResponseHeader

+ type ResponseUnion struct

+ AdminChangeReplicas *AdminChangeReplicasResponse

+ AdminMerge *AdminMergeResponse

+ AdminScatter *AdminScatterResponse

+ AdminSplit *AdminSplitResponse

+ AdminTransferLease *AdminTransferLeaseResponse

+ BeginTransaction *BeginTransactionResponse

+ CheckConsistency *CheckConsistencyResponse

+ ComputeChecksum *ComputeChecksumResponse

+ ConditionalPut *ConditionalPutResponse

+ Delete *DeleteResponse

+ DeleteRange *DeleteRangeResponse

+ DeprecatedVerifyChecksum *DeprecatedVerifyChecksumResponse

+ EndTransaction *EndTransactionResponse

+ Export *ExportResponse

+ Gc *GCResponse

+ Get *GetResponse

+ HeartbeatTxn *HeartbeatTxnResponse

+ Import *ImportResponse

+ Increment *IncrementResponse

+ InitPut *InitPutResponse

+ LeaseInfo *LeaseInfoResponse

+ Merge *MergeResponse

+ Noop *NoopResponse

+ PushTxn *PushTxnResponse

+ Put *PutResponse

+ QueryTxn *QueryTxnResponse

+ RangeLookup *RangeLookupResponse

+ RequestLease *RequestLeaseResponse

+ ResolveIntent *ResolveIntentResponse

+ ResolveIntentRange *ResolveIntentRangeResponse

+ ReverseScan *ReverseScanResponse

+ Scan *ScanResponse

+ TruncateLog *TruncateLogResponse

+ WriteBatch *WriteBatchResponse

+ func (*ResponseUnion) Descriptor() ([]byte, []int)

+ func (*ResponseUnion) ProtoMessage()

+ func (m *ResponseUnion) Marshal() (dAtA []byte, err error)

+ func (m *ResponseUnion) MarshalTo(dAtA []byte) (int, error)

+ func (m *ResponseUnion) Reset()

+ func (m *ResponseUnion) Size() (n int)

+ func (m *ResponseUnion) String() string

+ func (m *ResponseUnion) Unmarshal(dAtA []byte) error

+ func (ru *ResponseUnion) MustSetInner(reply Response)

+ func (ru ResponseUnion) GetInner() Response

+ func (this *ResponseUnion) GetValue() interface{}

+ func (this *ResponseUnion) SetValue(value interface{}) bool

+ type ReverseScanRequest struct

+ func (*ReverseScanRequest) Descriptor() ([]byte, []int)

+ func (*ReverseScanRequest) Method() Method

+ func (*ReverseScanRequest) ProtoMessage()

+ func (m *ReverseScanRequest) Marshal() (dAtA []byte, err error)

+ func (m *ReverseScanRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReverseScanRequest) Reset()

+ func (m *ReverseScanRequest) Size() (n int)

+ func (m *ReverseScanRequest) String() string

+ func (m *ReverseScanRequest) Unmarshal(dAtA []byte) error

+ func (rsr *ReverseScanRequest) ShallowCopy() Request

+ type ReverseScanResponse struct

+ Rows []KeyValue

+ func (*ReverseScanResponse) Descriptor() ([]byte, []int)

+ func (*ReverseScanResponse) ProtoMessage()

+ func (m *ReverseScanResponse) Marshal() (dAtA []byte, err error)

+ func (m *ReverseScanResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReverseScanResponse) Reset()

+ func (m *ReverseScanResponse) Size() (n int)

+ func (m *ReverseScanResponse) String() string

+ func (m *ReverseScanResponse) Unmarshal(dAtA []byte) error

+ func (sr *ReverseScanResponse) Verify(req Request) error

+ type ScanRequest struct

+ func (*ScanRequest) Descriptor() ([]byte, []int)

+ func (*ScanRequest) Method() Method

+ func (*ScanRequest) ProtoMessage()

+ func (m *ScanRequest) Marshal() (dAtA []byte, err error)

+ func (m *ScanRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ScanRequest) Reset()

+ func (m *ScanRequest) Size() (n int)

+ func (m *ScanRequest) String() string

+ func (m *ScanRequest) Unmarshal(dAtA []byte) error

+ func (sr *ScanRequest) ShallowCopy() Request

+ type ScanResponse struct

+ Rows []KeyValue

+ func (*ScanResponse) Descriptor() ([]byte, []int)

+ func (*ScanResponse) ProtoMessage()

+ func (m *ScanResponse) Marshal() (dAtA []byte, err error)

+ func (m *ScanResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ScanResponse) Reset()

+ func (m *ScanResponse) Size() (n int)

+ func (m *ScanResponse) String() string

+ func (m *ScanResponse) Unmarshal(dAtA []byte) error

+ func (sr *ScanResponse) Verify(req Request) error

+ type SendError struct

+ Message string

+ func NewSendError(msg string) *SendError

+ func (*SendError) Descriptor() ([]byte, []int)

+ func (*SendError) ProtoMessage()

+ func (m *SendError) Marshal() (dAtA []byte, err error)

+ func (m *SendError) MarshalTo(dAtA []byte) (int, error)

+ func (m *SendError) Reset()

+ func (m *SendError) Size() (n int)

+ func (m *SendError) String() string

+ func (m *SendError) Unmarshal(dAtA []byte) error

+ func (s SendError) Error() string

+ type Span struct

+ EndKey Key

+ Key Key

+ func MergeSpans(spans []Span) ([]Span, bool)

+ func NewPopulatedSpan(r randyData, easy bool) *Span

+ func (*Span) Descriptor() ([]byte, []int)

+ func (*Span) ProtoMessage()

+ func (m *Span) Marshal() (dAtA []byte, err error)

+ func (m *Span) MarshalTo(dAtA []byte) (int, error)

+ func (m *Span) Reset()

+ func (m *Span) Size() (n int)

+ func (m *Span) Unmarshal(dAtA []byte) error

+ func (rh *Span) SetHeader(other Span)

+ func (rh Span) Header() Span

+ func (s Span) AsRange() interval.Range

+ func (s Span) Contains(o Span) bool

+ func (s Span) Equal(o Span) bool

+ func (s Span) Overlaps(o Span) bool

+ func (s Span) String() string

+ type Spans []Span

+ func (a Spans) Len() int

+ func (a Spans) Less(i, j int) bool

+ func (a Spans) Swap(i, j int)

+ type SplitTrigger struct

+ LeftDesc RangeDescriptor

+ RightDesc RangeDescriptor

+ func (*SplitTrigger) Descriptor() ([]byte, []int)

+ func (*SplitTrigger) ProtoMessage()

+ func (m *SplitTrigger) Marshal() (dAtA []byte, err error)

+ func (m *SplitTrigger) MarshalTo(dAtA []byte) (int, error)

+ func (m *SplitTrigger) Reset()

+ func (m *SplitTrigger) Size() (n int)

+ func (m *SplitTrigger) String() string

+ func (m *SplitTrigger) Unmarshal(dAtA []byte) error

+ type StatementStatistics struct

+ Count int64

+ FirstAttemptCount int64

+ LastErr string

+ MaxRetries int64

+ NumRows NumericStat

+ OverheadLat NumericStat

+ ParseLat NumericStat

+ PlanLat NumericStat

+ RunLat NumericStat

+ ServiceLat NumericStat

+ func (*StatementStatistics) Descriptor() ([]byte, []int)

+ func (*StatementStatistics) ProtoMessage()

+ func (m *StatementStatistics) Marshal() (dAtA []byte, err error)

+ func (m *StatementStatistics) MarshalTo(dAtA []byte) (int, error)

+ func (m *StatementStatistics) Reset()

+ func (m *StatementStatistics) Size() (n int)

+ func (m *StatementStatistics) String() string

+ func (m *StatementStatistics) Unmarshal(dAtA []byte) error

+ type StoreCapacity struct

+ Available int64

+ Capacity int64

+ LeaseCount int32

+ RangeCount int32

+ func (*StoreCapacity) Descriptor() ([]byte, []int)

+ func (*StoreCapacity) ProtoMessage()

+ func (m *StoreCapacity) Marshal() (dAtA []byte, err error)

+ func (m *StoreCapacity) MarshalTo(dAtA []byte) (int, error)

+ func (m *StoreCapacity) Reset()

+ func (m *StoreCapacity) Size() (n int)

+ func (m *StoreCapacity) String() string

+ func (m *StoreCapacity) Unmarshal(dAtA []byte) error

+ func (sc StoreCapacity) FractionUsed() float64

+ type StoreDeadReplicas struct

+ Replicas []ReplicaIdent

+ StoreID StoreID

+ func (*StoreDeadReplicas) Descriptor() ([]byte, []int)

+ func (*StoreDeadReplicas) ProtoMessage()

+ func (m *StoreDeadReplicas) Marshal() (dAtA []byte, err error)

+ func (m *StoreDeadReplicas) MarshalTo(dAtA []byte) (int, error)

+ func (m *StoreDeadReplicas) Reset()

+ func (m *StoreDeadReplicas) Size() (n int)

+ func (m *StoreDeadReplicas) String() string

+ func (m *StoreDeadReplicas) Unmarshal(dAtA []byte) error

+ type StoreDescriptor struct

+ Attrs Attributes

+ Capacity StoreCapacity

+ Node NodeDescriptor

+ StoreID StoreID

+ func (*StoreDescriptor) Descriptor() ([]byte, []int)

+ func (*StoreDescriptor) ProtoMessage()

+ func (m *StoreDescriptor) Marshal() (dAtA []byte, err error)

+ func (m *StoreDescriptor) MarshalTo(dAtA []byte) (int, error)

+ func (m *StoreDescriptor) Reset()

+ func (m *StoreDescriptor) Size() (n int)

+ func (m *StoreDescriptor) String() string

+ func (m *StoreDescriptor) Unmarshal(dAtA []byte) error

+ func (s StoreDescriptor) CombinedAttrs() *Attributes

+ type StoreID int32

+ func (n StoreID) String() string

+ type StoreIDSlice []StoreID

+ func (s StoreIDSlice) Len() int

+ func (s StoreIDSlice) Less(i, j int) bool

+ func (s StoreIDSlice) Swap(i, j int)

+ type StoreIdent struct

+ ClusterID github_com_cockroachdb_cockroach_pkg_util_uuid.UUID

+ NodeID NodeID

+ StoreID StoreID

+ func (*StoreIdent) Descriptor() ([]byte, []int)

+ func (*StoreIdent) ProtoMessage()

+ func (m *StoreIdent) Marshal() (dAtA []byte, err error)

+ func (m *StoreIdent) MarshalTo(dAtA []byte) (int, error)

+ func (m *StoreIdent) Reset()

+ func (m *StoreIdent) Size() (n int)

+ func (m *StoreIdent) String() string

+ func (m *StoreIdent) Unmarshal(dAtA []byte) error

+ type StoreNotFoundError struct

+ StoreID StoreID

+ func NewStoreNotFoundError(storeID StoreID) *StoreNotFoundError

+ func (*StoreNotFoundError) Descriptor() ([]byte, []int)

+ func (*StoreNotFoundError) ProtoMessage()

+ func (e *StoreNotFoundError) Error() string

+ func (m *StoreNotFoundError) Marshal() (dAtA []byte, err error)

+ func (m *StoreNotFoundError) MarshalTo(dAtA []byte) (int, error)

+ func (m *StoreNotFoundError) Reset()

+ func (m *StoreNotFoundError) Size() (n int)

+ func (m *StoreNotFoundError) String() string

+ func (m *StoreNotFoundError) Unmarshal(dAtA []byte) error

+ type Tier struct

+ Key string

+ Value string

+ func (*Tier) Descriptor() ([]byte, []int)

+ func (*Tier) ProtoMessage()

+ func (m *Tier) Marshal() (dAtA []byte, err error)

+ func (m *Tier) MarshalTo(dAtA []byte) (int, error)

+ func (m *Tier) Reset()

+ func (m *Tier) Size() (n int)

+ func (m *Tier) Unmarshal(dAtA []byte) error

+ func (t *Tier) FromString(tier string) error

+ func (t Tier) String() string

+ type Transaction struct

+ Intents []Span

+ LastHeartbeat cockroach_util_hlc.Timestamp

+ MaxTimestamp cockroach_util_hlc.Timestamp

+ Name string

+ ObservedTimestamps []ObservedTimestamp

+ OrigTimestamp cockroach_util_hlc.Timestamp

+ RetryOnPush bool

+ Status TransactionStatus

+ WriteTooOld bool

+ Writing bool

+ func NewPopulatedTransaction(r randyData, easy bool) *Transaction

+ func NewTransaction(name string, baseKey Key, userPriority UserPriority, ...) *Transaction

+ func PrepareTransactionForRetry(ctx context.Context, pErr *Error, pri UserPriority) Transaction

+ func (*Transaction) Descriptor() ([]byte, []int)

+ func (*Transaction) ProtoMessage()

+ func (m *Transaction) Marshal() (dAtA []byte, err error)

+ func (m *Transaction) MarshalTo(dAtA []byte) (int, error)

+ func (m *Transaction) Reset()

+ func (m *Transaction) Size() (n int)

+ func (m *Transaction) Unmarshal(dAtA []byte) error

+ func (t *Transaction) Equal(s *Transaction) bool

+ func (t *Transaction) IsInitialized() bool

+ func (t *Transaction) ResetObservedTimestamps()

+ func (t *Transaction) Restart(userPriority UserPriority, upgradePriority int32, timestamp hlc.Timestamp)

+ func (t *Transaction) Update(o *Transaction)

+ func (t *Transaction) UpdateObservedTimestamp(nodeID NodeID, maxTS hlc.Timestamp)

+ func (t *Transaction) UpgradePriority(minPriority int32)

+ func (t Transaction) Clone() Transaction

+ func (t Transaction) GetObservedTimestamp(nodeID NodeID) (hlc.Timestamp, bool)

+ func (t Transaction) LastActive() hlc.Timestamp

+ func (t Transaction) String() string

+ type TransactionAbortedError struct

+ func NewTransactionAbortedError() *TransactionAbortedError

+ func (*TransactionAbortedError) Descriptor() ([]byte, []int)

+ func (*TransactionAbortedError) ProtoMessage()

+ func (e *TransactionAbortedError) Error() string

+ func (m *TransactionAbortedError) Marshal() (dAtA []byte, err error)

+ func (m *TransactionAbortedError) MarshalTo(dAtA []byte) (int, error)

+ func (m *TransactionAbortedError) Reset()

+ func (m *TransactionAbortedError) Size() (n int)

+ func (m *TransactionAbortedError) String() string

+ func (m *TransactionAbortedError) Unmarshal(dAtA []byte) error

+ type TransactionPushError struct

+ PusheeTxn Transaction

+ func NewTransactionPushError(pusheeTxn Transaction) *TransactionPushError

+ func (*TransactionPushError) Descriptor() ([]byte, []int)

+ func (*TransactionPushError) ProtoMessage()

+ func (e *TransactionPushError) Error() string

+ func (m *TransactionPushError) Marshal() (dAtA []byte, err error)

+ func (m *TransactionPushError) MarshalTo(dAtA []byte) (int, error)

+ func (m *TransactionPushError) Reset()

+ func (m *TransactionPushError) Size() (n int)

+ func (m *TransactionPushError) String() string

+ func (m *TransactionPushError) Unmarshal(dAtA []byte) error

+ type TransactionReplayError struct

+ func NewTransactionReplayError() *TransactionReplayError

+ func (*TransactionReplayError) Descriptor() ([]byte, []int)

+ func (*TransactionReplayError) ProtoMessage()

+ func (e *TransactionReplayError) Error() string

+ func (m *TransactionReplayError) Marshal() (dAtA []byte, err error)

+ func (m *TransactionReplayError) MarshalTo(dAtA []byte) (int, error)

+ func (m *TransactionReplayError) Reset()

+ func (m *TransactionReplayError) Size() (n int)

+ func (m *TransactionReplayError) String() string

+ func (m *TransactionReplayError) Unmarshal(dAtA []byte) error

+ type TransactionRestart int32

+ const TransactionRestart_BACKOFF

+ const TransactionRestart_IMMEDIATE

+ const TransactionRestart_NONE

+ func (TransactionRestart) EnumDescriptor() ([]byte, []int)

+ func (x *TransactionRestart) UnmarshalJSON(data []byte) error

+ func (x TransactionRestart) Enum() *TransactionRestart

+ func (x TransactionRestart) String() string

+ type TransactionRetryError struct

+ Reason TransactionRetryReason

+ func NewTransactionRetryError(reason TransactionRetryReason) *TransactionRetryError

+ func (*TransactionRetryError) Descriptor() ([]byte, []int)

+ func (*TransactionRetryError) ProtoMessage()

+ func (e *TransactionRetryError) Error() string

+ func (m *TransactionRetryError) Marshal() (dAtA []byte, err error)

+ func (m *TransactionRetryError) MarshalTo(dAtA []byte) (int, error)

+ func (m *TransactionRetryError) Reset()

+ func (m *TransactionRetryError) Size() (n int)

+ func (m *TransactionRetryError) String() string

+ func (m *TransactionRetryError) Unmarshal(dAtA []byte) error

+ type TransactionRetryReason int32

+ const RETRY_DELETE_RANGE

+ const RETRY_POSSIBLE_REPLAY

+ const RETRY_REASON_UNKNOWN

+ const RETRY_SERIALIZABLE

+ const RETRY_WRITE_TOO_OLD

+ func (TransactionRetryReason) EnumDescriptor() ([]byte, []int)

+ func (x *TransactionRetryReason) UnmarshalJSON(data []byte) error

+ func (x TransactionRetryReason) Enum() *TransactionRetryReason

+ func (x TransactionRetryReason) String() string

+ type TransactionStatus int32

+ const ABORTED

+ const COMMITTED

+ const PENDING

+ func (TransactionStatus) EnumDescriptor() ([]byte, []int)

+ func (x *TransactionStatus) UnmarshalJSON(data []byte) error

+ func (x TransactionStatus) Enum() *TransactionStatus

+ func (x TransactionStatus) String() string

+ type TransactionStatusError struct

+ Msg string

+ func NewTransactionStatusError(msg string) *TransactionStatusError

+ func (*TransactionStatusError) Descriptor() ([]byte, []int)

+ func (*TransactionStatusError) ProtoMessage()

+ func (e *TransactionStatusError) Error() string

+ func (m *TransactionStatusError) Marshal() (dAtA []byte, err error)

+ func (m *TransactionStatusError) MarshalTo(dAtA []byte) (int, error)

+ func (m *TransactionStatusError) Reset()

+ func (m *TransactionStatusError) Size() (n int)

+ func (m *TransactionStatusError) String() string

+ func (m *TransactionStatusError) Unmarshal(dAtA []byte) error

+ type TransferLeaseRequest struct

+ Lease Lease

+ PrevLease *Lease

+ func (*TransferLeaseRequest) Descriptor() ([]byte, []int)

+ func (*TransferLeaseRequest) Method() Method

+ func (*TransferLeaseRequest) ProtoMessage()

+ func (m *TransferLeaseRequest) Marshal() (dAtA []byte, err error)

+ func (m *TransferLeaseRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *TransferLeaseRequest) Reset()

+ func (m *TransferLeaseRequest) Size() (n int)

+ func (m *TransferLeaseRequest) String() string

+ func (m *TransferLeaseRequest) Unmarshal(dAtA []byte) error

+ func (tlr *TransferLeaseRequest) ShallowCopy() Request

+ type TruncateLogRequest struct

+ Index uint64

+ RangeID RangeID

+ func (*TruncateLogRequest) Descriptor() ([]byte, []int)

+ func (*TruncateLogRequest) Method() Method

+ func (*TruncateLogRequest) ProtoMessage()

+ func (m *TruncateLogRequest) Marshal() (dAtA []byte, err error)

+ func (m *TruncateLogRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *TruncateLogRequest) Reset()

+ func (m *TruncateLogRequest) Size() (n int)

+ func (m *TruncateLogRequest) String() string

+ func (m *TruncateLogRequest) Unmarshal(dAtA []byte) error

+ func (tlr *TruncateLogRequest) ShallowCopy() Request

+ type TruncateLogResponse struct

+ func (*TruncateLogResponse) Descriptor() ([]byte, []int)

+ func (*TruncateLogResponse) ProtoMessage()

+ func (m *TruncateLogResponse) Marshal() (dAtA []byte, err error)

+ func (m *TruncateLogResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *TruncateLogResponse) Reset()

+ func (m *TruncateLogResponse) Size() (n int)

+ func (m *TruncateLogResponse) String() string

+ func (m *TruncateLogResponse) Unmarshal(dAtA []byte) error

+ type UnhandledRetryableError struct

+ PErr Error

+ func (*UnhandledRetryableError) Descriptor() ([]byte, []int)

+ func (*UnhandledRetryableError) ProtoMessage()

+ func (e *UnhandledRetryableError) Error() string

+ func (m *UnhandledRetryableError) Marshal() (dAtA []byte, err error)

+ func (m *UnhandledRetryableError) MarshalTo(dAtA []byte) (int, error)

+ func (m *UnhandledRetryableError) Reset()

+ func (m *UnhandledRetryableError) Size() (n int)

+ func (m *UnhandledRetryableError) String() string

+ func (m *UnhandledRetryableError) Unmarshal(dAtA []byte) error

+ type UserPriority float64

+ func (up UserPriority) String() string

+ type Value struct

+ RawBytes []byte

+ Timestamp cockroach_util_hlc.Timestamp

+ func MakeValueFromBytes(bs []byte) Value

+ func MakeValueFromBytesAndTimestamp(bs []byte, t hlc.Timestamp) Value

+ func MakeValueFromString(s string) Value

+ func (*Value) Descriptor() ([]byte, []int)

+ func (*Value) ProtoMessage()

+ func (m *Value) Marshal() (dAtA []byte, err error)

+ func (m *Value) MarshalTo(dAtA []byte) (int, error)

+ func (m *Value) Reset()

+ func (m *Value) Size() (n int)

+ func (m *Value) String() string

+ func (m *Value) Unmarshal(dAtA []byte) error

+ func (v *Value) ClearChecksum()

+ func (v *Value) InitChecksum(key []byte)

+ func (v *Value) SetBool(b bool)

+ func (v *Value) SetBytes(b []byte)

+ func (v *Value) SetDecimal(dec *apd.Decimal) error

+ func (v *Value) SetDuration(t duration.Duration) error

+ func (v *Value) SetFloat(f float64)

+ func (v *Value) SetInt(i int64)

+ func (v *Value) SetProto(msg proto.Message) error

+ func (v *Value) SetString(s string)

+ func (v *Value) SetTime(t time.Time)

+ func (v *Value) SetTuple(data []byte)

+ func (v *Value) ShallowClone() *Value

+ func (v Value) GetBool() (bool, error)

+ func (v Value) GetBytes() ([]byte, error)

+ func (v Value) GetDecimal() (*apd.Decimal, error)

+ func (v Value) GetDuration() (duration.Duration, error)

+ func (v Value) GetFloat() (float64, error)

+ func (v Value) GetInt() (int64, error)

+ func (v Value) GetProto(msg proto.Message) error

+ func (v Value) GetTag() ValueType

+ func (v Value) GetTime() (time.Time, error)

+ func (v Value) GetTimeseries() (InternalTimeSeriesData, error)

+ func (v Value) GetTuple() ([]byte, error)

+ func (v Value) PrettyPrint() string

+ func (v Value) Verify(key []byte) error

+ type ValueType int32

+ const ValueType_BYTES

+ const ValueType_DECIMAL

+ const ValueType_DELIMITED_BYTES

+ const ValueType_DELIMITED_DECIMAL

+ const ValueType_DURATION

+ const ValueType_FLOAT

+ const ValueType_INT

+ const ValueType_NULL

+ const ValueType_TIME

+ const ValueType_TIMESERIES

+ const ValueType_TUPLE

+ const ValueType_UNKNOWN

+ func (ValueType) EnumDescriptor() ([]byte, []int)

+ func (x *ValueType) UnmarshalJSON(data []byte) error

+ func (x ValueType) Enum() *ValueType

+ func (x ValueType) String() string

+ type WriteBatchRequest struct

+ Data []byte

+ DataSpan Span

+ func (*WriteBatchRequest) Descriptor() ([]byte, []int)

+ func (*WriteBatchRequest) Method() Method

+ func (*WriteBatchRequest) ProtoMessage()

+ func (m *WriteBatchRequest) Marshal() (dAtA []byte, err error)

+ func (m *WriteBatchRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *WriteBatchRequest) Reset()

+ func (m *WriteBatchRequest) Size() (n int)

+ func (m *WriteBatchRequest) String() string

+ func (m *WriteBatchRequest) Unmarshal(dAtA []byte) error

+ func (r *WriteBatchRequest) ShallowCopy() Request

+ type WriteBatchResponse struct

+ func (*WriteBatchResponse) Descriptor() ([]byte, []int)

+ func (*WriteBatchResponse) ProtoMessage()

+ func (m *WriteBatchResponse) Marshal() (dAtA []byte, err error)

+ func (m *WriteBatchResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *WriteBatchResponse) Reset()

+ func (m *WriteBatchResponse) Size() (n int)

+ func (m *WriteBatchResponse) String() string

+ func (m *WriteBatchResponse) Unmarshal(dAtA []byte) error

+ type WriteIntentError struct

+ Intents []Intent

+ func (*WriteIntentError) Descriptor() ([]byte, []int)

+ func (*WriteIntentError) ProtoMessage()

+ func (e *WriteIntentError) Error() string

+ func (m *WriteIntentError) Marshal() (dAtA []byte, err error)

+ func (m *WriteIntentError) MarshalTo(dAtA []byte) (int, error)

+ func (m *WriteIntentError) Reset()

+ func (m *WriteIntentError) Size() (n int)

+ func (m *WriteIntentError) String() string

+ func (m *WriteIntentError) Unmarshal(dAtA []byte) error

+ type WriteTooOldError struct

+ ActualTimestamp cockroach_util_hlc.Timestamp

+ Timestamp cockroach_util_hlc.Timestamp

+ func (*WriteTooOldError) Descriptor() ([]byte, []int)

+ func (*WriteTooOldError) ProtoMessage()

+ func (e *WriteTooOldError) Error() string

+ func (m *WriteTooOldError) Marshal() (dAtA []byte, err error)

+ func (m *WriteTooOldError) MarshalTo(dAtA []byte) (int, error)

+ func (m *WriteTooOldError) Reset()

+ func (m *WriteTooOldError) Size() (n int)

+ func (m *WriteTooOldError) String() string

+ func (m *WriteTooOldError) Unmarshal(dAtA []byte) error

Incompatible versions in this module

v19.2.9+incompatible

Jun 29, 2020

v19.2.8+incompatible

Jun 22, 2020

v19.2.7+incompatible

May 13, 2020

v19.2.6+incompatible

Apr 3, 2020

v19.2.5+incompatible

Mar 16, 2020

v19.2.5-alpha-one-off+incompatible

Feb 11, 2020

v19.2.4+incompatible

Feb 6, 2020

v19.2.4-gctwooff+incompatible

Feb 27, 2020

v19.2.4-gconeoff+incompatible

Feb 26, 2020

v19.2.3+incompatible

Jan 29, 2020

v19.2.2+incompatible

Dec 10, 2019

v19.2.1+incompatible

Nov 18, 2019

v19.2.1-rc.1+incompatible

Nov 18, 2019

v19.2.0+incompatible

Nov 8, 2019

v19.2.0-rc.4+incompatible

Nov 5, 2019

v19.2.0-rc.3+incompatible

Nov 1, 2019

v19.2.0-rc.2+incompatible

Oct 23, 2019

v19.2.0-rc.1+incompatible

Oct 14, 2019

v19.2.0-beta.20191014+incompatible

Oct 7, 2019

v19.2.0-beta.20190930+incompatible

Sep 27, 2019

v19.2.0-alpha.20190805+incompatible

Aug 1, 2019

v19.2.0-alpha.20190701+incompatible

Jul 2, 2019

v19.2.0-alpha.20190606+incompatible

Jun 4, 2019

v19.1.11+incompatible

Jun 29, 2020

v19.1.10+incompatible

Jun 23, 2020

v19.1.9+incompatible

May 2, 2020

v19.1.8+incompatible

Feb 6, 2020

v19.1.7+incompatible

Jan 18, 2020

v19.1.6+incompatible

Dec 10, 2019

v19.1.5+incompatible

Sep 22, 2019

v19.1.4+incompatible

Aug 2, 2019

v19.1.3+incompatible

Jul 4, 2019

v19.1.2+incompatible

Jun 7, 2019

v19.1.1+incompatible

May 15, 2019

v19.1.0+incompatible

Apr 24, 2019

v19.1.0-rc.4+incompatible

Apr 24, 2019

v19.1.0-rc.3+incompatible

Apr 11, 2019

v19.1.0-rc.2+incompatible

Apr 4, 2019

v19.1.0-rc.1+incompatible

Mar 31, 2019

v19.1.0-beta.20190318+incompatible

Mar 12, 2019

v19.1.0-beta.20190304+incompatible

Feb 27, 2019

v19.1.0-beta.20190225+incompatible

Feb 19, 2019

v2.1.0-alpha.20180507+incompatible

Apr 30, 2018

v2.1.0-alpha.20180416+incompatible

Apr 10, 2018

v2.0.7+incompatible

Nov 28, 2018

v2.0.6+incompatible

Oct 1, 2018

v2.0.6-rc.1+incompatible

Sep 24, 2018

v2.0.5+incompatible

Aug 6, 2018

v2.0.4+incompatible

Jul 10, 2018

v2.0.3+incompatible

Jun 13, 2018

v2.0.2+incompatible

May 14, 2018

v2.0.1+incompatible

Apr 16, 2018

v2.0.0+incompatible

Apr 3, 2018

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