Documentation
¶
Overview ¶
Package datastream provides access to the Datastream API.
For product documentation, see: https://cloud.google.com/datastream/
Library status ¶
These client libraries are officially supported by Google. However, this library is considered complete and is in maintenance mode. This means that we will address critical bugs and security issues but will not add any new features.
When possible, we recommend using our newer [Cloud Client Libraries for Go](https://pkg.go.dev/cloud.google.com/go) that are still actively being worked and iterated on.
Creating a client ¶
Usage example:
import "google.golang.org/api/datastream/v1" ... ctx := context.Background() datastreamService, err := datastream.NewService(ctx)
In this example, Google Application Default Credentials are used for authentication. For information on how to create and obtain Application Default Credentials, see https://developers.google.com/identity/protocols/application-default-credentials.
Other authentication options ¶
To use an API key for authentication (note: some APIs do not support API keys), use google.golang.org/api/option.WithAPIKey:
datastreamService, err := datastream.NewService(ctx, option.WithAPIKey("AIza..."))
To use an OAuth token (e.g., a user token obtained via a three-legged OAuth flow, use google.golang.org/api/option.WithTokenSource:
config := &oauth2.Config{...} // ... token, err := config.Exchange(ctx, ...) datastreamService, err := datastream.NewService(ctx, option.WithTokenSource(config.TokenSource(ctx, token)))
See google.golang.org/api/option.ClientOption for details on options.
Index ¶
- Constants
- type AvroFileFormat
- type BackfillAllStrategy
- type BackfillJob
- type BackfillNoneStrategy
- type BigQueryDestinationConfig
- type BigQueryProfile
- type CancelOperationRequest
- type CdcStrategy
- type ConnectionProfile
- type DatasetTemplate
- type DestinationConfig
- type DiscoverConnectionProfileRequest
- type DiscoverConnectionProfileResponse
- type DropLargeObjects
- type Empty
- type Error
- type FetchStaticIpsResponse
- type ForwardSshTunnelConnectivity
- type GcsDestinationConfig
- type GcsProfile
- type JsonFileFormat
- type ListConnectionProfilesResponse
- type ListLocationsResponse
- type ListOperationsResponse
- type ListPrivateConnectionsResponse
- type ListRoutesResponse
- type ListStreamObjectsResponse
- type ListStreamsResponse
- type Location
- type LookupStreamObjectRequest
- type MostRecentStartPosition
- type MysqlColumn
- type MysqlDatabase
- type MysqlLogPosition
- type MysqlObjectIdentifier
- type MysqlProfile
- type MysqlRdbms
- type MysqlSourceConfig
- type MysqlSslConfig
- type MysqlTable
- type NextAvailableStartPosition
- type Operation
- type OperationMetadata
- type OracleColumn
- type OracleObjectIdentifier
- type OracleProfile
- type OracleRdbms
- type OracleSchema
- type OracleSourceConfig
- type OracleSslConfig
- type OracleTable
- type PostgresqlColumn
- type PostgresqlObjectIdentifier
- type PostgresqlProfile
- type PostgresqlRdbms
- type PostgresqlSchema
- type PostgresqlSourceConfig
- type PostgresqlTable
- type PrivateConnection
- type PrivateConnectivity
- type ProjectsLocationsConnectionProfilesCreateCall
- func (c *ProjectsLocationsConnectionProfilesCreateCall) ConnectionProfileId(connectionProfileId string) *ProjectsLocationsConnectionProfilesCreateCall
- func (c *ProjectsLocationsConnectionProfilesCreateCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesCreateCall
- func (c *ProjectsLocationsConnectionProfilesCreateCall) Do(opts ...googleapi.CallOption) (*Operation, error)
- func (c *ProjectsLocationsConnectionProfilesCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesCreateCall
- func (c *ProjectsLocationsConnectionProfilesCreateCall) Force(force bool) *ProjectsLocationsConnectionProfilesCreateCall
- func (c *ProjectsLocationsConnectionProfilesCreateCall) Header() http.Header
- func (c *ProjectsLocationsConnectionProfilesCreateCall) RequestId(requestId string) *ProjectsLocationsConnectionProfilesCreateCall
- func (c *ProjectsLocationsConnectionProfilesCreateCall) ValidateOnly(validateOnly bool) *ProjectsLocationsConnectionProfilesCreateCall
- type ProjectsLocationsConnectionProfilesDeleteCall
- func (c *ProjectsLocationsConnectionProfilesDeleteCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesDeleteCall
- func (c *ProjectsLocationsConnectionProfilesDeleteCall) Do(opts ...googleapi.CallOption) (*Operation, error)
- func (c *ProjectsLocationsConnectionProfilesDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesDeleteCall
- func (c *ProjectsLocationsConnectionProfilesDeleteCall) Header() http.Header
- func (c *ProjectsLocationsConnectionProfilesDeleteCall) RequestId(requestId string) *ProjectsLocationsConnectionProfilesDeleteCall
- type ProjectsLocationsConnectionProfilesDiscoverCall
- func (c *ProjectsLocationsConnectionProfilesDiscoverCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesDiscoverCall
- func (c *ProjectsLocationsConnectionProfilesDiscoverCall) Do(opts ...googleapi.CallOption) (*DiscoverConnectionProfileResponse, error)
- func (c *ProjectsLocationsConnectionProfilesDiscoverCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesDiscoverCall
- func (c *ProjectsLocationsConnectionProfilesDiscoverCall) Header() http.Header
- type ProjectsLocationsConnectionProfilesGetCall
- func (c *ProjectsLocationsConnectionProfilesGetCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesGetCall
- func (c *ProjectsLocationsConnectionProfilesGetCall) Do(opts ...googleapi.CallOption) (*ConnectionProfile, error)
- func (c *ProjectsLocationsConnectionProfilesGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesGetCall
- func (c *ProjectsLocationsConnectionProfilesGetCall) Header() http.Header
- func (c *ProjectsLocationsConnectionProfilesGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsConnectionProfilesGetCall
- type ProjectsLocationsConnectionProfilesListCall
- func (c *ProjectsLocationsConnectionProfilesListCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesListCall
- func (c *ProjectsLocationsConnectionProfilesListCall) Do(opts ...googleapi.CallOption) (*ListConnectionProfilesResponse, error)
- func (c *ProjectsLocationsConnectionProfilesListCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesListCall
- func (c *ProjectsLocationsConnectionProfilesListCall) Filter(filter string) *ProjectsLocationsConnectionProfilesListCall
- func (c *ProjectsLocationsConnectionProfilesListCall) Header() http.Header
- func (c *ProjectsLocationsConnectionProfilesListCall) IfNoneMatch(entityTag string) *ProjectsLocationsConnectionProfilesListCall
- func (c *ProjectsLocationsConnectionProfilesListCall) OrderBy(orderBy string) *ProjectsLocationsConnectionProfilesListCall
- func (c *ProjectsLocationsConnectionProfilesListCall) PageSize(pageSize int64) *ProjectsLocationsConnectionProfilesListCall
- func (c *ProjectsLocationsConnectionProfilesListCall) PageToken(pageToken string) *ProjectsLocationsConnectionProfilesListCall
- func (c *ProjectsLocationsConnectionProfilesListCall) Pages(ctx context.Context, f func(*ListConnectionProfilesResponse) error) error
- type ProjectsLocationsConnectionProfilesPatchCall
- func (c *ProjectsLocationsConnectionProfilesPatchCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesPatchCall
- func (c *ProjectsLocationsConnectionProfilesPatchCall) Do(opts ...googleapi.CallOption) (*Operation, error)
- func (c *ProjectsLocationsConnectionProfilesPatchCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesPatchCall
- func (c *ProjectsLocationsConnectionProfilesPatchCall) Force(force bool) *ProjectsLocationsConnectionProfilesPatchCall
- func (c *ProjectsLocationsConnectionProfilesPatchCall) Header() http.Header
- func (c *ProjectsLocationsConnectionProfilesPatchCall) RequestId(requestId string) *ProjectsLocationsConnectionProfilesPatchCall
- func (c *ProjectsLocationsConnectionProfilesPatchCall) UpdateMask(updateMask string) *ProjectsLocationsConnectionProfilesPatchCall
- func (c *ProjectsLocationsConnectionProfilesPatchCall) ValidateOnly(validateOnly bool) *ProjectsLocationsConnectionProfilesPatchCall
- type ProjectsLocationsConnectionProfilesService
- func (r *ProjectsLocationsConnectionProfilesService) Create(parent string, connectionprofile *ConnectionProfile) *ProjectsLocationsConnectionProfilesCreateCall
- func (r *ProjectsLocationsConnectionProfilesService) Delete(name string) *ProjectsLocationsConnectionProfilesDeleteCall
- func (r *ProjectsLocationsConnectionProfilesService) Discover(parent string, ...) *ProjectsLocationsConnectionProfilesDiscoverCall
- func (r *ProjectsLocationsConnectionProfilesService) Get(name string) *ProjectsLocationsConnectionProfilesGetCall
- func (r *ProjectsLocationsConnectionProfilesService) List(parent string) *ProjectsLocationsConnectionProfilesListCall
- func (r *ProjectsLocationsConnectionProfilesService) Patch(name string, connectionprofile *ConnectionProfile) *ProjectsLocationsConnectionProfilesPatchCall
- type ProjectsLocationsFetchStaticIpsCall
- func (c *ProjectsLocationsFetchStaticIpsCall) Context(ctx context.Context) *ProjectsLocationsFetchStaticIpsCall
- func (c *ProjectsLocationsFetchStaticIpsCall) Do(opts ...googleapi.CallOption) (*FetchStaticIpsResponse, error)
- func (c *ProjectsLocationsFetchStaticIpsCall) Fields(s ...googleapi.Field) *ProjectsLocationsFetchStaticIpsCall
- func (c *ProjectsLocationsFetchStaticIpsCall) Header() http.Header
- func (c *ProjectsLocationsFetchStaticIpsCall) IfNoneMatch(entityTag string) *ProjectsLocationsFetchStaticIpsCall
- func (c *ProjectsLocationsFetchStaticIpsCall) PageSize(pageSize int64) *ProjectsLocationsFetchStaticIpsCall
- func (c *ProjectsLocationsFetchStaticIpsCall) PageToken(pageToken string) *ProjectsLocationsFetchStaticIpsCall
- func (c *ProjectsLocationsFetchStaticIpsCall) Pages(ctx context.Context, f func(*FetchStaticIpsResponse) error) error
- type ProjectsLocationsGetCall
- func (c *ProjectsLocationsGetCall) Context(ctx context.Context) *ProjectsLocationsGetCall
- func (c *ProjectsLocationsGetCall) Do(opts ...googleapi.CallOption) (*Location, error)
- func (c *ProjectsLocationsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsGetCall
- func (c *ProjectsLocationsGetCall) Header() http.Header
- func (c *ProjectsLocationsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsGetCall
- type ProjectsLocationsListCall
- func (c *ProjectsLocationsListCall) Context(ctx context.Context) *ProjectsLocationsListCall
- func (c *ProjectsLocationsListCall) Do(opts ...googleapi.CallOption) (*ListLocationsResponse, error)
- func (c *ProjectsLocationsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsListCall
- func (c *ProjectsLocationsListCall) Filter(filter string) *ProjectsLocationsListCall
- func (c *ProjectsLocationsListCall) Header() http.Header
- func (c *ProjectsLocationsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsListCall
- func (c *ProjectsLocationsListCall) PageSize(pageSize int64) *ProjectsLocationsListCall
- func (c *ProjectsLocationsListCall) PageToken(pageToken string) *ProjectsLocationsListCall
- func (c *ProjectsLocationsListCall) Pages(ctx context.Context, f func(*ListLocationsResponse) error) error
- type ProjectsLocationsOperationsCancelCall
- func (c *ProjectsLocationsOperationsCancelCall) Context(ctx context.Context) *ProjectsLocationsOperationsCancelCall
- func (c *ProjectsLocationsOperationsCancelCall) Do(opts ...googleapi.CallOption) (*Empty, error)
- func (c *ProjectsLocationsOperationsCancelCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsCancelCall
- func (c *ProjectsLocationsOperationsCancelCall) Header() http.Header
- type ProjectsLocationsOperationsDeleteCall
- func (c *ProjectsLocationsOperationsDeleteCall) Context(ctx context.Context) *ProjectsLocationsOperationsDeleteCall
- func (c *ProjectsLocationsOperationsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error)
- func (c *ProjectsLocationsOperationsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsDeleteCall
- func (c *ProjectsLocationsOperationsDeleteCall) Header() http.Header
- type ProjectsLocationsOperationsGetCall
- func (c *ProjectsLocationsOperationsGetCall) Context(ctx context.Context) *ProjectsLocationsOperationsGetCall
- func (c *ProjectsLocationsOperationsGetCall) Do(opts ...googleapi.CallOption) (*Operation, error)
- func (c *ProjectsLocationsOperationsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsGetCall
- func (c *ProjectsLocationsOperationsGetCall) Header() http.Header
- func (c *ProjectsLocationsOperationsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsOperationsGetCall
- type ProjectsLocationsOperationsListCall
- func (c *ProjectsLocationsOperationsListCall) Context(ctx context.Context) *ProjectsLocationsOperationsListCall
- func (c *ProjectsLocationsOperationsListCall) Do(opts ...googleapi.CallOption) (*ListOperationsResponse, error)
- func (c *ProjectsLocationsOperationsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsListCall
- func (c *ProjectsLocationsOperationsListCall) Filter(filter string) *ProjectsLocationsOperationsListCall
- func (c *ProjectsLocationsOperationsListCall) Header() http.Header
- func (c *ProjectsLocationsOperationsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsOperationsListCall
- func (c *ProjectsLocationsOperationsListCall) PageSize(pageSize int64) *ProjectsLocationsOperationsListCall
- func (c *ProjectsLocationsOperationsListCall) PageToken(pageToken string) *ProjectsLocationsOperationsListCall
- func (c *ProjectsLocationsOperationsListCall) Pages(ctx context.Context, f func(*ListOperationsResponse) error) error
- type ProjectsLocationsOperationsService
- func (r *ProjectsLocationsOperationsService) Cancel(name string, canceloperationrequest *CancelOperationRequest) *ProjectsLocationsOperationsCancelCall
- func (r *ProjectsLocationsOperationsService) Delete(name string) *ProjectsLocationsOperationsDeleteCall
- func (r *ProjectsLocationsOperationsService) Get(name string) *ProjectsLocationsOperationsGetCall
- func (r *ProjectsLocationsOperationsService) List(name string) *ProjectsLocationsOperationsListCall
- type ProjectsLocationsPrivateConnectionsCreateCall
- func (c *ProjectsLocationsPrivateConnectionsCreateCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsCreateCall
- func (c *ProjectsLocationsPrivateConnectionsCreateCall) Do(opts ...googleapi.CallOption) (*Operation, error)
- func (c *ProjectsLocationsPrivateConnectionsCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsCreateCall
- func (c *ProjectsLocationsPrivateConnectionsCreateCall) Force(force bool) *ProjectsLocationsPrivateConnectionsCreateCall
- func (c *ProjectsLocationsPrivateConnectionsCreateCall) Header() http.Header
- func (c *ProjectsLocationsPrivateConnectionsCreateCall) PrivateConnectionId(privateConnectionId string) *ProjectsLocationsPrivateConnectionsCreateCall
- func (c *ProjectsLocationsPrivateConnectionsCreateCall) RequestId(requestId string) *ProjectsLocationsPrivateConnectionsCreateCall
- type ProjectsLocationsPrivateConnectionsDeleteCall
- func (c *ProjectsLocationsPrivateConnectionsDeleteCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsDeleteCall
- func (c *ProjectsLocationsPrivateConnectionsDeleteCall) Do(opts ...googleapi.CallOption) (*Operation, error)
- func (c *ProjectsLocationsPrivateConnectionsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsDeleteCall
- func (c *ProjectsLocationsPrivateConnectionsDeleteCall) Force(force bool) *ProjectsLocationsPrivateConnectionsDeleteCall
- func (c *ProjectsLocationsPrivateConnectionsDeleteCall) Header() http.Header
- func (c *ProjectsLocationsPrivateConnectionsDeleteCall) RequestId(requestId string) *ProjectsLocationsPrivateConnectionsDeleteCall
- type ProjectsLocationsPrivateConnectionsGetCall
- func (c *ProjectsLocationsPrivateConnectionsGetCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsGetCall
- func (c *ProjectsLocationsPrivateConnectionsGetCall) Do(opts ...googleapi.CallOption) (*PrivateConnection, error)
- func (c *ProjectsLocationsPrivateConnectionsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsGetCall
- func (c *ProjectsLocationsPrivateConnectionsGetCall) Header() http.Header
- func (c *ProjectsLocationsPrivateConnectionsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsPrivateConnectionsGetCall
- type ProjectsLocationsPrivateConnectionsListCall
- func (c *ProjectsLocationsPrivateConnectionsListCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsListCall
- func (c *ProjectsLocationsPrivateConnectionsListCall) Do(opts ...googleapi.CallOption) (*ListPrivateConnectionsResponse, error)
- func (c *ProjectsLocationsPrivateConnectionsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsListCall
- func (c *ProjectsLocationsPrivateConnectionsListCall) Filter(filter string) *ProjectsLocationsPrivateConnectionsListCall
- func (c *ProjectsLocationsPrivateConnectionsListCall) Header() http.Header
- func (c *ProjectsLocationsPrivateConnectionsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsPrivateConnectionsListCall
- func (c *ProjectsLocationsPrivateConnectionsListCall) OrderBy(orderBy string) *ProjectsLocationsPrivateConnectionsListCall
- func (c *ProjectsLocationsPrivateConnectionsListCall) PageSize(pageSize int64) *ProjectsLocationsPrivateConnectionsListCall
- func (c *ProjectsLocationsPrivateConnectionsListCall) PageToken(pageToken string) *ProjectsLocationsPrivateConnectionsListCall
- func (c *ProjectsLocationsPrivateConnectionsListCall) Pages(ctx context.Context, f func(*ListPrivateConnectionsResponse) error) error
- type ProjectsLocationsPrivateConnectionsRoutesCreateCall
- func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsRoutesCreateCall
- func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) Do(opts ...googleapi.CallOption) (*Operation, error)
- func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsRoutesCreateCall
- func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) Header() http.Header
- func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) RequestId(requestId string) *ProjectsLocationsPrivateConnectionsRoutesCreateCall
- func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) RouteId(routeId string) *ProjectsLocationsPrivateConnectionsRoutesCreateCall
- type ProjectsLocationsPrivateConnectionsRoutesDeleteCall
- func (c *ProjectsLocationsPrivateConnectionsRoutesDeleteCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsRoutesDeleteCall
- func (c *ProjectsLocationsPrivateConnectionsRoutesDeleteCall) Do(opts ...googleapi.CallOption) (*Operation, error)
- func (c *ProjectsLocationsPrivateConnectionsRoutesDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsRoutesDeleteCall
- func (c *ProjectsLocationsPrivateConnectionsRoutesDeleteCall) Header() http.Header
- func (c *ProjectsLocationsPrivateConnectionsRoutesDeleteCall) RequestId(requestId string) *ProjectsLocationsPrivateConnectionsRoutesDeleteCall
- type ProjectsLocationsPrivateConnectionsRoutesGetCall
- func (c *ProjectsLocationsPrivateConnectionsRoutesGetCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsRoutesGetCall
- func (c *ProjectsLocationsPrivateConnectionsRoutesGetCall) Do(opts ...googleapi.CallOption) (*Route, error)
- func (c *ProjectsLocationsPrivateConnectionsRoutesGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsRoutesGetCall
- func (c *ProjectsLocationsPrivateConnectionsRoutesGetCall) Header() http.Header
- func (c *ProjectsLocationsPrivateConnectionsRoutesGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsPrivateConnectionsRoutesGetCall
- type ProjectsLocationsPrivateConnectionsRoutesListCall
- func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsRoutesListCall
- func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Do(opts ...googleapi.CallOption) (*ListRoutesResponse, error)
- func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsRoutesListCall
- func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Filter(filter string) *ProjectsLocationsPrivateConnectionsRoutesListCall
- func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Header() http.Header
- func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) IfNoneMatch(entityTag string) *ProjectsLocationsPrivateConnectionsRoutesListCall
- func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) OrderBy(orderBy string) *ProjectsLocationsPrivateConnectionsRoutesListCall
- func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) PageSize(pageSize int64) *ProjectsLocationsPrivateConnectionsRoutesListCall
- func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) PageToken(pageToken string) *ProjectsLocationsPrivateConnectionsRoutesListCall
- func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Pages(ctx context.Context, f func(*ListRoutesResponse) error) error
- type ProjectsLocationsPrivateConnectionsRoutesService
- func (r *ProjectsLocationsPrivateConnectionsRoutesService) Create(parent string, route *Route) *ProjectsLocationsPrivateConnectionsRoutesCreateCall
- func (r *ProjectsLocationsPrivateConnectionsRoutesService) Delete(name string) *ProjectsLocationsPrivateConnectionsRoutesDeleteCall
- func (r *ProjectsLocationsPrivateConnectionsRoutesService) Get(name string) *ProjectsLocationsPrivateConnectionsRoutesGetCall
- func (r *ProjectsLocationsPrivateConnectionsRoutesService) List(parent string) *ProjectsLocationsPrivateConnectionsRoutesListCall
- type ProjectsLocationsPrivateConnectionsService
- func (r *ProjectsLocationsPrivateConnectionsService) Create(parent string, privateconnection *PrivateConnection) *ProjectsLocationsPrivateConnectionsCreateCall
- func (r *ProjectsLocationsPrivateConnectionsService) Delete(name string) *ProjectsLocationsPrivateConnectionsDeleteCall
- func (r *ProjectsLocationsPrivateConnectionsService) Get(name string) *ProjectsLocationsPrivateConnectionsGetCall
- func (r *ProjectsLocationsPrivateConnectionsService) List(parent string) *ProjectsLocationsPrivateConnectionsListCall
- type ProjectsLocationsService
- type ProjectsLocationsStreamsCreateCall
- func (c *ProjectsLocationsStreamsCreateCall) Context(ctx context.Context) *ProjectsLocationsStreamsCreateCall
- func (c *ProjectsLocationsStreamsCreateCall) Do(opts ...googleapi.CallOption) (*Operation, error)
- func (c *ProjectsLocationsStreamsCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsCreateCall
- func (c *ProjectsLocationsStreamsCreateCall) Force(force bool) *ProjectsLocationsStreamsCreateCall
- func (c *ProjectsLocationsStreamsCreateCall) Header() http.Header
- func (c *ProjectsLocationsStreamsCreateCall) RequestId(requestId string) *ProjectsLocationsStreamsCreateCall
- func (c *ProjectsLocationsStreamsCreateCall) StreamId(streamId string) *ProjectsLocationsStreamsCreateCall
- func (c *ProjectsLocationsStreamsCreateCall) ValidateOnly(validateOnly bool) *ProjectsLocationsStreamsCreateCall
- type ProjectsLocationsStreamsDeleteCall
- func (c *ProjectsLocationsStreamsDeleteCall) Context(ctx context.Context) *ProjectsLocationsStreamsDeleteCall
- func (c *ProjectsLocationsStreamsDeleteCall) Do(opts ...googleapi.CallOption) (*Operation, error)
- func (c *ProjectsLocationsStreamsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsDeleteCall
- func (c *ProjectsLocationsStreamsDeleteCall) Header() http.Header
- func (c *ProjectsLocationsStreamsDeleteCall) RequestId(requestId string) *ProjectsLocationsStreamsDeleteCall
- type ProjectsLocationsStreamsGetCall
- func (c *ProjectsLocationsStreamsGetCall) Context(ctx context.Context) *ProjectsLocationsStreamsGetCall
- func (c *ProjectsLocationsStreamsGetCall) Do(opts ...googleapi.CallOption) (*Stream, error)
- func (c *ProjectsLocationsStreamsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsGetCall
- func (c *ProjectsLocationsStreamsGetCall) Header() http.Header
- func (c *ProjectsLocationsStreamsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsStreamsGetCall
- type ProjectsLocationsStreamsListCall
- func (c *ProjectsLocationsStreamsListCall) Context(ctx context.Context) *ProjectsLocationsStreamsListCall
- func (c *ProjectsLocationsStreamsListCall) Do(opts ...googleapi.CallOption) (*ListStreamsResponse, error)
- func (c *ProjectsLocationsStreamsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsListCall
- func (c *ProjectsLocationsStreamsListCall) Filter(filter string) *ProjectsLocationsStreamsListCall
- func (c *ProjectsLocationsStreamsListCall) Header() http.Header
- func (c *ProjectsLocationsStreamsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsStreamsListCall
- func (c *ProjectsLocationsStreamsListCall) OrderBy(orderBy string) *ProjectsLocationsStreamsListCall
- func (c *ProjectsLocationsStreamsListCall) PageSize(pageSize int64) *ProjectsLocationsStreamsListCall
- func (c *ProjectsLocationsStreamsListCall) PageToken(pageToken string) *ProjectsLocationsStreamsListCall
- func (c *ProjectsLocationsStreamsListCall) Pages(ctx context.Context, f func(*ListStreamsResponse) error) error
- type ProjectsLocationsStreamsObjectsGetCall
- func (c *ProjectsLocationsStreamsObjectsGetCall) Context(ctx context.Context) *ProjectsLocationsStreamsObjectsGetCall
- func (c *ProjectsLocationsStreamsObjectsGetCall) Do(opts ...googleapi.CallOption) (*StreamObject, error)
- func (c *ProjectsLocationsStreamsObjectsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsObjectsGetCall
- func (c *ProjectsLocationsStreamsObjectsGetCall) Header() http.Header
- func (c *ProjectsLocationsStreamsObjectsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsStreamsObjectsGetCall
- type ProjectsLocationsStreamsObjectsListCall
- func (c *ProjectsLocationsStreamsObjectsListCall) Context(ctx context.Context) *ProjectsLocationsStreamsObjectsListCall
- func (c *ProjectsLocationsStreamsObjectsListCall) Do(opts ...googleapi.CallOption) (*ListStreamObjectsResponse, error)
- func (c *ProjectsLocationsStreamsObjectsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsObjectsListCall
- func (c *ProjectsLocationsStreamsObjectsListCall) Header() http.Header
- func (c *ProjectsLocationsStreamsObjectsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsStreamsObjectsListCall
- func (c *ProjectsLocationsStreamsObjectsListCall) PageSize(pageSize int64) *ProjectsLocationsStreamsObjectsListCall
- func (c *ProjectsLocationsStreamsObjectsListCall) PageToken(pageToken string) *ProjectsLocationsStreamsObjectsListCall
- func (c *ProjectsLocationsStreamsObjectsListCall) Pages(ctx context.Context, f func(*ListStreamObjectsResponse) error) error
- type ProjectsLocationsStreamsObjectsLookupCall
- func (c *ProjectsLocationsStreamsObjectsLookupCall) Context(ctx context.Context) *ProjectsLocationsStreamsObjectsLookupCall
- func (c *ProjectsLocationsStreamsObjectsLookupCall) Do(opts ...googleapi.CallOption) (*StreamObject, error)
- func (c *ProjectsLocationsStreamsObjectsLookupCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsObjectsLookupCall
- func (c *ProjectsLocationsStreamsObjectsLookupCall) Header() http.Header
- type ProjectsLocationsStreamsObjectsService
- func (r *ProjectsLocationsStreamsObjectsService) Get(name string) *ProjectsLocationsStreamsObjectsGetCall
- func (r *ProjectsLocationsStreamsObjectsService) List(parent string) *ProjectsLocationsStreamsObjectsListCall
- func (r *ProjectsLocationsStreamsObjectsService) Lookup(parent string, lookupstreamobjectrequest *LookupStreamObjectRequest) *ProjectsLocationsStreamsObjectsLookupCall
- func (r *ProjectsLocationsStreamsObjectsService) StartBackfillJob(object string, startbackfilljobrequest *StartBackfillJobRequest) *ProjectsLocationsStreamsObjectsStartBackfillJobCall
- func (r *ProjectsLocationsStreamsObjectsService) StopBackfillJob(object string, stopbackfilljobrequest *StopBackfillJobRequest) *ProjectsLocationsStreamsObjectsStopBackfillJobCall
- type ProjectsLocationsStreamsObjectsStartBackfillJobCall
- func (c *ProjectsLocationsStreamsObjectsStartBackfillJobCall) Context(ctx context.Context) *ProjectsLocationsStreamsObjectsStartBackfillJobCall
- func (c *ProjectsLocationsStreamsObjectsStartBackfillJobCall) Do(opts ...googleapi.CallOption) (*StartBackfillJobResponse, error)
- func (c *ProjectsLocationsStreamsObjectsStartBackfillJobCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsObjectsStartBackfillJobCall
- func (c *ProjectsLocationsStreamsObjectsStartBackfillJobCall) Header() http.Header
- type ProjectsLocationsStreamsObjectsStopBackfillJobCall
- func (c *ProjectsLocationsStreamsObjectsStopBackfillJobCall) Context(ctx context.Context) *ProjectsLocationsStreamsObjectsStopBackfillJobCall
- func (c *ProjectsLocationsStreamsObjectsStopBackfillJobCall) Do(opts ...googleapi.CallOption) (*StopBackfillJobResponse, error)
- func (c *ProjectsLocationsStreamsObjectsStopBackfillJobCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsObjectsStopBackfillJobCall
- func (c *ProjectsLocationsStreamsObjectsStopBackfillJobCall) Header() http.Header
- type ProjectsLocationsStreamsPatchCall
- func (c *ProjectsLocationsStreamsPatchCall) Context(ctx context.Context) *ProjectsLocationsStreamsPatchCall
- func (c *ProjectsLocationsStreamsPatchCall) Do(opts ...googleapi.CallOption) (*Operation, error)
- func (c *ProjectsLocationsStreamsPatchCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsPatchCall
- func (c *ProjectsLocationsStreamsPatchCall) Force(force bool) *ProjectsLocationsStreamsPatchCall
- func (c *ProjectsLocationsStreamsPatchCall) Header() http.Header
- func (c *ProjectsLocationsStreamsPatchCall) RequestId(requestId string) *ProjectsLocationsStreamsPatchCall
- func (c *ProjectsLocationsStreamsPatchCall) UpdateMask(updateMask string) *ProjectsLocationsStreamsPatchCall
- func (c *ProjectsLocationsStreamsPatchCall) ValidateOnly(validateOnly bool) *ProjectsLocationsStreamsPatchCall
- type ProjectsLocationsStreamsRunCall
- func (c *ProjectsLocationsStreamsRunCall) Context(ctx context.Context) *ProjectsLocationsStreamsRunCall
- func (c *ProjectsLocationsStreamsRunCall) Do(opts ...googleapi.CallOption) (*Operation, error)
- func (c *ProjectsLocationsStreamsRunCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsRunCall
- func (c *ProjectsLocationsStreamsRunCall) Header() http.Header
- type ProjectsLocationsStreamsService
- func (r *ProjectsLocationsStreamsService) Create(parent string, stream *Stream) *ProjectsLocationsStreamsCreateCall
- func (r *ProjectsLocationsStreamsService) Delete(name string) *ProjectsLocationsStreamsDeleteCall
- func (r *ProjectsLocationsStreamsService) Get(name string) *ProjectsLocationsStreamsGetCall
- func (r *ProjectsLocationsStreamsService) List(parent string) *ProjectsLocationsStreamsListCall
- func (r *ProjectsLocationsStreamsService) Patch(name string, stream *Stream) *ProjectsLocationsStreamsPatchCall
- func (r *ProjectsLocationsStreamsService) Run(name string, runstreamrequest *RunStreamRequest) *ProjectsLocationsStreamsRunCall
- type ProjectsService
- type Route
- type RunStreamRequest
- type Service
- type SingleTargetDataset
- type SourceConfig
- type SourceHierarchyDatasets
- type SourceObjectIdentifier
- type SpecificStartPosition
- type StartBackfillJobRequest
- type StartBackfillJobResponse
- type StaticServiceIpConnectivity
- type Status
- type StopBackfillJobRequest
- type StopBackfillJobResponse
- type Stream
- type StreamLargeObjects
- type StreamObject
- type Validation
- type ValidationMessage
- type ValidationResult
- type VpcPeeringConfig
Constants ¶
const ( // See, edit, configure, and delete your Google Cloud data and see the // email address for your Google Account. CloudPlatformScope = "https://www.googleapis.com/auth/cloud-platform" )
OAuth2 scopes used by this API.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AvroFileFormat ¶
type AvroFileFormat struct { }
AvroFileFormat: AVRO file format configuration.
type BackfillAllStrategy ¶
type BackfillAllStrategy struct { // MysqlExcludedObjects: MySQL data source objects to avoid backfilling. MysqlExcludedObjects *MysqlRdbms `json:"mysqlExcludedObjects,omitempty"` // OracleExcludedObjects: Oracle data source objects to avoid // backfilling. OracleExcludedObjects *OracleRdbms `json:"oracleExcludedObjects,omitempty"` // PostgresqlExcludedObjects: PostgreSQL data source objects to avoid // backfilling. PostgresqlExcludedObjects *PostgresqlRdbms `json:"postgresqlExcludedObjects,omitempty"` // ForceSendFields is a list of field names (e.g. // "MysqlExcludedObjects") to unconditionally include in API requests. // By default, fields with empty or default values are omitted from API // requests. However, any non-pointer, non-interface field appearing in // ForceSendFields will be sent to the server regardless of whether the // field is empty or not. This may be used to include empty fields in // Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "MysqlExcludedObjects") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
BackfillAllStrategy: Backfill strategy to automatically backfill the Stream's objects. Specific objects can be excluded.
func (*BackfillAllStrategy) MarshalJSON ¶
func (s *BackfillAllStrategy) MarshalJSON() ([]byte, error)
type BackfillJob ¶
type BackfillJob struct { // Errors: Output only. Errors which caused the backfill job to fail. Errors []*Error `json:"errors,omitempty"` // LastEndTime: Output only. Backfill job's end time. LastEndTime string `json:"lastEndTime,omitempty"` // LastStartTime: Output only. Backfill job's start time. LastStartTime string `json:"lastStartTime,omitempty"` // State: Output only. Backfill job state. // // Possible values: // "STATE_UNSPECIFIED" - Default value. // "NOT_STARTED" - Backfill job was never started for the stream // object (stream has backfill strategy defined as manual or object was // explicitly excluded from automatic backfill). // "PENDING" - Backfill job will start pending available resources. // "ACTIVE" - Backfill job is running. // "STOPPED" - Backfill job stopped (next job run will start from // beginning). // "FAILED" - Backfill job failed (due to an error). // "COMPLETED" - Backfill completed successfully. // "UNSUPPORTED" - Backfill job failed since the table structure is // currently unsupported for backfill. State string `json:"state,omitempty"` // Trigger: Backfill job's triggering reason. // // Possible values: // "TRIGGER_UNSPECIFIED" - Default value. // "AUTOMATIC" - Object backfill job was triggered automatically // according to the stream's backfill strategy. // "MANUAL" - Object backfill job was triggered manually using the // dedicated API. Trigger string `json:"trigger,omitempty"` // ForceSendFields is a list of field names (e.g. "Errors") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Errors") to include in API // requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
BackfillJob: Represents a backfill job on a specific stream object.
func (*BackfillJob) MarshalJSON ¶
func (s *BackfillJob) MarshalJSON() ([]byte, error)
type BackfillNoneStrategy ¶
type BackfillNoneStrategy struct { }
BackfillNoneStrategy: Backfill strategy to disable automatic backfill for the Stream's objects.
type BigQueryDestinationConfig ¶ added in v0.96.0
type BigQueryDestinationConfig struct { // DataFreshness: The guaranteed data freshness (in seconds) when // querying tables created by the stream. Editing this field will only // affect new tables created in the future, but existing tables will not // be impacted. Lower values mean that queries will return fresher data, // but may result in higher cost. DataFreshness string `json:"dataFreshness,omitempty"` // SingleTargetDataset: Single destination dataset. SingleTargetDataset *SingleTargetDataset `json:"singleTargetDataset,omitempty"` // SourceHierarchyDatasets: Source hierarchy datasets. SourceHierarchyDatasets *SourceHierarchyDatasets `json:"sourceHierarchyDatasets,omitempty"` // ForceSendFields is a list of field names (e.g. "DataFreshness") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "DataFreshness") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
BigQueryDestinationConfig: BigQuery destination configuration
func (*BigQueryDestinationConfig) MarshalJSON ¶ added in v0.96.0
func (s *BigQueryDestinationConfig) MarshalJSON() ([]byte, error)
type BigQueryProfile ¶ added in v0.96.0
type BigQueryProfile struct { }
BigQueryProfile: BigQuery warehouse profile.
type CancelOperationRequest ¶
type CancelOperationRequest struct { }
CancelOperationRequest: The request message for Operations.CancelOperation.
type CdcStrategy ¶ added in v0.135.0
type CdcStrategy struct { // MostRecentStartPosition: Optional. Start replicating from the most // recent position in the source. MostRecentStartPosition *MostRecentStartPosition `json:"mostRecentStartPosition,omitempty"` // NextAvailableStartPosition: Optional. Resume replication from the // next available position in the source. NextAvailableStartPosition *NextAvailableStartPosition `json:"nextAvailableStartPosition,omitempty"` // SpecificStartPosition: Optional. Start replicating from a specific // position in the source. SpecificStartPosition *SpecificStartPosition `json:"specificStartPosition,omitempty"` // ForceSendFields is a list of field names (e.g. // "MostRecentStartPosition") to unconditionally include in API // requests. By default, fields with empty or default values are omitted // from API requests. However, any non-pointer, non-interface field // appearing in ForceSendFields will be sent to the server regardless of // whether the field is empty or not. This may be used to include empty // fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "MostRecentStartPosition") // to include in API requests with the JSON null value. By default, // fields with empty values are omitted from API requests. However, any // field with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
CdcStrategy: The strategy that the stream uses for CDC replication.
func (*CdcStrategy) MarshalJSON ¶ added in v0.135.0
func (s *CdcStrategy) MarshalJSON() ([]byte, error)
type ConnectionProfile ¶
type ConnectionProfile struct { // BigqueryProfile: BigQuery Connection Profile configuration. BigqueryProfile *BigQueryProfile `json:"bigqueryProfile,omitempty"` // CreateTime: Output only. The create time of the resource. CreateTime string `json:"createTime,omitempty"` // DisplayName: Required. Display name. DisplayName string `json:"displayName,omitempty"` // ForwardSshConnectivity: Forward SSH tunnel connectivity. ForwardSshConnectivity *ForwardSshTunnelConnectivity `json:"forwardSshConnectivity,omitempty"` // GcsProfile: Cloud Storage ConnectionProfile configuration. GcsProfile *GcsProfile `json:"gcsProfile,omitempty"` // Labels: Labels. Labels map[string]string `json:"labels,omitempty"` // MysqlProfile: MySQL ConnectionProfile configuration. MysqlProfile *MysqlProfile `json:"mysqlProfile,omitempty"` // Name: Output only. The resource's name. Name string `json:"name,omitempty"` // OracleProfile: Oracle ConnectionProfile configuration. OracleProfile *OracleProfile `json:"oracleProfile,omitempty"` // PostgresqlProfile: PostgreSQL Connection Profile configuration. PostgresqlProfile *PostgresqlProfile `json:"postgresqlProfile,omitempty"` // PrivateConnectivity: Private connectivity. PrivateConnectivity *PrivateConnectivity `json:"privateConnectivity,omitempty"` // StaticServiceIpConnectivity: Static Service IP connectivity. StaticServiceIpConnectivity *StaticServiceIpConnectivity `json:"staticServiceIpConnectivity,omitempty"` // UpdateTime: Output only. The update time of the resource. UpdateTime string `json:"updateTime,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "BigqueryProfile") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "BigqueryProfile") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
ConnectionProfile: A set of reusable connection configurations to be used as a source or destination for a stream.
func (*ConnectionProfile) MarshalJSON ¶
func (s *ConnectionProfile) MarshalJSON() ([]byte, error)
type DatasetTemplate ¶ added in v0.96.0
type DatasetTemplate struct { // DatasetIdPrefix: If supplied, every created dataset will have its // name prefixed by the provided value. The prefix and name will be // separated by an underscore. i.e. _. DatasetIdPrefix string `json:"datasetIdPrefix,omitempty"` // KmsKeyName: Describes the Cloud KMS encryption key that will be used // to protect destination BigQuery table. The BigQuery Service Account // associated with your project requires access to this encryption key. // i.e. // projects/{project}/locations/{location}/keyRings/{key_ring}/cryptoKeys // /{cryptoKey}. See // https://cloud.google.com/bigquery/docs/customer-managed-encryption // for more information. KmsKeyName string `json:"kmsKeyName,omitempty"` // Location: Required. The geographic location where the dataset should // reside. See https://cloud.google.com/bigquery/docs/locations for // supported locations. Location string `json:"location,omitempty"` // ForceSendFields is a list of field names (e.g. "DatasetIdPrefix") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "DatasetIdPrefix") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
DatasetTemplate: Dataset template used for dynamic dataset creation.
func (*DatasetTemplate) MarshalJSON ¶ added in v0.96.0
func (s *DatasetTemplate) MarshalJSON() ([]byte, error)
type DestinationConfig ¶
type DestinationConfig struct { // BigqueryDestinationConfig: BigQuery destination configuration. BigqueryDestinationConfig *BigQueryDestinationConfig `json:"bigqueryDestinationConfig,omitempty"` // DestinationConnectionProfile: Required. Destination connection // profile resource. Format: // `projects/{project}/locations/{location}/connectionProfiles/{name}` DestinationConnectionProfile string `json:"destinationConnectionProfile,omitempty"` // GcsDestinationConfig: A configuration for how data should be loaded // to Cloud Storage. GcsDestinationConfig *GcsDestinationConfig `json:"gcsDestinationConfig,omitempty"` // ForceSendFields is a list of field names (e.g. // "BigqueryDestinationConfig") to unconditionally include in API // requests. By default, fields with empty or default values are omitted // from API requests. However, any non-pointer, non-interface field // appearing in ForceSendFields will be sent to the server regardless of // whether the field is empty or not. This may be used to include empty // fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. // "BigqueryDestinationConfig") to include in API requests with the JSON // null value. By default, fields with empty values are omitted from API // requests. However, any field with an empty value appearing in // NullFields will be sent to the server as null. It is an error if a // field in this list has a non-empty value. This may be used to include // null fields in Patch requests. NullFields []string `json:"-"` }
DestinationConfig: The configuration of the stream destination.
func (*DestinationConfig) MarshalJSON ¶
func (s *DestinationConfig) MarshalJSON() ([]byte, error)
type DiscoverConnectionProfileRequest ¶
type DiscoverConnectionProfileRequest struct { // ConnectionProfile: An ad-hoc connection profile configuration. ConnectionProfile *ConnectionProfile `json:"connectionProfile,omitempty"` // ConnectionProfileName: A reference to an existing connection profile. ConnectionProfileName string `json:"connectionProfileName,omitempty"` // FullHierarchy: Whether to retrieve the full hierarchy of data objects // (TRUE) or only the current level (FALSE). FullHierarchy bool `json:"fullHierarchy,omitempty"` // HierarchyDepth: The number of hierarchy levels below the current // level to be retrieved. HierarchyDepth int64 `json:"hierarchyDepth,omitempty"` // MysqlRdbms: MySQL RDBMS to enrich with child data objects and // metadata. MysqlRdbms *MysqlRdbms `json:"mysqlRdbms,omitempty"` // OracleRdbms: Oracle RDBMS to enrich with child data objects and // metadata. OracleRdbms *OracleRdbms `json:"oracleRdbms,omitempty"` // PostgresqlRdbms: PostgreSQL RDBMS to enrich with child data objects // and metadata. PostgresqlRdbms *PostgresqlRdbms `json:"postgresqlRdbms,omitempty"` // ForceSendFields is a list of field names (e.g. "ConnectionProfile") // to unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "ConnectionProfile") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
DiscoverConnectionProfileRequest: Request message for 'discover' ConnectionProfile request.
func (*DiscoverConnectionProfileRequest) MarshalJSON ¶
func (s *DiscoverConnectionProfileRequest) MarshalJSON() ([]byte, error)
type DiscoverConnectionProfileResponse ¶
type DiscoverConnectionProfileResponse struct { // MysqlRdbms: Enriched MySQL RDBMS object. MysqlRdbms *MysqlRdbms `json:"mysqlRdbms,omitempty"` // OracleRdbms: Enriched Oracle RDBMS object. OracleRdbms *OracleRdbms `json:"oracleRdbms,omitempty"` // PostgresqlRdbms: Enriched PostgreSQL RDBMS object. PostgresqlRdbms *PostgresqlRdbms `json:"postgresqlRdbms,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "MysqlRdbms") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "MysqlRdbms") to include in // API requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
DiscoverConnectionProfileResponse: Response from a discover request.
func (*DiscoverConnectionProfileResponse) MarshalJSON ¶
func (s *DiscoverConnectionProfileResponse) MarshalJSON() ([]byte, error)
type DropLargeObjects ¶ added in v0.75.0
type DropLargeObjects struct { }
DropLargeObjects: Configuration to drop large object values.
type Empty ¶
type Empty struct { // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` }
Empty: A generic empty message that you can re-use to avoid defining duplicated empty messages in your APIs. A typical example is to use it as the request or the response type of an API method. For instance: service Foo { rpc Bar(google.protobuf.Empty) returns (google.protobuf.Empty); }
type Error ¶
type Error struct { // Details: Additional information about the error. Details map[string]string `json:"details,omitempty"` // ErrorTime: The time when the error occurred. ErrorTime string `json:"errorTime,omitempty"` // ErrorUuid: A unique identifier for this specific error, allowing it // to be traced throughout the system in logs and API responses. ErrorUuid string `json:"errorUuid,omitempty"` // Message: A message containing more information about the error that // occurred. Message string `json:"message,omitempty"` // Reason: A title that explains the reason for the error. Reason string `json:"reason,omitempty"` // ForceSendFields is a list of field names (e.g. "Details") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Details") to include in // API requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
Error: Represent a user-facing Error.
func (*Error) MarshalJSON ¶
type FetchStaticIpsResponse ¶
type FetchStaticIpsResponse struct { // NextPageToken: A token that can be sent as `page_token` to retrieve // the next page. If this field is omitted, there are no subsequent // pages. NextPageToken string `json:"nextPageToken,omitempty"` // StaticIps: list of static ips by account StaticIps []string `json:"staticIps,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "NextPageToken") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "NextPageToken") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
FetchStaticIpsResponse: Response message for a 'FetchStaticIps' response.
func (*FetchStaticIpsResponse) MarshalJSON ¶
func (s *FetchStaticIpsResponse) MarshalJSON() ([]byte, error)
type ForwardSshTunnelConnectivity ¶
type ForwardSshTunnelConnectivity struct { // Hostname: Required. Hostname for the SSH tunnel. Hostname string `json:"hostname,omitempty"` // Password: Input only. SSH password. Password string `json:"password,omitempty"` // Port: Port for the SSH tunnel, default value is 22. Port int64 `json:"port,omitempty"` // PrivateKey: Input only. SSH private key. PrivateKey string `json:"privateKey,omitempty"` // Username: Required. Username for the SSH tunnel. Username string `json:"username,omitempty"` // ForceSendFields is a list of field names (e.g. "Hostname") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Hostname") to include in // API requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
ForwardSshTunnelConnectivity: Forward SSH Tunnel connectivity.
func (*ForwardSshTunnelConnectivity) MarshalJSON ¶
func (s *ForwardSshTunnelConnectivity) MarshalJSON() ([]byte, error)
type GcsDestinationConfig ¶
type GcsDestinationConfig struct { // AvroFileFormat: AVRO file format configuration. AvroFileFormat *AvroFileFormat `json:"avroFileFormat,omitempty"` // FileRotationInterval: The maximum duration for which new events are // added before a file is closed and a new file is created. Values // within the range of 15-60 seconds are allowed. FileRotationInterval string `json:"fileRotationInterval,omitempty"` // FileRotationMb: The maximum file size to be saved in the bucket. FileRotationMb int64 `json:"fileRotationMb,omitempty"` // JsonFileFormat: JSON file format configuration. JsonFileFormat *JsonFileFormat `json:"jsonFileFormat,omitempty"` // Path: Path inside the Cloud Storage bucket to write data to. Path string `json:"path,omitempty"` // ForceSendFields is a list of field names (e.g. "AvroFileFormat") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "AvroFileFormat") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
GcsDestinationConfig: Google Cloud Storage destination configuration
func (*GcsDestinationConfig) MarshalJSON ¶
func (s *GcsDestinationConfig) MarshalJSON() ([]byte, error)
type GcsProfile ¶
type GcsProfile struct { // Bucket: Required. The Cloud Storage bucket name. Bucket string `json:"bucket,omitempty"` // RootPath: The root path inside the Cloud Storage bucket. RootPath string `json:"rootPath,omitempty"` // ForceSendFields is a list of field names (e.g. "Bucket") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Bucket") to include in API // requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
GcsProfile: Cloud Storage bucket profile.
func (*GcsProfile) MarshalJSON ¶
func (s *GcsProfile) MarshalJSON() ([]byte, error)
type JsonFileFormat ¶
type JsonFileFormat struct { // Compression: Compression of the loaded JSON file. // // Possible values: // "JSON_COMPRESSION_UNSPECIFIED" - Unspecified json file compression. // "NO_COMPRESSION" - Do not compress JSON file. // "GZIP" - Gzip compression. Compression string `json:"compression,omitempty"` // SchemaFileFormat: The schema file format along JSON data files. // // Possible values: // "SCHEMA_FILE_FORMAT_UNSPECIFIED" - Unspecified schema file format. // "NO_SCHEMA_FILE" - Do not attach schema file. // "AVRO_SCHEMA_FILE" - Avro schema format. SchemaFileFormat string `json:"schemaFileFormat,omitempty"` // ForceSendFields is a list of field names (e.g. "Compression") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Compression") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
JsonFileFormat: JSON file format configuration.
func (*JsonFileFormat) MarshalJSON ¶
func (s *JsonFileFormat) MarshalJSON() ([]byte, error)
type ListConnectionProfilesResponse ¶
type ListConnectionProfilesResponse struct { // ConnectionProfiles: List of connection profiles. ConnectionProfiles []*ConnectionProfile `json:"connectionProfiles,omitempty"` // NextPageToken: A token, which can be sent as `page_token` to retrieve // the next page. If this field is omitted, there are no subsequent // pages. NextPageToken string `json:"nextPageToken,omitempty"` // Unreachable: Locations that could not be reached. Unreachable []string `json:"unreachable,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "ConnectionProfiles") // to unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "ConnectionProfiles") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
ListConnectionProfilesResponse: Response message for listing connection profiles.
func (*ListConnectionProfilesResponse) MarshalJSON ¶
func (s *ListConnectionProfilesResponse) MarshalJSON() ([]byte, error)
type ListLocationsResponse ¶
type ListLocationsResponse struct { // Locations: A list of locations that matches the specified filter in // the request. Locations []*Location `json:"locations,omitempty"` // NextPageToken: The standard List next-page token. NextPageToken string `json:"nextPageToken,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "Locations") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Locations") to include in // API requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
ListLocationsResponse: The response message for Locations.ListLocations.
func (*ListLocationsResponse) MarshalJSON ¶
func (s *ListLocationsResponse) MarshalJSON() ([]byte, error)
type ListOperationsResponse ¶
type ListOperationsResponse struct { // NextPageToken: The standard List next-page token. NextPageToken string `json:"nextPageToken,omitempty"` // Operations: A list of operations that matches the specified filter in // the request. Operations []*Operation `json:"operations,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "NextPageToken") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "NextPageToken") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
ListOperationsResponse: The response message for Operations.ListOperations.
func (*ListOperationsResponse) MarshalJSON ¶
func (s *ListOperationsResponse) MarshalJSON() ([]byte, error)
type ListPrivateConnectionsResponse ¶
type ListPrivateConnectionsResponse struct { // NextPageToken: A token, which can be sent as `page_token` to retrieve // the next page. If this field is omitted, there are no subsequent // pages. NextPageToken string `json:"nextPageToken,omitempty"` // PrivateConnections: List of private connectivity configurations. PrivateConnections []*PrivateConnection `json:"privateConnections,omitempty"` // Unreachable: Locations that could not be reached. Unreachable []string `json:"unreachable,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "NextPageToken") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "NextPageToken") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
ListPrivateConnectionsResponse: Response containing a list of private connection configurations.
func (*ListPrivateConnectionsResponse) MarshalJSON ¶
func (s *ListPrivateConnectionsResponse) MarshalJSON() ([]byte, error)
type ListRoutesResponse ¶
type ListRoutesResponse struct { // NextPageToken: A token, which can be sent as `page_token` to retrieve // the next page. If this field is omitted, there are no subsequent // pages. NextPageToken string `json:"nextPageToken,omitempty"` // Routes: List of Routes. Routes []*Route `json:"routes,omitempty"` // Unreachable: Locations that could not be reached. Unreachable []string `json:"unreachable,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "NextPageToken") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "NextPageToken") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
ListRoutesResponse: Route list response.
func (*ListRoutesResponse) MarshalJSON ¶
func (s *ListRoutesResponse) MarshalJSON() ([]byte, error)
type ListStreamObjectsResponse ¶
type ListStreamObjectsResponse struct { // NextPageToken: A token, which can be sent as `page_token` to retrieve // the next page. NextPageToken string `json:"nextPageToken,omitempty"` // StreamObjects: List of stream objects. StreamObjects []*StreamObject `json:"streamObjects,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "NextPageToken") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "NextPageToken") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
ListStreamObjectsResponse: Response containing the objects for a stream.
func (*ListStreamObjectsResponse) MarshalJSON ¶
func (s *ListStreamObjectsResponse) MarshalJSON() ([]byte, error)
type ListStreamsResponse ¶
type ListStreamsResponse struct { // NextPageToken: A token, which can be sent as `page_token` to retrieve // the next page. If this field is omitted, there are no subsequent // pages. NextPageToken string `json:"nextPageToken,omitempty"` // Streams: List of streams Streams []*Stream `json:"streams,omitempty"` // Unreachable: Locations that could not be reached. Unreachable []string `json:"unreachable,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "NextPageToken") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "NextPageToken") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
ListStreamsResponse: Response message for listing streams.
func (*ListStreamsResponse) MarshalJSON ¶
func (s *ListStreamsResponse) MarshalJSON() ([]byte, error)
type Location ¶
type Location struct { // DisplayName: The friendly name for this location, typically a nearby // city name. For example, "Tokyo". DisplayName string `json:"displayName,omitempty"` // Labels: Cross-service attributes for the location. For example // {"cloud.googleapis.com/region": "us-east1"} Labels map[string]string `json:"labels,omitempty"` // LocationId: The canonical id for this location. For example: // "us-east1". LocationId string `json:"locationId,omitempty"` // Metadata: Service-specific metadata. For example the available // capacity at the given location. Metadata googleapi.RawMessage `json:"metadata,omitempty"` // Name: Resource name for the location, which may vary between // implementations. For example: // "projects/example-project/locations/us-east1" Name string `json:"name,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "DisplayName") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "DisplayName") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
Location: A resource that represents a Google Cloud location.
func (*Location) MarshalJSON ¶
type LookupStreamObjectRequest ¶
type LookupStreamObjectRequest struct { // SourceObjectIdentifier: Required. The source object identifier which // maps to the stream object. SourceObjectIdentifier *SourceObjectIdentifier `json:"sourceObjectIdentifier,omitempty"` // ForceSendFields is a list of field names (e.g. // "SourceObjectIdentifier") to unconditionally include in API requests. // By default, fields with empty or default values are omitted from API // requests. However, any non-pointer, non-interface field appearing in // ForceSendFields will be sent to the server regardless of whether the // field is empty or not. This may be used to include empty fields in // Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "SourceObjectIdentifier") // to include in API requests with the JSON null value. By default, // fields with empty values are omitted from API requests. However, any // field with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
LookupStreamObjectRequest: Request for looking up a specific stream object by its source object identifier.
func (*LookupStreamObjectRequest) MarshalJSON ¶
func (s *LookupStreamObjectRequest) MarshalJSON() ([]byte, error)
type MostRecentStartPosition ¶ added in v0.135.0
type MostRecentStartPosition struct { }
MostRecentStartPosition: CDC strategy to start replicating from the most recent position in the source.
type MysqlColumn ¶
type MysqlColumn struct { // Collation: Column collation. Collation string `json:"collation,omitempty"` // Column: Column name. Column string `json:"column,omitempty"` // DataType: The MySQL data type. Full data types list can be found // here: https://dev.mysql.com/doc/refman/8.0/en/data-types.html DataType string `json:"dataType,omitempty"` // Length: Column length. Length int64 `json:"length,omitempty"` // Nullable: Whether or not the column can accept a null value. Nullable bool `json:"nullable,omitempty"` // OrdinalPosition: The ordinal position of the column in the table. OrdinalPosition int64 `json:"ordinalPosition,omitempty"` // Precision: Column precision. Precision int64 `json:"precision,omitempty"` // PrimaryKey: Whether or not the column represents a primary key. PrimaryKey bool `json:"primaryKey,omitempty"` // Scale: Column scale. Scale int64 `json:"scale,omitempty"` // ForceSendFields is a list of field names (e.g. "Collation") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Collation") to include in // API requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
MysqlColumn: MySQL Column.
func (*MysqlColumn) MarshalJSON ¶
func (s *MysqlColumn) MarshalJSON() ([]byte, error)
type MysqlDatabase ¶
type MysqlDatabase struct { // Database: Database name. Database string `json:"database,omitempty"` // MysqlTables: Tables in the database. MysqlTables []*MysqlTable `json:"mysqlTables,omitempty"` // ForceSendFields is a list of field names (e.g. "Database") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Database") to include in // API requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
MysqlDatabase: MySQL database.
func (*MysqlDatabase) MarshalJSON ¶
func (s *MysqlDatabase) MarshalJSON() ([]byte, error)
type MysqlLogPosition ¶ added in v0.135.0
type MysqlLogPosition struct { // LogFile: Required. The binary log file name. LogFile string `json:"logFile,omitempty"` // LogPosition: Optional. The position within the binary log file. // Default is head of file. LogPosition int64 `json:"logPosition,omitempty"` // ForceSendFields is a list of field names (e.g. "LogFile") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "LogFile") to include in // API requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
MysqlLogPosition: MySQL log position
func (*MysqlLogPosition) MarshalJSON ¶ added in v0.135.0
func (s *MysqlLogPosition) MarshalJSON() ([]byte, error)
type MysqlObjectIdentifier ¶
type MysqlObjectIdentifier struct { // Database: Required. The database name. Database string `json:"database,omitempty"` // Table: Required. The table name. Table string `json:"table,omitempty"` // ForceSendFields is a list of field names (e.g. "Database") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Database") to include in // API requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
MysqlObjectIdentifier: Mysql data source object identifier.
func (*MysqlObjectIdentifier) MarshalJSON ¶
func (s *MysqlObjectIdentifier) MarshalJSON() ([]byte, error)
type MysqlProfile ¶
type MysqlProfile struct { // Hostname: Required. Hostname for the MySQL connection. Hostname string `json:"hostname,omitempty"` // Password: Required. Input only. Password for the MySQL connection. Password string `json:"password,omitempty"` // Port: Port for the MySQL connection, default value is 3306. Port int64 `json:"port,omitempty"` // SslConfig: SSL configuration for the MySQL connection. SslConfig *MysqlSslConfig `json:"sslConfig,omitempty"` // Username: Required. Username for the MySQL connection. Username string `json:"username,omitempty"` // ForceSendFields is a list of field names (e.g. "Hostname") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Hostname") to include in // API requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
MysqlProfile: MySQL database profile.
func (*MysqlProfile) MarshalJSON ¶
func (s *MysqlProfile) MarshalJSON() ([]byte, error)
type MysqlRdbms ¶
type MysqlRdbms struct { // MysqlDatabases: Mysql databases on the server MysqlDatabases []*MysqlDatabase `json:"mysqlDatabases,omitempty"` // ForceSendFields is a list of field names (e.g. "MysqlDatabases") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "MysqlDatabases") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
MysqlRdbms: MySQL database structure
func (*MysqlRdbms) MarshalJSON ¶
func (s *MysqlRdbms) MarshalJSON() ([]byte, error)
type MysqlSourceConfig ¶
type MysqlSourceConfig struct { // ExcludeObjects: MySQL objects to exclude from the stream. ExcludeObjects *MysqlRdbms `json:"excludeObjects,omitempty"` // IncludeObjects: MySQL objects to retrieve from the source. IncludeObjects *MysqlRdbms `json:"includeObjects,omitempty"` // MaxConcurrentBackfillTasks: Maximum number of concurrent backfill // tasks. The number should be non negative. If not set (or set to 0), // the system's default value will be used. MaxConcurrentBackfillTasks int64 `json:"maxConcurrentBackfillTasks,omitempty"` // MaxConcurrentCdcTasks: Maximum number of concurrent CDC tasks. The // number should be non negative. If not set (or set to 0), the system's // default value will be used. MaxConcurrentCdcTasks int64 `json:"maxConcurrentCdcTasks,omitempty"` // ForceSendFields is a list of field names (e.g. "ExcludeObjects") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "ExcludeObjects") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
MysqlSourceConfig: MySQL source configuration
func (*MysqlSourceConfig) MarshalJSON ¶
func (s *MysqlSourceConfig) MarshalJSON() ([]byte, error)
type MysqlSslConfig ¶
type MysqlSslConfig struct { // CaCertificate: Input only. PEM-encoded certificate of the CA that // signed the source database server's certificate. CaCertificate string `json:"caCertificate,omitempty"` // CaCertificateSet: Output only. Indicates whether the ca_certificate // field is set. CaCertificateSet bool `json:"caCertificateSet,omitempty"` // ClientCertificate: Input only. PEM-encoded certificate that will be // used by the replica to authenticate against the source database // server. If this field is used then the 'client_key' and the // 'ca_certificate' fields are mandatory. ClientCertificate string `json:"clientCertificate,omitempty"` // ClientCertificateSet: Output only. Indicates whether the // client_certificate field is set. ClientCertificateSet bool `json:"clientCertificateSet,omitempty"` // ClientKey: Input only. PEM-encoded private key associated with the // Client Certificate. If this field is used then the // 'client_certificate' and the 'ca_certificate' fields are mandatory. ClientKey string `json:"clientKey,omitempty"` // ClientKeySet: Output only. Indicates whether the client_key field is // set. ClientKeySet bool `json:"clientKeySet,omitempty"` // ForceSendFields is a list of field names (e.g. "CaCertificate") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "CaCertificate") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
MysqlSslConfig: MySQL SSL configuration information.
func (*MysqlSslConfig) MarshalJSON ¶
func (s *MysqlSslConfig) MarshalJSON() ([]byte, error)
type MysqlTable ¶
type MysqlTable struct { // MysqlColumns: MySQL columns in the database. When unspecified as part // of include/exclude objects, includes/excludes everything. MysqlColumns []*MysqlColumn `json:"mysqlColumns,omitempty"` // Table: Table name. Table string `json:"table,omitempty"` // ForceSendFields is a list of field names (e.g. "MysqlColumns") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "MysqlColumns") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
MysqlTable: MySQL table.
func (*MysqlTable) MarshalJSON ¶
func (s *MysqlTable) MarshalJSON() ([]byte, error)
type NextAvailableStartPosition ¶ added in v0.135.0
type NextAvailableStartPosition struct { }
NextAvailableStartPosition: CDC strategy to resume replication from the next available position in the source.
type Operation ¶
type Operation struct { // Done: If the value is `false`, it means the operation is still in // progress. If `true`, the operation is completed, and either `error` // or `response` is available. Done bool `json:"done,omitempty"` // Error: The error result of the operation in case of failure or // cancellation. Error *Status `json:"error,omitempty"` // Metadata: Service-specific metadata associated with the operation. It // typically contains progress information and common metadata such as // create time. Some services might not provide such metadata. Any // method that returns a long-running operation should document the // metadata type, if any. Metadata googleapi.RawMessage `json:"metadata,omitempty"` // Name: The server-assigned name, which is only unique within the same // service that originally returns it. If you use the default HTTP // mapping, the `name` should be a resource name ending with // `operations/{unique_id}`. Name string `json:"name,omitempty"` // Response: The normal, successful response of the operation. If the // original method returns no data on success, such as `Delete`, the // response is `google.protobuf.Empty`. If the original method is // standard `Get`/`Create`/`Update`, the response should be the // resource. For other methods, the response should have the type // `XxxResponse`, where `Xxx` is the original method name. For example, // if the original method name is `TakeSnapshot()`, the inferred // response type is `TakeSnapshotResponse`. Response googleapi.RawMessage `json:"response,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "Done") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Done") to include in API // requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
Operation: This resource represents a long-running operation that is the result of a network API call.
func (*Operation) MarshalJSON ¶
type OperationMetadata ¶
type OperationMetadata struct { // ApiVersion: Output only. API version used to start the operation. ApiVersion string `json:"apiVersion,omitempty"` // CreateTime: Output only. The time the operation was created. CreateTime string `json:"createTime,omitempty"` // EndTime: Output only. The time the operation finished running. EndTime string `json:"endTime,omitempty"` // RequestedCancellation: Output only. Identifies whether the user has // requested cancellation of the operation. Operations that have // successfully been cancelled have Operation.error value with a // google.rpc.Status.code of 1, corresponding to `Code.CANCELLED`. RequestedCancellation bool `json:"requestedCancellation,omitempty"` // StatusMessage: Output only. Human-readable status of the operation, // if any. StatusMessage string `json:"statusMessage,omitempty"` // Target: Output only. Server-defined resource path for the target of // the operation. Target string `json:"target,omitempty"` // ValidationResult: Output only. Results of executed validations if // there are any. ValidationResult *ValidationResult `json:"validationResult,omitempty"` // Verb: Output only. Name of the verb executed by the operation. Verb string `json:"verb,omitempty"` // ForceSendFields is a list of field names (e.g. "ApiVersion") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "ApiVersion") to include in // API requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
OperationMetadata: Represents the metadata of the long-running operation.
func (*OperationMetadata) MarshalJSON ¶
func (s *OperationMetadata) MarshalJSON() ([]byte, error)
type OracleColumn ¶
type OracleColumn struct { // Column: Column name. Column string `json:"column,omitempty"` // DataType: The Oracle data type. DataType string `json:"dataType,omitempty"` // Encoding: Column encoding. Encoding string `json:"encoding,omitempty"` // Length: Column length. Length int64 `json:"length,omitempty"` // Nullable: Whether or not the column can accept a null value. Nullable bool `json:"nullable,omitempty"` // OrdinalPosition: The ordinal position of the column in the table. OrdinalPosition int64 `json:"ordinalPosition,omitempty"` // Precision: Column precision. Precision int64 `json:"precision,omitempty"` // PrimaryKey: Whether or not the column represents a primary key. PrimaryKey bool `json:"primaryKey,omitempty"` // Scale: Column scale. Scale int64 `json:"scale,omitempty"` // ForceSendFields is a list of field names (e.g. "Column") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Column") to include in API // requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
OracleColumn: Oracle Column.
func (*OracleColumn) MarshalJSON ¶
func (s *OracleColumn) MarshalJSON() ([]byte, error)
type OracleObjectIdentifier ¶
type OracleObjectIdentifier struct { // Schema: Required. The schema name. Schema string `json:"schema,omitempty"` // Table: Required. The table name. Table string `json:"table,omitempty"` // ForceSendFields is a list of field names (e.g. "Schema") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Schema") to include in API // requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
OracleObjectIdentifier: Oracle data source object identifier.
func (*OracleObjectIdentifier) MarshalJSON ¶
func (s *OracleObjectIdentifier) MarshalJSON() ([]byte, error)
type OracleProfile ¶
type OracleProfile struct { // ConnectionAttributes: Connection string attributes ConnectionAttributes map[string]string `json:"connectionAttributes,omitempty"` // DatabaseService: Required. Database for the Oracle connection. DatabaseService string `json:"databaseService,omitempty"` // Hostname: Required. Hostname for the Oracle connection. Hostname string `json:"hostname,omitempty"` // OracleSslConfig: Optional. SSL configuration for the Oracle // connection. OracleSslConfig *OracleSslConfig `json:"oracleSslConfig,omitempty"` // Password: Required. Password for the Oracle connection. Password string `json:"password,omitempty"` // Port: Port for the Oracle connection, default value is 1521. Port int64 `json:"port,omitempty"` // Username: Required. Username for the Oracle connection. Username string `json:"username,omitempty"` // ForceSendFields is a list of field names (e.g. // "ConnectionAttributes") to unconditionally include in API requests. // By default, fields with empty or default values are omitted from API // requests. However, any non-pointer, non-interface field appearing in // ForceSendFields will be sent to the server regardless of whether the // field is empty or not. This may be used to include empty fields in // Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "ConnectionAttributes") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
OracleProfile: Oracle database profile.
func (*OracleProfile) MarshalJSON ¶
func (s *OracleProfile) MarshalJSON() ([]byte, error)
type OracleRdbms ¶
type OracleRdbms struct { // OracleSchemas: Oracle schemas/databases in the database server. OracleSchemas []*OracleSchema `json:"oracleSchemas,omitempty"` // ForceSendFields is a list of field names (e.g. "OracleSchemas") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "OracleSchemas") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
OracleRdbms: Oracle database structure.
func (*OracleRdbms) MarshalJSON ¶
func (s *OracleRdbms) MarshalJSON() ([]byte, error)
type OracleSchema ¶
type OracleSchema struct { // OracleTables: Tables in the schema. OracleTables []*OracleTable `json:"oracleTables,omitempty"` // Schema: Schema name. Schema string `json:"schema,omitempty"` // ForceSendFields is a list of field names (e.g. "OracleTables") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "OracleTables") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
OracleSchema: Oracle schema.
func (*OracleSchema) MarshalJSON ¶
func (s *OracleSchema) MarshalJSON() ([]byte, error)
type OracleSourceConfig ¶
type OracleSourceConfig struct { // DropLargeObjects: Drop large object values. DropLargeObjects *DropLargeObjects `json:"dropLargeObjects,omitempty"` // ExcludeObjects: Oracle objects to exclude from the stream. ExcludeObjects *OracleRdbms `json:"excludeObjects,omitempty"` // IncludeObjects: Oracle objects to include in the stream. IncludeObjects *OracleRdbms `json:"includeObjects,omitempty"` // MaxConcurrentBackfillTasks: Maximum number of concurrent backfill // tasks. The number should be non-negative. If not set (or set to 0), // the system's default value is used. MaxConcurrentBackfillTasks int64 `json:"maxConcurrentBackfillTasks,omitempty"` // MaxConcurrentCdcTasks: Maximum number of concurrent CDC tasks. The // number should be non-negative. If not set (or set to 0), the system's // default value is used. MaxConcurrentCdcTasks int64 `json:"maxConcurrentCdcTasks,omitempty"` // StreamLargeObjects: Stream large object values. NOTE: This feature is // currently experimental. StreamLargeObjects *StreamLargeObjects `json:"streamLargeObjects,omitempty"` // ForceSendFields is a list of field names (e.g. "DropLargeObjects") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "DropLargeObjects") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
OracleSourceConfig: Oracle data source configuration
func (*OracleSourceConfig) MarshalJSON ¶
func (s *OracleSourceConfig) MarshalJSON() ([]byte, error)
type OracleSslConfig ¶ added in v0.139.0
type OracleSslConfig struct { // CaCertificate: Input only. PEM-encoded certificate of the CA that // signed the source database server's certificate. CaCertificate string `json:"caCertificate,omitempty"` // CaCertificateSet: Output only. Indicates whether the ca_certificate // field has been set for this Connection-Profile. CaCertificateSet bool `json:"caCertificateSet,omitempty"` // ForceSendFields is a list of field names (e.g. "CaCertificate") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "CaCertificate") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
OracleSslConfig: Oracle SSL configuration information.
func (*OracleSslConfig) MarshalJSON ¶ added in v0.139.0
func (s *OracleSslConfig) MarshalJSON() ([]byte, error)
type OracleTable ¶
type OracleTable struct { // OracleColumns: Oracle columns in the schema. When unspecified as part // of include/exclude objects, includes/excludes everything. OracleColumns []*OracleColumn `json:"oracleColumns,omitempty"` // Table: Table name. Table string `json:"table,omitempty"` // ForceSendFields is a list of field names (e.g. "OracleColumns") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "OracleColumns") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
OracleTable: Oracle table.
func (*OracleTable) MarshalJSON ¶
func (s *OracleTable) MarshalJSON() ([]byte, error)
type PostgresqlColumn ¶ added in v0.96.0
type PostgresqlColumn struct { // Column: Column name. Column string `json:"column,omitempty"` // DataType: The PostgreSQL data type. DataType string `json:"dataType,omitempty"` // Length: Column length. Length int64 `json:"length,omitempty"` // Nullable: Whether or not the column can accept a null value. Nullable bool `json:"nullable,omitempty"` // OrdinalPosition: The ordinal position of the column in the table. OrdinalPosition int64 `json:"ordinalPosition,omitempty"` // Precision: Column precision. Precision int64 `json:"precision,omitempty"` // PrimaryKey: Whether or not the column represents a primary key. PrimaryKey bool `json:"primaryKey,omitempty"` // Scale: Column scale. Scale int64 `json:"scale,omitempty"` // ForceSendFields is a list of field names (e.g. "Column") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Column") to include in API // requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
PostgresqlColumn: PostgreSQL Column.
func (*PostgresqlColumn) MarshalJSON ¶ added in v0.96.0
func (s *PostgresqlColumn) MarshalJSON() ([]byte, error)
type PostgresqlObjectIdentifier ¶ added in v0.96.0
type PostgresqlObjectIdentifier struct { // Schema: Required. The schema name. Schema string `json:"schema,omitempty"` // Table: Required. The table name. Table string `json:"table,omitempty"` // ForceSendFields is a list of field names (e.g. "Schema") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Schema") to include in API // requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
PostgresqlObjectIdentifier: PostgreSQL data source object identifier.
func (*PostgresqlObjectIdentifier) MarshalJSON ¶ added in v0.96.0
func (s *PostgresqlObjectIdentifier) MarshalJSON() ([]byte, error)
type PostgresqlProfile ¶ added in v0.96.0
type PostgresqlProfile struct { // Database: Required. Database for the PostgreSQL connection. Database string `json:"database,omitempty"` // Hostname: Required. Hostname for the PostgreSQL connection. Hostname string `json:"hostname,omitempty"` // Password: Required. Password for the PostgreSQL connection. Password string `json:"password,omitempty"` // Port: Port for the PostgreSQL connection, default value is 5432. Port int64 `json:"port,omitempty"` // Username: Required. Username for the PostgreSQL connection. Username string `json:"username,omitempty"` // ForceSendFields is a list of field names (e.g. "Database") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Database") to include in // API requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
PostgresqlProfile: PostgreSQL database profile.
func (*PostgresqlProfile) MarshalJSON ¶ added in v0.96.0
func (s *PostgresqlProfile) MarshalJSON() ([]byte, error)
type PostgresqlRdbms ¶ added in v0.96.0
type PostgresqlRdbms struct { // PostgresqlSchemas: PostgreSQL schemas in the database server. PostgresqlSchemas []*PostgresqlSchema `json:"postgresqlSchemas,omitempty"` // ForceSendFields is a list of field names (e.g. "PostgresqlSchemas") // to unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "PostgresqlSchemas") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
PostgresqlRdbms: PostgreSQL database structure.
func (*PostgresqlRdbms) MarshalJSON ¶ added in v0.96.0
func (s *PostgresqlRdbms) MarshalJSON() ([]byte, error)
type PostgresqlSchema ¶ added in v0.96.0
type PostgresqlSchema struct { // PostgresqlTables: Tables in the schema. PostgresqlTables []*PostgresqlTable `json:"postgresqlTables,omitempty"` // Schema: Schema name. Schema string `json:"schema,omitempty"` // ForceSendFields is a list of field names (e.g. "PostgresqlTables") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "PostgresqlTables") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
PostgresqlSchema: PostgreSQL schema.
func (*PostgresqlSchema) MarshalJSON ¶ added in v0.96.0
func (s *PostgresqlSchema) MarshalJSON() ([]byte, error)
type PostgresqlSourceConfig ¶ added in v0.96.0
type PostgresqlSourceConfig struct { // ExcludeObjects: PostgreSQL objects to exclude from the stream. ExcludeObjects *PostgresqlRdbms `json:"excludeObjects,omitempty"` // IncludeObjects: PostgreSQL objects to include in the stream. IncludeObjects *PostgresqlRdbms `json:"includeObjects,omitempty"` // MaxConcurrentBackfillTasks: Maximum number of concurrent backfill // tasks. The number should be non negative. If not set (or set to 0), // the system's default value will be used. MaxConcurrentBackfillTasks int64 `json:"maxConcurrentBackfillTasks,omitempty"` // Publication: Required. The name of the publication that includes the // set of all tables that are defined in the stream's include_objects. Publication string `json:"publication,omitempty"` // ReplicationSlot: Required. Immutable. The name of the logical // replication slot that's configured with the pgoutput plugin. ReplicationSlot string `json:"replicationSlot,omitempty"` // ForceSendFields is a list of field names (e.g. "ExcludeObjects") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "ExcludeObjects") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
PostgresqlSourceConfig: PostgreSQL data source configuration
func (*PostgresqlSourceConfig) MarshalJSON ¶ added in v0.96.0
func (s *PostgresqlSourceConfig) MarshalJSON() ([]byte, error)
type PostgresqlTable ¶ added in v0.96.0
type PostgresqlTable struct { // PostgresqlColumns: PostgreSQL columns in the schema. When unspecified // as part of include/exclude objects, includes/excludes everything. PostgresqlColumns []*PostgresqlColumn `json:"postgresqlColumns,omitempty"` // Table: Table name. Table string `json:"table,omitempty"` // ForceSendFields is a list of field names (e.g. "PostgresqlColumns") // to unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "PostgresqlColumns") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
PostgresqlTable: PostgreSQL table.
func (*PostgresqlTable) MarshalJSON ¶ added in v0.96.0
func (s *PostgresqlTable) MarshalJSON() ([]byte, error)
type PrivateConnection ¶
type PrivateConnection struct { // CreateTime: Output only. The create time of the resource. CreateTime string `json:"createTime,omitempty"` // DisplayName: Required. Display name. DisplayName string `json:"displayName,omitempty"` // Error: Output only. In case of error, the details of the error in a // user-friendly format. Error *Error `json:"error,omitempty"` // Labels: Labels. Labels map[string]string `json:"labels,omitempty"` // Name: Output only. The resource's name. Name string `json:"name,omitempty"` // State: Output only. The state of the Private Connection. // // Possible values: // "STATE_UNSPECIFIED" - Unspecified state. // "CREATING" - The private connection is in creation state - creating // resources. // "CREATED" - The private connection has been created with all of its // resources. // "FAILED" - The private connection creation has failed. // "DELETING" - The private connection is being deleted. // "FAILED_TO_DELETE" - Delete request has failed, resource is in // invalid state. State string `json:"state,omitempty"` // UpdateTime: Output only. The update time of the resource. UpdateTime string `json:"updateTime,omitempty"` // VpcPeeringConfig: VPC Peering Config. VpcPeeringConfig *VpcPeeringConfig `json:"vpcPeeringConfig,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "CreateTime") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "CreateTime") to include in // API requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
PrivateConnection: The PrivateConnection resource is used to establish private connectivity between Datastream and a customer's network.
func (*PrivateConnection) MarshalJSON ¶
func (s *PrivateConnection) MarshalJSON() ([]byte, error)
type PrivateConnectivity ¶
type PrivateConnectivity struct { // PrivateConnection: Required. A reference to a private connection // resource. Format: // `projects/{project}/locations/{location}/privateConnections/{name}` PrivateConnection string `json:"privateConnection,omitempty"` // ForceSendFields is a list of field names (e.g. "PrivateConnection") // to unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "PrivateConnection") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
PrivateConnectivity: Private Connectivity
func (*PrivateConnectivity) MarshalJSON ¶
func (s *PrivateConnectivity) MarshalJSON() ([]byte, error)
type ProjectsLocationsConnectionProfilesCreateCall ¶
type ProjectsLocationsConnectionProfilesCreateCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsConnectionProfilesCreateCall) ConnectionProfileId ¶
func (c *ProjectsLocationsConnectionProfilesCreateCall) ConnectionProfileId(connectionProfileId string) *ProjectsLocationsConnectionProfilesCreateCall
ConnectionProfileId sets the optional parameter "connectionProfileId": Required. The connection profile identifier.
func (*ProjectsLocationsConnectionProfilesCreateCall) Context ¶
func (c *ProjectsLocationsConnectionProfilesCreateCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesCreateCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsConnectionProfilesCreateCall) Do ¶
func (c *ProjectsLocationsConnectionProfilesCreateCall) Do(opts ...googleapi.CallOption) (*Operation, error)
Do executes the "datastream.projects.locations.connectionProfiles.create" call. Exactly one of *Operation or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Operation.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsConnectionProfilesCreateCall) Fields ¶
func (c *ProjectsLocationsConnectionProfilesCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesCreateCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsConnectionProfilesCreateCall) Force ¶
func (c *ProjectsLocationsConnectionProfilesCreateCall) Force(force bool) *ProjectsLocationsConnectionProfilesCreateCall
Force sets the optional parameter "force": Create the connection profile without validating it.
func (*ProjectsLocationsConnectionProfilesCreateCall) Header ¶
func (c *ProjectsLocationsConnectionProfilesCreateCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsConnectionProfilesCreateCall) RequestId ¶
func (c *ProjectsLocationsConnectionProfilesCreateCall) RequestId(requestId string) *ProjectsLocationsConnectionProfilesCreateCall
RequestId sets the optional parameter "requestId": A request ID to identify requests. Specify a unique request ID so that if you must retry your request, the server will know to ignore the request if it has already been completed. The server will guarantee that for at least 60 minutes since the first request. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID, the server can check if original operation with the same request ID was received, and if so, will ignore the second request. This prevents clients from accidentally creating duplicate commitments. The request ID must be a valid UUID with the exception that zero UUID is not supported (00000000-0000-0000-0000-000000000000).
func (*ProjectsLocationsConnectionProfilesCreateCall) ValidateOnly ¶ added in v0.66.0
func (c *ProjectsLocationsConnectionProfilesCreateCall) ValidateOnly(validateOnly bool) *ProjectsLocationsConnectionProfilesCreateCall
ValidateOnly sets the optional parameter "validateOnly": Only validate the connection profile, but don't create any resources. The default is false.
type ProjectsLocationsConnectionProfilesDeleteCall ¶
type ProjectsLocationsConnectionProfilesDeleteCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsConnectionProfilesDeleteCall) Context ¶
func (c *ProjectsLocationsConnectionProfilesDeleteCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesDeleteCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsConnectionProfilesDeleteCall) Do ¶
func (c *ProjectsLocationsConnectionProfilesDeleteCall) Do(opts ...googleapi.CallOption) (*Operation, error)
Do executes the "datastream.projects.locations.connectionProfiles.delete" call. Exactly one of *Operation or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Operation.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsConnectionProfilesDeleteCall) Fields ¶
func (c *ProjectsLocationsConnectionProfilesDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesDeleteCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsConnectionProfilesDeleteCall) Header ¶
func (c *ProjectsLocationsConnectionProfilesDeleteCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsConnectionProfilesDeleteCall) RequestId ¶
func (c *ProjectsLocationsConnectionProfilesDeleteCall) RequestId(requestId string) *ProjectsLocationsConnectionProfilesDeleteCall
RequestId sets the optional parameter "requestId": A request ID to identify requests. Specify a unique request ID so that if you must retry your request, the server will know to ignore the request if it has already been completed. The server will guarantee that for at least 60 minutes after the first request. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID, the server can check if original operation with the same request ID was received, and if so, will ignore the second request. This prevents clients from accidentally creating duplicate commitments. The request ID must be a valid UUID with the exception that zero UUID is not supported (00000000-0000-0000-0000-000000000000).
type ProjectsLocationsConnectionProfilesDiscoverCall ¶
type ProjectsLocationsConnectionProfilesDiscoverCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsConnectionProfilesDiscoverCall) Context ¶
func (c *ProjectsLocationsConnectionProfilesDiscoverCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesDiscoverCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsConnectionProfilesDiscoverCall) Do ¶
func (c *ProjectsLocationsConnectionProfilesDiscoverCall) Do(opts ...googleapi.CallOption) (*DiscoverConnectionProfileResponse, error)
Do executes the "datastream.projects.locations.connectionProfiles.discover" call. Exactly one of *DiscoverConnectionProfileResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *DiscoverConnectionProfileResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsConnectionProfilesDiscoverCall) Fields ¶
func (c *ProjectsLocationsConnectionProfilesDiscoverCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesDiscoverCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsConnectionProfilesDiscoverCall) Header ¶
func (c *ProjectsLocationsConnectionProfilesDiscoverCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
type ProjectsLocationsConnectionProfilesGetCall ¶
type ProjectsLocationsConnectionProfilesGetCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsConnectionProfilesGetCall) Context ¶
func (c *ProjectsLocationsConnectionProfilesGetCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesGetCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsConnectionProfilesGetCall) Do ¶
func (c *ProjectsLocationsConnectionProfilesGetCall) Do(opts ...googleapi.CallOption) (*ConnectionProfile, error)
Do executes the "datastream.projects.locations.connectionProfiles.get" call. Exactly one of *ConnectionProfile or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *ConnectionProfile.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsConnectionProfilesGetCall) Fields ¶
func (c *ProjectsLocationsConnectionProfilesGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesGetCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsConnectionProfilesGetCall) Header ¶
func (c *ProjectsLocationsConnectionProfilesGetCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsConnectionProfilesGetCall) IfNoneMatch ¶
func (c *ProjectsLocationsConnectionProfilesGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsConnectionProfilesGetCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
type ProjectsLocationsConnectionProfilesListCall ¶
type ProjectsLocationsConnectionProfilesListCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsConnectionProfilesListCall) Context ¶
func (c *ProjectsLocationsConnectionProfilesListCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesListCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsConnectionProfilesListCall) Do ¶
func (c *ProjectsLocationsConnectionProfilesListCall) Do(opts ...googleapi.CallOption) (*ListConnectionProfilesResponse, error)
Do executes the "datastream.projects.locations.connectionProfiles.list" call. Exactly one of *ListConnectionProfilesResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *ListConnectionProfilesResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsConnectionProfilesListCall) Fields ¶
func (c *ProjectsLocationsConnectionProfilesListCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesListCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsConnectionProfilesListCall) Filter ¶
func (c *ProjectsLocationsConnectionProfilesListCall) Filter(filter string) *ProjectsLocationsConnectionProfilesListCall
Filter sets the optional parameter "filter": Filter request.
func (*ProjectsLocationsConnectionProfilesListCall) Header ¶
func (c *ProjectsLocationsConnectionProfilesListCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsConnectionProfilesListCall) IfNoneMatch ¶
func (c *ProjectsLocationsConnectionProfilesListCall) IfNoneMatch(entityTag string) *ProjectsLocationsConnectionProfilesListCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
func (*ProjectsLocationsConnectionProfilesListCall) OrderBy ¶
func (c *ProjectsLocationsConnectionProfilesListCall) OrderBy(orderBy string) *ProjectsLocationsConnectionProfilesListCall
OrderBy sets the optional parameter "orderBy": Order by fields for the result.
func (*ProjectsLocationsConnectionProfilesListCall) PageSize ¶
func (c *ProjectsLocationsConnectionProfilesListCall) PageSize(pageSize int64) *ProjectsLocationsConnectionProfilesListCall
PageSize sets the optional parameter "pageSize": Maximum number of connection profiles to return. If unspecified, at most 50 connection profiles will be returned. The maximum value is 1000; values above 1000 will be coerced to 1000.
func (*ProjectsLocationsConnectionProfilesListCall) PageToken ¶
func (c *ProjectsLocationsConnectionProfilesListCall) PageToken(pageToken string) *ProjectsLocationsConnectionProfilesListCall
PageToken sets the optional parameter "pageToken": Page token received from a previous `ListConnectionProfiles` call. Provide this to retrieve the subsequent page. When paginating, all other parameters provided to `ListConnectionProfiles` must match the call that provided the page token.
func (*ProjectsLocationsConnectionProfilesListCall) Pages ¶
func (c *ProjectsLocationsConnectionProfilesListCall) Pages(ctx context.Context, f func(*ListConnectionProfilesResponse) error) error
Pages invokes f for each page of results. A non-nil error returned from f will halt the iteration. The provided context supersedes any context provided to the Context method.
type ProjectsLocationsConnectionProfilesPatchCall ¶
type ProjectsLocationsConnectionProfilesPatchCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsConnectionProfilesPatchCall) Context ¶
func (c *ProjectsLocationsConnectionProfilesPatchCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesPatchCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsConnectionProfilesPatchCall) Do ¶
func (c *ProjectsLocationsConnectionProfilesPatchCall) Do(opts ...googleapi.CallOption) (*Operation, error)
Do executes the "datastream.projects.locations.connectionProfiles.patch" call. Exactly one of *Operation or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Operation.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsConnectionProfilesPatchCall) Fields ¶
func (c *ProjectsLocationsConnectionProfilesPatchCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesPatchCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsConnectionProfilesPatchCall) Force ¶
func (c *ProjectsLocationsConnectionProfilesPatchCall) Force(force bool) *ProjectsLocationsConnectionProfilesPatchCall
Force sets the optional parameter "force": Update the connection profile without validating it.
func (*ProjectsLocationsConnectionProfilesPatchCall) Header ¶
func (c *ProjectsLocationsConnectionProfilesPatchCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsConnectionProfilesPatchCall) RequestId ¶
func (c *ProjectsLocationsConnectionProfilesPatchCall) RequestId(requestId string) *ProjectsLocationsConnectionProfilesPatchCall
RequestId sets the optional parameter "requestId": A request ID to identify requests. Specify a unique request ID so that if you must retry your request, the server will know to ignore the request if it has already been completed. The server will guarantee that for at least 60 minutes since the first request. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID, the server can check if original operation with the same request ID was received, and if so, will ignore the second request. This prevents clients from accidentally creating duplicate commitments. The request ID must be a valid UUID with the exception that zero UUID is not supported (00000000-0000-0000-0000-000000000000).
func (*ProjectsLocationsConnectionProfilesPatchCall) UpdateMask ¶
func (c *ProjectsLocationsConnectionProfilesPatchCall) UpdateMask(updateMask string) *ProjectsLocationsConnectionProfilesPatchCall
UpdateMask sets the optional parameter "updateMask": Field mask is used to specify the fields to be overwritten in the ConnectionProfile resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask then all fields will be overwritten.
func (*ProjectsLocationsConnectionProfilesPatchCall) ValidateOnly ¶ added in v0.66.0
func (c *ProjectsLocationsConnectionProfilesPatchCall) ValidateOnly(validateOnly bool) *ProjectsLocationsConnectionProfilesPatchCall
ValidateOnly sets the optional parameter "validateOnly": Only validate the connection profile, but don't update any resources. The default is false.
type ProjectsLocationsConnectionProfilesService ¶
type ProjectsLocationsConnectionProfilesService struct {
// contains filtered or unexported fields
}
func NewProjectsLocationsConnectionProfilesService ¶
func NewProjectsLocationsConnectionProfilesService(s *Service) *ProjectsLocationsConnectionProfilesService
func (*ProjectsLocationsConnectionProfilesService) Create ¶
func (r *ProjectsLocationsConnectionProfilesService) Create(parent string, connectionprofile *ConnectionProfile) *ProjectsLocationsConnectionProfilesCreateCall
Create: Use this method to create a connection profile in a project and location.
- parent: The parent that owns the collection of ConnectionProfiles.
func (*ProjectsLocationsConnectionProfilesService) Delete ¶
func (r *ProjectsLocationsConnectionProfilesService) Delete(name string) *ProjectsLocationsConnectionProfilesDeleteCall
Delete: Use this method to delete a connection profile.
- name: The name of the connection profile resource to delete.
func (*ProjectsLocationsConnectionProfilesService) Discover ¶
func (r *ProjectsLocationsConnectionProfilesService) Discover(parent string, discoverconnectionprofilerequest *DiscoverConnectionProfileRequest) *ProjectsLocationsConnectionProfilesDiscoverCall
Discover: Use this method to discover a connection profile. The discover API call exposes the data objects and metadata belonging to the profile. Typically, a request returns children data objects of a parent data object that's optionally supplied in the request.
- parent: The parent resource of the connection profile type. Must be in the format `projects/*/locations/*`.
func (*ProjectsLocationsConnectionProfilesService) Get ¶
func (r *ProjectsLocationsConnectionProfilesService) Get(name string) *ProjectsLocationsConnectionProfilesGetCall
Get: Use this method to get details about a connection profile.
- name: The name of the connection profile resource to get.
func (*ProjectsLocationsConnectionProfilesService) List ¶
func (r *ProjectsLocationsConnectionProfilesService) List(parent string) *ProjectsLocationsConnectionProfilesListCall
List: Use this method to list connection profiles created in a project and location.
- parent: The parent that owns the collection of connection profiles.
func (*ProjectsLocationsConnectionProfilesService) Patch ¶
func (r *ProjectsLocationsConnectionProfilesService) Patch(name string, connectionprofile *ConnectionProfile) *ProjectsLocationsConnectionProfilesPatchCall
Patch: Use this method to update the parameters of a connection profile.
- name: Output only. The resource's name.
type ProjectsLocationsFetchStaticIpsCall ¶
type ProjectsLocationsFetchStaticIpsCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsFetchStaticIpsCall) Context ¶
func (c *ProjectsLocationsFetchStaticIpsCall) Context(ctx context.Context) *ProjectsLocationsFetchStaticIpsCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsFetchStaticIpsCall) Do ¶
func (c *ProjectsLocationsFetchStaticIpsCall) Do(opts ...googleapi.CallOption) (*FetchStaticIpsResponse, error)
Do executes the "datastream.projects.locations.fetchStaticIps" call. Exactly one of *FetchStaticIpsResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *FetchStaticIpsResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsFetchStaticIpsCall) Fields ¶
func (c *ProjectsLocationsFetchStaticIpsCall) Fields(s ...googleapi.Field) *ProjectsLocationsFetchStaticIpsCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsFetchStaticIpsCall) Header ¶
func (c *ProjectsLocationsFetchStaticIpsCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsFetchStaticIpsCall) IfNoneMatch ¶
func (c *ProjectsLocationsFetchStaticIpsCall) IfNoneMatch(entityTag string) *ProjectsLocationsFetchStaticIpsCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
func (*ProjectsLocationsFetchStaticIpsCall) PageSize ¶
func (c *ProjectsLocationsFetchStaticIpsCall) PageSize(pageSize int64) *ProjectsLocationsFetchStaticIpsCall
PageSize sets the optional parameter "pageSize": Maximum number of Ips to return, will likely not be specified.
func (*ProjectsLocationsFetchStaticIpsCall) PageToken ¶
func (c *ProjectsLocationsFetchStaticIpsCall) PageToken(pageToken string) *ProjectsLocationsFetchStaticIpsCall
PageToken sets the optional parameter "pageToken": A page token, received from a previous `ListStaticIps` call. will likely not be specified.
func (*ProjectsLocationsFetchStaticIpsCall) Pages ¶
func (c *ProjectsLocationsFetchStaticIpsCall) Pages(ctx context.Context, f func(*FetchStaticIpsResponse) error) error
Pages invokes f for each page of results. A non-nil error returned from f will halt the iteration. The provided context supersedes any context provided to the Context method.
type ProjectsLocationsGetCall ¶
type ProjectsLocationsGetCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsGetCall) Context ¶
func (c *ProjectsLocationsGetCall) Context(ctx context.Context) *ProjectsLocationsGetCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsGetCall) Do ¶
func (c *ProjectsLocationsGetCall) Do(opts ...googleapi.CallOption) (*Location, error)
Do executes the "datastream.projects.locations.get" call. Exactly one of *Location or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Location.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsGetCall) Fields ¶
func (c *ProjectsLocationsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsGetCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsGetCall) Header ¶
func (c *ProjectsLocationsGetCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsGetCall) IfNoneMatch ¶
func (c *ProjectsLocationsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsGetCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
type ProjectsLocationsListCall ¶
type ProjectsLocationsListCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsListCall) Context ¶
func (c *ProjectsLocationsListCall) Context(ctx context.Context) *ProjectsLocationsListCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsListCall) Do ¶
func (c *ProjectsLocationsListCall) Do(opts ...googleapi.CallOption) (*ListLocationsResponse, error)
Do executes the "datastream.projects.locations.list" call. Exactly one of *ListLocationsResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *ListLocationsResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsListCall) Fields ¶
func (c *ProjectsLocationsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsListCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsListCall) Filter ¶
func (c *ProjectsLocationsListCall) Filter(filter string) *ProjectsLocationsListCall
Filter sets the optional parameter "filter": A filter to narrow down results to a preferred subset. The filtering language accepts strings like "displayName=tokyo", and is documented in more detail in AIP-160 (https://google.aip.dev/160).
func (*ProjectsLocationsListCall) Header ¶
func (c *ProjectsLocationsListCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsListCall) IfNoneMatch ¶
func (c *ProjectsLocationsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsListCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
func (*ProjectsLocationsListCall) PageSize ¶
func (c *ProjectsLocationsListCall) PageSize(pageSize int64) *ProjectsLocationsListCall
PageSize sets the optional parameter "pageSize": The maximum number of results to return. If not set, the service selects a default.
func (*ProjectsLocationsListCall) PageToken ¶
func (c *ProjectsLocationsListCall) PageToken(pageToken string) *ProjectsLocationsListCall
PageToken sets the optional parameter "pageToken": A page token received from the `next_page_token` field in the response. Send that page token to receive the subsequent page.
func (*ProjectsLocationsListCall) Pages ¶
func (c *ProjectsLocationsListCall) Pages(ctx context.Context, f func(*ListLocationsResponse) error) error
Pages invokes f for each page of results. A non-nil error returned from f will halt the iteration. The provided context supersedes any context provided to the Context method.
type ProjectsLocationsOperationsCancelCall ¶
type ProjectsLocationsOperationsCancelCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsOperationsCancelCall) Context ¶
func (c *ProjectsLocationsOperationsCancelCall) Context(ctx context.Context) *ProjectsLocationsOperationsCancelCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsOperationsCancelCall) Do ¶
func (c *ProjectsLocationsOperationsCancelCall) Do(opts ...googleapi.CallOption) (*Empty, error)
Do executes the "datastream.projects.locations.operations.cancel" call. Exactly one of *Empty or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Empty.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsOperationsCancelCall) Fields ¶
func (c *ProjectsLocationsOperationsCancelCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsCancelCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsOperationsCancelCall) Header ¶
func (c *ProjectsLocationsOperationsCancelCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
type ProjectsLocationsOperationsDeleteCall ¶
type ProjectsLocationsOperationsDeleteCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsOperationsDeleteCall) Context ¶
func (c *ProjectsLocationsOperationsDeleteCall) Context(ctx context.Context) *ProjectsLocationsOperationsDeleteCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsOperationsDeleteCall) Do ¶
func (c *ProjectsLocationsOperationsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error)
Do executes the "datastream.projects.locations.operations.delete" call. Exactly one of *Empty or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Empty.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsOperationsDeleteCall) Fields ¶
func (c *ProjectsLocationsOperationsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsDeleteCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsOperationsDeleteCall) Header ¶
func (c *ProjectsLocationsOperationsDeleteCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
type ProjectsLocationsOperationsGetCall ¶
type ProjectsLocationsOperationsGetCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsOperationsGetCall) Context ¶
func (c *ProjectsLocationsOperationsGetCall) Context(ctx context.Context) *ProjectsLocationsOperationsGetCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsOperationsGetCall) Do ¶
func (c *ProjectsLocationsOperationsGetCall) Do(opts ...googleapi.CallOption) (*Operation, error)
Do executes the "datastream.projects.locations.operations.get" call. Exactly one of *Operation or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Operation.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsOperationsGetCall) Fields ¶
func (c *ProjectsLocationsOperationsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsGetCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsOperationsGetCall) Header ¶
func (c *ProjectsLocationsOperationsGetCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsOperationsGetCall) IfNoneMatch ¶
func (c *ProjectsLocationsOperationsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsOperationsGetCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
type ProjectsLocationsOperationsListCall ¶
type ProjectsLocationsOperationsListCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsOperationsListCall) Context ¶
func (c *ProjectsLocationsOperationsListCall) Context(ctx context.Context) *ProjectsLocationsOperationsListCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsOperationsListCall) Do ¶
func (c *ProjectsLocationsOperationsListCall) Do(opts ...googleapi.CallOption) (*ListOperationsResponse, error)
Do executes the "datastream.projects.locations.operations.list" call. Exactly one of *ListOperationsResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *ListOperationsResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsOperationsListCall) Fields ¶
func (c *ProjectsLocationsOperationsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsListCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsOperationsListCall) Filter ¶
func (c *ProjectsLocationsOperationsListCall) Filter(filter string) *ProjectsLocationsOperationsListCall
Filter sets the optional parameter "filter": The standard list filter.
func (*ProjectsLocationsOperationsListCall) Header ¶
func (c *ProjectsLocationsOperationsListCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsOperationsListCall) IfNoneMatch ¶
func (c *ProjectsLocationsOperationsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsOperationsListCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
func (*ProjectsLocationsOperationsListCall) PageSize ¶
func (c *ProjectsLocationsOperationsListCall) PageSize(pageSize int64) *ProjectsLocationsOperationsListCall
PageSize sets the optional parameter "pageSize": The standard list page size.
func (*ProjectsLocationsOperationsListCall) PageToken ¶
func (c *ProjectsLocationsOperationsListCall) PageToken(pageToken string) *ProjectsLocationsOperationsListCall
PageToken sets the optional parameter "pageToken": The standard list page token.
func (*ProjectsLocationsOperationsListCall) Pages ¶
func (c *ProjectsLocationsOperationsListCall) Pages(ctx context.Context, f func(*ListOperationsResponse) error) error
Pages invokes f for each page of results. A non-nil error returned from f will halt the iteration. The provided context supersedes any context provided to the Context method.
type ProjectsLocationsOperationsService ¶
type ProjectsLocationsOperationsService struct {
// contains filtered or unexported fields
}
func NewProjectsLocationsOperationsService ¶
func NewProjectsLocationsOperationsService(s *Service) *ProjectsLocationsOperationsService
func (*ProjectsLocationsOperationsService) Cancel ¶
func (r *ProjectsLocationsOperationsService) Cancel(name string, canceloperationrequest *CancelOperationRequest) *ProjectsLocationsOperationsCancelCall
Cancel: Starts asynchronous cancellation on a long-running operation. The server makes a best effort to cancel the operation, but success is not guaranteed. If the server doesn't support this method, it returns `google.rpc.Code.UNIMPLEMENTED`. Clients can use Operations.GetOperation or other methods to check whether the cancellation succeeded or whether the operation completed despite cancellation. On successful cancellation, the operation is not deleted; instead, it becomes an operation with an Operation.error value with a google.rpc.Status.code of 1, corresponding to `Code.CANCELLED`.
- name: The name of the operation resource to be cancelled.
func (*ProjectsLocationsOperationsService) Delete ¶
func (r *ProjectsLocationsOperationsService) Delete(name string) *ProjectsLocationsOperationsDeleteCall
Delete: Deletes a long-running operation. This method indicates that the client is no longer interested in the operation result. It does not cancel the operation. If the server doesn't support this method, it returns `google.rpc.Code.UNIMPLEMENTED`.
- name: The name of the operation resource to be deleted.
func (*ProjectsLocationsOperationsService) Get ¶
func (r *ProjectsLocationsOperationsService) Get(name string) *ProjectsLocationsOperationsGetCall
Get: Gets the latest state of a long-running operation. Clients can use this method to poll the operation result at intervals as recommended by the API service.
- name: The name of the operation resource.
func (*ProjectsLocationsOperationsService) List ¶
func (r *ProjectsLocationsOperationsService) List(name string) *ProjectsLocationsOperationsListCall
List: Lists operations that match the specified filter in the request. If the server doesn't support this method, it returns `UNIMPLEMENTED`.
- name: The name of the operation's parent resource.
type ProjectsLocationsPrivateConnectionsCreateCall ¶
type ProjectsLocationsPrivateConnectionsCreateCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsPrivateConnectionsCreateCall) Context ¶
func (c *ProjectsLocationsPrivateConnectionsCreateCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsCreateCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsPrivateConnectionsCreateCall) Do ¶
func (c *ProjectsLocationsPrivateConnectionsCreateCall) Do(opts ...googleapi.CallOption) (*Operation, error)
Do executes the "datastream.projects.locations.privateConnections.create" call. Exactly one of *Operation or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Operation.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsPrivateConnectionsCreateCall) Fields ¶
func (c *ProjectsLocationsPrivateConnectionsCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsCreateCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsPrivateConnectionsCreateCall) Force ¶ added in v0.106.0
func (c *ProjectsLocationsPrivateConnectionsCreateCall) Force(force bool) *ProjectsLocationsPrivateConnectionsCreateCall
Force sets the optional parameter "force": If set to true, will skip validations.
func (*ProjectsLocationsPrivateConnectionsCreateCall) Header ¶
func (c *ProjectsLocationsPrivateConnectionsCreateCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsPrivateConnectionsCreateCall) PrivateConnectionId ¶
func (c *ProjectsLocationsPrivateConnectionsCreateCall) PrivateConnectionId(privateConnectionId string) *ProjectsLocationsPrivateConnectionsCreateCall
PrivateConnectionId sets the optional parameter "privateConnectionId": Required. The private connectivity identifier.
func (*ProjectsLocationsPrivateConnectionsCreateCall) RequestId ¶
func (c *ProjectsLocationsPrivateConnectionsCreateCall) RequestId(requestId string) *ProjectsLocationsPrivateConnectionsCreateCall
RequestId sets the optional parameter "requestId": A request ID to identify requests. Specify a unique request ID so that if you must retry your request, the server will know to ignore the request if it has already been completed. The server will guarantee that for at least 60 minutes since the first request. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID, the server can check if original operation with the same request ID was received, and if so, will ignore the second request. This prevents clients from accidentally creating duplicate commitments. The request ID must be a valid UUID with the exception that zero UUID is not supported (00000000-0000-0000-0000-000000000000).
type ProjectsLocationsPrivateConnectionsDeleteCall ¶
type ProjectsLocationsPrivateConnectionsDeleteCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsPrivateConnectionsDeleteCall) Context ¶
func (c *ProjectsLocationsPrivateConnectionsDeleteCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsDeleteCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsPrivateConnectionsDeleteCall) Do ¶
func (c *ProjectsLocationsPrivateConnectionsDeleteCall) Do(opts ...googleapi.CallOption) (*Operation, error)
Do executes the "datastream.projects.locations.privateConnections.delete" call. Exactly one of *Operation or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Operation.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsPrivateConnectionsDeleteCall) Fields ¶
func (c *ProjectsLocationsPrivateConnectionsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsDeleteCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsPrivateConnectionsDeleteCall) Force ¶
func (c *ProjectsLocationsPrivateConnectionsDeleteCall) Force(force bool) *ProjectsLocationsPrivateConnectionsDeleteCall
Force sets the optional parameter "force": If set to true, any child routes that belong to this PrivateConnection will also be deleted.
func (*ProjectsLocationsPrivateConnectionsDeleteCall) Header ¶
func (c *ProjectsLocationsPrivateConnectionsDeleteCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsPrivateConnectionsDeleteCall) RequestId ¶
func (c *ProjectsLocationsPrivateConnectionsDeleteCall) RequestId(requestId string) *ProjectsLocationsPrivateConnectionsDeleteCall
RequestId sets the optional parameter "requestId": A request ID to identify requests. Specify a unique request ID so that if you must retry your request, the server will know to ignore the request if it has already been completed. The server will guarantee that for at least 60 minutes after the first request. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID, the server can check if original operation with the same request ID was received, and if so, will ignore the second request. This prevents clients from accidentally creating duplicate commitments. The request ID must be a valid UUID with the exception that zero UUID is not supported (00000000-0000-0000-0000-000000000000).
type ProjectsLocationsPrivateConnectionsGetCall ¶
type ProjectsLocationsPrivateConnectionsGetCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsPrivateConnectionsGetCall) Context ¶
func (c *ProjectsLocationsPrivateConnectionsGetCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsGetCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsPrivateConnectionsGetCall) Do ¶
func (c *ProjectsLocationsPrivateConnectionsGetCall) Do(opts ...googleapi.CallOption) (*PrivateConnection, error)
Do executes the "datastream.projects.locations.privateConnections.get" call. Exactly one of *PrivateConnection or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *PrivateConnection.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsPrivateConnectionsGetCall) Fields ¶
func (c *ProjectsLocationsPrivateConnectionsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsGetCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsPrivateConnectionsGetCall) Header ¶
func (c *ProjectsLocationsPrivateConnectionsGetCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsPrivateConnectionsGetCall) IfNoneMatch ¶
func (c *ProjectsLocationsPrivateConnectionsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsPrivateConnectionsGetCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
type ProjectsLocationsPrivateConnectionsListCall ¶
type ProjectsLocationsPrivateConnectionsListCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsPrivateConnectionsListCall) Context ¶
func (c *ProjectsLocationsPrivateConnectionsListCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsListCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsPrivateConnectionsListCall) Do ¶
func (c *ProjectsLocationsPrivateConnectionsListCall) Do(opts ...googleapi.CallOption) (*ListPrivateConnectionsResponse, error)
Do executes the "datastream.projects.locations.privateConnections.list" call. Exactly one of *ListPrivateConnectionsResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *ListPrivateConnectionsResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsPrivateConnectionsListCall) Fields ¶
func (c *ProjectsLocationsPrivateConnectionsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsListCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsPrivateConnectionsListCall) Filter ¶
func (c *ProjectsLocationsPrivateConnectionsListCall) Filter(filter string) *ProjectsLocationsPrivateConnectionsListCall
Filter sets the optional parameter "filter": Filter request.
func (*ProjectsLocationsPrivateConnectionsListCall) Header ¶
func (c *ProjectsLocationsPrivateConnectionsListCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsPrivateConnectionsListCall) IfNoneMatch ¶
func (c *ProjectsLocationsPrivateConnectionsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsPrivateConnectionsListCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
func (*ProjectsLocationsPrivateConnectionsListCall) OrderBy ¶
func (c *ProjectsLocationsPrivateConnectionsListCall) OrderBy(orderBy string) *ProjectsLocationsPrivateConnectionsListCall
OrderBy sets the optional parameter "orderBy": Order by fields for the result.
func (*ProjectsLocationsPrivateConnectionsListCall) PageSize ¶
func (c *ProjectsLocationsPrivateConnectionsListCall) PageSize(pageSize int64) *ProjectsLocationsPrivateConnectionsListCall
PageSize sets the optional parameter "pageSize": Maximum number of private connectivity configurations to return. If unspecified, at most 50 private connectivity configurations that will be returned. The maximum value is 1000; values above 1000 will be coerced to 1000.
func (*ProjectsLocationsPrivateConnectionsListCall) PageToken ¶
func (c *ProjectsLocationsPrivateConnectionsListCall) PageToken(pageToken string) *ProjectsLocationsPrivateConnectionsListCall
PageToken sets the optional parameter "pageToken": Page token received from a previous `ListPrivateConnections` call. Provide this to retrieve the subsequent page. When paginating, all other parameters provided to `ListPrivateConnections` must match the call that provided the page token.
func (*ProjectsLocationsPrivateConnectionsListCall) Pages ¶
func (c *ProjectsLocationsPrivateConnectionsListCall) Pages(ctx context.Context, f func(*ListPrivateConnectionsResponse) error) error
Pages invokes f for each page of results. A non-nil error returned from f will halt the iteration. The provided context supersedes any context provided to the Context method.
type ProjectsLocationsPrivateConnectionsRoutesCreateCall ¶
type ProjectsLocationsPrivateConnectionsRoutesCreateCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsPrivateConnectionsRoutesCreateCall) Context ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsRoutesCreateCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsPrivateConnectionsRoutesCreateCall) Do ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) Do(opts ...googleapi.CallOption) (*Operation, error)
Do executes the "datastream.projects.locations.privateConnections.routes.create" call. Exactly one of *Operation or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Operation.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsPrivateConnectionsRoutesCreateCall) Fields ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsRoutesCreateCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsPrivateConnectionsRoutesCreateCall) Header ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsPrivateConnectionsRoutesCreateCall) RequestId ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) RequestId(requestId string) *ProjectsLocationsPrivateConnectionsRoutesCreateCall
RequestId sets the optional parameter "requestId": A request ID to identify requests. Specify a unique request ID so that if you must retry your request, the server will know to ignore the request if it has already been completed. The server will guarantee that for at least 60 minutes since the first request. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID, the server can check if original operation with the same request ID was received, and if so, will ignore the second request. This prevents clients from accidentally creating duplicate commitments. The request ID must be a valid UUID with the exception that zero UUID is not supported (00000000-0000-0000-0000-000000000000).
func (*ProjectsLocationsPrivateConnectionsRoutesCreateCall) RouteId ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) RouteId(routeId string) *ProjectsLocationsPrivateConnectionsRoutesCreateCall
RouteId sets the optional parameter "routeId": Required. The Route identifier.
type ProjectsLocationsPrivateConnectionsRoutesDeleteCall ¶
type ProjectsLocationsPrivateConnectionsRoutesDeleteCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsPrivateConnectionsRoutesDeleteCall) Context ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesDeleteCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsRoutesDeleteCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsPrivateConnectionsRoutesDeleteCall) Do ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesDeleteCall) Do(opts ...googleapi.CallOption) (*Operation, error)
Do executes the "datastream.projects.locations.privateConnections.routes.delete" call. Exactly one of *Operation or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Operation.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsPrivateConnectionsRoutesDeleteCall) Fields ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsRoutesDeleteCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsPrivateConnectionsRoutesDeleteCall) Header ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesDeleteCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsPrivateConnectionsRoutesDeleteCall) RequestId ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesDeleteCall) RequestId(requestId string) *ProjectsLocationsPrivateConnectionsRoutesDeleteCall
RequestId sets the optional parameter "requestId": A request ID to identify requests. Specify a unique request ID so that if you must retry your request, the server will know to ignore the request if it has already been completed. The server will guarantee that for at least 60 minutes after the first request. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID, the server can check if original operation with the same request ID was received, and if so, will ignore the second request. This prevents clients from accidentally creating duplicate commitments. The request ID must be a valid UUID with the exception that zero UUID is not supported (00000000-0000-0000-0000-000000000000).
type ProjectsLocationsPrivateConnectionsRoutesGetCall ¶
type ProjectsLocationsPrivateConnectionsRoutesGetCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsPrivateConnectionsRoutesGetCall) Context ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesGetCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsRoutesGetCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsPrivateConnectionsRoutesGetCall) Do ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesGetCall) Do(opts ...googleapi.CallOption) (*Route, error)
Do executes the "datastream.projects.locations.privateConnections.routes.get" call. Exactly one of *Route or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Route.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsPrivateConnectionsRoutesGetCall) Fields ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsRoutesGetCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsPrivateConnectionsRoutesGetCall) Header ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesGetCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsPrivateConnectionsRoutesGetCall) IfNoneMatch ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsPrivateConnectionsRoutesGetCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
type ProjectsLocationsPrivateConnectionsRoutesListCall ¶
type ProjectsLocationsPrivateConnectionsRoutesListCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsPrivateConnectionsRoutesListCall) Context ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsRoutesListCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsPrivateConnectionsRoutesListCall) Do ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Do(opts ...googleapi.CallOption) (*ListRoutesResponse, error)
Do executes the "datastream.projects.locations.privateConnections.routes.list" call. Exactly one of *ListRoutesResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *ListRoutesResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsPrivateConnectionsRoutesListCall) Fields ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsRoutesListCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsPrivateConnectionsRoutesListCall) Filter ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Filter(filter string) *ProjectsLocationsPrivateConnectionsRoutesListCall
Filter sets the optional parameter "filter": Filter request.
func (*ProjectsLocationsPrivateConnectionsRoutesListCall) Header ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsPrivateConnectionsRoutesListCall) IfNoneMatch ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) IfNoneMatch(entityTag string) *ProjectsLocationsPrivateConnectionsRoutesListCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
func (*ProjectsLocationsPrivateConnectionsRoutesListCall) OrderBy ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) OrderBy(orderBy string) *ProjectsLocationsPrivateConnectionsRoutesListCall
OrderBy sets the optional parameter "orderBy": Order by fields for the result.
func (*ProjectsLocationsPrivateConnectionsRoutesListCall) PageSize ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) PageSize(pageSize int64) *ProjectsLocationsPrivateConnectionsRoutesListCall
PageSize sets the optional parameter "pageSize": Maximum number of Routes to return. The service may return fewer than this value. If unspecified, at most 50 Routes will be returned. The maximum value is 1000; values above 1000 will be coerced to 1000.
func (*ProjectsLocationsPrivateConnectionsRoutesListCall) PageToken ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) PageToken(pageToken string) *ProjectsLocationsPrivateConnectionsRoutesListCall
PageToken sets the optional parameter "pageToken": Page token received from a previous `ListRoutes` call. Provide this to retrieve the subsequent page. When paginating, all other parameters provided to `ListRoutes` must match the call that provided the page token.
func (*ProjectsLocationsPrivateConnectionsRoutesListCall) Pages ¶
func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Pages(ctx context.Context, f func(*ListRoutesResponse) error) error
Pages invokes f for each page of results. A non-nil error returned from f will halt the iteration. The provided context supersedes any context provided to the Context method.
type ProjectsLocationsPrivateConnectionsRoutesService ¶
type ProjectsLocationsPrivateConnectionsRoutesService struct {
// contains filtered or unexported fields
}
func NewProjectsLocationsPrivateConnectionsRoutesService ¶
func NewProjectsLocationsPrivateConnectionsRoutesService(s *Service) *ProjectsLocationsPrivateConnectionsRoutesService
func (*ProjectsLocationsPrivateConnectionsRoutesService) Create ¶
func (r *ProjectsLocationsPrivateConnectionsRoutesService) Create(parent string, route *Route) *ProjectsLocationsPrivateConnectionsRoutesCreateCall
Create: Use this method to create a route for a private connectivity configuration in a project and location.
- parent: The parent that owns the collection of Routes.
func (*ProjectsLocationsPrivateConnectionsRoutesService) Delete ¶
func (r *ProjectsLocationsPrivateConnectionsRoutesService) Delete(name string) *ProjectsLocationsPrivateConnectionsRoutesDeleteCall
Delete: Use this method to delete a route.
- name: The name of the Route resource to delete.
func (*ProjectsLocationsPrivateConnectionsRoutesService) Get ¶
func (r *ProjectsLocationsPrivateConnectionsRoutesService) Get(name string) *ProjectsLocationsPrivateConnectionsRoutesGetCall
Get: Use this method to get details about a route.
- name: The name of the Route resource to get.
func (*ProjectsLocationsPrivateConnectionsRoutesService) List ¶
func (r *ProjectsLocationsPrivateConnectionsRoutesService) List(parent string) *ProjectsLocationsPrivateConnectionsRoutesListCall
List: Use this method to list routes created for a private connectivity configuration in a project and location.
- parent: The parent that owns the collection of Routess.
type ProjectsLocationsPrivateConnectionsService ¶
type ProjectsLocationsPrivateConnectionsService struct { Routes *ProjectsLocationsPrivateConnectionsRoutesService // contains filtered or unexported fields }
func NewProjectsLocationsPrivateConnectionsService ¶
func NewProjectsLocationsPrivateConnectionsService(s *Service) *ProjectsLocationsPrivateConnectionsService
func (*ProjectsLocationsPrivateConnectionsService) Create ¶
func (r *ProjectsLocationsPrivateConnectionsService) Create(parent string, privateconnection *PrivateConnection) *ProjectsLocationsPrivateConnectionsCreateCall
Create: Use this method to create a private connectivity configuration.
- parent: The parent that owns the collection of PrivateConnections.
func (*ProjectsLocationsPrivateConnectionsService) Delete ¶
func (r *ProjectsLocationsPrivateConnectionsService) Delete(name string) *ProjectsLocationsPrivateConnectionsDeleteCall
Delete: Use this method to delete a private connectivity configuration.
- name: The name of the private connectivity configuration to delete.
func (*ProjectsLocationsPrivateConnectionsService) Get ¶
func (r *ProjectsLocationsPrivateConnectionsService) Get(name string) *ProjectsLocationsPrivateConnectionsGetCall
Get: Use this method to get details about a private connectivity configuration.
- name: The name of the private connectivity configuration to get.
func (*ProjectsLocationsPrivateConnectionsService) List ¶
func (r *ProjectsLocationsPrivateConnectionsService) List(parent string) *ProjectsLocationsPrivateConnectionsListCall
List: Use this method to list private connectivity configurations in a project and location.
- parent: The parent that owns the collection of private connectivity configurations.
type ProjectsLocationsService ¶
type ProjectsLocationsService struct { ConnectionProfiles *ProjectsLocationsConnectionProfilesService Operations *ProjectsLocationsOperationsService PrivateConnections *ProjectsLocationsPrivateConnectionsService Streams *ProjectsLocationsStreamsService // contains filtered or unexported fields }
func NewProjectsLocationsService ¶
func NewProjectsLocationsService(s *Service) *ProjectsLocationsService
func (*ProjectsLocationsService) FetchStaticIps ¶
func (r *ProjectsLocationsService) FetchStaticIps(name string) *ProjectsLocationsFetchStaticIpsCall
FetchStaticIps: The FetchStaticIps API call exposes the static IP addresses used by Datastream.
- name: The resource name for the location for which static IPs should be returned. Must be in the format `projects/*/locations/*`.
func (*ProjectsLocationsService) Get ¶
func (r *ProjectsLocationsService) Get(name string) *ProjectsLocationsGetCall
Get: Gets information about a location.
- name: Resource name for the location.
func (*ProjectsLocationsService) List ¶
func (r *ProjectsLocationsService) List(name string) *ProjectsLocationsListCall
List: Lists information about the supported locations for this service.
- name: The resource that owns the locations collection, if applicable.
type ProjectsLocationsStreamsCreateCall ¶
type ProjectsLocationsStreamsCreateCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsStreamsCreateCall) Context ¶
func (c *ProjectsLocationsStreamsCreateCall) Context(ctx context.Context) *ProjectsLocationsStreamsCreateCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsStreamsCreateCall) Do ¶
func (c *ProjectsLocationsStreamsCreateCall) Do(opts ...googleapi.CallOption) (*Operation, error)
Do executes the "datastream.projects.locations.streams.create" call. Exactly one of *Operation or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Operation.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsStreamsCreateCall) Fields ¶
func (c *ProjectsLocationsStreamsCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsCreateCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsStreamsCreateCall) Force ¶
func (c *ProjectsLocationsStreamsCreateCall) Force(force bool) *ProjectsLocationsStreamsCreateCall
Force sets the optional parameter "force": Create the stream without validating it.
func (*ProjectsLocationsStreamsCreateCall) Header ¶
func (c *ProjectsLocationsStreamsCreateCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsStreamsCreateCall) RequestId ¶
func (c *ProjectsLocationsStreamsCreateCall) RequestId(requestId string) *ProjectsLocationsStreamsCreateCall
RequestId sets the optional parameter "requestId": A request ID to identify requests. Specify a unique request ID so that if you must retry your request, the server will know to ignore the request if it has already been completed. The server will guarantee that for at least 60 minutes since the first request. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID, the server can check if original operation with the same request ID was received, and if so, will ignore the second request. This prevents clients from accidentally creating duplicate commitments. The request ID must be a valid UUID with the exception that zero UUID is not supported (00000000-0000-0000-0000-000000000000).
func (*ProjectsLocationsStreamsCreateCall) StreamId ¶
func (c *ProjectsLocationsStreamsCreateCall) StreamId(streamId string) *ProjectsLocationsStreamsCreateCall
StreamId sets the optional parameter "streamId": Required. The stream identifier.
func (*ProjectsLocationsStreamsCreateCall) ValidateOnly ¶
func (c *ProjectsLocationsStreamsCreateCall) ValidateOnly(validateOnly bool) *ProjectsLocationsStreamsCreateCall
ValidateOnly sets the optional parameter "validateOnly": Only validate the stream, but don't create any resources. The default is false.
type ProjectsLocationsStreamsDeleteCall ¶
type ProjectsLocationsStreamsDeleteCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsStreamsDeleteCall) Context ¶
func (c *ProjectsLocationsStreamsDeleteCall) Context(ctx context.Context) *ProjectsLocationsStreamsDeleteCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsStreamsDeleteCall) Do ¶
func (c *ProjectsLocationsStreamsDeleteCall) Do(opts ...googleapi.CallOption) (*Operation, error)
Do executes the "datastream.projects.locations.streams.delete" call. Exactly one of *Operation or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Operation.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsStreamsDeleteCall) Fields ¶
func (c *ProjectsLocationsStreamsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsDeleteCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsStreamsDeleteCall) Header ¶
func (c *ProjectsLocationsStreamsDeleteCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsStreamsDeleteCall) RequestId ¶
func (c *ProjectsLocationsStreamsDeleteCall) RequestId(requestId string) *ProjectsLocationsStreamsDeleteCall
RequestId sets the optional parameter "requestId": A request ID to identify requests. Specify a unique request ID so that if you must retry your request, the server will know to ignore the request if it has already been completed. The server will guarantee that for at least 60 minutes after the first request. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID, the server can check if original operation with the same request ID was received, and if so, will ignore the second request. This prevents clients from accidentally creating duplicate commitments. The request ID must be a valid UUID with the exception that zero UUID is not supported (00000000-0000-0000-0000-000000000000).
type ProjectsLocationsStreamsGetCall ¶
type ProjectsLocationsStreamsGetCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsStreamsGetCall) Context ¶
func (c *ProjectsLocationsStreamsGetCall) Context(ctx context.Context) *ProjectsLocationsStreamsGetCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsStreamsGetCall) Do ¶
func (c *ProjectsLocationsStreamsGetCall) Do(opts ...googleapi.CallOption) (*Stream, error)
Do executes the "datastream.projects.locations.streams.get" call. Exactly one of *Stream or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Stream.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsStreamsGetCall) Fields ¶
func (c *ProjectsLocationsStreamsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsGetCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsStreamsGetCall) Header ¶
func (c *ProjectsLocationsStreamsGetCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsStreamsGetCall) IfNoneMatch ¶
func (c *ProjectsLocationsStreamsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsStreamsGetCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
type ProjectsLocationsStreamsListCall ¶
type ProjectsLocationsStreamsListCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsStreamsListCall) Context ¶
func (c *ProjectsLocationsStreamsListCall) Context(ctx context.Context) *ProjectsLocationsStreamsListCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsStreamsListCall) Do ¶
func (c *ProjectsLocationsStreamsListCall) Do(opts ...googleapi.CallOption) (*ListStreamsResponse, error)
Do executes the "datastream.projects.locations.streams.list" call. Exactly one of *ListStreamsResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *ListStreamsResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsStreamsListCall) Fields ¶
func (c *ProjectsLocationsStreamsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsListCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsStreamsListCall) Filter ¶
func (c *ProjectsLocationsStreamsListCall) Filter(filter string) *ProjectsLocationsStreamsListCall
Filter sets the optional parameter "filter": Filter request.
func (*ProjectsLocationsStreamsListCall) Header ¶
func (c *ProjectsLocationsStreamsListCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsStreamsListCall) IfNoneMatch ¶
func (c *ProjectsLocationsStreamsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsStreamsListCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
func (*ProjectsLocationsStreamsListCall) OrderBy ¶
func (c *ProjectsLocationsStreamsListCall) OrderBy(orderBy string) *ProjectsLocationsStreamsListCall
OrderBy sets the optional parameter "orderBy": Order by fields for the result.
func (*ProjectsLocationsStreamsListCall) PageSize ¶
func (c *ProjectsLocationsStreamsListCall) PageSize(pageSize int64) *ProjectsLocationsStreamsListCall
PageSize sets the optional parameter "pageSize": Maximum number of streams to return. If unspecified, at most 50 streams will be returned. The maximum value is 1000; values above 1000 will be coerced to 1000.
func (*ProjectsLocationsStreamsListCall) PageToken ¶
func (c *ProjectsLocationsStreamsListCall) PageToken(pageToken string) *ProjectsLocationsStreamsListCall
PageToken sets the optional parameter "pageToken": Page token received from a previous `ListStreams` call. Provide this to retrieve the subsequent page. When paginating, all other parameters provided to `ListStreams` must match the call that provided the page token.
func (*ProjectsLocationsStreamsListCall) Pages ¶
func (c *ProjectsLocationsStreamsListCall) Pages(ctx context.Context, f func(*ListStreamsResponse) error) error
Pages invokes f for each page of results. A non-nil error returned from f will halt the iteration. The provided context supersedes any context provided to the Context method.
type ProjectsLocationsStreamsObjectsGetCall ¶
type ProjectsLocationsStreamsObjectsGetCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsStreamsObjectsGetCall) Context ¶
func (c *ProjectsLocationsStreamsObjectsGetCall) Context(ctx context.Context) *ProjectsLocationsStreamsObjectsGetCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsStreamsObjectsGetCall) Do ¶
func (c *ProjectsLocationsStreamsObjectsGetCall) Do(opts ...googleapi.CallOption) (*StreamObject, error)
Do executes the "datastream.projects.locations.streams.objects.get" call. Exactly one of *StreamObject or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *StreamObject.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsStreamsObjectsGetCall) Fields ¶
func (c *ProjectsLocationsStreamsObjectsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsObjectsGetCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsStreamsObjectsGetCall) Header ¶
func (c *ProjectsLocationsStreamsObjectsGetCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsStreamsObjectsGetCall) IfNoneMatch ¶
func (c *ProjectsLocationsStreamsObjectsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsStreamsObjectsGetCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
type ProjectsLocationsStreamsObjectsListCall ¶
type ProjectsLocationsStreamsObjectsListCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsStreamsObjectsListCall) Context ¶
func (c *ProjectsLocationsStreamsObjectsListCall) Context(ctx context.Context) *ProjectsLocationsStreamsObjectsListCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsStreamsObjectsListCall) Do ¶
func (c *ProjectsLocationsStreamsObjectsListCall) Do(opts ...googleapi.CallOption) (*ListStreamObjectsResponse, error)
Do executes the "datastream.projects.locations.streams.objects.list" call. Exactly one of *ListStreamObjectsResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *ListStreamObjectsResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsStreamsObjectsListCall) Fields ¶
func (c *ProjectsLocationsStreamsObjectsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsObjectsListCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsStreamsObjectsListCall) Header ¶
func (c *ProjectsLocationsStreamsObjectsListCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsStreamsObjectsListCall) IfNoneMatch ¶
func (c *ProjectsLocationsStreamsObjectsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsStreamsObjectsListCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
func (*ProjectsLocationsStreamsObjectsListCall) PageSize ¶
func (c *ProjectsLocationsStreamsObjectsListCall) PageSize(pageSize int64) *ProjectsLocationsStreamsObjectsListCall
PageSize sets the optional parameter "pageSize": Maximum number of objects to return. Default is 50. The maximum value is 1000; values above 1000 will be coerced to 1000.
func (*ProjectsLocationsStreamsObjectsListCall) PageToken ¶
func (c *ProjectsLocationsStreamsObjectsListCall) PageToken(pageToken string) *ProjectsLocationsStreamsObjectsListCall
PageToken sets the optional parameter "pageToken": Page token received from a previous `ListStreamObjectsRequest` call. Provide this to retrieve the subsequent page. When paginating, all other parameters provided to `ListStreamObjectsRequest` must match the call that provided the page token.
func (*ProjectsLocationsStreamsObjectsListCall) Pages ¶
func (c *ProjectsLocationsStreamsObjectsListCall) Pages(ctx context.Context, f func(*ListStreamObjectsResponse) error) error
Pages invokes f for each page of results. A non-nil error returned from f will halt the iteration. The provided context supersedes any context provided to the Context method.
type ProjectsLocationsStreamsObjectsLookupCall ¶
type ProjectsLocationsStreamsObjectsLookupCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsStreamsObjectsLookupCall) Context ¶
func (c *ProjectsLocationsStreamsObjectsLookupCall) Context(ctx context.Context) *ProjectsLocationsStreamsObjectsLookupCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsStreamsObjectsLookupCall) Do ¶
func (c *ProjectsLocationsStreamsObjectsLookupCall) Do(opts ...googleapi.CallOption) (*StreamObject, error)
Do executes the "datastream.projects.locations.streams.objects.lookup" call. Exactly one of *StreamObject or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *StreamObject.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsStreamsObjectsLookupCall) Fields ¶
func (c *ProjectsLocationsStreamsObjectsLookupCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsObjectsLookupCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsStreamsObjectsLookupCall) Header ¶
func (c *ProjectsLocationsStreamsObjectsLookupCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
type ProjectsLocationsStreamsObjectsService ¶
type ProjectsLocationsStreamsObjectsService struct {
// contains filtered or unexported fields
}
func NewProjectsLocationsStreamsObjectsService ¶
func NewProjectsLocationsStreamsObjectsService(s *Service) *ProjectsLocationsStreamsObjectsService
func (*ProjectsLocationsStreamsObjectsService) Get ¶
func (r *ProjectsLocationsStreamsObjectsService) Get(name string) *ProjectsLocationsStreamsObjectsGetCall
Get: Use this method to get details about a stream object.
- name: The name of the stream object resource to get.
func (*ProjectsLocationsStreamsObjectsService) List ¶
func (r *ProjectsLocationsStreamsObjectsService) List(parent string) *ProjectsLocationsStreamsObjectsListCall
List: Use this method to list the objects of a specific stream.
- parent: The parent stream that owns the collection of objects.
func (*ProjectsLocationsStreamsObjectsService) Lookup ¶
func (r *ProjectsLocationsStreamsObjectsService) Lookup(parent string, lookupstreamobjectrequest *LookupStreamObjectRequest) *ProjectsLocationsStreamsObjectsLookupCall
Lookup: Use this method to look up a stream object by its source object identifier.
- parent: The parent stream that owns the collection of objects.
func (*ProjectsLocationsStreamsObjectsService) StartBackfillJob ¶
func (r *ProjectsLocationsStreamsObjectsService) StartBackfillJob(object string, startbackfilljobrequest *StartBackfillJobRequest) *ProjectsLocationsStreamsObjectsStartBackfillJobCall
StartBackfillJob: Use this method to start a backfill job for the specified stream object.
- object: The name of the stream object resource to start a backfill job for.
func (*ProjectsLocationsStreamsObjectsService) StopBackfillJob ¶
func (r *ProjectsLocationsStreamsObjectsService) StopBackfillJob(object string, stopbackfilljobrequest *StopBackfillJobRequest) *ProjectsLocationsStreamsObjectsStopBackfillJobCall
StopBackfillJob: Use this method to stop a backfill job for the specified stream object.
- object: The name of the stream object resource to stop the backfill job for.
type ProjectsLocationsStreamsObjectsStartBackfillJobCall ¶
type ProjectsLocationsStreamsObjectsStartBackfillJobCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsStreamsObjectsStartBackfillJobCall) Context ¶
func (c *ProjectsLocationsStreamsObjectsStartBackfillJobCall) Context(ctx context.Context) *ProjectsLocationsStreamsObjectsStartBackfillJobCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsStreamsObjectsStartBackfillJobCall) Do ¶
func (c *ProjectsLocationsStreamsObjectsStartBackfillJobCall) Do(opts ...googleapi.CallOption) (*StartBackfillJobResponse, error)
Do executes the "datastream.projects.locations.streams.objects.startBackfillJob" call. Exactly one of *StartBackfillJobResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *StartBackfillJobResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsStreamsObjectsStartBackfillJobCall) Fields ¶
func (c *ProjectsLocationsStreamsObjectsStartBackfillJobCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsObjectsStartBackfillJobCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsStreamsObjectsStartBackfillJobCall) Header ¶
func (c *ProjectsLocationsStreamsObjectsStartBackfillJobCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
type ProjectsLocationsStreamsObjectsStopBackfillJobCall ¶
type ProjectsLocationsStreamsObjectsStopBackfillJobCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsStreamsObjectsStopBackfillJobCall) Context ¶
func (c *ProjectsLocationsStreamsObjectsStopBackfillJobCall) Context(ctx context.Context) *ProjectsLocationsStreamsObjectsStopBackfillJobCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsStreamsObjectsStopBackfillJobCall) Do ¶
func (c *ProjectsLocationsStreamsObjectsStopBackfillJobCall) Do(opts ...googleapi.CallOption) (*StopBackfillJobResponse, error)
Do executes the "datastream.projects.locations.streams.objects.stopBackfillJob" call. Exactly one of *StopBackfillJobResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *StopBackfillJobResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsStreamsObjectsStopBackfillJobCall) Fields ¶
func (c *ProjectsLocationsStreamsObjectsStopBackfillJobCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsObjectsStopBackfillJobCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsStreamsObjectsStopBackfillJobCall) Header ¶
func (c *ProjectsLocationsStreamsObjectsStopBackfillJobCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
type ProjectsLocationsStreamsPatchCall ¶
type ProjectsLocationsStreamsPatchCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsStreamsPatchCall) Context ¶
func (c *ProjectsLocationsStreamsPatchCall) Context(ctx context.Context) *ProjectsLocationsStreamsPatchCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsStreamsPatchCall) Do ¶
func (c *ProjectsLocationsStreamsPatchCall) Do(opts ...googleapi.CallOption) (*Operation, error)
Do executes the "datastream.projects.locations.streams.patch" call. Exactly one of *Operation or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Operation.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsStreamsPatchCall) Fields ¶
func (c *ProjectsLocationsStreamsPatchCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsPatchCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsStreamsPatchCall) Force ¶
func (c *ProjectsLocationsStreamsPatchCall) Force(force bool) *ProjectsLocationsStreamsPatchCall
Force sets the optional parameter "force": Update the stream without validating it.
func (*ProjectsLocationsStreamsPatchCall) Header ¶
func (c *ProjectsLocationsStreamsPatchCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsStreamsPatchCall) RequestId ¶
func (c *ProjectsLocationsStreamsPatchCall) RequestId(requestId string) *ProjectsLocationsStreamsPatchCall
RequestId sets the optional parameter "requestId": A request ID to identify requests. Specify a unique request ID so that if you must retry your request, the server will know to ignore the request if it has already been completed. The server will guarantee that for at least 60 minutes since the first request. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID, the server can check if original operation with the same request ID was received, and if so, will ignore the second request. This prevents clients from accidentally creating duplicate commitments. The request ID must be a valid UUID with the exception that zero UUID is not supported (00000000-0000-0000-0000-000000000000).
func (*ProjectsLocationsStreamsPatchCall) UpdateMask ¶
func (c *ProjectsLocationsStreamsPatchCall) UpdateMask(updateMask string) *ProjectsLocationsStreamsPatchCall
UpdateMask sets the optional parameter "updateMask": Field mask is used to specify the fields to be overwritten in the stream resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask then all fields will be overwritten.
func (*ProjectsLocationsStreamsPatchCall) ValidateOnly ¶
func (c *ProjectsLocationsStreamsPatchCall) ValidateOnly(validateOnly bool) *ProjectsLocationsStreamsPatchCall
ValidateOnly sets the optional parameter "validateOnly": Only validate the stream with the changes, without actually updating it. The default is false.
type ProjectsLocationsStreamsRunCall ¶ added in v0.135.0
type ProjectsLocationsStreamsRunCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsStreamsRunCall) Context ¶ added in v0.135.0
func (c *ProjectsLocationsStreamsRunCall) Context(ctx context.Context) *ProjectsLocationsStreamsRunCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsStreamsRunCall) Do ¶ added in v0.135.0
func (c *ProjectsLocationsStreamsRunCall) Do(opts ...googleapi.CallOption) (*Operation, error)
Do executes the "datastream.projects.locations.streams.run" call. Exactly one of *Operation or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Operation.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsStreamsRunCall) Fields ¶ added in v0.135.0
func (c *ProjectsLocationsStreamsRunCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsRunCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsStreamsRunCall) Header ¶ added in v0.135.0
func (c *ProjectsLocationsStreamsRunCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
type ProjectsLocationsStreamsService ¶
type ProjectsLocationsStreamsService struct { Objects *ProjectsLocationsStreamsObjectsService // contains filtered or unexported fields }
func NewProjectsLocationsStreamsService ¶
func NewProjectsLocationsStreamsService(s *Service) *ProjectsLocationsStreamsService
func (*ProjectsLocationsStreamsService) Create ¶
func (r *ProjectsLocationsStreamsService) Create(parent string, stream *Stream) *ProjectsLocationsStreamsCreateCall
Create: Use this method to create a stream.
- parent: The parent that owns the collection of streams.
func (*ProjectsLocationsStreamsService) Delete ¶
func (r *ProjectsLocationsStreamsService) Delete(name string) *ProjectsLocationsStreamsDeleteCall
Delete: Use this method to delete a stream.
- name: The name of the stream resource to delete.
func (*ProjectsLocationsStreamsService) Get ¶
func (r *ProjectsLocationsStreamsService) Get(name string) *ProjectsLocationsStreamsGetCall
Get: Use this method to get details about a stream.
- name: The name of the stream resource to get.
func (*ProjectsLocationsStreamsService) List ¶
func (r *ProjectsLocationsStreamsService) List(parent string) *ProjectsLocationsStreamsListCall
List: Use this method to list streams in a project and location.
- parent: The parent that owns the collection of streams.
func (*ProjectsLocationsStreamsService) Patch ¶
func (r *ProjectsLocationsStreamsService) Patch(name string, stream *Stream) *ProjectsLocationsStreamsPatchCall
Patch: Use this method to update the configuration of a stream.
- name: Output only. The stream's name.
func (*ProjectsLocationsStreamsService) Run ¶ added in v0.135.0
func (r *ProjectsLocationsStreamsService) Run(name string, runstreamrequest *RunStreamRequest) *ProjectsLocationsStreamsRunCall
Run: Use this method to start, resume or recover a stream with a non default CDC strategy. NOTE: This feature is currently experimental.
- name: Name of the stream resource to start, in the format: projects/{project_id}/locations/{location}/streams/{stream_name}.
type ProjectsService ¶
type ProjectsService struct { Locations *ProjectsLocationsService // contains filtered or unexported fields }
func NewProjectsService ¶
func NewProjectsService(s *Service) *ProjectsService
type Route ¶
type Route struct { // CreateTime: Output only. The create time of the resource. CreateTime string `json:"createTime,omitempty"` // DestinationAddress: Required. Destination address for connection DestinationAddress string `json:"destinationAddress,omitempty"` // DestinationPort: Destination port for connection DestinationPort int64 `json:"destinationPort,omitempty"` // DisplayName: Required. Display name. DisplayName string `json:"displayName,omitempty"` // Labels: Labels. Labels map[string]string `json:"labels,omitempty"` // Name: Output only. The resource's name. Name string `json:"name,omitempty"` // UpdateTime: Output only. The update time of the resource. UpdateTime string `json:"updateTime,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "CreateTime") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "CreateTime") to include in // API requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
Route: The route resource is the child of the private connection resource, used for defining a route for a private connection.
func (*Route) MarshalJSON ¶
type RunStreamRequest ¶ added in v0.135.0
type RunStreamRequest struct { // CdcStrategy: Optional. The CDC strategy of the stream. If not set, // the system's default value will be used. CdcStrategy *CdcStrategy `json:"cdcStrategy,omitempty"` // ForceSendFields is a list of field names (e.g. "CdcStrategy") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "CdcStrategy") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
RunStreamRequest: Request message for running a stream.
func (*RunStreamRequest) MarshalJSON ¶ added in v0.135.0
func (s *RunStreamRequest) MarshalJSON() ([]byte, error)
type Service ¶
type Service struct { BasePath string // API endpoint base URL UserAgent string // optional additional User-Agent fragment Projects *ProjectsService // contains filtered or unexported fields }
func New
deprecated
New creates a new Service. It uses the provided http.Client for requests.
Deprecated: please use NewService instead. To provide a custom HTTP client, use option.WithHTTPClient. If you are using google.golang.org/api/googleapis/transport.APIKey, use option.WithAPIKey with NewService instead.
func NewService ¶
NewService creates a new Service.
type SingleTargetDataset ¶ added in v0.96.0
type SingleTargetDataset struct { // DatasetId: The dataset ID of the target dataset. DatasetIds allowed // characters: // https://cloud.google.com/bigquery/docs/reference/rest/v2/datasets#datasetreference. DatasetId string `json:"datasetId,omitempty"` // ForceSendFields is a list of field names (e.g. "DatasetId") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "DatasetId") to include in // API requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
SingleTargetDataset: A single target dataset to which all data will be streamed.
func (*SingleTargetDataset) MarshalJSON ¶ added in v0.96.0
func (s *SingleTargetDataset) MarshalJSON() ([]byte, error)
type SourceConfig ¶
type SourceConfig struct { // MysqlSourceConfig: MySQL data source configuration. MysqlSourceConfig *MysqlSourceConfig `json:"mysqlSourceConfig,omitempty"` // OracleSourceConfig: Oracle data source configuration. OracleSourceConfig *OracleSourceConfig `json:"oracleSourceConfig,omitempty"` // PostgresqlSourceConfig: PostgreSQL data source configuration. PostgresqlSourceConfig *PostgresqlSourceConfig `json:"postgresqlSourceConfig,omitempty"` // SourceConnectionProfile: Required. Source connection profile // resoource. Format: // `projects/{project}/locations/{location}/connectionProfiles/{name}` SourceConnectionProfile string `json:"sourceConnectionProfile,omitempty"` // ForceSendFields is a list of field names (e.g. "MysqlSourceConfig") // to unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "MysqlSourceConfig") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
SourceConfig: The configuration of the stream source.
func (*SourceConfig) MarshalJSON ¶
func (s *SourceConfig) MarshalJSON() ([]byte, error)
type SourceHierarchyDatasets ¶ added in v0.96.0
type SourceHierarchyDatasets struct { // DatasetTemplate: The dataset template to use for dynamic dataset // creation. DatasetTemplate *DatasetTemplate `json:"datasetTemplate,omitempty"` // ForceSendFields is a list of field names (e.g. "DatasetTemplate") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "DatasetTemplate") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
SourceHierarchyDatasets: Destination datasets are created so that hierarchy of the destination data objects matches the source hierarchy.
func (*SourceHierarchyDatasets) MarshalJSON ¶ added in v0.96.0
func (s *SourceHierarchyDatasets) MarshalJSON() ([]byte, error)
type SourceObjectIdentifier ¶
type SourceObjectIdentifier struct { // MysqlIdentifier: Mysql data source object identifier. MysqlIdentifier *MysqlObjectIdentifier `json:"mysqlIdentifier,omitempty"` // OracleIdentifier: Oracle data source object identifier. OracleIdentifier *OracleObjectIdentifier `json:"oracleIdentifier,omitempty"` // PostgresqlIdentifier: PostgreSQL data source object identifier. PostgresqlIdentifier *PostgresqlObjectIdentifier `json:"postgresqlIdentifier,omitempty"` // ForceSendFields is a list of field names (e.g. "MysqlIdentifier") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "MysqlIdentifier") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
SourceObjectIdentifier: Represents an identifier of an object in the data source.
func (*SourceObjectIdentifier) MarshalJSON ¶
func (s *SourceObjectIdentifier) MarshalJSON() ([]byte, error)
type SpecificStartPosition ¶ added in v0.135.0
type SpecificStartPosition struct { // MysqlLogPosition: MySQL specific log position to start replicating // from. MysqlLogPosition *MysqlLogPosition `json:"mysqlLogPosition,omitempty"` // ForceSendFields is a list of field names (e.g. "MysqlLogPosition") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "MysqlLogPosition") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
SpecificStartPosition: CDC strategy to start replicating from a specific position in the source.
func (*SpecificStartPosition) MarshalJSON ¶ added in v0.135.0
func (s *SpecificStartPosition) MarshalJSON() ([]byte, error)
type StartBackfillJobRequest ¶
type StartBackfillJobRequest struct { }
StartBackfillJobRequest: Request for manually initiating a backfill job for a specific stream object.
type StartBackfillJobResponse ¶
type StartBackfillJobResponse struct { // Object: The stream object resource a backfill job was started for. Object *StreamObject `json:"object,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "Object") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Object") to include in API // requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
StartBackfillJobResponse: Response for manually initiating a backfill job for a specific stream object.
func (*StartBackfillJobResponse) MarshalJSON ¶
func (s *StartBackfillJobResponse) MarshalJSON() ([]byte, error)
type StaticServiceIpConnectivity ¶
type StaticServiceIpConnectivity struct { }
StaticServiceIpConnectivity: Static IP address connectivity. Used when the source database is configured to allow incoming connections from the Datastream public IP addresses for the region specified in the connection profile.
type Status ¶
type Status struct { // Code: The status code, which should be an enum value of // google.rpc.Code. Code int64 `json:"code,omitempty"` // Details: A list of messages that carry the error details. There is a // common set of message types for APIs to use. Details []googleapi.RawMessage `json:"details,omitempty"` // Message: A developer-facing error message, which should be in // English. Any user-facing error message should be localized and sent // in the google.rpc.Status.details field, or localized by the client. Message string `json:"message,omitempty"` // ForceSendFields is a list of field names (e.g. "Code") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Code") to include in API // requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
Status: The `Status` type defines a logical error model that is suitable for different programming environments, including REST APIs and RPC APIs. It is used by gRPC (https://github.com/grpc). Each `Status` message contains three pieces of data: error code, error message, and error details. You can find out more about this error model and how to work with it in the API Design Guide (https://cloud.google.com/apis/design/errors).
func (*Status) MarshalJSON ¶
type StopBackfillJobRequest ¶
type StopBackfillJobRequest struct { }
StopBackfillJobRequest: Request for manually stopping a running backfill job for a specific stream object.
type StopBackfillJobResponse ¶
type StopBackfillJobResponse struct { // Object: The stream object resource the backfill job was stopped for. Object *StreamObject `json:"object,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "Object") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Object") to include in API // requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
StopBackfillJobResponse: Response for manually stop a backfill job for a specific stream object.
func (*StopBackfillJobResponse) MarshalJSON ¶
func (s *StopBackfillJobResponse) MarshalJSON() ([]byte, error)
type Stream ¶
type Stream struct { // BackfillAll: Automatically backfill objects included in the stream // source configuration. Specific objects can be excluded. BackfillAll *BackfillAllStrategy `json:"backfillAll,omitempty"` // BackfillNone: Do not automatically backfill any objects. BackfillNone *BackfillNoneStrategy `json:"backfillNone,omitempty"` // CreateTime: Output only. The creation time of the stream. CreateTime string `json:"createTime,omitempty"` // CustomerManagedEncryptionKey: Immutable. A reference to a KMS // encryption key. If provided, it will be used to encrypt the data. If // left blank, data will be encrypted using an internal Stream-specific // encryption key provisioned through KMS. CustomerManagedEncryptionKey string `json:"customerManagedEncryptionKey,omitempty"` // DestinationConfig: Required. Destination connection profile // configuration. DestinationConfig *DestinationConfig `json:"destinationConfig,omitempty"` // DisplayName: Required. Display name. DisplayName string `json:"displayName,omitempty"` // Errors: Output only. Errors on the Stream. Errors []*Error `json:"errors,omitempty"` // Labels: Labels. Labels map[string]string `json:"labels,omitempty"` // LastRecoveryTime: Output only. If the stream was recovered, the time // of the last recovery. Note: This field is currently experimental. LastRecoveryTime string `json:"lastRecoveryTime,omitempty"` // Name: Output only. The stream's name. Name string `json:"name,omitempty"` // SourceConfig: Required. Source connection profile configuration. SourceConfig *SourceConfig `json:"sourceConfig,omitempty"` // State: The state of the stream. // // Possible values: // "STATE_UNSPECIFIED" - Unspecified stream state. // "NOT_STARTED" - The stream has been created but has not yet started // streaming data. // "RUNNING" - The stream is running. // "PAUSED" - The stream is paused. // "MAINTENANCE" - The stream is in maintenance mode. Updates are // rejected on the resource in this state. // "FAILED" - The stream is experiencing an error that is preventing // data from being streamed. // "FAILED_PERMANENTLY" - The stream has experienced a terminal // failure. // "STARTING" - The stream is starting, but not yet running. // "DRAINING" - The Stream is no longer reading new events, but still // writing events in the buffer. State string `json:"state,omitempty"` // UpdateTime: Output only. The last update time of the stream. UpdateTime string `json:"updateTime,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "BackfillAll") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "BackfillAll") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
Stream: A resource representing streaming data from a source to a destination.
func (*Stream) MarshalJSON ¶
type StreamLargeObjects ¶ added in v0.89.0
type StreamLargeObjects struct { }
StreamLargeObjects: Configuration to stream large object values.
type StreamObject ¶
type StreamObject struct { // BackfillJob: The latest backfill job that was initiated for the // stream object. BackfillJob *BackfillJob `json:"backfillJob,omitempty"` // CreateTime: Output only. The creation time of the object. CreateTime string `json:"createTime,omitempty"` // DisplayName: Required. Display name. DisplayName string `json:"displayName,omitempty"` // Errors: Output only. Active errors on the object. Errors []*Error `json:"errors,omitempty"` // Name: Output only. The object resource's name. Name string `json:"name,omitempty"` // SourceObject: The object identifier in the data source. SourceObject *SourceObjectIdentifier `json:"sourceObject,omitempty"` // UpdateTime: Output only. The last update time of the object. UpdateTime string `json:"updateTime,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "BackfillJob") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "BackfillJob") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
StreamObject: A specific stream object (e.g a specific DB table).
func (*StreamObject) MarshalJSON ¶
func (s *StreamObject) MarshalJSON() ([]byte, error)
type Validation ¶
type Validation struct { // Code: A custom code identifying this validation. Code string `json:"code,omitempty"` // Description: A short description of the validation. Description string `json:"description,omitempty"` // Message: Messages reflecting the validation results. Message []*ValidationMessage `json:"message,omitempty"` // State: Output only. Validation execution status. // // Possible values: // "STATE_UNSPECIFIED" - Unspecified state. // "NOT_EXECUTED" - Validation did not execute. // "FAILED" - Validation failed. // "PASSED" - Validation passed. State string `json:"state,omitempty"` // ForceSendFields is a list of field names (e.g. "Code") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Code") to include in API // requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
Validation: A validation to perform on a stream.
func (*Validation) MarshalJSON ¶
func (s *Validation) MarshalJSON() ([]byte, error)
type ValidationMessage ¶
type ValidationMessage struct { // Code: A custom code identifying this specific message. Code string `json:"code,omitempty"` // Level: Message severity level (warning or error). // // Possible values: // "LEVEL_UNSPECIFIED" - Unspecified level. // "WARNING" - Potentially cause issues with the Stream. // "ERROR" - Definitely cause issues with the Stream. Level string `json:"level,omitempty"` // Message: The result of the validation. Message string `json:"message,omitempty"` // Metadata: Additional metadata related to the result. Metadata map[string]string `json:"metadata,omitempty"` // ForceSendFields is a list of field names (e.g. "Code") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Code") to include in API // requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
ValidationMessage: Represent user-facing validation result message.
func (*ValidationMessage) MarshalJSON ¶
func (s *ValidationMessage) MarshalJSON() ([]byte, error)
type ValidationResult ¶
type ValidationResult struct { // Validations: A list of validations (includes both executed as well as // not executed validations). Validations []*Validation `json:"validations,omitempty"` // ForceSendFields is a list of field names (e.g. "Validations") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Validations") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
ValidationResult: Contains the current validation results.
func (*ValidationResult) MarshalJSON ¶
func (s *ValidationResult) MarshalJSON() ([]byte, error)
type VpcPeeringConfig ¶
type VpcPeeringConfig struct { // Subnet: Required. A free subnet for peering. (CIDR of /29) Subnet string `json:"subnet,omitempty"` // Vpc: Required. Fully qualified name of the VPC that Datastream will // peer to. Format: `projects/{project}/global/{networks}/{name}` Vpc string `json:"vpc,omitempty"` // ForceSendFields is a list of field names (e.g. "Subnet") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Subnet") to include in API // requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
VpcPeeringConfig: The VPC Peering configuration is used to create VPC peering between Datastream and the consumer's VPC.
func (*VpcPeeringConfig) MarshalJSON ¶
func (s *VpcPeeringConfig) MarshalJSON() ([]byte, error)