102 references to String
Aspire.Hosting.Native.Server (102)
artifacts\obj\Aspire.Hosting.Native.Server\Debug\native-ats\NativeDispatch.g.cs (74)
30
var result = target.AddComputeEnvironment(RpcArguments.
String
(arguments["name"]), RpcArguments.
String
(arguments["typeId"]));
38
var result = target.AddConfiguredParameter(RpcArguments.
String
(arguments["name"]), RpcArguments.Boolean(arguments["secret"]), RpcArguments.Boolean(arguments["publishing"]));
46
var result = target.AddContainer(RpcArguments.
String
(arguments["name"]), RpcArguments.
String
(arguments["image"]));
54
var result = target.AddExecutable(RpcArguments.
String
(arguments["name"]), RpcArguments.
String
(arguments["executablePath"]), RpcArguments.
String
(arguments["workingDirectory"]));
62
var result = target.AddGeneratedParameter(RpcArguments.
String
(arguments["name"]), RpcArguments.
String
(arguments["options"]), RpcArguments.Boolean(arguments["secret"]));
70
var result = target.AddGeneratedSecretParameter(RpcArguments.
String
(arguments["name"]));
78
var result = target.AddParameterValue(RpcArguments.
String
(arguments["name"]), RpcArguments.
String
(arguments["value"]), RpcArguments.Boolean(arguments["secret"]), RpcArguments.Boolean(arguments["publishValueAsDefault"]));
86
var result = target.AddResource(RpcArguments.
String
(arguments["name"]), RpcArguments.
String
(arguments["typeId"]));
94
var result = target.AddSecretParameter(RpcArguments.
String
(arguments["name"]), RpcArguments.
String
(arguments["value"]));
101
target.AppendResourceLog(RpcArguments.
String
(arguments["stream"]), RpcArguments.
String
(arguments["message"]));
115
target.BeginPublishing(RpcArguments.
String
(arguments["target"]));
151
target.CompleteResourceCommand(RpcArguments.
String
(arguments["requestId"]), RpcArguments.Dto(arguments["result"], NativeRpcJsonContext.Default.RuntimeOperationResult));
173
target.ConfigurePublishing(RpcArguments.
String
(arguments["graphJson"]));
197
var result = target.CreateEndpointValue(handles.Get<DeclaredResource>(arguments["resource"], "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Api.DeclaredResource"), RpcArguments.
String
(arguments["endpointName"]), RpcArguments.
String
(arguments["property"]));
213
var result = target.CreateLiteralValue(RpcArguments.
String
(arguments["value"]));
228
target.DefineResourceCommand(RpcArguments.
String
(arguments["name"]), RpcArguments.
String
(arguments["displayName"]));
308
var result = target.InvokeResourceCommand(RpcArguments.
String
(arguments["resourceName"]), RpcArguments.
String
(arguments["commandName"]));
316
var result = target.JoinApplicationObserver(RpcArguments.
String
(arguments["invitation"]));
324
var result = target.JoinApplicationWorkspace(RpcArguments.
String
(arguments["invitation"]));
332
var result = target.JoinResourceExecution(RpcArguments.
String
(arguments["invitation"]));
396
var result = target.ReadResourceLogs(RpcArguments.
String
(arguments["resourceId"]), RpcArguments.Int64(arguments["afterSequence"]));
410
target.RemoveSymbolicConfiguration(RpcArguments.
String
(arguments["name"]));
417
target.ReportPublishingActivity(RpcArguments.
String
(arguments["step"]), RpcArguments.
String
(arguments["status"]), RpcArguments.Boolean(arguments["complete"]), RpcArguments.Boolean(arguments["failed"]));
424
target.ReportPublishingProgress(RpcArguments.
String
(arguments["step"]), RpcArguments.
String
(arguments["type"]), RpcArguments.
String
(arguments["id"]), RpcArguments.
String
(arguments["status"]), RpcArguments.Boolean(arguments["complete"]), RpcArguments.Boolean(arguments["failed"]), RpcArguments.Boolean(arguments["markdown"]));
432
var result = target.RequestConfirmation(RpcArguments.
String
(arguments["message"]));
439
target.RespondConfirmation(RpcArguments.
String
(arguments["requestId"]), RpcArguments.Boolean(arguments["accepted"]));
453
var result = await target.RestartContainerWithValues(RpcArguments.Int64(arguments["revision"]), RpcArguments.
String
(arguments["networkContext"]), RpcArguments.Dto(arguments["launch"], NativeRpcJsonContext.Default.ContainerWorkloadLaunch), RpcArguments.Dto(arguments["bindings"], NativeRpcJsonContext.Default.SymbolicLaunchBindings)).ConfigureAwait(false);
474
var result = await target.RestartExecutableWithValues(RpcArguments.Int64(arguments["revision"]), RpcArguments.
String
(arguments["networkContext"]), RpcArguments.Dto(arguments["launch"], NativeRpcJsonContext.Default.ExecutableWorkloadLaunch), RpcArguments.Dto(arguments["bindings"], NativeRpcJsonContext.Default.SymbolicLaunchBindings)).ConfigureAwait(false);
523
target.SetSymbolicConfiguration(RpcArguments.
String
(arguments["name"]), handles.Get<DeclaredValue>(arguments["value"], "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Api.DeclaredValue"));
545
var result = await target.StartContainerWithValues(RpcArguments.Int64(arguments["revision"]), RpcArguments.
String
(arguments["networkContext"]), RpcArguments.Dto(arguments["launch"], NativeRpcJsonContext.Default.ContainerWorkloadLaunch), RpcArguments.Dto(arguments["bindings"], NativeRpcJsonContext.Default.SymbolicLaunchBindings)).ConfigureAwait(false);
566
var result = await target.StartExecutableWithValues(RpcArguments.Int64(arguments["revision"]), RpcArguments.
String
(arguments["networkContext"]), RpcArguments.Dto(arguments["launch"], NativeRpcJsonContext.Default.ExecutableWorkloadLaunch), RpcArguments.Dto(arguments["bindings"], NativeRpcJsonContext.Default.SymbolicLaunchBindings)).ConfigureAwait(false);
653
var result = target.WithBindMount(RpcArguments.
String
(arguments["source"]), RpcArguments.
String
(arguments["target"]), RpcArguments.Boolean(arguments["readOnly"]));
676
var result = target.WithEntrypoint(RpcArguments.
String
(arguments["entrypoint"]));
684
var result = target.WithEnvironment(RpcArguments.
String
(arguments["name"]), handles.Get<DeclaredValue>(arguments["value"], "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Api.DeclaredValue"));
700
var result = target.WithLifecycleExecutable(RpcArguments.
String
(arguments["phase"]), RpcArguments.Dto(arguments["launch"], NativeRpcJsonContext.Default.ExecutableWorkloadLaunch), RpcArguments.Dto(arguments["bindings"], NativeRpcJsonContext.Default.SymbolicLaunchBindings));
708
var result = target.WithReference(RpcArguments.
String
(arguments["environmentName"]), handles.Get<DeclaredValue>(arguments["value"], "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Api.DeclaredValue"));
716
var result = target.WithVolume(RpcArguments.
String
(arguments["name"]), RpcArguments.
String
(arguments["target"]), RpcArguments.Boolean(arguments["readOnly"]));
723
target.WriteLifecycleLog(RpcArguments.
String
(arguments["stream"]), RpcArguments.
String
(arguments["message"]));
738
var result = target.AddContainer(RpcArguments.
String
(arguments["name"]), RpcArguments.
String
(arguments["image"]));
746
var result = target.AddExecutable(RpcArguments.
String
(arguments["name"]), RpcArguments.
String
(arguments["executablePath"]), RpcArguments.
String
(arguments["workingDirectory"]));
754
var result = target.AddSecretParameter(RpcArguments.
String
(arguments["name"]), RpcArguments.
String
(arguments["value"]));
770
var result = target.GetEndpoint(RpcArguments.
String
(arguments["name"]));
784
var result = target.GetSerializedAnnotation(RpcArguments.
String
(arguments["annotationId"]));
792
var result = target.Property(RpcArguments.
String
(arguments["property"]));
806
target.Set(RpcArguments.
String
(arguments["name"]), RpcArguments.Union(arguments["value"], handles, ["Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Api.DeclaredValue", "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Authoring.RpcEndpoint", "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Authoring.RpcResource"]));
829
var result = await target.WithArgsCallback(connection.CreateAuthoringCallback<RpcArgsEditor>(callbackConnection, RpcArguments.
String
(arguments["callback"]), "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Authoring.RpcArgsEditor")).ConfigureAwait(false);
853
var result = target.WithEnvironment(RpcArguments.
String
(arguments["name"]), RpcArguments.Union(arguments["value"], handles, ["Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Api.DeclaredValue", "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Authoring.RpcEndpoint", "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Authoring.RpcResource"]));
860
var result = await target.WithEnvironmentCallback(connection.CreateAuthoringCallback<RpcEnvironmentEditor>(callbackConnection, RpcArguments.
String
(arguments["callback"]), "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Authoring.RpcEnvironmentEditor")).ConfigureAwait(false);
868
var result = target.WithImageTag(RpcArguments.
String
(arguments["tag"]));
884
var result = target.WithSerializedAnnotation(RpcArguments.
String
(arguments["annotationId"]), RpcArguments.
String
(arguments["json"]));
Rpc\NativeHandles.cs (4)
52
var id = RpcArguments.
String
(reference["$handle"]);
53
var typeId = RpcArguments.
String
(reference["$type"]);
69
var id = RpcArguments.
String
(reference["$handle"]);
70
var typeId = RpcArguments.
String
(reference["$type"]);
Rpc\NativeProviderMetadata.cs (6)
50
result[index] = new(RpcArguments.
String
(metadata["id"]), RpcArguments.
String
(metadata["method"]),
64
var name = RpcArguments.
String
(argument["name"]);
91
new(RpcArguments.
String
(type["typeId"]), RpcArguments.
String
(type["category"]) switch
100
metadata[name] is { } value ? RpcArguments.
String
(value) : null;
Rpc\NativeProviderRegistry.cs (2)
222
var callbackId = RpcArguments.
String
(arguments[name]);
344
RpcArguments.
String
(handle["$type"]));
Rpc\NativeProviderValueProtocol.cs (3)
16
case NativeProviderValueKind.String: _ = RpcArguments.
String
(value); return;
31
var id = RpcArguments.
String
(handle["$handle"]);
32
if (id.Length is 0 or > 512 || RpcArguments.
String
(handle["$type"]) != type.TypeId)
Rpc\NativeRpcConnection.cs (2)
76
DelegatedCoreReference delegated => (delegated.Owner, RpcArguments.
String
(delegated.Handle["$handle"]), typeId),
77
ProviderResourceReference resource => (resource.Provider.Connection, RpcArguments.
String
(resource.Handle["$handle"]), typeId),
Rpc\NativeRpcConnection.Dispatch.cs (9)
18
var supplied = Encoding.UTF8.GetBytes(RpcArguments.
String
(authentication[0]));
76
? _languages.RuntimeSpec(RpcArguments.
String
(arguments[0]))
77
: _languages.GeneratedSdk(RpcArguments.
String
(arguments[0]));
86
var capabilityId = RpcArguments.
String
(arguments[0]);
117
return JsonValue.Create(_providers.Expect(this, RpcArguments.
String
(expectation[0])));
123
await _providers.RegisterAsync(this, RpcArguments.
String
(registration[0]), _peer).ConfigureAwait(false);
130
await _providers.WaitRegistrationAsync(this, RpcArguments.
String
(activation[0])).ConfigureAwait(false);
137
return JsonValue.Create(_providers.AbandonRegistration(this, RpcArguments.
String
(abandonment[0])));
143
return await _providers.InvokeCallbackAsync(this, RpcArguments.
String
(callback[0]), callbackArguments).ConfigureAwait(false);
Rpc\RpcArguments.cs (2)
35
? array.Select(
String
).ToArray()
44
if (value is JsonObject reference && typeIds.Contains(
String
(reference["$type"]), StringComparer.Ordinal))