Versions in this module Expand all Collapse all v1 v1.1.9 Oct 1, 2018 Changes in this version + var ErrIntOverflowProposerKv = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowState = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthProposerKv = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthState = fmt.Errorf("proto: negative length found during unmarshaling") + type ApplyFilterArgs struct + CmdID CmdIDKey + RangeID roachpb.RangeID + StoreID roachpb.StoreID + type ChangeReplicas struct + func (*ChangeReplicas) Descriptor() ([]byte, []int) + func (*ChangeReplicas) ProtoMessage() + func (m *ChangeReplicas) Marshal() (dAtA []byte, err error) + func (m *ChangeReplicas) MarshalTo(dAtA []byte) (int, error) + func (m *ChangeReplicas) Reset() + func (m *ChangeReplicas) Size() (n int) + func (m *ChangeReplicas) Unmarshal(dAtA []byte) error + func (this *ChangeReplicas) Equal(that interface{}) bool + type CmdIDKey string + type CommandQueueAction int + const CommandQueueBeginExecuting + const CommandQueueCancellation + const CommandQueueFinishExecuting + const CommandQueueWaitForPrereqs + type FilterArgs struct + CmdID CmdIDKey + Ctx context.Context + Hdr roachpb.Header + Index int + Req roachpb.Request + Sid roachpb.StoreID + func (f *FilterArgs) InRaftCmd() bool + type Merge struct + func (*Merge) Descriptor() ([]byte, []int) + func (*Merge) ProtoMessage() + func (m *Merge) Marshal() (dAtA []byte, err error) + func (m *Merge) MarshalTo(dAtA []byte) (int, error) + func (m *Merge) Reset() + func (m *Merge) Size() (n int) + func (m *Merge) String() string + func (m *Merge) Unmarshal(dAtA []byte) error + func (this *Merge) Equal(that interface{}) bool + type RaftCommand struct + MaxLeaseIndex uint64 + ProposerLease cockroach_roachpb1.Lease + ProposerReplica cockroach_roachpb.ReplicaDescriptor + ReplicatedEvalResult ReplicatedEvalResult + TestingBatchRequest *cockroach_roachpb3.BatchRequest + WriteBatch *WriteBatch + func (*RaftCommand) Descriptor() ([]byte, []int) + func (*RaftCommand) ProtoMessage() + func (m *RaftCommand) Marshal() (dAtA []byte, err error) + func (m *RaftCommand) MarshalTo(dAtA []byte) (int, error) + func (m *RaftCommand) Reset() + func (m *RaftCommand) Size() (n int) + func (m *RaftCommand) String() string + func (m *RaftCommand) Unmarshal(dAtA []byte) error + type RangeInfo struct + ApproximateProposalQuota int64 + LastIndex uint64 + NumDropped uint64 + NumPending uint64 + RaftLogSize int64 + 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 + func (this *RangeInfo) Equal(that interface{}) bool + type ReplicaApplyFilter func(args ApplyFilterArgs) *roachpb.Error + type ReplicaCommandFilter func(args FilterArgs) *roachpb.Error + type ReplicaResponseFilter func(roachpb.BatchRequest, *roachpb.BatchResponse) *roachpb.Error + type ReplicaState struct + Desc *cockroach_roachpb.RangeDescriptor + GCThreshold cockroach_util_hlc.Timestamp + Lease *cockroach_roachpb1.Lease + LeaseAppliedIndex uint64 + RaftAppliedIndex uint64 + Stats cockroach_storage_engine_enginepb.MVCCStats + TruncatedState *cockroach_roachpb4.RaftTruncatedState + TxnSpanGCThreshold cockroach_util_hlc.Timestamp + func (*ReplicaState) Descriptor() ([]byte, []int) + func (*ReplicaState) ProtoMessage() + func (m *ReplicaState) Marshal() (dAtA []byte, err error) + func (m *ReplicaState) MarshalTo(dAtA []byte) (int, error) + func (m *ReplicaState) Reset() + func (m *ReplicaState) Size() (n int) + func (m *ReplicaState) String() string + func (m *ReplicaState) Unmarshal(dAtA []byte) error + func (this *ReplicaState) Equal(that interface{}) bool + type ReplicatedEvalResult struct + AddSSTable *ReplicatedEvalResult_AddSSTable + BlockReads bool + ChangeReplicas *ChangeReplicas + ComputeChecksum *cockroach_roachpb3.ComputeChecksumRequest + Delta cockroach_storage_engine_enginepb.MVCCStats + EndKey github_com_cockroachdb_cockroach_pkg_roachpb.RKey + IsConsistencyRelated bool + IsFreeze bool + IsLeaseRequest bool + Merge *Merge + RaftLogDelta *int64 + Split *Split + StartKey github_com_cockroachdb_cockroach_pkg_roachpb.RKey + State ReplicaState + Timestamp cockroach_util_hlc.Timestamp + func (*ReplicatedEvalResult) Descriptor() ([]byte, []int) + func (*ReplicatedEvalResult) ProtoMessage() + func (m *ReplicatedEvalResult) Marshal() (dAtA []byte, err error) + func (m *ReplicatedEvalResult) MarshalTo(dAtA []byte) (int, error) + func (m *ReplicatedEvalResult) Reset() + func (m *ReplicatedEvalResult) Size() (n int) + func (m *ReplicatedEvalResult) String() string + func (m *ReplicatedEvalResult) Unmarshal(dAtA []byte) error + func (this *ReplicatedEvalResult) Equal(that interface{}) bool + type ReplicatedEvalResult_AddSSTable struct + CRC32 uint32 + Data []byte + func (*ReplicatedEvalResult_AddSSTable) Descriptor() ([]byte, []int) + func (*ReplicatedEvalResult_AddSSTable) ProtoMessage() + func (m *ReplicatedEvalResult_AddSSTable) Marshal() (dAtA []byte, err error) + func (m *ReplicatedEvalResult_AddSSTable) MarshalTo(dAtA []byte) (int, error) + func (m *ReplicatedEvalResult_AddSSTable) Reset() + func (m *ReplicatedEvalResult_AddSSTable) Size() (n int) + func (m *ReplicatedEvalResult_AddSSTable) String() string + func (m *ReplicatedEvalResult_AddSSTable) Unmarshal(dAtA []byte) error + func (this *ReplicatedEvalResult_AddSSTable) Equal(that interface{}) bool + type Split struct + RHSDelta cockroach_storage_engine_enginepb.MVCCStats + func (*Split) Descriptor() ([]byte, []int) + func (*Split) ProtoMessage() + func (m *Split) Marshal() (dAtA []byte, err error) + func (m *Split) MarshalTo(dAtA []byte) (int, error) + func (m *Split) Reset() + func (m *Split) Size() (n int) + func (m *Split) String() string + func (m *Split) Unmarshal(dAtA []byte) error + func (this *Split) Equal(that interface{}) bool + type WriteBatch struct + Data []byte + func (*WriteBatch) Descriptor() ([]byte, []int) + func (*WriteBatch) ProtoMessage() + func (m *WriteBatch) Marshal() (dAtA []byte, err error) + func (m *WriteBatch) MarshalTo(dAtA []byte) (int, error) + func (m *WriteBatch) Reset() + func (m *WriteBatch) Size() (n int) + func (m *WriteBatch) String() string + func (m *WriteBatch) Unmarshal(dAtA []byte) error Incompatible versions in this module v19.2.12+incompatible Jan 12, 2021