event

package
v0.15.0 Latest Latest
Warning

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

Go to latest
Published: Jul 27, 2020 License: GPL-3.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BasicTaskTerminated added in v0.12.0

type BasicTaskTerminated struct {
	DeviceEventBase
	ExitCode             int             `json:"exitCode"`
	Stdout               string          `json:"stdout"`
	Stderr               string          `json:"stderr"`
	VoluntaryTermination bool            `json:"voluntaryTermination"`
	FinalMesosState      mesos.TaskState `json:"finalMesosState"`
}

func (*BasicTaskTerminated) GetName added in v0.12.0

func (e *BasicTaskTerminated) GetName() string

type DeviceEvent

type DeviceEvent interface {
	GetName() string
	GetOrigin() DeviceEventOrigin
	GetType() pb.DeviceEventType
}

func NewDeviceEvent

func NewDeviceEvent(origin DeviceEventOrigin, t pb.DeviceEventType) (de DeviceEvent)

type DeviceEventBase

type DeviceEventBase struct {
	Type        pb.DeviceEventType `json:"type"`
	Origin      DeviceEventOrigin  `json:"origin"`
	MessageType string             `json:"_messageType"`
}

func (*DeviceEventBase) GetOrigin

func (b *DeviceEventBase) GetOrigin() DeviceEventOrigin

func (*DeviceEventBase) GetType

func (b *DeviceEventBase) GetType() pb.DeviceEventType

type DeviceEventOrigin

type DeviceEventOrigin struct {
	AgentId    mesos.AgentID    `json:"agentId"`
	ExecutorId mesos.ExecutorID `json:"executorId"`
	TaskId     mesos.TaskID     `json:"taskId"`
}

type EndOfStream added in v0.12.0

type EndOfStream struct {
	DeviceEventBase
}

func (*EndOfStream) GetName added in v0.12.0

func (e *EndOfStream) GetName() string

type TaskMessage added in v0.14.91

type TaskMessage interface {
	GetName() string
	GetTaskId() string
	GetTaskPID() int
}

func NewTaskMessage added in v0.14.91

func NewTaskMessage(name, id string, pid int32) (tm TaskMessage)

type TaskMessageBase added in v0.14.91

type TaskMessageBase struct {
	Name        string `json:"name"`
	TaskId      string `json:"taskId"`
	PID         int32  `json:"pid"`
	MessageType string `json:"_messageType"`
}

func (*TaskMessageBase) GetName added in v0.14.91

func (tmb *TaskMessageBase) GetName() string

func (*TaskMessageBase) GetTaskId added in v0.14.91

func (tmb *TaskMessageBase) GetTaskId() string

func (*TaskMessageBase) GetTaskPID added in v0.14.91

func (tmb *TaskMessageBase) GetTaskPID() int

Jump to

Keyboard shortcuts

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