MCPcopy Index your code
hub / github.com/bytewatch/dolphinbeat

github.com/bytewatch/dolphinbeat @main

Chat with this repo
repository ↗ · DeepWiki ↗ · + Follow
604 symbols 1,375 edges 62 files 59 documented · 10%
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

EventHandler (Interface)
(no doc) [4 implementers]
canal/handler.go
Logger (Interface)
Logger is an interface that can be implemented to provide custom log output. [1 implementers]
sink/kafka/client/go/logger.go
CkpStorage (Interface)
(no doc) [3 implementers]
ckp/storage.go
Checkpointer (Interface)
(no doc) [3 implementers]
ckp/checkpoint.go
Sink (Interface)
(no doc) [2 implementers]
sink/sink.go
ParseHandler (Interface)
(no doc) [2 implementers]
dump/parser.go
SchemaStorage (Interface)
(no doc) [2 implementers]
schema/storage.go
Logger (Interface)
(no doc) [1 implementers]
sink/logger.go

Core symbols most depended-on inside this repo

Errorf
called by 104
sink/logger.go
String
called by 31
canal/handler.go
Infof
called by 29
sink/logger.go
Warnf
called by 24
sink/logger.go
Execute
called by 19
canal/canal.go
Close
called by 16
ckp/storage.go
Close
called by 12
sink/sink.go
Position
called by 12
canal/master.go

Shape

Method 421
Function 89
Struct 78
Interface 9
TypeAlias 6
FuncType 1

Languages

Go100%

Modules by API surface

sink/kafka/protocol/protocol.pb.go141 symbols
canal/canal.go23 symbols
sink/stdout/operation.go19 symbols
canal/handler.go19 symbols
cmd/dolphinbeat/app.go18 symbols
ckp/checkpoint.go18 symbols
sink/kafka/kafka.go16 symbols
schema/storage_boltdb.go16 symbols
dump/dump_test.go16 symbols
sink/kafka/operation.go15 symbols
dump/dump.go15 symbols
canal/handler_mux.go15 symbols

Datastores touched

(mysql)Database · 1 repos

For agents

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

⬇ download graph artifact