@callback collect_metrics(stream_state :: map()) :: map()

@callback update_metrics(stream_state :: map(), event_type :: atom()) :: map()