X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/63be17fdad6232fc9ff59738b6b358410953274c..1a9cc8246d8abc0c873fa2e9795a564f2fdb58af:/services/keepstore/s3aws_volume_test.go diff --git a/services/keepstore/s3aws_volume_test.go b/services/keepstore/s3aws_volume_test.go index 57d81dbe09..0387d52f18 100644 --- a/services/keepstore/s3aws_volume_test.go +++ b/services/keepstore/s3aws_volume_test.go @@ -41,9 +41,9 @@ type s3AWSFakeClock struct { func (c *s3AWSFakeClock) Now() time.Time { if c.now == nil { - return time.Now() + return time.Now().UTC() } - return *c.now + return c.now.UTC() } func (c *s3AWSFakeClock) Since(t time.Time) time.Duration { @@ -123,11 +123,11 @@ func (s *StubbedS3AWSSuite) TestSignature(c *check.C) { // as of June 24, 2020. Cf. https://forums.aws.amazon.com/ann.jspa?annID=5816 vol := S3AWSVolume{ S3VolumeDriverParameters: arvados.S3VolumeDriverParameters{ - AccessKey: "xxx", - SecretKey: "xxx", - Endpoint: stub.URL, - Region: "test-region-1", - Bucket: "test-bucket-name", + AccessKeyID: "xxx", + SecretAccessKey: "xxx", + Endpoint: stub.URL, + Region: "test-region-1", + Bucket: "test-bucket-name", }, cluster: s.cluster, logger: ctxlog.TestLogger(c), @@ -166,7 +166,9 @@ func (s *StubbedS3AWSSuite) TestIAMRoleCredentials(c *check.C) { metrics: newVolumeMetricsVecs(prometheus.NewRegistry()), } err := v.check(s.metadata.URL + "/latest") + c.Check(err, check.IsNil) creds, err := v.bucket.svc.Client.Config.Credentials.Retrieve(context.Background()) + c.Check(err, check.IsNil) c.Check(creds.AccessKeyID, check.Equals, "ASIAIOSFODNN7EXAMPLE") c.Check(creds.SecretAccessKey, check.Equals, "wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY") @@ -185,6 +187,7 @@ func (s *StubbedS3AWSSuite) TestIAMRoleCredentials(c *check.C) { metrics: newVolumeMetricsVecs(prometheus.NewRegistry()), } err = deadv.check(s.metadata.URL + "/latest") + c.Check(err, check.IsNil) _, err = deadv.bucket.svc.Client.Config.Credentials.Retrieve(context.Background()) c.Check(err, check.ErrorMatches, `(?s).*EC2RoleRequestError: no EC2 instance role found.*`) c.Check(err, check.ErrorMatches, `(?s).*404.*`) @@ -564,8 +567,8 @@ func (s *StubbedS3AWSSuite) newTestableVolume(c *check.C, cluster *arvados.Clust S3AWSVolume: &S3AWSVolume{ S3VolumeDriverParameters: arvados.S3VolumeDriverParameters{ IAMRole: iamRole, - AccessKey: accessKey, - SecretKey: secretKey, + AccessKeyID: accessKey, + SecretAccessKey: secretKey, Bucket: S3AWSTestBucketName, Endpoint: endpoint, Region: "test-region-1",