From 6059738f643cfe9eb06f5855fa09b679c6be7e88 Mon Sep 17 00:00:00 2001 From: Jaganathan P <156800415+jagan2221@users.noreply.github.com> Date: Mon, 2 Dec 2024 12:00:14 +0530 Subject: [PATCH] Update provider_test.go --- pkg/configprovider/globprovider/provider_test.go | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/pkg/configprovider/globprovider/provider_test.go b/pkg/configprovider/globprovider/provider_test.go index ae5c2b9a70..76065b2f20 100644 --- a/pkg/configprovider/globprovider/provider_test.go +++ b/pkg/configprovider/globprovider/provider_test.go @@ -162,7 +162,9 @@ func ValidateProviderScheme(p confmap.Provider) error { func TestRemotelyManagedMergeFlow(t *testing.T) { fp := NewWithSettings(confmap.ProviderSettings{}) - fp.SetRemotelyManagedMergeFlow(true) + if globProvider, ok := fp.(*globprovider.Provider); ok { + globProvider.SetRemotelyManagedMergeFlow(true) + } ret, err := fp.Retrieve(context.Background(), schemePrefix+filepath.Join("testdata", "mergefunc", "*.yaml"), nil) require.NoError(t, err) retMap, err := ret.AsConf() @@ -176,7 +178,7 @@ func TestRemotelyManagedMergeFlow(t *testing.T) { }, }, }, - processor: "someprocessor", + "processor": "someprocessor", }) assert.Equal(t, expectedMap, retMap) assert.NoError(t, fp.Shutdown(context.Background())) @@ -184,6 +186,7 @@ func TestRemotelyManagedMergeFlow(t *testing.T) { func TestLocallyManagedMergeFlow(t *testing.T) { fp := NewWithSettings(confmap.ProviderSettings{}) + ret, err := fp.Retrieve(context.Background(), schemePrefix+filepath.Join("testdata", "mergefunc", "*.yaml"), nil) require.NoError(t, err) retMap, err := ret.AsConf() @@ -198,7 +201,7 @@ func TestLocallyManagedMergeFlow(t *testing.T) { }, }, }, - processor: "someprocessor", + "processor": "someprocessor", }) assert.Equal(t, expectedMap, retMap) assert.NoError(t, fp.Shutdown(context.Background()))