events
2015-12-14
Parent:2d030022b4b5
events/model.go
Update to new nsqio repo. The go-nsq client is now located under a nsqio org on Github, so we need to update the import path.
1 package events
3 import (
4 "log"
5 "time"
6 )
8 type Model interface {
9 GetModelName() string
10 GetID() string
11 GetSystem() string
12 }
14 func PublishModelEvent(p Publisher, m Model, action string) error {
15 evt := Event{
16 System: m.GetSystem(),
17 Model: m.GetModelName(),
18 ID: m.GetID(),
19 Action: action,
20 Data: m,
21 Timestamp: time.Now(),
22 }
23 err := p.Publish(evt.Model, evt)
24 if err != nil {
25 log.Printf("Error sending event: %#+v\n", err)
26 }
27 return err
28 }