mesos_v1_master

package
v1.9.0 Latest Latest
Warning

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

Go to latest
Published: Jan 26, 2020 License: Apache-2.0 Imports: 7 Imported by: 6

Documentation

Index

Constants

View Source
const Default_Call_DrainAgent_MarkGone bool = false

Variables

View Source
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",
}
View Source
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,
}
View Source
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",
}
View Source
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,
}
View Source
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",
}
View Source
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) Descriptor() ([]byte, []int)

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) GetType

func (m *Call) GetType() Call_Type

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) Reset

func (m *Call) Reset()

func (*Call) String

func (m *Call) String() string

func (*Call) XXX_DiscardUnknown added in v1.9.0

func (m *Call) XXX_DiscardUnknown()

func (*Call) XXX_Marshal added in v1.9.0

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

func (*Call) XXX_Merge added in v1.9.0

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

func (*Call) XXX_Size added in v1.9.0

func (m *Call) XXX_Size() int

func (*Call) XXX_Unmarshal added in v1.9.0

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

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) Enum

func (x Call_Type) Enum() *Call_Type

func (Call_Type) EnumDescriptor

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

func (Call_Type) String

func (x Call_Type) String() string

func (*Call_Type) UnmarshalJSON

func (x *Call_Type) UnmarshalJSON(data []byte) error

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 (*Call_UpdateMaintenanceSchedule) ProtoMessage

func (*Call_UpdateMaintenanceSchedule) ProtoMessage()

func (*Call_UpdateMaintenanceSchedule) Reset

func (m *Call_UpdateMaintenanceSchedule) Reset()

func (*Call_UpdateMaintenanceSchedule) 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) Descriptor() ([]byte, []int)

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) Reset

func (m *Event) Reset()

func (*Event) String

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown added in v1.9.0

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal added in v1.9.0

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

func (*Event) XXX_Merge added in v1.9.0

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

func (*Event) XXX_Size added in v1.9.0

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal added in v1.9.0

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

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 (*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 (*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 (*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) Descriptor() ([]byte, []int)

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) Reset

func (m *Response) Reset()

func (*Response) String

func (m *Response) String() string

func (*Response) XXX_DiscardUnknown added in v1.9.0

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal added in v1.9.0

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

func (*Response) XXX_Merge added in v1.9.0

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

func (*Response) XXX_Size added in v1.9.0

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal added in v1.9.0

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

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 (*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 (*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) Reset

func (*Response_GetAgents_Agent_ResourceProvider) 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 (*Response_GetAgents_Agent_ResourceProvider) XXX_Size added in v1.9.0

func (*Response_GetAgents_Agent_ResourceProvider) XXX_Unmarshal added in v1.9.0

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 (*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 (*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 (*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 (*Response_GetFrameworks_Framework) 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 (*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 (*Response_GetMaintenanceSchedule) ProtoMessage

func (*Response_GetMaintenanceSchedule) ProtoMessage()

func (*Response_GetMaintenanceSchedule) Reset

func (*Response_GetMaintenanceSchedule) 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 (*Response_GetMaintenanceStatus) ProtoMessage

func (*Response_GetMaintenanceStatus) ProtoMessage()

func (*Response_GetMaintenanceStatus) Reset

func (m *Response_GetMaintenanceStatus) Reset()

func (*Response_GetMaintenanceStatus) 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL