NetTemporal.Client.Core 1.0.0

Temporal.Client.Core

A .NET 8 wrapper around the Temporal.io SDK that provides a clean, DI-friendly abstraction for managing workflows — starting them, sending signals, executing updates, and querying state — with minimal boilerplate.

Installation

dotnet add package NetTemporal.Client.Core

Configuration

Add your Temporal connection settings to appsettings.json:

{
  "TemporalConfig": {
    "ServerAddress": "localhost:7233",
    "Namespace": "default",
    "ApiKey": ""
  }
}

Registration

Call AddTemporalClientCore in your Program.cs or Startup.cs:

builder.Services.AddTemporalClientCore(builder.Configuration);

This registers:

• ITemporalClient as a singleton (connected on startup)
• ITemporalClientService as a scoped service

Usage

Inject ITemporalClientService wherever you need it:

public class OrderService(ITemporalClientService temporal)
{
    // ...
}

Start a workflow with an initial signal

await temporal.StartWorkflowAsync(new TemporalSignalRequest
{
    WorkflowId  = "order-123",
    WorkflowName = "OrderWorkflow",
    TaskQueue   = "order-queue",
    SignalName  = "OrderReceived",
    Data        = new { OrderId = "123", Amount = 99.99 },
    MetaData    = null   // optional workflow constructor args
});

Send a signal to a running workflow

await temporal.SendSignalAsync(new TemporalSignalRequest
{
    WorkflowId   = "order-123",
    WorkflowName = "OrderWorkflow",
    TaskQueue    = "order-queue",
    SignalName   = "PaymentConfirmed",
    Data         = new { TransactionId = "txn-456" }
});

Execute a workflow update

var result = await temporal.UpdateWorkflowStateAsync<UpdateInput, UpdateResult>(
    workflowId: "order-123",
    updateName: "ApplyDiscount",
    data: new UpdateInput { DiscountPercent = 10 }
);

Query workflow execution history

var history = await temporal.GetWorkflowStateAsync("order-123");

Returns a GetWorkflowExecutionHistoryResponse? (from the Temporal gRPC API), or null if the workflow is not found.

Check and resume a failed workflow

bool isFailed = await temporal.IsWorkflowFailedAsync("order-123");

if (isFailed)
{
    await temporal.ResumeFailedWorkflowAsync("order-123");
}

ResumeFailedWorkflowAsync sends a ResumeWorkflow signal only if the workflow is currently in a failed state.
RemoveWorkflowFromFailedStateAsync sends the same signal unconditionally (no state check).

API Reference

TemporalSignalRequest

ITemporalClientService

Requirements

• .NET 8.0+
• A running Temporal server or Temporal Cloud account

License

This project is licensed under the MIT License.