taskpb

package
v0.7.3 Latest Latest
Warning

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

 Go to latest Published: Aug 16, 2018 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package taskpb is a generated protocol buffer package.

It is generated from these files: 

taskpb.proto

It has these top-level messages: 

TaskRangeMerge
TaskRangeDelete
TaskRangeLeaderTransfer
TaskRangeAddPeer
TaskRangeDelPeer
Task

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthTaskpb = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTaskpb   = fmt.Errorf("proto: integer overflow")
)
View Source 
var TaskType_name = map[int32]string{
	0: "EmptyTask",
	1: "RangeMerge",
	2: "RangeDelete",
	3: "RangeLeaderTransfer",
	4: "RangeAddPeer",
	5: "RangeDelPeer",
}
View Source 
var TaskType_value = map[string]int32{
	"EmptyTask":           0,
	"RangeMerge":          1,
	"RangeDelete":         2,
	"RangeLeaderTransfer": 3,
	"RangeAddPeer":        4,
	"RangeDelPeer":        5,
}

Functions

This section is empty.

Types

type Task 

type Task struct {
	Type                TaskType                 `protobuf:"varint,1,opt,name=type,proto3,enum=taskpb.TaskType" json:"type,omitempty"`
	RangeMerge          *TaskRangeMerge          `protobuf:"bytes,2,opt,name=range_merge,json=rangeMerge" json:"range_merge,omitempty"`
	RangeDelete         *TaskRangeDelete         `protobuf:"bytes,3,opt,name=range_delete,json=rangeDelete" json:"range_delete,omitempty"`
	RangeLeaderTransfer *TaskRangeLeaderTransfer `protobuf:"bytes,4,opt,name=range_leader_transfer,json=rangeLeaderTransfer" json:"range_leader_transfer,omitempty"`
	RangeAddPeer        *TaskRangeAddPeer        `protobuf:"bytes,5,opt,name=range_add_peer,json=rangeAddPeer" json:"range_add_peer,omitempty"`
	RangeDelPeer        *TaskRangeDelPeer        `protobuf:"bytes,6,opt,name=range_del_peer,json=rangeDelPeer" json:"range_del_peer,omitempty"`
}

func (*Task) Descriptor 

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

func (*Task) GetRangeAddPeer 

func (m *Task) GetRangeAddPeer() *TaskRangeAddPeer

func (*Task) GetRangeDelPeer 

func (m *Task) GetRangeDelPeer() *TaskRangeDelPeer

func (*Task) GetRangeDelete 

func (m *Task) GetRangeDelete() *TaskRangeDelete

func (*Task) GetRangeLeaderTransfer 

func (m *Task) GetRangeLeaderTransfer() *TaskRangeLeaderTransfer

func (*Task) GetRangeMerge 

func (m *Task) GetRangeMerge() *TaskRangeMerge

func (*Task) GetType 

func (m *Task) GetType() TaskType

func (*Task) Marshal 

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

func (*Task) MarshalTo 

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

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) Reset 

func (m *Task) Reset()

func (*Task) Size 

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

func (*Task) String 

func (m *Task) String() string

func (*Task) Unmarshal 

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

type TaskRangeAddPeer 

type TaskRangeAddPeer struct {
	Peer *metapb.Peer `protobuf:"bytes,1,opt,name=peer" json:"peer,omitempty"`
}

func (*TaskRangeAddPeer) Descriptor 

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

func (*TaskRangeAddPeer) GetPeer 

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

func (*TaskRangeAddPeer) Marshal 

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

func (*TaskRangeAddPeer) MarshalTo 

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

func (*TaskRangeAddPeer) ProtoMessage 

func (*TaskRangeAddPeer) ProtoMessage()

func (*TaskRangeAddPeer) Reset 

func (m *TaskRangeAddPeer) Reset()

func (*TaskRangeAddPeer) Size 

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

func (*TaskRangeAddPeer) String 

func (m *TaskRangeAddPeer) String() string

func (*TaskRangeAddPeer) Unmarshal 

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

type TaskRangeDelPeer 

type TaskRangeDelPeer struct {
	Peer *metapb.Peer `protobuf:"bytes,1,opt,name=peer" json:"peer,omitempty"`
}

func (*TaskRangeDelPeer) Descriptor 

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

func (*TaskRangeDelPeer) GetPeer 

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

func (*TaskRangeDelPeer) Marshal 

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

func (*TaskRangeDelPeer) MarshalTo 

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

func (*TaskRangeDelPeer) ProtoMessage 

func (*TaskRangeDelPeer) ProtoMessage()

func (*TaskRangeDelPeer) Reset 

func (m *TaskRangeDelPeer) Reset()

func (*TaskRangeDelPeer) Size 

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

func (*TaskRangeDelPeer) String 

func (m *TaskRangeDelPeer) String() string

func (*TaskRangeDelPeer) Unmarshal 

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

type TaskRangeDelete 

type TaskRangeDelete struct {
	RangeId uint64 `protobuf:"varint,1,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
}

func (*TaskRangeDelete) Descriptor 

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

func (*TaskRangeDelete) GetRangeId 

func (m *TaskRangeDelete) GetRangeId() uint64

func (*TaskRangeDelete) Marshal 

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

func (*TaskRangeDelete) MarshalTo 

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

func (*TaskRangeDelete) ProtoMessage 

func (*TaskRangeDelete) ProtoMessage()

func (*TaskRangeDelete) Reset 

func (m *TaskRangeDelete) Reset()

func (*TaskRangeDelete) Size 

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

func (*TaskRangeDelete) String 

func (m *TaskRangeDelete) String() string

func (*TaskRangeDelete) Unmarshal 

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

type TaskRangeLeaderTransfer 

type TaskRangeLeaderTransfer struct {
	ExpLeader *metapb.Peer `protobuf:"bytes,1,opt,name=exp_leader,json=expLeader" json:"exp_leader,omitempty"`
}

func (*TaskRangeLeaderTransfer) Descriptor 

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

func (*TaskRangeLeaderTransfer) GetExpLeader 

func (m *TaskRangeLeaderTransfer) GetExpLeader() *metapb.Peer

func (*TaskRangeLeaderTransfer) Marshal 

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

func (*TaskRangeLeaderTransfer) MarshalTo 

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

func (*TaskRangeLeaderTransfer) ProtoMessage 

func (*TaskRangeLeaderTransfer) ProtoMessage()

func (*TaskRangeLeaderTransfer) Reset 

func (m *TaskRangeLeaderTransfer) Reset()

func (*TaskRangeLeaderTransfer) Size 

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

func (*TaskRangeLeaderTransfer) String 

func (m *TaskRangeLeaderTransfer) String() string

func (*TaskRangeLeaderTransfer) Unmarshal 

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

type TaskRangeMerge 

type TaskRangeMerge struct {
}

TODO range merge

func (*TaskRangeMerge) Descriptor 

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

func (*TaskRangeMerge) Marshal 

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

func (*TaskRangeMerge) MarshalTo 

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

func (*TaskRangeMerge) ProtoMessage 

func (*TaskRangeMerge) ProtoMessage()

func (*TaskRangeMerge) Reset 

func (m *TaskRangeMerge) Reset()

func (*TaskRangeMerge) Size 

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

func (*TaskRangeMerge) String 

func (m *TaskRangeMerge) String() string

func (*TaskRangeMerge) Unmarshal 

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

type TaskType 

type TaskType int32
const (
	TaskType_EmptyTask           TaskType = 0
	TaskType_RangeMerge          TaskType = 1
	TaskType_RangeDelete         TaskType = 2
	TaskType_RangeLeaderTransfer TaskType = 3
	TaskType_RangeAddPeer        TaskType = 4
	TaskType_RangeDelPeer        TaskType = 5
)

func (TaskType) EnumDescriptor 

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

func (TaskType) String 

func (x TaskType) String() string

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.