mesosproto

package

Go to main page

Versions in this module

v1

v1.3.0-alpha.3

Apr 26, 2016

v1.3.0-alpha.2

Apr 11, 2016

v1.3.0-alpha.1

Mar 29, 2016

v1.3.0-alpha.0

Mar 4, 2016

v1.2.5-beta.0

May 6, 2016

v1.2.4-beta.0

Apr 22, 2016

v1.2.3

Apr 22, 2016

v1.2.3-beta.0

Apr 8, 2016

v1.2.2

Apr 8, 2016

v1.2.2-beta.0

Apr 1, 2016

v1.2.1

Apr 1, 2016

v1.2.1-beta.0

Mar 16, 2016

v1.2.0

Mar 16, 2016

Changes in this version

+ var ErrIntOverflowAuthentication = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowMesos = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowMessages = fmt.Errorf("proto: integer overflow")

+ 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

type ContainerInfo

+ NetworkInfos []*NetworkInfo

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

+ type ContainerStatus struct

+ NetworkInfos []*NetworkInfo

+ XXX_unrecognized []byte

+ func NewPopulatedContainerStatus(r randyMesos, easy bool) *ContainerStatus

+ func (*ContainerStatus) ProtoMessage()

+ 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 (this *ContainerStatus) Equal(that interface{}) bool

+ func (this *ContainerStatus) GoString() string

+ func (this *ContainerStatus) String() string

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

+ type DurationInfo struct

+ Nanoseconds *int64

+ XXX_unrecognized []byte

+ 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 (this *DurationInfo) Equal(that interface{}) bool

+ func (this *DurationInfo) GoString() string

+ func (this *DurationInfo) String() string

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

+ type Image_Appc struct

+ Id *string

+ Labels *Labels

+ Name *string

+ XXX_unrecognized []byte

+ 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 (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

+ type InternalNetworkError struct

+ Pid *string

+ Session *string

+ XXX_unrecognized []byte

+ func (*InternalNetworkError) ProtoMessage()

+ func (m *InternalNetworkError) GetPid() string

+ func (m *InternalNetworkError) GetSession() string

+ func (m *InternalNetworkError) Reset()

+ func (m *InternalNetworkError) String() string

+ type InverseOffer struct

+ FrameworkId *FrameworkID

+ Id *OfferID

+ Resources []*Resource

+ SlaveId *SlaveID

+ Unavailability *Unavailability

+ Url *URL

+ XXX_unrecognized []byte

+ func NewPopulatedInverseOffer(r randyMesos, easy bool) *InverseOffer

+ func (*InverseOffer) ProtoMessage()

+ func (m *InverseOffer) GetFrameworkId() *FrameworkID

+ func (m *InverseOffer) GetId() *OfferID

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

+ func (m *InverseOffer) GetSlaveId() *SlaveID

+ func (m *InverseOffer) GetUnavailability() *Unavailability

+ func (m *InverseOffer) GetUrl() *URL

+ 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 (this *InverseOffer) Equal(that interface{}) bool

+ func (this *InverseOffer) GoString() string

+ func (this *InverseOffer) String() string

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

+ type MachineID struct

+ Hostname *string

+ Ip *string

+ XXX_unrecognized []byte

+ 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 (this *MachineID) Equal(that interface{}) bool

+ func (this *MachineID) GoString() string

+ func (this *MachineID) String() string

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

+ type MachineInfo struct

+ Id *MachineID

+ Mode *MachineInfo_Mode

+ Unavailability *Unavailability

+ XXX_unrecognized []byte

+ 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 (this *MachineInfo) Equal(that interface{}) bool

+ func (this *MachineInfo) GoString() string

+ func (this *MachineInfo) String() string

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

+ type MachineInfo_Mode int32

+ const MachineInfo_DOWN

+ const MachineInfo_DRAINING

+ const MachineInfo_UP

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

+ func (x MachineInfo_Mode) Enum() *MachineInfo_Mode

+ func (x MachineInfo_Mode) String() string

+ type NetworkInfo struct

+ Groups []string

+ IpAddress *string

+ IpAddresses []*NetworkInfo_IPAddress

+ Labels *Labels

+ Protocol *NetworkInfo_Protocol

+ XXX_unrecognized []byte

+ func NewPopulatedNetworkInfo(r randyMesos, easy bool) *NetworkInfo

+ func (*NetworkInfo) ProtoMessage()

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

+ func (m *NetworkInfo) GetIpAddress() string

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

+ func (m *NetworkInfo) GetLabels() *Labels

+ func (m *NetworkInfo) GetProtocol() NetworkInfo_Protocol

+ 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 (this *NetworkInfo) Equal(that interface{}) bool

+ func (this *NetworkInfo) GoString() string

+ func (this *NetworkInfo) String() string

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

+ type NetworkInfo_IPAddress struct

+ IpAddress *string

+ Protocol *NetworkInfo_Protocol

+ XXX_unrecognized []byte

+ 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 (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

+ type NetworkInfo_Protocol int32

+ const NetworkInfo_IPv4

+ const NetworkInfo_IPv6

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

+ func (x NetworkInfo_Protocol) Enum() *NetworkInfo_Protocol

+ func (x NetworkInfo_Protocol) String() string

type Offer

+ Unavailability *Unavailability

+ func (m *Offer) GetUnavailability() *Unavailability

type Port

+ Visibility *DiscoveryInfo_Visibility

+ func (m *Port) GetVisibility() DiscoveryInfo_Visibility

type ResourceOffersMessage

+ InverseOffers []*InverseOffer

+ func (m *ResourceOffersMessage) GetInverseOffers() []*InverseOffer

type ResourceUsage_Executor

+ ContainerId *ContainerID

+ func (m *ResourceUsage_Executor) GetContainerId() *ContainerID

type TaskStatus

+ ContainerStatus *ContainerStatus

+ func (m *TaskStatus) GetContainerStatus() *ContainerStatus

type TaskStatus_Reason

+ const TaskStatus_REASON_CONTAINER_LAUNCH_FAILED

+ const TaskStatus_REASON_CONTAINER_LIMITATION

+ const TaskStatus_REASON_CONTAINER_LIMITATION_DISK

+ const TaskStatus_REASON_CONTAINER_LIMITATION_MEMORY

+ const TaskStatus_REASON_CONTAINER_PREEMPTED

+ const TaskStatus_REASON_CONTAINER_UPDATE_FAILED

+ const TaskStatus_REASON_EXECUTOR_REGISTRATION_TIMEOUT

+ const TaskStatus_REASON_EXECUTOR_REREGISTRATION_TIMEOUT

+ type TimeInfo struct

+ Nanoseconds *int64

+ XXX_unrecognized []byte

+ 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 (this *TimeInfo) Equal(that interface{}) bool

+ func (this *TimeInfo) GoString() string

+ func (this *TimeInfo) String() string

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

+ type Unavailability struct

+ Duration *DurationInfo

+ Start *TimeInfo

+ XXX_unrecognized []byte

+ 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 (this *Unavailability) Equal(that interface{}) bool

+ func (this *Unavailability) GoString() string

+ func (this *Unavailability) String() string

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

v1.2.0-beta.1

Mar 11, 2016

v1.2.0-beta.0

Mar 4, 2016

v1.2.0-alpha.8

Feb 19, 2016

v1.2.0-alpha.7

Feb 2, 2016

v1.2.0-alpha.6

Jan 13, 2016

v1.2.0-alpha.5

Dec 15, 2015

v1.2.0-alpha.4

Nov 25, 2015

v1.2.0-alpha.3

Nov 3, 2015

v1.2.0-alpha.2

Oct 19, 2015

v1.2.0-alpha.1

Sep 25, 2015

v1.2.0-alpha.0

Sep 25, 2015

v1.1.9-beta.0

Feb 23, 2016

v1.1.8

Feb 23, 2016

v1.1.8-beta.0

Jan 27, 2016

v1.1.7

Jan 27, 2016

v1.1.7-beta.0

Jan 27, 2016

v1.1.6

Jan 27, 2016

v1.1.6-beta.0

Jan 23, 2016

v1.1.5

Jan 23, 2016

v1.1.5-beta.0

Jan 8, 2016

v1.1.4

Jan 8, 2016

v1.1.4-beta.0

Dec 7, 2015

v1.1.3

Dec 7, 2015

Changes in this version

+ var ErrInvalidLengthAuthentication = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthAuthorizer = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthContainerizer = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthMessages = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthRegistry = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthScheduler = fmt.Errorf("proto: negative length found during unmarshaling")

+ var Image_Type_name = map[int32]string

+ var Image_Type_value = map[string]int32

+ type Address struct

+ Hostname *string

+ Ip *string

+ Port *int32

+ XXX_unrecognized []byte

+ 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 (this *Address) Equal(that interface{}) bool

+ func (this *Address) GoString() string

+ func (this *Address) String() string

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

+ type AppcImageManifest struct

+ AcKind *string

+ AcVersion *string

+ Annotations []*AppcImageManifest_Annotation

+ Labels []*AppcImageManifest_Label

+ Name *string

+ XXX_unrecognized []byte

+ func NewPopulatedAppcImageManifest(r randyMesos, easy bool) *AppcImageManifest

+ func (*AppcImageManifest) ProtoMessage()

+ func (m *AppcImageManifest) GetAcKind() string

+ func (m *AppcImageManifest) GetAcVersion() string

+ func (m *AppcImageManifest) GetAnnotations() []*AppcImageManifest_Annotation

+ func (m *AppcImageManifest) GetLabels() []*AppcImageManifest_Label

+ func (m *AppcImageManifest) GetName() string

+ func (m *AppcImageManifest) Marshal() (data []byte, err error)

+ func (m *AppcImageManifest) MarshalTo(data []byte) (int, error)

+ func (m *AppcImageManifest) Reset()

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

+ func (m *AppcImageManifest) Unmarshal(data []byte) error

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

+ func (this *AppcImageManifest) GoString() string

+ func (this *AppcImageManifest) String() string

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

+ type AppcImageManifest_Annotation struct

+ Name *string

+ Value *string

+ XXX_unrecognized []byte

+ func NewPopulatedAppcImageManifest_Annotation(r randyMesos, easy bool) *AppcImageManifest_Annotation

+ func (*AppcImageManifest_Annotation) ProtoMessage()

+ func (m *AppcImageManifest_Annotation) GetName() string

+ func (m *AppcImageManifest_Annotation) GetValue() string

+ func (m *AppcImageManifest_Annotation) Marshal() (data []byte, err error)

+ func (m *AppcImageManifest_Annotation) MarshalTo(data []byte) (int, error)

+ func (m *AppcImageManifest_Annotation) Reset()

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

+ func (m *AppcImageManifest_Annotation) Unmarshal(data []byte) error

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

+ func (this *AppcImageManifest_Annotation) GoString() string

+ func (this *AppcImageManifest_Annotation) String() string

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

+ type AppcImageManifest_Label struct

+ Name *string

+ Value *string

+ XXX_unrecognized []byte

+ func NewPopulatedAppcImageManifest_Label(r randyMesos, easy bool) *AppcImageManifest_Label

+ func (*AppcImageManifest_Label) ProtoMessage()

+ func (m *AppcImageManifest_Label) GetName() string

+ func (m *AppcImageManifest_Label) GetValue() string

+ func (m *AppcImageManifest_Label) Marshal() (data []byte, err error)

+ func (m *AppcImageManifest_Label) MarshalTo(data []byte) (int, error)

+ func (m *AppcImageManifest_Label) Reset()

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

+ func (m *AppcImageManifest_Label) Unmarshal(data []byte) error

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

+ func (this *AppcImageManifest_Label) GoString() string

+ func (this *AppcImageManifest_Label) String() string

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

type Archive

+ func NewPopulatedArchive(r randyMessages, easy bool) *Archive

+ func (m *Archive) Marshal() (data []byte, err error)

+ func (m *Archive) MarshalTo(data []byte) (int, error)

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

+ func (m *Archive) Unmarshal(data []byte) error

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

+ func (this *Archive) GoString() string

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

type Archive_Framework

+ func NewPopulatedArchive_Framework(r randyMessages, easy bool) *Archive_Framework

+ func (m *Archive_Framework) Marshal() (data []byte, err error)

+ func (m *Archive_Framework) MarshalTo(data []byte) (int, error)

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

+ func (m *Archive_Framework) Unmarshal(data []byte) error

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

+ func (this *Archive_Framework) GoString() string

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

type AuthenticateMessage

+ func NewPopulatedAuthenticateMessage(r randyAuthentication, easy bool) *AuthenticateMessage

+ func (m *AuthenticateMessage) Marshal() (data []byte, err error)

+ func (m *AuthenticateMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *AuthenticateMessage) Unmarshal(data []byte) error

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

+ func (this *AuthenticateMessage) GoString() string

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

type AuthenticationCompletedMessage

+ func NewPopulatedAuthenticationCompletedMessage(r randyAuthentication, easy bool) *AuthenticationCompletedMessage

+ func (m *AuthenticationCompletedMessage) Marshal() (data []byte, err error)

+ func (m *AuthenticationCompletedMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *AuthenticationCompletedMessage) Unmarshal(data []byte) error

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

+ func (this *AuthenticationCompletedMessage) GoString() string

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

type AuthenticationErrorMessage

+ func NewPopulatedAuthenticationErrorMessage(r randyAuthentication, easy bool) *AuthenticationErrorMessage

+ func (m *AuthenticationErrorMessage) Marshal() (data []byte, err error)

+ func (m *AuthenticationErrorMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *AuthenticationErrorMessage) Unmarshal(data []byte) error

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

+ func (this *AuthenticationErrorMessage) GoString() string

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

type AuthenticationFailedMessage

+ func NewPopulatedAuthenticationFailedMessage(r randyAuthentication, easy bool) *AuthenticationFailedMessage

+ func (m *AuthenticationFailedMessage) Marshal() (data []byte, err error)

+ func (m *AuthenticationFailedMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *AuthenticationFailedMessage) Unmarshal(data []byte) error

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

+ func (this *AuthenticationFailedMessage) GoString() string

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

type AuthenticationMechanismsMessage

+ func NewPopulatedAuthenticationMechanismsMessage(r randyAuthentication, easy bool) *AuthenticationMechanismsMessage

+ func (m *AuthenticationMechanismsMessage) Marshal() (data []byte, err error)

+ func (m *AuthenticationMechanismsMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *AuthenticationMechanismsMessage) Unmarshal(data []byte) error

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

+ func (this *AuthenticationMechanismsMessage) GoString() string

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

type AuthenticationStartMessage

+ func NewPopulatedAuthenticationStartMessage(r randyAuthentication, easy bool) *AuthenticationStartMessage

+ func (m *AuthenticationStartMessage) Marshal() (data []byte, err error)

+ func (m *AuthenticationStartMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *AuthenticationStartMessage) Unmarshal(data []byte) error

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

+ func (this *AuthenticationStartMessage) GoString() string

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

type AuthenticationStepMessage

+ func NewPopulatedAuthenticationStepMessage(r randyAuthentication, easy bool) *AuthenticationStepMessage

+ func (m *AuthenticationStepMessage) Marshal() (data []byte, err error)

+ func (m *AuthenticationStepMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *AuthenticationStepMessage) Unmarshal(data []byte) error

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

+ func (this *AuthenticationStepMessage) GoString() string

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

type Call

+ func NewPopulatedCall(r randyScheduler, easy bool) *Call

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

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

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

+ func (m *Call) Unmarshal(data []byte) error

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

+ func (this *Call) GoString() string

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

type Call_Accept

+ func NewPopulatedCall_Accept(r randyScheduler, easy bool) *Call_Accept

+ func (m *Call_Accept) Marshal() (data []byte, err error)

+ func (m *Call_Accept) MarshalTo(data []byte) (int, error)

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

+ func (m *Call_Accept) Unmarshal(data []byte) error

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

+ func (this *Call_Accept) GoString() string

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

type Call_Acknowledge

+ func NewPopulatedCall_Acknowledge(r randyScheduler, easy bool) *Call_Acknowledge

+ func (m *Call_Acknowledge) Marshal() (data []byte, err error)

+ func (m *Call_Acknowledge) MarshalTo(data []byte) (int, error)

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

+ func (m *Call_Acknowledge) Unmarshal(data []byte) error

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

+ func (this *Call_Acknowledge) GoString() string

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

type Call_Decline

+ func NewPopulatedCall_Decline(r randyScheduler, easy bool) *Call_Decline

+ func (m *Call_Decline) Marshal() (data []byte, err error)

+ func (m *Call_Decline) MarshalTo(data []byte) (int, error)

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

+ func (m *Call_Decline) Unmarshal(data []byte) error

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

+ func (this *Call_Decline) GoString() string

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

type Call_Kill

+ func NewPopulatedCall_Kill(r randyScheduler, easy bool) *Call_Kill

+ func (m *Call_Kill) Marshal() (data []byte, err error)

+ func (m *Call_Kill) MarshalTo(data []byte) (int, error)

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

+ func (m *Call_Kill) Unmarshal(data []byte) error

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

+ func (this *Call_Kill) GoString() string

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

type Call_Message

+ func NewPopulatedCall_Message(r randyScheduler, easy bool) *Call_Message

+ func (m *Call_Message) Marshal() (data []byte, err error)

+ func (m *Call_Message) MarshalTo(data []byte) (int, error)

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

+ func (m *Call_Message) Unmarshal(data []byte) error

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

+ func (this *Call_Message) GoString() string

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

type Call_Reconcile

+ func NewPopulatedCall_Reconcile(r randyScheduler, easy bool) *Call_Reconcile

+ func (m *Call_Reconcile) Marshal() (data []byte, err error)

+ func (m *Call_Reconcile) MarshalTo(data []byte) (int, error)

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

+ func (m *Call_Reconcile) Unmarshal(data []byte) error

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

+ func (this *Call_Reconcile) GoString() string

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

type Call_Reconcile_Task

+ func NewPopulatedCall_Reconcile_Task(r randyScheduler, easy bool) *Call_Reconcile_Task

+ func (m *Call_Reconcile_Task) Marshal() (data []byte, err error)

+ func (m *Call_Reconcile_Task) MarshalTo(data []byte) (int, error)

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

+ func (m *Call_Reconcile_Task) Unmarshal(data []byte) error

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

+ func (this *Call_Reconcile_Task) GoString() string

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

type Call_Request

+ func NewPopulatedCall_Request(r randyScheduler, easy bool) *Call_Request

+ func (m *Call_Request) Marshal() (data []byte, err error)

+ func (m *Call_Request) MarshalTo(data []byte) (int, error)

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

+ func (m *Call_Request) Unmarshal(data []byte) error

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

+ func (this *Call_Request) GoString() string

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

type Call_Shutdown

+ func NewPopulatedCall_Shutdown(r randyScheduler, easy bool) *Call_Shutdown

+ func (m *Call_Shutdown) Marshal() (data []byte, err error)

+ func (m *Call_Shutdown) MarshalTo(data []byte) (int, error)

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

+ func (m *Call_Shutdown) Unmarshal(data []byte) error

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

+ func (this *Call_Shutdown) GoString() string

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

type Call_Subscribe

+ func NewPopulatedCall_Subscribe(r randyScheduler, easy bool) *Call_Subscribe

+ func (m *Call_Subscribe) Marshal() (data []byte, err error)

+ func (m *Call_Subscribe) MarshalTo(data []byte) (int, error)

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

+ func (m *Call_Subscribe) Unmarshal(data []byte) error

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

+ func (this *Call_Subscribe) GoString() string

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

type CheckpointResourcesMessage

+ func NewPopulatedCheckpointResourcesMessage(r randyMessages, easy bool) *CheckpointResourcesMessage

+ func (m *CheckpointResourcesMessage) Marshal() (data []byte, err error)

+ func (m *CheckpointResourcesMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *CheckpointResourcesMessage) Unmarshal(data []byte) error

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

+ func (this *CheckpointResourcesMessage) GoString() string

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

type ContainerInfo

+ Mesos *ContainerInfo_MesosInfo

+ func (m *ContainerInfo) GetMesos() *ContainerInfo_MesosInfo

+ type ContainerInfo_MesosInfo struct

+ Image *Image

+ XXX_unrecognized []byte

+ 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 (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

type Containers

+ func NewPopulatedContainers(r randyContainerizer, easy bool) *Containers

+ func (m *Containers) Marshal() (data []byte, err error)

+ func (m *Containers) MarshalTo(data []byte) (int, error)

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

+ func (m *Containers) Unmarshal(data []byte) error

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

+ func (this *Containers) GoString() string

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

type DeactivateFrameworkMessage

+ func NewPopulatedDeactivateFrameworkMessage(r randyMessages, easy bool) *DeactivateFrameworkMessage

+ func (m *DeactivateFrameworkMessage) Marshal() (data []byte, err error)

+ func (m *DeactivateFrameworkMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *DeactivateFrameworkMessage) Unmarshal(data []byte) error

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

+ func (this *DeactivateFrameworkMessage) GoString() string

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

type Destroy

+ func NewPopulatedDestroy(r randyContainerizer, easy bool) *Destroy

+ func (m *Destroy) Marshal() (data []byte, err error)

+ func (m *Destroy) MarshalTo(data []byte) (int, error)

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

+ func (m *Destroy) Unmarshal(data []byte) error

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

+ func (this *Destroy) GoString() string

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

type Event

+ func NewPopulatedEvent(r randyScheduler, easy bool) *Event

+ func (m *Event) Marshal() (data []byte, err error)

+ func (m *Event) MarshalTo(data []byte) (int, error)

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

+ func (m *Event) Unmarshal(data []byte) error

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

+ func (this *Event) GoString() string

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

type Event_Error

+ func NewPopulatedEvent_Error(r randyScheduler, easy bool) *Event_Error

+ func (m *Event_Error) Marshal() (data []byte, err error)

+ func (m *Event_Error) MarshalTo(data []byte) (int, error)

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

+ func (m *Event_Error) Unmarshal(data []byte) error

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

+ func (this *Event_Error) GoString() string

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

type Event_Failure

+ func NewPopulatedEvent_Failure(r randyScheduler, easy bool) *Event_Failure

+ func (m *Event_Failure) Marshal() (data []byte, err error)

+ func (m *Event_Failure) MarshalTo(data []byte) (int, error)

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

+ func (m *Event_Failure) Unmarshal(data []byte) error

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

+ func (this *Event_Failure) GoString() string

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

type Event_Message

+ func NewPopulatedEvent_Message(r randyScheduler, easy bool) *Event_Message

+ func (m *Event_Message) Marshal() (data []byte, err error)

+ func (m *Event_Message) MarshalTo(data []byte) (int, error)

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

+ func (m *Event_Message) Unmarshal(data []byte) error

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

+ func (this *Event_Message) GoString() string

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

type Event_Offers

+ func NewPopulatedEvent_Offers(r randyScheduler, easy bool) *Event_Offers

+ func (m *Event_Offers) Marshal() (data []byte, err error)

+ func (m *Event_Offers) MarshalTo(data []byte) (int, error)

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

+ func (m *Event_Offers) Unmarshal(data []byte) error

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

+ func (this *Event_Offers) GoString() string

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

type Event_Rescind

+ func NewPopulatedEvent_Rescind(r randyScheduler, easy bool) *Event_Rescind

+ func (m *Event_Rescind) Marshal() (data []byte, err error)

+ func (m *Event_Rescind) MarshalTo(data []byte) (int, error)

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

+ func (m *Event_Rescind) Unmarshal(data []byte) error

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

+ func (this *Event_Rescind) GoString() string

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

type Event_Subscribed

+ HeartbeatIntervalSeconds *float64

+ func NewPopulatedEvent_Subscribed(r randyScheduler, easy bool) *Event_Subscribed

+ func (m *Event_Subscribed) GetHeartbeatIntervalSeconds() float64

+ func (m *Event_Subscribed) Marshal() (data []byte, err error)

+ func (m *Event_Subscribed) MarshalTo(data []byte) (int, error)

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

+ func (m *Event_Subscribed) Unmarshal(data []byte) error

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

+ func (this *Event_Subscribed) GoString() string

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

type Event_Type

+ const Event_HEARTBEAT

type Event_Update

+ func NewPopulatedEvent_Update(r randyScheduler, easy bool) *Event_Update

+ func (m *Event_Update) Marshal() (data []byte, err error)

+ func (m *Event_Update) MarshalTo(data []byte) (int, error)

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

+ func (m *Event_Update) Unmarshal(data []byte) error

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

+ func (this *Event_Update) GoString() string

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

type ExecutorRegisteredMessage

+ func NewPopulatedExecutorRegisteredMessage(r randyMessages, easy bool) *ExecutorRegisteredMessage

+ func (m *ExecutorRegisteredMessage) Marshal() (data []byte, err error)

+ func (m *ExecutorRegisteredMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *ExecutorRegisteredMessage) Unmarshal(data []byte) error

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

+ func (this *ExecutorRegisteredMessage) GoString() string

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

type ExecutorReregisteredMessage

+ func NewPopulatedExecutorReregisteredMessage(r randyMessages, easy bool) *ExecutorReregisteredMessage

+ func (m *ExecutorReregisteredMessage) Marshal() (data []byte, err error)

+ func (m *ExecutorReregisteredMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *ExecutorReregisteredMessage) Unmarshal(data []byte) error

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

+ func (this *ExecutorReregisteredMessage) GoString() string

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

type ExecutorToFrameworkMessage

+ func NewPopulatedExecutorToFrameworkMessage(r randyMessages, easy bool) *ExecutorToFrameworkMessage

+ func (m *ExecutorToFrameworkMessage) Marshal() (data []byte, err error)

+ func (m *ExecutorToFrameworkMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *ExecutorToFrameworkMessage) Unmarshal(data []byte) error

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

+ func (this *ExecutorToFrameworkMessage) GoString() string

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

type ExitedExecutorMessage

+ func NewPopulatedExitedExecutorMessage(r randyMessages, easy bool) *ExitedExecutorMessage

+ func (m *ExitedExecutorMessage) Marshal() (data []byte, err error)

+ func (m *ExitedExecutorMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *ExitedExecutorMessage) Unmarshal(data []byte) error

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

+ func (this *ExitedExecutorMessage) GoString() string

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

type FrameworkErrorMessage

+ func NewPopulatedFrameworkErrorMessage(r randyMessages, easy bool) *FrameworkErrorMessage

+ func (m *FrameworkErrorMessage) Marshal() (data []byte, err error)

+ func (m *FrameworkErrorMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *FrameworkErrorMessage) Unmarshal(data []byte) error

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

+ func (this *FrameworkErrorMessage) GoString() string

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

type FrameworkInfo

+ Labels *Labels

+ func (m *FrameworkInfo) GetLabels() *Labels

type FrameworkRegisteredMessage

+ func NewPopulatedFrameworkRegisteredMessage(r randyMessages, easy bool) *FrameworkRegisteredMessage

+ func (m *FrameworkRegisteredMessage) Marshal() (data []byte, err error)

+ func (m *FrameworkRegisteredMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *FrameworkRegisteredMessage) Unmarshal(data []byte) error

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

+ func (this *FrameworkRegisteredMessage) GoString() string

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

type FrameworkReregisteredMessage

+ func NewPopulatedFrameworkReregisteredMessage(r randyMessages, easy bool) *FrameworkReregisteredMessage

+ func (m *FrameworkReregisteredMessage) Marshal() (data []byte, err error)

+ func (m *FrameworkReregisteredMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *FrameworkReregisteredMessage) Unmarshal(data []byte) error

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

+ func (this *FrameworkReregisteredMessage) GoString() string

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

type FrameworkToExecutorMessage

+ func NewPopulatedFrameworkToExecutorMessage(r randyMessages, easy bool) *FrameworkToExecutorMessage

+ func (m *FrameworkToExecutorMessage) Marshal() (data []byte, err error)

+ func (m *FrameworkToExecutorMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *FrameworkToExecutorMessage) Unmarshal(data []byte) error

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

+ func (this *FrameworkToExecutorMessage) GoString() string

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

type HookExecuted

+ func NewPopulatedHookExecuted(r randyMessages, easy bool) *HookExecuted

+ func (m *HookExecuted) Marshal() (data []byte, err error)

+ func (m *HookExecuted) MarshalTo(data []byte) (int, error)

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

+ func (m *HookExecuted) Unmarshal(data []byte) error

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

+ func (this *HookExecuted) GoString() string

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

+ type Image struct

+ Appc *Image_AppC

+ Docker *Image_Docker

+ Type *Image_Type

+ XXX_unrecognized []byte

+ func NewPopulatedImage(r randyMesos, easy bool) *Image

+ func (*Image) ProtoMessage()

+ func (m *Image) GetAppc() *Image_AppC

+ 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 (this *Image) Equal(that interface{}) bool

+ func (this *Image) GoString() string

+ func (this *Image) String() string

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

+ type Image_AppC struct

+ Id *string

+ Labels *Labels

+ Name *string

+ XXX_unrecognized []byte

+ 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 (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

+ type Image_Docker struct

+ Name *string

+ XXX_unrecognized []byte

+ func NewPopulatedImage_Docker(r randyMesos, easy bool) *Image_Docker

+ func (*Image_Docker) ProtoMessage()

+ 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 (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

+ 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) String() string

type KillTaskMessage

+ func NewPopulatedKillTaskMessage(r randyMessages, easy bool) *KillTaskMessage

+ func (m *KillTaskMessage) Marshal() (data []byte, err error)

+ func (m *KillTaskMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *KillTaskMessage) Unmarshal(data []byte) error

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

+ func (this *KillTaskMessage) GoString() string

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

type Launch

+ func NewPopulatedLaunch(r randyContainerizer, easy bool) *Launch

+ func (m *Launch) Marshal() (data []byte, err error)

+ func (m *Launch) MarshalTo(data []byte) (int, error)

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

+ func (m *Launch) Unmarshal(data []byte) error

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

+ func (this *Launch) GoString() string

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

type LaunchTasksMessage

+ func NewPopulatedLaunchTasksMessage(r randyMessages, easy bool) *LaunchTasksMessage

+ func (m *LaunchTasksMessage) Marshal() (data []byte, err error)

+ func (m *LaunchTasksMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *LaunchTasksMessage) Unmarshal(data []byte) error

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

+ func (this *LaunchTasksMessage) GoString() string

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

type LostSlaveMessage

+ func NewPopulatedLostSlaveMessage(r randyMessages, easy bool) *LostSlaveMessage

+ func (m *LostSlaveMessage) Marshal() (data []byte, err error)

+ func (m *LostSlaveMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *LostSlaveMessage) Unmarshal(data []byte) error

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

+ func (this *LostSlaveMessage) GoString() string

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

type MasterInfo

+ Address *Address

+ func (m *MasterInfo) GetAddress() *Address

type MasterSlaveConnection

+ func NewPopulatedMasterSlaveConnection(r randyMessages, easy bool) *MasterSlaveConnection

+ func (m *MasterSlaveConnection) Marshal() (data []byte, err error)

+ func (m *MasterSlaveConnection) MarshalTo(data []byte) (int, error)

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

+ func (m *MasterSlaveConnection) Unmarshal(data []byte) error

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

+ func (this *MasterSlaveConnection) GoString() string

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

type Offer

+ Url *URL

+ func (m *Offer) GetUrl() *URL

type PingSlaveMessage

+ func NewPopulatedPingSlaveMessage(r randyMessages, easy bool) *PingSlaveMessage

+ func (m *PingSlaveMessage) Marshal() (data []byte, err error)

+ func (m *PingSlaveMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *PingSlaveMessage) Unmarshal(data []byte) error

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

+ func (this *PingSlaveMessage) GoString() string

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

type PongSlaveMessage

+ func NewPopulatedPongSlaveMessage(r randyMessages, easy bool) *PongSlaveMessage

+ func (m *PongSlaveMessage) Marshal() (data []byte, err error)

+ func (m *PongSlaveMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *PongSlaveMessage) Unmarshal(data []byte) error

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

+ func (this *PongSlaveMessage) GoString() string

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

type ReconcileTasksMessage

+ func NewPopulatedReconcileTasksMessage(r randyMessages, easy bool) *ReconcileTasksMessage

+ func (m *ReconcileTasksMessage) Marshal() (data []byte, err error)

+ func (m *ReconcileTasksMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *ReconcileTasksMessage) Unmarshal(data []byte) error

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

+ func (this *ReconcileTasksMessage) GoString() string

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

type ReconnectExecutorMessage

+ func NewPopulatedReconnectExecutorMessage(r randyMessages, easy bool) *ReconnectExecutorMessage

+ func (m *ReconnectExecutorMessage) Marshal() (data []byte, err error)

+ func (m *ReconnectExecutorMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *ReconnectExecutorMessage) Unmarshal(data []byte) error

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

+ func (this *ReconnectExecutorMessage) GoString() string

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

type RegisterExecutorMessage

+ func NewPopulatedRegisterExecutorMessage(r randyMessages, easy bool) *RegisterExecutorMessage

+ func (m *RegisterExecutorMessage) Marshal() (data []byte, err error)

+ func (m *RegisterExecutorMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *RegisterExecutorMessage) Unmarshal(data []byte) error

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

+ func (this *RegisterExecutorMessage) GoString() string

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

type RegisterFrameworkMessage

+ func NewPopulatedRegisterFrameworkMessage(r randyMessages, easy bool) *RegisterFrameworkMessage

+ func (m *RegisterFrameworkMessage) Marshal() (data []byte, err error)

+ func (m *RegisterFrameworkMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *RegisterFrameworkMessage) Unmarshal(data []byte) error

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

+ func (this *RegisterFrameworkMessage) GoString() string

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

type RegisterSlaveMessage

+ func NewPopulatedRegisterSlaveMessage(r randyMessages, easy bool) *RegisterSlaveMessage

+ func (m *RegisterSlaveMessage) Marshal() (data []byte, err error)

+ func (m *RegisterSlaveMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *RegisterSlaveMessage) Unmarshal(data []byte) error

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

+ func (this *RegisterSlaveMessage) GoString() string

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

type Registry

+ func NewPopulatedRegistry(r randyRegistry, easy bool) *Registry

+ func (m *Registry) Marshal() (data []byte, err error)

+ func (m *Registry) MarshalTo(data []byte) (int, error)

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

+ func (m *Registry) Unmarshal(data []byte) error

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

+ func (this *Registry) GoString() string

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

type Registry_Master

+ func NewPopulatedRegistry_Master(r randyRegistry, easy bool) *Registry_Master

+ func (m *Registry_Master) Marshal() (data []byte, err error)

+ func (m *Registry_Master) MarshalTo(data []byte) (int, error)

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

+ func (m *Registry_Master) Unmarshal(data []byte) error

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

+ func (this *Registry_Master) GoString() string

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

type Registry_Slave

+ func NewPopulatedRegistry_Slave(r randyRegistry, easy bool) *Registry_Slave

+ func (m *Registry_Slave) Marshal() (data []byte, err error)

+ func (m *Registry_Slave) MarshalTo(data []byte) (int, error)

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

+ func (m *Registry_Slave) Unmarshal(data []byte) error

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

+ func (this *Registry_Slave) GoString() string

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

type Registry_Slaves

+ func NewPopulatedRegistry_Slaves(r randyRegistry, easy bool) *Registry_Slaves

+ func (m *Registry_Slaves) Marshal() (data []byte, err error)

+ func (m *Registry_Slaves) MarshalTo(data []byte) (int, error)

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

+ func (m *Registry_Slaves) Unmarshal(data []byte) error

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

+ func (this *Registry_Slaves) GoString() string

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

type ReregisterExecutorMessage

+ func NewPopulatedReregisterExecutorMessage(r randyMessages, easy bool) *ReregisterExecutorMessage

+ func (m *ReregisterExecutorMessage) Marshal() (data []byte, err error)

+ func (m *ReregisterExecutorMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *ReregisterExecutorMessage) Unmarshal(data []byte) error

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

+ func (this *ReregisterExecutorMessage) GoString() string

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

type ReregisterFrameworkMessage

+ func NewPopulatedReregisterFrameworkMessage(r randyMessages, easy bool) *ReregisterFrameworkMessage

+ func (m *ReregisterFrameworkMessage) Marshal() (data []byte, err error)

+ func (m *ReregisterFrameworkMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *ReregisterFrameworkMessage) Unmarshal(data []byte) error

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

+ func (this *ReregisterFrameworkMessage) GoString() string

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

type ReregisterSlaveMessage

+ func NewPopulatedReregisterSlaveMessage(r randyMessages, easy bool) *ReregisterSlaveMessage

+ func (m *ReregisterSlaveMessage) Marshal() (data []byte, err error)

+ func (m *ReregisterSlaveMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *ReregisterSlaveMessage) Unmarshal(data []byte) error

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

+ func (this *ReregisterSlaveMessage) GoString() string

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

type RescindResourceOfferMessage

+ func NewPopulatedRescindResourceOfferMessage(r randyMessages, easy bool) *RescindResourceOfferMessage

+ func (m *RescindResourceOfferMessage) Marshal() (data []byte, err error)

+ func (m *RescindResourceOfferMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *RescindResourceOfferMessage) Unmarshal(data []byte) error

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

+ func (this *RescindResourceOfferMessage) GoString() string

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

type ResourceOffersMessage

+ func NewPopulatedResourceOffersMessage(r randyMessages, easy bool) *ResourceOffersMessage

+ func (m *ResourceOffersMessage) Marshal() (data []byte, err error)

+ func (m *ResourceOffersMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *ResourceOffersMessage) Unmarshal(data []byte) error

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

+ func (this *ResourceOffersMessage) GoString() string

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

type ResourceRequestMessage

+ func NewPopulatedResourceRequestMessage(r randyMessages, easy bool) *ResourceRequestMessage

+ func (m *ResourceRequestMessage) Marshal() (data []byte, err error)

+ func (m *ResourceRequestMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *ResourceRequestMessage) Unmarshal(data []byte) error

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

+ func (this *ResourceRequestMessage) GoString() string

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

type ResourceStatistics

+ MemUnevictableBytes *uint64

+ func (m *ResourceStatistics) GetMemUnevictableBytes() uint64

type ResourceUsage

+ Total []*Resource

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

type ReviveOffersMessage

+ func NewPopulatedReviveOffersMessage(r randyMessages, easy bool) *ReviveOffersMessage

+ func (m *ReviveOffersMessage) Marshal() (data []byte, err error)

+ func (m *ReviveOffersMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *ReviveOffersMessage) Unmarshal(data []byte) error

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

+ func (this *ReviveOffersMessage) GoString() string

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

type RunTaskMessage

+ func NewPopulatedRunTaskMessage(r randyMessages, easy bool) *RunTaskMessage

+ func (m *RunTaskMessage) Marshal() (data []byte, err error)

+ func (m *RunTaskMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *RunTaskMessage) Unmarshal(data []byte) error

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

+ func (this *RunTaskMessage) GoString() string

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

type ShutdownExecutorMessage

+ func NewPopulatedShutdownExecutorMessage(r randyMessages, easy bool) *ShutdownExecutorMessage

+ func (m *ShutdownExecutorMessage) Marshal() (data []byte, err error)

+ func (m *ShutdownExecutorMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *ShutdownExecutorMessage) Unmarshal(data []byte) error

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

+ func (this *ShutdownExecutorMessage) GoString() string

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

type ShutdownFrameworkMessage

+ func NewPopulatedShutdownFrameworkMessage(r randyMessages, easy bool) *ShutdownFrameworkMessage

+ func (m *ShutdownFrameworkMessage) Marshal() (data []byte, err error)

+ func (m *ShutdownFrameworkMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *ShutdownFrameworkMessage) Unmarshal(data []byte) error

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

+ func (this *ShutdownFrameworkMessage) GoString() string

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

type ShutdownMessage

+ func NewPopulatedShutdownMessage(r randyMessages, easy bool) *ShutdownMessage

+ func (m *ShutdownMessage) Marshal() (data []byte, err error)

+ func (m *ShutdownMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *ShutdownMessage) Unmarshal(data []byte) error

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

+ func (this *ShutdownMessage) GoString() string

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

type SlaveRegisteredMessage

+ func NewPopulatedSlaveRegisteredMessage(r randyMessages, easy bool) *SlaveRegisteredMessage

+ func (m *SlaveRegisteredMessage) Marshal() (data []byte, err error)

+ func (m *SlaveRegisteredMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *SlaveRegisteredMessage) Unmarshal(data []byte) error

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

+ func (this *SlaveRegisteredMessage) GoString() string

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

type SlaveReregisteredMessage

+ func NewPopulatedSlaveReregisteredMessage(r randyMessages, easy bool) *SlaveReregisteredMessage

+ func (m *SlaveReregisteredMessage) Marshal() (data []byte, err error)

+ func (m *SlaveReregisteredMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *SlaveReregisteredMessage) Unmarshal(data []byte) error

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

+ func (this *SlaveReregisteredMessage) GoString() string

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

type StatusUpdate

+ func NewPopulatedStatusUpdate(r randyMessages, easy bool) *StatusUpdate

+ func (m *StatusUpdate) Marshal() (data []byte, err error)

+ func (m *StatusUpdate) MarshalTo(data []byte) (int, error)

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

+ func (m *StatusUpdate) Unmarshal(data []byte) error

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

+ func (this *StatusUpdate) GoString() string

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

type StatusUpdateAcknowledgementMessage

+ func NewPopulatedStatusUpdateAcknowledgementMessage(r randyMessages, easy bool) *StatusUpdateAcknowledgementMessage

+ func (m *StatusUpdateAcknowledgementMessage) Marshal() (data []byte, err error)

+ func (m *StatusUpdateAcknowledgementMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *StatusUpdateAcknowledgementMessage) Unmarshal(data []byte) error

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

+ func (this *StatusUpdateAcknowledgementMessage) GoString() string

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

type StatusUpdateMessage

+ func NewPopulatedStatusUpdateMessage(r randyMessages, easy bool) *StatusUpdateMessage

+ func (m *StatusUpdateMessage) Marshal() (data []byte, err error)

+ func (m *StatusUpdateMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *StatusUpdateMessage) Unmarshal(data []byte) error

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

+ func (this *StatusUpdateMessage) GoString() string

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

type StatusUpdateRecord

+ func NewPopulatedStatusUpdateRecord(r randyMessages, easy bool) *StatusUpdateRecord

+ func (m *StatusUpdateRecord) Marshal() (data []byte, err error)

+ func (m *StatusUpdateRecord) MarshalTo(data []byte) (int, error)

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

+ func (m *StatusUpdateRecord) Unmarshal(data []byte) error

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

+ func (this *StatusUpdateRecord) GoString() string

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

type SubmitSchedulerRequest

+ func NewPopulatedSubmitSchedulerRequest(r randyMessages, easy bool) *SubmitSchedulerRequest

+ func (m *SubmitSchedulerRequest) Marshal() (data []byte, err error)

+ func (m *SubmitSchedulerRequest) MarshalTo(data []byte) (int, error)

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

+ func (m *SubmitSchedulerRequest) Unmarshal(data []byte) error

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

+ func (this *SubmitSchedulerRequest) GoString() string

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

type SubmitSchedulerResponse

+ func NewPopulatedSubmitSchedulerResponse(r randyMessages, easy bool) *SubmitSchedulerResponse

+ func (m *SubmitSchedulerResponse) Marshal() (data []byte, err error)

+ func (m *SubmitSchedulerResponse) MarshalTo(data []byte) (int, error)

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

+ func (m *SubmitSchedulerResponse) Unmarshal(data []byte) error

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

+ func (this *SubmitSchedulerResponse) GoString() string

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

type Task

+ func NewPopulatedTask(r randyMessages, easy bool) *Task

+ func (m *Task) Marshal() (data []byte, err error)

+ func (m *Task) MarshalTo(data []byte) (int, error)

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

+ func (m *Task) Unmarshal(data []byte) error

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

+ func (this *Task) GoString() string

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

type TaskHealthStatus

+ func NewPopulatedTaskHealthStatus(r randyMessages, easy bool) *TaskHealthStatus

+ func (m *TaskHealthStatus) Marshal() (data []byte, err error)

+ func (m *TaskHealthStatus) MarshalTo(data []byte) (int, error)

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

+ func (m *TaskHealthStatus) Unmarshal(data []byte) error

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

+ func (this *TaskHealthStatus) GoString() string

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

type TaskStatus

+ Labels *Labels

+ func (m *TaskStatus) GetLabels() *Labels

type Termination

+ func NewPopulatedTermination(r randyContainerizer, easy bool) *Termination

+ func (m *Termination) Marshal() (data []byte, err error)

+ func (m *Termination) MarshalTo(data []byte) (int, error)

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

+ func (m *Termination) Unmarshal(data []byte) error

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

+ func (this *Termination) GoString() string

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

+ type URL struct

+ Address *Address

+ Fragment *string

+ Path *string

+ Query []*Parameter

+ Scheme *string

+ XXX_unrecognized []byte

+ 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 (this *URL) Equal(that interface{}) bool

+ func (this *URL) GoString() string

+ func (this *URL) String() string

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

type UnregisterFrameworkMessage

+ func NewPopulatedUnregisterFrameworkMessage(r randyMessages, easy bool) *UnregisterFrameworkMessage

+ func (m *UnregisterFrameworkMessage) Marshal() (data []byte, err error)

+ func (m *UnregisterFrameworkMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *UnregisterFrameworkMessage) Unmarshal(data []byte) error

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

+ func (this *UnregisterFrameworkMessage) GoString() string

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

type UnregisterSlaveMessage

+ func NewPopulatedUnregisterSlaveMessage(r randyMessages, easy bool) *UnregisterSlaveMessage

+ func (m *UnregisterSlaveMessage) Marshal() (data []byte, err error)

+ func (m *UnregisterSlaveMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *UnregisterSlaveMessage) Unmarshal(data []byte) error

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

+ func (this *UnregisterSlaveMessage) GoString() string

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

type Update

+ func NewPopulatedUpdate(r randyContainerizer, easy bool) *Update

+ func (m *Update) Marshal() (data []byte, err error)

+ func (m *Update) MarshalTo(data []byte) (int, error)

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

+ func (m *Update) Unmarshal(data []byte) error

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

+ func (this *Update) GoString() string

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

type UpdateFrameworkMessage

+ func NewPopulatedUpdateFrameworkMessage(r randyMessages, easy bool) *UpdateFrameworkMessage

+ func (m *UpdateFrameworkMessage) Marshal() (data []byte, err error)

+ func (m *UpdateFrameworkMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *UpdateFrameworkMessage) Unmarshal(data []byte) error

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

+ func (this *UpdateFrameworkMessage) GoString() string

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

type UpdateSlaveMessage

+ func NewPopulatedUpdateSlaveMessage(r randyMessages, easy bool) *UpdateSlaveMessage

+ func (m *UpdateSlaveMessage) Marshal() (data []byte, err error)

+ func (m *UpdateSlaveMessage) MarshalTo(data []byte) (int, error)

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

+ func (m *UpdateSlaveMessage) Unmarshal(data []byte) error

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

+ func (this *UpdateSlaveMessage) GoString() string

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

type Usage

+ func NewPopulatedUsage(r randyContainerizer, easy bool) *Usage

+ func (m *Usage) Marshal() (data []byte, err error)

+ func (m *Usage) MarshalTo(data []byte) (int, error)

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

+ func (m *Usage) Unmarshal(data []byte) error

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

+ func (this *Usage) GoString() string

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

type Volume

+ Image *Image

+ func (m *Volume) GetImage() *Image

type Wait

+ func NewPopulatedWait(r randyContainerizer, easy bool) *Wait

+ func (m *Wait) Marshal() (data []byte, err error)

+ func (m *Wait) MarshalTo(data []byte) (int, error)

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

+ func (m *Wait) Unmarshal(data []byte) error

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

+ func (this *Wait) GoString() string

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

v1.1.3-beta.0

Nov 19, 2015

v1.1.2

Nov 19, 2015

v1.1.2-beta.0

Nov 9, 2015

v1.1.1

Nov 9, 2015

v1.1.1-beta.1

Nov 3, 2015

v1.1.1-beta.0

Sep 25, 2015

v1.1.1-beta

Sep 25, 2015

v1.1.0

Sep 25, 2015

Changes in this version

+ var DiscoveryInfo_Visibility_name = map[int32]string

+ var DiscoveryInfo_Visibility_value = map[string]int32

+ var ErrInvalidLengthLog = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthMesos = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthState = fmt.Errorf("proto: negative length found during unmarshaling")

+ var FrameworkInfo_Capability_Type_name = map[int32]string

+ var FrameworkInfo_Capability_Type_value = map[string]int32

+ var Offer_Operation_Type_name = map[int32]string

+ var Offer_Operation_Type_value = map[string]int32

type Call

+ Accept *Call_Accept

+ FrameworkId *FrameworkID

+ Shutdown *Call_Shutdown

+ Subscribe *Call_Subscribe

+ func (m *Call) GetAccept() *Call_Accept

+ func (m *Call) GetFrameworkId() *FrameworkID

+ func (m *Call) GetShutdown() *Call_Shutdown

+ func (m *Call) GetSubscribe() *Call_Subscribe

+ type Call_Accept struct

+ Filters *Filters

+ OfferIds []*OfferID

+ Operations []*Offer_Operation

+ XXX_unrecognized []byte

+ func (*Call_Accept) ProtoMessage()

+ func (m *Call_Accept) GetFilters() *Filters

+ func (m *Call_Accept) GetOfferIds() []*OfferID

+ func (m *Call_Accept) GetOperations() []*Offer_Operation

+ func (m *Call_Accept) Reset()

+ func (m *Call_Accept) String() string

type Call_Kill

+ SlaveId *SlaveID

+ func (m *Call_Kill) GetSlaveId() *SlaveID

type Call_Reconcile

+ Tasks []*Call_Reconcile_Task

+ func (m *Call_Reconcile) GetTasks() []*Call_Reconcile_Task

+ type Call_Reconcile_Task struct

+ SlaveId *SlaveID

+ TaskId *TaskID

+ XXX_unrecognized []byte

+ func (*Call_Reconcile_Task) ProtoMessage()

+ func (m *Call_Reconcile_Task) GetSlaveId() *SlaveID

+ func (m *Call_Reconcile_Task) GetTaskId() *TaskID

+ func (m *Call_Reconcile_Task) Reset()

+ func (m *Call_Reconcile_Task) String() string

+ type Call_Shutdown struct

+ ExecutorId *ExecutorID

+ SlaveId *SlaveID

+ XXX_unrecognized []byte

+ func (*Call_Shutdown) ProtoMessage()

+ func (m *Call_Shutdown) GetExecutorId() *ExecutorID

+ func (m *Call_Shutdown) GetSlaveId() *SlaveID

+ func (m *Call_Shutdown) Reset()

+ func (m *Call_Shutdown) String() string

+ type Call_Subscribe struct

+ Force *bool

+ FrameworkInfo *FrameworkInfo

+ XXX_unrecognized []byte

+ func (*Call_Subscribe) ProtoMessage()

+ func (m *Call_Subscribe) GetForce() bool

+ func (m *Call_Subscribe) GetFrameworkInfo() *FrameworkInfo

+ func (m *Call_Subscribe) Reset()

+ func (m *Call_Subscribe) String() string

type Call_Type

+ const Call_ACCEPT

+ const Call_SHUTDOWN

+ const Call_SUBSCRIBE

+ const Call_TEARDOWN

+ type CheckpointResourcesMessage struct

+ Resources []*Resource

+ XXX_unrecognized []byte

+ func (*CheckpointResourcesMessage) ProtoMessage()

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

+ func (m *CheckpointResourcesMessage) Reset()

+ func (m *CheckpointResourcesMessage) String() string

type CommandInfo_URI

+ Cache *bool

+ func (m *CommandInfo_URI) GetCache() bool

type ContainerInfo_DockerInfo

+ ForcePullImage *bool

+ func (m *ContainerInfo_DockerInfo) GetForcePullImage() bool

+ type DiscoveryInfo struct

+ Environment *string

+ Labels *Labels

+ Location *string

+ Name *string

+ Ports *Ports

+ Version *string

+ Visibility *DiscoveryInfo_Visibility

+ XXX_unrecognized []byte

+ 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 (this *DiscoveryInfo) Equal(that interface{}) bool

+ func (this *DiscoveryInfo) GoString() string

+ func (this *DiscoveryInfo) String() string

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

+ type DiscoveryInfo_Visibility int32

+ const DiscoveryInfo_CLUSTER

+ const DiscoveryInfo_EXTERNAL

+ const DiscoveryInfo_FRAMEWORK

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

+ func (x DiscoveryInfo_Visibility) Enum() *DiscoveryInfo_Visibility

+ func (x DiscoveryInfo_Visibility) String() string

type Event

+ Subscribed *Event_Subscribed

+ func (m *Event) GetSubscribed() *Event_Subscribed

+ type Event_Subscribed struct

+ FrameworkId *FrameworkID

+ XXX_unrecognized []byte

+ func (*Event_Subscribed) ProtoMessage()

+ func (m *Event_Subscribed) GetFrameworkId() *FrameworkID

+ func (m *Event_Subscribed) Reset()

+ func (m *Event_Subscribed) String() string

type Event_Type

+ const Event_SUBSCRIBED

type ExecutorInfo

+ Discovery *DiscoveryInfo

+ func (m *ExecutorInfo) GetDiscovery() *DiscoveryInfo

type FrameworkInfo

+ Capabilities []*FrameworkInfo_Capability

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

+ type FrameworkInfo_Capability struct

+ Type *FrameworkInfo_Capability_Type

+ XXX_unrecognized []byte

+ 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 (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

+ type FrameworkInfo_Capability_Type int32

+ const FrameworkInfo_Capability_REVOCABLE_RESOURCES

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

+ func (x FrameworkInfo_Capability_Type) Enum() *FrameworkInfo_Capability_Type

+ func (x FrameworkInfo_Capability_Type) String() string

+ type HookExecuted struct

+ Module *string

+ XXX_unrecognized []byte

+ func (*HookExecuted) ProtoMessage()

+ func (m *HookExecuted) GetModule() string

+ func (m *HookExecuted) Reset()

+ func (m *HookExecuted) String() string

+ type Label struct

+ Key *string

+ Value *string

+ XXX_unrecognized []byte

+ 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 (this *Label) Equal(that interface{}) bool

+ func (this *Label) GoString() string

+ func (this *Label) String() string

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

+ type Labels struct

+ Labels []*Label

+ XXX_unrecognized []byte

+ 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 (this *Labels) Equal(that interface{}) bool

+ func (this *Labels) GoString() string

+ func (this *Labels) String() string

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

type MasterInfo

+ Version *string

+ func (m *MasterInfo) GetVersion() string

+ type MasterSlaveConnection struct

+ TotalPingTimeoutSeconds *float64

+ XXX_unrecognized []byte

+ func (*MasterSlaveConnection) ProtoMessage()

+ func (m *MasterSlaveConnection) GetTotalPingTimeoutSeconds() float64

+ func (m *MasterSlaveConnection) Reset()

+ func (m *MasterSlaveConnection) String() string

+ type Offer_Operation struct

+ Create *Offer_Operation_Create

+ Destroy *Offer_Operation_Destroy

+ Launch *Offer_Operation_Launch

+ Reserve *Offer_Operation_Reserve

+ Type *Offer_Operation_Type

+ Unreserve *Offer_Operation_Unreserve

+ XXX_unrecognized []byte

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

+ type Offer_Operation_Create struct

+ Volumes []*Resource

+ XXX_unrecognized []byte

+ 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 (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

+ type Offer_Operation_Destroy struct

+ Volumes []*Resource

+ XXX_unrecognized []byte

+ 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 (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

+ type Offer_Operation_Launch struct

+ TaskInfos []*TaskInfo

+ XXX_unrecognized []byte

+ 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 (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

+ type Offer_Operation_Reserve struct

+ Resources []*Resource

+ XXX_unrecognized []byte

+ 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 (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

+ type Offer_Operation_Type int32

+ const Offer_Operation_CREATE

+ const Offer_Operation_DESTROY

+ const Offer_Operation_LAUNCH

+ const Offer_Operation_RESERVE

+ 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) String() string

+ type Offer_Operation_Unreserve struct

+ Resources []*Resource

+ XXX_unrecognized []byte

+ 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 (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

+ type Port struct

+ Name *string

+ Number *uint32

+ Protocol *string

+ XXX_unrecognized []byte

+ func NewPopulatedPort(r randyMesos, easy bool) *Port

+ func (*Port) ProtoMessage()

+ func (m *Port) GetName() string

+ func (m *Port) GetNumber() uint32

+ func (m *Port) GetProtocol() string

+ 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 (this *Port) Equal(that interface{}) bool

+ func (this *Port) GoString() string

+ func (this *Port) String() string

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

+ type Ports struct

+ Ports []*Port

+ XXX_unrecognized []byte

+ 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 (this *Ports) Equal(that interface{}) bool

+ func (this *Ports) GoString() string

+ func (this *Ports) String() string

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

type RegisterSlaveMessage

+ CheckpointedResources []*Resource

+ func (m *RegisterSlaveMessage) GetCheckpointedResources() []*Resource

type ReregisterSlaveMessage

+ CheckpointedResources []*Resource

+ func (m *ReregisterSlaveMessage) GetCheckpointedResources() []*Resource

type Resource

+ Disk *Resource_DiskInfo

+ Reservation *Resource_ReservationInfo

+ Revocable *Resource_RevocableInfo

+ func (m *Resource) GetDisk() *Resource_DiskInfo

+ func (m *Resource) GetReservation() *Resource_ReservationInfo

+ func (m *Resource) GetRevocable() *Resource_RevocableInfo

type ResourceStatistics

+ DiskLimitBytes *uint64

+ DiskUsedBytes *uint64

+ MemCacheBytes *uint64

+ MemCriticalPressureCounter *uint64

+ MemLowPressureCounter *uint64

+ MemMediumPressureCounter *uint64

+ MemSoftLimitBytes *uint64

+ MemSwapBytes *uint64

+ MemTotalBytes *uint64

+ MemTotalMemswBytes *uint64

+ NetTcpActiveConnections *float64

+ NetTcpTimeWaitConnections *float64

+ NetTrafficControlStatistics []*TrafficControlStatistics

+ Processes *uint32

+ Threads *uint32

+ func (m *ResourceStatistics) GetDiskLimitBytes() uint64

+ func (m *ResourceStatistics) GetDiskUsedBytes() uint64

+ func (m *ResourceStatistics) GetMemCacheBytes() uint64

+ func (m *ResourceStatistics) GetMemCriticalPressureCounter() uint64

+ func (m *ResourceStatistics) GetMemLowPressureCounter() uint64

+ func (m *ResourceStatistics) GetMemMediumPressureCounter() uint64

+ func (m *ResourceStatistics) GetMemSoftLimitBytes() uint64

+ func (m *ResourceStatistics) GetMemSwapBytes() uint64

+ func (m *ResourceStatistics) GetMemTotalBytes() uint64

+ func (m *ResourceStatistics) GetMemTotalMemswBytes() uint64

+ func (m *ResourceStatistics) GetNetTcpActiveConnections() float64

+ func (m *ResourceStatistics) GetNetTcpTimeWaitConnections() float64

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

+ func (m *ResourceStatistics) GetProcesses() uint32

+ func (m *ResourceStatistics) GetThreads() uint32

type ResourceUsage

+ Executors []*ResourceUsage_Executor

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

+ type ResourceUsage_Executor struct

+ Allocated []*Resource

+ ExecutorInfo *ExecutorInfo

+ Statistics *ResourceStatistics

+ XXX_unrecognized []byte

+ func NewPopulatedResourceUsage_Executor(r randyMesos, easy bool) *ResourceUsage_Executor

+ func (*ResourceUsage_Executor) ProtoMessage()

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

+ func (m *ResourceUsage_Executor) GetExecutorInfo() *ExecutorInfo

+ func (m *ResourceUsage_Executor) GetStatistics() *ResourceStatistics

+ 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 (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

+ type Resource_DiskInfo struct

+ Persistence *Resource_DiskInfo_Persistence

+ Volume *Volume

+ XXX_unrecognized []byte

+ func NewPopulatedResource_DiskInfo(r randyMesos, easy bool) *Resource_DiskInfo

+ func (*Resource_DiskInfo) ProtoMessage()

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

+ 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 (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

+ type Resource_DiskInfo_Persistence struct

+ Id *string

+ XXX_unrecognized []byte

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

+ type Resource_ReservationInfo struct

+ Principal *string

+ XXX_unrecognized []byte

+ func NewPopulatedResource_ReservationInfo(r randyMesos, easy bool) *Resource_ReservationInfo

+ func (*Resource_ReservationInfo) ProtoMessage()

+ 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 (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

+ type Resource_RevocableInfo struct

+ XXX_unrecognized []byte

+ 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 (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

type ShutdownExecutorMessage

+ ExecutorId *ExecutorID

+ FrameworkId *FrameworkID

+ func (m *ShutdownExecutorMessage) GetExecutorId() *ExecutorID

+ func (m *ShutdownExecutorMessage) GetFrameworkId() *FrameworkID

type SlaveRegisteredMessage

+ Connection *MasterSlaveConnection

+ func (m *SlaveRegisteredMessage) GetConnection() *MasterSlaveConnection

type SlaveReregisteredMessage

+ Connection *MasterSlaveConnection

+ func (m *SlaveReregisteredMessage) GetConnection() *MasterSlaveConnection

type Task

+ Discovery *DiscoveryInfo

+ Labels *Labels

+ func (m *Task) GetDiscovery() *DiscoveryInfo

+ func (m *Task) GetLabels() *Labels

type TaskInfo

+ Discovery *DiscoveryInfo

+ Labels *Labels

+ func (m *TaskInfo) GetDiscovery() *DiscoveryInfo

+ func (m *TaskInfo) GetLabels() *Labels

type TaskStatus

+ Uuid []byte

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

type TaskStatus_Reason

+ const TaskStatus_REASON_EXECUTOR_PREEMPTED

+ const TaskStatus_REASON_RESOURCES_UNKNOWN

+ type TrafficControlStatistics struct

+ Backlog *uint64

+ Bytes *uint64

+ Drops *uint64

+ Id *string

+ Overlimits *uint64

+ Packets *uint64

+ Qlen *uint64

+ Ratebps *uint64

+ Ratepps *uint64

+ Requeues *uint64

+ XXX_unrecognized []byte

+ 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 (this *TrafficControlStatistics) Equal(that interface{}) bool

+ func (this *TrafficControlStatistics) GoString() string

+ func (this *TrafficControlStatistics) String() string

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

+ type UpdateSlaveMessage struct

+ OversubscribedResources []*Resource

+ SlaveId *SlaveID

+ XXX_unrecognized []byte

+ func (*UpdateSlaveMessage) ProtoMessage()

+ func (m *UpdateSlaveMessage) GetOversubscribedResources() []*Resource

+ func (m *UpdateSlaveMessage) GetSlaveId() *SlaveID

+ func (m *UpdateSlaveMessage) Reset()

+ func (m *UpdateSlaveMessage) String() string

v1.1.0-beta

Sep 25, 2015

v1.1.0-alpha.1

Aug 28, 2015

v1.1.0-alpha.0

Jul 11, 2015

v1.0.8-beta

Oct 27, 2015

v1.0.7

Oct 27, 2015

v1.0.6

Sep 10, 2015

v1.0.5

Aug 31, 2015

v1.0.4

Aug 25, 2015

v1.0.3

Aug 7, 2015

v1.0.2

Aug 1, 2015

v1.0.1

Jul 17, 2015

v1.0.0

Jul 11, 2015

v0

v0.21.4

Jul 17, 2015

v0.21.3

Jul 16, 2015

v0.21.2

Jul 11, 2015

v0.21.1

Jul 9, 2015

v0.21.0

Jul 7, 2015

v0.20.2

Jun 30, 2015

v0.20.1

Jun 29, 2015

v0.20.0

Jun 26, 2015

v0.19.3

Jun 22, 2015

v0.19.2

Jun 22, 2015

v0.19.1

Jun 19, 2015

v0.19.0

Jun 10, 2015

v0.18.2

Jun 8, 2015

v0.18.1

Jun 3, 2015

v0.18.0

May 29, 2015

Changes in this version

+ const Default_ACLs_Permissive

+ 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_HTTP_Path

+ const Default_HealthCheck_IntervalSeconds

+ const Default_HealthCheck_TimeoutSeconds

+ const Default_MasterInfo_Port

+ const Default_Metadata_Promised

+ const Default_Resource_Role

+ const Default_RoleInfo_Weight

+ const Default_SlaveInfo_Checkpoint

+ const Default_SlaveInfo_Port

+ const Default_TaskHealthStatus_KillTask

+ var ACL_Entity_Type_name = map[int32]string

+ var ACL_Entity_Type_value = map[string]int32

+ var Action_Type_name = map[int32]string

+ var Action_Type_value = map[string]int32

+ var Call_Type_name = map[int32]string

+ var Call_Type_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 Event_Type_name = map[int32]string

+ var Event_Type_value = map[string]int32

+ var Metadata_Status_name = map[int32]string

+ var Metadata_Status_value = map[string]int32

+ var Operation_Type_name = map[int32]string

+ var Operation_Type_value = map[string]int32

+ var Record_Type_name = map[int32]string

+ var Record_Type_value = map[string]int32

+ var StatusUpdateRecord_Type_name = map[int32]string

+ var StatusUpdateRecord_Type_value = map[string]int32

+ 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 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

+ type ACL struct

+ XXX_unrecognized []byte

+ func NewPopulatedACL(r randyMesos, easy bool) *ACL

+ func (*ACL) ProtoMessage()

+ func (m *ACL) Marshal() (data []byte, err error)

+ func (m *ACL) MarshalTo(data []byte) (n int, err error)

+ func (m *ACL) Reset()

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

+ func (m *ACL) Unmarshal(data []byte) error

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

+ func (this *ACL) GoString() string

+ func (this *ACL) String() string

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

+ type ACL_Entity struct

+ Type *ACL_Entity_Type

+ Values []string

+ XXX_unrecognized []byte

+ func NewPopulatedACL_Entity(r randyMesos, easy bool) *ACL_Entity

+ func (*ACL_Entity) ProtoMessage()

+ func (m *ACL_Entity) GetType() ACL_Entity_Type

+ func (m *ACL_Entity) GetValues() []string

+ func (m *ACL_Entity) Marshal() (data []byte, err error)

+ func (m *ACL_Entity) MarshalTo(data []byte) (n int, err error)

+ func (m *ACL_Entity) Reset()

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

+ func (m *ACL_Entity) Unmarshal(data []byte) error

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

+ func (this *ACL_Entity) GoString() string

+ func (this *ACL_Entity) String() string

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

+ type ACL_Entity_Type int32

+ const ACL_Entity_ANY

+ const ACL_Entity_NONE

+ const ACL_Entity_SOME

+ const Default_ACL_Entity_Type

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

+ func (x ACL_Entity_Type) Enum() *ACL_Entity_Type

+ func (x ACL_Entity_Type) String() string

+ type ACL_RegisterFramework struct

+ Principals *ACL_Entity

+ Roles *ACL_Entity

+ XXX_unrecognized []byte

+ func NewPopulatedACL_RegisterFramework(r randyMesos, easy bool) *ACL_RegisterFramework

+ func (*ACL_RegisterFramework) ProtoMessage()

+ func (m *ACL_RegisterFramework) GetPrincipals() *ACL_Entity

+ func (m *ACL_RegisterFramework) GetRoles() *ACL_Entity

+ func (m *ACL_RegisterFramework) Marshal() (data []byte, err error)

+ func (m *ACL_RegisterFramework) MarshalTo(data []byte) (n int, err error)

+ func (m *ACL_RegisterFramework) Reset()

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

+ func (m *ACL_RegisterFramework) Unmarshal(data []byte) error

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

+ func (this *ACL_RegisterFramework) GoString() string

+ func (this *ACL_RegisterFramework) String() string

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

+ type ACL_RunTask struct

+ Principals *ACL_Entity

+ Users *ACL_Entity

+ XXX_unrecognized []byte

+ func NewPopulatedACL_RunTask(r randyMesos, easy bool) *ACL_RunTask

+ func (*ACL_RunTask) ProtoMessage()

+ func (m *ACL_RunTask) GetPrincipals() *ACL_Entity

+ func (m *ACL_RunTask) GetUsers() *ACL_Entity

+ func (m *ACL_RunTask) Marshal() (data []byte, err error)

+ func (m *ACL_RunTask) MarshalTo(data []byte) (n int, err error)

+ func (m *ACL_RunTask) Reset()

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

+ func (m *ACL_RunTask) Unmarshal(data []byte) error

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

+ func (this *ACL_RunTask) GoString() string

+ func (this *ACL_RunTask) String() string

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

+ type ACL_ShutdownFramework struct

+ FrameworkPrincipals *ACL_Entity

+ Principals *ACL_Entity

+ XXX_unrecognized []byte

+ func NewPopulatedACL_ShutdownFramework(r randyMesos, easy bool) *ACL_ShutdownFramework

+ func (*ACL_ShutdownFramework) ProtoMessage()

+ func (m *ACL_ShutdownFramework) GetFrameworkPrincipals() *ACL_Entity

+ func (m *ACL_ShutdownFramework) GetPrincipals() *ACL_Entity

+ func (m *ACL_ShutdownFramework) Marshal() (data []byte, err error)

+ func (m *ACL_ShutdownFramework) MarshalTo(data []byte) (n int, err error)

+ func (m *ACL_ShutdownFramework) Reset()

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

+ func (m *ACL_ShutdownFramework) Unmarshal(data []byte) error

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

+ func (this *ACL_ShutdownFramework) GoString() string

+ func (this *ACL_ShutdownFramework) String() string

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

+ type ACLs struct

+ Permissive *bool

+ RegisterFrameworks []*ACL_RegisterFramework

+ RunTasks []*ACL_RunTask

+ ShutdownFrameworks []*ACL_ShutdownFramework

+ XXX_unrecognized []byte

+ func NewPopulatedACLs(r randyMesos, easy bool) *ACLs

+ func (*ACLs) ProtoMessage()

+ func (m *ACLs) GetPermissive() bool

+ func (m *ACLs) GetRegisterFrameworks() []*ACL_RegisterFramework

+ func (m *ACLs) GetRunTasks() []*ACL_RunTask

+ func (m *ACLs) GetShutdownFrameworks() []*ACL_ShutdownFramework

+ func (m *ACLs) Marshal() (data []byte, err error)

+ func (m *ACLs) MarshalTo(data []byte) (n int, err error)

+ func (m *ACLs) Reset()

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

+ func (m *ACLs) Unmarshal(data []byte) error

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

+ func (this *ACLs) GoString() string

+ func (this *ACLs) String() string

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

+ type Action struct

+ Append *Action_Append

+ Learned *bool

+ Nop *Action_Nop

+ Performed *uint64

+ Position *uint64

+ Promised *uint64

+ Truncate *Action_Truncate

+ Type *Action_Type

+ XXX_unrecognized []byte

+ func NewPopulatedAction(r randyLog, easy bool) *Action

+ func (*Action) ProtoMessage()

+ func (m *Action) GetAppend() *Action_Append

+ func (m *Action) GetLearned() bool

+ func (m *Action) GetNop() *Action_Nop

+ func (m *Action) GetPerformed() uint64

+ func (m *Action) GetPosition() uint64

+ func (m *Action) GetPromised() uint64

+ func (m *Action) GetTruncate() *Action_Truncate

+ func (m *Action) GetType() Action_Type

+ func (m *Action) Marshal() (data []byte, err error)

+ func (m *Action) MarshalTo(data []byte) (n int, err error)

+ func (m *Action) Reset()

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

+ func (m *Action) Unmarshal(data []byte) error

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

+ func (this *Action) GoString() string

+ func (this *Action) String() string

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

+ type Action_Append struct

+ Bytes []byte

+ Cksum []byte

+ XXX_unrecognized []byte

+ func NewPopulatedAction_Append(r randyLog, easy bool) *Action_Append

+ func (*Action_Append) ProtoMessage()

+ func (m *Action_Append) GetBytes() []byte

+ func (m *Action_Append) GetCksum() []byte

+ func (m *Action_Append) Marshal() (data []byte, err error)

+ func (m *Action_Append) MarshalTo(data []byte) (n int, err error)

+ func (m *Action_Append) Reset()

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

+ func (m *Action_Append) Unmarshal(data []byte) error

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

+ func (this *Action_Append) GoString() string

+ func (this *Action_Append) String() string

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

+ type Action_Nop struct

+ XXX_unrecognized []byte

+ func NewPopulatedAction_Nop(r randyLog, easy bool) *Action_Nop

+ func (*Action_Nop) ProtoMessage()

+ func (m *Action_Nop) Marshal() (data []byte, err error)

+ func (m *Action_Nop) MarshalTo(data []byte) (n int, err error)

+ func (m *Action_Nop) Reset()

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

+ func (m *Action_Nop) Unmarshal(data []byte) error

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

+ func (this *Action_Nop) GoString() string

+ func (this *Action_Nop) String() string

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

+ type Action_Truncate struct

+ To *uint64

+ XXX_unrecognized []byte

+ func NewPopulatedAction_Truncate(r randyLog, easy bool) *Action_Truncate

+ func (*Action_Truncate) ProtoMessage()

+ func (m *Action_Truncate) GetTo() uint64

+ func (m *Action_Truncate) Marshal() (data []byte, err error)

+ func (m *Action_Truncate) MarshalTo(data []byte) (n int, err error)

+ func (m *Action_Truncate) Reset()

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

+ func (m *Action_Truncate) Unmarshal(data []byte) error

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

+ func (this *Action_Truncate) GoString() string

+ func (this *Action_Truncate) String() string

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

+ type Action_Type int32

+ const Action_APPEND

+ const Action_NOP

+ const Action_TRUNCATE

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

+ func (x Action_Type) Enum() *Action_Type

+ func (x Action_Type) String() string

+ type Archive struct

+ Frameworks []*Archive_Framework

+ XXX_unrecognized []byte

+ func (*Archive) ProtoMessage()

+ func (m *Archive) GetFrameworks() []*Archive_Framework

+ func (m *Archive) Reset()

+ func (m *Archive) String() string

+ type Archive_Framework struct

+ FrameworkInfo *FrameworkInfo

+ Pid *string

+ Tasks []*Task

+ XXX_unrecognized []byte

+ func (*Archive_Framework) ProtoMessage()

+ func (m *Archive_Framework) GetFrameworkInfo() *FrameworkInfo

+ func (m *Archive_Framework) GetPid() string

+ func (m *Archive_Framework) GetTasks() []*Task

+ func (m *Archive_Framework) Reset()

+ func (m *Archive_Framework) String() string

+ type Attribute struct

+ Name *string

+ Ranges *Value_Ranges

+ Scalar *Value_Scalar

+ Set *Value_Set

+ Text *Value_Text

+ Type *Value_Type

+ XXX_unrecognized []byte

+ 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) (n int, err error)

+ func (m *Attribute) Reset()

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

+ func (m *Attribute) Unmarshal(data []byte) 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

+ type AuthenticateMessage struct

+ Pid *string

+ XXX_unrecognized []byte

+ func (*AuthenticateMessage) ProtoMessage()

+ func (m *AuthenticateMessage) GetPid() string

+ func (m *AuthenticateMessage) Reset()

+ func (m *AuthenticateMessage) String() string

+ type AuthenticationCompletedMessage struct

+ XXX_unrecognized []byte

+ func (*AuthenticationCompletedMessage) ProtoMessage()

+ func (m *AuthenticationCompletedMessage) Reset()

+ func (m *AuthenticationCompletedMessage) String() string

+ type AuthenticationErrorMessage struct

+ Error *string

+ XXX_unrecognized []byte

+ func (*AuthenticationErrorMessage) ProtoMessage()

+ func (m *AuthenticationErrorMessage) GetError() string

+ func (m *AuthenticationErrorMessage) Reset()

+ func (m *AuthenticationErrorMessage) String() string

+ type AuthenticationFailedMessage struct

+ XXX_unrecognized []byte

+ func (*AuthenticationFailedMessage) ProtoMessage()

+ func (m *AuthenticationFailedMessage) Reset()

+ func (m *AuthenticationFailedMessage) String() string

+ type AuthenticationMechanismsMessage struct

+ Mechanisms []string

+ XXX_unrecognized []byte

+ func (*AuthenticationMechanismsMessage) ProtoMessage()

+ func (m *AuthenticationMechanismsMessage) GetMechanisms() []string

+ func (m *AuthenticationMechanismsMessage) Reset()

+ func (m *AuthenticationMechanismsMessage) String() string

+ type AuthenticationStartMessage struct

+ Data *string

+ Mechanism *string

+ XXX_unrecognized []byte

+ func (*AuthenticationStartMessage) ProtoMessage()

+ func (m *AuthenticationStartMessage) GetData() string

+ func (m *AuthenticationStartMessage) GetMechanism() string

+ func (m *AuthenticationStartMessage) Reset()

+ func (m *AuthenticationStartMessage) String() string

+ type AuthenticationStepMessage struct

+ Data []byte

+ XXX_unrecognized []byte

+ func (*AuthenticationStepMessage) ProtoMessage()

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

+ func (m *AuthenticationStepMessage) Reset()

+ func (m *AuthenticationStepMessage) String() string

+ type Call struct

+ Acknowledge *Call_Acknowledge

+ Decline *Call_Decline

+ FrameworkInfo *FrameworkInfo

+ Kill *Call_Kill

+ Launch *Call_Launch

+ Message *Call_Message

+ Reconcile *Call_Reconcile

+ Request *Call_Request

+ Type *Call_Type

+ XXX_unrecognized []byte

+ func (*Call) ProtoMessage()

+ func (m *Call) GetAcknowledge() *Call_Acknowledge

+ func (m *Call) GetDecline() *Call_Decline

+ func (m *Call) GetFrameworkInfo() *FrameworkInfo

+ func (m *Call) GetKill() *Call_Kill

+ func (m *Call) GetLaunch() *Call_Launch

+ func (m *Call) GetMessage() *Call_Message

+ func (m *Call) GetReconcile() *Call_Reconcile

+ func (m *Call) GetRequest() *Call_Request

+ func (m *Call) GetType() Call_Type

+ func (m *Call) Reset()

+ func (m *Call) String() string

+ type Call_Acknowledge struct

+ SlaveId *SlaveID

+ TaskId *TaskID

+ Uuid []byte

+ XXX_unrecognized []byte

+ func (*Call_Acknowledge) ProtoMessage()

+ func (m *Call_Acknowledge) GetSlaveId() *SlaveID

+ func (m *Call_Acknowledge) GetTaskId() *TaskID

+ func (m *Call_Acknowledge) GetUuid() []byte

+ func (m *Call_Acknowledge) Reset()

+ func (m *Call_Acknowledge) String() string

+ type Call_Decline struct

+ Filters *Filters

+ OfferIds []*OfferID

+ XXX_unrecognized []byte

+ func (*Call_Decline) ProtoMessage()

+ func (m *Call_Decline) GetFilters() *Filters

+ func (m *Call_Decline) GetOfferIds() []*OfferID

+ func (m *Call_Decline) Reset()

+ func (m *Call_Decline) String() string

+ type Call_Kill struct

+ TaskId *TaskID

+ XXX_unrecognized []byte

+ func (*Call_Kill) ProtoMessage()

+ func (m *Call_Kill) GetTaskId() *TaskID

+ func (m *Call_Kill) Reset()

+ func (m *Call_Kill) String() string

+ type Call_Launch struct

+ Filters *Filters

+ OfferIds []*OfferID

+ TaskInfos []*TaskInfo

+ XXX_unrecognized []byte

+ func (*Call_Launch) ProtoMessage()

+ func (m *Call_Launch) GetFilters() *Filters

+ func (m *Call_Launch) GetOfferIds() []*OfferID

+ func (m *Call_Launch) GetTaskInfos() []*TaskInfo

+ func (m *Call_Launch) Reset()

+ func (m *Call_Launch) String() string

+ type Call_Message struct

+ Data []byte

+ ExecutorId *ExecutorID

+ SlaveId *SlaveID

+ XXX_unrecognized []byte

+ func (*Call_Message) ProtoMessage()

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

+ func (m *Call_Message) GetExecutorId() *ExecutorID

+ func (m *Call_Message) GetSlaveId() *SlaveID

+ func (m *Call_Message) Reset()

+ func (m *Call_Message) String() string

+ type Call_Reconcile struct

+ Statuses []*TaskStatus

+ XXX_unrecognized []byte

+ func (*Call_Reconcile) ProtoMessage()

+ func (m *Call_Reconcile) GetStatuses() []*TaskStatus

+ func (m *Call_Reconcile) Reset()

+ func (m *Call_Reconcile) String() string

+ type Call_Request struct

+ Requests []*Request

+ XXX_unrecognized []byte

+ func (*Call_Request) ProtoMessage()

+ func (m *Call_Request) GetRequests() []*Request

+ func (m *Call_Request) Reset()

+ func (m *Call_Request) String() string

+ type Call_Type int32

+ const Call_ACKNOWLEDGE

+ const Call_DECLINE

+ const Call_KILL

+ const Call_LAUNCH

+ const Call_MESSAGE

+ const Call_RECONCILE

+ const Call_REGISTER

+ const Call_REQUEST

+ const Call_REREGISTER

+ const Call_REVIVE

+ const Call_UNREGISTER

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

+ func (x Call_Type) Enum() *Call_Type

+ func (x Call_Type) String() string

+ type CommandInfo struct

+ Arguments []string

+ Container *CommandInfo_ContainerInfo

+ Environment *Environment

+ Shell *bool

+ Uris []*CommandInfo_URI

+ User *string

+ Value *string

+ XXX_unrecognized []byte

+ func NewPopulatedCommandInfo(r randyMesos, easy bool) *CommandInfo

+ func (*CommandInfo) ProtoMessage()

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

+ func (m *CommandInfo) GetContainer() *CommandInfo_ContainerInfo

+ 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) (n int, err error)

+ func (m *CommandInfo) Reset()

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

+ func (m *CommandInfo) Unmarshal(data []byte) 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

+ type CommandInfo_ContainerInfo struct

+ Image *string

+ Options []string

+ XXX_unrecognized []byte

+ func NewPopulatedCommandInfo_ContainerInfo(r randyMesos, easy bool) *CommandInfo_ContainerInfo

+ func (*CommandInfo_ContainerInfo) ProtoMessage()

+ func (m *CommandInfo_ContainerInfo) GetImage() string

+ func (m *CommandInfo_ContainerInfo) GetOptions() []string

+ func (m *CommandInfo_ContainerInfo) Marshal() (data []byte, err error)

+ func (m *CommandInfo_ContainerInfo) MarshalTo(data []byte) (n int, err error)

+ func (m *CommandInfo_ContainerInfo) Reset()

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

+ func (m *CommandInfo_ContainerInfo) Unmarshal(data []byte) error

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

+ func (this *CommandInfo_ContainerInfo) GoString() string

+ func (this *CommandInfo_ContainerInfo) String() string

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

+ type CommandInfo_URI struct

+ Executable *bool

+ Extract *bool

+ Value *string

+ XXX_unrecognized []byte

+ func NewPopulatedCommandInfo_URI(r randyMesos, easy bool) *CommandInfo_URI

+ func (*CommandInfo_URI) ProtoMessage()

+ func (m *CommandInfo_URI) GetExecutable() bool

+ func (m *CommandInfo_URI) GetExtract() bool

+ func (m *CommandInfo_URI) GetValue() string

+ func (m *CommandInfo_URI) Marshal() (data []byte, err error)

+ func (m *CommandInfo_URI) MarshalTo(data []byte) (n int, err error)

+ func (m *CommandInfo_URI) Reset()

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

+ func (m *CommandInfo_URI) Unmarshal(data []byte) 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

+ type ContainerID struct

+ Value *string

+ XXX_unrecognized []byte

+ func NewPopulatedContainerID(r randyMesos, easy bool) *ContainerID

+ func (*ContainerID) ProtoMessage()

+ func (m *ContainerID) GetValue() string

+ func (m *ContainerID) Marshal() (data []byte, err error)

+ func (m *ContainerID) MarshalTo(data []byte) (n int, err error)

+ func (m *ContainerID) Reset()

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

+ func (m *ContainerID) Unmarshal(data []byte) 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

+ type ContainerInfo struct

+ Docker *ContainerInfo_DockerInfo

+ Hostname *string

+ Type *ContainerInfo_Type

+ Volumes []*Volume

+ XXX_unrecognized []byte

+ func NewPopulatedContainerInfo(r randyMesos, easy bool) *ContainerInfo

+ func (*ContainerInfo) ProtoMessage()

+ func (m *ContainerInfo) GetDocker() *ContainerInfo_DockerInfo

+ func (m *ContainerInfo) GetHostname() string

+ 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) (n int, err error)

+ func (m *ContainerInfo) Reset()

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

+ func (m *ContainerInfo) Unmarshal(data []byte) 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

+ type ContainerInfo_DockerInfo struct

+ Image *string

+ Network *ContainerInfo_DockerInfo_Network

+ Parameters []*Parameter

+ PortMappings []*ContainerInfo_DockerInfo_PortMapping

+ Privileged *bool

+ XXX_unrecognized []byte

+ func NewPopulatedContainerInfo_DockerInfo(r randyMesos, easy bool) *ContainerInfo_DockerInfo

+ func (*ContainerInfo_DockerInfo) ProtoMessage()

+ 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) Marshal() (data []byte, err error)

+ func (m *ContainerInfo_DockerInfo) MarshalTo(data []byte) (n int, err error)

+ func (m *ContainerInfo_DockerInfo) Reset()

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

+ func (m *ContainerInfo_DockerInfo) Unmarshal(data []byte) 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

+ type ContainerInfo_DockerInfo_Network int32

+ const ContainerInfo_DockerInfo_BRIDGE

+ const ContainerInfo_DockerInfo_HOST

+ const ContainerInfo_DockerInfo_NONE

+ 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) String() string

+ type ContainerInfo_DockerInfo_PortMapping struct

+ ContainerPort *uint32

+ HostPort *uint32

+ Protocol *string

+ XXX_unrecognized []byte

+ 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) (n int, err 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 (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

+ 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) String() string

+ type Containers struct

+ Containers []*ContainerID

+ XXX_unrecognized []byte

+ func (*Containers) ProtoMessage()

+ func (m *Containers) GetContainers() []*ContainerID

+ func (m *Containers) Reset()

+ func (m *Containers) String() string

+ type Credential struct

+ Principal *string

+ Secret []byte

+ XXX_unrecognized []byte

+ func NewPopulatedCredential(r randyMesos, easy bool) *Credential

+ func (*Credential) ProtoMessage()

+ func (m *Credential) GetPrincipal() string

+ func (m *Credential) GetSecret() []byte

+ func (m *Credential) Marshal() (data []byte, err error)

+ func (m *Credential) MarshalTo(data []byte) (n int, err error)

+ func (m *Credential) Reset()

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

+ func (m *Credential) Unmarshal(data []byte) 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

+ type Credentials struct

+ Credentials []*Credential

+ XXX_unrecognized []byte

+ 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) (n int, err error)

+ func (m *Credentials) Reset()

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

+ func (m *Credentials) Unmarshal(data []byte) 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

+ type DeactivateFrameworkMessage struct

+ FrameworkId *FrameworkID

+ XXX_unrecognized []byte

+ func (*DeactivateFrameworkMessage) ProtoMessage()

+ func (m *DeactivateFrameworkMessage) GetFrameworkId() *FrameworkID

+ func (m *DeactivateFrameworkMessage) Reset()

+ func (m *DeactivateFrameworkMessage) String() string

+ type Destroy struct

+ ContainerId *ContainerID

+ XXX_unrecognized []byte

+ func (*Destroy) ProtoMessage()

+ func (m *Destroy) GetContainerId() *ContainerID

+ func (m *Destroy) Reset()

+ func (m *Destroy) String() string

+ type Entry struct

+ Name *string

+ Uuid []byte

+ Value []byte

+ XXX_unrecognized []byte

+ func NewPopulatedEntry(r randyState, easy bool) *Entry

+ func (*Entry) ProtoMessage()

+ func (m *Entry) GetName() string

+ func (m *Entry) GetUuid() []byte

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

+ func (m *Entry) Marshal() (data []byte, err error)

+ func (m *Entry) MarshalTo(data []byte) (n int, err error)

+ func (m *Entry) Reset()

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

+ func (m *Entry) Unmarshal(data []byte) error

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

+ func (this *Entry) GoString() string

+ func (this *Entry) String() string

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

+ type Environment struct

+ Variables []*Environment_Variable

+ XXX_unrecognized []byte

+ 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) (n int, err error)

+ func (m *Environment) Reset()

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

+ func (m *Environment) Unmarshal(data []byte) 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

+ type Environment_Variable struct

+ Name *string

+ Value *string

+ XXX_unrecognized []byte

+ 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) (n int, err error)

+ func (m *Environment_Variable) Reset()

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

+ func (m *Environment_Variable) Unmarshal(data []byte) 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

+ type Event struct

+ Error *Event_Error

+ Failure *Event_Failure

+ Message *Event_Message

+ Offers *Event_Offers

+ Registered *Event_Registered

+ Reregistered *Event_Reregistered

+ Rescind *Event_Rescind

+ Type *Event_Type

+ Update *Event_Update

+ XXX_unrecognized []byte

+ func (*Event) ProtoMessage()

+ func (m *Event) GetError() *Event_Error

+ func (m *Event) GetFailure() *Event_Failure

+ func (m *Event) GetMessage() *Event_Message

+ func (m *Event) GetOffers() *Event_Offers

+ func (m *Event) GetRegistered() *Event_Registered

+ func (m *Event) GetReregistered() *Event_Reregistered

+ func (m *Event) GetRescind() *Event_Rescind

+ func (m *Event) GetType() Event_Type

+ func (m *Event) GetUpdate() *Event_Update

+ func (m *Event) Reset()

+ func (m *Event) String() string

+ type Event_Error struct

+ Message *string

+ XXX_unrecognized []byte

+ func (*Event_Error) ProtoMessage()

+ func (m *Event_Error) GetMessage() string

+ func (m *Event_Error) Reset()

+ func (m *Event_Error) String() string

+ type Event_Failure struct

+ ExecutorId *ExecutorID

+ SlaveId *SlaveID

+ Status *int32

+ XXX_unrecognized []byte

+ func (*Event_Failure) ProtoMessage()

+ func (m *Event_Failure) GetExecutorId() *ExecutorID

+ func (m *Event_Failure) GetSlaveId() *SlaveID

+ func (m *Event_Failure) GetStatus() int32

+ func (m *Event_Failure) Reset()

+ func (m *Event_Failure) String() string

+ type Event_Message struct

+ Data []byte

+ ExecutorId *ExecutorID

+ SlaveId *SlaveID

+ XXX_unrecognized []byte

+ func (*Event_Message) ProtoMessage()

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

+ func (m *Event_Message) GetExecutorId() *ExecutorID

+ func (m *Event_Message) GetSlaveId() *SlaveID

+ func (m *Event_Message) Reset()

+ func (m *Event_Message) String() string

+ type Event_Offers struct

+ Offers []*Offer

+ XXX_unrecognized []byte

+ func (*Event_Offers) ProtoMessage()

+ func (m *Event_Offers) GetOffers() []*Offer

+ func (m *Event_Offers) Reset()

+ func (m *Event_Offers) String() string

+ type Event_Registered struct

+ FrameworkId *FrameworkID

+ MasterInfo *MasterInfo

+ XXX_unrecognized []byte

+ func (*Event_Registered) ProtoMessage()

+ func (m *Event_Registered) GetFrameworkId() *FrameworkID

+ func (m *Event_Registered) GetMasterInfo() *MasterInfo

+ func (m *Event_Registered) Reset()

+ func (m *Event_Registered) String() string

+ type Event_Reregistered struct

+ FrameworkId *FrameworkID

+ MasterInfo *MasterInfo

+ XXX_unrecognized []byte

+ func (*Event_Reregistered) ProtoMessage()

+ func (m *Event_Reregistered) GetFrameworkId() *FrameworkID

+ func (m *Event_Reregistered) GetMasterInfo() *MasterInfo

+ func (m *Event_Reregistered) Reset()

+ func (m *Event_Reregistered) String() string

+ type Event_Rescind struct

+ OfferId *OfferID

+ XXX_unrecognized []byte

+ func (*Event_Rescind) ProtoMessage()

+ func (m *Event_Rescind) GetOfferId() *OfferID

+ func (m *Event_Rescind) Reset()

+ func (m *Event_Rescind) String() string

+ type Event_Type int32

+ const Event_ERROR

+ const Event_FAILURE

+ const Event_MESSAGE

+ const Event_OFFERS

+ const Event_REGISTERED

+ const Event_REREGISTERED

+ const Event_RESCIND

+ const Event_UPDATE

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

+ func (x Event_Type) Enum() *Event_Type

+ func (x Event_Type) String() string

+ type Event_Update struct

+ Status *TaskStatus

+ Uuid []byte

+ XXX_unrecognized []byte

+ func (*Event_Update) ProtoMessage()

+ func (m *Event_Update) GetStatus() *TaskStatus

+ func (m *Event_Update) GetUuid() []byte

+ func (m *Event_Update) Reset()

+ func (m *Event_Update) String() string

+ type ExecutorID struct

+ Value *string

+ XXX_unrecognized []byte

+ 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) (n int, err error)

+ func (m *ExecutorID) Reset()

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

+ func (m *ExecutorID) Unmarshal(data []byte) 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

+ type ExecutorInfo struct

+ Command *CommandInfo

+ Container *ContainerInfo

+ Data []byte

+ ExecutorId *ExecutorID

+ FrameworkId *FrameworkID

+ Name *string

+ Resources []*Resource

+ Source *string

+ XXX_unrecognized []byte

+ 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) GetExecutorId() *ExecutorID

+ func (m *ExecutorInfo) GetFrameworkId() *FrameworkID

+ func (m *ExecutorInfo) GetName() string

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

+ func (m *ExecutorInfo) GetSource() string

+ func (m *ExecutorInfo) Marshal() (data []byte, err error)

+ func (m *ExecutorInfo) MarshalTo(data []byte) (n int, err error)

+ func (m *ExecutorInfo) Reset()

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

+ func (m *ExecutorInfo) Unmarshal(data []byte) 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

+ type ExecutorRegisteredMessage struct

+ ExecutorInfo *ExecutorInfo

+ FrameworkId *FrameworkID

+ FrameworkInfo *FrameworkInfo

+ SlaveId *SlaveID

+ SlaveInfo *SlaveInfo

+ XXX_unrecognized []byte

+ func (*ExecutorRegisteredMessage) ProtoMessage()

+ func (m *ExecutorRegisteredMessage) GetExecutorInfo() *ExecutorInfo

+ func (m *ExecutorRegisteredMessage) GetFrameworkId() *FrameworkID

+ func (m *ExecutorRegisteredMessage) GetFrameworkInfo() *FrameworkInfo

+ func (m *ExecutorRegisteredMessage) GetSlaveId() *SlaveID

+ func (m *ExecutorRegisteredMessage) GetSlaveInfo() *SlaveInfo

+ func (m *ExecutorRegisteredMessage) Reset()

+ func (m *ExecutorRegisteredMessage) String() string

+ type ExecutorReregisteredMessage struct

+ SlaveId *SlaveID

+ SlaveInfo *SlaveInfo

+ XXX_unrecognized []byte

+ func (*ExecutorReregisteredMessage) ProtoMessage()

+ func (m *ExecutorReregisteredMessage) GetSlaveId() *SlaveID

+ func (m *ExecutorReregisteredMessage) GetSlaveInfo() *SlaveInfo

+ func (m *ExecutorReregisteredMessage) Reset()

+ func (m *ExecutorReregisteredMessage) String() string

+ type ExecutorToFrameworkMessage struct

+ Data []byte

+ ExecutorId *ExecutorID

+ FrameworkId *FrameworkID

+ SlaveId *SlaveID

+ XXX_unrecognized []byte

+ func (*ExecutorToFrameworkMessage) ProtoMessage()

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

+ func (m *ExecutorToFrameworkMessage) GetExecutorId() *ExecutorID

+ func (m *ExecutorToFrameworkMessage) GetFrameworkId() *FrameworkID

+ func (m *ExecutorToFrameworkMessage) GetSlaveId() *SlaveID

+ func (m *ExecutorToFrameworkMessage) Reset()

+ func (m *ExecutorToFrameworkMessage) String() string

+ type ExitedExecutorMessage struct

+ ExecutorId *ExecutorID

+ FrameworkId *FrameworkID

+ SlaveId *SlaveID

+ Status *int32

+ XXX_unrecognized []byte

+ func (*ExitedExecutorMessage) ProtoMessage()

+ func (m *ExitedExecutorMessage) GetExecutorId() *ExecutorID

+ func (m *ExitedExecutorMessage) GetFrameworkId() *FrameworkID

+ func (m *ExitedExecutorMessage) GetSlaveId() *SlaveID

+ func (m *ExitedExecutorMessage) GetStatus() int32

+ func (m *ExitedExecutorMessage) Reset()

+ func (m *ExitedExecutorMessage) String() string

+ type Filters struct

+ RefuseSeconds *float64

+ XXX_unrecognized []byte

+ func NewPopulatedFilters(r randyMesos, easy bool) *Filters

+ func (*Filters) ProtoMessage()

+ func (m *Filters) GetRefuseSeconds() float64

+ func (m *Filters) Marshal() (data []byte, err error)

+ func (m *Filters) MarshalTo(data []byte) (n int, err error)

+ func (m *Filters) Reset()

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

+ func (m *Filters) Unmarshal(data []byte) 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

+ type FrameworkErrorMessage struct

+ Message *string

+ XXX_unrecognized []byte

+ func (*FrameworkErrorMessage) ProtoMessage()

+ func (m *FrameworkErrorMessage) GetMessage() string

+ func (m *FrameworkErrorMessage) Reset()

+ func (m *FrameworkErrorMessage) String() string

+ type FrameworkID struct

+ Value *string

+ XXX_unrecognized []byte

+ 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) (n int, err error)

+ func (m *FrameworkID) Reset()

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

+ func (m *FrameworkID) Unmarshal(data []byte) 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

+ type FrameworkInfo struct

+ Checkpoint *bool

+ FailoverTimeout *float64

+ Hostname *string

+ Id *FrameworkID

+ Name *string

+ Principal *string

+ Role *string

+ User *string

+ WebuiUrl *string

+ XXX_unrecognized []byte

+ func NewPopulatedFrameworkInfo(r randyMesos, easy bool) *FrameworkInfo

+ func (*FrameworkInfo) ProtoMessage()

+ func (m *FrameworkInfo) GetCheckpoint() bool

+ func (m *FrameworkInfo) GetFailoverTimeout() float64

+ func (m *FrameworkInfo) GetHostname() string

+ func (m *FrameworkInfo) GetId() *FrameworkID

+ 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) (n int, err error)

+ func (m *FrameworkInfo) Reset()

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

+ func (m *FrameworkInfo) Unmarshal(data []byte) 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

+ type FrameworkRegisteredMessage struct

+ FrameworkId *FrameworkID

+ MasterInfo *MasterInfo

+ XXX_unrecognized []byte

+ func (*FrameworkRegisteredMessage) ProtoMessage()

+ func (m *FrameworkRegisteredMessage) GetFrameworkId() *FrameworkID

+ func (m *FrameworkRegisteredMessage) GetMasterInfo() *MasterInfo

+ func (m *FrameworkRegisteredMessage) Reset()

+ func (m *FrameworkRegisteredMessage) String() string

+ type FrameworkReregisteredMessage struct

+ FrameworkId *FrameworkID

+ MasterInfo *MasterInfo

+ XXX_unrecognized []byte

+ func (*FrameworkReregisteredMessage) ProtoMessage()

+ func (m *FrameworkReregisteredMessage) GetFrameworkId() *FrameworkID

+ func (m *FrameworkReregisteredMessage) GetMasterInfo() *MasterInfo

+ func (m *FrameworkReregisteredMessage) Reset()

+ func (m *FrameworkReregisteredMessage) String() string

+ type FrameworkToExecutorMessage struct

+ Data []byte

+ ExecutorId *ExecutorID

+ FrameworkId *FrameworkID

+ SlaveId *SlaveID

+ XXX_unrecognized []byte

+ func (*FrameworkToExecutorMessage) ProtoMessage()

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

+ func (m *FrameworkToExecutorMessage) GetExecutorId() *ExecutorID

+ func (m *FrameworkToExecutorMessage) GetFrameworkId() *FrameworkID

+ func (m *FrameworkToExecutorMessage) GetSlaveId() *SlaveID

+ func (m *FrameworkToExecutorMessage) Reset()

+ func (m *FrameworkToExecutorMessage) String() string

+ type HealthCheck struct

+ Command *CommandInfo

+ ConsecutiveFailures *uint32

+ DelaySeconds *float64

+ GracePeriodSeconds *float64

+ Http *HealthCheck_HTTP

+ IntervalSeconds *float64

+ TimeoutSeconds *float64

+ XXX_unrecognized []byte

+ 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_HTTP

+ func (m *HealthCheck) GetIntervalSeconds() float64

+ func (m *HealthCheck) GetTimeoutSeconds() float64

+ func (m *HealthCheck) Marshal() (data []byte, err error)

+ func (m *HealthCheck) MarshalTo(data []byte) (n int, err error)

+ func (m *HealthCheck) Reset()

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

+ func (m *HealthCheck) Unmarshal(data []byte) 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

+ type HealthCheck_HTTP struct

+ Path *string

+ Port *uint32

+ Statuses []uint32

+ XXX_unrecognized []byte

+ func NewPopulatedHealthCheck_HTTP(r randyMesos, easy bool) *HealthCheck_HTTP

+ func (*HealthCheck_HTTP) ProtoMessage()

+ func (m *HealthCheck_HTTP) GetPath() string

+ func (m *HealthCheck_HTTP) GetPort() uint32

+ func (m *HealthCheck_HTTP) GetStatuses() []uint32

+ func (m *HealthCheck_HTTP) Marshal() (data []byte, err error)

+ func (m *HealthCheck_HTTP) MarshalTo(data []byte) (n int, err error)

+ func (m *HealthCheck_HTTP) Reset()

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

+ func (m *HealthCheck_HTTP) Unmarshal(data []byte) error

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

+ func (this *HealthCheck_HTTP) GoString() string

+ func (this *HealthCheck_HTTP) String() string

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

+ type InternalAuthenticationResult struct

+ Completed *bool

+ Pid *string

+ Success *bool

+ XXX_unrecognized []byte

+ func (*InternalAuthenticationResult) ProtoMessage()

+ func (m *InternalAuthenticationResult) GetCompleted() bool

+ func (m *InternalAuthenticationResult) GetPid() string

+ func (m *InternalAuthenticationResult) GetSuccess() bool

+ func (m *InternalAuthenticationResult) Reset()

+ func (m *InternalAuthenticationResult) String() string

+ type InternalMasterChangeDetected struct

+ Master *MasterInfo

+ XXX_unrecognized []byte

+ func (*InternalMasterChangeDetected) ProtoMessage()

+ func (m *InternalMasterChangeDetected) GetMaster() *MasterInfo

+ func (m *InternalMasterChangeDetected) Reset()

+ func (m *InternalMasterChangeDetected) String() string

+ type InternalTryAuthentication struct

+ XXX_unrecognized []byte

+ func (*InternalTryAuthentication) ProtoMessage()

+ func (m *InternalTryAuthentication) Reset()

+ func (m *InternalTryAuthentication) String() string

+ type KillTaskMessage struct

+ FrameworkId *FrameworkID

+ TaskId *TaskID

+ XXX_unrecognized []byte

+ func (*KillTaskMessage) ProtoMessage()

+ func (m *KillTaskMessage) GetFrameworkId() *FrameworkID

+ func (m *KillTaskMessage) GetTaskId() *TaskID

+ func (m *KillTaskMessage) Reset()

+ func (m *KillTaskMessage) String() string

+ type Launch struct

+ Checkpoint *bool

+ ContainerId *ContainerID

+ Directory *string

+ ExecutorInfo *ExecutorInfo

+ SlaveId *SlaveID

+ SlavePid *string

+ TaskInfo *TaskInfo

+ User *string

+ XXX_unrecognized []byte

+ func (*Launch) ProtoMessage()

+ func (m *Launch) GetCheckpoint() bool

+ func (m *Launch) GetContainerId() *ContainerID

+ func (m *Launch) GetDirectory() string

+ func (m *Launch) GetExecutorInfo() *ExecutorInfo

+ func (m *Launch) GetSlaveId() *SlaveID

+ func (m *Launch) GetSlavePid() string

+ func (m *Launch) GetTaskInfo() *TaskInfo

+ func (m *Launch) GetUser() string

+ func (m *Launch) Reset()

+ func (m *Launch) String() string

+ type LaunchTasksMessage struct

+ Filters *Filters

+ FrameworkId *FrameworkID

+ OfferIds []*OfferID

+ Tasks []*TaskInfo

+ XXX_unrecognized []byte

+ func (*LaunchTasksMessage) ProtoMessage()

+ func (m *LaunchTasksMessage) GetFilters() *Filters

+ func (m *LaunchTasksMessage) GetFrameworkId() *FrameworkID

+ func (m *LaunchTasksMessage) GetOfferIds() []*OfferID

+ func (m *LaunchTasksMessage) GetTasks() []*TaskInfo

+ func (m *LaunchTasksMessage) Reset()

+ func (m *LaunchTasksMessage) String() string

+ type LearnedMessage struct

+ Action *Action

+ XXX_unrecognized []byte

+ func NewPopulatedLearnedMessage(r randyLog, easy bool) *LearnedMessage

+ func (*LearnedMessage) ProtoMessage()

+ func (m *LearnedMessage) GetAction() *Action

+ func (m *LearnedMessage) Marshal() (data []byte, err error)

+ func (m *LearnedMessage) MarshalTo(data []byte) (n int, err error)

+ func (m *LearnedMessage) Reset()

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

+ func (m *LearnedMessage) Unmarshal(data []byte) error

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

+ func (this *LearnedMessage) GoString() string

+ func (this *LearnedMessage) String() string

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

+ type LostSlaveMessage struct

+ SlaveId *SlaveID

+ XXX_unrecognized []byte

+ func (*LostSlaveMessage) ProtoMessage()

+ func (m *LostSlaveMessage) GetSlaveId() *SlaveID

+ func (m *LostSlaveMessage) Reset()

+ func (m *LostSlaveMessage) String() string

+ type MasterInfo struct

+ Hostname *string

+ Id *string

+ Ip *uint32

+ Pid *string

+ Port *uint32

+ XXX_unrecognized []byte

+ func NewPopulatedMasterInfo(r randyMesos, easy bool) *MasterInfo

+ func (*MasterInfo) ProtoMessage()

+ 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) Marshal() (data []byte, err error)

+ func (m *MasterInfo) MarshalTo(data []byte) (n int, err error)

+ func (m *MasterInfo) Reset()

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

+ func (m *MasterInfo) Unmarshal(data []byte) 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

+ type Metadata struct

+ Promised *uint64

+ Status *Metadata_Status

+ XXX_unrecognized []byte

+ func NewPopulatedMetadata(r randyLog, easy bool) *Metadata

+ func (*Metadata) ProtoMessage()

+ func (m *Metadata) GetPromised() uint64

+ func (m *Metadata) GetStatus() Metadata_Status

+ func (m *Metadata) Marshal() (data []byte, err error)

+ func (m *Metadata) MarshalTo(data []byte) (n int, err error)

+ func (m *Metadata) Reset()

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

+ func (m *Metadata) Unmarshal(data []byte) error

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

+ func (this *Metadata) GoString() string

+ func (this *Metadata) String() string

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

+ type Metadata_Status int32

+ const Default_Metadata_Status

+ const Metadata_EMPTY

+ const Metadata_RECOVERING

+ const Metadata_STARTING

+ const Metadata_VOTING

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

+ func (x Metadata_Status) Enum() *Metadata_Status

+ func (x Metadata_Status) String() string

+ type Modules struct

+ Libraries []*Modules_Library

+ XXX_unrecognized []byte

+ func (*Modules) ProtoMessage()

+ func (m *Modules) GetLibraries() []*Modules_Library

+ func (m *Modules) Reset()

+ func (m *Modules) String() string

+ type Modules_Library struct

+ File *string

+ Modules []*Modules_Library_Module

+ Name *string

+ XXX_unrecognized []byte

+ func (*Modules_Library) ProtoMessage()

+ func (m *Modules_Library) GetFile() string

+ func (m *Modules_Library) GetModules() []*Modules_Library_Module

+ func (m *Modules_Library) GetName() string

+ func (m *Modules_Library) Reset()

+ func (m *Modules_Library) String() string

+ type Modules_Library_Module struct

+ Name *string

+ Parameters []*Parameter

+ XXX_unrecognized []byte

+ func (*Modules_Library_Module) ProtoMessage()

+ func (m *Modules_Library_Module) GetName() string

+ func (m *Modules_Library_Module) GetParameters() []*Parameter

+ func (m *Modules_Library_Module) Reset()

+ func (m *Modules_Library_Module) String() string

+ type Offer struct

+ Attributes []*Attribute

+ ExecutorIds []*ExecutorID

+ FrameworkId *FrameworkID

+ Hostname *string

+ Id *OfferID

+ Resources []*Resource

+ SlaveId *SlaveID

+ XXX_unrecognized []byte

+ func NewPopulatedOffer(r randyMesos, easy bool) *Offer

+ func (*Offer) ProtoMessage()

+ 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) GetSlaveId() *SlaveID

+ func (m *Offer) Marshal() (data []byte, err error)

+ func (m *Offer) MarshalTo(data []byte) (n int, err error)

+ func (m *Offer) Reset()

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

+ func (m *Offer) Unmarshal(data []byte) 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

+ type OfferID struct

+ Value *string

+ XXX_unrecognized []byte

+ 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) (n int, err error)

+ func (m *OfferID) Reset()

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

+ func (m *OfferID) Unmarshal(data []byte) 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

+ type Operation struct

+ Diff *Operation_Diff

+ Expunge *Operation_Expunge

+ Snapshot *Operation_Snapshot

+ Type *Operation_Type

+ XXX_unrecognized []byte

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

+ func (*Operation) ProtoMessage()

+ func (m *Operation) GetDiff() *Operation_Diff

+ func (m *Operation) GetExpunge() *Operation_Expunge

+ func (m *Operation) GetSnapshot() *Operation_Snapshot

+ func (m *Operation) GetType() Operation_Type

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

+ func (m *Operation) MarshalTo(data []byte) (n int, err error)

+ func (m *Operation) Reset()

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

+ func (m *Operation) Unmarshal(data []byte) 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

+ type Operation_Diff struct

+ Entry *Entry

+ XXX_unrecognized []byte

+ func NewPopulatedOperation_Diff(r randyState, easy bool) *Operation_Diff

+ func (*Operation_Diff) ProtoMessage()

+ func (m *Operation_Diff) GetEntry() *Entry

+ func (m *Operation_Diff) Marshal() (data []byte, err error)

+ func (m *Operation_Diff) MarshalTo(data []byte) (n int, err error)

+ func (m *Operation_Diff) Reset()

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

+ func (m *Operation_Diff) Unmarshal(data []byte) error

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

+ func (this *Operation_Diff) GoString() string

+ func (this *Operation_Diff) String() string

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

+ type Operation_Expunge struct

+ Name *string

+ XXX_unrecognized []byte

+ func NewPopulatedOperation_Expunge(r randyState, easy bool) *Operation_Expunge

+ func (*Operation_Expunge) ProtoMessage()

+ func (m *Operation_Expunge) GetName() string

+ func (m *Operation_Expunge) Marshal() (data []byte, err error)

+ func (m *Operation_Expunge) MarshalTo(data []byte) (n int, err error)

+ func (m *Operation_Expunge) Reset()

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

+ func (m *Operation_Expunge) Unmarshal(data []byte) error

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

+ func (this *Operation_Expunge) GoString() string

+ func (this *Operation_Expunge) String() string

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

+ type Operation_Snapshot struct

+ Entry *Entry

+ XXX_unrecognized []byte

+ func NewPopulatedOperation_Snapshot(r randyState, easy bool) *Operation_Snapshot

+ func (*Operation_Snapshot) ProtoMessage()

+ func (m *Operation_Snapshot) GetEntry() *Entry

+ func (m *Operation_Snapshot) Marshal() (data []byte, err error)

+ func (m *Operation_Snapshot) MarshalTo(data []byte) (n int, err error)

+ func (m *Operation_Snapshot) Reset()

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

+ func (m *Operation_Snapshot) Unmarshal(data []byte) error

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

+ func (this *Operation_Snapshot) GoString() string

+ func (this *Operation_Snapshot) String() string

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

+ type Operation_Type int32

+ const Operation_DIFF

+ const Operation_EXPUNGE

+ const Operation_SNAPSHOT

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

+ func (x Operation_Type) Enum() *Operation_Type

+ func (x Operation_Type) String() string

+ type Parameter struct

+ Key *string

+ Value *string

+ XXX_unrecognized []byte

+ 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) (n int, err error)

+ func (m *Parameter) Reset()

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

+ func (m *Parameter) Unmarshal(data []byte) 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

+ type Parameters struct

+ Parameter []*Parameter

+ XXX_unrecognized []byte

+ 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) (n int, err error)

+ func (m *Parameters) Reset()

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

+ func (m *Parameters) Unmarshal(data []byte) 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

+ type PerfStatistics struct

+ AlignmentFaults *uint64

+ BranchLoadMisses *uint64

+ BranchLoads *uint64

+ BranchMisses *uint64

+ Branches *uint64

+ BusCycles *uint64

+ CacheMisses *uint64

+ CacheReferences *uint64

+ ContextSwitches *uint64

+ CpuClock *float64

+ CpuMigrations *uint64

+ Cycles *uint64

+ DtlbLoadMisses *uint64

+ DtlbLoads *uint64

+ DtlbPrefetchMisses *uint64

+ DtlbPrefetches *uint64

+ DtlbStoreMisses *uint64

+ DtlbStores *uint64

+ Duration *float64

+ EmulationFaults *uint64

+ Instructions *uint64

+ ItlbLoadMisses *uint64

+ ItlbLoads *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

+ XXX_unrecognized []byte

+ 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) GetCacheMisses() uint64

+ func (m *PerfStatistics) GetCacheReferences() uint64

+ func (m *PerfStatistics) GetContextSwitches() uint64

+ func (m *PerfStatistics) GetCpuClock() float64

+ func (m *PerfStatistics) GetCpuMigrations() 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) GetInstructions() uint64

+ func (m *PerfStatistics) GetItlbLoadMisses() uint64

+ func (m *PerfStatistics) GetItlbLoads() 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) (n int, err error)

+ func (m *PerfStatistics) Reset()

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

+ func (m *PerfStatistics) Unmarshal(data []byte) 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

+ type PingSlaveMessage struct

+ Connected *bool

+ XXX_unrecognized []byte

+ func (*PingSlaveMessage) ProtoMessage()

+ func (m *PingSlaveMessage) GetConnected() bool

+ func (m *PingSlaveMessage) Reset()

+ func (m *PingSlaveMessage) String() string

+ type PongSlaveMessage struct

+ XXX_unrecognized []byte

+ func (*PongSlaveMessage) ProtoMessage()

+ func (m *PongSlaveMessage) Reset()

+ func (m *PongSlaveMessage) String() string

+ type Promise struct

+ Proposal *uint64

+ XXX_unrecognized []byte

+ func NewPopulatedPromise(r randyLog, easy bool) *Promise

+ func (*Promise) ProtoMessage()

+ func (m *Promise) GetProposal() uint64

+ func (m *Promise) Marshal() (data []byte, err error)

+ func (m *Promise) MarshalTo(data []byte) (n int, err error)

+ func (m *Promise) Reset()

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

+ func (m *Promise) Unmarshal(data []byte) error

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

+ func (this *Promise) GoString() string

+ func (this *Promise) String() string

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

+ type PromiseRequest struct

+ Position *uint64

+ Proposal *uint64

+ XXX_unrecognized []byte

+ func NewPopulatedPromiseRequest(r randyLog, easy bool) *PromiseRequest

+ func (*PromiseRequest) ProtoMessage()

+ func (m *PromiseRequest) GetPosition() uint64

+ func (m *PromiseRequest) GetProposal() uint64

+ func (m *PromiseRequest) Marshal() (data []byte, err error)

+ func (m *PromiseRequest) MarshalTo(data []byte) (n int, err error)

+ func (m *PromiseRequest) Reset()

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

+ func (m *PromiseRequest) Unmarshal(data []byte) error

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

+ func (this *PromiseRequest) GoString() string

+ func (this *PromiseRequest) String() string

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

+ type PromiseResponse struct

+ Action *Action

+ Okay *bool

+ Position *uint64

+ Proposal *uint64

+ XXX_unrecognized []byte

+ func NewPopulatedPromiseResponse(r randyLog, easy bool) *PromiseResponse

+ func (*PromiseResponse) ProtoMessage()

+ func (m *PromiseResponse) GetAction() *Action

+ func (m *PromiseResponse) GetOkay() bool

+ func (m *PromiseResponse) GetPosition() uint64

+ func (m *PromiseResponse) GetProposal() uint64

+ func (m *PromiseResponse) Marshal() (data []byte, err error)

+ func (m *PromiseResponse) MarshalTo(data []byte) (n int, err error)

+ func (m *PromiseResponse) Reset()

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

+ func (m *PromiseResponse) Unmarshal(data []byte) error

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

+ func (this *PromiseResponse) GoString() string

+ func (this *PromiseResponse) String() string

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

+ type RateLimit struct

+ Capacity *uint64

+ Principal *string

+ Qps *float64

+ XXX_unrecognized []byte

+ 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) (n int, err error)

+ func (m *RateLimit) Reset()

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

+ func (m *RateLimit) Unmarshal(data []byte) 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

+ type RateLimits struct

+ AggregateDefaultCapacity *uint64

+ AggregateDefaultQps *float64

+ Limits []*RateLimit

+ XXX_unrecognized []byte

+ 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) (n int, err error)

+ func (m *RateLimits) Reset()

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

+ func (m *RateLimits) Unmarshal(data []byte) 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

+ type ReconcileTasksMessage struct

+ FrameworkId *FrameworkID

+ Statuses []*TaskStatus

+ XXX_unrecognized []byte

+ func (*ReconcileTasksMessage) ProtoMessage()

+ func (m *ReconcileTasksMessage) GetFrameworkId() *FrameworkID

+ func (m *ReconcileTasksMessage) GetStatuses() []*TaskStatus

+ func (m *ReconcileTasksMessage) Reset()

+ func (m *ReconcileTasksMessage) String() string

+ type ReconnectExecutorMessage struct

+ SlaveId *SlaveID

+ XXX_unrecognized []byte

+ func (*ReconnectExecutorMessage) ProtoMessage()

+ func (m *ReconnectExecutorMessage) GetSlaveId() *SlaveID

+ func (m *ReconnectExecutorMessage) Reset()

+ func (m *ReconnectExecutorMessage) String() string

+ type Record struct

+ Action *Action

+ Metadata *Metadata

+ Promise *Promise

+ Type *Record_Type

+ XXX_unrecognized []byte

+ func NewPopulatedRecord(r randyLog, easy bool) *Record

+ func (*Record) ProtoMessage()

+ func (m *Record) GetAction() *Action

+ func (m *Record) GetMetadata() *Metadata

+ func (m *Record) GetPromise() *Promise

+ func (m *Record) GetType() Record_Type

+ func (m *Record) Marshal() (data []byte, err error)

+ func (m *Record) MarshalTo(data []byte) (n int, err error)

+ func (m *Record) Reset()

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

+ func (m *Record) Unmarshal(data []byte) error

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

+ func (this *Record) GoString() string

+ func (this *Record) String() string

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

+ type Record_Type int32

+ const Record_ACTION

+ const Record_METADATA

+ const Record_PROMISE

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

+ func (x Record_Type) Enum() *Record_Type

+ func (x Record_Type) String() string

+ type RecoverRequest struct

+ XXX_unrecognized []byte

+ func NewPopulatedRecoverRequest(r randyLog, easy bool) *RecoverRequest

+ func (*RecoverRequest) ProtoMessage()

+ func (m *RecoverRequest) Marshal() (data []byte, err error)

+ func (m *RecoverRequest) MarshalTo(data []byte) (n int, err error)

+ func (m *RecoverRequest) Reset()

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

+ func (m *RecoverRequest) Unmarshal(data []byte) error

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

+ func (this *RecoverRequest) GoString() string

+ func (this *RecoverRequest) String() string

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

+ type RecoverResponse struct

+ Begin *uint64

+ End *uint64

+ Status *Metadata_Status

+ XXX_unrecognized []byte

+ func NewPopulatedRecoverResponse(r randyLog, easy bool) *RecoverResponse

+ func (*RecoverResponse) ProtoMessage()

+ func (m *RecoverResponse) GetBegin() uint64

+ func (m *RecoverResponse) GetEnd() uint64

+ func (m *RecoverResponse) GetStatus() Metadata_Status

+ func (m *RecoverResponse) Marshal() (data []byte, err error)

+ func (m *RecoverResponse) MarshalTo(data []byte) (n int, err error)

+ func (m *RecoverResponse) Reset()

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

+ func (m *RecoverResponse) Unmarshal(data []byte) error

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

+ func (this *RecoverResponse) GoString() string

+ func (this *RecoverResponse) String() string

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

+ type RegisterExecutorMessage struct

+ ExecutorId *ExecutorID

+ FrameworkId *FrameworkID

+ XXX_unrecognized []byte

+ func (*RegisterExecutorMessage) ProtoMessage()

+ func (m *RegisterExecutorMessage) GetExecutorId() *ExecutorID

+ func (m *RegisterExecutorMessage) GetFrameworkId() *FrameworkID

+ func (m *RegisterExecutorMessage) Reset()

+ func (m *RegisterExecutorMessage) String() string

+ type RegisterFrameworkMessage struct

+ Framework *FrameworkInfo

+ XXX_unrecognized []byte

+ func (*RegisterFrameworkMessage) ProtoMessage()

+ func (m *RegisterFrameworkMessage) GetFramework() *FrameworkInfo

+ func (m *RegisterFrameworkMessage) Reset()

+ func (m *RegisterFrameworkMessage) String() string

+ type RegisterSlaveMessage struct

+ Slave *SlaveInfo

+ Version *string

+ XXX_unrecognized []byte

+ func (*RegisterSlaveMessage) ProtoMessage()

+ func (m *RegisterSlaveMessage) GetSlave() *SlaveInfo

+ func (m *RegisterSlaveMessage) GetVersion() string

+ func (m *RegisterSlaveMessage) Reset()

+ func (m *RegisterSlaveMessage) String() string

+ type Registry struct

+ Master *Registry_Master

+ Slaves *Registry_Slaves

+ XXX_unrecognized []byte

+ func (*Registry) ProtoMessage()

+ func (m *Registry) GetMaster() *Registry_Master

+ func (m *Registry) GetSlaves() *Registry_Slaves

+ func (m *Registry) Reset()

+ func (m *Registry) String() string

+ type Registry_Master struct

+ Info *MasterInfo

+ XXX_unrecognized []byte

+ func (*Registry_Master) ProtoMessage()

+ func (m *Registry_Master) GetInfo() *MasterInfo

+ func (m *Registry_Master) Reset()

+ func (m *Registry_Master) String() string

+ type Registry_Slave struct

+ Info *SlaveInfo

+ XXX_unrecognized []byte

+ func (*Registry_Slave) ProtoMessage()

+ func (m *Registry_Slave) GetInfo() *SlaveInfo

+ func (m *Registry_Slave) Reset()

+ func (m *Registry_Slave) String() string

+ type Registry_Slaves struct

+ Slaves []*Registry_Slave

+ XXX_unrecognized []byte

+ func (*Registry_Slaves) ProtoMessage()

+ func (m *Registry_Slaves) GetSlaves() []*Registry_Slave

+ func (m *Registry_Slaves) Reset()

+ func (m *Registry_Slaves) String() string

+ type Request struct

+ Resources []*Resource

+ SlaveId *SlaveID

+ XXX_unrecognized []byte

+ func NewPopulatedRequest(r randyMesos, easy bool) *Request

+ func (*Request) ProtoMessage()

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

+ func (m *Request) GetSlaveId() *SlaveID

+ func (m *Request) Marshal() (data []byte, err error)

+ func (m *Request) MarshalTo(data []byte) (n int, err error)

+ func (m *Request) Reset()

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

+ func (m *Request) Unmarshal(data []byte) 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

+ type ReregisterExecutorMessage struct

+ ExecutorId *ExecutorID

+ FrameworkId *FrameworkID

+ Tasks []*TaskInfo

+ Updates []*StatusUpdate

+ XXX_unrecognized []byte

+ func (*ReregisterExecutorMessage) ProtoMessage()

+ func (m *ReregisterExecutorMessage) GetExecutorId() *ExecutorID

+ func (m *ReregisterExecutorMessage) GetFrameworkId() *FrameworkID

+ func (m *ReregisterExecutorMessage) GetTasks() []*TaskInfo

+ func (m *ReregisterExecutorMessage) GetUpdates() []*StatusUpdate

+ func (m *ReregisterExecutorMessage) Reset()

+ func (m *ReregisterExecutorMessage) String() string

+ type ReregisterFrameworkMessage struct

+ Failover *bool

+ Framework *FrameworkInfo

+ XXX_unrecognized []byte

+ func (*ReregisterFrameworkMessage) ProtoMessage()

+ func (m *ReregisterFrameworkMessage) GetFailover() bool

+ func (m *ReregisterFrameworkMessage) GetFramework() *FrameworkInfo

+ func (m *ReregisterFrameworkMessage) Reset()

+ func (m *ReregisterFrameworkMessage) String() string

+ type ReregisterSlaveMessage struct

+ CompletedFrameworks []*Archive_Framework

+ ExecutorInfos []*ExecutorInfo

+ Slave *SlaveInfo

+ SlaveId *SlaveID

+ Tasks []*Task

+ Version *string

+ XXX_unrecognized []byte

+ func (*ReregisterSlaveMessage) ProtoMessage()

+ func (m *ReregisterSlaveMessage) GetCompletedFrameworks() []*Archive_Framework

+ func (m *ReregisterSlaveMessage) GetExecutorInfos() []*ExecutorInfo

+ func (m *ReregisterSlaveMessage) GetSlave() *SlaveInfo

+ func (m *ReregisterSlaveMessage) GetSlaveId() *SlaveID

+ func (m *ReregisterSlaveMessage) GetTasks() []*Task

+ func (m *ReregisterSlaveMessage) GetVersion() string

+ func (m *ReregisterSlaveMessage) Reset()

+ func (m *ReregisterSlaveMessage) String() string

+ type RescindResourceOfferMessage struct

+ OfferId *OfferID

+ XXX_unrecognized []byte

+ func (*RescindResourceOfferMessage) ProtoMessage()

+ func (m *RescindResourceOfferMessage) GetOfferId() *OfferID

+ func (m *RescindResourceOfferMessage) Reset()

+ func (m *RescindResourceOfferMessage) String() string

+ type Resource struct

+ Name *string

+ Ranges *Value_Ranges

+ Role *string

+ Scalar *Value_Scalar

+ Set *Value_Set

+ Type *Value_Type

+ XXX_unrecognized []byte

+ func NewPopulatedResource(r randyMesos, easy bool) *Resource

+ func (*Resource) ProtoMessage()

+ func (m *Resource) GetName() string

+ func (m *Resource) GetRanges() *Value_Ranges

+ func (m *Resource) GetRole() string

+ func (m *Resource) GetScalar() *Value_Scalar

+ func (m *Resource) GetSet() *Value_Set

+ func (m *Resource) GetType() Value_Type

+ func (m *Resource) Marshal() (data []byte, err error)

+ func (m *Resource) MarshalTo(data []byte) (n int, err error)

+ func (m *Resource) Reset()

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

+ func (m *Resource) Unmarshal(data []byte) 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

+ type ResourceOffersMessage struct

+ Offers []*Offer

+ Pids []string

+ XXX_unrecognized []byte

+ func (*ResourceOffersMessage) ProtoMessage()

+ func (m *ResourceOffersMessage) GetOffers() []*Offer

+ func (m *ResourceOffersMessage) GetPids() []string

+ func (m *ResourceOffersMessage) Reset()

+ func (m *ResourceOffersMessage) String() string

+ type ResourceRequestMessage struct

+ FrameworkId *FrameworkID

+ Requests []*Request

+ XXX_unrecognized []byte

+ func (*ResourceRequestMessage) ProtoMessage()

+ func (m *ResourceRequestMessage) GetFrameworkId() *FrameworkID

+ func (m *ResourceRequestMessage) GetRequests() []*Request

+ func (m *ResourceRequestMessage) Reset()

+ func (m *ResourceRequestMessage) String() string

+ type ResourceStatistics struct

+ CpusLimit *float64

+ CpusNrPeriods *uint32

+ CpusNrThrottled *uint32

+ CpusSystemTimeSecs *float64

+ CpusThrottledTimeSecs *float64

+ CpusUserTimeSecs *float64

+ MemAnonBytes *uint64

+ MemFileBytes *uint64

+ MemLimitBytes *uint64

+ MemMappedFileBytes *uint64

+ MemRssBytes *uint64

+ NetRxBytes *uint64

+ NetRxDropped *uint64

+ NetRxErrors *uint64

+ NetRxPackets *uint64

+ NetTcpRttMicrosecsP50 *float64

+ NetTcpRttMicrosecsP90 *float64

+ NetTcpRttMicrosecsP95 *float64

+ NetTcpRttMicrosecsP99 *float64

+ NetTxBytes *uint64

+ NetTxDropped *uint64

+ NetTxErrors *uint64

+ NetTxPackets *uint64

+ Perf *PerfStatistics

+ Timestamp *float64

+ XXX_unrecognized []byte

+ 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) GetMemAnonBytes() uint64

+ func (m *ResourceStatistics) GetMemFileBytes() uint64

+ func (m *ResourceStatistics) GetMemLimitBytes() uint64

+ func (m *ResourceStatistics) GetMemMappedFileBytes() uint64

+ func (m *ResourceStatistics) GetMemRssBytes() uint64

+ func (m *ResourceStatistics) GetNetRxBytes() uint64

+ func (m *ResourceStatistics) GetNetRxDropped() uint64

+ func (m *ResourceStatistics) GetNetRxErrors() uint64

+ func (m *ResourceStatistics) GetNetRxPackets() uint64

+ func (m *ResourceStatistics) GetNetTcpRttMicrosecsP50() float64

+ func (m *ResourceStatistics) GetNetTcpRttMicrosecsP90() float64

+ func (m *ResourceStatistics) GetNetTcpRttMicrosecsP95() float64

+ func (m *ResourceStatistics) GetNetTcpRttMicrosecsP99() float64

+ 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) GetTimestamp() float64

+ func (m *ResourceStatistics) Marshal() (data []byte, err error)

+ func (m *ResourceStatistics) MarshalTo(data []byte) (n int, err error)

+ func (m *ResourceStatistics) Reset()

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

+ func (m *ResourceStatistics) Unmarshal(data []byte) 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

+ type ResourceUsage struct

+ ExecutorId *ExecutorID

+ ExecutorName *string

+ FrameworkId *FrameworkID

+ SlaveId *SlaveID

+ Statistics *ResourceStatistics

+ TaskId *TaskID

+ XXX_unrecognized []byte

+ func NewPopulatedResourceUsage(r randyMesos, easy bool) *ResourceUsage

+ func (*ResourceUsage) ProtoMessage()

+ func (m *ResourceUsage) GetExecutorId() *ExecutorID

+ func (m *ResourceUsage) GetExecutorName() string

+ func (m *ResourceUsage) GetFrameworkId() *FrameworkID

+ func (m *ResourceUsage) GetSlaveId() *SlaveID

+ func (m *ResourceUsage) GetStatistics() *ResourceStatistics

+ func (m *ResourceUsage) GetTaskId() *TaskID

+ func (m *ResourceUsage) Marshal() (data []byte, err error)

+ func (m *ResourceUsage) MarshalTo(data []byte) (n int, err error)

+ func (m *ResourceUsage) Reset()

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

+ func (m *ResourceUsage) Unmarshal(data []byte) 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

+ type ReviveOffersMessage struct

+ FrameworkId *FrameworkID

+ XXX_unrecognized []byte

+ func (*ReviveOffersMessage) ProtoMessage()

+ func (m *ReviveOffersMessage) GetFrameworkId() *FrameworkID

+ func (m *ReviveOffersMessage) Reset()

+ func (m *ReviveOffersMessage) String() string

+ type RoleInfo struct

+ Name *string

+ Weight *float64

+ XXX_unrecognized []byte

+ func (*RoleInfo) ProtoMessage()

+ func (m *RoleInfo) GetName() string

+ func (m *RoleInfo) GetWeight() float64

+ func (m *RoleInfo) Reset()

+ func (m *RoleInfo) String() string

+ type RunTaskMessage struct

+ Framework *FrameworkInfo

+ FrameworkId *FrameworkID

+ Pid *string

+ Task *TaskInfo

+ XXX_unrecognized []byte

+ func (*RunTaskMessage) ProtoMessage()

+ func (m *RunTaskMessage) GetFramework() *FrameworkInfo

+ func (m *RunTaskMessage) GetFrameworkId() *FrameworkID

+ func (m *RunTaskMessage) GetPid() string

+ func (m *RunTaskMessage) GetTask() *TaskInfo

+ func (m *RunTaskMessage) Reset()

+ func (m *RunTaskMessage) String() string

+ type ShutdownExecutorMessage struct

+ XXX_unrecognized []byte

+ func (*ShutdownExecutorMessage) ProtoMessage()

+ func (m *ShutdownExecutorMessage) Reset()

+ func (m *ShutdownExecutorMessage) String() string

+ type ShutdownFrameworkMessage struct

+ FrameworkId *FrameworkID

+ XXX_unrecognized []byte

+ func (*ShutdownFrameworkMessage) ProtoMessage()

+ func (m *ShutdownFrameworkMessage) GetFrameworkId() *FrameworkID

+ func (m *ShutdownFrameworkMessage) Reset()

+ func (m *ShutdownFrameworkMessage) String() string

+ type ShutdownMessage struct

+ Message *string

+ XXX_unrecognized []byte

+ func (*ShutdownMessage) ProtoMessage()

+ func (m *ShutdownMessage) GetMessage() string

+ func (m *ShutdownMessage) Reset()

+ func (m *ShutdownMessage) String() string

+ type SlaveID struct

+ Value *string

+ XXX_unrecognized []byte

+ func NewPopulatedSlaveID(r randyMesos, easy bool) *SlaveID

+ func (*SlaveID) ProtoMessage()

+ func (m *SlaveID) GetValue() string

+ func (m *SlaveID) Marshal() (data []byte, err error)

+ func (m *SlaveID) MarshalTo(data []byte) (n int, err error)

+ func (m *SlaveID) Reset()

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

+ func (m *SlaveID) Unmarshal(data []byte) error

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

+ func (this *SlaveID) GoString() string

+ func (this *SlaveID) String() string

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

+ type SlaveInfo struct

+ Attributes []*Attribute

+ Checkpoint *bool

+ Hostname *string

+ Id *SlaveID

+ Port *int32

+ Resources []*Resource

+ XXX_unrecognized []byte

+ func NewPopulatedSlaveInfo(r randyMesos, easy bool) *SlaveInfo

+ func (*SlaveInfo) ProtoMessage()

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

+ func (m *SlaveInfo) GetCheckpoint() bool

+ func (m *SlaveInfo) GetHostname() string

+ func (m *SlaveInfo) GetId() *SlaveID

+ func (m *SlaveInfo) GetPort() int32

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

+ func (m *SlaveInfo) Marshal() (data []byte, err error)

+ func (m *SlaveInfo) MarshalTo(data []byte) (n int, err error)

+ func (m *SlaveInfo) Reset()

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

+ func (m *SlaveInfo) Unmarshal(data []byte) error

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

+ func (this *SlaveInfo) GoString() string

+ func (this *SlaveInfo) String() string

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

+ type SlaveRegisteredMessage struct

+ SlaveId *SlaveID

+ XXX_unrecognized []byte

+ func (*SlaveRegisteredMessage) ProtoMessage()

+ func (m *SlaveRegisteredMessage) GetSlaveId() *SlaveID

+ func (m *SlaveRegisteredMessage) Reset()

+ func (m *SlaveRegisteredMessage) String() string

+ type SlaveReregisteredMessage struct

+ Reconciliations []*ReconcileTasksMessage

+ SlaveId *SlaveID

+ XXX_unrecognized []byte

+ func (*SlaveReregisteredMessage) ProtoMessage()

+ func (m *SlaveReregisteredMessage) GetReconciliations() []*ReconcileTasksMessage

+ func (m *SlaveReregisteredMessage) GetSlaveId() *SlaveID

+ func (m *SlaveReregisteredMessage) Reset()

+ func (m *SlaveReregisteredMessage) String() string

+ type Status int32

+ const Status_DRIVER_ABORTED

+ const Status_DRIVER_NOT_STARTED

+ const Status_DRIVER_RUNNING

+ const Status_DRIVER_STOPPED

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

+ func (x Status) Enum() *Status

+ func (x Status) String() string

+ type StatusUpdate struct

+ ExecutorId *ExecutorID

+ FrameworkId *FrameworkID

+ LatestState *TaskState

+ SlaveId *SlaveID

+ Status *TaskStatus

+ Timestamp *float64

+ Uuid []byte

+ XXX_unrecognized []byte

+ func (*StatusUpdate) ProtoMessage()

+ func (m *StatusUpdate) GetExecutorId() *ExecutorID

+ func (m *StatusUpdate) GetFrameworkId() *FrameworkID

+ func (m *StatusUpdate) GetLatestState() TaskState

+ func (m *StatusUpdate) GetSlaveId() *SlaveID

+ func (m *StatusUpdate) GetStatus() *TaskStatus

+ func (m *StatusUpdate) GetTimestamp() float64

+ func (m *StatusUpdate) GetUuid() []byte

+ func (m *StatusUpdate) Reset()

+ func (m *StatusUpdate) String() string

+ type StatusUpdateAcknowledgementMessage struct

+ FrameworkId *FrameworkID

+ SlaveId *SlaveID

+ TaskId *TaskID

+ Uuid []byte

+ XXX_unrecognized []byte

+ func (*StatusUpdateAcknowledgementMessage) ProtoMessage()

+ func (m *StatusUpdateAcknowledgementMessage) GetFrameworkId() *FrameworkID

+ func (m *StatusUpdateAcknowledgementMessage) GetSlaveId() *SlaveID

+ func (m *StatusUpdateAcknowledgementMessage) GetTaskId() *TaskID

+ func (m *StatusUpdateAcknowledgementMessage) GetUuid() []byte

+ func (m *StatusUpdateAcknowledgementMessage) Reset()

+ func (m *StatusUpdateAcknowledgementMessage) String() string

+ type StatusUpdateMessage struct

+ Pid *string

+ Update *StatusUpdate

+ XXX_unrecognized []byte

+ func (*StatusUpdateMessage) ProtoMessage()

+ func (m *StatusUpdateMessage) GetPid() string

+ func (m *StatusUpdateMessage) GetUpdate() *StatusUpdate

+ func (m *StatusUpdateMessage) Reset()

+ func (m *StatusUpdateMessage) String() string

+ type StatusUpdateRecord struct

+ Type *StatusUpdateRecord_Type

+ Update *StatusUpdate

+ Uuid []byte

+ XXX_unrecognized []byte

+ func (*StatusUpdateRecord) ProtoMessage()

+ func (m *StatusUpdateRecord) GetType() StatusUpdateRecord_Type

+ func (m *StatusUpdateRecord) GetUpdate() *StatusUpdate

+ func (m *StatusUpdateRecord) GetUuid() []byte

+ func (m *StatusUpdateRecord) Reset()

+ func (m *StatusUpdateRecord) String() string

+ type StatusUpdateRecord_Type int32

+ const StatusUpdateRecord_ACK

+ const StatusUpdateRecord_UPDATE

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

+ func (x StatusUpdateRecord_Type) Enum() *StatusUpdateRecord_Type

+ func (x StatusUpdateRecord_Type) String() string

+ type SubmitSchedulerRequest struct

+ Name *string

+ XXX_unrecognized []byte

+ func (*SubmitSchedulerRequest) ProtoMessage()

+ func (m *SubmitSchedulerRequest) GetName() string

+ func (m *SubmitSchedulerRequest) Reset()

+ func (m *SubmitSchedulerRequest) String() string

+ type SubmitSchedulerResponse struct

+ Okay *bool

+ XXX_unrecognized []byte

+ func (*SubmitSchedulerResponse) ProtoMessage()

+ func (m *SubmitSchedulerResponse) GetOkay() bool

+ func (m *SubmitSchedulerResponse) Reset()

+ func (m *SubmitSchedulerResponse) String() string

+ type Task struct

+ ExecutorId *ExecutorID

+ FrameworkId *FrameworkID

+ Name *string

+ Resources []*Resource

+ SlaveId *SlaveID

+ State *TaskState

+ StatusUpdateState *TaskState

+ StatusUpdateUuid []byte

+ Statuses []*TaskStatus

+ TaskId *TaskID

+ XXX_unrecognized []byte

+ func (*Task) ProtoMessage()

+ func (m *Task) GetExecutorId() *ExecutorID

+ func (m *Task) GetFrameworkId() *FrameworkID

+ func (m *Task) GetName() string

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

+ func (m *Task) GetSlaveId() *SlaveID

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

+ func (m *Task) String() string

+ type TaskHealthStatus struct

+ ConsecutiveFailures *int32

+ Healthy *bool

+ KillTask *bool

+ TaskId *TaskID

+ XXX_unrecognized []byte

+ func (*TaskHealthStatus) ProtoMessage()

+ func (m *TaskHealthStatus) GetConsecutiveFailures() int32

+ func (m *TaskHealthStatus) GetHealthy() bool

+ func (m *TaskHealthStatus) GetKillTask() bool

+ func (m *TaskHealthStatus) GetTaskId() *TaskID

+ func (m *TaskHealthStatus) Reset()

+ func (m *TaskHealthStatus) String() string

+ type TaskID struct

+ Value *string

+ XXX_unrecognized []byte

+ 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) (n int, err error)

+ func (m *TaskID) Reset()

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

+ func (m *TaskID) Unmarshal(data []byte) 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

+ type TaskInfo struct

+ Command *CommandInfo

+ Container *ContainerInfo

+ Data []byte

+ Executor *ExecutorInfo

+ HealthCheck *HealthCheck

+ Name *string

+ Resources []*Resource

+ SlaveId *SlaveID

+ TaskId *TaskID

+ XXX_unrecognized []byte

+ func NewPopulatedTaskInfo(r randyMesos, easy bool) *TaskInfo

+ func (*TaskInfo) ProtoMessage()

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

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

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

+ func (m *TaskInfo) GetExecutor() *ExecutorInfo

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

+ func (m *TaskInfo) GetName() string

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

+ func (m *TaskInfo) GetSlaveId() *SlaveID

+ func (m *TaskInfo) GetTaskId() *TaskID

+ func (m *TaskInfo) Marshal() (data []byte, err error)

+ func (m *TaskInfo) MarshalTo(data []byte) (n int, err error)

+ func (m *TaskInfo) Reset()

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

+ func (m *TaskInfo) Unmarshal(data []byte) 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

+ type TaskState int32

+ const TaskState_TASK_ERROR

+ const TaskState_TASK_FAILED

+ const TaskState_TASK_FINISHED

+ const TaskState_TASK_KILLED

+ const TaskState_TASK_LOST

+ const TaskState_TASK_RUNNING

+ const TaskState_TASK_STAGING

+ const TaskState_TASK_STARTING

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

+ func (x TaskState) Enum() *TaskState

+ func (x TaskState) String() string

+ type TaskStatus struct

+ Data []byte

+ ExecutorId *ExecutorID

+ Healthy *bool

+ Message *string

+ Reason *TaskStatus_Reason

+ SlaveId *SlaveID

+ Source *TaskStatus_Source

+ State *TaskState

+ TaskId *TaskID

+ Timestamp *float64

+ XXX_unrecognized []byte

+ func NewPopulatedTaskStatus(r randyMesos, easy bool) *TaskStatus

+ func (*TaskStatus) ProtoMessage()

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

+ func (m *TaskStatus) GetExecutorId() *ExecutorID

+ func (m *TaskStatus) GetHealthy() bool

+ func (m *TaskStatus) GetMessage() string

+ func (m *TaskStatus) GetReason() TaskStatus_Reason

+ func (m *TaskStatus) GetSlaveId() *SlaveID

+ func (m *TaskStatus) GetSource() TaskStatus_Source

+ func (m *TaskStatus) GetState() TaskState

+ func (m *TaskStatus) GetTaskId() *TaskID

+ func (m *TaskStatus) GetTimestamp() float64

+ func (m *TaskStatus) Marshal() (data []byte, err error)

+ func (m *TaskStatus) MarshalTo(data []byte) (n int, err error)

+ func (m *TaskStatus) Reset()

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

+ func (m *TaskStatus) Unmarshal(data []byte) 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

+ type TaskStatus_Reason int32

+ const TaskStatus_REASON_COMMAND_EXECUTOR_FAILED

+ const TaskStatus_REASON_EXECUTOR_TERMINATED

+ const TaskStatus_REASON_EXECUTOR_UNREGISTERED

+ const TaskStatus_REASON_FRAMEWORK_REMOVED

+ const TaskStatus_REASON_GC_ERROR

+ const TaskStatus_REASON_INVALID_FRAMEWORKID

+ const TaskStatus_REASON_INVALID_OFFERS

+ const TaskStatus_REASON_MASTER_DISCONNECTED

+ const TaskStatus_REASON_MEMORY_LIMIT

+ const TaskStatus_REASON_RECONCILIATION

+ const TaskStatus_REASON_SLAVE_DISCONNECTED

+ const TaskStatus_REASON_SLAVE_REMOVED

+ const TaskStatus_REASON_SLAVE_RESTARTED

+ const TaskStatus_REASON_SLAVE_UNKNOWN

+ const TaskStatus_REASON_TASK_INVALID

+ const TaskStatus_REASON_TASK_UNAUTHORIZED

+ const TaskStatus_REASON_TASK_UNKNOWN

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

+ func (x TaskStatus_Reason) Enum() *TaskStatus_Reason

+ func (x TaskStatus_Reason) String() string

+ type TaskStatus_Source int32

+ const TaskStatus_SOURCE_EXECUTOR

+ const TaskStatus_SOURCE_MASTER

+ const TaskStatus_SOURCE_SLAVE

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

+ func (x TaskStatus_Source) Enum() *TaskStatus_Source

+ func (x TaskStatus_Source) String() string

+ type Termination struct

+ Killed *bool

+ Message *string

+ Status *int32

+ XXX_unrecognized []byte

+ func (*Termination) ProtoMessage()

+ func (m *Termination) GetKilled() bool

+ func (m *Termination) GetMessage() string

+ func (m *Termination) GetStatus() int32

+ func (m *Termination) Reset()

+ func (m *Termination) String() string

+ type UnregisterFrameworkMessage struct

+ FrameworkId *FrameworkID

+ XXX_unrecognized []byte

+ func (*UnregisterFrameworkMessage) ProtoMessage()

+ func (m *UnregisterFrameworkMessage) GetFrameworkId() *FrameworkID

+ func (m *UnregisterFrameworkMessage) Reset()

+ func (m *UnregisterFrameworkMessage) String() string

+ type UnregisterSlaveMessage struct

+ SlaveId *SlaveID

+ XXX_unrecognized []byte

+ func (*UnregisterSlaveMessage) ProtoMessage()

+ func (m *UnregisterSlaveMessage) GetSlaveId() *SlaveID

+ func (m *UnregisterSlaveMessage) Reset()

+ func (m *UnregisterSlaveMessage) String() string

+ type Update struct

+ ContainerId *ContainerID

+ Resources []*Resource

+ XXX_unrecognized []byte

+ func (*Update) ProtoMessage()

+ func (m *Update) GetContainerId() *ContainerID

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

+ func (m *Update) Reset()

+ func (m *Update) String() string

+ type UpdateFrameworkMessage struct

+ FrameworkId *FrameworkID

+ Pid *string

+ XXX_unrecognized []byte

+ func (*UpdateFrameworkMessage) ProtoMessage()

+ func (m *UpdateFrameworkMessage) GetFrameworkId() *FrameworkID

+ func (m *UpdateFrameworkMessage) GetPid() string

+ func (m *UpdateFrameworkMessage) Reset()

+ func (m *UpdateFrameworkMessage) String() string

+ type Usage struct

+ ContainerId *ContainerID

+ XXX_unrecognized []byte

+ func (*Usage) ProtoMessage()

+ func (m *Usage) GetContainerId() *ContainerID

+ func (m *Usage) Reset()

+ func (m *Usage) String() string

+ type Value struct

+ Ranges *Value_Ranges

+ Scalar *Value_Scalar

+ Set *Value_Set

+ Text *Value_Text

+ Type *Value_Type

+ XXX_unrecognized []byte

+ 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) (n int, err error)

+ func (m *Value) Reset()

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

+ func (m *Value) Unmarshal(data []byte) 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

+ type Value_Range struct

+ Begin *uint64

+ End *uint64

+ XXX_unrecognized []byte

+ 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) (n int, err error)

+ func (m *Value_Range) Reset()

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

+ func (m *Value_Range) Unmarshal(data []byte) 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

+ type Value_Ranges struct

+ Range []*Value_Range

+ XXX_unrecognized []byte

+ func NewPopulatedValue_Ranges(r randyMesos, easy bool) *Value_Ranges

+ func (*Value_Ranges) ProtoMessage()

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

+ func (m *Value_Ranges) Marshal() (data []byte, err error)

+ func (m *Value_Ranges) MarshalTo(data []byte) (n int, err error)

+ func (m *Value_Ranges) Reset()

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

+ func (m *Value_Ranges) Unmarshal(data []byte) 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

+ type Value_Scalar struct

+ Value *float64

+ XXX_unrecognized []byte

+ func NewPopulatedValue_Scalar(r randyMesos, easy bool) *Value_Scalar

+ func (*Value_Scalar) ProtoMessage()

+ func (m *Value_Scalar) GetValue() float64

+ func (m *Value_Scalar) Marshal() (data []byte, err error)

+ func (m *Value_Scalar) MarshalTo(data []byte) (n int, err error)

+ func (m *Value_Scalar) Reset()

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

+ func (m *Value_Scalar) Unmarshal(data []byte) 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

+ type Value_Set struct

+ Item []string

+ XXX_unrecognized []byte

+ func NewPopulatedValue_Set(r randyMesos, easy bool) *Value_Set

+ func (*Value_Set) ProtoMessage()

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

+ func (m *Value_Set) Marshal() (data []byte, err error)

+ func (m *Value_Set) MarshalTo(data []byte) (n int, err error)

+ func (m *Value_Set) Reset()

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

+ func (m *Value_Set) Unmarshal(data []byte) 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

+ type Value_Text struct

+ Value *string

+ XXX_unrecognized []byte

+ 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) (n int, err error)

+ func (m *Value_Text) Reset()

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

+ func (m *Value_Text) Unmarshal(data []byte) 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

+ type Value_Type int32

+ const Value_RANGES

+ const Value_SCALAR

+ const Value_SET

+ const Value_TEXT

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

+ func (x Value_Type) Enum() *Value_Type

+ func (x Value_Type) String() string

+ type Volume struct

+ ContainerPath *string

+ HostPath *string

+ Mode *Volume_Mode

+ XXX_unrecognized []byte

+ func NewPopulatedVolume(r randyMesos, easy bool) *Volume

+ func (*Volume) ProtoMessage()

+ func (m *Volume) GetContainerPath() string

+ func (m *Volume) GetHostPath() string

+ func (m *Volume) GetMode() Volume_Mode

+ func (m *Volume) Marshal() (data []byte, err error)

+ func (m *Volume) MarshalTo(data []byte) (n int, err error)

+ func (m *Volume) Reset()

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

+ func (m *Volume) Unmarshal(data []byte) 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

+ type Volume_Mode int32

+ const Volume_RO

+ const Volume_RW

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

+ func (x Volume_Mode) Enum() *Volume_Mode

+ func (x Volume_Mode) String() string

+ type Wait struct

+ ContainerId *ContainerID

+ XXX_unrecognized []byte

+ func (*Wait) ProtoMessage()

+ func (m *Wait) GetContainerId() *ContainerID

+ func (m *Wait) Reset()

+ func (m *Wait) String() string

+ type WriteRequest struct

+ Append *Action_Append

+ Learned *bool

+ Nop *Action_Nop

+ Position *uint64

+ Proposal *uint64

+ Truncate *Action_Truncate

+ Type *Action_Type

+ XXX_unrecognized []byte

+ func NewPopulatedWriteRequest(r randyLog, easy bool) *WriteRequest

+ func (*WriteRequest) ProtoMessage()

+ func (m *WriteRequest) GetAppend() *Action_Append

+ func (m *WriteRequest) GetLearned() bool

+ func (m *WriteRequest) GetNop() *Action_Nop

+ func (m *WriteRequest) GetPosition() uint64

+ func (m *WriteRequest) GetProposal() uint64

+ func (m *WriteRequest) GetTruncate() *Action_Truncate

+ func (m *WriteRequest) GetType() Action_Type

+ func (m *WriteRequest) Marshal() (data []byte, err error)

+ func (m *WriteRequest) MarshalTo(data []byte) (n int, err error)

+ func (m *WriteRequest) Reset()

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

+ func (m *WriteRequest) Unmarshal(data []byte) error

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

+ func (this *WriteRequest) GoString() string

+ func (this *WriteRequest) String() string

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

+ type WriteResponse struct

+ Okay *bool

+ Position *uint64

+ Proposal *uint64

+ XXX_unrecognized []byte

+ func NewPopulatedWriteResponse(r randyLog, easy bool) *WriteResponse

+ func (*WriteResponse) ProtoMessage()

+ func (m *WriteResponse) GetOkay() bool

+ func (m *WriteResponse) GetPosition() uint64

+ func (m *WriteResponse) GetProposal() uint64

+ func (m *WriteResponse) Marshal() (data []byte, err error)

+ func (m *WriteResponse) MarshalTo(data []byte) (n int, err error)

+ func (m *WriteResponse) Reset()

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

+ func (m *WriteResponse) Unmarshal(data []byte) error

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

+ func (this *WriteResponse) GoString() string

+ func (this *WriteResponse) String() string

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

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