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 + 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 + NoConnectivity *NoConnectivitySettings + NullFields []string + OracleProfile *OracleProfile + PrivateConnectivity *PrivateConnectivity + StaticServiceIpConnectivity *StaticServiceIpConnectivity + UpdateTime string + func (s *ConnectionProfile) MarshalJSON() ([]byte, error) + type DestinationConfig struct + DestinationConnectionProfileName string + ForceSendFields []string + GcsDestinationConfig *GcsDestinationConfig + NullFields []string + func (s *DestinationConfig) MarshalJSON() ([]byte, error) + type DiscoverConnectionProfileRequest struct + ConnectionProfile *ConnectionProfile + ConnectionProfileName string + ForceSendFields []string + MysqlRdbms *MysqlRdbms + NullFields []string + OracleRdbms *OracleRdbms + RecursionDepth int64 + Recursive bool + func (s *DiscoverConnectionProfileRequest) MarshalJSON() ([]byte, error) + type DiscoverConnectionProfileResponse struct + ForceSendFields []string + MysqlRdbms *MysqlRdbms + NullFields []string + OracleRdbms *OracleRdbms + 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 FetchErrorsRequest struct + type FetchErrorsResponse struct + Errors []*Error + ForceSendFields []string + NullFields []string + func (s *FetchErrorsResponse) 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 + GcsFileFormat string + JsonFileFormat *JsonFileFormat + NullFields []string + Path string + func (s *GcsDestinationConfig) MarshalJSON() ([]byte, error) + type GcsProfile struct + BucketName 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 MysqlColumn struct + Collation string + ColumnName string + DataType string + ForceSendFields []string + Length int64 + NullFields []string + Nullable bool + OrdinalPosition int64 + PrimaryKey bool + func (s *MysqlColumn) MarshalJSON() ([]byte, error) + type MysqlDatabase struct + DatabaseName 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 + Allowlist *MysqlRdbms + ForceSendFields []string + NullFields []string + Rejectlist *MysqlRdbms + 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 + TableName string + func (s *MysqlTable) MarshalJSON() ([]byte, error) + type NoConnectivitySettings 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 + ColumnName 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 + SchemaName string + func (s *OracleSchema) MarshalJSON() ([]byte, error) + type OracleSourceConfig struct + Allowlist *OracleRdbms + DropLargeObjects *DropLargeObjects + ForceSendFields []string + NullFields []string + Rejectlist *OracleRdbms + func (s *OracleSourceConfig) MarshalJSON() ([]byte, error) + type OracleTable struct + ForceSendFields []string + NullFields []string + OracleColumns []*OracleColumn + TableName 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 + PrivateConnectionName 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) 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) 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) 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 ProjectsLocationsStreamsFetchErrorsCall struct + func (c *ProjectsLocationsStreamsFetchErrorsCall) Context(ctx context.Context) *ProjectsLocationsStreamsFetchErrorsCall + func (c *ProjectsLocationsStreamsFetchErrorsCall) Do(opts ...googleapi.CallOption) (*Operation, error) + func (c *ProjectsLocationsStreamsFetchErrorsCall) Fields(s ...googleapi.Field) *ProjectsLocationsStreamsFetchErrorsCall + func (c *ProjectsLocationsStreamsFetchErrorsCall) Header() http.Header + 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 ProjectsLocationsStreamsObjectsService struct + func NewProjectsLocationsStreamsObjectsService(s *Service) *ProjectsLocationsStreamsObjectsService + func (r *ProjectsLocationsStreamsObjectsService) Get(name string) *ProjectsLocationsStreamsObjectsGetCall + func (r *ProjectsLocationsStreamsObjectsService) List(parent string) *ProjectsLocationsStreamsObjectsListCall + func (r *ProjectsLocationsStreamsObjectsService) StartBackfillJob(object string) *ProjectsLocationsStreamsObjectsStartBackfillJobCall + func (r *ProjectsLocationsStreamsObjectsService) StopBackfillJob(object string) *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) FetchErrors(stream string, fetcherrorsrequest *FetchErrorsRequest) *ProjectsLocationsStreamsFetchErrorsCall + 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 + SourceConnectionProfileName 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 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 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 + Status 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 + VpcName string + func (s *VpcPeeringConfig) MarshalJSON() ([]byte, error)
Go to main page