rivusio

Core API Reference

Base Classes

::: rivusio.core.base.BasePipe options: show_root_heading: true show_source: true

::: rivusio.core.execution_strategy.ExecutionStrategy options: show_root_heading: true show_source: true

::: rivusio.core.metrics.PipelineMetricsMixin options: show_root_heading: true show_source: true

Exceptions

::: rivusio.core.exceptions.PipeError options: show_root_heading: true show_source: true

::: rivusio.core.exceptions.PipelineError options: show_root_heading: true show_source: true

::: rivusio.core.message.Message options: show_root_heading: true show_source: true

::: rivusio.core.message.MessageMetadata options: show_root_heading: true show_source: true

Types

::: rivusio.core.types.InputType options: show_root_heading: true show_source: true

::: rivusio.core.types.OutputType options: show_root_heading: true show_source: true

::: rivusio.core.types.BatchT options: show_root_heading: true show_source: true

::: rivusio.core.types.StreamType options: show_root_heading: true show_source: true

::: rivusio.core.types.T options: show_root_heading: true show_source: true

This site is open source. Improve this page.