executor

package

Go to main page

Versions in this module

v0

v0.0.11

May 15, 2020

v0.0.10

Jul 3, 2019

Changes in this version

type Call_Type

+ const Call_HEARTBEAT

type Event_Type

+ const Event_HEARTBEAT

v0.0.9

Mar 15, 2019

v0.0.8

Jul 26, 2018

v0.0.7

Jul 24, 2018

v0.0.6

Mar 12, 2018

v0.0.5

Sep 19, 2017

v0.0.4

Sep 13, 2017

Changes in this version

type Call

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

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

type Call_Message

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

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

type Call_Subscribe

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

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

type Call_Type

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

type Call_Update

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

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

type Event

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

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

type Event_Acknowledged

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

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

type Event_Error

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

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

type Event_Kill

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

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

type Event_Launch

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

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

type Event_LaunchGroup

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

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

type Event_Message

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

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

type Event_Subscribed

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

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

type Event_Type

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

v0.0.3

Jun 19, 2017

Changes in this version

+ var Call_Type_name = map[int32]string

+ var Call_Type_value = map[string]int32

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

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

+ var Event_Type_name = map[int32]string

+ var Event_Type_value = map[string]int32

+ type Call struct

+ ExecutorID mesos.ExecutorID

+ FrameworkID mesos.FrameworkID

+ Message *Call_Message

+ Subscribe *Call_Subscribe

+ Type *Call_Type

+ Update *Call_Update

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

+ func (*Call) ProtoMessage()

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

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

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

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

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

+ func (m *Call) GetType() Call_Type

+ func (m *Call) GetUpdate() *Call_Update

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

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

+ func (m *Call) Reset()

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

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

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

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

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

+ func (this *Call) GoString() string

+ func (this *Call) String() string

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

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

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

+ type CallOpt func(*Call)

+ type CallOptions []CallOpt

+ func (co CallOptions) Copy() CallOptions

+ type Call_Message struct

+ Data []byte

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

+ func (*Call_Message) ProtoMessage()

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

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

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

+ func (m *Call_Message) Reset()

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

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

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

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

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

+ func (this *Call_Message) GoString() string

+ func (this *Call_Message) String() string

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

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

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

+ type Call_Subscribe struct

+ UnacknowledgedTasks []mesos.TaskInfo

+ UnacknowledgedUpdates []Call_Update

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

+ func (*Call_Subscribe) ProtoMessage()

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

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

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

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

+ func (m *Call_Subscribe) Reset()

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

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

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

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

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

+ func (this *Call_Subscribe) GoString() string

+ func (this *Call_Subscribe) String() string

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

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

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

+ type Call_Type int32

+ const Call_MESSAGE

+ const Call_SUBSCRIBE

+ const Call_UNKNOWN

+ const Call_UPDATE

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

+ func (x Call_Type) Enum() *Call_Type

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

+ func (x Call_Type) String() string

+ type Call_Update struct

+ Status mesos.TaskStatus

+ func NewPopulatedCall_Update(r randyExecutor, easy bool) *Call_Update

+ func (*Call_Update) ProtoMessage()

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

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

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

+ func (m *Call_Update) Reset()

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

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

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

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

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

+ func (this *Call_Update) GoString() string

+ func (this *Call_Update) String() string

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

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

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

+ type Event struct

+ Acknowledged *Event_Acknowledged

+ Error *Event_Error

+ Kill *Event_Kill

+ Launch *Event_Launch

+ LaunchGroup *Event_LaunchGroup

+ Message *Event_Message

+ Subscribed *Event_Subscribed

+ Type *Event_Type

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

+ func (*Event) ProtoMessage()

+ func (m *Event) GetAcknowledged() *Event_Acknowledged

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

+ func (m *Event) GetKill() *Event_Kill

+ func (m *Event) GetLaunch() *Event_Launch

+ func (m *Event) GetLaunchGroup() *Event_LaunchGroup

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

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

+ func (m *Event) GetType() Event_Type

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

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

+ func (m *Event) Reset()

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

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

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

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

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

+ func (this *Event) GoString() string

+ func (this *Event) String() string

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

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

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

+ type Event_Acknowledged struct

+ TaskID mesos.TaskID

+ UUID []byte

+ func NewPopulatedEvent_Acknowledged(r randyExecutor, easy bool) *Event_Acknowledged

+ func (*Event_Acknowledged) ProtoMessage()

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

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

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

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

+ func (m *Event_Acknowledged) Reset()

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

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

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

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

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

+ func (this *Event_Acknowledged) GoString() string

+ func (this *Event_Acknowledged) String() string

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

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

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

+ type Event_Error struct

+ Message string

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

+ func (*Event_Error) ProtoMessage()

+ func (m *Event_Error) GetMessage() string

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

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

+ func (m *Event_Error) Reset()

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

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

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

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

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

+ func (this *Event_Error) GoString() string

+ func (this *Event_Error) String() string

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

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

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

+ type Event_Kill struct

+ KillPolicy *mesos.KillPolicy

+ TaskID mesos.TaskID

+ func NewPopulatedEvent_Kill(r randyExecutor, easy bool) *Event_Kill

+ func (*Event_Kill) ProtoMessage()

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

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

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

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

+ func (m *Event_Kill) Reset()

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

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

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

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

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

+ func (this *Event_Kill) GoString() string

+ func (this *Event_Kill) String() string

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

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

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

+ type Event_Launch struct

+ Task mesos.TaskInfo

+ func NewPopulatedEvent_Launch(r randyExecutor, easy bool) *Event_Launch

+ func (*Event_Launch) ProtoMessage()

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

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

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

+ func (m *Event_Launch) Reset()

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

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

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

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

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

+ func (this *Event_Launch) GoString() string

+ func (this *Event_Launch) String() string

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

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

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

+ type Event_LaunchGroup struct

+ TaskGroup mesos.TaskGroupInfo

+ func NewPopulatedEvent_LaunchGroup(r randyExecutor, easy bool) *Event_LaunchGroup

+ func (*Event_LaunchGroup) ProtoMessage()

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

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

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

+ func (m *Event_LaunchGroup) Reset()

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

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

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

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

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

+ func (this *Event_LaunchGroup) GoString() string

+ func (this *Event_LaunchGroup) String() string

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

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

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

+ type Event_Message struct

+ Data []byte

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

+ func (*Event_Message) ProtoMessage()

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

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

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

+ func (m *Event_Message) Reset()

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

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

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

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

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

+ func (this *Event_Message) GoString() string

+ func (this *Event_Message) String() string

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

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

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

+ type Event_Subscribed struct

+ AgentInfo mesos.AgentInfo

+ ContainerID *mesos.ContainerID

+ ExecutorInfo mesos.ExecutorInfo

+ FrameworkInfo mesos.FrameworkInfo

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

+ func (*Event_Subscribed) ProtoMessage()

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

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

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

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

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

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

+ func (m *Event_Subscribed) Reset()

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

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

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

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

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

+ func (this *Event_Subscribed) GoString() string

+ func (this *Event_Subscribed) String() string

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

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

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

+ type Event_Type int32

+ const Event_ACKNOWLEDGED

+ const Event_ERROR

+ const Event_KILL

+ const Event_LAUNCH

+ const Event_LAUNCH_GROUP

+ const Event_MESSAGE

+ const Event_SHUTDOWN

+ const Event_SUBSCRIBED

+ const Event_UNKNOWN

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

+ func (x Event_Type) Enum() *Event_Type

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

+ func (x Event_Type) String() string

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