-
Notifications
You must be signed in to change notification settings - Fork 3
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'main' into al/test-workflow
- Loading branch information
Showing
26 changed files
with
732 additions
and
495 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1 @@ | ||
| regctl image export ghcr.io/dapr/samples/pubsub-csharp-subscriber:1.9.0 --name pubsub-csharp-subscriber > /workspace/platform-deployment/test/sampleSchedules/pubsub-csharp-subscriber.tar |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,34 @@ | ||
| namespace Microsoft.Azure.SpaceFx.PlatformServices.Deployment; | ||
|
|
||
| public partial class MessageHandler<T> : Microsoft.Azure.SpaceFx.Core.IMessageHandler<T> where T : notnull { | ||
| private readonly ILogger<MessageHandler<T>> _logger; | ||
| public static EventHandler<T>? MessageReceivedEvent; | ||
| private readonly Microsoft.Azure.SpaceFx.Core.Services.PluginLoader _pluginLoader; | ||
| private readonly IServiceProvider _serviceProvider; | ||
| private readonly Core.Client _client; | ||
| private readonly Models.APP_CONFIG _appConfig; | ||
| private readonly PluginDelegates _pluginDelegates; | ||
|
|
||
| public MessageHandler(ILogger<MessageHandler<T>> logger, PluginDelegates pluginDelegates, Microsoft.Azure.SpaceFx.Core.Services.PluginLoader pluginLoader, IServiceProvider serviceProvider, Core.Client client) { | ||
| _logger = logger; | ||
| _pluginDelegates = pluginDelegates; | ||
| _pluginLoader = pluginLoader; | ||
| _serviceProvider = serviceProvider; | ||
| _client = client; | ||
|
|
||
| _appConfig = new Models.APP_CONFIG(); | ||
| } | ||
|
|
||
| public void MessageReceived(T message, MessageFormats.Common.DirectToApp fullMessage) => Task.Run(() => { | ||
| using (var scope = _serviceProvider.CreateScope()) { | ||
| if (message == null || EqualityComparer<T>.Default.Equals(message, default)) { | ||
| _logger.LogInformation("Received empty message '{messageType}' from '{appId}'. Discarding message.", typeof(T).Name, fullMessage.SourceAppId); | ||
| return; | ||
| } | ||
| // This function is just a catch all for any messages that come in. They are not processed and no plugins are triggered for security reasons. | ||
| // We're catching all messages here to reduce the log warnings for OOTB messages that are flowing | ||
| } | ||
| }); | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,73 @@ | ||
|
|
||
| using YamlDotNet.Core; | ||
| using YamlDotNet.Core.Events; | ||
| using YamlDotNet.Serialization; | ||
|
|
||
| namespace Microsoft.Azure.SpaceFx.PlatformServices.Deployment; | ||
| public static partial class Models { | ||
| public class KubernetesObjects { | ||
| public class ResourceDefinition { | ||
| public ResourceSection Resources { get; set; } | ||
|
|
||
| public ResourceDefinition() { | ||
| Resources = new ResourceSection(); | ||
| } | ||
| } | ||
|
|
||
| public class ResourceSection { | ||
| public ResourceDetails Limits { get; set; } | ||
| public ResourceDetails Requests { get; set; } | ||
|
|
||
| public ResourceSection() { | ||
| Limits = new ResourceDetails(); | ||
| Requests = new ResourceDetails(); | ||
| } | ||
| } | ||
|
|
||
| public class ResourceDetails { | ||
| public string Cpu { get; set; } | ||
| public string Memory { get; set; } | ||
|
|
||
| public ResourceDetails() { | ||
| Cpu = ""; | ||
| Memory = ""; | ||
| } | ||
| } | ||
|
|
||
| public class VolumeMountRoot { | ||
| public List<V1VolumeMount> VolumeMounts { get; set; } | ||
| public VolumeMountRoot() { | ||
| VolumeMounts = new List<V1VolumeMount>(); | ||
| } | ||
| } | ||
|
|
||
| public class VolumeRoot { | ||
| public List<V1Volume> Volumes { get; set; } | ||
| public VolumeRoot() { | ||
| Volumes = new List<V1Volume>(); | ||
| } | ||
|
|
||
| public class ConfigMapVolumeSource { | ||
| public string Name { get; set; } | ||
| public ConfigMapVolumeSource() { | ||
| Name = ""; | ||
| } | ||
| } | ||
|
|
||
| public class SecretVolumeSource { | ||
| public string SecretName { get; set; } | ||
| public SecretVolumeSource() { | ||
| SecretName = ""; | ||
| } | ||
| } | ||
|
|
||
| public class PersistentVolumeClaimVolumeSource { | ||
| public string ClaimName { get; set; } | ||
| public PersistentVolumeClaimVolumeSource() { | ||
| ClaimName = ""; | ||
| } | ||
| } | ||
| } | ||
| } | ||
|
|
||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.