Cleipnir.ResilientFunctions.MySQL
3.0.1
Prefix Reserved
See the version list below for details.
dotnet add package Cleipnir.ResilientFunctions.MySQL --version 3.0.1
NuGet\Install-Package Cleipnir.ResilientFunctions.MySQL -Version 3.0.1
<PackageReference Include="Cleipnir.ResilientFunctions.MySQL" Version="3.0.1" />
paket add Cleipnir.ResilientFunctions.MySQL --version 3.0.1
#r "nuget: Cleipnir.ResilientFunctions.MySQL, 3.0.1"
// Install Cleipnir.ResilientFunctions.MySQL as a Cake Addin #addin nuget:?package=Cleipnir.ResilientFunctions.MySQL&version=3.0.1 // Install Cleipnir.ResilientFunctions.MySQL as a Cake Tool #tool nuget:?package=Cleipnir.ResilientFunctions.MySQL&version=3.0.1
<p align="center"> <img src="./Docs/cleipnir.png" alt="logo" /> <br> Simply making fault-tolerant code simple <br> </p>
Cleipnir Resilient Functions
Providing a simple way to ensure your code gets run - until you say it is done!
Resilient Functions is a simple and intuitive .NET framework for managing the execution of functions which must complete in their entirety despite: failures, restarts, deployments, versioning etc.
It automatically retries a function invocation until it completes potentially across process restarts and physical nodes.
The framework also supports postponing/suspending invocations or failing invocations for manually handling. Furthermore, versioning is natively supported.
It requires a minimal amount of setup to get started and seamlessly scales with multiple running instances.
Crucially, all this allows the saga pattern / process manager pattern to be implemented in a simple yet powerful way.
Out-of-the-box you also get:
- synchronized invocation across multiple process instances
- cloud independence & support for multiple databases
- simple debuggability & testability
- easy versioning of functions
- native support for rpc and message-based communication
- graceful-shutdown
What it is not? |
---|
Unlike other saga frameworks Resilient Functions does not require a message-broker to operate.<br /> It is a fully self-contained solution - which operates on top of a database of choice or in-memory when testing.<br /> |
Sections
Getting Started
Only three steps needs to be performed to get started.
Firstly, install the relevant nuget package (using either Postgres, SqlServer, MySQL or Azure Blob-storage as persistence layer). I.e.
dotnet add package Cleipnir.ResilientFunctions.PostgreSQL
Secondly, setup the framework:
var store = new PostgreSqlFunctionStore(ConnStr);
await store.Initialize();
var functionsRegistry = new FunctionsRegistry(
store,
new Settings(
unhandledExceptionHandler: e => Console.WriteLine($"Unhandled framework exception occured: '{e}'"),
leaseLength: TimeSpan.FromSeconds(5)
)
);
Finally, register and invoke a function using the framework:
var actionRegistration = functionsRegistry.RegisterAction(
flowType: "OrderProcessor",
async (Order order, Workflow workflow) =>
{
var effect = workflow.Effect;
var transactionId = effect.Capture("TransactionId", Guid.NewGuid);
await _paymentProviderClient.Reserve(order.CustomerId, transactionId, order.TotalPrice);
await effect.Capture(
"ShipProducts",
work: () => _logisticsClient.ShipProducts(order.CustomerId, order.ProductIds),
ResiliencyLevel.AtMostOnce
);
await _paymentProviderClient.Capture(transactionId);
await _emailClient.SendOrderConfirmation(order.CustomerId, order.ProductIds);
}
);
var order = new Order(
OrderId: "MK-4321",
CustomerId: Guid.NewGuid(),
ProductIds: new[] { Guid.NewGuid(), Guid.NewGuid() },
TotalPrice: 123.5M
);
await actionRegistration.Invoke(order.OrderId, order);
Congrats, any non-completed Order flows are now automatically restarted by the framework.
Message-based solution:
It is also possible to implement message-based flows using the framework. I.e. awaiting 2 external messages before completing an invocation can be accomplished as follows:
var rAction = functionsRegistry.RegisterAction(
flowType: "MessageWaitingFunc",
async (string param, Workflow workflow) =>
{
var messages = await workflow.Messages;
await messages
.OfTypes<FundsReserved, InventoryLocked>()
.Take(2)
.Completion();
}
);
Show me more code
In the following chapter several stand-alone examples are presented.
Hello-World
Firstly, the compulsory, ‘hello world’-example can be realized as follows:
var store = new InMemoryFunctionStore();
var functions = new FunctionsRegistry(store, unhandledExceptionHandler: Console.WriteLine);
var rFunc = functions.RegisterFunc(
flowType: "HelloWorld",
inner: (string param) => param.ToUpper()
).Invoke;
var returned = await rFunc(flowInstance: "", param: "hello world");
Console.WriteLine($"Returned: '{returned}'");
HTTP-call & database
Allright, not useful, here are a couple of simple, but common, use-cases.
Invoking a HTTP-endpoint and storing the response in a database table:
public static async Task RegisterAndInvoke(IDbConnection connection, IFunctionStore store)
{
var functions = new FunctionsRegistry(store, new Settings(UnhandledExceptionHandler: Console.WriteLine));
var httpClient = new HttpClient();
var rAction = functions.RegisterAction(
flowType: "HttpAndDatabaseSaga",
inner: async (Guid id) =>
{
var response = await httpClient.PostAsync(URL, new StringContent(id.ToString()));
response.EnsureSuccessStatusCode();
var content = await response.Content.ReadAsStringAsync();
await connection.ExecuteAsync(
"UPDATE Entity SET State=@State WHERE Id=@Id",
new {State = content, Id = id}
);
}).Invoke;
var id = Guid.NewGuid();
await rAction(flowInstance: id.ToString(), param: id);
}
Sending customer emails
Consider a travel agency which wants to send a promotional email to its customers:
public static class EmailSenderSaga
{
public static async Task Start(MailAndRecipients mailAndRecipients, Workflow workflow)
{
var state = workflow.States.CreateOrGet<State>();
var (recipients, subject, content) = mailAndRecipients;
using var client = new SmtpClient();
await client.ConnectAsync("mail.smtpbucket.com", 8025);
for (var atRecipient = state.AtRecipient; atRecipient < mailAndRecipients.Recipients.Count; atRecipient++)
{
var recipient = recipients[atRecipient];
var message = new MimeMessage();
message.To.Add(new MailboxAddress(recipient.Name, recipient.Address));
message.From.Add(new MailboxAddress("The Travel Agency", "offers@thetravelagency.co.uk"));
message.Subject = subject;
message.Body = new TextPart(TextFormat.Html) { Text = content };
await client.SendAsync(message);
state.AtRecipient = atRecipient;
await state.Save();
}
}
public class State : FlowState
{
public int AtRecipient { get; set; }
}
}
Product | Versions Compatible and additional computed target framework versions. |
---|---|
.NET | net8.0 is compatible. net8.0-android was computed. net8.0-browser was computed. net8.0-ios was computed. net8.0-maccatalyst was computed. net8.0-macos was computed. net8.0-tvos was computed. net8.0-windows was computed. |
-
net8.0
- Cleipnir.ResilientFunctions (>= 3.0.1)
- MySqlConnector (>= 2.3.7)
NuGet packages (1)
Showing the top 1 NuGet packages that depend on Cleipnir.ResilientFunctions.MySQL:
Package | Downloads |
---|---|
Cleipnir.Flows.MySQL
Cleipnir Flows is a powerful .NET framework designed for ASP.NET services, providing a straightforward workflow-as-code approach. It ensures that your code executes reliably, even in the face of failures, restarts, deployments, versioning, and other challenges. While similar to Azure Durable Functions, Cleipnir Flows is specifically tailored for ASP.NET Core. |
GitHub repositories
This package is not used by any popular GitHub repositories.
Version | Downloads | Last updated |
---|---|---|
3.0.3 | 95 | 8/30/2024 |
3.0.2 | 97 | 7/25/2024 |
3.0.1 | 82 | 7/25/2024 |
3.0.0 | 90 | 7/14/2024 |
2.0.2 | 260 | 3/16/2024 |
2.0.1 | 176 | 3/15/2024 |
2.0.0 | 160 | 3/14/2024 |
1.0.16 | 749 | 8/30/2023 |
1.0.15 | 708 | 8/27/2023 |
1.0.14 | 752 | 8/13/2023 |
1.0.13 | 713 | 8/10/2023 |
1.0.12 | 763 | 8/2/2023 |
1.0.11 | 840 | 8/1/2023 |
1.0.10 | 802 | 7/30/2023 |
1.0.9 | 589 | 7/25/2023 |
1.0.8 | 835 | 7/24/2023 |
1.0.7 | 821 | 7/19/2023 |
1.0.6 | 785 | 7/12/2023 |
1.0.5 | 623 | 7/2/2023 |
1.0.4 | 628 | 4/4/2023 |
1.0.3 | 712 | 2/4/2023 |
1.0.2 | 723 | 2/1/2023 |