agent

package
v0.0.5 Latest Latest
Warning

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

 Go to latest Published: Sep 19, 2017 License: Apache-2.0 Imports: 13 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",
	13: "GET_TASKS",
	20: "GET_AGENT",
	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",
}
View Source 
var Call_Type_value = map[string]int32{
	"UNKNOWN":                         0,
	"GET_HEALTH":                      1,
	"GET_FLAGS":                       2,
	"GET_VERSION":                     3,
	"GET_METRICS":                     4,
	"GET_LOGGING_LEVEL":               5,
	"SET_LOGGING_LEVEL":               6,
	"LIST_FILES":                      7,
	"READ_FILE":                       8,
	"GET_STATE":                       9,
	"GET_CONTAINERS":                  10,
	"GET_FRAMEWORKS":                  11,
	"GET_EXECUTORS":                   12,
	"GET_TASKS":                       13,
	"GET_AGENT":                       20,
	"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,
}
View Source 
var ProcessIO_Control_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "TTY_INFO",
	2: "HEARTBEAT",
}
View Source 
var ProcessIO_Control_Type_value = map[string]int32{
	"UNKNOWN":   0,
	"TTY_INFO":  1,
	"HEARTBEAT": 2,
}
View Source 
var ProcessIO_Data_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "STDIN",
	2: "STDOUT",
	3: "STDERR",
}
View Source 
var ProcessIO_Data_Type_value = map[string]int32{
	"UNKNOWN": 0,
	"STDIN":   1,
	"STDOUT":  2,
	"STDERR":  3,
}
View Source 
var ProcessIO_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "DATA",
	2: "CONTROL",
}
View Source 
var ProcessIO_Type_value = map[string]int32{
	"UNKNOWN": 0,
	"DATA":    1,
	"CONTROL": 2,
}
View Source 
var Response_Type_name = map[int32]string{
	0:  "UNKNOWN",
	1:  "GET_HEALTH",
	2:  "GET_FLAGS",
	3:  "GET_VERSION",
	4:  "GET_METRICS",
	5:  "GET_LOGGING_LEVEL",
	6:  "LIST_FILES",
	7:  "READ_FILE",
	8:  "GET_STATE",
	9:  "GET_CONTAINERS",
	10: "GET_FRAMEWORKS",
	11: "GET_EXECUTORS",
	12: "GET_TASKS",
	14: "GET_AGENT",
	13: "WAIT_NESTED_CONTAINER",
}
View Source 
var Response_Type_value = map[string]int32{
	"UNKNOWN":               0,
	"GET_HEALTH":            1,
	"GET_FLAGS":             2,
	"GET_VERSION":           3,
	"GET_METRICS":           4,
	"GET_LOGGING_LEVEL":     5,
	"LIST_FILES":            6,
	"READ_FILE":             7,
	"GET_STATE":             8,
	"GET_CONTAINERS":        9,
	"GET_FRAMEWORKS":        10,
	"GET_EXECUTORS":         11,
	"GET_TASKS":             12,
	"GET_AGENT":             14,
	"WAIT_NESTED_CONTAINER": 13,
}

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

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

func (m *Call) GetAttachContainerInput() *Call_AttachContainerInput

func (*Call) GetAttachContainerOutput 

func (m *Call) GetAttachContainerOutput() *Call_AttachContainerOutput

func (*Call) GetGetMetrics 

func (m *Call) GetGetMetrics() *Call_GetMetrics

func (*Call) GetKillNestedContainer 

func (m *Call) GetKillNestedContainer() *Call_KillNestedContainer

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

func (m *Call) GetReadFile() *Call_ReadFile

func (*Call) GetRemoveNestedContainer added in v0.0.5 

func (m *Call) GetRemoveNestedContainer() *Call_RemoveNestedContainer

func (*Call) GetSetLoggingLevel 

func (m *Call) GetSetLoggingLevel() *Call_SetLoggingLevel

func (*Call) GetType 

func (m *Call) GetType() Call_Type

func (*Call) GetWaitNestedContainer 

func (m *Call) GetWaitNestedContainer() *Call_WaitNestedContainer

func (*Call) GoString 

func (this *Call) GoString() string

func (*Call) Marshal 

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

func (*Call) MarshalJSON 

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

func (*Call) MarshalJSONBuf 

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

func (*Call) MarshalTo 

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

func (*Call) ProtoMessage 

func (*Call) ProtoMessage()

func (*Call) ProtoSize 

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

func (*Call) Reset 

func (m *Call) Reset()

func (*Call) String 

func (this *Call) String() string

func (*Call) Unmarshal 

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

func (*Call) UnmarshalJSON 

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

func (*Call) UnmarshalJSONFFLexer 

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

func (*Call) VerboseEqual 

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

type Call_AttachContainerInput 

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

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

func NewPopulatedCall_AttachContainerInput 

func NewPopulatedCall_AttachContainerInput(r randyAgent, easy bool) *Call_AttachContainerInput

func (*Call_AttachContainerInput) Descriptor 

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

func (*Call_AttachContainerInput) Equal 

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

func (*Call_AttachContainerInput) GetContainerID 

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

func (*Call_AttachContainerInput) GetProcessIO 

func (m *Call_AttachContainerInput) GetProcessIO() *ProcessIO

func (*Call_AttachContainerInput) GetType 

func (m *Call_AttachContainerInput) GetType() Call_AttachContainerInput_Type

func (*Call_AttachContainerInput) GoString 

func (this *Call_AttachContainerInput) GoString() string

func (*Call_AttachContainerInput) Marshal 

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

func (*Call_AttachContainerInput) MarshalJSON 

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

func (*Call_AttachContainerInput) MarshalJSONBuf 

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

func (*Call_AttachContainerInput) MarshalTo 

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

func (*Call_AttachContainerInput) ProtoMessage 

func (*Call_AttachContainerInput) ProtoMessage()

func (*Call_AttachContainerInput) ProtoSize 

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

func (*Call_AttachContainerInput) Reset 

func (m *Call_AttachContainerInput) Reset()

func (*Call_AttachContainerInput) String 

func (this *Call_AttachContainerInput) String() string

func (*Call_AttachContainerInput) Unmarshal 

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

func (*Call_AttachContainerInput) UnmarshalJSON 

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

func (*Call_AttachContainerInput) UnmarshalJSONFFLexer 

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

func (*Call_AttachContainerInput) VerboseEqual 

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

type Call_AttachContainerInput_Type 

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

func (Call_AttachContainerInput_Type) Enum 

func (x Call_AttachContainerInput_Type) Enum() *Call_AttachContainerInput_Type

func (Call_AttachContainerInput_Type) EnumDescriptor 

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

func (Call_AttachContainerInput_Type) MarshalJSON 

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

func (Call_AttachContainerInput_Type) String 

func (x Call_AttachContainerInput_Type) String() string

func (*Call_AttachContainerInput_Type) UnmarshalJSON 

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

type Call_AttachContainerOutput 

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

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

func NewPopulatedCall_AttachContainerOutput 

func NewPopulatedCall_AttachContainerOutput(r randyAgent, easy bool) *Call_AttachContainerOutput

func (*Call_AttachContainerOutput) Descriptor 

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

func (*Call_AttachContainerOutput) Equal 

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

func (*Call_AttachContainerOutput) GetContainerID 

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

func (*Call_AttachContainerOutput) GoString 

func (this *Call_AttachContainerOutput) GoString() string

func (*Call_AttachContainerOutput) Marshal 

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

func (*Call_AttachContainerOutput) MarshalJSON 

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

func (*Call_AttachContainerOutput) MarshalJSONBuf 

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

func (*Call_AttachContainerOutput) MarshalTo 

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

func (*Call_AttachContainerOutput) ProtoMessage 

func (*Call_AttachContainerOutput) ProtoMessage()

func (*Call_AttachContainerOutput) ProtoSize 

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

func (*Call_AttachContainerOutput) Reset 

func (m *Call_AttachContainerOutput) Reset()

func (*Call_AttachContainerOutput) String 

func (this *Call_AttachContainerOutput) String() string

func (*Call_AttachContainerOutput) Unmarshal 

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

func (*Call_AttachContainerOutput) UnmarshalJSON 

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

func (*Call_AttachContainerOutput) UnmarshalJSONFFLexer 

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

func (*Call_AttachContainerOutput) VerboseEqual 

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

type Call_GetMetrics 

type Call_GetMetrics struct {
	// If set, `timeout` would be used to determines the maximum amount of time
	// the API will take to respond. If the timeout is exceeded, some metrics
	// may not be included in the response.
	Timeout *mesos.DurationInfo `protobuf:"bytes,1,opt,name=timeout" json:"timeout,omitempty"`
}

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

func NewPopulatedCall_GetMetrics 

func NewPopulatedCall_GetMetrics(r randyAgent, easy bool) *Call_GetMetrics

func (*Call_GetMetrics) Descriptor 

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

func (*Call_GetMetrics) Equal 

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

func (*Call_GetMetrics) GetTimeout 

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

func (*Call_GetMetrics) GoString 

func (this *Call_GetMetrics) GoString() string

func (*Call_GetMetrics) Marshal 

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

func (*Call_GetMetrics) MarshalJSON 

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

func (*Call_GetMetrics) MarshalJSONBuf 

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

func (*Call_GetMetrics) MarshalTo 

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

func (*Call_GetMetrics) ProtoMessage 

func (*Call_GetMetrics) ProtoMessage()

func (*Call_GetMetrics) ProtoSize 

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

func (*Call_GetMetrics) Reset 

func (m *Call_GetMetrics) Reset()

func (*Call_GetMetrics) String 

func (this *Call_GetMetrics) String() string

func (*Call_GetMetrics) Unmarshal 

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

func (*Call_GetMetrics) UnmarshalJSON 

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

func (*Call_GetMetrics) UnmarshalJSONFFLexer 

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

func (*Call_GetMetrics) VerboseEqual 

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

type Call_KillNestedContainer 

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

Kills the nested container. Currently only supports SIGKILL.

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

func (this *Call_KillNestedContainer) GoString() string

func (*Call_KillNestedContainer) Marshal 

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

func (*Call_KillNestedContainer) MarshalJSON 

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

func (*Call_KillNestedContainer) MarshalJSONBuf 

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

func (*Call_KillNestedContainer) MarshalTo 

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

func (*Call_KillNestedContainer) ProtoMessage 

func (*Call_KillNestedContainer) ProtoMessage()

func (*Call_KillNestedContainer) ProtoSize 

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

func (*Call_KillNestedContainer) Reset 

func (m *Call_KillNestedContainer) Reset()

func (*Call_KillNestedContainer) String 

func (this *Call_KillNestedContainer) String() string

func (*Call_KillNestedContainer) Unmarshal 

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

func (*Call_KillNestedContainer) UnmarshalJSON 

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

func (*Call_KillNestedContainer) UnmarshalJSONFFLexer 

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

func (*Call_KillNestedContainer) VerboseEqual 

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

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

Launches a nested container within an executor's tree of containers.

func NewPopulatedCall_LaunchNestedContainer 

func NewPopulatedCall_LaunchNestedContainer(r randyAgent, easy bool) *Call_LaunchNestedContainer

func (*Call_LaunchNestedContainer) Descriptor 

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

func (*Call_LaunchNestedContainer) Equal 

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

func (*Call_LaunchNestedContainer) GetCommand 

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

func (*Call_LaunchNestedContainer) GetContainer 

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

func (*Call_LaunchNestedContainer) GetContainerID 

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

func (*Call_LaunchNestedContainer) GoString 

func (this *Call_LaunchNestedContainer) GoString() string

func (*Call_LaunchNestedContainer) Marshal 

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

func (*Call_LaunchNestedContainer) MarshalJSON 

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

func (*Call_LaunchNestedContainer) MarshalJSONBuf 

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

func (*Call_LaunchNestedContainer) MarshalTo 

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

func (*Call_LaunchNestedContainer) ProtoMessage 

func (*Call_LaunchNestedContainer) ProtoMessage()

func (*Call_LaunchNestedContainer) ProtoSize 

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

func (*Call_LaunchNestedContainer) Reset 

func (m *Call_LaunchNestedContainer) Reset()

func (*Call_LaunchNestedContainer) String 

func (this *Call_LaunchNestedContainer) String() string

func (*Call_LaunchNestedContainer) Unmarshal 

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

func (*Call_LaunchNestedContainer) UnmarshalJSON 

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

func (*Call_LaunchNestedContainer) UnmarshalJSONFFLexer 

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

func (*Call_LaunchNestedContainer) VerboseEqual 

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

type Call_LaunchNestedContainerSession 

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

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

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

func NewPopulatedCall_LaunchNestedContainerSession 

func NewPopulatedCall_LaunchNestedContainerSession(r randyAgent, easy bool) *Call_LaunchNestedContainerSession

func (*Call_LaunchNestedContainerSession) Descriptor 

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

func (*Call_LaunchNestedContainerSession) Equal 

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

func (*Call_LaunchNestedContainerSession) GetCommand 

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

func (*Call_LaunchNestedContainerSession) GetContainer 

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

func (*Call_LaunchNestedContainerSession) GetContainerID 

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

func (*Call_LaunchNestedContainerSession) GoString 

func (this *Call_LaunchNestedContainerSession) GoString() string

func (*Call_LaunchNestedContainerSession) Marshal 

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

func (*Call_LaunchNestedContainerSession) MarshalJSON 

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

func (*Call_LaunchNestedContainerSession) MarshalJSONBuf 

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

func (*Call_LaunchNestedContainerSession) MarshalTo 

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

func (*Call_LaunchNestedContainerSession) ProtoMessage 

func (*Call_LaunchNestedContainerSession) ProtoMessage()

func (*Call_LaunchNestedContainerSession) ProtoSize 

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

func (*Call_LaunchNestedContainerSession) Reset 

func (m *Call_LaunchNestedContainerSession) Reset()

func (*Call_LaunchNestedContainerSession) String 

func (this *Call_LaunchNestedContainerSession) String() string

func (*Call_LaunchNestedContainerSession) Unmarshal 

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

func (*Call_LaunchNestedContainerSession) UnmarshalJSON 

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

func (*Call_LaunchNestedContainerSession) UnmarshalJSONFFLexer 

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

func (*Call_LaunchNestedContainerSession) VerboseEqual 

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

type Call_ListFiles 

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

Provides the file listing for a directory.

func NewPopulatedCall_ListFiles 

func NewPopulatedCall_ListFiles(r randyAgent, easy bool) *Call_ListFiles

func (*Call_ListFiles) Descriptor 

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

func (*Call_ListFiles) Equal 

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

func (*Call_ListFiles) GetPath 

func (m *Call_ListFiles) GetPath() string

func (*Call_ListFiles) GoString 

func (this *Call_ListFiles) GoString() string

func (*Call_ListFiles) Marshal 

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

func (*Call_ListFiles) MarshalJSON 

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

func (*Call_ListFiles) MarshalJSONBuf 

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

func (*Call_ListFiles) MarshalTo 

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

func (*Call_ListFiles) ProtoMessage 

func (*Call_ListFiles) ProtoMessage()

func (*Call_ListFiles) ProtoSize 

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

func (*Call_ListFiles) Reset 

func (m *Call_ListFiles) Reset()

func (*Call_ListFiles) String 

func (this *Call_ListFiles) String() string

func (*Call_ListFiles) Unmarshal 

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

func (*Call_ListFiles) UnmarshalJSON 

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

func (*Call_ListFiles) UnmarshalJSONFFLexer 

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

func (*Call_ListFiles) VerboseEqual 

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

type Call_ReadFile 

type Call_ReadFile struct {
	// The path of file.
	Path string `protobuf:"bytes,1,req,name=path" json:"path"`
	// Initial offset in file to start reading from.
	Offset uint64 `protobuf:"varint,2,req,name=offset" json:"offset"`
	// The maximum number of bytes to read. The read length is capped at 16
	// memory pages.
	Length *uint64 `protobuf:"varint,3,opt,name=length" json:"length,omitempty"`
}

Reads data from a file.

func NewPopulatedCall_ReadFile 

func NewPopulatedCall_ReadFile(r randyAgent, easy bool) *Call_ReadFile

func (*Call_ReadFile) Descriptor 

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

func (*Call_ReadFile) Equal 

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

func (*Call_ReadFile) GetLength 

func (m *Call_ReadFile) GetLength() uint64

func (*Call_ReadFile) GetOffset 

func (m *Call_ReadFile) GetOffset() uint64

func (*Call_ReadFile) GetPath 

func (m *Call_ReadFile) GetPath() string

func (*Call_ReadFile) GoString 

func (this *Call_ReadFile) GoString() string

func (*Call_ReadFile) Marshal 

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

func (*Call_ReadFile) MarshalJSON 

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

func (*Call_ReadFile) MarshalJSONBuf 

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

func (*Call_ReadFile) MarshalTo 

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

func (*Call_ReadFile) ProtoMessage 

func (*Call_ReadFile) ProtoMessage()

func (*Call_ReadFile) ProtoSize 

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

func (*Call_ReadFile) Reset 

func (m *Call_ReadFile) Reset()

func (*Call_ReadFile) String 

func (this *Call_ReadFile) String() string

func (*Call_ReadFile) Unmarshal 

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

func (*Call_ReadFile) UnmarshalJSON 

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

func (*Call_ReadFile) UnmarshalJSONFFLexer 

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

func (*Call_ReadFile) VerboseEqual 

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

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

Removes a nested container and its artifacts (runtime and sandbox directories).

func NewPopulatedCall_RemoveNestedContainer added in v0.0.5 

func NewPopulatedCall_RemoveNestedContainer(r randyAgent, easy bool) *Call_RemoveNestedContainer

func (*Call_RemoveNestedContainer) Descriptor added in v0.0.5 

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

func (*Call_RemoveNestedContainer) Equal added in v0.0.5 

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

func (*Call_RemoveNestedContainer) GetContainerID added in v0.0.5 

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

func (*Call_RemoveNestedContainer) GoString added in v0.0.5 

func (this *Call_RemoveNestedContainer) GoString() string

func (*Call_RemoveNestedContainer) Marshal added in v0.0.5 

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

func (*Call_RemoveNestedContainer) MarshalJSON added in v0.0.5 

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

func (*Call_RemoveNestedContainer) MarshalJSONBuf added in v0.0.5 

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

func (*Call_RemoveNestedContainer) MarshalTo added in v0.0.5 

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

func (*Call_RemoveNestedContainer) ProtoMessage added in v0.0.5 

func (*Call_RemoveNestedContainer) ProtoMessage()

func (*Call_RemoveNestedContainer) ProtoSize added in v0.0.5 

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

func (*Call_RemoveNestedContainer) Reset added in v0.0.5 

func (m *Call_RemoveNestedContainer) Reset()

func (*Call_RemoveNestedContainer) String added in v0.0.5 

func (this *Call_RemoveNestedContainer) String() string

func (*Call_RemoveNestedContainer) Unmarshal added in v0.0.5 

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

func (*Call_RemoveNestedContainer) UnmarshalJSON added in v0.0.5 

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

func (*Call_RemoveNestedContainer) UnmarshalJSONFFLexer added in v0.0.5 

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

func (*Call_RemoveNestedContainer) VerboseEqual added in v0.0.5 

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

type Call_SetLoggingLevel 

type Call_SetLoggingLevel struct {
	// The verbosity level.
	Level uint32 `protobuf:"varint,1,req,name=level" json:"level"`
	// The duration to keep verbosity level toggled. After this duration, the
	// verbosity level of log would revert to the original level.
	Duration mesos.DurationInfo `protobuf:"bytes,2,req,name=duration" json:"duration"`
}

Sets the logging verbosity level for a specified duration. Mesos uses [glog](https://github.com/google/glog) for logging. The library only uses verbose logging which means nothing will be output unless the verbosity level is set (by default it's 0, libprocess uses levels 1, 2, and 3).

func NewPopulatedCall_SetLoggingLevel 

func NewPopulatedCall_SetLoggingLevel(r randyAgent, easy bool) *Call_SetLoggingLevel

func (*Call_SetLoggingLevel) Descriptor 

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

func (*Call_SetLoggingLevel) Equal 

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

func (*Call_SetLoggingLevel) GetDuration 

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

func (*Call_SetLoggingLevel) GetLevel 

func (m *Call_SetLoggingLevel) GetLevel() uint32

func (*Call_SetLoggingLevel) GoString 

func (this *Call_SetLoggingLevel) GoString() string

func (*Call_SetLoggingLevel) Marshal 

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

func (*Call_SetLoggingLevel) MarshalJSON 

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

func (*Call_SetLoggingLevel) MarshalJSONBuf 

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

func (*Call_SetLoggingLevel) MarshalTo 

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

func (*Call_SetLoggingLevel) ProtoMessage 

func (*Call_SetLoggingLevel) ProtoMessage()

func (*Call_SetLoggingLevel) ProtoSize 

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

func (*Call_SetLoggingLevel) Reset 

func (m *Call_SetLoggingLevel) Reset()

func (*Call_SetLoggingLevel) String 

func (this *Call_SetLoggingLevel) String() string

func (*Call_SetLoggingLevel) Unmarshal 

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

func (*Call_SetLoggingLevel) UnmarshalJSON 

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

func (*Call_SetLoggingLevel) UnmarshalJSONFFLexer 

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

func (*Call_SetLoggingLevel) VerboseEqual 

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

type Call_Type 

type Call_Type int32

If a call of type `Call::FOO` requires additional parameters they can be included in the corresponding `Call::Foo` message. Similarly, if a call receives a synchronous response it will be returned as a `Response` message of type `Response::FOO`; see `Call::LaunchNestedContainerSession` and `Call::AttachContainerOutput` for exceptions. 

const (
	Call_UNKNOWN           Call_Type = 0
	Call_GET_HEALTH        Call_Type = 1
	Call_GET_FLAGS         Call_Type = 2
	Call_GET_VERSION       Call_Type = 3
	Call_GET_METRICS       Call_Type = 4
	Call_GET_LOGGING_LEVEL Call_Type = 5
	Call_SET_LOGGING_LEVEL Call_Type = 6
	Call_LIST_FILES        Call_Type = 7
	Call_READ_FILE         Call_Type = 8
	Call_GET_STATE         Call_Type = 9
	Call_GET_CONTAINERS    Call_Type = 10
	Call_GET_FRAMEWORKS    Call_Type = 11
	Call_GET_EXECUTORS     Call_Type = 12
	Call_GET_TASKS         Call_Type = 13
	Call_GET_AGENT         Call_Type = 20
	// Calls for managing nested containers underneath an executor's container.
	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
)

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_WaitNestedContainer 

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

Waits for the nested container to terminate and receives the exit status.

func NewPopulatedCall_WaitNestedContainer 

func NewPopulatedCall_WaitNestedContainer(r randyAgent, easy bool) *Call_WaitNestedContainer

func (*Call_WaitNestedContainer) Descriptor 

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

func (*Call_WaitNestedContainer) Equal 

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

func (*Call_WaitNestedContainer) GetContainerID 

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

func (*Call_WaitNestedContainer) GoString 

func (this *Call_WaitNestedContainer) GoString() string

func (*Call_WaitNestedContainer) Marshal 

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

func (*Call_WaitNestedContainer) MarshalJSON 

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

func (*Call_WaitNestedContainer) MarshalJSONBuf 

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

func (*Call_WaitNestedContainer) MarshalTo 

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

func (*Call_WaitNestedContainer) ProtoMessage 

func (*Call_WaitNestedContainer) ProtoMessage()

func (*Call_WaitNestedContainer) ProtoSize 

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

func (*Call_WaitNestedContainer) Reset 

func (m *Call_WaitNestedContainer) Reset()

func (*Call_WaitNestedContainer) String 

func (this *Call_WaitNestedContainer) String() string

func (*Call_WaitNestedContainer) Unmarshal 

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

func (*Call_WaitNestedContainer) UnmarshalJSON 

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

func (*Call_WaitNestedContainer) UnmarshalJSONFFLexer 

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

func (*Call_WaitNestedContainer) VerboseEqual 

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

type ProcessIO 

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

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

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

func NewPopulatedProcessIO 

func NewPopulatedProcessIO(r randyAgent, easy bool) *ProcessIO

func (*ProcessIO) Descriptor 

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

func (*ProcessIO) Equal 

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

func (*ProcessIO) GetControl 

func (m *ProcessIO) GetControl() *ProcessIO_Control

func (*ProcessIO) GetData 

func (m *ProcessIO) GetData() *ProcessIO_Data

func (*ProcessIO) GetType 

func (m *ProcessIO) GetType() ProcessIO_Type

func (*ProcessIO) GoString 

func (this *ProcessIO) GoString() string

func (*ProcessIO) Marshal 

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

func (*ProcessIO) MarshalJSON 

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

func (*ProcessIO) MarshalJSONBuf 

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

func (*ProcessIO) MarshalTo 

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

func (*ProcessIO) ProtoMessage 

func (*ProcessIO) ProtoMessage()

func (*ProcessIO) ProtoSize 

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

func (*ProcessIO) Reset 

func (m *ProcessIO) Reset()

func (*ProcessIO) String 

func (this *ProcessIO) String() string

func (*ProcessIO) Unmarshal 

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

func (*ProcessIO) UnmarshalJSON 

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

func (*ProcessIO) UnmarshalJSONFFLexer 

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

func (*ProcessIO) VerboseEqual 

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

type ProcessIO_Control 

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

func NewPopulatedProcessIO_Control 

func NewPopulatedProcessIO_Control(r randyAgent, easy bool) *ProcessIO_Control

func (*ProcessIO_Control) Descriptor 

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

func (*ProcessIO_Control) Equal 

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

func (*ProcessIO_Control) GetHeartbeat 

func (m *ProcessIO_Control) GetHeartbeat() *ProcessIO_Control_Heartbeat

func (*ProcessIO_Control) GetTTYInfo 

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

func (*ProcessIO_Control) GetType 

func (m *ProcessIO_Control) GetType() ProcessIO_Control_Type

func (*ProcessIO_Control) GoString 

func (this *ProcessIO_Control) GoString() string

func (*ProcessIO_Control) Marshal 

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

func (*ProcessIO_Control) MarshalJSON 

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

func (*ProcessIO_Control) MarshalJSONBuf 

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

func (*ProcessIO_Control) MarshalTo 

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

func (*ProcessIO_Control) ProtoMessage 

func (*ProcessIO_Control) ProtoMessage()

func (*ProcessIO_Control) ProtoSize 

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

func (*ProcessIO_Control) Reset 

func (m *ProcessIO_Control) Reset()

func (*ProcessIO_Control) String 

func (this *ProcessIO_Control) String() string

func (*ProcessIO_Control) Unmarshal 

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

func (*ProcessIO_Control) UnmarshalJSON 

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

func (*ProcessIO_Control) UnmarshalJSONFFLexer 

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

func (*ProcessIO_Control) VerboseEqual 

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

type ProcessIO_Control_Heartbeat 

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

func NewPopulatedProcessIO_Control_Heartbeat 

func NewPopulatedProcessIO_Control_Heartbeat(r randyAgent, easy bool) *ProcessIO_Control_Heartbeat

func (*ProcessIO_Control_Heartbeat) Descriptor 

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

func (*ProcessIO_Control_Heartbeat) Equal 

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

func (*ProcessIO_Control_Heartbeat) GetInterval 

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

func (*ProcessIO_Control_Heartbeat) GoString 

func (this *ProcessIO_Control_Heartbeat) GoString() string

func (*ProcessIO_Control_Heartbeat) Marshal 

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

func (*ProcessIO_Control_Heartbeat) MarshalJSON 

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

func (*ProcessIO_Control_Heartbeat) MarshalJSONBuf 

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

func (*ProcessIO_Control_Heartbeat) MarshalTo 

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

func (*ProcessIO_Control_Heartbeat) ProtoMessage 

func (*ProcessIO_Control_Heartbeat) ProtoMessage()

func (*ProcessIO_Control_Heartbeat) ProtoSize 

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

func (*ProcessIO_Control_Heartbeat) Reset 

func (m *ProcessIO_Control_Heartbeat) Reset()

func (*ProcessIO_Control_Heartbeat) String 

func (this *ProcessIO_Control_Heartbeat) String() string

func (*ProcessIO_Control_Heartbeat) Unmarshal 

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

func (*ProcessIO_Control_Heartbeat) UnmarshalJSON 

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

func (*ProcessIO_Control_Heartbeat) UnmarshalJSONFFLexer 

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

func (*ProcessIO_Control_Heartbeat) VerboseEqual 

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

type ProcessIO_Control_Type 

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

func (ProcessIO_Control_Type) Enum 

func (x ProcessIO_Control_Type) Enum() *ProcessIO_Control_Type

func (ProcessIO_Control_Type) EnumDescriptor 

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

func (ProcessIO_Control_Type) MarshalJSON 

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

func (ProcessIO_Control_Type) String 

func (x ProcessIO_Control_Type) String() string

func (*ProcessIO_Control_Type) UnmarshalJSON 

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

type ProcessIO_Data 

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

func NewPopulatedProcessIO_Data 

func NewPopulatedProcessIO_Data(r randyAgent, easy bool) *ProcessIO_Data

func (*ProcessIO_Data) Descriptor 

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

func (*ProcessIO_Data) Equal 

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

func (*ProcessIO_Data) GetData 

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

func (*ProcessIO_Data) GetType 

func (m *ProcessIO_Data) GetType() ProcessIO_Data_Type

func (*ProcessIO_Data) GoString 

func (this *ProcessIO_Data) GoString() string

func (*ProcessIO_Data) Marshal 

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

func (*ProcessIO_Data) MarshalJSON 

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

func (*ProcessIO_Data) MarshalJSONBuf 

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

func (*ProcessIO_Data) MarshalTo 

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

func (*ProcessIO_Data) ProtoMessage 

func (*ProcessIO_Data) ProtoMessage()

func (*ProcessIO_Data) ProtoSize 

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

func (*ProcessIO_Data) Reset 

func (m *ProcessIO_Data) Reset()

func (*ProcessIO_Data) String 

func (this *ProcessIO_Data) String() string

func (*ProcessIO_Data) Unmarshal 

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

func (*ProcessIO_Data) UnmarshalJSON 

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

func (*ProcessIO_Data) UnmarshalJSONFFLexer 

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

func (*ProcessIO_Data) VerboseEqual 

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

type ProcessIO_Data_Type 

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

func (ProcessIO_Data_Type) Enum 

func (x ProcessIO_Data_Type) Enum() *ProcessIO_Data_Type

func (ProcessIO_Data_Type) EnumDescriptor 

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

func (ProcessIO_Data_Type) MarshalJSON 

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

func (ProcessIO_Data_Type) String 

func (x ProcessIO_Data_Type) String() string

func (*ProcessIO_Data_Type) UnmarshalJSON 

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

type ProcessIO_Type 

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

func (ProcessIO_Type) Enum 

func (x ProcessIO_Type) Enum() *ProcessIO_Type

func (ProcessIO_Type) EnumDescriptor 

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

func (ProcessIO_Type) MarshalJSON 

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

func (ProcessIO_Type) String 

func (x ProcessIO_Type) String() string

func (*ProcessIO_Type) UnmarshalJSON 

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

type Response 

type Response struct {
	Type                Response_Type                 `protobuf:"varint,1,opt,name=type,enum=mesos.agent.Response_Type" json:"type"`
	GetHealth           *Response_GetHealth           `protobuf:"bytes,2,opt,name=get_health,json=getHealth" json:"get_health,omitempty"`
	GetFlags            *Response_GetFlags            `protobuf:"bytes,3,opt,name=get_flags,json=getFlags" json:"get_flags,omitempty"`
	GetVersion          *Response_GetVersion          `protobuf:"bytes,4,opt,name=get_version,json=getVersion" json:"get_version,omitempty"`
	GetMetrics          *Response_GetMetrics          `protobuf:"bytes,5,opt,name=get_metrics,json=getMetrics" json:"get_metrics,omitempty"`
	GetLoggingLevel     *Response_GetLoggingLevel     `protobuf:"bytes,6,opt,name=get_logging_level,json=getLoggingLevel" json:"get_logging_level,omitempty"`
	ListFiles           *Response_ListFiles           `protobuf:"bytes,7,opt,name=list_files,json=listFiles" json:"list_files,omitempty"`
	ReadFile            *Response_ReadFile            `protobuf:"bytes,8,opt,name=read_file,json=readFile" json:"read_file,omitempty"`
	GetState            *Response_GetState            `protobuf:"bytes,9,opt,name=get_state,json=getState" json:"get_state,omitempty"`
	GetContainers       *Response_GetContainers       `protobuf:"bytes,10,opt,name=get_containers,json=getContainers" json:"get_containers,omitempty"`
	GetFrameworks       *Response_GetFrameworks       `protobuf:"bytes,11,opt,name=get_frameworks,json=getFrameworks" json:"get_frameworks,omitempty"`
	GetExecutors        *Response_GetExecutors        `protobuf:"bytes,12,opt,name=get_executors,json=getExecutors" json:"get_executors,omitempty"`
	GetTasks            *Response_GetTasks            `protobuf:"bytes,13,opt,name=get_tasks,json=getTasks" json:"get_tasks,omitempty"`
	GetAgent            *Response_GetAgent            `protobuf:"bytes,15,opt,name=get_agent,json=getAgent" json:"get_agent,omitempty"`
	WaitNestedContainer *Response_WaitNestedContainer `protobuf:"bytes,14,opt,name=wait_nested_container,json=waitNestedContainer" json:"wait_nested_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) 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) GetWaitNestedContainer 

func (m *Response) GetWaitNestedContainer() *Response_WaitNestedContainer

func (*Response) GoString 

func (this *Response) GoString() string

func (*Response) Marshal 

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

func (*Response) MarshalJSON 

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

func (*Response) MarshalJSONBuf 

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

func (*Response) MarshalTo 

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

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoSize 

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

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) String 

func (this *Response) String() string

func (*Response) Unmarshal 

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

func (*Response) UnmarshalJSON 

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

func (*Response) UnmarshalJSONFFLexer 

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

func (*Response) VerboseEqual 

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

type Response_GetAgent added in v0.0.5 

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

Contains the agent's information.

func NewPopulatedResponse_GetAgent added in v0.0.5 

func NewPopulatedResponse_GetAgent(r randyAgent, easy bool) *Response_GetAgent

func (*Response_GetAgent) Descriptor added in v0.0.5 

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

func (*Response_GetAgent) Equal added in v0.0.5 

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

func (*Response_GetAgent) GetAgentInfo added in v0.0.5 

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

func (*Response_GetAgent) GoString added in v0.0.5 

func (this *Response_GetAgent) GoString() string

func (*Response_GetAgent) Marshal added in v0.0.5 

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

func (*Response_GetAgent) MarshalJSON added in v0.0.5 

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

func (*Response_GetAgent) MarshalJSONBuf added in v0.0.5 

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

func (*Response_GetAgent) MarshalTo added in v0.0.5 

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

func (*Response_GetAgent) ProtoMessage added in v0.0.5 

func (*Response_GetAgent) ProtoMessage()

func (*Response_GetAgent) ProtoSize added in v0.0.5 

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

func (*Response_GetAgent) Reset added in v0.0.5 

func (m *Response_GetAgent) Reset()

func (*Response_GetAgent) String added in v0.0.5 

func (this *Response_GetAgent) String() string

func (*Response_GetAgent) Unmarshal added in v0.0.5 

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

func (*Response_GetAgent) UnmarshalJSON added in v0.0.5 

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

func (*Response_GetAgent) UnmarshalJSONFFLexer added in v0.0.5 

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

func (*Response_GetAgent) VerboseEqual added in v0.0.5 

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

type Response_GetContainers 

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

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

func NewPopulatedResponse_GetContainers 

func NewPopulatedResponse_GetContainers(r randyAgent, easy bool) *Response_GetContainers

func (*Response_GetContainers) Descriptor 

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

func (*Response_GetContainers) Equal 

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

func (*Response_GetContainers) GetContainers 

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

func (*Response_GetContainers) GoString 

func (this *Response_GetContainers) GoString() string

func (*Response_GetContainers) Marshal 

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

func (*Response_GetContainers) MarshalJSON 

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

func (*Response_GetContainers) MarshalJSONBuf 

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

func (*Response_GetContainers) MarshalTo 

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

func (*Response_GetContainers) ProtoMessage 

func (*Response_GetContainers) ProtoMessage()

func (*Response_GetContainers) ProtoSize 

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

func (*Response_GetContainers) Reset 

func (m *Response_GetContainers) Reset()

func (*Response_GetContainers) String 

func (this *Response_GetContainers) String() string

func (*Response_GetContainers) Unmarshal 

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

func (*Response_GetContainers) UnmarshalJSON 

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

func (*Response_GetContainers) UnmarshalJSONFFLexer 

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

func (*Response_GetContainers) VerboseEqual 

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

type Response_GetContainers_Container 

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

func NewPopulatedResponse_GetContainers_Container 

func NewPopulatedResponse_GetContainers_Container(r randyAgent, easy bool) *Response_GetContainers_Container

func (*Response_GetContainers_Container) Descriptor 

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

func (*Response_GetContainers_Container) Equal 

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

func (*Response_GetContainers_Container) GetContainerID 

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

func (*Response_GetContainers_Container) GetContainerStatus 

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

func (*Response_GetContainers_Container) GetExecutorID 

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

func (*Response_GetContainers_Container) GetExecutorName 

func (m *Response_GetContainers_Container) GetExecutorName() string

func (*Response_GetContainers_Container) GetFrameworkID 

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

func (*Response_GetContainers_Container) GetResourceStatistics 

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

func (*Response_GetContainers_Container) GoString 

func (this *Response_GetContainers_Container) GoString() string

func (*Response_GetContainers_Container) Marshal 

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

func (*Response_GetContainers_Container) MarshalJSON 

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

func (*Response_GetContainers_Container) MarshalJSONBuf 

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

func (*Response_GetContainers_Container) MarshalTo 

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

func (*Response_GetContainers_Container) ProtoMessage 

func (*Response_GetContainers_Container) ProtoMessage()

func (*Response_GetContainers_Container) ProtoSize 

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

func (*Response_GetContainers_Container) Reset 

func (m *Response_GetContainers_Container) Reset()

func (*Response_GetContainers_Container) String 

func (this *Response_GetContainers_Container) String() string

func (*Response_GetContainers_Container) Unmarshal 

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

func (*Response_GetContainers_Container) UnmarshalJSON 

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

func (*Response_GetContainers_Container) UnmarshalJSONFFLexer 

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

func (*Response_GetContainers_Container) VerboseEqual 

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

type Response_GetExecutors 

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

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

func NewPopulatedResponse_GetExecutors 

func NewPopulatedResponse_GetExecutors(r randyAgent, easy bool) *Response_GetExecutors

func (*Response_GetExecutors) Descriptor 

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

func (*Response_GetExecutors) Equal 

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

func (*Response_GetExecutors) GetCompletedExecutors 

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

func (*Response_GetExecutors) GetExecutors 

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

func (*Response_GetExecutors) GoString 

func (this *Response_GetExecutors) GoString() string

func (*Response_GetExecutors) Marshal 

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

func (*Response_GetExecutors) MarshalJSON 

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

func (*Response_GetExecutors) MarshalJSONBuf 

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

func (*Response_GetExecutors) MarshalTo 

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

func (*Response_GetExecutors) ProtoMessage 

func (*Response_GetExecutors) ProtoMessage()

func (*Response_GetExecutors) ProtoSize 

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

func (*Response_GetExecutors) Reset 

func (m *Response_GetExecutors) Reset()

func (*Response_GetExecutors) String 

func (this *Response_GetExecutors) String() string

func (*Response_GetExecutors) Unmarshal 

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

func (*Response_GetExecutors) UnmarshalJSON 

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

func (*Response_GetExecutors) UnmarshalJSONFFLexer 

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

func (*Response_GetExecutors) VerboseEqual 

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

type Response_GetExecutors_Executor 

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

func NewPopulatedResponse_GetExecutors_Executor 

func NewPopulatedResponse_GetExecutors_Executor(r randyAgent, easy bool) *Response_GetExecutors_Executor

func (*Response_GetExecutors_Executor) Descriptor 

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

func (*Response_GetExecutors_Executor) Equal 

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

func (*Response_GetExecutors_Executor) GetExecutorInfo 

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

func (*Response_GetExecutors_Executor) GoString 

func (this *Response_GetExecutors_Executor) GoString() string

func (*Response_GetExecutors_Executor) Marshal 

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

func (*Response_GetExecutors_Executor) MarshalJSON 

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

func (*Response_GetExecutors_Executor) MarshalJSONBuf 

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

func (*Response_GetExecutors_Executor) MarshalTo 

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

func (*Response_GetExecutors_Executor) ProtoMessage 

func (*Response_GetExecutors_Executor) ProtoMessage()

func (*Response_GetExecutors_Executor) ProtoSize 

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

func (*Response_GetExecutors_Executor) Reset 

func (m *Response_GetExecutors_Executor) Reset()

func (*Response_GetExecutors_Executor) String 

func (this *Response_GetExecutors_Executor) String() string

func (*Response_GetExecutors_Executor) Unmarshal 

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

func (*Response_GetExecutors_Executor) UnmarshalJSON 

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

func (*Response_GetExecutors_Executor) UnmarshalJSONFFLexer 

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

func (*Response_GetExecutors_Executor) VerboseEqual 

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

type Response_GetFlags 

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

Contains the flag configuration of the agent.

func NewPopulatedResponse_GetFlags 

func NewPopulatedResponse_GetFlags(r randyAgent, easy bool) *Response_GetFlags

func (*Response_GetFlags) Descriptor 

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

func (*Response_GetFlags) Equal 

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

func (*Response_GetFlags) GetFlags 

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

func (*Response_GetFlags) GoString 

func (this *Response_GetFlags) GoString() string

func (*Response_GetFlags) Marshal 

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

func (*Response_GetFlags) MarshalJSON 

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

func (*Response_GetFlags) MarshalJSONBuf 

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

func (*Response_GetFlags) MarshalTo 

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

func (*Response_GetFlags) ProtoMessage 

func (*Response_GetFlags) ProtoMessage()

func (*Response_GetFlags) ProtoSize 

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

func (*Response_GetFlags) Reset 

func (m *Response_GetFlags) Reset()

func (*Response_GetFlags) String 

func (this *Response_GetFlags) String() string

func (*Response_GetFlags) Unmarshal 

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

func (*Response_GetFlags) UnmarshalJSON 

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

func (*Response_GetFlags) UnmarshalJSONFFLexer 

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

func (*Response_GetFlags) VerboseEqual 

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

type Response_GetFrameworks 

type Response_GetFrameworks struct {
	Frameworks          []Response_GetFrameworks_Framework `protobuf:"bytes,1,rep,name=frameworks" json:"frameworks"`
	CompletedFrameworks []Response_GetFrameworks_Framework `protobuf:"bytes,2,rep,name=completed_frameworks,json=completedFrameworks" json:"completed_frameworks"`
}

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

func NewPopulatedResponse_GetFrameworks 

func NewPopulatedResponse_GetFrameworks(r randyAgent, easy bool) *Response_GetFrameworks

func (*Response_GetFrameworks) Descriptor 

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

func (*Response_GetFrameworks) Equal 

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

func (*Response_GetFrameworks) GetCompletedFrameworks 

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

func (*Response_GetFrameworks) GetFrameworks 

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

func (*Response_GetFrameworks) GoString 

func (this *Response_GetFrameworks) GoString() string

func (*Response_GetFrameworks) Marshal 

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

func (*Response_GetFrameworks) MarshalJSON 

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

func (*Response_GetFrameworks) MarshalJSONBuf 

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

func (*Response_GetFrameworks) MarshalTo 

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

func (*Response_GetFrameworks) ProtoMessage 

func (*Response_GetFrameworks) ProtoMessage()

func (*Response_GetFrameworks) ProtoSize 

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

func (*Response_GetFrameworks) Reset 

func (m *Response_GetFrameworks) Reset()

func (*Response_GetFrameworks) String 

func (this *Response_GetFrameworks) String() string

func (*Response_GetFrameworks) Unmarshal 

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

func (*Response_GetFrameworks) UnmarshalJSON 

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

func (*Response_GetFrameworks) UnmarshalJSONFFLexer 

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

func (*Response_GetFrameworks) VerboseEqual 

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

type Response_GetFrameworks_Framework 

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

func NewPopulatedResponse_GetFrameworks_Framework 

func NewPopulatedResponse_GetFrameworks_Framework(r randyAgent, easy bool) *Response_GetFrameworks_Framework

func (*Response_GetFrameworks_Framework) Descriptor 

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

func (*Response_GetFrameworks_Framework) Equal 

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

func (*Response_GetFrameworks_Framework) GetFrameworkInfo 

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

func (*Response_GetFrameworks_Framework) GoString 

func (this *Response_GetFrameworks_Framework) GoString() string

func (*Response_GetFrameworks_Framework) Marshal 

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

func (*Response_GetFrameworks_Framework) MarshalJSON 

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

func (*Response_GetFrameworks_Framework) MarshalJSONBuf 

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

func (*Response_GetFrameworks_Framework) MarshalTo 

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

func (*Response_GetFrameworks_Framework) ProtoMessage 

func (*Response_GetFrameworks_Framework) ProtoMessage()

func (*Response_GetFrameworks_Framework) ProtoSize 

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

func (*Response_GetFrameworks_Framework) Reset 

func (m *Response_GetFrameworks_Framework) Reset()

func (*Response_GetFrameworks_Framework) String 

func (this *Response_GetFrameworks_Framework) String() string

func (*Response_GetFrameworks_Framework) Unmarshal 

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

func (*Response_GetFrameworks_Framework) UnmarshalJSON 

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

func (*Response_GetFrameworks_Framework) UnmarshalJSONFFLexer 

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

func (*Response_GetFrameworks_Framework) VerboseEqual 

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

type Response_GetHealth 

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

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

func NewPopulatedResponse_GetHealth 

func NewPopulatedResponse_GetHealth(r randyAgent, easy bool) *Response_GetHealth

func (*Response_GetHealth) Descriptor 

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

func (*Response_GetHealth) Equal 

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

func (*Response_GetHealth) GetHealthy 

func (m *Response_GetHealth) GetHealthy() bool

func (*Response_GetHealth) GoString 

func (this *Response_GetHealth) GoString() string

func (*Response_GetHealth) Marshal 

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

func (*Response_GetHealth) MarshalJSON 

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

func (*Response_GetHealth) MarshalJSONBuf 

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

func (*Response_GetHealth) MarshalTo 

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

func (*Response_GetHealth) ProtoMessage 

func (*Response_GetHealth) ProtoMessage()

func (*Response_GetHealth) ProtoSize 

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

func (*Response_GetHealth) Reset 

func (m *Response_GetHealth) Reset()

func (*Response_GetHealth) String 

func (this *Response_GetHealth) String() string

func (*Response_GetHealth) Unmarshal 

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

func (*Response_GetHealth) UnmarshalJSON 

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

func (*Response_GetHealth) UnmarshalJSONFFLexer 

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

func (*Response_GetHealth) VerboseEqual 

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

type Response_GetLoggingLevel 

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

Contains the logging level of the agent.

func NewPopulatedResponse_GetLoggingLevel 

func NewPopulatedResponse_GetLoggingLevel(r randyAgent, easy bool) *Response_GetLoggingLevel

func (*Response_GetLoggingLevel) Descriptor 

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

func (*Response_GetLoggingLevel) Equal 

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

func (*Response_GetLoggingLevel) GetLevel 

func (m *Response_GetLoggingLevel) GetLevel() uint32

func (*Response_GetLoggingLevel) GoString 

func (this *Response_GetLoggingLevel) GoString() string

func (*Response_GetLoggingLevel) Marshal 

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

func (*Response_GetLoggingLevel) MarshalJSON 

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

func (*Response_GetLoggingLevel) MarshalJSONBuf 

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

func (*Response_GetLoggingLevel) MarshalTo 

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

func (*Response_GetLoggingLevel) ProtoMessage 

func (*Response_GetLoggingLevel) ProtoMessage()

func (*Response_GetLoggingLevel) ProtoSize 

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

func (*Response_GetLoggingLevel) Reset 

func (m *Response_GetLoggingLevel) Reset()

func (*Response_GetLoggingLevel) String 

func (this *Response_GetLoggingLevel) String() string

func (*Response_GetLoggingLevel) Unmarshal 

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

func (*Response_GetLoggingLevel) UnmarshalJSON 

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

func (*Response_GetLoggingLevel) UnmarshalJSONFFLexer 

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

func (*Response_GetLoggingLevel) VerboseEqual 

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

type Response_GetMetrics 

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

Contains a snapshot of the current metrics.

func NewPopulatedResponse_GetMetrics 

func NewPopulatedResponse_GetMetrics(r randyAgent, easy bool) *Response_GetMetrics

func (*Response_GetMetrics) Descriptor 

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

func (*Response_GetMetrics) Equal 

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

func (*Response_GetMetrics) GetMetrics 

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

func (*Response_GetMetrics) GoString 

func (this *Response_GetMetrics) GoString() string

func (*Response_GetMetrics) Marshal 

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

func (*Response_GetMetrics) MarshalJSON 

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

func (*Response_GetMetrics) MarshalJSONBuf 

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

func (*Response_GetMetrics) MarshalTo 

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

func (*Response_GetMetrics) ProtoMessage 

func (*Response_GetMetrics) ProtoMessage()

func (*Response_GetMetrics) ProtoSize 

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

func (*Response_GetMetrics) Reset 

func (m *Response_GetMetrics) Reset()

func (*Response_GetMetrics) String 

func (this *Response_GetMetrics) String() string

func (*Response_GetMetrics) Unmarshal 

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

func (*Response_GetMetrics) UnmarshalJSON 

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

func (*Response_GetMetrics) UnmarshalJSONFFLexer 

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

func (*Response_GetMetrics) VerboseEqual 

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

type Response_GetState 

type Response_GetState struct {
	GetTasks      *Response_GetTasks      `protobuf:"bytes,1,opt,name=get_tasks,json=getTasks" json:"get_tasks,omitempty"`
	GetExecutors  *Response_GetExecutors  `protobuf:"bytes,2,opt,name=get_executors,json=getExecutors" json:"get_executors,omitempty"`
	GetFrameworks *Response_GetFrameworks `protobuf:"bytes,3,opt,name=get_frameworks,json=getFrameworks" json:"get_frameworks,omitempty"`
}

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

func NewPopulatedResponse_GetState 

func NewPopulatedResponse_GetState(r randyAgent, easy bool) *Response_GetState

func (*Response_GetState) Descriptor 

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

func (*Response_GetState) Equal 

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

func (*Response_GetState) GetGetExecutors 

func (m *Response_GetState) GetGetExecutors() *Response_GetExecutors

func (*Response_GetState) GetGetFrameworks 

func (m *Response_GetState) GetGetFrameworks() *Response_GetFrameworks

func (*Response_GetState) GetGetTasks 

func (m *Response_GetState) GetGetTasks() *Response_GetTasks

func (*Response_GetState) GoString 

func (this *Response_GetState) GoString() string

func (*Response_GetState) Marshal 

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

func (*Response_GetState) MarshalJSON 

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

func (*Response_GetState) MarshalJSONBuf 

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

func (*Response_GetState) MarshalTo 

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

func (*Response_GetState) ProtoMessage 

func (*Response_GetState) ProtoMessage()

func (*Response_GetState) ProtoSize 

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

func (*Response_GetState) Reset 

func (m *Response_GetState) Reset()

func (*Response_GetState) String 

func (this *Response_GetState) String() string

func (*Response_GetState) Unmarshal 

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

func (*Response_GetState) UnmarshalJSON 

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

func (*Response_GetState) UnmarshalJSONFFLexer 

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

func (*Response_GetState) VerboseEqual 

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

type Response_GetTasks 

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

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

func NewPopulatedResponse_GetTasks 

func NewPopulatedResponse_GetTasks(r randyAgent, easy bool) *Response_GetTasks

func (*Response_GetTasks) Descriptor 

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

func (*Response_GetTasks) Equal 

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

func (*Response_GetTasks) GetCompletedTasks 

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

func (*Response_GetTasks) GetLaunchedTasks 

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

func (*Response_GetTasks) GetPendingTasks 

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

func (*Response_GetTasks) GetQueuedTasks 

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

func (*Response_GetTasks) GetTerminatedTasks 

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

func (*Response_GetTasks) GoString 

func (this *Response_GetTasks) GoString() string

func (*Response_GetTasks) Marshal 

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

func (*Response_GetTasks) MarshalJSON 

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

func (*Response_GetTasks) MarshalJSONBuf 

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

func (*Response_GetTasks) MarshalTo 

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

func (*Response_GetTasks) ProtoMessage 

func (*Response_GetTasks) ProtoMessage()

func (*Response_GetTasks) ProtoSize 

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

func (*Response_GetTasks) Reset 

func (m *Response_GetTasks) Reset()

func (*Response_GetTasks) String 

func (this *Response_GetTasks) String() string

func (*Response_GetTasks) Unmarshal 

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

func (*Response_GetTasks) UnmarshalJSON 

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

func (*Response_GetTasks) UnmarshalJSONFFLexer 

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

func (*Response_GetTasks) VerboseEqual 

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

type Response_GetVersion 

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

Contains the version information of the agent.

func NewPopulatedResponse_GetVersion 

func NewPopulatedResponse_GetVersion(r randyAgent, easy bool) *Response_GetVersion

func (*Response_GetVersion) Descriptor 

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

func (*Response_GetVersion) Equal 

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

func (*Response_GetVersion) GetVersionInfo 

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

func (*Response_GetVersion) GoString 

func (this *Response_GetVersion) GoString() string

func (*Response_GetVersion) Marshal 

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

func (*Response_GetVersion) MarshalJSON 

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

func (*Response_GetVersion) MarshalJSONBuf 

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

func (*Response_GetVersion) MarshalTo 

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

func (*Response_GetVersion) ProtoMessage 

func (*Response_GetVersion) ProtoMessage()

func (*Response_GetVersion) ProtoSize 

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

func (*Response_GetVersion) Reset 

func (m *Response_GetVersion) Reset()

func (*Response_GetVersion) String 

func (this *Response_GetVersion) String() string

func (*Response_GetVersion) Unmarshal 

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

func (*Response_GetVersion) UnmarshalJSON 

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

func (*Response_GetVersion) UnmarshalJSONFFLexer 

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

func (*Response_GetVersion) VerboseEqual 

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

type Response_ListFiles 

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

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

func NewPopulatedResponse_ListFiles 

func NewPopulatedResponse_ListFiles(r randyAgent, easy bool) *Response_ListFiles

func (*Response_ListFiles) Descriptor 

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

func (*Response_ListFiles) Equal 

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

func (*Response_ListFiles) GetFileInfos 

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

func (*Response_ListFiles) GoString 

func (this *Response_ListFiles) GoString() string

func (*Response_ListFiles) Marshal 

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

func (*Response_ListFiles) MarshalJSON 

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

func (*Response_ListFiles) MarshalJSONBuf 

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

func (*Response_ListFiles) MarshalTo 

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

func (*Response_ListFiles) ProtoMessage 

func (*Response_ListFiles) ProtoMessage()

func (*Response_ListFiles) ProtoSize 

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

func (*Response_ListFiles) Reset 

func (m *Response_ListFiles) Reset()

func (*Response_ListFiles) String 

func (this *Response_ListFiles) String() string

func (*Response_ListFiles) Unmarshal 

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

func (*Response_ListFiles) UnmarshalJSON 

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

func (*Response_ListFiles) UnmarshalJSONFFLexer 

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

func (*Response_ListFiles) VerboseEqual 

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

type Response_ReadFile 

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

Contains the file data.

func NewPopulatedResponse_ReadFile 

func NewPopulatedResponse_ReadFile(r randyAgent, easy bool) *Response_ReadFile

func (*Response_ReadFile) Descriptor 

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

func (*Response_ReadFile) Equal 

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

func (*Response_ReadFile) GetData 

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

func (*Response_ReadFile) GetSize 

func (m *Response_ReadFile) GetSize() uint64

func (*Response_ReadFile) GoString 

func (this *Response_ReadFile) GoString() string

func (*Response_ReadFile) Marshal 

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

func (*Response_ReadFile) MarshalJSON 

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

func (*Response_ReadFile) MarshalJSONBuf 

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

func (*Response_ReadFile) MarshalTo 

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

func (*Response_ReadFile) ProtoMessage 

func (*Response_ReadFile) ProtoMessage()

func (*Response_ReadFile) ProtoSize 

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

func (*Response_ReadFile) Reset 

func (m *Response_ReadFile) Reset()

func (*Response_ReadFile) String 

func (this *Response_ReadFile) String() string

func (*Response_ReadFile) Unmarshal 

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

func (*Response_ReadFile) UnmarshalJSON 

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

func (*Response_ReadFile) UnmarshalJSONFFLexer 

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

func (*Response_ReadFile) VerboseEqual 

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

type Response_Type 

type Response_Type int32

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

const (
	Response_UNKNOWN               Response_Type = 0
	Response_GET_HEALTH            Response_Type = 1
	Response_GET_FLAGS             Response_Type = 2
	Response_GET_VERSION           Response_Type = 3
	Response_GET_METRICS           Response_Type = 4
	Response_GET_LOGGING_LEVEL     Response_Type = 5
	Response_LIST_FILES            Response_Type = 6
	Response_READ_FILE             Response_Type = 7
	Response_GET_STATE             Response_Type = 8
	Response_GET_CONTAINERS        Response_Type = 9
	Response_GET_FRAMEWORKS        Response_Type = 10
	Response_GET_EXECUTORS         Response_Type = 11
	Response_GET_TASKS             Response_Type = 12
	Response_GET_AGENT             Response_Type = 14
	Response_WAIT_NESTED_CONTAINER Response_Type = 13
)

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_WaitNestedContainer 

type Response_WaitNestedContainer struct {
	ExitStatus *int32 `protobuf:"varint,1,opt,name=exit_status,json=exitStatus" json:"exit_status,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) GoString 

func (this *Response_WaitNestedContainer) GoString() string

func (*Response_WaitNestedContainer) Marshal 

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

func (*Response_WaitNestedContainer) MarshalJSON 

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

func (*Response_WaitNestedContainer) MarshalJSONBuf 

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

func (*Response_WaitNestedContainer) MarshalTo 

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

func (*Response_WaitNestedContainer) ProtoMessage 

func (*Response_WaitNestedContainer) ProtoMessage()

func (*Response_WaitNestedContainer) ProtoSize 

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

func (*Response_WaitNestedContainer) Reset 

func (m *Response_WaitNestedContainer) Reset()

func (*Response_WaitNestedContainer) String 

func (this *Response_WaitNestedContainer) String() string

func (*Response_WaitNestedContainer) Unmarshal 

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

func (*Response_WaitNestedContainer) UnmarshalJSON 

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

func (*Response_WaitNestedContainer) UnmarshalJSONFFLexer 

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

func (*Response_WaitNestedContainer) VerboseEqual 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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