Documentation ¶ Index ¶ func NewJob(job *types.Job) error func Push(pid, id string, ctx map[string]interface{}) func StartJobs() error func StopJobs() func SubscribeProperty(client mqtt.Client) type Device func (d *Device) Push(ctx map[string]interface{}) type Job func (j *Job) Push(id string, ctx map[string]interface{}) Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ func NewJob ¶ func NewJob(job *types.Job) error func Push ¶ func Push(pid, id string, ctx map[string]interface{}) func StartJobs ¶ func StartJobs() error func StopJobs ¶ func StopJobs() func SubscribeProperty ¶ func SubscribeProperty(client mqtt.Client) Types ¶ type Device ¶ type Device struct { // contains filtered or unexported fields } func (*Device) Push ¶ func (d *Device) Push(ctx map[string]interface{}) type Job ¶ type Job struct { // contains filtered or unexported fields } func (*Job) Push ¶ func (j *Job) Push(id string, ctx map[string]interface{}) Source Files ¶ View all Source files job.go property.go Directories ¶ Show internal Expand all Path Synopsis aggregator Click to show internal directories. Click to hide internal directories.