Для добавления в систему хранилища всех событий со всего проекта с целью аналитики и агрегации можно реализовать централизованный event bus или использовать готовые решения, например, Kafka, RabbitMQ или Google Pub/Sub. В Go можно создать слой, который будет публиковать события в этот брокер.

Основные шаги:

Определить формат событий (например, JSON с полями: тип события, время, данные).
В местах генерации событий публиковать их в очередь или топик.
Создать отдельный сервис или компонент, который будет подписываться на эти события и сохранять их в хранилище (например, ClickHouse, Elasticsearch, TimescaleDB).

Пример публикации события в Kafka на Go:

import (
    "github.com/segmentio/kafka-go"
    "context"
    "encoding/json"
    "time"
)

type Event struct {
    Type string `json:"type"`
    Timestamp time.Time `json:"timestamp"`
    Payload interface{} `json:"payload"`
}

func publishEvent(writer *kafka.Writer, event Event) error {
    data, err := json.Marshal(event)
    if err != nil {
        return err
    }
    return writer.WriteMessages(context.Background(),
        kafka.Message{
            Key:   []byte(event.Type),
            Value: data,
        },
    )
}

Таким образом, вы централизуете сбор событий, что упрощает последующую аналитику и агрегацию.

Как добавить в систему хранилище всех событий со всего проекта для аналитики и агрегации?