Functions — github.com/AleksK1NG/Go-Elasticsearch-RabbitMQ

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

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

⨍ Functions 197◇ Types & classes 48

↓ 1 callersMethodshutDownHealthCheckServer

(ctx context.Context)

internal/app/healthcheck.go:74

↓ 1 callersMethoduploadElasticMappings

(ctx context.Context, indexConfig esclient.ElasticIndex)

internal/app/utils.go:80

↓ 1 callersMethodwaitShootDown

(duration time.Duration)

internal/app/utils.go:18

MethodCauses

()

pkg/http_errors/http_errors.go:42

MethodCauses

Causes RestError Causes

pkg/http_errors/http_errors.go:70

MethodClose

()

pkg/rabbitmq/publisher.go:39

MethodClose

(ctx context.Context)

internal/product/delivery/rabbitmq/consumer.go:152

MethodConsumeDeliveries

(ctx context.Context, deliveries <-chan amqp.Delivery)

pkg/rabbitmq/rabbitmq.go:85

MethodConsumeIndexDeliveries

(ctx context.Context, deliveries <-chan amqp.Delivery, workerID int)

internal/product/delivery/rabbitmq/consumer.go:43

FunctionCreateAlias

(ctx context.Context, esClient *elasticsearch.Client, indexes []string, name string, data []byte)

pkg/esclient/esclient.go:56

MethodDPanic

DPanic uses fmt.Sprint to construct and log a message. In development, the logger then panics. (See DPanicLevel for details.)

pkg/logger/logger.go:240

MethodDPanicf

DPanicf uses fmt.Sprintf to log a templated message. In development, the logger then panics. (See DPanicLevel for details.)

pkg/logger/logger.go:245

MethodDebug

Debug uses fmt.Sprint to construct and log a message.

pkg/logger/logger.go:185

MethodDebugf

Debugf uses fmt.Sprintf to log a templated message

pkg/logger/logger.go:190

MethodErr

Err uses error to log a message.

pkg/logger/logger.go:235

MethodErrBody

()

pkg/http_errors/http_errors.go:43

MethodErrBody

ErrBody Error body

pkg/http_errors/http_errors.go:55

MethodError

Error uses fmt.Sprint to construct and log a message.

pkg/logger/logger.go:225

MethodError

Error Error() interface method

pkg/http_errors/http_errors.go:60

FunctionErrorCtxResponse

ErrorCtxResponse Error response object and status code

pkg/http_errors/http_errors.go:226

FunctionErrorResponse

ErrorResponse Error response

pkg/http_errors/http_errors.go:221

MethodErrorf

Errorf uses fmt.Sprintf to log a templated message.

pkg/logger/logger.go:230

FunctionExtractTextMapCarrier

(spanCtx opentracing.SpanContext)

pkg/tracing/utils.go:145

FunctionExtractTextMapCarrierBytes

(spanCtx opentracing.SpanContext)

pkg/tracing/utils.go:175

FunctionExtractTextMapCarrierHeaders

(spanCtx opentracing.SpanContext)

pkg/tracing/utils.go:153

MethodFatal

Fatal uses fmt.Sprint to construct and log a message, then calls os.Exit.

pkg/logger/logger.go:260

MethodFatalf

Fatalf uses fmt.Sprintf to log a templated message, then calls os.Exit.

pkg/logger/logger.go:265

FunctionGetKafkaTracingHeadersFromSpanCtx

(spanCtx opentracing.SpanContext)

pkg/tracing/utils.go:135

MethodGetLimit

GetLimit Get limit

pkg/utils/pagination.go:109

MethodGetOppositeLayoutWord

(originalWord string)

pkg/keyboard_manager/keyboard_manager.go:24

MethodGetQueryString

GetQueryString get query string

pkg/utils/pagination.go:129

MethodGrpcClientInterceptorLogger

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

pkg/logger/logger.go:42

MethodGrpcClientInterceptorLogger

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

pkg/logger/logger.go:306

MethodGrpcClientInterceptorLoggerErr

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

pkg/logger/logger.go:43

MethodGrpcClientInterceptorLoggerErr

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

pkg/logger/logger.go:318

MethodGrpcMiddlewareAccessLogger

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

pkg/logger/logger.go:40

MethodGrpcMiddlewareAccessLogger

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

pkg/logger/logger.go:286

MethodGrpcMiddlewareAccessLoggerErr

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

pkg/logger/logger.go:41

MethodGrpcMiddlewareAccessLoggerErr

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

pkg/logger/logger.go:296

MethodHttpMiddlewareAccessLogger

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

pkg/logger/logger.go:275

MethodIndex

(ctx context.Context, product domain.Product)

internal/product/repository/elastic_repository.go:47

MethodIndex

(ctx context.Context, product Product)

internal/product/domain/repository.go:9

MethodIndex

(ctx context.Context, product domain.Product)

internal/product/usecase/usecase.go:57

MethodIndexAsync

(ctx context.Context, product domain.Product)

internal/product/usecase/usecase.go:35

MethodInfo

Info uses fmt.Sprint to construct and log a message

pkg/logger/logger.go:195

MethodInfof

Infof uses fmt.Sprintf to log a templated message.

pkg/logger/logger.go:200

MethodInitLogger

InitLogger Init logger

pkg/logger/logger.go:92

FunctionInjectTextMapCarrierToGrpcMetaData

(ctx context.Context, spanCtx opentracing.SpanContext)

pkg/tracing/utils.go:127

MethodKafkaLogCommittedMessage

(topic string, partition int, offset int64)

pkg/logger/logger.go:45

MethodKafkaLogCommittedMessage

(topic string, partition int, offset int64)

pkg/logger/logger.go:342

MethodKafkaProcessMessage

(topic string, partition int, message []byte, workerID int, offset int64, time time.Time)

pkg/logger/logger.go:44

MethodKafkaProcessMessage

(topic string, partition int, message []byte, workerID int, offset int64, time time.Time)

pkg/logger/logger.go:330

MethodKafkaProcessMessageWithHeaders

(topic string, partition int, message []byte, workerID int, offset int64, time time.Time, headers map[string]i

pkg/logger/logger.go:46

MethodKafkaProcessMessageWithHeaders

(topic string, partition int, message []byte, workerID int, offset int64, time time.Time, headers map[string]i

pkg/logger/logger.go:351

MethodNamed

Logger methods Named add logger microservice name

pkg/logger/logger.go:179

FunctionNewBadRequestError

NewBadRequestError New Bad Request Error

pkg/http_errors/http_errors.go:107

FunctionNewConsumer

( log logger.Logger, cfg *config.Config, amqpConn *amqp.Connection, amqpChan *amqp.Channel, productUseCas

internal/product/delivery/rabbitmq/consumer.go:31

FunctionNewEncoder

(w io.Writer)

pkg/serializer/serializer.go:22

FunctionNewForbiddenError

NewForbiddenError New Forbidden Error

pkg/http_errors/http_errors.go:147

FunctionNewInternalServerError

NewInternalServerError New Internal Server Error

pkg/http_errors/http_errors.go:161

FunctionNewNotFoundError

NewNotFoundError New Not Found Error

pkg/http_errors/http_errors.go:120

FunctionNewPaginationQuery

NewPaginationQuery Pagination query constructor

pkg/utils/pagination.go:44

FunctionNewRestErrorFromBytes

NewRestErrorFromBytes New Rest Error From Bytes

pkg/http_errors/http_errors.go:98

FunctionNewRestErrorWithMessage

NewRestErrorWithMessage New Rest Error With Message

pkg/http_errors/http_errors.go:88

FunctionNewUnauthorizedError

NewUnauthorizedError New Unauthorized Error

pkg/http_errors/http_errors.go:133

MethodPanic

Panic uses fmt.Sprint to construct and log a message, then panics.

pkg/logger/logger.go:250

MethodPanicf

Panicf uses fmt.Sprintf to log a templated message, then panics

pkg/logger/logger.go:255

MethodPrintf

(template string, args ...interface{})

pkg/logger/logger.go:37

MethodPrintf

Printf uses fmt.Sprintf to log a templated message

pkg/logger/logger.go:205

MethodPublish

(ctx context.Context, exchange, key string, msg amqp.Publishing)

pkg/rabbitmq/publisher.go:48

MethodPublishWithContext

(ctx context.Context, exchange, key string, mandatory, immediate bool, msg amqp.Publishing)

pkg/rabbitmq/publisher.go:63

MethodRequestLoggerMiddleware

(next echo.HandlerFunc)

pkg/middlewares/manager.go:14

MethodRequestLoggerMiddleware

(next echo.HandlerFunc)

pkg/middlewares/manager.go:27

FunctionSearch

(ctx context.Context, esClient *elasticsearch.Client, index, term string, fields []string)

pkg/esclient/esclient.go:95

MethodSearch

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

internal/product/repository/elastic_repository.go:79

MethodSearch

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

internal/product/domain/repository.go:10

MethodSearch

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

internal/product/usecase/usecase.go:64

MethodSetLogLevel

(logLevel string)

pkg/logger/logger.go:22

MethodSetLogLevel

(logLevel string)

pkg/logger/logger.go:133

MethodSetOrderBy

SetOrderBy Set order by

pkg/utils/pagination.go:96

MethodSetPage

SetPage Set page number

pkg/utils/pagination.go:81

MethodSetSize

SetSize Set page size

pkg/utils/pagination.go:66

FunctionStartGrpcServerTracerSpan

(ctx context.Context, operationName string)

pkg/tracing/utils.go:39

FunctionStartKafkaConsumerTracerSpan

(ctx context.Context, headers []kafka.Header, operationName string)

pkg/tracing/utils.go:55

MethodStatus

Status Error status

pkg/http_errors/http_errors.go:65

MethodString

()

pkg/utils/pagination.go:22

FunctionTestConsumer_ConsumeIndexDeliveries

(t *testing.T)

internal/product/delivery/rabbitmq/consumer_test.go:17

FunctionTestIndexAsync

(t *testing.T)

internal/product/delivery/http/v1/controller_test.go:16

FunctionTestIndexProduct

(t *testing.T)

internal/product/delivery/http/v1/controller_test.go:58

FunctionTraceErr

(span opentracing.Span, err error)

pkg/tracing/utils.go:188

MethodWarn

Warn uses fmt.Sprint to construct and log a message.

pkg/logger/logger.go:210

MethodWarnErrMsg

(msg string, err error)

pkg/logger/logger.go:29

MethodWarnErrMsg

WarnErrMsg log error message with warn level.

pkg/logger/logger.go:215

MethodWarnf

Warnf uses fmt.Sprintf to log a templated message.

pkg/logger/logger.go:220

MethodindexProduct

(ctx context.Context, msg amqp.Delivery)

internal/product/delivery/rabbitmq/consumer.go:74

← previous101–197 of 197, ranked by callers