event

type AnnounceTaskPIDEvent struct {
	TaskId string `json:"taskId"`
	PID    int32  `json:"pid"`
	// contains filtered or unexported fields
}

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"`
}

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

type DeviceEventBase struct {
	Type   pb.DeviceEventType `json:"type"`
	Origin DeviceEventOrigin  `json:"origin"`
	// contains filtered or unexported fields
}

type DeviceEventOrigin struct {
	// FIXME: replace these Mesos-tainted string wrappers with plain strings
	AgentId    mesos.AgentID    `json:"agentId"`
	ExecutorId mesos.ExecutorID `json:"executorId"`
	TaskId     mesos.TaskID     `json:"taskId"`
}

type EndOfStream struct {
	DeviceEventBase
}

type Event interface {
	GetName() string
	GetTimestamp() string
}

type TasksReleasedEvent struct {
	EnvironmentId     uid.ID           `json:"environmentId"`
	TaskIdsReleased   []string         `json:"taskIdsReleased"`
	TaskReleaseErrors map[string]error `json:"taskReleaseErrors"`
	// contains filtered or unexported fields
}

type TasksStateChangedEvent struct {
	EnvironmentId       uid.ID   `json:"environmentId"`
	TaskIdsStateChanged []string `json:"taskIdsStatesChanged"`
	TaskStateChangedErr error    `json:"taskStateChangedErr"`
	// contains filtered or unexported fields
}