MCPcopy Create free account

hub / github.com/AleksK1NG/Go-Elasticsearch-RabbitMQ / functions

Functions197 in github.com/AleksK1NG/Go-Elasticsearch-RabbitMQ

⨍ Functions 197◇ Types & classes 48
↓ 35 callersMethodErrorf
(template string, args ...interface{})
pkg/logger/logger.go:31
↓ 34 callersMethodString
()
pkg/tracing/jaeger.go:19
↓ 31 callersMethodInfof
(template string, args ...interface{})
pkg/logger/logger.go:26
↓ 19 callersMethodError
()
pkg/http_errors/http_errors.go:41
↓ 17 callersFunctionTraceWithErr
(span opentracing.Span, err error)
pkg/tracing/utils.go:193
↓ 16 callersMethodClose
()
pkg/rabbitmq/publisher.go:12
↓ 12 callersFunctionNewRestError
NewRestError New Rest Error
pkg/http_errors/http_errors.go:75
↓ 8 callersMethodError
(args ...interface{})
pkg/logger/logger.go:30
↓ 8 callersMethodWarnf
(template string, args ...interface{})
pkg/logger/logger.go:28
↓ 6 callersMethodInfo
(args ...interface{})
pkg/logger/logger.go:25
↓ 6 callersFunctionInjectTextMapCarrier
(spanCtx opentracing.SpanContext)
pkg/tracing/utils.go:119
↓ 5 callersMethodGetSize
GetSize Get OrderBy
pkg/utils/pagination.go:124
↓ 5 callersMethodString
()
pkg/esclient/esclient.go:20
↓ 4 callersMethodDebug
(args ...interface{})
pkg/logger/logger.go:23
↓ 4 callersMethodIndex
(ctx context.Context, product Product)
internal/product/domain/usecase.go:10
↓ 4 callersMethodNamed
(name string)
pkg/logger/logger.go:38
↓ 4 callersMethodSearch
(ctx context.Context, term string, pagination *utils.Pagination)
internal/product/domain/usecase.go:11
↓ 3 callersMethodDebugf
(template string, args ...interface{})
pkg/logger/logger.go:24
↓ 3 callersMethodFatal
(args ...interface{})
pkg/logger/logger.go:35
↓ 3 callersFunctionGetMicroserviceName
(cfg *config.Config)
internal/app/utils.go:25
↓ 3 callersMethodGetPage
GetPage Get OrderBy
pkg/utils/pagination.go:119
↓ 3 callersFunctionInfo
(ctx context.Context, esClient *elasticsearch.Client)
pkg/esclient/esclient.go:24
↓ 3 callersFunctionMarshal
(v any)
pkg/serializer/serializer.go:10
↓ 3 callersFunctionParseErrors
ParseErrors Parser of error string messages returns RestError
pkg/http_errors/http_errors.go:175
↓ 3 callersFunctionStartHttpServerTracerSpan
(c echo.Context, operationName string)
pkg/tracing/utils.go:15
↓ 3 callersFunctionUnmarshal
(data []byte, v any)
pkg/serializer/serializer.go:14
↓ 2 callersMethodErr
(msg string, err error)
pkg/logger/logger.go:32
↓ 2 callersMethodInitLogger
()
pkg/logger/logger.go:20
↓ 2 callersFunctionNewAppLogger
NewAppLogger App Logger constructor
pkg/logger/logger.go:59
↓ 2 callersFunctionNewHttpClient
(debugMode bool)
pkg/http_client/http_client.go:23
↓ 2 callersFunctionNewPublisher
(cfg Config, log logger.Logger)
pkg/rabbitmq/publisher.go:21
↓ 2 callersFunctionNewRabbitMQConnection
(cfg Config)
pkg/rabbitmq/rabbitmq.go:31
↓ 2 callersMethodPublish
(ctx context.Context, exchange, key string, msg amqp.Publishing)
pkg/rabbitmq/publisher.go:11
↓ 2 callersMethodPublishWithContext
(ctx context.Context, exchange, key string, mandatory, immediate bool, msg amqp.Publishing)
pkg/rabbitmq/publisher.go:10
↓ 2 callersMethodStatus
()
pkg/http_errors/http_errors.go:40
↓ 2 callersMethodSync
()
pkg/logger/logger.go:21
↓ 2 callersMethodWarn
(args ...interface{})
pkg/logger/logger.go:27
↓ 1 callersFunctionBindQueue
(ctx context.Context, channel *amqp.Channel, queue, key, exchange string)
pkg/rabbitmq/rabbitmq.go:80
↓ 1 callersFunctionConsumeQueue
(ctx context.Context, channel *amqp.Channel, concurrency int, queue string, consumer string, worker Deliveries
pkg/rabbitmq/rabbitmq.go:90
↓ 1 callersFunctionCreateIndex
(ctx context.Context, esClient *elasticsearch.Client, name string, data []byte)
pkg/esclient/esclient.go:36
↓ 1 callersMethodDPanic
(args ...interface{})
pkg/logger/logger.go:33
↓ 1 callersMethodDPanicf
(template string, args ...interface{})
pkg/logger/logger.go:34
↓ 1 callersFunctionDeclareBinding
(ctx context.Context, channel *amqp.Channel, exchangeAndQueueBinding ExchangeAndQueueBinding)
pkg/rabbitmq/rabbitmq.go:40
↓ 1 callersFunctionDeclareExchange
(ctx context.Context, channel *amqp.Channel, name, kind string)
pkg/rabbitmq/rabbitmq.go:57
↓ 1 callersFunctionDeclareQueue
(ctx context.Context, channel *amqp.Channel, name string)
pkg/rabbitmq/rabbitmq.go:69
↓ 1 callersFunctionExists
(ctx context.Context, esClient *elasticsearch.Client, indexes []string)
pkg/esclient/esclient.go:77
↓ 1 callersFunctionExtractTextMapCarrierHeadersToAmqpTable
(spanCtx opentracing.SpanContext)
pkg/tracing/utils.go:161
↓ 1 callersMethodFatalf
(template string, args ...interface{})
pkg/logger/logger.go:36
↓ 1 callersMethodGetHasMore
GetHasMore Get has more
pkg/utils/pagination.go:140
↓ 1 callersMethodGetOffset
GetOffset Get offset
pkg/utils/pagination.go:101
↓ 1 callersMethodGetOppositeLayoutWord
(originalWord string)
pkg/keyboard_manager/keyboard_manager.go:10
↓ 1 callersMethodGetOrderBy
GetOrderBy Get OrderBy
pkg/utils/pagination.go:114
↓ 1 callersFunctionGetTextMapCarrierFromMetaData
(ctx context.Context)
pkg/tracing/utils.go:29
↓ 1 callersMethodGetTotalPages
GetTotalPages Get total pages int
pkg/utils/pagination.go:134
↓ 1 callersMethodHttpMiddlewareAccessLogger
(method string, uri string, status int, size int64, time time.Duration)
pkg/logger/logger.go:39
↓ 1 callersMethodIndexAsync
(ctx context.Context, product Product)
internal/product/domain/usecase.go:9
↓ 1 callersMethodInitBulkIndexer
()
internal/product/delivery/rabbitmq/consumer.go:122
↓ 1 callersFunctionInitConfig
()
config/config.go:74
↓ 1 callersMethodMapRoutes
()
internal/product/delivery/http/v1/routes.go:3
↓ 1 callersFunctionNewApp
(log logger.Logger, cfg *config.Config)
internal/app/app.go:50
↓ 1 callersFunctionNewDecoder
(r io.Reader)
pkg/serializer/serializer.go:18
↓ 1 callersFunctionNewElasticSearchClient
(cfg Config)
pkg/elastic/elastic.go:27
↓ 1 callersFunctionNewEsRepository
( log logger.Logger, cfg *config.Config, esClient *elasticsearch.Client, missTypeManager keyboard_manager.
internal/product/repository/elastic_repository.go:38
↓ 1 callersFunctionNewJaegerTracer
(jaegerConfig *Config)
pkg/tracing/jaeger.go:23
↓ 1 callersFunctionNewKeyboardLayoutManager
(log logger.Logger, keyMappings map[string]string)
pkg/keyboard_manager/keyboard_manager.go:19
↓ 1 callersFunctionNewMiddlewareManager
(log logger.Logger, cfg *config.Config, metricsCb MiddlewareMetricsCb)
pkg/middlewares/manager.go:23
↓ 1 callersFunctionNewPaginationFromQueryParams
(size string, page string)
pkg/utils/pagination.go:51
↓ 1 callersFunctionNewPaginationResponse
(totalCount int64, pq *Pagination)
pkg/utils/pagination.go:26
↓ 1 callersFunctionNewProductController
( log logger.Logger, cfg *config.Config, productUseCase domain.ProductUseCase, group *echo.Group, validat
internal/product/delivery/http/v1/controller.go:29
↓ 1 callersFunctionNewProductUseCase
( log logger.Logger, cfg *config.Config, elasticRepository domain.ElasticRepository, amqpPublisher rabbitm
internal/product/usecase/usecase.go:26
↓ 1 callersFunctionNewSearchMicroserviceMetrics
(cfg *config.Config)
internal/metrics/metrics.go:21
↓ 1 callersMethodRun
()
internal/app/app.go:54
↓ 1 callersFunctionStartRabbitConsumerTracerSpan
(ctx context.Context, headers amqp091.Table, operationName string)
pkg/tracing/utils.go:71
↓ 1 callersMethodSync
Sync flushes any buffered log entries
pkg/logger/logger.go:270
↓ 1 callersFunctionTextMapCarrierFromKafkaMessageHeaders
(headers []kafka.Header)
pkg/tracing/utils.go:103
↓ 1 callersFunctionTextMapCarrierFromRabbitMessageHeaders
(headers map[string]any)
pkg/tracing/utils.go:111
↓ 1 callersFunctionTextMapCarrierToKafkaMessageHeaders
(textMap opentracing.TextMapCarrier)
pkg/tracing/utils.go:87
↓ 1 callersMethodbulkIndexProduct
(ctx context.Context, msg amqp.Delivery)
internal/product/delivery/rabbitmq/consumer.go:90
↓ 1 callersMethodcheckIgnoredURI
(requestURI string, uriList []string)
pkg/middlewares/manager.go:48
↓ 1 callersMethodcloseRabbitConn
()
internal/app/rabbitmq.go:54
↓ 1 callersMethodconfigureHealthCheckEndpoints
(ctx context.Context, health healthcheck.Handler)
internal/app/healthcheck.go:37
↓ 1 callersMethodgetHttpMetricsCb
()
internal/app/utils.go:142
↓ 1 callersMethodgetLoggerLevel
()
pkg/logger/logger.go:74
↓ 1 callersMethodindex
()
internal/product/delivery/http/v1/controller.go:63
↓ 1 callersMethodindexAsync
()
internal/product/delivery/http/v1/controller.go:40
↓ 1 callersMethodinitElasticsearchClient
(ctx context.Context)
internal/app/elastic.go:16
↓ 1 callersMethodinitIndexes
(ctx context.Context)
internal/app/utils.go:29
↓ 1 callersMethodinitRabbitMQ
(ctx context.Context)
internal/app/rabbitmq.go:19
↓ 1 callersMethodinitRabbitMQPublisher
(ctx context.Context)
internal/app/rabbitmq.go:63
↓ 1 callersMethodisIndexExists
(ctx context.Context, indexName string)
internal/app/utils.go:64
↓ 1 callersMethodloadKeyMappings
()
internal/app/keymappings.go:5
↓ 1 callersMethodloadKeyboardLayoutManager
()
internal/app/utils.go:114
↓ 1 callersMethodmapRoutes
()
internal/app/http_server.go:29
↓ 1 callersFunctionparseSqlErrors
(err error, debug bool)
pkg/http_errors/http_errors.go:204
↓ 1 callersFunctionparseValidatorError
(err error, debug bool)
pkg/http_errors/http_errors.go:208
↓ 1 callersMethodrunHealthCheck
(ctx context.Context)
internal/app/healthcheck.go:13
↓ 1 callersMethodrunHttpServer
()
internal/app/http_server.go:19
↓ 1 callersMethodrunMetrics
(cancel context.CancelFunc)
internal/app/metrics.go:10
↓ 1 callersMethodsearch
()
internal/product/delivery/http/v1/controller.go:86
↓ 1 callersMethodsetLoggerLevel
(logLevel string)
pkg/logger/logger.go:83
next →1–100 of 197, ranked by callers