alternative entity delimiter

centrifugal · Nov 4, 2024 · 410332b · 410332b
1 parent cb1d8b2
commit 410332b
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/internal/consuming/kafka.go b/internal/consuming/kafka.go
@@ -119,7 +119,7 @@ func (c *KafkaConsumer) initClient() (*kgo.Client, error) {
 		kgo.InstanceID(c.getInstanceID()),
 	}
 	if c.config.TLS.Enabled {
-		tlsConfig, err := c.config.TLS.ToGoTLSConfig("kafka_" + c.name)
+		tlsConfig, err := c.config.TLS.ToGoTLSConfig("kafka:" + c.name)
 		if err != nil {
 			return nil, fmt.Errorf("error making TLS configuration: %w", err)
 		}

diff --git a/internal/consuming/postgresql.go b/internal/consuming/postgresql.go
@@ -42,7 +42,7 @@ func NewPostgresConsumer(name string, logger Logger, dispatcher Dispatcher, conf
 		return nil, fmt.Errorf("error parsing postgresql DSN: %w", err)
 	}
 	if config.TLS.Enabled {
-		tlsConfig, err := config.TLS.ToGoTLSConfig("postgresql_" + name)
+		tlsConfig, err := config.TLS.ToGoTLSConfig("postgresql:" + name)
 		if err != nil {
 			return nil, fmt.Errorf("error creating postgresql TLS config: %w", err)
 		}

diff --git a/internal/proxy/grpc.go b/internal/proxy/grpc.go
@@ -58,7 +58,7 @@ func getDialOpts(p Config) ([]grpc.DialOption, error) {
 		}))
 	}
 	if p.GRPC.TLS.Enabled {
-		tlsConfig, err := p.GRPC.TLS.ToGoTLSConfig("proxy_grpc_" + p.Name)
+		tlsConfig, err := p.GRPC.TLS.ToGoTLSConfig("proxy_grpc:" + p.Name)
 		if err != nil {
 			return nil, fmt.Errorf("failed to create TLS config %v", err)
 		}