aramkoukia

[ApiVersionNeutral]
[Route("api/optout")]
public class OptOutControler : Controller
{
	[HttpGet]
	public string Get() => HttpContext.GetRequestedApiVersion().ToString();
}

aramkoukia

namespace Product.CommandService.Controllers.Product.V1
{
  [ApiVersion("1.0")]
  [Produces("application/json")]
  [Route("api/Product")]
  public class ProductController : Controller
  {
  }
}

aramkoukia

public void ConfigureServices(IServiceCollection services)
{
    services.AddMvc();
    services.AddApiVersioning(o => o.ApiVersionReader = new HeaderApiVersionReader("api-version"));
}

aramkoukia

using Confluent.Kafka;
using Confluent.Kafka.Serialization;
using System;
using System.Collections.Generic;
using System.Text;

namespace kafka_consumer
{
    class Program
    {

aramkoukia

using Confluent.Kafka;
using Confluent.Kafka.Serialization;
using System;
using System.Collections.Generic;
using System.Text;

namespace kafka_prototype
{
    class Program
    {

aramkoukia

Policy
  .Timeout(30, onTimeout: (context, timespan, task) => 
    {
        YourFunctionWhenTimeout(); 
    });

aramkoukia

Policy
   .Handle<Exception>()
   .Fallback<UserAvatar>(() => UserAvatar.GetRandomAvatar()) 

aramkoukia

Action<Exception, TimeSpan> onBreak = (exception, timespan) => { ... };
Action onReset = () => { ... };
CircuitBreakerPolicy breaker = Policy
    .Handle<Exception>()
    .CircuitBreaker(2, TimeSpan.FromMinutes(1), onBreak, onReset);

aramkoukia

Policy
    .Handle<Exception>()
    .CircuitBreaker(2, TimeSpan.FromMinutes(1));

aramkoukia

Policy
  .Handle<Exception>()
  .WaitAndRetry(new[]
  {
    TimeSpan.FromSeconds(1),
    TimeSpan.FromSeconds(2),
    TimeSpan.FromSeconds(3)
  }, (exception, timeSpan, context) => {
    YourFunction();
  });