raft_cmdpb

package
v0.0.0-...-3056823 Latest Latest
Warning

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

Go to latest
Published: Oct 27, 2016 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package raft_cmdpb is a generated protocol buffer package.

It is generated from these files:

raft_cmdpb.proto

It has these top-level messages:

GetRequest
GetResponse
PutRequest
PutResponse
DeleteRequest
DeleteResponse
SnapRequest
SnapResponse
Request
Response
ChangePeerRequest
ChangePeerResponse
SplitRequest
SplitResponse
CompactLogRequest
CompactLogResponse
TransferLeaderRequest
TransferLeaderResponse
AdminRequest
AdminResponse
RegionLeaderRequest
RegionLeaderResponse
RegionDetailRequest
RegionDetailResponse
StatusRequest
StatusResponse
RaftRequestHeader
RaftResponseHeader
RaftCmdRequest
RaftCmdResponse

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthRaftCmdpb = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRaftCmdpb   = fmt.Errorf("proto: integer overflow")
)
View Source
var AdminCmdType_name = map[int32]string{
	0: "InvalidAdmin",
	1: "ChangePeer",
	2: "Split",
	3: "CompactLog",
	4: "TransferLeader",
}
View Source
var AdminCmdType_value = map[string]int32{
	"InvalidAdmin":   0,
	"ChangePeer":     1,
	"Split":          2,
	"CompactLog":     3,
	"TransferLeader": 4,
}
View Source
var CmdType_name = map[int32]string{
	0: "Invalid",
	1: "Get",
	3: "Put",
	4: "Delete",
	5: "Snap",
}
View Source
var CmdType_value = map[string]int32{
	"Invalid": 0,
	"Get":     1,
	"Put":     3,
	"Delete":  4,
	"Snap":    5,
}
View Source
var StatusCmdType_name = map[int32]string{
	0: "InvalidStatus",
	1: "RegionLeader",
	2: "RegionDetail",
}
View Source
var StatusCmdType_value = map[string]int32{
	"InvalidStatus": 0,
	"RegionLeader":  1,
	"RegionDetail":  2,
}

Functions

This section is empty.

Types

type AdminCmdType

type AdminCmdType int32
const (
	AdminCmdType_InvalidAdmin   AdminCmdType = 0
	AdminCmdType_ChangePeer     AdminCmdType = 1
	AdminCmdType_Split          AdminCmdType = 2
	AdminCmdType_CompactLog     AdminCmdType = 3
	AdminCmdType_TransferLeader AdminCmdType = 4
)

func (AdminCmdType) Enum

func (x AdminCmdType) Enum() *AdminCmdType

func (AdminCmdType) EnumDescriptor

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

func (AdminCmdType) String

func (x AdminCmdType) String() string

func (*AdminCmdType) UnmarshalJSON

func (x *AdminCmdType) UnmarshalJSON(data []byte) error

type AdminRequest

type AdminRequest struct {
	CmdType          *AdminCmdType          `protobuf:"varint,1,opt,name=cmd_type,enum=raft_cmdpb.AdminCmdType" json:"cmd_type,omitempty"`
	ChangePeer       *ChangePeerRequest     `protobuf:"bytes,2,opt,name=change_peer" json:"change_peer,omitempty"`
	Split            *SplitRequest          `protobuf:"bytes,3,opt,name=split" json:"split,omitempty"`
	CompactLog       *CompactLogRequest     `protobuf:"bytes,4,opt,name=compact_log" json:"compact_log,omitempty"`
	TransferLeader   *TransferLeaderRequest `protobuf:"bytes,5,opt,name=transfer_leader" json:"transfer_leader,omitempty"`
	XXX_unrecognized []byte                 `json:"-"`
}

func (*AdminRequest) Descriptor

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

func (*AdminRequest) GetChangePeer

func (m *AdminRequest) GetChangePeer() *ChangePeerRequest

func (*AdminRequest) GetCmdType

func (m *AdminRequest) GetCmdType() AdminCmdType

func (*AdminRequest) GetCompactLog

func (m *AdminRequest) GetCompactLog() *CompactLogRequest

func (*AdminRequest) GetSplit

func (m *AdminRequest) GetSplit() *SplitRequest

func (*AdminRequest) GetTransferLeader

func (m *AdminRequest) GetTransferLeader() *TransferLeaderRequest

func (*AdminRequest) Marshal

func (m *AdminRequest) Marshal() (data []byte, err error)

func (*AdminRequest) MarshalTo

func (m *AdminRequest) MarshalTo(data []byte) (int, error)

func (*AdminRequest) ProtoMessage

func (*AdminRequest) ProtoMessage()

func (*AdminRequest) Reset

func (m *AdminRequest) Reset()

func (*AdminRequest) Size

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

func (*AdminRequest) String

func (m *AdminRequest) String() string

func (*AdminRequest) Unmarshal

func (m *AdminRequest) Unmarshal(data []byte) error

type AdminResponse

type AdminResponse struct {
	CmdType          *AdminCmdType           `protobuf:"varint,1,opt,name=cmd_type,enum=raft_cmdpb.AdminCmdType" json:"cmd_type,omitempty"`
	ChangePeer       *ChangePeerResponse     `protobuf:"bytes,2,opt,name=change_peer" json:"change_peer,omitempty"`
	Split            *SplitResponse          `protobuf:"bytes,3,opt,name=split" json:"split,omitempty"`
	CompactLog       *CompactLogResponse     `protobuf:"bytes,4,opt,name=compact_log" json:"compact_log,omitempty"`
	TransferLeader   *TransferLeaderResponse `protobuf:"bytes,5,opt,name=transfer_leader" json:"transfer_leader,omitempty"`
	XXX_unrecognized []byte                  `json:"-"`
}

func (*AdminResponse) Descriptor

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

func (*AdminResponse) GetChangePeer

func (m *AdminResponse) GetChangePeer() *ChangePeerResponse

func (*AdminResponse) GetCmdType

func (m *AdminResponse) GetCmdType() AdminCmdType

func (*AdminResponse) GetCompactLog

func (m *AdminResponse) GetCompactLog() *CompactLogResponse

func (*AdminResponse) GetSplit

func (m *AdminResponse) GetSplit() *SplitResponse

func (*AdminResponse) GetTransferLeader

func (m *AdminResponse) GetTransferLeader() *TransferLeaderResponse

func (*AdminResponse) Marshal

func (m *AdminResponse) Marshal() (data []byte, err error)

func (*AdminResponse) MarshalTo

func (m *AdminResponse) MarshalTo(data []byte) (int, error)

func (*AdminResponse) ProtoMessage

func (*AdminResponse) ProtoMessage()

func (*AdminResponse) Reset

func (m *AdminResponse) Reset()

func (*AdminResponse) Size

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

func (*AdminResponse) String

func (m *AdminResponse) String() string

func (*AdminResponse) Unmarshal

func (m *AdminResponse) Unmarshal(data []byte) error

type ChangePeerRequest

type ChangePeerRequest struct {
	// This can be only called in internal RaftStore now.
	ChangeType       *eraftpb.ConfChangeType `protobuf:"varint,1,opt,name=change_type,enum=eraftpb.ConfChangeType" json:"change_type,omitempty"`
	Peer             *metapb.Peer            `protobuf:"bytes,2,opt,name=peer" json:"peer,omitempty"`
	XXX_unrecognized []byte                  `json:"-"`
}

func (*ChangePeerRequest) Descriptor

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

func (*ChangePeerRequest) GetChangeType

func (m *ChangePeerRequest) GetChangeType() eraftpb.ConfChangeType

func (*ChangePeerRequest) GetPeer

func (m *ChangePeerRequest) GetPeer() *metapb.Peer

func (*ChangePeerRequest) Marshal

func (m *ChangePeerRequest) Marshal() (data []byte, err error)

func (*ChangePeerRequest) MarshalTo

func (m *ChangePeerRequest) MarshalTo(data []byte) (int, error)

func (*ChangePeerRequest) ProtoMessage

func (*ChangePeerRequest) ProtoMessage()

func (*ChangePeerRequest) Reset

func (m *ChangePeerRequest) Reset()

func (*ChangePeerRequest) Size

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

func (*ChangePeerRequest) String

func (m *ChangePeerRequest) String() string

func (*ChangePeerRequest) Unmarshal

func (m *ChangePeerRequest) Unmarshal(data []byte) error

type ChangePeerResponse

type ChangePeerResponse struct {
	Region           *metapb.Region `protobuf:"bytes,1,opt,name=region" json:"region,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*ChangePeerResponse) Descriptor

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

func (*ChangePeerResponse) GetRegion

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

func (*ChangePeerResponse) Marshal

func (m *ChangePeerResponse) Marshal() (data []byte, err error)

func (*ChangePeerResponse) MarshalTo

func (m *ChangePeerResponse) MarshalTo(data []byte) (int, error)

func (*ChangePeerResponse) ProtoMessage

func (*ChangePeerResponse) ProtoMessage()

func (*ChangePeerResponse) Reset

func (m *ChangePeerResponse) Reset()

func (*ChangePeerResponse) Size

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

func (*ChangePeerResponse) String

func (m *ChangePeerResponse) String() string

func (*ChangePeerResponse) Unmarshal

func (m *ChangePeerResponse) Unmarshal(data []byte) error

type CmdType

type CmdType int32
const (
	CmdType_Invalid CmdType = 0
	CmdType_Get     CmdType = 1
	CmdType_Put     CmdType = 3
	CmdType_Delete  CmdType = 4
	CmdType_Snap    CmdType = 5
)

func (CmdType) Enum

func (x CmdType) Enum() *CmdType

func (CmdType) EnumDescriptor

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

func (CmdType) String

func (x CmdType) String() string

func (*CmdType) UnmarshalJSON

func (x *CmdType) UnmarshalJSON(data []byte) error

type CompactLogRequest

type CompactLogRequest struct {
	CompactIndex     *uint64 `protobuf:"varint,1,opt,name=compact_index" json:"compact_index,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CompactLogRequest) Descriptor

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

func (*CompactLogRequest) GetCompactIndex

func (m *CompactLogRequest) GetCompactIndex() uint64

func (*CompactLogRequest) Marshal

func (m *CompactLogRequest) Marshal() (data []byte, err error)

func (*CompactLogRequest) MarshalTo

func (m *CompactLogRequest) MarshalTo(data []byte) (int, error)

func (*CompactLogRequest) ProtoMessage

func (*CompactLogRequest) ProtoMessage()

func (*CompactLogRequest) Reset

func (m *CompactLogRequest) Reset()

func (*CompactLogRequest) Size

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

func (*CompactLogRequest) String

func (m *CompactLogRequest) String() string

func (*CompactLogRequest) Unmarshal

func (m *CompactLogRequest) Unmarshal(data []byte) error

type CompactLogResponse

type CompactLogResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*CompactLogResponse) Descriptor

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

func (*CompactLogResponse) Marshal

func (m *CompactLogResponse) Marshal() (data []byte, err error)

func (*CompactLogResponse) MarshalTo

func (m *CompactLogResponse) MarshalTo(data []byte) (int, error)

func (*CompactLogResponse) ProtoMessage

func (*CompactLogResponse) ProtoMessage()

func (*CompactLogResponse) Reset

func (m *CompactLogResponse) Reset()

func (*CompactLogResponse) Size

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

func (*CompactLogResponse) String

func (m *CompactLogResponse) String() string

func (*CompactLogResponse) Unmarshal

func (m *CompactLogResponse) Unmarshal(data []byte) error

type DeleteRequest

type DeleteRequest struct {
	Cf               *string `protobuf:"bytes,1,opt,name=cf" json:"cf,omitempty"`
	Key              []byte  `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DeleteRequest) Descriptor

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

func (*DeleteRequest) GetCf

func (m *DeleteRequest) GetCf() string

func (*DeleteRequest) GetKey

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

func (*DeleteRequest) Marshal

func (m *DeleteRequest) Marshal() (data []byte, err error)

func (*DeleteRequest) MarshalTo

func (m *DeleteRequest) MarshalTo(data []byte) (int, error)

func (*DeleteRequest) ProtoMessage

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset

func (m *DeleteRequest) Reset()

func (*DeleteRequest) Size

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

func (*DeleteRequest) String

func (m *DeleteRequest) String() string

func (*DeleteRequest) Unmarshal

func (m *DeleteRequest) Unmarshal(data []byte) error

type DeleteResponse

type DeleteResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*DeleteResponse) Descriptor

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

func (*DeleteResponse) Marshal

func (m *DeleteResponse) Marshal() (data []byte, err error)

func (*DeleteResponse) MarshalTo

func (m *DeleteResponse) MarshalTo(data []byte) (int, error)

func (*DeleteResponse) ProtoMessage

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset

func (m *DeleteResponse) Reset()

func (*DeleteResponse) Size

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

func (*DeleteResponse) String

func (m *DeleteResponse) String() string

func (*DeleteResponse) Unmarshal

func (m *DeleteResponse) Unmarshal(data []byte) error

type GetRequest

type GetRequest struct {
	Cf               *string `protobuf:"bytes,1,opt,name=cf" json:"cf,omitempty"`
	Key              []byte  `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetRequest) Descriptor

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

func (*GetRequest) GetCf

func (m *GetRequest) GetCf() string

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

type GetResponse

type GetResponse struct {
	Value            []byte `protobuf:"bytes,1,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte `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) 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

type PutRequest

type PutRequest struct {
	Cf               *string `protobuf:"bytes,1,opt,name=cf" json:"cf,omitempty"`
	Key              []byte  `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"`
	Value            []byte  `protobuf:"bytes,3,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*PutRequest) Descriptor

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

func (*PutRequest) GetCf

func (m *PutRequest) GetCf() string

func (*PutRequest) GetKey

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

func (*PutRequest) GetValue

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

func (*PutRequest) Marshal

func (m *PutRequest) Marshal() (data []byte, err error)

func (*PutRequest) MarshalTo

func (m *PutRequest) MarshalTo(data []byte) (int, error)

func (*PutRequest) ProtoMessage

func (*PutRequest) ProtoMessage()

func (*PutRequest) Reset

func (m *PutRequest) Reset()

func (*PutRequest) Size

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

func (*PutRequest) String

func (m *PutRequest) String() string

func (*PutRequest) Unmarshal

func (m *PutRequest) Unmarshal(data []byte) error

type PutResponse

type PutResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*PutResponse) Descriptor

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

func (*PutResponse) Marshal

func (m *PutResponse) Marshal() (data []byte, err error)

func (*PutResponse) MarshalTo

func (m *PutResponse) MarshalTo(data []byte) (int, error)

func (*PutResponse) ProtoMessage

func (*PutResponse) ProtoMessage()

func (*PutResponse) Reset

func (m *PutResponse) Reset()

func (*PutResponse) Size

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

func (*PutResponse) String

func (m *PutResponse) String() string

func (*PutResponse) Unmarshal

func (m *PutResponse) Unmarshal(data []byte) error

type RaftCmdRequest

type RaftCmdRequest struct {
	Header *RaftRequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	// We can't enclose normal requests and administrator request
	// at same time.
	Requests         []*Request     `protobuf:"bytes,2,rep,name=requests" json:"requests,omitempty"`
	AdminRequest     *AdminRequest  `protobuf:"bytes,3,opt,name=admin_request" json:"admin_request,omitempty"`
	StatusRequest    *StatusRequest `protobuf:"bytes,4,opt,name=status_request" json:"status_request,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*RaftCmdRequest) Descriptor

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

func (*RaftCmdRequest) GetAdminRequest

func (m *RaftCmdRequest) GetAdminRequest() *AdminRequest

func (*RaftCmdRequest) GetHeader

func (m *RaftCmdRequest) GetHeader() *RaftRequestHeader

func (*RaftCmdRequest) GetRequests

func (m *RaftCmdRequest) GetRequests() []*Request

func (*RaftCmdRequest) GetStatusRequest

func (m *RaftCmdRequest) GetStatusRequest() *StatusRequest

func (*RaftCmdRequest) Marshal

func (m *RaftCmdRequest) Marshal() (data []byte, err error)

func (*RaftCmdRequest) MarshalTo

func (m *RaftCmdRequest) MarshalTo(data []byte) (int, error)

func (*RaftCmdRequest) ProtoMessage

func (*RaftCmdRequest) ProtoMessage()

func (*RaftCmdRequest) Reset

func (m *RaftCmdRequest) Reset()

func (*RaftCmdRequest) Size

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

func (*RaftCmdRequest) String

func (m *RaftCmdRequest) String() string

func (*RaftCmdRequest) Unmarshal

func (m *RaftCmdRequest) Unmarshal(data []byte) error

type RaftCmdResponse

type RaftCmdResponse struct {
	Header           *RaftResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Responses        []*Response         `protobuf:"bytes,2,rep,name=responses" json:"responses,omitempty"`
	AdminResponse    *AdminResponse      `protobuf:"bytes,3,opt,name=admin_response" json:"admin_response,omitempty"`
	StatusResponse   *StatusResponse     `protobuf:"bytes,4,opt,name=status_response" json:"status_response,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*RaftCmdResponse) Descriptor

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

func (*RaftCmdResponse) GetAdminResponse

func (m *RaftCmdResponse) GetAdminResponse() *AdminResponse

func (*RaftCmdResponse) GetHeader

func (m *RaftCmdResponse) GetHeader() *RaftResponseHeader

func (*RaftCmdResponse) GetResponses

func (m *RaftCmdResponse) GetResponses() []*Response

func (*RaftCmdResponse) GetStatusResponse

func (m *RaftCmdResponse) GetStatusResponse() *StatusResponse

func (*RaftCmdResponse) Marshal

func (m *RaftCmdResponse) Marshal() (data []byte, err error)

func (*RaftCmdResponse) MarshalTo

func (m *RaftCmdResponse) MarshalTo(data []byte) (int, error)

func (*RaftCmdResponse) ProtoMessage

func (*RaftCmdResponse) ProtoMessage()

func (*RaftCmdResponse) Reset

func (m *RaftCmdResponse) Reset()

func (*RaftCmdResponse) Size

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

func (*RaftCmdResponse) String

func (m *RaftCmdResponse) String() string

func (*RaftCmdResponse) Unmarshal

func (m *RaftCmdResponse) Unmarshal(data []byte) error

type RaftRequestHeader

type RaftRequestHeader struct {
	RegionId *uint64      `protobuf:"varint,1,opt,name=region_id" json:"region_id,omitempty"`
	Peer     *metapb.Peer `protobuf:"bytes,2,opt,name=peer" json:"peer,omitempty"`
	// true for read linearization
	ReadQuorum *bool `protobuf:"varint,3,opt,name=read_quorum" json:"read_quorum,omitempty"`
	// 16 bytes, to distinguish request.
	Uuid             []byte              `protobuf:"bytes,4,opt,name=uuid" json:"uuid,omitempty"`
	RegionEpoch      *metapb.RegionEpoch `protobuf:"bytes,5,opt,name=region_epoch" json:"region_epoch,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*RaftRequestHeader) Descriptor

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

func (*RaftRequestHeader) GetPeer

func (m *RaftRequestHeader) GetPeer() *metapb.Peer

func (*RaftRequestHeader) GetReadQuorum

func (m *RaftRequestHeader) GetReadQuorum() bool

func (*RaftRequestHeader) GetRegionEpoch

func (m *RaftRequestHeader) GetRegionEpoch() *metapb.RegionEpoch

func (*RaftRequestHeader) GetRegionId

func (m *RaftRequestHeader) GetRegionId() uint64

func (*RaftRequestHeader) GetUuid

func (m *RaftRequestHeader) GetUuid() []byte

func (*RaftRequestHeader) Marshal

func (m *RaftRequestHeader) Marshal() (data []byte, err error)

func (*RaftRequestHeader) MarshalTo

func (m *RaftRequestHeader) MarshalTo(data []byte) (int, error)

func (*RaftRequestHeader) ProtoMessage

func (*RaftRequestHeader) ProtoMessage()

func (*RaftRequestHeader) Reset

func (m *RaftRequestHeader) Reset()

func (*RaftRequestHeader) Size

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

func (*RaftRequestHeader) String

func (m *RaftRequestHeader) String() string

func (*RaftRequestHeader) Unmarshal

func (m *RaftRequestHeader) Unmarshal(data []byte) error

type RaftResponseHeader

type RaftResponseHeader struct {
	Error            *errorpb.Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	Uuid             []byte         `protobuf:"bytes,2,opt,name=uuid" json:"uuid,omitempty"`
	CurrentTerm      *uint64        `protobuf:"varint,3,opt,name=current_term" json:"current_term,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*RaftResponseHeader) Descriptor

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

func (*RaftResponseHeader) GetCurrentTerm

func (m *RaftResponseHeader) GetCurrentTerm() uint64

func (*RaftResponseHeader) GetError

func (m *RaftResponseHeader) GetError() *errorpb.Error

func (*RaftResponseHeader) GetUuid

func (m *RaftResponseHeader) GetUuid() []byte

func (*RaftResponseHeader) Marshal

func (m *RaftResponseHeader) Marshal() (data []byte, err error)

func (*RaftResponseHeader) MarshalTo

func (m *RaftResponseHeader) MarshalTo(data []byte) (int, error)

func (*RaftResponseHeader) ProtoMessage

func (*RaftResponseHeader) ProtoMessage()

func (*RaftResponseHeader) Reset

func (m *RaftResponseHeader) Reset()

func (*RaftResponseHeader) Size

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

func (*RaftResponseHeader) String

func (m *RaftResponseHeader) String() string

func (*RaftResponseHeader) Unmarshal

func (m *RaftResponseHeader) Unmarshal(data []byte) error

type RegionDetailRequest

type RegionDetailRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

For getting more information of the region. We add some admin operations (ChangePeer, Split...) into the pb job list, then pd server will peek the first one, handle it and then pop it from the job lib. But sometimes, the pd server may crash before popping. When another pd server starts and finds the job is running but not finished, it will first check whether the raft server already has handled this job. E,g, for ChangePeer, if we add Peer10 into region1 and find region1 has already had Peer10, we can think this ChangePeer is finished, and can pop this job from job list directly.

func (*RegionDetailRequest) Descriptor

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

func (*RegionDetailRequest) Marshal

func (m *RegionDetailRequest) Marshal() (data []byte, err error)

func (*RegionDetailRequest) MarshalTo

func (m *RegionDetailRequest) MarshalTo(data []byte) (int, error)

func (*RegionDetailRequest) ProtoMessage

func (*RegionDetailRequest) ProtoMessage()

func (*RegionDetailRequest) Reset

func (m *RegionDetailRequest) Reset()

func (*RegionDetailRequest) Size

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

func (*RegionDetailRequest) String

func (m *RegionDetailRequest) String() string

func (*RegionDetailRequest) Unmarshal

func (m *RegionDetailRequest) Unmarshal(data []byte) error

type RegionDetailResponse

type RegionDetailResponse struct {
	Region           *metapb.Region `protobuf:"bytes,1,opt,name=region" json:"region,omitempty"`
	Leader           *metapb.Peer   `protobuf:"bytes,2,opt,name=leader" json:"leader,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*RegionDetailResponse) Descriptor

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

func (*RegionDetailResponse) GetLeader

func (m *RegionDetailResponse) GetLeader() *metapb.Peer

func (*RegionDetailResponse) GetRegion

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

func (*RegionDetailResponse) Marshal

func (m *RegionDetailResponse) Marshal() (data []byte, err error)

func (*RegionDetailResponse) MarshalTo

func (m *RegionDetailResponse) MarshalTo(data []byte) (int, error)

func (*RegionDetailResponse) ProtoMessage

func (*RegionDetailResponse) ProtoMessage()

func (*RegionDetailResponse) Reset

func (m *RegionDetailResponse) Reset()

func (*RegionDetailResponse) Size

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

func (*RegionDetailResponse) String

func (m *RegionDetailResponse) String() string

func (*RegionDetailResponse) Unmarshal

func (m *RegionDetailResponse) Unmarshal(data []byte) error

type RegionLeaderRequest

type RegionLeaderRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

For get the leader of the region.

func (*RegionLeaderRequest) Descriptor

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

func (*RegionLeaderRequest) Marshal

func (m *RegionLeaderRequest) Marshal() (data []byte, err error)

func (*RegionLeaderRequest) MarshalTo

func (m *RegionLeaderRequest) MarshalTo(data []byte) (int, error)

func (*RegionLeaderRequest) ProtoMessage

func (*RegionLeaderRequest) ProtoMessage()

func (*RegionLeaderRequest) Reset

func (m *RegionLeaderRequest) Reset()

func (*RegionLeaderRequest) Size

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

func (*RegionLeaderRequest) String

func (m *RegionLeaderRequest) String() string

func (*RegionLeaderRequest) Unmarshal

func (m *RegionLeaderRequest) Unmarshal(data []byte) error

type RegionLeaderResponse

type RegionLeaderResponse struct {
	Leader           *metapb.Peer `protobuf:"bytes,1,opt,name=leader" json:"leader,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*RegionLeaderResponse) Descriptor

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

func (*RegionLeaderResponse) GetLeader

func (m *RegionLeaderResponse) GetLeader() *metapb.Peer

func (*RegionLeaderResponse) Marshal

func (m *RegionLeaderResponse) Marshal() (data []byte, err error)

func (*RegionLeaderResponse) MarshalTo

func (m *RegionLeaderResponse) MarshalTo(data []byte) (int, error)

func (*RegionLeaderResponse) ProtoMessage

func (*RegionLeaderResponse) ProtoMessage()

func (*RegionLeaderResponse) Reset

func (m *RegionLeaderResponse) Reset()

func (*RegionLeaderResponse) Size

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

func (*RegionLeaderResponse) String

func (m *RegionLeaderResponse) String() string

func (*RegionLeaderResponse) Unmarshal

func (m *RegionLeaderResponse) Unmarshal(data []byte) error

type Request

type Request struct {
	CmdType          *CmdType       `protobuf:"varint,1,opt,name=cmd_type,enum=raft_cmdpb.CmdType" json:"cmd_type,omitempty"`
	Get              *GetRequest    `protobuf:"bytes,2,opt,name=get" json:"get,omitempty"`
	Put              *PutRequest    `protobuf:"bytes,4,opt,name=put" json:"put,omitempty"`
	Delete           *DeleteRequest `protobuf:"bytes,5,opt,name=delete" json:"delete,omitempty"`
	Snap             *SnapRequest   `protobuf:"bytes,6,opt,name=snap" json:"snap,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*Request) Descriptor

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

func (*Request) GetCmdType

func (m *Request) GetCmdType() CmdType

func (*Request) GetDelete

func (m *Request) GetDelete() *DeleteRequest

func (*Request) GetGet

func (m *Request) GetGet() *GetRequest

func (*Request) GetPut

func (m *Request) GetPut() *PutRequest

func (*Request) GetSnap

func (m *Request) GetSnap() *SnapRequest

func (*Request) Marshal

func (m *Request) Marshal() (data []byte, err error)

func (*Request) MarshalTo

func (m *Request) MarshalTo(data []byte) (int, error)

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) Reset

func (m *Request) Reset()

func (*Request) Size

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

func (*Request) String

func (m *Request) String() string

func (*Request) Unmarshal

func (m *Request) Unmarshal(data []byte) error

type Response

type Response struct {
	CmdType          *CmdType        `protobuf:"varint,1,opt,name=cmd_type,enum=raft_cmdpb.CmdType" json:"cmd_type,omitempty"`
	Get              *GetResponse    `protobuf:"bytes,2,opt,name=get" json:"get,omitempty"`
	Put              *PutResponse    `protobuf:"bytes,4,opt,name=put" json:"put,omitempty"`
	Delete           *DeleteResponse `protobuf:"bytes,5,opt,name=delete" json:"delete,omitempty"`
	Snap             *SnapResponse   `protobuf:"bytes,6,opt,name=snap" json:"snap,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*Response) Descriptor

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

func (*Response) GetCmdType

func (m *Response) GetCmdType() CmdType

func (*Response) GetDelete

func (m *Response) GetDelete() *DeleteResponse

func (*Response) GetGet

func (m *Response) GetGet() *GetResponse

func (*Response) GetPut

func (m *Response) GetPut() *PutResponse

func (*Response) GetSnap

func (m *Response) GetSnap() *SnapResponse

func (*Response) Marshal

func (m *Response) Marshal() (data []byte, err error)

func (*Response) MarshalTo

func (m *Response) MarshalTo(data []byte) (int, error)

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) Reset

func (m *Response) Reset()

func (*Response) Size

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

func (*Response) String

func (m *Response) String() string

func (*Response) Unmarshal

func (m *Response) Unmarshal(data []byte) error

type SnapRequest

type SnapRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*SnapRequest) Descriptor

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

func (*SnapRequest) Marshal

func (m *SnapRequest) Marshal() (data []byte, err error)

func (*SnapRequest) MarshalTo

func (m *SnapRequest) MarshalTo(data []byte) (int, error)

func (*SnapRequest) ProtoMessage

func (*SnapRequest) ProtoMessage()

func (*SnapRequest) Reset

func (m *SnapRequest) Reset()

func (*SnapRequest) Size

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

func (*SnapRequest) String

func (m *SnapRequest) String() string

func (*SnapRequest) Unmarshal

func (m *SnapRequest) Unmarshal(data []byte) error

type SnapResponse

type SnapResponse struct {
	Region           *metapb.Region `protobuf:"bytes,1,opt,name=region" json:"region,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*SnapResponse) Descriptor

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

func (*SnapResponse) GetRegion

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

func (*SnapResponse) Marshal

func (m *SnapResponse) Marshal() (data []byte, err error)

func (*SnapResponse) MarshalTo

func (m *SnapResponse) MarshalTo(data []byte) (int, error)

func (*SnapResponse) ProtoMessage

func (*SnapResponse) ProtoMessage()

func (*SnapResponse) Reset

func (m *SnapResponse) Reset()

func (*SnapResponse) Size

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

func (*SnapResponse) String

func (m *SnapResponse) String() string

func (*SnapResponse) Unmarshal

func (m *SnapResponse) Unmarshal(data []byte) error

type SplitRequest

type SplitRequest struct {
	// This can be only called in internal RaftStore now.
	// The split_key must be in the been splitting region.
	// If the split_key is none, we will choose a proper key
	// to split the region in half.
	SplitKey []byte `protobuf:"bytes,1,opt,name=split_key" json:"split_key,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:"new_region_id,omitempty"`
	// The peer ids for the new split region.
	NewPeerIds       []uint64 `protobuf:"varint,3,rep,name=new_peer_ids" json:"new_peer_ids,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*SplitRequest) Descriptor

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

func (*SplitRequest) GetNewPeerIds

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

func (*SplitRequest) GetNewRegionId

func (m *SplitRequest) GetNewRegionId() uint64

func (*SplitRequest) GetSplitKey

func (m *SplitRequest) GetSplitKey() []byte

func (*SplitRequest) Marshal

func (m *SplitRequest) Marshal() (data []byte, err error)

func (*SplitRequest) MarshalTo

func (m *SplitRequest) MarshalTo(data []byte) (int, error)

func (*SplitRequest) ProtoMessage

func (*SplitRequest) ProtoMessage()

func (*SplitRequest) Reset

func (m *SplitRequest) Reset()

func (*SplitRequest) Size

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

func (*SplitRequest) String

func (m *SplitRequest) String() string

func (*SplitRequest) Unmarshal

func (m *SplitRequest) Unmarshal(data []byte) error

type SplitResponse

type SplitResponse struct {
	Left             *metapb.Region `protobuf:"bytes,1,opt,name=left" json:"left,omitempty"`
	Right            *metapb.Region `protobuf:"bytes,2,opt,name=right" json:"right,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*SplitResponse) Descriptor

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

func (*SplitResponse) GetLeft

func (m *SplitResponse) GetLeft() *metapb.Region

func (*SplitResponse) GetRight

func (m *SplitResponse) GetRight() *metapb.Region

func (*SplitResponse) Marshal

func (m *SplitResponse) Marshal() (data []byte, err error)

func (*SplitResponse) MarshalTo

func (m *SplitResponse) MarshalTo(data []byte) (int, error)

func (*SplitResponse) ProtoMessage

func (*SplitResponse) ProtoMessage()

func (*SplitResponse) Reset

func (m *SplitResponse) Reset()

func (*SplitResponse) Size

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

func (*SplitResponse) String

func (m *SplitResponse) String() string

func (*SplitResponse) Unmarshal

func (m *SplitResponse) Unmarshal(data []byte) error

type StatusCmdType

type StatusCmdType int32
const (
	StatusCmdType_InvalidStatus StatusCmdType = 0
	StatusCmdType_RegionLeader  StatusCmdType = 1
	StatusCmdType_RegionDetail  StatusCmdType = 2
)

func (StatusCmdType) Enum

func (x StatusCmdType) Enum() *StatusCmdType

func (StatusCmdType) EnumDescriptor

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

func (StatusCmdType) String

func (x StatusCmdType) String() string

func (*StatusCmdType) UnmarshalJSON

func (x *StatusCmdType) UnmarshalJSON(data []byte) error

type StatusRequest

type StatusRequest struct {
	CmdType          *StatusCmdType       `protobuf:"varint,1,opt,name=cmd_type,enum=raft_cmdpb.StatusCmdType" json:"cmd_type,omitempty"`
	RegionLeader     *RegionLeaderRequest `protobuf:"bytes,2,opt,name=region_leader" json:"region_leader,omitempty"`
	RegionDetail     *RegionDetailRequest `protobuf:"bytes,3,opt,name=region_detail" json:"region_detail,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*StatusRequest) Descriptor

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

func (*StatusRequest) GetCmdType

func (m *StatusRequest) GetCmdType() StatusCmdType

func (*StatusRequest) GetRegionDetail

func (m *StatusRequest) GetRegionDetail() *RegionDetailRequest

func (*StatusRequest) GetRegionLeader

func (m *StatusRequest) GetRegionLeader() *RegionLeaderRequest

func (*StatusRequest) Marshal

func (m *StatusRequest) Marshal() (data []byte, err error)

func (*StatusRequest) MarshalTo

func (m *StatusRequest) MarshalTo(data []byte) (int, error)

func (*StatusRequest) ProtoMessage

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) Reset

func (m *StatusRequest) Reset()

func (*StatusRequest) Size

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

func (*StatusRequest) String

func (m *StatusRequest) String() string

func (*StatusRequest) Unmarshal

func (m *StatusRequest) Unmarshal(data []byte) error

type StatusResponse

type StatusResponse struct {
	CmdType          *StatusCmdType        `protobuf:"varint,1,opt,name=cmd_type,enum=raft_cmdpb.StatusCmdType" json:"cmd_type,omitempty"`
	RegionLeader     *RegionLeaderResponse `protobuf:"bytes,2,opt,name=region_leader" json:"region_leader,omitempty"`
	RegionDetail     *RegionDetailResponse `protobuf:"bytes,3,opt,name=region_detail" json:"region_detail,omitempty"`
	XXX_unrecognized []byte                `json:"-"`
}

func (*StatusResponse) Descriptor

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

func (*StatusResponse) GetCmdType

func (m *StatusResponse) GetCmdType() StatusCmdType

func (*StatusResponse) GetRegionDetail

func (m *StatusResponse) GetRegionDetail() *RegionDetailResponse

func (*StatusResponse) GetRegionLeader

func (m *StatusResponse) GetRegionLeader() *RegionLeaderResponse

func (*StatusResponse) Marshal

func (m *StatusResponse) Marshal() (data []byte, err error)

func (*StatusResponse) MarshalTo

func (m *StatusResponse) MarshalTo(data []byte) (int, error)

func (*StatusResponse) ProtoMessage

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) Reset

func (m *StatusResponse) Reset()

func (*StatusResponse) Size

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

func (*StatusResponse) String

func (m *StatusResponse) String() string

func (*StatusResponse) Unmarshal

func (m *StatusResponse) Unmarshal(data []byte) error

type TransferLeaderRequest

type TransferLeaderRequest struct {
	Peer             *metapb.Peer `protobuf:"bytes,1,opt,name=peer" json:"peer,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*TransferLeaderRequest) Descriptor

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

func (*TransferLeaderRequest) GetPeer

func (m *TransferLeaderRequest) GetPeer() *metapb.Peer

func (*TransferLeaderRequest) Marshal

func (m *TransferLeaderRequest) Marshal() (data []byte, err error)

func (*TransferLeaderRequest) MarshalTo

func (m *TransferLeaderRequest) MarshalTo(data []byte) (int, error)

func (*TransferLeaderRequest) ProtoMessage

func (*TransferLeaderRequest) ProtoMessage()

func (*TransferLeaderRequest) Reset

func (m *TransferLeaderRequest) Reset()

func (*TransferLeaderRequest) Size

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

func (*TransferLeaderRequest) String

func (m *TransferLeaderRequest) String() string

func (*TransferLeaderRequest) Unmarshal

func (m *TransferLeaderRequest) Unmarshal(data []byte) error

type TransferLeaderResponse

type TransferLeaderResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*TransferLeaderResponse) Descriptor

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

func (*TransferLeaderResponse) Marshal

func (m *TransferLeaderResponse) Marshal() (data []byte, err error)

func (*TransferLeaderResponse) MarshalTo

func (m *TransferLeaderResponse) MarshalTo(data []byte) (int, error)

func (*TransferLeaderResponse) ProtoMessage

func (*TransferLeaderResponse) ProtoMessage()

func (*TransferLeaderResponse) Reset

func (m *TransferLeaderResponse) Reset()

func (*TransferLeaderResponse) Size

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

func (*TransferLeaderResponse) String

func (m *TransferLeaderResponse) String() string

func (*TransferLeaderResponse) Unmarshal

func (m *TransferLeaderResponse) Unmarshal(data []byte) error

Jump to

Keyboard shortcuts

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