Rystem.RepositoryFramework.Abstractions
1.1.17
See the version list below for details.
dotnet add package Rystem.RepositoryFramework.Abstractions --version 1.1.17
NuGet\Install-Package Rystem.RepositoryFramework.Abstractions -Version 1.1.17
<PackageReference Include="Rystem.RepositoryFramework.Abstractions" Version="1.1.17" />
paket add Rystem.RepositoryFramework.Abstractions --version 1.1.17
#r "nuget: Rystem.RepositoryFramework.Abstractions, 1.1.17"
// Install Rystem.RepositoryFramework.Abstractions as a Cake Addin #addin nuget:?package=Rystem.RepositoryFramework.Abstractions&version=1.1.17 // Install Rystem.RepositoryFramework.Abstractions as a Cake Tool #tool nuget:?package=Rystem.RepositoryFramework.Abstractions&version=1.1.17
What is Rystem?
Interfaces
Based on CQRS we could split our repository pattern in two main interfaces, one for update (write, delete) and one for read.
Command (Write-Delete)
public interface ICommandPattern<T, TKey, TState> : ICommandPattern
where TKey : notnull
where TState : class, IState<T>, new()
{
Task<TState> InsertAsync(TKey key, T value, CancellationToken cancellationToken = default);
Task<TState> UpdateAsync(TKey key, T value, CancellationToken cancellationToken = default);
Task<TState> DeleteAsync(TKey key, CancellationToken cancellationToken = default);
Task<BatchResults<TKey, TState>> BatchAsync(BatchOperations<T, TKey, State<T>> operations, CancellationToken cancellationToken = default);
}
Query (Read)
public interface IQueryPattern<T, TKey, TState> : IQueryPattern
where TKey : notnull
where TState : class, IState<T>, new()
{
Task<T?> GetAsync(TKey key, CancellationToken cancellationToken = default);
Task<TState> ExistAsync(TKey key, CancellationToken cancellationToken = default);
Task<IEnumerable<T>> QueryAsync(QueryOptions<T>? options = null, CancellationToken cancellationToken = default);
Task<long> CountAsync(QueryOptions<T>? options = null, CancellationToken cancellationToken = default);
}
Repository Pattern (Write-Delete-Read)
Repository pattern is a sum of CQRS interfaces.
public interface IRepositoryPattern<T, TKey, TState> : ICommandPattern<T, TKey, TState>, IQueryPattern<T, TKey, TState>, IRepositoryPattern, ICommandPattern, IQueryPattern
where TKey : notnull
where TState : class, IState<T>, new()
{
}
With State as TState
Command (Write-Delete)
public interface ICommandPattern<T, TKey> : ICommandPattern<T, TKey, State<T>>, ICommandPattern
where TKey : notnull
{
Task<State<T>> InsertAsync(TKey key, T value, CancellationToken cancellationToken = default);
Task<State<T>> UpdateAsync(TKey key, T value, CancellationToken cancellationToken = default);
Task<State<T>> DeleteAsync(TKey key, CancellationToken cancellationToken = default);
Task<BatchResults<TKey, State<T>>> BatchAsync(BatchOperations<T, TKey, State<T>> operations, CancellationToken cancellationToken = default);
}
Query (Read)
public interface IQueryPattern<T, TKey> : IQueryPattern<T, TKey, State<T>>, IQueryPattern
where TKey : notnull
{
Task<T?> GetAsync(TKey key, CancellationToken cancellationToken = default);
Task<State<T>> ExistAsync(TKey key, CancellationToken cancellationToken = default);
Task<IEnumerable<T>> QueryAsync(QueryOptions<T>? options = null, CancellationToken cancellationToken = default);
Task<long> CountAsync(QueryOptions<T>? options = null, CancellationToken cancellationToken = default);
}
Repository Pattern (Write-Delete-Read)
Repository pattern is a sum of CQRS interfaces.
public interface IRepositoryPattern<T, TKey> : IRepositoryPattern<T, TKey, State<T>>, ICommandPattern<T, TKey>, IQueryPattern<T, TKey>, IRepositoryPattern, ICommandPattern, IQueryPattern
where TKey : notnull
{
}
With State as TState and string as TKey
Command (Write-Delete)
public interface ICommandPattern<T> : ICommandPattern<T, string>, ICommandPattern
{
Task<State<T>> InsertAsync(string key, T value, CancellationToken cancellationToken = default);
Task<State<T>> UpdateAsync(string key, T value, CancellationToken cancellationToken = default);
Task<State<T>> DeleteAsync(string key, CancellationToken cancellationToken = default);
Task<BatchResults<string, State<T>>> BatchAsync(BatchOperations<T, string> operations, CancellationToken cancellationToken = default);
}
Query (Read)
public interface IQueryPattern<T> : IQueryPattern<T, string>, IQueryPattern
{
Task<T?> GetAsync(string key, CancellationToken cancellationToken = default);
Task<State<T>> ExistAsync(string key, CancellationToken cancellationToken = default);
Task<IEnumerable<T>> QueryAsync(QueryOptions<T>? options = null, CancellationToken cancellationToken = default);
Task<long> CountAsync(QueryOptions<T>? options = null, CancellationToken cancellationToken = default);
}
Repository Pattern (Write-Delete-Read)
Repository pattern is a sum of CQRS interfaces.
public interface IRepositoryPattern<T> : IRepositoryPattern<T, string>, ICommandPattern<T>, IQueryPattern<T>, IRepositoryPattern, ICommandPattern, IQueryPattern
where TKey : notnull
{
}
Examples
Model
public class User
{
public string Id { get; set; }
public string Name { get; set; }
public string Email { get; set; }
}
Command
public class UserWriter : ICommandPattern<User, string>
{
public Task<State<T>> DeleteAsync(string key, CancellationToken cancellationToken = default)
{
//delete on with DB or storage context
throw new NotImplementedException();
}
public Task<State<T>> InsertAsync(string key, User value, CancellationToken cancellationToken = default)
{
//insert on DB or storage context
throw new NotImplementedException();
}
public Task<State<T>> UpdateAsync(string key, User value, CancellationToken cancellationToken = default)
{
//update on DB or storage context
throw new NotImplementedException();
}
public Task<BatchResults<string, State<T>>> BatchAsync(BatchOperations<User, string> operations, CancellationToken cancellationToken = default)
{
//insert, update or delete some items on DB or storage context
throw new NotImplementedException();
}
}
Query
public class UserReader : IQueryPattern<User, string>
{
public Task<User?> GetAsync(string key, CancellationToken cancellationToken = default)
{
//get an item by key from DB or storage context
throw new NotImplementedException();
}
public Task<State<T>> ExistAsync(string key, CancellationToken cancellationToken = default)
{
//check if an item by key exists in DB or storage context
throw new NotImplementedException();
}
public Task<IEnumerable<User>> QueryAsync(QueryOptions<T>? options = null, CancellationToken cancellationToken = default)
{
//get a list of items by a predicate with top and skip from DB or storage context
throw new NotImplementedException();
}
public Task<long> CountAsync(QueryOptions<T>? options = null, CancellationToken cancellationToken = default)
{
//get an items count by a predicate with top and skip from DB or storage context
throw new NotImplementedException();
}
}
Alltogether as repository pattern
if you don't have CQRS infrastructure (usually it's correct to use CQRS when you have minimum two infrastructures one for write and delete and at least one for read)
public class UserRepository : IRepositoryPattern<User, string>, IQueryPattern<User, string>, ICommandPattern<User, string>
{
public Task<State<T>> DeleteAsync(string key, CancellationToken cancellationToken = default)
{
//delete on with DB or storage context
throw new NotImplementedException();
}
public Task<State<T>> InsertAsync(string key, User value, CancellationToken cancellationToken = default)
{
//insert on DB or storage context
throw new NotImplementedException();
}
public Task<State<T>> UpdateAsync(string key, User value, CancellationToken cancellationToken = default)
{
//update on DB or storage context
throw new NotImplementedException();
}
public Task<BatchResults<string, State<T>>> BatchAsync(BatchOperations<User, string> operations, CancellationToken cancellationToken = default)
{
//insert, update or delete some items on DB or storage context
throw new NotImplementedException();
}
public Task<User?> GetAsync(string key, CancellationToken cancellationToken = default)
{
//get an item by key from DB or storage context
throw new NotImplementedException();
}
public Task<State<T>> ExistAsync(string key, CancellationToken cancellationToken = default)
{
//check if an item by key exists in DB or storage context
throw new NotImplementedException();
}
public Task<IEnumerable<User>> QueryAsync(QueryOptions<T>? options = null, CancellationToken cancellationToken = default)
{
//get a list of items by a predicate with top and skip from DB or storage context
throw new NotImplementedException();
}
public Task<long> CountAsync(QueryOptions<T>? options = null, CancellationToken cancellationToken = default)
{
//get an items count by a predicate with top and skip from DB or storage context
throw new NotImplementedException();
}
}
How to use it
In DI you install the service
services.AddRepository<User, string, UserRepository>();
And you may inject the object
IRepository<User, string> repository
Query and Command
In DI you install the services
services.AddCommand<User, string, UserWriter>();
services.AddQuery<User, string, UserReader>();
And you may inject the objects
ICommand<User, string> command
IQuery<User, string> command
Example with default key
In DI you install the services
services.AddRepository<User, UserRepository>();
services.AddCommand<User, UserWriter>();
services.AddQuery<User, UserReader>();
And you may inject the objects
IRepository<User> repository
ICommand<User> command
IQuery<User> command
Example with TState
In DI you install the services, in example we are using a Result class that is an IState<T>, instead the default integration State.
services.AddRepository<User, string, Result, UserRepository>();
services.AddCommand<User, string, Result, UserWriter>();
services.AddQuery<User, string, Result, UserReader>();
And you may inject the objects
IRepository<User, string, Result> repository
ICommand<User, string, Result> command
IQuery<User, string, Result> command
Twice or more configurations for the same repository service
Pay attention during the DI, you may install the same repository two or more times for the same model. If you want to be sure, you may start the DI with a method that checks for you. When can it happen? For instance, when you use at the same time InMemory integration with a custom integration.
services.ThrowExceptionIfARepositoryServiceIsAddedTwoOrMoreTimes();
TKey when it's not a primitive
You can use a class or record. Record is better, for example, if you want to use the Equals operator from key, with record you don't check it by the refence but by the value of the properties in the record. My key:
public class MyKey
{
public int Id { get; set; }
public int Id2 { get; set; }
}
the DI
services.AddRepository<User, MyKey, Result, UserRepository>();
and you may inject (for ICommand and IQuery is the same)
IRepository<User, MyKey, Result> repository
Default TKey record
You may use the default record in repository framework namespace. For 1 value (it's not really useful I know, but I liked to create it).
new Key<int>(2);
or for 2 values
new Key<int, int>(2, 4);
or for 3 values
new Key<int, int, string>(2, 4, "312");
or for 4 values
new Key<int, int, string, Guid>(2, 4, "312", Guid.NewGuid());
or for 5 values
new Key<int, int, string, Guid, string>(2, 4, "312", Guid.NewGuid(), "3232");
the DI
services.AddRepository<User, Key<int, int>, Result, UserRepository>();
and you may inject (for ICommand and IQuery is the same)
IRepository<User, Key<int, int>, Result> repository
Entity framework examples
Product | Versions Compatible and additional computed target framework versions. |
---|---|
.NET | net6.0 is compatible. net6.0-android was computed. net6.0-ios was computed. net6.0-maccatalyst was computed. net6.0-macos was computed. net6.0-tvos was computed. net6.0-windows was computed. net7.0 was computed. net7.0-android was computed. net7.0-ios was computed. net7.0-maccatalyst was computed. net7.0-macos was computed. net7.0-tvos was computed. net7.0-windows was computed. net8.0 was computed. 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. |
-
net6.0
- Microsoft.Extensions.DependencyInjection.Abstractions (>= 6.0.0)
- Rystem (>= 4.0.26)
- System.Interactive (>= 6.0.1)
- System.Interactive.Async (>= 6.0.1)
NuGet packages (12)
Showing the top 5 NuGet packages that depend on Rystem.RepositoryFramework.Abstractions:
Package | Downloads |
---|---|
Rystem.RepositoryFramework.Api.Server
Rystem.RepositoryFramework allows you to use correctly concepts like repository pattern, CQRS and DDD. You have interfaces for your domains, auto-generated api, auto-generated HttpClient to simplify connection "api to front-end", a functionality for auto-population in memory of your models, a functionality to simulate exceptions and waiting time from external sources to improve your implementation/business test and load test. |
|
Rystem.RepositoryFramework.Api.Client
Rystem.RepositoryFramework allows you to use correctly concepts like repository pattern, CQRS and DDD. You have interfaces for your domains, auto-generated api, auto-generated HttpClient to simplify connection "api to front-end", a functionality for auto-population in memory of your models, a functionality to simulate exceptions and waiting time from external sources to improve your implementation/business test and load test. |
|
Rystem.RepositoryFramework.Infrastructure.Azure.Storage.Blob
Rystem.RepositoryFramework allows you to use correctly concepts like repository pattern, CQRS and DDD. You have interfaces for your domains, auto-generated api, auto-generated HttpClient to simplify connection "api to front-end", a functionality for auto-population in memory of your models, a functionality to simulate exceptions and waiting time from external sources to improve your implementation/business test and load test. |
|
Rystem.RepositoryFramework.Infrastructure.Azure.Storage.Table
Rystem.RepositoryFramework allows you to use correctly concepts like repository pattern, CQRS and DDD. You have interfaces for your domains, auto-generated api, auto-generated HttpClient to simplify connection "api to front-end", a functionality for auto-population in memory of your models, a functionality to simulate exceptions and waiting time from external sources to improve your implementation/business test and load test. |
|
Rystem.RepositoryFramework.Cache
Rystem.RepositoryFramework allows you to use correctly concepts like repository pattern, CQRS and DDD. You have interfaces for your domains, auto-generated api, auto-generated HttpClient to simplify connection "api to front-end", a functionality for auto-population in memory of your models, a functionality to simulate exceptions and waiting time from external sources to improve your implementation/business test and load test. |
GitHub repositories
This package is not used by any popular GitHub repositories.
Version | Downloads | Last updated |
---|---|---|
9.0.0-rc.1 | 125 | 10/18/2024 |
6.2.0 | 182,123 | 10/9/2024 |
6.1.1 | 212 | 10/9/2024 |
6.1.0 | 48,080 | 9/29/2024 |
6.0.24 | 348 | 9/11/2024 |
6.0.23 | 340,252 | 7/18/2024 |
6.0.21 | 286 | 6/18/2024 |
6.0.20 | 727,869 | 6/16/2024 |
6.0.19 | 30,678 | 6/14/2024 |
6.0.18 | 255 | 6/14/2024 |
6.0.17 | 258 | 6/14/2024 |
6.0.16 | 50,123 | 6/10/2024 |
6.0.15 | 267 | 6/9/2024 |
6.0.14 | 94,588 | 5/24/2024 |
6.0.13 | 270 | 5/23/2024 |
6.0.12 | 227 | 5/23/2024 |
6.0.11 | 297 | 5/20/2024 |
6.0.9 | 288 | 5/19/2024 |
6.0.7 | 257 | 5/18/2024 |
6.0.6 | 287 | 5/10/2024 |
6.0.5 | 231 | 5/10/2024 |
6.0.4 | 550,227 | 4/3/2024 |
6.0.3 | 1,504 | 3/25/2024 |
6.0.2 | 378,190 | 3/11/2024 |
6.0.1 | 51,170 | 3/8/2024 |
6.0.0 | 1,171,995 | 11/21/2023 |
6.0.0-rc.6 | 140 | 10/25/2023 |
6.0.0-rc.5 | 107 | 10/25/2023 |
6.0.0-rc.4 | 96 | 10/23/2023 |
6.0.0-rc.3 | 82 | 10/19/2023 |
6.0.0-rc.2 | 121 | 10/18/2023 |
6.0.0-rc.1 | 133 | 10/16/2023 |
5.0.20 | 641,466 | 9/25/2023 |
5.0.19 | 3,185 | 9/10/2023 |
5.0.18 | 2,455 | 9/6/2023 |
5.0.17 | 2,353 | 9/6/2023 |
5.0.16 | 2,408 | 9/5/2023 |
5.0.15 | 2,365 | 9/5/2023 |
5.0.14 | 2,379 | 9/5/2023 |
5.0.13 | 2,441 | 9/1/2023 |
5.0.12 | 2,303 | 8/31/2023 |
5.0.11 | 2,326 | 8/30/2023 |
5.0.10 | 2,361 | 8/29/2023 |
5.0.9 | 2,419 | 8/24/2023 |
5.0.8 | 2,467 | 8/24/2023 |
5.0.7 | 451,919 | 8/23/2023 |
5.0.6 | 19,822 | 8/21/2023 |
5.0.5 | 6,572 | 8/21/2023 |
5.0.4 | 2,474 | 8/16/2023 |
5.0.3 | 214,998 | 8/2/2023 |
5.0.2 | 4,289 | 8/2/2023 |
5.0.1 | 14,041 | 8/1/2023 |
5.0.0 | 14,445 | 7/31/2023 |
4.1.26 | 143,321 | 7/20/2023 |
4.1.25 | 27,130 | 7/16/2023 |
4.1.24 | 400,537 | 6/13/2023 |
4.1.23 | 48,212 | 6/13/2023 |
4.1.22 | 132,166 | 5/30/2023 |
4.1.21 | 58,194 | 5/20/2023 |
4.1.20 | 407,569 | 4/19/2023 |
4.1.19 | 98,335 | 3/20/2023 |
4.1.18 | 2,889 | 3/20/2023 |
4.1.17 | 3,141 | 3/16/2023 |
4.1.16 | 2,886 | 3/16/2023 |
4.1.15 | 2,842 | 3/15/2023 |
4.1.14 | 10,561 | 3/9/2023 |
4.1.13 | 2,993 | 3/7/2023 |
4.1.12 | 3,450 | 2/9/2023 |
4.1.11 | 3,052 | 1/26/2023 |
4.1.10 | 3,275 | 1/22/2023 |
4.1.9 | 2,936 | 1/20/2023 |
4.1.8 | 3,211 | 1/18/2023 |
4.1.7 | 3,164 | 1/18/2023 |
4.1.6 | 3,231 | 1/17/2023 |
4.1.1 | 3,188 | 1/4/2023 |
4.1.0 | 3,070 | 1/1/2023 |
3.1.5 | 3,020 | 12/21/2022 |
3.1.4 | 1,537 | 12/21/2022 |
3.1.3 | 3,329 | 12/12/2022 |
3.1.2 | 3,081 | 12/7/2022 |
3.1.1 | 3,169 | 12/7/2022 |
3.1.0 | 3,149 | 12/1/2022 |
3.0.29 | 3,116 | 12/1/2022 |
3.0.28 | 3,947 | 12/1/2022 |
3.0.27 | 3,319 | 11/23/2022 |
3.0.25 | 6,882 | 11/23/2022 |
3.0.24 | 4,539 | 11/18/2022 |
3.0.23 | 4,214 | 11/18/2022 |
3.0.22 | 4,354 | 11/15/2022 |
3.0.21 | 4,393 | 11/14/2022 |
3.0.20 | 4,459 | 11/13/2022 |
3.0.19 | 4,751 | 11/2/2022 |
3.0.18 | 4,489 | 11/2/2022 |
3.0.17 | 4,567 | 10/29/2022 |
3.0.16 | 4,644 | 10/29/2022 |
3.0.15 | 1,635 | 10/29/2022 |
3.0.14 | 7,473 | 10/24/2022 |
3.0.13 | 4,692 | 10/24/2022 |
3.0.12 | 4,702 | 10/17/2022 |
3.0.11 | 4,655 | 10/10/2022 |
3.0.10 | 4,214 | 10/6/2022 |
3.0.9 | 4,142 | 10/6/2022 |
3.0.8 | 4,116 | 10/6/2022 |
3.0.7 | 4,226 | 10/6/2022 |
3.0.6 | 4,220 | 10/5/2022 |
3.0.5 | 4,120 | 10/5/2022 |
3.0.4 | 4,190 | 10/5/2022 |
3.0.3 | 4,170 | 10/3/2022 |
3.0.2 | 4,230 | 9/30/2022 |
3.0.1 | 4,173 | 9/29/2022 |
3.0.0 | 1,671 | 9/29/2022 |
2.0.17 | 3,811 | 9/29/2022 |
2.0.16 | 4,292 | 9/27/2022 |
2.0.15 | 4,402 | 9/27/2022 |
2.0.14 | 4,307 | 9/26/2022 |
2.0.13 | 4,231 | 9/26/2022 |
2.0.12 | 4,227 | 9/26/2022 |
2.0.11 | 4,165 | 9/25/2022 |
2.0.10 | 4,372 | 9/25/2022 |
2.0.9 | 4,241 | 9/22/2022 |
2.0.8 | 4,161 | 9/22/2022 |
2.0.7 | 1,679 | 9/22/2022 |
2.0.6 | 4,173 | 9/20/2022 |
2.0.5 | 4,369 | 9/20/2022 |
2.0.4 | 4,250 | 9/20/2022 |
2.0.2 | 4,267 | 9/20/2022 |
2.0.1 | 4,490 | 9/13/2022 |
2.0.0 | 4,355 | 8/19/2022 |
1.1.24 | 4,375 | 7/30/2022 |
1.1.23 | 4,314 | 7/29/2022 |
1.1.22 | 4,124 | 7/29/2022 |
1.1.21 | 4,528 | 7/29/2022 |
1.1.20 | 4,291 | 7/29/2022 |
1.1.19 | 4,320 | 7/27/2022 |
1.1.17 | 4,334 | 7/27/2022 |
1.1.16 | 4,331 | 7/26/2022 |
1.1.15 | 4,368 | 7/25/2022 |
1.1.14 | 4,330 | 7/25/2022 |
1.1.13 | 4,227 | 7/22/2022 |
1.1.12 | 4,224 | 7/19/2022 |
1.1.11 | 4,301 | 7/19/2022 |
1.1.10 | 4,273 | 7/19/2022 |
1.1.9 | 4,319 | 7/19/2022 |
1.1.8 | 4,372 | 7/18/2022 |
1.1.7 | 4,208 | 7/18/2022 |
1.1.6 | 4,298 | 7/18/2022 |
1.1.5 | 4,292 | 7/17/2022 |
1.1.4 | 1,653 | 7/17/2022 |
1.1.3 | 6,811 | 7/17/2022 |
1.1.2 | 4,350 | 7/17/2022 |
1.1.1 | 1,686 | 7/17/2022 |
1.1.0 | 4,290 | 7/17/2022 |
1.0.2 | 4,295 | 7/15/2022 |
1.0.1 | 2,980 | 7/15/2022 |
1.0.0 | 5,486 | 7/8/2022 |
0.10.7 | 4,300 | 7/7/2022 |
0.10.6 | 1,746 | 7/7/2022 |
0.10.3 | 2,197 | 7/7/2022 |
0.10.2 | 5,743 | 7/2/2022 |
0.10.1 | 4,301 | 7/1/2022 |
0.10.0 | 4,101 | 7/1/2022 |
0.9.10 | 5,404 | 6/20/2022 |
0.9.9 | 4,343 | 6/11/2022 |
0.9.8 | 1,670 | 6/10/2022 |
0.9.7 | 4,238 | 6/9/2022 |
0.9.6 | 4,227 | 6/5/2022 |
0.9.5 | 2,844 | 6/3/2022 |
0.9.3 | 4,135 | 6/3/2022 |
0.9.2 | 2,454 | 5/31/2022 |
0.9.1 | 2,409 | 5/31/2022 |
0.9.0 | 2,395 | 5/31/2022 |
0.8.3-beta.1 | 110 | 5/31/2022 |
0.8.2 | 1,715 | 5/30/2022 |
0.8.1 | 1,724 | 5/29/2022 |