Files

dfir_datalog

dfir_datalog_core

grammar.rs join_plan.rs lib.rs util.rs

dfir_lang

graph

ops

_counter.rs _lattice_fold_batch.rs _lattice_join_fused_join.rs all_iterations.rs all_once.rs anti_join.rs anti_join_multiset.rs assert.rs assert_eq.rs batch.rs chain.rs cross_join.rs cross_join_multiset.rs cross_singleton.rs defer_signal.rs defer_tick.rs defer_tick_lazy.rs demux.rs demux_enum.rs dest_file.rs dest_sink.rs dest_sink_serde.rs difference.rs difference_multiset.rs enumerate.rs filter.rs filter_map.rs flat_map.rs flatten.rs fold.rs fold_keyed.rs for_each.rs identity.rs initialize.rs inspect.rs join.rs join_fused.rs join_fused_lhs.rs join_fused_rhs.rs join_multiset.rs lattice_bimorphism.rs lattice_fold.rs lattice_reduce.rs map.rs mod.rs multiset_delta.rs next_iteration.rs next_stratum.rs null.rs partition.rs persist.rs persist_mut.rs persist_mut_keyed.rs prefix.rs py_udf.rs reduce.rs reduce_keyed.rs repeat_n.rs sort.rs sort_by_key.rs source_file.rs source_interval.rs source_iter.rs source_json.rs source_stdin.rs source_stream.rs source_stream_serde.rs spin.rs state.rs state_by.rs tee.rs union.rs unique.rs unzip.rs zip.rs zip_longest.rs

di_mul_graph.rs eliminate_extra_unions_tees.rs flat_graph_builder.rs flat_to_partitioned.rs graph_algorithms.rs graph_write.rs meta_graph.rs meta_graph_debugging.rs mod.rs

diagnostic.rs lib.rs parse.rs pretty_span.rs process_singletons.rs union_find.rs

dfir_macro

dfir_rs

compiled

pull

half_join_state

fold.rs fold_from.rs mod.rs multiset.rs reduce.rs set.rs

anti_join.rs mod.rs symmetric_hash_join.rs

scheduled

handoff

handoff_list.rs mod.rs tee.rs vector.rs

net

mod.rs network_vertex.rs

context.rs graph.rs graph_ext.rs input.rs mod.rs port.rs query.rs reactor.rs state.rs subgraph.rs ticks.rs

util

unsync

clear.rs demux_enum.rs deploy.rs mod.rs monotonic.rs monotonic_map.rs multiset.rs priority_stack.rs simulation.rs slot_vec.rs socket.rs sparse_vec.rs tcp.rs udp.rs

declarative_macro.rs lib.rs

gossip_cli

gossip_kv

lattices

lib.rs membership.rs model.rs server.rs util.rs

gossip_server

config

main.rs membership.rs

hydro_cli

hydro_deploy

localhost

launched_binary.rs mod.rs

rust_crate

build.rs flamegraph.rs mod.rs ports.rs service.rs tracing_options.rs

azure.rs custom_service.rs deployment.rs gcp.rs lib.rs progress.rs ssh.rs terraform.rs util.rs

hydro_deploy_integration

hydro_lang

builder

built.rs compiled.rs deploy.rs mod.rs

deploy

deploy_graph.rs in_memory_graph.rs macro_runtime.rs mod.rs trybuild.rs trybuild_rewriters.rs

location

cluster

cluster_id.rs mod.rs

can_send.rs external_process.rs mod.rs process.rs tick.rs

rewrites

analyze_counter.rs analyze_perf.rs analyze_perf_and_counters.rs decoupler.rs insert_counter.rs mod.rs partitioner.rs persist_pullup.rs print_id.rs properties.rs

runtime_support

resource_measurement.rs

boundedness.rs cycle.rs deploy_runtime.rs ir.rs lib.rs optional.rs runtime_context.rs singleton.rs staging_util.rs stream.rs test_util.rs

hydro_std

bench_client.rs compartmentalize.rs lib.rs quorum.rs request_response.rs

hydro_test

cluster

compartmentalized_paxos.rs compute_pi.rs kv_replica.rs many_to_many.rs map_reduce.rs mod.rs paxos.rs paxos_bench.rs paxos_with_client.rs simple_cluster.rs two_pc.rs

distributed

first_ten.rs mod.rs

hydro_test_local

local

chat_app.rs compute_pi.rs count_elems.rs first_ten.rs graph_reachability.rs mod.rs negation.rs teed_join.rs

hydro_test_local_macro

local

chat_app.rs compute_pi.rs count_elems.rs first_ten.rs graph_reachability.rs mod.rs negation.rs teed_join.rs

include_mdtests

latency_measure

latency_measure.rs protocol.rs

lattices

ght

colt.rs lattice.rs macros.rs mod.rs test.rs

algebra.rs collections.rs conflict.rs dom_pair.rs lib.rs map_union.rs map_union_with_tombstones.rs ord.rs pair.rs point.rs semiring_application.rs set_union.rs set_union_with_tombstones.rs test.rs union_find.rs unit.rs vec_union.rs with_bot.rs with_top.rs

lattices_macro

load_test_server

multiplatform_test

pn

pn.rs protocol.rs

pn_delta

pn_delta.rs protocol.rs

pusherator

demux.rs filter.rs filter_map.rs flatten.rs for_each.rs inspect.rs lib.rs map.rs null.rs partition.rs pivot.rs switch.rs tee.rs unzip.rs

topolotree

main.rs protocol.rs

variadics

lib.rs variadic_collections.rs

variadics_macro

website_playground

lib.rs utils.rs

hydro_test_local/local/
mod.rs

Settings

Help

1pub mod chat_app;
2pub mod compute_pi;
3pub mod count_elems;
4pub mod first_ten;
5pub mod graph_reachability;
6pub mod negation;
7pub mod teed_join;