19 references to Upsert
Aspire.Hosting (4)
Dashboard\DashboardService.cs (1)
282
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)
494
WatchEventType.Added or WatchEventType.Modified => ResourceSnapshotChangeType.
Upsert
,
Aspire.Hosting.Tests (15)
Dashboard\ResourcePublisherTests.cs (15)
23
await publisher.IntegrateAsync(new TestResource("A"), a, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
24
await publisher.IntegrateAsync(new TestResource("B"), b, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
46
await publisher.IntegrateAsync(new TestResource("C"), c, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
49
Assert.Equal(ResourceSnapshotChangeType.
Upsert
, change.ChangeType);
76
await publisher.IntegrateAsync(new TestResource("A"), a, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
77
await publisher.IntegrateAsync(new TestResource("B"), b, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
89
await publisher.IntegrateAsync(new TestResource("C"), c, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
100
Assert.Equal(ResourceSnapshotChangeType.
Upsert
, v1.ChangeType);
101
Assert.Equal(ResourceSnapshotChangeType.
Upsert
, v2.ChangeType);
123
await publisher.IntegrateAsync(new TestResource("A"), a1, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
124
await publisher.IntegrateAsync(new TestResource("A"), a2, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
125
await publisher.IntegrateAsync(new TestResource("A"), a3, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
143
await publisher.IntegrateAsync(new TestResource("A"), a, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
144
await publisher.IntegrateAsync(new TestResource("B"), b, ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();
177
await publisher.IntegrateAsync(new TestResource("A"), CreateResourceSnapshot("A"), ResourceSnapshotChangeType.
Upsert
).DefaultTimeout();