add more infos to events

This commit is contained in:
Victor Vieux 2014-11-21 22:37:43 +00:00
parent 8635f0fb4d
commit f502698aed
3 changed files with 19 additions and 2 deletions

View File

@ -17,7 +17,16 @@ type eventsHandler struct {
func (eh *eventsHandler) Handle(e *cluster.Event) error {
eh.RLock()
str := fmt.Sprintf("{%q:%q,%q:%q,%q:%q,%q:%d}", "status", e.Status, "id", e.Id, "from", e.From+" node:"+e.NodeName, "time", e.Time)
str := fmt.Sprintf("{%q:%q,%q:%q,%q:%q,%q:%d,%q:%q,%q:%q,%q:%q,%q:%q}",
"status", e.Status,
"id", e.Id,
"from", e.From+" node:"+e.NodeName,
"time", e.Time,
"node_name", e.NodeName,
"node_id", e.NodeID,
"node_addr", e.NodeAddr,
"node_ip", e.NodeIP)
for key, w := range eh.ws {
if _, err := fmt.Fprintf(w, str); err != nil {

View File

@ -6,6 +6,9 @@ type Event struct {
dockerclient.Event
NodeName string
NodeID string
NodeAddr string
NodeIP string
}
type EventHandler interface {

View File

@ -340,7 +340,12 @@ func (n *Node) handler(ev *dockerclient.Event, args ...interface{}) {
return
}
event := &Event{NodeName: n.Name}
event := &Event{
NodeName: n.Name,
NodeID: n.ID,
NodeAddr: n.Addr,
NodeIP: n.IP,
}
event.Event = *ev
n.eventHandler.Handle(event)