Documentation ¶
Index ¶
- Constants
- Variables
- type Call
- func (*Call) Descriptor() ([]byte, []int)
- func (m *Call) GetCreateVolumes() *Call_CreateVolumes
- func (m *Call) GetDeactivateAgent() *Call_DeactivateAgent
- func (m *Call) GetDestroyVolumes() *Call_DestroyVolumes
- func (m *Call) GetDrainAgent() *Call_DrainAgent
- func (m *Call) GetGetMetrics() *Call_GetMetrics
- func (m *Call) GetGrowVolume() *Call_GrowVolume
- func (m *Call) GetListFiles() *Call_ListFiles
- func (m *Call) GetMarkAgentGone() *Call_MarkAgentGone
- func (m *Call) GetReactivateAgent() *Call_ReactivateAgent
- func (m *Call) GetReadFile() *Call_ReadFile
- func (m *Call) GetRemoveQuota() *Call_RemoveQuotadeprecated
- func (m *Call) GetReserveResources() *Call_ReserveResources
- func (m *Call) GetSetLoggingLevel() *Call_SetLoggingLevel
- func (m *Call) GetSetQuota() *Call_SetQuotadeprecated
- func (m *Call) GetShrinkVolume() *Call_ShrinkVolume
- func (m *Call) GetStartMaintenance() *Call_StartMaintenance
- func (m *Call) GetStopMaintenance() *Call_StopMaintenance
- func (m *Call) GetTeardown() *Call_Teardown
- func (m *Call) GetType() Call_Type
- func (m *Call) GetUnreserveResources() *Call_UnreserveResources
- func (m *Call) GetUpdateMaintenanceSchedule() *Call_UpdateMaintenanceSchedule
- func (m *Call) GetUpdateQuota() *Call_UpdateQuota
- func (m *Call) GetUpdateWeights() *Call_UpdateWeights
- func (*Call) ProtoMessage()
- func (m *Call) Reset()
- func (m *Call) String() string
- func (m *Call) XXX_DiscardUnknown()
- func (m *Call) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call) XXX_Merge(src proto.Message)
- func (m *Call) XXX_Size() int
- func (m *Call) XXX_Unmarshal(b []byte) error
- type Call_CreateVolumes
- func (*Call_CreateVolumes) Descriptor() ([]byte, []int)
- func (m *Call_CreateVolumes) GetAgentId() *v1.AgentID
- func (m *Call_CreateVolumes) GetVolumes() []*v1.Resource
- func (*Call_CreateVolumes) ProtoMessage()
- func (m *Call_CreateVolumes) Reset()
- func (m *Call_CreateVolumes) String() string
- func (m *Call_CreateVolumes) XXX_DiscardUnknown()
- func (m *Call_CreateVolumes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call_CreateVolumes) XXX_Merge(src proto.Message)
- func (m *Call_CreateVolumes) XXX_Size() int
- func (m *Call_CreateVolumes) XXX_Unmarshal(b []byte) error
- type Call_DeactivateAgent
- func (*Call_DeactivateAgent) Descriptor() ([]byte, []int)
- func (m *Call_DeactivateAgent) GetAgentId() *v1.AgentID
- func (*Call_DeactivateAgent) ProtoMessage()
- func (m *Call_DeactivateAgent) Reset()
- func (m *Call_DeactivateAgent) String() string
- func (m *Call_DeactivateAgent) XXX_DiscardUnknown()
- func (m *Call_DeactivateAgent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call_DeactivateAgent) XXX_Merge(src proto.Message)
- func (m *Call_DeactivateAgent) XXX_Size() int
- func (m *Call_DeactivateAgent) XXX_Unmarshal(b []byte) error
- type Call_DestroyVolumes
- func (*Call_DestroyVolumes) Descriptor() ([]byte, []int)
- func (m *Call_DestroyVolumes) GetAgentId() *v1.AgentID
- func (m *Call_DestroyVolumes) GetVolumes() []*v1.Resource
- func (*Call_DestroyVolumes) ProtoMessage()
- func (m *Call_DestroyVolumes) Reset()
- func (m *Call_DestroyVolumes) String() string
- func (m *Call_DestroyVolumes) XXX_DiscardUnknown()
- func (m *Call_DestroyVolumes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call_DestroyVolumes) XXX_Merge(src proto.Message)
- func (m *Call_DestroyVolumes) XXX_Size() int
- func (m *Call_DestroyVolumes) XXX_Unmarshal(b []byte) error
- type Call_DrainAgent
- func (*Call_DrainAgent) Descriptor() ([]byte, []int)
- func (m *Call_DrainAgent) GetAgentId() *v1.AgentID
- func (m *Call_DrainAgent) GetMarkGone() bool
- func (m *Call_DrainAgent) GetMaxGracePeriod() *duration.Duration
- func (*Call_DrainAgent) ProtoMessage()
- func (m *Call_DrainAgent) Reset()
- func (m *Call_DrainAgent) String() string
- func (m *Call_DrainAgent) XXX_DiscardUnknown()
- func (m *Call_DrainAgent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call_DrainAgent) XXX_Merge(src proto.Message)
- func (m *Call_DrainAgent) XXX_Size() int
- func (m *Call_DrainAgent) XXX_Unmarshal(b []byte) error
- type Call_GetMetrics
- func (*Call_GetMetrics) Descriptor() ([]byte, []int)
- func (m *Call_GetMetrics) GetTimeout() *v1.DurationInfo
- func (*Call_GetMetrics) ProtoMessage()
- func (m *Call_GetMetrics) Reset()
- func (m *Call_GetMetrics) String() string
- func (m *Call_GetMetrics) XXX_DiscardUnknown()
- func (m *Call_GetMetrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call_GetMetrics) XXX_Merge(src proto.Message)
- func (m *Call_GetMetrics) XXX_Size() int
- func (m *Call_GetMetrics) XXX_Unmarshal(b []byte) error
- type Call_GrowVolume
- func (*Call_GrowVolume) Descriptor() ([]byte, []int)
- func (m *Call_GrowVolume) GetAddition() *v1.Resource
- func (m *Call_GrowVolume) GetAgentId() *v1.AgentID
- func (m *Call_GrowVolume) GetVolume() *v1.Resource
- func (*Call_GrowVolume) ProtoMessage()
- func (m *Call_GrowVolume) Reset()
- func (m *Call_GrowVolume) String() string
- func (m *Call_GrowVolume) XXX_DiscardUnknown()
- func (m *Call_GrowVolume) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call_GrowVolume) XXX_Merge(src proto.Message)
- func (m *Call_GrowVolume) XXX_Size() int
- func (m *Call_GrowVolume) XXX_Unmarshal(b []byte) error
- type Call_ListFiles
- func (*Call_ListFiles) Descriptor() ([]byte, []int)
- func (m *Call_ListFiles) GetPath() string
- func (*Call_ListFiles) ProtoMessage()
- func (m *Call_ListFiles) Reset()
- func (m *Call_ListFiles) String() string
- func (m *Call_ListFiles) XXX_DiscardUnknown()
- func (m *Call_ListFiles) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call_ListFiles) XXX_Merge(src proto.Message)
- func (m *Call_ListFiles) XXX_Size() int
- func (m *Call_ListFiles) XXX_Unmarshal(b []byte) error
- type Call_MarkAgentGone
- func (*Call_MarkAgentGone) Descriptor() ([]byte, []int)
- func (m *Call_MarkAgentGone) GetAgentId() *v1.AgentID
- func (*Call_MarkAgentGone) ProtoMessage()
- func (m *Call_MarkAgentGone) Reset()
- func (m *Call_MarkAgentGone) String() string
- func (m *Call_MarkAgentGone) XXX_DiscardUnknown()
- func (m *Call_MarkAgentGone) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call_MarkAgentGone) XXX_Merge(src proto.Message)
- func (m *Call_MarkAgentGone) XXX_Size() int
- func (m *Call_MarkAgentGone) XXX_Unmarshal(b []byte) error
- type Call_ReactivateAgent
- func (*Call_ReactivateAgent) Descriptor() ([]byte, []int)
- func (m *Call_ReactivateAgent) GetAgentId() *v1.AgentID
- func (*Call_ReactivateAgent) ProtoMessage()
- func (m *Call_ReactivateAgent) Reset()
- func (m *Call_ReactivateAgent) String() string
- func (m *Call_ReactivateAgent) XXX_DiscardUnknown()
- func (m *Call_ReactivateAgent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call_ReactivateAgent) XXX_Merge(src proto.Message)
- func (m *Call_ReactivateAgent) XXX_Size() int
- func (m *Call_ReactivateAgent) XXX_Unmarshal(b []byte) error
- type Call_ReadFile
- func (*Call_ReadFile) Descriptor() ([]byte, []int)
- func (m *Call_ReadFile) GetLength() uint64
- func (m *Call_ReadFile) GetOffset() uint64
- func (m *Call_ReadFile) GetPath() string
- func (*Call_ReadFile) ProtoMessage()
- func (m *Call_ReadFile) Reset()
- func (m *Call_ReadFile) String() string
- func (m *Call_ReadFile) XXX_DiscardUnknown()
- func (m *Call_ReadFile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call_ReadFile) XXX_Merge(src proto.Message)
- func (m *Call_ReadFile) XXX_Size() int
- func (m *Call_ReadFile) XXX_Unmarshal(b []byte) error
- type Call_RemoveQuota
- func (*Call_RemoveQuota) Descriptor() ([]byte, []int)
- func (m *Call_RemoveQuota) GetRole() string
- func (*Call_RemoveQuota) ProtoMessage()
- func (m *Call_RemoveQuota) Reset()
- func (m *Call_RemoveQuota) String() string
- func (m *Call_RemoveQuota) XXX_DiscardUnknown()
- func (m *Call_RemoveQuota) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call_RemoveQuota) XXX_Merge(src proto.Message)
- func (m *Call_RemoveQuota) XXX_Size() int
- func (m *Call_RemoveQuota) XXX_Unmarshal(b []byte) error
- type Call_ReserveResources
- func (*Call_ReserveResources) Descriptor() ([]byte, []int)
- func (m *Call_ReserveResources) GetAgentId() *v1.AgentID
- func (m *Call_ReserveResources) GetResources() []*v1.Resource
- func (*Call_ReserveResources) ProtoMessage()
- func (m *Call_ReserveResources) Reset()
- func (m *Call_ReserveResources) String() string
- func (m *Call_ReserveResources) XXX_DiscardUnknown()
- func (m *Call_ReserveResources) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call_ReserveResources) XXX_Merge(src proto.Message)
- func (m *Call_ReserveResources) XXX_Size() int
- func (m *Call_ReserveResources) XXX_Unmarshal(b []byte) error
- type Call_SetLoggingLevel
- func (*Call_SetLoggingLevel) Descriptor() ([]byte, []int)
- func (m *Call_SetLoggingLevel) GetDuration() *v1.DurationInfo
- func (m *Call_SetLoggingLevel) GetLevel() uint32
- func (*Call_SetLoggingLevel) ProtoMessage()
- func (m *Call_SetLoggingLevel) Reset()
- func (m *Call_SetLoggingLevel) String() string
- func (m *Call_SetLoggingLevel) XXX_DiscardUnknown()
- func (m *Call_SetLoggingLevel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call_SetLoggingLevel) XXX_Merge(src proto.Message)
- func (m *Call_SetLoggingLevel) XXX_Size() int
- func (m *Call_SetLoggingLevel) XXX_Unmarshal(b []byte) error
- type Call_SetQuota
- func (*Call_SetQuota) Descriptor() ([]byte, []int)
- func (m *Call_SetQuota) GetQuotaRequest() *quota.QuotaRequest
- func (*Call_SetQuota) ProtoMessage()
- func (m *Call_SetQuota) Reset()
- func (m *Call_SetQuota) String() string
- func (m *Call_SetQuota) XXX_DiscardUnknown()
- func (m *Call_SetQuota) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call_SetQuota) XXX_Merge(src proto.Message)
- func (m *Call_SetQuota) XXX_Size() int
- func (m *Call_SetQuota) XXX_Unmarshal(b []byte) error
- type Call_ShrinkVolume
- func (*Call_ShrinkVolume) Descriptor() ([]byte, []int)
- func (m *Call_ShrinkVolume) GetAgentId() *v1.AgentID
- func (m *Call_ShrinkVolume) GetSubtract() *v1.Value_Scalar
- func (m *Call_ShrinkVolume) GetVolume() *v1.Resource
- func (*Call_ShrinkVolume) ProtoMessage()
- func (m *Call_ShrinkVolume) Reset()
- func (m *Call_ShrinkVolume) String() string
- func (m *Call_ShrinkVolume) XXX_DiscardUnknown()
- func (m *Call_ShrinkVolume) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call_ShrinkVolume) XXX_Merge(src proto.Message)
- func (m *Call_ShrinkVolume) XXX_Size() int
- func (m *Call_ShrinkVolume) XXX_Unmarshal(b []byte) error
- type Call_StartMaintenance
- func (*Call_StartMaintenance) Descriptor() ([]byte, []int)
- func (m *Call_StartMaintenance) GetMachines() []*v1.MachineID
- func (*Call_StartMaintenance) ProtoMessage()
- func (m *Call_StartMaintenance) Reset()
- func (m *Call_StartMaintenance) String() string
- func (m *Call_StartMaintenance) XXX_DiscardUnknown()
- func (m *Call_StartMaintenance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call_StartMaintenance) XXX_Merge(src proto.Message)
- func (m *Call_StartMaintenance) XXX_Size() int
- func (m *Call_StartMaintenance) XXX_Unmarshal(b []byte) error
- type Call_StopMaintenance
- func (*Call_StopMaintenance) Descriptor() ([]byte, []int)
- func (m *Call_StopMaintenance) GetMachines() []*v1.MachineID
- func (*Call_StopMaintenance) ProtoMessage()
- func (m *Call_StopMaintenance) Reset()
- func (m *Call_StopMaintenance) String() string
- func (m *Call_StopMaintenance) XXX_DiscardUnknown()
- func (m *Call_StopMaintenance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call_StopMaintenance) XXX_Merge(src proto.Message)
- func (m *Call_StopMaintenance) XXX_Size() int
- func (m *Call_StopMaintenance) XXX_Unmarshal(b []byte) error
- type Call_Teardown
- func (*Call_Teardown) Descriptor() ([]byte, []int)
- func (m *Call_Teardown) GetFrameworkId() *v1.FrameworkID
- func (*Call_Teardown) ProtoMessage()
- func (m *Call_Teardown) Reset()
- func (m *Call_Teardown) String() string
- func (m *Call_Teardown) XXX_DiscardUnknown()
- func (m *Call_Teardown) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call_Teardown) XXX_Merge(src proto.Message)
- func (m *Call_Teardown) XXX_Size() int
- func (m *Call_Teardown) XXX_Unmarshal(b []byte) error
- type Call_Type
- type Call_UnreserveResources
- func (*Call_UnreserveResources) Descriptor() ([]byte, []int)
- func (m *Call_UnreserveResources) GetAgentId() *v1.AgentID
- func (m *Call_UnreserveResources) GetResources() []*v1.Resource
- func (*Call_UnreserveResources) ProtoMessage()
- func (m *Call_UnreserveResources) Reset()
- func (m *Call_UnreserveResources) String() string
- func (m *Call_UnreserveResources) XXX_DiscardUnknown()
- func (m *Call_UnreserveResources) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call_UnreserveResources) XXX_Merge(src proto.Message)
- func (m *Call_UnreserveResources) XXX_Size() int
- func (m *Call_UnreserveResources) XXX_Unmarshal(b []byte) error
- type Call_UpdateMaintenanceSchedule
- func (*Call_UpdateMaintenanceSchedule) Descriptor() ([]byte, []int)
- func (m *Call_UpdateMaintenanceSchedule) GetSchedule() *maintenance.Schedule
- func (*Call_UpdateMaintenanceSchedule) ProtoMessage()
- func (m *Call_UpdateMaintenanceSchedule) Reset()
- func (m *Call_UpdateMaintenanceSchedule) String() string
- func (m *Call_UpdateMaintenanceSchedule) XXX_DiscardUnknown()
- func (m *Call_UpdateMaintenanceSchedule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call_UpdateMaintenanceSchedule) XXX_Merge(src proto.Message)
- func (m *Call_UpdateMaintenanceSchedule) XXX_Size() int
- func (m *Call_UpdateMaintenanceSchedule) XXX_Unmarshal(b []byte) error
- type Call_UpdateQuota
- func (*Call_UpdateQuota) Descriptor() ([]byte, []int)
- func (m *Call_UpdateQuota) GetForce() bool
- func (m *Call_UpdateQuota) GetQuotaConfigs() []*quota.QuotaConfig
- func (*Call_UpdateQuota) ProtoMessage()
- func (m *Call_UpdateQuota) Reset()
- func (m *Call_UpdateQuota) String() string
- func (m *Call_UpdateQuota) XXX_DiscardUnknown()
- func (m *Call_UpdateQuota) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call_UpdateQuota) XXX_Merge(src proto.Message)
- func (m *Call_UpdateQuota) XXX_Size() int
- func (m *Call_UpdateQuota) XXX_Unmarshal(b []byte) error
- type Call_UpdateWeights
- func (*Call_UpdateWeights) Descriptor() ([]byte, []int)
- func (m *Call_UpdateWeights) GetWeightInfos() []*v1.WeightInfo
- func (*Call_UpdateWeights) ProtoMessage()
- func (m *Call_UpdateWeights) Reset()
- func (m *Call_UpdateWeights) String() string
- func (m *Call_UpdateWeights) XXX_DiscardUnknown()
- func (m *Call_UpdateWeights) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call_UpdateWeights) XXX_Merge(src proto.Message)
- func (m *Call_UpdateWeights) XXX_Size() int
- func (m *Call_UpdateWeights) XXX_Unmarshal(b []byte) error
- type Event
- func (*Event) Descriptor() ([]byte, []int)
- func (m *Event) GetAgentAdded() *Event_AgentAdded
- func (m *Event) GetAgentRemoved() *Event_AgentRemoved
- func (m *Event) GetFrameworkAdded() *Event_FrameworkAdded
- func (m *Event) GetFrameworkRemoved() *Event_FrameworkRemoved
- func (m *Event) GetFrameworkUpdated() *Event_FrameworkUpdated
- func (m *Event) GetSubscribed() *Event_Subscribed
- func (m *Event) GetTaskAdded() *Event_TaskAdded
- func (m *Event) GetTaskUpdated() *Event_TaskUpdated
- func (m *Event) GetType() Event_Type
- func (*Event) ProtoMessage()
- func (m *Event) Reset()
- func (m *Event) String() string
- func (m *Event) XXX_DiscardUnknown()
- func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Event) XXX_Merge(src proto.Message)
- func (m *Event) XXX_Size() int
- func (m *Event) XXX_Unmarshal(b []byte) error
- type Event_AgentAdded
- func (*Event_AgentAdded) Descriptor() ([]byte, []int)
- func (m *Event_AgentAdded) GetAgent() *Response_GetAgents_Agent
- func (*Event_AgentAdded) ProtoMessage()
- func (m *Event_AgentAdded) Reset()
- func (m *Event_AgentAdded) String() string
- func (m *Event_AgentAdded) XXX_DiscardUnknown()
- func (m *Event_AgentAdded) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Event_AgentAdded) XXX_Merge(src proto.Message)
- func (m *Event_AgentAdded) XXX_Size() int
- func (m *Event_AgentAdded) XXX_Unmarshal(b []byte) error
- type Event_AgentRemoved
- func (*Event_AgentRemoved) Descriptor() ([]byte, []int)
- func (m *Event_AgentRemoved) GetAgentId() *v1.AgentID
- func (*Event_AgentRemoved) ProtoMessage()
- func (m *Event_AgentRemoved) Reset()
- func (m *Event_AgentRemoved) String() string
- func (m *Event_AgentRemoved) XXX_DiscardUnknown()
- func (m *Event_AgentRemoved) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Event_AgentRemoved) XXX_Merge(src proto.Message)
- func (m *Event_AgentRemoved) XXX_Size() int
- func (m *Event_AgentRemoved) XXX_Unmarshal(b []byte) error
- type Event_FrameworkAdded
- func (*Event_FrameworkAdded) Descriptor() ([]byte, []int)
- func (m *Event_FrameworkAdded) GetFramework() *Response_GetFrameworks_Framework
- func (*Event_FrameworkAdded) ProtoMessage()
- func (m *Event_FrameworkAdded) Reset()
- func (m *Event_FrameworkAdded) String() string
- func (m *Event_FrameworkAdded) XXX_DiscardUnknown()
- func (m *Event_FrameworkAdded) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Event_FrameworkAdded) XXX_Merge(src proto.Message)
- func (m *Event_FrameworkAdded) XXX_Size() int
- func (m *Event_FrameworkAdded) XXX_Unmarshal(b []byte) error
- type Event_FrameworkRemoved
- func (*Event_FrameworkRemoved) Descriptor() ([]byte, []int)
- func (m *Event_FrameworkRemoved) GetFrameworkInfo() *v1.FrameworkInfo
- func (*Event_FrameworkRemoved) ProtoMessage()
- func (m *Event_FrameworkRemoved) Reset()
- func (m *Event_FrameworkRemoved) String() string
- func (m *Event_FrameworkRemoved) XXX_DiscardUnknown()
- func (m *Event_FrameworkRemoved) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Event_FrameworkRemoved) XXX_Merge(src proto.Message)
- func (m *Event_FrameworkRemoved) XXX_Size() int
- func (m *Event_FrameworkRemoved) XXX_Unmarshal(b []byte) error
- type Event_FrameworkUpdated
- func (*Event_FrameworkUpdated) Descriptor() ([]byte, []int)
- func (m *Event_FrameworkUpdated) GetFramework() *Response_GetFrameworks_Framework
- func (*Event_FrameworkUpdated) ProtoMessage()
- func (m *Event_FrameworkUpdated) Reset()
- func (m *Event_FrameworkUpdated) String() string
- func (m *Event_FrameworkUpdated) XXX_DiscardUnknown()
- func (m *Event_FrameworkUpdated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Event_FrameworkUpdated) XXX_Merge(src proto.Message)
- func (m *Event_FrameworkUpdated) XXX_Size() int
- func (m *Event_FrameworkUpdated) XXX_Unmarshal(b []byte) error
- type Event_Subscribed
- func (*Event_Subscribed) Descriptor() ([]byte, []int)
- func (m *Event_Subscribed) GetGetState() *Response_GetState
- func (m *Event_Subscribed) GetHeartbeatIntervalSeconds() float64
- func (*Event_Subscribed) ProtoMessage()
- func (m *Event_Subscribed) Reset()
- func (m *Event_Subscribed) String() string
- func (m *Event_Subscribed) XXX_DiscardUnknown()
- func (m *Event_Subscribed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Event_Subscribed) XXX_Merge(src proto.Message)
- func (m *Event_Subscribed) XXX_Size() int
- func (m *Event_Subscribed) XXX_Unmarshal(b []byte) error
- type Event_TaskAdded
- func (*Event_TaskAdded) Descriptor() ([]byte, []int)
- func (m *Event_TaskAdded) GetTask() *v1.Task
- func (*Event_TaskAdded) ProtoMessage()
- func (m *Event_TaskAdded) Reset()
- func (m *Event_TaskAdded) String() string
- func (m *Event_TaskAdded) XXX_DiscardUnknown()
- func (m *Event_TaskAdded) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Event_TaskAdded) XXX_Merge(src proto.Message)
- func (m *Event_TaskAdded) XXX_Size() int
- func (m *Event_TaskAdded) XXX_Unmarshal(b []byte) error
- type Event_TaskUpdated
- func (*Event_TaskUpdated) Descriptor() ([]byte, []int)
- func (m *Event_TaskUpdated) GetFrameworkId() *v1.FrameworkID
- func (m *Event_TaskUpdated) GetState() v1.TaskState
- func (m *Event_TaskUpdated) GetStatus() *v1.TaskStatus
- func (*Event_TaskUpdated) ProtoMessage()
- func (m *Event_TaskUpdated) Reset()
- func (m *Event_TaskUpdated) String() string
- func (m *Event_TaskUpdated) XXX_DiscardUnknown()
- func (m *Event_TaskUpdated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Event_TaskUpdated) XXX_Merge(src proto.Message)
- func (m *Event_TaskUpdated) XXX_Size() int
- func (m *Event_TaskUpdated) XXX_Unmarshal(b []byte) error
- type Event_Type
- type Response
- func (*Response) Descriptor() ([]byte, []int)
- func (m *Response) GetGetAgents() *Response_GetAgents
- func (m *Response) GetGetExecutors() *Response_GetExecutors
- func (m *Response) GetGetFlags() *Response_GetFlags
- func (m *Response) GetGetFrameworks() *Response_GetFrameworks
- func (m *Response) GetGetHealth() *Response_GetHealth
- func (m *Response) GetGetLoggingLevel() *Response_GetLoggingLevel
- func (m *Response) GetGetMaintenanceSchedule() *Response_GetMaintenanceSchedule
- func (m *Response) GetGetMaintenanceStatus() *Response_GetMaintenanceStatus
- func (m *Response) GetGetMaster() *Response_GetMaster
- func (m *Response) GetGetMetrics() *Response_GetMetrics
- func (m *Response) GetGetOperations() *Response_GetOperations
- func (m *Response) GetGetQuota() *Response_GetQuota
- func (m *Response) GetGetRoles() *Response_GetRoles
- func (m *Response) GetGetState() *Response_GetState
- func (m *Response) GetGetTasks() *Response_GetTasks
- func (m *Response) GetGetVersion() *Response_GetVersion
- func (m *Response) GetGetWeights() *Response_GetWeights
- func (m *Response) GetListFiles() *Response_ListFiles
- func (m *Response) GetReadFile() *Response_ReadFile
- func (m *Response) GetType() Response_Type
- func (*Response) ProtoMessage()
- func (m *Response) Reset()
- func (m *Response) String() string
- func (m *Response) XXX_DiscardUnknown()
- func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response) XXX_Merge(src proto.Message)
- func (m *Response) XXX_Size() int
- func (m *Response) XXX_Unmarshal(b []byte) error
- type Response_GetAgents
- func (*Response_GetAgents) Descriptor() ([]byte, []int)
- func (m *Response_GetAgents) GetAgents() []*Response_GetAgents_Agent
- func (m *Response_GetAgents) GetRecoveredAgents() []*v1.AgentInfo
- func (*Response_GetAgents) ProtoMessage()
- func (m *Response_GetAgents) Reset()
- func (m *Response_GetAgents) String() string
- func (m *Response_GetAgents) XXX_DiscardUnknown()
- func (m *Response_GetAgents) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_GetAgents) XXX_Merge(src proto.Message)
- func (m *Response_GetAgents) XXX_Size() int
- func (m *Response_GetAgents) XXX_Unmarshal(b []byte) error
- type Response_GetAgents_Agent
- func (*Response_GetAgents_Agent) Descriptor() ([]byte, []int)
- func (m *Response_GetAgents_Agent) GetActive() bool
- func (m *Response_GetAgents_Agent) GetAgentInfo() *v1.AgentInfo
- func (m *Response_GetAgents_Agent) GetAllocatedResources() []*v1.Resource
- func (m *Response_GetAgents_Agent) GetCapabilities() []*v1.AgentInfo_Capability
- func (m *Response_GetAgents_Agent) GetDeactivated() bool
- func (m *Response_GetAgents_Agent) GetDrainInfo() *v1.DrainInfo
- func (m *Response_GetAgents_Agent) GetEstimatedDrainStartTime() *v1.TimeInfo
- func (m *Response_GetAgents_Agent) GetOfferedResources() []*v1.Resource
- func (m *Response_GetAgents_Agent) GetPid() string
- func (m *Response_GetAgents_Agent) GetRegisteredTime() *v1.TimeInfo
- func (m *Response_GetAgents_Agent) GetReregisteredTime() *v1.TimeInfo
- func (m *Response_GetAgents_Agent) GetResourceProviders() []*Response_GetAgents_Agent_ResourceProvider
- func (m *Response_GetAgents_Agent) GetTotalResources() []*v1.Resource
- func (m *Response_GetAgents_Agent) GetVersion() string
- func (*Response_GetAgents_Agent) ProtoMessage()
- func (m *Response_GetAgents_Agent) Reset()
- func (m *Response_GetAgents_Agent) String() string
- func (m *Response_GetAgents_Agent) XXX_DiscardUnknown()
- func (m *Response_GetAgents_Agent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_GetAgents_Agent) XXX_Merge(src proto.Message)
- func (m *Response_GetAgents_Agent) XXX_Size() int
- func (m *Response_GetAgents_Agent) XXX_Unmarshal(b []byte) error
- type Response_GetAgents_Agent_ResourceProvider
- func (*Response_GetAgents_Agent_ResourceProvider) Descriptor() ([]byte, []int)
- func (m *Response_GetAgents_Agent_ResourceProvider) GetResourceProviderInfo() *v1.ResourceProviderInfo
- func (m *Response_GetAgents_Agent_ResourceProvider) GetTotalResources() []*v1.Resource
- func (*Response_GetAgents_Agent_ResourceProvider) ProtoMessage()
- func (m *Response_GetAgents_Agent_ResourceProvider) Reset()
- func (m *Response_GetAgents_Agent_ResourceProvider) String() string
- func (m *Response_GetAgents_Agent_ResourceProvider) XXX_DiscardUnknown()
- func (m *Response_GetAgents_Agent_ResourceProvider) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_GetAgents_Agent_ResourceProvider) XXX_Merge(src proto.Message)
- func (m *Response_GetAgents_Agent_ResourceProvider) XXX_Size() int
- func (m *Response_GetAgents_Agent_ResourceProvider) XXX_Unmarshal(b []byte) error
- type Response_GetExecutors
- func (*Response_GetExecutors) Descriptor() ([]byte, []int)
- func (m *Response_GetExecutors) GetExecutors() []*Response_GetExecutors_Executor
- func (m *Response_GetExecutors) GetOrphanExecutors() []*Response_GetExecutors_Executordeprecated
- func (*Response_GetExecutors) ProtoMessage()
- func (m *Response_GetExecutors) Reset()
- func (m *Response_GetExecutors) String() string
- func (m *Response_GetExecutors) XXX_DiscardUnknown()
- func (m *Response_GetExecutors) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_GetExecutors) XXX_Merge(src proto.Message)
- func (m *Response_GetExecutors) XXX_Size() int
- func (m *Response_GetExecutors) XXX_Unmarshal(b []byte) error
- type Response_GetExecutors_Executor
- func (*Response_GetExecutors_Executor) Descriptor() ([]byte, []int)
- func (m *Response_GetExecutors_Executor) GetAgentId() *v1.AgentID
- func (m *Response_GetExecutors_Executor) GetExecutorInfo() *v1.ExecutorInfo
- func (*Response_GetExecutors_Executor) ProtoMessage()
- func (m *Response_GetExecutors_Executor) Reset()
- func (m *Response_GetExecutors_Executor) String() string
- func (m *Response_GetExecutors_Executor) XXX_DiscardUnknown()
- func (m *Response_GetExecutors_Executor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_GetExecutors_Executor) XXX_Merge(src proto.Message)
- func (m *Response_GetExecutors_Executor) XXX_Size() int
- func (m *Response_GetExecutors_Executor) XXX_Unmarshal(b []byte) error
- type Response_GetFlags
- func (*Response_GetFlags) Descriptor() ([]byte, []int)
- func (m *Response_GetFlags) GetFlags() []*v1.Flag
- func (*Response_GetFlags) ProtoMessage()
- func (m *Response_GetFlags) Reset()
- func (m *Response_GetFlags) String() string
- func (m *Response_GetFlags) XXX_DiscardUnknown()
- func (m *Response_GetFlags) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_GetFlags) XXX_Merge(src proto.Message)
- func (m *Response_GetFlags) XXX_Size() int
- func (m *Response_GetFlags) XXX_Unmarshal(b []byte) error
- type Response_GetFrameworks
- func (*Response_GetFrameworks) Descriptor() ([]byte, []int)
- func (m *Response_GetFrameworks) GetCompletedFrameworks() []*Response_GetFrameworks_Framework
- func (m *Response_GetFrameworks) GetFrameworks() []*Response_GetFrameworks_Framework
- func (m *Response_GetFrameworks) GetRecoveredFrameworks() []*v1.FrameworkInfodeprecated
- func (*Response_GetFrameworks) ProtoMessage()
- func (m *Response_GetFrameworks) Reset()
- func (m *Response_GetFrameworks) String() string
- func (m *Response_GetFrameworks) XXX_DiscardUnknown()
- func (m *Response_GetFrameworks) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_GetFrameworks) XXX_Merge(src proto.Message)
- func (m *Response_GetFrameworks) XXX_Size() int
- func (m *Response_GetFrameworks) XXX_Unmarshal(b []byte) error
- type Response_GetFrameworks_Framework
- func (*Response_GetFrameworks_Framework) Descriptor() ([]byte, []int)
- func (m *Response_GetFrameworks_Framework) GetActive() bool
- func (m *Response_GetFrameworks_Framework) GetAllocatedResources() []*v1.Resource
- func (m *Response_GetFrameworks_Framework) GetConnected() bool
- func (m *Response_GetFrameworks_Framework) GetFrameworkInfo() *v1.FrameworkInfo
- func (m *Response_GetFrameworks_Framework) GetInverseOffers() []*v1.InverseOffer
- func (m *Response_GetFrameworks_Framework) GetOfferedResources() []*v1.Resource
- func (m *Response_GetFrameworks_Framework) GetOffers() []*v1.Offer
- func (m *Response_GetFrameworks_Framework) GetRecovered() bool
- func (m *Response_GetFrameworks_Framework) GetRegisteredTime() *v1.TimeInfo
- func (m *Response_GetFrameworks_Framework) GetReregisteredTime() *v1.TimeInfo
- func (m *Response_GetFrameworks_Framework) GetUnregisteredTime() *v1.TimeInfo
- func (*Response_GetFrameworks_Framework) ProtoMessage()
- func (m *Response_GetFrameworks_Framework) Reset()
- func (m *Response_GetFrameworks_Framework) String() string
- func (m *Response_GetFrameworks_Framework) XXX_DiscardUnknown()
- func (m *Response_GetFrameworks_Framework) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_GetFrameworks_Framework) XXX_Merge(src proto.Message)
- func (m *Response_GetFrameworks_Framework) XXX_Size() int
- func (m *Response_GetFrameworks_Framework) XXX_Unmarshal(b []byte) error
- type Response_GetHealth
- func (*Response_GetHealth) Descriptor() ([]byte, []int)
- func (m *Response_GetHealth) GetHealthy() bool
- func (*Response_GetHealth) ProtoMessage()
- func (m *Response_GetHealth) Reset()
- func (m *Response_GetHealth) String() string
- func (m *Response_GetHealth) XXX_DiscardUnknown()
- func (m *Response_GetHealth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_GetHealth) XXX_Merge(src proto.Message)
- func (m *Response_GetHealth) XXX_Size() int
- func (m *Response_GetHealth) XXX_Unmarshal(b []byte) error
- type Response_GetLoggingLevel
- func (*Response_GetLoggingLevel) Descriptor() ([]byte, []int)
- func (m *Response_GetLoggingLevel) GetLevel() uint32
- func (*Response_GetLoggingLevel) ProtoMessage()
- func (m *Response_GetLoggingLevel) Reset()
- func (m *Response_GetLoggingLevel) String() string
- func (m *Response_GetLoggingLevel) XXX_DiscardUnknown()
- func (m *Response_GetLoggingLevel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_GetLoggingLevel) XXX_Merge(src proto.Message)
- func (m *Response_GetLoggingLevel) XXX_Size() int
- func (m *Response_GetLoggingLevel) XXX_Unmarshal(b []byte) error
- type Response_GetMaintenanceSchedule
- func (*Response_GetMaintenanceSchedule) Descriptor() ([]byte, []int)
- func (m *Response_GetMaintenanceSchedule) GetSchedule() *maintenance.Schedule
- func (*Response_GetMaintenanceSchedule) ProtoMessage()
- func (m *Response_GetMaintenanceSchedule) Reset()
- func (m *Response_GetMaintenanceSchedule) String() string
- func (m *Response_GetMaintenanceSchedule) XXX_DiscardUnknown()
- func (m *Response_GetMaintenanceSchedule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_GetMaintenanceSchedule) XXX_Merge(src proto.Message)
- func (m *Response_GetMaintenanceSchedule) XXX_Size() int
- func (m *Response_GetMaintenanceSchedule) XXX_Unmarshal(b []byte) error
- type Response_GetMaintenanceStatus
- func (*Response_GetMaintenanceStatus) Descriptor() ([]byte, []int)
- func (m *Response_GetMaintenanceStatus) GetStatus() *maintenance.ClusterStatus
- func (*Response_GetMaintenanceStatus) ProtoMessage()
- func (m *Response_GetMaintenanceStatus) Reset()
- func (m *Response_GetMaintenanceStatus) String() string
- func (m *Response_GetMaintenanceStatus) XXX_DiscardUnknown()
- func (m *Response_GetMaintenanceStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_GetMaintenanceStatus) XXX_Merge(src proto.Message)
- func (m *Response_GetMaintenanceStatus) XXX_Size() int
- func (m *Response_GetMaintenanceStatus) XXX_Unmarshal(b []byte) error
- type Response_GetMaster
- func (*Response_GetMaster) Descriptor() ([]byte, []int)
- func (m *Response_GetMaster) GetElectedTime() float64
- func (m *Response_GetMaster) GetMasterInfo() *v1.MasterInfo
- func (m *Response_GetMaster) GetStartTime() float64
- func (*Response_GetMaster) ProtoMessage()
- func (m *Response_GetMaster) Reset()
- func (m *Response_GetMaster) String() string
- func (m *Response_GetMaster) XXX_DiscardUnknown()
- func (m *Response_GetMaster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_GetMaster) XXX_Merge(src proto.Message)
- func (m *Response_GetMaster) XXX_Size() int
- func (m *Response_GetMaster) XXX_Unmarshal(b []byte) error
- type Response_GetMetrics
- func (*Response_GetMetrics) Descriptor() ([]byte, []int)
- func (m *Response_GetMetrics) GetMetrics() []*v1.Metric
- func (*Response_GetMetrics) ProtoMessage()
- func (m *Response_GetMetrics) Reset()
- func (m *Response_GetMetrics) String() string
- func (m *Response_GetMetrics) XXX_DiscardUnknown()
- func (m *Response_GetMetrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_GetMetrics) XXX_Merge(src proto.Message)
- func (m *Response_GetMetrics) XXX_Size() int
- func (m *Response_GetMetrics) XXX_Unmarshal(b []byte) error
- type Response_GetOperations
- func (*Response_GetOperations) Descriptor() ([]byte, []int)
- func (m *Response_GetOperations) GetOperations() []*v1.Operation
- func (*Response_GetOperations) ProtoMessage()
- func (m *Response_GetOperations) Reset()
- func (m *Response_GetOperations) String() string
- func (m *Response_GetOperations) XXX_DiscardUnknown()
- func (m *Response_GetOperations) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_GetOperations) XXX_Merge(src proto.Message)
- func (m *Response_GetOperations) XXX_Size() int
- func (m *Response_GetOperations) XXX_Unmarshal(b []byte) error
- type Response_GetQuota
- func (*Response_GetQuota) Descriptor() ([]byte, []int)
- func (m *Response_GetQuota) GetStatus() *quota.QuotaStatus
- func (*Response_GetQuota) ProtoMessage()
- func (m *Response_GetQuota) Reset()
- func (m *Response_GetQuota) String() string
- func (m *Response_GetQuota) XXX_DiscardUnknown()
- func (m *Response_GetQuota) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_GetQuota) XXX_Merge(src proto.Message)
- func (m *Response_GetQuota) XXX_Size() int
- func (m *Response_GetQuota) XXX_Unmarshal(b []byte) error
- type Response_GetRoles
- func (*Response_GetRoles) Descriptor() ([]byte, []int)
- func (m *Response_GetRoles) GetRoles() []*v1.Role
- func (*Response_GetRoles) ProtoMessage()
- func (m *Response_GetRoles) Reset()
- func (m *Response_GetRoles) String() string
- func (m *Response_GetRoles) XXX_DiscardUnknown()
- func (m *Response_GetRoles) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_GetRoles) XXX_Merge(src proto.Message)
- func (m *Response_GetRoles) XXX_Size() int
- func (m *Response_GetRoles) XXX_Unmarshal(b []byte) error
- type Response_GetState
- func (*Response_GetState) Descriptor() ([]byte, []int)
- func (m *Response_GetState) GetGetAgents() *Response_GetAgents
- func (m *Response_GetState) GetGetExecutors() *Response_GetExecutors
- func (m *Response_GetState) GetGetFrameworks() *Response_GetFrameworks
- func (m *Response_GetState) GetGetTasks() *Response_GetTasks
- func (*Response_GetState) ProtoMessage()
- func (m *Response_GetState) Reset()
- func (m *Response_GetState) String() string
- func (m *Response_GetState) XXX_DiscardUnknown()
- func (m *Response_GetState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_GetState) XXX_Merge(src proto.Message)
- func (m *Response_GetState) XXX_Size() int
- func (m *Response_GetState) XXX_Unmarshal(b []byte) error
- type Response_GetTasks
- func (*Response_GetTasks) Descriptor() ([]byte, []int)
- func (m *Response_GetTasks) GetCompletedTasks() []*v1.Task
- func (m *Response_GetTasks) GetOrphanTasks() []*v1.Taskdeprecated
- func (m *Response_GetTasks) GetPendingTasks() []*v1.Task
- func (m *Response_GetTasks) GetTasks() []*v1.Task
- func (m *Response_GetTasks) GetUnreachableTasks() []*v1.Task
- func (*Response_GetTasks) ProtoMessage()
- func (m *Response_GetTasks) Reset()
- func (m *Response_GetTasks) String() string
- func (m *Response_GetTasks) XXX_DiscardUnknown()
- func (m *Response_GetTasks) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_GetTasks) XXX_Merge(src proto.Message)
- func (m *Response_GetTasks) XXX_Size() int
- func (m *Response_GetTasks) XXX_Unmarshal(b []byte) error
- type Response_GetVersion
- func (*Response_GetVersion) Descriptor() ([]byte, []int)
- func (m *Response_GetVersion) GetVersionInfo() *v1.VersionInfo
- func (*Response_GetVersion) ProtoMessage()
- func (m *Response_GetVersion) Reset()
- func (m *Response_GetVersion) String() string
- func (m *Response_GetVersion) XXX_DiscardUnknown()
- func (m *Response_GetVersion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_GetVersion) XXX_Merge(src proto.Message)
- func (m *Response_GetVersion) XXX_Size() int
- func (m *Response_GetVersion) XXX_Unmarshal(b []byte) error
- type Response_GetWeights
- func (*Response_GetWeights) Descriptor() ([]byte, []int)
- func (m *Response_GetWeights) GetWeightInfos() []*v1.WeightInfo
- func (*Response_GetWeights) ProtoMessage()
- func (m *Response_GetWeights) Reset()
- func (m *Response_GetWeights) String() string
- func (m *Response_GetWeights) XXX_DiscardUnknown()
- func (m *Response_GetWeights) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_GetWeights) XXX_Merge(src proto.Message)
- func (m *Response_GetWeights) XXX_Size() int
- func (m *Response_GetWeights) XXX_Unmarshal(b []byte) error
- type Response_ListFiles
- func (*Response_ListFiles) Descriptor() ([]byte, []int)
- func (m *Response_ListFiles) GetFileInfos() []*v1.FileInfo
- func (*Response_ListFiles) ProtoMessage()
- func (m *Response_ListFiles) Reset()
- func (m *Response_ListFiles) String() string
- func (m *Response_ListFiles) XXX_DiscardUnknown()
- func (m *Response_ListFiles) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_ListFiles) XXX_Merge(src proto.Message)
- func (m *Response_ListFiles) XXX_Size() int
- func (m *Response_ListFiles) XXX_Unmarshal(b []byte) error
- type Response_ReadFile
- func (*Response_ReadFile) Descriptor() ([]byte, []int)
- func (m *Response_ReadFile) GetData() []byte
- func (m *Response_ReadFile) GetSize() uint64
- func (*Response_ReadFile) ProtoMessage()
- func (m *Response_ReadFile) Reset()
- func (m *Response_ReadFile) String() string
- func (m *Response_ReadFile) XXX_DiscardUnknown()
- func (m *Response_ReadFile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response_ReadFile) XXX_Merge(src proto.Message)
- func (m *Response_ReadFile) XXX_Size() int
- func (m *Response_ReadFile) XXX_Unmarshal(b []byte) error
- type Response_Type
Constants ¶
const Default_Call_DrainAgent_MarkGone bool = false
Variables ¶
var Call_Type_name = map[int32]string{
0: "UNKNOWN",
1: "GET_HEALTH",
2: "GET_FLAGS",
3: "GET_VERSION",
4: "GET_METRICS",
5: "GET_LOGGING_LEVEL",
6: "SET_LOGGING_LEVEL",
7: "LIST_FILES",
8: "READ_FILE",
9: "GET_STATE",
10: "GET_AGENTS",
11: "GET_FRAMEWORKS",
12: "GET_EXECUTORS",
33: "GET_OPERATIONS",
13: "GET_TASKS",
14: "GET_ROLES",
15: "GET_WEIGHTS",
16: "UPDATE_WEIGHTS",
17: "GET_MASTER",
18: "SUBSCRIBE",
19: "RESERVE_RESOURCES",
20: "UNRESERVE_RESOURCES",
21: "CREATE_VOLUMES",
22: "DESTROY_VOLUMES",
34: "GROW_VOLUME",
35: "SHRINK_VOLUME",
23: "GET_MAINTENANCE_STATUS",
24: "GET_MAINTENANCE_SCHEDULE",
25: "UPDATE_MAINTENANCE_SCHEDULE",
26: "START_MAINTENANCE",
27: "STOP_MAINTENANCE",
37: "DRAIN_AGENT",
38: "DEACTIVATE_AGENT",
39: "REACTIVATE_AGENT",
28: "GET_QUOTA",
36: "UPDATE_QUOTA",
29: "SET_QUOTA",
30: "REMOVE_QUOTA",
31: "TEARDOWN",
32: "MARK_AGENT_GONE",
}
var Call_Type_value = map[string]int32{
"UNKNOWN": 0,
"GET_HEALTH": 1,
"GET_FLAGS": 2,
"GET_VERSION": 3,
"GET_METRICS": 4,
"GET_LOGGING_LEVEL": 5,
"SET_LOGGING_LEVEL": 6,
"LIST_FILES": 7,
"READ_FILE": 8,
"GET_STATE": 9,
"GET_AGENTS": 10,
"GET_FRAMEWORKS": 11,
"GET_EXECUTORS": 12,
"GET_OPERATIONS": 33,
"GET_TASKS": 13,
"GET_ROLES": 14,
"GET_WEIGHTS": 15,
"UPDATE_WEIGHTS": 16,
"GET_MASTER": 17,
"SUBSCRIBE": 18,
"RESERVE_RESOURCES": 19,
"UNRESERVE_RESOURCES": 20,
"CREATE_VOLUMES": 21,
"DESTROY_VOLUMES": 22,
"GROW_VOLUME": 34,
"SHRINK_VOLUME": 35,
"GET_MAINTENANCE_STATUS": 23,
"GET_MAINTENANCE_SCHEDULE": 24,
"UPDATE_MAINTENANCE_SCHEDULE": 25,
"START_MAINTENANCE": 26,
"STOP_MAINTENANCE": 27,
"DRAIN_AGENT": 37,
"DEACTIVATE_AGENT": 38,
"REACTIVATE_AGENT": 39,
"GET_QUOTA": 28,
"UPDATE_QUOTA": 36,
"SET_QUOTA": 29,
"REMOVE_QUOTA": 30,
"TEARDOWN": 31,
"MARK_AGENT_GONE": 32,
}
var Event_Type_name = map[int32]string{
0: "UNKNOWN",
1: "SUBSCRIBED",
2: "TASK_ADDED",
3: "TASK_UPDATED",
4: "AGENT_ADDED",
5: "AGENT_REMOVED",
6: "FRAMEWORK_ADDED",
7: "FRAMEWORK_UPDATED",
8: "FRAMEWORK_REMOVED",
9: "HEARTBEAT",
}
var Event_Type_value = map[string]int32{
"UNKNOWN": 0,
"SUBSCRIBED": 1,
"TASK_ADDED": 2,
"TASK_UPDATED": 3,
"AGENT_ADDED": 4,
"AGENT_REMOVED": 5,
"FRAMEWORK_ADDED": 6,
"FRAMEWORK_UPDATED": 7,
"FRAMEWORK_REMOVED": 8,
"HEARTBEAT": 9,
}
var Response_Type_name = map[int32]string{
0: "UNKNOWN",
1: "GET_HEALTH",
2: "GET_FLAGS",
3: "GET_VERSION",
4: "GET_METRICS",
5: "GET_LOGGING_LEVEL",
6: "LIST_FILES",
7: "READ_FILE",
8: "GET_STATE",
9: "GET_AGENTS",
10: "GET_FRAMEWORKS",
11: "GET_EXECUTORS",
19: "GET_OPERATIONS",
12: "GET_TASKS",
13: "GET_ROLES",
14: "GET_WEIGHTS",
15: "GET_MASTER",
16: "GET_MAINTENANCE_STATUS",
17: "GET_MAINTENANCE_SCHEDULE",
18: "GET_QUOTA",
}
var Response_Type_value = map[string]int32{
"UNKNOWN": 0,
"GET_HEALTH": 1,
"GET_FLAGS": 2,
"GET_VERSION": 3,
"GET_METRICS": 4,
"GET_LOGGING_LEVEL": 5,
"LIST_FILES": 6,
"READ_FILE": 7,
"GET_STATE": 8,
"GET_AGENTS": 9,
"GET_FRAMEWORKS": 10,
"GET_EXECUTORS": 11,
"GET_OPERATIONS": 19,
"GET_TASKS": 12,
"GET_ROLES": 13,
"GET_WEIGHTS": 14,
"GET_MASTER": 15,
"GET_MAINTENANCE_STATUS": 16,
"GET_MAINTENANCE_SCHEDULE": 17,
"GET_QUOTA": 18,
}
Functions ¶
This section is empty.
Types ¶
type Call ¶
type Call struct { Type *Call_Type `protobuf:"varint,1,opt,name=type,enum=mesos.v1.master.Call_Type" json:"type,omitempty"` GetMetrics *Call_GetMetrics `protobuf:"bytes,2,opt,name=get_metrics,json=get_metrics" json:"get_metrics,omitempty"` SetLoggingLevel *Call_SetLoggingLevel `protobuf:"bytes,3,opt,name=set_logging_level,json=set_logging_level" json:"set_logging_level,omitempty"` ListFiles *Call_ListFiles `protobuf:"bytes,4,opt,name=list_files,json=list_files" json:"list_files,omitempty"` ReadFile *Call_ReadFile `protobuf:"bytes,5,opt,name=read_file,json=read_file" json:"read_file,omitempty"` UpdateWeights *Call_UpdateWeights `protobuf:"bytes,6,opt,name=update_weights,json=update_weights" json:"update_weights,omitempty"` ReserveResources *Call_ReserveResources `protobuf:"bytes,7,opt,name=reserve_resources,json=reserve_resources" json:"reserve_resources,omitempty"` UnreserveResources *Call_UnreserveResources `protobuf:"bytes,8,opt,name=unreserve_resources,json=unreserve_resources" json:"unreserve_resources,omitempty"` CreateVolumes *Call_CreateVolumes `protobuf:"bytes,9,opt,name=create_volumes,json=create_volumes" json:"create_volumes,omitempty"` DestroyVolumes *Call_DestroyVolumes `protobuf:"bytes,10,opt,name=destroy_volumes,json=destroy_volumes" json:"destroy_volumes,omitempty"` GrowVolume *Call_GrowVolume `protobuf:"bytes,18,opt,name=grow_volume,json=grow_volume" json:"grow_volume,omitempty"` ShrinkVolume *Call_ShrinkVolume `protobuf:"bytes,19,opt,name=shrink_volume,json=shrink_volume" json:"shrink_volume,omitempty"` UpdateMaintenanceSchedule *Call_UpdateMaintenanceSchedule `` /* 134-byte string literal not displayed */ StartMaintenance *Call_StartMaintenance `protobuf:"bytes,12,opt,name=start_maintenance,json=start_maintenance" json:"start_maintenance,omitempty"` StopMaintenance *Call_StopMaintenance `protobuf:"bytes,13,opt,name=stop_maintenance,json=stop_maintenance" json:"stop_maintenance,omitempty"` DrainAgent *Call_DrainAgent `protobuf:"bytes,21,opt,name=drain_agent,json=drain_agent" json:"drain_agent,omitempty"` DeactivateAgent *Call_DeactivateAgent `protobuf:"bytes,22,opt,name=deactivate_agent,json=deactivate_agent" json:"deactivate_agent,omitempty"` ReactivateAgent *Call_ReactivateAgent `protobuf:"bytes,23,opt,name=reactivate_agent,json=reactivate_agent" json:"reactivate_agent,omitempty"` UpdateQuota *Call_UpdateQuota `protobuf:"bytes,20,opt,name=update_quota,json=update_quota" json:"update_quota,omitempty"` Teardown *Call_Teardown `protobuf:"bytes,16,opt,name=teardown" json:"teardown,omitempty"` MarkAgentGone *Call_MarkAgentGone `protobuf:"bytes,17,opt,name=mark_agent_gone,json=mark_agent_gone" json:"mark_agent_gone,omitempty"` SetQuota *Call_SetQuota `protobuf:"bytes,14,opt,name=set_quota,json=set_quota" json:"set_quota,omitempty"` // Deprecated: Do not use. RemoveQuota *Call_RemoveQuota `protobuf:"bytes,15,opt,name=remove_quota,json=remove_quota" json:"remove_quota,omitempty"` // Deprecated: Do not use. XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Calls that can be sent to the v1 master API.
A call is described using the standard protocol buffer "union" trick, see https://developers.google.com/protocol-buffers/docs/techniques#union.
func (*Call) Descriptor ¶
func (*Call) GetCreateVolumes ¶
func (m *Call) GetCreateVolumes() *Call_CreateVolumes
func (*Call) GetDeactivateAgent ¶ added in v1.9.0
func (m *Call) GetDeactivateAgent() *Call_DeactivateAgent
func (*Call) GetDestroyVolumes ¶
func (m *Call) GetDestroyVolumes() *Call_DestroyVolumes
func (*Call) GetDrainAgent ¶ added in v1.9.0
func (m *Call) GetDrainAgent() *Call_DrainAgent
func (*Call) GetGetMetrics ¶
func (m *Call) GetGetMetrics() *Call_GetMetrics
func (*Call) GetGrowVolume ¶
func (m *Call) GetGrowVolume() *Call_GrowVolume
func (*Call) GetListFiles ¶
func (m *Call) GetListFiles() *Call_ListFiles
func (*Call) GetMarkAgentGone ¶
func (m *Call) GetMarkAgentGone() *Call_MarkAgentGone
func (*Call) GetReactivateAgent ¶ added in v1.9.0
func (m *Call) GetReactivateAgent() *Call_ReactivateAgent
func (*Call) GetReadFile ¶
func (m *Call) GetReadFile() *Call_ReadFile
func (*Call) GetRemoveQuota
deprecated
func (m *Call) GetRemoveQuota() *Call_RemoveQuota
Deprecated: Do not use.
func (*Call) GetReserveResources ¶
func (m *Call) GetReserveResources() *Call_ReserveResources
func (*Call) GetSetLoggingLevel ¶
func (m *Call) GetSetLoggingLevel() *Call_SetLoggingLevel
func (*Call) GetSetQuota
deprecated
func (m *Call) GetSetQuota() *Call_SetQuota
Deprecated: Do not use.
func (*Call) GetShrinkVolume ¶
func (m *Call) GetShrinkVolume() *Call_ShrinkVolume
func (*Call) GetStartMaintenance ¶
func (m *Call) GetStartMaintenance() *Call_StartMaintenance
func (*Call) GetStopMaintenance ¶
func (m *Call) GetStopMaintenance() *Call_StopMaintenance
func (*Call) GetTeardown ¶
func (m *Call) GetTeardown() *Call_Teardown
func (*Call) GetUnreserveResources ¶
func (m *Call) GetUnreserveResources() *Call_UnreserveResources
func (*Call) GetUpdateMaintenanceSchedule ¶
func (m *Call) GetUpdateMaintenanceSchedule() *Call_UpdateMaintenanceSchedule
func (*Call) GetUpdateQuota ¶ added in v1.8.0
func (m *Call) GetUpdateQuota() *Call_UpdateQuota
func (*Call) GetUpdateWeights ¶
func (m *Call) GetUpdateWeights() *Call_UpdateWeights
func (*Call) ProtoMessage ¶
func (*Call) ProtoMessage()
func (*Call) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call) XXX_DiscardUnknown()
func (*Call) XXX_Marshal ¶ added in v1.9.0
func (*Call) XXX_Unmarshal ¶ added in v1.9.0
type Call_CreateVolumes ¶
type Call_CreateVolumes struct { AgentId *v1.AgentID `protobuf:"bytes,1,req,name=agent_id,json=agent_id" json:"agent_id,omitempty"` Volumes []*v1.Resource `protobuf:"bytes,2,rep,name=volumes" json:"volumes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Create persistent volumes on reserved resources. The request is forwarded asynchronously to the Mesos agent where the reserved resources are located. That asynchronous message may not be delivered or creating the volumes at the agent might fail. Volume creation can be verified by sending a `GET_VOLUMES` call.
func (*Call_CreateVolumes) Descriptor ¶
func (*Call_CreateVolumes) Descriptor() ([]byte, []int)
func (*Call_CreateVolumes) GetAgentId ¶
func (m *Call_CreateVolumes) GetAgentId() *v1.AgentID
func (*Call_CreateVolumes) GetVolumes ¶
func (m *Call_CreateVolumes) GetVolumes() []*v1.Resource
func (*Call_CreateVolumes) ProtoMessage ¶
func (*Call_CreateVolumes) ProtoMessage()
func (*Call_CreateVolumes) Reset ¶
func (m *Call_CreateVolumes) Reset()
func (*Call_CreateVolumes) String ¶
func (m *Call_CreateVolumes) String() string
func (*Call_CreateVolumes) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call_CreateVolumes) XXX_DiscardUnknown()
func (*Call_CreateVolumes) XXX_Marshal ¶ added in v1.9.0
func (m *Call_CreateVolumes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Call_CreateVolumes) XXX_Merge ¶ added in v1.9.0
func (m *Call_CreateVolumes) XXX_Merge(src proto.Message)
func (*Call_CreateVolumes) XXX_Size ¶ added in v1.9.0
func (m *Call_CreateVolumes) XXX_Size() int
func (*Call_CreateVolumes) XXX_Unmarshal ¶ added in v1.9.0
func (m *Call_CreateVolumes) XXX_Unmarshal(b []byte) error
type Call_DeactivateAgent ¶ added in v1.9.0
type Call_DeactivateAgent struct { AgentId *v1.AgentID `protobuf:"bytes,1,req,name=agent_id,json=agent_id" json:"agent_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
EXPERIMENTAL.
Turns off offers for a specific agent. A deactivated agent will continue to run tasks and communicate statuses with the master.
func (*Call_DeactivateAgent) Descriptor ¶ added in v1.9.0
func (*Call_DeactivateAgent) Descriptor() ([]byte, []int)
func (*Call_DeactivateAgent) GetAgentId ¶ added in v1.9.0
func (m *Call_DeactivateAgent) GetAgentId() *v1.AgentID
func (*Call_DeactivateAgent) ProtoMessage ¶ added in v1.9.0
func (*Call_DeactivateAgent) ProtoMessage()
func (*Call_DeactivateAgent) Reset ¶ added in v1.9.0
func (m *Call_DeactivateAgent) Reset()
func (*Call_DeactivateAgent) String ¶ added in v1.9.0
func (m *Call_DeactivateAgent) String() string
func (*Call_DeactivateAgent) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call_DeactivateAgent) XXX_DiscardUnknown()
func (*Call_DeactivateAgent) XXX_Marshal ¶ added in v1.9.0
func (m *Call_DeactivateAgent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Call_DeactivateAgent) XXX_Merge ¶ added in v1.9.0
func (m *Call_DeactivateAgent) XXX_Merge(src proto.Message)
func (*Call_DeactivateAgent) XXX_Size ¶ added in v1.9.0
func (m *Call_DeactivateAgent) XXX_Size() int
func (*Call_DeactivateAgent) XXX_Unmarshal ¶ added in v1.9.0
func (m *Call_DeactivateAgent) XXX_Unmarshal(b []byte) error
type Call_DestroyVolumes ¶
type Call_DestroyVolumes struct { AgentId *v1.AgentID `protobuf:"bytes,1,req,name=agent_id,json=agent_id" json:"agent_id,omitempty"` Volumes []*v1.Resource `protobuf:"bytes,2,rep,name=volumes" json:"volumes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Destroy persistent volumes. The request is forwarded asynchronously to the Mesos agent where the reserved resources are located. That asynchronous message may not be delivered or destroying the volumes at the agent might fail. Volume deletion can be verified by sending a `GET_VOLUMES` call.
func (*Call_DestroyVolumes) Descriptor ¶
func (*Call_DestroyVolumes) Descriptor() ([]byte, []int)
func (*Call_DestroyVolumes) GetAgentId ¶
func (m *Call_DestroyVolumes) GetAgentId() *v1.AgentID
func (*Call_DestroyVolumes) GetVolumes ¶
func (m *Call_DestroyVolumes) GetVolumes() []*v1.Resource
func (*Call_DestroyVolumes) ProtoMessage ¶
func (*Call_DestroyVolumes) ProtoMessage()
func (*Call_DestroyVolumes) Reset ¶
func (m *Call_DestroyVolumes) Reset()
func (*Call_DestroyVolumes) String ¶
func (m *Call_DestroyVolumes) String() string
func (*Call_DestroyVolumes) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call_DestroyVolumes) XXX_DiscardUnknown()
func (*Call_DestroyVolumes) XXX_Marshal ¶ added in v1.9.0
func (m *Call_DestroyVolumes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Call_DestroyVolumes) XXX_Merge ¶ added in v1.9.0
func (m *Call_DestroyVolumes) XXX_Merge(src proto.Message)
func (*Call_DestroyVolumes) XXX_Size ¶ added in v1.9.0
func (m *Call_DestroyVolumes) XXX_Size() int
func (*Call_DestroyVolumes) XXX_Unmarshal ¶ added in v1.9.0
func (m *Call_DestroyVolumes) XXX_Unmarshal(b []byte) error
type Call_DrainAgent ¶ added in v1.9.0
type Call_DrainAgent struct { AgentId *v1.AgentID `protobuf:"bytes,1,req,name=agent_id,json=agent_id" json:"agent_id,omitempty"` // An upper bound for tasks with a KillPolicy. // If a task has a KillPolicy grace period greater than this value, // this value will be used instead. This allows the operator to limit // the maximum time it will take the agent to drain. // // NOTE: Grace periods start when the executor receives the associated kill. // If, for example, the agent is unreachable when this call is made, // tasks will still receive their full grace period to kill gracefully. MaxGracePeriod *duration.Duration `protobuf:"bytes,2,opt,name=max_grace_period,json=max_grace_period" json:"max_grace_period,omitempty"` // Whether or not this agent will be removed permanently from the // cluster when draining is complete. This transition is automatic // and does **NOT** require a separate call to `MarkAgentGone`. // // Compared to `MarkAgentGone`, which is used for unreachable agents, // marking agents gone after draining will respect kill policies. // To notify frameworks, tasks terminated during draining will return // a `TASK_GONE_BY_OPERATOR` status update instead of any other terminal // status. Executors will not need to account for this case, because // the terminal status update will be intercepted and modified by the agent. MarkGone *bool `protobuf:"varint,3,opt,name=mark_gone,json=mark_gone,def=0" json:"mark_gone,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
EXPERIMENTAL.
Marks an agent for automated draining of tasks. This prevents further tasks from being launched on the agent, by preventing offers from being sent for the agent (see 'DeactivateAgent'), and also begins killing tasks running on the agent.
func (*Call_DrainAgent) Descriptor ¶ added in v1.9.0
func (*Call_DrainAgent) Descriptor() ([]byte, []int)
func (*Call_DrainAgent) GetAgentId ¶ added in v1.9.0
func (m *Call_DrainAgent) GetAgentId() *v1.AgentID
func (*Call_DrainAgent) GetMarkGone ¶ added in v1.9.0
func (m *Call_DrainAgent) GetMarkGone() bool
func (*Call_DrainAgent) GetMaxGracePeriod ¶ added in v1.9.0
func (m *Call_DrainAgent) GetMaxGracePeriod() *duration.Duration
func (*Call_DrainAgent) ProtoMessage ¶ added in v1.9.0
func (*Call_DrainAgent) ProtoMessage()
func (*Call_DrainAgent) Reset ¶ added in v1.9.0
func (m *Call_DrainAgent) Reset()
func (*Call_DrainAgent) String ¶ added in v1.9.0
func (m *Call_DrainAgent) String() string
func (*Call_DrainAgent) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call_DrainAgent) XXX_DiscardUnknown()
func (*Call_DrainAgent) XXX_Marshal ¶ added in v1.9.0
func (m *Call_DrainAgent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Call_DrainAgent) XXX_Merge ¶ added in v1.9.0
func (m *Call_DrainAgent) XXX_Merge(src proto.Message)
func (*Call_DrainAgent) XXX_Size ¶ added in v1.9.0
func (m *Call_DrainAgent) XXX_Size() int
func (*Call_DrainAgent) XXX_Unmarshal ¶ added in v1.9.0
func (m *Call_DrainAgent) XXX_Unmarshal(b []byte) error
type Call_GetMetrics ¶
type Call_GetMetrics struct { // If set, `timeout` would be used to determines the maximum amount of time // the API will take to respond. If the timeout is exceeded, some metrics // may not be included in the response. Timeout *v1.DurationInfo `protobuf:"bytes,1,opt,name=timeout" json:"timeout,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Provides a snapshot of the current metrics tracked by the master.
func (*Call_GetMetrics) Descriptor ¶
func (*Call_GetMetrics) Descriptor() ([]byte, []int)
func (*Call_GetMetrics) GetTimeout ¶
func (m *Call_GetMetrics) GetTimeout() *v1.DurationInfo
func (*Call_GetMetrics) ProtoMessage ¶
func (*Call_GetMetrics) ProtoMessage()
func (*Call_GetMetrics) Reset ¶
func (m *Call_GetMetrics) Reset()
func (*Call_GetMetrics) String ¶
func (m *Call_GetMetrics) String() string
func (*Call_GetMetrics) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call_GetMetrics) XXX_DiscardUnknown()
func (*Call_GetMetrics) XXX_Marshal ¶ added in v1.9.0
func (m *Call_GetMetrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Call_GetMetrics) XXX_Merge ¶ added in v1.9.0
func (m *Call_GetMetrics) XXX_Merge(src proto.Message)
func (*Call_GetMetrics) XXX_Size ¶ added in v1.9.0
func (m *Call_GetMetrics) XXX_Size() int
func (*Call_GetMetrics) XXX_Unmarshal ¶ added in v1.9.0
func (m *Call_GetMetrics) XXX_Unmarshal(b []byte) error
type Call_GrowVolume ¶
type Call_GrowVolume struct { // `agent_id` must be set if `volume` is an agent-local resource, and must // be unset if `volume` is an external resource. AgentId *v1.AgentID `protobuf:"bytes,1,opt,name=agent_id,json=agent_id" json:"agent_id,omitempty"` Volume *v1.Resource `protobuf:"bytes,2,req,name=volume" json:"volume,omitempty"` Addition *v1.Resource `protobuf:"bytes,3,req,name=addition" json:"addition,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Grow a volume by an additional disk resource. NOTE: This is currently experimental and only for persistent volumes created on ROOT/PATH disks.
func (*Call_GrowVolume) Descriptor ¶
func (*Call_GrowVolume) Descriptor() ([]byte, []int)
func (*Call_GrowVolume) GetAddition ¶
func (m *Call_GrowVolume) GetAddition() *v1.Resource
func (*Call_GrowVolume) GetAgentId ¶
func (m *Call_GrowVolume) GetAgentId() *v1.AgentID
func (*Call_GrowVolume) GetVolume ¶
func (m *Call_GrowVolume) GetVolume() *v1.Resource
func (*Call_GrowVolume) ProtoMessage ¶
func (*Call_GrowVolume) ProtoMessage()
func (*Call_GrowVolume) Reset ¶
func (m *Call_GrowVolume) Reset()
func (*Call_GrowVolume) String ¶
func (m *Call_GrowVolume) String() string
func (*Call_GrowVolume) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call_GrowVolume) XXX_DiscardUnknown()
func (*Call_GrowVolume) XXX_Marshal ¶ added in v1.9.0
func (m *Call_GrowVolume) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Call_GrowVolume) XXX_Merge ¶ added in v1.9.0
func (m *Call_GrowVolume) XXX_Merge(src proto.Message)
func (*Call_GrowVolume) XXX_Size ¶ added in v1.9.0
func (m *Call_GrowVolume) XXX_Size() int
func (*Call_GrowVolume) XXX_Unmarshal ¶ added in v1.9.0
func (m *Call_GrowVolume) XXX_Unmarshal(b []byte) error
type Call_ListFiles ¶
type Call_ListFiles struct { Path *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Provides the file listing for a directory.
func (*Call_ListFiles) Descriptor ¶
func (*Call_ListFiles) Descriptor() ([]byte, []int)
func (*Call_ListFiles) GetPath ¶
func (m *Call_ListFiles) GetPath() string
func (*Call_ListFiles) ProtoMessage ¶
func (*Call_ListFiles) ProtoMessage()
func (*Call_ListFiles) Reset ¶
func (m *Call_ListFiles) Reset()
func (*Call_ListFiles) String ¶
func (m *Call_ListFiles) String() string
func (*Call_ListFiles) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call_ListFiles) XXX_DiscardUnknown()
func (*Call_ListFiles) XXX_Marshal ¶ added in v1.9.0
func (m *Call_ListFiles) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Call_ListFiles) XXX_Merge ¶ added in v1.9.0
func (m *Call_ListFiles) XXX_Merge(src proto.Message)
func (*Call_ListFiles) XXX_Size ¶ added in v1.9.0
func (m *Call_ListFiles) XXX_Size() int
func (*Call_ListFiles) XXX_Unmarshal ¶ added in v1.9.0
func (m *Call_ListFiles) XXX_Unmarshal(b []byte) error
type Call_MarkAgentGone ¶
type Call_MarkAgentGone struct { AgentId *v1.AgentID `protobuf:"bytes,1,req,name=agent_id,json=agent_id" json:"agent_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Mark an agent as gone. This can be used by an operator to assert that the agent instance has failed and is never coming back (e.g., ephemeral instance from cloud provider). The master would shutdown the agent and send 'TASK_GONE_BY_OPERATOR' updates for all the running tasks. The persistent volumes/reservations on the agent won't be accessible anymore.
NOTE: It is possible that the tasks might still be running if the operator's assertion was wrong and the agent was partitioned away from the master. The agent would be shutdown when it tries to reregister with the master when the partition heals.
func (*Call_MarkAgentGone) Descriptor ¶
func (*Call_MarkAgentGone) Descriptor() ([]byte, []int)
func (*Call_MarkAgentGone) GetAgentId ¶
func (m *Call_MarkAgentGone) GetAgentId() *v1.AgentID
func (*Call_MarkAgentGone) ProtoMessage ¶
func (*Call_MarkAgentGone) ProtoMessage()
func (*Call_MarkAgentGone) Reset ¶
func (m *Call_MarkAgentGone) Reset()
func (*Call_MarkAgentGone) String ¶
func (m *Call_MarkAgentGone) String() string
func (*Call_MarkAgentGone) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call_MarkAgentGone) XXX_DiscardUnknown()
func (*Call_MarkAgentGone) XXX_Marshal ¶ added in v1.9.0
func (m *Call_MarkAgentGone) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Call_MarkAgentGone) XXX_Merge ¶ added in v1.9.0
func (m *Call_MarkAgentGone) XXX_Merge(src proto.Message)
func (*Call_MarkAgentGone) XXX_Size ¶ added in v1.9.0
func (m *Call_MarkAgentGone) XXX_Size() int
func (*Call_MarkAgentGone) XXX_Unmarshal ¶ added in v1.9.0
func (m *Call_MarkAgentGone) XXX_Unmarshal(b []byte) error
type Call_ReactivateAgent ¶ added in v1.9.0
type Call_ReactivateAgent struct { AgentId *v1.AgentID `protobuf:"bytes,1,req,name=agent_id,json=agent_id" json:"agent_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
EXPERIMENTAL.
Turns on offers for a specific agent, which was previously drained or deactivated.
func (*Call_ReactivateAgent) Descriptor ¶ added in v1.9.0
func (*Call_ReactivateAgent) Descriptor() ([]byte, []int)
func (*Call_ReactivateAgent) GetAgentId ¶ added in v1.9.0
func (m *Call_ReactivateAgent) GetAgentId() *v1.AgentID
func (*Call_ReactivateAgent) ProtoMessage ¶ added in v1.9.0
func (*Call_ReactivateAgent) ProtoMessage()
func (*Call_ReactivateAgent) Reset ¶ added in v1.9.0
func (m *Call_ReactivateAgent) Reset()
func (*Call_ReactivateAgent) String ¶ added in v1.9.0
func (m *Call_ReactivateAgent) String() string
func (*Call_ReactivateAgent) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call_ReactivateAgent) XXX_DiscardUnknown()
func (*Call_ReactivateAgent) XXX_Marshal ¶ added in v1.9.0
func (m *Call_ReactivateAgent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Call_ReactivateAgent) XXX_Merge ¶ added in v1.9.0
func (m *Call_ReactivateAgent) XXX_Merge(src proto.Message)
func (*Call_ReactivateAgent) XXX_Size ¶ added in v1.9.0
func (m *Call_ReactivateAgent) XXX_Size() int
func (*Call_ReactivateAgent) XXX_Unmarshal ¶ added in v1.9.0
func (m *Call_ReactivateAgent) XXX_Unmarshal(b []byte) error
type Call_ReadFile ¶
type Call_ReadFile struct { // The path of file. Path *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"` // Initial offset in file to start reading from. Offset *uint64 `protobuf:"varint,2,req,name=offset" json:"offset,omitempty"` // The maximum number of bytes to read. The read length is capped at 16 // memory pages. Length *uint64 `protobuf:"varint,3,opt,name=length" json:"length,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Reads data from a file.
func (*Call_ReadFile) Descriptor ¶
func (*Call_ReadFile) Descriptor() ([]byte, []int)
func (*Call_ReadFile) GetLength ¶
func (m *Call_ReadFile) GetLength() uint64
func (*Call_ReadFile) GetOffset ¶
func (m *Call_ReadFile) GetOffset() uint64
func (*Call_ReadFile) GetPath ¶
func (m *Call_ReadFile) GetPath() string
func (*Call_ReadFile) ProtoMessage ¶
func (*Call_ReadFile) ProtoMessage()
func (*Call_ReadFile) Reset ¶
func (m *Call_ReadFile) Reset()
func (*Call_ReadFile) String ¶
func (m *Call_ReadFile) String() string
func (*Call_ReadFile) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call_ReadFile) XXX_DiscardUnknown()
func (*Call_ReadFile) XXX_Marshal ¶ added in v1.9.0
func (m *Call_ReadFile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Call_ReadFile) XXX_Merge ¶ added in v1.9.0
func (m *Call_ReadFile) XXX_Merge(src proto.Message)
func (*Call_ReadFile) XXX_Size ¶ added in v1.9.0
func (m *Call_ReadFile) XXX_Size() int
func (*Call_ReadFile) XXX_Unmarshal ¶ added in v1.9.0
func (m *Call_ReadFile) XXX_Unmarshal(b []byte) error
type Call_RemoveQuota ¶
type Call_RemoveQuota struct { Role *string `protobuf:"bytes,1,req,name=role" json:"role,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated in favor of `UpdateQuota`.
func (*Call_RemoveQuota) Descriptor ¶
func (*Call_RemoveQuota) Descriptor() ([]byte, []int)
func (*Call_RemoveQuota) GetRole ¶
func (m *Call_RemoveQuota) GetRole() string
func (*Call_RemoveQuota) ProtoMessage ¶
func (*Call_RemoveQuota) ProtoMessage()
func (*Call_RemoveQuota) Reset ¶
func (m *Call_RemoveQuota) Reset()
func (*Call_RemoveQuota) String ¶
func (m *Call_RemoveQuota) String() string
func (*Call_RemoveQuota) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call_RemoveQuota) XXX_DiscardUnknown()
func (*Call_RemoveQuota) XXX_Marshal ¶ added in v1.9.0
func (m *Call_RemoveQuota) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Call_RemoveQuota) XXX_Merge ¶ added in v1.9.0
func (m *Call_RemoveQuota) XXX_Merge(src proto.Message)
func (*Call_RemoveQuota) XXX_Size ¶ added in v1.9.0
func (m *Call_RemoveQuota) XXX_Size() int
func (*Call_RemoveQuota) XXX_Unmarshal ¶ added in v1.9.0
func (m *Call_RemoveQuota) XXX_Unmarshal(b []byte) error
type Call_ReserveResources ¶
type Call_ReserveResources struct { AgentId *v1.AgentID `protobuf:"bytes,1,req,name=agent_id,json=agent_id" json:"agent_id,omitempty"` Resources []*v1.Resource `protobuf:"bytes,2,rep,name=resources" json:"resources,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Reserve resources dynamically on a specific agent.
func (*Call_ReserveResources) Descriptor ¶
func (*Call_ReserveResources) Descriptor() ([]byte, []int)
func (*Call_ReserveResources) GetAgentId ¶
func (m *Call_ReserveResources) GetAgentId() *v1.AgentID
func (*Call_ReserveResources) GetResources ¶
func (m *Call_ReserveResources) GetResources() []*v1.Resource
func (*Call_ReserveResources) ProtoMessage ¶
func (*Call_ReserveResources) ProtoMessage()
func (*Call_ReserveResources) Reset ¶
func (m *Call_ReserveResources) Reset()
func (*Call_ReserveResources) String ¶
func (m *Call_ReserveResources) String() string
func (*Call_ReserveResources) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call_ReserveResources) XXX_DiscardUnknown()
func (*Call_ReserveResources) XXX_Marshal ¶ added in v1.9.0
func (m *Call_ReserveResources) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Call_ReserveResources) XXX_Merge ¶ added in v1.9.0
func (m *Call_ReserveResources) XXX_Merge(src proto.Message)
func (*Call_ReserveResources) XXX_Size ¶ added in v1.9.0
func (m *Call_ReserveResources) XXX_Size() int
func (*Call_ReserveResources) XXX_Unmarshal ¶ added in v1.9.0
func (m *Call_ReserveResources) XXX_Unmarshal(b []byte) error
type Call_SetLoggingLevel ¶
type Call_SetLoggingLevel struct { // The verbosity level. Level *uint32 `protobuf:"varint,1,req,name=level" json:"level,omitempty"` // The duration to keep verbosity level toggled. After this duration, the // verbosity level of log would revert to the original level. Duration *v1.DurationInfo `protobuf:"bytes,2,req,name=duration" json:"duration,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Sets the logging verbosity level for a specified duration. Mesos uses [glog](https://github.com/google/glog) for logging. The library only uses verbose logging which means nothing will be output unless the verbosity level is set (by default it's 0, libprocess uses levels 1, 2, and 3).
func (*Call_SetLoggingLevel) Descriptor ¶
func (*Call_SetLoggingLevel) Descriptor() ([]byte, []int)
func (*Call_SetLoggingLevel) GetDuration ¶
func (m *Call_SetLoggingLevel) GetDuration() *v1.DurationInfo
func (*Call_SetLoggingLevel) GetLevel ¶
func (m *Call_SetLoggingLevel) GetLevel() uint32
func (*Call_SetLoggingLevel) ProtoMessage ¶
func (*Call_SetLoggingLevel) ProtoMessage()
func (*Call_SetLoggingLevel) Reset ¶
func (m *Call_SetLoggingLevel) Reset()
func (*Call_SetLoggingLevel) String ¶
func (m *Call_SetLoggingLevel) String() string
func (*Call_SetLoggingLevel) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call_SetLoggingLevel) XXX_DiscardUnknown()
func (*Call_SetLoggingLevel) XXX_Marshal ¶ added in v1.9.0
func (m *Call_SetLoggingLevel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Call_SetLoggingLevel) XXX_Merge ¶ added in v1.9.0
func (m *Call_SetLoggingLevel) XXX_Merge(src proto.Message)
func (*Call_SetLoggingLevel) XXX_Size ¶ added in v1.9.0
func (m *Call_SetLoggingLevel) XXX_Size() int
func (*Call_SetLoggingLevel) XXX_Unmarshal ¶ added in v1.9.0
func (m *Call_SetLoggingLevel) XXX_Unmarshal(b []byte) error
type Call_SetQuota ¶
type Call_SetQuota struct { QuotaRequest *quota.QuotaRequest `protobuf:"bytes,1,req,name=quota_request,json=quota_request" json:"quota_request,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated in favor of `UpdateQuota`.
func (*Call_SetQuota) Descriptor ¶
func (*Call_SetQuota) Descriptor() ([]byte, []int)
func (*Call_SetQuota) GetQuotaRequest ¶
func (m *Call_SetQuota) GetQuotaRequest() *quota.QuotaRequest
func (*Call_SetQuota) ProtoMessage ¶
func (*Call_SetQuota) ProtoMessage()
func (*Call_SetQuota) Reset ¶
func (m *Call_SetQuota) Reset()
func (*Call_SetQuota) String ¶
func (m *Call_SetQuota) String() string
func (*Call_SetQuota) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call_SetQuota) XXX_DiscardUnknown()
func (*Call_SetQuota) XXX_Marshal ¶ added in v1.9.0
func (m *Call_SetQuota) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Call_SetQuota) XXX_Merge ¶ added in v1.9.0
func (m *Call_SetQuota) XXX_Merge(src proto.Message)
func (*Call_SetQuota) XXX_Size ¶ added in v1.9.0
func (m *Call_SetQuota) XXX_Size() int
func (*Call_SetQuota) XXX_Unmarshal ¶ added in v1.9.0
func (m *Call_SetQuota) XXX_Unmarshal(b []byte) error
type Call_ShrinkVolume ¶
type Call_ShrinkVolume struct { // `agent_id` must be set if `volume` is an agent-local resource, and must // be unset if `volume` is an external resource. AgentId *v1.AgentID `protobuf:"bytes,1,opt,name=agent_id,json=agent_id" json:"agent_id,omitempty"` Volume *v1.Resource `protobuf:"bytes,2,req,name=volume" json:"volume,omitempty"` // See comments in `Value.Scalar` for maximum precision supported. Subtract *v1.Value_Scalar `protobuf:"bytes,3,req,name=subtract" json:"subtract,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Shrink a volume by the size specified in the `subtract` field. NOTE: This is currently experimental and only for persistent volumes created on ROOT/PATH disks.
func (*Call_ShrinkVolume) Descriptor ¶
func (*Call_ShrinkVolume) Descriptor() ([]byte, []int)
func (*Call_ShrinkVolume) GetAgentId ¶
func (m *Call_ShrinkVolume) GetAgentId() *v1.AgentID
func (*Call_ShrinkVolume) GetSubtract ¶
func (m *Call_ShrinkVolume) GetSubtract() *v1.Value_Scalar
func (*Call_ShrinkVolume) GetVolume ¶
func (m *Call_ShrinkVolume) GetVolume() *v1.Resource
func (*Call_ShrinkVolume) ProtoMessage ¶
func (*Call_ShrinkVolume) ProtoMessage()
func (*Call_ShrinkVolume) Reset ¶
func (m *Call_ShrinkVolume) Reset()
func (*Call_ShrinkVolume) String ¶
func (m *Call_ShrinkVolume) String() string
func (*Call_ShrinkVolume) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call_ShrinkVolume) XXX_DiscardUnknown()
func (*Call_ShrinkVolume) XXX_Marshal ¶ added in v1.9.0
func (m *Call_ShrinkVolume) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Call_ShrinkVolume) XXX_Merge ¶ added in v1.9.0
func (m *Call_ShrinkVolume) XXX_Merge(src proto.Message)
func (*Call_ShrinkVolume) XXX_Size ¶ added in v1.9.0
func (m *Call_ShrinkVolume) XXX_Size() int
func (*Call_ShrinkVolume) XXX_Unmarshal ¶ added in v1.9.0
func (m *Call_ShrinkVolume) XXX_Unmarshal(b []byte) error
type Call_StartMaintenance ¶
type Call_StartMaintenance struct { Machines []*v1.MachineID `protobuf:"bytes,1,rep,name=machines" json:"machines,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Starts the maintenance of the cluster, this would bring a set of machines down.
func (*Call_StartMaintenance) Descriptor ¶
func (*Call_StartMaintenance) Descriptor() ([]byte, []int)
func (*Call_StartMaintenance) GetMachines ¶
func (m *Call_StartMaintenance) GetMachines() []*v1.MachineID
func (*Call_StartMaintenance) ProtoMessage ¶
func (*Call_StartMaintenance) ProtoMessage()
func (*Call_StartMaintenance) Reset ¶
func (m *Call_StartMaintenance) Reset()
func (*Call_StartMaintenance) String ¶
func (m *Call_StartMaintenance) String() string
func (*Call_StartMaintenance) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call_StartMaintenance) XXX_DiscardUnknown()
func (*Call_StartMaintenance) XXX_Marshal ¶ added in v1.9.0
func (m *Call_StartMaintenance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Call_StartMaintenance) XXX_Merge ¶ added in v1.9.0
func (m *Call_StartMaintenance) XXX_Merge(src proto.Message)
func (*Call_StartMaintenance) XXX_Size ¶ added in v1.9.0
func (m *Call_StartMaintenance) XXX_Size() int
func (*Call_StartMaintenance) XXX_Unmarshal ¶ added in v1.9.0
func (m *Call_StartMaintenance) XXX_Unmarshal(b []byte) error
type Call_StopMaintenance ¶
type Call_StopMaintenance struct { Machines []*v1.MachineID `protobuf:"bytes,1,rep,name=machines" json:"machines,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Stops the maintenance of the cluster, this would bring a set of machines back up.
func (*Call_StopMaintenance) Descriptor ¶
func (*Call_StopMaintenance) Descriptor() ([]byte, []int)
func (*Call_StopMaintenance) GetMachines ¶
func (m *Call_StopMaintenance) GetMachines() []*v1.MachineID
func (*Call_StopMaintenance) ProtoMessage ¶
func (*Call_StopMaintenance) ProtoMessage()
func (*Call_StopMaintenance) Reset ¶
func (m *Call_StopMaintenance) Reset()
func (*Call_StopMaintenance) String ¶
func (m *Call_StopMaintenance) String() string
func (*Call_StopMaintenance) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call_StopMaintenance) XXX_DiscardUnknown()
func (*Call_StopMaintenance) XXX_Marshal ¶ added in v1.9.0
func (m *Call_StopMaintenance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Call_StopMaintenance) XXX_Merge ¶ added in v1.9.0
func (m *Call_StopMaintenance) XXX_Merge(src proto.Message)
func (*Call_StopMaintenance) XXX_Size ¶ added in v1.9.0
func (m *Call_StopMaintenance) XXX_Size() int
func (*Call_StopMaintenance) XXX_Unmarshal ¶ added in v1.9.0
func (m *Call_StopMaintenance) XXX_Unmarshal(b []byte) error
type Call_Teardown ¶
type Call_Teardown struct { FrameworkId *v1.FrameworkID `protobuf:"bytes,1,req,name=framework_id,json=framework_id" json:"framework_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Tears down a running framework by shutting down all tasks/executors and removing the framework.
func (*Call_Teardown) Descriptor ¶
func (*Call_Teardown) Descriptor() ([]byte, []int)
func (*Call_Teardown) GetFrameworkId ¶
func (m *Call_Teardown) GetFrameworkId() *v1.FrameworkID
func (*Call_Teardown) ProtoMessage ¶
func (*Call_Teardown) ProtoMessage()
func (*Call_Teardown) Reset ¶
func (m *Call_Teardown) Reset()
func (*Call_Teardown) String ¶
func (m *Call_Teardown) String() string
func (*Call_Teardown) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call_Teardown) XXX_DiscardUnknown()
func (*Call_Teardown) XXX_Marshal ¶ added in v1.9.0
func (m *Call_Teardown) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Call_Teardown) XXX_Merge ¶ added in v1.9.0
func (m *Call_Teardown) XXX_Merge(src proto.Message)
func (*Call_Teardown) XXX_Size ¶ added in v1.9.0
func (m *Call_Teardown) XXX_Size() int
func (*Call_Teardown) XXX_Unmarshal ¶ added in v1.9.0
func (m *Call_Teardown) XXX_Unmarshal(b []byte) error
type Call_Type ¶
type Call_Type int32
const ( // If a call of type `Call::FOO` requires additional parameters they can be // included in the corresponding `Call::Foo` message. Similarly, if a call // receives a synchronous response it will be returned as a `Response` // message of type `Response::FOO`. Currently all calls except // `Call::SUBSCRIBE` receive synchronous responses; `Call::SUBSCRIBE` returns // a streaming response of `Event`. Call_UNKNOWN Call_Type = 0 Call_GET_HEALTH Call_Type = 1 Call_GET_FLAGS Call_Type = 2 Call_GET_VERSION Call_Type = 3 Call_GET_METRICS Call_Type = 4 Call_GET_LOGGING_LEVEL Call_Type = 5 Call_SET_LOGGING_LEVEL Call_Type = 6 Call_LIST_FILES Call_Type = 7 Call_READ_FILE Call_Type = 8 Call_GET_STATE Call_Type = 9 Call_GET_AGENTS Call_Type = 10 Call_GET_FRAMEWORKS Call_Type = 11 Call_GET_EXECUTORS Call_Type = 12 Call_GET_OPERATIONS Call_Type = 33 Call_GET_TASKS Call_Type = 13 Call_GET_ROLES Call_Type = 14 Call_GET_WEIGHTS Call_Type = 15 Call_UPDATE_WEIGHTS Call_Type = 16 Call_GET_MASTER Call_Type = 17 Call_SUBSCRIBE Call_Type = 18 Call_RESERVE_RESOURCES Call_Type = 19 Call_UNRESERVE_RESOURCES Call_Type = 20 Call_CREATE_VOLUMES Call_Type = 21 Call_DESTROY_VOLUMES Call_Type = 22 Call_GROW_VOLUME Call_Type = 34 Call_SHRINK_VOLUME Call_Type = 35 // Retrieves the cluster's maintenance status. Call_GET_MAINTENANCE_STATUS Call_Type = 23 // Retrieves the cluster's maintenance schedule. Call_GET_MAINTENANCE_SCHEDULE Call_Type = 24 Call_UPDATE_MAINTENANCE_SCHEDULE Call_Type = 25 Call_START_MAINTENANCE Call_Type = 26 Call_STOP_MAINTENANCE Call_Type = 27 Call_DRAIN_AGENT Call_Type = 37 Call_DEACTIVATE_AGENT Call_Type = 38 Call_REACTIVATE_AGENT Call_Type = 39 Call_GET_QUOTA Call_Type = 28 Call_UPDATE_QUOTA Call_Type = 36 // `SET_QUOTA` and `REMOVE_QUOTA` are deprecated in favor // of `UPDATE_QUOTA`. To reset a role's quota back to the default // (no guarantees and no limits), simply update the role's quota // with empty guarantees and limits. Call_SET_QUOTA Call_Type = 29 // Deprecated: Do not use. Call_REMOVE_QUOTA Call_Type = 30 // Deprecated: Do not use. Call_TEARDOWN Call_Type = 31 Call_MARK_AGENT_GONE Call_Type = 32 )
func (Call_Type) EnumDescriptor ¶
func (*Call_Type) UnmarshalJSON ¶
type Call_UnreserveResources ¶
type Call_UnreserveResources struct { AgentId *v1.AgentID `protobuf:"bytes,1,req,name=agent_id,json=agent_id" json:"agent_id,omitempty"` Resources []*v1.Resource `protobuf:"bytes,2,rep,name=resources" json:"resources,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Unreserve resources dynamically on a specific agent.
func (*Call_UnreserveResources) Descriptor ¶
func (*Call_UnreserveResources) Descriptor() ([]byte, []int)
func (*Call_UnreserveResources) GetAgentId ¶
func (m *Call_UnreserveResources) GetAgentId() *v1.AgentID
func (*Call_UnreserveResources) GetResources ¶
func (m *Call_UnreserveResources) GetResources() []*v1.Resource
func (*Call_UnreserveResources) ProtoMessage ¶
func (*Call_UnreserveResources) ProtoMessage()
func (*Call_UnreserveResources) Reset ¶
func (m *Call_UnreserveResources) Reset()
func (*Call_UnreserveResources) String ¶
func (m *Call_UnreserveResources) String() string
func (*Call_UnreserveResources) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call_UnreserveResources) XXX_DiscardUnknown()
func (*Call_UnreserveResources) XXX_Marshal ¶ added in v1.9.0
func (m *Call_UnreserveResources) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Call_UnreserveResources) XXX_Merge ¶ added in v1.9.0
func (m *Call_UnreserveResources) XXX_Merge(src proto.Message)
func (*Call_UnreserveResources) XXX_Size ¶ added in v1.9.0
func (m *Call_UnreserveResources) XXX_Size() int
func (*Call_UnreserveResources) XXX_Unmarshal ¶ added in v1.9.0
func (m *Call_UnreserveResources) XXX_Unmarshal(b []byte) error
type Call_UpdateMaintenanceSchedule ¶
type Call_UpdateMaintenanceSchedule struct { Schedule *maintenance.Schedule `protobuf:"bytes,1,req,name=schedule" json:"schedule,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Updates the cluster's maintenance schedule.
func (*Call_UpdateMaintenanceSchedule) Descriptor ¶
func (*Call_UpdateMaintenanceSchedule) Descriptor() ([]byte, []int)
func (*Call_UpdateMaintenanceSchedule) GetSchedule ¶
func (m *Call_UpdateMaintenanceSchedule) GetSchedule() *maintenance.Schedule
func (*Call_UpdateMaintenanceSchedule) ProtoMessage ¶
func (*Call_UpdateMaintenanceSchedule) ProtoMessage()
func (*Call_UpdateMaintenanceSchedule) Reset ¶
func (m *Call_UpdateMaintenanceSchedule) Reset()
func (*Call_UpdateMaintenanceSchedule) String ¶
func (m *Call_UpdateMaintenanceSchedule) String() string
func (*Call_UpdateMaintenanceSchedule) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call_UpdateMaintenanceSchedule) XXX_DiscardUnknown()
func (*Call_UpdateMaintenanceSchedule) XXX_Marshal ¶ added in v1.9.0
func (m *Call_UpdateMaintenanceSchedule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Call_UpdateMaintenanceSchedule) XXX_Merge ¶ added in v1.9.0
func (m *Call_UpdateMaintenanceSchedule) XXX_Merge(src proto.Message)
func (*Call_UpdateMaintenanceSchedule) XXX_Size ¶ added in v1.9.0
func (m *Call_UpdateMaintenanceSchedule) XXX_Size() int
func (*Call_UpdateMaintenanceSchedule) XXX_Unmarshal ¶ added in v1.9.0
func (m *Call_UpdateMaintenanceSchedule) XXX_Unmarshal(b []byte) error
type Call_UpdateQuota ¶ added in v1.8.0
type Call_UpdateQuota struct { // Determines whether to skip the capacity validation. See // `quota.QuotaConfig` for more details. Force *bool `protobuf:"varint,1,opt,name=force" json:"force,omitempty"` QuotaConfigs []*quota.QuotaConfig `protobuf:"bytes,2,rep,name=quota_configs,json=quota_configs" json:"quota_configs,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Updates quota given the provided quota configurations, these configurations are applied in an all-or-nothing manner.
func (*Call_UpdateQuota) Descriptor ¶ added in v1.8.0
func (*Call_UpdateQuota) Descriptor() ([]byte, []int)
func (*Call_UpdateQuota) GetForce ¶ added in v1.8.0
func (m *Call_UpdateQuota) GetForce() bool
func (*Call_UpdateQuota) GetQuotaConfigs ¶ added in v1.8.0
func (m *Call_UpdateQuota) GetQuotaConfigs() []*quota.QuotaConfig
func (*Call_UpdateQuota) ProtoMessage ¶ added in v1.8.0
func (*Call_UpdateQuota) ProtoMessage()
func (*Call_UpdateQuota) Reset ¶ added in v1.8.0
func (m *Call_UpdateQuota) Reset()
func (*Call_UpdateQuota) String ¶ added in v1.8.0
func (m *Call_UpdateQuota) String() string
func (*Call_UpdateQuota) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call_UpdateQuota) XXX_DiscardUnknown()
func (*Call_UpdateQuota) XXX_Marshal ¶ added in v1.9.0
func (m *Call_UpdateQuota) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Call_UpdateQuota) XXX_Merge ¶ added in v1.9.0
func (m *Call_UpdateQuota) XXX_Merge(src proto.Message)
func (*Call_UpdateQuota) XXX_Size ¶ added in v1.9.0
func (m *Call_UpdateQuota) XXX_Size() int
func (*Call_UpdateQuota) XXX_Unmarshal ¶ added in v1.9.0
func (m *Call_UpdateQuota) XXX_Unmarshal(b []byte) error
type Call_UpdateWeights ¶
type Call_UpdateWeights struct { WeightInfos []*v1.WeightInfo `protobuf:"bytes,1,rep,name=weight_infos,json=weight_infos" json:"weight_infos,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Call_UpdateWeights) Descriptor ¶
func (*Call_UpdateWeights) Descriptor() ([]byte, []int)
func (*Call_UpdateWeights) GetWeightInfos ¶
func (m *Call_UpdateWeights) GetWeightInfos() []*v1.WeightInfo
func (*Call_UpdateWeights) ProtoMessage ¶
func (*Call_UpdateWeights) ProtoMessage()
func (*Call_UpdateWeights) Reset ¶
func (m *Call_UpdateWeights) Reset()
func (*Call_UpdateWeights) String ¶
func (m *Call_UpdateWeights) String() string
func (*Call_UpdateWeights) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Call_UpdateWeights) XXX_DiscardUnknown()
func (*Call_UpdateWeights) XXX_Marshal ¶ added in v1.9.0
func (m *Call_UpdateWeights) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Call_UpdateWeights) XXX_Merge ¶ added in v1.9.0
func (m *Call_UpdateWeights) XXX_Merge(src proto.Message)
func (*Call_UpdateWeights) XXX_Size ¶ added in v1.9.0
func (m *Call_UpdateWeights) XXX_Size() int
func (*Call_UpdateWeights) XXX_Unmarshal ¶ added in v1.9.0
func (m *Call_UpdateWeights) XXX_Unmarshal(b []byte) error
type Event ¶
type Event struct { Type *Event_Type `protobuf:"varint,1,opt,name=type,enum=mesos.v1.master.Event_Type" json:"type,omitempty"` Subscribed *Event_Subscribed `protobuf:"bytes,2,opt,name=subscribed" json:"subscribed,omitempty"` TaskAdded *Event_TaskAdded `protobuf:"bytes,3,opt,name=task_added,json=task_added" json:"task_added,omitempty"` TaskUpdated *Event_TaskUpdated `protobuf:"bytes,4,opt,name=task_updated,json=task_updated" json:"task_updated,omitempty"` AgentAdded *Event_AgentAdded `protobuf:"bytes,5,opt,name=agent_added,json=agent_added" json:"agent_added,omitempty"` AgentRemoved *Event_AgentRemoved `protobuf:"bytes,6,opt,name=agent_removed,json=agent_removed" json:"agent_removed,omitempty"` FrameworkAdded *Event_FrameworkAdded `protobuf:"bytes,7,opt,name=framework_added,json=framework_added" json:"framework_added,omitempty"` FrameworkUpdated *Event_FrameworkUpdated `protobuf:"bytes,8,opt,name=framework_updated,json=framework_updated" json:"framework_updated,omitempty"` FrameworkRemoved *Event_FrameworkRemoved `protobuf:"bytes,9,opt,name=framework_removed,json=framework_removed" json:"framework_removed,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Streaming response to `Call::SUBSCRIBE` made to the master.
func (*Event) Descriptor ¶
func (*Event) GetAgentAdded ¶
func (m *Event) GetAgentAdded() *Event_AgentAdded
func (*Event) GetAgentRemoved ¶
func (m *Event) GetAgentRemoved() *Event_AgentRemoved
func (*Event) GetFrameworkAdded ¶
func (m *Event) GetFrameworkAdded() *Event_FrameworkAdded
func (*Event) GetFrameworkRemoved ¶
func (m *Event) GetFrameworkRemoved() *Event_FrameworkRemoved
func (*Event) GetFrameworkUpdated ¶
func (m *Event) GetFrameworkUpdated() *Event_FrameworkUpdated
func (*Event) GetSubscribed ¶
func (m *Event) GetSubscribed() *Event_Subscribed
func (*Event) GetTaskAdded ¶
func (m *Event) GetTaskAdded() *Event_TaskAdded
func (*Event) GetTaskUpdated ¶
func (m *Event) GetTaskUpdated() *Event_TaskUpdated
func (*Event) GetType ¶
func (m *Event) GetType() Event_Type
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Event) XXX_DiscardUnknown()
func (*Event) XXX_Marshal ¶ added in v1.9.0
func (*Event) XXX_Unmarshal ¶ added in v1.9.0
type Event_AgentAdded ¶
type Event_AgentAdded struct { Agent *Response_GetAgents_Agent `protobuf:"bytes,1,req,name=agent" json:"agent,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Forwarded by the master when an agent becomes known to it. This can happen when an agent registered for the first time, or reregistered with the master.
func (*Event_AgentAdded) Descriptor ¶
func (*Event_AgentAdded) Descriptor() ([]byte, []int)
func (*Event_AgentAdded) GetAgent ¶
func (m *Event_AgentAdded) GetAgent() *Response_GetAgents_Agent
func (*Event_AgentAdded) ProtoMessage ¶
func (*Event_AgentAdded) ProtoMessage()
func (*Event_AgentAdded) Reset ¶
func (m *Event_AgentAdded) Reset()
func (*Event_AgentAdded) String ¶
func (m *Event_AgentAdded) String() string
func (*Event_AgentAdded) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Event_AgentAdded) XXX_DiscardUnknown()
func (*Event_AgentAdded) XXX_Marshal ¶ added in v1.9.0
func (m *Event_AgentAdded) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Event_AgentAdded) XXX_Merge ¶ added in v1.9.0
func (m *Event_AgentAdded) XXX_Merge(src proto.Message)
func (*Event_AgentAdded) XXX_Size ¶ added in v1.9.0
func (m *Event_AgentAdded) XXX_Size() int
func (*Event_AgentAdded) XXX_Unmarshal ¶ added in v1.9.0
func (m *Event_AgentAdded) XXX_Unmarshal(b []byte) error
type Event_AgentRemoved ¶
type Event_AgentRemoved struct { AgentId *v1.AgentID `protobuf:"bytes,1,req,name=agent_id,json=agent_id" json:"agent_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Forwarded by the master when an agent is removed. This can happen when the agent is scheduled for maintenance.
NOTE: It's possible that an agent might become active once it has been removed, i.e. if the master has gc'ed its list of known "dead" agents. See MESOS-5965 for context.
func (*Event_AgentRemoved) Descriptor ¶
func (*Event_AgentRemoved) Descriptor() ([]byte, []int)
func (*Event_AgentRemoved) GetAgentId ¶
func (m *Event_AgentRemoved) GetAgentId() *v1.AgentID
func (*Event_AgentRemoved) ProtoMessage ¶
func (*Event_AgentRemoved) ProtoMessage()
func (*Event_AgentRemoved) Reset ¶
func (m *Event_AgentRemoved) Reset()
func (*Event_AgentRemoved) String ¶
func (m *Event_AgentRemoved) String() string
func (*Event_AgentRemoved) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Event_AgentRemoved) XXX_DiscardUnknown()
func (*Event_AgentRemoved) XXX_Marshal ¶ added in v1.9.0
func (m *Event_AgentRemoved) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Event_AgentRemoved) XXX_Merge ¶ added in v1.9.0
func (m *Event_AgentRemoved) XXX_Merge(src proto.Message)
func (*Event_AgentRemoved) XXX_Size ¶ added in v1.9.0
func (m *Event_AgentRemoved) XXX_Size() int
func (*Event_AgentRemoved) XXX_Unmarshal ¶ added in v1.9.0
func (m *Event_AgentRemoved) XXX_Unmarshal(b []byte) error
type Event_FrameworkAdded ¶
type Event_FrameworkAdded struct { Framework *Response_GetFrameworks_Framework `protobuf:"bytes,1,req,name=framework" json:"framework,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Forwarded by the master when a framework becomes known to it. This can happen when a new framework registers with the master.
func (*Event_FrameworkAdded) Descriptor ¶
func (*Event_FrameworkAdded) Descriptor() ([]byte, []int)
func (*Event_FrameworkAdded) GetFramework ¶
func (m *Event_FrameworkAdded) GetFramework() *Response_GetFrameworks_Framework
func (*Event_FrameworkAdded) ProtoMessage ¶
func (*Event_FrameworkAdded) ProtoMessage()
func (*Event_FrameworkAdded) Reset ¶
func (m *Event_FrameworkAdded) Reset()
func (*Event_FrameworkAdded) String ¶
func (m *Event_FrameworkAdded) String() string
func (*Event_FrameworkAdded) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Event_FrameworkAdded) XXX_DiscardUnknown()
func (*Event_FrameworkAdded) XXX_Marshal ¶ added in v1.9.0
func (m *Event_FrameworkAdded) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Event_FrameworkAdded) XXX_Merge ¶ added in v1.9.0
func (m *Event_FrameworkAdded) XXX_Merge(src proto.Message)
func (*Event_FrameworkAdded) XXX_Size ¶ added in v1.9.0
func (m *Event_FrameworkAdded) XXX_Size() int
func (*Event_FrameworkAdded) XXX_Unmarshal ¶ added in v1.9.0
func (m *Event_FrameworkAdded) XXX_Unmarshal(b []byte) error
type Event_FrameworkRemoved ¶
type Event_FrameworkRemoved struct { FrameworkInfo *v1.FrameworkInfo `protobuf:"bytes,1,req,name=framework_info,json=framework_info" json:"framework_info,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Forwarded by the master when a framework is removed. This can happen when a framework is explicitly teardown by the operator or if it fails to reregister with the master within the failover timeout.
func (*Event_FrameworkRemoved) Descriptor ¶
func (*Event_FrameworkRemoved) Descriptor() ([]byte, []int)
func (*Event_FrameworkRemoved) GetFrameworkInfo ¶
func (m *Event_FrameworkRemoved) GetFrameworkInfo() *v1.FrameworkInfo
func (*Event_FrameworkRemoved) ProtoMessage ¶
func (*Event_FrameworkRemoved) ProtoMessage()
func (*Event_FrameworkRemoved) Reset ¶
func (m *Event_FrameworkRemoved) Reset()
func (*Event_FrameworkRemoved) String ¶
func (m *Event_FrameworkRemoved) String() string
func (*Event_FrameworkRemoved) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Event_FrameworkRemoved) XXX_DiscardUnknown()
func (*Event_FrameworkRemoved) XXX_Marshal ¶ added in v1.9.0
func (m *Event_FrameworkRemoved) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Event_FrameworkRemoved) XXX_Merge ¶ added in v1.9.0
func (m *Event_FrameworkRemoved) XXX_Merge(src proto.Message)
func (*Event_FrameworkRemoved) XXX_Size ¶ added in v1.9.0
func (m *Event_FrameworkRemoved) XXX_Size() int
func (*Event_FrameworkRemoved) XXX_Unmarshal ¶ added in v1.9.0
func (m *Event_FrameworkRemoved) XXX_Unmarshal(b []byte) error
type Event_FrameworkUpdated ¶
type Event_FrameworkUpdated struct { Framework *Response_GetFrameworks_Framework `protobuf:"bytes,1,req,name=framework" json:"framework,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Forwarded by the master when a framework reregisters with the master upon a disconnection (network error) or upon a master failover.
func (*Event_FrameworkUpdated) Descriptor ¶
func (*Event_FrameworkUpdated) Descriptor() ([]byte, []int)
func (*Event_FrameworkUpdated) GetFramework ¶
func (m *Event_FrameworkUpdated) GetFramework() *Response_GetFrameworks_Framework
func (*Event_FrameworkUpdated) ProtoMessage ¶
func (*Event_FrameworkUpdated) ProtoMessage()
func (*Event_FrameworkUpdated) Reset ¶
func (m *Event_FrameworkUpdated) Reset()
func (*Event_FrameworkUpdated) String ¶
func (m *Event_FrameworkUpdated) String() string
func (*Event_FrameworkUpdated) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Event_FrameworkUpdated) XXX_DiscardUnknown()
func (*Event_FrameworkUpdated) XXX_Marshal ¶ added in v1.9.0
func (m *Event_FrameworkUpdated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Event_FrameworkUpdated) XXX_Merge ¶ added in v1.9.0
func (m *Event_FrameworkUpdated) XXX_Merge(src proto.Message)
func (*Event_FrameworkUpdated) XXX_Size ¶ added in v1.9.0
func (m *Event_FrameworkUpdated) XXX_Size() int
func (*Event_FrameworkUpdated) XXX_Unmarshal ¶ added in v1.9.0
func (m *Event_FrameworkUpdated) XXX_Unmarshal(b []byte) error
type Event_Subscribed ¶
type Event_Subscribed struct { // Snapshot of the entire cluster state. Further updates to the // cluster state are sent as separate events on the stream. GetState *Response_GetState `protobuf:"bytes,1,opt,name=get_state,json=get_state" json:"get_state,omitempty"` // This value will be set if the master is sending heartbeats to // subscribers. See the comment above on 'HEARTBEAT' for more details. HeartbeatIntervalSeconds *float64 `` /* 132-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
First event received when a client subscribes.
func (*Event_Subscribed) Descriptor ¶
func (*Event_Subscribed) Descriptor() ([]byte, []int)
func (*Event_Subscribed) GetGetState ¶
func (m *Event_Subscribed) GetGetState() *Response_GetState
func (*Event_Subscribed) GetHeartbeatIntervalSeconds ¶
func (m *Event_Subscribed) GetHeartbeatIntervalSeconds() float64
func (*Event_Subscribed) ProtoMessage ¶
func (*Event_Subscribed) ProtoMessage()
func (*Event_Subscribed) Reset ¶
func (m *Event_Subscribed) Reset()
func (*Event_Subscribed) String ¶
func (m *Event_Subscribed) String() string
func (*Event_Subscribed) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Event_Subscribed) XXX_DiscardUnknown()
func (*Event_Subscribed) XXX_Marshal ¶ added in v1.9.0
func (m *Event_Subscribed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Event_Subscribed) XXX_Merge ¶ added in v1.9.0
func (m *Event_Subscribed) XXX_Merge(src proto.Message)
func (*Event_Subscribed) XXX_Size ¶ added in v1.9.0
func (m *Event_Subscribed) XXX_Size() int
func (*Event_Subscribed) XXX_Unmarshal ¶ added in v1.9.0
func (m *Event_Subscribed) XXX_Unmarshal(b []byte) error
type Event_TaskAdded ¶
type Event_TaskAdded struct { Task *v1.Task `protobuf:"bytes,1,req,name=task" json:"task,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Forwarded by the master when a task becomes known to it. This can happen when a new task is launched by the scheduler or when the task becomes known to the master upon an agent (re-)registration after a failover.
func (*Event_TaskAdded) Descriptor ¶
func (*Event_TaskAdded) Descriptor() ([]byte, []int)
func (*Event_TaskAdded) GetTask ¶
func (m *Event_TaskAdded) GetTask() *v1.Task
func (*Event_TaskAdded) ProtoMessage ¶
func (*Event_TaskAdded) ProtoMessage()
func (*Event_TaskAdded) Reset ¶
func (m *Event_TaskAdded) Reset()
func (*Event_TaskAdded) String ¶
func (m *Event_TaskAdded) String() string
func (*Event_TaskAdded) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Event_TaskAdded) XXX_DiscardUnknown()
func (*Event_TaskAdded) XXX_Marshal ¶ added in v1.9.0
func (m *Event_TaskAdded) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Event_TaskAdded) XXX_Merge ¶ added in v1.9.0
func (m *Event_TaskAdded) XXX_Merge(src proto.Message)
func (*Event_TaskAdded) XXX_Size ¶ added in v1.9.0
func (m *Event_TaskAdded) XXX_Size() int
func (*Event_TaskAdded) XXX_Unmarshal ¶ added in v1.9.0
func (m *Event_TaskAdded) XXX_Unmarshal(b []byte) error
type Event_TaskUpdated ¶
type Event_TaskUpdated struct { FrameworkId *v1.FrameworkID `protobuf:"bytes,1,req,name=framework_id,json=framework_id" json:"framework_id,omitempty"` // This is the status of the task corresponding to the last // status update acknowledged by the scheduler. Status *v1.TaskStatus `protobuf:"bytes,2,req,name=status" json:"status,omitempty"` // This is the latest state of the task according to the agent, // which can be more recent than `status` above but intermediate // state changes may be skipped if they happen faster than the // scheduler can acknowledge them. State *v1.TaskState `protobuf:"varint,3,req,name=state,enum=mesos.v1.TaskState" json:"state,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Forwarded by the master when an existing task transitions to a new state.
func (*Event_TaskUpdated) Descriptor ¶
func (*Event_TaskUpdated) Descriptor() ([]byte, []int)
func (*Event_TaskUpdated) GetFrameworkId ¶
func (m *Event_TaskUpdated) GetFrameworkId() *v1.FrameworkID
func (*Event_TaskUpdated) GetState ¶
func (m *Event_TaskUpdated) GetState() v1.TaskState
func (*Event_TaskUpdated) GetStatus ¶
func (m *Event_TaskUpdated) GetStatus() *v1.TaskStatus
func (*Event_TaskUpdated) ProtoMessage ¶
func (*Event_TaskUpdated) ProtoMessage()
func (*Event_TaskUpdated) Reset ¶
func (m *Event_TaskUpdated) Reset()
func (*Event_TaskUpdated) String ¶
func (m *Event_TaskUpdated) String() string
func (*Event_TaskUpdated) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Event_TaskUpdated) XXX_DiscardUnknown()
func (*Event_TaskUpdated) XXX_Marshal ¶ added in v1.9.0
func (m *Event_TaskUpdated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Event_TaskUpdated) XXX_Merge ¶ added in v1.9.0
func (m *Event_TaskUpdated) XXX_Merge(src proto.Message)
func (*Event_TaskUpdated) XXX_Size ¶ added in v1.9.0
func (m *Event_TaskUpdated) XXX_Size() int
func (*Event_TaskUpdated) XXX_Unmarshal ¶ added in v1.9.0
func (m *Event_TaskUpdated) XXX_Unmarshal(b []byte) error
type Event_Type ¶
type Event_Type int32
const ( Event_UNKNOWN Event_Type = 0 Event_SUBSCRIBED Event_Type = 1 Event_TASK_ADDED Event_Type = 2 Event_TASK_UPDATED Event_Type = 3 Event_AGENT_ADDED Event_Type = 4 Event_AGENT_REMOVED Event_Type = 5 Event_FRAMEWORK_ADDED Event_Type = 6 Event_FRAMEWORK_UPDATED Event_Type = 7 Event_FRAMEWORK_REMOVED Event_Type = 8 // Periodic message sent by the master to the subscriber according to // 'Subscribed.heartbeat_interval_seconds'. If the subscriber does not // receive any events (including heartbeats) for an extended period of // time (e.g., 5 x heartbeat_interval_seconds), it is likely that the // connection is lost or there is a network partition. In that case, // the subscriber should close the existing subscription connection and // resubscribe using a backoff strategy. Event_HEARTBEAT Event_Type = 9 )
func (Event_Type) Enum ¶
func (x Event_Type) Enum() *Event_Type
func (Event_Type) EnumDescriptor ¶
func (Event_Type) EnumDescriptor() ([]byte, []int)
func (Event_Type) String ¶
func (x Event_Type) String() string
func (*Event_Type) UnmarshalJSON ¶
func (x *Event_Type) UnmarshalJSON(data []byte) error
type Response ¶
type Response struct { Type *Response_Type `protobuf:"varint,1,opt,name=type,enum=mesos.v1.master.Response_Type" json:"type,omitempty"` GetHealth *Response_GetHealth `protobuf:"bytes,2,opt,name=get_health,json=get_health" json:"get_health,omitempty"` GetFlags *Response_GetFlags `protobuf:"bytes,3,opt,name=get_flags,json=get_flags" json:"get_flags,omitempty"` GetVersion *Response_GetVersion `protobuf:"bytes,4,opt,name=get_version,json=get_version" json:"get_version,omitempty"` GetMetrics *Response_GetMetrics `protobuf:"bytes,5,opt,name=get_metrics,json=get_metrics" json:"get_metrics,omitempty"` GetLoggingLevel *Response_GetLoggingLevel `protobuf:"bytes,6,opt,name=get_logging_level,json=get_logging_level" json:"get_logging_level,omitempty"` ListFiles *Response_ListFiles `protobuf:"bytes,7,opt,name=list_files,json=list_files" json:"list_files,omitempty"` ReadFile *Response_ReadFile `protobuf:"bytes,8,opt,name=read_file,json=read_file" json:"read_file,omitempty"` GetState *Response_GetState `protobuf:"bytes,9,opt,name=get_state,json=get_state" json:"get_state,omitempty"` GetAgents *Response_GetAgents `protobuf:"bytes,10,opt,name=get_agents,json=get_agents" json:"get_agents,omitempty"` GetFrameworks *Response_GetFrameworks `protobuf:"bytes,11,opt,name=get_frameworks,json=get_frameworks" json:"get_frameworks,omitempty"` GetExecutors *Response_GetExecutors `protobuf:"bytes,12,opt,name=get_executors,json=get_executors" json:"get_executors,omitempty"` GetOperations *Response_GetOperations `protobuf:"bytes,20,opt,name=get_operations,json=get_operations" json:"get_operations,omitempty"` GetTasks *Response_GetTasks `protobuf:"bytes,13,opt,name=get_tasks,json=get_tasks" json:"get_tasks,omitempty"` GetRoles *Response_GetRoles `protobuf:"bytes,14,opt,name=get_roles,json=get_roles" json:"get_roles,omitempty"` GetWeights *Response_GetWeights `protobuf:"bytes,15,opt,name=get_weights,json=get_weights" json:"get_weights,omitempty"` GetMaster *Response_GetMaster `protobuf:"bytes,16,opt,name=get_master,json=get_master" json:"get_master,omitempty"` GetMaintenanceStatus *Response_GetMaintenanceStatus `protobuf:"bytes,17,opt,name=get_maintenance_status,json=get_maintenance_status" json:"get_maintenance_status,omitempty"` GetMaintenanceSchedule *Response_GetMaintenanceSchedule `protobuf:"bytes,18,opt,name=get_maintenance_schedule,json=get_maintenance_schedule" json:"get_maintenance_schedule,omitempty"` GetQuota *Response_GetQuota `protobuf:"bytes,19,opt,name=get_quota,json=get_quota" json:"get_quota,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Synchronous responses for all calls (except Call::SUBSCRIBE) made to the v1 master API.
func (*Response) Descriptor ¶
func (*Response) GetGetAgents ¶
func (m *Response) GetGetAgents() *Response_GetAgents
func (*Response) GetGetExecutors ¶
func (m *Response) GetGetExecutors() *Response_GetExecutors
func (*Response) GetGetFlags ¶
func (m *Response) GetGetFlags() *Response_GetFlags
func (*Response) GetGetFrameworks ¶
func (m *Response) GetGetFrameworks() *Response_GetFrameworks
func (*Response) GetGetHealth ¶
func (m *Response) GetGetHealth() *Response_GetHealth
func (*Response) GetGetLoggingLevel ¶
func (m *Response) GetGetLoggingLevel() *Response_GetLoggingLevel
func (*Response) GetGetMaintenanceSchedule ¶
func (m *Response) GetGetMaintenanceSchedule() *Response_GetMaintenanceSchedule
func (*Response) GetGetMaintenanceStatus ¶
func (m *Response) GetGetMaintenanceStatus() *Response_GetMaintenanceStatus
func (*Response) GetGetMaster ¶
func (m *Response) GetGetMaster() *Response_GetMaster
func (*Response) GetGetMetrics ¶
func (m *Response) GetGetMetrics() *Response_GetMetrics
func (*Response) GetGetOperations ¶
func (m *Response) GetGetOperations() *Response_GetOperations
func (*Response) GetGetQuota ¶
func (m *Response) GetGetQuota() *Response_GetQuota
func (*Response) GetGetRoles ¶
func (m *Response) GetGetRoles() *Response_GetRoles
func (*Response) GetGetState ¶
func (m *Response) GetGetState() *Response_GetState
func (*Response) GetGetTasks ¶
func (m *Response) GetGetTasks() *Response_GetTasks
func (*Response) GetGetVersion ¶
func (m *Response) GetGetVersion() *Response_GetVersion
func (*Response) GetGetWeights ¶
func (m *Response) GetGetWeights() *Response_GetWeights
func (*Response) GetListFiles ¶
func (m *Response) GetListFiles() *Response_ListFiles
func (*Response) GetReadFile ¶
func (m *Response) GetReadFile() *Response_ReadFile
func (*Response) GetType ¶
func (m *Response) GetType() Response_Type
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response) XXX_DiscardUnknown()
func (*Response) XXX_Marshal ¶ added in v1.9.0
func (*Response) XXX_Unmarshal ¶ added in v1.9.0
type Response_GetAgents ¶
type Response_GetAgents struct { // Registered agents. Agents []*Response_GetAgents_Agent `protobuf:"bytes,1,rep,name=agents" json:"agents,omitempty"` // Agents which are recovered from registry but not reregistered yet. RecoveredAgents []*v1.AgentInfo `protobuf:"bytes,2,rep,name=recovered_agents,json=recovered_agents" json:"recovered_agents,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Response_GetAgents) Descriptor ¶
func (*Response_GetAgents) Descriptor() ([]byte, []int)
func (*Response_GetAgents) GetAgents ¶
func (m *Response_GetAgents) GetAgents() []*Response_GetAgents_Agent
func (*Response_GetAgents) GetRecoveredAgents ¶
func (m *Response_GetAgents) GetRecoveredAgents() []*v1.AgentInfo
func (*Response_GetAgents) ProtoMessage ¶
func (*Response_GetAgents) ProtoMessage()
func (*Response_GetAgents) Reset ¶
func (m *Response_GetAgents) Reset()
func (*Response_GetAgents) String ¶
func (m *Response_GetAgents) String() string
func (*Response_GetAgents) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_GetAgents) XXX_DiscardUnknown()
func (*Response_GetAgents) XXX_Marshal ¶ added in v1.9.0
func (m *Response_GetAgents) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_GetAgents) XXX_Merge ¶ added in v1.9.0
func (m *Response_GetAgents) XXX_Merge(src proto.Message)
func (*Response_GetAgents) XXX_Size ¶ added in v1.9.0
func (m *Response_GetAgents) XXX_Size() int
func (*Response_GetAgents) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_GetAgents) XXX_Unmarshal(b []byte) error
type Response_GetAgents_Agent ¶
type Response_GetAgents_Agent struct { AgentInfo *v1.AgentInfo `protobuf:"bytes,1,req,name=agent_info,json=agent_info" json:"agent_info,omitempty"` Active *bool `protobuf:"varint,2,req,name=active" json:"active,omitempty"` Deactivated *bool `protobuf:"varint,12,opt,name=deactivated" json:"deactivated,omitempty"` Version *string `protobuf:"bytes,3,req,name=version" json:"version,omitempty"` Pid *string `protobuf:"bytes,4,opt,name=pid" json:"pid,omitempty"` RegisteredTime *v1.TimeInfo `protobuf:"bytes,5,opt,name=registered_time,json=registered_time" json:"registered_time,omitempty"` ReregisteredTime *v1.TimeInfo `protobuf:"bytes,6,opt,name=reregistered_time,json=reregistered_time" json:"reregistered_time,omitempty"` // Total resources (including oversubscribed resources) the agent // provides. TotalResources []*v1.Resource `protobuf:"bytes,7,rep,name=total_resources,json=total_resources" json:"total_resources,omitempty"` AllocatedResources []*v1.Resource `protobuf:"bytes,8,rep,name=allocated_resources,json=allocated_resources" json:"allocated_resources,omitempty"` OfferedResources []*v1.Resource `protobuf:"bytes,9,rep,name=offered_resources,json=offered_resources" json:"offered_resources,omitempty"` Capabilities []*v1.AgentInfo_Capability `protobuf:"bytes,10,rep,name=capabilities" json:"capabilities,omitempty"` ResourceProviders []*Response_GetAgents_Agent_ResourceProvider `protobuf:"bytes,11,rep,name=resource_providers,json=resource_providers" json:"resource_providers,omitempty"` DrainInfo *v1.DrainInfo `protobuf:"bytes,13,opt,name=drain_info,json=drain_info" json:"drain_info,omitempty"` EstimatedDrainStartTime *v1.TimeInfo `` /* 131-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Response_GetAgents_Agent) Descriptor ¶
func (*Response_GetAgents_Agent) Descriptor() ([]byte, []int)
func (*Response_GetAgents_Agent) GetActive ¶
func (m *Response_GetAgents_Agent) GetActive() bool
func (*Response_GetAgents_Agent) GetAgentInfo ¶
func (m *Response_GetAgents_Agent) GetAgentInfo() *v1.AgentInfo
func (*Response_GetAgents_Agent) GetAllocatedResources ¶
func (m *Response_GetAgents_Agent) GetAllocatedResources() []*v1.Resource
func (*Response_GetAgents_Agent) GetCapabilities ¶
func (m *Response_GetAgents_Agent) GetCapabilities() []*v1.AgentInfo_Capability
func (*Response_GetAgents_Agent) GetDeactivated ¶ added in v1.9.0
func (m *Response_GetAgents_Agent) GetDeactivated() bool
func (*Response_GetAgents_Agent) GetDrainInfo ¶ added in v1.9.0
func (m *Response_GetAgents_Agent) GetDrainInfo() *v1.DrainInfo
func (*Response_GetAgents_Agent) GetEstimatedDrainStartTime ¶ added in v1.9.0
func (m *Response_GetAgents_Agent) GetEstimatedDrainStartTime() *v1.TimeInfo
func (*Response_GetAgents_Agent) GetOfferedResources ¶
func (m *Response_GetAgents_Agent) GetOfferedResources() []*v1.Resource
func (*Response_GetAgents_Agent) GetPid ¶
func (m *Response_GetAgents_Agent) GetPid() string
func (*Response_GetAgents_Agent) GetRegisteredTime ¶
func (m *Response_GetAgents_Agent) GetRegisteredTime() *v1.TimeInfo
func (*Response_GetAgents_Agent) GetReregisteredTime ¶
func (m *Response_GetAgents_Agent) GetReregisteredTime() *v1.TimeInfo
func (*Response_GetAgents_Agent) GetResourceProviders ¶
func (m *Response_GetAgents_Agent) GetResourceProviders() []*Response_GetAgents_Agent_ResourceProvider
func (*Response_GetAgents_Agent) GetTotalResources ¶
func (m *Response_GetAgents_Agent) GetTotalResources() []*v1.Resource
func (*Response_GetAgents_Agent) GetVersion ¶
func (m *Response_GetAgents_Agent) GetVersion() string
func (*Response_GetAgents_Agent) ProtoMessage ¶
func (*Response_GetAgents_Agent) ProtoMessage()
func (*Response_GetAgents_Agent) Reset ¶
func (m *Response_GetAgents_Agent) Reset()
func (*Response_GetAgents_Agent) String ¶
func (m *Response_GetAgents_Agent) String() string
func (*Response_GetAgents_Agent) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_GetAgents_Agent) XXX_DiscardUnknown()
func (*Response_GetAgents_Agent) XXX_Marshal ¶ added in v1.9.0
func (m *Response_GetAgents_Agent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_GetAgents_Agent) XXX_Merge ¶ added in v1.9.0
func (m *Response_GetAgents_Agent) XXX_Merge(src proto.Message)
func (*Response_GetAgents_Agent) XXX_Size ¶ added in v1.9.0
func (m *Response_GetAgents_Agent) XXX_Size() int
func (*Response_GetAgents_Agent) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_GetAgents_Agent) XXX_Unmarshal(b []byte) error
type Response_GetAgents_Agent_ResourceProvider ¶
type Response_GetAgents_Agent_ResourceProvider struct { ResourceProviderInfo *v1.ResourceProviderInfo `protobuf:"bytes,1,req,name=resource_provider_info,json=resource_provider_info" json:"resource_provider_info,omitempty"` TotalResources []*v1.Resource `protobuf:"bytes,2,rep,name=total_resources,json=total_resources" json:"total_resources,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Response_GetAgents_Agent_ResourceProvider) Descriptor ¶
func (*Response_GetAgents_Agent_ResourceProvider) Descriptor() ([]byte, []int)
func (*Response_GetAgents_Agent_ResourceProvider) GetResourceProviderInfo ¶
func (m *Response_GetAgents_Agent_ResourceProvider) GetResourceProviderInfo() *v1.ResourceProviderInfo
func (*Response_GetAgents_Agent_ResourceProvider) GetTotalResources ¶
func (m *Response_GetAgents_Agent_ResourceProvider) GetTotalResources() []*v1.Resource
func (*Response_GetAgents_Agent_ResourceProvider) ProtoMessage ¶
func (*Response_GetAgents_Agent_ResourceProvider) ProtoMessage()
func (*Response_GetAgents_Agent_ResourceProvider) Reset ¶
func (m *Response_GetAgents_Agent_ResourceProvider) Reset()
func (*Response_GetAgents_Agent_ResourceProvider) String ¶
func (m *Response_GetAgents_Agent_ResourceProvider) String() string
func (*Response_GetAgents_Agent_ResourceProvider) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_GetAgents_Agent_ResourceProvider) XXX_DiscardUnknown()
func (*Response_GetAgents_Agent_ResourceProvider) XXX_Marshal ¶ added in v1.9.0
func (m *Response_GetAgents_Agent_ResourceProvider) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_GetAgents_Agent_ResourceProvider) XXX_Merge ¶ added in v1.9.0
func (m *Response_GetAgents_Agent_ResourceProvider) XXX_Merge(src proto.Message)
func (*Response_GetAgents_Agent_ResourceProvider) XXX_Size ¶ added in v1.9.0
func (m *Response_GetAgents_Agent_ResourceProvider) XXX_Size() int
func (*Response_GetAgents_Agent_ResourceProvider) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_GetAgents_Agent_ResourceProvider) XXX_Unmarshal(b []byte) error
type Response_GetExecutors ¶
type Response_GetExecutors struct { Executors []*Response_GetExecutors_Executor `protobuf:"bytes,1,rep,name=executors" json:"executors,omitempty"` // As of Mesos 1.3.0, this field is deprecated and will always be empty. // // TODO(neilc): Remove this field in Mesos 2.0. OrphanExecutors []*Response_GetExecutors_Executor `protobuf:"bytes,2,rep,name=orphan_executors,json=orphan_executors" json:"orphan_executors,omitempty"` // Deprecated: Do not use. XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Lists information about all the executors known to the master at the current time. Note that there might be executors unknown to the master running on partitioned or unsubscribed agents.
func (*Response_GetExecutors) Descriptor ¶
func (*Response_GetExecutors) Descriptor() ([]byte, []int)
func (*Response_GetExecutors) GetExecutors ¶
func (m *Response_GetExecutors) GetExecutors() []*Response_GetExecutors_Executor
func (*Response_GetExecutors) GetOrphanExecutors
deprecated
func (m *Response_GetExecutors) GetOrphanExecutors() []*Response_GetExecutors_Executor
Deprecated: Do not use.
func (*Response_GetExecutors) ProtoMessage ¶
func (*Response_GetExecutors) ProtoMessage()
func (*Response_GetExecutors) Reset ¶
func (m *Response_GetExecutors) Reset()
func (*Response_GetExecutors) String ¶
func (m *Response_GetExecutors) String() string
func (*Response_GetExecutors) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_GetExecutors) XXX_DiscardUnknown()
func (*Response_GetExecutors) XXX_Marshal ¶ added in v1.9.0
func (m *Response_GetExecutors) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_GetExecutors) XXX_Merge ¶ added in v1.9.0
func (m *Response_GetExecutors) XXX_Merge(src proto.Message)
func (*Response_GetExecutors) XXX_Size ¶ added in v1.9.0
func (m *Response_GetExecutors) XXX_Size() int
func (*Response_GetExecutors) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_GetExecutors) XXX_Unmarshal(b []byte) error
type Response_GetExecutors_Executor ¶
type Response_GetExecutors_Executor struct { ExecutorInfo *v1.ExecutorInfo `protobuf:"bytes,1,req,name=executor_info,json=executor_info" json:"executor_info,omitempty"` AgentId *v1.AgentID `protobuf:"bytes,2,req,name=agent_id,json=agent_id" json:"agent_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Response_GetExecutors_Executor) Descriptor ¶
func (*Response_GetExecutors_Executor) Descriptor() ([]byte, []int)
func (*Response_GetExecutors_Executor) GetAgentId ¶
func (m *Response_GetExecutors_Executor) GetAgentId() *v1.AgentID
func (*Response_GetExecutors_Executor) GetExecutorInfo ¶
func (m *Response_GetExecutors_Executor) GetExecutorInfo() *v1.ExecutorInfo
func (*Response_GetExecutors_Executor) ProtoMessage ¶
func (*Response_GetExecutors_Executor) ProtoMessage()
func (*Response_GetExecutors_Executor) Reset ¶
func (m *Response_GetExecutors_Executor) Reset()
func (*Response_GetExecutors_Executor) String ¶
func (m *Response_GetExecutors_Executor) String() string
func (*Response_GetExecutors_Executor) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_GetExecutors_Executor) XXX_DiscardUnknown()
func (*Response_GetExecutors_Executor) XXX_Marshal ¶ added in v1.9.0
func (m *Response_GetExecutors_Executor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_GetExecutors_Executor) XXX_Merge ¶ added in v1.9.0
func (m *Response_GetExecutors_Executor) XXX_Merge(src proto.Message)
func (*Response_GetExecutors_Executor) XXX_Size ¶ added in v1.9.0
func (m *Response_GetExecutors_Executor) XXX_Size() int
func (*Response_GetExecutors_Executor) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_GetExecutors_Executor) XXX_Unmarshal(b []byte) error
type Response_GetFlags ¶
type Response_GetFlags struct { Flags []*v1.Flag `protobuf:"bytes,1,rep,name=flags" json:"flags,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Contains the flag configuration of the master.
func (*Response_GetFlags) Descriptor ¶
func (*Response_GetFlags) Descriptor() ([]byte, []int)
func (*Response_GetFlags) GetFlags ¶
func (m *Response_GetFlags) GetFlags() []*v1.Flag
func (*Response_GetFlags) ProtoMessage ¶
func (*Response_GetFlags) ProtoMessage()
func (*Response_GetFlags) Reset ¶
func (m *Response_GetFlags) Reset()
func (*Response_GetFlags) String ¶
func (m *Response_GetFlags) String() string
func (*Response_GetFlags) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_GetFlags) XXX_DiscardUnknown()
func (*Response_GetFlags) XXX_Marshal ¶ added in v1.9.0
func (m *Response_GetFlags) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_GetFlags) XXX_Merge ¶ added in v1.9.0
func (m *Response_GetFlags) XXX_Merge(src proto.Message)
func (*Response_GetFlags) XXX_Size ¶ added in v1.9.0
func (m *Response_GetFlags) XXX_Size() int
func (*Response_GetFlags) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_GetFlags) XXX_Unmarshal(b []byte) error
type Response_GetFrameworks ¶
type Response_GetFrameworks struct { // Frameworks that have subscribed with the master. Note that this includes // frameworks that are disconnected and in the process of re-subscribing. Frameworks []*Response_GetFrameworks_Framework `protobuf:"bytes,1,rep,name=frameworks" json:"frameworks,omitempty"` // Frameworks that have been teared down. CompletedFrameworks []*Response_GetFrameworks_Framework `protobuf:"bytes,2,rep,name=completed_frameworks,json=completed_frameworks" json:"completed_frameworks,omitempty"` // This field previously contained frameworks that previously // subscribed but haven't yet re-subscribed after a master failover. // As of Mesos 1.2, this field will always be empty; recovered // frameworks are now reported in the `frameworks` list with the // `recovered` field set to true. // // TODO(neilc): Remove this field in Mesos 2.0. RecoveredFrameworks []*v1.FrameworkInfo `protobuf:"bytes,3,rep,name=recovered_frameworks,json=recovered_frameworks" json:"recovered_frameworks,omitempty"` // Deprecated: Do not use. XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Information about all the frameworks known to the master at the current time. Note that there might be frameworks unknown to the master running on partitioned or unsubscribed agents.
func (*Response_GetFrameworks) Descriptor ¶
func (*Response_GetFrameworks) Descriptor() ([]byte, []int)
func (*Response_GetFrameworks) GetCompletedFrameworks ¶
func (m *Response_GetFrameworks) GetCompletedFrameworks() []*Response_GetFrameworks_Framework
func (*Response_GetFrameworks) GetFrameworks ¶
func (m *Response_GetFrameworks) GetFrameworks() []*Response_GetFrameworks_Framework
func (*Response_GetFrameworks) GetRecoveredFrameworks
deprecated
func (m *Response_GetFrameworks) GetRecoveredFrameworks() []*v1.FrameworkInfo
Deprecated: Do not use.
func (*Response_GetFrameworks) ProtoMessage ¶
func (*Response_GetFrameworks) ProtoMessage()
func (*Response_GetFrameworks) Reset ¶
func (m *Response_GetFrameworks) Reset()
func (*Response_GetFrameworks) String ¶
func (m *Response_GetFrameworks) String() string
func (*Response_GetFrameworks) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_GetFrameworks) XXX_DiscardUnknown()
func (*Response_GetFrameworks) XXX_Marshal ¶ added in v1.9.0
func (m *Response_GetFrameworks) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_GetFrameworks) XXX_Merge ¶ added in v1.9.0
func (m *Response_GetFrameworks) XXX_Merge(src proto.Message)
func (*Response_GetFrameworks) XXX_Size ¶ added in v1.9.0
func (m *Response_GetFrameworks) XXX_Size() int
func (*Response_GetFrameworks) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_GetFrameworks) XXX_Unmarshal(b []byte) error
type Response_GetFrameworks_Framework ¶
type Response_GetFrameworks_Framework struct { FrameworkInfo *v1.FrameworkInfo `protobuf:"bytes,1,req,name=framework_info,json=framework_info" json:"framework_info,omitempty"` Active *bool `protobuf:"varint,2,req,name=active" json:"active,omitempty"` Connected *bool `protobuf:"varint,3,req,name=connected" json:"connected,omitempty"` // If true, this framework was previously subscribed but hasn't // yet re-subscribed after a master failover. Recovered frameworks // are only reported if one or more agents running a task or // executor for the framework have reregistered after master // failover. Recovered *bool `protobuf:"varint,11,req,name=recovered" json:"recovered,omitempty"` RegisteredTime *v1.TimeInfo `protobuf:"bytes,4,opt,name=registered_time,json=registered_time" json:"registered_time,omitempty"` ReregisteredTime *v1.TimeInfo `protobuf:"bytes,5,opt,name=reregistered_time,json=reregistered_time" json:"reregistered_time,omitempty"` UnregisteredTime *v1.TimeInfo `protobuf:"bytes,6,opt,name=unregistered_time,json=unregistered_time" json:"unregistered_time,omitempty"` Offers []*v1.Offer `protobuf:"bytes,7,rep,name=offers" json:"offers,omitempty"` InverseOffers []*v1.InverseOffer `protobuf:"bytes,8,rep,name=inverse_offers,json=inverse_offers" json:"inverse_offers,omitempty"` AllocatedResources []*v1.Resource `protobuf:"bytes,9,rep,name=allocated_resources,json=allocated_resources" json:"allocated_resources,omitempty"` OfferedResources []*v1.Resource `protobuf:"bytes,10,rep,name=offered_resources,json=offered_resources" json:"offered_resources,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Response_GetFrameworks_Framework) Descriptor ¶
func (*Response_GetFrameworks_Framework) Descriptor() ([]byte, []int)
func (*Response_GetFrameworks_Framework) GetActive ¶
func (m *Response_GetFrameworks_Framework) GetActive() bool
func (*Response_GetFrameworks_Framework) GetAllocatedResources ¶
func (m *Response_GetFrameworks_Framework) GetAllocatedResources() []*v1.Resource
func (*Response_GetFrameworks_Framework) GetConnected ¶
func (m *Response_GetFrameworks_Framework) GetConnected() bool
func (*Response_GetFrameworks_Framework) GetFrameworkInfo ¶
func (m *Response_GetFrameworks_Framework) GetFrameworkInfo() *v1.FrameworkInfo
func (*Response_GetFrameworks_Framework) GetInverseOffers ¶
func (m *Response_GetFrameworks_Framework) GetInverseOffers() []*v1.InverseOffer
func (*Response_GetFrameworks_Framework) GetOfferedResources ¶
func (m *Response_GetFrameworks_Framework) GetOfferedResources() []*v1.Resource
func (*Response_GetFrameworks_Framework) GetOffers ¶
func (m *Response_GetFrameworks_Framework) GetOffers() []*v1.Offer
func (*Response_GetFrameworks_Framework) GetRecovered ¶
func (m *Response_GetFrameworks_Framework) GetRecovered() bool
func (*Response_GetFrameworks_Framework) GetRegisteredTime ¶
func (m *Response_GetFrameworks_Framework) GetRegisteredTime() *v1.TimeInfo
func (*Response_GetFrameworks_Framework) GetReregisteredTime ¶
func (m *Response_GetFrameworks_Framework) GetReregisteredTime() *v1.TimeInfo
func (*Response_GetFrameworks_Framework) GetUnregisteredTime ¶
func (m *Response_GetFrameworks_Framework) GetUnregisteredTime() *v1.TimeInfo
func (*Response_GetFrameworks_Framework) ProtoMessage ¶
func (*Response_GetFrameworks_Framework) ProtoMessage()
func (*Response_GetFrameworks_Framework) Reset ¶
func (m *Response_GetFrameworks_Framework) Reset()
func (*Response_GetFrameworks_Framework) String ¶
func (m *Response_GetFrameworks_Framework) String() string
func (*Response_GetFrameworks_Framework) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_GetFrameworks_Framework) XXX_DiscardUnknown()
func (*Response_GetFrameworks_Framework) XXX_Marshal ¶ added in v1.9.0
func (m *Response_GetFrameworks_Framework) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_GetFrameworks_Framework) XXX_Merge ¶ added in v1.9.0
func (m *Response_GetFrameworks_Framework) XXX_Merge(src proto.Message)
func (*Response_GetFrameworks_Framework) XXX_Size ¶ added in v1.9.0
func (m *Response_GetFrameworks_Framework) XXX_Size() int
func (*Response_GetFrameworks_Framework) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_GetFrameworks_Framework) XXX_Unmarshal(b []byte) error
type Response_GetHealth ¶
type Response_GetHealth struct { Healthy *bool `protobuf:"varint,1,req,name=healthy" json:"healthy,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
`healthy` would be true if the master is healthy. Delayed responses are also indicative of the poor health of the master.
func (*Response_GetHealth) Descriptor ¶
func (*Response_GetHealth) Descriptor() ([]byte, []int)
func (*Response_GetHealth) GetHealthy ¶
func (m *Response_GetHealth) GetHealthy() bool
func (*Response_GetHealth) ProtoMessage ¶
func (*Response_GetHealth) ProtoMessage()
func (*Response_GetHealth) Reset ¶
func (m *Response_GetHealth) Reset()
func (*Response_GetHealth) String ¶
func (m *Response_GetHealth) String() string
func (*Response_GetHealth) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_GetHealth) XXX_DiscardUnknown()
func (*Response_GetHealth) XXX_Marshal ¶ added in v1.9.0
func (m *Response_GetHealth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_GetHealth) XXX_Merge ¶ added in v1.9.0
func (m *Response_GetHealth) XXX_Merge(src proto.Message)
func (*Response_GetHealth) XXX_Size ¶ added in v1.9.0
func (m *Response_GetHealth) XXX_Size() int
func (*Response_GetHealth) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_GetHealth) XXX_Unmarshal(b []byte) error
type Response_GetLoggingLevel ¶
type Response_GetLoggingLevel struct { Level *uint32 `protobuf:"varint,1,req,name=level" json:"level,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Contains the logging level of the master.
func (*Response_GetLoggingLevel) Descriptor ¶
func (*Response_GetLoggingLevel) Descriptor() ([]byte, []int)
func (*Response_GetLoggingLevel) GetLevel ¶
func (m *Response_GetLoggingLevel) GetLevel() uint32
func (*Response_GetLoggingLevel) ProtoMessage ¶
func (*Response_GetLoggingLevel) ProtoMessage()
func (*Response_GetLoggingLevel) Reset ¶
func (m *Response_GetLoggingLevel) Reset()
func (*Response_GetLoggingLevel) String ¶
func (m *Response_GetLoggingLevel) String() string
func (*Response_GetLoggingLevel) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_GetLoggingLevel) XXX_DiscardUnknown()
func (*Response_GetLoggingLevel) XXX_Marshal ¶ added in v1.9.0
func (m *Response_GetLoggingLevel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_GetLoggingLevel) XXX_Merge ¶ added in v1.9.0
func (m *Response_GetLoggingLevel) XXX_Merge(src proto.Message)
func (*Response_GetLoggingLevel) XXX_Size ¶ added in v1.9.0
func (m *Response_GetLoggingLevel) XXX_Size() int
func (*Response_GetLoggingLevel) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_GetLoggingLevel) XXX_Unmarshal(b []byte) error
type Response_GetMaintenanceSchedule ¶
type Response_GetMaintenanceSchedule struct { Schedule *maintenance.Schedule `protobuf:"bytes,1,req,name=schedule" json:"schedule,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Contains the cluster's maintenance schedule.
func (*Response_GetMaintenanceSchedule) Descriptor ¶
func (*Response_GetMaintenanceSchedule) Descriptor() ([]byte, []int)
func (*Response_GetMaintenanceSchedule) GetSchedule ¶
func (m *Response_GetMaintenanceSchedule) GetSchedule() *maintenance.Schedule
func (*Response_GetMaintenanceSchedule) ProtoMessage ¶
func (*Response_GetMaintenanceSchedule) ProtoMessage()
func (*Response_GetMaintenanceSchedule) Reset ¶
func (m *Response_GetMaintenanceSchedule) Reset()
func (*Response_GetMaintenanceSchedule) String ¶
func (m *Response_GetMaintenanceSchedule) String() string
func (*Response_GetMaintenanceSchedule) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_GetMaintenanceSchedule) XXX_DiscardUnknown()
func (*Response_GetMaintenanceSchedule) XXX_Marshal ¶ added in v1.9.0
func (m *Response_GetMaintenanceSchedule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_GetMaintenanceSchedule) XXX_Merge ¶ added in v1.9.0
func (m *Response_GetMaintenanceSchedule) XXX_Merge(src proto.Message)
func (*Response_GetMaintenanceSchedule) XXX_Size ¶ added in v1.9.0
func (m *Response_GetMaintenanceSchedule) XXX_Size() int
func (*Response_GetMaintenanceSchedule) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_GetMaintenanceSchedule) XXX_Unmarshal(b []byte) error
type Response_GetMaintenanceStatus ¶
type Response_GetMaintenanceStatus struct { Status *maintenance.ClusterStatus `protobuf:"bytes,1,req,name=status" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Contains the cluster's maintenance status.
func (*Response_GetMaintenanceStatus) Descriptor ¶
func (*Response_GetMaintenanceStatus) Descriptor() ([]byte, []int)
func (*Response_GetMaintenanceStatus) GetStatus ¶
func (m *Response_GetMaintenanceStatus) GetStatus() *maintenance.ClusterStatus
func (*Response_GetMaintenanceStatus) ProtoMessage ¶
func (*Response_GetMaintenanceStatus) ProtoMessage()
func (*Response_GetMaintenanceStatus) Reset ¶
func (m *Response_GetMaintenanceStatus) Reset()
func (*Response_GetMaintenanceStatus) String ¶
func (m *Response_GetMaintenanceStatus) String() string
func (*Response_GetMaintenanceStatus) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_GetMaintenanceStatus) XXX_DiscardUnknown()
func (*Response_GetMaintenanceStatus) XXX_Marshal ¶ added in v1.9.0
func (m *Response_GetMaintenanceStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_GetMaintenanceStatus) XXX_Merge ¶ added in v1.9.0
func (m *Response_GetMaintenanceStatus) XXX_Merge(src proto.Message)
func (*Response_GetMaintenanceStatus) XXX_Size ¶ added in v1.9.0
func (m *Response_GetMaintenanceStatus) XXX_Size() int
func (*Response_GetMaintenanceStatus) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_GetMaintenanceStatus) XXX_Unmarshal(b []byte) error
type Response_GetMaster ¶
type Response_GetMaster struct { MasterInfo *v1.MasterInfo `protobuf:"bytes,1,opt,name=master_info,json=master_info" json:"master_info,omitempty"` StartTime *float64 `protobuf:"fixed64,2,opt,name=start_time,json=start_time" json:"start_time,omitempty"` ElectedTime *float64 `protobuf:"fixed64,3,opt,name=elected_time,json=elected_time" json:"elected_time,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Contains the master's information.
func (*Response_GetMaster) Descriptor ¶
func (*Response_GetMaster) Descriptor() ([]byte, []int)
func (*Response_GetMaster) GetElectedTime ¶
func (m *Response_GetMaster) GetElectedTime() float64
func (*Response_GetMaster) GetMasterInfo ¶
func (m *Response_GetMaster) GetMasterInfo() *v1.MasterInfo
func (*Response_GetMaster) GetStartTime ¶
func (m *Response_GetMaster) GetStartTime() float64
func (*Response_GetMaster) ProtoMessage ¶
func (*Response_GetMaster) ProtoMessage()
func (*Response_GetMaster) Reset ¶
func (m *Response_GetMaster) Reset()
func (*Response_GetMaster) String ¶
func (m *Response_GetMaster) String() string
func (*Response_GetMaster) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_GetMaster) XXX_DiscardUnknown()
func (*Response_GetMaster) XXX_Marshal ¶ added in v1.9.0
func (m *Response_GetMaster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_GetMaster) XXX_Merge ¶ added in v1.9.0
func (m *Response_GetMaster) XXX_Merge(src proto.Message)
func (*Response_GetMaster) XXX_Size ¶ added in v1.9.0
func (m *Response_GetMaster) XXX_Size() int
func (*Response_GetMaster) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_GetMaster) XXX_Unmarshal(b []byte) error
type Response_GetMetrics ¶
type Response_GetMetrics struct { Metrics []*v1.Metric `protobuf:"bytes,1,rep,name=metrics" json:"metrics,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Contains a snapshot of the current metrics.
func (*Response_GetMetrics) Descriptor ¶
func (*Response_GetMetrics) Descriptor() ([]byte, []int)
func (*Response_GetMetrics) GetMetrics ¶
func (m *Response_GetMetrics) GetMetrics() []*v1.Metric
func (*Response_GetMetrics) ProtoMessage ¶
func (*Response_GetMetrics) ProtoMessage()
func (*Response_GetMetrics) Reset ¶
func (m *Response_GetMetrics) Reset()
func (*Response_GetMetrics) String ¶
func (m *Response_GetMetrics) String() string
func (*Response_GetMetrics) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_GetMetrics) XXX_DiscardUnknown()
func (*Response_GetMetrics) XXX_Marshal ¶ added in v1.9.0
func (m *Response_GetMetrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_GetMetrics) XXX_Merge ¶ added in v1.9.0
func (m *Response_GetMetrics) XXX_Merge(src proto.Message)
func (*Response_GetMetrics) XXX_Size ¶ added in v1.9.0
func (m *Response_GetMetrics) XXX_Size() int
func (*Response_GetMetrics) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_GetMetrics) XXX_Unmarshal(b []byte) error
type Response_GetOperations ¶
type Response_GetOperations struct { Operations []*v1.Operation `protobuf:"bytes,1,rep,name=operations" json:"operations,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Lists information about all operations known to the master at the current time.
func (*Response_GetOperations) Descriptor ¶
func (*Response_GetOperations) Descriptor() ([]byte, []int)
func (*Response_GetOperations) GetOperations ¶
func (m *Response_GetOperations) GetOperations() []*v1.Operation
func (*Response_GetOperations) ProtoMessage ¶
func (*Response_GetOperations) ProtoMessage()
func (*Response_GetOperations) Reset ¶
func (m *Response_GetOperations) Reset()
func (*Response_GetOperations) String ¶
func (m *Response_GetOperations) String() string
func (*Response_GetOperations) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_GetOperations) XXX_DiscardUnknown()
func (*Response_GetOperations) XXX_Marshal ¶ added in v1.9.0
func (m *Response_GetOperations) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_GetOperations) XXX_Merge ¶ added in v1.9.0
func (m *Response_GetOperations) XXX_Merge(src proto.Message)
func (*Response_GetOperations) XXX_Size ¶ added in v1.9.0
func (m *Response_GetOperations) XXX_Size() int
func (*Response_GetOperations) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_GetOperations) XXX_Unmarshal(b []byte) error
type Response_GetQuota ¶
type Response_GetQuota struct { Status *quota.QuotaStatus `protobuf:"bytes,1,req,name=status" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Contains the cluster's configured quotas.
func (*Response_GetQuota) Descriptor ¶
func (*Response_GetQuota) Descriptor() ([]byte, []int)
func (*Response_GetQuota) GetStatus ¶
func (m *Response_GetQuota) GetStatus() *quota.QuotaStatus
func (*Response_GetQuota) ProtoMessage ¶
func (*Response_GetQuota) ProtoMessage()
func (*Response_GetQuota) Reset ¶
func (m *Response_GetQuota) Reset()
func (*Response_GetQuota) String ¶
func (m *Response_GetQuota) String() string
func (*Response_GetQuota) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_GetQuota) XXX_DiscardUnknown()
func (*Response_GetQuota) XXX_Marshal ¶ added in v1.9.0
func (m *Response_GetQuota) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_GetQuota) XXX_Merge ¶ added in v1.9.0
func (m *Response_GetQuota) XXX_Merge(src proto.Message)
func (*Response_GetQuota) XXX_Size ¶ added in v1.9.0
func (m *Response_GetQuota) XXX_Size() int
func (*Response_GetQuota) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_GetQuota) XXX_Unmarshal(b []byte) error
type Response_GetRoles ¶
type Response_GetRoles struct { Roles []*v1.Role `protobuf:"bytes,1,rep,name=roles" json:"roles,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Provides information about every role that is on the role whitelist (if enabled), has one or more registered frameworks or has a non-default weight or quota.
func (*Response_GetRoles) Descriptor ¶
func (*Response_GetRoles) Descriptor() ([]byte, []int)
func (*Response_GetRoles) GetRoles ¶
func (m *Response_GetRoles) GetRoles() []*v1.Role
func (*Response_GetRoles) ProtoMessage ¶
func (*Response_GetRoles) ProtoMessage()
func (*Response_GetRoles) Reset ¶
func (m *Response_GetRoles) Reset()
func (*Response_GetRoles) String ¶
func (m *Response_GetRoles) String() string
func (*Response_GetRoles) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_GetRoles) XXX_DiscardUnknown()
func (*Response_GetRoles) XXX_Marshal ¶ added in v1.9.0
func (m *Response_GetRoles) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_GetRoles) XXX_Merge ¶ added in v1.9.0
func (m *Response_GetRoles) XXX_Merge(src proto.Message)
func (*Response_GetRoles) XXX_Size ¶ added in v1.9.0
func (m *Response_GetRoles) XXX_Size() int
func (*Response_GetRoles) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_GetRoles) XXX_Unmarshal(b []byte) error
type Response_GetState ¶
type Response_GetState struct { GetTasks *Response_GetTasks `protobuf:"bytes,1,opt,name=get_tasks,json=get_tasks" json:"get_tasks,omitempty"` GetExecutors *Response_GetExecutors `protobuf:"bytes,2,opt,name=get_executors,json=get_executors" json:"get_executors,omitempty"` GetFrameworks *Response_GetFrameworks `protobuf:"bytes,3,opt,name=get_frameworks,json=get_frameworks" json:"get_frameworks,omitempty"` GetAgents *Response_GetAgents `protobuf:"bytes,4,opt,name=get_agents,json=get_agents" json:"get_agents,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Contains full state of the master i.e. information about the tasks, agents, frameworks and executors running in the cluster.
func (*Response_GetState) Descriptor ¶
func (*Response_GetState) Descriptor() ([]byte, []int)
func (*Response_GetState) GetGetAgents ¶
func (m *Response_GetState) GetGetAgents() *Response_GetAgents
func (*Response_GetState) GetGetExecutors ¶
func (m *Response_GetState) GetGetExecutors() *Response_GetExecutors
func (*Response_GetState) GetGetFrameworks ¶
func (m *Response_GetState) GetGetFrameworks() *Response_GetFrameworks
func (*Response_GetState) GetGetTasks ¶
func (m *Response_GetState) GetGetTasks() *Response_GetTasks
func (*Response_GetState) ProtoMessage ¶
func (*Response_GetState) ProtoMessage()
func (*Response_GetState) Reset ¶
func (m *Response_GetState) Reset()
func (*Response_GetState) String ¶
func (m *Response_GetState) String() string
func (*Response_GetState) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_GetState) XXX_DiscardUnknown()
func (*Response_GetState) XXX_Marshal ¶ added in v1.9.0
func (m *Response_GetState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_GetState) XXX_Merge ¶ added in v1.9.0
func (m *Response_GetState) XXX_Merge(src proto.Message)
func (*Response_GetState) XXX_Size ¶ added in v1.9.0
func (m *Response_GetState) XXX_Size() int
func (*Response_GetState) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_GetState) XXX_Unmarshal(b []byte) error
type Response_GetTasks ¶
type Response_GetTasks struct { // Tasks that are enqueued on the master waiting (e.g., authorizing) // to be launched. PendingTasks []*v1.Task `protobuf:"bytes,1,rep,name=pending_tasks,json=pending_tasks" json:"pending_tasks,omitempty"` // Tasks that have been forwarded to the agent for launch. This // includes tasks that are staging or running; it also includes // tasks that have reached a terminal state but the terminal status // update has not yet been acknowledged by the scheduler. Tasks []*v1.Task `protobuf:"bytes,2,rep,name=tasks" json:"tasks,omitempty"` // Tasks that were running on agents that have become partitioned // from the master. If/when the agent is no longer partitioned, // tasks running on that agent will no longer be unreachable (they // will either be running or completed). Note that the master only // stores a limited number of unreachable tasks; information about // unreachable tasks is also not preserved across master failover. UnreachableTasks []*v1.Task `protobuf:"bytes,5,rep,name=unreachable_tasks,json=unreachable_tasks" json:"unreachable_tasks,omitempty"` // Tasks that have reached terminal state and have all their updates // acknowledged by the scheduler. CompletedTasks []*v1.Task `protobuf:"bytes,3,rep,name=completed_tasks,json=completed_tasks" json:"completed_tasks,omitempty"` // As of Mesos 1.3.0, this field is deprecated and will always be empty. // // TODO(neilc): Remove this field in Mesos 2.0. OrphanTasks []*v1.Task `protobuf:"bytes,4,rep,name=orphan_tasks,json=orphan_tasks" json:"orphan_tasks,omitempty"` // Deprecated: Do not use. XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Lists information about all the tasks known to the master at the current time. Note that there might be tasks unknown to the master running on partitioned or unsubscribed agents.
func (*Response_GetTasks) Descriptor ¶
func (*Response_GetTasks) Descriptor() ([]byte, []int)
func (*Response_GetTasks) GetCompletedTasks ¶
func (m *Response_GetTasks) GetCompletedTasks() []*v1.Task
func (*Response_GetTasks) GetOrphanTasks
deprecated
func (m *Response_GetTasks) GetOrphanTasks() []*v1.Task
Deprecated: Do not use.
func (*Response_GetTasks) GetPendingTasks ¶
func (m *Response_GetTasks) GetPendingTasks() []*v1.Task
func (*Response_GetTasks) GetTasks ¶
func (m *Response_GetTasks) GetTasks() []*v1.Task
func (*Response_GetTasks) GetUnreachableTasks ¶
func (m *Response_GetTasks) GetUnreachableTasks() []*v1.Task
func (*Response_GetTasks) ProtoMessage ¶
func (*Response_GetTasks) ProtoMessage()
func (*Response_GetTasks) Reset ¶
func (m *Response_GetTasks) Reset()
func (*Response_GetTasks) String ¶
func (m *Response_GetTasks) String() string
func (*Response_GetTasks) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_GetTasks) XXX_DiscardUnknown()
func (*Response_GetTasks) XXX_Marshal ¶ added in v1.9.0
func (m *Response_GetTasks) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_GetTasks) XXX_Merge ¶ added in v1.9.0
func (m *Response_GetTasks) XXX_Merge(src proto.Message)
func (*Response_GetTasks) XXX_Size ¶ added in v1.9.0
func (m *Response_GetTasks) XXX_Size() int
func (*Response_GetTasks) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_GetTasks) XXX_Unmarshal(b []byte) error
type Response_GetVersion ¶
type Response_GetVersion struct { VersionInfo *v1.VersionInfo `protobuf:"bytes,1,req,name=version_info,json=version_info" json:"version_info,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Contains the version information of the master.
func (*Response_GetVersion) Descriptor ¶
func (*Response_GetVersion) Descriptor() ([]byte, []int)
func (*Response_GetVersion) GetVersionInfo ¶
func (m *Response_GetVersion) GetVersionInfo() *v1.VersionInfo
func (*Response_GetVersion) ProtoMessage ¶
func (*Response_GetVersion) ProtoMessage()
func (*Response_GetVersion) Reset ¶
func (m *Response_GetVersion) Reset()
func (*Response_GetVersion) String ¶
func (m *Response_GetVersion) String() string
func (*Response_GetVersion) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_GetVersion) XXX_DiscardUnknown()
func (*Response_GetVersion) XXX_Marshal ¶ added in v1.9.0
func (m *Response_GetVersion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_GetVersion) XXX_Merge ¶ added in v1.9.0
func (m *Response_GetVersion) XXX_Merge(src proto.Message)
func (*Response_GetVersion) XXX_Size ¶ added in v1.9.0
func (m *Response_GetVersion) XXX_Size() int
func (*Response_GetVersion) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_GetVersion) XXX_Unmarshal(b []byte) error
type Response_GetWeights ¶
type Response_GetWeights struct { WeightInfos []*v1.WeightInfo `protobuf:"bytes,1,rep,name=weight_infos,json=weight_infos" json:"weight_infos,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Provides the weight information about every role.
func (*Response_GetWeights) Descriptor ¶
func (*Response_GetWeights) Descriptor() ([]byte, []int)
func (*Response_GetWeights) GetWeightInfos ¶
func (m *Response_GetWeights) GetWeightInfos() []*v1.WeightInfo
func (*Response_GetWeights) ProtoMessage ¶
func (*Response_GetWeights) ProtoMessage()
func (*Response_GetWeights) Reset ¶
func (m *Response_GetWeights) Reset()
func (*Response_GetWeights) String ¶
func (m *Response_GetWeights) String() string
func (*Response_GetWeights) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_GetWeights) XXX_DiscardUnknown()
func (*Response_GetWeights) XXX_Marshal ¶ added in v1.9.0
func (m *Response_GetWeights) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_GetWeights) XXX_Merge ¶ added in v1.9.0
func (m *Response_GetWeights) XXX_Merge(src proto.Message)
func (*Response_GetWeights) XXX_Size ¶ added in v1.9.0
func (m *Response_GetWeights) XXX_Size() int
func (*Response_GetWeights) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_GetWeights) XXX_Unmarshal(b []byte) error
type Response_ListFiles ¶
type Response_ListFiles struct { FileInfos []*v1.FileInfo `protobuf:"bytes,1,rep,name=file_infos,json=file_infos" json:"file_infos,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Contains the file listing(similar to `ls -l`) for a directory.
func (*Response_ListFiles) Descriptor ¶
func (*Response_ListFiles) Descriptor() ([]byte, []int)
func (*Response_ListFiles) GetFileInfos ¶
func (m *Response_ListFiles) GetFileInfos() []*v1.FileInfo
func (*Response_ListFiles) ProtoMessage ¶
func (*Response_ListFiles) ProtoMessage()
func (*Response_ListFiles) Reset ¶
func (m *Response_ListFiles) Reset()
func (*Response_ListFiles) String ¶
func (m *Response_ListFiles) String() string
func (*Response_ListFiles) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_ListFiles) XXX_DiscardUnknown()
func (*Response_ListFiles) XXX_Marshal ¶ added in v1.9.0
func (m *Response_ListFiles) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_ListFiles) XXX_Merge ¶ added in v1.9.0
func (m *Response_ListFiles) XXX_Merge(src proto.Message)
func (*Response_ListFiles) XXX_Size ¶ added in v1.9.0
func (m *Response_ListFiles) XXX_Size() int
func (*Response_ListFiles) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_ListFiles) XXX_Unmarshal(b []byte) error
type Response_ReadFile ¶
type Response_ReadFile struct { // The size of file (in bytes). Size *uint64 `protobuf:"varint,1,req,name=size" json:"size,omitempty"` Data []byte `protobuf:"bytes,2,req,name=data" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Contains the file data.
func (*Response_ReadFile) Descriptor ¶
func (*Response_ReadFile) Descriptor() ([]byte, []int)
func (*Response_ReadFile) GetData ¶
func (m *Response_ReadFile) GetData() []byte
func (*Response_ReadFile) GetSize ¶
func (m *Response_ReadFile) GetSize() uint64
func (*Response_ReadFile) ProtoMessage ¶
func (*Response_ReadFile) ProtoMessage()
func (*Response_ReadFile) Reset ¶
func (m *Response_ReadFile) Reset()
func (*Response_ReadFile) String ¶
func (m *Response_ReadFile) String() string
func (*Response_ReadFile) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *Response_ReadFile) XXX_DiscardUnknown()
func (*Response_ReadFile) XXX_Marshal ¶ added in v1.9.0
func (m *Response_ReadFile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Response_ReadFile) XXX_Merge ¶ added in v1.9.0
func (m *Response_ReadFile) XXX_Merge(src proto.Message)
func (*Response_ReadFile) XXX_Size ¶ added in v1.9.0
func (m *Response_ReadFile) XXX_Size() int
func (*Response_ReadFile) XXX_Unmarshal ¶ added in v1.9.0
func (m *Response_ReadFile) XXX_Unmarshal(b []byte) error
type Response_Type ¶
type Response_Type int32
Each of the responses of type `FOO` corresponds to `Foo` message below.
const ( Response_UNKNOWN Response_Type = 0 Response_GET_HEALTH Response_Type = 1 Response_GET_FLAGS Response_Type = 2 Response_GET_VERSION Response_Type = 3 Response_GET_METRICS Response_Type = 4 Response_GET_LOGGING_LEVEL Response_Type = 5 Response_LIST_FILES Response_Type = 6 Response_READ_FILE Response_Type = 7 Response_GET_STATE Response_Type = 8 Response_GET_AGENTS Response_Type = 9 Response_GET_FRAMEWORKS Response_Type = 10 Response_GET_EXECUTORS Response_Type = 11 Response_GET_OPERATIONS Response_Type = 19 Response_GET_TASKS Response_Type = 12 Response_GET_ROLES Response_Type = 13 Response_GET_WEIGHTS Response_Type = 14 Response_GET_MASTER Response_Type = 15 Response_GET_MAINTENANCE_STATUS Response_Type = 16 Response_GET_MAINTENANCE_SCHEDULE Response_Type = 17 Response_GET_QUOTA Response_Type = 18 )
func (Response_Type) Enum ¶
func (x Response_Type) Enum() *Response_Type
func (Response_Type) EnumDescriptor ¶
func (Response_Type) EnumDescriptor() ([]byte, []int)
func (Response_Type) String ¶
func (x Response_Type) String() string
func (*Response_Type) UnmarshalJSON ¶
func (x *Response_Type) UnmarshalJSON(data []byte) error