-
Notifications
You must be signed in to change notification settings - Fork 35
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
5 changed files
with
370 additions
and
91 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,114 @@ | ||
| // Copyright (c) Microsoft Corporation. | ||
| // Licensed under the MIT License. | ||
|
|
||
| using System.Net; | ||
| using Microsoft.Azure.Functions.Worker; | ||
| using Microsoft.Azure.Functions.Worker.Http; | ||
| using Microsoft.DurableTask.Client; | ||
| using Microsoft.DurableTask.Client.Entities; | ||
| using Microsoft.DurableTask.Entities; | ||
| using Microsoft.Extensions.Logging; | ||
|
|
||
| namespace AzureFunctionsApp.Entities; | ||
|
|
||
| /// <summary> | ||
| /// Example showing the lifetime of an entity. An entity is initialized on the first operation it receives and then | ||
| /// is considered deleted when <see cref="TaskEntity{TState}.State"/> is <c>null</c> at the end of an operation. | ||
| /// </summary> | ||
| public class Lifetime : TaskEntity<MyState> | ||
| { | ||
| readonly ILogger logger; | ||
|
|
||
| public Lifetime(ILogger<Lifetime> logger) | ||
| { | ||
| this.logger = logger; | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Optional property to override. When 'true', this will allow dispatching of operations to the TState object if | ||
| /// there is no matching method on the entity. Default is 'false'. | ||
| /// </summary> | ||
| protected override bool AllowStateDispatch => base.AllowStateDispatch; | ||
|
|
||
| // NOTE: when using TaskEntity<TState>, you cannot use "RunAsync" as the entity trigger name as this conflicts | ||
| // with the base class method 'RunAsync'. | ||
| [Function(nameof(Lifetime))] | ||
| public Task DispatchAsync([EntityTrigger] TaskEntityDispatcher dispatcher) | ||
| { | ||
| this.logger.LogInformation("Dispatching entity"); | ||
| return dispatcher.DispatchAsync(this); | ||
| } | ||
|
|
||
| public void Init() { } // no op just to init this entity. | ||
|
|
||
| public void CustomDelete() | ||
| { | ||
| // Deleting an entity is done by null-ing out the state. | ||
| // The '!' in `null!;` is only needed because we are using C# explicit nullability. | ||
| // This can be avoided by either: | ||
| // 1) Declare TaskEntity<MyState?> instead. | ||
| // 2) Disable explicit nullability. | ||
| this.State = null!; | ||
| } | ||
|
|
||
| public void Delete() | ||
| { | ||
| // Entities have an implicit 'delete' operation when there is no matching 'delete' method. By explicitly adding | ||
| // a 'Delete' method, it will override the implicit 'delete' operation. | ||
| // Since state deletion is determined by nulling out `this.State`, it means that value-types cannot be deleted | ||
| // except by the implicit delete (which will still delete it). To manually delete a value-type, you can declare | ||
| // it as nullable. Such as TaskEntity<int?> instead of TaskEntity<int>. | ||
| this.State = null!; | ||
| } | ||
|
|
||
| protected override MyState InitializeState(TaskEntityOperation operation) | ||
| { | ||
| // This method allows for customizing the default state value for a new entity. | ||
| return new("Default", 10); | ||
| } | ||
| } | ||
|
|
||
| public static class LifetimeApis | ||
| { | ||
| [Function("GetLifetime")] | ||
| public static async Task<HttpResponseData> GetAsync( | ||
| [HttpTrigger(AuthorizationLevel.Anonymous, "get", Route = "state/{id}")] HttpRequestData request, | ||
| [DurableClient] DurableTaskClient client, | ||
| string id) | ||
| { | ||
| EntityMetadata<MyState>? entity = await client.Entities.GetEntityAsync<MyState>( | ||
| new EntityInstanceId(nameof(Lifetime), id)); | ||
|
|
||
| if (entity is null) | ||
| { | ||
| return request.CreateResponse(HttpStatusCode.NotFound); | ||
| } | ||
|
|
||
| HttpResponseData response = request.CreateResponse(HttpStatusCode.OK); | ||
| await response.WriteAsJsonAsync(entity); | ||
| return response; | ||
| } | ||
|
|
||
| [Function("InitLifetime")] | ||
| public static async Task<HttpResponseData> InitAsync( | ||
| [HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = "state/{id}")] HttpRequestData request, | ||
| [DurableClient] DurableTaskClient client, | ||
| string id) | ||
| { | ||
| await client.Entities.SignalEntityAsync(new EntityInstanceId(nameof(Lifetime), id), "init"); | ||
| return request.CreateResponse(HttpStatusCode.Accepted); | ||
| } | ||
|
|
||
| [Function("DeleteLifetime")] | ||
| public static async Task<HttpResponseData> DeleteAsync( | ||
| [HttpTrigger(AuthorizationLevel.Anonymous, "delete", Route = "state/{id}")] HttpRequestData request, | ||
| [DurableClient] DurableTaskClient client, | ||
| string id) | ||
| { | ||
| string operation = bool.TryParse(request.Query["custom"], out bool b) && b ? "customDelete" : "delete"; | ||
| await client.Entities.SignalEntityAsync(new EntityInstanceId(nameof(Lifetime), id), operation); | ||
| return request.CreateResponse(HttpStatusCode.Accepted); | ||
| } | ||
| } | ||
|
|
||
| public record MyState(string PropA, int PropB); |
This file was deleted.
Oops, something went wrong.
Oops, something went wrong.