@@ -6343,7 +6343,7 @@ Flush the recovery update to the storage.
6343
6343
class StateStoreManager()
6344
6344
```
6345
6345
6346
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L24 )
6346
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L27 )
6347
6347
6348
6348
Class for managing state stores and partitions.
6349
6349
@@ -6361,7 +6361,7 @@ StateStoreManager is responsible for:
6361
6361
def stores() -> Dict[str, Dict[str, Store]]
6362
6362
```
6363
6363
6364
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L62 )
6364
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L67 )
6365
6365
6366
6366
Map of registered state stores
6367
6367
@@ -6378,7 +6378,7 @@ dict in format {topic: {store_name: store}}
6378
6378
def recovery_required() -> bool
6379
6379
```
6380
6380
6381
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L70 )
6381
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L75 )
6382
6382
6383
6383
Whether recovery needs to be done.
6384
6384
@@ -6391,7 +6391,7 @@ Whether recovery needs to be done.
6391
6391
def using_changelogs() -> bool
6392
6392
```
6393
6393
6394
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L79 )
6394
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L84 )
6395
6395
6396
6396
Whether the StateStoreManager is using changelog topics
6397
6397
@@ -6407,7 +6407,7 @@ using changelogs, as bool
6407
6407
def do_recovery()
6408
6408
```
6409
6409
6410
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L87 )
6410
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L96 )
6411
6411
6412
6412
Perform a state recovery, if necessary.
6413
6413
@@ -6419,7 +6419,7 @@ Perform a state recovery, if necessary.
6419
6419
def stop_recovery()
6420
6420
```
6421
6421
6422
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L93 )
6422
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L102 )
6423
6423
6424
6424
Stop recovery (called during app shutdown).
6425
6425
@@ -6431,7 +6431,7 @@ Stop recovery (called during app shutdown).
6431
6431
def get_store(topic: str, store_name: str = DEFAULT_STATE_STORE_NAME) -> Store
6432
6432
```
6433
6433
6434
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L99 )
6434
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L108 )
6435
6435
6436
6436
Get a store for given name and topic
6437
6437
@@ -6450,10 +6450,11 @@ instance of `Store`
6450
6450
6451
6451
```python
6452
6452
def register_store(topic_name: str,
6453
- store_name: str = DEFAULT_STATE_STORE_NAME)
6453
+ store_name: str = DEFAULT_STATE_STORE_NAME,
6454
+ store_type: Optional[StoreTypes] = None)
6454
6455
```
6455
6456
6456
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L132 )
6457
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L141 )
6457
6458
6458
6459
Register a state store to be managed by StateStoreManager.
6459
6460
@@ -6466,6 +6467,8 @@ Each store can be registered only once for each topic.
6466
6467
6467
6468
- `topic_name`: topic name
6468
6469
- `store_name`: store name
6470
+ - `store_type`: the storage type used for this store.
6471
+ Default to StateStoreManager `default_store_type`
6469
6472
6470
6473
<a id="quixstreams.state.manager.StateStoreManager.register_windowed_store"></a>
6471
6474
@@ -6475,7 +6478,7 @@ Each store can be registered only once for each topic.
6475
6478
def register_windowed_store(topic_name: str, store_name: str)
6476
6479
```
6477
6480
6478
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L157 )
6481
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L177 )
6479
6482
6480
6483
Register a windowed state store to be managed by StateStoreManager.
6481
6484
@@ -6497,7 +6500,7 @@ Each window store can be registered only once for each topic.
6497
6500
def clear_stores()
6498
6501
```
6499
6502
6500
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L183 )
6503
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L203 )
6501
6504
6502
6505
Delete all state stores managed by StateStoreManager.
6503
6506
@@ -6510,7 +6513,7 @@ def on_partition_assign(topic: str, partition: int,
6510
6513
committed_offset: int) -> List[StorePartition]
6511
6514
```
6512
6515
6513
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L198 )
6516
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L218 )
6514
6517
6515
6518
Assign store partitions for each registered store for the given `TopicPartition`
6516
6519
@@ -6534,7 +6537,7 @@ list of assigned `StorePartition`
6534
6537
def on_partition_revoke(topic: str, partition: int)
6535
6538
```
6536
6539
6537
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L224 )
6540
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L244 )
6538
6541
6539
6542
Revoke store partitions for each registered store for the given `TopicPartition`
6540
6543
@@ -6551,7 +6554,7 @@ Revoke store partitions for each registered store for the given `TopicPartition`
6551
6554
def init()
6552
6555
```
6553
6556
6554
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L237 )
6557
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L257 )
6555
6558
6556
6559
Initialize `StateStoreManager` and create a store directory
6557
6560
@@ -6564,7 +6567,7 @@ Initialize `StateStoreManager` and create a store directory
6564
6567
def close()
6565
6568
```
6566
6569
6567
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L244 )
6570
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L264 )
6568
6571
6569
6572
Close all registered stores
6570
6573
0 commit comments