MCPcopy Index your code
hub / github.com/dgryski/dmrgo

github.com/dgryski/dmrgo @main

Chat with this repo
repository ↗ · DeepWiki ↗ · + Follow
52 symbols 97 edges 6 files 22 documented · 42%
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

StreamProtocol (Interface)
StreamProtocol is a set of routines for marshaling and unmarshaling key/value pairs from the input stream. Map Reduce jo [3 …
proto.go
Emitter (Interface)
Emitter emits key/value pairs [3 implementers]
emitter.go
MapReduceJob (Interface)
MapReduceJob is the interface expected by the job runner [1 implementers]
runners.go

Core symbols most depended-on inside this repo

Flush
called by 7
emitter.go
Close
called by 5
emitter.go
primitiveToString
called by 4
proto.go
mapper
called by 3
runners.go
mapperFinal
called by 3
runners.go
Emit
called by 3
emitter.go
newPrintEmitter
called by 3
emitter.go
newPartitionEmitter
called by 3
emitter.go

Shape

Method 23
Function 17
Struct 9
Interface 3

Languages

Go100%

Modules by API surface

emitter.go15 symbols
runners.go14 symbols
proto.go11 symbols
examples/wordcount.go9 symbols
reporter.go3 symbols

For agents

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

⬇ download graph artifact