API Reference

• 1. aiomisc module
  • 1.1. aiomisc.aggregate module
    • AggregateAsyncFunc
    • AggregateFunc
    • AggregateStatistic
    • Aggregator
    • AggregatorAsync
    • Arg
    • ResultNotSetError
    • aggregate()
    • aggregate_async()
  • 1.2. aiomisc.backoff module
    • BackoffStatistic
    • RetryStatistic
    • asyncbackoff()
    • asyncretry()
  • 1.3. aiomisc.circuit_breaker module
    • CircuitBreaker
    • CircuitBreakerStates
    • CircuitBreakerStatistic
    • CircuitBroken
    • CounterKey
    • cutout()
    • random()
  • 1.4. aiomisc.compat module
    • EntrypointProtocol
    • EventLoopMixin
    • ParamSpec
    • Protocol
    • entry_pont_iterator()
    • final()
    • get_current_loop()
    • set_current_loop()
    • sock_set_nodelay()
    • sock_set_reuseport()
    • time_ns()
  • 1.5. aiomisc.context module
    • Context
    • get_context()
  • 1.6. aiomisc.counters module
    • AbstractStatistic
    • MetaStatistic
    • Metric
    • Statistic
    • StatisticResult
    • get_statistics()
  • 1.7. aiomisc.cron module
    • CronCallback
  • 1.8. aiomisc.entrypoint module
    • Entrypoint
    • entrypoint
    • get_context()
    • run()
  • 1.9. aiomisc.io module
    • AsyncBinaryIO
    • AsyncBz2BinaryIO
    • AsyncBz2TextIO
    • AsyncFileIO
    • AsyncGzipBinaryIO
    • AsyncGzipTextIO
    • AsyncLzmaBinaryIO
    • AsyncLzmaTextIO
    • AsyncTextIO
    • Compression
    • async_open()
  • 1.10. aiomisc.iterator_wrapper module
    • ChannelClosed
    • DequeWrapper
    • FromThreadChannel
    • IteratorProxy
    • IteratorWrapper
    • IteratorWrapperStatistic
    • QueueWrapper
    • QueueWrapperBase
    • make_queue()
  • 1.11. aiomisc.log module
    • LogFormat
    • LogLevel
    • basic_config()
  • 1.12. aiomisc.periodic module
    • PeriodicCallback
  • 1.13. aiomisc.plugins module
  • 1.14. aiomisc.pool module
    • ContextManager
    • PoolBase
    • random()
  • 1.15. aiomisc.process_pool module
    • ProcessPoolExecutor
    • ProcessPoolStatistic
  • 1.16. aiomisc.recurring module
    • RecurringCallback
    • RecurringCallbackStatistic
    • StrategyException
    • StrategySkip
    • StrategyStop
  • 1.17. aiomisc.signal module
    • Signal
    • receiver()
  • 1.18. aiomisc.thread_pool module
    • CoroutineWaiter
    • IteratorWrapperSeparate
    • TaskChannel
    • TaskChannelCloseException
    • ThreadPoolException
    • ThreadPoolExecutor
    • ThreadPoolStatistic
    • WorkItem
    • WorkItemBase
    • context_partial()
    • run_in_executor()
    • run_in_new_thread()
    • sync_await()
    • sync_wait_coroutine()
    • thread_pool_thread_loop()
    • threaded()
    • threaded_iterable()
    • threaded_iterable_separate()
    • threaded_separate()
    • wait_coroutine()
  • 1.19. aiomisc.timeout module
    • timeout()
  • 1.20. aiomisc.utils module
    • SelectAwaitable
    • SelectResult
    • awaitable()
    • bind_socket()
    • cancel_tasks()
    • chunk_list()
    • create_default_event_loop()
    • fast_uuid1()
    • fast_uuid4()
    • getrandbits()
    • new_event_loop()
    • pending_futures()
    • select
    • set_exception()
    • shield()
  • 1.21. aiomisc.worker_pool module
    • WorkerPool
    • WorkerPoolStatistic
• 2. aiomisc_log module
  • 2.1. aiomisc_log.formatter.color module
    • color_formatter()
  • 2.2. aiomisc_log.formatter.journald module
    • journald_formatter()
  • 2.3. aiomisc_log.formatter.json module
    • JSONLogFormatter
    • json_handler()
  • 2.4. aiomisc_log.formatter.rich.py module
    • rich_formatter()
  • 2.5. aiomisc_log.enum module
    • DateFormat
    • LogFormat
    • LogLevel
• 3. aiomisc_worker module
  • 3.1. aiomisc_worker.forking module
    • at_exit()
    • fork()
    • handle_interrupt()
    • main()
  • 3.2. aiomisc_worker.process module
    • Worker
    • at_exit()
    • main()
  • 3.3. aiomisc_worker.process_inner module
    • worker_inner()
  • 3.4. aiomisc_worker.protocol module
    • AsyncProtocol
    • FileIOProtocol
    • Protocol
    • SocketIOProtocol
  • 3.5. aiomisc_worker.worker module
    • bad_initializer()
    • execute()
    • on_cancel_signal()
    • on_exception()
    • worker()