mirror of
https://github.com/hanzo-fi/stack.git
synced 2026-10-30 20:34:43 +00:00
46 lines
1.2 KiB
Go
46 lines
1.2 KiB
Go
package modules
|
|
|
|
import (
|
|
"strings"
|
|
|
|
"github.com/formancehq/operator/apis/stack/v1beta3"
|
|
)
|
|
|
|
func BrokerEnvVars(broker v1beta3.Broker, serviceName string) ContainerEnv {
|
|
return BrokerEnvVarsWithPrefix(broker, serviceName)
|
|
}
|
|
|
|
func BrokerEnvVarsWithPrefix(broker v1beta3.Broker, serviceName string) ContainerEnv {
|
|
ret := ContainerEnv{}
|
|
|
|
if broker.Kafka != nil {
|
|
ret = ret.Append(
|
|
Env("BROKER", "kafka"),
|
|
Env("PUBLISHER_KAFKA_ENABLED", "true"),
|
|
Env("PUBLISHER_KAFKA_BROKER", strings.Join(broker.Kafka.Brokers, " ")),
|
|
)
|
|
if broker.Kafka.SASL != nil {
|
|
ret = ret.Append(
|
|
Env("PUBLISHER_KAFKA_SASL_ENABLED", "true"),
|
|
Env("PUBLISHER_KAFKA_SASL_USERNAME", broker.Kafka.SASL.Username),
|
|
Env("PUBLISHER_KAFKA_SASL_PASSWORD", broker.Kafka.SASL.Password),
|
|
Env("PUBLISHER_KAFKA_SASL_MECHANISM", broker.Kafka.SASL.Mechanism),
|
|
Env("PUBLISHER_KAFKA_SASL_SCRAM_SHA_SIZE", broker.Kafka.SASL.ScramSHASize),
|
|
)
|
|
}
|
|
if broker.Kafka.TLS {
|
|
ret = ret.Append(
|
|
Env("PUBLISHER_KAFKA_TLS_ENABLED", "true"),
|
|
)
|
|
}
|
|
} else {
|
|
ret = ret.Append(
|
|
Env("BROKER", "nats"),
|
|
Env("PUBLISHER_NATS_ENABLED", "true"),
|
|
Env("PUBLISHER_NATS_URL", broker.Nats.URL),
|
|
Env("PUBLISHER_NATS_CLIENT_ID", serviceName),
|
|
)
|
|
}
|
|
return ret
|
|
}
|