BKP4 (recovery side): gofmt the recovery module after the rename
Builds: design 47 G §556
This commit is contained in:
@@ -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 {
|
||||
|
||||
@@ -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.>",
|
||||
} {
|
||||
|
||||
Reference in New Issue
Block a user