aboutsummaryrefslogtreecommitdiff
path: root/tests/functional/new-instance-takeover/fiinha.go
diff options
context:
space:
mode:
authorEuAndreh <eu@euandre.org>2025-05-03 19:50:33 -0300
committerEuAndreh <eu@euandre.org>2025-05-03 19:50:33 -0300
commit7bf98f14cf2fa74c3591ce7b2b32c4e3c9263c3b (patch)
tree494f86b809ec0d6d69148c7422ea2930c4d437e5 /tests/functional/new-instance-takeover/fiinha.go
parentsrc/fiinha.go: os.Exit(rc) instead of ignoring rc (diff)
downloadfiinha-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.go22
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: