DcpResourceCollection

42 references to DcpResourceCollection

Aspire.Hosting.Native.Core.Tests (12)

DcpJsonTests.cs (1)

38await client.CreateAsync(DcpResourceCollection.Containers, "test-worker",

DcpResponseTests.cs (9)

43var resource = await client.GetAsync(DcpResourceCollection.Executables, "job", TestContext.Current.CancellationToken); 58Assert.Empty(await client.ReadLogsAsync(DcpResourceCollection.Executables, "job", LogStream.Stdout, 0, TestContext.Current.CancellationToken)); 62Assert.Equal(new DcpResource(null), await client.GetAsync(DcpResourceCollection.Executables, "job", TestContext.Current.CancellationToken)); 69await client.ReadLogsAsync(DcpResourceCollection.Executables, "job", LogStream.Stdout, 0, TestContext.Current.CancellationToken); 73await client.GetAsync(DcpResourceCollection.Executables, "job", TestContext.Current.CancellationToken); 85client.GetAsync(DcpResourceCollection.Executables, "job", TestContext.Current.CancellationToken)); 94await client.ReadLogsAsync(DcpResourceCollection.Executables, "job", LogStream.Stdout, 0, TestContext.Current.CancellationToken)); 103Assert.Equal([line], await client.ReadLogsAsync(DcpResourceCollection.Executables, "job", LogStream.Stdout, 0, 116await client.DeleteAsync(DcpResourceCollection.Executables, "job", TestContext.Current.CancellationToken);

NativeTimeProviderTests.cs (2)

274? (Task)client.ReadLogsAsync(DcpResourceCollection.Containers, "cache", LogStream.Stdout, 0, TestContext.Current.CancellationToken) 275: client.GetAsync(DcpResourceCollection.Containers, "cache", TestContext.Current.CancellationToken);

Aspire.Hosting.Native.Server (30)

Dashboard\DcpDashboard.cs (6)

34await client.CreateAsync(DcpResourceCollection.Services, service, JsonSerializer.SerializeToElement( 37await client.CreateAsync(DcpResourceCollection.Executables, name, JsonSerializer.SerializeToElement(spec, DcpJsonContext.Default.DcpWorkloadSpec), 50var process = await client.GetAsync(DcpResourceCollection.Executables, name, cancellationToken).ConfigureAwait(false) 56var allocation = await client.GetAsync(DcpResourceCollection.Services, service, cancellationToken).ConfigureAwait(false); 102await client.DeleteAsync(DcpResourceCollection.Executables, _name, cancellationToken).ConfigureAwait(false); 106await client.DeleteAsync(DcpResourceCollection.Services, _service, cancellationToken).ConfigureAwait(false);

Dcp\DcpApiClient.cs (4)

117public async Task<DcpResource?> GetAsync(DcpResourceCollection collection, string name, CancellationToken cancellationToken) 123public async Task CreateAsync(DcpResourceCollection collection, string name, JsonElement spec, Dictionary<string, string>? annotations, 133public async Task DeleteAsync(DcpResourceCollection collection, string name, CancellationToken cancellationToken) 143public async Task<string[]> ReadLogsAsync(DcpResourceCollection collection, string name, LogStream source, long offset, CancellationToken cancellationToken)

Dcp\DcpStates.cs (8)

37public static string ToPath(this DcpResourceCollection collection) => collection switch 39DcpResourceCollection.Containers => "containers", 40DcpResourceCollection.Executables => "executables", 41DcpResourceCollection.Services => "services", 45public static string ToKind(this DcpResourceCollection collection) => collection switch 47DcpResourceCollection.Containers => "Container", 48DcpResourceCollection.Executables => "Executable", 49DcpResourceCollection.Services => "Service",

Dcp\DcpWorkloadExecutor.cs (12)

38var collection = template is ContainerWorkload ? DcpResourceCollection.Containers : DcpResourceCollection.Executables; 49await client.CreateAsync(DcpResourceCollection.Services, services[index], JsonSerializer.SerializeToElement( 60var service = await client.GetAsync(DcpResourceCollection.Services, services[index], cancellationToken).ConfigureAwait(false); 98var collection = plan is ContainerWorkload ? DcpResourceCollection.Containers : DcpResourceCollection.Executables; 114await client.CreateAsync(DcpResourceCollection.Services, services[index], JsonSerializer.SerializeToElement( 196var endpoint = await client.GetAsync(DcpResourceCollection.Services, services[index], cancellationToken).ConfigureAwait(false); 243DcpApiClient client, DcpResourceCollection collection, string name, string[] services, 300await client.DeleteAsync(DcpResourceCollection.Services, service, cleanup.Token).ConfigureAwait(false);