debugpb

package
v0.0.0-...-4fa2b26 Latest Latest
Warning

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

Go to latest
Published: Apr 17, 2024 License: Apache-2.0 Imports: 13 Imported by: 38

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 */
	XXX_NoUnkeyedLiteral      struct{}                  `json:"-"`
	XXX_unrecognized          []byte                    `json:"-"`
	XXX_sizecache             int32                     `json:"-"`
}

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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 (*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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

func (*GetRangePropertiesResponse) Descriptor

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

func (*GetRangePropertiesResponse) GetProperties

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetRangePropertiesResponse_RangeProperty) Descriptor

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

func (*GetRangePropertiesResponse_RangeProperty) GetKey

func (*GetRangePropertiesResponse_RangeProperty) GetValue

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) Reset

func (*GetRangePropertiesResponse_RangeProperty) Size

func (*GetRangePropertiesResponse_RangeProperty) String

func (*GetRangePropertiesResponse_RangeProperty) Unmarshal

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 (*GetRangePropertiesResponse_RangeProperty) XXX_Size

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 (*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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 (*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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*ListFailPointsResponse) Descriptor

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

func (*ListFailPointsResponse) GetEntries

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 (*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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 (*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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 (*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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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) Compact

func (*UnimplementedDebugServer) FlashbackToVersion

func (*UnimplementedDebugServer) Get

func (*UnimplementedDebugServer) GetAllRegionsInStore

func (*UnimplementedDebugServer) GetClusterInfo

func (*UnimplementedDebugServer) GetMetrics

func (*UnimplementedDebugServer) GetRangeProperties

func (*UnimplementedDebugServer) GetRegionProperties

func (*UnimplementedDebugServer) GetRegionReadProgress

func (*UnimplementedDebugServer) GetStoreInfo

func (*UnimplementedDebugServer) InjectFailPoint

func (*UnimplementedDebugServer) ListFailPoints

func (*UnimplementedDebugServer) ModifyTikvConfig

func (*UnimplementedDebugServer) RaftLog

func (*UnimplementedDebugServer) RecoverFailPoint

func (*UnimplementedDebugServer) RegionInfo

func (*UnimplementedDebugServer) RegionSize

func (*UnimplementedDebugServer) ResetToVersion

func (*UnimplementedDebugServer) ScanMvcc

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL