diff --git a/pkg/config/resolver_test.go b/pkg/config/resolver_test.go index 073fd663..6a7f0b31 100644 --- a/pkg/config/resolver_test.go +++ b/pkg/config/resolver_test.go @@ -108,7 +108,7 @@ var testConfig = &config.Config{ Channels: []config.Kinesis{{}}, }, GCS: config.GCS{ - Credentials: "Credentials", + Credentials: `{"token": "token", "type": "authorized_user"}`, Bucket: "test", SkipExisting: true, MinimumPriority: "debug", @@ -135,7 +135,7 @@ func Test_ResolveTargets(t *testing.T) { resolver := config.NewResolver(testConfig, &rest.Config{}) if count := len(resolver.TargetClients()); count != 19 { - t.Errorf("Expected 17 Clients, got %d", count) + t.Errorf("Expected 19 Clients, got %d", count) } } diff --git a/pkg/config/target_factory_test.go b/pkg/config/target_factory_test.go index 1c49169e..99c06397 100644 --- a/pkg/config/target_factory_test.go +++ b/pkg/config/target_factory_test.go @@ -31,7 +31,7 @@ func newFakeClient() v1.SecretInterface { "secretAccessKey": []byte("secretAccessKey"), "kmsKeyId": []byte("kmsKeyId"), "token": []byte("token"), - "credentials": []byte("credentials"), + "credentials": []byte(`{"token": "token", "type": "authorized_user"}`), }, }).CoreV1().Secrets("default") } @@ -197,7 +197,7 @@ func Test_ResolveTargetWithoutHost(t *testing.T) { }) t.Run("Kinesis.StreamName", func(t *testing.T) { if len(factory.KinesisClients(config.Kinesis{Endpoint: "https://yds.serverless.yandexcloud.net", AccessKeyID: "access", SecretAccessKey: "secret", Region: "ru-central1"})) != 0 { - t.Error("Expected Client to be nil if no bucket is configured") + t.Error("Expected Client to be nil if no stream name is configured") } }) t.Run("GCS.Bucket", func(t *testing.T) {