mesos

package
v1.19.1 Latest Latest
Warning

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

 Go to latest Published: Oct 25, 2022 License: MIT Imports: 3 Imported by: 0

Documentation

Overview

Package mesos is a generated protocol buffer package.

It is generated from these files: 

mesos.proto

It has these top-level messages: 

FrameworkID
OfferID
AgentID
TaskID
ExecutorID
ContainerID
TimeInfo
DurationInfo
Address
URL
Unavailability
MachineID
MachineInfo
FrameworkInfo
HealthCheck
KillPolicy
CommandInfo
ExecutorInfo
MasterInfo
AgentInfo
Value
Attribute
Resource
TrafficControlStatistics
IpStatistics
IcmpStatistics
TcpStatistics
UdpStatistics
SNMPStatistics
ResourceStatistics
ResourceUsage
PerfStatistics
Request
Offer
InverseOffer
TaskInfo
TaskGroupInfo
Task
TaskStatus
Filters
Environment
Parameter
Parameters
Credential
Credentials
RateLimit
RateLimits
Image
Volume
NetworkInfo
CapabilityInfo
LinuxInfo
ContainerInfo
ContainerStatus
CgroupInfo
Labels
Label
Port
Ports
DiscoveryInfo
WeightInfo
VersionInfo
Flag
Role
Metric
FileInfo

Index

Constants

View Source 
const Default_AgentInfo_Port int32 = 5051
View Source 
const Default_CommandInfo_Shell bool = true
View Source 
const Default_CommandInfo_URI_Extract bool = true
View Source 
const Default_ContainerInfo_DockerInfo_Privileged bool = false
View Source 
const Default_Filters_RefuseSeconds float64 = 5
View Source 
const Default_FrameworkInfo_Checkpoint bool = false
View Source 
const Default_FrameworkInfo_FailoverTimeout float64 = 0
View Source 
const Default_FrameworkInfo_Role string = "*"
View Source 
const Default_HealthCheck_ConsecutiveFailures uint32 = 3
View Source 
const Default_HealthCheck_DelaySeconds float64 = 15
View Source 
const Default_HealthCheck_GracePeriodSeconds float64 = 10
View Source 
const Default_HealthCheck_IntervalSeconds float64 = 10
View Source 
const Default_HealthCheck_TimeoutSeconds float64 = 20
View Source 
const Default_Image_Cached bool = true
View Source 
const Default_MasterInfo_Port uint32 = 5050
View Source 
const Default_Resource_Role string = "*"

Variables

View Source 
var CapabilityInfo_Capability_name = map[int32]string{
	0:    "UNKNOWN",
	1000: "CHOWN",
	1001: "DAC_OVERRIDE",
	1002: "DAC_READ_SEARCH",
	1003: "FOWNER",
	1004: "FSETID",
	1005: "KILL",
	1006: "SETGID",
	1007: "SETUID",
	1008: "SETPCAP",
	1009: "LINUX_IMMUTABLE",
	1010: "NET_BIND_SERVICE",
	1011: "NET_BROADCAST",
	1012: "NET_ADMIN",
	1013: "NET_RAW",
	1014: "IPC_LOCK",
	1015: "IPC_OWNER",
	1016: "SYS_MODULE",
	1017: "SYS_RAWIO",
	1018: "SYS_CHROOT",
	1019: "SYS_PTRACE",
	1020: "SYS_PACCT",
	1021: "SYS_ADMIN",
	1022: "SYS_BOOT",
	1023: "SYS_NICE",
	1024: "SYS_RESOURCE",
	1025: "SYS_TIME",
	1026: "SYS_TTY_CONFIG",
	1027: "MKNOD",
	1028: "LEASE",
	1029: "AUDIT_WRITE",
	1030: "AUDIT_CONTROL",
	1031: "SETFCAP",
	1032: "MAC_OVERRIDE",
	1033: "MAC_ADMIN",
	1034: "SYSLOG",
	1035: "WAKE_ALARM",
	1036: "BLOCK_SUSPEND",
	1037: "AUDIT_READ",
}
View Source 
var CapabilityInfo_Capability_value = map[string]int32{
	"UNKNOWN":          0,
	"CHOWN":            1000,
	"DAC_OVERRIDE":     1001,
	"DAC_READ_SEARCH":  1002,
	"FOWNER":           1003,
	"FSETID":           1004,
	"KILL":             1005,
	"SETGID":           1006,
	"SETUID":           1007,
	"SETPCAP":          1008,
	"LINUX_IMMUTABLE":  1009,
	"NET_BIND_SERVICE": 1010,
	"NET_BROADCAST":    1011,
	"NET_ADMIN":        1012,
	"NET_RAW":          1013,
	"IPC_LOCK":         1014,
	"IPC_OWNER":        1015,
	"SYS_MODULE":       1016,
	"SYS_RAWIO":        1017,
	"SYS_CHROOT":       1018,
	"SYS_PTRACE":       1019,
	"SYS_PACCT":        1020,
	"SYS_ADMIN":        1021,
	"SYS_BOOT":         1022,
	"SYS_NICE":         1023,
	"SYS_RESOURCE":     1024,
	"SYS_TIME":         1025,
	"SYS_TTY_CONFIG":   1026,
	"MKNOD":            1027,
	"LEASE":            1028,
	"AUDIT_WRITE":      1029,
	"AUDIT_CONTROL":    1030,
	"SETFCAP":          1031,
	"MAC_OVERRIDE":     1032,
	"MAC_ADMIN":        1033,
	"SYSLOG":           1034,
	"WAKE_ALARM":       1035,
	"BLOCK_SUSPEND":    1036,
	"AUDIT_READ":       1037,
}
View Source 
var ContainerInfo_DockerInfo_Network_name = map[int32]string{
	1: "HOST",
	2: "BRIDGE",
	3: "NONE",
	4: "USER",
}
View Source 
var ContainerInfo_DockerInfo_Network_value = map[string]int32{
	"HOST":   1,
	"BRIDGE": 2,
	"NONE":   3,
	"USER":   4,
}
View Source 
var ContainerInfo_Type_name = map[int32]string{
	1: "DOCKER",
	2: "MESOS",
}
View Source 
var ContainerInfo_Type_value = map[string]int32{
	"DOCKER": 1,
	"MESOS":  2,
}
View Source 
var DiscoveryInfo_Visibility_name = map[int32]string{
	0: "FRAMEWORK",
	1: "CLUSTER",
	2: "EXTERNAL",
}
View Source 
var DiscoveryInfo_Visibility_value = map[string]int32{
	"FRAMEWORK": 0,
	"CLUSTER":   1,
	"EXTERNAL":  2,
}
View Source 
var ExecutorInfo_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "DEFAULT",
	2: "CUSTOM",
}
View Source 
var ExecutorInfo_Type_value = map[string]int32{
	"UNKNOWN": 0,
	"DEFAULT": 1,
	"CUSTOM":  2,
}
View Source 
var FrameworkInfo_Capability_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "REVOCABLE_RESOURCES",
	2: "TASK_KILLING_STATE",
	3: "GPU_RESOURCES",
	4: "SHARED_RESOURCES",
	5: "PARTITION_AWARE",
}
View Source 
var FrameworkInfo_Capability_Type_value = map[string]int32{
	"UNKNOWN":             0,
	"REVOCABLE_RESOURCES": 1,
	"TASK_KILLING_STATE":  2,
	"GPU_RESOURCES":       3,
	"SHARED_RESOURCES":    4,
	"PARTITION_AWARE":     5,
}
View Source 
var HealthCheck_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "COMMAND",
	2: "HTTP",
	3: "TCP",
}
View Source 
var HealthCheck_Type_value = map[string]int32{
	"UNKNOWN": 0,
	"COMMAND": 1,
	"HTTP":    2,
	"TCP":     3,
}
View Source 
var Image_Type_name = map[int32]string{
	1: "APPC",
	2: "DOCKER",
}
View Source 
var Image_Type_value = map[string]int32{
	"APPC":   1,
	"DOCKER": 2,
}
View Source 
var MachineInfo_Mode_name = map[int32]string{
	1: "UP",
	2: "DRAINING",
	3: "DOWN",
}
View Source 
var MachineInfo_Mode_value = map[string]int32{
	"UP":       1,
	"DRAINING": 2,
	"DOWN":     3,
}
View Source 
var NetworkInfo_Protocol_name = map[int32]string{
	1: "IPv4",
	2: "IPv6",
}
View Source 
var NetworkInfo_Protocol_value = map[string]int32{
	"IPv4": 1,
	"IPv6": 2,
}
View Source 
var Offer_Operation_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "LAUNCH",
	6: "LAUNCH_GROUP",
	2: "RESERVE",
	3: "UNRESERVE",
	4: "CREATE",
	5: "DESTROY",
}
View Source 
var Offer_Operation_Type_value = map[string]int32{
	"UNKNOWN":      0,
	"LAUNCH":       1,
	"LAUNCH_GROUP": 6,
	"RESERVE":      2,
	"UNRESERVE":    3,
	"CREATE":       4,
	"DESTROY":      5,
}
View Source 
var Resource_DiskInfo_Source_Type_name = map[int32]string{
	1: "PATH",
	2: "MOUNT",
}
View Source 
var Resource_DiskInfo_Source_Type_value = map[string]int32{
	"PATH":  1,
	"MOUNT": 2,
}
View Source 
var Status_name = map[int32]string{
	1: "DRIVER_NOT_STARTED",
	2: "DRIVER_RUNNING",
	3: "DRIVER_ABORTED",
	4: "DRIVER_STOPPED",
}
View Source 
var Status_value = map[string]int32{
	"DRIVER_NOT_STARTED": 1,
	"DRIVER_RUNNING":     2,
	"DRIVER_ABORTED":     3,
	"DRIVER_STOPPED":     4,
}
View Source 
var TaskState_name = map[int32]string{
	6:  "TASK_STAGING",
	0:  "TASK_STARTING",
	1:  "TASK_RUNNING",
	8:  "TASK_KILLING",
	2:  "TASK_FINISHED",
	3:  "TASK_FAILED",
	4:  "TASK_KILLED",
	7:  "TASK_ERROR",
	5:  "TASK_LOST",
	9:  "TASK_DROPPED",
	10: "TASK_UNREACHABLE",
	11: "TASK_GONE",
	12: "TASK_GONE_BY_OPERATOR",
	13: "TASK_UNKNOWN",
}
View Source 
var TaskState_value = map[string]int32{
	"TASK_STAGING":          6,
	"TASK_STARTING":         0,
	"TASK_RUNNING":          1,
	"TASK_KILLING":          8,
	"TASK_FINISHED":         2,
	"TASK_FAILED":           3,
	"TASK_KILLED":           4,
	"TASK_ERROR":            7,
	"TASK_LOST":             5,
	"TASK_DROPPED":          9,
	"TASK_UNREACHABLE":      10,
	"TASK_GONE":             11,
	"TASK_GONE_BY_OPERATOR": 12,
	"TASK_UNKNOWN":          13,
}
View Source 
var TaskStatus_Reason_name = map[int32]string{
	0:  "REASON_COMMAND_EXECUTOR_FAILED",
	21: "REASON_CONTAINER_LAUNCH_FAILED",
	19: "REASON_CONTAINER_LIMITATION",
	20: "REASON_CONTAINER_LIMITATION_DISK",
	8:  "REASON_CONTAINER_LIMITATION_MEMORY",
	17: "REASON_CONTAINER_PREEMPTED",
	22: "REASON_CONTAINER_UPDATE_FAILED",
	23: "REASON_EXECUTOR_REGISTRATION_TIMEOUT",
	24: "REASON_EXECUTOR_REREGISTRATION_TIMEOUT",
	1:  "REASON_EXECUTOR_TERMINATED",
	2:  "REASON_EXECUTOR_UNREGISTERED",
	3:  "REASON_FRAMEWORK_REMOVED",
	4:  "REASON_GC_ERROR",
	5:  "REASON_INVALID_FRAMEWORKID",
	6:  "REASON_INVALID_OFFERS",
	7:  "REASON_MASTER_DISCONNECTED",
	9:  "REASON_RECONCILIATION",
	18: "REASON_RESOURCES_UNKNOWN",
	10: "REASON_AGENT_DISCONNECTED",
	11: "REASON_AGENT_REMOVED",
	12: "REASON_AGENT_RESTARTED",
	13: "REASON_AGENT_UNKNOWN",
	25: "REASON_TASK_GROUP_INVALID",
	26: "REASON_TASK_GROUP_UNAUTHORIZED",
	14: "REASON_TASK_INVALID",
	15: "REASON_TASK_UNAUTHORIZED",
	16: "REASON_TASK_UNKNOWN",
}
View Source 
var TaskStatus_Reason_value = map[string]int32{
	"REASON_COMMAND_EXECUTOR_FAILED":         0,
	"REASON_CONTAINER_LAUNCH_FAILED":         21,
	"REASON_CONTAINER_LIMITATION":            19,
	"REASON_CONTAINER_LIMITATION_DISK":       20,
	"REASON_CONTAINER_LIMITATION_MEMORY":     8,
	"REASON_CONTAINER_PREEMPTED":             17,
	"REASON_CONTAINER_UPDATE_FAILED":         22,
	"REASON_EXECUTOR_REGISTRATION_TIMEOUT":   23,
	"REASON_EXECUTOR_REREGISTRATION_TIMEOUT": 24,
	"REASON_EXECUTOR_TERMINATED":             1,
	"REASON_EXECUTOR_UNREGISTERED":           2,
	"REASON_FRAMEWORK_REMOVED":               3,
	"REASON_GC_ERROR":                        4,
	"REASON_INVALID_FRAMEWORKID":             5,
	"REASON_INVALID_OFFERS":                  6,
	"REASON_MASTER_DISCONNECTED":             7,
	"REASON_RECONCILIATION":                  9,
	"REASON_RESOURCES_UNKNOWN":               18,
	"REASON_AGENT_DISCONNECTED":              10,
	"REASON_AGENT_REMOVED":                   11,
	"REASON_AGENT_RESTARTED":                 12,
	"REASON_AGENT_UNKNOWN":                   13,
	"REASON_TASK_GROUP_INVALID":              25,
	"REASON_TASK_GROUP_UNAUTHORIZED":         26,
	"REASON_TASK_INVALID":                    14,
	"REASON_TASK_UNAUTHORIZED":               15,
	"REASON_TASK_UNKNOWN":                    16,
}
View Source 
var TaskStatus_Source_name = map[int32]string{
	0: "SOURCE_MASTER",
	1: "SOURCE_AGENT",
	2: "SOURCE_EXECUTOR",
}
View Source 
var TaskStatus_Source_value = map[string]int32{
	"SOURCE_MASTER":   0,
	"SOURCE_AGENT":    1,
	"SOURCE_EXECUTOR": 2,
}
View Source 
var Value_Type_name = map[int32]string{
	0: "SCALAR",
	1: "RANGES",
	2: "SET",
	3: "TEXT",
}
View Source 
var Value_Type_value = map[string]int32{
	"SCALAR": 0,
	"RANGES": 1,
	"SET":    2,
	"TEXT":   3,
}
View Source 
var Volume_Mode_name = map[int32]string{
	1: "RW",
	2: "RO",
}
View Source 
var Volume_Mode_value = map[string]int32{
	"RW": 1,
	"RO": 2,
}
View Source 
var Volume_Source_SandboxPath_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "SELF",
	2: "PARENT",
}
View Source 
var Volume_Source_SandboxPath_Type_value = map[string]int32{
	"UNKNOWN": 0,
	"SELF":    1,
	"PARENT":  2,
}
View Source 
var Volume_Source_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "DOCKER_VOLUME",
	2: "SANDBOX_PATH",
}
View Source 
var Volume_Source_Type_value = map[string]int32{
	"UNKNOWN":       0,
	"DOCKER_VOLUME": 1,
	"SANDBOX_PATH":  2,
}

Functions

This section is empty.

Types

type Address 

type Address struct {
	// May contain a hostname, IP address, or both.
	Hostname         *string `protobuf:"bytes,1,opt,name=hostname" json:"hostname,omitempty"`
	Ip               *string `protobuf:"bytes,2,opt,name=ip" json:"ip,omitempty"`
	Port             *int32  `protobuf:"varint,3,req,name=port" json:"port,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* A network address.

TODO(bmahler): Use this more widely.

func (*Address) Descriptor 

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

func (*Address) GetHostname 

func (m *Address) GetHostname() string

func (*Address) GetIp 

func (m *Address) GetIp() string

func (*Address) GetPort 

func (m *Address) GetPort() int32

func (*Address) ProtoMessage 

func (*Address) ProtoMessage()

func (*Address) Reset 

func (m *Address) Reset()

func (*Address) String 

func (m *Address) String() string

type AgentID 

type AgentID struct {
	Value            *string `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* A unique ID assigned to an agent. Currently, an agent gets a new ID whenever it (re)registers with Mesos. Framework writers shouldn't assume any binding between an agent ID and and a hostname.

func (*AgentID) Descriptor 

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

func (*AgentID) GetValue 

func (m *AgentID) GetValue() string

func (*AgentID) ProtoMessage 

func (*AgentID) ProtoMessage()

func (*AgentID) Reset 

func (m *AgentID) Reset()

func (*AgentID) String 

func (m *AgentID) String() string

type AgentInfo 

type AgentInfo struct {
	Hostname         *string      `protobuf:"bytes,1,req,name=hostname" json:"hostname,omitempty"`
	Port             *int32       `protobuf:"varint,8,opt,name=port,def=5051" json:"port,omitempty"`
	Resources        []*Resource  `protobuf:"bytes,3,rep,name=resources" json:"resources,omitempty"`
	Attributes       []*Attribute `protobuf:"bytes,5,rep,name=attributes" json:"attributes,omitempty"`
	Id               *AgentID     `protobuf:"bytes,6,opt,name=id" json:"id,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

* Describes an agent. Note that the 'id' field is only available after an agent is registered with the master, and is made available here to facilitate re-registration.

func (*AgentInfo) Descriptor 

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

func (*AgentInfo) GetAttributes 

func (m *AgentInfo) GetAttributes() []*Attribute

func (*AgentInfo) GetHostname 

func (m *AgentInfo) GetHostname() string

func (*AgentInfo) GetId 

func (m *AgentInfo) GetId() *AgentID

func (*AgentInfo) GetPort 

func (m *AgentInfo) GetPort() int32

func (*AgentInfo) GetResources 

func (m *AgentInfo) GetResources() []*Resource

func (*AgentInfo) ProtoMessage 

func (*AgentInfo) ProtoMessage()

func (*AgentInfo) Reset 

func (m *AgentInfo) Reset()

func (*AgentInfo) String 

func (m *AgentInfo) String() string

type Attribute 

type Attribute struct {
	Name             *string       `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Type             *Value_Type   `protobuf:"varint,2,req,name=type,enum=mesos.v1.Value_Type" json:"type,omitempty"`
	Scalar           *Value_Scalar `protobuf:"bytes,3,opt,name=scalar" json:"scalar,omitempty"`
	Ranges           *Value_Ranges `protobuf:"bytes,4,opt,name=ranges" json:"ranges,omitempty"`
	Set              *Value_Set    `protobuf:"bytes,6,opt,name=set" json:"set,omitempty"`
	Text             *Value_Text   `protobuf:"bytes,5,opt,name=text" json:"text,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

* Describes an attribute that can be set on a machine. For now, attributes and resources share the same "value" type, but this may change in the future and attributes may only be string based.

func (*Attribute) Descriptor 

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

func (*Attribute) GetName 

func (m *Attribute) GetName() string

func (*Attribute) GetRanges 

func (m *Attribute) GetRanges() *Value_Ranges

func (*Attribute) GetScalar 

func (m *Attribute) GetScalar() *Value_Scalar

func (*Attribute) GetSet 

func (m *Attribute) GetSet() *Value_Set

func (*Attribute) GetText 

func (m *Attribute) GetText() *Value_Text

func (*Attribute) GetType 

func (m *Attribute) GetType() Value_Type

func (*Attribute) ProtoMessage 

func (*Attribute) ProtoMessage()

func (*Attribute) Reset 

func (m *Attribute) Reset()

func (*Attribute) String 

func (m *Attribute) String() string

type CapabilityInfo 

type CapabilityInfo struct {
	Capabilities     []CapabilityInfo_Capability `protobuf:"varint,1,rep,name=capabilities,enum=mesos.v1.CapabilityInfo_Capability" json:"capabilities,omitempty"`
	XXX_unrecognized []byte                      `json:"-"`
}

* Encapsulation of `Capabilities` supported by Linux. Reference: http://linux.die.net/man/7/capabilities.

func (*CapabilityInfo) Descriptor 

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

func (*CapabilityInfo) GetCapabilities 

func (m *CapabilityInfo) GetCapabilities() []CapabilityInfo_Capability

func (*CapabilityInfo) ProtoMessage 

func (*CapabilityInfo) ProtoMessage()

func (*CapabilityInfo) Reset 

func (m *CapabilityInfo) Reset()

func (*CapabilityInfo) String 

func (m *CapabilityInfo) String() string

type CapabilityInfo_Capability 

type CapabilityInfo_Capability int32

We start the actual values at an offset(1000) because Protobuf 2 uses the first value as the default one. Separating the default value from the real first value helps to disambiguate them. This is especially valuable for backward compatibility. See: MESOS-4997. 

const (
	CapabilityInfo_UNKNOWN          CapabilityInfo_Capability = 0
	CapabilityInfo_CHOWN            CapabilityInfo_Capability = 1000
	CapabilityInfo_DAC_OVERRIDE     CapabilityInfo_Capability = 1001
	CapabilityInfo_DAC_READ_SEARCH  CapabilityInfo_Capability = 1002
	CapabilityInfo_FOWNER           CapabilityInfo_Capability = 1003
	CapabilityInfo_FSETID           CapabilityInfo_Capability = 1004
	CapabilityInfo_KILL             CapabilityInfo_Capability = 1005
	CapabilityInfo_SETGID           CapabilityInfo_Capability = 1006
	CapabilityInfo_SETUID           CapabilityInfo_Capability = 1007
	CapabilityInfo_SETPCAP          CapabilityInfo_Capability = 1008
	CapabilityInfo_LINUX_IMMUTABLE  CapabilityInfo_Capability = 1009
	CapabilityInfo_NET_BIND_SERVICE CapabilityInfo_Capability = 1010
	CapabilityInfo_NET_BROADCAST    CapabilityInfo_Capability = 1011
	CapabilityInfo_NET_ADMIN        CapabilityInfo_Capability = 1012
	CapabilityInfo_NET_RAW          CapabilityInfo_Capability = 1013
	CapabilityInfo_IPC_LOCK         CapabilityInfo_Capability = 1014
	CapabilityInfo_IPC_OWNER        CapabilityInfo_Capability = 1015
	CapabilityInfo_SYS_MODULE       CapabilityInfo_Capability = 1016
	CapabilityInfo_SYS_RAWIO        CapabilityInfo_Capability = 1017
	CapabilityInfo_SYS_CHROOT       CapabilityInfo_Capability = 1018
	CapabilityInfo_SYS_PTRACE       CapabilityInfo_Capability = 1019
	CapabilityInfo_SYS_PACCT        CapabilityInfo_Capability = 1020
	CapabilityInfo_SYS_ADMIN        CapabilityInfo_Capability = 1021
	CapabilityInfo_SYS_BOOT         CapabilityInfo_Capability = 1022
	CapabilityInfo_SYS_NICE         CapabilityInfo_Capability = 1023
	CapabilityInfo_SYS_RESOURCE     CapabilityInfo_Capability = 1024
	CapabilityInfo_SYS_TIME         CapabilityInfo_Capability = 1025
	CapabilityInfo_SYS_TTY_CONFIG   CapabilityInfo_Capability = 1026
	CapabilityInfo_MKNOD            CapabilityInfo_Capability = 1027
	CapabilityInfo_LEASE            CapabilityInfo_Capability = 1028
	CapabilityInfo_AUDIT_WRITE      CapabilityInfo_Capability = 1029
	CapabilityInfo_AUDIT_CONTROL    CapabilityInfo_Capability = 1030
	CapabilityInfo_SETFCAP          CapabilityInfo_Capability = 1031
	CapabilityInfo_MAC_OVERRIDE     CapabilityInfo_Capability = 1032
	CapabilityInfo_MAC_ADMIN        CapabilityInfo_Capability = 1033
	CapabilityInfo_SYSLOG           CapabilityInfo_Capability = 1034
	CapabilityInfo_WAKE_ALARM       CapabilityInfo_Capability = 1035
	CapabilityInfo_BLOCK_SUSPEND    CapabilityInfo_Capability = 1036
	CapabilityInfo_AUDIT_READ       CapabilityInfo_Capability = 1037
)

func (CapabilityInfo_Capability) Enum 

func (x CapabilityInfo_Capability) Enum() *CapabilityInfo_Capability

func (CapabilityInfo_Capability) EnumDescriptor 

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

func (CapabilityInfo_Capability) String 

func (x CapabilityInfo_Capability) String() string

func (*CapabilityInfo_Capability) UnmarshalJSON 

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

type CgroupInfo 

type CgroupInfo struct {
	NetCls           *CgroupInfo_NetCls `protobuf:"bytes,1,opt,name=net_cls,json=netCls" json:"net_cls,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

* Linux control group (cgroup) information.

func (*CgroupInfo) Descriptor 

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

func (*CgroupInfo) GetNetCls 

func (m *CgroupInfo) GetNetCls() *CgroupInfo_NetCls

func (*CgroupInfo) ProtoMessage 

func (*CgroupInfo) ProtoMessage()

func (*CgroupInfo) Reset 

func (m *CgroupInfo) Reset()

func (*CgroupInfo) String 

func (m *CgroupInfo) String() string

type CgroupInfo_NetCls 

type CgroupInfo_NetCls struct {
	// The 32-bit classid consists of two parts, a 16 bit major handle
	// and a 16-bit minor handle. The major and minor handle are
	// represented using the format 0xAAAABBBB, where 0xAAAA is the
	// 16-bit major handle and 0xBBBB is the 16-bit minor handle.
	Classid          *uint32 `protobuf:"varint,1,opt,name=classid" json:"classid,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Configuration of a net_cls cgroup subsystem.

func (*CgroupInfo_NetCls) Descriptor 

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

func (*CgroupInfo_NetCls) GetClassid 

func (m *CgroupInfo_NetCls) GetClassid() uint32

func (*CgroupInfo_NetCls) ProtoMessage 

func (*CgroupInfo_NetCls) ProtoMessage()

func (*CgroupInfo_NetCls) Reset 

func (m *CgroupInfo_NetCls) Reset()

func (*CgroupInfo_NetCls) String 

func (m *CgroupInfo_NetCls) String() string

type CommandInfo 

type CommandInfo struct {
	Uris        []*CommandInfo_URI `protobuf:"bytes,1,rep,name=uris" json:"uris,omitempty"`
	Environment *Environment       `protobuf:"bytes,2,opt,name=environment" json:"environment,omitempty"`
	// There are two ways to specify the command:
	// 1) If 'shell == true', the command will be launched via shell
	// 		(i.e., /bin/sh -c 'value'). The 'value' specified will be
	// 		treated as the shell command. The 'arguments' will be ignored.
	// 2) If 'shell == false', the command will be launched by passing
	// 		arguments to an executable. The 'value' specified will be
	// 		treated as the filename of the executable. The 'arguments'
	// 		will be treated as the arguments to the executable. This is
	// 		similar to how POSIX exec families launch processes (i.e.,
	// 		execlp(value, arguments(0), arguments(1), ...)).
	// NOTE: The field 'value' is changed from 'required' to 'optional'
	// in 0.20.0. It will only cause issues if a new framework is
	// connecting to an old master.
	Shell     *bool    `protobuf:"varint,6,opt,name=shell,def=1" json:"shell,omitempty"`
	Value     *string  `protobuf:"bytes,3,opt,name=value" json:"value,omitempty"`
	Arguments []string `protobuf:"bytes,7,rep,name=arguments" json:"arguments,omitempty"`
	// Enables executor and tasks to run as a specific user. If the user
	// field is present both in FrameworkInfo and here, the CommandInfo
	// user value takes precedence.
	User             *string `protobuf:"bytes,5,opt,name=user" json:"user,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Describes a command, executed via: '/bin/sh -c value'. Any URIs specified are fetched before executing the command. If the executable field for an uri is set, executable file permission is set on the downloaded file. Otherwise, if the downloaded file has a recognized archive extension (currently [compressed] tar and zip) it is extracted into the executor's working directory. This extraction can be disabled by setting `extract` to false. In addition, any environment variables are set before executing the command (so they can be used to "parameterize" your command).

func (*CommandInfo) Descriptor 

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

func (*CommandInfo) GetArguments 

func (m *CommandInfo) GetArguments() []string

func (*CommandInfo) GetEnvironment 

func (m *CommandInfo) GetEnvironment() *Environment

func (*CommandInfo) GetShell 

func (m *CommandInfo) GetShell() bool

func (*CommandInfo) GetUris 

func (m *CommandInfo) GetUris() []*CommandInfo_URI

func (*CommandInfo) GetUser 

func (m *CommandInfo) GetUser() string

func (*CommandInfo) GetValue 

func (m *CommandInfo) GetValue() string

func (*CommandInfo) ProtoMessage 

func (*CommandInfo) ProtoMessage()

func (*CommandInfo) Reset 

func (m *CommandInfo) Reset()

func (*CommandInfo) String 

func (m *CommandInfo) String() string

type CommandInfo_URI 

type CommandInfo_URI struct {
	Value      *string `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	Executable *bool   `protobuf:"varint,2,opt,name=executable" json:"executable,omitempty"`
	// In case the fetched file is recognized as an archive, extract
	// its contents into the sandbox. Note that a cached archive is
	// not copied from the cache to the sandbox in case extraction
	// originates from an archive in the cache.
	Extract *bool `protobuf:"varint,3,opt,name=extract,def=1" json:"extract,omitempty"`
	// If this field is "true", the fetcher cache will be used. If not,
	// fetching bypasses the cache and downloads directly into the
	// sandbox directory, no matter whether a suitable cache file is
	// available or not. The former directs the fetcher to download to
	// the file cache, then copy from there to the sandbox. Subsequent
	// fetch attempts with the same URI will omit downloading and copy
	// from the cache as long as the file is resident there. Cache files
	// may get evicted at any time, which then leads to renewed
	// downloading. See also "docs/fetcher.md" and
	// "docs/fetcher-cache-internals.md".
	Cache *bool `protobuf:"varint,4,opt,name=cache" json:"cache,omitempty"`
	// The fetcher's default behavior is to use the URI string's basename to
	// name the local copy. If this field is provided, the local copy will be
	// named with its value instead. If there is a directory component (which
	// must be a relative path), the local copy will be stored in that
	// subdirectory inside the sandbox.
	OutputFile       *string `protobuf:"bytes,5,opt,name=output_file,json=outputFile" json:"output_file,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CommandInfo_URI) Descriptor 

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

func (*CommandInfo_URI) GetCache 

func (m *CommandInfo_URI) GetCache() bool

func (*CommandInfo_URI) GetExecutable 

func (m *CommandInfo_URI) GetExecutable() bool

func (*CommandInfo_URI) GetExtract 

func (m *CommandInfo_URI) GetExtract() bool

func (*CommandInfo_URI) GetOutputFile 

func (m *CommandInfo_URI) GetOutputFile() string

func (*CommandInfo_URI) GetValue 

func (m *CommandInfo_URI) GetValue() string

func (*CommandInfo_URI) ProtoMessage 

func (*CommandInfo_URI) ProtoMessage()

func (*CommandInfo_URI) Reset 

func (m *CommandInfo_URI) Reset()

func (*CommandInfo_URI) String 

func (m *CommandInfo_URI) String() string

type ContainerID 

type ContainerID struct {
	Value            *string      `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	Parent           *ContainerID `protobuf:"bytes,2,opt,name=parent" json:"parent,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

* ID used to uniquely identify a container. If the `parent` is not specified, the ID is a UUID generated by the agent to uniquely identify the container of an executor run. If the `parent` field is specified, it represents a nested container.

func (*ContainerID) Descriptor 

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

func (*ContainerID) GetParent 

func (m *ContainerID) GetParent() *ContainerID

func (*ContainerID) GetValue 

func (m *ContainerID) GetValue() string

func (*ContainerID) ProtoMessage 

func (*ContainerID) ProtoMessage()

func (*ContainerID) Reset 

func (m *ContainerID) Reset()

func (*ContainerID) String 

func (m *ContainerID) String() string

type ContainerInfo 

type ContainerInfo struct {
	Type     *ContainerInfo_Type `protobuf:"varint,1,req,name=type,enum=mesos.v1.ContainerInfo_Type" json:"type,omitempty"`
	Volumes  []*Volume           `protobuf:"bytes,2,rep,name=volumes" json:"volumes,omitempty"`
	Hostname *string             `protobuf:"bytes,4,opt,name=hostname" json:"hostname,omitempty"`
	// Only one of the following *Info messages should be set to match
	// the type.
	Docker *ContainerInfo_DockerInfo `protobuf:"bytes,3,opt,name=docker" json:"docker,omitempty"`
	Mesos  *ContainerInfo_MesosInfo  `protobuf:"bytes,5,opt,name=mesos" json:"mesos,omitempty"`
	// A list of network requests. A framework can request multiple IP addresses
	// for the container.
	NetworkInfos []*NetworkInfo `protobuf:"bytes,7,rep,name=network_infos,json=networkInfos" json:"network_infos,omitempty"`
	// Linux specific information for the container.
	LinuxInfo        *LinuxInfo `protobuf:"bytes,8,opt,name=linux_info,json=linuxInfo" json:"linux_info,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

* Describes a container configuration and allows extensible configurations for different container implementations.

func (*ContainerInfo) Descriptor 

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

func (*ContainerInfo) GetDocker 

func (m *ContainerInfo) GetDocker() *ContainerInfo_DockerInfo

func (*ContainerInfo) GetHostname 

func (m *ContainerInfo) GetHostname() string

func (*ContainerInfo) GetLinuxInfo 

func (m *ContainerInfo) GetLinuxInfo() *LinuxInfo

func (*ContainerInfo) GetMesos 

func (m *ContainerInfo) GetMesos() *ContainerInfo_MesosInfo

func (*ContainerInfo) GetNetworkInfos 

func (m *ContainerInfo) GetNetworkInfos() []*NetworkInfo

func (*ContainerInfo) GetType 

func (m *ContainerInfo) GetType() ContainerInfo_Type

func (*ContainerInfo) GetVolumes 

func (m *ContainerInfo) GetVolumes() []*Volume

func (*ContainerInfo) ProtoMessage 

func (*ContainerInfo) ProtoMessage()

func (*ContainerInfo) Reset 

func (m *ContainerInfo) Reset()

func (*ContainerInfo) String 

func (m *ContainerInfo) String() string

type ContainerInfo_DockerInfo 

type ContainerInfo_DockerInfo struct {
	// The docker image that is going to be passed to the registry.
	Image        *string                                 `protobuf:"bytes,1,req,name=image" json:"image,omitempty"`
	Network      *ContainerInfo_DockerInfo_Network       `protobuf:"varint,2,opt,name=network,enum=mesos.v1.ContainerInfo_DockerInfo_Network,def=1" json:"network,omitempty"`
	PortMappings []*ContainerInfo_DockerInfo_PortMapping `protobuf:"bytes,3,rep,name=port_mappings,json=portMappings" json:"port_mappings,omitempty"`
	Privileged   *bool                                   `protobuf:"varint,4,opt,name=privileged,def=0" json:"privileged,omitempty"`
	// Allowing arbitrary parameters to be passed to docker CLI.
	// Note that anything passed to this field is not guaranteed
	// to be supported moving forward, as we might move away from
	// the docker CLI.
	Parameters []*Parameter `protobuf:"bytes,5,rep,name=parameters" json:"parameters,omitempty"`
	// With this flag set to true, the docker containerizer will
	// pull the docker image from the registry even if the image
	// is already downloaded on the agent.
	ForcePullImage *bool `protobuf:"varint,6,opt,name=force_pull_image,json=forcePullImage" json:"force_pull_image,omitempty"`
	// The name of volume driver plugin.
	VolumeDriver     *string `protobuf:"bytes,7,opt,name=volume_driver,json=volumeDriver" json:"volume_driver,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ContainerInfo_DockerInfo) Descriptor 

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

func (*ContainerInfo_DockerInfo) GetForcePullImage 

func (m *ContainerInfo_DockerInfo) GetForcePullImage() bool

func (*ContainerInfo_DockerInfo) GetImage 

func (m *ContainerInfo_DockerInfo) GetImage() string

func (*ContainerInfo_DockerInfo) GetNetwork 

func (m *ContainerInfo_DockerInfo) GetNetwork() ContainerInfo_DockerInfo_Network

func (*ContainerInfo_DockerInfo) GetParameters 

func (m *ContainerInfo_DockerInfo) GetParameters() []*Parameter

func (*ContainerInfo_DockerInfo) GetPortMappings 

func (m *ContainerInfo_DockerInfo) GetPortMappings() []*ContainerInfo_DockerInfo_PortMapping

func (*ContainerInfo_DockerInfo) GetPrivileged 

func (m *ContainerInfo_DockerInfo) GetPrivileged() bool

func (*ContainerInfo_DockerInfo) GetVolumeDriver 

func (m *ContainerInfo_DockerInfo) GetVolumeDriver() string

func (*ContainerInfo_DockerInfo) ProtoMessage 

func (*ContainerInfo_DockerInfo) ProtoMessage()

func (*ContainerInfo_DockerInfo) Reset 

func (m *ContainerInfo_DockerInfo) Reset()

func (*ContainerInfo_DockerInfo) String 

func (m *ContainerInfo_DockerInfo) String() string

type ContainerInfo_DockerInfo_Network 

type ContainerInfo_DockerInfo_Network int32

Network options. 

const (
	ContainerInfo_DockerInfo_HOST   ContainerInfo_DockerInfo_Network = 1
	ContainerInfo_DockerInfo_BRIDGE ContainerInfo_DockerInfo_Network = 2
	ContainerInfo_DockerInfo_NONE   ContainerInfo_DockerInfo_Network = 3
	ContainerInfo_DockerInfo_USER   ContainerInfo_DockerInfo_Network = 4
)
const Default_ContainerInfo_DockerInfo_Network ContainerInfo_DockerInfo_Network = ContainerInfo_DockerInfo_HOST

func (ContainerInfo_DockerInfo_Network) Enum 

func (x ContainerInfo_DockerInfo_Network) Enum() *ContainerInfo_DockerInfo_Network

func (ContainerInfo_DockerInfo_Network) EnumDescriptor 

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

func (ContainerInfo_DockerInfo_Network) String 

func (x ContainerInfo_DockerInfo_Network) String() string

func (*ContainerInfo_DockerInfo_Network) UnmarshalJSON 

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

type ContainerInfo_DockerInfo_PortMapping 

type ContainerInfo_DockerInfo_PortMapping struct {
	HostPort      *uint32 `protobuf:"varint,1,req,name=host_port,json=hostPort" json:"host_port,omitempty"`
	ContainerPort *uint32 `protobuf:"varint,2,req,name=container_port,json=containerPort" json:"container_port,omitempty"`
	// Protocol to expose as (ie: tcp, udp).
	Protocol         *string `protobuf:"bytes,3,opt,name=protocol" json:"protocol,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ContainerInfo_DockerInfo_PortMapping) Descriptor 

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

func (*ContainerInfo_DockerInfo_PortMapping) GetContainerPort 

func (m *ContainerInfo_DockerInfo_PortMapping) GetContainerPort() uint32

func (*ContainerInfo_DockerInfo_PortMapping) GetHostPort 

func (m *ContainerInfo_DockerInfo_PortMapping) GetHostPort() uint32

func (*ContainerInfo_DockerInfo_PortMapping) GetProtocol 

func (m *ContainerInfo_DockerInfo_PortMapping) GetProtocol() string

func (*ContainerInfo_DockerInfo_PortMapping) ProtoMessage 

func (*ContainerInfo_DockerInfo_PortMapping) ProtoMessage()

func (*ContainerInfo_DockerInfo_PortMapping) Reset 

func (m *ContainerInfo_DockerInfo_PortMapping) Reset()

func (*ContainerInfo_DockerInfo_PortMapping) String 

func (m *ContainerInfo_DockerInfo_PortMapping) String() string

type ContainerInfo_MesosInfo 

type ContainerInfo_MesosInfo struct {
	Image            *Image `protobuf:"bytes,1,opt,name=image" json:"image,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*ContainerInfo_MesosInfo) Descriptor 

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

func (*ContainerInfo_MesosInfo) GetImage 

func (m *ContainerInfo_MesosInfo) GetImage() *Image

func (*ContainerInfo_MesosInfo) ProtoMessage 

func (*ContainerInfo_MesosInfo) ProtoMessage()

func (*ContainerInfo_MesosInfo) Reset 

func (m *ContainerInfo_MesosInfo) Reset()

func (*ContainerInfo_MesosInfo) String 

func (m *ContainerInfo_MesosInfo) String() string

type ContainerInfo_Type 

type ContainerInfo_Type int32

All container implementation types. 

const (
	ContainerInfo_DOCKER ContainerInfo_Type = 1
	ContainerInfo_MESOS  ContainerInfo_Type = 2
)

func (ContainerInfo_Type) Enum 

func (x ContainerInfo_Type) Enum() *ContainerInfo_Type

func (ContainerInfo_Type) EnumDescriptor 

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

func (ContainerInfo_Type) String 

func (x ContainerInfo_Type) String() string

func (*ContainerInfo_Type) UnmarshalJSON 

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

type ContainerStatus 

type ContainerStatus struct {
	// This field can be reliably used to identify the container IP address.
	NetworkInfos []*NetworkInfo `protobuf:"bytes,1,rep,name=network_infos,json=networkInfos" json:"network_infos,omitempty"`
	// Information about Linux control group (cgroup).
	CgroupInfo *CgroupInfo `protobuf:"bytes,2,opt,name=cgroup_info,json=cgroupInfo" json:"cgroup_info,omitempty"`
	// Information about Executor PID.
	ExecutorPid      *uint32 `protobuf:"varint,3,opt,name=executor_pid,json=executorPid" json:"executor_pid,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Container related information that is resolved during container setup. The information is sent back to the framework as part of the TaskStatus message.

func (*ContainerStatus) Descriptor 

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

func (*ContainerStatus) GetCgroupInfo 

func (m *ContainerStatus) GetCgroupInfo() *CgroupInfo

func (*ContainerStatus) GetExecutorPid 

func (m *ContainerStatus) GetExecutorPid() uint32

func (*ContainerStatus) GetNetworkInfos 

func (m *ContainerStatus) GetNetworkInfos() []*NetworkInfo

func (*ContainerStatus) ProtoMessage 

func (*ContainerStatus) ProtoMessage()

func (*ContainerStatus) Reset 

func (m *ContainerStatus) Reset()

func (*ContainerStatus) String 

func (m *ContainerStatus) String() string

type Credential 

type Credential struct {
	Principal        *string `protobuf:"bytes,1,req,name=principal" json:"principal,omitempty"`
	Secret           *string `protobuf:"bytes,2,opt,name=secret" json:"secret,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Credential used in various places for authentication and authorization.

NOTE: A 'principal' is different from 'FrameworkInfo.user'. The former is used for authentication and authorization while the latter is used to determine the default user under which the framework's executors/tasks are run.

func (*Credential) Descriptor 

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

func (*Credential) GetPrincipal 

func (m *Credential) GetPrincipal() string

func (*Credential) GetSecret 

func (m *Credential) GetSecret() string

func (*Credential) ProtoMessage 

func (*Credential) ProtoMessage()

func (*Credential) Reset 

func (m *Credential) Reset()

func (*Credential) String 

func (m *Credential) String() string

type Credentials 

type Credentials struct {
	Credentials      []*Credential `protobuf:"bytes,1,rep,name=credentials" json:"credentials,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

* Credentials used for framework authentication, HTTP authentication (where the common 'username' and 'password' are captured as 'principal' and 'secret' respectively), etc.

func (*Credentials) Descriptor 

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

func (*Credentials) GetCredentials 

func (m *Credentials) GetCredentials() []*Credential

func (*Credentials) ProtoMessage 

func (*Credentials) ProtoMessage()

func (*Credentials) Reset 

func (m *Credentials) Reset()

func (*Credentials) String 

func (m *Credentials) String() string

type DiscoveryInfo 

type DiscoveryInfo struct {
	Visibility       *DiscoveryInfo_Visibility `protobuf:"varint,1,req,name=visibility,enum=mesos.v1.DiscoveryInfo_Visibility" json:"visibility,omitempty"`
	Name             *string                   `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	Environment      *string                   `protobuf:"bytes,3,opt,name=environment" json:"environment,omitempty"`
	Location         *string                   `protobuf:"bytes,4,opt,name=location" json:"location,omitempty"`
	Version          *string                   `protobuf:"bytes,5,opt,name=version" json:"version,omitempty"`
	Ports            *Ports                    `protobuf:"bytes,6,opt,name=ports" json:"ports,omitempty"`
	Labels           *Labels                   `protobuf:"bytes,7,opt,name=labels" json:"labels,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

* Service discovery information. The visibility field restricts discovery within a framework (FRAMEWORK), within a Mesos cluster (CLUSTER), or places no restrictions (EXTERNAL). Each port in the ports field also has an optional visibility field. If visibility is specified for a port, it overrides the default service-wide DiscoveryInfo.visibility for that port. The environment, location, and version fields provide first class support for common attributes used to differentiate between similar services. The environment may receive values such as PROD/QA/DEV, the location field may receive values like EAST-US/WEST-US/EUROPE/AMEA, and the version field may receive values like v2.0/v0.9. The exact use of these fields is up to each service discovery system.

func (*DiscoveryInfo) Descriptor 

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

func (*DiscoveryInfo) GetEnvironment 

func (m *DiscoveryInfo) GetEnvironment() string

func (*DiscoveryInfo) GetLabels 

func (m *DiscoveryInfo) GetLabels() *Labels

func (*DiscoveryInfo) GetLocation 

func (m *DiscoveryInfo) GetLocation() string

func (*DiscoveryInfo) GetName 

func (m *DiscoveryInfo) GetName() string

func (*DiscoveryInfo) GetPorts 

func (m *DiscoveryInfo) GetPorts() *Ports

func (*DiscoveryInfo) GetVersion 

func (m *DiscoveryInfo) GetVersion() string

func (*DiscoveryInfo) GetVisibility 

func (m *DiscoveryInfo) GetVisibility() DiscoveryInfo_Visibility

func (*DiscoveryInfo) ProtoMessage 

func (*DiscoveryInfo) ProtoMessage()

func (*DiscoveryInfo) Reset 

func (m *DiscoveryInfo) Reset()

func (*DiscoveryInfo) String 

func (m *DiscoveryInfo) String() string

type DiscoveryInfo_Visibility 

type DiscoveryInfo_Visibility int32
const (
	DiscoveryInfo_FRAMEWORK DiscoveryInfo_Visibility = 0
	DiscoveryInfo_CLUSTER   DiscoveryInfo_Visibility = 1
	DiscoveryInfo_EXTERNAL  DiscoveryInfo_Visibility = 2
)

func (DiscoveryInfo_Visibility) Enum 

func (x DiscoveryInfo_Visibility) Enum() *DiscoveryInfo_Visibility

func (DiscoveryInfo_Visibility) EnumDescriptor 

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

func (DiscoveryInfo_Visibility) String 

func (x DiscoveryInfo_Visibility) String() string

func (*DiscoveryInfo_Visibility) UnmarshalJSON 

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

type DurationInfo 

type DurationInfo struct {
	Nanoseconds      *int64 `protobuf:"varint,1,req,name=nanoseconds" json:"nanoseconds,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

* Represents duration in nanoseconds.

func (*DurationInfo) Descriptor 

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

func (*DurationInfo) GetNanoseconds 

func (m *DurationInfo) GetNanoseconds() int64

func (*DurationInfo) ProtoMessage 

func (*DurationInfo) ProtoMessage()

func (*DurationInfo) Reset 

func (m *DurationInfo) Reset()

func (*DurationInfo) String 

func (m *DurationInfo) String() string

type Environment 

type Environment struct {
	Variables        []*Environment_Variable `protobuf:"bytes,1,rep,name=variables" json:"variables,omitempty"`
	XXX_unrecognized []byte                  `json:"-"`
}

* Describes a collection of environment variables. This is used with CommandInfo in order to set environment variables before running a command.

func (*Environment) Descriptor 

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

func (*Environment) GetVariables 

func (m *Environment) GetVariables() []*Environment_Variable

func (*Environment) ProtoMessage 

func (*Environment) ProtoMessage()

func (*Environment) Reset 

func (m *Environment) Reset()

func (*Environment) String 

func (m *Environment) String() string

type Environment_Variable 

type Environment_Variable struct {
	Name             *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Value            *string `protobuf:"bytes,2,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Environment_Variable) Descriptor 

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

func (*Environment_Variable) GetName 

func (m *Environment_Variable) GetName() string

func (*Environment_Variable) GetValue 

func (m *Environment_Variable) GetValue() string

func (*Environment_Variable) ProtoMessage 

func (*Environment_Variable) ProtoMessage()

func (*Environment_Variable) Reset 

func (m *Environment_Variable) Reset()

func (*Environment_Variable) String 

func (m *Environment_Variable) String() string

type ExecutorID 

type ExecutorID struct {
	Value            *string `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* A framework-generated ID to distinguish an executor. Only one executor with the same ID can be active on the same agent at a time. However, reusing executor IDs is discouraged.

func (*ExecutorID) Descriptor 

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

func (*ExecutorID) GetValue 

func (m *ExecutorID) GetValue() string

func (*ExecutorID) ProtoMessage 

func (*ExecutorID) ProtoMessage()

func (*ExecutorID) Reset 

func (m *ExecutorID) Reset()

func (*ExecutorID) String 

func (m *ExecutorID) String() string

type ExecutorInfo 

type ExecutorInfo struct {
	// For backwards compatibility, if this field is not set when using `LAUNCH`
	// offer operation, Mesos will infer the type by checking if `command` is
	// set (`CUSTOM`) or unset (`DEFAULT`). `type` must be set when using
	// `LAUNCH_GROUP` offer operation.
	//
	// TODO(vinod): Add support for explicitly setting `type` to `DEFAULT `
	// in `LAUNCH` offer operation.
	Type        *ExecutorInfo_Type `protobuf:"varint,15,opt,name=type,enum=mesos.v1.ExecutorInfo_Type" json:"type,omitempty"`
	ExecutorId  *ExecutorID        `protobuf:"bytes,1,req,name=executor_id,json=executorId" json:"executor_id,omitempty"`
	FrameworkId *FrameworkID       `protobuf:"bytes,8,opt,name=framework_id,json=frameworkId" json:"framework_id,omitempty"`
	Command     *CommandInfo       `protobuf:"bytes,7,opt,name=command" json:"command,omitempty"`
	// Executor provided with a container will launch the container
	// with the executor's CommandInfo and we expect the container to
	// act as a Mesos executor.
	Container *ContainerInfo `protobuf:"bytes,11,opt,name=container" json:"container,omitempty"`
	Resources []*Resource    `protobuf:"bytes,5,rep,name=resources" json:"resources,omitempty"`
	Name      *string        `protobuf:"bytes,9,opt,name=name" json:"name,omitempty"`
	// 'source' is an identifier style string used by frameworks to
	// track the source of an executor. This is useful when it's
	// possible for different executor ids to be related semantically.
	//
	// NOTE: 'source' is exposed alongside the resource usage of the
	// executor via JSON on the agent. This allows users to import usage
	// information into a time series database for monitoring.
	//
	// This field is deprecated since 1.0. Please use labels for
	// free-form metadata instead.
	Source *string `protobuf:"bytes,10,opt,name=source" json:"source,omitempty"`
	// This field can be used to pass arbitrary bytes to an executor.
	Data []byte `protobuf:"bytes,4,opt,name=data" json:"data,omitempty"`
	// Service discovery information for the executor. It is not
	// interpreted or acted upon by Mesos. It is up to a service
	// discovery system to use this information as needed and to handle
	// executors without service discovery information.
	Discovery *DiscoveryInfo `protobuf:"bytes,12,opt,name=discovery" json:"discovery,omitempty"`
	// When shutting down an executor the agent will wait in a
	// best-effort manner for the grace period specified here
	// before forcibly destroying the container. The executor
	// must not assume that it will always be allotted the full
	// grace period, as the agent may decide to allot a shorter
	// period and failures / forcible terminations may occur.
	ShutdownGracePeriod *DurationInfo `protobuf:"bytes,13,opt,name=shutdown_grace_period,json=shutdownGracePeriod" json:"shutdown_grace_period,omitempty"`
	// Labels are free-form key value pairs which are exposed through
	// master and agent endpoints. Labels will not be interpreted or
	// acted upon by Mesos itself. As opposed to the data field, labels
	// will be kept in memory on master and agent processes. Therefore,
	// labels should be used to tag executors with lightweight metadata.
	// Labels should not contain duplicate key-value pairs.
	Labels           *Labels `protobuf:"bytes,14,opt,name=labels" json:"labels,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Describes information about an executor.

func (*ExecutorInfo) Descriptor 

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

func (*ExecutorInfo) GetCommand 

func (m *ExecutorInfo) GetCommand() *CommandInfo

func (*ExecutorInfo) GetContainer 

func (m *ExecutorInfo) GetContainer() *ContainerInfo

func (*ExecutorInfo) GetData 

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

func (*ExecutorInfo) GetDiscovery 

func (m *ExecutorInfo) GetDiscovery() *DiscoveryInfo

func (*ExecutorInfo) GetExecutorId 

func (m *ExecutorInfo) GetExecutorId() *ExecutorID

func (*ExecutorInfo) GetFrameworkId 

func (m *ExecutorInfo) GetFrameworkId() *FrameworkID

func (*ExecutorInfo) GetLabels 

func (m *ExecutorInfo) GetLabels() *Labels

func (*ExecutorInfo) GetName 

func (m *ExecutorInfo) GetName() string

func (*ExecutorInfo) GetResources 

func (m *ExecutorInfo) GetResources() []*Resource

func (*ExecutorInfo) GetShutdownGracePeriod 

func (m *ExecutorInfo) GetShutdownGracePeriod() *DurationInfo

func (*ExecutorInfo) GetSource 

func (m *ExecutorInfo) GetSource() string

func (*ExecutorInfo) GetType 

func (m *ExecutorInfo) GetType() ExecutorInfo_Type

func (*ExecutorInfo) ProtoMessage 

func (*ExecutorInfo) ProtoMessage()

func (*ExecutorInfo) Reset 

func (m *ExecutorInfo) Reset()

func (*ExecutorInfo) String 

func (m *ExecutorInfo) String() string

type ExecutorInfo_Type 

type ExecutorInfo_Type int32
const (
	ExecutorInfo_UNKNOWN ExecutorInfo_Type = 0
	// Mesos provides a simple built-in default executor that frameworks can
	// leverage to run shell commands and containers.
	//
	// NOTES:
	//
	// 1) `command` must not be set when using a default executor.
	//
	// 2) Default executor only accepts a *single* `LAUNCH` or `LAUNCH_GROUP`
	//    offer operation.
	ExecutorInfo_DEFAULT ExecutorInfo_Type = 1
	// For frameworks that need custom functionality to run tasks, a `CUSTOM`
	// executor can be used. Note that `command` must be set when using a
	// `CUSTOM` executor.
	ExecutorInfo_CUSTOM ExecutorInfo_Type = 2
)

func (ExecutorInfo_Type) Enum 

func (x ExecutorInfo_Type) Enum() *ExecutorInfo_Type

func (ExecutorInfo_Type) EnumDescriptor 

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

func (ExecutorInfo_Type) String 

func (x ExecutorInfo_Type) String() string

func (*ExecutorInfo_Type) UnmarshalJSON 

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

type FileInfo 

type FileInfo struct {
	// Absolute path to the file.
	Path *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	// Number of hard links.
	Nlink *int32 `protobuf:"varint,2,opt,name=nlink" json:"nlink,omitempty"`
	// Total size in bytes.
	Size *uint64 `protobuf:"varint,3,opt,name=size" json:"size,omitempty"`
	// Last modification time.
	Mtime *TimeInfo `protobuf:"bytes,4,opt,name=mtime" json:"mtime,omitempty"`
	// Represents a file's mode and permission bits. The bits have the same
	// definition on all systems and is portable.
	Mode *uint32 `protobuf:"varint,5,opt,name=mode" json:"mode,omitempty"`
	// User ID of owner.
	Uid *string `protobuf:"bytes,6,opt,name=uid" json:"uid,omitempty"`
	// Group ID of owner.
	Gid              *string `protobuf:"bytes,7,opt,name=gid" json:"gid,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Describes a File.

func (*FileInfo) Descriptor 

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

func (*FileInfo) GetGid 

func (m *FileInfo) GetGid() string

func (*FileInfo) GetMode 

func (m *FileInfo) GetMode() uint32

func (*FileInfo) GetMtime 

func (m *FileInfo) GetMtime() *TimeInfo
func (m *FileInfo) GetNlink() int32

func (*FileInfo) GetPath 

func (m *FileInfo) GetPath() string

func (*FileInfo) GetSize 

func (m *FileInfo) GetSize() uint64

func (*FileInfo) GetUid 

func (m *FileInfo) GetUid() string

func (*FileInfo) ProtoMessage 

func (*FileInfo) ProtoMessage()

func (*FileInfo) Reset 

func (m *FileInfo) Reset()

func (*FileInfo) String 

func (m *FileInfo) String() string

type Filters 

type Filters struct {
	// Time to consider unused resources refused. Note that all unused
	// resources will be considered refused and use the default value
	// (below) regardless of whether Filters was passed to
	// SchedulerDriver::launchTasks. You MUST pass Filters with this
	// field set to change this behavior (i.e., get another offer which
	// includes unused resources sooner or later than the default).
	RefuseSeconds    *float64 `protobuf:"fixed64,1,opt,name=refuse_seconds,json=refuseSeconds,def=5" json:"refuse_seconds,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

* Describes possible filters that can be applied to unused resources (see SchedulerDriver::launchTasks) to influence the allocator.

func (*Filters) Descriptor 

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

func (*Filters) GetRefuseSeconds 

func (m *Filters) GetRefuseSeconds() float64

func (*Filters) ProtoMessage 

func (*Filters) ProtoMessage()

func (*Filters) Reset 

func (m *Filters) Reset()

func (*Filters) String 

func (m *Filters) String() string

type Flag 

type Flag struct {
	Name             *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Value            *string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Flag consists of a name and optionally its value.

func (*Flag) Descriptor 

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

func (*Flag) GetName 

func (m *Flag) GetName() string

func (*Flag) GetValue 

func (m *Flag) GetValue() string

func (*Flag) ProtoMessage 

func (*Flag) ProtoMessage()

func (*Flag) Reset 

func (m *Flag) Reset()

func (*Flag) String 

func (m *Flag) String() string

type FrameworkID 

type FrameworkID struct {
	Value            *string `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* A unique ID assigned to a framework. A framework can reuse this ID in order to do failover (see MesosSchedulerDriver).

func (*FrameworkID) Descriptor 

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

func (*FrameworkID) GetValue 

func (m *FrameworkID) GetValue() string

func (*FrameworkID) ProtoMessage 

func (*FrameworkID) ProtoMessage()

func (*FrameworkID) Reset 

func (m *FrameworkID) Reset()

func (*FrameworkID) String 

func (m *FrameworkID) String() string

type FrameworkInfo 

type FrameworkInfo struct {
	// Used to determine the Unix user that an executor or task should be
	// launched as.
	//
	// When using the MesosSchedulerDriver, if the field is set to an
	// empty string, it will automagically set it to the current user.
	//
	// When using the HTTP Scheduler API, the user has to be set
	// explicitly.
	User *string `protobuf:"bytes,1,req,name=user" json:"user,omitempty"`
	// Name of the framework that shows up in the Mesos Web UI.
	Name *string `protobuf:"bytes,2,req,name=name" json:"name,omitempty"`
	// Note that 'id' is only available after a framework has
	// registered, however, it is included here in order to facilitate
	// scheduler failover (i.e., if it is set then the
	// MesosSchedulerDriver expects the scheduler is performing
	// failover).
	Id *FrameworkID `protobuf:"bytes,3,opt,name=id" json:"id,omitempty"`
	// The amount of time (in seconds) that the master will wait for the
	// scheduler to failover before it tears down the framework by
	// killing all its tasks/executors. This should be non-zero if a
	// framework expects to reconnect after a failure and not lose its
	// tasks/executors.
	//
	// NOTE: To avoid accidental destruction of tasks, production
	// frameworks typically set this to a large value (e.g., 1 week).
	FailoverTimeout *float64 `protobuf:"fixed64,4,opt,name=failover_timeout,json=failoverTimeout,def=0" json:"failover_timeout,omitempty"`
	// If set, agents running tasks started by this framework will write
	// the framework pid, executor pids and status updates to disk. If
	// the agent exits (e.g., due to a crash or as part of upgrading
	// Mesos), this checkpointed data allows the restarted agent to
	// reconnect to executors that were started by the old instance of
	// the agent. Enabling checkpointing improves fault tolerance, at
	// the cost of a (usually small) increase in disk I/O.
	Checkpoint *bool `protobuf:"varint,5,opt,name=checkpoint,def=0" json:"checkpoint,omitempty"`
	// Used to group frameworks for allocation decisions, depending on
	// the allocation policy being used.
	Role *string `protobuf:"bytes,6,opt,name=role,def=*" json:"role,omitempty"`
	// Used to indicate the current host from which the scheduler is
	// registered in the Mesos Web UI. If set to an empty string Mesos
	// will automagically set it to the current hostname if one is
	// available.
	Hostname *string `protobuf:"bytes,7,opt,name=hostname" json:"hostname,omitempty"`
	// This field should match the credential's principal the framework
	// uses for authentication. This field is used for framework API
	// rate limiting and dynamic reservations. It should be set even
	// if authentication is not enabled if these features are desired.
	Principal *string `protobuf:"bytes,8,opt,name=principal" json:"principal,omitempty"`
	// This field allows a framework to advertise its web UI, so that
	// the Mesos web UI can link to it. It is expected to be a full URL,
	// for example http://my-scheduler.example.com:8080/.
	WebuiUrl *string `protobuf:"bytes,9,opt,name=webui_url,json=webuiUrl" json:"webui_url,omitempty"`
	// This field allows a framework to advertise its set of
	// capabilities (e.g., ability to receive offers for revocable
	// resources).
	Capabilities []*FrameworkInfo_Capability `protobuf:"bytes,10,rep,name=capabilities" json:"capabilities,omitempty"`
	// Labels are free-form key value pairs supplied by the framework
	// scheduler (e.g., to describe additional functionality offered by
	// the framework). These labels are not interpreted by Mesos itself.
	// Labels should not contain duplicate key-value pairs.
	Labels           *Labels `protobuf:"bytes,11,opt,name=labels" json:"labels,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Describes a framework.

func (*FrameworkInfo) Descriptor 

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

func (*FrameworkInfo) GetCapabilities 

func (m *FrameworkInfo) GetCapabilities() []*FrameworkInfo_Capability

func (*FrameworkInfo) GetCheckpoint 

func (m *FrameworkInfo) GetCheckpoint() bool

func (*FrameworkInfo) GetFailoverTimeout 

func (m *FrameworkInfo) GetFailoverTimeout() float64

func (*FrameworkInfo) GetHostname 

func (m *FrameworkInfo) GetHostname() string

func (*FrameworkInfo) GetId 

func (m *FrameworkInfo) GetId() *FrameworkID

func (*FrameworkInfo) GetLabels 

func (m *FrameworkInfo) GetLabels() *Labels

func (*FrameworkInfo) GetName 

func (m *FrameworkInfo) GetName() string

func (*FrameworkInfo) GetPrincipal 

func (m *FrameworkInfo) GetPrincipal() string

func (*FrameworkInfo) GetRole 

func (m *FrameworkInfo) GetRole() string

func (*FrameworkInfo) GetUser 

func (m *FrameworkInfo) GetUser() string

func (*FrameworkInfo) GetWebuiUrl 

func (m *FrameworkInfo) GetWebuiUrl() string

func (*FrameworkInfo) ProtoMessage 

func (*FrameworkInfo) ProtoMessage()

func (*FrameworkInfo) Reset 

func (m *FrameworkInfo) Reset()

func (*FrameworkInfo) String 

func (m *FrameworkInfo) String() string

type FrameworkInfo_Capability 

type FrameworkInfo_Capability struct {
	// Enum fields should be optional, see: MESOS-4997.
	Type             *FrameworkInfo_Capability_Type `protobuf:"varint,1,opt,name=type,enum=mesos.v1.FrameworkInfo_Capability_Type" json:"type,omitempty"`
	XXX_unrecognized []byte                         `json:"-"`
}

func (*FrameworkInfo_Capability) Descriptor 

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

func (*FrameworkInfo_Capability) GetType 

func (m *FrameworkInfo_Capability) GetType() FrameworkInfo_Capability_Type

func (*FrameworkInfo_Capability) ProtoMessage 

func (*FrameworkInfo_Capability) ProtoMessage()

func (*FrameworkInfo_Capability) Reset 

func (m *FrameworkInfo_Capability) Reset()

func (*FrameworkInfo_Capability) String 

func (m *FrameworkInfo_Capability) String() string

type FrameworkInfo_Capability_Type 

type FrameworkInfo_Capability_Type int32
const (
	// This must be the first enum value in this list, to
	// ensure that if 'type' is not set, the default value
	// is UNKNOWN. This enables enum values to be added
	// in a backwards-compatible way. See: MESOS-4997.
	FrameworkInfo_Capability_UNKNOWN FrameworkInfo_Capability_Type = 0
	// Receive offers with revocable resources. See 'Resource'
	// message for details.
	FrameworkInfo_Capability_REVOCABLE_RESOURCES FrameworkInfo_Capability_Type = 1
	// Receive the TASK_KILLING TaskState when a task is being
	// killed by an executor. The executor will examine this
	// capability to determine whether it can send TASK_KILLING.
	FrameworkInfo_Capability_TASK_KILLING_STATE FrameworkInfo_Capability_Type = 2
	// Indicates whether the framework is aware of GPU resources.
	// Frameworks that are aware of GPU resources are expected to
	// avoid placing non-GPU workloads on GPU agents, in order
	// to avoid occupying a GPU agent and preventing GPU workloads
	// from running! Currently, if a framework is unaware of GPU
	// resources, it will not be offered *any* of the resources on
	// an agent with GPUs. This restriction is in place because we
	// do not have a revocation mechanism that ensures GPU workloads
	// can evict GPU agent occupants if necessary.
	//
	// TODO(bmahler): As we add revocation we can relax the
	// restriction here. See MESOS-5634 for more information.
	FrameworkInfo_Capability_GPU_RESOURCES FrameworkInfo_Capability_Type = 3
	// Receive offers with resources that are shared.
	FrameworkInfo_Capability_SHARED_RESOURCES FrameworkInfo_Capability_Type = 4
	// Indicates that (1) the framework is prepared to handle the
	// following TaskStates: TASK_UNREACHABLE, TASK_DROPPED,
	// TASK_GONE, TASK_GONE_BY_OPERATOR, and TASK_UNKNOWN, and (2)
	// the framework will assume responsibility for managing
	// partitioned tasks that reregister with the master.
	//
	// Frameworks that enable this capability can define how they
	// would like to handle partitioned tasks. Frameworks will
	// receive TASK_UNREACHABLE for tasks on agents that are
	// partitioned from the master. If/when a partitioned agent
	// reregisters, tasks on the agent that were started by
	// PARTITION_AWARE frameworks will not killed.
	//
	// Without this capability, frameworks will receive TASK_LOST
	// for tasks on partitioned agents; such tasks will be killed by
	// Mesos when the agent reregisters (unless the master has
	// failed over).
	FrameworkInfo_Capability_PARTITION_AWARE FrameworkInfo_Capability_Type = 5
)

func (FrameworkInfo_Capability_Type) Enum 

func (x FrameworkInfo_Capability_Type) Enum() *FrameworkInfo_Capability_Type

func (FrameworkInfo_Capability_Type) EnumDescriptor 

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

func (FrameworkInfo_Capability_Type) String 

func (x FrameworkInfo_Capability_Type) String() string

func (*FrameworkInfo_Capability_Type) UnmarshalJSON 

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

type HealthCheck 

type HealthCheck struct {
	// Amount of time to wait until starting the health checks.
	DelaySeconds *float64 `protobuf:"fixed64,2,opt,name=delay_seconds,json=delaySeconds,def=15" json:"delay_seconds,omitempty"`
	// Interval between health checks.
	IntervalSeconds *float64 `protobuf:"fixed64,3,opt,name=interval_seconds,json=intervalSeconds,def=10" json:"interval_seconds,omitempty"`
	// Amount of time to wait for the health check to complete.
	TimeoutSeconds *float64 `protobuf:"fixed64,4,opt,name=timeout_seconds,json=timeoutSeconds,def=20" json:"timeout_seconds,omitempty"`
	// Number of consecutive failures until signaling kill task.
	ConsecutiveFailures *uint32 `protobuf:"varint,5,opt,name=consecutive_failures,json=consecutiveFailures,def=3" json:"consecutive_failures,omitempty"`
	// Amount of time to allow failed health checks since launch.
	GracePeriodSeconds *float64 `protobuf:"fixed64,6,opt,name=grace_period_seconds,json=gracePeriodSeconds,def=10" json:"grace_period_seconds,omitempty"`
	// The type of health check.
	Type *HealthCheck_Type `protobuf:"varint,8,opt,name=type,enum=mesos.v1.HealthCheck_Type" json:"type,omitempty"`
	// Command health check.
	Command *CommandInfo `protobuf:"bytes,7,opt,name=command" json:"command,omitempty"`
	// HTTP health check.
	Http *HealthCheck_HTTPCheckInfo `protobuf:"bytes,1,opt,name=http" json:"http,omitempty"`
	// TCP health check.
	Tcp              *HealthCheck_TCPCheckInfo `protobuf:"bytes,9,opt,name=tcp" json:"tcp,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

* Describes a health check for a task or executor (or any arbitrary process/command). A type is picked by specifying one of the optional fields. Specifying more than one type is an error.

func (*HealthCheck) Descriptor 

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

func (*HealthCheck) GetCommand 

func (m *HealthCheck) GetCommand() *CommandInfo

func (*HealthCheck) GetConsecutiveFailures 

func (m *HealthCheck) GetConsecutiveFailures() uint32

func (*HealthCheck) GetDelaySeconds 

func (m *HealthCheck) GetDelaySeconds() float64

func (*HealthCheck) GetGracePeriodSeconds 

func (m *HealthCheck) GetGracePeriodSeconds() float64

func (*HealthCheck) GetHttp 

func (m *HealthCheck) GetHttp() *HealthCheck_HTTPCheckInfo

func (*HealthCheck) GetIntervalSeconds 

func (m *HealthCheck) GetIntervalSeconds() float64

func (*HealthCheck) GetTcp 

func (m *HealthCheck) GetTcp() *HealthCheck_TCPCheckInfo

func (*HealthCheck) GetTimeoutSeconds 

func (m *HealthCheck) GetTimeoutSeconds() float64

func (*HealthCheck) GetType 

func (m *HealthCheck) GetType() HealthCheck_Type

func (*HealthCheck) ProtoMessage 

func (*HealthCheck) ProtoMessage()

func (*HealthCheck) Reset 

func (m *HealthCheck) Reset()

func (*HealthCheck) String 

func (m *HealthCheck) String() string

type HealthCheck_HTTPCheckInfo 

type HealthCheck_HTTPCheckInfo struct {
	// Currently "http" and "https" are supported.
	Scheme *string `protobuf:"bytes,3,opt,name=scheme" json:"scheme,omitempty"`
	// Port to send the HTTP request.
	Port *uint32 `protobuf:"varint,1,req,name=port" json:"port,omitempty"`
	// HTTP request path.
	Path *string `protobuf:"bytes,2,opt,name=path" json:"path,omitempty"`
	// NOTE: It is up to the custom executor to interpret and act on this
	// field. Setting this field has no effect on the default executors.
	//
	// TODO(haosdent): Deprecate this field when we add better support for
	// success and possibly failure statuses, e.g. ranges of success and
	// failure statuses.
	Statuses         []uint32 `protobuf:"varint,4,rep,name=statuses" json:"statuses,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

Describes an HTTP health check. Sends a GET request to scheme://<host>:port/path. Note that <host> is not configurable and is resolved automatically, in most cases to 127.0.0.1. Default executors treat return codes between 200 and 399 as success; custom executors may employ a different strategy, e.g. leveraging the `statuses` field.

func (*HealthCheck_HTTPCheckInfo) Descriptor 

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

func (*HealthCheck_HTTPCheckInfo) GetPath 

func (m *HealthCheck_HTTPCheckInfo) GetPath() string

func (*HealthCheck_HTTPCheckInfo) GetPort 

func (m *HealthCheck_HTTPCheckInfo) GetPort() uint32

func (*HealthCheck_HTTPCheckInfo) GetScheme 

func (m *HealthCheck_HTTPCheckInfo) GetScheme() string

func (*HealthCheck_HTTPCheckInfo) GetStatuses 

func (m *HealthCheck_HTTPCheckInfo) GetStatuses() []uint32

func (*HealthCheck_HTTPCheckInfo) ProtoMessage 

func (*HealthCheck_HTTPCheckInfo) ProtoMessage()

func (*HealthCheck_HTTPCheckInfo) Reset 

func (m *HealthCheck_HTTPCheckInfo) Reset()

func (*HealthCheck_HTTPCheckInfo) String 

func (m *HealthCheck_HTTPCheckInfo) String() string

type HealthCheck_TCPCheckInfo 

type HealthCheck_TCPCheckInfo struct {
	// Port expected to be open.
	Port             *uint32 `protobuf:"varint,1,req,name=port" json:"port,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Describes a TCP health check, i.e. based on establishing a TCP connection to the specified port.

func (*HealthCheck_TCPCheckInfo) Descriptor 

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

func (*HealthCheck_TCPCheckInfo) GetPort 

func (m *HealthCheck_TCPCheckInfo) GetPort() uint32

func (*HealthCheck_TCPCheckInfo) ProtoMessage 

func (*HealthCheck_TCPCheckInfo) ProtoMessage()

func (*HealthCheck_TCPCheckInfo) Reset 

func (m *HealthCheck_TCPCheckInfo) Reset()

func (*HealthCheck_TCPCheckInfo) String 

func (m *HealthCheck_TCPCheckInfo) String() string

type HealthCheck_Type 

type HealthCheck_Type int32
const (
	HealthCheck_UNKNOWN HealthCheck_Type = 0
	HealthCheck_COMMAND HealthCheck_Type = 1
	HealthCheck_HTTP    HealthCheck_Type = 2
	HealthCheck_TCP     HealthCheck_Type = 3
)

func (HealthCheck_Type) Enum 

func (x HealthCheck_Type) Enum() *HealthCheck_Type

func (HealthCheck_Type) EnumDescriptor 

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

func (HealthCheck_Type) String 

func (x HealthCheck_Type) String() string

func (*HealthCheck_Type) UnmarshalJSON 

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

type IcmpStatistics 

type IcmpStatistics struct {
	InMsgs           *int64 `protobuf:"varint,1,opt,name=InMsgs" json:"InMsgs,omitempty"`
	InErrors         *int64 `protobuf:"varint,2,opt,name=InErrors" json:"InErrors,omitempty"`
	InCsumErrors     *int64 `protobuf:"varint,3,opt,name=InCsumErrors" json:"InCsumErrors,omitempty"`
	InDestUnreachs   *int64 `protobuf:"varint,4,opt,name=InDestUnreachs" json:"InDestUnreachs,omitempty"`
	InTimeExcds      *int64 `protobuf:"varint,5,opt,name=InTimeExcds" json:"InTimeExcds,omitempty"`
	InParmProbs      *int64 `protobuf:"varint,6,opt,name=InParmProbs" json:"InParmProbs,omitempty"`
	InSrcQuenchs     *int64 `protobuf:"varint,7,opt,name=InSrcQuenchs" json:"InSrcQuenchs,omitempty"`
	InRedirects      *int64 `protobuf:"varint,8,opt,name=InRedirects" json:"InRedirects,omitempty"`
	InEchos          *int64 `protobuf:"varint,9,opt,name=InEchos" json:"InEchos,omitempty"`
	InEchoReps       *int64 `protobuf:"varint,10,opt,name=InEchoReps" json:"InEchoReps,omitempty"`
	InTimestamps     *int64 `protobuf:"varint,11,opt,name=InTimestamps" json:"InTimestamps,omitempty"`
	InTimestampReps  *int64 `protobuf:"varint,12,opt,name=InTimestampReps" json:"InTimestampReps,omitempty"`
	InAddrMasks      *int64 `protobuf:"varint,13,opt,name=InAddrMasks" json:"InAddrMasks,omitempty"`
	InAddrMaskReps   *int64 `protobuf:"varint,14,opt,name=InAddrMaskReps" json:"InAddrMaskReps,omitempty"`
	OutMsgs          *int64 `protobuf:"varint,15,opt,name=OutMsgs" json:"OutMsgs,omitempty"`
	OutErrors        *int64 `protobuf:"varint,16,opt,name=OutErrors" json:"OutErrors,omitempty"`
	OutDestUnreachs  *int64 `protobuf:"varint,17,opt,name=OutDestUnreachs" json:"OutDestUnreachs,omitempty"`
	OutTimeExcds     *int64 `protobuf:"varint,18,opt,name=OutTimeExcds" json:"OutTimeExcds,omitempty"`
	OutParmProbs     *int64 `protobuf:"varint,19,opt,name=OutParmProbs" json:"OutParmProbs,omitempty"`
	OutSrcQuenchs    *int64 `protobuf:"varint,20,opt,name=OutSrcQuenchs" json:"OutSrcQuenchs,omitempty"`
	OutRedirects     *int64 `protobuf:"varint,21,opt,name=OutRedirects" json:"OutRedirects,omitempty"`
	OutEchos         *int64 `protobuf:"varint,22,opt,name=OutEchos" json:"OutEchos,omitempty"`
	OutEchoReps      *int64 `protobuf:"varint,23,opt,name=OutEchoReps" json:"OutEchoReps,omitempty"`
	OutTimestamps    *int64 `protobuf:"varint,24,opt,name=OutTimestamps" json:"OutTimestamps,omitempty"`
	OutTimestampReps *int64 `protobuf:"varint,25,opt,name=OutTimestampReps" json:"OutTimestampReps,omitempty"`
	OutAddrMasks     *int64 `protobuf:"varint,26,opt,name=OutAddrMasks" json:"OutAddrMasks,omitempty"`
	OutAddrMaskReps  *int64 `protobuf:"varint,27,opt,name=OutAddrMaskReps" json:"OutAddrMaskReps,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*IcmpStatistics) Descriptor 

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

func (*IcmpStatistics) GetInAddrMaskReps 

func (m *IcmpStatistics) GetInAddrMaskReps() int64

func (*IcmpStatistics) GetInAddrMasks 

func (m *IcmpStatistics) GetInAddrMasks() int64

func (*IcmpStatistics) GetInCsumErrors 

func (m *IcmpStatistics) GetInCsumErrors() int64

func (*IcmpStatistics) GetInDestUnreachs 

func (m *IcmpStatistics) GetInDestUnreachs() int64

func (*IcmpStatistics) GetInEchoReps 

func (m *IcmpStatistics) GetInEchoReps() int64

func (*IcmpStatistics) GetInEchos 

func (m *IcmpStatistics) GetInEchos() int64

func (*IcmpStatistics) GetInErrors 

func (m *IcmpStatistics) GetInErrors() int64

func (*IcmpStatistics) GetInMsgs 

func (m *IcmpStatistics) GetInMsgs() int64

func (*IcmpStatistics) GetInParmProbs 

func (m *IcmpStatistics) GetInParmProbs() int64

func (*IcmpStatistics) GetInRedirects 

func (m *IcmpStatistics) GetInRedirects() int64

func (*IcmpStatistics) GetInSrcQuenchs 

func (m *IcmpStatistics) GetInSrcQuenchs() int64

func (*IcmpStatistics) GetInTimeExcds 

func (m *IcmpStatistics) GetInTimeExcds() int64

func (*IcmpStatistics) GetInTimestampReps 

func (m *IcmpStatistics) GetInTimestampReps() int64

func (*IcmpStatistics) GetInTimestamps 

func (m *IcmpStatistics) GetInTimestamps() int64

func (*IcmpStatistics) GetOutAddrMaskReps 

func (m *IcmpStatistics) GetOutAddrMaskReps() int64

func (*IcmpStatistics) GetOutAddrMasks 

func (m *IcmpStatistics) GetOutAddrMasks() int64

func (*IcmpStatistics) GetOutDestUnreachs 

func (m *IcmpStatistics) GetOutDestUnreachs() int64

func (*IcmpStatistics) GetOutEchoReps 

func (m *IcmpStatistics) GetOutEchoReps() int64

func (*IcmpStatistics) GetOutEchos 

func (m *IcmpStatistics) GetOutEchos() int64

func (*IcmpStatistics) GetOutErrors 

func (m *IcmpStatistics) GetOutErrors() int64

func (*IcmpStatistics) GetOutMsgs 

func (m *IcmpStatistics) GetOutMsgs() int64

func (*IcmpStatistics) GetOutParmProbs 

func (m *IcmpStatistics) GetOutParmProbs() int64

func (*IcmpStatistics) GetOutRedirects 

func (m *IcmpStatistics) GetOutRedirects() int64

func (*IcmpStatistics) GetOutSrcQuenchs 

func (m *IcmpStatistics) GetOutSrcQuenchs() int64

func (*IcmpStatistics) GetOutTimeExcds 

func (m *IcmpStatistics) GetOutTimeExcds() int64

func (*IcmpStatistics) GetOutTimestampReps 

func (m *IcmpStatistics) GetOutTimestampReps() int64

func (*IcmpStatistics) GetOutTimestamps 

func (m *IcmpStatistics) GetOutTimestamps() int64

func (*IcmpStatistics) ProtoMessage 

func (*IcmpStatistics) ProtoMessage()

func (*IcmpStatistics) Reset 

func (m *IcmpStatistics) Reset()

func (*IcmpStatistics) String 

func (m *IcmpStatistics) String() string

type Image 

type Image struct {
	Type *Image_Type `protobuf:"varint,1,req,name=type,enum=mesos.v1.Image_Type" json:"type,omitempty"`
	// Only one of the following image messages should be set to match
	// the type.
	Appc   *Image_Appc   `protobuf:"bytes,2,opt,name=appc" json:"appc,omitempty"`
	Docker *Image_Docker `protobuf:"bytes,3,opt,name=docker" json:"docker,omitempty"`
	// With this flag set to false, the mesos containerizer will pull
	// the docker/appc image from the registry even if the image is
	// already downloaded on the agent.
	Cached           *bool  `protobuf:"varint,4,opt,name=cached,def=1" json:"cached,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

* Describe an image used by tasks or executors. Note that it's only for tasks or executors launched by MesosContainerizer currently.

func (*Image) Descriptor 

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

func (*Image) GetAppc 

func (m *Image) GetAppc() *Image_Appc

func (*Image) GetCached 

func (m *Image) GetCached() bool

func (*Image) GetDocker 

func (m *Image) GetDocker() *Image_Docker

func (*Image) GetType 

func (m *Image) GetType() Image_Type

func (*Image) ProtoMessage 

func (*Image) ProtoMessage()

func (*Image) Reset 

func (m *Image) Reset()

func (*Image) String 

func (m *Image) String() string

type Image_Appc 

type Image_Appc struct {
	// The name of the image.
	Name *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	// An image ID is a string of the format "hash-value", where
	// "hash" is the hash algorithm used and "value" is the hex
	// encoded string of the digest. Currently the only permitted
	// hash algorithm is sha512.
	Id *string `protobuf:"bytes,2,opt,name=id" json:"id,omitempty"`
	// Optional labels. Suggested labels: "version", "os", and "arch".
	Labels           *Labels `protobuf:"bytes,3,opt,name=labels" json:"labels,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Protobuf for specifying an Appc container image. See: https://github.com/appc/spec/blob/master/spec/aci.md

func (*Image_Appc) Descriptor 

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

func (*Image_Appc) GetId 

func (m *Image_Appc) GetId() string

func (*Image_Appc) GetLabels 

func (m *Image_Appc) GetLabels() *Labels

func (*Image_Appc) GetName 

func (m *Image_Appc) GetName() string

func (*Image_Appc) ProtoMessage 

func (*Image_Appc) ProtoMessage()

func (*Image_Appc) Reset 

func (m *Image_Appc) Reset()

func (*Image_Appc) String 

func (m *Image_Appc) String() string

type Image_Docker 

type Image_Docker struct {
	// The name of the image. Expected format:
	//   [REGISTRY_HOST[:REGISTRY_PORT]/]REPOSITORY[:TAG|@TYPE:DIGEST]
	//
	// See: https://docs.docker.com/reference/commandline/pull/
	Name *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	// Credential to authenticate with docker registry.
	// NOTE: This is not encrypted, therefore framework and operators
	// should enable SSL when passing this information.
	Credential       *Credential `protobuf:"bytes,2,opt,name=credential" json:"credential,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*Image_Docker) Descriptor 

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

func (*Image_Docker) GetCredential 

func (m *Image_Docker) GetCredential() *Credential

func (*Image_Docker) GetName 

func (m *Image_Docker) GetName() string

func (*Image_Docker) ProtoMessage 

func (*Image_Docker) ProtoMessage()

func (*Image_Docker) Reset 

func (m *Image_Docker) Reset()

func (*Image_Docker) String 

func (m *Image_Docker) String() string

type Image_Type 

type Image_Type int32
const (
	Image_APPC   Image_Type = 1
	Image_DOCKER Image_Type = 2
)

func (Image_Type) Enum 

func (x Image_Type) Enum() *Image_Type

func (Image_Type) EnumDescriptor 

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

func (Image_Type) String 

func (x Image_Type) String() string

func (*Image_Type) UnmarshalJSON 

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

type InverseOffer 

type InverseOffer struct {
	// This is the same OfferID as found in normal offers, which allows
	// re-use of some of the OfferID-only messages.
	Id *OfferID `protobuf:"bytes,1,req,name=id" json:"id,omitempty"`
	// URL for reaching the agent running on the host.  This enables some
	// optimizations as described in MESOS-3012, such as allowing the
	// scheduler driver to bypass the master and talk directly with an agent.
	Url *URL `protobuf:"bytes,2,opt,name=url" json:"url,omitempty"`
	// The framework that should release its resources.
	// If no specifics are provided (i.e. which agent), all the framework's
	// resources are requested back.
	FrameworkId *FrameworkID `protobuf:"bytes,3,req,name=framework_id,json=frameworkId" json:"framework_id,omitempty"`
	// Specified if the resources need to be released from a particular agent.
	// All the framework's resources on this agent are requested back,
	// unless further qualified by the `resources` field.
	AgentId *AgentID `protobuf:"bytes,4,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	// This InverseOffer represents a planned unavailability event in the
	// specified interval.  Any tasks running on the given framework or agent
	// may be killed when the interval arrives.  Therefore, frameworks should
	// aim to gracefully terminate tasks prior to the arrival of the interval.
	//
	// For reserved resources, the resources are expected to be returned to the
	// framework after the unavailability interval.  This is an expectation,
	// not a guarantee.  For example, if the unavailability duration is not set,
	// the resources may be removed permanently.
	//
	// For other resources, there is no guarantee that requested resources will
	// be returned after the unavailability interval.  The allocator has no
	// obligation to re-offer these resources to the prior framework after
	// the unavailability.
	Unavailability *Unavailability `protobuf:"bytes,5,req,name=unavailability" json:"unavailability,omitempty"`
	// A list of resources being requested back from the framework,
	// on the agent identified by `agent_id`.  If no resources are specified
	// then all resources are being requested back.  For the purpose of
	// maintenance, this field is always empty (maintenance always requests
	// all resources back).
	Resources        []*Resource `protobuf:"bytes,6,rep,name=resources" json:"resources,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

* A request to return some resources occupied by a framework.

func (*InverseOffer) Descriptor 

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

func (*InverseOffer) GetAgentId 

func (m *InverseOffer) GetAgentId() *AgentID

func (*InverseOffer) GetFrameworkId 

func (m *InverseOffer) GetFrameworkId() *FrameworkID

func (*InverseOffer) GetId 

func (m *InverseOffer) GetId() *OfferID

func (*InverseOffer) GetResources 

func (m *InverseOffer) GetResources() []*Resource

func (*InverseOffer) GetUnavailability 

func (m *InverseOffer) GetUnavailability() *Unavailability

func (*InverseOffer) GetUrl 

func (m *InverseOffer) GetUrl() *URL

func (*InverseOffer) ProtoMessage 

func (*InverseOffer) ProtoMessage()

func (*InverseOffer) Reset 

func (m *InverseOffer) Reset()

func (*InverseOffer) String 

func (m *InverseOffer) String() string

type IpStatistics 

type IpStatistics struct {
	Forwarding       *int64 `protobuf:"varint,1,opt,name=Forwarding" json:"Forwarding,omitempty"`
	DefaultTTL       *int64 `protobuf:"varint,2,opt,name=DefaultTTL" json:"DefaultTTL,omitempty"`
	InReceives       *int64 `protobuf:"varint,3,opt,name=InReceives" json:"InReceives,omitempty"`
	InHdrErrors      *int64 `protobuf:"varint,4,opt,name=InHdrErrors" json:"InHdrErrors,omitempty"`
	InAddrErrors     *int64 `protobuf:"varint,5,opt,name=InAddrErrors" json:"InAddrErrors,omitempty"`
	ForwDatagrams    *int64 `protobuf:"varint,6,opt,name=ForwDatagrams" json:"ForwDatagrams,omitempty"`
	InUnknownProtos  *int64 `protobuf:"varint,7,opt,name=InUnknownProtos" json:"InUnknownProtos,omitempty"`
	InDiscards       *int64 `protobuf:"varint,8,opt,name=InDiscards" json:"InDiscards,omitempty"`
	InDelivers       *int64 `protobuf:"varint,9,opt,name=InDelivers" json:"InDelivers,omitempty"`
	OutRequests      *int64 `protobuf:"varint,10,opt,name=OutRequests" json:"OutRequests,omitempty"`
	OutDiscards      *int64 `protobuf:"varint,11,opt,name=OutDiscards" json:"OutDiscards,omitempty"`
	OutNoRoutes      *int64 `protobuf:"varint,12,opt,name=OutNoRoutes" json:"OutNoRoutes,omitempty"`
	ReasmTimeout     *int64 `protobuf:"varint,13,opt,name=ReasmTimeout" json:"ReasmTimeout,omitempty"`
	ReasmReqds       *int64 `protobuf:"varint,14,opt,name=ReasmReqds" json:"ReasmReqds,omitempty"`
	ReasmOKs         *int64 `protobuf:"varint,15,opt,name=ReasmOKs" json:"ReasmOKs,omitempty"`
	ReasmFails       *int64 `protobuf:"varint,16,opt,name=ReasmFails" json:"ReasmFails,omitempty"`
	FragOKs          *int64 `protobuf:"varint,17,opt,name=FragOKs" json:"FragOKs,omitempty"`
	FragFails        *int64 `protobuf:"varint,18,opt,name=FragFails" json:"FragFails,omitempty"`
	FragCreates      *int64 `protobuf:"varint,19,opt,name=FragCreates" json:"FragCreates,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*IpStatistics) Descriptor 

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

func (*IpStatistics) GetDefaultTTL 

func (m *IpStatistics) GetDefaultTTL() int64

func (*IpStatistics) GetForwDatagrams 

func (m *IpStatistics) GetForwDatagrams() int64

func (*IpStatistics) GetForwarding 

func (m *IpStatistics) GetForwarding() int64

func (*IpStatistics) GetFragCreates 

func (m *IpStatistics) GetFragCreates() int64

func (*IpStatistics) GetFragFails 

func (m *IpStatistics) GetFragFails() int64

func (*IpStatistics) GetFragOKs 

func (m *IpStatistics) GetFragOKs() int64

func (*IpStatistics) GetInAddrErrors 

func (m *IpStatistics) GetInAddrErrors() int64

func (*IpStatistics) GetInDelivers 

func (m *IpStatistics) GetInDelivers() int64

func (*IpStatistics) GetInDiscards 

func (m *IpStatistics) GetInDiscards() int64

func (*IpStatistics) GetInHdrErrors 

func (m *IpStatistics) GetInHdrErrors() int64

func (*IpStatistics) GetInReceives 

func (m *IpStatistics) GetInReceives() int64

func (*IpStatistics) GetInUnknownProtos 

func (m *IpStatistics) GetInUnknownProtos() int64

func (*IpStatistics) GetOutDiscards 

func (m *IpStatistics) GetOutDiscards() int64

func (*IpStatistics) GetOutNoRoutes 

func (m *IpStatistics) GetOutNoRoutes() int64

func (*IpStatistics) GetOutRequests 

func (m *IpStatistics) GetOutRequests() int64

func (*IpStatistics) GetReasmFails 

func (m *IpStatistics) GetReasmFails() int64

func (*IpStatistics) GetReasmOKs 

func (m *IpStatistics) GetReasmOKs() int64

func (*IpStatistics) GetReasmReqds 

func (m *IpStatistics) GetReasmReqds() int64

func (*IpStatistics) GetReasmTimeout 

func (m *IpStatistics) GetReasmTimeout() int64

func (*IpStatistics) ProtoMessage 

func (*IpStatistics) ProtoMessage()

func (*IpStatistics) Reset 

func (m *IpStatistics) Reset()

func (*IpStatistics) String 

func (m *IpStatistics) String() string

type KillPolicy 

type KillPolicy struct {
	// The grace period specifies how long to wait before forcibly
	// killing the task. It is recommended to attempt to gracefully
	// kill the task (and send TASK_KILLING) to indicate that the
	// graceful kill is in progress. Once the grace period elapses,
	// if the task has not terminated, a forcible kill should occur.
	// The task should not assume that it will always be allotted
	// the full grace period. For example, the executor may be
	// shutdown more quickly by the agent, or failures / forcible
	// terminations may occur.
	GracePeriod      *DurationInfo `protobuf:"bytes,1,opt,name=grace_period,json=gracePeriod" json:"grace_period,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

* Describes a kill policy for a task. Currently does not express different policies (e.g. hitting HTTP endpoints), only controls how long to wait between graceful and forcible task kill: 

graceful kill --------------> forcible kill
               grace_period

Kill policies are best-effort, because machine failures / forcible terminations may occur.

NOTE: For executor-less command-based tasks, the kill is performed via sending a signal to the task process: SIGTERM for the graceful kill and SIGKILL for the forcible kill. For the docker executor-less tasks the grace period is passed to 'docker stop --time'.

func (*KillPolicy) Descriptor 

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

func (*KillPolicy) GetGracePeriod 

func (m *KillPolicy) GetGracePeriod() *DurationInfo

func (*KillPolicy) ProtoMessage 

func (*KillPolicy) ProtoMessage()

func (*KillPolicy) Reset 

func (m *KillPolicy) Reset()

func (*KillPolicy) String 

func (m *KillPolicy) String() string

type Label 

type Label struct {
	Key              *string `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Value            *string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Key, value pair used to store free form user-data.

func (*Label) Descriptor 

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

func (*Label) GetKey 

func (m *Label) GetKey() string

func (*Label) GetValue 

func (m *Label) GetValue() string

func (*Label) ProtoMessage 

func (*Label) ProtoMessage()

func (*Label) Reset 

func (m *Label) Reset()

func (*Label) String 

func (m *Label) String() string

type Labels 

type Labels struct {
	Labels           []*Label `protobuf:"bytes,1,rep,name=labels" json:"labels,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

* Collection of labels. Labels should not contain duplicate key-value pairs.

func (*Labels) Descriptor 

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

func (*Labels) GetLabels 

func (m *Labels) GetLabels() []*Label

func (*Labels) ProtoMessage 

func (*Labels) ProtoMessage()

func (*Labels) Reset 

func (m *Labels) Reset()

func (*Labels) String 

func (m *Labels) String() string

type LinuxInfo 

type LinuxInfo struct {
	// Represents the capability whitelist.
	CapabilityInfo   *CapabilityInfo `protobuf:"bytes,1,opt,name=capability_info,json=capabilityInfo" json:"capability_info,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

* Encapsulation for Linux specific configuration. E.g, capabilities, limits etc.

func (*LinuxInfo) Descriptor 

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

func (*LinuxInfo) GetCapabilityInfo 

func (m *LinuxInfo) GetCapabilityInfo() *CapabilityInfo

func (*LinuxInfo) ProtoMessage 

func (*LinuxInfo) ProtoMessage()

func (*LinuxInfo) Reset 

func (m *LinuxInfo) Reset()

func (*LinuxInfo) String 

func (m *LinuxInfo) String() string

type MachineID 

type MachineID struct {
	Hostname         *string `protobuf:"bytes,1,opt,name=hostname" json:"hostname,omitempty"`
	Ip               *string `protobuf:"bytes,2,opt,name=ip" json:"ip,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Represents a single machine, which may hold one or more agents.

NOTE: In order to match an agent to a machine, both the `hostname` and `ip` must match the values advertised by the agent to the master. Hostname is not case-sensitive.

func (*MachineID) Descriptor 

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

func (*MachineID) GetHostname 

func (m *MachineID) GetHostname() string

func (*MachineID) GetIp 

func (m *MachineID) GetIp() string

func (*MachineID) ProtoMessage 

func (*MachineID) ProtoMessage()

func (*MachineID) Reset 

func (m *MachineID) Reset()

func (*MachineID) String 

func (m *MachineID) String() string

type MachineInfo 

type MachineInfo struct {
	Id   *MachineID        `protobuf:"bytes,1,req,name=id" json:"id,omitempty"`
	Mode *MachineInfo_Mode `protobuf:"varint,2,opt,name=mode,enum=mesos.v1.MachineInfo_Mode" json:"mode,omitempty"`
	// Signifies that the machine may be unavailable during the given interval.
	// See comments in `Unavailability` and for the `unavailability` fields
	// in `Offer` and `InverseOffer` for more information.
	Unavailability   *Unavailability `protobuf:"bytes,3,opt,name=unavailability" json:"unavailability,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

* Holds information about a single machine, its `mode`, and any other relevant information which may affect the behavior of the machine.

func (*MachineInfo) Descriptor 

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

func (*MachineInfo) GetId 

func (m *MachineInfo) GetId() *MachineID

func (*MachineInfo) GetMode 

func (m *MachineInfo) GetMode() MachineInfo_Mode

func (*MachineInfo) GetUnavailability 

func (m *MachineInfo) GetUnavailability() *Unavailability

func (*MachineInfo) ProtoMessage 

func (*MachineInfo) ProtoMessage()

func (*MachineInfo) Reset 

func (m *MachineInfo) Reset()

func (*MachineInfo) String 

func (m *MachineInfo) String() string

type MachineInfo_Mode 

type MachineInfo_Mode int32

Describes the several states that a machine can be in. A `Mode` applies to a machine and to all associated agents on the machine. 

const (
	// In this mode, a machine is behaving normally;
	// offering resources, executing tasks, etc.
	MachineInfo_UP MachineInfo_Mode = 1
	// In this mode, all agents on the machine are expected to cooperate with
	// frameworks to drain resources.  In general, draining is done ahead of
	// a pending `unavailability`.  The resources should be drained so as to
	// maximize utilization prior to the maintenance but without knowingly
	// violating the frameworks' requirements.
	MachineInfo_DRAINING MachineInfo_Mode = 2
	// In this mode, a machine is not running any tasks and will not offer
	// any of its resources.  Agents on the machine will not be allowed to
	// register with the master.
	MachineInfo_DOWN MachineInfo_Mode = 3
)

func (MachineInfo_Mode) Enum 

func (x MachineInfo_Mode) Enum() *MachineInfo_Mode

func (MachineInfo_Mode) EnumDescriptor 

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

func (MachineInfo_Mode) String 

func (x MachineInfo_Mode) String() string

func (*MachineInfo_Mode) UnmarshalJSON 

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

type MasterInfo 

type MasterInfo struct {
	Id *string `protobuf:"bytes,1,req,name=id" json:"id,omitempty"`
	// The IP address (only IPv4) as a packed 4-bytes integer,
	// stored in network order.  Deprecated, use `address.ip` instead.
	Ip *uint32 `protobuf:"varint,2,req,name=ip" json:"ip,omitempty"`
	// The TCP port the Master is listening on for incoming
	// HTTP requests; deprecated, use `address.port` instead.
	Port *uint32 `protobuf:"varint,3,req,name=port,def=5050" json:"port,omitempty"`
	// In the default implementation, this will contain information
	// about both the IP address, port and Master name; it should really
	// not be relied upon by external tooling/frameworks and be
	// considered an "internal" implementation field.
	Pid *string `protobuf:"bytes,4,opt,name=pid" json:"pid,omitempty"`
	// The server's hostname, if available; it may be unreliable
	// in environments where the DNS configuration does not resolve
	// internal hostnames (eg, some public cloud providers).
	// Deprecated, use `address.hostname` instead.
	Hostname *string `protobuf:"bytes,5,opt,name=hostname" json:"hostname,omitempty"`
	// The running Master version, as a string; taken from the
	// generated "master/version.hpp".
	Version *string `protobuf:"bytes,6,opt,name=version" json:"version,omitempty"`
	// The full IP address (supports both IPv4 and IPv6 formats)
	// and supersedes the use of `ip`, `port` and `hostname`.
	// Since Mesos 0.24.
	Address          *Address `protobuf:"bytes,7,opt,name=address" json:"address,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

* Describes a master. This will probably have more fields in the future which might be used, for example, to link a framework webui to a master webui.

func (*MasterInfo) Descriptor 

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

func (*MasterInfo) GetAddress 

func (m *MasterInfo) GetAddress() *Address

func (*MasterInfo) GetHostname 

func (m *MasterInfo) GetHostname() string

func (*MasterInfo) GetId 

func (m *MasterInfo) GetId() string

func (*MasterInfo) GetIp 

func (m *MasterInfo) GetIp() uint32

func (*MasterInfo) GetPid 

func (m *MasterInfo) GetPid() string

func (*MasterInfo) GetPort 

func (m *MasterInfo) GetPort() uint32

func (*MasterInfo) GetVersion 

func (m *MasterInfo) GetVersion() string

func (*MasterInfo) ProtoMessage 

func (*MasterInfo) ProtoMessage()

func (*MasterInfo) Reset 

func (m *MasterInfo) Reset()

func (*MasterInfo) String 

func (m *MasterInfo) String() string

type Metric 

type Metric struct {
	Name             *string  `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Value            *float64 `protobuf:"fixed64,2,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

* Metric consists of a name and optionally its value.

func (*Metric) Descriptor 

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

func (*Metric) GetName 

func (m *Metric) GetName() string

func (*Metric) GetValue 

func (m *Metric) GetValue() float64

func (*Metric) ProtoMessage 

func (*Metric) ProtoMessage()

func (*Metric) Reset 

func (m *Metric) Reset()

func (*Metric) String 

func (m *Metric) String() string

type NetworkInfo 

type NetworkInfo struct {
	// When included in a ContainerInfo, each of these represent a
	// request for an IP address. Each request can specify an explicit address
	// or the IP protocol to use.
	//
	// When included in a TaskStatus message, these inform the framework
	// scheduler about the IP addresses that are bound to the container
	// interface. When there are no custom network isolator modules installed,
	// this field is filled in automatically with the Agent IP address.
	IpAddresses []*NetworkInfo_IPAddress `protobuf:"bytes,5,rep,name=ip_addresses,json=ipAddresses" json:"ip_addresses,omitempty"`
	// Name of the network which will be used by network isolator to determine
	// the network that the container joins. It's up to the network isolator
	// to decide how to interpret this field.
	Name *string `protobuf:"bytes,6,opt,name=name" json:"name,omitempty"`
	// A group is the name given to a set of logically-related interfaces that
	// are allowed to communicate among themselves. Network traffic is allowed
	// between two container interfaces that share at least one network group.
	// For example, one might want to create separate groups for isolating dev,
	// testing, qa and prod deployment environments.
	Groups []string `protobuf:"bytes,3,rep,name=groups" json:"groups,omitempty"`
	// To tag certain metadata to be used by Isolator/IPAM, e.g., rack, etc.
	Labels           *Labels                    `protobuf:"bytes,4,opt,name=labels" json:"labels,omitempty"`
	PortMappings     []*NetworkInfo_PortMapping `protobuf:"bytes,7,rep,name=port_mappings,json=portMappings" json:"port_mappings,omitempty"`
	XXX_unrecognized []byte                     `json:"-"`
}

* Describes a network request from a framework as well as network resolution provided by Mesos.

A framework may request the network isolator on the Agent to isolate the container in a network namespace and create a virtual network interface. The `NetworkInfo` message describes the properties of that virtual interface, including the IP addresses and network isolation policy (network group membership).

The NetworkInfo message is not interpreted by the Master or Agent and is intended to be used by Agent and Master modules implementing network isolation. If the modules are missing, the message is simply ignored. In future, the task launch will fail if there is no module providing the network isolation capabilities (MESOS-3390).

An executor, Agent, or an Agent module may append NetworkInfos inside TaskStatus::container_status to provide information such as the container IP address and isolation groups.

func (*NetworkInfo) Descriptor 

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

func (*NetworkInfo) GetGroups 

func (m *NetworkInfo) GetGroups() []string

func (*NetworkInfo) GetIpAddresses 

func (m *NetworkInfo) GetIpAddresses() []*NetworkInfo_IPAddress

func (*NetworkInfo) GetLabels 

func (m *NetworkInfo) GetLabels() *Labels

func (*NetworkInfo) GetName 

func (m *NetworkInfo) GetName() string

func (*NetworkInfo) GetPortMappings 

func (m *NetworkInfo) GetPortMappings() []*NetworkInfo_PortMapping

func (*NetworkInfo) ProtoMessage 

func (*NetworkInfo) ProtoMessage()

func (*NetworkInfo) Reset 

func (m *NetworkInfo) Reset()

func (*NetworkInfo) String 

func (m *NetworkInfo) String() string

type NetworkInfo_IPAddress 

type NetworkInfo_IPAddress struct {
	// Specify IP address requirement. Set protocol to the desired value to
	// request the network isolator on the Agent to assign an IP address to the
	// container being launched. If a specific IP address is specified in
	// ip_address, this field should not be set.
	Protocol *NetworkInfo_Protocol `protobuf:"varint,1,opt,name=protocol,enum=mesos.v1.NetworkInfo_Protocol" json:"protocol,omitempty"`
	// Statically assigned IP provided by the Framework. This IP will be
	// assigned to the container by the network isolator module on the Agent.
	// This field should not be used with the protocol field above.
	//
	// If an explicit address is requested but is unavailable, the network
	// isolator should fail the task.
	IpAddress        *string `protobuf:"bytes,2,opt,name=ip_address,json=ipAddress" json:"ip_address,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Specifies a request for an IP address, or reports the assigned container IP address.

Users can request an automatically assigned IP (for example, via an IPAM service) or a specific IP by adding a NetworkInfo to the ContainerInfo for a task. On a request, specifying neither `protocol` nor `ip_address` means that any available address may be assigned.

func (*NetworkInfo_IPAddress) Descriptor 

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

func (*NetworkInfo_IPAddress) GetIpAddress 

func (m *NetworkInfo_IPAddress) GetIpAddress() string

func (*NetworkInfo_IPAddress) GetProtocol 

func (m *NetworkInfo_IPAddress) GetProtocol() NetworkInfo_Protocol

func (*NetworkInfo_IPAddress) ProtoMessage 

func (*NetworkInfo_IPAddress) ProtoMessage()

func (*NetworkInfo_IPAddress) Reset 

func (m *NetworkInfo_IPAddress) Reset()

func (*NetworkInfo_IPAddress) String 

func (m *NetworkInfo_IPAddress) String() string

type NetworkInfo_PortMapping 

type NetworkInfo_PortMapping struct {
	HostPort      *uint32 `protobuf:"varint,1,req,name=host_port,json=hostPort" json:"host_port,omitempty"`
	ContainerPort *uint32 `protobuf:"varint,2,req,name=container_port,json=containerPort" json:"container_port,omitempty"`
	// Protocol to expose as (ie: tcp, udp).
	Protocol         *string `protobuf:"bytes,3,opt,name=protocol" json:"protocol,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Specifies a port mapping request for the task on this network.

func (*NetworkInfo_PortMapping) Descriptor 

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

func (*NetworkInfo_PortMapping) GetContainerPort 

func (m *NetworkInfo_PortMapping) GetContainerPort() uint32

func (*NetworkInfo_PortMapping) GetHostPort 

func (m *NetworkInfo_PortMapping) GetHostPort() uint32

func (*NetworkInfo_PortMapping) GetProtocol 

func (m *NetworkInfo_PortMapping) GetProtocol() string

func (*NetworkInfo_PortMapping) ProtoMessage 

func (*NetworkInfo_PortMapping) ProtoMessage()

func (*NetworkInfo_PortMapping) Reset 

func (m *NetworkInfo_PortMapping) Reset()

func (*NetworkInfo_PortMapping) String 

func (m *NetworkInfo_PortMapping) String() string

type NetworkInfo_Protocol 

type NetworkInfo_Protocol int32
const (
	NetworkInfo_IPv4 NetworkInfo_Protocol = 1
	NetworkInfo_IPv6 NetworkInfo_Protocol = 2
)

func (NetworkInfo_Protocol) Enum 

func (x NetworkInfo_Protocol) Enum() *NetworkInfo_Protocol

func (NetworkInfo_Protocol) EnumDescriptor 

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

func (NetworkInfo_Protocol) String 

func (x NetworkInfo_Protocol) String() string

func (*NetworkInfo_Protocol) UnmarshalJSON 

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

type Offer 

type Offer struct {
	Id          *OfferID     `protobuf:"bytes,1,req,name=id" json:"id,omitempty"`
	FrameworkId *FrameworkID `protobuf:"bytes,2,req,name=framework_id,json=frameworkId" json:"framework_id,omitempty"`
	AgentId     *AgentID     `protobuf:"bytes,3,req,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	Hostname    *string      `protobuf:"bytes,4,req,name=hostname" json:"hostname,omitempty"`
	// URL for reaching the agent running on the host.
	Url         *URL          `protobuf:"bytes,8,opt,name=url" json:"url,omitempty"`
	Resources   []*Resource   `protobuf:"bytes,5,rep,name=resources" json:"resources,omitempty"`
	Attributes  []*Attribute  `protobuf:"bytes,7,rep,name=attributes" json:"attributes,omitempty"`
	ExecutorIds []*ExecutorID `protobuf:"bytes,6,rep,name=executor_ids,json=executorIds" json:"executor_ids,omitempty"`
	// Signifies that the resources in this Offer may be unavailable during
	// the given interval.  Any tasks launched using these resources may be
	// killed when the interval arrives.  For example, these resources may be
	// part of a planned maintenance schedule.
	//
	// This field only provides information about a planned unavailability.
	// The unavailability interval may not necessarily start at exactly this
	// interval, nor last for exactly the duration of this interval.
	// The unavailability may also be forever!  See comments in
	// `Unavailability` for more details.
	Unavailability   *Unavailability `protobuf:"bytes,9,opt,name=unavailability" json:"unavailability,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

* Describes some resources available on an agent. An offer only contains resources from a single agent.

func (*Offer) Descriptor 

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

func (*Offer) GetAgentId 

func (m *Offer) GetAgentId() *AgentID

func (*Offer) GetAttributes 

func (m *Offer) GetAttributes() []*Attribute

func (*Offer) GetExecutorIds 

func (m *Offer) GetExecutorIds() []*ExecutorID

func (*Offer) GetFrameworkId 

func (m *Offer) GetFrameworkId() *FrameworkID

func (*Offer) GetHostname 

func (m *Offer) GetHostname() string

func (*Offer) GetId 

func (m *Offer) GetId() *OfferID

func (*Offer) GetResources 

func (m *Offer) GetResources() []*Resource

func (*Offer) GetUnavailability 

func (m *Offer) GetUnavailability() *Unavailability

func (*Offer) GetUrl 

func (m *Offer) GetUrl() *URL

func (*Offer) ProtoMessage 

func (*Offer) ProtoMessage()

func (*Offer) Reset 

func (m *Offer) Reset()

func (*Offer) String 

func (m *Offer) String() string

type OfferID 

type OfferID struct {
	Value            *string `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* A unique ID assigned to an offer.

func (*OfferID) Descriptor 

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

func (*OfferID) GetValue 

func (m *OfferID) GetValue() string

func (*OfferID) ProtoMessage 

func (*OfferID) ProtoMessage()

func (*OfferID) Reset 

func (m *OfferID) Reset()

func (*OfferID) String 

func (m *OfferID) String() string

type Offer_Operation 

type Offer_Operation struct {
	Type             *Offer_Operation_Type        `protobuf:"varint,1,opt,name=type,enum=mesos.v1.Offer_Operation_Type" json:"type,omitempty"`
	Launch           *Offer_Operation_Launch      `protobuf:"bytes,2,opt,name=launch" json:"launch,omitempty"`
	LaunchGroup      *Offer_Operation_LaunchGroup `protobuf:"bytes,7,opt,name=launch_group,json=launchGroup" json:"launch_group,omitempty"`
	Reserve          *Offer_Operation_Reserve     `protobuf:"bytes,3,opt,name=reserve" json:"reserve,omitempty"`
	Unreserve        *Offer_Operation_Unreserve   `protobuf:"bytes,4,opt,name=unreserve" json:"unreserve,omitempty"`
	Create           *Offer_Operation_Create      `protobuf:"bytes,5,opt,name=create" json:"create,omitempty"`
	Destroy          *Offer_Operation_Destroy     `protobuf:"bytes,6,opt,name=destroy" json:"destroy,omitempty"`
	XXX_unrecognized []byte                       `json:"-"`
}

Defines an operation that can be performed against offers.

func (*Offer_Operation) Descriptor 

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

func (*Offer_Operation) GetCreate 

func (m *Offer_Operation) GetCreate() *Offer_Operation_Create

func (*Offer_Operation) GetDestroy 

func (m *Offer_Operation) GetDestroy() *Offer_Operation_Destroy

func (*Offer_Operation) GetLaunch 

func (m *Offer_Operation) GetLaunch() *Offer_Operation_Launch

func (*Offer_Operation) GetLaunchGroup 

func (m *Offer_Operation) GetLaunchGroup() *Offer_Operation_LaunchGroup

func (*Offer_Operation) GetReserve 

func (m *Offer_Operation) GetReserve() *Offer_Operation_Reserve

func (*Offer_Operation) GetType 

func (m *Offer_Operation) GetType() Offer_Operation_Type

func (*Offer_Operation) GetUnreserve 

func (m *Offer_Operation) GetUnreserve() *Offer_Operation_Unreserve

func (*Offer_Operation) ProtoMessage 

func (*Offer_Operation) ProtoMessage()

func (*Offer_Operation) Reset 

func (m *Offer_Operation) Reset()

func (*Offer_Operation) String 

func (m *Offer_Operation) String() string

type Offer_Operation_Create 

type Offer_Operation_Create struct {
	Volumes          []*Resource `protobuf:"bytes,1,rep,name=volumes" json:"volumes,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*Offer_Operation_Create) Descriptor 

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

func (*Offer_Operation_Create) GetVolumes 

func (m *Offer_Operation_Create) GetVolumes() []*Resource

func (*Offer_Operation_Create) ProtoMessage 

func (*Offer_Operation_Create) ProtoMessage()

func (*Offer_Operation_Create) Reset 

func (m *Offer_Operation_Create) Reset()

func (*Offer_Operation_Create) String 

func (m *Offer_Operation_Create) String() string

type Offer_Operation_Destroy 

type Offer_Operation_Destroy struct {
	Volumes          []*Resource `protobuf:"bytes,1,rep,name=volumes" json:"volumes,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*Offer_Operation_Destroy) Descriptor 

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

func (*Offer_Operation_Destroy) GetVolumes 

func (m *Offer_Operation_Destroy) GetVolumes() []*Resource

func (*Offer_Operation_Destroy) ProtoMessage 

func (*Offer_Operation_Destroy) ProtoMessage()

func (*Offer_Operation_Destroy) Reset 

func (m *Offer_Operation_Destroy) Reset()

func (*Offer_Operation_Destroy) String 

func (m *Offer_Operation_Destroy) String() string

type Offer_Operation_Launch 

type Offer_Operation_Launch struct {
	TaskInfos        []*TaskInfo `protobuf:"bytes,1,rep,name=task_infos,json=taskInfos" json:"task_infos,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

TODO(vinod): Deprecate this in favor of `LaunchGroup` below.

func (*Offer_Operation_Launch) Descriptor 

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

func (*Offer_Operation_Launch) GetTaskInfos 

func (m *Offer_Operation_Launch) GetTaskInfos() []*TaskInfo

func (*Offer_Operation_Launch) ProtoMessage 

func (*Offer_Operation_Launch) ProtoMessage()

func (*Offer_Operation_Launch) Reset 

func (m *Offer_Operation_Launch) Reset()

func (*Offer_Operation_Launch) String 

func (m *Offer_Operation_Launch) String() string

type Offer_Operation_LaunchGroup 

type Offer_Operation_LaunchGroup struct {
	Executor         *ExecutorInfo  `protobuf:"bytes,1,req,name=executor" json:"executor,omitempty"`
	TaskGroup        *TaskGroupInfo `protobuf:"bytes,2,req,name=task_group,json=taskGroup" json:"task_group,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

Unlike `Launch` above, all the tasks in a `task_group` are atomically delivered to an executor.

`NetworkInfo` set on executor will be shared by all tasks in the task group.

TODO(vinod): Any volumes set on executor could be used by a task by explicitly setting `Volume.source` in its resources.

func (*Offer_Operation_LaunchGroup) Descriptor 

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

func (*Offer_Operation_LaunchGroup) GetExecutor 

func (m *Offer_Operation_LaunchGroup) GetExecutor() *ExecutorInfo

func (*Offer_Operation_LaunchGroup) GetTaskGroup 

func (m *Offer_Operation_LaunchGroup) GetTaskGroup() *TaskGroupInfo

func (*Offer_Operation_LaunchGroup) ProtoMessage 

func (*Offer_Operation_LaunchGroup) ProtoMessage()

func (*Offer_Operation_LaunchGroup) Reset 

func (m *Offer_Operation_LaunchGroup) Reset()

func (*Offer_Operation_LaunchGroup) String 

func (m *Offer_Operation_LaunchGroup) String() string

type Offer_Operation_Reserve 

type Offer_Operation_Reserve struct {
	Resources        []*Resource `protobuf:"bytes,1,rep,name=resources" json:"resources,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*Offer_Operation_Reserve) Descriptor 

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

func (*Offer_Operation_Reserve) GetResources 

func (m *Offer_Operation_Reserve) GetResources() []*Resource

func (*Offer_Operation_Reserve) ProtoMessage 

func (*Offer_Operation_Reserve) ProtoMessage()

func (*Offer_Operation_Reserve) Reset 

func (m *Offer_Operation_Reserve) Reset()

func (*Offer_Operation_Reserve) String 

func (m *Offer_Operation_Reserve) String() string

type Offer_Operation_Type 

type Offer_Operation_Type int32
const (
	Offer_Operation_UNKNOWN      Offer_Operation_Type = 0
	Offer_Operation_LAUNCH       Offer_Operation_Type = 1
	Offer_Operation_LAUNCH_GROUP Offer_Operation_Type = 6
	Offer_Operation_RESERVE      Offer_Operation_Type = 2
	Offer_Operation_UNRESERVE    Offer_Operation_Type = 3
	Offer_Operation_CREATE       Offer_Operation_Type = 4
	Offer_Operation_DESTROY      Offer_Operation_Type = 5
)

func (Offer_Operation_Type) Enum 

func (x Offer_Operation_Type) Enum() *Offer_Operation_Type

func (Offer_Operation_Type) EnumDescriptor 

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

func (Offer_Operation_Type) String 

func (x Offer_Operation_Type) String() string

func (*Offer_Operation_Type) UnmarshalJSON 

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

type Offer_Operation_Unreserve 

type Offer_Operation_Unreserve struct {
	Resources        []*Resource `protobuf:"bytes,1,rep,name=resources" json:"resources,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*Offer_Operation_Unreserve) Descriptor 

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

func (*Offer_Operation_Unreserve) GetResources 

func (m *Offer_Operation_Unreserve) GetResources() []*Resource

func (*Offer_Operation_Unreserve) ProtoMessage 

func (*Offer_Operation_Unreserve) ProtoMessage()

func (*Offer_Operation_Unreserve) Reset 

func (m *Offer_Operation_Unreserve) Reset()

func (*Offer_Operation_Unreserve) String 

func (m *Offer_Operation_Unreserve) String() string

type Parameter 

type Parameter struct {
	Key              *string `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Value            *string `protobuf:"bytes,2,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* A generic (key, value) pair used in various places for parameters.

func (*Parameter) Descriptor 

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

func (*Parameter) GetKey 

func (m *Parameter) GetKey() string

func (*Parameter) GetValue 

func (m *Parameter) GetValue() string

func (*Parameter) ProtoMessage 

func (*Parameter) ProtoMessage()

func (*Parameter) Reset 

func (m *Parameter) Reset()

func (*Parameter) String 

func (m *Parameter) String() string

type Parameters 

type Parameters struct {
	Parameter        []*Parameter `protobuf:"bytes,1,rep,name=parameter" json:"parameter,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

* Collection of Parameter.

func (*Parameters) Descriptor 

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

func (*Parameters) GetParameter 

func (m *Parameters) GetParameter() []*Parameter

func (*Parameters) ProtoMessage 

func (*Parameters) ProtoMessage()

func (*Parameters) Reset 

func (m *Parameters) Reset()

func (*Parameters) String 

func (m *Parameters) String() string

type PerfStatistics 

type PerfStatistics struct {
	Timestamp *float64 `protobuf:"fixed64,1,req,name=timestamp" json:"timestamp,omitempty"`
	Duration  *float64 `protobuf:"fixed64,2,req,name=duration" json:"duration,omitempty"`
	// Hardware event.
	Cycles                *uint64 `protobuf:"varint,3,opt,name=cycles" json:"cycles,omitempty"`
	StalledCyclesFrontend *uint64 `protobuf:"varint,4,opt,name=stalled_cycles_frontend,json=stalledCyclesFrontend" json:"stalled_cycles_frontend,omitempty"`
	StalledCyclesBackend  *uint64 `protobuf:"varint,5,opt,name=stalled_cycles_backend,json=stalledCyclesBackend" json:"stalled_cycles_backend,omitempty"`
	Instructions          *uint64 `protobuf:"varint,6,opt,name=instructions" json:"instructions,omitempty"`
	CacheReferences       *uint64 `protobuf:"varint,7,opt,name=cache_references,json=cacheReferences" json:"cache_references,omitempty"`
	CacheMisses           *uint64 `protobuf:"varint,8,opt,name=cache_misses,json=cacheMisses" json:"cache_misses,omitempty"`
	Branches              *uint64 `protobuf:"varint,9,opt,name=branches" json:"branches,omitempty"`
	BranchMisses          *uint64 `protobuf:"varint,10,opt,name=branch_misses,json=branchMisses" json:"branch_misses,omitempty"`
	BusCycles             *uint64 `protobuf:"varint,11,opt,name=bus_cycles,json=busCycles" json:"bus_cycles,omitempty"`
	RefCycles             *uint64 `protobuf:"varint,12,opt,name=ref_cycles,json=refCycles" json:"ref_cycles,omitempty"`
	// Software event.
	CpuClock        *float64 `protobuf:"fixed64,13,opt,name=cpu_clock,json=cpuClock" json:"cpu_clock,omitempty"`
	TaskClock       *float64 `protobuf:"fixed64,14,opt,name=task_clock,json=taskClock" json:"task_clock,omitempty"`
	PageFaults      *uint64  `protobuf:"varint,15,opt,name=page_faults,json=pageFaults" json:"page_faults,omitempty"`
	MinorFaults     *uint64  `protobuf:"varint,16,opt,name=minor_faults,json=minorFaults" json:"minor_faults,omitempty"`
	MajorFaults     *uint64  `protobuf:"varint,17,opt,name=major_faults,json=majorFaults" json:"major_faults,omitempty"`
	ContextSwitches *uint64  `protobuf:"varint,18,opt,name=context_switches,json=contextSwitches" json:"context_switches,omitempty"`
	CpuMigrations   *uint64  `protobuf:"varint,19,opt,name=cpu_migrations,json=cpuMigrations" json:"cpu_migrations,omitempty"`
	AlignmentFaults *uint64  `protobuf:"varint,20,opt,name=alignment_faults,json=alignmentFaults" json:"alignment_faults,omitempty"`
	EmulationFaults *uint64  `protobuf:"varint,21,opt,name=emulation_faults,json=emulationFaults" json:"emulation_faults,omitempty"`
	// Hardware cache event.
	L1DcacheLoads          *uint64 `protobuf:"varint,22,opt,name=l1_dcache_loads,json=l1DcacheLoads" json:"l1_dcache_loads,omitempty"`
	L1DcacheLoadMisses     *uint64 `protobuf:"varint,23,opt,name=l1_dcache_load_misses,json=l1DcacheLoadMisses" json:"l1_dcache_load_misses,omitempty"`
	L1DcacheStores         *uint64 `protobuf:"varint,24,opt,name=l1_dcache_stores,json=l1DcacheStores" json:"l1_dcache_stores,omitempty"`
	L1DcacheStoreMisses    *uint64 `protobuf:"varint,25,opt,name=l1_dcache_store_misses,json=l1DcacheStoreMisses" json:"l1_dcache_store_misses,omitempty"`
	L1DcachePrefetches     *uint64 `protobuf:"varint,26,opt,name=l1_dcache_prefetches,json=l1DcachePrefetches" json:"l1_dcache_prefetches,omitempty"`
	L1DcachePrefetchMisses *uint64 `` /* 126-byte string literal not displayed */
	L1IcacheLoads          *uint64 `protobuf:"varint,28,opt,name=l1_icache_loads,json=l1IcacheLoads" json:"l1_icache_loads,omitempty"`
	L1IcacheLoadMisses     *uint64 `protobuf:"varint,29,opt,name=l1_icache_load_misses,json=l1IcacheLoadMisses" json:"l1_icache_load_misses,omitempty"`
	L1IcachePrefetches     *uint64 `protobuf:"varint,30,opt,name=l1_icache_prefetches,json=l1IcachePrefetches" json:"l1_icache_prefetches,omitempty"`
	L1IcachePrefetchMisses *uint64 `` /* 126-byte string literal not displayed */
	LlcLoads               *uint64 `protobuf:"varint,32,opt,name=llc_loads,json=llcLoads" json:"llc_loads,omitempty"`
	LlcLoadMisses          *uint64 `protobuf:"varint,33,opt,name=llc_load_misses,json=llcLoadMisses" json:"llc_load_misses,omitempty"`
	LlcStores              *uint64 `protobuf:"varint,34,opt,name=llc_stores,json=llcStores" json:"llc_stores,omitempty"`
	LlcStoreMisses         *uint64 `protobuf:"varint,35,opt,name=llc_store_misses,json=llcStoreMisses" json:"llc_store_misses,omitempty"`
	LlcPrefetches          *uint64 `protobuf:"varint,36,opt,name=llc_prefetches,json=llcPrefetches" json:"llc_prefetches,omitempty"`
	LlcPrefetchMisses      *uint64 `protobuf:"varint,37,opt,name=llc_prefetch_misses,json=llcPrefetchMisses" json:"llc_prefetch_misses,omitempty"`
	DtlbLoads              *uint64 `protobuf:"varint,38,opt,name=dtlb_loads,json=dtlbLoads" json:"dtlb_loads,omitempty"`
	DtlbLoadMisses         *uint64 `protobuf:"varint,39,opt,name=dtlb_load_misses,json=dtlbLoadMisses" json:"dtlb_load_misses,omitempty"`
	DtlbStores             *uint64 `protobuf:"varint,40,opt,name=dtlb_stores,json=dtlbStores" json:"dtlb_stores,omitempty"`
	DtlbStoreMisses        *uint64 `protobuf:"varint,41,opt,name=dtlb_store_misses,json=dtlbStoreMisses" json:"dtlb_store_misses,omitempty"`
	DtlbPrefetches         *uint64 `protobuf:"varint,42,opt,name=dtlb_prefetches,json=dtlbPrefetches" json:"dtlb_prefetches,omitempty"`
	DtlbPrefetchMisses     *uint64 `protobuf:"varint,43,opt,name=dtlb_prefetch_misses,json=dtlbPrefetchMisses" json:"dtlb_prefetch_misses,omitempty"`
	ItlbLoads              *uint64 `protobuf:"varint,44,opt,name=itlb_loads,json=itlbLoads" json:"itlb_loads,omitempty"`
	ItlbLoadMisses         *uint64 `protobuf:"varint,45,opt,name=itlb_load_misses,json=itlbLoadMisses" json:"itlb_load_misses,omitempty"`
	BranchLoads            *uint64 `protobuf:"varint,46,opt,name=branch_loads,json=branchLoads" json:"branch_loads,omitempty"`
	BranchLoadMisses       *uint64 `protobuf:"varint,47,opt,name=branch_load_misses,json=branchLoadMisses" json:"branch_load_misses,omitempty"`
	NodeLoads              *uint64 `protobuf:"varint,48,opt,name=node_loads,json=nodeLoads" json:"node_loads,omitempty"`
	NodeLoadMisses         *uint64 `protobuf:"varint,49,opt,name=node_load_misses,json=nodeLoadMisses" json:"node_load_misses,omitempty"`
	NodeStores             *uint64 `protobuf:"varint,50,opt,name=node_stores,json=nodeStores" json:"node_stores,omitempty"`
	NodeStoreMisses        *uint64 `protobuf:"varint,51,opt,name=node_store_misses,json=nodeStoreMisses" json:"node_store_misses,omitempty"`
	NodePrefetches         *uint64 `protobuf:"varint,52,opt,name=node_prefetches,json=nodePrefetches" json:"node_prefetches,omitempty"`
	NodePrefetchMisses     *uint64 `protobuf:"varint,53,opt,name=node_prefetch_misses,json=nodePrefetchMisses" json:"node_prefetch_misses,omitempty"`
	XXX_unrecognized       []byte  `json:"-"`
}

* Describes a sample of events from "perf stat". Only available on Linux.

NOTE: Each optional field matches the name of a perf event (see "perf list") with the following changes:

  1. Names are downcased.
  2. Hyphens ('-') are replaced with underscores ('_').
  3. Events with alternate names use the name "perf stat" returns, e.g., for the event "cycles OR cpu-cycles" perf always returns cycles.

func (*PerfStatistics) Descriptor 

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

func (*PerfStatistics) GetAlignmentFaults 

func (m *PerfStatistics) GetAlignmentFaults() uint64

func (*PerfStatistics) GetBranchLoadMisses 

func (m *PerfStatistics) GetBranchLoadMisses() uint64

func (*PerfStatistics) GetBranchLoads 

func (m *PerfStatistics) GetBranchLoads() uint64

func (*PerfStatistics) GetBranchMisses 

func (m *PerfStatistics) GetBranchMisses() uint64

func (*PerfStatistics) GetBranches 

func (m *PerfStatistics) GetBranches() uint64

func (*PerfStatistics) GetBusCycles 

func (m *PerfStatistics) GetBusCycles() uint64

func (*PerfStatistics) GetCacheMisses 

func (m *PerfStatistics) GetCacheMisses() uint64

func (*PerfStatistics) GetCacheReferences 

func (m *PerfStatistics) GetCacheReferences() uint64

func (*PerfStatistics) GetContextSwitches 

func (m *PerfStatistics) GetContextSwitches() uint64

func (*PerfStatistics) GetCpuClock 

func (m *PerfStatistics) GetCpuClock() float64

func (*PerfStatistics) GetCpuMigrations 

func (m *PerfStatistics) GetCpuMigrations() uint64

func (*PerfStatistics) GetCycles 

func (m *PerfStatistics) GetCycles() uint64

func (*PerfStatistics) GetDtlbLoadMisses 

func (m *PerfStatistics) GetDtlbLoadMisses() uint64

func (*PerfStatistics) GetDtlbLoads 

func (m *PerfStatistics) GetDtlbLoads() uint64

func (*PerfStatistics) GetDtlbPrefetchMisses 

func (m *PerfStatistics) GetDtlbPrefetchMisses() uint64

func (*PerfStatistics) GetDtlbPrefetches 

func (m *PerfStatistics) GetDtlbPrefetches() uint64

func (*PerfStatistics) GetDtlbStoreMisses 

func (m *PerfStatistics) GetDtlbStoreMisses() uint64

func (*PerfStatistics) GetDtlbStores 

func (m *PerfStatistics) GetDtlbStores() uint64

func (*PerfStatistics) GetDuration 

func (m *PerfStatistics) GetDuration() float64

func (*PerfStatistics) GetEmulationFaults 

func (m *PerfStatistics) GetEmulationFaults() uint64

func (*PerfStatistics) GetInstructions 

func (m *PerfStatistics) GetInstructions() uint64

func (*PerfStatistics) GetItlbLoadMisses 

func (m *PerfStatistics) GetItlbLoadMisses() uint64

func (*PerfStatistics) GetItlbLoads 

func (m *PerfStatistics) GetItlbLoads() uint64

func (*PerfStatistics) GetL1DcacheLoadMisses 

func (m *PerfStatistics) GetL1DcacheLoadMisses() uint64

func (*PerfStatistics) GetL1DcacheLoads 

func (m *PerfStatistics) GetL1DcacheLoads() uint64

func (*PerfStatistics) GetL1DcachePrefetchMisses 

func (m *PerfStatistics) GetL1DcachePrefetchMisses() uint64

func (*PerfStatistics) GetL1DcachePrefetches 

func (m *PerfStatistics) GetL1DcachePrefetches() uint64

func (*PerfStatistics) GetL1DcacheStoreMisses 

func (m *PerfStatistics) GetL1DcacheStoreMisses() uint64

func (*PerfStatistics) GetL1DcacheStores 

func (m *PerfStatistics) GetL1DcacheStores() uint64

func (*PerfStatistics) GetL1IcacheLoadMisses 

func (m *PerfStatistics) GetL1IcacheLoadMisses() uint64

func (*PerfStatistics) GetL1IcacheLoads 

func (m *PerfStatistics) GetL1IcacheLoads() uint64

func (*PerfStatistics) GetL1IcachePrefetchMisses 

func (m *PerfStatistics) GetL1IcachePrefetchMisses() uint64

func (*PerfStatistics) GetL1IcachePrefetches 

func (m *PerfStatistics) GetL1IcachePrefetches() uint64

func (*PerfStatistics) GetLlcLoadMisses 

func (m *PerfStatistics) GetLlcLoadMisses() uint64

func (*PerfStatistics) GetLlcLoads 

func (m *PerfStatistics) GetLlcLoads() uint64

func (*PerfStatistics) GetLlcPrefetchMisses 

func (m *PerfStatistics) GetLlcPrefetchMisses() uint64

func (*PerfStatistics) GetLlcPrefetches 

func (m *PerfStatistics) GetLlcPrefetches() uint64

func (*PerfStatistics) GetLlcStoreMisses 

func (m *PerfStatistics) GetLlcStoreMisses() uint64

func (*PerfStatistics) GetLlcStores 

func (m *PerfStatistics) GetLlcStores() uint64

func (*PerfStatistics) GetMajorFaults 

func (m *PerfStatistics) GetMajorFaults() uint64

func (*PerfStatistics) GetMinorFaults 

func (m *PerfStatistics) GetMinorFaults() uint64

func (*PerfStatistics) GetNodeLoadMisses 

func (m *PerfStatistics) GetNodeLoadMisses() uint64

func (*PerfStatistics) GetNodeLoads 

func (m *PerfStatistics) GetNodeLoads() uint64

func (*PerfStatistics) GetNodePrefetchMisses 

func (m *PerfStatistics) GetNodePrefetchMisses() uint64

func (*PerfStatistics) GetNodePrefetches 

func (m *PerfStatistics) GetNodePrefetches() uint64

func (*PerfStatistics) GetNodeStoreMisses 

func (m *PerfStatistics) GetNodeStoreMisses() uint64

func (*PerfStatistics) GetNodeStores 

func (m *PerfStatistics) GetNodeStores() uint64

func (*PerfStatistics) GetPageFaults 

func (m *PerfStatistics) GetPageFaults() uint64

func (*PerfStatistics) GetRefCycles 

func (m *PerfStatistics) GetRefCycles() uint64

func (*PerfStatistics) GetStalledCyclesBackend 

func (m *PerfStatistics) GetStalledCyclesBackend() uint64

func (*PerfStatistics) GetStalledCyclesFrontend 

func (m *PerfStatistics) GetStalledCyclesFrontend() uint64

func (*PerfStatistics) GetTaskClock 

func (m *PerfStatistics) GetTaskClock() float64

func (*PerfStatistics) GetTimestamp 

func (m *PerfStatistics) GetTimestamp() float64

func (*PerfStatistics) ProtoMessage 

func (*PerfStatistics) ProtoMessage()

func (*PerfStatistics) Reset 

func (m *PerfStatistics) Reset()

func (*PerfStatistics) String 

func (m *PerfStatistics) String() string

type Port 

type Port struct {
	// Port number on which the framework exposes a service.
	Number *uint32 `protobuf:"varint,1,req,name=number" json:"number,omitempty"`
	// Name of the service hosted on this port.
	Name *string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	// Layer 4-7 protocol on which the framework exposes its services.
	Protocol *string `protobuf:"bytes,3,opt,name=protocol" json:"protocol,omitempty"`
	// This field restricts discovery within a framework (FRAMEWORK),
	// within a Mesos cluster (CLUSTER), or places no restrictions (EXTERNAL).
	// The visibility setting for a Port overrides the general visibility setting
	// in the DiscoveryInfo.
	Visibility *DiscoveryInfo_Visibility `protobuf:"varint,4,opt,name=visibility,enum=mesos.v1.DiscoveryInfo_Visibility" json:"visibility,omitempty"`
	// This can be used to decorate the message with metadata to be
	// interpreted by external applications such as firewalls.
	Labels           *Labels `protobuf:"bytes,5,opt,name=labels" json:"labels,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Named port used for service discovery.

func (*Port) Descriptor 

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

func (*Port) GetLabels 

func (m *Port) GetLabels() *Labels

func (*Port) GetName 

func (m *Port) GetName() string

func (*Port) GetNumber 

func (m *Port) GetNumber() uint32

func (*Port) GetProtocol 

func (m *Port) GetProtocol() string

func (*Port) GetVisibility 

func (m *Port) GetVisibility() DiscoveryInfo_Visibility

func (*Port) ProtoMessage 

func (*Port) ProtoMessage()

func (*Port) Reset 

func (m *Port) Reset()

func (*Port) String 

func (m *Port) String() string

type Ports 

type Ports struct {
	Ports            []*Port `protobuf:"bytes,1,rep,name=ports" json:"ports,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Collection of ports.

func (*Ports) Descriptor 

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

func (*Ports) GetPorts 

func (m *Ports) GetPorts() []*Port

func (*Ports) ProtoMessage 

func (*Ports) ProtoMessage()

func (*Ports) Reset 

func (m *Ports) Reset()

func (*Ports) String 

func (m *Ports) String() string

type RateLimit 

type RateLimit struct {
	// Leaving QPS unset gives it unlimited rate (i.e., not throttled),
	// which also implies unlimited capacity.
	Qps *float64 `protobuf:"fixed64,1,opt,name=qps" json:"qps,omitempty"`
	// Principal of framework(s) to be throttled. Should match
	// FrameworkInfo.principal and Credential.principal (if using authentication).
	Principal *string `protobuf:"bytes,2,req,name=principal" json:"principal,omitempty"`
	// Max number of outstanding messages from frameworks of this principal
	// allowed by master before the next message is dropped and an error is sent
	// back to the sender. Messages received before the capacity is reached are
	// still going to be processed after the error is sent.
	// If unspecified, this principal is assigned unlimited capacity.
	// NOTE: This value is ignored if 'qps' is not set.
	Capacity         *uint64 `protobuf:"varint,3,opt,name=capacity" json:"capacity,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Rate (queries per second, QPS) limit for messages from a framework to master. Strictly speaking they are the combined rate from all frameworks of the same principal.

func (*RateLimit) Descriptor 

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

func (*RateLimit) GetCapacity 

func (m *RateLimit) GetCapacity() uint64

func (*RateLimit) GetPrincipal 

func (m *RateLimit) GetPrincipal() string

func (*RateLimit) GetQps 

func (m *RateLimit) GetQps() float64

func (*RateLimit) ProtoMessage 

func (*RateLimit) ProtoMessage()

func (*RateLimit) Reset 

func (m *RateLimit) Reset()

func (*RateLimit) String 

func (m *RateLimit) String() string

type RateLimits 

type RateLimits struct {
	// Items should have unique principals.
	Limits []*RateLimit `protobuf:"bytes,1,rep,name=limits" json:"limits,omitempty"`
	// All the frameworks not specified in 'limits' get this default rate.
	// This rate is an aggregate rate for all of them, i.e., their combined
	// traffic is throttled together at this rate.
	AggregateDefaultQps *float64 `protobuf:"fixed64,2,opt,name=aggregate_default_qps,json=aggregateDefaultQps" json:"aggregate_default_qps,omitempty"`
	// All the frameworks not specified in 'limits' get this default capacity.
	// This is an aggregate value similar to 'aggregate_default_qps'.
	AggregateDefaultCapacity *uint64 `` /* 129-byte string literal not displayed */
	XXX_unrecognized         []byte  `json:"-"`
}

* Collection of RateLimit. Frameworks without rate limits defined here are not throttled unless 'aggregate_default_qps' is specified.

func (*RateLimits) Descriptor 

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

func (*RateLimits) GetAggregateDefaultCapacity 

func (m *RateLimits) GetAggregateDefaultCapacity() uint64

func (*RateLimits) GetAggregateDefaultQps 

func (m *RateLimits) GetAggregateDefaultQps() float64

func (*RateLimits) GetLimits 

func (m *RateLimits) GetLimits() []*RateLimit

func (*RateLimits) ProtoMessage 

func (*RateLimits) ProtoMessage()

func (*RateLimits) Reset 

func (m *RateLimits) Reset()

func (*RateLimits) String 

func (m *RateLimits) String() string

type Request 

type Request struct {
	AgentId          *AgentID    `protobuf:"bytes,1,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	Resources        []*Resource `protobuf:"bytes,2,rep,name=resources" json:"resources,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

* Describes a request for resources that can be used by a framework to proactively influence the allocator. If 'agent_id' is provided then this request is assumed to only apply to resources on that agent.

func (*Request) Descriptor 

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

func (*Request) GetAgentId 

func (m *Request) GetAgentId() *AgentID

func (*Request) GetResources 

func (m *Request) GetResources() []*Resource

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) String 

func (m *Request) String() string

type Resource 

type Resource struct {
	Name   *string       `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Type   *Value_Type   `protobuf:"varint,2,req,name=type,enum=mesos.v1.Value_Type" json:"type,omitempty"`
	Scalar *Value_Scalar `protobuf:"bytes,3,opt,name=scalar" json:"scalar,omitempty"`
	Ranges *Value_Ranges `protobuf:"bytes,4,opt,name=ranges" json:"ranges,omitempty"`
	Set    *Value_Set    `protobuf:"bytes,5,opt,name=set" json:"set,omitempty"`
	// The role that this resource is reserved for. If "*", this indicates
	// that the resource is unreserved. Otherwise, the resource will only
	// be offered to frameworks that belong to this role.
	Role *string `protobuf:"bytes,6,opt,name=role,def=*" json:"role,omitempty"`
	// If this is set, this resource was dynamically reserved by an
	// operator or a framework. Otherwise, this resource is either unreserved
	// or statically reserved by an operator via the --resources flag.
	Reservation *Resource_ReservationInfo `protobuf:"bytes,8,opt,name=reservation" json:"reservation,omitempty"`
	Disk        *Resource_DiskInfo        `protobuf:"bytes,7,opt,name=disk" json:"disk,omitempty"`
	// If this is set, the resources are revocable, i.e., any tasks or
	// executors launched using these resources could get preempted or
	// throttled at any time. This could be used by frameworks to run
	// best effort tasks that do not need strict uptime or performance
	// guarantees. Note that if this is set, 'disk' or 'reservation'
	// cannot be set.
	Revocable *Resource_RevocableInfo `protobuf:"bytes,9,opt,name=revocable" json:"revocable,omitempty"`
	// If this is set, the resources are shared, i.e. multiple tasks
	// can be launched using this resource and all of them shall refer
	// to the same physical resource on the cluster. Note that only
	// persistent volumes can be shared currently.
	Shared           *Resource_SharedInfo `protobuf:"bytes,10,opt,name=shared" json:"shared,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

* Describes a resource on a machine. The `name` field is a string like "cpus" or "mem" that indicates which kind of resource this is; the rest of the fields describe the properties of the resource. A resource can take on one of three types: scalar (double), a list of finite and discrete ranges (e.g., [1-10, 20-30]), or a set of items. A resource is described using the standard protocol buffer "union" trick.

Note that "disk" and "mem" resources are scalar values expressed in megabytes. Fractional "cpus" values are allowed (e.g., "0.5"), which correspond to partial shares of a CPU.

func (*Resource) Descriptor 

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

func (*Resource) GetDisk 

func (m *Resource) GetDisk() *Resource_DiskInfo

func (*Resource) GetName 

func (m *Resource) GetName() string

func (*Resource) GetRanges 

func (m *Resource) GetRanges() *Value_Ranges

func (*Resource) GetReservation 

func (m *Resource) GetReservation() *Resource_ReservationInfo

func (*Resource) GetRevocable 

func (m *Resource) GetRevocable() *Resource_RevocableInfo

func (*Resource) GetRole 

func (m *Resource) GetRole() string

func (*Resource) GetScalar 

func (m *Resource) GetScalar() *Value_Scalar

func (*Resource) GetSet 

func (m *Resource) GetSet() *Value_Set

func (*Resource) GetShared 

func (m *Resource) GetShared() *Resource_SharedInfo

func (*Resource) GetType 

func (m *Resource) GetType() Value_Type

func (*Resource) ProtoMessage 

func (*Resource) ProtoMessage()

func (*Resource) Reset 

func (m *Resource) Reset()

func (*Resource) String 

func (m *Resource) String() string

type ResourceStatistics 

type ResourceStatistics struct {
	Timestamp *float64 `protobuf:"fixed64,1,req,name=timestamp" json:"timestamp,omitempty"`
	Processes *uint32  `protobuf:"varint,30,opt,name=processes" json:"processes,omitempty"`
	Threads   *uint32  `protobuf:"varint,31,opt,name=threads" json:"threads,omitempty"`
	// CPU Usage Information:
	// Total CPU time spent in user mode, and kernel mode.
	CpusUserTimeSecs   *float64 `protobuf:"fixed64,2,opt,name=cpus_user_time_secs,json=cpusUserTimeSecs" json:"cpus_user_time_secs,omitempty"`
	CpusSystemTimeSecs *float64 `protobuf:"fixed64,3,opt,name=cpus_system_time_secs,json=cpusSystemTimeSecs" json:"cpus_system_time_secs,omitempty"`
	// Number of CPUs allocated.
	CpusLimit *float64 `protobuf:"fixed64,4,opt,name=cpus_limit,json=cpusLimit" json:"cpus_limit,omitempty"`
	// cpu.stat on process throttling (for contention issues).
	CpusNrPeriods         *uint32  `protobuf:"varint,7,opt,name=cpus_nr_periods,json=cpusNrPeriods" json:"cpus_nr_periods,omitempty"`
	CpusNrThrottled       *uint32  `protobuf:"varint,8,opt,name=cpus_nr_throttled,json=cpusNrThrottled" json:"cpus_nr_throttled,omitempty"`
	CpusThrottledTimeSecs *float64 `protobuf:"fixed64,9,opt,name=cpus_throttled_time_secs,json=cpusThrottledTimeSecs" json:"cpus_throttled_time_secs,omitempty"`
	// mem_total_bytes was added in 0.23.0 to represent the total memory
	// of a process in RAM (as opposed to in Swap). This was previously
	// reported as mem_rss_bytes, which was also changed in 0.23.0 to
	// represent only the anonymous memory usage, to keep in sync with
	// Linux kernel's (arguably erroneous) use of terminology.
	MemTotalBytes *uint64 `protobuf:"varint,36,opt,name=mem_total_bytes,json=memTotalBytes" json:"mem_total_bytes,omitempty"`
	// Total memory + swap usage. This is set if swap is enabled.
	MemTotalMemswBytes *uint64 `protobuf:"varint,37,opt,name=mem_total_memsw_bytes,json=memTotalMemswBytes" json:"mem_total_memsw_bytes,omitempty"`
	// Hard memory limit for a container.
	MemLimitBytes *uint64 `protobuf:"varint,6,opt,name=mem_limit_bytes,json=memLimitBytes" json:"mem_limit_bytes,omitempty"`
	// Soft memory limit for a container.
	MemSoftLimitBytes *uint64 `protobuf:"varint,38,opt,name=mem_soft_limit_bytes,json=memSoftLimitBytes" json:"mem_soft_limit_bytes,omitempty"`
	// TODO(chzhcn) mem_file_bytes and mem_anon_bytes are deprecated in
	// 0.23.0 and will be removed in 0.24.0.
	MemFileBytes *uint64 `protobuf:"varint,10,opt,name=mem_file_bytes,json=memFileBytes" json:"mem_file_bytes,omitempty"`
	MemAnonBytes *uint64 `protobuf:"varint,11,opt,name=mem_anon_bytes,json=memAnonBytes" json:"mem_anon_bytes,omitempty"`
	// mem_cache_bytes is added in 0.23.0 to represent page cache usage.
	MemCacheBytes *uint64 `protobuf:"varint,39,opt,name=mem_cache_bytes,json=memCacheBytes" json:"mem_cache_bytes,omitempty"`
	// Since 0.23.0, mem_rss_bytes is changed to represent only
	// anonymous memory usage. Note that neither its requiredness, type,
	// name nor numeric tag has been changed.
	MemRssBytes        *uint64 `protobuf:"varint,5,opt,name=mem_rss_bytes,json=memRssBytes" json:"mem_rss_bytes,omitempty"`
	MemMappedFileBytes *uint64 `protobuf:"varint,12,opt,name=mem_mapped_file_bytes,json=memMappedFileBytes" json:"mem_mapped_file_bytes,omitempty"`
	// This is only set if swap is enabled.
	MemSwapBytes        *uint64 `protobuf:"varint,40,opt,name=mem_swap_bytes,json=memSwapBytes" json:"mem_swap_bytes,omitempty"`
	MemUnevictableBytes *uint64 `protobuf:"varint,41,opt,name=mem_unevictable_bytes,json=memUnevictableBytes" json:"mem_unevictable_bytes,omitempty"`
	// Number of occurrences of different levels of memory pressure
	// events reported by memory cgroup. Pressure listening (re)starts
	// with these values set to 0 when agent (re)starts. See
	// https://www.kernel.org/doc/Documentation/cgroups/memory.txt for
	// more details.
	MemLowPressureCounter      *uint64 `protobuf:"varint,32,opt,name=mem_low_pressure_counter,json=memLowPressureCounter" json:"mem_low_pressure_counter,omitempty"`
	MemMediumPressureCounter   *uint64 `` /* 132-byte string literal not displayed */
	MemCriticalPressureCounter *uint64 `` /* 138-byte string literal not displayed */
	// Disk Usage Information for executor working directory.
	DiskLimitBytes *uint64 `protobuf:"varint,26,opt,name=disk_limit_bytes,json=diskLimitBytes" json:"disk_limit_bytes,omitempty"`
	DiskUsedBytes  *uint64 `protobuf:"varint,27,opt,name=disk_used_bytes,json=diskUsedBytes" json:"disk_used_bytes,omitempty"`
	// Perf statistics.
	Perf *PerfStatistics `protobuf:"bytes,13,opt,name=perf" json:"perf,omitempty"`
	// Network Usage Information:
	NetRxPackets *uint64 `protobuf:"varint,14,opt,name=net_rx_packets,json=netRxPackets" json:"net_rx_packets,omitempty"`
	NetRxBytes   *uint64 `protobuf:"varint,15,opt,name=net_rx_bytes,json=netRxBytes" json:"net_rx_bytes,omitempty"`
	NetRxErrors  *uint64 `protobuf:"varint,16,opt,name=net_rx_errors,json=netRxErrors" json:"net_rx_errors,omitempty"`
	NetRxDropped *uint64 `protobuf:"varint,17,opt,name=net_rx_dropped,json=netRxDropped" json:"net_rx_dropped,omitempty"`
	NetTxPackets *uint64 `protobuf:"varint,18,opt,name=net_tx_packets,json=netTxPackets" json:"net_tx_packets,omitempty"`
	NetTxBytes   *uint64 `protobuf:"varint,19,opt,name=net_tx_bytes,json=netTxBytes" json:"net_tx_bytes,omitempty"`
	NetTxErrors  *uint64 `protobuf:"varint,20,opt,name=net_tx_errors,json=netTxErrors" json:"net_tx_errors,omitempty"`
	NetTxDropped *uint64 `protobuf:"varint,21,opt,name=net_tx_dropped,json=netTxDropped" json:"net_tx_dropped,omitempty"`
	// The kernel keeps track of RTT (round-trip time) for its TCP
	// sockets. RTT is a way to tell the latency of a container.
	NetTcpRttMicrosecsP50     *float64 `` /* 126-byte string literal not displayed */
	NetTcpRttMicrosecsP90     *float64 `` /* 126-byte string literal not displayed */
	NetTcpRttMicrosecsP95     *float64 `` /* 126-byte string literal not displayed */
	NetTcpRttMicrosecsP99     *float64 `` /* 126-byte string literal not displayed */
	NetTcpActiveConnections   *float64 `` /* 130-byte string literal not displayed */
	NetTcpTimeWaitConnections *float64 `` /* 138-byte string literal not displayed */
	// Network traffic flowing into or out of a container can be delayed
	// or dropped due to congestion or policy inside and outside the
	// container.
	NetTrafficControlStatistics []*TrafficControlStatistics `` /* 140-byte string literal not displayed */
	// Network SNMP statistics for each container.
	NetSnmpStatistics *SNMPStatistics `protobuf:"bytes,42,opt,name=net_snmp_statistics,json=netSnmpStatistics" json:"net_snmp_statistics,omitempty"`
	XXX_unrecognized  []byte          `json:"-"`
}

* A snapshot of resource usage statistics.

func (*ResourceStatistics) Descriptor 

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

func (*ResourceStatistics) GetCpusLimit 

func (m *ResourceStatistics) GetCpusLimit() float64

func (*ResourceStatistics) GetCpusNrPeriods 

func (m *ResourceStatistics) GetCpusNrPeriods() uint32

func (*ResourceStatistics) GetCpusNrThrottled 

func (m *ResourceStatistics) GetCpusNrThrottled() uint32

func (*ResourceStatistics) GetCpusSystemTimeSecs 

func (m *ResourceStatistics) GetCpusSystemTimeSecs() float64

func (*ResourceStatistics) GetCpusThrottledTimeSecs 

func (m *ResourceStatistics) GetCpusThrottledTimeSecs() float64

func (*ResourceStatistics) GetCpusUserTimeSecs 

func (m *ResourceStatistics) GetCpusUserTimeSecs() float64

func (*ResourceStatistics) GetDiskLimitBytes 

func (m *ResourceStatistics) GetDiskLimitBytes() uint64

func (*ResourceStatistics) GetDiskUsedBytes 

func (m *ResourceStatistics) GetDiskUsedBytes() uint64

func (*ResourceStatistics) GetMemAnonBytes 

func (m *ResourceStatistics) GetMemAnonBytes() uint64

func (*ResourceStatistics) GetMemCacheBytes 

func (m *ResourceStatistics) GetMemCacheBytes() uint64

func (*ResourceStatistics) GetMemCriticalPressureCounter 

func (m *ResourceStatistics) GetMemCriticalPressureCounter() uint64

func (*ResourceStatistics) GetMemFileBytes 

func (m *ResourceStatistics) GetMemFileBytes() uint64

func (*ResourceStatistics) GetMemLimitBytes 

func (m *ResourceStatistics) GetMemLimitBytes() uint64

func (*ResourceStatistics) GetMemLowPressureCounter 

func (m *ResourceStatistics) GetMemLowPressureCounter() uint64

func (*ResourceStatistics) GetMemMappedFileBytes 

func (m *ResourceStatistics) GetMemMappedFileBytes() uint64

func (*ResourceStatistics) GetMemMediumPressureCounter 

func (m *ResourceStatistics) GetMemMediumPressureCounter() uint64

func (*ResourceStatistics) GetMemRssBytes 

func (m *ResourceStatistics) GetMemRssBytes() uint64

func (*ResourceStatistics) GetMemSoftLimitBytes 

func (m *ResourceStatistics) GetMemSoftLimitBytes() uint64

func (*ResourceStatistics) GetMemSwapBytes 

func (m *ResourceStatistics) GetMemSwapBytes() uint64

func (*ResourceStatistics) GetMemTotalBytes 

func (m *ResourceStatistics) GetMemTotalBytes() uint64

func (*ResourceStatistics) GetMemTotalMemswBytes 

func (m *ResourceStatistics) GetMemTotalMemswBytes() uint64

func (*ResourceStatistics) GetMemUnevictableBytes 

func (m *ResourceStatistics) GetMemUnevictableBytes() uint64

func (*ResourceStatistics) GetNetRxBytes 

func (m *ResourceStatistics) GetNetRxBytes() uint64

func (*ResourceStatistics) GetNetRxDropped 

func (m *ResourceStatistics) GetNetRxDropped() uint64

func (*ResourceStatistics) GetNetRxErrors 

func (m *ResourceStatistics) GetNetRxErrors() uint64

func (*ResourceStatistics) GetNetRxPackets 

func (m *ResourceStatistics) GetNetRxPackets() uint64

func (*ResourceStatistics) GetNetSnmpStatistics 

func (m *ResourceStatistics) GetNetSnmpStatistics() *SNMPStatistics

func (*ResourceStatistics) GetNetTcpActiveConnections 

func (m *ResourceStatistics) GetNetTcpActiveConnections() float64

func (*ResourceStatistics) GetNetTcpRttMicrosecsP50 

func (m *ResourceStatistics) GetNetTcpRttMicrosecsP50() float64

func (*ResourceStatistics) GetNetTcpRttMicrosecsP90 

func (m *ResourceStatistics) GetNetTcpRttMicrosecsP90() float64

func (*ResourceStatistics) GetNetTcpRttMicrosecsP95 

func (m *ResourceStatistics) GetNetTcpRttMicrosecsP95() float64

func (*ResourceStatistics) GetNetTcpRttMicrosecsP99 

func (m *ResourceStatistics) GetNetTcpRttMicrosecsP99() float64

func (*ResourceStatistics) GetNetTcpTimeWaitConnections 

func (m *ResourceStatistics) GetNetTcpTimeWaitConnections() float64

func (*ResourceStatistics) GetNetTrafficControlStatistics 

func (m *ResourceStatistics) GetNetTrafficControlStatistics() []*TrafficControlStatistics

func (*ResourceStatistics) GetNetTxBytes 

func (m *ResourceStatistics) GetNetTxBytes() uint64

func (*ResourceStatistics) GetNetTxDropped 

func (m *ResourceStatistics) GetNetTxDropped() uint64

func (*ResourceStatistics) GetNetTxErrors 

func (m *ResourceStatistics) GetNetTxErrors() uint64

func (*ResourceStatistics) GetNetTxPackets 

func (m *ResourceStatistics) GetNetTxPackets() uint64

func (*ResourceStatistics) GetPerf 

func (m *ResourceStatistics) GetPerf() *PerfStatistics

func (*ResourceStatistics) GetProcesses 

func (m *ResourceStatistics) GetProcesses() uint32

func (*ResourceStatistics) GetThreads 

func (m *ResourceStatistics) GetThreads() uint32

func (*ResourceStatistics) GetTimestamp 

func (m *ResourceStatistics) GetTimestamp() float64

func (*ResourceStatistics) ProtoMessage 

func (*ResourceStatistics) ProtoMessage()

func (*ResourceStatistics) Reset 

func (m *ResourceStatistics) Reset()

func (*ResourceStatistics) String 

func (m *ResourceStatistics) String() string

type ResourceUsage 

type ResourceUsage struct {
	Executors []*ResourceUsage_Executor `protobuf:"bytes,1,rep,name=executors" json:"executors,omitempty"`
	// Agent's total resources including checkpointed dynamic
	// reservations and persistent volumes.
	Total            []*Resource `protobuf:"bytes,2,rep,name=total" json:"total,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

* Describes a snapshot of the resource usage for executors.

func (*ResourceUsage) Descriptor 

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

func (*ResourceUsage) GetExecutors 

func (m *ResourceUsage) GetExecutors() []*ResourceUsage_Executor

func (*ResourceUsage) GetTotal 

func (m *ResourceUsage) GetTotal() []*Resource

func (*ResourceUsage) ProtoMessage 

func (*ResourceUsage) ProtoMessage()

func (*ResourceUsage) Reset 

func (m *ResourceUsage) Reset()

func (*ResourceUsage) String 

func (m *ResourceUsage) String() string

type ResourceUsage_Executor 

type ResourceUsage_Executor struct {
	ExecutorInfo *ExecutorInfo `protobuf:"bytes,1,req,name=executor_info,json=executorInfo" json:"executor_info,omitempty"`
	// This includes resources used by the executor itself
	// as well as its active tasks.
	Allocated []*Resource `protobuf:"bytes,2,rep,name=allocated" json:"allocated,omitempty"`
	// Current resource usage. If absent, the containerizer
	// cannot provide resource usage.
	Statistics *ResourceStatistics `protobuf:"bytes,3,opt,name=statistics" json:"statistics,omitempty"`
	// The container id for the executor specified in the executor_info field.
	ContainerId *ContainerID `protobuf:"bytes,4,req,name=container_id,json=containerId" json:"container_id,omitempty"`
	// Non-terminal tasks.
	Tasks            []*ResourceUsage_Executor_Task `protobuf:"bytes,5,rep,name=tasks" json:"tasks,omitempty"`
	XXX_unrecognized []byte                         `json:"-"`
}

func (*ResourceUsage_Executor) Descriptor 

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

func (*ResourceUsage_Executor) GetAllocated 

func (m *ResourceUsage_Executor) GetAllocated() []*Resource

func (*ResourceUsage_Executor) GetContainerId 

func (m *ResourceUsage_Executor) GetContainerId() *ContainerID

func (*ResourceUsage_Executor) GetExecutorInfo 

func (m *ResourceUsage_Executor) GetExecutorInfo() *ExecutorInfo

func (*ResourceUsage_Executor) GetStatistics 

func (m *ResourceUsage_Executor) GetStatistics() *ResourceStatistics

func (*ResourceUsage_Executor) GetTasks 

func (m *ResourceUsage_Executor) GetTasks() []*ResourceUsage_Executor_Task

func (*ResourceUsage_Executor) ProtoMessage 

func (*ResourceUsage_Executor) ProtoMessage()

func (*ResourceUsage_Executor) Reset 

func (m *ResourceUsage_Executor) Reset()

func (*ResourceUsage_Executor) String 

func (m *ResourceUsage_Executor) String() string

type ResourceUsage_Executor_Task 

type ResourceUsage_Executor_Task struct {
	Name             *string     `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Id               *TaskID     `protobuf:"bytes,2,req,name=id" json:"id,omitempty"`
	Resources        []*Resource `protobuf:"bytes,3,rep,name=resources" json:"resources,omitempty"`
	Labels           *Labels     `protobuf:"bytes,4,opt,name=labels" json:"labels,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*ResourceUsage_Executor_Task) Descriptor 

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

func (*ResourceUsage_Executor_Task) GetId 

func (m *ResourceUsage_Executor_Task) GetId() *TaskID

func (*ResourceUsage_Executor_Task) GetLabels 

func (m *ResourceUsage_Executor_Task) GetLabels() *Labels

func (*ResourceUsage_Executor_Task) GetName 

func (m *ResourceUsage_Executor_Task) GetName() string

func (*ResourceUsage_Executor_Task) GetResources 

func (m *ResourceUsage_Executor_Task) GetResources() []*Resource

func (*ResourceUsage_Executor_Task) ProtoMessage 

func (*ResourceUsage_Executor_Task) ProtoMessage()

func (*ResourceUsage_Executor_Task) Reset 

func (m *ResourceUsage_Executor_Task) Reset()

func (*ResourceUsage_Executor_Task) String 

func (m *ResourceUsage_Executor_Task) String() string

type Resource_DiskInfo 

type Resource_DiskInfo struct {
	Persistence *Resource_DiskInfo_Persistence `protobuf:"bytes,1,opt,name=persistence" json:"persistence,omitempty"`
	// Describes how this disk resource will be mounted in the
	// container. If not set, the disk resource will be used as the
	// sandbox. Otherwise, it will be mounted according to the
	// 'container_path' inside 'volume'. The 'host_path' inside
	// 'volume' is ignored.
	// NOTE: If 'volume' is set but 'persistence' is not set, the
	// volume will be automatically garbage collected after
	// task/executor terminates. Currently, if 'persistence' is set,
	// 'volume' must be set.
	Volume           *Volume                   `protobuf:"bytes,2,opt,name=volume" json:"volume,omitempty"`
	Source           *Resource_DiskInfo_Source `protobuf:"bytes,3,opt,name=source" json:"source,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*Resource_DiskInfo) Descriptor 

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

func (*Resource_DiskInfo) GetPersistence 

func (m *Resource_DiskInfo) GetPersistence() *Resource_DiskInfo_Persistence

func (*Resource_DiskInfo) GetSource 

func (m *Resource_DiskInfo) GetSource() *Resource_DiskInfo_Source

func (*Resource_DiskInfo) GetVolume 

func (m *Resource_DiskInfo) GetVolume() *Volume

func (*Resource_DiskInfo) ProtoMessage 

func (*Resource_DiskInfo) ProtoMessage()

func (*Resource_DiskInfo) Reset 

func (m *Resource_DiskInfo) Reset()

func (*Resource_DiskInfo) String 

func (m *Resource_DiskInfo) String() string

type Resource_DiskInfo_Persistence 

type Resource_DiskInfo_Persistence struct {
	// A unique ID for the persistent disk volume. This ID must be
	// unique per role on each agent. Although it is possible to use
	// the same ID on different agents in the cluster and to reuse
	// IDs after a volume with that ID has been destroyed, both
	// practices are discouraged.
	Id *string `protobuf:"bytes,1,req,name=id" json:"id,omitempty"`
	// This field indicates the principal of the operator or
	// framework that created this volume. It is used in conjunction
	// with the "destroy" ACL to determine whether an entity
	// attempting to destroy the volume is permitted to do so.
	//
	// NOTE: This field is optional, while the `principal` found in
	// `ReservationInfo` is required. This field is optional to
	// allow for the possibility of volume creation without a
	// principal, though currently it must be provided.
	//
	// NOTE: This field should match the FrameworkInfo.principal of
	// the framework that created the volume.
	Principal        *string `protobuf:"bytes,2,opt,name=principal" json:"principal,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Describes a persistent disk volume.

A persistent disk volume will not be automatically garbage collected if the task/executor/agent terminates, but will be re-offered to the framework(s) belonging to the 'role'.

NOTE: Currently, we do not allow persistent disk volumes without a reservation (i.e., 'role' cannot be '*').

func (*Resource_DiskInfo_Persistence) Descriptor 

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

func (*Resource_DiskInfo_Persistence) GetId 

func (m *Resource_DiskInfo_Persistence) GetId() string

func (*Resource_DiskInfo_Persistence) GetPrincipal 

func (m *Resource_DiskInfo_Persistence) GetPrincipal() string

func (*Resource_DiskInfo_Persistence) ProtoMessage 

func (*Resource_DiskInfo_Persistence) ProtoMessage()

func (*Resource_DiskInfo_Persistence) Reset 

func (m *Resource_DiskInfo_Persistence) Reset()

func (*Resource_DiskInfo_Persistence) String 

func (m *Resource_DiskInfo_Persistence) String() string

type Resource_DiskInfo_Source 

type Resource_DiskInfo_Source struct {
	Type             *Resource_DiskInfo_Source_Type  `protobuf:"varint,1,req,name=type,enum=mesos.v1.Resource_DiskInfo_Source_Type" json:"type,omitempty"`
	Path             *Resource_DiskInfo_Source_Path  `protobuf:"bytes,2,opt,name=path" json:"path,omitempty"`
	Mount            *Resource_DiskInfo_Source_Mount `protobuf:"bytes,3,opt,name=mount" json:"mount,omitempty"`
	XXX_unrecognized []byte                          `json:"-"`
}

Describes where a disk originates from. TODO(jmlvanre): Add support for BLOCK devices.

func (*Resource_DiskInfo_Source) Descriptor 

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

func (*Resource_DiskInfo_Source) GetMount 

func (m *Resource_DiskInfo_Source) GetMount() *Resource_DiskInfo_Source_Mount

func (*Resource_DiskInfo_Source) GetPath 

func (m *Resource_DiskInfo_Source) GetPath() *Resource_DiskInfo_Source_Path

func (*Resource_DiskInfo_Source) GetType 

func (m *Resource_DiskInfo_Source) GetType() Resource_DiskInfo_Source_Type

func (*Resource_DiskInfo_Source) ProtoMessage 

func (*Resource_DiskInfo_Source) ProtoMessage()

func (*Resource_DiskInfo_Source) Reset 

func (m *Resource_DiskInfo_Source) Reset()

func (*Resource_DiskInfo_Source) String 

func (m *Resource_DiskInfo_Source) String() string

type Resource_DiskInfo_Source_Mount 

type Resource_DiskInfo_Source_Mount struct {
	// Path to mount point (e.g., /mnt/raid/disk0).
	Root             *string `protobuf:"bytes,1,req,name=root" json:"root,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

A mounted file-system set up by the Agent administrator. This can only be used exclusively: a framework cannot accept a partial amount of this disk.

func (*Resource_DiskInfo_Source_Mount) Descriptor 

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

func (*Resource_DiskInfo_Source_Mount) GetRoot 

func (m *Resource_DiskInfo_Source_Mount) GetRoot() string

func (*Resource_DiskInfo_Source_Mount) ProtoMessage 

func (*Resource_DiskInfo_Source_Mount) ProtoMessage()

func (*Resource_DiskInfo_Source_Mount) Reset 

func (m *Resource_DiskInfo_Source_Mount) Reset()

func (*Resource_DiskInfo_Source_Mount) String 

func (m *Resource_DiskInfo_Source_Mount) String() string

type Resource_DiskInfo_Source_Path 

type Resource_DiskInfo_Source_Path struct {
	// Path to the folder (e.g., /mnt/raid/disk0).
	Root             *string `protobuf:"bytes,1,req,name=root" json:"root,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

A folder that can be located on a separate disk device. This can be shared and carved up as necessary between frameworks.

func (*Resource_DiskInfo_Source_Path) Descriptor 

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

func (*Resource_DiskInfo_Source_Path) GetRoot 

func (m *Resource_DiskInfo_Source_Path) GetRoot() string

func (*Resource_DiskInfo_Source_Path) ProtoMessage 

func (*Resource_DiskInfo_Source_Path) ProtoMessage()

func (*Resource_DiskInfo_Source_Path) Reset 

func (m *Resource_DiskInfo_Source_Path) Reset()

func (*Resource_DiskInfo_Source_Path) String 

func (m *Resource_DiskInfo_Source_Path) String() string

type Resource_DiskInfo_Source_Type 

type Resource_DiskInfo_Source_Type int32
const (
	Resource_DiskInfo_Source_PATH  Resource_DiskInfo_Source_Type = 1
	Resource_DiskInfo_Source_MOUNT Resource_DiskInfo_Source_Type = 2
)

func (Resource_DiskInfo_Source_Type) Enum 

func (x Resource_DiskInfo_Source_Type) Enum() *Resource_DiskInfo_Source_Type

func (Resource_DiskInfo_Source_Type) EnumDescriptor 

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

func (Resource_DiskInfo_Source_Type) String 

func (x Resource_DiskInfo_Source_Type) String() string

func (*Resource_DiskInfo_Source_Type) UnmarshalJSON 

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

type Resource_ReservationInfo 

type Resource_ReservationInfo struct {
	// Indicates the principal, if any, of the framework or operator
	// that reserved this resource. If reserved by a framework, the
	// field should match the `FrameworkInfo.principal`. It is used in
	// conjunction with the `UnreserveResources` ACL to determine
	// whether the entity attempting to unreserve this resource is
	// permitted to do so.
	Principal *string `protobuf:"bytes,1,opt,name=principal" json:"principal,omitempty"`
	// Labels are free-form key value pairs that can be used to
	// associate arbitrary metadata with a reserved resource.  For
	// example, frameworks can use labels to identify the intended
	// purpose for a portion of the resources the framework has
	// reserved at a given agent. Labels should not contain duplicate
	// key-value pairs.
	Labels           *Labels `protobuf:"bytes,2,opt,name=labels" json:"labels,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Resource_ReservationInfo) Descriptor 

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

func (*Resource_ReservationInfo) GetLabels 

func (m *Resource_ReservationInfo) GetLabels() *Labels

func (*Resource_ReservationInfo) GetPrincipal 

func (m *Resource_ReservationInfo) GetPrincipal() string

func (*Resource_ReservationInfo) ProtoMessage 

func (*Resource_ReservationInfo) ProtoMessage()

func (*Resource_ReservationInfo) Reset 

func (m *Resource_ReservationInfo) Reset()

func (*Resource_ReservationInfo) String 

func (m *Resource_ReservationInfo) String() string

type Resource_RevocableInfo 

type Resource_RevocableInfo struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*Resource_RevocableInfo) Descriptor 

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

func (*Resource_RevocableInfo) ProtoMessage 

func (*Resource_RevocableInfo) ProtoMessage()

func (*Resource_RevocableInfo) Reset 

func (m *Resource_RevocableInfo) Reset()

func (*Resource_RevocableInfo) String 

func (m *Resource_RevocableInfo) String() string

type Resource_SharedInfo 

type Resource_SharedInfo struct {
	XXX_unrecognized []byte `json:"-"`
}

Allow the resource to be shared across tasks.

func (*Resource_SharedInfo) Descriptor 

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

func (*Resource_SharedInfo) ProtoMessage 

func (*Resource_SharedInfo) ProtoMessage()

func (*Resource_SharedInfo) Reset 

func (m *Resource_SharedInfo) Reset()

func (*Resource_SharedInfo) String 

func (m *Resource_SharedInfo) String() string

type Role 

type Role struct {
	Name             *string        `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Weight           *float64       `protobuf:"fixed64,2,req,name=weight" json:"weight,omitempty"`
	Frameworks       []*FrameworkID `protobuf:"bytes,3,rep,name=frameworks" json:"frameworks,omitempty"`
	Resources        []*Resource    `protobuf:"bytes,4,rep,name=resources" json:"resources,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

* Describes a Role. Roles can be used to specify that certain resources are reserved for the use of one or more frameworks.

func (*Role) Descriptor 

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

func (*Role) GetFrameworks 

func (m *Role) GetFrameworks() []*FrameworkID

func (*Role) GetName 

func (m *Role) GetName() string

func (*Role) GetResources 

func (m *Role) GetResources() []*Resource

func (*Role) GetWeight 

func (m *Role) GetWeight() float64

func (*Role) ProtoMessage 

func (*Role) ProtoMessage()

func (*Role) Reset 

func (m *Role) Reset()

func (*Role) String 

func (m *Role) String() string

type SNMPStatistics 

type SNMPStatistics struct {
	IpStats          *IpStatistics   `protobuf:"bytes,1,opt,name=ip_stats,json=ipStats" json:"ip_stats,omitempty"`
	IcmpStats        *IcmpStatistics `protobuf:"bytes,2,opt,name=icmp_stats,json=icmpStats" json:"icmp_stats,omitempty"`
	TcpStats         *TcpStatistics  `protobuf:"bytes,3,opt,name=tcp_stats,json=tcpStats" json:"tcp_stats,omitempty"`
	UdpStats         *UdpStatistics  `protobuf:"bytes,4,opt,name=udp_stats,json=udpStats" json:"udp_stats,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*SNMPStatistics) Descriptor 

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

func (*SNMPStatistics) GetIcmpStats 

func (m *SNMPStatistics) GetIcmpStats() *IcmpStatistics

func (*SNMPStatistics) GetIpStats 

func (m *SNMPStatistics) GetIpStats() *IpStatistics

func (*SNMPStatistics) GetTcpStats 

func (m *SNMPStatistics) GetTcpStats() *TcpStatistics

func (*SNMPStatistics) GetUdpStats 

func (m *SNMPStatistics) GetUdpStats() *UdpStatistics

func (*SNMPStatistics) ProtoMessage 

func (*SNMPStatistics) ProtoMessage()

func (*SNMPStatistics) Reset 

func (m *SNMPStatistics) Reset()

func (*SNMPStatistics) String 

func (m *SNMPStatistics) String() string

type Status 

type Status int32

* Status is used to indicate the state of the scheduler and executor driver after function calls. 

const (
	Status_DRIVER_NOT_STARTED Status = 1
	Status_DRIVER_RUNNING     Status = 2
	Status_DRIVER_ABORTED     Status = 3
	Status_DRIVER_STOPPED     Status = 4
)

func (Status) Enum 

func (x Status) Enum() *Status

func (Status) EnumDescriptor 

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

func (Status) String 

func (x Status) String() string

func (*Status) UnmarshalJSON 

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

type Task 

type Task struct {
	Name        *string       `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	TaskId      *TaskID       `protobuf:"bytes,2,req,name=task_id,json=taskId" json:"task_id,omitempty"`
	FrameworkId *FrameworkID  `protobuf:"bytes,3,req,name=framework_id,json=frameworkId" json:"framework_id,omitempty"`
	ExecutorId  *ExecutorID   `protobuf:"bytes,4,opt,name=executor_id,json=executorId" json:"executor_id,omitempty"`
	AgentId     *AgentID      `protobuf:"bytes,5,req,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	State       *TaskState    `protobuf:"varint,6,req,name=state,enum=mesos.v1.TaskState" json:"state,omitempty"`
	Resources   []*Resource   `protobuf:"bytes,7,rep,name=resources" json:"resources,omitempty"`
	Statuses    []*TaskStatus `protobuf:"bytes,8,rep,name=statuses" json:"statuses,omitempty"`
	// These fields correspond to the state and uuid of the latest
	// status update forwarded to the master.
	// NOTE: Either both the fields must be set or both must be unset.
	StatusUpdateState *TaskState `` /* 132-byte string literal not displayed */
	StatusUpdateUuid  []byte     `protobuf:"bytes,10,opt,name=status_update_uuid,json=statusUpdateUuid" json:"status_update_uuid,omitempty"`
	Labels            *Labels    `protobuf:"bytes,11,opt,name=labels" json:"labels,omitempty"`
	// Service discovery information for the task. It is not interpreted
	// or acted upon by Mesos. It is up to a service discovery system
	// to use this information as needed and to handle tasks without
	// service discovery information.
	Discovery *DiscoveryInfo `protobuf:"bytes,12,opt,name=discovery" json:"discovery,omitempty"`
	// Container information for the task.
	Container *ContainerInfo `protobuf:"bytes,13,opt,name=container" json:"container,omitempty"`
	// Specific user under which task is running.
	User             *string `protobuf:"bytes,14,opt,name=user" json:"user,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Describes a task, similar to `TaskInfo`.

`Task` is used in some of the Mesos messages found below. `Task` is used instead of `TaskInfo` if:

  1. we need additional IDs, such as a specific framework, executor, or agent; or
  2. we do not need the additional data, such as the command run by the task or the health checks. These additional fields may be large and unnecessary for some Mesos messages.

`Task` is generally constructed from a `TaskInfo`. See protobuf::createTask.

func (*Task) Descriptor 

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

func (*Task) GetAgentId 

func (m *Task) GetAgentId() *AgentID

func (*Task) GetContainer 

func (m *Task) GetContainer() *ContainerInfo

func (*Task) GetDiscovery 

func (m *Task) GetDiscovery() *DiscoveryInfo

func (*Task) GetExecutorId 

func (m *Task) GetExecutorId() *ExecutorID

func (*Task) GetFrameworkId 

func (m *Task) GetFrameworkId() *FrameworkID

func (*Task) GetLabels 

func (m *Task) GetLabels() *Labels

func (*Task) GetName 

func (m *Task) GetName() string

func (*Task) GetResources 

func (m *Task) GetResources() []*Resource

func (*Task) GetState 

func (m *Task) GetState() TaskState

func (*Task) GetStatusUpdateState 

func (m *Task) GetStatusUpdateState() TaskState

func (*Task) GetStatusUpdateUuid 

func (m *Task) GetStatusUpdateUuid() []byte

func (*Task) GetStatuses 

func (m *Task) GetStatuses() []*TaskStatus

func (*Task) GetTaskId 

func (m *Task) GetTaskId() *TaskID

func (*Task) GetUser 

func (m *Task) GetUser() string

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) Reset 

func (m *Task) Reset()

func (*Task) String 

func (m *Task) String() string

type TaskGroupInfo 

type TaskGroupInfo struct {
	Tasks            []*TaskInfo `protobuf:"bytes,1,rep,name=tasks" json:"tasks,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

* Describes a group of tasks that belong to an executor. The executor will receive the task group in a single message to allow the group to be launched "atomically".

NOTES:

  1. `NetworkInfo` must not be set inside task's `ContainerInfo`.
  2. `TaskInfo.executor` doesn't need to set. If set, it should match `LaunchGroup.executor`.

func (*TaskGroupInfo) Descriptor 

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

func (*TaskGroupInfo) GetTasks 

func (m *TaskGroupInfo) GetTasks() []*TaskInfo

func (*TaskGroupInfo) ProtoMessage 

func (*TaskGroupInfo) ProtoMessage()

func (*TaskGroupInfo) Reset 

func (m *TaskGroupInfo) Reset()

func (*TaskGroupInfo) String 

func (m *TaskGroupInfo) String() string

type TaskID 

type TaskID struct {
	Value            *string `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* A framework-generated ID to distinguish a task. The ID must remain unique while the task is active. A framework can reuse an ID _only_ if the previous task with the same ID has reached a terminal state (e.g., TASK_FINISHED, TASK_LOST, TASK_KILLED, etc.). However, reusing task IDs is strongly discouraged (MESOS-2198).

func (*TaskID) Descriptor 

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

func (*TaskID) GetValue 

func (m *TaskID) GetValue() string

func (*TaskID) ProtoMessage 

func (*TaskID) ProtoMessage()

func (*TaskID) Reset 

func (m *TaskID) Reset()

func (*TaskID) String 

func (m *TaskID) String() string

type TaskInfo 

type TaskInfo struct {
	Name      *string       `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	TaskId    *TaskID       `protobuf:"bytes,2,req,name=task_id,json=taskId" json:"task_id,omitempty"`
	AgentId   *AgentID      `protobuf:"bytes,3,req,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	Resources []*Resource   `protobuf:"bytes,4,rep,name=resources" json:"resources,omitempty"`
	Executor  *ExecutorInfo `protobuf:"bytes,5,opt,name=executor" json:"executor,omitempty"`
	Command   *CommandInfo  `protobuf:"bytes,7,opt,name=command" json:"command,omitempty"`
	// Task provided with a container will launch the container as part
	// of this task paired with the task's CommandInfo.
	Container *ContainerInfo `protobuf:"bytes,9,opt,name=container" json:"container,omitempty"`
	// A health check for the task. Implemented for executor-less
	// command-based tasks. For tasks that specify an executor, it is
	// the executor's responsibility to implement the health checking.
	HealthCheck *HealthCheck `protobuf:"bytes,8,opt,name=health_check,json=healthCheck" json:"health_check,omitempty"`
	// A kill policy for the task. Implemented for executor-less
	// command-based and docker tasks. For tasks that specify other
	// executor, it is the executor's responsibility to implement
	// the kill policy.
	KillPolicy *KillPolicy `protobuf:"bytes,12,opt,name=kill_policy,json=killPolicy" json:"kill_policy,omitempty"`
	Data       []byte      `protobuf:"bytes,6,opt,name=data" json:"data,omitempty"`
	// Labels are free-form key value pairs which are exposed through
	// master and agent endpoints. Labels will not be interpreted or
	// acted upon by Mesos itself. As opposed to the data field, labels
	// will be kept in memory on master and agent processes. Therefore,
	// labels should be used to tag tasks with light-weight meta-data.
	// Labels should not contain duplicate key-value pairs.
	Labels *Labels `protobuf:"bytes,10,opt,name=labels" json:"labels,omitempty"`
	// Service discovery information for the task. It is not interpreted
	// or acted upon by Mesos. It is up to a service discovery system
	// to use this information as needed and to handle tasks without
	// service discovery information.
	Discovery        *DiscoveryInfo `protobuf:"bytes,11,opt,name=discovery" json:"discovery,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

* Describes a task. Passed from the scheduler all the way to an executor (see SchedulerDriver::launchTasks and Executor::launchTask). Either ExecutorInfo or CommandInfo should be set. A different executor can be used to launch this task, and subsequent tasks meant for the same executor can reuse the same ExecutorInfo struct.

func (*TaskInfo) Descriptor 

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

func (*TaskInfo) GetAgentId 

func (m *TaskInfo) GetAgentId() *AgentID

func (*TaskInfo) GetCommand 

func (m *TaskInfo) GetCommand() *CommandInfo

func (*TaskInfo) GetContainer 

func (m *TaskInfo) GetContainer() *ContainerInfo

func (*TaskInfo) GetData 

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

func (*TaskInfo) GetDiscovery 

func (m *TaskInfo) GetDiscovery() *DiscoveryInfo

func (*TaskInfo) GetExecutor 

func (m *TaskInfo) GetExecutor() *ExecutorInfo

func (*TaskInfo) GetHealthCheck 

func (m *TaskInfo) GetHealthCheck() *HealthCheck

func (*TaskInfo) GetKillPolicy 

func (m *TaskInfo) GetKillPolicy() *KillPolicy

func (*TaskInfo) GetLabels 

func (m *TaskInfo) GetLabels() *Labels

func (*TaskInfo) GetName 

func (m *TaskInfo) GetName() string

func (*TaskInfo) GetResources 

func (m *TaskInfo) GetResources() []*Resource

func (*TaskInfo) GetTaskId 

func (m *TaskInfo) GetTaskId() *TaskID

func (*TaskInfo) ProtoMessage 

func (*TaskInfo) ProtoMessage()

func (*TaskInfo) Reset 

func (m *TaskInfo) Reset()

func (*TaskInfo) String 

func (m *TaskInfo) String() string

type TaskState 

type TaskState int32

* Describes possible task states. IMPORTANT: Mesos assumes tasks that enter terminal states (see below) imply the task is no longer running and thus clean up any thing associated with the task (ultimately offering any resources being consumed by that task to another task). 

const (
	TaskState_TASK_STAGING  TaskState = 6
	TaskState_TASK_STARTING TaskState = 0
	TaskState_TASK_RUNNING  TaskState = 1
	// NOTE: This should only be sent when the framework has
	// the TASK_KILLING_STATE capability.
	TaskState_TASK_KILLING  TaskState = 8
	TaskState_TASK_FINISHED TaskState = 2
	TaskState_TASK_FAILED   TaskState = 3
	TaskState_TASK_KILLED   TaskState = 4
	TaskState_TASK_ERROR    TaskState = 7
	// In Mesos 1.2, this will only be sent when the framework does NOT
	// opt-in to the PARTITION_AWARE capability.
	TaskState_TASK_LOST TaskState = 5
	// The task failed to launch because of a transient error. The
	// task's executor never started running. Unlike TASK_ERROR, the
	// task description is valid -- attempting to launch the task again
	// may be successful.
	TaskState_TASK_DROPPED TaskState = 9
	// The task was running on an agent that has lost contact with the
	// master, typically due to a network failure or partition. The task
	// may or may not still be running.
	TaskState_TASK_UNREACHABLE TaskState = 10
	// The task was running on an agent that has been shutdown (e.g.,
	// the agent become partitioned, rebooted, and then reconnected to
	// the master; any tasks running before the reboot will transition
	// from UNREACHABLE to GONE). The task is no longer running.
	TaskState_TASK_GONE TaskState = 11
	// The task was running on an agent that the master cannot contact;
	// the operator has asserted that the agent has been shutdown, but
	// this has not been directly confirmed by the master. If the
	// operator is correct, the task is not running and this is a
	// terminal state; if the operator is mistaken, the task may still
	// be running and might return to RUNNING in the future.
	TaskState_TASK_GONE_BY_OPERATOR TaskState = 12
	// The master has no knowledge of the task. This is typically
	// because either (a) the master never had knowledge of the task, or
	// (b) the master forgot about the task because it garbage collected
	// its metadata about the task. The task may or may not still be
	// running.
	TaskState_TASK_UNKNOWN TaskState = 13
)

func (TaskState) Enum 

func (x TaskState) Enum() *TaskState

func (TaskState) EnumDescriptor 

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

func (TaskState) String 

func (x TaskState) String() string

func (*TaskState) UnmarshalJSON 

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

type TaskStatus 

type TaskStatus struct {
	TaskId     *TaskID            `protobuf:"bytes,1,req,name=task_id,json=taskId" json:"task_id,omitempty"`
	State      *TaskState         `protobuf:"varint,2,req,name=state,enum=mesos.v1.TaskState" json:"state,omitempty"`
	Message    *string            `protobuf:"bytes,4,opt,name=message" json:"message,omitempty"`
	Source     *TaskStatus_Source `protobuf:"varint,9,opt,name=source,enum=mesos.v1.TaskStatus_Source" json:"source,omitempty"`
	Reason     *TaskStatus_Reason `protobuf:"varint,10,opt,name=reason,enum=mesos.v1.TaskStatus_Reason" json:"reason,omitempty"`
	Data       []byte             `protobuf:"bytes,3,opt,name=data" json:"data,omitempty"`
	AgentId    *AgentID           `protobuf:"bytes,5,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	ExecutorId *ExecutorID        `protobuf:"bytes,7,opt,name=executor_id,json=executorId" json:"executor_id,omitempty"`
	Timestamp  *float64           `protobuf:"fixed64,6,opt,name=timestamp" json:"timestamp,omitempty"`
	// Statuses that are delivered reliably to the scheduler will
	// include a 'uuid'. The status is considered delivered once
	// it is acknowledged by the scheduler. Schedulers can choose
	// to either explicitly acknowledge statuses or let the scheduler
	// driver implicitly acknowledge (default).
	//
	// TODO(bmahler): This is currently overwritten in the scheduler
	// driver and executor driver, but executors will need to set this
	// to a valid RFC-4122 UUID if using the HTTP API.
	Uuid []byte `protobuf:"bytes,11,opt,name=uuid" json:"uuid,omitempty"`
	// Describes whether the task has been determined to be healthy
	// (true) or unhealthy (false) according to the HealthCheck field in
	// the command info.
	Healthy *bool `protobuf:"varint,8,opt,name=healthy" json:"healthy,omitempty"`
	// Labels are free-form key value pairs which are exposed through
	// master and agent endpoints. Labels will not be interpreted or
	// acted upon by Mesos itself. As opposed to the data field, labels
	// will be kept in memory on master and agent processes. Therefore,
	// labels should be used to tag TaskStatus message with light-weight
	// meta-data.  Labels should not contain duplicate key-value pairs.
	Labels *Labels `protobuf:"bytes,12,opt,name=labels" json:"labels,omitempty"`
	// Container related information that is resolved dynamically such as
	// network address.
	ContainerStatus *ContainerStatus `protobuf:"bytes,13,opt,name=container_status,json=containerStatus" json:"container_status,omitempty"`
	// The time (according to the master's clock) when the agent where
	// this task was running became unreachable. This is only set on
	// status updates for tasks running on agents that are unreachable
	// (e.g., partitioned away from the master).
	UnreachableTime  *TimeInfo `protobuf:"bytes,14,opt,name=unreachable_time,json=unreachableTime" json:"unreachable_time,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

* Describes the current status of a task.

func (*TaskStatus) Descriptor 

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

func (*TaskStatus) GetAgentId 

func (m *TaskStatus) GetAgentId() *AgentID

func (*TaskStatus) GetContainerStatus 

func (m *TaskStatus) GetContainerStatus() *ContainerStatus

func (*TaskStatus) GetData 

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

func (*TaskStatus) GetExecutorId 

func (m *TaskStatus) GetExecutorId() *ExecutorID

func (*TaskStatus) GetHealthy 

func (m *TaskStatus) GetHealthy() bool

func (*TaskStatus) GetLabels 

func (m *TaskStatus) GetLabels() *Labels

func (*TaskStatus) GetMessage 

func (m *TaskStatus) GetMessage() string

func (*TaskStatus) GetReason 

func (m *TaskStatus) GetReason() TaskStatus_Reason

func (*TaskStatus) GetSource 

func (m *TaskStatus) GetSource() TaskStatus_Source

func (*TaskStatus) GetState 

func (m *TaskStatus) GetState() TaskState

func (*TaskStatus) GetTaskId 

func (m *TaskStatus) GetTaskId() *TaskID

func (*TaskStatus) GetTimestamp 

func (m *TaskStatus) GetTimestamp() float64

func (*TaskStatus) GetUnreachableTime 

func (m *TaskStatus) GetUnreachableTime() *TimeInfo

func (*TaskStatus) GetUuid 

func (m *TaskStatus) GetUuid() []byte

func (*TaskStatus) ProtoMessage 

func (*TaskStatus) ProtoMessage()

func (*TaskStatus) Reset 

func (m *TaskStatus) Reset()

func (*TaskStatus) String 

func (m *TaskStatus) String() string

type TaskStatus_Reason 

type TaskStatus_Reason int32

Detailed reason for the task status update.

TODO(bmahler): Differentiate between agent removal reasons (e.g. unhealthy vs. unregistered for maintenance). 

const (
	// TODO(jieyu): The default value when a caller doesn't check for
	// presence is 0 and so ideally the 0 reason is not a valid one.
	// Since this is not used anywhere, consider removing this reason.
	TaskStatus_REASON_COMMAND_EXECUTOR_FAILED         TaskStatus_Reason = 0
	TaskStatus_REASON_CONTAINER_LAUNCH_FAILED         TaskStatus_Reason = 21
	TaskStatus_REASON_CONTAINER_LIMITATION            TaskStatus_Reason = 19
	TaskStatus_REASON_CONTAINER_LIMITATION_DISK       TaskStatus_Reason = 20
	TaskStatus_REASON_CONTAINER_LIMITATION_MEMORY     TaskStatus_Reason = 8
	TaskStatus_REASON_CONTAINER_PREEMPTED             TaskStatus_Reason = 17
	TaskStatus_REASON_CONTAINER_UPDATE_FAILED         TaskStatus_Reason = 22
	TaskStatus_REASON_EXECUTOR_REGISTRATION_TIMEOUT   TaskStatus_Reason = 23
	TaskStatus_REASON_EXECUTOR_REREGISTRATION_TIMEOUT TaskStatus_Reason = 24
	TaskStatus_REASON_EXECUTOR_TERMINATED             TaskStatus_Reason = 1
	TaskStatus_REASON_EXECUTOR_UNREGISTERED           TaskStatus_Reason = 2
	TaskStatus_REASON_FRAMEWORK_REMOVED               TaskStatus_Reason = 3
	TaskStatus_REASON_GC_ERROR                        TaskStatus_Reason = 4
	TaskStatus_REASON_INVALID_FRAMEWORKID             TaskStatus_Reason = 5
	TaskStatus_REASON_INVALID_OFFERS                  TaskStatus_Reason = 6
	TaskStatus_REASON_MASTER_DISCONNECTED             TaskStatus_Reason = 7
	TaskStatus_REASON_RECONCILIATION                  TaskStatus_Reason = 9
	TaskStatus_REASON_RESOURCES_UNKNOWN               TaskStatus_Reason = 18
	TaskStatus_REASON_AGENT_DISCONNECTED              TaskStatus_Reason = 10
	TaskStatus_REASON_AGENT_REMOVED                   TaskStatus_Reason = 11
	TaskStatus_REASON_AGENT_RESTARTED                 TaskStatus_Reason = 12
	TaskStatus_REASON_AGENT_UNKNOWN                   TaskStatus_Reason = 13
	TaskStatus_REASON_TASK_GROUP_INVALID              TaskStatus_Reason = 25
	TaskStatus_REASON_TASK_GROUP_UNAUTHORIZED         TaskStatus_Reason = 26
	TaskStatus_REASON_TASK_INVALID                    TaskStatus_Reason = 14
	TaskStatus_REASON_TASK_UNAUTHORIZED               TaskStatus_Reason = 15
	TaskStatus_REASON_TASK_UNKNOWN                    TaskStatus_Reason = 16
)

func (TaskStatus_Reason) Enum 

func (x TaskStatus_Reason) Enum() *TaskStatus_Reason

func (TaskStatus_Reason) EnumDescriptor 

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

func (TaskStatus_Reason) String 

func (x TaskStatus_Reason) String() string

func (*TaskStatus_Reason) UnmarshalJSON 

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

type TaskStatus_Source 

type TaskStatus_Source int32

Describes the source of the task status update. 

const (
	TaskStatus_SOURCE_MASTER   TaskStatus_Source = 0
	TaskStatus_SOURCE_AGENT    TaskStatus_Source = 1
	TaskStatus_SOURCE_EXECUTOR TaskStatus_Source = 2
)

func (TaskStatus_Source) Enum 

func (x TaskStatus_Source) Enum() *TaskStatus_Source

func (TaskStatus_Source) EnumDescriptor 

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

func (TaskStatus_Source) String 

func (x TaskStatus_Source) String() string

func (*TaskStatus_Source) UnmarshalJSON 

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

type TcpStatistics 

type TcpStatistics struct {
	RtoAlgorithm     *int64 `protobuf:"varint,1,opt,name=RtoAlgorithm" json:"RtoAlgorithm,omitempty"`
	RtoMin           *int64 `protobuf:"varint,2,opt,name=RtoMin" json:"RtoMin,omitempty"`
	RtoMax           *int64 `protobuf:"varint,3,opt,name=RtoMax" json:"RtoMax,omitempty"`
	MaxConn          *int64 `protobuf:"varint,4,opt,name=MaxConn" json:"MaxConn,omitempty"`
	ActiveOpens      *int64 `protobuf:"varint,5,opt,name=ActiveOpens" json:"ActiveOpens,omitempty"`
	PassiveOpens     *int64 `protobuf:"varint,6,opt,name=PassiveOpens" json:"PassiveOpens,omitempty"`
	AttemptFails     *int64 `protobuf:"varint,7,opt,name=AttemptFails" json:"AttemptFails,omitempty"`
	EstabResets      *int64 `protobuf:"varint,8,opt,name=EstabResets" json:"EstabResets,omitempty"`
	CurrEstab        *int64 `protobuf:"varint,9,opt,name=CurrEstab" json:"CurrEstab,omitempty"`
	InSegs           *int64 `protobuf:"varint,10,opt,name=InSegs" json:"InSegs,omitempty"`
	OutSegs          *int64 `protobuf:"varint,11,opt,name=OutSegs" json:"OutSegs,omitempty"`
	RetransSegs      *int64 `protobuf:"varint,12,opt,name=RetransSegs" json:"RetransSegs,omitempty"`
	InErrs           *int64 `protobuf:"varint,13,opt,name=InErrs" json:"InErrs,omitempty"`
	OutRsts          *int64 `protobuf:"varint,14,opt,name=OutRsts" json:"OutRsts,omitempty"`
	InCsumErrors     *int64 `protobuf:"varint,15,opt,name=InCsumErrors" json:"InCsumErrors,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TcpStatistics) Descriptor 

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

func (*TcpStatistics) GetActiveOpens 

func (m *TcpStatistics) GetActiveOpens() int64

func (*TcpStatistics) GetAttemptFails 

func (m *TcpStatistics) GetAttemptFails() int64

func (*TcpStatistics) GetCurrEstab 

func (m *TcpStatistics) GetCurrEstab() int64

func (*TcpStatistics) GetEstabResets 

func (m *TcpStatistics) GetEstabResets() int64

func (*TcpStatistics) GetInCsumErrors 

func (m *TcpStatistics) GetInCsumErrors() int64

func (*TcpStatistics) GetInErrs 

func (m *TcpStatistics) GetInErrs() int64

func (*TcpStatistics) GetInSegs 

func (m *TcpStatistics) GetInSegs() int64

func (*TcpStatistics) GetMaxConn 

func (m *TcpStatistics) GetMaxConn() int64

func (*TcpStatistics) GetOutRsts 

func (m *TcpStatistics) GetOutRsts() int64

func (*TcpStatistics) GetOutSegs 

func (m *TcpStatistics) GetOutSegs() int64

func (*TcpStatistics) GetPassiveOpens 

func (m *TcpStatistics) GetPassiveOpens() int64

func (*TcpStatistics) GetRetransSegs 

func (m *TcpStatistics) GetRetransSegs() int64

func (*TcpStatistics) GetRtoAlgorithm 

func (m *TcpStatistics) GetRtoAlgorithm() int64

func (*TcpStatistics) GetRtoMax 

func (m *TcpStatistics) GetRtoMax() int64

func (*TcpStatistics) GetRtoMin 

func (m *TcpStatistics) GetRtoMin() int64

func (*TcpStatistics) ProtoMessage 

func (*TcpStatistics) ProtoMessage()

func (*TcpStatistics) Reset 

func (m *TcpStatistics) Reset()

func (*TcpStatistics) String 

func (m *TcpStatistics) String() string

type TimeInfo 

type TimeInfo struct {
	Nanoseconds      *int64 `protobuf:"varint,1,req,name=nanoseconds" json:"nanoseconds,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

* Represents time since the epoch, in nanoseconds.

func (*TimeInfo) Descriptor 

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

func (*TimeInfo) GetNanoseconds 

func (m *TimeInfo) GetNanoseconds() int64

func (*TimeInfo) ProtoMessage 

func (*TimeInfo) ProtoMessage()

func (*TimeInfo) Reset 

func (m *TimeInfo) Reset()

func (*TimeInfo) String 

func (m *TimeInfo) String() string

type TrafficControlStatistics 

type TrafficControlStatistics struct {
	Id               *string `protobuf:"bytes,1,req,name=id" json:"id,omitempty"`
	Backlog          *uint64 `protobuf:"varint,2,opt,name=backlog" json:"backlog,omitempty"`
	Bytes            *uint64 `protobuf:"varint,3,opt,name=bytes" json:"bytes,omitempty"`
	Drops            *uint64 `protobuf:"varint,4,opt,name=drops" json:"drops,omitempty"`
	Overlimits       *uint64 `protobuf:"varint,5,opt,name=overlimits" json:"overlimits,omitempty"`
	Packets          *uint64 `protobuf:"varint,6,opt,name=packets" json:"packets,omitempty"`
	Qlen             *uint64 `protobuf:"varint,7,opt,name=qlen" json:"qlen,omitempty"`
	Ratebps          *uint64 `protobuf:"varint,8,opt,name=ratebps" json:"ratebps,omitempty"`
	Ratepps          *uint64 `protobuf:"varint,9,opt,name=ratepps" json:"ratepps,omitempty"`
	Requeues         *uint64 `protobuf:"varint,10,opt,name=requeues" json:"requeues,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* When the network bandwidth caps are enabled and the container is over its limit, outbound packets may be either delayed or dropped completely either because it exceeds the maximum bandwidth allocation for a single container (the cap) or because the combined network traffic of multiple containers on the host exceeds the transmit capacity of the host (the share). We can report the following statistics for each of these conditions exported directly from the Linux Traffic Control Queueing Discipline.

id : name of the limiter, e.g. 'tx_bw_cap' backlog : number of packets currently delayed bytes : total bytes seen drops : number of packets dropped in total overlimits : number of packets which exceeded allocation packets : total packets seen qlen : number of packets currently queued rate_bps : throughput in bytes/sec rate_pps : throughput in packets/sec requeues : number of times a packet has been delayed due to 

locking or device contention issues

More information on the operation of Linux Traffic Control can be found at http://www.lartc.org/lartc.html.

func (*TrafficControlStatistics) Descriptor 

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

func (*TrafficControlStatistics) GetBacklog 

func (m *TrafficControlStatistics) GetBacklog() uint64

func (*TrafficControlStatistics) GetBytes 

func (m *TrafficControlStatistics) GetBytes() uint64

func (*TrafficControlStatistics) GetDrops 

func (m *TrafficControlStatistics) GetDrops() uint64

func (*TrafficControlStatistics) GetId 

func (m *TrafficControlStatistics) GetId() string

func (*TrafficControlStatistics) GetOverlimits 

func (m *TrafficControlStatistics) GetOverlimits() uint64

func (*TrafficControlStatistics) GetPackets 

func (m *TrafficControlStatistics) GetPackets() uint64

func (*TrafficControlStatistics) GetQlen 

func (m *TrafficControlStatistics) GetQlen() uint64

func (*TrafficControlStatistics) GetRatebps 

func (m *TrafficControlStatistics) GetRatebps() uint64

func (*TrafficControlStatistics) GetRatepps 

func (m *TrafficControlStatistics) GetRatepps() uint64

func (*TrafficControlStatistics) GetRequeues 

func (m *TrafficControlStatistics) GetRequeues() uint64

func (*TrafficControlStatistics) ProtoMessage 

func (*TrafficControlStatistics) ProtoMessage()

func (*TrafficControlStatistics) Reset 

func (m *TrafficControlStatistics) Reset()

func (*TrafficControlStatistics) String 

func (m *TrafficControlStatistics) String() string

type URL 

type URL struct {
	Scheme           *string      `protobuf:"bytes,1,req,name=scheme" json:"scheme,omitempty"`
	Address          *Address     `protobuf:"bytes,2,req,name=address" json:"address,omitempty"`
	Path             *string      `protobuf:"bytes,3,opt,name=path" json:"path,omitempty"`
	Query            []*Parameter `protobuf:"bytes,4,rep,name=query" json:"query,omitempty"`
	Fragment         *string      `protobuf:"bytes,5,opt,name=fragment" json:"fragment,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

* Represents a URL.

func (*URL) Descriptor 

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

func (*URL) GetAddress 

func (m *URL) GetAddress() *Address

func (*URL) GetFragment 

func (m *URL) GetFragment() string

func (*URL) GetPath 

func (m *URL) GetPath() string

func (*URL) GetQuery 

func (m *URL) GetQuery() []*Parameter

func (*URL) GetScheme 

func (m *URL) GetScheme() string

func (*URL) ProtoMessage 

func (*URL) ProtoMessage()

func (*URL) Reset 

func (m *URL) Reset()

func (*URL) String 

func (m *URL) String() string

type UdpStatistics 

type UdpStatistics struct {
	InDatagrams      *int64 `protobuf:"varint,1,opt,name=InDatagrams" json:"InDatagrams,omitempty"`
	NoPorts          *int64 `protobuf:"varint,2,opt,name=NoPorts" json:"NoPorts,omitempty"`
	InErrors         *int64 `protobuf:"varint,3,opt,name=InErrors" json:"InErrors,omitempty"`
	OutDatagrams     *int64 `protobuf:"varint,4,opt,name=OutDatagrams" json:"OutDatagrams,omitempty"`
	RcvbufErrors     *int64 `protobuf:"varint,5,opt,name=RcvbufErrors" json:"RcvbufErrors,omitempty"`
	SndbufErrors     *int64 `protobuf:"varint,6,opt,name=SndbufErrors" json:"SndbufErrors,omitempty"`
	InCsumErrors     *int64 `protobuf:"varint,7,opt,name=InCsumErrors" json:"InCsumErrors,omitempty"`
	IgnoredMulti     *int64 `protobuf:"varint,8,opt,name=IgnoredMulti" json:"IgnoredMulti,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*UdpStatistics) Descriptor 

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

func (*UdpStatistics) GetIgnoredMulti 

func (m *UdpStatistics) GetIgnoredMulti() int64

func (*UdpStatistics) GetInCsumErrors 

func (m *UdpStatistics) GetInCsumErrors() int64

func (*UdpStatistics) GetInDatagrams 

func (m *UdpStatistics) GetInDatagrams() int64

func (*UdpStatistics) GetInErrors 

func (m *UdpStatistics) GetInErrors() int64

func (*UdpStatistics) GetNoPorts 

func (m *UdpStatistics) GetNoPorts() int64

func (*UdpStatistics) GetOutDatagrams 

func (m *UdpStatistics) GetOutDatagrams() int64

func (*UdpStatistics) GetRcvbufErrors 

func (m *UdpStatistics) GetRcvbufErrors() int64

func (*UdpStatistics) GetSndbufErrors 

func (m *UdpStatistics) GetSndbufErrors() int64

func (*UdpStatistics) ProtoMessage 

func (*UdpStatistics) ProtoMessage()

func (*UdpStatistics) Reset 

func (m *UdpStatistics) Reset()

func (*UdpStatistics) String 

func (m *UdpStatistics) String() string

type Unavailability 

type Unavailability struct {
	Start *TimeInfo `protobuf:"bytes,1,req,name=start" json:"start,omitempty"`
	// When added to `start`, this represents the end of the interval.
	// If unspecified, the duration is assumed to be infinite.
	Duration         *DurationInfo `protobuf:"bytes,2,opt,name=duration" json:"duration,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

* Represents an interval, from a given start time over a given duration. This interval pertains to an unavailability event, such as maintenance, and is not a generic interval.

func (*Unavailability) Descriptor 

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

func (*Unavailability) GetDuration 

func (m *Unavailability) GetDuration() *DurationInfo

func (*Unavailability) GetStart 

func (m *Unavailability) GetStart() *TimeInfo

func (*Unavailability) ProtoMessage 

func (*Unavailability) ProtoMessage()

func (*Unavailability) Reset 

func (m *Unavailability) Reset()

func (*Unavailability) String 

func (m *Unavailability) String() string

type Value 

type Value struct {
	Type             *Value_Type   `protobuf:"varint,1,req,name=type,enum=mesos.v1.Value_Type" json:"type,omitempty"`
	Scalar           *Value_Scalar `protobuf:"bytes,2,opt,name=scalar" json:"scalar,omitempty"`
	Ranges           *Value_Ranges `protobuf:"bytes,3,opt,name=ranges" json:"ranges,omitempty"`
	Set              *Value_Set    `protobuf:"bytes,4,opt,name=set" json:"set,omitempty"`
	Text             *Value_Text   `protobuf:"bytes,5,opt,name=text" json:"text,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

* Describes an Attribute or Resource "value". A value is described using the standard protocol buffer "union" trick.

func (*Value) Descriptor 

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

func (*Value) GetRanges 

func (m *Value) GetRanges() *Value_Ranges

func (*Value) GetScalar 

func (m *Value) GetScalar() *Value_Scalar

func (*Value) GetSet 

func (m *Value) GetSet() *Value_Set

func (*Value) GetText 

func (m *Value) GetText() *Value_Text

func (*Value) GetType 

func (m *Value) GetType() Value_Type

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) Reset 

func (m *Value) Reset()

func (*Value) String 

func (m *Value) String() string

type Value_Range 

type Value_Range struct {
	Begin            *uint64 `protobuf:"varint,1,req,name=begin" json:"begin,omitempty"`
	End              *uint64 `protobuf:"varint,2,req,name=end" json:"end,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Value_Range) Descriptor 

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

func (*Value_Range) GetBegin 

func (m *Value_Range) GetBegin() uint64

func (*Value_Range) GetEnd 

func (m *Value_Range) GetEnd() uint64

func (*Value_Range) ProtoMessage 

func (*Value_Range) ProtoMessage()

func (*Value_Range) Reset 

func (m *Value_Range) Reset()

func (*Value_Range) String 

func (m *Value_Range) String() string

type Value_Ranges 

type Value_Ranges struct {
	Range            []*Value_Range `protobuf:"bytes,1,rep,name=range" json:"range,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*Value_Ranges) Descriptor 

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

func (*Value_Ranges) GetRange 

func (m *Value_Ranges) GetRange() []*Value_Range

func (*Value_Ranges) ProtoMessage 

func (*Value_Ranges) ProtoMessage()

func (*Value_Ranges) Reset 

func (m *Value_Ranges) Reset()

func (*Value_Ranges) String 

func (m *Value_Ranges) String() string

type Value_Scalar 

type Value_Scalar struct {
	// Scalar values are represented using floating point. To reduce
	// the chance of unpredictable floating point behavior due to
	// roundoff error, Mesos only supports three decimal digits of
	// precision for scalar resource values. That is, floating point
	// values are converted to a fixed point format that supports
	// three decimal digits of precision, and then converted back to
	// floating point on output. Any additional precision in scalar
	// resource values is discarded (via rounding).
	Value            *float64 `protobuf:"fixed64,1,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*Value_Scalar) Descriptor 

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

func (*Value_Scalar) GetValue 

func (m *Value_Scalar) GetValue() float64

func (*Value_Scalar) ProtoMessage 

func (*Value_Scalar) ProtoMessage()

func (*Value_Scalar) Reset 

func (m *Value_Scalar) Reset()

func (*Value_Scalar) String 

func (m *Value_Scalar) String() string

type Value_Set 

type Value_Set struct {
	Item             []string `protobuf:"bytes,1,rep,name=item" json:"item,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*Value_Set) Descriptor 

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

func (*Value_Set) GetItem 

func (m *Value_Set) GetItem() []string

func (*Value_Set) ProtoMessage 

func (*Value_Set) ProtoMessage()

func (*Value_Set) Reset 

func (m *Value_Set) Reset()

func (*Value_Set) String 

func (m *Value_Set) String() string

type Value_Text 

type Value_Text struct {
	Value            *string `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Value_Text) Descriptor 

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

func (*Value_Text) GetValue 

func (m *Value_Text) GetValue() string

func (*Value_Text) ProtoMessage 

func (*Value_Text) ProtoMessage()

func (*Value_Text) Reset 

func (m *Value_Text) Reset()

func (*Value_Text) String 

func (m *Value_Text) String() string

type Value_Type 

type Value_Type int32
const (
	Value_SCALAR Value_Type = 0
	Value_RANGES Value_Type = 1
	Value_SET    Value_Type = 2
	Value_TEXT   Value_Type = 3
)

func (Value_Type) Enum 

func (x Value_Type) Enum() *Value_Type

func (Value_Type) EnumDescriptor 

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

func (Value_Type) String 

func (x Value_Type) String() string

func (*Value_Type) UnmarshalJSON 

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

type VersionInfo 

type VersionInfo struct {
	Version          *string  `protobuf:"bytes,1,req,name=version" json:"version,omitempty"`
	BuildDate        *string  `protobuf:"bytes,2,opt,name=build_date,json=buildDate" json:"build_date,omitempty"`
	BuildTime        *float64 `protobuf:"fixed64,3,opt,name=build_time,json=buildTime" json:"build_time,omitempty"`
	BuildUser        *string  `protobuf:"bytes,4,opt,name=build_user,json=buildUser" json:"build_user,omitempty"`
	GitSha           *string  `protobuf:"bytes,5,opt,name=git_sha,json=gitSha" json:"git_sha,omitempty"`
	GitBranch        *string  `protobuf:"bytes,6,opt,name=git_branch,json=gitBranch" json:"git_branch,omitempty"`
	GitTag           *string  `protobuf:"bytes,7,opt,name=git_tag,json=gitTag" json:"git_tag,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

* Version information of a component.

func (*VersionInfo) Descriptor 

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

func (*VersionInfo) GetBuildDate 

func (m *VersionInfo) GetBuildDate() string

func (*VersionInfo) GetBuildTime 

func (m *VersionInfo) GetBuildTime() float64

func (*VersionInfo) GetBuildUser 

func (m *VersionInfo) GetBuildUser() string

func (*VersionInfo) GetGitBranch 

func (m *VersionInfo) GetGitBranch() string

func (*VersionInfo) GetGitSha 

func (m *VersionInfo) GetGitSha() string

func (*VersionInfo) GetGitTag 

func (m *VersionInfo) GetGitTag() string

func (*VersionInfo) GetVersion 

func (m *VersionInfo) GetVersion() string

func (*VersionInfo) ProtoMessage 

func (*VersionInfo) ProtoMessage()

func (*VersionInfo) Reset 

func (m *VersionInfo) Reset()

func (*VersionInfo) String 

func (m *VersionInfo) String() string

type Volume 

type Volume struct {
	// TODO(gyliu513): Make this as `optional` after deprecation cycle of 1.0.
	Mode *Volume_Mode `protobuf:"varint,3,req,name=mode,enum=mesos.v1.Volume_Mode" json:"mode,omitempty"`
	// Path pointing to a directory or file in the container. If the
	// path is a relative path, it is relative to the container work
	// directory. If the path is an absolute path, that path must
	// already exist.
	ContainerPath *string `protobuf:"bytes,1,req,name=container_path,json=containerPath" json:"container_path,omitempty"`
	// Absolute path pointing to a directory or file on the host or a
	// path relative to the container work directory.
	HostPath *string `protobuf:"bytes,2,opt,name=host_path,json=hostPath" json:"host_path,omitempty"`
	// The source of the volume is an Image which describes a root
	// filesystem which will be provisioned by Mesos.
	Image            *Image         `protobuf:"bytes,4,opt,name=image" json:"image,omitempty"`
	Source           *Volume_Source `protobuf:"bytes,5,opt,name=source" json:"source,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

* Describes a volume mapping either from host to container or vice versa. Both paths can either refer to a directory or a file.

func (*Volume) Descriptor 

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

func (*Volume) GetContainerPath 

func (m *Volume) GetContainerPath() string

func (*Volume) GetHostPath 

func (m *Volume) GetHostPath() string

func (*Volume) GetImage 

func (m *Volume) GetImage() *Image

func (*Volume) GetMode 

func (m *Volume) GetMode() Volume_Mode

func (*Volume) GetSource 

func (m *Volume) GetSource() *Volume_Source

func (*Volume) ProtoMessage 

func (*Volume) ProtoMessage()

func (*Volume) Reset 

func (m *Volume) Reset()

func (*Volume) String 

func (m *Volume) String() string

type Volume_Mode 

type Volume_Mode int32
const (
	Volume_RW Volume_Mode = 1
	Volume_RO Volume_Mode = 2
)

func (Volume_Mode) Enum 

func (x Volume_Mode) Enum() *Volume_Mode

func (Volume_Mode) EnumDescriptor 

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

func (Volume_Mode) String 

func (x Volume_Mode) String() string

func (*Volume_Mode) UnmarshalJSON 

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

type Volume_Source 

type Volume_Source struct {
	// Enum fields should be optional, see: MESOS-4997.
	Type *Volume_Source_Type `protobuf:"varint,1,opt,name=type,enum=mesos.v1.Volume_Source_Type" json:"type,omitempty"`
	// The source of the volume created by docker volume driver.
	DockerVolume     *Volume_Source_DockerVolume `protobuf:"bytes,2,opt,name=docker_volume,json=dockerVolume" json:"docker_volume,omitempty"`
	SandboxPath      *Volume_Source_SandboxPath  `protobuf:"bytes,3,opt,name=sandbox_path,json=sandboxPath" json:"sandbox_path,omitempty"`
	XXX_unrecognized []byte                      `json:"-"`
}

Describes where a volume originates from.

func (*Volume_Source) Descriptor 

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

func (*Volume_Source) GetDockerVolume 

func (m *Volume_Source) GetDockerVolume() *Volume_Source_DockerVolume

func (*Volume_Source) GetSandboxPath 

func (m *Volume_Source) GetSandboxPath() *Volume_Source_SandboxPath

func (*Volume_Source) GetType 

func (m *Volume_Source) GetType() Volume_Source_Type

func (*Volume_Source) ProtoMessage 

func (*Volume_Source) ProtoMessage()

func (*Volume_Source) Reset 

func (m *Volume_Source) Reset()

func (*Volume_Source) String 

func (m *Volume_Source) String() string

type Volume_Source_DockerVolume 

type Volume_Source_DockerVolume struct {
	// Driver of the volume, it can be flocker, convoy, raxrey etc.
	Driver *string `protobuf:"bytes,1,opt,name=driver" json:"driver,omitempty"`
	// Name of the volume.
	Name *string `protobuf:"bytes,2,req,name=name" json:"name,omitempty"`
	// Volume driver specific options.
	DriverOptions    *Parameters `protobuf:"bytes,3,opt,name=driver_options,json=driverOptions" json:"driver_options,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*Volume_Source_DockerVolume) Descriptor 

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

func (*Volume_Source_DockerVolume) GetDriver 

func (m *Volume_Source_DockerVolume) GetDriver() string

func (*Volume_Source_DockerVolume) GetDriverOptions 

func (m *Volume_Source_DockerVolume) GetDriverOptions() *Parameters

func (*Volume_Source_DockerVolume) GetName 

func (m *Volume_Source_DockerVolume) GetName() string

func (*Volume_Source_DockerVolume) ProtoMessage 

func (*Volume_Source_DockerVolume) ProtoMessage()

func (*Volume_Source_DockerVolume) Reset 

func (m *Volume_Source_DockerVolume) Reset()

func (*Volume_Source_DockerVolume) String 

func (m *Volume_Source_DockerVolume) String() string

type Volume_Source_SandboxPath 

type Volume_Source_SandboxPath struct {
	Type *Volume_Source_SandboxPath_Type `protobuf:"varint,1,opt,name=type,enum=mesos.v1.Volume_Source_SandboxPath_Type" json:"type,omitempty"`
	// A path relative to the corresponding container's sandbox.
	// Note that upwards traversal (i.e. ../../abc) is not allowed.
	Path             *string `protobuf:"bytes,2,req,name=path" json:"path,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Describe a path from a container's sandbox. The container can be the current container (SELF), or its parent container (PARENT). PARENT allows all child containers to share a volume from their parent container's sandbox. It'll be an error if the current container is a top level container.

func (*Volume_Source_SandboxPath) Descriptor 

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

func (*Volume_Source_SandboxPath) GetPath 

func (m *Volume_Source_SandboxPath) GetPath() string

func (*Volume_Source_SandboxPath) GetType 

func (m *Volume_Source_SandboxPath) GetType() Volume_Source_SandboxPath_Type

func (*Volume_Source_SandboxPath) ProtoMessage 

func (*Volume_Source_SandboxPath) ProtoMessage()

func (*Volume_Source_SandboxPath) Reset 

func (m *Volume_Source_SandboxPath) Reset()

func (*Volume_Source_SandboxPath) String 

func (m *Volume_Source_SandboxPath) String() string

type Volume_Source_SandboxPath_Type 

type Volume_Source_SandboxPath_Type int32
const (
	Volume_Source_SandboxPath_UNKNOWN Volume_Source_SandboxPath_Type = 0
	Volume_Source_SandboxPath_SELF    Volume_Source_SandboxPath_Type = 1
	Volume_Source_SandboxPath_PARENT  Volume_Source_SandboxPath_Type = 2
)

func (Volume_Source_SandboxPath_Type) Enum 

func (x Volume_Source_SandboxPath_Type) Enum() *Volume_Source_SandboxPath_Type

func (Volume_Source_SandboxPath_Type) EnumDescriptor 

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

func (Volume_Source_SandboxPath_Type) String 

func (x Volume_Source_SandboxPath_Type) String() string

func (*Volume_Source_SandboxPath_Type) UnmarshalJSON 

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

type Volume_Source_Type 

type Volume_Source_Type int32
const (
	// This must be the first enum value in this list, to
	// ensure that if 'type' is not set, the default value
	// is UNKNOWN. This enables enum values to be added
	// in a backwards-compatible way. See: MESOS-4997.
	Volume_Source_UNKNOWN Volume_Source_Type = 0
	// TODO(gyliu513): Add HOST_PATH and IMAGE as volume source type.
	Volume_Source_DOCKER_VOLUME Volume_Source_Type = 1
	Volume_Source_SANDBOX_PATH  Volume_Source_Type = 2
)

func (Volume_Source_Type) Enum 

func (x Volume_Source_Type) Enum() *Volume_Source_Type

func (Volume_Source_Type) EnumDescriptor 

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

func (Volume_Source_Type) String 

func (x Volume_Source_Type) String() string

func (*Volume_Source_Type) UnmarshalJSON 

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

type WeightInfo 

type WeightInfo struct {
	Weight *float64 `protobuf:"fixed64,1,req,name=weight" json:"weight,omitempty"`
	// Related role name.
	Role             *string `protobuf:"bytes,2,opt,name=role" json:"role,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Named WeightInfo to indicate resource allocation priority between the different roles.

func (*WeightInfo) Descriptor 

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

func (*WeightInfo) GetRole 

func (m *WeightInfo) GetRole() string

func (*WeightInfo) GetWeight 

func (m *WeightInfo) GetWeight() float64

func (*WeightInfo) ProtoMessage 

func (*WeightInfo) ProtoMessage()

func (*WeightInfo) Reset 

func (m *WeightInfo) Reset()

func (*WeightInfo) String 

func (m *WeightInfo) String() string

Source Files

View all Source files

Directories

Path Synopsis
Package mesos_allocator is a generated protocol buffer package.
 Package mesos_allocator is a generated protocol buffer package.
Package mesos_maintenance is a generated protocol buffer package.
 Package mesos_maintenance is a generated protocol buffer package.
Package mesos_master is a generated protocol buffer package.
 Package mesos_master is a generated protocol buffer package.
Package mesos_quota is a generated protocol buffer package.
 Package mesos_quota is a generated protocol buffer package.

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.