scheduler

package

Go to main page

Versions in this module

v0

v0.0.11

May 15, 2020

Changes in this version

type Call

+ UpdateFramework *Call_UpdateFramework

+ func (m *Call) GetUpdateFramework() *Call_UpdateFramework

type Call_AcknowledgeOperationStatus

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

type Call_ReconcileOperations

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

type Call_ReconcileOperations_Operation

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

type Call_Revive

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

type Call_Suppress

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

type Call_Type

+ const Call_UPDATE_FRAMEWORK

+ type Call_UpdateFramework struct

+ FrameworkInfo mesos.FrameworkInfo

+ SuppressedRoles []string

+ func NewPopulatedCall_UpdateFramework(r randyScheduler, easy bool) *Call_UpdateFramework

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

+ func (*Call_UpdateFramework) ProtoMessage()

+ func (m *Call_UpdateFramework) GetFrameworkInfo() mesos.FrameworkInfo

+ func (m *Call_UpdateFramework) GetSuppressedRoles() []string

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

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

+ func (m *Call_UpdateFramework) Reset()

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

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

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

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

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

+ func (this *Call_UpdateFramework) GoString() string

+ func (this *Call_UpdateFramework) String() string

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

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

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

type Event_UpdateOperationStatus

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

type Response

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

type Response_ReconcileOperations

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

v0.0.10

Jul 3, 2019

v0.0.9

Mar 15, 2019

v0.0.8

Jul 26, 2018

Changes in this version

type Response

+ Type Response_Type

+ func (m *Response) GetType() Response_Type

v0.0.7

Jul 24, 2018

Changes in this version

+ var Response_Type_name = map[int32]string

+ var Response_Type_value = map[string]int32

type Call

+ AcknowledgeOperationStatus *Call_AcknowledgeOperationStatus

+ ReconcileOperations *Call_ReconcileOperations

+ func (m *Call) GetAcknowledgeOperationStatus() *Call_AcknowledgeOperationStatus

+ func (m *Call) GetReconcileOperations() *Call_ReconcileOperations

+ type Call_AcknowledgeOperationStatus struct

+ AgentID *mesos.AgentID

+ OperationID mesos.OperationID

+ ResourceProviderID *mesos.ResourceProviderID

+ UUID []byte

+ func NewPopulatedCall_AcknowledgeOperationStatus(r randyScheduler, easy bool) *Call_AcknowledgeOperationStatus

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

+ func (*Call_AcknowledgeOperationStatus) ProtoMessage()

+ func (m *Call_AcknowledgeOperationStatus) GetAgentID() *mesos.AgentID

+ func (m *Call_AcknowledgeOperationStatus) GetOperationID() mesos.OperationID

+ func (m *Call_AcknowledgeOperationStatus) GetResourceProviderID() *mesos.ResourceProviderID

+ func (m *Call_AcknowledgeOperationStatus) GetUUID() []byte

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

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

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

+ func (m *Call_AcknowledgeOperationStatus) Reset()

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

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

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

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

+ func (this *Call_AcknowledgeOperationStatus) GoString() string

+ func (this *Call_AcknowledgeOperationStatus) String() string

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

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

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

+ type Call_ReconcileOperations struct

+ Operations []Call_ReconcileOperations_Operation

+ func NewPopulatedCall_ReconcileOperations(r randyScheduler, easy bool) *Call_ReconcileOperations

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

+ func (*Call_ReconcileOperations) ProtoMessage()

+ func (m *Call_ReconcileOperations) GetOperations() []Call_ReconcileOperations_Operation

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

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

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

+ func (m *Call_ReconcileOperations) Reset()

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

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

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

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

+ func (this *Call_ReconcileOperations) GoString() string

+ func (this *Call_ReconcileOperations) String() string

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

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

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

+ type Call_ReconcileOperations_Operation struct

+ AgentID *mesos.AgentID

+ OperationID mesos.OperationID

+ ResourceProviderID *mesos.ResourceProviderID

+ func NewPopulatedCall_ReconcileOperations_Operation(r randyScheduler, easy bool) *Call_ReconcileOperations_Operation

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

+ func (*Call_ReconcileOperations_Operation) ProtoMessage()

+ func (m *Call_ReconcileOperations_Operation) GetAgentID() *mesos.AgentID

+ func (m *Call_ReconcileOperations_Operation) GetOperationID() mesos.OperationID

+ func (m *Call_ReconcileOperations_Operation) GetResourceProviderID() *mesos.ResourceProviderID

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

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

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

+ func (m *Call_ReconcileOperations_Operation) Reset()

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

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

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

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

+ func (this *Call_ReconcileOperations_Operation) GoString() string

+ func (this *Call_ReconcileOperations_Operation) String() string

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

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

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

type Call_Type

+ const Call_ACKNOWLEDGE_OPERATION_STATUS

+ const Call_RECONCILE_OPERATIONS

type Event

+ UpdateOperationStatus *Event_UpdateOperationStatus

+ func (m *Event) GetUpdateOperationStatus() *Event_UpdateOperationStatus

type Event_Type

+ const Event_UPDATE_OPERATION_STATUS

+ type Event_UpdateOperationStatus struct

+ Status mesos.OperationStatus

+ func NewPopulatedEvent_UpdateOperationStatus(r randyScheduler, easy bool) *Event_UpdateOperationStatus

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

+ func (*Event_UpdateOperationStatus) ProtoMessage()

+ func (m *Event_UpdateOperationStatus) GetStatus() mesos.OperationStatus

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

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

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

+ func (m *Event_UpdateOperationStatus) Reset()

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

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

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

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

+ func (this *Event_UpdateOperationStatus) GoString() string

+ func (this *Event_UpdateOperationStatus) String() string

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

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

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

+ type Response struct

+ ReconcileOperations *Response_ReconcileOperations

+ func NewPopulatedResponse(r randyScheduler, easy bool) *Response

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

+ func (*Response) ProtoMessage()

+ func (m *Response) GetReconcileOperations() *Response_ReconcileOperations

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

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

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

+ func (m *Response) Reset()

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

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

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

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

+ func (this *Response) GoString() string

+ func (this *Response) String() string

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

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

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

+ type Response_ReconcileOperations struct

+ OperationStatuses []mesos.OperationStatus

+ func NewPopulatedResponse_ReconcileOperations(r randyScheduler, easy bool) *Response_ReconcileOperations

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

+ func (*Response_ReconcileOperations) ProtoMessage()

+ func (m *Response_ReconcileOperations) GetOperationStatuses() []mesos.OperationStatus

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

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

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

+ func (m *Response_ReconcileOperations) Reset()

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

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

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

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

+ func (this *Response_ReconcileOperations) GoString() string

+ func (this *Response_ReconcileOperations) String() string

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

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

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

+ type Response_Type int32

+ const Response_RECONCILE_OPERATIONS

+ const Response_UNKNOWN

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

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

+ func (x Response_Type) Enum() *Response_Type

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

+ func (x Response_Type) String() string

v0.0.6

Mar 12, 2018

Changes in this version

type Call_Subscribe

+ SuppressedRoles []string

+ func (m *Call_Subscribe) GetSuppressedRoles() []string

v0.0.5

Sep 19, 2017

Changes in this version

type Call_Revive

+ Roles []string

+ func (m *Call_Revive) GetRoles() []string

type Call_Suppress

+ Roles []string

+ func (m *Call_Suppress) GetRoles() []string

v0.0.4

Sep 13, 2017

Changes in this version

type Call

+ Revive *Call_Revive

+ Suppress *Call_Suppress

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

+ func (m *Call) GetRevive() *Call_Revive

+ func (m *Call) GetSuppress() *Call_Suppress

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

type Call_Accept

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

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

type Call_AcceptInverseOffers

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

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

type Call_Acknowledge

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

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

type Call_Decline

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

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

type Call_DeclineInverseOffers

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

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

type Call_Kill

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

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

type Call_Message

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

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

type Call_Reconcile

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

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

type Call_Reconcile_Task

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

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

type Call_Request

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

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

+ type Call_Revive struct

+ Role *string

+ func NewPopulatedCall_Revive(r randyScheduler, easy bool) *Call_Revive

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

+ func (*Call_Revive) ProtoMessage()

+ func (m *Call_Revive) GetRole() string

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

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

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

+ func (m *Call_Revive) Reset()

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

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

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

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

+ func (this *Call_Revive) GoString() string

+ func (this *Call_Revive) String() string

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

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

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

type Call_Shutdown

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

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

type Call_Subscribe

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

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

+ type Call_Suppress struct

+ Role *string

+ func NewPopulatedCall_Suppress(r randyScheduler, easy bool) *Call_Suppress

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

+ func (*Call_Suppress) ProtoMessage()

+ func (m *Call_Suppress) GetRole() string

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

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

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

+ func (m *Call_Suppress) Reset()

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

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

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

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

+ func (this *Call_Suppress) GoString() string

+ func (this *Call_Suppress) String() string

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

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

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

type Call_Type

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

type Event

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

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

type Event_Error

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

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

type Event_Failure

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

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

type Event_InverseOffers

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

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

type Event_Message

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

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

type Event_Offers

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

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

type Event_Rescind

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

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

type Event_RescindInverseOffer

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

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

type Event_Subscribed

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

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

type Event_Type

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

type Event_Update

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

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

v0.0.3

Jun 19, 2017

Changes in this version

+ var Call_Type_name = map[int32]string

+ var Call_Type_value = map[string]int32

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

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

+ var Event_Type_name = map[int32]string

+ var Event_Type_value = map[string]int32

+ type Call struct

+ Accept *Call_Accept

+ AcceptInverseOffers *Call_AcceptInverseOffers

+ Acknowledge *Call_Acknowledge

+ Decline *Call_Decline

+ DeclineInverseOffers *Call_DeclineInverseOffers

+ FrameworkID *mesos.FrameworkID

+ Kill *Call_Kill

+ Message *Call_Message

+ Reconcile *Call_Reconcile

+ Request *Call_Request

+ Shutdown *Call_Shutdown

+ Subscribe *Call_Subscribe

+ Type *Call_Type

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

+ func (*Call) ProtoMessage()

+ func (c *Call) With(opts ...CallOpt) *Call

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

+ func (m *Call) GetAcceptInverseOffers() *Call_AcceptInverseOffers

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

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

+ func (m *Call) GetDeclineInverseOffers() *Call_DeclineInverseOffers

+ func (m *Call) GetFrameworkID() *mesos.FrameworkID

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

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

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

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

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

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

+ func (m *Call) GetType() Call_Type

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

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

+ func (m *Call) Reset()

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

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

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

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

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

+ func (this *Call) GoString() string

+ func (this *Call) String() string

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

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

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

+ type CallOpt func(*Call)

+ type CallOptions []CallOpt

+ func (co CallOptions) Copy() CallOptions

+ type Call_Accept struct

+ Filters *mesos.Filters

+ OfferIDs []mesos.OfferID

+ Operations []mesos.Offer_Operation

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

+ func (*Call_Accept) ProtoMessage()

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

+ func (m *Call_Accept) GetOfferIDs() []mesos.OfferID

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

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

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

+ func (m *Call_Accept) Reset()

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

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

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

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

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

+ func (this *Call_Accept) GoString() string

+ func (this *Call_Accept) String() string

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

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

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

+ type Call_AcceptInverseOffers struct

+ Filters *mesos.Filters

+ InverseOfferIDs []mesos.OfferID

+ func NewPopulatedCall_AcceptInverseOffers(r randyScheduler, easy bool) *Call_AcceptInverseOffers

+ func (*Call_AcceptInverseOffers) ProtoMessage()

+ func (m *Call_AcceptInverseOffers) GetFilters() *mesos.Filters

+ func (m *Call_AcceptInverseOffers) GetInverseOfferIDs() []mesos.OfferID

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

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

+ func (m *Call_AcceptInverseOffers) Reset()

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

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

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

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

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

+ func (this *Call_AcceptInverseOffers) GoString() string

+ func (this *Call_AcceptInverseOffers) String() string

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

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

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

+ type Call_Acknowledge struct

+ AgentID mesos.AgentID

+ TaskID mesos.TaskID

+ UUID []byte

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

+ func (*Call_Acknowledge) ProtoMessage()

+ func (m *Call_Acknowledge) GetAgentID() mesos.AgentID

+ func (m *Call_Acknowledge) GetTaskID() mesos.TaskID

+ func (m *Call_Acknowledge) GetUUID() []byte

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

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

+ func (m *Call_Acknowledge) Reset()

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

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

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

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

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

+ func (this *Call_Acknowledge) GoString() string

+ func (this *Call_Acknowledge) String() string

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

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

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

+ type Call_Decline struct

+ Filters *mesos.Filters

+ OfferIDs []mesos.OfferID

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

+ func (*Call_Decline) ProtoMessage()

+ func (m *Call_Decline) GetFilters() *mesos.Filters

+ func (m *Call_Decline) GetOfferIDs() []mesos.OfferID

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

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

+ func (m *Call_Decline) Reset()

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

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

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

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

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

+ func (this *Call_Decline) GoString() string

+ func (this *Call_Decline) String() string

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

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

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

+ type Call_DeclineInverseOffers struct

+ Filters *mesos.Filters

+ InverseOfferIDs []mesos.OfferID

+ func NewPopulatedCall_DeclineInverseOffers(r randyScheduler, easy bool) *Call_DeclineInverseOffers

+ func (*Call_DeclineInverseOffers) ProtoMessage()

+ func (m *Call_DeclineInverseOffers) GetFilters() *mesos.Filters

+ func (m *Call_DeclineInverseOffers) GetInverseOfferIDs() []mesos.OfferID

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

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

+ func (m *Call_DeclineInverseOffers) Reset()

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

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

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

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

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

+ func (this *Call_DeclineInverseOffers) GoString() string

+ func (this *Call_DeclineInverseOffers) String() string

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

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

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

+ type Call_Kill struct

+ AgentID *mesos.AgentID

+ KillPolicy *mesos.KillPolicy

+ TaskID mesos.TaskID

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

+ func (*Call_Kill) ProtoMessage()

+ func (m *Call_Kill) GetAgentID() *mesos.AgentID

+ func (m *Call_Kill) GetKillPolicy() *mesos.KillPolicy

+ func (m *Call_Kill) GetTaskID() mesos.TaskID

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

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

+ func (m *Call_Kill) Reset()

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

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

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

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

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

+ func (this *Call_Kill) GoString() string

+ func (this *Call_Kill) String() string

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

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

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

+ type Call_Message struct

+ AgentID mesos.AgentID

+ Data []byte

+ ExecutorID mesos.ExecutorID

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

+ func (*Call_Message) ProtoMessage()

+ func (m *Call_Message) GetAgentID() mesos.AgentID

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

+ func (m *Call_Message) GetExecutorID() mesos.ExecutorID

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

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

+ func (m *Call_Message) Reset()

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

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

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

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

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

+ func (this *Call_Message) GoString() string

+ func (this *Call_Message) String() string

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

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

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

+ type Call_Reconcile struct

+ Tasks []Call_Reconcile_Task

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

+ func (*Call_Reconcile) ProtoMessage()

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

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

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

+ func (m *Call_Reconcile) Reset()

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

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

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

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

+ func (r *Call_Reconcile) With(opts ...ReconcileOpt) *Call_Reconcile

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

+ func (this *Call_Reconcile) GoString() string

+ func (this *Call_Reconcile) String() string

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

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

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

+ type Call_Reconcile_Task struct

+ AgentID *mesos.AgentID

+ TaskID mesos.TaskID

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

+ func (*Call_Reconcile_Task) ProtoMessage()

+ func (m *Call_Reconcile_Task) GetAgentID() *mesos.AgentID

+ func (m *Call_Reconcile_Task) GetTaskID() mesos.TaskID

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

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

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

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

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

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

+ func (this *Call_Reconcile_Task) GoString() string

+ func (this *Call_Reconcile_Task) String() string

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

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

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

+ type Call_Request struct

+ Requests []mesos.Request

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

+ func (*Call_Request) ProtoMessage()

+ func (m *Call_Request) GetRequests() []mesos.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 (mj *Call_Request) MarshalJSON() ([]byte, error)

+ func (mj *Call_Request) MarshalJSONBuf(buf fflib.EncodingBuffer) 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

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

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

+ type Call_Shutdown struct

+ AgentID mesos.AgentID

+ ExecutorID mesos.ExecutorID

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

+ func (*Call_Shutdown) ProtoMessage()

+ func (m *Call_Shutdown) GetAgentID() mesos.AgentID

+ func (m *Call_Shutdown) GetExecutorID() mesos.ExecutorID

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

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

+ func (m *Call_Shutdown) Reset()

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

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

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

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

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

+ func (this *Call_Shutdown) GoString() string

+ func (this *Call_Shutdown) String() string

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

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

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

+ type Call_Subscribe struct

+ FrameworkInfo *mesos.FrameworkInfo

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

+ func (*Call_Subscribe) ProtoMessage()

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

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

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

+ func (m *Call_Subscribe) Reset()

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

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

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

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

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

+ func (this *Call_Subscribe) GoString() string

+ func (this *Call_Subscribe) String() string

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

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

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

+ type Call_Type int32

+ const Call_ACCEPT

+ const Call_ACCEPT_INVERSE_OFFERS

+ const Call_ACKNOWLEDGE

+ const Call_DECLINE

+ const Call_DECLINE_INVERSE_OFFERS

+ const Call_KILL

+ const Call_MESSAGE

+ const Call_RECONCILE

+ const Call_REQUEST

+ const Call_REVIVE

+ const Call_SHUTDOWN

+ const Call_SUBSCRIBE

+ const Call_SUPPRESS

+ const Call_TEARDOWN

+ const Call_UNKNOWN

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

+ func (x Call_Type) Enum() *Call_Type

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

+ func (x Call_Type) String() string

+ type Event struct

+ Error *Event_Error

+ Failure *Event_Failure

+ InverseOffers *Event_InverseOffers

+ Message *Event_Message

+ Offers *Event_Offers

+ Rescind *Event_Rescind

+ RescindInverseOffer *Event_RescindInverseOffer

+ Subscribed *Event_Subscribed

+ Type *Event_Type

+ Update *Event_Update

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

+ func (*Event) ProtoMessage()

+ func (m *Event) GetError() *Event_Error

+ func (m *Event) GetFailure() *Event_Failure

+ func (m *Event) GetInverseOffers() *Event_InverseOffers

+ func (m *Event) GetMessage() *Event_Message

+ func (m *Event) GetOffers() *Event_Offers

+ func (m *Event) GetRescind() *Event_Rescind

+ func (m *Event) GetRescindInverseOffer() *Event_RescindInverseOffer

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

+ func (m *Event) GetType() Event_Type

+ func (m *Event) GetUpdate() *Event_Update

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

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

+ func (m *Event) Reset()

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

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

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

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

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

+ func (this *Event) GoString() string

+ func (this *Event) String() string

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

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

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

+ type EventPredicate func(*Event) bool

+ func (ep EventPredicate) Apply(e *Event) (result bool)

+ type Event_Error struct

+ Message string

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

+ func (*Event_Error) ProtoMessage()

+ func (m *Event_Error) GetMessage() string

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

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

+ func (m *Event_Error) Reset()

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

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

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

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

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

+ func (this *Event_Error) GoString() string

+ func (this *Event_Error) String() string

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

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

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

+ type Event_Failure struct

+ AgentID *mesos.AgentID

+ ExecutorID *mesos.ExecutorID

+ Status *int32

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

+ func (*Event_Failure) ProtoMessage()

+ func (m *Event_Failure) GetAgentID() *mesos.AgentID

+ func (m *Event_Failure) GetExecutorID() *mesos.ExecutorID

+ func (m *Event_Failure) GetStatus() int32

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

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

+ func (m *Event_Failure) Reset()

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

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

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

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

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

+ func (this *Event_Failure) GoString() string

+ func (this *Event_Failure) String() string

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

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

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

+ type Event_InverseOffers struct

+ InverseOffers []mesos.InverseOffer

+ func NewPopulatedEvent_InverseOffers(r randyScheduler, easy bool) *Event_InverseOffers

+ func (*Event_InverseOffers) ProtoMessage()

+ func (m *Event_InverseOffers) GetInverseOffers() []mesos.InverseOffer

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

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

+ func (m *Event_InverseOffers) Reset()

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

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

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

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

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

+ func (this *Event_InverseOffers) GoString() string

+ func (this *Event_InverseOffers) String() string

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

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

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

+ type Event_Message struct

+ AgentID mesos.AgentID

+ Data []byte

+ ExecutorID mesos.ExecutorID

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

+ func (*Event_Message) ProtoMessage()

+ func (m *Event_Message) GetAgentID() mesos.AgentID

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

+ func (m *Event_Message) GetExecutorID() mesos.ExecutorID

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

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

+ func (m *Event_Message) Reset()

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

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

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

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

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

+ func (this *Event_Message) GoString() string

+ func (this *Event_Message) String() string

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

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

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

+ type Event_Offers struct

+ Offers []mesos.Offer

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

+ func (*Event_Offers) ProtoMessage()

+ func (m *Event_Offers) GetOffers() []mesos.Offer

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

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

+ func (m *Event_Offers) Reset()

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

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

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

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

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

+ func (this *Event_Offers) GoString() string

+ func (this *Event_Offers) String() string

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

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

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

+ type Event_Rescind struct

+ OfferID mesos.OfferID

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

+ func (*Event_Rescind) ProtoMessage()

+ func (m *Event_Rescind) GetOfferID() mesos.OfferID

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

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

+ func (m *Event_Rescind) Reset()

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

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

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

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

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

+ func (this *Event_Rescind) GoString() string

+ func (this *Event_Rescind) String() string

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

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

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

+ type Event_RescindInverseOffer struct

+ InverseOfferID mesos.OfferID

+ func NewPopulatedEvent_RescindInverseOffer(r randyScheduler, easy bool) *Event_RescindInverseOffer

+ func (*Event_RescindInverseOffer) ProtoMessage()

+ func (m *Event_RescindInverseOffer) GetInverseOfferID() mesos.OfferID

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

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

+ func (m *Event_RescindInverseOffer) Reset()

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

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

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

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

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

+ func (this *Event_RescindInverseOffer) GoString() string

+ func (this *Event_RescindInverseOffer) String() string

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

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

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

+ type Event_Subscribed struct

+ FrameworkID *mesos.FrameworkID

+ HeartbeatIntervalSeconds *float64

+ MasterInfo *mesos.MasterInfo

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

+ func (*Event_Subscribed) ProtoMessage()

+ func (m *Event_Subscribed) GetFrameworkID() *mesos.FrameworkID

+ func (m *Event_Subscribed) GetHeartbeatIntervalSeconds() float64

+ func (m *Event_Subscribed) GetMasterInfo() *mesos.MasterInfo

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

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

+ func (m *Event_Subscribed) Reset()

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

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

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

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

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

+ func (this *Event_Subscribed) GoString() string

+ func (this *Event_Subscribed) String() string

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

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

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

+ type Event_Type int32

+ const Event_ERROR

+ const Event_FAILURE

+ const Event_HEARTBEAT

+ const Event_INVERSE_OFFERS

+ const Event_MESSAGE

+ const Event_OFFERS

+ const Event_RESCIND

+ const Event_RESCIND_INVERSE_OFFER

+ const Event_SUBSCRIBED

+ const Event_UNKNOWN

+ const Event_UPDATE

+ func (t Event_Type) Happens() EventPredicate

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

+ func (x Event_Type) Enum() *Event_Type

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

+ func (x Event_Type) String() string

+ type Event_Update struct

+ Status mesos.TaskStatus

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

+ func (*Event_Update) ProtoMessage()

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

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

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

+ func (m *Event_Update) Reset()

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

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

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

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

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

+ func (this *Event_Update) GoString() string

+ func (this *Event_Update) String() string

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

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

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

+ type ReconcileOpt func(*Call_Reconcile)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL