diff --git a/modules/mesh-recovery/cmd/mesh-recovery/dump.go b/modules/mesh-recovery/cmd/mesh-recovery/dump.go index 457900181..3bb8d4a92 100644 --- a/modules/mesh-recovery/cmd/mesh-recovery/dump.go +++ b/modules/mesh-recovery/cmd/mesh-recovery/dump.go @@ -18,11 +18,11 @@ import ( // The seat node-backup's item events (design 47 G §554, §563), each kept last per subject on a stream of its own. const ( - backupSeat = "node-backup" - itemStarted = "item-started" - itemEnded = "item-ended" + backupSeat = "node-backup" + itemStarted = "item-started" + itemEnded = "item-ended" itemStartedStream = "SEAT_node-backup_item-started" - itemEndedStream = "SEAT_node-backup_item-ended" + itemEndedStream = "SEAT_node-backup_item-ended" ) func itemSubject(event, node, module, item string) string { diff --git a/modules/mesh-recovery/cmd/mesh-recovery/whole_integration_test.go b/modules/mesh-recovery/cmd/mesh-recovery/whole_integration_test.go index 5811d048a..1ca0f260b 100644 --- a/modules/mesh-recovery/cmd/mesh-recovery/whole_integration_test.go +++ b/modules/mesh-recovery/cmd/mesh-recovery/whole_integration_test.go @@ -91,7 +91,7 @@ func TestRecoveryWhole(t *testing.T) { } for stream, subject := range map[string]string{ nodeengine.StreamRunning: "mesh.seat.node-engine.event.running.>", - itemStartedStream: "mesh.seat.node-backup.event.item-started.>", + itemStartedStream: "mesh.seat.node-backup.event.item-started.>", itemEndedStream: "mesh.seat.node-backup.event.item-ended.>", meshbroker.StreamSnapshotRestored: "mesh.seat.mesh-broker.event.snapshot-restored.>", } {