Index

A

abstract data class action_fetch_content() (sync_base.ip.cid method) action_fetch_identity() (sync_base.ip.node method) action_generate_keys() (sync_base.ip.peer method) action_open_api_node() (sync_base.res.users method) action_run() (sync_base.ip.event method) action_run_delete() (sync_base.ip.topic method) action_run_deliver() (sync_base.ip.topic method) action_run_export() (sync_base.ip.topic method) action_run_export_deliver() (sync_base.ip.topic method) action_run_import() (sync_base.ip.topic method) action_validate_keys() (sync_base.ip.peer method) action_view_sync_topics() (sync_base.base.automation method) (sync_base.ir.cron method) add() (sync_base.ip.node method) (sync_http.ip.node method) (sync_kubo.ip.node method) admit() (UnifiedBouncer method) API key user

api_node_id (sync_base.res.users attribute) api_node_ids (sync_base.res.users attribute) api_user_id (sync_base.ip.node attribute) AST async_broadcaster_pool() built-in function async_fetcher_pool() built-in function async_listener_pool() built-in function async_main() built-in function async_post() (OdooClient method) async_sender_pool() built-in function async_verifier_pool() built-in function auto_delete (sync_base.ip.topic attribute) auto_deliver (sync_base.ip.topic attribute) auto_import (sync_base.ip.topic attribute)

B

ban_peer() (IpfsClient method) base (class in sync_base) base.automation (class in sync_base) blob CID blob_content_bearer() (SyncBaseController method) blob_content_user() (SyncBaseController method) blocked_peers (PeerState attribute) broadcast built-in function _log_odoo_response() _single_broadcaster_task() _single_fetcher_task() _single_listener_thread() _single_verifier_task() async_broadcaster_pool() async_fetcher_pool() async_listener_pool() async_main() async_sender_pool() async_verifier_pool() create_express_app() express_fetch() express_send() main() p2p_receive() process_fetch_task() process_listener_message() route_inbound_event() sync_batcher_thread()

C

can_author (sync_base.ip.peer attribute) cat() (IpfsClient method) (sync_base.ip.node method) (sync_http.ip.node method) (sync_kubo.ip.node method) check_odoo_errors() (OdooClient method) CID, [1], [2] attachment blob content addressing, [1] cid (sync_base.ip.cid attribute) cid_id (sync_base.ir.attachment attribute) cid_ids (sync_base.ip.event attribute)

cid_state (sync_base.ip.cid attribute) content addressing, [1] CID, [1] copy() (sync_base.ir.attachment method) create() (sync_base.ip.event method) (sync_base.ip.node method) (sync_discuss.mail.message method) (sync_discuss.mail.message.reaction method) create_express_app() built-in function create_from_records() (sync_base.ip.event method) cryptographic identity peer

D

data mixin data_json (sync_base.ip.data attribute) data_raw (sync_base.ip.cid attribute) data_schema (sync_base.ip.schema attribute) debugging decentralized delete_domain (sync_base.ip.topic attribute)

deliver_batch_size (sync_base.ip.topic attribute) deliver_mode (sync_base.ip.topic attribute) deliver_retries (sync_base.ip.topic attribute) deployment development direct direction (sync_base.ip.event attribute) discuss.channel (class in sync_discuss) Docker Compose, [1]

E

Ed25519, [1] ESB event, [1] lifecycle signed message event_array_size (sync_base.ip.topic attribute) event_ids (sync_base.ip.cid attribute) events

export_batch_size (sync_base.ip.topic attribute) export_context_action_id (sync_base.ip.topic attribute) export_domain (sync_base.ip.topic attribute) export_mode (sync_base.ip.topic attribute) export_server_action_id (sync_base.ip.topic attribute) express_fetch() built-in function express_send() built-in function

F

fan-out file_size (sync_base.ip.cid attribute) filtered_domain() (sync_base.ip.data method)

find_or_create() (sync_base.ip.cid method) from_node_id (sync_base.ip.event attribute) from_peer (sync_base.ip.event attribute)

G

gate_url (sync_kubo.ip.node attribute) gateway, [1] node

gateway_id (sync_base.ip.swarm attribute) Grafana

H

heartbeat host_node_id (sync_base.ip.cid attribute) (sync_base.res.partner attribute) (sync_base.res.users attribute)

host_swarm_id (sync_base.res.partner attribute) (sync_base.res.users attribute) HTTP endpoints

I

idempotent import_batch_size (sync_base.ip.topic attribute) import_domain (sync_base.ip.topic attribute) import_mode (sync_base.ip.topic attribute) import_server_action_id (sync_base.ip.topic attribute) init() (sync_base.ip.data method) installation ip.cid, [1] (class in sync_base) (class in sync_http) ip.data, [1] (class in sync_base) ip.event, [1] (class in sync_base) ip.node (class in sync_base) (class in sync_discuss) (class in sync_http) (class in sync_kubo) ip.peer (class in sync_base)

ip.schema, [1] (class in sync_base) ip.swarm (class in sync_base) (class in sync_http) (class in sync_kubo) ip.topic, [1] (class in sync_base) (class in sync_kubo) IpfsClient (built-in class) ir.actions.server (class in sync_base) ir.attachment (class in sync_base) ir.cron (class in sync_base) is_active() (TopicState method) is_blocked() (PeerState method) is_gateway (sync_base.ip.node attribute) is_online (sync_base.ip.node attribute) is_trusted() (PeerState method)

J

JSON Schema schema, [1]

json_size (sync_base.ip.data attribute)

K

Kubo	kubo_url (sync_kubo.ip.node attribute)

L

last_seen (sync_base.ip.node attribute)

last_sync (PeerState attribute)

M

mail.message (class in sync_discuss) mail.message.reaction (class in sync_discuss) main() built-in function mapping, [1] schema, [1] mapping_info (sync_base.ip.data attribute) mapping_state (sync_base.ip.event attribute) max_direct_payload_bytes (UnifiedBouncer attribute)

max_requests_per_window (UnifiedBouncer attribute) MissingCidError module sync_base sync_contacts sync_discuss sync_http sync_kubo monitoring

N

name (sync_base.ip.swarm attribute) (sync_base.ip.topic attribute) netw_size (sync_base.ip.data attribute) network swarm

network_type (sync_base.ip.swarm attribute) node, [1] gateway node_ids (sync_base.ip.swarm attribute)

O

odoo_api_key (sync_http.ip.node attribute) odoo_schema (sync_base.ip.schema attribute)

odoo_url (sync_http.ip.node attribute) OdooClient (built-in class) own_peer_id (sync_base.res.users attribute)

P

p2p_receive() built-in function partner_id (sync_contacts.res.partner.alias attribute) peer, [1] cryptographic identity partner peer_char (sync_base.ip.peer attribute) peer_id (sync_base.ip.node attribute) (sync_base.res.partner attribute) peer_self (PeerState attribute) PeerID, [1] PeerState (built-in class) presence

private_key (sync_base.ip.peer attribute) process_fetch_task() built-in function process_listener_message() built-in function Prometheus protocol, [1] public_key (sync_base.ip.peer attribute) publish() (IpfsClient method) PubSub, [1] topic pull_events() (SyncHttpController method) push_events() (SyncBaseController method) Python sidecar

R

res.partner (class in sync_base) (class in sync_contacts) (class in sync_discuss) res.partner.alias (class in sync_contacts) res.users (class in sync_base)

REST controllers route_inbound_event() built-in function routing_mode (sync_base.ip.event attribute) (sync_base.ip.topic attribute) routing_state (sync_base.ip.event attribute)

S

schema, [1] JSON Schema, [1] mapping, [1] schema_id (sync_base.ip.topic attribute) semantic send_direct() (IpfsClient method) seqno (sync_base.ip.event attribute) setup_p2p_listener() (IpfsClient method) signature (sync_base.ip.event attribute) signed message event stat() (IpfsClient method) subscribe() (IpfsClient method) swarm, [1] network swarm_id (sync_base.ip.node attribute) swarm_ids (sync_base.ip.topic attribute) sync engine base sync() (OdooClient method) sync_alias_ids (sync_contacts.res.partner attribute) sync_author_node_id (sync_contacts.res.partner attribute) sync_base module sync_batcher_thread() built-in function sync_channel_uuid (sync_discuss.discuss.channel attribute)

sync_contacts module sync_date (sync_contacts.res.partner attribute) sync_discuss module sync_export_topic_ids (sync_base.base.automation attribute) (sync_base.ir.cron attribute) sync_from_odoo() (PeerState method) (TopicState method) sync_gateway_endpoint() (SyncKuboController method) sync_http module sync_import_topic_ids (sync_base.ir.cron attribute) sync_is_managed (sync_base.base.automation attribute) (sync_base.ir.cron attribute) sync_kubo module sync_main_channel_id (sync_discuss.mail.message attribute) sync_pending (sync_contacts.res.partner attribute) sync_send sync_swarm_ids (sync_base.ir.actions.server attribute) sync_topic_id (sync_base.ir.actions.server attribute) sync_uuid (sync_contacts.res.partner attribute) (sync_contacts.res.partner.alias attribute) SyncBaseController (built-in class) SyncHttpController (built-in class) SyncKuboController (built-in class)

T

to_node_id (sync_base.ip.event attribute) to_peer (sync_base.ip.event attribute) topic, [1] automation configuration cron namespace naming PubSub

topic_count (sync_base.ip.swarm attribute) topic_id (sync_base.ip.event attribute) topic_name (sync_base.ip.event attribute) topics (TopicState property) TopicState (built-in class) trait trust_level (sync_base.ip.peer attribute) trusted_peers (PeerState attribute)

U

unban_peer() (IpfsClient method) UnifiedBouncer (built-in class) unlink() (sync_base.base.automation method) (sync_base.ir.cron method) (sync_discuss.mail.message.reaction method)

upsert url (sync_base.ir.attachment attribute)

W

wait_for_ipfs() (IpfsClient method) write() (sync_base.base.automation method) (sync_base.ip.cid method) (sync_base.ip.event method) (sync_base.ip.node method) (sync_base.ir.attachment method) (sync_base.ir.cron method)

_

_action_fetch_content() (sync_base.ip.cid method) _action_run_export_deliver() (sync_base.ip.topic method) _action_run_import() (sync_base.ip.topic method) _active_topics (TopicState attribute) _admit_payload() (sync_base.ip.swarm method) _apply_mid_hooks() (sync_base.ip.schema method) _assemble_inbound_vals() (sync_base.ip.schema method) _build_relation_commands() (sync_base.ip.schema method) _check_authorization() (SyncBaseController method) _check_callable() (sync_base.ip.node method) _check_schemas() (sync_base.ip.schema method) _collect_ast_traits() (sync_base.ip.schema method) _compile_json_domain() (sync_base.ip.data method) _compute_attachment_url() (sync_base.ir.attachment method) _compute_im_status() (sync_discuss.res.partner method) _compute_sync_author_node() (sync_contacts.res.partner method) _compute_sync_pending() (sync_contacts.res.partner method) _compute_sync_time() (sync_base.ip.swarm method) _dispatch_events() (sync_base.ip.swarm method) (sync_http.ip.swarm method) (sync_kubo.ip.swarm method) _do_express_fetch_cids() (sync_base.ip.swarm method) (sync_http.ip.swarm method) (sync_kubo.ip.swarm method) _express_fetch_cids() (sync_base.ip.swarm method) _fetch_identity() (sync_base.ip.node method) (sync_http.ip.node method) (sync_kubo.ip.node method) _gate_request() (sync_kubo.ip.node method) _get_dispatch_domain() (sync_base.ip.event method) _get_online_domain() (sync_base.ip.node method) _get_sync_cid() (sync_base.ir.attachment method) _get_trait_registry() (sync_base.ip.schema method) _heartbeat_reap() (sync_base.ip.node method) (sync_http.ip.node method) _heartbeat_sweep() (sync_base.ip.node method) _http_dispatch_thread() (in module sync_http) _http_fetch_thread() (in module sync_http) _http_fetch_wanted_cids() (sync_http.ip.swarm method) _http_pull_sweep() (sync_http.ip.swarm method) _http_request() (sync_http.ip.node method) _http_request_json() (sync_http.ip.node method) _http_send_events() (sync_http.ip.node method) _kubo_request() (sync_kubo.ip.node method) _kubo_send_events() (sync_kubo.ip.node method) _locked_with_state() (sync_base.ip.event method) _log_odoo_response() built-in function

_normalize_payload() (sync_kubo.ip.node method) _on_online_change() (sync_base.ip.node method) (sync_discuss.ip.node method) _pass1_discover_lookups() (sync_base.ip.schema method) _pass2_resolve_cache() (sync_base.ip.schema method) _pass3_assemble_and_execute() (sync_base.ip.schema method) _peer_char_from_pubkey() (sync_base.ip.peer method) _run_action_sync_send() (sync_base.ir.actions.server method) _run_global_hooks() (sync_base.ip.schema method) _safe_execute_batch() (sync_kubo.ip.swarm method) _search() (sync_base.ip.data method) _serve_blob() (SyncBaseController method) _sign_payload() (sync_base.ip.peer method) _single_broadcaster_task() built-in function _single_fetcher_task() built-in function _single_listener_thread() built-in function _single_verifier_task() built-in function _sync_gateway_state() (sync_kubo.ip.swarm method) _sync_get_pull_order() (sync_kubo.ip.swarm method) _sync_get_push_order() (sync_kubo.ip.swarm method) _sync_get_update_order() (sync_kubo.ip.swarm method) _sync_infra() (sync_base.ip.topic method) _sync_notify_thread() (sync_discuss.mail.message method) _sync_pull() (sync_base.base method) (sync_base.ip.event method) (sync_kubo.ip.node method) (sync_kubo.ip.topic method) _sync_pull_base() (sync_base.base method) _sync_pull_self() (sync_base.ip.event method) _sync_push() (sync_base.base method) (sync_base.ip.event method) (sync_kubo.ip.node method) _sync_push_base() (sync_base.base method) _sync_update_base() (sync_base.base method) _sync_update_filter() (sync_base.base method) _to_payload() (sync_base.ip.schema method) _to_payload_single() (sync_base.ip.schema method) _to_records() (sync_base.ip.schema method) _trait_resolve_alias_pre() (sync_contacts.ip.schema method) _trait_set_from_node_mid() (sync_contacts.ip.schema method) _trigger_sync_export() (sync_discuss.mail.message method) _try_mapping() (sync_base.ip.event method) _try_sending() (sync_base.ip.event method) _verify_signature() (sync_base.ip.peer method)