hub / github.com/JasonThon/lightflus

github.com/JasonThon/lightflus @main

Chat with this repo

repository ↗ · DeepWiki ↗ · + Follow

969 symbols 2,321 edges 73 files 145 documented · 15%

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

Sink (Interface)

(no doc) [4 implementers]

src/stream/src/connector.rs

ICreateResourceRequest (Interface)

Properties of a CreateResourceRequest. [1 implementers]

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

Core symbols most depended-on inside this repo

to_string

called by 289

src/common/src/types.rs

clone

called by 180

src/proto/src/taskmanager.rs

map

called by 154

typescript-api/src/stream/dataflow.ts

get

called by 34

src/common/src/redis.rs

set

called by 25

src/common/src/redis.rs

get_type

called by 22

src/common/src/types.rs

as_bytes

called by 21

src/proto/src/common_impl.rs

get_data_bytes

called by 21

src/common/src/types.rs

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