raft_cmdpb

package
v0.6.4 Latest Latest
Warning

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

 Go to latest Published: Aug 1, 2018 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: 

SplitRequest
SplitResponse
MergeRequest
MergeResponse
LeaderChangeRequest
LeaderChangeResponse
CmdID
Command
PeerTask
SnapshotKVPair
SnapshotContext

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 CmdType_name = map[int32]string{
	0:  "Invalid",
	1:  "RawGet",
	2:  "RawPut",
	3:  "RawDelete",
	4:  "RawExecute",
	7:  "Select",
	8:  "Insert",
	9:  "Delete",
	10: "Update",
	11: "Replace",
	12: "BatchInsert",
	13: "KvSet",
	14: "KvGet",
	15: "KvBatchSet",
	16: "KvBatchGet",
	17: "KvScan",
	18: "KvDelete",
	19: "KvBatchDel",
	20: "KvRangeDel",
	30: "AdminSplit",
	31: "AdminMerge",
	32: "AdminLeaderChange",
	40: "Lock",
	41: "LockUpdate",
	42: "Unlock",
	43: "UnlockForce",
}
View Source 
var CmdType_value = map[string]int32{
	"Invalid":           0,
	"RawGet":            1,
	"RawPut":            2,
	"RawDelete":         3,
	"RawExecute":        4,
	"Select":            7,
	"Insert":            8,
	"Delete":            9,
	"Update":            10,
	"Replace":           11,
	"BatchInsert":       12,
	"KvSet":             13,
	"KvGet":             14,
	"KvBatchSet":        15,
	"KvBatchGet":        16,
	"KvScan":            17,
	"KvDelete":          18,
	"KvBatchDel":        19,
	"KvRangeDel":        20,
	"AdminSplit":        30,
	"AdminMerge":        31,
	"AdminLeaderChange": 32,
	"Lock":              40,
	"LockUpdate":        41,
	"Unlock":            42,
	"UnlockForce":       43,
}

Functions

This section is empty.

Types

type CmdID 

type CmdID struct {
	NodeId uint64 `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Seq    uint64 `protobuf:"varint,2,opt,name=seq,proto3" json:"seq,omitempty"`
}

func (*CmdID) Descriptor 

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

func (*CmdID) GetNodeId 

func (m *CmdID) GetNodeId() uint64

func (*CmdID) GetSeq 

func (m *CmdID) GetSeq() uint64

func (*CmdID) Marshal 

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

func (*CmdID) MarshalTo 

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

func (*CmdID) ProtoMessage 

func (*CmdID) ProtoMessage()

func (*CmdID) Reset 

func (m *CmdID) Reset()

func (*CmdID) Size 

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

func (*CmdID) String 

func (m *CmdID) String() string

func (*CmdID) Unmarshal 

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

type CmdType 

type CmdType int32
const (
	CmdType_Invalid           CmdType = 0
	CmdType_RawGet            CmdType = 1
	CmdType_RawPut            CmdType = 2
	CmdType_RawDelete         CmdType = 3
	CmdType_RawExecute        CmdType = 4
	CmdType_Select            CmdType = 7
	CmdType_Insert            CmdType = 8
	CmdType_Delete            CmdType = 9
	CmdType_Update            CmdType = 10
	CmdType_Replace           CmdType = 11
	CmdType_BatchInsert       CmdType = 12
	CmdType_KvSet             CmdType = 13
	CmdType_KvGet             CmdType = 14
	CmdType_KvBatchSet        CmdType = 15
	CmdType_KvBatchGet        CmdType = 16
	CmdType_KvScan            CmdType = 17
	CmdType_KvDelete          CmdType = 18
	CmdType_KvBatchDel        CmdType = 19
	CmdType_KvRangeDel        CmdType = 20
	CmdType_AdminSplit        CmdType = 30
	CmdType_AdminMerge        CmdType = 31
	CmdType_AdminLeaderChange CmdType = 32
	CmdType_Lock              CmdType = 40
	CmdType_LockUpdate        CmdType = 41
	CmdType_Unlock            CmdType = 42
	CmdType_UnlockForce       CmdType = 43
)

func (CmdType) EnumDescriptor 

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

func (CmdType) String 

func (x CmdType) String() string

type Command 

type Command struct {
	CmdId                *CmdID                        `protobuf:"bytes,1,opt,name=cmd_id,json=cmdId" json:"cmd_id,omitempty"`
	CmdType              CmdType                       `protobuf:"varint,2,opt,name=cmd_type,json=cmdType,proto3,enum=raft_cmdpb.CmdType" json:"cmd_type,omitempty"`
	VerifyEpoch          *metapb.RangeEpoch            `protobuf:"bytes,3,opt,name=verify_epoch,json=verifyEpoch" json:"verify_epoch,omitempty"`
	KvRawGetReq          *kvrpcpb.KvRawGetRequest      `protobuf:"bytes,4,opt,name=kv_raw_get_req,json=kvRawGetReq" json:"kv_raw_get_req,omitempty"`
	KvRawPutReq          *kvrpcpb.KvRawPutRequest      `protobuf:"bytes,5,opt,name=kv_raw_put_req,json=kvRawPutReq" json:"kv_raw_put_req,omitempty"`
	KvRawDeleteReq       *kvrpcpb.KvRawDeleteRequest   `protobuf:"bytes,6,opt,name=kv_raw_delete_req,json=kvRawDeleteReq" json:"kv_raw_delete_req,omitempty"`
	KvRawExecuteReq      *kvrpcpb.KvRawExecuteRequest  `protobuf:"bytes,7,opt,name=kv_raw_execute_req,json=kvRawExecuteReq" json:"kv_raw_execute_req,omitempty"`
	SelectReq            *kvrpcpb.SelectRequest        `protobuf:"bytes,8,opt,name=select_req,json=selectReq" json:"select_req,omitempty"`
	InsertReq            *kvrpcpb.InsertRequest        `protobuf:"bytes,9,opt,name=insert_req,json=insertReq" json:"insert_req,omitempty"`
	DeleteReq            *kvrpcpb.DeleteRequest        `protobuf:"bytes,10,opt,name=delete_req,json=deleteReq" json:"delete_req,omitempty"`
	BatchInsertReq       *kvrpcpb.BatchInsertRequest   `protobuf:"bytes,11,opt,name=batch_insert_req,json=batchInsertReq" json:"batch_insert_req,omitempty"`
	KvSetReq             *kvrpcpb.KvSetRequest         `protobuf:"bytes,12,opt,name=kv_set_req,json=kvSetReq" json:"kv_set_req,omitempty"`
	KvGetReq             *kvrpcpb.KvGetRequest         `protobuf:"bytes,13,opt,name=kv_get_req,json=kvGetReq" json:"kv_get_req,omitempty"`
	KvBatchSetReq        *kvrpcpb.KvBatchSetRequest    `protobuf:"bytes,14,opt,name=kv_batch_set_req,json=kvBatchSetReq" json:"kv_batch_set_req,omitempty"`
	KvBatchGetReq        *kvrpcpb.KvBatchGetRequest    `protobuf:"bytes,15,opt,name=kv_batch_get_req,json=kvBatchGetReq" json:"kv_batch_get_req,omitempty"`
	KvScanReq            *kvrpcpb.KvScanRequest        `protobuf:"bytes,16,opt,name=kv_scan_req,json=kvScanReq" json:"kv_scan_req,omitempty"`
	KvDeleteReq          *kvrpcpb.KvDeleteRequest      `protobuf:"bytes,17,opt,name=kv_delete_req,json=kvDeleteReq" json:"kv_delete_req,omitempty"`
	KvBatchDelReq        *kvrpcpb.KvBatchDeleteRequest `protobuf:"bytes,18,opt,name=kv_batch_del_req,json=kvBatchDelReq" json:"kv_batch_del_req,omitempty"`
	KvRangeDelReq        *kvrpcpb.KvRangeDeleteRequest `protobuf:"bytes,19,opt,name=kv_range_del_req,json=kvRangeDelReq" json:"kv_range_del_req,omitempty"`
	AdminSplitReq        *SplitRequest                 `protobuf:"bytes,30,opt,name=admin_split_req,json=adminSplitReq" json:"admin_split_req,omitempty"`
	AdminMergeReq        *MergeRequest                 `protobuf:"bytes,31,opt,name=admin_merge_req,json=adminMergeReq" json:"admin_merge_req,omitempty"`
	AdminLeaderChangeReq *LeaderChangeRequest          `protobuf:"bytes,32,opt,name=admin_leader_change_req,json=adminLeaderChangeReq" json:"admin_leader_change_req,omitempty"`
	LockReq              *kvrpcpb.LockRequest          `protobuf:"bytes,40,opt,name=lock_req,json=lockReq" json:"lock_req,omitempty"`
	LockUpdateReq        *kvrpcpb.LockUpdateRequest    `protobuf:"bytes,41,opt,name=lock_update_req,json=lockUpdateReq" json:"lock_update_req,omitempty"`
	UnlockReq            *kvrpcpb.UnlockRequest        `protobuf:"bytes,42,opt,name=unlock_req,json=unlockReq" json:"unlock_req,omitempty"`
	UnlockForceReq       *kvrpcpb.UnlockForceRequest   `protobuf:"bytes,43,opt,name=unlock_force_req,json=unlockForceReq" json:"unlock_force_req,omitempty"`
}

func (*Command) Descriptor 

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

func (*Command) GetAdminLeaderChangeReq 

func (m *Command) GetAdminLeaderChangeReq() *LeaderChangeRequest

func (*Command) GetAdminMergeReq 

func (m *Command) GetAdminMergeReq() *MergeRequest

func (*Command) GetAdminSplitReq 

func (m *Command) GetAdminSplitReq() *SplitRequest

func (*Command) GetBatchInsertReq 

func (m *Command) GetBatchInsertReq() *kvrpcpb.BatchInsertRequest

func (*Command) GetCmdId 

func (m *Command) GetCmdId() *CmdID

func (*Command) GetCmdType 

func (m *Command) GetCmdType() CmdType

func (*Command) GetDeleteReq 

func (m *Command) GetDeleteReq() *kvrpcpb.DeleteRequest

func (*Command) GetInsertReq 

func (m *Command) GetInsertReq() *kvrpcpb.InsertRequest

func (*Command) GetKvBatchDelReq 

func (m *Command) GetKvBatchDelReq() *kvrpcpb.KvBatchDeleteRequest

func (*Command) GetKvBatchGetReq 

func (m *Command) GetKvBatchGetReq() *kvrpcpb.KvBatchGetRequest

func (*Command) GetKvBatchSetReq 

func (m *Command) GetKvBatchSetReq() *kvrpcpb.KvBatchSetRequest

func (*Command) GetKvDeleteReq 

func (m *Command) GetKvDeleteReq() *kvrpcpb.KvDeleteRequest

func (*Command) GetKvGetReq 

func (m *Command) GetKvGetReq() *kvrpcpb.KvGetRequest

func (*Command) GetKvRangeDelReq 

func (m *Command) GetKvRangeDelReq() *kvrpcpb.KvRangeDeleteRequest

func (*Command) GetKvRawDeleteReq 

func (m *Command) GetKvRawDeleteReq() *kvrpcpb.KvRawDeleteRequest

func (*Command) GetKvRawExecuteReq 

func (m *Command) GetKvRawExecuteReq() *kvrpcpb.KvRawExecuteRequest

func (*Command) GetKvRawGetReq 

func (m *Command) GetKvRawGetReq() *kvrpcpb.KvRawGetRequest

func (*Command) GetKvRawPutReq 

func (m *Command) GetKvRawPutReq() *kvrpcpb.KvRawPutRequest

func (*Command) GetKvScanReq 

func (m *Command) GetKvScanReq() *kvrpcpb.KvScanRequest

func (*Command) GetKvSetReq 

func (m *Command) GetKvSetReq() *kvrpcpb.KvSetRequest

func (*Command) GetLockReq 

func (m *Command) GetLockReq() *kvrpcpb.LockRequest

func (*Command) GetLockUpdateReq 

func (m *Command) GetLockUpdateReq() *kvrpcpb.LockUpdateRequest

func (*Command) GetSelectReq 

func (m *Command) GetSelectReq() *kvrpcpb.SelectRequest

func (*Command) GetUnlockForceReq 

func (m *Command) GetUnlockForceReq() *kvrpcpb.UnlockForceRequest

func (*Command) GetUnlockReq 

func (m *Command) GetUnlockReq() *kvrpcpb.UnlockRequest

func (*Command) GetVerifyEpoch 

func (m *Command) GetVerifyEpoch() *metapb.RangeEpoch

func (*Command) Marshal 

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

func (*Command) MarshalTo 

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

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) Reset 

func (m *Command) Reset()

func (*Command) Size 

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

func (*Command) String 

func (m *Command) String() string

func (*Command) Unmarshal 

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

type LeaderChangeRequest 

type LeaderChangeRequest struct {
	RangeId uint64             `protobuf:"varint,1,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
	Epoch   *metapb.RangeEpoch `protobuf:"bytes,2,opt,name=epoch" json:"epoch,omitempty"`
}

func (*LeaderChangeRequest) Descriptor 

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

func (*LeaderChangeRequest) GetEpoch 

func (m *LeaderChangeRequest) GetEpoch() *metapb.RangeEpoch

func (*LeaderChangeRequest) GetRangeId 

func (m *LeaderChangeRequest) GetRangeId() uint64

func (*LeaderChangeRequest) Marshal 

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

func (*LeaderChangeRequest) MarshalTo 

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

func (*LeaderChangeRequest) ProtoMessage 

func (*LeaderChangeRequest) ProtoMessage()

func (*LeaderChangeRequest) Reset 

func (m *LeaderChangeRequest) Reset()

func (*LeaderChangeRequest) Size 

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

func (*LeaderChangeRequest) String 

func (m *LeaderChangeRequest) String() string

func (*LeaderChangeRequest) Unmarshal 

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

type LeaderChangeResponse 

type LeaderChangeResponse struct {
}

func (*LeaderChangeResponse) Descriptor 

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

func (*LeaderChangeResponse) Marshal 

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

func (*LeaderChangeResponse) MarshalTo 

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

func (*LeaderChangeResponse) ProtoMessage 

func (*LeaderChangeResponse) ProtoMessage()

func (*LeaderChangeResponse) Reset 

func (m *LeaderChangeResponse) Reset()

func (*LeaderChangeResponse) Size 

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

func (*LeaderChangeResponse) String 

func (m *LeaderChangeResponse) String() string

func (*LeaderChangeResponse) Unmarshal 

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

type MergeRequest 

type MergeRequest struct {
}

func (*MergeRequest) Descriptor 

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

func (*MergeRequest) Marshal 

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

func (*MergeRequest) MarshalTo 

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

func (*MergeRequest) ProtoMessage 

func (*MergeRequest) ProtoMessage()

func (*MergeRequest) Reset 

func (m *MergeRequest) Reset()

func (*MergeRequest) Size 

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

func (*MergeRequest) String 

func (m *MergeRequest) String() string

func (*MergeRequest) Unmarshal 

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

type MergeResponse 

type MergeResponse struct {
}

func (*MergeResponse) Descriptor 

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

func (*MergeResponse) Marshal 

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

func (*MergeResponse) MarshalTo 

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

func (*MergeResponse) ProtoMessage 

func (*MergeResponse) ProtoMessage()

func (*MergeResponse) Reset 

func (m *MergeResponse) Reset()

func (*MergeResponse) Size 

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

func (*MergeResponse) String 

func (m *MergeResponse) String() string

func (*MergeResponse) Unmarshal 

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

type PeerTask 

type PeerTask struct {
	VerifyEpoch *metapb.RangeEpoch `protobuf:"bytes,1,opt,name=verify_epoch,json=verifyEpoch" json:"verify_epoch,omitempty"`
	Peer        *metapb.Peer       `protobuf:"bytes,2,opt,name=peer" json:"peer,omitempty"`
}

func (*PeerTask) Descriptor 

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

func (*PeerTask) GetPeer 

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

func (*PeerTask) GetVerifyEpoch 

func (m *PeerTask) GetVerifyEpoch() *metapb.RangeEpoch

func (*PeerTask) Marshal 

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

func (*PeerTask) MarshalTo 

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

func (*PeerTask) ProtoMessage 

func (*PeerTask) ProtoMessage()

func (*PeerTask) Reset 

func (m *PeerTask) Reset()

func (*PeerTask) Size 

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

func (*PeerTask) String 

func (m *PeerTask) String() string

func (*PeerTask) Unmarshal 

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

type SnapshotContext 

type SnapshotContext struct {
	Meta *metapb.Range `protobuf:"bytes,1,opt,name=meta" json:"meta,omitempty"`
}

func (*SnapshotContext) Descriptor 

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

func (*SnapshotContext) GetMeta 

func (m *SnapshotContext) GetMeta() *metapb.Range

func (*SnapshotContext) Marshal 

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

func (*SnapshotContext) MarshalTo 

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

func (*SnapshotContext) ProtoMessage 

func (*SnapshotContext) ProtoMessage()

func (*SnapshotContext) Reset 

func (m *SnapshotContext) Reset()

func (*SnapshotContext) Size 

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

func (*SnapshotContext) String 

func (m *SnapshotContext) String() string

func (*SnapshotContext) Unmarshal 

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

type SnapshotKVPair 

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

func (*SnapshotKVPair) Descriptor 

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

func (*SnapshotKVPair) GetKey 

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

func (*SnapshotKVPair) GetValue 

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

func (*SnapshotKVPair) Marshal 

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

func (*SnapshotKVPair) MarshalTo 

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

func (*SnapshotKVPair) ProtoMessage 

func (*SnapshotKVPair) ProtoMessage()

func (*SnapshotKVPair) Reset 

func (m *SnapshotKVPair) Reset()

func (*SnapshotKVPair) Size 

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

func (*SnapshotKVPair) String 

func (m *SnapshotKVPair) String() string

func (*SnapshotKVPair) Unmarshal 

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

type SplitRequest 

type SplitRequest struct {
	Leader   uint64             `protobuf:"varint,1,opt,name=leader,proto3" json:"leader,omitempty"`
	SplitKey []byte             `protobuf:"bytes,2,opt,name=split_key,json=splitKey,proto3" json:"split_key,omitempty"`
	Epoch    *metapb.RangeEpoch `protobuf:"bytes,3,opt,name=epoch" json:"epoch,omitempty"`
	NewRange *metapb.Range      `protobuf:"bytes,4,opt,name=new_range,json=newRange" json:"new_range,omitempty"`
}

func (*SplitRequest) Descriptor 

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

func (*SplitRequest) GetEpoch 

func (m *SplitRequest) GetEpoch() *metapb.RangeEpoch

func (*SplitRequest) GetLeader 

func (m *SplitRequest) GetLeader() uint64

func (*SplitRequest) GetNewRange 

func (m *SplitRequest) GetNewRange() *metapb.Range

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 {
}

func (*SplitResponse) Descriptor 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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