Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/AleksK1NG/Go-CQRS-Kafka-gRPC-Microservices
/ functions
Functions
555 in github.com/AleksK1NG/Go-CQRS-Kafka-gRPC-Microservices
⨍
Functions
555
◇
Types & classes
155
↓ 1 callers
Method
connectKafkaBrokers
(ctx context.Context)
reader_service/internal/server/utils.go:20
↓ 1 callers
Function
file_kafka_proto_init
()
proto/kafka/kafka.pb.go:532
↓ 1 callers
Function
file_product_reader_proto_init
()
reader_service/proto/product_reader/product_reader.pb.go:92
↓ 1 callers
Function
file_product_writer_proto_init
()
writer_service/proto/product_writer/product_writer.pb.go:73
↓ 1 callers
Method
getConsumerGroupTopics
()
writer_service/internal/server/utils.go:111
↓ 1 callers
Method
getConsumerGroupTopics
()
reader_service/internal/server/utils.go:38
↓ 1 callers
Method
getLoggerLevel
()
pkg/logger/logger.go:73
↓ 1 callers
Method
initKafkaTopics
(ctx context.Context)
writer_service/internal/server/utils.go:41
↓ 1 callers
Method
logProcessMessage
(m kafka.Message, workerID int)
writer_service/internal/product/delivery/kafka/utils.go:24
↓ 1 callers
Method
logProcessMessage
(m kafka.Message, workerID int)
reader_service/internal/product/delivery/kafka/utils.go:17
↓ 1 callers
Method
mapRoutes
()
api_gateway_service/internal/server/http.go:32
↓ 1 callers
Method
newReaderGrpcServer
()
reader_service/internal/server/grpc_server.go:26
↓ 1 callers
Method
newWriterGrpcServer
()
writer_service/internal/server/grpc_server.go:27
↓ 1 callers
Function
parseSqlErrors
(err error, debug bool)
pkg/http_errors/http_errors.go:215
↓ 1 callers
Function
parseValidatorError
(err error, debug bool)
pkg/http_errors/http_errors.go:219
↓ 1 callers
Method
processCreateProduct
(ctx context.Context, r *kafka.Reader, m kafka.Message)
writer_service/internal/product/delivery/kafka/create_product_consumer.go:24
↓ 1 callers
Method
processDeleteProduct
(ctx context.Context, r *kafka.Reader, m kafka.Message)
writer_service/internal/product/delivery/kafka/delete_product_consumer.go:14
↓ 1 callers
Method
processProductCreated
(ctx context.Context, r *kafka.Reader, m kafka.Message)
reader_service/internal/product/delivery/kafka/create_product_consumer.go:23
↓ 1 callers
Method
processProductDeleted
(ctx context.Context, r *kafka.Reader, m kafka.Message)
reader_service/internal/product/delivery/kafka/delete_product_consumer.go:14
↓ 1 callers
Method
processProductUpdated
(ctx context.Context, r *kafka.Reader, m kafka.Message)
reader_service/internal/product/delivery/kafka/update_product_consumer.go:13
↓ 1 callers
Method
processUpdateProduct
(ctx context.Context, r *kafka.Reader, m kafka.Message)
writer_service/internal/product/delivery/kafka/update_product_consumer.go:14
↓ 1 callers
Method
runHealthCheck
(ctx context.Context)
writer_service/internal/server/utils.go:119
↓ 1 callers
Method
runHealthCheck
(ctx context.Context)
api_gateway_service/internal/server/utils.go:14
↓ 1 callers
Method
runHealthCheck
(ctx context.Context)
reader_service/internal/server/utils.go:46
↓ 1 callers
Method
runHttpServer
()
api_gateway_service/internal/server/http.go:22
↓ 1 callers
Method
runMetrics
(cancel context.CancelFunc)
writer_service/internal/server/utils.go:146
↓ 1 callers
Method
runMetrics
(cancel context.CancelFunc)
api_gateway_service/internal/server/utils.go:32
↓ 1 callers
Method
runMetrics
(cancel context.CancelFunc)
reader_service/internal/server/utils.go:77
Method
Causes
()
pkg/http_errors/http_errors.go:41
Method
Causes
Causes RestError Causes
pkg/http_errors/http_errors.go:69
Method
ClientRequestLoggerInterceptor
ClientRequestLoggerInterceptor gRPC client interceptor
pkg/interceptors/manager.go:54
Method
Close
()
pkg/kafka/producer.go:29
Method
ConsumeTopic
ConsumeTopic start consumer group with given worker and pool size
pkg/kafka/consumer_group.go:72
Method
CreateProduct
(ctx context.Context, in *CreateProductReq, opts ...grpc.CallOption)
writer_service/proto/product_writer/product_writer_grpc.pb.go:33
Method
CreateProduct
(context.Context, *CreateProductReq)
writer_service/proto/product_writer/product_writer_grpc.pb.go:64
Method
CreateProduct
(context.Context, *CreateProductReq)
writer_service/proto/product_writer/product_writer_grpc.pb.go:73
Method
CreateProduct
(ctx context.Context, req *writerService.CreateProductReq)
writer_service/internal/product/delivery/grpc/grpc_service.go:32
Method
CreateProduct
(ctx context.Context, product *models.Product)
writer_service/internal/product/repository/repository.go:10
Method
CreateProduct
(ctx context.Context, product *models.Product)
writer_service/internal/product/repository/pg_repository.go:24
Method
CreateProduct
()
api_gateway_service/internal/products/delivery.go:6
Method
CreateProduct
(ctx context.Context, in *CreateProductReq, opts ...grpc.CallOption)
reader_service/proto/product_reader/product_reader_grpc.pb.go:35
Method
CreateProduct
(context.Context, *CreateProductReq)
reader_service/proto/product_reader/product_reader_grpc.pb.go:84
Method
CreateProduct
(context.Context, *CreateProductReq)
reader_service/proto/product_reader/product_reader_grpc.pb.go:95
Method
CreateProduct
(ctx context.Context, req *readerService.CreateProductReq)
reader_service/internal/product/delivery/grpc/grpc_service.go:34
Method
CreateProduct
(ctx context.Context, product *models.Product)
reader_service/internal/product/repository/mongo_repository.go:28
Method
DPanic
DPanic uses fmt.Sprint to construct and log a message. In development, the logger then panics. (See DPanicLevel for details.)
pkg/logger/logger.go:185
Method
DPanicf
DPanicf uses fmt.Sprintf to log a templated message. In development, the logger then panics. (See DPanicLevel for details.)
pkg/logger/logger.go:190
Method
Debug
Debug uses fmt.Sprint to construct and log a message.
pkg/logger/logger.go:130
Method
Debugf
Debugf uses fmt.Sprintf to log a templated message
pkg/logger/logger.go:135
Method
DelAllProducts
(ctx context.Context)
reader_service/internal/product/repository/repository.go:23
Method
DelAllProducts
(ctx context.Context)
reader_service/internal/product/repository/redis_repository.go:74
Method
DelProduct
(ctx context.Context, key string)
reader_service/internal/product/repository/redis_repository.go:66
Method
DeleteProduct
()
api_gateway_service/internal/products/delivery.go:8
Method
DeleteProduct
(ctx context.Context, uuid uuid.UUID)
reader_service/internal/product/repository/mongo_repository.go:77
Method
DeleteProductByID
(ctx context.Context, uuid uuid.UUID)
writer_service/internal/product/repository/pg_repository.go:81
Method
DeleteProductByID
(ctx context.Context, in *DeleteProductByIdReq, opts ...grpc.CallOption)
reader_service/proto/product_reader/product_reader_grpc.pb.go:71
Method
DeleteProductByID
(context.Context, *DeleteProductByIdReq)
reader_service/proto/product_reader/product_reader_grpc.pb.go:88
Method
DeleteProductByID
(context.Context, *DeleteProductByIdReq)
reader_service/proto/product_reader/product_reader_grpc.pb.go:107
Method
DeleteProductByID
(ctx context.Context, req *readerService.DeleteProductByIdReq)
reader_service/internal/product/delivery/grpc/grpc_service.go:123
Method
Descriptor
Deprecated: Use Product.ProtoReflect.Descriptor instead.
writer_service/proto/product_writer/product_writer_messages.pb.go:65
Method
Descriptor
Deprecated: Use CreateProductReq.ProtoReflect.Descriptor instead.
writer_service/proto/product_writer/product_writer_messages.pb.go:150
Method
Descriptor
Deprecated: Use CreateProductRes.ProtoReflect.Descriptor instead.
writer_service/proto/product_writer/product_writer_messages.pb.go:218
Method
Descriptor
Deprecated: Use UpdateProductReq.ProtoReflect.Descriptor instead.
writer_service/proto/product_writer/product_writer_messages.pb.go:268
Method
Descriptor
Deprecated: Use UpdateProductRes.ProtoReflect.Descriptor instead.
writer_service/proto/product_writer/product_writer_messages.pb.go:334
Method
Descriptor
Deprecated: Use GetProductByIdReq.ProtoReflect.Descriptor instead.
writer_service/proto/product_writer/product_writer_messages.pb.go:374
Method
Descriptor
Deprecated: Use GetProductByIdRes.ProtoReflect.Descriptor instead.
writer_service/proto/product_writer/product_writer_messages.pb.go:421
Method
Descriptor
Deprecated: Use ProductCreate.ProtoReflect.Descriptor instead.
proto/kafka/kafka.pb.go:63
Method
Descriptor
Deprecated: Use ProductUpdate.ProtoReflect.Descriptor instead.
proto/kafka/kafka.pb.go:134
Method
Descriptor
Deprecated: Use Product.ProtoReflect.Descriptor instead.
proto/kafka/kafka.pb.go:207
Method
Descriptor
Deprecated: Use ProductCreated.ProtoReflect.Descriptor instead.
proto/kafka/kafka.pb.go:289
Method
Descriptor
Deprecated: Use ProductUpdated.ProtoReflect.Descriptor instead.
proto/kafka/kafka.pb.go:336
Method
Descriptor
Deprecated: Use ProductDelete.ProtoReflect.Descriptor instead.
proto/kafka/kafka.pb.go:383
Method
Descriptor
Deprecated: Use ProductDeleted.ProtoReflect.Descriptor instead.
proto/kafka/kafka.pb.go:430
Method
Descriptor
Deprecated: Use Product.ProtoReflect.Descriptor instead.
reader_service/proto/product_reader/product_reader_messages.pb.go:65
Method
Descriptor
Deprecated: Use CreateProductReq.ProtoReflect.Descriptor instead.
reader_service/proto/product_reader/product_reader_messages.pb.go:150
Method
Descriptor
Deprecated: Use CreateProductRes.ProtoReflect.Descriptor instead.
reader_service/proto/product_reader/product_reader_messages.pb.go:218
Method
Descriptor
Deprecated: Use UpdateProductReq.ProtoReflect.Descriptor instead.
reader_service/proto/product_reader/product_reader_messages.pb.go:268
Method
Descriptor
Deprecated: Use UpdateProductRes.ProtoReflect.Descriptor instead.
reader_service/proto/product_reader/product_reader_messages.pb.go:336
Method
Descriptor
Deprecated: Use GetProductByIdReq.ProtoReflect.Descriptor instead.
reader_service/proto/product_reader/product_reader_messages.pb.go:383
Method
Descriptor
Deprecated: Use GetProductByIdRes.ProtoReflect.Descriptor instead.
reader_service/proto/product_reader/product_reader_messages.pb.go:430
Method
Descriptor
Deprecated: Use SearchReq.ProtoReflect.Descriptor instead.
reader_service/proto/product_reader/product_reader_messages.pb.go:479
Method
Descriptor
Deprecated: Use SearchRes.ProtoReflect.Descriptor instead.
reader_service/proto/product_reader/product_reader_messages.pb.go:545
Method
Descriptor
Deprecated: Use DeleteProductByIdReq.ProtoReflect.Descriptor instead.
reader_service/proto/product_reader/product_reader_messages.pb.go:627
Method
Descriptor
Deprecated: Use DeleteProductByIdRes.ProtoReflect.Descriptor instead.
reader_service/proto/product_reader/product_reader_messages.pb.go:672
Method
Err
Err uses error to log a message.
pkg/logger/logger.go:180
Method
ErrBody
()
pkg/http_errors/http_errors.go:42
Method
ErrBody
ErrBody Error body
pkg/http_errors/http_errors.go:54
Method
Error
Error uses fmt.Sprint to construct and log a message.
pkg/logger/logger.go:170
Method
Error
Error Error() interface method
pkg/http_errors/http_errors.go:59
Function
ErrorCtxResponse
ErrorCtxResponse Error response object and status code
pkg/http_errors/http_errors.go:237
Function
ErrorResponse
ErrorResponse Error response
pkg/http_errors/http_errors.go:232
Method
Errorf
Errorf uses fmt.Sprintf to log a templated message.
pkg/logger/logger.go:175
Method
Fatal
Fatal uses fmt.Sprint to construct and log a message, then calls os.Exit.
pkg/logger/logger.go:205
Method
Fatalf
Fatalf uses fmt.Sprintf to log a templated message, then calls os.Exit.
pkg/logger/logger.go:210
Method
GetDescription
()
writer_service/proto/product_writer/product_writer_messages.pb.go:168
Method
GetDescription
()
writer_service/proto/product_writer/product_writer_messages.pb.go:286
Method
GetDescription
()
reader_service/proto/product_reader/product_reader_messages.pb.go:168
Method
GetDescription
()
reader_service/proto/product_reader/product_reader_messages.pb.go:286
Method
GetName
()
writer_service/proto/product_writer/product_writer_messages.pb.go:161
Method
GetName
()
writer_service/proto/product_writer/product_writer_messages.pb.go:279
← previous
next →
201–300 of 555, ranked by callers