MCPcopy Create free account

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

Functions555 in github.com/AleksK1NG/Go-CQRS-Kafka-gRPC-Microservices

⨍ Functions 555◇ Types & classes 155
↓ 69 callersMethodWarnMsg
(msg string, err error)
pkg/logger/logger.go:31
↓ 31 callersMethodError
()
pkg/http_errors/http_errors.go:40
↓ 20 callersMethodInfof
(template string, args ...interface{})
pkg/logger/logger.go:28
↓ 19 callersMethodHandle
(ctx context.Context, query *SearchProductQuery)
reader_service/internal/product/queries/search.go:12
↓ 18 callersFunctionNewRestError
NewRestError New Rest Error
pkg/http_errors/http_errors.go:74
↓ 14 callersMethodClose
()
pkg/kafka/producer.go:11
↓ 14 callersMethodString
()
proto/kafka/kafka.pb.go:188
↓ 13 callersMethodError
(args ...interface{})
pkg/logger/logger.go:32
↓ 13 callersMethodErrorf
(template string, args ...interface{})
pkg/logger/logger.go:33
↓ 11 callersFunctionfile_product_reader_messages_proto_rawDescGZIP
()
reader_service/proto/product_reader/product_reader_messages.pb.go:759
↓ 10 callersMethoderrResponse
(c codes.Code, err error)
reader_service/internal/product/delivery/grpc/grpc_service.go:144
↓ 9 callersMethodFatal
(args ...interface{})
pkg/logger/logger.go:37
↓ 9 callersMethodcommitErrMessage
(ctx context.Context, r *kafka.Reader, m kafka.Message)
writer_service/internal/product/delivery/kafka/utils.go:16
↓ 9 callersMethoderrResponse
(c codes.Code, err error)
writer_service/internal/product/delivery/grpc/grpc_service.go:116
↓ 8 callersMethodGetProductID
()
reader_service/proto/product_reader/product_reader_messages.pb.go:69
↓ 8 callersFunctionStartGrpcServerTracerSpan
(ctx context.Context, operationName string)
pkg/tracing/utils.go:36
↓ 8 callersMethodgetRedisProductPrefixKey
()
reader_service/internal/product/repository/redis_repository.go:82
↓ 7 callersMethodInfo
(args ...interface{})
pkg/logger/logger.go:27
↓ 7 callersMethodcommitErrMessage
(ctx context.Context, r *kafka.Reader, m kafka.Message)
reader_service/internal/product/delivery/kafka/utils.go:21
↓ 7 callersFunctionfile_kafka_proto_rawDescGZIP
()
proto/kafka/kafka.pb.go:501
↓ 7 callersFunctionfile_product_writer_messages_proto_rawDescGZIP
()
writer_service/proto/product_writer/product_writer_messages.pb.go:492
↓ 7 callersMethodtraceErr
(span opentracing.Span, err error)
api_gateway_service/internal/products/delivery/http/v1/handlers.go:235
↓ 6 callersMethodErr
(msg string, err error)
pkg/logger/logger.go:34
↓ 6 callersFunctionGetKafkaTracingHeadersFromSpanCtx
(spanCtx opentracing.SpanContext)
pkg/tracing/utils.go:108
↓ 6 callersMethodPublishMessage
(ctx context.Context, msgs ...kafka.Message)
pkg/kafka/producer.go:10
↓ 6 callersFunctionStartKafkaConsumerTracerSpan
(ctx context.Context, headers []kafka.Header, operationName string)
pkg/tracing/utils.go:52
↓ 6 callersMethodtraceErr
(span opentracing.Span, err error)
reader_service/internal/product/repository/mongo_repository.go:140
↓ 5 callersMethodDebugf
(template string, args ...interface{})
pkg/logger/logger.go:26
↓ 5 callersMethodGetSize
GetSize Get OrderBy
pkg/utils/pagination.go:98
↓ 5 callersFunctionStartHttpServerTracerSpan
(c echo.Context, operationName string)
pkg/tracing/utils.go:12
↓ 4 callersMethodGetDescription
()
reader_service/proto/product_reader/product_reader_messages.pb.go:83
↓ 4 callersMethodGetName
()
reader_service/proto/product_reader/product_reader_messages.pb.go:76
↓ 4 callersMethodGetPage
GetPage Get OrderBy
pkg/utils/pagination.go:93
↓ 4 callersMethodGetPrice
()
reader_service/proto/product_reader/product_reader_messages.pb.go:90
↓ 4 callersMethodGetProductID
()
writer_service/proto/product_writer/product_writer_messages.pb.go:69
↓ 4 callersMethodKafkaLogCommittedMessage
(topic string, partition int, offset int64)
pkg/logger/logger.go:45
↓ 4 callersMethodString
()
writer_service/proto/product_writer/product_writer_messages.pb.go:46
↓ 4 callersMethodString
()
reader_service/proto/product_reader/product_reader_messages.pb.go:46
↓ 4 callersMethodWarnf
(template string, args ...interface{})
pkg/logger/logger.go:30
↓ 3 callersMethodCreateProduct
(ctx context.Context, in *CreateProductReq, opts ...grpc.CallOption)
writer_service/proto/product_writer/product_writer_grpc.pb.go:20
↓ 3 callersMethodGetDescription
()
writer_service/proto/product_writer/product_writer_messages.pb.go:83
↓ 3 callersMethodGetName
()
writer_service/proto/product_writer/product_writer_messages.pb.go:76
↓ 3 callersMethodGetPrice
()
writer_service/proto/product_writer/product_writer_messages.pb.go:90
↓ 3 callersMethodGetProductById
(ctx context.Context, in *GetProductByIdReq, opts ...grpc.CallOption)
writer_service/proto/product_writer/product_writer_grpc.pb.go:22
↓ 3 callersMethodGetSize
()
reader_service/proto/product_reader/product_reader_messages.pb.go:497
↓ 3 callersMethodInitLogger
()
pkg/logger/logger.go:23
↓ 3 callersFunctionNewAppLogger
NewAppLogger App Logger constructor
pkg/logger/logger.go:58
↓ 3 callersFunctionNewInterceptorManager
NewInterceptorManager InterceptorManager constructor
pkg/interceptors/manager.go:35
↓ 3 callersFunctionNewJaegerTracer
(jaegerConfig *Config)
pkg/tracing/jaeger.go:17
↓ 3 callersFunctionParseErrors
ParseErrors Parser of error string messages returns RestError
pkg/http_errors/http_errors.go:174
↓ 3 callersMethodPutProduct
(ctx context.Context, key string, product *models.Product)
reader_service/internal/product/repository/repository.go:20
↓ 3 callersMethodUpdateProduct
(ctx context.Context, in *UpdateProductReq, opts ...grpc.CallOption)
writer_service/proto/product_writer/product_writer_grpc.pb.go:21
↓ 3 callersMethodWithName
(name string)
pkg/logger/logger.go:40
↓ 3 callersMethodcommitMessage
(ctx context.Context, r *kafka.Reader, m kafka.Message)
writer_service/internal/product/delivery/kafka/utils.go:8
↓ 3 callersMethodcommitMessage
(ctx context.Context, r *kafka.Reader, m kafka.Message)
reader_service/internal/product/delivery/kafka/utils.go:8
↓ 2 callersMethodConsumeTopic
(ctx context.Context, cancel context.CancelFunc, groupID, topic string, poolSize int, worker Worker)
pkg/kafka/consumer_group.go:20
↓ 2 callersMethodCreateProduct
(ctx context.Context, in *CreateProductReq, opts ...grpc.CallOption)
reader_service/proto/product_reader/product_reader_grpc.pb.go:20
↓ 2 callersMethodDebug
(args ...interface{})
pkg/logger/logger.go:25
↓ 2 callersMethodDeleteProductByID
(ctx context.Context, in *DeleteProductByIdReq, opts ...grpc.CallOption)
reader_service/proto/product_reader/product_reader_grpc.pb.go:24
↓ 2 callersMethodGetPage
()
reader_service/proto/product_reader/product_reader_messages.pb.go:490
↓ 2 callersMethodGetProduct
(ctx context.Context, key string)
reader_service/internal/product/repository/repository.go:21
↓ 2 callersMethodGetProductById
(ctx context.Context, in *GetProductByIdReq, opts ...grpc.CallOption)
reader_service/proto/product_reader/product_reader_grpc.pb.go:22
↓ 2 callersMethodGetProductById
(ctx context.Context, uuid uuid.UUID)
reader_service/internal/product/repository/repository.go:15
↓ 2 callersMethodGetProducts
()
reader_service/proto/product_reader/product_reader_messages.pb.go:584
↓ 2 callersMethodGetUpdatedAt
()
reader_service/proto/product_reader/product_reader_messages.pb.go:104
↓ 2 callersFunctionInjectTextMapCarrier
(spanCtx opentracing.SpanContext)
pkg/tracing/utils.go:92
↓ 2 callersFunctionInjectTextMapCarrierToGrpcMetaData
(ctx context.Context, spanCtx opentracing.SpanContext)
pkg/tracing/utils.go:100
↓ 2 callersMethodKafkaProcessMessage
(topic string, partition int, message string, workerID int, offset int64, time time.Time)
pkg/logger/logger.go:44
↓ 2 callersFunctionNewCreateProductCommand
(productID uuid.UUID, name string, description string, price float64)
writer_service/internal/product/commands/commands.go:22
↓ 2 callersFunctionNewCreateProductCommand
(productID string, name string, description string, price float64, createdAt time.Time, updatedAt time.Time)
reader_service/internal/product/commands/commands.go:31
↓ 2 callersFunctionNewDeleteProductCommand
(productID uuid.UUID)
reader_service/internal/product/commands/commands.go:51
↓ 2 callersFunctionNewUpdateProductCommand
(productID uuid.UUID, name string, description string, price float64)
writer_service/internal/product/commands/commands.go:33
↓ 2 callersFunctionNewUpdateProductCommand
(productID string, name string, description string, price float64, updatedAt time.Time)
reader_service/internal/product/commands/commands.go:43
↓ 2 callersFunctionProductResponseFromGrpc
(product *readerService.Product)
api_gateway_service/internal/dto/product_response.go:17
↓ 2 callersFunctionProductToGrpcMessage
(product *models.Product)
writer_service/mappers/product_mapper.go:11
↓ 2 callersFunctionProductToGrpcMessage
(product *Product)
reader_service/internal/models/product.go:40
↓ 2 callersMethodSearchProduct
(ctx context.Context, in *SearchReq, opts ...grpc.CallOption)
reader_service/proto/product_reader/product_reader_grpc.pb.go:23
↓ 2 callersMethodStatus
()
pkg/http_errors/http_errors.go:39
↓ 2 callersMethodSync
()
pkg/logger/logger.go:24
↓ 2 callersMethodUpdateProduct
(ctx context.Context, in *UpdateProductReq, opts ...grpc.CallOption)
reader_service/proto/product_reader/product_reader_grpc.pb.go:21
↓ 2 callersMethodWarn
(args ...interface{})
pkg/logger/logger.go:29
↓ 2 callersFunctionfile_product_reader_messages_proto_init
()
reader_service/proto/product_reader/product_reader_messages.pb.go:794
↓ 2 callersFunctionfile_product_writer_messages_proto_init
()
writer_service/proto/product_writer/product_writer_messages.pb.go:522
↓ 1 callersMethodClientRequestLoggerInterceptor
()
pkg/interceptors/manager.go:18
↓ 1 callersMethodCreateProduct
CreateProduct @Tags Products @Summary Create product @Description Create new product item @Accept json @Produce json @Success 201 {object} dto.CreateP
api_gateway_service/internal/products/delivery/http/v1/handlers.go:53
↓ 1 callersMethodCreateProduct
(ctx context.Context, product *models.Product)
reader_service/internal/product/repository/repository.go:11
↓ 1 callersMethodDPanic
(args ...interface{})
pkg/logger/logger.go:35
↓ 1 callersMethodDPanicf
(template string, args ...interface{})
pkg/logger/logger.go:36
↓ 1 callersMethodDelProduct
(ctx context.Context, key string)
reader_service/internal/product/repository/repository.go:22
↓ 1 callersMethodDeleteProduct
DeleteProduct @Tags Products @Summary Delete product @Description Delete existing product @Accept json @Produce json @Success 200 "" @Param id path st
api_gateway_service/internal/products/delivery/http/v1/handlers.go:210
↓ 1 callersMethodDeleteProduct
(ctx context.Context, uuid uuid.UUID)
reader_service/internal/product/repository/repository.go:13
↓ 1 callersMethodDeleteProductByID
(ctx context.Context, uuid uuid.UUID)
writer_service/internal/product/repository/repository.go:12
↓ 1 callersMethodFatalf
(template string, args ...interface{})
pkg/logger/logger.go:38
↓ 1 callersMethodGetCreatedAt
()
writer_service/proto/product_writer/product_writer_messages.pb.go:97
↓ 1 callersMethodGetCreatedAt
()
proto/kafka/kafka.pb.go:239
↓ 1 callersMethodGetCreatedAt
()
reader_service/proto/product_reader/product_reader_messages.pb.go:97
↓ 1 callersMethodGetDescription
()
proto/kafka/kafka.pb.go:81
↓ 1 callersMethodGetDescription
()
proto/kafka/kafka.pb.go:152
↓ 1 callersMethodGetDescription
()
proto/kafka/kafka.pb.go:225
↓ 1 callersMethodGetHasMore
GetHasMore Get has more
pkg/utils/pagination.go:115
next →1–100 of 555, ranked by callers