pdpb

package
v0.0.0-...-bca367d Latest Latest
Warning

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

Go to latest
Published: Jun 13, 2024 License: Apache-2.0 Imports: 15 Imported by: 681

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthPdpb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPdpb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPdpb = fmt.Errorf("proto: unexpected end of group")
)
View Source
var CheckPolicy_name = map[int32]string{
	0: "SCAN",
	1: "APPROXIMATE",
	2: "USEKEY",
}
View Source
var CheckPolicy_value = map[string]int32{
	"SCAN":        0,
	"APPROXIMATE": 1,
	"USEKEY":      2,
}
View Source
var ControlGrpcEvent_name = map[int32]string{
	0: "PAUSE",
	1: "RESUME",
}
View Source
var ControlGrpcEvent_value = map[string]int32{
	"PAUSE":  0,
	"RESUME": 1,
}
View Source
var ErrorType_name = map[int32]string{
	0:  "OK",
	1:  "UNKNOWN",
	2:  "NOT_BOOTSTRAPPED",
	3:  "STORE_TOMBSTONE",
	4:  "ALREADY_BOOTSTRAPPED",
	5:  "INCOMPATIBLE_VERSION",
	6:  "REGION_NOT_FOUND",
	7:  "GLOBAL_CONFIG_NOT_FOUND",
	8:  "DUPLICATED_ENTRY",
	9:  "ENTRY_NOT_FOUND",
	10: "INVALID_VALUE",
	11: "DATA_COMPACTED",
}
View Source
var ErrorType_value = map[string]int32{
	"OK":                      0,
	"UNKNOWN":                 1,
	"NOT_BOOTSTRAPPED":        2,
	"STORE_TOMBSTONE":         3,
	"ALREADY_BOOTSTRAPPED":    4,
	"INCOMPATIBLE_VERSION":    5,
	"REGION_NOT_FOUND":        6,
	"GLOBAL_CONFIG_NOT_FOUND": 7,
	"DUPLICATED_ENTRY":        8,
	"ENTRY_NOT_FOUND":         9,
	"INVALID_VALUE":           10,
	"DATA_COMPACTED":          11,
}
View Source
var EventType_name = map[int32]string{
	0: "PUT",
	1: "DELETE",
}
View Source
var EventType_value = map[string]int32{
	"PUT":    0,
	"DELETE": 1,
}
View Source
var OperatorStatus_name = map[int32]string{
	0: "SUCCESS",
	1: "TIMEOUT",
	2: "CANCEL",
	3: "REPLACE",
	4: "RUNNING",
}
View Source
var OperatorStatus_value = map[string]int32{
	"SUCCESS": 0,
	"TIMEOUT": 1,
	"CANCEL":  2,
	"REPLACE": 3,
	"RUNNING": 4,
}
View Source
var QueryKind_name = map[int32]string{
	0:  "Others",
	1:  "GC",
	2:  "Get",
	3:  "Scan",
	4:  "Coprocessor",
	5:  "Delete",
	6:  "DeleteRange",
	7:  "Put",
	8:  "Prewrite",
	9:  "AcquirePessimisticLock",
	10: "Commit",
	11: "Rollback",
}
View Source
var QueryKind_value = map[string]int32{
	"Others":                 0,
	"GC":                     1,
	"Get":                    2,
	"Scan":                   3,
	"Coprocessor":            4,
	"Delete":                 5,
	"DeleteRange":            6,
	"Put":                    7,
	"Prewrite":               8,
	"AcquirePessimisticLock": 9,
	"Commit":                 10,
	"Rollback":               11,
}
View Source
var ServiceMode_name = map[int32]string{
	0: "UNKNOWN_SVC_MODE",
	1: "PD_SVC_MODE",
	2: "API_SVC_MODE",
}
View Source
var ServiceMode_value = map[string]int32{
	"UNKNOWN_SVC_MODE": 0,
	"PD_SVC_MODE":      1,
	"API_SVC_MODE":     2,
}

Functions

func RegisterPDServer

func RegisterPDServer(s *grpc.Server, srv PDServer)

Types

type AllocIDRequest

type AllocIDRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*AllocIDRequest) Descriptor

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

func (*AllocIDRequest) GetHeader

func (m *AllocIDRequest) GetHeader() *RequestHeader

func (*AllocIDRequest) Marshal

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

func (*AllocIDRequest) MarshalTo

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

func (*AllocIDRequest) MarshalToSizedBuffer

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

func (*AllocIDRequest) ProtoMessage

func (*AllocIDRequest) ProtoMessage()

func (*AllocIDRequest) Reset

func (m *AllocIDRequest) Reset()

func (*AllocIDRequest) Size

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

func (*AllocIDRequest) String

func (m *AllocIDRequest) String() string

func (*AllocIDRequest) Unmarshal

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

func (*AllocIDRequest) XXX_DiscardUnknown

func (m *AllocIDRequest) XXX_DiscardUnknown()

func (*AllocIDRequest) XXX_Marshal

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

func (*AllocIDRequest) XXX_Merge

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

func (*AllocIDRequest) XXX_Size

func (m *AllocIDRequest) XXX_Size() int

func (*AllocIDRequest) XXX_Unmarshal

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

type AllocIDResponse

type AllocIDResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Id                   uint64          `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*AllocIDResponse) Descriptor

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

func (*AllocIDResponse) GetHeader

func (m *AllocIDResponse) GetHeader() *ResponseHeader

func (*AllocIDResponse) GetId

func (m *AllocIDResponse) GetId() uint64

func (*AllocIDResponse) Marshal

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

func (*AllocIDResponse) MarshalTo

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

func (*AllocIDResponse) MarshalToSizedBuffer

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

func (*AllocIDResponse) ProtoMessage

func (*AllocIDResponse) ProtoMessage()

func (*AllocIDResponse) Reset

func (m *AllocIDResponse) Reset()

func (*AllocIDResponse) Size

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

func (*AllocIDResponse) String

func (m *AllocIDResponse) String() string

func (*AllocIDResponse) Unmarshal

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

func (*AllocIDResponse) XXX_DiscardUnknown

func (m *AllocIDResponse) XXX_DiscardUnknown()

func (*AllocIDResponse) XXX_Marshal

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

func (*AllocIDResponse) XXX_Merge

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

func (*AllocIDResponse) XXX_Size

func (m *AllocIDResponse) XXX_Size() int

func (*AllocIDResponse) XXX_Unmarshal

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

type AskBatchSplitRequest

type AskBatchSplitRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Region               *metapb.Region `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	SplitCount           uint32         `protobuf:"varint,3,opt,name=split_count,json=splitCount,proto3" json:"split_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*AskBatchSplitRequest) Descriptor

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

func (*AskBatchSplitRequest) GetHeader

func (m *AskBatchSplitRequest) GetHeader() *RequestHeader

func (*AskBatchSplitRequest) GetRegion

func (m *AskBatchSplitRequest) GetRegion() *metapb.Region

func (*AskBatchSplitRequest) GetSplitCount

func (m *AskBatchSplitRequest) GetSplitCount() uint32

func (*AskBatchSplitRequest) Marshal

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

func (*AskBatchSplitRequest) MarshalTo

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

func (*AskBatchSplitRequest) MarshalToSizedBuffer

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

func (*AskBatchSplitRequest) ProtoMessage

func (*AskBatchSplitRequest) ProtoMessage()

func (*AskBatchSplitRequest) Reset

func (m *AskBatchSplitRequest) Reset()

func (*AskBatchSplitRequest) Size

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

func (*AskBatchSplitRequest) String

func (m *AskBatchSplitRequest) String() string

func (*AskBatchSplitRequest) Unmarshal

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

func (*AskBatchSplitRequest) XXX_DiscardUnknown

func (m *AskBatchSplitRequest) XXX_DiscardUnknown()

func (*AskBatchSplitRequest) XXX_Marshal

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

func (*AskBatchSplitRequest) XXX_Merge

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

func (*AskBatchSplitRequest) XXX_Size

func (m *AskBatchSplitRequest) XXX_Size() int

func (*AskBatchSplitRequest) XXX_Unmarshal

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

type AskBatchSplitResponse

type AskBatchSplitResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Ids                  []*SplitID      `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*AskBatchSplitResponse) Descriptor

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

func (*AskBatchSplitResponse) GetHeader

func (m *AskBatchSplitResponse) GetHeader() *ResponseHeader

func (*AskBatchSplitResponse) GetIds

func (m *AskBatchSplitResponse) GetIds() []*SplitID

func (*AskBatchSplitResponse) Marshal

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

func (*AskBatchSplitResponse) MarshalTo

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

func (*AskBatchSplitResponse) MarshalToSizedBuffer

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

func (*AskBatchSplitResponse) ProtoMessage

func (*AskBatchSplitResponse) ProtoMessage()

func (*AskBatchSplitResponse) Reset

func (m *AskBatchSplitResponse) Reset()

func (*AskBatchSplitResponse) Size

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

func (*AskBatchSplitResponse) String

func (m *AskBatchSplitResponse) String() string

func (*AskBatchSplitResponse) Unmarshal

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

func (*AskBatchSplitResponse) XXX_DiscardUnknown

func (m *AskBatchSplitResponse) XXX_DiscardUnknown()

func (*AskBatchSplitResponse) XXX_Marshal

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

func (*AskBatchSplitResponse) XXX_Merge

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

func (*AskBatchSplitResponse) XXX_Size

func (m *AskBatchSplitResponse) XXX_Size() int

func (*AskBatchSplitResponse) XXX_Unmarshal

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

type AskSplitRequest

type AskSplitRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Region               *metapb.Region `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*AskSplitRequest) Descriptor

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

func (*AskSplitRequest) GetHeader

func (m *AskSplitRequest) GetHeader() *RequestHeader

func (*AskSplitRequest) GetRegion

func (m *AskSplitRequest) GetRegion() *metapb.Region

func (*AskSplitRequest) Marshal

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

func (*AskSplitRequest) MarshalTo

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

func (*AskSplitRequest) MarshalToSizedBuffer

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

func (*AskSplitRequest) ProtoMessage

func (*AskSplitRequest) ProtoMessage()

func (*AskSplitRequest) Reset

func (m *AskSplitRequest) Reset()

func (*AskSplitRequest) Size

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

func (*AskSplitRequest) String

func (m *AskSplitRequest) String() string

func (*AskSplitRequest) Unmarshal

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

func (*AskSplitRequest) XXX_DiscardUnknown

func (m *AskSplitRequest) XXX_DiscardUnknown()

func (*AskSplitRequest) XXX_Marshal

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

func (*AskSplitRequest) XXX_Merge

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

func (*AskSplitRequest) XXX_Size

func (m *AskSplitRequest) XXX_Size() int

func (*AskSplitRequest) XXX_Unmarshal

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

type AskSplitResponse

type AskSplitResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// We split the region into two, first uses the origin
	// parent region id, and the second uses the new_region_id.
	// We must guarantee that the new_region_id is global unique.
	NewRegionId uint64 `protobuf:"varint,2,opt,name=new_region_id,json=newRegionId,proto3" json:"new_region_id,omitempty"`
	// The peer ids for the new split region.
	NewPeerIds           []uint64 `protobuf:"varint,3,rep,packed,name=new_peer_ids,json=newPeerIds,proto3" json:"new_peer_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AskSplitResponse) Descriptor

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

func (*AskSplitResponse) GetHeader

func (m *AskSplitResponse) GetHeader() *ResponseHeader

func (*AskSplitResponse) GetNewPeerIds

func (m *AskSplitResponse) GetNewPeerIds() []uint64

func (*AskSplitResponse) GetNewRegionId

func (m *AskSplitResponse) GetNewRegionId() uint64

func (*AskSplitResponse) Marshal

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

func (*AskSplitResponse) MarshalTo

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

func (*AskSplitResponse) MarshalToSizedBuffer

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

func (*AskSplitResponse) ProtoMessage

func (*AskSplitResponse) ProtoMessage()

func (*AskSplitResponse) Reset

func (m *AskSplitResponse) Reset()

func (*AskSplitResponse) Size

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

func (*AskSplitResponse) String

func (m *AskSplitResponse) String() string

func (*AskSplitResponse) Unmarshal

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

func (*AskSplitResponse) XXX_DiscardUnknown

func (m *AskSplitResponse) XXX_DiscardUnknown()

func (*AskSplitResponse) XXX_Marshal

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

func (*AskSplitResponse) XXX_Merge

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

func (*AskSplitResponse) XXX_Size

func (m *AskSplitResponse) XXX_Size() int

func (*AskSplitResponse) XXX_Unmarshal

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

type