19 references to Upsert
Aspire.Hosting (4)
Dashboard\DashboardService.cs (1)
319
if (update.ChangeType is ResourceSnapshotChangeType.
Upsert
)
Dashboard\DashboardServiceData.cs (1)
107
await _resourcePublisher.IntegrateAsync(@event.Resource, snapshot, ResourceSnapshotChangeType.
Upsert
)
Dashboard\ResourcePublisher.cs (1)
92
case ResourceSnapshotChangeType.
Upsert
:
Dcp\DcpResourceWatcher.cs (1)
285
WatchEventType.Added or WatchEventType.Modified => ResourceSnapshotChangeType.
Upsert
,
Aspire.Hosting.Tests (15)
Dashboard\ResourcePublisherTests.cs (15)
42
await publisher.IntegrateAsync(new TestResource("A"), a, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
43
await publisher.IntegrateAsync(new TestResource("B"), b, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
65
await publisher.IntegrateAsync(new TestResource("C"), c, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
68
Assert.Equal(ResourceSnapshotChangeType.
Upsert
, change.ChangeType);
95
await publisher.IntegrateAsync(new TestResource("A"), a, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
96
await publisher.IntegrateAsync(new TestResource("B"), b, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
108
await publisher.IntegrateAsync(new TestResource("C"), c, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
119
Assert.Equal(ResourceSnapshotChangeType.
Upsert
, v1.ChangeType);
120
Assert.Equal(ResourceSnapshotChangeType.
Upsert
, v2.ChangeType);
142
await publisher.IntegrateAsync(new TestResource("A"), a1, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
143
await publisher.IntegrateAsync(new TestResource("A"), a2, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
144
await publisher.IntegrateAsync(new TestResource("A"), a3, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
162
await publisher.IntegrateAsync(new TestResource("A"), a, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
163
await publisher.IntegrateAsync(new TestResource("B"), b, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
196
await publisher.IntegrateAsync(new TestResource("A"), CreateResourceSnapshot("A"), ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();