opensource/supermq
1
0
Fork 0
mirror of https://github.com/absmach/supermq.git synced 2026-06-23 07:10:19 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

MG-597- Add writers integrations (#104)

Browse Source 
* add gopher-lua-libs library

Signed-off-by: ianmuchyri <ianmuchiri8@gmail.com>

* update postgres writer

Signed-off-by: ianmuchyri <ianmuchiri8@gmail.com>

---------

Signed-off-by: ianmuchyri <ianmuchiri8@gmail.com>
This commit is contained in:
Ian Ngethe Muchiri
2025-04-04 11:41:49 +03:00
committed by GitHub
parent d1e855ccd4
commit 3a892108e1
7 changed files with 168 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cmd/postgres-writer/main.go
+5 -5
View File
@@ -34,19 +34,19 @@ import (
const (
svcName = "postgres-writer"
envPrefixDB = "SMQ_POSTGRES_"
envPrefixHTTP = "SMQ_POSTGRES_WRITER_HTTP_"
envPrefixDB = "MG_POSTGRES_"
envPrefixHTTP = "MG_POSTGRES_WRITER_HTTP_"
defDB = "messages"
defSvcHTTPPort = "9010"
)
type config struct {
LogLevel string `env:"SMQ_POSTGRES_WRITER_LOG_LEVEL" envDefault:"info"`
ConfigPath string `env:"SMQ_POSTGRES_WRITER_CONFIG_PATH" envDefault:"/config.toml"`
LogLevel string `env:"MG_POSTGRES_WRITER_LOG_LEVEL" envDefault:"info"`
ConfigPath string `env:"MG_POSTGRES_WRITER_CONFIG_PATH" envDefault:"/config.toml"`
BrokerURL string `env:"SMQ_MESSAGE_BROKER_URL" envDefault:"nats://localhost:4222"`
JaegerURL url.URL `env:"SMQ_JAEGER_URL" envDefault:"http://localhost:4318/v1/traces"`
SendTelemetry bool `env:"SMQ_SEND_TELEMETRY" envDefault:"true"`
InstanceID string `env:"SMQ_POSTGRES_WRITER_INSTANCE_ID" envDefault:""`
InstanceID string `env:"MG_POSTGRES_WRITER_INSTANCE_ID" envDefault:""`
TraceRatio float64 `env:"SMQ_JAEGER_TRACE_RATIO" envDefault:"1.0"`
}