scheduler

package
v0.0.11 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 15, 2020 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Overview

Package scheduler is a generated protocol buffer package.

It is generated from these files:

scheduler/scheduler.proto

It has these top-level messages:

Event
Response
Call

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthScheduler = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowScheduler   = fmt.Errorf("proto: integer overflow")
)
View Source
var Call_Type_name = map[int32]string{
	0:  "UNKNOWN",
	1:  "SUBSCRIBE",
	2:  "TEARDOWN",
	3:  "ACCEPT",
	4:  "DECLINE",
	13: "ACCEPT_INVERSE_OFFERS",
	14: "DECLINE_INVERSE_OFFERS",
	5:  "REVIVE",
	6:  "KILL",
	7:  "SHUTDOWN",
	8:  "ACKNOWLEDGE",
	15: "ACKNOWLEDGE_OPERATION_STATUS",
	9:  "RECONCILE",
	16: "RECONCILE_OPERATIONS",
	10: "MESSAGE",
	11: "REQUEST",
	12: "SUPPRESS",
	17: "UPDATE_FRAMEWORK",
}
View Source
var Call_Type_value = map[string]int32{
	"UNKNOWN":                      0,
	"SUBSCRIBE":                    1,
	"TEARDOWN":                     2,
	"ACCEPT":                       3,
	"DECLINE":                      4,
	"ACCEPT_INVERSE_OFFERS":        13,
	"DECLINE_INVERSE_OFFERS":       14,
	"REVIVE":                       5,
	"KILL":                         6,
	"SHUTDOWN":                     7,
	"ACKNOWLEDGE":                  8,
	"ACKNOWLEDGE_OPERATION_STATUS": 15,
	"RECONCILE":                    9,
	"RECONCILE_OPERATIONS":         16,
	"MESSAGE":                      10,
	"REQUEST":                      11,
	"SUPPRESS":                     12,
	"UPDATE_FRAMEWORK":             17,
}
View Source
var Event_Type_name = map[int32]string{
	0:  "UNKNOWN",
	1:  "SUBSCRIBED",
	2:  "OFFERS",
	9:  "INVERSE_OFFERS",
	3:  "RESCIND",
	10: "RESCIND_INVERSE_OFFER",
	4:  "UPDATE",
	11: "UPDATE_OPERATION_STATUS",
	5:  "MESSAGE",
	6:  "FAILURE",
	7:  "ERROR",
	8:  "HEARTBEAT",
}
View Source
var Event_Type_value = map[string]int32{
	"UNKNOWN":                 0,
	"SUBSCRIBED":              1,
	"OFFERS":                  2,
	"INVERSE_OFFERS":          9,
	"RESCIND":                 3,
	"RESCIND_INVERSE_OFFER":   10,
	"UPDATE":                  4,
	"UPDATE_OPERATION_STATUS": 11,
	"MESSAGE":                 5,
	"FAILURE":                 6,
	"ERROR":                   7,
	"HEARTBEAT":               8,
}
View Source
var Response_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "RECONCILE_OPERATIONS",
}
View Source
var Response_Type_value = map[string]int32{
	"UNKNOWN":              0,
	"RECONCILE_OPERATIONS": 1,
}

Functions

This section is empty.

Types

type Call

type Call struct {
	// Identifies who generated this call. Master assigns a framework id
	// when a new scheduler subscribes for the first time. Once assigned,
	// the scheduler must set the 'framework_id' here and within its
	// FrameworkInfo (in any further 'Subscribe' calls). This allows the
	// master to identify a scheduler correctly across disconnections,
	// failovers, etc.
	FrameworkID *mesos.FrameworkID `protobuf:"bytes,1,opt,name=framework_id,json=frameworkId" json:"framework_id,omitempty"`
	// Type of the call, indicates which optional field below should be
	// present if that type has a nested message definition.
	// See comments on `Event::Type` above on the reasoning behind this
	// field being optional.
	Type                       Call_Type                        `protobuf:"varint,2,opt,name=type,enum=mesos.scheduler.Call_Type" json:"type"`
	Subscribe                  *Call_Subscribe                  `protobuf:"bytes,3,opt,name=subscribe" json:"subscribe,omitempty"`
	Accept                     *Call_Accept                     `protobuf:"bytes,4,opt,name=accept" json:"accept,omitempty"`
	Decline                    *Call_Decline                    `protobuf:"bytes,5,opt,name=decline" json:"decline,omitempty"`
	AcceptInverseOffers        *Call_AcceptInverseOffers        `protobuf:"bytes,13,opt,name=accept_inverse_offers,json=acceptInverseOffers" json:"accept_inverse_offers,omitempty"`
	DeclineInverseOffers       *Call_DeclineInverseOffers       `protobuf:"bytes,14,opt,name=decline_inverse_offers,json=declineInverseOffers" json:"decline_inverse_offers,omitempty"`
	Revive                     *Call_Revive                     `protobuf:"bytes,15,opt,name=revive" json:"revive,omitempty"`
	Kill                       *Call_Kill                       `protobuf:"bytes,6,opt,name=kill" json:"kill,omitempty"`
	Shutdown                   *Call_Shutdown                   `protobuf:"bytes,7,opt,name=shutdown" json:"shutdown,omitempty"`
	Acknowledge                *Call_Acknowledge                `protobuf:"bytes,8,opt,name=acknowledge" json:"acknowledge,omitempty"`
	AcknowledgeOperationStatus *Call_AcknowledgeOperationStatus `` /* 135-byte string literal not displayed */
	Reconcile                  *Call_Reconcile                  `protobuf:"bytes,9,opt,name=reconcile" json:"reconcile,omitempty"`
	ReconcileOperations        *Call_ReconcileOperations        `protobuf:"bytes,18,opt,name=reconcile_operations,json=reconcileOperations" json:"reconcile_operations,omitempty"`
	Message                    *Call_Message                    `protobuf:"bytes,10,opt,name=message" json:"message,omitempty"`
	Request                    *Call_Request                    `protobuf:"bytes,11,opt,name=request" json:"request,omitempty"`
	Suppress                   *Call_Suppress                   `protobuf:"bytes,16,opt,name=suppress" json:"suppress,omitempty"`
	UpdateFramework            *Call_UpdateFramework            `protobuf:"bytes,19,opt,name=update_framework,json=updateFramework" json:"update_framework,omitempty"`
}

* Scheduler call API.

Like Event, a Call is described using the standard protocol buffer "union" trick (see above).

func NewPopulatedCall

func NewPopulatedCall(r randyScheduler, easy bool) *Call

func (*Call) Descriptor

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

func (*Call) Equal

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

func (*Call) GetAccept

func (m *Call) GetAccept() *Call_Accept

func (*Call) GetAcceptInverseOffers

func (m *Call) GetAcceptInverseOffers() *Call_AcceptInverseOffers

func (*Call) GetAcknowledge

func (m *Call) GetAcknowledge() *Call_Acknowledge

func (*Call) GetAcknowledgeOperationStatus

func (m *Call) GetAcknowledgeOperationStatus() *Call_AcknowledgeOperationStatus

func (*Call) GetDecline

func (m *Call) GetDecline() *Call_Decline

func (*Call) GetDeclineInverseOffers

func (m *Call) GetDeclineInverseOffers() *Call_DeclineInverseOffers

func (*Call) GetFrameworkID

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

func (*Call) GetKill

func (m *Call) GetKill() *Call_Kill

func (*Call) GetMessage

func (m *Call) GetMessage() *Call_Message

func (*Call) GetReconcile

func (m *Call) GetReconcile() *Call_Reconcile

func (*Call) GetReconcileOperations

func (m *Call) GetReconcileOperations() *Call_ReconcileOperations

func (*Call) GetRequest

func (m *Call) GetRequest() *Call_Request

func (*Call) GetRevive

func (m *Call) GetRevive() *Call_Revive

func (*Call) GetShutdown

func (m *Call) GetShutdown() *Call_Shutdown

func (*Call) GetSubscribe

func (m *Call) GetSubscribe() *Call_Subscribe

func (*Call) GetSuppress

func (m *Call) GetSuppress() *Call_Suppress

func (*Call) GetType

func (m *Call) GetType() Call_Type

func (*Call) GetUpdateFramework

func (m *Call) GetUpdateFramework() *Call_UpdateFramework

func (*Call) GoString

func (this *Call) GoString() string

func (*Call) Marshal

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

func (*Call) MarshalJSON

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

func (*Call) MarshalJSONBuf

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

func (*Call) MarshalTo

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

func (*Call) ProtoMessage

func (*Call) ProtoMessage()

func (*Call) Reset

func (m *Call) Reset()

func (*Call) Size

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

func (*Call) String

func (this *Call) String() string

func (*Call) Unmarshal

func (m *Call) Unmarshal(dAtA []byte) error

func (*Call) UnmarshalJSON

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

func (*Call) UnmarshalJSONFFLexer

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

func (*Call) VerboseEqual

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

func (*Call) With

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

With applies the given CallOpts to the receiving Call, returning it.

type CallOpt

type CallOpt func(*Call)

A CallOpt is a functional option type for Calls.

type CallOptions

type CallOptions []CallOpt

func (CallOptions) Copy

func (co CallOptions) Copy() CallOptions

Copy returns a cloned copy of CallOptions

type Call_Accept

type Call_Accept struct {
	OfferIDs   []mesos.OfferID         `protobuf:"bytes,1,rep,name=offer_ids,json=offerIds" json:"offer_ids"`
	Operations []mesos.Offer_Operation `protobuf:"bytes,2,rep,name=operations" json:"operations"`
	Filters    *mesos.Filters          `protobuf:"bytes,3,opt,name=filters" json:"filters,omitempty"`
}

Accepts an offer, performing the specified operations in a sequential manner.

E.g. Launch a task with a newly reserved persistent volume:

Accept {
  offer_ids: [ ... ]
  operations: [
    { type: RESERVE,
      reserve: { resources: [ disk(role):2 ] } }
    { type: CREATE,
      create: { volumes: [ disk(role):1+persistence ] } }
    { type: LAUNCH,
      launch: { task_infos ... disk(role):1;disk(role):1+persistence } }
  ]
}

Note that any of the offer's resources not used in the 'Accept' call (e.g., to launch a task) are considered unused and might be reoffered to other frameworks. In other words, the same OfferID cannot be used in more than one 'Accept' call.

func NewPopulatedCall_Accept

func NewPopulatedCall_Accept(r randyScheduler, easy bool) *Call_Accept

func (*Call_Accept) Descriptor

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

func (*Call_Accept) Equal

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

func (*Call_Accept) GetFilters

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

func (*Call_Accept) GetOfferIDs

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

func (*Call_Accept) GetOperations

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

func (*Call_Accept) GoString

func (this *Call_Accept) GoString() string

func (*Call_Accept) Marshal

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

func (*Call_Accept) MarshalJSON

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

func (*Call_Accept) MarshalJSONBuf

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

func (*Call_Accept) MarshalTo

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

func (*Call_Accept) ProtoMessage

func (*Call_Accept) ProtoMessage()

func (*Call_Accept) Reset

func (m *Call_Accept) Reset()

func (*Call_Accept) Size

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

func (*Call_Accept) String

func (this *Call_Accept) String() string

func (*Call_Accept) Unmarshal

func (m *Call_Accept) Unmarshal(dAtA []byte) error

func (*Call_Accept) UnmarshalJSON

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

func (*Call_Accept) UnmarshalJSONFFLexer

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

func (*Call_Accept) VerboseEqual

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

type Call_AcceptInverseOffers

type Call_AcceptInverseOffers struct {
	InverseOfferIDs []mesos.OfferID `protobuf:"bytes,1,rep,name=inverse_offer_ids,json=inverseOfferIds" json:"inverse_offer_ids"`
	Filters         *mesos.Filters  `protobuf:"bytes,2,opt,name=filters" json:"filters,omitempty"`
}

Accepts an inverse offer. Inverse offers should only be accepted if the resources in the offer can be safely evacuated before the provided unavailability.

func NewPopulatedCall_AcceptInverseOffers

func NewPopulatedCall_AcceptInverseOffers(r randyScheduler, easy bool) *Call_AcceptInverseOffers

func (*Call_AcceptInverseOffers) Descriptor

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

func (*Call_AcceptInverseOffers) Equal

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

func (*Call_AcceptInverseOffers) GetFilters

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

func (*Call_AcceptInverseOffers) GetInverseOfferIDs

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

func (*Call_AcceptInverseOffers) GoString

func (this *Call_AcceptInverseOffers) GoString() string

func (*Call_AcceptInverseOffers) Marshal

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

func (*Call_AcceptInverseOffers) MarshalJSON

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

func (*Call_AcceptInverseOffers) MarshalJSONBuf

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

func (*Call_AcceptInverseOffers) MarshalTo

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

func (*Call_AcceptInverseOffers) ProtoMessage

func (*Call_AcceptInverseOffers) ProtoMessage()

func (*Call_AcceptInverseOffers) Reset

func (m *Call_AcceptInverseOffers) Reset()

func (*Call_AcceptInverseOffers) Size

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

func (*Call_AcceptInverseOffers) String

func (this *Call_AcceptInverseOffers) String() string

func (*Call_AcceptInverseOffers) Unmarshal

func (m *Call_AcceptInverseOffers) Unmarshal(dAtA []byte) error

func (*Call_AcceptInverseOffers) UnmarshalJSON

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

func (*Call_AcceptInverseOffers) UnmarshalJSONFFLexer

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

func (*Call_AcceptInverseOffers) VerboseEqual

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

type Call_Acknowledge

type Call_Acknowledge struct {
	AgentID mesos.AgentID `protobuf:"bytes,1,req,name=agent_id,json=agentId" json:"agent_id"`
	TaskID  mesos.TaskID  `protobuf:"bytes,2,req,name=task_id,json=taskId" json:"task_id"`
	UUID    []byte        `protobuf:"bytes,3,req,name=uuid" json:"uuid,omitempty"`
}

Acknowledges the receipt of status update. Schedulers are responsible for explicitly acknowledging the receipt of status updates that have 'Update.status().uuid()' field set. Such status updates are retried by the agent until they are acknowledged by the scheduler.

func NewPopulatedCall_Acknowledge

func NewPopulatedCall_Acknowledge(r randyScheduler, easy bool) *Call_Acknowledge

func (*Call_Acknowledge) Descriptor

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

func (*Call_Acknowledge) Equal

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

func (*Call_Acknowledge) GetAgentID

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

func (*Call_Acknowledge) GetTaskID

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

func (*Call_Acknowledge) GetUUID

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

func (*Call_Acknowledge) GoString

func (this *Call_Acknowledge) GoString() string

func (*Call_Acknowledge) Marshal

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

func (*Call_Acknowledge) MarshalJSON

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

func (*Call_Acknowledge) MarshalJSONBuf

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

func (*Call_Acknowledge) MarshalTo

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

func (*Call_Acknowledge) ProtoMessage

func (*Call_Acknowledge) ProtoMessage()

func (*Call_Acknowledge) Reset

func (m *Call_Acknowledge) Reset()

func (*Call_Acknowledge) Size

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

func (*Call_Acknowledge) String

func (this *Call_Acknowledge) String() string

func (*Call_Acknowledge) Unmarshal

func (m *Call_Acknowledge) Unmarshal(dAtA []byte) error

func (*Call_Acknowledge) UnmarshalJSON

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

func (*Call_Acknowledge) UnmarshalJSONFFLexer

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

func (*Call_Acknowledge) VerboseEqual

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

type Call_AcknowledgeOperationStatus

type Call_AcknowledgeOperationStatus struct {
	// If the operation affects resources that belong to a SLRP, both
	// `agent_id` and `resource_provider_id` have to be set.
	//
	// If the operation affects resources that belong to a SERP, only
	// `resource_provider_id` has to be set.
	AgentID            *mesos.AgentID            `protobuf:"bytes,1,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	ResourceProviderID *mesos.ResourceProviderID `protobuf:"bytes,2,opt,name=resource_provider_id,json=resourceProviderId" json:"resource_provider_id,omitempty"`
	UUID               []byte                    `protobuf:"bytes,3,req,name=uuid" json:"uuid,omitempty"`
	OperationID        mesos.OperationID         `protobuf:"bytes,4,req,name=operation_id,json=operationId" json:"operation_id"`
}

EXPERIMENTAL.

Acknowledges the receipt of an operation status update. Schedulers are responsible for explicitly acknowledging the receipt of updates which have the 'UpdateOperationStatus.status().uuid()' field set. Such status updates are retried by the agent or resource provider until they are acknowledged by the scheduler.

func NewPopulatedCall_AcknowledgeOperationStatus

func NewPopulatedCall_AcknowledgeOperationStatus(r randyScheduler, easy bool) *Call_AcknowledgeOperationStatus

func (*Call_AcknowledgeOperationStatus) Descriptor

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

func (*Call_AcknowledgeOperationStatus) Equal

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

func (*Call_AcknowledgeOperationStatus) GetAgentID

func (*Call_AcknowledgeOperationStatus) GetOperationID

func (*Call_AcknowledgeOperationStatus) GetResourceProviderID

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

func (*Call_AcknowledgeOperationStatus) GetUUID

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

func (*Call_AcknowledgeOperationStatus) GoString

func (this *Call_AcknowledgeOperationStatus) GoString() string

func (*Call_AcknowledgeOperationStatus) Marshal

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

func (*Call_AcknowledgeOperationStatus) MarshalJSON

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

func (*Call_AcknowledgeOperationStatus) MarshalJSONBuf

func (*Call_AcknowledgeOperationStatus) MarshalTo

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

func (*Call_AcknowledgeOperationStatus) ProtoMessage

func (*Call_AcknowledgeOperationStatus) ProtoMessage()

func (*Call_AcknowledgeOperationStatus) Reset

func (*Call_AcknowledgeOperationStatus) Size

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

func (*Call_AcknowledgeOperationStatus) String

func (this *Call_AcknowledgeOperationStatus) String() string

func (*Call_AcknowledgeOperationStatus) Unmarshal

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

func (*Call_AcknowledgeOperationStatus) UnmarshalJSON

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

func (*Call_AcknowledgeOperationStatus) UnmarshalJSONFFLexer

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

func (*Call_AcknowledgeOperationStatus) VerboseEqual

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

type Call_Decline

type Call_Decline struct {
	OfferIDs []mesos.OfferID `protobuf:"bytes,1,rep,name=offer_ids,json=offerIds" json:"offer_ids"`
	Filters  *mesos.Filters  `protobuf:"bytes,2,opt,name=filters" json:"filters,omitempty"`
}

Declines an offer, signaling the master to potentially reoffer the resources to a different framework. Note that this is same as sending an Accept call with no operations. See comments on top of 'Accept' for semantics.

func NewPopulatedCall_Decline

func NewPopulatedCall_Decline(r randyScheduler, easy bool) *Call_Decline

func (*Call_Decline) Descriptor

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

func (*Call_Decline) Equal

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

func (*Call_Decline) GetFilters

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

func (*Call_Decline) GetOfferIDs

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

func (*Call_Decline) GoString

func (this *Call_Decline) GoString() string

func (*Call_Decline) Marshal

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

func (*Call_Decline) MarshalJSON

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

func (*Call_Decline) MarshalJSONBuf

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

func (*Call_Decline) MarshalTo

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

func (*Call_Decline) ProtoMessage

func (*Call_Decline) ProtoMessage()

func (*Call_Decline) Reset

func (m *Call_Decline) Reset()

func (*Call_Decline) Size

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

func (*Call_Decline) String

func (this *Call_Decline) String() string

func (*Call_Decline) Unmarshal

func (m *Call_Decline) Unmarshal(dAtA []byte) error

func (*Call_Decline) UnmarshalJSON

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

func (*Call_Decline) UnmarshalJSONFFLexer

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

func (*Call_Decline) VerboseEqual

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

type Call_DeclineInverseOffers

type Call_DeclineInverseOffers struct {
	InverseOfferIDs []mesos.OfferID `protobuf:"bytes,1,rep,name=inverse_offer_ids,json=inverseOfferIds" json:"inverse_offer_ids"`
	Filters         *mesos.Filters  `protobuf:"bytes,2,opt,name=filters" json:"filters,omitempty"`
}

Declines an inverse offer. Inverse offers should be declined if the resources in the offer might not be safely evacuated before the provided unavailability.

func NewPopulatedCall_DeclineInverseOffers

func NewPopulatedCall_DeclineInverseOffers(r randyScheduler, easy bool) *Call_DeclineInverseOffers

func (*Call_DeclineInverseOffers) Descriptor

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

func (*Call_DeclineInverseOffers) Equal

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

func (*Call_DeclineInverseOffers) GetFilters

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

func (*Call_DeclineInverseOffers) GetInverseOfferIDs

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

func (*Call_DeclineInverseOffers) GoString

func (this *Call_DeclineInverseOffers) GoString() string

func (*Call_DeclineInverseOffers) Marshal

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

func (*Call_DeclineInverseOffers) MarshalJSON

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

func (*Call_DeclineInverseOffers) MarshalJSONBuf

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

func (*Call_DeclineInverseOffers) MarshalTo

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

func (*Call_DeclineInverseOffers) ProtoMessage

func (*Call_DeclineInverseOffers) ProtoMessage()

func (*Call_DeclineInverseOffers) Reset

func (m *Call_DeclineInverseOffers) Reset()

func (*Call_DeclineInverseOffers) Size

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

func (*Call_DeclineInverseOffers) String

func (this *Call_DeclineInverseOffers) String() string

func (*Call_DeclineInverseOffers) Unmarshal

func (m *Call_DeclineInverseOffers) Unmarshal(dAtA []byte) error

func (*Call_DeclineInverseOffers) UnmarshalJSON

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

func (*Call_DeclineInverseOffers) UnmarshalJSONFFLexer

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

func (*Call_DeclineInverseOffers) VerboseEqual

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

type Call_Kill

type Call_Kill struct {
	TaskID  mesos.TaskID   `protobuf:"bytes,1,req,name=task_id,json=taskId" json:"task_id"`
	AgentID *mesos.AgentID `protobuf:"bytes,2,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	// If set, overrides any previously specified kill policy for this task.
	// This includes 'TaskInfo.kill_policy' and 'Executor.kill.kill_policy'.
	// Can be used to forcefully kill a task which is already being killed.
	KillPolicy *mesos.KillPolicy `protobuf:"bytes,3,opt,name=kill_policy,json=killPolicy" json:"kill_policy,omitempty"`
}

Kills a specific task. If the scheduler has a custom executor, the kill is forwarded to the executor and it is up to the executor to kill the task and send a TASK_KILLED (or TASK_FAILED) update. Note that Mesos releases the resources for a task once it receives a terminal update (See TaskState in v1/mesos.proto) for it. If the task is unknown to the master, a TASK_LOST update is generated.

If a task within a task group is killed before the group is delivered to the executor, all tasks in the task group are killed. When a task group has been delivered to the executor, it is up to the executor to decide how to deal with the kill. Note The default Mesos executor will currently kill all the tasks in the task group if it gets a kill for any task.

func NewPopulatedCall_Kill

func NewPopulatedCall_Kill(r randyScheduler, easy bool) *Call_Kill

func (*Call_Kill) Descriptor

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

func (*Call_Kill) Equal

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

func (*Call_Kill) GetAgentID

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

func (*Call_Kill) GetKillPolicy

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

func (*Call_Kill) GetTaskID

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

func (*Call_Kill) GoString

func (this *Call_Kill) GoString() string

func (*Call_Kill) Marshal

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

func (*Call_Kill) MarshalJSON

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

func (*Call_Kill) MarshalJSONBuf

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

func (*Call_Kill) MarshalTo

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

func (*Call_Kill) ProtoMessage

func (*Call_Kill) ProtoMessage()

func (*Call_Kill) Reset

func (m *Call_Kill) Reset()

func (*Call_Kill) Size

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

func (*Call_Kill) String

func (this *Call_Kill) String() string

func (*Call_Kill) Unmarshal

func (m *Call_Kill) Unmarshal(dAtA []byte) error

func (*Call_Kill) UnmarshalJSON

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

func (*Call_Kill) UnmarshalJSONFFLexer

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

func (*Call_Kill) VerboseEqual

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

type Call_Message

type Call_Message struct {
	AgentID    mesos.AgentID    `protobuf:"bytes,1,req,name=agent_id,json=agentId" json:"agent_id"`
	ExecutorID mesos.ExecutorID `protobuf:"bytes,2,req,name=executor_id,json=executorId" json:"executor_id"`
	Data       []byte           `protobuf:"bytes,3,req,name=data" json:"data,omitempty"`
}

Sends arbitrary binary data to the executor. Note that Mesos neither interprets this data nor makes any guarantees about the delivery of this message to the executor.

func NewPopulatedCall_Message

func NewPopulatedCall_Message(r randyScheduler, easy bool) *Call_Message

func (*Call_Message) Descriptor

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

func (*Call_Message) Equal

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

func (*Call_Message) GetAgentID

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

func (*Call_Message) GetData

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

func (*Call_Message) GetExecutorID

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

func (*Call_Message) GoString

func (this *Call_Message) GoString() string

func (*Call_Message) Marshal

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

func (*Call_Message) MarshalJSON

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

func (*Call_Message) MarshalJSONBuf

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

func (*Call_Message) MarshalTo

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

func (*Call_Message) ProtoMessage

func (*Call_Message) ProtoMessage()

func (*Call_Message) Reset

func (m *Call_Message) Reset()

func (*Call_Message) Size

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

func (*Call_Message) String

func (this *Call_Message) String() string

func (*Call_Message) Unmarshal

func (m *Call_Message) Unmarshal(dAtA []byte) error

func (*Call_Message) UnmarshalJSON

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

func (*Call_Message) UnmarshalJSONFFLexer

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

func (*Call_Message) VerboseEqual

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

type Call_Reconcile

type Call_Reconcile struct {
	Tasks []Call_Reconcile_Task `protobuf:"bytes,1,rep,name=tasks" json:"tasks"`
}

Allows the scheduler to query the status for non-terminal tasks. This causes the master to send back the latest task status for each task in 'tasks', if possible. Tasks that are no longer known will result in a TASK_LOST, TASK_UNKNOWN, or TASK_UNREACHABLE update. If 'tasks' is empty, then the master will send the latest status for each task currently known.

func NewPopulatedCall_Reconcile

func NewPopulatedCall_Reconcile(r randyScheduler, easy bool) *Call_Reconcile

func (*Call_Reconcile) Descriptor

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

func (*Call_Reconcile) Equal

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

func (*Call_Reconcile) GetTasks

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

func (*Call_Reconcile) GoString

func (this *Call_Reconcile) GoString() string

func (*Call_Reconcile) Marshal

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

func (*Call_Reconcile) MarshalJSON

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

func (*Call_Reconcile) MarshalJSONBuf

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

func (*Call_Reconcile) MarshalTo

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

func (*Call_Reconcile) ProtoMessage

func (*Call_Reconcile) ProtoMessage()

func (*Call_Reconcile) Reset

func (m *Call_Reconcile) Reset()

func (*Call_Reconcile) Size

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

func (*Call_Reconcile) String

func (this *Call_Reconcile) String() string

func (*Call_Reconcile) Unmarshal

func (m *Call_Reconcile) Unmarshal(dAtA []byte) error

func (*Call_Reconcile) UnmarshalJSON

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

func (*Call_Reconcile) UnmarshalJSONFFLexer

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

func (*Call_Reconcile) VerboseEqual

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

func (*Call_Reconcile) With

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

With applies the given ReconcileOpt's to the receiving Call_Reconcile, returning it.

type Call_ReconcileOperations

type Call_ReconcileOperations struct {
	Operations []Call_ReconcileOperations_Operation `protobuf:"bytes,1,rep,name=operations" json:"operations"`
}

EXPERIMENTAL.

Allows the scheduler to query the status of operations. This causes the master to send back the latest status for each operation in 'operations', if possible. If 'operations' is empty, then the master will send the latest status for each operation currently known.

func NewPopulatedCall_ReconcileOperations

func NewPopulatedCall_ReconcileOperations(r randyScheduler, easy bool) *Call_ReconcileOperations

func (*Call_ReconcileOperations) Descriptor

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

func (*Call_ReconcileOperations) Equal

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

func (*Call_ReconcileOperations) GetOperations

func (*Call_ReconcileOperations) GoString

func (this *Call_ReconcileOperations) GoString() string

func (*Call_ReconcileOperations) Marshal

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

func (*Call_ReconcileOperations) MarshalJSON

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

func (*Call_ReconcileOperations) MarshalJSONBuf

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

func (*Call_ReconcileOperations) MarshalTo

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

func (*Call_ReconcileOperations) ProtoMessage

func (*Call_ReconcileOperations) ProtoMessage()

func (*Call_ReconcileOperations) Reset

func (m *Call_ReconcileOperations) Reset()

func (*Call_ReconcileOperations) Size

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

func (*Call_ReconcileOperations) String

func (this *Call_ReconcileOperations) String() string

func (*Call_ReconcileOperations) Unmarshal

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

func (*Call_ReconcileOperations) UnmarshalJSON

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

func (*Call_ReconcileOperations) UnmarshalJSONFFLexer

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

func (*Call_ReconcileOperations) VerboseEqual

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

type Call_ReconcileOperations_Operation

type Call_ReconcileOperations_Operation struct {
	OperationID mesos.OperationID `protobuf:"bytes,1,req,name=operation_id,json=operationId" json:"operation_id"`
	// If `agent_id` is not set and the master doesn't know the operation,
	// then it will return `OPERATION_UNKNOWN`; if `agent_id` is set, it can
	// return more fine-grained states depending on the state of the
	// corresponding agent.
	AgentID            *mesos.AgentID            `protobuf:"bytes,2,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	ResourceProviderID *mesos.ResourceProviderID `protobuf:"bytes,3,opt,name=resource_provider_id,json=resourceProviderId" json:"resource_provider_id,omitempty"`
}

func NewPopulatedCall_ReconcileOperations_Operation

func NewPopulatedCall_ReconcileOperations_Operation(r randyScheduler, easy bool) *Call_ReconcileOperations_Operation

func (*Call_ReconcileOperations_Operation) Descriptor

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

func (*Call_ReconcileOperations_Operation) Equal

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

func (*Call_ReconcileOperations_Operation) GetAgentID

func (*Call_ReconcileOperations_Operation) GetOperationID

func (*Call_ReconcileOperations_Operation) GetResourceProviderID

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

func (*Call_ReconcileOperations_Operation) GoString

func (this *Call_ReconcileOperations_Operation) GoString() string

func (*Call_ReconcileOperations_Operation) Marshal

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

func (*Call_ReconcileOperations_Operation) MarshalJSON

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

func (*Call_ReconcileOperations_Operation) MarshalJSONBuf

func (*Call_ReconcileOperations_Operation) MarshalTo

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

func (*Call_ReconcileOperations_Operation) ProtoMessage

func (*Call_ReconcileOperations_Operation) ProtoMessage()

func (*Call_ReconcileOperations_Operation) Reset

func (*Call_ReconcileOperations_Operation) Size

func (*Call_ReconcileOperations_Operation) String

func (*Call_ReconcileOperations_Operation) Unmarshal

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

func (*Call_ReconcileOperations_Operation) UnmarshalJSON

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

func (*Call_ReconcileOperations_Operation) UnmarshalJSONFFLexer

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

func (*Call_ReconcileOperations_Operation) VerboseEqual

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

type Call_Reconcile_Task

type Call_Reconcile_Task struct {
	TaskID  mesos.TaskID   `protobuf:"bytes,1,req,name=task_id,json=taskId" json:"task_id"`
	AgentID *mesos.AgentID `protobuf:"bytes,2,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
}

TODO(vinod): Support arbitrary queries than just state of tasks.

func NewPopulatedCall_Reconcile_Task

func NewPopulatedCall_Reconcile_Task(r randyScheduler, easy bool) *Call_Reconcile_Task

func (*Call_Reconcile_Task) Descriptor

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

func (*Call_Reconcile_Task) Equal

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

func (*Call_Reconcile_Task) GetAgentID

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

func (*Call_Reconcile_Task) GetTaskID

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

func (*Call_Reconcile_Task) GoString

func (this *Call_Reconcile_Task) GoString() string

func (*Call_Reconcile_Task) Marshal

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

func (*Call_Reconcile_Task) MarshalJSON

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

func (*Call_Reconcile_Task) MarshalJSONBuf

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

func (*Call_Reconcile_Task) MarshalTo

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

func (*Call_Reconcile_Task) ProtoMessage

func (*Call_Reconcile_Task) ProtoMessage()

func (*Call_Reconcile_Task) Reset

func (m *Call_Reconcile_Task) Reset()

func (*Call_Reconcile_Task) Size

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

func (*Call_Reconcile_Task) String

func (this *Call_Reconcile_Task) String() string

func (*Call_Reconcile_Task) Unmarshal

func (m *Call_Reconcile_Task) Unmarshal(dAtA []byte) error

func (*Call_Reconcile_Task) UnmarshalJSON

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

func (*Call_Reconcile_Task) UnmarshalJSONFFLexer

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

func (*Call_Reconcile_Task) VerboseEqual

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

type Call_Request

type Call_Request struct {
	Requests []mesos.Request `protobuf:"bytes,1,rep,name=requests" json:"requests"`
}

Requests a specific set of resources from Mesos's allocator. If the allocator has support for this, corresponding offers will be sent asynchronously via the OFFERS event(s).

NOTE: The built-in hierarchical allocator doesn't have support for this call and hence simply ignores it.

func NewPopulatedCall_Request

func NewPopulatedCall_Request(r randyScheduler, easy bool) *Call_Request

func (*Call_Request) Descriptor

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

func (*Call_Request) Equal

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

func (*Call_Request) GetRequests

func (m *Call_Request) GetRequests() []mesos.Request

func (*Call_Request) GoString

func (this *Call_Request) GoString() string

func (*Call_Request) Marshal

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

func (*Call_Request) MarshalJSON

func (mj *Call_Request) MarshalJSON() ([]byte, error)

func (*Call_Request) MarshalJSONBuf

func (mj *Call_Request) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Call_Request) MarshalTo

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

func (*Call_Request) ProtoMessage

func (*Call_Request) ProtoMessage()

func (*Call_Request) Reset

func (m *Call_Request) Reset()

func (*Call_Request) Size

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

func (*Call_Request) String

func (this *Call_Request) String() string

func (*Call_Request) Unmarshal

func (m *Call_Request) Unmarshal(dAtA []byte) error

func (*Call_Request) UnmarshalJSON

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

func (*Call_Request) UnmarshalJSONFFLexer

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

func (*Call_Request) VerboseEqual

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

type Call_Revive

type Call_Revive struct {
	Roles []string `protobuf:"bytes,1,rep,name=roles" json:"roles,omitempty"`
}

Revive offers for the specified roles. If `roles` is empty, the `REVIVE` call will revive offers for all of the roles the framework is currently subscribed to.

func NewPopulatedCall_Revive

func NewPopulatedCall_Revive(r randyScheduler, easy bool) *Call_Revive

func (*Call_Revive) Descriptor

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

func (*Call_Revive) Equal

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

func (*Call_Revive) GetRoles

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

func (*Call_Revive) GoString

func (this *Call_Revive) GoString() string

func (*Call_Revive) Marshal

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

func (*Call_Revive) MarshalJSON

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

func (*Call_Revive) MarshalJSONBuf

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

func (*Call_Revive) MarshalTo

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

func (*Call_Revive) ProtoMessage

func (*Call_Revive) ProtoMessage()

func (*Call_Revive) Reset

func (m *Call_Revive) Reset()

func (*Call_Revive) Size

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

func (*Call_Revive) String

func (this *Call_Revive) String() string

func (*Call_Revive) Unmarshal

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

func (*Call_Revive) UnmarshalJSON

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

func (*Call_Revive) UnmarshalJSONFFLexer

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

func (*Call_Revive) VerboseEqual

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

type Call_Shutdown

type Call_Shutdown struct {
	ExecutorID mesos.ExecutorID `protobuf:"bytes,1,req,name=executor_id,json=executorId" json:"executor_id"`
	AgentID    mesos.AgentID    `protobuf:"bytes,2,req,name=agent_id,json=agentId" json:"agent_id"`
}

Shuts down a custom executor. When the executor gets a shutdown event, it is expected to kill all its tasks (and send TASK_KILLED updates) and terminate. If the executor doesn't terminate within a certain timeout (configurable via '--executor_shutdown_grace_period' agent flag), the agent will forcefully destroy the container (executor and its tasks) and transition its active tasks to TASK_LOST.

func NewPopulatedCall_Shutdown

func NewPopulatedCall_Shutdown(r randyScheduler, easy bool) *Call_Shutdown

func (*Call_Shutdown) Descriptor

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

func (*Call_Shutdown) Equal

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

func (*Call_Shutdown) GetAgentID

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

func (*Call_Shutdown) GetExecutorID

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

func (*Call_Shutdown) GoString

func (this *Call_Shutdown) GoString() string

func (*Call_Shutdown) Marshal

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

func (*Call_Shutdown) MarshalJSON

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

func (*Call_Shutdown) MarshalJSONBuf

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

func (*Call_Shutdown) MarshalTo

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

func (*Call_Shutdown) ProtoMessage

func (*Call_Shutdown) ProtoMessage()

func (*Call_Shutdown) Reset

func (m *Call_Shutdown) Reset()

func (*Call_Shutdown) Size

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

func (*Call_Shutdown) String

func (this *Call_Shutdown) String() string

func (*Call_Shutdown) Unmarshal

func (m *Call_Shutdown) Unmarshal(dAtA []byte) error

func (*Call_Shutdown) UnmarshalJSON

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

func (*Call_Shutdown) UnmarshalJSONFFLexer

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

func (*Call_Shutdown) VerboseEqual

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

type Call_Subscribe

type Call_Subscribe struct {
	// See the comments below on 'framework_id' on the semantics for
	// 'framework_info.id'.
	FrameworkInfo *mesos.FrameworkInfo `protobuf:"bytes,1,req,name=framework_info,json=frameworkInfo" json:"framework_info,omitempty"`
	// List of suppressed roles for which the framework does not wish to be
	// offered resources. The framework can decide to suppress all or a subset
	// of roles the framework (re)registers as.
	SuppressedRoles []string `protobuf:"bytes,2,rep,name=suppressed_roles,json=suppressedRoles" json:"suppressed_roles,omitempty"`
}

Subscribes the scheduler with the master to receive events. A scheduler must send other calls only after it has received the SUBCRIBED event.

func NewPopulatedCall_Subscribe

func NewPopulatedCall_Subscribe(r randyScheduler, easy bool) *Call_Subscribe

func (*Call_Subscribe) Descriptor

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

func (*Call_Subscribe) Equal

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

func (*Call_Subscribe) GetFrameworkInfo

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

func (*Call_Subscribe) GetSuppressedRoles

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

func (*Call_Subscribe) GoString

func (this *Call_Subscribe) GoString() string

func (*Call_Subscribe) Marshal

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

func (*Call_Subscribe) MarshalJSON

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

func (*Call_Subscribe) MarshalJSONBuf

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

func (*Call_Subscribe) MarshalTo

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

func (*Call_Subscribe) ProtoMessage

func (*Call_Subscribe) ProtoMessage()

func (*Call_Subscribe) Reset

func (m *Call_Subscribe) Reset()

func (*Call_Subscribe) Size

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

func (*Call_Subscribe) String

func (this *Call_Subscribe) String() string

func (*Call_Subscribe) Unmarshal

func (m *Call_Subscribe) Unmarshal(dAtA []byte) error

func (*Call_Subscribe) UnmarshalJSON

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

func (*Call_Subscribe) UnmarshalJSONFFLexer

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

func (*Call_Subscribe) VerboseEqual

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

type Call_Suppress

type Call_Suppress struct {
	Roles []string `protobuf:"bytes,1,rep,name=roles" json:"roles,omitempty"`
}

Suppress offers for the specified roles. If `roles` is empty, the `SUPPRESS` call will suppress offers for all of the roles the framework is currently subscribed to.

func NewPopulatedCall_Suppress

func NewPopulatedCall_Suppress(r randyScheduler, easy bool) *Call_Suppress

func (*Call_Suppress) Descriptor

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

func (*Call_Suppress) Equal

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

func (*Call_Suppress) GetRoles

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

func (*Call_Suppress) GoString

func (this *Call_Suppress) GoString() string

func (*Call_Suppress) Marshal

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

func (*Call_Suppress) MarshalJSON

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

func (*Call_Suppress) MarshalJSONBuf

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

func (*Call_Suppress) MarshalTo

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

func (*Call_Suppress) ProtoMessage

func (*Call_Suppress) ProtoMessage()

func (*Call_Suppress) Reset

func (m *Call_Suppress) Reset()

func (*Call_Suppress) Size

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

func (*Call_Suppress) String

func (this *Call_Suppress) String() string

func (*Call_Suppress) Unmarshal

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

func (*Call_Suppress) UnmarshalJSON

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

func (*Call_Suppress) UnmarshalJSONFFLexer

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

func (*Call_Suppress) VerboseEqual

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

type Call_Type

type Call_Type int32

Possible call types, followed by message definitions if applicable.

const (
	// See comments above on `Event::Type` for more details on this enum value.
	Call_UNKNOWN                      Call_Type = 0
	Call_SUBSCRIBE                    Call_Type = 1
	Call_TEARDOWN                     Call_Type = 2
	Call_ACCEPT                       Call_Type = 3
	Call_DECLINE                      Call_Type = 4
	Call_ACCEPT_INVERSE_OFFERS        Call_Type = 13
	Call_DECLINE_INVERSE_OFFERS       Call_Type = 14
	Call_REVIVE                       Call_Type = 5
	Call_KILL                         Call_Type = 6
	Call_SHUTDOWN                     Call_Type = 7
	Call_ACKNOWLEDGE                  Call_Type = 8
	Call_ACKNOWLEDGE_OPERATION_STATUS Call_Type = 15
	Call_RECONCILE                    Call_Type = 9
	Call_RECONCILE_OPERATIONS         Call_Type = 16
	Call_MESSAGE                      Call_Type = 10
	Call_REQUEST                      Call_Type = 11
	Call_SUPPRESS                     Call_Type = 12
	Call_UPDATE_FRAMEWORK             Call_Type = 17
)

func (Call_Type) Enum

func (x Call_Type) Enum() *Call_Type

func (Call_Type) EnumDescriptor

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

func (Call_Type) MarshalJSON

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

func (Call_Type) String

func (x Call_Type) String() string

func (*Call_Type) UnmarshalJSON

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

type Call_UpdateFramework

type Call_UpdateFramework struct {
	FrameworkInfo mesos.FrameworkInfo `protobuf:"bytes,1,req,name=framework_info,json=frameworkInfo" json:"framework_info"`
	// List of suppressed roles for which the framework does not wish to be
	// offered resources. The framework can decide to suppress all or a subset
	// of roles provided in the new `framework_info`.
	SuppressedRoles []string `protobuf:"bytes,2,rep,name=suppressed_roles,json=suppressedRoles" json:"suppressed_roles,omitempty"`
}

Updates the FrameworkInfo. All fields can be updated except for:

* FrameworkInfo.checkpoint * FrameworkInfo.principal * FrameworkInfo.user

The call returns after the update is either applied completely or not applied at all. No incomplete updates occur.

The HTTP response codes specific to this call are:

  • 200 OK: update operation was successfully completed.
  • 400 Bad Request: the requested update is not valid.
  • 403 Forbidden: framework is not authorized to use some entities requested by the update (e.g. not authorized to use some of the supplied roles).
  • 409 Conflict: framework disappeared while this call was being processed (example: the framework was removed by a concurrent TEARDOWN call).

func NewPopulatedCall_UpdateFramework

func NewPopulatedCall_UpdateFramework(r randyScheduler, easy bool) *Call_UpdateFramework

func (*Call_UpdateFramework) Descriptor

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

func (*Call_UpdateFramework) Equal

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

func (*Call_UpdateFramework) GetFrameworkInfo

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

func (*Call_UpdateFramework) GetSuppressedRoles

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

func (*Call_UpdateFramework) GoString

func (this *Call_UpdateFramework) GoString() string

func (*Call_UpdateFramework) Marshal

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

func (*Call_UpdateFramework) MarshalJSON

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

func (*Call_UpdateFramework) MarshalJSONBuf

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

func (*Call_UpdateFramework) MarshalTo

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

func (*Call_UpdateFramework) ProtoMessage

func (*Call_UpdateFramework) ProtoMessage()

func (*Call_UpdateFramework) Reset

func (m *Call_UpdateFramework) Reset()

func (*Call_UpdateFramework) Size

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

func (*Call_UpdateFramework) String

func (this *Call_UpdateFramework) String() string

func (*Call_UpdateFramework) Unmarshal

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

func (*Call_UpdateFramework) UnmarshalJSON

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

func (*Call_UpdateFramework) UnmarshalJSONFFLexer

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

func (*Call_UpdateFramework) VerboseEqual

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

type Event

type Event struct {
	// Type of the event, indicates which optional field below should be
	// present if that type has a nested message definition.
	// Enum fields should be optional, see: MESOS-4997.
	Type                  Event_Type                   `protobuf:"varint,1,opt,name=type,enum=mesos.scheduler.Event_Type" json:"type"`
	Subscribed            *Event_Subscribed            `protobuf:"bytes,2,opt,name=subscribed" json:"subscribed,omitempty"`
	Offers                *Event_Offers                `protobuf:"bytes,3,opt,name=offers" json:"offers,omitempty"`
	InverseOffers         *Event_InverseOffers         `protobuf:"bytes,9,opt,name=inverse_offers,json=inverseOffers" json:"inverse_offers,omitempty"`
	Rescind               *Event_Rescind               `protobuf:"bytes,4,opt,name=rescind" json:"rescind,omitempty"`
	RescindInverseOffer   *Event_RescindInverseOffer   `protobuf:"bytes,10,opt,name=rescind_inverse_offer,json=rescindInverseOffer" json:"rescind_inverse_offer,omitempty"`
	Update                *Event_Update                `protobuf:"bytes,5,opt,name=update" json:"update,omitempty"`
	UpdateOperationStatus *Event_UpdateOperationStatus `protobuf:"bytes,11,opt,name=update_operation_status,json=updateOperationStatus" json:"update_operation_status,omitempty"`
	Message               *Event_Message               `protobuf:"bytes,6,opt,name=message" json:"message,omitempty"`
	Failure               *Event_Failure               `protobuf:"bytes,7,opt,name=failure" json:"failure,omitempty"`
	Error                 *Event_Error                 `protobuf:"bytes,8,opt,name=error" json:"error,omitempty"`
}

* Scheduler event API.

An event is described using the standard protocol buffer "union" trick, see: https://developers.google.com/protocol-buffers/docs/techniques#union.

func NewPopulatedEvent

func NewPopulatedEvent(r randyScheduler, easy bool) *Event

func (*Event) Descriptor

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

func (*Event) Equal

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

func (*Event) GetError

func (m *Event) GetError() *Event_Error

func (*Event) GetFailure

func (m *Event) GetFailure() *Event_Failure

func (*Event) GetInverseOffers

func (m *Event) GetInverseOffers() *Event_InverseOffers

func (*Event) GetMessage

func (m *Event) GetMessage() *Event_Message

func (*Event) GetOffers

func (m *Event) GetOffers() *Event_Offers

func (*Event) GetRescind

func (m *Event) GetRescind() *Event_Rescind

func (*Event) GetRescindInverseOffer

func (m *Event) GetRescindInverseOffer() *Event_RescindInverseOffer

func (*Event) GetSubscribed

func (m *Event) GetSubscribed() *Event_Subscribed

func (*Event) GetType

func (m *Event) GetType() Event_Type

func (*Event) GetUpdate

func (m *Event) GetUpdate() *Event_Update

func (*Event) GetUpdateOperationStatus

func (m *Event) GetUpdateOperationStatus() *Event_UpdateOperationStatus

func (*Event) GoString

func (this *Event) GoString() string

func (*Event) Marshal

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

func (*Event) MarshalJSON

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

func (*Event) MarshalJSONBuf

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

func (*Event) MarshalTo

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

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) Reset

func (m *Event) Reset()

func (*Event) Size

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

func (*Event) String

func (this *Event) String() string

func (*Event) Unmarshal

func (m *Event) Unmarshal(dAtA []byte) error

func (*Event) UnmarshalJSON

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

func (*Event) UnmarshalJSONFFLexer

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

func (*Event) VerboseEqual

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

type Event_Error

type Event_Error struct {
	Message string `protobuf:"bytes,1,req,name=message" json:"message"`
}

Received when there is an unrecoverable error in the scheduler (e.g., scheduler failed over, rate limiting, authorization errors etc.). The scheduler should abort on receiving this event.

func NewPopulatedEvent_Error

func NewPopulatedEvent_Error(r randyScheduler, easy bool) *Event_Error

func (*Event_Error) Descriptor

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

func (*Event_Error) Equal

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

func (*Event_Error) GetMessage

func (m *Event_Error) GetMessage() string

func (*Event_Error) GoString

func (this *Event_Error) GoString() string

func (*Event_Error) Marshal

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

func (*Event_Error) MarshalJSON

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

func (*Event_Error) MarshalJSONBuf

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

func (*Event_Error) MarshalTo

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

func (*Event_Error) ProtoMessage

func (*Event_Error) ProtoMessage()

func (*Event_Error) Reset

func (m *Event_Error) Reset()

func (*Event_Error) Size

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

func (*Event_Error) String

func (this *Event_Error) String() string

func (*Event_Error) Unmarshal

func (m *Event_Error) Unmarshal(dAtA []byte) error

func (*Event_Error) UnmarshalJSON

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

func (*Event_Error) UnmarshalJSONFFLexer

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

func (*Event_Error) VerboseEqual

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

type Event_Failure

type Event_Failure struct {
	AgentID *mesos.AgentID `protobuf:"bytes,1,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	// If this was just a failure of an executor on an agent then
	// 'executor_id' will be set and possibly 'status' (if we were
	// able to determine the exit status).
	ExecutorID *mesos.ExecutorID `protobuf:"bytes,2,opt,name=executor_id,json=executorId" json:"executor_id,omitempty"`
	// On Posix, `status` corresponds to termination information in the
	// `stat_loc` area returned from a `waitpid` call. On Windows, `status`
	// is obtained via calling the `GetExitCodeProcess()` function. For
	// messages coming from Posix agents, schedulers need to apply
	// `WEXITSTATUS` family macros or equivalent transformations to obtain
	// exit codes.
	//
	// TODO(alexr): Consider unifying Windows and Posix behavior by returning
	// exit code here, see MESOS-7241.
	Status *int32 `protobuf:"varint,3,opt,name=status" json:"status,omitempty"`
}

Received when an agent is removed from the cluster (e.g., failed health checks) or when an executor is terminated. Note that, this event coincides with receipt of terminal UPDATE events for any active tasks belonging to the agent or executor and receipt of 'Rescind' events for any outstanding offers belonging to the agent. Note that there is no guaranteed order between the 'Failure', 'Update' and 'Rescind' events when an agent or executor is removed. TODO(vinod): Consider splitting the lost agent and terminated executor into separate events and ensure it's reliably generated.

func NewPopulatedEvent_Failure

func NewPopulatedEvent_Failure(r randyScheduler, easy bool) *Event_Failure

func (*Event_Failure) Descriptor

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

func (*Event_Failure) Equal

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

func (*Event_Failure) GetAgentID

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

func (*Event_Failure) GetExecutorID

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

func (*Event_Failure) GetStatus

func (m *Event_Failure) GetStatus() int32

func (*Event_Failure) GoString

func (this *Event_Failure) GoString() string

func (*Event_Failure) Marshal

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

func (*Event_Failure) MarshalJSON

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

func (*Event_Failure) MarshalJSONBuf

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

func (*Event_Failure) MarshalTo

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

func (*Event_Failure) ProtoMessage

func (*Event_Failure) ProtoMessage()

func (*Event_Failure) Reset

func (m *Event_Failure) Reset()

func (*Event_Failure) Size

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

func (*Event_Failure) String

func (this *Event_Failure) String() string

func (*Event_Failure) Unmarshal

func (m *Event_Failure) Unmarshal(dAtA []byte) error

func (*Event_Failure) UnmarshalJSON

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

func (*Event_Failure) UnmarshalJSONFFLexer

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

func (*Event_Failure) VerboseEqual

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

type Event_InverseOffers

type Event_InverseOffers struct {
	InverseOffers []mesos.InverseOffer `protobuf:"bytes,1,rep,name=inverse_offers,json=inverseOffers" json:"inverse_offers"`
}

Received whenever there are resources requested back from the scheduler. Each inverse offer specifies the agent, and optionally specific resources. Accepting or Declining an inverse offer informs the allocator of the scheduler's ability to release the specified resources without violating an SLA. If no resources are specified then all resources on the agent are requested to be released.

func NewPopulatedEvent_InverseOffers

func NewPopulatedEvent_InverseOffers(r randyScheduler, easy bool) *Event_InverseOffers

func (*Event_InverseOffers) Descriptor

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

func (*Event_InverseOffers) Equal

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

func (*Event_InverseOffers) GetInverseOffers

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

func (*Event_InverseOffers) GoString

func (this *Event_InverseOffers) GoString() string

func (*Event_InverseOffers) Marshal

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

func (*Event_InverseOffers) MarshalJSON

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

func (*Event_InverseOffers) MarshalJSONBuf

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

func (*Event_InverseOffers) MarshalTo

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

func (*Event_InverseOffers) ProtoMessage

func (*Event_InverseOffers) ProtoMessage()

func (*Event_InverseOffers) Reset

func (m *Event_InverseOffers) Reset()

func (*Event_InverseOffers) Size

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

func (*Event_InverseOffers) String

func (this *Event_InverseOffers) String() string

func (*Event_InverseOffers) Unmarshal

func (m *Event_InverseOffers) Unmarshal(dAtA []byte) error

func (*Event_InverseOffers) UnmarshalJSON

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

func (*Event_InverseOffers) UnmarshalJSONFFLexer

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

func (*Event_InverseOffers) VerboseEqual

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

type Event_Message

type Event_Message struct {
	AgentID    mesos.AgentID    `protobuf:"bytes,1,req,name=agent_id,json=agentId" json:"agent_id"`
	ExecutorID mesos.ExecutorID `protobuf:"bytes,2,req,name=executor_id,json=executorId" json:"executor_id"`
	Data       []byte           `protobuf:"bytes,3,req,name=data" json:"data,omitempty"`
}

Received when a custom message generated by the executor is forwarded by the master. Note that this message is not interpreted by Mesos and is only forwarded (without reliability guarantees) to the scheduler. It is up to the executor to retry if the message is dropped for any reason.

func NewPopulatedEvent_Message

func NewPopulatedEvent_Message(r randyScheduler, easy bool) *Event_Message

func (*Event_Message) Descriptor

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

func (*Event_Message) Equal

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

func (*Event_Message) GetAgentID

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

func (*Event_Message) GetData

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

func (*Event_Message) GetExecutorID

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

func (*Event_Message) GoString

func (this *Event_Message) GoString() string

func (*Event_Message) Marshal

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

func (*Event_Message) MarshalJSON

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

func (*Event_Message) MarshalJSONBuf

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

func (*Event_Message) MarshalTo

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

func (*Event_Message) ProtoMessage

func (*Event_Message) ProtoMessage()

func (*Event_Message) Reset

func (m *Event_Message) Reset()

func (*Event_Message) Size

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

func (*Event_Message) String

func (this *Event_Message) String() string

func (*Event_Message) Unmarshal

func (m *Event_Message) Unmarshal(dAtA []byte) error

func (*Event_Message) UnmarshalJSON

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

func (*Event_Message) UnmarshalJSONFFLexer

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

func (*Event_Message) VerboseEqual

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

type Event_Offers

type Event_Offers struct {
	Offers []mesos.Offer `protobuf:"bytes,1,rep,name=offers" json:"offers"`
}

Received whenever there are new resources that are offered to the scheduler. Each offer corresponds to a set of resources on an agent. Until the scheduler accepts or declines an offer the resources are considered allocated to the scheduler.

func NewPopulatedEvent_Offers

func NewPopulatedEvent_Offers(r randyScheduler, easy bool) *Event_Offers

func (*Event_Offers) Descriptor

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

func (*Event_Offers) Equal

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

func (*Event_Offers) GetOffers

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

func (*Event_Offers) GoString

func (this *Event_Offers) GoString() string

func (*Event_Offers) Marshal

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

func (*Event_Offers) MarshalJSON

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

func (*Event_Offers) MarshalJSONBuf

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

func (*Event_Offers) MarshalTo

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

func (*Event_Offers) ProtoMessage

func (*Event_Offers) ProtoMessage()

func (*Event_Offers) Reset

func (m *Event_Offers) Reset()

func (*Event_Offers) Size

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

func (*Event_Offers) String

func (this *Event_Offers) String() string

func (*Event_Offers) Unmarshal

func (m *Event_Offers) Unmarshal(dAtA []byte) error

func (*Event_Offers) UnmarshalJSON

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

func (*Event_Offers) UnmarshalJSONFFLexer

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

func (*Event_Offers) VerboseEqual

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

type Event_Rescind

type Event_Rescind struct {
	OfferID mesos.OfferID `protobuf:"bytes,1,req,name=offer_id,json=offerId" json:"offer_id"`
}

Received when a particular offer is no longer valid (e.g., the agent corresponding to the offer has been removed) and hence needs to be rescinded. Any future calls ('Accept' / 'Decline') made by the scheduler regarding this offer will be invalid.

func NewPopulatedEvent_Rescind

func NewPopulatedEvent_Rescind(r randyScheduler, easy bool) *Event_Rescind

func (*Event_Rescind) Descriptor

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

func (*Event_Rescind) Equal

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

func (*Event_Rescind) GetOfferID

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

func (*Event_Rescind) GoString

func (this *Event_Rescind) GoString() string

func (*Event_Rescind) Marshal

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

func (*Event_Rescind) MarshalJSON

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

func (*Event_Rescind) MarshalJSONBuf

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

func (*Event_Rescind) MarshalTo

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

func (*Event_Rescind) ProtoMessage

func (*Event_Rescind) ProtoMessage()

func (*Event_Rescind) Reset

func (m *Event_Rescind) Reset()

func (*Event_Rescind) Size

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

func (*Event_Rescind) String

func (this *Event_Rescind) String() string

func (*Event_Rescind) Unmarshal

func (m *Event_Rescind) Unmarshal(dAtA []byte) error

func (*Event_Rescind) UnmarshalJSON

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

func (*Event_Rescind) UnmarshalJSONFFLexer

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

func (*Event_Rescind) VerboseEqual

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

type Event_RescindInverseOffer

type Event_RescindInverseOffer struct {
	InverseOfferID mesos.OfferID `protobuf:"bytes,1,req,name=inverse_offer_id,json=inverseOfferId" json:"inverse_offer_id"`
}

Received when a particular inverse offer is no longer valid (e.g., the agent corresponding to the offer has been removed) and hence needs to be rescinded. Any future calls ('Accept' / 'Decline') made by the scheduler regarding this inverse offer will be invalid.

func NewPopulatedEvent_RescindInverseOffer

func NewPopulatedEvent_RescindInverseOffer(r randyScheduler, easy bool) *Event_RescindInverseOffer

func (*Event_RescindInverseOffer) Descriptor

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

func (*Event_RescindInverseOffer) Equal

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

func (*Event_RescindInverseOffer) GetInverseOfferID

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

func (*Event_RescindInverseOffer) GoString

func (this *Event_RescindInverseOffer) GoString() string

func (*Event_RescindInverseOffer) Marshal

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

func (*Event_RescindInverseOffer) MarshalJSON

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

func (*Event_RescindInverseOffer) MarshalJSONBuf

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

func (*Event_RescindInverseOffer) MarshalTo

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

func (*Event_RescindInverseOffer) ProtoMessage

func (*Event_RescindInverseOffer) ProtoMessage()

func (*Event_RescindInverseOffer) Reset

func (m *Event_RescindInverseOffer) Reset()

func (*Event_RescindInverseOffer) Size

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

func (*Event_RescindInverseOffer) String

func (this *Event_RescindInverseOffer) String() string

func (*Event_RescindInverseOffer) Unmarshal

func (m *Event_RescindInverseOffer) Unmarshal(dAtA []byte) error

func (*Event_RescindInverseOffer) UnmarshalJSON

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

func (*Event_RescindInverseOffer) UnmarshalJSONFFLexer

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

func (*Event_RescindInverseOffer) VerboseEqual

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

type Event_Subscribed

type Event_Subscribed struct {
	FrameworkID *mesos.FrameworkID `protobuf:"bytes,1,req,name=framework_id,json=frameworkId" json:"framework_id,omitempty"`
	// This value will be set if the master is sending heartbeats. See
	// the comment above on 'HEARTBEAT' for more details.
	HeartbeatIntervalSeconds *float64 `` /* 130-byte string literal not displayed */
	// Since Mesos 1.1.
	MasterInfo *mesos.MasterInfo `protobuf:"bytes,3,opt,name=master_info,json=masterInfo" json:"master_info,omitempty"`
}

First event received when the scheduler subscribes.

func NewPopulatedEvent_Subscribed

func NewPopulatedEvent_Subscribed(r randyScheduler, easy bool) *Event_Subscribed

func (*Event_Subscribed) Descriptor

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

func (*Event_Subscribed) Equal

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

func (*Event_Subscribed) GetFrameworkID

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

func (*Event_Subscribed) GetHeartbeatIntervalSeconds

func (m *Event_Subscribed) GetHeartbeatIntervalSeconds() float64

func (*Event_Subscribed) GetMasterInfo

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

func (*Event_Subscribed) GoString

func (this *Event_Subscribed) GoString() string

func (*Event_Subscribed) Marshal

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

func (*Event_Subscribed) MarshalJSON

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

func (*Event_Subscribed) MarshalJSONBuf

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

func (*Event_Subscribed) MarshalTo

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

func (*Event_Subscribed) ProtoMessage

func (*Event_Subscribed) ProtoMessage()

func (*Event_Subscribed) Reset

func (m *Event_Subscribed) Reset()

func (*Event_Subscribed) Size

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

func (*Event_Subscribed) String

func (this *Event_Subscribed) String() string

func (*Event_Subscribed) Unmarshal

func (m *Event_Subscribed) Unmarshal(dAtA []byte) error

func (*Event_Subscribed) UnmarshalJSON

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

func (*Event_Subscribed) UnmarshalJSONFFLexer

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

func (*Event_Subscribed) VerboseEqual

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

type Event_Type

type Event_Type int32

Possible event types, followed by message definitions if applicable.

const (
	// This must be the first enum value in this list, to
	// ensure that if 'type' is not set, the default value
	// is UNKNOWN. This enables enum values to be added
	// in a backwards-compatible way. See: MESOS-4997.
	Event_UNKNOWN                 Event_Type = 0
	Event_SUBSCRIBED              Event_Type = 1
	Event_OFFERS                  Event_Type = 2
	Event_INVERSE_OFFERS          Event_Type = 9
	Event_RESCIND                 Event_Type = 3
	Event_RESCIND_INVERSE_OFFER   Event_Type = 10
	Event_UPDATE                  Event_Type = 4
	Event_UPDATE_OPERATION_STATUS Event_Type = 11
	Event_MESSAGE                 Event_Type = 5
	Event_FAILURE                 Event_Type = 6
	Event_ERROR                   Event_Type = 7
	// Periodic message sent by the Mesos master according to
	// 'Subscribed.heartbeat_interval_seconds'. If the scheduler does
	// not receive any events (including heartbeats) for an extended
	// period of time (e.g., 5 x heartbeat_interval_seconds), there is
	// likely a network partition. In such a case the scheduler should
	// close the existing subscription connection and resubscribe
	// using a backoff strategy.
	Event_HEARTBEAT Event_Type = 8
)

func (Event_Type) Enum

func (x Event_Type) Enum() *Event_Type

func (Event_Type) EnumDescriptor

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

func (Event_Type) MarshalJSON

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

func (Event_Type) String

func (x Event_Type) String() string

func (*Event_Type) UnmarshalJSON

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

type Event_Update

type Event_Update struct {
	Status mesos.TaskStatus `protobuf:"bytes,1,req,name=status" json:"status"`
}

Received whenever there is a status update that is generated by the executor or agent or master. Status updates should be used by executors to reliably communicate the status of the tasks that they manage. It is crucial that a terminal update (see TaskState in v1/mesos.proto) is sent by the executor as soon as the task terminates, in order for Mesos to release the resources allocated to the task. It is also the responsibility of the scheduler to explicitly acknowledge the receipt of a status update. See 'Acknowledge' in the 'Call' section below for the semantics.

A task status update may be used for guaranteed delivery of some task-related information, e.g., task's health update. Such information may be shadowed by subsequent task status updates, that do not preserve fields of the previously sent message.

func NewPopulatedEvent_Update

func NewPopulatedEvent_Update(r randyScheduler, easy bool) *Event_Update

func (*Event_Update) Descriptor

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

func (*Event_Update) Equal

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

func (*Event_Update) GetStatus

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

func (*Event_Update) GoString

func (this *Event_Update) GoString() string

func (*Event_Update) Marshal

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

func (*Event_Update) MarshalJSON

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

func (*Event_Update) MarshalJSONBuf

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

func (*Event_Update) MarshalTo

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

func (*Event_Update) ProtoMessage

func (*Event_Update) ProtoMessage()

func (*Event_Update) Reset

func (m *Event_Update) Reset()

func (*Event_Update) Size

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

func (*Event_Update) String

func (this *Event_Update) String() string

func (*Event_Update) Unmarshal

func (m *Event_Update) Unmarshal(dAtA []byte) error

func (*Event_Update) UnmarshalJSON

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

func (*Event_Update) UnmarshalJSONFFLexer

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

func (*Event_Update) VerboseEqual

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

type Event_UpdateOperationStatus

type Event_UpdateOperationStatus struct {
	Status mesos.OperationStatus `protobuf:"bytes,1,req,name=status" json:"status"`
}

EXPERIMENTAL.

Received when there is an operation status update generated by the master, agent, or resource provider. These updates are only sent to the framework for operations which had the operation ID set by the framework. It is the responsibility of the scheduler to explicitly acknowledge the receipt of a status update. See 'AcknowledgeOperationStatus' in the 'Call' section below for the semantics.

func NewPopulatedEvent_UpdateOperationStatus

func NewPopulatedEvent_UpdateOperationStatus(r randyScheduler, easy bool) *Event_UpdateOperationStatus

func (*Event_UpdateOperationStatus) Descriptor

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

func (*Event_UpdateOperationStatus) Equal

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

func (*Event_UpdateOperationStatus) GetStatus

func (*Event_UpdateOperationStatus) GoString

func (this *Event_UpdateOperationStatus) GoString() string

func (*Event_UpdateOperationStatus) Marshal

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

func (*Event_UpdateOperationStatus) MarshalJSON

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

func (*Event_UpdateOperationStatus) MarshalJSONBuf

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

func (*Event_UpdateOperationStatus) MarshalTo

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

func (*Event_UpdateOperationStatus) ProtoMessage

func (*Event_UpdateOperationStatus) ProtoMessage()

func (*Event_UpdateOperationStatus) Reset

func (m *Event_UpdateOperationStatus) Reset()

func (*Event_UpdateOperationStatus) Size

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

func (*Event_UpdateOperationStatus) String

func (this *Event_UpdateOperationStatus) String() string

func (*Event_UpdateOperationStatus) Unmarshal

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

func (*Event_UpdateOperationStatus) UnmarshalJSON

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

func (*Event_UpdateOperationStatus) UnmarshalJSONFFLexer

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

func (*Event_UpdateOperationStatus) VerboseEqual

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

type ReconcileOpt

type ReconcileOpt func(*Call_Reconcile)

ReconcileOpt is a functional option type for Call_Reconcile

type Response

type Response struct {
	Type Response_Type `protobuf:"varint,1,opt,name=type,enum=mesos.scheduler.Response_Type" json:"type"`
	// DEPRECATED.
	ReconcileOperations *Response_ReconcileOperations `protobuf:"bytes,2,opt,name=reconcile_operations,json=reconcileOperations" json:"reconcile_operations,omitempty"`
}

* NOTE: After resolution of MESOS-9648, this message is not currently used by Mesos. It is left in place in anticipation of future use.

Synchronous responses for calls made to the scheduler API.

func NewPopulatedResponse

func NewPopulatedResponse(r randyScheduler, easy bool) *Response

func (*Response) Descriptor

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

func (*Response) Equal

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

func (*Response) GetReconcileOperations

func (m *Response) GetReconcileOperations() *Response_ReconcileOperations

func (*Response) GetType

func (m *Response) GetType() Response_Type

func (*Response) GoString

func (this *Response) GoString() string

func (*Response) Marshal

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

func (*Response) MarshalJSON

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

func (*Response) MarshalJSONBuf

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

func (*Response) MarshalTo

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

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) Reset

func (m *Response) Reset()

func (*Response) Size

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

func (*Response) String

func (this *Response) String() string

func (*Response) Unmarshal

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

func (*Response) UnmarshalJSON

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

func (*Response) UnmarshalJSONFFLexer

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

func (*Response) VerboseEqual

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

type Response_ReconcileOperations

type Response_ReconcileOperations struct {
	OperationStatuses []mesos.OperationStatus `protobuf:"bytes,1,rep,name=operation_statuses,json=operationStatuses" json:"operation_statuses"`
}

DEPRECATED.

func NewPopulatedResponse_ReconcileOperations

func NewPopulatedResponse_ReconcileOperations(r randyScheduler, easy bool) *Response_ReconcileOperations

func (*Response_ReconcileOperations) Descriptor

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

func (*Response_ReconcileOperations) Equal

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

func (*Response_ReconcileOperations) GetOperationStatuses

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

func (*Response_ReconcileOperations) GoString

func (this *Response_ReconcileOperations) GoString() string

func (*Response_ReconcileOperations) Marshal

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

func (*Response_ReconcileOperations) MarshalJSON

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

func (*Response_ReconcileOperations) MarshalJSONBuf

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

func (*Response_ReconcileOperations) MarshalTo

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

func (*Response_ReconcileOperations) ProtoMessage

func (*Response_ReconcileOperations) ProtoMessage()

func (*Response_ReconcileOperations) Reset

func (m *Response_ReconcileOperations) Reset()

func (*Response_ReconcileOperations) Size

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

func (*Response_ReconcileOperations) String

func (this *Response_ReconcileOperations) String() string

func (*Response_ReconcileOperations) Unmarshal

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

func (*Response_ReconcileOperations) UnmarshalJSON

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

func (*Response_ReconcileOperations) UnmarshalJSONFFLexer

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

func (*Response_ReconcileOperations) VerboseEqual

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

type Response_Type

type Response_Type int32

Each of the responses of type `FOO` corresponds to `Foo` message below.

const (
	Response_UNKNOWN Response_Type = 0
	// DEPRECATED.
	//
	// See 'ReconcileOperations' below.
	Response_RECONCILE_OPERATIONS Response_Type = 1
)

func (Response_Type) Enum

func (x Response_Type) Enum() *Response_Type

func (Response_Type) EnumDescriptor

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

func (Response_Type) MarshalJSON

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

func (Response_Type) String

func (x Response_Type) String() string

func (*Response_Type) UnmarshalJSON

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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