1
0
mirror of https://shylinux.com/x/icebergs synced 2025-06-28 03:02:59 +08:00
This commit is contained in:
IT 老营长 @云轩领航-创始人 2024-02-24 14:39:10 +08:00
parent 8f916dca23
commit 5fd5cbf774

View File

@ -503,7 +503,7 @@ func DreamEach(m *ice.Message, name string, status string, cb func(string)) *ice
return m return m
} }
msg := m.Spawn() msg := m.Spawn()
m.Cmds(DREAM).Table(func(value ice.Maps) { m.Cmds(DREAM, kit.Dict("dream.simple", ice.TRUE)).Table(func(value ice.Maps) {
if value[mdb.STATUS] == kit.Select(cli.START, status) && value[mdb.TYPE] == WORKER && (value[mdb.NAME] == name || reg.MatchString(kit.Format("%s:%s=%s@%d", value[mdb.NAME], value[mdb.TYPE], value[nfs.MODULE], value[nfs.VERSION]))) { if value[mdb.STATUS] == kit.Select(cli.START, status) && value[mdb.TYPE] == WORKER && (value[mdb.NAME] == name || reg.MatchString(kit.Format("%s:%s=%s@%d", value[mdb.NAME], value[mdb.TYPE], value[nfs.MODULE], value[nfs.VERSION]))) {
msg.Push(mdb.NAME, value[mdb.NAME]) msg.Push(mdb.NAME, value[mdb.NAME])
} }