What problem does it solve? Adding monitoring, circuit breaking, rate limiting, or distributed tracing to funboost consumers normally requires modifying broker internals. This Skill guides you to build Mixin extension classes that intercept consumer and publisher methods via Python MRO, injecting cross-cutting logic without touching the framework core. ## Core Features & Use Cases - Consumer Mixin Templates: Override hooks like _submit_task, _run, and the three post-execution record hooks to add metrics, circuit breakers, and quota checks. - Publisher Mixin Support: Intercept _publish_impl and _after_publish to add publish-side logging and metrics. - Hook Selection Guidance: Explains which of the three post-execution hooks allows blocking IO, async IO, or CPU-only operations, preventing consumer slowdowns. - Use Case: You want Prometheus metrics and a circuit breaker on a Redis-backed queue. Write a Mixin combining CircuitBreakerConsumerMixin and PrometheusConsumerMixin, then pass it via consumer_override_cls in BoosterParams with namespaced user_options config. ## Quick Start Ask the AI to write a funboost Consumer Mixin that counts task failures and sends an alert when failures exceed a threshold, then wire it into a @boost decorated function.
