ISagasBuffer.cs
395 Bytes
using Pole.Sagas.Core;
using Pole.Sagas.Server.Grpc;
using System;
using System.Collections.Generic;
using System.Text;
using System.Threading.Tasks;
namespace Pole.Sagas.Server
{
public interface ISagasBuffer
{
Task<IEnumerable<SagaEntity>> GetSagas(string serviceName, int limit);
Task<bool> AddSagas(IAsyncEnumerable<SagasGroupEntity> sagasGroupEntities);
}
}