Quick reference

kazmaps.user.account         # Event-Type: account.registered/banned/...
kazmaps.user.push_token
kazmaps.review.review        # Event-Type: review.created/updated/deleted/replied
kazmaps.media.photo          # Event-Type: photo.uploaded/deleted/tagged
kazmaps.catalog.place
kazmaps.indoor.building

notification-on-review-created
notification-on-user-banned
review-on-moderation-approved
search-index-on-review-updated

http_request_duration_seconds         # histogram, стандарт
http_requests_total                   # counter, стандарт
user_registrations_total              # counter, бизнес-событие
kafka_consumer_lag                    # gauge, current - committed
outbox_forwarder_lag_seconds          # histogram
outbox_unpublished_rows               # gauge
circuit_breaker_state                 # gauge: 0/1/2 (Closed/HalfOpen/Open)
circuit_breaker_trips_total           # counter
events_published_total                # counter
events_consumed_total                 # counter
messages_poisoned_total               # counter (DLQ)

REVIEW_HTTP_ADDR=:8007
REVIEW_DB_DSN=postgres://...
REVIEW_DB_POOL_MIN=2
REVIEW_DB_POOL_MAX=20
REVIEW_REDIS_ADDR=redis:6379
REVIEW_KAFKA_BROKERS=kafka:9092
REVIEW_INTERNAL_API_TOKEN=...
REVIEW_GATEWAY_HMAC_KEY=...
REVIEW_LOG_LEVEL=info
REVIEW_OTEL_EXPORTER_OTLP_ENDPOINT=tempo:4317

err := pool.QueryRow(ctx, q, id).Scan(&u.ID, &u.Email)
if err != nil {
    if pkgdb.IsNoRows(err) { return nil, pkgdb.ErrNotFound }
    return nil, fmt.Errorf("get user: %w", err)
}

rows, err := pool.Query(ctx, q, placeID)
if err != nil { return nil, fmt.Errorf("query: %w", err) }
defer rows.Close()
 
for rows.Next() {
    var r domain.Review
    if err := rows.Scan(&r.ID, &r.Rating, &r.Text); err != nil {
        return nil, fmt.Errorf("scan: %w", err)
    }
    out = append(out, r)
}
return out, rows.Err()

batch := &pgx.Batch{}
for _, id := range ids {
    batch.Queue(`UPDATE ... WHERE id = $1`, id)
}
br := pool.SendBatch(ctx, batch)
defer br.Close()
for range ids {
    if _, err := br.Exec(); err != nil { return err }
}

err := s.db.InTx(ctx, func(tx pgx.Tx) error {
    if err := s.repo.CreateTx(ctx, tx, ...); err != nil { return err }
    return s.outboxPub.PublishTx(ctx, tx, "outbox", msg)
})

cmd/server/main.go          — wiring всех зависимостей
internal/
├── config/                 — envconfig, DSN сборка
├── handler/                — HTTP-handler'ы + router.go
├── middleware/             — gatewayAuth, internalToken, rateLimit
├── service/                — бизнес-логика, sentinel ошибки
├── repository/postgres/    — pgx-репозитории (голый SQL)
├── event/                  — publisher, subscriber, handlers
├── domain/                 — типы предметной области
├── log/                    — slog-wrapper, FromCtx, PII-маскер
├── metrics/                — prometheus registry, MustRegister()
├── otel/                   — setup tracer provider
└── health/                 — /healthz, /readyz handler'ы
pkg/
├── db/                     — pgxpool wrapper, InTx, ErrNotFound
├── httpclient/             — RetryClient, CircuitBreaker
├── eventmeta/              — envelope-builder, helper New()
└── pii/                    — маскирование email/phone для логов
migrations/                 — golang-migrate up/down