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
Method
GetName
()
reader_service/proto/product_reader/product_reader_messages.pb.go:161
Method
GetName
()
reader_service/proto/product_reader/product_reader_messages.pb.go:279
Method
GetNewKafkaReader
(kafkaURL []string, topic, groupID string)
pkg/kafka/consumer_group.go:21
Method
GetNewKafkaWriter
(topic string)
pkg/kafka/consumer_group.go:22
Method
GetNewKafkaWriter
GetNewKafkaWriter create new kafka producer
pkg/kafka/consumer_group.go:57
Method
GetPage
()
reader_service/proto/product_reader/product_reader_messages.pb.go:563
Method
GetPrice
()
writer_service/proto/product_writer/product_writer_messages.pb.go:175
Method
GetPrice
()
writer_service/proto/product_writer/product_writer_messages.pb.go:293
Method
GetPrice
()
reader_service/proto/product_reader/product_reader_messages.pb.go:175
Method
GetPrice
()
reader_service/proto/product_reader/product_reader_messages.pb.go:293
Method
GetProduct
()
writer_service/proto/product_writer/product_writer_messages.pb.go:425
Method
GetProduct
()
reader_service/proto/product_reader/product_reader_messages.pb.go:434
Method
GetProduct
(ctx context.Context, key string)
reader_service/internal/product/repository/redis_repository.go:45
Method
GetProductByID
()
api_gateway_service/internal/products/delivery.go:10
Method
GetProductById
(ctx context.Context, in *GetProductByIdReq, opts ...grpc.CallOption)
writer_service/proto/product_writer/product_writer_grpc.pb.go:51
Method
GetProductById
(context.Context, *GetProductByIdReq)
writer_service/proto/product_writer/product_writer_grpc.pb.go:66
Method
GetProductById
(context.Context, *GetProductByIdReq)
writer_service/proto/product_writer/product_writer_grpc.pb.go:79
Method
GetProductById
(ctx context.Context, req *writerService.GetProductByIdReq)
writer_service/internal/product/delivery/grpc/grpc_service.go:88
Method
GetProductById
(ctx context.Context, uuid uuid.UUID)
writer_service/internal/product/repository/repository.go:14
Method
GetProductById
(ctx context.Context, uuid uuid.UUID)
writer_service/internal/product/repository/pg_repository.go:62
Method
GetProductById
(ctx context.Context, in *GetProductByIdReq, opts ...grpc.CallOption)
reader_service/proto/product_reader/product_reader_grpc.pb.go:53
Method
GetProductById
(context.Context, *GetProductByIdReq)
reader_service/proto/product_reader/product_reader_grpc.pb.go:86
Method
GetProductById
(context.Context, *GetProductByIdReq)
reader_service/proto/product_reader/product_reader_grpc.pb.go:101
Method
GetProductById
(ctx context.Context, req *readerService.GetProductByIdReq)
reader_service/internal/product/delivery/grpc/grpc_service.go:76
Method
GetProductById
(ctx context.Context, uuid uuid.UUID)
reader_service/internal/product/repository/mongo_repository.go:62
Method
GetProductID
()
writer_service/proto/product_writer/product_writer_messages.pb.go:154
Method
GetProductID
()
writer_service/proto/product_writer/product_writer_messages.pb.go:222
Method
GetProductID
()
writer_service/proto/product_writer/product_writer_messages.pb.go:272
Method
GetProductID
()
writer_service/proto/product_writer/product_writer_messages.pb.go:378
Method
GetProductID
()
reader_service/proto/product_reader/product_reader_messages.pb.go:154
Method
GetProductID
()
reader_service/proto/product_reader/product_reader_messages.pb.go:222
Method
GetProductID
()
reader_service/proto/product_reader/product_reader_messages.pb.go:272
Method
GetProductID
()
reader_service/proto/product_reader/product_reader_messages.pb.go:340
Method
GetProductID
()
reader_service/proto/product_reader/product_reader_messages.pb.go:387
Method
GetProductID
()
reader_service/proto/product_reader/product_reader_messages.pb.go:631
Method
GetQueryString
GetQueryString get query string
pkg/utils/pagination.go:103
Method
GetSize
()
reader_service/proto/product_reader/product_reader_messages.pb.go:570
Method
GrpcClientInterceptorLogger
(method string, req, reply interface{}, time time.Duration, metaData map[string][]string, err error)
pkg/logger/logger.go:241
Method
GrpcMiddlewareAccessLogger
(method string, time time.Duration, metaData map[string][]string, err error)
pkg/logger/logger.go:231
Method
Handle
(ctx context.Context, command *DeleteProductCommand)
writer_service/internal/product/commands/delete_product.go:18
Method
Handle
(ctx context.Context, command *DeleteProductCommand)
writer_service/internal/product/commands/delete_product.go:32
Method
Handle
(ctx context.Context, command *UpdateProductCommand)
writer_service/internal/product/commands/update_product.go:20
Method
Handle
(ctx context.Context, command *UpdateProductCommand)
writer_service/internal/product/commands/update_product.go:34
Method
Handle
(ctx context.Context, command *CreateProductCommand)
writer_service/internal/product/commands/create_product.go:20
Method
Handle
(ctx context.Context, command *CreateProductCommand)
writer_service/internal/product/commands/create_product.go:34
Method
Handle
(ctx context.Context, query *GetProductByIdQuery)
writer_service/internal/product/queries/get_product_by_id.go:12
Method
Handle
(ctx context.Context, query *GetProductByIdQuery)
writer_service/internal/product/queries/get_product_by_id.go:25
Method
Handle
(ctx context.Context, command *DeleteProductCommand)
api_gateway_service/internal/products/commands/delete_product.go:17
Method
Handle
(ctx context.Context, command *DeleteProductCommand)
api_gateway_service/internal/products/commands/delete_product.go:30
Method
Handle
(ctx context.Context, command *UpdateProductCommand)
api_gateway_service/internal/products/commands/update_product.go:17
Method
Handle
(ctx context.Context, command *UpdateProductCommand)
api_gateway_service/internal/products/commands/update_product.go:30
Method
Handle
(ctx context.Context, command *CreateProductCommand)
api_gateway_service/internal/products/commands/create_product.go:17
Method
Handle
(ctx context.Context, command *CreateProductCommand)
api_gateway_service/internal/products/commands/create_product.go:30
Method
Handle
(ctx context.Context, query *SearchProductQuery)
api_gateway_service/internal/products/queries/search_product.go:14
Method
Handle
(ctx context.Context, query *SearchProductQuery)
api_gateway_service/internal/products/queries/search_product.go:27
Method
Handle
(ctx context.Context, query *GetProductByIdQuery)
api_gateway_service/internal/products/queries/get_by_id.go:14
Method
Handle
(ctx context.Context, query *GetProductByIdQuery)
api_gateway_service/internal/products/queries/get_by_id.go:27
Method
Handle
(ctx context.Context, command *DeleteProductCommand)
reader_service/internal/product/commands/delete_product.go:12
Method
Handle
(ctx context.Context, command *DeleteProductCommand)
reader_service/internal/product/commands/delete_product.go:26
Method
Handle
(ctx context.Context, command *UpdateProductCommand)
reader_service/internal/product/commands/update_product.go:13
Method
Handle
(ctx context.Context, command *UpdateProductCommand)
reader_service/internal/product/commands/update_product.go:27
Method
Handle
(ctx context.Context, command *CreateProductCommand)
reader_service/internal/product/commands/create_product.go:13
Method
Handle
(ctx context.Context, command *CreateProductCommand)
reader_service/internal/product/commands/create_product.go:27
Method
Handle
(ctx context.Context, query *SearchProductQuery)
reader_service/internal/product/queries/search.go:26
Method
Handle
(ctx context.Context, query *GetProductByIdQuery)
reader_service/internal/product/queries/get_by_id.go:13
Method
Handle
(ctx context.Context, query *GetProductByIdQuery)
reader_service/internal/product/queries/get_by_id.go:27
Method
HttpMiddlewareAccessLogger
(method, uri string, status int, size int64, time time.Duration)
pkg/logger/logger.go:220
Method
Info
Info uses fmt.Sprint to construct and log a message
pkg/logger/logger.go:140
Method
Infof
Infof uses fmt.Sprintf to log a templated message.
pkg/logger/logger.go:145
Method
InitLogger
InitLogger Init logger
pkg/logger/logger.go:83
Method
KafkaLogCommittedMessage
(topic string, partition int, offset int64)
pkg/logger/logger.go:265
Method
KafkaProcessMessage
(topic string, partition int, message string, workerID int, offset int64, time time.Time)
pkg/logger/logger.go:253
Method
Logger
Logger Interceptor
pkg/interceptors/manager.go:40
Function
NewBadRequestError
NewBadRequestError New Bad Request Error
pkg/http_errors/http_errors.go:106
Function
NewConsumerGroup
NewConsumerGroup kafka consumer group constructor
pkg/kafka/consumer_group.go:32
Function
NewForbiddenError
NewForbiddenError New Forbidden Error
pkg/http_errors/http_errors.go:146
Function
NewHttpClient
(debugMode bool)
pkg/http_client/http_client.go:19
Function
NewInternalServerError
NewInternalServerError New Internal Server Error
pkg/http_errors/http_errors.go:160
Function
NewKafkaConn
NewKafkaConn create new kafka connection
pkg/kafka/client.go:10
Function
NewKafkaReader
NewKafkaReader create new configured kafka reader
pkg/kafka/reader.go:9
Function
NewLoggerConfig
(logLevel string, devMode bool, encoder string)
pkg/logger/logger.go:17
Function
NewNotFoundError
NewNotFoundError New Not Found Error
pkg/http_errors/http_errors.go:119
Function
NewProductMessageProcessor
(log logger.Logger, cfg *config.Config, v *validator.Validate, ps *service.ProductService, metrics *metrics.Wr
writer_service/internal/product/delivery/kafka/consumer_group.go:26
Function
NewReaderGrpcService
(log logger.Logger, cfg *config.Config, v *validator.Validate, ps *service.ProductService, metrics *metrics.Re
reader_service/internal/product/delivery/grpc/grpc_service.go:30
Function
NewReaderMessageProcessor
(log logger.Logger, cfg *config.Config, v *validator.Validate, ps *service.ProductService, metrics *metrics.Re
reader_service/internal/product/delivery/kafka/consumer_group.go:26
Function
NewReaderServiceClient
(cc grpc.ClientConnInterface)
reader_service/proto/product_reader/product_reader_grpc.pb.go:31
Function
NewRestErrorFromBytes
NewRestErrorFromBytes New Rest Error From Bytes
pkg/http_errors/http_errors.go:97
Function
NewRestErrorWithMessage
NewRestErrorWithMessage New Rest Error With Message
pkg/http_errors/http_errors.go:87
Function
NewUnauthorizedError
NewUnauthorizedError New Unauthorized Error
pkg/http_errors/http_errors.go:132
Function
NewUniversalRedisClient
(cfg *Config)
pkg/redis/redis.go:27
Function
NewWriterGrpcService
(log logger.Logger, cfg *config.Config, v *validator.Validate, ps *service.ProductService, metrics *metrics.Wr
writer_service/internal/product/delivery/grpc/grpc_service.go:28
Function
NewWriterServiceClient
(cc grpc.ClientConnInterface)
writer_service/proto/product_writer/product_writer_grpc.pb.go:29
Function
NewWriterWrapper
NewWriterWrapper response writer wrapper
pkg/http_utils/http_utils.go:12
Method
Panic
Panic uses fmt.Sprint to construct and log a message, then panics.
pkg/logger/logger.go:195
Method
Panicf
Panicf uses fmt.Sprintf to log a templated message, then panics
pkg/logger/logger.go:200
Method
Printf
(template string, args ...interface{})
pkg/logger/logger.go:39
Method
Printf
Printf uses fmt.Sprintf to log a templated message
pkg/logger/logger.go:150
Method
ProcessMessages
(ctx context.Context, r *kafka.Reader, wg *sync.WaitGroup, workerID int)
writer_service/internal/product/delivery/kafka/consumer_group.go:30
Method
ProcessMessages
(ctx context.Context, r *kafka.Reader, wg *sync.WaitGroup, workerID int)
pkg/kafka/consumer_group.go:13
Method
ProcessMessages
(ctx context.Context, r *kafka.Reader, wg *sync.WaitGroup, workerID int)
reader_service/internal/product/delivery/kafka/consumer_group.go:30
← previous
next →
301–400 of 555, ranked by callers