StreamState

Tracks sequence numbers and cumulative hash chaining per stream partition.

Source: crypto.py

Fields

Field	Type	Required	Description	Validators
node_id	str		Originating node ID	-
stream_id	str		Stream partition ID	-
last_sequence_no	int		Last committed sequence number	-
last_hash	str		Last cumulative hash	-
updated_at	datetime		-	-

Configuration

Setting	Value
Submittable	False
Track Changes	True

Controller

Controller hooks are implemented in *_controller.py files. Available lifecycle hooks:

• validate() - Called before save, raise exceptions for validation errors
• before_insert() - Called before inserting a new document
• after_insert() - Called after successfully inserting
• before_save() - Called before saving (insert or update)
• after_save() - Called after saving
• before_delete() - Called before deleting
• after_delete() - Called after deleting