czinegeroland

public class OrderStateMachine : MassTransitStateMachine<OrderState>
{
    public State PaymentProcessing { get; private set; }
    public State PaymentProcessingFailed { get; private set; }

    public State Shipping { get; private set; }
    public State ShippingFailed { get; private set; }

    public Event<OrderSubmitted> OrderSubmitted { get; private set; }

czinegeroland

builder.Services.AddMassTransit(busConfigurator =>
{
    ConnectionFactory.DefaultAddressFamily = AddressFamily.InterNetwork;

    busConfigurator
        .AddSagaStateMachine<OrderStateMachine, OrderState>()
        .Endpoint(_ => _.AddConfigureEndpointCallback((context, cfg) =>
        {
            cfg.UseMessageRetry(_ => _.Immediate(1));
            cfg.UseInMemoryInboxOutbox(context);

czinegeroland

app.MapGet("/submitOrder", async ([FromServices] IPublishEndpoint publishEndpoint) =>
{
    await publishEndpoint.Publish(new OrderSubmitted
    {
        OrderId = NewId.NextGuid(),
    });

    return;
});

czinegeroland

apiVersion: keda.sh/v1alpha1
kind: ScaledObject
metadata:
  name: consumer-scaledobject
  namespace: default
spec:
  scaleTargetRef:
    name: consumer
  minReplicaCount: 0
  maxReplicaCount: 3

czinegeroland

app.MapGet("/submitOrders-parallel/{messageCount:int}", async (
    [FromRoute] int messageCount,
    [FromServices] IPublishEndpoint publishEndpoint) =>
{
    var messages = Enumerable.Range(0, messageCount)
        .Select(_ => publishEndpoint.Publish(new OrderSubmitted
        {
            OrderId = NewId.NextGuid(),
        })
    );

czinegeroland

# This stage is used when running from VS in fast mode (Default for Debug configuration)
FROM mcr.microsoft.com/dotnet/aspnet:8.0 AS base
USER $APP_UID
WORKDIR /app
EXPOSE 8080
EXPOSE 8081


# This stage is used to build the service project
FROM mcr.microsoft.com/dotnet/sdk:8.0 AS build

czinegeroland

pipelines:
  default:
      - step:
          runs-on:
            - self.hosted
            - linux
          script:

czinegeroland

$$ u(t) = K_p \cdot e(t) + K_i \int_0^t e(\tau),d\tau + K_d \cdot \frac{de(t)}{dt} $$

czinegeroland

error = Setpoint - current_value;
    
% PID calculations
proportional = P * error;
integral = integral + (I * error * dt);
derivative = D * (error - previous_error) / dt;

czinegeroland

// Build Semantic Kernel with OpenAI chat completion
var builder = Kernel.CreateBuilder();
builder.AddOpenAIChatCompletion("gpt-5-nano", apiKey);
var kernel = builder.Build();

var chatCompletion = _kernel.GetRequiredService<IChatCompletionService>();

// Initialize chat history with system prompt
var chatHistory = new ChatHistory();
chatHistory.AddSystemMessage(PromtsHelper.GetSystemPrompt());