-
Notifications
You must be signed in to change notification settings - Fork 2
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Add StreamingClassOperatorResponse (#13)
- Loading branch information
Showing
3 changed files
with
159 additions
and
29 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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,22 @@ | ||
| namespace Arcane.Operator.Models.Common; | ||
|
|
||
| /// <summary> | ||
| /// Represents stream status badge for Lens app. | ||
| /// </summary> | ||
| public enum ResourceStatus | ||
| { | ||
| /// <summary> | ||
| /// The stream is in a ready state. | ||
| /// </summary> | ||
| READY, | ||
|
|
||
| /// <summary> | ||
| /// The stream is in an error state. | ||
| /// </summary> | ||
| ERROR, | ||
|
|
||
| /// <summary> | ||
| /// The stream is in a warning state. | ||
| /// </summary> | ||
| WARNING | ||
| } |
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,128 @@ | ||
| using System.Collections.Generic; | ||
| using System.Diagnostics.CodeAnalysis; | ||
| using Arcane.Operator.Models.Common; | ||
| using Arcane.Operator.Models.StreamStatuses.StreamStatus.V1Beta1; | ||
|
|
||
| namespace Arcane.Operator.Models; | ||
|
|
||
| /// <summary> | ||
| /// Possible stream states. | ||
| /// </summary> | ||
| public enum StreamClassPhase | ||
| { | ||
| /// <summary> | ||
| /// An initial state of the StreamClass object. | ||
| /// </summary> | ||
| INITIALIZING, | ||
|
|
||
| /// <summary> | ||
| /// A ready streaming class is ready to be used and new Streams of this class can be created. | ||
| /// </summary> | ||
| READY, | ||
|
|
||
| /// <summary> | ||
| /// An error occured in stream class controller and new Streams of this class can not be created. | ||
| /// </summary> | ||
| FAILED, | ||
|
|
||
| /// <summary> | ||
| /// The stream class is stopped and new Streams of this class can not be created. | ||
| /// </summary> | ||
| STOPPED | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Contains response from stream operator that can be used by other services inside the application | ||
| /// </summary> | ||
| [ExcludeFromCodeCoverage(Justification = "Model")] | ||
| public record StreamClassOperatorResponse | ||
| { | ||
| /// <summary> | ||
| /// Affected StreamClass identifier | ||
| /// </summary> | ||
| public string Id { get; private init; } | ||
|
|
||
| /// <summary> | ||
| /// Affected StreamClass kind | ||
| /// </summary> | ||
| public string Kind { get; set; } | ||
|
|
||
| /// <summary> | ||
| /// Affected StreamClass namespace | ||
| /// </summary> | ||
| public string Namespace { get; set; } | ||
|
|
||
| /// <summary> | ||
| /// Latest observed state of the StreamClass object | ||
| /// </summary> | ||
| public IEnumerable<V1Beta1StreamCondition> Conditions { get; private init; } | ||
|
|
||
| /// <summary> | ||
| /// StreamClass livecycle phase | ||
| /// </summary> | ||
| public StreamClassPhase Phase { get; private set; } | ||
|
|
||
|
|
||
| /// <summary> | ||
| /// Creates a StreamOperatorResponse object for stream with specified identifier, setting it state to RUNNING | ||
| /// </summary> | ||
| /// <param name="nameSpace">Kubernetes namespace</param> | ||
| /// <param name="kind">Affected stream class kind</param> | ||
| /// <param name="streamClassId">Affected stream class identifier</param> | ||
| public static StreamClassOperatorResponse Ready(string nameSpace, string kind, string streamClassId) | ||
| { | ||
| return new StreamClassOperatorResponse | ||
| { | ||
| Id = streamClassId, | ||
| Kind = kind, | ||
| Namespace = nameSpace, | ||
| Conditions = new[] | ||
| { | ||
| new V1Beta1StreamCondition { Type = ResourceStatus.READY.ToString(), Status = "True" } | ||
| }, | ||
| Phase = StreamClassPhase.READY | ||
| }; | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Creates a StreamOperatorResponse object for stream with specified identifier, setting it state to RUNNING | ||
| /// </summary> | ||
| /// <param name="nameSpace">Kubernetes namespace</param> | ||
| /// <param name="kind">Affected stream class kind</param> | ||
| /// <param name="streamClassId">Affected stream class identifier</param> | ||
| public static StreamClassOperatorResponse Failed(string nameSpace, string kind, string streamClassId) | ||
| { | ||
| return new StreamClassOperatorResponse | ||
| { | ||
| Id = streamClassId, | ||
| Kind = kind, | ||
| Namespace = nameSpace, | ||
| Conditions = new[] | ||
| { | ||
| new V1Beta1StreamCondition { Type = ResourceStatus.READY.ToString(), Status = "True" } | ||
| }, | ||
| Phase = StreamClassPhase.FAILED | ||
| }; | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Creates a StreamOperatorResponse object for stream with specified identifier, setting it state to RUNNING | ||
| /// </summary> | ||
| /// <param name="nameSpace">Kubernetes namespace</param> | ||
| /// <param name="kind">Affected stream class kind</param> | ||
| /// <param name="streamClassId">Affected stream class identifier</param> | ||
| public static StreamClassOperatorResponse Stopped(string nameSpace, string kind, string streamClassId) | ||
| { | ||
| return new StreamClassOperatorResponse | ||
| { | ||
| Id = streamClassId, | ||
| Kind = kind, | ||
| Namespace = nameSpace, | ||
| Conditions = new[] | ||
| { | ||
| new V1Beta1StreamCondition { Type = ResourceStatus.READY.ToString(), Status = "True" } | ||
| }, | ||
| Phase = StreamClassPhase.STOPPED | ||
| }; | ||
| } | ||
| } |