Versions in this module Expand all Collapse all v0 v0.0.1 Dec 7, 2023 Changes in this version + const CloudPlatformScope + type AvroFileFormat struct + type BackfillAllStrategy struct + ForceSendFields []string + MysqlExcludedObjects *MysqlRdbms + NullFields []string + OracleExcludedObjects *OracleRdbms + PostgresqlExcludedObjects *PostgresqlRdbms + 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 BigQueryDestinationConfig struct + DataFreshness string + ForceSendFields []string + NullFields []string + SingleTargetDataset *SingleTargetDataset + SourceHierarchyDatasets *SourceHierarchyDatasets + func (s *BigQueryDestinationConfig) MarshalJSON() ([]byte, error) + type BigQueryProfile struct + type CancelOperationRequest struct + type CdcStrategy struct + ForceSendFields []string + MostRecentStartPosition *MostRecentStartPosition + NextAvailableStartPosition *NextAvailableStartPosition + NullFields []string + SpecificStartPosition *SpecificStartPosition + func (s *CdcStrategy) MarshalJSON() ([]byte, error) + type ConnectionProfile struct + BigqueryProfile *BigQueryProfile + CreateTime string + DisplayName string + ForceSendFields []string + ForwardSshConnectivity *ForwardSshTunnelConnectivity + GcsProfile *GcsProfile + Labels map[string]string + MysqlProfile *MysqlProfile + Name string + NullFields []string + OracleProfile *OracleProfile + PostgresqlProfile *PostgresqlProfile + PrivateConnectivity *PrivateConnectivity + StaticServiceIpConnectivity *StaticServiceIpConnectivity + UpdateTime string + func (s *ConnectionProfile) MarshalJSON() ([]byte, error) + type DatasetTemplate struct + DatasetIdPrefix string + ForceSendFields []string + KmsKeyName string + Location string + NullFields []string + func (s *DatasetTemplate) MarshalJSON() ([]byte, error) + type DestinationConfig struct + BigqueryDestinationConfig *BigQueryDestinationConfig + 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 + PostgresqlRdbms *PostgresqlRdbms + func (s *DiscoverConnectionProfileRequest) MarshalJSON() ([]byte, error) + type DiscoverConnectionProfileResponse struct + ForceSendFields []string + MysqlRdbms *MysqlRdbms + NullFields []string + OracleRdbms *OracleRdbms + PostgresqlRdbms *PostgresqlRdbms + func (s *DiscoverConnectionProfileResponse) MarshalJSON() ([]byte, error) + type DropLargeObjects struct + 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 MostRecentStartPosition struct + type MysqlColumn struct + Collation string + Column string + DataType string + ForceSendFields []string + Length int64 + NullFields []string + Nullable bool + OrdinalPosition int64 + Precision int64 + PrimaryKey bool + Scale int64 + func (s *MysqlColumn) MarshalJSON() ([]byte, error) + type MysqlDatabase struct + Database string + ForceSendFields []string + MysqlTables []*MysqlTable + NullFields []string + func (s *MysqlDatabase) MarshalJSON() ([]byte, error) + type MysqlLogPosition struct + ForceSendFields []string + LogFile string + LogPosition int64 + NullFields []string + func (s *MysqlLogPosition) 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 + MaxConcurrentBackfillTasks int64 + MaxConcurrentCdcTasks int64 + 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 NextAvailableStartPosition struct + 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 + OracleSslConfig *OracleSslConfig + 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 + DropLargeObjects *DropLargeObjects + ExcludeObjects *OracleRdbms + ForceSendFields []string + IncludeObjects *OracleRdbms + MaxConcurrentBackfillTasks int64 + MaxConcurrentCdcTasks int64 + NullFields []string + StreamLargeObjects *StreamLargeObjects + func (s *OracleSourceConfig) MarshalJSON() ([]byte, error) + type OracleSslConfig struct + CaCertificate string + CaCertificateSet bool + ForceSendFields []string + NullFields []string + func (s *OracleSslConfig) MarshalJSON() ([]byte, error) + type OracleTable struct + ForceSendFields []string + NullFields []string + OracleColumns []*OracleColumn + Table string + func (s *OracleTable) MarshalJSON() ([]byte, error) + 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 + MaxConcurrentBackfillTasks int64 + 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 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 + func (c *ProjectsLocationsConnectionProfilesCreateCall) ValidateOnly(validateOnly bool) *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 + func (c *ProjectsLocationsConnectionProfilesPatchCall) ValidateOnly(validateOnly bool) *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) Force(force bool) *ProjectsLocationsPrivateConnectionsCreateCall + func (c *ProjectsLocationsPrivateConnectionsCreateCall) Header() http.Header + func (c *ProjectsLocationsPrivateConnectionsCreateCall) PrivateConnectionId(privateConnectionId string) *ProjectsLocationsPrivateConnectionsCreateCall + func (c *ProjectsLocationsPrivateConnectionsCreateCall) RequestId(requestId string) *ProjectsLocationsPrivateConnectionsCreateCall + type ProjectsLocationsPrivateConnectionsDeleteCall 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 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 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 + func (r *ProjectsLocationsStreamsService) Run(name string, runstreamrequest *RunStreamRequest) *ProjectsLocationsStreamsRunCall + 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 RunStreamRequest struct + CdcStrategy *CdcStrategy + ForceSendFields []string + NullFields []string + func (s *RunStreamRequest) 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 SingleTargetDataset struct + DatasetId string + ForceSendFields []string + NullFields []string + func (s *SingleTargetDataset) MarshalJSON() ([]byte, error) + type SourceConfig struct + ForceSendFields []string + MysqlSourceConfig *MysqlSourceConfig + NullFields []string + OracleSourceConfig *OracleSourceConfig + PostgresqlSourceConfig *PostgresqlSourceConfig + SourceConnectionProfile string + func (s *SourceConfig) MarshalJSON() ([]byte, error) + type SourceHierarchyDatasets struct + DatasetTemplate *DatasetTemplate + ForceSendFields []string + NullFields []string + func (s *SourceHierarchyDatasets) MarshalJSON() ([]byte, error) + type SourceObjectIdentifier struct + ForceSendFields []string + MysqlIdentifier *MysqlObjectIdentifier + NullFields []string + OracleIdentifier *OracleObjectIdentifier + PostgresqlIdentifier *PostgresqlObjectIdentifier + func (s *SourceObjectIdentifier) MarshalJSON() ([]byte, error) + type SpecificStartPosition struct + ForceSendFields []string + MysqlLogPosition *MysqlLogPosition + NullFields []string + func (s *SpecificStartPosition) 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 + LastRecoveryTime string + Name string + NullFields []string + SourceConfig *SourceConfig + State string + UpdateTime string + func (s *Stream) MarshalJSON() ([]byte, error) + type StreamLargeObjects struct + 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)
Go to main page