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

Complete refactor to new grpc control plane and only http proxy for carts #4

Merged
mats merged 75 commits from refactor/http-proxy into main 2025-10-14 22:31:28 +02:00
Conversation 0 Commits 75 Files Changed 88 +3 -3
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit b029a9d05a - Show all commits

6
pkg/actor/mutation_registry.go
View File

@@ -12,7 +12,7 @@ import (
type ApplyResult struct { type ApplyResult struct {
Type string `json:"type"` Type string `json:"type"`
Mutation proto.Message `json:"mutation"` Mutation proto.Message `json:"mutation"`
Error error `json:"error,omitempty"` Error string `json:"error,omitempty"`
} }
type MutationRegistry interface { type MutationRegistry interface {
@@ -167,11 +167,11 @@ func (r *ProtoMutationRegistry) Apply(grain any, msg ...proto.Message) ([]ApplyR
entry, ok := r.mutationRegistry[rt] entry, ok := r.mutationRegistry[rt]
r.mutationRegistryMu.RUnlock() r.mutationRegistryMu.RUnlock()
if !ok { if !ok {
results = append(results, ApplyResult{Error: ErrMutationNotRegistered, Type: rt.Name(), Mutation: m}) results = append(results, ApplyResult{Error: ErrMutationNotRegistered.Error(), Type: rt.Name(), Mutation: m})
continue continue
} }
err := entry.Handle(grain, m) err := entry.Handle(grain, m)
results = append(results, ApplyResult{Error: err, Type: rt.Name(), Mutation: m}) results = append(results, ApplyResult{Error: err.Error(), Type: rt.Name(), Mutation: m})
} }
// if entry.updateTotals { // if entry.updateTotals {