v1beta1

Aug 6, 2024

Changes in this version

+ 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 CloudStorageConfigInitParameters

+ FilenameDatetimeFormat *string

type CloudStorageConfigObservation

+ FilenameDatetimeFormat *string

type CloudStorageConfigParameters

+ FilenameDatetimeFormat *string

+ type IngestionDataSourceSettingsInitParameters struct

+ AwsKinesis []AwsKinesisInitParameters

+ func (in *IngestionDataSourceSettingsInitParameters) DeepCopy() *IngestionDataSourceSettingsInitParameters

+ func (in *IngestionDataSourceSettingsInitParameters) DeepCopyInto(out *IngestionDataSourceSettingsInitParameters)

+ type IngestionDataSourceSettingsObservation struct

+ AwsKinesis []AwsKinesisObservation

+ func (in *IngestionDataSourceSettingsObservation) DeepCopy() *IngestionDataSourceSettingsObservation

+ func (in *IngestionDataSourceSettingsObservation) DeepCopyInto(out *IngestionDataSourceSettingsObservation)

+ type IngestionDataSourceSettingsParameters struct

+ AwsKinesis []AwsKinesisParameters

+ func (in *IngestionDataSourceSettingsParameters) DeepCopy() *IngestionDataSourceSettingsParameters

+ func (in *IngestionDataSourceSettingsParameters) DeepCopyInto(out *IngestionDataSourceSettingsParameters)

type TopicInitParameters

+ IngestionDataSourceSettings []IngestionDataSourceSettingsInitParameters

type TopicObservation

+ IngestionDataSourceSettings []IngestionDataSourceSettingsObservation

type TopicParameters

+ IngestionDataSourceSettings []IngestionDataSourceSettingsParameters

May 16, 2024

Changes in this version

type LiteSubscription

+ func (tr *LiteSubscription) ConvertFrom(srcRaw conversion.Hub) error

+ func (tr *LiteSubscription) ConvertTo(dstRaw conversion.Hub) error

type LiteTopic

+ func (tr *LiteTopic) ConvertFrom(srcRaw conversion.Hub) error

+ func (tr *LiteTopic) ConvertTo(dstRaw conversion.Hub) error

type Subscription

+ func (tr *Subscription) ConvertFrom(srcRaw conversion.Hub) error

+ func (tr *Subscription) ConvertTo(dstRaw conversion.Hub) error

type SubscriptionIAMMember

+ func (tr *SubscriptionIAMMember) ConvertFrom(srcRaw conversion.Hub) error

+ func (tr *SubscriptionIAMMember) ConvertTo(dstRaw conversion.Hub) error

type Topic

+ func (tr *Topic) ConvertFrom(srcRaw conversion.Hub) error

+ func (tr *Topic) ConvertTo(dstRaw conversion.Hub) error

type TopicIAMMember

+ func (tr *TopicIAMMember) ConvertFrom(srcRaw conversion.Hub) error

+ func (tr *TopicIAMMember) ConvertTo(dstRaw conversion.Hub) error

Mar 7, 2024

Changes in this version

+ type AvroConfigInitParameters struct

+ WriteMetadata *bool

+ func (in *AvroConfigInitParameters) DeepCopy() *AvroConfigInitParameters

+ func (in *AvroConfigInitParameters) DeepCopyInto(out *AvroConfigInitParameters)

+ type AvroConfigObservation struct

+ WriteMetadata *bool

+ func (in *AvroConfigObservation) DeepCopy() *AvroConfigObservation

+ func (in *AvroConfigObservation) DeepCopyInto(out *AvroConfigObservation)

+ type AvroConfigParameters struct

+ WriteMetadata *bool

+ func (in *AvroConfigParameters) DeepCopy() *AvroConfigParameters

+ func (in *AvroConfigParameters) DeepCopyInto(out *AvroConfigParameters)

type BigqueryConfigInitParameters

+ UseTableSchema *bool

type BigqueryConfigObservation

+ UseTableSchema *bool

type BigqueryConfigParameters

+ UseTableSchema *bool

+ type CloudStorageConfigInitParameters struct

+ AvroConfig []AvroConfigInitParameters

+ Bucket *string

+ FilenamePrefix *string

+ FilenameSuffix *string

+ MaxBytes *float64

+ MaxDuration *string

+ func (in *CloudStorageConfigInitParameters) DeepCopy() *CloudStorageConfigInitParameters

+ func (in *CloudStorageConfigInitParameters) DeepCopyInto(out *CloudStorageConfigInitParameters)

+ type CloudStorageConfigObservation struct

+ AvroConfig []AvroConfigObservation

+ Bucket *string

+ FilenamePrefix *string

+ FilenameSuffix *string

+ MaxBytes *float64

+ MaxDuration *string

+ State *string

+ func (in *CloudStorageConfigObservation) DeepCopy() *CloudStorageConfigObservation

+ func (in *CloudStorageConfigObservation) DeepCopyInto(out *CloudStorageConfigObservation)

+ type CloudStorageConfigParameters struct

+ AvroConfig []AvroConfigParameters

+ Bucket *string

+ FilenamePrefix *string

+ FilenameSuffix *string

+ MaxBytes *float64

+ MaxDuration *string

+ func (in *CloudStorageConfigParameters) DeepCopy() *CloudStorageConfigParameters

+ func (in *CloudStorageConfigParameters) DeepCopyInto(out *CloudStorageConfigParameters)

type SubscriptionInitParameters

+ CloudStorageConfig []CloudStorageConfigInitParameters

type SubscriptionObservation

+ CloudStorageConfig []CloudStorageConfigObservation

+ EffectiveLabels map[string]*string

+ TerraformLabels map[string]*string

type SubscriptionParameters

+ CloudStorageConfig []CloudStorageConfigParameters

type TopicObservation

+ EffectiveLabels map[string]*string

+ TerraformLabels map[string]*string

Feb 22, 2024

Changes in this version

type LiteReservation

+ func (tr *LiteReservation) Hub()

type LiteSubscription

+ func (tr *LiteSubscription) Hub()

type LiteTopic

+ func (tr *LiteTopic) Hub()

type Schema

+ func (tr *Schema) Hub()

type Subscription

+ func (tr *Subscription) Hub()

type SubscriptionIAMMember

+ func (tr *SubscriptionIAMMember) Hub()

type Topic

+ func (tr *Topic) Hub()

type TopicIAMMember

+ func (tr *TopicIAMMember) Hub()

Dec 28, 2023

Changes in this version

type DeadLetterPolicyInitParameters

+ DeadLetterTopic *string

+ DeadLetterTopicRef *v1.Reference

+ DeadLetterTopicSelector *v1.Selector

type LiteSubscriptionInitParameters

+ Topic *string

+ TopicRef *v1.Reference

+ TopicSelector *v1.Selector

type ReservationConfigInitParameters

+ ThroughputReservation *string

+ ThroughputReservationRef *v1.Reference

+ ThroughputReservationSelector *v1.Selector

type SubscriptionIAMMemberInitParameters

+ Subscription *string

+ SubscriptionRef *v1.Reference

+ SubscriptionSelector *v1.Selector

type SubscriptionInitParameters

+ Topic *string

+ TopicRef *v1.Reference

+ TopicSelector *v1.Selector

type TopicIAMMemberInitParameters

+ Topic *string

+ TopicRef *v1.Reference

+ TopicSelector *v1.Selector

type TopicInitParameters

+ KMSKeyName *string

+ KMSKeyNameRef *v1.Reference

+ KMSKeyNameSelector *v1.Selector

Dec 13, 2023

Changes in this version

type LiteReservation

+ func (tr *LiteReservation) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type LiteSubscription

+ func (tr *LiteSubscription) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type LiteTopic

+ func (tr *LiteTopic) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type Schema

+ func (tr *Schema) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type Subscription

+ func (tr *Subscription) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type SubscriptionIAMMember

+ func (tr *SubscriptionIAMMember) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type Topic

+ func (tr *Topic) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type TopicIAMMember

+ func (tr *TopicIAMMember) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

Sep 28, 2023

Changes in this version

+ 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 PushConfigInitParameters

+ NoWrapper []NoWrapperInitParameters

type PushConfigObservation

+ NoWrapper []NoWrapperObservation

type PushConfigParameters

+ NoWrapper []NoWrapperParameters

Aug 1, 2023

Changes in this version

+ type BigqueryConfigInitParameters struct

+ DropUnknownFields *bool

+ Table *string

+ UseTopicSchema *bool

+ WriteMetadata *bool

+ func (in *BigqueryConfigInitParameters) DeepCopy() *BigqueryConfigInitParameters

+ func (in *BigqueryConfigInitParameters) DeepCopyInto(out *BigqueryConfigInitParameters)

+ type CapacityInitParameters struct

+ PublishMibPerSec *float64

+ SubscribeMibPerSec *float64

+ func (in *CapacityInitParameters) DeepCopy() *CapacityInitParameters

+ func (in *CapacityInitParameters) DeepCopyInto(out *CapacityInitParameters)

+ type ConditionInitParameters struct

+ Description *string

+ Expression *string

+ Title *string

+ func (in *ConditionInitParameters) DeepCopy() *ConditionInitParameters

+ func (in *ConditionInitParameters) DeepCopyInto(out *ConditionInitParameters)

+ type DeadLetterPolicyInitParameters struct

+ MaxDeliveryAttempts *float64

+ func (in *DeadLetterPolicyInitParameters) DeepCopy() *DeadLetterPolicyInitParameters

+ func (in *DeadLetterPolicyInitParameters) DeepCopyInto(out *DeadLetterPolicyInitParameters)

+ type DeliveryConfigInitParameters struct

+ DeliveryRequirement *string

+ func (in *DeliveryConfigInitParameters) DeepCopy() *DeliveryConfigInitParameters

+ func (in *DeliveryConfigInitParameters) DeepCopyInto(out *DeliveryConfigInitParameters)

+ type ExpirationPolicyInitParameters struct

+ TTL *string

+ func (in *ExpirationPolicyInitParameters) DeepCopy() *ExpirationPolicyInitParameters

+ func (in *ExpirationPolicyInitParameters) DeepCopyInto(out *ExpirationPolicyInitParameters)

type LiteReservation

+ func (mg *LiteReservation) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *LiteReservation) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *LiteReservation) GetInitParameters() (map[string]any, error)

+ type LiteReservationInitParameters struct

+ Project *string

+ ThroughputCapacity *float64

+ func (in *LiteReservationInitParameters) DeepCopy() *LiteReservationInitParameters

+ func (in *LiteReservationInitParameters) DeepCopyInto(out *LiteReservationInitParameters)

type LiteReservationSpec

+ InitProvider LiteReservationInitParameters

type LiteSubscription

+ func (mg *LiteSubscription) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *LiteSubscription) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *LiteSubscription) GetInitParameters() (map[string]any, error)

+ type LiteSubscriptionInitParameters struct

+ DeliveryConfig []DeliveryConfigInitParameters

+ Project *string

+ Region *string

+ func (in *LiteSubscriptionInitParameters) DeepCopy() *LiteSubscriptionInitParameters

+ func (in *LiteSubscriptionInitParameters) DeepCopyInto(out *LiteSubscriptionInitParameters)

type LiteSubscriptionSpec

+ InitProvider LiteSubscriptionInitParameters

type LiteTopic

+ func (mg *LiteTopic) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *LiteTopic) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *LiteTopic) GetInitParameters() (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 LiteTopicSpec

+ InitProvider LiteTopicInitParameters

+ type MessageStoragePolicyInitParameters struct

+ AllowedPersistenceRegions []*string

+ func (in *MessageStoragePolicyInitParameters) DeepCopy() *MessageStoragePolicyInitParameters

+ func (in *MessageStoragePolicyInitParameters) DeepCopyInto(out *MessageStoragePolicyInitParameters)

+ type OidcTokenInitParameters struct

+ Audience *string

+ ServiceAccountEmail *string

+ func (in *OidcTokenInitParameters) DeepCopy() *OidcTokenInitParameters

+ func (in *OidcTokenInitParameters) DeepCopyInto(out *OidcTokenInitParameters)

+ type PartitionConfigInitParameters struct

+ Capacity []CapacityInitParameters

+ Count *float64

+ func (in *PartitionConfigInitParameters) DeepCopy() *PartitionConfigInitParameters

+ func (in *PartitionConfigInitParameters) DeepCopyInto(out *PartitionConfigInitParameters)

+ type PushConfigInitParameters struct

+ Attributes map[string]*string

+ OidcToken []OidcTokenInitParameters

+ PushEndpoint *string

+ func (in *PushConfigInitParameters) DeepCopy() *PushConfigInitParameters

+ func (in *PushConfigInitParameters) DeepCopyInto(out *PushConfigInitParameters)

+ type ReservationConfigInitParameters struct

+ func (in *ReservationConfigInitParameters) DeepCopy() *ReservationConfigInitParameters

+ func (in *ReservationConfigInitParameters) DeepCopyInto(out *ReservationConfigInitParameters)

+ type RetentionConfigInitParameters struct

+ PerPartitionBytes *string

+ Period *string

+ func (in *RetentionConfigInitParameters) DeepCopy() *RetentionConfigInitParameters

+ func (in *RetentionConfigInitParameters) DeepCopyInto(out *RetentionConfigInitParameters)

+ type RetryPolicyInitParameters struct

+ MaximumBackoff *string

+ MinimumBackoff *string

+ func (in *RetryPolicyInitParameters) DeepCopy() *RetryPolicyInitParameters

+ func (in *RetryPolicyInitParameters) DeepCopyInto(out *RetryPolicyInitParameters)

type Schema

+ func (mg *Schema) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *Schema) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *Schema) GetInitParameters() (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 SchemaSettingsInitParameters struct

+ Encoding *string

+ Schema *string

+ func (in *SchemaSettingsInitParameters) DeepCopy() *SchemaSettingsInitParameters

+ func (in *SchemaSettingsInitParameters) DeepCopyInto(out *SchemaSettingsInitParameters)

type SchemaSpec

+ InitProvider SchemaInitParameters

type Subscription

+ func (mg *Subscription) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *Subscription) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *Subscription) GetInitParameters() (map[string]any, error)

type SubscriptionIAMMember

+ func (mg *SubscriptionIAMMember) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *SubscriptionIAMMember) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *SubscriptionIAMMember) GetInitParameters() (map[string]any, error)

+ type SubscriptionIAMMemberInitParameters struct

+ Condition []ConditionInitParameters

+ Member *string

+ Project *string

+ Role *string

+ func (in *SubscriptionIAMMemberInitParameters) DeepCopy() *SubscriptionIAMMemberInitParameters

+ func (in *SubscriptionIAMMemberInitParameters) DeepCopyInto(out *SubscriptionIAMMemberInitParameters)

type SubscriptionIAMMemberSpec

+ InitProvider SubscriptionIAMMemberInitParameters

+ type SubscriptionInitParameters struct

+ AckDeadlineSeconds *float64

+ BigqueryConfig []BigqueryConfigInitParameters

+ DeadLetterPolicy []DeadLetterPolicyInitParameters

+ EnableExactlyOnceDelivery *bool

+ EnableMessageOrdering *bool

+ ExpirationPolicy []ExpirationPolicyInitParameters

+ Filter *string

+ Labels map[string]*string

+ MessageRetentionDuration *string

+ Project *string

+ PushConfig []PushConfigInitParameters

+ RetainAckedMessages *bool

+ RetryPolicy []RetryPolicyInitParameters

+ func (in *SubscriptionInitParameters) DeepCopy() *SubscriptionInitParameters

+ func (in *SubscriptionInitParameters) DeepCopyInto(out *SubscriptionInitParameters)

type SubscriptionSpec

+ InitProvider SubscriptionInitParameters

type Topic

+ func (mg *Topic) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *Topic) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *Topic) GetInitParameters() (map[string]any, error)

type TopicIAMMember

+ func (mg *TopicIAMMember) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *TopicIAMMember) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *TopicIAMMember) GetInitParameters() (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 TopicIAMMemberInitParameters struct

+ Condition []TopicIAMMemberConditionInitParameters

+ Member *string

+ Project *string

+ Role *string

+ func (in *TopicIAMMemberInitParameters) DeepCopy() *TopicIAMMemberInitParameters

+ func (in *TopicIAMMemberInitParameters) DeepCopyInto(out *TopicIAMMemberInitParameters)

type TopicIAMMemberSpec

+ InitProvider TopicIAMMemberInitParameters

+ type TopicInitParameters struct

+ Labels map[string]*string

+ MessageRetentionDuration *string

+ MessageStoragePolicy []MessageStoragePolicyInitParameters

+ Project *string

+ SchemaSettings []SchemaSettingsInitParameters

+ func (in *TopicInitParameters) DeepCopy() *TopicInitParameters

+ func (in *TopicInitParameters) DeepCopyInto(out *TopicInitParameters)

type TopicSpec

+ InitProvider TopicInitParameters

Apr 19, 2023

Changes in this version

type BigqueryConfigObservation

+ DropUnknownFields *bool

+ Table *string

+ UseTopicSchema *bool

+ WriteMetadata *bool

type CapacityObservation

+ PublishMibPerSec *float64

+ SubscribeMibPerSec *float64

type ConditionObservation

+ Description *string

+ Expression *string

+ Title *string

type DeadLetterPolicyObservation

+ DeadLetterTopic *string

+ MaxDeliveryAttempts *float64

type DeliveryConfigObservation

+ DeliveryRequirement *string

type ExpirationPolicyObservation

+ TTL *string

type LiteReservation

+ func (mg *LiteReservation) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *LiteReservation) SetManagementPolicy(r xpv1.ManagementPolicy)

type LiteReservationObservation

+ Project *string

+ Region *string

+ ThroughputCapacity *float64

type LiteSubscription

+ func (mg *LiteSubscription) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *LiteSubscription) SetManagementPolicy(r xpv1.ManagementPolicy)

type LiteSubscriptionObservation

+ DeliveryConfig []DeliveryConfigObservation

+ Project *string

+ Region *string

+ Topic *string

+ Zone *string

type LiteTopic

+ func (mg *LiteTopic) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *LiteTopic) SetManagementPolicy(r xpv1.ManagementPolicy)

type LiteTopicObservation

+ PartitionConfig []PartitionConfigObservation

+ Project *string

+ Region *string

+ ReservationConfig []ReservationConfigObservation

+ RetentionConfig []RetentionConfigObservation

+ Zone *string

type MessageStoragePolicyObservation

+ AllowedPersistenceRegions []*string

type OidcTokenObservation

+ Audience *string

+ ServiceAccountEmail *string

type PartitionConfigObservation

+ Capacity []CapacityObservation

+ Count *float64

type PushConfigObservation

+ Attributes map[string]*string

+ OidcToken []OidcTokenObservation

+ PushEndpoint *string

type ReservationConfigObservation

+ ThroughputReservation *string

type RetentionConfigObservation

+ PerPartitionBytes *string

+ Period *string

type RetryPolicyObservation

+ MaximumBackoff *string

+ MinimumBackoff *string

type Schema

+ func (mg *Schema) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *Schema) SetManagementPolicy(r xpv1.ManagementPolicy)

type SchemaObservation

+ Definition *string

+ Project *string

+ Type *string

type SchemaSettingsObservation

+ Encoding *string

+ Schema *string

type Subscription

+ func (mg *Subscription) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *Subscription) SetManagementPolicy(r xpv1.ManagementPolicy)

type SubscriptionIAMMember

+ func (mg *SubscriptionIAMMember) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *SubscriptionIAMMember) SetManagementPolicy(r xpv1.ManagementPolicy)

type SubscriptionIAMMemberObservation

+ Condition []ConditionObservation

+ Member *string

+ Project *string

+ Role *string

+ Subscription *string

type SubscriptionObservation

+ AckDeadlineSeconds *float64

+ BigqueryConfig []BigqueryConfigObservation

+ DeadLetterPolicy []DeadLetterPolicyObservation

+ EnableExactlyOnceDelivery *bool

+ EnableMessageOrdering *bool

+ ExpirationPolicy []ExpirationPolicyObservation

+ Filter *string

+ Labels map[string]*string

+ MessageRetentionDuration *string

+ Project *string

+ PushConfig []PushConfigObservation

+ RetainAckedMessages *bool

+ RetryPolicy []RetryPolicyObservation

+ Topic *string

type Topic

+ func (mg *Topic) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *Topic) SetManagementPolicy(r xpv1.ManagementPolicy)

type TopicIAMMember

+ func (mg *TopicIAMMember) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *TopicIAMMember) SetManagementPolicy(r xpv1.ManagementPolicy)

type TopicIAMMemberConditionObservation

+ Description *string

+ Expression *string

+ Title *string

type TopicIAMMemberObservation

+ Condition []TopicIAMMemberConditionObservation

+ Member *string

+ Project *string

+ Role *string

+ Topic *string

type TopicObservation

+ KMSKeyName *string

+ Labels map[string]*string

+ MessageRetentionDuration *string

+ MessageStoragePolicy []MessageStoragePolicyObservation

+ Project *string

+ SchemaSettings []SchemaSettingsObservation

Jan 24, 2023

Changes in this version

+ type BigqueryConfigObservation struct

+ func (in *BigqueryConfigObservation) DeepCopy() *BigqueryConfigObservation

+ func (in *BigqueryConfigObservation) DeepCopyInto(out *BigqueryConfigObservation)

+ type BigqueryConfigParameters struct

+ DropUnknownFields *bool

+ Table *string

+ UseTopicSchema *bool

+ WriteMetadata *bool

+ func (in *BigqueryConfigParameters) DeepCopy() *BigqueryConfigParameters

+ func (in *BigqueryConfigParameters) DeepCopyInto(out *BigqueryConfigParameters)

type SubscriptionParameters

+ BigqueryConfig []BigqueryConfigParameters

Oct 17, 2022

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 CapacityObservation struct

+ 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 ConditionObservation struct

+ 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 DeadLetterPolicyObservation struct

+ func (in *DeadLetterPolicyObservation) DeepCopy() *DeadLetterPolicyObservation

+ func (in *DeadLetterPolicyObservation) DeepCopyInto(out *DeadLetterPolicyObservation)

+ type DeadLetterPolicyParameters struct

+ DeadLetterTopic *string

+ DeadLetterTopicRef *v1.Reference

+ DeadLetterTopicSelector *v1.Selector

+ MaxDeliveryAttempts *float64

+ func (in *DeadLetterPolicyParameters) DeepCopy() *DeadLetterPolicyParameters

+ func (in *DeadLetterPolicyParameters) DeepCopyInto(out *DeadLetterPolicyParameters)

+ type DeliveryConfigObservation struct

+ 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 ExpirationPolicyObservation struct

+ 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 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) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *LiteReservation) GetProviderConfigReference() *xpv1.Reference

+ func (mg *LiteReservation) GetProviderReference() *xpv1.Reference

+ func (mg *LiteReservation) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *LiteReservation) GetTerraformResourceType() string

+ func (mg *LiteReservation) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *LiteReservation) SetConditions(c ...xpv1.Condition)

+ func (mg *LiteReservation) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *LiteReservation) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *LiteReservation) SetProviderReference(r *xpv1.Reference)

+ func (mg *LiteReservation) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *LiteReservation) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *LiteReservation) GetConnectionDetailsMapping() map[string]string

+ func (tr *LiteReservation) GetID() string

+ func (tr *LiteReservation) GetObservation() (map[string]any, error)

+ func (tr *LiteReservation) GetParameters() (map[string]any, error)

+ func (tr *LiteReservation) GetTerraformSchemaVersion() int

+ 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 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

+ 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

+ 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) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *LiteSubscription) GetProviderConfigReference() *xpv1.Reference

+ func (mg *LiteSubscription) GetProviderReference() *xpv1.Reference

+ func (mg *LiteSubscription) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *LiteSubscription) GetTerraformResourceType() string

+ func (mg *LiteSubscription) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *LiteSubscription) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *LiteSubscription) SetConditions(c ...xpv1.Condition)

+ func (mg *LiteSubscription) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *LiteSubscription) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *LiteSubscription) SetProviderReference(r *xpv1.Reference)

+ func (mg *LiteSubscription) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *LiteSubscription) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *LiteSubscription) GetConnectionDetailsMapping() map[string]string

+ func (tr *LiteSubscription) GetID() string

+ func (tr *LiteSubscription) GetObservation() (map[string]any, error)

+ func (tr *LiteSubscription) GetParameters() (map[string]any, error)

+ func (tr *LiteSubscription) GetTerraformSchemaVersion() int

+ 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 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

+ ID *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.Reference

+ TopicSelector *v1.Selector

+ Zone *string

+ func (in *LiteSubscriptionParameters) DeepCopy() *LiteSubscriptionParameters

+ func (in *LiteSubscriptionParameters) DeepCopyInto(out *LiteSubscriptionParameters)

+ type LiteSubscriptionSpec struct

+ ForProvider LiteSubscriptionParameters

+ 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) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *LiteTopic) GetProviderConfigReference() *xpv1.Reference

+ func (mg *LiteTopic) GetProviderReference() *xpv1.Reference

+ func (mg *LiteTopic) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *LiteTopic) GetTerraformResourceType() string

+ func (mg *LiteTopic) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *LiteTopic) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *LiteTopic) SetConditions(c ...xpv1.Condition)

+ func (mg *LiteTopic) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *LiteTopic) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *LiteTopic) SetProviderReference(r *xpv1.Reference)

+ func (mg *LiteTopic) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *LiteTopic) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *LiteTopic) GetConnectionDetailsMapping() map[string]string

+ func (tr *LiteTopic) GetID() string

+ func (tr *LiteTopic) GetObservation() (map[string]any, error)

+ func (tr *LiteTopic) GetParameters() (map[string]any, error)

+ func (tr *LiteTopic) GetTerraformSchemaVersion() int

+ 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 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

+ 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

+ 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 MessageStoragePolicyObservation struct

+ func (in *MessageStoragePolicyObservation) DeepCopy() *MessageStoragePolicyObservation

+ func (in *MessageStoragePolicyObservation) DeepCopyInto(out *MessageStoragePolicyObservation)

+ type MessageStoragePolicyParameters struct

+ AllowedPersistenceRegions []*string

+ func (in *MessageStoragePolicyParameters) DeepCopy() *MessageStoragePolicyParameters

+ func (in *MessageStoragePolicyParameters) DeepCopyInto(out *MessageStoragePolicyParameters)

+ type OidcTokenObservation struct

+ 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 PartitionConfigObservation struct

+ 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 PushConfigObservation struct

+ func (in *PushConfigObservation) DeepCopy() *PushConfigObservation

+ func (in *PushConfigObservation) DeepCopyInto(out *PushConfigObservation)

+ type PushConfigParameters struct

+ Attributes map[string]*string

+ OidcToken []OidcTokenParameters

+ PushEndpoint *string

+ func (in *PushConfigParameters) DeepCopy() *PushConfigParameters

+ func (in *PushConfigParameters) DeepCopyInto(out *PushConfigParameters)

+ type ReservationConfigObservation struct

+ func (in *ReservationConfigObservation) DeepCopy() *ReservationConfigObservation

+ func (in *ReservationConfigObservation) DeepCopyInto(out *ReservationConfigObservation)

+ type ReservationConfigParameters struct

+ ThroughputReservation *string

+ ThroughputReservationRef *v1.Reference

+ ThroughputReservationSelector *v1.Selector

+ func (in *ReservationConfigParameters) DeepCopy() *ReservationConfigParameters

+ func (in *ReservationConfigParameters) DeepCopyInto(out *ReservationConfigParameters)

+ type RetentionConfigObservation struct

+ 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 RetryPolicyObservation struct

+ 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) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *Schema) GetProviderConfigReference() *xpv1.Reference

+ func (mg *Schema) GetProviderReference() *xpv1.Reference

+ func (mg *Schema) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *Schema) GetTerraformResourceType() string

+ func (mg *Schema) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *Schema) SetConditions(c ...xpv1.Condition)

+ func (mg *Schema) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *Schema) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *Schema) SetProviderReference(r *xpv1.Reference)

+ func (mg *Schema) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *Schema) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *Schema) GetConnectionDetailsMapping() map[string]string

+ func (tr *Schema) GetID() string

+ func (tr *Schema) GetObservation() (map[string]any, error)

+ func (tr *Schema) GetParameters() (map[string]any, error)

+ func (tr *Schema) GetTerraformSchemaVersion() int

+ 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 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

+ ID *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 SchemaSettingsObservation struct

+ 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

+ 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) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *Subscription) GetProviderConfigReference() *xpv1.Reference

+ func (mg *Subscription) GetProviderReference() *xpv1.Reference

+ func (mg *Subscription) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *Subscription) GetTerraformResourceType() string

+ func (mg *Subscription) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *Subscription) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *Subscription) SetConditions(c ...xpv1.Condition)

+ func (mg *Subscription) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *Subscription) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *Subscription) SetProviderReference(r *xpv1.Reference)

+ func (mg *Subscription) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *Subscription) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *Subscription) GetConnectionDetailsMapping() map[string]string

+ func (tr *Subscription) GetID() string

+ func (tr *Subscription) GetObservation() (map[string]any, error)

+ func (tr *Subscription) GetParameters() (map[string]any, error)

+ func (tr *Subscription) GetTerraformSchemaVersion() int

+ 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) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *SubscriptionIAMMember) GetProviderConfigReference() *xpv1.Reference

+ func (mg *SubscriptionIAMMember) GetProviderReference() *xpv1.Reference

+ func (mg *SubscriptionIAMMember) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *SubscriptionIAMMember) GetTerraformResourceType() string

+ func (mg *SubscriptionIAMMember) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *SubscriptionIAMMember) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *SubscriptionIAMMember) SetConditions(c ...xpv1.Condition)

+ func (mg *SubscriptionIAMMember) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *SubscriptionIAMMember) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *SubscriptionIAMMember) SetProviderReference(r *xpv1.Reference)

+ func (mg *SubscriptionIAMMember) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *SubscriptionIAMMember) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *SubscriptionIAMMember) GetConnectionDetailsMapping() map[string]string

+ func (tr *SubscriptionIAMMember) GetID() string

+ func (tr *SubscriptionIAMMember) GetObservation() (map[string]any, error)

+ func (tr *SubscriptionIAMMember) GetParameters() (map[string]any, error)

+ func (tr *SubscriptionIAMMember) GetTerraformSchemaVersion() int

+ 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 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

+ Etag *string

+ ID *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.Reference

+ SubscriptionSelector *v1.Selector

+ func (in *SubscriptionIAMMemberParameters) DeepCopy() *SubscriptionIAMMemberParameters

+ func (in *SubscriptionIAMMemberParameters) DeepCopyInto(out *SubscriptionIAMMemberParameters)

+ type SubscriptionIAMMemberSpec struct

+ ForProvider SubscriptionIAMMemberParameters

+ 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 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

+ ID *string

+ func (in *SubscriptionObservation) DeepCopy() *SubscriptionObservation

+ func (in *SubscriptionObservation) DeepCopyInto(out *SubscriptionObservation)

+ type SubscriptionParameters struct

+ AckDeadlineSeconds *float64

+ DeadLetterPolicy []DeadLetterPolicyParameters

+ EnableExactlyOnceDelivery *bool

+ EnableMessageOrdering *bool

+ ExpirationPolicy []ExpirationPolicyParameters

+ Filter *string

+ Labels map[string]*string

+ MessageRetentionDuration *string

+ Project *string

+ PushConfig []PushConfigParameters

+ RetainAckedMessages *bool

+ RetryPolicy []RetryPolicyParameters

+ Topic *string

+ TopicRef *v1.Reference

+ TopicSelector *v1.Selector

+ func (in *SubscriptionParameters) DeepCopy() *SubscriptionParameters

+ func (in *SubscriptionParameters) DeepCopyInto(out *SubscriptionParameters)

+ type SubscriptionSpec struct

+ ForProvider SubscriptionParameters

+ 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 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) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *Topic) GetProviderConfigReference() *xpv1.Reference

+ func (mg *Topic) GetProviderReference() *xpv1.Reference

+ func (mg *Topic) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *Topic) GetTerraformResourceType() string

+ func (mg *Topic) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *Topic) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *Topic) SetConditions(c ...xpv1.Condition)

+ func (mg *Topic) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *Topic) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *Topic) SetProviderReference(r *xpv1.Reference)

+ func (mg *Topic) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *Topic) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *Topic) GetConnectionDetailsMapping() map[string]string

+ func (tr *Topic) GetID() string

+ func (tr *Topic) GetObservation() (map[string]any, error)

+ func (tr *Topic) GetParameters() (map[string]any, error)

+ func (tr *Topic) GetTerraformSchemaVersion() int

+ 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) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *TopicIAMMember) GetProviderConfigReference() *xpv1.Reference

+ func (mg *TopicIAMMember) GetProviderReference() *xpv1.Reference

+ func (mg *TopicIAMMember) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *TopicIAMMember) GetTerraformResourceType() string

+ func (mg *TopicIAMMember) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *TopicIAMMember) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *TopicIAMMember) SetConditions(c ...xpv1.Condition)

+ func (mg *TopicIAMMember) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *TopicIAMMember) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *TopicIAMMember) SetProviderReference(r *xpv1.Reference)

+ func (mg *TopicIAMMember) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *TopicIAMMember) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *TopicIAMMember) GetConnectionDetailsMapping() map[string]string

+ func (tr *TopicIAMMember) GetID() string

+ func (tr *TopicIAMMember) GetObservation() (map[string]any, error)

+ func (tr *TopicIAMMember) GetParameters() (map[string]any, error)

+ func (tr *TopicIAMMember) GetTerraformSchemaVersion() int

+ 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 TopicIAMMemberConditionObservation struct

+ 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 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

+ Etag *string

+ ID *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.Reference

+ TopicSelector *v1.Selector

+ func (in *TopicIAMMemberParameters) DeepCopy() *TopicIAMMemberParameters

+ func (in *TopicIAMMemberParameters) DeepCopyInto(out *TopicIAMMemberParameters)

+ type TopicIAMMemberSpec struct

+ ForProvider TopicIAMMemberParameters

+ 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 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 TopicObservation struct

+ ID *string

+ func (in *TopicObservation) DeepCopy() *TopicObservation

+ func (in *TopicObservation) DeepCopyInto(out *TopicObservation)

+ type TopicParameters struct

+ KMSKeyName *string

+ KMSKeyNameRef *v1.Reference

+ KMSKeyNameSelector *v1.Selector

+ Labels map[string]*string

+ MessageRetentionDuration *string

+ MessageStoragePolicy []MessageStoragePolicyParameters

+ Project *string

+ SchemaSettings []SchemaSettingsParameters

+ func (in *TopicParameters) DeepCopy() *TopicParameters

+ func (in *TopicParameters) DeepCopyInto(out *TopicParameters)

+ type TopicSpec struct

+ ForProvider TopicParameters

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