Package datastream

import "google.golang.org/api/datastream/v1alpha1"
...
ctx := context.Background()
datastreamService, err := datastream.NewService(ctx)

datastreamService, err := datastream.NewService(ctx, option.WithAPIKey("AIza..."))

config := &oauth2.Config{...}
// ...
token, err := config.Exchange(ctx, ...)
datastreamService, err := datastream.NewService(ctx, option.WithTokenSource(config.TokenSource(ctx, token)))

Constants

OAuth2 scopes used by this API.

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"
)

type AvroFileFormat ¶

AvroFileFormat: AVRO file format configuration.

type AvroFileFormat struct {
}

type BackfillAllStrategy ¶

BackfillAllStrategy: Backfill strategy to automatically backfill the Stream's objects. Specific objects can be excluded.

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"`
    // 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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*BackfillAllStrategy) MarshalJSON ¶

func (s *BackfillAllStrategy) MarshalJSON() ([]byte, error)

type BackfillJob ¶

BackfillJob: Represents a backfill job on a specific stream object.

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: 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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*BackfillJob) MarshalJSON ¶

func (s *BackfillJob) MarshalJSON() ([]byte, error)

type BackfillNoneStrategy ¶

BackfillNoneStrategy: Backfill strategy to disable automatic backfill for the Stream's objects.

type BackfillNoneStrategy struct {
}

type CancelOperationRequest ¶

CancelOperationRequest: The request message for Operations.CancelOperation.

type CancelOperationRequest struct {
}

type ConnectionProfile ¶

type ConnectionProfile struct {
    // 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"`
    // NoConnectivity: No connectivity option chosen.
    NoConnectivity *NoConnectivitySettings `json:"noConnectivity,omitempty"`
    // OracleProfile: Oracle ConnectionProfile configuration.
    OracleProfile *OracleProfile `json:"oracleProfile,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. "CreateTime") to
    // unconditionally include in API requests. By default, fields with empty or
    // default values are omitted from API requests. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*ConnectionProfile) MarshalJSON ¶

func (s *ConnectionProfile) MarshalJSON() ([]byte, error)

type DestinationConfig ¶

DestinationConfig: The configuration of the stream destination.

type DestinationConfig struct {
    // DestinationConnectionProfileName: Required. Destination connection profile
    // identifier.
    DestinationConnectionProfileName string `json:"destinationConnectionProfileName,omitempty"`
    // GcsDestinationConfig: GCS destination configuration.
    GcsDestinationConfig *GcsDestinationConfig `json:"gcsDestinationConfig,omitempty"`
    // ForceSendFields is a list of field names (e.g.
    // "DestinationConnectionProfileName") to unconditionally include in API
    // requests. By default, fields with empty or default values are omitted from
    // API requests. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    ForceSendFields []string `json:"-"`
    // NullFields is a list of field names (e.g.
    // "DestinationConnectionProfileName") to include in API requests with the JSON
    // null value. By default, fields with empty values are omitted from API
    // requests. See https://pkg.go.dev/google.golang.org/api#hdr-NullFields for
    // more details.
    NullFields []string `json:"-"`
}

func (*DestinationConfig) MarshalJSON ¶

func (s *DestinationConfig) MarshalJSON() ([]byte, error)

type DiscoverConnectionProfileRequest ¶

DiscoverConnectionProfileRequest: Request message for 'discover' ConnectionProfile request.

type DiscoverConnectionProfileRequest struct {
    // ConnectionProfile: An ad-hoc ConnectionProfile configuration.
    ConnectionProfile *ConnectionProfile `json:"connectionProfile,omitempty"`
    // ConnectionProfileName: A reference to an existing ConnectionProfile.
    ConnectionProfileName string `json:"connectionProfileName,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"`
    // RecursionDepth: The number of hierarchy levels below the current level to be
    // retrieved.
    RecursionDepth int64 `json:"recursionDepth,omitempty"`
    // Recursive: Whether to retrieve the full hierarchy of data objects (TRUE) or
    // only the current level (FALSE).
    Recursive bool `json:"recursive,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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

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"`

    // 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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*DiscoverConnectionProfileResponse) MarshalJSON ¶

func (s *DiscoverConnectionProfileResponse) MarshalJSON() ([]byte, error)

type DropLargeObjects ¶

DropLargeObjects: Configuration to drop large object values.

type DropLargeObjects struct {
}

type Empty ¶

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 Empty struct {
    // ServerResponse contains the HTTP response code and headers from the server.
    googleapi.ServerResponse `json:"-"`
}

type Error ¶

Error: Represent a user-facing 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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*Error) MarshalJSON ¶

func (s *Error) MarshalJSON() ([]byte, error)

type FetchErrorsRequest ¶

FetchErrorsRequest: Request message for 'FetchErrors' request.

type FetchErrorsRequest struct {
}

type FetchErrorsResponse ¶

FetchErrorsResponse: Response message for a 'FetchErrors' response.

type FetchErrorsResponse struct {
    // Errors: The list of errors on the Stream.
    Errors []*Error `json:"errors,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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*FetchErrorsResponse) MarshalJSON ¶

func (s *FetchErrorsResponse) MarshalJSON() ([]byte, error)

type FetchStaticIpsResponse ¶

FetchStaticIpsResponse: Response message for a 'FetchStaticIps' response.

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*FetchStaticIpsResponse) MarshalJSON ¶

func (s *FetchStaticIpsResponse) MarshalJSON() ([]byte, error)

type ForwardSshTunnelConnectivity ¶

ForwardSshTunnelConnectivity: Forward SSH Tunnel connectivity.

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*ForwardSshTunnelConnectivity) MarshalJSON ¶

func (s *ForwardSshTunnelConnectivity) MarshalJSON() ([]byte, error)

type GcsDestinationConfig ¶

GcsDestinationConfig: Google Cloud Storage destination configuration

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.
    FileRotationInterval string `json:"fileRotationInterval,omitempty"`
    // FileRotationMb: The maximum file size to be saved in the bucket.
    FileRotationMb int64 `json:"fileRotationMb,omitempty"`
    // GcsFileFormat: File format that data should be written in. Deprecated field
    // (b/169501737) - use file_format instead.
    //
    // Possible values:
    //   "GCS_FILE_FORMAT_UNSPECIFIED" - Unspecified Cloud Storage file format.
    //   "AVRO" - Avro file format
    GcsFileFormat string `json:"gcsFileFormat,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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*GcsDestinationConfig) MarshalJSON ¶

func (s *GcsDestinationConfig) MarshalJSON() ([]byte, error)

type GcsProfile ¶

GcsProfile: Cloud Storage bucket profile.

type GcsProfile struct {
    // BucketName: Required. The full project and resource path for Cloud Storage
    // bucket including the name.
    BucketName string `json:"bucketName,omitempty"`
    // RootPath: The root path inside the Cloud Storage bucket.
    RootPath string `json:"rootPath,omitempty"`
    // ForceSendFields is a list of field names (e.g. "BucketName") to
    // unconditionally include in API requests. By default, fields with empty or
    // default values are omitted from API requests. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    ForceSendFields []string `json:"-"`
    // NullFields is a list of field names (e.g. "BucketName") to include in API
    // requests with the JSON null value. By default, fields with empty values are
    // omitted from API requests. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*GcsProfile) MarshalJSON ¶

func (s *GcsProfile) MarshalJSON() ([]byte, error)

type JsonFileFormat ¶

JsonFileFormat: JSON file format configuration.

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*ListConnectionProfilesResponse) MarshalJSON ¶

func (s *ListConnectionProfilesResponse) MarshalJSON() ([]byte, error)

type ListLocationsResponse ¶

ListLocationsResponse: The response message for Locations.ListLocations.

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*ListLocationsResponse) MarshalJSON ¶

func (s *ListLocationsResponse) MarshalJSON() ([]byte, error)

type ListOperationsResponse ¶

ListOperationsResponse: The response message for Operations.ListOperations.

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*ListPrivateConnectionsResponse) MarshalJSON ¶

func (s *ListPrivateConnectionsResponse) MarshalJSON() ([]byte, error)

type ListRoutesResponse ¶

ListRoutesResponse: route list response

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*ListRoutesResponse) MarshalJSON ¶

func (s *ListRoutesResponse) MarshalJSON() ([]byte, error)

type ListStreamObjectsResponse ¶

ListStreamObjectsResponse: Response containing the objects for a stream.

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*ListStreamsResponse) MarshalJSON ¶

func (s *ListStreamsResponse) MarshalJSON() ([]byte, error)

type Location ¶

Location: A resource that represents a Google Cloud 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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*Location) MarshalJSON ¶

func (s *Location) MarshalJSON() ([]byte, error)

type MysqlColumn ¶

MysqlColumn: MySQL Column.

type MysqlColumn struct {
    // Collation: Column collation.
    Collation string `json:"collation,omitempty"`
    // ColumnName: Column name.
    ColumnName string `json:"columnName,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"`
    // PrimaryKey: Whether or not the column represents a primary key.
    PrimaryKey bool `json:"primaryKey,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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*MysqlColumn) MarshalJSON ¶

func (s *MysqlColumn) MarshalJSON() ([]byte, error)

type MysqlDatabase ¶

MysqlDatabase: MySQL database.

type MysqlDatabase struct {
    // DatabaseName: Database name.
    DatabaseName string `json:"databaseName,omitempty"`
    // MysqlTables: Tables in the database.
    MysqlTables []*MysqlTable `json:"mysqlTables,omitempty"`
    // ForceSendFields is a list of field names (e.g. "DatabaseName") to
    // unconditionally include in API requests. By default, fields with empty or
    // default values are omitted from API requests. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    ForceSendFields []string `json:"-"`
    // NullFields is a list of field names (e.g. "DatabaseName") to include in API
    // requests with the JSON null value. By default, fields with empty values are
    // omitted from API requests. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*MysqlDatabase) MarshalJSON ¶

func (s *MysqlDatabase) MarshalJSON() ([]byte, error)

type MysqlObjectIdentifier ¶

MysqlObjectIdentifier: Mysql data source object identifier.

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*MysqlObjectIdentifier) MarshalJSON ¶

func (s *MysqlObjectIdentifier) MarshalJSON() ([]byte, error)

type MysqlProfile ¶

MysqlProfile: MySQL database profile.

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*MysqlProfile) MarshalJSON ¶

func (s *MysqlProfile) MarshalJSON() ([]byte, error)

type MysqlRdbms ¶

MysqlRdbms: MySQL database structure

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*MysqlRdbms) MarshalJSON ¶

func (s *MysqlRdbms) MarshalJSON() ([]byte, error)

type MysqlSourceConfig ¶

MysqlSourceConfig: MySQL source configuration

type MysqlSourceConfig struct {
    // Allowlist: MySQL objects to retrieve from the source.
    Allowlist *MysqlRdbms `json:"allowlist,omitempty"`
    // Rejectlist: MySQL objects to exclude from the stream.
    Rejectlist *MysqlRdbms `json:"rejectlist,omitempty"`
    // ForceSendFields is a list of field names (e.g. "Allowlist") to
    // unconditionally include in API requests. By default, fields with empty or
    // default values are omitted from API requests. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    ForceSendFields []string `json:"-"`
    // NullFields is a list of field names (e.g. "Allowlist") to include in API
    // requests with the JSON null value. By default, fields with empty values are
    // omitted from API requests. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*MysqlSourceConfig) MarshalJSON ¶

func (s *MysqlSourceConfig) MarshalJSON() ([]byte, error)

type MysqlSslConfig ¶

MysqlSslConfig: MySQL SSL configuration information.

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*MysqlSslConfig) MarshalJSON ¶

func (s *MysqlSslConfig) MarshalJSON() ([]byte, error)

type MysqlTable ¶

MysqlTable: MySQL table.

type MysqlTable struct {
    // MysqlColumns: MySQL columns in the database. When unspecified as part of
    // include/exclude lists, includes/excludes everything.
    MysqlColumns []*MysqlColumn `json:"mysqlColumns,omitempty"`
    // TableName: Table name.
    TableName string `json:"tableName,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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*MysqlTable) MarshalJSON ¶

func (s *MysqlTable) MarshalJSON() ([]byte, error)

type NoConnectivitySettings ¶

NoConnectivitySettings: No connectivity settings.

type NoConnectivitySettings struct {
}

type Operation ¶

Operation: This resource represents a long-running operation that is the result of a network API call.

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*Operation) MarshalJSON ¶

func (s *Operation) MarshalJSON() ([]byte, error)

type OperationMetadata ¶

OperationMetadata: Represents the metadata of the long-running operation.

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*OperationMetadata) MarshalJSON ¶

func (s *OperationMetadata) MarshalJSON() ([]byte, error)

type OracleColumn ¶

OracleColumn: Oracle Column.

type OracleColumn struct {
    // ColumnName: Column name.
    ColumnName string `json:"columnName,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. "ColumnName") to
    // unconditionally include in API requests. By default, fields with empty or
    // default values are omitted from API requests. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    ForceSendFields []string `json:"-"`
    // NullFields is a list of field names (e.g. "ColumnName") to include in API
    // requests with the JSON null value. By default, fields with empty values are
    // omitted from API requests. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*OracleColumn) MarshalJSON ¶

func (s *OracleColumn) MarshalJSON() ([]byte, error)

type OracleObjectIdentifier ¶

OracleObjectIdentifier: Oracle data source object identifier.

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*OracleObjectIdentifier) MarshalJSON ¶

func (s *OracleObjectIdentifier) MarshalJSON() ([]byte, error)

type OracleProfile ¶

OracleProfile: Oracle database profile.

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"`
    // 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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*OracleProfile) MarshalJSON ¶

func (s *OracleProfile) MarshalJSON() ([]byte, error)

type OracleRdbms ¶

OracleRdbms: Oracle database structure.

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*OracleRdbms) MarshalJSON ¶

func (s *OracleRdbms) MarshalJSON() ([]byte, error)

type OracleSchema ¶

OracleSchema: Oracle schema.

type OracleSchema struct {
    // OracleTables: Tables in the schema.
    OracleTables []*OracleTable `json:"oracleTables,omitempty"`
    // SchemaName: Schema name.
    SchemaName string `json:"schemaName,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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*OracleSchema) MarshalJSON ¶

func (s *OracleSchema) MarshalJSON() ([]byte, error)

type OracleSourceConfig ¶

OracleSourceConfig: Oracle data source configuration

type OracleSourceConfig struct {
    // Allowlist: Oracle objects to include in the stream.
    Allowlist *OracleRdbms `json:"allowlist,omitempty"`
    // DropLargeObjects: Drop large object values.
    DropLargeObjects *DropLargeObjects `json:"dropLargeObjects,omitempty"`
    // Rejectlist: Oracle objects to exclude from the stream.
    Rejectlist *OracleRdbms `json:"rejectlist,omitempty"`
    // ForceSendFields is a list of field names (e.g. "Allowlist") to
    // unconditionally include in API requests. By default, fields with empty or
    // default values are omitted from API requests. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    ForceSendFields []string `json:"-"`
    // NullFields is a list of field names (e.g. "Allowlist") to include in API
    // requests with the JSON null value. By default, fields with empty values are
    // omitted from API requests. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*OracleSourceConfig) MarshalJSON ¶

func (s *OracleSourceConfig) MarshalJSON() ([]byte, error)

type OracleTable ¶

OracleTable: Oracle table.

type OracleTable struct {
    // OracleColumns: Oracle columns in the schema. When unspecified as part of
    // inclue/exclude lists, includes/excludes everything.
    OracleColumns []*OracleColumn `json:"oracleColumns,omitempty"`
    // TableName: Table name.
    TableName string `json:"tableName,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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*OracleTable) MarshalJSON ¶

func (s *OracleTable) MarshalJSON() ([]byte, error)

type PrivateConnection ¶

PrivateConnection: The PrivateConnection resource is used to establish private connectivity between Datastream and a customer's network.

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"
    //   "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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*PrivateConnection) MarshalJSON ¶

func (s *PrivateConnection) MarshalJSON() ([]byte, error)

type PrivateConnectivity ¶

PrivateConnectivity: Private Connectivity

type PrivateConnectivity struct {
    PrivateConnectionName string `json:"privateConnectionName,omitempty"`
    // ForceSendFields is a list of field names (e.g. "PrivateConnectionName") to
    // unconditionally include in API requests. By default, fields with empty or
    // default values are omitted from API requests. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    ForceSendFields []string `json:"-"`
    // NullFields is a list of field names (e.g. "PrivateConnectionName") to
    // include in API requests with the JSON null value. By default, fields with
    // empty values are omitted from API requests. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

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.

func (*ProjectsLocationsConnectionProfilesCreateCall) Do ¶

func (c *ProjectsLocationsConnectionProfilesCreateCall) Do(opts ...googleapi.CallOption) (*Operation, error)

Do executes the "datastream.projects.locations.connectionProfiles.create" call. 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 details.

func (*ProjectsLocationsConnectionProfilesCreateCall) Header ¶

func (c *ProjectsLocationsConnectionProfilesCreateCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add 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).

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.

func (*ProjectsLocationsConnectionProfilesDeleteCall) Do ¶

func (c *ProjectsLocationsConnectionProfilesDeleteCall) Do(opts ...googleapi.CallOption) (*Operation, error)

Do executes the "datastream.projects.locations.connectionProfiles.delete" call. 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 details.

func (*ProjectsLocationsConnectionProfilesDeleteCall) Header ¶

func (c *ProjectsLocationsConnectionProfilesDeleteCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add 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.

func (*ProjectsLocationsConnectionProfilesDiscoverCall) Do ¶

func (c *ProjectsLocationsConnectionProfilesDiscoverCall) Do(opts ...googleapi.CallOption) (*DiscoverConnectionProfileResponse, error)

Do executes the "datastream.projects.locations.connectionProfiles.discover" call. 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 details.

func (*ProjectsLocationsConnectionProfilesDiscoverCall) Header ¶

func (c *ProjectsLocationsConnectionProfilesDiscoverCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add 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.

func (*ProjectsLocationsConnectionProfilesGetCall) Do ¶

func (c *ProjectsLocationsConnectionProfilesGetCall) Do(opts ...googleapi.CallOption) (*ConnectionProfile, error)

Do executes the "datastream.projects.locations.connectionProfiles.get" call. 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 details.

func (*ProjectsLocationsConnectionProfilesGetCall) Header ¶

func (c *ProjectsLocationsConnectionProfilesGetCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add headers to the request.

func (*ProjectsLocationsConnectionProfilesGetCall) IfNoneMatch ¶

func (c *ProjectsLocationsConnectionProfilesGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsConnectionProfilesGetCall

IfNoneMatch sets an 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.

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.

func (*ProjectsLocationsConnectionProfilesListCall) Do ¶

func (c *ProjectsLocationsConnectionProfilesListCall) Do(opts ...googleapi.CallOption) (*ListConnectionProfilesResponse, error)

Do executes the "datastream.projects.locations.connectionProfiles.list" call. 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 details.

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 a http.Header that can be modified by the caller to add headers to the request.

func (*ProjectsLocationsConnectionProfilesListCall) IfNoneMatch ¶

func (c *ProjectsLocationsConnectionProfilesListCall) IfNoneMatch(entityTag string) *ProjectsLocationsConnectionProfilesListCall

IfNoneMatch sets an 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.

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.

func (*ProjectsLocationsConnectionProfilesPatchCall) Do ¶

func (c *ProjectsLocationsConnectionProfilesPatchCall) Do(opts ...googleapi.CallOption) (*Operation, error)

Do executes the "datastream.projects.locations.connectionProfiles.patch" call. 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 details.

func (*ProjectsLocationsConnectionProfilesPatchCall) Header ¶

func (c *ProjectsLocationsConnectionProfilesPatchCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add 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 ¶

func (c *ProjectsLocationsConnectionProfilesPatchCall) ValidateOnly(validateOnly bool) *ProjectsLocationsConnectionProfilesPatchCall

ValidateOnly sets the optional parameter "validateOnly": Only validate the connection profile, but do not 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 under a parent data object that's optionally supplied in the request.

• parent: The parent resource of the ConnectionProfile 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.

func (*ProjectsLocationsFetchStaticIpsCall) Do ¶

func (c *ProjectsLocationsFetchStaticIpsCall) Do(opts ...googleapi.CallOption) (*FetchStaticIpsResponse, error)

Do executes the "datastream.projects.locations.fetchStaticIps" call. 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 details.

func (*ProjectsLocationsFetchStaticIpsCall) Header ¶

func (c *ProjectsLocationsFetchStaticIpsCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add headers to the request.

func (*ProjectsLocationsFetchStaticIpsCall) IfNoneMatch ¶

func (c *ProjectsLocationsFetchStaticIpsCall) IfNoneMatch(entityTag string) *ProjectsLocationsFetchStaticIpsCall

IfNoneMatch sets an 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.

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.

func (*ProjectsLocationsGetCall) Do ¶

func (c *ProjectsLocationsGetCall) Do(opts ...googleapi.CallOption) (*Location, error)

Do executes the "datastream.projects.locations.get" call. 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 details.

func (*ProjectsLocationsGetCall) Header ¶

func (c *ProjectsLocationsGetCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add headers to the request.

func (*ProjectsLocationsGetCall) IfNoneMatch ¶

func (c *ProjectsLocationsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsGetCall

IfNoneMatch sets an 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.

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.

func (*ProjectsLocationsListCall) Do ¶

func (c *ProjectsLocationsListCall) Do(opts ...googleapi.CallOption) (*ListLocationsResponse, error)

Do executes the "datastream.projects.locations.list" call. 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 details.

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 a http.Header that can be modified by the caller to add headers to the request.

func (*ProjectsLocationsListCall) IfNoneMatch ¶

func (c *ProjectsLocationsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsListCall

IfNoneMatch sets an 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.

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.

func (*ProjectsLocationsOperationsCancelCall) Do ¶

func (c *ProjectsLocationsOperationsCancelCall) Do(opts ...googleapi.CallOption) (*Empty, error)

Do executes the "datastream.projects.locations.operations.cancel" call. 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 details.

func (*ProjectsLocationsOperationsCancelCall) Header ¶

func (c *ProjectsLocationsOperationsCancelCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add 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.

func (*ProjectsLocationsOperationsDeleteCall) Do ¶

func (c *ProjectsLocationsOperationsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error)

Do executes the "datastream.projects.locations.operations.delete" call. 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 details.

func (*ProjectsLocationsOperationsDeleteCall) Header ¶

func (c *ProjectsLocationsOperationsDeleteCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add 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.

func (*ProjectsLocationsOperationsGetCall) Do ¶

func (c *ProjectsLocationsOperationsGetCall) Do(opts ...googleapi.CallOption) (*Operation, error)

Do executes the "datastream.projects.locations.operations.get" call. 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 details.

func (*ProjectsLocationsOperationsGetCall) Header ¶

func (c *ProjectsLocationsOperationsGetCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add headers to the request.

func (*ProjectsLocationsOperationsGetCall) IfNoneMatch ¶

func (c *ProjectsLocationsOperationsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsOperationsGetCall

IfNoneMatch sets an 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.

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.

func (*ProjectsLocationsOperationsListCall) Do ¶

func (c *ProjectsLocationsOperationsListCall) Do(opts ...googleapi.CallOption) (*ListOperationsResponse, error)

Do executes the "datastream.projects.locations.operations.list" call. 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 details.

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 a http.Header that can be modified by the caller to add headers to the request.

func (*ProjectsLocationsOperationsListCall) IfNoneMatch ¶

func (c *ProjectsLocationsOperationsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsOperationsListCall

IfNoneMatch sets an 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.

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.

func (*ProjectsLocationsPrivateConnectionsCreateCall) Do ¶

func (c *ProjectsLocationsPrivateConnectionsCreateCall) Do(opts ...googleapi.CallOption) (*Operation, error)

Do executes the "datastream.projects.locations.privateConnections.create" call. 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 details.

func (*ProjectsLocationsPrivateConnectionsCreateCall) Header ¶

func (c *ProjectsLocationsPrivateConnectionsCreateCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add 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.

func (*ProjectsLocationsPrivateConnectionsDeleteCall) Do ¶

func (c *ProjectsLocationsPrivateConnectionsDeleteCall) Do(opts ...googleapi.CallOption) (*Operation, error)

Do executes the "datastream.projects.locations.privateConnections.delete" call. 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 details.

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 a http.Header that can be modified by the caller to add 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.

func (*ProjectsLocationsPrivateConnectionsGetCall) Do ¶

func (c *ProjectsLocationsPrivateConnectionsGetCall) Do(opts ...googleapi.CallOption) (*PrivateConnection, error)

Do executes the "datastream.projects.locations.privateConnections.get" call. 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 details.

func (*ProjectsLocationsPrivateConnectionsGetCall) Header ¶

func (c *ProjectsLocationsPrivateConnectionsGetCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add headers to the request.

func (*ProjectsLocationsPrivateConnectionsGetCall) IfNoneMatch ¶

func (c *ProjectsLocationsPrivateConnectionsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsPrivateConnectionsGetCall

IfNoneMatch sets an 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.

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.

func (*ProjectsLocationsPrivateConnectionsListCall) Do ¶

func (c *ProjectsLocationsPrivateConnectionsListCall) Do(opts ...googleapi.CallOption) (*ListPrivateConnectionsResponse, error)

Do executes the "datastream.projects.locations.privateConnections.list" call. 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 details.

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 a http.Header that can be modified by the caller to add headers to the request.

func (*ProjectsLocationsPrivateConnectionsListCall) IfNoneMatch ¶

func (c *ProjectsLocationsPrivateConnectionsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsPrivateConnectionsListCall

IfNoneMatch sets an 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.

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.

func (*ProjectsLocationsPrivateConnectionsRoutesCreateCall) Do ¶

func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) Do(opts ...googleapi.CallOption) (*Operation, error)

Do executes the "datastream.projects.locations.privateConnections.routes.create" call. 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 details.

func (*ProjectsLocationsPrivateConnectionsRoutesCreateCall) Header ¶

func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add 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.

func (*ProjectsLocationsPrivateConnectionsRoutesDeleteCall) Do ¶

func (c *ProjectsLocationsPrivateConnectionsRoutesDeleteCall) Do(opts ...googleapi.CallOption) (*Operation, error)

Do executes the "datastream.projects.locations.privateConnections.routes.delete" call. 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 details.

func (*ProjectsLocationsPrivateConnectionsRoutesDeleteCall) Header ¶

func (c *ProjectsLocationsPrivateConnectionsRoutesDeleteCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add 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.

func (*ProjectsLocationsPrivateConnectionsRoutesGetCall) Do ¶

func (c *ProjectsLocationsPrivateConnectionsRoutesGetCall) Do(opts ...googleapi.CallOption) (*Route, error)

Do executes the "datastream.projects.locations.privateConnections.routes.get" call. 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 details.

func (*ProjectsLocationsPrivateConnectionsRoutesGetCall) Header ¶

func (c *ProjectsLocationsPrivateConnectionsRoutesGetCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add headers to the request.

func (*ProjectsLocationsPrivateConnectionsRoutesGetCall) IfNoneMatch ¶

func (c *ProjectsLocationsPrivateConnectionsRoutesGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsPrivateConnectionsRoutesGetCall

IfNoneMatch sets an 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.

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.

func (*ProjectsLocationsPrivateConnectionsRoutesListCall) Do ¶

func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Do(opts ...googleapi.CallOption) (*ListRoutesResponse, error)

Do executes the "datastream.projects.locations.privateConnections.routes.list" call. 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 details.

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 a http.Header that can be modified by the caller to add headers to the request.

func (*ProjectsLocationsPrivateConnectionsRoutesListCall) IfNoneMatch ¶

func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) IfNoneMatch(entityTag string) *ProjectsLocationsPrivateConnectionsRoutesListCall

IfNoneMatch sets an 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.

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 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 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 name resource of the Response type. 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.

func (*ProjectsLocationsStreamsCreateCall) Do ¶

func (c *ProjectsLocationsStreamsCreateCall) Do(opts ...googleapi.CallOption) (*Operation, error)

Do executes the "datastream.projects.locations.streams.create" call. 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 details.

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 a http.Header that can be modified by the caller to add 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 do not 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.

func (*ProjectsLocationsStreamsDeleteCall) Do ¶

func (c *ProjectsLocationsStreamsDeleteCall) Do(opts ...googleapi.CallOption) (*Operation, error)

Do executes the "datastream.projects.locations.streams.delete" call. 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 details.

func (*ProjectsLocationsStreamsDeleteCall) Header ¶

func (c *ProjectsLocationsStreamsDeleteCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add 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 ProjectsLocationsStreamsFetchErrorsCall ¶

type ProjectsLocationsStreamsFetchErrorsCall struct {
    // contains filtered or unexported fields
}

func (*ProjectsLocationsStreamsFetchErrorsCall) Context ¶

func (c *ProjectsLocationsStreamsFetchErrorsCall) Context(ctx context.Context) *ProjectsLocationsStreamsFetchErrorsCall

Context sets the context to be used in this call's Do method.

func (*ProjectsLocationsStreamsFetchErrorsCall) Do ¶

func (c *ProjectsLocationsStreamsFetchErrorsCall) Do(opts ...googleapi.CallOption) (*Operation, error)

Do executes the "datastream.projects.locations.streams.fetchErrors" call. 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 (*ProjectsLocationsStreamsFetchErrorsCall) Fields ¶

func (c *ProjectsLocationsStreamsFetchErrorsCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsFetchErrorsCall

Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more details.

func (*ProjectsLocationsStreamsFetchErrorsCall) Header ¶

func (c *ProjectsLocationsStreamsFetchErrorsCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add headers to the request.

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.

func (*ProjectsLocationsStreamsGetCall) Do ¶

func (c *ProjectsLocationsStreamsGetCall) Do(opts ...googleapi.CallOption) (*Stream, error)

Do executes the "datastream.projects.locations.streams.get" call. 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 details.

func (*ProjectsLocationsStreamsGetCall) Header ¶

func (c *ProjectsLocationsStreamsGetCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add headers to the request.

func (*ProjectsLocationsStreamsGetCall) IfNoneMatch ¶

func (c *ProjectsLocationsStreamsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsStreamsGetCall

IfNoneMatch sets an 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.

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.

func (*ProjectsLocationsStreamsListCall) Do ¶

func (c *ProjectsLocationsStreamsListCall) Do(opts ...googleapi.CallOption) (*ListStreamsResponse, error)

Do executes the "datastream.projects.locations.streams.list" call. 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 details.

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 a http.Header that can be modified by the caller to add headers to the request.

func (*ProjectsLocationsStreamsListCall) IfNoneMatch ¶

func (c *ProjectsLocationsStreamsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsStreamsListCall

IfNoneMatch sets an 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.

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.

func (*ProjectsLocationsStreamsObjectsGetCall) Do ¶

func (c *ProjectsLocationsStreamsObjectsGetCall) Do(opts ...googleapi.CallOption) (*StreamObject, error)

Do executes the "datastream.projects.locations.streams.objects.get" call. 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 details.

func (*ProjectsLocationsStreamsObjectsGetCall) Header ¶

func (c *ProjectsLocationsStreamsObjectsGetCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add headers to the request.

func (*ProjectsLocationsStreamsObjectsGetCall) IfNoneMatch ¶

func (c *ProjectsLocationsStreamsObjectsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsStreamsObjectsGetCall

IfNoneMatch sets an 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.

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.

func (*ProjectsLocationsStreamsObjectsListCall) Do ¶

func (c *ProjectsLocationsStreamsObjectsListCall) Do(opts ...googleapi.CallOption) (*ListStreamObjectsResponse, error)

Do executes the "datastream.projects.locations.streams.objects.list" call. 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 details.

func (*ProjectsLocationsStreamsObjectsListCall) Header ¶

func (c *ProjectsLocationsStreamsObjectsListCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add headers to the request.

func (*ProjectsLocationsStreamsObjectsListCall) IfNoneMatch ¶

func (c *ProjectsLocationsStreamsObjectsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsStreamsObjectsListCall

IfNoneMatch sets an 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.

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 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) StartBackfillJob ¶

func (r *ProjectsLocationsStreamsObjectsService) StartBackfillJob(object string) *ProjectsLocationsStreamsObjectsStartBackfillJobCall

StartBackfillJob: Starts 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) *ProjectsLocationsStreamsObjectsStopBackfillJobCall

StopBackfillJob: Stops the 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.

func (*ProjectsLocationsStreamsObjectsStartBackfillJobCall) Do ¶

func (c *ProjectsLocationsStreamsObjectsStartBackfillJobCall) Do(opts ...googleapi.CallOption) (*StartBackfillJobResponse, error)

Do executes the "datastream.projects.locations.streams.objects.startBackfillJob" call. 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 details.

func (*ProjectsLocationsStreamsObjectsStartBackfillJobCall) Header ¶

func (c *ProjectsLocationsStreamsObjectsStartBackfillJobCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add 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.

func (*ProjectsLocationsStreamsObjectsStopBackfillJobCall) Do ¶

func (c *ProjectsLocationsStreamsObjectsStopBackfillJobCall) Do(opts ...googleapi.CallOption) (*StopBackfillJobResponse, error)

Do executes the "datastream.projects.locations.streams.objects.stopBackfillJob" call. 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 details.

func (*ProjectsLocationsStreamsObjectsStopBackfillJobCall) Header ¶

func (c *ProjectsLocationsStreamsObjectsStopBackfillJobCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add 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.

func (*ProjectsLocationsStreamsPatchCall) Do ¶

func (c *ProjectsLocationsStreamsPatchCall) Do(opts ...googleapi.CallOption) (*Operation, error)

Do executes the "datastream.projects.locations.streams.patch" call. 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 details.

func (*ProjectsLocationsStreamsPatchCall) Force ¶

func (c *ProjectsLocationsStreamsPatchCall) Force(force bool) *ProjectsLocationsStreamsPatchCall

Force sets the optional parameter "force": Execute the update without validating it.

func (*ProjectsLocationsStreamsPatchCall) Header ¶

func (c *ProjectsLocationsStreamsPatchCall) Header() http.Header

Header returns a http.Header that can be modified by the caller to add 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 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) FetchErrors ¶

func (r *ProjectsLocationsStreamsService) FetchErrors(stream string, fetcherrorsrequest *FetchErrorsRequest) *ProjectsLocationsStreamsFetchErrorsCall

FetchErrors: Use this method to fetch any errors associated with a stream.

- stream: Name of the Stream resource for which to fetch any errors.

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.

type ProjectsService ¶

type ProjectsService struct {
    Locations *ProjectsLocationsService
    // contains filtered or unexported fields
}

func NewProjectsService ¶

func NewProjectsService(s *Service) *ProjectsService

type Route ¶

Route: The Route resource is the child of the PrivateConnection resource. It used to define a route for a PrivateConnection setup.

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*Route) MarshalJSON ¶

func (s *Route) 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 ¶

func New(client *http.Client) (*Service, error)

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 ¶

func NewService(ctx context.Context, opts ...option.ClientOption) (*Service, error)

NewService creates a new Service.

type SourceConfig ¶

SourceConfig: The configuration of the stream source.

type SourceConfig struct {
    // MysqlSourceConfig: MySQL data source configuration
    MysqlSourceConfig *MysqlSourceConfig `json:"mysqlSourceConfig,omitempty"`
    // OracleSourceConfig: Oracle data source configuration
    OracleSourceConfig *OracleSourceConfig `json:"oracleSourceConfig,omitempty"`
    // SourceConnectionProfileName: Required. Source connection profile identifier.
    SourceConnectionProfileName string `json:"sourceConnectionProfileName,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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*SourceConfig) MarshalJSON ¶

func (s *SourceConfig) MarshalJSON() ([]byte, error)

type SourceObjectIdentifier ¶

SourceObjectIdentifier: Represents an identifier of an object in the data source.

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"`
    // 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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*SourceObjectIdentifier) MarshalJSON ¶

func (s *SourceObjectIdentifier) MarshalJSON() ([]byte, error)

type StartBackfillJobResponse ¶

StartBackfillJobResponse: Response for manually initiating a backfill job for a specific stream object.

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*StartBackfillJobResponse) MarshalJSON ¶

func (s *StartBackfillJobResponse) MarshalJSON() ([]byte, error)

type StaticServiceIpConnectivity ¶

StaticServiceIpConnectivity: Static IP address connectivity.

type StaticServiceIpConnectivity struct {
}

type Status ¶

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).

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*Status) MarshalJSON ¶

func (s *Status) MarshalJSON() ([]byte, error)

type StopBackfillJobResponse ¶

StopBackfillJobResponse: Response for manually stop a backfill job for a specific stream object.

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

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"`
    // 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.
    //   "CREATED" - The stream has been created.
    //   "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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*Stream) MarshalJSON ¶

func (s *Stream) MarshalJSON() ([]byte, error)

type StreamObject ¶

StreamObject: A specific stream object (e.g a specific DB table).

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'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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

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"`
    // Status: Validation execution status.
    //
    // Possible values:
    //   "STATUS_UNSPECIFIED" - Unspecified status.
    //   "NOT_EXECUTED" - Validation did not execute.
    //   "FAILED" - Validation failed.
    //   "PASSED" - Validation passed.
    Status string `json:"status,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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*Validation) MarshalJSON ¶

func (s *Validation) MarshalJSON() ([]byte, error)

type ValidationMessage ¶

ValidationMessage: Represent user-facing validation result message.

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*ValidationMessage) MarshalJSON ¶

func (s *ValidationMessage) MarshalJSON() ([]byte, error)

type ValidationResult ¶

ValidationResult: Contains the current validation results.

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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*ValidationResult) MarshalJSON ¶

func (s *ValidationResult) MarshalJSON() ([]byte, error)

type VpcPeeringConfig ¶

VpcPeeringConfig: The VPC Peering configuration is used to create VPC peering between Datastream and the consumer's VPC.

type VpcPeeringConfig struct {
    // Subnet: Required. A free subnet for peering. (CIDR of /29)
    Subnet string `json:"subnet,omitempty"`
    // VpcName: Required. fully qualified name of the VPC Datastream will peer to.
    VpcName string `json:"vpcName,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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more
    // details.
    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. See
    // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details.
    NullFields []string `json:"-"`
}

func (*VpcPeeringConfig) MarshalJSON ¶

func (s *VpcPeeringConfig) MarshalJSON() ([]byte, error)