mesos_master

package
v0.20.2 Latest Latest
Warning

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

 Go to latest Published: Jan 22, 2021 License: MIT Imports: 6 Imported by: 0

Documentation

Overview

Package mesos_master is a generated protocol buffer package.

It is generated from these files: 

master.proto

It has these top-level messages: 

Call
Response
Event

Index

Constants

This section is empty.

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",
	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",
	23: "GET_MAINTENANCE_STATUS",
	24: "GET_MAINTENANCE_SCHEDULE",
	25: "UPDATE_MAINTENANCE_SCHEDULE",
	26: "START_MAINTENANCE",
	27: "STOP_MAINTENANCE",
	28: "GET_QUOTA",
	29: "SET_QUOTA",
	30: "REMOVE_QUOTA",
}
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_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,
	"GET_MAINTENANCE_STATUS":      23,
	"GET_MAINTENANCE_SCHEDULE":    24,
	"UPDATE_MAINTENANCE_SCHEDULE": 25,
	"START_MAINTENANCE":           26,
	"STOP_MAINTENANCE":            27,
	"GET_QUOTA":                   28,
	"SET_QUOTA":                   29,
	"REMOVE_QUOTA":                30,
}
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",
}
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,
}
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",
	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_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=getMetrics" json:"get_metrics,omitempty"`
	SetLoggingLevel           *Call_SetLoggingLevel           `protobuf:"bytes,3,opt,name=set_logging_level,json=setLoggingLevel" json:"set_logging_level,omitempty"`
	ListFiles                 *Call_ListFiles                 `protobuf:"bytes,4,opt,name=list_files,json=listFiles" json:"list_files,omitempty"`
	ReadFile                  *Call_ReadFile                  `protobuf:"bytes,5,opt,name=read_file,json=readFile" json:"read_file,omitempty"`
	UpdateWeights             *Call_UpdateWeights             `protobuf:"bytes,6,opt,name=update_weights,json=updateWeights" json:"update_weights,omitempty"`
	ReserveResources          *Call_ReserveResources          `protobuf:"bytes,7,opt,name=reserve_resources,json=reserveResources" json:"reserve_resources,omitempty"`
	UnreserveResources        *Call_UnreserveResources        `protobuf:"bytes,8,opt,name=unreserve_resources,json=unreserveResources" json:"unreserve_resources,omitempty"`
	CreateVolumes             *Call_CreateVolumes             `protobuf:"bytes,9,opt,name=create_volumes,json=createVolumes" json:"create_volumes,omitempty"`
	DestroyVolumes            *Call_DestroyVolumes            `protobuf:"bytes,10,opt,name=destroy_volumes,json=destroyVolumes" json:"destroy_volumes,omitempty"`
	UpdateMaintenanceSchedule *Call_UpdateMaintenanceSchedule `` /* 132-byte string literal not displayed */
	StartMaintenance          *Call_StartMaintenance          `protobuf:"bytes,12,opt,name=start_maintenance,json=startMaintenance" json:"start_maintenance,omitempty"`
	StopMaintenance           *Call_StopMaintenance           `protobuf:"bytes,13,opt,name=stop_maintenance,json=stopMaintenance" json:"stop_maintenance,omitempty"`
	SetQuota                  *Call_SetQuota                  `protobuf:"bytes,14,opt,name=set_quota,json=setQuota" json:"set_quota,omitempty"`
	RemoveQuota               *Call_RemoveQuota               `protobuf:"bytes,15,opt,name=remove_quota,json=removeQuota" json:"remove_quota,omitempty"`
	XXX_unrecognized          []byte                          `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) GetDestroyVolumes 

func (m *Call) GetDestroyVolumes() *Call_DestroyVolumes

func (*Call) GetGetMetrics 

func (m *Call) GetGetMetrics() *Call_GetMetrics

func (*Call) GetListFiles 

func (m *Call) GetListFiles() *Call_ListFiles

func (*Call) GetReadFile 

func (m *Call) GetReadFile() *Call_ReadFile

func (*Call) GetRemoveQuota 

func (m *Call) GetRemoveQuota() *Call_RemoveQuota

func (*Call) GetReserveResources 

func (m *Call) GetReserveResources() *Call_ReserveResources

func (*Call) GetSetLoggingLevel 

func (m *Call) GetSetLoggingLevel() *Call_SetLoggingLevel

func (*Call) GetSetQuota 

func (m *Call) GetSetQuota() *Call_SetQuota

func (*Call) GetStartMaintenance 

func (m *Call) GetStartMaintenance() *Call_StartMaintenance

func (*Call) GetStopMaintenance 

func (m *Call) GetStopMaintenance() *Call_StopMaintenance

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

type Call_CreateVolumes 

type Call_CreateVolumes struct {
	AgentId          *mesos.AgentID    `protobuf:"bytes,1,req,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	Volumes          []*mesos.Resource `protobuf:"bytes,2,rep,name=volumes" json:"volumes,omitempty"`
	XXX_unrecognized []byte            `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() *mesos.AgentID

func (*Call_CreateVolumes) GetVolumes 

func (m *Call_CreateVolumes) GetVolumes() []*mesos.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

type Call_DestroyVolumes 

type Call_DestroyVolumes struct {
	AgentId          *mesos.AgentID    `protobuf:"bytes,1,req,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	Volumes          []*mesos.Resource `protobuf:"bytes,2,rep,name=volumes" json:"volumes,omitempty"`
	XXX_unrecognized []byte            `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() *mesos.AgentID

func (*Call_DestroyVolumes) GetVolumes 

func (m *Call_DestroyVolumes) GetVolumes() []*mesos.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

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          *mesos.DurationInfo `protobuf:"bytes,1,opt,name=timeout" json:"timeout,omitempty"`
	XXX_unrecognized []byte              `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() *mesos.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

type Call_ListFiles 

type Call_ListFiles struct {
	Path             *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	XXX_unrecognized []byte  `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

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_unrecognized []byte  `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

type Call_RemoveQuota 

type Call_RemoveQuota struct {
	Role             *string `protobuf:"bytes,1,req,name=role" json:"role,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

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

type Call_ReserveResources 

type Call_ReserveResources struct {
	AgentId          *mesos.AgentID    `protobuf:"bytes,1,req,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	Resources        []*mesos.Resource `protobuf:"bytes,2,rep,name=resources" json:"resources,omitempty"`
	XXX_unrecognized []byte            `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() *mesos.AgentID

func (*Call_ReserveResources) GetResources 

func (m *Call_ReserveResources) GetResources() []*mesos.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

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         *mesos.DurationInfo `protobuf:"bytes,2,req,name=duration" json:"duration,omitempty"`
	XXX_unrecognized []byte              `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() *mesos.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

type Call_SetQuota 

type Call_SetQuota struct {
	QuotaRequest     *mesos_quota.QuotaRequest `protobuf:"bytes,1,req,name=quota_request,json=quotaRequest" json:"quota_request,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

Sets the quota for resources to be used by a particular role.

func (*Call_SetQuota) Descriptor 

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

func (*Call_SetQuota) GetQuotaRequest 

func (m *Call_SetQuota) GetQuotaRequest() *mesos_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

type Call_StartMaintenance 

type Call_StartMaintenance struct {
	Machines         []*mesos.MachineID `protobuf:"bytes,1,rep,name=machines" json:"machines,omitempty"`
	XXX_unrecognized []byte             `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() []*mesos.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

type Call_StopMaintenance 

type Call_StopMaintenance struct {
	Machines         []*mesos.MachineID `protobuf:"bytes,1,rep,name=machines" json:"machines,omitempty"`
	XXX_unrecognized []byte             `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() []*mesos.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

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_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
	// 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_GET_QUOTA                   Call_Type = 28
	Call_SET_QUOTA                   Call_Type = 29
	Call_REMOVE_QUOTA                Call_Type = 30
)

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          *mesos.AgentID    `protobuf:"bytes,1,req,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	Resources        []*mesos.Resource `protobuf:"bytes,2,rep,name=resources" json:"resources,omitempty"`
	XXX_unrecognized []byte            `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() *mesos.AgentID

func (*Call_UnreserveResources) GetResources 

func (m *Call_UnreserveResources) GetResources() []*mesos.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

type Call_UpdateMaintenanceSchedule 

type Call_UpdateMaintenanceSchedule struct {
	Schedule         *mesos_maintenance.Schedule `protobuf:"bytes,1,req,name=schedule" json:"schedule,omitempty"`
	XXX_unrecognized []byte                      `json:"-"`
}

Updates the cluster's maintenance schedule.

func (*Call_UpdateMaintenanceSchedule) Descriptor 

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

func (*Call_UpdateMaintenanceSchedule) GetSchedule 

func (m *Call_UpdateMaintenanceSchedule) GetSchedule() *mesos_maintenance.Schedule

func (*Call_UpdateMaintenanceSchedule) ProtoMessage 

func (*Call_UpdateMaintenanceSchedule) ProtoMessage()

func (*Call_UpdateMaintenanceSchedule) Reset 

func (m *Call_UpdateMaintenanceSchedule) Reset()

func (*Call_UpdateMaintenanceSchedule) String 

func (m *Call_UpdateMaintenanceSchedule) String() string

type Call_UpdateWeights 

type Call_UpdateWeights struct {
	WeightInfos      []*mesos.WeightInfo `protobuf:"bytes,1,rep,name=weight_infos,json=weightInfos" json:"weight_infos,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*Call_UpdateWeights) Descriptor 

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

func (*Call_UpdateWeights) GetWeightInfos 

func (m *Call_UpdateWeights) GetWeightInfos() []*mesos.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

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=taskAdded" json:"task_added,omitempty"`
	TaskUpdated      *Event_TaskUpdated  `protobuf:"bytes,4,opt,name=task_updated,json=taskUpdated" json:"task_updated,omitempty"`
	AgentAdded       *Event_AgentAdded   `protobuf:"bytes,5,opt,name=agent_added,json=agentAdded" json:"agent_added,omitempty"`
	AgentRemoved     *Event_AgentRemoved `protobuf:"bytes,6,opt,name=agent_removed,json=agentRemoved" json:"agent_removed,omitempty"`
	XXX_unrecognized []byte              `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) 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

type Event_AgentAdded 

type Event_AgentAdded struct {
	Agent            *Response_GetAgents_Agent `protobuf:"bytes,1,req,name=agent" json:"agent,omitempty"`
	XXX_unrecognized []byte                    `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 after a master failover.

func (*Event_AgentAdded) Descriptor 

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

func (*Event_AgentAdded) GetAgent 

func (m *Event_AgentAdded) GetAgent() *Response_GetAgents_Agent

func (*Event_AgentAdded) ProtoMessage 

func (*Event_AgentAdded) ProtoMessage()

func (*Event_AgentAdded) Reset 

func (m *Event_AgentAdded) Reset()

func (*Event_AgentAdded) String 

func (m *Event_AgentAdded) String() string

type Event_AgentRemoved 

type Event_AgentRemoved struct {
	AgentId          *mesos.AgentID `protobuf:"bytes,1,req,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

Forwarded by the master when an agent is removed. This can happen when an agent does not re-register within `--agent_reregister_timeout` upon a master failover, or 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() *mesos.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

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=getState" json:"get_state,omitempty"`
	XXX_unrecognized []byte             `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) ProtoMessage 

func (*Event_Subscribed) ProtoMessage()

func (*Event_Subscribed) Reset 

func (m *Event_Subscribed) Reset()

func (*Event_Subscribed) String 

func (m *Event_Subscribed) String() string

type Event_TaskAdded 

type Event_TaskAdded struct {
	Task             *mesos.Task `protobuf:"bytes,1,req,name=task" json:"task,omitempty"`
	XXX_unrecognized []byte      `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() *mesos.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

type Event_TaskUpdated 

type Event_TaskUpdated struct {
	FrameworkId *mesos.FrameworkID `protobuf:"bytes,1,req,name=framework_id,json=frameworkId" json:"framework_id,omitempty"`
	// This is the status of the task corresponding to the last
	// status update acknowledged by the scheduler.
	Status *mesos.TaskStatus `protobuf:"bytes,2,req,name=status" json:"status,omitempty"`
	// This is the latest state of the task according to the agent.
	State            *mesos.TaskState `protobuf:"varint,3,req,name=state,enum=mesos.v1.TaskState" json:"state,omitempty"`
	XXX_unrecognized []byte           `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() *mesos.FrameworkID

func (*Event_TaskUpdated) GetState 

func (m *Event_TaskUpdated) GetState() mesos.TaskState

func (*Event_TaskUpdated) GetStatus 

func (m *Event_TaskUpdated) GetStatus() *mesos.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

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
)

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=getHealth" json:"get_health,omitempty"`
	GetFlags               *Response_GetFlags               `protobuf:"bytes,3,opt,name=get_flags,json=getFlags" json:"get_flags,omitempty"`
	GetVersion             *Response_GetVersion             `protobuf:"bytes,4,opt,name=get_version,json=getVersion" json:"get_version,omitempty"`
	GetMetrics             *Response_GetMetrics             `protobuf:"bytes,5,opt,name=get_metrics,json=getMetrics" json:"get_metrics,omitempty"`
	GetLoggingLevel        *Response_GetLoggingLevel        `protobuf:"bytes,6,opt,name=get_logging_level,json=getLoggingLevel" json:"get_logging_level,omitempty"`
	ListFiles              *Response_ListFiles              `protobuf:"bytes,7,opt,name=list_files,json=listFiles" json:"list_files,omitempty"`
	ReadFile               *Response_ReadFile               `protobuf:"bytes,8,opt,name=read_file,json=readFile" json:"read_file,omitempty"`
	GetState               *Response_GetState               `protobuf:"bytes,9,opt,name=get_state,json=getState" json:"get_state,omitempty"`
	GetAgents              *Response_GetAgents              `protobuf:"bytes,10,opt,name=get_agents,json=getAgents" json:"get_agents,omitempty"`
	GetFrameworks          *Response_GetFrameworks          `protobuf:"bytes,11,opt,name=get_frameworks,json=getFrameworks" json:"get_frameworks,omitempty"`
	GetExecutors           *Response_GetExecutors           `protobuf:"bytes,12,opt,name=get_executors,json=getExecutors" json:"get_executors,omitempty"`
	GetTasks               *Response_GetTasks               `protobuf:"bytes,13,opt,name=get_tasks,json=getTasks" json:"get_tasks,omitempty"`
	GetRoles               *Response_GetRoles               `protobuf:"bytes,14,opt,name=get_roles,json=getRoles" json:"get_roles,omitempty"`
	GetWeights             *Response_GetWeights             `protobuf:"bytes,15,opt,name=get_weights,json=getWeights" json:"get_weights,omitempty"`
	GetMaster              *Response_GetMaster              `protobuf:"bytes,16,opt,name=get_master,json=getMaster" json:"get_master,omitempty"`
	GetMaintenanceStatus   *Response_GetMaintenanceStatus   `protobuf:"bytes,17,opt,name=get_maintenance_status,json=getMaintenanceStatus" json:"get_maintenance_status,omitempty"`
	GetMaintenanceSchedule *Response_GetMaintenanceSchedule `protobuf:"bytes,18,opt,name=get_maintenance_schedule,json=getMaintenanceSchedule" json:"get_maintenance_schedule,omitempty"`
	GetQuota               *Response_GetQuota               `protobuf:"bytes,19,opt,name=get_quota,json=getQuota" json:"get_quota,omitempty"`
	XXX_unrecognized       []byte                           `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) 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

type Response_GetAgents 

type Response_GetAgents struct {
	// Registered agents.
	Agents           []*Response_GetAgents_Agent `protobuf:"bytes,1,rep,name=agents" json:"agents,omitempty"`
	XXX_unrecognized []byte                      `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) ProtoMessage 

func (*Response_GetAgents) ProtoMessage()

func (*Response_GetAgents) Reset 

func (m *Response_GetAgents) Reset()

func (*Response_GetAgents) String 

func (m *Response_GetAgents) String() string

type Response_GetAgents_Agent 

type Response_GetAgents_Agent struct {
	AgentInfo        *mesos.AgentInfo `protobuf:"bytes,1,req,name=agent_info,json=agentInfo" json:"agent_info,omitempty"`
	Active           *bool            `protobuf:"varint,2,req,name=active" json:"active,omitempty"`
	Version          *string          `protobuf:"bytes,3,req,name=version" json:"version,omitempty"`
	Pid              *string          `protobuf:"bytes,4,opt,name=pid" json:"pid,omitempty"`
	RegisteredTime   *mesos.TimeInfo  `protobuf:"bytes,5,opt,name=registered_time,json=registeredTime" json:"registered_time,omitempty"`
	ReregisteredTime *mesos.TimeInfo  `protobuf:"bytes,6,opt,name=reregistered_time,json=reregisteredTime" json:"reregistered_time,omitempty"`
	// Total resources (including oversubscribed resources) the agent
	// provides.
	TotalResources     []*mesos.Resource `protobuf:"bytes,7,rep,name=total_resources,json=totalResources" json:"total_resources,omitempty"`
	AllocatedResources []*mesos.Resource `protobuf:"bytes,8,rep,name=allocated_resources,json=allocatedResources" json:"allocated_resources,omitempty"`
	OfferedResources   []*mesos.Resource `protobuf:"bytes,9,rep,name=offered_resources,json=offeredResources" json:"offered_resources,omitempty"`
	XXX_unrecognized   []byte            `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() *mesos.AgentInfo

func (*Response_GetAgents_Agent) GetAllocatedResources 

func (m *Response_GetAgents_Agent) GetAllocatedResources() []*mesos.Resource

func (*Response_GetAgents_Agent) GetOfferedResources 

func (m *Response_GetAgents_Agent) GetOfferedResources() []*mesos.Resource

func (*Response_GetAgents_Agent) GetPid 

func (m *Response_GetAgents_Agent) GetPid() string

func (*Response_GetAgents_Agent) GetRegisteredTime 

func (m *Response_GetAgents_Agent) GetRegisteredTime() *mesos.TimeInfo

func (*Response_GetAgents_Agent) GetReregisteredTime 

func (m *Response_GetAgents_Agent) GetReregisteredTime() *mesos.TimeInfo

func (*Response_GetAgents_Agent) GetTotalResources 

func (m *Response_GetAgents_Agent) GetTotalResources() []*mesos.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

type Response_GetExecutors 

type Response_GetExecutors struct {
	Executors        []*Response_GetExecutors_Executor `protobuf:"bytes,1,rep,name=executors" json:"executors,omitempty"`
	OrphanExecutors  []*Response_GetExecutors_Executor `protobuf:"bytes,2,rep,name=orphan_executors,json=orphanExecutors" json:"orphan_executors,omitempty"`
	XXX_unrecognized []byte                            `json:"-"`
}

Lists information about all the executors known to the master at the current time. Note that there might be executors unknown to the master running on partitioned or unsubscribed agents.

func (*Response_GetExecutors) Descriptor 

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

func (*Response_GetExecutors) GetExecutors 

func (m *Response_GetExecutors) GetExecutors() []*Response_GetExecutors_Executor

func (*Response_GetExecutors) GetOrphanExecutors 

func (m *Response_GetExecutors) GetOrphanExecutors() []*Response_GetExecutors_Executor

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

type Response_GetExecutors_Executor 

type Response_GetExecutors_Executor struct {
	ExecutorInfo     *mesos.ExecutorInfo `protobuf:"bytes,1,req,name=executor_info,json=executorInfo" json:"executor_info,omitempty"`
	AgentId          *mesos.AgentID      `protobuf:"bytes,2,req,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*Response_GetExecutors_Executor) Descriptor 

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

func (*Response_GetExecutors_Executor) GetAgentId 

func (m *Response_GetExecutors_Executor) GetAgentId() *mesos.AgentID

func (*Response_GetExecutors_Executor) GetExecutorInfo 

func (m *Response_GetExecutors_Executor) GetExecutorInfo() *mesos.ExecutorInfo

func (*Response_GetExecutors_Executor) ProtoMessage 

func (*Response_GetExecutors_Executor) ProtoMessage()

func (*Response_GetExecutors_Executor) Reset 

func (m *Response_GetExecutors_Executor) Reset()

func (*Response_GetExecutors_Executor) String 

func (m *Response_GetExecutors_Executor) String() string

type Response_GetFlags 

type Response_GetFlags struct {
	Flags            []*mesos.Flag `protobuf:"bytes,1,rep,name=flags" json:"flags,omitempty"`
	XXX_unrecognized []byte        `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() []*mesos.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

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=completedFrameworks" json:"completed_frameworks,omitempty"`
	// Frameworks that have previously subscribed but haven't yet subscribed
	// after a master failover.
	RecoveredFrameworks []*mesos.FrameworkInfo `protobuf:"bytes,3,rep,name=recovered_frameworks,json=recoveredFrameworks" json:"recovered_frameworks,omitempty"`
	XXX_unrecognized    []byte                 `json:"-"`
}

Information about all the frameworks known to the master at the current time. Note that there might be frameworks unknown to the master running on partitioned or unsubscribed agents.

func (*Response_GetFrameworks) Descriptor 

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

func (*Response_GetFrameworks) GetCompletedFrameworks 

func (m *Response_GetFrameworks) GetCompletedFrameworks() []*Response_GetFrameworks_Framework

func (*Response_GetFrameworks) GetFrameworks 

func (m *Response_GetFrameworks) GetFrameworks() []*Response_GetFrameworks_Framework

func (*Response_GetFrameworks) GetRecoveredFrameworks 

func (m *Response_GetFrameworks) GetRecoveredFrameworks() []*mesos.FrameworkInfo

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

type Response_GetFrameworks_Framework 

type Response_GetFrameworks_Framework struct {
	FrameworkInfo      *mesos.FrameworkInfo  `protobuf:"bytes,1,req,name=framework_info,json=frameworkInfo" 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"`
	RegisteredTime     *mesos.TimeInfo       `protobuf:"bytes,4,opt,name=registered_time,json=registeredTime" json:"registered_time,omitempty"`
	ReregisteredTime   *mesos.TimeInfo       `protobuf:"bytes,5,opt,name=reregistered_time,json=reregisteredTime" json:"reregistered_time,omitempty"`
	UnregisteredTime   *mesos.TimeInfo       `protobuf:"bytes,6,opt,name=unregistered_time,json=unregisteredTime" json:"unregistered_time,omitempty"`
	Offers             []*mesos.Offer        `protobuf:"bytes,7,rep,name=offers" json:"offers,omitempty"`
	InverseOffers      []*mesos.InverseOffer `protobuf:"bytes,8,rep,name=inverse_offers,json=inverseOffers" json:"inverse_offers,omitempty"`
	AllocatedResources []*mesos.Resource     `protobuf:"bytes,9,rep,name=allocated_resources,json=allocatedResources" json:"allocated_resources,omitempty"`
	OfferedResources   []*mesos.Resource     `protobuf:"bytes,10,rep,name=offered_resources,json=offeredResources" json:"offered_resources,omitempty"`
	XXX_unrecognized   []byte                `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() []*mesos.Resource

func (*Response_GetFrameworks_Framework) GetConnected 

func (m *Response_GetFrameworks_Framework) GetConnected() bool

func (*Response_GetFrameworks_Framework) GetFrameworkInfo 

func (m *Response_GetFrameworks_Framework) GetFrameworkInfo() *mesos.FrameworkInfo

func (*Response_GetFrameworks_Framework) GetInverseOffers 

func (m *Response_GetFrameworks_Framework) GetInverseOffers() []*mesos.InverseOffer

func (*Response_GetFrameworks_Framework) GetOfferedResources 

func (m *Response_GetFrameworks_Framework) GetOfferedResources() []*mesos.Resource

func (*Response_GetFrameworks_Framework) GetOffers 

func (m *Response_GetFrameworks_Framework) GetOffers() []*mesos.Offer

func (*Response_GetFrameworks_Framework) GetRegisteredTime 

func (m *Response_GetFrameworks_Framework) GetRegisteredTime() *mesos.TimeInfo

func (*Response_GetFrameworks_Framework) GetReregisteredTime 

func (m *Response_GetFrameworks_Framework) GetReregisteredTime() *mesos.TimeInfo

func (*Response_GetFrameworks_Framework) GetUnregisteredTime 

func (m *Response_GetFrameworks_Framework) GetUnregisteredTime() *mesos.TimeInfo

func (*Response_GetFrameworks_Framework) ProtoMessage 

func (*Response_GetFrameworks_Framework) ProtoMessage()

func (*Response_GetFrameworks_Framework) Reset 

func (m *Response_GetFrameworks_Framework) Reset()

func (*Response_GetFrameworks_Framework) String 

func (m *Response_GetFrameworks_Framework) String() string

type Response_GetHealth 

type Response_GetHealth struct {
	Healthy          *bool  `protobuf:"varint,1,req,name=healthy" json:"healthy,omitempty"`
	XXX_unrecognized []byte `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

type Response_GetLoggingLevel 

type Response_GetLoggingLevel struct {
	Level            *uint32 `protobuf:"varint,1,req,name=level" json:"level,omitempty"`
	XXX_unrecognized []byte  `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

type Response_GetMaintenanceSchedule 

type Response_GetMaintenanceSchedule struct {
	Schedule         *mesos_maintenance.Schedule `protobuf:"bytes,1,req,name=schedule" json:"schedule,omitempty"`
	XXX_unrecognized []byte                      `json:"-"`
}

Contains the cluster's maintenance schedule.

func (*Response_GetMaintenanceSchedule) Descriptor 

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

func (*Response_GetMaintenanceSchedule) GetSchedule 

func (m *Response_GetMaintenanceSchedule) GetSchedule() *mesos_maintenance.Schedule

func (*Response_GetMaintenanceSchedule) ProtoMessage 

func (*Response_GetMaintenanceSchedule) ProtoMessage()

func (*Response_GetMaintenanceSchedule) Reset 

func (m *Response_GetMaintenanceSchedule) Reset()

func (*Response_GetMaintenanceSchedule) String 

func (m *Response_GetMaintenanceSchedule) String() string

type Response_GetMaintenanceStatus 

type Response_GetMaintenanceStatus struct {
	Status           *mesos_maintenance.ClusterStatus `protobuf:"bytes,1,req,name=status" json:"status,omitempty"`
	XXX_unrecognized []byte                           `json:"-"`
}

Contains the cluster's maintenance status.

func (*Response_GetMaintenanceStatus) Descriptor 

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

func (*Response_GetMaintenanceStatus) GetStatus 

func (m *Response_GetMaintenanceStatus) GetStatus() *mesos_maintenance.ClusterStatus

func (*Response_GetMaintenanceStatus) ProtoMessage 

func (*Response_GetMaintenanceStatus) ProtoMessage()

func (*Response_GetMaintenanceStatus) Reset 

func (m *Response_GetMaintenanceStatus) Reset()

func (*Response_GetMaintenanceStatus) String 

func (m *Response_GetMaintenanceStatus) String() string

type Response_GetMaster 

type Response_GetMaster struct {
	MasterInfo       *mesos.MasterInfo `protobuf:"bytes,1,opt,name=master_info,json=masterInfo" json:"master_info,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

Contains the master's information.

func (*Response_GetMaster) Descriptor 

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

func (*Response_GetMaster) GetMasterInfo 

func (m *Response_GetMaster) GetMasterInfo() *mesos.MasterInfo

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

type Response_GetMetrics 

type Response_GetMetrics struct {
	Metrics          []*mesos.Metric `protobuf:"bytes,1,rep,name=metrics" json:"metrics,omitempty"`
	XXX_unrecognized []byte          `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() []*mesos.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

type Response_GetQuota 

type Response_GetQuota struct {
	Status           *mesos_quota.QuotaStatus `protobuf:"bytes,1,req,name=status" json:"status,omitempty"`
	XXX_unrecognized []byte                   `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() *mesos_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

type Response_GetRoles 

type Response_GetRoles struct {
	Roles            []*mesos.Role `protobuf:"bytes,1,rep,name=roles" json:"roles,omitempty"`
	XXX_unrecognized []byte        `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() []*mesos.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

type Response_GetState 

type Response_GetState struct {
	GetTasks         *Response_GetTasks      `protobuf:"bytes,1,opt,name=get_tasks,json=getTasks" json:"get_tasks,omitempty"`
	GetExecutors     *Response_GetExecutors  `protobuf:"bytes,2,opt,name=get_executors,json=getExecutors" json:"get_executors,omitempty"`
	GetFrameworks    *Response_GetFrameworks `protobuf:"bytes,3,opt,name=get_frameworks,json=getFrameworks" json:"get_frameworks,omitempty"`
	GetAgents        *Response_GetAgents     `protobuf:"bytes,4,opt,name=get_agents,json=getAgents" json:"get_agents,omitempty"`
	XXX_unrecognized []byte                  `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

type Response_GetTasks 

type Response_GetTasks struct {
	// Tasks that are an enqueued on the master waiting (e.g., authorizing)
	// to be launched.
	PendingTasks []*mesos.Task `protobuf:"bytes,1,rep,name=pending_tasks,json=pendingTasks" json:"pending_tasks,omitempty"`
	// Tasks that have been forwarded to the agent for launch. This includes
	// tasks that are running and reached terminal state.
	Tasks []*mesos.Task `protobuf:"bytes,2,rep,name=tasks" json:"tasks,omitempty"`
	// Tasks that have reached terminal state and have all their updates
	// acknowledged by the scheduler.
	CompletedTasks []*mesos.Task `protobuf:"bytes,3,rep,name=completed_tasks,json=completedTasks" json:"completed_tasks,omitempty"`
	// Tasks belonging to frameworks that have not yet re-subscribed with
	// master (e.g., immediately after master failover).
	OrphanTasks      []*mesos.Task `protobuf:"bytes,4,rep,name=orphan_tasks,json=orphanTasks" json:"orphan_tasks,omitempty"`
	XXX_unrecognized []byte        `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() []*mesos.Task

func (*Response_GetTasks) GetOrphanTasks 

func (m *Response_GetTasks) GetOrphanTasks() []*mesos.Task

func (*Response_GetTasks) GetPendingTasks 

func (m *Response_GetTasks) GetPendingTasks() []*mesos.Task

func (*Response_GetTasks) GetTasks 

func (m *Response_GetTasks) GetTasks() []*mesos.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

type Response_GetVersion 

type Response_GetVersion struct {
	VersionInfo      *mesos.VersionInfo `protobuf:"bytes,1,req,name=version_info,json=versionInfo" json:"version_info,omitempty"`
	XXX_unrecognized []byte             `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() *mesos.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

type Response_GetWeights 

type Response_GetWeights struct {
	WeightInfos      []*mesos.WeightInfo `protobuf:"bytes,1,rep,name=weight_infos,json=weightInfos" json:"weight_infos,omitempty"`
	XXX_unrecognized []byte              `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() []*mesos.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

type Response_ListFiles 

type Response_ListFiles struct {
	FileInfos        []*mesos.FileInfo `protobuf:"bytes,1,rep,name=file_infos,json=fileInfos" json:"file_infos,omitempty"`
	XXX_unrecognized []byte            `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() []*mesos.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

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_unrecognized []byte  `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

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_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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.