288 references to RpcArguments
Aspire.Hosting.Native.Server (288)
artifacts\obj\Aspire.Hosting.Native.Server\Debug\native-ats\NativeDispatch.g.cs (254)
20
RpcArguments
.Validate(arguments, ["context", "revision"]);
27
RpcArguments
.Validate(arguments, ["context", "name", "typeId"]);
30
var result = target.AddComputeEnvironment(
RpcArguments
.String(arguments["name"]),
RpcArguments
.String(arguments["typeId"]));
35
RpcArguments
.Validate(arguments, ["context", "name", "secret", "publishing"]);
38
var result = target.AddConfiguredParameter(
RpcArguments
.String(arguments["name"]),
RpcArguments
.Boolean(arguments["secret"]),
RpcArguments
.Boolean(arguments["publishing"]));
43
RpcArguments
.Validate(arguments, ["context", "name", "image"]);
46
var result = target.AddContainer(
RpcArguments
.String(arguments["name"]),
RpcArguments
.String(arguments["image"]));
51
RpcArguments
.Validate(arguments, ["context", "name", "executablePath", "workingDirectory"]);
54
var result = target.AddExecutable(
RpcArguments
.String(arguments["name"]),
RpcArguments
.String(arguments["executablePath"]),
RpcArguments
.String(arguments["workingDirectory"]));
59
RpcArguments
.Validate(arguments, ["context", "name", "options", "secret"]);
62
var result = target.AddGeneratedParameter(
RpcArguments
.String(arguments["name"]),
RpcArguments
.String(arguments["options"]),
RpcArguments
.Boolean(arguments["secret"]));
67
RpcArguments
.Validate(arguments, ["context", "name"]);
70
var result = target.AddGeneratedSecretParameter(
RpcArguments
.String(arguments["name"]));
75
RpcArguments
.Validate(arguments, ["context", "name", "value", "secret", "publishValueAsDefault"]);
78
var result = target.AddParameterValue(
RpcArguments
.String(arguments["name"]),
RpcArguments
.String(arguments["value"]),
RpcArguments
.Boolean(arguments["secret"]),
RpcArguments
.Boolean(arguments["publishValueAsDefault"]));
83
RpcArguments
.Validate(arguments, ["context", "name", "typeId"]);
86
var result = target.AddResource(
RpcArguments
.String(arguments["name"]),
RpcArguments
.String(arguments["typeId"]));
91
RpcArguments
.Validate(arguments, ["context", "name", "value"]);
94
var result = target.AddSecretParameter(
RpcArguments
.String(arguments["name"]),
RpcArguments
.String(arguments["value"]));
99
RpcArguments
.Validate(arguments, ["context", "stream", "message"]);
101
target.AppendResourceLog(
RpcArguments
.String(arguments["stream"]),
RpcArguments
.String(arguments["message"]));
106
RpcArguments
.Validate(arguments, ["context"]);
113
RpcArguments
.Validate(arguments, ["context", "target"]);
115
target.BeginPublishing(
RpcArguments
.String(arguments["target"]));
120
RpcArguments
.Validate(arguments, ["context"]);
128
RpcArguments
.Validate(arguments, ["context"]);
135
RpcArguments
.Validate(arguments, ["context", "revision"]);
142
RpcArguments
.Validate(arguments, ["context", "failed"]);
144
target.CompletePublishing(
RpcArguments
.Boolean(arguments["failed"]));
149
RpcArguments
.Validate(arguments, ["context", "requestId", "result"]);
151
target.CompleteResourceCommand(
RpcArguments
.String(arguments["requestId"]),
RpcArguments
.Dto(arguments["result"], NativeRpcJsonContext.Default.RuntimeOperationResult));
156
RpcArguments
.Validate(arguments, ["context", "revision", "result"]);
158
target.CompleteResourceConfiguration(
RpcArguments
.Int64(arguments["revision"]),
RpcArguments
.Dto(arguments["result"], NativeRpcJsonContext.Default.RuntimeOperationResult));
163
RpcArguments
.Validate(arguments, ["context", "suffix"]);
171
RpcArguments
.Validate(arguments, ["context", "graphJson"]);
173
target.ConfigurePublishing(
RpcArguments
.String(arguments["graphJson"]));
178
RpcArguments
.Validate(arguments, ["context"]);
186
RpcArguments
.Validate(arguments, ["context"]);
194
RpcArguments
.Validate(arguments, ["context", "resource", "endpointName", "property"]);
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"]));
202
RpcArguments
.Validate(arguments, ["context"]);
210
RpcArguments
.Validate(arguments, ["context", "value"]);
213
var result = target.CreateLiteralValue(
RpcArguments
.String(arguments["value"]));
218
RpcArguments
.Validate(arguments, ["context"]);
226
RpcArguments
.Validate(arguments, ["context", "name", "displayName"]);
228
target.DefineResourceCommand(
RpcArguments
.String(arguments["name"]),
RpcArguments
.String(arguments["displayName"]));
233
RpcArguments
.Validate(arguments, ["context"]);
241
RpcArguments
.Validate(arguments, ["context"]);
248
RpcArguments
.Validate(arguments, ["context"]);
256
RpcArguments
.Validate(arguments, ["context"]);
263
RpcArguments
.Validate(arguments, ["context"]);
270
RpcArguments
.Validate(arguments, ["context"]);
277
RpcArguments
.Validate(arguments, ["context"]);
284
RpcArguments
.Validate(arguments, ["context"]);
291
RpcArguments
.Validate(arguments, ["context"]);
298
RpcArguments
.Validate(arguments, ["context", "resource"]);
305
RpcArguments
.Validate(arguments, ["context", "resourceName", "commandName"]);
308
var result = target.InvokeResourceCommand(
RpcArguments
.String(arguments["resourceName"]),
RpcArguments
.String(arguments["commandName"]));
313
RpcArguments
.Validate(arguments, ["context", "invitation"]);
316
var result = target.JoinApplicationObserver(
RpcArguments
.String(arguments["invitation"]));
321
RpcArguments
.Validate(arguments, ["context", "invitation"]);
324
var result = target.JoinApplicationWorkspace(
RpcArguments
.String(arguments["invitation"]));
329
RpcArguments
.Validate(arguments, ["context", "invitation"]);
332
var result = target.JoinResourceExecution(
RpcArguments
.String(arguments["invitation"]));
337
RpcArguments
.Validate(arguments, ["context"]);
345
RpcArguments
.Validate(arguments, ["context", "observation"]);
347
target.PublishObservation(
RpcArguments
.Dto(arguments["observation"], NativeRpcJsonContext.Default.ResourceObservation));
352
RpcArguments
.Validate(arguments, ["context"]);
359
RpcArguments
.Validate(arguments, ["context"]);
366
RpcArguments
.Validate(arguments, ["context"]);
373
RpcArguments
.Validate(arguments, ["context"]);
380
RpcArguments
.Validate(arguments, ["context"]);
387
RpcArguments
.Validate(arguments, ["context"]);
394
RpcArguments
.Validate(arguments, ["context", "resourceId", "afterSequence"]);
396
var result = target.ReadResourceLogs(
RpcArguments
.String(arguments["resourceId"]),
RpcArguments
.Int64(arguments["afterSequence"]));
401
RpcArguments
.Validate(arguments, ["context"]);
408
RpcArguments
.Validate(arguments, ["context", "name"]);
410
target.RemoveSymbolicConfiguration(
RpcArguments
.String(arguments["name"]));
415
RpcArguments
.Validate(arguments, ["context", "step", "status", "complete", "failed"]);
417
target.ReportPublishingActivity(
RpcArguments
.String(arguments["step"]),
RpcArguments
.String(arguments["status"]),
RpcArguments
.Boolean(arguments["complete"]),
RpcArguments
.Boolean(arguments["failed"]));
422
RpcArguments
.Validate(arguments, ["context", "step", "type", "id", "status", "complete", "failed", "markdown"]);
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"]));
429
RpcArguments
.Validate(arguments, ["context", "message"]);
432
var result = target.RequestConfirmation(
RpcArguments
.String(arguments["message"]));
437
RpcArguments
.Validate(arguments, ["context", "requestId", "accepted"]);
439
target.RespondConfirmation(
RpcArguments
.String(arguments["requestId"]),
RpcArguments
.Boolean(arguments["accepted"]));
444
RpcArguments
.Validate(arguments, ["context", "revision", "container"]);
446
var result = await target.RestartContainer(
RpcArguments
.Int64(arguments["revision"]),
RpcArguments
.Dto(arguments["container"], NativeRpcJsonContext.Default.ContainerLaunch)).ConfigureAwait(false);
451
RpcArguments
.Validate(arguments, ["context", "revision", "networkContext", "launch", "bindings"]);
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);
458
RpcArguments
.Validate(arguments, ["context", "revision", "launch"]);
460
var result = await target.RestartContainerWorkload(
RpcArguments
.Int64(arguments["revision"]),
RpcArguments
.Dto(arguments["launch"], NativeRpcJsonContext.Default.ContainerWorkloadLaunch)).ConfigureAwait(false);
465
RpcArguments
.Validate(arguments, ["context", "revision", "executable"]);
467
var result = await target.RestartExecutable(
RpcArguments
.Int64(arguments["revision"]),
RpcArguments
.Dto(arguments["executable"], NativeRpcJsonContext.Default.ExecutableLaunch)).ConfigureAwait(false);
472
RpcArguments
.Validate(arguments, ["context", "revision", "networkContext", "launch", "bindings"]);
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);
479
RpcArguments
.Validate(arguments, ["context", "revision", "launch"]);
481
var result = await target.RestartExecutableWorkload(
RpcArguments
.Int64(arguments["revision"]),
RpcArguments
.Dto(arguments["launch"], NativeRpcJsonContext.Default.ExecutableWorkloadLaunch)).ConfigureAwait(false);
486
RpcArguments
.Validate(arguments, ["context"]);
493
RpcArguments
.Validate(arguments, ["context", "composition"]);
500
RpcArguments
.Validate(arguments, ["context", "launch", "bindings"]);
502
var result = await target.RunLifecycleExecutable(
RpcArguments
.Dto(arguments["launch"], NativeRpcJsonContext.Default.ExecutableWorkloadLaunch),
RpcArguments
.Dto(arguments["bindings"], NativeRpcJsonContext.Default.SymbolicLaunchBindings)).ConfigureAwait(false);
507
RpcArguments
.Validate(arguments, ["context"]);
514
RpcArguments
.Validate(arguments, ["context", "configuration"]);
516
target.SetResourceConfiguration(
RpcArguments
.Dto(arguments["configuration"], NativeRpcJsonContext.Default.ResourceConfiguration));
521
RpcArguments
.Validate(arguments, ["context", "name", "value"]);
523
target.SetSymbolicConfiguration(
RpcArguments
.String(arguments["name"]), handles.Get<DeclaredValue>(arguments["value"], "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Api.DeclaredValue"));
528
RpcArguments
.Validate(arguments, ["context"]);
536
RpcArguments
.Validate(arguments, ["context", "container"]);
538
var result = await target.StartContainer(
RpcArguments
.Dto(arguments["container"], NativeRpcJsonContext.Default.ContainerLaunch)).ConfigureAwait(false);
543
RpcArguments
.Validate(arguments, ["context", "revision", "networkContext", "launch", "bindings"]);
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);
550
RpcArguments
.Validate(arguments, ["context", "launch"]);
552
var result = await target.StartContainerWorkload(
RpcArguments
.Dto(arguments["launch"], NativeRpcJsonContext.Default.ContainerWorkloadLaunch)).ConfigureAwait(false);
557
RpcArguments
.Validate(arguments, ["context", "executable"]);
559
var result = await target.StartExecutable(
RpcArguments
.Dto(arguments["executable"], NativeRpcJsonContext.Default.ExecutableLaunch)).ConfigureAwait(false);
564
RpcArguments
.Validate(arguments, ["context", "revision", "networkContext", "launch", "bindings"]);
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);
571
RpcArguments
.Validate(arguments, ["context", "launch"]);
573
var result = await target.StartExecutableWorkload(
RpcArguments
.Dto(arguments["launch"], NativeRpcJsonContext.Default.ExecutableWorkloadLaunch)).ConfigureAwait(false);
578
RpcArguments
.Validate(arguments, ["context"]);
586
RpcArguments
.Validate(arguments, ["context", "timeoutMilliseconds"]);
588
await target.WaitApplicationReady(
RpcArguments
.Int32(arguments["timeoutMilliseconds"])).ConfigureAwait(false);
593
RpcArguments
.Validate(arguments, ["context", "dependency"]);
600
RpcArguments
.Validate(arguments, ["context"]);
607
RpcArguments
.Validate(arguments, ["context"]);
614
RpcArguments
.Validate(arguments, ["context", "timeoutMilliseconds"]);
616
var result = await target.WaitResourceCommands(
RpcArguments
.Int32(arguments["timeoutMilliseconds"])).ConfigureAwait(false);
621
RpcArguments
.Validate(arguments, ["context", "resource", "timeoutMilliseconds"]);
623
var result = await target.WaitResourceCompletion(handles.Get<DeclaredResource>(arguments["resource"], "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Api.DeclaredResource"),
RpcArguments
.Int32(arguments["timeoutMilliseconds"])).ConfigureAwait(false);
628
RpcArguments
.Validate(arguments, ["context", "revision", "timeoutMilliseconds"]);
630
var result = await target.WaitResourceConfiguration(
RpcArguments
.Int64(arguments["revision"]),
RpcArguments
.Int32(arguments["timeoutMilliseconds"])).ConfigureAwait(false);
635
RpcArguments
.Validate(arguments, ["context", "version", "timeoutMilliseconds"]);
637
var result = await target.WaitResourceObservations(
RpcArguments
.Int64(arguments["version"]),
RpcArguments
.Int32(arguments["timeoutMilliseconds"])).ConfigureAwait(false);
642
RpcArguments
.Validate(arguments, ["context", "value"]);
650
RpcArguments
.Validate(arguments, ["context", "source", "target", "readOnly"]);
653
var result = target.WithBindMount(
RpcArguments
.String(arguments["source"]),
RpcArguments
.String(arguments["target"]),
RpcArguments
.Boolean(arguments["readOnly"]));
658
RpcArguments
.Validate(arguments, ["context", "environment"]);
665
RpcArguments
.Validate(arguments, ["context", "endpoint"]);
668
var result = target.WithEndpoint(
RpcArguments
.Dto(arguments["endpoint"], NativeRpcJsonContext.Default.WorkloadEndpointDeclaration));
673
RpcArguments
.Validate(arguments, ["context", "entrypoint"]);
676
var result = target.WithEntrypoint(
RpcArguments
.String(arguments["entrypoint"]));
681
RpcArguments
.Validate(arguments, ["context", "name", "value"]);
684
var result = target.WithEnvironment(
RpcArguments
.String(arguments["name"]), handles.Get<DeclaredValue>(arguments["value"], "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Api.DeclaredValue"));
689
RpcArguments
.Validate(arguments, ["context"]);
697
RpcArguments
.Validate(arguments, ["context", "phase", "launch", "bindings"]);
700
var result = target.WithLifecycleExecutable(
RpcArguments
.String(arguments["phase"]),
RpcArguments
.Dto(arguments["launch"], NativeRpcJsonContext.Default.ExecutableWorkloadLaunch),
RpcArguments
.Dto(arguments["bindings"], NativeRpcJsonContext.Default.SymbolicLaunchBindings));
705
RpcArguments
.Validate(arguments, ["context", "environmentName", "value"]);
708
var result = target.WithReference(
RpcArguments
.String(arguments["environmentName"]), handles.Get<DeclaredValue>(arguments["value"], "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Api.DeclaredValue"));
713
RpcArguments
.Validate(arguments, ["context", "name", "target", "readOnly"]);
716
var result = target.WithVolume(
RpcArguments
.String(arguments["name"]),
RpcArguments
.String(arguments["target"]),
RpcArguments
.Boolean(arguments["readOnly"]));
721
RpcArguments
.Validate(arguments, ["context", "stream", "message"]);
723
target.WriteLifecycleLog(
RpcArguments
.String(arguments["stream"]),
RpcArguments
.String(arguments["message"]));
728
RpcArguments
.Validate(arguments, ["context", "value"]);
730
target.Add(
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"]));
735
RpcArguments
.Validate(arguments, ["context", "name", "image"]);
738
var result = target.AddContainer(
RpcArguments
.String(arguments["name"]),
RpcArguments
.String(arguments["image"]));
743
RpcArguments
.Validate(arguments, ["context", "name", "executablePath", "workingDirectory"]);
746
var result = target.AddExecutable(
RpcArguments
.String(arguments["name"]),
RpcArguments
.String(arguments["executablePath"]),
RpcArguments
.String(arguments["workingDirectory"]));
751
RpcArguments
.Validate(arguments, ["context", "name", "value"]);
754
var result = target.AddSecretParameter(
RpcArguments
.String(arguments["name"]),
RpcArguments
.String(arguments["value"]));
759
RpcArguments
.Validate(arguments, ["context"]);
767
RpcArguments
.Validate(arguments, ["context", "name"]);
770
var result = target.GetEndpoint(
RpcArguments
.String(arguments["name"]));
775
RpcArguments
.Validate(arguments, ["context"]);
782
RpcArguments
.Validate(arguments, ["context", "annotationId"]);
784
var result = target.GetSerializedAnnotation(
RpcArguments
.String(arguments["annotationId"]));
789
RpcArguments
.Validate(arguments, ["context", "property"]);
792
var result = target.Property(
RpcArguments
.String(arguments["property"]));
797
RpcArguments
.Validate(arguments, ["context"]);
804
RpcArguments
.Validate(arguments, ["context", "name", "value"]);
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"]));
811
RpcArguments
.Validate(arguments, ["context", "dependency"]);
819
RpcArguments
.Validate(arguments, ["context", "args"]);
822
var result = target.WithArgs(
RpcArguments
.Strings(arguments["args"]));
827
RpcArguments
.Validate(arguments, ["context", "callback"]);
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);
834
RpcArguments
.Validate(arguments, ["context", "value"]);
837
var result = target.WithConnectionString(
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"]));
842
RpcArguments
.Validate(arguments, ["context", "options"]);
845
var result = target.WithEndpoint(
RpcArguments
.Dto(arguments["options"], NativeRpcJsonContext.Default.RpcEndpointOptions));
850
RpcArguments
.Validate(arguments, ["context", "name", "value"]);
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"]));
858
RpcArguments
.Validate(arguments, ["context", "callback"]);
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);
865
RpcArguments
.Validate(arguments, ["context", "tag"]);
868
var result = target.WithImageTag(
RpcArguments
.String(arguments["tag"]));
873
RpcArguments
.Validate(arguments, ["context", "source"]);
881
RpcArguments
.Validate(arguments, ["context", "annotationId", "json"]);
884
var result = target.WithSerializedAnnotation(
RpcArguments
.String(arguments["annotationId"]),
RpcArguments
.String(arguments["json"]));
889
RpcArguments
.Validate(arguments, []);
Rpc\NativeHandles.cs (6)
51
RpcArguments
.Validate(reference, ["$handle", "$type"]);
52
var id =
RpcArguments
.String(reference["$handle"]);
53
var typeId =
RpcArguments
.String(reference["$type"]);
68
RpcArguments
.Validate(reference, ["$handle", "$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 (4)
211
RpcArguments
.Validate(arguments, parameters.Select(parameter => parameter.Name).ToArray());
222
var callbackId =
RpcArguments
.String(arguments[name]);
344
RpcArguments
.String(handle["$type"]));
369
RpcArguments
.Validate(arguments, Enumerable.Range(0, parameters.Length).Select(index => $"p{index}").ToArray());
Rpc\NativeProviderValueProtocol.cs (7)
16
case NativeProviderValueKind.String: _ =
RpcArguments
.String(value); return;
17
case NativeProviderValueKind.Boolean: _ =
RpcArguments
.Boolean(value); return;
18
case NativeProviderValueKind.Int32: _ =
RpcArguments
.Int32(value); return;
19
case NativeProviderValueKind.Int64: _ =
RpcArguments
.Int64(value); return;
30
RpcArguments
.Validate(handle, core ? ["$handle", "$type"] : ["$handle", "$type", "$lifetime"]);
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);