MCPcopy Index your code
hub / github.com/deviceinsight/kafkactl

github.com/deviceinsight/kafkactl @v5.19.0

Chat with this repo
repository ↗ · DeepWiki ↗ · release v5.19.0 ↗ · + Follow
865 symbols 4,644 edges 160 files 28 documented · 3%
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

MessageDeserializer (Interface)
(no doc) [5 implementers]
internal/consume/MessageDeserializer.go
Runner (Interface)
Runner interface for shell commands [2 implementers]
internal/k8s/runner.go
AccessTokenProvider (Interface)
(no doc) [2 implementers]
pkg/plugins/auth/interface.go
StdLogger (Interface)
StdLogger is used to log error messages.
internal/output/output.go
Parser (Interface)
(no doc) [2 implementers]
internal/producer/input/parser.go
Resolver (Interface)
(no doc) [2 implementers]
internal/credential/credential.go
Config (Interface)
(no doc) [1 implementers]
internal/global/config.go
Consumer (Interface)
(no doc) [2 implementers]
internal/consume/Consumer.go

Core symbols most depended-on inside this repo

Execute
called by 307
internal/k8s/runner.go
GetStdOut
called by 210
internal/testutil/test_util.go
AssertEquals
called by 205
internal/testutil/test_util.go
CreateKafkaCtlCommand
called by 177
internal/testutil/test_util.go
Flags
called by 156
internal/global/config.go
CreateTopic
called by 124
internal/testutil/helpers.go
StartIntegrationTest
called by 114
internal/testutil/test_util.go
Debugf
called by 93
internal/output/output.go

Shape

Function 515
Method 203
Struct 133
Interface 10
TypeAlias 4

Languages

Go100%

Modules by API surface

cmd/consume/consume_test.go36 symbols
internal/common-operation.go33 symbols
cmd/produce/produce_test.go32 symbols
internal/global/config.go27 symbols
internal/topic/topic-operation.go25 symbols
internal/testutil/test_util.go25 symbols
internal/consumergroups/consumer-group-operation.go19 symbols
internal/k8s/k8s-operation.go18 symbols
internal/user/user-operation.go16 symbols
internal/k8s/executor.go16 symbols
internal/k8s/executer_test.go14 symbols
internal/output/output.go13 symbols

For agents

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

⬇ download graph artifact