1 Star 0 Fork 0

zhuchance / kubernetes

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
克隆/下载
messages.pb.go 47.08 KB
一键复制 编辑 原始数据 按行查看 历史
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550
// Code generated by protoc-gen-gogo.
// source: messages.proto
// DO NOT EDIT!
package mesosproto
import proto "github.com/gogo/protobuf/proto"
import math "math"
// discarding unused import gogoproto "github.com/gogo/protobuf/gogoproto/gogo.pb"
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = math.Inf
type StatusUpdateRecord_Type int32
const (
StatusUpdateRecord_UPDATE StatusUpdateRecord_Type = 0
StatusUpdateRecord_ACK StatusUpdateRecord_Type = 1
)
var StatusUpdateRecord_Type_name = map[int32]string{
0: "UPDATE",
1: "ACK",
}
var StatusUpdateRecord_Type_value = map[string]int32{
"UPDATE": 0,
"ACK": 1,
}
func (x StatusUpdateRecord_Type) Enum() *StatusUpdateRecord_Type {
p := new(StatusUpdateRecord_Type)
*p = x
return p
}
func (x StatusUpdateRecord_Type) String() string {
return proto.EnumName(StatusUpdateRecord_Type_name, int32(x))
}
func (x *StatusUpdateRecord_Type) UnmarshalJSON(data []byte) error {
value, err := proto.UnmarshalJSONEnum(StatusUpdateRecord_Type_value, data, "StatusUpdateRecord_Type")
if err != nil {
return err
}
*x = StatusUpdateRecord_Type(value)
return nil
}
// TODO(benh): It would be great if this could just be a
// TaskInfo wherever it gets used! However, doing so would
// require adding the framework_id field, the executor_id field, and
// the state field into TaskInfo though (or send them another
// way). Also, one performance reason why we don't do that now is
// because storing whatever data is coupled with a TaskInfo
// could be large and unnecessary.
// TODO(bmahler): Add executor_uuid here, and send it to the master. This will
// allow us to expose executor work directories for tasks in the webui when
// looking from the master level. Currently only the slave knows which run the
// task belongs to.
type Task struct {
Name *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
TaskId *TaskID `protobuf:"bytes,2,req,name=task_id" json:"task_id,omitempty"`
FrameworkId *FrameworkID `protobuf:"bytes,3,req,name=framework_id" json:"framework_id,omitempty"`
ExecutorId *ExecutorID `protobuf:"bytes,4,opt,name=executor_id" json:"executor_id,omitempty"`
SlaveId *SlaveID `protobuf:"bytes,5,req,name=slave_id" json:"slave_id,omitempty"`
State *TaskState `protobuf:"varint,6,req,name=state,enum=mesosproto.TaskState" json:"state,omitempty"`
Resources []*Resource `protobuf:"bytes,7,rep,name=resources" json:"resources,omitempty"`
Statuses []*TaskStatus `protobuf:"bytes,8,rep,name=statuses" json:"statuses,omitempty"`
// These fields correspond to the state and uuid of the latest
// status update forwarded to the master.
// NOTE: Either both the fields must be set or both must be unset.
StatusUpdateState *TaskState `protobuf:"varint,9,opt,name=status_update_state,enum=mesosproto.TaskState" json:"status_update_state,omitempty"`
StatusUpdateUuid []byte `protobuf:"bytes,10,opt,name=status_update_uuid" json:"status_update_uuid,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *Task) Reset() { *m = Task{} }
func (m *Task) String() string { return proto.CompactTextString(m) }
func (*Task) ProtoMessage() {}
func (m *Task) GetName() string {
if m != nil && m.Name != nil {
return *m.Name
}
return ""
}
func (m *Task) GetTaskId() *TaskID {
if m != nil {
return m.TaskId
}
return nil
}
func (m *Task) GetFrameworkId() *FrameworkID {
if m != nil {
return m.FrameworkId
}
return nil
}
func (m *Task) GetExecutorId() *ExecutorID {
if m != nil {
return m.ExecutorId
}
return nil
}
func (m *Task) GetSlaveId() *SlaveID {
if m != nil {
return m.SlaveId
}
return nil
}
func (m *Task) GetState() TaskState {
if m != nil && m.State != nil {
return *m.State
}
return TaskState_TASK_STAGING
}
func (m *Task) GetResources() []*Resource {
if m != nil {
return m.Resources
}
return nil
}
func (m *Task) GetStatuses() []*TaskStatus {
if m != nil {
return m.Statuses
}
return nil
}
func (m *Task) GetStatusUpdateState() TaskState {
if m != nil && m.StatusUpdateState != nil {
return *m.StatusUpdateState
}
return TaskState_TASK_STAGING
}
func (m *Task) GetStatusUpdateUuid() []byte {
if m != nil {
return m.StatusUpdateUuid
}
return nil
}
// Describes a role, which are used to group frameworks for allocation
// decisions, depending on the allocation policy being used.
// The weight field can be used to indicate forms of priority.
type RoleInfo struct {
Name *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
Weight *float64 `protobuf:"fixed64,2,opt,name=weight,def=1" json:"weight,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *RoleInfo) Reset() { *m = RoleInfo{} }
func (m *RoleInfo) String() string { return proto.CompactTextString(m) }
func (*RoleInfo) ProtoMessage() {}
const Default_RoleInfo_Weight float64 = 1
func (m *RoleInfo) GetName() string {
if m != nil && m.Name != nil {
return *m.Name
}
return ""
}
func (m *RoleInfo) GetWeight() float64 {
if m != nil && m.Weight != nil {
return *m.Weight
}
return Default_RoleInfo_Weight
}
// TODO(vinod): Create a new UUID message type.
type StatusUpdate struct {
FrameworkId *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
ExecutorId *ExecutorID `protobuf:"bytes,2,opt,name=executor_id" json:"executor_id,omitempty"`
SlaveId *SlaveID `protobuf:"bytes,3,opt,name=slave_id" json:"slave_id,omitempty"`
Status *TaskStatus `protobuf:"bytes,4,req,name=status" json:"status,omitempty"`
Timestamp *float64 `protobuf:"fixed64,5,req,name=timestamp" json:"timestamp,omitempty"`
Uuid []byte `protobuf:"bytes,6,req,name=uuid" json:"uuid,omitempty"`
// This corresponds to the latest state of the task according to the
// slave. Note that this state might be different than the state in
// 'status' because status update manager queues updates. In other
// words, 'status' corresponds to the update at top of the queue and
// 'latest_state' corresponds to the update at bottom of the queue.
LatestState *TaskState `protobuf:"varint,7,opt,name=latest_state,enum=mesosproto.TaskState" json:"latest_state,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *StatusUpdate) Reset() { *m = StatusUpdate{} }
func (m *StatusUpdate) String() string { return proto.CompactTextString(m) }
func (*StatusUpdate) ProtoMessage() {}
func (m *StatusUpdate) GetFrameworkId() *FrameworkID {
if m != nil {
return m.FrameworkId
}
return nil
}
func (m *StatusUpdate) GetExecutorId() *ExecutorID {
if m != nil {
return m.ExecutorId
}
return nil
}
func (m *StatusUpdate) GetSlaveId() *SlaveID {
if m != nil {
return m.SlaveId
}
return nil
}
func (m *StatusUpdate) GetStatus() *TaskStatus {
if m != nil {
return m.Status
}
return nil
}
func (m *StatusUpdate) GetTimestamp() float64 {
if m != nil && m.Timestamp != nil {
return *m.Timestamp
}
return 0
}
func (m *StatusUpdate) GetUuid() []byte {
if m != nil {
return m.Uuid
}
return nil
}
func (m *StatusUpdate) GetLatestState() TaskState {
if m != nil && m.LatestState != nil {
return *m.LatestState
}
return TaskState_TASK_STAGING
}
// This message encapsulates how we checkpoint a status update to disk.
// NOTE: If type == UPDATE, the 'update' field is required.
// NOTE: If type == ACK, the 'uuid' field is required.
type StatusUpdateRecord struct {
Type *StatusUpdateRecord_Type `protobuf:"varint,1,req,name=type,enum=mesosproto.StatusUpdateRecord_Type" json:"type,omitempty"`
Update *StatusUpdate `protobuf:"bytes,2,opt,name=update" json:"update,omitempty"`
Uuid []byte `protobuf:"bytes,3,opt,name=uuid" json:"uuid,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *StatusUpdateRecord) Reset() { *m = StatusUpdateRecord{} }
func (m *StatusUpdateRecord) String() string { return proto.CompactTextString(m) }
func (*StatusUpdateRecord) ProtoMessage() {}
func (m *StatusUpdateRecord) GetType() StatusUpdateRecord_Type {
if m != nil && m.Type != nil {
return *m.Type
}
return StatusUpdateRecord_UPDATE
}
func (m *StatusUpdateRecord) GetUpdate() *StatusUpdate {
if m != nil {
return m.Update
}
return nil
}
func (m *StatusUpdateRecord) GetUuid() []byte {
if m != nil {
return m.Uuid
}
return nil
}
type SubmitSchedulerRequest struct {
Name *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *SubmitSchedulerRequest) Reset() { *m = SubmitSchedulerRequest{} }
func (m *SubmitSchedulerRequest) String() string { return proto.CompactTextString(m) }
func (*SubmitSchedulerRequest) ProtoMessage() {}
func (m *SubmitSchedulerRequest) GetName() string {
if m != nil && m.Name != nil {
return *m.Name
}
return ""
}
type SubmitSchedulerResponse struct {
Okay *bool `protobuf:"varint,1,req,name=okay" json:"okay,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *SubmitSchedulerResponse) Reset() { *m = SubmitSchedulerResponse{} }
func (m *SubmitSchedulerResponse) String() string { return proto.CompactTextString(m) }
func (*SubmitSchedulerResponse) ProtoMessage() {}
func (m *SubmitSchedulerResponse) GetOkay() bool {
if m != nil && m.Okay != nil {
return *m.Okay
}
return false
}
type ExecutorToFrameworkMessage struct {
SlaveId *SlaveID `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
FrameworkId *FrameworkID `protobuf:"bytes,2,req,name=framework_id" json:"framework_id,omitempty"`
ExecutorId *ExecutorID `protobuf:"bytes,3,req,name=executor_id" json:"executor_id,omitempty"`
Data []byte `protobuf:"bytes,4,req,name=data" json:"data,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *ExecutorToFrameworkMessage) Reset() { *m = ExecutorToFrameworkMessage{} }
func (m *ExecutorToFrameworkMessage) String() string { return proto.CompactTextString(m) }
func (*ExecutorToFrameworkMessage) ProtoMessage() {}
func (m *ExecutorToFrameworkMessage) GetSlaveId() *SlaveID {
if m != nil {
return m.SlaveId
}
return nil
}
func (m *ExecutorToFrameworkMessage) GetFrameworkId() *FrameworkID {
if m != nil {
return m.FrameworkId
}
return nil
}
func (m *ExecutorToFrameworkMessage) GetExecutorId() *ExecutorID {
if m != nil {
return m.ExecutorId
}
return nil
}
func (m *ExecutorToFrameworkMessage) GetData() []byte {
if m != nil {
return m.Data
}
return nil
}
type FrameworkToExecutorMessage struct {
SlaveId *SlaveID `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
FrameworkId *FrameworkID `protobuf:"bytes,2,req,name=framework_id" json:"framework_id,omitempty"`
ExecutorId *ExecutorID `protobuf:"bytes,3,req,name=executor_id" json:"executor_id,omitempty"`
Data []byte `protobuf:"bytes,4,req,name=data" json:"data,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *FrameworkToExecutorMessage) Reset() { *m = FrameworkToExecutorMessage{} }
func (m *FrameworkToExecutorMessage) String() string { return proto.CompactTextString(m) }
func (*FrameworkToExecutorMessage) ProtoMessage() {}
func (m *FrameworkToExecutorMessage) GetSlaveId() *SlaveID {
if m != nil {
return m.SlaveId
}
return nil
}
func (m *FrameworkToExecutorMessage) GetFrameworkId() *FrameworkID {
if m != nil {
return m.FrameworkId
}
return nil
}
func (m *FrameworkToExecutorMessage) GetExecutorId() *ExecutorID {
if m != nil {
return m.ExecutorId
}
return nil
}
func (m *FrameworkToExecutorMessage) GetData() []byte {
if m != nil {
return m.Data
}
return nil
}
type RegisterFrameworkMessage struct {
Framework *FrameworkInfo `protobuf:"bytes,1,req,name=framework" json:"framework,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *RegisterFrameworkMessage) Reset() { *m = RegisterFrameworkMessage{} }
func (m *RegisterFrameworkMessage) String() string { return proto.CompactTextString(m) }
func (*RegisterFrameworkMessage) ProtoMessage() {}
func (m *RegisterFrameworkMessage) GetFramework() *FrameworkInfo {
if m != nil {
return m.Framework
}
return nil
}
type ReregisterFrameworkMessage struct {
Framework *FrameworkInfo `protobuf:"bytes,2,req,name=framework" json:"framework,omitempty"`
Failover *bool `protobuf:"varint,3,req,name=failover" json:"failover,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *ReregisterFrameworkMessage) Reset() { *m = ReregisterFrameworkMessage{} }
func (m *ReregisterFrameworkMessage) String() string { return proto.CompactTextString(m) }
func (*ReregisterFrameworkMessage) ProtoMessage() {}
func (m *ReregisterFrameworkMessage) GetFramework() *FrameworkInfo {
if m != nil {
return m.Framework
}
return nil
}
func (m *ReregisterFrameworkMessage) GetFailover() bool {
if m != nil && m.Failover != nil {
return *m.Failover
}
return false
}
type FrameworkRegisteredMessage struct {
FrameworkId *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
MasterInfo *MasterInfo `protobuf:"bytes,2,req,name=master_info" json:"master_info,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *FrameworkRegisteredMessage) Reset() { *m = FrameworkRegisteredMessage{} }
func (m *FrameworkRegisteredMessage) String() string { return proto.CompactTextString(m) }
func (*FrameworkRegisteredMessage) ProtoMessage() {}
func (m *FrameworkRegisteredMessage) GetFrameworkId() *FrameworkID {
if m != nil {
return m.FrameworkId
}
return nil
}
func (m *FrameworkRegisteredMessage) GetMasterInfo() *MasterInfo {
if m != nil {
return m.MasterInfo
}
return nil
}
type FrameworkReregisteredMessage struct {
FrameworkId *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
MasterInfo *MasterInfo `protobuf:"bytes,2,req,name=master_info" json:"master_info,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *FrameworkReregisteredMessage) Reset() { *m = FrameworkReregisteredMessage{} }
func (m *FrameworkReregisteredMessage) String() string { return proto.CompactTextString(m) }
func (*FrameworkReregisteredMessage) ProtoMessage() {}
func (m *FrameworkReregisteredMessage) GetFrameworkId() *FrameworkID {
if m != nil {
return m.FrameworkId
}
return nil
}
func (m *FrameworkReregisteredMessage) GetMasterInfo() *MasterInfo {
if m != nil {
return m.MasterInfo
}
return nil
}
type UnregisterFrameworkMessage struct {
FrameworkId *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *UnregisterFrameworkMessage) Reset() { *m = UnregisterFrameworkMessage{} }
func (m *UnregisterFrameworkMessage) String() string { return proto.CompactTextString(m) }
func (*UnregisterFrameworkMessage) ProtoMessage() {}
func (m *UnregisterFrameworkMessage) GetFrameworkId() *FrameworkID {
if m != nil {
return m.FrameworkId
}
return nil
}
type DeactivateFrameworkMessage struct {
FrameworkId *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *DeactivateFrameworkMessage) Reset() { *m = DeactivateFrameworkMessage{} }
func (m *DeactivateFrameworkMessage) String() string { return proto.CompactTextString(m) }
func (*DeactivateFrameworkMessage) ProtoMessage() {}
func (m *DeactivateFrameworkMessage) GetFrameworkId() *FrameworkID {
if m != nil {
return m.FrameworkId
}
return nil
}
type ResourceRequestMessage struct {
FrameworkId *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
Requests []*Request `protobuf:"bytes,2,rep,name=requests" json:"requests,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *ResourceRequestMessage) Reset() { *m = ResourceRequestMessage{} }
func (m *ResourceRequestMessage) String() string { return proto.CompactTextString(m) }
func (*ResourceRequestMessage) ProtoMessage() {}
func (m *ResourceRequestMessage) GetFrameworkId() *FrameworkID {
if m != nil {
return m.FrameworkId
}
return nil
}
func (m *ResourceRequestMessage) GetRequests() []*Request {
if m != nil {
return m.Requests
}
return nil
}
type ResourceOffersMessage struct {
Offers []*Offer `protobuf:"bytes,1,rep,name=offers" json:"offers,omitempty"`
Pids []string `protobuf:"bytes,2,rep,name=pids" json:"pids,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *ResourceOffersMessage) Reset() { *m = ResourceOffersMessage{} }
func (m *ResourceOffersMessage) String() string { return proto.CompactTextString(m) }
func (*ResourceOffersMessage) ProtoMessage() {}
func (m *ResourceOffersMessage) GetOffers() []*Offer {
if m != nil {
return m.Offers
}
return nil
}
func (m *ResourceOffersMessage) GetPids() []string {
if m != nil {
return m.Pids
}
return nil
}
type LaunchTasksMessage struct {
FrameworkId *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
Tasks []*TaskInfo `protobuf:"bytes,3,rep,name=tasks" json:"tasks,omitempty"`
Filters *Filters `protobuf:"bytes,5,req,name=filters" json:"filters,omitempty"`
OfferIds []*OfferID `protobuf:"bytes,6,rep,name=offer_ids" json:"offer_ids,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *LaunchTasksMessage) Reset() { *m = LaunchTasksMessage{} }
func (m *LaunchTasksMessage) String() string { return proto.CompactTextString(m) }
func (*LaunchTasksMessage) ProtoMessage() {}
func (m *LaunchTasksMessage) GetFrameworkId() *FrameworkID {
if m != nil {
return m.FrameworkId
}
return nil
}
func (m *LaunchTasksMessage) GetTasks() []*TaskInfo {
if m != nil {
return m.Tasks
}
return nil
}
func (m *LaunchTasksMessage) GetFilters() *Filters {
if m != nil {
return m.Filters
}
return nil
}
func (m *LaunchTasksMessage) GetOfferIds() []*OfferID {
if m != nil {
return m.OfferIds
}
return nil
}
type RescindResourceOfferMessage struct {
OfferId *OfferID `protobuf:"bytes,1,req,name=offer_id" json:"offer_id,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *RescindResourceOfferMessage) Reset() { *m = RescindResourceOfferMessage{} }
func (m *RescindResourceOfferMessage) String() string { return proto.CompactTextString(m) }
func (*RescindResourceOfferMessage) ProtoMessage() {}
func (m *RescindResourceOfferMessage) GetOfferId() *OfferID {
if m != nil {
return m.OfferId
}
return nil
}
type ReviveOffersMessage struct {
FrameworkId *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *ReviveOffersMessage) Reset() { *m = ReviveOffersMessage{} }
func (m *ReviveOffersMessage) String() string { return proto.CompactTextString(m) }
func (*ReviveOffersMessage) ProtoMessage() {}
func (m *ReviveOffersMessage) GetFrameworkId() *FrameworkID {
if m != nil {
return m.FrameworkId
}
return nil
}
type RunTaskMessage struct {
FrameworkId *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
Framework *FrameworkInfo `protobuf:"bytes,2,req,name=framework" json:"framework,omitempty"`
Pid *string `protobuf:"bytes,3,req,name=pid" json:"pid,omitempty"`
Task *TaskInfo `protobuf:"bytes,4,req,name=task" json:"task,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *RunTaskMessage) Reset() { *m = RunTaskMessage{} }
func (m *RunTaskMessage) String() string { return proto.CompactTextString(m) }
func (*RunTaskMessage) ProtoMessage() {}
func (m *RunTaskMessage) GetFrameworkId() *FrameworkID {
if m != nil {
return m.FrameworkId
}
return nil
}
func (m *RunTaskMessage) GetFramework() *FrameworkInfo {
if m != nil {
return m.Framework
}
return nil
}
func (m *RunTaskMessage) GetPid() string {
if m != nil && m.Pid != nil {
return *m.Pid
}
return ""
}
func (m *RunTaskMessage) GetTask() *TaskInfo {
if m != nil {
return m.Task
}
return nil
}
type KillTaskMessage struct {
// TODO(bmahler): Include the SlaveID here to improve the Master's
// ability to respond for non-activated slaves.
FrameworkId *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
TaskId *TaskID `protobuf:"bytes,2,req,name=task_id" json:"task_id,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *KillTaskMessage) Reset() { *m = KillTaskMessage{} }
func (m *KillTaskMessage) String() string { return proto.CompactTextString(m) }
func (*KillTaskMessage) ProtoMessage() {}
func (m *KillTaskMessage) GetFrameworkId() *FrameworkID {
if m != nil {
return m.FrameworkId
}
return nil
}
func (m *KillTaskMessage) GetTaskId() *TaskID {
if m != nil {
return m.TaskId
}
return nil
}
// NOTE: If 'pid' is present, scheduler driver sends an
// acknowledgement to the pid.
type StatusUpdateMessage struct {
Update *StatusUpdate `protobuf:"bytes,1,req,name=update" json:"update,omitempty"`
Pid *string `protobuf:"bytes,2,opt,name=pid" json:"pid,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *StatusUpdateMessage) Reset() { *m = StatusUpdateMessage{} }
func (m *StatusUpdateMessage) String() string { return proto.CompactTextString(m) }
func (*StatusUpdateMessage) ProtoMessage() {}
func (m *StatusUpdateMessage) GetUpdate() *StatusUpdate {
if m != nil {
return m.Update
}
return nil
}
func (m *StatusUpdateMessage) GetPid() string {
if m != nil && m.Pid != nil {
return *m.Pid
}
return ""
}
type StatusUpdateAcknowledgementMessage struct {
SlaveId *SlaveID `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
FrameworkId *FrameworkID `protobuf:"bytes,2,req,name=framework_id" json:"framework_id,omitempty"`
TaskId *TaskID `protobuf:"bytes,3,req,name=task_id" json:"task_id,omitempty"`
Uuid []byte `protobuf:"bytes,4,req,name=uuid" json:"uuid,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *StatusUpdateAcknowledgementMessage) Reset() { *m = StatusUpdateAcknowledgementMessage{} }
func (m *StatusUpdateAcknowledgementMessage) String() string { return proto.CompactTextString(m) }
func (*StatusUpdateAcknowledgementMessage) ProtoMessage() {}
func (m *StatusUpdateAcknowledgementMessage) GetSlaveId() *SlaveID {
if m != nil {
return m.SlaveId
}
return nil
}
func (m *StatusUpdateAcknowledgementMessage) GetFrameworkId() *FrameworkID {
if m != nil {
return m.FrameworkId
}
return nil
}
func (m *StatusUpdateAcknowledgementMessage) GetTaskId() *TaskID {
if m != nil {
return m.TaskId
}
return nil
}
func (m *StatusUpdateAcknowledgementMessage) GetUuid() []byte {
if m != nil {
return m.Uuid
}
return nil
}
type LostSlaveMessage struct {
SlaveId *SlaveID `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *LostSlaveMessage) Reset() { *m = LostSlaveMessage{} }
func (m *LostSlaveMessage) String() string { return proto.CompactTextString(m) }
func (*LostSlaveMessage) ProtoMessage() {}
func (m *LostSlaveMessage) GetSlaveId() *SlaveID {
if m != nil {
return m.SlaveId
}
return nil
}
// Allows the framework to query the status for non-terminal tasks.
// This causes the master to send back the latest task status for
// each task in 'statuses', if possible. Tasks that are no longer
// known will result in a TASK_LOST update. If statuses is empty,
// then the master will send the latest status for each task
// currently known.
type ReconcileTasksMessage struct {
FrameworkId *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
Statuses []*TaskStatus `protobuf:"bytes,2,rep,name=statuses" json:"statuses,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *ReconcileTasksMessage) Reset() { *m = ReconcileTasksMessage{} }
func (m *ReconcileTasksMessage) String() string { return proto.CompactTextString(m) }
func (*ReconcileTasksMessage) ProtoMessage() {}
func (m *ReconcileTasksMessage) GetFrameworkId() *FrameworkID {
if m != nil {
return m.FrameworkId
}
return nil
}
func (m *ReconcileTasksMessage) GetStatuses() []*TaskStatus {
if m != nil {
return m.Statuses
}
return nil
}
type FrameworkErrorMessage struct {
Message *string `protobuf:"bytes,2,req,name=message" json:"message,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *FrameworkErrorMessage) Reset() { *m = FrameworkErrorMessage{} }
func (m *FrameworkErrorMessage) String() string { return proto.CompactTextString(m) }
func (*FrameworkErrorMessage) ProtoMessage() {}
func (m *FrameworkErrorMessage) GetMessage() string {
if m != nil && m.Message != nil {
return *m.Message
}
return ""
}
type RegisterSlaveMessage struct {
Slave *SlaveInfo `protobuf:"bytes,1,req,name=slave" json:"slave,omitempty"`
// NOTE: This is a hack for the master to detect the slave's
// version. If unset the slave is < 0.21.0.
// TODO(bmahler): Do proper versioning: MESOS-986.
Version *string `protobuf:"bytes,2,opt,name=version" json:"version,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *RegisterSlaveMessage) Reset() { *m = RegisterSlaveMessage{} }
func (m *RegisterSlaveMessage) String() string { return proto.CompactTextString(m) }
func (*RegisterSlaveMessage) ProtoMessage() {}
func (m *RegisterSlaveMessage) GetSlave() *SlaveInfo {
if m != nil {
return m.Slave
}
return nil
}
func (m *RegisterSlaveMessage) GetVersion() string {
if m != nil && m.Version != nil {
return *m.Version
}
return ""
}
type ReregisterSlaveMessage struct {
// TODO(bmahler): slave_id is deprecated.
// 0.21.0: Now an optional field. Always written, never read.
// 0.22.0: Remove this field.
SlaveId *SlaveID `protobuf:"bytes,1,opt,name=slave_id" json:"slave_id,omitempty"`
Slave *SlaveInfo `protobuf:"bytes,2,req,name=slave" json:"slave,omitempty"`
ExecutorInfos []*ExecutorInfo `protobuf:"bytes,4,rep,name=executor_infos" json:"executor_infos,omitempty"`
Tasks []*Task `protobuf:"bytes,3,rep,name=tasks" json:"tasks,omitempty"`
CompletedFrameworks []*Archive_Framework `protobuf:"bytes,5,rep,name=completed_frameworks" json:"completed_frameworks,omitempty"`
// NOTE: This is a hack for the master to detect the slave's
// version. If unset the slave is < 0.21.0.
// TODO(bmahler): Do proper versioning: MESOS-986.
Version *string `protobuf:"bytes,6,opt,name=version" json:"version,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *ReregisterSlaveMessage) Reset() { *m = ReregisterSlaveMessage{} }
func (m *ReregisterSlaveMessage) String() string { return proto.CompactTextString(m) }
func (*ReregisterSlaveMessage) ProtoMessage() {}
func (m *ReregisterSlaveMessage) GetSlaveId() *SlaveID {
if m != nil {
return m.SlaveId
}
return nil
}
func (m *ReregisterSlaveMessage) GetSlave() *SlaveInfo {
if m != nil {
return m.Slave
}
return nil
}
func (m *ReregisterSlaveMessage) GetExecutorInfos() []*ExecutorInfo {
if m != nil {
return m.ExecutorInfos
}
return nil
}
func (m *ReregisterSlaveMessage) GetTasks() []*Task {
if m != nil {
return m.Tasks
}
return nil
}
func (m *ReregisterSlaveMessage) GetCompletedFrameworks() []*Archive_Framework {
if m != nil {
return m.CompletedFrameworks
}
return nil
}
func (m *ReregisterSlaveMessage) GetVersion() string {
if m != nil && m.Version != nil {
return *m.Version
}
return ""
}
type SlaveRegisteredMessage struct {
SlaveId *SlaveID `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *SlaveRegisteredMessage) Reset() { *m = SlaveRegisteredMessage{} }
func (m *SlaveRegisteredMessage) String() string { return proto.CompactTextString(m) }
func (*SlaveRegisteredMessage) ProtoMessage() {}
func (m *SlaveRegisteredMessage) GetSlaveId() *SlaveID {
if m != nil {
return m.SlaveId
}
return nil
}
type SlaveReregisteredMessage struct {
SlaveId *SlaveID `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
Reconciliations []*ReconcileTasksMessage `protobuf:"bytes,2,rep,name=reconciliations" json:"reconciliations,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *SlaveReregisteredMessage) Reset() { *m = SlaveReregisteredMessage{} }
func (m *SlaveReregisteredMessage) String() string { return proto.CompactTextString(m) }
func (*SlaveReregisteredMessage) ProtoMessage() {}
func (m *SlaveReregisteredMessage) GetSlaveId() *SlaveID {
if m != nil {
return m.SlaveId
}
return nil
}
func (m *SlaveReregisteredMessage) GetReconciliations() []*ReconcileTasksMessage {
if m != nil {
return m.Reconciliations
}
return nil
}
type UnregisterSlaveMessage struct {
SlaveId *SlaveID `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *UnregisterSlaveMessage) Reset() { *m = UnregisterSlaveMessage{} }
func (m *UnregisterSlaveMessage) String() string { return proto.CompactTextString(m) }
func (*UnregisterSlaveMessage) ProtoMessage() {}
func (m *UnregisterSlaveMessage) GetSlaveId() *SlaveID {
if m != nil {
return m.SlaveId
}
return nil
}
// This message is periodically sent by the master to the slave.
// If the slave is connected to the master, "connected" is true.
type PingSlaveMessage struct {
Connected *bool `protobuf:"varint,1,req,name=connected" json:"connected,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *PingSlaveMessage) Reset() { *m = PingSlaveMessage{} }
func (m *PingSlaveMessage) String() string { return proto.CompactTextString(m) }
func (*PingSlaveMessage) ProtoMessage() {}
func (m *PingSlaveMessage) GetConnected() bool {
if m != nil && m.Connected != nil {
return *m.Connected
}
return false
}
// This message is sent by the slave to the master in response to the
// PingSlaveMessage.
type PongSlaveMessage struct {
XXX_unrecognized []byte `json:"-"`
}
func (m *PongSlaveMessage) Reset() { *m = PongSlaveMessage{} }
func (m *PongSlaveMessage) String() string { return proto.CompactTextString(m) }
func (*PongSlaveMessage) ProtoMessage() {}
// Tells a slave to shut down all executors of the given framework.
type ShutdownFrameworkMessage struct {
FrameworkId *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *ShutdownFrameworkMessage) Reset() { *m = ShutdownFrameworkMessage{} }
func (m *ShutdownFrameworkMessage) String() string { return proto.CompactTextString(m) }
func (*ShutdownFrameworkMessage) ProtoMessage() {}
func (m *ShutdownFrameworkMessage) GetFrameworkId() *FrameworkID {
if m != nil {
return m.FrameworkId
}
return nil
}
// Tells the executor to initiate a shut down by invoking
// Executor::shutdown.
type ShutdownExecutorMessage struct {
XXX_unrecognized []byte `json:"-"`
}
func (m *ShutdownExecutorMessage) Reset() { *m = ShutdownExecutorMessage{} }
func (m *ShutdownExecutorMessage) String() string { return proto.CompactTextString(m) }
func (*ShutdownExecutorMessage) ProtoMessage() {}
type UpdateFrameworkMessage struct {
FrameworkId *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
Pid *string `protobuf:"bytes,2,req,name=pid" json:"pid,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *UpdateFrameworkMessage) Reset() { *m = UpdateFrameworkMessage{} }
func (m *UpdateFrameworkMessage) String() string { return proto.CompactTextString(m) }
func (*UpdateFrameworkMessage) ProtoMessage() {}
func (m *UpdateFrameworkMessage) GetFrameworkId() *FrameworkID {
if m != nil {
return m.FrameworkId
}
return nil
}
func (m *UpdateFrameworkMessage) GetPid() string {
if m != nil && m.Pid != nil {
return *m.Pid
}
return ""
}
type RegisterExecutorMessage struct {
FrameworkId *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
ExecutorId *ExecutorID `protobuf:"bytes,2,req,name=executor_id" json:"executor_id,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *RegisterExecutorMessage) Reset() { *m = RegisterExecutorMessage{} }
func (m *RegisterExecutorMessage) String() string { return proto.CompactTextString(m) }
func (*RegisterExecutorMessage) ProtoMessage() {}
func (m *RegisterExecutorMessage) GetFrameworkId() *FrameworkID {
if m != nil {
return m.FrameworkId
}
return nil
}
func (m *RegisterExecutorMessage) GetExecutorId() *ExecutorID {
if m != nil {
return m.ExecutorId
}
return nil
}
type ExecutorRegisteredMessage struct {
ExecutorInfo *ExecutorInfo `protobuf:"bytes,2,req,name=executor_info" json:"executor_info,omitempty"`
FrameworkId *FrameworkID `protobuf:"bytes,3,req,name=framework_id" json:"framework_id,omitempty"`
FrameworkInfo *FrameworkInfo `protobuf:"bytes,4,req,name=framework_info" json:"framework_info,omitempty"`
SlaveId *SlaveID `protobuf:"bytes,5,req,name=slave_id" json:"slave_id,omitempty"`
SlaveInfo *SlaveInfo `protobuf:"bytes,6,req,name=slave_info" json:"slave_info,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *ExecutorRegisteredMessage) Reset() { *m = ExecutorRegisteredMessage{} }
func (m *ExecutorRegisteredMessage) String() string { return proto.CompactTextString(m) }
func (*ExecutorRegisteredMessage) ProtoMessage() {}
func (m *ExecutorRegisteredMessage) GetExecutorInfo() *ExecutorInfo {
if m != nil {
return m.ExecutorInfo
}
return nil
}
func (m *ExecutorRegisteredMessage) GetFrameworkId() *FrameworkID {
if m != nil {
return m.FrameworkId
}
return nil
}
func (m *ExecutorRegisteredMessage) GetFrameworkInfo() *FrameworkInfo {
if m != nil {
return m.FrameworkInfo
}
return nil
}
func (m *ExecutorRegisteredMessage) GetSlaveId() *SlaveID {
if m != nil {
return m.SlaveId
}
return nil
}
func (m *ExecutorRegisteredMessage) GetSlaveInfo() *SlaveInfo {
if m != nil {
return m.SlaveInfo
}
return nil
}
type ExecutorReregisteredMessage struct {
SlaveId *SlaveID `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
SlaveInfo *SlaveInfo `protobuf:"bytes,2,req,name=slave_info" json:"slave_info,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *ExecutorReregisteredMessage) Reset() { *m = ExecutorReregisteredMessage{} }
func (m *ExecutorReregisteredMessage) String() string { return proto.CompactTextString(m) }
func (*ExecutorReregisteredMessage) ProtoMessage() {}
func (m *ExecutorReregisteredMessage) GetSlaveId() *SlaveID {
if m != nil {
return m.SlaveId
}
return nil
}
func (m *ExecutorReregisteredMessage) GetSlaveInfo() *SlaveInfo {
if m != nil {
return m.SlaveInfo
}
return nil
}
type ExitedExecutorMessage struct {
SlaveId *SlaveID `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
FrameworkId *FrameworkID `protobuf:"bytes,2,req,name=framework_id" json:"framework_id,omitempty"`
ExecutorId *ExecutorID `protobuf:"bytes,3,req,name=executor_id" json:"executor_id,omitempty"`
Status *int32 `protobuf:"varint,4,req,name=status" json:"status,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *ExitedExecutorMessage) Reset() { *m = ExitedExecutorMessage{} }
func (m *ExitedExecutorMessage) String() string { return proto.CompactTextString(m) }
func (*ExitedExecutorMessage) ProtoMessage() {}
func (m *ExitedExecutorMessage) GetSlaveId() *SlaveID {
if m != nil {
return m.SlaveId
}
return nil
}
func (m *ExitedExecutorMessage) GetFrameworkId() *FrameworkID {
if m != nil {
return m.FrameworkId
}
return nil
}
func (m *ExitedExecutorMessage) GetExecutorId() *ExecutorID {
if m != nil {
return m.ExecutorId
}
return nil
}
func (m *ExitedExecutorMessage) GetStatus() int32 {
if m != nil && m.Status != nil {
return *m.Status
}
return 0
}
type ReconnectExecutorMessage struct {
SlaveId *SlaveID `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *ReconnectExecutorMessage) Reset() { *m = ReconnectExecutorMessage{} }
func (m *ReconnectExecutorMessage) String() string { return proto.CompactTextString(m) }
func (*ReconnectExecutorMessage) ProtoMessage() {}
func (m *ReconnectExecutorMessage) GetSlaveId() *SlaveID {
if m != nil {
return m.SlaveId
}
return nil
}
type ReregisterExecutorMessage struct {
ExecutorId *ExecutorID `protobuf:"bytes,1,req,name=executor_id" json:"executor_id,omitempty"`
FrameworkId *FrameworkID `protobuf:"bytes,2,req,name=framework_id" json:"framework_id,omitempty"`
Tasks []*TaskInfo `protobuf:"bytes,3,rep,name=tasks" json:"tasks,omitempty"`
Updates []*StatusUpdate `protobuf:"bytes,4,rep,name=updates" json:"updates,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *ReregisterExecutorMessage) Reset() { *m = ReregisterExecutorMessage{} }
func (m *ReregisterExecutorMessage) String() string { return proto.CompactTextString(m) }
func (*ReregisterExecutorMessage) ProtoMessage() {}
func (m *ReregisterExecutorMessage) GetExecutorId() *ExecutorID {
if m != nil {
return m.ExecutorId
}
return nil
}
func (m *ReregisterExecutorMessage) GetFrameworkId() *FrameworkID {
if m != nil {
return m.FrameworkId
}
return nil
}
func (m *ReregisterExecutorMessage) GetTasks() []*TaskInfo {
if m != nil {
return m.Tasks
}
return nil
}
func (m *ReregisterExecutorMessage) GetUpdates() []*StatusUpdate {
if m != nil {
return m.Updates
}
return nil
}
type ShutdownMessage struct {
Message *string `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *ShutdownMessage) Reset() { *m = ShutdownMessage{} }
func (m *ShutdownMessage) String() string { return proto.CompactTextString(m) }
func (*ShutdownMessage) ProtoMessage() {}
func (m *ShutdownMessage) GetMessage() string {
if m != nil && m.Message != nil {
return *m.Message
}
return ""
}
type AuthenticateMessage struct {
Pid *string `protobuf:"bytes,1,req,name=pid" json:"pid,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *AuthenticateMessage) Reset() { *m = AuthenticateMessage{} }
func (m *AuthenticateMessage) String() string { return proto.CompactTextString(m) }
func (*AuthenticateMessage) ProtoMessage() {}
func (m *AuthenticateMessage) GetPid() string {
if m != nil && m.Pid != nil {
return *m.Pid
}
return ""
}
type AuthenticationMechanismsMessage struct {
Mechanisms []string `protobuf:"bytes,1,rep,name=mechanisms" json:"mechanisms,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *AuthenticationMechanismsMessage) Reset() { *m = AuthenticationMechanismsMessage{} }
func (m *AuthenticationMechanismsMessage) String() string { return proto.CompactTextString(m) }
func (*AuthenticationMechanismsMessage) ProtoMessage() {}
func (m *AuthenticationMechanismsMessage) GetMechanisms() []string {
if m != nil {
return m.Mechanisms
}
return nil
}
type AuthenticationStartMessage struct {
Mechanism *string `protobuf:"bytes,1,req,name=mechanism" json:"mechanism,omitempty"`
Data *string `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *AuthenticationStartMessage) Reset() { *m = AuthenticationStartMessage{} }
func (m *AuthenticationStartMessage) String() string { return proto.CompactTextString(m) }
func (*AuthenticationStartMessage) ProtoMessage() {}
func (m *AuthenticationStartMessage) GetMechanism() string {
if m != nil && m.Mechanism != nil {
return *m.Mechanism
}
return ""
}
func (m *AuthenticationStartMessage) GetData() string {
if m != nil && m.Data != nil {
return *m.Data
}
return ""
}
type AuthenticationStepMessage struct {
Data []byte `protobuf:"bytes,1,req,name=data" json:"data,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *AuthenticationStepMessage) Reset() { *m = AuthenticationStepMessage{} }
func (m *AuthenticationStepMessage) String() string { return proto.CompactTextString(m) }
func (*AuthenticationStepMessage) ProtoMessage() {}
func (m *AuthenticationStepMessage) GetData() []byte {
if m != nil {
return m.Data
}
return nil
}
type AuthenticationCompletedMessage struct {
XXX_unrecognized []byte `json:"-"`
}
func (m *AuthenticationCompletedMessage) Reset() { *m = AuthenticationCompletedMessage{} }
func (m *AuthenticationCompletedMessage) String() string { return proto.CompactTextString(m) }
func (*AuthenticationCompletedMessage) ProtoMessage() {}
type AuthenticationFailedMessage struct {
XXX_unrecognized []byte `json:"-"`
}
func (m *AuthenticationFailedMessage) Reset() { *m = AuthenticationFailedMessage{} }
func (m *AuthenticationFailedMessage) String() string { return proto.CompactTextString(m) }
func (*AuthenticationFailedMessage) ProtoMessage() {}
type AuthenticationErrorMessage struct {
Error *string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *AuthenticationErrorMessage) Reset() { *m = AuthenticationErrorMessage{} }
func (m *AuthenticationErrorMessage) String() string { return proto.CompactTextString(m) }
func (*AuthenticationErrorMessage) ProtoMessage() {}
func (m *AuthenticationErrorMessage) GetError() string {
if m != nil && m.Error != nil {
return *m.Error
}
return ""
}
// *
// Describes Completed Frameworks, etc. for archival.
type Archive struct {
Frameworks []*Archive_Framework `protobuf:"bytes,1,rep,name=frameworks" json:"frameworks,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *Archive) Reset() { *m = Archive{} }
func (m *Archive) String() string { return proto.CompactTextString(m) }
func (*Archive) ProtoMessage() {}
func (m *Archive) GetFrameworks() []*Archive_Framework {
if m != nil {
return m.Frameworks
}
return nil
}
type Archive_Framework struct {
FrameworkInfo *FrameworkInfo `protobuf:"bytes,1,req,name=framework_info" json:"framework_info,omitempty"`
Pid *string `protobuf:"bytes,2,opt,name=pid" json:"pid,omitempty"`
Tasks []*Task `protobuf:"bytes,3,rep,name=tasks" json:"tasks,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *Archive_Framework) Reset() { *m = Archive_Framework{} }
func (m *Archive_Framework) String() string { return proto.CompactTextString(m) }
func (*Archive_Framework) ProtoMessage() {}
func (m *Archive_Framework) GetFrameworkInfo() *FrameworkInfo {
if m != nil {
return m.FrameworkInfo
}
return nil
}
func (m *Archive_Framework) GetPid() string {
if m != nil && m.Pid != nil {
return *m.Pid
}
return ""
}
func (m *Archive_Framework) GetTasks() []*Task {
if m != nil {
return m.Tasks
}
return nil
}
// Message describing task current health status that is sent by
// the task health checker to the command executor.
// The command executor reports the task status back to the
// on each receive. If the health checker configured faiure
// condition meets, then kill_task flag will be set to true which
// the executor on message receive will kill the task.
type TaskHealthStatus struct {
TaskId *TaskID `protobuf:"bytes,1,req,name=task_id" json:"task_id,omitempty"`
Healthy *bool `protobuf:"varint,2,req,name=healthy" json:"healthy,omitempty"`
// Flag to initiate task kill.
KillTask *bool `protobuf:"varint,3,opt,name=kill_task,def=0" json:"kill_task,omitempty"`
// Number of consecutive counts in current status.
// This will not be populated if task is healthy.
ConsecutiveFailures *int32 `protobuf:"varint,4,opt,name=consecutive_failures" json:"consecutive_failures,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *TaskHealthStatus) Reset() { *m = TaskHealthStatus{} }
func (m *TaskHealthStatus) String() string { return proto.CompactTextString(m) }
func (*TaskHealthStatus) ProtoMessage() {}
const Default_TaskHealthStatus_KillTask bool = false
func (m *TaskHealthStatus) GetTaskId() *TaskID {
if m != nil {
return m.TaskId
}
return nil
}
func (m *TaskHealthStatus) GetHealthy() bool {
if m != nil && m.Healthy != nil {
return *m.Healthy
}
return false
}
func (m *TaskHealthStatus) GetKillTask() bool {
if m != nil && m.KillTask != nil {
return *m.KillTask
}
return Default_TaskHealthStatus_KillTask
}
func (m *TaskHealthStatus) GetConsecutiveFailures() int32 {
if m != nil && m.ConsecutiveFailures != nil {
return *m.ConsecutiveFailures
}
return 0
}
// Collection of Modules.
type Modules struct {
Libraries []*Modules_Library `protobuf:"bytes,1,rep,name=libraries" json:"libraries,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *Modules) Reset() { *m = Modules{} }
func (m *Modules) String() string { return proto.CompactTextString(m) }
func (*Modules) ProtoMessage() {}
func (m *Modules) GetLibraries() []*Modules_Library {
if m != nil {
return m.Libraries
}
return nil
}
type Modules_Library struct {
// If "file" contains a slash ("/"), then it is interpreted as a
// (relative or absolute) pathname. Otherwise a standard library
// search is performed.
File *string `protobuf:"bytes,1,opt,name=file" json:"file,omitempty"`
// We will add the proper prefix ("lib") and suffix (".so" for
// Linux and ".dylib" for OS X) to the "name".
Name *string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
Modules []*Modules_Library_Module `protobuf:"bytes,3,rep,name=modules" json:"modules,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *Modules_Library) Reset() { *m = Modules_Library{} }
func (m *Modules_Library) String() string { return proto.CompactTextString(m) }
func (*Modules_Library) ProtoMessage() {}
func (m *Modules_Library) GetFile() string {
if m != nil && m.File != nil {
return *m.File
}
return ""
}
func (m *Modules_Library) GetName() string {
if m != nil && m.Name != nil {
return *m.Name
}
return ""
}
func (m *Modules_Library) GetModules() []*Modules_Library_Module {
if m != nil {
return m.Modules
}
return nil
}
type Modules_Library_Module struct {
// Module name.
Name *string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
// Module-specific parameters.
Parameters []*Parameter `protobuf:"bytes,2,rep,name=parameters" json:"parameters,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *Modules_Library_Module) Reset() { *m = Modules_Library_Module{} }
func (m *Modules_Library_Module) String() string { return proto.CompactTextString(m) }
func (*Modules_Library_Module) ProtoMessage() {}
func (m *Modules_Library_Module) GetName() string {
if m != nil && m.Name != nil {
return *m.Name
}
return ""
}
func (m *Modules_Library_Module) GetParameters() []*Parameter {
if m != nil {
return m.Parameters
}
return nil
}
func init() {
proto.RegisterEnum("mesosproto.StatusUpdateRecord_Type", StatusUpdateRecord_Type_name, StatusUpdateRecord_Type_value)
}
Go
1
https://gitee.com/meoom/kubernetes.git
git@gitee.com:meoom/kubernetes.git
meoom
kubernetes
kubernetes
v0.21.2

搜索帮助