Documentation
¶
Overview ¶
Package marathon is a generated protocol buffer package.
protoc --java_out=src/main/java/ --proto_path=/path/to/mesos/include/mesos/ --proto_path=src/main/proto/ src/main/proto/marathon.proto
It is generated from these files:
marathon.proto
It has these top-level messages:
Constraint HealthCheckDefinition ReadinessCheckDefinition ObsoleteIpAddress ObsoleteDiscoveryInfo NetworkDefinition ServiceDefinition UnreachableStrategy Json ResourceRoles MarathonTask MarathonApp ContainerInfo ExtendedContainerInfo Volume EventSubscribers StorageVersion UpgradeStrategyDefinition GroupDefinition DeploymentPlanDefinition TaskFailure ZKStoreEntry ResidencyDefinition Secret EnvVarReference EnvVarSecretRef
Index ¶
- Constants
- Variables
- type Constraint
- type Constraint_Operator
- type ContainerInfo
- type DeploymentPlanDefinition
- func (*DeploymentPlanDefinition) Descriptor() ([]byte, []int)
- func (m *DeploymentPlanDefinition) GetDeprecatedOriginal() *GroupDefinition
- func (m *DeploymentPlanDefinition) GetDeprecatedTarget() *GroupDefinition
- func (m *DeploymentPlanDefinition) GetId() string
- func (m *DeploymentPlanDefinition) GetOriginalRootVersion() string
- func (m *DeploymentPlanDefinition) GetTargetRootVersion() string
- func (m *DeploymentPlanDefinition) GetTimestamp() string
- func (*DeploymentPlanDefinition) ProtoMessage()
- func (m *DeploymentPlanDefinition) Reset()
- func (m *DeploymentPlanDefinition) String() string
- type EnvVarReference
- func (*EnvVarReference) Descriptor() ([]byte, []int)
- func (m *EnvVarReference) GetName() string
- func (m *EnvVarReference) GetSecretRef() *EnvVarSecretRef
- func (m *EnvVarReference) GetType() EnvVarReference_Type
- func (*EnvVarReference) ProtoMessage()
- func (m *EnvVarReference) Reset()
- func (m *EnvVarReference) String() string
- type EnvVarReference_Type
- type EnvVarSecretRef
- type EventSubscribers
- type ExtendedContainerInfo
- func (*ExtendedContainerInfo) Descriptor() ([]byte, []int)
- func (m *ExtendedContainerInfo) GetDocker() *ExtendedContainerInfo_DockerInfo
- func (m *ExtendedContainerInfo) GetMesosAppC() *ExtendedContainerInfo_MesosAppCInfo
- func (m *ExtendedContainerInfo) GetMesosDocker() *ExtendedContainerInfo_MesosDockerInfo
- func (m *ExtendedContainerInfo) GetPortMappings() []*ExtendedContainerInfo_PortMapping
- func (m *ExtendedContainerInfo) GetType() mesos.ContainerInfo_Type
- func (m *ExtendedContainerInfo) GetVolumes() []*Volume
- func (*ExtendedContainerInfo) ProtoMessage()
- func (m *ExtendedContainerInfo) Reset()
- func (m *ExtendedContainerInfo) String() string
- type ExtendedContainerInfo_DockerInfo
- func (*ExtendedContainerInfo_DockerInfo) Descriptor() ([]byte, []int)
- func (m *ExtendedContainerInfo_DockerInfo) GetForcePullImage() bool
- func (m *ExtendedContainerInfo_DockerInfo) GetImage() string
- func (m *ExtendedContainerInfo_DockerInfo) GetOBSOLETENetwork() mesos.ContainerInfo_DockerInfo_Network
- func (m *ExtendedContainerInfo_DockerInfo) GetOBSOLETEPortMappings() []*ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping
- func (m *ExtendedContainerInfo_DockerInfo) GetParameters() []*mesos.Parameter
- func (m *ExtendedContainerInfo_DockerInfo) GetPrivileged() bool
- func (*ExtendedContainerInfo_DockerInfo) ProtoMessage()
- func (m *ExtendedContainerInfo_DockerInfo) Reset()
- func (m *ExtendedContainerInfo_DockerInfo) String() string
- type ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping
- func (*ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) Descriptor() ([]byte, []int)
- func (m *ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) GetContainerPort() uint32
- func (m *ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) GetHostPort() uint32
- func (m *ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) GetLabels() []*mesos.Label
- func (m *ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) GetName() string
- func (m *ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) GetProtocol() string
- func (m *ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) GetServicePort() uint32
- func (*ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) ProtoMessage()
- func (m *ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) Reset()
- func (m *ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) String() string
- type ExtendedContainerInfo_MesosAppCInfo
- func (*ExtendedContainerInfo_MesosAppCInfo) Descriptor() ([]byte, []int)
- func (m *ExtendedContainerInfo_MesosAppCInfo) GetForcePullImage() bool
- func (m *ExtendedContainerInfo_MesosAppCInfo) GetId() string
- func (m *ExtendedContainerInfo_MesosAppCInfo) GetImage() string
- func (m *ExtendedContainerInfo_MesosAppCInfo) GetLabels() []*mesos.Label
- func (*ExtendedContainerInfo_MesosAppCInfo) ProtoMessage()
- func (m *ExtendedContainerInfo_MesosAppCInfo) Reset()
- func (m *ExtendedContainerInfo_MesosAppCInfo) String() string
- type ExtendedContainerInfo_MesosDockerInfo
- func (*ExtendedContainerInfo_MesosDockerInfo) Descriptor() ([]byte, []int)
- func (m *ExtendedContainerInfo_MesosDockerInfo) GetCredential() *mesos.Credential
- func (m *ExtendedContainerInfo_MesosDockerInfo) GetForcePullImage() bool
- func (m *ExtendedContainerInfo_MesosDockerInfo) GetImage() string
- func (*ExtendedContainerInfo_MesosDockerInfo) ProtoMessage()
- func (m *ExtendedContainerInfo_MesosDockerInfo) Reset()
- func (m *ExtendedContainerInfo_MesosDockerInfo) String() string
- type ExtendedContainerInfo_PortMapping
- func (*ExtendedContainerInfo_PortMapping) Descriptor() ([]byte, []int)
- func (m *ExtendedContainerInfo_PortMapping) GetContainerPort() uint32
- func (m *ExtendedContainerInfo_PortMapping) GetHostPort() uint32
- func (m *ExtendedContainerInfo_PortMapping) GetLabels() []*mesos.Label
- func (m *ExtendedContainerInfo_PortMapping) GetName() string
- func (m *ExtendedContainerInfo_PortMapping) GetProtocol() string
- func (m *ExtendedContainerInfo_PortMapping) GetServicePort() uint32
- func (*ExtendedContainerInfo_PortMapping) ProtoMessage()
- func (m *ExtendedContainerInfo_PortMapping) Reset()
- func (m *ExtendedContainerInfo_PortMapping) String() string
- type GroupDefinition
- func (*GroupDefinition) Descriptor() ([]byte, []int)
- func (m *GroupDefinition) GetApps() []*GroupDefinition_AppReference
- func (m *GroupDefinition) GetDependencies() []string
- func (m *GroupDefinition) GetDeprecatedApps() []*ServiceDefinition
- func (m *GroupDefinition) GetDeprecatedPods() []*Json
- func (m *GroupDefinition) GetGroups() []*GroupDefinition
- func (m *GroupDefinition) GetId() string
- func (m *GroupDefinition) GetPods() []*GroupDefinition_AppReference
- func (m *GroupDefinition) GetVersion() string
- func (*GroupDefinition) ProtoMessage()
- func (m *GroupDefinition) Reset()
- func (m *GroupDefinition) String() string
- type GroupDefinition_AppReference
- func (*GroupDefinition_AppReference) Descriptor() ([]byte, []int)
- func (m *GroupDefinition_AppReference) GetId() string
- func (m *GroupDefinition_AppReference) GetVersion() string
- func (*GroupDefinition_AppReference) ProtoMessage()
- func (m *GroupDefinition_AppReference) Reset()
- func (m *GroupDefinition_AppReference) String() string
- type HealthCheckDefinition
- func (*HealthCheckDefinition) Descriptor() ([]byte, []int)
- func (m *HealthCheckDefinition) GetCommand() *mesos.CommandInfo
- func (m *HealthCheckDefinition) GetDelaySeconds() uint32
- func (m *HealthCheckDefinition) GetGracePeriodSeconds() uint32
- func (m *HealthCheckDefinition) GetIgnoreHttp1Xx() bool
- func (m *HealthCheckDefinition) GetIntervalSeconds() uint32
- func (m *HealthCheckDefinition) GetMaxConsecutiveFailures() uint32
- func (m *HealthCheckDefinition) GetPath() string
- func (m *HealthCheckDefinition) GetPort() uint32
- func (m *HealthCheckDefinition) GetPortIndex() uint32
- func (m *HealthCheckDefinition) GetPortName() string
- func (m *HealthCheckDefinition) GetProtocol() HealthCheckDefinition_Protocol
- func (m *HealthCheckDefinition) GetTimeoutSeconds() uint32
- func (*HealthCheckDefinition) ProtoMessage()
- func (m *HealthCheckDefinition) Reset()
- func (m *HealthCheckDefinition) String() string
- type HealthCheckDefinition_Protocol
- type Json
- type KillSelection
- type MarathonApp
- type MarathonTask
- func (*MarathonTask) Descriptor() ([]byte, []int)
- func (m *MarathonTask) GetCondition() MarathonTask_Condition
- func (m *MarathonTask) GetId() string
- func (m *MarathonTask) GetOBSOLETEAttributes() []*mesos.Attribute
- func (m *MarathonTask) GetOBSOLETEHost() string
- func (m *MarathonTask) GetOBSOLETENetworks() []*mesos.NetworkInfo
- func (m *MarathonTask) GetOBSOLETESlaveId() *mesos.SlaveID
- func (m *MarathonTask) GetOBSOLETEStatuses() []*mesos.TaskStatus
- func (m *MarathonTask) GetPorts() []uint32
- func (m *MarathonTask) GetReservation() *MarathonTask_Reservation
- func (m *MarathonTask) GetStagedAt() int64
- func (m *MarathonTask) GetStartedAt() int64
- func (m *MarathonTask) GetStatus() *mesos.TaskStatus
- func (m *MarathonTask) GetVersion() string
- func (*MarathonTask) ProtoMessage()
- func (m *MarathonTask) Reset()
- func (m *MarathonTask) String() string
- type MarathonTask_Condition
- type MarathonTask_Reservation
- func (*MarathonTask_Reservation) Descriptor() ([]byte, []int)
- func (m *MarathonTask_Reservation) GetLocalVolumeIds() []string
- func (m *MarathonTask_Reservation) GetState() *MarathonTask_Reservation_State
- func (*MarathonTask_Reservation) ProtoMessage()
- func (m *MarathonTask_Reservation) Reset()
- func (m *MarathonTask_Reservation) String() string
- type MarathonTask_Reservation_State
- func (*MarathonTask_Reservation_State) Descriptor() ([]byte, []int)
- func (m *MarathonTask_Reservation_State) GetTimeout() *MarathonTask_Reservation_State_Timeout
- func (m *MarathonTask_Reservation_State) GetType() MarathonTask_Reservation_State_Type
- func (*MarathonTask_Reservation_State) ProtoMessage()
- func (m *MarathonTask_Reservation_State) Reset()
- func (m *MarathonTask_Reservation_State) String() string
- type MarathonTask_Reservation_State_Timeout
- func (*MarathonTask_Reservation_State_Timeout) Descriptor() ([]byte, []int)
- func (m *MarathonTask_Reservation_State_Timeout) GetDeadline() int64
- func (m *MarathonTask_Reservation_State_Timeout) GetInitiated() int64
- func (m *MarathonTask_Reservation_State_Timeout) GetReason() MarathonTask_Reservation_State_Timeout_Reason
- func (*MarathonTask_Reservation_State_Timeout) ProtoMessage()
- func (m *MarathonTask_Reservation_State_Timeout) Reset()
- func (m *MarathonTask_Reservation_State_Timeout) String() string
- type MarathonTask_Reservation_State_Timeout_Reason
- func (x MarathonTask_Reservation_State_Timeout_Reason) Enum() *MarathonTask_Reservation_State_Timeout_Reason
- func (MarathonTask_Reservation_State_Timeout_Reason) EnumDescriptor() ([]byte, []int)
- func (x MarathonTask_Reservation_State_Timeout_Reason) String() string
- func (x *MarathonTask_Reservation_State_Timeout_Reason) UnmarshalJSON(data []byte) error
- type MarathonTask_Reservation_State_Type
- func (x MarathonTask_Reservation_State_Type) Enum() *MarathonTask_Reservation_State_Type
- func (MarathonTask_Reservation_State_Type) EnumDescriptor() ([]byte, []int)
- func (x MarathonTask_Reservation_State_Type) String() string
- func (x *MarathonTask_Reservation_State_Type) UnmarshalJSON(data []byte) error
- type NetworkDefinition
- func (*NetworkDefinition) Descriptor() ([]byte, []int)
- func (m *NetworkDefinition) GetLabels() []*mesos.Label
- func (m *NetworkDefinition) GetMode() NetworkDefinition_Mode
- func (m *NetworkDefinition) GetName() string
- func (*NetworkDefinition) ProtoMessage()
- func (m *NetworkDefinition) Reset()
- func (m *NetworkDefinition) String() string
- type NetworkDefinition_Mode
- type ObsoleteDiscoveryInfo
- type ObsoleteIpAddress
- func (*ObsoleteIpAddress) Descriptor() ([]byte, []int)
- func (m *ObsoleteIpAddress) GetDiscoveryInfo() *ObsoleteDiscoveryInfo
- func (m *ObsoleteIpAddress) GetGroups() []string
- func (m *ObsoleteIpAddress) GetLabels() []*mesos.Label
- func (m *ObsoleteIpAddress) GetNetworkName() string
- func (*ObsoleteIpAddress) ProtoMessage()
- func (m *ObsoleteIpAddress) Reset()
- func (m *ObsoleteIpAddress) String() string
- type ReadinessCheckDefinition
- func (*ReadinessCheckDefinition) Descriptor() ([]byte, []int)
- func (m *ReadinessCheckDefinition) GetHttpStatusCodeForReady() []uint32
- func (m *ReadinessCheckDefinition) GetIntervalMillis() uint64
- func (m *ReadinessCheckDefinition) GetName() string
- func (m *ReadinessCheckDefinition) GetPath() string
- func (m *ReadinessCheckDefinition) GetPortName() string
- func (m *ReadinessCheckDefinition) GetPreserveLastResponse() bool
- func (m *ReadinessCheckDefinition) GetProtocol() ReadinessCheckDefinition_Protocol
- func (m *ReadinessCheckDefinition) GetTimeoutMillis() uint64
- func (*ReadinessCheckDefinition) ProtoMessage()
- func (m *ReadinessCheckDefinition) Reset()
- func (m *ReadinessCheckDefinition) String() string
- type ReadinessCheckDefinition_Protocol
- type ResidencyDefinition
- func (*ResidencyDefinition) Descriptor() ([]byte, []int)
- func (m *ResidencyDefinition) GetRelaunchEscalationTimeoutSeconds() int64
- func (m *ResidencyDefinition) GetTaskLostBehavior() ResidencyDefinition_TaskLostBehavior
- func (*ResidencyDefinition) ProtoMessage()
- func (m *ResidencyDefinition) Reset()
- func (m *ResidencyDefinition) String() string
- type ResidencyDefinition_TaskLostBehavior
- func (x ResidencyDefinition_TaskLostBehavior) Enum() *ResidencyDefinition_TaskLostBehavior
- func (ResidencyDefinition_TaskLostBehavior) EnumDescriptor() ([]byte, []int)
- func (x ResidencyDefinition_TaskLostBehavior) String() string
- func (x *ResidencyDefinition_TaskLostBehavior) UnmarshalJSON(data []byte) error
- type ResourceRoles
- type Secret
- type ServiceDefinition
- func (*ServiceDefinition) Descriptor() ([]byte, []int)
- func (m *ServiceDefinition) GetAcceptedResourceRoles() *ResourceRoles
- func (m *ServiceDefinition) GetBackoff() int64
- func (m *ServiceDefinition) GetBackoffFactor() float64
- func (m *ServiceDefinition) GetCmd() *mesos.CommandInfo
- func (m *ServiceDefinition) GetConstraints() []*Constraint
- func (m *ServiceDefinition) GetContainer() *ExtendedContainerInfo
- func (m *ServiceDefinition) GetDependencies() []string
- func (m *ServiceDefinition) GetDescription() string
- func (m *ServiceDefinition) GetEnvVarReferences() []*EnvVarReference
- func (m *ServiceDefinition) GetExecutor() string
- func (m *ServiceDefinition) GetHealthChecks() []*HealthCheckDefinition
- func (m *ServiceDefinition) GetId() string
- func (m *ServiceDefinition) GetInstances() uint32
- func (m *ServiceDefinition) GetKillSelection() KillSelection
- func (m *ServiceDefinition) GetLabels() []*mesos.Parameter
- func (m *ServiceDefinition) GetLastConfigChangeAt() int64
- func (m *ServiceDefinition) GetLastScalingAt() int64
- func (m *ServiceDefinition) GetMaxLaunchDelay() int64
- func (m *ServiceDefinition) GetNetworks() []*NetworkDefinition
- func (m *ServiceDefinition) GetOBSOLETEContainer() *ContainerInfo
- func (m *ServiceDefinition) GetOBSOLETEIpAddress() *ObsoleteIpAddress
- func (m *ServiceDefinition) GetPortDefinitions() []*mesos.Port
- func (m *ServiceDefinition) GetPorts() []uint32
- func (m *ServiceDefinition) GetReadinessCheckDefinition() []*ReadinessCheckDefinition
- func (m *ServiceDefinition) GetRequirePorts() bool
- func (m *ServiceDefinition) GetResidency() *ResidencyDefinition
- func (m *ServiceDefinition) GetResources() []*mesos.Resource
- func (m *ServiceDefinition) GetSecrets() []*Secret
- func (m *ServiceDefinition) GetStoreUrls() []string
- func (m *ServiceDefinition) GetTaskKillGracePeriod() int64
- func (m *ServiceDefinition) GetUnreachableStrategy() *UnreachableStrategy
- func (m *ServiceDefinition) GetUpgradeStrategy() *UpgradeStrategyDefinition
- func (m *ServiceDefinition) GetVersion() string
- func (*ServiceDefinition) ProtoMessage()
- func (m *ServiceDefinition) Reset()
- func (m *ServiceDefinition) String() string
- type StorageVersion
- func (*StorageVersion) Descriptor() ([]byte, []int)
- func (m *StorageVersion) GetFormat() StorageVersion_StorageFormat
- func (m *StorageVersion) GetMajor() uint32
- func (m *StorageVersion) GetMinor() uint32
- func (m *StorageVersion) GetPatch() uint32
- func (*StorageVersion) ProtoMessage()
- func (m *StorageVersion) Reset()
- func (m *StorageVersion) String() string
- type StorageVersion_StorageFormat
- type TaskFailure
- func (*TaskFailure) Descriptor() ([]byte, []int)
- func (m *TaskFailure) GetAppId() string
- func (m *TaskFailure) GetHost() string
- func (m *TaskFailure) GetMessage() string
- func (m *TaskFailure) GetSlaveId() *mesos.SlaveID
- func (m *TaskFailure) GetState() mesos.TaskState
- func (m *TaskFailure) GetTaskId() *mesos.TaskID
- func (m *TaskFailure) GetTimestamp() string
- func (m *TaskFailure) GetVersion() string
- func (*TaskFailure) ProtoMessage()
- func (m *TaskFailure) Reset()
- func (m *TaskFailure) String() string
- type UnreachableStrategy
- func (*UnreachableStrategy) Descriptor() ([]byte, []int)
- func (m *UnreachableStrategy) GetExpungeAfterSeconds() uint64
- func (m *UnreachableStrategy) GetInactiveAfterSeconds() uint64
- func (*UnreachableStrategy) ProtoMessage()
- func (m *UnreachableStrategy) Reset()
- func (m *UnreachableStrategy) String() string
- type UpgradeStrategyDefinition
- func (*UpgradeStrategyDefinition) Descriptor() ([]byte, []int)
- func (m *UpgradeStrategyDefinition) GetMaximumOverCapacity() float64
- func (m *UpgradeStrategyDefinition) GetMinimumHealthCapacity() float64
- func (*UpgradeStrategyDefinition) ProtoMessage()
- func (m *UpgradeStrategyDefinition) Reset()
- func (m *UpgradeStrategyDefinition) String() string
- type Volume
- func (*Volume) Descriptor() ([]byte, []int)
- func (m *Volume) GetContainerPath() string
- func (m *Volume) GetExternal() *Volume_ExternalVolumeInfo
- func (m *Volume) GetHostPath() string
- func (m *Volume) GetImage() *mesos.Image
- func (m *Volume) GetMode() mesos.Volume_Mode
- func (m *Volume) GetPersistent() *Volume_PersistentVolumeInfo
- func (*Volume) ProtoMessage()
- func (m *Volume) Reset()
- func (m *Volume) String() string
- type Volume_ExternalVolumeInfo
- func (*Volume_ExternalVolumeInfo) Descriptor() ([]byte, []int)
- func (m *Volume_ExternalVolumeInfo) GetName() string
- func (m *Volume_ExternalVolumeInfo) GetOptions() []*mesos.Label
- func (m *Volume_ExternalVolumeInfo) GetProvider() string
- func (m *Volume_ExternalVolumeInfo) GetSize() uint64
- func (*Volume_ExternalVolumeInfo) ProtoMessage()
- func (m *Volume_ExternalVolumeInfo) Reset()
- func (m *Volume_ExternalVolumeInfo) String() string
- type Volume_PersistentVolumeInfo
- func (*Volume_PersistentVolumeInfo) Descriptor() ([]byte, []int)
- func (m *Volume_PersistentVolumeInfo) GetConstraints() []*Constraint
- func (m *Volume_PersistentVolumeInfo) GetMaxSize() uint64
- func (m *Volume_PersistentVolumeInfo) GetSize() uint64
- func (m *Volume_PersistentVolumeInfo) GetType() mesos.Resource_DiskInfo_Source_Type
- func (*Volume_PersistentVolumeInfo) ProtoMessage()
- func (m *Volume_PersistentVolumeInfo) Reset()
- func (m *Volume_PersistentVolumeInfo) String() string
- type ZKStoreEntry
- func (*ZKStoreEntry) Descriptor() ([]byte, []int)
- func (m *ZKStoreEntry) GetCompressed() bool
- func (m *ZKStoreEntry) GetName() string
- func (m *ZKStoreEntry) GetUuid() []byte
- func (m *ZKStoreEntry) GetValue() []byte
- func (*ZKStoreEntry) ProtoMessage()
- func (m *ZKStoreEntry) Reset()
- func (m *ZKStoreEntry) String() string
Constants ¶
const Default_ExtendedContainerInfo_DockerInfo_OBSOLETENetwork mesos.ContainerInfo_DockerInfo_Network = mesos.ContainerInfo_DockerInfo_HOST
const Default_ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping_ServicePort uint32 = 0
const Default_ExtendedContainerInfo_DockerInfo_Privileged bool = false
const Default_ExtendedContainerInfo_PortMapping_ServicePort uint32 = 0
const Default_HealthCheckDefinition_DelaySeconds uint32 = 15
const Default_HealthCheckDefinition_GracePeriodSeconds uint32 = 15
const Default_HealthCheckDefinition_IgnoreHttp1Xx bool = false
const Default_HealthCheckDefinition_IntervalSeconds uint32 = 10
const Default_HealthCheckDefinition_MaxConsecutiveFailures uint32 = 3
const Default_HealthCheckDefinition_Path string = "/"
const Default_HealthCheckDefinition_TimeoutSeconds uint32 = 20
const Default_MarathonTask_Version string = "1970-01-01T00:00:00.000Z"
const Default_ServiceDefinition_Backoff int64 = 1000
const Default_ServiceDefinition_BackoffFactor float64 = 1.15
const Default_ServiceDefinition_MaxLaunchDelay int64 = 3600000
const Default_ServiceDefinition_RequirePorts bool = false
const Default_ServiceDefinition_Version string = "1970-01-01T00:00:00.000Z"
const Default_UnreachableStrategy_ExpungeAfterSeconds uint64 = 604800
const Default_UnreachableStrategy_InactiveAfterSeconds uint64 = 900
const Default_UpgradeStrategyDefinition_MaximumOverCapacity float64 = 1
const Default_ZKStoreEntry_Compressed bool = false
Variables ¶
var Constraint_Operator_name = map[int32]string{
0: "UNIQUE",
1: "LIKE",
2: "CLUSTER",
3: "GROUP_BY",
4: "UNLIKE",
5: "MAX_PER",
}
var Constraint_Operator_value = map[string]int32{
"UNIQUE": 0,
"LIKE": 1,
"CLUSTER": 2,
"GROUP_BY": 3,
"UNLIKE": 4,
"MAX_PER": 5,
}
var EnvVarReference_Type_name = map[int32]string{
0: "UNKNOWN",
1: "SECRET",
}
var EnvVarReference_Type_value = map[string]int32{
"UNKNOWN": 0,
"SECRET": 1,
}
var HealthCheckDefinition_Protocol_name = map[int32]string{
0: "HTTP",
1: "TCP",
2: "COMMAND",
3: "HTTPS",
4: "MESOS_HTTP",
5: "MESOS_HTTPS",
6: "MESOS_TCP",
}
var HealthCheckDefinition_Protocol_value = map[string]int32{
"HTTP": 0,
"TCP": 1,
"COMMAND": 2,
"HTTPS": 3,
"MESOS_HTTP": 4,
"MESOS_HTTPS": 5,
"MESOS_TCP": 6,
}
var KillSelection_name = map[int32]string{
1: "YoungestFirst",
2: "OldestFirst",
}
var KillSelection_value = map[string]int32{
"YoungestFirst": 1,
"OldestFirst": 2,
}
var MarathonTask_Condition_name = map[int32]string{
0: "Invalid",
1: "Reserved",
2: "Created",
3: "Error",
4: "Failed",
5: "Finished",
6: "Killed",
7: "Killing",
8: "Lost",
9: "Running",
10: "Staging",
11: "Starting",
12: "Unreachable",
13: "Gone",
14: "Unknown",
15: "Dropped",
}
var MarathonTask_Condition_value = map[string]int32{
"Invalid": 0,
"Reserved": 1,
"Created": 2,
"Error": 3,
"Failed": 4,
"Finished": 5,
"Killed": 6,
"Killing": 7,
"Lost": 8,
"Running": 9,
"Staging": 10,
"Starting": 11,
"Unreachable": 12,
"Gone": 13,
"Unknown": 14,
"Dropped": 15,
}
var MarathonTask_Reservation_State_Timeout_Reason_name = map[int32]string{
1: "RelaunchEscalationTimeout",
2: "ReservationTimeout",
}
var MarathonTask_Reservation_State_Timeout_Reason_value = map[string]int32{
"RelaunchEscalationTimeout": 1,
"ReservationTimeout": 2,
}
var MarathonTask_Reservation_State_Type_name = map[int32]string{
1: "New",
2: "Launched",
3: "Suspended",
4: "Garbage",
5: "Unknown",
}
var MarathonTask_Reservation_State_Type_value = map[string]int32{
"New": 1,
"Launched": 2,
"Suspended": 3,
"Garbage": 4,
"Unknown": 5,
}
var NetworkDefinition_Mode_name = map[int32]string{
0: "UNKNOWN",
1: "HOST",
2: "CONTAINER",
3: "BRIDGE",
}
var NetworkDefinition_Mode_value = map[string]int32{
"UNKNOWN": 0,
"HOST": 1,
"CONTAINER": 2,
"BRIDGE": 3,
}
var ReadinessCheckDefinition_Protocol_name = map[int32]string{
0: "HTTP",
1: "HTTPS",
}
var ReadinessCheckDefinition_Protocol_value = map[string]int32{
"HTTP": 0,
"HTTPS": 1,
}
var ResidencyDefinition_TaskLostBehavior_name = map[int32]string{
0: "RELAUNCH_AFTER_TIMEOUT",
1: "WAIT_FOREVER",
}
var ResidencyDefinition_TaskLostBehavior_value = map[string]int32{
"RELAUNCH_AFTER_TIMEOUT": 0,
"WAIT_FOREVER": 1,
}
var StorageVersion_StorageFormat_name = map[int32]string{
0: "LEGACY",
1: "PERSISTENCE_STORE",
}
var StorageVersion_StorageFormat_value = map[string]int32{
"LEGACY": 0,
"PERSISTENCE_STORE": 1,
}
Functions ¶
This section is empty.
Types ¶
type Constraint ¶
type Constraint struct { Field *string `protobuf:"bytes,1,req,name=field" json:"field,omitempty"` Operator *Constraint_Operator `protobuf:"varint,2,req,name=operator,enum=mesosphere.marathon.Constraint_Operator" json:"operator,omitempty"` Value *string `protobuf:"bytes,3,opt,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Constraint) Descriptor ¶
func (*Constraint) Descriptor() ([]byte, []int)
func (*Constraint) GetField ¶
func (m *Constraint) GetField() string
func (*Constraint) GetOperator ¶
func (m *Constraint) GetOperator() Constraint_Operator
func (*Constraint) GetValue ¶
func (m *Constraint) GetValue() string
func (*Constraint) ProtoMessage ¶
func (*Constraint) ProtoMessage()
func (*Constraint) Reset ¶
func (m *Constraint) Reset()
func (*Constraint) String ¶
func (m *Constraint) String() string
type Constraint_Operator ¶
type Constraint_Operator int32
const ( // Field must be unique across all tasks. Constraint_UNIQUE Constraint_Operator = 0 // Field must match the regex given by value. Constraint_LIKE Constraint_Operator = 1 // Tasks will be clustered, i.e. all tasks need to have the same value. If value is not set, any value will be // accepted for the first task, and subsequent tasks must use that same value. Constraint_CLUSTER Constraint_Operator = 2 // Tasks will be grouped by field. Value specifies the minimum size of each group. Constraint_GROUP_BY Constraint_Operator = 3 // Field must not match the regex given by value. Constraint_UNLIKE Constraint_Operator = 4 // Field will be grouped by field. Value specifies the maximum size of each group. Constraint_MAX_PER Constraint_Operator = 5 )
func (Constraint_Operator) Enum ¶
func (x Constraint_Operator) Enum() *Constraint_Operator
func (Constraint_Operator) EnumDescriptor ¶
func (Constraint_Operator) EnumDescriptor() ([]byte, []int)
func (Constraint_Operator) String ¶
func (x Constraint_Operator) String() string
func (*Constraint_Operator) UnmarshalJSON ¶
func (x *Constraint_Operator) UnmarshalJSON(data []byte) error
type ContainerInfo ¶
type ContainerInfo struct { Image []byte `protobuf:"bytes,1,req,name=image,def=" json:"image,omitempty"` Options [][]byte `protobuf:"bytes,2,rep,name=options" json:"options,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ContainerInfo) Descriptor ¶
func (*ContainerInfo) Descriptor() ([]byte, []int)
func (*ContainerInfo) GetImage ¶
func (m *ContainerInfo) GetImage() []byte
func (*ContainerInfo) GetOptions ¶
func (m *ContainerInfo) GetOptions() [][]byte
func (*ContainerInfo) ProtoMessage ¶
func (*ContainerInfo) ProtoMessage()
func (*ContainerInfo) Reset ¶
func (m *ContainerInfo) Reset()
func (*ContainerInfo) String ¶
func (m *ContainerInfo) String() string
type DeploymentPlanDefinition ¶
type DeploymentPlanDefinition struct { Id *string `protobuf:"bytes,1,req,name=id" json:"id,omitempty"` Timestamp *string `protobuf:"bytes,2,opt,name=timestamp" json:"timestamp,omitempty"` // Note: deprecated_* can't be read by legacy persistent stores if they aren't set (since they were required) // They are no longer read by PersistenceStores DeprecatedOriginal *GroupDefinition `protobuf:"bytes,4,opt,name=deprecated_original,json=deprecatedOriginal" json:"deprecated_original,omitempty"` DeprecatedTarget *GroupDefinition `protobuf:"bytes,5,opt,name=deprecated_target,json=deprecatedTarget" json:"deprecated_target,omitempty"` // The new original and target are required by PersistenceStores OriginalRootVersion *string `protobuf:"bytes,6,opt,name=original_root_version,json=originalRootVersion" json:"original_root_version,omitempty"` TargetRootVersion *string `protobuf:"bytes,7,opt,name=target_root_version,json=targetRootVersion" json:"target_root_version,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*DeploymentPlanDefinition) Descriptor ¶
func (*DeploymentPlanDefinition) Descriptor() ([]byte, []int)
func (*DeploymentPlanDefinition) GetDeprecatedOriginal ¶
func (m *DeploymentPlanDefinition) GetDeprecatedOriginal() *GroupDefinition
func (*DeploymentPlanDefinition) GetDeprecatedTarget ¶
func (m *DeploymentPlanDefinition) GetDeprecatedTarget() *GroupDefinition
func (*DeploymentPlanDefinition) GetId ¶
func (m *DeploymentPlanDefinition) GetId() string
func (*DeploymentPlanDefinition) GetOriginalRootVersion ¶
func (m *DeploymentPlanDefinition) GetOriginalRootVersion() string
func (*DeploymentPlanDefinition) GetTargetRootVersion ¶
func (m *DeploymentPlanDefinition) GetTargetRootVersion() string
func (*DeploymentPlanDefinition) GetTimestamp ¶
func (m *DeploymentPlanDefinition) GetTimestamp() string
func (*DeploymentPlanDefinition) ProtoMessage ¶
func (*DeploymentPlanDefinition) ProtoMessage()
func (*DeploymentPlanDefinition) Reset ¶
func (m *DeploymentPlanDefinition) Reset()
func (*DeploymentPlanDefinition) String ¶
func (m *DeploymentPlanDefinition) String() string
type EnvVarReference ¶
type EnvVarReference struct { Type *EnvVarReference_Type `protobuf:"varint,1,req,name=type,enum=mesosphere.marathon.EnvVarReference_Type" json:"type,omitempty"` Name *string `protobuf:"bytes,2,req,name=name" json:"name,omitempty"` SecretRef *EnvVarSecretRef `protobuf:"bytes,3,opt,name=secretRef" json:"secretRef,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*EnvVarReference) Descriptor ¶
func (*EnvVarReference) Descriptor() ([]byte, []int)
func (*EnvVarReference) GetName ¶
func (m *EnvVarReference) GetName() string
func (*EnvVarReference) GetSecretRef ¶
func (m *EnvVarReference) GetSecretRef() *EnvVarSecretRef
func (*EnvVarReference) GetType ¶
func (m *EnvVarReference) GetType() EnvVarReference_Type
func (*EnvVarReference) ProtoMessage ¶
func (*EnvVarReference) ProtoMessage()
func (*EnvVarReference) Reset ¶
func (m *EnvVarReference) Reset()
func (*EnvVarReference) String ¶
func (m *EnvVarReference) String() string
type EnvVarReference_Type ¶
type EnvVarReference_Type int32
const ( EnvVarReference_UNKNOWN EnvVarReference_Type = 0 EnvVarReference_SECRET EnvVarReference_Type = 1 )
func (EnvVarReference_Type) Enum ¶
func (x EnvVarReference_Type) Enum() *EnvVarReference_Type
func (EnvVarReference_Type) EnumDescriptor ¶
func (EnvVarReference_Type) EnumDescriptor() ([]byte, []int)
func (EnvVarReference_Type) String ¶
func (x EnvVarReference_Type) String() string
func (*EnvVarReference_Type) UnmarshalJSON ¶
func (x *EnvVarReference_Type) UnmarshalJSON(data []byte) error
type EnvVarSecretRef ¶
type EnvVarSecretRef struct { SecretId *string `protobuf:"bytes,1,req,name=secretId" json:"secretId,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*EnvVarSecretRef) Descriptor ¶
func (*EnvVarSecretRef) Descriptor() ([]byte, []int)
func (*EnvVarSecretRef) GetSecretId ¶
func (m *EnvVarSecretRef) GetSecretId() string
func (*EnvVarSecretRef) ProtoMessage ¶
func (*EnvVarSecretRef) ProtoMessage()
func (*EnvVarSecretRef) Reset ¶
func (m *EnvVarSecretRef) Reset()
func (*EnvVarSecretRef) String ¶
func (m *EnvVarSecretRef) String() string
type EventSubscribers ¶
type EventSubscribers struct { CallbackUrls []string `protobuf:"bytes,1,rep,name=callback_urls,json=callbackUrls" json:"callback_urls,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*EventSubscribers) Descriptor ¶
func (*EventSubscribers) Descriptor() ([]byte, []int)
func (*EventSubscribers) GetCallbackUrls ¶
func (m *EventSubscribers) GetCallbackUrls() []string
func (*EventSubscribers) ProtoMessage ¶
func (*EventSubscribers) ProtoMessage()
func (*EventSubscribers) Reset ¶
func (m *EventSubscribers) Reset()
func (*EventSubscribers) String ¶
func (m *EventSubscribers) String() string
type ExtendedContainerInfo ¶
type ExtendedContainerInfo struct { Type *mesos.ContainerInfo_Type `protobuf:"varint,1,req,name=type,enum=mesos.ContainerInfo_Type" json:"type,omitempty"` Volumes []*Volume `protobuf:"bytes,2,rep,name=volumes" json:"volumes,omitempty"` PortMappings []*ExtendedContainerInfo_PortMapping `protobuf:"bytes,6,rep,name=port_mappings,json=portMappings" json:"port_mappings,omitempty"` Docker *ExtendedContainerInfo_DockerInfo `protobuf:"bytes,3,opt,name=docker" json:"docker,omitempty"` MesosDocker *ExtendedContainerInfo_MesosDockerInfo `protobuf:"bytes,4,opt,name=mesosDocker" json:"mesosDocker,omitempty"` MesosAppC *ExtendedContainerInfo_MesosAppCInfo `protobuf:"bytes,5,opt,name=mesosAppC" json:"mesosAppC,omitempty"` XXX_unrecognized []byte `json:"-"` }
Copied from mesos.proto and adjusted to meet the needs for persistent volumes Extends DockerInfo.PortMapping to include `service_port`.
func (*ExtendedContainerInfo) Descriptor ¶
func (*ExtendedContainerInfo) Descriptor() ([]byte, []int)
func (*ExtendedContainerInfo) GetDocker ¶
func (m *ExtendedContainerInfo) GetDocker() *ExtendedContainerInfo_DockerInfo
func (*ExtendedContainerInfo) GetMesosAppC ¶
func (m *ExtendedContainerInfo) GetMesosAppC() *ExtendedContainerInfo_MesosAppCInfo
func (*ExtendedContainerInfo) GetMesosDocker ¶
func (m *ExtendedContainerInfo) GetMesosDocker() *ExtendedContainerInfo_MesosDockerInfo
func (*ExtendedContainerInfo) GetPortMappings ¶
func (m *ExtendedContainerInfo) GetPortMappings() []*ExtendedContainerInfo_PortMapping
func (*ExtendedContainerInfo) GetType ¶
func (m *ExtendedContainerInfo) GetType() mesos.ContainerInfo_Type
func (*ExtendedContainerInfo) GetVolumes ¶
func (m *ExtendedContainerInfo) GetVolumes() []*Volume
func (*ExtendedContainerInfo) ProtoMessage ¶
func (*ExtendedContainerInfo) ProtoMessage()
func (*ExtendedContainerInfo) Reset ¶
func (m *ExtendedContainerInfo) Reset()
func (*ExtendedContainerInfo) String ¶
func (m *ExtendedContainerInfo) String() string
type ExtendedContainerInfo_DockerInfo ¶
type ExtendedContainerInfo_DockerInfo struct { Image *string `protobuf:"bytes,1,req,name=image" json:"image,omitempty"` // deprecated in favor of ServiceDefinition.networks since 1.5 OBSOLETENetwork *mesos.ContainerInfo_DockerInfo_Network `` /* 150-byte string literal not displayed */ // deprecated in favor of ExtendedContainerInfo.port_mappings, since 1.5 OBSOLETEPortMappings []*ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping `protobuf:"bytes,3,rep,name=OBSOLETE_port_mappings,json=OBSOLETEPortMappings" json:"OBSOLETE_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 []*mesos.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"` XXX_unrecognized []byte `json:"-"` }
Docker on a Docker engine
func (*ExtendedContainerInfo_DockerInfo) Descriptor ¶
func (*ExtendedContainerInfo_DockerInfo) Descriptor() ([]byte, []int)
func (*ExtendedContainerInfo_DockerInfo) GetForcePullImage ¶
func (m *ExtendedContainerInfo_DockerInfo) GetForcePullImage() bool
func (*ExtendedContainerInfo_DockerInfo) GetImage ¶
func (m *ExtendedContainerInfo_DockerInfo) GetImage() string
func (*ExtendedContainerInfo_DockerInfo) GetOBSOLETENetwork ¶
func (m *ExtendedContainerInfo_DockerInfo) GetOBSOLETENetwork() mesos.ContainerInfo_DockerInfo_Network
func (*ExtendedContainerInfo_DockerInfo) GetOBSOLETEPortMappings ¶
func (m *ExtendedContainerInfo_DockerInfo) GetOBSOLETEPortMappings() []*ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping
func (*ExtendedContainerInfo_DockerInfo) GetParameters ¶
func (m *ExtendedContainerInfo_DockerInfo) GetParameters() []*mesos.Parameter
func (*ExtendedContainerInfo_DockerInfo) GetPrivileged ¶
func (m *ExtendedContainerInfo_DockerInfo) GetPrivileged() bool
func (*ExtendedContainerInfo_DockerInfo) ProtoMessage ¶
func (*ExtendedContainerInfo_DockerInfo) ProtoMessage()
func (*ExtendedContainerInfo_DockerInfo) Reset ¶
func (m *ExtendedContainerInfo_DockerInfo) Reset()
func (*ExtendedContainerInfo_DockerInfo) String ¶
func (m *ExtendedContainerInfo_DockerInfo) String() string
type ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping ¶
type ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping struct { HostPort *uint32 `protobuf:"varint,1,opt,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 *string `protobuf:"bytes,3,opt,name=protocol" json:"protocol,omitempty"` Name *string `protobuf:"bytes,4,opt,name=name" json:"name,omitempty"` Labels []*mesos.Label `protobuf:"bytes,5,rep,name=labels" json:"labels,omitempty"` ServicePort *uint32 `protobuf:"varint,100,opt,name=service_port,json=servicePort,def=0" json:"service_port,omitempty"` XXX_unrecognized []byte `json:"-"` }
deprecated in favor of ExtendedContainerInfo.PortMapping,since 1.5
func (*ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) Descriptor ¶
func (*ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) Descriptor() ([]byte, []int)
func (*ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) GetContainerPort ¶
func (m *ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) GetContainerPort() uint32
func (*ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) GetHostPort ¶
func (m *ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) GetHostPort() uint32
func (*ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) GetLabels ¶
func (m *ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) GetLabels() []*mesos.Label
func (*ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) GetName ¶
func (m *ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) GetName() string
func (*ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) GetProtocol ¶
func (m *ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) GetProtocol() string
func (*ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) GetServicePort ¶
func (m *ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) GetServicePort() uint32
func (*ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) ProtoMessage ¶
func (*ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) ProtoMessage()
func (*ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) Reset ¶
func (m *ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) Reset()
func (*ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) String ¶
func (m *ExtendedContainerInfo_DockerInfo_ObsoleteDockerPortMapping) String() string
type ExtendedContainerInfo_MesosAppCInfo ¶
type ExtendedContainerInfo_MesosAppCInfo struct { // The name of the image. Image *string `protobuf:"bytes,1,req,name=image" json:"image,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 []*mesos.Label `protobuf:"bytes,3,rep,name=labels" json:"labels,omitempty"` // With this flag set to true, the universal Mesos containerizer will // pull the docker image from the registry even if the image // is already downloaded on the agent. ForcePullImage *bool `protobuf:"varint,4,opt,name=force_pull_image,json=forcePullImage" json:"force_pull_image,omitempty"` XXX_unrecognized []byte `json:"-"` }
AppC on the universal Mesos engine
func (*ExtendedContainerInfo_MesosAppCInfo) Descriptor ¶
func (*ExtendedContainerInfo_MesosAppCInfo) Descriptor() ([]byte, []int)
func (*ExtendedContainerInfo_MesosAppCInfo) GetForcePullImage ¶
func (m *ExtendedContainerInfo_MesosAppCInfo) GetForcePullImage() bool
func (*ExtendedContainerInfo_MesosAppCInfo) GetId ¶
func (m *ExtendedContainerInfo_MesosAppCInfo) GetId() string
func (*ExtendedContainerInfo_MesosAppCInfo) GetImage ¶
func (m *ExtendedContainerInfo_MesosAppCInfo) GetImage() string
func (*ExtendedContainerInfo_MesosAppCInfo) GetLabels ¶
func (m *ExtendedContainerInfo_MesosAppCInfo) GetLabels() []*mesos.Label
func (*ExtendedContainerInfo_MesosAppCInfo) ProtoMessage ¶
func (*ExtendedContainerInfo_MesosAppCInfo) ProtoMessage()
func (*ExtendedContainerInfo_MesosAppCInfo) Reset ¶
func (m *ExtendedContainerInfo_MesosAppCInfo) Reset()
func (*ExtendedContainerInfo_MesosAppCInfo) String ¶
func (m *ExtendedContainerInfo_MesosAppCInfo) String() string
type ExtendedContainerInfo_MesosDockerInfo ¶
type ExtendedContainerInfo_MesosDockerInfo struct { // The name of the image. Expected format: // [REGISTRY_HOST[:REGISTRY_PORT]/]REPOSITORY[:TAG|@TYPE:DIGEST] // // See: https://docs.docker.com/reference/commandline/pull/ Image *string `protobuf:"bytes,1,req,name=image" json:"image,omitempty"` // Credential to authenticate with docker registry. // NOTE: This is not encrypted, therefore framework and operators // should enable SSL when passing this information. Credential *mesos.Credential `protobuf:"bytes,2,opt,name=credential" json:"credential,omitempty"` // With this flag set to true, the universal Mesos containerizer will // pull the docker image from the registry even if the image // is already downloaded on the agent. ForcePullImage *bool `protobuf:"varint,3,opt,name=force_pull_image,json=forcePullImage" json:"force_pull_image,omitempty"` XXX_unrecognized []byte `json:"-"` }
Docker on the universal Mesos engine
func (*ExtendedContainerInfo_MesosDockerInfo) Descriptor ¶
func (*ExtendedContainerInfo_MesosDockerInfo) Descriptor() ([]byte, []int)
func (*ExtendedContainerInfo_MesosDockerInfo) GetCredential ¶
func (m *ExtendedContainerInfo_MesosDockerInfo) GetCredential() *mesos.Credential
func (*ExtendedContainerInfo_MesosDockerInfo) GetForcePullImage ¶
func (m *ExtendedContainerInfo_MesosDockerInfo) GetForcePullImage() bool
func (*ExtendedContainerInfo_MesosDockerInfo) GetImage ¶
func (m *ExtendedContainerInfo_MesosDockerInfo) GetImage() string
func (*ExtendedContainerInfo_MesosDockerInfo) ProtoMessage ¶
func (*ExtendedContainerInfo_MesosDockerInfo) ProtoMessage()
func (*ExtendedContainerInfo_MesosDockerInfo) Reset ¶
func (m *ExtendedContainerInfo_MesosDockerInfo) Reset()
func (*ExtendedContainerInfo_MesosDockerInfo) String ¶
func (m *ExtendedContainerInfo_MesosDockerInfo) String() string
type ExtendedContainerInfo_PortMapping ¶
type ExtendedContainerInfo_PortMapping struct { HostPort *uint32 `protobuf:"varint,1,opt,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 *string `protobuf:"bytes,3,opt,name=protocol" json:"protocol,omitempty"` Name *string `protobuf:"bytes,4,opt,name=name" json:"name,omitempty"` Labels []*mesos.Label `protobuf:"bytes,5,rep,name=labels" json:"labels,omitempty"` ServicePort *uint32 `protobuf:"varint,6,opt,name=service_port,json=servicePort,def=0" json:"service_port,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ExtendedContainerInfo_PortMapping) Descriptor ¶
func (*ExtendedContainerInfo_PortMapping) Descriptor() ([]byte, []int)
func (*ExtendedContainerInfo_PortMapping) GetContainerPort ¶
func (m *ExtendedContainerInfo_PortMapping) GetContainerPort() uint32
func (*ExtendedContainerInfo_PortMapping) GetHostPort ¶
func (m *ExtendedContainerInfo_PortMapping) GetHostPort() uint32
func (*ExtendedContainerInfo_PortMapping) GetLabels ¶
func (m *ExtendedContainerInfo_PortMapping) GetLabels() []*mesos.Label
func (*ExtendedContainerInfo_PortMapping) GetName ¶
func (m *ExtendedContainerInfo_PortMapping) GetName() string
func (*ExtendedContainerInfo_PortMapping) GetProtocol ¶
func (m *ExtendedContainerInfo_PortMapping) GetProtocol() string
func (*ExtendedContainerInfo_PortMapping) GetServicePort ¶
func (m *ExtendedContainerInfo_PortMapping) GetServicePort() uint32
func (*ExtendedContainerInfo_PortMapping) ProtoMessage ¶
func (*ExtendedContainerInfo_PortMapping) ProtoMessage()
func (*ExtendedContainerInfo_PortMapping) Reset ¶
func (m *ExtendedContainerInfo_PortMapping) Reset()
func (*ExtendedContainerInfo_PortMapping) String ¶
func (m *ExtendedContainerInfo_PortMapping) String() string
type GroupDefinition ¶
type GroupDefinition struct { Id *string `protobuf:"bytes,1,req,name=id" json:"id,omitempty"` Version *string `protobuf:"bytes,2,req,name=version" json:"version,omitempty"` // legacy: new storage uses AppReferences DeprecatedApps []*ServiceDefinition `protobuf:"bytes,3,rep,name=deprecated_apps,json=deprecatedApps" json:"deprecated_apps,omitempty"` DeprecatedPods []*Json `protobuf:"bytes,8,rep,name=deprecated_pods,json=deprecatedPods" json:"deprecated_pods,omitempty"` Groups []*GroupDefinition `protobuf:"bytes,4,rep,name=groups" json:"groups,omitempty"` Dependencies []string `protobuf:"bytes,5,rep,name=dependencies" json:"dependencies,omitempty"` Apps []*GroupDefinition_AppReference `protobuf:"bytes,6,rep,name=apps" json:"apps,omitempty"` Pods []*GroupDefinition_AppReference `protobuf:"bytes,7,rep,name=pods" json:"pods,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*GroupDefinition) Descriptor ¶
func (*GroupDefinition) Descriptor() ([]byte, []int)
func (*GroupDefinition) GetApps ¶
func (m *GroupDefinition) GetApps() []*GroupDefinition_AppReference
func (*GroupDefinition) GetDependencies ¶
func (m *GroupDefinition) GetDependencies() []string
func (*GroupDefinition) GetDeprecatedApps ¶
func (m *GroupDefinition) GetDeprecatedApps() []*ServiceDefinition
func (*GroupDefinition) GetDeprecatedPods ¶
func (m *GroupDefinition) GetDeprecatedPods() []*Json
func (*GroupDefinition) GetGroups ¶
func (m *GroupDefinition) GetGroups() []*GroupDefinition
func (*GroupDefinition) GetId ¶
func (m *GroupDefinition) GetId() string
func (*GroupDefinition) GetPods ¶
func (m *GroupDefinition) GetPods() []*GroupDefinition_AppReference
func (*GroupDefinition) GetVersion ¶
func (m *GroupDefinition) GetVersion() string
func (*GroupDefinition) ProtoMessage ¶
func (*GroupDefinition) ProtoMessage()
func (*GroupDefinition) Reset ¶
func (m *GroupDefinition) Reset()
func (*GroupDefinition) String ¶
func (m *GroupDefinition) String() string
type GroupDefinition_AppReference ¶
type GroupDefinition_AppReference struct { Id *string `protobuf:"bytes,1,req,name=id" json:"id,omitempty"` Version *string `protobuf:"bytes,2,req,name=version" json:"version,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*GroupDefinition_AppReference) Descriptor ¶
func (*GroupDefinition_AppReference) Descriptor() ([]byte, []int)
func (*GroupDefinition_AppReference) GetId ¶
func (m *GroupDefinition_AppReference) GetId() string
func (*GroupDefinition_AppReference) GetVersion ¶
func (m *GroupDefinition_AppReference) GetVersion() string
func (*GroupDefinition_AppReference) ProtoMessage ¶
func (*GroupDefinition_AppReference) ProtoMessage()
func (*GroupDefinition_AppReference) Reset ¶
func (m *GroupDefinition_AppReference) Reset()
func (*GroupDefinition_AppReference) String ¶
func (m *GroupDefinition_AppReference) String() string
type HealthCheckDefinition ¶
type HealthCheckDefinition struct { Protocol *HealthCheckDefinition_Protocol `protobuf:"varint,1,req,name=protocol,enum=mesosphere.marathon.HealthCheckDefinition_Protocol" json:"protocol,omitempty"` PortIndex *uint32 `protobuf:"varint,2,opt,name=portIndex" json:"portIndex,omitempty"` GracePeriodSeconds *uint32 `protobuf:"varint,3,opt,name=gracePeriodSeconds,def=15" json:"gracePeriodSeconds,omitempty"` IntervalSeconds *uint32 `protobuf:"varint,4,opt,name=intervalSeconds,def=10" json:"intervalSeconds,omitempty"` TimeoutSeconds *uint32 `protobuf:"varint,5,opt,name=timeoutSeconds,def=20" json:"timeoutSeconds,omitempty"` Path *string `protobuf:"bytes,6,opt,name=path,def=/" json:"path,omitempty"` MaxConsecutiveFailures *uint32 `protobuf:"varint,7,opt,name=maxConsecutiveFailures,def=3" json:"maxConsecutiveFailures,omitempty"` Command *mesos.CommandInfo `protobuf:"bytes,8,opt,name=command" json:"command,omitempty"` IgnoreHttp1Xx *bool `protobuf:"varint,9,opt,name=ignoreHttp1xx,def=0" json:"ignoreHttp1xx,omitempty"` Port *uint32 `protobuf:"varint,10,opt,name=port" json:"port,omitempty"` DelaySeconds *uint32 `protobuf:"varint,11,opt,name=delaySeconds,def=15" json:"delaySeconds,omitempty"` // portName and portIndex are exclusive; both must not be set PortName *string `protobuf:"bytes,12,opt,name=portName" json:"portName,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*HealthCheckDefinition) Descriptor ¶
func (*HealthCheckDefinition) Descriptor() ([]byte, []int)
func (*HealthCheckDefinition) GetCommand ¶
func (m *HealthCheckDefinition) GetCommand() *mesos.CommandInfo
func (*HealthCheckDefinition) GetDelaySeconds ¶
func (m *HealthCheckDefinition) GetDelaySeconds() uint32
func (*HealthCheckDefinition) GetGracePeriodSeconds ¶
func (m *HealthCheckDefinition) GetGracePeriodSeconds() uint32
func (*HealthCheckDefinition) GetIgnoreHttp1Xx ¶
func (m *HealthCheckDefinition) GetIgnoreHttp1Xx() bool
func (*HealthCheckDefinition) GetIntervalSeconds ¶
func (m *HealthCheckDefinition) GetIntervalSeconds() uint32
func (*HealthCheckDefinition) GetMaxConsecutiveFailures ¶
func (m *HealthCheckDefinition) GetMaxConsecutiveFailures() uint32
func (*HealthCheckDefinition) GetPath ¶
func (m *HealthCheckDefinition) GetPath() string
func (*HealthCheckDefinition) GetPort ¶
func (m *HealthCheckDefinition) GetPort() uint32
func (*HealthCheckDefinition) GetPortIndex ¶
func (m *HealthCheckDefinition) GetPortIndex() uint32
func (*HealthCheckDefinition) GetPortName ¶
func (m *HealthCheckDefinition) GetPortName() string
func (*HealthCheckDefinition) GetProtocol ¶
func (m *HealthCheckDefinition) GetProtocol() HealthCheckDefinition_Protocol
func (*HealthCheckDefinition) GetTimeoutSeconds ¶
func (m *HealthCheckDefinition) GetTimeoutSeconds() uint32
func (*HealthCheckDefinition) ProtoMessage ¶
func (*HealthCheckDefinition) ProtoMessage()
func (*HealthCheckDefinition) Reset ¶
func (m *HealthCheckDefinition) Reset()
func (*HealthCheckDefinition) String ¶
func (m *HealthCheckDefinition) String() string
type HealthCheckDefinition_Protocol ¶
type HealthCheckDefinition_Protocol int32
const ( HealthCheckDefinition_HTTP HealthCheckDefinition_Protocol = 0 HealthCheckDefinition_TCP HealthCheckDefinition_Protocol = 1 HealthCheckDefinition_COMMAND HealthCheckDefinition_Protocol = 2 HealthCheckDefinition_HTTPS HealthCheckDefinition_Protocol = 3 HealthCheckDefinition_MESOS_HTTP HealthCheckDefinition_Protocol = 4 HealthCheckDefinition_MESOS_HTTPS HealthCheckDefinition_Protocol = 5 HealthCheckDefinition_MESOS_TCP HealthCheckDefinition_Protocol = 6 )
func (HealthCheckDefinition_Protocol) Enum ¶
func (x HealthCheckDefinition_Protocol) Enum() *HealthCheckDefinition_Protocol
func (HealthCheckDefinition_Protocol) EnumDescriptor ¶
func (HealthCheckDefinition_Protocol) EnumDescriptor() ([]byte, []int)
func (HealthCheckDefinition_Protocol) String ¶
func (x HealthCheckDefinition_Protocol) String() string
func (*HealthCheckDefinition_Protocol) UnmarshalJSON ¶
func (x *HealthCheckDefinition_Protocol) UnmarshalJSON(data []byte) error
type Json ¶
type Json struct { Json *string `protobuf:"bytes,1,req,name=json" json:"json,omitempty"` XXX_unrecognized []byte `json:"-"` }
we serialize PodDefinition and Instances as json, only required for legacy content
func (*Json) Descriptor ¶
func (*Json) ProtoMessage ¶
func (*Json) ProtoMessage()
type KillSelection ¶
type KillSelection int32
const ( KillSelection_YoungestFirst KillSelection = 1 KillSelection_OldestFirst KillSelection = 2 )
const Default_ServiceDefinition_KillSelection KillSelection = KillSelection_YoungestFirst
func (KillSelection) Enum ¶
func (x KillSelection) Enum() *KillSelection
func (KillSelection) EnumDescriptor ¶
func (KillSelection) EnumDescriptor() ([]byte, []int)
func (KillSelection) String ¶
func (x KillSelection) String() string
func (*KillSelection) UnmarshalJSON ¶
func (x *KillSelection) UnmarshalJSON(data []byte) error
type MarathonApp ¶
type MarathonApp struct { Name *string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"` Tasks []*MarathonTask `protobuf:"bytes,2,rep,name=tasks" json:"tasks,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*MarathonApp) Descriptor ¶
func (*MarathonApp) Descriptor() ([]byte, []int)
func (*MarathonApp) GetName ¶
func (m *MarathonApp) GetName() string
func (*MarathonApp) GetTasks ¶
func (m *MarathonApp) GetTasks() []*MarathonTask
func (*MarathonApp) ProtoMessage ¶
func (*MarathonApp) ProtoMessage()
func (*MarathonApp) Reset ¶
func (m *MarathonApp) Reset()
func (*MarathonApp) String ¶
func (m *MarathonApp) String() string
type MarathonTask ¶
type MarathonTask struct { Id *string `protobuf:"bytes,1,req,name=id" json:"id,omitempty"` OBSOLETEHost *string `protobuf:"bytes,2,opt,name=OBSOLETE_host,json=OBSOLETEHost" json:"OBSOLETE_host,omitempty"` Ports []uint32 `protobuf:"varint,3,rep,name=ports" json:"ports,omitempty"` OBSOLETEAttributes []*mesos.Attribute `protobuf:"bytes,4,rep,name=OBSOLETE_attributes,json=OBSOLETEAttributes" json:"OBSOLETE_attributes,omitempty"` StagedAt *int64 `protobuf:"varint,5,opt,name=staged_at,json=stagedAt" json:"staged_at,omitempty"` StartedAt *int64 `protobuf:"varint,6,opt,name=started_at,json=startedAt" json:"started_at,omitempty"` OBSOLETEStatuses []*mesos.TaskStatus `protobuf:"bytes,7,rep,name=OBSOLETE_statuses,json=OBSOLETEStatuses" json:"OBSOLETE_statuses,omitempty"` Version *string `protobuf:"bytes,8,opt,name=version,def=1970-01-01T00:00:00.000Z" json:"version,omitempty"` Status *mesos.TaskStatus `protobuf:"bytes,9,opt,name=status" json:"status,omitempty"` OBSOLETESlaveId *mesos.SlaveID `protobuf:"bytes,10,opt,name=OBSOLETE_slaveId,json=OBSOLETESlaveId" json:"OBSOLETE_slaveId,omitempty"` OBSOLETENetworks []*mesos.NetworkInfo `protobuf:"bytes,11,rep,name=OBSOLETE_networks,json=OBSOLETENetworks" json:"OBSOLETE_networks,omitempty"` Reservation *MarathonTask_Reservation `protobuf:"bytes,12,opt,name=reservation" json:"reservation,omitempty"` Condition *MarathonTask_Condition `protobuf:"varint,13,opt,name=condition,enum=mesosphere.marathon.MarathonTask_Condition" json:"condition,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*MarathonTask) Descriptor ¶
func (*MarathonTask) Descriptor() ([]byte, []int)
func (*MarathonTask) GetCondition ¶
func (m *MarathonTask) GetCondition() MarathonTask_Condition
func (*MarathonTask) GetId ¶
func (m *MarathonTask) GetId() string
func (*MarathonTask) GetOBSOLETEAttributes ¶
func (m *MarathonTask) GetOBSOLETEAttributes() []*mesos.Attribute
func (*MarathonTask) GetOBSOLETEHost ¶
func (m *MarathonTask) GetOBSOLETEHost() string
func (*MarathonTask) GetOBSOLETENetworks ¶
func (m *MarathonTask) GetOBSOLETENetworks() []*mesos.NetworkInfo
func (*MarathonTask) GetOBSOLETESlaveId ¶
func (m *MarathonTask) GetOBSOLETESlaveId() *mesos.SlaveID
func (*MarathonTask) GetOBSOLETEStatuses ¶
func (m *MarathonTask) GetOBSOLETEStatuses() []*mesos.TaskStatus
func (*MarathonTask) GetPorts ¶
func (m *MarathonTask) GetPorts() []uint32
func (*MarathonTask) GetReservation ¶
func (m *MarathonTask) GetReservation() *MarathonTask_Reservation
func (*MarathonTask) GetStagedAt ¶
func (m *MarathonTask) GetStagedAt() int64
func (*MarathonTask) GetStartedAt ¶
func (m *MarathonTask) GetStartedAt() int64
func (*MarathonTask) GetStatus ¶
func (m *MarathonTask) GetStatus() *mesos.TaskStatus
func (*MarathonTask) GetVersion ¶
func (m *MarathonTask) GetVersion() string
func (*MarathonTask) ProtoMessage ¶
func (*MarathonTask) ProtoMessage()
func (*MarathonTask) Reset ¶
func (m *MarathonTask) Reset()
func (*MarathonTask) String ¶
func (m *MarathonTask) String() string
type MarathonTask_Condition ¶
type MarathonTask_Condition int32
const ( MarathonTask_Invalid MarathonTask_Condition = 0 MarathonTask_Reserved MarathonTask_Condition = 1 MarathonTask_Created MarathonTask_Condition = 2 MarathonTask_Error MarathonTask_Condition = 3 MarathonTask_Failed MarathonTask_Condition = 4 MarathonTask_Finished MarathonTask_Condition = 5 MarathonTask_Killed MarathonTask_Condition = 6 MarathonTask_Killing MarathonTask_Condition = 7 MarathonTask_Lost MarathonTask_Condition = 8 MarathonTask_Running MarathonTask_Condition = 9 MarathonTask_Staging MarathonTask_Condition = 10 MarathonTask_Starting MarathonTask_Condition = 11 MarathonTask_Unreachable MarathonTask_Condition = 12 MarathonTask_Gone MarathonTask_Condition = 13 MarathonTask_Unknown MarathonTask_Condition = 14 MarathonTask_Dropped MarathonTask_Condition = 15 )
func (MarathonTask_Condition) Enum ¶
func (x MarathonTask_Condition) Enum() *MarathonTask_Condition
func (MarathonTask_Condition) EnumDescriptor ¶
func (MarathonTask_Condition) EnumDescriptor() ([]byte, []int)
func (MarathonTask_Condition) String ¶
func (x MarathonTask_Condition) String() string
func (*MarathonTask_Condition) UnmarshalJSON ¶
func (x *MarathonTask_Condition) UnmarshalJSON(data []byte) error
type MarathonTask_Reservation ¶
type MarathonTask_Reservation struct { LocalVolumeIds []string `protobuf:"bytes,1,rep,name=local_volume_ids,json=localVolumeIds" json:"local_volume_ids,omitempty"` State *MarathonTask_Reservation_State `protobuf:"bytes,2,req,name=state" json:"state,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*MarathonTask_Reservation) Descriptor ¶
func (*MarathonTask_Reservation) Descriptor() ([]byte, []int)
func (*MarathonTask_Reservation) GetLocalVolumeIds ¶
func (m *MarathonTask_Reservation) GetLocalVolumeIds() []string
func (*MarathonTask_Reservation) GetState ¶
func (m *MarathonTask_Reservation) GetState() *MarathonTask_Reservation_State
func (*MarathonTask_Reservation) ProtoMessage ¶
func (*MarathonTask_Reservation) ProtoMessage()
func (*MarathonTask_Reservation) Reset ¶
func (m *MarathonTask_Reservation) Reset()
func (*MarathonTask_Reservation) String ¶
func (m *MarathonTask_Reservation) String() string
type MarathonTask_Reservation_State ¶
type MarathonTask_Reservation_State struct { Type *MarathonTask_Reservation_State_Type `protobuf:"varint,1,req,name=type,enum=mesosphere.marathon.MarathonTask_Reservation_State_Type" json:"type,omitempty"` Timeout *MarathonTask_Reservation_State_Timeout `protobuf:"bytes,2,opt,name=timeout" json:"timeout,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*MarathonTask_Reservation_State) Descriptor ¶
func (*MarathonTask_Reservation_State) Descriptor() ([]byte, []int)
func (*MarathonTask_Reservation_State) GetTimeout ¶
func (m *MarathonTask_Reservation_State) GetTimeout() *MarathonTask_Reservation_State_Timeout
func (*MarathonTask_Reservation_State) GetType ¶
func (m *MarathonTask_Reservation_State) GetType() MarathonTask_Reservation_State_Type
func (*MarathonTask_Reservation_State) ProtoMessage ¶
func (*MarathonTask_Reservation_State) ProtoMessage()
func (*MarathonTask_Reservation_State) Reset ¶
func (m *MarathonTask_Reservation_State) Reset()
func (*MarathonTask_Reservation_State) String ¶
func (m *MarathonTask_Reservation_State) String() string
type MarathonTask_Reservation_State_Timeout ¶
type MarathonTask_Reservation_State_Timeout struct { Initiated *int64 `protobuf:"varint,1,req,name=initiated" json:"initiated,omitempty"` Deadline *int64 `protobuf:"varint,2,req,name=deadline" json:"deadline,omitempty"` Reason *MarathonTask_Reservation_State_Timeout_Reason `` /* 130-byte string literal not displayed */ XXX_unrecognized []byte `json:"-"` }
func (*MarathonTask_Reservation_State_Timeout) Descriptor ¶
func (*MarathonTask_Reservation_State_Timeout) Descriptor() ([]byte, []int)
func (*MarathonTask_Reservation_State_Timeout) GetDeadline ¶
func (m *MarathonTask_Reservation_State_Timeout) GetDeadline() int64
func (*MarathonTask_Reservation_State_Timeout) GetInitiated ¶
func (m *MarathonTask_Reservation_State_Timeout) GetInitiated() int64
func (*MarathonTask_Reservation_State_Timeout) GetReason ¶
func (m *MarathonTask_Reservation_State_Timeout) GetReason() MarathonTask_Reservation_State_Timeout_Reason
func (*MarathonTask_Reservation_State_Timeout) ProtoMessage ¶
func (*MarathonTask_Reservation_State_Timeout) ProtoMessage()
func (*MarathonTask_Reservation_State_Timeout) Reset ¶
func (m *MarathonTask_Reservation_State_Timeout) Reset()
func (*MarathonTask_Reservation_State_Timeout) String ¶
func (m *MarathonTask_Reservation_State_Timeout) String() string
type MarathonTask_Reservation_State_Timeout_Reason ¶
type MarathonTask_Reservation_State_Timeout_Reason int32
const ( MarathonTask_Reservation_State_Timeout_RelaunchEscalationTimeout MarathonTask_Reservation_State_Timeout_Reason = 1 MarathonTask_Reservation_State_Timeout_ReservationTimeout MarathonTask_Reservation_State_Timeout_Reason = 2 )
func (MarathonTask_Reservation_State_Timeout_Reason) EnumDescriptor ¶
func (MarathonTask_Reservation_State_Timeout_Reason) EnumDescriptor() ([]byte, []int)
func (MarathonTask_Reservation_State_Timeout_Reason) String ¶
func (x MarathonTask_Reservation_State_Timeout_Reason) String() string
func (*MarathonTask_Reservation_State_Timeout_Reason) UnmarshalJSON ¶
func (x *MarathonTask_Reservation_State_Timeout_Reason) UnmarshalJSON(data []byte) error
type MarathonTask_Reservation_State_Type ¶
type MarathonTask_Reservation_State_Type int32
const ( MarathonTask_Reservation_State_New MarathonTask_Reservation_State_Type = 1 MarathonTask_Reservation_State_Launched MarathonTask_Reservation_State_Type = 2 MarathonTask_Reservation_State_Suspended MarathonTask_Reservation_State_Type = 3 MarathonTask_Reservation_State_Garbage MarathonTask_Reservation_State_Type = 4 MarathonTask_Reservation_State_Unknown MarathonTask_Reservation_State_Type = 5 )
func (MarathonTask_Reservation_State_Type) Enum ¶
func (x MarathonTask_Reservation_State_Type) Enum() *MarathonTask_Reservation_State_Type
func (MarathonTask_Reservation_State_Type) EnumDescriptor ¶
func (MarathonTask_Reservation_State_Type) EnumDescriptor() ([]byte, []int)
func (MarathonTask_Reservation_State_Type) String ¶
func (x MarathonTask_Reservation_State_Type) String() string
func (*MarathonTask_Reservation_State_Type) UnmarshalJSON ¶
func (x *MarathonTask_Reservation_State_Type) UnmarshalJSON(data []byte) error
type NetworkDefinition ¶
type NetworkDefinition struct { Mode *NetworkDefinition_Mode `protobuf:"varint,1,opt,name=mode,enum=mesosphere.marathon.NetworkDefinition_Mode" json:"mode,omitempty"` Name *string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"` Labels []*mesos.Label `protobuf:"bytes,3,rep,name=labels" json:"labels,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*NetworkDefinition) Descriptor ¶
func (*NetworkDefinition) Descriptor() ([]byte, []int)
func (*NetworkDefinition) GetLabels ¶
func (m *NetworkDefinition) GetLabels() []*mesos.Label
func (*NetworkDefinition) GetMode ¶
func (m *NetworkDefinition) GetMode() NetworkDefinition_Mode
func (*NetworkDefinition) GetName ¶
func (m *NetworkDefinition) GetName() string
func (*NetworkDefinition) ProtoMessage ¶
func (*NetworkDefinition) ProtoMessage()
func (*NetworkDefinition) Reset ¶
func (m *NetworkDefinition) Reset()
func (*NetworkDefinition) String ¶
func (m *NetworkDefinition) String() string
type NetworkDefinition_Mode ¶
type NetworkDefinition_Mode int32
const ( NetworkDefinition_UNKNOWN NetworkDefinition_Mode = 0 NetworkDefinition_HOST NetworkDefinition_Mode = 1 NetworkDefinition_CONTAINER NetworkDefinition_Mode = 2 NetworkDefinition_BRIDGE NetworkDefinition_Mode = 3 )
func (NetworkDefinition_Mode) Enum ¶
func (x NetworkDefinition_Mode) Enum() *NetworkDefinition_Mode
func (NetworkDefinition_Mode) EnumDescriptor ¶
func (NetworkDefinition_Mode) EnumDescriptor() ([]byte, []int)
func (NetworkDefinition_Mode) String ¶
func (x NetworkDefinition_Mode) String() string
func (*NetworkDefinition_Mode) UnmarshalJSON ¶
func (x *NetworkDefinition_Mode) UnmarshalJSON(data []byte) error
type ObsoleteDiscoveryInfo ¶
type ObsoleteDiscoveryInfo struct { Ports []*mesos.Port `protobuf:"bytes,1,rep,name=ports" json:"ports,omitempty"` XXX_unrecognized []byte `json:"-"` }
deprecated, left here only to support migrations
func (*ObsoleteDiscoveryInfo) Descriptor ¶
func (*ObsoleteDiscoveryInfo) Descriptor() ([]byte, []int)
func (*ObsoleteDiscoveryInfo) GetPorts ¶
func (m *ObsoleteDiscoveryInfo) GetPorts() []*mesos.Port
func (*ObsoleteDiscoveryInfo) ProtoMessage ¶
func (*ObsoleteDiscoveryInfo) ProtoMessage()
func (*ObsoleteDiscoveryInfo) Reset ¶
func (m *ObsoleteDiscoveryInfo) Reset()
func (*ObsoleteDiscoveryInfo) String ¶
func (m *ObsoleteDiscoveryInfo) String() string
type ObsoleteIpAddress ¶
type ObsoleteIpAddress struct { Groups []string `protobuf:"bytes,1,rep,name=groups" json:"groups,omitempty"` Labels []*mesos.Label `protobuf:"bytes,2,rep,name=labels" json:"labels,omitempty"` DiscoveryInfo *ObsoleteDiscoveryInfo `protobuf:"bytes,3,opt,name=discoveryInfo" json:"discoveryInfo,omitempty"` NetworkName *string `protobuf:"bytes,4,opt,name=networkName" json:"networkName,omitempty"` XXX_unrecognized []byte `json:"-"` }
deprecated, left here only to support migrations
func (*ObsoleteIpAddress) Descriptor ¶
func (*ObsoleteIpAddress) Descriptor() ([]byte, []int)
func (*ObsoleteIpAddress) GetDiscoveryInfo ¶
func (m *ObsoleteIpAddress) GetDiscoveryInfo() *ObsoleteDiscoveryInfo
func (*ObsoleteIpAddress) GetGroups ¶
func (m *ObsoleteIpAddress) GetGroups() []string
func (*ObsoleteIpAddress) GetLabels ¶
func (m *ObsoleteIpAddress) GetLabels() []*mesos.Label
func (*ObsoleteIpAddress) GetNetworkName ¶
func (m *ObsoleteIpAddress) GetNetworkName() string
func (*ObsoleteIpAddress) ProtoMessage ¶
func (*ObsoleteIpAddress) ProtoMessage()
func (*ObsoleteIpAddress) Reset ¶
func (m *ObsoleteIpAddress) Reset()
func (*ObsoleteIpAddress) String ¶
func (m *ObsoleteIpAddress) String() string
type ReadinessCheckDefinition ¶
type ReadinessCheckDefinition struct { Name *string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"` Protocol *ReadinessCheckDefinition_Protocol `protobuf:"varint,2,opt,name=protocol,enum=mesosphere.marathon.ReadinessCheckDefinition_Protocol" json:"protocol,omitempty"` Path *string `protobuf:"bytes,3,opt,name=path" json:"path,omitempty"` PortName *string `protobuf:"bytes,4,opt,name=portName" json:"portName,omitempty"` IntervalMillis *uint64 `protobuf:"varint,5,opt,name=intervalMillis" json:"intervalMillis,omitempty"` TimeoutMillis *uint64 `protobuf:"varint,6,opt,name=timeoutMillis" json:"timeoutMillis,omitempty"` HttpStatusCodeForReady []uint32 `protobuf:"varint,7,rep,name=httpStatusCodeForReady" json:"httpStatusCodeForReady,omitempty"` PreserveLastResponse *bool `protobuf:"varint,8,opt,name=preserveLastResponse" json:"preserveLastResponse,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ReadinessCheckDefinition) Descriptor ¶
func (*ReadinessCheckDefinition) Descriptor() ([]byte, []int)
func (*ReadinessCheckDefinition) GetHttpStatusCodeForReady ¶
func (m *ReadinessCheckDefinition) GetHttpStatusCodeForReady() []uint32
func (*ReadinessCheckDefinition) GetIntervalMillis ¶
func (m *ReadinessCheckDefinition) GetIntervalMillis() uint64
func (*ReadinessCheckDefinition) GetName ¶
func (m *ReadinessCheckDefinition) GetName() string
func (*ReadinessCheckDefinition) GetPath ¶
func (m *ReadinessCheckDefinition) GetPath() string
func (*ReadinessCheckDefinition) GetPortName ¶
func (m *ReadinessCheckDefinition) GetPortName() string
func (*ReadinessCheckDefinition) GetPreserveLastResponse ¶
func (m *ReadinessCheckDefinition) GetPreserveLastResponse() bool
func (*ReadinessCheckDefinition) GetProtocol ¶
func (m *ReadinessCheckDefinition) GetProtocol() ReadinessCheckDefinition_Protocol
func (*ReadinessCheckDefinition) GetTimeoutMillis ¶
func (m *ReadinessCheckDefinition) GetTimeoutMillis() uint64
func (*ReadinessCheckDefinition) ProtoMessage ¶
func (*ReadinessCheckDefinition) ProtoMessage()
func (*ReadinessCheckDefinition) Reset ¶
func (m *ReadinessCheckDefinition) Reset()
func (*ReadinessCheckDefinition) String ¶
func (m *ReadinessCheckDefinition) String() string
type ReadinessCheckDefinition_Protocol ¶
type ReadinessCheckDefinition_Protocol int32
const ( ReadinessCheckDefinition_HTTP ReadinessCheckDefinition_Protocol = 0 ReadinessCheckDefinition_HTTPS ReadinessCheckDefinition_Protocol = 1 )
func (ReadinessCheckDefinition_Protocol) Enum ¶
func (x ReadinessCheckDefinition_Protocol) Enum() *ReadinessCheckDefinition_Protocol
func (ReadinessCheckDefinition_Protocol) EnumDescriptor ¶
func (ReadinessCheckDefinition_Protocol) EnumDescriptor() ([]byte, []int)
func (ReadinessCheckDefinition_Protocol) String ¶
func (x ReadinessCheckDefinition_Protocol) String() string
func (*ReadinessCheckDefinition_Protocol) UnmarshalJSON ¶
func (x *ReadinessCheckDefinition_Protocol) UnmarshalJSON(data []byte) error
type ResidencyDefinition ¶
type ResidencyDefinition struct { RelaunchEscalationTimeoutSeconds *int64 `protobuf:"varint,1,opt,name=relaunchEscalationTimeoutSeconds" json:"relaunchEscalationTimeoutSeconds,omitempty"` TaskLostBehavior *ResidencyDefinition_TaskLostBehavior `` /* 141-byte string literal not displayed */ XXX_unrecognized []byte `json:"-"` }
func (*ResidencyDefinition) Descriptor ¶
func (*ResidencyDefinition) Descriptor() ([]byte, []int)
func (*ResidencyDefinition) GetRelaunchEscalationTimeoutSeconds ¶
func (m *ResidencyDefinition) GetRelaunchEscalationTimeoutSeconds() int64
func (*ResidencyDefinition) GetTaskLostBehavior ¶
func (m *ResidencyDefinition) GetTaskLostBehavior() ResidencyDefinition_TaskLostBehavior
func (*ResidencyDefinition) ProtoMessage ¶
func (*ResidencyDefinition) ProtoMessage()
func (*ResidencyDefinition) Reset ¶
func (m *ResidencyDefinition) Reset()
func (*ResidencyDefinition) String ¶
func (m *ResidencyDefinition) String() string
type ResidencyDefinition_TaskLostBehavior ¶
type ResidencyDefinition_TaskLostBehavior int32
const ( ResidencyDefinition_RELAUNCH_AFTER_TIMEOUT ResidencyDefinition_TaskLostBehavior = 0 ResidencyDefinition_WAIT_FOREVER ResidencyDefinition_TaskLostBehavior = 1 )
func (ResidencyDefinition_TaskLostBehavior) Enum ¶
func (x ResidencyDefinition_TaskLostBehavior) Enum() *ResidencyDefinition_TaskLostBehavior
func (ResidencyDefinition_TaskLostBehavior) EnumDescriptor ¶
func (ResidencyDefinition_TaskLostBehavior) EnumDescriptor() ([]byte, []int)
func (ResidencyDefinition_TaskLostBehavior) String ¶
func (x ResidencyDefinition_TaskLostBehavior) String() string
func (*ResidencyDefinition_TaskLostBehavior) UnmarshalJSON ¶
func (x *ResidencyDefinition_TaskLostBehavior) UnmarshalJSON(data []byte) error
type ResourceRoles ¶
type ResourceRoles struct { Role []string `protobuf:"bytes,1,rep,name=role" json:"role,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ResourceRoles) Descriptor ¶
func (*ResourceRoles) Descriptor() ([]byte, []int)
func (*ResourceRoles) GetRole ¶
func (m *ResourceRoles) GetRole() []string
func (*ResourceRoles) ProtoMessage ¶
func (*ResourceRoles) ProtoMessage()
func (*ResourceRoles) Reset ¶
func (m *ResourceRoles) Reset()
func (*ResourceRoles) String ¶
func (m *ResourceRoles) String() string
type Secret ¶
type Secret struct { Id *string `protobuf:"bytes,1,req,name=id" json:"id,omitempty"` Source *string `protobuf:"bytes,2,req,name=source" json:"source,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Secret) Descriptor ¶
func (*Secret) ProtoMessage ¶
func (*Secret) ProtoMessage()
type ServiceDefinition ¶
type ServiceDefinition struct { Id *string `protobuf:"bytes,1,req,name=id" json:"id,omitempty"` Cmd *mesos.CommandInfo `protobuf:"bytes,2,req,name=cmd" json:"cmd,omitempty"` Instances *uint32 `protobuf:"varint,3,req,name=instances" json:"instances,omitempty"` Resources []*mesos.Resource `protobuf:"bytes,4,rep,name=resources" json:"resources,omitempty"` Description *string `protobuf:"bytes,5,opt,name=description" json:"description,omitempty"` Ports []uint32 `protobuf:"varint,6,rep,name=ports" json:"ports,omitempty"` Constraints []*Constraint `protobuf:"bytes,7,rep,name=constraints" json:"constraints,omitempty"` Executor *string `protobuf:"bytes,8,req,name=executor,def=" json:"executor,omitempty"` // optional double taskRateLimit = 9 [default = 1]; OBSOLETEContainer *ContainerInfo `protobuf:"bytes,10,opt,name=OBSOLETE_container,json=OBSOLETEContainer" json:"OBSOLETE_container,omitempty"` Version *string `protobuf:"bytes,11,opt,name=version,def=1970-01-01T00:00:00.000Z" json:"version,omitempty"` HealthChecks []*HealthCheckDefinition `protobuf:"bytes,12,rep,name=healthChecks" json:"healthChecks,omitempty"` Backoff *int64 `protobuf:"varint,13,opt,name=backoff,def=1000" json:"backoff,omitempty"` BackoffFactor *float64 `protobuf:"fixed64,14,opt,name=backoffFactor,def=1.15" json:"backoffFactor,omitempty"` UpgradeStrategy *UpgradeStrategyDefinition `protobuf:"bytes,15,opt,name=upgradeStrategy" json:"upgradeStrategy,omitempty"` Dependencies []string `protobuf:"bytes,16,rep,name=dependencies" json:"dependencies,omitempty"` StoreUrls []string `protobuf:"bytes,17,rep,name=storeUrls" json:"storeUrls,omitempty"` RequirePorts *bool `protobuf:"varint,18,opt,name=require_ports,json=requirePorts,def=0" json:"require_ports,omitempty"` Container *ExtendedContainerInfo `protobuf:"bytes,19,opt,name=container" json:"container,omitempty"` Labels []*mesos.Parameter `protobuf:"bytes,20,rep,name=labels" json:"labels,omitempty"` MaxLaunchDelay *int64 `protobuf:"varint,21,opt,name=maxLaunchDelay,def=3600000" json:"maxLaunchDelay,omitempty"` AcceptedResourceRoles *ResourceRoles `protobuf:"bytes,22,opt,name=acceptedResourceRoles" json:"acceptedResourceRoles,omitempty"` LastScalingAt *int64 `protobuf:"varint,23,opt,name=last_scaling_at,json=lastScalingAt" json:"last_scaling_at,omitempty"` LastConfigChangeAt *int64 `protobuf:"varint,24,opt,name=last_config_change_at,json=lastConfigChangeAt" json:"last_config_change_at,omitempty"` OBSOLETEIpAddress *ObsoleteIpAddress `protobuf:"bytes,25,opt,name=OBSOLETE_ipAddress,json=OBSOLETEIpAddress" json:"OBSOLETE_ipAddress,omitempty"` Residency *ResidencyDefinition `protobuf:"bytes,26,opt,name=residency" json:"residency,omitempty"` PortDefinitions []*mesos.Port `protobuf:"bytes,27,rep,name=portDefinitions" json:"portDefinitions,omitempty"` ReadinessCheckDefinition []*ReadinessCheckDefinition `protobuf:"bytes,28,rep,name=readinessCheckDefinition" json:"readinessCheckDefinition,omitempty"` Secrets []*Secret `protobuf:"bytes,29,rep,name=secrets" json:"secrets,omitempty"` EnvVarReferences []*EnvVarReference `protobuf:"bytes,30,rep,name=envVarReferences" json:"envVarReferences,omitempty"` TaskKillGracePeriod *int64 `protobuf:"varint,31,opt,name=taskKillGracePeriod" json:"taskKillGracePeriod,omitempty"` UnreachableStrategy *UnreachableStrategy `protobuf:"bytes,32,opt,name=unreachableStrategy" json:"unreachableStrategy,omitempty"` KillSelection *KillSelection `protobuf:"varint,33,opt,name=killSelection,enum=mesosphere.marathon.KillSelection,def=1" json:"killSelection,omitempty"` Networks []*NetworkDefinition `protobuf:"bytes,34,rep,name=networks" json:"networks,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ServiceDefinition) Descriptor ¶
func (*ServiceDefinition) Descriptor() ([]byte, []int)
func (*ServiceDefinition) GetAcceptedResourceRoles ¶
func (m *ServiceDefinition) GetAcceptedResourceRoles() *ResourceRoles
func (*ServiceDefinition) GetBackoff ¶
func (m *ServiceDefinition) GetBackoff() int64
func (*ServiceDefinition) GetBackoffFactor ¶
func (m *ServiceDefinition) GetBackoffFactor() float64
func (*ServiceDefinition) GetCmd ¶
func (m *ServiceDefinition) GetCmd() *mesos.CommandInfo
func (*ServiceDefinition) GetConstraints ¶
func (m *ServiceDefinition) GetConstraints() []*Constraint
func (*ServiceDefinition) GetContainer ¶
func (m *ServiceDefinition) GetContainer() *ExtendedContainerInfo
func (*ServiceDefinition) GetDependencies ¶
func (m *ServiceDefinition) GetDependencies() []string
func (*ServiceDefinition) GetDescription ¶
func (m *ServiceDefinition) GetDescription() string
func (*ServiceDefinition) GetEnvVarReferences ¶
func (m *ServiceDefinition) GetEnvVarReferences() []*EnvVarReference
func (*ServiceDefinition) GetExecutor ¶
func (m *ServiceDefinition) GetExecutor() string
func (*ServiceDefinition) GetHealthChecks ¶
func (m *ServiceDefinition) GetHealthChecks() []*HealthCheckDefinition
func (*ServiceDefinition) GetId ¶
func (m *ServiceDefinition) GetId() string
func (*ServiceDefinition) GetInstances ¶
func (m *ServiceDefinition) GetInstances() uint32
func (*ServiceDefinition) GetKillSelection ¶
func (m *ServiceDefinition) GetKillSelection() KillSelection
func (*ServiceDefinition) GetLabels ¶
func (m *ServiceDefinition) GetLabels() []*mesos.Parameter
func (*ServiceDefinition) GetLastConfigChangeAt ¶
func (m *ServiceDefinition) GetLastConfigChangeAt() int64
func (*ServiceDefinition) GetLastScalingAt ¶
func (m *ServiceDefinition) GetLastScalingAt() int64
func (*ServiceDefinition) GetMaxLaunchDelay ¶
func (m *ServiceDefinition) GetMaxLaunchDelay() int64
func (*ServiceDefinition) GetNetworks ¶
func (m *ServiceDefinition) GetNetworks() []*NetworkDefinition
func (*ServiceDefinition) GetOBSOLETEContainer ¶
func (m *ServiceDefinition) GetOBSOLETEContainer() *ContainerInfo
func (*ServiceDefinition) GetOBSOLETEIpAddress ¶
func (m *ServiceDefinition) GetOBSOLETEIpAddress() *ObsoleteIpAddress
func (*ServiceDefinition) GetPortDefinitions ¶
func (m *ServiceDefinition) GetPortDefinitions() []*mesos.Port
func (*ServiceDefinition) GetPorts ¶
func (m *ServiceDefinition) GetPorts() []uint32
func (*ServiceDefinition) GetReadinessCheckDefinition ¶
func (m *ServiceDefinition) GetReadinessCheckDefinition() []*ReadinessCheckDefinition
func (*ServiceDefinition) GetRequirePorts ¶
func (m *ServiceDefinition) GetRequirePorts() bool
func (*ServiceDefinition) GetResidency ¶
func (m *ServiceDefinition) GetResidency() *ResidencyDefinition
func (*ServiceDefinition) GetResources ¶
func (m *ServiceDefinition) GetResources() []*mesos.Resource
func (*ServiceDefinition) GetSecrets ¶
func (m *ServiceDefinition) GetSecrets() []*Secret
func (*ServiceDefinition) GetStoreUrls ¶
func (m *ServiceDefinition) GetStoreUrls() []string
func (*ServiceDefinition) GetTaskKillGracePeriod ¶
func (m *ServiceDefinition) GetTaskKillGracePeriod() int64
func (*ServiceDefinition) GetUnreachableStrategy ¶
func (m *ServiceDefinition) GetUnreachableStrategy() *UnreachableStrategy
func (*ServiceDefinition) GetUpgradeStrategy ¶
func (m *ServiceDefinition) GetUpgradeStrategy() *UpgradeStrategyDefinition
func (*ServiceDefinition) GetVersion ¶
func (m *ServiceDefinition) GetVersion() string
func (*ServiceDefinition) ProtoMessage ¶
func (*ServiceDefinition) ProtoMessage()
func (*ServiceDefinition) Reset ¶
func (m *ServiceDefinition) Reset()
func (*ServiceDefinition) String ¶
func (m *ServiceDefinition) String() string
type StorageVersion ¶
type StorageVersion struct { Major *uint32 `protobuf:"varint,1,req,name=major" json:"major,omitempty"` Minor *uint32 `protobuf:"varint,2,req,name=minor" json:"minor,omitempty"` Patch *uint32 `protobuf:"varint,3,req,name=patch" json:"patch,omitempty"` // when we read old formats, we always assume legacy. Format *StorageVersion_StorageFormat `protobuf:"varint,4,opt,name=format,enum=mesosphere.marathon.StorageVersion_StorageFormat,def=0" json:"format,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*StorageVersion) Descriptor ¶
func (*StorageVersion) Descriptor() ([]byte, []int)
func (*StorageVersion) GetFormat ¶
func (m *StorageVersion) GetFormat() StorageVersion_StorageFormat
func (*StorageVersion) GetMajor ¶
func (m *StorageVersion) GetMajor() uint32
func (*StorageVersion) GetMinor ¶
func (m *StorageVersion) GetMinor() uint32
func (*StorageVersion) GetPatch ¶
func (m *StorageVersion) GetPatch() uint32
func (*StorageVersion) ProtoMessage ¶
func (*StorageVersion) ProtoMessage()
func (*StorageVersion) Reset ¶
func (m *StorageVersion) Reset()
func (*StorageVersion) String ¶
func (m *StorageVersion) String() string
type StorageVersion_StorageFormat ¶
type StorageVersion_StorageFormat int32
const ( StorageVersion_LEGACY StorageVersion_StorageFormat = 0 StorageVersion_PERSISTENCE_STORE StorageVersion_StorageFormat = 1 )
const Default_StorageVersion_Format StorageVersion_StorageFormat = StorageVersion_LEGACY
func (StorageVersion_StorageFormat) Enum ¶
func (x StorageVersion_StorageFormat) Enum() *StorageVersion_StorageFormat
func (StorageVersion_StorageFormat) EnumDescriptor ¶
func (StorageVersion_StorageFormat) EnumDescriptor() ([]byte, []int)
func (StorageVersion_StorageFormat) String ¶
func (x StorageVersion_StorageFormat) String() string
func (*StorageVersion_StorageFormat) UnmarshalJSON ¶
func (x *StorageVersion_StorageFormat) UnmarshalJSON(data []byte) error
type TaskFailure ¶
type TaskFailure struct { AppId *string `protobuf:"bytes,1,req,name=app_id,json=appId" json:"app_id,omitempty"` TaskId *mesos.TaskID `protobuf:"bytes,2,req,name=task_id,json=taskId" json:"task_id,omitempty"` State *mesos.TaskState `protobuf:"varint,3,req,name=state,enum=mesos.TaskState" json:"state,omitempty"` Message *string `protobuf:"bytes,4,opt,name=message,def=" json:"message,omitempty"` Host *string `protobuf:"bytes,5,opt,name=host,def=" json:"host,omitempty"` Version *string `protobuf:"bytes,6,req,name=version" json:"version,omitempty"` Timestamp *string `protobuf:"bytes,7,req,name=timestamp" json:"timestamp,omitempty"` SlaveId *mesos.SlaveID `protobuf:"bytes,8,opt,name=slaveId" json:"slaveId,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*TaskFailure) Descriptor ¶
func (*TaskFailure) Descriptor() ([]byte, []int)
func (*TaskFailure) GetAppId ¶
func (m *TaskFailure) GetAppId() string
func (*TaskFailure) GetHost ¶
func (m *TaskFailure) GetHost() string
func (*TaskFailure) GetMessage ¶
func (m *TaskFailure) GetMessage() string
func (*TaskFailure) GetSlaveId ¶
func (m *TaskFailure) GetSlaveId() *mesos.SlaveID
func (*TaskFailure) GetState ¶
func (m *TaskFailure) GetState() mesos.TaskState
func (*TaskFailure) GetTaskId ¶
func (m *TaskFailure) GetTaskId() *mesos.TaskID
func (*TaskFailure) GetTimestamp ¶
func (m *TaskFailure) GetTimestamp() string
func (*TaskFailure) GetVersion ¶
func (m *TaskFailure) GetVersion() string
func (*TaskFailure) ProtoMessage ¶
func (*TaskFailure) ProtoMessage()
func (*TaskFailure) Reset ¶
func (m *TaskFailure) Reset()
func (*TaskFailure) String ¶
func (m *TaskFailure) String() string
type UnreachableStrategy ¶
type UnreachableStrategy struct { // UnreachableDisabled is represented by both of these fields missing InactiveAfterSeconds *uint64 `protobuf:"varint,1,opt,name=inactiveAfterSeconds,def=900" json:"inactiveAfterSeconds,omitempty"` ExpungeAfterSeconds *uint64 `protobuf:"varint,2,opt,name=expungeAfterSeconds,def=604800" json:"expungeAfterSeconds,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*UnreachableStrategy) Descriptor ¶
func (*UnreachableStrategy) Descriptor() ([]byte, []int)
func (*UnreachableStrategy) GetExpungeAfterSeconds ¶
func (m *UnreachableStrategy) GetExpungeAfterSeconds() uint64
func (*UnreachableStrategy) GetInactiveAfterSeconds ¶
func (m *UnreachableStrategy) GetInactiveAfterSeconds() uint64
func (*UnreachableStrategy) ProtoMessage ¶
func (*UnreachableStrategy) ProtoMessage()
func (*UnreachableStrategy) Reset ¶
func (m *UnreachableStrategy) Reset()
func (*UnreachableStrategy) String ¶
func (m *UnreachableStrategy) String() string
type UpgradeStrategyDefinition ¶
type UpgradeStrategyDefinition struct { MinimumHealthCapacity *float64 `protobuf:"fixed64,1,req,name=minimumHealthCapacity" json:"minimumHealthCapacity,omitempty"` MaximumOverCapacity *float64 `protobuf:"fixed64,2,opt,name=maximumOverCapacity,def=1" json:"maximumOverCapacity,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*UpgradeStrategyDefinition) Descriptor ¶
func (*UpgradeStrategyDefinition) Descriptor() ([]byte, []int)
func (*UpgradeStrategyDefinition) GetMaximumOverCapacity ¶
func (m *UpgradeStrategyDefinition) GetMaximumOverCapacity() float64
func (*UpgradeStrategyDefinition) GetMinimumHealthCapacity ¶
func (m *UpgradeStrategyDefinition) GetMinimumHealthCapacity() float64
func (*UpgradeStrategyDefinition) ProtoMessage ¶
func (*UpgradeStrategyDefinition) ProtoMessage()
func (*UpgradeStrategyDefinition) Reset ¶
func (m *UpgradeStrategyDefinition) Reset()
func (*UpgradeStrategyDefinition) String ¶
func (m *UpgradeStrategyDefinition) String() string
type Volume ¶
type Volume struct { Mode *mesos.Volume_Mode `protobuf:"varint,3,req,name=mode,enum=mesos.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 *mesos.Image `protobuf:"bytes,4,opt,name=image" json:"image,omitempty"` // Defines a Persistent Volume; implies no hostPath or external. Persistent *Volume_PersistentVolumeInfo `protobuf:"bytes,5,opt,name=persistent" json:"persistent,omitempty"` // Defines an External Volume; implies no hostPath or persistent. External *Volume_ExternalVolumeInfo `protobuf:"bytes,6,opt,name=external" json:"external,omitempty"` XXX_unrecognized []byte `json:"-"` }
Copied from mesos.proto and adjusted to meet the needs of persistent volumes 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) GetContainerPath ¶
func (*Volume) GetExternal ¶
func (m *Volume) GetExternal() *Volume_ExternalVolumeInfo
func (*Volume) GetHostPath ¶
func (*Volume) GetMode ¶
func (m *Volume) GetMode() mesos.Volume_Mode
func (*Volume) GetPersistent ¶
func (m *Volume) GetPersistent() *Volume_PersistentVolumeInfo
func (*Volume) ProtoMessage ¶
func (*Volume) ProtoMessage()
type Volume_ExternalVolumeInfo ¶
type Volume_ExternalVolumeInfo struct { Size *uint64 `protobuf:"varint,1,opt,name=size" json:"size,omitempty"` Name *string `protobuf:"bytes,2,req,name=name" json:"name,omitempty"` Provider *string `protobuf:"bytes,3,req,name=provider" json:"provider,omitempty"` Options []*mesos.Label `protobuf:"bytes,4,rep,name=options" json:"options,omitempty"` XXX_unrecognized []byte `json:"-"` }
Defining properties of external volumes
func (*Volume_ExternalVolumeInfo) Descriptor ¶
func (*Volume_ExternalVolumeInfo) Descriptor() ([]byte, []int)
func (*Volume_ExternalVolumeInfo) GetName ¶
func (m *Volume_ExternalVolumeInfo) GetName() string
func (*Volume_ExternalVolumeInfo) GetOptions ¶
func (m *Volume_ExternalVolumeInfo) GetOptions() []*mesos.Label
func (*Volume_ExternalVolumeInfo) GetProvider ¶
func (m *Volume_ExternalVolumeInfo) GetProvider() string
func (*Volume_ExternalVolumeInfo) GetSize ¶
func (m *Volume_ExternalVolumeInfo) GetSize() uint64
func (*Volume_ExternalVolumeInfo) ProtoMessage ¶
func (*Volume_ExternalVolumeInfo) ProtoMessage()
func (*Volume_ExternalVolumeInfo) Reset ¶
func (m *Volume_ExternalVolumeInfo) Reset()
func (*Volume_ExternalVolumeInfo) String ¶
func (m *Volume_ExternalVolumeInfo) String() string
type Volume_PersistentVolumeInfo ¶
type Volume_PersistentVolumeInfo struct { Size *uint64 `protobuf:"varint,1,req,name=size" json:"size,omitempty"` Type *mesos.Resource_DiskInfo_Source_Type `protobuf:"varint,2,opt,name=type,enum=mesos.Resource_DiskInfo_Source_Type" json:"type,omitempty"` Constraints []*Constraint `protobuf:"bytes,3,rep,name=constraints" json:"constraints,omitempty"` MaxSize *uint64 `protobuf:"varint,4,opt,name=maxSize" json:"maxSize,omitempty"` XXX_unrecognized []byte `json:"-"` }
Defining properties of persistent volumes
func (*Volume_PersistentVolumeInfo) Descriptor ¶
func (*Volume_PersistentVolumeInfo) Descriptor() ([]byte, []int)
func (*Volume_PersistentVolumeInfo) GetConstraints ¶
func (m *Volume_PersistentVolumeInfo) GetConstraints() []*Constraint
func (*Volume_PersistentVolumeInfo) GetMaxSize ¶
func (m *Volume_PersistentVolumeInfo) GetMaxSize() uint64
func (*Volume_PersistentVolumeInfo) GetSize ¶
func (m *Volume_PersistentVolumeInfo) GetSize() uint64
func (*Volume_PersistentVolumeInfo) GetType ¶
func (m *Volume_PersistentVolumeInfo) GetType() mesos.Resource_DiskInfo_Source_Type
func (*Volume_PersistentVolumeInfo) ProtoMessage ¶
func (*Volume_PersistentVolumeInfo) ProtoMessage()
func (*Volume_PersistentVolumeInfo) Reset ¶
func (m *Volume_PersistentVolumeInfo) Reset()
func (*Volume_PersistentVolumeInfo) String ¶
func (m *Volume_PersistentVolumeInfo) String() string
type ZKStoreEntry ¶
type ZKStoreEntry struct { Name *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"` Uuid []byte `protobuf:"bytes,2,req,name=uuid" json:"uuid,omitempty"` Value []byte `protobuf:"bytes,3,req,name=value" json:"value,omitempty"` // This flag indicates, if the byte array in value is gzip compressed // Introduced in Marathon 0.12 // Optional to be backward compatible Compressed *bool `protobuf:"varint,4,opt,name=compressed,def=0" json:"compressed,omitempty"` XXX_unrecognized []byte `json:"-"` }
* Describes a state entry, a versioned (via a UUID) key/value pair. Copied from libmesos (src/messages/state.pro) to ensure compatibility with ZooKeeperState from libmesos.
func (*ZKStoreEntry) Descriptor ¶
func (*ZKStoreEntry) Descriptor() ([]byte, []int)
func (*ZKStoreEntry) GetCompressed ¶
func (m *ZKStoreEntry) GetCompressed() bool
func (*ZKStoreEntry) GetName ¶
func (m *ZKStoreEntry) GetName() string
func (*ZKStoreEntry) GetUuid ¶
func (m *ZKStoreEntry) GetUuid() []byte
func (*ZKStoreEntry) GetValue ¶
func (m *ZKStoreEntry) GetValue() []byte
func (*ZKStoreEntry) ProtoMessage ¶
func (*ZKStoreEntry) ProtoMessage()
func (*ZKStoreEntry) Reset ¶
func (m *ZKStoreEntry) Reset()
func (*ZKStoreEntry) String ¶
func (m *ZKStoreEntry) String() string