19 references to Upsert
Aspire.Hosting (4)
Dashboard\DashboardService.cs (1)
248
if (update.ChangeType is ResourceSnapshotChangeType.
Upsert
)
Dashboard\DashboardServiceData.cs (1)
79
await _resourcePublisher.IntegrateAsync(@event.Resource, snapshot, ResourceSnapshotChangeType.
Upsert
)
Dashboard\ResourcePublisher.cs (1)
92
case ResourceSnapshotChangeType.
Upsert
:
Dcp\DcpExecutor.cs (1)
367
WatchEventType.Added or WatchEventType.Modified => ResourceSnapshotChangeType.
Upsert
,
Aspire.Hosting.Tests (15)
Dashboard\ResourcePublisherTests.cs (15)
22
await publisher.IntegrateAsync(new TestResource("A"), a, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
23
await publisher.IntegrateAsync(new TestResource("B"), b, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
45
await publisher.IntegrateAsync(new TestResource("C"), c, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
48
Assert.Equal(ResourceSnapshotChangeType.
Upsert
, change.ChangeType);
75
await publisher.IntegrateAsync(new TestResource("A"), a, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
76
await publisher.IntegrateAsync(new TestResource("B"), b, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
88
await publisher.IntegrateAsync(new TestResource("C"), c, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
99
Assert.Equal(ResourceSnapshotChangeType.
Upsert
, v1.ChangeType);
100
Assert.Equal(ResourceSnapshotChangeType.
Upsert
, v2.ChangeType);
122
await publisher.IntegrateAsync(new TestResource("A"), a1, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
123
await publisher.IntegrateAsync(new TestResource("A"), a2, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
124
await publisher.IntegrateAsync(new TestResource("A"), a3, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
142
await publisher.IntegrateAsync(new TestResource("A"), a, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
143
await publisher.IntegrateAsync(new TestResource("B"), b, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
176
await publisher.IntegrateAsync(new TestResource("A"), CreateResourceSnapshot("A"), ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();