[package]
edition = "2021"
name = "net-mesh"
version = "0.24.0"
build = false
autolib = false
autobins = false
autoexamples = false
autotests = false
autobenches = false
description = "High-performance, schema-agnostic, backend-agnostic event bus"
readme = "README.md"
keywords = [
"event-bus",
"high-performance",
"streaming",
]
categories = [
"asynchronous",
"concurrency",
"data-structures",
]
license = "Apache-2.0"
repository = "https://github.com/ai-2070/net"
[features]
cli = [
"dataforts",
"redex-disk",
"dep:clap",
]
cortex = ["redex"]
dataforts = [
"redex",
"redex-disk",
"dep:blake3",
"dep:fastcdc",
"dep:reed-solomon-erasure",
]
default = [
"net",
"nat-traversal",
"cortex",
"meshdb",
"meshos",
"dataforts",
]
ffi = []
jetstream = ["dep:async-nats"]
meshdb = ["cortex"]
meshos = [
"cortex",
"dep:blake3",
]
nat-traversal = ["net"]
net = [
"dep:chacha20poly1305",
"dep:snow",
"dep:getrandom",
"dep:dashmap",
"dep:crossbeam-queue",
"dep:socket2",
"dep:hex",
"dep:libc",
"dep:blake2",
"dep:ed25519-dalek",
"dep:x25519-dalek",
]
netdb = ["cortex"]
port-mapping = [
"nat-traversal",
"dep:igd-next",
]
redex = [
"net",
"dep:tokio-stream",
"dep:postcard",
]
redex-disk = ["redex"]
redis = ["dep:redis"]
regex = ["dep:regex"]
[lib]
name = "net"
crate-type = [
"lib",
"cdylib",
"staticlib",
]
path = "src/lib.rs"
[[bin]]
name = "net-blob"
path = "src/bin/net-blob.rs"
required-features = ["cli"]
[[example]]
name = "mesh_demo"
path = "examples/mesh_demo.rs"
[[test]]
name = "aggregator_fold_query"
path = "tests/aggregator_fold_query.rs"
[[test]]
name = "aggregator_registry_rpc"
path = "tests/aggregator_registry_rpc.rs"
[[test]]
name = "bus_shutdown_drain"
path = "tests/bus_shutdown_drain.rs"
[[test]]
name = "bus_stranded_flush"
path = "tests/bus_stranded_flush.rs"
[[test]]
name = "capability_aggregation_e2e"
path = "tests/capability_aggregation_e2e.rs"
[[test]]
name = "capability_auth_call_path"
path = "tests/capability_auth_call_path.rs"
[[test]]
name = "capability_auth_conformance"
path = "tests/capability_auth_conformance.rs"
[[test]]
name = "capability_broadcast"
path = "tests/capability_broadcast.rs"
[[test]]
name = "capability_multihop"
path = "tests/capability_multihop.rs"
[[test]]
name = "capability_schema_doc_guard"
path = "tests/capability_schema_doc_guard.rs"
[[test]]
name = "capability_scope"
path = "tests/capability_scope.rs"
[[test]]
name = "chain_discovery"
path = "tests/chain_discovery.rs"
[[test]]
name = "channel_auth"
path = "tests/channel_auth.rs"
[[test]]
name = "channel_auth_hardening"
path = "tests/channel_auth_hardening.rs"
[[test]]
name = "connect_direct"
path = "tests/connect_direct.rs"
[[test]]
name = "connect_post_start"
path = "tests/connect_post_start.rs"
[[test]]
name = "cortex_ryw_global_cap"
path = "tests/cortex_ryw_global_cap.rs"
[[test]]
name = "cross_lang_capability_fixtures"
path = "tests/cross_lang_capability_fixtures.rs"
[[test]]
name = "dataforts_blob_e2e"
path = "tests/dataforts_blob_e2e.rs"
[[test]]
name = "dataforts_blob_v3_cdc_conformance"
path = "tests/dataforts_blob_v3_cdc_conformance.rs"
[[test]]
name = "dataforts_blob_v3_composed_conformance"
path = "tests/dataforts_blob_v3_composed_conformance.rs"
[[test]]
name = "dataforts_blob_v3_rs_conformance"
path = "tests/dataforts_blob_v3_rs_conformance.rs"
[[test]]
name = "dataforts_blob_v3_tree_conformance"
path = "tests/dataforts_blob_v3_tree_conformance.rs"
[[test]]
name = "dataforts_gravity_e2e"
path = "tests/dataforts_gravity_e2e.rs"
[[test]]
name = "dataforts_greedy_e2e"
path = "tests/dataforts_greedy_e2e.rs"
[[test]]
name = "deck_pipeline"
path = "tests/deck_pipeline.rs"
[[test]]
name = "error_kind_mirror"
path = "tests/error_kind_mirror.rs"
[[test]]
name = "failure_detector_matrix"
path = "tests/failure_detector_matrix.rs"
[[test]]
name = "ffi_poll_buffer"
path = "tests/ffi_poll_buffer.rs"
[[test]]
name = "ffi_shutdown_race"
path = "tests/ffi_shutdown_race.rs"
[[test]]
name = "integration_cortex_adapter"
path = "tests/integration_cortex_adapter.rs"
required-features = ["cortex"]
[[test]]
name = "integration_cortex_memories"
path = "tests/integration_cortex_memories.rs"
required-features = ["cortex"]
[[test]]
name = "integration_cortex_tasks"
path = "tests/integration_cortex_tasks.rs"
required-features = ["cortex"]
[[test]]
name = "integration_jetstream"
path = "tests/integration_jetstream.rs"
required-features = ["jetstream"]
[[test]]
name = "integration_mesh_cancel"
path = "tests/integration_mesh_cancel.rs"
[[test]]
name = "integration_net"
path = "tests/integration_net.rs"
required-features = ["net"]
[[test]]
name = "integration_netdb"
path = "tests/integration_netdb.rs"
required-features = ["netdb"]
[[test]]
name = "integration_nrpc_client_streaming"
path = "tests/integration_nrpc_client_streaming.rs"
[[test]]
name = "integration_nrpc_cross_lang"
path = "tests/integration_nrpc_cross_lang.rs"
required-features = ["cortex"]
[[test]]
name = "integration_nrpc_cross_lang_streaming"
path = "tests/integration_nrpc_cross_lang_streaming.rs"
[[test]]
name = "integration_nrpc_duplex"
path = "tests/integration_nrpc_duplex.rs"
[[test]]
name = "integration_nrpc_loopback"
path = "tests/integration_nrpc_loopback.rs"
[[test]]
name = "integration_nrpc_mesh"
path = "tests/integration_nrpc_mesh.rs"
[[test]]
name = "integration_nrpc_predicate_header"
path = "tests/integration_nrpc_predicate_header.rs"
required-features = ["cortex"]
[[test]]
name = "integration_nrpc_service_discovery"
path = "tests/integration_nrpc_service_discovery.rs"
[[test]]
name = "integration_nrpc_streaming"
path = "tests/integration_nrpc_streaming.rs"
[[test]]
name = "integration_placement_filter_callback"
path = "tests/integration_placement_filter_callback.rs"
required-features = ["net"]
[[test]]
name = "integration_redex"
path = "tests/integration_redex.rs"
required-features = ["redex"]
[[test]]
name = "integration_redis"
path = "tests/integration_redis.rs"
required-features = ["redis"]
[[test]]
name = "loom_models"
path = "tests/loom_models.rs"
[[test]]
name = "meshdb_subprotocol_wire"
path = "tests/meshdb_subprotocol_wire.rs"
[[test]]
name = "meshos_pipeline"
path = "tests/meshos_pipeline.rs"
[[test]]
name = "migration_integration"
path = "tests/migration_integration.rs"
[[test]]
name = "migration_target_failure_mid_chunking"
path = "tests/migration_target_failure_mid_chunking.rs"
[[test]]
name = "nat_classify"
path = "tests/nat_classify.rs"
[[test]]
name = "net_blob_cli"
path = "tests/net_blob_cli.rs"
required-features = ["cli"]
[[test]]
name = "netdb_builder_and_accessors"
path = "tests/netdb_builder_and_accessors.rs"
[[test]]
name = "netsocket_production_defaults"
path = "tests/netsocket_production_defaults.rs"
[[test]]
name = "nrpc_inbound_dispatcher"
path = "tests/nrpc_inbound_dispatcher.rs"
[[test]]
name = "parallel_bind_stress"
path = "tests/parallel_bind_stress.rs"
[[test]]
name = "parsed_packet_short_input"
path = "tests/parsed_packet_short_input.rs"
[[test]]
name = "peer_death_clears_capability_index"
path = "tests/peer_death_clears_capability_index.rs"
[[test]]
name = "peer_death_evicts_peer_map"
path = "tests/peer_death_evicts_peer_map.rs"
[[test]]
name = "port_mapping_null"
path = "tests/port_mapping_null.rs"
[[test]]
name = "port_mapping_real_router"
path = "tests/port_mapping_real_router.rs"
[[test]]
name = "proxy_coverage_gaps"
path = "tests/proxy_coverage_gaps.rs"
[[test]]
name = "punch_keepalive"
path = "tests/punch_keepalive.rs"
[[test]]
name = "punch_keepalive_timing"
path = "tests/punch_keepalive_timing.rs"
[[test]]
name = "queue_group_dispatch"
path = "tests/queue_group_dispatch.rs"
[[test]]
name = "redex_replication_dst"
path = "tests/redex_replication_dst.rs"
[[test]]
name = "redex_replication_e2e"
path = "tests/redex_replication_e2e.rs"
[[test]]
name = "reflex_override"
path = "tests/reflex_override.rs"
[[test]]
name = "reflex_probe"
path = "tests/reflex_probe.rs"
[[test]]
name = "rendezvous_ack"
path = "tests/rendezvous_ack.rs"
[[test]]
name = "rendezvous_coordinator"
path = "tests/rendezvous_coordinator.rs"
[[test]]
name = "send_subprotocol_malformed"
path = "tests/send_subprotocol_malformed.rs"
[[test]]
name = "stream_config_and_error_display"
path = "tests/stream_config_and_error_display.rs"
[[test]]
name = "subnet_enforcement"
path = "tests/subnet_enforcement.rs"
[[test]]
name = "three_node_integration"
path = "tests/three_node_integration.rs"
[[bench]]
name = "auth_guard"
path = "benches/auth_guard.rs"
harness = false
required-features = ["net"]
[[bench]]
name = "cortex"
path = "benches/cortex.rs"
harness = false
required-features = [
"cortex",
"netdb",
]
[[bench]]
name = "ingestion"
path = "benches/ingestion.rs"
harness = false
[[bench]]
name = "mesh"
path = "benches/mesh.rs"
harness = false
required-features = ["net"]
[[bench]]
name = "net"
path = "benches/net.rs"
harness = false
required-features = ["net"]
[[bench]]
name = "parallel"
path = "benches/parallel.rs"
harness = false
[[bench]]
name = "placement"
path = "benches/placement.rs"
harness = false
required-features = ["net"]
[[bench]]
name = "redex"
path = "benches/redex.rs"
harness = false
required-features = ["redex"]
[dependencies.arc-swap]
version = "1.7.1"
[dependencies.async-nats]
version = "0.49"
optional = true
[dependencies.async-trait]
version = "0.1"
[dependencies.base64]
version = "0.22"
[dependencies.blake2]
version = "0.10"
optional = true
[dependencies.blake3]
version = "1"
optional = true
[dependencies.bytes]
version = "1"
[dependencies.chacha20poly1305]
version = "0.10"
optional = true
[dependencies.clap]
version = "4"
features = [
"derive",
"env",
]
optional = true
[dependencies.crossbeam-queue]
version = "0.3"
optional = true
[dependencies.crossbeam-utils]
version = "0.8"
[dependencies.dashmap]
version = "6"
optional = true
[dependencies.ed25519-dalek]
version = "2"
features = [
"rand_core",
"zeroize",
]
optional = true
[dependencies.fastcdc]
version = "~4.0"
optional = true
default-features = false
[dependencies.futures]
version = "0.3"
[dependencies.getrandom]
version = "0.4.2"
optional = true
[dependencies.hex]
version = "0.4"
optional = true
[dependencies.igd-next]
version = "0.17"
features = ["aio_tokio"]
optional = true
default-features = false
[dependencies.libc]
version = "0.2"
optional = true
[dependencies.lru]
version = "0.18"
[dependencies.parking_lot]
version = "0.12"
[dependencies.postcard]
version = "1"
features = ["alloc"]
optional = true
default-features = false
[dependencies.quanta]
version = "0.12"
[dependencies.redis]
version = "1.2"
features = [
"tokio-comp",
"connection-manager",
]
optional = true
[dependencies.reed-solomon-erasure]
version = "6"
features = ["std"]
optional = true
default-features = false
[dependencies.regex]
version = "1"
optional = true
[dependencies.semver]
version = "1"
[dependencies.serde]
version = "1"
features = [
"derive",
"rc",
]
[dependencies.serde_json]
version = "1"
features = ["raw_value"]
[dependencies.snow]
version = "0.10.0"
optional = true
[dependencies.socket2]
version = "0.6"
features = ["all"]
optional = true
[dependencies.thiserror]
version = "2"
[dependencies.tokio]
version = "1"
features = [
"rt-multi-thread",
"sync",
"time",
"macros",
"net",
"io-util",
]
[dependencies.tokio-stream]
version = "0.1"
features = ["sync"]
optional = true
[dependencies.tracing]
version = "0.1"
[dependencies.x25519-dalek]
version = "2"
features = [
"static_secrets",
"zeroize",
]
optional = true
[dependencies.xxhash-rust]
version = "0.8"
features = ["xxh3"]
[dev-dependencies.criterion]
version = "0.8"
features = ["async_tokio"]
[dev-dependencies.rand]
version = "0.10"
[dev-dependencies.tokio]
version = "1"
features = [
"full",
"test-util",
]
[target."cfg(loom)".dev-dependencies.loom]
version = "0.7"
[lints.clippy]
expect_used = "warn"
multiple_unsafe_ops_per_block = "warn"
undocumented_unsafe_blocks = "warn"
unwrap_used = "warn"
[lints.rust.unexpected_cfgs]
level = "warn"
priority = 0
check-cfg = ["cfg(loom)"]
[profile.bench]
lto = true
codegen-units = 1
[profile.dev]
opt-level = 0
debug = 2
[profile.native]
lto = "thin"
inherits = "release"
[profile.release]
opt-level = 3
lto = true
codegen-units = 1
panic = "abort"
[profile.release-with-debug]
debug = 2
inherits = "release"