event

Documentation

Index

• type DeviceEvent
  • func NewDeviceEvent(origin DeviceEventOrigin, t pb.DeviceEventType) (de DeviceEvent)
• type DeviceEventBase
  • func (b *DeviceEventBase) GetOrigin() DeviceEventOrigin
  • func (b *DeviceEventBase) GetType() pb.DeviceEventType
• type DeviceEventOrigin
• type EndOfData
  • func (e *EndOfData) GetName() string

Types

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 EndOfData

type EndOfData struct {
	DeviceEventBase
}

func (*EndOfData) GetName

func (e *EndOfData) GetName() string