@@ -285,7 +285,7 @@ func (m *PodMutator) buildSources(ctx context.Context, flagSourceConfig *v1alpha
285285 case source .Provider .IsGrpc ():
286286 sourceCfg = m .toGrpcProviderConfig (source )
287287 case source .Provider .IsFlagdProxy ():
288- sourceCfg , err = m .handleFlagdProxy (ctx , pod , source )
288+ sourceCfg , err = m .toFlagdProxyConfig (ctx , pod , source )
289289 if err != nil {
290290 return []types.SourceConfig {}, err
291291 }
@@ -427,7 +427,7 @@ func (m *PodMutator) isFlagdProxyReady(ctx context.Context) (bool, bool, error)
427427 return true , true , nil
428428}
429429
430- func (m * PodMutator ) handleFlagdProxy (ctx context.Context , pod * corev1.Pod , source v1alpha1.Source ) (types.SourceConfig , error ) {
430+ func (m * PodMutator ) toFlagdProxyConfig (ctx context.Context , pod * corev1.Pod , source v1alpha1.Source ) (types.SourceConfig , error ) {
431431 // does the proxy exist
432432 exists , ready , err := m .isFlagdProxyReady (ctx )
433433 if err != nil {
@@ -440,7 +440,7 @@ func (m *PodMutator) handleFlagdProxy(ctx context.Context, pod *corev1.Pod, sour
440440 return types.SourceConfig {
441441 Provider : "grpc" ,
442442 Selector : fmt .Sprintf ("core.openfeature.dev/%s/%s" , ns , n ),
443- URI : fmt .Sprintf ("grpc:// %s.%s.svc.cluster.local:%d" , controllers .FlagdProxyServiceName , m .FlagdProxyConfig .Namespace , m .FlagdProxyConfig .Port ),
443+ URI : fmt .Sprintf ("%s.%s.svc.cluster.local:%d" , controllers .FlagdProxyServiceName , m .FlagdProxyConfig .Namespace , m .FlagdProxyConfig .Port ),
444444 }, nil
445445}
446446
0 commit comments