mesos

package

Go to main page

Versions in this module

v0

v0.0.11

May 15, 2020

Changes in this version

+ const Default_DrainConfig_MarkGone

+ const Default_LinuxInfo_ShareCgroups

+ var DrainState_name = map[int32]string

+ var DrainState_value = map[string]int32

+ var LinuxInfo_IpcMode_name = map[int32]string

+ var LinuxInfo_IpcMode_value = map[string]int32

type AgentInfo_Capability

+ func (m *AgentInfo_Capability) Size() (n int)

type AgentInfo_Capability_Type

+ const AgentInfo_Capability_AGENT_DRAINING

+ const AgentInfo_Capability_TASK_RESOURCE_LIMITS

type CSIPluginContainerInfo

+ func (m *CSIPluginContainerInfo) Size() (n int)

type CSIPluginInfo

+ func (m *CSIPluginInfo) Size() (n int)

type CgroupInfo_Blkio

+ func (m *CgroupInfo_Blkio) Size() (n int)

type CgroupInfo_Blkio_CFQ

+ func (m *CgroupInfo_Blkio_CFQ) Size() (n int)

type CgroupInfo_Blkio_CFQ_Statistics

+ func (m *CgroupInfo_Blkio_CFQ_Statistics) Size() (n int)

type CgroupInfo_Blkio_Statistics

+ func (m *CgroupInfo_Blkio_Statistics) Size() (n int)

type CgroupInfo_Blkio_Throttling

+ func (m *CgroupInfo_Blkio_Throttling) Size() (n int)

type CgroupInfo_Blkio_Throttling_Statistics

+ func (m *CgroupInfo_Blkio_Throttling_Statistics) Size() (n int)

type CgroupInfo_Blkio_Value

+ func (m *CgroupInfo_Blkio_Value) Size() (n int)

type CheckInfo

+ func (m *CheckInfo) Size() (n int)

type CheckInfo_Command

+ func (m *CheckInfo_Command) Size() (n int)

type CheckInfo_Http

+ func (m *CheckInfo_Http) Size() (n int)

type CheckInfo_Tcp

+ func (m *CheckInfo_Tcp) Size() (n int)

type CheckStatusInfo

+ func (m *CheckStatusInfo) Size() (n int)

type CheckStatusInfo_Command

+ func (m *CheckStatusInfo_Command) Size() (n int)

type CheckStatusInfo_Http

+ func (m *CheckStatusInfo_Http) Size() (n int)

type CheckStatusInfo_Tcp

+ func (m *CheckStatusInfo_Tcp) Size() (n int)

type Device

+ func (m *Device) Size() (n int)

type DeviceAccess

+ func (m *DeviceAccess) Size() (n int)

type DeviceAccess_Access

+ func (m *DeviceAccess_Access) Size() (n int)

type DeviceWhitelist

+ func (m *DeviceWhitelist) Size() (n int)

type Device_Number

+ func (m *Device_Number) Size() (n int)

type DiskStatistics

+ func (m *DiskStatistics) Size() (n int)

type DomainInfo

+ func (m *DomainInfo) Size() (n int)

type DomainInfo_FaultDomain

+ func (m *DomainInfo_FaultDomain) Size() (n int)

type DomainInfo_FaultDomain_RegionInfo

+ func (m *DomainInfo_FaultDomain_RegionInfo) Size() (n int)

type DomainInfo_FaultDomain_ZoneInfo

+ func (m *DomainInfo_FaultDomain_ZoneInfo) Size() (n int)

+ type DrainConfig struct

+ MarkGone *bool

+ MaxGracePeriod *DurationInfo

+ func NewPopulatedDrainConfig(r randyMesos, easy bool) *DrainConfig

+ func (*DrainConfig) Descriptor() ([]byte, []int)

+ func (*DrainConfig) ProtoMessage()

+ func (m *DrainConfig) GetMarkGone() bool

+ func (m *DrainConfig) GetMaxGracePeriod() *DurationInfo

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

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

+ func (m *DrainConfig) Reset()

+ func (m *DrainConfig) Size() (n int)

+ func (m *DrainConfig) Unmarshal(dAtA []byte) error

+ func (mj *DrainConfig) MarshalJSON() ([]byte, error)

+ func (mj *DrainConfig) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *DrainConfig) Equal(that interface{}) bool

+ func (this *DrainConfig) GoString() string

+ func (this *DrainConfig) String() string

+ func (this *DrainConfig) VerboseEqual(that interface{}) error

+ func (uj *DrainConfig) UnmarshalJSON(input []byte) error

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

+ type DrainInfo struct

+ Config DrainConfig

+ State DrainState

+ func NewPopulatedDrainInfo(r randyMesos, easy bool) *DrainInfo

+ func (*DrainInfo) Descriptor() ([]byte, []int)

+ func (*DrainInfo) ProtoMessage()

+ func (m *DrainInfo) GetConfig() DrainConfig

+ func (m *DrainInfo) GetState() DrainState

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

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

+ func (m *DrainInfo) Reset()

+ func (m *DrainInfo) Size() (n int)

+ func (m *DrainInfo) Unmarshal(dAtA []byte) error

+ func (mj *DrainInfo) MarshalJSON() ([]byte, error)

+ func (mj *DrainInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *DrainInfo) Equal(that interface{}) bool

+ func (this *DrainInfo) GoString() string

+ func (this *DrainInfo) String() string

+ func (this *DrainInfo) VerboseEqual(that interface{}) error

+ func (uj *DrainInfo) UnmarshalJSON(input []byte) error

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

+ type DrainState int32

+ const DrainState_DRAINED

+ const DrainState_DRAINING

+ const DrainState_UNKNOWN

+ func (DrainState) EnumDescriptor() ([]byte, []int)

+ func (x *DrainState) UnmarshalJSON(data []byte) error

+ func (x DrainState) Enum() *DrainState

+ func (x DrainState) MarshalJSON() ([]byte, error)

+ func (x DrainState) String() string

type LinuxInfo

+ IPCMode *LinuxInfo_IpcMode

+ SHMSize *uint32

+ ShareCgroups *bool

+ func (m *LinuxInfo) GetIPCMode() LinuxInfo_IpcMode

+ func (m *LinuxInfo) GetSHMSize() uint32

+ func (m *LinuxInfo) GetShareCgroups() bool

+ type LinuxInfo_IpcMode int32

+ const LinuxInfo_PRIVATE

+ const LinuxInfo_SHARE_PARENT

+ const LinuxInfo_UNKNOWN

+ func (LinuxInfo_IpcMode) EnumDescriptor() ([]byte, []int)

+ func (x *LinuxInfo_IpcMode) UnmarshalJSON(data []byte) error

+ func (x LinuxInfo_IpcMode) Enum() *LinuxInfo_IpcMode

+ func (x LinuxInfo_IpcMode) MarshalJSON() ([]byte, error)

+ func (x LinuxInfo_IpcMode) String() string

type MasterInfo_Capability

+ func (m *MasterInfo_Capability) Size() (n int)

type MasterInfo_Capability_Type

+ const MasterInfo_Capability_AGENT_DRAINING

type MountPropagation

+ func (m *MountPropagation) Size() (n int)

type OfferFilters

+ func (m *OfferFilters) Size() (n int)

type OfferFilters_MinAllocatableResources

+ func (m *OfferFilters_MinAllocatableResources) Size() (n int)

type OfferFilters_ResourceQuantities

+ func (m *OfferFilters_ResourceQuantities) Size() (n int)

type Offer_Operation_CreateDisk

+ func (m *Offer_Operation_CreateDisk) Size() (n int)

type Offer_Operation_DestroyDisk

+ func (m *Offer_Operation_DestroyDisk) Size() (n int)

type Offer_Operation_GrowVolume

+ func (m *Offer_Operation_GrowVolume) Size() (n int)

type Offer_Operation_Reserve

+ Source []Resource

+ func (m *Offer_Operation_Reserve) GetSource() []Resource

type Offer_Operation_ShrinkVolume

+ func (m *Offer_Operation_ShrinkVolume) Size() (n int)

type Operation

+ func (m *Operation) Size() (n int)

type OperationID

+ func (m *OperationID) Size() (n int)

type OperationStatus

+ func (m *OperationStatus) Size() (n int)

type RLimitInfo

+ func (m *RLimitInfo) Size() (n int)

type RLimitInfo_RLimit

+ func (m *RLimitInfo_RLimit) Size() (n int)

type ResourceProviderID

+ func (m *ResourceProviderID) Size() (n int)

type ResourceProviderInfo

+ func (m *ResourceProviderInfo) Size() (n int)

type ResourceProviderInfo_Storage

+ ReconciliationIntervalSeconds *float64

+ func (m *ResourceProviderInfo_Storage) GetReconciliationIntervalSeconds() float64

+ func (m *ResourceProviderInfo_Storage) Size() (n int)

type ResourceStatistics

+ CPUsSoftLimit *float64

+ func (m *ResourceStatistics) GetCPUsSoftLimit() float64

type Resource_AllocationInfo

+ func (m *Resource_AllocationInfo) Size() (n int)

type SeccompInfo

+ func (m *SeccompInfo) Size() (n int)

type Secret

+ func (m *Secret) Size() (n int)

type Secret_Reference

+ func (m *Secret_Reference) Size() (n int)

type Secret_Value

+ func (m *Secret_Value) Size() (n int)

type TTYInfo

+ func (m *TTYInfo) Size() (n int)

type TTYInfo_WindowSize

+ func (m *TTYInfo_WindowSize) Size() (n int)

type Task

+ KillPolicy *KillPolicy

+ func (m *Task) GetKillPolicy() *KillPolicy

type TaskInfo

+ Limits map[string]Value_Scalar

+ func (m *TaskInfo) GetLimits() map[string]Value_Scalar

type TaskResourceLimitation

+ func (m *TaskResourceLimitation) Size() (n int)

type TaskStatus_Reason

+ const REASON_AGENT_DRAINING

type UUID

+ func (m *UUID) Size() (n int)

type Volume_Source_HostPath

+ func (m *Volume_Source_HostPath) Size() (n int)

v0.0.10

Jul 3, 2019

Changes in this version

type AgentInfo_Capability_Type

+ const AgentInfo_Capability_AGENT_OPERATION_FEEDBACK

type FrameworkInfo

+ OfferFilters map[string]OfferFilters

+ func (m *FrameworkInfo) GetOfferFilters() map[string]OfferFilters

type LinuxInfo

+ Seccomp *SeccompInfo

+ func (m *LinuxInfo) GetSeccomp() *SeccompInfo

+ type OfferFilters struct

+ MinAllocatableResources *OfferFilters_MinAllocatableResources

+ func NewPopulatedOfferFilters(r randyMesos, easy bool) *OfferFilters

+ func (*OfferFilters) Descriptor() ([]byte, []int)

+ func (*OfferFilters) ProtoMessage()

+ func (m *OfferFilters) GetMinAllocatableResources() *OfferFilters_MinAllocatableResources

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

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

+ func (m *OfferFilters) ProtoSize() (n int)

+ func (m *OfferFilters) Reset()

+ func (m *OfferFilters) Unmarshal(dAtA []byte) error

+ func (mj *OfferFilters) MarshalJSON() ([]byte, error)

+ func (mj *OfferFilters) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *OfferFilters) Equal(that interface{}) bool

+ func (this *OfferFilters) GoString() string

+ func (this *OfferFilters) String() string

+ func (this *OfferFilters) VerboseEqual(that interface{}) error

+ func (uj *OfferFilters) UnmarshalJSON(input []byte) error

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

+ type OfferFilters_MinAllocatableResources struct

+ Quantities []OfferFilters_ResourceQuantities

+ func NewPopulatedOfferFilters_MinAllocatableResources(r randyMesos, easy bool) *OfferFilters_MinAllocatableResources

+ func (*OfferFilters_MinAllocatableResources) Descriptor() ([]byte, []int)

+ func (*OfferFilters_MinAllocatableResources) ProtoMessage()

+ func (m *OfferFilters_MinAllocatableResources) GetQuantities() []OfferFilters_ResourceQuantities

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

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

+ func (m *OfferFilters_MinAllocatableResources) ProtoSize() (n int)

+ func (m *OfferFilters_MinAllocatableResources) Reset()

+ func (m *OfferFilters_MinAllocatableResources) Unmarshal(dAtA []byte) error

+ func (mj *OfferFilters_MinAllocatableResources) MarshalJSON() ([]byte, error)

+ func (mj *OfferFilters_MinAllocatableResources) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *OfferFilters_MinAllocatableResources) Equal(that interface{}) bool

+ func (this *OfferFilters_MinAllocatableResources) GoString() string

+ func (this *OfferFilters_MinAllocatableResources) String() string

+ func (this *OfferFilters_MinAllocatableResources) VerboseEqual(that interface{}) error

+ func (uj *OfferFilters_MinAllocatableResources) UnmarshalJSON(input []byte) error

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

+ type OfferFilters_ResourceQuantities struct

+ Quantities map[string]Value_Scalar

+ func NewPopulatedOfferFilters_ResourceQuantities(r randyMesos, easy bool) *OfferFilters_ResourceQuantities

+ func (*OfferFilters_ResourceQuantities) Descriptor() ([]byte, []int)

+ func (*OfferFilters_ResourceQuantities) ProtoMessage()

+ func (m *OfferFilters_ResourceQuantities) GetQuantities() map[string]Value_Scalar

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

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

+ func (m *OfferFilters_ResourceQuantities) ProtoSize() (n int)

+ func (m *OfferFilters_ResourceQuantities) Reset()

+ func (m *OfferFilters_ResourceQuantities) Unmarshal(dAtA []byte) error

+ func (mj *OfferFilters_ResourceQuantities) MarshalJSON() ([]byte, error)

+ func (mj *OfferFilters_ResourceQuantities) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *OfferFilters_ResourceQuantities) Equal(that interface{}) bool

+ func (this *OfferFilters_ResourceQuantities) GoString() string

+ func (this *OfferFilters_ResourceQuantities) String() string

+ func (this *OfferFilters_ResourceQuantities) VerboseEqual(that interface{}) error

+ func (uj *OfferFilters_ResourceQuantities) UnmarshalJSON(input []byte) error

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

+ type SeccompInfo struct

+ ProfileName *string

+ Unconfined *bool

+ func NewPopulatedSeccompInfo(r randyMesos, easy bool) *SeccompInfo

+ func (*SeccompInfo) Descriptor() ([]byte, []int)

+ func (*SeccompInfo) ProtoMessage()

+ func (m *SeccompInfo) GetProfileName() string

+ func (m *SeccompInfo) GetUnconfined() bool

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

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

+ func (m *SeccompInfo) ProtoSize() (n int)

+ func (m *SeccompInfo) Reset()

+ func (m *SeccompInfo) Unmarshal(dAtA []byte) error

+ func (mj *SeccompInfo) MarshalJSON() ([]byte, error)

+ func (mj *SeccompInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *SeccompInfo) Equal(that interface{}) bool

+ func (this *SeccompInfo) GoString() string

+ func (this *SeccompInfo) String() string

+ func (this *SeccompInfo) VerboseEqual(that interface{}) error

+ func (uj *SeccompInfo) UnmarshalJSON(input []byte) error

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

type Task

+ HealthCheck *HealthCheck

+ func (m *Task) GetHealthCheck() *HealthCheck

v0.0.9

Mar 15, 2019

Changes in this version

+ var CapabilityReservationRefinement string = ""

+ func IsCapabilityReservationRefinementEnabled() bool

type CgroupInfo_Blkio_Operation

+ const CgroupInfo_Blkio_DISCARD

type Offer_Operation

+ CreateDisk *Offer_Operation_CreateDisk

+ DestroyDisk *Offer_Operation_DestroyDisk

+ func (m *Offer_Operation) GetCreateDisk() *Offer_Operation_CreateDisk

+ func (m *Offer_Operation) GetDestroyDisk() *Offer_Operation_DestroyDisk

+ type Offer_Operation_CreateDisk struct

+ Source Resource

+ TargetProfile *string

+ TargetType Resource_DiskInfo_Source_Type

+ func NewPopulatedOffer_Operation_CreateDisk(r randyMesos, easy bool) *Offer_Operation_CreateDisk

+ func (*Offer_Operation_CreateDisk) Descriptor() ([]byte, []int)

+ func (*Offer_Operation_CreateDisk) ProtoMessage()

+ func (m *Offer_Operation_CreateDisk) GetSource() Resource

+ func (m *Offer_Operation_CreateDisk) GetTargetProfile() string

+ func (m *Offer_Operation_CreateDisk) GetTargetType() Resource_DiskInfo_Source_Type

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

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

+ func (m *Offer_Operation_CreateDisk) ProtoSize() (n int)

+ func (m *Offer_Operation_CreateDisk) Reset()

+ func (m *Offer_Operation_CreateDisk) Unmarshal(dAtA []byte) error

+ func (mj *Offer_Operation_CreateDisk) MarshalJSON() ([]byte, error)

+ func (mj *Offer_Operation_CreateDisk) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Offer_Operation_CreateDisk) Equal(that interface{}) bool

+ func (this *Offer_Operation_CreateDisk) GoString() string

+ func (this *Offer_Operation_CreateDisk) String() string

+ func (this *Offer_Operation_CreateDisk) VerboseEqual(that interface{}) error

+ func (uj *Offer_Operation_CreateDisk) UnmarshalJSON(input []byte) error

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

+ type Offer_Operation_DestroyDisk struct

+ Source Resource

+ func NewPopulatedOffer_Operation_DestroyDisk(r randyMesos, easy bool) *Offer_Operation_DestroyDisk

+ func (*Offer_Operation_DestroyDisk) Descriptor() ([]byte, []int)

+ func (*Offer_Operation_DestroyDisk) ProtoMessage()

+ func (m *Offer_Operation_DestroyDisk) GetSource() Resource

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

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

+ func (m *Offer_Operation_DestroyDisk) ProtoSize() (n int)

+ func (m *Offer_Operation_DestroyDisk) Reset()

+ func (m *Offer_Operation_DestroyDisk) Unmarshal(dAtA []byte) error

+ func (mj *Offer_Operation_DestroyDisk) MarshalJSON() ([]byte, error)

+ func (mj *Offer_Operation_DestroyDisk) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Offer_Operation_DestroyDisk) Equal(that interface{}) bool

+ func (this *Offer_Operation_DestroyDisk) GoString() string

+ func (this *Offer_Operation_DestroyDisk) String() string

+ func (this *Offer_Operation_DestroyDisk) VerboseEqual(that interface{}) error

+ func (uj *Offer_Operation_DestroyDisk) UnmarshalJSON(input []byte) error

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

type Offer_Operation_Type

+ const Offer_Operation_CREATE_DISK

+ const Offer_Operation_DESTROY_DISK

type OperationStatus

+ AgentID *AgentID

+ ResourceProviderID *ResourceProviderID

+ func (m *OperationStatus) GetAgentID() *AgentID

+ func (m *OperationStatus) GetResourceProviderID() *ResourceProviderID

type Resource_DiskInfo_Source

+ Vendor *string

+ func (m *Resource_DiskInfo_Source) GetVendor() string

v0.0.8

Jul 26, 2018

Changes in this version

type AgentInfo_Capability_Type

+ const AgentInfo_Capability_RESIZE_VOLUME

type Offer_Operation

+ GrowVolume *Offer_Operation_GrowVolume

+ ShrinkVolume *Offer_Operation_ShrinkVolume

+ func (m *Offer_Operation) GetGrowVolume() *Offer_Operation_GrowVolume

+ func (m *Offer_Operation) GetShrinkVolume() *Offer_Operation_ShrinkVolume

+ type Offer_Operation_GrowVolume struct

+ Addition Resource

+ Volume Resource

+ func NewPopulatedOffer_Operation_GrowVolume(r randyMesos, easy bool) *Offer_Operation_GrowVolume

+ func (*Offer_Operation_GrowVolume) Descriptor() ([]byte, []int)

+ func (*Offer_Operation_GrowVolume) ProtoMessage()

+ func (m *Offer_Operation_GrowVolume) GetAddition() Resource

+ func (m *Offer_Operation_GrowVolume) GetVolume() Resource

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

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

+ func (m *Offer_Operation_GrowVolume) ProtoSize() (n int)

+ func (m *Offer_Operation_GrowVolume) Reset()

+ func (m *Offer_Operation_GrowVolume) Unmarshal(dAtA []byte) error

+ func (mj *Offer_Operation_GrowVolume) MarshalJSON() ([]byte, error)

+ func (mj *Offer_Operation_GrowVolume) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Offer_Operation_GrowVolume) Equal(that interface{}) bool

+ func (this *Offer_Operation_GrowVolume) GoString() string

+ func (this *Offer_Operation_GrowVolume) String() string

+ func (this *Offer_Operation_GrowVolume) VerboseEqual(that interface{}) error

+ func (uj *Offer_Operation_GrowVolume) UnmarshalJSON(input []byte) error

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

+ type Offer_Operation_ShrinkVolume struct

+ Subtract Value_Scalar

+ Volume Resource

+ func NewPopulatedOffer_Operation_ShrinkVolume(r randyMesos, easy bool) *Offer_Operation_ShrinkVolume

+ func (*Offer_Operation_ShrinkVolume) Descriptor() ([]byte, []int)

+ func (*Offer_Operation_ShrinkVolume) ProtoMessage()

+ func (m *Offer_Operation_ShrinkVolume) GetSubtract() Value_Scalar

+ func (m *Offer_Operation_ShrinkVolume) GetVolume() Resource

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

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

+ func (m *Offer_Operation_ShrinkVolume) ProtoSize() (n int)

+ func (m *Offer_Operation_ShrinkVolume) Reset()

+ func (m *Offer_Operation_ShrinkVolume) Unmarshal(dAtA []byte) error

+ func (mj *Offer_Operation_ShrinkVolume) MarshalJSON() ([]byte, error)

+ func (mj *Offer_Operation_ShrinkVolume) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Offer_Operation_ShrinkVolume) Equal(that interface{}) bool

+ func (this *Offer_Operation_ShrinkVolume) GoString() string

+ func (this *Offer_Operation_ShrinkVolume) String() string

+ func (this *Offer_Operation_ShrinkVolume) VerboseEqual(that interface{}) error

+ func (uj *Offer_Operation_ShrinkVolume) UnmarshalJSON(input []byte) error

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

type Offer_Operation_Type

+ const Offer_Operation_GROW_VOLUME

+ const Offer_Operation_SHRINK_VOLUME

type OperationState

+ const OPERATION_GONE_BY_OPERATOR

+ const OPERATION_RECOVERING

+ const OPERATION_UNKNOWN

+ const OPERATION_UNREACHABLE

type TaskInfo

+ MaxCompletionTime *DurationInfo

+ func (m *TaskInfo) GetMaxCompletionTime() *DurationInfo

type TaskStatus_Reason

+ const REASON_MAX_COMPLETION_TIME_REACHED

v0.0.7

Jul 24, 2018

Changes in this version

+ const DefaultRole

+ var CSIPluginContainerInfo_Service_name = map[int32]string

+ var CSIPluginContainerInfo_Service_value = map[string]int32

+ var MasterInfo_Capability_Type_name = map[int32]string

+ var MasterInfo_Capability_Type_value = map[string]int32

+ var MountPropagation_Mode_name = map[int32]string

+ var MountPropagation_Mode_value = map[string]int32

+ var OperationState_name = map[int32]string

+ var OperationState_value = map[string]int32

type AgentInfo_Capability_Type

+ const AgentInfo_Capability_RESOURCE_PROVIDER

+ type CSIPluginContainerInfo struct

+ Command *CommandInfo

+ Container *ContainerInfo

+ Resources []Resource

+ Services []CSIPluginContainerInfo_Service

+ func NewPopulatedCSIPluginContainerInfo(r randyMesos, easy bool) *CSIPluginContainerInfo

+ func (*CSIPluginContainerInfo) Descriptor() ([]byte, []int)

+ func (*CSIPluginContainerInfo) ProtoMessage()

+ func (m *CSIPluginContainerInfo) GetCommand() *CommandInfo

+ func (m *CSIPluginContainerInfo) GetContainer() *ContainerInfo

+ func (m *CSIPluginContainerInfo) GetResources() []Resource

+ func (m *CSIPluginContainerInfo) GetServices() []CSIPluginContainerInfo_Service

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

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

+ func (m *CSIPluginContainerInfo) ProtoSize() (n int)

+ func (m *CSIPluginContainerInfo) Reset()

+ func (m *CSIPluginContainerInfo) Unmarshal(dAtA []byte) error

+ func (mj *CSIPluginContainerInfo) MarshalJSON() ([]byte, error)

+ func (mj *CSIPluginContainerInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *CSIPluginContainerInfo) Equal(that interface{}) bool

+ func (this *CSIPluginContainerInfo) GoString() string

+ func (this *CSIPluginContainerInfo) String() string

+ func (this *CSIPluginContainerInfo) VerboseEqual(that interface{}) error

+ func (uj *CSIPluginContainerInfo) UnmarshalJSON(input []byte) error

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

+ type CSIPluginContainerInfo_Service int32

+ const CSIPluginContainerInfo_CONTROLLER_SERVICE

+ const CSIPluginContainerInfo_NODE_SERVICE

+ const CSIPluginContainerInfo_UNKNOWN

+ func (CSIPluginContainerInfo_Service) EnumDescriptor() ([]byte, []int)

+ func (x *CSIPluginContainerInfo_Service) UnmarshalJSON(data []byte) error

+ func (x CSIPluginContainerInfo_Service) Enum() *CSIPluginContainerInfo_Service

+ func (x CSIPluginContainerInfo_Service) MarshalJSON() ([]byte, error)

+ func (x CSIPluginContainerInfo_Service) String() string

+ type CSIPluginInfo struct

+ Containers []CSIPluginContainerInfo

+ Name string

+ Type string

+ func NewPopulatedCSIPluginInfo(r randyMesos, easy bool) *CSIPluginInfo

+ func (*CSIPluginInfo) Descriptor() ([]byte, []int)

+ func (*CSIPluginInfo) ProtoMessage()

+ func (m *CSIPluginInfo) GetContainers() []CSIPluginContainerInfo

+ func (m *CSIPluginInfo) GetName() string

+ func (m *CSIPluginInfo) GetType() string

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

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

+ func (m *CSIPluginInfo) ProtoSize() (n int)

+ func (m *CSIPluginInfo) Reset()

+ func (m *CSIPluginInfo) Unmarshal(dAtA []byte) error

+ func (mj *CSIPluginInfo) MarshalJSON() ([]byte, error)

+ func (mj *CSIPluginInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *CSIPluginInfo) Equal(that interface{}) bool

+ func (this *CSIPluginInfo) GoString() string

+ func (this *CSIPluginInfo) String() string

+ func (this *CSIPluginInfo) VerboseEqual(that interface{}) error

+ func (uj *CSIPluginInfo) UnmarshalJSON(input []byte) error

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

type HealthCheck_HTTPCheckInfo

+ Protocol *NetworkInfo_Protocol

+ func (m *HealthCheck_HTTPCheckInfo) GetProtocol() NetworkInfo_Protocol

type HealthCheck_TCPCheckInfo

+ Protocol *NetworkInfo_Protocol

+ func (m *HealthCheck_TCPCheckInfo) GetProtocol() NetworkInfo_Protocol

type Label

+ func (left Label) Equivalent(right Label) bool

type Labels

+ func (left *Labels) Equivalent(right *Labels) bool

+ func (left *Labels) Format() string

type MasterInfo

+ Capabilities []MasterInfo_Capability

+ func (m *MasterInfo) GetCapabilities() []MasterInfo_Capability

+ type MasterInfo_Capability struct

+ Type MasterInfo_Capability_Type

+ func NewPopulatedMasterInfo_Capability(r randyMesos, easy bool) *MasterInfo_Capability

+ func (*MasterInfo_Capability) Descriptor() ([]byte, []int)

+ func (*MasterInfo_Capability) ProtoMessage()

+ func (m *MasterInfo_Capability) GetType() MasterInfo_Capability_Type

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

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

+ func (m *MasterInfo_Capability) ProtoSize() (n int)

+ func (m *MasterInfo_Capability) Reset()

+ func (m *MasterInfo_Capability) Unmarshal(dAtA []byte) error

+ func (mj *MasterInfo_Capability) MarshalJSON() ([]byte, error)

+ func (mj *MasterInfo_Capability) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *MasterInfo_Capability) Equal(that interface{}) bool

+ func (this *MasterInfo_Capability) GoString() string

+ func (this *MasterInfo_Capability) String() string

+ func (this *MasterInfo_Capability) VerboseEqual(that interface{}) error

+ func (uj *MasterInfo_Capability) UnmarshalJSON(input []byte) error

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

+ type MasterInfo_Capability_Type int32

+ const MasterInfo_Capability_AGENT_UPDATE

+ const MasterInfo_Capability_UNKNOWN

+ func (MasterInfo_Capability_Type) EnumDescriptor() ([]byte, []int)

+ func (x *MasterInfo_Capability_Type) UnmarshalJSON(data []byte) error

+ func (x MasterInfo_Capability_Type) Enum() *MasterInfo_Capability_Type

+ func (x MasterInfo_Capability_Type) MarshalJSON() ([]byte, error)

+ func (x MasterInfo_Capability_Type) String() string

+ type MountPropagation struct

+ Mode *MountPropagation_Mode

+ func NewPopulatedMountPropagation(r randyMesos, easy bool) *MountPropagation

+ func (*MountPropagation) Descriptor() ([]byte, []int)

+ func (*MountPropagation) ProtoMessage()

+ func (m *MountPropagation) GetMode() MountPropagation_Mode

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

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

+ func (m *MountPropagation) ProtoSize() (n int)

+ func (m *MountPropagation) Reset()

+ func (m *MountPropagation) Unmarshal(dAtA []byte) error

+ func (mj *MountPropagation) MarshalJSON() ([]byte, error)

+ func (mj *MountPropagation) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *MountPropagation) Equal(that interface{}) bool

+ func (this *MountPropagation) GoString() string

+ func (this *MountPropagation) String() string

+ func (this *MountPropagation) VerboseEqual(that interface{}) error

+ func (uj *MountPropagation) UnmarshalJSON(input []byte) error

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

+ type MountPropagation_Mode int32

+ const MountPropagation_BIDIRECTIONAL

+ const MountPropagation_HOST_TO_CONTAINER

+ const MountPropagation_UNKNOWN

+ func (MountPropagation_Mode) EnumDescriptor() ([]byte, []int)

+ func (x *MountPropagation_Mode) UnmarshalJSON(data []byte) error

+ func (x MountPropagation_Mode) Enum() *MountPropagation_Mode

+ func (x MountPropagation_Mode) MarshalJSON() ([]byte, error)

+ func (x MountPropagation_Mode) String() string

type NetworkInfo_Protocol

+ const Default_HealthCheck_HTTPCheckInfo_Protocol

+ const Default_HealthCheck_TCPCheckInfo_Protocol

type Offer_Operation

+ CreateBlock *Offer_Operation_CreateBlock

+ CreateVolume *Offer_Operation_CreateVolume

+ DestroyBlock *Offer_Operation_DestroyBlock

+ DestroyVolume *Offer_Operation_DestroyVolume

+ ID *OperationID

+ func (m *Offer_Operation) GetCreateBlock() *Offer_Operation_CreateBlock

+ func (m *Offer_Operation) GetCreateVolume() *Offer_Operation_CreateVolume

+ func (m *Offer_Operation) GetDestroyBlock() *Offer_Operation_DestroyBlock

+ func (m *Offer_Operation) GetDestroyVolume() *Offer_Operation_DestroyVolume

+ func (m *Offer_Operation) GetID() *OperationID

+ type Offer_Operation_CreateBlock struct

+ Source Resource

+ func NewPopulatedOffer_Operation_CreateBlock(r randyMesos, easy bool) *Offer_Operation_CreateBlock

+ func (*Offer_Operation_CreateBlock) Descriptor() ([]byte, []int)

+ func (*Offer_Operation_CreateBlock) ProtoMessage()

+ func (m *Offer_Operation_CreateBlock) GetSource() Resource

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

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

+ func (m *Offer_Operation_CreateBlock) ProtoSize() (n int)

+ func (m *Offer_Operation_CreateBlock) Reset()

+ func (m *Offer_Operation_CreateBlock) Unmarshal(dAtA []byte) error

+ func (mj *Offer_Operation_CreateBlock) MarshalJSON() ([]byte, error)

+ func (mj *Offer_Operation_CreateBlock) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Offer_Operation_CreateBlock) Equal(that interface{}) bool

+ func (this *Offer_Operation_CreateBlock) GoString() string

+ func (this *Offer_Operation_CreateBlock) String() string

+ func (this *Offer_Operation_CreateBlock) VerboseEqual(that interface{}) error

+ func (uj *Offer_Operation_CreateBlock) UnmarshalJSON(input []byte) error

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

+ type Offer_Operation_CreateVolume struct

+ Source Resource

+ TargetType Resource_DiskInfo_Source_Type

+ func NewPopulatedOffer_Operation_CreateVolume(r randyMesos, easy bool) *Offer_Operation_CreateVolume

+ func (*Offer_Operation_CreateVolume) Descriptor() ([]byte, []int)

+ func (*Offer_Operation_CreateVolume) ProtoMessage()

+ func (m *Offer_Operation_CreateVolume) GetSource() Resource

+ func (m *Offer_Operation_CreateVolume) GetTargetType() Resource_DiskInfo_Source_Type

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

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

+ func (m *Offer_Operation_CreateVolume) ProtoSize() (n int)

+ func (m *Offer_Operation_CreateVolume) Reset()

+ func (m *Offer_Operation_CreateVolume) Unmarshal(dAtA []byte) error

+ func (mj *Offer_Operation_CreateVolume) MarshalJSON() ([]byte, error)

+ func (mj *Offer_Operation_CreateVolume) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Offer_Operation_CreateVolume) Equal(that interface{}) bool

+ func (this *Offer_Operation_CreateVolume) GoString() string

+ func (this *Offer_Operation_CreateVolume) String() string

+ func (this *Offer_Operation_CreateVolume) VerboseEqual(that interface{}) error

+ func (uj *Offer_Operation_CreateVolume) UnmarshalJSON(input []byte) error

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

+ type Offer_Operation_DestroyBlock struct

+ Block Resource

+ func NewPopulatedOffer_Operation_DestroyBlock(r randyMesos, easy bool) *Offer_Operation_DestroyBlock

+ func (*Offer_Operation_DestroyBlock) Descriptor() ([]byte, []int)

+ func (*Offer_Operation_DestroyBlock) ProtoMessage()

+ func (m *Offer_Operation_DestroyBlock) GetBlock() Resource

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

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

+ func (m *Offer_Operation_DestroyBlock) ProtoSize() (n int)

+ func (m *Offer_Operation_DestroyBlock) Reset()

+ func (m *Offer_Operation_DestroyBlock) Unmarshal(dAtA []byte) error

+ func (mj *Offer_Operation_DestroyBlock) MarshalJSON() ([]byte, error)

+ func (mj *Offer_Operation_DestroyBlock) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Offer_Operation_DestroyBlock) Equal(that interface{}) bool

+ func (this *Offer_Operation_DestroyBlock) GoString() string

+ func (this *Offer_Operation_DestroyBlock) String() string

+ func (this *Offer_Operation_DestroyBlock) VerboseEqual(that interface{}) error

+ func (uj *Offer_Operation_DestroyBlock) UnmarshalJSON(input []byte) error

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

+ type Offer_Operation_DestroyVolume struct

+ Volume Resource

+ func NewPopulatedOffer_Operation_DestroyVolume(r randyMesos, easy bool) *Offer_Operation_DestroyVolume

+ func (*Offer_Operation_DestroyVolume) Descriptor() ([]byte, []int)

+ func (*Offer_Operation_DestroyVolume) ProtoMessage()

+ func (m *Offer_Operation_DestroyVolume) GetVolume() Resource

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

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

+ func (m *Offer_Operation_DestroyVolume) ProtoSize() (n int)

+ func (m *Offer_Operation_DestroyVolume) Reset()

+ func (m *Offer_Operation_DestroyVolume) Unmarshal(dAtA []byte) error

+ func (mj *Offer_Operation_DestroyVolume) MarshalJSON() ([]byte, error)

+ func (mj *Offer_Operation_DestroyVolume) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Offer_Operation_DestroyVolume) Equal(that interface{}) bool

+ func (this *Offer_Operation_DestroyVolume) GoString() string

+ func (this *Offer_Operation_DestroyVolume) String() string

+ func (this *Offer_Operation_DestroyVolume) VerboseEqual(that interface{}) error

+ func (uj *Offer_Operation_DestroyVolume) UnmarshalJSON(input []byte) error

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

type Offer_Operation_Type

+ const Offer_Operation_CREATE_BLOCK

+ const Offer_Operation_CREATE_VOLUME

+ const Offer_Operation_DESTROY_BLOCK

+ const Offer_Operation_DESTROY_VOLUME

+ type Operation struct

+ AgentID *AgentID

+ FrameworkID *FrameworkID

+ Info Offer_Operation

+ LatestStatus OperationStatus

+ Statuses []OperationStatus

+ UUID UUID

+ func NewPopulatedOperation(r randyMesos, easy bool) *Operation

+ func (*Operation) Descriptor() ([]byte, []int)

+ func (*Operation) ProtoMessage()

+ func (m *Operation) GetAgentID() *AgentID

+ func (m *Operation) GetFrameworkID() *FrameworkID

+ func (m *Operation) GetInfo() Offer_Operation

+ func (m *Operation) GetLatestStatus() OperationStatus

+ func (m *Operation) GetStatuses() []OperationStatus

+ func (m *Operation) GetUUID() UUID

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

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

+ func (m *Operation) ProtoSize() (n int)

+ func (m *Operation) Reset()

+ func (m *Operation) Unmarshal(dAtA []byte) error

+ func (mj *Operation) MarshalJSON() ([]byte, error)

+ func (mj *Operation) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Operation) Equal(that interface{}) bool

+ func (this *Operation) GoString() string

+ func (this *Operation) String() string

+ func (this *Operation) VerboseEqual(that interface{}) error

+ func (uj *Operation) UnmarshalJSON(input []byte) error

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

+ type OperationID struct

+ Value string

+ func NewPopulatedOperationID(r randyMesos, easy bool) *OperationID

+ func (*OperationID) Descriptor() ([]byte, []int)

+ func (*OperationID) ProtoMessage()

+ func (m *OperationID) GetValue() string

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

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

+ func (m *OperationID) ProtoSize() (n int)

+ func (m *OperationID) Reset()

+ func (m *OperationID) Unmarshal(dAtA []byte) error

+ func (mj *OperationID) MarshalJSON() ([]byte, error)

+ func (mj *OperationID) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *OperationID) Equal(that interface{}) bool

+ func (this *OperationID) GoString() string

+ func (this *OperationID) String() string

+ func (this *OperationID) VerboseEqual(that interface{}) error

+ func (uj *OperationID) UnmarshalJSON(input []byte) error

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

+ type OperationState int32

+ const OPERATION_DROPPED

+ const OPERATION_ERROR

+ const OPERATION_FAILED

+ const OPERATION_FINISHED

+ const OPERATION_PENDING

+ const OPERATION_UNSUPPORTED

+ func (OperationState) EnumDescriptor() ([]byte, []int)

+ func (x *OperationState) UnmarshalJSON(data []byte) error

+ func (x OperationState) Enum() *OperationState

+ func (x OperationState) MarshalJSON() ([]byte, error)

+ func (x OperationState) String() string

+ type OperationStatus struct

+ ConvertedResources []Resource

+ Message *string

+ OperationID *OperationID

+ State OperationState

+ UUID *UUID

+ func NewPopulatedOperationStatus(r randyMesos, easy bool) *OperationStatus

+ func (*OperationStatus) Descriptor() ([]byte, []int)

+ func (*OperationStatus) ProtoMessage()

+ func (m *OperationStatus) GetConvertedResources() []Resource

+ func (m *OperationStatus) GetMessage() string

+ func (m *OperationStatus) GetOperationID() *OperationID

+ func (m *OperationStatus) GetState() OperationState

+ func (m *OperationStatus) GetUUID() *UUID

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

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

+ func (m *OperationStatus) ProtoSize() (n int)

+ func (m *OperationStatus) Reset()

+ func (m *OperationStatus) Unmarshal(dAtA []byte) error

+ func (mj *OperationStatus) MarshalJSON() ([]byte, error)

+ func (mj *OperationStatus) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *OperationStatus) Equal(that interface{}) bool

+ func (this *OperationStatus) GoString() string

+ func (this *OperationStatus) String() string

+ func (this *OperationStatus) VerboseEqual(that interface{}) error

+ func (uj *OperationStatus) UnmarshalJSON(input []byte) error

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

type Resource

+ func (left *Resource) HasResourceProvider() bool

+ func (left *Resource) IsAllocatableTo(role string) bool

+ func (left *Resource) IsDisk(t Resource_DiskInfo_Source_Type) bool

+ func (r *Resource) Allocate(role string)

+ func (r *Resource) ReservationRole() string

+ func (r *Resource) Unallocate()

type ResourceProviderInfo

+ DefaultReservations []Resource_ReservationInfo

+ Storage *ResourceProviderInfo_Storage

+ func (m *ResourceProviderInfo) GetDefaultReservations() []Resource_ReservationInfo

+ func (m *ResourceProviderInfo) GetStorage() *ResourceProviderInfo_Storage

+ type ResourceProviderInfo_Storage struct

+ Plugin CSIPluginInfo

+ func NewPopulatedResourceProviderInfo_Storage(r randyMesos, easy bool) *ResourceProviderInfo_Storage

+ func (*ResourceProviderInfo_Storage) Descriptor() ([]byte, []int)

+ func (*ResourceProviderInfo_Storage) ProtoMessage()

+ func (m *ResourceProviderInfo_Storage) GetPlugin() CSIPluginInfo

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

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

+ func (m *ResourceProviderInfo_Storage) ProtoSize() (n int)

+ func (m *ResourceProviderInfo_Storage) Reset()

+ func (m *ResourceProviderInfo_Storage) Unmarshal(dAtA []byte) error

+ func (mj *ResourceProviderInfo_Storage) MarshalJSON() ([]byte, error)

+ func (mj *ResourceProviderInfo_Storage) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *ResourceProviderInfo_Storage) Equal(that interface{}) bool

+ func (this *ResourceProviderInfo_Storage) GoString() string

+ func (this *ResourceProviderInfo_Storage) String() string

+ func (this *ResourceProviderInfo_Storage) VerboseEqual(that interface{}) error

+ func (uj *ResourceProviderInfo_Storage) UnmarshalJSON(input []byte) error

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

type Resource_AllocationInfo

+ func (left *Resource_AllocationInfo) Equivalent(right *Resource_AllocationInfo) bool

type Resource_DiskInfo_Source

+ ID *string

+ Metadata *Labels

+ Profile *string

+ func (m *Resource_DiskInfo_Source) GetID() string

+ func (m *Resource_DiskInfo_Source) GetMetadata() *Labels

+ func (m *Resource_DiskInfo_Source) GetProfile() string

type Resource_DiskInfo_Source_Type

+ const Resource_DiskInfo_Source_BLOCK

+ const Resource_DiskInfo_Source_MOUNT

+ const Resource_DiskInfo_Source_PATH

+ const Resource_DiskInfo_Source_RAW

+ const Resource_DiskInfo_Source_UNKNOWN

type Resources

+ func (resources Resources) Format(options ...func(*ResourcesFormatOptions)) string

+ func (rs Resources) Allocate(role string) Resources

+ func (rs Resources) PopReservation() (result Resources)

+ func (rs Resources) PushReservation(ri Resource_ReservationInfo) (result Resources)

+ func (rs Resources) ToUnreserved() (result Resources)

+ func (rs Resources) Unallocate() Resources

+ type ResourcesFormatOptions struct

+ ShowAllocated bool

+ type TaskResourceLimitation struct

+ Resources []Resource

+ func NewPopulatedTaskResourceLimitation(r randyMesos, easy bool) *TaskResourceLimitation

+ func (*TaskResourceLimitation) Descriptor() ([]byte, []int)

+ func (*TaskResourceLimitation) ProtoMessage()

+ func (m *TaskResourceLimitation) GetResources() []Resource

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

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

+ func (m *TaskResourceLimitation) ProtoSize() (n int)

+ func (m *TaskResourceLimitation) Reset()

+ func (m *TaskResourceLimitation) Unmarshal(dAtA []byte) error

+ func (mj *TaskResourceLimitation) MarshalJSON() ([]byte, error)

+ func (mj *TaskResourceLimitation) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *TaskResourceLimitation) Equal(that interface{}) bool

+ func (this *TaskResourceLimitation) GoString() string

+ func (this *TaskResourceLimitation) String() string

+ func (this *TaskResourceLimitation) VerboseEqual(that interface{}) error

+ func (uj *TaskResourceLimitation) UnmarshalJSON(input []byte) error

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

type TaskStatus

+ Limitation *TaskResourceLimitation

+ func (m *TaskStatus) GetLimitation() *TaskResourceLimitation

type TaskStatus_Reason

+ const REASON_AGENT_REMOVED_BY_OPERATOR

+ const REASON_AGENT_REREGISTERED

+ type UUID struct

+ Value []byte

+ func NewPopulatedUUID(r randyMesos, easy bool) *UUID

+ func (*UUID) Descriptor() ([]byte, []int)

+ func (*UUID) ProtoMessage()

+ func (m *UUID) GetValue() []byte

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

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

+ func (m *UUID) ProtoSize() (n int)

+ func (m *UUID) Reset()

+ func (m *UUID) Unmarshal(dAtA []byte) error

+ func (mj *UUID) MarshalJSON() ([]byte, error)

+ func (mj *UUID) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *UUID) Equal(that interface{}) bool

+ func (this *UUID) GoString() string

+ func (this *UUID) String() string

+ func (this *UUID) VerboseEqual(that interface{}) error

+ func (uj *UUID) UnmarshalJSON(input []byte) error

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

type Volume_Source

+ HostPath *Volume_Source_HostPath

+ func (m *Volume_Source) GetHostPath() *Volume_Source_HostPath

+ type Volume_Source_HostPath struct

+ MountPropagation *MountPropagation

+ Path string

+ func NewPopulatedVolume_Source_HostPath(r randyMesos, easy bool) *Volume_Source_HostPath

+ func (*Volume_Source_HostPath) Descriptor() ([]byte, []int)

+ func (*Volume_Source_HostPath) ProtoMessage()

+ func (m *Volume_Source_HostPath) GetMountPropagation() *MountPropagation

+ func (m *Volume_Source_HostPath) GetPath() string

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

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

+ func (m *Volume_Source_HostPath) ProtoSize() (n int)

+ func (m *Volume_Source_HostPath) Reset()

+ func (m *Volume_Source_HostPath) Unmarshal(dAtA []byte) error

+ func (mj *Volume_Source_HostPath) MarshalJSON() ([]byte, error)

+ func (mj *Volume_Source_HostPath) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Volume_Source_HostPath) Equal(that interface{}) bool

+ func (this *Volume_Source_HostPath) GoString() string

+ func (this *Volume_Source_HostPath) String() string

+ func (this *Volume_Source_HostPath) VerboseEqual(that interface{}) error

+ func (uj *Volume_Source_HostPath) UnmarshalJSON(input []byte) error

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

type Volume_Source_Type

+ const Volume_Source_HOST_PATH

v0.0.6

Mar 12, 2018

Changes in this version

+ var CgroupInfo_Blkio_Operation_name = map[int32]string

+ var CgroupInfo_Blkio_Operation_value = map[string]int32

+ var Resource_ReservationInfo_Type_name = map[int32]string

+ var Resource_ReservationInfo_Type_value = map[string]int32

type AgentInfo

+ Domain *DomainInfo

+ func (m *AgentInfo) GetDomain() *DomainInfo

type AgentInfo_Capability_Type

+ const AgentInfo_Capability_HIERARCHICAL_ROLE

+ const AgentInfo_Capability_RESERVATION_REFINEMENT

+ type CgroupInfo_Blkio struct

+ func NewPopulatedCgroupInfo_Blkio(r randyMesos, easy bool) *CgroupInfo_Blkio

+ func (*CgroupInfo_Blkio) Descriptor() ([]byte, []int)

+ func (*CgroupInfo_Blkio) ProtoMessage()

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

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

+ func (m *CgroupInfo_Blkio) ProtoSize() (n int)

+ func (m *CgroupInfo_Blkio) Reset()

+ func (m *CgroupInfo_Blkio) Unmarshal(dAtA []byte) error

+ func (mj *CgroupInfo_Blkio) MarshalJSON() ([]byte, error)

+ func (mj *CgroupInfo_Blkio) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *CgroupInfo_Blkio) Equal(that interface{}) bool

+ func (this *CgroupInfo_Blkio) GoString() string

+ func (this *CgroupInfo_Blkio) String() string

+ func (this *CgroupInfo_Blkio) VerboseEqual(that interface{}) error

+ func (uj *CgroupInfo_Blkio) UnmarshalJSON(input []byte) error

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

+ type CgroupInfo_Blkio_CFQ struct

+ func NewPopulatedCgroupInfo_Blkio_CFQ(r randyMesos, easy bool) *CgroupInfo_Blkio_CFQ

+ func (*CgroupInfo_Blkio_CFQ) Descriptor() ([]byte, []int)

+ func (*CgroupInfo_Blkio_CFQ) ProtoMessage()

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

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

+ func (m *CgroupInfo_Blkio_CFQ) ProtoSize() (n int)

+ func (m *CgroupInfo_Blkio_CFQ) Reset()

+ func (m *CgroupInfo_Blkio_CFQ) Unmarshal(dAtA []byte) error

+ func (mj *CgroupInfo_Blkio_CFQ) MarshalJSON() ([]byte, error)

+ func (mj *CgroupInfo_Blkio_CFQ) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *CgroupInfo_Blkio_CFQ) Equal(that interface{}) bool

+ func (this *CgroupInfo_Blkio_CFQ) GoString() string

+ func (this *CgroupInfo_Blkio_CFQ) String() string

+ func (this *CgroupInfo_Blkio_CFQ) VerboseEqual(that interface{}) error

+ func (uj *CgroupInfo_Blkio_CFQ) UnmarshalJSON(input []byte) error

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

+ type CgroupInfo_Blkio_CFQ_Statistics struct

+ Device *Device_Number

+ IOMerged []CgroupInfo_Blkio_Value

+ IOQueued []CgroupInfo_Blkio_Value

+ IOServiceBytes []CgroupInfo_Blkio_Value

+ IOServiceTime []CgroupInfo_Blkio_Value

+ IOServiced []CgroupInfo_Blkio_Value

+ IOWaitTime []CgroupInfo_Blkio_Value

+ Sectors *uint64

+ Time *uint64

+ func NewPopulatedCgroupInfo_Blkio_CFQ_Statistics(r randyMesos, easy bool) *CgroupInfo_Blkio_CFQ_Statistics

+ func (*CgroupInfo_Blkio_CFQ_Statistics) Descriptor() ([]byte, []int)

+ func (*CgroupInfo_Blkio_CFQ_Statistics) ProtoMessage()

+ func (m *CgroupInfo_Blkio_CFQ_Statistics) GetDevice() *Device_Number

+ func (m *CgroupInfo_Blkio_CFQ_Statistics) GetIOMerged() []CgroupInfo_Blkio_Value

+ func (m *CgroupInfo_Blkio_CFQ_Statistics) GetIOQueued() []CgroupInfo_Blkio_Value

+ func (m *CgroupInfo_Blkio_CFQ_Statistics) GetIOServiceBytes() []CgroupInfo_Blkio_Value

+ func (m *CgroupInfo_Blkio_CFQ_Statistics) GetIOServiceTime() []CgroupInfo_Blkio_Value

+ func (m *CgroupInfo_Blkio_CFQ_Statistics) GetIOServiced() []CgroupInfo_Blkio_Value

+ func (m *CgroupInfo_Blkio_CFQ_Statistics) GetIOWaitTime() []CgroupInfo_Blkio_Value

+ func (m *CgroupInfo_Blkio_CFQ_Statistics) GetSectors() uint64

+ func (m *CgroupInfo_Blkio_CFQ_Statistics) GetTime() uint64

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

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

+ func (m *CgroupInfo_Blkio_CFQ_Statistics) ProtoSize() (n int)

+ func (m *CgroupInfo_Blkio_CFQ_Statistics) Reset()

+ func (m *CgroupInfo_Blkio_CFQ_Statistics) Unmarshal(dAtA []byte) error

+ func (mj *CgroupInfo_Blkio_CFQ_Statistics) MarshalJSON() ([]byte, error)

+ func (mj *CgroupInfo_Blkio_CFQ_Statistics) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *CgroupInfo_Blkio_CFQ_Statistics) Equal(that interface{}) bool

+ func (this *CgroupInfo_Blkio_CFQ_Statistics) GoString() string

+ func (this *CgroupInfo_Blkio_CFQ_Statistics) String() string

+ func (this *CgroupInfo_Blkio_CFQ_Statistics) VerboseEqual(that interface{}) error

+ func (uj *CgroupInfo_Blkio_CFQ_Statistics) UnmarshalJSON(input []byte) error

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

+ type CgroupInfo_Blkio_Operation int32

+ const CgroupInfo_Blkio_ASYNC

+ const CgroupInfo_Blkio_READ

+ const CgroupInfo_Blkio_SYNC

+ const CgroupInfo_Blkio_TOTAL

+ const CgroupInfo_Blkio_UNKNOWN

+ const CgroupInfo_Blkio_WRITE

+ func (CgroupInfo_Blkio_Operation) EnumDescriptor() ([]byte, []int)

+ func (x *CgroupInfo_Blkio_Operation) UnmarshalJSON(data []byte) error

+ func (x CgroupInfo_Blkio_Operation) Enum() *CgroupInfo_Blkio_Operation

+ func (x CgroupInfo_Blkio_Operation) MarshalJSON() ([]byte, error)

+ func (x CgroupInfo_Blkio_Operation) String() string

+ type CgroupInfo_Blkio_Statistics struct

+ CFQ []CgroupInfo_Blkio_CFQ_Statistics

+ CFQRecursive []CgroupInfo_Blkio_CFQ_Statistics

+ Throttling []*CgroupInfo_Blkio_Throttling_Statistics

+ func NewPopulatedCgroupInfo_Blkio_Statistics(r randyMesos, easy bool) *CgroupInfo_Blkio_Statistics

+ func (*CgroupInfo_Blkio_Statistics) Descriptor() ([]byte, []int)

+ func (*CgroupInfo_Blkio_Statistics) ProtoMessage()

+ func (m *CgroupInfo_Blkio_Statistics) GetCFQ() []CgroupInfo_Blkio_CFQ_Statistics

+ func (m *CgroupInfo_Blkio_Statistics) GetCFQRecursive() []CgroupInfo_Blkio_CFQ_Statistics

+ func (m *CgroupInfo_Blkio_Statistics) GetThrottling() []*CgroupInfo_Blkio_Throttling_Statistics

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

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

+ func (m *CgroupInfo_Blkio_Statistics) ProtoSize() (n int)

+ func (m *CgroupInfo_Blkio_Statistics) Reset()

+ func (m *CgroupInfo_Blkio_Statistics) Unmarshal(dAtA []byte) error

+ func (mj *CgroupInfo_Blkio_Statistics) MarshalJSON() ([]byte, error)

+ func (mj *CgroupInfo_Blkio_Statistics) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *CgroupInfo_Blkio_Statistics) Equal(that interface{}) bool

+ func (this *CgroupInfo_Blkio_Statistics) GoString() string

+ func (this *CgroupInfo_Blkio_Statistics) String() string

+ func (this *CgroupInfo_Blkio_Statistics) VerboseEqual(that interface{}) error

+ func (uj *CgroupInfo_Blkio_Statistics) UnmarshalJSON(input []byte) error

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

+ type CgroupInfo_Blkio_Throttling struct

+ func NewPopulatedCgroupInfo_Blkio_Throttling(r randyMesos, easy bool) *CgroupInfo_Blkio_Throttling

+ func (*CgroupInfo_Blkio_Throttling) Descriptor() ([]byte, []int)

+ func (*CgroupInfo_Blkio_Throttling) ProtoMessage()

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

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

+ func (m *CgroupInfo_Blkio_Throttling) ProtoSize() (n int)

+ func (m *CgroupInfo_Blkio_Throttling) Reset()

+ func (m *CgroupInfo_Blkio_Throttling) Unmarshal(dAtA []byte) error

+ func (mj *CgroupInfo_Blkio_Throttling) MarshalJSON() ([]byte, error)

+ func (mj *CgroupInfo_Blkio_Throttling) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *CgroupInfo_Blkio_Throttling) Equal(that interface{}) bool

+ func (this *CgroupInfo_Blkio_Throttling) GoString() string

+ func (this *CgroupInfo_Blkio_Throttling) String() string

+ func (this *CgroupInfo_Blkio_Throttling) VerboseEqual(that interface{}) error

+ func (uj *CgroupInfo_Blkio_Throttling) UnmarshalJSON(input []byte) error

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

+ type CgroupInfo_Blkio_Throttling_Statistics struct

+ Device *Device_Number

+ IOServiceBytes []CgroupInfo_Blkio_Value

+ IOServiced []CgroupInfo_Blkio_Value

+ func NewPopulatedCgroupInfo_Blkio_Throttling_Statistics(r randyMesos, easy bool) *CgroupInfo_Blkio_Throttling_Statistics

+ func (*CgroupInfo_Blkio_Throttling_Statistics) Descriptor() ([]byte, []int)

+ func (*CgroupInfo_Blkio_Throttling_Statistics) ProtoMessage()

+ func (m *CgroupInfo_Blkio_Throttling_Statistics) GetDevice() *Device_Number

+ func (m *CgroupInfo_Blkio_Throttling_Statistics) GetIOServiceBytes() []CgroupInfo_Blkio_Value

+ func (m *CgroupInfo_Blkio_Throttling_Statistics) GetIOServiced() []CgroupInfo_Blkio_Value

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

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

+ func (m *CgroupInfo_Blkio_Throttling_Statistics) ProtoSize() (n int)

+ func (m *CgroupInfo_Blkio_Throttling_Statistics) Reset()

+ func (m *CgroupInfo_Blkio_Throttling_Statistics) Unmarshal(dAtA []byte) error

+ func (mj *CgroupInfo_Blkio_Throttling_Statistics) MarshalJSON() ([]byte, error)

+ func (mj *CgroupInfo_Blkio_Throttling_Statistics) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *CgroupInfo_Blkio_Throttling_Statistics) Equal(that interface{}) bool

+ func (this *CgroupInfo_Blkio_Throttling_Statistics) GoString() string

+ func (this *CgroupInfo_Blkio_Throttling_Statistics) String() string

+ func (this *CgroupInfo_Blkio_Throttling_Statistics) VerboseEqual(that interface{}) error

+ func (uj *CgroupInfo_Blkio_Throttling_Statistics) UnmarshalJSON(input []byte) error

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

+ type CgroupInfo_Blkio_Value struct

+ Op *CgroupInfo_Blkio_Operation

+ Value *uint64

+ func NewPopulatedCgroupInfo_Blkio_Value(r randyMesos, easy bool) *CgroupInfo_Blkio_Value

+ func (*CgroupInfo_Blkio_Value) Descriptor() ([]byte, []int)

+ func (*CgroupInfo_Blkio_Value) ProtoMessage()

+ func (m *CgroupInfo_Blkio_Value) GetOp() CgroupInfo_Blkio_Operation

+ func (m *CgroupInfo_Blkio_Value) GetValue() uint64

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

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

+ func (m *CgroupInfo_Blkio_Value) ProtoSize() (n int)

+ func (m *CgroupInfo_Blkio_Value) Reset()

+ func (m *CgroupInfo_Blkio_Value) Unmarshal(dAtA []byte) error

+ func (mj *CgroupInfo_Blkio_Value) MarshalJSON() ([]byte, error)

+ func (mj *CgroupInfo_Blkio_Value) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *CgroupInfo_Blkio_Value) Equal(that interface{}) bool

+ func (this *CgroupInfo_Blkio_Value) GoString() string

+ func (this *CgroupInfo_Blkio_Value) String() string

+ func (this *CgroupInfo_Blkio_Value) VerboseEqual(that interface{}) error

+ func (uj *CgroupInfo_Blkio_Value) UnmarshalJSON(input []byte) error

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

type Device

+ Number *Device_Number

+ func (m *Device) GetNumber() *Device_Number

+ type Device_Number struct

+ MajorNumber *uint64

+ MinorNumber *uint64

+ func NewPopulatedDevice_Number(r randyMesos, easy bool) *Device_Number

+ func (*Device_Number) Descriptor() ([]byte, []int)

+ func (*Device_Number) ProtoMessage()

+ func (m *Device_Number) GetMajorNumber() uint64

+ func (m *Device_Number) GetMinorNumber() uint64

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

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

+ func (m *Device_Number) ProtoSize() (n int)

+ func (m *Device_Number) Reset()

+ func (m *Device_Number) Unmarshal(dAtA []byte) error

+ func (mj *Device_Number) MarshalJSON() ([]byte, error)

+ func (mj *Device_Number) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Device_Number) Equal(that interface{}) bool

+ func (this *Device_Number) GoString() string

+ func (this *Device_Number) String() string

+ func (this *Device_Number) VerboseEqual(that interface{}) error

+ func (uj *Device_Number) UnmarshalJSON(input []byte) error

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

+ type DomainInfo struct

+ FaultDomain *DomainInfo_FaultDomain

+ func NewPopulatedDomainInfo(r randyMesos, easy bool) *DomainInfo

+ func (*DomainInfo) Descriptor() ([]byte, []int)

+ func (*DomainInfo) ProtoMessage()

+ func (m *DomainInfo) GetFaultDomain() *DomainInfo_FaultDomain

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

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

+ func (m *DomainInfo) ProtoSize() (n int)

+ func (m *DomainInfo) Reset()

+ func (m *DomainInfo) Unmarshal(dAtA []byte) error

+ func (mj *DomainInfo) MarshalJSON() ([]byte, error)

+ func (mj *DomainInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *DomainInfo) Equal(that interface{}) bool

+ func (this *DomainInfo) GoString() string

+ func (this *DomainInfo) String() string

+ func (this *DomainInfo) VerboseEqual(that interface{}) error

+ func (uj *DomainInfo) UnmarshalJSON(input []byte) error

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

+ type DomainInfo_FaultDomain struct

+ Region DomainInfo_FaultDomain_RegionInfo

+ Zone DomainInfo_FaultDomain_ZoneInfo

+ func NewPopulatedDomainInfo_FaultDomain(r randyMesos, easy bool) *DomainInfo_FaultDomain

+ func (*DomainInfo_FaultDomain) Descriptor() ([]byte, []int)

+ func (*DomainInfo_FaultDomain) ProtoMessage()

+ func (m *DomainInfo_FaultDomain) GetRegion() DomainInfo_FaultDomain_RegionInfo

+ func (m *DomainInfo_FaultDomain) GetZone() DomainInfo_FaultDomain_ZoneInfo

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

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

+ func (m *DomainInfo_FaultDomain) ProtoSize() (n int)

+ func (m *DomainInfo_FaultDomain) Reset()

+ func (m *DomainInfo_FaultDomain) Unmarshal(dAtA []byte) error

+ func (mj *DomainInfo_FaultDomain) MarshalJSON() ([]byte, error)

+ func (mj *DomainInfo_FaultDomain) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *DomainInfo_FaultDomain) Equal(that interface{}) bool

+ func (this *DomainInfo_FaultDomain) GoString() string

+ func (this *DomainInfo_FaultDomain) String() string

+ func (this *DomainInfo_FaultDomain) VerboseEqual(that interface{}) error

+ func (uj *DomainInfo_FaultDomain) UnmarshalJSON(input []byte) error

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

+ type DomainInfo_FaultDomain_RegionInfo struct

+ Name string

+ func NewPopulatedDomainInfo_FaultDomain_RegionInfo(r randyMesos, easy bool) *DomainInfo_FaultDomain_RegionInfo

+ func (*DomainInfo_FaultDomain_RegionInfo) Descriptor() ([]byte, []int)

+ func (*DomainInfo_FaultDomain_RegionInfo) ProtoMessage()

+ func (m *DomainInfo_FaultDomain_RegionInfo) GetName() string

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

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

+ func (m *DomainInfo_FaultDomain_RegionInfo) ProtoSize() (n int)

+ func (m *DomainInfo_FaultDomain_RegionInfo) Reset()

+ func (m *DomainInfo_FaultDomain_RegionInfo) Unmarshal(dAtA []byte) error

+ func (mj *DomainInfo_FaultDomain_RegionInfo) MarshalJSON() ([]byte, error)

+ func (mj *DomainInfo_FaultDomain_RegionInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *DomainInfo_FaultDomain_RegionInfo) Equal(that interface{}) bool

+ func (this *DomainInfo_FaultDomain_RegionInfo) GoString() string

+ func (this *DomainInfo_FaultDomain_RegionInfo) String() string

+ func (this *DomainInfo_FaultDomain_RegionInfo) VerboseEqual(that interface{}) error

+ func (uj *DomainInfo_FaultDomain_RegionInfo) UnmarshalJSON(input []byte) error

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

+ type DomainInfo_FaultDomain_ZoneInfo struct

+ Name string

+ func NewPopulatedDomainInfo_FaultDomain_ZoneInfo(r randyMesos, easy bool) *DomainInfo_FaultDomain_ZoneInfo

+ func (*DomainInfo_FaultDomain_ZoneInfo) Descriptor() ([]byte, []int)

+ func (*DomainInfo_FaultDomain_ZoneInfo) ProtoMessage()

+ func (m *DomainInfo_FaultDomain_ZoneInfo) GetName() string

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

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

+ func (m *DomainInfo_FaultDomain_ZoneInfo) ProtoSize() (n int)

+ func (m *DomainInfo_FaultDomain_ZoneInfo) Reset()

+ func (m *DomainInfo_FaultDomain_ZoneInfo) Unmarshal(dAtA []byte) error

+ func (mj *DomainInfo_FaultDomain_ZoneInfo) MarshalJSON() ([]byte, error)

+ func (mj *DomainInfo_FaultDomain_ZoneInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *DomainInfo_FaultDomain_ZoneInfo) Equal(that interface{}) bool

+ func (this *DomainInfo_FaultDomain_ZoneInfo) GoString() string

+ func (this *DomainInfo_FaultDomain_ZoneInfo) String() string

+ func (this *DomainInfo_FaultDomain_ZoneInfo) VerboseEqual(that interface{}) error

+ func (uj *DomainInfo_FaultDomain_ZoneInfo) UnmarshalJSON(input []byte) error

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

type FrameworkInfo_Capability_Type

+ const FrameworkInfo_Capability_REGION_AWARE

+ const FrameworkInfo_Capability_RESERVATION_REFINEMENT

type LinuxInfo

+ BoundingCapabilities *CapabilityInfo

+ EffectiveCapabilities *CapabilityInfo

+ SharePIDNamespace *bool

+ func (m *LinuxInfo) GetBoundingCapabilities() *CapabilityInfo

+ func (m *LinuxInfo) GetEffectiveCapabilities() *CapabilityInfo

+ func (m *LinuxInfo) GetSharePIDNamespace() bool

type MasterInfo

+ Domain *DomainInfo

+ func (m *MasterInfo) GetDomain() *DomainInfo

type NetworkInfo_Protocol

+ const Default_NetworkInfo_IPAddress_Protocol

type Offer

+ Domain *DomainInfo

+ func (m *Offer) GetDomain() *DomainInfo

type Resource

+ Reservations []Resource_ReservationInfo

+ func (m *Resource) GetReservations() []Resource_ReservationInfo

+ type ResourceProviderInfo struct

+ Attributes []Attribute

+ ID *ResourceProviderID

+ Name string

+ Type string

+ func NewPopulatedResourceProviderInfo(r randyMesos, easy bool) *ResourceProviderInfo

+ func (*ResourceProviderInfo) Descriptor() ([]byte, []int)

+ func (*ResourceProviderInfo) ProtoMessage()

+ func (m *ResourceProviderInfo) GetAttributes() []Attribute

+ func (m *ResourceProviderInfo) GetID() *ResourceProviderID

+ func (m *ResourceProviderInfo) GetName() string

+ func (m *ResourceProviderInfo) GetType() string

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

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

+ func (m *ResourceProviderInfo) ProtoSize() (n int)

+ func (m *ResourceProviderInfo) Reset()

+ func (m *ResourceProviderInfo) Unmarshal(dAtA []byte) error

+ func (mj *ResourceProviderInfo) MarshalJSON() ([]byte, error)

+ func (mj *ResourceProviderInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *ResourceProviderInfo) Equal(that interface{}) bool

+ func (this *ResourceProviderInfo) GoString() string

+ func (this *ResourceProviderInfo) String() string

+ func (this *ResourceProviderInfo) VerboseEqual(that interface{}) error

+ func (uj *ResourceProviderInfo) UnmarshalJSON(input []byte) error

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

type ResourceStatistics

+ BlkioStatistics *CgroupInfo_Blkio_Statistics

+ func (m *ResourceStatistics) GetBlkioStatistics() *CgroupInfo_Blkio_Statistics

type Resource_ReservationInfo

+ Role *string

+ Type *Resource_ReservationInfo_Type

+ func (m *Resource_ReservationInfo) GetRole() string

+ func (m *Resource_ReservationInfo) GetType() Resource_ReservationInfo_Type

+ type Resource_ReservationInfo_Type int32

+ const Resource_ReservationInfo_DYNAMIC

+ const Resource_ReservationInfo_STATIC

+ const Resource_ReservationInfo_UNKNOWN

+ func (Resource_ReservationInfo_Type) EnumDescriptor() ([]byte, []int)

+ func (x *Resource_ReservationInfo_Type) UnmarshalJSON(data []byte) error

+ func (x Resource_ReservationInfo_Type) Enum() *Resource_ReservationInfo_Type

+ func (x Resource_ReservationInfo_Type) MarshalJSON() ([]byte, error)

+ func (x Resource_ReservationInfo_Type) String() string

type TaskStatus_Reason

+ const REASON_TASK_HEALTH_CHECK_STATUS_UPDATED

v0.0.5

Sep 19, 2017

Changes in this version

+ var Environment_Variable_Type_name = map[int32]string

+ var Environment_Variable_Type_value = map[string]int32

+ var Secret_Type_name = map[int32]string

+ var Secret_Type_value = map[string]int32

type CheckInfo

+ TCP *CheckInfo_Tcp

+ func (m *CheckInfo) GetTCP() *CheckInfo_Tcp

+ type CheckInfo_Tcp struct

+ Port uint32

+ func NewPopulatedCheckInfo_Tcp(r randyMesos, easy bool) *CheckInfo_Tcp

+ func (*CheckInfo_Tcp) Descriptor() ([]byte, []int)

+ func (*CheckInfo_Tcp) ProtoMessage()

+ func (m *CheckInfo_Tcp) GetPort() uint32

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

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

+ func (m *CheckInfo_Tcp) ProtoSize() (n int)

+ func (m *CheckInfo_Tcp) Reset()

+ func (m *CheckInfo_Tcp) Unmarshal(dAtA []byte) error

+ func (mj *CheckInfo_Tcp) MarshalJSON() ([]byte, error)

+ func (mj *CheckInfo_Tcp) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *CheckInfo_Tcp) Equal(that interface{}) bool

+ func (this *CheckInfo_Tcp) GoString() string

+ func (this *CheckInfo_Tcp) String() string

+ func (this *CheckInfo_Tcp) VerboseEqual(that interface{}) error

+ func (uj *CheckInfo_Tcp) UnmarshalJSON(input []byte) error

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

type CheckInfo_Type

+ const CheckInfo_TCP

type CheckStatusInfo

+ TCP *CheckStatusInfo_Tcp

+ func (m *CheckStatusInfo) GetTCP() *CheckStatusInfo_Tcp

+ type CheckStatusInfo_Tcp struct

+ Succeeded *bool

+ func NewPopulatedCheckStatusInfo_Tcp(r randyMesos, easy bool) *CheckStatusInfo_Tcp

+ func (*CheckStatusInfo_Tcp) Descriptor() ([]byte, []int)

+ func (*CheckStatusInfo_Tcp) ProtoMessage()

+ func (m *CheckStatusInfo_Tcp) GetSucceeded() bool

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

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

+ func (m *CheckStatusInfo_Tcp) ProtoSize() (n int)

+ func (m *CheckStatusInfo_Tcp) Reset()

+ func (m *CheckStatusInfo_Tcp) Unmarshal(dAtA []byte) error

+ func (mj *CheckStatusInfo_Tcp) MarshalJSON() ([]byte, error)

+ func (mj *CheckStatusInfo_Tcp) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *CheckStatusInfo_Tcp) Equal(that interface{}) bool

+ func (this *CheckStatusInfo_Tcp) GoString() string

+ func (this *CheckStatusInfo_Tcp) String() string

+ func (this *CheckStatusInfo_Tcp) VerboseEqual(that interface{}) error

+ func (uj *CheckStatusInfo_Tcp) UnmarshalJSON(input []byte) error

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

+ type Device struct

+ Path string

+ func NewPopulatedDevice(r randyMesos, easy bool) *Device

+ func (*Device) Descriptor() ([]byte, []int)

+ func (*Device) ProtoMessage()

+ func (m *Device) GetPath() string

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

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

+ func (m *Device) ProtoSize() (n int)

+ func (m *Device) Reset()

+ func (m *Device) Unmarshal(dAtA []byte) error

+ func (mj *Device) MarshalJSON() ([]byte, error)

+ func (mj *Device) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Device) Equal(that interface{}) bool

+ func (this *Device) GoString() string

+ func (this *Device) String() string

+ func (this *Device) VerboseEqual(that interface{}) error

+ func (uj *Device) UnmarshalJSON(input []byte) error

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

+ type DeviceAccess struct

+ Access DeviceAccess_Access

+ Device Device

+ func NewPopulatedDeviceAccess(r randyMesos, easy bool) *DeviceAccess

+ func (*DeviceAccess) Descriptor() ([]byte, []int)

+ func (*DeviceAccess) ProtoMessage()

+ func (m *DeviceAccess) GetAccess() DeviceAccess_Access

+ func (m *DeviceAccess) GetDevice() Device

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

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

+ func (m *DeviceAccess) ProtoSize() (n int)

+ func (m *DeviceAccess) Reset()

+ func (m *DeviceAccess) Unmarshal(dAtA []byte) error

+ func (mj *DeviceAccess) MarshalJSON() ([]byte, error)

+ func (mj *DeviceAccess) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *DeviceAccess) Equal(that interface{}) bool

+ func (this *DeviceAccess) GoString() string

+ func (this *DeviceAccess) String() string

+ func (this *DeviceAccess) VerboseEqual(that interface{}) error

+ func (uj *DeviceAccess) UnmarshalJSON(input []byte) error

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

+ type DeviceAccess_Access struct

+ Mknod *bool

+ Read *bool

+ Write *bool

+ func NewPopulatedDeviceAccess_Access(r randyMesos, easy bool) *DeviceAccess_Access

+ func (*DeviceAccess_Access) Descriptor() ([]byte, []int)

+ func (*DeviceAccess_Access) ProtoMessage()

+ func (m *DeviceAccess_Access) GetMknod() bool

+ func (m *DeviceAccess_Access) GetRead() bool

+ func (m *DeviceAccess_Access) GetWrite() bool

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

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

+ func (m *DeviceAccess_Access) ProtoSize() (n int)

+ func (m *DeviceAccess_Access) Reset()

+ func (m *DeviceAccess_Access) Unmarshal(dAtA []byte) error

+ func (mj *DeviceAccess_Access) MarshalJSON() ([]byte, error)

+ func (mj *DeviceAccess_Access) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *DeviceAccess_Access) Equal(that interface{}) bool

+ func (this *DeviceAccess_Access) GoString() string

+ func (this *DeviceAccess_Access) String() string

+ func (this *DeviceAccess_Access) VerboseEqual(that interface{}) error

+ func (uj *DeviceAccess_Access) UnmarshalJSON(input []byte) error

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

+ type DeviceWhitelist struct

+ AllowedDevices []DeviceAccess

+ func NewPopulatedDeviceWhitelist(r randyMesos, easy bool) *DeviceWhitelist

+ func (*DeviceWhitelist) Descriptor() ([]byte, []int)

+ func (*DeviceWhitelist) ProtoMessage()

+ func (m *DeviceWhitelist) GetAllowedDevices() []DeviceAccess

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

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

+ func (m *DeviceWhitelist) ProtoSize() (n int)

+ func (m *DeviceWhitelist) Reset()

+ func (m *DeviceWhitelist) Unmarshal(dAtA []byte) error

+ func (mj *DeviceWhitelist) MarshalJSON() ([]byte, error)

+ func (mj *DeviceWhitelist) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *DeviceWhitelist) Equal(that interface{}) bool

+ func (this *DeviceWhitelist) GoString() string

+ func (this *DeviceWhitelist) String() string

+ func (this *DeviceWhitelist) VerboseEqual(that interface{}) error

+ func (uj *DeviceWhitelist) UnmarshalJSON(input []byte) error

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

+ type DiskStatistics struct

+ LimitBytes *uint64

+ Persistence *Resource_DiskInfo_Persistence

+ Source *Resource_DiskInfo_Source

+ UsedBytes *uint64

+ func NewPopulatedDiskStatistics(r randyMesos, easy bool) *DiskStatistics

+ func (*DiskStatistics) Descriptor() ([]byte, []int)

+ func (*DiskStatistics) ProtoMessage()

+ func (m *DiskStatistics) GetLimitBytes() uint64

+ func (m *DiskStatistics) GetPersistence() *Resource_DiskInfo_Persistence

+ func (m *DiskStatistics) GetSource() *Resource_DiskInfo_Source

+ func (m *DiskStatistics) GetUsedBytes() uint64

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

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

+ func (m *DiskStatistics) ProtoSize() (n int)

+ func (m *DiskStatistics) Reset()

+ func (m *DiskStatistics) Unmarshal(dAtA []byte) error

+ func (mj *DiskStatistics) MarshalJSON() ([]byte, error)

+ func (mj *DiskStatistics) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *DiskStatistics) Equal(that interface{}) bool

+ func (this *DiskStatistics) GoString() string

+ func (this *DiskStatistics) String() string

+ func (this *DiskStatistics) VerboseEqual(that interface{}) error

+ func (uj *DiskStatistics) UnmarshalJSON(input []byte) error

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

type Environment_Variable

+ Secret *Secret

+ Type *Environment_Variable_Type

+ func (m *Environment_Variable) GetSecret() *Secret

+ func (m *Environment_Variable) GetType() Environment_Variable_Type

+ type Environment_Variable_Type int32

+ const Default_Environment_Variable_Type

+ const Environment_Variable_SECRET

+ const Environment_Variable_UNKNOWN

+ const Environment_Variable_VALUE

+ func (Environment_Variable_Type) EnumDescriptor() ([]byte, []int)

+ func (x *Environment_Variable_Type) UnmarshalJSON(data []byte) error

+ func (x Environment_Variable_Type) Enum() *Environment_Variable_Type

+ func (x Environment_Variable_Type) MarshalJSON() ([]byte, error)

+ func (x Environment_Variable_Type) String() string

type Image_Docker

+ Config *Secret

+ func (m *Image_Docker) GetConfig() *Secret

type Resource

+ ProviderID *ResourceProviderID

+ func (m *Resource) GetProviderID() *ResourceProviderID

+ type ResourceProviderID struct

+ Value string

+ func NewPopulatedResourceProviderID(r randyMesos, easy bool) *ResourceProviderID

+ func (*ResourceProviderID) Descriptor() ([]byte, []int)

+ func (*ResourceProviderID) ProtoMessage()

+ func (m *ResourceProviderID) GetValue() string

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

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

+ func (m *ResourceProviderID) ProtoSize() (n int)

+ func (m *ResourceProviderID) Reset()

+ func (m *ResourceProviderID) Unmarshal(dAtA []byte) error

+ func (mj *ResourceProviderID) MarshalJSON() ([]byte, error)

+ func (mj *ResourceProviderID) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *ResourceProviderID) Equal(that interface{}) bool

+ func (this *ResourceProviderID) GoString() string

+ func (this *ResourceProviderID) String() string

+ func (this *ResourceProviderID) VerboseEqual(that interface{}) error

+ func (uj *ResourceProviderID) UnmarshalJSON(input []byte) error

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

type ResourceStatistics

+ DiskStatistics []DiskStatistics

+ func (m *ResourceStatistics) GetDiskStatistics() []DiskStatistics

type Resource_DiskInfo_Source_Type

+ const UNKNOWN

+ type Secret struct

+ Reference *Secret_Reference

+ Type Secret_Type

+ Value *Secret_Value

+ func NewPopulatedSecret(r randyMesos, easy bool) *Secret

+ func (*Secret) Descriptor() ([]byte, []int)

+ func (*Secret) ProtoMessage()

+ func (m *Secret) GetReference() *Secret_Reference

+ func (m *Secret) GetType() Secret_Type

+ func (m *Secret) GetValue() *Secret_Value

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

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

+ func (m *Secret) ProtoSize() (n int)

+ func (m *Secret) Reset()

+ func (m *Secret) Unmarshal(dAtA []byte) error

+ func (mj *Secret) MarshalJSON() ([]byte, error)

+ func (mj *Secret) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Secret) Equal(that interface{}) bool

+ func (this *Secret) GoString() string

+ func (this *Secret) String() string

+ func (this *Secret) VerboseEqual(that interface{}) error

+ func (uj *Secret) UnmarshalJSON(input []byte) error

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

+ type Secret_Reference struct

+ Key *string

+ Name string

+ func NewPopulatedSecret_Reference(r randyMesos, easy bool) *Secret_Reference

+ func (*Secret_Reference) Descriptor() ([]byte, []int)

+ func (*Secret_Reference) ProtoMessage()

+ func (m *Secret_Reference) GetKey() string

+ func (m *Secret_Reference) GetName() string

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

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

+ func (m *Secret_Reference) ProtoSize() (n int)

+ func (m *Secret_Reference) Reset()

+ func (m *Secret_Reference) Unmarshal(dAtA []byte) error

+ func (mj *Secret_Reference) MarshalJSON() ([]byte, error)

+ func (mj *Secret_Reference) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Secret_Reference) Equal(that interface{}) bool

+ func (this *Secret_Reference) GoString() string

+ func (this *Secret_Reference) String() string

+ func (this *Secret_Reference) VerboseEqual(that interface{}) error

+ func (uj *Secret_Reference) UnmarshalJSON(input []byte) error

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

+ type Secret_Type int32

+ const Secret_REFERENCE

+ const Secret_UNKNOWN

+ const Secret_VALUE

+ func (Secret_Type) EnumDescriptor() ([]byte, []int)

+ func (x *Secret_Type) UnmarshalJSON(data []byte) error

+ func (x Secret_Type) Enum() *Secret_Type

+ func (x Secret_Type) MarshalJSON() ([]byte, error)

+ func (x Secret_Type) String() string

+ type Secret_Value struct

+ Data []byte

+ func NewPopulatedSecret_Value(r randyMesos, easy bool) *Secret_Value

+ func (*Secret_Value) Descriptor() ([]byte, []int)

+ func (*Secret_Value) ProtoMessage()

+ func (m *Secret_Value) GetData() []byte

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

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

+ func (m *Secret_Value) ProtoSize() (n int)

+ func (m *Secret_Value) Reset()

+ func (m *Secret_Value) Unmarshal(dAtA []byte) error

+ func (mj *Secret_Value) MarshalJSON() ([]byte, error)

+ func (mj *Secret_Value) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Secret_Value) Equal(that interface{}) bool

+ func (this *Secret_Value) GoString() string

+ func (this *Secret_Value) String() string

+ func (this *Secret_Value) VerboseEqual(that interface{}) error

+ func (uj *Secret_Value) UnmarshalJSON(input []byte) error

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

type TaskStatus_Reason

+ const REASON_TASK_KILLED_DURING_LAUNCH

type Volume_Source

+ Secret *Secret

+ func (m *Volume_Source) GetSecret() *Secret

type Volume_Source_Type

+ const Volume_Source_SECRET

v0.0.4

Sep 13, 2017

Changes in this version

+ const Default_CheckInfo_DelaySeconds

+ const Default_CheckInfo_IntervalSeconds

+ const Default_CheckInfo_TimeoutSeconds

+ var AgentInfo_Capability_Type_name = map[int32]string

+ var AgentInfo_Capability_Type_value = map[string]int32

+ var CheckInfo_Type_name = map[int32]string

+ var CheckInfo_Type_value = map[string]int32

+ var RLimitInfo_RLimit_Type_name = map[int32]string

+ var RLimitInfo_RLimit_Type_value = map[string]int32

+ func IsResourceError(err error) (ok bool)

type Address

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

+ func (m *Address) ProtoSize() (n int)

type AgentID

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

+ func (m *AgentID) ProtoSize() (n int)

type AgentInfo

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

+ func (m *AgentInfo) ProtoSize() (n int)

+ type AgentInfo_Capability struct

+ Type AgentInfo_Capability_Type

+ func NewPopulatedAgentInfo_Capability(r randyMesos, easy bool) *AgentInfo_Capability

+ func (*AgentInfo_Capability) Descriptor() ([]byte, []int)

+ func (*AgentInfo_Capability) ProtoMessage()

+ func (m *AgentInfo_Capability) GetType() AgentInfo_Capability_Type

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

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

+ func (m *AgentInfo_Capability) ProtoSize() (n int)

+ func (m *AgentInfo_Capability) Reset()

+ func (m *AgentInfo_Capability) Unmarshal(dAtA []byte) error

+ func (mj *AgentInfo_Capability) MarshalJSON() ([]byte, error)

+ func (mj *AgentInfo_Capability) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *AgentInfo_Capability) Equal(that interface{}) bool

+ func (this *AgentInfo_Capability) GoString() string

+ func (this *AgentInfo_Capability) String() string

+ func (this *AgentInfo_Capability) VerboseEqual(that interface{}) error

+ func (uj *AgentInfo_Capability) UnmarshalJSON(input []byte) error

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

+ type AgentInfo_Capability_Type int32

+ const AgentInfo_Capability_MULTI_ROLE

+ const AgentInfo_Capability_UNKNOWN

+ func (AgentInfo_Capability_Type) EnumDescriptor() ([]byte, []int)

+ func (x *AgentInfo_Capability_Type) UnmarshalJSON(data []byte) error

+ func (x AgentInfo_Capability_Type) Enum() *AgentInfo_Capability_Type

+ func (x AgentInfo_Capability_Type) MarshalJSON() ([]byte, error)

+ func (x AgentInfo_Capability_Type) String() string

type Attribute

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

+ func (m *Attribute) ProtoSize() (n int)

type CapabilityInfo

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

+ func (m *CapabilityInfo) ProtoSize() (n int)

type CapabilityInfo_Capability

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

type CgroupInfo

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

+ func (m *CgroupInfo) ProtoSize() (n int)

type CgroupInfo_NetCls

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

+ func (m *CgroupInfo_NetCls) ProtoSize() (n int)

+ type CheckInfo struct

+ Command *CheckInfo_Command

+ DelaySeconds *float64

+ HTTP *CheckInfo_Http

+ IntervalSeconds *float64

+ TimeoutSeconds *float64

+ Type CheckInfo_Type

+ func NewPopulatedCheckInfo(r randyMesos, easy bool) *CheckInfo

+ func (*CheckInfo) Descriptor() ([]byte, []int)

+ func (*CheckInfo) ProtoMessage()

+ func (m *CheckInfo) GetCommand() *CheckInfo_Command

+ func (m *CheckInfo) GetDelaySeconds() float64

+ func (m *CheckInfo) GetHTTP() *CheckInfo_Http

+ func (m *CheckInfo) GetIntervalSeconds() float64

+ func (m *CheckInfo) GetTimeoutSeconds() float64

+ func (m *CheckInfo) GetType() CheckInfo_Type

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

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

+ func (m *CheckInfo) ProtoSize() (n int)

+ func (m *CheckInfo) Reset()

+ func (m *CheckInfo) Unmarshal(dAtA []byte) error

+ func (mj *CheckInfo) MarshalJSON() ([]byte, error)

+ func (mj *CheckInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *CheckInfo) Equal(that interface{}) bool

+ func (this *CheckInfo) GoString() string

+ func (this *CheckInfo) String() string

+ func (this *CheckInfo) VerboseEqual(that interface{}) error

+ func (uj *CheckInfo) UnmarshalJSON(input []byte) error

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

+ type CheckInfo_Command struct

+ Command CommandInfo

+ func NewPopulatedCheckInfo_Command(r randyMesos, easy bool) *CheckInfo_Command

+ func (*CheckInfo_Command) Descriptor() ([]byte, []int)

+ func (*CheckInfo_Command) ProtoMessage()

+ func (m *CheckInfo_Command) GetCommand() CommandInfo

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

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

+ func (m *CheckInfo_Command) ProtoSize() (n int)

+ func (m *CheckInfo_Command) Reset()

+ func (m *CheckInfo_Command) Unmarshal(dAtA []byte) error

+ func (mj *CheckInfo_Command) MarshalJSON() ([]byte, error)

+ func (mj *CheckInfo_Command) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *CheckInfo_Command) Equal(that interface{}) bool

+ func (this *CheckInfo_Command) GoString() string

+ func (this *CheckInfo_Command) String() string

+ func (this *CheckInfo_Command) VerboseEqual(that interface{}) error

+ func (uj *CheckInfo_Command) UnmarshalJSON(input []byte) error

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

+ type CheckInfo_Http struct

+ Path *string

+ Port uint32

+ func NewPopulatedCheckInfo_Http(r randyMesos, easy bool) *CheckInfo_Http

+ func (*CheckInfo_Http) Descriptor() ([]byte, []int)

+ func (*CheckInfo_Http) ProtoMessage()

+ func (m *CheckInfo_Http) GetPath() string

+ func (m *CheckInfo_Http) GetPort() uint32

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

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

+ func (m *CheckInfo_Http) ProtoSize() (n int)

+ func (m *CheckInfo_Http) Reset()

+ func (m *CheckInfo_Http) Unmarshal(dAtA []byte) error

+ func (mj *CheckInfo_Http) MarshalJSON() ([]byte, error)

+ func (mj *CheckInfo_Http) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *CheckInfo_Http) Equal(that interface{}) bool

+ func (this *CheckInfo_Http) GoString() string

+ func (this *CheckInfo_Http) String() string

+ func (this *CheckInfo_Http) VerboseEqual(that interface{}) error

+ func (uj *CheckInfo_Http) UnmarshalJSON(input []byte) error

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

+ type CheckInfo_Type int32

+ const CheckInfo_COMMAND

+ const CheckInfo_HTTP

+ const CheckInfo_UNKNOWN

+ func (CheckInfo_Type) EnumDescriptor() ([]byte, []int)

+ func (x *CheckInfo_Type) UnmarshalJSON(data []byte) error

+ func (x CheckInfo_Type) Enum() *CheckInfo_Type

+ func (x CheckInfo_Type) MarshalJSON() ([]byte, error)

+ func (x CheckInfo_Type) String() string

+ type CheckStatusInfo struct

+ Command *CheckStatusInfo_Command

+ HTTP *CheckStatusInfo_Http

+ Type *CheckInfo_Type

+ func NewPopulatedCheckStatusInfo(r randyMesos, easy bool) *CheckStatusInfo

+ func (*CheckStatusInfo) Descriptor() ([]byte, []int)

+ func (*CheckStatusInfo) ProtoMessage()

+ func (m *CheckStatusInfo) GetCommand() *CheckStatusInfo_Command

+ func (m *CheckStatusInfo) GetHTTP() *CheckStatusInfo_Http

+ func (m *CheckStatusInfo) GetType() CheckInfo_Type

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

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

+ func (m *CheckStatusInfo) ProtoSize() (n int)

+ func (m *CheckStatusInfo) Reset()

+ func (m *CheckStatusInfo) Unmarshal(dAtA []byte) error

+ func (mj *CheckStatusInfo) MarshalJSON() ([]byte, error)

+ func (mj *CheckStatusInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *CheckStatusInfo) Equal(that interface{}) bool

+ func (this *CheckStatusInfo) GoString() string

+ func (this *CheckStatusInfo) String() string

+ func (this *CheckStatusInfo) VerboseEqual(that interface{}) error

+ func (uj *CheckStatusInfo) UnmarshalJSON(input []byte) error

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

+ type CheckStatusInfo_Command struct

+ ExitCode *int32

+ func NewPopulatedCheckStatusInfo_Command(r randyMesos, easy bool) *CheckStatusInfo_Command

+ func (*CheckStatusInfo_Command) Descriptor() ([]byte, []int)

+ func (*CheckStatusInfo_Command) ProtoMessage()

+ func (m *CheckStatusInfo_Command) GetExitCode() int32

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

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

+ func (m *CheckStatusInfo_Command) ProtoSize() (n int)

+ func (m *CheckStatusInfo_Command) Reset()

+ func (m *CheckStatusInfo_Command) Unmarshal(dAtA []byte) error

+ func (mj *CheckStatusInfo_Command) MarshalJSON() ([]byte, error)

+ func (mj *CheckStatusInfo_Command) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *CheckStatusInfo_Command) Equal(that interface{}) bool

+ func (this *CheckStatusInfo_Command) GoString() string

+ func (this *CheckStatusInfo_Command) String() string

+ func (this *CheckStatusInfo_Command) VerboseEqual(that interface{}) error

+ func (uj *CheckStatusInfo_Command) UnmarshalJSON(input []byte) error

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

+ type CheckStatusInfo_Http struct

+ StatusCode *uint32

+ func NewPopulatedCheckStatusInfo_Http(r randyMesos, easy bool) *CheckStatusInfo_Http

+ func (*CheckStatusInfo_Http) Descriptor() ([]byte, []int)

+ func (*CheckStatusInfo_Http) ProtoMessage()

+ func (m *CheckStatusInfo_Http) GetStatusCode() uint32

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

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

+ func (m *CheckStatusInfo_Http) ProtoSize() (n int)

+ func (m *CheckStatusInfo_Http) Reset()

+ func (m *CheckStatusInfo_Http) Unmarshal(dAtA []byte) error

+ func (mj *CheckStatusInfo_Http) MarshalJSON() ([]byte, error)

+ func (mj *CheckStatusInfo_Http) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *CheckStatusInfo_Http) Equal(that interface{}) bool

+ func (this *CheckStatusInfo_Http) GoString() string

+ func (this *CheckStatusInfo_Http) String() string

+ func (this *CheckStatusInfo_Http) VerboseEqual(that interface{}) error

+ func (uj *CheckStatusInfo_Http) UnmarshalJSON(input []byte) error

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

type CommandInfo

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

+ func (m *CommandInfo) ProtoSize() (n int)

type CommandInfo_URI

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

+ func (m *CommandInfo_URI) ProtoSize() (n int)

type ContainerID

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

+ func (m *ContainerID) ProtoSize() (n int)

type ContainerInfo

+ RlimitInfo *RLimitInfo

+ TTYInfo *TTYInfo

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

+ func (m *ContainerInfo) GetRlimitInfo() *RLimitInfo

+ func (m *ContainerInfo) GetTTYInfo() *TTYInfo

+ func (m *ContainerInfo) ProtoSize() (n int)

type ContainerInfo_DockerInfo

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

+ func (m *ContainerInfo_DockerInfo) ProtoSize() (n int)

type ContainerInfo_DockerInfo_Network

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

type ContainerInfo_DockerInfo_PortMapping

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

+ func (m *ContainerInfo_DockerInfo_PortMapping) ProtoSize() (n int)

type ContainerInfo_MesosInfo

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

+ func (m *ContainerInfo_MesosInfo) ProtoSize() (n int)

type ContainerInfo_Type

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

type ContainerStatus

+ ContainerID *ContainerID

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

+ func (m *ContainerStatus) GetContainerID() *ContainerID

+ func (m *ContainerStatus) ProtoSize() (n int)

type Credential

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

+ func (m *Credential) ProtoSize() (n int)

type Credentials

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

+ func (m *Credentials) ProtoSize() (n int)

type DiscoveryInfo

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

+ func (m *DiscoveryInfo) ProtoSize() (n int)

type DiscoveryInfo_Visibility

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

type DurationInfo

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

+ func (m *DurationInfo) ProtoSize() (n int)

type Environment

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

+ func (m *Environment) ProtoSize() (n int)

type Environment_Variable

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

+ func (m *Environment_Variable) ProtoSize() (n int)

type ExecutorID

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

+ func (m *ExecutorID) ProtoSize() (n int)

type ExecutorInfo

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

+ func (m *ExecutorInfo) ProtoSize() (n int)

type ExecutorInfo_Type

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

type FileInfo

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

+ func (m *FileInfo) GetSize() uint64

+ func (m *FileInfo) ProtoSize() (n int)

type Filters

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

+ func (m *Filters) ProtoSize() (n int)

type Flag

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

+ func (m *Flag) ProtoSize() (n int)

type FrameworkID

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

+ func (m *FrameworkID) ProtoSize() (n int)

type FrameworkInfo

+ Roles []string

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

+ func (m *FrameworkInfo) GetRoles() []string

+ func (m *FrameworkInfo) ProtoSize() (n int)

type FrameworkInfo_Capability

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

+ func (m *FrameworkInfo_Capability) ProtoSize() (n int)

type FrameworkInfo_Capability_Type

+ const FrameworkInfo_Capability_MULTI_ROLE

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

type HealthCheck

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

+ func (m *HealthCheck) ProtoSize() (n int)

type HealthCheck_HTTPCheckInfo

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

+ func (m *HealthCheck_HTTPCheckInfo) ProtoSize() (n int)

type HealthCheck_TCPCheckInfo

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

+ func (m *HealthCheck_TCPCheckInfo) ProtoSize() (n int)

type HealthCheck_Type

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

type IcmpStatistics

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

+ func (m *IcmpStatistics) ProtoSize() (n int)

type Image

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

+ func (m *Image) ProtoSize() (n int)

type Image_Appc

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

+ func (m *Image_Appc) ProtoSize() (n int)

type Image_Docker

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

+ func (m *Image_Docker) ProtoSize() (n int)

type Image_Type

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

type InverseOffer

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

+ func (m *InverseOffer) ProtoSize() (n int)

type IpStatistics

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

+ func (m *IpStatistics) ProtoSize() (n int)

type KillPolicy

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

+ func (m *KillPolicy) ProtoSize() (n int)

type Label

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

+ func (m *Label) ProtoSize() (n int)

type Labels

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

+ func (m *Labels) ProtoSize() (n int)

type LinuxInfo

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

+ func (m *LinuxInfo) ProtoSize() (n int)

type MachineID

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

+ func (m *MachineID) ProtoSize() (n int)

type MachineInfo

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

+ func (m *MachineInfo) ProtoSize() (n int)

type MachineInfo_Mode

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

type MasterInfo

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

+ func (m *MasterInfo) ProtoSize() (n int)

type Metric

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

+ func (m *Metric) ProtoSize() (n int)

type NetworkInfo

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

+ func (m *NetworkInfo) ProtoSize() (n int)

type NetworkInfo_IPAddress

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

+ func (m *NetworkInfo_IPAddress) ProtoSize() (n int)

type NetworkInfo_PortMapping

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

+ func (m *NetworkInfo_PortMapping) ProtoSize() (n int)

type NetworkInfo_Protocol

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

type Offer

+ AllocationInfo *Resource_AllocationInfo

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

+ func (m *Offer) GetAllocationInfo() *Resource_AllocationInfo

+ func (m *Offer) ProtoSize() (n int)

type OfferID

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

+ func (m *OfferID) ProtoSize() (n int)

type Offer_Operation

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

+ func (m *Offer_Operation) ProtoSize() (n int)

type Offer_Operation_Create

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

+ func (m *Offer_Operation_Create) ProtoSize() (n int)

type Offer_Operation_Destroy

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

+ func (m *Offer_Operation_Destroy) ProtoSize() (n int)

type Offer_Operation_Launch

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

+ func (m *Offer_Operation_Launch) ProtoSize() (n int)

type Offer_Operation_LaunchGroup

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

+ func (m *Offer_Operation_LaunchGroup) ProtoSize() (n int)

type Offer_Operation_Reserve

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

+ func (m *Offer_Operation_Reserve) ProtoSize() (n int)

type Offer_Operation_Type

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

type Offer_Operation_Unreserve

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

+ func (m *Offer_Operation_Unreserve) ProtoSize() (n int)

type Parameter

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

+ func (m *Parameter) ProtoSize() (n int)

type Parameters

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

+ func (m *Parameters) ProtoSize() (n int)

type PerfStatistics

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

+ func (m *PerfStatistics) ProtoSize() (n int)

type Port

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

+ func (m *Port) ProtoSize() (n int)

type Ports

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

+ func (m *Ports) ProtoSize() (n int)

+ type RLimitInfo struct

+ Rlimits []RLimitInfo_RLimit

+ func NewPopulatedRLimitInfo(r randyMesos, easy bool) *RLimitInfo

+ func (*RLimitInfo) Descriptor() ([]byte, []int)

+ func (*RLimitInfo) ProtoMessage()

+ func (m *RLimitInfo) GetRlimits() []RLimitInfo_RLimit

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

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

+ func (m *RLimitInfo) ProtoSize() (n int)

+ func (m *RLimitInfo) Reset()

+ func (m *RLimitInfo) Unmarshal(dAtA []byte) error

+ func (mj *RLimitInfo) MarshalJSON() ([]byte, error)

+ func (mj *RLimitInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *RLimitInfo) Equal(that interface{}) bool

+ func (this *RLimitInfo) GoString() string

+ func (this *RLimitInfo) String() string

+ func (this *RLimitInfo) VerboseEqual(that interface{}) error

+ func (uj *RLimitInfo) UnmarshalJSON(input []byte) error

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

+ type RLimitInfo_RLimit struct

+ Hard *uint64

+ Soft *uint64

+ Type RLimitInfo_RLimit_Type

+ func NewPopulatedRLimitInfo_RLimit(r randyMesos, easy bool) *RLimitInfo_RLimit

+ func (*RLimitInfo_RLimit) Descriptor() ([]byte, []int)

+ func (*RLimitInfo_RLimit) ProtoMessage()

+ func (m *RLimitInfo_RLimit) GetHard() uint64

+ func (m *RLimitInfo_RLimit) GetSoft() uint64

+ func (m *RLimitInfo_RLimit) GetType() RLimitInfo_RLimit_Type

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

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

+ func (m *RLimitInfo_RLimit) ProtoSize() (n int)

+ func (m *RLimitInfo_RLimit) Reset()

+ func (m *RLimitInfo_RLimit) Unmarshal(dAtA []byte) error

+ func (mj *RLimitInfo_RLimit) MarshalJSON() ([]byte, error)

+ func (mj *RLimitInfo_RLimit) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *RLimitInfo_RLimit) Equal(that interface{}) bool

+ func (this *RLimitInfo_RLimit) GoString() string

+ func (this *RLimitInfo_RLimit) String() string

+ func (this *RLimitInfo_RLimit) VerboseEqual(that interface{}) error

+ func (uj *RLimitInfo_RLimit) UnmarshalJSON(input []byte) error

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

+ type RLimitInfo_RLimit_Type int32

+ const RLimitInfo_RLimit_RLMT_AS

+ const RLimitInfo_RLimit_RLMT_CORE

+ const RLimitInfo_RLimit_RLMT_CPU

+ const RLimitInfo_RLimit_RLMT_DATA

+ const RLimitInfo_RLimit_RLMT_FSIZE

+ const RLimitInfo_RLimit_RLMT_LOCKS

+ const RLimitInfo_RLimit_RLMT_MEMLOCK

+ const RLimitInfo_RLimit_RLMT_MSGQUEUE

+ const RLimitInfo_RLimit_RLMT_NICE

+ const RLimitInfo_RLimit_RLMT_NOFILE

+ const RLimitInfo_RLimit_RLMT_NPROC

+ const RLimitInfo_RLimit_RLMT_RSS

+ const RLimitInfo_RLimit_RLMT_RTPRIO

+ const RLimitInfo_RLimit_RLMT_RTTIME

+ const RLimitInfo_RLimit_RLMT_SIGPENDING

+ const RLimitInfo_RLimit_RLMT_STACK

+ const RLimitInfo_RLimit_UNKNOWN

+ func (RLimitInfo_RLimit_Type) EnumDescriptor() ([]byte, []int)

+ func (x *RLimitInfo_RLimit_Type) UnmarshalJSON(data []byte) error

+ func (x RLimitInfo_RLimit_Type) Enum() *RLimitInfo_RLimit_Type

+ func (x RLimitInfo_RLimit_Type) MarshalJSON() ([]byte, error)

+ func (x RLimitInfo_RLimit_Type) String() string

type RateLimit

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

+ func (m *RateLimit) ProtoSize() (n int)

type RateLimits

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

+ func (m *RateLimits) ProtoSize() (n int)

type Request

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

+ func (m *Request) ProtoSize() (n int)

type Resource

+ AllocationInfo *Resource_AllocationInfo

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

+ func (m *Resource) GetAllocationInfo() *Resource_AllocationInfo

+ func (m *Resource) ProtoSize() (n int)

type ResourceStatistics

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

+ func (m *ResourceStatistics) ProtoSize() (n int)

type ResourceUsage

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

+ func (m *ResourceUsage) ProtoSize() (n int)

type ResourceUsage_Executor

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

+ func (m *ResourceUsage_Executor) ProtoSize() (n int)

type ResourceUsage_Executor_Task

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

+ func (m *ResourceUsage_Executor_Task) ProtoSize() (n int)

+ type Resource_AllocationInfo struct

+ Role *string

+ func NewPopulatedResource_AllocationInfo(r randyMesos, easy bool) *Resource_AllocationInfo

+ func (*Resource_AllocationInfo) Descriptor() ([]byte, []int)

+ func (*Resource_AllocationInfo) ProtoMessage()

+ func (m *Resource_AllocationInfo) GetRole() string

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

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

+ func (m *Resource_AllocationInfo) ProtoSize() (n int)

+ func (m *Resource_AllocationInfo) Reset()

+ func (m *Resource_AllocationInfo) Unmarshal(dAtA []byte) error

+ func (mj *Resource_AllocationInfo) MarshalJSON() ([]byte, error)

+ func (mj *Resource_AllocationInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Resource_AllocationInfo) Equal(that interface{}) bool

+ func (this *Resource_AllocationInfo) GoString() string

+ func (this *Resource_AllocationInfo) String() string

+ func (this *Resource_AllocationInfo) VerboseEqual(that interface{}) error

+ func (uj *Resource_AllocationInfo) UnmarshalJSON(input []byte) error

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

type Resource_DiskInfo

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

+ func (m *Resource_DiskInfo) ProtoSize() (n int)

type Resource_DiskInfo_Persistence

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

+ func (m *Resource_DiskInfo_Persistence) ProtoSize() (n int)

type Resource_DiskInfo_Source

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

+ func (m *Resource_DiskInfo_Source) ProtoSize() (n int)

type Resource_DiskInfo_Source_Mount

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

+ func (m *Resource_DiskInfo_Source_Mount) ProtoSize() (n int)

type Resource_DiskInfo_Source_Path

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

+ func (m *Resource_DiskInfo_Source_Path) ProtoSize() (n int)

type Resource_DiskInfo_Source_Type

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

type Resource_ReservationInfo

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

+ func (m *Resource_ReservationInfo) ProtoSize() (n int)

type Resource_RevocableInfo

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

+ func (m *Resource_RevocableInfo) ProtoSize() (n int)

type Resource_SharedInfo

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

+ func (m *Resource_SharedInfo) ProtoSize() (n int)

type Resources

+ func (resources *Resources) Add1(that Resource) (rs Resources)

+ func (resources *Resources) Minus1(that Resource) Resources

+ func (resources *Resources) Subtract1(that Resource) Resources

type Role

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

+ func (m *Role) ProtoSize() (n int)

type SNMPStatistics

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

+ func (m *SNMPStatistics) ProtoSize() (n int)

type Status

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

+ type TTYInfo struct

+ WindowSize *TTYInfo_WindowSize

+ func NewPopulatedTTYInfo(r randyMesos, easy bool) *TTYInfo

+ func (*TTYInfo) Descriptor() ([]byte, []int)

+ func (*TTYInfo) ProtoMessage()

+ func (m *TTYInfo) GetWindowSize() *TTYInfo_WindowSize

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

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

+ func (m *TTYInfo) ProtoSize() (n int)

+ func (m *TTYInfo) Reset()

+ func (m *TTYInfo) Unmarshal(dAtA []byte) error

+ func (mj *TTYInfo) MarshalJSON() ([]byte, error)

+ func (mj *TTYInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *TTYInfo) Equal(that interface{}) bool

+ func (this *TTYInfo) GoString() string

+ func (this *TTYInfo) String() string

+ func (this *TTYInfo) VerboseEqual(that interface{}) error

+ func (uj *TTYInfo) UnmarshalJSON(input []byte) error

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

+ type TTYInfo_WindowSize struct

+ Columns uint32

+ Rows uint32

+ func NewPopulatedTTYInfo_WindowSize(r randyMesos, easy bool) *TTYInfo_WindowSize

+ func (*TTYInfo_WindowSize) Descriptor() ([]byte, []int)

+ func (*TTYInfo_WindowSize) ProtoMessage()

+ func (m *TTYInfo_WindowSize) GetColumns() uint32

+ func (m *TTYInfo_WindowSize) GetRows() uint32

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

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

+ func (m *TTYInfo_WindowSize) ProtoSize() (n int)

+ func (m *TTYInfo_WindowSize) Reset()

+ func (m *TTYInfo_WindowSize) Unmarshal(dAtA []byte) error

+ func (mj *TTYInfo_WindowSize) MarshalJSON() ([]byte, error)

+ func (mj *TTYInfo_WindowSize) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *TTYInfo_WindowSize) Equal(that interface{}) bool

+ func (this *TTYInfo_WindowSize) GoString() string

+ func (this *TTYInfo_WindowSize) String() string

+ func (this *TTYInfo_WindowSize) VerboseEqual(that interface{}) error

+ func (uj *TTYInfo_WindowSize) UnmarshalJSON(input []byte) error

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

type Task

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

+ func (m *Task) ProtoSize() (n int)

type TaskGroupInfo

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

+ func (m *TaskGroupInfo) ProtoSize() (n int)

type TaskID

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

+ func (m *TaskID) ProtoSize() (n int)

type TaskInfo

+ Check *CheckInfo

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

+ func (m *TaskInfo) GetCheck() *CheckInfo

+ func (m *TaskInfo) ProtoSize() (n int)

type TaskState

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

type TaskStatus

+ CheckStatus *CheckStatusInfo

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

+ func (m *TaskStatus) GetCheckStatus() *CheckStatusInfo

+ func (m *TaskStatus) ProtoSize() (n int)

type TaskStatus_Reason

+ const REASON_IO_SWITCHBOARD_EXITED

+ const REASON_TASK_CHECK_STATUS_UPDATED

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

type TaskStatus_Source

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

type TcpStatistics

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

+ func (m *TcpStatistics) ProtoSize() (n int)

type TimeInfo

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

+ func (m *TimeInfo) ProtoSize() (n int)

type TrafficControlStatistics

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

+ func (m *TrafficControlStatistics) ProtoSize() (n int)

type URL

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

+ func (m *URL) ProtoSize() (n int)

type UdpStatistics

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

+ func (m *UdpStatistics) ProtoSize() (n int)

type Unavailability

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

+ func (m *Unavailability) ProtoSize() (n int)

type Value

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

+ func (m *Value) ProtoSize() (n int)

type Value_Range

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

+ func (m *Value_Range) ProtoSize() (n int)

type Value_Ranges

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

+ func (m *Value_Ranges) ProtoSize() (n int)

type Value_Scalar

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

+ func (m *Value_Scalar) ProtoSize() (n int)

type Value_Set

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

+ func (m *Value_Set) ProtoSize() (n int)

type Value_Text

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

+ func (m *Value_Text) ProtoSize() (n int)

type Value_Type

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

type VersionInfo

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

+ func (m *VersionInfo) ProtoSize() (n int)

type Volume

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

+ func (m *Volume) ProtoSize() (n int)

type Volume_Mode

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

type Volume_Source

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

+ func (m *Volume_Source) ProtoSize() (n int)

type Volume_Source_DockerVolume

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

+ func (m *Volume_Source_DockerVolume) ProtoSize() (n int)

type Volume_Source_SandboxPath

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

+ func (m *Volume_Source_SandboxPath) ProtoSize() (n int)

type Volume_Source_SandboxPath_Type

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

type Volume_Source_Type

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

type WeightInfo

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

+ func (m *WeightInfo) ProtoSize() (n int)

v0.0.3

Jun 19, 2017

Changes in this version

+ const Default_AgentInfo_Port

+ const Default_CommandInfo_Shell

+ const Default_CommandInfo_URI_Extract

+ const Default_ContainerInfo_DockerInfo_Privileged

+ const Default_Filters_RefuseSeconds

+ const Default_FrameworkInfo_Checkpoint

+ const Default_FrameworkInfo_FailoverTimeout

+ const Default_FrameworkInfo_Role

+ const Default_HealthCheck_ConsecutiveFailures

+ const Default_HealthCheck_DelaySeconds

+ const Default_HealthCheck_GracePeriodSeconds

+ const Default_HealthCheck_IntervalSeconds

+ const Default_HealthCheck_TimeoutSeconds

+ const Default_Image_Cached

+ const Default_MasterInfo_Port

+ const Default_Resource_Role

+ var AnyResources = ResourceFilter(func(r *Resource) bool { ... })

+ var CapabilityInfo_Capability_name = map[int32]string

+ var CapabilityInfo_Capability_value = map[string]int32

+ var ContainerInfo_DockerInfo_Network_name = map[int32]string

+ var ContainerInfo_DockerInfo_Network_value = map[string]int32

+ var ContainerInfo_Type_name = map[int32]string

+ var ContainerInfo_Type_value = map[string]int32

+ var DiscoveryInfo_Visibility_name = map[int32]string

+ var DiscoveryInfo_Visibility_value = map[string]int32

+ var ErrIntOverflowMesos = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthMesos = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ExecutorInfo_Type_name = map[int32]string

+ var ExecutorInfo_Type_value = map[string]int32

+ var FrameworkInfo_Capability_Type_name = map[int32]string

+ var FrameworkInfo_Capability_Type_value = map[string]int32

+ var HealthCheck_Type_name = map[int32]string

+ var HealthCheck_Type_value = map[string]int32

+ var Image_Type_name = map[int32]string

+ var Image_Type_value = map[string]int32

+ var MachineInfo_Mode_name = map[int32]string

+ var MachineInfo_Mode_value = map[string]int32

+ var NetworkInfo_Protocol_name = map[int32]string

+ var NetworkInfo_Protocol_value = map[string]int32

+ var Offer_Operation_Type_name = map[int32]string

+ var Offer_Operation_Type_value = map[string]int32

+ var PersistentVolumes = ResourceFilter(func(r *Resource) bool { ... })

+ var RangeResources = ResourceFilter(func(r *Resource) bool { ... })

+ var Resource_DiskInfo_Source_Type_name = map[int32]string

+ var Resource_DiskInfo_Source_Type_value = map[string]int32

+ var RevocableResources = ResourceFilter(func(r *Resource) bool { ... })

+ var ScalarResources = ResourceFilter(func(r *Resource) bool { ... })

+ var SetResources = ResourceFilter(func(r *Resource) bool { ... })

+ var Status_name = map[int32]string

+ var Status_value = map[string]int32

+ var TaskState_name = map[int32]string

+ var TaskState_value = map[string]int32

+ var TaskStatus_Reason_name = map[int32]string

+ var TaskStatus_Reason_value = map[string]int32

+ var TaskStatus_Source_name = map[int32]string

+ var TaskStatus_Source_value = map[string]int32

+ var UnreservedResources = ResourceFilter(func(r *Resource) bool { ... })

+ var Value_Type_name = map[int32]string

+ var Value_Type_value = map[string]int32

+ var Volume_Mode_name = map[int32]string

+ var Volume_Mode_value = map[string]int32

+ var Volume_Source_SandboxPath_Type_name = map[int32]string

+ var Volume_Source_SandboxPath_Type_value = map[string]int32

+ var Volume_Source_Type_name = map[int32]string

+ var Volume_Source_Type_value = map[string]int32

+ type Address struct

+ Hostname *string

+ IP *string

+ Port int32

+ func NewPopulatedAddress(r randyMesos, easy bool) *Address

+ func (*Address) ProtoMessage()

+ func (m *Address) GetHostname() string

+ func (m *Address) GetIP() string

+ func (m *Address) GetPort() int32

+ func (m *Address) Marshal() (data []byte, err error)

+ func (m *Address) MarshalTo(data []byte) (int, error)

+ func (m *Address) Reset()

+ func (m *Address) Size() (n int)

+ func (m *Address) Unmarshal(data []byte) error

+ func (mj *Address) MarshalJSON() ([]byte, error)

+ func (mj *Address) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Address) Equal(that interface{}) bool

+ func (this *Address) GoString() string

+ func (this *Address) String() string

+ func (this *Address) VerboseEqual(that interface{}) error

+ func (uj *Address) UnmarshalJSON(input []byte) error

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

+ type AgentID struct

+ Value string

+ func NewPopulatedAgentID(r randyMesos, easy bool) *AgentID

+ func (*AgentID) ProtoMessage()

+ func (m *AgentID) GetValue() string

+ func (m *AgentID) Marshal() (data []byte, err error)

+ func (m *AgentID) MarshalTo(data []byte) (int, error)

+ func (m *AgentID) Reset()

+ func (m *AgentID) Size() (n int)

+ func (m *AgentID) Unmarshal(data []byte) error

+ func (mj *AgentID) MarshalJSON() ([]byte, error)

+ func (mj *AgentID) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *AgentID) Equal(that interface{}) bool

+ func (this *AgentID) GoString() string

+ func (this *AgentID) String() string

+ func (this *AgentID) VerboseEqual(that interface{}) error

+ func (uj *AgentID) UnmarshalJSON(input []byte) error

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

+ type AgentInfo struct

+ Attributes []Attribute

+ Hostname string

+ ID *AgentID

+ Port *int32

+ Resources []Resource

+ func NewPopulatedAgentInfo(r randyMesos, easy bool) *AgentInfo

+ func (*AgentInfo) ProtoMessage()

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

+ func (m *AgentInfo) GetHostname() string

+ func (m *AgentInfo) GetID() *AgentID

+ func (m *AgentInfo) GetPort() int32

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

+ func (m *AgentInfo) Marshal() (data []byte, err error)

+ func (m *AgentInfo) MarshalTo(data []byte) (int, error)

+ func (m *AgentInfo) Reset()

+ func (m *AgentInfo) Size() (n int)

+ func (m *AgentInfo) Unmarshal(data []byte) error

+ func (mj *AgentInfo) MarshalJSON() ([]byte, error)

+ func (mj *AgentInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *AgentInfo) Equal(that interface{}) bool

+ func (this *AgentInfo) GoString() string

+ func (this *AgentInfo) String() string

+ func (this *AgentInfo) VerboseEqual(that interface{}) error

+ func (uj *AgentInfo) UnmarshalJSON(input []byte) error

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

+ type Attribute struct

+ Name string

+ Ranges *Value_Ranges

+ Scalar *Value_Scalar

+ Set *Value_Set

+ Text *Value_Text

+ Type Value_Type

+ func NewPopulatedAttribute(r randyMesos, easy bool) *Attribute

+ func (*Attribute) ProtoMessage()

+ func (m *Attribute) GetName() string

+ func (m *Attribute) GetRanges() *Value_Ranges

+ func (m *Attribute) GetScalar() *Value_Scalar

+ func (m *Attribute) GetSet() *Value_Set

+ func (m *Attribute) GetText() *Value_Text

+ func (m *Attribute) GetType() Value_Type

+ func (m *Attribute) Marshal() (data []byte, err error)

+ func (m *Attribute) MarshalTo(data []byte) (int, error)

+ func (m *Attribute) Reset()

+ func (m *Attribute) Size() (n int)

+ func (m *Attribute) Unmarshal(data []byte) error

+ func (mj *Attribute) MarshalJSON() ([]byte, error)

+ func (mj *Attribute) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Attribute) Equal(that interface{}) bool

+ func (this *Attribute) GoString() string

+ func (this *Attribute) String() string

+ func (this *Attribute) VerboseEqual(that interface{}) error

+ func (uj *Attribute) UnmarshalJSON(input []byte) error

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

+ type CapabilityInfo struct

+ Capabilities []CapabilityInfo_Capability

+ func NewPopulatedCapabilityInfo(r randyMesos, easy bool) *CapabilityInfo

+ func (*CapabilityInfo) ProtoMessage()

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

+ func (m *CapabilityInfo) Marshal() (data []byte, err error)

+ func (m *CapabilityInfo) MarshalTo(data []byte) (int, error)

+ func (m *CapabilityInfo) Reset()

+ func (m *CapabilityInfo) Size() (n int)

+ func (m *CapabilityInfo) Unmarshal(data []byte) error

+ func (mj *CapabilityInfo) MarshalJSON() ([]byte, error)

+ func (mj *CapabilityInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *CapabilityInfo) Equal(that interface{}) bool

+ func (this *CapabilityInfo) GoString() string

+ func (this *CapabilityInfo) String() string

+ func (this *CapabilityInfo) VerboseEqual(that interface{}) error

+ func (uj *CapabilityInfo) UnmarshalJSON(input []byte) error

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

+ type CapabilityInfo_Capability int32

+ const CapabilityInfo_AUDIT_CONTROL

+ const CapabilityInfo_AUDIT_READ

+ const CapabilityInfo_AUDIT_WRITE

+ const CapabilityInfo_BLOCK_SUSPEND

+ const CapabilityInfo_CHOWN

+ const CapabilityInfo_DAC_OVERRIDE

+ const CapabilityInfo_DAC_READ_SEARCH

+ const CapabilityInfo_FOWNER

+ const CapabilityInfo_FSETID

+ const CapabilityInfo_IPC_LOCK

+ const CapabilityInfo_IPC_OWNER

+ const CapabilityInfo_KILL

+ const CapabilityInfo_LEASE

+ const CapabilityInfo_LINUX_IMMUTABLE

+ const CapabilityInfo_MAC_ADMIN

+ const CapabilityInfo_MAC_OVERRIDE

+ const CapabilityInfo_MKNOD

+ const CapabilityInfo_NET_ADMIN

+ const CapabilityInfo_NET_BIND_SERVICE

+ const CapabilityInfo_NET_BROADCAST

+ const CapabilityInfo_NET_RAW

+ const CapabilityInfo_SETFCAP

+ const CapabilityInfo_SETGID

+ const CapabilityInfo_SETPCAP

+ const CapabilityInfo_SETUID

+ const CapabilityInfo_SYSLOG

+ const CapabilityInfo_SYS_ADMIN

+ const CapabilityInfo_SYS_BOOT

+ const CapabilityInfo_SYS_CHROOT

+ const CapabilityInfo_SYS_MODULE

+ const CapabilityInfo_SYS_NICE

+ const CapabilityInfo_SYS_PACCT

+ const CapabilityInfo_SYS_PTRACE

+ const CapabilityInfo_SYS_RAWIO

+ const CapabilityInfo_SYS_RESOURCE

+ const CapabilityInfo_SYS_TIME

+ const CapabilityInfo_SYS_TTY_CONFIG

+ const CapabilityInfo_UNKNOWN

+ const CapabilityInfo_WAKE_ALARM

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

+ func (x CapabilityInfo_Capability) Enum() *CapabilityInfo_Capability

+ func (x CapabilityInfo_Capability) MarshalJSON() ([]byte, error)

+ func (x CapabilityInfo_Capability) String() string

+ type CgroupInfo struct

+ NetCLS *CgroupInfo_NetCls

+ func NewPopulatedCgroupInfo(r randyMesos, easy bool) *CgroupInfo

+ func (*CgroupInfo) ProtoMessage()

+ func (m *CgroupInfo) GetNetCLS() *CgroupInfo_NetCls

+ func (m *CgroupInfo) Marshal() (data []byte, err error)

+ func (m *CgroupInfo) MarshalTo(data []byte) (int, error)

+ func (m *CgroupInfo) Reset()

+ func (m *CgroupInfo) Size() (n int)

+ func (m *CgroupInfo) Unmarshal(data []byte) error

+ func (mj *CgroupInfo) MarshalJSON() ([]byte, error)

+ func (mj *CgroupInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *CgroupInfo) Equal(that interface{}) bool

+ func (this *CgroupInfo) GoString() string

+ func (this *CgroupInfo) String() string

+ func (this *CgroupInfo) VerboseEqual(that interface{}) error

+ func (uj *CgroupInfo) UnmarshalJSON(input []byte) error

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

+ type CgroupInfo_NetCls struct

+ ClassID *uint32

+ func NewPopulatedCgroupInfo_NetCls(r randyMesos, easy bool) *CgroupInfo_NetCls

+ func (*CgroupInfo_NetCls) ProtoMessage()

+ func (m *CgroupInfo_NetCls) GetClassID() uint32

+ func (m *CgroupInfo_NetCls) Marshal() (data []byte, err error)

+ func (m *CgroupInfo_NetCls) MarshalTo(data []byte) (int, error)

+ func (m *CgroupInfo_NetCls) Reset()

+ func (m *CgroupInfo_NetCls) Size() (n int)

+ func (m *CgroupInfo_NetCls) Unmarshal(data []byte) error

+ func (mj *CgroupInfo_NetCls) MarshalJSON() ([]byte, error)

+ func (mj *CgroupInfo_NetCls) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *CgroupInfo_NetCls) Equal(that interface{}) bool

+ func (this *CgroupInfo_NetCls) GoString() string

+ func (this *CgroupInfo_NetCls) String() string

+ func (this *CgroupInfo_NetCls) VerboseEqual(that interface{}) error

+ func (uj *CgroupInfo_NetCls) UnmarshalJSON(input []byte) error

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

+ type Client interface

+ Do func(encoding.Marshaler) (Response, error)

+ type ClientFunc func(encoding.Marshaler) (Response, error)

+ func (cf ClientFunc) Do(m encoding.Marshaler) (Response, error)

+ type CloseFunc func() error

+ func (f CloseFunc) Close() error

+ type CommandInfo struct

+ Arguments []string

+ Environment *Environment

+ Shell *bool

+ URIs []CommandInfo_URI

+ User *string

+ Value *string

+ func NewPopulatedCommandInfo(r randyMesos, easy bool) *CommandInfo

+ func (*CommandInfo) ProtoMessage()

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

+ func (m *CommandInfo) GetEnvironment() *Environment

+ func (m *CommandInfo) GetShell() bool

+ func (m *CommandInfo) GetURIs() []CommandInfo_URI

+ func (m *CommandInfo) GetUser() string

+ func (m *CommandInfo) GetValue() string

+ func (m *CommandInfo) Marshal() (data []byte, err error)

+ func (m *CommandInfo) MarshalTo(data []byte) (int, error)

+ func (m *CommandInfo) Reset()

+ func (m *CommandInfo) Size() (n int)

+ func (m *CommandInfo) Unmarshal(data []byte) error

+ func (mj *CommandInfo) MarshalJSON() ([]byte, error)

+ func (mj *CommandInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *CommandInfo) Equal(that interface{}) bool

+ func (this *CommandInfo) GoString() string

+ func (this *CommandInfo) String() string

+ func (this *CommandInfo) VerboseEqual(that interface{}) error

+ func (uj *CommandInfo) UnmarshalJSON(input []byte) error

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

+ type CommandInfo_URI struct

+ Cache *bool

+ Executable *bool

+ Extract *bool

+ OutputFile *string

+ Value string

+ func NewPopulatedCommandInfo_URI(r randyMesos, easy bool) *CommandInfo_URI

+ func (*CommandInfo_URI) ProtoMessage()

+ func (m *CommandInfo_URI) GetCache() bool

+ func (m *CommandInfo_URI) GetExecutable() bool

+ func (m *CommandInfo_URI) GetExtract() bool

+ func (m *CommandInfo_URI) GetOutputFile() string

+ func (m *CommandInfo_URI) GetValue() string

+ func (m *CommandInfo_URI) Marshal() (data []byte, err error)

+ func (m *CommandInfo_URI) MarshalTo(data []byte) (int, error)

+ func (m *CommandInfo_URI) Reset()

+ func (m *CommandInfo_URI) Size() (n int)

+ func (m *CommandInfo_URI) Unmarshal(data []byte) error

+ func (mj *CommandInfo_URI) MarshalJSON() ([]byte, error)

+ func (mj *CommandInfo_URI) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *CommandInfo_URI) Equal(that interface{}) bool

+ func (this *CommandInfo_URI) GoString() string

+ func (this *CommandInfo_URI) String() string

+ func (this *CommandInfo_URI) VerboseEqual(that interface{}) error

+ func (uj *CommandInfo_URI) UnmarshalJSON(input []byte) error

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

+ type ContainerID struct

+ Parent *ContainerID

+ Value string

+ func NewPopulatedContainerID(r randyMesos, easy bool) *ContainerID

+ func (*ContainerID) ProtoMessage()

+ func (m *ContainerID) GetParent() *ContainerID

+ func (m *ContainerID) GetValue() string

+ func (m *ContainerID) Marshal() (data []byte, err error)

+ func (m *ContainerID) MarshalTo(data []byte) (int, error)

+ func (m *ContainerID) Reset()

+ func (m *ContainerID) Size() (n int)

+ func (m *ContainerID) Unmarshal(data []byte) error

+ func (mj *ContainerID) MarshalJSON() ([]byte, error)

+ func (mj *ContainerID) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *ContainerID) Equal(that interface{}) bool

+ func (this *ContainerID) GoString() string

+ func (this *ContainerID) String() string

+ func (this *ContainerID) VerboseEqual(that interface{}) error

+ func (uj *ContainerID) UnmarshalJSON(input []byte) error

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

+ type ContainerInfo struct

+ Docker *ContainerInfo_DockerInfo

+ Hostname *string

+ LinuxInfo *LinuxInfo

+ Mesos *ContainerInfo_MesosInfo

+ NetworkInfos []NetworkInfo

+ Type *ContainerInfo_Type

+ Volumes []Volume

+ func NewPopulatedContainerInfo(r randyMesos, easy bool) *ContainerInfo

+ func (*ContainerInfo) ProtoMessage()

+ func (m *ContainerInfo) GetDocker() *ContainerInfo_DockerInfo

+ func (m *ContainerInfo) GetHostname() string

+ func (m *ContainerInfo) GetLinuxInfo() *LinuxInfo

+ func (m *ContainerInfo) GetMesos() *ContainerInfo_MesosInfo

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

+ func (m *ContainerInfo) GetType() ContainerInfo_Type

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

+ func (m *ContainerInfo) Marshal() (data []byte, err error)

+ func (m *ContainerInfo) MarshalTo(data []byte) (int, error)

+ func (m *ContainerInfo) Reset()

+ func (m *ContainerInfo) Size() (n int)

+ func (m *ContainerInfo) Unmarshal(data []byte) error

+ func (mj *ContainerInfo) MarshalJSON() ([]byte, error)

+ func (mj *ContainerInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *ContainerInfo) Equal(that interface{}) bool

+ func (this *ContainerInfo) GoString() string

+ func (this *ContainerInfo) String() string

+ func (this *ContainerInfo) VerboseEqual(that interface{}) error

+ func (uj *ContainerInfo) UnmarshalJSON(input []byte) error

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

+ type ContainerInfo_DockerInfo struct

+ ForcePullImage *bool

+ Image string

+ Network *ContainerInfo_DockerInfo_Network

+ Parameters []Parameter

+ PortMappings []ContainerInfo_DockerInfo_PortMapping

+ Privileged *bool

+ VolumeDriver *string

+ func NewPopulatedContainerInfo_DockerInfo(r randyMesos, easy bool) *ContainerInfo_DockerInfo

+ func (*ContainerInfo_DockerInfo) ProtoMessage()

+ func (m *ContainerInfo_DockerInfo) GetForcePullImage() bool

+ func (m *ContainerInfo_DockerInfo) GetImage() string

+ func (m *ContainerInfo_DockerInfo) GetNetwork() ContainerInfo_DockerInfo_Network

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

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

+ func (m *ContainerInfo_DockerInfo) GetPrivileged() bool

+ func (m *ContainerInfo_DockerInfo) GetVolumeDriver() string

+ func (m *ContainerInfo_DockerInfo) Marshal() (data []byte, err error)

+ func (m *ContainerInfo_DockerInfo) MarshalTo(data []byte) (int, error)

+ func (m *ContainerInfo_DockerInfo) Reset()

+ func (m *ContainerInfo_DockerInfo) Size() (n int)

+ func (m *ContainerInfo_DockerInfo) Unmarshal(data []byte) error

+ func (mj *ContainerInfo_DockerInfo) MarshalJSON() ([]byte, error)

+ func (mj *ContainerInfo_DockerInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *ContainerInfo_DockerInfo) Equal(that interface{}) bool

+ func (this *ContainerInfo_DockerInfo) GoString() string

+ func (this *ContainerInfo_DockerInfo) String() string

+ func (this *ContainerInfo_DockerInfo) VerboseEqual(that interface{}) error

+ func (uj *ContainerInfo_DockerInfo) UnmarshalJSON(input []byte) error

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

+ type ContainerInfo_DockerInfo_Network int32

+ const ContainerInfo_DockerInfo_BRIDGE

+ const ContainerInfo_DockerInfo_HOST

+ const ContainerInfo_DockerInfo_NONE

+ const ContainerInfo_DockerInfo_USER

+ const Default_ContainerInfo_DockerInfo_Network

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

+ func (x ContainerInfo_DockerInfo_Network) Enum() *ContainerInfo_DockerInfo_Network

+ func (x ContainerInfo_DockerInfo_Network) MarshalJSON() ([]byte, error)

+ func (x ContainerInfo_DockerInfo_Network) String() string

+ type ContainerInfo_DockerInfo_PortMapping struct

+ ContainerPort uint32

+ HostPort uint32

+ Protocol *string

+ func NewPopulatedContainerInfo_DockerInfo_PortMapping(r randyMesos, easy bool) *ContainerInfo_DockerInfo_PortMapping

+ func (*ContainerInfo_DockerInfo_PortMapping) ProtoMessage()

+ func (m *ContainerInfo_DockerInfo_PortMapping) GetContainerPort() uint32

+ func (m *ContainerInfo_DockerInfo_PortMapping) GetHostPort() uint32

+ func (m *ContainerInfo_DockerInfo_PortMapping) GetProtocol() string

+ func (m *ContainerInfo_DockerInfo_PortMapping) Marshal() (data []byte, err error)

+ func (m *ContainerInfo_DockerInfo_PortMapping) MarshalTo(data []byte) (int, error)

+ func (m *ContainerInfo_DockerInfo_PortMapping) Reset()

+ func (m *ContainerInfo_DockerInfo_PortMapping) Size() (n int)

+ func (m *ContainerInfo_DockerInfo_PortMapping) Unmarshal(data []byte) error

+ func (mj *ContainerInfo_DockerInfo_PortMapping) MarshalJSON() ([]byte, error)

+ func (mj *ContainerInfo_DockerInfo_PortMapping) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *ContainerInfo_DockerInfo_PortMapping) Equal(that interface{}) bool

+ func (this *ContainerInfo_DockerInfo_PortMapping) GoString() string

+ func (this *ContainerInfo_DockerInfo_PortMapping) String() string

+ func (this *ContainerInfo_DockerInfo_PortMapping) VerboseEqual(that interface{}) error

+ func (uj *ContainerInfo_DockerInfo_PortMapping) UnmarshalJSON(input []byte) error

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

+ type ContainerInfo_MesosInfo struct

+ Image *Image

+ func NewPopulatedContainerInfo_MesosInfo(r randyMesos, easy bool) *ContainerInfo_MesosInfo

+ func (*ContainerInfo_MesosInfo) ProtoMessage()

+ func (m *ContainerInfo_MesosInfo) GetImage() *Image

+ func (m *ContainerInfo_MesosInfo) Marshal() (data []byte, err error)

+ func (m *ContainerInfo_MesosInfo) MarshalTo(data []byte) (int, error)

+ func (m *ContainerInfo_MesosInfo) Reset()

+ func (m *ContainerInfo_MesosInfo) Size() (n int)

+ func (m *ContainerInfo_MesosInfo) Unmarshal(data []byte) error

+ func (mj *ContainerInfo_MesosInfo) MarshalJSON() ([]byte, error)

+ func (mj *ContainerInfo_MesosInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *ContainerInfo_MesosInfo) Equal(that interface{}) bool

+ func (this *ContainerInfo_MesosInfo) GoString() string

+ func (this *ContainerInfo_MesosInfo) String() string

+ func (this *ContainerInfo_MesosInfo) VerboseEqual(that interface{}) error

+ func (uj *ContainerInfo_MesosInfo) UnmarshalJSON(input []byte) error

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

+ type ContainerInfo_Type int32

+ const ContainerInfo_DOCKER

+ const ContainerInfo_MESOS

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

+ func (x ContainerInfo_Type) Enum() *ContainerInfo_Type

+ func (x ContainerInfo_Type) MarshalJSON() ([]byte, error)

+ func (x ContainerInfo_Type) String() string

+ type ContainerStatus struct

+ CgroupInfo *CgroupInfo

+ ExecutorPID *uint32

+ NetworkInfos []NetworkInfo

+ func NewPopulatedContainerStatus(r randyMesos, easy bool) *ContainerStatus

+ func (*ContainerStatus) ProtoMessage()

+ func (m *ContainerStatus) GetCgroupInfo() *CgroupInfo

+ func (m *ContainerStatus) GetExecutorPID() uint32

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

+ func (m *ContainerStatus) Marshal() (data []byte, err error)

+ func (m *ContainerStatus) MarshalTo(data []byte) (int, error)

+ func (m *ContainerStatus) Reset()

+ func (m *ContainerStatus) Size() (n int)

+ func (m *ContainerStatus) Unmarshal(data []byte) error

+ func (mj *ContainerStatus) MarshalJSON() ([]byte, error)

+ func (mj *ContainerStatus) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *ContainerStatus) Equal(that interface{}) bool

+ func (this *ContainerStatus) GoString() string

+ func (this *ContainerStatus) String() string

+ func (this *ContainerStatus) VerboseEqual(that interface{}) error

+ func (uj *ContainerStatus) UnmarshalJSON(input []byte) error

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

+ type Credential struct

+ Principal string

+ Secret *string

+ func NewPopulatedCredential(r randyMesos, easy bool) *Credential

+ func (*Credential) ProtoMessage()

+ func (m *Credential) GetPrincipal() string

+ func (m *Credential) GetSecret() string

+ func (m *Credential) Marshal() (data []byte, err error)

+ func (m *Credential) MarshalTo(data []byte) (int, error)

+ func (m *Credential) Reset()

+ func (m *Credential) Size() (n int)

+ func (m *Credential) Unmarshal(data []byte) error

+ func (mj *Credential) MarshalJSON() ([]byte, error)

+ func (mj *Credential) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Credential) Equal(that interface{}) bool

+ func (this *Credential) GoString() string

+ func (this *Credential) String() string

+ func (this *Credential) VerboseEqual(that interface{}) error

+ func (uj *Credential) UnmarshalJSON(input []byte) error

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

+ type Credentials struct

+ Credentials []Credential

+ func NewPopulatedCredentials(r randyMesos, easy bool) *Credentials

+ func (*Credentials) ProtoMessage()

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

+ func (m *Credentials) Marshal() (data []byte, err error)

+ func (m *Credentials) MarshalTo(data []byte) (int, error)

+ func (m *Credentials) Reset()

+ func (m *Credentials) Size() (n int)

+ func (m *Credentials) Unmarshal(data []byte) error

+ func (mj *Credentials) MarshalJSON() ([]byte, error)

+ func (mj *Credentials) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Credentials) Equal(that interface{}) bool

+ func (this *Credentials) GoString() string

+ func (this *Credentials) String() string

+ func (this *Credentials) VerboseEqual(that interface{}) error

+ func (uj *Credentials) UnmarshalJSON(input []byte) error

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

+ type DiscoveryInfo struct

+ Environment *string

+ Labels *Labels

+ Location *string

+ Name *string

+ Ports *Ports

+ Version *string

+ Visibility DiscoveryInfo_Visibility

+ func NewPopulatedDiscoveryInfo(r randyMesos, easy bool) *DiscoveryInfo

+ func (*DiscoveryInfo) ProtoMessage()

+ func (m *DiscoveryInfo) GetEnvironment() string

+ func (m *DiscoveryInfo) GetLabels() *Labels

+ func (m *DiscoveryInfo) GetLocation() string

+ func (m *DiscoveryInfo) GetName() string

+ func (m *DiscoveryInfo) GetPorts() *Ports

+ func (m *DiscoveryInfo) GetVersion() string

+ func (m *DiscoveryInfo) GetVisibility() DiscoveryInfo_Visibility

+ func (m *DiscoveryInfo) Marshal() (data []byte, err error)

+ func (m *DiscoveryInfo) MarshalTo(data []byte) (int, error)

+ func (m *DiscoveryInfo) Reset()

+ func (m *DiscoveryInfo) Size() (n int)

+ func (m *DiscoveryInfo) Unmarshal(data []byte) error

+ func (mj *DiscoveryInfo) MarshalJSON() ([]byte, error)

+ func (mj *DiscoveryInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *DiscoveryInfo) Equal(that interface{}) bool

+ func (this *DiscoveryInfo) GoString() string

+ func (this *DiscoveryInfo) String() string

+ func (this *DiscoveryInfo) VerboseEqual(that interface{}) error

+ func (uj *DiscoveryInfo) UnmarshalJSON(input []byte) error

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

+ type DiscoveryInfo_Visibility int32

+ const CLUSTER

+ const EXTERNAL

+ const FRAMEWORK

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

+ func (x DiscoveryInfo_Visibility) Enum() *DiscoveryInfo_Visibility

+ func (x DiscoveryInfo_Visibility) MarshalJSON() ([]byte, error)

+ func (x DiscoveryInfo_Visibility) String() string

+ type DurationInfo struct

+ Nanoseconds int64

+ func NewPopulatedDurationInfo(r randyMesos, easy bool) *DurationInfo

+ func (*DurationInfo) ProtoMessage()

+ func (m *DurationInfo) GetNanoseconds() int64

+ func (m *DurationInfo) Marshal() (data []byte, err error)

+ func (m *DurationInfo) MarshalTo(data []byte) (int, error)

+ func (m *DurationInfo) Reset()

+ func (m *DurationInfo) Size() (n int)

+ func (m *DurationInfo) Unmarshal(data []byte) error

+ func (mj *DurationInfo) MarshalJSON() ([]byte, error)

+ func (mj *DurationInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *DurationInfo) Equal(that interface{}) bool

+ func (this *DurationInfo) GoString() string

+ func (this *DurationInfo) String() string

+ func (this *DurationInfo) VerboseEqual(that interface{}) error

+ func (uj *DurationInfo) UnmarshalJSON(input []byte) error

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

+ type Environment struct

+ Variables []Environment_Variable

+ func NewPopulatedEnvironment(r randyMesos, easy bool) *Environment

+ func (*Environment) ProtoMessage()

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

+ func (m *Environment) Marshal() (data []byte, err error)

+ func (m *Environment) MarshalTo(data []byte) (int, error)

+ func (m *Environment) Reset()

+ func (m *Environment) Size() (n int)

+ func (m *Environment) Unmarshal(data []byte) error

+ func (mj *Environment) MarshalJSON() ([]byte, error)

+ func (mj *Environment) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Environment) Equal(that interface{}) bool

+ func (this *Environment) GoString() string

+ func (this *Environment) String() string

+ func (this *Environment) VerboseEqual(that interface{}) error

+ func (uj *Environment) UnmarshalJSON(input []byte) error

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

+ type Environment_Variable struct

+ Name string

+ Value string

+ func NewPopulatedEnvironment_Variable(r randyMesos, easy bool) *Environment_Variable

+ func (*Environment_Variable) ProtoMessage()

+ func (m *Environment_Variable) GetName() string

+ func (m *Environment_Variable) GetValue() string

+ func (m *Environment_Variable) Marshal() (data []byte, err error)

+ func (m *Environment_Variable) MarshalTo(data []byte) (int, error)

+ func (m *Environment_Variable) Reset()

+ func (m *Environment_Variable) Size() (n int)

+ func (m *Environment_Variable) Unmarshal(data []byte) error

+ func (mj *Environment_Variable) MarshalJSON() ([]byte, error)

+ func (mj *Environment_Variable) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Environment_Variable) Equal(that interface{}) bool

+ func (this *Environment_Variable) GoString() string

+ func (this *Environment_Variable) String() string

+ func (this *Environment_Variable) VerboseEqual(that interface{}) error

+ func (uj *Environment_Variable) UnmarshalJSON(input []byte) error

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

+ type ExecutorID struct

+ Value string

+ func NewPopulatedExecutorID(r randyMesos, easy bool) *ExecutorID

+ func (*ExecutorID) ProtoMessage()

+ func (m *ExecutorID) GetValue() string

+ func (m *ExecutorID) Marshal() (data []byte, err error)

+ func (m *ExecutorID) MarshalTo(data []byte) (int, error)

+ func (m *ExecutorID) Reset()

+ func (m *ExecutorID) Size() (n int)

+ func (m *ExecutorID) Unmarshal(data []byte) error

+ func (mj *ExecutorID) MarshalJSON() ([]byte, error)

+ func (mj *ExecutorID) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *ExecutorID) Equal(that interface{}) bool

+ func (this *ExecutorID) GoString() string

+ func (this *ExecutorID) String() string

+ func (this *ExecutorID) VerboseEqual(that interface{}) error

+ func (uj *ExecutorID) UnmarshalJSON(input []byte) error

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

+ type ExecutorInfo struct

+ Command CommandInfo

+ Container *ContainerInfo

+ Data []byte

+ Discovery *DiscoveryInfo

+ ExecutorID ExecutorID

+ FrameworkID *FrameworkID

+ Labels *Labels

+ Name *string

+ Resources []Resource

+ ShutdownGracePeriod *DurationInfo

+ Source *string

+ Type *ExecutorInfo_Type

+ func NewPopulatedExecutorInfo(r randyMesos, easy bool) *ExecutorInfo

+ func (*ExecutorInfo) ProtoMessage()

+ func (m *ExecutorInfo) GetCommand() CommandInfo

+ func (m *ExecutorInfo) GetContainer() *ContainerInfo

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

+ func (m *ExecutorInfo) GetDiscovery() *DiscoveryInfo

+ func (m *ExecutorInfo) GetExecutorID() ExecutorID

+ func (m *ExecutorInfo) GetFrameworkID() *FrameworkID

+ func (m *ExecutorInfo) GetLabels() *Labels

+ func (m *ExecutorInfo) GetName() string

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

+ func (m *ExecutorInfo) GetShutdownGracePeriod() *DurationInfo

+ func (m *ExecutorInfo) GetSource() string

+ func (m *ExecutorInfo) GetType() ExecutorInfo_Type

+ func (m *ExecutorInfo) Marshal() (data []byte, err error)

+ func (m *ExecutorInfo) MarshalTo(data []byte) (int, error)

+ func (m *ExecutorInfo) Reset()

+ func (m *ExecutorInfo) Size() (n int)

+ func (m *ExecutorInfo) Unmarshal(data []byte) error

+ func (mj *ExecutorInfo) MarshalJSON() ([]byte, error)

+ func (mj *ExecutorInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *ExecutorInfo) Equal(that interface{}) bool

+ func (this *ExecutorInfo) GoString() string

+ func (this *ExecutorInfo) String() string

+ func (this *ExecutorInfo) VerboseEqual(that interface{}) error

+ func (uj *ExecutorInfo) UnmarshalJSON(input []byte) error

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

+ type ExecutorInfo_Type int32

+ const ExecutorInfo_CUSTOM

+ const ExecutorInfo_DEFAULT

+ const ExecutorInfo_UNKNOWN

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

+ func (x ExecutorInfo_Type) Enum() *ExecutorInfo_Type

+ func (x ExecutorInfo_Type) MarshalJSON() ([]byte, error)

+ func (x ExecutorInfo_Type) String() string

+ type FileInfo struct

+ GID *string

+ Mode *uint32

+ Mtime *TimeInfo

+ Nlink *int32

+ Path string

+ Size_ *uint64

+ UID *string

+ func NewPopulatedFileInfo(r randyMesos, easy bool) *FileInfo

+ func (*FileInfo) ProtoMessage()

+ func (m *FileInfo) GetGID() string

+ func (m *FileInfo) GetMode() uint32

+ func (m *FileInfo) GetMtime() *TimeInfo

+ func (m *FileInfo) GetNlink() int32

+ func (m *FileInfo) GetPath() string

+ func (m *FileInfo) GetSize_() uint64

+ func (m *FileInfo) GetUID() string

+ func (m *FileInfo) Marshal() (data []byte, err error)

+ func (m *FileInfo) MarshalTo(data []byte) (int, error)

+ func (m *FileInfo) Reset()

+ func (m *FileInfo) Size() (n int)

+ func (m *FileInfo) Unmarshal(data []byte) error

+ func (mj *FileInfo) MarshalJSON() ([]byte, error)

+ func (mj *FileInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *FileInfo) Equal(that interface{}) bool

+ func (this *FileInfo) GoString() string

+ func (this *FileInfo) String() string

+ func (this *FileInfo) VerboseEqual(that interface{}) error

+ func (uj *FileInfo) UnmarshalJSON(input []byte) error

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

+ type FilterOpt func(*Filters)

+ func RefuseSeconds(d time.Duration) FilterOpt

+ type Filters struct

+ RefuseSeconds *float64

+ func NewPopulatedFilters(r randyMesos, easy bool) *Filters

+ func OptionalFilters(fo ...FilterOpt) *Filters

+ func (*Filters) ProtoMessage()

+ func (f *Filters) With(opts ...FilterOpt) *Filters

+ func (m *Filters) GetRefuseSeconds() float64

+ func (m *Filters) Marshal() (data []byte, err error)

+ func (m *Filters) MarshalTo(data []byte) (int, error)

+ func (m *Filters) Reset()

+ func (m *Filters) Size() (n int)

+ func (m *Filters) Unmarshal(data []byte) error

+ func (mj *Filters) MarshalJSON() ([]byte, error)

+ func (mj *Filters) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Filters) Equal(that interface{}) bool

+ func (this *Filters) GoString() string

+ func (this *Filters) String() string

+ func (this *Filters) VerboseEqual(that interface{}) error

+ func (uj *Filters) UnmarshalJSON(input []byte) error

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

+ type Flag struct

+ Name string

+ Value *string

+ func NewPopulatedFlag(r randyMesos, easy bool) *Flag

+ func (*Flag) ProtoMessage()

+ func (m *Flag) GetName() string

+ func (m *Flag) GetValue() string

+ func (m *Flag) Marshal() (data []byte, err error)

+ func (m *Flag) MarshalTo(data []byte) (int, error)

+ func (m *Flag) Reset()

+ func (m *Flag) Size() (n int)

+ func (m *Flag) Unmarshal(data []byte) error

+ func (mj *Flag) MarshalJSON() ([]byte, error)

+ func (mj *Flag) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Flag) Equal(that interface{}) bool

+ func (this *Flag) GoString() string

+ func (this *Flag) String() string

+ func (this *Flag) VerboseEqual(that interface{}) error

+ func (uj *Flag) UnmarshalJSON(input []byte) error

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

+ type FlattenConfig struct

+ Reservation *Resource_ReservationInfo

+ Role string

+ type FlattenOpt func(*FlattenConfig)

+ type FrameworkID struct

+ Value string

+ func NewPopulatedFrameworkID(r randyMesos, easy bool) *FrameworkID

+ func (*FrameworkID) ProtoMessage()

+ func (m *FrameworkID) GetValue() string

+ func (m *FrameworkID) Marshal() (data []byte, err error)

+ func (m *FrameworkID) MarshalTo(data []byte) (int, error)

+ func (m *FrameworkID) Reset()

+ func (m *FrameworkID) Size() (n int)

+ func (m *FrameworkID) Unmarshal(data []byte) error

+ func (mj *FrameworkID) MarshalJSON() ([]byte, error)

+ func (mj *FrameworkID) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *FrameworkID) Equal(that interface{}) bool

+ func (this *FrameworkID) GoString() string

+ func (this *FrameworkID) String() string

+ func (this *FrameworkID) VerboseEqual(that interface{}) error

+ func (uj *FrameworkID) UnmarshalJSON(input []byte) error

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

+ type FrameworkInfo struct

+ Capabilities []FrameworkInfo_Capability

+ Checkpoint *bool

+ FailoverTimeout *float64

+ Hostname *string

+ ID *FrameworkID

+ Labels *Labels

+ Name string

+ Principal *string

+ Role *string

+ User string

+ WebUiURL *string

+ func NewPopulatedFrameworkInfo(r randyMesos, easy bool) *FrameworkInfo

+ func (*FrameworkInfo) ProtoMessage()

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

+ func (m *FrameworkInfo) GetCheckpoint() bool

+ func (m *FrameworkInfo) GetFailoverTimeout() float64

+ func (m *FrameworkInfo) GetHostname() string

+ func (m *FrameworkInfo) GetID() *FrameworkID

+ func (m *FrameworkInfo) GetLabels() *Labels

+ func (m *FrameworkInfo) GetName() string

+ func (m *FrameworkInfo) GetPrincipal() string

+ func (m *FrameworkInfo) GetRole() string

+ func (m *FrameworkInfo) GetUser() string

+ func (m *FrameworkInfo) GetWebUiURL() string

+ func (m *FrameworkInfo) Marshal() (data []byte, err error)

+ func (m *FrameworkInfo) MarshalTo(data []byte) (int, error)

+ func (m *FrameworkInfo) Reset()

+ func (m *FrameworkInfo) Size() (n int)

+ func (m *FrameworkInfo) Unmarshal(data []byte) error

+ func (mj *FrameworkInfo) MarshalJSON() ([]byte, error)

+ func (mj *FrameworkInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *FrameworkInfo) Equal(that interface{}) bool

+ func (this *FrameworkInfo) GoString() string

+ func (this *FrameworkInfo) String() string

+ func (this *FrameworkInfo) VerboseEqual(that interface{}) error

+ func (uj *FrameworkInfo) UnmarshalJSON(input []byte) error

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

+ type FrameworkInfo_Capability struct

+ Type FrameworkInfo_Capability_Type

+ func NewPopulatedFrameworkInfo_Capability(r randyMesos, easy bool) *FrameworkInfo_Capability

+ func (*FrameworkInfo_Capability) ProtoMessage()

+ func (m *FrameworkInfo_Capability) GetType() FrameworkInfo_Capability_Type

+ func (m *FrameworkInfo_Capability) Marshal() (data []byte, err error)

+ func (m *FrameworkInfo_Capability) MarshalTo(data []byte) (int, error)

+ func (m *FrameworkInfo_Capability) Reset()

+ func (m *FrameworkInfo_Capability) Size() (n int)

+ func (m *FrameworkInfo_Capability) Unmarshal(data []byte) error

+ func (mj *FrameworkInfo_Capability) MarshalJSON() ([]byte, error)

+ func (mj *FrameworkInfo_Capability) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *FrameworkInfo_Capability) Equal(that interface{}) bool

+ func (this *FrameworkInfo_Capability) GoString() string

+ func (this *FrameworkInfo_Capability) String() string

+ func (this *FrameworkInfo_Capability) VerboseEqual(that interface{}) error

+ func (uj *FrameworkInfo_Capability) UnmarshalJSON(input []byte) error

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

+ type FrameworkInfo_Capability_Type int32

+ const FrameworkInfo_Capability_GPU_RESOURCES

+ const FrameworkInfo_Capability_PARTITION_AWARE

+ const FrameworkInfo_Capability_REVOCABLE_RESOURCES

+ const FrameworkInfo_Capability_SHARED_RESOURCES

+ const FrameworkInfo_Capability_TASK_KILLING_STATE

+ const FrameworkInfo_Capability_UNKNOWN

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

+ func (x FrameworkInfo_Capability_Type) Enum() *FrameworkInfo_Capability_Type

+ func (x FrameworkInfo_Capability_Type) MarshalJSON() ([]byte, error)

+ func (x FrameworkInfo_Capability_Type) String() string

+ type HealthCheck struct

+ Command *CommandInfo

+ ConsecutiveFailures *uint32

+ DelaySeconds *float64

+ GracePeriodSeconds *float64

+ HTTP *HealthCheck_HTTPCheckInfo

+ IntervalSeconds *float64

+ TCP *HealthCheck_TCPCheckInfo

+ TimeoutSeconds *float64

+ Type *HealthCheck_Type

+ func NewPopulatedHealthCheck(r randyMesos, easy bool) *HealthCheck

+ func (*HealthCheck) ProtoMessage()

+ func (m *HealthCheck) GetCommand() *CommandInfo

+ func (m *HealthCheck) GetConsecutiveFailures() uint32

+ func (m *HealthCheck) GetDelaySeconds() float64

+ func (m *HealthCheck) GetGracePeriodSeconds() float64

+ func (m *HealthCheck) GetHTTP() *HealthCheck_HTTPCheckInfo

+ func (m *HealthCheck) GetIntervalSeconds() float64

+ func (m *HealthCheck) GetTCP() *HealthCheck_TCPCheckInfo

+ func (m *HealthCheck) GetTimeoutSeconds() float64

+ func (m *HealthCheck) GetType() HealthCheck_Type

+ func (m *HealthCheck) Marshal() (data []byte, err error)

+ func (m *HealthCheck) MarshalTo(data []byte) (int, error)

+ func (m *HealthCheck) Reset()

+ func (m *HealthCheck) Size() (n int)

+ func (m *HealthCheck) Unmarshal(data []byte) error

+ func (mj *HealthCheck) MarshalJSON() ([]byte, error)

+ func (mj *HealthCheck) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *HealthCheck) Equal(that interface{}) bool

+ func (this *HealthCheck) GoString() string

+ func (this *HealthCheck) String() string

+ func (this *HealthCheck) VerboseEqual(that interface{}) error

+ func (uj *HealthCheck) UnmarshalJSON(input []byte) error

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

+ type HealthCheck_HTTPCheckInfo struct

+ Path *string

+ Port uint32

+ Scheme *string

+ Statuses []uint32

+ func NewPopulatedHealthCheck_HTTPCheckInfo(r randyMesos, easy bool) *HealthCheck_HTTPCheckInfo

+ func (*HealthCheck_HTTPCheckInfo) ProtoMessage()

+ func (m *HealthCheck_HTTPCheckInfo) GetPath() string

+ func (m *HealthCheck_HTTPCheckInfo) GetPort() uint32

+ func (m *HealthCheck_HTTPCheckInfo) GetScheme() string

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

+ func (m *HealthCheck_HTTPCheckInfo) Marshal() (data []byte, err error)

+ func (m *HealthCheck_HTTPCheckInfo) MarshalTo(data []byte) (int, error)

+ func (m *HealthCheck_HTTPCheckInfo) Reset()

+ func (m *HealthCheck_HTTPCheckInfo) Size() (n int)

+ func (m *HealthCheck_HTTPCheckInfo) Unmarshal(data []byte) error

+ func (mj *HealthCheck_HTTPCheckInfo) MarshalJSON() ([]byte, error)

+ func (mj *HealthCheck_HTTPCheckInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *HealthCheck_HTTPCheckInfo) Equal(that interface{}) bool

+ func (this *HealthCheck_HTTPCheckInfo) GoString() string

+ func (this *HealthCheck_HTTPCheckInfo) String() string

+ func (this *HealthCheck_HTTPCheckInfo) VerboseEqual(that interface{}) error

+ func (uj *HealthCheck_HTTPCheckInfo) UnmarshalJSON(input []byte) error

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

+ type HealthCheck_TCPCheckInfo struct

+ Port uint32

+ func NewPopulatedHealthCheck_TCPCheckInfo(r randyMesos, easy bool) *HealthCheck_TCPCheckInfo

+ func (*HealthCheck_TCPCheckInfo) ProtoMessage()

+ func (m *HealthCheck_TCPCheckInfo) GetPort() uint32

+ func (m *HealthCheck_TCPCheckInfo) Marshal() (data []byte, err error)

+ func (m *HealthCheck_TCPCheckInfo) MarshalTo(data []byte) (int, error)

+ func (m *HealthCheck_TCPCheckInfo) Reset()

+ func (m *HealthCheck_TCPCheckInfo) Size() (n int)

+ func (m *HealthCheck_TCPCheckInfo) Unmarshal(data []byte) error

+ func (mj *HealthCheck_TCPCheckInfo) MarshalJSON() ([]byte, error)

+ func (mj *HealthCheck_TCPCheckInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *HealthCheck_TCPCheckInfo) Equal(that interface{}) bool

+ func (this *HealthCheck_TCPCheckInfo) GoString() string

+ func (this *HealthCheck_TCPCheckInfo) String() string

+ func (this *HealthCheck_TCPCheckInfo) VerboseEqual(that interface{}) error

+ func (uj *HealthCheck_TCPCheckInfo) UnmarshalJSON(input []byte) error

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

+ type HealthCheck_Type int32

+ const HealthCheck_COMMAND

+ const HealthCheck_HTTP

+ const HealthCheck_TCP

+ const HealthCheck_UNKNOWN

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

+ func (x HealthCheck_Type) Enum() *HealthCheck_Type

+ func (x HealthCheck_Type) MarshalJSON() ([]byte, error)

+ func (x HealthCheck_Type) String() string

+ type IcmpStatistics struct

+ InAddrMaskReps *int64

+ InAddrMasks *int64

+ InCsumErrors *int64

+ InDestUnreachs *int64

+ InEchoReps *int64

+ InEchos *int64

+ InErrors *int64

+ InMsgs *int64

+ InParmProbs *int64

+ InRedirects *int64

+ InSrcQuenchs *int64

+ InTimeExcds *int64

+ InTimestampReps *int64

+ InTimestamps *int64

+ OutAddrMaskReps *int64

+ OutAddrMasks *int64

+ OutDestUnreachs *int64

+ OutEchoReps *int64

+ OutEchos *int64

+ OutErrors *int64

+ OutMsgs *int64

+ OutParmProbs *int64

+ OutRedirects *int64

+ OutSrcQuenchs *int64

+ OutTimeExcds *int64

+ OutTimestampReps *int64

+ OutTimestamps *int64

+ func NewPopulatedIcmpStatistics(r randyMesos, easy bool) *IcmpStatistics

+ func (*IcmpStatistics) ProtoMessage()

+ func (m *IcmpStatistics) GetInAddrMaskReps() int64

+ func (m *IcmpStatistics) GetInAddrMasks() int64

+ func (m *IcmpStatistics) GetInCsumErrors() int64

+ func (m *IcmpStatistics) GetInDestUnreachs() int64

+ func (m *IcmpStatistics) GetInEchoReps() int64

+ func (m *IcmpStatistics) GetInEchos() int64

+ func (m *IcmpStatistics) GetInErrors() int64

+ func (m *IcmpStatistics) GetInMsgs() int64

+ func (m *IcmpStatistics) GetInParmProbs() int64

+ func (m *IcmpStatistics) GetInRedirects() int64

+ func (m *IcmpStatistics) GetInSrcQuenchs() int64

+ func (m *IcmpStatistics) GetInTimeExcds() int64

+ func (m *IcmpStatistics) GetInTimestampReps() int64

+ func (m *IcmpStatistics) GetInTimestamps() int64

+ func (m *IcmpStatistics) GetOutAddrMaskReps() int64

+ func (m *IcmpStatistics) GetOutAddrMasks() int64

+ func (m *IcmpStatistics) GetOutDestUnreachs() int64

+ func (m *IcmpStatistics) GetOutEchoReps() int64

+ func (m *IcmpStatistics) GetOutEchos() int64

+ func (m *IcmpStatistics) GetOutErrors() int64

+ func (m *IcmpStatistics) GetOutMsgs() int64

+ func (m *IcmpStatistics) GetOutParmProbs() int64

+ func (m *IcmpStatistics) GetOutRedirects() int64

+ func (m *IcmpStatistics) GetOutSrcQuenchs() int64

+ func (m *IcmpStatistics) GetOutTimeExcds() int64

+ func (m *IcmpStatistics) GetOutTimestampReps() int64

+ func (m *IcmpStatistics) GetOutTimestamps() int64

+ func (m *IcmpStatistics) Marshal() (data []byte, err error)

+ func (m *IcmpStatistics) MarshalTo(data []byte) (int, error)

+ func (m *IcmpStatistics) Reset()

+ func (m *IcmpStatistics) Size() (n int)

+ func (m *IcmpStatistics) Unmarshal(data []byte) error

+ func (mj *IcmpStatistics) MarshalJSON() ([]byte, error)

+ func (mj *IcmpStatistics) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *IcmpStatistics) Equal(that interface{}) bool

+ func (this *IcmpStatistics) GoString() string

+ func (this *IcmpStatistics) String() string

+ func (this *IcmpStatistics) VerboseEqual(that interface{}) error

+ func (uj *IcmpStatistics) UnmarshalJSON(input []byte) error

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

+ type Image struct

+ Appc *Image_Appc

+ Cached *bool

+ Docker *Image_Docker

+ Type *Image_Type

+ func NewPopulatedImage(r randyMesos, easy bool) *Image

+ func (*Image) ProtoMessage()

+ func (m *Image) GetAppc() *Image_Appc

+ func (m *Image) GetCached() bool

+ func (m *Image) GetDocker() *Image_Docker

+ func (m *Image) GetType() Image_Type

+ func (m *Image) Marshal() (data []byte, err error)

+ func (m *Image) MarshalTo(data []byte) (int, error)

+ func (m *Image) Reset()

+ func (m *Image) Size() (n int)

+ func (m *Image) Unmarshal(data []byte) error

+ func (mj *Image) MarshalJSON() ([]byte, error)

+ func (mj *Image) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Image) Equal(that interface{}) bool

+ func (this *Image) GoString() string

+ func (this *Image) String() string

+ func (this *Image) VerboseEqual(that interface{}) error

+ func (uj *Image) UnmarshalJSON(input []byte) error

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

+ type Image_Appc struct

+ ID *string

+ Labels *Labels

+ Name string

+ func NewPopulatedImage_Appc(r randyMesos, easy bool) *Image_Appc

+ func (*Image_Appc) ProtoMessage()

+ func (m *Image_Appc) GetID() string

+ func (m *Image_Appc) GetLabels() *Labels

+ func (m *Image_Appc) GetName() string

+ func (m *Image_Appc) Marshal() (data []byte, err error)

+ func (m *Image_Appc) MarshalTo(data []byte) (int, error)

+ func (m *Image_Appc) Reset()

+ func (m *Image_Appc) Size() (n int)

+ func (m *Image_Appc) Unmarshal(data []byte) error

+ func (mj *Image_Appc) MarshalJSON() ([]byte, error)

+ func (mj *Image_Appc) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Image_Appc) Equal(that interface{}) bool

+ func (this *Image_Appc) GoString() string

+ func (this *Image_Appc) String() string

+ func (this *Image_Appc) VerboseEqual(that interface{}) error

+ func (uj *Image_Appc) UnmarshalJSON(input []byte) error

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

+ type Image_Docker struct

+ Credential *Credential

+ Name string

+ func NewPopulatedImage_Docker(r randyMesos, easy bool) *Image_Docker

+ func (*Image_Docker) ProtoMessage()

+ func (m *Image_Docker) GetCredential() *Credential

+ func (m *Image_Docker) GetName() string

+ func (m *Image_Docker) Marshal() (data []byte, err error)

+ func (m *Image_Docker) MarshalTo(data []byte) (int, error)

+ func (m *Image_Docker) Reset()

+ func (m *Image_Docker) Size() (n int)

+ func (m *Image_Docker) Unmarshal(data []byte) error

+ func (mj *Image_Docker) MarshalJSON() ([]byte, error)

+ func (mj *Image_Docker) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Image_Docker) Equal(that interface{}) bool

+ func (this *Image_Docker) GoString() string

+ func (this *Image_Docker) String() string

+ func (this *Image_Docker) VerboseEqual(that interface{}) error

+ func (uj *Image_Docker) UnmarshalJSON(input []byte) error

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

+ type Image_Type int32

+ const Image_APPC

+ const Image_DOCKER

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

+ func (x Image_Type) Enum() *Image_Type

+ func (x Image_Type) MarshalJSON() ([]byte, error)

+ func (x Image_Type) String() string

+ type InverseOffer struct

+ AgentID *AgentID

+ FrameworkID FrameworkID

+ OfferID OfferID

+ Resources []Resource

+ URL *URL

+ Unavailability Unavailability

+ func NewPopulatedInverseOffer(r randyMesos, easy bool) *InverseOffer

+ func (*InverseOffer) ProtoMessage()

+ func (m *InverseOffer) GetAgentID() *AgentID

+ func (m *InverseOffer) GetFrameworkID() FrameworkID

+ func (m *InverseOffer) GetOfferID() OfferID

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

+ func (m *InverseOffer) GetURL() *URL

+ func (m *InverseOffer) GetUnavailability() Unavailability

+ func (m *InverseOffer) Marshal() (data []byte, err error)

+ func (m *InverseOffer) MarshalTo(data []byte) (int, error)

+ func (m *InverseOffer) Reset()

+ func (m *InverseOffer) Size() (n int)

+ func (m *InverseOffer) Unmarshal(data []byte) error

+ func (mj *InverseOffer) MarshalJSON() ([]byte, error)

+ func (mj *InverseOffer) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *InverseOffer) Equal(that interface{}) bool

+ func (this *InverseOffer) GoString() string

+ func (this *InverseOffer) String() string

+ func (this *InverseOffer) VerboseEqual(that interface{}) error

+ func (uj *InverseOffer) UnmarshalJSON(input []byte) error

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

+ type IpStatistics struct

+ DefaultTTL *int64

+ ForwDatagrams *int64

+ Forwarding *int64

+ FragCreates *int64

+ FragFails *int64

+ FragOKs *int64

+ InAddrErrors *int64

+ InDelivers *int64

+ InDiscards *int64

+ InHdrErrors *int64

+ InReceives *int64

+ InUnknownProtos *int64

+ OutDiscards *int64

+ OutNoRoutes *int64

+ OutRequests *int64

+ ReasmFails *int64

+ ReasmOKs *int64

+ ReasmReqds *int64

+ ReasmTimeout *int64

+ func NewPopulatedIpStatistics(r randyMesos, easy bool) *IpStatistics

+ func (*IpStatistics) ProtoMessage()

+ func (m *IpStatistics) GetDefaultTTL() int64

+ func (m *IpStatistics) GetForwDatagrams() int64

+ func (m *IpStatistics) GetForwarding() int64

+ func (m *IpStatistics) GetFragCreates() int64

+ func (m *IpStatistics) GetFragFails() int64

+ func (m *IpStatistics) GetFragOKs() int64

+ func (m *IpStatistics) GetInAddrErrors() int64

+ func (m *IpStatistics) GetInDelivers() int64

+ func (m *IpStatistics) GetInDiscards() int64

+ func (m *IpStatistics) GetInHdrErrors() int64

+ func (m *IpStatistics) GetInReceives() int64

+ func (m *IpStatistics) GetInUnknownProtos() int64

+ func (m *IpStatistics) GetOutDiscards() int64

+ func (m *IpStatistics) GetOutNoRoutes() int64

+ func (m *IpStatistics) GetOutRequests() int64

+ func (m *IpStatistics) GetReasmFails() int64

+ func (m *IpStatistics) GetReasmOKs() int64

+ func (m *IpStatistics) GetReasmReqds() int64

+ func (m *IpStatistics) GetReasmTimeout() int64

+ func (m *IpStatistics) Marshal() (data []byte, err error)

+ func (m *IpStatistics) MarshalTo(data []byte) (int, error)

+ func (m *IpStatistics) Reset()

+ func (m *IpStatistics) Size() (n int)

+ func (m *IpStatistics) Unmarshal(data []byte) error

+ func (mj *IpStatistics) MarshalJSON() ([]byte, error)

+ func (mj *IpStatistics) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *IpStatistics) Equal(that interface{}) bool

+ func (this *IpStatistics) GoString() string

+ func (this *IpStatistics) String() string

+ func (this *IpStatistics) VerboseEqual(that interface{}) error

+ func (uj *IpStatistics) UnmarshalJSON(input []byte) error

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

+ type KillPolicy struct

+ GracePeriod *DurationInfo

+ func NewPopulatedKillPolicy(r randyMesos, easy bool) *KillPolicy

+ func (*KillPolicy) ProtoMessage()

+ func (m *KillPolicy) GetGracePeriod() *DurationInfo

+ func (m *KillPolicy) Marshal() (data []byte, err error)

+ func (m *KillPolicy) MarshalTo(data []byte) (int, error)

+ func (m *KillPolicy) Reset()

+ func (m *KillPolicy) Size() (n int)

+ func (m *KillPolicy) Unmarshal(data []byte) error

+ func (mj *KillPolicy) MarshalJSON() ([]byte, error)

+ func (mj *KillPolicy) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *KillPolicy) Equal(that interface{}) bool

+ func (this *KillPolicy) GoString() string

+ func (this *KillPolicy) String() string

+ func (this *KillPolicy) VerboseEqual(that interface{}) error

+ func (uj *KillPolicy) UnmarshalJSON(input []byte) error

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

+ type Label struct

+ Key string

+ Value *string

+ func NewPopulatedLabel(r randyMesos, easy bool) *Label

+ func (*Label) ProtoMessage()

+ func (m *Label) GetKey() string

+ func (m *Label) GetValue() string

+ func (m *Label) Marshal() (data []byte, err error)

+ func (m *Label) MarshalTo(data []byte) (int, error)

+ func (m *Label) Reset()

+ func (m *Label) Size() (n int)

+ func (m *Label) Unmarshal(data []byte) error

+ func (mj *Label) MarshalJSON() ([]byte, error)

+ func (mj *Label) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Label) Equal(that interface{}) bool

+ func (this *Label) GoString() string

+ func (this *Label) String() string

+ func (this *Label) VerboseEqual(that interface{}) error

+ func (uj *Label) UnmarshalJSON(input []byte) error

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

+ type Labels struct

+ Labels []Label

+ func NewPopulatedLabels(r randyMesos, easy bool) *Labels

+ func (*Labels) ProtoMessage()

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

+ func (m *Labels) Marshal() (data []byte, err error)

+ func (m *Labels) MarshalTo(data []byte) (int, error)

+ func (m *Labels) Reset()

+ func (m *Labels) Size() (n int)

+ func (m *Labels) Unmarshal(data []byte) error

+ func (mj *Labels) MarshalJSON() ([]byte, error)

+ func (mj *Labels) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Labels) Equal(that interface{}) bool

+ func (this *Labels) GoString() string

+ func (this *Labels) String() string

+ func (this *Labels) VerboseEqual(that interface{}) error

+ func (uj *Labels) UnmarshalJSON(input []byte) error

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

+ type LinuxInfo struct

+ CapabilityInfo *CapabilityInfo

+ func NewPopulatedLinuxInfo(r randyMesos, easy bool) *LinuxInfo

+ func (*LinuxInfo) ProtoMessage()

+ func (m *LinuxInfo) GetCapabilityInfo() *CapabilityInfo

+ func (m *LinuxInfo) Marshal() (data []byte, err error)

+ func (m *LinuxInfo) MarshalTo(data []byte) (int, error)

+ func (m *LinuxInfo) Reset()

+ func (m *LinuxInfo) Size() (n int)

+ func (m *LinuxInfo) Unmarshal(data []byte) error

+ func (mj *LinuxInfo) MarshalJSON() ([]byte, error)

+ func (mj *LinuxInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *LinuxInfo) Equal(that interface{}) bool

+ func (this *LinuxInfo) GoString() string

+ func (this *LinuxInfo) String() string

+ func (this *LinuxInfo) VerboseEqual(that interface{}) error

+ func (uj *LinuxInfo) UnmarshalJSON(input []byte) error

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

+ type MachineID struct

+ Hostname *string

+ IP *string

+ func NewPopulatedMachineID(r randyMesos, easy bool) *MachineID

+ func (*MachineID) ProtoMessage()

+ func (m *MachineID) GetHostname() string

+ func (m *MachineID) GetIP() string

+ func (m *MachineID) Marshal() (data []byte, err error)

+ func (m *MachineID) MarshalTo(data []byte) (int, error)

+ func (m *MachineID) Reset()

+ func (m *MachineID) Size() (n int)

+ func (m *MachineID) Unmarshal(data []byte) error

+ func (mj *MachineID) MarshalJSON() ([]byte, error)

+ func (mj *MachineID) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *MachineID) Equal(that interface{}) bool

+ func (this *MachineID) GoString() string

+ func (this *MachineID) String() string

+ func (this *MachineID) VerboseEqual(that interface{}) error

+ func (uj *MachineID) UnmarshalJSON(input []byte) error

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

+ type MachineInfo struct

+ ID MachineID

+ Mode *MachineInfo_Mode

+ Unavailability *Unavailability

+ func NewPopulatedMachineInfo(r randyMesos, easy bool) *MachineInfo

+ func (*MachineInfo) ProtoMessage()

+ func (m *MachineInfo) GetID() MachineID

+ func (m *MachineInfo) GetMode() MachineInfo_Mode

+ func (m *MachineInfo) GetUnavailability() *Unavailability

+ func (m *MachineInfo) Marshal() (data []byte, err error)

+ func (m *MachineInfo) MarshalTo(data []byte) (int, error)

+ func (m *MachineInfo) Reset()

+ func (m *MachineInfo) Size() (n int)

+ func (m *MachineInfo) Unmarshal(data []byte) error

+ func (mj *MachineInfo) MarshalJSON() ([]byte, error)

+ func (mj *MachineInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *MachineInfo) Equal(that interface{}) bool

+ func (this *MachineInfo) GoString() string

+ func (this *MachineInfo) String() string

+ func (this *MachineInfo) VerboseEqual(that interface{}) error

+ func (uj *MachineInfo) UnmarshalJSON(input []byte) error

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

+ type MachineInfo_Mode int32

+ const DOWN

+ const DRAINING

+ const UP

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

+ func (x MachineInfo_Mode) Enum() *MachineInfo_Mode

+ func (x MachineInfo_Mode) MarshalJSON() ([]byte, error)

+ func (x MachineInfo_Mode) String() string

+ type MasterInfo struct

+ Address *Address

+ Hostname *string

+ ID string

+ IP uint32

+ PID *string

+ Port *uint32

+ Version *string

+ func NewPopulatedMasterInfo(r randyMesos, easy bool) *MasterInfo

+ func (*MasterInfo) ProtoMessage()

+ func (m *MasterInfo) GetAddress() *Address

+ func (m *MasterInfo) GetHostname() string

+ func (m *MasterInfo) GetID() string

+ func (m *MasterInfo) GetIP() uint32

+ func (m *MasterInfo) GetPID() string

+ func (m *MasterInfo) GetPort() uint32

+ func (m *MasterInfo) GetVersion() string

+ func (m *MasterInfo) Marshal() (data []byte, err error)

+ func (m *MasterInfo) MarshalTo(data []byte) (int, error)

+ func (m *MasterInfo) Reset()

+ func (m *MasterInfo) Size() (n int)

+ func (m *MasterInfo) Unmarshal(data []byte) error

+ func (mj *MasterInfo) MarshalJSON() ([]byte, error)

+ func (mj *MasterInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *MasterInfo) Equal(that interface{}) bool

+ func (this *MasterInfo) GoString() string

+ func (this *MasterInfo) String() string

+ func (this *MasterInfo) VerboseEqual(that interface{}) error

+ func (uj *MasterInfo) UnmarshalJSON(input []byte) error

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

+ type Metric struct

+ Name string

+ Value *float64

+ func NewPopulatedMetric(r randyMesos, easy bool) *Metric

+ func (*Metric) ProtoMessage()

+ func (m *Metric) GetName() string

+ func (m *Metric) GetValue() float64

+ func (m *Metric) Marshal() (data []byte, err error)

+ func (m *Metric) MarshalTo(data []byte) (int, error)

+ func (m *Metric) Reset()

+ func (m *Metric) Size() (n int)

+ func (m *Metric) Unmarshal(data []byte) error

+ func (mj *Metric) MarshalJSON() ([]byte, error)

+ func (mj *Metric) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Metric) Equal(that interface{}) bool

+ func (this *Metric) GoString() string

+ func (this *Metric) String() string

+ func (this *Metric) VerboseEqual(that interface{}) error

+ func (uj *Metric) UnmarshalJSON(input []byte) error

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

+ type NetworkInfo struct

+ Groups []string

+ IPAddresses []NetworkInfo_IPAddress

+ Labels *Labels

+ Name *string

+ PortMappings []NetworkInfo_PortMapping

+ func NewPopulatedNetworkInfo(r randyMesos, easy bool) *NetworkInfo

+ func (*NetworkInfo) ProtoMessage()

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

+ func (m *NetworkInfo) GetIPAddresses() []NetworkInfo_IPAddress

+ func (m *NetworkInfo) GetLabels() *Labels

+ func (m *NetworkInfo) GetName() string

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

+ func (m *NetworkInfo) Marshal() (data []byte, err error)

+ func (m *NetworkInfo) MarshalTo(data []byte) (int, error)

+ func (m *NetworkInfo) Reset()

+ func (m *NetworkInfo) Size() (n int)

+ func (m *NetworkInfo) Unmarshal(data []byte) error

+ func (mj *NetworkInfo) MarshalJSON() ([]byte, error)

+ func (mj *NetworkInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *NetworkInfo) Equal(that interface{}) bool

+ func (this *NetworkInfo) GoString() string

+ func (this *NetworkInfo) String() string

+ func (this *NetworkInfo) VerboseEqual(that interface{}) error

+ func (uj *NetworkInfo) UnmarshalJSON(input []byte) error

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

+ type NetworkInfo_IPAddress struct

+ IPAddress *string

+ Protocol *NetworkInfo_Protocol

+ func NewPopulatedNetworkInfo_IPAddress(r randyMesos, easy bool) *NetworkInfo_IPAddress

+ func (*NetworkInfo_IPAddress) ProtoMessage()

+ func (m *NetworkInfo_IPAddress) GetIPAddress() string

+ func (m *NetworkInfo_IPAddress) GetProtocol() NetworkInfo_Protocol

+ func (m *NetworkInfo_IPAddress) Marshal() (data []byte, err error)

+ func (m *NetworkInfo_IPAddress) MarshalTo(data []byte) (int, error)

+ func (m *NetworkInfo_IPAddress) Reset()

+ func (m *NetworkInfo_IPAddress) Size() (n int)

+ func (m *NetworkInfo_IPAddress) Unmarshal(data []byte) error

+ func (mj *NetworkInfo_IPAddress) MarshalJSON() ([]byte, error)

+ func (mj *NetworkInfo_IPAddress) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *NetworkInfo_IPAddress) Equal(that interface{}) bool

+ func (this *NetworkInfo_IPAddress) GoString() string

+ func (this *NetworkInfo_IPAddress) String() string

+ func (this *NetworkInfo_IPAddress) VerboseEqual(that interface{}) error

+ func (uj *NetworkInfo_IPAddress) UnmarshalJSON(input []byte) error

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

+ type NetworkInfo_PortMapping struct

+ ContainerPort uint32

+ HostPort uint32

+ Protocol *string

+ func NewPopulatedNetworkInfo_PortMapping(r randyMesos, easy bool) *NetworkInfo_PortMapping

+ func (*NetworkInfo_PortMapping) ProtoMessage()

+ func (m *NetworkInfo_PortMapping) GetContainerPort() uint32

+ func (m *NetworkInfo_PortMapping) GetHostPort() uint32

+ func (m *NetworkInfo_PortMapping) GetProtocol() string

+ func (m *NetworkInfo_PortMapping) Marshal() (data []byte, err error)

+ func (m *NetworkInfo_PortMapping) MarshalTo(data []byte) (int, error)

+ func (m *NetworkInfo_PortMapping) Reset()

+ func (m *NetworkInfo_PortMapping) Size() (n int)

+ func (m *NetworkInfo_PortMapping) Unmarshal(data []byte) error

+ func (mj *NetworkInfo_PortMapping) MarshalJSON() ([]byte, error)

+ func (mj *NetworkInfo_PortMapping) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *NetworkInfo_PortMapping) Equal(that interface{}) bool

+ func (this *NetworkInfo_PortMapping) GoString() string

+ func (this *NetworkInfo_PortMapping) String() string

+ func (this *NetworkInfo_PortMapping) VerboseEqual(that interface{}) error

+ func (uj *NetworkInfo_PortMapping) UnmarshalJSON(input []byte) error

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

+ type NetworkInfo_Protocol int32

+ const IPv4

+ const IPv6

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

+ func (x NetworkInfo_Protocol) Enum() *NetworkInfo_Protocol

+ func (x NetworkInfo_Protocol) MarshalJSON() ([]byte, error)

+ func (x NetworkInfo_Protocol) String() string

+ type Offer struct

+ AgentID AgentID

+ Attributes []Attribute

+ ExecutorIDs []ExecutorID

+ FrameworkID FrameworkID

+ Hostname string

+ ID OfferID

+ Resources []Resource

+ URL *URL

+ Unavailability *Unavailability

+ func NewPopulatedOffer(r randyMesos, easy bool) *Offer

+ func (*Offer) ProtoMessage()

+ func (m *Offer) GetAgentID() AgentID

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

+ func (m *Offer) GetExecutorIDs() []ExecutorID

+ func (m *Offer) GetFrameworkID() FrameworkID

+ func (m *Offer) GetHostname() string

+ func (m *Offer) GetID() OfferID

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

+ func (m *Offer) GetURL() *URL

+ func (m *Offer) GetUnavailability() *Unavailability

+ func (m *Offer) Marshal() (data []byte, err error)

+ func (m *Offer) MarshalTo(data []byte) (int, error)

+ func (m *Offer) Reset()

+ func (m *Offer) Size() (n int)

+ func (m *Offer) Unmarshal(data []byte) error

+ func (mj *Offer) MarshalJSON() ([]byte, error)

+ func (mj *Offer) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Offer) Equal(that interface{}) bool

+ func (this *Offer) GoString() string

+ func (this *Offer) String() string

+ func (this *Offer) VerboseEqual(that interface{}) error

+ func (uj *Offer) UnmarshalJSON(input []byte) error

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

+ type OfferID struct

+ Value string

+ func NewPopulatedOfferID(r randyMesos, easy bool) *OfferID

+ func (*OfferID) ProtoMessage()

+ func (m *OfferID) GetValue() string

+ func (m *OfferID) Marshal() (data []byte, err error)

+ func (m *OfferID) MarshalTo(data []byte) (int, error)

+ func (m *OfferID) Reset()

+ func (m *OfferID) Size() (n int)

+ func (m *OfferID) Unmarshal(data []byte) error

+ func (mj *OfferID) MarshalJSON() ([]byte, error)

+ func (mj *OfferID) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *OfferID) Equal(that interface{}) bool

+ func (this *OfferID) GoString() string

+ func (this *OfferID) String() string

+ func (this *OfferID) VerboseEqual(that interface{}) error

+ func (uj *OfferID) UnmarshalJSON(input []byte) error

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

+ type Offer_Operation struct

+ Create *Offer_Operation_Create

+ Destroy *Offer_Operation_Destroy

+ Launch *Offer_Operation_Launch

+ LaunchGroup *Offer_Operation_LaunchGroup

+ Reserve *Offer_Operation_Reserve

+ Type *Offer_Operation_Type

+ Unreserve *Offer_Operation_Unreserve

+ func NewPopulatedOffer_Operation(r randyMesos, easy bool) *Offer_Operation

+ func (*Offer_Operation) ProtoMessage()

+ func (m *Offer_Operation) GetCreate() *Offer_Operation_Create

+ func (m *Offer_Operation) GetDestroy() *Offer_Operation_Destroy

+ func (m *Offer_Operation) GetLaunch() *Offer_Operation_Launch

+ func (m *Offer_Operation) GetLaunchGroup() *Offer_Operation_LaunchGroup

+ func (m *Offer_Operation) GetReserve() *Offer_Operation_Reserve

+ func (m *Offer_Operation) GetType() Offer_Operation_Type

+ func (m *Offer_Operation) GetUnreserve() *Offer_Operation_Unreserve

+ func (m *Offer_Operation) Marshal() (data []byte, err error)

+ func (m *Offer_Operation) MarshalTo(data []byte) (int, error)

+ func (m *Offer_Operation) Reset()

+ func (m *Offer_Operation) Size() (n int)

+ func (m *Offer_Operation) Unmarshal(data []byte) error

+ func (mj *Offer_Operation) MarshalJSON() ([]byte, error)

+ func (mj *Offer_Operation) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (operation Offer_Operation) Apply(resources Resources) (Resources, error)

+ func (this *Offer_Operation) Equal(that interface{}) bool

+ func (this *Offer_Operation) GoString() string

+ func (this *Offer_Operation) String() string

+ func (this *Offer_Operation) VerboseEqual(that interface{}) error

+ func (uj *Offer_Operation) UnmarshalJSON(input []byte) error

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

+ type Offer_Operation_Create struct

+ Volumes []Resource

+ func NewPopulatedOffer_Operation_Create(r randyMesos, easy bool) *Offer_Operation_Create

+ func (*Offer_Operation_Create) ProtoMessage()

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

+ func (m *Offer_Operation_Create) Marshal() (data []byte, err error)

+ func (m *Offer_Operation_Create) MarshalTo(data []byte) (int, error)

+ func (m *Offer_Operation_Create) Reset()

+ func (m *Offer_Operation_Create) Size() (n int)

+ func (m *Offer_Operation_Create) Unmarshal(data []byte) error

+ func (mj *Offer_Operation_Create) MarshalJSON() ([]byte, error)

+ func (mj *Offer_Operation_Create) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Offer_Operation_Create) Equal(that interface{}) bool

+ func (this *Offer_Operation_Create) GoString() string

+ func (this *Offer_Operation_Create) String() string

+ func (this *Offer_Operation_Create) VerboseEqual(that interface{}) error

+ func (uj *Offer_Operation_Create) UnmarshalJSON(input []byte) error

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

+ type Offer_Operation_Destroy struct

+ Volumes []Resource

+ func NewPopulatedOffer_Operation_Destroy(r randyMesos, easy bool) *Offer_Operation_Destroy

+ func (*Offer_Operation_Destroy) ProtoMessage()

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

+ func (m *Offer_Operation_Destroy) Marshal() (data []byte, err error)

+ func (m *Offer_Operation_Destroy) MarshalTo(data []byte) (int, error)

+ func (m *Offer_Operation_Destroy) Reset()

+ func (m *Offer_Operation_Destroy) Size() (n int)

+ func (m *Offer_Operation_Destroy) Unmarshal(data []byte) error

+ func (mj *Offer_Operation_Destroy) MarshalJSON() ([]byte, error)

+ func (mj *Offer_Operation_Destroy) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Offer_Operation_Destroy) Equal(that interface{}) bool

+ func (this *Offer_Operation_Destroy) GoString() string

+ func (this *Offer_Operation_Destroy) String() string

+ func (this *Offer_Operation_Destroy) VerboseEqual(that interface{}) error

+ func (uj *Offer_Operation_Destroy) UnmarshalJSON(input []byte) error

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

+ type Offer_Operation_Launch struct

+ TaskInfos []TaskInfo

+ func NewPopulatedOffer_Operation_Launch(r randyMesos, easy bool) *Offer_Operation_Launch

+ func (*Offer_Operation_Launch) ProtoMessage()

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

+ func (m *Offer_Operation_Launch) Marshal() (data []byte, err error)

+ func (m *Offer_Operation_Launch) MarshalTo(data []byte) (int, error)

+ func (m *Offer_Operation_Launch) Reset()

+ func (m *Offer_Operation_Launch) Size() (n int)

+ func (m *Offer_Operation_Launch) Unmarshal(data []byte) error

+ func (mj *Offer_Operation_Launch) MarshalJSON() ([]byte, error)

+ func (mj *Offer_Operation_Launch) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Offer_Operation_Launch) Equal(that interface{}) bool

+ func (this *Offer_Operation_Launch) GoString() string

+ func (this *Offer_Operation_Launch) String() string

+ func (this *Offer_Operation_Launch) VerboseEqual(that interface{}) error

+ func (uj *Offer_Operation_Launch) UnmarshalJSON(input []byte) error

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

+ type Offer_Operation_LaunchGroup struct

+ Executor ExecutorInfo

+ TaskGroup TaskGroupInfo

+ func NewPopulatedOffer_Operation_LaunchGroup(r randyMesos, easy bool) *Offer_Operation_LaunchGroup

+ func (*Offer_Operation_LaunchGroup) ProtoMessage()

+ func (m *Offer_Operation_LaunchGroup) GetExecutor() ExecutorInfo

+ func (m *Offer_Operation_LaunchGroup) GetTaskGroup() TaskGroupInfo

+ func (m *Offer_Operation_LaunchGroup) Marshal() (data []byte, err error)

+ func (m *Offer_Operation_LaunchGroup) MarshalTo(data []byte) (int, error)

+ func (m *Offer_Operation_LaunchGroup) Reset()

+ func (m *Offer_Operation_LaunchGroup) Size() (n int)

+ func (m *Offer_Operation_LaunchGroup) Unmarshal(data []byte) error

+ func (mj *Offer_Operation_LaunchGroup) MarshalJSON() ([]byte, error)

+ func (mj *Offer_Operation_LaunchGroup) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Offer_Operation_LaunchGroup) Equal(that interface{}) bool

+ func (this *Offer_Operation_LaunchGroup) GoString() string

+ func (this *Offer_Operation_LaunchGroup) String() string

+ func (this *Offer_Operation_LaunchGroup) VerboseEqual(that interface{}) error

+ func (uj *Offer_Operation_LaunchGroup) UnmarshalJSON(input []byte) error

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

+ type Offer_Operation_Reserve struct

+ Resources []Resource

+ func NewPopulatedOffer_Operation_Reserve(r randyMesos, easy bool) *Offer_Operation_Reserve

+ func (*Offer_Operation_Reserve) ProtoMessage()

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

+ func (m *Offer_Operation_Reserve) Marshal() (data []byte, err error)

+ func (m *Offer_Operation_Reserve) MarshalTo(data []byte) (int, error)

+ func (m *Offer_Operation_Reserve) Reset()

+ func (m *Offer_Operation_Reserve) Size() (n int)

+ func (m *Offer_Operation_Reserve) Unmarshal(data []byte) error

+ func (mj *Offer_Operation_Reserve) MarshalJSON() ([]byte, error)

+ func (mj *Offer_Operation_Reserve) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Offer_Operation_Reserve) Equal(that interface{}) bool

+ func (this *Offer_Operation_Reserve) GoString() string

+ func (this *Offer_Operation_Reserve) String() string

+ func (this *Offer_Operation_Reserve) VerboseEqual(that interface{}) error

+ func (uj *Offer_Operation_Reserve) UnmarshalJSON(input []byte) error

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

+ type Offer_Operation_Type int32

+ const Offer_Operation_CREATE

+ const Offer_Operation_DESTROY

+ const Offer_Operation_LAUNCH

+ const Offer_Operation_LAUNCH_GROUP

+ const Offer_Operation_RESERVE

+ const Offer_Operation_UNKNOWN

+ const Offer_Operation_UNRESERVE

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

+ func (x Offer_Operation_Type) Enum() *Offer_Operation_Type

+ func (x Offer_Operation_Type) MarshalJSON() ([]byte, error)

+ func (x Offer_Operation_Type) String() string

+ type Offer_Operation_Unreserve struct

+ Resources []Resource

+ func NewPopulatedOffer_Operation_Unreserve(r randyMesos, easy bool) *Offer_Operation_Unreserve

+ func (*Offer_Operation_Unreserve) ProtoMessage()

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

+ func (m *Offer_Operation_Unreserve) Marshal() (data []byte, err error)

+ func (m *Offer_Operation_Unreserve) MarshalTo(data []byte) (int, error)

+ func (m *Offer_Operation_Unreserve) Reset()

+ func (m *Offer_Operation_Unreserve) Size() (n int)

+ func (m *Offer_Operation_Unreserve) Unmarshal(data []byte) error

+ func (mj *Offer_Operation_Unreserve) MarshalJSON() ([]byte, error)

+ func (mj *Offer_Operation_Unreserve) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Offer_Operation_Unreserve) Equal(that interface{}) bool

+ func (this *Offer_Operation_Unreserve) GoString() string

+ func (this *Offer_Operation_Unreserve) String() string

+ func (this *Offer_Operation_Unreserve) VerboseEqual(that interface{}) error

+ func (uj *Offer_Operation_Unreserve) UnmarshalJSON(input []byte) error

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

+ type OperationError struct

+ func (err *OperationError) Cause() error

+ func (err *OperationError) Error() string

+ func (err *OperationError) Operation() Offer_Operation_Type

+ func (err *OperationError) Type() OperationErrorType

+ type OperationErrorType int

+ const OperationErrorTypeInvalid

+ const OperationErrorTypeUnknown

+ type Parameter struct

+ Key string

+ Value string

+ func NewPopulatedParameter(r randyMesos, easy bool) *Parameter

+ func (*Parameter) ProtoMessage()

+ func (m *Parameter) GetKey() string

+ func (m *Parameter) GetValue() string

+ func (m *Parameter) Marshal() (data []byte, err error)

+ func (m *Parameter) MarshalTo(data []byte) (int, error)

+ func (m *Parameter) Reset()

+ func (m *Parameter) Size() (n int)

+ func (m *Parameter) Unmarshal(data []byte) error

+ func (mj *Parameter) MarshalJSON() ([]byte, error)

+ func (mj *Parameter) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Parameter) Equal(that interface{}) bool

+ func (this *Parameter) GoString() string

+ func (this *Parameter) String() string

+ func (this *Parameter) VerboseEqual(that interface{}) error

+ func (uj *Parameter) UnmarshalJSON(input []byte) error

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

+ type Parameters struct

+ Parameter []Parameter

+ func NewPopulatedParameters(r randyMesos, easy bool) *Parameters

+ func (*Parameters) ProtoMessage()

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

+ func (m *Parameters) Marshal() (data []byte, err error)

+ func (m *Parameters) MarshalTo(data []byte) (int, error)

+ func (m *Parameters) Reset()

+ func (m *Parameters) Size() (n int)

+ func (m *Parameters) Unmarshal(data []byte) error

+ func (mj *Parameters) MarshalJSON() ([]byte, error)

+ func (mj *Parameters) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Parameters) Equal(that interface{}) bool

+ func (this *Parameters) GoString() string

+ func (this *Parameters) String() string

+ func (this *Parameters) VerboseEqual(that interface{}) error

+ func (uj *Parameters) UnmarshalJSON(input []byte) error

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

+ type PerfStatistics struct

+ AlignmentFaults *uint64

+ BranchLoadMisses *uint64

+ BranchLoads *uint64

+ BranchMisses *uint64

+ Branches *uint64

+ BusCycles *uint64

+ CPUClock *float64

+ CPUMigrations *uint64

+ CacheMisses *uint64

+ CacheReferences *uint64

+ ContextSwitches *uint64

+ Cycles *uint64

+ DTLBLoadMisses *uint64

+ DTLBLoads *uint64

+ DTLBPrefetchMisses *uint64

+ DTLBPrefetches *uint64

+ DTLBStoreMisses *uint64

+ DTLBStores *uint64

+ Duration float64

+ EmulationFaults *uint64

+ ITLBLoadMisses *uint64

+ ITLBLoads *uint64

+ Instructions *uint64

+ L1DcacheLoadMisses *uint64

+ L1DcacheLoads *uint64

+ L1DcachePrefetchMisses *uint64

+ L1DcachePrefetches *uint64

+ L1DcacheStoreMisses *uint64

+ L1DcacheStores *uint64

+ L1IcacheLoadMisses *uint64

+ L1IcacheLoads *uint64

+ L1IcachePrefetchMisses *uint64

+ L1IcachePrefetches *uint64

+ LLCLoadMisses *uint64

+ LLCLoads *uint64

+ LLCPrefetchMisses *uint64

+ LLCPrefetches *uint64

+ LLCStoreMisses *uint64

+ LLCStores *uint64

+ MajorFaults *uint64

+ MinorFaults *uint64

+ NodeLoadMisses *uint64

+ NodeLoads *uint64

+ NodePrefetchMisses *uint64

+ NodePrefetches *uint64

+ NodeStoreMisses *uint64

+ NodeStores *uint64

+ PageFaults *uint64

+ RefCycles *uint64

+ StalledCyclesBackend *uint64

+ StalledCyclesFrontend *uint64

+ TaskClock *float64

+ Timestamp float64

+ func NewPopulatedPerfStatistics(r randyMesos, easy bool) *PerfStatistics

+ func (*PerfStatistics) ProtoMessage()

+ func (m *PerfStatistics) GetAlignmentFaults() uint64

+ func (m *PerfStatistics) GetBranchLoadMisses() uint64

+ func (m *PerfStatistics) GetBranchLoads() uint64

+ func (m *PerfStatistics) GetBranchMisses() uint64

+ func (m *PerfStatistics) GetBranches() uint64

+ func (m *PerfStatistics) GetBusCycles() uint64

+ func (m *PerfStatistics) GetCPUClock() float64

+ func (m *PerfStatistics) GetCPUMigrations() uint64

+ func (m *PerfStatistics) GetCacheMisses() uint64

+ func (m *PerfStatistics) GetCacheReferences() uint64

+ func (m *PerfStatistics) GetContextSwitches() uint64

+ func (m *PerfStatistics) GetCycles() uint64

+ func (m *PerfStatistics) GetDTLBLoadMisses() uint64

+ func (m *PerfStatistics) GetDTLBLoads() uint64

+ func (m *PerfStatistics) GetDTLBPrefetchMisses() uint64

+ func (m *PerfStatistics) GetDTLBPrefetches() uint64

+ func (m *PerfStatistics) GetDTLBStoreMisses() uint64

+ func (m *PerfStatistics) GetDTLBStores() uint64

+ func (m *PerfStatistics) GetDuration() float64

+ func (m *PerfStatistics) GetEmulationFaults() uint64

+ func (m *PerfStatistics) GetITLBLoadMisses() uint64

+ func (m *PerfStatistics) GetITLBLoads() uint64

+ func (m *PerfStatistics) GetInstructions() uint64

+ func (m *PerfStatistics) GetL1DcacheLoadMisses() uint64

+ func (m *PerfStatistics) GetL1DcacheLoads() uint64

+ func (m *PerfStatistics) GetL1DcachePrefetchMisses() uint64

+ func (m *PerfStatistics) GetL1DcachePrefetches() uint64

+ func (m *PerfStatistics) GetL1DcacheStoreMisses() uint64

+ func (m *PerfStatistics) GetL1DcacheStores() uint64

+ func (m *PerfStatistics) GetL1IcacheLoadMisses() uint64

+ func (m *PerfStatistics) GetL1IcacheLoads() uint64

+ func (m *PerfStatistics) GetL1IcachePrefetchMisses() uint64

+ func (m *PerfStatistics) GetL1IcachePrefetches() uint64

+ func (m *PerfStatistics) GetLLCLoadMisses() uint64

+ func (m *PerfStatistics) GetLLCLoads() uint64

+ func (m *PerfStatistics) GetLLCPrefetchMisses() uint64

+ func (m *PerfStatistics) GetLLCPrefetches() uint64

+ func (m *PerfStatistics) GetLLCStoreMisses() uint64

+ func (m *PerfStatistics) GetLLCStores() uint64

+ func (m *PerfStatistics) GetMajorFaults() uint64

+ func (m *PerfStatistics) GetMinorFaults() uint64

+ func (m *PerfStatistics) GetNodeLoadMisses() uint64

+ func (m *PerfStatistics) GetNodeLoads() uint64

+ func (m *PerfStatistics) GetNodePrefetchMisses() uint64

+ func (m *PerfStatistics) GetNodePrefetches() uint64

+ func (m *PerfStatistics) GetNodeStoreMisses() uint64

+ func (m *PerfStatistics) GetNodeStores() uint64

+ func (m *PerfStatistics) GetPageFaults() uint64

+ func (m *PerfStatistics) GetRefCycles() uint64

+ func (m *PerfStatistics) GetStalledCyclesBackend() uint64

+ func (m *PerfStatistics) GetStalledCyclesFrontend() uint64

+ func (m *PerfStatistics) GetTaskClock() float64

+ func (m *PerfStatistics) GetTimestamp() float64

+ func (m *PerfStatistics) Marshal() (data []byte, err error)

+ func (m *PerfStatistics) MarshalTo(data []byte) (int, error)

+ func (m *PerfStatistics) Reset()

+ func (m *PerfStatistics) Size() (n int)

+ func (m *PerfStatistics) Unmarshal(data []byte) error

+ func (mj *PerfStatistics) MarshalJSON() ([]byte, error)

+ func (mj *PerfStatistics) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *PerfStatistics) Equal(that interface{}) bool

+ func (this *PerfStatistics) GoString() string

+ func (this *PerfStatistics) String() string

+ func (this *PerfStatistics) VerboseEqual(that interface{}) error

+ func (uj *PerfStatistics) UnmarshalJSON(input []byte) error

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

+ type Port struct

+ Labels *Labels

+ Name *string

+ Number uint32

+ Protocol *string

+ Visibility *DiscoveryInfo_Visibility

+ func NewPopulatedPort(r randyMesos, easy bool) *Port

+ func (*Port) ProtoMessage()

+ func (m *Port) GetLabels() *Labels

+ func (m *Port) GetName() string

+ func (m *Port) GetNumber() uint32

+ func (m *Port) GetProtocol() string

+ func (m *Port) GetVisibility() DiscoveryInfo_Visibility

+ func (m *Port) Marshal() (data []byte, err error)

+ func (m *Port) MarshalTo(data []byte) (int, error)

+ func (m *Port) Reset()

+ func (m *Port) Size() (n int)

+ func (m *Port) Unmarshal(data []byte) error

+ func (mj *Port) MarshalJSON() ([]byte, error)

+ func (mj *Port) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Port) Equal(that interface{}) bool

+ func (this *Port) GoString() string

+ func (this *Port) String() string

+ func (this *Port) VerboseEqual(that interface{}) error

+ func (uj *Port) UnmarshalJSON(input []byte) error

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

+ type Ports struct

+ Ports []Port

+ func NewPopulatedPorts(r randyMesos, easy bool) *Ports

+ func (*Ports) ProtoMessage()

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

+ func (m *Ports) Marshal() (data []byte, err error)

+ func (m *Ports) MarshalTo(data []byte) (int, error)

+ func (m *Ports) Reset()

+ func (m *Ports) Size() (n int)

+ func (m *Ports) Unmarshal(data []byte) error

+ func (mj *Ports) MarshalJSON() ([]byte, error)

+ func (mj *Ports) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Ports) Equal(that interface{}) bool

+ func (this *Ports) GoString() string

+ func (this *Ports) String() string

+ func (this *Ports) VerboseEqual(that interface{}) error

+ func (uj *Ports) UnmarshalJSON(input []byte) error

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

+ type RangeBuilder struct

+ func BuildRanges() RangeBuilder

+ func (rb RangeBuilder) Span(bp, ep uint64) RangeBuilder

+ type Ranges []Value_Range

+ func NewPortRanges(o *Offer) Ranges

+ func NewRanges(ns ...uint64) Ranges

+ func (left Ranges) Compare(right Ranges) int

+ func (left Ranges) Equivalent(right Ranges) (result bool)

+ func (rs Ranges) Clone() Ranges

+ func (rs Ranges) Len() int

+ func (rs Ranges) Less(i, j int) bool

+ func (rs Ranges) Max() uint64

+ func (rs Ranges) Min() uint64

+ func (rs Ranges) Partition(n uint64) (Ranges, bool)

+ func (rs Ranges) Remove(removal Value_Range) Ranges

+ func (rs Ranges) Search(n uint64) int

+ func (rs Ranges) Size() uint64

+ func (rs Ranges) Sort() Ranges

+ func (rs Ranges) Squash() Ranges

+ func (rs Ranges) Swap(i, j int)

+ type RateLimit struct

+ Capacity *uint64

+ Principal string

+ QPS *float64

+ func NewPopulatedRateLimit(r randyMesos, easy bool) *RateLimit

+ func (*RateLimit) ProtoMessage()

+ func (m *RateLimit) GetCapacity() uint64

+ func (m *RateLimit) GetPrincipal() string

+ func (m *RateLimit) GetQPS() float64

+ func (m *RateLimit) Marshal() (data []byte, err error)

+ func (m *RateLimit) MarshalTo(data []byte) (int, error)

+ func (m *RateLimit) Reset()

+ func (m *RateLimit) Size() (n int)

+ func (m *RateLimit) Unmarshal(data []byte) error

+ func (mj *RateLimit) MarshalJSON() ([]byte, error)

+ func (mj *RateLimit) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *RateLimit) Equal(that interface{}) bool

+ func (this *RateLimit) GoString() string

+ func (this *RateLimit) String() string

+ func (this *RateLimit) VerboseEqual(that interface{}) error

+ func (uj *RateLimit) UnmarshalJSON(input []byte) error

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

+ type RateLimits struct

+ AggregateDefaultCapacity *uint64

+ AggregateDefaultQPS *float64

+ Limits []RateLimit

+ func NewPopulatedRateLimits(r randyMesos, easy bool) *RateLimits

+ func (*RateLimits) ProtoMessage()

+ func (m *RateLimits) GetAggregateDefaultCapacity() uint64

+ func (m *RateLimits) GetAggregateDefaultQPS() float64

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

+ func (m *RateLimits) Marshal() (data []byte, err error)

+ func (m *RateLimits) MarshalTo(data []byte) (int, error)

+ func (m *RateLimits) Reset()

+ func (m *RateLimits) Size() (n int)

+ func (m *RateLimits) Unmarshal(data []byte) error

+ func (mj *RateLimits) MarshalJSON() ([]byte, error)

+ func (mj *RateLimits) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *RateLimits) Equal(that interface{}) bool

+ func (this *RateLimits) GoString() string

+ func (this *RateLimits) String() string

+ func (this *RateLimits) VerboseEqual(that interface{}) error

+ func (uj *RateLimits) UnmarshalJSON(input []byte) error

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

+ type Request struct

+ AgentID *AgentID

+ Resources []Resource

+ func NewPopulatedRequest(r randyMesos, easy bool) *Request

+ func (*Request) ProtoMessage()

+ func (m *Request) GetAgentID() *AgentID

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

+ func (m *Request) Marshal() (data []byte, err error)

+ func (m *Request) MarshalTo(data []byte) (int, error)

+ func (m *Request) Reset()

+ func (m *Request) Size() (n int)

+ func (m *Request) Unmarshal(data []byte) error

+ func (mj *Request) MarshalJSON() ([]byte, error)

+ func (mj *Request) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Request) Equal(that interface{}) bool

+ func (this *Request) GoString() string

+ func (this *Request) String() string

+ func (this *Request) VerboseEqual(that interface{}) error

+ func (uj *Request) UnmarshalJSON(input []byte) error

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

+ type Resource struct

+ Disk *Resource_DiskInfo

+ Name string

+ Ranges *Value_Ranges

+ Reservation *Resource_ReservationInfo

+ Revocable *Resource_RevocableInfo

+ Role *string

+ Scalar *Value_Scalar

+ Set *Value_Set

+ Shared *Resource_SharedInfo

+ Type *Value_Type

+ func NewPopulatedResource(r randyMesos, easy bool) *Resource

+ func (*Resource) ProtoMessage()

+ func (left *Resource) Add(right Resource)

+ func (left *Resource) Addable(right Resource) bool

+ func (left *Resource) Equivalent(right Resource) bool

+ func (left *Resource) IsDynamicallyReserved() bool

+ func (left *Resource) IsEmpty() bool

+ func (left *Resource) IsPersistentVolume() bool

+ func (left *Resource) IsReserved(role string) bool

+ func (left *Resource) IsRevocable() bool

+ func (left *Resource) IsUnreserved() bool

+ func (left *Resource) Subtract(right Resource)

+ func (left *Resource) Subtractable(right Resource) bool

+ func (left *Resource) Validate() error

+ func (left Resource) Contains(right Resource) bool

+ func (m *Resource) GetDisk() *Resource_DiskInfo

+ func (m *Resource) GetName() string

+ func (m *Resource) GetRanges() *Value_Ranges

+ func (m *Resource) GetReservation() *Resource_ReservationInfo

+ func (m *Resource) GetRevocable() *Resource_RevocableInfo

+ func (m *Resource) GetRole() string

+ func (m *Resource) GetScalar() *Value_Scalar

+ func (m *Resource) GetSet() *Value_Set

+ func (m *Resource) GetShared() *Resource_SharedInfo

+ func (m *Resource) GetType() Value_Type

+ func (m *Resource) Marshal() (data []byte, err error)

+ func (m *Resource) MarshalTo(data []byte) (int, error)

+ func (m *Resource) Reset()

+ func (m *Resource) Size() (n int)

+ func (m *Resource) Unmarshal(data []byte) error

+ func (mj *Resource) MarshalJSON() ([]byte, error)

+ func (mj *Resource) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Resource) Equal(that interface{}) bool

+ func (this *Resource) GoString() string

+ func (this *Resource) String() string

+ func (this *Resource) VerboseEqual(that interface{}) error

+ func (uj *Resource) UnmarshalJSON(input []byte) error

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

+ type ResourceBuilder struct

+ func BuildResource() ResourceBuilder

+ func (rb ResourceBuilder) Disk(persistenceID, containerPath string) ResourceBuilder

+ func (rb ResourceBuilder) Name(name string) ResourceBuilder

+ func (rb ResourceBuilder) Ranges(rs Ranges) ResourceBuilder

+ func (rb ResourceBuilder) Revocable() ResourceBuilder

+ func (rb ResourceBuilder) Role(role string) ResourceBuilder

+ func (rb ResourceBuilder) Scalar(x float64) ResourceBuilder

+ func (rb ResourceBuilder) Set(x ...string) ResourceBuilder

+ type ResourceError struct

+ func (err *ResourceError) Error() string

+ func (err *ResourceError) Reason() string

+ func (err *ResourceError) Resource() Resource

+ func (err *ResourceError) Type() ResourceErrorType

+ type ResourceErrorType int

+ const ResourceErrorTypeIllegalDisk

+ const ResourceErrorTypeIllegalName

+ const ResourceErrorTypeIllegalRanges

+ const ResourceErrorTypeIllegalReservation

+ const ResourceErrorTypeIllegalScalar

+ const ResourceErrorTypeIllegalSet

+ const ResourceErrorTypeIllegalType

+ const ResourceErrorTypeUnsupportedType

+ const RoleDefault

+ func (t ResourceErrorType) Generate(reason string) error

+ type ResourceFilter func(*Resource) bool

+ func NamedResources(name string) ResourceFilter

+ func ReservedResources(role string) ResourceFilter

+ func (rf ResourceFilter) And(f ResourceFilter) ResourceFilter

+ func (rf ResourceFilter) Or(f ResourceFilter) ResourceFilter

+ func (rf ResourceFilter) Select(resources Resources) (result Resources)

+ type ResourceFilters []ResourceFilter

+ func (rf ResourceFilters) Predicate() ResourceFilter

+ type ResourceStatistics struct

+ CPUsLimit *float64

+ CPUsNrPeriods *uint32

+ CPUsNrThrottled *uint32

+ CPUsSystemTimeSecs *float64

+ CPUsThrottledTimeSecs *float64

+ CPUsUserTimeSecs *float64

+ DiskLimitBytes *uint64

+ DiskUsedBytes *uint64

+ MemAnonBytes *uint64

+ MemCacheBytes *uint64

+ MemCriticalPressureCounter *uint64

+ MemFileBytes *uint64

+ MemLimitBytes *uint64

+ MemLowPressureCounter *uint64

+ MemMappedFileBytes *uint64

+ MemMediumPressureCounter *uint64

+ MemRSSBytes *uint64

+ MemSoftLimitBytes *uint64

+ MemSwapBytes *uint64

+ MemTotalBytes *uint64

+ MemTotalMemswBytes *uint64

+ MemUnevictableBytes *uint64

+ NetRxBytes *uint64

+ NetRxDropped *uint64

+ NetRxErrors *uint64

+ NetRxPackets *uint64

+ NetSNMPStatistics *SNMPStatistics

+ NetTCPActiveConnections *float64

+ NetTCPRttMicrosecsP50 *float64

+ NetTCPRttMicrosecsP90 *float64

+ NetTCPRttMicrosecsP95 *float64

+ NetTCPRttMicrosecsP99 *float64

+ NetTCPTimeWaitConnections *float64

+ NetTrafficControlStatistics []TrafficControlStatistics

+ NetTxBytes *uint64

+ NetTxDropped *uint64

+ NetTxErrors *uint64

+ NetTxPackets *uint64

+ Perf *PerfStatistics

+ Processes *uint32

+ Threads *uint32

+ Timestamp float64

+ func NewPopulatedResourceStatistics(r randyMesos, easy bool) *ResourceStatistics

+ func (*ResourceStatistics) ProtoMessage()

+ func (m *ResourceStatistics) GetCPUsLimit() float64

+ func (m *ResourceStatistics) GetCPUsNrPeriods() uint32

+ func (m *ResourceStatistics) GetCPUsNrThrottled() uint32

+ func (m *ResourceStatistics) GetCPUsSystemTimeSecs() float64

+ func (m *ResourceStatistics) GetCPUsThrottledTimeSecs() float64

+ func (m *ResourceStatistics) GetCPUsUserTimeSecs() float64

+ func (m *ResourceStatistics) GetDiskLimitBytes() uint64

+ func (m *ResourceStatistics) GetDiskUsedBytes() uint64

+ func (m *ResourceStatistics) GetMemAnonBytes() uint64

+ func (m *ResourceStatistics) GetMemCacheBytes() uint64

+ func (m *ResourceStatistics) GetMemCriticalPressureCounter() uint64

+ func (m *ResourceStatistics) GetMemFileBytes() uint64

+ func (m *ResourceStatistics) GetMemLimitBytes() uint64

+ func (m *ResourceStatistics) GetMemLowPressureCounter() uint64

+ func (m *ResourceStatistics) GetMemMappedFileBytes() uint64

+ func (m *ResourceStatistics) GetMemMediumPressureCounter() uint64

+ func (m *ResourceStatistics) GetMemRSSBytes() uint64

+ func (m *ResourceStatistics) GetMemSoftLimitBytes() uint64

+ func (m *ResourceStatistics) GetMemSwapBytes() uint64

+ func (m *ResourceStatistics) GetMemTotalBytes() uint64

+ func (m *ResourceStatistics) GetMemTotalMemswBytes() uint64

+ func (m *ResourceStatistics) GetMemUnevictableBytes() uint64

+ func (m *ResourceStatistics) GetNetRxBytes() uint64

+ func (m *ResourceStatistics) GetNetRxDropped() uint64

+ func (m *ResourceStatistics) GetNetRxErrors() uint64

+ func (m *ResourceStatistics) GetNetRxPackets() uint64

+ func (m *ResourceStatistics) GetNetSNMPStatistics() *SNMPStatistics

+ func (m *ResourceStatistics) GetNetTCPActiveConnections() float64

+ func (m *ResourceStatistics) GetNetTCPRttMicrosecsP50() float64

+ func (m *ResourceStatistics) GetNetTCPRttMicrosecsP90() float64

+ func (m *ResourceStatistics) GetNetTCPRttMicrosecsP95() float64

+ func (m *ResourceStatistics) GetNetTCPRttMicrosecsP99() float64

+ func (m *ResourceStatistics) GetNetTCPTimeWaitConnections() float64

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

+ func (m *ResourceStatistics) GetNetTxBytes() uint64

+ func (m *ResourceStatistics) GetNetTxDropped() uint64

+ func (m *ResourceStatistics) GetNetTxErrors() uint64

+ func (m *ResourceStatistics) GetNetTxPackets() uint64

+ func (m *ResourceStatistics) GetPerf() *PerfStatistics

+ func (m *ResourceStatistics) GetProcesses() uint32

+ func (m *ResourceStatistics) GetThreads() uint32

+ func (m *ResourceStatistics) GetTimestamp() float64

+ func (m *ResourceStatistics) Marshal() (data []byte, err error)

+ func (m *ResourceStatistics) MarshalTo(data []byte) (int, error)

+ func (m *ResourceStatistics) Reset()

+ func (m *ResourceStatistics) Size() (n int)

+ func (m *ResourceStatistics) Unmarshal(data []byte) error

+ func (mj *ResourceStatistics) MarshalJSON() ([]byte, error)

+ func (mj *ResourceStatistics) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *ResourceStatistics) Equal(that interface{}) bool

+ func (this *ResourceStatistics) GoString() string

+ func (this *ResourceStatistics) String() string

+ func (this *ResourceStatistics) VerboseEqual(that interface{}) error

+ func (uj *ResourceStatistics) UnmarshalJSON(input []byte) error

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

+ type ResourceUsage struct

+ Executors []ResourceUsage_Executor

+ Total []Resource

+ func NewPopulatedResourceUsage(r randyMesos, easy bool) *ResourceUsage

+ func (*ResourceUsage) ProtoMessage()

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

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

+ func (m *ResourceUsage) Marshal() (data []byte, err error)

+ func (m *ResourceUsage) MarshalTo(data []byte) (int, error)

+ func (m *ResourceUsage) Reset()

+ func (m *ResourceUsage) Size() (n int)

+ func (m *ResourceUsage) Unmarshal(data []byte) error

+ func (mj *ResourceUsage) MarshalJSON() ([]byte, error)

+ func (mj *ResourceUsage) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *ResourceUsage) Equal(that interface{}) bool

+ func (this *ResourceUsage) GoString() string

+ func (this *ResourceUsage) String() string

+ func (this *ResourceUsage) VerboseEqual(that interface{}) error

+ func (uj *ResourceUsage) UnmarshalJSON(input []byte) error

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

+ type ResourceUsage_Executor struct

+ Allocated []Resource

+ ContainerID ContainerID

+ ExecutorInfo ExecutorInfo

+ Statistics *ResourceStatistics

+ Tasks []ResourceUsage_Executor_Task

+ func NewPopulatedResourceUsage_Executor(r randyMesos, easy bool) *ResourceUsage_Executor

+ func (*ResourceUsage_Executor) ProtoMessage()

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

+ func (m *ResourceUsage_Executor) GetContainerID() ContainerID

+ func (m *ResourceUsage_Executor) GetExecutorInfo() ExecutorInfo

+ func (m *ResourceUsage_Executor) GetStatistics() *ResourceStatistics

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

+ func (m *ResourceUsage_Executor) Marshal() (data []byte, err error)

+ func (m *ResourceUsage_Executor) MarshalTo(data []byte) (int, error)

+ func (m *ResourceUsage_Executor) Reset()

+ func (m *ResourceUsage_Executor) Size() (n int)

+ func (m *ResourceUsage_Executor) Unmarshal(data []byte) error

+ func (mj *ResourceUsage_Executor) MarshalJSON() ([]byte, error)

+ func (mj *ResourceUsage_Executor) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *ResourceUsage_Executor) Equal(that interface{}) bool

+ func (this *ResourceUsage_Executor) GoString() string

+ func (this *ResourceUsage_Executor) String() string

+ func (this *ResourceUsage_Executor) VerboseEqual(that interface{}) error

+ func (uj *ResourceUsage_Executor) UnmarshalJSON(input []byte) error

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

+ type ResourceUsage_Executor_Task struct

+ ID TaskID

+ Labels *Labels

+ Name string

+ Resources []Resource

+ func NewPopulatedResourceUsage_Executor_Task(r randyMesos, easy bool) *ResourceUsage_Executor_Task

+ func (*ResourceUsage_Executor_Task) ProtoMessage()

+ func (m *ResourceUsage_Executor_Task) GetID() TaskID

+ func (m *ResourceUsage_Executor_Task) GetLabels() *Labels

+ func (m *ResourceUsage_Executor_Task) GetName() string

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

+ func (m *ResourceUsage_Executor_Task) Marshal() (data []byte, err error)

+ func (m *ResourceUsage_Executor_Task) MarshalTo(data []byte) (int, error)

+ func (m *ResourceUsage_Executor_Task) Reset()

+ func (m *ResourceUsage_Executor_Task) Size() (n int)

+ func (m *ResourceUsage_Executor_Task) Unmarshal(data []byte) error

+ func (mj *ResourceUsage_Executor_Task) MarshalJSON() ([]byte, error)

+ func (mj *ResourceUsage_Executor_Task) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *ResourceUsage_Executor_Task) Equal(that interface{}) bool

+ func (this *ResourceUsage_Executor_Task) GoString() string

+ func (this *ResourceUsage_Executor_Task) String() string

+ func (this *ResourceUsage_Executor_Task) VerboseEqual(that interface{}) error

+ func (uj *ResourceUsage_Executor_Task) UnmarshalJSON(input []byte) error

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

+ type Resource_DiskInfo struct

+ Persistence *Resource_DiskInfo_Persistence

+ Source *Resource_DiskInfo_Source

+ Volume *Volume

+ func NewPopulatedResource_DiskInfo(r randyMesos, easy bool) *Resource_DiskInfo

+ func (*Resource_DiskInfo) ProtoMessage()

+ func (left *Resource_DiskInfo) Equivalent(right *Resource_DiskInfo) bool

+ func (m *Resource_DiskInfo) GetPersistence() *Resource_DiskInfo_Persistence

+ func (m *Resource_DiskInfo) GetSource() *Resource_DiskInfo_Source

+ func (m *Resource_DiskInfo) GetVolume() *Volume

+ func (m *Resource_DiskInfo) Marshal() (data []byte, err error)

+ func (m *Resource_DiskInfo) MarshalTo(data []byte) (int, error)

+ func (m *Resource_DiskInfo) Reset()

+ func (m *Resource_DiskInfo) Size() (n int)

+ func (m *Resource_DiskInfo) Unmarshal(data []byte) error

+ func (mj *Resource_DiskInfo) MarshalJSON() ([]byte, error)

+ func (mj *Resource_DiskInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Resource_DiskInfo) Equal(that interface{}) bool

+ func (this *Resource_DiskInfo) GoString() string

+ func (this *Resource_DiskInfo) String() string

+ func (this *Resource_DiskInfo) VerboseEqual(that interface{}) error

+ func (uj *Resource_DiskInfo) UnmarshalJSON(input []byte) error

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

+ type Resource_DiskInfo_Persistence struct

+ ID string

+ Principal *string

+ func NewPopulatedResource_DiskInfo_Persistence(r randyMesos, easy bool) *Resource_DiskInfo_Persistence

+ func (*Resource_DiskInfo_Persistence) ProtoMessage()

+ func (m *Resource_DiskInfo_Persistence) GetID() string

+ func (m *Resource_DiskInfo_Persistence) GetPrincipal() string

+ func (m *Resource_DiskInfo_Persistence) Marshal() (data []byte, err error)

+ func (m *Resource_DiskInfo_Persistence) MarshalTo(data []byte) (int, error)

+ func (m *Resource_DiskInfo_Persistence) Reset()

+ func (m *Resource_DiskInfo_Persistence) Size() (n int)

+ func (m *Resource_DiskInfo_Persistence) Unmarshal(data []byte) error

+ func (mj *Resource_DiskInfo_Persistence) MarshalJSON() ([]byte, error)

+ func (mj *Resource_DiskInfo_Persistence) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Resource_DiskInfo_Persistence) Equal(that interface{}) bool

+ func (this *Resource_DiskInfo_Persistence) GoString() string

+ func (this *Resource_DiskInfo_Persistence) String() string

+ func (this *Resource_DiskInfo_Persistence) VerboseEqual(that interface{}) error

+ func (uj *Resource_DiskInfo_Persistence) UnmarshalJSON(input []byte) error

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

+ type Resource_DiskInfo_Source struct

+ Mount *Resource_DiskInfo_Source_Mount

+ Path *Resource_DiskInfo_Source_Path

+ Type *Resource_DiskInfo_Source_Type

+ func NewPopulatedResource_DiskInfo_Source(r randyMesos, easy bool) *Resource_DiskInfo_Source

+ func (*Resource_DiskInfo_Source) ProtoMessage()

+ func (m *Resource_DiskInfo_Source) GetMount() *Resource_DiskInfo_Source_Mount

+ func (m *Resource_DiskInfo_Source) GetPath() *Resource_DiskInfo_Source_Path

+ func (m *Resource_DiskInfo_Source) GetType() Resource_DiskInfo_Source_Type

+ func (m *Resource_DiskInfo_Source) Marshal() (data []byte, err error)

+ func (m *Resource_DiskInfo_Source) MarshalTo(data []byte) (int, error)

+ func (m *Resource_DiskInfo_Source) Reset()

+ func (m *Resource_DiskInfo_Source) Size() (n int)

+ func (m *Resource_DiskInfo_Source) Unmarshal(data []byte) error

+ func (mj *Resource_DiskInfo_Source) MarshalJSON() ([]byte, error)

+ func (mj *Resource_DiskInfo_Source) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Resource_DiskInfo_Source) Equal(that interface{}) bool

+ func (this *Resource_DiskInfo_Source) GoString() string

+ func (this *Resource_DiskInfo_Source) String() string

+ func (this *Resource_DiskInfo_Source) VerboseEqual(that interface{}) error

+ func (uj *Resource_DiskInfo_Source) UnmarshalJSON(input []byte) error

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

+ type Resource_DiskInfo_Source_Mount struct

+ Root string

+ func NewPopulatedResource_DiskInfo_Source_Mount(r randyMesos, easy bool) *Resource_DiskInfo_Source_Mount

+ func (*Resource_DiskInfo_Source_Mount) ProtoMessage()

+ func (m *Resource_DiskInfo_Source_Mount) GetRoot() string

+ func (m *Resource_DiskInfo_Source_Mount) Marshal() (data []byte, err error)

+ func (m *Resource_DiskInfo_Source_Mount) MarshalTo(data []byte) (int, error)

+ func (m *Resource_DiskInfo_Source_Mount) Reset()

+ func (m *Resource_DiskInfo_Source_Mount) Size() (n int)

+ func (m *Resource_DiskInfo_Source_Mount) Unmarshal(data []byte) error

+ func (mj *Resource_DiskInfo_Source_Mount) MarshalJSON() ([]byte, error)

+ func (mj *Resource_DiskInfo_Source_Mount) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Resource_DiskInfo_Source_Mount) Equal(that interface{}) bool

+ func (this *Resource_DiskInfo_Source_Mount) GoString() string

+ func (this *Resource_DiskInfo_Source_Mount) String() string

+ func (this *Resource_DiskInfo_Source_Mount) VerboseEqual(that interface{}) error

+ func (uj *Resource_DiskInfo_Source_Mount) UnmarshalJSON(input []byte) error

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

+ type Resource_DiskInfo_Source_Path struct

+ Root string

+ func NewPopulatedResource_DiskInfo_Source_Path(r randyMesos, easy bool) *Resource_DiskInfo_Source_Path

+ func (*Resource_DiskInfo_Source_Path) ProtoMessage()

+ func (m *Resource_DiskInfo_Source_Path) GetRoot() string

+ func (m *Resource_DiskInfo_Source_Path) Marshal() (data []byte, err error)

+ func (m *Resource_DiskInfo_Source_Path) MarshalTo(data []byte) (int, error)

+ func (m *Resource_DiskInfo_Source_Path) Reset()

+ func (m *Resource_DiskInfo_Source_Path) Size() (n int)

+ func (m *Resource_DiskInfo_Source_Path) Unmarshal(data []byte) error

+ func (mj *Resource_DiskInfo_Source_Path) MarshalJSON() ([]byte, error)

+ func (mj *Resource_DiskInfo_Source_Path) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Resource_DiskInfo_Source_Path) Equal(that interface{}) bool

+ func (this *Resource_DiskInfo_Source_Path) GoString() string

+ func (this *Resource_DiskInfo_Source_Path) String() string

+ func (this *Resource_DiskInfo_Source_Path) VerboseEqual(that interface{}) error

+ func (uj *Resource_DiskInfo_Source_Path) UnmarshalJSON(input []byte) error

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

+ type Resource_DiskInfo_Source_Type int32

+ const MOUNT

+ const PATH

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

+ func (x Resource_DiskInfo_Source_Type) Enum() *Resource_DiskInfo_Source_Type

+ func (x Resource_DiskInfo_Source_Type) MarshalJSON() ([]byte, error)

+ func (x Resource_DiskInfo_Source_Type) String() string

+ type Resource_ReservationInfo struct

+ Labels *Labels

+ Principal *string

+ func NewPopulatedResource_ReservationInfo(r randyMesos, easy bool) *Resource_ReservationInfo

+ func (*Resource_ReservationInfo) ProtoMessage()

+ func (left *Resource_ReservationInfo) Equivalent(right *Resource_ReservationInfo) bool

+ func (m *Resource_ReservationInfo) GetLabels() *Labels

+ func (m *Resource_ReservationInfo) GetPrincipal() string

+ func (m *Resource_ReservationInfo) Marshal() (data []byte, err error)

+ func (m *Resource_ReservationInfo) MarshalTo(data []byte) (int, error)

+ func (m *Resource_ReservationInfo) Reset()

+ func (m *Resource_ReservationInfo) Size() (n int)

+ func (m *Resource_ReservationInfo) Unmarshal(data []byte) error

+ func (mj *Resource_ReservationInfo) MarshalJSON() ([]byte, error)

+ func (mj *Resource_ReservationInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (ri *Resource_ReservationInfo) Assign() FlattenOpt

+ func (this *Resource_ReservationInfo) Equal(that interface{}) bool

+ func (this *Resource_ReservationInfo) GoString() string

+ func (this *Resource_ReservationInfo) String() string

+ func (this *Resource_ReservationInfo) VerboseEqual(that interface{}) error

+ func (uj *Resource_ReservationInfo) UnmarshalJSON(input []byte) error

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

+ type Resource_RevocableInfo struct

+ func NewPopulatedResource_RevocableInfo(r randyMesos, easy bool) *Resource_RevocableInfo

+ func (*Resource_RevocableInfo) ProtoMessage()

+ func (m *Resource_RevocableInfo) Marshal() (data []byte, err error)

+ func (m *Resource_RevocableInfo) MarshalTo(data []byte) (int, error)

+ func (m *Resource_RevocableInfo) Reset()

+ func (m *Resource_RevocableInfo) Size() (n int)

+ func (m *Resource_RevocableInfo) Unmarshal(data []byte) error

+ func (mj *Resource_RevocableInfo) MarshalJSON() ([]byte, error)

+ func (mj *Resource_RevocableInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Resource_RevocableInfo) Equal(that interface{}) bool

+ func (this *Resource_RevocableInfo) GoString() string

+ func (this *Resource_RevocableInfo) String() string

+ func (this *Resource_RevocableInfo) VerboseEqual(that interface{}) error

+ func (uj *Resource_RevocableInfo) UnmarshalJSON(input []byte) error

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

+ type Resource_SharedInfo struct

+ func NewPopulatedResource_SharedInfo(r randyMesos, easy bool) *Resource_SharedInfo

+ func (*Resource_SharedInfo) ProtoMessage()

+ func (m *Resource_SharedInfo) Marshal() (data []byte, err error)

+ func (m *Resource_SharedInfo) MarshalTo(data []byte) (int, error)

+ func (m *Resource_SharedInfo) Reset()

+ func (m *Resource_SharedInfo) Size() (n int)

+ func (m *Resource_SharedInfo) Unmarshal(data []byte) error

+ func (mj *Resource_SharedInfo) MarshalJSON() ([]byte, error)

+ func (mj *Resource_SharedInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Resource_SharedInfo) Equal(that interface{}) bool

+ func (this *Resource_SharedInfo) GoString() string

+ func (this *Resource_SharedInfo) String() string

+ func (this *Resource_SharedInfo) VerboseEqual(that interface{}) error

+ func (uj *Resource_SharedInfo) UnmarshalJSON(input []byte) error

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

+ type Resources []Resource

+ func (resources *Resources) Add(that ...Resource) (rs Resources)

+ func (resources *Resources) Subtract(that ...Resource) (rs Resources)

+ func (resources Resources) CPUs() (float64, bool)

+ func (resources Resources) Clone() Resources

+ func (resources Resources) Contains(that Resource) bool

+ func (resources Resources) ContainsAll(that Resources) bool

+ func (resources Resources) Disk() (uint64, bool)

+ func (resources Resources) Equivalent(that Resources) bool

+ func (resources Resources) Find(targets Resources) (total Resources)

+ func (resources Resources) Flatten(opts ...FlattenOpt) (flattened Resources)

+ func (resources Resources) Memory() (uint64, bool)

+ func (resources Resources) Minus(that ...Resource) Resources

+ func (resources Resources) Names() (names []string)

+ func (resources Resources) Plus(that ...Resource) Resources

+ func (resources Resources) Ports() (Ranges, bool)

+ func (resources Resources) String() string

+ func (resources Resources) SumRanges(rf ResourceFilter) *Value_Ranges

+ func (resources Resources) SumScalars(rf ResourceFilter) *Value_Scalar

+ func (resources Resources) SumSets(rf ResourceFilter) *Value_Set

+ func (resources Resources) Types() map[string]Value_Type

+ func (resources Resources) Validate() error

+ type Response interface

+ type ResponseDecorator interface

+ Decorate func(Response) Response

+ type ResponseDecoratorFunc func(Response) Response

+ func (f ResponseDecoratorFunc) Decorate(r Response) Response

+ type ResponseWrapper struct

+ Closer io.Closer

+ Decoder encoding.Decoder

+ Response Response

+ func (wrapper *ResponseWrapper) Close() error

+ func (wrapper *ResponseWrapper) Decode(u encoding.Unmarshaler) error

+ type Role struct

+ Frameworks []FrameworkID

+ Name string

+ Resources []Resource

+ Weight float64

+ func NewPopulatedRole(r randyMesos, easy bool) *Role

+ func (*Role) ProtoMessage()

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

+ func (m *Role) GetName() string

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

+ func (m *Role) GetWeight() float64

+ func (m *Role) Marshal() (data []byte, err error)

+ func (m *Role) MarshalTo(data []byte) (int, error)

+ func (m *Role) Reset()

+ func (m *Role) Size() (n int)

+ func (m *Role) Unmarshal(data []byte) error

+ func (mj *Role) MarshalJSON() ([]byte, error)

+ func (mj *Role) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Role) Equal(that interface{}) bool

+ func (this *Role) GoString() string

+ func (this *Role) String() string

+ func (this *Role) VerboseEqual(that interface{}) error

+ func (uj *Role) UnmarshalJSON(input []byte) error

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

+ type RoleName string

+ func (r RoleName) Assign() FlattenOpt

+ func (r RoleName) IsDefault() bool

+ func (r RoleName) Proto() *string

+ type SNMPStatistics struct

+ ICMPStats *IcmpStatistics

+ IPStats *IpStatistics

+ TCPStats *TcpStatistics

+ UDPStats *UdpStatistics

+ func NewPopulatedSNMPStatistics(r randyMesos, easy bool) *SNMPStatistics

+ func (*SNMPStatistics) ProtoMessage()

+ func (m *SNMPStatistics) GetICMPStats() *IcmpStatistics

+ func (m *SNMPStatistics) GetIPStats() *IpStatistics

+ func (m *SNMPStatistics) GetTCPStats() *TcpStatistics

+ func (m *SNMPStatistics) GetUDPStats() *UdpStatistics

+ func (m *SNMPStatistics) Marshal() (data []byte, err error)

+ func (m *SNMPStatistics) MarshalTo(data []byte) (int, error)

+ func (m *SNMPStatistics) Reset()

+ func (m *SNMPStatistics) Size() (n int)

+ func (m *SNMPStatistics) Unmarshal(data []byte) error

+ func (mj *SNMPStatistics) MarshalJSON() ([]byte, error)

+ func (mj *SNMPStatistics) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *SNMPStatistics) Equal(that interface{}) bool

+ func (this *SNMPStatistics) GoString() string

+ func (this *SNMPStatistics) String() string

+ func (this *SNMPStatistics) VerboseEqual(that interface{}) error

+ func (uj *SNMPStatistics) UnmarshalJSON(input []byte) error

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

+ type Status int32

+ const DRIVER_ABORTED

+ const DRIVER_NOT_STARTED

+ const DRIVER_RUNNING

+ const DRIVER_STOPPED

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

+ func (x Status) Enum() *Status

+ func (x Status) MarshalJSON() ([]byte, error)

+ func (x Status) String() string

+ type Task struct

+ AgentID AgentID

+ Container *ContainerInfo

+ Discovery *DiscoveryInfo

+ ExecutorID *ExecutorID

+ FrameworkID FrameworkID

+ Labels *Labels

+ Name string

+ Resources []Resource

+ State *TaskState

+ StatusUpdateState *TaskState

+ StatusUpdateUUID []byte

+ Statuses []TaskStatus

+ TaskID TaskID

+ User *string

+ func NewPopulatedTask(r randyMesos, easy bool) *Task

+ func (*Task) ProtoMessage()

+ func (m *Task) GetAgentID() AgentID

+ func (m *Task) GetContainer() *ContainerInfo

+ func (m *Task) GetDiscovery() *DiscoveryInfo

+ func (m *Task) GetExecutorID() *ExecutorID

+ func (m *Task) GetFrameworkID() FrameworkID

+ func (m *Task) GetLabels() *Labels

+ func (m *Task) GetName() string

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

+ func (m *Task) GetState() TaskState

+ func (m *Task) GetStatusUpdateState() TaskState

+ func (m *Task) GetStatusUpdateUUID() []byte

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

+ func (m *Task) GetTaskID() TaskID

+ func (m *Task) GetUser() string

+ func (m *Task) Marshal() (data []byte, err error)

+ func (m *Task) MarshalTo(data []byte) (int, error)

+ func (m *Task) Reset()

+ func (m *Task) Size() (n int)

+ func (m *Task) Unmarshal(data []byte) error

+ func (mj *Task) MarshalJSON() ([]byte, error)

+ func (mj *Task) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Task) Equal(that interface{}) bool

+ func (this *Task) GoString() string

+ func (this *Task) String() string

+ func (this *Task) VerboseEqual(that interface{}) error

+ func (uj *Task) UnmarshalJSON(input []byte) error

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

+ type TaskGroupInfo struct

+ Tasks []TaskInfo

+ func NewPopulatedTaskGroupInfo(r randyMesos, easy bool) *TaskGroupInfo

+ func (*TaskGroupInfo) ProtoMessage()

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

+ func (m *TaskGroupInfo) Marshal() (data []byte, err error)

+ func (m *TaskGroupInfo) MarshalTo(data []byte) (int, error)

+ func (m *TaskGroupInfo) Reset()

+ func (m *TaskGroupInfo) Size() (n int)

+ func (m *TaskGroupInfo) Unmarshal(data []byte) error

+ func (mj *TaskGroupInfo) MarshalJSON() ([]byte, error)

+ func (mj *TaskGroupInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *TaskGroupInfo) Equal(that interface{}) bool

+ func (this *TaskGroupInfo) GoString() string

+ func (this *TaskGroupInfo) String() string

+ func (this *TaskGroupInfo) VerboseEqual(that interface{}) error

+ func (uj *TaskGroupInfo) UnmarshalJSON(input []byte) error

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

+ type TaskID struct

+ Value string

+ func NewPopulatedTaskID(r randyMesos, easy bool) *TaskID

+ func (*TaskID) ProtoMessage()

+ func (m *TaskID) GetValue() string

+ func (m *TaskID) Marshal() (data []byte, err error)

+ func (m *TaskID) MarshalTo(data []byte) (int, error)

+ func (m *TaskID) Reset()

+ func (m *TaskID) Size() (n int)

+ func (m *TaskID) Unmarshal(data []byte) error

+ func (mj *TaskID) MarshalJSON() ([]byte, error)

+ func (mj *TaskID) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *TaskID) Equal(that interface{}) bool

+ func (this *TaskID) GoString() string

+ func (this *TaskID) String() string

+ func (this *TaskID) VerboseEqual(that interface{}) error

+ func (uj *TaskID) UnmarshalJSON(input []byte) error

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

+ type TaskInfo struct

+ AgentID AgentID

+ Command *CommandInfo

+ Container *ContainerInfo

+ Data []byte

+ Discovery *DiscoveryInfo

+ Executor *ExecutorInfo

+ HealthCheck *HealthCheck

+ KillPolicy *KillPolicy

+ Labels *Labels

+ Name string

+ Resources []Resource

+ TaskID TaskID

+ func NewPopulatedTaskInfo(r randyMesos, easy bool) *TaskInfo

+ func (*TaskInfo) ProtoMessage()

+ func (m *TaskInfo) GetAgentID() AgentID

+ func (m *TaskInfo) GetCommand() *CommandInfo

+ func (m *TaskInfo) GetContainer() *ContainerInfo

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

+ func (m *TaskInfo) GetDiscovery() *DiscoveryInfo

+ func (m *TaskInfo) GetExecutor() *ExecutorInfo

+ func (m *TaskInfo) GetHealthCheck() *HealthCheck

+ func (m *TaskInfo) GetKillPolicy() *KillPolicy

+ func (m *TaskInfo) GetLabels() *Labels

+ func (m *TaskInfo) GetName() string

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

+ func (m *TaskInfo) GetTaskID() TaskID

+ func (m *TaskInfo) Marshal() (data []byte, err error)

+ func (m *TaskInfo) MarshalTo(data []byte) (int, error)

+ func (m *TaskInfo) Reset()

+ func (m *TaskInfo) Size() (n int)

+ func (m *TaskInfo) Unmarshal(data []byte) error

+ func (mj *TaskInfo) MarshalJSON() ([]byte, error)

+ func (mj *TaskInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *TaskInfo) Equal(that interface{}) bool

+ func (this *TaskInfo) GoString() string

+ func (this *TaskInfo) String() string

+ func (this *TaskInfo) VerboseEqual(that interface{}) error

+ func (uj *TaskInfo) UnmarshalJSON(input []byte) error

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

+ type TaskState int32

+ const TASK_DROPPED

+ const TASK_ERROR

+ const TASK_FAILED

+ const TASK_FINISHED

+ const TASK_GONE

+ const TASK_GONE_BY_OPERATOR

+ const TASK_KILLED

+ const TASK_KILLING

+ const TASK_LOST

+ const TASK_RUNNING

+ const TASK_STAGING

+ const TASK_STARTING

+ const TASK_UNKNOWN

+ const TASK_UNREACHABLE

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

+ func (x TaskState) Enum() *TaskState

+ func (x TaskState) MarshalJSON() ([]byte, error)

+ func (x TaskState) String() string

+ type TaskStatus struct

+ AgentID *AgentID

+ ContainerStatus *ContainerStatus

+ Data []byte

+ ExecutorID *ExecutorID

+ Healthy *bool

+ Labels *Labels

+ Message *string

+ Reason *TaskStatus_Reason

+ Source *TaskStatus_Source

+ State *TaskState

+ TaskID TaskID

+ Timestamp *float64

+ UUID []byte

+ UnreachableTime *TimeInfo

+ func NewPopulatedTaskStatus(r randyMesos, easy bool) *TaskStatus

+ func (*TaskStatus) ProtoMessage()

+ func (m *TaskStatus) GetAgentID() *AgentID

+ func (m *TaskStatus) GetContainerStatus() *ContainerStatus

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

+ func (m *TaskStatus) GetExecutorID() *ExecutorID

+ func (m *TaskStatus) GetHealthy() bool

+ func (m *TaskStatus) GetLabels() *Labels

+ func (m *TaskStatus) GetMessage() string

+ func (m *TaskStatus) GetReason() TaskStatus_Reason

+ func (m *TaskStatus) GetSource() TaskStatus_Source

+ func (m *TaskStatus) GetState() TaskState

+ func (m *TaskStatus) GetTaskID() TaskID

+ func (m *TaskStatus) GetTimestamp() float64

+ func (m *TaskStatus) GetUUID() []byte

+ func (m *TaskStatus) GetUnreachableTime() *TimeInfo

+ func (m *TaskStatus) Marshal() (data []byte, err error)

+ func (m *TaskStatus) MarshalTo(data []byte) (int, error)

+ func (m *TaskStatus) Reset()

+ func (m *TaskStatus) Size() (n int)

+ func (m *TaskStatus) Unmarshal(data []byte) error

+ func (mj *TaskStatus) MarshalJSON() ([]byte, error)

+ func (mj *TaskStatus) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *TaskStatus) Equal(that interface{}) bool

+ func (this *TaskStatus) GoString() string

+ func (this *TaskStatus) String() string

+ func (this *TaskStatus) VerboseEqual(that interface{}) error

+ func (uj *TaskStatus) UnmarshalJSON(input []byte) error

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

+ type TaskStatus_Reason int32

+ const REASON_AGENT_DISCONNECTED

+ const REASON_AGENT_REMOVED

+ const REASON_AGENT_RESTARTED

+ const REASON_AGENT_UNKNOWN

+ const REASON_COMMAND_EXECUTOR_FAILED

+ const REASON_CONTAINER_LAUNCH_FAILED

+ const REASON_CONTAINER_LIMITATION

+ const REASON_CONTAINER_LIMITATION_DISK

+ const REASON_CONTAINER_LIMITATION_MEMORY

+ const REASON_CONTAINER_PREEMPTED

+ const REASON_CONTAINER_UPDATE_FAILED

+ const REASON_EXECUTOR_REGISTRATION_TIMEOUT

+ const REASON_EXECUTOR_REREGISTRATION_TIMEOUT

+ const REASON_EXECUTOR_TERMINATED

+ const REASON_EXECUTOR_UNREGISTERED

+ const REASON_FRAMEWORK_REMOVED

+ const REASON_GC_ERROR

+ const REASON_INVALID_FRAMEWORKID

+ const REASON_INVALID_OFFERS

+ const REASON_MASTER_DISCONNECTED

+ const REASON_RECONCILIATION

+ const REASON_RESOURCES_UNKNOWN

+ const REASON_TASK_GROUP_INVALID

+ const REASON_TASK_GROUP_UNAUTHORIZED

+ const REASON_TASK_INVALID

+ const REASON_TASK_UNAUTHORIZED

+ const REASON_TASK_UNKNOWN

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

+ func (x TaskStatus_Reason) Enum() *TaskStatus_Reason

+ func (x TaskStatus_Reason) MarshalJSON() ([]byte, error)

+ func (x TaskStatus_Reason) String() string

+ type TaskStatus_Source int32

+ const SOURCE_AGENT

+ const SOURCE_EXECUTOR

+ const SOURCE_MASTER

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

+ func (x TaskStatus_Source) Enum() *TaskStatus_Source

+ func (x TaskStatus_Source) MarshalJSON() ([]byte, error)

+ func (x TaskStatus_Source) String() string

+ type TcpStatistics struct

+ ActiveOpens *int64

+ AttemptFails *int64

+ CurrEstab *int64

+ EstabResets *int64

+ InCsumErrors *int64

+ InErrs *int64

+ InSegs *int64

+ MaxConn *int64

+ OutRsts *int64

+ OutSegs *int64

+ PassiveOpens *int64

+ RetransSegs *int64

+ RtoAlgorithm *int64

+ RtoMax *int64

+ RtoMin *int64

+ func NewPopulatedTcpStatistics(r randyMesos, easy bool) *TcpStatistics

+ func (*TcpStatistics) ProtoMessage()

+ func (m *TcpStatistics) GetActiveOpens() int64

+ func (m *TcpStatistics) GetAttemptFails() int64

+ func (m *TcpStatistics) GetCurrEstab() int64

+ func (m *TcpStatistics) GetEstabResets() int64

+ func (m *TcpStatistics) GetInCsumErrors() int64

+ func (m *TcpStatistics) GetInErrs() int64

+ func (m *TcpStatistics) GetInSegs() int64

+ func (m *TcpStatistics) GetMaxConn() int64

+ func (m *TcpStatistics) GetOutRsts() int64

+ func (m *TcpStatistics) GetOutSegs() int64

+ func (m *TcpStatistics) GetPassiveOpens() int64

+ func (m *TcpStatistics) GetRetransSegs() int64

+ func (m *TcpStatistics) GetRtoAlgorithm() int64

+ func (m *TcpStatistics) GetRtoMax() int64

+ func (m *TcpStatistics) GetRtoMin() int64

+ func (m *TcpStatistics) Marshal() (data []byte, err error)

+ func (m *TcpStatistics) MarshalTo(data []byte) (int, error)

+ func (m *TcpStatistics) Reset()

+ func (m *TcpStatistics) Size() (n int)

+ func (m *TcpStatistics) Unmarshal(data []byte) error

+ func (mj *TcpStatistics) MarshalJSON() ([]byte, error)

+ func (mj *TcpStatistics) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *TcpStatistics) Equal(that interface{}) bool

+ func (this *TcpStatistics) GoString() string

+ func (this *TcpStatistics) String() string

+ func (this *TcpStatistics) VerboseEqual(that interface{}) error

+ func (uj *TcpStatistics) UnmarshalJSON(input []byte) error

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

+ type TimeInfo struct

+ Nanoseconds int64

+ func NewPopulatedTimeInfo(r randyMesos, easy bool) *TimeInfo

+ func (*TimeInfo) ProtoMessage()

+ func (m *TimeInfo) GetNanoseconds() int64

+ func (m *TimeInfo) Marshal() (data []byte, err error)

+ func (m *TimeInfo) MarshalTo(data []byte) (int, error)

+ func (m *TimeInfo) Reset()

+ func (m *TimeInfo) Size() (n int)

+ func (m *TimeInfo) Unmarshal(data []byte) error

+ func (mj *TimeInfo) MarshalJSON() ([]byte, error)

+ func (mj *TimeInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *TimeInfo) Equal(that interface{}) bool

+ func (this *TimeInfo) GoString() string

+ func (this *TimeInfo) String() string

+ func (this *TimeInfo) VerboseEqual(that interface{}) error

+ func (uj *TimeInfo) UnmarshalJSON(input []byte) error

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

+ type TrafficControlStatistics struct

+ Backlog *uint64

+ Bytes *uint64

+ Drops *uint64

+ ID string

+ Overlimits *uint64

+ Packets *uint64

+ Qlen *uint64

+ RateBPS *uint64

+ RatePPS *uint64

+ Requeues *uint64

+ func NewPopulatedTrafficControlStatistics(r randyMesos, easy bool) *TrafficControlStatistics

+ func (*TrafficControlStatistics) ProtoMessage()

+ func (m *TrafficControlStatistics) GetBacklog() uint64

+ func (m *TrafficControlStatistics) GetBytes() uint64

+ func (m *TrafficControlStatistics) GetDrops() uint64

+ func (m *TrafficControlStatistics) GetID() string

+ func (m *TrafficControlStatistics) GetOverlimits() uint64

+ func (m *TrafficControlStatistics) GetPackets() uint64

+ func (m *TrafficControlStatistics) GetQlen() uint64

+ func (m *TrafficControlStatistics) GetRateBPS() uint64

+ func (m *TrafficControlStatistics) GetRatePPS() uint64

+ func (m *TrafficControlStatistics) GetRequeues() uint64

+ func (m *TrafficControlStatistics) Marshal() (data []byte, err error)

+ func (m *TrafficControlStatistics) MarshalTo(data []byte) (int, error)

+ func (m *TrafficControlStatistics) Reset()

+ func (m *TrafficControlStatistics) Size() (n int)

+ func (m *TrafficControlStatistics) Unmarshal(data []byte) error

+ func (mj *TrafficControlStatistics) MarshalJSON() ([]byte, error)

+ func (mj *TrafficControlStatistics) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *TrafficControlStatistics) Equal(that interface{}) bool

+ func (this *TrafficControlStatistics) GoString() string

+ func (this *TrafficControlStatistics) String() string

+ func (this *TrafficControlStatistics) VerboseEqual(that interface{}) error

+ func (uj *TrafficControlStatistics) UnmarshalJSON(input []byte) error

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

+ type URL struct

+ Address Address

+ Fragment *string

+ Path *string

+ Query []Parameter

+ Scheme string

+ func NewPopulatedURL(r randyMesos, easy bool) *URL

+ func (*URL) ProtoMessage()

+ func (m *URL) GetAddress() Address

+ func (m *URL) GetFragment() string

+ func (m *URL) GetPath() string

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

+ func (m *URL) GetScheme() string

+ func (m *URL) Marshal() (data []byte, err error)

+ func (m *URL) MarshalTo(data []byte) (int, error)

+ func (m *URL) Reset()

+ func (m *URL) Size() (n int)

+ func (m *URL) Unmarshal(data []byte) error

+ func (mj *URL) MarshalJSON() ([]byte, error)

+ func (mj *URL) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *URL) Equal(that interface{}) bool

+ func (this *URL) GoString() string

+ func (this *URL) String() string

+ func (this *URL) VerboseEqual(that interface{}) error

+ func (uj *URL) UnmarshalJSON(input []byte) error

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

+ type UdpStatistics struct

+ IgnoredMulti *int64

+ InCsumErrors *int64

+ InDatagrams *int64

+ InErrors *int64

+ NoPorts *int64

+ OutDatagrams *int64

+ RcvbufErrors *int64

+ SndbufErrors *int64

+ func NewPopulatedUdpStatistics(r randyMesos, easy bool) *UdpStatistics

+ func (*UdpStatistics) ProtoMessage()

+ func (m *UdpStatistics) GetIgnoredMulti() int64

+ func (m *UdpStatistics) GetInCsumErrors() int64

+ func (m *UdpStatistics) GetInDatagrams() int64

+ func (m *UdpStatistics) GetInErrors() int64

+ func (m *UdpStatistics) GetNoPorts() int64

+ func (m *UdpStatistics) GetOutDatagrams() int64

+ func (m *UdpStatistics) GetRcvbufErrors() int64

+ func (m *UdpStatistics) GetSndbufErrors() int64

+ func (m *UdpStatistics) Marshal() (data []byte, err error)

+ func (m *UdpStatistics) MarshalTo(data []byte) (int, error)

+ func (m *UdpStatistics) Reset()

+ func (m *UdpStatistics) Size() (n int)

+ func (m *UdpStatistics) Unmarshal(data []byte) error

+ func (mj *UdpStatistics) MarshalJSON() ([]byte, error)

+ func (mj *UdpStatistics) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *UdpStatistics) Equal(that interface{}) bool

+ func (this *UdpStatistics) GoString() string

+ func (this *UdpStatistics) String() string

+ func (this *UdpStatistics) VerboseEqual(that interface{}) error

+ func (uj *UdpStatistics) UnmarshalJSON(input []byte) error

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

+ type Unavailability struct

+ Duration *DurationInfo

+ Start TimeInfo

+ func NewPopulatedUnavailability(r randyMesos, easy bool) *Unavailability

+ func (*Unavailability) ProtoMessage()

+ func (m *Unavailability) GetDuration() *DurationInfo

+ func (m *Unavailability) GetStart() TimeInfo

+ func (m *Unavailability) Marshal() (data []byte, err error)

+ func (m *Unavailability) MarshalTo(data []byte) (int, error)

+ func (m *Unavailability) Reset()

+ func (m *Unavailability) Size() (n int)

+ func (m *Unavailability) Unmarshal(data []byte) error

+ func (mj *Unavailability) MarshalJSON() ([]byte, error)

+ func (mj *Unavailability) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Unavailability) Equal(that interface{}) bool

+ func (this *Unavailability) GoString() string

+ func (this *Unavailability) String() string

+ func (this *Unavailability) VerboseEqual(that interface{}) error

+ func (uj *Unavailability) UnmarshalJSON(input []byte) error

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

+ type Value struct

+ Ranges *Value_Ranges

+ Scalar *Value_Scalar

+ Set *Value_Set

+ Text *Value_Text

+ Type Value_Type

+ func NewPopulatedValue(r randyMesos, easy bool) *Value

+ func (*Value) ProtoMessage()

+ func (m *Value) GetRanges() *Value_Ranges

+ func (m *Value) GetScalar() *Value_Scalar

+ func (m *Value) GetSet() *Value_Set

+ func (m *Value) GetText() *Value_Text

+ func (m *Value) GetType() Value_Type

+ func (m *Value) Marshal() (data []byte, err error)

+ func (m *Value) MarshalTo(data []byte) (int, error)

+ func (m *Value) Reset()

+ func (m *Value) Size() (n int)

+ func (m *Value) Unmarshal(data []byte) error

+ func (mj *Value) MarshalJSON() ([]byte, error)

+ func (mj *Value) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Value) Equal(that interface{}) bool

+ func (this *Value) GoString() string

+ func (this *Value) String() string

+ func (this *Value) VerboseEqual(that interface{}) error

+ func (uj *Value) UnmarshalJSON(input []byte) error

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

+ type Value_Range struct

+ Begin uint64

+ End uint64

+ func NewPopulatedValue_Range(r randyMesos, easy bool) *Value_Range

+ func (*Value_Range) ProtoMessage()

+ func (m *Value_Range) GetBegin() uint64

+ func (m *Value_Range) GetEnd() uint64

+ func (m *Value_Range) Marshal() (data []byte, err error)

+ func (m *Value_Range) MarshalTo(data []byte) (int, error)

+ func (m *Value_Range) Reset()

+ func (m *Value_Range) Size() (n int)

+ func (m *Value_Range) Unmarshal(data []byte) error

+ func (mj *Value_Range) MarshalJSON() ([]byte, error)

+ func (mj *Value_Range) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Value_Range) Equal(that interface{}) bool

+ func (this *Value_Range) GoString() string

+ func (this *Value_Range) String() string

+ func (this *Value_Range) VerboseEqual(that interface{}) error

+ func (uj *Value_Range) UnmarshalJSON(input []byte) error

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

+ type Value_Ranges struct

+ Range []Value_Range

+ func NewPopulatedValue_Ranges(r randyMesos, easy bool) *Value_Ranges

+ func (*Value_Ranges) ProtoMessage()

+ func (left *Value_Ranges) Add(right *Value_Ranges) *Value_Ranges

+ func (left *Value_Ranges) Compare(right *Value_Ranges) int

+ func (left *Value_Ranges) Subtract(right *Value_Ranges) *Value_Ranges

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

+ func (m *Value_Ranges) Marshal() (data []byte, err error)

+ func (m *Value_Ranges) MarshalTo(data []byte) (int, error)

+ func (m *Value_Ranges) Reset()

+ func (m *Value_Ranges) Size() (n int)

+ func (m *Value_Ranges) Unmarshal(data []byte) error

+ func (mj *Value_Ranges) MarshalJSON() ([]byte, error)

+ func (mj *Value_Ranges) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Value_Ranges) Equal(that interface{}) bool

+ func (this *Value_Ranges) GoString() string

+ func (this *Value_Ranges) String() string

+ func (this *Value_Ranges) VerboseEqual(that interface{}) error

+ func (uj *Value_Ranges) UnmarshalJSON(input []byte) error

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

+ type Value_Scalar struct

+ Value float64

+ func NewPopulatedValue_Scalar(r randyMesos, easy bool) *Value_Scalar

+ func (*Value_Scalar) ProtoMessage()

+ func (left *Value_Scalar) Add(right *Value_Scalar) *Value_Scalar

+ func (left *Value_Scalar) Compare(right *Value_Scalar) int

+ func (left *Value_Scalar) Subtract(right *Value_Scalar) *Value_Scalar

+ func (m *Value_Scalar) GetValue() float64

+ func (m *Value_Scalar) Marshal() (data []byte, err error)

+ func (m *Value_Scalar) MarshalTo(data []byte) (int, error)

+ func (m *Value_Scalar) Reset()

+ func (m *Value_Scalar) Size() (n int)

+ func (m *Value_Scalar) Unmarshal(data []byte) error

+ func (mj *Value_Scalar) MarshalJSON() ([]byte, error)

+ func (mj *Value_Scalar) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Value_Scalar) Equal(that interface{}) bool

+ func (this *Value_Scalar) GoString() string

+ func (this *Value_Scalar) String() string

+ func (this *Value_Scalar) VerboseEqual(that interface{}) error

+ func (uj *Value_Scalar) UnmarshalJSON(input []byte) error

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

+ type Value_Set struct

+ Item []string

+ func NewPopulatedValue_Set(r randyMesos, easy bool) *Value_Set

+ func (*Value_Set) ProtoMessage()

+ func (left *Value_Set) Add(right *Value_Set) *Value_Set

+ func (left *Value_Set) Compare(right *Value_Set) int

+ func (left *Value_Set) Subtract(right *Value_Set) *Value_Set

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

+ func (m *Value_Set) Marshal() (data []byte, err error)

+ func (m *Value_Set) MarshalTo(data []byte) (int, error)

+ func (m *Value_Set) Reset()

+ func (m *Value_Set) Size() (n int)

+ func (m *Value_Set) Unmarshal(data []byte) error

+ func (mj *Value_Set) MarshalJSON() ([]byte, error)

+ func (mj *Value_Set) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Value_Set) Equal(that interface{}) bool

+ func (this *Value_Set) GoString() string

+ func (this *Value_Set) String() string

+ func (this *Value_Set) VerboseEqual(that interface{}) error

+ func (uj *Value_Set) UnmarshalJSON(input []byte) error

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

+ type Value_Text struct

+ Value string

+ func NewPopulatedValue_Text(r randyMesos, easy bool) *Value_Text

+ func (*Value_Text) ProtoMessage()

+ func (m *Value_Text) GetValue() string

+ func (m *Value_Text) Marshal() (data []byte, err error)

+ func (m *Value_Text) MarshalTo(data []byte) (int, error)

+ func (m *Value_Text) Reset()

+ func (m *Value_Text) Size() (n int)

+ func (m *Value_Text) Unmarshal(data []byte) error

+ func (mj *Value_Text) MarshalJSON() ([]byte, error)

+ func (mj *Value_Text) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Value_Text) Equal(that interface{}) bool

+ func (this *Value_Text) GoString() string

+ func (this *Value_Text) String() string

+ func (this *Value_Text) VerboseEqual(that interface{}) error

+ func (uj *Value_Text) UnmarshalJSON(input []byte) error

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

+ type Value_Type int32

+ const RANGES

+ const SCALAR

+ const SET

+ const TEXT

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

+ func (x Value_Type) Enum() *Value_Type

+ func (x Value_Type) MarshalJSON() ([]byte, error)

+ func (x Value_Type) String() string

+ type VersionInfo struct

+ BuildDate *string

+ BuildTime *float64

+ BuildUser *string

+ GitBranch *string

+ GitSHA *string

+ GitTag *string

+ Version string

+ func NewPopulatedVersionInfo(r randyMesos, easy bool) *VersionInfo

+ func (*VersionInfo) ProtoMessage()

+ func (m *VersionInfo) GetBuildDate() string

+ func (m *VersionInfo) GetBuildTime() float64

+ func (m *VersionInfo) GetBuildUser() string

+ func (m *VersionInfo) GetGitBranch() string

+ func (m *VersionInfo) GetGitSHA() string

+ func (m *VersionInfo) GetGitTag() string

+ func (m *VersionInfo) GetVersion() string

+ func (m *VersionInfo) Marshal() (data []byte, err error)

+ func (m *VersionInfo) MarshalTo(data []byte) (int, error)

+ func (m *VersionInfo) Reset()

+ func (m *VersionInfo) Size() (n int)

+ func (m *VersionInfo) Unmarshal(data []byte) error

+ func (mj *VersionInfo) MarshalJSON() ([]byte, error)

+ func (mj *VersionInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *VersionInfo) Equal(that interface{}) bool

+ func (this *VersionInfo) GoString() string

+ func (this *VersionInfo) String() string

+ func (this *VersionInfo) VerboseEqual(that interface{}) error

+ func (uj *VersionInfo) UnmarshalJSON(input []byte) error

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

+ type Volume struct

+ ContainerPath string

+ HostPath *string

+ Image *Image

+ Mode *Volume_Mode

+ Source *Volume_Source

+ func NewPopulatedVolume(r randyMesos, easy bool) *Volume

+ func (*Volume) ProtoMessage()

+ func (m *Volume) GetContainerPath() string

+ func (m *Volume) GetHostPath() string

+ func (m *Volume) GetImage() *Image

+ func (m *Volume) GetMode() Volume_Mode

+ func (m *Volume) GetSource() *Volume_Source

+ func (m *Volume) Marshal() (data []byte, err error)

+ func (m *Volume) MarshalTo(data []byte) (int, error)

+ func (m *Volume) Reset()

+ func (m *Volume) Size() (n int)

+ func (m *Volume) Unmarshal(data []byte) error

+ func (mj *Volume) MarshalJSON() ([]byte, error)

+ func (mj *Volume) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Volume) Equal(that interface{}) bool

+ func (this *Volume) GoString() string

+ func (this *Volume) String() string

+ func (this *Volume) VerboseEqual(that interface{}) error

+ func (uj *Volume) UnmarshalJSON(input []byte) error

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

+ type Volume_Mode int32

+ const RO

+ const RW

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

+ func (x Volume_Mode) Enum() *Volume_Mode

+ func (x Volume_Mode) MarshalJSON() ([]byte, error)

+ func (x Volume_Mode) String() string

+ type Volume_Source struct

+ DockerVolume *Volume_Source_DockerVolume

+ SandboxPath *Volume_Source_SandboxPath

+ Type Volume_Source_Type

+ func NewPopulatedVolume_Source(r randyMesos, easy bool) *Volume_Source

+ func (*Volume_Source) ProtoMessage()

+ func (m *Volume_Source) GetDockerVolume() *Volume_Source_DockerVolume

+ func (m *Volume_Source) GetSandboxPath() *Volume_Source_SandboxPath

+ func (m *Volume_Source) GetType() Volume_Source_Type

+ func (m *Volume_Source) Marshal() (data []byte, err error)

+ func (m *Volume_Source) MarshalTo(data []byte) (int, error)

+ func (m *Volume_Source) Reset()

+ func (m *Volume_Source) Size() (n int)

+ func (m *Volume_Source) Unmarshal(data []byte) error

+ func (mj *Volume_Source) MarshalJSON() ([]byte, error)

+ func (mj *Volume_Source) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Volume_Source) Equal(that interface{}) bool

+ func (this *Volume_Source) GoString() string

+ func (this *Volume_Source) String() string

+ func (this *Volume_Source) VerboseEqual(that interface{}) error

+ func (uj *Volume_Source) UnmarshalJSON(input []byte) error

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

+ type Volume_Source_DockerVolume struct

+ Driver *string

+ DriverOptions *Parameters

+ Name string

+ func NewPopulatedVolume_Source_DockerVolume(r randyMesos, easy bool) *Volume_Source_DockerVolume

+ func (*Volume_Source_DockerVolume) ProtoMessage()

+ func (m *Volume_Source_DockerVolume) GetDriver() string

+ func (m *Volume_Source_DockerVolume) GetDriverOptions() *Parameters

+ func (m *Volume_Source_DockerVolume) GetName() string

+ func (m *Volume_Source_DockerVolume) Marshal() (data []byte, err error)

+ func (m *Volume_Source_DockerVolume) MarshalTo(data []byte) (int, error)

+ func (m *Volume_Source_DockerVolume) Reset()

+ func (m *Volume_Source_DockerVolume) Size() (n int)

+ func (m *Volume_Source_DockerVolume) Unmarshal(data []byte) error

+ func (mj *Volume_Source_DockerVolume) MarshalJSON() ([]byte, error)

+ func (mj *Volume_Source_DockerVolume) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Volume_Source_DockerVolume) Equal(that interface{}) bool

+ func (this *Volume_Source_DockerVolume) GoString() string

+ func (this *Volume_Source_DockerVolume) String() string

+ func (this *Volume_Source_DockerVolume) VerboseEqual(that interface{}) error

+ func (uj *Volume_Source_DockerVolume) UnmarshalJSON(input []byte) error

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

+ type Volume_Source_SandboxPath struct

+ Path string

+ Type *Volume_Source_SandboxPath_Type

+ func NewPopulatedVolume_Source_SandboxPath(r randyMesos, easy bool) *Volume_Source_SandboxPath

+ func (*Volume_Source_SandboxPath) ProtoMessage()

+ func (m *Volume_Source_SandboxPath) GetPath() string

+ func (m *Volume_Source_SandboxPath) GetType() Volume_Source_SandboxPath_Type

+ func (m *Volume_Source_SandboxPath) Marshal() (data []byte, err error)

+ func (m *Volume_Source_SandboxPath) MarshalTo(data []byte) (int, error)

+ func (m *Volume_Source_SandboxPath) Reset()

+ func (m *Volume_Source_SandboxPath) Size() (n int)

+ func (m *Volume_Source_SandboxPath) Unmarshal(data []byte) error

+ func (mj *Volume_Source_SandboxPath) MarshalJSON() ([]byte, error)

+ func (mj *Volume_Source_SandboxPath) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *Volume_Source_SandboxPath) Equal(that interface{}) bool

+ func (this *Volume_Source_SandboxPath) GoString() string

+ func (this *Volume_Source_SandboxPath) String() string

+ func (this *Volume_Source_SandboxPath) VerboseEqual(that interface{}) error

+ func (uj *Volume_Source_SandboxPath) UnmarshalJSON(input []byte) error

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

+ type Volume_Source_SandboxPath_Type int32

+ const Volume_Source_SandboxPath_PARENT

+ const Volume_Source_SandboxPath_SELF

+ const Volume_Source_SandboxPath_UNKNOWN

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

+ func (x Volume_Source_SandboxPath_Type) Enum() *Volume_Source_SandboxPath_Type

+ func (x Volume_Source_SandboxPath_Type) MarshalJSON() ([]byte, error)

+ func (x Volume_Source_SandboxPath_Type) String() string

+ type Volume_Source_Type int32

+ const Volume_Source_DOCKER_VOLUME

+ const Volume_Source_SANDBOX_PATH

+ const Volume_Source_UNKNOWN

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

+ func (x Volume_Source_Type) Enum() *Volume_Source_Type

+ func (x Volume_Source_Type) MarshalJSON() ([]byte, error)

+ func (x Volume_Source_Type) String() string

+ type WeightInfo struct

+ Role *string

+ Weight float64

+ func NewPopulatedWeightInfo(r randyMesos, easy bool) *WeightInfo

+ func (*WeightInfo) ProtoMessage()

+ func (m *WeightInfo) GetRole() string

+ func (m *WeightInfo) GetWeight() float64

+ func (m *WeightInfo) Marshal() (data []byte, err error)

+ func (m *WeightInfo) MarshalTo(data []byte) (int, error)

+ func (m *WeightInfo) Reset()

+ func (m *WeightInfo) Size() (n int)

+ func (m *WeightInfo) Unmarshal(data []byte) error

+ func (mj *WeightInfo) MarshalJSON() ([]byte, error)

+ func (mj *WeightInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (this *WeightInfo) Equal(that interface{}) bool

+ func (this *WeightInfo) GoString() string

+ func (this *WeightInfo) String() string

+ func (this *WeightInfo) VerboseEqual(that interface{}) error

+ func (uj *WeightInfo) UnmarshalJSON(input []byte) error

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

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