diff options
| author | Pavlo Strokov <pstrokov@gitlab.com> | 2020-03-27 07:25:52 +0300 |
|---|---|---|
| committer | Paul Okstad <pokstad@gitlab.com> | 2020-03-27 07:25:52 +0300 |
| commit | a98b52ec08cffd61cd41bcc53761d54ef360ecee (patch) | |
| tree | 914cad6d1e7fc7aa0d25ddc9d6e6c4ba448ba3e3 /internal/praefect/auth_test.go | |
| parent | 5cad7eb778160c81aa9a8755ec991030266bb4d5 (diff) | |
Praefect: replication event queue as a primary storage of events
Replication storage interface switched to `ReplicationEventQueue`.
`gitaly_replication_queue` table extended with `meta` column
introduced as a container for meta information such as correlation
ID, etc.
`memoryReplicationEventQueue` now populates `LockID` field to
produce same result as SQL impl.
`ReplicationEventQueueInterceptor` introduced for testing purposes
as well as an interceptor for metrics, etc.
`slice` package created to assemble common operation on different
kind of slices (`Uint64` is first one).
Part of: https://gitlab.com/gitlab-org/gitaly/-/issues/2166
Diffstat (limited to 'internal/praefect/auth_test.go')
| -rw-r--r-- | internal/praefect/auth_test.go | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/internal/praefect/auth_test.go b/internal/praefect/auth_test.go index 0229590a0..3831b60f8 100644 --- a/internal/praefect/auth_test.go +++ b/internal/praefect/auth_test.go @@ -189,7 +189,10 @@ func runServer(t *testing.T, token string, required bool) (*Server, string, func } logEntry := testhelper.DiscardTestEntry(t) - ds := datastore.NewInMemory(conf) + ds := datastore.MemoryQueue{ + MemoryDatastore: datastore.NewInMemory(conf), + ReplicationEventQueue: datastore.NewMemoryReplicationEventQueue(), + } nodeMgr, err := nodes.NewManager(logEntry, conf, promtest.NewMockHistogramVec()) require.NoError(t, err) |