mirror of
https://github.com/hanzoai/o11y-foundry.git
synced 2026-11-03 02:08:34 +00:00
NageshbansalandGitHub
8d19509e81
#### Fixes
- Render templated per-node macros (`shard`, `replica`) in ClickHouse
`config.yaml` so multi-shard/multi-replica clusters get unique Keeper
paths instead of collisions
- Use the first TelemetryStore TCP address (not comma-joined) for
`SIGNOZ_TELEMETRYSTORE_CLICKHOUSE_DSN` and ingester ClickHouse DSNs
#### Refactors
- `telemetrystore` molding now emits `config-{shard}-{replica}.yaml` per
node (mirrors `telemetrykeeper` per-replica pattern)
Related: https://github.com/SigNoz/platform-pod/issues/1332
82 lines
2.8 KiB
Go
82 lines
2.8 KiB
Go
package signozmolding
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"log/slog"
|
|
"strings"
|
|
|
|
"github.com/signoz/foundry/api/v1alpha1"
|
|
"github.com/signoz/foundry/api/v1alpha1/installation"
|
|
"github.com/signoz/foundry/internal/domain"
|
|
"github.com/signoz/foundry/internal/errors"
|
|
"github.com/signoz/foundry/internal/molding"
|
|
)
|
|
|
|
var _ molding.Molding = (*signoz)(nil)
|
|
|
|
type signoz struct {
|
|
logger *slog.Logger
|
|
}
|
|
|
|
func New(logger *slog.Logger) *signoz {
|
|
return &signoz{
|
|
logger: logger,
|
|
}
|
|
}
|
|
|
|
func (molding *signoz) Kind() v1alpha1.MoldingKind {
|
|
return v1alpha1.MoldingKindSignoz
|
|
}
|
|
|
|
func (molding *signoz) MoldV1Alpha1(ctx context.Context, config *installation.Casting) error {
|
|
if config.Spec.Signoz.Status.Env == nil {
|
|
config.Spec.Signoz.Status.Env = make(map[string]string)
|
|
}
|
|
|
|
if config.Spec.Signoz.Spec.Env == nil {
|
|
config.Spec.Signoz.Spec.Env = make(map[string]string)
|
|
}
|
|
|
|
// Add telemetry store addresses
|
|
config.Spec.Signoz.Status.Env["SIGNOZ_TELEMETRYSTORE_PROVIDER"] = config.Spec.TelemetryStore.Kind.String()
|
|
|
|
if val, ok := config.Spec.Signoz.Spec.Env["SIGNOZ_TELEMETRYSTORE_CLICKHOUSE_DSN"]; ok {
|
|
molding.logger.WarnContext(ctx, "SIGNOZ_TELEMETRYSTORE_CLICKHOUSE_DSN is going to be overridden", slog.String("value", val))
|
|
}
|
|
|
|
if len(config.Spec.TelemetryStore.Status.Addresses.TCP) == 0 {
|
|
return errors.Newf(errors.TypeInternal, "telemetry store address is not set")
|
|
}
|
|
config.Spec.Signoz.Status.Env["SIGNOZ_TELEMETRYSTORE_CLICKHOUSE_DSN"] = config.Spec.TelemetryStore.Status.Addresses.TCP[0]
|
|
|
|
// Add metastore addresses
|
|
config.Spec.Signoz.Status.Env["SIGNOZ_SQLSTORE_PROVIDER"] = config.Spec.MetaStore.Kind.String()
|
|
|
|
switch config.Spec.MetaStore.Kind {
|
|
case installation.MetaStoreKindSQLite:
|
|
config.Spec.Signoz.Status.Env["SIGNOZ_SQLSTORE_SQLITE_PATH"] = "/var/lib/signoz/signoz.db"
|
|
case installation.MetaStoreKindPostgres:
|
|
if config.Spec.MetaStore.Status.Addresses.DSN != nil {
|
|
if val, ok := config.Spec.Signoz.Spec.Env["SIGNOZ_SQLSTORE_POSTGRES_DSN"]; ok {
|
|
molding.logger.WarnContext(ctx, "SIGNOZ_SQLSTORE_POSTGRES_DSN is going to be overridden", slog.String("value", val))
|
|
}
|
|
// construct postgres dsn with user, password, host, port, and db
|
|
addrs, err := domain.ParseAddresses(config.Spec.MetaStore.Status.Addresses.DSN)
|
|
if err != nil {
|
|
return errors.Wrapf(err, errors.TypeInternal, "failed to parse addresses")
|
|
}
|
|
var dsns []string
|
|
user := config.Spec.MetaStore.Status.Env["POSTGRES_USER"]
|
|
password := config.Spec.MetaStore.Status.Env["POSTGRES_PASSWORD"]
|
|
db := config.Spec.MetaStore.Status.Env["POSTGRES_DB"]
|
|
for _, addr := range addrs {
|
|
dsn := fmt.Sprintf("postgres://%s:%s@%s:%d/%s?sslmode=disable", user, password, addr.Host(), addr.Port(), db)
|
|
dsns = append(dsns, dsn)
|
|
}
|
|
config.Spec.Signoz.Status.Env["SIGNOZ_SQLSTORE_POSTGRES_DSN"] = strings.Join(dsns, ",")
|
|
}
|
|
}
|
|
return nil
|
|
}
|