rpcpb

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Mar 9, 2022 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 ReplicaRoleType_name = map[int32]string{
	0: "Voter",
	1: "Leader",
	2: "Follower",
	3: "Learner",
}
View Source 
var ReplicaRoleType_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: "TypeAskBatchSplitReq",
	12: "TypeAskBatchSplitRsp",
	13: "TypeCreateDestroyingReq",
	14: "TypeCreateDestroyingRsp",
	15: "TypeReportDestroyedReq",
	16: "TypeReportDestroyedRsp",
	17: "TypeGetDestroyingReq",
	18: "TypeGetDestroyingRsp",
	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",
	37: "TypeAddScheduleGroupRuleReq",
	38: "TypeAddScheduleGroupRuleRsp",
	39: "TypeGetScheduleGroupRuleReq",
	40: "TypeGetScheduleGroupRuleRsp",
}
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,
	"TypeAskBatchSplitReq":        11,
	"TypeAskBatchSplitRsp":        12,
	"TypeCreateDestroyingReq":     13,
	"TypeCreateDestroyingRsp":     14,
	"TypeReportDestroyedReq":      15,
	"TypeReportDestroyedRsp":      16,
	"TypeGetDestroyingReq":        17,
	"TypeGetDestroyingRsp":        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,
	"TypeAddScheduleGroupRuleReq": 37,
	"TypeAddScheduleGroupRuleRsp": 38,
	"TypeGetScheduleGroupRuleReq": 39,
	"TypeGetScheduleGroupRuleRsp": 40,
}

Functions

This section is empty.

Types

type AddScheduleGroupRuleReq added in v0.2.0 

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

func (*AddScheduleGroupRuleReq) Descriptor added in v0.2.0 

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

func (*AddScheduleGroupRuleReq) GetRule added in v0.2.0 

func (m *AddScheduleGroupRuleReq) GetRule() metapb.ScheduleGroupRule

func (*AddScheduleGroupRuleReq) Marshal added in v0.2.0 

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

func (*AddScheduleGroupRuleReq) MarshalTo added in v0.2.0 

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

func (*AddScheduleGroupRuleReq) ProtoMessage added in v0.2.0 

func (*AddScheduleGroupRuleReq) ProtoMessage()

func (*AddScheduleGroupRuleReq) Reset added in v0.2.0 

func (m *AddScheduleGroupRuleReq) Reset()

func (*AddScheduleGroupRuleReq) Size added in v0.2.0 

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

func (*AddScheduleGroupRuleReq) String added in v0.2.0 

func (m *AddScheduleGroupRuleReq) String() string

func (*AddScheduleGroupRuleReq) Unmarshal added in v0.2.0 

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

func (*AddScheduleGroupRuleReq) XXX_DiscardUnknown added in v0.2.0 

func (m *AddScheduleGroupRuleReq) XXX_DiscardUnknown()

func (*AddScheduleGroupRuleReq) XXX_Marshal added in v0.2.0 

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

func (*AddScheduleGroupRuleReq) XXX_Merge added in v0.2.0 

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

func (*AddScheduleGroupRuleReq) XXX_Size added in v0.2.0 

func (m *AddScheduleGroupRuleReq) XXX_Size() int

func (*AddScheduleGroupRuleReq) XXX_Unmarshal added in v0.2.0 

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

type AddScheduleGroupRuleRsp added in v0.2.0 

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

func (*AddScheduleGroupRuleRsp) Descriptor added in v0.2.0 

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

func (*AddScheduleGroupRuleRsp) Marshal added in v0.2.0 

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

func (*AddScheduleGroupRuleRsp) MarshalTo added in v0.2.0 

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

func (*AddScheduleGroupRuleRsp) ProtoMessage added in v0.2.0 

func (*AddScheduleGroupRuleRsp) ProtoMessage()

func (*AddScheduleGroupRuleRsp) Reset added in v0.2.0 

func (m *AddScheduleGroupRuleRsp) Reset()

func (*AddScheduleGroupRuleRsp) Size added in v0.2.0 

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

func (*AddScheduleGroupRuleRsp) String added in v0.2.0 

func (m *AddScheduleGroupRuleRsp) String() string

func (*AddScheduleGroupRuleRsp) Unmarshal added in v0.2.0 

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

func (*AddScheduleGroupRuleRsp) XXX_DiscardUnknown added in v0.2.0 

func (m *AddScheduleGroupRuleRsp) XXX_DiscardUnknown()

func (*AddScheduleGroupRuleRsp) XXX_Marshal added in v0.2.0 

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

func (*AddScheduleGroupRuleRsp) XXX_Merge added in v0.2.0 

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

func (*AddScheduleGroupRuleRsp) XXX_Size added in v0.2.0 

func (m *AddScheduleGroupRuleRsp) XXX_Size() int

func (*AddScheduleGroupRuleRsp) XXX_Unmarshal added in v0.2.0 

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

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 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 {
	Destroyed            []byte   `protobuf:"bytes,1,opt,name=destroyed,proto3" json:"destroyed,omitempty"`
	Destroying           []byte   `protobuf:"bytes,2,opt,name=destroying,proto3" json:"destroying,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) GetDestroyed added in v0.2.0 

func (m *CheckResourceStateRsp) GetDestroyed() []byte

func (*CheckResourceStateRsp) GetDestroying added in v0.2.0 

func (m *CheckResourceStateRsp) GetDestroying() []byte

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 ConfigChange added in v0.2.0 

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

ChangePeer change peer

func (*ConfigChange) Descriptor added in v0.2.0 

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

func (*ConfigChange) GetChangeType added in v0.2.0 

func (m *ConfigChange) GetChangeType() metapb.ConfigChangeType

func (*ConfigChange) GetReplica added in v0.2.0 

func (m *ConfigChange) GetReplica() metapb.Replica

func (*ConfigChange) Marshal added in v0.2.0 

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

func (*ConfigChange) MarshalTo added in v0.2.0 

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

func (*ConfigChange) ProtoMessage added in v0.2.0 

func (*ConfigChange) ProtoMessage()

func (*ConfigChange) Reset added in v0.2.0 

func (m *ConfigChange) Reset()

func (*ConfigChange) Size added in v0.2.0 

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

func (*ConfigChange) String added in v0.2.0 

func (m *ConfigChange) String() string

func (*ConfigChange) Unmarshal added in v0.2.0 

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

func (*ConfigChange) XXX_DiscardUnknown added in v0.2.0 

func (m *ConfigChange) XXX_DiscardUnknown()

func (*ConfigChange) XXX_Marshal added in v0.2.0 

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

func (*ConfigChange) XXX_Merge added in v0.2.0 

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

func (*ConfigChange) XXX_Size added in v0.2.0 

func (m *ConfigChange) XXX_Size() int

func (*ConfigChange) XXX_Unmarshal added in v0.2.0 

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

type ConfigChangeV2 added in v0.2.0 

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

ConfigChangeV2 change peer v2

func (*ConfigChangeV2) Descriptor added in v0.2.0 

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

func (*ConfigChangeV2) GetChanges added in v0.2.0 

func (m *ConfigChangeV2) GetChanges() []ConfigChange

func (*ConfigChangeV2) Marshal added in v0.2.0 

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

func (*ConfigChangeV2) MarshalTo added in v0.2.0 

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

func (*ConfigChangeV2) ProtoMessage added in v0.2.0 

func (*ConfigChangeV2) ProtoMessage()

func (*ConfigChangeV2) Reset added in v0.2.0 

func (m *ConfigChangeV2) Reset()

func (*ConfigChangeV2) Size added in v0.2.0 

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

func (*ConfigChangeV2) String added in v0.2.0 

func (m *ConfigChangeV2) String() string

func (*ConfigChangeV2) Unmarshal added in v0.2.0 

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

func (*ConfigChangeV2) XXX_DiscardUnknown added in v0.2.0 

func (m *ConfigChangeV2) XXX_DiscardUnknown()

func (*ConfigChangeV2) XXX_Marshal added in v0.2.0 

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

func (*ConfigChangeV2) XXX_Merge added in v0.2.0 

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

func (*ConfigChangeV2) XXX_Size added in v0.2.0 

func (m *ConfigChangeV2) XXX_Size() int

func (*ConfigChangeV2) XXX_Unmarshal added in v0.2.0 

func (m *ConfigChangeV2) 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 CreateDestroyingReq added in v0.2.0 

type CreateDestroyingReq struct {
	ID                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Index                uint64   `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	Replicas             []uint64 `protobuf:"varint,3,rep,packed,name=replicas,proto3" json:"replicas,omitempty"`
	RemoveData           bool     `protobuf:"varint,4,opt,name=removeData,proto3" json:"removeData,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CreateDestroyingReq create destroying status request

func (*CreateDestroyingReq) Descriptor added in v0.2.0 

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

func (*CreateDestroyingReq) GetID added in v0.2.0 

func (m *CreateDestroyingReq) GetID() uint64

func (*CreateDestroyingReq) GetIndex added in v0.2.0 

func (m *CreateDestroyingReq) GetIndex() uint64

func (*CreateDestroyingReq) GetRemoveData added in v0.2.0 

func (m *CreateDestroyingReq) GetRemoveData() bool

func (*CreateDestroyingReq) GetReplicas added in v0.2.0 

func (m *CreateDestroyingReq) GetReplicas() []uint64

func (*CreateDestroyingReq) Marshal added in v0.2.0 

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

func (*CreateDestroyingReq) MarshalTo added in v0.2.0 

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

func (*CreateDestroyingReq) ProtoMessage added in v0.2.0 

func (*CreateDestroyingReq) ProtoMessage()

func (*CreateDestroyingReq) Reset added in v0.2.0 

func (m *CreateDestroyingReq) Reset()

func (*CreateDestroyingReq) Size added in v0.2.0 

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

func (*CreateDestroyingReq) String added in v0.2.0 

func (m *CreateDestroyingReq) String() string

func (*CreateDestroyingReq) Unmarshal added in v0.2.0 

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

func (*CreateDestroyingReq) XXX_DiscardUnknown added in v0.2.0 

func (m *CreateDestroyingReq) XXX_DiscardUnknown()

func (*CreateDestroyingReq) XXX_Marshal added in v0.2.0 

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

func (*CreateDestroyingReq) XXX_Merge added in v0.2.0 

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

func (*CreateDestroyingReq) XXX_Size added in v0.2.0 

func (m *CreateDestroyingReq) XXX_Size() int

func (*CreateDestroyingReq) XXX_Unmarshal added in v0.2.0 

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

type CreateDestroyingRsp added in v0.2.0 

type CreateDestroyingRsp struct {
	State                metapb.ResourceState `protobuf:"varint,1,opt,name=state,proto3,enum=metapb.ResourceState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

CreateDestroyingRsp create destroying status response

func (*CreateDestroyingRsp) Descriptor added in v0.2.0 

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

func (*CreateDestroyingRsp) GetState added in v0.2.0 

func (m *CreateDestroyingRsp) GetState() metapb.ResourceState

func (*CreateDestroyingRsp) Marshal added in v0.2.0 

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

func (*CreateDestroyingRsp) MarshalTo added in v0.2.0 

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

func (*CreateDestroyingRsp) ProtoMessage added in v0.2.0 

func (*CreateDestroyingRsp) ProtoMessage()

func (*CreateDestroyingRsp) Reset added in v0.2.0 

func (m *CreateDestroyingRsp) Reset()

func (*CreateDestroyingRsp) Size added in v0.2.0 

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

func (*CreateDestroyingRsp) String added in v0.2.0 

func (m *CreateDestroyingRsp) String() string

func (*CreateDestroyingRsp) Unmarshal added in v0.2.0 

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

func (*CreateDestroyingRsp) XXX_DiscardUnknown added in v0.2.0 

func (m *CreateDestroyingRsp) XXX_DiscardUnknown()

func (*CreateDestroyingRsp) XXX_Marshal added in v0.2.0 

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

func (*CreateDestroyingRsp) XXX_Merge added in v0.2.0 

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

func (*CreateDestroyingRsp) XXX_Size added in v0.2.0 

func (m *CreateDestroyingRsp) XXX_Size() int

func (*CreateDestroyingRsp) XXX_Unmarshal added in v0.2.0 

func (m *CreateDestroyingRsp) 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"`
	LeastReplicas        []uint64 `protobuf:"varint,2,rep,packed,name=leastReplicas,proto3" json:"leastReplicas,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) GetLeastReplicas added in v0.2.0 

func (m *CreateResourcesReq) GetLeastReplicas() []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 GetDestroyingReq added in v0.2.0 

type GetDestroyingReq 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:"-"`
}

GetDestroyingReq get destroying status request

func (*GetDestroyingReq) Descriptor added in v0.2.0 

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

func (*GetDestroyingReq) GetID added in v0.2.0 

func (m *GetDestroyingReq) GetID() uint64

func (*GetDestroyingReq) Marshal added in v0.2.0 

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

func (*GetDestroyingReq) MarshalTo added in v0.2.0 

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

func (*GetDestroyingReq) ProtoMessage added in v0.2.0 

func (*GetDestroyingReq) ProtoMessage()

func (*GetDestroyingReq) Reset added in v0.2.0 

func (m *GetDestroyingReq) Reset()

func (*GetDestroyingReq) Size added in v0.2.0 

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

func (*GetDestroyingReq) String added in v0.2.0 

func (m *GetDestroyingReq) String() string

func (*GetDestroyingReq) Unmarshal added in v0.2.0 

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

func (*GetDestroyingReq) XXX_DiscardUnknown added in v0.2.0 

func (m *GetDestroyingReq) XXX_DiscardUnknown()

func (*GetDestroyingReq) XXX_Marshal added in v0.2.0 

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

func (*GetDestroyingReq) XXX_Merge added in v0.2.0 

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

func (*GetDestroyingReq) XXX_Size added in v0.2.0 

func (m *GetDestroyingReq) XXX_Size() int

func (*GetDestroyingReq) XXX_Unmarshal added in v0.2.0 

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

type GetDestroyingRsp added in v0.2.0 

type GetDestroyingRsp struct {
	Status               *metapb.DestroyingStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

GetDestroyingRsp get destroying status response

func (*GetDestroyingRsp) Descriptor added in v0.2.0 

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

func (*GetDestroyingRsp) GetStatus added in v0.2.0 

func (m *GetDestroyingRsp) GetStatus() *metapb.DestroyingStatus

func (*GetDestroyingRsp) Marshal added in v0.2.0 

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

func (*GetDestroyingRsp) MarshalTo added in v0.2.0 

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

func (*GetDestroyingRsp) ProtoMessage added in v0.2.0 

func (*GetDestroyingRsp) ProtoMessage()

func (*GetDestroyingRsp) Reset added in v0.2.0 

func (m *GetDestroyingRsp) Reset()

func (*GetDestroyingRsp) Size added in v0.2.0 

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

func (*GetDestroyingRsp) String added in v0.2.0 

func (m *GetDestroyingRsp) String() string

func (*GetDestroyingRsp) Unmarshal added in v0.2.0 

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

func (*GetDestroyingRsp) XXX_DiscardUnknown added in v0.2.0 

func (m *GetDestroyingRsp) XXX_DiscardUnknown()

func (*GetDestroyingRsp) XXX_Marshal added in v0.2.0 

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

func (*GetDestroyingRsp) XXX_Merge added in v0.2.0 

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

func (*GetDestroyingRsp) XXX_Size added in v0.2.0 

func (m *GetDestroyingRsp) XXX_Size() int

func (*GetDestroyingRsp) XXX_Unmarshal added in v0.2.0 

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

type GetScheduleGroupRuleReq added in v0.2.0 

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

func (*GetScheduleGroupRuleReq) Descriptor added in v0.2.0 

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

func (*GetScheduleGroupRuleReq) Marshal added in v0.2.0 

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

func (*GetScheduleGroupRuleReq) MarshalTo added in v0.2.0 

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

func (*GetScheduleGroupRuleReq) ProtoMessage added in v0.2.0 

func (*GetScheduleGroupRuleReq) ProtoMessage()

func (*GetScheduleGroupRuleReq) Reset added in v0.2.0 

func (m *GetScheduleGroupRuleReq) Reset()

func (*GetScheduleGroupRuleReq) Size added in v0.2.0 

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

func (*GetScheduleGroupRuleReq) String added in v0.2.0 

func (m *GetScheduleGroupRuleReq) String() string

func (*GetScheduleGroupRuleReq) Unmarshal added in v0.2.0 

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

func (*GetScheduleGroupRuleReq) XXX_DiscardUnknown added in v0.2.0 

func (m *GetScheduleGroupRuleReq) XXX_DiscardUnknown()

func (*GetScheduleGroupRuleReq) XXX_Marshal added in v0.2.0 

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

func (*GetScheduleGroupRuleReq) XXX_Merge added in v0.2.0 

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

func (*GetScheduleGroupRuleReq) XXX_Size added in v0.2.0 

func (m *GetScheduleGroupRuleReq) XXX_Size() int

func (*GetScheduleGroupRuleReq) XXX_Unmarshal added in v0.2.0 

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

type GetScheduleGroupRuleRsp added in v0.2.0 

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

func (*GetScheduleGroupRuleRsp) Descriptor added in v0.2.0 

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

func (*GetScheduleGroupRuleRsp) GetRules added in v0.2.0 

func (m *GetScheduleGroupRuleRsp) GetRules() []metapb.ScheduleGroupRule

func (*GetScheduleGroupRuleRsp) Marshal added in v0.2.0 

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

func (*GetScheduleGroupRuleRsp) MarshalTo added in v0.2.0 

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

func (*GetScheduleGroupRuleRsp) ProtoMessage added in v0.2.0 

func (*GetScheduleGroupRuleRsp) ProtoMessage()

func (*GetScheduleGroupRuleRsp) Reset added in v0.2.0 

func (m *GetScheduleGroupRuleRsp) Reset()

func (*GetScheduleGroupRuleRsp) Size added in v0.2.0 

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

func (*GetScheduleGroupRuleRsp) String added in v0.2.0 

func (m *GetScheduleGroupRuleRsp) String() string

func (*GetScheduleGroupRuleRsp) Unmarshal added in v0.2.0 

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

func (*GetScheduleGroupRuleRsp) XXX_DiscardUnknown added in v0.2.0 

func (m *GetScheduleGroupRuleRsp) XXX_DiscardUnknown()

func (*GetScheduleGroupRuleRsp) XXX_Marshal added in v0.2.0 

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

func (*GetScheduleGroupRuleRsp) XXX_Merge added in v0.2.0 

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

func (*GetScheduleGroupRuleRsp) XXX_Size added in v0.2.0 

func (m *GetScheduleGroupRuleRsp) XXX_Size() int

func (*GetScheduleGroupRuleRsp) XXX_Unmarshal added in v0.2.0 

func (m *GetScheduleGroupRuleRsp) 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 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 ReplicaRoleType `protobuf:"varint,7,opt,name=role,proto3,enum=rpcpb.ReplicaRoleType" 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() ReplicaRoleType

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 {
	DestroyResources     []byte   `protobuf:"bytes,1,opt,name=destroyResources,proto3" json:"destroyResources,omitempty"`
	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) GetDestroyResources added in v0.2.0 

func (m *PutContainerRsp) GetDestroyResources() []byte

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 ReplicaRoleType added in v0.2.0 

type ReplicaRoleType int32

PeerRoleType is the expected peer type of the placement rule 

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

func (ReplicaRoleType) EnumDescriptor added in v0.2.0 

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

func (ReplicaRoleType) String added in v0.2.0 

func (x ReplicaRoleType) String() string

type ReportDestroyedReq added in v0.2.0 

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

ReportDestroyedReq report destroying request

func (*ReportDestroyedReq) Descriptor added in v0.2.0 

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

func (*ReportDestroyedReq) GetID added in v0.2.0 

func (m *ReportDestroyedReq) GetID() uint64

func (*ReportDestroyedReq) GetReplicaID added in v0.2.0 

func (m *ReportDestroyedReq) GetReplicaID() uint64

func (*ReportDestroyedReq) Marshal added in v0.2.0 

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

func (*ReportDestroyedReq) MarshalTo added in v0.2.0 

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

func (*ReportDestroyedReq) ProtoMessage added in v0.2.0 

func (*ReportDestroyedReq) ProtoMessage()

func (*ReportDestroyedReq) Reset added in v0.2.0 

func (m *ReportDestroyedReq) Reset()

func (*ReportDestroyedReq) Size added in v0.2.0 

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

func (*ReportDestroyedReq) String added in v0.2.0 

func (m *ReportDestroyedReq) String() string

func (*ReportDestroyedReq) Unmarshal added in v0.2.0 

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

func (*ReportDestroyedReq) XXX_DiscardUnknown added in v0.2.0 

func (m *ReportDestroyedReq) XXX_DiscardUnknown()

func (*ReportDestroyedReq) XXX_Marshal added in v0.2.0 

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

func (*ReportDestroyedReq) XXX_Merge added in v0.2.0 

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

func (*ReportDestroyedReq) XXX_Size added in v0.2.0 

func (m *ReportDestroyedReq) XXX_Size() int

func (*ReportDestroyedReq) XXX_Unmarshal added in v0.2.0 

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

type ReportDestroyedRsp added in v0.2.0 

type ReportDestroyedRsp struct {
	State                metapb.ResourceState `protobuf:"varint,1,opt,name=state,proto3,enum=metapb.ResourceState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

ReportDestroyedRsp report destroying rsp

func (*ReportDestroyedRsp) Descriptor added in v0.2.0 

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

func (*ReportDestroyedRsp) GetState added in v0.2.0 

func (m *ReportDestroyedRsp) GetState() metapb.ResourceState

func (*ReportDestroyedRsp) Marshal added in v0.2.0 

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

func (*ReportDestroyedRsp) MarshalTo added in v0.2.0 

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

func (*ReportDestroyedRsp) ProtoMessage added in v0.2.0 

func (*ReportDestroyedRsp) ProtoMessage()

func (*ReportDestroyedRsp) Reset added in v0.2.0 

func (m *ReportDestroyedRsp) Reset()

func (*ReportDestroyedRsp) Size added in v0.2.0 

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

func (*ReportDestroyedRsp) String added in v0.2.0 

func (m *ReportDestroyedRsp) String() string

func (*ReportDestroyedRsp) Unmarshal added in v0.2.0 

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

func (*ReportDestroyedRsp) XXX_DiscardUnknown added in v0.2.0 

func (m *ReportDestroyedRsp) XXX_DiscardUnknown()

func (*ReportDestroyedRsp) XXX_Marshal added in v0.2.0 

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

func (*ReportDestroyedRsp) XXX_Merge added in v0.2.0 

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

func (*ReportDestroyedRsp) XXX_Size added in v0.2.0 

func (m *ReportDestroyedRsp) XXX_Size() int

func (*ReportDestroyedRsp) XXX_Unmarshal added in v0.2.0 

func (m *ReportDestroyedRsp) 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"`
	AskBatchSplit        AskBatchSplitReq        `protobuf:"bytes,9,opt,name=askBatchSplit,proto3" json:"askBatchSplit"`
	CreateDestroying     CreateDestroyingReq     `protobuf:"bytes,10,opt,name=createDestroying,proto3" json:"createDestroying"`
	ReportDestroyed      ReportDestroyedReq      `protobuf:"bytes,11,opt,name=ReportDestroyed,proto3" json:"ReportDestroyed"`
	GetDestroying        GetDestroyingReq        `protobuf:"bytes,12,opt,name=getDestroying,proto3" json:"getDestroying"`
	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"`
	AddScheduleGroupRule AddScheduleGroupRuleReq `protobuf:"bytes,22,opt,name=addScheduleGroupRule,proto3" json:"addScheduleGroupRule"`
	GetScheduleGroupRule GetScheduleGroupRuleReq `protobuf:"bytes,23,opt,name=getScheduleGroupRule,proto3" json:"getScheduleGroupRule"`
	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) GetAddScheduleGroupRule added in v0.2.0 

func (m *Request) GetAddScheduleGroupRule() AddScheduleGroupRuleReq

func (*Request) GetAllocID 

func (m *Request) GetAllocID() AllocIDReq

func (*Request) GetAskBatchSplit 

func (m *Request) GetAskBatchSplit() AskBatchSplitReq

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) GetCreateDestroying added in v0.2.0 

func (m *Request) GetCreateDestroying() CreateDestroyingReq

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) GetGetDestroying added in v0.2.0 

func (m *Request) GetGetDestroying() GetDestroyingReq

func (*Request) GetGetScheduleGroupRule added in v0.2.0 

func (m *Request) GetGetScheduleGroupRule() GetScheduleGroupRuleReq

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) GetReportDestroyed added in v0.2.0 

func (m *Request) GetReportDestroyed() ReportDestroyedReq

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.Replica       `protobuf:"bytes,4,opt,name=leader,proto3" json:"leader,omitempty"`
	DownReplicas         []metapb.ReplicaStats `protobuf:"bytes,5,rep,name=downReplicas,proto3" json:"downReplicas"`
	PendingReplicas      []metapb.Replica      `protobuf:"bytes,6,rep,name=pendingReplicas,proto3" json:"pendingReplicas"`
	Stats                metapb.ResourceStats  `protobuf:"bytes,7,opt,name=stats,proto3" json:"stats"`
	GroupKey             string                `protobuf:"bytes,8,opt,name=groupKey,proto3" json:"groupKey,omitempty"`
	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) GetDownReplicas added in v0.2.0 

func (m *ResourceHeartbeatReq) GetDownReplicas() []metapb.ReplicaStats

func (*ResourceHeartbeatReq) GetGroupKey added in v0.2.0 

func (m *ResourceHeartbeatReq) GetGroupKey() string

func (*ResourceHeartbeatReq) GetLeader 

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

func (*ResourceHeartbeatReq) GetPendingReplicas added in v0.2.0 

func (m *ResourceHeartbeatReq) GetPendingReplicas() []metapb.Replica

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.
	TargetReplica *metapb.Replica `protobuf:"bytes,3,opt,name=targetReplica,proto3" json:"targetReplica,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.
	ConfigChange   *ConfigChange   `protobuf:"bytes,4,opt,name=configChange,proto3" json:"configChange,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"`
	ConfigChangeV2 *ConfigChangeV2 `protobuf:"bytes,8,opt,name=configChangeV2,proto3" json:"configChangeV2,omitempty"`
	// DestroyDirectly the resource has been removed, destroy directly without raft.
	DestroyDirectly      bool     `protobuf:"varint,9,opt,name=destroyDirectly,proto3" json:"destroyDirectly,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) GetConfigChange added in v0.2.0 

func (m *ResourceHeartbeatRsp) GetConfigChange() *ConfigChange

func (*ResourceHeartbeatRsp) GetConfigChangeV2 added in v0.2.0 

func (m *ResourceHeartbeatRsp) GetConfigChangeV2() *ConfigChangeV2

func (*ResourceHeartbeatRsp) GetDestroyDirectly added in v0.2.0 

func (m *ResourceHeartbeatRsp) GetDestroyDirectly() 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) GetTargetReplica added in v0.2.0 

func (m *ResourceHeartbeatRsp) GetTargetReplica() *metapb.Replica

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"`
	AskBatchSplit        AskBatchSplitRsp        `protobuf:"bytes,10,opt,name=askBatchSplit,proto3" json:"askBatchSplit"`
	CreateDestroying     CreateDestroyingRsp     `protobuf:"bytes,11,opt,name=createDestroying,proto3" json:"createDestroying"`
	ReportDestroyed      ReportDestroyedRsp      `protobuf:"bytes,12,opt,name=ReportDestroyed,proto3" json:"ReportDestroyed"`
	GetDestroying        GetDestroyingRsp        `protobuf:"bytes,13,opt,name=getDestroying,proto3" json:"getDestroying"`
	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"`
	AddScheduleGroupRule AddScheduleGroupRuleRsp `protobuf:"bytes,23,opt,name=addScheduleGroupRule,proto3" json:"addScheduleGroupRule"`
	GetScheduleGroupRule GetScheduleGroupRuleRsp `protobuf:"bytes,24,opt,name=getScheduleGroupRule,proto3" json:"getScheduleGroupRule"`
	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) GetAddScheduleGroupRule added in v0.2.0 

func (m *Response) GetAddScheduleGroupRule() AddScheduleGroupRuleRsp

func (*Response) GetAllocID 

func (m *Response) GetAllocID() AllocIDRsp

func (*Response) GetAskBatchSplit 

func (m *Response) GetAskBatchSplit() AskBatchSplitRsp

func (*Response) GetCheckResourceState 

func (m *Response) GetCheckResourceState() CheckResourceStateRsp

func (*Response) GetContainerHeartbeat 

func (m *Response) GetContainerHeartbeat() ContainerHeartbeatRsp

func (*Response) GetCreateDestroying added in v0.2.0 

func (m *Response) GetCreateDestroying() CreateDestroyingRsp

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) GetGetDestroying added in v0.2.0 

func (m *Response) GetGetDestroying() GetDestroyingRsp

func (*Response) GetGetScheduleGroupRule added in v0.2.0 

func (m *Response) GetGetScheduleGroupRule() GetScheduleGroupRuleRsp

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) GetReportDestroyed added in v0.2.0 

func (m *Response) GetReportDestroyed() ReportDestroyedRsp

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"`
	NewReplicaIDs        []uint64 `protobuf:"varint,2,rep,packed,name=newReplicaIDs,proto3" json:"newReplicaIDs,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) GetNewReplicaIDs added in v0.2.0 

func (m *SplitID) GetNewReplicaIDs() []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 {
	Replica              metapb.Replica `protobuf:"bytes,1,opt,name=replica,proto3" json:"replica"`
	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) GetReplica added in v0.2.0 

func (m *TransferLeader) GetReplica() metapb.Replica

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
	TypeAskBatchSplitReq        Type = 11
	TypeAskBatchSplitRsp        Type = 12
	TypeCreateDestroyingReq     Type = 13
	TypeCreateDestroyingRsp     Type = 14
	TypeReportDestroyedReq      Type = 15
	TypeReportDestroyedRsp      Type = 16
	TypeGetDestroyingReq        Type = 17
	TypeGetDestroyingRsp        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
	TypeAddScheduleGroupRuleReq Type = 37
	TypeAddScheduleGroupRuleRsp Type = 38
	TypeGetScheduleGroupRuleReq Type = 39
	TypeGetScheduleGroupRuleRsp Type = 40
)

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.