diff options
| author | chrislu <chris.lu@gmail.com> | 2022-05-11 00:52:15 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-05-11 00:52:15 -0700 |
| commit | bff1ccc1debf256912d747ab8ca127799d5a28dd (patch) | |
| tree | d6534346362a268c36fd51c0a05c9d6d5bec71d5 | |
| parent | 76da688176f401c0feac4fa8a7b20371d8549682 (diff) | |
| download | seaweedfs-bff1ccc1debf256912d747ab8ca127799d5a28dd.tar.xz seaweedfs-bff1ccc1debf256912d747ab8ca127799d5a28dd.zip | |
fix compilation
| -rw-r--r-- | weed/remote_storage/azure/azure_highlevel.go | 4 | ||||
| -rw-r--r-- | weed/replication/sink/azuresink/azure_sink.go | 2 |
2 files changed, 3 insertions, 3 deletions
diff --git a/weed/remote_storage/azure/azure_highlevel.go b/weed/remote_storage/azure/azure_highlevel.go index 9b735c2cb..a5cd4070b 100644 --- a/weed/remote_storage/azure/azure_highlevel.go +++ b/weed/remote_storage/azure/azure_highlevel.go @@ -41,7 +41,7 @@ func uploadReaderAtToBlockBlob(ctx context.Context, reader io.ReaderAt, readerSi if o.Progress != nil { body = pipeline.NewRequestBodyProgress(body, o.Progress) } - return blockBlobURL.Upload(ctx, body, o.BlobHTTPHeaders, o.Metadata, o.AccessConditions, o.BlobAccessTier, o.BlobTagsMap, o.ClientProvidedKeyOptions) + return blockBlobURL.Upload(ctx, body, o.BlobHTTPHeaders, o.Metadata, o.AccessConditions, o.BlobAccessTier, o.BlobTagsMap, o.ClientProvidedKeyOptions, o.ImmutabilityPolicyOptions) } var numBlocks = uint16(((readerSize - 1) / o.BlockSize) + 1) @@ -85,7 +85,7 @@ func uploadReaderAtToBlockBlob(ctx context.Context, reader io.ReaderAt, readerSi return nil, err } // All put blocks were successful, call Put Block List to finalize the blob - return blockBlobURL.CommitBlockList(ctx, blockIDList, o.BlobHTTPHeaders, o.Metadata, o.AccessConditions, o.BlobAccessTier, o.BlobTagsMap, o.ClientProvidedKeyOptions) + return blockBlobURL.CommitBlockList(ctx, blockIDList, o.BlobHTTPHeaders, o.Metadata, o.AccessConditions, o.BlobAccessTier, o.BlobTagsMap, o.ClientProvidedKeyOptions, o.ImmutabilityPolicyOptions) } // The UUID reserved variants. diff --git a/weed/replication/sink/azuresink/azure_sink.go b/weed/replication/sink/azuresink/azure_sink.go index 3b944e5b7..3097ef439 100644 --- a/weed/replication/sink/azuresink/azure_sink.go +++ b/weed/replication/sink/azuresink/azure_sink.go @@ -109,7 +109,7 @@ func (g *AzureSink) CreateEntry(key string, entry *filer_pb.Entry, signatures [] // Azure Storage account's container. appendBlobURL := g.containerURL.NewAppendBlobURL(key) - _, err := appendBlobURL.Create(context.Background(), azblob.BlobHTTPHeaders{}, azblob.Metadata{}, azblob.BlobAccessConditions{}, azblob.BlobTagsMap{}, azblob.ClientProvidedKeyOptions{}) + _, err := appendBlobURL.Create(context.Background(), azblob.BlobHTTPHeaders{}, azblob.Metadata{}, azblob.BlobAccessConditions{}, azblob.BlobTagsMap{}, azblob.ClientProvidedKeyOptions{}, azblob.ImmutabilityPolicyOptions{}) if err != nil { return err } |