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

Compare commits

base: mats:c74968cfcee053fa842f8904b2fd3734791d0728
Branches Tags
mats:main mats:feature/triggers mats:refactor/http-proxy mats:refactor/grpc-grain mats:refactor/grpc
...
compare: mats:374bd4272b7e7bd512db37afd69455399fb195ef
Branches Tags
mats:main mats:feature/triggers mats:refactor/http-proxy mats:refactor/grpc-grain mats:refactor/grpc

2 Commits
c74968cfce ... 374bd4272b

Author SHA1 Message Date
Mats Törnberg
374bd4272b update
Some checks failed
Build and Publish / BuildAndDeployAmd64 (push) Failing after 10s
Details
Build and Publish / BuildAndDeployArm64 (push) Failing after 11s
Details
2025-11-25 19:34:39 +01:00
Mats Törnberg
ffd7ace839 update 2025-11-25 18:58:17 +01:00
46 changed files with 112 additions and 99 deletions
Expand all files Collapse all files

4
Makefile
View File

@@ -14,10 +14,10 @@
# Conventions: # Conventions:
# - All .proto files live in $(PROTO_DIR) # - All .proto files live in $(PROTO_DIR)
# - Generated Go code is emitted under $(PROTO_DIR) via go_package mapping # - Generated Go code is emitted under $(PROTO_DIR) via go_package mapping
# - go_package is set to: git.tornberg.me/go-cart-actor/proto;messages # - go_package is set to: git.k6n.net/go-cart-actor/proto;messages
# ------------------------------------------------------------------------------ # ------------------------------------------------------------------------------
MODULE_PATH := git.tornberg.me/go-cart-actor MODULE_PATH := git.k6n.net/go-cart-actor
PROTO_DIR := proto PROTO_DIR := proto
PROTOS := $(PROTO_DIR)/messages.proto $(PROTO_DIR)/control_plane.proto PROTOS := $(PROTO_DIR)/messages.proto $(PROTO_DIR)/control_plane.proto

4
cmd/backoffice/fileserver.go
View File

@@ -16,8 +16,8 @@ import (
"strings" "strings"
"time" "time"
"git.tornberg.me/go-cart-actor/pkg/actor" "git.k6n.net/go-cart-actor/pkg/actor"
"git.tornberg.me/go-cart-actor/pkg/cart" "git.k6n.net/go-cart-actor/pkg/cart"
"github.com/gogo/protobuf/proto" "github.com/gogo/protobuf/proto"
) )

2
cmd/backoffice/fileserver_test.go
View File

@@ -7,7 +7,7 @@ import (
"testing" "testing"
"time" "time"
"git.tornberg.me/go-cart-actor/pkg/cart" "git.k6n.net/go-cart-actor/pkg/cart"
) )
// TestAppendFileInfoRandomProjectFile picks a random existing .go source file in the // TestAppendFileInfoRandomProjectFile picks a random existing .go source file in the

18
cmd/backoffice/main.go
View File

@@ -9,9 +9,9 @@ import (
"os" "os"
"time" "time"
actor "git.tornberg.me/go-cart-actor/pkg/actor" actor "git.k6n.net/go-cart-actor/pkg/actor"
"git.tornberg.me/go-cart-actor/pkg/cart" "git.k6n.net/go-cart-actor/pkg/cart"
"git.tornberg.me/mats/go-redis-inventory/pkg/inventory" "github.com/matst80/go-redis-inventory/pkg/inventory"
"github.com/matst80/slask-finder/pkg/messaging" "github.com/matst80/slask-finder/pkg/messaging"
amqp "github.com/rabbitmq/amqp091-go" amqp "github.com/rabbitmq/amqp091-go"
"github.com/redis/go-redis/v9" "github.com/redis/go-redis/v9"
@@ -106,8 +106,8 @@ func main() {
mux.HandleFunc("GET /carts", fs.CartsHandler) mux.HandleFunc("GET /carts", fs.CartsHandler)
mux.HandleFunc("GET /cart/{id}", fs.CartHandler) mux.HandleFunc("GET /cart/{id}", fs.CartHandler)
mux.HandleFunc("PUT /inventory/{locationId}/{sku}", func(w http.ResponseWriter, r *http.Request) { mux.HandleFunc("PUT /inventory/{locationId}/{sku}", func(w http.ResponseWriter, r *http.Request) {
inventoryLocationId := r.PathValue("locationId") inventoryLocationId := inventory.LocationID(r.PathValue("locationId"))
inventorySku := r.PathValue("sku") inventorySku := inventory.SKU(r.PathValue("sku"))
pipe := rdb.Pipeline() pipe := rdb.Pipeline()
var payload struct { var payload struct {
Quantity int64 `json:"quantity"` Quantity int64 `json:"quantity"`
@@ -117,12 +117,18 @@ func main() {
http.Error(w, "invalid payload", http.StatusBadRequest) http.Error(w, "invalid payload", http.StatusBadRequest)
return return
} }
inventoryService.UpdateInventory(r.Context(), pipe, inventory.SKU(inventorySku), inventory.LocationID(inventoryLocationId), payload.Quantity) inventoryService.UpdateInventory(r.Context(), pipe, inventorySku, inventoryLocationId, payload.Quantity)
_, err = pipe.Exec(r.Context()) _, err = pipe.Exec(r.Context())
if err != nil { if err != nil {
http.Error(w, "failed to update inventory", http.StatusInternalServerError) http.Error(w, "failed to update inventory", http.StatusInternalServerError)
return return
} }
err := inventoryService.SendInventoryChanged(r.Context(), inventorySku, inventoryLocationId)
if err != nil {
w.WriteHeader(http.StatusBadRequest)
return
}
w.WriteHeader(http.StatusOK) w.WriteHeader(http.StatusOK)
}) })
mux.HandleFunc("/promotions", fs.PromotionsHandler) mux.HandleFunc("/promotions", fs.PromotionsHandler)

2
cmd/cart/checkout_builder.go
View File

@@ -4,7 +4,7 @@ import (
"encoding/json" "encoding/json"
"fmt" "fmt"
"git.tornberg.me/go-cart-actor/pkg/cart" "git.k6n.net/go-cart-actor/pkg/cart"
) )
// CheckoutMeta carries the external / URL metadata required to build a // CheckoutMeta carries the external / URL metadata required to build a

8
cmd/cart/checkout_server.go
View File

@@ -8,10 +8,10 @@ import (
"net/http" "net/http"
"time" "time"
"git.tornberg.me/go-cart-actor/pkg/actor" "git.k6n.net/go-cart-actor/pkg/actor"
"git.tornberg.me/go-cart-actor/pkg/cart" "git.k6n.net/go-cart-actor/pkg/cart"
"git.tornberg.me/go-cart-actor/pkg/messages" "git.k6n.net/go-cart-actor/pkg/messages"
"git.tornberg.me/mats/go-redis-inventory/pkg/inventory" "github.com/matst80/go-redis-inventory/pkg/inventory"
amqp "github.com/rabbitmq/amqp091-go" amqp "github.com/rabbitmq/amqp091-go"
) )

6
cmd/cart/k8s-host-discovery.go
View File

@@ -3,9 +3,9 @@ package main
import ( import (
"log" "log"
"git.tornberg.me/go-cart-actor/pkg/actor" "git.k6n.net/go-cart-actor/pkg/actor"
"git.tornberg.me/go-cart-actor/pkg/cart" "git.k6n.net/go-cart-actor/pkg/cart"
"git.tornberg.me/go-cart-actor/pkg/discovery" "git.k6n.net/go-cart-actor/pkg/discovery"
"k8s.io/client-go/kubernetes" "k8s.io/client-go/kubernetes"
"k8s.io/client-go/rest" "k8s.io/client-go/rest"
) )

14
cmd/cart/main.go
View File

@@ -13,13 +13,13 @@ import (
"strings" "strings"
"time" "time"
"git.tornberg.me/go-cart-actor/pkg/actor" "git.k6n.net/go-cart-actor/pkg/actor"
"git.tornberg.me/go-cart-actor/pkg/cart" "git.k6n.net/go-cart-actor/pkg/cart"
messages "git.tornberg.me/go-cart-actor/pkg/messages" messages "git.k6n.net/go-cart-actor/pkg/messages"
"git.tornberg.me/go-cart-actor/pkg/promotions" "git.k6n.net/go-cart-actor/pkg/promotions"
"git.tornberg.me/go-cart-actor/pkg/proxy" "git.k6n.net/go-cart-actor/pkg/proxy"
"git.tornberg.me/go-cart-actor/pkg/voucher" "git.k6n.net/go-cart-actor/pkg/voucher"
"git.tornberg.me/mats/go-redis-inventory/pkg/inventory" "github.com/matst80/go-redis-inventory/pkg/inventory"
"github.com/prometheus/client_golang/prometheus" "github.com/prometheus/client_golang/prometheus"
"github.com/prometheus/client_golang/prometheus/promauto" "github.com/prometheus/client_golang/prometheus/promauto"
"github.com/prometheus/client_golang/prometheus/promhttp" "github.com/prometheus/client_golang/prometheus/promhttp"

10
cmd/cart/pool-server.go
View File

@@ -11,12 +11,12 @@ import (
"sync" "sync"
"time" "time"
"git.tornberg.me/go-cart-actor/pkg/actor" "git.k6n.net/go-cart-actor/pkg/actor"
"git.tornberg.me/go-cart-actor/pkg/cart" "git.k6n.net/go-cart-actor/pkg/cart"
messages "git.tornberg.me/go-cart-actor/pkg/messages" messages "git.k6n.net/go-cart-actor/pkg/messages"
"git.tornberg.me/go-cart-actor/pkg/voucher" "git.k6n.net/go-cart-actor/pkg/voucher"
"git.tornberg.me/mats/go-redis-inventory/pkg/inventory"
"github.com/gogo/protobuf/proto" "github.com/gogo/protobuf/proto"
"github.com/matst80/go-redis-inventory/pkg/inventory"
"github.com/prometheus/client_golang/prometheus" "github.com/prometheus/client_golang/prometheus"
"github.com/prometheus/client_golang/prometheus/promauto" "github.com/prometheus/client_golang/prometheus/promauto"
"go.opentelemetry.io/contrib/bridges/otelslog" "go.opentelemetry.io/contrib/bridges/otelslog"

4
cmd/cart/product-fetcher.go
View File

@@ -6,8 +6,8 @@ import (
"fmt" "fmt"
"net/http" "net/http"
"git.tornberg.me/go-cart-actor/pkg/cart" "git.k6n.net/go-cart-actor/pkg/cart"
messages "git.tornberg.me/go-cart-actor/pkg/messages" messages "git.k6n.net/go-cart-actor/pkg/messages"
"github.com/matst80/slask-finder/pkg/index" "github.com/matst80/slask-finder/pkg/index"
) )

2
cmd/inventory/main.go
View File

@@ -9,7 +9,7 @@ import (
"strings" "strings"
"sync" "sync"
"git.tornberg.me/mats/go-redis-inventory/pkg/inventory" "github.com/matst80/go-redis-inventory/pkg/inventory"
"github.com/matst80/slask-finder/pkg/index" "github.com/matst80/slask-finder/pkg/index"
"github.com/matst80/slask-finder/pkg/messaging" "github.com/matst80/slask-finder/pkg/messaging"
"github.com/redis/go-redis/v9" "github.com/redis/go-redis/v9"

2
cmd/inventory/stockhandler.go
View File

@@ -7,7 +7,7 @@ import (
"strings" "strings"
"sync" "sync"
"git.tornberg.me/mats/go-redis-inventory/pkg/inventory" "github.com/matst80/go-redis-inventory/pkg/inventory"
"github.com/matst80/slask-finder/pkg/types" "github.com/matst80/slask-finder/pkg/types"
"github.com/redis/go-redis/v9" "github.com/redis/go-redis/v9"
) )

23
go.mod
View File

@@ -1,15 +1,15 @@
module git.tornberg.me/go-cart-actor module git.k6n.net/go-cart-actor
go 1.25.3 go 1.25.4
require ( require (
git.tornberg.me/mats/go-redis-inventory v0.0.0-20251113201741-8bf0efac50ee
github.com/gogo/protobuf v1.3.2 github.com/gogo/protobuf v1.3.2
github.com/google/uuid v1.6.0 github.com/google/uuid v1.6.0
github.com/matst80/go-redis-inventory v0.0.0-20251125181530-7ebbc97e3841
github.com/matst80/slask-finder v0.0.0-20251118173753-f66c21cfbda4 github.com/matst80/slask-finder v0.0.0-20251118173753-f66c21cfbda4
github.com/prometheus/client_golang v1.23.2 github.com/prometheus/client_golang v1.23.2
github.com/rabbitmq/amqp091-go v1.10.0 github.com/rabbitmq/amqp091-go v1.10.0
github.com/redis/go-redis/v9 v9.16.0 github.com/redis/go-redis/v9 v9.17.0
go.opentelemetry.io/contrib/bridges/otelslog v0.13.0 go.opentelemetry.io/contrib/bridges/otelslog v0.13.0
go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.63.0 go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.63.0
go.opentelemetry.io/otel v1.38.0 go.opentelemetry.io/otel v1.38.0
@@ -30,6 +30,7 @@ require (
) )
require ( require (
git.tornberg.me/mats/go-redis-inventory v0.0.0-20251113201741-8bf0efac50ee // indirect
github.com/RoaringBitmap/roaring/v2 v2.14.4 // indirect github.com/RoaringBitmap/roaring/v2 v2.14.4 // indirect
github.com/beorn7/perks v1.0.1 // indirect github.com/beorn7/perks v1.0.1 // indirect
github.com/bits-and-blooms/bitset v1.24.4 // indirect github.com/bits-and-blooms/bitset v1.24.4 // indirect
@@ -58,7 +59,7 @@ require (
github.com/go-openapi/swag/stringutils v0.25.3 // indirect github.com/go-openapi/swag/stringutils v0.25.3 // indirect
github.com/go-openapi/swag/typeutils v0.25.3 // indirect github.com/go-openapi/swag/typeutils v0.25.3 // indirect
github.com/go-openapi/swag/yamlutils v0.25.3 // indirect github.com/go-openapi/swag/yamlutils v0.25.3 // indirect
github.com/google/gnostic-models v0.7.0 // indirect github.com/google/gnostic-models v0.7.1 // indirect
github.com/google/go-cmp v0.7.0 // indirect github.com/google/go-cmp v0.7.0 // indirect
github.com/gorilla/schema v1.4.1 // indirect github.com/gorilla/schema v1.4.1 // indirect
github.com/grpc-ecosystem/grpc-gateway/v2 v2.27.3 // indirect github.com/grpc-ecosystem/grpc-gateway/v2 v2.27.3 // indirect
@@ -76,13 +77,13 @@ require (
github.com/perimeterx/marshmallow v1.1.5 // indirect github.com/perimeterx/marshmallow v1.1.5 // indirect
github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect
github.com/prometheus/client_model v0.6.2 // indirect github.com/prometheus/client_model v0.6.2 // indirect
github.com/prometheus/common v0.67.3 // indirect github.com/prometheus/common v0.67.4 // indirect
github.com/prometheus/procfs v0.19.2 // indirect github.com/prometheus/procfs v0.19.2 // indirect
github.com/speakeasy-api/jsonpath v0.6.2 // indirect github.com/speakeasy-api/jsonpath v0.6.2 // indirect
github.com/speakeasy-api/openapi-overlay v0.10.3 // indirect github.com/speakeasy-api/openapi-overlay v0.10.3 // indirect
github.com/spf13/pflag v1.0.10 // indirect github.com/spf13/pflag v1.0.10 // indirect
github.com/vmware-labs/yaml-jsonpath v0.3.2 // indirect github.com/vmware-labs/yaml-jsonpath v0.3.2 // indirect
github.com/woodsbury/decimal128 v1.3.0 // indirect github.com/woodsbury/decimal128 v1.4.0 // indirect
github.com/x448/float16 v0.8.4 // indirect github.com/x448/float16 v0.8.4 // indirect
go.opentelemetry.io/auto/sdk v1.2.1 // indirect go.opentelemetry.io/auto/sdk v1.2.1 // indirect
go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.38.0 // indirect go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.38.0 // indirect
@@ -99,18 +100,18 @@ require (
golang.org/x/text v0.31.0 // indirect golang.org/x/text v0.31.0 // indirect
golang.org/x/time v0.14.0 // indirect golang.org/x/time v0.14.0 // indirect
golang.org/x/tools v0.39.0 // indirect golang.org/x/tools v0.39.0 // indirect
google.golang.org/genproto/googleapis/api v0.0.0-20251111163417-95abcf5c77ba // indirect google.golang.org/genproto/googleapis/api v0.0.0-20251124214823-79d6a2a48846 // indirect
google.golang.org/genproto/googleapis/rpc v0.0.0-20251111163417-95abcf5c77ba // indirect google.golang.org/genproto/googleapis/rpc v0.0.0-20251124214823-79d6a2a48846 // indirect
gopkg.in/evanphx/json-patch.v4 v4.13.0 // indirect gopkg.in/evanphx/json-patch.v4 v4.13.0 // indirect
gopkg.in/inf.v0 v0.9.1 // indirect gopkg.in/inf.v0 v0.9.1 // indirect
gopkg.in/yaml.v2 v2.4.0 // indirect gopkg.in/yaml.v2 v2.4.0 // indirect
gopkg.in/yaml.v3 v3.0.1 // indirect gopkg.in/yaml.v3 v3.0.1 // indirect
k8s.io/klog/v2 v2.130.1 // indirect k8s.io/klog/v2 v2.130.1 // indirect
k8s.io/kube-openapi v0.0.0-20250910181357-589584f1c912 // indirect k8s.io/kube-openapi v0.0.0-20251125145642-4e65d59e963e // indirect
k8s.io/utils v0.0.0-20251002143259-bc988d571ff4 // indirect k8s.io/utils v0.0.0-20251002143259-bc988d571ff4 // indirect
sigs.k8s.io/json v0.0.0-20250730193827-2d320260d730 // indirect sigs.k8s.io/json v0.0.0-20250730193827-2d320260d730 // indirect
sigs.k8s.io/randfill v1.0.0 // indirect sigs.k8s.io/randfill v1.0.0 // indirect
sigs.k8s.io/structured-merge-diff/v6 v6.3.0 // indirect sigs.k8s.io/structured-merge-diff/v6 v6.3.1 // indirect
sigs.k8s.io/yaml v1.6.0 // indirect sigs.k8s.io/yaml v1.6.0 // indirect
) )

34
go.sum
View File

@@ -82,8 +82,8 @@ github.com/gogo/protobuf v1.3.2/go.mod h1:P1XiOD3dCwIKUDQYPy72D8LYyHL2YPYrpS2s69
github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U= github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
github.com/golang/protobuf v1.5.4 h1:i7eJL8qZTpSEXOPTxNKhASYpMn+8e5Q6AdndVa1dWek= github.com/golang/protobuf v1.5.4 h1:i7eJL8qZTpSEXOPTxNKhASYpMn+8e5Q6AdndVa1dWek=
github.com/golang/protobuf v1.5.4/go.mod h1:lnTiLA8Wa4RWRcIUkrtSVa5nRhsEGBg48fD6rSs7xps= github.com/golang/protobuf v1.5.4/go.mod h1:lnTiLA8Wa4RWRcIUkrtSVa5nRhsEGBg48fD6rSs7xps=
github.com/google/gnostic-models v0.7.0 h1:qwTtogB15McXDaNqTZdzPJRHvaVJlAl+HVQnLmJEJxo= github.com/google/gnostic-models v0.7.1 h1:SisTfuFKJSKM5CPZkffwi6coztzzeYUhc3v4yxLWH8c=
github.com/google/gnostic-models v0.7.0/go.mod h1:whL5G0m6dmc5cPxKc5bdKdEN3UjI7OUGxBlw57miDrQ= github.com/google/gnostic-models v0.7.1/go.mod h1:whL5G0m6dmc5cPxKc5bdKdEN3UjI7OUGxBlw57miDrQ=
github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8= github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8=
github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU= github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU=
github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg= github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
@@ -115,6 +115,8 @@ github.com/kylelemons/godebug v1.1.0 h1:RPNrshWIDI6G2gRW9EHilWtl7Z6Sb1BR0xunSBf0
github.com/kylelemons/godebug v1.1.0/go.mod h1:9/0rRGxNHcop5bhtWyNeEfOS8JIWk580+fNqagV/RAw= github.com/kylelemons/godebug v1.1.0/go.mod h1:9/0rRGxNHcop5bhtWyNeEfOS8JIWk580+fNqagV/RAw=
github.com/mailru/easyjson v0.9.1 h1:LbtsOm5WAswyWbvTEOqhypdPeZzHavpZx96/n553mR8= github.com/mailru/easyjson v0.9.1 h1:LbtsOm5WAswyWbvTEOqhypdPeZzHavpZx96/n553mR8=
github.com/mailru/easyjson v0.9.1/go.mod h1:1+xMtQp2MRNVL/V1bOzuP3aP8VNwRW55fQUto+XFtTU= github.com/mailru/easyjson v0.9.1/go.mod h1:1+xMtQp2MRNVL/V1bOzuP3aP8VNwRW55fQUto+XFtTU=
github.com/matst80/go-redis-inventory v0.0.0-20251125181530-7ebbc97e3841 h1:CCHa+LuxwGOPPbIpuFYNT7VtC5rHjSulB337Y+Yyys8=
github.com/matst80/go-redis-inventory v0.0.0-20251125181530-7ebbc97e3841/go.mod h1:d42+bHxhmMg73OQM+5i5U7vyEQfuVLJkt7QPsEbr8kI=
github.com/matst80/slask-finder v0.0.0-20251118173753-f66c21cfbda4 h1:yWwWkCaXhwrp5EAd6Z2Rd/n823K0Fz/A3+bqcAcn0qk= github.com/matst80/slask-finder v0.0.0-20251118173753-f66c21cfbda4 h1:yWwWkCaXhwrp5EAd6Z2Rd/n823K0Fz/A3+bqcAcn0qk=
github.com/matst80/slask-finder v0.0.0-20251118173753-f66c21cfbda4/go.mod h1:aqCC0Y1Jv+DhL36YHXf+0bZZkpQNMe9yFMcwgRSJ+Rc= github.com/matst80/slask-finder v0.0.0-20251118173753-f66c21cfbda4/go.mod h1:aqCC0Y1Jv+DhL36YHXf+0bZZkpQNMe9yFMcwgRSJ+Rc=
github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q= github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
@@ -155,14 +157,14 @@ github.com/prometheus/client_golang v1.23.2 h1:Je96obch5RDVy3FDMndoUsjAhG5Edi49h
github.com/prometheus/client_golang v1.23.2/go.mod h1:Tb1a6LWHB3/SPIzCoaDXI4I8UHKeFTEQ1YCr+0Gyqmg= github.com/prometheus/client_golang v1.23.2/go.mod h1:Tb1a6LWHB3/SPIzCoaDXI4I8UHKeFTEQ1YCr+0Gyqmg=
github.com/prometheus/client_model v0.6.2 h1:oBsgwpGs7iVziMvrGhE53c/GrLUsZdHnqNwqPLxwZyk= github.com/prometheus/client_model v0.6.2 h1:oBsgwpGs7iVziMvrGhE53c/GrLUsZdHnqNwqPLxwZyk=
github.com/prometheus/client_model v0.6.2/go.mod h1:y3m2F6Gdpfy6Ut/GBsUqTWZqCUvMVzSfMLjcu6wAwpE= github.com/prometheus/client_model v0.6.2/go.mod h1:y3m2F6Gdpfy6Ut/GBsUqTWZqCUvMVzSfMLjcu6wAwpE=
github.com/prometheus/common v0.67.3 h1:shd26MlnwTw5jksTDhC7rTQIteBxy+ZZDr3t7F2xN2Q= github.com/prometheus/common v0.67.4 h1:yR3NqWO1/UyO1w2PhUvXlGQs/PtFmoveVO0KZ4+Lvsc=
github.com/prometheus/common v0.67.3/go.mod h1:gP0fq6YjjNCLssJCQp0yk4M8W6ikLURwkdd/YKtTbyI= github.com/prometheus/common v0.67.4/go.mod h1:gP0fq6YjjNCLssJCQp0yk4M8W6ikLURwkdd/YKtTbyI=
github.com/prometheus/procfs v0.19.2 h1:zUMhqEW66Ex7OXIiDkll3tl9a1ZdilUOd/F6ZXw4Vws= github.com/prometheus/procfs v0.19.2 h1:zUMhqEW66Ex7OXIiDkll3tl9a1ZdilUOd/F6ZXw4Vws=
github.com/prometheus/procfs v0.19.2/go.mod h1:M0aotyiemPhBCM0z5w87kL22CxfcH05ZpYlu+b4J7mw= github.com/prometheus/procfs v0.19.2/go.mod h1:M0aotyiemPhBCM0z5w87kL22CxfcH05ZpYlu+b4J7mw=
github.com/rabbitmq/amqp091-go v1.10.0 h1:STpn5XsHlHGcecLmMFCtg7mqq0RnD+zFr4uzukfVhBw= github.com/rabbitmq/amqp091-go v1.10.0 h1:STpn5XsHlHGcecLmMFCtg7mqq0RnD+zFr4uzukfVhBw=
github.com/rabbitmq/amqp091-go v1.10.0/go.mod h1:Hy4jKW5kQART1u+JkDTF9YYOQUHXqMuhrgxOEeS7G4o= github.com/rabbitmq/amqp091-go v1.10.0/go.mod h1:Hy4jKW5kQART1u+JkDTF9YYOQUHXqMuhrgxOEeS7G4o=
github.com/redis/go-redis/v9 v9.16.0 h1:OotgqgLSRCmzfqChbQyG1PHC3tLNR89DG4jdOERSEP4= github.com/redis/go-redis/v9 v9.17.0 h1:K6E+ZlYN95KSMmZeEQPbU/c++wfmEvfFB17yEAq/VhM=
github.com/redis/go-redis/v9 v9.16.0/go.mod h1:u410H11HMLoB+TP67dz8rL9s6QW2j76l0//kSOd3370= github.com/redis/go-redis/v9 v9.17.0/go.mod h1:u410H11HMLoB+TP67dz8rL9s6QW2j76l0//kSOd3370=
github.com/rogpeppe/go-internal v1.14.1 h1:UQB4HGPB6osV0SQTLymcB4TgvyWu6ZyliaW0tI/otEQ= github.com/rogpeppe/go-internal v1.14.1 h1:UQB4HGPB6osV0SQTLymcB4TgvyWu6ZyliaW0tI/otEQ=
github.com/rogpeppe/go-internal v1.14.1/go.mod h1:MaRKkUm5W0goXpeCfT7UZI6fk/L7L7so1lCWt35ZSgc= github.com/rogpeppe/go-internal v1.14.1/go.mod h1:MaRKkUm5W0goXpeCfT7UZI6fk/L7L7so1lCWt35ZSgc=
github.com/sergi/go-diff v1.1.0 h1:we8PVUC3FE2uYfodKH/nBHMSetSfHDR6scGdBi+erh0= github.com/sergi/go-diff v1.1.0 h1:we8PVUC3FE2uYfodKH/nBHMSetSfHDR6scGdBi+erh0=
@@ -185,8 +187,8 @@ github.com/ugorji/go/codec v1.2.11 h1:BMaWp1Bb6fHwEtbplGBGJ498wD+LKlNSl25MjdZY4d
github.com/ugorji/go/codec v1.2.11/go.mod h1:UNopzCgEMSXjBc6AOMqYvWC1ktqTAfzJZUZgYf6w6lg= github.com/ugorji/go/codec v1.2.11/go.mod h1:UNopzCgEMSXjBc6AOMqYvWC1ktqTAfzJZUZgYf6w6lg=
github.com/vmware-labs/yaml-jsonpath v0.3.2 h1:/5QKeCBGdsInyDCyVNLbXyilb61MXGi9NP674f9Hobk= github.com/vmware-labs/yaml-jsonpath v0.3.2 h1:/5QKeCBGdsInyDCyVNLbXyilb61MXGi9NP674f9Hobk=
github.com/vmware-labs/yaml-jsonpath v0.3.2/go.mod h1:U6whw1z03QyqgWdgXxvVnQ90zN1BWz5V+51Ewf8k+rQ= github.com/vmware-labs/yaml-jsonpath v0.3.2/go.mod h1:U6whw1z03QyqgWdgXxvVnQ90zN1BWz5V+51Ewf8k+rQ=
github.com/woodsbury/decimal128 v1.3.0 h1:8pffMNWIlC0O5vbyHWFZAt5yWvWcrHA+3ovIIjVWss0= github.com/woodsbury/decimal128 v1.4.0 h1:xJATj7lLu4f2oObouMt2tgGiElE5gO6mSWUjQsBgUlc=
github.com/woodsbury/decimal128 v1.3.0/go.mod h1:C5UTmyTjW3JftjUFzOVhC20BEQa2a4ZKOB5I6Zjb+ds= github.com/woodsbury/decimal128 v1.4.0/go.mod h1:BP46FUrVjVhdTbKT+XuQh2xfQaGki9LMIRJSFuh6THU=
github.com/x448/float16 v0.8.4 h1:qLwI1I70+NjRFUR3zs1JPUCgaCXSh3SW62uAKT1mSBM= github.com/x448/float16 v0.8.4 h1:qLwI1I70+NjRFUR3zs1JPUCgaCXSh3SW62uAKT1mSBM=
github.com/x448/float16 v0.8.4/go.mod h1:14CWIYCyZA/cWjXOioeEpHeN/83MdbZDRQHoFcYsOfg= github.com/x448/float16 v0.8.4/go.mod h1:14CWIYCyZA/cWjXOioeEpHeN/83MdbZDRQHoFcYsOfg=
github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74= github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
@@ -279,10 +281,10 @@ golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8T
golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
gonum.org/v1/gonum v0.16.0 h1:5+ul4Swaf3ESvrOnidPp4GZbzf0mxVQpDCYUQE7OJfk= gonum.org/v1/gonum v0.16.0 h1:5+ul4Swaf3ESvrOnidPp4GZbzf0mxVQpDCYUQE7OJfk=
gonum.org/v1/gonum v0.16.0/go.mod h1:fef3am4MQ93R2HHpKnLk4/Tbh/s0+wqD5nfa6Pnwy4E= gonum.org/v1/gonum v0.16.0/go.mod h1:fef3am4MQ93R2HHpKnLk4/Tbh/s0+wqD5nfa6Pnwy4E=
google.golang.org/genproto/googleapis/api v0.0.0-20251111163417-95abcf5c77ba h1:B14OtaXuMaCQsl2deSvNkyPKIzq3BjfxQp8d00QyWx4= google.golang.org/genproto/googleapis/api v0.0.0-20251124214823-79d6a2a48846 h1:ZdyUkS9po3H7G0tuh955QVyyotWvOD4W0aEapeGeUYk=
google.golang.org/genproto/googleapis/api v0.0.0-20251111163417-95abcf5c77ba/go.mod h1:G5IanEx8/PgI9w6CFcYQf7jMtHQhZruvfM1i3qOqk5U= google.golang.org/genproto/googleapis/api v0.0.0-20251124214823-79d6a2a48846/go.mod h1:Fk4kyraUvqD7i5H6S43sj2W98fbZa75lpZz/eUyhfO0=
google.golang.org/genproto/googleapis/rpc v0.0.0-20251111163417-95abcf5c77ba h1:UKgtfRM7Yh93Sya0Fo8ZzhDP4qBckrrxEr2oF5UIVb8= google.golang.org/genproto/googleapis/rpc v0.0.0-20251124214823-79d6a2a48846 h1:Wgl1rcDNThT+Zn47YyCXOXyX/COgMTIdhJ717F0l4xk=
google.golang.org/genproto/googleapis/rpc v0.0.0-20251111163417-95abcf5c77ba/go.mod h1:7i2o+ce6H/6BluujYR+kqX3GKH+dChPTQU19wjRPiGk= google.golang.org/genproto/googleapis/rpc v0.0.0-20251124214823-79d6a2a48846/go.mod h1:7i2o+ce6H/6BluujYR+kqX3GKH+dChPTQU19wjRPiGk=
google.golang.org/grpc v1.77.0 h1:wVVY6/8cGA6vvffn+wWK5ToddbgdU3d8MNENr4evgXM= google.golang.org/grpc v1.77.0 h1:wVVY6/8cGA6vvffn+wWK5ToddbgdU3d8MNENr4evgXM=
google.golang.org/grpc v1.77.0/go.mod h1:z0BY1iVj0q8E1uSQCjL9cppRj+gnZjzDnzV0dHhrNig= google.golang.org/grpc v1.77.0/go.mod h1:z0BY1iVj0q8E1uSQCjL9cppRj+gnZjzDnzV0dHhrNig=
google.golang.org/protobuf v1.36.10 h1:AYd7cD/uASjIL6Q9LiTjz8JLcrh/88q5UObnmY3aOOE= google.golang.org/protobuf v1.36.10 h1:AYd7cD/uASjIL6Q9LiTjz8JLcrh/88q5UObnmY3aOOE=
@@ -315,15 +317,15 @@ k8s.io/client-go v0.34.2 h1:Co6XiknN+uUZqiddlfAjT68184/37PS4QAzYvQvDR8M=
k8s.io/client-go v0.34.2/go.mod h1:2VYDl1XXJsdcAxw7BenFslRQX28Dxz91U9MWKjX97fE= k8s.io/client-go v0.34.2/go.mod h1:2VYDl1XXJsdcAxw7BenFslRQX28Dxz91U9MWKjX97fE=
k8s.io/klog/v2 v2.130.1 h1:n9Xl7H1Xvksem4KFG4PYbdQCQxqc/tTUyrgXaOhHSzk= k8s.io/klog/v2 v2.130.1 h1:n9Xl7H1Xvksem4KFG4PYbdQCQxqc/tTUyrgXaOhHSzk=
k8s.io/klog/v2 v2.130.1/go.mod h1:3Jpz1GvMt720eyJH1ckRHK1EDfpxISzJ7I9OYgaDtPE= k8s.io/klog/v2 v2.130.1/go.mod h1:3Jpz1GvMt720eyJH1ckRHK1EDfpxISzJ7I9OYgaDtPE=
k8s.io/kube-openapi v0.0.0-20250910181357-589584f1c912 h1:Y3gxNAuB0OBLImH611+UDZcmKS3g6CthxToOb37KgwE= k8s.io/kube-openapi v0.0.0-20251125145642-4e65d59e963e h1:iW9ChlU0cU16w8MpVYjXk12dqQ4BPFBEgif+ap7/hqQ=
k8s.io/kube-openapi v0.0.0-20250910181357-589584f1c912/go.mod h1:kdmbQkyfwUagLfXIad1y2TdrjPFWp2Q89B3qkRwf/pQ= k8s.io/kube-openapi v0.0.0-20251125145642-4e65d59e963e/go.mod h1:kdmbQkyfwUagLfXIad1y2TdrjPFWp2Q89B3qkRwf/pQ=
k8s.io/utils v0.0.0-20251002143259-bc988d571ff4 h1:SjGebBtkBqHFOli+05xYbK8YF1Dzkbzn+gDM4X9T4Ck= k8s.io/utils v0.0.0-20251002143259-bc988d571ff4 h1:SjGebBtkBqHFOli+05xYbK8YF1Dzkbzn+gDM4X9T4Ck=
k8s.io/utils v0.0.0-20251002143259-bc988d571ff4/go.mod h1:OLgZIPagt7ERELqWJFomSt595RzquPNLL48iOWgYOg0= k8s.io/utils v0.0.0-20251002143259-bc988d571ff4/go.mod h1:OLgZIPagt7ERELqWJFomSt595RzquPNLL48iOWgYOg0=
sigs.k8s.io/json v0.0.0-20250730193827-2d320260d730 h1:IpInykpT6ceI+QxKBbEflcR5EXP7sU1kvOlxwZh5txg= sigs.k8s.io/json v0.0.0-20250730193827-2d320260d730 h1:IpInykpT6ceI+QxKBbEflcR5EXP7sU1kvOlxwZh5txg=
sigs.k8s.io/json v0.0.0-20250730193827-2d320260d730/go.mod h1:mdzfpAEoE6DHQEN0uh9ZbOCuHbLK5wOm7dK4ctXE9Tg= sigs.k8s.io/json v0.0.0-20250730193827-2d320260d730/go.mod h1:mdzfpAEoE6DHQEN0uh9ZbOCuHbLK5wOm7dK4ctXE9Tg=
sigs.k8s.io/randfill v1.0.0 h1:JfjMILfT8A6RbawdsK2JXGBR5AQVfd+9TbzrlneTyrU= sigs.k8s.io/randfill v1.0.0 h1:JfjMILfT8A6RbawdsK2JXGBR5AQVfd+9TbzrlneTyrU=
sigs.k8s.io/randfill v1.0.0/go.mod h1:XeLlZ/jmk4i1HRopwe7/aU3H5n1zNUcX6TM94b3QxOY= sigs.k8s.io/randfill v1.0.0/go.mod h1:XeLlZ/jmk4i1HRopwe7/aU3H5n1zNUcX6TM94b3QxOY=
sigs.k8s.io/structured-merge-diff/v6 v6.3.0 h1:jTijUJbW353oVOd9oTlifJqOGEkUw2jB/fXCbTiQEco= sigs.k8s.io/structured-merge-diff/v6 v6.3.1 h1:JrhdFMqOd/+3ByqlP2I45kTOZmTRLBUm5pvRjeheg7E=
sigs.k8s.io/structured-merge-diff/v6 v6.3.0/go.mod h1:M3W8sfWvn2HhQDIbGWj3S099YozAsymCo/wrT5ohRUE= sigs.k8s.io/structured-merge-diff/v6 v6.3.1/go.mod h1:M3W8sfWvn2HhQDIbGWj3S099YozAsymCo/wrT5ohRUE=
sigs.k8s.io/yaml v1.6.0 h1:G8fkbMSAFqgEFgh4b1wmtzDnioxFCUgTZhlbj5P9QYs= sigs.k8s.io/yaml v1.6.0 h1:G8fkbMSAFqgEFgh4b1wmtzDnioxFCUgTZhlbj5P9QYs=
sigs.k8s.io/yaml v1.6.0/go.mod h1:796bPqUfzR/0jLAl6XjHl3Ck7MiyVv8dbTdyT3/pMf4= sigs.k8s.io/yaml v1.6.0/go.mod h1:796bPqUfzR/0jLAl6XjHl3Ck7MiyVv8dbTdyT3/pMf4=

2
pkg/actor/grpc_server.go
View File

@@ -7,7 +7,7 @@ import (
"net" "net"
"time" "time"
messages "git.tornberg.me/go-cart-actor/pkg/messages" messages "git.k6n.net/go-cart-actor/pkg/messages"
"go.opentelemetry.io/contrib/bridges/otelslog" "go.opentelemetry.io/contrib/bridges/otelslog"
"go.opentelemetry.io/otel" "go.opentelemetry.io/otel"
"go.opentelemetry.io/otel/attribute" "go.opentelemetry.io/otel/attribute"

2
pkg/actor/mutation_registry_test.go
View File

@@ -7,7 +7,7 @@ import (
"slices" "slices"
"testing" "testing"
"git.tornberg.me/go-cart-actor/pkg/messages" "git.k6n.net/go-cart-actor/pkg/messages"
) )
type cartState struct { type cartState struct {

6
pkg/cart/cart-grain.go
View File

@@ -7,9 +7,9 @@ import (
"sync" "sync"
"time" "time"
"git.tornberg.me/go-cart-actor/pkg/actor" "git.k6n.net/go-cart-actor/pkg/actor"
messages "git.tornberg.me/go-cart-actor/pkg/messages" messages "git.k6n.net/go-cart-actor/pkg/messages"
"git.tornberg.me/go-cart-actor/pkg/voucher" "git.k6n.net/go-cart-actor/pkg/voucher"
) )
// Legacy padded [16]byte CartId and its helper methods removed. // Legacy padded [16]byte CartId and its helper methods removed.

4
pkg/cart/cart-mutation-helper.go
View File

@@ -1,8 +1,8 @@
package cart package cart
import ( import (
"git.tornberg.me/go-cart-actor/pkg/actor" "git.k6n.net/go-cart-actor/pkg/actor"
messages "git.tornberg.me/go-cart-actor/pkg/messages" messages "git.k6n.net/go-cart-actor/pkg/messages"
) )
func NewCartMultationRegistry() actor.MutationRegistry { func NewCartMultationRegistry() actor.MutationRegistry {

2
pkg/cart/mutation_add_giftcard.go
View File

@@ -4,7 +4,7 @@ import (
"encoding/json" "encoding/json"
"fmt" "fmt"
messages "git.tornberg.me/go-cart-actor/pkg/messages" messages "git.k6n.net/go-cart-actor/pkg/messages"
"google.golang.org/protobuf/proto" "google.golang.org/protobuf/proto"
) )

2
pkg/cart/mutation_add_item.go
View File

@@ -3,7 +3,7 @@ package cart
import ( import (
"fmt" "fmt"
messages "git.tornberg.me/go-cart-actor/pkg/messages" messages "git.k6n.net/go-cart-actor/pkg/messages"
) )
// mutation_add_item.go // mutation_add_item.go

4
pkg/cart/mutation_add_voucher.go
View File

@@ -3,8 +3,8 @@ package cart
import ( import (
"slices" "slices"
"git.tornberg.me/go-cart-actor/pkg/actor" "git.k6n.net/go-cart-actor/pkg/actor"
"git.tornberg.me/go-cart-actor/pkg/messages" "git.k6n.net/go-cart-actor/pkg/messages"
) )
func RemoveVoucher(g *CartGrain, m *messages.RemoveVoucher) error { func RemoveVoucher(g *CartGrain, m *messages.RemoveVoucher) error {

2
pkg/cart/mutation_change_quantity.go
View File

@@ -3,7 +3,7 @@ package cart
import ( import (
"fmt" "fmt"
messages "git.tornberg.me/go-cart-actor/pkg/messages" messages "git.k6n.net/go-cart-actor/pkg/messages"
) )
// mutation_change_quantity.go // mutation_change_quantity.go

2
pkg/cart/mutation_confirmation_viewed.go
View File

@@ -3,7 +3,7 @@ package cart
import ( import (
"time" "time"
messages "git.tornberg.me/go-cart-actor/pkg/messages" messages "git.k6n.net/go-cart-actor/pkg/messages"
) )
func ConfirmationViewed(grain *CartGrain, req *messages.ConfirmationViewed) error { func ConfirmationViewed(grain *CartGrain, req *messages.ConfirmationViewed) error {

3
pkg/cart/mutation_create_checkout_order.go
View File

@@ -2,8 +2,9 @@ package cart
import ( import (
"errors" "errors"
messages "git.k6n.net/go-cart-actor/pkg/messages"
"github.com/google/uuid" "github.com/google/uuid"
messages "git.tornberg.me/go-cart-actor/pkg/messages"
) )
func CreateCheckoutOrder(grain *CartGrain, req *messages.CreateCheckoutOrder) error { func CreateCheckoutOrder(grain *CartGrain, req *messages.CreateCheckoutOrder) error {

2
pkg/cart/mutation_initialize_checkout.go
View File

@@ -3,7 +3,7 @@ package cart
import ( import (
"fmt" "fmt"
messages "git.tornberg.me/go-cart-actor/pkg/messages" messages "git.k6n.net/go-cart-actor/pkg/messages"
) )
// mutation_initialize_checkout.go // mutation_initialize_checkout.go

2
pkg/cart/mutation_inventory_reserved.go
View File

@@ -1,6 +1,6 @@
package cart package cart
import "git.tornberg.me/go-cart-actor/pkg/messages" import "git.k6n.net/go-cart-actor/pkg/messages"
func InventoryReserved(g *CartGrain, m *messages.InventoryReserved) error { func InventoryReserved(g *CartGrain, m *messages.InventoryReserved) error {
g.InventoryReserved = true g.InventoryReserved = true

2
pkg/cart/mutation_line_item_marking.go
View File

@@ -3,7 +3,7 @@ package cart
import ( import (
"fmt" "fmt"
messages "git.tornberg.me/go-cart-actor/pkg/messages" messages "git.k6n.net/go-cart-actor/pkg/messages"
) )
func LineItemMarking(grain *CartGrain, req *messages.LineItemMarking) error { func LineItemMarking(grain *CartGrain, req *messages.LineItemMarking) error {

2
pkg/cart/mutation_order_created.go
View File

@@ -3,7 +3,7 @@ package cart
import ( import (
"fmt" "fmt"
messages "git.tornberg.me/go-cart-actor/pkg/messages" messages "git.k6n.net/go-cart-actor/pkg/messages"
) )
// mutation_order_created.go // mutation_order_created.go

2
pkg/cart/mutation_payment_declined.go
View File

@@ -3,7 +3,7 @@ package cart
import ( import (
"time" "time"
messages "git.tornberg.me/go-cart-actor/pkg/messages" messages "git.k6n.net/go-cart-actor/pkg/messages"
) )
func PaymentDeclined(grain *CartGrain, req *messages.PaymentDeclined) error { func PaymentDeclined(grain *CartGrain, req *messages.PaymentDeclined) error {

2
pkg/cart/mutation_precondition.go
View File

@@ -1,6 +1,6 @@
package cart package cart
import messages "git.tornberg.me/go-cart-actor/pkg/messages" import messages "git.k6n.net/go-cart-actor/pkg/messages"
func PreConditionFailed(g *CartGrain, m *messages.PreConditionFailed) error { func PreConditionFailed(g *CartGrain, m *messages.PreConditionFailed) error {
return nil return nil

2
pkg/cart/mutation_remove_delivery.go
View File

@@ -3,7 +3,7 @@ package cart
import ( import (
"fmt" "fmt"
messages "git.tornberg.me/go-cart-actor/pkg/messages" messages "git.k6n.net/go-cart-actor/pkg/messages"
) )
// mutation_remove_delivery.go // mutation_remove_delivery.go

2
pkg/cart/mutation_remove_giftcard.go
View File

@@ -3,7 +3,7 @@ package cart
import ( import (
"fmt" "fmt"
messages "git.tornberg.me/go-cart-actor/pkg/messages" messages "git.k6n.net/go-cart-actor/pkg/messages"
) )
func RemoveGiftcard(grain *CartGrain, req *messages.RemoveGiftcard) error { func RemoveGiftcard(grain *CartGrain, req *messages.RemoveGiftcard) error {

2
pkg/cart/mutation_remove_item.go
View File

@@ -3,7 +3,7 @@ package cart
import ( import (
"fmt" "fmt"
messages "git.tornberg.me/go-cart-actor/pkg/messages" messages "git.k6n.net/go-cart-actor/pkg/messages"
) )
// mutation_remove_item.go // mutation_remove_item.go

3
pkg/cart/mutation_remove_line_item_marking.go
View File

@@ -2,7 +2,8 @@ package cart
import ( import (
"fmt" "fmt"
messages "git.tornberg.me/go-cart-actor/pkg/messages"
messages "git.k6n.net/go-cart-actor/pkg/messages"
) )
func RemoveLineItemMarking(grain *CartGrain, req *messages.RemoveLineItemMarking) error { func RemoveLineItemMarking(grain *CartGrain, req *messages.RemoveLineItemMarking) error {

2
pkg/cart/mutation_set_delivery.go
View File

@@ -4,7 +4,7 @@ import (
"fmt" "fmt"
"slices" "slices"
messages "git.tornberg.me/go-cart-actor/pkg/messages" messages "git.k6n.net/go-cart-actor/pkg/messages"
) )
// mutation_set_delivery.go // mutation_set_delivery.go

2
pkg/cart/mutation_set_pickup_point.go
View File

@@ -3,7 +3,7 @@ package cart
import ( import (
"fmt" "fmt"
messages "git.tornberg.me/go-cart-actor/pkg/messages" messages "git.k6n.net/go-cart-actor/pkg/messages"
) )
// mutation_set_pickup_point.go // mutation_set_pickup_point.go

3
pkg/cart/mutation_set_user_id.go
View File

@@ -2,7 +2,8 @@ package cart
import ( import (
"errors" "errors"
messages "git.tornberg.me/go-cart-actor/pkg/messages"
messages "git.k6n.net/go-cart-actor/pkg/messages"
) )
func SetUserId(grain *CartGrain, req *messages.SetUserId) error { func SetUserId(grain *CartGrain, req *messages.SetUserId) error {

3
pkg/cart/mutation_subscription_added.go
View File

@@ -2,7 +2,8 @@ package cart
import ( import (
"fmt" "fmt"
messages "git.tornberg.me/go-cart-actor/pkg/messages"
messages "git.k6n.net/go-cart-actor/pkg/messages"
) )
func SubscriptionAdded(grain *CartGrain, req *messages.SubscriptionAdded) error { func SubscriptionAdded(grain *CartGrain, req *messages.SubscriptionAdded) error {

4
pkg/cart/mutation_test.go
View File

@@ -13,8 +13,8 @@ import (
"github.com/gogo/protobuf/proto" "github.com/gogo/protobuf/proto"
"google.golang.org/protobuf/types/known/anypb" "google.golang.org/protobuf/types/known/anypb"
"git.tornberg.me/go-cart-actor/pkg/actor" "git.k6n.net/go-cart-actor/pkg/actor"
messages "git.tornberg.me/go-cart-actor/pkg/messages" messages "git.k6n.net/go-cart-actor/pkg/messages"
) )
// ---------------------- // ----------------------

2
pkg/cart/mutation_upsert_subscriptiondetails.go
View File

@@ -4,7 +4,7 @@ import (
"encoding/json" "encoding/json"
"fmt" "fmt"
messages "git.tornberg.me/go-cart-actor/pkg/messages" messages "git.k6n.net/go-cart-actor/pkg/messages"
) )
func UpsertSubscriptionDetails(g *CartGrain, m *messages.UpsertSubscriptionDetails) error { func UpsertSubscriptionDetails(g *CartGrain, m *messages.UpsertSubscriptionDetails) error {

2
pkg/promotions/eval.go
View File

@@ -7,7 +7,7 @@ import (
"strings" "strings"
"time" "time"
"git.tornberg.me/go-cart-actor/pkg/cart" "git.k6n.net/go-cart-actor/pkg/cart"
) )
var errInvalidTimeFormat = errors.New("invalid time format") var errInvalidTimeFormat = errors.New("invalid time format")

2
pkg/promotions/eval_test.go
View File

@@ -6,7 +6,7 @@ import (
"testing" "testing"
"time" "time"
"git.tornberg.me/go-cart-actor/pkg/cart" "git.k6n.net/go-cart-actor/pkg/cart"
) )
// --- Helpers --------------------------------------------------------------- // --- Helpers ---------------------------------------------------------------

2
pkg/proxy/remotehost.go
View File

@@ -9,7 +9,7 @@ import (
"net/http" "net/http"
"time" "time"
messages "git.tornberg.me/go-cart-actor/pkg/messages" messages "git.k6n.net/go-cart-actor/pkg/messages"
"go.opentelemetry.io/contrib/bridges/otelslog" "go.opentelemetry.io/contrib/bridges/otelslog"
"go.opentelemetry.io/otel" "go.opentelemetry.io/otel"
"go.opentelemetry.io/otel/attribute" "go.opentelemetry.io/otel/attribute"

2
pkg/voucher/service.go
View File

@@ -6,7 +6,7 @@ import (
"fmt" "fmt"
"os" "os"
"git.tornberg.me/go-cart-actor/pkg/messages" "git.k6n.net/go-cart-actor/pkg/messages"
) )
type Rule struct { type Rule struct {

2
proto/control_plane.proto
View File

@@ -2,7 +2,7 @@ syntax = "proto3";
package messages; package messages;
option go_package = "git.tornberg.me/go-cart-actor/proto;messages"; option go_package = "git.k6n.net/go-cart-actor/proto;messages";
// ----------------------------------------------------------------------------- // -----------------------------------------------------------------------------
// Control Plane gRPC API // Control Plane gRPC API

2
proto/messages.proto
View File

@@ -1,6 +1,6 @@
syntax = "proto3"; syntax = "proto3";
package messages; package messages;
option go_package = "git.tornberg.me/go-cart-actor/proto;messages"; option go_package = "git.k6n.net/go-cart-actor/proto;messages";
import "google/protobuf/any.proto"; import "google/protobuf/any.proto";