mesosproto

package

Go to main page

Versions in this module

v0

v0.0.2

Sep 30, 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

+ Request *Call_Request

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

+ func (m *Call) GetRequest() *Call_Request

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

+ Requests []*Request

+ XXX_unrecognized []byte

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

+ func (*Call_Request) ProtoMessage()

+ func (m *Call_Request) GetRequests() []*Request

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

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

+ func (m *Call_Request) Reset()

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

+ const Call_REQUEST

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

v0.0.1

Sep 15, 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_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 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 Event_Type_name = map[int32]string

+ var Event_Type_value = map[string]int32

+ var FrameworkInfo_Capability_Type_name = map[int32]string

+ var FrameworkInfo_Capability_Type_value = map[string]int32

+ var Metadata_Status_name = map[int32]string

+ var Metadata_Status_value = map[string]int32

+ var Offer_Operation_Type_name = map[int32]string

+ var Offer_Operation_Type_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) (int, 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) (int, 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) (int, 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) (int, 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) (int, 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) (int, 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) (int, 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) (int, 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) (int, 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) (int, 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) (int, 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 []byte

+ Mechanism *string

+ XXX_unrecognized []byte

+ func (*AuthenticationStartMessage) ProtoMessage()

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

+ 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

+ Accept *Call_Accept

+ Acknowledge *Call_Acknowledge

+ Decline *Call_Decline

+ FrameworkId *FrameworkID

+ Kill *Call_Kill

+ Message *Call_Message

+ Reconcile *Call_Reconcile

+ Shutdown *Call_Shutdown

+ Subscribe *Call_Subscribe

+ Type *Call_Type

+ XXX_unrecognized []byte

+ func (*Call) ProtoMessage()

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

+ func (m *Call) GetAcknowledge() *Call_Acknowledge

+ func (m *Call) GetDecline() *Call_Decline

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

+ func (m *Call) GetKill() *Call_Kill

+ func (m *Call) GetMessage() *Call_Message

+ func (m *Call) GetReconcile() *Call_Reconcile

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

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

+ func (m *Call) GetType() Call_Type

+ func (m *Call) Reset()

+ func (m *Call) String() string

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

+ SlaveId *SlaveID

+ TaskId *TaskID

+ XXX_unrecognized []byte

+ func (*Call_Kill) ProtoMessage()

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

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

+ func (m *Call_Kill) Reset()

+ func (m *Call_Kill) 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

+ Tasks []*Call_Reconcile_Task

+ XXX_unrecognized []byte

+ func (*Call_Reconcile) ProtoMessage()

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

+ func (m *Call_Reconcile) Reset()

+ func (m *Call_Reconcile) String() string

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

+ const Call_ACCEPT

+ const Call_ACKNOWLEDGE

+ const Call_DECLINE

+ const Call_KILL

+ const Call_MESSAGE

+ const Call_RECONCILE

+ const Call_REVIVE

+ const Call_SHUTDOWN

+ const Call_SUBSCRIBE

+ const Call_TEARDOWN

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

+ func (x Call_Type) Enum() *Call_Type

+ func (x Call_Type) String() string

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

+ Cache *bool

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

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

+ ForcePullImage *bool

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

+ func (m *ContainerInfo_DockerInfo) GetImage() string

+ func (m *ContainerInfo_DockerInfo) GetNetwork() ContainerInfo_DockerInfo_Network

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

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

+ func (m *ContainerInfo_DockerInfo) GetPrivileged() bool

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

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

+ func (m *ContainerInfo_DockerInfo) Reset()

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

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

+ func (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) (int, error)

+ func (m *ContainerInfo_DockerInfo_PortMapping) Reset()

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

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

+ func (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) (int, 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) (int, 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 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 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) (int, 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) (int, 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) (int, 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

+ Rescind *Event_Rescind

+ Subscribed *Event_Subscribed

+ 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) GetRescind() *Event_Rescind

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

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

+ const Event_ERROR

+ const Event_FAILURE

+ const Event_MESSAGE

+ const Event_OFFERS

+ const Event_RESCIND

+ const Event_SUBSCRIBED

+ 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

+ XXX_unrecognized []byte

+ func (*Event_Update) ProtoMessage()

+ func (m *Event_Update) GetStatus() *TaskStatus

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

+ Discovery *DiscoveryInfo

+ 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) GetDiscovery() *DiscoveryInfo

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

+ Capabilities []*FrameworkInfo_Capability

+ 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) GetCapabilities() []*FrameworkInfo_Capability

+ func (m *FrameworkInfo) GetCheckpoint() bool

+ func (m *FrameworkInfo) GetFailoverTimeout() float64

+ func (m *FrameworkInfo) GetHostname() string

+ func (m *FrameworkInfo) GetId() *FrameworkID

+ func (m *FrameworkInfo) GetName() string

+ func (m *FrameworkInfo) GetPrincipal() string

+ func (m *FrameworkInfo) GetRole() string

+ func (m *FrameworkInfo) GetUser() string

+ func (m *FrameworkInfo) GetWebuiUrl() string

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

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

+ func (m *FrameworkInfo) Reset()

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

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

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

+ func (this *FrameworkInfo) GoString() string

+ func (this *FrameworkInfo) String() string

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

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

+ Version *string

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

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

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

+ func (m *MasterInfo) Reset()

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

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

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

+ func (this *MasterInfo) GoString() string

+ func (this *MasterInfo) String() string

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

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

+ CheckpointedResources []*Resource

+ Slave *SlaveInfo

+ Version *string

+ XXX_unrecognized []byte

+ func (*RegisterSlaveMessage) ProtoMessage()

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

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

+ CheckpointedResources []*Resource

+ CompletedFrameworks []*Archive_Framework

+ ExecutorInfos []*ExecutorInfo

+ Slave *SlaveInfo

+ Tasks []*Task

+ Version *string

+ XXX_unrecognized []byte

+ func (*ReregisterSlaveMessage) ProtoMessage()

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

+ func (m *ReregisterSlaveMessage) GetCompletedFrameworks() []*Archive_Framework

+ func (m *ReregisterSlaveMessage) GetExecutorInfos() []*ExecutorInfo

+ func (m *ReregisterSlaveMessage) GetSlave() *SlaveInfo

+ 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

+ Disk *Resource_DiskInfo

+ Name *string

+ Ranges *Value_Ranges

+ Reservation *Resource_ReservationInfo

+ Revocable *Resource_RevocableInfo

+ 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) GetDisk() *Resource_DiskInfo

+ func (m *Resource) GetName() string

+ func (m *Resource) GetRanges() *Value_Ranges

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

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

+ func (m *Resource) GetRole() string

+ func (m *Resource) GetScalar() *Value_Scalar

+ func (m *Resource) GetSet() *Value_Set

+ func (m *Resource) GetType() Value_Type

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

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

+ func (m *Resource) Reset()

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

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

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

+ DiskLimitBytes *uint64

+ DiskUsedBytes *uint64

+ MemAnonBytes *uint64

+ MemCacheBytes *uint64

+ MemCriticalPressureCounter *uint64

+ MemFileBytes *uint64

+ MemLimitBytes *uint64

+ MemLowPressureCounter *uint64

+ MemMappedFileBytes *uint64

+ MemMediumPressureCounter *uint64

+ MemRssBytes *uint64

+ MemSoftLimitBytes *uint64

+ MemSwapBytes *uint64

+ MemTotalBytes *uint64

+ MemTotalMemswBytes *uint64

+ NetRxBytes *uint64

+ NetRxDropped *uint64

+ NetRxErrors *uint64

+ NetRxPackets *uint64

+ NetTcpActiveConnections *float64

+ NetTcpRttMicrosecsP50 *float64

+ NetTcpRttMicrosecsP90 *float64

+ NetTcpRttMicrosecsP95 *float64

+ NetTcpRttMicrosecsP99 *float64

+ NetTcpTimeWaitConnections *float64

+ NetTrafficControlStatistics []*TrafficControlStatistics

+ NetTxBytes *uint64

+ NetTxDropped *uint64

+ NetTxErrors *uint64

+ NetTxPackets *uint64

+ Perf *PerfStatistics

+ Processes *uint32

+ Threads *uint32

+ Timestamp *float64

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

+ func (m *ResourceStatistics) GetDiskUsedBytes() uint64

+ func (m *ResourceStatistics) GetMemAnonBytes() uint64

+ func (m *ResourceStatistics) GetMemCacheBytes() uint64

+ func (m *ResourceStatistics) GetMemCriticalPressureCounter() uint64

+ func (m *ResourceStatistics) GetMemFileBytes() uint64

+ func (m *ResourceStatistics) GetMemLimitBytes() uint64

+ func (m *ResourceStatistics) GetMemLowPressureCounter() uint64

+ func (m *ResourceStatistics) GetMemMappedFileBytes() uint64

+ func (m *ResourceStatistics) GetMemMediumPressureCounter() uint64

+ func (m *ResourceStatistics) GetMemRssBytes() uint64

+ func (m *ResourceStatistics) GetMemSoftLimitBytes() uint64

+ func (m *ResourceStatistics) GetMemSwapBytes() uint64

+ func (m *ResourceStatistics) GetMemTotalBytes() uint64

+ func (m *ResourceStatistics) GetMemTotalMemswBytes() uint64

+ func (m *ResourceStatistics) GetNetRxBytes() uint64

+ func (m *ResourceStatistics) GetNetRxDropped() uint64

+ func (m *ResourceStatistics) GetNetRxErrors() uint64

+ func (m *ResourceStatistics) GetNetRxPackets() uint64

+ func (m *ResourceStatistics) GetNetTcpActiveConnections() float64

+ func (m *ResourceStatistics) GetNetTcpRttMicrosecsP50() float64

+ func (m *ResourceStatistics) GetNetTcpRttMicrosecsP90() float64

+ func (m *ResourceStatistics) GetNetTcpRttMicrosecsP95() float64

+ func (m *ResourceStatistics) GetNetTcpRttMicrosecsP99() float64

+ func (m *ResourceStatistics) GetNetTcpTimeWaitConnections() float64

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

+ func (m *ResourceStatistics) GetNetTxBytes() uint64

+ func (m *ResourceStatistics) GetNetTxDropped() uint64

+ func (m *ResourceStatistics) GetNetTxErrors() uint64

+ func (m *ResourceStatistics) GetNetTxPackets() uint64

+ func (m *ResourceStatistics) GetPerf() *PerfStatistics

+ func (m *ResourceStatistics) GetProcesses() uint32

+ func (m *ResourceStatistics) GetThreads() uint32

+ func (m *ResourceStatistics) GetTimestamp() float64

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

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

+ func (m *ResourceStatistics) Reset()

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

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

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

+ Executors []*ResourceUsage_Executor

+ XXX_unrecognized []byte

+ func NewPopulatedResourceUsage(r randyMesos, easy bool) *ResourceUsage

+ func (*ResourceUsage) ProtoMessage()

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

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

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

+ func (m *ResourceUsage) Reset()

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

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

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

+ func (this *ResourceUsage) GoString() string

+ func (this *ResourceUsage) String() string

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

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

+ ExecutorId *ExecutorID

+ FrameworkId *FrameworkID

+ XXX_unrecognized []byte

+ func (*ShutdownExecutorMessage) ProtoMessage()

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

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

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

+ Connection *MasterSlaveConnection

+ SlaveId *SlaveID

+ XXX_unrecognized []byte

+ func (*SlaveRegisteredMessage) ProtoMessage()

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

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

+ func (m *SlaveRegisteredMessage) Reset()

+ func (m *SlaveRegisteredMessage) String() string

+ type SlaveReregisteredMessage struct

+ Connection *MasterSlaveConnection

+ Reconciliations []*ReconcileTasksMessage

+ SlaveId *SlaveID

+ XXX_unrecognized []byte

+ func (*SlaveReregisteredMessage) ProtoMessage()

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

+ 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

+ Discovery *DiscoveryInfo

+ ExecutorId *ExecutorID

+ FrameworkId *FrameworkID

+ Labels *Labels

+ 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) GetDiscovery() *DiscoveryInfo

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

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

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

+ func (m *Task) GetName() string

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

+ func (m *Task) 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) (int, 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

+ Discovery *DiscoveryInfo

+ Executor *ExecutorInfo

+ HealthCheck *HealthCheck

+ Labels *Labels

+ 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) GetDiscovery() *DiscoveryInfo

+ func (m *TaskInfo) GetExecutor() *ExecutorInfo

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

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

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

+ Uuid []byte

+ 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) GetUuid() []byte

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

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

+ func (m *TaskStatus) Reset()

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

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

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

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

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

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