debugpb

package
v0.0.0-...-e1fa7ea Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 13, 2024 License: Apache-2.0 Imports: 13 Imported by: 39

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthDebugpb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDebugpb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDebugpb = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var BottommostLevelCompaction_name = map[int32]string{
	0: "Skip",
	1: "Force",
	2: "IfHaveCompactionFilter",
}
View Source 
var BottommostLevelCompaction_value = map[string]int32{
	"Skip":                   0,
	"Force":                  1,
	"IfHaveCompactionFilter": 2,
}
View Source 
var DB_name = map[int32]string{
	0: "INVALID",
	1: "KV",
	2: "RAFT",
}
View Source 
var DB_value = map[string]int32{
	"INVALID": 0,
	"KV":      1,
	"RAFT":    2,
}
View Source 
var MODULE_name = map[int32]string{
	0:  "UNUSED",
	1:  "KVDB",
	2:  "RAFTDB",
	3:  "READPOOL",
	4:  "SERVER",
	5:  "STORAGE",
	6:  "PD",
	7:  "METRIC",
	8:  "COPROCESSOR",
	9:  "SECURITY",
	10: "IMPORT",
}
View Source 
var MODULE_value = map[string]int32{
	"UNUSED":      0,
	"KVDB":        1,
	"RAFTDB":      2,
	"READPOOL":    3,
	"SERVER":      4,
	"STORAGE":     5,
	"PD":          6,
	"METRIC":      7,
	"COPROCESSOR": 8,
	"SECURITY":    9,
	"IMPORT":      10,
}

Functions

func RegisterDebugServer 

func RegisterDebugServer(s *grpc.Server, srv DebugServer)

Types

type BottommostLevelCompaction 

type BottommostLevelCompaction int32
const (
	// Skip bottommost level compaction
	BottommostLevelCompaction_Skip BottommostLevelCompaction = 0
	// Force bottommost level compaction
	BottommostLevelCompaction_Force BottommostLevelCompaction = 1
	// Compact bottommost level if there is a compaction filter.
	BottommostLevelCompaction_IfHaveCompactionFilter BottommostLevelCompaction = 2
)

func (BottommostLevelCompaction) EnumDescriptor 

func (BottommostLevelCompaction) EnumDescriptor() ([]byte, []int)

func (BottommostLevelCompaction) String 

func (x BottommostLevelCompaction) String() string

type CompactRequest 

type CompactRequest struct {
	Db                        DB                        `protobuf:"varint,1,opt,name=db,proto3,enum=debugpb.DB" json:"db,omitempty"`
	Cf                        string                    `protobuf:"bytes,2,opt,name=cf,proto3" json:"cf,omitempty"`
	FromKey                   []byte                    `protobuf:"bytes,3,opt,name=from_key,json=fromKey,proto3" json:"from_key,omitempty"`
	ToKey                     []byte                    `protobuf:"bytes,4,opt,name=to_key,json=toKey,proto3" json:"to_key,omitempty"`
	Threads                   uint32                    `protobuf:"varint,5,opt,name=threads,proto3" json:"threads,omitempty"`
	BottommostLevelCompaction BottommostLevelCompaction `` /* 178-byte string literal not displayed */
}

func (*CompactRequest) Descriptor 

func (*CompactRequest) Descriptor() ([]byte, []int)

func (*CompactRequest) GetBottommostLevelCompaction 

func (m *CompactRequest) GetBottommostLevelCompaction() BottommostLevelCompaction

func (*CompactRequest) GetCf 

func (m *CompactRequest) GetCf() string

func (*CompactRequest) GetDb 

func (m *CompactRequest) GetDb() DB

func (*CompactRequest) GetFromKey 

func (m *CompactRequest) GetFromKey() []byte

func (*CompactRequest) GetThreads 

func (m *CompactRequest) GetThreads() uint32

func (*CompactRequest) GetToKey 

func (m *CompactRequest) GetToKey() []byte

func (*CompactRequest) Marshal 

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

func (*CompactRequest) MarshalTo 

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

func (*CompactRequest) MarshalToSizedBuffer 

func (m *CompactRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CompactRequest) ProtoMessage 

func (*CompactRequest) ProtoMessage()

func (*CompactRequest) Reset 

func (m *CompactRequest) Reset()

func (*CompactRequest) Size 

func (m *CompactRequest) Size() (n int)

func (*CompactRequest) String 

func (m *CompactRequest) String() string

func (*CompactRequest) Unmarshal 

func (m *CompactRequest) Unmarshal(dAtA []byte) error

func (*CompactRequest) XXX_DiscardUnknown 

func (m *CompactRequest) XXX_DiscardUnknown()

func (*CompactRequest) XXX_Marshal 

func (m *CompactRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CompactRequest) XXX_Merge 

func (m *CompactRequest) XXX_Merge(src proto.Message)

func (*CompactRequest) XXX_Size 

func (m *CompactRequest) XXX_Size() int

func (*CompactRequest) XXX_Unmarshal 

func (m *CompactRequest) XXX_Unmarshal(b []byte) error

type CompactResponse 

type CompactResponse struct {
}

func (*CompactResponse) Descriptor 

func (*CompactResponse) Descriptor() ([]byte, []int)

func (*CompactResponse) Marshal 

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

func (*CompactResponse) MarshalTo 

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

func (*CompactResponse) MarshalToSizedBuffer 

func (m *CompactResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CompactResponse) ProtoMessage 

func (*CompactResponse) ProtoMessage()

func (*CompactResponse) Reset 

func (m *CompactResponse) Reset()

func (*CompactResponse) Size 

func (m *CompactResponse) Size() (n int)

func (*CompactResponse) String 

func (m *CompactResponse) String() string

func (*CompactResponse) Unmarshal 

func (m *CompactResponse) Unmarshal(dAtA []byte) error

func (*CompactResponse) XXX_DiscardUnknown 

func (m *CompactResponse) XXX_DiscardUnknown()

func (*CompactResponse) XXX_Marshal 

func (m *CompactResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CompactResponse) XXX_Merge 

func (m *CompactResponse) XXX_Merge(src proto.Message)

func (*CompactResponse) XXX_Size 

func (m *CompactResponse) XXX_Size() int

func (*CompactResponse) XXX_Unmarshal 

func (m *CompactResponse) XXX_Unmarshal(b []byte) error

type DB 

type DB int32
const (
	DB_INVALID DB = 0
	DB_KV      DB = 1
	DB_RAFT    DB = 2
)

func (DB) EnumDescriptor 

func (DB) EnumDescriptor() ([]byte, []int)

func (DB) String 

func (x DB) String() string

type DebugClient 

type DebugClient interface {
	// Read a value arbitrarily for a key.
	// Note: Server uses key directly w/o any encoding.
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	// Read raft info.
	RaftLog(ctx context.Context, in *RaftLogRequest, opts ...grpc.CallOption) (*RaftLogResponse, error)
	RegionInfo(ctx context.Context, in *RegionInfoRequest, opts ...grpc.CallOption) (*RegionInfoResponse, error)
	// Calculate size of a region.
	// Note: DO NOT CALL IT IN PRODUCTION, it's really expensive.
	RegionSize(ctx context.Context, in *RegionSizeRequest, opts ...grpc.CallOption) (*RegionSizeResponse, error)
	// Scan a specific range.
	// Note: DO NOT CALL IT IN PRODUCTION, it's really expensive.
	//       Server uses keys directly w/o any encoding.
	ScanMvcc(ctx context.Context, in *ScanMvccRequest, opts ...grpc.CallOption) (Debug_ScanMvccClient, error)
	// Compact a column family in a specified range.
	// Note: Server uses keys directly w/o any encoding.
	Compact(ctx context.Context, in *CompactRequest, opts ...grpc.CallOption) (*CompactResponse, error)
	// Inject a fail point. Currently, it's only used in tests.
	// Note: DO NOT CALL IT IN PRODUCTION.
	InjectFailPoint(ctx context.Context, in *InjectFailPointRequest, opts ...grpc.CallOption) (*InjectFailPointResponse, error)
	// Recover from a fail point.
	RecoverFailPoint(ctx context.Context, in *RecoverFailPointRequest, opts ...grpc.CallOption) (*RecoverFailPointResponse, error)
	// List all fail points.
	ListFailPoints(ctx context.Context, in *ListFailPointsRequest, opts ...grpc.CallOption) (*ListFailPointsResponse, error)
	// Get Metrics
	GetMetrics(ctx context.Context, in *GetMetricsRequest, opts ...grpc.CallOption) (*GetMetricsResponse, error)
	// Do a consistent check for a region.
	CheckRegionConsistency(ctx context.Context, in *RegionConsistencyCheckRequest, opts ...grpc.CallOption) (*RegionConsistencyCheckResponse, error)
	// dynamically modify tikv's config
	ModifyTikvConfig(ctx context.Context, in *ModifyTikvConfigRequest, opts ...grpc.CallOption) (*ModifyTikvConfigResponse, error)
	// Get region properties
	GetRegionProperties(ctx context.Context, in *GetRegionPropertiesRequest, opts ...grpc.CallOption) (*GetRegionPropertiesResponse, error)
	// Get store ID
	GetStoreInfo(ctx context.Context, in *GetStoreInfoRequest, opts ...grpc.CallOption) (*GetStoreInfoResponse, error)
	// Get cluster ID
	GetClusterInfo(ctx context.Context, in *GetClusterInfoRequest, opts ...grpc.CallOption) (*GetClusterInfoResponse, error)
	// Get all region IDs in the store
	GetAllRegionsInStore(ctx context.Context, in *GetAllRegionsInStoreRequest, opts ...grpc.CallOption) (*GetAllRegionsInStoreResponse, error)
	// Make this TiKV node return to the status on this node to certain ts.
	ResetToVersion(ctx context.Context, in *ResetToVersionRequest, opts ...grpc.CallOption) (*ResetToVersionResponse, error)
	// Get range properties
	GetRangeProperties(ctx context.Context, in *GetRangePropertiesRequest, opts ...grpc.CallOption) (*GetRangePropertiesResponse, error)
	// Flashback given key range to a specified version.
	FlashbackToVersion(ctx context.Context, in *FlashbackToVersionRequest, opts ...grpc.CallOption) (*FlashbackToVersionResponse, error)
	// GetRegionReadProgress returns the some useful info in RegionReadProgress
	GetRegionReadProgress(ctx context.Context, in *GetRegionReadProgressRequest, opts ...grpc.CallOption) (*GetRegionReadProgressResponse, error)
}

DebugClient is the client API for Debug service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDebugClient 

func NewDebugClient(cc *grpc.ClientConn) DebugClient

type DebugServer 

type DebugServer interface {
	// Read a value arbitrarily for a key.
	// Note: Server uses key directly w/o any encoding.
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// Read raft info.
	RaftLog(context.Context, *RaftLogRequest) (*RaftLogResponse, error)
	RegionInfo(context.Context, *RegionInfoRequest) (*RegionInfoResponse, error)
	// Calculate size of a region.
	// Note: DO NOT CALL IT IN PRODUCTION, it's really expensive.
	RegionSize(context.Context, *RegionSizeRequest) (*RegionSizeResponse, error)
	// Scan a specific range.
	// Note: DO NOT CALL IT IN PRODUCTION, it's really expensive.
	//       Server uses keys directly w/o any encoding.
	ScanMvcc(*ScanMvccRequest, Debug_ScanMvccServer) error
	// Compact a column family in a specified range.
	// Note: Server uses keys directly w/o any encoding.
	Compact(context.Context, *CompactRequest) (*CompactResponse, error)
	// Inject a fail point. Currently, it's only used in tests.
	// Note: DO NOT CALL IT IN PRODUCTION.
	InjectFailPoint(context.Context, *InjectFailPointRequest) (*InjectFailPointResponse, error)
	// Recover from a fail point.
	RecoverFailPoint(context.Context, *RecoverFailPointRequest) (*RecoverFailPointResponse, error)
	// List all fail points.
	ListFailPoints(context.Context, *ListFailPointsRequest) (*ListFailPointsResponse, error)
	// Get Metrics
	GetMetrics(context.Context, *GetMetricsRequest) (*GetMetricsResponse, error)
	// Do a consistent check for a region.
	CheckRegionConsistency(context.Context, *RegionConsistencyCheckRequest) (*RegionConsistencyCheckResponse, error)
	// dynamically modify tikv's config
	ModifyTikvConfig(context.Context, *ModifyTikvConfigRequest) (*ModifyTikvConfigResponse, error)
	// Get region properties
	GetRegionProperties(context.Context, *GetRegionPropertiesRequest) (*GetRegionPropertiesResponse, error)
	// Get store ID
	GetStoreInfo(context.Context, *GetStoreInfoRequest) (*GetStoreInfoResponse, error)
	// Get cluster ID
	GetClusterInfo(context.Context, *GetClusterInfoRequest) (*GetClusterInfoResponse, error)
	// Get all region IDs in the store
	GetAllRegionsInStore(context.Context, *GetAllRegionsInStoreRequest) (*GetAllRegionsInStoreResponse, error)
	// Make this TiKV node return to the status on this node to certain ts.
	ResetToVersion(context.Context, *ResetToVersionRequest) (*ResetToVersionResponse, error)
	// Get range properties
	GetRangeProperties(context.Context, *GetRangePropertiesRequest) (*GetRangePropertiesResponse, error)
	// Flashback given key range to a specified version.
	FlashbackToVersion(context.Context, *FlashbackToVersionRequest) (*FlashbackToVersionResponse, error)
	// GetRegionReadProgress returns the some useful info in RegionReadProgress
	GetRegionReadProgress(context.Context, *GetRegionReadProgressRequest) (*GetRegionReadProgressResponse, error)
}

DebugServer is the server API for Debug service.

type Debug_ScanMvccClient 

type Debug_ScanMvccClient interface {
	Recv() (*ScanMvccResponse, error)
	grpc.ClientStream
}

type Debug_ScanMvccServer 

type Debug_ScanMvccServer interface {
	Send(*ScanMvccResponse) error
	grpc.ServerStream
}

type FlashbackToVersionRequest 

type FlashbackToVersionRequest struct {
	Context  *kvrpcpb.Context `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	Version  uint64           `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	RegionId uint64           `protobuf:"varint,3,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	StartKey []byte           `protobuf:"bytes,4,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey   []byte           `protobuf:"bytes,5,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	StartTs  uint64           `protobuf:"varint,6,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	CommitTs uint64           `protobuf:"varint,7,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"`
}

func (*FlashbackToVersionRequest) Descriptor 

func (*FlashbackToVersionRequest) Descriptor() ([]byte, []int)

func (*FlashbackToVersionRequest) GetCommitTs 

func (m *FlashbackToVersionRequest) GetCommitTs() uint64

func (*FlashbackToVersionRequest) GetContext 

func (m *FlashbackToVersionRequest) GetContext() *kvrpcpb.Context

func (*FlashbackToVersionRequest) GetEndKey 

func (m *FlashbackToVersionRequest) GetEndKey() []byte

func (*FlashbackToVersionRequest) GetRegionId 

func (m *FlashbackToVersionRequest) GetRegionId() uint64

func (*FlashbackToVersionRequest) GetStartKey 

func (m *FlashbackToVersionRequest) GetStartKey() []byte

func (*FlashbackToVersionRequest) GetStartTs 

func (m *FlashbackToVersionRequest) GetStartTs() uint64

func (*FlashbackToVersionRequest) GetVersion 

func (m *FlashbackToVersionRequest) GetVersion() uint64

func (*FlashbackToVersionRequest) Marshal 

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

func (*FlashbackToVersionRequest) MarshalTo 

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

func (*FlashbackToVersionRequest) MarshalToSizedBuffer 

func (m *FlashbackToVersionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FlashbackToVersionRequest) ProtoMessage 

func (*FlashbackToVersionRequest) ProtoMessage()

func (*FlashbackToVersionRequest) Reset 

func (m *FlashbackToVersionRequest) Reset()

func (*FlashbackToVersionRequest) Size 

func (m *FlashbackToVersionRequest) Size() (n int)

func (*FlashbackToVersionRequest) String 

func (m *FlashbackToVersionRequest) String() string

func (*FlashbackToVersionRequest) Unmarshal 

func (m *FlashbackToVersionRequest) Unmarshal(dAtA []byte) error

func (*FlashbackToVersionRequest) XXX_DiscardUnknown 

func (m *FlashbackToVersionRequest) XXX_DiscardUnknown()

func (*FlashbackToVersionRequest) XXX_Marshal 

func (m *FlashbackToVersionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlashbackToVersionRequest) XXX_Merge 

func (m *FlashbackToVersionRequest) XXX_Merge(src proto.Message)

func (*FlashbackToVersionRequest) XXX_Size 

func (m *FlashbackToVersionRequest) XXX_Size() int

func (*FlashbackToVersionRequest) XXX_Unmarshal 

func (m *FlashbackToVersionRequest) XXX_Unmarshal(b []byte) error

type FlashbackToVersionResponse 

type FlashbackToVersionResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
}

func (*FlashbackToVersionResponse) Descriptor 

func (*FlashbackToVersionResponse) Descriptor() ([]byte, []int)

func (*FlashbackToVersionResponse) GetError 

func (m *FlashbackToVersionResponse) GetError() string

func (*FlashbackToVersionResponse) Marshal 

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

func (*FlashbackToVersionResponse) MarshalTo 

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

func (*FlashbackToVersionResponse) MarshalToSizedBuffer 

func (m *FlashbackToVersionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FlashbackToVersionResponse) ProtoMessage 

func (*FlashbackToVersionResponse) ProtoMessage()

func (*FlashbackToVersionResponse) Reset 

func (m *FlashbackToVersionResponse) Reset()

func (*FlashbackToVersionResponse) Size 

func (m *FlashbackToVersionResponse) Size() (n int)

func (*FlashbackToVersionResponse) String 

func (m *FlashbackToVersionResponse) String() string

func (*FlashbackToVersionResponse) Unmarshal 

func (m *FlashbackToVersionResponse) Unmarshal(dAtA []byte) error

func (*FlashbackToVersionResponse) XXX_DiscardUnknown 

func (m *FlashbackToVersionResponse) XXX_DiscardUnknown()

func (*FlashbackToVersionResponse) XXX_Marshal 

func (m *FlashbackToVersionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlashbackToVersionResponse) XXX_Merge 

func (m *FlashbackToVersionResponse) XXX_Merge(src proto.Message)

func (*FlashbackToVersionResponse) XXX_Size 

func (m *FlashbackToVersionResponse) XXX_Size() int

func (*FlashbackToVersionResponse) XXX_Unmarshal 

func (m *FlashbackToVersionResponse) XXX_Unmarshal(b []byte) error

type GetAllRegionsInStoreRequest 

type GetAllRegionsInStoreRequest struct {
}

func (*GetAllRegionsInStoreRequest) Descriptor 

func (*GetAllRegionsInStoreRequest) Descriptor() ([]byte, []int)

func (*GetAllRegionsInStoreRequest) Marshal 

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

func (*GetAllRegionsInStoreRequest) MarshalTo 

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

func (*GetAllRegionsInStoreRequest) MarshalToSizedBuffer 

func (m *GetAllRegionsInStoreRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetAllRegionsInStoreRequest) ProtoMessage 

func (*GetAllRegionsInStoreRequest) ProtoMessage()

func (*GetAllRegionsInStoreRequest) Reset 

func (m *GetAllRegionsInStoreRequest) Reset()

func (*GetAllRegionsInStoreRequest) Size 

func (m *GetAllRegionsInStoreRequest) Size() (n int)

func (*GetAllRegionsInStoreRequest) String 

func (m *GetAllRegionsInStoreRequest) String() string

func (*GetAllRegionsInStoreRequest) Unmarshal 

func (m *GetAllRegionsInStoreRequest) Unmarshal(dAtA []byte) error

func (*GetAllRegionsInStoreRequest) XXX_DiscardUnknown 

func (m *GetAllRegionsInStoreRequest) XXX_DiscardUnknown()

func (*GetAllRegionsInStoreRequest) XXX_Marshal 

func (m *GetAllRegionsInStoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAllRegionsInStoreRequest) XXX_Merge 

func (m *GetAllRegionsInStoreRequest) XXX_Merge(src proto.Message)

func (*GetAllRegionsInStoreRequest) XXX_Size 

func (m *GetAllRegionsInStoreRequest) XXX_Size() int

func (*GetAllRegionsInStoreRequest) XXX_Unmarshal 

func (m *GetAllRegionsInStoreRequest) XXX_Unmarshal(b []byte) error

type GetAllRegionsInStoreResponse 

type GetAllRegionsInStoreResponse struct {
	Regions []uint64 `protobuf:"varint,1,rep,packed,name=regions,proto3" json:"regions,omitempty"`
}

func (*GetAllRegionsInStoreResponse) Descriptor 

func (*GetAllRegionsInStoreResponse) Descriptor() ([]byte, []int)

func (*GetAllRegionsInStoreResponse) GetRegions 

func (m *GetAllRegionsInStoreResponse) GetRegions() []uint64

func (*GetAllRegionsInStoreResponse) Marshal 

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

func (*GetAllRegionsInStoreResponse) MarshalTo 

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

func (*GetAllRegionsInStoreResponse) MarshalToSizedBuffer 

func (m *GetAllRegionsInStoreResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetAllRegionsInStoreResponse) ProtoMessage 

func (*GetAllRegionsInStoreResponse) ProtoMessage()

func (*GetAllRegionsInStoreResponse) Reset 

func (m *GetAllRegionsInStoreResponse) Reset()

func (*GetAllRegionsInStoreResponse) Size 

func (m *GetAllRegionsInStoreResponse) Size() (n int)

func (*GetAllRegionsInStoreResponse) String 

func (m *GetAllRegionsInStoreResponse) String() string

func (*GetAllRegionsInStoreResponse) Unmarshal 

func (m *GetAllRegionsInStoreResponse) Unmarshal(dAtA []byte) error

func (*GetAllRegionsInStoreResponse) XXX_DiscardUnknown 

func (m *GetAllRegionsInStoreResponse) XXX_DiscardUnknown()

func (*GetAllRegionsInStoreResponse) XXX_Marshal 

func (m *GetAllRegionsInStoreResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAllRegionsInStoreResponse) XXX_Merge 

func (m *GetAllRegionsInStoreResponse) XXX_Merge(src proto.Message)

func (*GetAllRegionsInStoreResponse) XXX_Size 

func (m *GetAllRegionsInStoreResponse) XXX_Size() int

func (*GetAllRegionsInStoreResponse) XXX_Unmarshal 

func (m *GetAllRegionsInStoreResponse) XXX_Unmarshal(b []byte) error

type GetClusterInfoRequest 

type GetClusterInfoRequest struct {
}

func (*GetClusterInfoRequest) Descriptor 

func (*GetClusterInfoRequest) Descriptor() ([]byte, []int)

func (*GetClusterInfoRequest) Marshal 

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

func (*GetClusterInfoRequest) MarshalTo 

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

func (*GetClusterInfoRequest) MarshalToSizedBuffer 

func (m *GetClusterInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetClusterInfoRequest) ProtoMessage 

func (*GetClusterInfoRequest) ProtoMessage()

func (*GetClusterInfoRequest) Reset 

func (m *GetClusterInfoRequest) Reset()

func (*GetClusterInfoRequest) Size 

func (m *GetClusterInfoRequest) Size() (n int)

func (*GetClusterInfoRequest) String 

func (m *GetClusterInfoRequest) String() string

func (*GetClusterInfoRequest) Unmarshal 

func (m *GetClusterInfoRequest) Unmarshal(dAtA []byte) error

func (*GetClusterInfoRequest) XXX_DiscardUnknown 

func (m *GetClusterInfoRequest) XXX_DiscardUnknown()

func (*GetClusterInfoRequest) XXX_Marshal 

func (m *GetClusterInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetClusterInfoRequest) XXX_Merge 

func (m *GetClusterInfoRequest) XXX_Merge(src proto.Message)

func (*GetClusterInfoRequest) XXX_Size 

func (m *GetClusterInfoRequest) XXX_Size() int

func (*GetClusterInfoRequest) XXX_Unmarshal 

func (m *GetClusterInfoRequest) XXX_Unmarshal(b []byte) error

type GetClusterInfoResponse 

type GetClusterInfoResponse struct {
	ClusterId uint64 `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
}

func (*GetClusterInfoResponse) Descriptor 

func (*GetClusterInfoResponse) Descriptor() ([]byte, []int)

func (*GetClusterInfoResponse) GetClusterId 

func (m *GetClusterInfoResponse) GetClusterId() uint64

func (*GetClusterInfoResponse) Marshal 

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

func (*GetClusterInfoResponse) MarshalTo 

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

func (*GetClusterInfoResponse) MarshalToSizedBuffer 

func (m *GetClusterInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetClusterInfoResponse) ProtoMessage 

func (*GetClusterInfoResponse) ProtoMessage()

func (*GetClusterInfoResponse) Reset 

func (m *GetClusterInfoResponse) Reset()

func (*GetClusterInfoResponse) Size 

func (m *GetClusterInfoResponse) Size() (n int)

func (*GetClusterInfoResponse) String 

func (m *GetClusterInfoResponse) String() string

func (*GetClusterInfoResponse) Unmarshal 

func (m *GetClusterInfoResponse) Unmarshal(dAtA []byte) error

func (*GetClusterInfoResponse) XXX_DiscardUnknown 

func (m *GetClusterInfoResponse) XXX_DiscardUnknown()

func (*GetClusterInfoResponse) XXX_Marshal 

func (m *GetClusterInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetClusterInfoResponse) XXX_Merge 

func (m *GetClusterInfoResponse) XXX_Merge(src proto.Message)

func (*GetClusterInfoResponse) XXX_Size 

func (m *GetClusterInfoResponse) XXX_Size() int

func (*GetClusterInfoResponse) XXX_Unmarshal 

func (m *GetClusterInfoResponse) XXX_Unmarshal(b []byte) error

type GetMetricsRequest 

type GetMetricsRequest struct {
	All bool `protobuf:"varint,1,opt,name=all,proto3" json:"all,omitempty"`
}

func (*GetMetricsRequest) Descriptor 

func (*GetMetricsRequest) Descriptor() ([]byte, []int)

func (*GetMetricsRequest) GetAll 

func (m *GetMetricsRequest) GetAll() bool

func (*GetMetricsRequest) Marshal 

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

func (*GetMetricsRequest) MarshalTo 

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

func (*GetMetricsRequest) MarshalToSizedBuffer 

func (m *GetMetricsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetMetricsRequest) ProtoMessage 

func (*GetMetricsRequest) ProtoMessage()

func (*GetMetricsRequest) Reset 

func (m *GetMetricsRequest) Reset()

func (*GetMetricsRequest) Size 

func (m *GetMetricsRequest) Size() (n int)

func (*GetMetricsRequest) String 

func (m *GetMetricsRequest) String() string

func (*GetMetricsRequest) Unmarshal 

func (m *GetMetricsRequest) Unmarshal(dAtA []byte) error

func (*GetMetricsRequest) XXX_DiscardUnknown 

func (m *GetMetricsRequest) XXX_DiscardUnknown()

func (*GetMetricsRequest) XXX_Marshal 

func (m *GetMetricsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetMetricsRequest) XXX_Merge 

func (m *GetMetricsRequest) XXX_Merge(src proto.Message)

func (*GetMetricsRequest) XXX_Size 

func (m *GetMetricsRequest) XXX_Size() int

func (*GetMetricsRequest) XXX_Unmarshal 

func (m *GetMetricsRequest) XXX_Unmarshal(b []byte) error

type GetMetricsResponse 

type GetMetricsResponse struct {
	Prometheus  string `protobuf:"bytes,1,opt,name=prometheus,proto3" json:"prometheus,omitempty"`
	RocksdbKv   string `protobuf:"bytes,2,opt,name=rocksdb_kv,json=rocksdbKv,proto3" json:"rocksdb_kv,omitempty"`
	RocksdbRaft string `protobuf:"bytes,3,opt,name=rocksdb_raft,json=rocksdbRaft,proto3" json:"rocksdb_raft,omitempty"`
	Jemalloc    string `protobuf:"bytes,4,opt,name=jemalloc,proto3" json:"jemalloc,omitempty"`
	StoreId     uint64 `protobuf:"varint,5,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
}

func (*GetMetricsResponse) Descriptor 

func (*GetMetricsResponse) Descriptor() ([]byte, []int)

func (*GetMetricsResponse) GetJemalloc 

func (m *GetMetricsResponse) GetJemalloc() string

func (*GetMetricsResponse) GetPrometheus 

func (m *GetMetricsResponse) GetPrometheus() string

func (*GetMetricsResponse) GetRocksdbKv 

func (m *GetMetricsResponse) GetRocksdbKv() string

func (*GetMetricsResponse) GetRocksdbRaft 

func (m *GetMetricsResponse) GetRocksdbRaft() string

func (*GetMetricsResponse) GetStoreId 

func (m *GetMetricsResponse) GetStoreId() uint64

func (*GetMetricsResponse) Marshal 

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

func (*GetMetricsResponse) MarshalTo 

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

func (*GetMetricsResponse) MarshalToSizedBuffer 

func (m *GetMetricsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetMetricsResponse) ProtoMessage 

func (*GetMetricsResponse) ProtoMessage()

func (*GetMetricsResponse) Reset 

func (m *GetMetricsResponse) Reset()

func (*GetMetricsResponse) Size 

func (m *GetMetricsResponse) Size() (n int)

func (*GetMetricsResponse) String 

func (m *GetMetricsResponse) String() string

func (*GetMetricsResponse) Unmarshal 

func (m *GetMetricsResponse) Unmarshal(dAtA []byte) error

func (*GetMetricsResponse) XXX_DiscardUnknown 

func (m *GetMetricsResponse) XXX_DiscardUnknown()

func (*GetMetricsResponse) XXX_Marshal 

func (m *GetMetricsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetMetricsResponse) XXX_Merge 

func (m *GetMetricsResponse) XXX_Merge(src proto.Message)

func (*GetMetricsResponse) XXX_Size 

func (m *GetMetricsResponse) XXX_Size() int

func (*GetMetricsResponse) XXX_Unmarshal 

func (m *GetMetricsResponse) XXX_Unmarshal(b []byte) error

type GetRangePropertiesRequest 

type GetRangePropertiesRequest struct {
	StartKey []byte `protobuf:"bytes,1,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey   []byte `protobuf:"bytes,2,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
}

func (*GetRangePropertiesRequest) Descriptor 

func (*GetRangePropertiesRequest) Descriptor() ([]byte, []int)

func (*GetRangePropertiesRequest) GetEndKey 

func (m *GetRangePropertiesRequest) GetEndKey() []byte

func (*GetRangePropertiesRequest) GetStartKey 

func (m *GetRangePropertiesRequest) GetStartKey() []byte

func (*GetRangePropertiesRequest) Marshal 

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

func (*GetRangePropertiesRequest) MarshalTo 

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

func (*GetRangePropertiesRequest) MarshalToSizedBuffer 

func (m *GetRangePropertiesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRangePropertiesRequest) ProtoMessage 

func (*GetRangePropertiesRequest) ProtoMessage()

func (*GetRangePropertiesRequest) Reset 

func (m *GetRangePropertiesRequest) Reset()

func (*GetRangePropertiesRequest) Size 

func (m *GetRangePropertiesRequest) Size() (n int)

func (*GetRangePropertiesRequest) String 

func (m *GetRangePropertiesRequest) String() string

func (*GetRangePropertiesRequest) Unmarshal 

func (m *GetRangePropertiesRequest) Unmarshal(dAtA []byte) error

func (*GetRangePropertiesRequest) XXX_DiscardUnknown 

func (m *GetRangePropertiesRequest) XXX_DiscardUnknown()

func (*GetRangePropertiesRequest) XXX_Marshal 

func (m *GetRangePropertiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetRangePropertiesRequest) XXX_Merge 

func (m *GetRangePropertiesRequest) XXX_Merge(src proto.Message)

func (*GetRangePropertiesRequest) XXX_Size 

func (m *GetRangePropertiesRequest) XXX_Size() int

func (*GetRangePropertiesRequest) XXX_Unmarshal 

func (m *GetRangePropertiesRequest) XXX_Unmarshal(b []byte) error

type GetRangePropertiesResponse 

type GetRangePropertiesResponse struct {
	Properties []*GetRangePropertiesResponse_RangeProperty `protobuf:"bytes,1,rep,name=properties,proto3" json:"properties,omitempty"`
}

func (*GetRangePropertiesResponse) Descriptor 

func (*GetRangePropertiesResponse) Descriptor() ([]byte, []int)

func (*GetRangePropertiesResponse) GetProperties 

func (m *GetRangePropertiesResponse) GetProperties() []*GetRangePropertiesResponse_RangeProperty

func (*GetRangePropertiesResponse) Marshal 

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

func (*GetRangePropertiesResponse) MarshalTo 

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

func (*GetRangePropertiesResponse) MarshalToSizedBuffer 

func (m *GetRangePropertiesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRangePropertiesResponse) ProtoMessage 

func (*GetRangePropertiesResponse) ProtoMessage()

func (*GetRangePropertiesResponse) Reset 

func (m *GetRangePropertiesResponse) Reset()

func (*GetRangePropertiesResponse) Size 

func (m *GetRangePropertiesResponse) Size() (n int)

func (*GetRangePropertiesResponse) String 

func (m *GetRangePropertiesResponse) String() string

func (*GetRangePropertiesResponse) Unmarshal 

func (m *GetRangePropertiesResponse) Unmarshal(dAtA []byte) error

func (*GetRangePropertiesResponse) XXX_DiscardUnknown 

func (m *GetRangePropertiesResponse) XXX_DiscardUnknown()

func (*GetRangePropertiesResponse) XXX_Marshal 

func (m *GetRangePropertiesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetRangePropertiesResponse) XXX_Merge 

func (m *GetRangePropertiesResponse) XXX_Merge(src proto.Message)

func (*GetRangePropertiesResponse) XXX_Size 

func (m *GetRangePropertiesResponse) XXX_Size() int

func (*GetRangePropertiesResponse) XXX_Unmarshal 

func (m *GetRangePropertiesResponse) XXX_Unmarshal(b []byte) error

type GetRangePropertiesResponse_RangeProperty 

type GetRangePropertiesResponse_RangeProperty struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*GetRangePropertiesResponse_RangeProperty) Descriptor 

func (*GetRangePropertiesResponse_RangeProperty) Descriptor() ([]byte, []int)

func (*GetRangePropertiesResponse_RangeProperty) GetKey 

func (m *GetRangePropertiesResponse_RangeProperty) GetKey() string

func (*GetRangePropertiesResponse_RangeProperty) GetValue 

func (m *GetRangePropertiesResponse_RangeProperty) GetValue() string

func (*GetRangePropertiesResponse_RangeProperty) Marshal 

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

func (*GetRangePropertiesResponse_RangeProperty) MarshalTo 

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

func (*GetRangePropertiesResponse_RangeProperty) MarshalToSizedBuffer 

func (m *GetRangePropertiesResponse_RangeProperty) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRangePropertiesResponse_RangeProperty) ProtoMessage 

func (*GetRangePropertiesResponse_RangeProperty) ProtoMessage()

func (*GetRangePropertiesResponse_RangeProperty) Reset 

func (m *GetRangePropertiesResponse_RangeProperty) Reset()

func (*GetRangePropertiesResponse_RangeProperty) Size 

func (m *GetRangePropertiesResponse_RangeProperty) Size() (n int)

func (*GetRangePropertiesResponse_RangeProperty) String 

func (m *GetRangePropertiesResponse_RangeProperty) String() string

func (*GetRangePropertiesResponse_RangeProperty) Unmarshal 

func (m *GetRangePropertiesResponse_RangeProperty) Unmarshal(dAtA []byte) error

func (*GetRangePropertiesResponse_RangeProperty) XXX_DiscardUnknown 

func (m *GetRangePropertiesResponse_RangeProperty) XXX_DiscardUnknown()

func (*GetRangePropertiesResponse_RangeProperty) XXX_Marshal 

func (m *GetRangePropertiesResponse_RangeProperty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetRangePropertiesResponse_RangeProperty) XXX_Merge 

func (m *GetRangePropertiesResponse_RangeProperty) XXX_Merge(src proto.Message)

func (*GetRangePropertiesResponse_RangeProperty) XXX_Size 

func (m *GetRangePropertiesResponse_RangeProperty) XXX_Size() int

func (*GetRangePropertiesResponse_RangeProperty) XXX_Unmarshal 

func (m *GetRangePropertiesResponse_RangeProperty) XXX_Unmarshal(b []byte) error

type GetRegionPropertiesRequest 

type GetRegionPropertiesRequest struct {
	RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
}

func (*GetRegionPropertiesRequest) Descriptor 

func (*GetRegionPropertiesRequest) Descriptor() ([]byte, []int)

func (*GetRegionPropertiesRequest) GetRegionId 

func (m *GetRegionPropertiesRequest) GetRegionId() uint64

func (*GetRegionPropertiesRequest) Marshal 

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

func (*GetRegionPropertiesRequest) MarshalTo 

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

func (*GetRegionPropertiesRequest) MarshalToSizedBuffer 

func (m *GetRegionPropertiesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRegionPropertiesRequest) ProtoMessage 

func (*GetRegionPropertiesRequest) ProtoMessage()

func (*GetRegionPropertiesRequest) Reset 

func (m *GetRegionPropertiesRequest) Reset()

func (*GetRegionPropertiesRequest) Size 

func (m *GetRegionPropertiesRequest) Size() (n int)

func (*GetRegionPropertiesRequest) String 

func (m *GetRegionPropertiesRequest) String() string

func (*GetRegionPropertiesRequest) Unmarshal 

func (m *GetRegionPropertiesRequest) Unmarshal(dAtA []byte) error

func (*GetRegionPropertiesRequest) XXX_DiscardUnknown 

func (m *GetRegionPropertiesRequest) XXX_DiscardUnknown()

func (*GetRegionPropertiesRequest) XXX_Marshal 

func (m *GetRegionPropertiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetRegionPropertiesRequest) XXX_Merge 

func (m *GetRegionPropertiesRequest) XXX_Merge(src proto.Message)

func (*GetRegionPropertiesRequest) XXX_Size 

func (m *GetRegionPropertiesRequest) XXX_Size() int

func (*GetRegionPropertiesRequest) XXX_Unmarshal 

func (m *GetRegionPropertiesRequest) XXX_Unmarshal(b []byte) error

type GetRegionPropertiesResponse 

type GetRegionPropertiesResponse struct {
	Props []*Property `protobuf:"bytes,1,rep,name=props,proto3" json:"props,omitempty"`
}

func (*GetRegionPropertiesResponse) Descriptor 

func (*GetRegionPropertiesResponse) Descriptor() ([]byte, []int)

func (*GetRegionPropertiesResponse) GetProps 

func (m *GetRegionPropertiesResponse) GetProps() []*Property

func (*GetRegionPropertiesResponse) Marshal 

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

func (*GetRegionPropertiesResponse) MarshalTo 

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

func (*GetRegionPropertiesResponse) MarshalToSizedBuffer 

func (m *GetRegionPropertiesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRegionPropertiesResponse) ProtoMessage 

func (*GetRegionPropertiesResponse) ProtoMessage()

func (*GetRegionPropertiesResponse) Reset 

func (m *GetRegionPropertiesResponse) Reset()

func (*GetRegionPropertiesResponse) Size 

func (m *GetRegionPropertiesResponse) Size() (n int)

func (*GetRegionPropertiesResponse) String 

func (m *GetRegionPropertiesResponse) String() string

func (*GetRegionPropertiesResponse) Unmarshal 

func (m *GetRegionPropertiesResponse) Unmarshal(dAtA []byte) error

func (*GetRegionPropertiesResponse) XXX_DiscardUnknown 

func (m *GetRegionPropertiesResponse) XXX_DiscardUnknown()

func (*GetRegionPropertiesResponse) XXX_Marshal 

func (m *GetRegionPropertiesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetRegionPropertiesResponse) XXX_Merge 

func (m *GetRegionPropertiesResponse) XXX_Merge(src proto.Message)

func (*GetRegionPropertiesResponse) XXX_Size 

func (m *GetRegionPropertiesResponse) XXX_Size() int

func (*GetRegionPropertiesResponse) XXX_Unmarshal 

func (m *GetRegionPropertiesResponse) XXX_Unmarshal(b []byte) error

type GetRegionReadProgressRequest 

type GetRegionReadProgressRequest struct {
	RegionId   uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	LogLocks   bool   `protobuf:"varint,2,opt,name=log_locks,json=logLocks,proto3" json:"log_locks,omitempty"`
	MinStartTs uint64 `protobuf:"varint,3,opt,name=min_start_ts,json=minStartTs,proto3" json:"min_start_ts,omitempty"`
}

func (*GetRegionReadProgressRequest) Descriptor 

func (*GetRegionReadProgressRequest) Descriptor() ([]byte, []int)

func (*GetRegionReadProgressRequest) GetLogLocks 

func (m *GetRegionReadProgressRequest) GetLogLocks() bool

func (*GetRegionReadProgressRequest) GetMinStartTs 

func (m *GetRegionReadProgressRequest) GetMinStartTs() uint64

func (*GetRegionReadProgressRequest) GetRegionId 

func (m *GetRegionReadProgressRequest) GetRegionId() uint64

func (*GetRegionReadProgressRequest) Marshal 

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

func (*GetRegionReadProgressRequest) MarshalTo 

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

func (*GetRegionReadProgressRequest) MarshalToSizedBuffer 

func (m *GetRegionReadProgressRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRegionReadProgressRequest) ProtoMessage 

func (*GetRegionReadProgressRequest) ProtoMessage()

func (*GetRegionReadProgressRequest) Reset 

func (m *GetRegionReadProgressRequest) Reset()

func (*GetRegionReadProgressRequest) Size 

func (m *GetRegionReadProgressRequest) Size() (n int)

func (*GetRegionReadProgressRequest) String 

func (m *GetRegionReadProgressRequest) String() string

func (*GetRegionReadProgressRequest) Unmarshal 

func (m *GetRegionReadProgressRequest) Unmarshal(dAtA []byte) error

func (*GetRegionReadProgressRequest) XXX_DiscardUnknown 

func (m *GetRegionReadProgressRequest) XXX_DiscardUnknown()

func (*GetRegionReadProgressRequest) XXX_Marshal 

func (m *GetRegionReadProgressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetRegionReadProgressRequest) XXX_Merge 

func (m *GetRegionReadProgressRequest) XXX_Merge(src proto.Message)

func (*GetRegionReadProgressRequest) XXX_Size 

func (m *GetRegionReadProgressRequest) XXX_Size() int

func (*GetRegionReadProgressRequest) XXX_Unmarshal 

func (m *GetRegionReadProgressRequest) XXX_Unmarshal(b []byte) error

type GetRegionReadProgressResponse 

type GetRegionReadProgressResponse struct {
	// below are from region_read_progress module
	SafeTs                        uint64 `protobuf:"varint,1,opt,name=safe_ts,json=safeTs,proto3" json:"safe_ts,omitempty"`
	AppliedIndex                  uint64 `protobuf:"varint,2,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
	PendingFrontAppliedIndex      uint64 `` /* 138-byte string literal not displayed */
	PendingFrontTs                uint64 `protobuf:"varint,4,opt,name=pending_front_ts,json=pendingFrontTs,proto3" json:"pending_front_ts,omitempty"`
	PendingBackAppliedIndex       uint64 `` /* 135-byte string literal not displayed */
	PendingBackTs                 uint64 `protobuf:"varint,6,opt,name=pending_back_ts,json=pendingBackTs,proto3" json:"pending_back_ts,omitempty"`
	RegionReadProgressPaused      bool   `` /* 138-byte string literal not displayed */
	DurationToLastUpdateSafeTsMs  uint64 `` /* 156-byte string literal not displayed */
	DurationToLastConsumeLeaderMs uint64 `` /* 157-byte string literal not displayed */
	RegionReadProgressExist       bool   `` /* 136-byte string literal not displayed */
	ReadStateTs                   uint64 `protobuf:"varint,18,opt,name=read_state_ts,json=readStateTs,proto3" json:"read_state_ts,omitempty"`
	ReadStateApplyIndex           uint64 `protobuf:"varint,19,opt,name=read_state_apply_index,json=readStateApplyIndex,proto3" json:"read_state_apply_index,omitempty"`
	Discard                       bool   `protobuf:"varint,20,opt,name=discard,proto3" json:"discard,omitempty"`
	// below are from resolved-ts module
	ResolvedTs           uint64 `protobuf:"varint,11,opt,name=resolved_ts,json=resolvedTs,proto3" json:"resolved_ts,omitempty"`
	ResolverTrackedIndex uint64 `protobuf:"varint,12,opt,name=resolver_tracked_index,json=resolverTrackedIndex,proto3" json:"resolver_tracked_index,omitempty"`
	ResolverExist        bool   `protobuf:"varint,13,opt,name=resolver_exist,json=resolverExist,proto3" json:"resolver_exist,omitempty"`
	ResolverStopped      bool   `protobuf:"varint,14,opt,name=resolver_stopped,json=resolverStopped,proto3" json:"resolver_stopped,omitempty"`
	NumLocks             uint64 `protobuf:"varint,16,opt,name=num_locks,json=numLocks,proto3" json:"num_locks,omitempty"`
	NumTransactions      uint64 `protobuf:"varint,17,opt,name=num_transactions,json=numTransactions,proto3" json:"num_transactions,omitempty"`
	Error                string `protobuf:"bytes,15,opt,name=error,proto3" json:"error,omitempty"`
}

func (*GetRegionReadProgressResponse) Descriptor 

func (*GetRegionReadProgressResponse) Descriptor() ([]byte, []int)

func (*GetRegionReadProgressResponse) GetAppliedIndex 

func (m *GetRegionReadProgressResponse) GetAppliedIndex() uint64

func (*GetRegionReadProgressResponse) GetDiscard 

func (m *GetRegionReadProgressResponse) GetDiscard() bool

func (*GetRegionReadProgressResponse) GetDurationToLastConsumeLeaderMs 

func (m *GetRegionReadProgressResponse) GetDurationToLastConsumeLeaderMs() uint64

func (*GetRegionReadProgressResponse) GetDurationToLastUpdateSafeTsMs 

func (m *GetRegionReadProgressResponse) GetDurationToLastUpdateSafeTsMs() uint64

func (*GetRegionReadProgressResponse) GetError 

func (m *GetRegionReadProgressResponse) GetError() string

func (*GetRegionReadProgressResponse) GetNumLocks 

func (m *GetRegionReadProgressResponse) GetNumLocks() uint64

func (*GetRegionReadProgressResponse) GetNumTransactions 

func (m *GetRegionReadProgressResponse) GetNumTransactions() uint64

func (*GetRegionReadProgressResponse) GetPendingBackAppliedIndex 

func (m *GetRegionReadProgressResponse) GetPendingBackAppliedIndex() uint64

func (*GetRegionReadProgressResponse) GetPendingBackTs 

func (m *GetRegionReadProgressResponse) GetPendingBackTs() uint64

func (*GetRegionReadProgressResponse) GetPendingFrontAppliedIndex 

func (m *GetRegionReadProgressResponse) GetPendingFrontAppliedIndex() uint64

func (*GetRegionReadProgressResponse) GetPendingFrontTs 

func (m *GetRegionReadProgressResponse) GetPendingFrontTs() uint64

func (*GetRegionReadProgressResponse) GetReadStateApplyIndex 

func (m *GetRegionReadProgressResponse) GetReadStateApplyIndex() uint64

func (*GetRegionReadProgressResponse) GetReadStateTs 

func (m *GetRegionReadProgressResponse) GetReadStateTs() uint64

func (*GetRegionReadProgressResponse) GetRegionReadProgressExist 

func (m *GetRegionReadProgressResponse) GetRegionReadProgressExist() bool

func (*GetRegionReadProgressResponse) GetRegionReadProgressPaused 

func (m *GetRegionReadProgressResponse) GetRegionReadProgressPaused() bool

func (*GetRegionReadProgressResponse) GetResolvedTs 

func (m *GetRegionReadProgressResponse) GetResolvedTs() uint64

func (*GetRegionReadProgressResponse) GetResolverExist 

func (m *GetRegionReadProgressResponse) GetResolverExist() bool

func (*GetRegionReadProgressResponse) GetResolverStopped 

func (m *GetRegionReadProgressResponse) GetResolverStopped() bool

func (*GetRegionReadProgressResponse) GetResolverTrackedIndex 

func (m *GetRegionReadProgressResponse) GetResolverTrackedIndex() uint64

func (*GetRegionReadProgressResponse) GetSafeTs 

func (m *GetRegionReadProgressResponse) GetSafeTs() uint64

func (*GetRegionReadProgressResponse) Marshal 

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

func (*GetRegionReadProgressResponse) MarshalTo 

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

func (*GetRegionReadProgressResponse) MarshalToSizedBuffer 

func (m *GetRegionReadProgressResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRegionReadProgressResponse) ProtoMessage 

func (*GetRegionReadProgressResponse) ProtoMessage()

func (*GetRegionReadProgressResponse) Reset 

func (m *GetRegionReadProgressResponse) Reset()

func (*GetRegionReadProgressResponse) Size 

func (m *GetRegionReadProgressResponse) Size() (n int)

func (*GetRegionReadProgressResponse) String 

func (m *GetRegionReadProgressResponse) String() string

func (*GetRegionReadProgressResponse) Unmarshal 

func (m *GetRegionReadProgressResponse) Unmarshal(dAtA []byte) error

func (*GetRegionReadProgressResponse) XXX_DiscardUnknown 

func (m *GetRegionReadProgressResponse) XXX_DiscardUnknown()

func (*GetRegionReadProgressResponse) XXX_Marshal 

func (m *GetRegionReadProgressResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetRegionReadProgressResponse) XXX_Merge 

func (m *GetRegionReadProgressResponse) XXX_Merge(src proto.Message)

func (*GetRegionReadProgressResponse) XXX_Size 

func (m *GetRegionReadProgressResponse) XXX_Size() int

func (*GetRegionReadProgressResponse) XXX_Unmarshal 

func (m *GetRegionReadProgressResponse) XXX_Unmarshal(b []byte) error

type GetRequest 

type GetRequest struct {
	Db  DB     `protobuf:"varint,1,opt,name=db,proto3,enum=debugpb.DB" json:"db,omitempty"`
	Cf  string `protobuf:"bytes,2,opt,name=cf,proto3" json:"cf,omitempty"`
	Key []byte `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetCf 

func (m *GetRequest) GetCf() string

func (*GetRequest) GetDb 

func (m *GetRequest) GetDb() DB

func (*GetRequest) GetKey 

func (m *GetRequest) GetKey() []byte

func (*GetRequest) Marshal 

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

func (*GetRequest) MarshalTo 

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

func (*GetRequest) MarshalToSizedBuffer 

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

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) Size 

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

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) Unmarshal 

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

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetRequest) XXX_Merge 

func (m *GetRequest) XXX_Merge(src proto.Message)

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

func (m *GetRequest) XXX_Unmarshal(b []byte) error

type GetResponse 

type GetResponse struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetValue 

func (m *GetResponse) GetValue() []byte

func (*GetResponse) Marshal 

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

func (*GetResponse) MarshalTo 

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

func (*GetResponse) MarshalToSizedBuffer 

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

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) Size 

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

func (*GetResponse) String 

func (m *GetResponse) String() string

func (*GetResponse) Unmarshal 

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

func (*GetResponse) XXX_DiscardUnknown 

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal 

func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetResponse) XXX_Merge 

func (m *GetResponse) XXX_Merge(src proto.Message)

func (*GetResponse) XXX_Size 

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal 

func (m *GetResponse) XXX_Unmarshal(b []byte) error

type GetStoreInfoRequest 

type GetStoreInfoRequest struct {
}

func (*GetStoreInfoRequest) Descriptor 

func (*GetStoreInfoRequest) Descriptor() ([]byte, []int)

func (*GetStoreInfoRequest) Marshal 

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

func (*GetStoreInfoRequest) MarshalTo 

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

func (*GetStoreInfoRequest) MarshalToSizedBuffer 

func (m *GetStoreInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetStoreInfoRequest) ProtoMessage 

func (*GetStoreInfoRequest) ProtoMessage()

func (*GetStoreInfoRequest) Reset 

func (m *GetStoreInfoRequest) Reset()

func (*GetStoreInfoRequest) Size 

func (m *GetStoreInfoRequest) Size() (n int)

func (*GetStoreInfoRequest) String 

func (m *GetStoreInfoRequest) String() string

func (*GetStoreInfoRequest) Unmarshal 

func (m *GetStoreInfoRequest) Unmarshal(dAtA []byte) error

func (*GetStoreInfoRequest) XXX_DiscardUnknown 

func (m *GetStoreInfoRequest) XXX_DiscardUnknown()

func (*GetStoreInfoRequest) XXX_Marshal 

func (m *GetStoreInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetStoreInfoRequest) XXX_Merge 

func (m *GetStoreInfoRequest) XXX_Merge(src proto.Message)

func (*GetStoreInfoRequest) XXX_Size 

func (m *GetStoreInfoRequest) XXX_Size() int

func (*GetStoreInfoRequest) XXX_Unmarshal 

func (m *GetStoreInfoRequest) XXX_Unmarshal(b []byte) error

type GetStoreInfoResponse 

type GetStoreInfoResponse struct {
	StoreId    uint64             `protobuf:"varint,1,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
	ApiVersion kvrpcpb.APIVersion `protobuf:"varint,2,opt,name=api_version,json=apiVersion,proto3,enum=kvrpcpb.APIVersion" json:"api_version,omitempty"`
}

func (*GetStoreInfoResponse) Descriptor 

func (*GetStoreInfoResponse) Descriptor() ([]byte, []int)

func (*GetStoreInfoResponse) GetApiVersion 

func (m *GetStoreInfoResponse) GetApiVersion() kvrpcpb.APIVersion

func (*GetStoreInfoResponse) GetStoreId 

func (m *GetStoreInfoResponse) GetStoreId() uint64

func (*GetStoreInfoResponse) Marshal 

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

func (*GetStoreInfoResponse) MarshalTo 

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

func (*GetStoreInfoResponse) MarshalToSizedBuffer 

func (m *GetStoreInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetStoreInfoResponse) ProtoMessage 

func (*GetStoreInfoResponse) ProtoMessage()

func (*GetStoreInfoResponse) Reset 

func (m *GetStoreInfoResponse) Reset()

func (*GetStoreInfoResponse) Size 

func (m *GetStoreInfoResponse) Size() (n int)

func (*GetStoreInfoResponse) String 

func (m *GetStoreInfoResponse) String() string

func (*GetStoreInfoResponse) Unmarshal 

func (m *GetStoreInfoResponse) Unmarshal(dAtA []byte) error

func (*GetStoreInfoResponse) XXX_DiscardUnknown 

func (m *GetStoreInfoResponse) XXX_DiscardUnknown()

func (*GetStoreInfoResponse) XXX_Marshal 

func (m *GetStoreInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetStoreInfoResponse) XXX_Merge 

func (m *GetStoreInfoResponse) XXX_Merge(src proto.Message)

func (*GetStoreInfoResponse) XXX_Size 

func (m *GetStoreInfoResponse) XXX_Size() int

func (*GetStoreInfoResponse) XXX_Unmarshal 

func (m *GetStoreInfoResponse) XXX_Unmarshal(b []byte) error

type InjectFailPointRequest 

type InjectFailPointRequest struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Actions string `protobuf:"bytes,2,opt,name=actions,proto3" json:"actions,omitempty"`
}

func (*InjectFailPointRequest) Descriptor 

func (*InjectFailPointRequest) Descriptor() ([]byte, []int)

func (*InjectFailPointRequest) GetActions 

func (m *InjectFailPointRequest) GetActions() string

func (*InjectFailPointRequest) GetName 

func (m *InjectFailPointRequest) GetName() string

func (*InjectFailPointRequest) Marshal 

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

func (*InjectFailPointRequest) MarshalTo 

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

func (*InjectFailPointRequest) MarshalToSizedBuffer 

func (m *InjectFailPointRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InjectFailPointRequest) ProtoMessage 

func (*InjectFailPointRequest) ProtoMessage()

func (*InjectFailPointRequest) Reset 

func (m *InjectFailPointRequest) Reset()

func (*InjectFailPointRequest) Size 

func (m *InjectFailPointRequest) Size() (n int)

func (*InjectFailPointRequest) String 

func (m *InjectFailPointRequest) String() string

func (*InjectFailPointRequest) Unmarshal 

func (m *InjectFailPointRequest) Unmarshal(dAtA []byte) error

func (*InjectFailPointRequest) XXX_DiscardUnknown 

func (m *InjectFailPointRequest) XXX_DiscardUnknown()

func (*InjectFailPointRequest) XXX_Marshal 

func (m *InjectFailPointRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InjectFailPointRequest) XXX_Merge 

func (m *InjectFailPointRequest) XXX_Merge(src proto.Message)

func (*InjectFailPointRequest) XXX_Size 

func (m *InjectFailPointRequest) XXX_Size() int

func (*InjectFailPointRequest) XXX_Unmarshal 

func (m *InjectFailPointRequest) XXX_Unmarshal(b []byte) error

type InjectFailPointResponse 

type InjectFailPointResponse struct {
}

func (*InjectFailPointResponse) Descriptor 

func (*InjectFailPointResponse) Descriptor() ([]byte, []int)

func (*InjectFailPointResponse) Marshal 

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

func (*InjectFailPointResponse) MarshalTo 

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

func (*InjectFailPointResponse) MarshalToSizedBuffer 

func (m *InjectFailPointResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InjectFailPointResponse) ProtoMessage 

func (*InjectFailPointResponse) ProtoMessage()

func (*InjectFailPointResponse) Reset 

func (m *InjectFailPointResponse) Reset()

func (*InjectFailPointResponse) Size 

func (m *InjectFailPointResponse) Size() (n int)

func (*InjectFailPointResponse) String 

func (m *InjectFailPointResponse) String() string

func (*InjectFailPointResponse) Unmarshal 

func (m *InjectFailPointResponse) Unmarshal(dAtA []byte) error

func (*InjectFailPointResponse) XXX_DiscardUnknown 

func (m *InjectFailPointResponse) XXX_DiscardUnknown()

func (*InjectFailPointResponse) XXX_Marshal 

func (m *InjectFailPointResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InjectFailPointResponse) XXX_Merge 

func (m *InjectFailPointResponse) XXX_Merge(src proto.Message)

func (*InjectFailPointResponse) XXX_Size 

func (m *InjectFailPointResponse) XXX_Size() int

func (*InjectFailPointResponse) XXX_Unmarshal 

func (m *InjectFailPointResponse) XXX_Unmarshal(b []byte) error

type ListFailPointsRequest 

type ListFailPointsRequest struct {
}

func (*ListFailPointsRequest) Descriptor 

func (*ListFailPointsRequest) Descriptor() ([]byte, []int)

func (*ListFailPointsRequest) Marshal 

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

func (*ListFailPointsRequest) MarshalTo 

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

func (*ListFailPointsRequest) MarshalToSizedBuffer 

func (m *ListFailPointsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListFailPointsRequest) ProtoMessage 

func (*ListFailPointsRequest) ProtoMessage()

func (*ListFailPointsRequest) Reset 

func (m *ListFailPointsRequest) Reset()

func (*ListFailPointsRequest) Size 

func (m *ListFailPointsRequest) Size() (n int)

func (*ListFailPointsRequest) String 

func (m *ListFailPointsRequest) String() string

func (*ListFailPointsRequest) Unmarshal 

func (m *ListFailPointsRequest) Unmarshal(dAtA []byte) error

func (*ListFailPointsRequest) XXX_DiscardUnknown 

func (m *ListFailPointsRequest) XXX_DiscardUnknown()

func (*ListFailPointsRequest) XXX_Marshal 

func (m *ListFailPointsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListFailPointsRequest) XXX_Merge 

func (m *ListFailPointsRequest) XXX_Merge(src proto.Message)

func (*ListFailPointsRequest) XXX_Size 

func (m *ListFailPointsRequest) XXX_Size() int

func (*ListFailPointsRequest) XXX_Unmarshal 

func (m *ListFailPointsRequest) XXX_Unmarshal(b []byte) error

type ListFailPointsResponse 

type ListFailPointsResponse struct {
	Entries []*ListFailPointsResponse_Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
}

func (*ListFailPointsResponse) Descriptor 

func (*ListFailPointsResponse) Descriptor() ([]byte, []int)

func (*ListFailPointsResponse) GetEntries 

func (m *ListFailPointsResponse) GetEntries() []*ListFailPointsResponse_Entry

func (*ListFailPointsResponse) Marshal 

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

func (*ListFailPointsResponse) MarshalTo 

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

func (*ListFailPointsResponse) MarshalToSizedBuffer 

func (m *ListFailPointsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListFailPointsResponse) ProtoMessage 

func (*ListFailPointsResponse) ProtoMessage()

func (*ListFailPointsResponse) Reset 

func (m *ListFailPointsResponse) Reset()

func (*ListFailPointsResponse) Size 

func (m *ListFailPointsResponse) Size() (n int)

func (*ListFailPointsResponse) String 

func (m *ListFailPointsResponse) String() string

func (*ListFailPointsResponse) Unmarshal 

func (m *ListFailPointsResponse) Unmarshal(dAtA []byte) error

func (*ListFailPointsResponse) XXX_DiscardUnknown 

func (m *ListFailPointsResponse) XXX_DiscardUnknown()

func (*ListFailPointsResponse) XXX_Marshal 

func (m *ListFailPointsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListFailPointsResponse) XXX_Merge 

func (m *ListFailPointsResponse) XXX_Merge(src proto.Message)

func (*ListFailPointsResponse) XXX_Size 

func (m *ListFailPointsResponse) XXX_Size() int

func (*ListFailPointsResponse) XXX_Unmarshal 

func (m *ListFailPointsResponse) XXX_Unmarshal(b []byte) error

type ListFailPointsResponse_Entry 

type ListFailPointsResponse_Entry struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Actions string `protobuf:"bytes,2,opt,name=actions,proto3" json:"actions,omitempty"`
}

func (*ListFailPointsResponse_Entry) Descriptor 

func (*ListFailPointsResponse_Entry) Descriptor() ([]byte, []int)

func (*ListFailPointsResponse_Entry) GetActions 

func (m *ListFailPointsResponse_Entry) GetActions() string

func (*ListFailPointsResponse_Entry) GetName 

func (m *ListFailPointsResponse_Entry) GetName() string

func (*ListFailPointsResponse_Entry) Marshal 

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

func (*ListFailPointsResponse_Entry) MarshalTo 

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

func (*ListFailPointsResponse_Entry) MarshalToSizedBuffer 

func (m *ListFailPointsResponse_Entry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListFailPointsResponse_Entry) ProtoMessage 

func (*ListFailPointsResponse_Entry) ProtoMessage()

func (*ListFailPointsResponse_Entry) Reset 

func (m *ListFailPointsResponse_Entry) Reset()

func (*ListFailPointsResponse_Entry) Size 

func (m *ListFailPointsResponse_Entry) Size() (n int)

func (*ListFailPointsResponse_Entry) String 

func (m *ListFailPointsResponse_Entry) String() string

func (*ListFailPointsResponse_Entry) Unmarshal 

func (m *ListFailPointsResponse_Entry) Unmarshal(dAtA []byte) error

func (*ListFailPointsResponse_Entry) XXX_DiscardUnknown 

func (m *ListFailPointsResponse_Entry) XXX_DiscardUnknown()

func (*ListFailPointsResponse_Entry) XXX_Marshal 

func (m *ListFailPointsResponse_Entry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListFailPointsResponse_Entry) XXX_Merge 

func (m *ListFailPointsResponse_Entry) XXX_Merge(src proto.Message)

func (*ListFailPointsResponse_Entry) XXX_Size 

func (m *ListFailPointsResponse_Entry) XXX_Size() int

func (*ListFailPointsResponse_Entry) XXX_Unmarshal 

func (m *ListFailPointsResponse_Entry) XXX_Unmarshal(b []byte) error

type MODULE 

type MODULE int32
const (
	MODULE_UNUSED      MODULE = 0
	MODULE_KVDB        MODULE = 1
	MODULE_RAFTDB      MODULE = 2
	MODULE_READPOOL    MODULE = 3
	MODULE_SERVER      MODULE = 4
	MODULE_STORAGE     MODULE = 5
	MODULE_PD          MODULE = 6
	MODULE_METRIC      MODULE = 7
	MODULE_COPROCESSOR MODULE = 8
	MODULE_SECURITY    MODULE = 9
	MODULE_IMPORT      MODULE = 10
)

func (MODULE) EnumDescriptor 

func (MODULE) EnumDescriptor() ([]byte, []int)

func (MODULE) String 

func (x MODULE) String() string

type ModifyTikvConfigRequest 

type ModifyTikvConfigRequest struct {
	Module      MODULE `protobuf:"varint,1,opt,name=module,proto3,enum=debugpb.MODULE" json:"module,omitempty"`
	ConfigName  string `protobuf:"bytes,2,opt,name=config_name,json=configName,proto3" json:"config_name,omitempty"`
	ConfigValue string `protobuf:"bytes,3,opt,name=config_value,json=configValue,proto3" json:"config_value,omitempty"`
}

func (*ModifyTikvConfigRequest) Descriptor 

func (*ModifyTikvConfigRequest) Descriptor() ([]byte, []int)

func (*ModifyTikvConfigRequest) GetConfigName 

func (m *ModifyTikvConfigRequest) GetConfigName() string

func (*ModifyTikvConfigRequest) GetConfigValue 

func (m *ModifyTikvConfigRequest) GetConfigValue() string

func (*ModifyTikvConfigRequest) GetModule 

func (m *ModifyTikvConfigRequest) GetModule() MODULE

func (*ModifyTikvConfigRequest) Marshal 

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

func (*ModifyTikvConfigRequest) MarshalTo 

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

func (*ModifyTikvConfigRequest) MarshalToSizedBuffer 

func (m *ModifyTikvConfigRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ModifyTikvConfigRequest) ProtoMessage 

func (*ModifyTikvConfigRequest) ProtoMessage()

func (*ModifyTikvConfigRequest) Reset 

func (m *ModifyTikvConfigRequest) Reset()

func (*ModifyTikvConfigRequest) Size 

func (m *ModifyTikvConfigRequest) Size() (n int)

func (*ModifyTikvConfigRequest) String 

func (m *ModifyTikvConfigRequest) String() string

func (*ModifyTikvConfigRequest) Unmarshal 

func (m *ModifyTikvConfigRequest) Unmarshal(dAtA []byte) error

func (*ModifyTikvConfigRequest) XXX_DiscardUnknown 

func (m *ModifyTikvConfigRequest) XXX_DiscardUnknown()

func (*ModifyTikvConfigRequest) XXX_Marshal 

func (m *ModifyTikvConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModifyTikvConfigRequest) XXX_Merge 

func (m *ModifyTikvConfigRequest) XXX_Merge(src proto.Message)

func (*ModifyTikvConfigRequest) XXX_Size 

func (m *ModifyTikvConfigRequest) XXX_Size() int

func (*ModifyTikvConfigRequest) XXX_Unmarshal 

func (m *ModifyTikvConfigRequest) XXX_Unmarshal(b []byte) error

type ModifyTikvConfigResponse 

type ModifyTikvConfigResponse struct {
}

func (*ModifyTikvConfigResponse) Descriptor 

func (*ModifyTikvConfigResponse) Descriptor() ([]byte, []int)

func (*ModifyTikvConfigResponse) Marshal 

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

func (*ModifyTikvConfigResponse) MarshalTo 

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

func (*ModifyTikvConfigResponse) MarshalToSizedBuffer 

func (m *ModifyTikvConfigResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ModifyTikvConfigResponse) ProtoMessage 

func (*ModifyTikvConfigResponse) ProtoMessage()

func (*ModifyTikvConfigResponse) Reset 

func (m *ModifyTikvConfigResponse) Reset()

func (*ModifyTikvConfigResponse) Size 

func (m *ModifyTikvConfigResponse) Size() (n int)

func (*ModifyTikvConfigResponse) String 

func (m *ModifyTikvConfigResponse) String() string

func (*ModifyTikvConfigResponse) Unmarshal 

func (m *ModifyTikvConfigResponse) Unmarshal(dAtA []byte) error

func (*ModifyTikvConfigResponse) XXX_DiscardUnknown 

func (m *ModifyTikvConfigResponse) XXX_DiscardUnknown()

func (*ModifyTikvConfigResponse) XXX_Marshal 

func (m *ModifyTikvConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModifyTikvConfigResponse) XXX_Merge 

func (m *ModifyTikvConfigResponse) XXX_Merge(src proto.Message)

func (*ModifyTikvConfigResponse) XXX_Size 

func (m *ModifyTikvConfigResponse) XXX_Size() int

func (*ModifyTikvConfigResponse) XXX_Unmarshal 

func (m *ModifyTikvConfigResponse) XXX_Unmarshal(b []byte) error

type Property 

type Property struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Property) Descriptor 

func (*Property) Descriptor() ([]byte, []int)

func (*Property) GetName 

func (m *Property) GetName() string

func (*Property) GetValue 

func (m *Property) GetValue() string

func (*Property) Marshal 

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

func (*Property) MarshalTo 

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

func (*Property) MarshalToSizedBuffer 

func (m *Property) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Property) ProtoMessage 

func (*Property) ProtoMessage()

func (*Property) Reset 

func (m *Property) Reset()

func (*Property) Size 

func (m *Property) Size() (n int)

func (*Property) String 

func (m *Property) String() string

func (*Property) Unmarshal 

func (m *Property) Unmarshal(dAtA []byte) error

func (*Property) XXX_DiscardUnknown 

func (m *Property) XXX_DiscardUnknown()

func (*Property) XXX_Marshal 

func (m *Property) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Property) XXX_Merge 

func (m *Property) XXX_Merge(src proto.Message)

func (*Property) XXX_Size 

func (m *Property) XXX_Size() int

func (*Property) XXX_Unmarshal 

func (m *Property) XXX_Unmarshal(b []byte) error

type RaftLogRequest 

type RaftLogRequest struct {
	RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	LogIndex uint64 `protobuf:"varint,2,opt,name=log_index,json=logIndex,proto3" json:"log_index,omitempty"`
}

func (*RaftLogRequest) Descriptor 

func (*RaftLogRequest) Descriptor() ([]byte, []int)

func (*RaftLogRequest) GetLogIndex 

func (m *RaftLogRequest) GetLogIndex() uint64

func (*RaftLogRequest) GetRegionId 

func (m *RaftLogRequest) GetRegionId() uint64

func (*RaftLogRequest) Marshal 

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

func (*RaftLogRequest) MarshalTo 

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

func (*RaftLogRequest) MarshalToSizedBuffer 

func (m *RaftLogRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RaftLogRequest) ProtoMessage 

func (*RaftLogRequest) ProtoMessage()

func (*RaftLogRequest) Reset 

func (m *RaftLogRequest) Reset()

func (*RaftLogRequest) Size 

func (m *RaftLogRequest) Size() (n int)

func (*RaftLogRequest) String 

func (m *RaftLogRequest) String() string

func (*RaftLogRequest) Unmarshal 

func (m *RaftLogRequest) Unmarshal(dAtA []byte) error

func (*RaftLogRequest) XXX_DiscardUnknown 

func (m *RaftLogRequest) XXX_DiscardUnknown()

func (*RaftLogRequest) XXX_Marshal 

func (m *RaftLogRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RaftLogRequest) XXX_Merge 

func (m *RaftLogRequest) XXX_Merge(src proto.Message)

func (*RaftLogRequest) XXX_Size 

func (m *RaftLogRequest) XXX_Size() int

func (*RaftLogRequest) XXX_Unmarshal 

func (m *RaftLogRequest) XXX_Unmarshal(b []byte) error

type RaftLogResponse 

type RaftLogResponse struct {
	Entry *eraftpb.Entry `protobuf:"bytes,1,opt,name=entry,proto3" json:"entry,omitempty"`
}

func (*RaftLogResponse) Descriptor 

func (*RaftLogResponse) Descriptor() ([]byte, []int)

func (*RaftLogResponse) GetEntry 

func (m *RaftLogResponse) GetEntry() *eraftpb.Entry

func (*RaftLogResponse) Marshal 

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

func (*RaftLogResponse) MarshalTo 

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

func (*RaftLogResponse) MarshalToSizedBuffer 

func (m *RaftLogResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RaftLogResponse) ProtoMessage 

func (*RaftLogResponse) ProtoMessage()

func (*RaftLogResponse) Reset 

func (m *RaftLogResponse) Reset()

func (*RaftLogResponse) Size 

func (m *RaftLogResponse) Size() (n int)

func (*RaftLogResponse) String 

func (m *RaftLogResponse) String() string

func (*RaftLogResponse) Unmarshal 

func (m *RaftLogResponse) Unmarshal(dAtA []byte) error

func (*RaftLogResponse) XXX_DiscardUnknown 

func (m *RaftLogResponse) XXX_DiscardUnknown()

func (*RaftLogResponse) XXX_Marshal 

func (m *RaftLogResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RaftLogResponse) XXX_Merge 

func (m *RaftLogResponse) XXX_Merge(src proto.Message)

func (*RaftLogResponse) XXX_Size 

func (m *RaftLogResponse) XXX_Size() int

func (*RaftLogResponse) XXX_Unmarshal 

func (m *RaftLogResponse) XXX_Unmarshal(b []byte) error

type RecoverFailPointRequest 

type RecoverFailPointRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*RecoverFailPointRequest) Descriptor 

func (*RecoverFailPointRequest) Descriptor() ([]byte, []int)

func (*RecoverFailPointRequest) GetName 

func (m *RecoverFailPointRequest) GetName() string

func (*RecoverFailPointRequest) Marshal 

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

func (*RecoverFailPointRequest) MarshalTo 

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

func (*RecoverFailPointRequest) MarshalToSizedBuffer 

func (m *RecoverFailPointRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RecoverFailPointRequest) ProtoMessage 

func (*RecoverFailPointRequest) ProtoMessage()

func (*RecoverFailPointRequest) Reset 

func (m *RecoverFailPointRequest) Reset()

func (*RecoverFailPointRequest) Size 

func (m *RecoverFailPointRequest) Size() (n int)

func (*RecoverFailPointRequest) String 

func (m *RecoverFailPointRequest) String() string

func (*RecoverFailPointRequest) Unmarshal 

func (m *RecoverFailPointRequest) Unmarshal(dAtA []byte) error

func (*RecoverFailPointRequest) XXX_DiscardUnknown 

func (m *RecoverFailPointRequest) XXX_DiscardUnknown()

func (*RecoverFailPointRequest) XXX_Marshal 

func (m *RecoverFailPointRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RecoverFailPointRequest) XXX_Merge 

func (m *RecoverFailPointRequest) XXX_Merge(src proto.Message)

func (*RecoverFailPointRequest) XXX_Size 

func (m *RecoverFailPointRequest) XXX_Size() int

func (*RecoverFailPointRequest) XXX_Unmarshal 

func (m *RecoverFailPointRequest) XXX_Unmarshal(b []byte) error

type RecoverFailPointResponse 

type RecoverFailPointResponse struct {
}

func (*RecoverFailPointResponse) Descriptor 

func (*RecoverFailPointResponse) Descriptor() ([]byte, []int)

func (*RecoverFailPointResponse) Marshal 

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

func (*RecoverFailPointResponse) MarshalTo 

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

func (*RecoverFailPointResponse) MarshalToSizedBuffer 

func (m *RecoverFailPointResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RecoverFailPointResponse) ProtoMessage 

func (*RecoverFailPointResponse) ProtoMessage()

func (*RecoverFailPointResponse) Reset 

func (m *RecoverFailPointResponse) Reset()

func (*RecoverFailPointResponse) Size 

func (m *RecoverFailPointResponse) Size() (n int)

func (*RecoverFailPointResponse) String 

func (m *RecoverFailPointResponse) String() string

func (*RecoverFailPointResponse) Unmarshal 

func (m *RecoverFailPointResponse) Unmarshal(dAtA []byte) error

func (*RecoverFailPointResponse) XXX_DiscardUnknown 

func (m *RecoverFailPointResponse) XXX_DiscardUnknown()

func (*RecoverFailPointResponse) XXX_Marshal 

func (m *RecoverFailPointResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RecoverFailPointResponse) XXX_Merge 

func (m *RecoverFailPointResponse) XXX_Merge(src proto.Message)

func (*RecoverFailPointResponse) XXX_Size 

func (m *RecoverFailPointResponse) XXX_Size() int

func (*RecoverFailPointResponse) XXX_Unmarshal 

func (m *RecoverFailPointResponse) XXX_Unmarshal(b []byte) error

type RegionConsistencyCheckRequest 

type RegionConsistencyCheckRequest struct {
	RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
}

func (*RegionConsistencyCheckRequest) Descriptor 

func (*RegionConsistencyCheckRequest) Descriptor() ([]byte, []int)

func (*RegionConsistencyCheckRequest) GetRegionId 

func (m *RegionConsistencyCheckRequest) GetRegionId() uint64

func (*RegionConsistencyCheckRequest) Marshal 

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

func (*RegionConsistencyCheckRequest) MarshalTo 

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

func (*RegionConsistencyCheckRequest) MarshalToSizedBuffer 

func (m *RegionConsistencyCheckRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegionConsistencyCheckRequest) ProtoMessage 

func (*RegionConsistencyCheckRequest) ProtoMessage()

func (*RegionConsistencyCheckRequest) Reset 

func (m *RegionConsistencyCheckRequest) Reset()

func (*RegionConsistencyCheckRequest) Size 

func (m *RegionConsistencyCheckRequest) Size() (n int)

func (*RegionConsistencyCheckRequest) String 

func (m *RegionConsistencyCheckRequest) String() string

func (*RegionConsistencyCheckRequest) Unmarshal 

func (m *RegionConsistencyCheckRequest) Unmarshal(dAtA []byte) error

func (*RegionConsistencyCheckRequest) XXX_DiscardUnknown 

func (m *RegionConsistencyCheckRequest) XXX_DiscardUnknown()

func (*RegionConsistencyCheckRequest) XXX_Marshal 

func (m *RegionConsistencyCheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegionConsistencyCheckRequest) XXX_Merge 

func (m *RegionConsistencyCheckRequest) XXX_Merge(src proto.Message)

func (*RegionConsistencyCheckRequest) XXX_Size 

func (m *RegionConsistencyCheckRequest) XXX_Size() int

func (*RegionConsistencyCheckRequest) XXX_Unmarshal 

func (m *RegionConsistencyCheckRequest) XXX_Unmarshal(b []byte) error

type RegionConsistencyCheckResponse 

type RegionConsistencyCheckResponse struct {
}

func (*RegionConsistencyCheckResponse) Descriptor 

func (*RegionConsistencyCheckResponse) Descriptor() ([]byte, []int)

func (*RegionConsistencyCheckResponse) Marshal 

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

func (*RegionConsistencyCheckResponse) MarshalTo 

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

func (*RegionConsistencyCheckResponse) MarshalToSizedBuffer 

func (m *RegionConsistencyCheckResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegionConsistencyCheckResponse) ProtoMessage 

func (*RegionConsistencyCheckResponse) ProtoMessage()

func (*RegionConsistencyCheckResponse) Reset 

func (m *RegionConsistencyCheckResponse) Reset()

func (*RegionConsistencyCheckResponse) Size 

func (m *RegionConsistencyCheckResponse) Size() (n int)

func (*RegionConsistencyCheckResponse) String 

func (m *RegionConsistencyCheckResponse) String() string

func (*RegionConsistencyCheckResponse) Unmarshal 

func (m *RegionConsistencyCheckResponse) Unmarshal(dAtA []byte) error

func (*RegionConsistencyCheckResponse) XXX_DiscardUnknown 

func (m *RegionConsistencyCheckResponse) XXX_DiscardUnknown()

func (*RegionConsistencyCheckResponse) XXX_Marshal 

func (m *RegionConsistencyCheckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegionConsistencyCheckResponse) XXX_Merge 

func (m *RegionConsistencyCheckResponse) XXX_Merge(src proto.Message)

func (*RegionConsistencyCheckResponse) XXX_Size 

func (m *RegionConsistencyCheckResponse) XXX_Size() int

func (*RegionConsistencyCheckResponse) XXX_Unmarshal 

func (m *RegionConsistencyCheckResponse) XXX_Unmarshal(b []byte) error

type RegionInfoRequest 

type RegionInfoRequest struct {
	RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
}

func (*RegionInfoRequest) Descriptor 

func (*RegionInfoRequest) Descriptor() ([]byte, []int)

func (*RegionInfoRequest) GetRegionId 

func (m *RegionInfoRequest) GetRegionId() uint64

func (*RegionInfoRequest) Marshal 

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

func (*RegionInfoRequest) MarshalTo 

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

func (*RegionInfoRequest) MarshalToSizedBuffer 

func (m *RegionInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegionInfoRequest) ProtoMessage 

func (*RegionInfoRequest) ProtoMessage()

func (*RegionInfoRequest) Reset 

func (m *RegionInfoRequest) Reset()

func (*RegionInfoRequest) Size 

func (m *RegionInfoRequest) Size() (n int)

func (*RegionInfoRequest) String 

func (m *RegionInfoRequest) String() string

func (*RegionInfoRequest) Unmarshal 

func (m *RegionInfoRequest) Unmarshal(dAtA []byte) error

func (*RegionInfoRequest) XXX_DiscardUnknown 

func (m *RegionInfoRequest) XXX_DiscardUnknown()

func (*RegionInfoRequest) XXX_Marshal 

func (m *RegionInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegionInfoRequest) XXX_Merge 

func (m *RegionInfoRequest) XXX_Merge(src proto.Message)

func (*RegionInfoRequest) XXX_Size 

func (m *RegionInfoRequest) XXX_Size() int

func (*RegionInfoRequest) XXX_Unmarshal 

func (m *RegionInfoRequest) XXX_Unmarshal(b []byte) error

type RegionInfoResponse 

type RegionInfoResponse struct {
	RaftLocalState   *raft_serverpb.RaftLocalState   `protobuf:"bytes,1,opt,name=raft_local_state,json=raftLocalState,proto3" json:"raft_local_state,omitempty"`
	RaftApplyState   *raft_serverpb.RaftApplyState   `protobuf:"bytes,2,opt,name=raft_apply_state,json=raftApplyState,proto3" json:"raft_apply_state,omitempty"`
	RegionLocalState *raft_serverpb.RegionLocalState `protobuf:"bytes,3,opt,name=region_local_state,json=regionLocalState,proto3" json:"region_local_state,omitempty"`
}

func (*RegionInfoResponse) Descriptor 

func (*RegionInfoResponse) Descriptor() ([]byte, []int)

func (*RegionInfoResponse) GetRaftApplyState 

func (m *RegionInfoResponse) GetRaftApplyState() *raft_serverpb.RaftApplyState

func (*RegionInfoResponse) GetRaftLocalState 

func (m *RegionInfoResponse) GetRaftLocalState() *raft_serverpb.RaftLocalState

func (*RegionInfoResponse) GetRegionLocalState 

func (m *RegionInfoResponse) GetRegionLocalState() *raft_serverpb.RegionLocalState

func (*RegionInfoResponse) Marshal 

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

func (*RegionInfoResponse) MarshalTo 

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

func (*RegionInfoResponse) MarshalToSizedBuffer 

func (m *RegionInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegionInfoResponse) ProtoMessage 

func (*RegionInfoResponse) ProtoMessage()

func (*RegionInfoResponse) Reset 

func (m *RegionInfoResponse) Reset()

func (*RegionInfoResponse) Size 

func (m *RegionInfoResponse) Size() (n int)

func (*RegionInfoResponse) String 

func (m *RegionInfoResponse) String() string

func (*RegionInfoResponse) Unmarshal 

func (m *RegionInfoResponse) Unmarshal(dAtA []byte) error

func (*RegionInfoResponse) XXX_DiscardUnknown 

func (m *RegionInfoResponse) XXX_DiscardUnknown()

func (*RegionInfoResponse) XXX_Marshal 

func (m *RegionInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegionInfoResponse) XXX_Merge 

func (m *RegionInfoResponse) XXX_Merge(src proto.Message)

func (*RegionInfoResponse) XXX_Size 

func (m *RegionInfoResponse) XXX_Size() int

func (*RegionInfoResponse) XXX_Unmarshal 

func (m *RegionInfoResponse) XXX_Unmarshal(b []byte) error

type RegionSizeRequest 

type RegionSizeRequest struct {
	RegionId uint64   `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	Cfs      []string `protobuf:"bytes,2,rep,name=cfs,proto3" json:"cfs,omitempty"`
}

func (*RegionSizeRequest) Descriptor 

func (*RegionSizeRequest) Descriptor() ([]byte, []int)

func (*RegionSizeRequest) GetCfs 

func (m *RegionSizeRequest) GetCfs() []string

func (*RegionSizeRequest) GetRegionId 

func (m *RegionSizeRequest) GetRegionId() uint64

func (*RegionSizeRequest) Marshal 

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

func (*RegionSizeRequest) MarshalTo 

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

func (*RegionSizeRequest) MarshalToSizedBuffer 

func (m *RegionSizeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegionSizeRequest) ProtoMessage 

func (*RegionSizeRequest) ProtoMessage()

func (*RegionSizeRequest) Reset 

func (m *RegionSizeRequest) Reset()

func (*RegionSizeRequest) Size 

func (m *RegionSizeRequest) Size() (n int)

func (*RegionSizeRequest) String 

func (m *RegionSizeRequest) String() string

func (*RegionSizeRequest) Unmarshal 

func (m *RegionSizeRequest) Unmarshal(dAtA []byte) error

func (*RegionSizeRequest) XXX_DiscardUnknown 

func (m *RegionSizeRequest) XXX_DiscardUnknown()

func (*RegionSizeRequest) XXX_Marshal 

func (m *RegionSizeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegionSizeRequest) XXX_Merge 

func (m *RegionSizeRequest) XXX_Merge(src proto.Message)

func (*RegionSizeRequest) XXX_Size 

func (m *RegionSizeRequest) XXX_Size() int

func (*RegionSizeRequest) XXX_Unmarshal 

func (m *RegionSizeRequest) XXX_Unmarshal(b []byte) error

type RegionSizeResponse 

type RegionSizeResponse struct {
	Entries []*RegionSizeResponse_Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
}

func (*RegionSizeResponse) Descriptor 

func (*RegionSizeResponse) Descriptor() ([]byte, []int)

func (*RegionSizeResponse) GetEntries 

func (m *RegionSizeResponse) GetEntries() []*RegionSizeResponse_Entry

func (*RegionSizeResponse) Marshal 

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

func (*RegionSizeResponse) MarshalTo 

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

func (*RegionSizeResponse) MarshalToSizedBuffer 

func (m *RegionSizeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegionSizeResponse) ProtoMessage 

func (*RegionSizeResponse) ProtoMessage()

func (*RegionSizeResponse) Reset 

func (m *RegionSizeResponse) Reset()

func (*RegionSizeResponse) Size 

func (m *RegionSizeResponse) Size() (n int)

func (*RegionSizeResponse) String 

func (m *RegionSizeResponse) String() string

func (*RegionSizeResponse) Unmarshal 

func (m *RegionSizeResponse) Unmarshal(dAtA []byte) error

func (*RegionSizeResponse) XXX_DiscardUnknown 

func (m *RegionSizeResponse) XXX_DiscardUnknown()

func (*RegionSizeResponse) XXX_Marshal 

func (m *RegionSizeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegionSizeResponse) XXX_Merge 

func (m *RegionSizeResponse) XXX_Merge(src proto.Message)

func (*RegionSizeResponse) XXX_Size 

func (m *RegionSizeResponse) XXX_Size() int

func (*RegionSizeResponse) XXX_Unmarshal 

func (m *RegionSizeResponse) XXX_Unmarshal(b []byte) error

type RegionSizeResponse_Entry 

type RegionSizeResponse_Entry struct {
	Cf    string `protobuf:"bytes,1,opt,name=cf,proto3" json:"cf,omitempty"`
	Size_ uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
}

func (*RegionSizeResponse_Entry) Descriptor 

func (*RegionSizeResponse_Entry) Descriptor() ([]byte, []int)

func (*RegionSizeResponse_Entry) GetCf 

func (m *RegionSizeResponse_Entry) GetCf() string

func (*RegionSizeResponse_Entry) GetSize_ 

func (m *RegionSizeResponse_Entry) GetSize_() uint64

func (*RegionSizeResponse_Entry) Marshal 

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

func (*RegionSizeResponse_Entry) MarshalTo 

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

func (*RegionSizeResponse_Entry) MarshalToSizedBuffer 

func (m *RegionSizeResponse_Entry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegionSizeResponse_Entry) ProtoMessage 

func (*RegionSizeResponse_Entry) ProtoMessage()

func (*RegionSizeResponse_Entry) Reset 

func (m *RegionSizeResponse_Entry) Reset()

func (*RegionSizeResponse_Entry) Size 

func (m *RegionSizeResponse_Entry) Size() (n int)

func (*RegionSizeResponse_Entry) String 

func (m *RegionSizeResponse_Entry) String() string

func (*RegionSizeResponse_Entry) Unmarshal 

func (m *RegionSizeResponse_Entry) Unmarshal(dAtA []byte) error

func (*RegionSizeResponse_Entry) XXX_DiscardUnknown 

func (m *RegionSizeResponse_Entry) XXX_DiscardUnknown()

func (*RegionSizeResponse_Entry) XXX_Marshal 

func (m *RegionSizeResponse_Entry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegionSizeResponse_Entry) XXX_Merge 

func (m *RegionSizeResponse_Entry) XXX_Merge(src proto.Message)

func (*RegionSizeResponse_Entry) XXX_Size 

func (m *RegionSizeResponse_Entry) XXX_Size() int

func (*RegionSizeResponse_Entry) XXX_Unmarshal 

func (m *RegionSizeResponse_Entry) XXX_Unmarshal(b []byte) error

type ResetToVersionRequest 

type ResetToVersionRequest struct {
	Ts uint64 `protobuf:"varint,1,opt,name=ts,proto3" json:"ts,omitempty"`
}

func (*ResetToVersionRequest) Descriptor 

func (*ResetToVersionRequest) Descriptor() ([]byte, []int)

func (*ResetToVersionRequest) GetTs 

func (m *ResetToVersionRequest) GetTs() uint64

func (*ResetToVersionRequest) Marshal 

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

func (*ResetToVersionRequest) MarshalTo 

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

func (*ResetToVersionRequest) MarshalToSizedBuffer 

func (m *ResetToVersionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResetToVersionRequest) ProtoMessage 

func (*ResetToVersionRequest) ProtoMessage()

func (*ResetToVersionRequest) Reset 

func (m *ResetToVersionRequest) Reset()

func (*ResetToVersionRequest) Size 

func (m *ResetToVersionRequest) Size() (n int)

func (*ResetToVersionRequest) String 

func (m *ResetToVersionRequest) String() string

func (*ResetToVersionRequest) Unmarshal 

func (m *ResetToVersionRequest) Unmarshal(dAtA []byte) error

func (*ResetToVersionRequest) XXX_DiscardUnknown 

func (m *ResetToVersionRequest) XXX_DiscardUnknown()

func (*ResetToVersionRequest) XXX_Marshal 

func (m *ResetToVersionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResetToVersionRequest) XXX_Merge 

func (m *ResetToVersionRequest) XXX_Merge(src proto.Message)

func (*ResetToVersionRequest) XXX_Size 

func (m *ResetToVersionRequest) XXX_Size() int

func (*ResetToVersionRequest) XXX_Unmarshal 

func (m *ResetToVersionRequest) XXX_Unmarshal(b []byte) error

type ResetToVersionResponse 

type ResetToVersionResponse struct {
}

func (*ResetToVersionResponse) Descriptor 

func (*ResetToVersionResponse) Descriptor() ([]byte, []int)

func (*ResetToVersionResponse) Marshal 

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

func (*ResetToVersionResponse) MarshalTo 

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

func (*ResetToVersionResponse) MarshalToSizedBuffer 

func (m *ResetToVersionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResetToVersionResponse) ProtoMessage 

func (*ResetToVersionResponse) ProtoMessage()

func (*ResetToVersionResponse) Reset 

func (m *ResetToVersionResponse) Reset()

func (*ResetToVersionResponse) Size 

func (m *ResetToVersionResponse) Size() (n int)

func (*ResetToVersionResponse) String 

func (m *ResetToVersionResponse) String() string

func (*ResetToVersionResponse) Unmarshal 

func (m *ResetToVersionResponse) Unmarshal(dAtA []byte) error

func (*ResetToVersionResponse) XXX_DiscardUnknown 

func (m *ResetToVersionResponse) XXX_DiscardUnknown()

func (*ResetToVersionResponse) XXX_Marshal 

func (m *ResetToVersionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResetToVersionResponse) XXX_Merge 

func (m *ResetToVersionResponse) XXX_Merge(src proto.Message)

func (*ResetToVersionResponse) XXX_Size 

func (m *ResetToVersionResponse) XXX_Size() int

func (*ResetToVersionResponse) XXX_Unmarshal 

func (m *ResetToVersionResponse) XXX_Unmarshal(b []byte) error

type ScanMvccRequest 

type ScanMvccRequest struct {
	FromKey []byte `protobuf:"bytes,1,opt,name=from_key,json=fromKey,proto3" json:"from_key,omitempty"`
	ToKey   []byte `protobuf:"bytes,2,opt,name=to_key,json=toKey,proto3" json:"to_key,omitempty"`
	Limit   uint64 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
}

func (*ScanMvccRequest) Descriptor 

func (*ScanMvccRequest) Descriptor() ([]byte, []int)

func (*ScanMvccRequest) GetFromKey 

func (m *ScanMvccRequest) GetFromKey() []byte

func (*ScanMvccRequest) GetLimit 

func (m *ScanMvccRequest) GetLimit() uint64

func (*ScanMvccRequest) GetToKey 

func (m *ScanMvccRequest) GetToKey() []byte

func (*ScanMvccRequest) Marshal 

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

func (*ScanMvccRequest) MarshalTo 

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

func (*ScanMvccRequest) MarshalToSizedBuffer 

func (m *ScanMvccRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScanMvccRequest) ProtoMessage 

func (*ScanMvccRequest) ProtoMessage()

func (*ScanMvccRequest) Reset 

func (m *ScanMvccRequest) Reset()

func (*ScanMvccRequest) Size 

func (m *ScanMvccRequest) Size() (n int)

func (*ScanMvccRequest) String 

func (m *ScanMvccRequest) String() string

func (*ScanMvccRequest) Unmarshal 

func (m *ScanMvccRequest) Unmarshal(dAtA []byte) error

func (*ScanMvccRequest) XXX_DiscardUnknown 

func (m *ScanMvccRequest) XXX_DiscardUnknown()

func (*ScanMvccRequest) XXX_Marshal 

func (m *ScanMvccRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScanMvccRequest) XXX_Merge 

func (m *ScanMvccRequest) XXX_Merge(src proto.Message)

func (*ScanMvccRequest) XXX_Size 

func (m *ScanMvccRequest) XXX_Size() int

func (*ScanMvccRequest) XXX_Unmarshal 

func (m *ScanMvccRequest) XXX_Unmarshal(b []byte) error

type ScanMvccResponse 

type ScanMvccResponse struct {
	Key  []byte            `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Info *kvrpcpb.MvccInfo `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
}

func (*ScanMvccResponse) Descriptor 

func (*ScanMvccResponse) Descriptor() ([]byte, []int)

func (*ScanMvccResponse) GetInfo 

func (m *ScanMvccResponse) GetInfo() *kvrpcpb.MvccInfo

func (*ScanMvccResponse) GetKey 

func (m *ScanMvccResponse) GetKey() []byte

func (*ScanMvccResponse) Marshal 

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

func (*ScanMvccResponse) MarshalTo 

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

func (*ScanMvccResponse) MarshalToSizedBuffer 

func (m *ScanMvccResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScanMvccResponse) ProtoMessage 

func (*ScanMvccResponse) ProtoMessage()

func (*ScanMvccResponse) Reset 

func (m *ScanMvccResponse) Reset()

func (*ScanMvccResponse) Size 

func (m *ScanMvccResponse) Size() (n int)

func (*ScanMvccResponse) String 

func (m *ScanMvccResponse) String() string

func (*ScanMvccResponse) Unmarshal 

func (m *ScanMvccResponse) Unmarshal(dAtA []byte) error

func (*ScanMvccResponse) XXX_DiscardUnknown 

func (m *ScanMvccResponse) XXX_DiscardUnknown()

func (*ScanMvccResponse) XXX_Marshal 

func (m *ScanMvccResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScanMvccResponse) XXX_Merge 

func (m *ScanMvccResponse) XXX_Merge(src proto.Message)

func (*ScanMvccResponse) XXX_Size 

func (m *ScanMvccResponse) XXX_Size() int

func (*ScanMvccResponse) XXX_Unmarshal 

func (m *ScanMvccResponse) XXX_Unmarshal(b []byte) error

type UnimplementedDebugServer 

type UnimplementedDebugServer struct {
}

UnimplementedDebugServer can be embedded to have forward compatible implementations.

func (*UnimplementedDebugServer) CheckRegionConsistency 

func (*UnimplementedDebugServer) CheckRegionConsistency(ctx context.Context, req *RegionConsistencyCheckRequest) (*RegionConsistencyCheckResponse, error)

func (*UnimplementedDebugServer) Compact 

func (*UnimplementedDebugServer) Compact(ctx context.Context, req *CompactRequest) (*CompactResponse, error)

func (*UnimplementedDebugServer) FlashbackToVersion 

func (*UnimplementedDebugServer) FlashbackToVersion(ctx context.Context, req *FlashbackToVersionRequest) (*FlashbackToVersionResponse, error)

func (*UnimplementedDebugServer) Get 

func (*UnimplementedDebugServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)

func (*UnimplementedDebugServer) GetAllRegionsInStore 

func (*UnimplementedDebugServer) GetAllRegionsInStore(ctx context.Context, req *GetAllRegionsInStoreRequest) (*GetAllRegionsInStoreResponse, error)

func (*UnimplementedDebugServer) GetClusterInfo 

func (*UnimplementedDebugServer) GetClusterInfo(ctx context.Context, req *GetClusterInfoRequest) (*GetClusterInfoResponse, error)

func (*UnimplementedDebugServer) GetMetrics 

func (*UnimplementedDebugServer) GetMetrics(ctx context.Context, req *GetMetricsRequest) (*GetMetricsResponse, error)

func (*UnimplementedDebugServer) GetRangeProperties 

func (*UnimplementedDebugServer) GetRangeProperties(ctx context.Context, req *GetRangePropertiesRequest) (*GetRangePropertiesResponse, error)

func (*UnimplementedDebugServer) GetRegionProperties 

func (*UnimplementedDebugServer) GetRegionProperties(ctx context.Context, req *GetRegionPropertiesRequest) (*GetRegionPropertiesResponse, error)

func (*UnimplementedDebugServer) GetRegionReadProgress 

func (*UnimplementedDebugServer) GetRegionReadProgress(ctx context.Context, req *GetRegionReadProgressRequest) (*GetRegionReadProgressResponse, error)

func (*UnimplementedDebugServer) GetStoreInfo 

func (*UnimplementedDebugServer) GetStoreInfo(ctx context.Context, req *GetStoreInfoRequest) (*GetStoreInfoResponse, error)

func (*UnimplementedDebugServer) InjectFailPoint 

func (*UnimplementedDebugServer) InjectFailPoint(ctx context.Context, req *InjectFailPointRequest) (*InjectFailPointResponse, error)

func (*UnimplementedDebugServer) ListFailPoints 

func (*UnimplementedDebugServer) ListFailPoints(ctx context.Context, req *ListFailPointsRequest) (*ListFailPointsResponse, error)

func (*UnimplementedDebugServer) ModifyTikvConfig 

func (*UnimplementedDebugServer) ModifyTikvConfig(ctx context.Context, req *ModifyTikvConfigRequest) (*ModifyTikvConfigResponse, error)

func (*UnimplementedDebugServer) RaftLog 

func (*UnimplementedDebugServer) RaftLog(ctx context.Context, req *RaftLogRequest) (*RaftLogResponse, error)

func (*UnimplementedDebugServer) RecoverFailPoint 

func (*UnimplementedDebugServer) RecoverFailPoint(ctx context.Context, req *RecoverFailPointRequest) (*RecoverFailPointResponse, error)

func (*UnimplementedDebugServer) RegionInfo 

func (*UnimplementedDebugServer) RegionInfo(ctx context.Context, req *RegionInfoRequest) (*RegionInfoResponse, error)

func (*UnimplementedDebugServer) RegionSize 

func (*UnimplementedDebugServer) RegionSize(ctx context.Context, req *RegionSizeRequest) (*RegionSizeResponse, error)

func (*UnimplementedDebugServer) ResetToVersion 

func (*UnimplementedDebugServer) ResetToVersion(ctx context.Context, req *ResetToVersionRequest) (*ResetToVersionResponse, error)

func (*UnimplementedDebugServer) ScanMvcc 

func (*UnimplementedDebugServer) ScanMvcc(req *ScanMvccRequest, srv Debug_ScanMvccServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.