Skip to content

Latest commit

 

History

History
41 lines (26 loc) · 564 Bytes

File metadata and controls

41 lines (26 loc) · 564 Bytes

CLI Commands

TODO: Available commands

Main Consumer

stream-processor

Starts the Pulsar consumer and processes frames.

Cleanup (One-shot)

stream-processor cleanup

Runs a single cleanup cycle. Useful for CronJob deployments.

Offline Checker

# Continuous mode
stream-processor offline-checker --continuous

# One-shot mode
stream-processor offline-checker --once

Archive Cleanup

stream-processor archive-cleanup

Removes expired archives.

Code Reference

  • src/stream_processor/main.py