@@ -35,7 +35,7 @@ func newS3(client sdkclient.S3, bucket string) *S3 {
3535 return & S3 {client : client , bucket : bucket }
3636}
3737
38- func (s * S3 ) Store (ctx context.Context , storedBatch Batch ) error {
38+ func (s * S3 ) Store (ctx context.Context , batch Batch ) error {
3939 invocationID := "unknown"
4040 if lc , ok := lambdacontext .FromContext (ctx ); ok {
4141 invocationID = lc .AwsRequestID
@@ -47,8 +47,8 @@ func (s *S3) Store(ctx context.Context, storedBatch Batch) error {
4747 _ , err := s .client .PutObject (ctx , & s3.PutObjectInput {
4848 Bucket : aws .String (s .bucket ),
4949 Key : aws .String (key ),
50- Body : bytes .NewReader (storedBatch .Data ),
51- Metadata : map [string ]string {metadataStorageTagKey : storedBatch .StorageTag },
50+ Body : bytes .NewReader (batch .Data ),
51+ Metadata : map [string ]string {metadataStorageTagKey : batch .StorageTag },
5252 })
5353 if err != nil {
5454 return err
@@ -110,10 +110,10 @@ func (s *S3) getBatch(ctx context.Context, object types.Object) (Batch, error) {
110110 }, nil
111111}
112112
113- func (s * S3 ) Delete (ctx context.Context , sentBatch Batch ) error {
113+ func (s * S3 ) Delete (ctx context.Context , batch Batch ) error {
114114 _ , err := s .client .DeleteObject (ctx , & s3.DeleteObjectInput {
115115 Bucket : aws .String (s .bucket ),
116- Key : aws .String (sentBatch .DeleteKey ),
116+ Key : aws .String (batch .DeleteKey ),
117117 })
118118 if err != nil {
119119 return err
0 commit comments