rpcpb

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Oct 13, 2021 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRpcpb = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRpcpb   = fmt.Errorf("proto: integer overflow")
)
View Source 
var LabelConstraintOp_name = map[int32]string{
	0: "In",
	1: "NotIn",
	2: "Exists",
	3: "NotExists",
}
View Source 
var LabelConstraintOp_value = map[string]int32{
	"In":        0,
	"NotIn":     1,
	"Exists":    2,
	"NotExists": 3,
}
View Source 
var PeerRoleType_name = map[int32]string{
	0: "Voter",
	1: "Leader",
	2: "Follower",
	3: "Learner",
}
View Source 
var PeerRoleType_value = map[string]int32{
	"Voter":    0,
	"Leader":   1,
	"Follower": 2,
	"Learner":  3,
}
View Source 
var Type_name = map[int32]string{
	0:  "TypeRegisterContainer",
	1:  "TypeResourceHeartbeatReq",
	2:  "TypeResourceHeartbeatRsp",
	3:  "TypeContainerHeartbeatReq",
	4:  "TypeContainerHeartbeatRsp",
	5:  "TypePutContainerReq",
	6:  "TypePutContainerRsp",
	7:  "TypeGetContainerReq",
	8:  "TypeGetContainerRsp",
	9:  "TypeAllocIDReq",
	10: "TypeAllocIDRsp",
	11: "TypeAskSplitReq",
	12: "TypeAskSplitRsp",
	13: "TypeAskBatchSplitReq",
	14: "TypeAskBatchSplitRsp",
	15: "TypeReportSplitReq",
	16: "TypeReportSplitRsp",
	17: "TypeBatchReportSplitReq",
	18: "TypeBatchReportSplitRsp",
	19: "TypeCreateWatcherReq",
	20: "TypeEventNotify",
	21: "TypeCreateResourcesReq",
	22: "TypeCreateResourcesRsp",
	23: "TypeRemoveResourcesReq",
	24: "TypeRemoveResourcesRsp",
	25: "TypeCheckResourceStateReq",
	26: "TypeCheckResourceStateRsp",
	27: "TypePutPlacementRuleReq",
	28: "TypePutPlacementRuleRsp",
	29: "TypeGetAppliedRulesReq",
	30: "TypeGetAppliedRulesRsp",
	31: "TypeCreateJobReq",
	32: "TypeCreateJobRsp",
	33: "TypeRemoveJobReq",
	34: "TypeRemoveJobRsp",
	35: "TypeExecuteJobReq",
	36: "TypeExecuteJobRsp",
}
View Source 
var Type_value = map[string]int32{
	"TypeRegisterContainer":     0,
	"TypeResourceHeartbeatReq":  1,
	"TypeResourceHeartbeatRsp":  2,
	"TypeContainerHeartbeatReq": 3,
	"TypeContainerHeartbeatRsp": 4,
	"TypePutContainerReq":       5,
	"TypePutContainerRsp":       6,
	"TypeGetContainerReq":       7,
	"TypeGetContainerRsp":       8,
	"TypeAllocIDReq":            9,
	"TypeAllocIDRsp":            10,
	"TypeAskSplitReq":           11,
	"TypeAskSplitRsp":           12,
	"TypeAskBatchSplitReq":      13,
	"TypeAskBatchSplitRsp":      14,
	"TypeReportSplitReq":        15,
	"TypeReportSplitRsp":        16,
	"TypeBatchReportSplitReq":   17,
	"TypeBatchReportSplitRsp":   18,
	"TypeCreateWatcherReq":      19,
	"TypeEventNotify":           20,
	"TypeCreateResourcesReq":    21,
	"TypeCreateResourcesRsp":    22,
	"TypeRemoveResourcesReq":    23,
	"TypeRemoveResourcesRsp":    24,
	"TypeCheckResourceStateReq": 25,
	"TypeCheckResourceStateRsp": 26,
	"TypePutPlacementRuleReq":   27,
	"TypePutPlacementRuleRsp":   28,
	"TypeGetAppliedRulesReq":    29,
	"TypeGetAppliedRulesRsp":    30,
	"TypeCreateJobReq":          31,
	"TypeCreateJobRsp":          32,
	"TypeRemoveJobReq":          33,
	"TypeRemoveJobRsp":          34,
	"TypeExecuteJobReq":         35,
	"TypeExecuteJobRsp":         36,
}

Functions

This section is empty.

Types

type AllocIDReq 

type AllocIDReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

AllocIDReq alloc id request

func (*AllocIDReq) Descriptor 

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

func (*AllocIDReq) Marshal 

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

func (*AllocIDReq) MarshalTo 

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

func (*AllocIDReq) ProtoMessage 

func (*AllocIDReq) ProtoMessage()

func (*AllocIDReq) Reset 

func (m *AllocIDReq) Reset()

func (*AllocIDReq) Size 

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

func (*AllocIDReq) String 

func (m *AllocIDReq) String() string

func (*AllocIDReq) Unmarshal 

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

func (*AllocIDReq) XXX_DiscardUnknown 

func (m *AllocIDReq) XXX_DiscardUnknown()

func (*AllocIDReq) XXX_Marshal 

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

func (*AllocIDReq) XXX_Merge 

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

func (*AllocIDReq) XXX_Size 

func (m *AllocIDReq) XXX_Size() int

func (*AllocIDReq) XXX_Unmarshal 

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

type AllocIDRsp 

type AllocIDRsp struct {
	ID                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

AllocIDRsp alloc id response

func (*AllocIDRsp) Descriptor 

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

func (*AllocIDRsp) GetID 

func (m *AllocIDRsp) GetID() uint64

func (*AllocIDRsp) Marshal 

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

func (*AllocIDRsp) MarshalTo 

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

func (*AllocIDRsp) ProtoMessage 

func (*AllocIDRsp) ProtoMessage()

func (*AllocIDRsp) Reset 

func (m *AllocIDRsp) Reset()

func (*AllocIDRsp) Size 

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

func (*AllocIDRsp) String 

func (m *AllocIDRsp) String() string

func (*AllocIDRsp) Unmarshal 

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

func (*AllocIDRsp) XXX_DiscardUnknown 

func (m *AllocIDRsp) XXX_DiscardUnknown()

func (*AllocIDRsp) XXX_Marshal 

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

func (*AllocIDRsp) XXX_Merge 

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

func (*AllocIDRsp) XXX_Size 

func (m *AllocIDRsp) XXX_Size() int

func (*AllocIDRsp) XXX_Unmarshal 

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

type AskBatchSplitReq 

type AskBatchSplitReq struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Count                uint32   `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

AskBatchSplitReq ask batch split request

func (*AskBatchSplitReq) Descriptor 

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

func (*AskBatchSplitReq) GetCount 

func (m *AskBatchSplitReq) GetCount() uint32

func (*AskBatchSplitReq) GetData 

func (m *AskBatchSplitReq) GetData() []byte

func (*AskBatchSplitReq) Marshal 

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

func (*AskBatchSplitReq) MarshalTo 

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

func (*AskBatchSplitReq) ProtoMessage 

func (*AskBatchSplitReq) ProtoMessage()

func (*AskBatchSplitReq) Reset 

func (m *AskBatchSplitReq) Reset()

func (*AskBatchSplitReq) Size 

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

func (*AskBatchSplitReq) String 

func (m *AskBatchSplitReq) String() string

func (*AskBatchSplitReq) Unmarshal 

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

func (*AskBatchSplitReq) XXX_DiscardUnknown 

func (m *AskBatchSplitReq) XXX_DiscardUnknown()

func (*AskBatchSplitReq) XXX_Marshal 

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

func (*AskBatchSplitReq) XXX_Merge 

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

func (*AskBatchSplitReq) XXX_Size 

func (m *AskBatchSplitReq) XXX_Size() int

func (*AskBatchSplitReq) XXX_Unmarshal 

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

type AskBatchSplitRsp 

type AskBatchSplitRsp struct {
	SplitIDs             []SplitID `protobuf:"bytes,1,rep,name=splitIDs,proto3" json:"splitIDs"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

AskBatchSplitRsp ask batch split response

func (*AskBatchSplitRsp) Descriptor 

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

func (*AskBatchSplitRsp) GetSplitIDs 

func (m *AskBatchSplitRsp) GetSplitIDs() []SplitID

func (*AskBatchSplitRsp) Marshal 

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

func (*AskBatchSplitRsp) MarshalTo 

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

func (*AskBatchSplitRsp) ProtoMessage 

func (*AskBatchSplitRsp) ProtoMessage()

func (*AskBatchSplitRsp) Reset 

func (m *AskBatchSplitRsp) Reset()

func (*AskBatchSplitRsp) Size 

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

func (*AskBatchSplitRsp) String 

func (m *AskBatchSplitRsp) String() string

func (*AskBatchSplitRsp) Unmarshal 

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

func (*AskBatchSplitRsp) XXX_DiscardUnknown 

func (m *AskBatchSplitRsp) XXX_DiscardUnknown()

func (*AskBatchSplitRsp) XXX_Marshal 

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

func (*AskBatchSplitRsp) XXX_Merge 

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

func (*AskBatchSplitRsp) XXX_Size 

func (m *AskBatchSplitRsp) XXX_Size() int

func (*AskBatchSplitRsp) XXX_Unmarshal 

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

type AskSplitReq 

type AskSplitReq struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

AskSplitReq ask split request

func (*AskSplitReq) Descriptor 

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

func (*AskSplitReq) GetData 

func (m *AskSplitReq) GetData() []byte

func (*AskSplitReq) Marshal 

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

func (*AskSplitReq) MarshalTo 

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

func (*AskSplitReq) ProtoMessage 

func (*AskSplitReq) ProtoMessage()

func (*AskSplitReq) Reset 

func (m *AskSplitReq) Reset()

func (*AskSplitReq) Size 

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

func (*AskSplitReq) String 

func (m *AskSplitReq) String() string

func (*AskSplitReq) Unmarshal 

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

func (*AskSplitReq) XXX_DiscardUnknown 

func (m *AskSplitReq) XXX_DiscardUnknown()

func (*AskSplitReq) XXX_Marshal 

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

func (*AskSplitReq) XXX_Merge 

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

func (*AskSplitReq) XXX_Size 

func (m *AskSplitReq) XXX_Size() int

func (*AskSplitReq) XXX_Unmarshal 

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

type AskSplitRsp 

type AskSplitRsp struct {
	SplitID              SplitID  `protobuf:"bytes,1,opt,name=splitID,proto3" json:"splitID"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

AskSplitRsp ask split response

func (*AskSplitRsp) Descriptor 

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

func (*AskSplitRsp) GetSplitID 

func (m *AskSplitRsp) GetSplitID() SplitID

func (*AskSplitRsp) Marshal 

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

func (*AskSplitRsp) MarshalTo 

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

func (*AskSplitRsp) ProtoMessage 

func (*AskSplitRsp) ProtoMessage()

func (*AskSplitRsp) Reset 

func (m *AskSplitRsp) Reset()

func (*AskSplitRsp) Size 

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

func (*AskSplitRsp) String 

func (m *AskSplitRsp) String() string

func (*AskSplitRsp) Unmarshal 

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

func (*AskSplitRsp) XXX_DiscardUnknown 

func (m *AskSplitRsp) XXX_DiscardUnknown()

func (*AskSplitRsp) XXX_Marshal 

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

func (*AskSplitRsp) XXX_Merge 

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

func (*AskSplitRsp) XXX_Size 

func (m *AskSplitRsp) XXX_Size() int

func (*AskSplitRsp) XXX_Unmarshal 

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

type BatchReportSplitReq 

type BatchReportSplitReq struct {
	Resources            [][]byte `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

BatchReportSplitReq report split request

func (*BatchReportSplitReq) Descriptor 

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

func (*BatchReportSplitReq) GetResources 

func (m *BatchReportSplitReq) GetResources() [][]byte

func (*BatchReportSplitReq) Marshal 

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

func (*BatchReportSplitReq) MarshalTo 

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

func (*BatchReportSplitReq) ProtoMessage 

func (*BatchReportSplitReq) ProtoMessage()

func (*BatchReportSplitReq) Reset 

func (m *BatchReportSplitReq) Reset()

func (*BatchReportSplitReq) Size 

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

func (*BatchReportSplitReq) String 

func (m *BatchReportSplitReq) String() string

func (*BatchReportSplitReq) Unmarshal 

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

func (*BatchReportSplitReq) XXX_DiscardUnknown 

func (m *BatchReportSplitReq) XXX_DiscardUnknown()

func (*BatchReportSplitReq) XXX_Marshal 

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

func (*BatchReportSplitReq) XXX_Merge 

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

func (*BatchReportSplitReq) XXX_Size 

func (m *BatchReportSplitReq) XXX_Size() int

func (*BatchReportSplitReq) XXX_Unmarshal 

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

type BatchReportSplitRsp 

type BatchReportSplitRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

BatchReportSplitRsp report split response

func (*BatchReportSplitRsp) Descriptor 

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

func (*BatchReportSplitRsp) Marshal 

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

func (*BatchReportSplitRsp) MarshalTo 

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

func (*BatchReportSplitRsp) ProtoMessage 

func (*BatchReportSplitRsp) ProtoMessage()

func (*BatchReportSplitRsp) Reset 

func (m *BatchReportSplitRsp) Reset()

func (*BatchReportSplitRsp) Size 

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

func (*BatchReportSplitRsp) String 

func (m *BatchReportSplitRsp) String() string

func (*BatchReportSplitRsp) Unmarshal 

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

func (*BatchReportSplitRsp) XXX_DiscardUnknown 

func (m *BatchReportSplitRsp) XXX_DiscardUnknown()

func (*BatchReportSplitRsp) XXX_Marshal 

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

func (*BatchReportSplitRsp) XXX_Merge 

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

func (*BatchReportSplitRsp) XXX_Size 

func (m *BatchReportSplitRsp) XXX_Size() int

func (*BatchReportSplitRsp) XXX_Unmarshal 

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

type ChangePeer 

type ChangePeer struct {
	Peer                 metapb.Peer           `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer"`
	ChangeType           metapb.ChangePeerType `protobuf:"varint,2,opt,name=changeType,proto3,enum=metapb.ChangePeerType" json:"changeType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

ChangePeer change peer

func (*ChangePeer) Descriptor 

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

func (*ChangePeer) GetChangeType 

func (m *ChangePeer) GetChangeType() metapb.ChangePeerType

func (*ChangePeer) GetPeer 

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

func (*ChangePeer) Marshal 

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

func (*ChangePeer) MarshalTo 

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

func (*ChangePeer) ProtoMessage 

func (*ChangePeer) ProtoMessage()

func (*ChangePeer) Reset 

func (m *ChangePeer) Reset()

func (*ChangePeer) Size 

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

func (*ChangePeer) String 

func (m *ChangePeer) String() string

func (*ChangePeer) Unmarshal 

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

func (*ChangePeer) XXX_DiscardUnknown 

func (m *ChangePeer) XXX_DiscardUnknown()

func (*ChangePeer) XXX_Marshal 

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

func (*ChangePeer) XXX_Merge 

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

func (*ChangePeer) XXX_Size 

func (m *ChangePeer) XXX_Size() int

func (*ChangePeer) XXX_Unmarshal 

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

type ChangePeerV2 

type ChangePeerV2 struct {
	// If changes is empty, it means that to exit joint state.
	Changes              []ChangePeer `protobuf:"bytes,1,rep,name=changes,proto3" json:"changes"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

ChangePeerV2 change peer v2

func (*ChangePeerV2) Descriptor 

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

func (*ChangePeerV2) GetChanges 

func (m *ChangePeerV2) GetChanges() []ChangePeer

func (*ChangePeerV2) Marshal 

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

func (*ChangePeerV2) MarshalTo 

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

func (*ChangePeerV2) ProtoMessage 

func (*ChangePeerV2) ProtoMessage()

func (*ChangePeerV2) Reset 

func (m *ChangePeerV2) Reset()

func (*ChangePeerV2) Size 

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

func (*ChangePeerV2) String 

func (m *ChangePeerV2) String() string

func (*ChangePeerV2) Unmarshal 

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

func (*ChangePeerV2) XXX_DiscardUnknown 

func (m *ChangePeerV2) XXX_DiscardUnknown()

func (*ChangePeerV2) XXX_Marshal 

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

func (*ChangePeerV2) XXX_Merge 

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

func (*ChangePeerV2) XXX_Size 

func (m *ChangePeerV2) XXX_Size() int

func (*ChangePeerV2) XXX_Unmarshal 

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

type CheckResourceStateReq 

type CheckResourceStateReq struct {
	IDs                  []byte   `protobuf:"bytes,1,opt,name=ids,proto3" json:"ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CheckResourceStateReq check resource state req

func (*CheckResourceStateReq) Descriptor 

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

func (*CheckResourceStateReq) GetIDs 

func (m *CheckResourceStateReq) GetIDs() []byte

func (*CheckResourceStateReq) Marshal 

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

func (*CheckResourceStateReq) MarshalTo 

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

func (*CheckResourceStateReq) ProtoMessage 

func (*CheckResourceStateReq) ProtoMessage()

func (*CheckResourceStateReq) Reset 

func (m *CheckResourceStateReq) Reset()

func (*CheckResourceStateReq) Size 

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

func (*CheckResourceStateReq) String 

func (m *CheckResourceStateReq) String() string

func (*CheckResourceStateReq) Unmarshal 

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

func (*CheckResourceStateReq) XXX_DiscardUnknown 

func (m *CheckResourceStateReq) XXX_DiscardUnknown()

func (*CheckResourceStateReq) XXX_Marshal 

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

func (*CheckResourceStateReq) XXX_Merge 

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

func (*CheckResourceStateReq) XXX_Size 

func (m *CheckResourceStateReq) XXX_Size() int

func (*CheckResourceStateReq) XXX_Unmarshal 

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

type CheckResourceStateRsp 

type CheckResourceStateRsp struct {
	Removed              []uint64 `protobuf:"varint,1,rep,packed,name=removed,proto3" json:"removed,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CheckResourceStateReq check resource state rsp

func (*CheckResourceStateRsp) Descriptor 

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

func (*CheckResourceStateRsp) GetRemoved 

func (m *CheckResourceStateRsp) GetRemoved() []uint64

func (*CheckResourceStateRsp) Marshal 

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

func (*CheckResourceStateRsp) MarshalTo 

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

func (*CheckResourceStateRsp) ProtoMessage 

func (*CheckResourceStateRsp) ProtoMessage()

func (*CheckResourceStateRsp) Reset 

func (m *CheckResourceStateRsp) Reset()

func (*CheckResourceStateRsp) Size 

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

func (*CheckResourceStateRsp) String 

func (m *CheckResourceStateRsp) String() string

func (*CheckResourceStateRsp) Unmarshal 

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

func (*CheckResourceStateRsp) XXX_DiscardUnknown 

func (m *CheckResourceStateRsp) XXX_DiscardUnknown()

func (*CheckResourceStateRsp) XXX_Marshal 

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

func (*CheckResourceStateRsp) XXX_Merge 

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

func (*CheckResourceStateRsp) XXX_Size 

func (m *CheckResourceStateRsp) XXX_Size() int

func (*CheckResourceStateRsp) XXX_Unmarshal 

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

type ContainerEventData 

type ContainerEventData struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ContainerEventData container created or updated

func (*ContainerEventData) Descriptor 

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

func (*ContainerEventData) GetData 

func (m *ContainerEventData) GetData() []byte

func (*ContainerEventData) Marshal 

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

func (*ContainerEventData) MarshalTo 

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

func (*ContainerEventData) ProtoMessage 

func (*ContainerEventData) ProtoMessage()

func (*ContainerEventData) Reset 

func (m *ContainerEventData) Reset()

func (*ContainerEventData) Size 

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

func (*ContainerEventData) String 

func (m *ContainerEventData) String() string

func (*ContainerEventData) Unmarshal 

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

func (*ContainerEventData) XXX_DiscardUnknown 

func (m *ContainerEventData) XXX_DiscardUnknown()

func (*ContainerEventData) XXX_Marshal 

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

func (*ContainerEventData) XXX_Merge 

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

func (*ContainerEventData) XXX_Size 

func (m *ContainerEventData) XXX_Size() int

func (*ContainerEventData) XXX_Unmarshal 

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

type ContainerHeartbeatReq 

type ContainerHeartbeatReq struct {
	Stats                metapb.ContainerStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats"`
	Data                 []byte                `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

ContainerHeartbeatReq container heartbeat request

func (*ContainerHeartbeatReq) Descriptor 

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

func (*ContainerHeartbeatReq) GetData 

func (m *ContainerHeartbeatReq) GetData() []byte

func (*ContainerHeartbeatReq) GetStats 

func (m *ContainerHeartbeatReq) GetStats() metapb.ContainerStats

func (*ContainerHeartbeatReq) Marshal 

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

func (*ContainerHeartbeatReq) MarshalTo 

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

func (*ContainerHeartbeatReq) ProtoMessage 

func (*ContainerHeartbeatReq) ProtoMessage()

func (*ContainerHeartbeatReq) Reset 

func (m *ContainerHeartbeatReq) Reset()

func (*ContainerHeartbeatReq) Size 

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

func (*ContainerHeartbeatReq) String 

func (m *ContainerHeartbeatReq) String() string

func (*ContainerHeartbeatReq) Unmarshal 

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

func (*ContainerHeartbeatReq) XXX_DiscardUnknown 

func (m *ContainerHeartbeatReq) XXX_DiscardUnknown()

func (*ContainerHeartbeatReq) XXX_Marshal 

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

func (*ContainerHeartbeatReq) XXX_Merge 

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

func (*ContainerHeartbeatReq) XXX_Size 

func (m *ContainerHeartbeatReq) XXX_Size() int

func (*ContainerHeartbeatReq) XXX_Unmarshal 

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

type ContainerHeartbeatRsp 

type ContainerHeartbeatRsp struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ContainerHeartbeatRsp container heartbeat response

func (*ContainerHeartbeatRsp) Descriptor 

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

func (*ContainerHeartbeatRsp) GetData 

func (m *ContainerHeartbeatRsp) GetData() []byte

func (*ContainerHeartbeatRsp) Marshal 

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

func (*ContainerHeartbeatRsp) MarshalTo 

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

func (*ContainerHeartbeatRsp) ProtoMessage 

func (*ContainerHeartbeatRsp) ProtoMessage()

func (*ContainerHeartbeatRsp) Reset 

func (m *ContainerHeartbeatRsp) Reset()

func (*ContainerHeartbeatRsp) Size 

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

func (*ContainerHeartbeatRsp) String 

func (m *ContainerHeartbeatRsp) String() string

func (*ContainerHeartbeatRsp) Unmarshal 

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

func (*ContainerHeartbeatRsp) XXX_DiscardUnknown 

func (m *ContainerHeartbeatRsp) XXX_DiscardUnknown()

func (*ContainerHeartbeatRsp) XXX_Marshal 

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

func (*ContainerHeartbeatRsp) XXX_Merge 

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

func (*ContainerHeartbeatRsp) XXX_Size 

func (m *ContainerHeartbeatRsp) XXX_Size() int

func (*ContainerHeartbeatRsp) XXX_Unmarshal 

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

type CreateJobReq 

type CreateJobReq struct {
	Job                  metapb.Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

CreateJobReq create job req

func (*CreateJobReq) Descriptor 

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

func (*CreateJobReq) GetJob 

func (m *CreateJobReq) GetJob() metapb.Job

func (*CreateJobReq) Marshal 

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

func (*CreateJobReq) MarshalTo 

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

func (*CreateJobReq) ProtoMessage 

func (*CreateJobReq) ProtoMessage()

func (*CreateJobReq) Reset 

func (m *CreateJobReq) Reset()

func (*CreateJobReq) Size 

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

func (*CreateJobReq) String 

func (m *CreateJobReq) String() string

func (*CreateJobReq) Unmarshal 

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

func (*CreateJobReq) XXX_DiscardUnknown 

func (m *CreateJobReq) XXX_DiscardUnknown()

func (*CreateJobReq) XXX_Marshal 

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

func (*CreateJobReq) XXX_Merge 

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

func (*CreateJobReq) XXX_Size 

func (m *CreateJobReq) XXX_Size() int

func (*CreateJobReq) XXX_Unmarshal 

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

type CreateJobRsp 

type CreateJobRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CreateJobRsp create job rsp

func (*CreateJobRsp) Descriptor 

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

func (*CreateJobRsp) Marshal 

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

func (*CreateJobRsp) MarshalTo 

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

func (*CreateJobRsp) ProtoMessage 

func (*CreateJobRsp) ProtoMessage()

func (*CreateJobRsp) Reset 

func (m *CreateJobRsp) Reset()

func (*CreateJobRsp) Size 

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

func (*CreateJobRsp) String 

func (m *CreateJobRsp) String() string

func (*CreateJobRsp) Unmarshal 

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

func (*CreateJobRsp) XXX_DiscardUnknown 

func (m *CreateJobRsp) XXX_DiscardUnknown()

func (*CreateJobRsp) XXX_Marshal 

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

func (*CreateJobRsp) XXX_Merge 

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

func (*CreateJobRsp) XXX_Size 

func (m *CreateJobRsp) XXX_Size() int

func (*CreateJobRsp) XXX_Unmarshal 

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

type CreateResourcesReq 

type CreateResourcesReq struct {
	Resources            [][]byte `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"`
	LeastPeers           []uint64 `protobuf:"varint,2,rep,packed,name=leastPeers,proto3" json:"leastPeers,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CreateResourcesReq create resources req

func (*CreateResourcesReq) Descriptor 

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

func (*CreateResourcesReq) GetLeastPeers 

func (m *CreateResourcesReq) GetLeastPeers() []uint64

func (*CreateResourcesReq) GetResources 

func (m *CreateResourcesReq) GetResources() [][]byte

func (*CreateResourcesReq) Marshal 

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

func (*CreateResourcesReq) MarshalTo 

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

func (*CreateResourcesReq) ProtoMessage 

func (*CreateResourcesReq) ProtoMessage()

func (*CreateResourcesReq) Reset 

func (m *CreateResourcesReq) Reset()

func (*CreateResourcesReq) Size 

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

func (*CreateResourcesReq) String 

func (m *CreateResourcesReq) String() string

func (*CreateResourcesReq) Unmarshal 

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

func (*CreateResourcesReq) XXX_DiscardUnknown 

func (m *CreateResourcesReq) XXX_DiscardUnknown()

func (*CreateResourcesReq) XXX_Marshal 

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

func (*CreateResourcesReq) XXX_Merge 

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

func (*CreateResourcesReq) XXX_Size 

func (m *CreateResourcesReq) XXX_Size() int

func (*CreateResourcesReq) XXX_Unmarshal 

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

type CreateResourcesRsp 

type CreateResourcesRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CreateResourcesRsp create resources rsp

func (*CreateResourcesRsp) Descriptor 

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

func (*CreateResourcesRsp) Marshal 

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

func (*CreateResourcesRsp) MarshalTo 

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

func (*CreateResourcesRsp) ProtoMessage 

func (*CreateResourcesRsp) ProtoMessage()

func (*CreateResourcesRsp) Reset 

func (m *CreateResourcesRsp) Reset()

func (*CreateResourcesRsp) Size 

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

func (*CreateResourcesRsp) String 

func (m *CreateResourcesRsp) String() string

func (*CreateResourcesRsp) Unmarshal 

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

func (*CreateResourcesRsp) XXX_DiscardUnknown 

func (m *CreateResourcesRsp) XXX_DiscardUnknown()

func (*CreateResourcesRsp) XXX_Marshal 

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

func (*CreateResourcesRsp) XXX_Merge 

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

func (*CreateResourcesRsp) XXX_Size 

func (m *CreateResourcesRsp) XXX_Size() int

func (*CreateResourcesRsp) XXX_Unmarshal 

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

type CreateWatcherReq 

type CreateWatcherReq struct {
	Flag                 uint32   `protobuf:"varint,1,opt,name=flag,proto3" json:"flag,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CreateWatcherReq create watcher req

func (*CreateWatcherReq) Descriptor 

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

func (*CreateWatcherReq) GetFlag 

func (m *CreateWatcherReq) GetFlag() uint32

func (*CreateWatcherReq) Marshal 

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

func (*CreateWatcherReq) MarshalTo 

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

func (*CreateWatcherReq) ProtoMessage 

func (*CreateWatcherReq) ProtoMessage()

func (*CreateWatcherReq) Reset 

func (m *CreateWatcherReq) Reset()

func (*CreateWatcherReq) Size 

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

func (*CreateWatcherReq) String 

func (m *CreateWatcherReq) String() string

func (*CreateWatcherReq) Unmarshal 

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

func (*CreateWatcherReq) XXX_DiscardUnknown 

func (m *CreateWatcherReq) XXX_DiscardUnknown()

func (*CreateWatcherReq) XXX_Marshal 

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

func (*CreateWatcherReq) XXX_Merge 

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

func (*CreateWatcherReq) XXX_Size 

func (m *CreateWatcherReq) XXX_Size() int

func (*CreateWatcherReq) XXX_Unmarshal 

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

type EventNotify 

type EventNotify struct {
	Seq                  uint64                 `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"`
	Type                 uint32                 `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"`
	InitEvent            *InitEventData         `protobuf:"bytes,3,opt,name=initEvent,proto3" json:"initEvent,omitempty"`
	ResourceEvent        *ResourceEventData     `protobuf:"bytes,4,opt,name=resourceEvent,proto3" json:"resourceEvent,omitempty"`
	ContainerEvent       *ContainerEventData    `protobuf:"bytes,5,opt,name=containerEvent,proto3" json:"containerEvent,omitempty"`
	ResourceStatsEvent   *metapb.ResourceStats  `protobuf:"bytes,6,opt,name=resourceStatsEvent,proto3" json:"resourceStatsEvent,omitempty"`
	ContainerStatsEvent  *metapb.ContainerStats `protobuf:"bytes,7,opt,name=containerStatsEvent,proto3" json:"containerStatsEvent,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

EventNotify event notify

func (*EventNotify) Descriptor 

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

func (*EventNotify) GetContainerEvent 

func (m *EventNotify) GetContainerEvent() *ContainerEventData

func (*EventNotify) GetContainerStatsEvent 

func (m *EventNotify) GetContainerStatsEvent() *metapb.ContainerStats

func (*EventNotify) GetInitEvent 

func (m *EventNotify) GetInitEvent() *InitEventData

func (*EventNotify) GetResourceEvent 

func (m *EventNotify) GetResourceEvent() *ResourceEventData

func (*EventNotify) GetResourceStatsEvent 

func (m *EventNotify) GetResourceStatsEvent() *metapb.ResourceStats

func (*EventNotify) GetSeq 

func (m *EventNotify) GetSeq() uint64

func (*EventNotify) GetType 

func (m *EventNotify) GetType() uint32

func (*EventNotify) Marshal 

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

func (*EventNotify) MarshalTo 

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

func (*EventNotify) ProtoMessage 

func (*EventNotify) ProtoMessage()

func (*EventNotify) Reset 

func (m *EventNotify) Reset()

func (*EventNotify) Size 

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

func (*EventNotify) String 

func (m *EventNotify) String() string

func (*EventNotify) Unmarshal 

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

func (*EventNotify) XXX_DiscardUnknown 

func (m *EventNotify) XXX_DiscardUnknown()

func (*EventNotify) XXX_Marshal 

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

func (*EventNotify) XXX_Merge 

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

func (*EventNotify) XXX_Size 

func (m *EventNotify) XXX_Size() int

func (*EventNotify) XXX_Unmarshal 

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

type ExecuteJobReq 

type ExecuteJobReq struct {
	Job                  metapb.Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job"`
	Data                 []byte     `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

ExecuteJobReq execute on job request

func (*ExecuteJobReq) Descriptor 

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

func (*ExecuteJobReq) GetData 

func (m *ExecuteJobReq) GetData() []byte

func (*ExecuteJobReq) GetJob 

func (m *ExecuteJobReq) GetJob() metapb.Job

func (*ExecuteJobReq) Marshal 

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

func (*ExecuteJobReq) MarshalTo 

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

func (*ExecuteJobReq) ProtoMessage 

func (*ExecuteJobReq) ProtoMessage()

func (*ExecuteJobReq) Reset 

func (m *ExecuteJobReq) Reset()

func (*ExecuteJobReq) Size 

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

func (*ExecuteJobReq) String 

func (m *ExecuteJobReq) String() string

func (*ExecuteJobReq) Unmarshal 

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

func (*ExecuteJobReq) XXX_DiscardUnknown 

func (m *ExecuteJobReq) XXX_DiscardUnknown()

func (*ExecuteJobReq) XXX_Marshal 

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

func (*ExecuteJobReq) XXX_Merge 

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

func (*ExecuteJobReq) XXX_Size 

func (m *ExecuteJobReq) XXX_Size() int

func (*ExecuteJobReq) XXX_Unmarshal 

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

type ExecuteJobRsp 

type ExecuteJobRsp struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ExecuteJobRsp execute on job response

func (*ExecuteJobRsp) Descriptor 

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

func (*ExecuteJobRsp) GetData 

func (m *ExecuteJobRsp) GetData() []byte

func (*ExecuteJobRsp) Marshal 

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

func (*ExecuteJobRsp) MarshalTo 

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

func (*ExecuteJobRsp) ProtoMessage 

func (*ExecuteJobRsp) ProtoMessage()

func (*ExecuteJobRsp) Reset 

func (m *ExecuteJobRsp) Reset()

func (*ExecuteJobRsp) Size 

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

func (*ExecuteJobRsp) String 

func (m *ExecuteJobRsp) String() string

func (*ExecuteJobRsp) Unmarshal 

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

func (*ExecuteJobRsp) XXX_DiscardUnknown 

func (m *ExecuteJobRsp) XXX_DiscardUnknown()

func (*ExecuteJobRsp) XXX_Marshal 

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

func (*ExecuteJobRsp) XXX_Merge 

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

func (*ExecuteJobRsp) XXX_Size 

func (m *ExecuteJobRsp) XXX_Size() int

func (*ExecuteJobRsp) XXX_Unmarshal 

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

type GetAppliedRulesReq 

type GetAppliedRulesReq struct {
	ResourceID           uint64   `protobuf:"varint,1,opt,name=resourceID,proto3" json:"resourceID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetAppliedRulesReq get applied rules req

func (*GetAppliedRulesReq) Descriptor 

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

func (*GetAppliedRulesReq) GetResourceID 

func (m *GetAppliedRulesReq) GetResourceID() uint64

func (*GetAppliedRulesReq) Marshal 

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

func (*GetAppliedRulesReq) MarshalTo 

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

func (*GetAppliedRulesReq) ProtoMessage 

func (*GetAppliedRulesReq) ProtoMessage()

func (*GetAppliedRulesReq) Reset 

func (m *GetAppliedRulesReq) Reset()

func (*GetAppliedRulesReq) Size 

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

func (*GetAppliedRulesReq) String 

func (m *GetAppliedRulesReq) String() string

func (*GetAppliedRulesReq) Unmarshal 

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

func (*GetAppliedRulesReq) XXX_DiscardUnknown 

func (m *GetAppliedRulesReq) XXX_DiscardUnknown()

func (*GetAppliedRulesReq) XXX_Marshal 

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

func (*GetAppliedRulesReq) XXX_Merge 

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

func (*GetAppliedRulesReq) XXX_Size 

func (m *GetAppliedRulesReq) XXX_Size() int

func (*GetAppliedRulesReq) XXX_Unmarshal 

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

type GetAppliedRulesRsp 

type GetAppliedRulesRsp struct {
	Rules                []PlacementRule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

GetAppliedRulesRsp get applied rules rsp

func (*GetAppliedRulesRsp) Descriptor 

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

func (*GetAppliedRulesRsp) GetRules 

func (m *GetAppliedRulesRsp) GetRules() []PlacementRule

func (*GetAppliedRulesRsp) Marshal 

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

func (*GetAppliedRulesRsp) MarshalTo 

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

func (*GetAppliedRulesRsp) ProtoMessage 

func (*GetAppliedRulesRsp) ProtoMessage()

func (*GetAppliedRulesRsp) Reset 

func (m *GetAppliedRulesRsp) Reset()

func (*GetAppliedRulesRsp) Size 

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

func (*GetAppliedRulesRsp) String 

func (m *GetAppliedRulesRsp) String() string

func (*GetAppliedRulesRsp) Unmarshal 

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

func (*GetAppliedRulesRsp) XXX_DiscardUnknown 

func (m *GetAppliedRulesRsp) XXX_DiscardUnknown()

func (*GetAppliedRulesRsp) XXX_Marshal 

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

func (*GetAppliedRulesRsp) XXX_Merge 

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

func (*GetAppliedRulesRsp) XXX_Size 

func (m *GetAppliedRulesRsp) XXX_Size() int

func (*GetAppliedRulesRsp) XXX_Unmarshal 

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

type GetContainerReq 

type GetContainerReq struct {
	ID                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetContainerReq get container request

func (*GetContainerReq) Descriptor 

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

func (*GetContainerReq) GetID 

func (m *GetContainerReq) GetID() uint64

func (*GetContainerReq) Marshal 

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

func (*GetContainerReq) MarshalTo 

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

func (*GetContainerReq) ProtoMessage 

func (*GetContainerReq) ProtoMessage()

func (*GetContainerReq) Reset 

func (m *GetContainerReq) Reset()

func (*GetContainerReq) Size 

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

func (*GetContainerReq) String 

func (m *GetContainerReq) String() string

func (*GetContainerReq) Unmarshal 

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

func (*GetContainerReq) XXX_DiscardUnknown 

func (m *GetContainerReq) XXX_DiscardUnknown()

func (*GetContainerReq) XXX_Marshal 

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

func (*GetContainerReq) XXX_Merge 

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

func (*GetContainerReq) XXX_Size 

func (m *GetContainerReq) XXX_Size() int

func (*GetContainerReq) XXX_Unmarshal 

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

type GetContainerRsp 

type GetContainerRsp struct {
	Data                 []byte                 `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Stats                *metapb.ContainerStats `protobuf:"bytes,2,opt,name=stats,proto3" json:"stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

GetContainerRsp get container response

func (*GetContainerRsp) Descriptor 

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

func (*GetContainerRsp) GetData 

func (m *GetContainerRsp) GetData() []byte

func (*GetContainerRsp) GetStats 

func (m *GetContainerRsp) GetStats() *metapb.ContainerStats

func (*GetContainerRsp) Marshal 

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

func (*GetContainerRsp) MarshalTo 

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

func (*GetContainerRsp) ProtoMessage 

func (*GetContainerRsp) ProtoMessage()

func (*GetContainerRsp) Reset 

func (m *GetContainerRsp) Reset()

func (*GetContainerRsp) Size 

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

func (*GetContainerRsp) String 

func (m *GetContainerRsp) String() string

func (*GetContainerRsp) Unmarshal 

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

func (*GetContainerRsp) XXX_DiscardUnknown 

func (m *GetContainerRsp) XXX_DiscardUnknown()

func (*GetContainerRsp) XXX_Marshal 

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

func (*GetContainerRsp) XXX_Merge 

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

func (*GetContainerRsp) XXX_Size 

func (m *GetContainerRsp) XXX_Size() int

func (*GetContainerRsp) XXX_Unmarshal 

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

type InitEventData 

type InitEventData struct {
	Resources            [][]byte `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"`
	Leaders              []uint64 `protobuf:"varint,2,rep,packed,name=leaders,proto3" json:"leaders,omitempty"`
	Containers           [][]byte `protobuf:"bytes,3,rep,name=containers,proto3" json:"containers,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

InitEventData init event data

func (*InitEventData) Descriptor 

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

func (*InitEventData) GetContainers 

func (m *InitEventData) GetContainers() [][]byte

func (*InitEventData) GetLeaders 

func (m *InitEventData) GetLeaders() []uint64

func (*InitEventData) GetResources 

func (m *InitEventData) GetResources() [][]byte

func (*InitEventData) Marshal 

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

func (*InitEventData) MarshalTo 

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

func (*InitEventData) ProtoMessage 

func (*InitEventData) ProtoMessage()

func (*InitEventData) Reset 

func (m *InitEventData) Reset()

func (*InitEventData) Size 

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

func (*InitEventData) String 

func (m *InitEventData) String() string

func (*InitEventData) Unmarshal 

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

func (*InitEventData) XXX_DiscardUnknown 

func (m *InitEventData) XXX_DiscardUnknown()

func (*InitEventData) XXX_Marshal 

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

func (*InitEventData) XXX_Merge 

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

func (*InitEventData) XXX_Size 

func (m *InitEventData) XXX_Size() int

func (*InitEventData) XXX_Unmarshal 

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

type LabelConstraint 

type LabelConstraint struct {
	Key                  string            `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Op                   LabelConstraintOp `protobuf:"varint,2,opt,name=op,proto3,enum=rpcpb.LabelConstraintOp" json:"op,omitempty"`
	Values               []string          `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

LabelConstraint is used to filter container when trying to place peer of a resource.

func (*LabelConstraint) Descriptor 

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

func (*LabelConstraint) GetKey 

func (m *LabelConstraint) GetKey() string

func (*LabelConstraint) GetOp 

func (m *LabelConstraint) GetOp() LabelConstraintOp

func (*LabelConstraint) GetValues 

func (m *LabelConstraint) GetValues() []string

func (*LabelConstraint) Marshal 

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

func (*LabelConstraint) MarshalTo 

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

func (*LabelConstraint) ProtoMessage 

func (*LabelConstraint) ProtoMessage()

func (*LabelConstraint) Reset 

func (m *LabelConstraint) Reset()

func (*LabelConstraint) Size 

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

func (*LabelConstraint) String 

func (m *LabelConstraint) String() string

func (*LabelConstraint) Unmarshal 

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

func (*LabelConstraint) XXX_DiscardUnknown 

func (m *LabelConstraint) XXX_DiscardUnknown()

func (*LabelConstraint) XXX_Marshal 

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

func (*LabelConstraint) XXX_Merge 

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

func (*LabelConstraint) XXX_Size 

func (m *LabelConstraint) XXX_Size() int

func (*LabelConstraint) XXX_Unmarshal 

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

type LabelConstraintOp 

type LabelConstraintOp int32

LabelConstraintOp defines how a LabelConstraint matches a container. It can be one of 'in', 'notIn', 'exists', or 'notExists'. 

const (
	// In If label does not exist, `in` is always false.
	In LabelConstraintOp = 0
	// NotIn restricts the container label value should not in the value list.
	NotIn LabelConstraintOp = 1
	// Exists restricts the container should have the label.
	Exists LabelConstraintOp = 2
	// NotExists restricts the container should not have the label.
	NotExists LabelConstraintOp = 3
)

func (LabelConstraintOp) EnumDescriptor 

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

func (LabelConstraintOp) String 

func (x LabelConstraintOp) String() string

type Merge 

type Merge struct {
	// target resource
	Target               []byte   `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Merge merge

func (*Merge) Descriptor 

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

func (*Merge) GetTarget 

func (m *Merge) GetTarget() []byte

func (*Merge) Marshal 

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

func (*Merge) MarshalTo 

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

func (*Merge) ProtoMessage 

func (*Merge) ProtoMessage()

func (*Merge) Reset 

func (m *Merge) Reset()

func (*Merge) Size 

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

func (*Merge) String 

func (m *Merge) String() string

func (*Merge) Unmarshal 

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

func (*Merge) XXX_DiscardUnknown 

func (m *Merge) XXX_DiscardUnknown()

func (*Merge) XXX_Marshal 

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

func (*Merge) XXX_Merge 

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

func (*Merge) XXX_Size 

func (m *Merge) XXX_Size() int

func (*Merge) XXX_Unmarshal 

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

type PeerRoleType 

type PeerRoleType int32

PeerRoleType is the expected peer type of the placement rule 

const (
	// Voter can either match a leader peer or follower peer
	Voter PeerRoleType = 0
	// Leader matches a leader.
	Leader PeerRoleType = 1
	// Follower matches a follower.
	Follower PeerRoleType = 2
	// Learner matches a learner.
	Learner PeerRoleType = 3
)

func (PeerRoleType) EnumDescriptor 

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

func (PeerRoleType) String 

func (x PeerRoleType) String() string

type PlacementRule 

type PlacementRule struct {
	// ID unique ID within a group
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// GroupID mark the source that add the rule
	GroupID string `protobuf:"bytes,2,opt,name=groupID,proto3" json:"groupID,omitempty"`
	// Index rule apply order in a group, rule with less ID is applied first when indexes are equal
	Index uint32 `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"`
	// Override when it is true, all rules with less indexes are disabled
	Override bool   `protobuf:"varint,4,opt,name=override,proto3" json:"override,omitempty"`
	StartKey []byte `protobuf:"bytes,5,opt,name=startKey,proto3" json:"startKey,omitempty"`
	EndKey   []byte `protobuf:"bytes,6,opt,name=endKey,proto3" json:"endKey,omitempty"`
	// Role expected role of the peers
	Role PeerRoleType `protobuf:"varint,7,opt,name=role,proto3,enum=rpcpb.PeerRoleType" json:"role,omitempty"`
	// Count expected count of the peers
	Count uint32 `protobuf:"varint,8,opt,name=count,proto3" json:"count,omitempty"`
	// LabelConstraints used to select containers to place peers
	LabelConstraints []LabelConstraint `protobuf:"bytes,9,rep,name=labelConstraints,proto3" json:"labelConstraints"`
	// LocationLabels used to make peers isolated physically
	LocationLabels []string `protobuf:"bytes,10,rep,name=locationLabels,proto3" json:"locationLabels,omitempty"`
	// IsolationLevelused to isolate replicas explicitly and forcibly
	IsolationLevel       string   `protobuf:"bytes,11,opt,name=isolationLevel,proto3" json:"isolationLevel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PlacementRule place rule

func (*PlacementRule) Descriptor 

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

func (*PlacementRule) GetCount 

func (m *PlacementRule) GetCount() uint32

func (*PlacementRule) GetEndKey 

func (m *PlacementRule) GetEndKey() []byte

func (*PlacementRule) GetGroupID 

func (m *PlacementRule) GetGroupID() string

func (*PlacementRule) GetID 

func (m *PlacementRule) GetID() string

func (*PlacementRule) GetIndex 

func (m *PlacementRule) GetIndex() uint32

func (*PlacementRule) GetIsolationLevel 

func (m *PlacementRule) GetIsolationLevel() string

func (*PlacementRule) GetLabelConstraints 

func (m *PlacementRule) GetLabelConstraints() []LabelConstraint

func (*PlacementRule) GetLocationLabels 

func (m *PlacementRule) GetLocationLabels() []string

func (*PlacementRule) GetOverride 

func (m *PlacementRule) GetOverride() bool

func (*PlacementRule) GetRole 

func (m *PlacementRule) GetRole() PeerRoleType

func (*PlacementRule) GetStartKey 

func (m *PlacementRule) GetStartKey() []byte

func (*PlacementRule) Marshal 

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

func (*PlacementRule) MarshalTo 

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

func (*PlacementRule) ProtoMessage 

func (*PlacementRule) ProtoMessage()

func (*PlacementRule) Reset 

func (m *PlacementRule) Reset()

func (*PlacementRule) Size 

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

func (*PlacementRule) String 

func (m *PlacementRule) String() string

func (*PlacementRule) Unmarshal 

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

func (*PlacementRule) XXX_DiscardUnknown 

func (m *PlacementRule) XXX_DiscardUnknown()

func (*PlacementRule) XXX_Marshal 

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

func (*PlacementRule) XXX_Merge 

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

func (*PlacementRule) XXX_Size 

func (m *PlacementRule) XXX_Size() int

func (*PlacementRule) XXX_Unmarshal 

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

type PutContainerReq 

type PutContainerReq struct {
	Container            []byte   `protobuf:"bytes,1,opt,name=container,proto3" json:"container,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PutContainerReq put container request

func (*PutContainerReq) Descriptor 

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

func (*PutContainerReq) GetContainer 

func (m *PutContainerReq) GetContainer() []byte

func (*PutContainerReq) Marshal 

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

func (*PutContainerReq) MarshalTo 

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

func (*PutContainerReq) ProtoMessage 

func (*PutContainerReq) ProtoMessage()

func (*PutContainerReq) Reset 

func (m *PutContainerReq) Reset()

func (*PutContainerReq) Size 

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

func (*PutContainerReq) String 

func (m *PutContainerReq) String() string

func (*PutContainerReq) Unmarshal 

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

func (*PutContainerReq) XXX_DiscardUnknown 

func (m *PutContainerReq) XXX_DiscardUnknown()

func (*PutContainerReq) XXX_Marshal 

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

func (*PutContainerReq) XXX_Merge 

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

func (*PutContainerReq) XXX_Size 

func (m *PutContainerReq) XXX_Size() int

func (*PutContainerReq) XXX_Unmarshal 

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

type PutContainerRsp 

type PutContainerRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PutContainerRsp put container response

func (*PutContainerRsp) Descriptor 

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

func (*PutContainerRsp) Marshal 

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

func (*PutContainerRsp) MarshalTo 

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

func (*PutContainerRsp) ProtoMessage 

func (*PutContainerRsp) ProtoMessage()

func (*PutContainerRsp) Reset 

func (m *PutContainerRsp) Reset()

func (*PutContainerRsp) Size 

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

func (*PutContainerRsp) String 

func (m *PutContainerRsp) String() string

func (*PutContainerRsp) Unmarshal 

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

func (*PutContainerRsp) XXX_DiscardUnknown 

func (m *PutContainerRsp) XXX_DiscardUnknown()

func (*PutContainerRsp) XXX_Marshal 

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

func (*PutContainerRsp) XXX_Merge 

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

func (*PutContainerRsp) XXX_Size 

func (m *PutContainerRsp) XXX_Size() int

func (*PutContainerRsp) XXX_Unmarshal 

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

type PutPlacementRuleReq 

type PutPlacementRuleReq struct {
	Rule                 PlacementRule `protobuf:"bytes,1,opt,name=rule,proto3" json:"rule"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

PutPlacementRuleReq put placement rule req

func (*PutPlacementRuleReq) Descriptor 

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

func (*PutPlacementRuleReq) GetRule 

func (m *PutPlacementRuleReq) GetRule() PlacementRule

func (*PutPlacementRuleReq) Marshal 

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

func (*PutPlacementRuleReq) MarshalTo 

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

func (*PutPlacementRuleReq) ProtoMessage 

func (*PutPlacementRuleReq) ProtoMessage()

func (*PutPlacementRuleReq) Reset 

func (m *PutPlacementRuleReq) Reset()

func (*PutPlacementRuleReq) Size 

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

func (*PutPlacementRuleReq) String 

func (m *PutPlacementRuleReq) String() string

func (*PutPlacementRuleReq) Unmarshal 

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

func (*PutPlacementRuleReq) XXX_DiscardUnknown 

func (m *PutPlacementRuleReq) XXX_DiscardUnknown()

func (*PutPlacementRuleReq) XXX_Marshal 

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

func (*PutPlacementRuleReq) XXX_Merge 

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

func (*PutPlacementRuleReq) XXX_Size 

func (m *PutPlacementRuleReq) XXX_Size() int

func (*PutPlacementRuleReq) XXX_Unmarshal 

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

type PutPlacementRuleRsp 

type PutPlacementRuleRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PutPlacementRuleRsp put placement rule rsp

func (*PutPlacementRuleRsp) Descriptor 

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

func (*PutPlacementRuleRsp) Marshal 

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

func (*PutPlacementRuleRsp) MarshalTo 

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

func (*PutPlacementRuleRsp) ProtoMessage 

func (*PutPlacementRuleRsp) ProtoMessage()

func (*PutPlacementRuleRsp) Reset 

func (m *PutPlacementRuleRsp) Reset()

func (*PutPlacementRuleRsp) Size 

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

func (*PutPlacementRuleRsp) String 

func (m *PutPlacementRuleRsp) String() string

func (*PutPlacementRuleRsp) Unmarshal 

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

func (*PutPlacementRuleRsp) XXX_DiscardUnknown 

func (m *PutPlacementRuleRsp) XXX_DiscardUnknown()

func (*PutPlacementRuleRsp) XXX_Marshal 

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

func (*PutPlacementRuleRsp) XXX_Merge 

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

func (*PutPlacementRuleRsp) XXX_Size 

func (m *PutPlacementRuleRsp) XXX_Size() int

func (*PutPlacementRuleRsp) XXX_Unmarshal 

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

type RemoveJobReq 

type RemoveJobReq struct {
	Job                  metapb.Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

RemoveJobReq Remove job req

func (*RemoveJobReq) Descriptor 

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

func (*RemoveJobReq) GetJob 

func (m *RemoveJobReq) GetJob() metapb.Job

func (*RemoveJobReq) Marshal 

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

func (*RemoveJobReq) MarshalTo 

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

func (*RemoveJobReq) ProtoMessage 

func (*RemoveJobReq) ProtoMessage()

func (*RemoveJobReq) Reset 

func (m *RemoveJobReq) Reset()

func (*RemoveJobReq) Size 

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

func (*RemoveJobReq) String 

func (m *RemoveJobReq) String() string

func (*RemoveJobReq) Unmarshal 

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

func (*RemoveJobReq) XXX_DiscardUnknown 

func (m *RemoveJobReq) XXX_DiscardUnknown()

func (*RemoveJobReq) XXX_Marshal 

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

func (*RemoveJobReq) XXX_Merge 

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

func (*RemoveJobReq) XXX_Size 

func (m *RemoveJobReq) XXX_Size() int

func (*RemoveJobReq) XXX_Unmarshal 

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

type RemoveJobRsp 

type RemoveJobRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RemoveJobRsp Remove job rsp

func (*RemoveJobRsp) Descriptor 

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

func (*RemoveJobRsp) Marshal 

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

func (*RemoveJobRsp) MarshalTo 

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

func (*RemoveJobRsp) ProtoMessage 

func (*RemoveJobRsp) ProtoMessage()

func (*RemoveJobRsp) Reset 

func (m *RemoveJobRsp) Reset()

func (*RemoveJobRsp) Size 

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

func (*RemoveJobRsp) String 

func (m *RemoveJobRsp) String() string

func (*RemoveJobRsp) Unmarshal 

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

func (*RemoveJobRsp) XXX_DiscardUnknown 

func (m *RemoveJobRsp) XXX_DiscardUnknown()

func (*RemoveJobRsp) XXX_Marshal 

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

func (*RemoveJobRsp) XXX_Merge 

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

func (*RemoveJobRsp) XXX_Size 

func (m *RemoveJobRsp) XXX_Size() int

func (*RemoveJobRsp) XXX_Unmarshal 

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

type RemoveResourcesReq 

type RemoveResourcesReq struct {
	IDs                  []uint64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RemoveResourcesReq remove resources req

func (*RemoveResourcesReq) Descriptor 

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

func (*RemoveResourcesReq) GetIDs 

func (m *RemoveResourcesReq) GetIDs() []uint64

func (*RemoveResourcesReq) Marshal 

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

func (*RemoveResourcesReq) MarshalTo 

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

func (*RemoveResourcesReq) ProtoMessage 

func (*RemoveResourcesReq) ProtoMessage()

func (*RemoveResourcesReq) Reset 

func (m *RemoveResourcesReq) Reset()

func (*RemoveResourcesReq) Size 

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

func (*RemoveResourcesReq) String 

func (m *RemoveResourcesReq) String() string

func (*RemoveResourcesReq) Unmarshal 

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

func (*RemoveResourcesReq) XXX_DiscardUnknown 

func (m *RemoveResourcesReq) XXX_DiscardUnknown()

func (*RemoveResourcesReq) XXX_Marshal 

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

func (*RemoveResourcesReq) XXX_Merge 

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

func (*RemoveResourcesReq) XXX_Size 

func (m *RemoveResourcesReq) XXX_Size() int

func (*RemoveResourcesReq) XXX_Unmarshal 

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

type RemoveResourcesRsp 

type RemoveResourcesRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RemoveResourcesRsp remove resources rsp

func (*RemoveResourcesRsp) Descriptor 

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

func (*RemoveResourcesRsp) Marshal 

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

func (*RemoveResourcesRsp) MarshalTo 

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

func (*RemoveResourcesRsp) ProtoMessage 

func (*RemoveResourcesRsp) ProtoMessage()

func (*RemoveResourcesRsp) Reset 

func (m *RemoveResourcesRsp) Reset()

func (*RemoveResourcesRsp) Size 

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

func (*RemoveResourcesRsp) String 

func (m *RemoveResourcesRsp) String() string

func (*RemoveResourcesRsp) Unmarshal 

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

func (*RemoveResourcesRsp) XXX_DiscardUnknown 

func (m *RemoveResourcesRsp) XXX_DiscardUnknown()

func (*RemoveResourcesRsp) XXX_Marshal 

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

func (*RemoveResourcesRsp) XXX_Merge 

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

func (*RemoveResourcesRsp) XXX_Size 

func (m *RemoveResourcesRsp) XXX_Size() int

func (*RemoveResourcesRsp) XXX_Unmarshal 

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

type ReportSplitReq 

type ReportSplitReq struct {
	Left                 []byte   `protobuf:"bytes,1,opt,name=left,proto3" json:"left,omitempty"`
	Right                []byte   `protobuf:"bytes,2,opt,name=right,proto3" json:"right,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ReportSplitReq report split request

func (*ReportSplitReq) Descriptor 

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

func (*ReportSplitReq) GetLeft 

func (m *ReportSplitReq) GetLeft() []byte

func (*ReportSplitReq) GetRight 

func (m *ReportSplitReq) GetRight() []byte

func (*ReportSplitReq) Marshal 

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

func (*ReportSplitReq) MarshalTo 

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

func (*ReportSplitReq) ProtoMessage 

func (*ReportSplitReq) ProtoMessage()

func (*ReportSplitReq) Reset 

func (m *ReportSplitReq) Reset()

func (*ReportSplitReq) Size 

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

func (*ReportSplitReq) String 

func (m *ReportSplitReq) String() string

func (*ReportSplitReq) Unmarshal 

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

func (*ReportSplitReq) XXX_DiscardUnknown 

func (m *ReportSplitReq) XXX_DiscardUnknown()

func (*ReportSplitReq) XXX_Marshal 

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

func (*ReportSplitReq) XXX_Merge 

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

func (*ReportSplitReq) XXX_Size 

func (m *ReportSplitReq) XXX_Size() int

func (*ReportSplitReq) XXX_Unmarshal 

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

type ReportSplitRsp 

type ReportSplitRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ReportSplitRsp report split response

func (*ReportSplitRsp) Descriptor 

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

func (*ReportSplitRsp) Marshal 

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

func (*ReportSplitRsp) MarshalTo 

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

func (*ReportSplitRsp) ProtoMessage 

func (*ReportSplitRsp) ProtoMessage()

func (*ReportSplitRsp) Reset 

func (m *ReportSplitRsp) Reset()

func (*ReportSplitRsp) Size 

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

func (*ReportSplitRsp) String 

func (m *ReportSplitRsp) String() string

func (*ReportSplitRsp) Unmarshal 

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

func (*ReportSplitRsp) XXX_DiscardUnknown 

func (m *ReportSplitRsp) XXX_DiscardUnknown()

func (*ReportSplitRsp) XXX_Marshal 

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

func (*ReportSplitRsp) XXX_Merge 

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

func (*ReportSplitRsp) XXX_Size 

func (m *ReportSplitRsp) XXX_Size() int

func (*ReportSplitRsp) XXX_Unmarshal 

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

type Request 

type Request struct {
	ID                   uint64                `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	ContainerID          uint64                `protobuf:"varint,2,opt,name=containerID,proto3" json:"containerID,omitempty"`
	Type                 Type                  `protobuf:"varint,3,opt,name=type,proto3,enum=rpcpb.Type" json:"type,omitempty"`
	ResourceHeartbeat    ResourceHeartbeatReq  `protobuf:"bytes,4,opt,name=resourceHeartbeat,proto3" json:"resourceHeartbeat"`
	ContainerHeartbeat   ContainerHeartbeatReq `protobuf:"bytes,5,opt,name=containerHeartbeat,proto3" json:"containerHeartbeat"`
	PutContainer         PutContainerReq       `protobuf:"bytes,6,opt,name=putContainer,proto3" json:"putContainer"`
	GetContainer         GetContainerReq       `protobuf:"bytes,7,opt,name=getContainer,proto3" json:"getContainer"`
	AllocID              AllocIDReq            `protobuf:"bytes,8,opt,name=allocID,proto3" json:"allocID"`
	AskSplit             AskSplitReq           `protobuf:"bytes,9,opt,name=askSplit,proto3" json:"askSplit"`
	AskBatchSplit        AskBatchSplitReq      `protobuf:"bytes,10,opt,name=askBatchSplit,proto3" json:"askBatchSplit"`
	ReportSplit          ReportSplitReq        `protobuf:"bytes,11,opt,name=reportSplit,proto3" json:"reportSplit"`
	BatchReportSplit     BatchReportSplitReq   `protobuf:"bytes,12,opt,name=batchReportSplit,proto3" json:"batchReportSplit"`
	CreateWatcher        CreateWatcherReq      `protobuf:"bytes,13,opt,name=createWatcher,proto3" json:"createWatcher"`
	CreateResources      CreateResourcesReq    `protobuf:"bytes,14,opt,name=createResources,proto3" json:"createResources"`
	RemoveResources      RemoveResourcesReq    `protobuf:"bytes,15,opt,name=removeResources,proto3" json:"removeResources"`
	CheckResourceState   CheckResourceStateReq `protobuf:"bytes,16,opt,name=checkResourceState,proto3" json:"checkResourceState"`
	PutPlacementRule     PutPlacementRuleReq   `protobuf:"bytes,17,opt,name=putPlacementRule,proto3" json:"putPlacementRule"`
	GetAppliedRules      GetAppliedRulesReq    `protobuf:"bytes,18,opt,name=getAppliedRules,proto3" json:"getAppliedRules"`
	CreateJob            CreateJobReq          `protobuf:"bytes,19,opt,name=createJob,proto3" json:"createJob"`
	RemoveJob            RemoveJobReq          `protobuf:"bytes,20,opt,name=removeJob,proto3" json:"removeJob"`
	ExecuteJob           ExecuteJobReq         `protobuf:"bytes,21,opt,name=executeJob,proto3" json:"executeJob"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

Request the prophet rpc request

func (*Request) Descriptor 

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

func (*Request) GetAllocID 

func (m *Request) GetAllocID() AllocIDReq

func (*Request) GetAskBatchSplit 

func (m *Request) GetAskBatchSplit() AskBatchSplitReq

func (*Request) GetAskSplit 

func (m *Request) GetAskSplit() AskSplitReq

func (*Request) GetBatchReportSplit 

func (m *Request) GetBatchReportSplit() BatchReportSplitReq

func (*Request) GetCheckResourceState 

func (m *Request) GetCheckResourceState() CheckResourceStateReq

func (*Request) GetContainerHeartbeat 

func (m *Request) GetContainerHeartbeat() ContainerHeartbeatReq

func (*Request) GetContainerID 

func (m *Request) GetContainerID() uint64

func (*Request) GetCreateJob 

func (m *Request) GetCreateJob() CreateJobReq

func (*Request) GetCreateResources 

func (m *Request) GetCreateResources() CreateResourcesReq

func (*Request) GetCreateWatcher 

func (m *Request) GetCreateWatcher() CreateWatcherReq

func (*Request) GetExecuteJob 

func (m *Request) GetExecuteJob() ExecuteJobReq

func (*Request) GetGetAppliedRules 

func (m *Request) GetGetAppliedRules() GetAppliedRulesReq

func (*Request) GetGetContainer 

func (m *Request) GetGetContainer() GetContainerReq

func (*Request) GetID 

func (m *Request) GetID() uint64

func (*Request) GetPutContainer 

func (m *Request) GetPutContainer() PutContainerReq

func (*Request) GetPutPlacementRule 

func (m *Request) GetPutPlacementRule() PutPlacementRuleReq

func (*Request) GetRemoveJob 

func (m *Request) GetRemoveJob() RemoveJobReq

func (*Request) GetRemoveResources 

func (m *Request) GetRemoveResources() RemoveResourcesReq

func (*Request) GetReportSplit 

func (m *Request) GetReportSplit() ReportSplitReq

func (*Request) GetResourceHeartbeat 

func (m *Request) GetResourceHeartbeat() ResourceHeartbeatReq

func (*Request) GetType 

func (m *Request) GetType() Type

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

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

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

func (*Request) XXX_Merge 

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

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

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

type ResourceEventData 

type ResourceEventData struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Leader               uint64   `protobuf:"varint,2,opt,name=leader,proto3" json:"leader,omitempty"`
	Removed              bool     `protobuf:"varint,3,opt,name=removed,proto3" json:"removed,omitempty"`
	Create               bool     `protobuf:"varint,4,opt,name=create,proto3" json:"create,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ResourceEventData resource created or updated

func (*ResourceEventData) Descriptor 

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

func (*ResourceEventData) GetCreate 

func (m *ResourceEventData) GetCreate() bool

func (*ResourceEventData) GetData 

func (m *ResourceEventData) GetData() []byte

func (*ResourceEventData) GetLeader 

func (m *ResourceEventData) GetLeader() uint64

func (*ResourceEventData) GetRemoved 

func (m *ResourceEventData) GetRemoved() bool

func (*ResourceEventData) Marshal 

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

func (*ResourceEventData) MarshalTo 

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

func (*ResourceEventData) ProtoMessage 

func (*ResourceEventData) ProtoMessage()

func (*ResourceEventData) Reset 

func (m *ResourceEventData) Reset()

func (*ResourceEventData) Size 

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

func (*ResourceEventData) String 

func (m *ResourceEventData) String() string

func (*ResourceEventData) Unmarshal 

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

func (*ResourceEventData) XXX_DiscardUnknown 

func (m *ResourceEventData) XXX_DiscardUnknown()

func (*ResourceEventData) XXX_Marshal 

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

func (*ResourceEventData) XXX_Merge 

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

func (*ResourceEventData) XXX_Size 

func (m *ResourceEventData) XXX_Size() int

func (*ResourceEventData) XXX_Unmarshal 

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

type ResourceHeartbeatReq 

type ResourceHeartbeatReq struct {
	ContainerID uint64 `protobuf:"varint,1,opt,name=containerID,proto3" json:"containerID,omitempty"`
	Resource    []byte `protobuf:"bytes,2,opt,name=resource,proto3" json:"resource,omitempty"`
	// Term is the term of raft group.
	Term                 uint64               `protobuf:"varint,3,opt,name=term,proto3" json:"term,omitempty"`
	Leader               *metapb.Peer         `protobuf:"bytes,4,opt,name=leader,proto3" json:"leader,omitempty"`
	DownPeers            []metapb.PeerStats   `protobuf:"bytes,5,rep,name=downPeers,proto3" json:"downPeers"`
	PendingPeers         []metapb.Peer        `protobuf:"bytes,6,rep,name=pendingPeers,proto3" json:"pendingPeers"`
	Stats                metapb.ResourceStats `protobuf:"bytes,7,opt,name=stats,proto3" json:"stats"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

ResourceHeartbeatReq resource heartbeat request

func (*ResourceHeartbeatReq) Descriptor 

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

func (*ResourceHeartbeatReq) GetContainerID 

func (m *ResourceHeartbeatReq) GetContainerID() uint64

func (*ResourceHeartbeatReq) GetDownPeers 

func (m *ResourceHeartbeatReq) GetDownPeers() []metapb.PeerStats

func (*ResourceHeartbeatReq) GetLeader 

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

func (*ResourceHeartbeatReq) GetPendingPeers 

func (m *ResourceHeartbeatReq) GetPendingPeers() []metapb.Peer

func (*ResourceHeartbeatReq) GetResource 

func (m *ResourceHeartbeatReq) GetResource() []byte

func (*ResourceHeartbeatReq) GetStats 

func (m *ResourceHeartbeatReq) GetStats() metapb.ResourceStats

func (*ResourceHeartbeatReq) GetTerm 

func (m *ResourceHeartbeatReq) GetTerm() uint64

func (*ResourceHeartbeatReq) Marshal 

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

func (*ResourceHeartbeatReq) MarshalTo 

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

func (*ResourceHeartbeatReq) ProtoMessage 

func (*ResourceHeartbeatReq) ProtoMessage()

func (*ResourceHeartbeatReq) Reset 

func (m *ResourceHeartbeatReq) Reset()

func (*ResourceHeartbeatReq) Size 

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

func (*ResourceHeartbeatReq) String 

func (m *ResourceHeartbeatReq) String() string

func (*ResourceHeartbeatReq) Unmarshal 

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

func (*ResourceHeartbeatReq) XXX_DiscardUnknown 

func (m *ResourceHeartbeatReq) XXX_DiscardUnknown()

func (*ResourceHeartbeatReq) XXX_Marshal 

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

func (*ResourceHeartbeatReq) XXX_Merge 

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

func (*ResourceHeartbeatReq) XXX_Size 

func (m *ResourceHeartbeatReq) XXX_Size() int

func (*ResourceHeartbeatReq) XXX_Unmarshal 

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

type ResourceHeartbeatRsp 

type ResourceHeartbeatRsp struct {
	ResourceID    uint64               `protobuf:"varint,1,opt,name=resourceID,proto3" json:"resourceID,omitempty"`
	ResourceEpoch metapb.ResourceEpoch `protobuf:"bytes,2,opt,name=resourceEpoch,proto3" json:"resourceEpoch"`
	// Leader of the resource at the moment of the corresponding request was made.
	TargetPeer *metapb.Peer `protobuf:"bytes,3,opt,name=targetPeer,proto3" json:"targetPeer,omitempty"`
	// Notice, prophet only allows handling reported epoch >= current prophet's.
	// Leader peer reports resource status with ResourceHeartbeatReq
	// to prophet regularly, prophet will determine whether this resource
	// should do ChangePeer or not.
	// E,g, max peer number is 3, resource A, first only peer 1 in A.
	// 1. prophet resource state -> Peers (1), ConfVer (1).
	// 2. Leader peer 1 reports resource state to prophet, prophet finds the
	// peer number is < 3, so first changes its current resource
	// state -> Peers (1, 2), ConfVer (1), and returns ChangePeer Adding 2.
	// 3. Leader does ChangePeer, then reports Peers (1, 2), ConfVer (2),
	// prophet updates its state -> Peers (1, 2), ConfVer (2).
	// 4. Leader may report old Peers (1), ConfVer (1) to pd before ConfChange
	// finished, pd stills responses ChangePeer Adding 2, of course, we must
	// guarantee the second ChangePeer can't be applied in your application.
	ChangePeer     *ChangePeer     `protobuf:"bytes,4,opt,name=changePeer,proto3" json:"changePeer,omitempty"`
	TransferLeader *TransferLeader `protobuf:"bytes,5,opt,name=transferLeader,proto3" json:"transferLeader,omitempty"`
	Merge          *Merge          `protobuf:"bytes,6,opt,name=merge,proto3" json:"merge,omitempty"`
	SplitResource  *SplitResource  `protobuf:"bytes,7,opt,name=splitResource,proto3" json:"splitResource,omitempty"`
	ChangePeerV2   *ChangePeerV2   `protobuf:"bytes,8,opt,name=changePeerV2,proto3" json:"changePeerV2,omitempty"`
	// DestoryDirectly the resource has been removed, destory directly without raft.
	DestoryDirectly      bool     `protobuf:"varint,9,opt,name=destoryDirectly,proto3" json:"destoryDirectly,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ResourceHeartbeatRsp resource heartbeat response.

func (*ResourceHeartbeatRsp) Descriptor 

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

func (*ResourceHeartbeatRsp) GetChangePeer 

func (m *ResourceHeartbeatRsp) GetChangePeer() *ChangePeer

func (*ResourceHeartbeatRsp) GetChangePeerV2 

func (m *ResourceHeartbeatRsp) GetChangePeerV2() *ChangePeerV2

func (*ResourceHeartbeatRsp) GetDestoryDirectly 

func (m *ResourceHeartbeatRsp) GetDestoryDirectly() bool

func (*ResourceHeartbeatRsp) GetMerge 

func (m *ResourceHeartbeatRsp) GetMerge() *Merge

func (*ResourceHeartbeatRsp) GetResourceEpoch 

func (m *ResourceHeartbeatRsp) GetResourceEpoch() metapb.ResourceEpoch

func (*ResourceHeartbeatRsp) GetResourceID 

func (m *ResourceHeartbeatRsp) GetResourceID() uint64

func (*ResourceHeartbeatRsp) GetSplitResource 

func (m *ResourceHeartbeatRsp) GetSplitResource() *SplitResource

func (*ResourceHeartbeatRsp) GetTargetPeer 

func (m *ResourceHeartbeatRsp) GetTargetPeer() *metapb.Peer

func (*ResourceHeartbeatRsp) GetTransferLeader 

func (m *ResourceHeartbeatRsp) GetTransferLeader() *TransferLeader

func (*ResourceHeartbeatRsp) Marshal 

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

func (*ResourceHeartbeatRsp) MarshalTo 

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

func (*ResourceHeartbeatRsp) ProtoMessage 

func (*ResourceHeartbeatRsp) ProtoMessage()

func (*ResourceHeartbeatRsp) Reset 

func (m *ResourceHeartbeatRsp) Reset()

func (*ResourceHeartbeatRsp) Size 

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

func (*ResourceHeartbeatRsp) String 

func (m *ResourceHeartbeatRsp) String() string

func (*ResourceHeartbeatRsp) Unmarshal 

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

func (*ResourceHeartbeatRsp) XXX_DiscardUnknown 

func (m *ResourceHeartbeatRsp) XXX_DiscardUnknown()

func (*ResourceHeartbeatRsp) XXX_Marshal 

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

func (*ResourceHeartbeatRsp) XXX_Merge 

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

func (*ResourceHeartbeatRsp) XXX_Size 

func (m *ResourceHeartbeatRsp) XXX_Size() int

func (*ResourceHeartbeatRsp) XXX_Unmarshal 

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

type Response 

type Response struct {
	ID                   uint64                `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Type                 Type                  `protobuf:"varint,2,opt,name=type,proto3,enum=rpcpb.Type" json:"type,omitempty"`
	Error                string                `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	Leader               string                `protobuf:"bytes,4,opt,name=leader,proto3" json:"leader,omitempty"`
	ResourceHeartbeat    ResourceHeartbeatRsp  `protobuf:"bytes,5,opt,name=resourceHeartbeat,proto3" json:"resourceHeartbeat"`
	ContainerHeartbeat   ContainerHeartbeatRsp `protobuf:"bytes,6,opt,name=containerHeartbeat,proto3" json:"containerHeartbeat"`
	PutContainer         PutContainerRsp       `protobuf:"bytes,7,opt,name=putContainer,proto3" json:"putContainer"`
	GetContainer         GetContainerRsp       `protobuf:"bytes,8,opt,name=getContainer,proto3" json:"getContainer"`
	AllocID              AllocIDRsp            `protobuf:"bytes,9,opt,name=allocID,proto3" json:"allocID"`
	AskSplit             AskSplitRsp           `protobuf:"bytes,10,opt,name=askSplit,proto3" json:"askSplit"`
	AskBatchSplit        AskBatchSplitRsp      `protobuf:"bytes,11,opt,name=askBatchSplit,proto3" json:"askBatchSplit"`
	ReportSplit          ReportSplitRsp        `protobuf:"bytes,12,opt,name=reportSplit,proto3" json:"reportSplit"`
	BatchReportSplit     BatchReportSplitRsp   `protobuf:"bytes,13,opt,name=batchReportSplit,proto3" json:"batchReportSplit"`
	Event                EventNotify           `protobuf:"bytes,14,opt,name=event,proto3" json:"event"`
	CreateResources      CreateResourcesRsp    `protobuf:"bytes,15,opt,name=createResources,proto3" json:"createResources"`
	RemoveResources      RemoveResourcesRsp    `protobuf:"bytes,16,opt,name=removeResources,proto3" json:"removeResources"`
	CheckResourceState   CheckResourceStateRsp `protobuf:"bytes,17,opt,name=checkResourceState,proto3" json:"checkResourceState"`
	PutPlacementRule     PutPlacementRuleRsp   `protobuf:"bytes,18,opt,name=putPlacementRule,proto3" json:"putPlacementRule"`
	GetAppliedRules      GetAppliedRulesRsp    `protobuf:"bytes,19,opt,name=getAppliedRules,proto3" json:"getAppliedRules"`
	CreateJob            CreateJobRsp          `protobuf:"bytes,20,opt,name=createJob,proto3" json:"createJob"`
	RemoveJob            RemoveJobRsp          `protobuf:"bytes,21,opt,name=removeJob,proto3" json:"removeJob"`
	ExecuteJob           ExecuteJobRsp         `protobuf:"bytes,22,opt,name=executeJob,proto3" json:"executeJob"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

Response the prophet rpc response

func (*Response) Descriptor 

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

func (*Response) GetAllocID 

func (m *Response) GetAllocID() AllocIDRsp

func (*Response) GetAskBatchSplit 

func (m *Response) GetAskBatchSplit() AskBatchSplitRsp

func (*Response) GetAskSplit 

func (m *Response) GetAskSplit() AskSplitRsp

func (*Response) GetBatchReportSplit 

func (m *Response) GetBatchReportSplit() BatchReportSplitRsp

func (*Response) GetCheckResourceState 

func (m *Response) GetCheckResourceState() CheckResourceStateRsp

func (*Response) GetContainerHeartbeat 

func (m *Response) GetContainerHeartbeat() ContainerHeartbeatRsp

func (*Response) GetCreateJob 

func (m *Response) GetCreateJob() CreateJobRsp

func (*Response) GetCreateResources 

func (m *Response) GetCreateResources() CreateResourcesRsp

func (*Response) GetError 

func (m *Response) GetError() string

func (*Response) GetEvent 

func (m *Response) GetEvent() EventNotify

func (*Response) GetExecuteJob 

func (m *Response) GetExecuteJob() ExecuteJobRsp

func (*Response) GetGetAppliedRules 

func (m *Response) GetGetAppliedRules() GetAppliedRulesRsp

func (*Response) GetGetContainer 

func (m *Response) GetGetContainer() GetContainerRsp

func (*Response) GetID 

func (m *Response) GetID() uint64

func (*Response) GetLeader 

func (m *Response) GetLeader() string

func (*Response) GetPutContainer 

func (m *Response) GetPutContainer() PutContainerRsp

func (*Response) GetPutPlacementRule 

func (m *Response) GetPutPlacementRule() PutPlacementRuleRsp

func (*Response) GetRemoveJob 

func (m *Response) GetRemoveJob() RemoveJobRsp

func (*Response) GetRemoveResources 

func (m *Response) GetRemoveResources() RemoveResourcesRsp

func (*Response) GetReportSplit 

func (m *Response) GetReportSplit() ReportSplitRsp

func (*Response) GetResourceHeartbeat 

func (m *Response) GetResourceHeartbeat() ResourceHeartbeatRsp

func (*Response) GetType 

func (m *Response) GetType() Type

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

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

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

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

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

type SplitID 

type SplitID struct {
	NewID                uint64   `protobuf:"varint,1,opt,name=newID,proto3" json:"newID,omitempty"`
	NewPeerIDs           []uint64 `protobuf:"varint,2,rep,packed,name=newPeerIDs,proto3" json:"newPeerIDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

SplitID split id

func (*SplitID) Descriptor 

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

func (*SplitID) GetNewID 

func (m *SplitID) GetNewID() uint64

func (*SplitID) GetNewPeerIDs 

func (m *SplitID) GetNewPeerIDs() []uint64

func (*SplitID) Marshal 

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

func (*SplitID) MarshalTo 

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

func (*SplitID) ProtoMessage 

func (*SplitID) ProtoMessage()

func (*SplitID) Reset 

func (m *SplitID) Reset()

func (*SplitID) Size 

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

func (*SplitID) String 

func (m *SplitID) String() string

func (*SplitID) Unmarshal 

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

func (*SplitID) XXX_DiscardUnknown 

func (m *SplitID) XXX_DiscardUnknown()

func (*SplitID) XXX_Marshal 

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

func (*SplitID) XXX_Merge 

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

func (*SplitID) XXX_Size 

func (m *SplitID) XXX_Size() int

func (*SplitID) XXX_Unmarshal 

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

type SplitResource 

type SplitResource struct {
	Policy               metapb.CheckPolicy `protobuf:"varint,1,opt,name=policy,proto3,enum=metapb.CheckPolicy" json:"policy,omitempty"`
	Keys                 [][]byte           `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

SplitResource split resource

func (*SplitResource) Descriptor 

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

func (*SplitResource) GetKeys 

func (m *SplitResource) GetKeys() [][]byte

func (*SplitResource) GetPolicy 

func (m *SplitResource) GetPolicy() metapb.CheckPolicy

func (*SplitResource) Marshal 

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

func (*SplitResource) MarshalTo 

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

func (*SplitResource) ProtoMessage 

func (*SplitResource) ProtoMessage()

func (*SplitResource) Reset 

func (m *SplitResource) Reset()

func (*SplitResource) Size 

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

func (*SplitResource) String 

func (m *SplitResource) String() string

func (*SplitResource) Unmarshal 

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

func (*SplitResource) XXX_DiscardUnknown 

func (m *SplitResource) XXX_DiscardUnknown()

func (*SplitResource) XXX_Marshal 

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

func (*SplitResource) XXX_Merge 

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

func (*SplitResource) XXX_Size 

func (m *SplitResource) XXX_Size() int

func (*SplitResource) XXX_Unmarshal 

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

type TransferLeader 

type TransferLeader struct {
	Peer                 metapb.Peer `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

TransferLeader transfer leader

func (*TransferLeader) Descriptor 

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

func (*TransferLeader) GetPeer 

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

func (*TransferLeader) Marshal 

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

func (*TransferLeader) MarshalTo 

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

func (*TransferLeader) ProtoMessage 

func (*TransferLeader) ProtoMessage()

func (*TransferLeader) Reset 

func (m *TransferLeader) Reset()

func (*TransferLeader) Size 

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

func (*TransferLeader) String 

func (m *TransferLeader) String() string

func (*TransferLeader) Unmarshal 

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

func (*TransferLeader) XXX_DiscardUnknown 

func (m *TransferLeader) XXX_DiscardUnknown()

func (*TransferLeader) XXX_Marshal 

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

func (*TransferLeader) XXX_Merge 

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

func (*TransferLeader) XXX_Size 

func (m *TransferLeader) XXX_Size() int

func (*TransferLeader) XXX_Unmarshal 

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

type Type 

type Type int32

Type rpc type 

const (
	TypeRegisterContainer     Type = 0
	TypeResourceHeartbeatReq  Type = 1
	TypeResourceHeartbeatRsp  Type = 2
	TypeContainerHeartbeatReq Type = 3
	TypeContainerHeartbeatRsp Type = 4
	TypePutContainerReq       Type = 5
	TypePutContainerRsp       Type = 6
	TypeGetContainerReq       Type = 7
	TypeGetContainerRsp       Type = 8
	TypeAllocIDReq            Type = 9
	TypeAllocIDRsp            Type = 10
	TypeAskSplitReq           Type = 11
	TypeAskSplitRsp           Type = 12
	TypeAskBatchSplitReq      Type = 13
	TypeAskBatchSplitRsp      Type = 14
	TypeReportSplitReq        Type = 15
	TypeReportSplitRsp        Type = 16
	TypeBatchReportSplitReq   Type = 17
	TypeBatchReportSplitRsp   Type = 18
	TypeCreateWatcherReq      Type = 19
	TypeEventNotify           Type = 20
	TypeCreateResourcesReq    Type = 21
	TypeCreateResourcesRsp    Type = 22
	TypeRemoveResourcesReq    Type = 23
	TypeRemoveResourcesRsp    Type = 24
	TypeCheckResourceStateReq Type = 25
	TypeCheckResourceStateRsp Type = 26
	TypePutPlacementRuleReq   Type = 27
	TypePutPlacementRuleRsp   Type = 28
	TypeGetAppliedRulesReq    Type = 29
	TypeGetAppliedRulesRsp    Type = 30
	TypeCreateJobReq          Type = 31
	TypeCreateJobRsp          Type = 32
	TypeRemoveJobReq          Type = 33
	TypeRemoveJobRsp          Type = 34
	TypeExecuteJobReq         Type = 35
	TypeExecuteJobRsp         Type = 36
)

func (Type) EnumDescriptor 

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

func (Type) String 

func (x Type) 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.