diff options
| author | EuAndreh <eu@euandre.org> | 2025-05-03 19:50:33 -0300 |
|---|---|---|
| committer | EuAndreh <eu@euandre.org> | 2025-05-03 19:50:33 -0300 |
| commit | 7bf98f14cf2fa74c3591ce7b2b32c4e3c9263c3b (patch) | |
| tree | 494f86b809ec0d6d69148c7422ea2930c4d437e5 /tests/functional/new-instance-takeover/fiinha.go | |
| parent | src/fiinha.go: os.Exit(rc) instead of ignoring rc (diff) | |
| download | fiinha-7bf98f14cf2fa74c3591ce7b2b32c4e3c9263c3b.tar.gz fiinha-7bf98f14cf2fa74c3591ce7b2b32c4e3c9263c3b.tar.xz | |
re s/guuid/uuid/g
Diffstat (limited to 'tests/functional/new-instance-takeover/fiinha.go')
| -rw-r--r-- | tests/functional/new-instance-takeover/fiinha.go | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/tests/functional/new-instance-takeover/fiinha.go b/tests/functional/new-instance-takeover/fiinha.go index 5fdb9b4..5e6ad4b 100644 --- a/tests/functional/new-instance-takeover/fiinha.go +++ b/tests/functional/new-instance-takeover/fiinha.go @@ -4,7 +4,7 @@ import ( "runtime" "os" - "guuid" + "uuid" g "gobang" ) @@ -14,7 +14,7 @@ const topic = "topic" -func pub(queue IQueue, topic string, flowID guuid.UUID) { +func pub(queue IQueue, topic string, flowID uuid.UUID) { unsent := UnsentMessage{ Topic: topic, FlowID: flowID, @@ -24,7 +24,7 @@ func pub(queue IQueue, topic string, flowID guuid.UUID) { g.TErrorIf(err) } -func handlerFn(publish func(guuid.UUID)) func(Message) error { +func handlerFn(publish func(uuid.UUID)) func(Message) error { return func(message Message) error { publish(message.FlowID) return nil @@ -49,8 +49,8 @@ func startInstance( queue.queries = queries - pub_ := func(topic string) func(guuid.UUID) { - return func(flowID guuid.UUID) { + pub_ := func(topic string) func(uuid.UUID) { + return func(flowID uuid.UUID) { pub(queue, topic, flowID) } } @@ -76,16 +76,16 @@ func MainTest() { instanceID1 := os.Getpid() instanceID2 := instanceID1 + 1 - flowID1 := guuid.New() - flowID2 := guuid.New() + flowID1 := uuid.New() + flowID2 := uuid.New() g.Testing("new instances take ownership of topic+name combo", func() { q1, err := startInstance(dbpath, instanceID1, "first") g.TErrorIf(err) defer q1.Close() - pub(q1, topic, guuid.New()) - pub(q1, topic, guuid.New()) + pub(q1, topic, uuid.New()) + pub(q1, topic, uuid.New()) pub(q1, topic, flowID1) <- q1.WaitFor("individual-first", flowID1, "w").Channel @@ -97,8 +97,8 @@ func MainTest() { <- q2.WaitFor("individual-second", flowID1, "w").Channel - pub(q2, topic, guuid.New()) - pub(q2, topic, guuid.New()) + pub(q2, topic, uuid.New()) + pub(q2, topic, uuid.New()) pub(q2, topic, flowID2) // FIXME: notify multiple instances so we can add this: |
