diff --git a/main.go b/main.go index ac9e396..d9005a1 100644 --- a/main.go +++ b/main.go @@ -55,8 +55,16 @@ func main() { env.String("AUTHN_KUBECONFIG_CLUSTER_NAME", "krateo"), "cluster name for generated kubeconfig") kubernetesURL := flag.String("kubeconfig-server-url", env.String("AUTHN_KUBECONFIG_SERVER_URL", ""), "kubernetes api server url for generated kubeconfig") - snowplowURL := flag.String("snowplow-url", - env.String("URL_SNOWPLOW", "http://snowplow.krateo-system.svc.cluster.local:8081"), "snowplow url for restaction api calls") + snowplowHOST := flag.String("snowplow-host", + env.String("SNOWPLOW_SERVICE_HOST", ""), "snowplow host for restaction api calls") + snowplowPORT := flag.String("snowplow-post", + env.String("SNOWPLOW_SERVICE_PORT", "8081"), "snowplow port for restaction api calls") + var snowplowURL *string + temp := "http://" + *snowplowHOST + ":" + *snowplowPORT + snowplowURL = &temp + if *snowplowURL == "http://:8081" { + snowplowURL = flag.String("snowplow-url", env.String("URL_SNOWPLOW", "http://snowplow.krateo-system.svc.cluster.local:8081"), "snowplow url for restaction api calls") + } storageNamespace := flag.String("namespace", env.String("AUTHN_NAMESPACE", ""), "namespace where to store secrets with generated config") authnUsername := flag.String("authn-username", @@ -106,6 +114,9 @@ func main() { evt.Msg("configuration and env vars info") } + log.Debug().Msgf("Snowplow URL from Service ENV: %s", temp) + log.Debug().Msgf("Snowplow URL computed/from parameter: %s", *snowplowURL) + // Kubernetes configuration var cfg *rest.Config var err error