recoco-core 0.2.1

Recoco-core is the core library of Recoco; it's nearly identical to the main ReCoco crate, which is a simple wrapper around recoco-core and other sub-crates.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86

#![allow(unused_imports)]

// ReCoco is a Rust-only fork of CocoIndex, by [CocoIndex](https://CocoIndex)
// Original code from CocoIndex is copyrighted by CocoIndex
// SPDX-FileCopyrightText: 2025-2026 CocoIndex (upstream)
// SPDX-FileContributor: CocoIndex Contributors
//
// All modifications from the upstream for ReCoco are copyrighted by Knitli Inc.
// SPDX-FileCopyrightText: 2026 Knitli Inc. (ReCoco)
// SPDX-FileContributor: Adam Poulemanos <adam@knit.li>
//
// Both the upstream CocoIndex code and the ReCoco modifications are licensed under the Apache-2.0 License.
// SPDX-License-Identifier: Apache-2.0

pub use async_trait::async_trait;
pub use chrono::{DateTime, Utc};
pub use futures::{FutureExt, StreamExt};
pub use futures::{
    future::{BoxFuture, Shared},
    prelude::*,
    stream::BoxStream,
};
pub use indexmap::{IndexMap, IndexSet};
#[cfg(any(
    feature = "server",
    feature = "persistence",
    feature = "target-postgres"
))]
pub use itertools::Itertools;
pub use serde::{Deserialize, Serialize, de::DeserializeOwned};
pub use std::any::Any;
pub use std::borrow::Cow;
pub use std::collections::{BTreeMap, BTreeSet, HashMap, HashSet};
pub use std::fmt::Debug;
pub use std::hash::Hash;
pub use std::sync::{Arc, LazyLock, Mutex, OnceLock, RwLock, Weak};

pub use crate::base::{self, schema, spec, value};
pub use crate::builder::{self, exec_ctx, plan};
pub use crate::execution;
pub use crate::lib_context::{FlowContext, LibContext, get_lib_context, get_runtime};
pub use crate::ops::interface;
pub use crate::setup;
pub use crate::setup::AuthRegistry;
#[cfg(any(
    feature = "source-azure",
    feature = "source-local-file",
    feature = "source-s3"
))]
pub use async_stream::{stream, try_stream};
#[cfg(any(
    feature = "source-azure",
    feature = "source-local-file",
    feature = "source-s3"
))]
pub use recoco_utils as utils;
#[cfg(any(
    feature = "function-embed",
    feature = "source-azure",
    feature = "source-gdrive",
    feature = "source-s3",
    feature = "source-local-file",
    feature = "source-postgres"
))]
pub use recoco_utils::batching;
pub use recoco_utils::concur_control;
#[cfg(any(
    feature = "target-kuzu",
    feature = "function-embed",
    feature = "function-extract-llm",
    feature = "persistence"
))]
pub use recoco_utils::http;
#[cfg(any(
    feature = "server",
    feature = "provider-openai",
    feature = "provider-gemini",
    feature = "persistence",
    feature = "function-split",
    feature = "target-neo4j"
))]
pub use recoco_utils::retryable;
pub use recoco_utils::{api_bail, api_error};
pub use tracing::{Span, debug, error, info, info_span, instrument, trace, warn};

pub use utils::prelude::*;