Versions in this module Expand all Collapse all v2 v2.0.1 Sep 26, 2025 v2.0.0 Sep 25, 2025 Changes in this version + const CRDGroup + const CRDVersion + var AddToScheme = SchemeBuilder.AddToScheme + var CRDGroupVersion = schema.GroupVersion + var LiteReservation_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: LiteReservation_Kind}.String() + var LiteReservation_GroupVersionKind = CRDGroupVersion.WithKind(LiteReservation_Kind) + var LiteReservation_Kind = "LiteReservation" + var LiteReservation_KindAPIVersion = LiteReservation_Kind + "." + CRDGroupVersion.String() + var LiteSubscription_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: LiteSubscription_Kind}.String() + var LiteSubscription_GroupVersionKind = CRDGroupVersion.WithKind(LiteSubscription_Kind) + var LiteSubscription_Kind = "LiteSubscription" + var LiteSubscription_KindAPIVersion = LiteSubscription_Kind + "." + CRDGroupVersion.String() + var LiteTopic_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: LiteTopic_Kind}.String() + var LiteTopic_GroupVersionKind = CRDGroupVersion.WithKind(LiteTopic_Kind) + var LiteTopic_Kind = "LiteTopic" + var LiteTopic_KindAPIVersion = LiteTopic_Kind + "." + CRDGroupVersion.String() + var Schema_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: Schema_Kind}.String() + var Schema_GroupVersionKind = CRDGroupVersion.WithKind(Schema_Kind) + var Schema_Kind = "Schema" + var Schema_KindAPIVersion = Schema_Kind + "." + CRDGroupVersion.String() + var SchemeBuilder = &scheme.Builder + var SubscriptionIAMMember_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: SubscriptionIAMMember_Kind}.String() + var SubscriptionIAMMember_GroupVersionKind = CRDGroupVersion.WithKind(SubscriptionIAMMember_Kind) + var SubscriptionIAMMember_Kind = "SubscriptionIAMMember" + var SubscriptionIAMMember_KindAPIVersion = SubscriptionIAMMember_Kind + "." + CRDGroupVersion.String() + var Subscription_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: Subscription_Kind}.String() + var Subscription_GroupVersionKind = CRDGroupVersion.WithKind(Subscription_Kind) + var Subscription_Kind = "Subscription" + var Subscription_KindAPIVersion = Subscription_Kind + "." + CRDGroupVersion.String() + var TopicIAMMember_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: TopicIAMMember_Kind}.String() + var TopicIAMMember_GroupVersionKind = CRDGroupVersion.WithKind(TopicIAMMember_Kind) + var TopicIAMMember_Kind = "TopicIAMMember" + var TopicIAMMember_KindAPIVersion = TopicIAMMember_Kind + "." + CRDGroupVersion.String() + var Topic_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: Topic_Kind}.String() + var Topic_GroupVersionKind = CRDGroupVersion.WithKind(Topic_Kind) + var Topic_Kind = "Topic" + var Topic_KindAPIVersion = Topic_Kind + "." + CRDGroupVersion.String() + type AvroConfigInitParameters struct + UseTopicSchema *bool + WriteMetadata *bool + func (in *AvroConfigInitParameters) DeepCopy() *AvroConfigInitParameters + func (in *AvroConfigInitParameters) DeepCopyInto(out *AvroConfigInitParameters) + type AvroConfigObservation struct + UseTopicSchema *bool + WriteMetadata *bool + func (in *AvroConfigObservation) DeepCopy() *AvroConfigObservation + func (in *AvroConfigObservation) DeepCopyInto(out *AvroConfigObservation) + type AvroConfigParameters struct + UseTopicSchema *bool + WriteMetadata *bool + func (in *AvroConfigParameters) DeepCopy() *AvroConfigParameters + func (in *AvroConfigParameters) DeepCopyInto(out *AvroConfigParameters) + type AvroFormatInitParameters struct + func (in *AvroFormatInitParameters) DeepCopy() *AvroFormatInitParameters + func (in *AvroFormatInitParameters) DeepCopyInto(out *AvroFormatInitParameters) + type AvroFormatObservation struct + func (in *AvroFormatObservation) DeepCopy() *AvroFormatObservation + func (in *AvroFormatObservation) DeepCopyInto(out *AvroFormatObservation) + type AvroFormatParameters struct + func (in *AvroFormatParameters) DeepCopy() *AvroFormatParameters + func (in *AvroFormatParameters) DeepCopyInto(out *AvroFormatParameters) + type AwsKinesisInitParameters struct + AwsRoleArn *string + ConsumerArn *string + GCPServiceAccount *string + StreamArn *string + func (in *AwsKinesisInitParameters) DeepCopy() *AwsKinesisInitParameters + func (in *AwsKinesisInitParameters) DeepCopyInto(out *AwsKinesisInitParameters) + type AwsKinesisObservation struct + AwsRoleArn *string + ConsumerArn *string + GCPServiceAccount *string + StreamArn *string + func (in *AwsKinesisObservation) DeepCopy() *AwsKinesisObservation + func (in *AwsKinesisObservation) DeepCopyInto(out *AwsKinesisObservation) + type AwsKinesisParameters struct + AwsRoleArn *string + ConsumerArn *string + GCPServiceAccount *string + StreamArn *string + func (in *AwsKinesisParameters) DeepCopy() *AwsKinesisParameters + func (in *AwsKinesisParameters) DeepCopyInto(out *AwsKinesisParameters) + type AwsMskInitParameters struct + AwsRoleArn *string + ClusterArn *string + GCPServiceAccount *string + Topic *string + func (in *AwsMskInitParameters) DeepCopy() *AwsMskInitParameters + func (in *AwsMskInitParameters) DeepCopyInto(out *AwsMskInitParameters) + type AwsMskObservation struct + AwsRoleArn *string + ClusterArn *string + GCPServiceAccount *string + Topic *string + func (in *AwsMskObservation) DeepCopy() *AwsMskObservation + func (in *AwsMskObservation) DeepCopyInto(out *AwsMskObservation) + type AwsMskParameters struct + AwsRoleArn *string + ClusterArn *string + GCPServiceAccount *string + Topic *string + func (in *AwsMskParameters) DeepCopy() *AwsMskParameters + func (in *AwsMskParameters) DeepCopyInto(out *AwsMskParameters) + type AzureEventHubsInitParameters struct + ClientID *string + EventHub *string + GCPServiceAccount *string + Namespace *string + ResourceGroup *string + SubscriptionID *string + TenantID *string + func (in *AzureEventHubsInitParameters) DeepCopy() *AzureEventHubsInitParameters + func (in *AzureEventHubsInitParameters) DeepCopyInto(out *AzureEventHubsInitParameters) + type AzureEventHubsObservation struct + ClientID *string + EventHub *string + GCPServiceAccount *string + Namespace *string + ResourceGroup *string + SubscriptionID *string + TenantID *string + func (in *AzureEventHubsObservation) DeepCopy() *AzureEventHubsObservation + func (in *AzureEventHubsObservation) DeepCopyInto(out *AzureEventHubsObservation) + type AzureEventHubsParameters struct + ClientID *string + EventHub *string + GCPServiceAccount *string + Namespace *string + ResourceGroup *string + SubscriptionID *string + TenantID *string + func (in *AzureEventHubsParameters) DeepCopy() *AzureEventHubsParameters + func (in *AzureEventHubsParameters) DeepCopyInto(out *AzureEventHubsParameters) + type BigqueryConfigInitParameters struct + DropUnknownFields *bool + ServiceAccountEmail *string + ServiceAccountEmailRef *v1.NamespacedReference + ServiceAccountEmailSelector *v1.NamespacedSelector + Table *string + UseTableSchema *bool + UseTopicSchema *bool + WriteMetadata *bool + func (in *BigqueryConfigInitParameters) DeepCopy() *BigqueryConfigInitParameters + func (in *BigqueryConfigInitParameters) DeepCopyInto(out *BigqueryConfigInitParameters) + type BigqueryConfigObservation struct + DropUnknownFields *bool + ServiceAccountEmail *string + Table *string + UseTableSchema *bool + UseTopicSchema *bool + WriteMetadata *bool + func (in *BigqueryConfigObservation) DeepCopy() *BigqueryConfigObservation + func (in *BigqueryConfigObservation) DeepCopyInto(out *BigqueryConfigObservation) + type BigqueryConfigParameters struct + DropUnknownFields *bool + ServiceAccountEmail *string + ServiceAccountEmailRef *v1.NamespacedReference + ServiceAccountEmailSelector *v1.NamespacedSelector + Table *string + UseTableSchema *bool + UseTopicSchema *bool + WriteMetadata *bool + func (in *BigqueryConfigParameters) DeepCopy() *BigqueryConfigParameters + func (in *BigqueryConfigParameters) DeepCopyInto(out *BigqueryConfigParameters) + type CapacityInitParameters struct + PublishMibPerSec *float64 + SubscribeMibPerSec *float64 + func (in *CapacityInitParameters) DeepCopy() *CapacityInitParameters + func (in *CapacityInitParameters) DeepCopyInto(out *CapacityInitParameters) + type CapacityObservation struct + PublishMibPerSec *float64 + SubscribeMibPerSec *float64 + func (in *CapacityObservation) DeepCopy() *CapacityObservation + func (in *CapacityObservation) DeepCopyInto(out *CapacityObservation) + type CapacityParameters struct + PublishMibPerSec *float64 + SubscribeMibPerSec *float64 + func (in *CapacityParameters) DeepCopy() *CapacityParameters + func (in *CapacityParameters) DeepCopyInto(out *CapacityParameters) + type CloudStorageConfigInitParameters struct + AvroConfig *AvroConfigInitParameters + Bucket *string + FilenameDatetimeFormat *string + FilenamePrefix *string + FilenameSuffix *string + MaxBytes *float64 + MaxDuration *string + MaxMessages *float64 + ServiceAccountEmail *string + ServiceAccountEmailRef *v1.NamespacedReference + ServiceAccountEmailSelector *v1.NamespacedSelector + func (in *CloudStorageConfigInitParameters) DeepCopy() *CloudStorageConfigInitParameters + func (in *CloudStorageConfigInitParameters) DeepCopyInto(out *CloudStorageConfigInitParameters) + type CloudStorageConfigObservation struct + AvroConfig *AvroConfigObservation + Bucket *string + FilenameDatetimeFormat *string + FilenamePrefix *string + FilenameSuffix *string + MaxBytes *float64 + MaxDuration *string + MaxMessages *float64 + ServiceAccountEmail *string + State *string + func (in *CloudStorageConfigObservation) DeepCopy() *CloudStorageConfigObservation + func (in *CloudStorageConfigObservation) DeepCopyInto(out *CloudStorageConfigObservation) + type CloudStorageConfigParameters struct + AvroConfig *AvroConfigParameters + Bucket *string + FilenameDatetimeFormat *string + FilenamePrefix *string + FilenameSuffix *string + MaxBytes *float64 + MaxDuration *string + MaxMessages *float64 + ServiceAccountEmail *string + ServiceAccountEmailRef *v1.NamespacedReference + ServiceAccountEmailSelector *v1.NamespacedSelector + func (in *CloudStorageConfigParameters) DeepCopy() *CloudStorageConfigParameters + func (in *CloudStorageConfigParameters) DeepCopyInto(out *CloudStorageConfigParameters) + type CloudStorageInitParameters struct + AvroFormat *AvroFormatInitParameters + Bucket *string + MatchGlob *string + MinimumObjectCreateTime *string + PubsubAvroFormat *PubsubAvroFormatInitParameters + TextFormat *TextFormatInitParameters + func (in *CloudStorageInitParameters) DeepCopy() *CloudStorageInitParameters + func (in *CloudStorageInitParameters) DeepCopyInto(out *CloudStorageInitParameters) + type CloudStorageObservation struct + AvroFormat *AvroFormatParameters + Bucket *string + MatchGlob *string + MinimumObjectCreateTime *string + PubsubAvroFormat *PubsubAvroFormatParameters + TextFormat *TextFormatObservation + func (in *CloudStorageObservation) DeepCopy() *CloudStorageObservation + func (in *CloudStorageObservation) DeepCopyInto(out *CloudStorageObservation) + type CloudStorageParameters struct + AvroFormat *AvroFormatParameters + Bucket *string + MatchGlob *string + MinimumObjectCreateTime *string + PubsubAvroFormat *PubsubAvroFormatParameters + TextFormat *TextFormatParameters + func (in *CloudStorageParameters) DeepCopy() *CloudStorageParameters + func (in *CloudStorageParameters) DeepCopyInto(out *CloudStorageParameters) + type ConditionInitParameters struct + Description *string + Expression *string + Title *string + func (in *ConditionInitParameters) DeepCopy() *ConditionInitParameters + func (in *ConditionInitParameters) DeepCopyInto(out *ConditionInitParameters) + type ConditionObservation struct + Description *string + Expression *string + Title *string + func (in *ConditionObservation) DeepCopy() *ConditionObservation + func (in *ConditionObservation) DeepCopyInto(out *ConditionObservation) + type ConditionParameters struct + Description *string + Expression *string + Title *string + func (in *ConditionParameters) DeepCopy() *ConditionParameters + func (in *ConditionParameters) DeepCopyInto(out *ConditionParameters) + type ConfluentCloudInitParameters struct + BootstrapServer *string + ClusterID *string + GCPServiceAccount *string + IdentityPoolID *string + Topic *string + func (in *ConfluentCloudInitParameters) DeepCopy() *ConfluentCloudInitParameters + func (in *ConfluentCloudInitParameters) DeepCopyInto(out *ConfluentCloudInitParameters) + type ConfluentCloudObservation struct + BootstrapServer *string + ClusterID *string + GCPServiceAccount *string + IdentityPoolID *string + Topic *string + func (in *ConfluentCloudObservation) DeepCopy() *ConfluentCloudObservation + func (in *ConfluentCloudObservation) DeepCopyInto(out *ConfluentCloudObservation) + type ConfluentCloudParameters struct + BootstrapServer *string + ClusterID *string + GCPServiceAccount *string + IdentityPoolID *string + Topic *string + func (in *ConfluentCloudParameters) DeepCopy() *ConfluentCloudParameters + func (in *ConfluentCloudParameters) DeepCopyInto(out *ConfluentCloudParameters) + type DeadLetterPolicyInitParameters struct + DeadLetterTopic *string + DeadLetterTopicRef *v1.NamespacedReference + DeadLetterTopicSelector *v1.NamespacedSelector + MaxDeliveryAttempts *float64 + func (in *DeadLetterPolicyInitParameters) DeepCopy() *DeadLetterPolicyInitParameters + func (in *DeadLetterPolicyInitParameters) DeepCopyInto(out *DeadLetterPolicyInitParameters) + type DeadLetterPolicyObservation struct + DeadLetterTopic *string + MaxDeliveryAttempts *float64 + func (in *DeadLetterPolicyObservation) DeepCopy() *DeadLetterPolicyObservation + func (in *DeadLetterPolicyObservation) DeepCopyInto(out *DeadLetterPolicyObservation) + type DeadLetterPolicyParameters struct + DeadLetterTopic *string + DeadLetterTopicRef *v1.NamespacedReference + DeadLetterTopicSelector *v1.NamespacedSelector + MaxDeliveryAttempts *float64 + func (in *DeadLetterPolicyParameters) DeepCopy() *DeadLetterPolicyParameters + func (in *DeadLetterPolicyParameters) DeepCopyInto(out *DeadLetterPolicyParameters) + type DeliveryConfigInitParameters struct + DeliveryRequirement *string + func (in *DeliveryConfigInitParameters) DeepCopy() *DeliveryConfigInitParameters + func (in *DeliveryConfigInitParameters) DeepCopyInto(out *DeliveryConfigInitParameters) + type DeliveryConfigObservation struct + DeliveryRequirement *string + func (in *DeliveryConfigObservation) DeepCopy() *DeliveryConfigObservation + func (in *DeliveryConfigObservation) DeepCopyInto(out *DeliveryConfigObservation) + type DeliveryConfigParameters struct + DeliveryRequirement *string + func (in *DeliveryConfigParameters) DeepCopy() *DeliveryConfigParameters + func (in *DeliveryConfigParameters) DeepCopyInto(out *DeliveryConfigParameters) + type ExpirationPolicyInitParameters struct + TTL *string + func (in *ExpirationPolicyInitParameters) DeepCopy() *ExpirationPolicyInitParameters + func (in *ExpirationPolicyInitParameters) DeepCopyInto(out *ExpirationPolicyInitParameters) + type ExpirationPolicyObservation struct + TTL *string + func (in *ExpirationPolicyObservation) DeepCopy() *ExpirationPolicyObservation + func (in *ExpirationPolicyObservation) DeepCopyInto(out *ExpirationPolicyObservation) + type ExpirationPolicyParameters struct + TTL *string + func (in *ExpirationPolicyParameters) DeepCopy() *ExpirationPolicyParameters + func (in *ExpirationPolicyParameters) DeepCopyInto(out *ExpirationPolicyParameters) + type IngestionDataSourceSettingsInitParameters struct + AwsKinesis *AwsKinesisInitParameters + AwsMsk *AwsMskInitParameters + AzureEventHubs *AzureEventHubsInitParameters + CloudStorage *CloudStorageInitParameters + ConfluentCloud *ConfluentCloudInitParameters + PlatformLogsSettings *PlatformLogsSettingsInitParameters + func (in *IngestionDataSourceSettingsInitParameters) DeepCopy() *IngestionDataSourceSettingsInitParameters + func (in *IngestionDataSourceSettingsInitParameters) DeepCopyInto(out *IngestionDataSourceSettingsInitParameters) + type IngestionDataSourceSettingsObservation struct + AwsKinesis *AwsKinesisObservation + AwsMsk *AwsMskObservation + AzureEventHubs *AzureEventHubsObservation + CloudStorage *CloudStorageObservation + ConfluentCloud *ConfluentCloudObservation + PlatformLogsSettings *PlatformLogsSettingsObservation + func (in *IngestionDataSourceSettingsObservation) DeepCopy() *IngestionDataSourceSettingsObservation + func (in *IngestionDataSourceSettingsObservation) DeepCopyInto(out *IngestionDataSourceSettingsObservation) + type IngestionDataSourceSettingsParameters struct + AwsKinesis *AwsKinesisParameters + AwsMsk *AwsMskParameters + AzureEventHubs *AzureEventHubsParameters + CloudStorage *CloudStorageParameters + ConfluentCloud *ConfluentCloudParameters + PlatformLogsSettings *PlatformLogsSettingsParameters + func (in *IngestionDataSourceSettingsParameters) DeepCopy() *IngestionDataSourceSettingsParameters + func (in *IngestionDataSourceSettingsParameters) DeepCopyInto(out *IngestionDataSourceSettingsParameters) + type JavascriptUdfInitParameters struct + Code *string + FunctionName *string + func (in *JavascriptUdfInitParameters) DeepCopy() *JavascriptUdfInitParameters + func (in *JavascriptUdfInitParameters) DeepCopyInto(out *JavascriptUdfInitParameters) + type JavascriptUdfObservation struct + Code *string + FunctionName *string + func (in *JavascriptUdfObservation) DeepCopy() *JavascriptUdfObservation + func (in *JavascriptUdfObservation) DeepCopyInto(out *JavascriptUdfObservation) + type JavascriptUdfParameters struct + Code *string + FunctionName *string + func (in *JavascriptUdfParameters) DeepCopy() *JavascriptUdfParameters + func (in *JavascriptUdfParameters) DeepCopyInto(out *JavascriptUdfParameters) + type LiteReservation struct + Spec LiteReservationSpec + Status LiteReservationStatus + func (in *LiteReservation) DeepCopy() *LiteReservation + func (in *LiteReservation) DeepCopyInto(out *LiteReservation) + func (in *LiteReservation) DeepCopyObject() runtime.Object + func (mg *LiteReservation) GetCondition(ct xpv1.ConditionType) xpv1.Condition + func (mg *LiteReservation) GetManagementPolicies() xpv1.ManagementPolicies + func (mg *LiteReservation) GetProviderConfigReference() *xpv1.ProviderConfigReference + func (mg *LiteReservation) GetTerraformResourceType() string + func (mg *LiteReservation) GetWriteConnectionSecretToReference() *xpv1.LocalSecretReference + func (mg *LiteReservation) SetConditions(c ...xpv1.Condition) + func (mg *LiteReservation) SetManagementPolicies(r xpv1.ManagementPolicies) + func (mg *LiteReservation) SetProviderConfigReference(r *xpv1.ProviderConfigReference) + func (mg *LiteReservation) SetWriteConnectionSecretToReference(r *xpv1.LocalSecretReference) + func (tr *LiteReservation) GetConnectionDetailsMapping() map[string]string + func (tr *LiteReservation) GetID() string + func (tr *LiteReservation) GetInitParameters() (map[string]any, error) + func (tr *LiteReservation) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error) + func (tr *LiteReservation) GetObservation() (map[string]any, error) + func (tr *LiteReservation) GetParameters() (map[string]any, error) + func (tr *LiteReservation) GetTerraformSchemaVersion() int + func (tr *LiteReservation) Hub() + func (tr *LiteReservation) LateInitialize(attrs []byte) (bool, error) + func (tr *LiteReservation) SetObservation(obs map[string]any) error + func (tr *LiteReservation) SetParameters(params map[string]any) error + type LiteReservationInitParameters struct + Project *string + ThroughputCapacity *float64 + func (in *LiteReservationInitParameters) DeepCopy() *LiteReservationInitParameters + func (in *LiteReservationInitParameters) DeepCopyInto(out *LiteReservationInitParameters) + type LiteReservationList struct + Items []LiteReservation + func (in *LiteReservationList) DeepCopy() *LiteReservationList + func (in *LiteReservationList) DeepCopyInto(out *LiteReservationList) + func (in *LiteReservationList) DeepCopyObject() runtime.Object + func (l *LiteReservationList) GetItems() []resource.Managed + type LiteReservationObservation struct + ID *string + Project *string + Region *string + ThroughputCapacity *float64 + func (in *LiteReservationObservation) DeepCopy() *LiteReservationObservation + func (in *LiteReservationObservation) DeepCopyInto(out *LiteReservationObservation) + type LiteReservationParameters struct + Project *string + Region *string + ThroughputCapacity *float64 + func (in *LiteReservationParameters) DeepCopy() *LiteReservationParameters + func (in *LiteReservationParameters) DeepCopyInto(out *LiteReservationParameters) + type LiteReservationSpec struct + ForProvider LiteReservationParameters + InitProvider LiteReservationInitParameters + func (in *LiteReservationSpec) DeepCopy() *LiteReservationSpec + func (in *LiteReservationSpec) DeepCopyInto(out *LiteReservationSpec) + type LiteReservationStatus struct + AtProvider LiteReservationObservation + func (in *LiteReservationStatus) DeepCopy() *LiteReservationStatus + func (in *LiteReservationStatus) DeepCopyInto(out *LiteReservationStatus) + type LiteSubscription struct + Spec LiteSubscriptionSpec + Status LiteSubscriptionStatus + func (in *LiteSubscription) DeepCopy() *LiteSubscription + func (in *LiteSubscription) DeepCopyInto(out *LiteSubscription) + func (in *LiteSubscription) DeepCopyObject() runtime.Object + func (mg *LiteSubscription) GetCondition(ct xpv1.ConditionType) xpv1.Condition + func (mg *LiteSubscription) GetManagementPolicies() xpv1.ManagementPolicies + func (mg *LiteSubscription) GetProviderConfigReference() *xpv1.ProviderConfigReference + func (mg *LiteSubscription) GetTerraformResourceType() string + func (mg *LiteSubscription) GetWriteConnectionSecretToReference() *xpv1.LocalSecretReference + func (mg *LiteSubscription) ResolveReferences(ctx context.Context, c client.Reader) error + func (mg *LiteSubscription) SetConditions(c ...xpv1.Condition) + func (mg *LiteSubscription) SetManagementPolicies(r xpv1.ManagementPolicies) + func (mg *LiteSubscription) SetProviderConfigReference(r *xpv1.ProviderConfigReference) + func (mg *LiteSubscription) SetWriteConnectionSecretToReference(r *xpv1.LocalSecretReference) + func (tr *LiteSubscription) GetConnectionDetailsMapping() map[string]string + func (tr *LiteSubscription) GetID() string + func (tr *LiteSubscription) GetInitParameters() (map[string]any, error) + func (tr *LiteSubscription) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error) + func (tr *LiteSubscription) GetObservation() (map[string]any, error) + func (tr *LiteSubscription) GetParameters() (map[string]any, error) + func (tr *LiteSubscription) GetTerraformSchemaVersion() int + func (tr *LiteSubscription) Hub() + func (tr *LiteSubscription) LateInitialize(attrs []byte) (bool, error) + func (tr *LiteSubscription) SetObservation(obs map[string]any) error + func (tr *LiteSubscription) SetParameters(params map[string]any) error + type LiteSubscriptionInitParameters struct + DeliveryConfig *DeliveryConfigInitParameters + Project *string + Region *string + Topic *string + TopicRef *v1.NamespacedReference + TopicSelector *v1.NamespacedSelector + func (in *LiteSubscriptionInitParameters) DeepCopy() *LiteSubscriptionInitParameters + func (in *LiteSubscriptionInitParameters) DeepCopyInto(out *LiteSubscriptionInitParameters) + type LiteSubscriptionList struct + Items []LiteSubscription + func (in *LiteSubscriptionList) DeepCopy() *LiteSubscriptionList + func (in *LiteSubscriptionList) DeepCopyInto(out *LiteSubscriptionList) + func (in *LiteSubscriptionList) DeepCopyObject() runtime.Object + func (l *LiteSubscriptionList) GetItems() []resource.Managed + type LiteSubscriptionObservation struct + DeliveryConfig *DeliveryConfigObservation + ID *string + Project *string + Region *string + Topic *string + Zone *string + func (in *LiteSubscriptionObservation) DeepCopy() *LiteSubscriptionObservation + func (in *LiteSubscriptionObservation) DeepCopyInto(out *LiteSubscriptionObservation) + type LiteSubscriptionParameters struct + DeliveryConfig *DeliveryConfigParameters + Project *string + Region *string + Topic *string + TopicRef *v1.NamespacedReference + TopicSelector *v1.NamespacedSelector + Zone *string + func (in *LiteSubscriptionParameters) DeepCopy() *LiteSubscriptionParameters + func (in *LiteSubscriptionParameters) DeepCopyInto(out *LiteSubscriptionParameters) + type LiteSubscriptionSpec struct + ForProvider LiteSubscriptionParameters + InitProvider LiteSubscriptionInitParameters + func (in *LiteSubscriptionSpec) DeepCopy() *LiteSubscriptionSpec + func (in *LiteSubscriptionSpec) DeepCopyInto(out *LiteSubscriptionSpec) + type LiteSubscriptionStatus struct + AtProvider LiteSubscriptionObservation + func (in *LiteSubscriptionStatus) DeepCopy() *LiteSubscriptionStatus + func (in *LiteSubscriptionStatus) DeepCopyInto(out *LiteSubscriptionStatus) + type LiteTopic struct + Spec LiteTopicSpec + Status LiteTopicStatus + func (in *LiteTopic) DeepCopy() *LiteTopic + func (in *LiteTopic) DeepCopyInto(out *LiteTopic) + func (in *LiteTopic) DeepCopyObject() runtime.Object + func (mg *LiteTopic) GetCondition(ct xpv1.ConditionType) xpv1.Condition + func (mg *LiteTopic) GetManagementPolicies() xpv1.ManagementPolicies + func (mg *LiteTopic) GetProviderConfigReference() *xpv1.ProviderConfigReference + func (mg *LiteTopic) GetTerraformResourceType() string + func (mg *LiteTopic) GetWriteConnectionSecretToReference() *xpv1.LocalSecretReference + func (mg *LiteTopic) ResolveReferences(ctx context.Context, c client.Reader) error + func (mg *LiteTopic) SetConditions(c ...xpv1.Condition) + func (mg *LiteTopic) SetManagementPolicies(r xpv1.ManagementPolicies) + func (mg *LiteTopic) SetProviderConfigReference(r *xpv1.ProviderConfigReference) + func (mg *LiteTopic) SetWriteConnectionSecretToReference(r *xpv1.LocalSecretReference) + func (tr *LiteTopic) GetConnectionDetailsMapping() map[string]string + func (tr *LiteTopic) GetID() string + func (tr *LiteTopic) GetInitParameters() (map[string]any, error) + func (tr *LiteTopic) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error) + func (tr *LiteTopic) GetObservation() (map[string]any, error) + func (tr *LiteTopic) GetParameters() (map[string]any, error) + func (tr *LiteTopic) GetTerraformSchemaVersion() int + func (tr *LiteTopic) Hub() + func (tr *LiteTopic) LateInitialize(attrs []byte) (bool, error) + func (tr *LiteTopic) SetObservation(obs map[string]any) error + func (tr *LiteTopic) SetParameters(params map[string]any) error + type LiteTopicInitParameters struct + PartitionConfig *PartitionConfigInitParameters + Project *string + Region *string + ReservationConfig *ReservationConfigInitParameters + RetentionConfig *RetentionConfigInitParameters + func (in *LiteTopicInitParameters) DeepCopy() *LiteTopicInitParameters + func (in *LiteTopicInitParameters) DeepCopyInto(out *LiteTopicInitParameters) + type LiteTopicList struct + Items []LiteTopic + func (in *LiteTopicList) DeepCopy() *LiteTopicList + func (in *LiteTopicList) DeepCopyInto(out *LiteTopicList) + func (in *LiteTopicList) DeepCopyObject() runtime.Object + func (l *LiteTopicList) GetItems() []resource.Managed + type LiteTopicObservation struct + ID *string + PartitionConfig *PartitionConfigObservation + Project *string + Region *string + ReservationConfig *ReservationConfigObservation + RetentionConfig *RetentionConfigObservation + Zone *string + func (in *LiteTopicObservation) DeepCopy() *LiteTopicObservation + func (in *LiteTopicObservation) DeepCopyInto(out *LiteTopicObservation) + type LiteTopicParameters struct + PartitionConfig *PartitionConfigParameters + Project *string + Region *string + ReservationConfig *ReservationConfigParameters + RetentionConfig *RetentionConfigParameters + Zone *string + func (in *LiteTopicParameters) DeepCopy() *LiteTopicParameters + func (in *LiteTopicParameters) DeepCopyInto(out *LiteTopicParameters) + type LiteTopicSpec struct + ForProvider LiteTopicParameters + InitProvider LiteTopicInitParameters + func (in *LiteTopicSpec) DeepCopy() *LiteTopicSpec + func (in *LiteTopicSpec) DeepCopyInto(out *LiteTopicSpec) + type LiteTopicStatus struct + AtProvider LiteTopicObservation + func (in *LiteTopicStatus) DeepCopy() *LiteTopicStatus + func (in *LiteTopicStatus) DeepCopyInto(out *LiteTopicStatus) + type MessageStoragePolicyInitParameters struct + AllowedPersistenceRegions []*string + EnforceInTransit *bool + func (in *MessageStoragePolicyInitParameters) DeepCopy() *MessageStoragePolicyInitParameters + func (in *MessageStoragePolicyInitParameters) DeepCopyInto(out *MessageStoragePolicyInitParameters) + type MessageStoragePolicyObservation struct + AllowedPersistenceRegions []*string + EnforceInTransit *bool + func (in *MessageStoragePolicyObservation) DeepCopy() *MessageStoragePolicyObservation + func (in *MessageStoragePolicyObservation) DeepCopyInto(out *MessageStoragePolicyObservation) + type MessageStoragePolicyParameters struct + AllowedPersistenceRegions []*string + EnforceInTransit *bool + func (in *MessageStoragePolicyParameters) DeepCopy() *MessageStoragePolicyParameters + func (in *MessageStoragePolicyParameters) DeepCopyInto(out *MessageStoragePolicyParameters) + type MessageTransformsInitParameters struct + Disabled *bool + JavascriptUdf *JavascriptUdfInitParameters + func (in *MessageTransformsInitParameters) DeepCopy() *MessageTransformsInitParameters + func (in *MessageTransformsInitParameters) DeepCopyInto(out *MessageTransformsInitParameters) + type MessageTransformsJavascriptUdfInitParameters struct + Code *string + FunctionName *string + func (in *MessageTransformsJavascriptUdfInitParameters) DeepCopy() *MessageTransformsJavascriptUdfInitParameters + func (in *MessageTransformsJavascriptUdfInitParameters) DeepCopyInto(out *MessageTransformsJavascriptUdfInitParameters) + type MessageTransformsJavascriptUdfObservation struct + Code *string + FunctionName *string + func (in *MessageTransformsJavascriptUdfObservation) DeepCopy() *MessageTransformsJavascriptUdfObservation + func (in *MessageTransformsJavascriptUdfObservation) DeepCopyInto(out *MessageTransformsJavascriptUdfObservation) + type MessageTransformsJavascriptUdfParameters struct + Code *string + FunctionName *string + func (in *MessageTransformsJavascriptUdfParameters) DeepCopy() *MessageTransformsJavascriptUdfParameters + func (in *MessageTransformsJavascriptUdfParameters) DeepCopyInto(out *MessageTransformsJavascriptUdfParameters) + type MessageTransformsObservation struct + Disabled *bool + JavascriptUdf *JavascriptUdfObservation + func (in *MessageTransformsObservation) DeepCopy() *MessageTransformsObservation + func (in *MessageTransformsObservation) DeepCopyInto(out *MessageTransformsObservation) + type MessageTransformsParameters struct + Disabled *bool + JavascriptUdf *JavascriptUdfParameters + func (in *MessageTransformsParameters) DeepCopy() *MessageTransformsParameters + func (in *MessageTransformsParameters) DeepCopyInto(out *MessageTransformsParameters) + type NoWrapperInitParameters struct + WriteMetadata *bool + func (in *NoWrapperInitParameters) DeepCopy() *NoWrapperInitParameters + func (in *NoWrapperInitParameters) DeepCopyInto(out *NoWrapperInitParameters) + type NoWrapperObservation struct + WriteMetadata *bool + func (in *NoWrapperObservation) DeepCopy() *NoWrapperObservation + func (in *NoWrapperObservation) DeepCopyInto(out *NoWrapperObservation) + type NoWrapperParameters struct + WriteMetadata *bool + func (in *NoWrapperParameters) DeepCopy() *NoWrapperParameters + func (in *NoWrapperParameters) DeepCopyInto(out *NoWrapperParameters) + type OidcTokenInitParameters struct + Audience *string + ServiceAccountEmail *string + func (in *OidcTokenInitParameters) DeepCopy() *OidcTokenInitParameters + func (in *OidcTokenInitParameters) DeepCopyInto(out *OidcTokenInitParameters) + type OidcTokenObservation struct + Audience *string + ServiceAccountEmail *string + func (in *OidcTokenObservation) DeepCopy() *OidcTokenObservation + func (in *OidcTokenObservation) DeepCopyInto(out *OidcTokenObservation) + type OidcTokenParameters struct + Audience *string + ServiceAccountEmail *string + func (in *OidcTokenParameters) DeepCopy() *OidcTokenParameters + func (in *OidcTokenParameters) DeepCopyInto(out *OidcTokenParameters) + type PartitionConfigInitParameters struct + Capacity *CapacityInitParameters + Count *float64 + func (in *PartitionConfigInitParameters) DeepCopy() *PartitionConfigInitParameters + func (in *PartitionConfigInitParameters) DeepCopyInto(out *PartitionConfigInitParameters) + type PartitionConfigObservation struct + Capacity *CapacityObservation + Count *float64 + func (in *PartitionConfigObservation) DeepCopy() *PartitionConfigObservation + func (in *PartitionConfigObservation) DeepCopyInto(out *PartitionConfigObservation) + type PartitionConfigParameters struct + Capacity *CapacityParameters + Count *float64 + func (in *PartitionConfigParameters) DeepCopy() *PartitionConfigParameters + func (in *PartitionConfigParameters) DeepCopyInto(out *PartitionConfigParameters) + type PlatformLogsSettingsInitParameters struct + Severity *string + func (in *PlatformLogsSettingsInitParameters) DeepCopy() *PlatformLogsSettingsInitParameters + func (in *PlatformLogsSettingsInitParameters) DeepCopyInto(out *PlatformLogsSettingsInitParameters) + type PlatformLogsSettingsObservation struct + Severity *string + func (in *PlatformLogsSettingsObservation) DeepCopy() *PlatformLogsSettingsObservation + func (in *PlatformLogsSettingsObservation) DeepCopyInto(out *PlatformLogsSettingsObservation) + type PlatformLogsSettingsParameters struct + Severity *string + func (in *PlatformLogsSettingsParameters) DeepCopy() *PlatformLogsSettingsParameters + func (in *PlatformLogsSettingsParameters) DeepCopyInto(out *PlatformLogsSettingsParameters) + type PubsubAvroFormatInitParameters struct + func (in *PubsubAvroFormatInitParameters) DeepCopy() *PubsubAvroFormatInitParameters + func (in *PubsubAvroFormatInitParameters) DeepCopyInto(out *PubsubAvroFormatInitParameters) + type PubsubAvroFormatObservation struct + func (in *PubsubAvroFormatObservation) DeepCopy() *PubsubAvroFormatObservation + func (in *PubsubAvroFormatObservation) DeepCopyInto(out *PubsubAvroFormatObservation) + type PubsubAvroFormatParameters struct + func (in *PubsubAvroFormatParameters) DeepCopy() *PubsubAvroFormatParameters + func (in *PubsubAvroFormatParameters) DeepCopyInto(out *PubsubAvroFormatParameters) + type PushConfigInitParameters struct + Attributes map[string]*string + NoWrapper *NoWrapperInitParameters + OidcToken *OidcTokenInitParameters + PushEndpoint *string + func (in *PushConfigInitParameters) DeepCopy() *PushConfigInitParameters + func (in *PushConfigInitParameters) DeepCopyInto(out *PushConfigInitParameters) + type PushConfigObservation struct + Attributes map[string]*string + NoWrapper *NoWrapperObservation + OidcToken *OidcTokenObservation + PushEndpoint *string + func (in *PushConfigObservation) DeepCopy() *PushConfigObservation + func (in *PushConfigObservation) DeepCopyInto(out *PushConfigObservation) + type PushConfigParameters struct + Attributes map[string]*string + NoWrapper *NoWrapperParameters + OidcToken *OidcTokenParameters + PushEndpoint *string + func (in *PushConfigParameters) DeepCopy() *PushConfigParameters + func (in *PushConfigParameters) DeepCopyInto(out *PushConfigParameters) + type ReservationConfigInitParameters struct + ThroughputReservation *string + ThroughputReservationRef *v1.NamespacedReference + ThroughputReservationSelector *v1.NamespacedSelector + func (in *ReservationConfigInitParameters) DeepCopy() *ReservationConfigInitParameters + func (in *ReservationConfigInitParameters) DeepCopyInto(out *ReservationConfigInitParameters) + type ReservationConfigObservation struct + ThroughputReservation *string + func (in *ReservationConfigObservation) DeepCopy() *ReservationConfigObservation + func (in *ReservationConfigObservation) DeepCopyInto(out *ReservationConfigObservation) + type ReservationConfigParameters struct + ThroughputReservation *string + ThroughputReservationRef *v1.NamespacedReference + ThroughputReservationSelector *v1.NamespacedSelector + func (in *ReservationConfigParameters) DeepCopy() *ReservationConfigParameters + func (in *ReservationConfigParameters) DeepCopyInto(out *ReservationConfigParameters) + type RetentionConfigInitParameters struct + PerPartitionBytes *string + Period *string + func (in *RetentionConfigInitParameters) DeepCopy() *RetentionConfigInitParameters + func (in *RetentionConfigInitParameters) DeepCopyInto(out *RetentionConfigInitParameters) + type RetentionConfigObservation struct + PerPartitionBytes *string + Period *string + func (in *RetentionConfigObservation) DeepCopy() *RetentionConfigObservation + func (in *RetentionConfigObservation) DeepCopyInto(out *RetentionConfigObservation) + type RetentionConfigParameters struct + PerPartitionBytes *string + Period *string + func (in *RetentionConfigParameters) DeepCopy() *RetentionConfigParameters + func (in *RetentionConfigParameters) DeepCopyInto(out *RetentionConfigParameters) + type RetryPolicyInitParameters struct + MaximumBackoff *string + MinimumBackoff *string + func (in *RetryPolicyInitParameters) DeepCopy() *RetryPolicyInitParameters + func (in *RetryPolicyInitParameters) DeepCopyInto(out *RetryPolicyInitParameters) + type RetryPolicyObservation struct + MaximumBackoff *string + MinimumBackoff *string + func (in *RetryPolicyObservation) DeepCopy() *RetryPolicyObservation + func (in *RetryPolicyObservation) DeepCopyInto(out *RetryPolicyObservation) + type RetryPolicyParameters struct + MaximumBackoff *string + MinimumBackoff *string + func (in *RetryPolicyParameters) DeepCopy() *RetryPolicyParameters + func (in *RetryPolicyParameters) DeepCopyInto(out *RetryPolicyParameters) + type Schema struct + Spec SchemaSpec + Status SchemaStatus + func (in *Schema) DeepCopy() *Schema + func (in *Schema) DeepCopyInto(out *Schema) + func (in *Schema) DeepCopyObject() runtime.Object + func (mg *Schema) GetCondition(ct xpv1.ConditionType) xpv1.Condition + func (mg *Schema) GetManagementPolicies() xpv1.ManagementPolicies + func (mg *Schema) GetProviderConfigReference() *xpv1.ProviderConfigReference + func (mg *Schema) GetTerraformResourceType() string + func (mg *Schema) GetWriteConnectionSecretToReference() *xpv1.LocalSecretReference + func (mg *Schema) SetConditions(c ...xpv1.Condition) + func (mg *Schema) SetManagementPolicies(r xpv1.ManagementPolicies) + func (mg *Schema) SetProviderConfigReference(r *xpv1.ProviderConfigReference) + func (mg *Schema) SetWriteConnectionSecretToReference(r *xpv1.LocalSecretReference) + func (tr *Schema) GetConnectionDetailsMapping() map[string]string + func (tr *Schema) GetID() string + func (tr *Schema) GetInitParameters() (map[string]any, error) + func (tr *Schema) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error) + func (tr *Schema) GetObservation() (map[string]any, error) + func (tr *Schema) GetParameters() (map[string]any, error) + func (tr *Schema) GetTerraformSchemaVersion() int + func (tr *Schema) Hub() + func (tr *Schema) LateInitialize(attrs []byte) (bool, error) + func (tr *Schema) SetObservation(obs map[string]any) error + func (tr *Schema) SetParameters(params map[string]any) error + type SchemaInitParameters struct + Definition *string + Project *string + Type *string + func (in *SchemaInitParameters) DeepCopy() *SchemaInitParameters + func (in *SchemaInitParameters) DeepCopyInto(out *SchemaInitParameters) + type SchemaList struct + Items []Schema + func (in *SchemaList) DeepCopy() *SchemaList + func (in *SchemaList) DeepCopyInto(out *SchemaList) + func (in *SchemaList) DeepCopyObject() runtime.Object + func (l *SchemaList) GetItems() []resource.Managed + type SchemaObservation struct + Definition *string + ID *string + Project *string + Type *string + func (in *SchemaObservation) DeepCopy() *SchemaObservation + func (in *SchemaObservation) DeepCopyInto(out *SchemaObservation) + type SchemaParameters struct + Definition *string + Project *string + Type *string + func (in *SchemaParameters) DeepCopy() *SchemaParameters + func (in *SchemaParameters) DeepCopyInto(out *SchemaParameters) + type SchemaSettingsInitParameters struct + Encoding *string + Schema *string + func (in *SchemaSettingsInitParameters) DeepCopy() *SchemaSettingsInitParameters + func (in *SchemaSettingsInitParameters) DeepCopyInto(out *SchemaSettingsInitParameters) + type SchemaSettingsObservation struct + Encoding *string + Schema *string + func (in *SchemaSettingsObservation) DeepCopy() *SchemaSettingsObservation + func (in *SchemaSettingsObservation) DeepCopyInto(out *SchemaSettingsObservation) + type SchemaSettingsParameters struct + Encoding *string + Schema *string + func (in *SchemaSettingsParameters) DeepCopy() *SchemaSettingsParameters + func (in *SchemaSettingsParameters) DeepCopyInto(out *SchemaSettingsParameters) + type SchemaSpec struct + ForProvider SchemaParameters + InitProvider SchemaInitParameters + func (in *SchemaSpec) DeepCopy() *SchemaSpec + func (in *SchemaSpec) DeepCopyInto(out *SchemaSpec) + type SchemaStatus struct + AtProvider SchemaObservation + func (in *SchemaStatus) DeepCopy() *SchemaStatus + func (in *SchemaStatus) DeepCopyInto(out *SchemaStatus) + type Subscription struct + Spec SubscriptionSpec + Status SubscriptionStatus + func (in *Subscription) DeepCopy() *Subscription + func (in *Subscription) DeepCopyInto(out *Subscription) + func (in *Subscription) DeepCopyObject() runtime.Object + func (mg *Subscription) GetCondition(ct xpv1.ConditionType) xpv1.Condition + func (mg *Subscription) GetManagementPolicies() xpv1.ManagementPolicies + func (mg *Subscription) GetProviderConfigReference() *xpv1.ProviderConfigReference + func (mg *Subscription) GetTerraformResourceType() string + func (mg *Subscription) GetWriteConnectionSecretToReference() *xpv1.LocalSecretReference + func (mg *Subscription) ResolveReferences(ctx context.Context, c client.Reader) error + func (mg *Subscription) SetConditions(c ...xpv1.Condition) + func (mg *Subscription) SetManagementPolicies(r xpv1.ManagementPolicies) + func (mg *Subscription) SetProviderConfigReference(r *xpv1.ProviderConfigReference) + func (mg *Subscription) SetWriteConnectionSecretToReference(r *xpv1.LocalSecretReference) + func (tr *Subscription) GetConnectionDetailsMapping() map[string]string + func (tr *Subscription) GetID() string + func (tr *Subscription) GetInitParameters() (map[string]any, error) + func (tr *Subscription) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error) + func (tr *Subscription) GetObservation() (map[string]any, error) + func (tr *Subscription) GetParameters() (map[string]any, error) + func (tr *Subscription) GetTerraformSchemaVersion() int + func (tr *Subscription) Hub() + func (tr *Subscription) LateInitialize(attrs []byte) (bool, error) + func (tr *Subscription) SetObservation(obs map[string]any) error + func (tr *Subscription) SetParameters(params map[string]any) error + type SubscriptionIAMMember struct + Spec SubscriptionIAMMemberSpec + Status SubscriptionIAMMemberStatus + func (in *SubscriptionIAMMember) DeepCopy() *SubscriptionIAMMember + func (in *SubscriptionIAMMember) DeepCopyInto(out *SubscriptionIAMMember) + func (in *SubscriptionIAMMember) DeepCopyObject() runtime.Object + func (mg *SubscriptionIAMMember) GetCondition(ct xpv1.ConditionType) xpv1.Condition + func (mg *SubscriptionIAMMember) GetManagementPolicies() xpv1.ManagementPolicies + func (mg *SubscriptionIAMMember) GetProviderConfigReference() *xpv1.ProviderConfigReference + func (mg *SubscriptionIAMMember) GetTerraformResourceType() string + func (mg *SubscriptionIAMMember) GetWriteConnectionSecretToReference() *xpv1.LocalSecretReference + func (mg *SubscriptionIAMMember) ResolveReferences(ctx context.Context, c client.Reader) error + func (mg *SubscriptionIAMMember) SetConditions(c ...xpv1.Condition) + func (mg *SubscriptionIAMMember) SetManagementPolicies(r xpv1.ManagementPolicies) + func (mg *SubscriptionIAMMember) SetProviderConfigReference(r *xpv1.ProviderConfigReference) + func (mg *SubscriptionIAMMember) SetWriteConnectionSecretToReference(r *xpv1.LocalSecretReference) + func (tr *SubscriptionIAMMember) GetConnectionDetailsMapping() map[string]string + func (tr *SubscriptionIAMMember) GetID() string + func (tr *SubscriptionIAMMember) GetInitParameters() (map[string]any, error) + func (tr *SubscriptionIAMMember) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error) + func (tr *SubscriptionIAMMember) GetObservation() (map[string]any, error) + func (tr *SubscriptionIAMMember) GetParameters() (map[string]any, error) + func (tr *SubscriptionIAMMember) GetTerraformSchemaVersion() int + func (tr *SubscriptionIAMMember) Hub() + func (tr *SubscriptionIAMMember) LateInitialize(attrs []byte) (bool, error) + func (tr *SubscriptionIAMMember) SetObservation(obs map[string]any) error + func (tr *SubscriptionIAMMember) SetParameters(params map[string]any) error + type SubscriptionIAMMemberInitParameters struct + Condition *ConditionInitParameters + Member *string + Project *string + Role *string + Subscription *string + SubscriptionRef *v1.NamespacedReference + SubscriptionSelector *v1.NamespacedSelector + func (in *SubscriptionIAMMemberInitParameters) DeepCopy() *SubscriptionIAMMemberInitParameters + func (in *SubscriptionIAMMemberInitParameters) DeepCopyInto(out *SubscriptionIAMMemberInitParameters) + type SubscriptionIAMMemberList struct + Items []SubscriptionIAMMember + func (in *SubscriptionIAMMemberList) DeepCopy() *SubscriptionIAMMemberList + func (in *SubscriptionIAMMemberList) DeepCopyInto(out *SubscriptionIAMMemberList) + func (in *SubscriptionIAMMemberList) DeepCopyObject() runtime.Object + func (l *SubscriptionIAMMemberList) GetItems() []resource.Managed + type SubscriptionIAMMemberObservation struct + Condition *ConditionObservation + Etag *string + ID *string + Member *string + Project *string + Role *string + Subscription *string + func (in *SubscriptionIAMMemberObservation) DeepCopy() *SubscriptionIAMMemberObservation + func (in *SubscriptionIAMMemberObservation) DeepCopyInto(out *SubscriptionIAMMemberObservation) + type SubscriptionIAMMemberParameters struct + Condition *ConditionParameters + Member *string + Project *string + Role *string + Subscription *string + SubscriptionRef *v1.NamespacedReference + SubscriptionSelector *v1.NamespacedSelector + func (in *SubscriptionIAMMemberParameters) DeepCopy() *SubscriptionIAMMemberParameters + func (in *SubscriptionIAMMemberParameters) DeepCopyInto(out *SubscriptionIAMMemberParameters) + type SubscriptionIAMMemberSpec struct + ForProvider SubscriptionIAMMemberParameters + InitProvider SubscriptionIAMMemberInitParameters + func (in *SubscriptionIAMMemberSpec) DeepCopy() *SubscriptionIAMMemberSpec + func (in *SubscriptionIAMMemberSpec) DeepCopyInto(out *SubscriptionIAMMemberSpec) + type SubscriptionIAMMemberStatus struct + AtProvider SubscriptionIAMMemberObservation + func (in *SubscriptionIAMMemberStatus) DeepCopy() *SubscriptionIAMMemberStatus + func (in *SubscriptionIAMMemberStatus) DeepCopyInto(out *SubscriptionIAMMemberStatus) + type SubscriptionInitParameters struct + AckDeadlineSeconds *float64 + BigqueryConfig *BigqueryConfigInitParameters + CloudStorageConfig *CloudStorageConfigInitParameters + DeadLetterPolicy *DeadLetterPolicyInitParameters + EnableExactlyOnceDelivery *bool + EnableMessageOrdering *bool + ExpirationPolicy *ExpirationPolicyInitParameters + Filter *string + Labels map[string]*string + MessageRetentionDuration *string + MessageTransforms []MessageTransformsInitParameters + Project *string + PushConfig *PushConfigInitParameters + RetainAckedMessages *bool + RetryPolicy *RetryPolicyInitParameters + Topic *string + TopicRef *v1.NamespacedReference + TopicSelector *v1.NamespacedSelector + func (in *SubscriptionInitParameters) DeepCopy() *SubscriptionInitParameters + func (in *SubscriptionInitParameters) DeepCopyInto(out *SubscriptionInitParameters) + type SubscriptionList struct + Items []Subscription + func (in *SubscriptionList) DeepCopy() *SubscriptionList + func (in *SubscriptionList) DeepCopyInto(out *SubscriptionList) + func (in *SubscriptionList) DeepCopyObject() runtime.Object + func (l *SubscriptionList) GetItems() []resource.Managed + type SubscriptionObservation struct + AckDeadlineSeconds *float64 + BigqueryConfig *BigqueryConfigObservation + CloudStorageConfig *CloudStorageConfigObservation + DeadLetterPolicy *DeadLetterPolicyObservation + EffectiveLabels map[string]*string + EnableExactlyOnceDelivery *bool + EnableMessageOrdering *bool + ExpirationPolicy *ExpirationPolicyObservation + Filter *string + ID *string + Labels map[string]*string + MessageRetentionDuration *string + MessageTransforms []MessageTransformsObservation + Project *string + PushConfig *PushConfigObservation + RetainAckedMessages *bool + RetryPolicy *RetryPolicyObservation + TerraformLabels map[string]*string + Topic *string + func (in *SubscriptionObservation) DeepCopy() *SubscriptionObservation + func (in *SubscriptionObservation) DeepCopyInto(out *SubscriptionObservation) + type SubscriptionParameters struct + AckDeadlineSeconds *float64 + BigqueryConfig *BigqueryConfigParameters + CloudStorageConfig *CloudStorageConfigParameters + DeadLetterPolicy *DeadLetterPolicyParameters + EnableExactlyOnceDelivery *bool + EnableMessageOrdering *bool + ExpirationPolicy *ExpirationPolicyParameters + Filter *string + Labels map[string]*string + MessageRetentionDuration *string + MessageTransforms []MessageTransformsParameters + Project *string + PushConfig *PushConfigParameters + RetainAckedMessages *bool + RetryPolicy *RetryPolicyParameters + Topic *string + TopicRef *v1.NamespacedReference + TopicSelector *v1.NamespacedSelector + func (in *SubscriptionParameters) DeepCopy() *SubscriptionParameters + func (in *SubscriptionParameters) DeepCopyInto(out *SubscriptionParameters) + type SubscriptionSpec struct + ForProvider SubscriptionParameters + InitProvider SubscriptionInitParameters + func (in *SubscriptionSpec) DeepCopy() *SubscriptionSpec + func (in *SubscriptionSpec) DeepCopyInto(out *SubscriptionSpec) + type SubscriptionStatus struct + AtProvider SubscriptionObservation + func (in *SubscriptionStatus) DeepCopy() *SubscriptionStatus + func (in *SubscriptionStatus) DeepCopyInto(out *SubscriptionStatus) + type TextFormatInitParameters struct + Delimiter *string + func (in *TextFormatInitParameters) DeepCopy() *TextFormatInitParameters + func (in *TextFormatInitParameters) DeepCopyInto(out *TextFormatInitParameters) + type TextFormatObservation struct + Delimiter *string + func (in *TextFormatObservation) DeepCopy() *TextFormatObservation + func (in *TextFormatObservation) DeepCopyInto(out *TextFormatObservation) + type TextFormatParameters struct + Delimiter *string + func (in *TextFormatParameters) DeepCopy() *TextFormatParameters + func (in *TextFormatParameters) DeepCopyInto(out *TextFormatParameters) + type Topic struct + Spec TopicSpec + Status TopicStatus + func (in *Topic) DeepCopy() *Topic + func (in *Topic) DeepCopyInto(out *Topic) + func (in *Topic) DeepCopyObject() runtime.Object + func (mg *Topic) GetCondition(ct xpv1.ConditionType) xpv1.Condition + func (mg *Topic) GetManagementPolicies() xpv1.ManagementPolicies + func (mg *Topic) GetProviderConfigReference() *xpv1.ProviderConfigReference + func (mg *Topic) GetTerraformResourceType() string + func (mg *Topic) GetWriteConnectionSecretToReference() *xpv1.LocalSecretReference + func (mg *Topic) ResolveReferences(ctx context.Context, c client.Reader) error + func (mg *Topic) SetConditions(c ...xpv1.Condition) + func (mg *Topic) SetManagementPolicies(r xpv1.ManagementPolicies) + func (mg *Topic) SetProviderConfigReference(r *xpv1.ProviderConfigReference) + func (mg *Topic) SetWriteConnectionSecretToReference(r *xpv1.LocalSecretReference) + func (tr *Topic) GetConnectionDetailsMapping() map[string]string + func (tr *Topic) GetID() string + func (tr *Topic) GetInitParameters() (map[string]any, error) + func (tr *Topic) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error) + func (tr *Topic) GetObservation() (map[string]any, error) + func (tr *Topic) GetParameters() (map[string]any, error) + func (tr *Topic) GetTerraformSchemaVersion() int + func (tr *Topic) Hub() + func (tr *Topic) LateInitialize(attrs []byte) (bool, error) + func (tr *Topic) SetObservation(obs map[string]any) error + func (tr *Topic) SetParameters(params map[string]any) error + type TopicIAMMember struct + Spec TopicIAMMemberSpec + Status TopicIAMMemberStatus + func (in *TopicIAMMember) DeepCopy() *TopicIAMMember + func (in *TopicIAMMember) DeepCopyInto(out *TopicIAMMember) + func (in *TopicIAMMember) DeepCopyObject() runtime.Object + func (mg *TopicIAMMember) GetCondition(ct xpv1.ConditionType) xpv1.Condition + func (mg *TopicIAMMember) GetManagementPolicies() xpv1.ManagementPolicies + func (mg *TopicIAMMember) GetProviderConfigReference() *xpv1.ProviderConfigReference + func (mg *TopicIAMMember) GetTerraformResourceType() string + func (mg *TopicIAMMember) GetWriteConnectionSecretToReference() *xpv1.LocalSecretReference + func (mg *TopicIAMMember) ResolveReferences(ctx context.Context, c client.Reader) error + func (mg *TopicIAMMember) SetConditions(c ...xpv1.Condition) + func (mg *TopicIAMMember) SetManagementPolicies(r xpv1.ManagementPolicies) + func (mg *TopicIAMMember) SetProviderConfigReference(r *xpv1.ProviderConfigReference) + func (mg *TopicIAMMember) SetWriteConnectionSecretToReference(r *xpv1.LocalSecretReference) + func (tr *TopicIAMMember) GetConnectionDetailsMapping() map[string]string + func (tr *TopicIAMMember) GetID() string + func (tr *TopicIAMMember) GetInitParameters() (map[string]any, error) + func (tr *TopicIAMMember) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error) + func (tr *TopicIAMMember) GetObservation() (map[string]any, error) + func (tr *TopicIAMMember) GetParameters() (map[string]any, error) + func (tr *TopicIAMMember) GetTerraformSchemaVersion() int + func (tr *TopicIAMMember) Hub() + func (tr *TopicIAMMember) LateInitialize(attrs []byte) (bool, error) + func (tr *TopicIAMMember) SetObservation(obs map[string]any) error + func (tr *TopicIAMMember) SetParameters(params map[string]any) error + type TopicIAMMemberConditionInitParameters struct + Description *string + Expression *string + Title *string + func (in *TopicIAMMemberConditionInitParameters) DeepCopy() *TopicIAMMemberConditionInitParameters + func (in *TopicIAMMemberConditionInitParameters) DeepCopyInto(out *TopicIAMMemberConditionInitParameters) + type TopicIAMMemberConditionObservation struct + Description *string + Expression *string + Title *string + func (in *TopicIAMMemberConditionObservation) DeepCopy() *TopicIAMMemberConditionObservation + func (in *TopicIAMMemberConditionObservation) DeepCopyInto(out *TopicIAMMemberConditionObservation) + type TopicIAMMemberConditionParameters struct + Description *string + Expression *string + Title *string + func (in *TopicIAMMemberConditionParameters) DeepCopy() *TopicIAMMemberConditionParameters + func (in *TopicIAMMemberConditionParameters) DeepCopyInto(out *TopicIAMMemberConditionParameters) + type TopicIAMMemberInitParameters struct + Condition *TopicIAMMemberConditionInitParameters + Member *string + Project *string + Role *string + Topic *string + TopicRef *v1.NamespacedReference + TopicSelector *v1.NamespacedSelector + func (in *TopicIAMMemberInitParameters) DeepCopy() *TopicIAMMemberInitParameters + func (in *TopicIAMMemberInitParameters) DeepCopyInto(out *TopicIAMMemberInitParameters) + type TopicIAMMemberList struct + Items []TopicIAMMember + func (in *TopicIAMMemberList) DeepCopy() *TopicIAMMemberList + func (in *TopicIAMMemberList) DeepCopyInto(out *TopicIAMMemberList) + func (in *TopicIAMMemberList) DeepCopyObject() runtime.Object + func (l *TopicIAMMemberList) GetItems() []resource.Managed + type TopicIAMMemberObservation struct + Condition *TopicIAMMemberConditionObservation + Etag *string + ID *string + Member *string + Project *string + Role *string + Topic *string + func (in *TopicIAMMemberObservation) DeepCopy() *TopicIAMMemberObservation + func (in *TopicIAMMemberObservation) DeepCopyInto(out *TopicIAMMemberObservation) + type TopicIAMMemberParameters struct + Condition *TopicIAMMemberConditionParameters + Member *string + Project *string + Role *string + Topic *string + TopicRef *v1.NamespacedReference + TopicSelector *v1.NamespacedSelector + func (in *TopicIAMMemberParameters) DeepCopy() *TopicIAMMemberParameters + func (in *TopicIAMMemberParameters) DeepCopyInto(out *TopicIAMMemberParameters) + type TopicIAMMemberSpec struct + ForProvider TopicIAMMemberParameters + InitProvider TopicIAMMemberInitParameters + func (in *TopicIAMMemberSpec) DeepCopy() *TopicIAMMemberSpec + func (in *TopicIAMMemberSpec) DeepCopyInto(out *TopicIAMMemberSpec) + type TopicIAMMemberStatus struct + AtProvider TopicIAMMemberObservation + func (in *TopicIAMMemberStatus) DeepCopy() *TopicIAMMemberStatus + func (in *TopicIAMMemberStatus) DeepCopyInto(out *TopicIAMMemberStatus) + type TopicInitParameters struct + IngestionDataSourceSettings *IngestionDataSourceSettingsInitParameters + KMSKeyName *string + KMSKeyNameRef *v1.NamespacedReference + KMSKeyNameSelector *v1.NamespacedSelector + Labels map[string]*string + MessageRetentionDuration *string + MessageStoragePolicy *MessageStoragePolicyInitParameters + MessageTransforms []TopicMessageTransformsInitParameters + Project *string + SchemaSettings *SchemaSettingsInitParameters + func (in *TopicInitParameters) DeepCopy() *TopicInitParameters + func (in *TopicInitParameters) DeepCopyInto(out *TopicInitParameters) + type TopicList struct + Items []Topic + func (in *TopicList) DeepCopy() *TopicList + func (in *TopicList) DeepCopyInto(out *TopicList) + func (in *TopicList) DeepCopyObject() runtime.Object + func (l *TopicList) GetItems() []resource.Managed + type TopicMessageTransformsInitParameters struct + Disabled *bool + JavascriptUdf *MessageTransformsJavascriptUdfInitParameters + func (in *TopicMessageTransformsInitParameters) DeepCopy() *TopicMessageTransformsInitParameters + func (in *TopicMessageTransformsInitParameters) DeepCopyInto(out *TopicMessageTransformsInitParameters) + type TopicMessageTransformsObservation struct + Disabled *bool + JavascriptUdf *MessageTransformsJavascriptUdfObservation + func (in *TopicMessageTransformsObservation) DeepCopy() *TopicMessageTransformsObservation + func (in *TopicMessageTransformsObservation) DeepCopyInto(out *TopicMessageTransformsObservation) + type TopicMessageTransformsParameters struct + Disabled *bool + JavascriptUdf *MessageTransformsJavascriptUdfParameters + func (in *TopicMessageTransformsParameters) DeepCopy() *TopicMessageTransformsParameters + func (in *TopicMessageTransformsParameters) DeepCopyInto(out *TopicMessageTransformsParameters) + type TopicObservation struct + EffectiveLabels map[string]*string + ID *string + IngestionDataSourceSettings *IngestionDataSourceSettingsObservation + KMSKeyName *string + Labels map[string]*string + MessageRetentionDuration *string + MessageStoragePolicy *MessageStoragePolicyObservation + MessageTransforms []TopicMessageTransformsObservation + Project *string + SchemaSettings *SchemaSettingsObservation + TerraformLabels map[string]*string + func (in *TopicObservation) DeepCopy() *TopicObservation + func (in *TopicObservation) DeepCopyInto(out *TopicObservation) + type TopicParameters struct + IngestionDataSourceSettings *IngestionDataSourceSettingsParameters + KMSKeyName *string + KMSKeyNameRef *v1.NamespacedReference + KMSKeyNameSelector *v1.NamespacedSelector + Labels map[string]*string + MessageRetentionDuration *string + MessageStoragePolicy *MessageStoragePolicyParameters + MessageTransforms []TopicMessageTransformsParameters + Project *string + SchemaSettings *SchemaSettingsParameters + func (in *TopicParameters) DeepCopy() *TopicParameters + func (in *TopicParameters) DeepCopyInto(out *TopicParameters) + type TopicSpec struct + ForProvider TopicParameters + InitProvider TopicInitParameters + func (in *TopicSpec) DeepCopy() *TopicSpec + func (in *TopicSpec) DeepCopyInto(out *TopicSpec) + type TopicStatus struct + AtProvider TopicObservation + func (in *TopicStatus) DeepCopy() *TopicStatus + func (in *TopicStatus) DeepCopyInto(out *TopicStatus)