fix(audit): M5 integration — add BackfillSourceNodeAsync to 5 test stubs (M5.5+M5.6 interface collision after cherry-pick recovery)
This commit is contained in:
@@ -220,6 +220,10 @@ public class AuditLogIngestActorTests : TestKit, IClassFixture<MsSqlMigrationFix
|
|||||||
string channel, DateTime threshold, int batchSize, CancellationToken ct = default) =>
|
string channel, DateTime threshold, int batchSize, CancellationToken ct = default) =>
|
||||||
_inner.PurgeChannelOlderThanAsync(channel, threshold, batchSize, ct);
|
_inner.PurgeChannelOlderThanAsync(channel, threshold, batchSize, ct);
|
||||||
|
|
||||||
|
public Task<long> BackfillSourceNodeAsync(
|
||||||
|
string sentinel, DateTime before, int batchSize, CancellationToken ct = default) =>
|
||||||
|
_inner.BackfillSourceNodeAsync(sentinel, before, batchSize, ct);
|
||||||
|
|
||||||
public Task<IReadOnlyList<DateTime>> GetPartitionBoundariesOlderThanAsync(
|
public Task<IReadOnlyList<DateTime>> GetPartitionBoundariesOlderThanAsync(
|
||||||
DateTime threshold, CancellationToken ct = default) =>
|
DateTime threshold, CancellationToken ct = default) =>
|
||||||
_inner.GetPartitionBoundariesOlderThanAsync(threshold, ct);
|
_inner.GetPartitionBoundariesOlderThanAsync(threshold, ct);
|
||||||
|
|||||||
@@ -93,6 +93,10 @@ public class AuditLogPurgeActorTests : TestKit, IClassFixture<MsSqlMigrationFixt
|
|||||||
return Task.FromResult(RowsPerChannel(channel));
|
return Task.FromResult(RowsPerChannel(channel));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public Task<long> BackfillSourceNodeAsync(
|
||||||
|
string sentinel, DateTime before, int batchSize, CancellationToken ct = default) =>
|
||||||
|
Task.FromResult(0L);
|
||||||
|
|
||||||
public Task<ZB.MOM.WW.ScadaBridge.Commons.Types.AuditLogKpiSnapshot> GetKpiSnapshotAsync(
|
public Task<ZB.MOM.WW.ScadaBridge.Commons.Types.AuditLogKpiSnapshot> GetKpiSnapshotAsync(
|
||||||
TimeSpan window, DateTime? nowUtc = null, CancellationToken ct = default) =>
|
TimeSpan window, DateTime? nowUtc = null, CancellationToken ct = default) =>
|
||||||
Task.FromResult(new ZB.MOM.WW.ScadaBridge.Commons.Types.AuditLogKpiSnapshot(0L, 0L, 0L, nowUtc ?? DateTime.UtcNow));
|
Task.FromResult(new ZB.MOM.WW.ScadaBridge.Commons.Types.AuditLogKpiSnapshot(0L, 0L, 0L, nowUtc ?? DateTime.UtcNow));
|
||||||
|
|||||||
@@ -47,6 +47,9 @@ public class CentralAuditWriteFailuresTests : TestKit
|
|||||||
public Task<long> PurgeChannelOlderThanAsync(
|
public Task<long> PurgeChannelOlderThanAsync(
|
||||||
string channel, DateTime threshold, int batchSize, CancellationToken ct = default) =>
|
string channel, DateTime threshold, int batchSize, CancellationToken ct = default) =>
|
||||||
Task.FromResult(0L);
|
Task.FromResult(0L);
|
||||||
|
public Task<long> BackfillSourceNodeAsync(
|
||||||
|
string sentinel, DateTime before, int batchSize, CancellationToken ct = default) =>
|
||||||
|
Task.FromResult(0L);
|
||||||
public Task<IReadOnlyList<DateTime>> GetPartitionBoundariesOlderThanAsync(
|
public Task<IReadOnlyList<DateTime>> GetPartitionBoundariesOlderThanAsync(
|
||||||
DateTime threshold, CancellationToken ct = default) =>
|
DateTime threshold, CancellationToken ct = default) =>
|
||||||
Task.FromResult<IReadOnlyList<DateTime>>(Array.Empty<DateTime>());
|
Task.FromResult<IReadOnlyList<DateTime>>(Array.Empty<DateTime>());
|
||||||
|
|||||||
+4
@@ -93,6 +93,10 @@ public class SiteAuditReconciliationActorTests : TestKit, IClassFixture<MsSqlMig
|
|||||||
string channel, DateTime threshold, int batchSize, CancellationToken ct = default) =>
|
string channel, DateTime threshold, int batchSize, CancellationToken ct = default) =>
|
||||||
Task.FromResult(0L);
|
Task.FromResult(0L);
|
||||||
|
|
||||||
|
public Task<long> BackfillSourceNodeAsync(
|
||||||
|
string sentinel, DateTime before, int batchSize, CancellationToken ct = default) =>
|
||||||
|
Task.FromResult(0L);
|
||||||
|
|
||||||
public Task<IReadOnlyList<DateTime>> GetPartitionBoundariesOlderThanAsync(
|
public Task<IReadOnlyList<DateTime>> GetPartitionBoundariesOlderThanAsync(
|
||||||
DateTime threshold, CancellationToken ct = default) =>
|
DateTime threshold, CancellationToken ct = default) =>
|
||||||
Task.FromResult<IReadOnlyList<DateTime>>(Array.Empty<DateTime>());
|
Task.FromResult<IReadOnlyList<DateTime>>(Array.Empty<DateTime>());
|
||||||
|
|||||||
@@ -93,6 +93,10 @@ public class SiteAuditPushFlowTests : TestKit
|
|||||||
string channel, DateTime threshold, int batchSize, CancellationToken ct = default)
|
string channel, DateTime threshold, int batchSize, CancellationToken ct = default)
|
||||||
=> throw new NotSupportedException();
|
=> throw new NotSupportedException();
|
||||||
|
|
||||||
|
public Task<long> BackfillSourceNodeAsync(
|
||||||
|
string sentinel, DateTime before, int batchSize, CancellationToken ct = default)
|
||||||
|
=> throw new NotSupportedException();
|
||||||
|
|
||||||
public Task<IReadOnlyList<DateTime>> GetPartitionBoundariesOlderThanAsync(
|
public Task<IReadOnlyList<DateTime>> GetPartitionBoundariesOlderThanAsync(
|
||||||
DateTime threshold, CancellationToken ct = default)
|
DateTime threshold, CancellationToken ct = default)
|
||||||
=> throw new NotSupportedException();
|
=> throw new NotSupportedException();
|
||||||
|
|||||||
Reference in New Issue
Block a user