datalake_lease_client.hpp

// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.
 
#pragma once
 
#include "azure/storage/files/datalake/datalake_file_system_client.hpp"
#include "azure/storage/files/datalake/datalake_path_client.hpp"
 
#include <azure/storage/blobs/blob_lease_client.hpp>
 
#include <chrono>
 
namespace Azure { namespace Storage { namespace Files { namespace DataLake {
 
  class DataLakeLeaseClient final {
  public:
    explicit DataLakeLeaseClient(DataLakePathClient pathClient, std::string leaseId)
        : m_blobLeaseClient(std::move(pathClient.m_blobClient), std::move(leaseId))
    {
    }
 
    explicit DataLakeLeaseClient(DataLakeFileSystemClient fileSystemClient, std::string leaseId)
        : m_blobLeaseClient(std::move(fileSystemClient.m_blobContainerClient), std::move(leaseId))
    {
    }
 
    static std::string CreateUniqueLeaseId()
    {
      return Blobs::BlobLeaseClient::CreateUniqueLeaseId();
    };
 
    AZ_STORAGE_FILES_DATALAKE_DLLEXPORT const static std::chrono::seconds InfiniteLeaseDuration;
 
    std::string GetLeaseId() { return m_blobLeaseClient.GetLeaseId(); }
 
    Azure::Response<Models::AcquireLeaseResult> Acquire(
        std::chrono::seconds duration,
        const AcquireLeaseOptions& options = AcquireLeaseOptions(),
        const Azure::Core::Context& context = Azure::Core::Context())
    {
      return m_blobLeaseClient.Acquire(duration, options, context);
    }
 
    Azure::Response<Models::RenewLeaseResult> Renew(
        const RenewLeaseOptions& options = RenewLeaseOptions(),
        const Azure::Core::Context& context = Azure::Core::Context())
    {
      return m_blobLeaseClient.Renew(options, context);
    }
 
    Azure::Response<Models::ReleaseLeaseResult> Release(
        const ReleaseLeaseOptions& options = ReleaseLeaseOptions(),
        const Azure::Core::Context& context = Azure::Core::Context())
    {
      return m_blobLeaseClient.Release(options, context);
    }
 
    Azure::Response<Models::ChangeLeaseResult> Change(
        const std::string& proposedLeaseId,
        const ChangeLeaseOptions& options = ChangeLeaseOptions(),
        const Azure::Core::Context& context = Azure::Core::Context())
    {
      return m_blobLeaseClient.Change(proposedLeaseId, options, context);
    }
 
    Azure::Response<Models::BreakLeaseResult> Break(
        const BreakLeaseOptions& options = BreakLeaseOptions(),
        const Azure::Core::Context& context = Azure::Core::Context())
    {
      return m_blobLeaseClient.Break(options, context);
    }
 
  private:
    Blobs::BlobLeaseClient m_blobLeaseClient;
  };
 
}}}} // namespace Azure::Storage::Files::DataLake