hub / github.com/JasonThon/lightflus

github.com/JasonThon/lightflus @main

969 symbols 2,321 edges 73 files 145 documented · 15% ● updated 3y agov1.0.2-alpha · 2023-04-09★ 1001 open issues

Browse by type

⨍ Functions 588◇ Types & classes 381

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

loading…

Extension points exported contracts — how you extend this code

RpcGateway (Interface)

Rpc Gateway trait. All Rpc clients should implement this trait [4 implementers]

src/common/src/net/gateway.rs

IOperator (Interface)

(no doc) [4 implementers]

src/stream/src/dataflow.rs

IConnectionOpts (Interface)

Properties of a ConnectionOpts. [2 implementers]

typescript-api/src/proto/apiserver.d.ts

DataflowStorage (Interface)

(no doc) [2 implementers]

src/lightflus-core/src/coordinator/storage.rs

TaskManagerApi (Interface)

(no doc) [1 implementers]

src/proto/src/taskmanager.rs

StreamEvent (Interface)

The trait that is a stream event A [`StreamEvent`] can be serialized to be sent to external sink (e.g. Kafka, Database). [1 …

src/common/src/event.rs

browse all types & interfaces →

Core symbols most depended-on inside this repo

↓ 8 filesget_env

src/common/src/utils.rs

↓ 4 filesFunc

src/proto/src/common.rs

↓ 4 filesinit

tools/alpha/common/probe/probe.pb.go

↓ 4 filesnow

src/common/src/utils.rs

↓ 4 filesrun_producer

src/common/src/kafka.rs

↓ 3 filesKafka

An unified implementation for Kafka Source and Sink.

src/stream/src/connector.rs

browse all functions →

Shape

Method 415

Class 266

Function 173

Interface 58

Enum 50

Struct 5

TypeAlias 2

Languages

Rust68%

TypeScript27%

Go5%

Modules by API surface

typescript-api/src/proto/apiserver.d.ts128 symbols

src/proto/src/common.rs55 symbols

tools/alpha/common/probe/probe.pb.go50 symbols

typescript-api/src/connectors/connectors.ts48 symbols

typescript-api/src/stream/operator.ts40 symbols

src/common/src/types.rs38 symbols

src/proto/src/taskmanager.rs37 symbols

src/proto/src/common_impl.rs37 symbols

src/common/src/utils.rs34 symbols

src/stream/src/task.rs32 symbols

src/stream/src/connector.rs31 symbols

src/proto/src/coordinator.rs26 symbols

Datastores touched

(mysql)Database · 1 repos

For agents

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

⬇ download graph artifact