Functions — github.com/AleksK1NG/Go-CQRS-Kafka-gRPC-Microservices

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

↓ 1 callersMethodGetHasMore

()

reader_service/proto/product_reader/product_reader_messages.pb.go:577

↓ 1 callersMethodGetLimit

GetLimit Get limit

pkg/utils/pagination.go:83

↓ 1 callersMethodGetName

()

proto/kafka/kafka.pb.go:74

↓ 1 callersMethodGetName

()

proto/kafka/kafka.pb.go:145

↓ 1 callersMethodGetName

()

proto/kafka/kafka.pb.go:218

↓ 1 callersMethodGetNewKafkaReader

GetNewKafkaReader create new kafka reader

pkg/kafka/consumer_group.go:37

↓ 1 callersMethodGetOffset

GetOffset Get offset

pkg/utils/pagination.go:75

↓ 1 callersMethodGetOrderBy

GetOrderBy Get OrderBy

pkg/utils/pagination.go:88

↓ 1 callersMethodGetPrice

()

proto/kafka/kafka.pb.go:88

↓ 1 callersMethodGetPrice

()

proto/kafka/kafka.pb.go:159

↓ 1 callersMethodGetPrice

()

proto/kafka/kafka.pb.go:232

↓ 1 callersMethodGetProduct

()

proto/kafka/kafka.pb.go:293

↓ 1 callersMethodGetProduct

()

proto/kafka/kafka.pb.go:340

↓ 1 callersMethodGetProductByID

GetProductByID @Tags Products @Summary Get product @Description Get product by id @Accept json @Produce json @Param id path string true "Product ID" @

api_gateway_service/internal/products/delivery/http/v1/handlers.go:94

↓ 1 callersMethodGetProductID

()

proto/kafka/kafka.pb.go:67

↓ 1 callersMethodGetProductID

()

proto/kafka/kafka.pb.go:138

↓ 1 callersMethodGetProductID

()

proto/kafka/kafka.pb.go:211

↓ 1 callersMethodGetProductID

()

proto/kafka/kafka.pb.go:387

↓ 1 callersMethodGetProductID

()

proto/kafka/kafka.pb.go:434

↓ 1 callersMethodGetSearch

()

reader_service/proto/product_reader/product_reader_messages.pb.go:483

↓ 1 callersFunctionGetTextMapCarrierFromMetaData

(ctx context.Context)

pkg/tracing/utils.go:26

↓ 1 callersMethodGetTotalCount

()

reader_service/proto/product_reader/product_reader_messages.pb.go:549

↓ 1 callersMethodGetTotalPages

GetTotalPages Get total pages int

pkg/utils/pagination.go:108

↓ 1 callersMethodGetTotalPages

()

reader_service/proto/product_reader/product_reader_messages.pb.go:556

↓ 1 callersMethodGetUpdatedAt

()

writer_service/proto/product_writer/product_writer_messages.pb.go:104

↓ 1 callersMethodGetUpdatedAt

()

proto/kafka/kafka.pb.go:246

↓ 1 callersMethodGrpcClientInterceptorLogger

(method string, req interface{}, reply interface{}, time time.Duration, metaData map[string][]string, err erro

pkg/logger/logger.go:43

↓ 1 callersMethodGrpcMiddlewareAccessLogger

(method string, time time.Duration, metaData map[string][]string, err error)

pkg/logger/logger.go:42

↓ 1 callersMethodHttpMiddlewareAccessLogger

(method string, uri string, status int, size int64, time time.Duration)

pkg/logger/logger.go:41

↓ 1 callersFunctionInitConfig

()

writer_service/config/config.go:48

↓ 1 callersFunctionInitConfig

()

api_gateway_service/config/config.go:55

↓ 1 callersFunctionInitConfig

()

reader_service/config/config.go:59

↓ 1 callersMethodLogger

( ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler, )

pkg/interceptors/manager.go:12

↓ 1 callersMethodMapRoutes

()

api_gateway_service/internal/products/delivery/http/v1/routes.go:8

↓ 1 callersFunctionNewApiGatewayMetrics

(cfg *config.Config)

api_gateway_service/internal/metrics/metrics.go:20

↓ 1 callersFunctionNewCreateProductCommand

(createDto *dto.CreateProductDto)

api_gateway_service/internal/products/commands/commands.go:22

↓ 1 callersFunctionNewCreateProductHandler

(log logger.Logger, cfg *config.Config, pgRepo repository.Repository, kafkaProducer kafkaClient.Producer)

writer_service/internal/product/commands/create_product.go:30

↓ 1 callersFunctionNewCreateProductHandler

(log logger.Logger, cfg *config.Config, kafkaProducer kafkaClient.Producer)

api_gateway_service/internal/products/commands/create_product.go:26

↓ 1 callersFunctionNewCreateProductHandler

(log logger.Logger, cfg *config.Config, mongoRepo repository.Repository, redisRepo repository.CacheRepository)

reader_service/internal/product/commands/create_product.go:23

↓ 1 callersFunctionNewDeleteProductCmdHandler

(log logger.Logger, cfg *config.Config, mongoRepo repository.Repository, redisRepo repository.CacheRepository)

reader_service/internal/product/commands/delete_product.go:22

↓ 1 callersFunctionNewDeleteProductCommand

(productID uuid.UUID)

writer_service/internal/product/commands/commands.go:41

↓ 1 callersFunctionNewDeleteProductCommand

(productID uuid.UUID)

api_gateway_service/internal/products/commands/commands.go:38

↓ 1 callersFunctionNewDeleteProductHandler

(log logger.Logger, cfg *config.Config, pgRepo repository.Repository, kafkaProducer kafkaClient.Producer)

writer_service/internal/product/commands/delete_product.go:28

↓ 1 callersFunctionNewDeleteProductHandler

(log logger.Logger, cfg *config.Config, kafkaProducer kafkaClient.Producer)

api_gateway_service/internal/products/commands/delete_product.go:26

↓ 1 callersFunctionNewGetProductByIdHandler

(log logger.Logger, cfg *config.Config, pgRepo repository.Repository)

writer_service/internal/product/queries/get_product_by_id.go:21

↓ 1 callersFunctionNewGetProductByIdHandler

(log logger.Logger, cfg *config.Config, rsClient readerService.ReaderServiceClient)

api_gateway_service/internal/products/queries/get_by_id.go:23

↓ 1 callersFunctionNewGetProductByIdHandler

(log logger.Logger, cfg *config.Config, mongoRepo repository.Repository, redisRepo repository.CacheRepository)

reader_service/internal/product/queries/get_by_id.go:23

↓ 1 callersFunctionNewGetProductByIdQuery

(productID uuid.UUID)

writer_service/internal/product/queries/queries.go:17

↓ 1 callersFunctionNewGetProductByIdQuery

(productID uuid.UUID)

api_gateway_service/internal/products/queries/queries.go:21

↓ 1 callersFunctionNewGetProductByIdQuery

(productID uuid.UUID)

reader_service/internal/product/queries/queries.go:21

↓ 1 callersFunctionNewMiddlewareManager

(log logger.Logger, cfg *config.Config)

api_gateway_service/internal/middlewares/middlewares.go:20

↓ 1 callersFunctionNewMongoDBConn

NewMongoDBConn Create new MongoDB client

pkg/mongodb/mongodb.go:26

↓ 1 callersFunctionNewMongoRepository

(log logger.Logger, cfg *config.Config, db *mongo.Client)

reader_service/internal/product/repository/mongo_repository.go:24

↓ 1 callersFunctionNewPaginationFromQueryParams

(size string, page string)

pkg/utils/pagination.go:25

↓ 1 callersFunctionNewPaginationQuery

NewPaginationQuery Pagination query constructor

pkg/utils/pagination.go:21

↓ 1 callersFunctionNewPgxConn

NewPgxConn pool

pkg/postgres/postgres.go:31

↓ 1 callersFunctionNewProducer

NewProducer create new kafka producer

pkg/kafka/producer.go:21

↓ 1 callersFunctionNewProductCommands

(createProduct CreateProductCmdHandler, updateProduct UpdateProductCmdHandler, deleteProduct DeleteProductCmdH

writer_service/internal/product/commands/commands.go:11

↓ 1 callersFunctionNewProductCommands

(createProduct CreateProductCmdHandler, updateProduct UpdateProductCmdHandler, deleteProduct DeleteProductCmdH

api_gateway_service/internal/products/commands/commands.go:14

↓ 1 callersFunctionNewProductCommands

( createProduct CreateProductCmdHandler, updateProduct UpdateProductCmdHandler, deleteProduct DeleteProduct

reader_service/internal/product/commands/commands.go:14

↓ 1 callersFunctionNewProductListWithPagination

(products []*Product, count int64, pagination *utils.Pagination)

reader_service/internal/models/product.go:29

↓ 1 callersFunctionNewProductQueries

(getProductById GetProductByIdHandler)

writer_service/internal/product/queries/queries.go:9

↓ 1 callersFunctionNewProductQueries

(getProductById GetProductByIdHandler, searchProduct SearchProductHandler)

api_gateway_service/internal/products/queries/queries.go:13

↓ 1 callersFunctionNewProductQueries

(getProductById GetProductByIdHandler, searchProduct SearchProductHandler)

reader_service/internal/product/queries/queries.go:13

↓ 1 callersFunctionNewProductRepository

(log logger.Logger, cfg *config.Config, db *pgxpool.Pool)

writer_service/internal/product/repository/pg_repository.go:20

↓ 1 callersFunctionNewProductService

(log logger.Logger, cfg *config.Config, pgRepo repository.Repository, kafkaProducer kafkaClient.Producer)

writer_service/internal/product/service/service.go:17

↓ 1 callersFunctionNewProductService

(log logger.Logger, cfg *config.Config, kafkaProducer kafkaClient.Producer, rsClient readerService.ReaderServi

api_gateway_service/internal/products/service/service.go:17

↓ 1 callersFunctionNewProductService

( log logger.Logger, cfg *config.Config, mongoRepo repository.Repository, redisRepo repository.CacheReposi

reader_service/internal/product/service/service.go:16

↓ 1 callersFunctionNewProductsHandlers

( group *echo.Group, log logger.Logger, mw middlewares.MiddlewareManager, cfg *config.Config, ps *service

api_gateway_service/internal/products/delivery/http/v1/handlers.go:33

↓ 1 callersFunctionNewReaderServiceConn

(ctx context.Context, cfg *config.Config, im interceptors.InterceptorManager)

api_gateway_service/internal/client/reader_service.go:19

↓ 1 callersFunctionNewReaderServiceMetrics

(cfg *config.Config)

reader_service/internal/metrics/metrics.go:28

↓ 1 callersFunctionNewRedisRepository

(log logger.Logger, cfg *config.Config, redisClient redis.UniversalClient)

reader_service/internal/product/repository/redis_repository.go:24

↓ 1 callersFunctionNewSearchProductHandler

(log logger.Logger, cfg *config.Config, rsClient readerService.ReaderServiceClient)

api_gateway_service/internal/products/queries/search_product.go:23

↓ 1 callersFunctionNewSearchProductHandler

(log logger.Logger, cfg *config.Config, mongoRepo repository.Repository, redisRepo repository.CacheRepository)

reader_service/internal/product/queries/search.go:22

↓ 1 callersFunctionNewSearchProductQuery

(text string, pagination *utils.Pagination)

api_gateway_service/internal/products/queries/queries.go:30

↓ 1 callersFunctionNewSearchProductQuery

(text string, pagination *utils.Pagination)

reader_service/internal/product/queries/queries.go:30

↓ 1 callersFunctionNewServer

(log logger.Logger, cfg *config.Config)

writer_service/internal/server/server.go:36

↓ 1 callersFunctionNewServer

(log logger.Logger, cfg *config.Config)

api_gateway_service/internal/server/server.go:35

↓ 1 callersFunctionNewServer

(log logger.Logger, cfg *config.Config)

reader_service/internal/server/server.go:39

↓ 1 callersFunctionNewUpdateProductCmdHandler

(log logger.Logger, cfg *config.Config, mongoRepo repository.Repository, redisRepo repository.CacheRepository)

reader_service/internal/product/commands/update_product.go:23

↓ 1 callersFunctionNewUpdateProductCommand

(updateDto *dto.UpdateProductDto)

api_gateway_service/internal/products/commands/commands.go:30

↓ 1 callersFunctionNewUpdateProductHandler

(log logger.Logger, cfg *config.Config, pgRepo repository.Repository, kafkaProducer kafkaClient.Producer)

writer_service/internal/product/commands/update_product.go:30

↓ 1 callersFunctionNewUpdateProductHandler

(log logger.Logger, cfg *config.Config, kafkaProducer kafkaClient.Producer)

api_gateway_service/internal/products/commands/update_product.go:26

↓ 1 callersFunctionNewWriter

NewWriter create new configured kafka writer

pkg/kafka/writer.go:9

↓ 1 callersFunctionNewWriterServiceMetrics

(cfg *config.Config)

writer_service/internal/metrics/metrics.go:28

↓ 1 callersFunctionProductListToGrpc

(products *ProductsList)

reader_service/internal/models/product.go:51

↓ 1 callersFunctionProductsListResponseFromGrpc

(listResponse *readerService.SearchRes)

api_gateway_service/internal/dto/product_list_response.go:14

↓ 1 callersMethodRun

()

writer_service/internal/server/server.go:40

↓ 1 callersMethodRun

()

api_gateway_service/internal/server/server.go:39

↓ 1 callersMethodRun

()

reader_service/internal/server/server.go:43

↓ 1 callersMethodSearch

(ctx context.Context, search string, pagination *utils.Pagination)

reader_service/internal/product/repository/repository.go:16

↓ 1 callersMethodSearchProduct

()

api_gateway_service/internal/products/delivery.go:11

↓ 1 callersMethodSearchProduct

SearchProduct @Tags Products @Summary Search product @Description Get product by name with pagination @Accept json @Produce json @Param search query s

api_gateway_service/internal/products/delivery/http/v1/handlers.go:132

↓ 1 callersFunctionTextMapCarrierFromKafkaMessageHeaders

(headers []kafka.Header)

pkg/tracing/utils.go:84

↓ 1 callersFunctionTextMapCarrierToKafkaMessageHeaders

(textMap opentracing.TextMapCarrier)

pkg/tracing/utils.go:68

↓ 1 callersMethodUpdateProduct

UpdateProduct @Tags Products @Summary Update product @Description Update existing product @Accept json @Produce json @Param id path string true "Produ

api_gateway_service/internal/products/delivery/http/v1/handlers.go:163

↓ 1 callersMethodUpdateProduct

(ctx context.Context, product *models.Product)

reader_service/internal/product/repository/repository.go:12

↓ 1 callersFunctionWriterProductToGrpc

(product *models.Product)

writer_service/mappers/product_mapper.go:39

↓ 1 callersMethodcheckIgnoredURI

(requestURI string, uriList []string)

api_gateway_service/internal/middlewares/middlewares.go:44

↓ 1 callersMethodconnectKafkaBrokers

(ctx context.Context)

writer_service/internal/server/utils.go:23

← previous next →101–200 of 555, ranked by callers