dataflow_service.h

// Copyright 2010 Google Inc.
//
// Licensed under the Apache License, Version 2.0 (the "License"); you may not
// use this file except in compliance with the License. You may obtain a copy of
// the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
// WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
// License for the specific language governing permissions and limitations under
// the License.
//
//------------------------------------------------------------------------------
// This code was generated by google-apis-code-generator 1.5.1
//   Build date: 2018-10-08 17:45:39 UTC
//   on: 2020-03-19, 02:23:49 UTC
//   C++ generator version: 0.1.4
//
//  Changes to this file may cause incorrect behavior and will be lost if
//  the code is regenerated.
//------------------------------------------------------------------------------
#ifndef  GOOGLE_DATAFLOW_API_DATAFLOW_SERVICE_H_
#define  GOOGLE_DATAFLOW_API_DATAFLOW_SERVICE_H_

#include <string>
#include "googleapis/base/integral_types.h"
#include "googleapis/base/macros.h"
#include "googleapis/client/service/client_service.h"
#include "googleapis/client/service/service_request_pager.h"
#include "googleapis/client/util/status.h"
#include "googleapis/client/util/uri_template.h"

#include "google/dataflow_api/create_job_from_template_request.h"
#include "google/dataflow_api/delete_snapshot_response.h"
#include "google/dataflow_api/get_debug_config_request.h"
#include "google/dataflow_api/get_debug_config_response.h"
#include "google/dataflow_api/get_template_response.h"
#include "google/dataflow_api/job.h"
#include "google/dataflow_api/job_metrics.h"
#include "google/dataflow_api/launch_flex_template_request.h"
#include "google/dataflow_api/launch_flex_template_response.h"
#include "google/dataflow_api/launch_template_parameters.h"
#include "google/dataflow_api/launch_template_response.h"
#include "google/dataflow_api/lease_work_item_request.h"
#include "google/dataflow_api/lease_work_item_response.h"
#include "google/dataflow_api/list_job_messages_response.h"
#include "google/dataflow_api/list_jobs_response.h"
#include "google/dataflow_api/list_snapshots_response.h"
#include "google/dataflow_api/report_work_item_status_request.h"
#include "google/dataflow_api/report_work_item_status_response.h"
#include "google/dataflow_api/send_debug_capture_request.h"
#include "google/dataflow_api/send_debug_capture_response.h"
#include "google/dataflow_api/send_worker_messages_request.h"
#include "google/dataflow_api/send_worker_messages_response.h"
#include "google/dataflow_api/snapshot.h"
#include "google/dataflow_api/snapshot_job_request.h"
#include "google/dataflow_api/validate_response.h"


namespace google_dataflow_api {
using namespace googleapis;
class DataflowService;

class DataflowServiceBaseRequest
      : public client::ClientServiceRequest {
 public:
  DataflowServiceBaseRequest(
      const client::ClientService* service,
      client::AuthorizationCredential* credential,
      client::HttpRequest::HttpMethod method,
      const StringPiece& uri_template);

  virtual ~DataflowServiceBaseRequest();


  void clear_xgafv() {
    _have_xgafv_ = false;
    client::ClearCppValueHelper(&xgafv_);
  }


  const string& get_xgafv() const { return xgafv_; }

  string* mutable_$Xgafv() {
    _have_xgafv_ = true;
    return &xgafv_;
  }


  void set_xgafv(const string& value) {
    _have_xgafv_ = true;
    xgafv_ = value;
  }



  void clear_access_token() {
    _have_access_token_ = false;
    client::ClearCppValueHelper(&access_token_);
  }


  const string& get_access_token() const { return access_token_; }

  string* mutable_accessToken() {
    _have_access_token_ = true;
    return &access_token_;
  }


  void set_access_token(const string& value) {
    _have_access_token_ = true;
    access_token_ = value;
  }



  void clear_alt() {
    _have_alt_ = false;
    client::ClearCppValueHelper(&alt_);
  }


  const string& get_alt() const { return alt_; }

  string* mutable_alt() {
    _have_alt_ = true;
    return &alt_;
  }


  void set_alt(const string& value) {
    _have_alt_ = true;
    alt_ = value;
  }



  void clear_callback() {
    _have_callback_ = false;
    client::ClearCppValueHelper(&callback_);
  }


  const string& get_callback() const { return callback_; }

  string* mutable_callback() {
    _have_callback_ = true;
    return &callback_;
  }


  void set_callback(const string& value) {
    _have_callback_ = true;
    callback_ = value;
  }



  void clear_fields() {
    _have_fields_ = false;
    client::ClearCppValueHelper(&fields_);
  }


  const string& get_fields() const { return fields_; }

  string* mutable_fields() {
    _have_fields_ = true;
    return &fields_;
  }


  void set_fields(const string& value) {
    _have_fields_ = true;
    fields_ = value;
  }



  void clear_key() {
    _have_key_ = false;
    client::ClearCppValueHelper(&key_);
  }


  const string& get_key() const { return key_; }

  string* mutable_key() {
    _have_key_ = true;
    return &key_;
  }


  void set_key(const string& value) {
    _have_key_ = true;
    key_ = value;
  }



  void clear_oauth_token() {
    _have_oauth_token_ = false;
    client::ClearCppValueHelper(&oauth_token_);
  }


  const string& get_oauth_token() const { return oauth_token_; }

  string* mutable_oauthToken() {
    _have_oauth_token_ = true;
    return &oauth_token_;
  }


  void set_oauth_token(const string& value) {
    _have_oauth_token_ = true;
    oauth_token_ = value;
  }



  void clear_pretty_print() {
    _have_pretty_print_ = false;
    client::ClearCppValueHelper(&pretty_print_);
  }


  bool get_pretty_print() const { return pretty_print_; }

  void set_pretty_print(bool value) {
    _have_pretty_print_ = true;
    pretty_print_ = value;
  }

  void clear_quota_user() {
    _have_quota_user_ = false;
    client::ClearCppValueHelper(&quota_user_);
  }


  const string& get_quota_user() const { return quota_user_; }

  string* mutable_quotaUser() {
    _have_quota_user_ = true;
    return &quota_user_;
  }


  void set_quota_user(const string& value) {
    _have_quota_user_ = true;
    quota_user_ = value;
  }



  void clear_upload_type() {
    _have_upload_type_ = false;
    client::ClearCppValueHelper(&upload_type_);
  }


  const string& get_upload_type() const { return upload_type_; }

  string* mutable_uploadType() {
    _have_upload_type_ = true;
    return &upload_type_;
  }


  void set_upload_type(const string& value) {
    _have_upload_type_ = true;
    upload_type_ = value;
  }



  void clear_upload_protocol() {
    _have_upload_protocol_ = false;
    client::ClearCppValueHelper(&upload_protocol_);
  }


  const string& get_upload_protocol() const { return upload_protocol_; }

  string* mutable_uploadProtocol() {
    _have_upload_protocol_ = true;
    return &upload_protocol_;
  }


  void set_upload_protocol(const string& value) {
    _have_upload_protocol_ = true;
    upload_protocol_ = value;
  }

  virtual util::Status AppendVariable(
      const StringPiece& variable_name,
      const client::UriTemplateConfig& config,
      string* target);

  virtual util::Status AppendOptionalQueryParameters(string* target);


 protected:
  void AddJsonContentToRequest(const client::JsonCppData *content);

 private:
  string xgafv_;
  string access_token_;
  string alt_;
  string callback_;
  string fields_;
  string key_;
  string oauth_token_;
  bool pretty_print_;
  string quota_user_;
  string upload_type_;
  string upload_protocol_;
  bool _have_xgafv_ : 1;
  bool _have_access_token_ : 1;
  bool _have_alt_ : 1;
  bool _have_callback_ : 1;
  bool _have_fields_ : 1;
  bool _have_key_ : 1;
  bool _have_oauth_token_ : 1;
  bool _have_pretty_print_ : 1;
  bool _have_quota_user_ : 1;
  bool _have_upload_type_ : 1;
  bool _have_upload_protocol_ : 1;

  DISALLOW_COPY_AND_ASSIGN(DataflowServiceBaseRequest);
};



class ProjectsResource_DeleteSnapshotsMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_DeleteSnapshotsMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id);

  virtual ~ProjectsResource_DeleteSnapshotsMethod();


    void clear_snapshot_id() {
      _have_snapshot_id_ = false;
      client::ClearCppValueHelper(&snapshot_id_);
    }


    const string& get_snapshot_id() const { return snapshot_id_; }

    string* mutable_snapshotId() {
      _have_snapshot_id_ = true;
      return &snapshot_id_;
    }


    void set_snapshot_id(const string& value) {
      _have_snapshot_id_ = true;
      snapshot_id_ = value;
    }



    void clear_location() {
      _have_location_ = false;
      client::ClearCppValueHelper(&location_);
    }


    const string& get_location() const { return location_; }

    string* mutable_location() {
      _have_location_ = true;
      return &location_;
    }


    void set_location(const string& value) {
      _have_location_ = true;
      location_ = value;
    }

  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);

  virtual util::Status AppendOptionalQueryParameters(string* target);


  util::Status ExecuteAndParseResponse(
      DeleteSnapshotResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string snapshot_id_;
  string location_;
  bool _have_snapshot_id_ : 1;
  bool _have_location_ : 1;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_DeleteSnapshotsMethod);
};

class ProjectsResource_WorkerMessagesMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_WorkerMessagesMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const SendWorkerMessagesRequest& _content_);

  virtual ~ProjectsResource_WorkerMessagesMethod();


  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);


  util::Status ExecuteAndParseResponse(
      SendWorkerMessagesResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;  string _content_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_WorkerMessagesMethod);
};




class ProjectsResource_JobsResource_AggregatedMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_JobsResource_AggregatedMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id);

  virtual ~ProjectsResource_JobsResource_AggregatedMethod();


    void clear_filter() {
      _have_filter_ = false;
      client::ClearCppValueHelper(&filter_);
    }


    const string& get_filter() const { return filter_; }

    string* mutable_filter() {
      _have_filter_ = true;
      return &filter_;
    }


    void set_filter(const string& value) {
      _have_filter_ = true;
      filter_ = value;
    }



    void clear_location() {
      _have_location_ = false;
      client::ClearCppValueHelper(&location_);
    }


    const string& get_location() const { return location_; }

    string* mutable_location() {
      _have_location_ = true;
      return &location_;
    }


    void set_location(const string& value) {
      _have_location_ = true;
      location_ = value;
    }



    void clear_page_token() {
      _have_page_token_ = false;
      client::ClearCppValueHelper(&page_token_);
    }


    const string& get_page_token() const { return page_token_; }

    string* mutable_pageToken() {
      _have_page_token_ = true;
      return &page_token_;
    }


    void set_page_token(const string& value) {
      _have_page_token_ = true;
      page_token_ = value;
    }



    void clear_page_size() {
      _have_page_size_ = false;
      client::ClearCppValueHelper(&page_size_);
    }


    int32 get_page_size() const { return page_size_; }

    void set_page_size(int32 value) {
      _have_page_size_ = true;
      page_size_ = value;
    }

    void clear_view() {
      _have_view_ = false;
      client::ClearCppValueHelper(&view_);
    }


    const string& get_view() const { return view_; }

    string* mutable_view() {
      _have_view_ = true;
      return &view_;
    }


    void set_view(const string& value) {
      _have_view_ = true;
      view_ = value;
    }

  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);

  virtual util::Status AppendOptionalQueryParameters(string* target);


  util::Status ExecuteAndParseResponse(
      ListJobsResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string filter_;
  string location_;
  string page_token_;
  int32 page_size_;
  string view_;
  bool _have_filter_ : 1;
  bool _have_location_ : 1;
  bool _have_page_token_ : 1;
  bool _have_page_size_ : 1;
  bool _have_view_ : 1;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_JobsResource_AggregatedMethod);
};

typedef client::ServiceRequestPager<
            ProjectsResource_JobsResource_AggregatedMethod,
            ListJobsResponse>
        ProjectsResource_JobsResource_AggregatedMethodPager;

class ProjectsResource_JobsResource_CreateMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_JobsResource_CreateMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const Job& _content_);

  virtual ~ProjectsResource_JobsResource_CreateMethod();


    void clear_location() {
      _have_location_ = false;
      client::ClearCppValueHelper(&location_);
    }


    const string& get_location() const { return location_; }

    string* mutable_location() {
      _have_location_ = true;
      return &location_;
    }


    void set_location(const string& value) {
      _have_location_ = true;
      location_ = value;
    }



    void clear_replace_job_id() {
      _have_replace_job_id_ = false;
      client::ClearCppValueHelper(&replace_job_id_);
    }


    const string& get_replace_job_id() const { return replace_job_id_; }

    string* mutable_replaceJobId() {
      _have_replace_job_id_ = true;
      return &replace_job_id_;
    }


    void set_replace_job_id(const string& value) {
      _have_replace_job_id_ = true;
      replace_job_id_ = value;
    }



    void clear_view() {
      _have_view_ = false;
      client::ClearCppValueHelper(&view_);
    }


    const string& get_view() const { return view_; }

    string* mutable_view() {
      _have_view_ = true;
      return &view_;
    }


    void set_view(const string& value) {
      _have_view_ = true;
      view_ = value;
    }

  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);

  virtual util::Status AppendOptionalQueryParameters(string* target);


  util::Status ExecuteAndParseResponse(
      Job* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;
  string replace_job_id_;
  string view_;
  bool _have_location_ : 1;
  bool _have_replace_job_id_ : 1;
  bool _have_view_ : 1;  string _content_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_JobsResource_CreateMethod);
};

class ProjectsResource_JobsResource_GetMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_JobsResource_GetMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& job_id);

  virtual ~ProjectsResource_JobsResource_GetMethod();


    void clear_view() {
      _have_view_ = false;
      client::ClearCppValueHelper(&view_);
    }


    const string& get_view() const { return view_; }

    string* mutable_view() {
      _have_view_ = true;
      return &view_;
    }


    void set_view(const string& value) {
      _have_view_ = true;
      view_ = value;
    }



    void clear_location() {
      _have_location_ = false;
      client::ClearCppValueHelper(&location_);
    }


    const string& get_location() const { return location_; }

    string* mutable_location() {
      _have_location_ = true;
      return &location_;
    }


    void set_location(const string& value) {
      _have_location_ = true;
      location_ = value;
    }

  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);

  virtual util::Status AppendOptionalQueryParameters(string* target);


  util::Status ExecuteAndParseResponse(
      Job* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string job_id_;
  string view_;
  string location_;
  bool _have_view_ : 1;
  bool _have_location_ : 1;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_JobsResource_GetMethod);
};

class ProjectsResource_JobsResource_GetMetricsMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_JobsResource_GetMetricsMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& job_id);

  virtual ~ProjectsResource_JobsResource_GetMetricsMethod();


    void clear_location() {
      _have_location_ = false;
      client::ClearCppValueHelper(&location_);
    }


    const string& get_location() const { return location_; }

    string* mutable_location() {
      _have_location_ = true;
      return &location_;
    }


    void set_location(const string& value) {
      _have_location_ = true;
      location_ = value;
    }



    void clear_start_time() {
      _have_start_time_ = false;
      client::ClearCppValueHelper(&start_time_);
    }


    const string& get_start_time() const { return start_time_; }

    string* mutable_startTime() {
      _have_start_time_ = true;
      return &start_time_;
    }


    void set_start_time(const string& value) {
      _have_start_time_ = true;
      start_time_ = value;
    }

  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);

  virtual util::Status AppendOptionalQueryParameters(string* target);


  util::Status ExecuteAndParseResponse(
      JobMetrics* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string job_id_;
  string location_;
  string start_time_;
  bool _have_location_ : 1;
  bool _have_start_time_ : 1;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_JobsResource_GetMetricsMethod);
};

class ProjectsResource_JobsResource_ListMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_JobsResource_ListMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id);

  virtual ~ProjectsResource_JobsResource_ListMethod();


    void clear_location() {
      _have_location_ = false;
      client::ClearCppValueHelper(&location_);
    }


    const string& get_location() const { return location_; }

    string* mutable_location() {
      _have_location_ = true;
      return &location_;
    }


    void set_location(const string& value) {
      _have_location_ = true;
      location_ = value;
    }



    void clear_page_token() {
      _have_page_token_ = false;
      client::ClearCppValueHelper(&page_token_);
    }


    const string& get_page_token() const { return page_token_; }

    string* mutable_pageToken() {
      _have_page_token_ = true;
      return &page_token_;
    }


    void set_page_token(const string& value) {
      _have_page_token_ = true;
      page_token_ = value;
    }



    void clear_page_size() {
      _have_page_size_ = false;
      client::ClearCppValueHelper(&page_size_);
    }


    int32 get_page_size() const { return page_size_; }

    void set_page_size(int32 value) {
      _have_page_size_ = true;
      page_size_ = value;
    }

    void clear_view() {
      _have_view_ = false;
      client::ClearCppValueHelper(&view_);
    }


    const string& get_view() const { return view_; }

    string* mutable_view() {
      _have_view_ = true;
      return &view_;
    }


    void set_view(const string& value) {
      _have_view_ = true;
      view_ = value;
    }



    void clear_filter() {
      _have_filter_ = false;
      client::ClearCppValueHelper(&filter_);
    }


    const string& get_filter() const { return filter_; }

    string* mutable_filter() {
      _have_filter_ = true;
      return &filter_;
    }


    void set_filter(const string& value) {
      _have_filter_ = true;
      filter_ = value;
    }

  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);

  virtual util::Status AppendOptionalQueryParameters(string* target);


  util::Status ExecuteAndParseResponse(
      ListJobsResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;
  string page_token_;
  int32 page_size_;
  string view_;
  string filter_;
  bool _have_location_ : 1;
  bool _have_page_token_ : 1;
  bool _have_page_size_ : 1;
  bool _have_view_ : 1;
  bool _have_filter_ : 1;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_JobsResource_ListMethod);
};

typedef client::ServiceRequestPager<
            ProjectsResource_JobsResource_ListMethod,
            ListJobsResponse>
        ProjectsResource_JobsResource_ListMethodPager;

class ProjectsResource_JobsResource_SnapshotMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_JobsResource_SnapshotMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& job_id,
      const SnapshotJobRequest& _content_);

  virtual ~ProjectsResource_JobsResource_SnapshotMethod();


  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);


  util::Status ExecuteAndParseResponse(
      Snapshot* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string job_id_;  string _content_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_JobsResource_SnapshotMethod);
};

class ProjectsResource_JobsResource_UpdateMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_JobsResource_UpdateMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& job_id,
      const Job& _content_);

  virtual ~ProjectsResource_JobsResource_UpdateMethod();


    void clear_location() {
      _have_location_ = false;
      client::ClearCppValueHelper(&location_);
    }


    const string& get_location() const { return location_; }

    string* mutable_location() {
      _have_location_ = true;
      return &location_;
    }


    void set_location(const string& value) {
      _have_location_ = true;
      location_ = value;
    }

  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);

  virtual util::Status AppendOptionalQueryParameters(string* target);


  util::Status ExecuteAndParseResponse(
      Job* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string job_id_;
  string location_;
  bool _have_location_ : 1;  string _content_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_JobsResource_UpdateMethod);
};




class ProjectsResource_JobsResource_DebugResource_GetConfigMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_JobsResource_DebugResource_GetConfigMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& job_id,
      const GetDebugConfigRequest& _content_);

  virtual ~ProjectsResource_JobsResource_DebugResource_GetConfigMethod();


  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);


  util::Status ExecuteAndParseResponse(
      GetDebugConfigResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string job_id_;  string _content_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_JobsResource_DebugResource_GetConfigMethod);
};

class ProjectsResource_JobsResource_DebugResource_SendCaptureMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_JobsResource_DebugResource_SendCaptureMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& job_id,
      const SendDebugCaptureRequest& _content_);

  virtual ~ProjectsResource_JobsResource_DebugResource_SendCaptureMethod();


  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);


  util::Status ExecuteAndParseResponse(
      SendDebugCaptureResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string job_id_;  string _content_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_JobsResource_DebugResource_SendCaptureMethod);
};


class ProjectsResource_JobsResource_MessagesResource_ListMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_JobsResource_MessagesResource_ListMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& job_id);

  virtual ~ProjectsResource_JobsResource_MessagesResource_ListMethod();


    void clear_end_time() {
      _have_end_time_ = false;
      client::ClearCppValueHelper(&end_time_);
    }


    const string& get_end_time() const { return end_time_; }

    string* mutable_endTime() {
      _have_end_time_ = true;
      return &end_time_;
    }


    void set_end_time(const string& value) {
      _have_end_time_ = true;
      end_time_ = value;
    }



    void clear_location() {
      _have_location_ = false;
      client::ClearCppValueHelper(&location_);
    }


    const string& get_location() const { return location_; }

    string* mutable_location() {
      _have_location_ = true;
      return &location_;
    }


    void set_location(const string& value) {
      _have_location_ = true;
      location_ = value;
    }



    void clear_start_time() {
      _have_start_time_ = false;
      client::ClearCppValueHelper(&start_time_);
    }


    const string& get_start_time() const { return start_time_; }

    string* mutable_startTime() {
      _have_start_time_ = true;
      return &start_time_;
    }


    void set_start_time(const string& value) {
      _have_start_time_ = true;
      start_time_ = value;
    }



    void clear_page_token() {
      _have_page_token_ = false;
      client::ClearCppValueHelper(&page_token_);
    }


    const string& get_page_token() const { return page_token_; }

    string* mutable_pageToken() {
      _have_page_token_ = true;
      return &page_token_;
    }


    void set_page_token(const string& value) {
      _have_page_token_ = true;
      page_token_ = value;
    }



    void clear_page_size() {
      _have_page_size_ = false;
      client::ClearCppValueHelper(&page_size_);
    }


    int32 get_page_size() const { return page_size_; }

    void set_page_size(int32 value) {
      _have_page_size_ = true;
      page_size_ = value;
    }

    void clear_minimum_importance() {
      _have_minimum_importance_ = false;
      client::ClearCppValueHelper(&minimum_importance_);
    }


    const string& get_minimum_importance() const { return minimum_importance_; }

    string* mutable_minimumImportance() {
      _have_minimum_importance_ = true;
      return &minimum_importance_;
    }


    void set_minimum_importance(const string& value) {
      _have_minimum_importance_ = true;
      minimum_importance_ = value;
    }

  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);

  virtual util::Status AppendOptionalQueryParameters(string* target);


  util::Status ExecuteAndParseResponse(
      ListJobMessagesResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string job_id_;
  string end_time_;
  string location_;
  string start_time_;
  string page_token_;
  int32 page_size_;
  string minimum_importance_;
  bool _have_end_time_ : 1;
  bool _have_location_ : 1;
  bool _have_start_time_ : 1;
  bool _have_page_token_ : 1;
  bool _have_page_size_ : 1;
  bool _have_minimum_importance_ : 1;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_JobsResource_MessagesResource_ListMethod);
};

typedef client::ServiceRequestPager<
            ProjectsResource_JobsResource_MessagesResource_ListMethod,
            ListJobMessagesResponse>
        ProjectsResource_JobsResource_MessagesResource_ListMethodPager;


class ProjectsResource_JobsResource_WorkItemsResource_LeaseMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_JobsResource_WorkItemsResource_LeaseMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& job_id,
      const LeaseWorkItemRequest& _content_);

  virtual ~ProjectsResource_JobsResource_WorkItemsResource_LeaseMethod();


  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);


  util::Status ExecuteAndParseResponse(
      LeaseWorkItemResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string job_id_;  string _content_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_JobsResource_WorkItemsResource_LeaseMethod);
};

class ProjectsResource_JobsResource_WorkItemsResource_ReportStatusMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_JobsResource_WorkItemsResource_ReportStatusMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& job_id,
      const ReportWorkItemStatusRequest& _content_);

  virtual ~ProjectsResource_JobsResource_WorkItemsResource_ReportStatusMethod();


  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);


  util::Status ExecuteAndParseResponse(
      ReportWorkItemStatusResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string job_id_;  string _content_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_JobsResource_WorkItemsResource_ReportStatusMethod);
};


class ProjectsResource_LocationsResource_WorkerMessagesMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_LocationsResource_WorkerMessagesMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& location,
      const SendWorkerMessagesRequest& _content_);

  virtual ~ProjectsResource_LocationsResource_WorkerMessagesMethod();


  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);


  util::Status ExecuteAndParseResponse(
      SendWorkerMessagesResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;  string _content_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_LocationsResource_WorkerMessagesMethod);
};




class ProjectsResource_LocationsResource_FlexTemplatesResource_LaunchMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_LocationsResource_FlexTemplatesResource_LaunchMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& location,
      const LaunchFlexTemplateRequest& _content_);

  virtual ~ProjectsResource_LocationsResource_FlexTemplatesResource_LaunchMethod();


  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);


  util::Status ExecuteAndParseResponse(
      LaunchFlexTemplateResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;  string _content_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_LocationsResource_FlexTemplatesResource_LaunchMethod);
};


class ProjectsResource_LocationsResource_JobsResource_CreateMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_LocationsResource_JobsResource_CreateMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& location,
      const Job& _content_);

  virtual ~ProjectsResource_LocationsResource_JobsResource_CreateMethod();


    void clear_view() {
      _have_view_ = false;
      client::ClearCppValueHelper(&view_);
    }


    const string& get_view() const { return view_; }

    string* mutable_view() {
      _have_view_ = true;
      return &view_;
    }


    void set_view(const string& value) {
      _have_view_ = true;
      view_ = value;
    }



    void clear_replace_job_id() {
      _have_replace_job_id_ = false;
      client::ClearCppValueHelper(&replace_job_id_);
    }


    const string& get_replace_job_id() const { return replace_job_id_; }

    string* mutable_replaceJobId() {
      _have_replace_job_id_ = true;
      return &replace_job_id_;
    }


    void set_replace_job_id(const string& value) {
      _have_replace_job_id_ = true;
      replace_job_id_ = value;
    }

  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);

  virtual util::Status AppendOptionalQueryParameters(string* target);


  util::Status ExecuteAndParseResponse(
      Job* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;
  string view_;
  string replace_job_id_;
  bool _have_view_ : 1;
  bool _have_replace_job_id_ : 1;  string _content_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_LocationsResource_JobsResource_CreateMethod);
};

class ProjectsResource_LocationsResource_JobsResource_GetMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_LocationsResource_JobsResource_GetMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& location,
      const absl::string_view& job_id);

  virtual ~ProjectsResource_LocationsResource_JobsResource_GetMethod();


    void clear_view() {
      _have_view_ = false;
      client::ClearCppValueHelper(&view_);
    }


    const string& get_view() const { return view_; }

    string* mutable_view() {
      _have_view_ = true;
      return &view_;
    }


    void set_view(const string& value) {
      _have_view_ = true;
      view_ = value;
    }

  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);

  virtual util::Status AppendOptionalQueryParameters(string* target);


  util::Status ExecuteAndParseResponse(
      Job* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;
  string job_id_;
  string view_;
  bool _have_view_ : 1;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_LocationsResource_JobsResource_GetMethod);
};

class ProjectsResource_LocationsResource_JobsResource_GetMetricsMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_LocationsResource_JobsResource_GetMetricsMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& location,
      const absl::string_view& job_id);

  virtual ~ProjectsResource_LocationsResource_JobsResource_GetMetricsMethod();


    void clear_start_time() {
      _have_start_time_ = false;
      client::ClearCppValueHelper(&start_time_);
    }


    const string& get_start_time() const { return start_time_; }

    string* mutable_startTime() {
      _have_start_time_ = true;
      return &start_time_;
    }


    void set_start_time(const string& value) {
      _have_start_time_ = true;
      start_time_ = value;
    }

  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);

  virtual util::Status AppendOptionalQueryParameters(string* target);


  util::Status ExecuteAndParseResponse(
      JobMetrics* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;
  string job_id_;
  string start_time_;
  bool _have_start_time_ : 1;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_LocationsResource_JobsResource_GetMetricsMethod);
};

class ProjectsResource_LocationsResource_JobsResource_ListMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_LocationsResource_JobsResource_ListMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& location);

  virtual ~ProjectsResource_LocationsResource_JobsResource_ListMethod();


    void clear_page_token() {
      _have_page_token_ = false;
      client::ClearCppValueHelper(&page_token_);
    }


    const string& get_page_token() const { return page_token_; }

    string* mutable_pageToken() {
      _have_page_token_ = true;
      return &page_token_;
    }


    void set_page_token(const string& value) {
      _have_page_token_ = true;
      page_token_ = value;
    }



    void clear_page_size() {
      _have_page_size_ = false;
      client::ClearCppValueHelper(&page_size_);
    }


    int32 get_page_size() const { return page_size_; }

    void set_page_size(int32 value) {
      _have_page_size_ = true;
      page_size_ = value;
    }

    void clear_view() {
      _have_view_ = false;
      client::ClearCppValueHelper(&view_);
    }


    const string& get_view() const { return view_; }

    string* mutable_view() {
      _have_view_ = true;
      return &view_;
    }


    void set_view(const string& value) {
      _have_view_ = true;
      view_ = value;
    }



    void clear_filter() {
      _have_filter_ = false;
      client::ClearCppValueHelper(&filter_);
    }


    const string& get_filter() const { return filter_; }

    string* mutable_filter() {
      _have_filter_ = true;
      return &filter_;
    }


    void set_filter(const string& value) {
      _have_filter_ = true;
      filter_ = value;
    }

  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);

  virtual util::Status AppendOptionalQueryParameters(string* target);


  util::Status ExecuteAndParseResponse(
      ListJobsResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;
  string page_token_;
  int32 page_size_;
  string view_;
  string filter_;
  bool _have_page_token_ : 1;
  bool _have_page_size_ : 1;
  bool _have_view_ : 1;
  bool _have_filter_ : 1;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_LocationsResource_JobsResource_ListMethod);
};

typedef client::ServiceRequestPager<
            ProjectsResource_LocationsResource_JobsResource_ListMethod,
            ListJobsResponse>
        ProjectsResource_LocationsResource_JobsResource_ListMethodPager;

class ProjectsResource_LocationsResource_JobsResource_SnapshotMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_LocationsResource_JobsResource_SnapshotMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& location,
      const absl::string_view& job_id,
      const SnapshotJobRequest& _content_);

  virtual ~ProjectsResource_LocationsResource_JobsResource_SnapshotMethod();


  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);


  util::Status ExecuteAndParseResponse(
      Snapshot* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;
  string job_id_;  string _content_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_LocationsResource_JobsResource_SnapshotMethod);
};

class ProjectsResource_LocationsResource_JobsResource_UpdateMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_LocationsResource_JobsResource_UpdateMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& location,
      const absl::string_view& job_id,
      const Job& _content_);

  virtual ~ProjectsResource_LocationsResource_JobsResource_UpdateMethod();


  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);


  util::Status ExecuteAndParseResponse(
      Job* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;
  string job_id_;  string _content_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_LocationsResource_JobsResource_UpdateMethod);
};




class ProjectsResource_LocationsResource_JobsResource_DebugResource_GetConfigMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_LocationsResource_JobsResource_DebugResource_GetConfigMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& location,
      const absl::string_view& job_id,
      const GetDebugConfigRequest& _content_);

  virtual ~ProjectsResource_LocationsResource_JobsResource_DebugResource_GetConfigMethod();


  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);


  util::Status ExecuteAndParseResponse(
      GetDebugConfigResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;
  string job_id_;  string _content_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_LocationsResource_JobsResource_DebugResource_GetConfigMethod);
};

class ProjectsResource_LocationsResource_JobsResource_DebugResource_SendCaptureMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_LocationsResource_JobsResource_DebugResource_SendCaptureMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& location,
      const absl::string_view& job_id,
      const SendDebugCaptureRequest& _content_);

  virtual ~ProjectsResource_LocationsResource_JobsResource_DebugResource_SendCaptureMethod();


  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);


  util::Status ExecuteAndParseResponse(
      SendDebugCaptureResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;
  string job_id_;  string _content_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_LocationsResource_JobsResource_DebugResource_SendCaptureMethod);
};


class ProjectsResource_LocationsResource_JobsResource_MessagesResource_ListMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_LocationsResource_JobsResource_MessagesResource_ListMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& location,
      const absl::string_view& job_id);

  virtual ~ProjectsResource_LocationsResource_JobsResource_MessagesResource_ListMethod();


    void clear_end_time() {
      _have_end_time_ = false;
      client::ClearCppValueHelper(&end_time_);
    }


    const string& get_end_time() const { return end_time_; }

    string* mutable_endTime() {
      _have_end_time_ = true;
      return &end_time_;
    }


    void set_end_time(const string& value) {
      _have_end_time_ = true;
      end_time_ = value;
    }



    void clear_page_token() {
      _have_page_token_ = false;
      client::ClearCppValueHelper(&page_token_);
    }


    const string& get_page_token() const { return page_token_; }

    string* mutable_pageToken() {
      _have_page_token_ = true;
      return &page_token_;
    }


    void set_page_token(const string& value) {
      _have_page_token_ = true;
      page_token_ = value;
    }



    void clear_start_time() {
      _have_start_time_ = false;
      client::ClearCppValueHelper(&start_time_);
    }


    const string& get_start_time() const { return start_time_; }

    string* mutable_startTime() {
      _have_start_time_ = true;
      return &start_time_;
    }


    void set_start_time(const string& value) {
      _have_start_time_ = true;
      start_time_ = value;
    }



    void clear_page_size() {
      _have_page_size_ = false;
      client::ClearCppValueHelper(&page_size_);
    }


    int32 get_page_size() const { return page_size_; }

    void set_page_size(int32 value) {
      _have_page_size_ = true;
      page_size_ = value;
    }

    void clear_minimum_importance() {
      _have_minimum_importance_ = false;
      client::ClearCppValueHelper(&minimum_importance_);
    }


    const string& get_minimum_importance() const { return minimum_importance_; }

    string* mutable_minimumImportance() {
      _have_minimum_importance_ = true;
      return &minimum_importance_;
    }


    void set_minimum_importance(const string& value) {
      _have_minimum_importance_ = true;
      minimum_importance_ = value;
    }

  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);

  virtual util::Status AppendOptionalQueryParameters(string* target);


  util::Status ExecuteAndParseResponse(
      ListJobMessagesResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;
  string job_id_;
  string end_time_;
  string page_token_;
  string start_time_;
  int32 page_size_;
  string minimum_importance_;
  bool _have_end_time_ : 1;
  bool _have_page_token_ : 1;
  bool _have_start_time_ : 1;
  bool _have_page_size_ : 1;
  bool _have_minimum_importance_ : 1;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_LocationsResource_JobsResource_MessagesResource_ListMethod);
};

typedef client::ServiceRequestPager<
            ProjectsResource_LocationsResource_JobsResource_MessagesResource_ListMethod,
            ListJobMessagesResponse>
        ProjectsResource_LocationsResource_JobsResource_MessagesResource_ListMethodPager;


class ProjectsResource_LocationsResource_JobsResource_SnapshotsResource_ListMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_LocationsResource_JobsResource_SnapshotsResource_ListMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& location,
      const absl::string_view& job_id);

  virtual ~ProjectsResource_LocationsResource_JobsResource_SnapshotsResource_ListMethod();


  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);


  util::Status ExecuteAndParseResponse(
      ListSnapshotsResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;
  string job_id_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_LocationsResource_JobsResource_SnapshotsResource_ListMethod);
};


class ProjectsResource_LocationsResource_JobsResource_WorkItemsResource_LeaseMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_LocationsResource_JobsResource_WorkItemsResource_LeaseMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& location,
      const absl::string_view& job_id,
      const LeaseWorkItemRequest& _content_);

  virtual ~ProjectsResource_LocationsResource_JobsResource_WorkItemsResource_LeaseMethod();


  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);


  util::Status ExecuteAndParseResponse(
      LeaseWorkItemResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;
  string job_id_;  string _content_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_LocationsResource_JobsResource_WorkItemsResource_LeaseMethod);
};

class ProjectsResource_LocationsResource_JobsResource_WorkItemsResource_ReportStatusMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_LocationsResource_JobsResource_WorkItemsResource_ReportStatusMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& location,
      const absl::string_view& job_id,
      const ReportWorkItemStatusRequest& _content_);

  virtual ~ProjectsResource_LocationsResource_JobsResource_WorkItemsResource_ReportStatusMethod();


  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);


  util::Status ExecuteAndParseResponse(
      ReportWorkItemStatusResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;
  string job_id_;  string _content_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_LocationsResource_JobsResource_WorkItemsResource_ReportStatusMethod);
};


class ProjectsResource_LocationsResource_SnapshotsResource_DeleteMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_LocationsResource_SnapshotsResource_DeleteMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& location,
      const absl::string_view& snapshot_id);

  virtual ~ProjectsResource_LocationsResource_SnapshotsResource_DeleteMethod();


  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);


  util::Status ExecuteAndParseResponse(
      DeleteSnapshotResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;
  string snapshot_id_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_LocationsResource_SnapshotsResource_DeleteMethod);
};

class ProjectsResource_LocationsResource_SnapshotsResource_GetMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_LocationsResource_SnapshotsResource_GetMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& location,
      const absl::string_view& snapshot_id);

  virtual ~ProjectsResource_LocationsResource_SnapshotsResource_GetMethod();


  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);


  util::Status ExecuteAndParseResponse(
      Snapshot* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;
  string snapshot_id_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_LocationsResource_SnapshotsResource_GetMethod);
};

class ProjectsResource_LocationsResource_SnapshotsResource_ListMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_LocationsResource_SnapshotsResource_ListMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& location);

  virtual ~ProjectsResource_LocationsResource_SnapshotsResource_ListMethod();


    void clear_job_id() {
      _have_job_id_ = false;
      client::ClearCppValueHelper(&job_id_);
    }


    const string& get_job_id() const { return job_id_; }

    string* mutable_jobId() {
      _have_job_id_ = true;
      return &job_id_;
    }


    void set_job_id(const string& value) {
      _have_job_id_ = true;
      job_id_ = value;
    }

  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);

  virtual util::Status AppendOptionalQueryParameters(string* target);


  util::Status ExecuteAndParseResponse(
      ListSnapshotsResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;
  string job_id_;
  bool _have_job_id_ : 1;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_LocationsResource_SnapshotsResource_ListMethod);
};


class ProjectsResource_LocationsResource_SqlResource_ValidateMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_LocationsResource_SqlResource_ValidateMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& location);

  virtual ~ProjectsResource_LocationsResource_SqlResource_ValidateMethod();


    void clear_query() {
      _have_query_ = false;
      client::ClearCppValueHelper(&query_);
    }


    const string& get_query() const { return query_; }

    string* mutable_query() {
      _have_query_ = true;
      return &query_;
    }


    void set_query(const string& value) {
      _have_query_ = true;
      query_ = value;
    }

  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);

  virtual util::Status AppendOptionalQueryParameters(string* target);


  util::Status ExecuteAndParseResponse(
      ValidateResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;
  string query_;
  bool _have_query_ : 1;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_LocationsResource_SqlResource_ValidateMethod);
};


class ProjectsResource_LocationsResource_TemplatesResource_CreateMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_LocationsResource_TemplatesResource_CreateMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& location,
      const CreateJobFromTemplateRequest& _content_);

  virtual ~ProjectsResource_LocationsResource_TemplatesResource_CreateMethod();


  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);


  util::Status ExecuteAndParseResponse(
      Job* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;  string _content_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_LocationsResource_TemplatesResource_CreateMethod);
};

class ProjectsResource_LocationsResource_TemplatesResource_GetMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_LocationsResource_TemplatesResource_GetMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& location);

  virtual ~ProjectsResource_LocationsResource_TemplatesResource_GetMethod();


    void clear_view() {
      _have_view_ = false;
      client::ClearCppValueHelper(&view_);
    }


    const string& get_view() const { return view_; }

    string* mutable_view() {
      _have_view_ = true;
      return &view_;
    }


    void set_view(const string& value) {
      _have_view_ = true;
      view_ = value;
    }



    void clear_gcs_path() {
      _have_gcs_path_ = false;
      client::ClearCppValueHelper(&gcs_path_);
    }


    const string& get_gcs_path() const { return gcs_path_; }

    string* mutable_gcsPath() {
      _have_gcs_path_ = true;
      return &gcs_path_;
    }


    void set_gcs_path(const string& value) {
      _have_gcs_path_ = true;
      gcs_path_ = value;
    }

  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);

  virtual util::Status AppendOptionalQueryParameters(string* target);


  util::Status ExecuteAndParseResponse(
      GetTemplateResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;
  string view_;
  string gcs_path_;
  bool _have_view_ : 1;
  bool _have_gcs_path_ : 1;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_LocationsResource_TemplatesResource_GetMethod);
};

class ProjectsResource_LocationsResource_TemplatesResource_LaunchMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_LocationsResource_TemplatesResource_LaunchMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& location,
      const LaunchTemplateParameters& _content_);

  virtual ~ProjectsResource_LocationsResource_TemplatesResource_LaunchMethod();


    void clear_dynamic_template_gcs_path() {
      _have_dynamic_template_gcs_path_ = false;
      client::ClearCppValueHelper(&dynamic_template_gcs_path_);
    }


    const string& get_dynamic_template_gcs_path() const { return dynamic_template_gcs_path_; }

    string* mutable_dynamicTemplateGcsPath() {
      _have_dynamic_template_gcs_path_ = true;
      return &dynamic_template_gcs_path_;
    }


    void set_dynamic_template_gcs_path(const string& value) {
      _have_dynamic_template_gcs_path_ = true;
      dynamic_template_gcs_path_ = value;
    }



    void clear_dynamic_template_staging_location() {
      _have_dynamic_template_staging_location_ = false;
      client::ClearCppValueHelper(&dynamic_template_staging_location_);
    }


    const string& get_dynamic_template_staging_location() const { return dynamic_template_staging_location_; }

    string* mutable_dynamicTemplateStagingLocation() {
      _have_dynamic_template_staging_location_ = true;
      return &dynamic_template_staging_location_;
    }


    void set_dynamic_template_staging_location(const string& value) {
      _have_dynamic_template_staging_location_ = true;
      dynamic_template_staging_location_ = value;
    }



    void clear_validate_only() {
      _have_validate_only_ = false;
      client::ClearCppValueHelper(&validate_only_);
    }


    bool get_validate_only() const { return validate_only_; }

    void set_validate_only(bool value) {
      _have_validate_only_ = true;
      validate_only_ = value;
    }

    void clear_gcs_path() {
      _have_gcs_path_ = false;
      client::ClearCppValueHelper(&gcs_path_);
    }


    const string& get_gcs_path() const { return gcs_path_; }

    string* mutable_gcsPath() {
      _have_gcs_path_ = true;
      return &gcs_path_;
    }


    void set_gcs_path(const string& value) {
      _have_gcs_path_ = true;
      gcs_path_ = value;
    }

  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);

  virtual util::Status AppendOptionalQueryParameters(string* target);


  util::Status ExecuteAndParseResponse(
      LaunchTemplateResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string location_;
  string dynamic_template_gcs_path_;
  string dynamic_template_staging_location_;
  bool validate_only_;
  string gcs_path_;
  bool _have_dynamic_template_gcs_path_ : 1;
  bool _have_dynamic_template_staging_location_ : 1;
  bool _have_validate_only_ : 1;
  bool _have_gcs_path_ : 1;  string _content_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_LocationsResource_TemplatesResource_LaunchMethod);
};


class ProjectsResource_SnapshotsResource_GetMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_SnapshotsResource_GetMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const absl::string_view& snapshot_id);

  virtual ~ProjectsResource_SnapshotsResource_GetMethod();


    void clear_location() {
      _have_location_ = false;
      client::ClearCppValueHelper(&location_);
    }


    const string& get_location() const { return location_; }

    string* mutable_location() {
      _have_location_ = true;
      return &location_;
    }


    void set_location(const string& value) {
      _have_location_ = true;
      location_ = value;
    }

  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);

  virtual util::Status AppendOptionalQueryParameters(string* target);


  util::Status ExecuteAndParseResponse(
      Snapshot* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string snapshot_id_;
  string location_;
  bool _have_location_ : 1;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_SnapshotsResource_GetMethod);
};

class ProjectsResource_SnapshotsResource_ListMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_SnapshotsResource_ListMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id);

  virtual ~ProjectsResource_SnapshotsResource_ListMethod();


    void clear_job_id() {
      _have_job_id_ = false;
      client::ClearCppValueHelper(&job_id_);
    }


    const string& get_job_id() const { return job_id_; }

    string* mutable_jobId() {
      _have_job_id_ = true;
      return &job_id_;
    }


    void set_job_id(const string& value) {
      _have_job_id_ = true;
      job_id_ = value;
    }



    void clear_location() {
      _have_location_ = false;
      client::ClearCppValueHelper(&location_);
    }


    const string& get_location() const { return location_; }

    string* mutable_location() {
      _have_location_ = true;
      return &location_;
    }


    void set_location(const string& value) {
      _have_location_ = true;
      location_ = value;
    }

  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);

  virtual util::Status AppendOptionalQueryParameters(string* target);


  util::Status ExecuteAndParseResponse(
      ListSnapshotsResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string job_id_;
  string location_;
  bool _have_job_id_ : 1;
  bool _have_location_ : 1;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_SnapshotsResource_ListMethod);
};


class ProjectsResource_TemplatesResource_CreateMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_TemplatesResource_CreateMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const CreateJobFromTemplateRequest& _content_);

  virtual ~ProjectsResource_TemplatesResource_CreateMethod();


  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);


  util::Status ExecuteAndParseResponse(
      Job* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;  string _content_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_TemplatesResource_CreateMethod);
};

class ProjectsResource_TemplatesResource_GetMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_TemplatesResource_GetMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id);

  virtual ~ProjectsResource_TemplatesResource_GetMethod();


    void clear_view() {
      _have_view_ = false;
      client::ClearCppValueHelper(&view_);
    }


    const string& get_view() const { return view_; }

    string* mutable_view() {
      _have_view_ = true;
      return &view_;
    }


    void set_view(const string& value) {
      _have_view_ = true;
      view_ = value;
    }



    void clear_gcs_path() {
      _have_gcs_path_ = false;
      client::ClearCppValueHelper(&gcs_path_);
    }


    const string& get_gcs_path() const { return gcs_path_; }

    string* mutable_gcsPath() {
      _have_gcs_path_ = true;
      return &gcs_path_;
    }


    void set_gcs_path(const string& value) {
      _have_gcs_path_ = true;
      gcs_path_ = value;
    }



    void clear_location() {
      _have_location_ = false;
      client::ClearCppValueHelper(&location_);
    }


    const string& get_location() const { return location_; }

    string* mutable_location() {
      _have_location_ = true;
      return &location_;
    }


    void set_location(const string& value) {
      _have_location_ = true;
      location_ = value;
    }

  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);

  virtual util::Status AppendOptionalQueryParameters(string* target);


  util::Status ExecuteAndParseResponse(
      GetTemplateResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string view_;
  string gcs_path_;
  string location_;
  bool _have_view_ : 1;
  bool _have_gcs_path_ : 1;
  bool _have_location_ : 1;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_TemplatesResource_GetMethod);
};

class ProjectsResource_TemplatesResource_LaunchMethod : public DataflowServiceBaseRequest {
 public:
  ProjectsResource_TemplatesResource_LaunchMethod(
      const DataflowService* _service_,
      client::AuthorizationCredential* _credential_,
      const absl::string_view& project_id,
      const LaunchTemplateParameters& _content_);

  virtual ~ProjectsResource_TemplatesResource_LaunchMethod();


    void clear_gcs_path() {
      _have_gcs_path_ = false;
      client::ClearCppValueHelper(&gcs_path_);
    }


    const string& get_gcs_path() const { return gcs_path_; }

    string* mutable_gcsPath() {
      _have_gcs_path_ = true;
      return &gcs_path_;
    }


    void set_gcs_path(const string& value) {
      _have_gcs_path_ = true;
      gcs_path_ = value;
    }



    void clear_location() {
      _have_location_ = false;
      client::ClearCppValueHelper(&location_);
    }


    const string& get_location() const { return location_; }

    string* mutable_location() {
      _have_location_ = true;
      return &location_;
    }


    void set_location(const string& value) {
      _have_location_ = true;
      location_ = value;
    }



    void clear_dynamic_template_gcs_path() {
      _have_dynamic_template_gcs_path_ = false;
      client::ClearCppValueHelper(&dynamic_template_gcs_path_);
    }


    const string& get_dynamic_template_gcs_path() const { return dynamic_template_gcs_path_; }

    string* mutable_dynamicTemplateGcsPath() {
      _have_dynamic_template_gcs_path_ = true;
      return &dynamic_template_gcs_path_;
    }


    void set_dynamic_template_gcs_path(const string& value) {
      _have_dynamic_template_gcs_path_ = true;
      dynamic_template_gcs_path_ = value;
    }



    void clear_dynamic_template_staging_location() {
      _have_dynamic_template_staging_location_ = false;
      client::ClearCppValueHelper(&dynamic_template_staging_location_);
    }


    const string& get_dynamic_template_staging_location() const { return dynamic_template_staging_location_; }

    string* mutable_dynamicTemplateStagingLocation() {
      _have_dynamic_template_staging_location_ = true;
      return &dynamic_template_staging_location_;
    }


    void set_dynamic_template_staging_location(const string& value) {
      _have_dynamic_template_staging_location_ = true;
      dynamic_template_staging_location_ = value;
    }



    void clear_validate_only() {
      _have_validate_only_ = false;
      client::ClearCppValueHelper(&validate_only_);
    }


    bool get_validate_only() const { return validate_only_; }

    void set_validate_only(bool value) {
      _have_validate_only_ = true;
      validate_only_ = value;
    }

  virtual util::Status AppendVariable(
        const StringPiece& variable_name,
        const client::UriTemplateConfig& config,
        string* target);

  virtual util::Status AppendOptionalQueryParameters(string* target);


  util::Status ExecuteAndParseResponse(
      LaunchTemplateResponse* data) {
    return DataflowServiceBaseRequest::ExecuteAndParseResponse(data);
  }

 private:
  string project_id_;
  string gcs_path_;
  string location_;
  string dynamic_template_gcs_path_;
  string dynamic_template_staging_location_;
  bool validate_only_;
  bool _have_gcs_path_ : 1;
  bool _have_location_ : 1;
  bool _have_dynamic_template_gcs_path_ : 1;
  bool _have_dynamic_template_staging_location_ : 1;
  bool _have_validate_only_ : 1;  string _content_;
  DISALLOW_COPY_AND_ASSIGN(ProjectsResource_TemplatesResource_LaunchMethod);
};



class DataflowService : public client::ClientService {
 public:
  static const char googleapis_API_NAME[];

  static const char googleapis_API_VERSION[];

  static const char googleapis_API_GENERATOR[];


  class ProjectsResource {
   public:
    explicit ProjectsResource(DataflowService* service);

    ~ProjectsResource() {}

    class JobsResource {
     public:
      explicit JobsResource(DataflowService* service);

      ~JobsResource() {}

      class DebugResource {
       public:
        explicit DebugResource(DataflowService* service);

        ~DebugResource() {}


        ProjectsResource_JobsResource_DebugResource_GetConfigMethod* NewGetConfigMethod(
            client::AuthorizationCredential* _credential_,
            const absl::string_view& project_id,
            const absl::string_view& job_id,
            const GetDebugConfigRequest& _content_) const;

        ProjectsResource_JobsResource_DebugResource_SendCaptureMethod* NewSendCaptureMethod(
            client::AuthorizationCredential* _credential_,
            const absl::string_view& project_id,
            const absl::string_view& job_id,
            const SendDebugCaptureRequest& _content_) const;

       private:
        DataflowService* service_;

        DISALLOW_COPY_AND_ASSIGN(DebugResource);
      };
      const DebugResource& get_debug() const {
        return debug_;
      }


      class MessagesResource {
       public:
        explicit MessagesResource(DataflowService* service);

        ~MessagesResource() {}


        ProjectsResource_JobsResource_MessagesResource_ListMethod* NewListMethod(
            client::AuthorizationCredential* _credential_,
            const absl::string_view& project_id,
            const absl::string_view& job_id) const;

        ProjectsResource_JobsResource_MessagesResource_ListMethodPager* NewListMethodPager(
            client::AuthorizationCredential* _credential_,
            const absl::string_view& project_id,
            const absl::string_view& job_id) const;

       private:
        DataflowService* service_;

        DISALLOW_COPY_AND_ASSIGN(MessagesResource);
      };
      const MessagesResource& get_messages() const {
        return messages_;
      }


      class WorkItemsResource {
       public:
        explicit WorkItemsResource(DataflowService* service);

        ~WorkItemsResource() {}


        ProjectsResource_JobsResource_WorkItemsResource_LeaseMethod* NewLeaseMethod(
            client::AuthorizationCredential* _credential_,
            const absl::string_view& project_id,
            const absl::string_view& job_id,
            const LeaseWorkItemRequest& _content_) const;

        ProjectsResource_JobsResource_WorkItemsResource_ReportStatusMethod* NewReportStatusMethod(
            client::AuthorizationCredential* _credential_,
            const absl::string_view& project_id,
            const absl::string_view& job_id,
            const ReportWorkItemStatusRequest& _content_) const;

       private:
        DataflowService* service_;

        DISALLOW_COPY_AND_ASSIGN(WorkItemsResource);
      };
      const WorkItemsResource& get_work_items() const {
        return work_items_;
      }



      ProjectsResource_JobsResource_AggregatedMethod* NewAggregatedMethod(
          client::AuthorizationCredential* _credential_,
          const absl::string_view& project_id) const;

      ProjectsResource_JobsResource_AggregatedMethodPager* NewAggregatedMethodPager(
          client::AuthorizationCredential* _credential_,
          const absl::string_view& project_id) const;

      ProjectsResource_JobsResource_CreateMethod* NewCreateMethod(
          client::AuthorizationCredential* _credential_,
          const absl::string_view& project_id,
          const Job& _content_) const;

      ProjectsResource_JobsResource_GetMethod* NewGetMethod(
          client::AuthorizationCredential* _credential_,
          const absl::string_view& project_id,
          const absl::string_view& job_id) const;

      ProjectsResource_JobsResource_GetMetricsMethod* NewGetMetricsMethod(
          client::AuthorizationCredential* _credential_,
          const absl::string_view& project_id,
          const absl::string_view& job_id) const;

      ProjectsResource_JobsResource_ListMethod* NewListMethod(
          client::AuthorizationCredential* _credential_,
          const absl::string_view& project_id) const;

      ProjectsResource_JobsResource_ListMethodPager* NewListMethodPager(
          client::AuthorizationCredential* _credential_,
          const absl::string_view& project_id) const;

      ProjectsResource_JobsResource_SnapshotMethod* NewSnapshotMethod(
          client::AuthorizationCredential* _credential_,
          const absl::string_view& project_id,
          const absl::string_view& job_id,
          const SnapshotJobRequest& _content_) const;

      ProjectsResource_JobsResource_UpdateMethod* NewUpdateMethod(
          client::AuthorizationCredential* _credential_,
          const absl::string_view& project_id,
          const absl::string_view& job_id,
          const Job& _content_) const;

     private:
      DataflowService* service_;
      DebugResource debug_;
      MessagesResource messages_;
      WorkItemsResource work_items_;

      DISALLOW_COPY_AND_ASSIGN(JobsResource);
    };
    const JobsResource& get_jobs() const {
      return jobs_;
    }


    class LocationsResource {
     public:
      explicit LocationsResource(DataflowService* service);

      ~LocationsResource() {}

      class FlexTemplatesResource {
       public:
        explicit FlexTemplatesResource(DataflowService* service);

        ~FlexTemplatesResource() {}


        ProjectsResource_LocationsResource_FlexTemplatesResource_LaunchMethod* NewLaunchMethod(
            client::AuthorizationCredential* _credential_,
            const absl::string_view& project_id,
            const absl::string_view& location,
            const LaunchFlexTemplateRequest& _content_) const;

       private:
        DataflowService* service_;

        DISALLOW_COPY_AND_ASSIGN(FlexTemplatesResource);
      };
      const FlexTemplatesResource& get_flex_templates() const {
        return flex_templates_;
      }


      class JobsResource {
       public:
        explicit JobsResource(DataflowService* service);

        ~JobsResource() {}

        class DebugResource {
         public:
          explicit DebugResource(DataflowService* service);

          ~DebugResource() {}


          ProjectsResource_LocationsResource_JobsResource_DebugResource_GetConfigMethod* NewGetConfigMethod(
              client::AuthorizationCredential* _credential_,
              const absl::string_view& project_id,
              const absl::string_view& location,
              const absl::string_view& job_id,
              const GetDebugConfigRequest& _content_) const;

          ProjectsResource_LocationsResource_JobsResource_DebugResource_SendCaptureMethod* NewSendCaptureMethod(
              client::AuthorizationCredential* _credential_,
              const absl::string_view& project_id,
              const absl::string_view& location,
              const absl::string_view& job_id,
              const SendDebugCaptureRequest& _content_) const;

         private:
          DataflowService* service_;

          DISALLOW_COPY_AND_ASSIGN(DebugResource);
        };
        const DebugResource& get_debug() const {
          return debug_;
        }


        class MessagesResource {
         public:
          explicit MessagesResource(DataflowService* service);

          ~MessagesResource() {}


          ProjectsResource_LocationsResource_JobsResource_MessagesResource_ListMethod* NewListMethod(
              client::AuthorizationCredential* _credential_,
              const absl::string_view& project_id,
              const absl::string_view& location,
              const absl::string_view& job_id) const;

          ProjectsResource_LocationsResource_JobsResource_MessagesResource_ListMethodPager* NewListMethodPager(
              client::AuthorizationCredential* _credential_,
              const absl::string_view& project_id,
              const absl::string_view& location,
              const absl::string_view& job_id) const;

         private:
          DataflowService* service_;

          DISALLOW_COPY_AND_ASSIGN(MessagesResource);
        };
        const MessagesResource& get_messages() const {
          return messages_;
        }


        class SnapshotsResource {
         public:
          explicit SnapshotsResource(DataflowService* service);

          ~SnapshotsResource() {}


          ProjectsResource_LocationsResource_JobsResource_SnapshotsResource_ListMethod* NewListMethod(
              client::AuthorizationCredential* _credential_,
              const absl::string_view& project_id,
              const absl::string_view& location,
              const absl::string_view& job_id) const;

         private:
          DataflowService* service_;

          DISALLOW_COPY_AND_ASSIGN(SnapshotsResource);
        };
        const SnapshotsResource& get_snapshots() const {
          return snapshots_;
        }


        class WorkItemsResource {
         public:
          explicit WorkItemsResource(DataflowService* service);

          ~WorkItemsResource() {}


          ProjectsResource_LocationsResource_JobsResource_WorkItemsResource_LeaseMethod* NewLeaseMethod(
              client::AuthorizationCredential* _credential_,
              const absl::string_view& project_id,
              const absl::string_view& location,
              const absl::string_view& job_id,
              const LeaseWorkItemRequest& _content_) const;

          ProjectsResource_LocationsResource_JobsResource_WorkItemsResource_ReportStatusMethod* NewReportStatusMethod(
              client::AuthorizationCredential* _credential_,
              const absl::string_view& project_id,
              const absl::string_view& location,
              const absl::string_view& job_id,
              const ReportWorkItemStatusRequest& _content_) const;

         private:
          DataflowService* service_;

          DISALLOW_COPY_AND_ASSIGN(WorkItemsResource);
        };
        const WorkItemsResource& get_work_items() const {
          return work_items_;
        }



        ProjectsResource_LocationsResource_JobsResource_CreateMethod* NewCreateMethod(
            client::AuthorizationCredential* _credential_,
            const absl::string_view& project_id,
            const absl::string_view& location,
            const Job& _content_) const;

        ProjectsResource_LocationsResource_JobsResource_GetMethod* NewGetMethod(
            client::AuthorizationCredential* _credential_,
            const absl::string_view& project_id,
            const absl::string_view& location,
            const absl::string_view& job_id) const;

        ProjectsResource_LocationsResource_JobsResource_GetMetricsMethod* NewGetMetricsMethod(
            client::AuthorizationCredential* _credential_,
            const absl::string_view& project_id,
            const absl::string_view& location,
            const absl::string_view& job_id) const;

        ProjectsResource_LocationsResource_JobsResource_ListMethod* NewListMethod(
            client::AuthorizationCredential* _credential_,
            const absl::string_view& project_id,
            const absl::string_view& location) const;

        ProjectsResource_LocationsResource_JobsResource_ListMethodPager* NewListMethodPager(
            client::AuthorizationCredential* _credential_,
            const absl::string_view& project_id,
            const absl::string_view& location) const;

        ProjectsResource_LocationsResource_JobsResource_SnapshotMethod* NewSnapshotMethod(
            client::AuthorizationCredential* _credential_,
            const absl::string_view& project_id,
            const absl::string_view& location,
            const absl::string_view& job_id,
            const SnapshotJobRequest& _content_) const;

        ProjectsResource_LocationsResource_JobsResource_UpdateMethod* NewUpdateMethod(
            client::AuthorizationCredential* _credential_,
            const absl::string_view& project_id,
            const absl::string_view& location,
            const absl::string_view& job_id,
            const Job& _content_) const;

       private:
        DataflowService* service_;
        DebugResource debug_;
        MessagesResource messages_;
        SnapshotsResource snapshots_;
        WorkItemsResource work_items_;

        DISALLOW_COPY_AND_ASSIGN(JobsResource);
      };
      const JobsResource& get_jobs() const {
        return jobs_;
      }


      class SnapshotsResource {
       public:
        explicit SnapshotsResource(DataflowService* service);

        ~SnapshotsResource() {}


        ProjectsResource_LocationsResource_SnapshotsResource_DeleteMethod* NewDeleteMethod(
            client::AuthorizationCredential* _credential_,
            const absl::string_view& project_id,
            const absl::string_view& location,
            const absl::string_view& snapshot_id) const;

        ProjectsResource_LocationsResource_SnapshotsResource_GetMethod* NewGetMethod(
            client::AuthorizationCredential* _credential_,
            const absl::string_view& project_id,
            const absl::string_view& location,
            const absl::string_view& snapshot_id) const;

        ProjectsResource_LocationsResource_SnapshotsResource_ListMethod* NewListMethod(
            client::AuthorizationCredential* _credential_,
            const absl::string_view& project_id,
            const absl::string_view& location) const;

       private:
        DataflowService* service_;

        DISALLOW_COPY_AND_ASSIGN(SnapshotsResource);
      };
      const SnapshotsResource& get_snapshots() const {
        return snapshots_;
      }


      class SqlResource {
       public:
        explicit SqlResource(DataflowService* service);

        ~SqlResource() {}


        ProjectsResource_LocationsResource_SqlResource_ValidateMethod* NewValidateMethod(
            client::AuthorizationCredential* _credential_,
            const absl::string_view& project_id,
            const absl::string_view& location) const;

       private:
        DataflowService* service_;

        DISALLOW_COPY_AND_ASSIGN(SqlResource);
      };
      const SqlResource& get_sql() const {
        return sql_;
      }


      class TemplatesResource {
       public:
        explicit TemplatesResource(DataflowService* service);

        ~TemplatesResource() {}


        ProjectsResource_LocationsResource_TemplatesResource_CreateMethod* NewCreateMethod(
            client::AuthorizationCredential* _credential_,
            const absl::string_view& project_id,
            const absl::string_view& location,
            const CreateJobFromTemplateRequest& _content_) const;

        ProjectsResource_LocationsResource_TemplatesResource_GetMethod* NewGetMethod(
            client::AuthorizationCredential* _credential_,
            const absl::string_view& project_id,
            const absl::string_view& location) const;

        ProjectsResource_LocationsResource_TemplatesResource_LaunchMethod* NewLaunchMethod(
            client::AuthorizationCredential* _credential_,
            const absl::string_view& project_id,
            const absl::string_view& location,
            const LaunchTemplateParameters& _content_) const;

       private:
        DataflowService* service_;

        DISALLOW_COPY_AND_ASSIGN(TemplatesResource);
      };
      const TemplatesResource& get_templates() const {
        return templates_;
      }



      ProjectsResource_LocationsResource_WorkerMessagesMethod* NewWorkerMessagesMethod(
          client::AuthorizationCredential* _credential_,
          const absl::string_view& project_id,
          const absl::string_view& location,
          const SendWorkerMessagesRequest& _content_) const;

     private:
      DataflowService* service_;
      FlexTemplatesResource flex_templates_;
      JobsResource jobs_;
      SnapshotsResource snapshots_;
      SqlResource sql_;
      TemplatesResource templates_;

      DISALLOW_COPY_AND_ASSIGN(LocationsResource);
    };
    const LocationsResource& get_locations() const {
      return locations_;
    }


    class SnapshotsResource {
     public:
      explicit SnapshotsResource(DataflowService* service);

      ~SnapshotsResource() {}


      ProjectsResource_SnapshotsResource_GetMethod* NewGetMethod(
          client::AuthorizationCredential* _credential_,
          const absl::string_view& project_id,
          const absl::string_view& snapshot_id) const;

      ProjectsResource_SnapshotsResource_ListMethod* NewListMethod(
          client::AuthorizationCredential* _credential_,
          const absl::string_view& project_id) const;

     private:
      DataflowService* service_;

      DISALLOW_COPY_AND_ASSIGN(SnapshotsResource);
    };
    const SnapshotsResource& get_snapshots() const {
      return snapshots_;
    }


    class TemplatesResource {
     public:
      explicit TemplatesResource(DataflowService* service);

      ~TemplatesResource() {}


      ProjectsResource_TemplatesResource_CreateMethod* NewCreateMethod(
          client::AuthorizationCredential* _credential_,
          const absl::string_view& project_id,
          const CreateJobFromTemplateRequest& _content_) const;

      ProjectsResource_TemplatesResource_GetMethod* NewGetMethod(
          client::AuthorizationCredential* _credential_,
          const absl::string_view& project_id) const;

      ProjectsResource_TemplatesResource_LaunchMethod* NewLaunchMethod(
          client::AuthorizationCredential* _credential_,
          const absl::string_view& project_id,
          const LaunchTemplateParameters& _content_) const;

     private:
      DataflowService* service_;

      DISALLOW_COPY_AND_ASSIGN(TemplatesResource);
    };
    const TemplatesResource& get_templates() const {
      return templates_;
    }



    ProjectsResource_DeleteSnapshotsMethod* NewDeleteSnapshotsMethod(
        client::AuthorizationCredential* _credential_,
        const absl::string_view& project_id) const;

    ProjectsResource_WorkerMessagesMethod* NewWorkerMessagesMethod(
        client::AuthorizationCredential* _credential_,
        const absl::string_view& project_id,
        const SendWorkerMessagesRequest& _content_) const;

   private:
    DataflowService* service_;
    JobsResource jobs_;
    LocationsResource locations_;
    SnapshotsResource snapshots_;
    TemplatesResource templates_;

    DISALLOW_COPY_AND_ASSIGN(ProjectsResource);
  };



  explicit DataflowService(client::HttpTransport* transport);

  virtual ~DataflowService();

  const ProjectsResource& get_projects() const {
    return projects_;
  }

  class SCOPES {
   public:
    static const char CLOUD_PLATFORM[];

    static const char COMPUTE[];

    static const char COMPUTE_READONLY[];

    static const char USERINFO_EMAIL[];

   private:
    SCOPES();  // Never instantiated.
    ~SCOPES();  // Never instantiated.
  };

 private:
  ProjectsResource projects_;

  DISALLOW_COPY_AND_ASSIGN(DataflowService);
};


}  // namespace google_dataflow_api
#endif  // GOOGLE_DATAFLOW_API_DATAFLOW_SERVICE_H_