TRAFILO

NAME

trafilo

A concurrent, stateful streaming event-handler framework written in C.

SYNOPSIS

#include <trafilo.h>

trafilo_config_t cfg = { ... };
trafilo_t *t = trafilo_create(&cfg);
trafilo_run(t);
trafilo_shutdown(t);
trafilo_destroy(t);

DESCRIPTION

Trafilo runs continuously. It binds to a UDP socket, receives raw datagrams, and distributes them to a concurrent worker pool. The framework orchestrates ingestion, dispatches events by key across sharded buckets, maintains per-key state, accumulates events into sliding windows, and invokes a user-defined sink function when a window emits. Trafilo manages threading and synchronization via the trafilo_t opaque handle. The caller provides the domain logic via trafilo_config_t.