From 420d2ca0c46a83af1f7e6bd595055ead2664f992 Mon Sep 17 00:00:00 2001 From: TiganeteaRobert Date: Mon, 29 Aug 2022 11:17:56 +0300 Subject: [PATCH] trying to fix unit test --- pkg/target/kinesis_test.go | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/pkg/target/kinesis_test.go b/pkg/target/kinesis_test.go index e7bfff01..78a45c03 100644 --- a/pkg/target/kinesis_test.go +++ b/pkg/target/kinesis_test.go @@ -8,6 +8,10 @@ package target import ( "fmt" + "github.com/aws/aws-sdk-go/aws" + "github.com/aws/aws-sdk-go/aws/credentials" + "github.com/aws/aws-sdk-go/aws/session" + "github.com/aws/aws-sdk-go/service/kinesis" "strings" "sync/atomic" "testing" @@ -37,7 +41,12 @@ func TestKinesisTarget_KinesisConnectionFailure(t *testing.T) { assert := assert.New(t) - client := testutil.GetAWSLocalstackKinesisClient() + client := kinesis.New(session.Must(session.NewSession(&aws.Config{ + Credentials: credentials.NewStaticCredentials("foo", "var", ""), + S3ForcePathStyle: aws.Bool(true), + Region: aws.String(`wrong-region`), + Endpoint: aws.String(`wrong-endpoint`), + }))) target, err := newKinesisTargetWithInterfaces(client, "00000000000", testutil.AWSLocalstackRegion, "not-exists") assert.NotNil(err)