Asynkron.DurableFunctions 0.0.2

Asynkron.DurableFunctions Library

This library provides base classes and attributes that replicate the functionality of Azure Durable Functions, but with "Asynkron" prefixes instead of "Azure".

Features

Attributes

• FunctionNameAttribute - Specifies the name of a function (equivalent to Azure's [FunctionName])
• OrchestrationTriggerAttribute - Specifies that a parameter should be treated as an orchestration trigger (equivalent to Azure's [OrchestrationTrigger])

Interfaces

• IDurableOrchestrationContext - Defines the interface for a durable orchestration context (equivalent to Azure's IDurableOrchestrationContext)

Context Methods

The IDurableOrchestrationContext provides the following methods:

• CallActivityAsync<TResult>(string name, object? input = null) - Calls an activity function asynchronously with a return value
• CallActivityAsync(string name, object? input = null) - Calls an activity function asynchronously without a return value
• CreateTimer(DateTime fireAt) - Creates a timer that expires at the specified time
• WaitForExternalEvent<TResult>(string name) - Waits for an external event to be raised

Properties

• InstanceId - Gets the instance ID of the orchestration
• CurrentUtcDateTime - Gets the current date and time in UTC
• IsReplaying - Gets a value indicating whether the orchestration is replaying

Usage Example

using Asynkron.DurableFunctions;

public class MyOrchestrator
{
    [FunctionName("MyOrchestrator")]
    public async Task<string> RunOrchestrator([OrchestrationTrigger] IDurableOrchestrationContext context)
    {
        var result = await context.CallActivityAsync<string>("MyActivity", "input data");
        return result;
    }

    [FunctionName("MyActivity")]
    public string MyActivity(string input)
    {
        return $"Processed: {input}";
    }
}

Current Status

This is a stub implementation. The core attributes and interfaces are implemented, but the actual orchestration runtime is not yet implemented. The CallActivityAsync, CreateTimer, and WaitForExternalEvent methods currently throw NotImplementedException.

Future Development

To complete the implementation, the following would need to be added:

1. Orchestration runtime engine
2. Activity function discovery and invocation
3. State persistence and replay logic
4. Timer management
5. External event handling
6. ASP.NET Core integration