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.2-testing.20170530

May 30, 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

v20.1.0-rc.2+incompatible

Apr 17, 2020

v20.1.0-rc.1+incompatible

Apr 9, 2020

v20.1.0-beta.4+incompatible

Mar 23, 2020

v20.1.0-beta.3+incompatible

Mar 23, 2020

v20.1.0-beta.2+incompatible

Feb 22, 2020

v20.1.0-beta.1+incompatible

Feb 10, 2020

v20.1.0-alpha20191216+incompatible

Dec 13, 2019

v20.1.0-alpha.20200123+incompatible

Jan 23, 2020

v20.1.0-alpha.20191118+incompatible

Nov 10, 2019

v19.2.6+incompatible

Apr 3, 2020

v19.2.5+incompatible

Mar 16, 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.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