mats/go-cart-actor
1
0
Fork 0
Code Issues Pull Requests 1 Actions 3 Packages Projects Releases Wiki Activity

slask
All checks were successful
Build and Publish / Metadata (push) Successful in 12s
Details
Build and Publish / BuildAndDeployAmd64 (push) Successful in 1m29s
Details
Build and Publish / BuildAndDeployArm64 (push) Successful in 4m27s
Details

Browse Source
This commit is contained in:
matst80
2025-10-15 22:45:53 +02:00
parent 96315383d4
commit 9537dc671f
2 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
cmd/backoffice/fileserver.go
View File

@@ -24,9 +24,10 @@ type FileServer struct {
storage actor.LogStorage[cart.CartGrain] storage actor.LogStorage[cart.CartGrain]
} }
func NewFileServer(dataDir string) *FileServer { func NewFileServer(dataDir string, storage actor.LogStorage[cart.CartGrain]) *FileServer {
return &FileServer{ return &FileServer{
dataDir: dataDir, dataDir: dataDir,
storage: storage,
} }
} }

6
cmd/backoffice/main.go
View File

@@ -29,8 +29,6 @@ func envOrDefault(key, def string) string {
return def return def
} }
var globalDisk *actor.DiskStorage[cart.CartGrain]
func startMutationConsumer(ctx context.Context, conn *amqp.Connection, hub *Hub) error { func startMutationConsumer(ctx context.Context, conn *amqp.Connection, hub *Hub) error {
ch, err := conn.Channel() ch, err := conn.Channel()
if err != nil { if err != nil {
@@ -82,9 +80,9 @@ func main() {
_ = os.MkdirAll(dataDir, 0755) _ = os.MkdirAll(dataDir, 0755)
reg := cart.NewCartMultationRegistry() reg := cart.NewCartMultationRegistry()
globalDisk = actor.NewDiskStorage[cart.CartGrain](dataDir, reg) diskStorage := actor.NewDiskStorage[cart.CartGrain](dataDir, reg)
fs := NewFileServer(dataDir) fs := NewFileServer(dataDir, diskStorage)
hub := NewHub() hub := NewHub()
go hub.Run() go hub.Run()