Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 1 addition & 5 deletions src/EventStore.ClusterNode/ClusterVNodeHostedService.cs
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,6 @@
using EventStore.Core.LogAbstraction;
using EventStore.Core.PluginModel;
using EventStore.Core.Services.PersistentSubscription.ConsumerStrategy;
using EventStore.Core.Services.Storage.InMemory;
using EventStore.PluginHosting;
using EventStore.Plugins;
using EventStore.Plugins.Authentication;
Expand Down Expand Up @@ -125,10 +124,7 @@ public ClusterVNodeHostedService(
Node = ClusterVNode.Create(_options, logFormatFactory, GetAuthenticationProviderFactory(),
authProviderFactory,
GetPersistentSubscriptionConsumerStrategyFactories(), certificateProvider,
configuration,
additionalVirtualStreamReaders: _options.PlugableComponents
.OfType<IVirtualStreamReaderProvider>()
.GetVirtualStreamReaders());
configuration);

EnabledNodeSubsystems = projectionMode >= ProjectionType.System
? new[] { NodeSubsystems.Projections }
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -357,8 +357,6 @@ private sealed class StubVirtualStreamReader : IVirtualStreamReader

public long GetLastEventNumber(string streamId) => ExpectedVersion.NoStream;

public long GetLastIndexedPosition(string streamId) => -1;

public bool CanReadStream(string streamId) => false;
}
}

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -402,12 +402,11 @@ public async Task read_forwards_uses_the_reader_that_claims_the_stream()
[Fact]
public void metadata_uses_the_reader_that_claims_the_stream()
{
var firstReader = new FakeVirtualStreamReader(FirstStream, lastEventNumber: 10, lastIndexedPosition: 100);
var secondReader = new FakeVirtualStreamReader(SecondStream, lastEventNumber: 20, lastIndexedPosition: 200);
var firstReader = new FakeVirtualStreamReader(FirstStream, lastEventNumber: 10);
var secondReader = new FakeVirtualStreamReader(SecondStream, lastEventNumber: 20);
var sut = new VirtualStreamReader([firstReader, secondReader]);

Assert.Equal(20, sut.GetLastEventNumber(SecondStream));
Assert.Equal(200, sut.GetLastIndexedPosition(SecondStream));
}

[Fact]
Expand All @@ -429,8 +428,7 @@ public async Task earlier_reader_wins_when_more_than_one_reader_claims_the_strea

private sealed class FakeVirtualStreamReader(
string streamId,
long lastEventNumber,
long lastIndexedPosition = -1) : IVirtualStreamReader
long lastEventNumber) : IVirtualStreamReader
{
public int ForwardReadCount { get; private set; }

Expand All @@ -452,7 +450,7 @@ private sealed class FakeVirtualStreamReader(
nextEventNumber: lastEventNumber + 1,
lastEventNumber: lastEventNumber,
isEndOfStream: true,
tfLastCommitPosition: lastIndexedPosition));
tfLastCommitPosition: -1));
}

public ValueTask<ClientMessage.ReadStreamEventsBackwardCompleted> ReadBackwards(
Expand All @@ -471,12 +469,10 @@ private sealed class FakeVirtualStreamReader(
nextEventNumber: -1,
lastEventNumber: lastEventNumber,
isEndOfStream: true,
tfLastCommitPosition: lastIndexedPosition));
tfLastCommitPosition: -1));

public long GetLastEventNumber(string streamId) => lastEventNumber;

public long GetLastIndexedPosition(string streamId) => lastIndexedPosition;

public bool CanReadStream(string candidate) => candidate == streamId;
}
}

This file was deleted.

This file was deleted.

Loading
Loading