Source file src/google.golang.org/api/datafusion/v1/datafusion-gen.go

Documentation: google.golang.org/api/datafusion/v1

     1  // Copyright 2024 Google LLC.
     2  // Use of this source code is governed by a BSD-style
     3  // license that can be found in the LICENSE file.
     4  
     5  // Code generated file. DO NOT EDIT.
     6  
     7  // Package datafusion provides access to the Cloud Data Fusion API.
     8  //
     9  // For product documentation, see: https://cloud.google.com/data-fusion/docs
    10  //
    11  // # Library status
    12  //
    13  // These client libraries are officially supported by Google. However, this
    14  // library is considered complete and is in maintenance mode. This means
    15  // that we will address critical bugs and security issues but will not add
    16  // any new features.
    17  //
    18  // When possible, we recommend using our newer
    19  // [Cloud Client Libraries for Go](https://pkg.go.dev/cloud.google.com/go)
    20  // that are still actively being worked and iterated on.
    21  //
    22  // # Creating a client
    23  //
    24  // Usage example:
    25  //
    26  //	import "google.golang.org/api/datafusion/v1"
    27  //	...
    28  //	ctx := context.Background()
    29  //	datafusionService, err := datafusion.NewService(ctx)
    30  //
    31  // In this example, Google Application Default Credentials are used for
    32  // authentication. For information on how to create and obtain Application
    33  // Default Credentials, see https://developers.google.com/identity/protocols/application-default-credentials.
    34  //
    35  // # Other authentication options
    36  //
    37  // To use an API key for authentication (note: some APIs do not support API
    38  // keys), use [google.golang.org/api/option.WithAPIKey]:
    39  //
    40  //	datafusionService, err := datafusion.NewService(ctx, option.WithAPIKey("AIza..."))
    41  //
    42  // To use an OAuth token (e.g., a user token obtained via a three-legged OAuth
    43  // flow, use [google.golang.org/api/option.WithTokenSource]:
    44  //
    45  //	config := &oauth2.Config{...}
    46  //	// ...
    47  //	token, err := config.Exchange(ctx, ...)
    48  //	datafusionService, err := datafusion.NewService(ctx, option.WithTokenSource(config.TokenSource(ctx, token)))
    49  //
    50  // See [google.golang.org/api/option.ClientOption] for details on options.
    51  package datafusion // import "google.golang.org/api/datafusion/v1"
    52  
    53  import (
    54  	"bytes"
    55  	"context"
    56  	"encoding/json"
    57  	"errors"
    58  	"fmt"
    59  	"io"
    60  	"net/http"
    61  	"net/url"
    62  	"strconv"
    63  	"strings"
    64  
    65  	googleapi "google.golang.org/api/googleapi"
    66  	internal "google.golang.org/api/internal"
    67  	gensupport "google.golang.org/api/internal/gensupport"
    68  	option "google.golang.org/api/option"
    69  	internaloption "google.golang.org/api/option/internaloption"
    70  	htransport "google.golang.org/api/transport/http"
    71  )
    72  
    73  // Always reference these packages, just in case the auto-generated code
    74  // below doesn't.
    75  var _ = bytes.NewBuffer
    76  var _ = strconv.Itoa
    77  var _ = fmt.Sprintf
    78  var _ = json.NewDecoder
    79  var _ = io.Copy
    80  var _ = url.Parse
    81  var _ = gensupport.MarshalJSON
    82  var _ = googleapi.Version
    83  var _ = errors.New
    84  var _ = strings.Replace
    85  var _ = context.Canceled
    86  var _ = internaloption.WithDefaultEndpoint
    87  var _ = internal.Version
    88  
    89  const apiId = "datafusion:v1"
    90  const apiName = "datafusion"
    91  const apiVersion = "v1"
    92  const basePath = "https://datafusion.googleapis.com/"
    93  const basePathTemplate = "https://datafusion.UNIVERSE_DOMAIN/"
    94  const mtlsBasePath = "https://datafusion.mtls.googleapis.com/"
    95  
    96  // OAuth2 scopes used by this API.
    97  const (
    98  	// See, edit, configure, and delete your Google Cloud data and see the email
    99  	// address for your Google Account.
   100  	CloudPlatformScope = "https://www.googleapis.com/auth/cloud-platform"
   101  )
   102  
   103  // NewService creates a new Service.
   104  func NewService(ctx context.Context, opts ...option.ClientOption) (*Service, error) {
   105  	scopesOption := internaloption.WithDefaultScopes(
   106  		"https://www.googleapis.com/auth/cloud-platform",
   107  	)
   108  	// NOTE: prepend, so we don't override user-specified scopes.
   109  	opts = append([]option.ClientOption{scopesOption}, opts...)
   110  	opts = append(opts, internaloption.WithDefaultEndpoint(basePath))
   111  	opts = append(opts, internaloption.WithDefaultEndpointTemplate(basePathTemplate))
   112  	opts = append(opts, internaloption.WithDefaultMTLSEndpoint(mtlsBasePath))
   113  	opts = append(opts, internaloption.EnableNewAuthLibrary())
   114  	client, endpoint, err := htransport.NewClient(ctx, opts...)
   115  	if err != nil {
   116  		return nil, err
   117  	}
   118  	s, err := New(client)
   119  	if err != nil {
   120  		return nil, err
   121  	}
   122  	if endpoint != "" {
   123  		s.BasePath = endpoint
   124  	}
   125  	return s, nil
   126  }
   127  
   128  // New creates a new Service. It uses the provided http.Client for requests.
   129  //
   130  // Deprecated: please use NewService instead.
   131  // To provide a custom HTTP client, use option.WithHTTPClient.
   132  // If you are using google.golang.org/api/googleapis/transport.APIKey, use option.WithAPIKey with NewService instead.
   133  func New(client *http.Client) (*Service, error) {
   134  	if client == nil {
   135  		return nil, errors.New("client is nil")
   136  	}
   137  	s := &Service{client: client, BasePath: basePath}
   138  	s.Projects = NewProjectsService(s)
   139  	return s, nil
   140  }
   141  
   142  type Service struct {
   143  	client    *http.Client
   144  	BasePath  string // API endpoint base URL
   145  	UserAgent string // optional additional User-Agent fragment
   146  
   147  	Projects *ProjectsService
   148  }
   149  
   150  func (s *Service) userAgent() string {
   151  	if s.UserAgent == "" {
   152  		return googleapi.UserAgent
   153  	}
   154  	return googleapi.UserAgent + " " + s.UserAgent
   155  }
   156  
   157  func NewProjectsService(s *Service) *ProjectsService {
   158  	rs := &ProjectsService{s: s}
   159  	rs.Locations = NewProjectsLocationsService(s)
   160  	return rs
   161  }
   162  
   163  type ProjectsService struct {
   164  	s *Service
   165  
   166  	Locations *ProjectsLocationsService
   167  }
   168  
   169  func NewProjectsLocationsService(s *Service) *ProjectsLocationsService {
   170  	rs := &ProjectsLocationsService{s: s}
   171  	rs.Instances = NewProjectsLocationsInstancesService(s)
   172  	rs.Operations = NewProjectsLocationsOperationsService(s)
   173  	rs.Versions = NewProjectsLocationsVersionsService(s)
   174  	return rs
   175  }
   176  
   177  type ProjectsLocationsService struct {
   178  	s *Service
   179  
   180  	Instances *ProjectsLocationsInstancesService
   181  
   182  	Operations *ProjectsLocationsOperationsService
   183  
   184  	Versions *ProjectsLocationsVersionsService
   185  }
   186  
   187  func NewProjectsLocationsInstancesService(s *Service) *ProjectsLocationsInstancesService {
   188  	rs := &ProjectsLocationsInstancesService{s: s}
   189  	rs.DnsPeerings = NewProjectsLocationsInstancesDnsPeeringsService(s)
   190  	return rs
   191  }
   192  
   193  type ProjectsLocationsInstancesService struct {
   194  	s *Service
   195  
   196  	DnsPeerings *ProjectsLocationsInstancesDnsPeeringsService
   197  }
   198  
   199  func NewProjectsLocationsInstancesDnsPeeringsService(s *Service) *ProjectsLocationsInstancesDnsPeeringsService {
   200  	rs := &ProjectsLocationsInstancesDnsPeeringsService{s: s}
   201  	return rs
   202  }
   203  
   204  type ProjectsLocationsInstancesDnsPeeringsService struct {
   205  	s *Service
   206  }
   207  
   208  func NewProjectsLocationsOperationsService(s *Service) *ProjectsLocationsOperationsService {
   209  	rs := &ProjectsLocationsOperationsService{s: s}
   210  	return rs
   211  }
   212  
   213  type ProjectsLocationsOperationsService struct {
   214  	s *Service
   215  }
   216  
   217  func NewProjectsLocationsVersionsService(s *Service) *ProjectsLocationsVersionsService {
   218  	rs := &ProjectsLocationsVersionsService{s: s}
   219  	return rs
   220  }
   221  
   222  type ProjectsLocationsVersionsService struct {
   223  	s *Service
   224  }
   225  
   226  // Accelerator: Identifies Data Fusion accelerators for an instance.
   227  type Accelerator struct {
   228  	// AcceleratorType: The type of an accelator for a CDF instance.
   229  	//
   230  	// Possible values:
   231  	//   "ACCELERATOR_TYPE_UNSPECIFIED" - Default value, if unspecified.
   232  	//   "CDC" - Change Data Capture accelerator for CDF.
   233  	//   "HEALTHCARE" - Cloud Healthcare accelerator for CDF. This accelerator is
   234  	// to enable Cloud Healthcare specific CDF plugins developed by Healthcare
   235  	// team.
   236  	//   "CCAI_INSIGHTS" - Contact Center AI Insights This accelerator is used to
   237  	// enable import and export pipelines custom built to streamline CCAI Insights
   238  	// processing.
   239  	//   "CLOUDSEARCH" - Cloud search accelerator for CDF. This accelerator is to
   240  	// enable Cloud search specific CDF plugins developed by Cloudsearch team.
   241  	AcceleratorType string `json:"acceleratorType,omitempty"`
   242  	// State: The state of the accelerator.
   243  	//
   244  	// Possible values:
   245  	//   "STATE_UNSPECIFIED" - Default value, do not use.
   246  	//   "ENABLED" - Indicates that the accelerator is enabled and available to
   247  	// use.
   248  	//   "DISABLED" - Indicates that the accelerator is disabled and not available
   249  	// to use.
   250  	//   "UNKNOWN" - Indicates that accelerator state is currently unknown.
   251  	// Requests for enable, disable could be retried while in this state.
   252  	State string `json:"state,omitempty"`
   253  	// ForceSendFields is a list of field names (e.g. "AcceleratorType") to
   254  	// unconditionally include in API requests. By default, fields with empty or
   255  	// default values are omitted from API requests. See
   256  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   257  	// details.
   258  	ForceSendFields []string `json:"-"`
   259  	// NullFields is a list of field names (e.g. "AcceleratorType") to include in
   260  	// API requests with the JSON null value. By default, fields with empty values
   261  	// are omitted from API requests. See
   262  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   263  	NullFields []string `json:"-"`
   264  }
   265  
   266  func (s *Accelerator) MarshalJSON() ([]byte, error) {
   267  	type NoMethod Accelerator
   268  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   269  }
   270  
   271  // AuditConfig: Specifies the audit configuration for a service. The
   272  // configuration determines which permission types are logged, and what
   273  // identities, if any, are exempted from logging. An AuditConfig must have one
   274  // or more AuditLogConfigs. If there are AuditConfigs for both `allServices`
   275  // and a specific service, the union of the two AuditConfigs is used for that
   276  // service: the log_types specified in each AuditConfig are enabled, and the
   277  // exempted_members in each AuditLogConfig are exempted. Example Policy with
   278  // multiple AuditConfigs: { "audit_configs": [ { "service": "allServices",
   279  // "audit_log_configs": [ { "log_type": "DATA_READ", "exempted_members": [
   280  // "user:jose@example.com" ] }, { "log_type": "DATA_WRITE" }, { "log_type":
   281  // "ADMIN_READ" } ] }, { "service": "sampleservice.googleapis.com",
   282  // "audit_log_configs": [ { "log_type": "DATA_READ" }, { "log_type":
   283  // "DATA_WRITE", "exempted_members": [ "user:aliya@example.com" ] } ] } ] } For
   284  // sampleservice, this policy enables DATA_READ, DATA_WRITE and ADMIN_READ
   285  // logging. It also exempts `jose@example.com` from DATA_READ logging, and
   286  // `aliya@example.com` from DATA_WRITE logging.
   287  type AuditConfig struct {
   288  	// AuditLogConfigs: The configuration for logging of each type of permission.
   289  	AuditLogConfigs []*AuditLogConfig `json:"auditLogConfigs,omitempty"`
   290  	// Service: Specifies a service that will be enabled for audit logging. For
   291  	// example, `storage.googleapis.com`, `cloudsql.googleapis.com`. `allServices`
   292  	// is a special value that covers all services.
   293  	Service string `json:"service,omitempty"`
   294  	// ForceSendFields is a list of field names (e.g. "AuditLogConfigs") to
   295  	// unconditionally include in API requests. By default, fields with empty or
   296  	// default values are omitted from API requests. See
   297  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   298  	// details.
   299  	ForceSendFields []string `json:"-"`
   300  	// NullFields is a list of field names (e.g. "AuditLogConfigs") to include in
   301  	// API requests with the JSON null value. By default, fields with empty values
   302  	// are omitted from API requests. See
   303  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   304  	NullFields []string `json:"-"`
   305  }
   306  
   307  func (s *AuditConfig) MarshalJSON() ([]byte, error) {
   308  	type NoMethod AuditConfig
   309  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   310  }
   311  
   312  // AuditLogConfig: Provides the configuration for logging a type of
   313  // permissions. Example: { "audit_log_configs": [ { "log_type": "DATA_READ",
   314  // "exempted_members": [ "user:jose@example.com" ] }, { "log_type":
   315  // "DATA_WRITE" } ] } This enables 'DATA_READ' and 'DATA_WRITE' logging, while
   316  // exempting jose@example.com from DATA_READ logging.
   317  type AuditLogConfig struct {
   318  	// ExemptedMembers: Specifies the identities that do not cause logging for this
   319  	// type of permission. Follows the same format of Binding.members.
   320  	ExemptedMembers []string `json:"exemptedMembers,omitempty"`
   321  	// LogType: The log type that this config enables.
   322  	//
   323  	// Possible values:
   324  	//   "LOG_TYPE_UNSPECIFIED" - Default case. Should never be this.
   325  	//   "ADMIN_READ" - Admin reads. Example: CloudIAM getIamPolicy
   326  	//   "DATA_WRITE" - Data writes. Example: CloudSQL Users create
   327  	//   "DATA_READ" - Data reads. Example: CloudSQL Users list
   328  	LogType string `json:"logType,omitempty"`
   329  	// ForceSendFields is a list of field names (e.g. "ExemptedMembers") to
   330  	// unconditionally include in API requests. By default, fields with empty or
   331  	// default values are omitted from API requests. See
   332  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   333  	// details.
   334  	ForceSendFields []string `json:"-"`
   335  	// NullFields is a list of field names (e.g. "ExemptedMembers") to include in
   336  	// API requests with the JSON null value. By default, fields with empty values
   337  	// are omitted from API requests. See
   338  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   339  	NullFields []string `json:"-"`
   340  }
   341  
   342  func (s *AuditLogConfig) MarshalJSON() ([]byte, error) {
   343  	type NoMethod AuditLogConfig
   344  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   345  }
   346  
   347  // Binding: Associates `members`, or principals, with a `role`.
   348  type Binding struct {
   349  	// Condition: The condition that is associated with this binding. If the
   350  	// condition evaluates to `true`, then this binding applies to the current
   351  	// request. If the condition evaluates to `false`, then this binding does not
   352  	// apply to the current request. However, a different role binding might grant
   353  	// the same role to one or more of the principals in this binding. To learn
   354  	// which resources support conditions in their IAM policies, see the IAM
   355  	// documentation
   356  	// (https://cloud.google.com/iam/help/conditions/resource-policies).
   357  	Condition *Expr `json:"condition,omitempty"`
   358  	// Members: Specifies the principals requesting access for a Google Cloud
   359  	// resource. `members` can have the following values: * `allUsers`: A special
   360  	// identifier that represents anyone who is on the internet; with or without a
   361  	// Google account. * `allAuthenticatedUsers`: A special identifier that
   362  	// represents anyone who is authenticated with a Google account or a service
   363  	// account. Does not include identities that come from external identity
   364  	// providers (IdPs) through identity federation. * `user:{emailid}`: An email
   365  	// address that represents a specific Google account. For example,
   366  	// `alice@example.com` . * `serviceAccount:{emailid}`: An email address that
   367  	// represents a Google service account. For example,
   368  	// `my-other-app@appspot.gserviceaccount.com`. *
   369  	// `serviceAccount:{projectid}.svc.id.goog[{namespace}/{kubernetes-sa}]`: An
   370  	// identifier for a Kubernetes service account
   371  	// (https://cloud.google.com/kubernetes-engine/docs/how-to/kubernetes-service-accounts).
   372  	// For example, `my-project.svc.id.goog[my-namespace/my-kubernetes-sa]`. *
   373  	// `group:{emailid}`: An email address that represents a Google group. For
   374  	// example, `admins@example.com`. * `domain:{domain}`: The G Suite domain
   375  	// (primary) that represents all the users of that domain. For example,
   376  	// `google.com` or `example.com`. *
   377  	// `principal://iam.googleapis.com/locations/global/workforcePools/{pool_id}/sub
   378  	// ject/{subject_attribute_value}`: A single identity in a workforce identity
   379  	// pool. *
   380  	// `principalSet://iam.googleapis.com/locations/global/workforcePools/{pool_id}/
   381  	// group/{group_id}`: All workforce identities in a group. *
   382  	// `principalSet://iam.googleapis.com/locations/global/workforcePools/{pool_id}/
   383  	// attribute.{attribute_name}/{attribute_value}`: All workforce identities with
   384  	// a specific attribute value. *
   385  	// `principalSet://iam.googleapis.com/locations/global/workforcePools/{pool_id}/
   386  	// *`: All identities in a workforce identity pool. *
   387  	// `principal://iam.googleapis.com/projects/{project_number}/locations/global/wo
   388  	// rkloadIdentityPools/{pool_id}/subject/{subject_attribute_value}`: A single
   389  	// identity in a workload identity pool. *
   390  	// `principalSet://iam.googleapis.com/projects/{project_number}/locations/global
   391  	// /workloadIdentityPools/{pool_id}/group/{group_id}`: A workload identity pool
   392  	// group. *
   393  	// `principalSet://iam.googleapis.com/projects/{project_number}/locations/global
   394  	// /workloadIdentityPools/{pool_id}/attribute.{attribute_name}/{attribute_value}
   395  	// `: All identities in a workload identity pool with a certain attribute. *
   396  	// `principalSet://iam.googleapis.com/projects/{project_number}/locations/global
   397  	// /workloadIdentityPools/{pool_id}/*`: All identities in a workload identity
   398  	// pool. * `deleted:user:{emailid}?uid={uniqueid}`: An email address (plus
   399  	// unique identifier) representing a user that has been recently deleted. For
   400  	// example, `alice@example.com?uid=123456789012345678901`. If the user is
   401  	// recovered, this value reverts to `user:{emailid}` and the recovered user
   402  	// retains the role in the binding. *
   403  	// `deleted:serviceAccount:{emailid}?uid={uniqueid}`: An email address (plus
   404  	// unique identifier) representing a service account that has been recently
   405  	// deleted. For example,
   406  	// `my-other-app@appspot.gserviceaccount.com?uid=123456789012345678901`. If the
   407  	// service account is undeleted, this value reverts to
   408  	// `serviceAccount:{emailid}` and the undeleted service account retains the
   409  	// role in the binding. * `deleted:group:{emailid}?uid={uniqueid}`: An email
   410  	// address (plus unique identifier) representing a Google group that has been
   411  	// recently deleted. For example,
   412  	// `admins@example.com?uid=123456789012345678901`. If the group is recovered,
   413  	// this value reverts to `group:{emailid}` and the recovered group retains the
   414  	// role in the binding. *
   415  	// `deleted:principal://iam.googleapis.com/locations/global/workforcePools/{pool
   416  	// _id}/subject/{subject_attribute_value}`: Deleted single identity in a
   417  	// workforce identity pool. For example,
   418  	// `deleted:principal://iam.googleapis.com/locations/global/workforcePools/my-po
   419  	// ol-id/subject/my-subject-attribute-value`.
   420  	Members []string `json:"members,omitempty"`
   421  	// Role: Role that is assigned to the list of `members`, or principals. For
   422  	// example, `roles/viewer`, `roles/editor`, or `roles/owner`.
   423  	Role string `json:"role,omitempty"`
   424  	// ForceSendFields is a list of field names (e.g. "Condition") to
   425  	// unconditionally include in API requests. By default, fields with empty or
   426  	// default values are omitted from API requests. See
   427  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   428  	// details.
   429  	ForceSendFields []string `json:"-"`
   430  	// NullFields is a list of field names (e.g. "Condition") to include in API
   431  	// requests with the JSON null value. By default, fields with empty values are
   432  	// omitted from API requests. See
   433  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   434  	NullFields []string `json:"-"`
   435  }
   436  
   437  func (s *Binding) MarshalJSON() ([]byte, error) {
   438  	type NoMethod Binding
   439  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   440  }
   441  
   442  // CancelOperationRequest: The request message for Operations.CancelOperation.
   443  type CancelOperationRequest struct {
   444  }
   445  
   446  // CryptoKeyConfig: The crypto key configuration. This field is used by the
   447  // Customer-managed encryption keys (CMEK) feature.
   448  type CryptoKeyConfig struct {
   449  	// KeyReference: The name of the key which is used to encrypt/decrypt customer
   450  	// data. For key in Cloud KMS, the key should be in the format of
   451  	// `projects/*/locations/*/keyRings/*/cryptoKeys/*`.
   452  	KeyReference string `json:"keyReference,omitempty"`
   453  	// ForceSendFields is a list of field names (e.g. "KeyReference") to
   454  	// unconditionally include in API requests. By default, fields with empty or
   455  	// default values are omitted from API requests. See
   456  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   457  	// details.
   458  	ForceSendFields []string `json:"-"`
   459  	// NullFields is a list of field names (e.g. "KeyReference") to include in API
   460  	// requests with the JSON null value. By default, fields with empty values are
   461  	// omitted from API requests. See
   462  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   463  	NullFields []string `json:"-"`
   464  }
   465  
   466  func (s *CryptoKeyConfig) MarshalJSON() ([]byte, error) {
   467  	type NoMethod CryptoKeyConfig
   468  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   469  }
   470  
   471  // DataResidencyAugmentedView: Next tag: 7
   472  type DataResidencyAugmentedView struct {
   473  	// CrGopoGuris: Cloud resource to Google owned production object mapping in the
   474  	// form of GURIs. The GURIs should be available in DG KB storage/cns tables.
   475  	// This is the preferred way of providing cloud resource mappings. For further
   476  	// details please read go/cloud-resource-monitoring_sig
   477  	CrGopoGuris []string `json:"crGopoGuris,omitempty"`
   478  	// CrGopoPrefixes: Cloud resource to Google owned production object mapping in
   479  	// the form of prefixes. These should be available in DG KB storage/cns tables.
   480  	// The entity type, which is the part of the string before the first colon in
   481  	// the GURI, must be completely specified in prefix. For details about GURI
   482  	// please read go/guri. For further details about the field please read
   483  	// go/cloud-resource-monitoring_sig.
   484  	CrGopoPrefixes []string `json:"crGopoPrefixes,omitempty"`
   485  	// ServiceData: Service-specific data. Only required for pre-determined
   486  	// services. Generally used to bind a Cloud Resource to some a TI container
   487  	// that uniquely specifies a customer. See milestone 2 of DRZ KR8 SIG for more
   488  	// information.
   489  	ServiceData *ServiceData `json:"serviceData,omitempty"`
   490  	// TpIds: The list of project_id's of the tenant projects in the 'google.com'
   491  	// org which serve the Cloud Resource. See go/drz-mst-sig for more details.
   492  	TpIds []string `json:"tpIds,omitempty"`
   493  	// ForceSendFields is a list of field names (e.g. "CrGopoGuris") to
   494  	// unconditionally include in API requests. By default, fields with empty or
   495  	// default values are omitted from API requests. See
   496  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   497  	// details.
   498  	ForceSendFields []string `json:"-"`
   499  	// NullFields is a list of field names (e.g. "CrGopoGuris") to include in API
   500  	// requests with the JSON null value. By default, fields with empty values are
   501  	// omitted from API requests. See
   502  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   503  	NullFields []string `json:"-"`
   504  }
   505  
   506  func (s *DataResidencyAugmentedView) MarshalJSON() ([]byte, error) {
   507  	type NoMethod DataResidencyAugmentedView
   508  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   509  }
   510  
   511  // DnsPeering: DNS peering configuration. These configurations are used to
   512  // create DNS peering with the customer Cloud DNS.
   513  type DnsPeering struct {
   514  	// Description: Optional. Optional description of the dns zone.
   515  	Description string `json:"description,omitempty"`
   516  	// Domain: Required. The dns name suffix of the zone.
   517  	Domain string `json:"domain,omitempty"`
   518  	// Name: Required. The resource name of the dns peering zone. Format:
   519  	// projects/{project}/locations/{location}/instances/{instance}/dnsPeerings/{dns
   520  	// _peering}
   521  	Name string `json:"name,omitempty"`
   522  	// TargetNetwork: Optional. Optional target network to which dns peering should
   523  	// happen.
   524  	TargetNetwork string `json:"targetNetwork,omitempty"`
   525  	// TargetProject: Optional. Optional target project to which dns peering should
   526  	// happen.
   527  	TargetProject string `json:"targetProject,omitempty"`
   528  
   529  	// ServerResponse contains the HTTP response code and headers from the server.
   530  	googleapi.ServerResponse `json:"-"`
   531  	// ForceSendFields is a list of field names (e.g. "Description") to
   532  	// unconditionally include in API requests. By default, fields with empty or
   533  	// default values are omitted from API requests. See
   534  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   535  	// details.
   536  	ForceSendFields []string `json:"-"`
   537  	// NullFields is a list of field names (e.g. "Description") to include in API
   538  	// requests with the JSON null value. By default, fields with empty values are
   539  	// omitted from API requests. See
   540  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   541  	NullFields []string `json:"-"`
   542  }
   543  
   544  func (s *DnsPeering) MarshalJSON() ([]byte, error) {
   545  	type NoMethod DnsPeering
   546  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   547  }
   548  
   549  // Empty: A generic empty message that you can re-use to avoid defining
   550  // duplicated empty messages in your APIs. A typical example is to use it as
   551  // the request or the response type of an API method. For instance: service Foo
   552  // { rpc Bar(google.protobuf.Empty) returns (google.protobuf.Empty); }
   553  type Empty struct {
   554  	// ServerResponse contains the HTTP response code and headers from the server.
   555  	googleapi.ServerResponse `json:"-"`
   556  }
   557  
   558  // EventPublishConfig: Confirguration of PubSubEventWriter.
   559  type EventPublishConfig struct {
   560  	// Enabled: Required. Option to enable Event Publishing.
   561  	Enabled bool `json:"enabled,omitempty"`
   562  	// Topic: Required. The resource name of the Pub/Sub topic. Format:
   563  	// projects/{project_id}/topics/{topic_id}
   564  	Topic string `json:"topic,omitempty"`
   565  	// ForceSendFields is a list of field names (e.g. "Enabled") to unconditionally
   566  	// include in API requests. By default, fields with empty or default values are
   567  	// omitted from API requests. See
   568  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   569  	// details.
   570  	ForceSendFields []string `json:"-"`
   571  	// NullFields is a list of field names (e.g. "Enabled") to include in API
   572  	// requests with the JSON null value. By default, fields with empty values are
   573  	// omitted from API requests. See
   574  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   575  	NullFields []string `json:"-"`
   576  }
   577  
   578  func (s *EventPublishConfig) MarshalJSON() ([]byte, error) {
   579  	type NoMethod EventPublishConfig
   580  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   581  }
   582  
   583  // Expr: Represents a textual expression in the Common Expression Language
   584  // (CEL) syntax. CEL is a C-like expression language. The syntax and semantics
   585  // of CEL are documented at https://github.com/google/cel-spec. Example
   586  // (Comparison): title: "Summary size limit" description: "Determines if a
   587  // summary is less than 100 chars" expression: "document.summary.size() < 100"
   588  // Example (Equality): title: "Requestor is owner" description: "Determines if
   589  // requestor is the document owner" expression: "document.owner ==
   590  // request.auth.claims.email" Example (Logic): title: "Public documents"
   591  // description: "Determine whether the document should be publicly visible"
   592  // expression: "document.type != 'private' && document.type != 'internal'"
   593  // Example (Data Manipulation): title: "Notification string" description:
   594  // "Create a notification string with a timestamp." expression: "'New message
   595  // received at ' + string(document.create_time)" The exact variables and
   596  // functions that may be referenced within an expression are determined by the
   597  // service that evaluates it. See the service documentation for additional
   598  // information.
   599  type Expr struct {
   600  	// Description: Optional. Description of the expression. This is a longer text
   601  	// which describes the expression, e.g. when hovered over it in a UI.
   602  	Description string `json:"description,omitempty"`
   603  	// Expression: Textual representation of an expression in Common Expression
   604  	// Language syntax.
   605  	Expression string `json:"expression,omitempty"`
   606  	// Location: Optional. String indicating the location of the expression for
   607  	// error reporting, e.g. a file name and a position in the file.
   608  	Location string `json:"location,omitempty"`
   609  	// Title: Optional. Title for the expression, i.e. a short string describing
   610  	// its purpose. This can be used e.g. in UIs which allow to enter the
   611  	// expression.
   612  	Title string `json:"title,omitempty"`
   613  	// ForceSendFields is a list of field names (e.g. "Description") to
   614  	// unconditionally include in API requests. By default, fields with empty or
   615  	// default values are omitted from API requests. See
   616  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   617  	// details.
   618  	ForceSendFields []string `json:"-"`
   619  	// NullFields is a list of field names (e.g. "Description") to include in API
   620  	// requests with the JSON null value. By default, fields with empty values are
   621  	// omitted from API requests. See
   622  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   623  	NullFields []string `json:"-"`
   624  }
   625  
   626  func (s *Expr) MarshalJSON() ([]byte, error) {
   627  	type NoMethod Expr
   628  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   629  }
   630  
   631  // Instance: Represents a Data Fusion instance.
   632  type Instance struct {
   633  	// Accelerators: Output only. List of accelerators enabled for this CDF
   634  	// instance.
   635  	Accelerators []*Accelerator `json:"accelerators,omitempty"`
   636  	// ApiEndpoint: Output only. Endpoint on which the REST APIs is accessible.
   637  	ApiEndpoint string `json:"apiEndpoint,omitempty"`
   638  	// AvailableVersion: Output only. Available versions that the instance can be
   639  	// upgraded to using UpdateInstanceRequest.
   640  	AvailableVersion []*Version `json:"availableVersion,omitempty"`
   641  	// CreateTime: Output only. The time the instance was created.
   642  	CreateTime string `json:"createTime,omitempty"`
   643  	// CryptoKeyConfig: The crypto key configuration. This field is used by the
   644  	// Customer-Managed Encryption Keys (CMEK) feature.
   645  	CryptoKeyConfig *CryptoKeyConfig `json:"cryptoKeyConfig,omitempty"`
   646  	// DataplexDataLineageIntegrationEnabled: Optional. Option to enable the
   647  	// Dataplex Lineage Integration feature.
   648  	DataplexDataLineageIntegrationEnabled bool `json:"dataplexDataLineageIntegrationEnabled,omitempty"`
   649  	// DataprocServiceAccount: User-managed service account to set on Dataproc when
   650  	// Cloud Data Fusion creates Dataproc to run data processing pipelines. This
   651  	// allows users to have fine-grained access control on Dataproc's accesses to
   652  	// cloud resources.
   653  	DataprocServiceAccount string `json:"dataprocServiceAccount,omitempty"`
   654  	// Description: A description of this instance.
   655  	Description string `json:"description,omitempty"`
   656  	// DisabledReason: Output only. If the instance state is DISABLED, the reason
   657  	// for disabling the instance.
   658  	//
   659  	// Possible values:
   660  	//   "DISABLED_REASON_UNSPECIFIED" - This is an unknown reason for disabling.
   661  	//   "KMS_KEY_ISSUE" - The KMS key used by the instance is either revoked or
   662  	// denied access to
   663  	DisabledReason []string `json:"disabledReason,omitempty"`
   664  	// DisplayName: Display name for an instance.
   665  	DisplayName string `json:"displayName,omitempty"`
   666  	// EnableRbac: Option to enable granular role-based access control.
   667  	EnableRbac bool `json:"enableRbac,omitempty"`
   668  	// EnableStackdriverLogging: Option to enable Stackdriver Logging.
   669  	EnableStackdriverLogging bool `json:"enableStackdriverLogging,omitempty"`
   670  	// EnableStackdriverMonitoring: Option to enable Stackdriver Monitoring.
   671  	EnableStackdriverMonitoring bool `json:"enableStackdriverMonitoring,omitempty"`
   672  	// EnableZoneSeparation: Option to enable granular zone separation.
   673  	EnableZoneSeparation bool `json:"enableZoneSeparation,omitempty"`
   674  	// EventPublishConfig: Option to enable and pass metadata for event publishing.
   675  	EventPublishConfig *EventPublishConfig `json:"eventPublishConfig,omitempty"`
   676  	// GcsBucket: Output only. Cloud Storage bucket generated by Data Fusion in the
   677  	// customer project.
   678  	GcsBucket string `json:"gcsBucket,omitempty"`
   679  	// Labels: The resource labels for instance to use to annotate any related
   680  	// underlying resources such as Compute Engine VMs. The character '=' is not
   681  	// allowed to be used within the labels.
   682  	Labels map[string]string `json:"labels,omitempty"`
   683  	// Name: Output only. The name of this instance is in the form of
   684  	// projects/{project}/locations/{location}/instances/{instance}.
   685  	Name string `json:"name,omitempty"`
   686  	// NetworkConfig: Network configuration options. These are required when a
   687  	// private Data Fusion instance is to be created.
   688  	NetworkConfig *NetworkConfig `json:"networkConfig,omitempty"`
   689  	// Options: Map of additional options used to configure the behavior of Data
   690  	// Fusion instance.
   691  	Options map[string]string `json:"options,omitempty"`
   692  	// P4ServiceAccount: Output only. P4 service account for the customer project.
   693  	P4ServiceAccount string `json:"p4ServiceAccount,omitempty"`
   694  	// PatchRevision: Optional. Current patch revision of the Data Fusion.
   695  	PatchRevision string `json:"patchRevision,omitempty"`
   696  	// PrivateInstance: Specifies whether the Data Fusion instance should be
   697  	// private. If set to true, all Data Fusion nodes will have private IP
   698  	// addresses and will not be able to access the public internet.
   699  	PrivateInstance bool `json:"privateInstance,omitempty"`
   700  	// SatisfiesPzs: Output only. Reserved for future use.
   701  	SatisfiesPzs bool `json:"satisfiesPzs,omitempty"`
   702  	// ServiceAccount: Output only. Deprecated. Use tenant_project_id instead to
   703  	// extract the tenant project ID.
   704  	ServiceAccount string `json:"serviceAccount,omitempty"`
   705  	// ServiceEndpoint: Output only. Endpoint on which the Data Fusion UI is
   706  	// accessible.
   707  	ServiceEndpoint string `json:"serviceEndpoint,omitempty"`
   708  	// State: Output only. The current state of this Data Fusion instance.
   709  	//
   710  	// Possible values:
   711  	//   "STATE_UNSPECIFIED" - Instance does not have a state yet
   712  	//   "CREATING" - Instance is being created
   713  	//   "ACTIVE" - Instance is active and ready for requests. This corresponds to
   714  	// 'RUNNING' in datafusion.v1beta1.
   715  	//   "FAILED" - Instance creation failed
   716  	//   "DELETING" - Instance is being deleted
   717  	//   "UPGRADING" - Instance is being upgraded
   718  	//   "RESTARTING" - Instance is being restarted
   719  	//   "UPDATING" - Instance is being updated on customer request
   720  	//   "AUTO_UPDATING" - Instance is being auto-updated
   721  	//   "AUTO_UPGRADING" - Instance is being auto-upgraded
   722  	//   "DISABLED" - Instance is disabled
   723  	State string `json:"state,omitempty"`
   724  	// StateMessage: Output only. Additional information about the current state of
   725  	// this Data Fusion instance if available.
   726  	StateMessage string `json:"stateMessage,omitempty"`
   727  	// TenantProjectId: Output only. The name of the tenant project.
   728  	TenantProjectId string `json:"tenantProjectId,omitempty"`
   729  	// Type: Required. Instance type.
   730  	//
   731  	// Possible values:
   732  	//   "TYPE_UNSPECIFIED" - No type specified. The instance creation will fail.
   733  	//   "BASIC" - Basic Data Fusion instance. In Basic type, the user will be able
   734  	// to create data pipelines using point and click UI. However, there are
   735  	// certain limitations, such as fewer number of concurrent pipelines, no
   736  	// support for streaming pipelines, etc.
   737  	//   "ENTERPRISE" - Enterprise Data Fusion instance. In Enterprise type, the
   738  	// user will have all features available, such as support for streaming
   739  	// pipelines, higher number of concurrent pipelines, etc.
   740  	//   "DEVELOPER" - Developer Data Fusion instance. In Developer type, the user
   741  	// will have all features available but with restrictive capabilities. This is
   742  	// to help enterprises design and develop their data ingestion and integration
   743  	// pipelines at low cost.
   744  	Type string `json:"type,omitempty"`
   745  	// UpdateTime: Output only. The time the instance was last updated.
   746  	UpdateTime string `json:"updateTime,omitempty"`
   747  	// Version: Current version of the Data Fusion. Only specifiable in Update.
   748  	Version string `json:"version,omitempty"`
   749  	// WorkforceIdentityServiceEndpoint: Output only. Endpoint on which the Data
   750  	// Fusion UI is accessible to third-party users
   751  	WorkforceIdentityServiceEndpoint string `json:"workforceIdentityServiceEndpoint,omitempty"`
   752  	// Zone: Name of the zone in which the Data Fusion instance will be created.
   753  	// Only DEVELOPER instances use this field.
   754  	Zone string `json:"zone,omitempty"`
   755  
   756  	// ServerResponse contains the HTTP response code and headers from the server.
   757  	googleapi.ServerResponse `json:"-"`
   758  	// ForceSendFields is a list of field names (e.g. "Accelerators") to
   759  	// unconditionally include in API requests. By default, fields with empty or
   760  	// default values are omitted from API requests. See
   761  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   762  	// details.
   763  	ForceSendFields []string `json:"-"`
   764  	// NullFields is a list of field names (e.g. "Accelerators") to include in API
   765  	// requests with the JSON null value. By default, fields with empty values are
   766  	// omitted from API requests. See
   767  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   768  	NullFields []string `json:"-"`
   769  }
   770  
   771  func (s *Instance) MarshalJSON() ([]byte, error) {
   772  	type NoMethod Instance
   773  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   774  }
   775  
   776  // ListAvailableVersionsResponse: Response message for the list available
   777  // versions request.
   778  type ListAvailableVersionsResponse struct {
   779  	// AvailableVersions: Represents a list of versions that are supported.
   780  	AvailableVersions []*Version `json:"availableVersions,omitempty"`
   781  	// NextPageToken: Token to retrieve the next page of results or empty if there
   782  	// are no more results in the list.
   783  	NextPageToken string `json:"nextPageToken,omitempty"`
   784  
   785  	// ServerResponse contains the HTTP response code and headers from the server.
   786  	googleapi.ServerResponse `json:"-"`
   787  	// ForceSendFields is a list of field names (e.g. "AvailableVersions") to
   788  	// unconditionally include in API requests. By default, fields with empty or
   789  	// default values are omitted from API requests. See
   790  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   791  	// details.
   792  	ForceSendFields []string `json:"-"`
   793  	// NullFields is a list of field names (e.g. "AvailableVersions") to include in
   794  	// API requests with the JSON null value. By default, fields with empty values
   795  	// are omitted from API requests. See
   796  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   797  	NullFields []string `json:"-"`
   798  }
   799  
   800  func (s *ListAvailableVersionsResponse) MarshalJSON() ([]byte, error) {
   801  	type NoMethod ListAvailableVersionsResponse
   802  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   803  }
   804  
   805  // ListDnsPeeringsResponse: Response message for list DNS peerings.
   806  type ListDnsPeeringsResponse struct {
   807  	// DnsPeerings: List of dns peering.
   808  	DnsPeerings []*DnsPeering `json:"dnsPeerings,omitempty"`
   809  	// NextPageToken: A token, which can be sent as `page_token` to retrieve the
   810  	// next page. If this field is omitted, there are no subsequent pages.
   811  	NextPageToken string `json:"nextPageToken,omitempty"`
   812  
   813  	// ServerResponse contains the HTTP response code and headers from the server.
   814  	googleapi.ServerResponse `json:"-"`
   815  	// ForceSendFields is a list of field names (e.g. "DnsPeerings") to
   816  	// unconditionally include in API requests. By default, fields with empty or
   817  	// default values are omitted from API requests. See
   818  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   819  	// details.
   820  	ForceSendFields []string `json:"-"`
   821  	// NullFields is a list of field names (e.g. "DnsPeerings") to include in API
   822  	// requests with the JSON null value. By default, fields with empty values are
   823  	// omitted from API requests. See
   824  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   825  	NullFields []string `json:"-"`
   826  }
   827  
   828  func (s *ListDnsPeeringsResponse) MarshalJSON() ([]byte, error) {
   829  	type NoMethod ListDnsPeeringsResponse
   830  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   831  }
   832  
   833  // ListInstancesResponse: Response message for the list instance request.
   834  type ListInstancesResponse struct {
   835  	// Instances: Represents a list of Data Fusion instances.
   836  	Instances []*Instance `json:"instances,omitempty"`
   837  	// NextPageToken: Token to retrieve the next page of results or empty if there
   838  	// are no more results in the list.
   839  	NextPageToken string `json:"nextPageToken,omitempty"`
   840  	// Unreachable: Locations that could not be reached.
   841  	Unreachable []string `json:"unreachable,omitempty"`
   842  
   843  	// ServerResponse contains the HTTP response code and headers from the server.
   844  	googleapi.ServerResponse `json:"-"`
   845  	// ForceSendFields is a list of field names (e.g. "Instances") to
   846  	// unconditionally include in API requests. By default, fields with empty or
   847  	// default values are omitted from API requests. See
   848  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   849  	// details.
   850  	ForceSendFields []string `json:"-"`
   851  	// NullFields is a list of field names (e.g. "Instances") to include in API
   852  	// requests with the JSON null value. By default, fields with empty values are
   853  	// omitted from API requests. See
   854  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   855  	NullFields []string `json:"-"`
   856  }
   857  
   858  func (s *ListInstancesResponse) MarshalJSON() ([]byte, error) {
   859  	type NoMethod ListInstancesResponse
   860  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   861  }
   862  
   863  // ListLocationsResponse: The response message for Locations.ListLocations.
   864  type ListLocationsResponse struct {
   865  	// Locations: A list of locations that matches the specified filter in the
   866  	// request.
   867  	Locations []*Location `json:"locations,omitempty"`
   868  	// NextPageToken: The standard List next-page token.
   869  	NextPageToken string `json:"nextPageToken,omitempty"`
   870  
   871  	// ServerResponse contains the HTTP response code and headers from the server.
   872  	googleapi.ServerResponse `json:"-"`
   873  	// ForceSendFields is a list of field names (e.g. "Locations") to
   874  	// unconditionally include in API requests. By default, fields with empty or
   875  	// default values are omitted from API requests. See
   876  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   877  	// details.
   878  	ForceSendFields []string `json:"-"`
   879  	// NullFields is a list of field names (e.g. "Locations") to include in API
   880  	// requests with the JSON null value. By default, fields with empty values are
   881  	// omitted from API requests. See
   882  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   883  	NullFields []string `json:"-"`
   884  }
   885  
   886  func (s *ListLocationsResponse) MarshalJSON() ([]byte, error) {
   887  	type NoMethod ListLocationsResponse
   888  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   889  }
   890  
   891  // ListOperationsResponse: The response message for Operations.ListOperations.
   892  type ListOperationsResponse struct {
   893  	// NextPageToken: The standard List next-page token.
   894  	NextPageToken string `json:"nextPageToken,omitempty"`
   895  	// Operations: A list of operations that matches the specified filter in the
   896  	// request.
   897  	Operations []*Operation `json:"operations,omitempty"`
   898  
   899  	// ServerResponse contains the HTTP response code and headers from the server.
   900  	googleapi.ServerResponse `json:"-"`
   901  	// ForceSendFields is a list of field names (e.g. "NextPageToken") to
   902  	// unconditionally include in API requests. By default, fields with empty or
   903  	// default values are omitted from API requests. See
   904  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   905  	// details.
   906  	ForceSendFields []string `json:"-"`
   907  	// NullFields is a list of field names (e.g. "NextPageToken") to include in API
   908  	// requests with the JSON null value. By default, fields with empty values are
   909  	// omitted from API requests. See
   910  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   911  	NullFields []string `json:"-"`
   912  }
   913  
   914  func (s *ListOperationsResponse) MarshalJSON() ([]byte, error) {
   915  	type NoMethod ListOperationsResponse
   916  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   917  }
   918  
   919  // Location: A resource that represents a Google Cloud location.
   920  type Location struct {
   921  	// DisplayName: The friendly name for this location, typically a nearby city
   922  	// name. For example, "Tokyo".
   923  	DisplayName string `json:"displayName,omitempty"`
   924  	// Labels: Cross-service attributes for the location. For example
   925  	// {"cloud.googleapis.com/region": "us-east1"}
   926  	Labels map[string]string `json:"labels,omitempty"`
   927  	// LocationId: The canonical id for this location. For example: "us-east1".
   928  	LocationId string `json:"locationId,omitempty"`
   929  	// Metadata: Service-specific metadata. For example the available capacity at
   930  	// the given location.
   931  	Metadata googleapi.RawMessage `json:"metadata,omitempty"`
   932  	// Name: Resource name for the location, which may vary between
   933  	// implementations. For example:
   934  	// "projects/example-project/locations/us-east1"
   935  	Name string `json:"name,omitempty"`
   936  
   937  	// ServerResponse contains the HTTP response code and headers from the server.
   938  	googleapi.ServerResponse `json:"-"`
   939  	// ForceSendFields is a list of field names (e.g. "DisplayName") to
   940  	// unconditionally include in API requests. By default, fields with empty or
   941  	// default values are omitted from API requests. See
   942  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   943  	// details.
   944  	ForceSendFields []string `json:"-"`
   945  	// NullFields is a list of field names (e.g. "DisplayName") to include in API
   946  	// requests with the JSON null value. By default, fields with empty values are
   947  	// omitted from API requests. See
   948  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   949  	NullFields []string `json:"-"`
   950  }
   951  
   952  func (s *Location) MarshalJSON() ([]byte, error) {
   953  	type NoMethod Location
   954  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   955  }
   956  
   957  // NetworkConfig: Network configuration for a Data Fusion instance. These
   958  // configurations are used for peering with the customer network.
   959  // Configurations are optional when a public Data Fusion instance is to be
   960  // created. However, providing these configurations allows several benefits,
   961  // such as reduced network latency while accessing the customer resources from
   962  // managed Data Fusion instance nodes, as well as access to the customer
   963  // on-prem resources.
   964  type NetworkConfig struct {
   965  	// ConnectionType: Optional. Type of connection for establishing private IP
   966  	// connectivity between the Data Fusion customer project VPC and the
   967  	// corresponding tenant project from a predefined list of available connection
   968  	// modes. If this field is unspecified for a private instance, VPC peering is
   969  	// used.
   970  	//
   971  	// Possible values:
   972  	//   "CONNECTION_TYPE_UNSPECIFIED" - No specific connection type was requested,
   973  	// the default value of VPC_PEERING is chosen.
   974  	//   "VPC_PEERING" - Requests the use of VPC peerings for connecting the
   975  	// consumer and tenant projects.
   976  	//   "PRIVATE_SERVICE_CONNECT_INTERFACES" - Requests the use of Private Service
   977  	// Connect Interfaces for connecting the consumer and tenant projects.
   978  	ConnectionType string `json:"connectionType,omitempty"`
   979  	// IpAllocation: Optional. The IP range in CIDR notation to use for the managed
   980  	// Data Fusion instance nodes. This range must not overlap with any other
   981  	// ranges used in the Data Fusion instance network. This is required only when
   982  	// using connection type VPC_PEERING. Format: a.b.c.d/22 Example:
   983  	// 192.168.0.0/22
   984  	IpAllocation string `json:"ipAllocation,omitempty"`
   985  	// Network: Optional. Name of the network in the customer project with which
   986  	// the Tenant Project will be peered for executing pipelines. This is required
   987  	// only when using connection type VPC peering. In case of shared VPC where the
   988  	// network resides in another host project the network should specified in the
   989  	// form of projects/{host-project-id}/global/networks/{network}. This is only
   990  	// required for connectivity type VPC_PEERING.
   991  	Network string `json:"network,omitempty"`
   992  	// PrivateServiceConnectConfig: Optional. Configuration for Private Service
   993  	// Connect. This is required only when using connection type
   994  	// PRIVATE_SERVICE_CONNECT_INTERFACES.
   995  	PrivateServiceConnectConfig *PrivateServiceConnectConfig `json:"privateServiceConnectConfig,omitempty"`
   996  	// ForceSendFields is a list of field names (e.g. "ConnectionType") to
   997  	// unconditionally include in API requests. By default, fields with empty or
   998  	// default values are omitted from API requests. See
   999  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1000  	// details.
  1001  	ForceSendFields []string `json:"-"`
  1002  	// NullFields is a list of field names (e.g. "ConnectionType") to include in
  1003  	// API requests with the JSON null value. By default, fields with empty values
  1004  	// are omitted from API requests. See
  1005  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1006  	NullFields []string `json:"-"`
  1007  }
  1008  
  1009  func (s *NetworkConfig) MarshalJSON() ([]byte, error) {
  1010  	type NoMethod NetworkConfig
  1011  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1012  }
  1013  
  1014  // Operation: This resource represents a long-running operation that is the
  1015  // result of a network API call.
  1016  type Operation struct {
  1017  	// Done: If the value is `false`, it means the operation is still in progress.
  1018  	// If `true`, the operation is completed, and either `error` or `response` is
  1019  	// available.
  1020  	Done bool `json:"done,omitempty"`
  1021  	// Error: The error result of the operation in case of failure or cancellation.
  1022  	Error *Status `json:"error,omitempty"`
  1023  	// Metadata: Service-specific metadata associated with the operation. It
  1024  	// typically contains progress information and common metadata such as create
  1025  	// time. Some services might not provide such metadata. Any method that returns
  1026  	// a long-running operation should document the metadata type, if any.
  1027  	Metadata googleapi.RawMessage `json:"metadata,omitempty"`
  1028  	// Name: The server-assigned name, which is only unique within the same service
  1029  	// that originally returns it. If you use the default HTTP mapping, the `name`
  1030  	// should be a resource name ending with `operations/{unique_id}`.
  1031  	Name string `json:"name,omitempty"`
  1032  	// Response: The normal, successful response of the operation. If the original
  1033  	// method returns no data on success, such as `Delete`, the response is
  1034  	// `google.protobuf.Empty`. If the original method is standard
  1035  	// `Get`/`Create`/`Update`, the response should be the resource. For other
  1036  	// methods, the response should have the type `XxxResponse`, where `Xxx` is the
  1037  	// original method name. For example, if the original method name is
  1038  	// `TakeSnapshot()`, the inferred response type is `TakeSnapshotResponse`.
  1039  	Response googleapi.RawMessage `json:"response,omitempty"`
  1040  
  1041  	// ServerResponse contains the HTTP response code and headers from the server.
  1042  	googleapi.ServerResponse `json:"-"`
  1043  	// ForceSendFields is a list of field names (e.g. "Done") to unconditionally
  1044  	// include in API requests. By default, fields with empty or default values are
  1045  	// omitted from API requests. See
  1046  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1047  	// details.
  1048  	ForceSendFields []string `json:"-"`
  1049  	// NullFields is a list of field names (e.g. "Done") to include in API requests
  1050  	// with the JSON null value. By default, fields with empty values are omitted
  1051  	// from API requests. See
  1052  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1053  	NullFields []string `json:"-"`
  1054  }
  1055  
  1056  func (s *Operation) MarshalJSON() ([]byte, error) {
  1057  	type NoMethod Operation
  1058  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1059  }
  1060  
  1061  // OperationMetadata: Represents the metadata of a long-running operation.
  1062  type OperationMetadata struct {
  1063  	// AdditionalStatus: Map to hold any additional status info for the operation
  1064  	// If there is an accelerator being enabled/disabled/deleted, this will be
  1065  	// populated with accelerator name as key and status as ENABLING, DISABLING or
  1066  	// DELETING
  1067  	AdditionalStatus map[string]string `json:"additionalStatus,omitempty"`
  1068  	// ApiVersion: API version used to start the operation.
  1069  	ApiVersion string `json:"apiVersion,omitempty"`
  1070  	// CreateTime: The time the operation was created.
  1071  	CreateTime string `json:"createTime,omitempty"`
  1072  	// EndTime: The time the operation finished running.
  1073  	EndTime string `json:"endTime,omitempty"`
  1074  	// RequestedCancellation: Identifies whether the user has requested
  1075  	// cancellation of the operation. Operations that have successfully been
  1076  	// cancelled have Operation.error value with a google.rpc.Status.code of 1,
  1077  	// corresponding to `Code.CANCELLED`.
  1078  	RequestedCancellation bool `json:"requestedCancellation,omitempty"`
  1079  	// StatusDetail: Human-readable status of the operation if any.
  1080  	StatusDetail string `json:"statusDetail,omitempty"`
  1081  	// Target: Server-defined resource path for the target of the operation.
  1082  	Target string `json:"target,omitempty"`
  1083  	// Verb: Name of the verb executed by the operation.
  1084  	Verb string `json:"verb,omitempty"`
  1085  	// ForceSendFields is a list of field names (e.g. "AdditionalStatus") to
  1086  	// unconditionally include in API requests. By default, fields with empty or
  1087  	// default values are omitted from API requests. See
  1088  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1089  	// details.
  1090  	ForceSendFields []string `json:"-"`
  1091  	// NullFields is a list of field names (e.g. "AdditionalStatus") to include in
  1092  	// API requests with the JSON null value. By default, fields with empty values
  1093  	// are omitted from API requests. See
  1094  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1095  	NullFields []string `json:"-"`
  1096  }
  1097  
  1098  func (s *OperationMetadata) MarshalJSON() ([]byte, error) {
  1099  	type NoMethod OperationMetadata
  1100  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1101  }
  1102  
  1103  // PersistentDiskData: Persistent Disk service-specific Data. Contains
  1104  // information that may not be appropriate for the generic DRZ Augmented View.
  1105  // This currently includes LSV Colossus Roots and GCS Buckets.
  1106  type PersistentDiskData struct {
  1107  	// CfsRoots: Path to Colossus root for an LSV. NOTE: Unlike `cr_ti_guris` and
  1108  	// `cr_ti_prefixes`, the field `cfs_roots` below does not need to be a GUri or
  1109  	// GUri prefix. It can simply be any valid CFS or CFS2 Path. The DRZ KR8 SIG
  1110  	// has more details overall, but generally the `cfs_roots` provided here should
  1111  	// be scoped to an individual Persistent Disk. An example for a PD Disk with a
  1112  	// disk ID 3277719120423414466, follows: * `cr_ti_guris` could be
  1113  	// ‘/cfs2/pj/pd-cloud-prod’ as this is a valid GUri present in the DG KB
  1114  	// and contains enough information to perform location monitoring and scope
  1115  	// ownership of the Production Object. * `cfs_roots` would be:
  1116  	// ‘/cfs2/pj/pd-cloud-staging/lsv000001234@/
  1117  	// lsv/projects~773365403387~zones~2700~disks~3277719120423414466
  1118  	// ~bank-blue-careful-3526-lsv00054DB1B7254BA3/’ as this allows us to
  1119  	// enumerate the files on CFS2 that belong to an individual Disk.
  1120  	CfsRoots []string `json:"cfsRoots,omitempty"`
  1121  	// GcsBucketNames: The GCS Buckets that back this snapshot or image. This is
  1122  	// required as `cr_ti_prefixes` and `cr_ti_guris` only accept TI resources.
  1123  	// This should be the globally unique bucket name.
  1124  	GcsBucketNames []string `json:"gcsBucketNames,omitempty"`
  1125  	// ForceSendFields is a list of field names (e.g. "CfsRoots") to
  1126  	// unconditionally include in API requests. By default, fields with empty or
  1127  	// default values are omitted from API requests. See
  1128  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1129  	// details.
  1130  	ForceSendFields []string `json:"-"`
  1131  	// NullFields is a list of field names (e.g. "CfsRoots") to include in API
  1132  	// requests with the JSON null value. By default, fields with empty values are
  1133  	// omitted from API requests. See
  1134  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1135  	NullFields []string `json:"-"`
  1136  }
  1137  
  1138  func (s *PersistentDiskData) MarshalJSON() ([]byte, error) {
  1139  	type NoMethod PersistentDiskData
  1140  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1141  }
  1142  
  1143  // Policy: An Identity and Access Management (IAM) policy, which specifies
  1144  // access controls for Google Cloud resources. A `Policy` is a collection of
  1145  // `bindings`. A `binding` binds one or more `members`, or principals, to a
  1146  // single `role`. Principals can be user accounts, service accounts, Google
  1147  // groups, and domains (such as G Suite). A `role` is a named list of
  1148  // permissions; each `role` can be an IAM predefined role or a user-created
  1149  // custom role. For some types of Google Cloud resources, a `binding` can also
  1150  // specify a `condition`, which is a logical expression that allows access to a
  1151  // resource only if the expression evaluates to `true`. A condition can add
  1152  // constraints based on attributes of the request, the resource, or both. To
  1153  // learn which resources support conditions in their IAM policies, see the IAM
  1154  // documentation
  1155  // (https://cloud.google.com/iam/help/conditions/resource-policies). **JSON
  1156  // example:** ``` { "bindings": [ { "role":
  1157  // "roles/resourcemanager.organizationAdmin", "members": [
  1158  // "user:mike@example.com", "group:admins@example.com", "domain:google.com",
  1159  // "serviceAccount:my-project-id@appspot.gserviceaccount.com" ] }, { "role":
  1160  // "roles/resourcemanager.organizationViewer", "members": [
  1161  // "user:eve@example.com" ], "condition": { "title": "expirable access",
  1162  // "description": "Does not grant access after Sep 2020", "expression":
  1163  // "request.time < timestamp('2020-10-01T00:00:00.000Z')", } } ], "etag":
  1164  // "BwWWja0YfJA=", "version": 3 } ``` **YAML example:** ``` bindings: -
  1165  // members: - user:mike@example.com - group:admins@example.com -
  1166  // domain:google.com - serviceAccount:my-project-id@appspot.gserviceaccount.com
  1167  // role: roles/resourcemanager.organizationAdmin - members: -
  1168  // user:eve@example.com role: roles/resourcemanager.organizationViewer
  1169  // condition: title: expirable access description: Does not grant access after
  1170  // Sep 2020 expression: request.time < timestamp('2020-10-01T00:00:00.000Z')
  1171  // etag: BwWWja0YfJA= version: 3 ``` For a description of IAM and its features,
  1172  // see the IAM documentation (https://cloud.google.com/iam/docs/).
  1173  type Policy struct {
  1174  	// AuditConfigs: Specifies cloud audit logging configuration for this policy.
  1175  	AuditConfigs []*AuditConfig `json:"auditConfigs,omitempty"`
  1176  	// Bindings: Associates a list of `members`, or principals, with a `role`.
  1177  	// Optionally, may specify a `condition` that determines how and when the
  1178  	// `bindings` are applied. Each of the `bindings` must contain at least one
  1179  	// principal. The `bindings` in a `Policy` can refer to up to 1,500 principals;
  1180  	// up to 250 of these principals can be Google groups. Each occurrence of a
  1181  	// principal counts towards these limits. For example, if the `bindings` grant
  1182  	// 50 different roles to `user:alice@example.com`, and not to any other
  1183  	// principal, then you can add another 1,450 principals to the `bindings` in
  1184  	// the `Policy`.
  1185  	Bindings []*Binding `json:"bindings,omitempty"`
  1186  	// Etag: `etag` is used for optimistic concurrency control as a way to help
  1187  	// prevent simultaneous updates of a policy from overwriting each other. It is
  1188  	// strongly suggested that systems make use of the `etag` in the
  1189  	// read-modify-write cycle to perform policy updates in order to avoid race
  1190  	// conditions: An `etag` is returned in the response to `getIamPolicy`, and
  1191  	// systems are expected to put that etag in the request to `setIamPolicy` to
  1192  	// ensure that their change will be applied to the same version of the policy.
  1193  	// **Important:** If you use IAM Conditions, you must include the `etag` field
  1194  	// whenever you call `setIamPolicy`. If you omit this field, then IAM allows
  1195  	// you to overwrite a version `3` policy with a version `1` policy, and all of
  1196  	// the conditions in the version `3` policy are lost.
  1197  	Etag string `json:"etag,omitempty"`
  1198  	// Version: Specifies the format of the policy. Valid values are `0`, `1`, and
  1199  	// `3`. Requests that specify an invalid value are rejected. Any operation that
  1200  	// affects conditional role bindings must specify version `3`. This requirement
  1201  	// applies to the following operations: * Getting a policy that includes a
  1202  	// conditional role binding * Adding a conditional role binding to a policy *
  1203  	// Changing a conditional role binding in a policy * Removing any role binding,
  1204  	// with or without a condition, from a policy that includes conditions
  1205  	// **Important:** If you use IAM Conditions, you must include the `etag` field
  1206  	// whenever you call `setIamPolicy`. If you omit this field, then IAM allows
  1207  	// you to overwrite a version `3` policy with a version `1` policy, and all of
  1208  	// the conditions in the version `3` policy are lost. If a policy does not
  1209  	// include any conditions, operations on that policy may specify any valid
  1210  	// version or leave the field unset. To learn which resources support
  1211  	// conditions in their IAM policies, see the IAM documentation
  1212  	// (https://cloud.google.com/iam/help/conditions/resource-policies).
  1213  	Version int64 `json:"version,omitempty"`
  1214  
  1215  	// ServerResponse contains the HTTP response code and headers from the server.
  1216  	googleapi.ServerResponse `json:"-"`
  1217  	// ForceSendFields is a list of field names (e.g. "AuditConfigs") to
  1218  	// unconditionally include in API requests. By default, fields with empty or
  1219  	// default values are omitted from API requests. See
  1220  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1221  	// details.
  1222  	ForceSendFields []string `json:"-"`
  1223  	// NullFields is a list of field names (e.g. "AuditConfigs") to include in API
  1224  	// requests with the JSON null value. By default, fields with empty values are
  1225  	// omitted from API requests. See
  1226  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1227  	NullFields []string `json:"-"`
  1228  }
  1229  
  1230  func (s *Policy) MarshalJSON() ([]byte, error) {
  1231  	type NoMethod Policy
  1232  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1233  }
  1234  
  1235  // PrivateServiceConnectConfig: Configuration for using Private Service Connect
  1236  // to establish connectivity between the Data Fusion consumer project and the
  1237  // corresponding tenant project.
  1238  type PrivateServiceConnectConfig struct {
  1239  	// EffectiveUnreachableCidrBlock: Output only. The CIDR block to which the CDF
  1240  	// instance can't route traffic to in the consumer project VPC. The size of
  1241  	// this block is /25. The format of this field is governed by RFC 4632.
  1242  	// Example: 240.0.0.0/25
  1243  	EffectiveUnreachableCidrBlock string `json:"effectiveUnreachableCidrBlock,omitempty"`
  1244  	// NetworkAttachment: Required. The reference to the network attachment used to
  1245  	// establish private connectivity. It will be of the form
  1246  	// projects/{project-id}/regions/{region}/networkAttachments/{network-attachment
  1247  	// -id}.
  1248  	NetworkAttachment string `json:"networkAttachment,omitempty"`
  1249  	// UnreachableCidrBlock: Optional. Input only. The CIDR block to which the CDF
  1250  	// instance can't route traffic to in the consumer project VPC. The size of
  1251  	// this block should be at least /25. This range should not overlap with the
  1252  	// primary address range of any subnetwork used by the network attachment. This
  1253  	// range can be used for other purposes in the consumer VPC as long as there is
  1254  	// no requirement for CDF to reach destinations using these addresses. If this
  1255  	// value is not provided, the server chooses a non RFC 1918 address range. The
  1256  	// format of this field is governed by RFC 4632. Example: 192.168.0.0/25
  1257  	UnreachableCidrBlock string `json:"unreachableCidrBlock,omitempty"`
  1258  	// ForceSendFields is a list of field names (e.g.
  1259  	// "EffectiveUnreachableCidrBlock") to unconditionally include in API requests.
  1260  	// By default, fields with empty or default values are omitted from API
  1261  	// requests. See https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields
  1262  	// for more details.
  1263  	ForceSendFields []string `json:"-"`
  1264  	// NullFields is a list of field names (e.g. "EffectiveUnreachableCidrBlock")
  1265  	// to include in API requests with the JSON null value. By default, fields with
  1266  	// empty values are omitted from API requests. See
  1267  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1268  	NullFields []string `json:"-"`
  1269  }
  1270  
  1271  func (s *PrivateServiceConnectConfig) MarshalJSON() ([]byte, error) {
  1272  	type NoMethod PrivateServiceConnectConfig
  1273  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1274  }
  1275  
  1276  // RestartInstanceRequest: Request message for restarting a Data Fusion
  1277  // instance.
  1278  type RestartInstanceRequest struct {
  1279  }
  1280  
  1281  // ServiceData: This message defines service-specific data that certain service
  1282  // teams must provide as part of the Data Residency Augmented View for a
  1283  // resource. Next ID: 2
  1284  type ServiceData struct {
  1285  	// Pd: Auxiliary data for the persistent disk pipeline provided to provide the
  1286  	// LSV Colossus Roots and GCS Buckets.
  1287  	Pd *PersistentDiskData `json:"pd,omitempty"`
  1288  	// ForceSendFields is a list of field names (e.g. "Pd") to unconditionally
  1289  	// include in API requests. By default, fields with empty or default values are
  1290  	// omitted from API requests. See
  1291  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1292  	// details.
  1293  	ForceSendFields []string `json:"-"`
  1294  	// NullFields is a list of field names (e.g. "Pd") to include in API requests
  1295  	// with the JSON null value. By default, fields with empty values are omitted
  1296  	// from API requests. See
  1297  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1298  	NullFields []string `json:"-"`
  1299  }
  1300  
  1301  func (s *ServiceData) MarshalJSON() ([]byte, error) {
  1302  	type NoMethod ServiceData
  1303  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1304  }
  1305  
  1306  // SetIamPolicyRequest: Request message for `SetIamPolicy` method.
  1307  type SetIamPolicyRequest struct {
  1308  	// Policy: REQUIRED: The complete policy to be applied to the `resource`. The
  1309  	// size of the policy is limited to a few 10s of KB. An empty policy is a valid
  1310  	// policy but certain Google Cloud services (such as Projects) might reject
  1311  	// them.
  1312  	Policy *Policy `json:"policy,omitempty"`
  1313  	// UpdateMask: OPTIONAL: A FieldMask specifying which fields of the policy to
  1314  	// modify. Only the fields in the mask will be modified. If no mask is
  1315  	// provided, the following default mask is used: `paths: "bindings, etag"
  1316  	UpdateMask string `json:"updateMask,omitempty"`
  1317  	// ForceSendFields is a list of field names (e.g. "Policy") to unconditionally
  1318  	// include in API requests. By default, fields with empty or default values are
  1319  	// omitted from API requests. See
  1320  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1321  	// details.
  1322  	ForceSendFields []string `json:"-"`
  1323  	// NullFields is a list of field names (e.g. "Policy") to include in API
  1324  	// requests with the JSON null value. By default, fields with empty values are
  1325  	// omitted from API requests. See
  1326  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1327  	NullFields []string `json:"-"`
  1328  }
  1329  
  1330  func (s *SetIamPolicyRequest) MarshalJSON() ([]byte, error) {
  1331  	type NoMethod SetIamPolicyRequest
  1332  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1333  }
  1334  
  1335  // Status: The `Status` type defines a logical error model that is suitable for
  1336  // different programming environments, including REST APIs and RPC APIs. It is
  1337  // used by gRPC (https://github.com/grpc). Each `Status` message contains three
  1338  // pieces of data: error code, error message, and error details. You can find
  1339  // out more about this error model and how to work with it in the API Design
  1340  // Guide (https://cloud.google.com/apis/design/errors).
  1341  type Status struct {
  1342  	// Code: The status code, which should be an enum value of google.rpc.Code.
  1343  	Code int64 `json:"code,omitempty"`
  1344  	// Details: A list of messages that carry the error details. There is a common
  1345  	// set of message types for APIs to use.
  1346  	Details []googleapi.RawMessage `json:"details,omitempty"`
  1347  	// Message: A developer-facing error message, which should be in English. Any
  1348  	// user-facing error message should be localized and sent in the
  1349  	// google.rpc.Status.details field, or localized by the client.
  1350  	Message string `json:"message,omitempty"`
  1351  	// ForceSendFields is a list of field names (e.g. "Code") to unconditionally
  1352  	// include in API requests. By default, fields with empty or default values are
  1353  	// omitted from API requests. See
  1354  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1355  	// details.
  1356  	ForceSendFields []string `json:"-"`
  1357  	// NullFields is a list of field names (e.g. "Code") to include in API requests
  1358  	// with the JSON null value. By default, fields with empty values are omitted
  1359  	// from API requests. See
  1360  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1361  	NullFields []string `json:"-"`
  1362  }
  1363  
  1364  func (s *Status) MarshalJSON() ([]byte, error) {
  1365  	type NoMethod Status
  1366  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1367  }
  1368  
  1369  // TestIamPermissionsRequest: Request message for `TestIamPermissions` method.
  1370  type TestIamPermissionsRequest struct {
  1371  	// Permissions: The set of permissions to check for the `resource`. Permissions
  1372  	// with wildcards (such as `*` or `storage.*`) are not allowed. For more
  1373  	// information see IAM Overview
  1374  	// (https://cloud.google.com/iam/docs/overview#permissions).
  1375  	Permissions []string `json:"permissions,omitempty"`
  1376  	// ForceSendFields is a list of field names (e.g. "Permissions") to
  1377  	// unconditionally include in API requests. By default, fields with empty or
  1378  	// default values are omitted from API requests. See
  1379  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1380  	// details.
  1381  	ForceSendFields []string `json:"-"`
  1382  	// NullFields is a list of field names (e.g. "Permissions") to include in API
  1383  	// requests with the JSON null value. By default, fields with empty values are
  1384  	// omitted from API requests. See
  1385  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1386  	NullFields []string `json:"-"`
  1387  }
  1388  
  1389  func (s *TestIamPermissionsRequest) MarshalJSON() ([]byte, error) {
  1390  	type NoMethod TestIamPermissionsRequest
  1391  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1392  }
  1393  
  1394  // TestIamPermissionsResponse: Response message for `TestIamPermissions`
  1395  // method.
  1396  type TestIamPermissionsResponse struct {
  1397  	// Permissions: A subset of `TestPermissionsRequest.permissions` that the
  1398  	// caller is allowed.
  1399  	Permissions []string `json:"permissions,omitempty"`
  1400  
  1401  	// ServerResponse contains the HTTP response code and headers from the server.
  1402  	googleapi.ServerResponse `json:"-"`
  1403  	// ForceSendFields is a list of field names (e.g. "Permissions") to
  1404  	// unconditionally include in API requests. By default, fields with empty or
  1405  	// default values are omitted from API requests. See
  1406  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1407  	// details.
  1408  	ForceSendFields []string `json:"-"`
  1409  	// NullFields is a list of field names (e.g. "Permissions") to include in API
  1410  	// requests with the JSON null value. By default, fields with empty values are
  1411  	// omitted from API requests. See
  1412  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1413  	NullFields []string `json:"-"`
  1414  }
  1415  
  1416  func (s *TestIamPermissionsResponse) MarshalJSON() ([]byte, error) {
  1417  	type NoMethod TestIamPermissionsResponse
  1418  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1419  }
  1420  
  1421  // Version: The Data Fusion version. This proto message stores information
  1422  // about certain Data Fusion version, which is used for Data Fusion version
  1423  // upgrade.
  1424  type Version struct {
  1425  	// AvailableFeatures: Represents a list of available feature names for a given
  1426  	// version.
  1427  	AvailableFeatures []string `json:"availableFeatures,omitempty"`
  1428  	// DefaultVersion: Whether this is currently the default version for Cloud Data
  1429  	// Fusion
  1430  	DefaultVersion bool `json:"defaultVersion,omitempty"`
  1431  	// Type: Type represents the release availability of the version
  1432  	//
  1433  	// Possible values:
  1434  	//   "TYPE_UNSPECIFIED" - Version does not have availability yet
  1435  	//   "TYPE_PREVIEW" - Version is under development and not considered stable
  1436  	//   "TYPE_GENERAL_AVAILABILITY" - Version is available for public use
  1437  	Type string `json:"type,omitempty"`
  1438  	// VersionNumber: The version number of the Data Fusion instance, such as
  1439  	// '6.0.1.0'.
  1440  	VersionNumber string `json:"versionNumber,omitempty"`
  1441  	// ForceSendFields is a list of field names (e.g. "AvailableFeatures") to
  1442  	// unconditionally include in API requests. By default, fields with empty or
  1443  	// default values are omitted from API requests. See
  1444  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1445  	// details.
  1446  	ForceSendFields []string `json:"-"`
  1447  	// NullFields is a list of field names (e.g. "AvailableFeatures") to include in
  1448  	// API requests with the JSON null value. By default, fields with empty values
  1449  	// are omitted from API requests. See
  1450  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1451  	NullFields []string `json:"-"`
  1452  }
  1453  
  1454  func (s *Version) MarshalJSON() ([]byte, error) {
  1455  	type NoMethod Version
  1456  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1457  }
  1458  
  1459  type ProjectsLocationsGetCall struct {
  1460  	s            *Service
  1461  	name         string
  1462  	urlParams_   gensupport.URLParams
  1463  	ifNoneMatch_ string
  1464  	ctx_         context.Context
  1465  	header_      http.Header
  1466  }
  1467  
  1468  // Get: Gets information about a location.
  1469  //
  1470  // - name: Resource name for the location.
  1471  func (r *ProjectsLocationsService) Get(name string) *ProjectsLocationsGetCall {
  1472  	c := &ProjectsLocationsGetCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  1473  	c.name = name
  1474  	return c
  1475  }
  1476  
  1477  // Fields allows partial responses to be retrieved. See
  1478  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  1479  // details.
  1480  func (c *ProjectsLocationsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsGetCall {
  1481  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  1482  	return c
  1483  }
  1484  
  1485  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  1486  // object's ETag matches the given value. This is useful for getting updates
  1487  // only after the object has changed since the last request.
  1488  func (c *ProjectsLocationsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsGetCall {
  1489  	c.ifNoneMatch_ = entityTag
  1490  	return c
  1491  }
  1492  
  1493  // Context sets the context to be used in this call's Do method.
  1494  func (c *ProjectsLocationsGetCall) Context(ctx context.Context) *ProjectsLocationsGetCall {
  1495  	c.ctx_ = ctx
  1496  	return c
  1497  }
  1498  
  1499  // Header returns a http.Header that can be modified by the caller to add
  1500  // headers to the request.
  1501  func (c *ProjectsLocationsGetCall) Header() http.Header {
  1502  	if c.header_ == nil {
  1503  		c.header_ = make(http.Header)
  1504  	}
  1505  	return c.header_
  1506  }
  1507  
  1508  func (c *ProjectsLocationsGetCall) doRequest(alt string) (*http.Response, error) {
  1509  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  1510  	if c.ifNoneMatch_ != "" {
  1511  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  1512  	}
  1513  	var body io.Reader = nil
  1514  	c.urlParams_.Set("alt", alt)
  1515  	c.urlParams_.Set("prettyPrint", "false")
  1516  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1/{+name}")
  1517  	urls += "?" + c.urlParams_.Encode()
  1518  	req, err := http.NewRequest("GET", urls, body)
  1519  	if err != nil {
  1520  		return nil, err
  1521  	}
  1522  	req.Header = reqHeaders
  1523  	googleapi.Expand(req.URL, map[string]string{
  1524  		"name": c.name,
  1525  	})
  1526  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  1527  }
  1528  
  1529  // Do executes the "datafusion.projects.locations.get" call.
  1530  // Any non-2xx status code is an error. Response headers are in either
  1531  // *Location.ServerResponse.Header or (if a response was returned at all) in
  1532  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  1533  // whether the returned error was because http.StatusNotModified was returned.
  1534  func (c *ProjectsLocationsGetCall) Do(opts ...googleapi.CallOption) (*Location, error) {
  1535  	gensupport.SetOptions(c.urlParams_, opts...)
  1536  	res, err := c.doRequest("json")
  1537  	if res != nil && res.StatusCode == http.StatusNotModified {
  1538  		if res.Body != nil {
  1539  			res.Body.Close()
  1540  		}
  1541  		return nil, gensupport.WrapError(&googleapi.Error{
  1542  			Code:   res.StatusCode,
  1543  			Header: res.Header,
  1544  		})
  1545  	}
  1546  	if err != nil {
  1547  		return nil, err
  1548  	}
  1549  	defer googleapi.CloseBody(res)
  1550  	if err := googleapi.CheckResponse(res); err != nil {
  1551  		return nil, gensupport.WrapError(err)
  1552  	}
  1553  	ret := &Location{
  1554  		ServerResponse: googleapi.ServerResponse{
  1555  			Header:         res.Header,
  1556  			HTTPStatusCode: res.StatusCode,
  1557  		},
  1558  	}
  1559  	target := &ret
  1560  	if err := gensupport.DecodeResponse(target, res); err != nil {
  1561  		return nil, err
  1562  	}
  1563  	return ret, nil
  1564  }
  1565  
  1566  type ProjectsLocationsListCall struct {
  1567  	s            *Service
  1568  	name         string
  1569  	urlParams_   gensupport.URLParams
  1570  	ifNoneMatch_ string
  1571  	ctx_         context.Context
  1572  	header_      http.Header
  1573  }
  1574  
  1575  // List: Lists information about the supported locations for this service.
  1576  //
  1577  // - name: The resource that owns the locations collection, if applicable.
  1578  func (r *ProjectsLocationsService) List(name string) *ProjectsLocationsListCall {
  1579  	c := &ProjectsLocationsListCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  1580  	c.name = name
  1581  	return c
  1582  }
  1583  
  1584  // Filter sets the optional parameter "filter": A filter to narrow down results
  1585  // to a preferred subset. The filtering language accepts strings like
  1586  // "displayName=tokyo", and is documented in more detail in AIP-160
  1587  // (https://google.aip.dev/160).
  1588  func (c *ProjectsLocationsListCall) Filter(filter string) *ProjectsLocationsListCall {
  1589  	c.urlParams_.Set("filter", filter)
  1590  	return c
  1591  }
  1592  
  1593  // IncludeUnrevealedLocations sets the optional parameter
  1594  // "includeUnrevealedLocations": If true, the returned list will include
  1595  // locations which are not yet revealed.
  1596  func (c *ProjectsLocationsListCall) IncludeUnrevealedLocations(includeUnrevealedLocations bool) *ProjectsLocationsListCall {
  1597  	c.urlParams_.Set("includeUnrevealedLocations", fmt.Sprint(includeUnrevealedLocations))
  1598  	return c
  1599  }
  1600  
  1601  // PageSize sets the optional parameter "pageSize": The maximum number of
  1602  // results to return. If not set, the service selects a default.
  1603  func (c *ProjectsLocationsListCall) PageSize(pageSize int64) *ProjectsLocationsListCall {
  1604  	c.urlParams_.Set("pageSize", fmt.Sprint(pageSize))
  1605  	return c
  1606  }
  1607  
  1608  // PageToken sets the optional parameter "pageToken": A page token received
  1609  // from the `next_page_token` field in the response. Send that page token to
  1610  // receive the subsequent page.
  1611  func (c *ProjectsLocationsListCall) PageToken(pageToken string) *ProjectsLocationsListCall {
  1612  	c.urlParams_.Set("pageToken", pageToken)
  1613  	return c
  1614  }
  1615  
  1616  // Fields allows partial responses to be retrieved. See
  1617  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  1618  // details.
  1619  func (c *ProjectsLocationsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsListCall {
  1620  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  1621  	return c
  1622  }
  1623  
  1624  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  1625  // object's ETag matches the given value. This is useful for getting updates
  1626  // only after the object has changed since the last request.
  1627  func (c *ProjectsLocationsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsListCall {
  1628  	c.ifNoneMatch_ = entityTag
  1629  	return c
  1630  }
  1631  
  1632  // Context sets the context to be used in this call's Do method.
  1633  func (c *ProjectsLocationsListCall) Context(ctx context.Context) *ProjectsLocationsListCall {
  1634  	c.ctx_ = ctx
  1635  	return c
  1636  }
  1637  
  1638  // Header returns a http.Header that can be modified by the caller to add
  1639  // headers to the request.
  1640  func (c *ProjectsLocationsListCall) Header() http.Header {
  1641  	if c.header_ == nil {
  1642  		c.header_ = make(http.Header)
  1643  	}
  1644  	return c.header_
  1645  }
  1646  
  1647  func (c *ProjectsLocationsListCall) doRequest(alt string) (*http.Response, error) {
  1648  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  1649  	if c.ifNoneMatch_ != "" {
  1650  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  1651  	}
  1652  	var body io.Reader = nil
  1653  	c.urlParams_.Set("alt", alt)
  1654  	c.urlParams_.Set("prettyPrint", "false")
  1655  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1/{+name}/locations")
  1656  	urls += "?" + c.urlParams_.Encode()
  1657  	req, err := http.NewRequest("GET", urls, body)
  1658  	if err != nil {
  1659  		return nil, err
  1660  	}
  1661  	req.Header = reqHeaders
  1662  	googleapi.Expand(req.URL, map[string]string{
  1663  		"name": c.name,
  1664  	})
  1665  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  1666  }
  1667  
  1668  // Do executes the "datafusion.projects.locations.list" call.
  1669  // Any non-2xx status code is an error. Response headers are in either
  1670  // *ListLocationsResponse.ServerResponse.Header or (if a response was returned
  1671  // at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to
  1672  // check whether the returned error was because http.StatusNotModified was
  1673  // returned.
  1674  func (c *ProjectsLocationsListCall) Do(opts ...googleapi.CallOption) (*ListLocationsResponse, error) {
  1675  	gensupport.SetOptions(c.urlParams_, opts...)
  1676  	res, err := c.doRequest("json")
  1677  	if res != nil && res.StatusCode == http.StatusNotModified {
  1678  		if res.Body != nil {
  1679  			res.Body.Close()
  1680  		}
  1681  		return nil, gensupport.WrapError(&googleapi.Error{
  1682  			Code:   res.StatusCode,
  1683  			Header: res.Header,
  1684  		})
  1685  	}
  1686  	if err != nil {
  1687  		return nil, err
  1688  	}
  1689  	defer googleapi.CloseBody(res)
  1690  	if err := googleapi.CheckResponse(res); err != nil {
  1691  		return nil, gensupport.WrapError(err)
  1692  	}
  1693  	ret := &ListLocationsResponse{
  1694  		ServerResponse: googleapi.ServerResponse{
  1695  			Header:         res.Header,
  1696  			HTTPStatusCode: res.StatusCode,
  1697  		},
  1698  	}
  1699  	target := &ret
  1700  	if err := gensupport.DecodeResponse(target, res); err != nil {
  1701  		return nil, err
  1702  	}
  1703  	return ret, nil
  1704  }
  1705  
  1706  // Pages invokes f for each page of results.
  1707  // A non-nil error returned from f will halt the iteration.
  1708  // The provided context supersedes any context provided to the Context method.
  1709  func (c *ProjectsLocationsListCall) Pages(ctx context.Context, f func(*ListLocationsResponse) error) error {
  1710  	c.ctx_ = ctx
  1711  	defer c.PageToken(c.urlParams_.Get("pageToken"))
  1712  	for {
  1713  		x, err := c.Do()
  1714  		if err != nil {
  1715  			return err
  1716  		}
  1717  		if err := f(x); err != nil {
  1718  			return err
  1719  		}
  1720  		if x.NextPageToken == "" {
  1721  			return nil
  1722  		}
  1723  		c.PageToken(x.NextPageToken)
  1724  	}
  1725  }
  1726  
  1727  type ProjectsLocationsInstancesCreateCall struct {
  1728  	s          *Service
  1729  	parent     string
  1730  	instance   *Instance
  1731  	urlParams_ gensupport.URLParams
  1732  	ctx_       context.Context
  1733  	header_    http.Header
  1734  }
  1735  
  1736  // Create: Creates a new Data Fusion instance in the specified project and
  1737  // location.
  1738  //
  1739  //   - parent: The instance's project and location in the format
  1740  //     projects/{project}/locations/{location}.
  1741  func (r *ProjectsLocationsInstancesService) Create(parent string, instance *Instance) *ProjectsLocationsInstancesCreateCall {
  1742  	c := &ProjectsLocationsInstancesCreateCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  1743  	c.parent = parent
  1744  	c.instance = instance
  1745  	return c
  1746  }
  1747  
  1748  // InstanceId sets the optional parameter "instanceId": Required. The name of
  1749  // the instance to create. Instance name can only contain lowercase
  1750  // alphanumeric characters and hyphens. It must start with a letter and must
  1751  // not end with a hyphen. It can have a maximum of 30 characters.
  1752  func (c *ProjectsLocationsInstancesCreateCall) InstanceId(instanceId string) *ProjectsLocationsInstancesCreateCall {
  1753  	c.urlParams_.Set("instanceId", instanceId)
  1754  	return c
  1755  }
  1756  
  1757  // Fields allows partial responses to be retrieved. See
  1758  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  1759  // details.
  1760  func (c *ProjectsLocationsInstancesCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsInstancesCreateCall {
  1761  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  1762  	return c
  1763  }
  1764  
  1765  // Context sets the context to be used in this call's Do method.
  1766  func (c *ProjectsLocationsInstancesCreateCall) Context(ctx context.Context) *ProjectsLocationsInstancesCreateCall {
  1767  	c.ctx_ = ctx
  1768  	return c
  1769  }
  1770  
  1771  // Header returns a http.Header that can be modified by the caller to add
  1772  // headers to the request.
  1773  func (c *ProjectsLocationsInstancesCreateCall) Header() http.Header {
  1774  	if c.header_ == nil {
  1775  		c.header_ = make(http.Header)
  1776  	}
  1777  	return c.header_
  1778  }
  1779  
  1780  func (c *ProjectsLocationsInstancesCreateCall) doRequest(alt string) (*http.Response, error) {
  1781  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
  1782  	var body io.Reader = nil
  1783  	body, err := googleapi.WithoutDataWrapper.JSONReader(c.instance)
  1784  	if err != nil {
  1785  		return nil, err
  1786  	}
  1787  	c.urlParams_.Set("alt", alt)
  1788  	c.urlParams_.Set("prettyPrint", "false")
  1789  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1/{+parent}/instances")
  1790  	urls += "?" + c.urlParams_.Encode()
  1791  	req, err := http.NewRequest("POST", urls, body)
  1792  	if err != nil {
  1793  		return nil, err
  1794  	}
  1795  	req.Header = reqHeaders
  1796  	googleapi.Expand(req.URL, map[string]string{
  1797  		"parent": c.parent,
  1798  	})
  1799  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  1800  }
  1801  
  1802  // Do executes the "datafusion.projects.locations.instances.create" call.
  1803  // Any non-2xx status code is an error. Response headers are in either
  1804  // *Operation.ServerResponse.Header or (if a response was returned at all) in
  1805  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  1806  // whether the returned error was because http.StatusNotModified was returned.
  1807  func (c *ProjectsLocationsInstancesCreateCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
  1808  	gensupport.SetOptions(c.urlParams_, opts...)
  1809  	res, err := c.doRequest("json")
  1810  	if res != nil && res.StatusCode == http.StatusNotModified {
  1811  		if res.Body != nil {
  1812  			res.Body.Close()
  1813  		}
  1814  		return nil, gensupport.WrapError(&googleapi.Error{
  1815  			Code:   res.StatusCode,
  1816  			Header: res.Header,
  1817  		})
  1818  	}
  1819  	if err != nil {
  1820  		return nil, err
  1821  	}
  1822  	defer googleapi.CloseBody(res)
  1823  	if err := googleapi.CheckResponse(res); err != nil {
  1824  		return nil, gensupport.WrapError(err)
  1825  	}
  1826  	ret := &Operation{
  1827  		ServerResponse: googleapi.ServerResponse{
  1828  			Header:         res.Header,
  1829  			HTTPStatusCode: res.StatusCode,
  1830  		},
  1831  	}
  1832  	target := &ret
  1833  	if err := gensupport.DecodeResponse(target, res); err != nil {
  1834  		return nil, err
  1835  	}
  1836  	return ret, nil
  1837  }
  1838  
  1839  type ProjectsLocationsInstancesDeleteCall struct {
  1840  	s          *Service
  1841  	name       string
  1842  	urlParams_ gensupport.URLParams
  1843  	ctx_       context.Context
  1844  	header_    http.Header
  1845  }
  1846  
  1847  // Delete: Deletes a single Date Fusion instance.
  1848  //
  1849  //   - name: The instance resource name in the format
  1850  //     projects/{project}/locations/{location}/instances/{instance}.
  1851  func (r *ProjectsLocationsInstancesService) Delete(name string) *ProjectsLocationsInstancesDeleteCall {
  1852  	c := &ProjectsLocationsInstancesDeleteCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  1853  	c.name = name
  1854  	return c
  1855  }
  1856  
  1857  // Fields allows partial responses to be retrieved. See
  1858  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  1859  // details.
  1860  func (c *ProjectsLocationsInstancesDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsInstancesDeleteCall {
  1861  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  1862  	return c
  1863  }
  1864  
  1865  // Context sets the context to be used in this call's Do method.
  1866  func (c *ProjectsLocationsInstancesDeleteCall) Context(ctx context.Context) *ProjectsLocationsInstancesDeleteCall {
  1867  	c.ctx_ = ctx
  1868  	return c
  1869  }
  1870  
  1871  // Header returns a http.Header that can be modified by the caller to add
  1872  // headers to the request.
  1873  func (c *ProjectsLocationsInstancesDeleteCall) Header() http.Header {
  1874  	if c.header_ == nil {
  1875  		c.header_ = make(http.Header)
  1876  	}
  1877  	return c.header_
  1878  }
  1879  
  1880  func (c *ProjectsLocationsInstancesDeleteCall) doRequest(alt string) (*http.Response, error) {
  1881  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  1882  	var body io.Reader = nil
  1883  	c.urlParams_.Set("alt", alt)
  1884  	c.urlParams_.Set("prettyPrint", "false")
  1885  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1/{+name}")
  1886  	urls += "?" + c.urlParams_.Encode()
  1887  	req, err := http.NewRequest("DELETE", urls, body)
  1888  	if err != nil {
  1889  		return nil, err
  1890  	}
  1891  	req.Header = reqHeaders
  1892  	googleapi.Expand(req.URL, map[string]string{
  1893  		"name": c.name,
  1894  	})
  1895  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  1896  }
  1897  
  1898  // Do executes the "datafusion.projects.locations.instances.delete" call.
  1899  // Any non-2xx status code is an error. Response headers are in either
  1900  // *Operation.ServerResponse.Header or (if a response was returned at all) in
  1901  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  1902  // whether the returned error was because http.StatusNotModified was returned.
  1903  func (c *ProjectsLocationsInstancesDeleteCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
  1904  	gensupport.SetOptions(c.urlParams_, opts...)
  1905  	res, err := c.doRequest("json")
  1906  	if res != nil && res.StatusCode == http.StatusNotModified {
  1907  		if res.Body != nil {
  1908  			res.Body.Close()
  1909  		}
  1910  		return nil, gensupport.WrapError(&googleapi.Error{
  1911  			Code:   res.StatusCode,
  1912  			Header: res.Header,
  1913  		})
  1914  	}
  1915  	if err != nil {
  1916  		return nil, err
  1917  	}
  1918  	defer googleapi.CloseBody(res)
  1919  	if err := googleapi.CheckResponse(res); err != nil {
  1920  		return nil, gensupport.WrapError(err)
  1921  	}
  1922  	ret := &Operation{
  1923  		ServerResponse: googleapi.ServerResponse{
  1924  			Header:         res.Header,
  1925  			HTTPStatusCode: res.StatusCode,
  1926  		},
  1927  	}
  1928  	target := &ret
  1929  	if err := gensupport.DecodeResponse(target, res); err != nil {
  1930  		return nil, err
  1931  	}
  1932  	return ret, nil
  1933  }
  1934  
  1935  type ProjectsLocationsInstancesGetCall struct {
  1936  	s            *Service
  1937  	name         string
  1938  	urlParams_   gensupport.URLParams
  1939  	ifNoneMatch_ string
  1940  	ctx_         context.Context
  1941  	header_      http.Header
  1942  }
  1943  
  1944  // Get: Gets details of a single Data Fusion instance.
  1945  //
  1946  //   - name: The instance resource name in the format
  1947  //     projects/{project}/locations/{location}/instances/{instance}.
  1948  func (r *ProjectsLocationsInstancesService) Get(name string) *ProjectsLocationsInstancesGetCall {
  1949  	c := &ProjectsLocationsInstancesGetCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  1950  	c.name = name
  1951  	return c
  1952  }
  1953  
  1954  // Fields allows partial responses to be retrieved. See
  1955  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  1956  // details.
  1957  func (c *ProjectsLocationsInstancesGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsInstancesGetCall {
  1958  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  1959  	return c
  1960  }
  1961  
  1962  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  1963  // object's ETag matches the given value. This is useful for getting updates
  1964  // only after the object has changed since the last request.
  1965  func (c *ProjectsLocationsInstancesGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsInstancesGetCall {
  1966  	c.ifNoneMatch_ = entityTag
  1967  	return c
  1968  }
  1969  
  1970  // Context sets the context to be used in this call's Do method.
  1971  func (c *ProjectsLocationsInstancesGetCall) Context(ctx context.Context) *ProjectsLocationsInstancesGetCall {
  1972  	c.ctx_ = ctx
  1973  	return c
  1974  }
  1975  
  1976  // Header returns a http.Header that can be modified by the caller to add
  1977  // headers to the request.
  1978  func (c *ProjectsLocationsInstancesGetCall) Header() http.Header {
  1979  	if c.header_ == nil {
  1980  		c.header_ = make(http.Header)
  1981  	}
  1982  	return c.header_
  1983  }
  1984  
  1985  func (c *ProjectsLocationsInstancesGetCall) doRequest(alt string) (*http.Response, error) {
  1986  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  1987  	if c.ifNoneMatch_ != "" {
  1988  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  1989  	}
  1990  	var body io.Reader = nil
  1991  	c.urlParams_.Set("alt", alt)
  1992  	c.urlParams_.Set("prettyPrint", "false")
  1993  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1/{+name}")
  1994  	urls += "?" + c.urlParams_.Encode()
  1995  	req, err := http.NewRequest("GET", urls, body)
  1996  	if err != nil {
  1997  		return nil, err
  1998  	}
  1999  	req.Header = reqHeaders
  2000  	googleapi.Expand(req.URL, map[string]string{
  2001  		"name": c.name,
  2002  	})
  2003  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  2004  }
  2005  
  2006  // Do executes the "datafusion.projects.locations.instances.get" call.
  2007  // Any non-2xx status code is an error. Response headers are in either
  2008  // *Instance.ServerResponse.Header or (if a response was returned at all) in
  2009  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  2010  // whether the returned error was because http.StatusNotModified was returned.
  2011  func (c *ProjectsLocationsInstancesGetCall) Do(opts ...googleapi.CallOption) (*Instance, error) {
  2012  	gensupport.SetOptions(c.urlParams_, opts...)
  2013  	res, err := c.doRequest("json")
  2014  	if res != nil && res.StatusCode == http.StatusNotModified {
  2015  		if res.Body != nil {
  2016  			res.Body.Close()
  2017  		}
  2018  		return nil, gensupport.WrapError(&googleapi.Error{
  2019  			Code:   res.StatusCode,
  2020  			Header: res.Header,
  2021  		})
  2022  	}
  2023  	if err != nil {
  2024  		return nil, err
  2025  	}
  2026  	defer googleapi.CloseBody(res)
  2027  	if err := googleapi.CheckResponse(res); err != nil {
  2028  		return nil, gensupport.WrapError(err)
  2029  	}
  2030  	ret := &Instance{
  2031  		ServerResponse: googleapi.ServerResponse{
  2032  			Header:         res.Header,
  2033  			HTTPStatusCode: res.StatusCode,
  2034  		},
  2035  	}
  2036  	target := &ret
  2037  	if err := gensupport.DecodeResponse(target, res); err != nil {
  2038  		return nil, err
  2039  	}
  2040  	return ret, nil
  2041  }
  2042  
  2043  type ProjectsLocationsInstancesGetIamPolicyCall struct {
  2044  	s            *Service
  2045  	resource     string
  2046  	urlParams_   gensupport.URLParams
  2047  	ifNoneMatch_ string
  2048  	ctx_         context.Context
  2049  	header_      http.Header
  2050  }
  2051  
  2052  // GetIamPolicy: Gets the access control policy for a resource. Returns an
  2053  // empty policy if the resource exists and does not have a policy set.
  2054  //
  2055  //   - resource: REQUIRED: The resource for which the policy is being requested.
  2056  //     See Resource names (https://cloud.google.com/apis/design/resource_names)
  2057  //     for the appropriate value for this field.
  2058  func (r *ProjectsLocationsInstancesService) GetIamPolicy(resource string) *ProjectsLocationsInstancesGetIamPolicyCall {
  2059  	c := &ProjectsLocationsInstancesGetIamPolicyCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  2060  	c.resource = resource
  2061  	return c
  2062  }
  2063  
  2064  // OptionsRequestedPolicyVersion sets the optional parameter
  2065  // "options.requestedPolicyVersion": The maximum policy version that will be
  2066  // used to format the policy. Valid values are 0, 1, and 3. Requests specifying
  2067  // an invalid value will be rejected. Requests for policies with any
  2068  // conditional role bindings must specify version 3. Policies with no
  2069  // conditional role bindings may specify any valid value or leave the field
  2070  // unset. The policy in the response might use the policy version that you
  2071  // specified, or it might use a lower policy version. For example, if you
  2072  // specify version 3, but the policy has no conditional role bindings, the
  2073  // response uses version 1. To learn which resources support conditions in
  2074  // their IAM policies, see the IAM documentation
  2075  // (https://cloud.google.com/iam/help/conditions/resource-policies).
  2076  func (c *ProjectsLocationsInstancesGetIamPolicyCall) OptionsRequestedPolicyVersion(optionsRequestedPolicyVersion int64) *ProjectsLocationsInstancesGetIamPolicyCall {
  2077  	c.urlParams_.Set("options.requestedPolicyVersion", fmt.Sprint(optionsRequestedPolicyVersion))
  2078  	return c
  2079  }
  2080  
  2081  // Fields allows partial responses to be retrieved. See
  2082  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  2083  // details.
  2084  func (c *ProjectsLocationsInstancesGetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsLocationsInstancesGetIamPolicyCall {
  2085  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  2086  	return c
  2087  }
  2088  
  2089  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  2090  // object's ETag matches the given value. This is useful for getting updates
  2091  // only after the object has changed since the last request.
  2092  func (c *ProjectsLocationsInstancesGetIamPolicyCall) IfNoneMatch(entityTag string) *ProjectsLocationsInstancesGetIamPolicyCall {
  2093  	c.ifNoneMatch_ = entityTag
  2094  	return c
  2095  }
  2096  
  2097  // Context sets the context to be used in this call's Do method.
  2098  func (c *ProjectsLocationsInstancesGetIamPolicyCall) Context(ctx context.Context) *ProjectsLocationsInstancesGetIamPolicyCall {
  2099  	c.ctx_ = ctx
  2100  	return c
  2101  }
  2102  
  2103  // Header returns a http.Header that can be modified by the caller to add
  2104  // headers to the request.
  2105  func (c *ProjectsLocationsInstancesGetIamPolicyCall) Header() http.Header {
  2106  	if c.header_ == nil {
  2107  		c.header_ = make(http.Header)
  2108  	}
  2109  	return c.header_
  2110  }
  2111  
  2112  func (c *ProjectsLocationsInstancesGetIamPolicyCall) doRequest(alt string) (*http.Response, error) {
  2113  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  2114  	if c.ifNoneMatch_ != "" {
  2115  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  2116  	}
  2117  	var body io.Reader = nil
  2118  	c.urlParams_.Set("alt", alt)
  2119  	c.urlParams_.Set("prettyPrint", "false")
  2120  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1/{+resource}:getIamPolicy")
  2121  	urls += "?" + c.urlParams_.Encode()
  2122  	req, err := http.NewRequest("GET", urls, body)
  2123  	if err != nil {
  2124  		return nil, err
  2125  	}
  2126  	req.Header = reqHeaders
  2127  	googleapi.Expand(req.URL, map[string]string{
  2128  		"resource": c.resource,
  2129  	})
  2130  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  2131  }
  2132  
  2133  // Do executes the "datafusion.projects.locations.instances.getIamPolicy" call.
  2134  // Any non-2xx status code is an error. Response headers are in either
  2135  // *Policy.ServerResponse.Header or (if a response was returned at all) in
  2136  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  2137  // whether the returned error was because http.StatusNotModified was returned.
  2138  func (c *ProjectsLocationsInstancesGetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error) {
  2139  	gensupport.SetOptions(c.urlParams_, opts...)
  2140  	res, err := c.doRequest("json")
  2141  	if res != nil && res.StatusCode == http.StatusNotModified {
  2142  		if res.Body != nil {
  2143  			res.Body.Close()
  2144  		}
  2145  		return nil, gensupport.WrapError(&googleapi.Error{
  2146  			Code:   res.StatusCode,
  2147  			Header: res.Header,
  2148  		})
  2149  	}
  2150  	if err != nil {
  2151  		return nil, err
  2152  	}
  2153  	defer googleapi.CloseBody(res)
  2154  	if err := googleapi.CheckResponse(res); err != nil {
  2155  		return nil, gensupport.WrapError(err)
  2156  	}
  2157  	ret := &Policy{
  2158  		ServerResponse: googleapi.ServerResponse{
  2159  			Header:         res.Header,
  2160  			HTTPStatusCode: res.StatusCode,
  2161  		},
  2162  	}
  2163  	target := &ret
  2164  	if err := gensupport.DecodeResponse(target, res); err != nil {
  2165  		return nil, err
  2166  	}
  2167  	return ret, nil
  2168  }
  2169  
  2170  type ProjectsLocationsInstancesListCall struct {
  2171  	s            *Service
  2172  	parent       string
  2173  	urlParams_   gensupport.URLParams
  2174  	ifNoneMatch_ string
  2175  	ctx_         context.Context
  2176  	header_      http.Header
  2177  }
  2178  
  2179  // List: Lists Data Fusion instances in the specified project and location.
  2180  //
  2181  //   - parent: The project and location for which to retrieve instance
  2182  //     information in the format projects/{project}/locations/{location}. If the
  2183  //     location is specified as '-' (wildcard), then all regions available to the
  2184  //     project are queried, and the results are aggregated.
  2185  func (r *ProjectsLocationsInstancesService) List(parent string) *ProjectsLocationsInstancesListCall {
  2186  	c := &ProjectsLocationsInstancesListCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  2187  	c.parent = parent
  2188  	return c
  2189  }
  2190  
  2191  // Filter sets the optional parameter "filter": List filter.
  2192  func (c *ProjectsLocationsInstancesListCall) Filter(filter string) *ProjectsLocationsInstancesListCall {
  2193  	c.urlParams_.Set("filter", filter)
  2194  	return c
  2195  }
  2196  
  2197  // OrderBy sets the optional parameter "orderBy": Sort results. Supported
  2198  // values are "name", "name desc", or "" (unsorted).
  2199  func (c *ProjectsLocationsInstancesListCall) OrderBy(orderBy string) *ProjectsLocationsInstancesListCall {
  2200  	c.urlParams_.Set("orderBy", orderBy)
  2201  	return c
  2202  }
  2203  
  2204  // PageSize sets the optional parameter "pageSize": The maximum number of items
  2205  // to return.
  2206  func (c *ProjectsLocationsInstancesListCall) PageSize(pageSize int64) *ProjectsLocationsInstancesListCall {
  2207  	c.urlParams_.Set("pageSize", fmt.Sprint(pageSize))
  2208  	return c
  2209  }
  2210  
  2211  // PageToken sets the optional parameter "pageToken": The next_page_token value
  2212  // to use if there are additional results to retrieve for this list request.
  2213  func (c *ProjectsLocationsInstancesListCall) PageToken(pageToken string) *ProjectsLocationsInstancesListCall {
  2214  	c.urlParams_.Set("pageToken", pageToken)
  2215  	return c
  2216  }
  2217  
  2218  // Fields allows partial responses to be retrieved. See
  2219  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  2220  // details.
  2221  func (c *ProjectsLocationsInstancesListCall) Fields(s ...googleapi.Field) *ProjectsLocationsInstancesListCall {
  2222  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  2223  	return c
  2224  }
  2225  
  2226  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  2227  // object's ETag matches the given value. This is useful for getting updates
  2228  // only after the object has changed since the last request.
  2229  func (c *ProjectsLocationsInstancesListCall) IfNoneMatch(entityTag string) *ProjectsLocationsInstancesListCall {
  2230  	c.ifNoneMatch_ = entityTag
  2231  	return c
  2232  }
  2233  
  2234  // Context sets the context to be used in this call's Do method.
  2235  func (c *ProjectsLocationsInstancesListCall) Context(ctx context.Context) *ProjectsLocationsInstancesListCall {
  2236  	c.ctx_ = ctx
  2237  	return c
  2238  }
  2239  
  2240  // Header returns a http.Header that can be modified by the caller to add
  2241  // headers to the request.
  2242  func (c *ProjectsLocationsInstancesListCall) Header() http.Header {
  2243  	if c.header_ == nil {
  2244  		c.header_ = make(http.Header)
  2245  	}
  2246  	return c.header_
  2247  }
  2248  
  2249  func (c *ProjectsLocationsInstancesListCall) doRequest(alt string) (*http.Response, error) {
  2250  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  2251  	if c.ifNoneMatch_ != "" {
  2252  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  2253  	}
  2254  	var body io.Reader = nil
  2255  	c.urlParams_.Set("alt", alt)
  2256  	c.urlParams_.Set("prettyPrint", "false")
  2257  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1/{+parent}/instances")
  2258  	urls += "?" + c.urlParams_.Encode()
  2259  	req, err := http.NewRequest("GET", urls, body)
  2260  	if err != nil {
  2261  		return nil, err
  2262  	}
  2263  	req.Header = reqHeaders
  2264  	googleapi.Expand(req.URL, map[string]string{
  2265  		"parent": c.parent,
  2266  	})
  2267  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  2268  }
  2269  
  2270  // Do executes the "datafusion.projects.locations.instances.list" call.
  2271  // Any non-2xx status code is an error. Response headers are in either
  2272  // *ListInstancesResponse.ServerResponse.Header or (if a response was returned
  2273  // at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to
  2274  // check whether the returned error was because http.StatusNotModified was
  2275  // returned.
  2276  func (c *ProjectsLocationsInstancesListCall) Do(opts ...googleapi.CallOption) (*ListInstancesResponse, error) {
  2277  	gensupport.SetOptions(c.urlParams_, opts...)
  2278  	res, err := c.doRequest("json")
  2279  	if res != nil && res.StatusCode == http.StatusNotModified {
  2280  		if res.Body != nil {
  2281  			res.Body.Close()
  2282  		}
  2283  		return nil, gensupport.WrapError(&googleapi.Error{
  2284  			Code:   res.StatusCode,
  2285  			Header: res.Header,
  2286  		})
  2287  	}
  2288  	if err != nil {
  2289  		return nil, err
  2290  	}
  2291  	defer googleapi.CloseBody(res)
  2292  	if err := googleapi.CheckResponse(res); err != nil {
  2293  		return nil, gensupport.WrapError(err)
  2294  	}
  2295  	ret := &ListInstancesResponse{
  2296  		ServerResponse: googleapi.ServerResponse{
  2297  			Header:         res.Header,
  2298  			HTTPStatusCode: res.StatusCode,
  2299  		},
  2300  	}
  2301  	target := &ret
  2302  	if err := gensupport.DecodeResponse(target, res); err != nil {
  2303  		return nil, err
  2304  	}
  2305  	return ret, nil
  2306  }
  2307  
  2308  // Pages invokes f for each page of results.
  2309  // A non-nil error returned from f will halt the iteration.
  2310  // The provided context supersedes any context provided to the Context method.
  2311  func (c *ProjectsLocationsInstancesListCall) Pages(ctx context.Context, f func(*ListInstancesResponse) error) error {
  2312  	c.ctx_ = ctx
  2313  	defer c.PageToken(c.urlParams_.Get("pageToken"))
  2314  	for {
  2315  		x, err := c.Do()
  2316  		if err != nil {
  2317  			return err
  2318  		}
  2319  		if err := f(x); err != nil {
  2320  			return err
  2321  		}
  2322  		if x.NextPageToken == "" {
  2323  			return nil
  2324  		}
  2325  		c.PageToken(x.NextPageToken)
  2326  	}
  2327  }
  2328  
  2329  type ProjectsLocationsInstancesPatchCall struct {
  2330  	s          *Service
  2331  	name       string
  2332  	instance   *Instance
  2333  	urlParams_ gensupport.URLParams
  2334  	ctx_       context.Context
  2335  	header_    http.Header
  2336  }
  2337  
  2338  // Patch: Updates a single Data Fusion instance.
  2339  //
  2340  //   - name: Output only. The name of this instance is in the form of
  2341  //     projects/{project}/locations/{location}/instances/{instance}.
  2342  func (r *ProjectsLocationsInstancesService) Patch(name string, instance *Instance) *ProjectsLocationsInstancesPatchCall {
  2343  	c := &ProjectsLocationsInstancesPatchCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  2344  	c.name = name
  2345  	c.instance = instance
  2346  	return c
  2347  }
  2348  
  2349  // UpdateMask sets the optional parameter "updateMask": Field mask is used to
  2350  // specify the fields that the update will overwrite in an instance resource.
  2351  // The fields specified in the update_mask are relative to the resource, not
  2352  // the full request. A field will be overwritten if it is in the mask. If the
  2353  // user does not provide a mask, the label field will be overwritten.
  2354  func (c *ProjectsLocationsInstancesPatchCall) UpdateMask(updateMask string) *ProjectsLocationsInstancesPatchCall {
  2355  	c.urlParams_.Set("updateMask", updateMask)
  2356  	return c
  2357  }
  2358  
  2359  // Fields allows partial responses to be retrieved. See
  2360  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  2361  // details.
  2362  func (c *ProjectsLocationsInstancesPatchCall) Fields(s ...googleapi.Field) *ProjectsLocationsInstancesPatchCall {
  2363  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  2364  	return c
  2365  }
  2366  
  2367  // Context sets the context to be used in this call's Do method.
  2368  func (c *ProjectsLocationsInstancesPatchCall) Context(ctx context.Context) *ProjectsLocationsInstancesPatchCall {
  2369  	c.ctx_ = ctx
  2370  	return c
  2371  }
  2372  
  2373  // Header returns a http.Header that can be modified by the caller to add
  2374  // headers to the request.
  2375  func (c *ProjectsLocationsInstancesPatchCall) Header() http.Header {
  2376  	if c.header_ == nil {
  2377  		c.header_ = make(http.Header)
  2378  	}
  2379  	return c.header_
  2380  }
  2381  
  2382  func (c *ProjectsLocationsInstancesPatchCall) doRequest(alt string) (*http.Response, error) {
  2383  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
  2384  	var body io.Reader = nil
  2385  	body, err := googleapi.WithoutDataWrapper.JSONReader(c.instance)
  2386  	if err != nil {
  2387  		return nil, err
  2388  	}
  2389  	c.urlParams_.Set("alt", alt)
  2390  	c.urlParams_.Set("prettyPrint", "false")
  2391  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1/{+name}")
  2392  	urls += "?" + c.urlParams_.Encode()
  2393  	req, err := http.NewRequest("PATCH", urls, body)
  2394  	if err != nil {
  2395  		return nil, err
  2396  	}
  2397  	req.Header = reqHeaders
  2398  	googleapi.Expand(req.URL, map[string]string{
  2399  		"name": c.name,
  2400  	})
  2401  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  2402  }
  2403  
  2404  // Do executes the "datafusion.projects.locations.instances.patch" call.
  2405  // Any non-2xx status code is an error. Response headers are in either
  2406  // *Operation.ServerResponse.Header or (if a response was returned at all) in
  2407  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  2408  // whether the returned error was because http.StatusNotModified was returned.
  2409  func (c *ProjectsLocationsInstancesPatchCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
  2410  	gensupport.SetOptions(c.urlParams_, opts...)
  2411  	res, err := c.doRequest("json")
  2412  	if res != nil && res.StatusCode == http.StatusNotModified {
  2413  		if res.Body != nil {
  2414  			res.Body.Close()
  2415  		}
  2416  		return nil, gensupport.WrapError(&googleapi.Error{
  2417  			Code:   res.StatusCode,
  2418  			Header: res.Header,
  2419  		})
  2420  	}
  2421  	if err != nil {
  2422  		return nil, err
  2423  	}
  2424  	defer googleapi.CloseBody(res)
  2425  	if err := googleapi.CheckResponse(res); err != nil {
  2426  		return nil, gensupport.WrapError(err)
  2427  	}
  2428  	ret := &Operation{
  2429  		ServerResponse: googleapi.ServerResponse{
  2430  			Header:         res.Header,
  2431  			HTTPStatusCode: res.StatusCode,
  2432  		},
  2433  	}
  2434  	target := &ret
  2435  	if err := gensupport.DecodeResponse(target, res); err != nil {
  2436  		return nil, err
  2437  	}
  2438  	return ret, nil
  2439  }
  2440  
  2441  type ProjectsLocationsInstancesRestartCall struct {
  2442  	s                      *Service
  2443  	name                   string
  2444  	restartinstancerequest *RestartInstanceRequest
  2445  	urlParams_             gensupport.URLParams
  2446  	ctx_                   context.Context
  2447  	header_                http.Header
  2448  }
  2449  
  2450  // Restart: Restart a single Data Fusion instance. At the end of an operation
  2451  // instance is fully restarted.
  2452  //
  2453  //   - name: Name of the Data Fusion instance which need to be restarted in the
  2454  //     form of projects/{project}/locations/{location}/instances/{instance}.
  2455  func (r *ProjectsLocationsInstancesService) Restart(name string, restartinstancerequest *RestartInstanceRequest) *ProjectsLocationsInstancesRestartCall {
  2456  	c := &ProjectsLocationsInstancesRestartCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  2457  	c.name = name
  2458  	c.restartinstancerequest = restartinstancerequest
  2459  	return c
  2460  }
  2461  
  2462  // Fields allows partial responses to be retrieved. See
  2463  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  2464  // details.
  2465  func (c *ProjectsLocationsInstancesRestartCall) Fields(s ...googleapi.Field) *ProjectsLocationsInstancesRestartCall {
  2466  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  2467  	return c
  2468  }
  2469  
  2470  // Context sets the context to be used in this call's Do method.
  2471  func (c *ProjectsLocationsInstancesRestartCall) Context(ctx context.Context) *ProjectsLocationsInstancesRestartCall {
  2472  	c.ctx_ = ctx
  2473  	return c
  2474  }
  2475  
  2476  // Header returns a http.Header that can be modified by the caller to add
  2477  // headers to the request.
  2478  func (c *ProjectsLocationsInstancesRestartCall) Header() http.Header {
  2479  	if c.header_ == nil {
  2480  		c.header_ = make(http.Header)
  2481  	}
  2482  	return c.header_
  2483  }
  2484  
  2485  func (c *ProjectsLocationsInstancesRestartCall) doRequest(alt string) (*http.Response, error) {
  2486  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
  2487  	var body io.Reader = nil
  2488  	body, err := googleapi.WithoutDataWrapper.JSONReader(c.restartinstancerequest)
  2489  	if err != nil {
  2490  		return nil, err
  2491  	}
  2492  	c.urlParams_.Set("alt", alt)
  2493  	c.urlParams_.Set("prettyPrint", "false")
  2494  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1/{+name}:restart")
  2495  	urls += "?" + c.urlParams_.Encode()
  2496  	req, err := http.NewRequest("POST", urls, body)
  2497  	if err != nil {
  2498  		return nil, err
  2499  	}
  2500  	req.Header = reqHeaders
  2501  	googleapi.Expand(req.URL, map[string]string{
  2502  		"name": c.name,
  2503  	})
  2504  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  2505  }
  2506  
  2507  // Do executes the "datafusion.projects.locations.instances.restart" call.
  2508  // Any non-2xx status code is an error. Response headers are in either
  2509  // *Operation.ServerResponse.Header or (if a response was returned at all) in
  2510  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  2511  // whether the returned error was because http.StatusNotModified was returned.
  2512  func (c *ProjectsLocationsInstancesRestartCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
  2513  	gensupport.SetOptions(c.urlParams_, opts...)
  2514  	res, err := c.doRequest("json")
  2515  	if res != nil && res.StatusCode == http.StatusNotModified {
  2516  		if res.Body != nil {
  2517  			res.Body.Close()
  2518  		}
  2519  		return nil, gensupport.WrapError(&googleapi.Error{
  2520  			Code:   res.StatusCode,
  2521  			Header: res.Header,
  2522  		})
  2523  	}
  2524  	if err != nil {
  2525  		return nil, err
  2526  	}
  2527  	defer googleapi.CloseBody(res)
  2528  	if err := googleapi.CheckResponse(res); err != nil {
  2529  		return nil, gensupport.WrapError(err)
  2530  	}
  2531  	ret := &Operation{
  2532  		ServerResponse: googleapi.ServerResponse{
  2533  			Header:         res.Header,
  2534  			HTTPStatusCode: res.StatusCode,
  2535  		},
  2536  	}
  2537  	target := &ret
  2538  	if err := gensupport.DecodeResponse(target, res); err != nil {
  2539  		return nil, err
  2540  	}
  2541  	return ret, nil
  2542  }
  2543  
  2544  type ProjectsLocationsInstancesSetIamPolicyCall struct {
  2545  	s                   *Service
  2546  	resource            string
  2547  	setiampolicyrequest *SetIamPolicyRequest
  2548  	urlParams_          gensupport.URLParams
  2549  	ctx_                context.Context
  2550  	header_             http.Header
  2551  }
  2552  
  2553  // SetIamPolicy: Sets the access control policy on the specified resource.
  2554  // Replaces any existing policy. Can return `NOT_FOUND`, `INVALID_ARGUMENT`,
  2555  // and `PERMISSION_DENIED` errors.
  2556  //
  2557  //   - resource: REQUIRED: The resource for which the policy is being specified.
  2558  //     See Resource names (https://cloud.google.com/apis/design/resource_names)
  2559  //     for the appropriate value for this field.
  2560  func (r *ProjectsLocationsInstancesService) SetIamPolicy(resource string, setiampolicyrequest *SetIamPolicyRequest) *ProjectsLocationsInstancesSetIamPolicyCall {
  2561  	c := &ProjectsLocationsInstancesSetIamPolicyCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  2562  	c.resource = resource
  2563  	c.setiampolicyrequest = setiampolicyrequest
  2564  	return c
  2565  }
  2566  
  2567  // Fields allows partial responses to be retrieved. See
  2568  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  2569  // details.
  2570  func (c *ProjectsLocationsInstancesSetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsLocationsInstancesSetIamPolicyCall {
  2571  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  2572  	return c
  2573  }
  2574  
  2575  // Context sets the context to be used in this call's Do method.
  2576  func (c *ProjectsLocationsInstancesSetIamPolicyCall) Context(ctx context.Context) *ProjectsLocationsInstancesSetIamPolicyCall {
  2577  	c.ctx_ = ctx
  2578  	return c
  2579  }
  2580  
  2581  // Header returns a http.Header that can be modified by the caller to add
  2582  // headers to the request.
  2583  func (c *ProjectsLocationsInstancesSetIamPolicyCall) Header() http.Header {
  2584  	if c.header_ == nil {
  2585  		c.header_ = make(http.Header)
  2586  	}
  2587  	return c.header_
  2588  }
  2589  
  2590  func (c *ProjectsLocationsInstancesSetIamPolicyCall) doRequest(alt string) (*http.Response, error) {
  2591  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
  2592  	var body io.Reader = nil
  2593  	body, err := googleapi.WithoutDataWrapper.JSONReader(c.setiampolicyrequest)
  2594  	if err != nil {
  2595  		return nil, err
  2596  	}
  2597  	c.urlParams_.Set("alt", alt)
  2598  	c.urlParams_.Set("prettyPrint", "false")
  2599  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1/{+resource}:setIamPolicy")
  2600  	urls += "?" + c.urlParams_.Encode()
  2601  	req, err := http.NewRequest("POST", urls, body)
  2602  	if err != nil {
  2603  		return nil, err
  2604  	}
  2605  	req.Header = reqHeaders
  2606  	googleapi.Expand(req.URL, map[string]string{
  2607  		"resource": c.resource,
  2608  	})
  2609  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  2610  }
  2611  
  2612  // Do executes the "datafusion.projects.locations.instances.setIamPolicy" call.
  2613  // Any non-2xx status code is an error. Response headers are in either
  2614  // *Policy.ServerResponse.Header or (if a response was returned at all) in
  2615  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  2616  // whether the returned error was because http.StatusNotModified was returned.
  2617  func (c *ProjectsLocationsInstancesSetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error) {
  2618  	gensupport.SetOptions(c.urlParams_, opts...)
  2619  	res, err := c.doRequest("json")
  2620  	if res != nil && res.StatusCode == http.StatusNotModified {
  2621  		if res.Body != nil {
  2622  			res.Body.Close()
  2623  		}
  2624  		return nil, gensupport.WrapError(&googleapi.Error{
  2625  			Code:   res.StatusCode,
  2626  			Header: res.Header,
  2627  		})
  2628  	}
  2629  	if err != nil {
  2630  		return nil, err
  2631  	}
  2632  	defer googleapi.CloseBody(res)
  2633  	if err := googleapi.CheckResponse(res); err != nil {
  2634  		return nil, gensupport.WrapError(err)
  2635  	}
  2636  	ret := &Policy{
  2637  		ServerResponse: googleapi.ServerResponse{
  2638  			Header:         res.Header,
  2639  			HTTPStatusCode: res.StatusCode,
  2640  		},
  2641  	}
  2642  	target := &ret
  2643  	if err := gensupport.DecodeResponse(target, res); err != nil {
  2644  		return nil, err
  2645  	}
  2646  	return ret, nil
  2647  }
  2648  
  2649  type ProjectsLocationsInstancesTestIamPermissionsCall struct {
  2650  	s                         *Service
  2651  	resource                  string
  2652  	testiampermissionsrequest *TestIamPermissionsRequest
  2653  	urlParams_                gensupport.URLParams
  2654  	ctx_                      context.Context
  2655  	header_                   http.Header
  2656  }
  2657  
  2658  // TestIamPermissions: Returns permissions that a caller has on the specified
  2659  // resource. If the resource does not exist, this will return an empty set of
  2660  // permissions, not a `NOT_FOUND` error. Note: This operation is designed to be
  2661  // used for building permission-aware UIs and command-line tools, not for
  2662  // authorization checking. This operation may "fail open" without warning.
  2663  //
  2664  //   - resource: REQUIRED: The resource for which the policy detail is being
  2665  //     requested. See Resource names
  2666  //     (https://cloud.google.com/apis/design/resource_names) for the appropriate
  2667  //     value for this field.
  2668  func (r *ProjectsLocationsInstancesService) TestIamPermissions(resource string, testiampermissionsrequest *TestIamPermissionsRequest) *ProjectsLocationsInstancesTestIamPermissionsCall {
  2669  	c := &ProjectsLocationsInstancesTestIamPermissionsCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  2670  	c.resource = resource
  2671  	c.testiampermissionsrequest = testiampermissionsrequest
  2672  	return c
  2673  }
  2674  
  2675  // Fields allows partial responses to be retrieved. See
  2676  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  2677  // details.
  2678  func (c *ProjectsLocationsInstancesTestIamPermissionsCall) Fields(s ...googleapi.Field) *ProjectsLocationsInstancesTestIamPermissionsCall {
  2679  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  2680  	return c
  2681  }
  2682  
  2683  // Context sets the context to be used in this call's Do method.
  2684  func (c *ProjectsLocationsInstancesTestIamPermissionsCall) Context(ctx context.Context) *ProjectsLocationsInstancesTestIamPermissionsCall {
  2685  	c.ctx_ = ctx
  2686  	return c
  2687  }
  2688  
  2689  // Header returns a http.Header that can be modified by the caller to add
  2690  // headers to the request.
  2691  func (c *ProjectsLocationsInstancesTestIamPermissionsCall) Header() http.Header {
  2692  	if c.header_ == nil {
  2693  		c.header_ = make(http.Header)
  2694  	}
  2695  	return c.header_
  2696  }
  2697  
  2698  func (c *ProjectsLocationsInstancesTestIamPermissionsCall) doRequest(alt string) (*http.Response, error) {
  2699  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
  2700  	var body io.Reader = nil
  2701  	body, err := googleapi.WithoutDataWrapper.JSONReader(c.testiampermissionsrequest)
  2702  	if err != nil {
  2703  		return nil, err
  2704  	}
  2705  	c.urlParams_.Set("alt", alt)
  2706  	c.urlParams_.Set("prettyPrint", "false")
  2707  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1/{+resource}:testIamPermissions")
  2708  	urls += "?" + c.urlParams_.Encode()
  2709  	req, err := http.NewRequest("POST", urls, body)
  2710  	if err != nil {
  2711  		return nil, err
  2712  	}
  2713  	req.Header = reqHeaders
  2714  	googleapi.Expand(req.URL, map[string]string{
  2715  		"resource": c.resource,
  2716  	})
  2717  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  2718  }
  2719  
  2720  // Do executes the "datafusion.projects.locations.instances.testIamPermissions" call.
  2721  // Any non-2xx status code is an error. Response headers are in either
  2722  // *TestIamPermissionsResponse.ServerResponse.Header or (if a response was
  2723  // returned at all) in error.(*googleapi.Error).Header. Use
  2724  // googleapi.IsNotModified to check whether the returned error was because
  2725  // http.StatusNotModified was returned.
  2726  func (c *ProjectsLocationsInstancesTestIamPermissionsCall) Do(opts ...googleapi.CallOption) (*TestIamPermissionsResponse, error) {
  2727  	gensupport.SetOptions(c.urlParams_, opts...)
  2728  	res, err := c.doRequest("json")
  2729  	if res != nil && res.StatusCode == http.StatusNotModified {
  2730  		if res.Body != nil {
  2731  			res.Body.Close()
  2732  		}
  2733  		return nil, gensupport.WrapError(&googleapi.Error{
  2734  			Code:   res.StatusCode,
  2735  			Header: res.Header,
  2736  		})
  2737  	}
  2738  	if err != nil {
  2739  		return nil, err
  2740  	}
  2741  	defer googleapi.CloseBody(res)
  2742  	if err := googleapi.CheckResponse(res); err != nil {
  2743  		return nil, gensupport.WrapError(err)
  2744  	}
  2745  	ret := &TestIamPermissionsResponse{
  2746  		ServerResponse: googleapi.ServerResponse{
  2747  			Header:         res.Header,
  2748  			HTTPStatusCode: res.StatusCode,
  2749  		},
  2750  	}
  2751  	target := &ret
  2752  	if err := gensupport.DecodeResponse(target, res); err != nil {
  2753  		return nil, err
  2754  	}
  2755  	return ret, nil
  2756  }
  2757  
  2758  type ProjectsLocationsInstancesDnsPeeringsCreateCall struct {
  2759  	s          *Service
  2760  	parent     string
  2761  	dnspeering *DnsPeering
  2762  	urlParams_ gensupport.URLParams
  2763  	ctx_       context.Context
  2764  	header_    http.Header
  2765  }
  2766  
  2767  // Create: Creates DNS peering on the given resource.
  2768  //
  2769  // - parent: The resource on which DNS peering will be created.
  2770  func (r *ProjectsLocationsInstancesDnsPeeringsService) Create(parent string, dnspeering *DnsPeering) *ProjectsLocationsInstancesDnsPeeringsCreateCall {
  2771  	c := &ProjectsLocationsInstancesDnsPeeringsCreateCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  2772  	c.parent = parent
  2773  	c.dnspeering = dnspeering
  2774  	return c
  2775  }
  2776  
  2777  // DnsPeeringId sets the optional parameter "dnsPeeringId": Required. The name
  2778  // of the peering to create.
  2779  func (c *ProjectsLocationsInstancesDnsPeeringsCreateCall) DnsPeeringId(dnsPeeringId string) *ProjectsLocationsInstancesDnsPeeringsCreateCall {
  2780  	c.urlParams_.Set("dnsPeeringId", dnsPeeringId)
  2781  	return c
  2782  }
  2783  
  2784  // Fields allows partial responses to be retrieved. See
  2785  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  2786  // details.
  2787  func (c *ProjectsLocationsInstancesDnsPeeringsCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsInstancesDnsPeeringsCreateCall {
  2788  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  2789  	return c
  2790  }
  2791  
  2792  // Context sets the context to be used in this call's Do method.
  2793  func (c *ProjectsLocationsInstancesDnsPeeringsCreateCall) Context(ctx context.Context) *ProjectsLocationsInstancesDnsPeeringsCreateCall {
  2794  	c.ctx_ = ctx
  2795  	return c
  2796  }
  2797  
  2798  // Header returns a http.Header that can be modified by the caller to add
  2799  // headers to the request.
  2800  func (c *ProjectsLocationsInstancesDnsPeeringsCreateCall) Header() http.Header {
  2801  	if c.header_ == nil {
  2802  		c.header_ = make(http.Header)
  2803  	}
  2804  	return c.header_
  2805  }
  2806  
  2807  func (c *ProjectsLocationsInstancesDnsPeeringsCreateCall) doRequest(alt string) (*http.Response, error) {
  2808  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
  2809  	var body io.Reader = nil
  2810  	body, err := googleapi.WithoutDataWrapper.JSONReader(c.dnspeering)
  2811  	if err != nil {
  2812  		return nil, err
  2813  	}
  2814  	c.urlParams_.Set("alt", alt)
  2815  	c.urlParams_.Set("prettyPrint", "false")
  2816  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1/{+parent}/dnsPeerings")
  2817  	urls += "?" + c.urlParams_.Encode()
  2818  	req, err := http.NewRequest("POST", urls, body)
  2819  	if err != nil {
  2820  		return nil, err
  2821  	}
  2822  	req.Header = reqHeaders
  2823  	googleapi.Expand(req.URL, map[string]string{
  2824  		"parent": c.parent,
  2825  	})
  2826  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  2827  }
  2828  
  2829  // Do executes the "datafusion.projects.locations.instances.dnsPeerings.create" call.
  2830  // Any non-2xx status code is an error. Response headers are in either
  2831  // *DnsPeering.ServerResponse.Header or (if a response was returned at all) in
  2832  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  2833  // whether the returned error was because http.StatusNotModified was returned.
  2834  func (c *ProjectsLocationsInstancesDnsPeeringsCreateCall) Do(opts ...googleapi.CallOption) (*DnsPeering, error) {
  2835  	gensupport.SetOptions(c.urlParams_, opts...)
  2836  	res, err := c.doRequest("json")
  2837  	if res != nil && res.StatusCode == http.StatusNotModified {
  2838  		if res.Body != nil {
  2839  			res.Body.Close()
  2840  		}
  2841  		return nil, gensupport.WrapError(&googleapi.Error{
  2842  			Code:   res.StatusCode,
  2843  			Header: res.Header,
  2844  		})
  2845  	}
  2846  	if err != nil {
  2847  		return nil, err
  2848  	}
  2849  	defer googleapi.CloseBody(res)
  2850  	if err := googleapi.CheckResponse(res); err != nil {
  2851  		return nil, gensupport.WrapError(err)
  2852  	}
  2853  	ret := &DnsPeering{
  2854  		ServerResponse: googleapi.ServerResponse{
  2855  			Header:         res.Header,
  2856  			HTTPStatusCode: res.StatusCode,
  2857  		},
  2858  	}
  2859  	target := &ret
  2860  	if err := gensupport.DecodeResponse(target, res); err != nil {
  2861  		return nil, err
  2862  	}
  2863  	return ret, nil
  2864  }
  2865  
  2866  type ProjectsLocationsInstancesDnsPeeringsDeleteCall struct {
  2867  	s          *Service
  2868  	name       string
  2869  	urlParams_ gensupport.URLParams
  2870  	ctx_       context.Context
  2871  	header_    http.Header
  2872  }
  2873  
  2874  // Delete: Deletes DNS peering on the given resource.
  2875  //
  2876  //   - name: The name of the DNS peering zone to delete. Format:
  2877  //     projects/{project}/locations/{location}/instances/{instance}/dnsPeerings/{d
  2878  //     ns_peering}.
  2879  func (r *ProjectsLocationsInstancesDnsPeeringsService) Delete(name string) *ProjectsLocationsInstancesDnsPeeringsDeleteCall {
  2880  	c := &ProjectsLocationsInstancesDnsPeeringsDeleteCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  2881  	c.name = name
  2882  	return c
  2883  }
  2884  
  2885  // Fields allows partial responses to be retrieved. See
  2886  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  2887  // details.
  2888  func (c *ProjectsLocationsInstancesDnsPeeringsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsInstancesDnsPeeringsDeleteCall {
  2889  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  2890  	return c
  2891  }
  2892  
  2893  // Context sets the context to be used in this call's Do method.
  2894  func (c *ProjectsLocationsInstancesDnsPeeringsDeleteCall) Context(ctx context.Context) *ProjectsLocationsInstancesDnsPeeringsDeleteCall {
  2895  	c.ctx_ = ctx
  2896  	return c
  2897  }
  2898  
  2899  // Header returns a http.Header that can be modified by the caller to add
  2900  // headers to the request.
  2901  func (c *ProjectsLocationsInstancesDnsPeeringsDeleteCall) Header() http.Header {
  2902  	if c.header_ == nil {
  2903  		c.header_ = make(http.Header)
  2904  	}
  2905  	return c.header_
  2906  }
  2907  
  2908  func (c *ProjectsLocationsInstancesDnsPeeringsDeleteCall) doRequest(alt string) (*http.Response, error) {
  2909  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  2910  	var body io.Reader = nil
  2911  	c.urlParams_.Set("alt", alt)
  2912  	c.urlParams_.Set("prettyPrint", "false")
  2913  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1/{+name}")
  2914  	urls += "?" + c.urlParams_.Encode()
  2915  	req, err := http.NewRequest("DELETE", urls, body)
  2916  	if err != nil {
  2917  		return nil, err
  2918  	}
  2919  	req.Header = reqHeaders
  2920  	googleapi.Expand(req.URL, map[string]string{
  2921  		"name": c.name,
  2922  	})
  2923  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  2924  }
  2925  
  2926  // Do executes the "datafusion.projects.locations.instances.dnsPeerings.delete" call.
  2927  // Any non-2xx status code is an error. Response headers are in either
  2928  // *Empty.ServerResponse.Header or (if a response was returned at all) in
  2929  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  2930  // whether the returned error was because http.StatusNotModified was returned.
  2931  func (c *ProjectsLocationsInstancesDnsPeeringsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error) {
  2932  	gensupport.SetOptions(c.urlParams_, opts...)
  2933  	res, err := c.doRequest("json")
  2934  	if res != nil && res.StatusCode == http.StatusNotModified {
  2935  		if res.Body != nil {
  2936  			res.Body.Close()
  2937  		}
  2938  		return nil, gensupport.WrapError(&googleapi.Error{
  2939  			Code:   res.StatusCode,
  2940  			Header: res.Header,
  2941  		})
  2942  	}
  2943  	if err != nil {
  2944  		return nil, err
  2945  	}
  2946  	defer googleapi.CloseBody(res)
  2947  	if err := googleapi.CheckResponse(res); err != nil {
  2948  		return nil, gensupport.WrapError(err)
  2949  	}
  2950  	ret := &Empty{
  2951  		ServerResponse: googleapi.ServerResponse{
  2952  			Header:         res.Header,
  2953  			HTTPStatusCode: res.StatusCode,
  2954  		},
  2955  	}
  2956  	target := &ret
  2957  	if err := gensupport.DecodeResponse(target, res); err != nil {
  2958  		return nil, err
  2959  	}
  2960  	return ret, nil
  2961  }
  2962  
  2963  type ProjectsLocationsInstancesDnsPeeringsListCall struct {
  2964  	s            *Service
  2965  	parent       string
  2966  	urlParams_   gensupport.URLParams
  2967  	ifNoneMatch_ string
  2968  	ctx_         context.Context
  2969  	header_      http.Header
  2970  }
  2971  
  2972  // List: Lists DNS peerings for a given resource.
  2973  //
  2974  //   - parent: The parent, which owns this collection of dns peerings. Format:
  2975  //     projects/{project}/locations/{location}/instances/{instance}.
  2976  func (r *ProjectsLocationsInstancesDnsPeeringsService) List(parent string) *ProjectsLocationsInstancesDnsPeeringsListCall {
  2977  	c := &ProjectsLocationsInstancesDnsPeeringsListCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  2978  	c.parent = parent
  2979  	return c
  2980  }
  2981  
  2982  // PageSize sets the optional parameter "pageSize": The maximum number of dns
  2983  // peerings to return. The service may return fewer than this value. If
  2984  // unspecified, at most 50 dns peerings will be returned. The maximum value is
  2985  // 200; values above 200 will be coerced to 200.
  2986  func (c *ProjectsLocationsInstancesDnsPeeringsListCall) PageSize(pageSize int64) *ProjectsLocationsInstancesDnsPeeringsListCall {
  2987  	c.urlParams_.Set("pageSize", fmt.Sprint(pageSize))
  2988  	return c
  2989  }
  2990  
  2991  // PageToken sets the optional parameter "pageToken": A page token, received
  2992  // from a previous `ListDnsPeerings` call. Provide this to retrieve the
  2993  // subsequent page. When paginating, all other parameters provided to
  2994  // `ListDnsPeerings` must match the call that provided the page token.
  2995  func (c *ProjectsLocationsInstancesDnsPeeringsListCall) PageToken(pageToken string) *ProjectsLocationsInstancesDnsPeeringsListCall {
  2996  	c.urlParams_.Set("pageToken", pageToken)
  2997  	return c
  2998  }
  2999  
  3000  // Fields allows partial responses to be retrieved. See
  3001  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  3002  // details.
  3003  func (c *ProjectsLocationsInstancesDnsPeeringsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsInstancesDnsPeeringsListCall {
  3004  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  3005  	return c
  3006  }
  3007  
  3008  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  3009  // object's ETag matches the given value. This is useful for getting updates
  3010  // only after the object has changed since the last request.
  3011  func (c *ProjectsLocationsInstancesDnsPeeringsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsInstancesDnsPeeringsListCall {
  3012  	c.ifNoneMatch_ = entityTag
  3013  	return c
  3014  }
  3015  
  3016  // Context sets the context to be used in this call's Do method.
  3017  func (c *ProjectsLocationsInstancesDnsPeeringsListCall) Context(ctx context.Context) *ProjectsLocationsInstancesDnsPeeringsListCall {
  3018  	c.ctx_ = ctx
  3019  	return c
  3020  }
  3021  
  3022  // Header returns a http.Header that can be modified by the caller to add
  3023  // headers to the request.
  3024  func (c *ProjectsLocationsInstancesDnsPeeringsListCall) Header() http.Header {
  3025  	if c.header_ == nil {
  3026  		c.header_ = make(http.Header)
  3027  	}
  3028  	return c.header_
  3029  }
  3030  
  3031  func (c *ProjectsLocationsInstancesDnsPeeringsListCall) doRequest(alt string) (*http.Response, error) {
  3032  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  3033  	if c.ifNoneMatch_ != "" {
  3034  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  3035  	}
  3036  	var body io.Reader = nil
  3037  	c.urlParams_.Set("alt", alt)
  3038  	c.urlParams_.Set("prettyPrint", "false")
  3039  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1/{+parent}/dnsPeerings")
  3040  	urls += "?" + c.urlParams_.Encode()
  3041  	req, err := http.NewRequest("GET", urls, body)
  3042  	if err != nil {
  3043  		return nil, err
  3044  	}
  3045  	req.Header = reqHeaders
  3046  	googleapi.Expand(req.URL, map[string]string{
  3047  		"parent": c.parent,
  3048  	})
  3049  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  3050  }
  3051  
  3052  // Do executes the "datafusion.projects.locations.instances.dnsPeerings.list" call.
  3053  // Any non-2xx status code is an error. Response headers are in either
  3054  // *ListDnsPeeringsResponse.ServerResponse.Header or (if a response was
  3055  // returned at all) in error.(*googleapi.Error).Header. Use
  3056  // googleapi.IsNotModified to check whether the returned error was because
  3057  // http.StatusNotModified was returned.
  3058  func (c *ProjectsLocationsInstancesDnsPeeringsListCall) Do(opts ...googleapi.CallOption) (*ListDnsPeeringsResponse, error) {
  3059  	gensupport.SetOptions(c.urlParams_, opts...)
  3060  	res, err := c.doRequest("json")
  3061  	if res != nil && res.StatusCode == http.StatusNotModified {
  3062  		if res.Body != nil {
  3063  			res.Body.Close()
  3064  		}
  3065  		return nil, gensupport.WrapError(&googleapi.Error{
  3066  			Code:   res.StatusCode,
  3067  			Header: res.Header,
  3068  		})
  3069  	}
  3070  	if err != nil {
  3071  		return nil, err
  3072  	}
  3073  	defer googleapi.CloseBody(res)
  3074  	if err := googleapi.CheckResponse(res); err != nil {
  3075  		return nil, gensupport.WrapError(err)
  3076  	}
  3077  	ret := &ListDnsPeeringsResponse{
  3078  		ServerResponse: googleapi.ServerResponse{
  3079  			Header:         res.Header,
  3080  			HTTPStatusCode: res.StatusCode,
  3081  		},
  3082  	}
  3083  	target := &ret
  3084  	if err := gensupport.DecodeResponse(target, res); err != nil {
  3085  		return nil, err
  3086  	}
  3087  	return ret, nil
  3088  }
  3089  
  3090  // Pages invokes f for each page of results.
  3091  // A non-nil error returned from f will halt the iteration.
  3092  // The provided context supersedes any context provided to the Context method.
  3093  func (c *ProjectsLocationsInstancesDnsPeeringsListCall) Pages(ctx context.Context, f func(*ListDnsPeeringsResponse) error) error {
  3094  	c.ctx_ = ctx
  3095  	defer c.PageToken(c.urlParams_.Get("pageToken"))
  3096  	for {
  3097  		x, err := c.Do()
  3098  		if err != nil {
  3099  			return err
  3100  		}
  3101  		if err := f(x); err != nil {
  3102  			return err
  3103  		}
  3104  		if x.NextPageToken == "" {
  3105  			return nil
  3106  		}
  3107  		c.PageToken(x.NextPageToken)
  3108  	}
  3109  }
  3110  
  3111  type ProjectsLocationsOperationsCancelCall struct {
  3112  	s                      *Service
  3113  	name                   string
  3114  	canceloperationrequest *CancelOperationRequest
  3115  	urlParams_             gensupport.URLParams
  3116  	ctx_                   context.Context
  3117  	header_                http.Header
  3118  }
  3119  
  3120  // Cancel: Starts asynchronous cancellation on a long-running operation. The
  3121  // server makes a best effort to cancel the operation, but success is not
  3122  // guaranteed. If the server doesn't support this method, it returns
  3123  // `google.rpc.Code.UNIMPLEMENTED`. Clients can use Operations.GetOperation or
  3124  // other methods to check whether the cancellation succeeded or whether the
  3125  // operation completed despite cancellation. On successful cancellation, the
  3126  // operation is not deleted; instead, it becomes an operation with an
  3127  // Operation.error value with a google.rpc.Status.code of 1, corresponding to
  3128  // `Code.CANCELLED`.
  3129  //
  3130  // - name: The name of the operation resource to be cancelled.
  3131  func (r *ProjectsLocationsOperationsService) Cancel(name string, canceloperationrequest *CancelOperationRequest) *ProjectsLocationsOperationsCancelCall {
  3132  	c := &ProjectsLocationsOperationsCancelCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  3133  	c.name = name
  3134  	c.canceloperationrequest = canceloperationrequest
  3135  	return c
  3136  }
  3137  
  3138  // Fields allows partial responses to be retrieved. See
  3139  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  3140  // details.
  3141  func (c *ProjectsLocationsOperationsCancelCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsCancelCall {
  3142  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  3143  	return c
  3144  }
  3145  
  3146  // Context sets the context to be used in this call's Do method.
  3147  func (c *ProjectsLocationsOperationsCancelCall) Context(ctx context.Context) *ProjectsLocationsOperationsCancelCall {
  3148  	c.ctx_ = ctx
  3149  	return c
  3150  }
  3151  
  3152  // Header returns a http.Header that can be modified by the caller to add
  3153  // headers to the request.
  3154  func (c *ProjectsLocationsOperationsCancelCall) Header() http.Header {
  3155  	if c.header_ == nil {
  3156  		c.header_ = make(http.Header)
  3157  	}
  3158  	return c.header_
  3159  }
  3160  
  3161  func (c *ProjectsLocationsOperationsCancelCall) doRequest(alt string) (*http.Response, error) {
  3162  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
  3163  	var body io.Reader = nil
  3164  	body, err := googleapi.WithoutDataWrapper.JSONReader(c.canceloperationrequest)
  3165  	if err != nil {
  3166  		return nil, err
  3167  	}
  3168  	c.urlParams_.Set("alt", alt)
  3169  	c.urlParams_.Set("prettyPrint", "false")
  3170  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1/{+name}:cancel")
  3171  	urls += "?" + c.urlParams_.Encode()
  3172  	req, err := http.NewRequest("POST", urls, body)
  3173  	if err != nil {
  3174  		return nil, err
  3175  	}
  3176  	req.Header = reqHeaders
  3177  	googleapi.Expand(req.URL, map[string]string{
  3178  		"name": c.name,
  3179  	})
  3180  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  3181  }
  3182  
  3183  // Do executes the "datafusion.projects.locations.operations.cancel" call.
  3184  // Any non-2xx status code is an error. Response headers are in either
  3185  // *Empty.ServerResponse.Header or (if a response was returned at all) in
  3186  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  3187  // whether the returned error was because http.StatusNotModified was returned.
  3188  func (c *ProjectsLocationsOperationsCancelCall) Do(opts ...googleapi.CallOption) (*Empty, error) {
  3189  	gensupport.SetOptions(c.urlParams_, opts...)
  3190  	res, err := c.doRequest("json")
  3191  	if res != nil && res.StatusCode == http.StatusNotModified {
  3192  		if res.Body != nil {
  3193  			res.Body.Close()
  3194  		}
  3195  		return nil, gensupport.WrapError(&googleapi.Error{
  3196  			Code:   res.StatusCode,
  3197  			Header: res.Header,
  3198  		})
  3199  	}
  3200  	if err != nil {
  3201  		return nil, err
  3202  	}
  3203  	defer googleapi.CloseBody(res)
  3204  	if err := googleapi.CheckResponse(res); err != nil {
  3205  		return nil, gensupport.WrapError(err)
  3206  	}
  3207  	ret := &Empty{
  3208  		ServerResponse: googleapi.ServerResponse{
  3209  			Header:         res.Header,
  3210  			HTTPStatusCode: res.StatusCode,
  3211  		},
  3212  	}
  3213  	target := &ret
  3214  	if err := gensupport.DecodeResponse(target, res); err != nil {
  3215  		return nil, err
  3216  	}
  3217  	return ret, nil
  3218  }
  3219  
  3220  type ProjectsLocationsOperationsDeleteCall struct {
  3221  	s          *Service
  3222  	name       string
  3223  	urlParams_ gensupport.URLParams
  3224  	ctx_       context.Context
  3225  	header_    http.Header
  3226  }
  3227  
  3228  // Delete: Deletes a long-running operation. This method indicates that the
  3229  // client is no longer interested in the operation result. It does not cancel
  3230  // the operation. If the server doesn't support this method, it returns
  3231  // `google.rpc.Code.UNIMPLEMENTED`.
  3232  //
  3233  // - name: The name of the operation resource to be deleted.
  3234  func (r *ProjectsLocationsOperationsService) Delete(name string) *ProjectsLocationsOperationsDeleteCall {
  3235  	c := &ProjectsLocationsOperationsDeleteCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  3236  	c.name = name
  3237  	return c
  3238  }
  3239  
  3240  // Fields allows partial responses to be retrieved. See
  3241  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  3242  // details.
  3243  func (c *ProjectsLocationsOperationsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsDeleteCall {
  3244  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  3245  	return c
  3246  }
  3247  
  3248  // Context sets the context to be used in this call's Do method.
  3249  func (c *ProjectsLocationsOperationsDeleteCall) Context(ctx context.Context) *ProjectsLocationsOperationsDeleteCall {
  3250  	c.ctx_ = ctx
  3251  	return c
  3252  }
  3253  
  3254  // Header returns a http.Header that can be modified by the caller to add
  3255  // headers to the request.
  3256  func (c *ProjectsLocationsOperationsDeleteCall) Header() http.Header {
  3257  	if c.header_ == nil {
  3258  		c.header_ = make(http.Header)
  3259  	}
  3260  	return c.header_
  3261  }
  3262  
  3263  func (c *ProjectsLocationsOperationsDeleteCall) doRequest(alt string) (*http.Response, error) {
  3264  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  3265  	var body io.Reader = nil
  3266  	c.urlParams_.Set("alt", alt)
  3267  	c.urlParams_.Set("prettyPrint", "false")
  3268  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1/{+name}")
  3269  	urls += "?" + c.urlParams_.Encode()
  3270  	req, err := http.NewRequest("DELETE", urls, body)
  3271  	if err != nil {
  3272  		return nil, err
  3273  	}
  3274  	req.Header = reqHeaders
  3275  	googleapi.Expand(req.URL, map[string]string{
  3276  		"name": c.name,
  3277  	})
  3278  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  3279  }
  3280  
  3281  // Do executes the "datafusion.projects.locations.operations.delete" call.
  3282  // Any non-2xx status code is an error. Response headers are in either
  3283  // *Empty.ServerResponse.Header or (if a response was returned at all) in
  3284  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  3285  // whether the returned error was because http.StatusNotModified was returned.
  3286  func (c *ProjectsLocationsOperationsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error) {
  3287  	gensupport.SetOptions(c.urlParams_, opts...)
  3288  	res, err := c.doRequest("json")
  3289  	if res != nil && res.StatusCode == http.StatusNotModified {
  3290  		if res.Body != nil {
  3291  			res.Body.Close()
  3292  		}
  3293  		return nil, gensupport.WrapError(&googleapi.Error{
  3294  			Code:   res.StatusCode,
  3295  			Header: res.Header,
  3296  		})
  3297  	}
  3298  	if err != nil {
  3299  		return nil, err
  3300  	}
  3301  	defer googleapi.CloseBody(res)
  3302  	if err := googleapi.CheckResponse(res); err != nil {
  3303  		return nil, gensupport.WrapError(err)
  3304  	}
  3305  	ret := &Empty{
  3306  		ServerResponse: googleapi.ServerResponse{
  3307  			Header:         res.Header,
  3308  			HTTPStatusCode: res.StatusCode,
  3309  		},
  3310  	}
  3311  	target := &ret
  3312  	if err := gensupport.DecodeResponse(target, res); err != nil {
  3313  		return nil, err
  3314  	}
  3315  	return ret, nil
  3316  }
  3317  
  3318  type ProjectsLocationsOperationsGetCall struct {
  3319  	s            *Service
  3320  	name         string
  3321  	urlParams_   gensupport.URLParams
  3322  	ifNoneMatch_ string
  3323  	ctx_         context.Context
  3324  	header_      http.Header
  3325  }
  3326  
  3327  // Get: Gets the latest state of a long-running operation. Clients can use this
  3328  // method to poll the operation result at intervals as recommended by the API
  3329  // service.
  3330  //
  3331  // - name: The name of the operation resource.
  3332  func (r *ProjectsLocationsOperationsService) Get(name string) *ProjectsLocationsOperationsGetCall {
  3333  	c := &ProjectsLocationsOperationsGetCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  3334  	c.name = name
  3335  	return c
  3336  }
  3337  
  3338  // Fields allows partial responses to be retrieved. See
  3339  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  3340  // details.
  3341  func (c *ProjectsLocationsOperationsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsGetCall {
  3342  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  3343  	return c
  3344  }
  3345  
  3346  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  3347  // object's ETag matches the given value. This is useful for getting updates
  3348  // only after the object has changed since the last request.
  3349  func (c *ProjectsLocationsOperationsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsOperationsGetCall {
  3350  	c.ifNoneMatch_ = entityTag
  3351  	return c
  3352  }
  3353  
  3354  // Context sets the context to be used in this call's Do method.
  3355  func (c *ProjectsLocationsOperationsGetCall) Context(ctx context.Context) *ProjectsLocationsOperationsGetCall {
  3356  	c.ctx_ = ctx
  3357  	return c
  3358  }
  3359  
  3360  // Header returns a http.Header that can be modified by the caller to add
  3361  // headers to the request.
  3362  func (c *ProjectsLocationsOperationsGetCall) Header() http.Header {
  3363  	if c.header_ == nil {
  3364  		c.header_ = make(http.Header)
  3365  	}
  3366  	return c.header_
  3367  }
  3368  
  3369  func (c *ProjectsLocationsOperationsGetCall) doRequest(alt string) (*http.Response, error) {
  3370  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  3371  	if c.ifNoneMatch_ != "" {
  3372  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  3373  	}
  3374  	var body io.Reader = nil
  3375  	c.urlParams_.Set("alt", alt)
  3376  	c.urlParams_.Set("prettyPrint", "false")
  3377  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1/{+name}")
  3378  	urls += "?" + c.urlParams_.Encode()
  3379  	req, err := http.NewRequest("GET", urls, body)
  3380  	if err != nil {
  3381  		return nil, err
  3382  	}
  3383  	req.Header = reqHeaders
  3384  	googleapi.Expand(req.URL, map[string]string{
  3385  		"name": c.name,
  3386  	})
  3387  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  3388  }
  3389  
  3390  // Do executes the "datafusion.projects.locations.operations.get" call.
  3391  // Any non-2xx status code is an error. Response headers are in either
  3392  // *Operation.ServerResponse.Header or (if a response was returned at all) in
  3393  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  3394  // whether the returned error was because http.StatusNotModified was returned.
  3395  func (c *ProjectsLocationsOperationsGetCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
  3396  	gensupport.SetOptions(c.urlParams_, opts...)
  3397  	res, err := c.doRequest("json")
  3398  	if res != nil && res.StatusCode == http.StatusNotModified {
  3399  		if res.Body != nil {
  3400  			res.Body.Close()
  3401  		}
  3402  		return nil, gensupport.WrapError(&googleapi.Error{
  3403  			Code:   res.StatusCode,
  3404  			Header: res.Header,
  3405  		})
  3406  	}
  3407  	if err != nil {
  3408  		return nil, err
  3409  	}
  3410  	defer googleapi.CloseBody(res)
  3411  	if err := googleapi.CheckResponse(res); err != nil {
  3412  		return nil, gensupport.WrapError(err)
  3413  	}
  3414  	ret := &Operation{
  3415  		ServerResponse: googleapi.ServerResponse{
  3416  			Header:         res.Header,
  3417  			HTTPStatusCode: res.StatusCode,
  3418  		},
  3419  	}
  3420  	target := &ret
  3421  	if err := gensupport.DecodeResponse(target, res); err != nil {
  3422  		return nil, err
  3423  	}
  3424  	return ret, nil
  3425  }
  3426  
  3427  type ProjectsLocationsOperationsListCall struct {
  3428  	s            *Service
  3429  	name         string
  3430  	urlParams_   gensupport.URLParams
  3431  	ifNoneMatch_ string
  3432  	ctx_         context.Context
  3433  	header_      http.Header
  3434  }
  3435  
  3436  // List: Lists operations that match the specified filter in the request. If
  3437  // the server doesn't support this method, it returns `UNIMPLEMENTED`.
  3438  //
  3439  // - name: The name of the operation's parent resource.
  3440  func (r *ProjectsLocationsOperationsService) List(name string) *ProjectsLocationsOperationsListCall {
  3441  	c := &ProjectsLocationsOperationsListCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  3442  	c.name = name
  3443  	return c
  3444  }
  3445  
  3446  // Filter sets the optional parameter "filter": The standard list filter.
  3447  func (c *ProjectsLocationsOperationsListCall) Filter(filter string) *ProjectsLocationsOperationsListCall {
  3448  	c.urlParams_.Set("filter", filter)
  3449  	return c
  3450  }
  3451  
  3452  // PageSize sets the optional parameter "pageSize": The standard list page
  3453  // size.
  3454  func (c *ProjectsLocationsOperationsListCall) PageSize(pageSize int64) *ProjectsLocationsOperationsListCall {
  3455  	c.urlParams_.Set("pageSize", fmt.Sprint(pageSize))
  3456  	return c
  3457  }
  3458  
  3459  // PageToken sets the optional parameter "pageToken": The standard list page
  3460  // token.
  3461  func (c *ProjectsLocationsOperationsListCall) PageToken(pageToken string) *ProjectsLocationsOperationsListCall {
  3462  	c.urlParams_.Set("pageToken", pageToken)
  3463  	return c
  3464  }
  3465  
  3466  // Fields allows partial responses to be retrieved. See
  3467  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  3468  // details.
  3469  func (c *ProjectsLocationsOperationsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsListCall {
  3470  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  3471  	return c
  3472  }
  3473  
  3474  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  3475  // object's ETag matches the given value. This is useful for getting updates
  3476  // only after the object has changed since the last request.
  3477  func (c *ProjectsLocationsOperationsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsOperationsListCall {
  3478  	c.ifNoneMatch_ = entityTag
  3479  	return c
  3480  }
  3481  
  3482  // Context sets the context to be used in this call's Do method.
  3483  func (c *ProjectsLocationsOperationsListCall) Context(ctx context.Context) *ProjectsLocationsOperationsListCall {
  3484  	c.ctx_ = ctx
  3485  	return c
  3486  }
  3487  
  3488  // Header returns a http.Header that can be modified by the caller to add
  3489  // headers to the request.
  3490  func (c *ProjectsLocationsOperationsListCall) Header() http.Header {
  3491  	if c.header_ == nil {
  3492  		c.header_ = make(http.Header)
  3493  	}
  3494  	return c.header_
  3495  }
  3496  
  3497  func (c *ProjectsLocationsOperationsListCall) doRequest(alt string) (*http.Response, error) {
  3498  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  3499  	if c.ifNoneMatch_ != "" {
  3500  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  3501  	}
  3502  	var body io.Reader = nil
  3503  	c.urlParams_.Set("alt", alt)
  3504  	c.urlParams_.Set("prettyPrint", "false")
  3505  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1/{+name}/operations")
  3506  	urls += "?" + c.urlParams_.Encode()
  3507  	req, err := http.NewRequest("GET", urls, body)
  3508  	if err != nil {
  3509  		return nil, err
  3510  	}
  3511  	req.Header = reqHeaders
  3512  	googleapi.Expand(req.URL, map[string]string{
  3513  		"name": c.name,
  3514  	})
  3515  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  3516  }
  3517  
  3518  // Do executes the "datafusion.projects.locations.operations.list" call.
  3519  // Any non-2xx status code is an error. Response headers are in either
  3520  // *ListOperationsResponse.ServerResponse.Header or (if a response was returned
  3521  // at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to
  3522  // check whether the returned error was because http.StatusNotModified was
  3523  // returned.
  3524  func (c *ProjectsLocationsOperationsListCall) Do(opts ...googleapi.CallOption) (*ListOperationsResponse, error) {
  3525  	gensupport.SetOptions(c.urlParams_, opts...)
  3526  	res, err := c.doRequest("json")
  3527  	if res != nil && res.StatusCode == http.StatusNotModified {
  3528  		if res.Body != nil {
  3529  			res.Body.Close()
  3530  		}
  3531  		return nil, gensupport.WrapError(&googleapi.Error{
  3532  			Code:   res.StatusCode,
  3533  			Header: res.Header,
  3534  		})
  3535  	}
  3536  	if err != nil {
  3537  		return nil, err
  3538  	}
  3539  	defer googleapi.CloseBody(res)
  3540  	if err := googleapi.CheckResponse(res); err != nil {
  3541  		return nil, gensupport.WrapError(err)
  3542  	}
  3543  	ret := &ListOperationsResponse{
  3544  		ServerResponse: googleapi.ServerResponse{
  3545  			Header:         res.Header,
  3546  			HTTPStatusCode: res.StatusCode,
  3547  		},
  3548  	}
  3549  	target := &ret
  3550  	if err := gensupport.DecodeResponse(target, res); err != nil {
  3551  		return nil, err
  3552  	}
  3553  	return ret, nil
  3554  }
  3555  
  3556  // Pages invokes f for each page of results.
  3557  // A non-nil error returned from f will halt the iteration.
  3558  // The provided context supersedes any context provided to the Context method.
  3559  func (c *ProjectsLocationsOperationsListCall) Pages(ctx context.Context, f func(*ListOperationsResponse) error) error {
  3560  	c.ctx_ = ctx
  3561  	defer c.PageToken(c.urlParams_.Get("pageToken"))
  3562  	for {
  3563  		x, err := c.Do()
  3564  		if err != nil {
  3565  			return err
  3566  		}
  3567  		if err := f(x); err != nil {
  3568  			return err
  3569  		}
  3570  		if x.NextPageToken == "" {
  3571  			return nil
  3572  		}
  3573  		c.PageToken(x.NextPageToken)
  3574  	}
  3575  }
  3576  
  3577  type ProjectsLocationsVersionsListCall struct {
  3578  	s            *Service
  3579  	parent       string
  3580  	urlParams_   gensupport.URLParams
  3581  	ifNoneMatch_ string
  3582  	ctx_         context.Context
  3583  	header_      http.Header
  3584  }
  3585  
  3586  // List: Lists possible versions for Data Fusion instances in the specified
  3587  // project and location.
  3588  //
  3589  //   - parent: The project and location for which to retrieve instance
  3590  //     information in the format projects/{project}/locations/{location}.
  3591  func (r *ProjectsLocationsVersionsService) List(parent string) *ProjectsLocationsVersionsListCall {
  3592  	c := &ProjectsLocationsVersionsListCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  3593  	c.parent = parent
  3594  	return c
  3595  }
  3596  
  3597  // LatestPatchOnly sets the optional parameter "latestPatchOnly": Whether or
  3598  // not to return the latest patch of every available minor version. If true,
  3599  // only the latest patch will be returned. Ex. if allowed versions is [6.1.1,
  3600  // 6.1.2, 6.2.0] then response will be [6.1.2, 6.2.0]
  3601  func (c *ProjectsLocationsVersionsListCall) LatestPatchOnly(latestPatchOnly bool) *ProjectsLocationsVersionsListCall {
  3602  	c.urlParams_.Set("latestPatchOnly", fmt.Sprint(latestPatchOnly))
  3603  	return c
  3604  }
  3605  
  3606  // PageSize sets the optional parameter "pageSize": The maximum number of items
  3607  // to return.
  3608  func (c *ProjectsLocationsVersionsListCall) PageSize(pageSize int64) *ProjectsLocationsVersionsListCall {
  3609  	c.urlParams_.Set("pageSize", fmt.Sprint(pageSize))
  3610  	return c
  3611  }
  3612  
  3613  // PageToken sets the optional parameter "pageToken": The next_page_token value
  3614  // to use if there are additional results to retrieve for this list request.
  3615  func (c *ProjectsLocationsVersionsListCall) PageToken(pageToken string) *ProjectsLocationsVersionsListCall {
  3616  	c.urlParams_.Set("pageToken", pageToken)
  3617  	return c
  3618  }
  3619  
  3620  // Fields allows partial responses to be retrieved. See
  3621  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  3622  // details.
  3623  func (c *ProjectsLocationsVersionsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsVersionsListCall {
  3624  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  3625  	return c
  3626  }
  3627  
  3628  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  3629  // object's ETag matches the given value. This is useful for getting updates
  3630  // only after the object has changed since the last request.
  3631  func (c *ProjectsLocationsVersionsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsVersionsListCall {
  3632  	c.ifNoneMatch_ = entityTag
  3633  	return c
  3634  }
  3635  
  3636  // Context sets the context to be used in this call's Do method.
  3637  func (c *ProjectsLocationsVersionsListCall) Context(ctx context.Context) *ProjectsLocationsVersionsListCall {
  3638  	c.ctx_ = ctx
  3639  	return c
  3640  }
  3641  
  3642  // Header returns a http.Header that can be modified by the caller to add
  3643  // headers to the request.
  3644  func (c *ProjectsLocationsVersionsListCall) Header() http.Header {
  3645  	if c.header_ == nil {
  3646  		c.header_ = make(http.Header)
  3647  	}
  3648  	return c.header_
  3649  }
  3650  
  3651  func (c *ProjectsLocationsVersionsListCall) doRequest(alt string) (*http.Response, error) {
  3652  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  3653  	if c.ifNoneMatch_ != "" {
  3654  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  3655  	}
  3656  	var body io.Reader = nil
  3657  	c.urlParams_.Set("alt", alt)
  3658  	c.urlParams_.Set("prettyPrint", "false")
  3659  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1/{+parent}/versions")
  3660  	urls += "?" + c.urlParams_.Encode()
  3661  	req, err := http.NewRequest("GET", urls, body)
  3662  	if err != nil {
  3663  		return nil, err
  3664  	}
  3665  	req.Header = reqHeaders
  3666  	googleapi.Expand(req.URL, map[string]string{
  3667  		"parent": c.parent,
  3668  	})
  3669  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  3670  }
  3671  
  3672  // Do executes the "datafusion.projects.locations.versions.list" call.
  3673  // Any non-2xx status code is an error. Response headers are in either
  3674  // *ListAvailableVersionsResponse.ServerResponse.Header or (if a response was
  3675  // returned at all) in error.(*googleapi.Error).Header. Use
  3676  // googleapi.IsNotModified to check whether the returned error was because
  3677  // http.StatusNotModified was returned.
  3678  func (c *ProjectsLocationsVersionsListCall) Do(opts ...googleapi.CallOption) (*ListAvailableVersionsResponse, error) {
  3679  	gensupport.SetOptions(c.urlParams_, opts...)
  3680  	res, err := c.doRequest("json")
  3681  	if res != nil && res.StatusCode == http.StatusNotModified {
  3682  		if res.Body != nil {
  3683  			res.Body.Close()
  3684  		}
  3685  		return nil, gensupport.WrapError(&googleapi.Error{
  3686  			Code:   res.StatusCode,
  3687  			Header: res.Header,
  3688  		})
  3689  	}
  3690  	if err != nil {
  3691  		return nil, err
  3692  	}
  3693  	defer googleapi.CloseBody(res)
  3694  	if err := googleapi.CheckResponse(res); err != nil {
  3695  		return nil, gensupport.WrapError(err)
  3696  	}
  3697  	ret := &ListAvailableVersionsResponse{
  3698  		ServerResponse: googleapi.ServerResponse{
  3699  			Header:         res.Header,
  3700  			HTTPStatusCode: res.StatusCode,
  3701  		},
  3702  	}
  3703  	target := &ret
  3704  	if err := gensupport.DecodeResponse(target, res); err != nil {
  3705  		return nil, err
  3706  	}
  3707  	return ret, nil
  3708  }
  3709  
  3710  // Pages invokes f for each page of results.
  3711  // A non-nil error returned from f will halt the iteration.
  3712  // The provided context supersedes any context provided to the Context method.
  3713  func (c *ProjectsLocationsVersionsListCall) Pages(ctx context.Context, f func(*ListAvailableVersionsResponse) error) error {
  3714  	c.ctx_ = ctx
  3715  	defer c.PageToken(c.urlParams_.Get("pageToken"))
  3716  	for {
  3717  		x, err := c.Do()
  3718  		if err != nil {
  3719  			return err
  3720  		}
  3721  		if err := f(x); err != nil {
  3722  			return err
  3723  		}
  3724  		if x.NextPageToken == "" {
  3725  			return nil
  3726  		}
  3727  		c.PageToken(x.NextPageToken)
  3728  	}
  3729  }
  3730  

View as plain text