From 2bb4ab2bf2434610bdf17891d20383259a9de84f Mon Sep 17 00:00:00 2001 From: oppiliappan Date: Fri, 13 Jun 2025 09:17:09 +0000 Subject: [PATCH] spindle: use sqlite3 cursor store Signed-off-by: oppiliappan --- spindle/server.go | 8 +++++++- 1 file(s) changed, 7 insertion(s)(+), 1 deletion(s)(-) diff --git a/spindle/server.go b/spindle/server.go --- a/spindle/server.go +++ b/spindle/server.go @@ -11,6 +11,7 @@ "github.com/go-chi/chi/v5" "tangled.sh/tangled.sh/core/api/tangled" "tangled.sh/tangled.sh/core/jetstream" "tangled.sh/tangled.sh/core/knotclient" + "tangled.sh/tangled.sh/core/knotclient/cursor" "tangled.sh/tangled.sh/core/log" "tangled.sh/tangled.sh/core/notifier" "tangled.sh/tangled.sh/core/rbac" @@ -78,14 +79,19 @@ // for each incoming sh.tangled.pipeline, we execute // spindle.processPipeline, which in turn enqueues the pipeline // job in the above registered queue. + cursorStore, err := cursor.NewSQLiteStore(cfg.Server.DBPath) + if err != nil { + return fmt.Errorf("failed to setup sqlite3 cursor store: %w", err) + } go func() { logger.Info("starting event consumer") - knotEventSource := knotclient.NewEventSource("localhost:5555") + knotEventSource := knotclient.NewEventSource("localhost:6000") ccfg := knotclient.NewConsumerConfig() ccfg.Logger = logger ccfg.Dev = cfg.Server.Dev ccfg.ProcessFunc = spindle.processPipeline + ccfg.CursorStore = cursorStore ccfg.AddEventSource(knotEventSource) ec := knotclient.NewEventConsumer(*ccfg) -- tangled.sh