Source file src/google.golang.org/api/datastream/v1alpha1/datastream-gen.go

Documentation: google.golang.org/api/datastream/v1alpha1

     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 datastream provides access to the Datastream API.
     8  //
     9  // For product documentation, see: https://cloud.google.com/datastream/
    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/datastream/v1alpha1"
    27  //	...
    28  //	ctx := context.Background()
    29  //	datastreamService, err := datastream.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  //	datastreamService, err := datastream.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  //	datastreamService, err := datastream.NewService(ctx, option.WithTokenSource(config.TokenSource(ctx, token)))
    49  //
    50  // See [google.golang.org/api/option.ClientOption] for details on options.
    51  package datastream // import "google.golang.org/api/datastream/v1alpha1"
    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 = "datastream:v1alpha1"
    90  const apiName = "datastream"
    91  const apiVersion = "v1alpha1"
    92  const basePath = "https://datastream.googleapis.com/"
    93  const basePathTemplate = "https://datastream.UNIVERSE_DOMAIN/"
    94  const mtlsBasePath = "https://datastream.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.ConnectionProfiles = NewProjectsLocationsConnectionProfilesService(s)
   172  	rs.Operations = NewProjectsLocationsOperationsService(s)
   173  	rs.PrivateConnections = NewProjectsLocationsPrivateConnectionsService(s)
   174  	rs.Streams = NewProjectsLocationsStreamsService(s)
   175  	return rs
   176  }
   177  
   178  type ProjectsLocationsService struct {
   179  	s *Service
   180  
   181  	ConnectionProfiles *ProjectsLocationsConnectionProfilesService
   182  
   183  	Operations *ProjectsLocationsOperationsService
   184  
   185  	PrivateConnections *ProjectsLocationsPrivateConnectionsService
   186  
   187  	Streams *ProjectsLocationsStreamsService
   188  }
   189  
   190  func NewProjectsLocationsConnectionProfilesService(s *Service) *ProjectsLocationsConnectionProfilesService {
   191  	rs := &ProjectsLocationsConnectionProfilesService{s: s}
   192  	return rs
   193  }
   194  
   195  type ProjectsLocationsConnectionProfilesService struct {
   196  	s *Service
   197  }
   198  
   199  func NewProjectsLocationsOperationsService(s *Service) *ProjectsLocationsOperationsService {
   200  	rs := &ProjectsLocationsOperationsService{s: s}
   201  	return rs
   202  }
   203  
   204  type ProjectsLocationsOperationsService struct {
   205  	s *Service
   206  }
   207  
   208  func NewProjectsLocationsPrivateConnectionsService(s *Service) *ProjectsLocationsPrivateConnectionsService {
   209  	rs := &ProjectsLocationsPrivateConnectionsService{s: s}
   210  	rs.Routes = NewProjectsLocationsPrivateConnectionsRoutesService(s)
   211  	return rs
   212  }
   213  
   214  type ProjectsLocationsPrivateConnectionsService struct {
   215  	s *Service
   216  
   217  	Routes *ProjectsLocationsPrivateConnectionsRoutesService
   218  }
   219  
   220  func NewProjectsLocationsPrivateConnectionsRoutesService(s *Service) *ProjectsLocationsPrivateConnectionsRoutesService {
   221  	rs := &ProjectsLocationsPrivateConnectionsRoutesService{s: s}
   222  	return rs
   223  }
   224  
   225  type ProjectsLocationsPrivateConnectionsRoutesService struct {
   226  	s *Service
   227  }
   228  
   229  func NewProjectsLocationsStreamsService(s *Service) *ProjectsLocationsStreamsService {
   230  	rs := &ProjectsLocationsStreamsService{s: s}
   231  	rs.Objects = NewProjectsLocationsStreamsObjectsService(s)
   232  	return rs
   233  }
   234  
   235  type ProjectsLocationsStreamsService struct {
   236  	s *Service
   237  
   238  	Objects *ProjectsLocationsStreamsObjectsService
   239  }
   240  
   241  func NewProjectsLocationsStreamsObjectsService(s *Service) *ProjectsLocationsStreamsObjectsService {
   242  	rs := &ProjectsLocationsStreamsObjectsService{s: s}
   243  	return rs
   244  }
   245  
   246  type ProjectsLocationsStreamsObjectsService struct {
   247  	s *Service
   248  }
   249  
   250  // AvroFileFormat: AVRO file format configuration.
   251  type AvroFileFormat struct {
   252  }
   253  
   254  // BackfillAllStrategy: Backfill strategy to automatically backfill the
   255  // Stream's objects. Specific objects can be excluded.
   256  type BackfillAllStrategy struct {
   257  	// MysqlExcludedObjects: MySQL data source objects to avoid backfilling.
   258  	MysqlExcludedObjects *MysqlRdbms `json:"mysqlExcludedObjects,omitempty"`
   259  	// OracleExcludedObjects: Oracle data source objects to avoid backfilling.
   260  	OracleExcludedObjects *OracleRdbms `json:"oracleExcludedObjects,omitempty"`
   261  	// ForceSendFields is a list of field names (e.g. "MysqlExcludedObjects") to
   262  	// unconditionally include in API requests. By default, fields with empty or
   263  	// default values are omitted from API requests. See
   264  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   265  	// details.
   266  	ForceSendFields []string `json:"-"`
   267  	// NullFields is a list of field names (e.g. "MysqlExcludedObjects") to include
   268  	// in API requests with the JSON null value. By default, fields with empty
   269  	// values are omitted from API requests. See
   270  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   271  	NullFields []string `json:"-"`
   272  }
   273  
   274  func (s *BackfillAllStrategy) MarshalJSON() ([]byte, error) {
   275  	type NoMethod BackfillAllStrategy
   276  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   277  }
   278  
   279  // BackfillJob: Represents a backfill job on a specific stream object.
   280  type BackfillJob struct {
   281  	// Errors: Output only. Errors which caused the backfill job to fail.
   282  	Errors []*Error `json:"errors,omitempty"`
   283  	// LastEndTime: Output only. Backfill job's end time.
   284  	LastEndTime string `json:"lastEndTime,omitempty"`
   285  	// LastStartTime: Output only. Backfill job's start time.
   286  	LastStartTime string `json:"lastStartTime,omitempty"`
   287  	// State: Backfill job state.
   288  	//
   289  	// Possible values:
   290  	//   "STATE_UNSPECIFIED" - Default value.
   291  	//   "NOT_STARTED" - Backfill job was never started for the stream object
   292  	// (stream has backfill strategy defined as manual or object was explicitly
   293  	// excluded from automatic backfill).
   294  	//   "PENDING" - Backfill job will start pending available resources.
   295  	//   "ACTIVE" - Backfill job is running.
   296  	//   "STOPPED" - Backfill job stopped (next job run will start from beginning).
   297  	//   "FAILED" - Backfill job failed (due to an error).
   298  	//   "COMPLETED" - Backfill completed successfully.
   299  	//   "UNSUPPORTED" - Backfill job failed since the table structure is currently
   300  	// unsupported for backfill.
   301  	State string `json:"state,omitempty"`
   302  	// Trigger: Backfill job's triggering reason.
   303  	//
   304  	// Possible values:
   305  	//   "TRIGGER_UNSPECIFIED" - Default value.
   306  	//   "AUTOMATIC" - Object backfill job was triggered automatically according to
   307  	// the stream's backfill strategy.
   308  	//   "MANUAL" - Object backfill job was triggered manually using the dedicated
   309  	// API.
   310  	Trigger string `json:"trigger,omitempty"`
   311  	// ForceSendFields is a list of field names (e.g. "Errors") to unconditionally
   312  	// include in API requests. By default, fields with empty or default values are
   313  	// omitted from API requests. See
   314  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   315  	// details.
   316  	ForceSendFields []string `json:"-"`
   317  	// NullFields is a list of field names (e.g. "Errors") to include in API
   318  	// requests with the JSON null value. By default, fields with empty values are
   319  	// omitted from API requests. See
   320  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   321  	NullFields []string `json:"-"`
   322  }
   323  
   324  func (s *BackfillJob) MarshalJSON() ([]byte, error) {
   325  	type NoMethod BackfillJob
   326  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   327  }
   328  
   329  // BackfillNoneStrategy: Backfill strategy to disable automatic backfill for
   330  // the Stream's objects.
   331  type BackfillNoneStrategy struct {
   332  }
   333  
   334  // CancelOperationRequest: The request message for Operations.CancelOperation.
   335  type CancelOperationRequest struct {
   336  }
   337  
   338  type ConnectionProfile struct {
   339  	// CreateTime: Output only. The create time of the resource.
   340  	CreateTime string `json:"createTime,omitempty"`
   341  	// DisplayName: Required. Display name.
   342  	DisplayName string `json:"displayName,omitempty"`
   343  	// ForwardSshConnectivity: Forward SSH tunnel connectivity.
   344  	ForwardSshConnectivity *ForwardSshTunnelConnectivity `json:"forwardSshConnectivity,omitempty"`
   345  	// GcsProfile: Cloud Storage ConnectionProfile configuration.
   346  	GcsProfile *GcsProfile `json:"gcsProfile,omitempty"`
   347  	// Labels: Labels.
   348  	Labels map[string]string `json:"labels,omitempty"`
   349  	// MysqlProfile: MySQL ConnectionProfile configuration.
   350  	MysqlProfile *MysqlProfile `json:"mysqlProfile,omitempty"`
   351  	// Name: Output only. The resource's name.
   352  	Name string `json:"name,omitempty"`
   353  	// NoConnectivity: No connectivity option chosen.
   354  	NoConnectivity *NoConnectivitySettings `json:"noConnectivity,omitempty"`
   355  	// OracleProfile: Oracle ConnectionProfile configuration.
   356  	OracleProfile *OracleProfile `json:"oracleProfile,omitempty"`
   357  	// PrivateConnectivity: Private connectivity.
   358  	PrivateConnectivity *PrivateConnectivity `json:"privateConnectivity,omitempty"`
   359  	// StaticServiceIpConnectivity: Static Service IP connectivity.
   360  	StaticServiceIpConnectivity *StaticServiceIpConnectivity `json:"staticServiceIpConnectivity,omitempty"`
   361  	// UpdateTime: Output only. The update time of the resource.
   362  	UpdateTime string `json:"updateTime,omitempty"`
   363  
   364  	// ServerResponse contains the HTTP response code and headers from the server.
   365  	googleapi.ServerResponse `json:"-"`
   366  	// ForceSendFields is a list of field names (e.g. "CreateTime") to
   367  	// unconditionally include in API requests. By default, fields with empty or
   368  	// default values are omitted from API requests. See
   369  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   370  	// details.
   371  	ForceSendFields []string `json:"-"`
   372  	// NullFields is a list of field names (e.g. "CreateTime") to include in API
   373  	// requests with the JSON null value. By default, fields with empty values are
   374  	// omitted from API requests. See
   375  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   376  	NullFields []string `json:"-"`
   377  }
   378  
   379  func (s *ConnectionProfile) MarshalJSON() ([]byte, error) {
   380  	type NoMethod ConnectionProfile
   381  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   382  }
   383  
   384  // DestinationConfig: The configuration of the stream destination.
   385  type DestinationConfig struct {
   386  	// DestinationConnectionProfileName: Required. Destination connection profile
   387  	// identifier.
   388  	DestinationConnectionProfileName string `json:"destinationConnectionProfileName,omitempty"`
   389  	// GcsDestinationConfig: GCS destination configuration.
   390  	GcsDestinationConfig *GcsDestinationConfig `json:"gcsDestinationConfig,omitempty"`
   391  	// ForceSendFields is a list of field names (e.g.
   392  	// "DestinationConnectionProfileName") to unconditionally include in API
   393  	// requests. By default, fields with empty or default values are omitted from
   394  	// API requests. See
   395  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   396  	// details.
   397  	ForceSendFields []string `json:"-"`
   398  	// NullFields is a list of field names (e.g.
   399  	// "DestinationConnectionProfileName") to include in API requests with the JSON
   400  	// null value. By default, fields with empty values are omitted from API
   401  	// requests. See https://pkg.go.dev/google.golang.org/api#hdr-NullFields for
   402  	// more details.
   403  	NullFields []string `json:"-"`
   404  }
   405  
   406  func (s *DestinationConfig) MarshalJSON() ([]byte, error) {
   407  	type NoMethod DestinationConfig
   408  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   409  }
   410  
   411  // DiscoverConnectionProfileRequest: Request message for 'discover'
   412  // ConnectionProfile request.
   413  type DiscoverConnectionProfileRequest struct {
   414  	// ConnectionProfile: An ad-hoc ConnectionProfile configuration.
   415  	ConnectionProfile *ConnectionProfile `json:"connectionProfile,omitempty"`
   416  	// ConnectionProfileName: A reference to an existing ConnectionProfile.
   417  	ConnectionProfileName string `json:"connectionProfileName,omitempty"`
   418  	// MysqlRdbms: MySQL RDBMS to enrich with child data objects and metadata.
   419  	MysqlRdbms *MysqlRdbms `json:"mysqlRdbms,omitempty"`
   420  	// OracleRdbms: Oracle RDBMS to enrich with child data objects and metadata.
   421  	OracleRdbms *OracleRdbms `json:"oracleRdbms,omitempty"`
   422  	// RecursionDepth: The number of hierarchy levels below the current level to be
   423  	// retrieved.
   424  	RecursionDepth int64 `json:"recursionDepth,omitempty"`
   425  	// Recursive: Whether to retrieve the full hierarchy of data objects (TRUE) or
   426  	// only the current level (FALSE).
   427  	Recursive bool `json:"recursive,omitempty"`
   428  	// ForceSendFields is a list of field names (e.g. "ConnectionProfile") to
   429  	// unconditionally include in API requests. By default, fields with empty or
   430  	// default values are omitted from API requests. See
   431  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   432  	// details.
   433  	ForceSendFields []string `json:"-"`
   434  	// NullFields is a list of field names (e.g. "ConnectionProfile") to include in
   435  	// API requests with the JSON null value. By default, fields with empty values
   436  	// are omitted from API requests. See
   437  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   438  	NullFields []string `json:"-"`
   439  }
   440  
   441  func (s *DiscoverConnectionProfileRequest) MarshalJSON() ([]byte, error) {
   442  	type NoMethod DiscoverConnectionProfileRequest
   443  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   444  }
   445  
   446  type DiscoverConnectionProfileResponse struct {
   447  	// MysqlRdbms: Enriched MySQL RDBMS object.
   448  	MysqlRdbms *MysqlRdbms `json:"mysqlRdbms,omitempty"`
   449  	// OracleRdbms: Enriched Oracle RDBMS object.
   450  	OracleRdbms *OracleRdbms `json:"oracleRdbms,omitempty"`
   451  
   452  	// ServerResponse contains the HTTP response code and headers from the server.
   453  	googleapi.ServerResponse `json:"-"`
   454  	// ForceSendFields is a list of field names (e.g. "MysqlRdbms") to
   455  	// unconditionally include in API requests. By default, fields with empty or
   456  	// default values are omitted from API requests. See
   457  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   458  	// details.
   459  	ForceSendFields []string `json:"-"`
   460  	// NullFields is a list of field names (e.g. "MysqlRdbms") to include in API
   461  	// requests with the JSON null value. By default, fields with empty values are
   462  	// omitted from API requests. See
   463  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   464  	NullFields []string `json:"-"`
   465  }
   466  
   467  func (s *DiscoverConnectionProfileResponse) MarshalJSON() ([]byte, error) {
   468  	type NoMethod DiscoverConnectionProfileResponse
   469  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   470  }
   471  
   472  // DropLargeObjects: Configuration to drop large object values.
   473  type DropLargeObjects struct {
   474  }
   475  
   476  // Empty: A generic empty message that you can re-use to avoid defining
   477  // duplicated empty messages in your APIs. A typical example is to use it as
   478  // the request or the response type of an API method. For instance: service Foo
   479  // { rpc Bar(google.protobuf.Empty) returns (google.protobuf.Empty); }
   480  type Empty struct {
   481  	// ServerResponse contains the HTTP response code and headers from the server.
   482  	googleapi.ServerResponse `json:"-"`
   483  }
   484  
   485  // Error: Represent a user-facing Error.
   486  type Error struct {
   487  	// Details: Additional information about the error.
   488  	Details map[string]string `json:"details,omitempty"`
   489  	// ErrorTime: The time when the error occurred.
   490  	ErrorTime string `json:"errorTime,omitempty"`
   491  	// ErrorUuid: A unique identifier for this specific error, allowing it to be
   492  	// traced throughout the system in logs and API responses.
   493  	ErrorUuid string `json:"errorUuid,omitempty"`
   494  	// Message: A message containing more information about the error that
   495  	// occurred.
   496  	Message string `json:"message,omitempty"`
   497  	// Reason: A title that explains the reason for the error.
   498  	Reason string `json:"reason,omitempty"`
   499  	// ForceSendFields is a list of field names (e.g. "Details") to unconditionally
   500  	// include in API requests. By default, fields with empty or default values are
   501  	// omitted from API requests. See
   502  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   503  	// details.
   504  	ForceSendFields []string `json:"-"`
   505  	// NullFields is a list of field names (e.g. "Details") to include in API
   506  	// requests with the JSON null value. By default, fields with empty values are
   507  	// omitted from API requests. See
   508  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   509  	NullFields []string `json:"-"`
   510  }
   511  
   512  func (s *Error) MarshalJSON() ([]byte, error) {
   513  	type NoMethod Error
   514  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   515  }
   516  
   517  // FetchErrorsRequest: Request message for 'FetchErrors' request.
   518  type FetchErrorsRequest struct {
   519  }
   520  
   521  // FetchErrorsResponse: Response message for a 'FetchErrors' response.
   522  type FetchErrorsResponse struct {
   523  	// Errors: The list of errors on the Stream.
   524  	Errors []*Error `json:"errors,omitempty"`
   525  	// ForceSendFields is a list of field names (e.g. "Errors") to unconditionally
   526  	// include in API requests. By default, fields with empty or default values are
   527  	// omitted from API requests. See
   528  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   529  	// details.
   530  	ForceSendFields []string `json:"-"`
   531  	// NullFields is a list of field names (e.g. "Errors") to include in API
   532  	// requests with the JSON null value. By default, fields with empty values are
   533  	// omitted from API requests. See
   534  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   535  	NullFields []string `json:"-"`
   536  }
   537  
   538  func (s *FetchErrorsResponse) MarshalJSON() ([]byte, error) {
   539  	type NoMethod FetchErrorsResponse
   540  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   541  }
   542  
   543  // FetchStaticIpsResponse: Response message for a 'FetchStaticIps' response.
   544  type FetchStaticIpsResponse struct {
   545  	// NextPageToken: A token that can be sent as `page_token` to retrieve the next
   546  	// page. If this field is omitted, there are no subsequent pages.
   547  	NextPageToken string `json:"nextPageToken,omitempty"`
   548  	// StaticIps: list of static ips by account
   549  	StaticIps []string `json:"staticIps,omitempty"`
   550  
   551  	// ServerResponse contains the HTTP response code and headers from the server.
   552  	googleapi.ServerResponse `json:"-"`
   553  	// ForceSendFields is a list of field names (e.g. "NextPageToken") to
   554  	// unconditionally include in API requests. By default, fields with empty or
   555  	// default values are omitted from API requests. See
   556  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   557  	// details.
   558  	ForceSendFields []string `json:"-"`
   559  	// NullFields is a list of field names (e.g. "NextPageToken") to include in API
   560  	// requests with the JSON null value. By default, fields with empty values are
   561  	// omitted from API requests. See
   562  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   563  	NullFields []string `json:"-"`
   564  }
   565  
   566  func (s *FetchStaticIpsResponse) MarshalJSON() ([]byte, error) {
   567  	type NoMethod FetchStaticIpsResponse
   568  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   569  }
   570  
   571  // ForwardSshTunnelConnectivity: Forward SSH Tunnel connectivity.
   572  type ForwardSshTunnelConnectivity struct {
   573  	// Hostname: Required. Hostname for the SSH tunnel.
   574  	Hostname string `json:"hostname,omitempty"`
   575  	// Password: Input only. SSH password.
   576  	Password string `json:"password,omitempty"`
   577  	// Port: Port for the SSH tunnel, default value is 22.
   578  	Port int64 `json:"port,omitempty"`
   579  	// PrivateKey: Input only. SSH private key.
   580  	PrivateKey string `json:"privateKey,omitempty"`
   581  	// Username: Required. Username for the SSH tunnel.
   582  	Username string `json:"username,omitempty"`
   583  	// ForceSendFields is a list of field names (e.g. "Hostname") to
   584  	// unconditionally include in API requests. By default, fields with empty or
   585  	// default values are omitted from API requests. See
   586  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   587  	// details.
   588  	ForceSendFields []string `json:"-"`
   589  	// NullFields is a list of field names (e.g. "Hostname") to include in API
   590  	// requests with the JSON null value. By default, fields with empty values are
   591  	// omitted from API requests. See
   592  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   593  	NullFields []string `json:"-"`
   594  }
   595  
   596  func (s *ForwardSshTunnelConnectivity) MarshalJSON() ([]byte, error) {
   597  	type NoMethod ForwardSshTunnelConnectivity
   598  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   599  }
   600  
   601  // GcsDestinationConfig: Google Cloud Storage destination configuration
   602  type GcsDestinationConfig struct {
   603  	// AvroFileFormat: AVRO file format configuration.
   604  	AvroFileFormat *AvroFileFormat `json:"avroFileFormat,omitempty"`
   605  	// FileRotationInterval: The maximum duration for which new events are added
   606  	// before a file is closed and a new file is created.
   607  	FileRotationInterval string `json:"fileRotationInterval,omitempty"`
   608  	// FileRotationMb: The maximum file size to be saved in the bucket.
   609  	FileRotationMb int64 `json:"fileRotationMb,omitempty"`
   610  	// GcsFileFormat: File format that data should be written in. Deprecated field
   611  	// (b/169501737) - use file_format instead.
   612  	//
   613  	// Possible values:
   614  	//   "GCS_FILE_FORMAT_UNSPECIFIED" - Unspecified Cloud Storage file format.
   615  	//   "AVRO" - Avro file format
   616  	GcsFileFormat string `json:"gcsFileFormat,omitempty"`
   617  	// JsonFileFormat: JSON file format configuration.
   618  	JsonFileFormat *JsonFileFormat `json:"jsonFileFormat,omitempty"`
   619  	// Path: Path inside the Cloud Storage bucket to write data to.
   620  	Path string `json:"path,omitempty"`
   621  	// ForceSendFields is a list of field names (e.g. "AvroFileFormat") to
   622  	// unconditionally include in API requests. By default, fields with empty or
   623  	// default values are omitted from API requests. See
   624  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   625  	// details.
   626  	ForceSendFields []string `json:"-"`
   627  	// NullFields is a list of field names (e.g. "AvroFileFormat") to include in
   628  	// API requests with the JSON null value. By default, fields with empty values
   629  	// are omitted from API requests. See
   630  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   631  	NullFields []string `json:"-"`
   632  }
   633  
   634  func (s *GcsDestinationConfig) MarshalJSON() ([]byte, error) {
   635  	type NoMethod GcsDestinationConfig
   636  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   637  }
   638  
   639  // GcsProfile: Cloud Storage bucket profile.
   640  type GcsProfile struct {
   641  	// BucketName: Required. The full project and resource path for Cloud Storage
   642  	// bucket including the name.
   643  	BucketName string `json:"bucketName,omitempty"`
   644  	// RootPath: The root path inside the Cloud Storage bucket.
   645  	RootPath string `json:"rootPath,omitempty"`
   646  	// ForceSendFields is a list of field names (e.g. "BucketName") to
   647  	// unconditionally include in API requests. By default, fields with empty or
   648  	// default values are omitted from API requests. See
   649  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   650  	// details.
   651  	ForceSendFields []string `json:"-"`
   652  	// NullFields is a list of field names (e.g. "BucketName") to include in API
   653  	// requests with the JSON null value. By default, fields with empty values are
   654  	// omitted from API requests. See
   655  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   656  	NullFields []string `json:"-"`
   657  }
   658  
   659  func (s *GcsProfile) MarshalJSON() ([]byte, error) {
   660  	type NoMethod GcsProfile
   661  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   662  }
   663  
   664  // JsonFileFormat: JSON file format configuration.
   665  type JsonFileFormat struct {
   666  	// Compression: Compression of the loaded JSON file.
   667  	//
   668  	// Possible values:
   669  	//   "JSON_COMPRESSION_UNSPECIFIED" - Unspecified json file compression.
   670  	//   "NO_COMPRESSION" - Do not compress JSON file.
   671  	//   "GZIP" - Gzip compression.
   672  	Compression string `json:"compression,omitempty"`
   673  	// SchemaFileFormat: The schema file format along JSON data files.
   674  	//
   675  	// Possible values:
   676  	//   "SCHEMA_FILE_FORMAT_UNSPECIFIED" - Unspecified schema file format.
   677  	//   "NO_SCHEMA_FILE" - Do not attach schema file.
   678  	//   "AVRO_SCHEMA_FILE" - Avro schema format.
   679  	SchemaFileFormat string `json:"schemaFileFormat,omitempty"`
   680  	// ForceSendFields is a list of field names (e.g. "Compression") to
   681  	// unconditionally include in API requests. By default, fields with empty or
   682  	// default values are omitted from API requests. See
   683  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   684  	// details.
   685  	ForceSendFields []string `json:"-"`
   686  	// NullFields is a list of field names (e.g. "Compression") to include in API
   687  	// requests with the JSON null value. By default, fields with empty values are
   688  	// omitted from API requests. See
   689  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   690  	NullFields []string `json:"-"`
   691  }
   692  
   693  func (s *JsonFileFormat) MarshalJSON() ([]byte, error) {
   694  	type NoMethod JsonFileFormat
   695  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   696  }
   697  
   698  type ListConnectionProfilesResponse struct {
   699  	// ConnectionProfiles: List of connection profiles.
   700  	ConnectionProfiles []*ConnectionProfile `json:"connectionProfiles,omitempty"`
   701  	// NextPageToken: A token, which can be sent as `page_token` to retrieve the
   702  	// next page. If this field is omitted, there are no subsequent pages.
   703  	NextPageToken string `json:"nextPageToken,omitempty"`
   704  	// Unreachable: Locations that could not be reached.
   705  	Unreachable []string `json:"unreachable,omitempty"`
   706  
   707  	// ServerResponse contains the HTTP response code and headers from the server.
   708  	googleapi.ServerResponse `json:"-"`
   709  	// ForceSendFields is a list of field names (e.g. "ConnectionProfiles") to
   710  	// unconditionally include in API requests. By default, fields with empty or
   711  	// default values are omitted from API requests. See
   712  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   713  	// details.
   714  	ForceSendFields []string `json:"-"`
   715  	// NullFields is a list of field names (e.g. "ConnectionProfiles") to include
   716  	// in API requests with the JSON null value. By default, fields with empty
   717  	// values are omitted from API requests. See
   718  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   719  	NullFields []string `json:"-"`
   720  }
   721  
   722  func (s *ListConnectionProfilesResponse) MarshalJSON() ([]byte, error) {
   723  	type NoMethod ListConnectionProfilesResponse
   724  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   725  }
   726  
   727  // ListLocationsResponse: The response message for Locations.ListLocations.
   728  type ListLocationsResponse struct {
   729  	// Locations: A list of locations that matches the specified filter in the
   730  	// request.
   731  	Locations []*Location `json:"locations,omitempty"`
   732  	// NextPageToken: The standard List next-page token.
   733  	NextPageToken string `json:"nextPageToken,omitempty"`
   734  
   735  	// ServerResponse contains the HTTP response code and headers from the server.
   736  	googleapi.ServerResponse `json:"-"`
   737  	// ForceSendFields is a list of field names (e.g. "Locations") to
   738  	// unconditionally include in API requests. By default, fields with empty or
   739  	// default values are omitted from API requests. See
   740  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   741  	// details.
   742  	ForceSendFields []string `json:"-"`
   743  	// NullFields is a list of field names (e.g. "Locations") to include in API
   744  	// requests with the JSON null value. By default, fields with empty values are
   745  	// omitted from API requests. See
   746  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   747  	NullFields []string `json:"-"`
   748  }
   749  
   750  func (s *ListLocationsResponse) MarshalJSON() ([]byte, error) {
   751  	type NoMethod ListLocationsResponse
   752  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   753  }
   754  
   755  // ListOperationsResponse: The response message for Operations.ListOperations.
   756  type ListOperationsResponse struct {
   757  	// NextPageToken: The standard List next-page token.
   758  	NextPageToken string `json:"nextPageToken,omitempty"`
   759  	// Operations: A list of operations that matches the specified filter in the
   760  	// request.
   761  	Operations []*Operation `json:"operations,omitempty"`
   762  
   763  	// ServerResponse contains the HTTP response code and headers from the server.
   764  	googleapi.ServerResponse `json:"-"`
   765  	// ForceSendFields is a list of field names (e.g. "NextPageToken") to
   766  	// unconditionally include in API requests. By default, fields with empty or
   767  	// default values are omitted from API requests. See
   768  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   769  	// details.
   770  	ForceSendFields []string `json:"-"`
   771  	// NullFields is a list of field names (e.g. "NextPageToken") to include in API
   772  	// requests with the JSON null value. By default, fields with empty values are
   773  	// omitted from API requests. See
   774  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   775  	NullFields []string `json:"-"`
   776  }
   777  
   778  func (s *ListOperationsResponse) MarshalJSON() ([]byte, error) {
   779  	type NoMethod ListOperationsResponse
   780  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   781  }
   782  
   783  type ListPrivateConnectionsResponse struct {
   784  	// NextPageToken: A token, which can be sent as `page_token` to retrieve the
   785  	// next page. If this field is omitted, there are no subsequent pages.
   786  	NextPageToken string `json:"nextPageToken,omitempty"`
   787  	// PrivateConnections: List of private connectivity configurations.
   788  	PrivateConnections []*PrivateConnection `json:"privateConnections,omitempty"`
   789  	// Unreachable: Locations that could not be reached.
   790  	Unreachable []string `json:"unreachable,omitempty"`
   791  
   792  	// ServerResponse contains the HTTP response code and headers from the server.
   793  	googleapi.ServerResponse `json:"-"`
   794  	// ForceSendFields is a list of field names (e.g. "NextPageToken") to
   795  	// unconditionally include in API requests. By default, fields with empty or
   796  	// default values are omitted from API requests. See
   797  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   798  	// details.
   799  	ForceSendFields []string `json:"-"`
   800  	// NullFields is a list of field names (e.g. "NextPageToken") to include in API
   801  	// requests with the JSON null value. By default, fields with empty values are
   802  	// omitted from API requests. See
   803  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   804  	NullFields []string `json:"-"`
   805  }
   806  
   807  func (s *ListPrivateConnectionsResponse) MarshalJSON() ([]byte, error) {
   808  	type NoMethod ListPrivateConnectionsResponse
   809  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   810  }
   811  
   812  // ListRoutesResponse: route list response
   813  type ListRoutesResponse struct {
   814  	// NextPageToken: A token, which can be sent as `page_token` to retrieve the
   815  	// next page. If this field is omitted, there are no subsequent pages.
   816  	NextPageToken string `json:"nextPageToken,omitempty"`
   817  	// Routes: List of Routes.
   818  	Routes []*Route `json:"routes,omitempty"`
   819  	// Unreachable: Locations that could not be reached.
   820  	Unreachable []string `json:"unreachable,omitempty"`
   821  
   822  	// ServerResponse contains the HTTP response code and headers from the server.
   823  	googleapi.ServerResponse `json:"-"`
   824  	// ForceSendFields is a list of field names (e.g. "NextPageToken") to
   825  	// unconditionally include in API requests. By default, fields with empty or
   826  	// default values are omitted from API requests. See
   827  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   828  	// details.
   829  	ForceSendFields []string `json:"-"`
   830  	// NullFields is a list of field names (e.g. "NextPageToken") to include in API
   831  	// requests with the JSON null value. By default, fields with empty values are
   832  	// omitted from API requests. See
   833  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   834  	NullFields []string `json:"-"`
   835  }
   836  
   837  func (s *ListRoutesResponse) MarshalJSON() ([]byte, error) {
   838  	type NoMethod ListRoutesResponse
   839  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   840  }
   841  
   842  // ListStreamObjectsResponse: Response containing the objects for a stream.
   843  type ListStreamObjectsResponse struct {
   844  	// NextPageToken: A token, which can be sent as `page_token` to retrieve the
   845  	// next page.
   846  	NextPageToken string `json:"nextPageToken,omitempty"`
   847  	// StreamObjects: List of stream objects.
   848  	StreamObjects []*StreamObject `json:"streamObjects,omitempty"`
   849  
   850  	// ServerResponse contains the HTTP response code and headers from the server.
   851  	googleapi.ServerResponse `json:"-"`
   852  	// ForceSendFields is a list of field names (e.g. "NextPageToken") to
   853  	// unconditionally include in API requests. By default, fields with empty or
   854  	// default values are omitted from API requests. See
   855  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   856  	// details.
   857  	ForceSendFields []string `json:"-"`
   858  	// NullFields is a list of field names (e.g. "NextPageToken") to include in API
   859  	// requests with the JSON null value. By default, fields with empty values are
   860  	// omitted from API requests. See
   861  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   862  	NullFields []string `json:"-"`
   863  }
   864  
   865  func (s *ListStreamObjectsResponse) MarshalJSON() ([]byte, error) {
   866  	type NoMethod ListStreamObjectsResponse
   867  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   868  }
   869  
   870  type ListStreamsResponse struct {
   871  	// NextPageToken: A token, which can be sent as `page_token` to retrieve the
   872  	// next page. If this field is omitted, there are no subsequent pages.
   873  	NextPageToken string `json:"nextPageToken,omitempty"`
   874  	// Streams: List of streams
   875  	Streams []*Stream `json:"streams,omitempty"`
   876  	// Unreachable: Locations that could not be reached.
   877  	Unreachable []string `json:"unreachable,omitempty"`
   878  
   879  	// ServerResponse contains the HTTP response code and headers from the server.
   880  	googleapi.ServerResponse `json:"-"`
   881  	// ForceSendFields is a list of field names (e.g. "NextPageToken") to
   882  	// unconditionally include in API requests. By default, fields with empty or
   883  	// default values are omitted from API requests. See
   884  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   885  	// details.
   886  	ForceSendFields []string `json:"-"`
   887  	// NullFields is a list of field names (e.g. "NextPageToken") to include in API
   888  	// requests with the JSON null value. By default, fields with empty values are
   889  	// omitted from API requests. See
   890  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   891  	NullFields []string `json:"-"`
   892  }
   893  
   894  func (s *ListStreamsResponse) MarshalJSON() ([]byte, error) {
   895  	type NoMethod ListStreamsResponse
   896  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   897  }
   898  
   899  // Location: A resource that represents a Google Cloud location.
   900  type Location struct {
   901  	// DisplayName: The friendly name for this location, typically a nearby city
   902  	// name. For example, "Tokyo".
   903  	DisplayName string `json:"displayName,omitempty"`
   904  	// Labels: Cross-service attributes for the location. For example
   905  	// {"cloud.googleapis.com/region": "us-east1"}
   906  	Labels map[string]string `json:"labels,omitempty"`
   907  	// LocationId: The canonical id for this location. For example: "us-east1".
   908  	LocationId string `json:"locationId,omitempty"`
   909  	// Metadata: Service-specific metadata. For example the available capacity at
   910  	// the given location.
   911  	Metadata googleapi.RawMessage `json:"metadata,omitempty"`
   912  	// Name: Resource name for the location, which may vary between
   913  	// implementations. For example:
   914  	// "projects/example-project/locations/us-east1"
   915  	Name string `json:"name,omitempty"`
   916  
   917  	// ServerResponse contains the HTTP response code and headers from the server.
   918  	googleapi.ServerResponse `json:"-"`
   919  	// ForceSendFields is a list of field names (e.g. "DisplayName") to
   920  	// unconditionally include in API requests. By default, fields with empty or
   921  	// default values are omitted from API requests. See
   922  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   923  	// details.
   924  	ForceSendFields []string `json:"-"`
   925  	// NullFields is a list of field names (e.g. "DisplayName") to include in API
   926  	// requests with the JSON null value. By default, fields with empty values are
   927  	// omitted from API requests. See
   928  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   929  	NullFields []string `json:"-"`
   930  }
   931  
   932  func (s *Location) MarshalJSON() ([]byte, error) {
   933  	type NoMethod Location
   934  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   935  }
   936  
   937  // MysqlColumn: MySQL Column.
   938  type MysqlColumn struct {
   939  	// Collation: Column collation.
   940  	Collation string `json:"collation,omitempty"`
   941  	// ColumnName: Column name.
   942  	ColumnName string `json:"columnName,omitempty"`
   943  	// DataType: The MySQL data type. Full data types list can be found here:
   944  	// https://dev.mysql.com/doc/refman/8.0/en/data-types.html
   945  	DataType string `json:"dataType,omitempty"`
   946  	// Length: Column length.
   947  	Length int64 `json:"length,omitempty"`
   948  	// Nullable: Whether or not the column can accept a null value.
   949  	Nullable bool `json:"nullable,omitempty"`
   950  	// OrdinalPosition: The ordinal position of the column in the table.
   951  	OrdinalPosition int64 `json:"ordinalPosition,omitempty"`
   952  	// PrimaryKey: Whether or not the column represents a primary key.
   953  	PrimaryKey bool `json:"primaryKey,omitempty"`
   954  	// ForceSendFields is a list of field names (e.g. "Collation") to
   955  	// unconditionally include in API requests. By default, fields with empty or
   956  	// default values are omitted from API requests. See
   957  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   958  	// details.
   959  	ForceSendFields []string `json:"-"`
   960  	// NullFields is a list of field names (e.g. "Collation") to include in API
   961  	// requests with the JSON null value. By default, fields with empty values are
   962  	// omitted from API requests. See
   963  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   964  	NullFields []string `json:"-"`
   965  }
   966  
   967  func (s *MysqlColumn) MarshalJSON() ([]byte, error) {
   968  	type NoMethod MysqlColumn
   969  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   970  }
   971  
   972  // MysqlDatabase: MySQL database.
   973  type MysqlDatabase struct {
   974  	// DatabaseName: Database name.
   975  	DatabaseName string `json:"databaseName,omitempty"`
   976  	// MysqlTables: Tables in the database.
   977  	MysqlTables []*MysqlTable `json:"mysqlTables,omitempty"`
   978  	// ForceSendFields is a list of field names (e.g. "DatabaseName") to
   979  	// unconditionally include in API requests. By default, fields with empty or
   980  	// default values are omitted from API requests. See
   981  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
   982  	// details.
   983  	ForceSendFields []string `json:"-"`
   984  	// NullFields is a list of field names (e.g. "DatabaseName") to include in API
   985  	// requests with the JSON null value. By default, fields with empty values are
   986  	// omitted from API requests. See
   987  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
   988  	NullFields []string `json:"-"`
   989  }
   990  
   991  func (s *MysqlDatabase) MarshalJSON() ([]byte, error) {
   992  	type NoMethod MysqlDatabase
   993  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
   994  }
   995  
   996  // MysqlObjectIdentifier: Mysql data source object identifier.
   997  type MysqlObjectIdentifier struct {
   998  	// Database: Required. The database name.
   999  	Database string `json:"database,omitempty"`
  1000  	// Table: Required. The table name.
  1001  	Table string `json:"table,omitempty"`
  1002  	// ForceSendFields is a list of field names (e.g. "Database") to
  1003  	// unconditionally include in API requests. By default, fields with empty or
  1004  	// default values are omitted from API requests. See
  1005  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1006  	// details.
  1007  	ForceSendFields []string `json:"-"`
  1008  	// NullFields is a list of field names (e.g. "Database") to include in API
  1009  	// requests with the JSON null value. By default, fields with empty values are
  1010  	// omitted from API requests. See
  1011  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1012  	NullFields []string `json:"-"`
  1013  }
  1014  
  1015  func (s *MysqlObjectIdentifier) MarshalJSON() ([]byte, error) {
  1016  	type NoMethod MysqlObjectIdentifier
  1017  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1018  }
  1019  
  1020  // MysqlProfile: MySQL database profile.
  1021  type MysqlProfile struct {
  1022  	// Hostname: Required. Hostname for the MySQL connection.
  1023  	Hostname string `json:"hostname,omitempty"`
  1024  	// Password: Required. Input only. Password for the MySQL connection.
  1025  	Password string `json:"password,omitempty"`
  1026  	// Port: Port for the MySQL connection, default value is 3306.
  1027  	Port int64 `json:"port,omitempty"`
  1028  	// SslConfig: SSL configuration for the MySQL connection.
  1029  	SslConfig *MysqlSslConfig `json:"sslConfig,omitempty"`
  1030  	// Username: Required. Username for the MySQL connection.
  1031  	Username string `json:"username,omitempty"`
  1032  	// ForceSendFields is a list of field names (e.g. "Hostname") to
  1033  	// unconditionally include in API requests. By default, fields with empty or
  1034  	// default values are omitted from API requests. See
  1035  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1036  	// details.
  1037  	ForceSendFields []string `json:"-"`
  1038  	// NullFields is a list of field names (e.g. "Hostname") to include in API
  1039  	// requests with the JSON null value. By default, fields with empty values are
  1040  	// omitted from API requests. See
  1041  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1042  	NullFields []string `json:"-"`
  1043  }
  1044  
  1045  func (s *MysqlProfile) MarshalJSON() ([]byte, error) {
  1046  	type NoMethod MysqlProfile
  1047  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1048  }
  1049  
  1050  // MysqlRdbms: MySQL database structure
  1051  type MysqlRdbms struct {
  1052  	// MysqlDatabases: Mysql databases on the server
  1053  	MysqlDatabases []*MysqlDatabase `json:"mysqlDatabases,omitempty"`
  1054  	// ForceSendFields is a list of field names (e.g. "MysqlDatabases") to
  1055  	// unconditionally include in API requests. By default, fields with empty or
  1056  	// default values are omitted from API requests. See
  1057  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1058  	// details.
  1059  	ForceSendFields []string `json:"-"`
  1060  	// NullFields is a list of field names (e.g. "MysqlDatabases") to include in
  1061  	// API requests with the JSON null value. By default, fields with empty values
  1062  	// are omitted from API requests. See
  1063  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1064  	NullFields []string `json:"-"`
  1065  }
  1066  
  1067  func (s *MysqlRdbms) MarshalJSON() ([]byte, error) {
  1068  	type NoMethod MysqlRdbms
  1069  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1070  }
  1071  
  1072  // MysqlSourceConfig: MySQL source configuration
  1073  type MysqlSourceConfig struct {
  1074  	// Allowlist: MySQL objects to retrieve from the source.
  1075  	Allowlist *MysqlRdbms `json:"allowlist,omitempty"`
  1076  	// Rejectlist: MySQL objects to exclude from the stream.
  1077  	Rejectlist *MysqlRdbms `json:"rejectlist,omitempty"`
  1078  	// ForceSendFields is a list of field names (e.g. "Allowlist") to
  1079  	// unconditionally include in API requests. By default, fields with empty or
  1080  	// default values are omitted from API requests. See
  1081  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1082  	// details.
  1083  	ForceSendFields []string `json:"-"`
  1084  	// NullFields is a list of field names (e.g. "Allowlist") to include in API
  1085  	// requests with the JSON null value. By default, fields with empty values are
  1086  	// omitted from API requests. See
  1087  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1088  	NullFields []string `json:"-"`
  1089  }
  1090  
  1091  func (s *MysqlSourceConfig) MarshalJSON() ([]byte, error) {
  1092  	type NoMethod MysqlSourceConfig
  1093  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1094  }
  1095  
  1096  // MysqlSslConfig: MySQL SSL configuration information.
  1097  type MysqlSslConfig struct {
  1098  	// CaCertificate: Input only. PEM-encoded certificate of the CA that signed the
  1099  	// source database server's certificate.
  1100  	CaCertificate string `json:"caCertificate,omitempty"`
  1101  	// CaCertificateSet: Output only. Indicates whether the ca_certificate field is
  1102  	// set.
  1103  	CaCertificateSet bool `json:"caCertificateSet,omitempty"`
  1104  	// ClientCertificate: Input only. PEM-encoded certificate that will be used by
  1105  	// the replica to authenticate against the source database server. If this
  1106  	// field is used then the 'client_key' and the 'ca_certificate' fields are
  1107  	// mandatory.
  1108  	ClientCertificate string `json:"clientCertificate,omitempty"`
  1109  	// ClientCertificateSet: Output only. Indicates whether the client_certificate
  1110  	// field is set.
  1111  	ClientCertificateSet bool `json:"clientCertificateSet,omitempty"`
  1112  	// ClientKey: Input only. PEM-encoded private key associated with the Client
  1113  	// Certificate. If this field is used then the 'client_certificate' and the
  1114  	// 'ca_certificate' fields are mandatory.
  1115  	ClientKey string `json:"clientKey,omitempty"`
  1116  	// ClientKeySet: Output only. Indicates whether the client_key field is set.
  1117  	ClientKeySet bool `json:"clientKeySet,omitempty"`
  1118  	// ForceSendFields is a list of field names (e.g. "CaCertificate") to
  1119  	// unconditionally include in API requests. By default, fields with empty or
  1120  	// default values are omitted from API requests. See
  1121  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1122  	// details.
  1123  	ForceSendFields []string `json:"-"`
  1124  	// NullFields is a list of field names (e.g. "CaCertificate") to include in API
  1125  	// requests with the JSON null value. By default, fields with empty values are
  1126  	// omitted from API requests. See
  1127  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1128  	NullFields []string `json:"-"`
  1129  }
  1130  
  1131  func (s *MysqlSslConfig) MarshalJSON() ([]byte, error) {
  1132  	type NoMethod MysqlSslConfig
  1133  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1134  }
  1135  
  1136  // MysqlTable: MySQL table.
  1137  type MysqlTable struct {
  1138  	// MysqlColumns: MySQL columns in the database. When unspecified as part of
  1139  	// include/exclude lists, includes/excludes everything.
  1140  	MysqlColumns []*MysqlColumn `json:"mysqlColumns,omitempty"`
  1141  	// TableName: Table name.
  1142  	TableName string `json:"tableName,omitempty"`
  1143  	// ForceSendFields is a list of field names (e.g. "MysqlColumns") to
  1144  	// unconditionally include in API requests. By default, fields with empty or
  1145  	// default values are omitted from API requests. See
  1146  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1147  	// details.
  1148  	ForceSendFields []string `json:"-"`
  1149  	// NullFields is a list of field names (e.g. "MysqlColumns") to include in API
  1150  	// requests with the JSON null value. By default, fields with empty values are
  1151  	// omitted from API requests. See
  1152  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1153  	NullFields []string `json:"-"`
  1154  }
  1155  
  1156  func (s *MysqlTable) MarshalJSON() ([]byte, error) {
  1157  	type NoMethod MysqlTable
  1158  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1159  }
  1160  
  1161  // NoConnectivitySettings: No connectivity settings.
  1162  type NoConnectivitySettings struct {
  1163  }
  1164  
  1165  // Operation: This resource represents a long-running operation that is the
  1166  // result of a network API call.
  1167  type Operation struct {
  1168  	// Done: If the value is `false`, it means the operation is still in progress.
  1169  	// If `true`, the operation is completed, and either `error` or `response` is
  1170  	// available.
  1171  	Done bool `json:"done,omitempty"`
  1172  	// Error: The error result of the operation in case of failure or cancellation.
  1173  	Error *Status `json:"error,omitempty"`
  1174  	// Metadata: Service-specific metadata associated with the operation. It
  1175  	// typically contains progress information and common metadata such as create
  1176  	// time. Some services might not provide such metadata. Any method that returns
  1177  	// a long-running operation should document the metadata type, if any.
  1178  	Metadata googleapi.RawMessage `json:"metadata,omitempty"`
  1179  	// Name: The server-assigned name, which is only unique within the same service
  1180  	// that originally returns it. If you use the default HTTP mapping, the `name`
  1181  	// should be a resource name ending with `operations/{unique_id}`.
  1182  	Name string `json:"name,omitempty"`
  1183  	// Response: The normal, successful response of the operation. If the original
  1184  	// method returns no data on success, such as `Delete`, the response is
  1185  	// `google.protobuf.Empty`. If the original method is standard
  1186  	// `Get`/`Create`/`Update`, the response should be the resource. For other
  1187  	// methods, the response should have the type `XxxResponse`, where `Xxx` is the
  1188  	// original method name. For example, if the original method name is
  1189  	// `TakeSnapshot()`, the inferred response type is `TakeSnapshotResponse`.
  1190  	Response googleapi.RawMessage `json:"response,omitempty"`
  1191  
  1192  	// ServerResponse contains the HTTP response code and headers from the server.
  1193  	googleapi.ServerResponse `json:"-"`
  1194  	// ForceSendFields is a list of field names (e.g. "Done") to unconditionally
  1195  	// include in API requests. By default, fields with empty or default values are
  1196  	// omitted from API requests. See
  1197  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1198  	// details.
  1199  	ForceSendFields []string `json:"-"`
  1200  	// NullFields is a list of field names (e.g. "Done") to include in API requests
  1201  	// with the JSON null value. By default, fields with empty values are omitted
  1202  	// from API requests. See
  1203  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1204  	NullFields []string `json:"-"`
  1205  }
  1206  
  1207  func (s *Operation) MarshalJSON() ([]byte, error) {
  1208  	type NoMethod Operation
  1209  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1210  }
  1211  
  1212  // OperationMetadata: Represents the metadata of the long-running operation.
  1213  type OperationMetadata struct {
  1214  	// ApiVersion: Output only. API version used to start the operation.
  1215  	ApiVersion string `json:"apiVersion,omitempty"`
  1216  	// CreateTime: Output only. The time the operation was created.
  1217  	CreateTime string `json:"createTime,omitempty"`
  1218  	// EndTime: Output only. The time the operation finished running.
  1219  	EndTime string `json:"endTime,omitempty"`
  1220  	// RequestedCancellation: Output only. Identifies whether the user has
  1221  	// requested cancellation of the operation. Operations that have successfully
  1222  	// been cancelled have Operation.error value with a google.rpc.Status.code of
  1223  	// 1, corresponding to `Code.CANCELLED`.
  1224  	RequestedCancellation bool `json:"requestedCancellation,omitempty"`
  1225  	// StatusMessage: Output only. Human-readable status of the operation, if any.
  1226  	StatusMessage string `json:"statusMessage,omitempty"`
  1227  	// Target: Output only. Server-defined resource path for the target of the
  1228  	// operation.
  1229  	Target string `json:"target,omitempty"`
  1230  	// ValidationResult: Output only. Results of executed validations if there are
  1231  	// any.
  1232  	ValidationResult *ValidationResult `json:"validationResult,omitempty"`
  1233  	// Verb: Output only. Name of the verb executed by the operation.
  1234  	Verb string `json:"verb,omitempty"`
  1235  	// ForceSendFields is a list of field names (e.g. "ApiVersion") to
  1236  	// unconditionally include in API requests. By default, fields with empty or
  1237  	// default values are omitted from API requests. See
  1238  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1239  	// details.
  1240  	ForceSendFields []string `json:"-"`
  1241  	// NullFields is a list of field names (e.g. "ApiVersion") to include in API
  1242  	// requests with the JSON null value. By default, fields with empty values are
  1243  	// omitted from API requests. See
  1244  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1245  	NullFields []string `json:"-"`
  1246  }
  1247  
  1248  func (s *OperationMetadata) MarshalJSON() ([]byte, error) {
  1249  	type NoMethod OperationMetadata
  1250  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1251  }
  1252  
  1253  // OracleColumn: Oracle Column.
  1254  type OracleColumn struct {
  1255  	// ColumnName: Column name.
  1256  	ColumnName string `json:"columnName,omitempty"`
  1257  	// DataType: The Oracle data type.
  1258  	DataType string `json:"dataType,omitempty"`
  1259  	// Encoding: Column encoding.
  1260  	Encoding string `json:"encoding,omitempty"`
  1261  	// Length: Column length.
  1262  	Length int64 `json:"length,omitempty"`
  1263  	// Nullable: Whether or not the column can accept a null value.
  1264  	Nullable bool `json:"nullable,omitempty"`
  1265  	// OrdinalPosition: The ordinal position of the column in the table.
  1266  	OrdinalPosition int64 `json:"ordinalPosition,omitempty"`
  1267  	// Precision: Column precision.
  1268  	Precision int64 `json:"precision,omitempty"`
  1269  	// PrimaryKey: Whether or not the column represents a primary key.
  1270  	PrimaryKey bool `json:"primaryKey,omitempty"`
  1271  	// Scale: Column scale.
  1272  	Scale int64 `json:"scale,omitempty"`
  1273  	// ForceSendFields is a list of field names (e.g. "ColumnName") to
  1274  	// unconditionally include in API requests. By default, fields with empty or
  1275  	// default values are omitted from API requests. See
  1276  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1277  	// details.
  1278  	ForceSendFields []string `json:"-"`
  1279  	// NullFields is a list of field names (e.g. "ColumnName") to include in API
  1280  	// requests with the JSON null value. By default, fields with empty values are
  1281  	// omitted from API requests. See
  1282  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1283  	NullFields []string `json:"-"`
  1284  }
  1285  
  1286  func (s *OracleColumn) MarshalJSON() ([]byte, error) {
  1287  	type NoMethod OracleColumn
  1288  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1289  }
  1290  
  1291  // OracleObjectIdentifier: Oracle data source object identifier.
  1292  type OracleObjectIdentifier struct {
  1293  	// Schema: Required. The schema name.
  1294  	Schema string `json:"schema,omitempty"`
  1295  	// Table: Required. The table name.
  1296  	Table string `json:"table,omitempty"`
  1297  	// ForceSendFields is a list of field names (e.g. "Schema") to unconditionally
  1298  	// include in API requests. By default, fields with empty or default values are
  1299  	// omitted from API requests. See
  1300  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1301  	// details.
  1302  	ForceSendFields []string `json:"-"`
  1303  	// NullFields is a list of field names (e.g. "Schema") to include in API
  1304  	// requests with the JSON null value. By default, fields with empty values are
  1305  	// omitted from API requests. See
  1306  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1307  	NullFields []string `json:"-"`
  1308  }
  1309  
  1310  func (s *OracleObjectIdentifier) MarshalJSON() ([]byte, error) {
  1311  	type NoMethod OracleObjectIdentifier
  1312  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1313  }
  1314  
  1315  // OracleProfile: Oracle database profile.
  1316  type OracleProfile struct {
  1317  	// ConnectionAttributes: Connection string attributes
  1318  	ConnectionAttributes map[string]string `json:"connectionAttributes,omitempty"`
  1319  	// DatabaseService: Required. Database for the Oracle connection.
  1320  	DatabaseService string `json:"databaseService,omitempty"`
  1321  	// Hostname: Required. Hostname for the Oracle connection.
  1322  	Hostname string `json:"hostname,omitempty"`
  1323  	// Password: Required. Password for the Oracle connection.
  1324  	Password string `json:"password,omitempty"`
  1325  	// Port: Port for the Oracle connection, default value is 1521.
  1326  	Port int64 `json:"port,omitempty"`
  1327  	// Username: Required. Username for the Oracle connection.
  1328  	Username string `json:"username,omitempty"`
  1329  	// ForceSendFields is a list of field names (e.g. "ConnectionAttributes") to
  1330  	// unconditionally include in API requests. By default, fields with empty or
  1331  	// default values are omitted from API requests. See
  1332  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1333  	// details.
  1334  	ForceSendFields []string `json:"-"`
  1335  	// NullFields is a list of field names (e.g. "ConnectionAttributes") to include
  1336  	// in API requests with the JSON null value. By default, fields with empty
  1337  	// values are omitted from API requests. See
  1338  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1339  	NullFields []string `json:"-"`
  1340  }
  1341  
  1342  func (s *OracleProfile) MarshalJSON() ([]byte, error) {
  1343  	type NoMethod OracleProfile
  1344  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1345  }
  1346  
  1347  // OracleRdbms: Oracle database structure.
  1348  type OracleRdbms struct {
  1349  	// OracleSchemas: Oracle schemas/databases in the database server.
  1350  	OracleSchemas []*OracleSchema `json:"oracleSchemas,omitempty"`
  1351  	// ForceSendFields is a list of field names (e.g. "OracleSchemas") to
  1352  	// unconditionally include in API requests. By default, fields with empty or
  1353  	// default values are 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. "OracleSchemas") to include in API
  1358  	// requests with the JSON null value. By default, fields with empty values are
  1359  	// omitted 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 *OracleRdbms) MarshalJSON() ([]byte, error) {
  1365  	type NoMethod OracleRdbms
  1366  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1367  }
  1368  
  1369  // OracleSchema: Oracle schema.
  1370  type OracleSchema struct {
  1371  	// OracleTables: Tables in the schema.
  1372  	OracleTables []*OracleTable `json:"oracleTables,omitempty"`
  1373  	// SchemaName: Schema name.
  1374  	SchemaName string `json:"schemaName,omitempty"`
  1375  	// ForceSendFields is a list of field names (e.g. "OracleTables") to
  1376  	// unconditionally include in API requests. By default, fields with empty or
  1377  	// default values are omitted from API requests. See
  1378  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1379  	// details.
  1380  	ForceSendFields []string `json:"-"`
  1381  	// NullFields is a list of field names (e.g. "OracleTables") to include in API
  1382  	// requests with the JSON null value. By default, fields with empty values are
  1383  	// omitted from API requests. See
  1384  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1385  	NullFields []string `json:"-"`
  1386  }
  1387  
  1388  func (s *OracleSchema) MarshalJSON() ([]byte, error) {
  1389  	type NoMethod OracleSchema
  1390  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1391  }
  1392  
  1393  // OracleSourceConfig: Oracle data source configuration
  1394  type OracleSourceConfig struct {
  1395  	// Allowlist: Oracle objects to include in the stream.
  1396  	Allowlist *OracleRdbms `json:"allowlist,omitempty"`
  1397  	// DropLargeObjects: Drop large object values.
  1398  	DropLargeObjects *DropLargeObjects `json:"dropLargeObjects,omitempty"`
  1399  	// Rejectlist: Oracle objects to exclude from the stream.
  1400  	Rejectlist *OracleRdbms `json:"rejectlist,omitempty"`
  1401  	// ForceSendFields is a list of field names (e.g. "Allowlist") to
  1402  	// unconditionally include in API requests. By default, fields with empty or
  1403  	// default values are omitted from API requests. See
  1404  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1405  	// details.
  1406  	ForceSendFields []string `json:"-"`
  1407  	// NullFields is a list of field names (e.g. "Allowlist") to include in API
  1408  	// requests with the JSON null value. By default, fields with empty values are
  1409  	// omitted from API requests. See
  1410  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1411  	NullFields []string `json:"-"`
  1412  }
  1413  
  1414  func (s *OracleSourceConfig) MarshalJSON() ([]byte, error) {
  1415  	type NoMethod OracleSourceConfig
  1416  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1417  }
  1418  
  1419  // OracleTable: Oracle table.
  1420  type OracleTable struct {
  1421  	// OracleColumns: Oracle columns in the schema. When unspecified as part of
  1422  	// inclue/exclude lists, includes/excludes everything.
  1423  	OracleColumns []*OracleColumn `json:"oracleColumns,omitempty"`
  1424  	// TableName: Table name.
  1425  	TableName string `json:"tableName,omitempty"`
  1426  	// ForceSendFields is a list of field names (e.g. "OracleColumns") to
  1427  	// unconditionally include in API requests. By default, fields with empty or
  1428  	// default values are omitted from API requests. See
  1429  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1430  	// details.
  1431  	ForceSendFields []string `json:"-"`
  1432  	// NullFields is a list of field names (e.g. "OracleColumns") to include in API
  1433  	// requests with the JSON null value. By default, fields with empty values are
  1434  	// omitted from API requests. See
  1435  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1436  	NullFields []string `json:"-"`
  1437  }
  1438  
  1439  func (s *OracleTable) MarshalJSON() ([]byte, error) {
  1440  	type NoMethod OracleTable
  1441  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1442  }
  1443  
  1444  // PrivateConnection: The PrivateConnection resource is used to establish
  1445  // private connectivity between Datastream and a customer's network.
  1446  type PrivateConnection struct {
  1447  	// CreateTime: Output only. The create time of the resource.
  1448  	CreateTime string `json:"createTime,omitempty"`
  1449  	// DisplayName: Required. Display name.
  1450  	DisplayName string `json:"displayName,omitempty"`
  1451  	// Error: Output only. In case of error, the details of the error in a
  1452  	// user-friendly format.
  1453  	Error *Error `json:"error,omitempty"`
  1454  	// Labels: Labels.
  1455  	Labels map[string]string `json:"labels,omitempty"`
  1456  	// Name: Output only. The resource's name.
  1457  	Name string `json:"name,omitempty"`
  1458  	// State: Output only. The state of the Private Connection.
  1459  	//
  1460  	// Possible values:
  1461  	//   "STATE_UNSPECIFIED"
  1462  	//   "CREATING" - The private connection is in creation state - creating
  1463  	// resources.
  1464  	//   "CREATED" - The private connection has been created with all of its
  1465  	// resources.
  1466  	//   "FAILED" - The private connection creation has failed.
  1467  	//   "DELETING" - The private connection is being deleted.
  1468  	//   "FAILED_TO_DELETE" - Delete request has failed, resource is in invalid
  1469  	// state.
  1470  	State string `json:"state,omitempty"`
  1471  	// UpdateTime: Output only. The update time of the resource.
  1472  	UpdateTime string `json:"updateTime,omitempty"`
  1473  	// VpcPeeringConfig: VPC Peering Config
  1474  	VpcPeeringConfig *VpcPeeringConfig `json:"vpcPeeringConfig,omitempty"`
  1475  
  1476  	// ServerResponse contains the HTTP response code and headers from the server.
  1477  	googleapi.ServerResponse `json:"-"`
  1478  	// ForceSendFields is a list of field names (e.g. "CreateTime") to
  1479  	// unconditionally include in API requests. By default, fields with empty or
  1480  	// default values are omitted from API requests. See
  1481  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1482  	// details.
  1483  	ForceSendFields []string `json:"-"`
  1484  	// NullFields is a list of field names (e.g. "CreateTime") to include in API
  1485  	// requests with the JSON null value. By default, fields with empty values are
  1486  	// omitted from API requests. See
  1487  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1488  	NullFields []string `json:"-"`
  1489  }
  1490  
  1491  func (s *PrivateConnection) MarshalJSON() ([]byte, error) {
  1492  	type NoMethod PrivateConnection
  1493  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1494  }
  1495  
  1496  // PrivateConnectivity: Private Connectivity
  1497  type PrivateConnectivity struct {
  1498  	PrivateConnectionName string `json:"privateConnectionName,omitempty"`
  1499  	// ForceSendFields is a list of field names (e.g. "PrivateConnectionName") to
  1500  	// unconditionally include in API requests. By default, fields with empty or
  1501  	// default values are omitted from API requests. See
  1502  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1503  	// details.
  1504  	ForceSendFields []string `json:"-"`
  1505  	// NullFields is a list of field names (e.g. "PrivateConnectionName") to
  1506  	// include in API requests with the JSON null value. By default, fields with
  1507  	// empty values are omitted from API requests. See
  1508  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1509  	NullFields []string `json:"-"`
  1510  }
  1511  
  1512  func (s *PrivateConnectivity) MarshalJSON() ([]byte, error) {
  1513  	type NoMethod PrivateConnectivity
  1514  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1515  }
  1516  
  1517  // Route: The Route resource is the child of the PrivateConnection resource. It
  1518  // used to define a route for a PrivateConnection setup.
  1519  type Route struct {
  1520  	// CreateTime: Output only. The create time of the resource.
  1521  	CreateTime string `json:"createTime,omitempty"`
  1522  	// DestinationAddress: Required. Destination address for connection
  1523  	DestinationAddress string `json:"destinationAddress,omitempty"`
  1524  	// DestinationPort: Destination port for connection
  1525  	DestinationPort int64 `json:"destinationPort,omitempty"`
  1526  	// DisplayName: Required. Display name.
  1527  	DisplayName string `json:"displayName,omitempty"`
  1528  	// Labels: Labels.
  1529  	Labels map[string]string `json:"labels,omitempty"`
  1530  	// Name: Output only. The resource's name.
  1531  	Name string `json:"name,omitempty"`
  1532  	// UpdateTime: Output only. The update time of the resource.
  1533  	UpdateTime string `json:"updateTime,omitempty"`
  1534  
  1535  	// ServerResponse contains the HTTP response code and headers from the server.
  1536  	googleapi.ServerResponse `json:"-"`
  1537  	// ForceSendFields is a list of field names (e.g. "CreateTime") to
  1538  	// unconditionally include in API requests. By default, fields with empty or
  1539  	// default values are omitted from API requests. See
  1540  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1541  	// details.
  1542  	ForceSendFields []string `json:"-"`
  1543  	// NullFields is a list of field names (e.g. "CreateTime") to include in API
  1544  	// requests with the JSON null value. By default, fields with empty values are
  1545  	// omitted from API requests. See
  1546  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1547  	NullFields []string `json:"-"`
  1548  }
  1549  
  1550  func (s *Route) MarshalJSON() ([]byte, error) {
  1551  	type NoMethod Route
  1552  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1553  }
  1554  
  1555  // SourceConfig: The configuration of the stream source.
  1556  type SourceConfig struct {
  1557  	// MysqlSourceConfig: MySQL data source configuration
  1558  	MysqlSourceConfig *MysqlSourceConfig `json:"mysqlSourceConfig,omitempty"`
  1559  	// OracleSourceConfig: Oracle data source configuration
  1560  	OracleSourceConfig *OracleSourceConfig `json:"oracleSourceConfig,omitempty"`
  1561  	// SourceConnectionProfileName: Required. Source connection profile identifier.
  1562  	SourceConnectionProfileName string `json:"sourceConnectionProfileName,omitempty"`
  1563  	// ForceSendFields is a list of field names (e.g. "MysqlSourceConfig") to
  1564  	// unconditionally include in API requests. By default, fields with empty or
  1565  	// default values are omitted from API requests. See
  1566  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1567  	// details.
  1568  	ForceSendFields []string `json:"-"`
  1569  	// NullFields is a list of field names (e.g. "MysqlSourceConfig") to include in
  1570  	// API requests with the JSON null value. By default, fields with empty values
  1571  	// are omitted from API requests. See
  1572  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1573  	NullFields []string `json:"-"`
  1574  }
  1575  
  1576  func (s *SourceConfig) MarshalJSON() ([]byte, error) {
  1577  	type NoMethod SourceConfig
  1578  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1579  }
  1580  
  1581  // SourceObjectIdentifier: Represents an identifier of an object in the data
  1582  // source.
  1583  type SourceObjectIdentifier struct {
  1584  	// MysqlIdentifier: Mysql data source object identifier.
  1585  	MysqlIdentifier *MysqlObjectIdentifier `json:"mysqlIdentifier,omitempty"`
  1586  	// OracleIdentifier: Oracle data source object identifier.
  1587  	OracleIdentifier *OracleObjectIdentifier `json:"oracleIdentifier,omitempty"`
  1588  	// ForceSendFields is a list of field names (e.g. "MysqlIdentifier") to
  1589  	// unconditionally include in API requests. By default, fields with empty or
  1590  	// default values are omitted from API requests. See
  1591  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1592  	// details.
  1593  	ForceSendFields []string `json:"-"`
  1594  	// NullFields is a list of field names (e.g. "MysqlIdentifier") to include in
  1595  	// API requests with the JSON null value. By default, fields with empty values
  1596  	// are omitted from API requests. See
  1597  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1598  	NullFields []string `json:"-"`
  1599  }
  1600  
  1601  func (s *SourceObjectIdentifier) MarshalJSON() ([]byte, error) {
  1602  	type NoMethod SourceObjectIdentifier
  1603  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1604  }
  1605  
  1606  // StartBackfillJobResponse: Response for manually initiating a backfill job
  1607  // for a specific stream object.
  1608  type StartBackfillJobResponse struct {
  1609  	// Object: The stream object resource a backfill job was started for.
  1610  	Object *StreamObject `json:"object,omitempty"`
  1611  
  1612  	// ServerResponse contains the HTTP response code and headers from the server.
  1613  	googleapi.ServerResponse `json:"-"`
  1614  	// ForceSendFields is a list of field names (e.g. "Object") to unconditionally
  1615  	// include in API requests. By default, fields with empty or default values are
  1616  	// omitted from API requests. See
  1617  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1618  	// details.
  1619  	ForceSendFields []string `json:"-"`
  1620  	// NullFields is a list of field names (e.g. "Object") to include in API
  1621  	// requests with the JSON null value. By default, fields with empty values are
  1622  	// omitted from API requests. See
  1623  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1624  	NullFields []string `json:"-"`
  1625  }
  1626  
  1627  func (s *StartBackfillJobResponse) MarshalJSON() ([]byte, error) {
  1628  	type NoMethod StartBackfillJobResponse
  1629  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1630  }
  1631  
  1632  // StaticServiceIpConnectivity: Static IP address connectivity.
  1633  type StaticServiceIpConnectivity struct {
  1634  }
  1635  
  1636  // Status: The `Status` type defines a logical error model that is suitable for
  1637  // different programming environments, including REST APIs and RPC APIs. It is
  1638  // used by gRPC (https://github.com/grpc). Each `Status` message contains three
  1639  // pieces of data: error code, error message, and error details. You can find
  1640  // out more about this error model and how to work with it in the API Design
  1641  // Guide (https://cloud.google.com/apis/design/errors).
  1642  type Status struct {
  1643  	// Code: The status code, which should be an enum value of google.rpc.Code.
  1644  	Code int64 `json:"code,omitempty"`
  1645  	// Details: A list of messages that carry the error details. There is a common
  1646  	// set of message types for APIs to use.
  1647  	Details []googleapi.RawMessage `json:"details,omitempty"`
  1648  	// Message: A developer-facing error message, which should be in English. Any
  1649  	// user-facing error message should be localized and sent in the
  1650  	// google.rpc.Status.details field, or localized by the client.
  1651  	Message string `json:"message,omitempty"`
  1652  	// ForceSendFields is a list of field names (e.g. "Code") to unconditionally
  1653  	// include in API requests. By default, fields with empty or default values are
  1654  	// omitted from API requests. See
  1655  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1656  	// details.
  1657  	ForceSendFields []string `json:"-"`
  1658  	// NullFields is a list of field names (e.g. "Code") to include in API requests
  1659  	// with the JSON null value. By default, fields with empty values are omitted
  1660  	// from API requests. See
  1661  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1662  	NullFields []string `json:"-"`
  1663  }
  1664  
  1665  func (s *Status) MarshalJSON() ([]byte, error) {
  1666  	type NoMethod Status
  1667  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1668  }
  1669  
  1670  // StopBackfillJobResponse: Response for manually stop a backfill job for a
  1671  // specific stream object.
  1672  type StopBackfillJobResponse struct {
  1673  	// Object: The stream object resource the backfill job was stopped for.
  1674  	Object *StreamObject `json:"object,omitempty"`
  1675  
  1676  	// ServerResponse contains the HTTP response code and headers from the server.
  1677  	googleapi.ServerResponse `json:"-"`
  1678  	// ForceSendFields is a list of field names (e.g. "Object") to unconditionally
  1679  	// include in API requests. By default, fields with empty or default values are
  1680  	// omitted from API requests. See
  1681  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1682  	// details.
  1683  	ForceSendFields []string `json:"-"`
  1684  	// NullFields is a list of field names (e.g. "Object") to include in API
  1685  	// requests with the JSON null value. By default, fields with empty values are
  1686  	// omitted from API requests. See
  1687  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1688  	NullFields []string `json:"-"`
  1689  }
  1690  
  1691  func (s *StopBackfillJobResponse) MarshalJSON() ([]byte, error) {
  1692  	type NoMethod StopBackfillJobResponse
  1693  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1694  }
  1695  
  1696  type Stream struct {
  1697  	// BackfillAll: Automatically backfill objects included in the stream source
  1698  	// configuration. Specific objects can be excluded.
  1699  	BackfillAll *BackfillAllStrategy `json:"backfillAll,omitempty"`
  1700  	// BackfillNone: Do not automatically backfill any objects.
  1701  	BackfillNone *BackfillNoneStrategy `json:"backfillNone,omitempty"`
  1702  	// CreateTime: Output only. The creation time of the stream.
  1703  	CreateTime string `json:"createTime,omitempty"`
  1704  	// CustomerManagedEncryptionKey: Immutable. A reference to a KMS encryption
  1705  	// key. If provided, it will be used to encrypt the data. If left blank, data
  1706  	// will be encrypted using an internal Stream-specific encryption key
  1707  	// provisioned through KMS.
  1708  	CustomerManagedEncryptionKey string `json:"customerManagedEncryptionKey,omitempty"`
  1709  	// DestinationConfig: Required. Destination connection profile configuration.
  1710  	DestinationConfig *DestinationConfig `json:"destinationConfig,omitempty"`
  1711  	// DisplayName: Required. Display name.
  1712  	DisplayName string `json:"displayName,omitempty"`
  1713  	// Errors: Output only. Errors on the Stream.
  1714  	Errors []*Error `json:"errors,omitempty"`
  1715  	// Labels: Labels.
  1716  	Labels map[string]string `json:"labels,omitempty"`
  1717  	// Name: Output only. The stream's name.
  1718  	Name string `json:"name,omitempty"`
  1719  	// SourceConfig: Required. Source connection profile configuration.
  1720  	SourceConfig *SourceConfig `json:"sourceConfig,omitempty"`
  1721  	// State: The state of the stream.
  1722  	//
  1723  	// Possible values:
  1724  	//   "STATE_UNSPECIFIED" - Unspecified stream state.
  1725  	//   "CREATED" - The stream has been created.
  1726  	//   "RUNNING" - The stream is running.
  1727  	//   "PAUSED" - The stream is paused.
  1728  	//   "MAINTENANCE" - The stream is in maintenance mode. Updates are rejected on
  1729  	// the resource in this state.
  1730  	//   "FAILED" - The stream is experiencing an error that is preventing data
  1731  	// from being streamed.
  1732  	//   "FAILED_PERMANENTLY" - The stream has experienced a terminal failure.
  1733  	//   "STARTING" - The stream is starting, but not yet running.
  1734  	//   "DRAINING" - The Stream is no longer reading new events, but still writing
  1735  	// events in the buffer.
  1736  	State string `json:"state,omitempty"`
  1737  	// UpdateTime: Output only. The last update time of the stream.
  1738  	UpdateTime string `json:"updateTime,omitempty"`
  1739  
  1740  	// ServerResponse contains the HTTP response code and headers from the server.
  1741  	googleapi.ServerResponse `json:"-"`
  1742  	// ForceSendFields is a list of field names (e.g. "BackfillAll") to
  1743  	// unconditionally include in API requests. By default, fields with empty or
  1744  	// default values are omitted from API requests. See
  1745  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1746  	// details.
  1747  	ForceSendFields []string `json:"-"`
  1748  	// NullFields is a list of field names (e.g. "BackfillAll") to include in API
  1749  	// requests with the JSON null value. By default, fields with empty values are
  1750  	// omitted from API requests. See
  1751  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1752  	NullFields []string `json:"-"`
  1753  }
  1754  
  1755  func (s *Stream) MarshalJSON() ([]byte, error) {
  1756  	type NoMethod Stream
  1757  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1758  }
  1759  
  1760  // StreamObject: A specific stream object (e.g a specific DB table).
  1761  type StreamObject struct {
  1762  	// BackfillJob: The latest backfill job that was initiated for the stream
  1763  	// object.
  1764  	BackfillJob *BackfillJob `json:"backfillJob,omitempty"`
  1765  	// CreateTime: Output only. The creation time of the object.
  1766  	CreateTime string `json:"createTime,omitempty"`
  1767  	// DisplayName: Required. Display name.
  1768  	DisplayName string `json:"displayName,omitempty"`
  1769  	// Errors: Output only. Active errors on the object.
  1770  	Errors []*Error `json:"errors,omitempty"`
  1771  	// Name: Output only. The object's name.
  1772  	Name string `json:"name,omitempty"`
  1773  	// SourceObject: The object identifier in the data source.
  1774  	SourceObject *SourceObjectIdentifier `json:"sourceObject,omitempty"`
  1775  	// UpdateTime: Output only. The last update time of the object.
  1776  	UpdateTime string `json:"updateTime,omitempty"`
  1777  
  1778  	// ServerResponse contains the HTTP response code and headers from the server.
  1779  	googleapi.ServerResponse `json:"-"`
  1780  	// ForceSendFields is a list of field names (e.g. "BackfillJob") to
  1781  	// unconditionally include in API requests. By default, fields with empty or
  1782  	// default values are omitted from API requests. See
  1783  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1784  	// details.
  1785  	ForceSendFields []string `json:"-"`
  1786  	// NullFields is a list of field names (e.g. "BackfillJob") to include in API
  1787  	// requests with the JSON null value. By default, fields with empty values are
  1788  	// omitted from API requests. See
  1789  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1790  	NullFields []string `json:"-"`
  1791  }
  1792  
  1793  func (s *StreamObject) MarshalJSON() ([]byte, error) {
  1794  	type NoMethod StreamObject
  1795  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1796  }
  1797  
  1798  type Validation struct {
  1799  	// Code: A custom code identifying this validation.
  1800  	Code string `json:"code,omitempty"`
  1801  	// Description: A short description of the validation.
  1802  	Description string `json:"description,omitempty"`
  1803  	// Message: Messages reflecting the validation results.
  1804  	Message []*ValidationMessage `json:"message,omitempty"`
  1805  	// Status: Validation execution status.
  1806  	//
  1807  	// Possible values:
  1808  	//   "STATUS_UNSPECIFIED" - Unspecified status.
  1809  	//   "NOT_EXECUTED" - Validation did not execute.
  1810  	//   "FAILED" - Validation failed.
  1811  	//   "PASSED" - Validation passed.
  1812  	Status string `json:"status,omitempty"`
  1813  	// ForceSendFields is a list of field names (e.g. "Code") to unconditionally
  1814  	// include in API requests. By default, fields with empty or default values are
  1815  	// omitted from API requests. See
  1816  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1817  	// details.
  1818  	ForceSendFields []string `json:"-"`
  1819  	// NullFields is a list of field names (e.g. "Code") to include in API requests
  1820  	// with the JSON null value. By default, fields with empty values are omitted
  1821  	// from API requests. See
  1822  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1823  	NullFields []string `json:"-"`
  1824  }
  1825  
  1826  func (s *Validation) MarshalJSON() ([]byte, error) {
  1827  	type NoMethod Validation
  1828  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1829  }
  1830  
  1831  // ValidationMessage: Represent user-facing validation result message.
  1832  type ValidationMessage struct {
  1833  	// Code: A custom code identifying this specific message.
  1834  	Code string `json:"code,omitempty"`
  1835  	// Level: Message severity level (warning or error).
  1836  	//
  1837  	// Possible values:
  1838  	//   "LEVEL_UNSPECIFIED" - Unspecified level.
  1839  	//   "WARNING" - Potentially cause issues with the Stream.
  1840  	//   "ERROR" - Definitely cause issues with the Stream.
  1841  	Level string `json:"level,omitempty"`
  1842  	// Message: The result of the validation.
  1843  	Message string `json:"message,omitempty"`
  1844  	// Metadata: Additional metadata related to the result.
  1845  	Metadata map[string]string `json:"metadata,omitempty"`
  1846  	// ForceSendFields is a list of field names (e.g. "Code") to unconditionally
  1847  	// include in API requests. By default, fields with empty or default values are
  1848  	// omitted from API requests. See
  1849  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1850  	// details.
  1851  	ForceSendFields []string `json:"-"`
  1852  	// NullFields is a list of field names (e.g. "Code") to include in API requests
  1853  	// with the JSON null value. By default, fields with empty values are omitted
  1854  	// from API requests. See
  1855  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1856  	NullFields []string `json:"-"`
  1857  }
  1858  
  1859  func (s *ValidationMessage) MarshalJSON() ([]byte, error) {
  1860  	type NoMethod ValidationMessage
  1861  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1862  }
  1863  
  1864  // ValidationResult: Contains the current validation results.
  1865  type ValidationResult struct {
  1866  	// Validations: A list of validations (includes both executed as well as not
  1867  	// executed validations).
  1868  	Validations []*Validation `json:"validations,omitempty"`
  1869  	// ForceSendFields is a list of field names (e.g. "Validations") to
  1870  	// unconditionally include in API requests. By default, fields with empty or
  1871  	// default values are omitted from API requests. See
  1872  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1873  	// details.
  1874  	ForceSendFields []string `json:"-"`
  1875  	// NullFields is a list of field names (e.g. "Validations") to include in API
  1876  	// requests with the JSON null value. By default, fields with empty values are
  1877  	// omitted from API requests. See
  1878  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1879  	NullFields []string `json:"-"`
  1880  }
  1881  
  1882  func (s *ValidationResult) MarshalJSON() ([]byte, error) {
  1883  	type NoMethod ValidationResult
  1884  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1885  }
  1886  
  1887  // VpcPeeringConfig: The VPC Peering configuration is used to create VPC
  1888  // peering between Datastream and the consumer's VPC.
  1889  type VpcPeeringConfig struct {
  1890  	// Subnet: Required. A free subnet for peering. (CIDR of /29)
  1891  	Subnet string `json:"subnet,omitempty"`
  1892  	// VpcName: Required. fully qualified name of the VPC Datastream will peer to.
  1893  	VpcName string `json:"vpcName,omitempty"`
  1894  	// ForceSendFields is a list of field names (e.g. "Subnet") to unconditionally
  1895  	// include in API requests. By default, fields with empty or default values are
  1896  	// omitted from API requests. See
  1897  	// https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
  1898  	// details.
  1899  	ForceSendFields []string `json:"-"`
  1900  	// NullFields is a list of field names (e.g. "Subnet") to include in API
  1901  	// requests with the JSON null value. By default, fields with empty values are
  1902  	// omitted from API requests. See
  1903  	// https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
  1904  	NullFields []string `json:"-"`
  1905  }
  1906  
  1907  func (s *VpcPeeringConfig) MarshalJSON() ([]byte, error) {
  1908  	type NoMethod VpcPeeringConfig
  1909  	return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
  1910  }
  1911  
  1912  type ProjectsLocationsFetchStaticIpsCall struct {
  1913  	s            *Service
  1914  	name         string
  1915  	urlParams_   gensupport.URLParams
  1916  	ifNoneMatch_ string
  1917  	ctx_         context.Context
  1918  	header_      http.Header
  1919  }
  1920  
  1921  // FetchStaticIps: The FetchStaticIps API call exposes the static IP addresses
  1922  // used by Datastream.
  1923  //
  1924  //   - name: The name resource of the Response type. Must be in the format
  1925  //     `projects/*/locations/*`.
  1926  func (r *ProjectsLocationsService) FetchStaticIps(name string) *ProjectsLocationsFetchStaticIpsCall {
  1927  	c := &ProjectsLocationsFetchStaticIpsCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  1928  	c.name = name
  1929  	return c
  1930  }
  1931  
  1932  // PageSize sets the optional parameter "pageSize": Maximum number of Ips to
  1933  // return, will likely not be specified.
  1934  func (c *ProjectsLocationsFetchStaticIpsCall) PageSize(pageSize int64) *ProjectsLocationsFetchStaticIpsCall {
  1935  	c.urlParams_.Set("pageSize", fmt.Sprint(pageSize))
  1936  	return c
  1937  }
  1938  
  1939  // PageToken sets the optional parameter "pageToken": A page token, received
  1940  // from a previous `ListStaticIps` call. will likely not be specified.
  1941  func (c *ProjectsLocationsFetchStaticIpsCall) PageToken(pageToken string) *ProjectsLocationsFetchStaticIpsCall {
  1942  	c.urlParams_.Set("pageToken", pageToken)
  1943  	return c
  1944  }
  1945  
  1946  // Fields allows partial responses to be retrieved. See
  1947  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  1948  // details.
  1949  func (c *ProjectsLocationsFetchStaticIpsCall) Fields(s ...googleapi.Field) *ProjectsLocationsFetchStaticIpsCall {
  1950  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  1951  	return c
  1952  }
  1953  
  1954  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  1955  // object's ETag matches the given value. This is useful for getting updates
  1956  // only after the object has changed since the last request.
  1957  func (c *ProjectsLocationsFetchStaticIpsCall) IfNoneMatch(entityTag string) *ProjectsLocationsFetchStaticIpsCall {
  1958  	c.ifNoneMatch_ = entityTag
  1959  	return c
  1960  }
  1961  
  1962  // Context sets the context to be used in this call's Do method.
  1963  func (c *ProjectsLocationsFetchStaticIpsCall) Context(ctx context.Context) *ProjectsLocationsFetchStaticIpsCall {
  1964  	c.ctx_ = ctx
  1965  	return c
  1966  }
  1967  
  1968  // Header returns a http.Header that can be modified by the caller to add
  1969  // headers to the request.
  1970  func (c *ProjectsLocationsFetchStaticIpsCall) Header() http.Header {
  1971  	if c.header_ == nil {
  1972  		c.header_ = make(http.Header)
  1973  	}
  1974  	return c.header_
  1975  }
  1976  
  1977  func (c *ProjectsLocationsFetchStaticIpsCall) doRequest(alt string) (*http.Response, error) {
  1978  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  1979  	if c.ifNoneMatch_ != "" {
  1980  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  1981  	}
  1982  	var body io.Reader = nil
  1983  	c.urlParams_.Set("alt", alt)
  1984  	c.urlParams_.Set("prettyPrint", "false")
  1985  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+name}:fetchStaticIps")
  1986  	urls += "?" + c.urlParams_.Encode()
  1987  	req, err := http.NewRequest("GET", urls, body)
  1988  	if err != nil {
  1989  		return nil, err
  1990  	}
  1991  	req.Header = reqHeaders
  1992  	googleapi.Expand(req.URL, map[string]string{
  1993  		"name": c.name,
  1994  	})
  1995  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  1996  }
  1997  
  1998  // Do executes the "datastream.projects.locations.fetchStaticIps" call.
  1999  // Any non-2xx status code is an error. Response headers are in either
  2000  // *FetchStaticIpsResponse.ServerResponse.Header or (if a response was returned
  2001  // at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to
  2002  // check whether the returned error was because http.StatusNotModified was
  2003  // returned.
  2004  func (c *ProjectsLocationsFetchStaticIpsCall) Do(opts ...googleapi.CallOption) (*FetchStaticIpsResponse, error) {
  2005  	gensupport.SetOptions(c.urlParams_, opts...)
  2006  	res, err := c.doRequest("json")
  2007  	if res != nil && res.StatusCode == http.StatusNotModified {
  2008  		if res.Body != nil {
  2009  			res.Body.Close()
  2010  		}
  2011  		return nil, gensupport.WrapError(&googleapi.Error{
  2012  			Code:   res.StatusCode,
  2013  			Header: res.Header,
  2014  		})
  2015  	}
  2016  	if err != nil {
  2017  		return nil, err
  2018  	}
  2019  	defer googleapi.CloseBody(res)
  2020  	if err := googleapi.CheckResponse(res); err != nil {
  2021  		return nil, gensupport.WrapError(err)
  2022  	}
  2023  	ret := &FetchStaticIpsResponse{
  2024  		ServerResponse: googleapi.ServerResponse{
  2025  			Header:         res.Header,
  2026  			HTTPStatusCode: res.StatusCode,
  2027  		},
  2028  	}
  2029  	target := &ret
  2030  	if err := gensupport.DecodeResponse(target, res); err != nil {
  2031  		return nil, err
  2032  	}
  2033  	return ret, nil
  2034  }
  2035  
  2036  // Pages invokes f for each page of results.
  2037  // A non-nil error returned from f will halt the iteration.
  2038  // The provided context supersedes any context provided to the Context method.
  2039  func (c *ProjectsLocationsFetchStaticIpsCall) Pages(ctx context.Context, f func(*FetchStaticIpsResponse) error) error {
  2040  	c.ctx_ = ctx
  2041  	defer c.PageToken(c.urlParams_.Get("pageToken"))
  2042  	for {
  2043  		x, err := c.Do()
  2044  		if err != nil {
  2045  			return err
  2046  		}
  2047  		if err := f(x); err != nil {
  2048  			return err
  2049  		}
  2050  		if x.NextPageToken == "" {
  2051  			return nil
  2052  		}
  2053  		c.PageToken(x.NextPageToken)
  2054  	}
  2055  }
  2056  
  2057  type ProjectsLocationsGetCall struct {
  2058  	s            *Service
  2059  	name         string
  2060  	urlParams_   gensupport.URLParams
  2061  	ifNoneMatch_ string
  2062  	ctx_         context.Context
  2063  	header_      http.Header
  2064  }
  2065  
  2066  // Get: Gets information about a location.
  2067  //
  2068  // - name: Resource name for the location.
  2069  func (r *ProjectsLocationsService) Get(name string) *ProjectsLocationsGetCall {
  2070  	c := &ProjectsLocationsGetCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  2071  	c.name = name
  2072  	return c
  2073  }
  2074  
  2075  // Fields allows partial responses to be retrieved. See
  2076  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  2077  // details.
  2078  func (c *ProjectsLocationsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsGetCall {
  2079  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  2080  	return c
  2081  }
  2082  
  2083  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  2084  // object's ETag matches the given value. This is useful for getting updates
  2085  // only after the object has changed since the last request.
  2086  func (c *ProjectsLocationsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsGetCall {
  2087  	c.ifNoneMatch_ = entityTag
  2088  	return c
  2089  }
  2090  
  2091  // Context sets the context to be used in this call's Do method.
  2092  func (c *ProjectsLocationsGetCall) Context(ctx context.Context) *ProjectsLocationsGetCall {
  2093  	c.ctx_ = ctx
  2094  	return c
  2095  }
  2096  
  2097  // Header returns a http.Header that can be modified by the caller to add
  2098  // headers to the request.
  2099  func (c *ProjectsLocationsGetCall) Header() http.Header {
  2100  	if c.header_ == nil {
  2101  		c.header_ = make(http.Header)
  2102  	}
  2103  	return c.header_
  2104  }
  2105  
  2106  func (c *ProjectsLocationsGetCall) doRequest(alt string) (*http.Response, error) {
  2107  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  2108  	if c.ifNoneMatch_ != "" {
  2109  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  2110  	}
  2111  	var body io.Reader = nil
  2112  	c.urlParams_.Set("alt", alt)
  2113  	c.urlParams_.Set("prettyPrint", "false")
  2114  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+name}")
  2115  	urls += "?" + c.urlParams_.Encode()
  2116  	req, err := http.NewRequest("GET", urls, body)
  2117  	if err != nil {
  2118  		return nil, err
  2119  	}
  2120  	req.Header = reqHeaders
  2121  	googleapi.Expand(req.URL, map[string]string{
  2122  		"name": c.name,
  2123  	})
  2124  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  2125  }
  2126  
  2127  // Do executes the "datastream.projects.locations.get" call.
  2128  // Any non-2xx status code is an error. Response headers are in either
  2129  // *Location.ServerResponse.Header or (if a response was returned at all) in
  2130  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  2131  // whether the returned error was because http.StatusNotModified was returned.
  2132  func (c *ProjectsLocationsGetCall) Do(opts ...googleapi.CallOption) (*Location, error) {
  2133  	gensupport.SetOptions(c.urlParams_, opts...)
  2134  	res, err := c.doRequest("json")
  2135  	if res != nil && res.StatusCode == http.StatusNotModified {
  2136  		if res.Body != nil {
  2137  			res.Body.Close()
  2138  		}
  2139  		return nil, gensupport.WrapError(&googleapi.Error{
  2140  			Code:   res.StatusCode,
  2141  			Header: res.Header,
  2142  		})
  2143  	}
  2144  	if err != nil {
  2145  		return nil, err
  2146  	}
  2147  	defer googleapi.CloseBody(res)
  2148  	if err := googleapi.CheckResponse(res); err != nil {
  2149  		return nil, gensupport.WrapError(err)
  2150  	}
  2151  	ret := &Location{
  2152  		ServerResponse: googleapi.ServerResponse{
  2153  			Header:         res.Header,
  2154  			HTTPStatusCode: res.StatusCode,
  2155  		},
  2156  	}
  2157  	target := &ret
  2158  	if err := gensupport.DecodeResponse(target, res); err != nil {
  2159  		return nil, err
  2160  	}
  2161  	return ret, nil
  2162  }
  2163  
  2164  type ProjectsLocationsListCall struct {
  2165  	s            *Service
  2166  	name         string
  2167  	urlParams_   gensupport.URLParams
  2168  	ifNoneMatch_ string
  2169  	ctx_         context.Context
  2170  	header_      http.Header
  2171  }
  2172  
  2173  // List: Lists information about the supported locations for this service.
  2174  //
  2175  // - name: The resource that owns the locations collection, if applicable.
  2176  func (r *ProjectsLocationsService) List(name string) *ProjectsLocationsListCall {
  2177  	c := &ProjectsLocationsListCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  2178  	c.name = name
  2179  	return c
  2180  }
  2181  
  2182  // Filter sets the optional parameter "filter": A filter to narrow down results
  2183  // to a preferred subset. The filtering language accepts strings like
  2184  // "displayName=tokyo", and is documented in more detail in AIP-160
  2185  // (https://google.aip.dev/160).
  2186  func (c *ProjectsLocationsListCall) Filter(filter string) *ProjectsLocationsListCall {
  2187  	c.urlParams_.Set("filter", filter)
  2188  	return c
  2189  }
  2190  
  2191  // PageSize sets the optional parameter "pageSize": The maximum number of
  2192  // results to return. If not set, the service selects a default.
  2193  func (c *ProjectsLocationsListCall) PageSize(pageSize int64) *ProjectsLocationsListCall {
  2194  	c.urlParams_.Set("pageSize", fmt.Sprint(pageSize))
  2195  	return c
  2196  }
  2197  
  2198  // PageToken sets the optional parameter "pageToken": A page token received
  2199  // from the `next_page_token` field in the response. Send that page token to
  2200  // receive the subsequent page.
  2201  func (c *ProjectsLocationsListCall) PageToken(pageToken string) *ProjectsLocationsListCall {
  2202  	c.urlParams_.Set("pageToken", pageToken)
  2203  	return c
  2204  }
  2205  
  2206  // Fields allows partial responses to be retrieved. See
  2207  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  2208  // details.
  2209  func (c *ProjectsLocationsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsListCall {
  2210  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  2211  	return c
  2212  }
  2213  
  2214  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  2215  // object's ETag matches the given value. This is useful for getting updates
  2216  // only after the object has changed since the last request.
  2217  func (c *ProjectsLocationsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsListCall {
  2218  	c.ifNoneMatch_ = entityTag
  2219  	return c
  2220  }
  2221  
  2222  // Context sets the context to be used in this call's Do method.
  2223  func (c *ProjectsLocationsListCall) Context(ctx context.Context) *ProjectsLocationsListCall {
  2224  	c.ctx_ = ctx
  2225  	return c
  2226  }
  2227  
  2228  // Header returns a http.Header that can be modified by the caller to add
  2229  // headers to the request.
  2230  func (c *ProjectsLocationsListCall) Header() http.Header {
  2231  	if c.header_ == nil {
  2232  		c.header_ = make(http.Header)
  2233  	}
  2234  	return c.header_
  2235  }
  2236  
  2237  func (c *ProjectsLocationsListCall) doRequest(alt string) (*http.Response, error) {
  2238  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  2239  	if c.ifNoneMatch_ != "" {
  2240  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  2241  	}
  2242  	var body io.Reader = nil
  2243  	c.urlParams_.Set("alt", alt)
  2244  	c.urlParams_.Set("prettyPrint", "false")
  2245  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+name}/locations")
  2246  	urls += "?" + c.urlParams_.Encode()
  2247  	req, err := http.NewRequest("GET", urls, body)
  2248  	if err != nil {
  2249  		return nil, err
  2250  	}
  2251  	req.Header = reqHeaders
  2252  	googleapi.Expand(req.URL, map[string]string{
  2253  		"name": c.name,
  2254  	})
  2255  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  2256  }
  2257  
  2258  // Do executes the "datastream.projects.locations.list" call.
  2259  // Any non-2xx status code is an error. Response headers are in either
  2260  // *ListLocationsResponse.ServerResponse.Header or (if a response was returned
  2261  // at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to
  2262  // check whether the returned error was because http.StatusNotModified was
  2263  // returned.
  2264  func (c *ProjectsLocationsListCall) Do(opts ...googleapi.CallOption) (*ListLocationsResponse, error) {
  2265  	gensupport.SetOptions(c.urlParams_, opts...)
  2266  	res, err := c.doRequest("json")
  2267  	if res != nil && res.StatusCode == http.StatusNotModified {
  2268  		if res.Body != nil {
  2269  			res.Body.Close()
  2270  		}
  2271  		return nil, gensupport.WrapError(&googleapi.Error{
  2272  			Code:   res.StatusCode,
  2273  			Header: res.Header,
  2274  		})
  2275  	}
  2276  	if err != nil {
  2277  		return nil, err
  2278  	}
  2279  	defer googleapi.CloseBody(res)
  2280  	if err := googleapi.CheckResponse(res); err != nil {
  2281  		return nil, gensupport.WrapError(err)
  2282  	}
  2283  	ret := &ListLocationsResponse{
  2284  		ServerResponse: googleapi.ServerResponse{
  2285  			Header:         res.Header,
  2286  			HTTPStatusCode: res.StatusCode,
  2287  		},
  2288  	}
  2289  	target := &ret
  2290  	if err := gensupport.DecodeResponse(target, res); err != nil {
  2291  		return nil, err
  2292  	}
  2293  	return ret, nil
  2294  }
  2295  
  2296  // Pages invokes f for each page of results.
  2297  // A non-nil error returned from f will halt the iteration.
  2298  // The provided context supersedes any context provided to the Context method.
  2299  func (c *ProjectsLocationsListCall) Pages(ctx context.Context, f func(*ListLocationsResponse) error) error {
  2300  	c.ctx_ = ctx
  2301  	defer c.PageToken(c.urlParams_.Get("pageToken"))
  2302  	for {
  2303  		x, err := c.Do()
  2304  		if err != nil {
  2305  			return err
  2306  		}
  2307  		if err := f(x); err != nil {
  2308  			return err
  2309  		}
  2310  		if x.NextPageToken == "" {
  2311  			return nil
  2312  		}
  2313  		c.PageToken(x.NextPageToken)
  2314  	}
  2315  }
  2316  
  2317  type ProjectsLocationsConnectionProfilesCreateCall struct {
  2318  	s                 *Service
  2319  	parent            string
  2320  	connectionprofile *ConnectionProfile
  2321  	urlParams_        gensupport.URLParams
  2322  	ctx_              context.Context
  2323  	header_           http.Header
  2324  }
  2325  
  2326  // Create: Use this method to create a connection profile in a project and
  2327  // location.
  2328  //
  2329  // - parent: The parent that owns the collection of ConnectionProfiles.
  2330  func (r *ProjectsLocationsConnectionProfilesService) Create(parent string, connectionprofile *ConnectionProfile) *ProjectsLocationsConnectionProfilesCreateCall {
  2331  	c := &ProjectsLocationsConnectionProfilesCreateCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  2332  	c.parent = parent
  2333  	c.connectionprofile = connectionprofile
  2334  	return c
  2335  }
  2336  
  2337  // ConnectionProfileId sets the optional parameter "connectionProfileId":
  2338  // Required. The connection profile identifier.
  2339  func (c *ProjectsLocationsConnectionProfilesCreateCall) ConnectionProfileId(connectionProfileId string) *ProjectsLocationsConnectionProfilesCreateCall {
  2340  	c.urlParams_.Set("connectionProfileId", connectionProfileId)
  2341  	return c
  2342  }
  2343  
  2344  // RequestId sets the optional parameter "requestId": A request ID to identify
  2345  // requests. Specify a unique request ID so that if you must retry your
  2346  // request, the server will know to ignore the request if it has already been
  2347  // completed. The server will guarantee that for at least 60 minutes since the
  2348  // first request. For example, consider a situation where you make an initial
  2349  // request and the request times out. If you make the request again with the
  2350  // same request ID, the server can check if original operation with the same
  2351  // request ID was received, and if so, will ignore the second request. This
  2352  // prevents clients from accidentally creating duplicate commitments. The
  2353  // request ID must be a valid UUID with the exception that zero UUID is not
  2354  // supported (00000000-0000-0000-0000-000000000000).
  2355  func (c *ProjectsLocationsConnectionProfilesCreateCall) RequestId(requestId string) *ProjectsLocationsConnectionProfilesCreateCall {
  2356  	c.urlParams_.Set("requestId", requestId)
  2357  	return c
  2358  }
  2359  
  2360  // Fields allows partial responses to be retrieved. See
  2361  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  2362  // details.
  2363  func (c *ProjectsLocationsConnectionProfilesCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesCreateCall {
  2364  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  2365  	return c
  2366  }
  2367  
  2368  // Context sets the context to be used in this call's Do method.
  2369  func (c *ProjectsLocationsConnectionProfilesCreateCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesCreateCall {
  2370  	c.ctx_ = ctx
  2371  	return c
  2372  }
  2373  
  2374  // Header returns a http.Header that can be modified by the caller to add
  2375  // headers to the request.
  2376  func (c *ProjectsLocationsConnectionProfilesCreateCall) Header() http.Header {
  2377  	if c.header_ == nil {
  2378  		c.header_ = make(http.Header)
  2379  	}
  2380  	return c.header_
  2381  }
  2382  
  2383  func (c *ProjectsLocationsConnectionProfilesCreateCall) doRequest(alt string) (*http.Response, error) {
  2384  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
  2385  	var body io.Reader = nil
  2386  	body, err := googleapi.WithoutDataWrapper.JSONReader(c.connectionprofile)
  2387  	if err != nil {
  2388  		return nil, err
  2389  	}
  2390  	c.urlParams_.Set("alt", alt)
  2391  	c.urlParams_.Set("prettyPrint", "false")
  2392  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+parent}/connectionProfiles")
  2393  	urls += "?" + c.urlParams_.Encode()
  2394  	req, err := http.NewRequest("POST", urls, body)
  2395  	if err != nil {
  2396  		return nil, err
  2397  	}
  2398  	req.Header = reqHeaders
  2399  	googleapi.Expand(req.URL, map[string]string{
  2400  		"parent": c.parent,
  2401  	})
  2402  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  2403  }
  2404  
  2405  // Do executes the "datastream.projects.locations.connectionProfiles.create" call.
  2406  // Any non-2xx status code is an error. Response headers are in either
  2407  // *Operation.ServerResponse.Header or (if a response was returned at all) in
  2408  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  2409  // whether the returned error was because http.StatusNotModified was returned.
  2410  func (c *ProjectsLocationsConnectionProfilesCreateCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
  2411  	gensupport.SetOptions(c.urlParams_, opts...)
  2412  	res, err := c.doRequest("json")
  2413  	if res != nil && res.StatusCode == http.StatusNotModified {
  2414  		if res.Body != nil {
  2415  			res.Body.Close()
  2416  		}
  2417  		return nil, gensupport.WrapError(&googleapi.Error{
  2418  			Code:   res.StatusCode,
  2419  			Header: res.Header,
  2420  		})
  2421  	}
  2422  	if err != nil {
  2423  		return nil, err
  2424  	}
  2425  	defer googleapi.CloseBody(res)
  2426  	if err := googleapi.CheckResponse(res); err != nil {
  2427  		return nil, gensupport.WrapError(err)
  2428  	}
  2429  	ret := &Operation{
  2430  		ServerResponse: googleapi.ServerResponse{
  2431  			Header:         res.Header,
  2432  			HTTPStatusCode: res.StatusCode,
  2433  		},
  2434  	}
  2435  	target := &ret
  2436  	if err := gensupport.DecodeResponse(target, res); err != nil {
  2437  		return nil, err
  2438  	}
  2439  	return ret, nil
  2440  }
  2441  
  2442  type ProjectsLocationsConnectionProfilesDeleteCall struct {
  2443  	s          *Service
  2444  	name       string
  2445  	urlParams_ gensupport.URLParams
  2446  	ctx_       context.Context
  2447  	header_    http.Header
  2448  }
  2449  
  2450  // Delete: Use this method to delete a connection profile..
  2451  //
  2452  // - name: The name of the connection profile resource to delete.
  2453  func (r *ProjectsLocationsConnectionProfilesService) Delete(name string) *ProjectsLocationsConnectionProfilesDeleteCall {
  2454  	c := &ProjectsLocationsConnectionProfilesDeleteCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  2455  	c.name = name
  2456  	return c
  2457  }
  2458  
  2459  // RequestId sets the optional parameter "requestId": A request ID to identify
  2460  // requests. Specify a unique request ID so that if you must retry your
  2461  // request, the server will know to ignore the request if it has already been
  2462  // completed. The server will guarantee that for at least 60 minutes after the
  2463  // first request. For example, consider a situation where you make an initial
  2464  // request and the request times out. If you make the request again with the
  2465  // same request ID, the server can check if original operation with the same
  2466  // request ID was received, and if so, will ignore the second request. This
  2467  // prevents clients from accidentally creating duplicate commitments. The
  2468  // request ID must be a valid UUID with the exception that zero UUID is not
  2469  // supported (00000000-0000-0000-0000-000000000000).
  2470  func (c *ProjectsLocationsConnectionProfilesDeleteCall) RequestId(requestId string) *ProjectsLocationsConnectionProfilesDeleteCall {
  2471  	c.urlParams_.Set("requestId", requestId)
  2472  	return c
  2473  }
  2474  
  2475  // Fields allows partial responses to be retrieved. See
  2476  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  2477  // details.
  2478  func (c *ProjectsLocationsConnectionProfilesDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesDeleteCall {
  2479  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  2480  	return c
  2481  }
  2482  
  2483  // Context sets the context to be used in this call's Do method.
  2484  func (c *ProjectsLocationsConnectionProfilesDeleteCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesDeleteCall {
  2485  	c.ctx_ = ctx
  2486  	return c
  2487  }
  2488  
  2489  // Header returns a http.Header that can be modified by the caller to add
  2490  // headers to the request.
  2491  func (c *ProjectsLocationsConnectionProfilesDeleteCall) Header() http.Header {
  2492  	if c.header_ == nil {
  2493  		c.header_ = make(http.Header)
  2494  	}
  2495  	return c.header_
  2496  }
  2497  
  2498  func (c *ProjectsLocationsConnectionProfilesDeleteCall) doRequest(alt string) (*http.Response, error) {
  2499  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  2500  	var body io.Reader = nil
  2501  	c.urlParams_.Set("alt", alt)
  2502  	c.urlParams_.Set("prettyPrint", "false")
  2503  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+name}")
  2504  	urls += "?" + c.urlParams_.Encode()
  2505  	req, err := http.NewRequest("DELETE", urls, body)
  2506  	if err != nil {
  2507  		return nil, err
  2508  	}
  2509  	req.Header = reqHeaders
  2510  	googleapi.Expand(req.URL, map[string]string{
  2511  		"name": c.name,
  2512  	})
  2513  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  2514  }
  2515  
  2516  // Do executes the "datastream.projects.locations.connectionProfiles.delete" call.
  2517  // Any non-2xx status code is an error. Response headers are in either
  2518  // *Operation.ServerResponse.Header or (if a response was returned at all) in
  2519  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  2520  // whether the returned error was because http.StatusNotModified was returned.
  2521  func (c *ProjectsLocationsConnectionProfilesDeleteCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
  2522  	gensupport.SetOptions(c.urlParams_, opts...)
  2523  	res, err := c.doRequest("json")
  2524  	if res != nil && res.StatusCode == http.StatusNotModified {
  2525  		if res.Body != nil {
  2526  			res.Body.Close()
  2527  		}
  2528  		return nil, gensupport.WrapError(&googleapi.Error{
  2529  			Code:   res.StatusCode,
  2530  			Header: res.Header,
  2531  		})
  2532  	}
  2533  	if err != nil {
  2534  		return nil, err
  2535  	}
  2536  	defer googleapi.CloseBody(res)
  2537  	if err := googleapi.CheckResponse(res); err != nil {
  2538  		return nil, gensupport.WrapError(err)
  2539  	}
  2540  	ret := &Operation{
  2541  		ServerResponse: googleapi.ServerResponse{
  2542  			Header:         res.Header,
  2543  			HTTPStatusCode: res.StatusCode,
  2544  		},
  2545  	}
  2546  	target := &ret
  2547  	if err := gensupport.DecodeResponse(target, res); err != nil {
  2548  		return nil, err
  2549  	}
  2550  	return ret, nil
  2551  }
  2552  
  2553  type ProjectsLocationsConnectionProfilesDiscoverCall struct {
  2554  	s                                *Service
  2555  	parent                           string
  2556  	discoverconnectionprofilerequest *DiscoverConnectionProfileRequest
  2557  	urlParams_                       gensupport.URLParams
  2558  	ctx_                             context.Context
  2559  	header_                          http.Header
  2560  }
  2561  
  2562  // Discover: Use this method to discover a connection profile. The discover API
  2563  // call exposes the data objects and metadata belonging to the profile.
  2564  // Typically, a request returns children data objects under a parent data
  2565  // object that's optionally supplied in the request.
  2566  //
  2567  //   - parent: The parent resource of the ConnectionProfile type. Must be in the
  2568  //     format `projects/*/locations/*`.
  2569  func (r *ProjectsLocationsConnectionProfilesService) Discover(parent string, discoverconnectionprofilerequest *DiscoverConnectionProfileRequest) *ProjectsLocationsConnectionProfilesDiscoverCall {
  2570  	c := &ProjectsLocationsConnectionProfilesDiscoverCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  2571  	c.parent = parent
  2572  	c.discoverconnectionprofilerequest = discoverconnectionprofilerequest
  2573  	return c
  2574  }
  2575  
  2576  // Fields allows partial responses to be retrieved. See
  2577  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  2578  // details.
  2579  func (c *ProjectsLocationsConnectionProfilesDiscoverCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesDiscoverCall {
  2580  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  2581  	return c
  2582  }
  2583  
  2584  // Context sets the context to be used in this call's Do method.
  2585  func (c *ProjectsLocationsConnectionProfilesDiscoverCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesDiscoverCall {
  2586  	c.ctx_ = ctx
  2587  	return c
  2588  }
  2589  
  2590  // Header returns a http.Header that can be modified by the caller to add
  2591  // headers to the request.
  2592  func (c *ProjectsLocationsConnectionProfilesDiscoverCall) Header() http.Header {
  2593  	if c.header_ == nil {
  2594  		c.header_ = make(http.Header)
  2595  	}
  2596  	return c.header_
  2597  }
  2598  
  2599  func (c *ProjectsLocationsConnectionProfilesDiscoverCall) doRequest(alt string) (*http.Response, error) {
  2600  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
  2601  	var body io.Reader = nil
  2602  	body, err := googleapi.WithoutDataWrapper.JSONReader(c.discoverconnectionprofilerequest)
  2603  	if err != nil {
  2604  		return nil, err
  2605  	}
  2606  	c.urlParams_.Set("alt", alt)
  2607  	c.urlParams_.Set("prettyPrint", "false")
  2608  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+parent}/connectionProfiles:discover")
  2609  	urls += "?" + c.urlParams_.Encode()
  2610  	req, err := http.NewRequest("POST", urls, body)
  2611  	if err != nil {
  2612  		return nil, err
  2613  	}
  2614  	req.Header = reqHeaders
  2615  	googleapi.Expand(req.URL, map[string]string{
  2616  		"parent": c.parent,
  2617  	})
  2618  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  2619  }
  2620  
  2621  // Do executes the "datastream.projects.locations.connectionProfiles.discover" call.
  2622  // Any non-2xx status code is an error. Response headers are in either
  2623  // *DiscoverConnectionProfileResponse.ServerResponse.Header or (if a response
  2624  // was returned at all) in error.(*googleapi.Error).Header. Use
  2625  // googleapi.IsNotModified to check whether the returned error was because
  2626  // http.StatusNotModified was returned.
  2627  func (c *ProjectsLocationsConnectionProfilesDiscoverCall) Do(opts ...googleapi.CallOption) (*DiscoverConnectionProfileResponse, error) {
  2628  	gensupport.SetOptions(c.urlParams_, opts...)
  2629  	res, err := c.doRequest("json")
  2630  	if res != nil && res.StatusCode == http.StatusNotModified {
  2631  		if res.Body != nil {
  2632  			res.Body.Close()
  2633  		}
  2634  		return nil, gensupport.WrapError(&googleapi.Error{
  2635  			Code:   res.StatusCode,
  2636  			Header: res.Header,
  2637  		})
  2638  	}
  2639  	if err != nil {
  2640  		return nil, err
  2641  	}
  2642  	defer googleapi.CloseBody(res)
  2643  	if err := googleapi.CheckResponse(res); err != nil {
  2644  		return nil, gensupport.WrapError(err)
  2645  	}
  2646  	ret := &DiscoverConnectionProfileResponse{
  2647  		ServerResponse: googleapi.ServerResponse{
  2648  			Header:         res.Header,
  2649  			HTTPStatusCode: res.StatusCode,
  2650  		},
  2651  	}
  2652  	target := &ret
  2653  	if err := gensupport.DecodeResponse(target, res); err != nil {
  2654  		return nil, err
  2655  	}
  2656  	return ret, nil
  2657  }
  2658  
  2659  type ProjectsLocationsConnectionProfilesGetCall struct {
  2660  	s            *Service
  2661  	name         string
  2662  	urlParams_   gensupport.URLParams
  2663  	ifNoneMatch_ string
  2664  	ctx_         context.Context
  2665  	header_      http.Header
  2666  }
  2667  
  2668  // Get: Use this method to get details about a connection profile.
  2669  //
  2670  // - name: The name of the connection profile resource to get.
  2671  func (r *ProjectsLocationsConnectionProfilesService) Get(name string) *ProjectsLocationsConnectionProfilesGetCall {
  2672  	c := &ProjectsLocationsConnectionProfilesGetCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  2673  	c.name = name
  2674  	return c
  2675  }
  2676  
  2677  // Fields allows partial responses to be retrieved. See
  2678  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  2679  // details.
  2680  func (c *ProjectsLocationsConnectionProfilesGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesGetCall {
  2681  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  2682  	return c
  2683  }
  2684  
  2685  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  2686  // object's ETag matches the given value. This is useful for getting updates
  2687  // only after the object has changed since the last request.
  2688  func (c *ProjectsLocationsConnectionProfilesGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsConnectionProfilesGetCall {
  2689  	c.ifNoneMatch_ = entityTag
  2690  	return c
  2691  }
  2692  
  2693  // Context sets the context to be used in this call's Do method.
  2694  func (c *ProjectsLocationsConnectionProfilesGetCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesGetCall {
  2695  	c.ctx_ = ctx
  2696  	return c
  2697  }
  2698  
  2699  // Header returns a http.Header that can be modified by the caller to add
  2700  // headers to the request.
  2701  func (c *ProjectsLocationsConnectionProfilesGetCall) Header() http.Header {
  2702  	if c.header_ == nil {
  2703  		c.header_ = make(http.Header)
  2704  	}
  2705  	return c.header_
  2706  }
  2707  
  2708  func (c *ProjectsLocationsConnectionProfilesGetCall) doRequest(alt string) (*http.Response, error) {
  2709  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  2710  	if c.ifNoneMatch_ != "" {
  2711  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  2712  	}
  2713  	var body io.Reader = nil
  2714  	c.urlParams_.Set("alt", alt)
  2715  	c.urlParams_.Set("prettyPrint", "false")
  2716  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+name}")
  2717  	urls += "?" + c.urlParams_.Encode()
  2718  	req, err := http.NewRequest("GET", urls, body)
  2719  	if err != nil {
  2720  		return nil, err
  2721  	}
  2722  	req.Header = reqHeaders
  2723  	googleapi.Expand(req.URL, map[string]string{
  2724  		"name": c.name,
  2725  	})
  2726  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  2727  }
  2728  
  2729  // Do executes the "datastream.projects.locations.connectionProfiles.get" call.
  2730  // Any non-2xx status code is an error. Response headers are in either
  2731  // *ConnectionProfile.ServerResponse.Header or (if a response was returned at
  2732  // all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to
  2733  // check whether the returned error was because http.StatusNotModified was
  2734  // returned.
  2735  func (c *ProjectsLocationsConnectionProfilesGetCall) Do(opts ...googleapi.CallOption) (*ConnectionProfile, error) {
  2736  	gensupport.SetOptions(c.urlParams_, opts...)
  2737  	res, err := c.doRequest("json")
  2738  	if res != nil && res.StatusCode == http.StatusNotModified {
  2739  		if res.Body != nil {
  2740  			res.Body.Close()
  2741  		}
  2742  		return nil, gensupport.WrapError(&googleapi.Error{
  2743  			Code:   res.StatusCode,
  2744  			Header: res.Header,
  2745  		})
  2746  	}
  2747  	if err != nil {
  2748  		return nil, err
  2749  	}
  2750  	defer googleapi.CloseBody(res)
  2751  	if err := googleapi.CheckResponse(res); err != nil {
  2752  		return nil, gensupport.WrapError(err)
  2753  	}
  2754  	ret := &ConnectionProfile{
  2755  		ServerResponse: googleapi.ServerResponse{
  2756  			Header:         res.Header,
  2757  			HTTPStatusCode: res.StatusCode,
  2758  		},
  2759  	}
  2760  	target := &ret
  2761  	if err := gensupport.DecodeResponse(target, res); err != nil {
  2762  		return nil, err
  2763  	}
  2764  	return ret, nil
  2765  }
  2766  
  2767  type ProjectsLocationsConnectionProfilesListCall struct {
  2768  	s            *Service
  2769  	parent       string
  2770  	urlParams_   gensupport.URLParams
  2771  	ifNoneMatch_ string
  2772  	ctx_         context.Context
  2773  	header_      http.Header
  2774  }
  2775  
  2776  // List: Use this method to list connection profiles created in a project and
  2777  // location.
  2778  //
  2779  // - parent: The parent that owns the collection of connection profiles.
  2780  func (r *ProjectsLocationsConnectionProfilesService) List(parent string) *ProjectsLocationsConnectionProfilesListCall {
  2781  	c := &ProjectsLocationsConnectionProfilesListCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  2782  	c.parent = parent
  2783  	return c
  2784  }
  2785  
  2786  // Filter sets the optional parameter "filter": Filter request.
  2787  func (c *ProjectsLocationsConnectionProfilesListCall) Filter(filter string) *ProjectsLocationsConnectionProfilesListCall {
  2788  	c.urlParams_.Set("filter", filter)
  2789  	return c
  2790  }
  2791  
  2792  // OrderBy sets the optional parameter "orderBy": Order by fields for the
  2793  // result.
  2794  func (c *ProjectsLocationsConnectionProfilesListCall) OrderBy(orderBy string) *ProjectsLocationsConnectionProfilesListCall {
  2795  	c.urlParams_.Set("orderBy", orderBy)
  2796  	return c
  2797  }
  2798  
  2799  // PageSize sets the optional parameter "pageSize": Maximum number of
  2800  // connection profiles to return. If unspecified, at most 50 connection
  2801  // profiles will be returned. The maximum value is 1000; values above 1000 will
  2802  // be coerced to 1000.
  2803  func (c *ProjectsLocationsConnectionProfilesListCall) PageSize(pageSize int64) *ProjectsLocationsConnectionProfilesListCall {
  2804  	c.urlParams_.Set("pageSize", fmt.Sprint(pageSize))
  2805  	return c
  2806  }
  2807  
  2808  // PageToken sets the optional parameter "pageToken": Page token received from
  2809  // a previous `ListConnectionProfiles` call. Provide this to retrieve the
  2810  // subsequent page. When paginating, all other parameters provided to
  2811  // `ListConnectionProfiles` must match the call that provided the page token.
  2812  func (c *ProjectsLocationsConnectionProfilesListCall) PageToken(pageToken string) *ProjectsLocationsConnectionProfilesListCall {
  2813  	c.urlParams_.Set("pageToken", pageToken)
  2814  	return c
  2815  }
  2816  
  2817  // Fields allows partial responses to be retrieved. See
  2818  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  2819  // details.
  2820  func (c *ProjectsLocationsConnectionProfilesListCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesListCall {
  2821  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  2822  	return c
  2823  }
  2824  
  2825  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  2826  // object's ETag matches the given value. This is useful for getting updates
  2827  // only after the object has changed since the last request.
  2828  func (c *ProjectsLocationsConnectionProfilesListCall) IfNoneMatch(entityTag string) *ProjectsLocationsConnectionProfilesListCall {
  2829  	c.ifNoneMatch_ = entityTag
  2830  	return c
  2831  }
  2832  
  2833  // Context sets the context to be used in this call's Do method.
  2834  func (c *ProjectsLocationsConnectionProfilesListCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesListCall {
  2835  	c.ctx_ = ctx
  2836  	return c
  2837  }
  2838  
  2839  // Header returns a http.Header that can be modified by the caller to add
  2840  // headers to the request.
  2841  func (c *ProjectsLocationsConnectionProfilesListCall) Header() http.Header {
  2842  	if c.header_ == nil {
  2843  		c.header_ = make(http.Header)
  2844  	}
  2845  	return c.header_
  2846  }
  2847  
  2848  func (c *ProjectsLocationsConnectionProfilesListCall) doRequest(alt string) (*http.Response, error) {
  2849  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  2850  	if c.ifNoneMatch_ != "" {
  2851  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  2852  	}
  2853  	var body io.Reader = nil
  2854  	c.urlParams_.Set("alt", alt)
  2855  	c.urlParams_.Set("prettyPrint", "false")
  2856  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+parent}/connectionProfiles")
  2857  	urls += "?" + c.urlParams_.Encode()
  2858  	req, err := http.NewRequest("GET", urls, body)
  2859  	if err != nil {
  2860  		return nil, err
  2861  	}
  2862  	req.Header = reqHeaders
  2863  	googleapi.Expand(req.URL, map[string]string{
  2864  		"parent": c.parent,
  2865  	})
  2866  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  2867  }
  2868  
  2869  // Do executes the "datastream.projects.locations.connectionProfiles.list" call.
  2870  // Any non-2xx status code is an error. Response headers are in either
  2871  // *ListConnectionProfilesResponse.ServerResponse.Header or (if a response was
  2872  // returned at all) in error.(*googleapi.Error).Header. Use
  2873  // googleapi.IsNotModified to check whether the returned error was because
  2874  // http.StatusNotModified was returned.
  2875  func (c *ProjectsLocationsConnectionProfilesListCall) Do(opts ...googleapi.CallOption) (*ListConnectionProfilesResponse, error) {
  2876  	gensupport.SetOptions(c.urlParams_, opts...)
  2877  	res, err := c.doRequest("json")
  2878  	if res != nil && res.StatusCode == http.StatusNotModified {
  2879  		if res.Body != nil {
  2880  			res.Body.Close()
  2881  		}
  2882  		return nil, gensupport.WrapError(&googleapi.Error{
  2883  			Code:   res.StatusCode,
  2884  			Header: res.Header,
  2885  		})
  2886  	}
  2887  	if err != nil {
  2888  		return nil, err
  2889  	}
  2890  	defer googleapi.CloseBody(res)
  2891  	if err := googleapi.CheckResponse(res); err != nil {
  2892  		return nil, gensupport.WrapError(err)
  2893  	}
  2894  	ret := &ListConnectionProfilesResponse{
  2895  		ServerResponse: googleapi.ServerResponse{
  2896  			Header:         res.Header,
  2897  			HTTPStatusCode: res.StatusCode,
  2898  		},
  2899  	}
  2900  	target := &ret
  2901  	if err := gensupport.DecodeResponse(target, res); err != nil {
  2902  		return nil, err
  2903  	}
  2904  	return ret, nil
  2905  }
  2906  
  2907  // Pages invokes f for each page of results.
  2908  // A non-nil error returned from f will halt the iteration.
  2909  // The provided context supersedes any context provided to the Context method.
  2910  func (c *ProjectsLocationsConnectionProfilesListCall) Pages(ctx context.Context, f func(*ListConnectionProfilesResponse) error) error {
  2911  	c.ctx_ = ctx
  2912  	defer c.PageToken(c.urlParams_.Get("pageToken"))
  2913  	for {
  2914  		x, err := c.Do()
  2915  		if err != nil {
  2916  			return err
  2917  		}
  2918  		if err := f(x); err != nil {
  2919  			return err
  2920  		}
  2921  		if x.NextPageToken == "" {
  2922  			return nil
  2923  		}
  2924  		c.PageToken(x.NextPageToken)
  2925  	}
  2926  }
  2927  
  2928  type ProjectsLocationsConnectionProfilesPatchCall struct {
  2929  	s                 *Service
  2930  	name              string
  2931  	connectionprofile *ConnectionProfile
  2932  	urlParams_        gensupport.URLParams
  2933  	ctx_              context.Context
  2934  	header_           http.Header
  2935  }
  2936  
  2937  // Patch: Use this method to update the parameters of a connection profile.
  2938  //
  2939  // - name: Output only. The resource's name.
  2940  func (r *ProjectsLocationsConnectionProfilesService) Patch(name string, connectionprofile *ConnectionProfile) *ProjectsLocationsConnectionProfilesPatchCall {
  2941  	c := &ProjectsLocationsConnectionProfilesPatchCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  2942  	c.name = name
  2943  	c.connectionprofile = connectionprofile
  2944  	return c
  2945  }
  2946  
  2947  // RequestId sets the optional parameter "requestId": A request ID to identify
  2948  // requests. Specify a unique request ID so that if you must retry your
  2949  // request, the server will know to ignore the request if it has already been
  2950  // completed. The server will guarantee that for at least 60 minutes since the
  2951  // first request. For example, consider a situation where you make an initial
  2952  // request and the request times out. If you make the request again with the
  2953  // same request ID, the server can check if original operation with the same
  2954  // request ID was received, and if so, will ignore the second request. This
  2955  // prevents clients from accidentally creating duplicate commitments. The
  2956  // request ID must be a valid UUID with the exception that zero UUID is not
  2957  // supported (00000000-0000-0000-0000-000000000000).
  2958  func (c *ProjectsLocationsConnectionProfilesPatchCall) RequestId(requestId string) *ProjectsLocationsConnectionProfilesPatchCall {
  2959  	c.urlParams_.Set("requestId", requestId)
  2960  	return c
  2961  }
  2962  
  2963  // UpdateMask sets the optional parameter "updateMask": Field mask is used to
  2964  // specify the fields to be overwritten in the ConnectionProfile resource by
  2965  // the update. The fields specified in the update_mask are relative to the
  2966  // resource, not the full request. A field will be overwritten if it is in the
  2967  // mask. If the user does not provide a mask then all fields will be
  2968  // overwritten.
  2969  func (c *ProjectsLocationsConnectionProfilesPatchCall) UpdateMask(updateMask string) *ProjectsLocationsConnectionProfilesPatchCall {
  2970  	c.urlParams_.Set("updateMask", updateMask)
  2971  	return c
  2972  }
  2973  
  2974  // ValidateOnly sets the optional parameter "validateOnly": Only validate the
  2975  // connection profile, but do not update any resources. The default is false.
  2976  func (c *ProjectsLocationsConnectionProfilesPatchCall) ValidateOnly(validateOnly bool) *ProjectsLocationsConnectionProfilesPatchCall {
  2977  	c.urlParams_.Set("validateOnly", fmt.Sprint(validateOnly))
  2978  	return c
  2979  }
  2980  
  2981  // Fields allows partial responses to be retrieved. See
  2982  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  2983  // details.
  2984  func (c *ProjectsLocationsConnectionProfilesPatchCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesPatchCall {
  2985  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  2986  	return c
  2987  }
  2988  
  2989  // Context sets the context to be used in this call's Do method.
  2990  func (c *ProjectsLocationsConnectionProfilesPatchCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesPatchCall {
  2991  	c.ctx_ = ctx
  2992  	return c
  2993  }
  2994  
  2995  // Header returns a http.Header that can be modified by the caller to add
  2996  // headers to the request.
  2997  func (c *ProjectsLocationsConnectionProfilesPatchCall) Header() http.Header {
  2998  	if c.header_ == nil {
  2999  		c.header_ = make(http.Header)
  3000  	}
  3001  	return c.header_
  3002  }
  3003  
  3004  func (c *ProjectsLocationsConnectionProfilesPatchCall) doRequest(alt string) (*http.Response, error) {
  3005  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
  3006  	var body io.Reader = nil
  3007  	body, err := googleapi.WithoutDataWrapper.JSONReader(c.connectionprofile)
  3008  	if err != nil {
  3009  		return nil, err
  3010  	}
  3011  	c.urlParams_.Set("alt", alt)
  3012  	c.urlParams_.Set("prettyPrint", "false")
  3013  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+name}")
  3014  	urls += "?" + c.urlParams_.Encode()
  3015  	req, err := http.NewRequest("PATCH", urls, body)
  3016  	if err != nil {
  3017  		return nil, err
  3018  	}
  3019  	req.Header = reqHeaders
  3020  	googleapi.Expand(req.URL, map[string]string{
  3021  		"name": c.name,
  3022  	})
  3023  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  3024  }
  3025  
  3026  // Do executes the "datastream.projects.locations.connectionProfiles.patch" call.
  3027  // Any non-2xx status code is an error. Response headers are in either
  3028  // *Operation.ServerResponse.Header or (if a response was returned at all) in
  3029  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  3030  // whether the returned error was because http.StatusNotModified was returned.
  3031  func (c *ProjectsLocationsConnectionProfilesPatchCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
  3032  	gensupport.SetOptions(c.urlParams_, opts...)
  3033  	res, err := c.doRequest("json")
  3034  	if res != nil && res.StatusCode == http.StatusNotModified {
  3035  		if res.Body != nil {
  3036  			res.Body.Close()
  3037  		}
  3038  		return nil, gensupport.WrapError(&googleapi.Error{
  3039  			Code:   res.StatusCode,
  3040  			Header: res.Header,
  3041  		})
  3042  	}
  3043  	if err != nil {
  3044  		return nil, err
  3045  	}
  3046  	defer googleapi.CloseBody(res)
  3047  	if err := googleapi.CheckResponse(res); err != nil {
  3048  		return nil, gensupport.WrapError(err)
  3049  	}
  3050  	ret := &Operation{
  3051  		ServerResponse: googleapi.ServerResponse{
  3052  			Header:         res.Header,
  3053  			HTTPStatusCode: res.StatusCode,
  3054  		},
  3055  	}
  3056  	target := &ret
  3057  	if err := gensupport.DecodeResponse(target, res); err != nil {
  3058  		return nil, err
  3059  	}
  3060  	return ret, nil
  3061  }
  3062  
  3063  type ProjectsLocationsOperationsCancelCall struct {
  3064  	s                      *Service
  3065  	name                   string
  3066  	canceloperationrequest *CancelOperationRequest
  3067  	urlParams_             gensupport.URLParams
  3068  	ctx_                   context.Context
  3069  	header_                http.Header
  3070  }
  3071  
  3072  // Cancel: Starts asynchronous cancellation on a long-running operation. The
  3073  // server makes a best effort to cancel the operation, but success is not
  3074  // guaranteed. If the server doesn't support this method, it returns
  3075  // `google.rpc.Code.UNIMPLEMENTED`. Clients can use Operations.GetOperation or
  3076  // other methods to check whether the cancellation succeeded or whether the
  3077  // operation completed despite cancellation. On successful cancellation, the
  3078  // operation is not deleted; instead, it becomes an operation with an
  3079  // Operation.error value with a google.rpc.Status.code of 1, corresponding to
  3080  // `Code.CANCELLED`.
  3081  //
  3082  // - name: The name of the operation resource to be cancelled.
  3083  func (r *ProjectsLocationsOperationsService) Cancel(name string, canceloperationrequest *CancelOperationRequest) *ProjectsLocationsOperationsCancelCall {
  3084  	c := &ProjectsLocationsOperationsCancelCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  3085  	c.name = name
  3086  	c.canceloperationrequest = canceloperationrequest
  3087  	return c
  3088  }
  3089  
  3090  // Fields allows partial responses to be retrieved. See
  3091  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  3092  // details.
  3093  func (c *ProjectsLocationsOperationsCancelCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsCancelCall {
  3094  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  3095  	return c
  3096  }
  3097  
  3098  // Context sets the context to be used in this call's Do method.
  3099  func (c *ProjectsLocationsOperationsCancelCall) Context(ctx context.Context) *ProjectsLocationsOperationsCancelCall {
  3100  	c.ctx_ = ctx
  3101  	return c
  3102  }
  3103  
  3104  // Header returns a http.Header that can be modified by the caller to add
  3105  // headers to the request.
  3106  func (c *ProjectsLocationsOperationsCancelCall) Header() http.Header {
  3107  	if c.header_ == nil {
  3108  		c.header_ = make(http.Header)
  3109  	}
  3110  	return c.header_
  3111  }
  3112  
  3113  func (c *ProjectsLocationsOperationsCancelCall) doRequest(alt string) (*http.Response, error) {
  3114  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
  3115  	var body io.Reader = nil
  3116  	body, err := googleapi.WithoutDataWrapper.JSONReader(c.canceloperationrequest)
  3117  	if err != nil {
  3118  		return nil, err
  3119  	}
  3120  	c.urlParams_.Set("alt", alt)
  3121  	c.urlParams_.Set("prettyPrint", "false")
  3122  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+name}:cancel")
  3123  	urls += "?" + c.urlParams_.Encode()
  3124  	req, err := http.NewRequest("POST", urls, body)
  3125  	if err != nil {
  3126  		return nil, err
  3127  	}
  3128  	req.Header = reqHeaders
  3129  	googleapi.Expand(req.URL, map[string]string{
  3130  		"name": c.name,
  3131  	})
  3132  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  3133  }
  3134  
  3135  // Do executes the "datastream.projects.locations.operations.cancel" call.
  3136  // Any non-2xx status code is an error. Response headers are in either
  3137  // *Empty.ServerResponse.Header or (if a response was returned at all) in
  3138  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  3139  // whether the returned error was because http.StatusNotModified was returned.
  3140  func (c *ProjectsLocationsOperationsCancelCall) Do(opts ...googleapi.CallOption) (*Empty, error) {
  3141  	gensupport.SetOptions(c.urlParams_, opts...)
  3142  	res, err := c.doRequest("json")
  3143  	if res != nil && res.StatusCode == http.StatusNotModified {
  3144  		if res.Body != nil {
  3145  			res.Body.Close()
  3146  		}
  3147  		return nil, gensupport.WrapError(&googleapi.Error{
  3148  			Code:   res.StatusCode,
  3149  			Header: res.Header,
  3150  		})
  3151  	}
  3152  	if err != nil {
  3153  		return nil, err
  3154  	}
  3155  	defer googleapi.CloseBody(res)
  3156  	if err := googleapi.CheckResponse(res); err != nil {
  3157  		return nil, gensupport.WrapError(err)
  3158  	}
  3159  	ret := &Empty{
  3160  		ServerResponse: googleapi.ServerResponse{
  3161  			Header:         res.Header,
  3162  			HTTPStatusCode: res.StatusCode,
  3163  		},
  3164  	}
  3165  	target := &ret
  3166  	if err := gensupport.DecodeResponse(target, res); err != nil {
  3167  		return nil, err
  3168  	}
  3169  	return ret, nil
  3170  }
  3171  
  3172  type ProjectsLocationsOperationsDeleteCall struct {
  3173  	s          *Service
  3174  	name       string
  3175  	urlParams_ gensupport.URLParams
  3176  	ctx_       context.Context
  3177  	header_    http.Header
  3178  }
  3179  
  3180  // Delete: Deletes a long-running operation. This method indicates that the
  3181  // client is no longer interested in the operation result. It does not cancel
  3182  // the operation. If the server doesn't support this method, it returns
  3183  // `google.rpc.Code.UNIMPLEMENTED`.
  3184  //
  3185  // - name: The name of the operation resource to be deleted.
  3186  func (r *ProjectsLocationsOperationsService) Delete(name string) *ProjectsLocationsOperationsDeleteCall {
  3187  	c := &ProjectsLocationsOperationsDeleteCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  3188  	c.name = name
  3189  	return c
  3190  }
  3191  
  3192  // Fields allows partial responses to be retrieved. See
  3193  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  3194  // details.
  3195  func (c *ProjectsLocationsOperationsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsDeleteCall {
  3196  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  3197  	return c
  3198  }
  3199  
  3200  // Context sets the context to be used in this call's Do method.
  3201  func (c *ProjectsLocationsOperationsDeleteCall) Context(ctx context.Context) *ProjectsLocationsOperationsDeleteCall {
  3202  	c.ctx_ = ctx
  3203  	return c
  3204  }
  3205  
  3206  // Header returns a http.Header that can be modified by the caller to add
  3207  // headers to the request.
  3208  func (c *ProjectsLocationsOperationsDeleteCall) Header() http.Header {
  3209  	if c.header_ == nil {
  3210  		c.header_ = make(http.Header)
  3211  	}
  3212  	return c.header_
  3213  }
  3214  
  3215  func (c *ProjectsLocationsOperationsDeleteCall) doRequest(alt string) (*http.Response, error) {
  3216  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  3217  	var body io.Reader = nil
  3218  	c.urlParams_.Set("alt", alt)
  3219  	c.urlParams_.Set("prettyPrint", "false")
  3220  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+name}")
  3221  	urls += "?" + c.urlParams_.Encode()
  3222  	req, err := http.NewRequest("DELETE", urls, body)
  3223  	if err != nil {
  3224  		return nil, err
  3225  	}
  3226  	req.Header = reqHeaders
  3227  	googleapi.Expand(req.URL, map[string]string{
  3228  		"name": c.name,
  3229  	})
  3230  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  3231  }
  3232  
  3233  // Do executes the "datastream.projects.locations.operations.delete" call.
  3234  // Any non-2xx status code is an error. Response headers are in either
  3235  // *Empty.ServerResponse.Header or (if a response was returned at all) in
  3236  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  3237  // whether the returned error was because http.StatusNotModified was returned.
  3238  func (c *ProjectsLocationsOperationsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error) {
  3239  	gensupport.SetOptions(c.urlParams_, opts...)
  3240  	res, err := c.doRequest("json")
  3241  	if res != nil && res.StatusCode == http.StatusNotModified {
  3242  		if res.Body != nil {
  3243  			res.Body.Close()
  3244  		}
  3245  		return nil, gensupport.WrapError(&googleapi.Error{
  3246  			Code:   res.StatusCode,
  3247  			Header: res.Header,
  3248  		})
  3249  	}
  3250  	if err != nil {
  3251  		return nil, err
  3252  	}
  3253  	defer googleapi.CloseBody(res)
  3254  	if err := googleapi.CheckResponse(res); err != nil {
  3255  		return nil, gensupport.WrapError(err)
  3256  	}
  3257  	ret := &Empty{
  3258  		ServerResponse: googleapi.ServerResponse{
  3259  			Header:         res.Header,
  3260  			HTTPStatusCode: res.StatusCode,
  3261  		},
  3262  	}
  3263  	target := &ret
  3264  	if err := gensupport.DecodeResponse(target, res); err != nil {
  3265  		return nil, err
  3266  	}
  3267  	return ret, nil
  3268  }
  3269  
  3270  type ProjectsLocationsOperationsGetCall struct {
  3271  	s            *Service
  3272  	name         string
  3273  	urlParams_   gensupport.URLParams
  3274  	ifNoneMatch_ string
  3275  	ctx_         context.Context
  3276  	header_      http.Header
  3277  }
  3278  
  3279  // Get: Gets the latest state of a long-running operation. Clients can use this
  3280  // method to poll the operation result at intervals as recommended by the API
  3281  // service.
  3282  //
  3283  // - name: The name of the operation resource.
  3284  func (r *ProjectsLocationsOperationsService) Get(name string) *ProjectsLocationsOperationsGetCall {
  3285  	c := &ProjectsLocationsOperationsGetCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  3286  	c.name = name
  3287  	return c
  3288  }
  3289  
  3290  // Fields allows partial responses to be retrieved. See
  3291  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  3292  // details.
  3293  func (c *ProjectsLocationsOperationsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsGetCall {
  3294  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  3295  	return c
  3296  }
  3297  
  3298  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  3299  // object's ETag matches the given value. This is useful for getting updates
  3300  // only after the object has changed since the last request.
  3301  func (c *ProjectsLocationsOperationsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsOperationsGetCall {
  3302  	c.ifNoneMatch_ = entityTag
  3303  	return c
  3304  }
  3305  
  3306  // Context sets the context to be used in this call's Do method.
  3307  func (c *ProjectsLocationsOperationsGetCall) Context(ctx context.Context) *ProjectsLocationsOperationsGetCall {
  3308  	c.ctx_ = ctx
  3309  	return c
  3310  }
  3311  
  3312  // Header returns a http.Header that can be modified by the caller to add
  3313  // headers to the request.
  3314  func (c *ProjectsLocationsOperationsGetCall) Header() http.Header {
  3315  	if c.header_ == nil {
  3316  		c.header_ = make(http.Header)
  3317  	}
  3318  	return c.header_
  3319  }
  3320  
  3321  func (c *ProjectsLocationsOperationsGetCall) doRequest(alt string) (*http.Response, error) {
  3322  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  3323  	if c.ifNoneMatch_ != "" {
  3324  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  3325  	}
  3326  	var body io.Reader = nil
  3327  	c.urlParams_.Set("alt", alt)
  3328  	c.urlParams_.Set("prettyPrint", "false")
  3329  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+name}")
  3330  	urls += "?" + c.urlParams_.Encode()
  3331  	req, err := http.NewRequest("GET", urls, body)
  3332  	if err != nil {
  3333  		return nil, err
  3334  	}
  3335  	req.Header = reqHeaders
  3336  	googleapi.Expand(req.URL, map[string]string{
  3337  		"name": c.name,
  3338  	})
  3339  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  3340  }
  3341  
  3342  // Do executes the "datastream.projects.locations.operations.get" call.
  3343  // Any non-2xx status code is an error. Response headers are in either
  3344  // *Operation.ServerResponse.Header or (if a response was returned at all) in
  3345  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  3346  // whether the returned error was because http.StatusNotModified was returned.
  3347  func (c *ProjectsLocationsOperationsGetCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
  3348  	gensupport.SetOptions(c.urlParams_, opts...)
  3349  	res, err := c.doRequest("json")
  3350  	if res != nil && res.StatusCode == http.StatusNotModified {
  3351  		if res.Body != nil {
  3352  			res.Body.Close()
  3353  		}
  3354  		return nil, gensupport.WrapError(&googleapi.Error{
  3355  			Code:   res.StatusCode,
  3356  			Header: res.Header,
  3357  		})
  3358  	}
  3359  	if err != nil {
  3360  		return nil, err
  3361  	}
  3362  	defer googleapi.CloseBody(res)
  3363  	if err := googleapi.CheckResponse(res); err != nil {
  3364  		return nil, gensupport.WrapError(err)
  3365  	}
  3366  	ret := &Operation{
  3367  		ServerResponse: googleapi.ServerResponse{
  3368  			Header:         res.Header,
  3369  			HTTPStatusCode: res.StatusCode,
  3370  		},
  3371  	}
  3372  	target := &ret
  3373  	if err := gensupport.DecodeResponse(target, res); err != nil {
  3374  		return nil, err
  3375  	}
  3376  	return ret, nil
  3377  }
  3378  
  3379  type ProjectsLocationsOperationsListCall struct {
  3380  	s            *Service
  3381  	name         string
  3382  	urlParams_   gensupport.URLParams
  3383  	ifNoneMatch_ string
  3384  	ctx_         context.Context
  3385  	header_      http.Header
  3386  }
  3387  
  3388  // List: Lists operations that match the specified filter in the request. If
  3389  // the server doesn't support this method, it returns `UNIMPLEMENTED`.
  3390  //
  3391  // - name: The name of the operation's parent resource.
  3392  func (r *ProjectsLocationsOperationsService) List(name string) *ProjectsLocationsOperationsListCall {
  3393  	c := &ProjectsLocationsOperationsListCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  3394  	c.name = name
  3395  	return c
  3396  }
  3397  
  3398  // Filter sets the optional parameter "filter": The standard list filter.
  3399  func (c *ProjectsLocationsOperationsListCall) Filter(filter string) *ProjectsLocationsOperationsListCall {
  3400  	c.urlParams_.Set("filter", filter)
  3401  	return c
  3402  }
  3403  
  3404  // PageSize sets the optional parameter "pageSize": The standard list page
  3405  // size.
  3406  func (c *ProjectsLocationsOperationsListCall) PageSize(pageSize int64) *ProjectsLocationsOperationsListCall {
  3407  	c.urlParams_.Set("pageSize", fmt.Sprint(pageSize))
  3408  	return c
  3409  }
  3410  
  3411  // PageToken sets the optional parameter "pageToken": The standard list page
  3412  // token.
  3413  func (c *ProjectsLocationsOperationsListCall) PageToken(pageToken string) *ProjectsLocationsOperationsListCall {
  3414  	c.urlParams_.Set("pageToken", pageToken)
  3415  	return c
  3416  }
  3417  
  3418  // Fields allows partial responses to be retrieved. See
  3419  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  3420  // details.
  3421  func (c *ProjectsLocationsOperationsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsListCall {
  3422  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  3423  	return c
  3424  }
  3425  
  3426  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  3427  // object's ETag matches the given value. This is useful for getting updates
  3428  // only after the object has changed since the last request.
  3429  func (c *ProjectsLocationsOperationsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsOperationsListCall {
  3430  	c.ifNoneMatch_ = entityTag
  3431  	return c
  3432  }
  3433  
  3434  // Context sets the context to be used in this call's Do method.
  3435  func (c *ProjectsLocationsOperationsListCall) Context(ctx context.Context) *ProjectsLocationsOperationsListCall {
  3436  	c.ctx_ = ctx
  3437  	return c
  3438  }
  3439  
  3440  // Header returns a http.Header that can be modified by the caller to add
  3441  // headers to the request.
  3442  func (c *ProjectsLocationsOperationsListCall) Header() http.Header {
  3443  	if c.header_ == nil {
  3444  		c.header_ = make(http.Header)
  3445  	}
  3446  	return c.header_
  3447  }
  3448  
  3449  func (c *ProjectsLocationsOperationsListCall) doRequest(alt string) (*http.Response, error) {
  3450  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  3451  	if c.ifNoneMatch_ != "" {
  3452  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  3453  	}
  3454  	var body io.Reader = nil
  3455  	c.urlParams_.Set("alt", alt)
  3456  	c.urlParams_.Set("prettyPrint", "false")
  3457  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+name}/operations")
  3458  	urls += "?" + c.urlParams_.Encode()
  3459  	req, err := http.NewRequest("GET", urls, body)
  3460  	if err != nil {
  3461  		return nil, err
  3462  	}
  3463  	req.Header = reqHeaders
  3464  	googleapi.Expand(req.URL, map[string]string{
  3465  		"name": c.name,
  3466  	})
  3467  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  3468  }
  3469  
  3470  // Do executes the "datastream.projects.locations.operations.list" call.
  3471  // Any non-2xx status code is an error. Response headers are in either
  3472  // *ListOperationsResponse.ServerResponse.Header or (if a response was returned
  3473  // at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to
  3474  // check whether the returned error was because http.StatusNotModified was
  3475  // returned.
  3476  func (c *ProjectsLocationsOperationsListCall) Do(opts ...googleapi.CallOption) (*ListOperationsResponse, error) {
  3477  	gensupport.SetOptions(c.urlParams_, opts...)
  3478  	res, err := c.doRequest("json")
  3479  	if res != nil && res.StatusCode == http.StatusNotModified {
  3480  		if res.Body != nil {
  3481  			res.Body.Close()
  3482  		}
  3483  		return nil, gensupport.WrapError(&googleapi.Error{
  3484  			Code:   res.StatusCode,
  3485  			Header: res.Header,
  3486  		})
  3487  	}
  3488  	if err != nil {
  3489  		return nil, err
  3490  	}
  3491  	defer googleapi.CloseBody(res)
  3492  	if err := googleapi.CheckResponse(res); err != nil {
  3493  		return nil, gensupport.WrapError(err)
  3494  	}
  3495  	ret := &ListOperationsResponse{
  3496  		ServerResponse: googleapi.ServerResponse{
  3497  			Header:         res.Header,
  3498  			HTTPStatusCode: res.StatusCode,
  3499  		},
  3500  	}
  3501  	target := &ret
  3502  	if err := gensupport.DecodeResponse(target, res); err != nil {
  3503  		return nil, err
  3504  	}
  3505  	return ret, nil
  3506  }
  3507  
  3508  // Pages invokes f for each page of results.
  3509  // A non-nil error returned from f will halt the iteration.
  3510  // The provided context supersedes any context provided to the Context method.
  3511  func (c *ProjectsLocationsOperationsListCall) Pages(ctx context.Context, f func(*ListOperationsResponse) error) error {
  3512  	c.ctx_ = ctx
  3513  	defer c.PageToken(c.urlParams_.Get("pageToken"))
  3514  	for {
  3515  		x, err := c.Do()
  3516  		if err != nil {
  3517  			return err
  3518  		}
  3519  		if err := f(x); err != nil {
  3520  			return err
  3521  		}
  3522  		if x.NextPageToken == "" {
  3523  			return nil
  3524  		}
  3525  		c.PageToken(x.NextPageToken)
  3526  	}
  3527  }
  3528  
  3529  type ProjectsLocationsPrivateConnectionsCreateCall struct {
  3530  	s                 *Service
  3531  	parent            string
  3532  	privateconnection *PrivateConnection
  3533  	urlParams_        gensupport.URLParams
  3534  	ctx_              context.Context
  3535  	header_           http.Header
  3536  }
  3537  
  3538  // Create: Use this method to create a private connectivity configuration.
  3539  //
  3540  // - parent: The parent that owns the collection of PrivateConnections.
  3541  func (r *ProjectsLocationsPrivateConnectionsService) Create(parent string, privateconnection *PrivateConnection) *ProjectsLocationsPrivateConnectionsCreateCall {
  3542  	c := &ProjectsLocationsPrivateConnectionsCreateCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  3543  	c.parent = parent
  3544  	c.privateconnection = privateconnection
  3545  	return c
  3546  }
  3547  
  3548  // PrivateConnectionId sets the optional parameter "privateConnectionId":
  3549  // Required. The private connectivity identifier.
  3550  func (c *ProjectsLocationsPrivateConnectionsCreateCall) PrivateConnectionId(privateConnectionId string) *ProjectsLocationsPrivateConnectionsCreateCall {
  3551  	c.urlParams_.Set("privateConnectionId", privateConnectionId)
  3552  	return c
  3553  }
  3554  
  3555  // RequestId sets the optional parameter "requestId": A request ID to identify
  3556  // requests. Specify a unique request ID so that if you must retry your
  3557  // request, the server will know to ignore the request if it has already been
  3558  // completed. The server will guarantee that for at least 60 minutes since the
  3559  // first request. For example, consider a situation where you make an initial
  3560  // request and the request times out. If you make the request again with the
  3561  // same request ID, the server can check if original operation with the same
  3562  // request ID was received, and if so, will ignore the second request. This
  3563  // prevents clients from accidentally creating duplicate commitments. The
  3564  // request ID must be a valid UUID with the exception that zero UUID is not
  3565  // supported (00000000-0000-0000-0000-000000000000).
  3566  func (c *ProjectsLocationsPrivateConnectionsCreateCall) RequestId(requestId string) *ProjectsLocationsPrivateConnectionsCreateCall {
  3567  	c.urlParams_.Set("requestId", requestId)
  3568  	return c
  3569  }
  3570  
  3571  // Fields allows partial responses to be retrieved. See
  3572  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  3573  // details.
  3574  func (c *ProjectsLocationsPrivateConnectionsCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsCreateCall {
  3575  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  3576  	return c
  3577  }
  3578  
  3579  // Context sets the context to be used in this call's Do method.
  3580  func (c *ProjectsLocationsPrivateConnectionsCreateCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsCreateCall {
  3581  	c.ctx_ = ctx
  3582  	return c
  3583  }
  3584  
  3585  // Header returns a http.Header that can be modified by the caller to add
  3586  // headers to the request.
  3587  func (c *ProjectsLocationsPrivateConnectionsCreateCall) Header() http.Header {
  3588  	if c.header_ == nil {
  3589  		c.header_ = make(http.Header)
  3590  	}
  3591  	return c.header_
  3592  }
  3593  
  3594  func (c *ProjectsLocationsPrivateConnectionsCreateCall) doRequest(alt string) (*http.Response, error) {
  3595  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
  3596  	var body io.Reader = nil
  3597  	body, err := googleapi.WithoutDataWrapper.JSONReader(c.privateconnection)
  3598  	if err != nil {
  3599  		return nil, err
  3600  	}
  3601  	c.urlParams_.Set("alt", alt)
  3602  	c.urlParams_.Set("prettyPrint", "false")
  3603  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+parent}/privateConnections")
  3604  	urls += "?" + c.urlParams_.Encode()
  3605  	req, err := http.NewRequest("POST", urls, body)
  3606  	if err != nil {
  3607  		return nil, err
  3608  	}
  3609  	req.Header = reqHeaders
  3610  	googleapi.Expand(req.URL, map[string]string{
  3611  		"parent": c.parent,
  3612  	})
  3613  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  3614  }
  3615  
  3616  // Do executes the "datastream.projects.locations.privateConnections.create" call.
  3617  // Any non-2xx status code is an error. Response headers are in either
  3618  // *Operation.ServerResponse.Header or (if a response was returned at all) in
  3619  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  3620  // whether the returned error was because http.StatusNotModified was returned.
  3621  func (c *ProjectsLocationsPrivateConnectionsCreateCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
  3622  	gensupport.SetOptions(c.urlParams_, opts...)
  3623  	res, err := c.doRequest("json")
  3624  	if res != nil && res.StatusCode == http.StatusNotModified {
  3625  		if res.Body != nil {
  3626  			res.Body.Close()
  3627  		}
  3628  		return nil, gensupport.WrapError(&googleapi.Error{
  3629  			Code:   res.StatusCode,
  3630  			Header: res.Header,
  3631  		})
  3632  	}
  3633  	if err != nil {
  3634  		return nil, err
  3635  	}
  3636  	defer googleapi.CloseBody(res)
  3637  	if err := googleapi.CheckResponse(res); err != nil {
  3638  		return nil, gensupport.WrapError(err)
  3639  	}
  3640  	ret := &Operation{
  3641  		ServerResponse: googleapi.ServerResponse{
  3642  			Header:         res.Header,
  3643  			HTTPStatusCode: res.StatusCode,
  3644  		},
  3645  	}
  3646  	target := &ret
  3647  	if err := gensupport.DecodeResponse(target, res); err != nil {
  3648  		return nil, err
  3649  	}
  3650  	return ret, nil
  3651  }
  3652  
  3653  type ProjectsLocationsPrivateConnectionsDeleteCall struct {
  3654  	s          *Service
  3655  	name       string
  3656  	urlParams_ gensupport.URLParams
  3657  	ctx_       context.Context
  3658  	header_    http.Header
  3659  }
  3660  
  3661  // Delete: Use this method to delete a private connectivity configuration.
  3662  //
  3663  // - name: The name of the private connectivity configuration to delete.
  3664  func (r *ProjectsLocationsPrivateConnectionsService) Delete(name string) *ProjectsLocationsPrivateConnectionsDeleteCall {
  3665  	c := &ProjectsLocationsPrivateConnectionsDeleteCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  3666  	c.name = name
  3667  	return c
  3668  }
  3669  
  3670  // Force sets the optional parameter "force": If set to true, any child routes
  3671  // that belong to this PrivateConnection will also be deleted.
  3672  func (c *ProjectsLocationsPrivateConnectionsDeleteCall) Force(force bool) *ProjectsLocationsPrivateConnectionsDeleteCall {
  3673  	c.urlParams_.Set("force", fmt.Sprint(force))
  3674  	return c
  3675  }
  3676  
  3677  // RequestId sets the optional parameter "requestId": A request ID to identify
  3678  // requests. Specify a unique request ID so that if you must retry your
  3679  // request, the server will know to ignore the request if it has already been
  3680  // completed. The server will guarantee that for at least 60 minutes after the
  3681  // first request. For example, consider a situation where you make an initial
  3682  // request and the request times out. If you make the request again with the
  3683  // same request ID, the server can check if original operation with the same
  3684  // request ID was received, and if so, will ignore the second request. This
  3685  // prevents clients from accidentally creating duplicate commitments. The
  3686  // request ID must be a valid UUID with the exception that zero UUID is not
  3687  // supported (00000000-0000-0000-0000-000000000000).
  3688  func (c *ProjectsLocationsPrivateConnectionsDeleteCall) RequestId(requestId string) *ProjectsLocationsPrivateConnectionsDeleteCall {
  3689  	c.urlParams_.Set("requestId", requestId)
  3690  	return c
  3691  }
  3692  
  3693  // Fields allows partial responses to be retrieved. See
  3694  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  3695  // details.
  3696  func (c *ProjectsLocationsPrivateConnectionsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsDeleteCall {
  3697  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  3698  	return c
  3699  }
  3700  
  3701  // Context sets the context to be used in this call's Do method.
  3702  func (c *ProjectsLocationsPrivateConnectionsDeleteCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsDeleteCall {
  3703  	c.ctx_ = ctx
  3704  	return c
  3705  }
  3706  
  3707  // Header returns a http.Header that can be modified by the caller to add
  3708  // headers to the request.
  3709  func (c *ProjectsLocationsPrivateConnectionsDeleteCall) Header() http.Header {
  3710  	if c.header_ == nil {
  3711  		c.header_ = make(http.Header)
  3712  	}
  3713  	return c.header_
  3714  }
  3715  
  3716  func (c *ProjectsLocationsPrivateConnectionsDeleteCall) doRequest(alt string) (*http.Response, error) {
  3717  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  3718  	var body io.Reader = nil
  3719  	c.urlParams_.Set("alt", alt)
  3720  	c.urlParams_.Set("prettyPrint", "false")
  3721  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+name}")
  3722  	urls += "?" + c.urlParams_.Encode()
  3723  	req, err := http.NewRequest("DELETE", urls, body)
  3724  	if err != nil {
  3725  		return nil, err
  3726  	}
  3727  	req.Header = reqHeaders
  3728  	googleapi.Expand(req.URL, map[string]string{
  3729  		"name": c.name,
  3730  	})
  3731  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  3732  }
  3733  
  3734  // Do executes the "datastream.projects.locations.privateConnections.delete" call.
  3735  // Any non-2xx status code is an error. Response headers are in either
  3736  // *Operation.ServerResponse.Header or (if a response was returned at all) in
  3737  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  3738  // whether the returned error was because http.StatusNotModified was returned.
  3739  func (c *ProjectsLocationsPrivateConnectionsDeleteCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
  3740  	gensupport.SetOptions(c.urlParams_, opts...)
  3741  	res, err := c.doRequest("json")
  3742  	if res != nil && res.StatusCode == http.StatusNotModified {
  3743  		if res.Body != nil {
  3744  			res.Body.Close()
  3745  		}
  3746  		return nil, gensupport.WrapError(&googleapi.Error{
  3747  			Code:   res.StatusCode,
  3748  			Header: res.Header,
  3749  		})
  3750  	}
  3751  	if err != nil {
  3752  		return nil, err
  3753  	}
  3754  	defer googleapi.CloseBody(res)
  3755  	if err := googleapi.CheckResponse(res); err != nil {
  3756  		return nil, gensupport.WrapError(err)
  3757  	}
  3758  	ret := &Operation{
  3759  		ServerResponse: googleapi.ServerResponse{
  3760  			Header:         res.Header,
  3761  			HTTPStatusCode: res.StatusCode,
  3762  		},
  3763  	}
  3764  	target := &ret
  3765  	if err := gensupport.DecodeResponse(target, res); err != nil {
  3766  		return nil, err
  3767  	}
  3768  	return ret, nil
  3769  }
  3770  
  3771  type ProjectsLocationsPrivateConnectionsGetCall struct {
  3772  	s            *Service
  3773  	name         string
  3774  	urlParams_   gensupport.URLParams
  3775  	ifNoneMatch_ string
  3776  	ctx_         context.Context
  3777  	header_      http.Header
  3778  }
  3779  
  3780  // Get: Use this method to get details about a private connectivity
  3781  // configuration.
  3782  //
  3783  // - name: The name of the private connectivity configuration to get.
  3784  func (r *ProjectsLocationsPrivateConnectionsService) Get(name string) *ProjectsLocationsPrivateConnectionsGetCall {
  3785  	c := &ProjectsLocationsPrivateConnectionsGetCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  3786  	c.name = name
  3787  	return c
  3788  }
  3789  
  3790  // Fields allows partial responses to be retrieved. See
  3791  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  3792  // details.
  3793  func (c *ProjectsLocationsPrivateConnectionsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsGetCall {
  3794  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  3795  	return c
  3796  }
  3797  
  3798  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  3799  // object's ETag matches the given value. This is useful for getting updates
  3800  // only after the object has changed since the last request.
  3801  func (c *ProjectsLocationsPrivateConnectionsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsPrivateConnectionsGetCall {
  3802  	c.ifNoneMatch_ = entityTag
  3803  	return c
  3804  }
  3805  
  3806  // Context sets the context to be used in this call's Do method.
  3807  func (c *ProjectsLocationsPrivateConnectionsGetCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsGetCall {
  3808  	c.ctx_ = ctx
  3809  	return c
  3810  }
  3811  
  3812  // Header returns a http.Header that can be modified by the caller to add
  3813  // headers to the request.
  3814  func (c *ProjectsLocationsPrivateConnectionsGetCall) Header() http.Header {
  3815  	if c.header_ == nil {
  3816  		c.header_ = make(http.Header)
  3817  	}
  3818  	return c.header_
  3819  }
  3820  
  3821  func (c *ProjectsLocationsPrivateConnectionsGetCall) doRequest(alt string) (*http.Response, error) {
  3822  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  3823  	if c.ifNoneMatch_ != "" {
  3824  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  3825  	}
  3826  	var body io.Reader = nil
  3827  	c.urlParams_.Set("alt", alt)
  3828  	c.urlParams_.Set("prettyPrint", "false")
  3829  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+name}")
  3830  	urls += "?" + c.urlParams_.Encode()
  3831  	req, err := http.NewRequest("GET", urls, body)
  3832  	if err != nil {
  3833  		return nil, err
  3834  	}
  3835  	req.Header = reqHeaders
  3836  	googleapi.Expand(req.URL, map[string]string{
  3837  		"name": c.name,
  3838  	})
  3839  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  3840  }
  3841  
  3842  // Do executes the "datastream.projects.locations.privateConnections.get" call.
  3843  // Any non-2xx status code is an error. Response headers are in either
  3844  // *PrivateConnection.ServerResponse.Header or (if a response was returned at
  3845  // all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to
  3846  // check whether the returned error was because http.StatusNotModified was
  3847  // returned.
  3848  func (c *ProjectsLocationsPrivateConnectionsGetCall) Do(opts ...googleapi.CallOption) (*PrivateConnection, error) {
  3849  	gensupport.SetOptions(c.urlParams_, opts...)
  3850  	res, err := c.doRequest("json")
  3851  	if res != nil && res.StatusCode == http.StatusNotModified {
  3852  		if res.Body != nil {
  3853  			res.Body.Close()
  3854  		}
  3855  		return nil, gensupport.WrapError(&googleapi.Error{
  3856  			Code:   res.StatusCode,
  3857  			Header: res.Header,
  3858  		})
  3859  	}
  3860  	if err != nil {
  3861  		return nil, err
  3862  	}
  3863  	defer googleapi.CloseBody(res)
  3864  	if err := googleapi.CheckResponse(res); err != nil {
  3865  		return nil, gensupport.WrapError(err)
  3866  	}
  3867  	ret := &PrivateConnection{
  3868  		ServerResponse: googleapi.ServerResponse{
  3869  			Header:         res.Header,
  3870  			HTTPStatusCode: res.StatusCode,
  3871  		},
  3872  	}
  3873  	target := &ret
  3874  	if err := gensupport.DecodeResponse(target, res); err != nil {
  3875  		return nil, err
  3876  	}
  3877  	return ret, nil
  3878  }
  3879  
  3880  type ProjectsLocationsPrivateConnectionsListCall struct {
  3881  	s            *Service
  3882  	parent       string
  3883  	urlParams_   gensupport.URLParams
  3884  	ifNoneMatch_ string
  3885  	ctx_         context.Context
  3886  	header_      http.Header
  3887  }
  3888  
  3889  // List: Use this method to list private connectivity configurations in a
  3890  // project and location.
  3891  //
  3892  //   - parent: The parent that owns the collection of private connectivity
  3893  //     configurations.
  3894  func (r *ProjectsLocationsPrivateConnectionsService) List(parent string) *ProjectsLocationsPrivateConnectionsListCall {
  3895  	c := &ProjectsLocationsPrivateConnectionsListCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  3896  	c.parent = parent
  3897  	return c
  3898  }
  3899  
  3900  // Filter sets the optional parameter "filter": Filter request.
  3901  func (c *ProjectsLocationsPrivateConnectionsListCall) Filter(filter string) *ProjectsLocationsPrivateConnectionsListCall {
  3902  	c.urlParams_.Set("filter", filter)
  3903  	return c
  3904  }
  3905  
  3906  // OrderBy sets the optional parameter "orderBy": Order by fields for the
  3907  // result.
  3908  func (c *ProjectsLocationsPrivateConnectionsListCall) OrderBy(orderBy string) *ProjectsLocationsPrivateConnectionsListCall {
  3909  	c.urlParams_.Set("orderBy", orderBy)
  3910  	return c
  3911  }
  3912  
  3913  // PageSize sets the optional parameter "pageSize": Maximum number of private
  3914  // connectivity configurations to return. If unspecified, at most 50 private
  3915  // connectivity configurations that will be returned. The maximum value is
  3916  // 1000; values above 1000 will be coerced to 1000.
  3917  func (c *ProjectsLocationsPrivateConnectionsListCall) PageSize(pageSize int64) *ProjectsLocationsPrivateConnectionsListCall {
  3918  	c.urlParams_.Set("pageSize", fmt.Sprint(pageSize))
  3919  	return c
  3920  }
  3921  
  3922  // PageToken sets the optional parameter "pageToken": Page token received from
  3923  // a previous `ListPrivateConnections` call. Provide this to retrieve the
  3924  // subsequent page. When paginating, all other parameters provided to
  3925  // `ListPrivateConnections` must match the call that provided the page token.
  3926  func (c *ProjectsLocationsPrivateConnectionsListCall) PageToken(pageToken string) *ProjectsLocationsPrivateConnectionsListCall {
  3927  	c.urlParams_.Set("pageToken", pageToken)
  3928  	return c
  3929  }
  3930  
  3931  // Fields allows partial responses to be retrieved. See
  3932  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  3933  // details.
  3934  func (c *ProjectsLocationsPrivateConnectionsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsListCall {
  3935  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  3936  	return c
  3937  }
  3938  
  3939  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  3940  // object's ETag matches the given value. This is useful for getting updates
  3941  // only after the object has changed since the last request.
  3942  func (c *ProjectsLocationsPrivateConnectionsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsPrivateConnectionsListCall {
  3943  	c.ifNoneMatch_ = entityTag
  3944  	return c
  3945  }
  3946  
  3947  // Context sets the context to be used in this call's Do method.
  3948  func (c *ProjectsLocationsPrivateConnectionsListCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsListCall {
  3949  	c.ctx_ = ctx
  3950  	return c
  3951  }
  3952  
  3953  // Header returns a http.Header that can be modified by the caller to add
  3954  // headers to the request.
  3955  func (c *ProjectsLocationsPrivateConnectionsListCall) Header() http.Header {
  3956  	if c.header_ == nil {
  3957  		c.header_ = make(http.Header)
  3958  	}
  3959  	return c.header_
  3960  }
  3961  
  3962  func (c *ProjectsLocationsPrivateConnectionsListCall) doRequest(alt string) (*http.Response, error) {
  3963  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  3964  	if c.ifNoneMatch_ != "" {
  3965  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  3966  	}
  3967  	var body io.Reader = nil
  3968  	c.urlParams_.Set("alt", alt)
  3969  	c.urlParams_.Set("prettyPrint", "false")
  3970  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+parent}/privateConnections")
  3971  	urls += "?" + c.urlParams_.Encode()
  3972  	req, err := http.NewRequest("GET", urls, body)
  3973  	if err != nil {
  3974  		return nil, err
  3975  	}
  3976  	req.Header = reqHeaders
  3977  	googleapi.Expand(req.URL, map[string]string{
  3978  		"parent": c.parent,
  3979  	})
  3980  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  3981  }
  3982  
  3983  // Do executes the "datastream.projects.locations.privateConnections.list" call.
  3984  // Any non-2xx status code is an error. Response headers are in either
  3985  // *ListPrivateConnectionsResponse.ServerResponse.Header or (if a response was
  3986  // returned at all) in error.(*googleapi.Error).Header. Use
  3987  // googleapi.IsNotModified to check whether the returned error was because
  3988  // http.StatusNotModified was returned.
  3989  func (c *ProjectsLocationsPrivateConnectionsListCall) Do(opts ...googleapi.CallOption) (*ListPrivateConnectionsResponse, error) {
  3990  	gensupport.SetOptions(c.urlParams_, opts...)
  3991  	res, err := c.doRequest("json")
  3992  	if res != nil && res.StatusCode == http.StatusNotModified {
  3993  		if res.Body != nil {
  3994  			res.Body.Close()
  3995  		}
  3996  		return nil, gensupport.WrapError(&googleapi.Error{
  3997  			Code:   res.StatusCode,
  3998  			Header: res.Header,
  3999  		})
  4000  	}
  4001  	if err != nil {
  4002  		return nil, err
  4003  	}
  4004  	defer googleapi.CloseBody(res)
  4005  	if err := googleapi.CheckResponse(res); err != nil {
  4006  		return nil, gensupport.WrapError(err)
  4007  	}
  4008  	ret := &ListPrivateConnectionsResponse{
  4009  		ServerResponse: googleapi.ServerResponse{
  4010  			Header:         res.Header,
  4011  			HTTPStatusCode: res.StatusCode,
  4012  		},
  4013  	}
  4014  	target := &ret
  4015  	if err := gensupport.DecodeResponse(target, res); err != nil {
  4016  		return nil, err
  4017  	}
  4018  	return ret, nil
  4019  }
  4020  
  4021  // Pages invokes f for each page of results.
  4022  // A non-nil error returned from f will halt the iteration.
  4023  // The provided context supersedes any context provided to the Context method.
  4024  func (c *ProjectsLocationsPrivateConnectionsListCall) Pages(ctx context.Context, f func(*ListPrivateConnectionsResponse) error) error {
  4025  	c.ctx_ = ctx
  4026  	defer c.PageToken(c.urlParams_.Get("pageToken"))
  4027  	for {
  4028  		x, err := c.Do()
  4029  		if err != nil {
  4030  			return err
  4031  		}
  4032  		if err := f(x); err != nil {
  4033  			return err
  4034  		}
  4035  		if x.NextPageToken == "" {
  4036  			return nil
  4037  		}
  4038  		c.PageToken(x.NextPageToken)
  4039  	}
  4040  }
  4041  
  4042  type ProjectsLocationsPrivateConnectionsRoutesCreateCall struct {
  4043  	s          *Service
  4044  	parent     string
  4045  	route      *Route
  4046  	urlParams_ gensupport.URLParams
  4047  	ctx_       context.Context
  4048  	header_    http.Header
  4049  }
  4050  
  4051  // Create: Use this method to create a route for a private connectivity in a
  4052  // project and location.
  4053  //
  4054  // - parent: The parent that owns the collection of Routes.
  4055  func (r *ProjectsLocationsPrivateConnectionsRoutesService) Create(parent string, route *Route) *ProjectsLocationsPrivateConnectionsRoutesCreateCall {
  4056  	c := &ProjectsLocationsPrivateConnectionsRoutesCreateCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  4057  	c.parent = parent
  4058  	c.route = route
  4059  	return c
  4060  }
  4061  
  4062  // RequestId sets the optional parameter "requestId": A request ID to identify
  4063  // requests. Specify a unique request ID so that if you must retry your
  4064  // request, the server will know to ignore the request if it has already been
  4065  // completed. The server will guarantee that for at least 60 minutes since the
  4066  // first request. For example, consider a situation where you make an initial
  4067  // request and the request times out. If you make the request again with the
  4068  // same request ID, the server can check if original operation with the same
  4069  // request ID was received, and if so, will ignore the second request. This
  4070  // prevents clients from accidentally creating duplicate commitments. The
  4071  // request ID must be a valid UUID with the exception that zero UUID is not
  4072  // supported (00000000-0000-0000-0000-000000000000).
  4073  func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) RequestId(requestId string) *ProjectsLocationsPrivateConnectionsRoutesCreateCall {
  4074  	c.urlParams_.Set("requestId", requestId)
  4075  	return c
  4076  }
  4077  
  4078  // RouteId sets the optional parameter "routeId": Required. The Route
  4079  // identifier.
  4080  func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) RouteId(routeId string) *ProjectsLocationsPrivateConnectionsRoutesCreateCall {
  4081  	c.urlParams_.Set("routeId", routeId)
  4082  	return c
  4083  }
  4084  
  4085  // Fields allows partial responses to be retrieved. See
  4086  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  4087  // details.
  4088  func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsRoutesCreateCall {
  4089  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  4090  	return c
  4091  }
  4092  
  4093  // Context sets the context to be used in this call's Do method.
  4094  func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsRoutesCreateCall {
  4095  	c.ctx_ = ctx
  4096  	return c
  4097  }
  4098  
  4099  // Header returns a http.Header that can be modified by the caller to add
  4100  // headers to the request.
  4101  func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) Header() http.Header {
  4102  	if c.header_ == nil {
  4103  		c.header_ = make(http.Header)
  4104  	}
  4105  	return c.header_
  4106  }
  4107  
  4108  func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) doRequest(alt string) (*http.Response, error) {
  4109  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
  4110  	var body io.Reader = nil
  4111  	body, err := googleapi.WithoutDataWrapper.JSONReader(c.route)
  4112  	if err != nil {
  4113  		return nil, err
  4114  	}
  4115  	c.urlParams_.Set("alt", alt)
  4116  	c.urlParams_.Set("prettyPrint", "false")
  4117  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+parent}/routes")
  4118  	urls += "?" + c.urlParams_.Encode()
  4119  	req, err := http.NewRequest("POST", urls, body)
  4120  	if err != nil {
  4121  		return nil, err
  4122  	}
  4123  	req.Header = reqHeaders
  4124  	googleapi.Expand(req.URL, map[string]string{
  4125  		"parent": c.parent,
  4126  	})
  4127  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  4128  }
  4129  
  4130  // Do executes the "datastream.projects.locations.privateConnections.routes.create" call.
  4131  // Any non-2xx status code is an error. Response headers are in either
  4132  // *Operation.ServerResponse.Header or (if a response was returned at all) in
  4133  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  4134  // whether the returned error was because http.StatusNotModified was returned.
  4135  func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
  4136  	gensupport.SetOptions(c.urlParams_, opts...)
  4137  	res, err := c.doRequest("json")
  4138  	if res != nil && res.StatusCode == http.StatusNotModified {
  4139  		if res.Body != nil {
  4140  			res.Body.Close()
  4141  		}
  4142  		return nil, gensupport.WrapError(&googleapi.Error{
  4143  			Code:   res.StatusCode,
  4144  			Header: res.Header,
  4145  		})
  4146  	}
  4147  	if err != nil {
  4148  		return nil, err
  4149  	}
  4150  	defer googleapi.CloseBody(res)
  4151  	if err := googleapi.CheckResponse(res); err != nil {
  4152  		return nil, gensupport.WrapError(err)
  4153  	}
  4154  	ret := &Operation{
  4155  		ServerResponse: googleapi.ServerResponse{
  4156  			Header:         res.Header,
  4157  			HTTPStatusCode: res.StatusCode,
  4158  		},
  4159  	}
  4160  	target := &ret
  4161  	if err := gensupport.DecodeResponse(target, res); err != nil {
  4162  		return nil, err
  4163  	}
  4164  	return ret, nil
  4165  }
  4166  
  4167  type ProjectsLocationsPrivateConnectionsRoutesDeleteCall struct {
  4168  	s          *Service
  4169  	name       string
  4170  	urlParams_ gensupport.URLParams
  4171  	ctx_       context.Context
  4172  	header_    http.Header
  4173  }
  4174  
  4175  // Delete: Use this method to delete a route.
  4176  //
  4177  // - name: The name of the Route resource to delete.
  4178  func (r *ProjectsLocationsPrivateConnectionsRoutesService) Delete(name string) *ProjectsLocationsPrivateConnectionsRoutesDeleteCall {
  4179  	c := &ProjectsLocationsPrivateConnectionsRoutesDeleteCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  4180  	c.name = name
  4181  	return c
  4182  }
  4183  
  4184  // RequestId sets the optional parameter "requestId": A request ID to identify
  4185  // requests. Specify a unique request ID so that if you must retry your
  4186  // request, the server will know to ignore the request if it has already been
  4187  // completed. The server will guarantee that for at least 60 minutes after the
  4188  // first request. For example, consider a situation where you make an initial
  4189  // request and the request times out. If you make the request again with the
  4190  // same request ID, the server can check if original operation with the same
  4191  // request ID was received, and if so, will ignore the second request. This
  4192  // prevents clients from accidentally creating duplicate commitments. The
  4193  // request ID must be a valid UUID with the exception that zero UUID is not
  4194  // supported (00000000-0000-0000-0000-000000000000).
  4195  func (c *ProjectsLocationsPrivateConnectionsRoutesDeleteCall) RequestId(requestId string) *ProjectsLocationsPrivateConnectionsRoutesDeleteCall {
  4196  	c.urlParams_.Set("requestId", requestId)
  4197  	return c
  4198  }
  4199  
  4200  // Fields allows partial responses to be retrieved. See
  4201  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  4202  // details.
  4203  func (c *ProjectsLocationsPrivateConnectionsRoutesDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsRoutesDeleteCall {
  4204  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  4205  	return c
  4206  }
  4207  
  4208  // Context sets the context to be used in this call's Do method.
  4209  func (c *ProjectsLocationsPrivateConnectionsRoutesDeleteCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsRoutesDeleteCall {
  4210  	c.ctx_ = ctx
  4211  	return c
  4212  }
  4213  
  4214  // Header returns a http.Header that can be modified by the caller to add
  4215  // headers to the request.
  4216  func (c *ProjectsLocationsPrivateConnectionsRoutesDeleteCall) Header() http.Header {
  4217  	if c.header_ == nil {
  4218  		c.header_ = make(http.Header)
  4219  	}
  4220  	return c.header_
  4221  }
  4222  
  4223  func (c *ProjectsLocationsPrivateConnectionsRoutesDeleteCall) doRequest(alt string) (*http.Response, error) {
  4224  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  4225  	var body io.Reader = nil
  4226  	c.urlParams_.Set("alt", alt)
  4227  	c.urlParams_.Set("prettyPrint", "false")
  4228  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+name}")
  4229  	urls += "?" + c.urlParams_.Encode()
  4230  	req, err := http.NewRequest("DELETE", urls, body)
  4231  	if err != nil {
  4232  		return nil, err
  4233  	}
  4234  	req.Header = reqHeaders
  4235  	googleapi.Expand(req.URL, map[string]string{
  4236  		"name": c.name,
  4237  	})
  4238  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  4239  }
  4240  
  4241  // Do executes the "datastream.projects.locations.privateConnections.routes.delete" call.
  4242  // Any non-2xx status code is an error. Response headers are in either
  4243  // *Operation.ServerResponse.Header or (if a response was returned at all) in
  4244  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  4245  // whether the returned error was because http.StatusNotModified was returned.
  4246  func (c *ProjectsLocationsPrivateConnectionsRoutesDeleteCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
  4247  	gensupport.SetOptions(c.urlParams_, opts...)
  4248  	res, err := c.doRequest("json")
  4249  	if res != nil && res.StatusCode == http.StatusNotModified {
  4250  		if res.Body != nil {
  4251  			res.Body.Close()
  4252  		}
  4253  		return nil, gensupport.WrapError(&googleapi.Error{
  4254  			Code:   res.StatusCode,
  4255  			Header: res.Header,
  4256  		})
  4257  	}
  4258  	if err != nil {
  4259  		return nil, err
  4260  	}
  4261  	defer googleapi.CloseBody(res)
  4262  	if err := googleapi.CheckResponse(res); err != nil {
  4263  		return nil, gensupport.WrapError(err)
  4264  	}
  4265  	ret := &Operation{
  4266  		ServerResponse: googleapi.ServerResponse{
  4267  			Header:         res.Header,
  4268  			HTTPStatusCode: res.StatusCode,
  4269  		},
  4270  	}
  4271  	target := &ret
  4272  	if err := gensupport.DecodeResponse(target, res); err != nil {
  4273  		return nil, err
  4274  	}
  4275  	return ret, nil
  4276  }
  4277  
  4278  type ProjectsLocationsPrivateConnectionsRoutesGetCall struct {
  4279  	s            *Service
  4280  	name         string
  4281  	urlParams_   gensupport.URLParams
  4282  	ifNoneMatch_ string
  4283  	ctx_         context.Context
  4284  	header_      http.Header
  4285  }
  4286  
  4287  // Get: Use this method to get details about a route.
  4288  //
  4289  // - name: The name of the Route resource to get.
  4290  func (r *ProjectsLocationsPrivateConnectionsRoutesService) Get(name string) *ProjectsLocationsPrivateConnectionsRoutesGetCall {
  4291  	c := &ProjectsLocationsPrivateConnectionsRoutesGetCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  4292  	c.name = name
  4293  	return c
  4294  }
  4295  
  4296  // Fields allows partial responses to be retrieved. See
  4297  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  4298  // details.
  4299  func (c *ProjectsLocationsPrivateConnectionsRoutesGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsRoutesGetCall {
  4300  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  4301  	return c
  4302  }
  4303  
  4304  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  4305  // object's ETag matches the given value. This is useful for getting updates
  4306  // only after the object has changed since the last request.
  4307  func (c *ProjectsLocationsPrivateConnectionsRoutesGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsPrivateConnectionsRoutesGetCall {
  4308  	c.ifNoneMatch_ = entityTag
  4309  	return c
  4310  }
  4311  
  4312  // Context sets the context to be used in this call's Do method.
  4313  func (c *ProjectsLocationsPrivateConnectionsRoutesGetCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsRoutesGetCall {
  4314  	c.ctx_ = ctx
  4315  	return c
  4316  }
  4317  
  4318  // Header returns a http.Header that can be modified by the caller to add
  4319  // headers to the request.
  4320  func (c *ProjectsLocationsPrivateConnectionsRoutesGetCall) Header() http.Header {
  4321  	if c.header_ == nil {
  4322  		c.header_ = make(http.Header)
  4323  	}
  4324  	return c.header_
  4325  }
  4326  
  4327  func (c *ProjectsLocationsPrivateConnectionsRoutesGetCall) doRequest(alt string) (*http.Response, error) {
  4328  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  4329  	if c.ifNoneMatch_ != "" {
  4330  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  4331  	}
  4332  	var body io.Reader = nil
  4333  	c.urlParams_.Set("alt", alt)
  4334  	c.urlParams_.Set("prettyPrint", "false")
  4335  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+name}")
  4336  	urls += "?" + c.urlParams_.Encode()
  4337  	req, err := http.NewRequest("GET", urls, body)
  4338  	if err != nil {
  4339  		return nil, err
  4340  	}
  4341  	req.Header = reqHeaders
  4342  	googleapi.Expand(req.URL, map[string]string{
  4343  		"name": c.name,
  4344  	})
  4345  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  4346  }
  4347  
  4348  // Do executes the "datastream.projects.locations.privateConnections.routes.get" call.
  4349  // Any non-2xx status code is an error. Response headers are in either
  4350  // *Route.ServerResponse.Header or (if a response was returned at all) in
  4351  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  4352  // whether the returned error was because http.StatusNotModified was returned.
  4353  func (c *ProjectsLocationsPrivateConnectionsRoutesGetCall) Do(opts ...googleapi.CallOption) (*Route, error) {
  4354  	gensupport.SetOptions(c.urlParams_, opts...)
  4355  	res, err := c.doRequest("json")
  4356  	if res != nil && res.StatusCode == http.StatusNotModified {
  4357  		if res.Body != nil {
  4358  			res.Body.Close()
  4359  		}
  4360  		return nil, gensupport.WrapError(&googleapi.Error{
  4361  			Code:   res.StatusCode,
  4362  			Header: res.Header,
  4363  		})
  4364  	}
  4365  	if err != nil {
  4366  		return nil, err
  4367  	}
  4368  	defer googleapi.CloseBody(res)
  4369  	if err := googleapi.CheckResponse(res); err != nil {
  4370  		return nil, gensupport.WrapError(err)
  4371  	}
  4372  	ret := &Route{
  4373  		ServerResponse: googleapi.ServerResponse{
  4374  			Header:         res.Header,
  4375  			HTTPStatusCode: res.StatusCode,
  4376  		},
  4377  	}
  4378  	target := &ret
  4379  	if err := gensupport.DecodeResponse(target, res); err != nil {
  4380  		return nil, err
  4381  	}
  4382  	return ret, nil
  4383  }
  4384  
  4385  type ProjectsLocationsPrivateConnectionsRoutesListCall struct {
  4386  	s            *Service
  4387  	parent       string
  4388  	urlParams_   gensupport.URLParams
  4389  	ifNoneMatch_ string
  4390  	ctx_         context.Context
  4391  	header_      http.Header
  4392  }
  4393  
  4394  // List: Use this method to list routes created for a private connectivity in a
  4395  // project and location.
  4396  //
  4397  // - parent: The parent that owns the collection of Routess.
  4398  func (r *ProjectsLocationsPrivateConnectionsRoutesService) List(parent string) *ProjectsLocationsPrivateConnectionsRoutesListCall {
  4399  	c := &ProjectsLocationsPrivateConnectionsRoutesListCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  4400  	c.parent = parent
  4401  	return c
  4402  }
  4403  
  4404  // Filter sets the optional parameter "filter": Filter request.
  4405  func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Filter(filter string) *ProjectsLocationsPrivateConnectionsRoutesListCall {
  4406  	c.urlParams_.Set("filter", filter)
  4407  	return c
  4408  }
  4409  
  4410  // OrderBy sets the optional parameter "orderBy": Order by fields for the
  4411  // result.
  4412  func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) OrderBy(orderBy string) *ProjectsLocationsPrivateConnectionsRoutesListCall {
  4413  	c.urlParams_.Set("orderBy", orderBy)
  4414  	return c
  4415  }
  4416  
  4417  // PageSize sets the optional parameter "pageSize": Maximum number of Routes to
  4418  // return. The service may return fewer than this value. If unspecified, at
  4419  // most 50 Routes will be returned. The maximum value is 1000; values above
  4420  // 1000 will be coerced to 1000.
  4421  func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) PageSize(pageSize int64) *ProjectsLocationsPrivateConnectionsRoutesListCall {
  4422  	c.urlParams_.Set("pageSize", fmt.Sprint(pageSize))
  4423  	return c
  4424  }
  4425  
  4426  // PageToken sets the optional parameter "pageToken": Page token received from
  4427  // a previous `ListRoutes` call. Provide this to retrieve the subsequent page.
  4428  // When paginating, all other parameters provided to `ListRoutes` must match
  4429  // the call that provided the page token.
  4430  func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) PageToken(pageToken string) *ProjectsLocationsPrivateConnectionsRoutesListCall {
  4431  	c.urlParams_.Set("pageToken", pageToken)
  4432  	return c
  4433  }
  4434  
  4435  // Fields allows partial responses to be retrieved. See
  4436  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  4437  // details.
  4438  func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsRoutesListCall {
  4439  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  4440  	return c
  4441  }
  4442  
  4443  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  4444  // object's ETag matches the given value. This is useful for getting updates
  4445  // only after the object has changed since the last request.
  4446  func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) IfNoneMatch(entityTag string) *ProjectsLocationsPrivateConnectionsRoutesListCall {
  4447  	c.ifNoneMatch_ = entityTag
  4448  	return c
  4449  }
  4450  
  4451  // Context sets the context to be used in this call's Do method.
  4452  func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsRoutesListCall {
  4453  	c.ctx_ = ctx
  4454  	return c
  4455  }
  4456  
  4457  // Header returns a http.Header that can be modified by the caller to add
  4458  // headers to the request.
  4459  func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Header() http.Header {
  4460  	if c.header_ == nil {
  4461  		c.header_ = make(http.Header)
  4462  	}
  4463  	return c.header_
  4464  }
  4465  
  4466  func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) doRequest(alt string) (*http.Response, error) {
  4467  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  4468  	if c.ifNoneMatch_ != "" {
  4469  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  4470  	}
  4471  	var body io.Reader = nil
  4472  	c.urlParams_.Set("alt", alt)
  4473  	c.urlParams_.Set("prettyPrint", "false")
  4474  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+parent}/routes")
  4475  	urls += "?" + c.urlParams_.Encode()
  4476  	req, err := http.NewRequest("GET", urls, body)
  4477  	if err != nil {
  4478  		return nil, err
  4479  	}
  4480  	req.Header = reqHeaders
  4481  	googleapi.Expand(req.URL, map[string]string{
  4482  		"parent": c.parent,
  4483  	})
  4484  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  4485  }
  4486  
  4487  // Do executes the "datastream.projects.locations.privateConnections.routes.list" call.
  4488  // Any non-2xx status code is an error. Response headers are in either
  4489  // *ListRoutesResponse.ServerResponse.Header or (if a response was returned at
  4490  // all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to
  4491  // check whether the returned error was because http.StatusNotModified was
  4492  // returned.
  4493  func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Do(opts ...googleapi.CallOption) (*ListRoutesResponse, error) {
  4494  	gensupport.SetOptions(c.urlParams_, opts...)
  4495  	res, err := c.doRequest("json")
  4496  	if res != nil && res.StatusCode == http.StatusNotModified {
  4497  		if res.Body != nil {
  4498  			res.Body.Close()
  4499  		}
  4500  		return nil, gensupport.WrapError(&googleapi.Error{
  4501  			Code:   res.StatusCode,
  4502  			Header: res.Header,
  4503  		})
  4504  	}
  4505  	if err != nil {
  4506  		return nil, err
  4507  	}
  4508  	defer googleapi.CloseBody(res)
  4509  	if err := googleapi.CheckResponse(res); err != nil {
  4510  		return nil, gensupport.WrapError(err)
  4511  	}
  4512  	ret := &ListRoutesResponse{
  4513  		ServerResponse: googleapi.ServerResponse{
  4514  			Header:         res.Header,
  4515  			HTTPStatusCode: res.StatusCode,
  4516  		},
  4517  	}
  4518  	target := &ret
  4519  	if err := gensupport.DecodeResponse(target, res); err != nil {
  4520  		return nil, err
  4521  	}
  4522  	return ret, nil
  4523  }
  4524  
  4525  // Pages invokes f for each page of results.
  4526  // A non-nil error returned from f will halt the iteration.
  4527  // The provided context supersedes any context provided to the Context method.
  4528  func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Pages(ctx context.Context, f func(*ListRoutesResponse) error) error {
  4529  	c.ctx_ = ctx
  4530  	defer c.PageToken(c.urlParams_.Get("pageToken"))
  4531  	for {
  4532  		x, err := c.Do()
  4533  		if err != nil {
  4534  			return err
  4535  		}
  4536  		if err := f(x); err != nil {
  4537  			return err
  4538  		}
  4539  		if x.NextPageToken == "" {
  4540  			return nil
  4541  		}
  4542  		c.PageToken(x.NextPageToken)
  4543  	}
  4544  }
  4545  
  4546  type ProjectsLocationsStreamsCreateCall struct {
  4547  	s          *Service
  4548  	parent     string
  4549  	stream     *Stream
  4550  	urlParams_ gensupport.URLParams
  4551  	ctx_       context.Context
  4552  	header_    http.Header
  4553  }
  4554  
  4555  // Create: Use this method to create a stream.
  4556  //
  4557  // - parent: The parent that owns the collection of streams.
  4558  func (r *ProjectsLocationsStreamsService) Create(parent string, stream *Stream) *ProjectsLocationsStreamsCreateCall {
  4559  	c := &ProjectsLocationsStreamsCreateCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  4560  	c.parent = parent
  4561  	c.stream = stream
  4562  	return c
  4563  }
  4564  
  4565  // Force sets the optional parameter "force": Create the stream without
  4566  // validating it.
  4567  func (c *ProjectsLocationsStreamsCreateCall) Force(force bool) *ProjectsLocationsStreamsCreateCall {
  4568  	c.urlParams_.Set("force", fmt.Sprint(force))
  4569  	return c
  4570  }
  4571  
  4572  // RequestId sets the optional parameter "requestId": A request ID to identify
  4573  // requests. Specify a unique request ID so that if you must retry your
  4574  // request, the server will know to ignore the request if it has already been
  4575  // completed. The server will guarantee that for at least 60 minutes since the
  4576  // first request. For example, consider a situation where you make an initial
  4577  // request and the request times out. If you make the request again with the
  4578  // same request ID, the server can check if original operation with the same
  4579  // request ID was received, and if so, will ignore the second request. This
  4580  // prevents clients from accidentally creating duplicate commitments. The
  4581  // request ID must be a valid UUID with the exception that zero UUID is not
  4582  // supported (00000000-0000-0000-0000-000000000000).
  4583  func (c *ProjectsLocationsStreamsCreateCall) RequestId(requestId string) *ProjectsLocationsStreamsCreateCall {
  4584  	c.urlParams_.Set("requestId", requestId)
  4585  	return c
  4586  }
  4587  
  4588  // StreamId sets the optional parameter "streamId": Required. The stream
  4589  // identifier.
  4590  func (c *ProjectsLocationsStreamsCreateCall) StreamId(streamId string) *ProjectsLocationsStreamsCreateCall {
  4591  	c.urlParams_.Set("streamId", streamId)
  4592  	return c
  4593  }
  4594  
  4595  // ValidateOnly sets the optional parameter "validateOnly": Only validate the
  4596  // stream, but do not create any resources. The default is false.
  4597  func (c *ProjectsLocationsStreamsCreateCall) ValidateOnly(validateOnly bool) *ProjectsLocationsStreamsCreateCall {
  4598  	c.urlParams_.Set("validateOnly", fmt.Sprint(validateOnly))
  4599  	return c
  4600  }
  4601  
  4602  // Fields allows partial responses to be retrieved. See
  4603  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  4604  // details.
  4605  func (c *ProjectsLocationsStreamsCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsCreateCall {
  4606  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  4607  	return c
  4608  }
  4609  
  4610  // Context sets the context to be used in this call's Do method.
  4611  func (c *ProjectsLocationsStreamsCreateCall) Context(ctx context.Context) *ProjectsLocationsStreamsCreateCall {
  4612  	c.ctx_ = ctx
  4613  	return c
  4614  }
  4615  
  4616  // Header returns a http.Header that can be modified by the caller to add
  4617  // headers to the request.
  4618  func (c *ProjectsLocationsStreamsCreateCall) Header() http.Header {
  4619  	if c.header_ == nil {
  4620  		c.header_ = make(http.Header)
  4621  	}
  4622  	return c.header_
  4623  }
  4624  
  4625  func (c *ProjectsLocationsStreamsCreateCall) doRequest(alt string) (*http.Response, error) {
  4626  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
  4627  	var body io.Reader = nil
  4628  	body, err := googleapi.WithoutDataWrapper.JSONReader(c.stream)
  4629  	if err != nil {
  4630  		return nil, err
  4631  	}
  4632  	c.urlParams_.Set("alt", alt)
  4633  	c.urlParams_.Set("prettyPrint", "false")
  4634  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+parent}/streams")
  4635  	urls += "?" + c.urlParams_.Encode()
  4636  	req, err := http.NewRequest("POST", urls, body)
  4637  	if err != nil {
  4638  		return nil, err
  4639  	}
  4640  	req.Header = reqHeaders
  4641  	googleapi.Expand(req.URL, map[string]string{
  4642  		"parent": c.parent,
  4643  	})
  4644  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  4645  }
  4646  
  4647  // Do executes the "datastream.projects.locations.streams.create" call.
  4648  // Any non-2xx status code is an error. Response headers are in either
  4649  // *Operation.ServerResponse.Header or (if a response was returned at all) in
  4650  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  4651  // whether the returned error was because http.StatusNotModified was returned.
  4652  func (c *ProjectsLocationsStreamsCreateCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
  4653  	gensupport.SetOptions(c.urlParams_, opts...)
  4654  	res, err := c.doRequest("json")
  4655  	if res != nil && res.StatusCode == http.StatusNotModified {
  4656  		if res.Body != nil {
  4657  			res.Body.Close()
  4658  		}
  4659  		return nil, gensupport.WrapError(&googleapi.Error{
  4660  			Code:   res.StatusCode,
  4661  			Header: res.Header,
  4662  		})
  4663  	}
  4664  	if err != nil {
  4665  		return nil, err
  4666  	}
  4667  	defer googleapi.CloseBody(res)
  4668  	if err := googleapi.CheckResponse(res); err != nil {
  4669  		return nil, gensupport.WrapError(err)
  4670  	}
  4671  	ret := &Operation{
  4672  		ServerResponse: googleapi.ServerResponse{
  4673  			Header:         res.Header,
  4674  			HTTPStatusCode: res.StatusCode,
  4675  		},
  4676  	}
  4677  	target := &ret
  4678  	if err := gensupport.DecodeResponse(target, res); err != nil {
  4679  		return nil, err
  4680  	}
  4681  	return ret, nil
  4682  }
  4683  
  4684  type ProjectsLocationsStreamsDeleteCall struct {
  4685  	s          *Service
  4686  	name       string
  4687  	urlParams_ gensupport.URLParams
  4688  	ctx_       context.Context
  4689  	header_    http.Header
  4690  }
  4691  
  4692  // Delete: Use this method to delete a stream.
  4693  //
  4694  // - name: The name of the stream resource to delete.
  4695  func (r *ProjectsLocationsStreamsService) Delete(name string) *ProjectsLocationsStreamsDeleteCall {
  4696  	c := &ProjectsLocationsStreamsDeleteCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  4697  	c.name = name
  4698  	return c
  4699  }
  4700  
  4701  // RequestId sets the optional parameter "requestId": A request ID to identify
  4702  // requests. Specify a unique request ID so that if you must retry your
  4703  // request, the server will know to ignore the request if it has already been
  4704  // completed. The server will guarantee that for at least 60 minutes after the
  4705  // first request. For example, consider a situation where you make an initial
  4706  // request and the request times out. If you make the request again with the
  4707  // same request ID, the server can check if original operation with the same
  4708  // request ID was received, and if so, will ignore the second request. This
  4709  // prevents clients from accidentally creating duplicate commitments. The
  4710  // request ID must be a valid UUID with the exception that zero UUID is not
  4711  // supported (00000000-0000-0000-0000-000000000000).
  4712  func (c *ProjectsLocationsStreamsDeleteCall) RequestId(requestId string) *ProjectsLocationsStreamsDeleteCall {
  4713  	c.urlParams_.Set("requestId", requestId)
  4714  	return c
  4715  }
  4716  
  4717  // Fields allows partial responses to be retrieved. See
  4718  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  4719  // details.
  4720  func (c *ProjectsLocationsStreamsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsDeleteCall {
  4721  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  4722  	return c
  4723  }
  4724  
  4725  // Context sets the context to be used in this call's Do method.
  4726  func (c *ProjectsLocationsStreamsDeleteCall) Context(ctx context.Context) *ProjectsLocationsStreamsDeleteCall {
  4727  	c.ctx_ = ctx
  4728  	return c
  4729  }
  4730  
  4731  // Header returns a http.Header that can be modified by the caller to add
  4732  // headers to the request.
  4733  func (c *ProjectsLocationsStreamsDeleteCall) Header() http.Header {
  4734  	if c.header_ == nil {
  4735  		c.header_ = make(http.Header)
  4736  	}
  4737  	return c.header_
  4738  }
  4739  
  4740  func (c *ProjectsLocationsStreamsDeleteCall) doRequest(alt string) (*http.Response, error) {
  4741  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  4742  	var body io.Reader = nil
  4743  	c.urlParams_.Set("alt", alt)
  4744  	c.urlParams_.Set("prettyPrint", "false")
  4745  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+name}")
  4746  	urls += "?" + c.urlParams_.Encode()
  4747  	req, err := http.NewRequest("DELETE", urls, body)
  4748  	if err != nil {
  4749  		return nil, err
  4750  	}
  4751  	req.Header = reqHeaders
  4752  	googleapi.Expand(req.URL, map[string]string{
  4753  		"name": c.name,
  4754  	})
  4755  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  4756  }
  4757  
  4758  // Do executes the "datastream.projects.locations.streams.delete" call.
  4759  // Any non-2xx status code is an error. Response headers are in either
  4760  // *Operation.ServerResponse.Header or (if a response was returned at all) in
  4761  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  4762  // whether the returned error was because http.StatusNotModified was returned.
  4763  func (c *ProjectsLocationsStreamsDeleteCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
  4764  	gensupport.SetOptions(c.urlParams_, opts...)
  4765  	res, err := c.doRequest("json")
  4766  	if res != nil && res.StatusCode == http.StatusNotModified {
  4767  		if res.Body != nil {
  4768  			res.Body.Close()
  4769  		}
  4770  		return nil, gensupport.WrapError(&googleapi.Error{
  4771  			Code:   res.StatusCode,
  4772  			Header: res.Header,
  4773  		})
  4774  	}
  4775  	if err != nil {
  4776  		return nil, err
  4777  	}
  4778  	defer googleapi.CloseBody(res)
  4779  	if err := googleapi.CheckResponse(res); err != nil {
  4780  		return nil, gensupport.WrapError(err)
  4781  	}
  4782  	ret := &Operation{
  4783  		ServerResponse: googleapi.ServerResponse{
  4784  			Header:         res.Header,
  4785  			HTTPStatusCode: res.StatusCode,
  4786  		},
  4787  	}
  4788  	target := &ret
  4789  	if err := gensupport.DecodeResponse(target, res); err != nil {
  4790  		return nil, err
  4791  	}
  4792  	return ret, nil
  4793  }
  4794  
  4795  type ProjectsLocationsStreamsFetchErrorsCall struct {
  4796  	s                  *Service
  4797  	stream             string
  4798  	fetcherrorsrequest *FetchErrorsRequest
  4799  	urlParams_         gensupport.URLParams
  4800  	ctx_               context.Context
  4801  	header_            http.Header
  4802  }
  4803  
  4804  // FetchErrors: Use this method to fetch any errors associated with a stream.
  4805  //
  4806  // - stream: Name of the Stream resource for which to fetch any errors.
  4807  func (r *ProjectsLocationsStreamsService) FetchErrors(stream string, fetcherrorsrequest *FetchErrorsRequest) *ProjectsLocationsStreamsFetchErrorsCall {
  4808  	c := &ProjectsLocationsStreamsFetchErrorsCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  4809  	c.stream = stream
  4810  	c.fetcherrorsrequest = fetcherrorsrequest
  4811  	return c
  4812  }
  4813  
  4814  // Fields allows partial responses to be retrieved. See
  4815  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  4816  // details.
  4817  func (c *ProjectsLocationsStreamsFetchErrorsCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsFetchErrorsCall {
  4818  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  4819  	return c
  4820  }
  4821  
  4822  // Context sets the context to be used in this call's Do method.
  4823  func (c *ProjectsLocationsStreamsFetchErrorsCall) Context(ctx context.Context) *ProjectsLocationsStreamsFetchErrorsCall {
  4824  	c.ctx_ = ctx
  4825  	return c
  4826  }
  4827  
  4828  // Header returns a http.Header that can be modified by the caller to add
  4829  // headers to the request.
  4830  func (c *ProjectsLocationsStreamsFetchErrorsCall) Header() http.Header {
  4831  	if c.header_ == nil {
  4832  		c.header_ = make(http.Header)
  4833  	}
  4834  	return c.header_
  4835  }
  4836  
  4837  func (c *ProjectsLocationsStreamsFetchErrorsCall) doRequest(alt string) (*http.Response, error) {
  4838  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
  4839  	var body io.Reader = nil
  4840  	body, err := googleapi.WithoutDataWrapper.JSONReader(c.fetcherrorsrequest)
  4841  	if err != nil {
  4842  		return nil, err
  4843  	}
  4844  	c.urlParams_.Set("alt", alt)
  4845  	c.urlParams_.Set("prettyPrint", "false")
  4846  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+stream}:fetchErrors")
  4847  	urls += "?" + c.urlParams_.Encode()
  4848  	req, err := http.NewRequest("POST", urls, body)
  4849  	if err != nil {
  4850  		return nil, err
  4851  	}
  4852  	req.Header = reqHeaders
  4853  	googleapi.Expand(req.URL, map[string]string{
  4854  		"stream": c.stream,
  4855  	})
  4856  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  4857  }
  4858  
  4859  // Do executes the "datastream.projects.locations.streams.fetchErrors" call.
  4860  // Any non-2xx status code is an error. Response headers are in either
  4861  // *Operation.ServerResponse.Header or (if a response was returned at all) in
  4862  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  4863  // whether the returned error was because http.StatusNotModified was returned.
  4864  func (c *ProjectsLocationsStreamsFetchErrorsCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
  4865  	gensupport.SetOptions(c.urlParams_, opts...)
  4866  	res, err := c.doRequest("json")
  4867  	if res != nil && res.StatusCode == http.StatusNotModified {
  4868  		if res.Body != nil {
  4869  			res.Body.Close()
  4870  		}
  4871  		return nil, gensupport.WrapError(&googleapi.Error{
  4872  			Code:   res.StatusCode,
  4873  			Header: res.Header,
  4874  		})
  4875  	}
  4876  	if err != nil {
  4877  		return nil, err
  4878  	}
  4879  	defer googleapi.CloseBody(res)
  4880  	if err := googleapi.CheckResponse(res); err != nil {
  4881  		return nil, gensupport.WrapError(err)
  4882  	}
  4883  	ret := &Operation{
  4884  		ServerResponse: googleapi.ServerResponse{
  4885  			Header:         res.Header,
  4886  			HTTPStatusCode: res.StatusCode,
  4887  		},
  4888  	}
  4889  	target := &ret
  4890  	if err := gensupport.DecodeResponse(target, res); err != nil {
  4891  		return nil, err
  4892  	}
  4893  	return ret, nil
  4894  }
  4895  
  4896  type ProjectsLocationsStreamsGetCall struct {
  4897  	s            *Service
  4898  	name         string
  4899  	urlParams_   gensupport.URLParams
  4900  	ifNoneMatch_ string
  4901  	ctx_         context.Context
  4902  	header_      http.Header
  4903  }
  4904  
  4905  // Get: Use this method to get details about a stream.
  4906  //
  4907  // - name: The name of the stream resource to get.
  4908  func (r *ProjectsLocationsStreamsService) Get(name string) *ProjectsLocationsStreamsGetCall {
  4909  	c := &ProjectsLocationsStreamsGetCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  4910  	c.name = name
  4911  	return c
  4912  }
  4913  
  4914  // Fields allows partial responses to be retrieved. See
  4915  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  4916  // details.
  4917  func (c *ProjectsLocationsStreamsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsGetCall {
  4918  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  4919  	return c
  4920  }
  4921  
  4922  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  4923  // object's ETag matches the given value. This is useful for getting updates
  4924  // only after the object has changed since the last request.
  4925  func (c *ProjectsLocationsStreamsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsStreamsGetCall {
  4926  	c.ifNoneMatch_ = entityTag
  4927  	return c
  4928  }
  4929  
  4930  // Context sets the context to be used in this call's Do method.
  4931  func (c *ProjectsLocationsStreamsGetCall) Context(ctx context.Context) *ProjectsLocationsStreamsGetCall {
  4932  	c.ctx_ = ctx
  4933  	return c
  4934  }
  4935  
  4936  // Header returns a http.Header that can be modified by the caller to add
  4937  // headers to the request.
  4938  func (c *ProjectsLocationsStreamsGetCall) Header() http.Header {
  4939  	if c.header_ == nil {
  4940  		c.header_ = make(http.Header)
  4941  	}
  4942  	return c.header_
  4943  }
  4944  
  4945  func (c *ProjectsLocationsStreamsGetCall) doRequest(alt string) (*http.Response, error) {
  4946  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  4947  	if c.ifNoneMatch_ != "" {
  4948  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  4949  	}
  4950  	var body io.Reader = nil
  4951  	c.urlParams_.Set("alt", alt)
  4952  	c.urlParams_.Set("prettyPrint", "false")
  4953  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+name}")
  4954  	urls += "?" + c.urlParams_.Encode()
  4955  	req, err := http.NewRequest("GET", urls, body)
  4956  	if err != nil {
  4957  		return nil, err
  4958  	}
  4959  	req.Header = reqHeaders
  4960  	googleapi.Expand(req.URL, map[string]string{
  4961  		"name": c.name,
  4962  	})
  4963  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  4964  }
  4965  
  4966  // Do executes the "datastream.projects.locations.streams.get" call.
  4967  // Any non-2xx status code is an error. Response headers are in either
  4968  // *Stream.ServerResponse.Header or (if a response was returned at all) in
  4969  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  4970  // whether the returned error was because http.StatusNotModified was returned.
  4971  func (c *ProjectsLocationsStreamsGetCall) Do(opts ...googleapi.CallOption) (*Stream, error) {
  4972  	gensupport.SetOptions(c.urlParams_, opts...)
  4973  	res, err := c.doRequest("json")
  4974  	if res != nil && res.StatusCode == http.StatusNotModified {
  4975  		if res.Body != nil {
  4976  			res.Body.Close()
  4977  		}
  4978  		return nil, gensupport.WrapError(&googleapi.Error{
  4979  			Code:   res.StatusCode,
  4980  			Header: res.Header,
  4981  		})
  4982  	}
  4983  	if err != nil {
  4984  		return nil, err
  4985  	}
  4986  	defer googleapi.CloseBody(res)
  4987  	if err := googleapi.CheckResponse(res); err != nil {
  4988  		return nil, gensupport.WrapError(err)
  4989  	}
  4990  	ret := &Stream{
  4991  		ServerResponse: googleapi.ServerResponse{
  4992  			Header:         res.Header,
  4993  			HTTPStatusCode: res.StatusCode,
  4994  		},
  4995  	}
  4996  	target := &ret
  4997  	if err := gensupport.DecodeResponse(target, res); err != nil {
  4998  		return nil, err
  4999  	}
  5000  	return ret, nil
  5001  }
  5002  
  5003  type ProjectsLocationsStreamsListCall struct {
  5004  	s            *Service
  5005  	parent       string
  5006  	urlParams_   gensupport.URLParams
  5007  	ifNoneMatch_ string
  5008  	ctx_         context.Context
  5009  	header_      http.Header
  5010  }
  5011  
  5012  // List: Use this method to list streams in a project and location.
  5013  //
  5014  // - parent: The parent that owns the collection of streams.
  5015  func (r *ProjectsLocationsStreamsService) List(parent string) *ProjectsLocationsStreamsListCall {
  5016  	c := &ProjectsLocationsStreamsListCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  5017  	c.parent = parent
  5018  	return c
  5019  }
  5020  
  5021  // Filter sets the optional parameter "filter": Filter request.
  5022  func (c *ProjectsLocationsStreamsListCall) Filter(filter string) *ProjectsLocationsStreamsListCall {
  5023  	c.urlParams_.Set("filter", filter)
  5024  	return c
  5025  }
  5026  
  5027  // OrderBy sets the optional parameter "orderBy": Order by fields for the
  5028  // result.
  5029  func (c *ProjectsLocationsStreamsListCall) OrderBy(orderBy string) *ProjectsLocationsStreamsListCall {
  5030  	c.urlParams_.Set("orderBy", orderBy)
  5031  	return c
  5032  }
  5033  
  5034  // PageSize sets the optional parameter "pageSize": Maximum number of streams
  5035  // to return. If unspecified, at most 50 streams will be returned. The maximum
  5036  // value is 1000; values above 1000 will be coerced to 1000.
  5037  func (c *ProjectsLocationsStreamsListCall) PageSize(pageSize int64) *ProjectsLocationsStreamsListCall {
  5038  	c.urlParams_.Set("pageSize", fmt.Sprint(pageSize))
  5039  	return c
  5040  }
  5041  
  5042  // PageToken sets the optional parameter "pageToken": Page token received from
  5043  // a previous `ListStreams` call. Provide this to retrieve the subsequent page.
  5044  // When paginating, all other parameters provided to `ListStreams` must match
  5045  // the call that provided the page token.
  5046  func (c *ProjectsLocationsStreamsListCall) PageToken(pageToken string) *ProjectsLocationsStreamsListCall {
  5047  	c.urlParams_.Set("pageToken", pageToken)
  5048  	return c
  5049  }
  5050  
  5051  // Fields allows partial responses to be retrieved. See
  5052  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  5053  // details.
  5054  func (c *ProjectsLocationsStreamsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsListCall {
  5055  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  5056  	return c
  5057  }
  5058  
  5059  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  5060  // object's ETag matches the given value. This is useful for getting updates
  5061  // only after the object has changed since the last request.
  5062  func (c *ProjectsLocationsStreamsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsStreamsListCall {
  5063  	c.ifNoneMatch_ = entityTag
  5064  	return c
  5065  }
  5066  
  5067  // Context sets the context to be used in this call's Do method.
  5068  func (c *ProjectsLocationsStreamsListCall) Context(ctx context.Context) *ProjectsLocationsStreamsListCall {
  5069  	c.ctx_ = ctx
  5070  	return c
  5071  }
  5072  
  5073  // Header returns a http.Header that can be modified by the caller to add
  5074  // headers to the request.
  5075  func (c *ProjectsLocationsStreamsListCall) Header() http.Header {
  5076  	if c.header_ == nil {
  5077  		c.header_ = make(http.Header)
  5078  	}
  5079  	return c.header_
  5080  }
  5081  
  5082  func (c *ProjectsLocationsStreamsListCall) doRequest(alt string) (*http.Response, error) {
  5083  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  5084  	if c.ifNoneMatch_ != "" {
  5085  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  5086  	}
  5087  	var body io.Reader = nil
  5088  	c.urlParams_.Set("alt", alt)
  5089  	c.urlParams_.Set("prettyPrint", "false")
  5090  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+parent}/streams")
  5091  	urls += "?" + c.urlParams_.Encode()
  5092  	req, err := http.NewRequest("GET", urls, body)
  5093  	if err != nil {
  5094  		return nil, err
  5095  	}
  5096  	req.Header = reqHeaders
  5097  	googleapi.Expand(req.URL, map[string]string{
  5098  		"parent": c.parent,
  5099  	})
  5100  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  5101  }
  5102  
  5103  // Do executes the "datastream.projects.locations.streams.list" call.
  5104  // Any non-2xx status code is an error. Response headers are in either
  5105  // *ListStreamsResponse.ServerResponse.Header or (if a response was returned at
  5106  // all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to
  5107  // check whether the returned error was because http.StatusNotModified was
  5108  // returned.
  5109  func (c *ProjectsLocationsStreamsListCall) Do(opts ...googleapi.CallOption) (*ListStreamsResponse, error) {
  5110  	gensupport.SetOptions(c.urlParams_, opts...)
  5111  	res, err := c.doRequest("json")
  5112  	if res != nil && res.StatusCode == http.StatusNotModified {
  5113  		if res.Body != nil {
  5114  			res.Body.Close()
  5115  		}
  5116  		return nil, gensupport.WrapError(&googleapi.Error{
  5117  			Code:   res.StatusCode,
  5118  			Header: res.Header,
  5119  		})
  5120  	}
  5121  	if err != nil {
  5122  		return nil, err
  5123  	}
  5124  	defer googleapi.CloseBody(res)
  5125  	if err := googleapi.CheckResponse(res); err != nil {
  5126  		return nil, gensupport.WrapError(err)
  5127  	}
  5128  	ret := &ListStreamsResponse{
  5129  		ServerResponse: googleapi.ServerResponse{
  5130  			Header:         res.Header,
  5131  			HTTPStatusCode: res.StatusCode,
  5132  		},
  5133  	}
  5134  	target := &ret
  5135  	if err := gensupport.DecodeResponse(target, res); err != nil {
  5136  		return nil, err
  5137  	}
  5138  	return ret, nil
  5139  }
  5140  
  5141  // Pages invokes f for each page of results.
  5142  // A non-nil error returned from f will halt the iteration.
  5143  // The provided context supersedes any context provided to the Context method.
  5144  func (c *ProjectsLocationsStreamsListCall) Pages(ctx context.Context, f func(*ListStreamsResponse) error) error {
  5145  	c.ctx_ = ctx
  5146  	defer c.PageToken(c.urlParams_.Get("pageToken"))
  5147  	for {
  5148  		x, err := c.Do()
  5149  		if err != nil {
  5150  			return err
  5151  		}
  5152  		if err := f(x); err != nil {
  5153  			return err
  5154  		}
  5155  		if x.NextPageToken == "" {
  5156  			return nil
  5157  		}
  5158  		c.PageToken(x.NextPageToken)
  5159  	}
  5160  }
  5161  
  5162  type ProjectsLocationsStreamsPatchCall struct {
  5163  	s          *Service
  5164  	name       string
  5165  	stream     *Stream
  5166  	urlParams_ gensupport.URLParams
  5167  	ctx_       context.Context
  5168  	header_    http.Header
  5169  }
  5170  
  5171  // Patch: Use this method to update the configuration of a stream.
  5172  //
  5173  // - name: Output only. The stream's name.
  5174  func (r *ProjectsLocationsStreamsService) Patch(name string, stream *Stream) *ProjectsLocationsStreamsPatchCall {
  5175  	c := &ProjectsLocationsStreamsPatchCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  5176  	c.name = name
  5177  	c.stream = stream
  5178  	return c
  5179  }
  5180  
  5181  // Force sets the optional parameter "force": Execute the update without
  5182  // validating it.
  5183  func (c *ProjectsLocationsStreamsPatchCall) Force(force bool) *ProjectsLocationsStreamsPatchCall {
  5184  	c.urlParams_.Set("force", fmt.Sprint(force))
  5185  	return c
  5186  }
  5187  
  5188  // RequestId sets the optional parameter "requestId": A request ID to identify
  5189  // requests. Specify a unique request ID so that if you must retry your
  5190  // request, the server will know to ignore the request if it has already been
  5191  // completed. The server will guarantee that for at least 60 minutes since the
  5192  // first request. For example, consider a situation where you make an initial
  5193  // request and the request times out. If you make the request again with the
  5194  // same request ID, the server can check if original operation with the same
  5195  // request ID was received, and if so, will ignore the second request. This
  5196  // prevents clients from accidentally creating duplicate commitments. The
  5197  // request ID must be a valid UUID with the exception that zero UUID is not
  5198  // supported (00000000-0000-0000-0000-000000000000).
  5199  func (c *ProjectsLocationsStreamsPatchCall) RequestId(requestId string) *ProjectsLocationsStreamsPatchCall {
  5200  	c.urlParams_.Set("requestId", requestId)
  5201  	return c
  5202  }
  5203  
  5204  // UpdateMask sets the optional parameter "updateMask": Field mask is used to
  5205  // specify the fields to be overwritten in the stream resource by the update.
  5206  // The fields specified in the update_mask are relative to the resource, not
  5207  // the full request. A field will be overwritten if it is in the mask. If the
  5208  // user does not provide a mask then all fields will be overwritten.
  5209  func (c *ProjectsLocationsStreamsPatchCall) UpdateMask(updateMask string) *ProjectsLocationsStreamsPatchCall {
  5210  	c.urlParams_.Set("updateMask", updateMask)
  5211  	return c
  5212  }
  5213  
  5214  // ValidateOnly sets the optional parameter "validateOnly": Only validate the
  5215  // stream with the changes, without actually updating it. The default is false.
  5216  func (c *ProjectsLocationsStreamsPatchCall) ValidateOnly(validateOnly bool) *ProjectsLocationsStreamsPatchCall {
  5217  	c.urlParams_.Set("validateOnly", fmt.Sprint(validateOnly))
  5218  	return c
  5219  }
  5220  
  5221  // Fields allows partial responses to be retrieved. See
  5222  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  5223  // details.
  5224  func (c *ProjectsLocationsStreamsPatchCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsPatchCall {
  5225  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  5226  	return c
  5227  }
  5228  
  5229  // Context sets the context to be used in this call's Do method.
  5230  func (c *ProjectsLocationsStreamsPatchCall) Context(ctx context.Context) *ProjectsLocationsStreamsPatchCall {
  5231  	c.ctx_ = ctx
  5232  	return c
  5233  }
  5234  
  5235  // Header returns a http.Header that can be modified by the caller to add
  5236  // headers to the request.
  5237  func (c *ProjectsLocationsStreamsPatchCall) Header() http.Header {
  5238  	if c.header_ == nil {
  5239  		c.header_ = make(http.Header)
  5240  	}
  5241  	return c.header_
  5242  }
  5243  
  5244  func (c *ProjectsLocationsStreamsPatchCall) doRequest(alt string) (*http.Response, error) {
  5245  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
  5246  	var body io.Reader = nil
  5247  	body, err := googleapi.WithoutDataWrapper.JSONReader(c.stream)
  5248  	if err != nil {
  5249  		return nil, err
  5250  	}
  5251  	c.urlParams_.Set("alt", alt)
  5252  	c.urlParams_.Set("prettyPrint", "false")
  5253  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+name}")
  5254  	urls += "?" + c.urlParams_.Encode()
  5255  	req, err := http.NewRequest("PATCH", urls, body)
  5256  	if err != nil {
  5257  		return nil, err
  5258  	}
  5259  	req.Header = reqHeaders
  5260  	googleapi.Expand(req.URL, map[string]string{
  5261  		"name": c.name,
  5262  	})
  5263  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  5264  }
  5265  
  5266  // Do executes the "datastream.projects.locations.streams.patch" call.
  5267  // Any non-2xx status code is an error. Response headers are in either
  5268  // *Operation.ServerResponse.Header or (if a response was returned at all) in
  5269  // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  5270  // whether the returned error was because http.StatusNotModified was returned.
  5271  func (c *ProjectsLocationsStreamsPatchCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
  5272  	gensupport.SetOptions(c.urlParams_, opts...)
  5273  	res, err := c.doRequest("json")
  5274  	if res != nil && res.StatusCode == http.StatusNotModified {
  5275  		if res.Body != nil {
  5276  			res.Body.Close()
  5277  		}
  5278  		return nil, gensupport.WrapError(&googleapi.Error{
  5279  			Code:   res.StatusCode,
  5280  			Header: res.Header,
  5281  		})
  5282  	}
  5283  	if err != nil {
  5284  		return nil, err
  5285  	}
  5286  	defer googleapi.CloseBody(res)
  5287  	if err := googleapi.CheckResponse(res); err != nil {
  5288  		return nil, gensupport.WrapError(err)
  5289  	}
  5290  	ret := &Operation{
  5291  		ServerResponse: googleapi.ServerResponse{
  5292  			Header:         res.Header,
  5293  			HTTPStatusCode: res.StatusCode,
  5294  		},
  5295  	}
  5296  	target := &ret
  5297  	if err := gensupport.DecodeResponse(target, res); err != nil {
  5298  		return nil, err
  5299  	}
  5300  	return ret, nil
  5301  }
  5302  
  5303  type ProjectsLocationsStreamsObjectsGetCall struct {
  5304  	s            *Service
  5305  	name         string
  5306  	urlParams_   gensupport.URLParams
  5307  	ifNoneMatch_ string
  5308  	ctx_         context.Context
  5309  	header_      http.Header
  5310  }
  5311  
  5312  // Get: Use this method to get details about a stream object.
  5313  //
  5314  // - name: The name of the stream object resource to get.
  5315  func (r *ProjectsLocationsStreamsObjectsService) Get(name string) *ProjectsLocationsStreamsObjectsGetCall {
  5316  	c := &ProjectsLocationsStreamsObjectsGetCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  5317  	c.name = name
  5318  	return c
  5319  }
  5320  
  5321  // Fields allows partial responses to be retrieved. See
  5322  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  5323  // details.
  5324  func (c *ProjectsLocationsStreamsObjectsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsObjectsGetCall {
  5325  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  5326  	return c
  5327  }
  5328  
  5329  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  5330  // object's ETag matches the given value. This is useful for getting updates
  5331  // only after the object has changed since the last request.
  5332  func (c *ProjectsLocationsStreamsObjectsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsStreamsObjectsGetCall {
  5333  	c.ifNoneMatch_ = entityTag
  5334  	return c
  5335  }
  5336  
  5337  // Context sets the context to be used in this call's Do method.
  5338  func (c *ProjectsLocationsStreamsObjectsGetCall) Context(ctx context.Context) *ProjectsLocationsStreamsObjectsGetCall {
  5339  	c.ctx_ = ctx
  5340  	return c
  5341  }
  5342  
  5343  // Header returns a http.Header that can be modified by the caller to add
  5344  // headers to the request.
  5345  func (c *ProjectsLocationsStreamsObjectsGetCall) Header() http.Header {
  5346  	if c.header_ == nil {
  5347  		c.header_ = make(http.Header)
  5348  	}
  5349  	return c.header_
  5350  }
  5351  
  5352  func (c *ProjectsLocationsStreamsObjectsGetCall) doRequest(alt string) (*http.Response, error) {
  5353  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  5354  	if c.ifNoneMatch_ != "" {
  5355  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  5356  	}
  5357  	var body io.Reader = nil
  5358  	c.urlParams_.Set("alt", alt)
  5359  	c.urlParams_.Set("prettyPrint", "false")
  5360  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+name}")
  5361  	urls += "?" + c.urlParams_.Encode()
  5362  	req, err := http.NewRequest("GET", urls, body)
  5363  	if err != nil {
  5364  		return nil, err
  5365  	}
  5366  	req.Header = reqHeaders
  5367  	googleapi.Expand(req.URL, map[string]string{
  5368  		"name": c.name,
  5369  	})
  5370  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  5371  }
  5372  
  5373  // Do executes the "datastream.projects.locations.streams.objects.get" call.
  5374  // Any non-2xx status code is an error. Response headers are in either
  5375  // *StreamObject.ServerResponse.Header or (if a response was returned at all)
  5376  // in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check
  5377  // whether the returned error was because http.StatusNotModified was returned.
  5378  func (c *ProjectsLocationsStreamsObjectsGetCall) Do(opts ...googleapi.CallOption) (*StreamObject, error) {
  5379  	gensupport.SetOptions(c.urlParams_, opts...)
  5380  	res, err := c.doRequest("json")
  5381  	if res != nil && res.StatusCode == http.StatusNotModified {
  5382  		if res.Body != nil {
  5383  			res.Body.Close()
  5384  		}
  5385  		return nil, gensupport.WrapError(&googleapi.Error{
  5386  			Code:   res.StatusCode,
  5387  			Header: res.Header,
  5388  		})
  5389  	}
  5390  	if err != nil {
  5391  		return nil, err
  5392  	}
  5393  	defer googleapi.CloseBody(res)
  5394  	if err := googleapi.CheckResponse(res); err != nil {
  5395  		return nil, gensupport.WrapError(err)
  5396  	}
  5397  	ret := &StreamObject{
  5398  		ServerResponse: googleapi.ServerResponse{
  5399  			Header:         res.Header,
  5400  			HTTPStatusCode: res.StatusCode,
  5401  		},
  5402  	}
  5403  	target := &ret
  5404  	if err := gensupport.DecodeResponse(target, res); err != nil {
  5405  		return nil, err
  5406  	}
  5407  	return ret, nil
  5408  }
  5409  
  5410  type ProjectsLocationsStreamsObjectsListCall struct {
  5411  	s            *Service
  5412  	parent       string
  5413  	urlParams_   gensupport.URLParams
  5414  	ifNoneMatch_ string
  5415  	ctx_         context.Context
  5416  	header_      http.Header
  5417  }
  5418  
  5419  // List: Use this method to list the objects of a specific stream.
  5420  //
  5421  // - parent: The parent stream that owns the collection of objects.
  5422  func (r *ProjectsLocationsStreamsObjectsService) List(parent string) *ProjectsLocationsStreamsObjectsListCall {
  5423  	c := &ProjectsLocationsStreamsObjectsListCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  5424  	c.parent = parent
  5425  	return c
  5426  }
  5427  
  5428  // PageSize sets the optional parameter "pageSize": Maximum number of objects
  5429  // to return. Default is 50. The maximum value is 1000; values above 1000 will
  5430  // be coerced to 1000.
  5431  func (c *ProjectsLocationsStreamsObjectsListCall) PageSize(pageSize int64) *ProjectsLocationsStreamsObjectsListCall {
  5432  	c.urlParams_.Set("pageSize", fmt.Sprint(pageSize))
  5433  	return c
  5434  }
  5435  
  5436  // PageToken sets the optional parameter "pageToken": Page token received from
  5437  // a previous `ListStreamObjectsRequest` call. Provide this to retrieve the
  5438  // subsequent page. When paginating, all other parameters provided to
  5439  // `ListStreamObjectsRequest` must match the call that provided the page token.
  5440  func (c *ProjectsLocationsStreamsObjectsListCall) PageToken(pageToken string) *ProjectsLocationsStreamsObjectsListCall {
  5441  	c.urlParams_.Set("pageToken", pageToken)
  5442  	return c
  5443  }
  5444  
  5445  // Fields allows partial responses to be retrieved. See
  5446  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  5447  // details.
  5448  func (c *ProjectsLocationsStreamsObjectsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsObjectsListCall {
  5449  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  5450  	return c
  5451  }
  5452  
  5453  // IfNoneMatch sets an optional parameter which makes the operation fail if the
  5454  // object's ETag matches the given value. This is useful for getting updates
  5455  // only after the object has changed since the last request.
  5456  func (c *ProjectsLocationsStreamsObjectsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsStreamsObjectsListCall {
  5457  	c.ifNoneMatch_ = entityTag
  5458  	return c
  5459  }
  5460  
  5461  // Context sets the context to be used in this call's Do method.
  5462  func (c *ProjectsLocationsStreamsObjectsListCall) Context(ctx context.Context) *ProjectsLocationsStreamsObjectsListCall {
  5463  	c.ctx_ = ctx
  5464  	return c
  5465  }
  5466  
  5467  // Header returns a http.Header that can be modified by the caller to add
  5468  // headers to the request.
  5469  func (c *ProjectsLocationsStreamsObjectsListCall) Header() http.Header {
  5470  	if c.header_ == nil {
  5471  		c.header_ = make(http.Header)
  5472  	}
  5473  	return c.header_
  5474  }
  5475  
  5476  func (c *ProjectsLocationsStreamsObjectsListCall) doRequest(alt string) (*http.Response, error) {
  5477  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  5478  	if c.ifNoneMatch_ != "" {
  5479  		reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
  5480  	}
  5481  	var body io.Reader = nil
  5482  	c.urlParams_.Set("alt", alt)
  5483  	c.urlParams_.Set("prettyPrint", "false")
  5484  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+parent}/objects")
  5485  	urls += "?" + c.urlParams_.Encode()
  5486  	req, err := http.NewRequest("GET", urls, body)
  5487  	if err != nil {
  5488  		return nil, err
  5489  	}
  5490  	req.Header = reqHeaders
  5491  	googleapi.Expand(req.URL, map[string]string{
  5492  		"parent": c.parent,
  5493  	})
  5494  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  5495  }
  5496  
  5497  // Do executes the "datastream.projects.locations.streams.objects.list" call.
  5498  // Any non-2xx status code is an error. Response headers are in either
  5499  // *ListStreamObjectsResponse.ServerResponse.Header or (if a response was
  5500  // returned at all) in error.(*googleapi.Error).Header. Use
  5501  // googleapi.IsNotModified to check whether the returned error was because
  5502  // http.StatusNotModified was returned.
  5503  func (c *ProjectsLocationsStreamsObjectsListCall) Do(opts ...googleapi.CallOption) (*ListStreamObjectsResponse, error) {
  5504  	gensupport.SetOptions(c.urlParams_, opts...)
  5505  	res, err := c.doRequest("json")
  5506  	if res != nil && res.StatusCode == http.StatusNotModified {
  5507  		if res.Body != nil {
  5508  			res.Body.Close()
  5509  		}
  5510  		return nil, gensupport.WrapError(&googleapi.Error{
  5511  			Code:   res.StatusCode,
  5512  			Header: res.Header,
  5513  		})
  5514  	}
  5515  	if err != nil {
  5516  		return nil, err
  5517  	}
  5518  	defer googleapi.CloseBody(res)
  5519  	if err := googleapi.CheckResponse(res); err != nil {
  5520  		return nil, gensupport.WrapError(err)
  5521  	}
  5522  	ret := &ListStreamObjectsResponse{
  5523  		ServerResponse: googleapi.ServerResponse{
  5524  			Header:         res.Header,
  5525  			HTTPStatusCode: res.StatusCode,
  5526  		},
  5527  	}
  5528  	target := &ret
  5529  	if err := gensupport.DecodeResponse(target, res); err != nil {
  5530  		return nil, err
  5531  	}
  5532  	return ret, nil
  5533  }
  5534  
  5535  // Pages invokes f for each page of results.
  5536  // A non-nil error returned from f will halt the iteration.
  5537  // The provided context supersedes any context provided to the Context method.
  5538  func (c *ProjectsLocationsStreamsObjectsListCall) Pages(ctx context.Context, f func(*ListStreamObjectsResponse) error) error {
  5539  	c.ctx_ = ctx
  5540  	defer c.PageToken(c.urlParams_.Get("pageToken"))
  5541  	for {
  5542  		x, err := c.Do()
  5543  		if err != nil {
  5544  			return err
  5545  		}
  5546  		if err := f(x); err != nil {
  5547  			return err
  5548  		}
  5549  		if x.NextPageToken == "" {
  5550  			return nil
  5551  		}
  5552  		c.PageToken(x.NextPageToken)
  5553  	}
  5554  }
  5555  
  5556  type ProjectsLocationsStreamsObjectsStartBackfillJobCall struct {
  5557  	s          *Service
  5558  	object     string
  5559  	urlParams_ gensupport.URLParams
  5560  	ctx_       context.Context
  5561  	header_    http.Header
  5562  }
  5563  
  5564  // StartBackfillJob: Starts backfill job for the specified stream object.
  5565  //
  5566  //   - object: The name of the stream object resource to start a backfill job
  5567  //     for.
  5568  func (r *ProjectsLocationsStreamsObjectsService) StartBackfillJob(object string) *ProjectsLocationsStreamsObjectsStartBackfillJobCall {
  5569  	c := &ProjectsLocationsStreamsObjectsStartBackfillJobCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  5570  	c.object = object
  5571  	return c
  5572  }
  5573  
  5574  // Fields allows partial responses to be retrieved. See
  5575  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  5576  // details.
  5577  func (c *ProjectsLocationsStreamsObjectsStartBackfillJobCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsObjectsStartBackfillJobCall {
  5578  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  5579  	return c
  5580  }
  5581  
  5582  // Context sets the context to be used in this call's Do method.
  5583  func (c *ProjectsLocationsStreamsObjectsStartBackfillJobCall) Context(ctx context.Context) *ProjectsLocationsStreamsObjectsStartBackfillJobCall {
  5584  	c.ctx_ = ctx
  5585  	return c
  5586  }
  5587  
  5588  // Header returns a http.Header that can be modified by the caller to add
  5589  // headers to the request.
  5590  func (c *ProjectsLocationsStreamsObjectsStartBackfillJobCall) Header() http.Header {
  5591  	if c.header_ == nil {
  5592  		c.header_ = make(http.Header)
  5593  	}
  5594  	return c.header_
  5595  }
  5596  
  5597  func (c *ProjectsLocationsStreamsObjectsStartBackfillJobCall) doRequest(alt string) (*http.Response, error) {
  5598  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  5599  	var body io.Reader = nil
  5600  	c.urlParams_.Set("alt", alt)
  5601  	c.urlParams_.Set("prettyPrint", "false")
  5602  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+object}:startBackfillJob")
  5603  	urls += "?" + c.urlParams_.Encode()
  5604  	req, err := http.NewRequest("POST", urls, body)
  5605  	if err != nil {
  5606  		return nil, err
  5607  	}
  5608  	req.Header = reqHeaders
  5609  	googleapi.Expand(req.URL, map[string]string{
  5610  		"object": c.object,
  5611  	})
  5612  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  5613  }
  5614  
  5615  // Do executes the "datastream.projects.locations.streams.objects.startBackfillJob" call.
  5616  // Any non-2xx status code is an error. Response headers are in either
  5617  // *StartBackfillJobResponse.ServerResponse.Header or (if a response was
  5618  // returned at all) in error.(*googleapi.Error).Header. Use
  5619  // googleapi.IsNotModified to check whether the returned error was because
  5620  // http.StatusNotModified was returned.
  5621  func (c *ProjectsLocationsStreamsObjectsStartBackfillJobCall) Do(opts ...googleapi.CallOption) (*StartBackfillJobResponse, error) {
  5622  	gensupport.SetOptions(c.urlParams_, opts...)
  5623  	res, err := c.doRequest("json")
  5624  	if res != nil && res.StatusCode == http.StatusNotModified {
  5625  		if res.Body != nil {
  5626  			res.Body.Close()
  5627  		}
  5628  		return nil, gensupport.WrapError(&googleapi.Error{
  5629  			Code:   res.StatusCode,
  5630  			Header: res.Header,
  5631  		})
  5632  	}
  5633  	if err != nil {
  5634  		return nil, err
  5635  	}
  5636  	defer googleapi.CloseBody(res)
  5637  	if err := googleapi.CheckResponse(res); err != nil {
  5638  		return nil, gensupport.WrapError(err)
  5639  	}
  5640  	ret := &StartBackfillJobResponse{
  5641  		ServerResponse: googleapi.ServerResponse{
  5642  			Header:         res.Header,
  5643  			HTTPStatusCode: res.StatusCode,
  5644  		},
  5645  	}
  5646  	target := &ret
  5647  	if err := gensupport.DecodeResponse(target, res); err != nil {
  5648  		return nil, err
  5649  	}
  5650  	return ret, nil
  5651  }
  5652  
  5653  type ProjectsLocationsStreamsObjectsStopBackfillJobCall struct {
  5654  	s          *Service
  5655  	object     string
  5656  	urlParams_ gensupport.URLParams
  5657  	ctx_       context.Context
  5658  	header_    http.Header
  5659  }
  5660  
  5661  // StopBackfillJob: Stops the backfill job for the specified stream object.
  5662  //
  5663  //   - object: The name of the stream object resource to stop the backfill job
  5664  //     for.
  5665  func (r *ProjectsLocationsStreamsObjectsService) StopBackfillJob(object string) *ProjectsLocationsStreamsObjectsStopBackfillJobCall {
  5666  	c := &ProjectsLocationsStreamsObjectsStopBackfillJobCall{s: r.s, urlParams_: make(gensupport.URLParams)}
  5667  	c.object = object
  5668  	return c
  5669  }
  5670  
  5671  // Fields allows partial responses to be retrieved. See
  5672  // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more
  5673  // details.
  5674  func (c *ProjectsLocationsStreamsObjectsStopBackfillJobCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsObjectsStopBackfillJobCall {
  5675  	c.urlParams_.Set("fields", googleapi.CombineFields(s))
  5676  	return c
  5677  }
  5678  
  5679  // Context sets the context to be used in this call's Do method.
  5680  func (c *ProjectsLocationsStreamsObjectsStopBackfillJobCall) Context(ctx context.Context) *ProjectsLocationsStreamsObjectsStopBackfillJobCall {
  5681  	c.ctx_ = ctx
  5682  	return c
  5683  }
  5684  
  5685  // Header returns a http.Header that can be modified by the caller to add
  5686  // headers to the request.
  5687  func (c *ProjectsLocationsStreamsObjectsStopBackfillJobCall) Header() http.Header {
  5688  	if c.header_ == nil {
  5689  		c.header_ = make(http.Header)
  5690  	}
  5691  	return c.header_
  5692  }
  5693  
  5694  func (c *ProjectsLocationsStreamsObjectsStopBackfillJobCall) doRequest(alt string) (*http.Response, error) {
  5695  	reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
  5696  	var body io.Reader = nil
  5697  	c.urlParams_.Set("alt", alt)
  5698  	c.urlParams_.Set("prettyPrint", "false")
  5699  	urls := googleapi.ResolveRelative(c.s.BasePath, "v1alpha1/{+object}:stopBackfillJob")
  5700  	urls += "?" + c.urlParams_.Encode()
  5701  	req, err := http.NewRequest("POST", urls, body)
  5702  	if err != nil {
  5703  		return nil, err
  5704  	}
  5705  	req.Header = reqHeaders
  5706  	googleapi.Expand(req.URL, map[string]string{
  5707  		"object": c.object,
  5708  	})
  5709  	return gensupport.SendRequest(c.ctx_, c.s.client, req)
  5710  }
  5711  
  5712  // Do executes the "datastream.projects.locations.streams.objects.stopBackfillJob" call.
  5713  // Any non-2xx status code is an error. Response headers are in either
  5714  // *StopBackfillJobResponse.ServerResponse.Header or (if a response was
  5715  // returned at all) in error.(*googleapi.Error).Header. Use
  5716  // googleapi.IsNotModified to check whether the returned error was because
  5717  // http.StatusNotModified was returned.
  5718  func (c *ProjectsLocationsStreamsObjectsStopBackfillJobCall) Do(opts ...googleapi.CallOption) (*StopBackfillJobResponse, error) {
  5719  	gensupport.SetOptions(c.urlParams_, opts...)
  5720  	res, err := c.doRequest("json")
  5721  	if res != nil && res.StatusCode == http.StatusNotModified {
  5722  		if res.Body != nil {
  5723  			res.Body.Close()
  5724  		}
  5725  		return nil, gensupport.WrapError(&googleapi.Error{
  5726  			Code:   res.StatusCode,
  5727  			Header: res.Header,
  5728  		})
  5729  	}
  5730  	if err != nil {
  5731  		return nil, err
  5732  	}
  5733  	defer googleapi.CloseBody(res)
  5734  	if err := googleapi.CheckResponse(res); err != nil {
  5735  		return nil, gensupport.WrapError(err)
  5736  	}
  5737  	ret := &StopBackfillJobResponse{
  5738  		ServerResponse: googleapi.ServerResponse{
  5739  			Header:         res.Header,
  5740  			HTTPStatusCode: res.StatusCode,
  5741  		},
  5742  	}
  5743  	target := &ret
  5744  	if err := gensupport.DecodeResponse(target, res); err != nil {
  5745  		return nil, err
  5746  	}
  5747  	return ret, nil
  5748  }
  5749  

View as plain text