MCPcopy Index your code
hub / github.com/cloudflare/go-stream

github.com/cloudflare/go-stream @main

Chat with this repo
repository ↗ · DeepWiki ↗ · + Follow
648 symbols 1,591 edges 60 files 46 documented · 7%
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

Generator (Interface)
import "encoding/json" [4 implementers]
stream/mapper/generator.go
Operator (Interface)
* soft stops are created by closing the input channel */ [2 implementers]
stream/operator.go
Manager (Interface)
* There should be a separate manager for each service */ [2 implementers]
cluster/manager.go
InterfaceReader (Interface)
(no doc) [3 implementers]
stream/source/interfacereader.go
Node (Interface)
(no doc) [3 implementers]
cluster/node.go
PartitionVisitor (Interface)
(no doc) [2 implementers]
cube/partitionedcube.go
Cuber (Interface)
(no doc) [2 implementers]
cube/cube.go
Aggregate (Interface)
(no doc) [2 implementers]
cube/aggregate.go

Core symbols most depended-on inside this repo

ereport
called by 50
cube/pg/hll/hll.c
Add
called by 48
stream/chain.go
Out
called by 21
stream/mapper/output.go
Wait
called by 19
stream/chain.go
Stop
called by 17
stream/chain.go
Unix
called by 15
cube/dimension.go
SetIn
called by 15
stream/operator.go
Error
called by 14
cube/pg/hll/hll.go

Shape

Method 310
Function 210
Struct 78
Interface 44
TypeAlias 6

Languages

Go93%
C7%
C++1%

Modules by API surface

cube/pg/table.go64 symbols
cube/pg/hll/hll.c44 symbols
util/util.go37 symbols
cube/partitionedcube.go33 symbols
stream/chain.go31 symbols
stream/mapper/operator.go23 symbols
stream/sink/writer.go20 symbols
cube/cube.go19 symbols
stream/operator.go17 symbols
cluster/node.go16 symbols
stream/source/reader.go15 symbols
cube/pg/hll/hll.go15 symbols

For agents

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

⬇ download graph artifact