kglite 0.10.16

Pure-Rust knowledge graph engine — Cypher pipeline, snapshot/working CoW transactions, columnar/mmap/disk storage backends, optional dataset loaders (SEC EDGAR, Sodir, Wikidata). PyO3 wrappers live in the sibling kglite-py crate (the Python wheel); embeddable directly from any Rust binary without PyO3 in the dep tree.
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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143

//! Sync wrappers around the async `fetch_*` functions for bindings
//! without their own tokio runtime. See [`crate::datasets::blocking`]
//! for the rationale.

use crate::datasets::blocking;
use crate::datasets::sec::client::SecClient;
use crate::datasets::sec::error::Result;
use crate::datasets::sec::fetch::{
    fetch_13f_info_table, fetch_company_facts, fetch_company_submission, fetch_company_tickers,
    fetch_exhibit21_attachment, fetch_filing_primary_doc, fetch_form4_filing,
    fetch_quarterly_master_idx, fetch_submissions_bulk, YearRange,
};
use crate::datasets::sec::layout::Workdir;

/// Sync wrapper around [`fetch_quarterly_master_idx`].
pub fn fetch_quarterly_master_idx_blocking(
    client: &SecClient,
    workdir: &Workdir,
    range: YearRange,
    current_year: u16,
    current_quarter: u8,
) -> Result<(usize, usize)> {
    blocking::run(fetch_quarterly_master_idx(
        client,
        workdir,
        range,
        current_year,
        current_quarter,
    ))
}

/// Sync wrapper around [`fetch_submissions_bulk`].
pub fn fetch_submissions_bulk_blocking(
    client: &SecClient,
    workdir: &Workdir,
    staleness_hours: u64,
    force_refetch: bool,
) -> Result<bool> {
    blocking::run(fetch_submissions_bulk(
        client,
        workdir,
        staleness_hours,
        force_refetch,
    ))
}

/// Sync wrapper around [`fetch_company_tickers`].
pub fn fetch_company_tickers_blocking(
    client: &SecClient,
    workdir: &Workdir,
    force_refetch: bool,
) -> Result<bool> {
    blocking::run(fetch_company_tickers(client, workdir, force_refetch))
}

/// Sync wrapper around [`fetch_company_facts`].
pub fn fetch_company_facts_blocking(
    client: &SecClient,
    workdir: &Workdir,
    cik: u64,
    force_refetch: bool,
) -> Result<bool> {
    blocking::run(fetch_company_facts(client, workdir, cik, force_refetch))
}

/// Sync wrapper around [`fetch_company_submission`].
pub fn fetch_company_submission_blocking(
    client: &SecClient,
    workdir: &Workdir,
    cik: u64,
    force_refetch: bool,
) -> Result<bool> {
    blocking::run(fetch_company_submission(
        client,
        workdir,
        cik,
        force_refetch,
    ))
}

/// Sync wrapper around [`fetch_13f_info_table`].
pub fn fetch_13f_info_table_blocking(
    client: &SecClient,
    workdir: &Workdir,
    issuer_cik: u64,
    accession_dashed: &str,
) -> Result<bool> {
    blocking::run(fetch_13f_info_table(
        client,
        workdir,
        issuer_cik,
        accession_dashed,
    ))
}

/// Sync wrapper around [`fetch_form4_filing`].
pub fn fetch_form4_filing_blocking(
    client: &SecClient,
    workdir: &Workdir,
    issuer_cik: u64,
    accession_dashed: &str,
    primary_document: &str,
) -> Result<bool> {
    blocking::run(fetch_form4_filing(
        client,
        workdir,
        issuer_cik,
        accession_dashed,
        primary_document,
    ))
}

/// Sync wrapper around [`fetch_filing_primary_doc`].
pub fn fetch_filing_primary_doc_blocking(
    client: &SecClient,
    workdir: &Workdir,
    issuer_cik: u64,
    accession_dashed: &str,
    primary_document: &str,
) -> Result<bool> {
    blocking::run(fetch_filing_primary_doc(
        client,
        workdir,
        issuer_cik,
        accession_dashed,
        primary_document,
    ))
}

/// Sync wrapper around [`fetch_exhibit21_attachment`].
pub fn fetch_exhibit21_attachment_blocking(
    client: &SecClient,
    workdir: &Workdir,
    issuer_cik: u64,
    accession_dashed: &str,
) -> Result<usize> {
    blocking::run(fetch_exhibit21_attachment(
        client,
        workdir,
        issuer_cik,
        accession_dashed,
    ))
}