nautilus_serialization/python/
mod.rs

1// -------------------------------------------------------------------------------------------------
2//  Copyright (C) 2015-2026 Nautech Systems Pty Ltd. All rights reserved.
3//  https://nautechsystems.io
4//
5//  Licensed under the GNU Lesser General Public License Version 3.0 (the "License");
6//  You may not use this file except in compliance with the License.
7//  You may obtain a copy of the License at https://www.gnu.org/licenses/lgpl-3.0.en.html
8//
9//  Unless required by applicable law or agreed to in writing, software
10//  distributed under the License is distributed on an "AS IS" BASIS,
11//  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12//  See the License for the specific language governing permissions and
13//  limitations under the License.
14// -------------------------------------------------------------------------------------------------
15
16//! Python bindings from [PyO3](https://pyo3.rs).
17
18#[cfg(feature = "arrow")]
19pub mod arrow;
20
21use pyo3::prelude::*;
22
23/// Loaded as `nautilus_pyo3.serialization`.
24///
25/// # Errors
26///
27/// Returns a `PyErr` if registering any module components fails.
28// Allow unused `m` when no feature-gated content registers on the module
29#[allow(unused_variables)]
30#[pymodule]
31pub fn serialization(_: Python<'_>, m: &Bound<'_, PyModule>) -> PyResult<()> {
32    #[cfg(feature = "arrow")]
33    {
34        m.add_function(wrap_pyfunction!(
35            crate::python::arrow::get_arrow_schema_map,
36            m
37        )?)?;
38        m.add_function(wrap_pyfunction!(
39            crate::python::arrow::pyobjects_to_arrow_record_batch_bytes,
40            m
41        )?)?;
42        m.add_function(wrap_pyfunction!(
43            crate::python::arrow::py_book_deltas_to_arrow_record_batch_bytes,
44            m
45        )?)?;
46        m.add_function(wrap_pyfunction!(
47            crate::python::arrow::py_book_depth10_to_arrow_record_batch_bytes,
48            m
49        )?)?;
50        m.add_function(wrap_pyfunction!(
51            crate::python::arrow::py_quotes_to_arrow_record_batch_bytes,
52            m
53        )?)?;
54        m.add_function(wrap_pyfunction!(
55            crate::python::arrow::py_trades_to_arrow_record_batch_bytes,
56            m
57        )?)?;
58        m.add_function(wrap_pyfunction!(
59            crate::python::arrow::py_bars_to_arrow_record_batch_bytes,
60            m
61        )?)?;
62        m.add_function(wrap_pyfunction!(
63            crate::python::arrow::py_mark_prices_to_arrow_record_batch_bytes,
64            m
65        )?)?;
66        m.add_function(wrap_pyfunction!(
67            crate::python::arrow::py_index_prices_to_arrow_record_batch_bytes,
68            m
69        )?)?;
70        m.add_function(wrap_pyfunction!(
71            crate::python::arrow::py_instrument_closes_to_arrow_record_batch_bytes,
72            m
73        )?)?;
74    }
75
76    Ok(())
77}
nautilus_serialization/python/mod.rs

nautilus_serialization/python/
mod.rs
