change event channel name

This commit is contained in:
曾庆国 2019-08-24 15:30:59 +08:00
parent 00eb6ad1d9
commit 69e0fe2aa0
2 changed files with 5 additions and 2 deletions

View File

@ -385,7 +385,10 @@ func (e *exectorManager) sendAction(tenantID, serviceID, eventID, newVersion, ac
ServiceID: serviceID,
StartTime: time.Now().Format(time.RFC3339),
OptType: "upgrade",
Status: "running",
Target: "service",
TargetID: serviceID,
UserName: "system",
SynType: 1,
}
if err := db.GetManager().ServiceEventDao().AddModel(event); err != nil {
logrus.Errorf("create upgrade event failure %s, service %s do not auto upgrade", err.Error(), serviceID)

View File

@ -155,7 +155,7 @@ func (p *PubContext) handleSubscribe(wm WebsocketMessage) {
p.createChan(channel, "newmonitor", channelInfo[1])
}
if channelInfo[0] == "e" {
p.createChan(channel, "newmonitor", channelInfo[1])
p.createChan(channel, "event", channelInfo[1])
}
}
}