diff options
Diffstat (limited to 'tests')
-rw-r--r-- | tests/benchmarks/deadletters/fiinha.go (renamed from tests/benchmarks/deadletters/q.go) | 2 | ||||
-rw-r--r-- | tests/benchmarks/lookup/fiinha.go (renamed from tests/benchmarks/lookup/q.go) | 2 | ||||
-rw-r--r-- | tests/benchmarks/multiple-consumers/fiinha.go (renamed from tests/benchmarks/multiple-consumers/q.go) | 2 | ||||
-rw-r--r-- | tests/benchmarks/multiple-produces/fiinha.go (renamed from tests/benchmarks/multiple-produces/q.go) | 2 | ||||
-rw-r--r-- | tests/benchmarks/reaper/fiinha.go | 24 | ||||
-rw-r--r-- | tests/benchmarks/reaper/q.go | 24 | ||||
-rw-r--r-- | tests/benchmarks/replay/fiinha.go | 24 | ||||
-rw-r--r-- | tests/benchmarks/replay/q.go | 24 | ||||
-rw-r--r-- | tests/benchmarks/single-consumer/fiinha.go | 24 | ||||
-rw-r--r-- | tests/benchmarks/single-consumer/q.go | 24 | ||||
-rw-r--r-- | tests/benchmarks/single-producer/fiinha.go | 24 | ||||
-rw-r--r-- | tests/benchmarks/single-producer/q.go | 24 | ||||
-rw-r--r-- | tests/benchmarks/subscribe/fiinha.go | 24 | ||||
-rw-r--r-- | tests/benchmarks/subscribe/q.go | 24 | ||||
-rw-r--r-- | tests/benchmarks/unsubscribe/fiinha.go | 24 | ||||
-rw-r--r-- | tests/benchmarks/unsubscribe/q.go | 24 | ||||
-rw-r--r-- | tests/benchmarks/waiter/fiinha.go | 24 | ||||
-rw-r--r-- | tests/benchmarks/waiter/q.go | 24 | ||||
-rw-r--r-- | tests/fiinha.go (renamed from tests/q.go) | 12 | ||||
-rw-r--r-- | tests/functional/consume-one-produce-many/fiinha.go (renamed from tests/functional/consume-one-produce-many/q.go) | 2 | ||||
-rw-r--r-- | tests/functional/consumer-with-deadletter/fiinha.go (renamed from tests/functional/consumer-with-deadletter/q.go) | 2 | ||||
-rw-r--r-- | tests/functional/custom-prefix/fiinha.go (renamed from tests/functional/custom-prefix/q.go) | 2 | ||||
-rw-r--r-- | tests/functional/distinct-consumers-separate-instances/fiinha.go (renamed from tests/functional/distinct-consumers-separate-instances/q.go) | 2 | ||||
-rw-r--r-- | tests/functional/flow-id/fiinha.go (renamed from tests/functional/flow-id/q.go) | 2 | ||||
-rw-r--r-- | tests/functional/idempotency/fiinha.go | 5 | ||||
-rw-r--r-- | tests/functional/idempotency/q.go | 5 | ||||
-rw-r--r-- | tests/functional/new-instance-takeover/fiinha.go (renamed from tests/functional/new-instance-takeover/q.go) | 2 | ||||
-rw-r--r-- | tests/functional/wait-after-publish/fiinha.go (renamed from tests/functional/wait-after-publish/q.go) | 2 | ||||
-rw-r--r-- | tests/functional/waiter/fiinha.go | 5 | ||||
-rw-r--r-- | tests/functional/waiter/q.go | 5 | ||||
-rw-r--r-- | tests/fuzz/api-check/fiinha.go (renamed from tests/fuzz/api-check/q.go) | 2 | ||||
-rw-r--r-- | tests/fuzz/cli-check/fiinha.go (renamed from tests/fuzz/queries-check/q.go) | 2 | ||||
-rw-r--r-- | tests/fuzz/equal-produced-consumed-order-check/fiinha.go (renamed from tests/fuzz/equal-produced-consumed-order-check/q.go) | 2 | ||||
-rw-r--r-- | tests/fuzz/exactly-once-check/fiinha.go (renamed from tests/fuzz/exactly-once-check/q.go) | 2 | ||||
-rw-r--r-- | tests/fuzz/queries-check/fiinha.go (renamed from tests/fuzz/cli-check/q.go) | 2 | ||||
-rw-r--r-- | tests/fuzz/total-order-check/fiinha.go (renamed from tests/fuzz/total-order-check/q.go) | 2 | ||||
-rw-r--r-- | tests/main.go | 4 | ||||
-rw-r--r-- | tests/queries.sql | 312 |
38 files changed, 359 insertions, 359 deletions
diff --git a/tests/benchmarks/deadletters/q.go b/tests/benchmarks/deadletters/fiinha.go index 0c203bb..9c0b641 100644 --- a/tests/benchmarks/deadletters/q.go +++ b/tests/benchmarks/deadletters/fiinha.go @@ -1,4 +1,4 @@ -package q +package fiinha import ( "flag" diff --git a/tests/benchmarks/lookup/q.go b/tests/benchmarks/lookup/fiinha.go index 0c203bb..9c0b641 100644 --- a/tests/benchmarks/lookup/q.go +++ b/tests/benchmarks/lookup/fiinha.go @@ -1,4 +1,4 @@ -package q +package fiinha import ( "flag" diff --git a/tests/benchmarks/multiple-consumers/q.go b/tests/benchmarks/multiple-consumers/fiinha.go index 0c203bb..9c0b641 100644 --- a/tests/benchmarks/multiple-consumers/q.go +++ b/tests/benchmarks/multiple-consumers/fiinha.go @@ -1,4 +1,4 @@ -package q +package fiinha import ( "flag" diff --git a/tests/benchmarks/multiple-produces/q.go b/tests/benchmarks/multiple-produces/fiinha.go index 0c203bb..9c0b641 100644 --- a/tests/benchmarks/multiple-produces/q.go +++ b/tests/benchmarks/multiple-produces/fiinha.go @@ -1,4 +1,4 @@ -package q +package fiinha import ( "flag" diff --git a/tests/benchmarks/reaper/fiinha.go b/tests/benchmarks/reaper/fiinha.go new file mode 100644 index 0000000..9c0b641 --- /dev/null +++ b/tests/benchmarks/reaper/fiinha.go @@ -0,0 +1,24 @@ +package fiinha + +import ( + "flag" + "time" +) + + + +var nFlag = flag.Int( + "n", + 1_000, + "The number of iterations to execute", +) + +func MainTest() { + // FIXME + flag.Parse() + n := *nFlag + + for i := 0; i < n; i++ { + time.Sleep(time.Millisecond * 1) + } +} diff --git a/tests/benchmarks/reaper/q.go b/tests/benchmarks/reaper/q.go deleted file mode 100644 index 0c203bb..0000000 --- a/tests/benchmarks/reaper/q.go +++ /dev/null @@ -1,24 +0,0 @@ -package q - -import ( - "flag" - "time" -) - - - -var nFlag = flag.Int( - "n", - 1_000, - "The number of iterations to execute", -) - -func MainTest() { - // FIXME - flag.Parse() - n := *nFlag - - for i := 0; i < n; i++ { - time.Sleep(time.Millisecond * 1) - } -} diff --git a/tests/benchmarks/replay/fiinha.go b/tests/benchmarks/replay/fiinha.go new file mode 100644 index 0000000..9c0b641 --- /dev/null +++ b/tests/benchmarks/replay/fiinha.go @@ -0,0 +1,24 @@ +package fiinha + +import ( + "flag" + "time" +) + + + +var nFlag = flag.Int( + "n", + 1_000, + "The number of iterations to execute", +) + +func MainTest() { + // FIXME + flag.Parse() + n := *nFlag + + for i := 0; i < n; i++ { + time.Sleep(time.Millisecond * 1) + } +} diff --git a/tests/benchmarks/replay/q.go b/tests/benchmarks/replay/q.go deleted file mode 100644 index 0c203bb..0000000 --- a/tests/benchmarks/replay/q.go +++ /dev/null @@ -1,24 +0,0 @@ -package q - -import ( - "flag" - "time" -) - - - -var nFlag = flag.Int( - "n", - 1_000, - "The number of iterations to execute", -) - -func MainTest() { - // FIXME - flag.Parse() - n := *nFlag - - for i := 0; i < n; i++ { - time.Sleep(time.Millisecond * 1) - } -} diff --git a/tests/benchmarks/single-consumer/fiinha.go b/tests/benchmarks/single-consumer/fiinha.go new file mode 100644 index 0000000..9c0b641 --- /dev/null +++ b/tests/benchmarks/single-consumer/fiinha.go @@ -0,0 +1,24 @@ +package fiinha + +import ( + "flag" + "time" +) + + + +var nFlag = flag.Int( + "n", + 1_000, + "The number of iterations to execute", +) + +func MainTest() { + // FIXME + flag.Parse() + n := *nFlag + + for i := 0; i < n; i++ { + time.Sleep(time.Millisecond * 1) + } +} diff --git a/tests/benchmarks/single-consumer/q.go b/tests/benchmarks/single-consumer/q.go deleted file mode 100644 index 0c203bb..0000000 --- a/tests/benchmarks/single-consumer/q.go +++ /dev/null @@ -1,24 +0,0 @@ -package q - -import ( - "flag" - "time" -) - - - -var nFlag = flag.Int( - "n", - 1_000, - "The number of iterations to execute", -) - -func MainTest() { - // FIXME - flag.Parse() - n := *nFlag - - for i := 0; i < n; i++ { - time.Sleep(time.Millisecond * 1) - } -} diff --git a/tests/benchmarks/single-producer/fiinha.go b/tests/benchmarks/single-producer/fiinha.go new file mode 100644 index 0000000..9c0b641 --- /dev/null +++ b/tests/benchmarks/single-producer/fiinha.go @@ -0,0 +1,24 @@ +package fiinha + +import ( + "flag" + "time" +) + + + +var nFlag = flag.Int( + "n", + 1_000, + "The number of iterations to execute", +) + +func MainTest() { + // FIXME + flag.Parse() + n := *nFlag + + for i := 0; i < n; i++ { + time.Sleep(time.Millisecond * 1) + } +} diff --git a/tests/benchmarks/single-producer/q.go b/tests/benchmarks/single-producer/q.go deleted file mode 100644 index 0c203bb..0000000 --- a/tests/benchmarks/single-producer/q.go +++ /dev/null @@ -1,24 +0,0 @@ -package q - -import ( - "flag" - "time" -) - - - -var nFlag = flag.Int( - "n", - 1_000, - "The number of iterations to execute", -) - -func MainTest() { - // FIXME - flag.Parse() - n := *nFlag - - for i := 0; i < n; i++ { - time.Sleep(time.Millisecond * 1) - } -} diff --git a/tests/benchmarks/subscribe/fiinha.go b/tests/benchmarks/subscribe/fiinha.go new file mode 100644 index 0000000..9c0b641 --- /dev/null +++ b/tests/benchmarks/subscribe/fiinha.go @@ -0,0 +1,24 @@ +package fiinha + +import ( + "flag" + "time" +) + + + +var nFlag = flag.Int( + "n", + 1_000, + "The number of iterations to execute", +) + +func MainTest() { + // FIXME + flag.Parse() + n := *nFlag + + for i := 0; i < n; i++ { + time.Sleep(time.Millisecond * 1) + } +} diff --git a/tests/benchmarks/subscribe/q.go b/tests/benchmarks/subscribe/q.go deleted file mode 100644 index 0c203bb..0000000 --- a/tests/benchmarks/subscribe/q.go +++ /dev/null @@ -1,24 +0,0 @@ -package q - -import ( - "flag" - "time" -) - - - -var nFlag = flag.Int( - "n", - 1_000, - "The number of iterations to execute", -) - -func MainTest() { - // FIXME - flag.Parse() - n := *nFlag - - for i := 0; i < n; i++ { - time.Sleep(time.Millisecond * 1) - } -} diff --git a/tests/benchmarks/unsubscribe/fiinha.go b/tests/benchmarks/unsubscribe/fiinha.go new file mode 100644 index 0000000..9c0b641 --- /dev/null +++ b/tests/benchmarks/unsubscribe/fiinha.go @@ -0,0 +1,24 @@ +package fiinha + +import ( + "flag" + "time" +) + + + +var nFlag = flag.Int( + "n", + 1_000, + "The number of iterations to execute", +) + +func MainTest() { + // FIXME + flag.Parse() + n := *nFlag + + for i := 0; i < n; i++ { + time.Sleep(time.Millisecond * 1) + } +} diff --git a/tests/benchmarks/unsubscribe/q.go b/tests/benchmarks/unsubscribe/q.go deleted file mode 100644 index 0c203bb..0000000 --- a/tests/benchmarks/unsubscribe/q.go +++ /dev/null @@ -1,24 +0,0 @@ -package q - -import ( - "flag" - "time" -) - - - -var nFlag = flag.Int( - "n", - 1_000, - "The number of iterations to execute", -) - -func MainTest() { - // FIXME - flag.Parse() - n := *nFlag - - for i := 0; i < n; i++ { - time.Sleep(time.Millisecond * 1) - } -} diff --git a/tests/benchmarks/waiter/fiinha.go b/tests/benchmarks/waiter/fiinha.go new file mode 100644 index 0000000..9c0b641 --- /dev/null +++ b/tests/benchmarks/waiter/fiinha.go @@ -0,0 +1,24 @@ +package fiinha + +import ( + "flag" + "time" +) + + + +var nFlag = flag.Int( + "n", + 1_000, + "The number of iterations to execute", +) + +func MainTest() { + // FIXME + flag.Parse() + n := *nFlag + + for i := 0; i < n; i++ { + time.Sleep(time.Millisecond * 1) + } +} diff --git a/tests/benchmarks/waiter/q.go b/tests/benchmarks/waiter/q.go deleted file mode 100644 index 0c203bb..0000000 --- a/tests/benchmarks/waiter/q.go +++ /dev/null @@ -1,24 +0,0 @@ -package q - -import ( - "flag" - "time" -) - - - -var nFlag = flag.Int( - "n", - 1_000, - "The number of iterations to execute", -) - -func MainTest() { - // FIXME - flag.Parse() - n := *nFlag - - for i := 0; i < n; i++ { - time.Sleep(time.Millisecond * 1) - } -} diff --git a/tests/q.go b/tests/fiinha.go index 565ca25..a6ae315 100644 --- a/tests/q.go +++ b/tests/fiinha.go @@ -1,4 +1,4 @@ -package q +package fiinha import ( "bytes" @@ -5635,8 +5635,8 @@ func test_getopt() { _, _, rc2 := getopt(argv2, commandsMap, &w2) args, command, rc3 := getopt(argv3, commandsMap, &w3) expectedArgs := argsT{ - databasePath: "q.db", - prefix: "q", + databasePath: "fiinha.db", + prefix: "fiinha", command: "bad", allArgs: argv3, args: argv3[2:], @@ -5662,8 +5662,8 @@ func test_getopt() { &w, ) expectedArgs := argsT{ - databasePath: "q.db", - prefix: "q", + databasePath: "fiinha.db", + prefix: "fiinha", command: "good", allArgs: []string{"$0", "good"}, args: []string{}, @@ -5699,7 +5699,7 @@ func test_getopt() { args, command, rc := getopt(argv, commandsMap, &w) expectedArgs := argsT{ databasePath: "F", - prefix: "q", + prefix: "fiinha", command: "good", allArgs: argv, args: []string{"-f", "-f", "SUB"}, diff --git a/tests/functional/consume-one-produce-many/q.go b/tests/functional/consume-one-produce-many/fiinha.go index 48d66d3..6a3ca47 100644 --- a/tests/functional/consume-one-produce-many/q.go +++ b/tests/functional/consume-one-produce-many/fiinha.go @@ -1,4 +1,4 @@ -package q +package fiinha func MainTest() { // FIXME diff --git a/tests/functional/consumer-with-deadletter/q.go b/tests/functional/consumer-with-deadletter/fiinha.go index a79ad5b..7d88e0e 100644 --- a/tests/functional/consumer-with-deadletter/q.go +++ b/tests/functional/consumer-with-deadletter/fiinha.go @@ -1,4 +1,4 @@ -package q +package fiinha import ( "errors" diff --git a/tests/functional/custom-prefix/q.go b/tests/functional/custom-prefix/fiinha.go index 48d66d3..6a3ca47 100644 --- a/tests/functional/custom-prefix/q.go +++ b/tests/functional/custom-prefix/fiinha.go @@ -1,4 +1,4 @@ -package q +package fiinha func MainTest() { // FIXME diff --git a/tests/functional/distinct-consumers-separate-instances/q.go b/tests/functional/distinct-consumers-separate-instances/fiinha.go index 48d66d3..6a3ca47 100644 --- a/tests/functional/distinct-consumers-separate-instances/q.go +++ b/tests/functional/distinct-consumers-separate-instances/fiinha.go @@ -1,4 +1,4 @@ -package q +package fiinha func MainTest() { // FIXME diff --git a/tests/functional/flow-id/q.go b/tests/functional/flow-id/fiinha.go index 48d66d3..6a3ca47 100644 --- a/tests/functional/flow-id/q.go +++ b/tests/functional/flow-id/fiinha.go @@ -1,4 +1,4 @@ -package q +package fiinha func MainTest() { // FIXME diff --git a/tests/functional/idempotency/fiinha.go b/tests/functional/idempotency/fiinha.go new file mode 100644 index 0000000..6a3ca47 --- /dev/null +++ b/tests/functional/idempotency/fiinha.go @@ -0,0 +1,5 @@ +package fiinha + +func MainTest() { + // FIXME +} diff --git a/tests/functional/idempotency/q.go b/tests/functional/idempotency/q.go deleted file mode 100644 index 48d66d3..0000000 --- a/tests/functional/idempotency/q.go +++ /dev/null @@ -1,5 +0,0 @@ -package q - -func MainTest() { - // FIXME -} diff --git a/tests/functional/new-instance-takeover/q.go b/tests/functional/new-instance-takeover/fiinha.go index 76ed59f..5fdb9b4 100644 --- a/tests/functional/new-instance-takeover/q.go +++ b/tests/functional/new-instance-takeover/fiinha.go @@ -1,4 +1,4 @@ -package q +package fiinha import ( "runtime" diff --git a/tests/functional/wait-after-publish/q.go b/tests/functional/wait-after-publish/fiinha.go index b70d27e..a60a57b 100644 --- a/tests/functional/wait-after-publish/q.go +++ b/tests/functional/wait-after-publish/fiinha.go @@ -1,4 +1,4 @@ -package q +package fiinha import ( "runtime" diff --git a/tests/functional/waiter/fiinha.go b/tests/functional/waiter/fiinha.go new file mode 100644 index 0000000..6a3ca47 --- /dev/null +++ b/tests/functional/waiter/fiinha.go @@ -0,0 +1,5 @@ +package fiinha + +func MainTest() { + // FIXME +} diff --git a/tests/functional/waiter/q.go b/tests/functional/waiter/q.go deleted file mode 100644 index 48d66d3..0000000 --- a/tests/functional/waiter/q.go +++ /dev/null @@ -1,5 +0,0 @@ -package q - -func MainTest() { - // FIXME -} diff --git a/tests/fuzz/api-check/q.go b/tests/fuzz/api-check/fiinha.go index f8b2ab4..86801de 100644 --- a/tests/fuzz/api-check/q.go +++ b/tests/fuzz/api-check/fiinha.go @@ -1,4 +1,4 @@ -package q +package fiinha import ( "os" diff --git a/tests/fuzz/queries-check/q.go b/tests/fuzz/cli-check/fiinha.go index 5c872e5..1cb6f37 100644 --- a/tests/fuzz/queries-check/q.go +++ b/tests/fuzz/cli-check/fiinha.go @@ -1,4 +1,4 @@ -package q +package fiinha import ( "os" diff --git a/tests/fuzz/equal-produced-consumed-order-check/q.go b/tests/fuzz/equal-produced-consumed-order-check/fiinha.go index 8b95aef..ef2e72a 100644 --- a/tests/fuzz/equal-produced-consumed-order-check/q.go +++ b/tests/fuzz/equal-produced-consumed-order-check/fiinha.go @@ -1,4 +1,4 @@ -package q +package fiinha import ( "os" diff --git a/tests/fuzz/exactly-once-check/q.go b/tests/fuzz/exactly-once-check/fiinha.go index d483ad8..6ac1fb1 100644 --- a/tests/fuzz/exactly-once-check/q.go +++ b/tests/fuzz/exactly-once-check/fiinha.go @@ -1,4 +1,4 @@ -package q +package fiinha import ( "os" diff --git a/tests/fuzz/cli-check/q.go b/tests/fuzz/queries-check/fiinha.go index 5c872e5..1cb6f37 100644 --- a/tests/fuzz/cli-check/q.go +++ b/tests/fuzz/queries-check/fiinha.go @@ -1,4 +1,4 @@ -package q +package fiinha import ( "os" diff --git a/tests/fuzz/total-order-check/q.go b/tests/fuzz/total-order-check/fiinha.go index 67af544..cb5aa61 100644 --- a/tests/fuzz/total-order-check/q.go +++ b/tests/fuzz/total-order-check/fiinha.go @@ -1,4 +1,4 @@ -package q +package fiinha import ( "os" diff --git a/tests/main.go b/tests/main.go index 893132e..789b267 100644 --- a/tests/main.go +++ b/tests/main.go @@ -1,7 +1,7 @@ package main -import "q" +import "fiinha" func main() { - q.MainTest() + fiinha.MainTest() } diff --git a/tests/queries.sql b/tests/queries.sql index e790d41..241f419 100644 --- a/tests/queries.sql +++ b/tests/queries.sql @@ -1,59 +1,59 @@ -- createTables.sql: -- write: - CREATE TABLE IF NOT EXISTS "q_payloads" ( + CREATE TABLE IF NOT EXISTS "fiinha_payloads" ( id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT, timestamp TEXT NOT NULL DEFAULT (strftime('%Y-%m-%dT%H:%M:%f000000Z', 'now')), topic TEXT NOT NULL, payload BLOB NOT NULL ) STRICT; - CREATE INDEX IF NOT EXISTS "q_payloads_topic" - ON "q_payloads"(topic); + CREATE INDEX IF NOT EXISTS "fiinha_payloads_topic" + ON "fiinha_payloads"(topic); - CREATE TABLE IF NOT EXISTS "q_messages" ( + CREATE TABLE IF NOT EXISTS "fiinha_messages" ( id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT, timestamp TEXT NOT NULL DEFAULT (strftime('%Y-%m-%dT%H:%M:%f000000Z', 'now')), uuid BLOB NOT NULL UNIQUE, flow_id BLOB NOT NULL, payload_id INTEGER NOT NULL - REFERENCES "q_payloads"(id) + REFERENCES "fiinha_payloads"(id) ) STRICT; - CREATE INDEX IF NOT EXISTS "q_messages_flow_id" - ON "q_messages"(flow_id); + CREATE INDEX IF NOT EXISTS "fiinha_messages_flow_id" + ON "fiinha_messages"(flow_id); - CREATE TABLE IF NOT EXISTS "q_offsets" ( + CREATE TABLE IF NOT EXISTS "fiinha_offsets" ( id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT, timestamp TEXT NOT NULL DEFAULT (strftime('%Y-%m-%dT%H:%M:%f000000Z', 'now')), consumer TEXT NOT NULL, message_id INTEGER NOT NULL - REFERENCES "q_messages"(id), + REFERENCES "fiinha_messages"(id), instance_id INTEGER NOT NULL, UNIQUE (consumer, message_id) ) STRICT; - CREATE INDEX IF NOT EXISTS "q_offsets_consumer" - ON "q_offsets"(consumer); + CREATE INDEX IF NOT EXISTS "fiinha_offsets_consumer" + ON "fiinha_offsets"(consumer); - CREATE TABLE IF NOT EXISTS "q_deadletters" ( + CREATE TABLE IF NOT EXISTS "fiinha_deadletters" ( id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT, uuid BLOB NOT NULL UNIQUE, consumer TEXT NOT NULL, message_id INTEGER NOT NULL - REFERENCES "q_messages"(id), + REFERENCES "fiinha_messages"(id), instance_id INTEGER NOT NULL, UNIQUE (consumer, message_id) ) STRICT; - CREATE INDEX IF NOT EXISTS "q_deadletters_consumer" - ON "q_deadletters"(consumer); + CREATE INDEX IF NOT EXISTS "fiinha_deadletters_consumer" + ON "fiinha_deadletters"(consumer); - CREATE TABLE IF NOT EXISTS "q_replays" ( + CREATE TABLE IF NOT EXISTS "fiinha_replays" ( id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT, deadletter_id INTEGER NOT NULL UNIQUE - REFERENCES "q_deadletters"(id) , + REFERENCES "fiinha_deadletters"(id) , message_id INTEGER NOT NULL UNIQUE - REFERENCES "q_messages"(id) + REFERENCES "fiinha_messages"(id) ) STRICT; - CREATE TABLE IF NOT EXISTS "q_owners" ( + CREATE TABLE IF NOT EXISTS "fiinha_owners" ( id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT, topic TEXT NOT NULL, consumer TEXT NOT NULL, @@ -61,16 +61,16 @@ UNIQUE (topic, consumer) ) STRICT; - CREATE TRIGGER IF NOT EXISTS "q_check_instance_owns_topic" - BEFORE INSERT ON "q_offsets" + CREATE TRIGGER IF NOT EXISTS "fiinha_check_instance_owns_topic" + BEFORE INSERT ON "fiinha_offsets" WHEN NEW.instance_id != ( - SELECT owner_id FROM "q_owners" + SELECT owner_id FROM "fiinha_owners" WHERE topic = ( - SELECT "q_payloads".topic - FROM "q_payloads" - JOIN "q_messages" ON "q_payloads".id = - "q_messages".payload_id - WHERE "q_messages".id = NEW.message_id + SELECT "fiinha_payloads".topic + FROM "fiinha_payloads" + JOIN "fiinha_messages" ON "fiinha_payloads".id = + "fiinha_messages".payload_id + WHERE "fiinha_messages".id = NEW.message_id ) AND consumer = NEW.consumer ) BEGIN @@ -80,16 +80,16 @@ ); END; - CREATE TRIGGER IF NOT EXISTS "q_check_can_publish_deadletter" - BEFORE INSERT ON "q_deadletters" + CREATE TRIGGER IF NOT EXISTS "fiinha_check_can_publish_deadletter" + BEFORE INSERT ON "fiinha_deadletters" WHEN NEW.instance_id != ( - SELECT owner_id FROM "q_owners" + SELECT owner_id FROM "fiinha_owners" WHERE topic = ( - SELECT "q_payloads".topic - FROM "q_payloads" - JOIN "q_messages" ON "q_payloads".id = - "q_messages".payload_id - WHERE "q_messages".id = NEW.message_id + SELECT "fiinha_payloads".topic + FROM "fiinha_payloads" + JOIN "fiinha_messages" ON "fiinha_payloads".id = + "fiinha_messages".payload_id + WHERE "fiinha_messages".id = NEW.message_id ) AND consumer = NEW.consumer ) BEGIN @@ -106,7 +106,7 @@ -- take.sql: -- write: - INSERT INTO "q_owners" (topic, consumer, owner_id) + INSERT INTO "fiinha_owners" (topic, consumer, owner_id) VALUES (?, ?, ?) ON CONFLICT (topic, consumer) DO UPDATE SET owner_id=excluded.owner_id; @@ -118,15 +118,15 @@ -- publish.sql: -- write: - INSERT INTO "q_payloads" (topic, payload) + INSERT INTO "fiinha_payloads" (topic, payload) VALUES (?, ?); - INSERT INTO "q_messages" (uuid, flow_id, payload_id) + INSERT INTO "fiinha_messages" (uuid, flow_id, payload_id) VALUES (?, ?, last_insert_rowid()); -- read: - SELECT id, timestamp FROM "q_messages" + SELECT id, timestamp FROM "fiinha_messages" WHERE uuid = ?; @@ -137,17 +137,17 @@ -- read: SELECT - "q_messages".id, - "q_messages".timestamp, - "q_messages".uuid, - "q_payloads".payload - FROM "q_messages" - JOIN "q_payloads" ON - "q_payloads".id = "q_messages".payload_id + "fiinha_messages".id, + "fiinha_messages".timestamp, + "fiinha_messages".uuid, + "fiinha_payloads".payload + FROM "fiinha_messages" + JOIN "fiinha_payloads" ON + "fiinha_payloads".id = "fiinha_messages".payload_id WHERE - "q_payloads".topic = ? AND - "q_messages".flow_id = ? - ORDER BY "q_messages".id DESC + "fiinha_payloads".topic = ? AND + "fiinha_messages".flow_id = ? + ORDER BY "fiinha_messages".id DESC LIMIT 1; @@ -159,27 +159,27 @@ -- read: SELECT ( - SELECT owner_id FROM "q_owners" + SELECT owner_id FROM "fiinha_owners" WHERE topic = ? AND consumer = ? LIMIT 1 ) AS owner_id, - "q_messages".id, - "q_messages".timestamp, - "q_messages".uuid, - "q_messages".flow_id, - "q_payloads".payload - FROM "q_messages" - JOIN "q_payloads" ON - "q_payloads".id = "q_messages".payload_id + "fiinha_messages".id, + "fiinha_messages".timestamp, + "fiinha_messages".uuid, + "fiinha_messages".flow_id, + "fiinha_payloads".payload + FROM "fiinha_messages" + JOIN "fiinha_payloads" ON + "fiinha_payloads".id = "fiinha_messages".payload_id WHERE - "q_payloads".topic = ? AND - "q_messages".id NOT IN ( - SELECT message_id FROM "q_offsets" + "fiinha_payloads".topic = ? AND + "fiinha_messages".id NOT IN ( + SELECT message_id FROM "fiinha_offsets" WHERE consumer = ? ) - ORDER BY "q_messages".id ASC + ORDER BY "fiinha_messages".id ASC LIMIT 1; @@ -190,26 +190,26 @@ -- read: SELECT - "q_messages".id, - "q_messages".timestamp, - "q_messages".uuid, - "q_messages".flow_id, - "q_payloads".topic, - "q_payloads".payload - FROM "q_messages" - JOIN "q_payloads" ON - "q_payloads".id = "q_messages".payload_id + "fiinha_messages".id, + "fiinha_messages".timestamp, + "fiinha_messages".uuid, + "fiinha_messages".flow_id, + "fiinha_payloads".topic, + "fiinha_payloads".payload + FROM "fiinha_messages" + JOIN "fiinha_payloads" ON + "fiinha_payloads".id = "fiinha_messages".payload_id WHERE - "q_payloads".topic = ? AND - "q_messages".id NOT IN ( - SELECT message_id FROM "q_offsets" + "fiinha_payloads".topic = ? AND + "fiinha_messages".id NOT IN ( + SELECT message_id FROM "fiinha_offsets" WHERE consumer = ? ) - ORDER BY "q_messages".id ASC; + ORDER BY "fiinha_messages".id ASC; -- owner: - SELECT owner_id FROM "q_owners" + SELECT owner_id FROM "fiinha_owners" WHERE topic = ? AND consumer = ?; @@ -217,8 +217,8 @@ -- commit.sql: -- write: - INSERT INTO "q_offsets" (consumer, message_id, instance_id) - VALUES (?, (SELECT id FROM "q_messages" WHERE uuid = ?), ?); + INSERT INTO "fiinha_offsets" (consumer, message_id, instance_id) + VALUES (?, (SELECT id FROM "fiinha_messages" WHERE uuid = ?), ?); -- read: @@ -227,13 +227,13 @@ -- toDead.sql: -- write: - INSERT INTO "q_offsets" + INSERT INTO "fiinha_offsets" ( consumer, message_id, instance_id) - VALUES ( ?, (SELECT id FROM "q_messages" WHERE uuid = ?), ?); + VALUES ( ?, (SELECT id FROM "fiinha_messages" WHERE uuid = ?), ?); - INSERT INTO "q_deadletters" + INSERT INTO "fiinha_deadletters" (uuid, consumer, message_id, instance_id) - VALUES (?, ?, (SELECT id FROM "q_messages" WHERE uuid = ?), ?); + VALUES (?, ?, (SELECT id FROM "fiinha_messages" WHERE uuid = ?), ?); -- read: @@ -242,34 +242,34 @@ -- replay.sql: -- write: - INSERT INTO "q_messages" (uuid, flow_id, payload_id) + INSERT INTO "fiinha_messages" (uuid, flow_id, payload_id) SELECT ?, - "q_messages".flow_id, - "q_messages".payload_id - FROM "q_messages" - JOIN "q_deadletters" ON - "q_messages".id = "q_deadletters".message_id - WHERE "q_deadletters".uuid = ?; - - INSERT INTO "q_replays" (deadletter_id, message_id) + "fiinha_messages".flow_id, + "fiinha_messages".payload_id + FROM "fiinha_messages" + JOIN "fiinha_deadletters" ON + "fiinha_messages".id = "fiinha_deadletters".message_id + WHERE "fiinha_deadletters".uuid = ?; + + INSERT INTO "fiinha_replays" (deadletter_id, message_id) VALUES ( - (SELECT id FROM "q_deadletters" WHERE uuid = ?), + (SELECT id FROM "fiinha_deadletters" WHERE uuid = ?), last_insert_rowid() ); -- read: SELECT - "q_messages".id, - "q_messages".timestamp, - "q_messages".flow_id, - "q_payloads".topic, - "q_payloads".payload - FROM "q_messages" - JOIN "q_payloads" ON - "q_payloads".id = "q_messages".payload_id - WHERE "q_messages".uuid = ?; + "fiinha_messages".id, + "fiinha_messages".timestamp, + "fiinha_messages".flow_id, + "fiinha_payloads".topic, + "fiinha_payloads".payload + FROM "fiinha_messages" + JOIN "fiinha_payloads" ON + "fiinha_payloads".id = "fiinha_messages".payload_id + WHERE "fiinha_messages".uuid = ?; -- owner: @@ -279,24 +279,24 @@ -- read: SELECT - "q_deadletters".uuid, - "q_offsets".timestamp, - "q_messages".uuid - FROM "q_deadletters" - JOIN "q_offsets" ON - "q_deadletters".message_id = "q_offsets".message_id - JOIN "q_messages" ON - "q_deadletters".message_id = "q_messages".id - JOIN "q_payloads" ON - "q_messages".payload_id = "q_payloads".id + "fiinha_deadletters".uuid, + "fiinha_offsets".timestamp, + "fiinha_messages".uuid + FROM "fiinha_deadletters" + JOIN "fiinha_offsets" ON + "fiinha_deadletters".message_id = "fiinha_offsets".message_id + JOIN "fiinha_messages" ON + "fiinha_deadletters".message_id = "fiinha_messages".id + JOIN "fiinha_payloads" ON + "fiinha_messages".payload_id = "fiinha_payloads".id WHERE - "q_payloads".topic = ? AND - "q_deadletters".consumer = ? AND - "q_offsets".consumer = ? AND - "q_deadletters".id NOT IN ( - SELECT deadletter_id FROM "q_replays" + "fiinha_payloads".topic = ? AND + "fiinha_deadletters".consumer = ? AND + "fiinha_offsets".consumer = ? AND + "fiinha_deadletters".id NOT IN ( + SELECT deadletter_id FROM "fiinha_replays" ) - ORDER BY "q_deadletters".id ASC + ORDER BY "fiinha_deadletters".id ASC LIMIT 1; @@ -307,30 +307,30 @@ -- read: SELECT - "q_deadletters".uuid, - "q_deadletters".message_id, - "q_offsets".timestamp, - "q_offsets".consumer, - "q_messages".timestamp, - "q_messages".uuid, - "q_messages".flow_id, - "q_payloads".topic, - "q_payloads".payload - FROM "q_deadletters" - JOIN "q_offsets" ON - "q_deadletters".message_id = "q_offsets".message_id - JOIN "q_messages" ON - "q_deadletters".message_id = "q_messages".id - JOIN "q_payloads" ON - "q_messages".payload_id = "q_payloads".id + "fiinha_deadletters".uuid, + "fiinha_deadletters".message_id, + "fiinha_offsets".timestamp, + "fiinha_offsets".consumer, + "fiinha_messages".timestamp, + "fiinha_messages".uuid, + "fiinha_messages".flow_id, + "fiinha_payloads".topic, + "fiinha_payloads".payload + FROM "fiinha_deadletters" + JOIN "fiinha_offsets" ON + "fiinha_deadletters".message_id = "fiinha_offsets".message_id + JOIN "fiinha_messages" ON + "fiinha_deadletters".message_id = "fiinha_messages".id + JOIN "fiinha_payloads" ON + "fiinha_messages".payload_id = "fiinha_payloads".id WHERE - "q_payloads".topic = ? AND - "q_deadletters".consumer = ? AND - "q_offsets".consumer = ? AND - "q_deadletters".id NOT IN ( - SELECT deadletter_id FROM "q_replays" + "fiinha_payloads".topic = ? AND + "fiinha_deadletters".consumer = ? AND + "fiinha_offsets".consumer = ? AND + "fiinha_deadletters".id NOT IN ( + SELECT deadletter_id FROM "fiinha_replays" ) - ORDER BY "q_deadletters".id ASC; + ORDER BY "fiinha_deadletters".id ASC; -- owner: @@ -341,10 +341,10 @@ -- read: SELECT COUNT(1) as size - FROM "q_messages" - JOIN "q_payloads" ON - "q_messages".payload_id = "q_payloads".id - WHERE "q_payloads".topic = ?; + FROM "fiinha_messages" + JOIN "fiinha_payloads" ON + "fiinha_messages".payload_id = "fiinha_payloads".id + WHERE "fiinha_payloads".topic = ?; -- owner: @@ -355,14 +355,14 @@ -- read: SELECT COUNT(1) as count - FROM "q_messages" - JOIN "q_offsets" ON - "q_messages".id = "q_offsets".message_id - JOIN "q_payloads" ON - "q_messages".payload_id = "q_payloads".id + FROM "fiinha_messages" + JOIN "fiinha_offsets" ON + "fiinha_messages".id = "fiinha_offsets".message_id + JOIN "fiinha_payloads" ON + "fiinha_messages".payload_id = "fiinha_payloads".id WHERE - "q_payloads".topic = ? AND - "q_offsets".consumer = ?; + "fiinha_payloads".topic = ? AND + "fiinha_offsets".consumer = ?; -- owner: @@ -372,13 +372,13 @@ -- read: SELECT 1 as data - FROM "q_messages" - JOIN "q_payloads" ON - "q_payloads".id = "q_messages".payload_id + FROM "fiinha_messages" + JOIN "fiinha_payloads" ON + "fiinha_payloads".id = "fiinha_messages".payload_id WHERE - "q_payloads".topic = ? AND - "q_messages".id NOT IN ( - SELECT message_id FROM "q_offsets" + "fiinha_payloads".topic = ? AND + "fiinha_messages".id NOT IN ( + SELECT message_id FROM "fiinha_offsets" WHERE consumer = ? ) LIMIT 1; |