Complete refactor to new grpc control plane and only http proxy for carts #4
@@ -154,7 +154,7 @@ func (r *ProtoMutationRegistry) Apply(grain any, msg ...proto.Message) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
for _, m := range msg {
|
for _, m := range msg {
|
||||||
rt := indirectType(reflect.TypeOf(msg))
|
rt := indirectType(reflect.TypeOf(m))
|
||||||
r.mutationRegistryMu.RLock()
|
r.mutationRegistryMu.RLock()
|
||||||
entry, ok := r.mutationRegistry[rt]
|
entry, ok := r.mutationRegistry[rt]
|
||||||
r.mutationRegistryMu.RUnlock()
|
r.mutationRegistryMu.RUnlock()
|
||||||
|
|||||||
Reference in New Issue
Block a user