agent

package
v0.0.11 Latest Latest
Warning

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

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

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",
	31: "GET_OPERATIONS",
	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",
	32: "MARK_RESOURCE_PROVIDER_GONE",
	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_OPERATIONS":                  31,
	"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,
	"MARK_RESOURCE_PROVIDER_GONE":     32,
	"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",
	17: "GET_OPERATIONS",
	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_OPERATIONS":         17,
	"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 */
	MarkResourceProviderGone     *Call_MarkResourceProviderGone     `` /* 131-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) GetMarkResourceProviderGone added in v0.0.10

func (m *Call) GetMarkResourceProviderGone() *Call_MarkResourceProviderGone

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

func (m *Call) Reset()

func (*Call) Size added in v0.0.11

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

func (*Call) String

func (this *Call) String() string

func (*Call) Unmarshal

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

func (*Call) UnmarshalJSON

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

func (*Call) UnmarshalJSONFFLexer

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

func (*Call) VerboseEqual

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

type Call_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.

NOTE: For the time being, this API is subject to change and the related feature is experimental.

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 (*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) Reset added in v0.0.7

func (m *Call_AddResourceProviderConfig) Reset()

func (*Call_AddResourceProviderConfig) Size added in v0.0.11

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

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

func (m *Call_AttachContainerInput) Reset()

func (*Call_AttachContainerInput) Size added in v0.0.11

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

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

func (m *Call_AttachContainerOutput) Reset()

func (*Call_AttachContainerOutput) Size added in v0.0.11

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

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

func (m *Call_GetContainers) Reset()

func (*Call_GetContainers) Size added in v0.0.11

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

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

func (m *Call_GetMetrics) Reset()

func (*Call_GetMetrics) Size added in v0.0.11

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

func (*Call_GetMetrics) String

func (this *Call_GetMetrics) String() string

func (*Call_GetMetrics) Unmarshal

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

func (*Call_GetMetrics) UnmarshalJSON

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

func (*Call_GetMetrics) UnmarshalJSONFFLexer

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

func (*Call_GetMetrics) VerboseEqual

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

type Call_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) Reset added in v0.0.7

func (m *Call_KillContainer) Reset()

func (*Call_KillContainer) Size added in v0.0.11

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

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

func (m *Call_KillNestedContainer) Reset()

func (*Call_KillNestedContainer) Size added in v0.0.11

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

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"`
	// Resource limits associated with the container during launch.
	Limits map[string]mesos.Value_Scalar `protobuf:"bytes,5,rep,name=limits" json:"limits" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
}

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

func (m *Call_LaunchContainer) GetLimits() map[string]mesos.Value_Scalar

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

func (m *Call_LaunchContainer) Reset()

func (*Call_LaunchContainer) Size added in v0.0.11

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

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

func (m *Call_LaunchNestedContainer) Reset()

func (*Call_LaunchNestedContainer) Size added in v0.0.11

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

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 (*Call_LaunchNestedContainerSession) GetContainer

func (*Call_LaunchNestedContainerSession) GetContainerID

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 (*Call_LaunchNestedContainerSession) MarshalTo

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

func (*Call_LaunchNestedContainerSession) ProtoMessage

func (*Call_LaunchNestedContainerSession) ProtoMessage()

func (*Call_LaunchNestedContainerSession) Reset

func (*Call_LaunchNestedContainerSession) Size added in v0.0.11

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

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

func (m *Call_ListFiles) Reset()

func (*Call_ListFiles) Size added in v0.0.11

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

func (*Call_ListFiles) String

func (this *Call_ListFiles) String() string

func (*Call_ListFiles) Unmarshal

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

func (*Call_ListFiles) UnmarshalJSON

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

func (*Call_ListFiles) UnmarshalJSONFFLexer

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

func (*Call_ListFiles) VerboseEqual

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

type Call_MarkResourceProviderGone added in v0.0.10

type Call_MarkResourceProviderGone struct {
	ResourceProviderID mesos.ResourceProviderID `protobuf:"bytes,1,req,name=resource_provider_id,json=resourceProviderId" json:"resource_provider_id"`
}

Mark a resource provider as gone.

func NewPopulatedCall_MarkResourceProviderGone added in v0.0.10

func NewPopulatedCall_MarkResourceProviderGone(r randyAgent, easy bool) *Call_MarkResourceProviderGone

func (*Call_MarkResourceProviderGone) Descriptor added in v0.0.10

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

func (*Call_MarkResourceProviderGone) Equal added in v0.0.10

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

func (*Call_MarkResourceProviderGone) GetResourceProviderID added in v0.0.10

func (m *Call_MarkResourceProviderGone) GetResourceProviderID() mesos.ResourceProviderID

func (*Call_MarkResourceProviderGone) GoString added in v0.0.10

func (this *Call_MarkResourceProviderGone) GoString() string

func (*Call_MarkResourceProviderGone) Marshal added in v0.0.10

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

func (*Call_MarkResourceProviderGone) MarshalJSON added in v0.0.10

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

func (*Call_MarkResourceProviderGone) MarshalJSONBuf added in v0.0.10

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

func (*Call_MarkResourceProviderGone) MarshalTo added in v0.0.10

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

func (*Call_MarkResourceProviderGone) ProtoMessage added in v0.0.10

func (*Call_MarkResourceProviderGone) ProtoMessage()

func (*Call_MarkResourceProviderGone) Reset added in v0.0.10

func (m *Call_MarkResourceProviderGone) Reset()

func (*Call_MarkResourceProviderGone) Size added in v0.0.11

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

func (*Call_MarkResourceProviderGone) String added in v0.0.10

func (this *Call_MarkResourceProviderGone) String() string

func (*Call_MarkResourceProviderGone) Unmarshal added in v0.0.10

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

func (*Call_MarkResourceProviderGone) UnmarshalJSON added in v0.0.10

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

func (*Call_MarkResourceProviderGone) UnmarshalJSONFFLexer added in v0.0.10

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

func (*Call_MarkResourceProviderGone) VerboseEqual added in v0.0.10

func (this *Call_MarkResourceProviderGone) 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) Reset added in v0.0.7

func (m *Call_PruneImages) Reset()

func (*Call_PruneImages) Size added in v0.0.11

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

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

func (m *Call_ReadFile) Reset()

func (*Call_ReadFile) Size added in v0.0.11

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

func (*Call_ReadFile) String

func (this *Call_ReadFile) String() string

func (*Call_ReadFile) Unmarshal

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

func (*Call_ReadFile) UnmarshalJSON

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

func (*Call_ReadFile) UnmarshalJSONFFLexer

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

func (*Call_ReadFile) VerboseEqual

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

type Call_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) Reset added in v0.0.7

func (m *Call_RemoveContainer) Reset()

func (*Call_RemoveContainer) Size added in v0.0.11

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

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

func (m *Call_RemoveNestedContainer) Reset()

func (*Call_RemoveNestedContainer) Size added in v0.0.11

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

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 (*Call_RemoveResourceProviderConfig) GetType added in v0.0.7

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 (*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) Reset added in v0.0.7

func (*Call_RemoveResourceProviderConfig) Size added in v0.0.11

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

func (*Call_RemoveResourceProviderConfig) String added in v0.0.7

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

func (m *Call_SetLoggingLevel) Reset()

func (*Call_SetLoggingLevel) Size added in v0.0.11

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

func (*Call_SetLoggingLevel) String

func (this *Call_SetLoggingLevel) String() string

func (*Call_SetLoggingLevel) Unmarshal

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

func (*Call_SetLoggingLevel) UnmarshalJSON

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

func (*Call_SetLoggingLevel) UnmarshalJSONFFLexer

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

func (*Call_SetLoggingLevel) VerboseEqual

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

type Call_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 operations.
	Call_GET_OPERATIONS Call_Type = 31
	// 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
	Call_MARK_RESOURCE_PROVIDER_GONE     Call_Type = 32
	// 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 409 Conflict if no config file describes a resource provider of the

same type and name exists.

Returns 500 Internal Server Error if anything goes wrong.

NOTE: For the time being, this API is subject to change and the related feature is experimental.

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 (*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 (*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) Reset added in v0.0.7

func (*Call_UpdateResourceProviderConfig) Size added in v0.0.11

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

func (*Call_UpdateResourceProviderConfig) String added in v0.0.7

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

func (m *Call_WaitContainer) Reset()

func (*Call_WaitContainer) Size added in v0.0.11

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

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

func (m *Call_WaitNestedContainer) Reset()

func (*Call_WaitNestedContainer) Size added in v0.0.11

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

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

func (m *ProcessIO) Reset()

func (*ProcessIO) Size added in v0.0.11

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

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 (*ProcessIO_Control) GetTTYInfo

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

func (*ProcessIO_Control) GetType

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

func (m *ProcessIO_Control) Reset()

func (*ProcessIO_Control) Size added in v0.0.11

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

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

func (m *ProcessIO_Control_Heartbeat) Reset()

func (*ProcessIO_Control_Heartbeat) Size added in v0.0.11

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

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

func (m *ProcessIO_Data) Reset()

func (*ProcessIO_Data) Size added in v0.0.11

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

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 (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"`
	GetOperations        *Response_GetOperations        `protobuf:"bytes,18,opt,name=get_operations,json=getOperations" json:"get_operations,omitempty"`
	GetTasks             *Response_GetTasks             `protobuf:"bytes,13,opt,name=get_tasks,json=getTasks" json:"get_tasks,omitempty"`
	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) GetGetOperations added in v0.0.8

func (m *Response) GetGetOperations() *Response_GetOperations

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

func (m *Response) Reset()

func (*Response) Size added in v0.0.11

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

func (*Response) String

func (this *Response) String() string

func (*Response) Unmarshal

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

func (*Response) UnmarshalJSON

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

func (*Response) UnmarshalJSONFFLexer

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

func (*Response) VerboseEqual

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

type Response_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"`
	DrainConfig             *mesos.DrainConfig `protobuf:"bytes,2,opt,name=drain_config,json=drainConfig" json:"drain_config,omitempty"`
	EstimatedDrainStartTime *mesos.TimeInfo    `` /* 127-byte string literal not displayed */
}

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

func (m *Response_GetAgent) GetDrainConfig() *mesos.DrainConfig

func (*Response_GetAgent) GetEstimatedDrainStartTime added in v0.0.11

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

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

func (m *Response_GetAgent) Reset()

func (*Response_GetAgent) Size added in v0.0.11

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

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

func (m *Response_GetContainers) Reset()

func (*Response_GetContainers) Size added in v0.0.11

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

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 (*Response_GetContainers_Container) GetContainerStatus

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

func (*Response_GetContainers_Container) GetExecutorID

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

func (*Response_GetContainers_Container) Size added in v0.0.11

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

func (*Response_GetContainers_Container) 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 (*Response_GetExecutors) GoString

func (this *Response_GetExecutors) GoString() string

func (*Response_GetExecutors) Marshal

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

func (*Response_GetExecutors) MarshalJSON

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

func (*Response_GetExecutors) MarshalJSONBuf

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

func (*Response_GetExecutors) MarshalTo

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

func (*Response_GetExecutors) ProtoMessage

func (*Response_GetExecutors) ProtoMessage()

func (*Response_GetExecutors) Reset

func (m *Response_GetExecutors) Reset()

func (*Response_GetExecutors) Size added in v0.0.11

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

func (*Response_GetExecutors) String

func (this *Response_GetExecutors) String() string

func (*Response_GetExecutors) Unmarshal

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

func (*Response_GetExecutors) UnmarshalJSON

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

func (*Response_GetExecutors) UnmarshalJSONFFLexer

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

func (*Response_GetExecutors) VerboseEqual

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

type Response_GetExecutors_Executor

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

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

func (m *Response_GetExecutors_Executor) Reset()

func (*Response_GetExecutors_Executor) Size added in v0.0.11

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

func (*Response_GetExecutors_Executor) String

func (this *Response_GetExecutors_Executor) String() string

func (*Response_GetExecutors_Executor) Unmarshal

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

func (*Response_GetExecutors_Executor) UnmarshalJSON

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

func (*Response_GetExecutors_Executor) UnmarshalJSONFFLexer

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

func (*Response_GetExecutors_Executor) VerboseEqual

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

type Response_GetFlags

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

Contains the flag configuration of the 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) Reset

func (m *Response_GetFlags) Reset()

func (*Response_GetFlags) Size added in v0.0.11

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

func (*Response_GetFlags) String

func (this *Response_GetFlags) String() string

func (*Response_GetFlags) Unmarshal

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

func (*Response_GetFlags) UnmarshalJSON

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

func (*Response_GetFlags) UnmarshalJSONFFLexer

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

func (*Response_GetFlags) VerboseEqual

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

type Response_GetFrameworks

type Response_GetFrameworks struct {
	Frameworks          []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 (*Response_GetFrameworks) GoString

func (this *Response_GetFrameworks) GoString() string

func (*Response_GetFrameworks) Marshal

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

func (*Response_GetFrameworks) MarshalJSON

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

func (*Response_GetFrameworks) MarshalJSONBuf

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

func (*Response_GetFrameworks) MarshalTo

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

func (*Response_GetFrameworks) ProtoMessage

func (*Response_GetFrameworks) ProtoMessage()

func (*Response_GetFrameworks) Reset

func (m *Response_GetFrameworks) Reset()

func (*Response_GetFrameworks) Size added in v0.0.11

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

func (*Response_GetFrameworks) String

func (this *Response_GetFrameworks) String() string

func (*Response_GetFrameworks) Unmarshal

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

func (*Response_GetFrameworks) UnmarshalJSON

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

func (*Response_GetFrameworks) UnmarshalJSONFFLexer

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

func (*Response_GetFrameworks) VerboseEqual

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

type Response_GetFrameworks_Framework

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

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

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

func (*Response_GetFrameworks_Framework) ProtoMessage

func (*Response_GetFrameworks_Framework) ProtoMessage()

func (*Response_GetFrameworks_Framework) Reset

func (*Response_GetFrameworks_Framework) Size added in v0.0.11

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

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

func (m *Response_GetHealth) Reset()

func (*Response_GetHealth) Size added in v0.0.11

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

func (*Response_GetHealth) String

func (this *Response_GetHealth) String() string

func (*Response_GetHealth) Unmarshal

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

func (*Response_GetHealth) UnmarshalJSON

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

func (*Response_GetHealth) UnmarshalJSONFFLexer

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

func (*Response_GetHealth) VerboseEqual

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

type Response_GetLoggingLevel

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

Contains the logging level of the 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) Reset

func (m *Response_GetLoggingLevel) Reset()

func (*Response_GetLoggingLevel) Size added in v0.0.11

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

func (*Response_GetLoggingLevel) String

func (this *Response_GetLoggingLevel) String() string

func (*Response_GetLoggingLevel) Unmarshal

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

func (*Response_GetLoggingLevel) UnmarshalJSON

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

func (*Response_GetLoggingLevel) UnmarshalJSONFFLexer

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

func (*Response_GetLoggingLevel) VerboseEqual

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

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

func (m *Response_GetMetrics) Reset()

func (*Response_GetMetrics) Size added in v0.0.11

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

func (*Response_GetMetrics) String

func (this *Response_GetMetrics) String() string

func (*Response_GetMetrics) Unmarshal

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

func (*Response_GetMetrics) UnmarshalJSON

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

func (*Response_GetMetrics) UnmarshalJSONFFLexer

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

func (*Response_GetMetrics) VerboseEqual

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

type Response_GetOperations added in v0.0.8

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

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

func NewPopulatedResponse_GetOperations added in v0.0.8

func NewPopulatedResponse_GetOperations(r randyAgent, easy bool) *Response_GetOperations

func (*Response_GetOperations) Descriptor added in v0.0.8

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

func (*Response_GetOperations) Equal added in v0.0.8

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

func (*Response_GetOperations) GetOperations added in v0.0.8

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

func (*Response_GetOperations) GoString added in v0.0.8

func (this *Response_GetOperations) GoString() string

func (*Response_GetOperations) Marshal added in v0.0.8

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

func (*Response_GetOperations) MarshalJSON added in v0.0.8

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

func (*Response_GetOperations) MarshalJSONBuf added in v0.0.8

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

func (*Response_GetOperations) MarshalTo added in v0.0.8

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

func (*Response_GetOperations) ProtoMessage added in v0.0.8

func (*Response_GetOperations) ProtoMessage()

func (*Response_GetOperations) Reset added in v0.0.8

func (m *Response_GetOperations) Reset()

func (*Response_GetOperations) Size added in v0.0.11

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

func (*Response_GetOperations) String added in v0.0.8

func (this *Response_GetOperations) String() string

func (*Response_GetOperations) Unmarshal added in v0.0.8

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

func (*Response_GetOperations) UnmarshalJSON added in v0.0.8

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

func (*Response_GetOperations) UnmarshalJSONFFLexer added in v0.0.8

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

func (*Response_GetOperations) VerboseEqual added in v0.0.8

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

type Response_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 (*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) Reset added in v0.0.7

func (m *Response_GetResourceProviders) Reset()

func (*Response_GetResourceProviders) Size added in v0.0.11

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

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

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) 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 (*Response_GetResourceProviders_ResourceProvider) GetTotalResources added in v0.0.8

func (*Response_GetResourceProviders_ResourceProvider) GoString added in v0.0.7

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 (*Response_GetResourceProviders_ResourceProvider) MarshalJSONBuf added in v0.0.7

func (*Response_GetResourceProviders_ResourceProvider) MarshalTo added in v0.0.7

func (*Response_GetResourceProviders_ResourceProvider) ProtoMessage added in v0.0.7

func (*Response_GetResourceProviders_ResourceProvider) Reset added in v0.0.7

func (*Response_GetResourceProviders_ResourceProvider) Size added in v0.0.11

func (*Response_GetResourceProviders_ResourceProvider) String added in v0.0.7

func (*Response_GetResourceProviders_ResourceProvider) Unmarshal added in v0.0.7

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

func (m *Response_GetState) Reset()

func (*Response_GetState) Size added in v0.0.11

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

func (*Response_GetState) String

func (this *Response_GetState) String() string

func (*Response_GetState) Unmarshal

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

func (*Response_GetState) UnmarshalJSON

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

func (*Response_GetState) UnmarshalJSONFFLexer

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

func (*Response_GetState) VerboseEqual

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

type Response_GetTasks

type Response_GetTasks struct {
	// Tasks that are 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) Reset

func (m *Response_GetTasks) Reset()

func (*Response_GetTasks) Size added in v0.0.11

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

func (*Response_GetTasks) String

func (this *Response_GetTasks) String() string

func (*Response_GetTasks) Unmarshal

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

func (*Response_GetTasks) UnmarshalJSON

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

func (*Response_GetTasks) UnmarshalJSONFFLexer

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

func (*Response_GetTasks) VerboseEqual

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

type Response_GetVersion

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

Contains the version information of the 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) Reset

func (m *Response_GetVersion) Reset()

func (*Response_GetVersion) Size added in v0.0.11

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

func (*Response_GetVersion) String

func (this *Response_GetVersion) String() string

func (*Response_GetVersion) Unmarshal

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

func (*Response_GetVersion) UnmarshalJSON

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

func (*Response_GetVersion) UnmarshalJSONFFLexer

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

func (*Response_GetVersion) VerboseEqual

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

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

func (m *Response_ListFiles) Reset()

func (*Response_ListFiles) Size added in v0.0.11

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

func (*Response_ListFiles) String

func (this *Response_ListFiles) String() string

func (*Response_ListFiles) Unmarshal

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

func (*Response_ListFiles) UnmarshalJSON

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

func (*Response_ListFiles) UnmarshalJSONFFLexer

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

func (*Response_ListFiles) VerboseEqual

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

type Response_ReadFile

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

Contains the file data.

func NewPopulatedResponse_ReadFile

func NewPopulatedResponse_ReadFile(r 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_ added in v0.0.11

func (m *Response_ReadFile) GetSize_() uint64

func (*Response_ReadFile) GoString

func (this *Response_ReadFile) GoString() string

func (*Response_ReadFile) Marshal

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

func (*Response_ReadFile) MarshalJSON

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

func (*Response_ReadFile) MarshalJSONBuf

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

func (*Response_ReadFile) MarshalTo

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

func (*Response_ReadFile) ProtoMessage

func (*Response_ReadFile) ProtoMessage()

func (*Response_ReadFile) Reset

func (m *Response_ReadFile) Reset()

func (*Response_ReadFile) Size

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

func (*Response_ReadFile) String

func (this *Response_ReadFile) String() string

func (*Response_ReadFile) Unmarshal

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

func (*Response_ReadFile) UnmarshalJSON

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

func (*Response_ReadFile) UnmarshalJSONFFLexer

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

func (*Response_ReadFile) VerboseEqual

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

type Response_Type

type Response_Type int32

Each of the responses of type `FOO` corresponds to `Foo` message below.

const (
	Response_UNKNOWN                Response_Type = 0
	Response_GET_HEALTH             Response_Type = 1
	Response_GET_FLAGS              Response_Type = 2
	Response_GET_VERSION            Response_Type = 3
	Response_GET_METRICS            Response_Type = 4
	Response_GET_LOGGING_LEVEL      Response_Type = 5
	Response_LIST_FILES             Response_Type = 6
	Response_READ_FILE              Response_Type = 7
	Response_GET_STATE              Response_Type = 8
	Response_GET_CONTAINERS         Response_Type = 9
	Response_GET_FRAMEWORKS         Response_Type = 10
	Response_GET_EXECUTORS          Response_Type = 11
	Response_GET_OPERATIONS         Response_Type = 17
	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 (*Response_WaitContainer) GetMessage added in v0.0.7

func (m *Response_WaitContainer) GetMessage() string

func (*Response_WaitContainer) GetReason added in v0.0.7

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

func (m *Response_WaitContainer) Reset()

func (*Response_WaitContainer) Size added in v0.0.11

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

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 (*Response_WaitNestedContainer) GetMessage added in v0.0.7

func (m *Response_WaitNestedContainer) GetMessage() string

func (*Response_WaitNestedContainer) GetReason added in v0.0.7

func (*Response_WaitNestedContainer) GetState added in v0.0.7

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

func (m *Response_WaitNestedContainer) Reset()

func (*Response_WaitNestedContainer) Size added in v0.0.11

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

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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