Skip to main content

API Reference

info

Complete API reference for Fluvius Framework.

Domain API

Domain Class

class Domain:
def create_command(self, name: str, payload: dict) -> Command
async def process_command(self, command: Command) -> dict
def set_aggroot(self, resource: str, id: str)

Aggregate API

Aggregate Class

class Aggregate:
@action(evt_key: str, resources: list)
async def action_method(self, ...) -> dict

Next Steps