executor

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 executor is a generated protocol buffer package.

It is generated from these files: 

executor/executor.proto

It has these top-level messages: 

Event
Call

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthExecutor = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowExecutor   = fmt.Errorf("proto: integer overflow")
)
View Source 
var Call_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "SUBSCRIBE",
	2: "UPDATE",
	3: "MESSAGE",
	4: "HEARTBEAT",
}
View Source 
var Call_Type_value = map[string]int32{
	"UNKNOWN":   0,
	"SUBSCRIBE": 1,
	"UPDATE":    2,
	"MESSAGE":   3,
	"HEARTBEAT": 4,
}
View Source 
var Event_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "SUBSCRIBED",
	2: "LAUNCH",
	8: "LAUNCH_GROUP",
	3: "KILL",
	4: "ACKNOWLEDGED",
	5: "MESSAGE",
	6: "ERROR",
	7: "SHUTDOWN",
	9: "HEARTBEAT",
}
View Source 
var Event_Type_value = map[string]int32{
	"UNKNOWN":      0,
	"SUBSCRIBED":   1,
	"LAUNCH":       2,
	"LAUNCH_GROUP": 8,
	"KILL":         3,
	"ACKNOWLEDGED": 4,
	"MESSAGE":      5,
	"ERROR":        6,
	"SHUTDOWN":     7,
	"HEARTBEAT":    9,
}

Functions

This section is empty.

Types

type Call 

type Call struct {
	// Identifies the executor which generated this call.
	ExecutorID  mesos.ExecutorID  `protobuf:"bytes,1,req,name=executor_id,json=executorId" json:"executor_id"`
	FrameworkID mesos.FrameworkID `protobuf:"bytes,2,req,name=framework_id,json=frameworkId" json:"framework_id"`
	// Type of the call, indicates which optional field below should be
	// present if that type has a nested message definition.
	// In case type is SUBSCRIBED, no message needs to be set.
	// See comments on `Event::Type` above on the reasoning behind this
	// field being optional.
	Type      Call_Type       `protobuf:"varint,3,opt,name=type,enum=mesos.executor.Call_Type" json:"type"`
	Subscribe *Call_Subscribe `protobuf:"bytes,4,opt,name=subscribe" json:"subscribe,omitempty"`
	Update    *Call_Update    `protobuf:"bytes,5,opt,name=update" json:"update,omitempty"`
	Message   *Call_Message   `protobuf:"bytes,6,opt,name=message" json:"message,omitempty"`
}

* Executor call API.

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

func NewPopulatedCall 

func NewPopulatedCall(r randyExecutor, easy bool) *Call

func (*Call) Descriptor 

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

func (*Call) Equal 

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

func (*Call) GetExecutorID 

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

func (*Call) GetFrameworkID 

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

func (*Call) GetMessage 

func (m *Call) GetMessage() *Call_Message

func (*Call) GetSubscribe 

func (m *Call) GetSubscribe() *Call_Subscribe

func (*Call) GetType 

func (m *Call) GetType() Call_Type

func (*Call) GetUpdate 

func (m *Call) GetUpdate() *Call_Update

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_Message 

type Call_Message struct {
	Data []byte `protobuf:"bytes,2,req,name=data" json:"data,omitempty"`
}

Sends arbitrary binary data to the scheduler. Note that Mesos neither interprets this data nor makes any guarantees about the delivery of this message to the scheduler. See 'Message' in the 'Events' section.

func NewPopulatedCall_Message 

func NewPopulatedCall_Message(r randyExecutor, 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) GetData 

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

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_Subscribe 

type Call_Subscribe struct {
	UnacknowledgedTasks   []mesos.TaskInfo `protobuf:"bytes,1,rep,name=unacknowledged_tasks,json=unacknowledgedTasks" json:"unacknowledged_tasks"`
	UnacknowledgedUpdates []Call_Update    `protobuf:"bytes,2,rep,name=unacknowledged_updates,json=unacknowledgedUpdates" json:"unacknowledged_updates"`
}

Request to subscribe with the agent. If subscribing after a disconnection, it must include a list of all the tasks and updates which haven't been acknowledged by the scheduler.

func NewPopulatedCall_Subscribe 

func NewPopulatedCall_Subscribe(r randyExecutor, 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) GetUnacknowledgedTasks 

func (m *Call_Subscribe) GetUnacknowledgedTasks() []mesos.TaskInfo

func (*Call_Subscribe) GetUnacknowledgedUpdates 

func (m *Call_Subscribe) GetUnacknowledgedUpdates() []Call_Update

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_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_UPDATE    Call_Type = 2
	Call_MESSAGE   Call_Type = 3
	// Optional message that can be used to make sure the executor's
	// connection is still alive and to prevent any possible network
	// intermediaries from marking the connection as stale (when there
	// are no other messages being sent). Heartbeats are only necessary
	// if the executor uses a persistent connection to send calls.
	Call_HEARTBEAT Call_Type = 4
)

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_Update 

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

Notifies the scheduler that a task has transitioned from one state to another. 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 to the scheduler as soon as the task terminates, in order for Mesos to release the resources allocated to the task. It is the responsibility of the scheduler to explicitly acknowledge the receipt of a status update. See 'Acknowledged' in the 'Events' section above for the semantics.

func NewPopulatedCall_Update 

func NewPopulatedCall_Update(r randyExecutor, easy bool) *Call_Update

func (*Call_Update) Descriptor 

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

func (*Call_Update) Equal 

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

func (*Call_Update) GetStatus 

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

func (*Call_Update) GoString 

func (this *Call_Update) GoString() string

func (*Call_Update) Marshal 

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

func (*Call_Update) MarshalJSON 

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

func (*Call_Update) MarshalJSONBuf 

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

func (*Call_Update) MarshalTo 

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

func (*Call_Update) ProtoMessage 

func (*Call_Update) ProtoMessage()

func (*Call_Update) Reset 

func (m *Call_Update) Reset()

func (*Call_Update) Size 

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

func (*Call_Update) String 

func (this *Call_Update) String() string

func (*Call_Update) Unmarshal 

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

func (*Call_Update) UnmarshalJSON 

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

func (*Call_Update) UnmarshalJSONFFLexer 

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

func (*Call_Update) VerboseEqual 

func (this *Call_Update) 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.executor.Event_Type" json:"type"`
	Subscribed   *Event_Subscribed   `protobuf:"bytes,2,opt,name=subscribed" json:"subscribed,omitempty"`
	Acknowledged *Event_Acknowledged `protobuf:"bytes,3,opt,name=acknowledged" json:"acknowledged,omitempty"`
	Launch       *Event_Launch       `protobuf:"bytes,4,opt,name=launch" json:"launch,omitempty"`
	LaunchGroup  *Event_LaunchGroup  `protobuf:"bytes,8,opt,name=launch_group,json=launchGroup" json:"launch_group,omitempty"`
	Kill         *Event_Kill         `protobuf:"bytes,5,opt,name=kill" json:"kill,omitempty"`
	Message      *Event_Message      `protobuf:"bytes,6,opt,name=message" json:"message,omitempty"`
	Error        *Event_Error        `protobuf:"bytes,7,opt,name=error" json:"error,omitempty"`
}

* Executor 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 randyExecutor, easy bool) *Event

func (*Event) Descriptor 

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

func (*Event) Equal 

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

func (*Event) GetAcknowledged 

func (m *Event) GetAcknowledged() *Event_Acknowledged

func (*Event) GetError 

func (m *Event) GetError() *Event_Error

func (*Event) GetKill 

func (m *Event) GetKill() *Event_Kill

func (*Event) GetLaunch 

func (m *Event) GetLaunch() *Event_Launch

func (*Event) GetLaunchGroup 

func (m *Event) GetLaunchGroup() *Event_LaunchGroup

func (*Event) GetMessage 

func (m *Event) GetMessage() *Event_Message

func (*Event) GetSubscribed 

func (m *Event) GetSubscribed() *Event_Subscribed

func (*Event) GetType 

func (m *Event) GetType() Event_Type

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_Acknowledged 

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

Received when the agent acknowledges the receipt of status update. Schedulers are responsible for explicitly acknowledging the receipt of status updates that have 'update.status().uuid()' field set. Unacknowledged updates can be retried by the executor. They should also be sent by the executor whenever it re-subscribes.

func NewPopulatedEvent_Acknowledged 

func NewPopulatedEvent_Acknowledged(r randyExecutor, easy bool) *Event_Acknowledged

func (*Event_Acknowledged) Descriptor 

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

func (*Event_Acknowledged) Equal 

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

func (*Event_Acknowledged) GetTaskID 

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

func (*Event_Acknowledged) GetUUID 

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

func (*Event_Acknowledged) GoString 

func (this *Event_Acknowledged) GoString() string

func (*Event_Acknowledged) Marshal 

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

func (*Event_Acknowledged) MarshalJSON 

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

func (*Event_Acknowledged) MarshalJSONBuf 

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

func (*Event_Acknowledged) MarshalTo 

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

func (*Event_Acknowledged) ProtoMessage 

func (*Event_Acknowledged) ProtoMessage()

func (*Event_Acknowledged) Reset 

func (m *Event_Acknowledged) Reset()

func (*Event_Acknowledged) Size 

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

func (*Event_Acknowledged) String 

func (this *Event_Acknowledged) String() string

func (*Event_Acknowledged) Unmarshal 

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

func (*Event_Acknowledged) UnmarshalJSON 

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

func (*Event_Acknowledged) UnmarshalJSONFFLexer 

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

func (*Event_Acknowledged) VerboseEqual 

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

type Event_Error 

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

Received in case the executor sends invalid calls (e.g., required values not set). TODO(arojas): Remove this once the old executor driver is no longer supported. With HTTP API all errors will be signaled via HTTP response codes.

func NewPopulatedEvent_Error 

func NewPopulatedEvent_Error(r randyExecutor, 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_Kill 

type Event_Kill struct {
	TaskID mesos.TaskID `protobuf:"bytes,1,req,name=task_id,json=taskId" json:"task_id"`
	// 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,2,opt,name=kill_policy,json=killPolicy" json:"kill_policy,omitempty"`
}

Received when the scheduler wants to kill a specific task. Once the task is terminated, the executor should send a TASK_KILLED (or TASK_FAILED) update. The terminal update is necessary so Mesos can release the resources associated with the task.

func NewPopulatedEvent_Kill 

func NewPopulatedEvent_Kill(r randyExecutor, easy bool) *Event_Kill

func (*Event_Kill) Descriptor 

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

func (*Event_Kill) Equal 

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

func (*Event_Kill) GetKillPolicy 

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

func (*Event_Kill) GetTaskID 

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

func (*Event_Kill) GoString 

func (this *Event_Kill) GoString() string

func (*Event_Kill) Marshal 

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

func (*Event_Kill) MarshalJSON 

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

func (*Event_Kill) MarshalJSONBuf 

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

func (*Event_Kill) MarshalTo 

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

func (*Event_Kill) ProtoMessage 

func (*Event_Kill) ProtoMessage()

func (*Event_Kill) Reset 

func (m *Event_Kill) Reset()

func (*Event_Kill) Size 

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

func (*Event_Kill) String 

func (this *Event_Kill) String() string

func (*Event_Kill) Unmarshal 

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

func (*Event_Kill) UnmarshalJSON 

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

func (*Event_Kill) UnmarshalJSONFFLexer 

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

func (*Event_Kill) VerboseEqual 

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

type Event_Launch 

type Event_Launch struct {
	Task mesos.TaskInfo `protobuf:"bytes,1,req,name=task" json:"task"`
}

Received when the framework attempts to launch a task. Once the task is successfully launched, the executor must respond with a TASK_RUNNING update (See TaskState in v1/mesos.proto).

func NewPopulatedEvent_Launch 

func NewPopulatedEvent_Launch(r randyExecutor, easy bool) *Event_Launch

func (*Event_Launch) Descriptor 

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

func (*Event_Launch) Equal 

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

func (*Event_Launch) GetTask 

func (m *Event_Launch) GetTask() mesos.TaskInfo

func (*Event_Launch) GoString 

func (this *Event_Launch) GoString() string

func (*Event_Launch) Marshal 

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

func (*Event_Launch) MarshalJSON 

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

func (*Event_Launch) MarshalJSONBuf 

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

func (*Event_Launch) MarshalTo 

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

func (*Event_Launch) ProtoMessage 

func (*Event_Launch) ProtoMessage()

func (*Event_Launch) Reset 

func (m *Event_Launch) Reset()

func (*Event_Launch) Size 

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

func (*Event_Launch) String 

func (this *Event_Launch) String() string

func (*Event_Launch) Unmarshal 

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

func (*Event_Launch) UnmarshalJSON 

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

func (*Event_Launch) UnmarshalJSONFFLexer 

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

func (*Event_Launch) VerboseEqual 

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

type Event_LaunchGroup 

type Event_LaunchGroup struct {
	TaskGroup mesos.TaskGroupInfo `protobuf:"bytes,1,req,name=task_group,json=taskGroup" json:"task_group"`
}

Received when the framework attempts to launch a group of tasks atomically. Similar to `Launch` above the executor must send TASK_RUNNING updates for tasks that are successfully launched.

func NewPopulatedEvent_LaunchGroup 

func NewPopulatedEvent_LaunchGroup(r randyExecutor, easy bool) *Event_LaunchGroup

func (*Event_LaunchGroup) Descriptor 

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

func (*Event_LaunchGroup) Equal 

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

func (*Event_LaunchGroup) GetTaskGroup 

func (m *Event_LaunchGroup) GetTaskGroup() mesos.TaskGroupInfo

func (*Event_LaunchGroup) GoString 

func (this *Event_LaunchGroup) GoString() string

func (*Event_LaunchGroup) Marshal 

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

func (*Event_LaunchGroup) MarshalJSON 

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

func (*Event_LaunchGroup) MarshalJSONBuf 

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

func (*Event_LaunchGroup) MarshalTo 

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

func (*Event_LaunchGroup) ProtoMessage 

func (*Event_LaunchGroup) ProtoMessage()

func (*Event_LaunchGroup) Reset 

func (m *Event_LaunchGroup) Reset()

func (*Event_LaunchGroup) Size 

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

func (*Event_LaunchGroup) String 

func (this *Event_LaunchGroup) String() string

func (*Event_LaunchGroup) Unmarshal 

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

func (*Event_LaunchGroup) UnmarshalJSON 

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

func (*Event_LaunchGroup) UnmarshalJSONFFLexer 

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

func (*Event_LaunchGroup) VerboseEqual 

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

type Event_Message 

type Event_Message struct {
	Data []byte `protobuf:"bytes,1,req,name=data" json:"data,omitempty"`
}

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

func NewPopulatedEvent_Message 

func NewPopulatedEvent_Message(r randyExecutor, 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) GetData 

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

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_Subscribed 

type Event_Subscribed struct {
	ExecutorInfo  mesos.ExecutorInfo  `protobuf:"bytes,1,req,name=executor_info,json=executorInfo" json:"executor_info"`
	FrameworkInfo mesos.FrameworkInfo `protobuf:"bytes,2,req,name=framework_info,json=frameworkInfo" json:"framework_info"`
	AgentInfo     mesos.AgentInfo     `protobuf:"bytes,3,req,name=agent_info,json=agentInfo" json:"agent_info"`
	// Uniquely identifies the container of an executor run.
	ContainerID *mesos.ContainerID `protobuf:"bytes,4,opt,name=container_id,json=containerId" json:"container_id,omitempty"`
}

First event received when the executor subscribes. The 'id' field in the 'framework_info' will be set.

func NewPopulatedEvent_Subscribed 

func NewPopulatedEvent_Subscribed(r randyExecutor, 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) GetAgentInfo 

func (m *Event_Subscribed) GetAgentInfo() mesos.AgentInfo

func (*Event_Subscribed) GetContainerID 

func (m *Event_Subscribed) GetContainerID() *mesos.ContainerID

func (*Event_Subscribed) GetExecutorInfo 

func (m *Event_Subscribed) GetExecutorInfo() mesos.ExecutorInfo

func (*Event_Subscribed) GetFrameworkInfo 

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

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_LAUNCH       Event_Type = 2
	Event_LAUNCH_GROUP Event_Type = 8
	Event_KILL         Event_Type = 3
	Event_ACKNOWLEDGED Event_Type = 4
	Event_MESSAGE      Event_Type = 5
	Event_ERROR        Event_Type = 6
	// Received when the agent asks the executor to shutdown/kill itself.
	// The executor is then required to kill all its active tasks, send
	// `TASK_KILLED` status updates and gracefully exit. The executor
	// should terminate within a `MESOS_EXECUTOR_SHUTDOWN_GRACE_PERIOD`
	// (an environment variable set by the agent upon executor startup);
	// it can be configured via `ExecutorInfo.shutdown_grace_period`. If
	// the executor fails to do so, the agent will forcefully destroy the
	// container where the executor is running. The agent would then send
	// `TASK_LOST` updates for any remaining active tasks of this executor.
	//
	// NOTE: The executor must not assume that it will always be allotted
	// the full grace period, as the agent may decide to allot a shorter
	// period and failures / forcible terminations may occur.
	//
	// TODO(alexr): Consider adding a duration field into the `Shutdown`
	// message so that the agent can communicate when a shorter period
	// has been allotted.
	Event_SHUTDOWN Event_Type = 7
	// Received periodically to make sure the connection is alive and to
	// prevent any possible network intermediaries from marking the
	// connection as stale (when there are no other messages being sent).
	Event_HEARTBEAT Event_Type = 9
)

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.