hub / github.com/aljoscha/statefun-rust

github.com/aljoscha/statefun-rust @v0.1.1

repository ↗ · DeepWiki ↗ · release v0.1.1 ↗ · + Follow

88 symbols 286 edges 12 files 24 documented · 27%

What it actually does AI analysis from the code graph — generated when you open this

loading…

README

Statefun Rust SDK

An SDK for writing stateful functions in Rust. See the Apache Flink Stateful Functions website for more information about the project.

At the moment this project is very bare-bones. I'm just getting started and there's no tests yet and probably some bugs.

Building

You need to have the Protobuf compiler protoc available in your $PATH. On macOS you can install this via

brew install protobuf

Extension points exported contracts — how you extend this code

InvokableFunction (Interface)

A function that can be invoked. This is used as trait objects in the `FunctionRegistry`. [1 implementers]

statefun-sdk/src/function_registry.rs

Transport (Interface)

Serves up stateful functions in a [FunctionRegistry](crate::FunctionRegistry) to make them invokable in a Statefun deplo [1 …

statefun-sdk/src/transport.rs

InvocationBridge (Interface)

An invokable that takes protobuf `ToFunction` as argument and returns a protobuf `FromFunction`. [1 implementers]

statefun-sdk/src/invocation_bridge.rs

KafkaEgress (Interface)

Extension trait for sending egress messages to Kafka using [Effects](crate::Effects). [1 implementers]

statefun-sdk/src/io/kafka.rs

Core symbols most depended-on inside this repo

string_value

called by 14

statefun-sdk/src/invocation_bridge.rs

register_fn

called by 11

statefun-sdk/src/function_registry.rs

self_address

called by 9

statefun-sdk/src/invocation_bridge.rs

into_proto

called by 8

statefun-sdk/src/lib.rs

function_type

called by 8

statefun-sdk/src/invocation_bridge.rs

invoke_from_proto

called by 7

statefun-sdk/src/invocation_bridge.rs

caller_address

called by 7

statefun-sdk/src/invocation_bridge.rs

assert_invocation

called by 6

statefun-sdk/src/invocation_bridge.rs

Shape

Function 55

Method 20

Class 8

Interface 4

Enum 1

Languages

Rust100%

Modules by API surface

statefun-sdk/src/invocation_bridge.rs33 symbols

statefun-sdk/src/lib.rs19 symbols

statefun-sdk/src/function_registry.rs13 symbols

statefun-sdk/src/transport/hyper.rs5 symbols

statefun-proto/build.rs5 symbols

statefun-example-proto/build.rs5 symbols

statefun-sdk/src/io/kafka.rs4 symbols

statefun-example/src/main.rs3 symbols

statefun-sdk/src/transport.rs1 symbols

For agents

$ claude mcp add statefun-rust \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact

github.com/aljoscha/statefun-rust @v0.1.1

Statefun Rust SDK

Building

Extension points exported contracts — how you extend this code

Core symbols most depended-on inside this repo

Shape

Languages

Modules by API surface

For agents

Ask about this repo answers extend the page