1 implementation of Resource
Aspire.Hosting.Native.Client (1)
Authoring\DistributedApplicationBuilder.cs (1)
193
public T
Resource
{ get; } = resource;
63 references to Resource
Aspire.Hosting.Native.Client (22)
Authoring\NativeApplication.cs (2)
286
if (!await _execution.WaitResourceCompletionAsync(_context.Declaration(resource.
Resource
), 60000, operation.Token).ConfigureAwait(false))
288
throw new InvalidOperationException($"The executable '{resource.
Resource
.Name}' failed.");
Authoring\Publishing.cs (5)
122
builder.ApplicationBuilder.Record(context => context.Declaration(builder.
Resource
)
123
.WithComputeEnvironmentAsync(context.Declaration(environment.
Resource
), context.Token));
142
var declaration = context.Declaration(builder.
Resource
);
162
await context.Declaration(builder.
Resource
).WithExternalHttpEndpointsAsync(context.Token).ConfigureAwait(false));
178
await context.Declaration(builder.
Resource
).WithBindMountAsync(source, target, readOnly, context.Token).ConfigureAwait(false));
Authoring\ResourceBuilderExtensions.cs (15)
20
context.BindConnection(resource.
Resource
, connection);
38
new(context => context.Parameter(parameter.
Resource
));
47
resource.ApplicationBuilder.Record(async context => await context.Declaration(resource.
Resource
)
74
resource.ApplicationBuilder.Record(async context => await context.Declaration(resource.
Resource
)
90
resource.ApplicationBuilder.Record(context => context.Declaration(resource.
Resource
).WithEndpointAsync(new()
103
new(resource.
Resource
, name);
111
resource.ApplicationBuilder.Record(context => context.Declaration(resource.
Resource
).WithEntrypointAsync(entrypoint, context.Token));
123
resource.ApplicationBuilder.Record(context => context.Declaration(resource.
Resource
).WithVolumeAsync(name, target, false, context.Token));
137
consumer.ApplicationBuilder.Record(async context => await context.Declaration(consumer.
Resource
)
138
.WithReferenceAsync($"ConnectionStrings__{producer.
Resource
.Name}",
139
await context.Value(context.Connection(producer.
Resource
)).ConfigureAwait(false), context.Token).ConfigureAwait(false));
153
consumer.ApplicationBuilder.Record(context => context.Declaration(consumer.
Resource
)
154
.WaitForAsync(context.Declaration(dependency.
Resource
), context.Token));
170
await context.Declaration(resource.
Resource
).SetSymbolicConfigurationAsync($"health.env.{name}",
173
await context.Declaration(resource.
Resource
).WithLifecycleExecutableAsync("health", captured.Launch(),
Aspire.Hosting.Native.Core.Tests (15)
NativeBuilderAuthoringTests.cs (14)
67
Assert.Equal(expected, first.GetDefaultDataVolumeName(cache.
Resource
));
71
Assert.Equal(expected, rerun.GetDefaultDataVolumeName(rerun.AddRedis("cache").WithDataVolume().
Resource
));
74
Assert.Equal(expected, revision.GetDefaultDataVolumeName(revision.AddRedis("cache").WithDataVolume().
Resource
));
79
other.GetDefaultDataVolumeName(other.AddRedis("cache").WithDataVolume().
Resource
));
82
var namedVolume = named.GetDefaultDataVolumeName(named.AddRedis("cache").WithDataVolume().
Resource
);
96
explicitPrefix.GetDefaultDataVolumeName(explicitPrefix.AddRedis("cache").WithDataVolume().
Resource
));
127
var volume = builder.GetDefaultDataVolumeName(cache.
Resource
);
171
Assert.IsType<RedisContainerResource>(cache.
Resource
);
172
Assert.IsType<ExecutableResource>(consumer.
Resource
);
177
Assert.False(typeof(NativeRemoteObject).IsAssignableFrom(cache.
Resource
.GetType()));
229
var consumerValues = (await bound.Declaration(consumer.
Resource
).InspectSymbolicConfigurationAsync()).Properties;
232
Assert.Empty((await bound.Declaration(waiter.
Resource
).InspectSymbolicConfigurationAsync()).Properties);
233
Assert.True((await bound.Declaration(cache.
Resource
).InspectSymbolicConfigurationAsync()).Properties
235
Assert.Equal("[native reference expression]", cache.
Resource
.ConnectionStringExpression.ToString());
NativeComposeCSharpTests.cs (1)
191
Assert.Equal("compose", target.Parent.
Resource
.Name);
NativeIntegrations.DockerCompose (22)
DockerComposeBuilderExtensions.cs (20)
36
!Strings(context.Model["parameters"]).Contains(parameter.
Resource
.Name, StringComparer.Ordinal))
40
var variable = ParameterVariable(parameter.
Resource
.Name);
42
if (Objects(parameters).Any(entry => Text(entry, "environmentVariable") == variable && Text(entry, "name") != parameter.
Resource
.Name))
46
if (!Objects(parameters).Any(entry => Text(entry, "name") == parameter.
Resource
.Name))
52
parameters.Add(new JsonObject { ["name"] = parameter.
Resource
.Name, ["environmentVariable"] = variable });
63
public string Name => environment.
Resource
.Name + "-dashboard";
70
environment.
Resource
.DashboardHostPort = port;
76
environment.
Resource
.DashboardForwardedHeaders = enabled;
80
public Uri PrimaryEndpoint => new($"http://{(environment.
Resource
.DashboardHostPort is null ? ServiceName(Name) : "127.0.0.1")}:{environment.
Resource
.DashboardHostPort ?? 18888}");
92
result.WithPublishConfiguration("dockerComposeEnvironment", result.
Resource
.Configuration);
99
state.Targets.Add(result.
Resource
, target);
142
if (!state.ServiceCallbacks.TryGetValue(builder.
Resource
, out var callbacks))
144
state.ServiceCallbacks.Add(builder.
Resource
, callbacks = []);
155
configure(builder.
Resource
);
163
builder.
Resource
.DashboardEnabled = enabled;
171
builder.
Resource
.DashboardEnabled = true;
184
builder.
Resource
.FileCallbacks.Add(configure);
193
builder.
Resource
.EnvironmentCallbacks.Add(configure);
203
Infrastructure(builder.ApplicationBuilder).Targets[builder.
Resource
].WithRunner(runner);
DockerComposeEnvironment.cs (2)
103
foreach (var configure in _builder!.
Resource
.FileCallbacks)
166
foreach (var configure in _builder.
Resource
.EnvironmentCallbacks)
NativeIntegrations.DockerCompose.AppHost.Sample (1)
Program.cs (1)
20
cache.WithVolume(builder.GetDefaultDataVolumeName(cache.
Resource
), "/data");
NativeIntegrations.Redis (3)
RedisContainerResource.cs (1)
20
string? name = null) => cache.WithVolume(name ?? cache.ApplicationBuilder.GetDefaultDataVolumeName(cache.
Resource
), "/data");
RedisExtensions.cs (2)
23
return new RedisResource(native.Declaration(cache.
Resource
),
24
await native.Value(cache.
Resource
.ConnectionStringExpression).ConfigureAwait(false));