master

package
v0.0.11 Latest Latest
Warning

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

 Go to latest Published: May 15, 2020 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Package master is a generated protocol buffer package.

It is generated from these files: 

master/master.proto

It has these top-level messages: 

Call
Response
Event

Index

Constants

View Source 
const Default_Call_DrainAgent_MarkGone bool = false

Variables

View Source 
var (
	ErrInvalidLengthMaster = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMaster   = fmt.Errorf("proto: integer overflow")
)
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.master.Call_Type" json:"type"`
	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"`
	GrowVolume                *Call_GrowVolume                `protobuf:"bytes,18,opt,name=grow_volume,json=growVolume" json:"grow_volume,omitempty"`
	ShrinkVolume              *Call_ShrinkVolume              `protobuf:"bytes,19,opt,name=shrink_volume,json=shrinkVolume" json:"shrink_volume,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"`
	DrainAgent                *Call_DrainAgent                `protobuf:"bytes,21,opt,name=drain_agent,json=drainAgent" json:"drain_agent,omitempty"`
	DeactivateAgent           *Call_DeactivateAgent           `protobuf:"bytes,22,opt,name=deactivate_agent,json=deactivateAgent" json:"deactivate_agent,omitempty"`
	ReactivateAgent           *Call_ReactivateAgent           `protobuf:"bytes,23,opt,name=reactivate_agent,json=reactivateAgent" json:"reactivate_agent,omitempty"`
	UpdateQuota               *Call_UpdateQuota               `protobuf:"bytes,20,opt,name=update_quota,json=updateQuota" 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=markAgentGone" json:"mark_agent_gone,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"`
}

* 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 NewPopulatedCall 

func NewPopulatedCall(r randyMaster, easy bool) *Call

func (*Call) Descriptor 

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

func (*Call) Equal 

func (this *Call) Equal(that interface{}) bool

func (*Call) GetCreateVolumes 

func (m *Call) GetCreateVolumes() *Call_CreateVolumes

func (*Call) GetDeactivateAgent added in v0.0.11 

func (m *Call) GetDeactivateAgent() *Call_DeactivateAgent

func (*Call) GetDestroyVolumes 

func (m *Call) GetDestroyVolumes() *Call_DestroyVolumes

func (*Call) GetDrainAgent added in v0.0.11 

func (m *Call) GetDrainAgent() *Call_DrainAgent

func (*Call) GetGetMetrics 

func (m *Call) GetGetMetrics() *Call_GetMetrics

func (*Call) GetGrowVolume added in v0.0.8 

func (m *Call) GetGrowVolume() *Call_GrowVolume

func (*Call) GetListFiles 

func (m *Call) GetListFiles() *Call_ListFiles

func (*Call) GetMarkAgentGone added in v0.0.7 

func (m *Call) GetMarkAgentGone() *Call_MarkAgentGone

func (*Call) GetReactivateAgent added in v0.0.11 

func (m *Call) GetReactivateAgent() *Call_ReactivateAgent

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) GetShrinkVolume added in v0.0.8 

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

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 v0.0.10 

func (m *Call) GetUpdateQuota() *Call_UpdateQuota

func (*Call) GetUpdateWeights 

func (m *Call) GetUpdateWeights() *Call_UpdateWeights

func (*Call) GoString 

func (this *Call) GoString() string

func (*Call) Marshal 

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

func (*Call) MarshalJSON 

func (mj *Call) MarshalJSON() ([]byte, error)

func (*Call) MarshalJSONBuf 

func (mj *Call) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call) MarshalTo 

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

func (*Call) ProtoMessage 

func (*Call) ProtoMessage()

func (*Call) Reset 

func (m *Call) Reset()

func (*Call) Size added in v0.0.11 

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

func (*Call) String 

func (this *Call) String() string

func (*Call) Unmarshal 

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

func (*Call) UnmarshalJSON 

func (uj *Call) UnmarshalJSON(input []byte) error

func (*Call) UnmarshalJSONFFLexer 

func (uj *Call) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call) VerboseEqual 

func (this *Call) VerboseEqual(that interface{}) error

type Call_CreateVolumes 

type Call_CreateVolumes struct {
	AgentID mesos.AgentID    `protobuf:"bytes,1,req,name=agent_id,json=agentId" json:"agent_id"`
	Volumes []mesos.Resource `protobuf:"bytes,2,rep,name=volumes" json:"volumes"`
}

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 NewPopulatedCall_CreateVolumes 

func NewPopulatedCall_CreateVolumes(r randyMaster, easy bool) *Call_CreateVolumes

func (*Call_CreateVolumes) Descriptor 

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

func (*Call_CreateVolumes) Equal 

func (this *Call_CreateVolumes) Equal(that interface{}) bool

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

func (this *Call_CreateVolumes) GoString() string

func (*Call_CreateVolumes) Marshal 

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

func (*Call_CreateVolumes) MarshalJSON 

func (mj *Call_CreateVolumes) MarshalJSON() ([]byte, error)

func (*Call_CreateVolumes) MarshalJSONBuf 

func (mj *Call_CreateVolumes) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_CreateVolumes) MarshalTo 

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

func (*Call_CreateVolumes) ProtoMessage 

func (*Call_CreateVolumes) ProtoMessage()

func (*Call_CreateVolumes) Reset 

func (m *Call_CreateVolumes) Reset()

func (*Call_CreateVolumes) Size added in v0.0.11 

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

func (*Call_CreateVolumes) String 

func (this *Call_CreateVolumes) String() string

func (*Call_CreateVolumes) Unmarshal 

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

func (*Call_CreateVolumes) UnmarshalJSON 

func (uj *Call_CreateVolumes) UnmarshalJSON(input []byte) error

func (*Call_CreateVolumes) UnmarshalJSONFFLexer 

func (uj *Call_CreateVolumes) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call_CreateVolumes) VerboseEqual 

func (this *Call_CreateVolumes) VerboseEqual(that interface{}) error

type Call_DeactivateAgent added in v0.0.11 

type Call_DeactivateAgent struct {
	AgentID mesos.AgentID `protobuf:"bytes,1,req,name=agent_id,json=agentId" json:"agent_id"`
}

EXPERIMENTAL.

Turns off offers for a specific agent. A deactivated agent will continue to run tasks and communicate statuses with the master.

func NewPopulatedCall_DeactivateAgent added in v0.0.11 

func NewPopulatedCall_DeactivateAgent(r randyMaster, easy bool) *Call_DeactivateAgent

func (*Call_DeactivateAgent) Descriptor added in v0.0.11 

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

func (*Call_DeactivateAgent) Equal added in v0.0.11 

func (this *Call_DeactivateAgent) Equal(that interface{}) bool

func (*Call_DeactivateAgent) GetAgentID added in v0.0.11 

func (m *Call_DeactivateAgent) GetAgentID() mesos.AgentID

func (*Call_DeactivateAgent) GoString added in v0.0.11 

func (this *Call_DeactivateAgent) GoString() string

func (*Call_DeactivateAgent) Marshal added in v0.0.11 

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

func (*Call_DeactivateAgent) MarshalJSON added in v0.0.11 

func (mj *Call_DeactivateAgent) MarshalJSON() ([]byte, error)

func (*Call_DeactivateAgent) MarshalJSONBuf added in v0.0.11 

func (mj *Call_DeactivateAgent) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_DeactivateAgent) MarshalTo added in v0.0.11 

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

func (*Call_DeactivateAgent) ProtoMessage added in v0.0.11 

func (*Call_DeactivateAgent) ProtoMessage()

func (*Call_DeactivateAgent) Reset added in v0.0.11 

func (m *Call_DeactivateAgent) Reset()

func (*Call_DeactivateAgent) Size added in v0.0.11 

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

func (*Call_DeactivateAgent) String added in v0.0.11 

func (this *Call_DeactivateAgent) String() string

func (*Call_DeactivateAgent) Unmarshal added in v0.0.11 

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

func (*Call_DeactivateAgent) UnmarshalJSON added in v0.0.11 

func (uj *Call_DeactivateAgent) UnmarshalJSON(input []byte) error

func (*Call_DeactivateAgent) UnmarshalJSONFFLexer added in v0.0.11 

func (uj *Call_DeactivateAgent) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call_DeactivateAgent) VerboseEqual added in v0.0.11 

func (this *Call_DeactivateAgent) VerboseEqual(that interface{}) error

type Call_DestroyVolumes 

type Call_DestroyVolumes struct {
	AgentID mesos.AgentID    `protobuf:"bytes,1,req,name=agent_id,json=agentId" json:"agent_id"`
	Volumes []mesos.Resource `protobuf:"bytes,2,rep,name=volumes" json:"volumes"`
}

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 NewPopulatedCall_DestroyVolumes 

func NewPopulatedCall_DestroyVolumes(r randyMaster, easy bool) *Call_DestroyVolumes

func (*Call_DestroyVolumes) Descriptor 

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

func (*Call_DestroyVolumes) Equal 

func (this *Call_DestroyVolumes) Equal(that interface{}) bool

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

func (this *Call_DestroyVolumes) GoString() string

func (*Call_DestroyVolumes) Marshal 

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

func (*Call_DestroyVolumes) MarshalJSON 

func (mj *Call_DestroyVolumes) MarshalJSON() ([]byte, error)

func (*Call_DestroyVolumes) MarshalJSONBuf 

func (mj *Call_DestroyVolumes) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_DestroyVolumes) MarshalTo 

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

func (*Call_DestroyVolumes) ProtoMessage 

func (*Call_DestroyVolumes) ProtoMessage()

func (*Call_DestroyVolumes) Reset 

func (m *Call_DestroyVolumes) Reset()

func (*Call_DestroyVolumes) Size added in v0.0.11 

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

func (*Call_DestroyVolumes) String 

func (this *Call_DestroyVolumes) String() string

func (*Call_DestroyVolumes) Unmarshal 

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

func (*Call_DestroyVolumes) UnmarshalJSON 

func (uj *Call_DestroyVolumes) UnmarshalJSON(input []byte) error

func (*Call_DestroyVolumes) UnmarshalJSONFFLexer 

func (uj *Call_DestroyVolumes) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call_DestroyVolumes) VerboseEqual 

func (this *Call_DestroyVolumes) VerboseEqual(that interface{}) error

type Call_DrainAgent added in v0.0.11 

type Call_DrainAgent struct {
	AgentID mesos.AgentID `protobuf:"bytes,1,req,name=agent_id,json=agentId" json:"agent_id"`
	// 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 *google_protobuf.Duration `protobuf:"bytes,2,opt,name=max_grace_period,json=maxGracePeriod" 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=markGone,def=0" json:"mark_gone,omitempty"`
}

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 NewPopulatedCall_DrainAgent added in v0.0.11 

func NewPopulatedCall_DrainAgent(r randyMaster, easy bool) *Call_DrainAgent

func (*Call_DrainAgent) Descriptor added in v0.0.11 

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

func (*Call_DrainAgent) Equal added in v0.0.11 

func (this *Call_DrainAgent) Equal(that interface{}) bool

func (*Call_DrainAgent) GetAgentID added in v0.0.11 

func (m *Call_DrainAgent) GetAgentID() mesos.AgentID

func (*Call_DrainAgent) GetMarkGone added in v0.0.11 

func (m *Call_DrainAgent) GetMarkGone() bool

func (*Call_DrainAgent) GetMaxGracePeriod added in v0.0.11 

func (m *Call_DrainAgent) GetMaxGracePeriod() *google_protobuf.Duration

func (*Call_DrainAgent) GoString added in v0.0.11 

func (this *Call_DrainAgent) GoString() string

func (*Call_DrainAgent) Marshal added in v0.0.11 

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

func (*Call_DrainAgent) MarshalJSON added in v0.0.11 

func (mj *Call_DrainAgent) MarshalJSON() ([]byte, error)

func (*Call_DrainAgent) MarshalJSONBuf added in v0.0.11 

func (mj *Call_DrainAgent) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_DrainAgent) MarshalTo added in v0.0.11 

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

func (*Call_DrainAgent) ProtoMessage added in v0.0.11 

func (*Call_DrainAgent) ProtoMessage()

func (*Call_DrainAgent) Reset added in v0.0.11 

func (m *Call_DrainAgent) Reset()

func (*Call_DrainAgent) Size added in v0.0.11 

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

func (*Call_DrainAgent) String added in v0.0.11 

func (this *Call_DrainAgent) String() string

func (*Call_DrainAgent) Unmarshal added in v0.0.11 

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

func (*Call_DrainAgent) UnmarshalJSON added in v0.0.11 

func (uj *Call_DrainAgent) UnmarshalJSON(input []byte) error

func (*Call_DrainAgent) UnmarshalJSONFFLexer added in v0.0.11 

func (uj *Call_DrainAgent) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call_DrainAgent) VerboseEqual added in v0.0.11 

func (this *Call_DrainAgent) VerboseEqual(that interface{}) 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 *mesos.DurationInfo `protobuf:"bytes,1,opt,name=timeout" json:"timeout,omitempty"`
}

Provides a snapshot of the current metrics tracked by the master.

func NewPopulatedCall_GetMetrics 

func NewPopulatedCall_GetMetrics(r randyMaster, easy bool) *Call_GetMetrics

func (*Call_GetMetrics) Descriptor 

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

func (*Call_GetMetrics) Equal 

func (this *Call_GetMetrics) Equal(that interface{}) bool

func (*Call_GetMetrics) GetTimeout 

func (m *Call_GetMetrics) GetTimeout() *mesos.DurationInfo

func (*Call_GetMetrics) GoString 

func (this *Call_GetMetrics) GoString() string

func (*Call_GetMetrics) Marshal 

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

func (*Call_GetMetrics) MarshalJSON 

func (mj *Call_GetMetrics) MarshalJSON() ([]byte, error)

func (*Call_GetMetrics) MarshalJSONBuf 

func (mj *Call_GetMetrics) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_GetMetrics) MarshalTo 

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

func (*Call_GetMetrics) ProtoMessage 

func (*Call_GetMetrics) ProtoMessage()

func (*Call_GetMetrics) Reset 

func (m *Call_GetMetrics) Reset()

func (*Call_GetMetrics) Size added in v0.0.11 

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

func (*Call_GetMetrics) String 

func (this *Call_GetMetrics) String() string

func (*Call_GetMetrics) Unmarshal 

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

func (*Call_GetMetrics) UnmarshalJSON 

func (uj *Call_GetMetrics) UnmarshalJSON(input []byte) error

func (*Call_GetMetrics) UnmarshalJSONFFLexer 

func (uj *Call_GetMetrics) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call_GetMetrics) VerboseEqual 

func (this *Call_GetMetrics) VerboseEqual(that interface{}) error

type Call_GrowVolume added in v0.0.8 

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  *mesos.AgentID `protobuf:"bytes,1,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	Volume   mesos.Resource `protobuf:"bytes,2,req,name=volume" json:"volume"`
	Addition mesos.Resource `protobuf:"bytes,3,req,name=addition" json:"addition"`
}

Grow a volume by an additional disk resource. NOTE: This is currently experimental and only for persistent volumes created on ROOT/PATH disks.

func NewPopulatedCall_GrowVolume added in v0.0.8 

func NewPopulatedCall_GrowVolume(r randyMaster, easy bool) *Call_GrowVolume

func (*Call_GrowVolume) Descriptor added in v0.0.8 

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

func (*Call_GrowVolume) Equal added in v0.0.8 

func (this *Call_GrowVolume) Equal(that interface{}) bool

func (*Call_GrowVolume) GetAddition added in v0.0.8 

func (m *Call_GrowVolume) GetAddition() mesos.Resource

func (*Call_GrowVolume) GetAgentID added in v0.0.8 

func (m *Call_GrowVolume) GetAgentID() *mesos.AgentID

func (*Call_GrowVolume) GetVolume added in v0.0.8 

func (m *Call_GrowVolume) GetVolume() mesos.Resource

func (*Call_GrowVolume) GoString added in v0.0.8 

func (this *Call_GrowVolume) GoString() string

func (*Call_GrowVolume) Marshal added in v0.0.8 

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

func (*Call_GrowVolume) MarshalJSON added in v0.0.8 

func (mj *Call_GrowVolume) MarshalJSON() ([]byte, error)

func (*Call_GrowVolume) MarshalJSONBuf added in v0.0.8 

func (mj *Call_GrowVolume) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_GrowVolume) MarshalTo added in v0.0.8 

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

func (*Call_GrowVolume) ProtoMessage added in v0.0.8 

func (*Call_GrowVolume) ProtoMessage()

func (*Call_GrowVolume) Reset added in v0.0.8 

func (m *Call_GrowVolume) Reset()

func (*Call_GrowVolume) Size added in v0.0.11 

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

func (*Call_GrowVolume) String added in v0.0.8 

func (this *Call_GrowVolume) String() string

func (*Call_GrowVolume) Unmarshal added in v0.0.8 

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

func (*Call_GrowVolume) UnmarshalJSON added in v0.0.8 

func (uj *Call_GrowVolume) UnmarshalJSON(input []byte) error

func (*Call_GrowVolume) UnmarshalJSONFFLexer added in v0.0.8 

func (uj *Call_GrowVolume) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call_GrowVolume) VerboseEqual added in v0.0.8 

func (this *Call_GrowVolume) VerboseEqual(that interface{}) error

type Call_ListFiles 

type Call_ListFiles struct {
	Path string `protobuf:"bytes,1,req,name=path" json:"path"`
}

Provides the file listing for a directory.

func NewPopulatedCall_ListFiles 

func NewPopulatedCall_ListFiles(r randyMaster, easy bool) *Call_ListFiles

func (*Call_ListFiles) Descriptor 

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

func (*Call_ListFiles) Equal 

func (this *Call_ListFiles) Equal(that interface{}) bool

func (*Call_ListFiles) GetPath 

func (m *Call_ListFiles) GetPath() string

func (*Call_ListFiles) GoString 

func (this *Call_ListFiles) GoString() string

func (*Call_ListFiles) Marshal 

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

func (*Call_ListFiles) MarshalJSON 

func (mj *Call_ListFiles) MarshalJSON() ([]byte, error)

func (*Call_ListFiles) MarshalJSONBuf 

func (mj *Call_ListFiles) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_ListFiles) MarshalTo 

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

func (*Call_ListFiles) ProtoMessage 

func (*Call_ListFiles) ProtoMessage()

func (*Call_ListFiles) Reset 

func (m *Call_ListFiles) Reset()

func (*Call_ListFiles) Size added in v0.0.11 

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

func (*Call_ListFiles) String 

func (this *Call_ListFiles) String() string

func (*Call_ListFiles) Unmarshal 

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

func (*Call_ListFiles) UnmarshalJSON 

func (uj *Call_ListFiles) UnmarshalJSON(input []byte) error

func (*Call_ListFiles) UnmarshalJSONFFLexer 

func (uj *Call_ListFiles) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call_ListFiles) VerboseEqual 

func (this *Call_ListFiles) VerboseEqual(that interface{}) error

type Call_MarkAgentGone added in v0.0.7 

type Call_MarkAgentGone struct {
	AgentID mesos.AgentID `protobuf:"bytes,1,req,name=agent_id,json=agentId" json:"agent_id"`
}

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 NewPopulatedCall_MarkAgentGone added in v0.0.7 

func NewPopulatedCall_MarkAgentGone(r randyMaster, easy bool) *Call_MarkAgentGone

func (*Call_MarkAgentGone) Descriptor added in v0.0.7 

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

func (*Call_MarkAgentGone) Equal added in v0.0.7 

func (this *Call_MarkAgentGone) Equal(that interface{}) bool

func (*Call_MarkAgentGone) GetAgentID added in v0.0.7 

func (m *Call_MarkAgentGone) GetAgentID() mesos.AgentID

func (*Call_MarkAgentGone) GoString added in v0.0.7 

func (this *Call_MarkAgentGone) GoString() string

func (*Call_MarkAgentGone) Marshal added in v0.0.7 

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

func (*Call_MarkAgentGone) MarshalJSON added in v0.0.7 

func (mj *Call_MarkAgentGone) MarshalJSON() ([]byte, error)

func (*Call_MarkAgentGone) MarshalJSONBuf added in v0.0.7 

func (mj *Call_MarkAgentGone) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_MarkAgentGone) MarshalTo added in v0.0.7 

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

func (*Call_MarkAgentGone) ProtoMessage added in v0.0.7 

func (*Call_MarkAgentGone) ProtoMessage()

func (*Call_MarkAgentGone) Reset added in v0.0.7 

func (m *Call_MarkAgentGone) Reset()

func (*Call_MarkAgentGone) Size added in v0.0.11 

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

func (*Call_MarkAgentGone) String added in v0.0.7 

func (this *Call_MarkAgentGone) String() string

func (*Call_MarkAgentGone) Unmarshal added in v0.0.7 

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

func (*Call_MarkAgentGone) UnmarshalJSON added in v0.0.7 

func (uj *Call_MarkAgentGone) UnmarshalJSON(input []byte) error

func (*Call_MarkAgentGone) UnmarshalJSONFFLexer added in v0.0.7 

func (uj *Call_MarkAgentGone) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call_MarkAgentGone) VerboseEqual added in v0.0.7 

func (this *Call_MarkAgentGone) VerboseEqual(that interface{}) error

type Call_ReactivateAgent added in v0.0.11 

type Call_ReactivateAgent struct {
	AgentID mesos.AgentID `protobuf:"bytes,1,req,name=agent_id,json=agentId" json:"agent_id"`
}

EXPERIMENTAL.

Turns on offers for a specific agent, which was previously drained or deactivated.

func NewPopulatedCall_ReactivateAgent added in v0.0.11 

func NewPopulatedCall_ReactivateAgent(r randyMaster, easy bool) *Call_ReactivateAgent

func (*Call_ReactivateAgent) Descriptor added in v0.0.11 

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

func (*Call_ReactivateAgent) Equal added in v0.0.11 

func (this *Call_ReactivateAgent) Equal(that interface{}) bool

func (*Call_ReactivateAgent) GetAgentID added in v0.0.11 

func (m *Call_ReactivateAgent) GetAgentID() mesos.AgentID

func (*Call_ReactivateAgent) GoString added in v0.0.11 

func (this *Call_ReactivateAgent) GoString() string

func (*Call_ReactivateAgent) Marshal added in v0.0.11 

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

func (*Call_ReactivateAgent) MarshalJSON added in v0.0.11 

func (mj *Call_ReactivateAgent) MarshalJSON() ([]byte, error)

func (*Call_ReactivateAgent) MarshalJSONBuf added in v0.0.11 

func (mj *Call_ReactivateAgent) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_ReactivateAgent) MarshalTo added in v0.0.11 

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

func (*Call_ReactivateAgent) ProtoMessage added in v0.0.11 

func (*Call_ReactivateAgent) ProtoMessage()

func (*Call_ReactivateAgent) Reset added in v0.0.11 

func (m *Call_ReactivateAgent) Reset()

func (*Call_ReactivateAgent) Size added in v0.0.11 

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

func (*Call_ReactivateAgent) String added in v0.0.11 

func (this *Call_ReactivateAgent) String() string

func (*Call_ReactivateAgent) Unmarshal added in v0.0.11 

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

func (*Call_ReactivateAgent) UnmarshalJSON added in v0.0.11 

func (uj *Call_ReactivateAgent) UnmarshalJSON(input []byte) error

func (*Call_ReactivateAgent) UnmarshalJSONFFLexer added in v0.0.11 

func (uj *Call_ReactivateAgent) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call_ReactivateAgent) VerboseEqual added in v0.0.11 

func (this *Call_ReactivateAgent) VerboseEqual(that interface{}) error

type Call_ReadFile 

type Call_ReadFile struct {
	// The path of file.
	Path string `protobuf:"bytes,1,req,name=path" json:"path"`
	// Initial offset in file to start reading from.
	Offset uint64 `protobuf:"varint,2,req,name=offset" json:"offset"`
	// 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"`
}

Reads data from a file.

func NewPopulatedCall_ReadFile 

func NewPopulatedCall_ReadFile(r randyMaster, easy bool) *Call_ReadFile

func (*Call_ReadFile) Descriptor 

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

func (*Call_ReadFile) Equal 

func (this *Call_ReadFile) Equal(that interface{}) bool

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

func (this *Call_ReadFile) GoString() string

func (*Call_ReadFile) Marshal 

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

func (*Call_ReadFile) MarshalJSON 

func (mj *Call_ReadFile) MarshalJSON() ([]byte, error)

func (*Call_ReadFile) MarshalJSONBuf 

func (mj *Call_ReadFile) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_ReadFile) MarshalTo 

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

func (*Call_ReadFile) ProtoMessage 

func (*Call_ReadFile) ProtoMessage()

func (*Call_ReadFile) Reset 

func (m *Call_ReadFile) Reset()

func (*Call_ReadFile) Size added in v0.0.11 

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

func (*Call_ReadFile) String 

func (this *Call_ReadFile) String() string

func (*Call_ReadFile) Unmarshal 

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

func (*Call_ReadFile) UnmarshalJSON 

func (uj *Call_ReadFile) UnmarshalJSON(input []byte) error

func (*Call_ReadFile) UnmarshalJSONFFLexer 

func (uj *Call_ReadFile) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call_ReadFile) VerboseEqual 

func (this *Call_ReadFile) VerboseEqual(that interface{}) error

type Call_RemoveQuota 

type Call_RemoveQuota struct {
	Role string `protobuf:"bytes,1,req,name=role" json:"role"`
}

Deprecated in favor of `UpdateQuota`.

func NewPopulatedCall_RemoveQuota 

func NewPopulatedCall_RemoveQuota(r randyMaster, easy bool) *Call_RemoveQuota

func (*Call_RemoveQuota) Descriptor 

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

func (*Call_RemoveQuota) Equal 

func (this *Call_RemoveQuota) Equal(that interface{}) bool

func (*Call_RemoveQuota) GetRole 

func (m *Call_RemoveQuota) GetRole() string

func (*Call_RemoveQuota) GoString 

func (this *Call_RemoveQuota) GoString() string

func (*Call_RemoveQuota) Marshal 

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

func (*Call_RemoveQuota) MarshalJSON 

func (mj *Call_RemoveQuota) MarshalJSON() ([]byte, error)

func (*Call_RemoveQuota) MarshalJSONBuf 

func (mj *Call_RemoveQuota) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_RemoveQuota) MarshalTo 

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

func (*Call_RemoveQuota) ProtoMessage 

func (*Call_RemoveQuota) ProtoMessage()

func (*Call_RemoveQuota) Reset 

func (m *Call_RemoveQuota) Reset()

func (*Call_RemoveQuota) Size added in v0.0.11 

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

func (*Call_RemoveQuota) String 

func (this *Call_RemoveQuota) String() string

func (*Call_RemoveQuota) Unmarshal 

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

func (*Call_RemoveQuota) UnmarshalJSON 

func (uj *Call_RemoveQuota) UnmarshalJSON(input []byte) error

func (*Call_RemoveQuota) UnmarshalJSONFFLexer 

func (uj *Call_RemoveQuota) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call_RemoveQuota) VerboseEqual 

func (this *Call_RemoveQuota) VerboseEqual(that interface{}) error

type Call_ReserveResources 

type Call_ReserveResources struct {
	AgentID   mesos.AgentID    `protobuf:"bytes,1,req,name=agent_id,json=agentId" json:"agent_id"`
	Source    []mesos.Resource `protobuf:"bytes,3,rep,name=source" json:"source"`
	Resources []mesos.Resource `protobuf:"bytes,2,rep,name=resources" json:"resources"`
}

Reserve resources dynamically on a specific agent.

func NewPopulatedCall_ReserveResources 

func NewPopulatedCall_ReserveResources(r randyMaster, easy bool) *Call_ReserveResources

func (*Call_ReserveResources) Descriptor 

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

func (*Call_ReserveResources) Equal 

func (this *Call_ReserveResources) Equal(that interface{}) bool

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) GetSource added in v0.0.11 

func (m *Call_ReserveResources) GetSource() []mesos.Resource

func (*Call_ReserveResources) GoString 

func (this *Call_ReserveResources) GoString() string

func (*Call_ReserveResources) Marshal 

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

func (*Call_ReserveResources) MarshalJSON 

func (mj *Call_ReserveResources) MarshalJSON() ([]byte, error)

func (*Call_ReserveResources) MarshalJSONBuf 

func (mj *Call_ReserveResources) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_ReserveResources) MarshalTo 

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

func (*Call_ReserveResources) ProtoMessage 

func (*Call_ReserveResources) ProtoMessage()

func (*Call_ReserveResources) Reset 

func (m *Call_ReserveResources) Reset()

func (*Call_ReserveResources) Size added in v0.0.11 

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

func (*Call_ReserveResources) String 

func (this *Call_ReserveResources) String() string

func (*Call_ReserveResources) Unmarshal 

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

func (*Call_ReserveResources) UnmarshalJSON 

func (uj *Call_ReserveResources) UnmarshalJSON(input []byte) error

func (*Call_ReserveResources) UnmarshalJSONFFLexer 

func (uj *Call_ReserveResources) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call_ReserveResources) VerboseEqual 

func (this *Call_ReserveResources) VerboseEqual(that interface{}) error

type Call_SetLoggingLevel 

type Call_SetLoggingLevel struct {
	// The verbosity level.
	Level uint32 `protobuf:"varint,1,req,name=level" json:"level"`
	// 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"`
}

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 NewPopulatedCall_SetLoggingLevel 

func NewPopulatedCall_SetLoggingLevel(r randyMaster, easy bool) *Call_SetLoggingLevel

func (*Call_SetLoggingLevel) Descriptor 

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

func (*Call_SetLoggingLevel) Equal 

func (this *Call_SetLoggingLevel) Equal(that interface{}) bool

func (*Call_SetLoggingLevel) GetDuration 

func (m *Call_SetLoggingLevel) GetDuration() mesos.DurationInfo

func (*Call_SetLoggingLevel) GetLevel 

func (m *Call_SetLoggingLevel) GetLevel() uint32

func (*Call_SetLoggingLevel) GoString 

func (this *Call_SetLoggingLevel) GoString() string

func (*Call_SetLoggingLevel) Marshal 

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

func (*Call_SetLoggingLevel) MarshalJSON 

func (mj *Call_SetLoggingLevel) MarshalJSON() ([]byte, error)

func (*Call_SetLoggingLevel) MarshalJSONBuf 

func (mj *Call_SetLoggingLevel) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_SetLoggingLevel) MarshalTo 

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

func (*Call_SetLoggingLevel) ProtoMessage 

func (*Call_SetLoggingLevel) ProtoMessage()

func (*Call_SetLoggingLevel) Reset 

func (m *Call_SetLoggingLevel) Reset()

func (*Call_SetLoggingLevel) Size added in v0.0.11 

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

func (*Call_SetLoggingLevel) String 

func (this *Call_SetLoggingLevel) String() string

func (*Call_SetLoggingLevel) Unmarshal 

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

func (*Call_SetLoggingLevel) UnmarshalJSON 

func (uj *Call_SetLoggingLevel) UnmarshalJSON(input []byte) error

func (*Call_SetLoggingLevel) UnmarshalJSONFFLexer 

func (uj *Call_SetLoggingLevel) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call_SetLoggingLevel) VerboseEqual 

func (this *Call_SetLoggingLevel) VerboseEqual(that interface{}) error

type Call_SetQuota 

type Call_SetQuota struct {
	QuotaRequest mesos_quota.QuotaRequest `protobuf:"bytes,1,req,name=quota_request,json=quotaRequest" json:"quota_request"`
}

Deprecated in favor of `UpdateQuota`.

func NewPopulatedCall_SetQuota 

func NewPopulatedCall_SetQuota(r randyMaster, easy bool) *Call_SetQuota

func (*Call_SetQuota) Descriptor 

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

func (*Call_SetQuota) Equal 

func (this *Call_SetQuota) Equal(that interface{}) bool

func (*Call_SetQuota) GetQuotaRequest 

func (m *Call_SetQuota) GetQuotaRequest() mesos_quota.QuotaRequest

func (*Call_SetQuota) GoString 

func (this *Call_SetQuota) GoString() string

func (*Call_SetQuota) Marshal 

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

func (*Call_SetQuota) MarshalJSON 

func (mj *Call_SetQuota) MarshalJSON() ([]byte, error)

func (*Call_SetQuota) MarshalJSONBuf 

func (mj *Call_SetQuota) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_SetQuota) MarshalTo 

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

func (*Call_SetQuota) ProtoMessage 

func (*Call_SetQuota) ProtoMessage()

func (*Call_SetQuota) Reset 

func (m *Call_SetQuota) Reset()

func (*Call_SetQuota) Size added in v0.0.11 

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

func (*Call_SetQuota) String 

func (this *Call_SetQuota) String() string

func (*Call_SetQuota) Unmarshal 

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

func (*Call_SetQuota) UnmarshalJSON 

func (uj *Call_SetQuota) UnmarshalJSON(input []byte) error

func (*Call_SetQuota) UnmarshalJSONFFLexer 

func (uj *Call_SetQuota) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call_SetQuota) VerboseEqual 

func (this *Call_SetQuota) VerboseEqual(that interface{}) error

type Call_ShrinkVolume added in v0.0.8 

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 *mesos.AgentID `protobuf:"bytes,1,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	Volume  mesos.Resource `protobuf:"bytes,2,req,name=volume" json:"volume"`
	// See comments in `Value.Scalar` for maximum precision supported.
	Subtract mesos.Value_Scalar `protobuf:"bytes,3,req,name=subtract" json:"subtract"`
}

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 NewPopulatedCall_ShrinkVolume added in v0.0.8 

func NewPopulatedCall_ShrinkVolume(r randyMaster, easy bool) *Call_ShrinkVolume

func (*Call_ShrinkVolume) Descriptor added in v0.0.8 

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

func (*Call_ShrinkVolume) Equal added in v0.0.8 

func (this *Call_ShrinkVolume) Equal(that interface{}) bool

func (*Call_ShrinkVolume) GetAgentID added in v0.0.8 

func (m *Call_ShrinkVolume) GetAgentID() *mesos.AgentID

func (*Call_ShrinkVolume) GetSubtract added in v0.0.8 

func (m *Call_ShrinkVolume) GetSubtract() mesos.Value_Scalar

func (*Call_ShrinkVolume) GetVolume added in v0.0.8 

func (m *Call_ShrinkVolume) GetVolume() mesos.Resource

func (*Call_ShrinkVolume) GoString added in v0.0.8 

func (this *Call_ShrinkVolume) GoString() string

func (*Call_ShrinkVolume) Marshal added in v0.0.8 

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

func (*Call_ShrinkVolume) MarshalJSON added in v0.0.8 

func (mj *Call_ShrinkVolume) MarshalJSON() ([]byte, error)

func (*Call_ShrinkVolume) MarshalJSONBuf added in v0.0.8 

func (mj *Call_ShrinkVolume) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_ShrinkVolume) MarshalTo added in v0.0.8 

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

func (*Call_ShrinkVolume) ProtoMessage added in v0.0.8 

func (*Call_ShrinkVolume) ProtoMessage()

func (*Call_ShrinkVolume) Reset added in v0.0.8 

func (m *Call_ShrinkVolume) Reset()

func (*Call_ShrinkVolume) Size added in v0.0.11 

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

func (*Call_ShrinkVolume) String added in v0.0.8 

func (this *Call_ShrinkVolume) String() string

func (*Call_ShrinkVolume) Unmarshal added in v0.0.8 

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

func (*Call_ShrinkVolume) UnmarshalJSON added in v0.0.8 

func (uj *Call_ShrinkVolume) UnmarshalJSON(input []byte) error

func (*Call_ShrinkVolume) UnmarshalJSONFFLexer added in v0.0.8 

func (uj *Call_ShrinkVolume) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call_ShrinkVolume) VerboseEqual added in v0.0.8 

func (this *Call_ShrinkVolume) VerboseEqual(that interface{}) error

type Call_StartMaintenance 

type Call_StartMaintenance struct {
	Machines []mesos.MachineID `protobuf:"bytes,1,rep,name=machines" json:"machines"`
}

Starts the maintenance of the cluster, this would bring a set of machines down.

func NewPopulatedCall_StartMaintenance 

func NewPopulatedCall_StartMaintenance(r randyMaster, easy bool) *Call_StartMaintenance

func (*Call_StartMaintenance) Descriptor 

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

func (*Call_StartMaintenance) Equal 

func (this *Call_StartMaintenance) Equal(that interface{}) bool

func (*Call_StartMaintenance) GetMachines 

func (m *Call_StartMaintenance) GetMachines() []mesos.MachineID

func (*Call_StartMaintenance) GoString 

func (this *Call_StartMaintenance) GoString() string

func (*Call_StartMaintenance) Marshal 

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

func (*Call_StartMaintenance) MarshalJSON 

func (mj *Call_StartMaintenance) MarshalJSON() ([]byte, error)

func (*Call_StartMaintenance) MarshalJSONBuf 

func (mj *Call_StartMaintenance) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_StartMaintenance) MarshalTo 

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

func (*Call_StartMaintenance) ProtoMessage 

func (*Call_StartMaintenance) ProtoMessage()

func (*Call_StartMaintenance) Reset 

func (m *Call_StartMaintenance) Reset()

func (*Call_StartMaintenance) Size added in v0.0.11 

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

func (*Call_StartMaintenance) String 

func (this *Call_StartMaintenance) String() string

func (*Call_StartMaintenance) Unmarshal 

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

func (*Call_StartMaintenance) UnmarshalJSON 

func (uj *Call_StartMaintenance) UnmarshalJSON(input []byte) error

func (*Call_StartMaintenance) UnmarshalJSONFFLexer 

func (uj *Call_StartMaintenance) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call_StartMaintenance) VerboseEqual 

func (this *Call_StartMaintenance) VerboseEqual(that interface{}) error

type Call_StopMaintenance 

type Call_StopMaintenance struct {
	Machines []mesos.MachineID `protobuf:"bytes,1,rep,name=machines" json:"machines"`
}

Stops the maintenance of the cluster, this would bring a set of machines back up.

func NewPopulatedCall_StopMaintenance 

func NewPopulatedCall_StopMaintenance(r randyMaster, easy bool) *Call_StopMaintenance

func (*Call_StopMaintenance) Descriptor 

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

func (*Call_StopMaintenance) Equal 

func (this *Call_StopMaintenance) Equal(that interface{}) bool

func (*Call_StopMaintenance) GetMachines 

func (m *Call_StopMaintenance) GetMachines() []mesos.MachineID

func (*Call_StopMaintenance) GoString 

func (this *Call_StopMaintenance) GoString() string

func (*Call_StopMaintenance) Marshal 

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

func (*Call_StopMaintenance) MarshalJSON 

func (mj *Call_StopMaintenance) MarshalJSON() ([]byte, error)

func (*Call_StopMaintenance) MarshalJSONBuf 

func (mj *Call_StopMaintenance) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_StopMaintenance) MarshalTo 

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

func (*Call_StopMaintenance) ProtoMessage 

func (*Call_StopMaintenance) ProtoMessage()

func (*Call_StopMaintenance) Reset 

func (m *Call_StopMaintenance) Reset()

func (*Call_StopMaintenance) Size added in v0.0.11 

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

func (*Call_StopMaintenance) String 

func (this *Call_StopMaintenance) String() string

func (*Call_StopMaintenance) Unmarshal 

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

func (*Call_StopMaintenance) UnmarshalJSON 

func (uj *Call_StopMaintenance) UnmarshalJSON(input []byte) error

func (*Call_StopMaintenance) UnmarshalJSONFFLexer 

func (uj *Call_StopMaintenance) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call_StopMaintenance) VerboseEqual 

func (this *Call_StopMaintenance) VerboseEqual(that interface{}) error

type Call_Teardown added in v0.0.7 

type Call_Teardown struct {
	FrameworkID mesos.FrameworkID `protobuf:"bytes,1,req,name=framework_id,json=frameworkId" json:"framework_id"`
}

Tears down a running framework by shutting down all tasks/executors and removing the framework.

func NewPopulatedCall_Teardown added in v0.0.7 

func NewPopulatedCall_Teardown(r randyMaster, easy bool) *Call_Teardown

func (*Call_Teardown) Descriptor added in v0.0.7 

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

func (*Call_Teardown) Equal added in v0.0.7 

func (this *Call_Teardown) Equal(that interface{}) bool

func (*Call_Teardown) GetFrameworkID added in v0.0.7 

func (m *Call_Teardown) GetFrameworkID() mesos.FrameworkID

func (*Call_Teardown) GoString added in v0.0.7 

func (this *Call_Teardown) GoString() string

func (*Call_Teardown) Marshal added in v0.0.7 

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

func (*Call_Teardown) MarshalJSON added in v0.0.7 

func (mj *Call_Teardown) MarshalJSON() ([]byte, error)

func (*Call_Teardown) MarshalJSONBuf added in v0.0.7 

func (mj *Call_Teardown) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_Teardown) MarshalTo added in v0.0.7 

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

func (*Call_Teardown) ProtoMessage added in v0.0.7 

func (*Call_Teardown) ProtoMessage()

func (*Call_Teardown) Reset added in v0.0.7 

func (m *Call_Teardown) Reset()

func (*Call_Teardown) Size added in v0.0.11 

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

func (*Call_Teardown) String added in v0.0.7 

func (this *Call_Teardown) String() string

func (*Call_Teardown) Unmarshal added in v0.0.7 

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

func (*Call_Teardown) UnmarshalJSON added in v0.0.7 

func (uj *Call_Teardown) UnmarshalJSON(input []byte) error

func (*Call_Teardown) UnmarshalJSONFFLexer added in v0.0.7 

func (uj *Call_Teardown) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call_Teardown) VerboseEqual added in v0.0.7 

func (this *Call_Teardown) VerboseEqual(that interface{}) 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
	Call_REMOVE_QUOTA    Call_Type = 30
	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) MarshalJSON 

func (x Call_Type) MarshalJSON() ([]byte, error)

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"`
	Resources []mesos.Resource `protobuf:"bytes,2,rep,name=resources" json:"resources"`
}

Unreserve resources dynamically on a specific agent.

func NewPopulatedCall_UnreserveResources 

func NewPopulatedCall_UnreserveResources(r randyMaster, easy bool) *Call_UnreserveResources

func (*Call_UnreserveResources) Descriptor 

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

func (*Call_UnreserveResources) Equal 

func (this *Call_UnreserveResources) Equal(that interface{}) bool

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

func (this *Call_UnreserveResources) GoString() string

func (*Call_UnreserveResources) Marshal 

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

func (*Call_UnreserveResources) MarshalJSON 

func (mj *Call_UnreserveResources) MarshalJSON() ([]byte, error)

func (*Call_UnreserveResources) MarshalJSONBuf 

func (mj *Call_UnreserveResources) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_UnreserveResources) MarshalTo 

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

func (*Call_UnreserveResources) ProtoMessage 

func (*Call_UnreserveResources) ProtoMessage()

func (*Call_UnreserveResources) Reset 

func (m *Call_UnreserveResources) Reset()

func (*Call_UnreserveResources) Size added in v0.0.11 

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

func (*Call_UnreserveResources) String 

func (this *Call_UnreserveResources) String() string

func (*Call_UnreserveResources) Unmarshal 

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

func (*Call_UnreserveResources) UnmarshalJSON 

func (uj *Call_UnreserveResources) UnmarshalJSON(input []byte) error

func (*Call_UnreserveResources) UnmarshalJSONFFLexer 

func (uj *Call_UnreserveResources) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call_UnreserveResources) VerboseEqual 

func (this *Call_UnreserveResources) VerboseEqual(that interface{}) error

type Call_UpdateMaintenanceSchedule 

type Call_UpdateMaintenanceSchedule struct {
	Schedule mesos_maintenance.Schedule `protobuf:"bytes,1,req,name=schedule" json:"schedule"`
}

Updates the cluster's maintenance schedule.

func NewPopulatedCall_UpdateMaintenanceSchedule 

func NewPopulatedCall_UpdateMaintenanceSchedule(r randyMaster, easy bool) *Call_UpdateMaintenanceSchedule

func (*Call_UpdateMaintenanceSchedule) Descriptor 

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

func (*Call_UpdateMaintenanceSchedule) Equal 

func (this *Call_UpdateMaintenanceSchedule) Equal(that interface{}) bool

func (*Call_UpdateMaintenanceSchedule) GetSchedule 

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

func (*Call_UpdateMaintenanceSchedule) GoString 

func (this *Call_UpdateMaintenanceSchedule) GoString() string

func (*Call_UpdateMaintenanceSchedule) Marshal 

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

func (*Call_UpdateMaintenanceSchedule) MarshalJSON 

func (mj *Call_UpdateMaintenanceSchedule) MarshalJSON() ([]byte, error)

func (*Call_UpdateMaintenanceSchedule) MarshalJSONBuf 

func (mj *Call_UpdateMaintenanceSchedule) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_UpdateMaintenanceSchedule) MarshalTo 

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

func (*Call_UpdateMaintenanceSchedule) ProtoMessage 

func (*Call_UpdateMaintenanceSchedule) ProtoMessage()

func (*Call_UpdateMaintenanceSchedule) Reset 

func (m *Call_UpdateMaintenanceSchedule) Reset()

func (*Call_UpdateMaintenanceSchedule) Size added in v0.0.11 

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

func (*Call_UpdateMaintenanceSchedule) String 

func (this *Call_UpdateMaintenanceSchedule) String() string

func (*Call_UpdateMaintenanceSchedule) Unmarshal 

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

func (*Call_UpdateMaintenanceSchedule) UnmarshalJSON 

func (uj *Call_UpdateMaintenanceSchedule) UnmarshalJSON(input []byte) error

func (*Call_UpdateMaintenanceSchedule) UnmarshalJSONFFLexer 

func (uj *Call_UpdateMaintenanceSchedule) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call_UpdateMaintenanceSchedule) VerboseEqual 

func (this *Call_UpdateMaintenanceSchedule) VerboseEqual(that interface{}) error

type Call_UpdateQuota added in v0.0.10 

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 []mesos_quota.QuotaConfig `protobuf:"bytes,2,rep,name=quota_configs,json=quotaConfigs" json:"quota_configs"`
}

Updates quota given the provided quota configurations, these configurations are applied in an all-or-nothing manner.

func NewPopulatedCall_UpdateQuota added in v0.0.10 

func NewPopulatedCall_UpdateQuota(r randyMaster, easy bool) *Call_UpdateQuota

func (*Call_UpdateQuota) Descriptor added in v0.0.10 

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

func (*Call_UpdateQuota) Equal added in v0.0.10 

func (this *Call_UpdateQuota) Equal(that interface{}) bool

func (*Call_UpdateQuota) GetForce added in v0.0.10 

func (m *Call_UpdateQuota) GetForce() bool

func (*Call_UpdateQuota) GetQuotaConfigs added in v0.0.10 

func (m *Call_UpdateQuota) GetQuotaConfigs() []mesos_quota.QuotaConfig

func (*Call_UpdateQuota) GoString added in v0.0.10 

func (this *Call_UpdateQuota) GoString() string

func (*Call_UpdateQuota) Marshal added in v0.0.10 

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

func (*Call_UpdateQuota) MarshalJSON added in v0.0.10 

func (mj *Call_UpdateQuota) MarshalJSON() ([]byte, error)

func (*Call_UpdateQuota) MarshalJSONBuf added in v0.0.10 

func (mj *Call_UpdateQuota) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_UpdateQuota) MarshalTo added in v0.0.10 

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

func (*Call_UpdateQuota) ProtoMessage added in v0.0.10 

func (*Call_UpdateQuota) ProtoMessage()

func (*Call_UpdateQuota) Reset added in v0.0.10 

func (m *Call_UpdateQuota) Reset()

func (*Call_UpdateQuota) Size added in v0.0.11 

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

func (*Call_UpdateQuota) String added in v0.0.10 

func (this *Call_UpdateQuota) String() string

func (*Call_UpdateQuota) Unmarshal added in v0.0.10 

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

func (*Call_UpdateQuota) UnmarshalJSON added in v0.0.10 

func (uj *Call_UpdateQuota) UnmarshalJSON(input []byte) error

func (*Call_UpdateQuota) UnmarshalJSONFFLexer added in v0.0.10 

func (uj *Call_UpdateQuota) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call_UpdateQuota) VerboseEqual added in v0.0.10 

func (this *Call_UpdateQuota) VerboseEqual(that interface{}) error

type Call_UpdateWeights 

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

func NewPopulatedCall_UpdateWeights 

func NewPopulatedCall_UpdateWeights(r randyMaster, easy bool) *Call_UpdateWeights

func (*Call_UpdateWeights) Descriptor 

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

func (*Call_UpdateWeights) Equal 

func (this *Call_UpdateWeights) Equal(that interface{}) bool

func (*Call_UpdateWeights) GetWeightInfos 

func (m *Call_UpdateWeights) GetWeightInfos() []mesos.WeightInfo

func (*Call_UpdateWeights) GoString 

func (this *Call_UpdateWeights) GoString() string

func (*Call_UpdateWeights) Marshal 

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

func (*Call_UpdateWeights) MarshalJSON 

func (mj *Call_UpdateWeights) MarshalJSON() ([]byte, error)

func (*Call_UpdateWeights) MarshalJSONBuf 

func (mj *Call_UpdateWeights) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_UpdateWeights) MarshalTo 

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

func (*Call_UpdateWeights) ProtoMessage 

func (*Call_UpdateWeights) ProtoMessage()

func (*Call_UpdateWeights) Reset 

func (m *Call_UpdateWeights) Reset()

func (*Call_UpdateWeights) Size added in v0.0.11 

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

func (*Call_UpdateWeights) String 

func (this *Call_UpdateWeights) String() string

func (*Call_UpdateWeights) Unmarshal 

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

func (*Call_UpdateWeights) UnmarshalJSON 

func (uj *Call_UpdateWeights) UnmarshalJSON(input []byte) error

func (*Call_UpdateWeights) UnmarshalJSONFFLexer 

func (uj *Call_UpdateWeights) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Call_UpdateWeights) VerboseEqual 

func (this *Call_UpdateWeights) VerboseEqual(that interface{}) error

type Event 

type Event struct {
	Type             Event_Type              `protobuf:"varint,1,opt,name=type,enum=mesos.master.Event_Type" json:"type"`
	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"`
	FrameworkAdded   *Event_FrameworkAdded   `protobuf:"bytes,7,opt,name=framework_added,json=frameworkAdded" json:"framework_added,omitempty"`
	FrameworkUpdated *Event_FrameworkUpdated `protobuf:"bytes,8,opt,name=framework_updated,json=frameworkUpdated" json:"framework_updated,omitempty"`
	FrameworkRemoved *Event_FrameworkRemoved `protobuf:"bytes,9,opt,name=framework_removed,json=frameworkRemoved" json:"framework_removed,omitempty"`
}

* Streaming response to `Call::SUBSCRIBE` made to the master.

func NewPopulatedEvent 

func NewPopulatedEvent(r randyMaster, easy bool) *Event

func (*Event) Descriptor 

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

func (*Event) Equal 

func (this *Event) Equal(that interface{}) bool

func (*Event) GetAgentAdded 

func (m *Event) GetAgentAdded() *Event_AgentAdded

func (*Event) GetAgentRemoved 

func (m *Event) GetAgentRemoved() *Event_AgentRemoved

func (*Event) GetFrameworkAdded added in v0.0.6 

func (m *Event) GetFrameworkAdded() *Event_FrameworkAdded

func (*Event) GetFrameworkRemoved added in v0.0.6 

func (m *Event) GetFrameworkRemoved() *Event_FrameworkRemoved

func (*Event) GetFrameworkUpdated added in v0.0.6 

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

func (this *Event) GoString() string

func (*Event) Marshal 

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

func (*Event) MarshalJSON 

func (mj *Event) MarshalJSON() ([]byte, error)

func (*Event) MarshalJSONBuf 

func (mj *Event) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Event) MarshalTo 

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

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) Size added in v0.0.11 

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

func (*Event) String 

func (this *Event) String() string

func (*Event) Unmarshal 

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

func (*Event) UnmarshalJSON 

func (uj *Event) UnmarshalJSON(input []byte) error

func (*Event) UnmarshalJSONFFLexer 

func (uj *Event) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Event) VerboseEqual 

func (this *Event) VerboseEqual(that interface{}) error

type Event_AgentAdded 

type Event_AgentAdded struct {
	Agent Response_GetAgents_Agent `protobuf:"bytes,1,req,name=agent" json:"agent"`
}

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 NewPopulatedEvent_AgentAdded 

func NewPopulatedEvent_AgentAdded(r randyMaster, easy bool) *Event_AgentAdded

func (*Event_AgentAdded) Descriptor 

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

func (*Event_AgentAdded) Equal 

func (this *Event_AgentAdded) Equal(that interface{}) bool

func (*Event_AgentAdded) GetAgent 

func (m *Event_AgentAdded) GetAgent() Response_GetAgents_Agent

func (*Event_AgentAdded) GoString 

func (this *Event_AgentAdded) GoString() string

func (*Event_AgentAdded) Marshal 

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

func (*Event_AgentAdded) MarshalJSON 

func (mj *Event_AgentAdded) MarshalJSON() ([]byte, error)

func (*Event_AgentAdded) MarshalJSONBuf 

func (mj *Event_AgentAdded) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Event_AgentAdded) MarshalTo 

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

func (*Event_AgentAdded) ProtoMessage 

func (*Event_AgentAdded) ProtoMessage()

func (*Event_AgentAdded) Reset 

func (m *Event_AgentAdded) Reset()

func (*Event_AgentAdded) Size added in v0.0.11 

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

func (*Event_AgentAdded) String 

func (this *Event_AgentAdded) String() string

func (*Event_AgentAdded) Unmarshal 

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

func (*Event_AgentAdded) UnmarshalJSON 

func (uj *Event_AgentAdded) UnmarshalJSON(input []byte) error

func (*Event_AgentAdded) UnmarshalJSONFFLexer 

func (uj *Event_AgentAdded) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Event_AgentAdded) VerboseEqual 

func (this *Event_AgentAdded) VerboseEqual(that interface{}) error

type Event_AgentRemoved 

type Event_AgentRemoved struct {
	AgentID mesos.AgentID `protobuf:"bytes,1,req,name=agent_id,json=agentId" json:"agent_id"`
}

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 NewPopulatedEvent_AgentRemoved 

func NewPopulatedEvent_AgentRemoved(r randyMaster, easy bool) *Event_AgentRemoved

func (*Event_AgentRemoved) Descriptor 

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

func (*Event_AgentRemoved) Equal 

func (this *Event_AgentRemoved) Equal(that interface{}) bool

func (*Event_AgentRemoved) GetAgentID 

func (m *Event_AgentRemoved) GetAgentID() mesos.AgentID

func (*Event_AgentRemoved) GoString 

func (this *Event_AgentRemoved) GoString() string

func (*Event_AgentRemoved) Marshal 

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

func (*Event_AgentRemoved) MarshalJSON 

func (mj *Event_AgentRemoved) MarshalJSON() ([]byte, error)

func (*Event_AgentRemoved) MarshalJSONBuf 

func (mj *Event_AgentRemoved) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Event_AgentRemoved) MarshalTo 

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

func (*Event_AgentRemoved) ProtoMessage 

func (*Event_AgentRemoved) ProtoMessage()

func (*Event_AgentRemoved) Reset 

func (m *Event_AgentRemoved) Reset()

func (*Event_AgentRemoved) Size added in v0.0.11 

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

func (*Event_AgentRemoved) String 

func (this *Event_AgentRemoved) String() string

func (*Event_AgentRemoved) Unmarshal 

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

func (*Event_AgentRemoved) UnmarshalJSON 

func (uj *Event_AgentRemoved) UnmarshalJSON(input []byte) error

func (*Event_AgentRemoved) UnmarshalJSONFFLexer 

func (uj *Event_AgentRemoved) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Event_AgentRemoved) VerboseEqual 

func (this *Event_AgentRemoved) VerboseEqual(that interface{}) error

type Event_FrameworkAdded added in v0.0.6 

type Event_FrameworkAdded struct {
	Framework Response_GetFrameworks_Framework `protobuf:"bytes,1,req,name=framework" json:"framework"`
}

Forwarded by the master when a framework becomes known to it. This can happen when a new framework registers with the master.

func NewPopulatedEvent_FrameworkAdded added in v0.0.6 

func NewPopulatedEvent_FrameworkAdded(r randyMaster, easy bool) *Event_FrameworkAdded

func (*Event_FrameworkAdded) Descriptor added in v0.0.6 

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

func (*Event_FrameworkAdded) Equal added in v0.0.6 

func (this *Event_FrameworkAdded) Equal(that interface{}) bool

func (*Event_FrameworkAdded) GetFramework added in v0.0.6 

func (m *Event_FrameworkAdded) GetFramework() Response_GetFrameworks_Framework

func (*Event_FrameworkAdded) GoString added in v0.0.6 

func (this *Event_FrameworkAdded) GoString() string

func (*Event_FrameworkAdded) Marshal added in v0.0.6 

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

func (*Event_FrameworkAdded) MarshalJSON added in v0.0.6 

func (mj *Event_FrameworkAdded) MarshalJSON() ([]byte, error)

func (*Event_FrameworkAdded) MarshalJSONBuf added in v0.0.6 

func (mj *Event_FrameworkAdded) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Event_FrameworkAdded) MarshalTo added in v0.0.6 

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

func (*Event_FrameworkAdded) ProtoMessage added in v0.0.6 

func (*Event_FrameworkAdded) ProtoMessage()

func (*Event_FrameworkAdded) Reset added in v0.0.6 

func (m *Event_FrameworkAdded) Reset()

func (*Event_FrameworkAdded) Size added in v0.0.11 

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

func (*Event_FrameworkAdded) String added in v0.0.6 

func (this *Event_FrameworkAdded) String() string

func (*Event_FrameworkAdded) Unmarshal added in v0.0.6 

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

func (*Event_FrameworkAdded) UnmarshalJSON added in v0.0.6 

func (uj *Event_FrameworkAdded) UnmarshalJSON(input []byte) error

func (*Event_FrameworkAdded) UnmarshalJSONFFLexer added in v0.0.6 

func (uj *Event_FrameworkAdded) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Event_FrameworkAdded) VerboseEqual added in v0.0.6 

func (this *Event_FrameworkAdded) VerboseEqual(that interface{}) error

type Event_FrameworkRemoved added in v0.0.6 

type Event_FrameworkRemoved struct {
	FrameworkInfo mesos.FrameworkInfo `protobuf:"bytes,1,req,name=framework_info,json=frameworkInfo" json:"framework_info"`
}

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 NewPopulatedEvent_FrameworkRemoved added in v0.0.6 

func NewPopulatedEvent_FrameworkRemoved(r randyMaster, easy bool) *Event_FrameworkRemoved

func (*Event_FrameworkRemoved) Descriptor added in v0.0.6 

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

func (*Event_FrameworkRemoved) Equal added in v0.0.6 

func (this *Event_FrameworkRemoved) Equal(that interface{}) bool

func (*Event_FrameworkRemoved) GetFrameworkInfo added in v0.0.6 

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

func (*Event_FrameworkRemoved) GoString added in v0.0.6 

func (this *Event_FrameworkRemoved) GoString() string

func (*Event_FrameworkRemoved) Marshal added in v0.0.6 

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

func (*Event_FrameworkRemoved) MarshalJSON added in v0.0.6 

func (mj *Event_FrameworkRemoved) MarshalJSON() ([]byte, error)

func (*Event_FrameworkRemoved) MarshalJSONBuf added in v0.0.6 

func (mj *Event_FrameworkRemoved) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Event_FrameworkRemoved) MarshalTo added in v0.0.6 

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

func (*Event_FrameworkRemoved) ProtoMessage added in v0.0.6 

func (*Event_FrameworkRemoved) ProtoMessage()

func (*Event_FrameworkRemoved) Reset added in v0.0.6 

func (m *Event_FrameworkRemoved) Reset()

func (*Event_FrameworkRemoved) Size added in v0.0.11 

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

func (*Event_FrameworkRemoved) String added in v0.0.6 

func (this *Event_FrameworkRemoved) String() string

func (*Event_FrameworkRemoved) Unmarshal added in v0.0.6 

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

func (*Event_FrameworkRemoved) UnmarshalJSON added in v0.0.6 

func (uj *Event_FrameworkRemoved) UnmarshalJSON(input []byte) error

func (*Event_FrameworkRemoved) UnmarshalJSONFFLexer added in v0.0.6 

func (uj *Event_FrameworkRemoved) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Event_FrameworkRemoved) VerboseEqual added in v0.0.6 

func (this *Event_FrameworkRemoved) VerboseEqual(that interface{}) error

type Event_FrameworkUpdated added in v0.0.6 

type Event_FrameworkUpdated struct {
	Framework Response_GetFrameworks_Framework `protobuf:"bytes,1,req,name=framework" json:"framework"`
}

Forwarded by the master when a framework reregisters with the master upon a disconnection (network error) or upon a master failover.

func NewPopulatedEvent_FrameworkUpdated added in v0.0.6 

func NewPopulatedEvent_FrameworkUpdated(r randyMaster, easy bool) *Event_FrameworkUpdated

func (*Event_FrameworkUpdated) Descriptor added in v0.0.6 

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

func (*Event_FrameworkUpdated) Equal added in v0.0.6 

func (this *Event_FrameworkUpdated) Equal(that interface{}) bool

func (*Event_FrameworkUpdated) GetFramework added in v0.0.6 

func (m *Event_FrameworkUpdated) GetFramework() Response_GetFrameworks_Framework

func (*Event_FrameworkUpdated) GoString added in v0.0.6 

func (this *Event_FrameworkUpdated) GoString() string

func (*Event_FrameworkUpdated) Marshal added in v0.0.6 

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

func (*Event_FrameworkUpdated) MarshalJSON added in v0.0.6 

func (mj *Event_FrameworkUpdated) MarshalJSON() ([]byte, error)

func (*Event_FrameworkUpdated) MarshalJSONBuf added in v0.0.6 

func (mj *Event_FrameworkUpdated) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Event_FrameworkUpdated) MarshalTo added in v0.0.6 

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

func (*Event_FrameworkUpdated) ProtoMessage added in v0.0.6 

func (*Event_FrameworkUpdated) ProtoMessage()

func (*Event_FrameworkUpdated) Reset added in v0.0.6 

func (m *Event_FrameworkUpdated) Reset()

func (*Event_FrameworkUpdated) Size added in v0.0.11 

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

func (*Event_FrameworkUpdated) String added in v0.0.6 

func (this *Event_FrameworkUpdated) String() string

func (*Event_FrameworkUpdated) Unmarshal added in v0.0.6 

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

func (*Event_FrameworkUpdated) UnmarshalJSON added in v0.0.6 

func (uj *Event_FrameworkUpdated) UnmarshalJSON(input []byte) error

func (*Event_FrameworkUpdated) UnmarshalJSONFFLexer added in v0.0.6 

func (uj *Event_FrameworkUpdated) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Event_FrameworkUpdated) VerboseEqual added in v0.0.6 

func (this *Event_FrameworkUpdated) VerboseEqual(that interface{}) 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=getState" 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 `` /* 130-byte string literal not displayed */
}

First event received when a client subscribes.

func NewPopulatedEvent_Subscribed 

func NewPopulatedEvent_Subscribed(r randyMaster, easy bool) *Event_Subscribed

func (*Event_Subscribed) Descriptor 

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

func (*Event_Subscribed) Equal 

func (this *Event_Subscribed) Equal(that interface{}) bool

func (*Event_Subscribed) GetGetState 

func (m *Event_Subscribed) GetGetState() *Response_GetState

func (*Event_Subscribed) GetHeartbeatIntervalSeconds added in v0.0.7 

func (m *Event_Subscribed) GetHeartbeatIntervalSeconds() float64

func (*Event_Subscribed) GoString 

func (this *Event_Subscribed) GoString() string

func (*Event_Subscribed) Marshal 

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

func (*Event_Subscribed) MarshalJSON 

func (mj *Event_Subscribed) MarshalJSON() ([]byte, error)

func (*Event_Subscribed) MarshalJSONBuf 

func (mj *Event_Subscribed) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Event_Subscribed) MarshalTo 

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

func (*Event_Subscribed) ProtoMessage 

func (*Event_Subscribed) ProtoMessage()

func (*Event_Subscribed) Reset 

func (m *Event_Subscribed) Reset()

func (*Event_Subscribed) Size added in v0.0.11 

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

func (*Event_Subscribed) String 

func (this *Event_Subscribed) String() string

func (*Event_Subscribed) Unmarshal 

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

func (*Event_Subscribed) UnmarshalJSON 

func (uj *Event_Subscribed) UnmarshalJSON(input []byte) error

func (*Event_Subscribed) UnmarshalJSONFFLexer 

func (uj *Event_Subscribed) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Event_Subscribed) VerboseEqual 

func (this *Event_Subscribed) VerboseEqual(that interface{}) error

type Event_TaskAdded 

type Event_TaskAdded struct {
	Task mesos.Task `protobuf:"bytes,1,req,name=task" json:"task"`
}

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 NewPopulatedEvent_TaskAdded 

func NewPopulatedEvent_TaskAdded(r randyMaster, easy bool) *Event_TaskAdded

func (*Event_TaskAdded) Descriptor 

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

func (*Event_TaskAdded) Equal 

func (this *Event_TaskAdded) Equal(that interface{}) bool

func (*Event_TaskAdded) GetTask 

func (m *Event_TaskAdded) GetTask() mesos.Task

func (*Event_TaskAdded) GoString 

func (this *Event_TaskAdded) GoString() string

func (*Event_TaskAdded) Marshal 

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

func (*Event_TaskAdded) MarshalJSON 

func (mj *Event_TaskAdded) MarshalJSON() ([]byte, error)

func (*Event_TaskAdded) MarshalJSONBuf 

func (mj *Event_TaskAdded) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Event_TaskAdded) MarshalTo 

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

func (*Event_TaskAdded) ProtoMessage 

func (*Event_TaskAdded) ProtoMessage()

func (*Event_TaskAdded) Reset 

func (m *Event_TaskAdded) Reset()

func (*Event_TaskAdded) Size added in v0.0.11 

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

func (*Event_TaskAdded) String 

func (this *Event_TaskAdded) String() string

func (*Event_TaskAdded) Unmarshal 

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

func (*Event_TaskAdded) UnmarshalJSON 

func (uj *Event_TaskAdded) UnmarshalJSON(input []byte) error

func (*Event_TaskAdded) UnmarshalJSONFFLexer 

func (uj *Event_TaskAdded) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Event_TaskAdded) VerboseEqual 

func (this *Event_TaskAdded) VerboseEqual(that interface{}) error

type Event_TaskUpdated 

type Event_TaskUpdated struct {
	FrameworkID mesos.FrameworkID `protobuf:"bytes,1,req,name=framework_id,json=frameworkId" json:"framework_id"`
	// 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"`
	// 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 *mesos.TaskState `protobuf:"varint,3,req,name=state,enum=mesos.TaskState" json:"state,omitempty"`
}

Forwarded by the master when an existing task transitions to a new state.

func NewPopulatedEvent_TaskUpdated 

func NewPopulatedEvent_TaskUpdated(r randyMaster, easy bool) *Event_TaskUpdated

func (*Event_TaskUpdated) Descriptor 

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

func (*Event_TaskUpdated) Equal 

func (this *Event_TaskUpdated) Equal(that interface{}) bool

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

func (this *Event_TaskUpdated) GoString() string

func (*Event_TaskUpdated) Marshal 

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

func (*Event_TaskUpdated) MarshalJSON 

func (mj *Event_TaskUpdated) MarshalJSON() ([]byte, error)

func (*Event_TaskUpdated) MarshalJSONBuf 

func (mj *Event_TaskUpdated) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Event_TaskUpdated) MarshalTo 

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

func (*Event_TaskUpdated) ProtoMessage 

func (*Event_TaskUpdated) ProtoMessage()

func (*Event_TaskUpdated) Reset 

func (m *Event_TaskUpdated) Reset()

func (*Event_TaskUpdated) Size added in v0.0.11 

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

func (*Event_TaskUpdated) String 

func (this *Event_TaskUpdated) String() string

func (*Event_TaskUpdated) Unmarshal 

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

func (*Event_TaskUpdated) UnmarshalJSON 

func (uj *Event_TaskUpdated) UnmarshalJSON(input []byte) error

func (*Event_TaskUpdated) UnmarshalJSONFFLexer 

func (uj *Event_TaskUpdated) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Event_TaskUpdated) VerboseEqual 

func (this *Event_TaskUpdated) VerboseEqual(that interface{}) 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) MarshalJSON 

func (x Event_Type) MarshalJSON() ([]byte, error)

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.master.Response_Type" json:"type"`
	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"`
	GetOperations          *Response_GetOperations          `protobuf:"bytes,20,opt,name=get_operations,json=getOperations" json:"get_operations,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"`
}

* Synchronous responses for all calls (except Call::SUBSCRIBE) made to the v1 master API.

func NewPopulatedResponse 

func NewPopulatedResponse(r randyMaster, easy bool) *Response

func (*Response) Descriptor 

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

func (*Response) Equal 

func (this *Response) Equal(that interface{}) bool

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

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

func (this *Response) GoString() string

func (*Response) Marshal 

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

func (*Response) MarshalJSON 

func (mj *Response) MarshalJSON() ([]byte, error)

func (*Response) MarshalJSONBuf 

func (mj *Response) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response) MarshalTo 

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

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) Size added in v0.0.11 

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

func (*Response) String 

func (this *Response) String() string

func (*Response) Unmarshal 

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

func (*Response) UnmarshalJSON 

func (uj *Response) UnmarshalJSON(input []byte) error

func (*Response) UnmarshalJSONFFLexer 

func (uj *Response) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response) VerboseEqual 

func (this *Response) VerboseEqual(that interface{}) error

type Response_GetAgents 

type Response_GetAgents struct {
	// Registered agents.
	Agents []Response_GetAgents_Agent `protobuf:"bytes,1,rep,name=agents" json:"agents"`
	// Agents which are recovered from registry but not reregistered yet.
	RecoveredAgents []mesos.AgentInfo `protobuf:"bytes,2,rep,name=recovered_agents,json=recoveredAgents" json:"recovered_agents"`
}

func NewPopulatedResponse_GetAgents 

func NewPopulatedResponse_GetAgents(r randyMaster, easy bool) *Response_GetAgents

func (*Response_GetAgents) Descriptor 

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

func (*Response_GetAgents) Equal 

func (this *Response_GetAgents) Equal(that interface{}) bool

func (*Response_GetAgents) GetAgents 

func (m *Response_GetAgents) GetAgents() []Response_GetAgents_Agent

func (*Response_GetAgents) GetRecoveredAgents 

func (m *Response_GetAgents) GetRecoveredAgents() []mesos.AgentInfo

func (*Response_GetAgents) GoString 

func (this *Response_GetAgents) GoString() string

func (*Response_GetAgents) Marshal 

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

func (*Response_GetAgents) MarshalJSON 

func (mj *Response_GetAgents) MarshalJSON() ([]byte, error)

func (*Response_GetAgents) MarshalJSONBuf 

func (mj *Response_GetAgents) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_GetAgents) MarshalTo 

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

func (*Response_GetAgents) ProtoMessage 

func (*Response_GetAgents) ProtoMessage()

func (*Response_GetAgents) Reset 

func (m *Response_GetAgents) Reset()

func (*Response_GetAgents) Size added in v0.0.11 

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

func (*Response_GetAgents) String 

func (this *Response_GetAgents) String() string

func (*Response_GetAgents) Unmarshal 

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

func (*Response_GetAgents) UnmarshalJSON 

func (uj *Response_GetAgents) UnmarshalJSON(input []byte) error

func (*Response_GetAgents) UnmarshalJSONFFLexer 

func (uj *Response_GetAgents) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_GetAgents) VerboseEqual 

func (this *Response_GetAgents) VerboseEqual(that interface{}) error

type Response_GetAgents_Agent 

type Response_GetAgents_Agent struct {
	AgentInfo        mesos.AgentInfo `protobuf:"bytes,1,req,name=agent_info,json=agentInfo" json:"agent_info"`
	Active           bool            `protobuf:"varint,2,req,name=active" json:"active"`
	Deactivated      *bool           `protobuf:"varint,12,opt,name=deactivated" json:"deactivated,omitempty"`
	Version          string          `protobuf:"bytes,3,req,name=version" json:"version"`
	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"`
	AllocatedResources      []mesos.Resource                            `protobuf:"bytes,8,rep,name=allocated_resources,json=allocatedResources" json:"allocated_resources"`
	OfferedResources        []mesos.Resource                            `protobuf:"bytes,9,rep,name=offered_resources,json=offeredResources" json:"offered_resources"`
	Capabilities            []mesos.AgentInfo_Capability                `protobuf:"bytes,10,rep,name=capabilities" json:"capabilities"`
	ResourceProviders       []Response_GetAgents_Agent_ResourceProvider `protobuf:"bytes,11,rep,name=resource_providers,json=resourceProviders" json:"resource_providers"`
	DrainInfo               *mesos.DrainInfo                            `protobuf:"bytes,13,opt,name=drain_info,json=drainInfo" json:"drain_info,omitempty"`
	EstimatedDrainStartTime *mesos.TimeInfo                             `` /* 128-byte string literal not displayed */
}

func NewPopulatedResponse_GetAgents_Agent 

func NewPopulatedResponse_GetAgents_Agent(r randyMaster, easy bool) *Response_GetAgents_Agent

func (*Response_GetAgents_Agent) Descriptor 

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

func (*Response_GetAgents_Agent) Equal 

func (this *Response_GetAgents_Agent) Equal(that interface{}) bool

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) GetCapabilities added in v0.0.5 

func (m *Response_GetAgents_Agent) GetCapabilities() []mesos.AgentInfo_Capability

func (*Response_GetAgents_Agent) GetDeactivated added in v0.0.11 

func (m *Response_GetAgents_Agent) GetDeactivated() bool

func (*Response_GetAgents_Agent) GetDrainInfo added in v0.0.11 

func (m *Response_GetAgents_Agent) GetDrainInfo() *mesos.DrainInfo

func (*Response_GetAgents_Agent) GetEstimatedDrainStartTime added in v0.0.11 

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

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) GetResourceProviders added in v0.0.7 

func (m *Response_GetAgents_Agent) GetResourceProviders() []Response_GetAgents_Agent_ResourceProvider

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

func (this *Response_GetAgents_Agent) GoString() string

func (*Response_GetAgents_Agent) Marshal 

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

func (*Response_GetAgents_Agent) MarshalJSON 

func (mj *Response_GetAgents_Agent) MarshalJSON() ([]byte, error)

func (*Response_GetAgents_Agent) MarshalJSONBuf 

func (mj *Response_GetAgents_Agent) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_GetAgents_Agent) MarshalTo 

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

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) Size added in v0.0.11 

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

func (*Response_GetAgents_Agent) String 

func (this *Response_GetAgents_Agent) String() string

func (*Response_GetAgents_Agent) Unmarshal 

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

func (*Response_GetAgents_Agent) UnmarshalJSON 

func (uj *Response_GetAgents_Agent) UnmarshalJSON(input []byte) error

func (*Response_GetAgents_Agent) UnmarshalJSONFFLexer 

func (uj *Response_GetAgents_Agent) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_GetAgents_Agent) VerboseEqual 

func (this *Response_GetAgents_Agent) VerboseEqual(that interface{}) error

type Response_GetAgents_Agent_ResourceProvider added in v0.0.7 

type Response_GetAgents_Agent_ResourceProvider struct {
	ResourceProviderInfo mesos.ResourceProviderInfo `protobuf:"bytes,1,req,name=resource_provider_info,json=resourceProviderInfo" json:"resource_provider_info"`
	TotalResources       []mesos.Resource           `protobuf:"bytes,2,rep,name=total_resources,json=totalResources" json:"total_resources"`
}

func NewPopulatedResponse_GetAgents_Agent_ResourceProvider added in v0.0.7 

func NewPopulatedResponse_GetAgents_Agent_ResourceProvider(r randyMaster, easy bool) *Response_GetAgents_Agent_ResourceProvider

func (*Response_GetAgents_Agent_ResourceProvider) Descriptor added in v0.0.7 

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

func (*Response_GetAgents_Agent_ResourceProvider) Equal added in v0.0.7 

func (this *Response_GetAgents_Agent_ResourceProvider) Equal(that interface{}) bool

func (*Response_GetAgents_Agent_ResourceProvider) GetResourceProviderInfo added in v0.0.7 

func (m *Response_GetAgents_Agent_ResourceProvider) GetResourceProviderInfo() mesos.ResourceProviderInfo

func (*Response_GetAgents_Agent_ResourceProvider) GetTotalResources added in v0.0.8 

func (m *Response_GetAgents_Agent_ResourceProvider) GetTotalResources() []mesos.Resource

func (*Response_GetAgents_Agent_ResourceProvider) GoString added in v0.0.7 

func (this *Response_GetAgents_Agent_ResourceProvider) GoString() string

func (*Response_GetAgents_Agent_ResourceProvider) Marshal added in v0.0.7 

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

func (*Response_GetAgents_Agent_ResourceProvider) MarshalJSON added in v0.0.7 

func (mj *Response_GetAgents_Agent_ResourceProvider) MarshalJSON() ([]byte, error)

func (*Response_GetAgents_Agent_ResourceProvider) MarshalJSONBuf added in v0.0.7 

func (mj *Response_GetAgents_Agent_ResourceProvider) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_GetAgents_Agent_ResourceProvider) MarshalTo added in v0.0.7 

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

func (*Response_GetAgents_Agent_ResourceProvider) ProtoMessage added in v0.0.7 

func (*Response_GetAgents_Agent_ResourceProvider) ProtoMessage()

func (*Response_GetAgents_Agent_ResourceProvider) Reset added in v0.0.7 

func (m *Response_GetAgents_Agent_ResourceProvider) Reset()

func (*Response_GetAgents_Agent_ResourceProvider) Size added in v0.0.11 

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

func (*Response_GetAgents_Agent_ResourceProvider) String added in v0.0.7 

func (this *Response_GetAgents_Agent_ResourceProvider) String() string

func (*Response_GetAgents_Agent_ResourceProvider) Unmarshal added in v0.0.7 

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

func (*Response_GetAgents_Agent_ResourceProvider) UnmarshalJSON added in v0.0.7 

func (uj *Response_GetAgents_Agent_ResourceProvider) UnmarshalJSON(input []byte) error

func (*Response_GetAgents_Agent_ResourceProvider) UnmarshalJSONFFLexer added in v0.0.7 

func (uj *Response_GetAgents_Agent_ResourceProvider) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_GetAgents_Agent_ResourceProvider) VerboseEqual added in v0.0.7 

func (this *Response_GetAgents_Agent_ResourceProvider) VerboseEqual(that interface{}) error

type Response_GetExecutors 

type Response_GetExecutors struct {
	Executors []Response_GetExecutors_Executor `protobuf:"bytes,1,rep,name=executors" json:"executors"`
	// 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=orphanExecutors" json:"orphan_executors"`
}

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 NewPopulatedResponse_GetExecutors 

func NewPopulatedResponse_GetExecutors(r randyMaster, easy bool) *Response_GetExecutors

func (*Response_GetExecutors) Descriptor 

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

func (*Response_GetExecutors) Equal 

func (this *Response_GetExecutors) Equal(that interface{}) bool

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

func (this *Response_GetExecutors) GoString() string

func (*Response_GetExecutors) Marshal 

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

func (*Response_GetExecutors) MarshalJSON 

func (mj *Response_GetExecutors) MarshalJSON() ([]byte, error)

func (*Response_GetExecutors) MarshalJSONBuf 

func (mj *Response_GetExecutors) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_GetExecutors) MarshalTo 

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

func (*Response_GetExecutors) ProtoMessage 

func (*Response_GetExecutors) ProtoMessage()

func (*Response_GetExecutors) Reset 

func (m *Response_GetExecutors) Reset()

func (*Response_GetExecutors) Size added in v0.0.11 

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

func (*Response_GetExecutors) String 

func (this *Response_GetExecutors) String() string

func (*Response_GetExecutors) Unmarshal 

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

func (*Response_GetExecutors) UnmarshalJSON 

func (uj *Response_GetExecutors) UnmarshalJSON(input []byte) error

func (*Response_GetExecutors) UnmarshalJSONFFLexer 

func (uj *Response_GetExecutors) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_GetExecutors) VerboseEqual 

func (this *Response_GetExecutors) VerboseEqual(that interface{}) error

type Response_GetExecutors_Executor 

type Response_GetExecutors_Executor struct {
	ExecutorInfo mesos.ExecutorInfo `protobuf:"bytes,1,req,name=executor_info,json=executorInfo" json:"executor_info"`
	AgentID      mesos.AgentID      `protobuf:"bytes,2,req,name=agent_id,json=agentId" json:"agent_id"`
}

func NewPopulatedResponse_GetExecutors_Executor 

func NewPopulatedResponse_GetExecutors_Executor(r randyMaster, easy bool) *Response_GetExecutors_Executor

func (*Response_GetExecutors_Executor) Descriptor 

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

func (*Response_GetExecutors_Executor) Equal 

func (this *Response_GetExecutors_Executor) Equal(that interface{}) bool

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

func (this *Response_GetExecutors_Executor) GoString() string

func (*Response_GetExecutors_Executor) Marshal 

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

func (*Response_GetExecutors_Executor) MarshalJSON 

func (mj *Response_GetExecutors_Executor) MarshalJSON() ([]byte, error)

func (*Response_GetExecutors_Executor) MarshalJSONBuf 

func (mj *Response_GetExecutors_Executor) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_GetExecutors_Executor) MarshalTo 

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

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) Size added in v0.0.11 

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

func (*Response_GetExecutors_Executor) String 

func (this *Response_GetExecutors_Executor) String() string

func (*Response_GetExecutors_Executor) Unmarshal 

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

func (*Response_GetExecutors_Executor) UnmarshalJSON 

func (uj *Response_GetExecutors_Executor) UnmarshalJSON(input []byte) error

func (*Response_GetExecutors_Executor) UnmarshalJSONFFLexer 

func (uj *Response_GetExecutors_Executor) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_GetExecutors_Executor) VerboseEqual 

func (this *Response_GetExecutors_Executor) VerboseEqual(that interface{}) error

type Response_GetFlags 

type Response_GetFlags struct {
	Flags []mesos.Flag `protobuf:"bytes,1,rep,name=flags" json:"flags"`
}

Contains the flag configuration of the master.

func NewPopulatedResponse_GetFlags 

func NewPopulatedResponse_GetFlags(r randyMaster, easy bool) *Response_GetFlags

func (*Response_GetFlags) Descriptor 

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

func (*Response_GetFlags) Equal 

func (this *Response_GetFlags) Equal(that interface{}) bool

func (*Response_GetFlags) GetFlags 

func (m *Response_GetFlags) GetFlags() []mesos.Flag

func (*Response_GetFlags) GoString 

func (this *Response_GetFlags) GoString() string

func (*Response_GetFlags) Marshal 

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

func (*Response_GetFlags) MarshalJSON 

func (mj *Response_GetFlags) MarshalJSON() ([]byte, error)

func (*Response_GetFlags) MarshalJSONBuf 

func (mj *Response_GetFlags) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_GetFlags) MarshalTo 

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

func (*Response_GetFlags) ProtoMessage 

func (*Response_GetFlags) ProtoMessage()

func (*Response_GetFlags) Reset 

func (m *Response_GetFlags) Reset()

func (*Response_GetFlags) Size added in v0.0.11 

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

func (*Response_GetFlags) String 

func (this *Response_GetFlags) String() string

func (*Response_GetFlags) Unmarshal 

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

func (*Response_GetFlags) UnmarshalJSON 

func (uj *Response_GetFlags) UnmarshalJSON(input []byte) error

func (*Response_GetFlags) UnmarshalJSONFFLexer 

func (uj *Response_GetFlags) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_GetFlags) VerboseEqual 

func (this *Response_GetFlags) VerboseEqual(that interface{}) 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"`
	// Frameworks that have been teared down.
	CompletedFrameworks []Response_GetFrameworks_Framework `protobuf:"bytes,2,rep,name=completed_frameworks,json=completedFrameworks" json:"completed_frameworks"`
	// 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 []mesos.FrameworkInfo `protobuf:"bytes,3,rep,name=recovered_frameworks,json=recoveredFrameworks" json:"recovered_frameworks"`
}

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 NewPopulatedResponse_GetFrameworks 

func NewPopulatedResponse_GetFrameworks(r randyMaster, easy bool) *Response_GetFrameworks

func (*Response_GetFrameworks) Descriptor 

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

func (*Response_GetFrameworks) Equal 

func (this *Response_GetFrameworks) Equal(that interface{}) bool

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

func (this *Response_GetFrameworks) GoString() string

func (*Response_GetFrameworks) Marshal 

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

func (*Response_GetFrameworks) MarshalJSON 

func (mj *Response_GetFrameworks) MarshalJSON() ([]byte, error)

func (*Response_GetFrameworks) MarshalJSONBuf 

func (mj *Response_GetFrameworks) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_GetFrameworks) MarshalTo 

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

func (*Response_GetFrameworks) ProtoMessage 

func (*Response_GetFrameworks) ProtoMessage()

func (*Response_GetFrameworks) Reset 

func (m *Response_GetFrameworks) Reset()

func (*Response_GetFrameworks) Size added in v0.0.11 

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

func (*Response_GetFrameworks) String 

func (this *Response_GetFrameworks) String() string

func (*Response_GetFrameworks) Unmarshal 

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

func (*Response_GetFrameworks) UnmarshalJSON 

func (uj *Response_GetFrameworks) UnmarshalJSON(input []byte) error

func (*Response_GetFrameworks) UnmarshalJSONFFLexer 

func (uj *Response_GetFrameworks) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_GetFrameworks) VerboseEqual 

func (this *Response_GetFrameworks) VerboseEqual(that interface{}) error

type Response_GetFrameworks_Framework 

type Response_GetFrameworks_Framework struct {
	FrameworkInfo mesos.FrameworkInfo `protobuf:"bytes,1,req,name=framework_info,json=frameworkInfo" json:"framework_info"`
	Active        bool                `protobuf:"varint,2,req,name=active" json:"active"`
	Connected     bool                `protobuf:"varint,3,req,name=connected" json:"connected"`
	// 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"`
	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"`
	InverseOffers      []mesos.InverseOffer `protobuf:"bytes,8,rep,name=inverse_offers,json=inverseOffers" json:"inverse_offers"`
	AllocatedResources []mesos.Resource     `protobuf:"bytes,9,rep,name=allocated_resources,json=allocatedResources" json:"allocated_resources"`
	OfferedResources   []mesos.Resource     `protobuf:"bytes,10,rep,name=offered_resources,json=offeredResources" json:"offered_resources"`
}

func NewPopulatedResponse_GetFrameworks_Framework 

func NewPopulatedResponse_GetFrameworks_Framework(r randyMaster, easy bool) *Response_GetFrameworks_Framework

func (*Response_GetFrameworks_Framework) Descriptor 

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

func (*Response_GetFrameworks_Framework) Equal 

func (this *Response_GetFrameworks_Framework) Equal(that interface{}) bool

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

func (m *Response_GetFrameworks_Framework) GetRecovered() bool

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

func (this *Response_GetFrameworks_Framework) GoString() string

func (*Response_GetFrameworks_Framework) Marshal 

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

func (*Response_GetFrameworks_Framework) MarshalJSON 

func (mj *Response_GetFrameworks_Framework) MarshalJSON() ([]byte, error)

func (*Response_GetFrameworks_Framework) MarshalJSONBuf 

func (mj *Response_GetFrameworks_Framework) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_GetFrameworks_Framework) MarshalTo 

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

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) Size added in v0.0.11 

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

func (*Response_GetFrameworks_Framework) String 

func (this *Response_GetFrameworks_Framework) String() string

func (*Response_GetFrameworks_Framework) Unmarshal 

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

func (*Response_GetFrameworks_Framework) UnmarshalJSON 

func (uj *Response_GetFrameworks_Framework) UnmarshalJSON(input []byte) error

func (*Response_GetFrameworks_Framework) UnmarshalJSONFFLexer 

func (uj *Response_GetFrameworks_Framework) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_GetFrameworks_Framework) VerboseEqual 

func (this *Response_GetFrameworks_Framework) VerboseEqual(that interface{}) error

type Response_GetHealth 

type Response_GetHealth struct {
	Healthy bool `protobuf:"varint,1,req,name=healthy" json:"healthy"`
}

`healthy` would be true if the master is healthy. Delayed responses are also indicative of the poor health of the master.

func NewPopulatedResponse_GetHealth 

func NewPopulatedResponse_GetHealth(r randyMaster, easy bool) *Response_GetHealth

func (*Response_GetHealth) Descriptor 

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

func (*Response_GetHealth) Equal 

func (this *Response_GetHealth) Equal(that interface{}) bool

func (*Response_GetHealth) GetHealthy 

func (m *Response_GetHealth) GetHealthy() bool

func (*Response_GetHealth) GoString 

func (this *Response_GetHealth) GoString() string

func (*Response_GetHealth) Marshal 

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

func (*Response_GetHealth) MarshalJSON 

func (mj *Response_GetHealth) MarshalJSON() ([]byte, error)

func (*Response_GetHealth) MarshalJSONBuf 

func (mj *Response_GetHealth) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_GetHealth) MarshalTo 

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

func (*Response_GetHealth) ProtoMessage 

func (*Response_GetHealth) ProtoMessage()

func (*Response_GetHealth) Reset 

func (m *Response_GetHealth) Reset()

func (*Response_GetHealth) Size added in v0.0.11 

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

func (*Response_GetHealth) String 

func (this *Response_GetHealth) String() string

func (*Response_GetHealth) Unmarshal 

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

func (*Response_GetHealth) UnmarshalJSON 

func (uj *Response_GetHealth) UnmarshalJSON(input []byte) error

func (*Response_GetHealth) UnmarshalJSONFFLexer 

func (uj *Response_GetHealth) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_GetHealth) VerboseEqual 

func (this *Response_GetHealth) VerboseEqual(that interface{}) error

type Response_GetLoggingLevel 

type Response_GetLoggingLevel struct {
	Level uint32 `protobuf:"varint,1,req,name=level" json:"level"`
}

Contains the logging level of the master.

func NewPopulatedResponse_GetLoggingLevel 

func NewPopulatedResponse_GetLoggingLevel(r randyMaster, easy bool) *Response_GetLoggingLevel

func (*Response_GetLoggingLevel) Descriptor 

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

func (*Response_GetLoggingLevel) Equal 

func (this *Response_GetLoggingLevel) Equal(that interface{}) bool

func (*Response_GetLoggingLevel) GetLevel 

func (m *Response_GetLoggingLevel) GetLevel() uint32

func (*Response_GetLoggingLevel) GoString 

func (this *Response_GetLoggingLevel) GoString() string

func (*Response_GetLoggingLevel) Marshal 

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

func (*Response_GetLoggingLevel) MarshalJSON 

func (mj *Response_GetLoggingLevel) MarshalJSON() ([]byte, error)

func (*Response_GetLoggingLevel) MarshalJSONBuf 

func (mj *Response_GetLoggingLevel) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_GetLoggingLevel) MarshalTo 

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

func (*Response_GetLoggingLevel) ProtoMessage 

func (*Response_GetLoggingLevel) ProtoMessage()

func (*Response_GetLoggingLevel) Reset 

func (m *Response_GetLoggingLevel) Reset()

func (*Response_GetLoggingLevel) Size added in v0.0.11 

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

func (*Response_GetLoggingLevel) String 

func (this *Response_GetLoggingLevel) String() string

func (*Response_GetLoggingLevel) Unmarshal 

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

func (*Response_GetLoggingLevel) UnmarshalJSON 

func (uj *Response_GetLoggingLevel) UnmarshalJSON(input []byte) error

func (*Response_GetLoggingLevel) UnmarshalJSONFFLexer 

func (uj *Response_GetLoggingLevel) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_GetLoggingLevel) VerboseEqual 

func (this *Response_GetLoggingLevel) VerboseEqual(that interface{}) error

type Response_GetMaintenanceSchedule 

type Response_GetMaintenanceSchedule struct {
	Schedule mesos_maintenance.Schedule `protobuf:"bytes,1,req,name=schedule" json:"schedule"`
}

Contains the cluster's maintenance schedule.

func NewPopulatedResponse_GetMaintenanceSchedule 

func NewPopulatedResponse_GetMaintenanceSchedule(r randyMaster, easy bool) *Response_GetMaintenanceSchedule

func (*Response_GetMaintenanceSchedule) Descriptor 

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

func (*Response_GetMaintenanceSchedule) Equal 

func (this *Response_GetMaintenanceSchedule) Equal(that interface{}) bool

func (*Response_GetMaintenanceSchedule) GetSchedule 

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

func (*Response_GetMaintenanceSchedule) GoString 

func (this *Response_GetMaintenanceSchedule) GoString() string

func (*Response_GetMaintenanceSchedule) Marshal 

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

func (*Response_GetMaintenanceSchedule) MarshalJSON 

func (mj *Response_GetMaintenanceSchedule) MarshalJSON() ([]byte, error)

func (*Response_GetMaintenanceSchedule) MarshalJSONBuf 

func (mj *Response_GetMaintenanceSchedule) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_GetMaintenanceSchedule) MarshalTo 

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

func (*Response_GetMaintenanceSchedule) ProtoMessage 

func (*Response_GetMaintenanceSchedule) ProtoMessage()

func (*Response_GetMaintenanceSchedule) Reset 

func (m *Response_GetMaintenanceSchedule) Reset()

func (*Response_GetMaintenanceSchedule) Size added in v0.0.11 

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

func (*Response_GetMaintenanceSchedule) String 

func (this *Response_GetMaintenanceSchedule) String() string

func (*Response_GetMaintenanceSchedule) Unmarshal 

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

func (*Response_GetMaintenanceSchedule) UnmarshalJSON 

func (uj *Response_GetMaintenanceSchedule) UnmarshalJSON(input []byte) error

func (*Response_GetMaintenanceSchedule) UnmarshalJSONFFLexer 

func (uj *Response_GetMaintenanceSchedule) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_GetMaintenanceSchedule) VerboseEqual 

func (this *Response_GetMaintenanceSchedule) VerboseEqual(that interface{}) error

type Response_GetMaintenanceStatus 

type Response_GetMaintenanceStatus struct {
	Status mesos_maintenance.ClusterStatus `protobuf:"bytes,1,req,name=status" json:"status"`
}

Contains the cluster's maintenance status.

func NewPopulatedResponse_GetMaintenanceStatus 

func NewPopulatedResponse_GetMaintenanceStatus(r randyMaster, easy bool) *Response_GetMaintenanceStatus

func (*Response_GetMaintenanceStatus) Descriptor 

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

func (*Response_GetMaintenanceStatus) Equal 

func (this *Response_GetMaintenanceStatus) Equal(that interface{}) bool

func (*Response_GetMaintenanceStatus) GetStatus 

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

func (*Response_GetMaintenanceStatus) GoString 

func (this *Response_GetMaintenanceStatus) GoString() string

func (*Response_GetMaintenanceStatus) Marshal 

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

func (*Response_GetMaintenanceStatus) MarshalJSON 

func (mj *Response_GetMaintenanceStatus) MarshalJSON() ([]byte, error)

func (*Response_GetMaintenanceStatus) MarshalJSONBuf 

func (mj *Response_GetMaintenanceStatus) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_GetMaintenanceStatus) MarshalTo 

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

func (*Response_GetMaintenanceStatus) ProtoMessage 

func (*Response_GetMaintenanceStatus) ProtoMessage()

func (*Response_GetMaintenanceStatus) Reset 

func (m *Response_GetMaintenanceStatus) Reset()

func (*Response_GetMaintenanceStatus) Size added in v0.0.11 

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

func (*Response_GetMaintenanceStatus) String 

func (this *Response_GetMaintenanceStatus) String() string

func (*Response_GetMaintenanceStatus) Unmarshal 

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

func (*Response_GetMaintenanceStatus) UnmarshalJSON 

func (uj *Response_GetMaintenanceStatus) UnmarshalJSON(input []byte) error

func (*Response_GetMaintenanceStatus) UnmarshalJSONFFLexer 

func (uj *Response_GetMaintenanceStatus) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_GetMaintenanceStatus) VerboseEqual 

func (this *Response_GetMaintenanceStatus) VerboseEqual(that interface{}) error

type Response_GetMaster 

type Response_GetMaster struct {
	MasterInfo  *mesos.MasterInfo `protobuf:"bytes,1,opt,name=master_info,json=masterInfo" json:"master_info,omitempty"`
	StartTime   *float64          `protobuf:"fixed64,2,opt,name=start_time,json=startTime" json:"start_time,omitempty"`
	ElectedTime *float64          `protobuf:"fixed64,3,opt,name=elected_time,json=electedTime" json:"elected_time,omitempty"`
}

Contains the master's information.

func NewPopulatedResponse_GetMaster 

func NewPopulatedResponse_GetMaster(r randyMaster, easy bool) *Response_GetMaster

func (*Response_GetMaster) Descriptor 

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

func (*Response_GetMaster) Equal 

func (this *Response_GetMaster) Equal(that interface{}) bool

func (*Response_GetMaster) GetElectedTime added in v0.0.7 

func (m *Response_GetMaster) GetElectedTime() float64

func (*Response_GetMaster) GetMasterInfo 

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

func (*Response_GetMaster) GetStartTime added in v0.0.7 

func (m *Response_GetMaster) GetStartTime() float64

func (*Response_GetMaster) GoString 

func (this *Response_GetMaster) GoString() string

func (*Response_GetMaster) Marshal 

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

func (*Response_GetMaster) MarshalJSON 

func (mj *Response_GetMaster) MarshalJSON() ([]byte, error)

func (*Response_GetMaster) MarshalJSONBuf 

func (mj *Response_GetMaster) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_GetMaster) MarshalTo 

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

func (*Response_GetMaster) ProtoMessage 

func (*Response_GetMaster) ProtoMessage()

func (*Response_GetMaster) Reset 

func (m *Response_GetMaster) Reset()

func (*Response_GetMaster) Size added in v0.0.11 

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

func (*Response_GetMaster) String 

func (this *Response_GetMaster) String() string

func (*Response_GetMaster) Unmarshal 

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

func (*Response_GetMaster) UnmarshalJSON 

func (uj *Response_GetMaster) UnmarshalJSON(input []byte) error

func (*Response_GetMaster) UnmarshalJSONFFLexer 

func (uj *Response_GetMaster) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_GetMaster) VerboseEqual 

func (this *Response_GetMaster) VerboseEqual(that interface{}) error

type Response_GetMetrics 

type Response_GetMetrics struct {
	Metrics []mesos.Metric `protobuf:"bytes,1,rep,name=metrics" json:"metrics"`
}

Contains a snapshot of the current metrics.

func NewPopulatedResponse_GetMetrics 

func NewPopulatedResponse_GetMetrics(r randyMaster, easy bool) *Response_GetMetrics

func (*Response_GetMetrics) Descriptor 

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

func (*Response_GetMetrics) Equal 

func (this *Response_GetMetrics) Equal(that interface{}) bool

func (*Response_GetMetrics) GetMetrics 

func (m *Response_GetMetrics) GetMetrics() []mesos.Metric

func (*Response_GetMetrics) GoString 

func (this *Response_GetMetrics) GoString() string

func (*Response_GetMetrics) Marshal 

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

func (*Response_GetMetrics) MarshalJSON 

func (mj *Response_GetMetrics) MarshalJSON() ([]byte, error)

func (*Response_GetMetrics) MarshalJSONBuf 

func (mj *Response_GetMetrics) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_GetMetrics) MarshalTo 

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

func (*Response_GetMetrics) ProtoMessage 

func (*Response_GetMetrics) ProtoMessage()

func (*Response_GetMetrics) Reset 

func (m *Response_GetMetrics) Reset()

func (*Response_GetMetrics) Size added in v0.0.11 

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

func (*Response_GetMetrics) String 

func (this *Response_GetMetrics) String() string

func (*Response_GetMetrics) Unmarshal 

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

func (*Response_GetMetrics) UnmarshalJSON 

func (uj *Response_GetMetrics) UnmarshalJSON(input []byte) error

func (*Response_GetMetrics) UnmarshalJSONFFLexer 

func (uj *Response_GetMetrics) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_GetMetrics) VerboseEqual 

func (this *Response_GetMetrics) VerboseEqual(that interface{}) error

type Response_GetOperations added in v0.0.8 

type Response_GetOperations struct {
	Operations []mesos.Operation `protobuf:"bytes,1,rep,name=operations" json:"operations"`
}

Lists information about all operations known to the master at the current time.

func NewPopulatedResponse_GetOperations added in v0.0.8 

func NewPopulatedResponse_GetOperations(r randyMaster, easy bool) *Response_GetOperations

func (*Response_GetOperations) Descriptor added in v0.0.8 

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

func (*Response_GetOperations) Equal added in v0.0.8 

func (this *Response_GetOperations) Equal(that interface{}) bool

func (*Response_GetOperations) GetOperations added in v0.0.8 

func (m *Response_GetOperations) GetOperations() []mesos.Operation

func (*Response_GetOperations) GoString added in v0.0.8 

func (this *Response_GetOperations) GoString() string

func (*Response_GetOperations) Marshal added in v0.0.8 

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

func (*Response_GetOperations) MarshalJSON added in v0.0.8 

func (mj *Response_GetOperations) MarshalJSON() ([]byte, error)

func (*Response_GetOperations) MarshalJSONBuf added in v0.0.8 

func (mj *Response_GetOperations) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_GetOperations) MarshalTo added in v0.0.8 

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

func (*Response_GetOperations) ProtoMessage added in v0.0.8 

func (*Response_GetOperations) ProtoMessage()

func (*Response_GetOperations) Reset added in v0.0.8 

func (m *Response_GetOperations) Reset()

func (*Response_GetOperations) Size added in v0.0.11 

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

func (*Response_GetOperations) String added in v0.0.8 

func (this *Response_GetOperations) String() string

func (*Response_GetOperations) Unmarshal added in v0.0.8 

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

func (*Response_GetOperations) UnmarshalJSON added in v0.0.8 

func (uj *Response_GetOperations) UnmarshalJSON(input []byte) error

func (*Response_GetOperations) UnmarshalJSONFFLexer added in v0.0.8 

func (uj *Response_GetOperations) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_GetOperations) VerboseEqual added in v0.0.8 

func (this *Response_GetOperations) VerboseEqual(that interface{}) error

type Response_GetQuota 

type Response_GetQuota struct {
	Status mesos_quota.QuotaStatus `protobuf:"bytes,1,req,name=status" json:"status"`
}

Contains the cluster's configured quotas.

func NewPopulatedResponse_GetQuota 

func NewPopulatedResponse_GetQuota(r randyMaster, easy bool) *Response_GetQuota

func (*Response_GetQuota) Descriptor 

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

func (*Response_GetQuota) Equal 

func (this *Response_GetQuota) Equal(that interface{}) bool

func (*Response_GetQuota) GetStatus 

func (m *Response_GetQuota) GetStatus() mesos_quota.QuotaStatus

func (*Response_GetQuota) GoString 

func (this *Response_GetQuota) GoString() string

func (*Response_GetQuota) Marshal 

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

func (*Response_GetQuota) MarshalJSON 

func (mj *Response_GetQuota) MarshalJSON() ([]byte, error)

func (*Response_GetQuota) MarshalJSONBuf 

func (mj *Response_GetQuota) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_GetQuota) MarshalTo 

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

func (*Response_GetQuota) ProtoMessage 

func (*Response_GetQuota) ProtoMessage()

func (*Response_GetQuota) Reset 

func (m *Response_GetQuota) Reset()

func (*Response_GetQuota) Size added in v0.0.11 

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

func (*Response_GetQuota) String 

func (this *Response_GetQuota) String() string

func (*Response_GetQuota) Unmarshal 

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

func (*Response_GetQuota) UnmarshalJSON 

func (uj *Response_GetQuota) UnmarshalJSON(input []byte) error

func (*Response_GetQuota) UnmarshalJSONFFLexer 

func (uj *Response_GetQuota) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_GetQuota) VerboseEqual 

func (this *Response_GetQuota) VerboseEqual(that interface{}) error

type Response_GetRoles 

type Response_GetRoles struct {
	Roles []mesos.Role `protobuf:"bytes,1,rep,name=roles" json:"roles"`
}

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 NewPopulatedResponse_GetRoles 

func NewPopulatedResponse_GetRoles(r randyMaster, easy bool) *Response_GetRoles

func (*Response_GetRoles) Descriptor 

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

func (*Response_GetRoles) Equal 

func (this *Response_GetRoles) Equal(that interface{}) bool

func (*Response_GetRoles) GetRoles 

func (m *Response_GetRoles) GetRoles() []mesos.Role

func (*Response_GetRoles) GoString 

func (this *Response_GetRoles) GoString() string

func (*Response_GetRoles) Marshal 

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

func (*Response_GetRoles) MarshalJSON 

func (mj *Response_GetRoles) MarshalJSON() ([]byte, error)

func (*Response_GetRoles) MarshalJSONBuf 

func (mj *Response_GetRoles) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_GetRoles) MarshalTo 

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

func (*Response_GetRoles) ProtoMessage 

func (*Response_GetRoles) ProtoMessage()

func (*Response_GetRoles) Reset 

func (m *Response_GetRoles) Reset()

func (*Response_GetRoles) Size added in v0.0.11 

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

func (*Response_GetRoles) String 

func (this *Response_GetRoles) String() string

func (*Response_GetRoles) Unmarshal 

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

func (*Response_GetRoles) UnmarshalJSON 

func (uj *Response_GetRoles) UnmarshalJSON(input []byte) error

func (*Response_GetRoles) UnmarshalJSONFFLexer 

func (uj *Response_GetRoles) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_GetRoles) VerboseEqual 

func (this *Response_GetRoles) VerboseEqual(that interface{}) error

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"`
}

Contains full state of the master i.e. information about the tasks, agents, frameworks and executors running in the cluster.

func NewPopulatedResponse_GetState 

func NewPopulatedResponse_GetState(r randyMaster, easy bool) *Response_GetState

func (*Response_GetState) Descriptor 

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

func (*Response_GetState) Equal 

func (this *Response_GetState) Equal(that interface{}) bool

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

func (this *Response_GetState) GoString() string

func (*Response_GetState) Marshal 

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

func (*Response_GetState) MarshalJSON 

func (mj *Response_GetState) MarshalJSON() ([]byte, error)

func (*Response_GetState) MarshalJSONBuf 

func (mj *Response_GetState) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_GetState) MarshalTo 

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

func (*Response_GetState) ProtoMessage 

func (*Response_GetState) ProtoMessage()

func (*Response_GetState) Reset 

func (m *Response_GetState) Reset()

func (*Response_GetState) Size added in v0.0.11 

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

func (*Response_GetState) String 

func (this *Response_GetState) String() string

func (*Response_GetState) Unmarshal 

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

func (*Response_GetState) UnmarshalJSON 

func (uj *Response_GetState) UnmarshalJSON(input []byte) error

func (*Response_GetState) UnmarshalJSONFFLexer 

func (uj *Response_GetState) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_GetState) VerboseEqual 

func (this *Response_GetState) VerboseEqual(that interface{}) error

type Response_GetTasks 

type Response_GetTasks struct {
	// Tasks that are 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"`
	// 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 []mesos.Task `protobuf:"bytes,2,rep,name=tasks" json:"tasks"`
	// 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 []mesos.Task `protobuf:"bytes,5,rep,name=unreachable_tasks,json=unreachableTasks" json:"unreachable_tasks"`
	// 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"`
	// 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 []mesos.Task `protobuf:"bytes,4,rep,name=orphan_tasks,json=orphanTasks" json:"orphan_tasks"`
}

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 NewPopulatedResponse_GetTasks 

func NewPopulatedResponse_GetTasks(r randyMaster, easy bool) *Response_GetTasks

func (*Response_GetTasks) Descriptor 

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

func (*Response_GetTasks) Equal 

func (this *Response_GetTasks) Equal(that interface{}) bool

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

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

func (*Response_GetTasks) GoString 

func (this *Response_GetTasks) GoString() string

func (*Response_GetTasks) Marshal 

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

func (*Response_GetTasks) MarshalJSON 

func (mj *Response_GetTasks) MarshalJSON() ([]byte, error)

func (*Response_GetTasks) MarshalJSONBuf 

func (mj *Response_GetTasks) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_GetTasks) MarshalTo 

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

func (*Response_GetTasks) ProtoMessage 

func (*Response_GetTasks) ProtoMessage()

func (*Response_GetTasks) Reset 

func (m *Response_GetTasks) Reset()

func (*Response_GetTasks) Size added in v0.0.11 

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

func (*Response_GetTasks) String 

func (this *Response_GetTasks) String() string

func (*Response_GetTasks) Unmarshal 

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

func (*Response_GetTasks) UnmarshalJSON 

func (uj *Response_GetTasks) UnmarshalJSON(input []byte) error

func (*Response_GetTasks) UnmarshalJSONFFLexer 

func (uj *Response_GetTasks) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_GetTasks) VerboseEqual 

func (this *Response_GetTasks) VerboseEqual(that interface{}) error

type Response_GetVersion 

type Response_GetVersion struct {
	VersionInfo mesos.VersionInfo `protobuf:"bytes,1,req,name=version_info,json=versionInfo" json:"version_info"`
}

Contains the version information of the master.

func NewPopulatedResponse_GetVersion 

func NewPopulatedResponse_GetVersion(r randyMaster, easy bool) *Response_GetVersion

func (*Response_GetVersion) Descriptor 

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

func (*Response_GetVersion) Equal 

func (this *Response_GetVersion) Equal(that interface{}) bool

func (*Response_GetVersion) GetVersionInfo 

func (m *Response_GetVersion) GetVersionInfo() mesos.VersionInfo

func (*Response_GetVersion) GoString 

func (this *Response_GetVersion) GoString() string

func (*Response_GetVersion) Marshal 

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

func (*Response_GetVersion) MarshalJSON 

func (mj *Response_GetVersion) MarshalJSON() ([]byte, error)

func (*Response_GetVersion) MarshalJSONBuf 

func (mj *Response_GetVersion) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_GetVersion) MarshalTo 

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

func (*Response_GetVersion) ProtoMessage 

func (*Response_GetVersion) ProtoMessage()

func (*Response_GetVersion) Reset 

func (m *Response_GetVersion) Reset()

func (*Response_GetVersion) Size added in v0.0.11 

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

func (*Response_GetVersion) String 

func (this *Response_GetVersion) String() string

func (*Response_GetVersion) Unmarshal 

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

func (*Response_GetVersion) UnmarshalJSON 

func (uj *Response_GetVersion) UnmarshalJSON(input []byte) error

func (*Response_GetVersion) UnmarshalJSONFFLexer 

func (uj *Response_GetVersion) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_GetVersion) VerboseEqual 

func (this *Response_GetVersion) VerboseEqual(that interface{}) error

type Response_GetWeights 

type Response_GetWeights struct {
	WeightInfos []mesos.WeightInfo `protobuf:"bytes,1,rep,name=weight_infos,json=weightInfos" json:"weight_infos"`
}

Provides the weight information about every role.

func NewPopulatedResponse_GetWeights 

func NewPopulatedResponse_GetWeights(r randyMaster, easy bool) *Response_GetWeights

func (*Response_GetWeights) Descriptor 

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

func (*Response_GetWeights) Equal 

func (this *Response_GetWeights) Equal(that interface{}) bool

func (*Response_GetWeights) GetWeightInfos 

func (m *Response_GetWeights) GetWeightInfos() []mesos.WeightInfo

func (*Response_GetWeights) GoString 

func (this *Response_GetWeights) GoString() string

func (*Response_GetWeights) Marshal 

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

func (*Response_GetWeights) MarshalJSON 

func (mj *Response_GetWeights) MarshalJSON() ([]byte, error)

func (*Response_GetWeights) MarshalJSONBuf 

func (mj *Response_GetWeights) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_GetWeights) MarshalTo 

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

func (*Response_GetWeights) ProtoMessage 

func (*Response_GetWeights) ProtoMessage()

func (*Response_GetWeights) Reset 

func (m *Response_GetWeights) Reset()

func (*Response_GetWeights) Size added in v0.0.11 

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

func (*Response_GetWeights) String 

func (this *Response_GetWeights) String() string

func (*Response_GetWeights) Unmarshal 

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

func (*Response_GetWeights) UnmarshalJSON 

func (uj *Response_GetWeights) UnmarshalJSON(input []byte) error

func (*Response_GetWeights) UnmarshalJSONFFLexer 

func (uj *Response_GetWeights) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_GetWeights) VerboseEqual 

func (this *Response_GetWeights) VerboseEqual(that interface{}) error

type Response_ListFiles 

type Response_ListFiles struct {
	FileInfos []mesos.FileInfo `protobuf:"bytes,1,rep,name=file_infos,json=fileInfos" json:"file_infos"`
}

Contains the file listing(similar to `ls -l`) for a directory.

func NewPopulatedResponse_ListFiles 

func NewPopulatedResponse_ListFiles(r randyMaster, easy bool) *Response_ListFiles

func (*Response_ListFiles) Descriptor 

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

func (*Response_ListFiles) Equal 

func (this *Response_ListFiles) Equal(that interface{}) bool

func (*Response_ListFiles) GetFileInfos 

func (m *Response_ListFiles) GetFileInfos() []mesos.FileInfo

func (*Response_ListFiles) GoString 

func (this *Response_ListFiles) GoString() string

func (*Response_ListFiles) Marshal 

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

func (*Response_ListFiles) MarshalJSON 

func (mj *Response_ListFiles) MarshalJSON() ([]byte, error)

func (*Response_ListFiles) MarshalJSONBuf 

func (mj *Response_ListFiles) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_ListFiles) MarshalTo 

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

func (*Response_ListFiles) ProtoMessage 

func (*Response_ListFiles) ProtoMessage()

func (*Response_ListFiles) Reset 

func (m *Response_ListFiles) Reset()

func (*Response_ListFiles) Size added in v0.0.11 

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

func (*Response_ListFiles) String 

func (this *Response_ListFiles) String() string

func (*Response_ListFiles) Unmarshal 

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

func (*Response_ListFiles) UnmarshalJSON 

func (uj *Response_ListFiles) UnmarshalJSON(input []byte) error

func (*Response_ListFiles) UnmarshalJSONFFLexer 

func (uj *Response_ListFiles) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_ListFiles) VerboseEqual 

func (this *Response_ListFiles) VerboseEqual(that interface{}) error

type Response_ReadFile 

type Response_ReadFile struct {
	// The size of file (in bytes).
	Size_ uint64 `protobuf:"varint,1,req,name=size" json:"size"`
	Data  []byte `protobuf:"bytes,2,req,name=data" json:"data,omitempty"`
}

Contains the file data.

func NewPopulatedResponse_ReadFile 

func NewPopulatedResponse_ReadFile(r randyMaster, easy bool) *Response_ReadFile

func (*Response_ReadFile) Descriptor 

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

func (*Response_ReadFile) Equal 

func (this *Response_ReadFile) Equal(that interface{}) bool

func (*Response_ReadFile) GetData 

func (m *Response_ReadFile) GetData() []byte

func (*Response_ReadFile) GetSize_ added in v0.0.11 

func (m *Response_ReadFile) GetSize_() uint64

func (*Response_ReadFile) GoString 

func (this *Response_ReadFile) GoString() string

func (*Response_ReadFile) Marshal 

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

func (*Response_ReadFile) MarshalJSON 

func (mj *Response_ReadFile) MarshalJSON() ([]byte, error)

func (*Response_ReadFile) MarshalJSONBuf 

func (mj *Response_ReadFile) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Response_ReadFile) MarshalTo 

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

func (*Response_ReadFile) ProtoMessage 

func (*Response_ReadFile) ProtoMessage()

func (*Response_ReadFile) Reset 

func (m *Response_ReadFile) Reset()

func (*Response_ReadFile) Size 

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

func (*Response_ReadFile) String 

func (this *Response_ReadFile) String() string

func (*Response_ReadFile) Unmarshal 

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

func (*Response_ReadFile) UnmarshalJSON 

func (uj *Response_ReadFile) UnmarshalJSON(input []byte) error

func (*Response_ReadFile) UnmarshalJSONFFLexer 

func (uj *Response_ReadFile) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Response_ReadFile) VerboseEqual 

func (this *Response_ReadFile) VerboseEqual(that interface{}) 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) MarshalJSON 

func (x Response_Type) MarshalJSON() ([]byte, error)

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

Directories

Path Synopsis

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.