config

Documentation

Index

• func GetGrpcDialAddr(adapterConfig *model.InvocationConfig) string
• func GetGrpcServerAddr() string
• func GetKafkaBrokerAddr() string
• func GetMongoConnectionUri(adapterConfig *model.RepositoryClientConfig) string
• func GetOtelCollectorUrl() string
• func GetRedisConnectionAddr(adapterConfig *model.RepositoryClientConfig) string
• func GetRestServerAddr() string
• func NewConfigLoader(format string) ports.ConfigLoader
• type EnvVars
  • func FromClusterConfig(config model.ClusterConfig) *EnvVars
  • func GetEnvs() *EnvVars
  • func (e EnvVars) AsK8sEnvVars() []corev1.EnvVar

Functions

func GetGrpcDialAddr

func GetGrpcDialAddr(adapterConfig *model.InvocationConfig) string

func GetGrpcServerAddr

func GetGrpcServerAddr() string

func GetKafkaBrokerAddr

func GetKafkaBrokerAddr() string

func GetMongoConnectionUri

func GetMongoConnectionUri(adapterConfig *model.RepositoryClientConfig) string

func GetOtelCollectorUrl

func GetOtelCollectorUrl() string

func GetRedisConnectionAddr

func GetRedisConnectionAddr(adapterConfig *model.RepositoryClientConfig) string

func GetRestServerAddr

func GetRestServerAddr() string

func NewConfigLoader

func NewConfigLoader(format string) ports.ConfigLoader

Types

type EnvVars

type EnvVars struct {
	LOG_LEVEL                string
	TRACING                  bool
	HTTP_PORT                string
	GRPC_PORT                string
	KAFKA_PORT               string
	KAFKA_CLUSTER_NAME       string
	KAFKA_CLUSTER_NAMESPACE  string
	MONGO_USER               string
	MONGO_PASSWORD           string
	MONGO_PORT               string
	REDIS_PORT               string
	OTEL_COLLECTOR_NAME      string
	OTEL_COLLECTOR_NAMESPACE string
	OTEL_COLLECTOR_PORT      string
	METRICS_PORT             string
	HEALTH_PORT              string
}

func FromClusterConfig

func FromClusterConfig(config model.ClusterConfig) *EnvVars

func GetEnvs

func GetEnvs() *EnvVars

func (EnvVars) AsK8sEnvVars

func (e EnvVars) AsK8sEnvVars() []corev1.EnvVar