diff options
| author | Sami Hiltunen <shiltunen@gitlab.com> | 2020-09-17 16:56:26 +0300 |
|---|---|---|
| committer | Zeger-Jan van de Weg <git@zjvandeweg.nl> | 2020-09-17 16:56:26 +0300 |
| commit | 9251df2df09fec0cd3600faa6178156fe9a84fe2 (patch) | |
| tree | 21024e23f7fc856dcb00ac7f7b01a1100b78ec89 /internal/praefect/auth_test.go | |
| parent | 974ed277520086b2a9c830fab11a3076234f13a9 (diff) | |
extract routing logic in to a separate component
Routing logic is currently not pluggable as it is part of the coordinator
and depends on the NodeManager. In preparation for variable replication
factor and per repository primary, this commit extracts the routing logic
in to a separate component which allows for plugging in alternative
implementation. There should be no behavior difference, except for eagerly
loading consistent secondaries on repository scoped mutators regardless of
whether transactions are enabled or not. This should be fine though as
transactions are enabled by default.
Diffstat (limited to 'internal/praefect/auth_test.go')
| -rw-r--r-- | internal/praefect/auth_test.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/internal/praefect/auth_test.go b/internal/praefect/auth_test.go index 055a1025d..27d19de5d 100644 --- a/internal/praefect/auth_test.go +++ b/internal/praefect/auth_test.go @@ -177,7 +177,7 @@ func runServer(t *testing.T, token string, required bool) (*grpc.Server, string, registry, err := protoregistry.New(fd) require.NoError(t, err) - coordinator := NewCoordinator(queue, rs, nodeMgr, txMgr, conf, registry) + coordinator := NewCoordinator(queue, rs, NewNodeManagerRouter(nodeMgr, rs), txMgr, conf, registry) srv := NewGRPCServer(conf, logEntry, registry, coordinator.StreamDirector, nodeMgr, txMgr, queue, rs) |