hub / github.com/AleksK1NG/Go-CQRS-Kafka-gRPC-Microservices

github.com/AleksK1NG/Go-CQRS-Kafka-gRPC-Microservices @main

Chat with this repo

repository ↗ · DeepWiki ↗ · + Follow

710 symbols 1,912 edges 100 files 113 documented · 16% ● updated 4y ago★ 249

Browse by type

⨍ Functions 555◇ Types & classes 155

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

DeleteProductCmdHandler (Interface)

(no doc) [14 implementers]

writer_service/internal/product/commands/delete_product.go

MessageProcessor (Interface)

MessageProcessor processor methods must implement kafka.Worker func method interface [2 implementers]

pkg/kafka/consumer_group.go

Logger (Interface)

Logger methods interface [1 implementers]

pkg/logger/logger.go

RestErr (Interface)

RestErr Rest error interface [1 implementers]

pkg/http_errors/http_errors.go

InterceptorManager (Interface)

(no doc) [1 implementers]

pkg/interceptors/manager.go

UpdateProductCmdHandler (Interface)

(no doc) [14 implementers]

writer_service/internal/product/commands/update_product.go

browse all types & interfaces →

Core symbols most depended-on inside this repo

↓ 31 filesLogger

Logger methods interface

pkg/logger/logger.go

↓ 22 filesSearchProductHandler

reader_service/internal/product/queries/search.go

↓ 13 filesGetProductByIdHandler

writer_service/internal/product/queries/get_product_by_id.go

↓ 13 filesUpdateProductCmdHandler

writer_service/internal/product/commands/update_product.go

↓ 13 filesDeleteProductCmdHandler

writer_service/internal/product/commands/delete_product.go

↓ 13 filesCreateProductCmdHandler

writer_service/internal/product/commands/create_product.go

browse all functions →

Shape

Method 421

Function 134

Struct 123

Interface 31

FuncType 1

Languages

Go100%

Modules by API surface

reader_service/proto/product_reader/product_reader_messages.pb.go98 symbols

proto/kafka/kafka.pb.go64 symbols

writer_service/proto/product_writer/product_writer_messages.pb.go63 symbols

pkg/logger/logger.go54 symbols

reader_service/proto/product_reader/product_reader_grpc.pb.go33 symbols

writer_service/proto/product_writer/product_writer_grpc.pb.go23 symbols

pkg/http_errors/http_errors.go23 symbols

pkg/utils/pagination.go14 symbols

pkg/kafka/consumer_group.go12 symbols

reader_service/internal/product/repository/repository.go11 symbols

pkg/tracing/utils.go9 symbols

writer_service/internal/product/commands/commands.go8 symbols

Datastores touched

(mongodb)Database · 1 repos

For agents

$ claude mcp add Go-CQRS-Kafka-gRPC-Microservices \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact

github.com/AleksK1NG/Go-CQRS-Kafka-gRPC-Microservices @main

Extension points exported contracts — how you extend this code

Core symbols most depended-on inside this repo

Shape

Languages

Modules by API surface

Datastores touched

For agents

Ask about this repo answers extend the page