Skip to content

Commit c29325b

Browse files
author
Sergio García Prado
committed
ISSUE #99
* Add `minos-database-lmdb` classes skeleton
1 parent 4ecea70 commit c29325b

File tree

13 files changed

+112
-116
lines changed

13 files changed

+112
-116
lines changed

packages/core/minos-microservice-saga/minos/saga/__init__.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -53,6 +53,7 @@
5353
RequestExecutor,
5454
ResponseExecutor,
5555
SagaExecution,
56+
SagaExecutionDatabaseOperationFactory,
5657
SagaExecutionStorage,
5758
SagaStatus,
5859
SagaStepExecution,

packages/core/minos-microservice-saga/minos/saga/executions/__init__.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,9 @@
11
from .commit import (
22
TransactionCommitter,
33
)
4+
from .database import (
5+
SagaExecutionDatabaseOperationFactory,
6+
)
47
from .executors import (
58
Executor,
69
LocalExecutor,
Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
from .factories import (
2+
SagaExecutionDatabaseOperationFactory,
3+
)
Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
from abc import (
2+
ABC,
3+
)
4+
5+
from minos.common import (
6+
DatabaseOperationFactory,
7+
)
8+
9+
10+
class SagaExecutionDatabaseOperationFactory(DatabaseOperationFactory, ABC):
11+
"""TODO"""

packages/plugins/minos-database-lmdb/minos/plugins/lmdb/__init__.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,3 +3,13 @@
33
__author__ = "Minos Framework Devs"
44
__email__ = "[email protected]"
55
__version__ = "0.0.0"
6+
7+
from .clients import (
8+
LmdbDatabaseClient,
9+
)
10+
from .factories import (
11+
LmdbSagaExecutionDatabaseOperationFactory,
12+
)
13+
from .operations import (
14+
LmdbDatabaseOperation,
15+
)
Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,25 @@
1+
from typing import (
2+
Any,
3+
AsyncIterator,
4+
)
5+
6+
from minos.common import (
7+
DatabaseClient,
8+
DatabaseOperation,
9+
)
10+
11+
12+
class LmdbDatabaseClient(DatabaseClient):
13+
"""TODO"""
14+
15+
async def _is_valid(self, **kwargs) -> bool:
16+
pass
17+
18+
async def _reset(self, **kwargs) -> None:
19+
pass
20+
21+
async def _execute(self, operation: DatabaseOperation) -> None:
22+
pass
23+
24+
def _fetch_all(self, *args, **kwargs) -> AsyncIterator[Any]:
25+
pass
Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
from .saga import (
2+
LmdbSagaExecutionDatabaseOperationFactory,
3+
)
Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
from .executions import (
2+
LmdbSagaExecutionDatabaseOperationFactory,
3+
)
Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
from minos.saga import (
2+
SagaExecutionDatabaseOperationFactory,
3+
)
4+
5+
6+
class LmdbSagaExecutionDatabaseOperationFactory(SagaExecutionDatabaseOperationFactory):
7+
"""TODO"""
Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
from minos.common import (
2+
DatabaseOperation,
3+
)
4+
5+
6+
class LmdbDatabaseOperation(DatabaseOperation):
7+
"""TODO"""

0 commit comments

Comments
 (0)