agent

package
v0.0.7 Latest Latest
Warning

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

 Go to latest Published: Jul 24, 2018 License: Apache-2.0 Imports: 13 Imported by: 32

Documentation

Overview

Package agent is a generated protocol buffer package.

It is generated from these files: 

agent/agent.proto

It has these top-level messages: 

Call
Response
ProcessIO

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthAgent = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAgent   = fmt.Errorf("proto: integer overflow")
)
View Source 
var Call_AttachContainerInput_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "CONTAINER_ID",
	2: "PROCESS_IO",
}
View Source 
var Call_AttachContainerInput_Type_value = map[string]int32{
	"UNKNOWN":      0,
	"CONTAINER_ID": 1,
	"PROCESS_IO":   2,
}
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_CONTAINERS",
	11: "GET_FRAMEWORKS",
	12: "GET_EXECUTORS",
	13: "GET_TASKS",
	20: "GET_AGENT",
	26: "GET_RESOURCE_PROVIDERS",
	14: "LAUNCH_NESTED_CONTAINER",
	15: "WAIT_NESTED_CONTAINER",
	16: "KILL_NESTED_CONTAINER",
	21: "REMOVE_NESTED_CONTAINER",
	17: "LAUNCH_NESTED_CONTAINER_SESSION",
	18: "ATTACH_CONTAINER_INPUT",
	19: "ATTACH_CONTAINER_OUTPUT",
	22: "LAUNCH_CONTAINER",
	23: "WAIT_CONTAINER",
	24: "KILL_CONTAINER",
	25: "REMOVE_CONTAINER",
	27: "ADD_RESOURCE_PROVIDER_CONFIG",
	28: "UPDATE_RESOURCE_PROVIDER_CONFIG",
	29: "REMOVE_RESOURCE_PROVIDER_CONFIG",
	30: "PRUNE_IMAGES",
}
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_CONTAINERS":                  10,
	"GET_FRAMEWORKS":                  11,
	"GET_EXECUTORS":                   12,
	"GET_TASKS":                       13,
	"GET_AGENT":                       20,
	"GET_RESOURCE_PROVIDERS":          26,
	"LAUNCH_NESTED_CONTAINER":         14,
	"WAIT_NESTED_CONTAINER":           15,
	"KILL_NESTED_CONTAINER":           16,
	"REMOVE_NESTED_CONTAINER":         21,
	"LAUNCH_NESTED_CONTAINER_SESSION": 17,
	"ATTACH_CONTAINER_INPUT":          18,
	"ATTACH_CONTAINER_OUTPUT":         19,
	"LAUNCH_CONTAINER":                22,
	"WAIT_CONTAINER":                  23,
	"KILL_CONTAINER":                  24,
	"REMOVE_CONTAINER":                25,
	"ADD_RESOURCE_PROVIDER_CONFIG":    27,
	"UPDATE_RESOURCE_PROVIDER_CONFIG": 28,
	"REMOVE_RESOURCE_PROVIDER_CONFIG": 29,
	"PRUNE_IMAGES":                    30,
}
View Source 
var ProcessIO_Control_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "TTY_INFO",
	2: "HEARTBEAT",
}
View Source 
var ProcessIO_Control_Type_value = map[string]int32{
	"UNKNOWN":   0,
	"TTY_INFO":  1,
	"HEARTBEAT": 2,
}
View Source 
var ProcessIO_Data_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "STDIN",
	2: "STDOUT",
	3: "STDERR",
}
View Source 
var ProcessIO_Data_Type_value = map[string]int32{
	"UNKNOWN": 0,
	"STDIN":   1,
	"STDOUT":  2,
	"STDERR":  3,
}
View Source 
var ProcessIO_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "DATA",
	2: "CONTROL",
}
View Source 
var ProcessIO_Type_value = map[string]int32{
	"UNKNOWN": 0,
	"DATA":    1,
	"CONTROL": 2,
}
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_CONTAINERS",
	10: "GET_FRAMEWORKS",
	11: "GET_EXECUTORS",
	12: "GET_TASKS",
	14: "GET_AGENT",
	16: "GET_RESOURCE_PROVIDERS",
	13: "WAIT_NESTED_CONTAINER",
	15: "WAIT_CONTAINER",
}
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_CONTAINERS":         9,
	"GET_FRAMEWORKS":         10,
	"GET_EXECUTORS":          11,
	"GET_TASKS":              12,
	"GET_AGENT":              14,
	"GET_RESOURCE_PROVIDERS": 16,
	"WAIT_NESTED_CONTAINER":  13,
	"WAIT_CONTAINER":         15,
}

Functions

This section is empty.

Types

type Call 

type Call struct {
	Type                         Call_Type                          `protobuf:"varint,1,opt,name=type,enum=mesos.agent.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"`
	GetContainers                *Call_GetContainers                `protobuf:"bytes,20,opt,name=get_containers,json=getContainers" json:"get_containers,omitempty"`
	LaunchNestedContainer        *Call_LaunchNestedContainer        `protobuf:"bytes,6,opt,name=launch_nested_container,json=launchNestedContainer" json:"launch_nested_container,omitempty"`
	WaitNestedContainer          *Call_WaitNestedContainer          `protobuf:"bytes,7,opt,name=wait_nested_container,json=waitNestedContainer" json:"wait_nested_container,omitempty"`
	KillNestedContainer          *Call_KillNestedContainer          `protobuf:"bytes,8,opt,name=kill_nested_container,json=killNestedContainer" json:"kill_nested_container,omitempty"`
	RemoveNestedContainer        *Call_RemoveNestedContainer        `protobuf:"bytes,12,opt,name=remove_nested_container,json=removeNestedContainer" json:"remove_nested_container,omitempty"`
	LaunchNestedContainerSession *Call_LaunchNestedContainerSession `` /* 142-byte string literal not displayed */
	AttachContainerInput         *Call_AttachContainerInput         `protobuf:"bytes,10,opt,name=attach_container_input,json=attachContainerInput" json:"attach_container_input,omitempty"`
	AttachContainerOutput        *Call_AttachContainerOutput        `protobuf:"bytes,11,opt,name=attach_container_output,json=attachContainerOutput" json:"attach_container_output,omitempty"`
	LaunchContainer              *Call_LaunchContainer              `protobuf:"bytes,13,opt,name=launch_container,json=launchContainer" json:"launch_container,omitempty"`
	WaitContainer                *Call_WaitContainer                `protobuf:"bytes,14,opt,name=wait_container,json=waitContainer" json:"wait_container,omitempty"`
	KillContainer                *Call_KillContainer                `protobuf:"bytes,15,opt,name=kill_container,json=killContainer" json:"kill_container,omitempty"`
	RemoveContainer              *Call_RemoveContainer              `protobuf:"bytes,16,opt,name=remove_container,json=removeContainer" json:"remove_container,omitempty"`
	AddResourceProviderConfig    *Call_AddResourceProviderConfig    `` /* 134-byte string literal not displayed */
	UpdateResourceProviderConfig *Call_UpdateResourceProviderConfig `` /* 143-byte string literal not displayed */
	RemoveResourceProviderConfig *Call_RemoveResourceProviderConfig `` /* 143-byte string literal not displayed */
	PruneImages                  *Call_PruneImages                  `protobuf:"bytes,21,opt,name=prune_images,json=pruneImages" json:"prune_images,omitempty"`
}

* Calls that can be sent to the v1 agent 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 randyAgent, easy bool) *Call

func (*Call) Descriptor 

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

func (*Call) Equal 

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

func (*Call) GetAddResourceProviderConfig added in v0.0.7 

func (m *Call) GetAddResourceProviderConfig() *Call_AddResourceProviderConfig

func (*Call) GetAttachContainerInput 

func (m *Call) GetAttachContainerInput() *Call_AttachContainerInput

func (*Call) GetAttachContainerOutput 

func (m *Call) GetAttachContainerOutput() *Call_AttachContainerOutput

func (*Call) GetGetContainers added in v0.0.7 

func (m *Call) GetGetContainers() *Call_GetContainers

func (*Call) GetGetMetrics 

func (m *Call) GetGetMetrics() *Call_GetMetrics

func (*Call) GetKillContainer added in v0.0.7 

func (m *Call) GetKillContainer() *Call_KillContainer

func (*Call) GetKillNestedContainer 

func (m *Call) GetKillNestedContainer() *Call_KillNestedContainer

func (*Call) GetLaunchContainer added in v0.0.7 

func (m *Call) GetLaunchContainer() *Call_LaunchContainer

func (*Call) GetLaunchNestedContainer 

func (m *Call) GetLaunchNestedContainer() *Call_LaunchNestedContainer

func (*Call) GetLaunchNestedContainerSession 

func (m *Call) GetLaunchNestedContainerSession() *Call_LaunchNestedContainerSession

func (*Call) GetListFiles 

func (m *Call) GetListFiles() *Call_ListFiles

func (*Call) GetPruneImages added in v0.0.7 

func (m *Call) GetPruneImages() *Call_PruneImages

func (*Call) GetReadFile 

func (m *Call) GetReadFile() *Call_ReadFile

func (*Call) GetRemoveContainer added in v0.0.7 

func (m *Call) GetRemoveContainer() *Call_RemoveContainer

func (*Call) GetRemoveNestedContainer added in v0.0.5 

func (m *Call) GetRemoveNestedContainer() *Call_RemoveNestedContainer

func (*Call) GetRemoveResourceProviderConfig added in v0.0.7 

func (m *Call) GetRemoveResourceProviderConfig() *Call_RemoveResourceProviderConfig

func (*Call) GetSetLoggingLevel 

func (m *Call) GetSetLoggingLevel() *Call_SetLoggingLevel

func (*Call) GetType 

func (m *Call) GetType() Call_Type

func (*Call) GetUpdateResourceProviderConfig added in v0.0.7 

func (m *Call) GetUpdateResourceProviderConfig() *Call_UpdateResourceProviderConfig

func (*Call) GetWaitContainer added in v0.0.7 

func (m *Call) GetWaitContainer() *Call_WaitContainer

func (*Call) GetWaitNestedContainer 

func (m *Call) GetWaitNestedContainer() *Call_WaitNestedContainer

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

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

func (*Call) Reset 

func (m *Call) Reset()

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

type Call_AddResourceProviderConfig struct {
	Info mesos.ResourceProviderInfo `protobuf:"bytes,1,req,name=info" json:"info"`
}

Adds a new resource provider config file.

The content of the `info` field will be written into a new config file in the resource provider config directory, and a new resource provider will be launched asynchronously based on the config. Callers must not set the `info.id` field. This call is idempotent, so if a config file identical to the content of the `info` field already exists, this call will return without launching a resource provider. Note that if a config file is placed into the resource provider config directory out-of-band after the agent starts up, it will not be checked against this call.

Returns 200 OK if a new config file is created, or an identical config file 

exists.

Returns 400 Bad Request if `info` is not well-formed. Returns 403 Forbidden if the call is not authorized. Returns 409 Conflict if another config file that describes a 

resource provider of the same type and name exists, but the content is
not identical.

Returns 500 Internal Server Error if anything goes wrong.

func NewPopulatedCall_AddResourceProviderConfig added in v0.0.7 

func NewPopulatedCall_AddResourceProviderConfig(r randyAgent, easy bool) *Call_AddResourceProviderConfig

func (*Call_AddResourceProviderConfig) Descriptor added in v0.0.7 

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

func (*Call_AddResourceProviderConfig) Equal added in v0.0.7 

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

func (*Call_AddResourceProviderConfig) GetInfo added in v0.0.7 

func (m *Call_AddResourceProviderConfig) GetInfo() mesos.ResourceProviderInfo

func (*Call_AddResourceProviderConfig) GoString added in v0.0.7 

func (this *Call_AddResourceProviderConfig) GoString() string

func (*Call_AddResourceProviderConfig) Marshal added in v0.0.7 

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

func (*Call_AddResourceProviderConfig) MarshalJSON added in v0.0.7 

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

func (*Call_AddResourceProviderConfig) MarshalJSONBuf added in v0.0.7 

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

func (*Call_AddResourceProviderConfig) MarshalTo added in v0.0.7 

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

func (*Call_AddResourceProviderConfig) ProtoMessage added in v0.0.7 

func (*Call_AddResourceProviderConfig) ProtoMessage()

func (*Call_AddResourceProviderConfig) ProtoSize added in v0.0.7 

func (m *Call_AddResourceProviderConfig) ProtoSize() (n int)

func (*Call_AddResourceProviderConfig) Reset added in v0.0.7 

func (m *Call_AddResourceProviderConfig) Reset()

func (*Call_AddResourceProviderConfig) String added in v0.0.7 

func (this *Call_AddResourceProviderConfig) String() string

func (*Call_AddResourceProviderConfig) Unmarshal added in v0.0.7 

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

func (*Call_AddResourceProviderConfig) UnmarshalJSON added in v0.0.7 

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

func (*Call_AddResourceProviderConfig) UnmarshalJSONFFLexer added in v0.0.7 

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

func (*Call_AddResourceProviderConfig) VerboseEqual added in v0.0.7 

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

type Call_AttachContainerInput 

type Call_AttachContainerInput struct {
	Type        Call_AttachContainerInput_Type `protobuf:"varint,1,opt,name=type,enum=mesos.agent.Call_AttachContainerInput_Type" json:"type"`
	ContainerID *mesos.ContainerID             `protobuf:"bytes,2,opt,name=container_id,json=containerId" json:"container_id,omitempty"`
	ProcessIO   *ProcessIO                     `protobuf:"bytes,3,opt,name=process_io,json=processIo" json:"process_io,omitempty"`
}

Attaches the caller to the STDIN of the entry point of the container. Clients can use this to stream input data to a container. Note that this call needs to be made on a persistent connection by streaming a CONTAINER_ID message followed by one or more PROCESS_IO messages.

func NewPopulatedCall_AttachContainerInput 

func NewPopulatedCall_AttachContainerInput(r randyAgent, easy bool) *Call_AttachContainerInput

func (*Call_AttachContainerInput) Descriptor 

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

func (*Call_AttachContainerInput) Equal 

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

func (*Call_AttachContainerInput) GetContainerID 

func (m *Call_AttachContainerInput) GetContainerID() *mesos.ContainerID

func (*Call_AttachContainerInput) GetProcessIO 

func (m *Call_AttachContainerInput) GetProcessIO() *ProcessIO

func (*Call_AttachContainerInput) GetType 

func (m *Call_AttachContainerInput) GetType() Call_AttachContainerInput_Type

func (*Call_AttachContainerInput) GoString 

func (this *Call_AttachContainerInput) GoString() string

func (*Call_AttachContainerInput) Marshal 

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

func (*Call_AttachContainerInput) MarshalJSON 

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

func (*Call_AttachContainerInput) MarshalJSONBuf 

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

func (*Call_AttachContainerInput) MarshalTo 

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

func (*Call_AttachContainerInput) ProtoMessage 

func (*Call_AttachContainerInput) ProtoMessage()

func (*Call_AttachContainerInput) ProtoSize 

func (m *Call_AttachContainerInput) ProtoSize() (n int)

func (*Call_AttachContainerInput) Reset 

func (m *Call_AttachContainerInput) Reset()

func (*Call_AttachContainerInput) String 

func (this *Call_AttachContainerInput) String() string

func (*Call_AttachContainerInput) Unmarshal 

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

func (*Call_AttachContainerInput) UnmarshalJSON 

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

func (*Call_AttachContainerInput) UnmarshalJSONFFLexer 

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

func (*Call_AttachContainerInput) VerboseEqual 

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

type Call_AttachContainerInput_Type 

type Call_AttachContainerInput_Type int32
const (
	Call_AttachContainerInput_UNKNOWN      Call_AttachContainerInput_Type = 0
	Call_AttachContainerInput_CONTAINER_ID Call_AttachContainerInput_Type = 1
	Call_AttachContainerInput_PROCESS_IO   Call_AttachContainerInput_Type = 2
)

func (Call_AttachContainerInput_Type) Enum 

func (x Call_AttachContainerInput_Type) Enum() *Call_AttachContainerInput_Type

func (Call_AttachContainerInput_Type) EnumDescriptor 

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

func (Call_AttachContainerInput_Type) MarshalJSON 

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

func (Call_AttachContainerInput_Type) String 

func (x Call_AttachContainerInput_Type) String() string

func (*Call_AttachContainerInput_Type) UnmarshalJSON 

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

type Call_AttachContainerOutput 

type Call_AttachContainerOutput struct {
	ContainerID mesos.ContainerID `protobuf:"bytes,1,req,name=container_id,json=containerId" json:"container_id"`
}

Attaches the caller to the STDOUT and STDERR of the entrypoint of the container. Clients can use this to stream output/error from the container. This call will result in a streaming response of `ProcessIO`; so this call needs to be made on a persistent connection.

func NewPopulatedCall_AttachContainerOutput 

func NewPopulatedCall_AttachContainerOutput(r randyAgent, easy bool) *Call_AttachContainerOutput

func (*Call_AttachContainerOutput) Descriptor 

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

func (*Call_AttachContainerOutput) Equal 

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

func (*Call_AttachContainerOutput) GetContainerID 

func (m *Call_AttachContainerOutput) GetContainerID() mesos.ContainerID

func (*Call_AttachContainerOutput) GoString 

func (this *Call_AttachContainerOutput) GoString() string

func (*Call_AttachContainerOutput) Marshal 

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

func (*Call_AttachContainerOutput) MarshalJSON 

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

func (*Call_AttachContainerOutput) MarshalJSONBuf 

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

func (*Call_AttachContainerOutput) MarshalTo 

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

func (*Call_AttachContainerOutput) ProtoMessage 

func (*Call_AttachContainerOutput) ProtoMessage()

func (*Call_AttachContainerOutput) ProtoSize 

func (m *Call_AttachContainerOutput) ProtoSize() (n int)

func (*Call_AttachContainerOutput) Reset 

func (m *Call_AttachContainerOutput) Reset()

func (*Call_AttachContainerOutput) String 

func (this *Call_AttachContainerOutput) String() string

func (*Call_AttachContainerOutput) Unmarshal 

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

func (*Call_AttachContainerOutput) UnmarshalJSON 

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

func (*Call_AttachContainerOutput) UnmarshalJSONFFLexer 

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

func (*Call_AttachContainerOutput) VerboseEqual 

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

type Call_GetContainers added in v0.0.7 

type Call_GetContainers struct {
	ShowNested     *bool `protobuf:"varint,1,opt,name=show_nested,json=showNested" json:"show_nested,omitempty"`
	ShowStandalone *bool `protobuf:"varint,2,opt,name=show_standalone,json=showStandalone" json:"show_standalone,omitempty"`
}

Lists active containers on the agent.

func NewPopulatedCall_GetContainers added in v0.0.7 

func NewPopulatedCall_GetContainers(r randyAgent, easy bool) *Call_GetContainers

func (*Call_GetContainers) Descriptor added in v0.0.7 

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

func (*Call_GetContainers) Equal added in v0.0.7 

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

func (*Call_GetContainers) GetShowNested added in v0.0.7 

func (m *Call_GetContainers) GetShowNested() bool

func (*Call_GetContainers) GetShowStandalone added in v0.0.7 

func (m *Call_GetContainers) GetShowStandalone() bool

func (*Call_GetContainers) GoString added in v0.0.7 

func (this *Call_GetContainers) GoString() string

func (*Call_GetContainers) Marshal added in v0.0.7 

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

func (*Call_GetContainers) MarshalJSON added in v0.0.7 

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

func (*Call_GetContainers) MarshalJSONBuf added in v0.0.7 

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

func (*Call_GetContainers) MarshalTo added in v0.0.7 

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

func (*Call_GetContainers) ProtoMessage added in v0.0.7 

func (*Call_GetContainers) ProtoMessage()

func (*Call_GetContainers) ProtoSize added in v0.0.7 

func (m *Call_GetContainers) ProtoSize() (n int)

func (*Call_GetContainers) Reset added in v0.0.7 

func (m *Call_GetContainers) Reset()

func (*Call_GetContainers) String added in v0.0.7 

func (this *Call_GetContainers) String() string

func (*Call_GetContainers) Unmarshal added in v0.0.7 

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

func (*Call_GetContainers) UnmarshalJSON added in v0.0.7 

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

func (*Call_GetContainers) UnmarshalJSONFFLexer added in v0.0.7 

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

func (*Call_GetContainers) VerboseEqual added in v0.0.7 

func (this *Call_GetContainers) 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 agent.

func NewPopulatedCall_GetMetrics 

func NewPopulatedCall_GetMetrics(r randyAgent, 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) ProtoSize 

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

func (*Call_GetMetrics) Reset 

func (m *Call_GetMetrics) Reset()

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

type Call_KillContainer struct {
	ContainerID mesos.ContainerID `protobuf:"bytes,1,req,name=container_id,json=containerId" json:"container_id"`
	// Defaults to SIGKILL.
	Signal *int32 `protobuf:"varint,2,opt,name=signal" json:"signal,omitempty"`
}

Kills the standalone or nested container. The signal to be sent to the container can be specified in the 'signal' field.

Returns 200 OK if the signal is sent successfully. Returns 404 Not Found if the container does not exist.

func NewPopulatedCall_KillContainer added in v0.0.7 

func NewPopulatedCall_KillContainer(r randyAgent, easy bool) *Call_KillContainer

func (*Call_KillContainer) Descriptor added in v0.0.7 

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

func (*Call_KillContainer) Equal added in v0.0.7 

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

func (*Call_KillContainer) GetContainerID added in v0.0.7 

func (m *Call_KillContainer) GetContainerID() mesos.ContainerID

func (*Call_KillContainer) GetSignal added in v0.0.7 

func (m *Call_KillContainer) GetSignal() int32

func (*Call_KillContainer) GoString added in v0.0.7 

func (this *Call_KillContainer) GoString() string

func (*Call_KillContainer) Marshal added in v0.0.7 

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

func (*Call_KillContainer) MarshalJSON added in v0.0.7 

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

func (*Call_KillContainer) MarshalJSONBuf added in v0.0.7 

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

func (*Call_KillContainer) MarshalTo added in v0.0.7 

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

func (*Call_KillContainer) ProtoMessage added in v0.0.7 

func (*Call_KillContainer) ProtoMessage()

func (*Call_KillContainer) ProtoSize added in v0.0.7 

func (m *Call_KillContainer) ProtoSize() (n int)

func (*Call_KillContainer) Reset added in v0.0.7 

func (m *Call_KillContainer) Reset()

func (*Call_KillContainer) String added in v0.0.7 

func (this *Call_KillContainer) String() string

func (*Call_KillContainer) Unmarshal added in v0.0.7 

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

func (*Call_KillContainer) UnmarshalJSON added in v0.0.7 

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

func (*Call_KillContainer) UnmarshalJSONFFLexer added in v0.0.7 

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

func (*Call_KillContainer) VerboseEqual added in v0.0.7 

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

type Call_KillNestedContainer 

type Call_KillNestedContainer struct {
	ContainerID mesos.ContainerID `protobuf:"bytes,1,req,name=container_id,json=containerId" json:"container_id"`
	Signal      *int32            `protobuf:"varint,2,opt,name=signal" json:"signal,omitempty"`
}

Deprecated in favor of `KillContainer`.

func NewPopulatedCall_KillNestedContainer 

func NewPopulatedCall_KillNestedContainer(r randyAgent, easy bool) *Call_KillNestedContainer

func (*Call_KillNestedContainer) Descriptor 

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

func (*Call_KillNestedContainer) Equal 

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

func (*Call_KillNestedContainer) GetContainerID 

func (m *Call_KillNestedContainer) GetContainerID() mesos.ContainerID

func (*Call_KillNestedContainer) GetSignal added in v0.0.6 

func (m *Call_KillNestedContainer) GetSignal() int32

func (*Call_KillNestedContainer) GoString 

func (this *Call_KillNestedContainer) GoString() string

func (*Call_KillNestedContainer) Marshal 

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

func (*Call_KillNestedContainer) MarshalJSON 

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

func (*Call_KillNestedContainer) MarshalJSONBuf 

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

func (*Call_KillNestedContainer) MarshalTo 

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

func (*Call_KillNestedContainer) ProtoMessage 

func (*Call_KillNestedContainer) ProtoMessage()

func (*Call_KillNestedContainer) ProtoSize 

func (m *Call_KillNestedContainer) ProtoSize() (n int)

func (*Call_KillNestedContainer) Reset 

func (m *Call_KillNestedContainer) Reset()

func (*Call_KillNestedContainer) String 

func (this *Call_KillNestedContainer) String() string

func (*Call_KillNestedContainer) Unmarshal 

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

func (*Call_KillNestedContainer) UnmarshalJSON 

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

func (*Call_KillNestedContainer) UnmarshalJSONFFLexer 

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

func (*Call_KillNestedContainer) VerboseEqual 

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

type Call_LaunchContainer added in v0.0.7 

type Call_LaunchContainer struct {
	// NOTE: Some characters cannot be used in the ID. All characters
	// must be valid filesystem path characters.  In addition, '/' and '.'
	// are reserved.
	ContainerID mesos.ContainerID  `protobuf:"bytes,1,req,name=container_id,json=containerId" json:"container_id"`
	Command     *mesos.CommandInfo `protobuf:"bytes,2,opt,name=command" json:"command,omitempty"`
	// NOTE: Nested containers may not specify resources and instead
	// share resources with its parent container.
	//
	// TODO(josephw): These resources are purely used for isolation
	// and are not accounted for by the Mesos master (if connected).
	// It is the caller's responsibility to ensure that resources are
	// not overcommitted (e.g. CPU and memory) or conflicting (e.g. ports
	// and volumes). Once there is support for preempting tasks and a
	// way to update the resources advertised by the agent, these standalone
	// container resources should be accounted for by the master.
	Resources []mesos.Resource     `protobuf:"bytes,3,rep,name=resources" json:"resources"`
	Container *mesos.ContainerInfo `protobuf:"bytes,4,opt,name=container" json:"container,omitempty"`
}

Launches a either a "standalone" container on this agent or a nested container within another tree of containers.

A standalone container is launched by specifying a ContainerID with no parent. Standalone containers bypass the normal offer cycle between the master and agent. Unlike other containers, a standalone container does not have an executor or any tasks. This means the standalone container does not report back to Mesos or any framework and must be supervised separately.

A nested container is launched by specifying a ContainerID with another existing container (including standalone containers) as the parent.

Returns 200 OK if the new container launch succeeds. Returns 202 Accepted if the requested ContainerID is already in use 

by a standalone or nested container.

Returns 400 Bad Request if the container launch fails.

func NewPopulatedCall_LaunchContainer added in v0.0.7 

func NewPopulatedCall_LaunchContainer(r randyAgent, easy bool) *Call_LaunchContainer

func (*Call_LaunchContainer) Descriptor added in v0.0.7 

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

func (*Call_LaunchContainer) Equal added in v0.0.7 

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

func (*Call_LaunchContainer) GetCommand added in v0.0.7 

func (m *Call_LaunchContainer) GetCommand() *mesos.CommandInfo

func (*Call_LaunchContainer) GetContainer added in v0.0.7 

func (m *Call_LaunchContainer) GetContainer() *mesos.ContainerInfo

func (*Call_LaunchContainer) GetContainerID added in v0.0.7 

func (m *Call_LaunchContainer) GetContainerID() mesos.ContainerID

func (*Call_LaunchContainer) GetResources added in v0.0.7 

func (m *Call_LaunchContainer) GetResources() []mesos.Resource

func (*Call_LaunchContainer) GoString added in v0.0.7 

func (this *Call_LaunchContainer) GoString() string

func (*Call_LaunchContainer) Marshal added in v0.0.7 

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

func (*Call_LaunchContainer) MarshalJSON added in v0.0.7 

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

func (*Call_LaunchContainer) MarshalJSONBuf added in v0.0.7 

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

func (*Call_LaunchContainer) MarshalTo added in v0.0.7 

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

func (*Call_LaunchContainer) ProtoMessage added in v0.0.7 

func (*Call_LaunchContainer) ProtoMessage()

func (*Call_LaunchContainer) ProtoSize added in v0.0.7 

func (m *Call_LaunchContainer) ProtoSize() (n int)

func (*Call_LaunchContainer) Reset added in v0.0.7 

func (m *Call_LaunchContainer) Reset()

func (*Call_LaunchContainer) String added in v0.0.7 

func (this *Call_LaunchContainer) String() string

func (*Call_LaunchContainer) Unmarshal added in v0.0.7 

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

func (*Call_LaunchContainer) UnmarshalJSON added in v0.0.7 

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

func (*Call_LaunchContainer) UnmarshalJSONFFLexer added in v0.0.7 

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

func (*Call_LaunchContainer) VerboseEqual added in v0.0.7 

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

type Call_LaunchNestedContainer 

type Call_LaunchNestedContainer struct {
	ContainerID mesos.ContainerID    `protobuf:"bytes,1,req,name=container_id,json=containerId" json:"container_id"`
	Command     *mesos.CommandInfo   `protobuf:"bytes,2,opt,name=command" json:"command,omitempty"`
	Container   *mesos.ContainerInfo `protobuf:"bytes,3,opt,name=container" json:"container,omitempty"`
}

Deprecated in favor of `LaunchContainer`.

func NewPopulatedCall_LaunchNestedContainer 

func NewPopulatedCall_LaunchNestedContainer(r randyAgent, easy bool) *Call_LaunchNestedContainer

func (*Call_LaunchNestedContainer) Descriptor 

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

func (*Call_LaunchNestedContainer) Equal 

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

func (*Call_LaunchNestedContainer) GetCommand 

func (m *Call_LaunchNestedContainer) GetCommand() *mesos.CommandInfo

func (*Call_LaunchNestedContainer) GetContainer 

func (m *Call_LaunchNestedContainer) GetContainer() *mesos.ContainerInfo

func (*Call_LaunchNestedContainer) GetContainerID 

func (m *Call_LaunchNestedContainer) GetContainerID() mesos.ContainerID

func (*Call_LaunchNestedContainer) GoString 

func (this *Call_LaunchNestedContainer) GoString() string

func (*Call_LaunchNestedContainer) Marshal 

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

func (*Call_LaunchNestedContainer) MarshalJSON 

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

func (*Call_LaunchNestedContainer) MarshalJSONBuf 

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

func (*Call_LaunchNestedContainer) MarshalTo 

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

func (*Call_LaunchNestedContainer) ProtoMessage 

func (*Call_LaunchNestedContainer) ProtoMessage()

func (*Call_LaunchNestedContainer) ProtoSize 

func (m *Call_LaunchNestedContainer) ProtoSize() (n int)

func (*Call_LaunchNestedContainer) Reset 

func (m *Call_LaunchNestedContainer) Reset()

func (*Call_LaunchNestedContainer) String 

func (this *Call_LaunchNestedContainer) String() string

func (*Call_LaunchNestedContainer) Unmarshal 

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

func (*Call_LaunchNestedContainer) UnmarshalJSON 

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

func (*Call_LaunchNestedContainer) UnmarshalJSONFFLexer 

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

func (*Call_LaunchNestedContainer) VerboseEqual 

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

type Call_LaunchNestedContainerSession 

type Call_LaunchNestedContainerSession struct {
	ContainerID mesos.ContainerID    `protobuf:"bytes,1,req,name=container_id,json=containerId" json:"container_id"`
	Command     *mesos.CommandInfo   `protobuf:"bytes,2,opt,name=command" json:"command,omitempty"`
	Container   *mesos.ContainerInfo `protobuf:"bytes,3,opt,name=container" json:"container,omitempty"`
}

Launches a nested container within an executor's tree of containers. The differences between this call and `LaunchNestedContainer` are:

  1. The container's life-cycle is tied to the lifetime of the connection used to make this call, i.e., if the connection ever breaks, the container will be destroyed.
  2. The nested container shares the same namespaces and cgroups as its parent container.
  3. Results in a streaming response of type `ProcessIO`. So the call needs to be made on a persistent connection.

func NewPopulatedCall_LaunchNestedContainerSession 

func NewPopulatedCall_LaunchNestedContainerSession(r randyAgent, easy bool) *Call_LaunchNestedContainerSession

func (*Call_LaunchNestedContainerSession) Descriptor 

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

func (*Call_LaunchNestedContainerSession) Equal 

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

func (*Call_LaunchNestedContainerSession) GetCommand 

func (m *Call_LaunchNestedContainerSession) GetCommand() *mesos.CommandInfo

func (*Call_LaunchNestedContainerSession) GetContainer 

func (m *Call_LaunchNestedContainerSession) GetContainer() *mesos.ContainerInfo

func (*Call_LaunchNestedContainerSession) GetContainerID 

func (m *Call_LaunchNestedContainerSession) GetContainerID() mesos.ContainerID

func (*Call_LaunchNestedContainerSession) GoString 

func (this *Call_LaunchNestedContainerSession) GoString() string

func (*Call_LaunchNestedContainerSession) Marshal 

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

func (*Call_LaunchNestedContainerSession) MarshalJSON 

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

func (*Call_LaunchNestedContainerSession) MarshalJSONBuf 

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

func (*Call_LaunchNestedContainerSession) MarshalTo 

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

func (*Call_LaunchNestedContainerSession) ProtoMessage 

func (*Call_LaunchNestedContainerSession) ProtoMessage()

func (*Call_LaunchNestedContainerSession) ProtoSize 

func (m *Call_LaunchNestedContainerSession) ProtoSize() (n int)

func (*Call_LaunchNestedContainerSession) Reset 

func (m *Call_LaunchNestedContainerSession) Reset()

func (*Call_LaunchNestedContainerSession) String 

func (this *Call_LaunchNestedContainerSession) String() string

func (*Call_LaunchNestedContainerSession) Unmarshal 

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

func (*Call_LaunchNestedContainerSession) UnmarshalJSON 

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

func (*Call_LaunchNestedContainerSession) UnmarshalJSONFFLexer 

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

func (*Call_LaunchNestedContainerSession) VerboseEqual 

func (this *Call_LaunchNestedContainerSession) 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 randyAgent, 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) ProtoSize 

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

func (*Call_ListFiles) Reset 

func (m *Call_ListFiles) Reset()

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

type Call_PruneImages struct {
	ExcludedImages []mesos.Image `protobuf:"bytes,1,rep,name=excluded_images,json=excludedImages" json:"excluded_images"`
}

Prune unused container images from image store.

Images and layers referenced by active containers as well as image references specified in `excluded_images` will not be pruned.

func NewPopulatedCall_PruneImages added in v0.0.7 

func NewPopulatedCall_PruneImages(r randyAgent, easy bool) *Call_PruneImages

func (*Call_PruneImages) Descriptor added in v0.0.7 

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

func (*Call_PruneImages) Equal added in v0.0.7 

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

func (*Call_PruneImages) GetExcludedImages added in v0.0.7 

func (m *Call_PruneImages) GetExcludedImages() []mesos.Image

func (*Call_PruneImages) GoString added in v0.0.7 

func (this *Call_PruneImages) GoString() string

func (*Call_PruneImages) Marshal added in v0.0.7 

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

func (*Call_PruneImages) MarshalJSON added in v0.0.7 

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

func (*Call_PruneImages) MarshalJSONBuf added in v0.0.7 

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

func (*Call_PruneImages) MarshalTo added in v0.0.7 

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

func (*Call_PruneImages) ProtoMessage added in v0.0.7 

func (*Call_PruneImages) ProtoMessage()

func (*Call_PruneImages) ProtoSize added in v0.0.7 

func (m *Call_PruneImages) ProtoSize() (n int)

func (*Call_PruneImages) Reset added in v0.0.7 

func (m *Call_PruneImages) Reset()

func (*Call_PruneImages) String added in v0.0.7 

func (this *Call_PruneImages) String() string

func (*Call_PruneImages) Unmarshal added in v0.0.7 

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

func (*Call_PruneImages) UnmarshalJSON added in v0.0.7 

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

func (*Call_PruneImages) UnmarshalJSONFFLexer added in v0.0.7 

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

func (*Call_PruneImages) VerboseEqual added in v0.0.7 

func (this *Call_PruneImages) 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 randyAgent, 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) ProtoSize 

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

func (*Call_ReadFile) Reset 

func (m *Call_ReadFile) Reset()

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

type Call_RemoveContainer struct {
	ContainerID mesos.ContainerID `protobuf:"bytes,1,req,name=container_id,json=containerId" json:"container_id"`
}

Removes a container's artifacts (runtime and sandbox directories).

For nested containers, it is important to use this call if multiple nested containers are launched under the same parent container, because garbage collection only takes place at the parent container. Artifacts belonging to nested containers will not be garbage collected while the parent container is running.

TODO(josephw): A standalone container's runtime directory is currently garbage collected as soon as the container exits. To allow the user to retrieve the exit status reliably, the runtime directory cannot be garbage collected immediately. Instead, the user will eventually be required to make this call after the standalone container has exited. Also, a standalone container's sandbox directory is currently not garbage collected and is only deleted via this call.

Returns 200 OK if the removal is successful or if the parent container 

(for nested containers) does not exist.

Returns 500 Internal Server Error if anything goes wrong, including 

if the container is still running or does not exist.

TODO(josephw): Consider returning a 400 Bad Request instead of 500 Internal Server Error when the user tries to remove a running or nonexistent nested container.

func NewPopulatedCall_RemoveContainer added in v0.0.7 

func NewPopulatedCall_RemoveContainer(r randyAgent, easy bool) *Call_RemoveContainer

func (*Call_RemoveContainer) Descriptor added in v0.0.7 

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

func (*Call_RemoveContainer) Equal added in v0.0.7 

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

func (*Call_RemoveContainer) GetContainerID added in v0.0.7 

func (m *Call_RemoveContainer) GetContainerID() mesos.ContainerID

func (*Call_RemoveContainer) GoString added in v0.0.7 

func (this *Call_RemoveContainer) GoString() string

func (*Call_RemoveContainer) Marshal added in v0.0.7 

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

func (*Call_RemoveContainer) MarshalJSON added in v0.0.7 

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

func (*Call_RemoveContainer) MarshalJSONBuf added in v0.0.7 

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

func (*Call_RemoveContainer) MarshalTo added in v0.0.7 

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

func (*Call_RemoveContainer) ProtoMessage added in v0.0.7 

func (*Call_RemoveContainer) ProtoMessage()

func (*Call_RemoveContainer) ProtoSize added in v0.0.7 

func (m *Call_RemoveContainer) ProtoSize() (n int)

func (*Call_RemoveContainer) Reset added in v0.0.7 

func (m *Call_RemoveContainer) Reset()

func (*Call_RemoveContainer) String added in v0.0.7 

func (this *Call_RemoveContainer) String() string

func (*Call_RemoveContainer) Unmarshal added in v0.0.7 

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

func (*Call_RemoveContainer) UnmarshalJSON added in v0.0.7 

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

func (*Call_RemoveContainer) UnmarshalJSONFFLexer added in v0.0.7 

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

func (*Call_RemoveContainer) VerboseEqual added in v0.0.7 

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

type Call_RemoveNestedContainer added in v0.0.5 

type Call_RemoveNestedContainer struct {
	ContainerID mesos.ContainerID `protobuf:"bytes,1,req,name=container_id,json=containerId" json:"container_id"`
}

Deprecated in favor of `RemoveContainer`.

func NewPopulatedCall_RemoveNestedContainer added in v0.0.5 

func NewPopulatedCall_RemoveNestedContainer(r randyAgent, easy bool) *Call_RemoveNestedContainer

func (*Call_RemoveNestedContainer) Descriptor added in v0.0.5 

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

func (*Call_RemoveNestedContainer) Equal added in v0.0.5 

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

func (*Call_RemoveNestedContainer) GetContainerID added in v0.0.5 

func (m *Call_RemoveNestedContainer) GetContainerID() mesos.ContainerID

func (*Call_RemoveNestedContainer) GoString added in v0.0.5 

func (this *Call_RemoveNestedContainer) GoString() string

func (*Call_RemoveNestedContainer) Marshal added in v0.0.5 

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

func (*Call_RemoveNestedContainer) MarshalJSON added in v0.0.5 

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

func (*Call_RemoveNestedContainer) MarshalJSONBuf added in v0.0.5 

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

func (*Call_RemoveNestedContainer) MarshalTo added in v0.0.5 

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

func (*Call_RemoveNestedContainer) ProtoMessage added in v0.0.5 

func (*Call_RemoveNestedContainer) ProtoMessage()

func (*Call_RemoveNestedContainer) ProtoSize added in v0.0.5 

func (m *Call_RemoveNestedContainer) ProtoSize() (n int)

func (*Call_RemoveNestedContainer) Reset added in v0.0.5 

func (m *Call_RemoveNestedContainer) Reset()

func (*Call_RemoveNestedContainer) String added in v0.0.5 

func (this *Call_RemoveNestedContainer) String() string

func (*Call_RemoveNestedContainer) Unmarshal added in v0.0.5 

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

func (*Call_RemoveNestedContainer) UnmarshalJSON added in v0.0.5 

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

func (*Call_RemoveNestedContainer) UnmarshalJSONFFLexer added in v0.0.5 

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

func (*Call_RemoveNestedContainer) VerboseEqual added in v0.0.5 

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

type Call_RemoveResourceProviderConfig added in v0.0.7 

type Call_RemoveResourceProviderConfig struct {
	Type string `protobuf:"bytes,1,req,name=type" json:"type"`
	Name string `protobuf:"bytes,2,req,name=name" json:"name"`
}

Removes a config file from the resource provider config directory.

The config file that describes the resource provider of the specified type and name will be removed, and the corresponding resource provider will be terminated asynchronously. This call is idempotent, so if no matching config file exists, this call will return without terminating any resource provider. Note that if a config file is placed into the resource provider config directory out-of-band after the agent starts up, it will not be checked against this call.

Returns 200 OK if the config file is removed, or no matching config file 

exists.

Returns 403 Forbidden if the call is not authorized. Returns 500 Internal Server Error if anything goes wrong.

func NewPopulatedCall_RemoveResourceProviderConfig added in v0.0.7 

func NewPopulatedCall_RemoveResourceProviderConfig(r randyAgent, easy bool) *Call_RemoveResourceProviderConfig

func (*Call_RemoveResourceProviderConfig) Descriptor added in v0.0.7 

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

func (*Call_RemoveResourceProviderConfig) Equal added in v0.0.7 

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

func (*Call_RemoveResourceProviderConfig) GetName added in v0.0.7 

func (m *Call_RemoveResourceProviderConfig) GetName() string

func (*Call_RemoveResourceProviderConfig) GetType added in v0.0.7 

func (m *Call_RemoveResourceProviderConfig) GetType() string

func (*Call_RemoveResourceProviderConfig) GoString added in v0.0.7 

func (this *Call_RemoveResourceProviderConfig) GoString() string

func (*Call_RemoveResourceProviderConfig) Marshal added in v0.0.7 

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

func (*Call_RemoveResourceProviderConfig) MarshalJSON added in v0.0.7 

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

func (*Call_RemoveResourceProviderConfig) MarshalJSONBuf added in v0.0.7 

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

func (*Call_RemoveResourceProviderConfig) MarshalTo added in v0.0.7 

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

func (*Call_RemoveResourceProviderConfig) ProtoMessage added in v0.0.7 

func (*Call_RemoveResourceProviderConfig) ProtoMessage()

func (*Call_RemoveResourceProviderConfig) ProtoSize added in v0.0.7 

func (m *Call_RemoveResourceProviderConfig) ProtoSize() (n int)

func (*Call_RemoveResourceProviderConfig) Reset added in v0.0.7 

func (m *Call_RemoveResourceProviderConfig) Reset()

func (*Call_RemoveResourceProviderConfig) String added in v0.0.7 

func (this *Call_RemoveResourceProviderConfig) String() string

func (*Call_RemoveResourceProviderConfig) Unmarshal added in v0.0.7 

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

func (*Call_RemoveResourceProviderConfig) UnmarshalJSON added in v0.0.7 

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

func (*Call_RemoveResourceProviderConfig) UnmarshalJSONFFLexer added in v0.0.7 

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

func (*Call_RemoveResourceProviderConfig) VerboseEqual added in v0.0.7 

func (this *Call_RemoveResourceProviderConfig) 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 randyAgent, 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) ProtoSize 

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

func (*Call_SetLoggingLevel) Reset 

func (m *Call_SetLoggingLevel) Reset()

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_Type 

type Call_Type int32

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`; see `Call::LaunchNestedContainerSession` and `Call::AttachContainerOutput` for exceptions. 

const (
	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_CONTAINERS    Call_Type = 10
	// Retrieves the information about known frameworks.
	Call_GET_FRAMEWORKS Call_Type = 11
	// Retrieves the information about known executors.
	Call_GET_EXECUTORS Call_Type = 12
	// Retrieves the information about known tasks.
	Call_GET_TASKS Call_Type = 13
	// Retrieves the agent information.
	Call_GET_AGENT Call_Type = 20
	// Retrieves the information about known resource providers.
	Call_GET_RESOURCE_PROVIDERS Call_Type = 26
	// Calls for managing nested containers underneath an executor's container.
	// Some of these calls are deprecated in favor of the calls
	// for both standalone or nested containers further below.
	Call_LAUNCH_NESTED_CONTAINER Call_Type = 14
	Call_WAIT_NESTED_CONTAINER   Call_Type = 15
	Call_KILL_NESTED_CONTAINER   Call_Type = 16
	Call_REMOVE_NESTED_CONTAINER Call_Type = 21
	// See 'LaunchNestedContainerSession' below.
	Call_LAUNCH_NESTED_CONTAINER_SESSION Call_Type = 17
	Call_ATTACH_CONTAINER_INPUT          Call_Type = 18
	Call_ATTACH_CONTAINER_OUTPUT         Call_Type = 19
	// Calls for managing standalone containers
	// or containers nested underneath another container.
	Call_LAUNCH_CONTAINER                Call_Type = 22
	Call_WAIT_CONTAINER                  Call_Type = 23
	Call_KILL_CONTAINER                  Call_Type = 24
	Call_REMOVE_CONTAINER                Call_Type = 25
	Call_ADD_RESOURCE_PROVIDER_CONFIG    Call_Type = 27
	Call_UPDATE_RESOURCE_PROVIDER_CONFIG Call_Type = 28
	Call_REMOVE_RESOURCE_PROVIDER_CONFIG Call_Type = 29
	// Prune unused container images.
	Call_PRUNE_IMAGES Call_Type = 30
)

func (Call_Type) Enum 

func (x Call_Type) Enum() *Call_Type

func (Call_Type) EnumDescriptor 

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

func (Call_Type) 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_UpdateResourceProviderConfig added in v0.0.7 

type Call_UpdateResourceProviderConfig struct {
	Info mesos.ResourceProviderInfo `protobuf:"bytes,1,req,name=info" json:"info"`
}

Updates an existing resource provider config file.

The content of the `info` field will be written into an existing config file that describes a resource provider of the specified type and name in the resource provider config directory, and the corresponding resource provider will be relaunched asynchronously to reflect the changes in the config. Callers must not set the `info.id` field. This call is idempotent, so if there is no change in the config, this call will return without relaunching the resource provider. Note that if a config file is placed into the resource provider config directory out-of-band after the agent starts up, it will not be checked against this call.

Returns 200 OK if an existing config file is updated, or there is no change 

in the config file.

Returns 400 Bad Request if `info` is not well-formed. Returns 403 Forbidden if the call is not authorized. Returns 404 Not Found if no config file describes a resource 

provider of the same type and name exists.

Returns 500 Internal Server Error if anything goes wrong.

func NewPopulatedCall_UpdateResourceProviderConfig added in v0.0.7 

func NewPopulatedCall_UpdateResourceProviderConfig(r randyAgent, easy bool) *Call_UpdateResourceProviderConfig

func (*Call_UpdateResourceProviderConfig) Descriptor added in v0.0.7 

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

func (*Call_UpdateResourceProviderConfig) Equal added in v0.0.7 

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

func (*Call_UpdateResourceProviderConfig) GetInfo added in v0.0.7 

func (m *Call_UpdateResourceProviderConfig) GetInfo() mesos.ResourceProviderInfo

func (*Call_UpdateResourceProviderConfig) GoString added in v0.0.7 

func (this *Call_UpdateResourceProviderConfig) GoString() string

func (*Call_UpdateResourceProviderConfig) Marshal added in v0.0.7 

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

func (*Call_UpdateResourceProviderConfig) MarshalJSON added in v0.0.7 

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

func (*Call_UpdateResourceProviderConfig) MarshalJSONBuf added in v0.0.7 

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

func (*Call_UpdateResourceProviderConfig) MarshalTo added in v0.0.7 

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

func (*Call_UpdateResourceProviderConfig) ProtoMessage added in v0.0.7 

func (*Call_UpdateResourceProviderConfig) ProtoMessage()

func (*Call_UpdateResourceProviderConfig) ProtoSize added in v0.0.7 

func (m *Call_UpdateResourceProviderConfig) ProtoSize() (n int)

func (*Call_UpdateResourceProviderConfig) Reset added in v0.0.7 

func (m *Call_UpdateResourceProviderConfig) Reset()

func (*Call_UpdateResourceProviderConfig) String added in v0.0.7 

func (this *Call_UpdateResourceProviderConfig) String() string

func (*Call_UpdateResourceProviderConfig) Unmarshal added in v0.0.7 

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

func (*Call_UpdateResourceProviderConfig) UnmarshalJSON added in v0.0.7 

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

func (*Call_UpdateResourceProviderConfig) UnmarshalJSONFFLexer added in v0.0.7 

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

func (*Call_UpdateResourceProviderConfig) VerboseEqual added in v0.0.7 

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

type Call_WaitContainer added in v0.0.7 

type Call_WaitContainer struct {
	ContainerID mesos.ContainerID `protobuf:"bytes,1,req,name=container_id,json=containerId" json:"container_id"`
}

Waits for the standalone or nested container to terminate and returns the exit status.

Returns 200 OK if and when the container exits. Returns 404 Not Found if the container does not exist.

func NewPopulatedCall_WaitContainer added in v0.0.7 

func NewPopulatedCall_WaitContainer(r randyAgent, easy bool) *Call_WaitContainer

func (*Call_WaitContainer) Descriptor added in v0.0.7 

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

func (*Call_WaitContainer) Equal added in v0.0.7 

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

func (*Call_WaitContainer) GetContainerID added in v0.0.7 

func (m *Call_WaitContainer) GetContainerID() mesos.ContainerID

func (*Call_WaitContainer) GoString added in v0.0.7 

func (this *Call_WaitContainer) GoString() string

func (*Call_WaitContainer) Marshal added in v0.0.7 

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

func (*Call_WaitContainer) MarshalJSON added in v0.0.7 

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

func (*Call_WaitContainer) MarshalJSONBuf added in v0.0.7 

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

func (*Call_WaitContainer) MarshalTo added in v0.0.7 

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

func (*Call_WaitContainer) ProtoMessage added in v0.0.7 

func (*Call_WaitContainer) ProtoMessage()

func (*Call_WaitContainer) ProtoSize added in v0.0.7 

func (m *Call_WaitContainer) ProtoSize() (n int)

func (*Call_WaitContainer) Reset added in v0.0.7 

func (m *Call_WaitContainer) Reset()

func (*Call_WaitContainer) String added in v0.0.7 

func (this *Call_WaitContainer) String() string

func (*Call_WaitContainer) Unmarshal added in v0.0.7 

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

func (*Call_WaitContainer) UnmarshalJSON added in v0.0.7 

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

func (*Call_WaitContainer) UnmarshalJSONFFLexer added in v0.0.7 

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

func (*Call_WaitContainer) VerboseEqual added in v0.0.7 

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

type Call_WaitNestedContainer 

type Call_WaitNestedContainer struct {
	ContainerID mesos.ContainerID `protobuf:"bytes,1,req,name=container_id,json=containerId" json:"container_id"`
}

Deprecated in favor of `WaitContainer`.

func NewPopulatedCall_WaitNestedContainer 

func NewPopulatedCall_WaitNestedContainer(r randyAgent, easy bool) *Call_WaitNestedContainer

func (*Call_WaitNestedContainer) Descriptor 

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

func (*Call_WaitNestedContainer) Equal 

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

func (*Call_WaitNestedContainer) GetContainerID 

func (m *Call_WaitNestedContainer) GetContainerID() mesos.ContainerID

func (*Call_WaitNestedContainer) GoString 

func (this *Call_WaitNestedContainer) GoString() string

func (*Call_WaitNestedContainer) Marshal 

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

func (*Call_WaitNestedContainer) MarshalJSON 

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

func (*Call_WaitNestedContainer) MarshalJSONBuf 

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

func (*Call_WaitNestedContainer) MarshalTo 

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

func (*Call_WaitNestedContainer) ProtoMessage 

func (*Call_WaitNestedContainer) ProtoMessage()

func (*Call_WaitNestedContainer) ProtoSize 

func (m *Call_WaitNestedContainer) ProtoSize() (n int)

func (*Call_WaitNestedContainer) Reset 

func (m *Call_WaitNestedContainer) Reset()

func (*Call_WaitNestedContainer) String 

func (this *Call_WaitNestedContainer) String() string

func (*Call_WaitNestedContainer) Unmarshal 

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

func (*Call_WaitNestedContainer) UnmarshalJSON 

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

func (*Call_WaitNestedContainer) UnmarshalJSONFFLexer 

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

func (*Call_WaitNestedContainer) VerboseEqual 

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

type ProcessIO 

type ProcessIO struct {
	Type    ProcessIO_Type     `protobuf:"varint,1,opt,name=type,enum=mesos.agent.ProcessIO_Type" json:"type"`
	Data    *ProcessIO_Data    `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
	Control *ProcessIO_Control `protobuf:"bytes,3,opt,name=control" json:"control,omitempty"`
}

* Streaming response to `Call::LAUNCH_NESTED_CONTAINER_SESSION` and `Call::ATTACH_CONTAINER_OUTPUT`.

This message is also used to stream request data for `Call::ATTACH_CONTAINER_INPUT`.

func NewPopulatedProcessIO 

func NewPopulatedProcessIO(r randyAgent, easy bool) *ProcessIO

func (*ProcessIO) Descriptor 

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

func (*ProcessIO) Equal 

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

func (*ProcessIO) GetControl 

func (m *ProcessIO) GetControl() *ProcessIO_Control

func (*ProcessIO) GetData 

func (m *ProcessIO) GetData() *ProcessIO_Data

func (*ProcessIO) GetType 

func (m *ProcessIO) GetType() ProcessIO_Type

func (*ProcessIO) GoString 

func (this *ProcessIO) GoString() string

func (*ProcessIO) Marshal 

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

func (*ProcessIO) MarshalJSON 

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

func (*ProcessIO) MarshalJSONBuf 

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

func (*ProcessIO) MarshalTo 

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

func (*ProcessIO) ProtoMessage 

func (*ProcessIO) ProtoMessage()

func (*ProcessIO) ProtoSize 

func (m *ProcessIO) ProtoSize() (n int)

func (*ProcessIO) Reset 

func (m *ProcessIO) Reset()

func (*ProcessIO) String 

func (this *ProcessIO) String() string

func (*ProcessIO) Unmarshal 

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

func (*ProcessIO) UnmarshalJSON 

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

func (*ProcessIO) UnmarshalJSONFFLexer 

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

func (*ProcessIO) VerboseEqual 

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

type ProcessIO_Control 

type ProcessIO_Control struct {
	Type      ProcessIO_Control_Type       `protobuf:"varint,1,opt,name=type,enum=mesos.agent.ProcessIO_Control_Type" json:"type"`
	TTYInfo   *mesos.TTYInfo               `protobuf:"bytes,2,opt,name=tty_info,json=ttyInfo" json:"tty_info,omitempty"`
	Heartbeat *ProcessIO_Control_Heartbeat `protobuf:"bytes,3,opt,name=heartbeat" json:"heartbeat,omitempty"`
}

func NewPopulatedProcessIO_Control 

func NewPopulatedProcessIO_Control(r randyAgent, easy bool) *ProcessIO_Control

func (*ProcessIO_Control) Descriptor 

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

func (*ProcessIO_Control) Equal 

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

func (*ProcessIO_Control) GetHeartbeat 

func (m *ProcessIO_Control) GetHeartbeat() *ProcessIO_Control_Heartbeat

func (*ProcessIO_Control) GetTTYInfo 

func (m *ProcessIO_Control) GetTTYInfo() *mesos.TTYInfo

func (*ProcessIO_Control) GetType 

func (m *ProcessIO_Control) GetType() ProcessIO_Control_Type

func (*ProcessIO_Control) GoString 

func (this *ProcessIO_Control) GoString() string

func (*ProcessIO_Control) Marshal 

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

func (*ProcessIO_Control) MarshalJSON 

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

func (*ProcessIO_Control) MarshalJSONBuf 

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

func (*ProcessIO_Control) MarshalTo 

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

func (*ProcessIO_Control) ProtoMessage 

func (*ProcessIO_Control) ProtoMessage()

func (*ProcessIO_Control) ProtoSize 

func (m *ProcessIO_Control) ProtoSize() (n int)

func (*ProcessIO_Control) Reset 

func (m *ProcessIO_Control) Reset()

func (*ProcessIO_Control) String 

func (this *ProcessIO_Control) String() string

func (*ProcessIO_Control) Unmarshal 

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

func (*ProcessIO_Control) UnmarshalJSON 

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

func (*ProcessIO_Control) UnmarshalJSONFFLexer 

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

func (*ProcessIO_Control) VerboseEqual 

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

type ProcessIO_Control_Heartbeat 

type ProcessIO_Control_Heartbeat struct {
	Interval *mesos.DurationInfo `protobuf:"bytes,1,opt,name=interval" json:"interval,omitempty"`
}

func NewPopulatedProcessIO_Control_Heartbeat 

func NewPopulatedProcessIO_Control_Heartbeat(r randyAgent, easy bool) *ProcessIO_Control_Heartbeat

func (*ProcessIO_Control_Heartbeat) Descriptor 

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

func (*ProcessIO_Control_Heartbeat) Equal 

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

func (*ProcessIO_Control_Heartbeat) GetInterval 

func (m *ProcessIO_Control_Heartbeat) GetInterval() *mesos.DurationInfo

func (*ProcessIO_Control_Heartbeat) GoString 

func (this *ProcessIO_Control_Heartbeat) GoString() string

func (*ProcessIO_Control_Heartbeat) Marshal 

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

func (*ProcessIO_Control_Heartbeat) MarshalJSON 

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

func (*ProcessIO_Control_Heartbeat) MarshalJSONBuf 

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

func (*ProcessIO_Control_Heartbeat) MarshalTo 

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

func (*ProcessIO_Control_Heartbeat) ProtoMessage 

func (*ProcessIO_Control_Heartbeat) ProtoMessage()

func (*ProcessIO_Control_Heartbeat) ProtoSize 

func (m *ProcessIO_Control_Heartbeat) ProtoSize() (n int)

func (*ProcessIO_Control_Heartbeat) Reset 

func (m *ProcessIO_Control_Heartbeat) Reset()

func (*ProcessIO_Control_Heartbeat) String 

func (this *ProcessIO_Control_Heartbeat) String() string

func (*ProcessIO_Control_Heartbeat) Unmarshal 

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

func (*ProcessIO_Control_Heartbeat) UnmarshalJSON 

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

func (*ProcessIO_Control_Heartbeat) UnmarshalJSONFFLexer 

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

func (*ProcessIO_Control_Heartbeat) VerboseEqual 

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

type ProcessIO_Control_Type 

type ProcessIO_Control_Type int32
const (
	ProcessIO_Control_UNKNOWN   ProcessIO_Control_Type = 0
	ProcessIO_Control_TTY_INFO  ProcessIO_Control_Type = 1
	ProcessIO_Control_HEARTBEAT ProcessIO_Control_Type = 2
)

func (ProcessIO_Control_Type) Enum 

func (x ProcessIO_Control_Type) Enum() *ProcessIO_Control_Type

func (ProcessIO_Control_Type) EnumDescriptor 

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

func (ProcessIO_Control_Type) MarshalJSON 

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

func (ProcessIO_Control_Type) String 

func (x ProcessIO_Control_Type) String() string

func (*ProcessIO_Control_Type) UnmarshalJSON 

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

type ProcessIO_Data 

type ProcessIO_Data struct {
	Type ProcessIO_Data_Type `protobuf:"varint,1,opt,name=type,enum=mesos.agent.ProcessIO_Data_Type" json:"type"`
	Data []byte              `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
}

func NewPopulatedProcessIO_Data 

func NewPopulatedProcessIO_Data(r randyAgent, easy bool) *ProcessIO_Data

func (*ProcessIO_Data) Descriptor 

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

func (*ProcessIO_Data) Equal 

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

func (*ProcessIO_Data) GetData 

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

func (*ProcessIO_Data) GetType 

func (m *ProcessIO_Data) GetType() ProcessIO_Data_Type

func (*ProcessIO_Data) GoString 

func (this *ProcessIO_Data) GoString() string

func (*ProcessIO_Data) Marshal 

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

func (*ProcessIO_Data) MarshalJSON 

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

func (*ProcessIO_Data) MarshalJSONBuf 

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

func (*ProcessIO_Data) MarshalTo 

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

func (*ProcessIO_Data) ProtoMessage 

func (*ProcessIO_Data) ProtoMessage()

func (*ProcessIO_Data) ProtoSize 

func (m *ProcessIO_Data) ProtoSize() (n int)

func (*ProcessIO_Data) Reset 

func (m *ProcessIO_Data) Reset()

func (*ProcessIO_Data) String 

func (this *ProcessIO_Data) String() string

func (*ProcessIO_Data) Unmarshal 

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

func (*ProcessIO_Data) UnmarshalJSON 

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

func (*ProcessIO_Data) UnmarshalJSONFFLexer 

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

func (*ProcessIO_Data) VerboseEqual 

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

type ProcessIO_Data_Type 

type ProcessIO_Data_Type int32
const (
	ProcessIO_Data_UNKNOWN ProcessIO_Data_Type = 0
	ProcessIO_Data_STDIN   ProcessIO_Data_Type = 1
	ProcessIO_Data_STDOUT  ProcessIO_Data_Type = 2
	ProcessIO_Data_STDERR  ProcessIO_Data_Type = 3
)

func (ProcessIO_Data_Type) Enum 

func (x ProcessIO_Data_Type) Enum() *ProcessIO_Data_Type

func (ProcessIO_Data_Type) EnumDescriptor 

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

func (ProcessIO_Data_Type) MarshalJSON 

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

func (ProcessIO_Data_Type) String 

func (x ProcessIO_Data_Type) String() string

func (*ProcessIO_Data_Type) UnmarshalJSON 

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

type ProcessIO_Type 

type ProcessIO_Type int32
const (
	ProcessIO_UNKNOWN ProcessIO_Type = 0
	ProcessIO_DATA    ProcessIO_Type = 1
	ProcessIO_CONTROL ProcessIO_Type = 2
)

func (ProcessIO_Type) Enum 

func (x ProcessIO_Type) Enum() *ProcessIO_Type

func (ProcessIO_Type) EnumDescriptor 

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

func (ProcessIO_Type) MarshalJSON 

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

func (ProcessIO_Type) String 

func (x ProcessIO_Type) String() string

func (*ProcessIO_Type) UnmarshalJSON 

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

type Response 

type Response struct {
	Type                 Response_Type                  `protobuf:"varint,1,opt,name=type,enum=mesos.agent.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"`
	GetContainers        *Response_GetContainers        `protobuf:"bytes,10,opt,name=get_containers,json=getContainers" json:"get_containers,omitempty"`
	GetFrameworks        *Response_GetFrameworks        `protobuf:"bytes,11,opt,name=get_frameworks,json=getFrameworks" json:"get_frameworks,omitempty"`
	GetExecutors         *Response_GetExecutors         `protobuf:"bytes,12,opt,name=get_executors,json=getExecutors" json:"get_executors,omitempty"`
	GetTasks             *Response_GetTasks             `protobuf:"bytes,13,opt,name=get_tasks,json=getTasks" json:"get_tasks,omitempty"`
	GetAgent             *Response_GetAgent             `protobuf:"bytes,15,opt,name=get_agent,json=getAgent" json:"get_agent,omitempty"`
	GetResourceProviders *Response_GetResourceProviders `protobuf:"bytes,17,opt,name=get_resource_providers,json=getResourceProviders" json:"get_resource_providers,omitempty"`
	WaitNestedContainer  *Response_WaitNestedContainer  `protobuf:"bytes,14,opt,name=wait_nested_container,json=waitNestedContainer" json:"wait_nested_container,omitempty"`
	WaitContainer        *Response_WaitContainer        `protobuf:"bytes,16,opt,name=wait_container,json=waitContainer" json:"wait_container,omitempty"`
}

* Synchronous responses for all calls made to the v1 agent API.

func NewPopulatedResponse 

func NewPopulatedResponse(r randyAgent, easy bool) *Response

func (*Response) Descriptor 

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

func (*Response) Equal 

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

func (*Response) GetGetAgent added in v0.0.5 

func (m *Response) GetGetAgent() *Response_GetAgent

func (*Response) GetGetContainers 

func (m *Response) GetGetContainers() *Response_GetContainers

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

func (m *Response) GetGetMetrics() *Response_GetMetrics

func (*Response) GetGetResourceProviders added in v0.0.7 

func (m *Response) GetGetResourceProviders() *Response_GetResourceProviders

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

func (m *Response) GetWaitContainer() *Response_WaitContainer

func (*Response) GetWaitNestedContainer 

func (m *Response) GetWaitNestedContainer() *Response_WaitNestedContainer

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

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

func (*Response) Reset 

func (m *Response) Reset()

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

type Response_GetAgent struct {
	AgentInfo *mesos.AgentInfo `protobuf:"bytes,1,opt,name=agent_info,json=agentInfo" json:"agent_info,omitempty"`
}

Contains the agent's information.

func NewPopulatedResponse_GetAgent added in v0.0.5 

func NewPopulatedResponse_GetAgent(r randyAgent, easy bool) *Response_GetAgent

func (*Response_GetAgent) Descriptor added in v0.0.5 

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

func (*Response_GetAgent) Equal added in v0.0.5 

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

func (*Response_GetAgent) GetAgentInfo added in v0.0.5 

func (m *Response_GetAgent) GetAgentInfo() *mesos.AgentInfo

func (*Response_GetAgent) GoString added in v0.0.5 

func (this *Response_GetAgent) GoString() string

func (*Response_GetAgent) Marshal added in v0.0.5 

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

func (*Response_GetAgent) MarshalJSON added in v0.0.5 

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

func (*Response_GetAgent) MarshalJSONBuf added in v0.0.5 

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

func (*Response_GetAgent) MarshalTo added in v0.0.5 

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

func (*Response_GetAgent) ProtoMessage added in v0.0.5 

func (*Response_GetAgent) ProtoMessage()

func (*Response_GetAgent) ProtoSize added in v0.0.5 

func (m *Response_GetAgent) ProtoSize() (n int)

func (*Response_GetAgent) Reset added in v0.0.5 

func (m *Response_GetAgent) Reset()

func (*Response_GetAgent) String added in v0.0.5 

func (this *Response_GetAgent) String() string

func (*Response_GetAgent) Unmarshal added in v0.0.5 

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

func (*Response_GetAgent) UnmarshalJSON added in v0.0.5 

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

func (*Response_GetAgent) UnmarshalJSONFFLexer added in v0.0.5 

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

func (*Response_GetAgent) VerboseEqual added in v0.0.5 

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

type Response_GetContainers 

type Response_GetContainers struct {
	Containers []Response_GetContainers_Container `protobuf:"bytes,1,rep,name=containers" json:"containers"`
}

Information about containers running on this agent. It contains ContainerStatus and ResourceStatistics along with some metadata of the containers.

func NewPopulatedResponse_GetContainers 

func NewPopulatedResponse_GetContainers(r randyAgent, easy bool) *Response_GetContainers

func (*Response_GetContainers) Descriptor 

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

func (*Response_GetContainers) Equal 

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

func (*Response_GetContainers) GetContainers 

func (m *Response_GetContainers) GetContainers() []Response_GetContainers_Container

func (*Response_GetContainers) GoString 

func (this *Response_GetContainers) GoString() string

func (*Response_GetContainers) Marshal 

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

func (*Response_GetContainers) MarshalJSON 

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

func (*Response_GetContainers) MarshalJSONBuf 

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

func (*Response_GetContainers) MarshalTo 

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

func (*Response_GetContainers) ProtoMessage 

func (*Response_GetContainers) ProtoMessage()

func (*Response_GetContainers) ProtoSize 

func (m *Response_GetContainers) ProtoSize() (n int)

func (*Response_GetContainers) Reset 

func (m *Response_GetContainers) Reset()

func (*Response_GetContainers) String 

func (this *Response_GetContainers) String() string

func (*Response_GetContainers) Unmarshal 

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

func (*Response_GetContainers) UnmarshalJSON 

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

func (*Response_GetContainers) UnmarshalJSONFFLexer 

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

func (*Response_GetContainers) VerboseEqual 

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

type Response_GetContainers_Container 

type Response_GetContainers_Container struct {
	FrameworkID        *mesos.FrameworkID        `protobuf:"bytes,1,opt,name=framework_id,json=frameworkId" json:"framework_id,omitempty"`
	ExecutorID         *mesos.ExecutorID         `protobuf:"bytes,2,opt,name=executor_id,json=executorId" json:"executor_id,omitempty"`
	ExecutorName       *string                   `protobuf:"bytes,3,opt,name=executor_name,json=executorName" json:"executor_name,omitempty"`
	ContainerID        mesos.ContainerID         `protobuf:"bytes,4,req,name=container_id,json=containerId" json:"container_id"`
	ContainerStatus    *mesos.ContainerStatus    `protobuf:"bytes,5,opt,name=container_status,json=containerStatus" json:"container_status,omitempty"`
	ResourceStatistics *mesos.ResourceStatistics `protobuf:"bytes,6,opt,name=resource_statistics,json=resourceStatistics" json:"resource_statistics,omitempty"`
}

func NewPopulatedResponse_GetContainers_Container 

func NewPopulatedResponse_GetContainers_Container(r randyAgent, easy bool) *Response_GetContainers_Container

func (*Response_GetContainers_Container) Descriptor 

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

func (*Response_GetContainers_Container) Equal 

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

func (*Response_GetContainers_Container) GetContainerID 

func (m *Response_GetContainers_Container) GetContainerID() mesos.ContainerID

func (*Response_GetContainers_Container) GetContainerStatus 

func (m *Response_GetContainers_Container) GetContainerStatus() *mesos.ContainerStatus

func (*Response_GetContainers_Container) GetExecutorID 

func (m *Response_GetContainers_Container) GetExecutorID() *mesos.ExecutorID

func (*Response_GetContainers_Container) GetExecutorName 

func (m *Response_GetContainers_Container) GetExecutorName() string

func (*Response_GetContainers_Container) GetFrameworkID 

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

func (*Response_GetContainers_Container) GetResourceStatistics 

func (m *Response_GetContainers_Container) GetResourceStatistics() *mesos.ResourceStatistics

func (*Response_GetContainers_Container) GoString 

func (this *Response_GetContainers_Container) GoString() string

func (*Response_GetContainers_Container) Marshal 

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

func (*Response_GetContainers_Container) MarshalJSON 

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

func (*Response_GetContainers_Container) MarshalJSONBuf 

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

func (*Response_GetContainers_Container) MarshalTo 

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

func (*Response_GetContainers_Container) ProtoMessage 

func (*Response_GetContainers_Container) ProtoMessage()

func (*Response_GetContainers_Container) ProtoSize 

func (m *Response_GetContainers_Container) ProtoSize() (n int)

func (*Response_GetContainers_Container) Reset 

func (m *Response_GetContainers_Container) Reset()

func (*Response_GetContainers_Container) String 

func (this *Response_GetContainers_Container) String() string

func (*Response_GetContainers_Container) Unmarshal 

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

func (*Response_GetContainers_Container) UnmarshalJSON 

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

func (*Response_GetContainers_Container) UnmarshalJSONFFLexer 

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

func (*Response_GetContainers_Container) VerboseEqual 

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

type Response_GetExecutors 

type Response_GetExecutors struct {
	Executors          []Response_GetExecutors_Executor `protobuf:"bytes,1,rep,name=executors" json:"executors"`
	CompletedExecutors []Response_GetExecutors_Executor `protobuf:"bytes,2,rep,name=completed_executors,json=completedExecutors" json:"completed_executors"`
}

Lists information about all the executors known to the agent at the current time.

func NewPopulatedResponse_GetExecutors 

func NewPopulatedResponse_GetExecutors(r randyAgent, 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) GetCompletedExecutors 

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

func (*Response_GetExecutors) GetExecutors 

func (m *Response_GetExecutors) GetExecutors() []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) ProtoSize 

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

func (*Response_GetExecutors) Reset 

func (m *Response_GetExecutors) Reset()

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

func NewPopulatedResponse_GetExecutors_Executor 

func NewPopulatedResponse_GetExecutors_Executor(r randyAgent, 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) 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) ProtoSize 

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

func (*Response_GetExecutors_Executor) Reset 

func (m *Response_GetExecutors_Executor) Reset()

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 agent.

func NewPopulatedResponse_GetFlags 

func NewPopulatedResponse_GetFlags(r randyAgent, 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) ProtoSize 

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

func (*Response_GetFlags) Reset 

func (m *Response_GetFlags) Reset()

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          []Response_GetFrameworks_Framework `protobuf:"bytes,1,rep,name=frameworks" json:"frameworks"`
	CompletedFrameworks []Response_GetFrameworks_Framework `protobuf:"bytes,2,rep,name=completed_frameworks,json=completedFrameworks" json:"completed_frameworks"`
}

Information about all the frameworks known to the agent at the current time.

func NewPopulatedResponse_GetFrameworks 

func NewPopulatedResponse_GetFrameworks(r randyAgent, 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) 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) ProtoSize 

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

func (*Response_GetFrameworks) Reset 

func (m *Response_GetFrameworks) Reset()

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

func NewPopulatedResponse_GetFrameworks_Framework 

func NewPopulatedResponse_GetFrameworks_Framework(r randyAgent, 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) GetFrameworkInfo 

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

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

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

func (*Response_GetFrameworks_Framework) Reset 

func (m *Response_GetFrameworks_Framework) Reset()

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 agent is healthy. Delayed responses are also indicative of the poor health of the agent.

func NewPopulatedResponse_GetHealth 

func NewPopulatedResponse_GetHealth(r randyAgent, 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) ProtoSize 

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

func (*Response_GetHealth) Reset 

func (m *Response_GetHealth) Reset()

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 agent.

func NewPopulatedResponse_GetLoggingLevel 

func NewPopulatedResponse_GetLoggingLevel(r randyAgent, 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) ProtoSize 

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

func (*Response_GetLoggingLevel) Reset 

func (m *Response_GetLoggingLevel) Reset()

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_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 randyAgent, 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) ProtoSize 

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

func (*Response_GetMetrics) Reset 

func (m *Response_GetMetrics) Reset()

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

type Response_GetResourceProviders struct {
	ResourceProviders []Response_GetResourceProviders_ResourceProvider `protobuf:"bytes,1,rep,name=resource_providers,json=resourceProviders" json:"resource_providers"`
}

Lists information about all resource providers known to the agent at the current time.

func NewPopulatedResponse_GetResourceProviders added in v0.0.7 

func NewPopulatedResponse_GetResourceProviders(r randyAgent, easy bool) *Response_GetResourceProviders

func (*Response_GetResourceProviders) Descriptor added in v0.0.7 

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

func (*Response_GetResourceProviders) Equal added in v0.0.7 

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

func (*Response_GetResourceProviders) GetResourceProviders added in v0.0.7 

func (m *Response_GetResourceProviders) GetResourceProviders() []Response_GetResourceProviders_ResourceProvider

func (*Response_GetResourceProviders) GoString added in v0.0.7 

func (this *Response_GetResourceProviders) GoString() string

func (*Response_GetResourceProviders) Marshal added in v0.0.7 

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

func (*Response_GetResourceProviders) MarshalJSON added in v0.0.7 

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

func (*Response_GetResourceProviders) MarshalJSONBuf added in v0.0.7 

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

func (*Response_GetResourceProviders) MarshalTo added in v0.0.7 

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

func (*Response_GetResourceProviders) ProtoMessage added in v0.0.7 

func (*Response_GetResourceProviders) ProtoMessage()

func (*Response_GetResourceProviders) ProtoSize added in v0.0.7 

func (m *Response_GetResourceProviders) ProtoSize() (n int)

func (*Response_GetResourceProviders) Reset added in v0.0.7 

func (m *Response_GetResourceProviders) Reset()

func (*Response_GetResourceProviders) String added in v0.0.7 

func (this *Response_GetResourceProviders) String() string

func (*Response_GetResourceProviders) Unmarshal added in v0.0.7 

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

func (*Response_GetResourceProviders) UnmarshalJSON added in v0.0.7 

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

func (*Response_GetResourceProviders) UnmarshalJSONFFLexer added in v0.0.7 

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

func (*Response_GetResourceProviders) VerboseEqual added in v0.0.7 

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

type Response_GetResourceProviders_ResourceProvider added in v0.0.7 

type Response_GetResourceProviders_ResourceProvider struct {
	ResourceProviderInfo mesos.ResourceProviderInfo `protobuf:"bytes,1,req,name=resource_provider_info,json=resourceProviderInfo" json:"resource_provider_info"`
}

func NewPopulatedResponse_GetResourceProviders_ResourceProvider added in v0.0.7 

func NewPopulatedResponse_GetResourceProviders_ResourceProvider(r randyAgent, easy bool) *Response_GetResourceProviders_ResourceProvider

func (*Response_GetResourceProviders_ResourceProvider) Descriptor added in v0.0.7 

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

func (*Response_GetResourceProviders_ResourceProvider) Equal added in v0.0.7 

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

func (*Response_GetResourceProviders_ResourceProvider) GetResourceProviderInfo added in v0.0.7 

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

func (*Response_GetResourceProviders_ResourceProvider) GoString added in v0.0.7 

func (this *Response_GetResourceProviders_ResourceProvider) GoString() string

func (*Response_GetResourceProviders_ResourceProvider) Marshal added in v0.0.7 

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

func (*Response_GetResourceProviders_ResourceProvider) MarshalJSON added in v0.0.7 

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

func (*Response_GetResourceProviders_ResourceProvider) MarshalJSONBuf added in v0.0.7 

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

func (*Response_GetResourceProviders_ResourceProvider) MarshalTo added in v0.0.7 

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

func (*Response_GetResourceProviders_ResourceProvider) ProtoMessage added in v0.0.7 

func (*Response_GetResourceProviders_ResourceProvider) ProtoMessage()

func (*Response_GetResourceProviders_ResourceProvider) ProtoSize added in v0.0.7 

func (m *Response_GetResourceProviders_ResourceProvider) ProtoSize() (n int)

func (*Response_GetResourceProviders_ResourceProvider) Reset added in v0.0.7 

func (m *Response_GetResourceProviders_ResourceProvider) Reset()

func (*Response_GetResourceProviders_ResourceProvider) String added in v0.0.7 

func (this *Response_GetResourceProviders_ResourceProvider) String() string

func (*Response_GetResourceProviders_ResourceProvider) Unmarshal added in v0.0.7 

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

func (*Response_GetResourceProviders_ResourceProvider) UnmarshalJSON added in v0.0.7 

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

func (*Response_GetResourceProviders_ResourceProvider) UnmarshalJSONFFLexer added in v0.0.7 

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

func (*Response_GetResourceProviders_ResourceProvider) VerboseEqual added in v0.0.7 

func (this *Response_GetResourceProviders_ResourceProvider) 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"`
}

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

func NewPopulatedResponse_GetState 

func NewPopulatedResponse_GetState(r randyAgent, 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) 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) ProtoSize 

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

func (*Response_GetState) Reset 

func (m *Response_GetState) Reset()

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 pending in the agent's queue before an executor is
	// launched.
	PendingTasks []mesos.Task `protobuf:"bytes,1,rep,name=pending_tasks,json=pendingTasks" json:"pending_tasks"`
	// Tasks that are enqueued for a launched executor that has not yet
	// registered.
	QueuedTasks []mesos.Task `protobuf:"bytes,2,rep,name=queued_tasks,json=queuedTasks" json:"queued_tasks"`
	// Tasks that are running.
	LaunchedTasks []mesos.Task `protobuf:"bytes,3,rep,name=launched_tasks,json=launchedTasks" json:"launched_tasks"`
	// Tasks that are terminated but pending updates.
	TerminatedTasks []mesos.Task `protobuf:"bytes,4,rep,name=terminated_tasks,json=terminatedTasks" json:"terminated_tasks"`
	// Tasks that are terminated and updates acked.
	CompletedTasks []mesos.Task `protobuf:"bytes,5,rep,name=completed_tasks,json=completedTasks" json:"completed_tasks"`
}

Lists information about all the tasks known to the agent at the current time.

func NewPopulatedResponse_GetTasks 

func NewPopulatedResponse_GetTasks(r randyAgent, 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) GetLaunchedTasks 

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

func (*Response_GetTasks) GetPendingTasks 

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

func (*Response_GetTasks) GetQueuedTasks 

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

func (*Response_GetTasks) GetTerminatedTasks 

func (m *Response_GetTasks) GetTerminatedTasks() []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) ProtoSize 

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

func (*Response_GetTasks) Reset 

func (m *Response_GetTasks) Reset()

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 agent.

func NewPopulatedResponse_GetVersion 

func NewPopulatedResponse_GetVersion(r randyAgent, 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) ProtoSize 

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

func (*Response_GetVersion) Reset 

func (m *Response_GetVersion) Reset()

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_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 randyAgent, 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) ProtoSize 

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

func (*Response_ListFiles) Reset 

func (m *Response_ListFiles) Reset()

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 randyAgent, 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 

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

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

func (*Response_ReadFile) Reset 

func (m *Response_ReadFile) Reset()

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_CONTAINERS         Response_Type = 9
	Response_GET_FRAMEWORKS         Response_Type = 10
	Response_GET_EXECUTORS          Response_Type = 11
	Response_GET_TASKS              Response_Type = 12
	Response_GET_AGENT              Response_Type = 14
	Response_GET_RESOURCE_PROVIDERS Response_Type = 16
	Response_WAIT_NESTED_CONTAINER  Response_Type = 13
	Response_WAIT_CONTAINER         Response_Type = 15
)

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

type Response_WaitContainer added in v0.0.7 

type Response_WaitContainer struct {
	// Wait status of the lead process in the container. Note that this
	// is the return value of `wait(2)`, so callers must use the `wait(2)`
	// family of macros to extract whether the process exited cleanly and
	// what the exit code was.
	ExitStatus *int32 `protobuf:"varint,1,opt,name=exit_status,json=exitStatus" json:"exit_status,omitempty"`
	// The `state` and `reason` fields may be populated if the Mesos agent
	// terminates the container. In the absence of any special knowledge,
	// executors should propagate this information via the `status` field
	// of an `Update` call for the corresponding TaskID.
	State  *mesos.TaskState         `protobuf:"varint,2,opt,name=state,enum=mesos.TaskState" json:"state,omitempty"`
	Reason *mesos.TaskStatus_Reason `protobuf:"varint,3,opt,name=reason,enum=mesos.TaskStatus_Reason" json:"reason,omitempty"`
	// This field will be populated if the task was terminated due to
	// a resource limitation.
	Limitation *mesos.TaskResourceLimitation `protobuf:"bytes,4,opt,name=limitation" json:"limitation,omitempty"`
	Message    *string                       `protobuf:"bytes,5,opt,name=message" json:"message,omitempty"`
}

Returns termination information about the standalone or nested container.

func NewPopulatedResponse_WaitContainer added in v0.0.7 

func NewPopulatedResponse_WaitContainer(r randyAgent, easy bool) *Response_WaitContainer

func (*Response_WaitContainer) Descriptor added in v0.0.7 

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

func (*Response_WaitContainer) Equal added in v0.0.7 

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

func (*Response_WaitContainer) GetExitStatus added in v0.0.7 

func (m *Response_WaitContainer) GetExitStatus() int32

func (*Response_WaitContainer) GetLimitation added in v0.0.7 

func (m *Response_WaitContainer) GetLimitation() *mesos.TaskResourceLimitation

func (*Response_WaitContainer) GetMessage added in v0.0.7 

func (m *Response_WaitContainer) GetMessage() string

func (*Response_WaitContainer) GetReason added in v0.0.7 

func (m *Response_WaitContainer) GetReason() mesos.TaskStatus_Reason

func (*Response_WaitContainer) GetState added in v0.0.7 

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

func (*Response_WaitContainer) GoString added in v0.0.7 

func (this *Response_WaitContainer) GoString() string

func (*Response_WaitContainer) Marshal added in v0.0.7 

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

func (*Response_WaitContainer) MarshalJSON added in v0.0.7 

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

func (*Response_WaitContainer) MarshalJSONBuf added in v0.0.7 

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

func (*Response_WaitContainer) MarshalTo added in v0.0.7 

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

func (*Response_WaitContainer) ProtoMessage added in v0.0.7 

func (*Response_WaitContainer) ProtoMessage()

func (*Response_WaitContainer) ProtoSize added in v0.0.7 

func (m *Response_WaitContainer) ProtoSize() (n int)

func (*Response_WaitContainer) Reset added in v0.0.7 

func (m *Response_WaitContainer) Reset()

func (*Response_WaitContainer) String added in v0.0.7 

func (this *Response_WaitContainer) String() string

func (*Response_WaitContainer) Unmarshal added in v0.0.7 

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

func (*Response_WaitContainer) UnmarshalJSON added in v0.0.7 

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

func (*Response_WaitContainer) UnmarshalJSONFFLexer added in v0.0.7 

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

func (*Response_WaitContainer) VerboseEqual added in v0.0.7 

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

type Response_WaitNestedContainer 

type Response_WaitNestedContainer struct {
	// Wait status of the lead process in the container. Note that this
	// is the return value of `wait(2)`, so callers must use the `wait(2)`
	// family of macros to extract whether the process exited cleanly and
	// what the exit code was.
	ExitStatus *int32 `protobuf:"varint,1,opt,name=exit_status,json=exitStatus" json:"exit_status,omitempty"`
	// The `state` and `reason` fields may be populated if the Mesos agent
	// terminates the container. In the absence of any special knowledge,
	// executors should propagate this information via the `status` field
	// of an `Update` call for the corresponding TaskID.
	State  *mesos.TaskState         `protobuf:"varint,2,opt,name=state,enum=mesos.TaskState" json:"state,omitempty"`
	Reason *mesos.TaskStatus_Reason `protobuf:"varint,3,opt,name=reason,enum=mesos.TaskStatus_Reason" json:"reason,omitempty"`
	// This field will be populated if the task was terminated due to
	// a resource limitation.
	Limitation *mesos.TaskResourceLimitation `protobuf:"bytes,4,opt,name=limitation" json:"limitation,omitempty"`
	Message    *string                       `protobuf:"bytes,5,opt,name=message" json:"message,omitempty"`
}

Returns termination information about the nested container.

func NewPopulatedResponse_WaitNestedContainer 

func NewPopulatedResponse_WaitNestedContainer(r randyAgent, easy bool) *Response_WaitNestedContainer

func (*Response_WaitNestedContainer) Descriptor 

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

func (*Response_WaitNestedContainer) Equal 

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

func (*Response_WaitNestedContainer) GetExitStatus 

func (m *Response_WaitNestedContainer) GetExitStatus() int32

func (*Response_WaitNestedContainer) GetLimitation added in v0.0.7 

func (m *Response_WaitNestedContainer) GetLimitation() *mesos.TaskResourceLimitation

func (*Response_WaitNestedContainer) GetMessage added in v0.0.7 

func (m *Response_WaitNestedContainer) GetMessage() string

func (*Response_WaitNestedContainer) GetReason added in v0.0.7 

func (m *Response_WaitNestedContainer) GetReason() mesos.TaskStatus_Reason

func (*Response_WaitNestedContainer) GetState added in v0.0.7 

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

func (*Response_WaitNestedContainer) GoString 

func (this *Response_WaitNestedContainer) GoString() string

func (*Response_WaitNestedContainer) Marshal 

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

func (*Response_WaitNestedContainer) MarshalJSON 

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

func (*Response_WaitNestedContainer) MarshalJSONBuf 

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

func (*Response_WaitNestedContainer) MarshalTo 

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

func (*Response_WaitNestedContainer) ProtoMessage 

func (*Response_WaitNestedContainer) ProtoMessage()

func (*Response_WaitNestedContainer) ProtoSize 

func (m *Response_WaitNestedContainer) ProtoSize() (n int)

func (*Response_WaitNestedContainer) Reset 

func (m *Response_WaitNestedContainer) Reset()

func (*Response_WaitNestedContainer) String 

func (this *Response_WaitNestedContainer) String() string

func (*Response_WaitNestedContainer) Unmarshal 

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

func (*Response_WaitNestedContainer) UnmarshalJSON 

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

func (*Response_WaitNestedContainer) UnmarshalJSONFFLexer 

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

func (*Response_WaitNestedContainer) VerboseEqual 

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