datastream

Sep 8, 2025

Changes in this version

+ type MongodbChangeStreamPosition struct

+ ForceSendFields []string

+ NullFields []string

+ StartTime string

+ func (s MongodbChangeStreamPosition) MarshalJSON() ([]byte, error)

type SpecificStartPosition

+ MongodbChangeStreamPosition *MongodbChangeStreamPosition

Aug 5, 2025

Changes in this version

+ type BasicEncryption struct

+ type EncryptionAndServerValidation struct

+ CaCertificate string

+ ForceSendFields []string

+ NullFields []string

+ ServerCertificateHostname string

+ func (s EncryptionAndServerValidation) MarshalJSON() ([]byte, error)

+ type EncryptionNotEnforced struct

type SqlServerProfile

+ SslConfig *SqlServerSslConfig

+ type SqlServerSslConfig struct

+ BasicEncryption *BasicEncryption

+ EncryptionAndServerValidation *EncryptionAndServerValidation

+ EncryptionNotEnforced *EncryptionNotEnforced

+ ForceSendFields []string

+ NullFields []string

+ func (s SqlServerSslConfig) MarshalJSON() ([]byte, error)

Jul 22, 2025

Changes in this version

type OracleSslConfig

+ ServerCertificateDistinguishedName string

type ServerAndClientVerification

+ ServerCertificateHostname string

type ServerVerification

+ ServerCertificateHostname string

Jul 9, 2025

Changes in this version

type SourceHierarchyDatasets

+ ProjectId string

May 28, 2025

Changes in this version

type MongodbProfile

+ SslConfig *MongodbSslConfig

+ type MongodbSslConfig struct

+ CaCertificate string

+ CaCertificateSet bool

+ ClientCertificate string

+ ClientCertificateSet bool

+ ClientKey string

+ ClientKeySet bool

+ ForceSendFields []string

+ NullFields []string

+ SecretManagerStoredClientKey string

+ func (s MongodbSslConfig) MarshalJSON() ([]byte, error)

May 21, 2025

Changes in this version

type MongodbSourceConfig

+ MaxConcurrentBackfillTasks int64

type StandardConnectionFormat

+ DirectConnection bool

+ ForceSendFields []string

+ NullFields []string

+ func (s StandardConnectionFormat) MarshalJSON() ([]byte, error)

Apr 14, 2025

Changes in this version

type BackfillAllStrategy

+ MongodbExcludedObjects *MongodbCluster

type ConnectionProfile

+ MongodbProfile *MongodbProfile

type DiscoverConnectionProfileRequest

+ MongodbCluster *MongodbCluster

+ SalesforceOrg *SalesforceOrg

type DiscoverConnectionProfileResponse

+ MongodbCluster *MongodbCluster

+ SalesforceOrg *SalesforceOrg

+ type HostAddress struct

+ ForceSendFields []string

+ Hostname string

+ NullFields []string

+ Port int64

+ func (s HostAddress) MarshalJSON() ([]byte, error)

+ type MongodbCluster struct

+ Databases []*MongodbDatabase

+ ForceSendFields []string

+ NullFields []string

+ func (s MongodbCluster) MarshalJSON() ([]byte, error)

+ type MongodbCollection struct

+ Collection string

+ Fields []*MongodbField

+ ForceSendFields []string

+ NullFields []string

+ func (s MongodbCollection) MarshalJSON() ([]byte, error)

+ type MongodbDatabase struct

+ Collections []*MongodbCollection

+ Database string

+ ForceSendFields []string

+ NullFields []string

+ func (s MongodbDatabase) MarshalJSON() ([]byte, error)

+ type MongodbField struct

+ Field string

+ ForceSendFields []string

+ NullFields []string

+ func (s MongodbField) MarshalJSON() ([]byte, error)

+ type MongodbObjectIdentifier struct

+ Collection string

+ Database string

+ ForceSendFields []string

+ NullFields []string

+ func (s MongodbObjectIdentifier) MarshalJSON() ([]byte, error)

+ type MongodbProfile struct

+ ForceSendFields []string

+ HostAddresses []*HostAddress

+ NullFields []string

+ Password string

+ ReplicaSet string

+ SecretManagerStoredPassword string

+ SrvConnectionFormat *SrvConnectionFormat

+ StandardConnectionFormat *StandardConnectionFormat

+ Username string

+ func (s MongodbProfile) MarshalJSON() ([]byte, error)

+ type MongodbSourceConfig struct

+ ExcludeObjects *MongodbCluster

+ ForceSendFields []string

+ IncludeObjects *MongodbCluster

+ NullFields []string

+ func (s MongodbSourceConfig) MarshalJSON() ([]byte, error)

type ProjectsLocationsListCall

+ func (c *ProjectsLocationsListCall) ExtraLocationTypes(extraLocationTypes ...string) *ProjectsLocationsListCall

type SourceConfig

+ MongodbSourceConfig *MongodbSourceConfig

type SourceObjectIdentifier

+ MongodbIdentifier *MongodbObjectIdentifier

+ type SrvConnectionFormat struct

+ type StandardConnectionFormat struct

Mar 25, 2025

Changes in this version

type PrivateConnection

+ PscInterfaceConfig *PscInterfaceConfig

type ProjectsLocationsPrivateConnectionsCreateCall

+ func (c *ProjectsLocationsPrivateConnectionsCreateCall) ValidateOnly(validateOnly bool) *ProjectsLocationsPrivateConnectionsCreateCall

+ type PscInterfaceConfig struct

+ ForceSendFields []string

+ NetworkAttachment string

+ NullFields []string

+ func (s PscInterfaceConfig) MarshalJSON() ([]byte, error)

Mar 19, 2025

Changes in this version

type MysqlProfile

+ SecretManagerStoredPassword string

type OracleAsmConfig

+ SecretManagerStoredPassword string

type PostgresqlProfile

+ SecretManagerStoredPassword string

type SqlServerProfile

+ SecretManagerStoredPassword string

Feb 25, 2025

Changes in this version

type BackfillAllStrategy

+ SalesforceExcludedObjects *SalesforceOrg

type BigQueryDestinationConfig

+ BlmtConfig *BlmtConfig

+ type BlmtConfig struct

+ Bucket string

+ ConnectionName string

+ FileFormat string

+ ForceSendFields []string

+ NullFields []string

+ RootPath string

+ TableFormat string

+ func (s BlmtConfig) MarshalJSON() ([]byte, error)

type ConnectionProfile

+ SalesforceProfile *SalesforceProfile

+ type Oauth2ClientCredentials struct

+ ClientId string

+ ClientSecret string

+ ForceSendFields []string

+ NullFields []string

+ SecretManagerStoredClientSecret string

+ func (s Oauth2ClientCredentials) MarshalJSON() ([]byte, error)

+ type SalesforceField struct

+ DataType string

+ ForceSendFields []string

+ Name string

+ Nillable bool

+ NullFields []string

+ func (s SalesforceField) MarshalJSON() ([]byte, error)

+ type SalesforceObject struct

+ Fields []*SalesforceField

+ ForceSendFields []string

+ NullFields []string

+ ObjectName string

+ func (s SalesforceObject) MarshalJSON() ([]byte, error)

+ type SalesforceObjectIdentifier struct

+ ForceSendFields []string

+ NullFields []string

+ ObjectName string

+ func (s SalesforceObjectIdentifier) MarshalJSON() ([]byte, error)

+ type SalesforceOrg struct

+ ForceSendFields []string

+ NullFields []string

+ Objects []*SalesforceObject

+ func (s SalesforceOrg) MarshalJSON() ([]byte, error)

+ type SalesforceProfile struct

+ Domain string

+ ForceSendFields []string

+ NullFields []string

+ Oauth2ClientCredentials *Oauth2ClientCredentials

+ UserCredentials *UserCredentials

+ func (s SalesforceProfile) MarshalJSON() ([]byte, error)

+ type SalesforceSourceConfig struct

+ ExcludeObjects *SalesforceOrg

+ ForceSendFields []string

+ IncludeObjects *SalesforceOrg

+ NullFields []string

+ PollingInterval string

+ func (s SalesforceSourceConfig) MarshalJSON() ([]byte, error)

type SourceConfig

+ SalesforceSourceConfig *SalesforceSourceConfig

type SourceObjectIdentifier

+ SalesforceIdentifier *SalesforceObjectIdentifier

+ type UserCredentials struct

+ ForceSendFields []string

+ NullFields []string

+ Password string

+ SecretManagerStoredPassword string

+ SecretManagerStoredSecurityToken string

+ SecurityToken string

+ Username string

+ func (s UserCredentials) MarshalJSON() ([]byte, error)

Feb 12, 2025

Changes in this version

+ type MysqlGtidPosition struct

+ ForceSendFields []string

+ GtidSet string

+ NullFields []string

+ func (s MysqlGtidPosition) MarshalJSON() ([]byte, error)

type SpecificStartPosition

+ MysqlGtidPosition *MysqlGtidPosition

Jan 28, 2025

Changes in this version

type ConnectionProfile

+ SatisfiesPzi bool

+ SatisfiesPzs bool

type PrivateConnection

+ SatisfiesPzi bool

+ SatisfiesPzs bool

type Stream

+ SatisfiesPzi bool

+ SatisfiesPzs bool

Jan 15, 2025

Changes in this version

type PostgresqlProfile

+ SslConfig *PostgresqlSslConfig

+ type PostgresqlSslConfig struct

+ ForceSendFields []string

+ NullFields []string

+ ServerAndClientVerification *ServerAndClientVerification

+ ServerVerification *ServerVerification

+ func (s PostgresqlSslConfig) MarshalJSON() ([]byte, error)

+ type ServerAndClientVerification struct

+ CaCertificate string

+ ClientCertificate string

+ ClientKey string

+ ForceSendFields []string

+ NullFields []string

+ func (s ServerAndClientVerification) MarshalJSON() ([]byte, error)

+ type ServerVerification struct

+ CaCertificate string

+ ForceSendFields []string

+ NullFields []string

+ func (s ServerVerification) MarshalJSON() ([]byte, error)

Dec 16, 2024

Changes in this version

type SpecificStartPosition

+ SqlServerLsnPosition *SqlServerLsnPosition

+ type SqlServerLsnPosition struct

+ ForceSendFields []string

+ Lsn string

+ NullFields []string

+ func (s SqlServerLsnPosition) MarshalJSON() ([]byte, error)

Nov 6, 2024

Changes in this version

+ type BinaryLogParser struct

+ ForceSendFields []string

+ LogFileDirectories *LogFileDirectories

+ NullFields []string

+ OracleAsmLogFileAccess *OracleAsmLogFileAccess

+ func (s BinaryLogParser) MarshalJSON() ([]byte, error)

+ type BinaryLogPosition struct

+ type Gtid struct

+ type LogFileDirectories struct

+ ArchivedLogDirectory string

+ ForceSendFields []string

+ NullFields []string

+ OnlineLogDirectory string

+ func (s LogFileDirectories) MarshalJSON() ([]byte, error)

+ type LogMiner struct

type MysqlSourceConfig

+ BinaryLogPosition *BinaryLogPosition

+ Gtid *Gtid

+ type OracleAsmConfig struct

+ AsmService string

+ ConnectionAttributes map[string]string

+ ForceSendFields []string

+ Hostname string

+ NullFields []string

+ OracleSslConfig *OracleSslConfig

+ Password string

+ Port int64

+ Username string

+ func (s OracleAsmConfig) MarshalJSON() ([]byte, error)

+ type OracleAsmLogFileAccess struct

type OracleProfile

+ OracleAsmConfig *OracleAsmConfig

+ SecretManagerStoredPassword string

type OracleSourceConfig

+ BinaryLogParser *BinaryLogParser

+ LogMiner *LogMiner

Sep 19, 2024

Changes in this version

type RunStreamRequest

+ Force bool

Jun 18, 2024

Changes in this version

type DiscoverConnectionProfileRequest

+ SqlServerRdbms *SqlServerRdbms

type DiscoverConnectionProfileResponse

+ SqlServerRdbms *SqlServerRdbms

Jun 4, 2024

Changes in this version

+ type SqlServerChangeTables struct

type SqlServerSourceConfig

+ ChangeTables *SqlServerChangeTables

+ TransactionLogs *SqlServerTransactionLogs

+ type SqlServerTransactionLogs struct

Apr 22, 2024

Changes in this version

+ type AppendOnly struct

type BigQueryDestinationConfig

+ AppendOnly *AppendOnly

+ Merge *Merge

+ type Merge struct

Feb 21, 2024

Changes in this version

type BackfillAllStrategy

+ SqlServerExcludedObjects *SqlServerRdbms

type ConnectionProfile

+ SqlServerProfile *SqlServerProfile

type SourceConfig

+ SqlServerSourceConfig *SqlServerSourceConfig

type SourceObjectIdentifier

+ SqlServerIdentifier *SqlServerObjectIdentifier

+ type SqlServerColumn struct

+ Column string

+ DataType string

+ ForceSendFields []string

+ Length int64

+ NullFields []string

+ Nullable bool

+ OrdinalPosition int64

+ Precision int64

+ PrimaryKey bool

+ Scale int64

+ func (s *SqlServerColumn) MarshalJSON() ([]byte, error)

+ type SqlServerObjectIdentifier struct

+ ForceSendFields []string

+ NullFields []string

+ Schema string

+ Table string

+ func (s *SqlServerObjectIdentifier) MarshalJSON() ([]byte, error)

+ type SqlServerProfile struct

+ Database string

+ ForceSendFields []string

+ Hostname string

+ NullFields []string

+ Password string

+ Port int64

+ Username string

+ func (s *SqlServerProfile) MarshalJSON() ([]byte, error)

+ type SqlServerRdbms struct

+ ForceSendFields []string

+ NullFields []string

+ Schemas []*SqlServerSchema

+ func (s *SqlServerRdbms) MarshalJSON() ([]byte, error)

+ type SqlServerSchema struct

+ ForceSendFields []string

+ NullFields []string

+ Schema string

+ Tables []*SqlServerTable

+ func (s *SqlServerSchema) MarshalJSON() ([]byte, error)

+ type SqlServerSourceConfig struct

+ ExcludeObjects *SqlServerRdbms

+ ForceSendFields []string

+ IncludeObjects *SqlServerRdbms

+ MaxConcurrentBackfillTasks int64

+ MaxConcurrentCdcTasks int64

+ NullFields []string

+ func (s *SqlServerSourceConfig) MarshalJSON() ([]byte, error)

+ type SqlServerTable struct

+ Columns []*SqlServerColumn

+ ForceSendFields []string

+ NullFields []string

+ Table string

+ func (s *SqlServerTable) MarshalJSON() ([]byte, error)

Jan 11, 2024

Changes in this version

+ type OracleScnPosition struct

+ ForceSendFields []string

+ NullFields []string

+ Scn int64

+ func (s *OracleScnPosition) MarshalJSON() ([]byte, error)

type SpecificStartPosition

+ OracleScnPosition *OracleScnPosition

Sep 8, 2023

Changes in this version

type OracleProfile

+ OracleSslConfig *OracleSslConfig

+ type OracleSslConfig struct

+ CaCertificate string

+ CaCertificateSet bool

+ ForceSendFields []string

+ NullFields []string

+ func (s *OracleSslConfig) MarshalJSON() ([]byte, error)

type Stream

+ LastRecoveryTime string

Aug 7, 2023

Changes in this version

+ type CdcStrategy struct

+ ForceSendFields []string

+ MostRecentStartPosition *MostRecentStartPosition

+ NextAvailableStartPosition *NextAvailableStartPosition

+ NullFields []string

+ SpecificStartPosition *SpecificStartPosition

+ func (s *CdcStrategy) MarshalJSON() ([]byte, error)

+ type MostRecentStartPosition struct

+ type MysqlLogPosition struct

+ ForceSendFields []string

+ LogFile string

+ LogPosition int64

+ NullFields []string

+ func (s *MysqlLogPosition) MarshalJSON() ([]byte, error)

+ type NextAvailableStartPosition struct

+ type ProjectsLocationsStreamsRunCall struct

+ func (c *ProjectsLocationsStreamsRunCall) Context(ctx context.Context) *ProjectsLocationsStreamsRunCall

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

+ func (c *ProjectsLocationsStreamsRunCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsRunCall

+ func (c *ProjectsLocationsStreamsRunCall) Header() http.Header

type ProjectsLocationsStreamsService

+ func (r *ProjectsLocationsStreamsService) Run(name string, runstreamrequest *RunStreamRequest) *ProjectsLocationsStreamsRunCall

+ type RunStreamRequest struct

+ CdcStrategy *CdcStrategy

+ ForceSendFields []string

+ NullFields []string

+ func (s *RunStreamRequest) MarshalJSON() ([]byte, error)

+ type SpecificStartPosition struct

+ ForceSendFields []string

+ MysqlLogPosition *MysqlLogPosition

+ NullFields []string

+ func (s *SpecificStartPosition) MarshalJSON() ([]byte, error)

Jul 24, 2023

Changes in this version

type MysqlColumn

+ Precision int64

+ Scale int64

May 30, 2023

Changes in this version

type ProjectsLocationsStreamsPatchCall

+ func (c *ProjectsLocationsStreamsPatchCall) CdcStrategySpecificStartPositionMysqlLogPositionLogFile(cdcStrategySpecificStartPositionMysqlLogPositionLogFile string) *ProjectsLocationsStreamsPatchCall

+ func (c *ProjectsLocationsStreamsPatchCall) CdcStrategySpecificStartPositionMysqlLogPositionLogPosition(cdcStrategySpecificStartPositionMysqlLogPositionLogPosition int64) *ProjectsLocationsStreamsPatchCall

Feb 13, 2023

Changes in this version

type MysqlSourceConfig

+ MaxConcurrentBackfillTasks int64

type OracleSourceConfig

+ MaxConcurrentBackfillTasks int64

type PostgresqlSourceConfig

+ MaxConcurrentBackfillTasks int64

Jan 4, 2023

Changes in this version

type ProjectsLocationsPrivateConnectionsCreateCall

+ func (c *ProjectsLocationsPrivateConnectionsCreateCall) Force(force bool) *ProjectsLocationsPrivateConnectionsCreateCall

Sep 14, 2022

Changes in this version

type BackfillAllStrategy

+ PostgresqlExcludedObjects *PostgresqlRdbms

+ type BigQueryDestinationConfig struct

+ DataFreshness string

+ ForceSendFields []string

+ NullFields []string

+ SingleTargetDataset *SingleTargetDataset

+ SourceHierarchyDatasets *SourceHierarchyDatasets

+ func (s *BigQueryDestinationConfig) MarshalJSON() ([]byte, error)

+ type BigQueryProfile struct

type ConnectionProfile

+ BigqueryProfile *BigQueryProfile

+ PostgresqlProfile *PostgresqlProfile

+ type DatasetTemplate struct

+ DatasetIdPrefix string

+ ForceSendFields []string

+ KmsKeyName string

+ Location string

+ NullFields []string

+ func (s *DatasetTemplate) MarshalJSON() ([]byte, error)

type DestinationConfig

+ BigqueryDestinationConfig *BigQueryDestinationConfig

type DiscoverConnectionProfileRequest

+ PostgresqlRdbms *PostgresqlRdbms

type DiscoverConnectionProfileResponse

+ PostgresqlRdbms *PostgresqlRdbms

+ type PostgresqlColumn struct

+ Column string

+ DataType string

+ ForceSendFields []string

+ Length int64

+ NullFields []string

+ Nullable bool

+ OrdinalPosition int64

+ Precision int64

+ PrimaryKey bool

+ Scale int64

+ func (s *PostgresqlColumn) MarshalJSON() ([]byte, error)

+ type PostgresqlObjectIdentifier struct

+ ForceSendFields []string

+ NullFields []string

+ Schema string

+ Table string

+ func (s *PostgresqlObjectIdentifier) MarshalJSON() ([]byte, error)

+ type PostgresqlProfile struct

+ Database string

+ ForceSendFields []string

+ Hostname string

+ NullFields []string

+ Password string

+ Port int64

+ Username string

+ func (s *PostgresqlProfile) MarshalJSON() ([]byte, error)

+ type PostgresqlRdbms struct

+ ForceSendFields []string

+ NullFields []string

+ PostgresqlSchemas []*PostgresqlSchema

+ func (s *PostgresqlRdbms) MarshalJSON() ([]byte, error)

+ type PostgresqlSchema struct

+ ForceSendFields []string

+ NullFields []string

+ PostgresqlTables []*PostgresqlTable

+ Schema string

+ func (s *PostgresqlSchema) MarshalJSON() ([]byte, error)

+ type PostgresqlSourceConfig struct

+ ExcludeObjects *PostgresqlRdbms

+ ForceSendFields []string

+ IncludeObjects *PostgresqlRdbms

+ NullFields []string

+ Publication string

+ ReplicationSlot string

+ func (s *PostgresqlSourceConfig) MarshalJSON() ([]byte, error)

+ type PostgresqlTable struct

+ ForceSendFields []string

+ NullFields []string

+ PostgresqlColumns []*PostgresqlColumn

+ Table string

+ func (s *PostgresqlTable) MarshalJSON() ([]byte, error)

+ type SingleTargetDataset struct

+ DatasetId string

+ ForceSendFields []string

+ NullFields []string

+ func (s *SingleTargetDataset) MarshalJSON() ([]byte, error)

type SourceConfig

+ PostgresqlSourceConfig *PostgresqlSourceConfig

+ type SourceHierarchyDatasets struct

+ DatasetTemplate *DatasetTemplate

+ ForceSendFields []string

+ NullFields []string

+ func (s *SourceHierarchyDatasets) MarshalJSON() ([]byte, error)

type SourceObjectIdentifier

+ PostgresqlIdentifier *PostgresqlObjectIdentifier

Jul 26, 2022

Changes in this version

type MysqlSourceConfig

+ MaxConcurrentCdcTasks int64

type OracleSourceConfig

+ MaxConcurrentCdcTasks int64

+ StreamLargeObjects *StreamLargeObjects

+ type StreamLargeObjects struct

Apr 20, 2022

Changes in this version

+ type DropLargeObjects struct

Mar 30, 2022

Changes in this version

+ type OracleDropLargeObjects struct

type OracleSourceConfig

+ DropLargeObjects *OracleDropLargeObjects

Jan 28, 2022

Changes in this version

type ProjectsLocationsConnectionProfilesCreateCall

+ func (c *ProjectsLocationsConnectionProfilesCreateCall) ValidateOnly(validateOnly bool) *ProjectsLocationsConnectionProfilesCreateCall

type ProjectsLocationsConnectionProfilesPatchCall

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

Dec 2, 2021

Changes in this version

+ const CloudPlatformScope

+ type AvroFileFormat struct

+ type BackfillAllStrategy struct

+ ForceSendFields []string

+ MysqlExcludedObjects *MysqlRdbms

+ NullFields []string

+ OracleExcludedObjects *OracleRdbms

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

+ type BackfillJob struct

+ Errors []*Error

+ ForceSendFields []string

+ LastEndTime string

+ LastStartTime string

+ NullFields []string

+ State string

+ Trigger string

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

+ type BackfillNoneStrategy struct

+ type CancelOperationRequest struct

+ type ConnectionProfile struct

+ CreateTime string

+ DisplayName string

+ ForceSendFields []string

+ ForwardSshConnectivity *ForwardSshTunnelConnectivity

+ GcsProfile *GcsProfile

+ Labels map[string]string

+ MysqlProfile *MysqlProfile

+ Name string

+ NullFields []string

+ OracleProfile *OracleProfile

+ PrivateConnectivity *PrivateConnectivity

+ StaticServiceIpConnectivity *StaticServiceIpConnectivity

+ UpdateTime string

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

+ type DestinationConfig struct

+ DestinationConnectionProfile string

+ ForceSendFields []string

+ GcsDestinationConfig *GcsDestinationConfig

+ NullFields []string

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

+ type DiscoverConnectionProfileRequest struct

+ ConnectionProfile *ConnectionProfile

+ ConnectionProfileName string

+ ForceSendFields []string

+ FullHierarchy bool

+ HierarchyDepth int64

+ MysqlRdbms *MysqlRdbms

+ NullFields []string

+ OracleRdbms *OracleRdbms

+ func (s *DiscoverConnectionProfileRequest) MarshalJSON() ([]byte, error)

+ type DiscoverConnectionProfileResponse struct

+ ForceSendFields []string

+ MysqlRdbms *MysqlRdbms

+ NullFields []string

+ OracleRdbms *OracleRdbms

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

+ type Empty struct

+ type Error struct

+ Details map[string]string

+ ErrorTime string

+ ErrorUuid string

+ ForceSendFields []string

+ Message string

+ NullFields []string

+ Reason string

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

+ type FetchStaticIpsResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ StaticIps []string

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

+ type ForwardSshTunnelConnectivity struct

+ ForceSendFields []string

+ Hostname string

+ NullFields []string

+ Password string

+ Port int64

+ PrivateKey string

+ Username string

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

+ type GcsDestinationConfig struct

+ AvroFileFormat *AvroFileFormat

+ FileRotationInterval string

+ FileRotationMb int64

+ ForceSendFields []string

+ JsonFileFormat *JsonFileFormat

+ NullFields []string

+ Path string

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

+ type GcsProfile struct

+ Bucket string

+ ForceSendFields []string

+ NullFields []string

+ RootPath string

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

+ type JsonFileFormat struct

+ Compression string

+ ForceSendFields []string

+ NullFields []string

+ SchemaFileFormat string

+ func (s *JsonFileFormat) MarshalJSON() ([]byte, error)

+ type ListConnectionProfilesResponse struct

+ ConnectionProfiles []*ConnectionProfile

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ Unreachable []string

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

+ type ListLocationsResponse struct

+ ForceSendFields []string

+ Locations []*Location

+ NextPageToken string

+ NullFields []string

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

+ type ListOperationsResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ Operations []*Operation

+ func (s *ListOperationsResponse) MarshalJSON() ([]byte, error)

+ type ListPrivateConnectionsResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ PrivateConnections []*PrivateConnection

+ Unreachable []string

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

+ type ListRoutesResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ Routes []*Route

+ Unreachable []string

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

+ type ListStreamObjectsResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ StreamObjects []*StreamObject

+ func (s *ListStreamObjectsResponse) MarshalJSON() ([]byte, error)

+ type ListStreamsResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ Streams []*Stream

+ Unreachable []string

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

+ type Location struct

+ DisplayName string

+ ForceSendFields []string

+ Labels map[string]string

+ LocationId string

+ Metadata googleapi.RawMessage

+ Name string

+ NullFields []string

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

+ type LookupStreamObjectRequest struct

+ ForceSendFields []string

+ NullFields []string

+ SourceObjectIdentifier *SourceObjectIdentifier

+ func (s *LookupStreamObjectRequest) MarshalJSON() ([]byte, error)

+ type MysqlColumn struct

+ Collation string

+ Column string

+ DataType string

+ ForceSendFields []string

+ Length int64

+ NullFields []string

+ Nullable bool

+ OrdinalPosition int64

+ PrimaryKey bool

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

+ type MysqlDatabase struct

+ Database string

+ ForceSendFields []string

+ MysqlTables []*MysqlTable

+ NullFields []string

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

+ type MysqlObjectIdentifier struct

+ Database string

+ ForceSendFields []string

+ NullFields []string

+ Table string

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

+ type MysqlProfile struct

+ ForceSendFields []string

+ Hostname string

+ NullFields []string

+ Password string

+ Port int64

+ SslConfig *MysqlSslConfig

+ Username string

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

+ type MysqlRdbms struct

+ ForceSendFields []string

+ MysqlDatabases []*MysqlDatabase

+ NullFields []string

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

+ type MysqlSourceConfig struct

+ ExcludeObjects *MysqlRdbms

+ ForceSendFields []string

+ IncludeObjects *MysqlRdbms

+ NullFields []string

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

+ type MysqlSslConfig struct

+ CaCertificate string

+ CaCertificateSet bool

+ ClientCertificate string

+ ClientCertificateSet bool

+ ClientKey string

+ ClientKeySet bool

+ ForceSendFields []string

+ NullFields []string

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

+ type MysqlTable struct

+ ForceSendFields []string

+ MysqlColumns []*MysqlColumn

+ NullFields []string

+ Table string

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

+ type Operation struct

+ Done bool

+ Error *Status

+ ForceSendFields []string

+ Metadata googleapi.RawMessage

+ Name string

+ NullFields []string

+ Response googleapi.RawMessage

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

+ type OperationMetadata struct

+ ApiVersion string

+ CreateTime string

+ EndTime string

+ ForceSendFields []string

+ NullFields []string

+ RequestedCancellation bool

+ StatusMessage string

+ Target string

+ ValidationResult *ValidationResult

+ Verb string

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

+ type OracleColumn struct

+ Column string

+ DataType string

+ Encoding string

+ ForceSendFields []string

+ Length int64

+ NullFields []string

+ Nullable bool

+ OrdinalPosition int64

+ Precision int64

+ PrimaryKey bool

+ Scale int64

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

+ type OracleObjectIdentifier struct

+ ForceSendFields []string

+ NullFields []string

+ Schema string

+ Table string

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

+ type OracleProfile struct

+ ConnectionAttributes map[string]string

+ DatabaseService string

+ ForceSendFields []string

+ Hostname string

+ NullFields []string

+ Password string

+ Port int64

+ Username string

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

+ type OracleRdbms struct

+ ForceSendFields []string

+ NullFields []string

+ OracleSchemas []*OracleSchema

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

+ type OracleSchema struct

+ ForceSendFields []string

+ NullFields []string

+ OracleTables []*OracleTable

+ Schema string

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

+ type OracleSourceConfig struct

+ ExcludeObjects *OracleRdbms

+ ForceSendFields []string

+ IncludeObjects *OracleRdbms

+ NullFields []string

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

+ type OracleTable struct

+ ForceSendFields []string

+ NullFields []string

+ OracleColumns []*OracleColumn

+ Table string

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

+ type PrivateConnection struct

+ CreateTime string

+ DisplayName string

+ Error *Error

+ ForceSendFields []string

+ Labels map[string]string

+ Name string

+ NullFields []string

+ State string

+ UpdateTime string

+ VpcPeeringConfig *VpcPeeringConfig

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

+ type PrivateConnectivity struct

+ ForceSendFields []string

+ NullFields []string

+ PrivateConnection string

+ func (s *PrivateConnectivity) MarshalJSON() ([]byte, error)

+ type ProjectsLocationsConnectionProfilesCreateCall struct

+ func (c *ProjectsLocationsConnectionProfilesCreateCall) ConnectionProfileId(connectionProfileId string) *ProjectsLocationsConnectionProfilesCreateCall

+ func (c *ProjectsLocationsConnectionProfilesCreateCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesCreateCall

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

+ func (c *ProjectsLocationsConnectionProfilesCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesCreateCall

+ func (c *ProjectsLocationsConnectionProfilesCreateCall) Force(force bool) *ProjectsLocationsConnectionProfilesCreateCall

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

+ func (c *ProjectsLocationsConnectionProfilesCreateCall) RequestId(requestId string) *ProjectsLocationsConnectionProfilesCreateCall

+ type ProjectsLocationsConnectionProfilesDeleteCall struct

+ func (c *ProjectsLocationsConnectionProfilesDeleteCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesDeleteCall

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

+ func (c *ProjectsLocationsConnectionProfilesDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesDeleteCall

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

+ func (c *ProjectsLocationsConnectionProfilesDeleteCall) RequestId(requestId string) *ProjectsLocationsConnectionProfilesDeleteCall

+ type ProjectsLocationsConnectionProfilesDiscoverCall struct

+ func (c *ProjectsLocationsConnectionProfilesDiscoverCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesDiscoverCall

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

+ func (c *ProjectsLocationsConnectionProfilesDiscoverCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesDiscoverCall

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

+ type ProjectsLocationsConnectionProfilesGetCall struct

+ func (c *ProjectsLocationsConnectionProfilesGetCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesGetCall

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

+ func (c *ProjectsLocationsConnectionProfilesGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesGetCall

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

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

+ type ProjectsLocationsConnectionProfilesListCall struct

+ func (c *ProjectsLocationsConnectionProfilesListCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesListCall

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

+ func (c *ProjectsLocationsConnectionProfilesListCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesListCall

+ func (c *ProjectsLocationsConnectionProfilesListCall) Filter(filter string) *ProjectsLocationsConnectionProfilesListCall

+ func (c *ProjectsLocationsConnectionProfilesListCall) Header() http.Header

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

+ func (c *ProjectsLocationsConnectionProfilesListCall) OrderBy(orderBy string) *ProjectsLocationsConnectionProfilesListCall

+ func (c *ProjectsLocationsConnectionProfilesListCall) PageSize(pageSize int64) *ProjectsLocationsConnectionProfilesListCall

+ func (c *ProjectsLocationsConnectionProfilesListCall) PageToken(pageToken string) *ProjectsLocationsConnectionProfilesListCall

+ func (c *ProjectsLocationsConnectionProfilesListCall) Pages(ctx context.Context, f func(*ListConnectionProfilesResponse) error) error

+ type ProjectsLocationsConnectionProfilesPatchCall struct

+ func (c *ProjectsLocationsConnectionProfilesPatchCall) Context(ctx context.Context) *ProjectsLocationsConnectionProfilesPatchCall

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

+ func (c *ProjectsLocationsConnectionProfilesPatchCall) Fields(s ...googleapi.Field) *ProjectsLocationsConnectionProfilesPatchCall

+ func (c *ProjectsLocationsConnectionProfilesPatchCall) Force(force bool) *ProjectsLocationsConnectionProfilesPatchCall

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

+ func (c *ProjectsLocationsConnectionProfilesPatchCall) RequestId(requestId string) *ProjectsLocationsConnectionProfilesPatchCall

+ func (c *ProjectsLocationsConnectionProfilesPatchCall) UpdateMask(updateMask string) *ProjectsLocationsConnectionProfilesPatchCall

+ type ProjectsLocationsConnectionProfilesService struct

+ func NewProjectsLocationsConnectionProfilesService(s *Service) *ProjectsLocationsConnectionProfilesService

+ func (r *ProjectsLocationsConnectionProfilesService) Create(parent string, connectionprofile *ConnectionProfile) *ProjectsLocationsConnectionProfilesCreateCall

+ func (r *ProjectsLocationsConnectionProfilesService) Delete(name string) *ProjectsLocationsConnectionProfilesDeleteCall

+ func (r *ProjectsLocationsConnectionProfilesService) Discover(parent string, ...) *ProjectsLocationsConnectionProfilesDiscoverCall

+ func (r *ProjectsLocationsConnectionProfilesService) Get(name string) *ProjectsLocationsConnectionProfilesGetCall

+ func (r *ProjectsLocationsConnectionProfilesService) List(parent string) *ProjectsLocationsConnectionProfilesListCall

+ func (r *ProjectsLocationsConnectionProfilesService) Patch(name string, connectionprofile *ConnectionProfile) *ProjectsLocationsConnectionProfilesPatchCall

+ type ProjectsLocationsFetchStaticIpsCall struct

+ func (c *ProjectsLocationsFetchStaticIpsCall) Context(ctx context.Context) *ProjectsLocationsFetchStaticIpsCall

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

+ func (c *ProjectsLocationsFetchStaticIpsCall) Fields(s ...googleapi.Field) *ProjectsLocationsFetchStaticIpsCall

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

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

+ func (c *ProjectsLocationsFetchStaticIpsCall) PageSize(pageSize int64) *ProjectsLocationsFetchStaticIpsCall

+ func (c *ProjectsLocationsFetchStaticIpsCall) PageToken(pageToken string) *ProjectsLocationsFetchStaticIpsCall

+ func (c *ProjectsLocationsFetchStaticIpsCall) Pages(ctx context.Context, f func(*FetchStaticIpsResponse) error) error

+ type ProjectsLocationsGetCall struct

+ func (c *ProjectsLocationsGetCall) Context(ctx context.Context) *ProjectsLocationsGetCall

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

+ func (c *ProjectsLocationsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsGetCall

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

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

+ type ProjectsLocationsListCall struct

+ func (c *ProjectsLocationsListCall) Context(ctx context.Context) *ProjectsLocationsListCall

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

+ func (c *ProjectsLocationsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsListCall

+ func (c *ProjectsLocationsListCall) Filter(filter string) *ProjectsLocationsListCall

+ func (c *ProjectsLocationsListCall) Header() http.Header

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

+ func (c *ProjectsLocationsListCall) PageSize(pageSize int64) *ProjectsLocationsListCall

+ func (c *ProjectsLocationsListCall) PageToken(pageToken string) *ProjectsLocationsListCall

+ func (c *ProjectsLocationsListCall) Pages(ctx context.Context, f func(*ListLocationsResponse) error) error

+ type ProjectsLocationsOperationsCancelCall struct

+ func (c *ProjectsLocationsOperationsCancelCall) Context(ctx context.Context) *ProjectsLocationsOperationsCancelCall

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

+ func (c *ProjectsLocationsOperationsCancelCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsCancelCall

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

+ type ProjectsLocationsOperationsDeleteCall struct

+ func (c *ProjectsLocationsOperationsDeleteCall) Context(ctx context.Context) *ProjectsLocationsOperationsDeleteCall

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

+ func (c *ProjectsLocationsOperationsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsDeleteCall

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

+ type ProjectsLocationsOperationsGetCall struct

+ func (c *ProjectsLocationsOperationsGetCall) Context(ctx context.Context) *ProjectsLocationsOperationsGetCall

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

+ func (c *ProjectsLocationsOperationsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsGetCall

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

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

+ type ProjectsLocationsOperationsListCall struct

+ func (c *ProjectsLocationsOperationsListCall) Context(ctx context.Context) *ProjectsLocationsOperationsListCall

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

+ func (c *ProjectsLocationsOperationsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsListCall

+ func (c *ProjectsLocationsOperationsListCall) Filter(filter string) *ProjectsLocationsOperationsListCall

+ func (c *ProjectsLocationsOperationsListCall) Header() http.Header

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

+ func (c *ProjectsLocationsOperationsListCall) PageSize(pageSize int64) *ProjectsLocationsOperationsListCall

+ func (c *ProjectsLocationsOperationsListCall) PageToken(pageToken string) *ProjectsLocationsOperationsListCall

+ func (c *ProjectsLocationsOperationsListCall) Pages(ctx context.Context, f func(*ListOperationsResponse) error) error

+ type ProjectsLocationsOperationsService struct

+ func NewProjectsLocationsOperationsService(s *Service) *ProjectsLocationsOperationsService

+ func (r *ProjectsLocationsOperationsService) Cancel(name string, canceloperationrequest *CancelOperationRequest) *ProjectsLocationsOperationsCancelCall

+ func (r *ProjectsLocationsOperationsService) Delete(name string) *ProjectsLocationsOperationsDeleteCall

+ func (r *ProjectsLocationsOperationsService) Get(name string) *ProjectsLocationsOperationsGetCall

+ func (r *ProjectsLocationsOperationsService) List(name string) *ProjectsLocationsOperationsListCall

+ type ProjectsLocationsPrivateConnectionsCreateCall struct

+ func (c *ProjectsLocationsPrivateConnectionsCreateCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsCreateCall

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

+ func (c *ProjectsLocationsPrivateConnectionsCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsCreateCall

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

+ func (c *ProjectsLocationsPrivateConnectionsCreateCall) PrivateConnectionId(privateConnectionId string) *ProjectsLocationsPrivateConnectionsCreateCall

+ func (c *ProjectsLocationsPrivateConnectionsCreateCall) RequestId(requestId string) *ProjectsLocationsPrivateConnectionsCreateCall

+ type ProjectsLocationsPrivateConnectionsDeleteCall struct

+ func (c *ProjectsLocationsPrivateConnectionsDeleteCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsDeleteCall

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

+ func (c *ProjectsLocationsPrivateConnectionsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsDeleteCall

+ func (c *ProjectsLocationsPrivateConnectionsDeleteCall) Force(force bool) *ProjectsLocationsPrivateConnectionsDeleteCall

+ func (c *ProjectsLocationsPrivateConnectionsDeleteCall) Header() http.Header

+ func (c *ProjectsLocationsPrivateConnectionsDeleteCall) RequestId(requestId string) *ProjectsLocationsPrivateConnectionsDeleteCall

+ type ProjectsLocationsPrivateConnectionsGetCall struct

+ func (c *ProjectsLocationsPrivateConnectionsGetCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsGetCall

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

+ func (c *ProjectsLocationsPrivateConnectionsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsGetCall

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

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

+ type ProjectsLocationsPrivateConnectionsListCall struct

+ func (c *ProjectsLocationsPrivateConnectionsListCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsListCall

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

+ func (c *ProjectsLocationsPrivateConnectionsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsListCall

+ func (c *ProjectsLocationsPrivateConnectionsListCall) Filter(filter string) *ProjectsLocationsPrivateConnectionsListCall

+ func (c *ProjectsLocationsPrivateConnectionsListCall) Header() http.Header

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

+ func (c *ProjectsLocationsPrivateConnectionsListCall) OrderBy(orderBy string) *ProjectsLocationsPrivateConnectionsListCall

+ func (c *ProjectsLocationsPrivateConnectionsListCall) PageSize(pageSize int64) *ProjectsLocationsPrivateConnectionsListCall

+ func (c *ProjectsLocationsPrivateConnectionsListCall) PageToken(pageToken string) *ProjectsLocationsPrivateConnectionsListCall

+ func (c *ProjectsLocationsPrivateConnectionsListCall) Pages(ctx context.Context, f func(*ListPrivateConnectionsResponse) error) error

+ type ProjectsLocationsPrivateConnectionsRoutesCreateCall struct

+ func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsRoutesCreateCall

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

+ func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsRoutesCreateCall

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

+ func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) RequestId(requestId string) *ProjectsLocationsPrivateConnectionsRoutesCreateCall

+ func (c *ProjectsLocationsPrivateConnectionsRoutesCreateCall) RouteId(routeId string) *ProjectsLocationsPrivateConnectionsRoutesCreateCall

+ type ProjectsLocationsPrivateConnectionsRoutesDeleteCall struct

+ func (c *ProjectsLocationsPrivateConnectionsRoutesDeleteCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsRoutesDeleteCall

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

+ func (c *ProjectsLocationsPrivateConnectionsRoutesDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsRoutesDeleteCall

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

+ func (c *ProjectsLocationsPrivateConnectionsRoutesDeleteCall) RequestId(requestId string) *ProjectsLocationsPrivateConnectionsRoutesDeleteCall

+ type ProjectsLocationsPrivateConnectionsRoutesGetCall struct

+ func (c *ProjectsLocationsPrivateConnectionsRoutesGetCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsRoutesGetCall

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

+ func (c *ProjectsLocationsPrivateConnectionsRoutesGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsRoutesGetCall

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

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

+ type ProjectsLocationsPrivateConnectionsRoutesListCall struct

+ func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Context(ctx context.Context) *ProjectsLocationsPrivateConnectionsRoutesListCall

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

+ func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Fields(s ...googleapi.Field) *ProjectsLocationsPrivateConnectionsRoutesListCall

+ func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Filter(filter string) *ProjectsLocationsPrivateConnectionsRoutesListCall

+ func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Header() http.Header

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

+ func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) OrderBy(orderBy string) *ProjectsLocationsPrivateConnectionsRoutesListCall

+ func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) PageSize(pageSize int64) *ProjectsLocationsPrivateConnectionsRoutesListCall

+ func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) PageToken(pageToken string) *ProjectsLocationsPrivateConnectionsRoutesListCall

+ func (c *ProjectsLocationsPrivateConnectionsRoutesListCall) Pages(ctx context.Context, f func(*ListRoutesResponse) error) error

+ type ProjectsLocationsPrivateConnectionsRoutesService struct

+ func NewProjectsLocationsPrivateConnectionsRoutesService(s *Service) *ProjectsLocationsPrivateConnectionsRoutesService

+ func (r *ProjectsLocationsPrivateConnectionsRoutesService) Create(parent string, route *Route) *ProjectsLocationsPrivateConnectionsRoutesCreateCall

+ func (r *ProjectsLocationsPrivateConnectionsRoutesService) Delete(name string) *ProjectsLocationsPrivateConnectionsRoutesDeleteCall

+ func (r *ProjectsLocationsPrivateConnectionsRoutesService) Get(name string) *ProjectsLocationsPrivateConnectionsRoutesGetCall

+ func (r *ProjectsLocationsPrivateConnectionsRoutesService) List(parent string) *ProjectsLocationsPrivateConnectionsRoutesListCall

+ type ProjectsLocationsPrivateConnectionsService struct

+ Routes *ProjectsLocationsPrivateConnectionsRoutesService

+ func NewProjectsLocationsPrivateConnectionsService(s *Service) *ProjectsLocationsPrivateConnectionsService

+ func (r *ProjectsLocationsPrivateConnectionsService) Create(parent string, privateconnection *PrivateConnection) *ProjectsLocationsPrivateConnectionsCreateCall

+ func (r *ProjectsLocationsPrivateConnectionsService) Delete(name string) *ProjectsLocationsPrivateConnectionsDeleteCall

+ func (r *ProjectsLocationsPrivateConnectionsService) Get(name string) *ProjectsLocationsPrivateConnectionsGetCall

+ func (r *ProjectsLocationsPrivateConnectionsService) List(parent string) *ProjectsLocationsPrivateConnectionsListCall

+ type ProjectsLocationsService struct

+ ConnectionProfiles *ProjectsLocationsConnectionProfilesService

+ Operations *ProjectsLocationsOperationsService

+ PrivateConnections *ProjectsLocationsPrivateConnectionsService

+ Streams *ProjectsLocationsStreamsService

+ func NewProjectsLocationsService(s *Service) *ProjectsLocationsService

+ func (r *ProjectsLocationsService) FetchStaticIps(name string) *ProjectsLocationsFetchStaticIpsCall

+ func (r *ProjectsLocationsService) Get(name string) *ProjectsLocationsGetCall

+ func (r *ProjectsLocationsService) List(name string) *ProjectsLocationsListCall

+ type ProjectsLocationsStreamsCreateCall struct

+ func (c *ProjectsLocationsStreamsCreateCall) Context(ctx context.Context) *ProjectsLocationsStreamsCreateCall

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

+ func (c *ProjectsLocationsStreamsCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsCreateCall

+ func (c *ProjectsLocationsStreamsCreateCall) Force(force bool) *ProjectsLocationsStreamsCreateCall

+ func (c *ProjectsLocationsStreamsCreateCall) Header() http.Header

+ func (c *ProjectsLocationsStreamsCreateCall) RequestId(requestId string) *ProjectsLocationsStreamsCreateCall

+ func (c *ProjectsLocationsStreamsCreateCall) StreamId(streamId string) *ProjectsLocationsStreamsCreateCall

+ func (c *ProjectsLocationsStreamsCreateCall) ValidateOnly(validateOnly bool) *ProjectsLocationsStreamsCreateCall

+ type ProjectsLocationsStreamsDeleteCall struct

+ func (c *ProjectsLocationsStreamsDeleteCall) Context(ctx context.Context) *ProjectsLocationsStreamsDeleteCall

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

+ func (c *ProjectsLocationsStreamsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsDeleteCall

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

+ func (c *ProjectsLocationsStreamsDeleteCall) RequestId(requestId string) *ProjectsLocationsStreamsDeleteCall

+ type ProjectsLocationsStreamsGetCall struct

+ func (c *ProjectsLocationsStreamsGetCall) Context(ctx context.Context) *ProjectsLocationsStreamsGetCall

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

+ func (c *ProjectsLocationsStreamsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsGetCall

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

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

+ type ProjectsLocationsStreamsListCall struct

+ func (c *ProjectsLocationsStreamsListCall) Context(ctx context.Context) *ProjectsLocationsStreamsListCall

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

+ func (c *ProjectsLocationsStreamsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsListCall

+ func (c *ProjectsLocationsStreamsListCall) Filter(filter string) *ProjectsLocationsStreamsListCall

+ func (c *ProjectsLocationsStreamsListCall) Header() http.Header

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

+ func (c *ProjectsLocationsStreamsListCall) OrderBy(orderBy string) *ProjectsLocationsStreamsListCall

+ func (c *ProjectsLocationsStreamsListCall) PageSize(pageSize int64) *ProjectsLocationsStreamsListCall

+ func (c *ProjectsLocationsStreamsListCall) PageToken(pageToken string) *ProjectsLocationsStreamsListCall

+ func (c *ProjectsLocationsStreamsListCall) Pages(ctx context.Context, f func(*ListStreamsResponse) error) error

+ type ProjectsLocationsStreamsObjectsGetCall struct

+ func (c *ProjectsLocationsStreamsObjectsGetCall) Context(ctx context.Context) *ProjectsLocationsStreamsObjectsGetCall

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

+ func (c *ProjectsLocationsStreamsObjectsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsObjectsGetCall

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

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

+ type ProjectsLocationsStreamsObjectsListCall struct

+ func (c *ProjectsLocationsStreamsObjectsListCall) Context(ctx context.Context) *ProjectsLocationsStreamsObjectsListCall

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

+ func (c *ProjectsLocationsStreamsObjectsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsObjectsListCall

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

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

+ func (c *ProjectsLocationsStreamsObjectsListCall) PageSize(pageSize int64) *ProjectsLocationsStreamsObjectsListCall

+ func (c *ProjectsLocationsStreamsObjectsListCall) PageToken(pageToken string) *ProjectsLocationsStreamsObjectsListCall

+ func (c *ProjectsLocationsStreamsObjectsListCall) Pages(ctx context.Context, f func(*ListStreamObjectsResponse) error) error

+ type ProjectsLocationsStreamsObjectsLookupCall struct

+ func (c *ProjectsLocationsStreamsObjectsLookupCall) Context(ctx context.Context) *ProjectsLocationsStreamsObjectsLookupCall

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

+ func (c *ProjectsLocationsStreamsObjectsLookupCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsObjectsLookupCall

+ func (c *ProjectsLocationsStreamsObjectsLookupCall) Header() http.Header

+ type ProjectsLocationsStreamsObjectsService struct

+ func NewProjectsLocationsStreamsObjectsService(s *Service) *ProjectsLocationsStreamsObjectsService

+ func (r *ProjectsLocationsStreamsObjectsService) Get(name string) *ProjectsLocationsStreamsObjectsGetCall

+ func (r *ProjectsLocationsStreamsObjectsService) List(parent string) *ProjectsLocationsStreamsObjectsListCall

+ func (r *ProjectsLocationsStreamsObjectsService) Lookup(parent string, lookupstreamobjectrequest *LookupStreamObjectRequest) *ProjectsLocationsStreamsObjectsLookupCall

+ func (r *ProjectsLocationsStreamsObjectsService) StartBackfillJob(object string, startbackfilljobrequest *StartBackfillJobRequest) *ProjectsLocationsStreamsObjectsStartBackfillJobCall

+ func (r *ProjectsLocationsStreamsObjectsService) StopBackfillJob(object string, stopbackfilljobrequest *StopBackfillJobRequest) *ProjectsLocationsStreamsObjectsStopBackfillJobCall

+ type ProjectsLocationsStreamsObjectsStartBackfillJobCall struct

+ func (c *ProjectsLocationsStreamsObjectsStartBackfillJobCall) Context(ctx context.Context) *ProjectsLocationsStreamsObjectsStartBackfillJobCall

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

+ func (c *ProjectsLocationsStreamsObjectsStartBackfillJobCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsObjectsStartBackfillJobCall

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

+ type ProjectsLocationsStreamsObjectsStopBackfillJobCall struct

+ func (c *ProjectsLocationsStreamsObjectsStopBackfillJobCall) Context(ctx context.Context) *ProjectsLocationsStreamsObjectsStopBackfillJobCall

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

+ func (c *ProjectsLocationsStreamsObjectsStopBackfillJobCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsObjectsStopBackfillJobCall

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

+ type ProjectsLocationsStreamsPatchCall struct

+ func (c *ProjectsLocationsStreamsPatchCall) Context(ctx context.Context) *ProjectsLocationsStreamsPatchCall

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

+ func (c *ProjectsLocationsStreamsPatchCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsPatchCall

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

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

+ func (c *ProjectsLocationsStreamsPatchCall) RequestId(requestId string) *ProjectsLocationsStreamsPatchCall

+ func (c *ProjectsLocationsStreamsPatchCall) UpdateMask(updateMask string) *ProjectsLocationsStreamsPatchCall

+ func (c *ProjectsLocationsStreamsPatchCall) ValidateOnly(validateOnly bool) *ProjectsLocationsStreamsPatchCall

+ type ProjectsLocationsStreamsService struct

+ Objects *ProjectsLocationsStreamsObjectsService

+ func NewProjectsLocationsStreamsService(s *Service) *ProjectsLocationsStreamsService

+ func (r *ProjectsLocationsStreamsService) Create(parent string, stream *Stream) *ProjectsLocationsStreamsCreateCall

+ func (r *ProjectsLocationsStreamsService) Delete(name string) *ProjectsLocationsStreamsDeleteCall

+ func (r *ProjectsLocationsStreamsService) Get(name string) *ProjectsLocationsStreamsGetCall

+ func (r *ProjectsLocationsStreamsService) List(parent string) *ProjectsLocationsStreamsListCall

+ func (r *ProjectsLocationsStreamsService) Patch(name string, stream *Stream) *ProjectsLocationsStreamsPatchCall

+ type ProjectsService struct

+ Locations *ProjectsLocationsService

+ func NewProjectsService(s *Service) *ProjectsService

+ type Route struct

+ CreateTime string

+ DestinationAddress string

+ DestinationPort int64

+ DisplayName string

+ ForceSendFields []string

+ Labels map[string]string

+ Name string

+ NullFields []string

+ UpdateTime string

+ func (s *Route) MarshalJSON() ([]byte, error)

+ type Service struct

+ BasePath string

+ Projects *ProjectsService

+ UserAgent string

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

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

+ type SourceConfig struct

+ ForceSendFields []string

+ MysqlSourceConfig *MysqlSourceConfig

+ NullFields []string

+ OracleSourceConfig *OracleSourceConfig

+ SourceConnectionProfile string

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

+ type SourceObjectIdentifier struct

+ ForceSendFields []string

+ MysqlIdentifier *MysqlObjectIdentifier

+ NullFields []string

+ OracleIdentifier *OracleObjectIdentifier

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

+ type StartBackfillJobRequest struct

+ type StartBackfillJobResponse struct

+ ForceSendFields []string

+ NullFields []string

+ Object *StreamObject

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

+ type StaticServiceIpConnectivity struct

+ type Status struct

+ Code int64

+ Details []googleapi.RawMessage

+ ForceSendFields []string

+ Message string

+ NullFields []string

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

+ type StopBackfillJobRequest struct

+ type StopBackfillJobResponse struct

+ ForceSendFields []string

+ NullFields []string

+ Object *StreamObject

+ func (s *StopBackfillJobResponse) MarshalJSON() ([]byte, error)

+ type Stream struct

+ BackfillAll *BackfillAllStrategy

+ BackfillNone *BackfillNoneStrategy

+ CreateTime string

+ CustomerManagedEncryptionKey string

+ DestinationConfig *DestinationConfig

+ DisplayName string

+ Errors []*Error

+ ForceSendFields []string

+ Labels map[string]string

+ Name string

+ NullFields []string

+ SourceConfig *SourceConfig

+ State string

+ UpdateTime string

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

+ type StreamObject struct

+ BackfillJob *BackfillJob

+ CreateTime string

+ DisplayName string

+ Errors []*Error

+ ForceSendFields []string

+ Name string

+ NullFields []string

+ SourceObject *SourceObjectIdentifier

+ UpdateTime string

+ func (s *StreamObject) MarshalJSON() ([]byte, error)

+ type Validation struct

+ Code string

+ Description string

+ ForceSendFields []string

+ Message []*ValidationMessage

+ NullFields []string

+ State string

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

+ type ValidationMessage struct

+ Code string

+ ForceSendFields []string

+ Level string

+ Message string

+ Metadata map[string]string

+ NullFields []string

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

+ type ValidationResult struct

+ ForceSendFields []string

+ NullFields []string

+ Validations []*Validation

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

+ type VpcPeeringConfig struct

+ ForceSendFields []string

+ NullFields []string

+ Subnet string

+ Vpc string

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