Documentation ¶
Overview ¶
+kubebuilder:object:generate=true +groupName=pubsub.gcp.upbound.io +versionName=v1beta1
Index ¶
- Constants
- Variables
- type AvroConfigInitParameters
- type AvroConfigObservation
- type AvroConfigParameters
- type BigqueryConfigInitParameters
- type BigqueryConfigObservation
- type BigqueryConfigParameters
- type CapacityInitParameters
- type CapacityObservation
- type CapacityParameters
- type CloudStorageConfigInitParameters
- type CloudStorageConfigObservation
- type CloudStorageConfigParameters
- type ConditionInitParameters
- type ConditionObservation
- type ConditionParameters
- type DeadLetterPolicyInitParameters
- type DeadLetterPolicyObservation
- type DeadLetterPolicyParameters
- type DeliveryConfigInitParameters
- type DeliveryConfigObservation
- type DeliveryConfigParameters
- type ExpirationPolicyInitParameters
- type ExpirationPolicyObservation
- type ExpirationPolicyParameters
- type LiteReservation
- 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 (tr *LiteReservation) GetConnectionDetailsMapping() map[string]string
- func (mg *LiteReservation) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *LiteReservation) GetID() string
- func (tr *LiteReservation) GetInitParameters() (map[string]any, error)
- func (mg *LiteReservation) GetManagementPolicies() xpv1.ManagementPolicies
- 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 (mg *LiteReservation) GetProviderConfigReference() *xpv1.Reference
- func (mg *LiteReservation) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *LiteReservation) GetTerraformResourceType() string
- func (tr *LiteReservation) GetTerraformSchemaVersion() int
- func (mg *LiteReservation) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *LiteReservation) Hub()
- func (tr *LiteReservation) LateInitialize(attrs []byte) (bool, error)
- func (mg *LiteReservation) SetConditions(c ...xpv1.Condition)
- func (mg *LiteReservation) SetDeletionPolicy(r xpv1.DeletionPolicy)
- func (mg *LiteReservation) SetManagementPolicies(r xpv1.ManagementPolicies)
- func (tr *LiteReservation) SetObservation(obs map[string]any) error
- func (tr *LiteReservation) SetParameters(params map[string]any) error
- func (mg *LiteReservation) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *LiteReservation) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *LiteReservation) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type LiteReservationInitParameters
- type LiteReservationList
- type LiteReservationObservation
- type LiteReservationParameters
- type LiteReservationSpec
- type LiteReservationStatus
- type LiteSubscription
- func (tr *LiteSubscription) ConvertFrom(srcRaw conversion.Hub) error
- func (tr *LiteSubscription) ConvertTo(dstRaw conversion.Hub) error
- 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 (tr *LiteSubscription) GetConnectionDetailsMapping() map[string]string
- func (mg *LiteSubscription) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *LiteSubscription) GetID() string
- func (tr *LiteSubscription) GetInitParameters() (map[string]any, error)
- func (mg *LiteSubscription) GetManagementPolicies() xpv1.ManagementPolicies
- 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 (mg *LiteSubscription) GetProviderConfigReference() *xpv1.Reference
- func (mg *LiteSubscription) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *LiteSubscription) GetTerraformResourceType() string
- func (tr *LiteSubscription) GetTerraformSchemaVersion() int
- func (mg *LiteSubscription) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *LiteSubscription) LateInitialize(attrs []byte) (bool, error)
- 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) SetManagementPolicies(r xpv1.ManagementPolicies)
- func (tr *LiteSubscription) SetObservation(obs map[string]any) error
- func (tr *LiteSubscription) SetParameters(params map[string]any) error
- func (mg *LiteSubscription) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *LiteSubscription) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *LiteSubscription) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type LiteSubscriptionInitParameters
- type LiteSubscriptionList
- type LiteSubscriptionObservation
- type LiteSubscriptionParameters
- type LiteSubscriptionSpec
- type LiteSubscriptionStatus
- type LiteTopic
- func (tr *LiteTopic) ConvertFrom(srcRaw conversion.Hub) error
- func (tr *LiteTopic) ConvertTo(dstRaw conversion.Hub) error
- 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 (tr *LiteTopic) GetConnectionDetailsMapping() map[string]string
- func (mg *LiteTopic) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *LiteTopic) GetID() string
- func (tr *LiteTopic) GetInitParameters() (map[string]any, error)
- func (mg *LiteTopic) GetManagementPolicies() xpv1.ManagementPolicies
- 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 (mg *LiteTopic) GetProviderConfigReference() *xpv1.Reference
- func (mg *LiteTopic) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *LiteTopic) GetTerraformResourceType() string
- func (tr *LiteTopic) GetTerraformSchemaVersion() int
- func (mg *LiteTopic) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *LiteTopic) LateInitialize(attrs []byte) (bool, error)
- 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) SetManagementPolicies(r xpv1.ManagementPolicies)
- func (tr *LiteTopic) SetObservation(obs map[string]any) error
- func (tr *LiteTopic) SetParameters(params map[string]any) error
- func (mg *LiteTopic) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *LiteTopic) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *LiteTopic) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type LiteTopicInitParameters
- type LiteTopicList
- type LiteTopicObservation
- type LiteTopicParameters
- type LiteTopicSpec
- type LiteTopicStatus
- type MessageStoragePolicyInitParameters
- type MessageStoragePolicyObservation
- type MessageStoragePolicyParameters
- type NoWrapperInitParameters
- type NoWrapperObservation
- type NoWrapperParameters
- type OidcTokenInitParameters
- type OidcTokenObservation
- type OidcTokenParameters
- type PartitionConfigInitParameters
- type PartitionConfigObservation
- type PartitionConfigParameters
- type PushConfigInitParameters
- type PushConfigObservation
- type PushConfigParameters
- type ReservationConfigInitParameters
- type ReservationConfigObservation
- type ReservationConfigParameters
- type RetentionConfigInitParameters
- type RetentionConfigObservation
- type RetentionConfigParameters
- type RetryPolicyInitParameters
- type RetryPolicyObservation
- type RetryPolicyParameters
- type Schema
- 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 (tr *Schema) GetConnectionDetailsMapping() map[string]string
- func (mg *Schema) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *Schema) GetID() string
- func (tr *Schema) GetInitParameters() (map[string]any, error)
- func (mg *Schema) GetManagementPolicies() xpv1.ManagementPolicies
- 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 (mg *Schema) GetProviderConfigReference() *xpv1.Reference
- func (mg *Schema) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *Schema) GetTerraformResourceType() string
- func (tr *Schema) GetTerraformSchemaVersion() int
- func (mg *Schema) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *Schema) Hub()
- func (tr *Schema) LateInitialize(attrs []byte) (bool, error)
- func (mg *Schema) SetConditions(c ...xpv1.Condition)
- func (mg *Schema) SetDeletionPolicy(r xpv1.DeletionPolicy)
- func (mg *Schema) SetManagementPolicies(r xpv1.ManagementPolicies)
- func (tr *Schema) SetObservation(obs map[string]any) error
- func (tr *Schema) SetParameters(params map[string]any) error
- func (mg *Schema) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *Schema) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *Schema) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type SchemaInitParameters
- type SchemaList
- type SchemaObservation
- type SchemaParameters
- type SchemaSettingsInitParameters
- type SchemaSettingsObservation
- type SchemaSettingsParameters
- type SchemaSpec
- type SchemaStatus
- type Subscription
- func (tr *Subscription) ConvertFrom(srcRaw conversion.Hub) error
- func (tr *Subscription) ConvertTo(dstRaw conversion.Hub) error
- 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 (tr *Subscription) GetConnectionDetailsMapping() map[string]string
- func (mg *Subscription) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *Subscription) GetID() string
- func (tr *Subscription) GetInitParameters() (map[string]any, error)
- func (mg *Subscription) GetManagementPolicies() xpv1.ManagementPolicies
- 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 (mg *Subscription) GetProviderConfigReference() *xpv1.Reference
- func (mg *Subscription) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *Subscription) GetTerraformResourceType() string
- func (tr *Subscription) GetTerraformSchemaVersion() int
- func (mg *Subscription) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *Subscription) LateInitialize(attrs []byte) (bool, error)
- 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) SetManagementPolicies(r xpv1.ManagementPolicies)
- func (tr *Subscription) SetObservation(obs map[string]any) error
- func (tr *Subscription) SetParameters(params map[string]any) error
- func (mg *Subscription) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *Subscription) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *Subscription) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type SubscriptionIAMMember
- func (tr *SubscriptionIAMMember) ConvertFrom(srcRaw conversion.Hub) error
- func (tr *SubscriptionIAMMember) ConvertTo(dstRaw conversion.Hub) error
- 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 (tr *SubscriptionIAMMember) GetConnectionDetailsMapping() map[string]string
- func (mg *SubscriptionIAMMember) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *SubscriptionIAMMember) GetID() string
- func (tr *SubscriptionIAMMember) GetInitParameters() (map[string]any, error)
- func (mg *SubscriptionIAMMember) GetManagementPolicies() xpv1.ManagementPolicies
- 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 (mg *SubscriptionIAMMember) GetProviderConfigReference() *xpv1.Reference
- func (mg *SubscriptionIAMMember) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *SubscriptionIAMMember) GetTerraformResourceType() string
- func (tr *SubscriptionIAMMember) GetTerraformSchemaVersion() int
- func (mg *SubscriptionIAMMember) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *SubscriptionIAMMember) LateInitialize(attrs []byte) (bool, error)
- 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) SetManagementPolicies(r xpv1.ManagementPolicies)
- func (tr *SubscriptionIAMMember) SetObservation(obs map[string]any) error
- func (tr *SubscriptionIAMMember) SetParameters(params map[string]any) error
- func (mg *SubscriptionIAMMember) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *SubscriptionIAMMember) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *SubscriptionIAMMember) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type SubscriptionIAMMemberInitParameters
- type SubscriptionIAMMemberList
- type SubscriptionIAMMemberObservation
- type SubscriptionIAMMemberParameters
- type SubscriptionIAMMemberSpec
- type SubscriptionIAMMemberStatus
- type SubscriptionInitParameters
- type SubscriptionList
- type SubscriptionObservation
- type SubscriptionParameters
- type SubscriptionSpec
- type SubscriptionStatus
- type Topic
- func (tr *Topic) ConvertFrom(srcRaw conversion.Hub) error
- func (tr *Topic) ConvertTo(dstRaw conversion.Hub) error
- 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 (tr *Topic) GetConnectionDetailsMapping() map[string]string
- func (mg *Topic) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *Topic) GetID() string
- func (tr *Topic) GetInitParameters() (map[string]any, error)
- func (mg *Topic) GetManagementPolicies() xpv1.ManagementPolicies
- 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 (mg *Topic) GetProviderConfigReference() *xpv1.Reference
- func (mg *Topic) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *Topic) GetTerraformResourceType() string
- func (tr *Topic) GetTerraformSchemaVersion() int
- func (mg *Topic) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *Topic) LateInitialize(attrs []byte) (bool, error)
- 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) SetManagementPolicies(r xpv1.ManagementPolicies)
- func (tr *Topic) SetObservation(obs map[string]any) error
- func (tr *Topic) SetParameters(params map[string]any) error
- func (mg *Topic) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *Topic) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *Topic) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type TopicIAMMember
- func (tr *TopicIAMMember) ConvertFrom(srcRaw conversion.Hub) error
- func (tr *TopicIAMMember) ConvertTo(dstRaw conversion.Hub) error
- 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 (tr *TopicIAMMember) GetConnectionDetailsMapping() map[string]string
- func (mg *TopicIAMMember) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *TopicIAMMember) GetID() string
- func (tr *TopicIAMMember) GetInitParameters() (map[string]any, error)
- func (mg *TopicIAMMember) GetManagementPolicies() xpv1.ManagementPolicies
- 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 (mg *TopicIAMMember) GetProviderConfigReference() *xpv1.Reference
- func (mg *TopicIAMMember) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *TopicIAMMember) GetTerraformResourceType() string
- func (tr *TopicIAMMember) GetTerraformSchemaVersion() int
- func (mg *TopicIAMMember) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *TopicIAMMember) LateInitialize(attrs []byte) (bool, error)
- 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) SetManagementPolicies(r xpv1.ManagementPolicies)
- func (tr *TopicIAMMember) SetObservation(obs map[string]any) error
- func (tr *TopicIAMMember) SetParameters(params map[string]any) error
- func (mg *TopicIAMMember) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *TopicIAMMember) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *TopicIAMMember) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type TopicIAMMemberConditionInitParameters
- type TopicIAMMemberConditionObservation
- type TopicIAMMemberConditionParameters
- type TopicIAMMemberInitParameters
- type TopicIAMMemberList
- type TopicIAMMemberObservation
- type TopicIAMMemberParameters
- type TopicIAMMemberSpec
- type TopicIAMMemberStatus
- type TopicInitParameters
- type TopicList
- type TopicObservation
- type TopicParameters
- type TopicSpec
- type TopicStatus
Constants ¶
const ( CRDGroup = "pubsub.gcp.upbound.io" CRDVersion = "v1beta1" )
Package type metadata.
Variables ¶
var ( // CRDGroupVersion is the API Group Version used to register the objects CRDGroupVersion = schema.GroupVersion{Group: CRDGroup, Version: CRDVersion} // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = &scheme.Builder{GroupVersion: CRDGroupVersion} // AddToScheme adds the types in this group-version to the given scheme. AddToScheme = SchemeBuilder.AddToScheme )
var ( LiteReservation_Kind = "LiteReservation" LiteReservation_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: LiteReservation_Kind}.String() LiteReservation_KindAPIVersion = LiteReservation_Kind + "." + CRDGroupVersion.String() LiteReservation_GroupVersionKind = CRDGroupVersion.WithKind(LiteReservation_Kind) )
Repository type metadata.
var ( LiteSubscription_Kind = "LiteSubscription" LiteSubscription_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: LiteSubscription_Kind}.String() LiteSubscription_KindAPIVersion = LiteSubscription_Kind + "." + CRDGroupVersion.String() LiteSubscription_GroupVersionKind = CRDGroupVersion.WithKind(LiteSubscription_Kind) )
Repository type metadata.
var ( LiteTopic_Kind = "LiteTopic" LiteTopic_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: LiteTopic_Kind}.String() LiteTopic_KindAPIVersion = LiteTopic_Kind + "." + CRDGroupVersion.String() LiteTopic_GroupVersionKind = CRDGroupVersion.WithKind(LiteTopic_Kind) )
Repository type metadata.
var ( Schema_Kind = "Schema" Schema_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: Schema_Kind}.String() Schema_KindAPIVersion = Schema_Kind + "." + CRDGroupVersion.String() Schema_GroupVersionKind = CRDGroupVersion.WithKind(Schema_Kind) )
Repository type metadata.
var ( Subscription_Kind = "Subscription" Subscription_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: Subscription_Kind}.String() Subscription_KindAPIVersion = Subscription_Kind + "." + CRDGroupVersion.String() Subscription_GroupVersionKind = CRDGroupVersion.WithKind(Subscription_Kind) )
Repository type metadata.
var ( SubscriptionIAMMember_Kind = "SubscriptionIAMMember" SubscriptionIAMMember_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: SubscriptionIAMMember_Kind}.String() SubscriptionIAMMember_KindAPIVersion = SubscriptionIAMMember_Kind + "." + CRDGroupVersion.String() SubscriptionIAMMember_GroupVersionKind = CRDGroupVersion.WithKind(SubscriptionIAMMember_Kind) )
Repository type metadata.
var ( Topic_Kind = "Topic" Topic_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: Topic_Kind}.String() Topic_KindAPIVersion = Topic_Kind + "." + CRDGroupVersion.String() Topic_GroupVersionKind = CRDGroupVersion.WithKind(Topic_Kind) )
Repository type metadata.
var ( TopicIAMMember_Kind = "TopicIAMMember" TopicIAMMember_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: TopicIAMMember_Kind}.String() TopicIAMMember_KindAPIVersion = TopicIAMMember_Kind + "." + CRDGroupVersion.String() TopicIAMMember_GroupVersionKind = CRDGroupVersion.WithKind(TopicIAMMember_Kind) )
Repository type metadata.
Functions ¶
This section is empty.
Types ¶
type AvroConfigInitParameters ¶ added in v1.0.0
type AvroConfigInitParameters struct { // When true, writes the Pub/Sub message metadata to // x-goog-pubsub-<KEY>:<VAL> headers of the HTTP request. Writes the // Pub/Sub message attributes to <KEY>:<VAL> headers of the HTTP request. WriteMetadata *bool `json:"writeMetadata,omitempty" tf:"write_metadata,omitempty"` }
func (*AvroConfigInitParameters) DeepCopy ¶ added in v1.0.0
func (in *AvroConfigInitParameters) DeepCopy() *AvroConfigInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AvroConfigInitParameters.
func (*AvroConfigInitParameters) DeepCopyInto ¶ added in v1.0.0
func (in *AvroConfigInitParameters) DeepCopyInto(out *AvroConfigInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type AvroConfigObservation ¶ added in v1.0.0
type AvroConfigObservation struct { // When true, writes the Pub/Sub message metadata to // x-goog-pubsub-<KEY>:<VAL> headers of the HTTP request. Writes the // Pub/Sub message attributes to <KEY>:<VAL> headers of the HTTP request. WriteMetadata *bool `json:"writeMetadata,omitempty" tf:"write_metadata,omitempty"` }
func (*AvroConfigObservation) DeepCopy ¶ added in v1.0.0
func (in *AvroConfigObservation) DeepCopy() *AvroConfigObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AvroConfigObservation.
func (*AvroConfigObservation) DeepCopyInto ¶ added in v1.0.0
func (in *AvroConfigObservation) DeepCopyInto(out *AvroConfigObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type AvroConfigParameters ¶ added in v1.0.0
type AvroConfigParameters struct { // When true, writes the Pub/Sub message metadata to // x-goog-pubsub-<KEY>:<VAL> headers of the HTTP request. Writes the // Pub/Sub message attributes to <KEY>:<VAL> headers of the HTTP request. // +kubebuilder:validation:Optional WriteMetadata *bool `json:"writeMetadata,omitempty" tf:"write_metadata,omitempty"` }
func (*AvroConfigParameters) DeepCopy ¶ added in v1.0.0
func (in *AvroConfigParameters) DeepCopy() *AvroConfigParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AvroConfigParameters.
func (*AvroConfigParameters) DeepCopyInto ¶ added in v1.0.0
func (in *AvroConfigParameters) DeepCopyInto(out *AvroConfigParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BigqueryConfigInitParameters ¶ added in v0.35.0
type BigqueryConfigInitParameters struct { // When true and use_topic_schema or use_table_schema is true, any fields that are a part of the topic schema or message schema that // are not part of the BigQuery table schema are dropped when writing to BigQuery. Otherwise, the schemas must be kept in sync // and any messages with extra fields are not written and remain in the subscription's backlog. DropUnknownFields *bool `json:"dropUnknownFields,omitempty" tf:"drop_unknown_fields,omitempty"` // The name of the table to which to write data, of the form {projectId}:{datasetId}.{tableId} Table *string `json:"table,omitempty" tf:"table,omitempty"` // When true, use the BigQuery table's schema as the columns to write to in BigQuery. Messages // must be published in JSON format. Only one of use_topic_schema and use_table_schema can be set. UseTableSchema *bool `json:"useTableSchema,omitempty" tf:"use_table_schema,omitempty"` // When true, use the topic's schema as the columns to write to in BigQuery, if it exists. // Only one of use_topic_schema and use_table_schema can be set. UseTopicSchema *bool `json:"useTopicSchema,omitempty" tf:"use_topic_schema,omitempty"` // When true, write the subscription name, messageId, publishTime, attributes, and orderingKey to additional columns in the table. // The subscription name, messageId, and publishTime fields are put in their own columns while all other message properties (other than data) are written to a JSON object in the attributes column. WriteMetadata *bool `json:"writeMetadata,omitempty" tf:"write_metadata,omitempty"` }
func (*BigqueryConfigInitParameters) DeepCopy ¶ added in v0.35.0
func (in *BigqueryConfigInitParameters) DeepCopy() *BigqueryConfigInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BigqueryConfigInitParameters.
func (*BigqueryConfigInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *BigqueryConfigInitParameters) DeepCopyInto(out *BigqueryConfigInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BigqueryConfigObservation ¶ added in v0.26.0
type BigqueryConfigObservation struct { // When true and use_topic_schema or use_table_schema is true, any fields that are a part of the topic schema or message schema that // are not part of the BigQuery table schema are dropped when writing to BigQuery. Otherwise, the schemas must be kept in sync // and any messages with extra fields are not written and remain in the subscription's backlog. DropUnknownFields *bool `json:"dropUnknownFields,omitempty" tf:"drop_unknown_fields,omitempty"` // The name of the table to which to write data, of the form {projectId}:{datasetId}.{tableId} Table *string `json:"table,omitempty" tf:"table,omitempty"` // When true, use the BigQuery table's schema as the columns to write to in BigQuery. Messages // must be published in JSON format. Only one of use_topic_schema and use_table_schema can be set. UseTableSchema *bool `json:"useTableSchema,omitempty" tf:"use_table_schema,omitempty"` // When true, use the topic's schema as the columns to write to in BigQuery, if it exists. // Only one of use_topic_schema and use_table_schema can be set. UseTopicSchema *bool `json:"useTopicSchema,omitempty" tf:"use_topic_schema,omitempty"` // When true, write the subscription name, messageId, publishTime, attributes, and orderingKey to additional columns in the table. // The subscription name, messageId, and publishTime fields are put in their own columns while all other message properties (other than data) are written to a JSON object in the attributes column. WriteMetadata *bool `json:"writeMetadata,omitempty" tf:"write_metadata,omitempty"` }
func (*BigqueryConfigObservation) DeepCopy ¶ added in v0.26.0
func (in *BigqueryConfigObservation) DeepCopy() *BigqueryConfigObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BigqueryConfigObservation.
func (*BigqueryConfigObservation) DeepCopyInto ¶ added in v0.26.0
func (in *BigqueryConfigObservation) DeepCopyInto(out *BigqueryConfigObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BigqueryConfigParameters ¶ added in v0.26.0
type BigqueryConfigParameters struct { // When true and use_topic_schema or use_table_schema is true, any fields that are a part of the topic schema or message schema that // are not part of the BigQuery table schema are dropped when writing to BigQuery. Otherwise, the schemas must be kept in sync // and any messages with extra fields are not written and remain in the subscription's backlog. // +kubebuilder:validation:Optional DropUnknownFields *bool `json:"dropUnknownFields,omitempty" tf:"drop_unknown_fields,omitempty"` // The name of the table to which to write data, of the form {projectId}:{datasetId}.{tableId} // +kubebuilder:validation:Optional Table *string `json:"table" tf:"table,omitempty"` // When true, use the BigQuery table's schema as the columns to write to in BigQuery. Messages // must be published in JSON format. Only one of use_topic_schema and use_table_schema can be set. // +kubebuilder:validation:Optional UseTableSchema *bool `json:"useTableSchema,omitempty" tf:"use_table_schema,omitempty"` // When true, use the topic's schema as the columns to write to in BigQuery, if it exists. // Only one of use_topic_schema and use_table_schema can be set. // +kubebuilder:validation:Optional UseTopicSchema *bool `json:"useTopicSchema,omitempty" tf:"use_topic_schema,omitempty"` // When true, write the subscription name, messageId, publishTime, attributes, and orderingKey to additional columns in the table. // The subscription name, messageId, and publishTime fields are put in their own columns while all other message properties (other than data) are written to a JSON object in the attributes column. // +kubebuilder:validation:Optional WriteMetadata *bool `json:"writeMetadata,omitempty" tf:"write_metadata,omitempty"` }
func (*BigqueryConfigParameters) DeepCopy ¶ added in v0.26.0
func (in *BigqueryConfigParameters) DeepCopy() *BigqueryConfigParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BigqueryConfigParameters.
func (*BigqueryConfigParameters) DeepCopyInto ¶ added in v0.26.0
func (in *BigqueryConfigParameters) DeepCopyInto(out *BigqueryConfigParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CapacityInitParameters ¶ added in v0.35.0
type CapacityInitParameters struct { // Subscribe throughput capacity per partition in MiB/s. Must be >= 4 and <= 16. PublishMibPerSec *float64 `json:"publishMibPerSec,omitempty" tf:"publish_mib_per_sec,omitempty"` // Publish throughput capacity per partition in MiB/s. Must be >= 4 and <= 16. SubscribeMibPerSec *float64 `json:"subscribeMibPerSec,omitempty" tf:"subscribe_mib_per_sec,omitempty"` }
func (*CapacityInitParameters) DeepCopy ¶ added in v0.35.0
func (in *CapacityInitParameters) DeepCopy() *CapacityInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CapacityInitParameters.
func (*CapacityInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *CapacityInitParameters) DeepCopyInto(out *CapacityInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CapacityObservation ¶
type CapacityObservation struct { // Subscribe throughput capacity per partition in MiB/s. Must be >= 4 and <= 16. PublishMibPerSec *float64 `json:"publishMibPerSec,omitempty" tf:"publish_mib_per_sec,omitempty"` // Publish throughput capacity per partition in MiB/s. Must be >= 4 and <= 16. SubscribeMibPerSec *float64 `json:"subscribeMibPerSec,omitempty" tf:"subscribe_mib_per_sec,omitempty"` }
func (*CapacityObservation) DeepCopy ¶
func (in *CapacityObservation) DeepCopy() *CapacityObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CapacityObservation.
func (*CapacityObservation) DeepCopyInto ¶
func (in *CapacityObservation) DeepCopyInto(out *CapacityObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CapacityParameters ¶
type CapacityParameters struct { // Subscribe throughput capacity per partition in MiB/s. Must be >= 4 and <= 16. // +kubebuilder:validation:Optional PublishMibPerSec *float64 `json:"publishMibPerSec" tf:"publish_mib_per_sec,omitempty"` // Publish throughput capacity per partition in MiB/s. Must be >= 4 and <= 16. // +kubebuilder:validation:Optional SubscribeMibPerSec *float64 `json:"subscribeMibPerSec" tf:"subscribe_mib_per_sec,omitempty"` }
func (*CapacityParameters) DeepCopy ¶
func (in *CapacityParameters) DeepCopy() *CapacityParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CapacityParameters.
func (*CapacityParameters) DeepCopyInto ¶
func (in *CapacityParameters) DeepCopyInto(out *CapacityParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CloudStorageConfigInitParameters ¶ added in v1.0.0
type CloudStorageConfigInitParameters struct { // If set, message data will be written to Cloud Storage in Avro format. // Structure is documented below. AvroConfig []AvroConfigInitParameters `json:"avroConfig,omitempty" tf:"avro_config,omitempty"` // User-provided name for the Cloud Storage bucket. The bucket must be created by the user. The bucket name must be without any prefix like "gs://". Bucket *string `json:"bucket,omitempty" tf:"bucket,omitempty"` // User-provided prefix for Cloud Storage filename. FilenamePrefix *string `json:"filenamePrefix,omitempty" tf:"filename_prefix,omitempty"` // User-provided suffix for Cloud Storage filename. Must not end in "/". FilenameSuffix *string `json:"filenameSuffix,omitempty" tf:"filename_suffix,omitempty"` // The maximum bytes that can be written to a Cloud Storage file before a new file is created. Min 1 KB, max 10 GiB. // The maxBytes limit may be exceeded in cases where messages are larger than the limit. MaxBytes *float64 `json:"maxBytes,omitempty" tf:"max_bytes,omitempty"` // The maximum duration that can elapse before a new Cloud Storage file is created. Min 1 minute, max 10 minutes, default 5 minutes. // May not exceed the subscription's acknowledgement deadline. // A duration in seconds with up to nine fractional digits, ending with 's'. Example: "3.5s". MaxDuration *string `json:"maxDuration,omitempty" tf:"max_duration,omitempty"` }
func (*CloudStorageConfigInitParameters) DeepCopy ¶ added in v1.0.0
func (in *CloudStorageConfigInitParameters) DeepCopy() *CloudStorageConfigInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudStorageConfigInitParameters.
func (*CloudStorageConfigInitParameters) DeepCopyInto ¶ added in v1.0.0
func (in *CloudStorageConfigInitParameters) DeepCopyInto(out *CloudStorageConfigInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CloudStorageConfigObservation ¶ added in v1.0.0
type CloudStorageConfigObservation struct { // If set, message data will be written to Cloud Storage in Avro format. // Structure is documented below. AvroConfig []AvroConfigObservation `json:"avroConfig,omitempty" tf:"avro_config,omitempty"` // User-provided name for the Cloud Storage bucket. The bucket must be created by the user. The bucket name must be without any prefix like "gs://". Bucket *string `json:"bucket,omitempty" tf:"bucket,omitempty"` // User-provided prefix for Cloud Storage filename. FilenamePrefix *string `json:"filenamePrefix,omitempty" tf:"filename_prefix,omitempty"` // User-provided suffix for Cloud Storage filename. Must not end in "/". FilenameSuffix *string `json:"filenameSuffix,omitempty" tf:"filename_suffix,omitempty"` // The maximum bytes that can be written to a Cloud Storage file before a new file is created. Min 1 KB, max 10 GiB. // The maxBytes limit may be exceeded in cases where messages are larger than the limit. MaxBytes *float64 `json:"maxBytes,omitempty" tf:"max_bytes,omitempty"` // The maximum duration that can elapse before a new Cloud Storage file is created. Min 1 minute, max 10 minutes, default 5 minutes. // May not exceed the subscription's acknowledgement deadline. // A duration in seconds with up to nine fractional digits, ending with 's'. Example: "3.5s". MaxDuration *string `json:"maxDuration,omitempty" tf:"max_duration,omitempty"` // (Output) // An output-only field that indicates whether or not the subscription can receive messages. State *string `json:"state,omitempty" tf:"state,omitempty"` }
func (*CloudStorageConfigObservation) DeepCopy ¶ added in v1.0.0
func (in *CloudStorageConfigObservation) DeepCopy() *CloudStorageConfigObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudStorageConfigObservation.
func (*CloudStorageConfigObservation) DeepCopyInto ¶ added in v1.0.0
func (in *CloudStorageConfigObservation) DeepCopyInto(out *CloudStorageConfigObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CloudStorageConfigParameters ¶ added in v1.0.0
type CloudStorageConfigParameters struct { // If set, message data will be written to Cloud Storage in Avro format. // Structure is documented below. // +kubebuilder:validation:Optional AvroConfig []AvroConfigParameters `json:"avroConfig,omitempty" tf:"avro_config,omitempty"` // User-provided name for the Cloud Storage bucket. The bucket must be created by the user. The bucket name must be without any prefix like "gs://". // +kubebuilder:validation:Optional Bucket *string `json:"bucket" tf:"bucket,omitempty"` // User-provided prefix for Cloud Storage filename. // +kubebuilder:validation:Optional FilenamePrefix *string `json:"filenamePrefix,omitempty" tf:"filename_prefix,omitempty"` // User-provided suffix for Cloud Storage filename. Must not end in "/". // +kubebuilder:validation:Optional FilenameSuffix *string `json:"filenameSuffix,omitempty" tf:"filename_suffix,omitempty"` // The maximum bytes that can be written to a Cloud Storage file before a new file is created. Min 1 KB, max 10 GiB. // The maxBytes limit may be exceeded in cases where messages are larger than the limit. // +kubebuilder:validation:Optional MaxBytes *float64 `json:"maxBytes,omitempty" tf:"max_bytes,omitempty"` // The maximum duration that can elapse before a new Cloud Storage file is created. Min 1 minute, max 10 minutes, default 5 minutes. // May not exceed the subscription's acknowledgement deadline. // A duration in seconds with up to nine fractional digits, ending with 's'. Example: "3.5s". // +kubebuilder:validation:Optional MaxDuration *string `json:"maxDuration,omitempty" tf:"max_duration,omitempty"` }
func (*CloudStorageConfigParameters) DeepCopy ¶ added in v1.0.0
func (in *CloudStorageConfigParameters) DeepCopy() *CloudStorageConfigParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudStorageConfigParameters.
func (*CloudStorageConfigParameters) DeepCopyInto ¶ added in v1.0.0
func (in *CloudStorageConfigParameters) DeepCopyInto(out *CloudStorageConfigParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConditionInitParameters ¶ added in v0.35.0
type ConditionInitParameters struct { Description *string `json:"description,omitempty" tf:"description,omitempty"` Expression *string `json:"expression,omitempty" tf:"expression,omitempty"` Title *string `json:"title,omitempty" tf:"title,omitempty"` }
func (*ConditionInitParameters) DeepCopy ¶ added in v0.35.0
func (in *ConditionInitParameters) DeepCopy() *ConditionInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConditionInitParameters.
func (*ConditionInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *ConditionInitParameters) DeepCopyInto(out *ConditionInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConditionObservation ¶
type ConditionObservation struct { Description *string `json:"description,omitempty" tf:"description,omitempty"` Expression *string `json:"expression,omitempty" tf:"expression,omitempty"` Title *string `json:"title,omitempty" tf:"title,omitempty"` }
func (*ConditionObservation) DeepCopy ¶
func (in *ConditionObservation) DeepCopy() *ConditionObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConditionObservation.
func (*ConditionObservation) DeepCopyInto ¶
func (in *ConditionObservation) DeepCopyInto(out *ConditionObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConditionParameters ¶
type ConditionParameters struct { // +kubebuilder:validation:Optional Description *string `json:"description,omitempty" tf:"description,omitempty"` // +kubebuilder:validation:Optional Expression *string `json:"expression" tf:"expression,omitempty"` // +kubebuilder:validation:Optional Title *string `json:"title" tf:"title,omitempty"` }
func (*ConditionParameters) DeepCopy ¶
func (in *ConditionParameters) DeepCopy() *ConditionParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConditionParameters.
func (*ConditionParameters) DeepCopyInto ¶
func (in *ConditionParameters) DeepCopyInto(out *ConditionParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeadLetterPolicyInitParameters ¶ added in v0.35.0
type DeadLetterPolicyInitParameters struct { // The name of the topic to which dead letter messages should be published. // Format is projects/{project}/topics/{topic}. // The Cloud Pub/Sub service account associated with the enclosing subscription's // parent project (i.e., // service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have // permission to Publish() to this topic. // The operation will fail if the topic does not exist. // Users should ensure that there is a subscription attached to this topic // since messages published to a topic with no subscriptions are lost. // +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/pubsub/v1beta1.Topic // +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractResourceID() DeadLetterTopic *string `json:"deadLetterTopic,omitempty" tf:"dead_letter_topic,omitempty"` // Reference to a Topic in pubsub to populate deadLetterTopic. // +kubebuilder:validation:Optional DeadLetterTopicRef *v1.Reference `json:"deadLetterTopicRef,omitempty" tf:"-"` // Selector for a Topic in pubsub to populate deadLetterTopic. // +kubebuilder:validation:Optional DeadLetterTopicSelector *v1.Selector `json:"deadLetterTopicSelector,omitempty" tf:"-"` // The maximum number of delivery attempts for any message. The value must be // between 5 and 100. // The number of delivery attempts is defined as 1 + (the sum of number of // NACKs and number of times the acknowledgement deadline has been exceeded for the message). // A NACK is any call to ModifyAckDeadline with a 0 deadline. Note that // client libraries may automatically extend ack_deadlines. // This field will be honored on a best effort basis. // If this parameter is 0, a default value of 5 is used. MaxDeliveryAttempts *float64 `json:"maxDeliveryAttempts,omitempty" tf:"max_delivery_attempts,omitempty"` }
func (*DeadLetterPolicyInitParameters) DeepCopy ¶ added in v0.35.0
func (in *DeadLetterPolicyInitParameters) DeepCopy() *DeadLetterPolicyInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeadLetterPolicyInitParameters.
func (*DeadLetterPolicyInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *DeadLetterPolicyInitParameters) DeepCopyInto(out *DeadLetterPolicyInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeadLetterPolicyObservation ¶
type DeadLetterPolicyObservation struct { // The name of the topic to which dead letter messages should be published. // Format is projects/{project}/topics/{topic}. // The Cloud Pub/Sub service account associated with the enclosing subscription's // parent project (i.e., // service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have // permission to Publish() to this topic. // The operation will fail if the topic does not exist. // Users should ensure that there is a subscription attached to this topic // since messages published to a topic with no subscriptions are lost. DeadLetterTopic *string `json:"deadLetterTopic,omitempty" tf:"dead_letter_topic,omitempty"` // The maximum number of delivery attempts for any message. The value must be // between 5 and 100. // The number of delivery attempts is defined as 1 + (the sum of number of // NACKs and number of times the acknowledgement deadline has been exceeded for the message). // A NACK is any call to ModifyAckDeadline with a 0 deadline. Note that // client libraries may automatically extend ack_deadlines. // This field will be honored on a best effort basis. // If this parameter is 0, a default value of 5 is used. MaxDeliveryAttempts *float64 `json:"maxDeliveryAttempts,omitempty" tf:"max_delivery_attempts,omitempty"` }
func (*DeadLetterPolicyObservation) DeepCopy ¶
func (in *DeadLetterPolicyObservation) DeepCopy() *DeadLetterPolicyObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeadLetterPolicyObservation.
func (*DeadLetterPolicyObservation) DeepCopyInto ¶
func (in *DeadLetterPolicyObservation) DeepCopyInto(out *DeadLetterPolicyObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeadLetterPolicyParameters ¶
type DeadLetterPolicyParameters struct { // The name of the topic to which dead letter messages should be published. // Format is projects/{project}/topics/{topic}. // The Cloud Pub/Sub service account associated with the enclosing subscription's // parent project (i.e., // service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have // permission to Publish() to this topic. // The operation will fail if the topic does not exist. // Users should ensure that there is a subscription attached to this topic // since messages published to a topic with no subscriptions are lost. // +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/pubsub/v1beta1.Topic // +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractResourceID() // +kubebuilder:validation:Optional DeadLetterTopic *string `json:"deadLetterTopic,omitempty" tf:"dead_letter_topic,omitempty"` // Reference to a Topic in pubsub to populate deadLetterTopic. // +kubebuilder:validation:Optional DeadLetterTopicRef *v1.Reference `json:"deadLetterTopicRef,omitempty" tf:"-"` // Selector for a Topic in pubsub to populate deadLetterTopic. // +kubebuilder:validation:Optional DeadLetterTopicSelector *v1.Selector `json:"deadLetterTopicSelector,omitempty" tf:"-"` // The maximum number of delivery attempts for any message. The value must be // between 5 and 100. // The number of delivery attempts is defined as 1 + (the sum of number of // NACKs and number of times the acknowledgement deadline has been exceeded for the message). // A NACK is any call to ModifyAckDeadline with a 0 deadline. Note that // client libraries may automatically extend ack_deadlines. // This field will be honored on a best effort basis. // If this parameter is 0, a default value of 5 is used. // +kubebuilder:validation:Optional MaxDeliveryAttempts *float64 `json:"maxDeliveryAttempts,omitempty" tf:"max_delivery_attempts,omitempty"` }
func (*DeadLetterPolicyParameters) DeepCopy ¶
func (in *DeadLetterPolicyParameters) DeepCopy() *DeadLetterPolicyParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeadLetterPolicyParameters.
func (*DeadLetterPolicyParameters) DeepCopyInto ¶
func (in *DeadLetterPolicyParameters) DeepCopyInto(out *DeadLetterPolicyParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeliveryConfigInitParameters ¶ added in v0.35.0
type DeliveryConfigInitParameters struct { // When this subscription should send messages to subscribers relative to messages persistence in storage. // Possible values are: DELIVER_IMMEDIATELY, DELIVER_AFTER_STORED, DELIVERY_REQUIREMENT_UNSPECIFIED. DeliveryRequirement *string `json:"deliveryRequirement,omitempty" tf:"delivery_requirement,omitempty"` }
func (*DeliveryConfigInitParameters) DeepCopy ¶ added in v0.35.0
func (in *DeliveryConfigInitParameters) DeepCopy() *DeliveryConfigInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeliveryConfigInitParameters.
func (*DeliveryConfigInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *DeliveryConfigInitParameters) DeepCopyInto(out *DeliveryConfigInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeliveryConfigObservation ¶
type DeliveryConfigObservation struct { // When this subscription should send messages to subscribers relative to messages persistence in storage. // Possible values are: DELIVER_IMMEDIATELY, DELIVER_AFTER_STORED, DELIVERY_REQUIREMENT_UNSPECIFIED. DeliveryRequirement *string `json:"deliveryRequirement,omitempty" tf:"delivery_requirement,omitempty"` }
func (*DeliveryConfigObservation) DeepCopy ¶
func (in *DeliveryConfigObservation) DeepCopy() *DeliveryConfigObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeliveryConfigObservation.
func (*DeliveryConfigObservation) DeepCopyInto ¶
func (in *DeliveryConfigObservation) DeepCopyInto(out *DeliveryConfigObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeliveryConfigParameters ¶
type DeliveryConfigParameters struct { // When this subscription should send messages to subscribers relative to messages persistence in storage. // Possible values are: DELIVER_IMMEDIATELY, DELIVER_AFTER_STORED, DELIVERY_REQUIREMENT_UNSPECIFIED. // +kubebuilder:validation:Optional DeliveryRequirement *string `json:"deliveryRequirement" tf:"delivery_requirement,omitempty"` }
func (*DeliveryConfigParameters) DeepCopy ¶
func (in *DeliveryConfigParameters) DeepCopy() *DeliveryConfigParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeliveryConfigParameters.
func (*DeliveryConfigParameters) DeepCopyInto ¶
func (in *DeliveryConfigParameters) DeepCopyInto(out *DeliveryConfigParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ExpirationPolicyInitParameters ¶ added in v0.35.0
type ExpirationPolicyInitParameters struct { // Specifies the "time-to-live" duration for an associated resource. The // resource expires if it is not active for a period of ttl. // If ttl is set to "", the associated resource never expires. // A duration in seconds with up to nine fractional digits, terminated by 's'. // Example - "3.5s". TTL *string `json:"ttl,omitempty" tf:"ttl,omitempty"` }
func (*ExpirationPolicyInitParameters) DeepCopy ¶ added in v0.35.0
func (in *ExpirationPolicyInitParameters) DeepCopy() *ExpirationPolicyInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExpirationPolicyInitParameters.
func (*ExpirationPolicyInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *ExpirationPolicyInitParameters) DeepCopyInto(out *ExpirationPolicyInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ExpirationPolicyObservation ¶
type ExpirationPolicyObservation struct { // Specifies the "time-to-live" duration for an associated resource. The // resource expires if it is not active for a period of ttl. // If ttl is set to "", the associated resource never expires. // A duration in seconds with up to nine fractional digits, terminated by 's'. // Example - "3.5s". TTL *string `json:"ttl,omitempty" tf:"ttl,omitempty"` }
func (*ExpirationPolicyObservation) DeepCopy ¶
func (in *ExpirationPolicyObservation) DeepCopy() *ExpirationPolicyObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExpirationPolicyObservation.
func (*ExpirationPolicyObservation) DeepCopyInto ¶
func (in *ExpirationPolicyObservation) DeepCopyInto(out *ExpirationPolicyObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ExpirationPolicyParameters ¶
type ExpirationPolicyParameters struct { // Specifies the "time-to-live" duration for an associated resource. The // resource expires if it is not active for a period of ttl. // If ttl is set to "", the associated resource never expires. // A duration in seconds with up to nine fractional digits, terminated by 's'. // Example - "3.5s". // +kubebuilder:validation:Optional TTL *string `json:"ttl" tf:"ttl,omitempty"` }
func (*ExpirationPolicyParameters) DeepCopy ¶
func (in *ExpirationPolicyParameters) DeepCopy() *ExpirationPolicyParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExpirationPolicyParameters.
func (*ExpirationPolicyParameters) DeepCopyInto ¶
func (in *ExpirationPolicyParameters) DeepCopyInto(out *ExpirationPolicyParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LiteReservation ¶
type LiteReservation struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` // +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.throughputCapacity) || (has(self.initProvider) && has(self.initProvider.throughputCapacity))",message="spec.forProvider.throughputCapacity is a required parameter" Spec LiteReservationSpec `json:"spec"` Status LiteReservationStatus `json:"status,omitempty"` }
LiteReservation is the Schema for the LiteReservations API. A named resource representing a shared pool of capacity. +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcp}
func (*LiteReservation) DeepCopy ¶
func (in *LiteReservation) DeepCopy() *LiteReservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteReservation.
func (*LiteReservation) DeepCopyInto ¶
func (in *LiteReservation) DeepCopyInto(out *LiteReservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*LiteReservation) DeepCopyObject ¶
func (in *LiteReservation) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*LiteReservation) GetCondition ¶
func (mg *LiteReservation) GetCondition(ct xpv1.ConditionType) xpv1.Condition
GetCondition of this LiteReservation.
func (*LiteReservation) GetConnectionDetailsMapping ¶
func (tr *LiteReservation) GetConnectionDetailsMapping() map[string]string
GetConnectionDetailsMapping for this LiteReservation
func (*LiteReservation) GetDeletionPolicy ¶
func (mg *LiteReservation) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this LiteReservation.
func (*LiteReservation) GetID ¶
func (tr *LiteReservation) GetID() string
GetID returns ID of underlying Terraform resource of this LiteReservation
func (*LiteReservation) GetInitParameters ¶ added in v0.35.0
func (tr *LiteReservation) GetInitParameters() (map[string]any, error)
GetInitParameters of this LiteReservation
func (*LiteReservation) GetManagementPolicies ¶ added in v0.35.0
func (mg *LiteReservation) GetManagementPolicies() xpv1.ManagementPolicies
GetManagementPolicies of this LiteReservation.
func (*LiteReservation) GetMergedParameters ¶ added in v0.40.0
func (tr *LiteReservation) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)
GetInitParameters of this LiteReservation
func (*LiteReservation) GetObservation ¶
func (tr *LiteReservation) GetObservation() (map[string]any, error)
GetObservation of this LiteReservation
func (*LiteReservation) GetParameters ¶
func (tr *LiteReservation) GetParameters() (map[string]any, error)
GetParameters of this LiteReservation
func (*LiteReservation) GetProviderConfigReference ¶
func (mg *LiteReservation) GetProviderConfigReference() *xpv1.Reference
GetProviderConfigReference of this LiteReservation.
func (*LiteReservation) GetPublishConnectionDetailsTo ¶
func (mg *LiteReservation) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this LiteReservation.
func (*LiteReservation) GetTerraformResourceType ¶
func (mg *LiteReservation) GetTerraformResourceType() string
GetTerraformResourceType returns Terraform resource type for this LiteReservation
func (*LiteReservation) GetTerraformSchemaVersion ¶
func (tr *LiteReservation) GetTerraformSchemaVersion() int
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*LiteReservation) GetWriteConnectionSecretToReference ¶
func (mg *LiteReservation) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this LiteReservation.
func (*LiteReservation) Hub ¶ added in v0.41.2
func (tr *LiteReservation) Hub()
Hub marks this type as a conversion hub.
func (*LiteReservation) LateInitialize ¶
func (tr *LiteReservation) LateInitialize(attrs []byte) (bool, error)
LateInitialize this LiteReservation using its observed tfState. returns True if there are any spec changes for the resource.
func (*LiteReservation) SetConditions ¶
func (mg *LiteReservation) SetConditions(c ...xpv1.Condition)
SetConditions of this LiteReservation.
func (*LiteReservation) SetDeletionPolicy ¶
func (mg *LiteReservation) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this LiteReservation.
func (*LiteReservation) SetManagementPolicies ¶ added in v0.35.0
func (mg *LiteReservation) SetManagementPolicies(r xpv1.ManagementPolicies)
SetManagementPolicies of this LiteReservation.
func (*LiteReservation) SetObservation ¶
func (tr *LiteReservation) SetObservation(obs map[string]any) error
SetObservation for this LiteReservation
func (*LiteReservation) SetParameters ¶
func (tr *LiteReservation) SetParameters(params map[string]any) error
SetParameters for this LiteReservation
func (*LiteReservation) SetProviderConfigReference ¶
func (mg *LiteReservation) SetProviderConfigReference(r *xpv1.Reference)
SetProviderConfigReference of this LiteReservation.
func (*LiteReservation) SetPublishConnectionDetailsTo ¶
func (mg *LiteReservation) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
SetPublishConnectionDetailsTo of this LiteReservation.
func (*LiteReservation) SetWriteConnectionSecretToReference ¶
func (mg *LiteReservation) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
SetWriteConnectionSecretToReference of this LiteReservation.
type LiteReservationInitParameters ¶ added in v0.35.0
type LiteReservationInitParameters struct { // The ID of the project in which the resource belongs. // If it is not provided, the provider project is used. Project *string `json:"project,omitempty" tf:"project,omitempty"` // The reserved throughput capacity. Every unit of throughput capacity is // equivalent to 1 MiB/s of published messages or 2 MiB/s of subscribed // messages. ThroughputCapacity *float64 `json:"throughputCapacity,omitempty" tf:"throughput_capacity,omitempty"` }
func (*LiteReservationInitParameters) DeepCopy ¶ added in v0.35.0
func (in *LiteReservationInitParameters) DeepCopy() *LiteReservationInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteReservationInitParameters.
func (*LiteReservationInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *LiteReservationInitParameters) DeepCopyInto(out *LiteReservationInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LiteReservationList ¶
type LiteReservationList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []LiteReservation `json:"items"` }
LiteReservationList contains a list of LiteReservations
func (*LiteReservationList) DeepCopy ¶
func (in *LiteReservationList) DeepCopy() *LiteReservationList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteReservationList.
func (*LiteReservationList) DeepCopyInto ¶
func (in *LiteReservationList) DeepCopyInto(out *LiteReservationList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*LiteReservationList) DeepCopyObject ¶
func (in *LiteReservationList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*LiteReservationList) GetItems ¶
func (l *LiteReservationList) GetItems() []resource.Managed
GetItems of this LiteReservationList.
type LiteReservationObservation ¶
type LiteReservationObservation struct { // an identifier for the resource with format projects/{{project}}/locations/{{region}}/reservations/{{name}} ID *string `json:"id,omitempty" tf:"id,omitempty"` // The ID of the project in which the resource belongs. // If it is not provided, the provider project is used. Project *string `json:"project,omitempty" tf:"project,omitempty"` // The region of the pubsub lite reservation. Region *string `json:"region,omitempty" tf:"region,omitempty"` // The reserved throughput capacity. Every unit of throughput capacity is // equivalent to 1 MiB/s of published messages or 2 MiB/s of subscribed // messages. ThroughputCapacity *float64 `json:"throughputCapacity,omitempty" tf:"throughput_capacity,omitempty"` }
func (*LiteReservationObservation) DeepCopy ¶
func (in *LiteReservationObservation) DeepCopy() *LiteReservationObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteReservationObservation.
func (*LiteReservationObservation) DeepCopyInto ¶
func (in *LiteReservationObservation) DeepCopyInto(out *LiteReservationObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LiteReservationParameters ¶
type LiteReservationParameters struct { // The ID of the project in which the resource belongs. // If it is not provided, the provider project is used. // +kubebuilder:validation:Optional Project *string `json:"project,omitempty" tf:"project,omitempty"` // The region of the pubsub lite reservation. // +kubebuilder:validation:Required Region *string `json:"region" tf:"region,omitempty"` // The reserved throughput capacity. Every unit of throughput capacity is // equivalent to 1 MiB/s of published messages or 2 MiB/s of subscribed // messages. // +kubebuilder:validation:Optional ThroughputCapacity *float64 `json:"throughputCapacity,omitempty" tf:"throughput_capacity,omitempty"` }
func (*LiteReservationParameters) DeepCopy ¶
func (in *LiteReservationParameters) DeepCopy() *LiteReservationParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteReservationParameters.
func (*LiteReservationParameters) DeepCopyInto ¶
func (in *LiteReservationParameters) DeepCopyInto(out *LiteReservationParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LiteReservationSpec ¶
type LiteReservationSpec struct { v1.ResourceSpec `json:",inline"` ForProvider LiteReservationParameters `json:"forProvider"` // THIS IS A BETA FIELD. It will be honored // unless the Management Policies feature flag is disabled. // InitProvider holds the same fields as ForProvider, with the exception // of Identifier and other resource reference fields. The fields that are // in InitProvider are merged into ForProvider when the resource is created. // The same fields are also added to the terraform ignore_changes hook, to // avoid updating them after creation. This is useful for fields that are // required on creation, but we do not desire to update them after creation, // for example because of an external controller is managing them, like an // autoscaler. InitProvider LiteReservationInitParameters `json:"initProvider,omitempty"` }
LiteReservationSpec defines the desired state of LiteReservation
func (*LiteReservationSpec) DeepCopy ¶
func (in *LiteReservationSpec) DeepCopy() *LiteReservationSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteReservationSpec.
func (*LiteReservationSpec) DeepCopyInto ¶
func (in *LiteReservationSpec) DeepCopyInto(out *LiteReservationSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LiteReservationStatus ¶
type LiteReservationStatus struct { v1.ResourceStatus `json:",inline"` AtProvider LiteReservationObservation `json:"atProvider,omitempty"` }
LiteReservationStatus defines the observed state of LiteReservation.
func (*LiteReservationStatus) DeepCopy ¶
func (in *LiteReservationStatus) DeepCopy() *LiteReservationStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteReservationStatus.
func (*LiteReservationStatus) DeepCopyInto ¶
func (in *LiteReservationStatus) DeepCopyInto(out *LiteReservationStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LiteSubscription ¶
type LiteSubscription struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec LiteSubscriptionSpec `json:"spec"` Status LiteSubscriptionStatus `json:"status,omitempty"` }
LiteSubscription is the Schema for the LiteSubscriptions API. A named resource representing the stream of messages from a single, specific topic, to be delivered to the subscribing application. +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcp}
func (*LiteSubscription) ConvertFrom ¶ added in v1.2.0
func (tr *LiteSubscription) ConvertFrom(srcRaw conversion.Hub) error
ConvertFrom converts from the hub type to the LiteSubscription type.
func (*LiteSubscription) ConvertTo ¶ added in v1.2.0
func (tr *LiteSubscription) ConvertTo(dstRaw conversion.Hub) error
ConvertTo converts this LiteSubscription to the hub type.
func (*LiteSubscription) DeepCopy ¶
func (in *LiteSubscription) DeepCopy() *LiteSubscription
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteSubscription.
func (*LiteSubscription) DeepCopyInto ¶
func (in *LiteSubscription) DeepCopyInto(out *LiteSubscription)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*LiteSubscription) DeepCopyObject ¶
func (in *LiteSubscription) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*LiteSubscription) GetCondition ¶
func (mg *LiteSubscription) GetCondition(ct xpv1.ConditionType) xpv1.Condition
GetCondition of this LiteSubscription.
func (*LiteSubscription) GetConnectionDetailsMapping ¶
func (tr *LiteSubscription) GetConnectionDetailsMapping() map[string]string
GetConnectionDetailsMapping for this LiteSubscription
func (*LiteSubscription) GetDeletionPolicy ¶
func (mg *LiteSubscription) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this LiteSubscription.
func (*LiteSubscription) GetID ¶
func (tr *LiteSubscription) GetID() string
GetID returns ID of underlying Terraform resource of this LiteSubscription
func (*LiteSubscription) GetInitParameters ¶ added in v0.35.0
func (tr *LiteSubscription) GetInitParameters() (map[string]any, error)
GetInitParameters of this LiteSubscription
func (*LiteSubscription) GetManagementPolicies ¶ added in v0.35.0
func (mg *LiteSubscription) GetManagementPolicies() xpv1.ManagementPolicies
GetManagementPolicies of this LiteSubscription.
func (*LiteSubscription) GetMergedParameters ¶ added in v0.40.0
func (tr *LiteSubscription) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)
GetInitParameters of this LiteSubscription
func (*LiteSubscription) GetObservation ¶
func (tr *LiteSubscription) GetObservation() (map[string]any, error)
GetObservation of this LiteSubscription
func (*LiteSubscription) GetParameters ¶
func (tr *LiteSubscription) GetParameters() (map[string]any, error)
GetParameters of this LiteSubscription
func (*LiteSubscription) GetProviderConfigReference ¶
func (mg *LiteSubscription) GetProviderConfigReference() *xpv1.Reference
GetProviderConfigReference of this LiteSubscription.
func (*LiteSubscription) GetPublishConnectionDetailsTo ¶
func (mg *LiteSubscription) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this LiteSubscription.
func (*LiteSubscription) GetTerraformResourceType ¶
func (mg *LiteSubscription) GetTerraformResourceType() string
GetTerraformResourceType returns Terraform resource type for this LiteSubscription
func (*LiteSubscription) GetTerraformSchemaVersion ¶
func (tr *LiteSubscription) GetTerraformSchemaVersion() int
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*LiteSubscription) GetWriteConnectionSecretToReference ¶
func (mg *LiteSubscription) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this LiteSubscription.
func (*LiteSubscription) LateInitialize ¶
func (tr *LiteSubscription) LateInitialize(attrs []byte) (bool, error)
LateInitialize this LiteSubscription using its observed tfState. returns True if there are any spec changes for the resource.
func (*LiteSubscription) ResolveReferences ¶
func (*LiteSubscription) SetConditions ¶
func (mg *LiteSubscription) SetConditions(c ...xpv1.Condition)
SetConditions of this LiteSubscription.
func (*LiteSubscription) SetDeletionPolicy ¶
func (mg *LiteSubscription) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this LiteSubscription.
func (*LiteSubscription) SetManagementPolicies ¶ added in v0.35.0
func (mg *LiteSubscription) SetManagementPolicies(r xpv1.ManagementPolicies)
SetManagementPolicies of this LiteSubscription.
func (*LiteSubscription) SetObservation ¶
func (tr *LiteSubscription) SetObservation(obs map[string]any) error
SetObservation for this LiteSubscription
func (*LiteSubscription) SetParameters ¶
func (tr *LiteSubscription) SetParameters(params map[string]any) error
SetParameters for this LiteSubscription
func (*LiteSubscription) SetProviderConfigReference ¶
func (mg *LiteSubscription) SetProviderConfigReference(r *xpv1.Reference)
SetProviderConfigReference of this LiteSubscription.
func (*LiteSubscription) SetPublishConnectionDetailsTo ¶
func (mg *LiteSubscription) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
SetPublishConnectionDetailsTo of this LiteSubscription.
func (*LiteSubscription) SetWriteConnectionSecretToReference ¶
func (mg *LiteSubscription) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
SetWriteConnectionSecretToReference of this LiteSubscription.
type LiteSubscriptionInitParameters ¶ added in v0.35.0
type LiteSubscriptionInitParameters struct { // The settings for this subscription's message delivery. // Structure is documented below. DeliveryConfig []DeliveryConfigInitParameters `json:"deliveryConfig,omitempty" tf:"delivery_config,omitempty"` // The ID of the project in which the resource belongs. // If it is not provided, the provider project is used. Project *string `json:"project,omitempty" tf:"project,omitempty"` // The region of the pubsub lite topic. Region *string `json:"region,omitempty" tf:"region,omitempty"` // A reference to a Topic resource. // +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/pubsub/v1beta1.LiteTopic Topic *string `json:"topic,omitempty" tf:"topic,omitempty"` // Reference to a LiteTopic in pubsub to populate topic. // +kubebuilder:validation:Optional TopicRef *v1.Reference `json:"topicRef,omitempty" tf:"-"` // Selector for a LiteTopic in pubsub to populate topic. // +kubebuilder:validation:Optional TopicSelector *v1.Selector `json:"topicSelector,omitempty" tf:"-"` }
func (*LiteSubscriptionInitParameters) DeepCopy ¶ added in v0.35.0
func (in *LiteSubscriptionInitParameters) DeepCopy() *LiteSubscriptionInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteSubscriptionInitParameters.
func (*LiteSubscriptionInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *LiteSubscriptionInitParameters) DeepCopyInto(out *LiteSubscriptionInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LiteSubscriptionList ¶
type LiteSubscriptionList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []LiteSubscription `json:"items"` }
LiteSubscriptionList contains a list of LiteSubscriptions
func (*LiteSubscriptionList) DeepCopy ¶
func (in *LiteSubscriptionList) DeepCopy() *LiteSubscriptionList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteSubscriptionList.
func (*LiteSubscriptionList) DeepCopyInto ¶
func (in *LiteSubscriptionList) DeepCopyInto(out *LiteSubscriptionList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*LiteSubscriptionList) DeepCopyObject ¶
func (in *LiteSubscriptionList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*LiteSubscriptionList) GetItems ¶
func (l *LiteSubscriptionList) GetItems() []resource.Managed
GetItems of this LiteSubscriptionList.
type LiteSubscriptionObservation ¶
type LiteSubscriptionObservation struct { // The settings for this subscription's message delivery. // Structure is documented below. DeliveryConfig []DeliveryConfigObservation `json:"deliveryConfig,omitempty" tf:"delivery_config,omitempty"` // an identifier for the resource with format projects/{{project}}/locations/{{zone}}/subscriptions/{{name}} ID *string `json:"id,omitempty" tf:"id,omitempty"` // The ID of the project in which the resource belongs. // If it is not provided, the provider project is used. Project *string `json:"project,omitempty" tf:"project,omitempty"` // The region of the pubsub lite topic. Region *string `json:"region,omitempty" tf:"region,omitempty"` // A reference to a Topic resource. Topic *string `json:"topic,omitempty" tf:"topic,omitempty"` // The zone of the pubsub lite topic. Zone *string `json:"zone,omitempty" tf:"zone,omitempty"` }
func (*LiteSubscriptionObservation) DeepCopy ¶
func (in *LiteSubscriptionObservation) DeepCopy() *LiteSubscriptionObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteSubscriptionObservation.
func (*LiteSubscriptionObservation) DeepCopyInto ¶
func (in *LiteSubscriptionObservation) DeepCopyInto(out *LiteSubscriptionObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LiteSubscriptionParameters ¶
type LiteSubscriptionParameters struct { // The settings for this subscription's message delivery. // Structure is documented below. // +kubebuilder:validation:Optional DeliveryConfig []DeliveryConfigParameters `json:"deliveryConfig,omitempty" tf:"delivery_config,omitempty"` // The ID of the project in which the resource belongs. // If it is not provided, the provider project is used. // +kubebuilder:validation:Optional Project *string `json:"project,omitempty" tf:"project,omitempty"` // The region of the pubsub lite topic. // +kubebuilder:validation:Optional Region *string `json:"region,omitempty" tf:"region,omitempty"` // A reference to a Topic resource. // +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/pubsub/v1beta1.LiteTopic // +kubebuilder:validation:Optional Topic *string `json:"topic,omitempty" tf:"topic,omitempty"` // Reference to a LiteTopic in pubsub to populate topic. // +kubebuilder:validation:Optional TopicRef *v1.Reference `json:"topicRef,omitempty" tf:"-"` // Selector for a LiteTopic in pubsub to populate topic. // +kubebuilder:validation:Optional TopicSelector *v1.Selector `json:"topicSelector,omitempty" tf:"-"` // The zone of the pubsub lite topic. // +kubebuilder:validation:Required Zone *string `json:"zone" tf:"zone,omitempty"` }
func (*LiteSubscriptionParameters) DeepCopy ¶
func (in *LiteSubscriptionParameters) DeepCopy() *LiteSubscriptionParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteSubscriptionParameters.
func (*LiteSubscriptionParameters) DeepCopyInto ¶
func (in *LiteSubscriptionParameters) DeepCopyInto(out *LiteSubscriptionParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LiteSubscriptionSpec ¶
type LiteSubscriptionSpec struct { v1.ResourceSpec `json:",inline"` ForProvider LiteSubscriptionParameters `json:"forProvider"` // THIS IS A BETA FIELD. It will be honored // unless the Management Policies feature flag is disabled. // InitProvider holds the same fields as ForProvider, with the exception // of Identifier and other resource reference fields. The fields that are // in InitProvider are merged into ForProvider when the resource is created. // The same fields are also added to the terraform ignore_changes hook, to // avoid updating them after creation. This is useful for fields that are // required on creation, but we do not desire to update them after creation, // for example because of an external controller is managing them, like an // autoscaler. InitProvider LiteSubscriptionInitParameters `json:"initProvider,omitempty"` }
LiteSubscriptionSpec defines the desired state of LiteSubscription
func (*LiteSubscriptionSpec) DeepCopy ¶
func (in *LiteSubscriptionSpec) DeepCopy() *LiteSubscriptionSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteSubscriptionSpec.
func (*LiteSubscriptionSpec) DeepCopyInto ¶
func (in *LiteSubscriptionSpec) DeepCopyInto(out *LiteSubscriptionSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LiteSubscriptionStatus ¶
type LiteSubscriptionStatus struct { v1.ResourceStatus `json:",inline"` AtProvider LiteSubscriptionObservation `json:"atProvider,omitempty"` }
LiteSubscriptionStatus defines the observed state of LiteSubscription.
func (*LiteSubscriptionStatus) DeepCopy ¶
func (in *LiteSubscriptionStatus) DeepCopy() *LiteSubscriptionStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteSubscriptionStatus.
func (*LiteSubscriptionStatus) DeepCopyInto ¶
func (in *LiteSubscriptionStatus) DeepCopyInto(out *LiteSubscriptionStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LiteTopic ¶
type LiteTopic struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` // +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.partitionConfig) || (has(self.initProvider) && has(self.initProvider.partitionConfig))",message="spec.forProvider.partitionConfig is a required parameter" // +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.retentionConfig) || (has(self.initProvider) && has(self.initProvider.retentionConfig))",message="spec.forProvider.retentionConfig is a required parameter" Spec LiteTopicSpec `json:"spec"` Status LiteTopicStatus `json:"status,omitempty"` }
LiteTopic is the Schema for the LiteTopics API. A named resource to which messages are sent by publishers. +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcp}
func (*LiteTopic) ConvertFrom ¶ added in v1.2.0
func (tr *LiteTopic) ConvertFrom(srcRaw conversion.Hub) error
ConvertFrom converts from the hub type to the LiteTopic type.
func (*LiteTopic) ConvertTo ¶ added in v1.2.0
func (tr *LiteTopic) ConvertTo(dstRaw conversion.Hub) error
ConvertTo converts this LiteTopic to the hub type.
func (*LiteTopic) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteTopic.
func (*LiteTopic) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*LiteTopic) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*LiteTopic) GetCondition ¶
func (mg *LiteTopic) GetCondition(ct xpv1.ConditionType) xpv1.Condition
GetCondition of this LiteTopic.
func (*LiteTopic) GetConnectionDetailsMapping ¶
GetConnectionDetailsMapping for this LiteTopic
func (*LiteTopic) GetDeletionPolicy ¶
func (mg *LiteTopic) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this LiteTopic.
func (*LiteTopic) GetInitParameters ¶ added in v0.35.0
GetInitParameters of this LiteTopic
func (*LiteTopic) GetManagementPolicies ¶ added in v0.35.0
func (mg *LiteTopic) GetManagementPolicies() xpv1.ManagementPolicies
GetManagementPolicies of this LiteTopic.
func (*LiteTopic) GetMergedParameters ¶ added in v0.40.0
GetInitParameters of this LiteTopic
func (*LiteTopic) GetObservation ¶
GetObservation of this LiteTopic
func (*LiteTopic) GetParameters ¶
GetParameters of this LiteTopic
func (*LiteTopic) GetProviderConfigReference ¶
GetProviderConfigReference of this LiteTopic.
func (*LiteTopic) GetPublishConnectionDetailsTo ¶
func (mg *LiteTopic) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this LiteTopic.
func (*LiteTopic) GetTerraformResourceType ¶
GetTerraformResourceType returns Terraform resource type for this LiteTopic
func (*LiteTopic) GetTerraformSchemaVersion ¶
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*LiteTopic) GetWriteConnectionSecretToReference ¶
func (mg *LiteTopic) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this LiteTopic.
func (*LiteTopic) LateInitialize ¶
LateInitialize this LiteTopic using its observed tfState. returns True if there are any spec changes for the resource.
func (*LiteTopic) ResolveReferences ¶
ResolveReferences of this LiteTopic.
func (*LiteTopic) SetConditions ¶
SetConditions of this LiteTopic.
func (*LiteTopic) SetDeletionPolicy ¶
func (mg *LiteTopic) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this LiteTopic.
func (*LiteTopic) SetManagementPolicies ¶ added in v0.35.0
func (mg *LiteTopic) SetManagementPolicies(r xpv1.ManagementPolicies)
SetManagementPolicies of this LiteTopic.
func (*LiteTopic) SetObservation ¶
SetObservation for this LiteTopic
func (*LiteTopic) SetParameters ¶
SetParameters for this LiteTopic
func (*LiteTopic) SetProviderConfigReference ¶
SetProviderConfigReference of this LiteTopic.
func (*LiteTopic) SetPublishConnectionDetailsTo ¶
func (mg *LiteTopic) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
SetPublishConnectionDetailsTo of this LiteTopic.
func (*LiteTopic) SetWriteConnectionSecretToReference ¶
func (mg *LiteTopic) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
SetWriteConnectionSecretToReference of this LiteTopic.
type LiteTopicInitParameters ¶ added in v0.35.0
type LiteTopicInitParameters struct { // The settings for this topic's partitions. // Structure is documented below. PartitionConfig []PartitionConfigInitParameters `json:"partitionConfig,omitempty" tf:"partition_config,omitempty"` // The ID of the project in which the resource belongs. // If it is not provided, the provider project is used. Project *string `json:"project,omitempty" tf:"project,omitempty"` // The region of the pubsub lite topic. Region *string `json:"region,omitempty" tf:"region,omitempty"` // The settings for this topic's Reservation usage. // Structure is documented below. ReservationConfig []ReservationConfigInitParameters `json:"reservationConfig,omitempty" tf:"reservation_config,omitempty"` // The settings for a topic's message retention. // Structure is documented below. RetentionConfig []RetentionConfigInitParameters `json:"retentionConfig,omitempty" tf:"retention_config,omitempty"` }
func (*LiteTopicInitParameters) DeepCopy ¶ added in v0.35.0
func (in *LiteTopicInitParameters) DeepCopy() *LiteTopicInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteTopicInitParameters.
func (*LiteTopicInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *LiteTopicInitParameters) DeepCopyInto(out *LiteTopicInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LiteTopicList ¶
type LiteTopicList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []LiteTopic `json:"items"` }
LiteTopicList contains a list of LiteTopics
func (*LiteTopicList) DeepCopy ¶
func (in *LiteTopicList) DeepCopy() *LiteTopicList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteTopicList.
func (*LiteTopicList) DeepCopyInto ¶
func (in *LiteTopicList) DeepCopyInto(out *LiteTopicList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*LiteTopicList) DeepCopyObject ¶
func (in *LiteTopicList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*LiteTopicList) GetItems ¶
func (l *LiteTopicList) GetItems() []resource.Managed
GetItems of this LiteTopicList.
type LiteTopicObservation ¶
type LiteTopicObservation struct { // an identifier for the resource with format projects/{{project}}/locations/{{zone}}/topics/{{name}} ID *string `json:"id,omitempty" tf:"id,omitempty"` // The settings for this topic's partitions. // Structure is documented below. PartitionConfig []PartitionConfigObservation `json:"partitionConfig,omitempty" tf:"partition_config,omitempty"` // The ID of the project in which the resource belongs. // If it is not provided, the provider project is used. Project *string `json:"project,omitempty" tf:"project,omitempty"` // The region of the pubsub lite topic. Region *string `json:"region,omitempty" tf:"region,omitempty"` // The settings for this topic's Reservation usage. // Structure is documented below. ReservationConfig []ReservationConfigObservation `json:"reservationConfig,omitempty" tf:"reservation_config,omitempty"` // The settings for a topic's message retention. // Structure is documented below. RetentionConfig []RetentionConfigObservation `json:"retentionConfig,omitempty" tf:"retention_config,omitempty"` // The zone of the pubsub lite topic. Zone *string `json:"zone,omitempty" tf:"zone,omitempty"` }
func (*LiteTopicObservation) DeepCopy ¶
func (in *LiteTopicObservation) DeepCopy() *LiteTopicObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteTopicObservation.
func (*LiteTopicObservation) DeepCopyInto ¶
func (in *LiteTopicObservation) DeepCopyInto(out *LiteTopicObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LiteTopicParameters ¶
type LiteTopicParameters struct { // The settings for this topic's partitions. // Structure is documented below. // +kubebuilder:validation:Optional PartitionConfig []PartitionConfigParameters `json:"partitionConfig,omitempty" tf:"partition_config,omitempty"` // The ID of the project in which the resource belongs. // If it is not provided, the provider project is used. // +kubebuilder:validation:Optional Project *string `json:"project,omitempty" tf:"project,omitempty"` // The region of the pubsub lite topic. // +kubebuilder:validation:Optional Region *string `json:"region,omitempty" tf:"region,omitempty"` // The settings for this topic's Reservation usage. // Structure is documented below. // +kubebuilder:validation:Optional ReservationConfig []ReservationConfigParameters `json:"reservationConfig,omitempty" tf:"reservation_config,omitempty"` // The settings for a topic's message retention. // Structure is documented below. // +kubebuilder:validation:Optional RetentionConfig []RetentionConfigParameters `json:"retentionConfig,omitempty" tf:"retention_config,omitempty"` // The zone of the pubsub lite topic. // +kubebuilder:validation:Required Zone *string `json:"zone" tf:"zone,omitempty"` }
func (*LiteTopicParameters) DeepCopy ¶
func (in *LiteTopicParameters) DeepCopy() *LiteTopicParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteTopicParameters.
func (*LiteTopicParameters) DeepCopyInto ¶
func (in *LiteTopicParameters) DeepCopyInto(out *LiteTopicParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LiteTopicSpec ¶
type LiteTopicSpec struct { v1.ResourceSpec `json:",inline"` ForProvider LiteTopicParameters `json:"forProvider"` // THIS IS A BETA FIELD. It will be honored // unless the Management Policies feature flag is disabled. // InitProvider holds the same fields as ForProvider, with the exception // of Identifier and other resource reference fields. The fields that are // in InitProvider are merged into ForProvider when the resource is created. // The same fields are also added to the terraform ignore_changes hook, to // avoid updating them after creation. This is useful for fields that are // required on creation, but we do not desire to update them after creation, // for example because of an external controller is managing them, like an // autoscaler. InitProvider LiteTopicInitParameters `json:"initProvider,omitempty"` }
LiteTopicSpec defines the desired state of LiteTopic
func (*LiteTopicSpec) DeepCopy ¶
func (in *LiteTopicSpec) DeepCopy() *LiteTopicSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteTopicSpec.
func (*LiteTopicSpec) DeepCopyInto ¶
func (in *LiteTopicSpec) DeepCopyInto(out *LiteTopicSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LiteTopicStatus ¶
type LiteTopicStatus struct { v1.ResourceStatus `json:",inline"` AtProvider LiteTopicObservation `json:"atProvider,omitempty"` }
LiteTopicStatus defines the observed state of LiteTopic.
func (*LiteTopicStatus) DeepCopy ¶
func (in *LiteTopicStatus) DeepCopy() *LiteTopicStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteTopicStatus.
func (*LiteTopicStatus) DeepCopyInto ¶
func (in *LiteTopicStatus) DeepCopyInto(out *LiteTopicStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MessageStoragePolicyInitParameters ¶ added in v0.35.0
type MessageStoragePolicyInitParameters struct { // A list of IDs of GCP regions where messages that are published to // the topic may be persisted in storage. Messages published by // publishers running in non-allowed GCP regions (or running outside // of GCP altogether) will be routed for storage in one of the // allowed regions. An empty list means that no regions are allowed, // and is not a valid configuration. AllowedPersistenceRegions []*string `json:"allowedPersistenceRegions,omitempty" tf:"allowed_persistence_regions,omitempty"` }
func (*MessageStoragePolicyInitParameters) DeepCopy ¶ added in v0.35.0
func (in *MessageStoragePolicyInitParameters) DeepCopy() *MessageStoragePolicyInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MessageStoragePolicyInitParameters.
func (*MessageStoragePolicyInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *MessageStoragePolicyInitParameters) DeepCopyInto(out *MessageStoragePolicyInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MessageStoragePolicyObservation ¶
type MessageStoragePolicyObservation struct { // A list of IDs of GCP regions where messages that are published to // the topic may be persisted in storage. Messages published by // publishers running in non-allowed GCP regions (or running outside // of GCP altogether) will be routed for storage in one of the // allowed regions. An empty list means that no regions are allowed, // and is not a valid configuration. AllowedPersistenceRegions []*string `json:"allowedPersistenceRegions,omitempty" tf:"allowed_persistence_regions,omitempty"` }
func (*MessageStoragePolicyObservation) DeepCopy ¶
func (in *MessageStoragePolicyObservation) DeepCopy() *MessageStoragePolicyObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MessageStoragePolicyObservation.
func (*MessageStoragePolicyObservation) DeepCopyInto ¶
func (in *MessageStoragePolicyObservation) DeepCopyInto(out *MessageStoragePolicyObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MessageStoragePolicyParameters ¶
type MessageStoragePolicyParameters struct { // A list of IDs of GCP regions where messages that are published to // the topic may be persisted in storage. Messages published by // publishers running in non-allowed GCP regions (or running outside // of GCP altogether) will be routed for storage in one of the // allowed regions. An empty list means that no regions are allowed, // and is not a valid configuration. // +kubebuilder:validation:Optional AllowedPersistenceRegions []*string `json:"allowedPersistenceRegions" tf:"allowed_persistence_regions,omitempty"` }
func (*MessageStoragePolicyParameters) DeepCopy ¶
func (in *MessageStoragePolicyParameters) DeepCopy() *MessageStoragePolicyParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MessageStoragePolicyParameters.
func (*MessageStoragePolicyParameters) DeepCopyInto ¶
func (in *MessageStoragePolicyParameters) DeepCopyInto(out *MessageStoragePolicyParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type NoWrapperInitParameters ¶ added in v0.37.0
type NoWrapperInitParameters struct { // When true, writes the Pub/Sub message metadata to // x-goog-pubsub-<KEY>:<VAL> headers of the HTTP request. Writes the // Pub/Sub message attributes to <KEY>:<VAL> headers of the HTTP request. WriteMetadata *bool `json:"writeMetadata,omitempty" tf:"write_metadata,omitempty"` }
func (*NoWrapperInitParameters) DeepCopy ¶ added in v0.37.0
func (in *NoWrapperInitParameters) DeepCopy() *NoWrapperInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NoWrapperInitParameters.
func (*NoWrapperInitParameters) DeepCopyInto ¶ added in v0.37.0
func (in *NoWrapperInitParameters) DeepCopyInto(out *NoWrapperInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type NoWrapperObservation ¶ added in v0.37.0
type NoWrapperObservation struct { // When true, writes the Pub/Sub message metadata to // x-goog-pubsub-<KEY>:<VAL> headers of the HTTP request. Writes the // Pub/Sub message attributes to <KEY>:<VAL> headers of the HTTP request. WriteMetadata *bool `json:"writeMetadata,omitempty" tf:"write_metadata,omitempty"` }
func (*NoWrapperObservation) DeepCopy ¶ added in v0.37.0
func (in *NoWrapperObservation) DeepCopy() *NoWrapperObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NoWrapperObservation.
func (*NoWrapperObservation) DeepCopyInto ¶ added in v0.37.0
func (in *NoWrapperObservation) DeepCopyInto(out *NoWrapperObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type NoWrapperParameters ¶ added in v0.37.0
type NoWrapperParameters struct { // When true, writes the Pub/Sub message metadata to // x-goog-pubsub-<KEY>:<VAL> headers of the HTTP request. Writes the // Pub/Sub message attributes to <KEY>:<VAL> headers of the HTTP request. // +kubebuilder:validation:Optional WriteMetadata *bool `json:"writeMetadata" tf:"write_metadata,omitempty"` }
func (*NoWrapperParameters) DeepCopy ¶ added in v0.37.0
func (in *NoWrapperParameters) DeepCopy() *NoWrapperParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NoWrapperParameters.
func (*NoWrapperParameters) DeepCopyInto ¶ added in v0.37.0
func (in *NoWrapperParameters) DeepCopyInto(out *NoWrapperParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OidcTokenInitParameters ¶ added in v0.35.0
type OidcTokenInitParameters struct { // Audience to be used when generating OIDC token. The audience claim // identifies the recipients that the JWT is intended for. The audience // value is a single case-sensitive string. Having multiple values (array) // for the audience field is not supported. More info about the OIDC JWT // token audience here: https://tools.ietf.org/html/rfc7519#section-4.1.3 // Note: if not specified, the Push endpoint URL will be used. Audience *string `json:"audience,omitempty" tf:"audience,omitempty"` // Service account email to be used for generating the OIDC token. // The caller (for subscriptions.create, subscriptions.patch, and // subscriptions.modifyPushConfig RPCs) must have the // iam.serviceAccounts.actAs permission for the service account. ServiceAccountEmail *string `json:"serviceAccountEmail,omitempty" tf:"service_account_email,omitempty"` }
func (*OidcTokenInitParameters) DeepCopy ¶ added in v0.35.0
func (in *OidcTokenInitParameters) DeepCopy() *OidcTokenInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OidcTokenInitParameters.
func (*OidcTokenInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *OidcTokenInitParameters) DeepCopyInto(out *OidcTokenInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OidcTokenObservation ¶
type OidcTokenObservation struct { // Audience to be used when generating OIDC token. The audience claim // identifies the recipients that the JWT is intended for. The audience // value is a single case-sensitive string. Having multiple values (array) // for the audience field is not supported. More info about the OIDC JWT // token audience here: https://tools.ietf.org/html/rfc7519#section-4.1.3 // Note: if not specified, the Push endpoint URL will be used. Audience *string `json:"audience,omitempty" tf:"audience,omitempty"` // Service account email to be used for generating the OIDC token. // The caller (for subscriptions.create, subscriptions.patch, and // subscriptions.modifyPushConfig RPCs) must have the // iam.serviceAccounts.actAs permission for the service account. ServiceAccountEmail *string `json:"serviceAccountEmail,omitempty" tf:"service_account_email,omitempty"` }
func (*OidcTokenObservation) DeepCopy ¶
func (in *OidcTokenObservation) DeepCopy() *OidcTokenObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OidcTokenObservation.
func (*OidcTokenObservation) DeepCopyInto ¶
func (in *OidcTokenObservation) DeepCopyInto(out *OidcTokenObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OidcTokenParameters ¶
type OidcTokenParameters struct { // Audience to be used when generating OIDC token. The audience claim // identifies the recipients that the JWT is intended for. The audience // value is a single case-sensitive string. Having multiple values (array) // for the audience field is not supported. More info about the OIDC JWT // token audience here: https://tools.ietf.org/html/rfc7519#section-4.1.3 // Note: if not specified, the Push endpoint URL will be used. // +kubebuilder:validation:Optional Audience *string `json:"audience,omitempty" tf:"audience,omitempty"` // Service account email to be used for generating the OIDC token. // The caller (for subscriptions.create, subscriptions.patch, and // subscriptions.modifyPushConfig RPCs) must have the // iam.serviceAccounts.actAs permission for the service account. // +kubebuilder:validation:Optional ServiceAccountEmail *string `json:"serviceAccountEmail" tf:"service_account_email,omitempty"` }
func (*OidcTokenParameters) DeepCopy ¶
func (in *OidcTokenParameters) DeepCopy() *OidcTokenParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OidcTokenParameters.
func (*OidcTokenParameters) DeepCopyInto ¶
func (in *OidcTokenParameters) DeepCopyInto(out *OidcTokenParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PartitionConfigInitParameters ¶ added in v0.35.0
type PartitionConfigInitParameters struct { // The capacity configuration. // Structure is documented below. Capacity []CapacityInitParameters `json:"capacity,omitempty" tf:"capacity,omitempty"` // The number of partitions in the topic. Must be at least 1. Count *float64 `json:"count,omitempty" tf:"count,omitempty"` }
func (*PartitionConfigInitParameters) DeepCopy ¶ added in v0.35.0
func (in *PartitionConfigInitParameters) DeepCopy() *PartitionConfigInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PartitionConfigInitParameters.
func (*PartitionConfigInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *PartitionConfigInitParameters) DeepCopyInto(out *PartitionConfigInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PartitionConfigObservation ¶
type PartitionConfigObservation struct { // The capacity configuration. // Structure is documented below. Capacity []CapacityObservation `json:"capacity,omitempty" tf:"capacity,omitempty"` // The number of partitions in the topic. Must be at least 1. Count *float64 `json:"count,omitempty" tf:"count,omitempty"` }
func (*PartitionConfigObservation) DeepCopy ¶
func (in *PartitionConfigObservation) DeepCopy() *PartitionConfigObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PartitionConfigObservation.
func (*PartitionConfigObservation) DeepCopyInto ¶
func (in *PartitionConfigObservation) DeepCopyInto(out *PartitionConfigObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PartitionConfigParameters ¶
type PartitionConfigParameters struct { // The capacity configuration. // Structure is documented below. // +kubebuilder:validation:Optional Capacity []CapacityParameters `json:"capacity,omitempty" tf:"capacity,omitempty"` // The number of partitions in the topic. Must be at least 1. // +kubebuilder:validation:Optional Count *float64 `json:"count" tf:"count,omitempty"` }
func (*PartitionConfigParameters) DeepCopy ¶
func (in *PartitionConfigParameters) DeepCopy() *PartitionConfigParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PartitionConfigParameters.
func (*PartitionConfigParameters) DeepCopyInto ¶
func (in *PartitionConfigParameters) DeepCopyInto(out *PartitionConfigParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PushConfigInitParameters ¶ added in v0.35.0
type PushConfigInitParameters struct { // Endpoint configuration attributes. // Every endpoint has a set of API supported attributes that can // be used to control different aspects of the message delivery. // The currently supported attribute is x-goog-version, which you // can use to change the format of the pushed message. This // attribute indicates the version of the data expected by // the endpoint. This controls the shape of the pushed message // (i.e., its fields and metadata). The endpoint version is // based on the version of the Pub/Sub API. // If not present during the subscriptions.create call, // it will default to the version of the API used to make // such call. If not present during a subscriptions.modifyPushConfig // call, its value will not be changed. subscriptions.get // calls will always return a valid version, even if the // subscription was created without this attribute. // The possible values for this attribute are: // +mapType=granular Attributes map[string]*string `json:"attributes,omitempty" tf:"attributes,omitempty"` // When set, the payload to the push endpoint is not wrapped.Sets the // data field as the HTTP body for delivery. // Structure is documented below. NoWrapper []NoWrapperInitParameters `json:"noWrapper,omitempty" tf:"no_wrapper,omitempty"` // If specified, Pub/Sub will generate and attach an OIDC JWT token as // an Authorization header in the HTTP request for every pushed message. // Structure is documented below. OidcToken []OidcTokenInitParameters `json:"oidcToken,omitempty" tf:"oidc_token,omitempty"` // A URL locating the endpoint to which messages should be pushed. // For example, a Webhook endpoint might use // "https://example.com/push". PushEndpoint *string `json:"pushEndpoint,omitempty" tf:"push_endpoint,omitempty"` }
func (*PushConfigInitParameters) DeepCopy ¶ added in v0.35.0
func (in *PushConfigInitParameters) DeepCopy() *PushConfigInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PushConfigInitParameters.
func (*PushConfigInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *PushConfigInitParameters) DeepCopyInto(out *PushConfigInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PushConfigObservation ¶
type PushConfigObservation struct { // Endpoint configuration attributes. // Every endpoint has a set of API supported attributes that can // be used to control different aspects of the message delivery. // The currently supported attribute is x-goog-version, which you // can use to change the format of the pushed message. This // attribute indicates the version of the data expected by // the endpoint. This controls the shape of the pushed message // (i.e., its fields and metadata). The endpoint version is // based on the version of the Pub/Sub API. // If not present during the subscriptions.create call, // it will default to the version of the API used to make // such call. If not present during a subscriptions.modifyPushConfig // call, its value will not be changed. subscriptions.get // calls will always return a valid version, even if the // subscription was created without this attribute. // The possible values for this attribute are: // +mapType=granular Attributes map[string]*string `json:"attributes,omitempty" tf:"attributes,omitempty"` // When set, the payload to the push endpoint is not wrapped.Sets the // data field as the HTTP body for delivery. // Structure is documented below. NoWrapper []NoWrapperObservation `json:"noWrapper,omitempty" tf:"no_wrapper,omitempty"` // If specified, Pub/Sub will generate and attach an OIDC JWT token as // an Authorization header in the HTTP request for every pushed message. // Structure is documented below. OidcToken []OidcTokenObservation `json:"oidcToken,omitempty" tf:"oidc_token,omitempty"` // A URL locating the endpoint to which messages should be pushed. // For example, a Webhook endpoint might use // "https://example.com/push". PushEndpoint *string `json:"pushEndpoint,omitempty" tf:"push_endpoint,omitempty"` }
func (*PushConfigObservation) DeepCopy ¶
func (in *PushConfigObservation) DeepCopy() *PushConfigObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PushConfigObservation.
func (*PushConfigObservation) DeepCopyInto ¶
func (in *PushConfigObservation) DeepCopyInto(out *PushConfigObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PushConfigParameters ¶
type PushConfigParameters struct { // Endpoint configuration attributes. // Every endpoint has a set of API supported attributes that can // be used to control different aspects of the message delivery. // The currently supported attribute is x-goog-version, which you // can use to change the format of the pushed message. This // attribute indicates the version of the data expected by // the endpoint. This controls the shape of the pushed message // (i.e., its fields and metadata). The endpoint version is // based on the version of the Pub/Sub API. // If not present during the subscriptions.create call, // it will default to the version of the API used to make // such call. If not present during a subscriptions.modifyPushConfig // call, its value will not be changed. subscriptions.get // calls will always return a valid version, even if the // subscription was created without this attribute. // The possible values for this attribute are: // +kubebuilder:validation:Optional // +mapType=granular Attributes map[string]*string `json:"attributes,omitempty" tf:"attributes,omitempty"` // When set, the payload to the push endpoint is not wrapped.Sets the // data field as the HTTP body for delivery. // Structure is documented below. // +kubebuilder:validation:Optional NoWrapper []NoWrapperParameters `json:"noWrapper,omitempty" tf:"no_wrapper,omitempty"` // If specified, Pub/Sub will generate and attach an OIDC JWT token as // an Authorization header in the HTTP request for every pushed message. // Structure is documented below. // +kubebuilder:validation:Optional OidcToken []OidcTokenParameters `json:"oidcToken,omitempty" tf:"oidc_token,omitempty"` // A URL locating the endpoint to which messages should be pushed. // For example, a Webhook endpoint might use // "https://example.com/push". // +kubebuilder:validation:Optional PushEndpoint *string `json:"pushEndpoint" tf:"push_endpoint,omitempty"` }
func (*PushConfigParameters) DeepCopy ¶
func (in *PushConfigParameters) DeepCopy() *PushConfigParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PushConfigParameters.
func (*PushConfigParameters) DeepCopyInto ¶
func (in *PushConfigParameters) DeepCopyInto(out *PushConfigParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ReservationConfigInitParameters ¶ added in v0.35.0
type ReservationConfigInitParameters struct { // The Reservation to use for this topic's throughput capacity. // +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/pubsub/v1beta1.LiteReservation ThroughputReservation *string `json:"throughputReservation,omitempty" tf:"throughput_reservation,omitempty"` // Reference to a LiteReservation in pubsub to populate throughputReservation. // +kubebuilder:validation:Optional ThroughputReservationRef *v1.Reference `json:"throughputReservationRef,omitempty" tf:"-"` // Selector for a LiteReservation in pubsub to populate throughputReservation. // +kubebuilder:validation:Optional ThroughputReservationSelector *v1.Selector `json:"throughputReservationSelector,omitempty" tf:"-"` }
func (*ReservationConfigInitParameters) DeepCopy ¶ added in v0.35.0
func (in *ReservationConfigInitParameters) DeepCopy() *ReservationConfigInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReservationConfigInitParameters.
func (*ReservationConfigInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *ReservationConfigInitParameters) DeepCopyInto(out *ReservationConfigInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ReservationConfigObservation ¶
type ReservationConfigObservation struct { // The Reservation to use for this topic's throughput capacity. ThroughputReservation *string `json:"throughputReservation,omitempty" tf:"throughput_reservation,omitempty"` }
func (*ReservationConfigObservation) DeepCopy ¶
func (in *ReservationConfigObservation) DeepCopy() *ReservationConfigObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReservationConfigObservation.
func (*ReservationConfigObservation) DeepCopyInto ¶
func (in *ReservationConfigObservation) DeepCopyInto(out *ReservationConfigObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ReservationConfigParameters ¶
type ReservationConfigParameters struct { // The Reservation to use for this topic's throughput capacity. // +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/pubsub/v1beta1.LiteReservation // +kubebuilder:validation:Optional ThroughputReservation *string `json:"throughputReservation,omitempty" tf:"throughput_reservation,omitempty"` // Reference to a LiteReservation in pubsub to populate throughputReservation. // +kubebuilder:validation:Optional ThroughputReservationRef *v1.Reference `json:"throughputReservationRef,omitempty" tf:"-"` // Selector for a LiteReservation in pubsub to populate throughputReservation. // +kubebuilder:validation:Optional ThroughputReservationSelector *v1.Selector `json:"throughputReservationSelector,omitempty" tf:"-"` }
func (*ReservationConfigParameters) DeepCopy ¶
func (in *ReservationConfigParameters) DeepCopy() *ReservationConfigParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReservationConfigParameters.
func (*ReservationConfigParameters) DeepCopyInto ¶
func (in *ReservationConfigParameters) DeepCopyInto(out *ReservationConfigParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RetentionConfigInitParameters ¶ added in v0.35.0
type RetentionConfigInitParameters struct { // The provisioned storage, in bytes, per partition. If the number of bytes stored // in any of the topic's partitions grows beyond this value, older messages will be // dropped to make room for newer ones, regardless of the value of period. PerPartitionBytes *string `json:"perPartitionBytes,omitempty" tf:"per_partition_bytes,omitempty"` // How long a published message is retained. If unset, messages will be retained as // long as the bytes retained for each partition is below perPartitionBytes. A // duration in seconds with up to nine fractional digits, terminated by 's'. // Example: "3.5s". Period *string `json:"period,omitempty" tf:"period,omitempty"` }
func (*RetentionConfigInitParameters) DeepCopy ¶ added in v0.35.0
func (in *RetentionConfigInitParameters) DeepCopy() *RetentionConfigInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RetentionConfigInitParameters.
func (*RetentionConfigInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *RetentionConfigInitParameters) DeepCopyInto(out *RetentionConfigInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RetentionConfigObservation ¶
type RetentionConfigObservation struct { // The provisioned storage, in bytes, per partition. If the number of bytes stored // in any of the topic's partitions grows beyond this value, older messages will be // dropped to make room for newer ones, regardless of the value of period. PerPartitionBytes *string `json:"perPartitionBytes,omitempty" tf:"per_partition_bytes,omitempty"` // How long a published message is retained. If unset, messages will be retained as // long as the bytes retained for each partition is below perPartitionBytes. A // duration in seconds with up to nine fractional digits, terminated by 's'. // Example: "3.5s". Period *string `json:"period,omitempty" tf:"period,omitempty"` }
func (*RetentionConfigObservation) DeepCopy ¶
func (in *RetentionConfigObservation) DeepCopy() *RetentionConfigObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RetentionConfigObservation.
func (*RetentionConfigObservation) DeepCopyInto ¶
func (in *RetentionConfigObservation) DeepCopyInto(out *RetentionConfigObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RetentionConfigParameters ¶
type RetentionConfigParameters struct { // The provisioned storage, in bytes, per partition. If the number of bytes stored // in any of the topic's partitions grows beyond this value, older messages will be // dropped to make room for newer ones, regardless of the value of period. // +kubebuilder:validation:Optional PerPartitionBytes *string `json:"perPartitionBytes" tf:"per_partition_bytes,omitempty"` // How long a published message is retained. If unset, messages will be retained as // long as the bytes retained for each partition is below perPartitionBytes. A // duration in seconds with up to nine fractional digits, terminated by 's'. // Example: "3.5s". // +kubebuilder:validation:Optional Period *string `json:"period,omitempty" tf:"period,omitempty"` }
func (*RetentionConfigParameters) DeepCopy ¶
func (in *RetentionConfigParameters) DeepCopy() *RetentionConfigParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RetentionConfigParameters.
func (*RetentionConfigParameters) DeepCopyInto ¶
func (in *RetentionConfigParameters) DeepCopyInto(out *RetentionConfigParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RetryPolicyInitParameters ¶ added in v0.35.0
type RetryPolicyInitParameters struct { // The maximum delay between consecutive deliveries of a given message. Value should be between 0 and 600 seconds. Defaults to 600 seconds. // A duration in seconds with up to nine fractional digits, terminated by 's'. Example: "3.5s". MaximumBackoff *string `json:"maximumBackoff,omitempty" tf:"maximum_backoff,omitempty"` // The minimum delay between consecutive deliveries of a given message. Value should be between 0 and 600 seconds. Defaults to 10 seconds. // A duration in seconds with up to nine fractional digits, terminated by 's'. Example: "3.5s". MinimumBackoff *string `json:"minimumBackoff,omitempty" tf:"minimum_backoff,omitempty"` }
func (*RetryPolicyInitParameters) DeepCopy ¶ added in v0.35.0
func (in *RetryPolicyInitParameters) DeepCopy() *RetryPolicyInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RetryPolicyInitParameters.
func (*RetryPolicyInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *RetryPolicyInitParameters) DeepCopyInto(out *RetryPolicyInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RetryPolicyObservation ¶
type RetryPolicyObservation struct { // The maximum delay between consecutive deliveries of a given message. Value should be between 0 and 600 seconds. Defaults to 600 seconds. // A duration in seconds with up to nine fractional digits, terminated by 's'. Example: "3.5s". MaximumBackoff *string `json:"maximumBackoff,omitempty" tf:"maximum_backoff,omitempty"` // The minimum delay between consecutive deliveries of a given message. Value should be between 0 and 600 seconds. Defaults to 10 seconds. // A duration in seconds with up to nine fractional digits, terminated by 's'. Example: "3.5s". MinimumBackoff *string `json:"minimumBackoff,omitempty" tf:"minimum_backoff,omitempty"` }
func (*RetryPolicyObservation) DeepCopy ¶
func (in *RetryPolicyObservation) DeepCopy() *RetryPolicyObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RetryPolicyObservation.
func (*RetryPolicyObservation) DeepCopyInto ¶
func (in *RetryPolicyObservation) DeepCopyInto(out *RetryPolicyObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RetryPolicyParameters ¶
type RetryPolicyParameters struct { // The maximum delay between consecutive deliveries of a given message. Value should be between 0 and 600 seconds. Defaults to 600 seconds. // A duration in seconds with up to nine fractional digits, terminated by 's'. Example: "3.5s". // +kubebuilder:validation:Optional MaximumBackoff *string `json:"maximumBackoff,omitempty" tf:"maximum_backoff,omitempty"` // The minimum delay between consecutive deliveries of a given message. Value should be between 0 and 600 seconds. Defaults to 10 seconds. // A duration in seconds with up to nine fractional digits, terminated by 's'. Example: "3.5s". // +kubebuilder:validation:Optional MinimumBackoff *string `json:"minimumBackoff,omitempty" tf:"minimum_backoff,omitempty"` }
func (*RetryPolicyParameters) DeepCopy ¶
func (in *RetryPolicyParameters) DeepCopy() *RetryPolicyParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RetryPolicyParameters.
func (*RetryPolicyParameters) DeepCopyInto ¶
func (in *RetryPolicyParameters) DeepCopyInto(out *RetryPolicyParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Schema ¶
type Schema struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec SchemaSpec `json:"spec"` Status SchemaStatus `json:"status,omitempty"` }
Schema is the Schema for the Schemas API. A schema is a format that messages must follow, creating a contract between publisher and subscriber that Pub/Sub will enforce. +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcp}
func (*Schema) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Schema.
func (*Schema) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Schema) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Schema) GetCondition ¶
func (mg *Schema) GetCondition(ct xpv1.ConditionType) xpv1.Condition
GetCondition of this Schema.
func (*Schema) GetConnectionDetailsMapping ¶
GetConnectionDetailsMapping for this Schema
func (*Schema) GetDeletionPolicy ¶
func (mg *Schema) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this Schema.
func (*Schema) GetInitParameters ¶ added in v0.35.0
GetInitParameters of this Schema
func (*Schema) GetManagementPolicies ¶ added in v0.35.0
func (mg *Schema) GetManagementPolicies() xpv1.ManagementPolicies
GetManagementPolicies of this Schema.
func (*Schema) GetMergedParameters ¶ added in v0.40.0
GetInitParameters of this Schema
func (*Schema) GetObservation ¶
GetObservation of this Schema
func (*Schema) GetParameters ¶
GetParameters of this Schema
func (*Schema) GetProviderConfigReference ¶
GetProviderConfigReference of this Schema.
func (*Schema) GetPublishConnectionDetailsTo ¶
func (mg *Schema) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this Schema.
func (*Schema) GetTerraformResourceType ¶
GetTerraformResourceType returns Terraform resource type for this Schema
func (*Schema) GetTerraformSchemaVersion ¶
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*Schema) GetWriteConnectionSecretToReference ¶
func (mg *Schema) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this Schema.
func (*Schema) Hub ¶ added in v0.41.2
func (tr *Schema) Hub()
Hub marks this type as a conversion hub.
func (*Schema) LateInitialize ¶
LateInitialize this Schema using its observed tfState. returns True if there are any spec changes for the resource.
func (*Schema) SetConditions ¶
SetConditions of this Schema.
func (*Schema) SetDeletionPolicy ¶
func (mg *Schema) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this Schema.
func (*Schema) SetManagementPolicies ¶ added in v0.35.0
func (mg *Schema) SetManagementPolicies(r xpv1.ManagementPolicies)
SetManagementPolicies of this Schema.
func (*Schema) SetObservation ¶
SetObservation for this Schema
func (*Schema) SetParameters ¶
SetParameters for this Schema
func (*Schema) SetProviderConfigReference ¶
SetProviderConfigReference of this Schema.
func (*Schema) SetPublishConnectionDetailsTo ¶
func (mg *Schema) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
SetPublishConnectionDetailsTo of this Schema.
func (*Schema) SetWriteConnectionSecretToReference ¶
func (mg *Schema) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
SetWriteConnectionSecretToReference of this Schema.
type SchemaInitParameters ¶ added in v0.35.0
type SchemaInitParameters struct { // The definition of the schema. // This should contain a string representing the full definition of the schema // that is a valid schema definition of the type specified in type. Changes // to the definition commit new schema revisions. // A schema can only have up to 20 revisions, so updates that fail with an // error indicating that the limit has been reached require manually // deleting old revisions. Definition *string `json:"definition,omitempty" tf:"definition,omitempty"` // The ID of the project in which the resource belongs. // If it is not provided, the provider project is used. Project *string `json:"project,omitempty" tf:"project,omitempty"` // The type of the schema definition // Default value is TYPE_UNSPECIFIED. // Possible values are: TYPE_UNSPECIFIED, PROTOCOL_BUFFER, AVRO. Type *string `json:"type,omitempty" tf:"type,omitempty"` }
func (*SchemaInitParameters) DeepCopy ¶ added in v0.35.0
func (in *SchemaInitParameters) DeepCopy() *SchemaInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SchemaInitParameters.
func (*SchemaInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *SchemaInitParameters) DeepCopyInto(out *SchemaInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SchemaList ¶
type SchemaList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Schema `json:"items"` }
SchemaList contains a list of Schemas
func (*SchemaList) DeepCopy ¶
func (in *SchemaList) DeepCopy() *SchemaList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SchemaList.
func (*SchemaList) DeepCopyInto ¶
func (in *SchemaList) DeepCopyInto(out *SchemaList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SchemaList) DeepCopyObject ¶
func (in *SchemaList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*SchemaList) GetItems ¶
func (l *SchemaList) GetItems() []resource.Managed
GetItems of this SchemaList.
type SchemaObservation ¶
type SchemaObservation struct { // The definition of the schema. // This should contain a string representing the full definition of the schema // that is a valid schema definition of the type specified in type. Changes // to the definition commit new schema revisions. // A schema can only have up to 20 revisions, so updates that fail with an // error indicating that the limit has been reached require manually // deleting old revisions. Definition *string `json:"definition,omitempty" tf:"definition,omitempty"` // an identifier for the resource with format projects/{{project}}/schemas/{{name}} ID *string `json:"id,omitempty" tf:"id,omitempty"` // The ID of the project in which the resource belongs. // If it is not provided, the provider project is used. Project *string `json:"project,omitempty" tf:"project,omitempty"` // The type of the schema definition // Default value is TYPE_UNSPECIFIED. // Possible values are: TYPE_UNSPECIFIED, PROTOCOL_BUFFER, AVRO. Type *string `json:"type,omitempty" tf:"type,omitempty"` }
func (*SchemaObservation) DeepCopy ¶
func (in *SchemaObservation) DeepCopy() *SchemaObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SchemaObservation.
func (*SchemaObservation) DeepCopyInto ¶
func (in *SchemaObservation) DeepCopyInto(out *SchemaObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SchemaParameters ¶
type SchemaParameters struct { // The definition of the schema. // This should contain a string representing the full definition of the schema // that is a valid schema definition of the type specified in type. Changes // to the definition commit new schema revisions. // A schema can only have up to 20 revisions, so updates that fail with an // error indicating that the limit has been reached require manually // deleting old revisions. // +kubebuilder:validation:Optional Definition *string `json:"definition,omitempty" tf:"definition,omitempty"` // The ID of the project in which the resource belongs. // If it is not provided, the provider project is used. // +kubebuilder:validation:Optional Project *string `json:"project,omitempty" tf:"project,omitempty"` // The type of the schema definition // Default value is TYPE_UNSPECIFIED. // Possible values are: TYPE_UNSPECIFIED, PROTOCOL_BUFFER, AVRO. // +kubebuilder:validation:Optional Type *string `json:"type,omitempty" tf:"type,omitempty"` }
func (*SchemaParameters) DeepCopy ¶
func (in *SchemaParameters) DeepCopy() *SchemaParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SchemaParameters.
func (*SchemaParameters) DeepCopyInto ¶
func (in *SchemaParameters) DeepCopyInto(out *SchemaParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SchemaSettingsInitParameters ¶ added in v0.35.0
type SchemaSettingsInitParameters struct { // The encoding of messages validated against schema. // Default value is ENCODING_UNSPECIFIED. // Possible values are: ENCODING_UNSPECIFIED, JSON, BINARY. Encoding *string `json:"encoding,omitempty" tf:"encoding,omitempty"` // The name of the schema that messages published should be // validated against. Format is projects/{project}/schemas/{schema}. // The value of this field will be deleted-schema // if the schema has been deleted. Schema *string `json:"schema,omitempty" tf:"schema,omitempty"` }
func (*SchemaSettingsInitParameters) DeepCopy ¶ added in v0.35.0
func (in *SchemaSettingsInitParameters) DeepCopy() *SchemaSettingsInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SchemaSettingsInitParameters.
func (*SchemaSettingsInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *SchemaSettingsInitParameters) DeepCopyInto(out *SchemaSettingsInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SchemaSettingsObservation ¶
type SchemaSettingsObservation struct { // The encoding of messages validated against schema. // Default value is ENCODING_UNSPECIFIED. // Possible values are: ENCODING_UNSPECIFIED, JSON, BINARY. Encoding *string `json:"encoding,omitempty" tf:"encoding,omitempty"` // The name of the schema that messages published should be // validated against. Format is projects/{project}/schemas/{schema}. // The value of this field will be deleted-schema // if the schema has been deleted. Schema *string `json:"schema,omitempty" tf:"schema,omitempty"` }
func (*SchemaSettingsObservation) DeepCopy ¶
func (in *SchemaSettingsObservation) DeepCopy() *SchemaSettingsObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SchemaSettingsObservation.
func (*SchemaSettingsObservation) DeepCopyInto ¶
func (in *SchemaSettingsObservation) DeepCopyInto(out *SchemaSettingsObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SchemaSettingsParameters ¶
type SchemaSettingsParameters struct { // The encoding of messages validated against schema. // Default value is ENCODING_UNSPECIFIED. // Possible values are: ENCODING_UNSPECIFIED, JSON, BINARY. // +kubebuilder:validation:Optional Encoding *string `json:"encoding,omitempty" tf:"encoding,omitempty"` // The name of the schema that messages published should be // validated against. Format is projects/{project}/schemas/{schema}. // The value of this field will be deleted-schema // if the schema has been deleted. // +kubebuilder:validation:Optional Schema *string `json:"schema" tf:"schema,omitempty"` }
func (*SchemaSettingsParameters) DeepCopy ¶
func (in *SchemaSettingsParameters) DeepCopy() *SchemaSettingsParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SchemaSettingsParameters.
func (*SchemaSettingsParameters) DeepCopyInto ¶
func (in *SchemaSettingsParameters) DeepCopyInto(out *SchemaSettingsParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SchemaSpec ¶
type SchemaSpec struct { v1.ResourceSpec `json:",inline"` ForProvider SchemaParameters `json:"forProvider"` // THIS IS A BETA FIELD. It will be honored // unless the Management Policies feature flag is disabled. // InitProvider holds the same fields as ForProvider, with the exception // of Identifier and other resource reference fields. The fields that are // in InitProvider are merged into ForProvider when the resource is created. // The same fields are also added to the terraform ignore_changes hook, to // avoid updating them after creation. This is useful for fields that are // required on creation, but we do not desire to update them after creation, // for example because of an external controller is managing them, like an // autoscaler. InitProvider SchemaInitParameters `json:"initProvider,omitempty"` }
SchemaSpec defines the desired state of Schema
func (*SchemaSpec) DeepCopy ¶
func (in *SchemaSpec) DeepCopy() *SchemaSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SchemaSpec.
func (*SchemaSpec) DeepCopyInto ¶
func (in *SchemaSpec) DeepCopyInto(out *SchemaSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SchemaStatus ¶
type SchemaStatus struct { v1.ResourceStatus `json:",inline"` AtProvider SchemaObservation `json:"atProvider,omitempty"` }
SchemaStatus defines the observed state of Schema.
func (*SchemaStatus) DeepCopy ¶
func (in *SchemaStatus) DeepCopy() *SchemaStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SchemaStatus.
func (*SchemaStatus) DeepCopyInto ¶
func (in *SchemaStatus) DeepCopyInto(out *SchemaStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Subscription ¶
type Subscription struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec SubscriptionSpec `json:"spec"` Status SubscriptionStatus `json:"status,omitempty"` }
Subscription is the Schema for the Subscriptions API. A named resource representing the stream of messages from a single, specific topic, to be delivered to the subscribing application. +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcp}
func (*Subscription) ConvertFrom ¶ added in v1.2.0
func (tr *Subscription) ConvertFrom(srcRaw conversion.Hub) error
ConvertFrom converts from the hub type to the Subscription type.
func (*Subscription) ConvertTo ¶ added in v1.2.0
func (tr *Subscription) ConvertTo(dstRaw conversion.Hub) error
ConvertTo converts this Subscription to the hub type.
func (*Subscription) DeepCopy ¶
func (in *Subscription) DeepCopy() *Subscription
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Subscription.
func (*Subscription) DeepCopyInto ¶
func (in *Subscription) DeepCopyInto(out *Subscription)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Subscription) DeepCopyObject ¶
func (in *Subscription) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Subscription) GetCondition ¶
func (mg *Subscription) GetCondition(ct xpv1.ConditionType) xpv1.Condition
GetCondition of this Subscription.
func (*Subscription) GetConnectionDetailsMapping ¶
func (tr *Subscription) GetConnectionDetailsMapping() map[string]string
GetConnectionDetailsMapping for this Subscription
func (*Subscription) GetDeletionPolicy ¶
func (mg *Subscription) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this Subscription.
func (*Subscription) GetID ¶
func (tr *Subscription) GetID() string
GetID returns ID of underlying Terraform resource of this Subscription
func (*Subscription) GetInitParameters ¶ added in v0.35.0
func (tr *Subscription) GetInitParameters() (map[string]any, error)
GetInitParameters of this Subscription
func (*Subscription) GetManagementPolicies ¶ added in v0.35.0
func (mg *Subscription) GetManagementPolicies() xpv1.ManagementPolicies
GetManagementPolicies of this Subscription.
func (*Subscription) GetMergedParameters ¶ added in v0.40.0
func (tr *Subscription) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)
GetInitParameters of this Subscription
func (*Subscription) GetObservation ¶
func (tr *Subscription) GetObservation() (map[string]any, error)
GetObservation of this Subscription
func (*Subscription) GetParameters ¶
func (tr *Subscription) GetParameters() (map[string]any, error)
GetParameters of this Subscription
func (*Subscription) GetProviderConfigReference ¶
func (mg *Subscription) GetProviderConfigReference() *xpv1.Reference
GetProviderConfigReference of this Subscription.
func (*Subscription) GetPublishConnectionDetailsTo ¶
func (mg *Subscription) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this Subscription.
func (*Subscription) GetTerraformResourceType ¶
func (mg *Subscription) GetTerraformResourceType() string
GetTerraformResourceType returns Terraform resource type for this Subscription
func (*Subscription) GetTerraformSchemaVersion ¶
func (tr *Subscription) GetTerraformSchemaVersion() int
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*Subscription) GetWriteConnectionSecretToReference ¶
func (mg *Subscription) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this Subscription.
func (*Subscription) LateInitialize ¶
func (tr *Subscription) LateInitialize(attrs []byte) (bool, error)
LateInitialize this Subscription using its observed tfState. returns True if there are any spec changes for the resource.
func (*Subscription) ResolveReferences ¶
ResolveReferences of this Subscription.
func (*Subscription) SetConditions ¶
func (mg *Subscription) SetConditions(c ...xpv1.Condition)
SetConditions of this Subscription.
func (*Subscription) SetDeletionPolicy ¶
func (mg *Subscription) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this Subscription.
func (*Subscription) SetManagementPolicies ¶ added in v0.35.0
func (mg *Subscription) SetManagementPolicies(r xpv1.ManagementPolicies)
SetManagementPolicies of this Subscription.
func (*Subscription) SetObservation ¶
func (tr *Subscription) SetObservation(obs map[string]any) error
SetObservation for this Subscription
func (*Subscription) SetParameters ¶
func (tr *Subscription) SetParameters(params map[string]any) error
SetParameters for this Subscription
func (*Subscription) SetProviderConfigReference ¶
func (mg *Subscription) SetProviderConfigReference(r *xpv1.Reference)
SetProviderConfigReference of this Subscription.
func (*Subscription) SetPublishConnectionDetailsTo ¶
func (mg *Subscription) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
SetPublishConnectionDetailsTo of this Subscription.
func (*Subscription) SetWriteConnectionSecretToReference ¶
func (mg *Subscription) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
SetWriteConnectionSecretToReference of this Subscription.
type SubscriptionIAMMember ¶
type SubscriptionIAMMember struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` // +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.member) || (has(self.initProvider) && has(self.initProvider.member))",message="spec.forProvider.member is a required parameter" // +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.role) || (has(self.initProvider) && has(self.initProvider.role))",message="spec.forProvider.role is a required parameter" Spec SubscriptionIAMMemberSpec `json:"spec"` Status SubscriptionIAMMemberStatus `json:"status,omitempty"` }
SubscriptionIAMMember is the Schema for the SubscriptionIAMMembers API. <no value> +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcp}
func (*SubscriptionIAMMember) ConvertFrom ¶ added in v1.2.0
func (tr *SubscriptionIAMMember) ConvertFrom(srcRaw conversion.Hub) error
ConvertFrom converts from the hub type to the SubscriptionIAMMember type.
func (*SubscriptionIAMMember) ConvertTo ¶ added in v1.2.0
func (tr *SubscriptionIAMMember) ConvertTo(dstRaw conversion.Hub) error
ConvertTo converts this SubscriptionIAMMember to the hub type.
func (*SubscriptionIAMMember) DeepCopy ¶
func (in *SubscriptionIAMMember) DeepCopy() *SubscriptionIAMMember
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionIAMMember.
func (*SubscriptionIAMMember) DeepCopyInto ¶
func (in *SubscriptionIAMMember) DeepCopyInto(out *SubscriptionIAMMember)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SubscriptionIAMMember) DeepCopyObject ¶
func (in *SubscriptionIAMMember) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*SubscriptionIAMMember) GetCondition ¶
func (mg *SubscriptionIAMMember) GetCondition(ct xpv1.ConditionType) xpv1.Condition
GetCondition of this SubscriptionIAMMember.
func (*SubscriptionIAMMember) GetConnectionDetailsMapping ¶
func (tr *SubscriptionIAMMember) GetConnectionDetailsMapping() map[string]string
GetConnectionDetailsMapping for this SubscriptionIAMMember
func (*SubscriptionIAMMember) GetDeletionPolicy ¶
func (mg *SubscriptionIAMMember) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this SubscriptionIAMMember.
func (*SubscriptionIAMMember) GetID ¶
func (tr *SubscriptionIAMMember) GetID() string
GetID returns ID of underlying Terraform resource of this SubscriptionIAMMember
func (*SubscriptionIAMMember) GetInitParameters ¶ added in v0.35.0
func (tr *SubscriptionIAMMember) GetInitParameters() (map[string]any, error)
GetInitParameters of this SubscriptionIAMMember
func (*SubscriptionIAMMember) GetManagementPolicies ¶ added in v0.35.0
func (mg *SubscriptionIAMMember) GetManagementPolicies() xpv1.ManagementPolicies
GetManagementPolicies of this SubscriptionIAMMember.
func (*SubscriptionIAMMember) GetMergedParameters ¶ added in v0.40.0
func (tr *SubscriptionIAMMember) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)
GetInitParameters of this SubscriptionIAMMember
func (*SubscriptionIAMMember) GetObservation ¶
func (tr *SubscriptionIAMMember) GetObservation() (map[string]any, error)
GetObservation of this SubscriptionIAMMember
func (*SubscriptionIAMMember) GetParameters ¶
func (tr *SubscriptionIAMMember) GetParameters() (map[string]any, error)
GetParameters of this SubscriptionIAMMember
func (*SubscriptionIAMMember) GetProviderConfigReference ¶
func (mg *SubscriptionIAMMember) GetProviderConfigReference() *xpv1.Reference
GetProviderConfigReference of this SubscriptionIAMMember.
func (*SubscriptionIAMMember) GetPublishConnectionDetailsTo ¶
func (mg *SubscriptionIAMMember) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this SubscriptionIAMMember.
func (*SubscriptionIAMMember) GetTerraformResourceType ¶
func (mg *SubscriptionIAMMember) GetTerraformResourceType() string
GetTerraformResourceType returns Terraform resource type for this SubscriptionIAMMember
func (*SubscriptionIAMMember) GetTerraformSchemaVersion ¶
func (tr *SubscriptionIAMMember) GetTerraformSchemaVersion() int
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*SubscriptionIAMMember) GetWriteConnectionSecretToReference ¶
func (mg *SubscriptionIAMMember) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this SubscriptionIAMMember.
func (*SubscriptionIAMMember) LateInitialize ¶
func (tr *SubscriptionIAMMember) LateInitialize(attrs []byte) (bool, error)
LateInitialize this SubscriptionIAMMember using its observed tfState. returns True if there are any spec changes for the resource.
func (*SubscriptionIAMMember) ResolveReferences ¶
ResolveReferences of this SubscriptionIAMMember.
func (*SubscriptionIAMMember) SetConditions ¶
func (mg *SubscriptionIAMMember) SetConditions(c ...xpv1.Condition)
SetConditions of this SubscriptionIAMMember.
func (*SubscriptionIAMMember) SetDeletionPolicy ¶
func (mg *SubscriptionIAMMember) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this SubscriptionIAMMember.
func (*SubscriptionIAMMember) SetManagementPolicies ¶ added in v0.35.0
func (mg *SubscriptionIAMMember) SetManagementPolicies(r xpv1.ManagementPolicies)
SetManagementPolicies of this SubscriptionIAMMember.
func (*SubscriptionIAMMember) SetObservation ¶
func (tr *SubscriptionIAMMember) SetObservation(obs map[string]any) error
SetObservation for this SubscriptionIAMMember
func (*SubscriptionIAMMember) SetParameters ¶
func (tr *SubscriptionIAMMember) SetParameters(params map[string]any) error
SetParameters for this SubscriptionIAMMember
func (*SubscriptionIAMMember) SetProviderConfigReference ¶
func (mg *SubscriptionIAMMember) SetProviderConfigReference(r *xpv1.Reference)
SetProviderConfigReference of this SubscriptionIAMMember.
func (*SubscriptionIAMMember) SetPublishConnectionDetailsTo ¶
func (mg *SubscriptionIAMMember) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
SetPublishConnectionDetailsTo of this SubscriptionIAMMember.
func (*SubscriptionIAMMember) SetWriteConnectionSecretToReference ¶
func (mg *SubscriptionIAMMember) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
SetWriteConnectionSecretToReference of this SubscriptionIAMMember.
type SubscriptionIAMMemberInitParameters ¶ added in v0.35.0
type SubscriptionIAMMemberInitParameters struct { Condition []ConditionInitParameters `json:"condition,omitempty" tf:"condition,omitempty"` Member *string `json:"member,omitempty" tf:"member,omitempty"` Project *string `json:"project,omitempty" tf:"project,omitempty"` Role *string `json:"role,omitempty" tf:"role,omitempty"` // +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/pubsub/v1beta1.Subscription Subscription *string `json:"subscription,omitempty" tf:"subscription,omitempty"` // Reference to a Subscription in pubsub to populate subscription. // +kubebuilder:validation:Optional SubscriptionRef *v1.Reference `json:"subscriptionRef,omitempty" tf:"-"` // Selector for a Subscription in pubsub to populate subscription. // +kubebuilder:validation:Optional SubscriptionSelector *v1.Selector `json:"subscriptionSelector,omitempty" tf:"-"` }
func (*SubscriptionIAMMemberInitParameters) DeepCopy ¶ added in v0.35.0
func (in *SubscriptionIAMMemberInitParameters) DeepCopy() *SubscriptionIAMMemberInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionIAMMemberInitParameters.
func (*SubscriptionIAMMemberInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *SubscriptionIAMMemberInitParameters) DeepCopyInto(out *SubscriptionIAMMemberInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SubscriptionIAMMemberList ¶
type SubscriptionIAMMemberList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []SubscriptionIAMMember `json:"items"` }
SubscriptionIAMMemberList contains a list of SubscriptionIAMMembers
func (*SubscriptionIAMMemberList) DeepCopy ¶
func (in *SubscriptionIAMMemberList) DeepCopy() *SubscriptionIAMMemberList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionIAMMemberList.
func (*SubscriptionIAMMemberList) DeepCopyInto ¶
func (in *SubscriptionIAMMemberList) DeepCopyInto(out *SubscriptionIAMMemberList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SubscriptionIAMMemberList) DeepCopyObject ¶
func (in *SubscriptionIAMMemberList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*SubscriptionIAMMemberList) GetItems ¶
func (l *SubscriptionIAMMemberList) GetItems() []resource.Managed
GetItems of this SubscriptionIAMMemberList.
type SubscriptionIAMMemberObservation ¶
type SubscriptionIAMMemberObservation struct { Condition []ConditionObservation `json:"condition,omitempty" tf:"condition,omitempty"` Etag *string `json:"etag,omitempty" tf:"etag,omitempty"` ID *string `json:"id,omitempty" tf:"id,omitempty"` Member *string `json:"member,omitempty" tf:"member,omitempty"` Project *string `json:"project,omitempty" tf:"project,omitempty"` Role *string `json:"role,omitempty" tf:"role,omitempty"` Subscription *string `json:"subscription,omitempty" tf:"subscription,omitempty"` }
func (*SubscriptionIAMMemberObservation) DeepCopy ¶
func (in *SubscriptionIAMMemberObservation) DeepCopy() *SubscriptionIAMMemberObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionIAMMemberObservation.
func (*SubscriptionIAMMemberObservation) DeepCopyInto ¶
func (in *SubscriptionIAMMemberObservation) DeepCopyInto(out *SubscriptionIAMMemberObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SubscriptionIAMMemberParameters ¶
type SubscriptionIAMMemberParameters struct { // +kubebuilder:validation:Optional Condition []ConditionParameters `json:"condition,omitempty" tf:"condition,omitempty"` // +kubebuilder:validation:Optional Member *string `json:"member,omitempty" tf:"member,omitempty"` // +kubebuilder:validation:Optional Project *string `json:"project,omitempty" tf:"project,omitempty"` // +kubebuilder:validation:Optional Role *string `json:"role,omitempty" tf:"role,omitempty"` // +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/pubsub/v1beta1.Subscription // +kubebuilder:validation:Optional Subscription *string `json:"subscription,omitempty" tf:"subscription,omitempty"` // Reference to a Subscription in pubsub to populate subscription. // +kubebuilder:validation:Optional SubscriptionRef *v1.Reference `json:"subscriptionRef,omitempty" tf:"-"` // Selector for a Subscription in pubsub to populate subscription. // +kubebuilder:validation:Optional SubscriptionSelector *v1.Selector `json:"subscriptionSelector,omitempty" tf:"-"` }
func (*SubscriptionIAMMemberParameters) DeepCopy ¶
func (in *SubscriptionIAMMemberParameters) DeepCopy() *SubscriptionIAMMemberParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionIAMMemberParameters.
func (*SubscriptionIAMMemberParameters) DeepCopyInto ¶
func (in *SubscriptionIAMMemberParameters) DeepCopyInto(out *SubscriptionIAMMemberParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SubscriptionIAMMemberSpec ¶
type SubscriptionIAMMemberSpec struct { v1.ResourceSpec `json:",inline"` ForProvider SubscriptionIAMMemberParameters `json:"forProvider"` // THIS IS A BETA FIELD. It will be honored // unless the Management Policies feature flag is disabled. // InitProvider holds the same fields as ForProvider, with the exception // of Identifier and other resource reference fields. The fields that are // in InitProvider are merged into ForProvider when the resource is created. // The same fields are also added to the terraform ignore_changes hook, to // avoid updating them after creation. This is useful for fields that are // required on creation, but we do not desire to update them after creation, // for example because of an external controller is managing them, like an // autoscaler. InitProvider SubscriptionIAMMemberInitParameters `json:"initProvider,omitempty"` }
SubscriptionIAMMemberSpec defines the desired state of SubscriptionIAMMember
func (*SubscriptionIAMMemberSpec) DeepCopy ¶
func (in *SubscriptionIAMMemberSpec) DeepCopy() *SubscriptionIAMMemberSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionIAMMemberSpec.
func (*SubscriptionIAMMemberSpec) DeepCopyInto ¶
func (in *SubscriptionIAMMemberSpec) DeepCopyInto(out *SubscriptionIAMMemberSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SubscriptionIAMMemberStatus ¶
type SubscriptionIAMMemberStatus struct { v1.ResourceStatus `json:",inline"` AtProvider SubscriptionIAMMemberObservation `json:"atProvider,omitempty"` }
SubscriptionIAMMemberStatus defines the observed state of SubscriptionIAMMember.
func (*SubscriptionIAMMemberStatus) DeepCopy ¶
func (in *SubscriptionIAMMemberStatus) DeepCopy() *SubscriptionIAMMemberStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionIAMMemberStatus.
func (*SubscriptionIAMMemberStatus) DeepCopyInto ¶
func (in *SubscriptionIAMMemberStatus) DeepCopyInto(out *SubscriptionIAMMemberStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SubscriptionInitParameters ¶ added in v0.35.0
type SubscriptionInitParameters struct { // This value is the maximum time after a subscriber receives a message // before the subscriber should acknowledge the message. After message // delivery but before the ack deadline expires and before the message is // acknowledged, it is an outstanding message and will not be delivered // again during that time (on a best-effort basis). // For pull subscriptions, this value is used as the initial value for // the ack deadline. To override this value for a given message, call // subscriptions.modifyAckDeadline with the corresponding ackId if using // pull. The minimum custom deadline you can specify is 10 seconds. The // maximum custom deadline you can specify is 600 seconds (10 minutes). // If this parameter is 0, a default value of 10 seconds is used. // For push delivery, this value is also used to set the request timeout // for the call to the push endpoint. // If the subscriber never acknowledges the message, the Pub/Sub system // will eventually redeliver the message. AckDeadlineSeconds *float64 `json:"ackDeadlineSeconds,omitempty" tf:"ack_deadline_seconds,omitempty"` // If delivery to BigQuery is used with this subscription, this field is used to configure it. // Either pushConfig, bigQueryConfig or cloudStorageConfig can be set, but not combined. // If all three are empty, then the subscriber will pull and ack messages using API methods. // Structure is documented below. BigqueryConfig []BigqueryConfigInitParameters `json:"bigqueryConfig,omitempty" tf:"bigquery_config,omitempty"` // If delivery to Cloud Storage is used with this subscription, this field is used to configure it. // Either pushConfig, bigQueryConfig or cloudStorageConfig can be set, but not combined. // If all three are empty, then the subscriber will pull and ack messages using API methods. // Structure is documented below. CloudStorageConfig []CloudStorageConfigInitParameters `json:"cloudStorageConfig,omitempty" tf:"cloud_storage_config,omitempty"` // A policy that specifies the conditions for dead lettering messages in // this subscription. If dead_letter_policy is not set, dead lettering // is disabled. // The Cloud Pub/Sub service account associated with this subscription's // parent project (i.e., // service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have // permission to Acknowledge() messages on this subscription. // Structure is documented below. DeadLetterPolicy []DeadLetterPolicyInitParameters `json:"deadLetterPolicy,omitempty" tf:"dead_letter_policy,omitempty"` // If true, Pub/Sub provides the following guarantees for the delivery // of a message with a given value of messageId on this Subscriptions': EnableExactlyOnceDelivery *bool `json:"enableExactlyOnceDelivery,omitempty" tf:"enable_exactly_once_delivery,omitempty"` // If true, messages published with the same orderingKey in PubsubMessage will be delivered to // the subscribers in the order in which they are received by the Pub/Sub system. Otherwise, they // may be delivered in any order. EnableMessageOrdering *bool `json:"enableMessageOrdering,omitempty" tf:"enable_message_ordering,omitempty"` // A policy that specifies the conditions for this subscription's expiration. // A subscription is considered active as long as any connected subscriber // is successfully consuming messages from the subscription or is issuing // operations on the subscription. If expirationPolicy is not set, a default // policy with ttl of 31 days will be used. If it is set but ttl is "", the // resource never expires. The minimum allowed value for expirationPolicy.ttl // is 1 day. // Structure is documented below. ExpirationPolicy []ExpirationPolicyInitParameters `json:"expirationPolicy,omitempty" tf:"expiration_policy,omitempty"` // The subscription only delivers the messages that match the filter. // Pub/Sub automatically acknowledges the messages that don't match the filter. You can filter messages // by their attributes. The maximum length of a filter is 256 bytes. After creating the subscription, // you can't modify the filter. Filter *string `json:"filter,omitempty" tf:"filter,omitempty"` // A set of key/value label pairs to assign to this Subscription. // +mapType=granular Labels map[string]*string `json:"labels,omitempty" tf:"labels,omitempty"` // How long to retain unacknowledged messages in the subscription's // backlog, from the moment a message is published. If // retain_acked_messages is true, then this also configures the retention // of acknowledged messages, and thus configures how far back in time a // subscriptions.seek can be done. Defaults to 7 days. Cannot be more // than 7 days ("604800s") or less than 10 minutes ("600s"). // A duration in seconds with up to nine fractional digits, terminated // by 's'. Example: "600.5s". MessageRetentionDuration *string `json:"messageRetentionDuration,omitempty" tf:"message_retention_duration,omitempty"` // The ID of the project in which the resource belongs. // If it is not provided, the provider project is used. Project *string `json:"project,omitempty" tf:"project,omitempty"` // If push delivery is used with this subscription, this field is used to // configure it. An empty pushConfig signifies that the subscriber will // pull and ack messages using API methods. // Structure is documented below. PushConfig []PushConfigInitParameters `json:"pushConfig,omitempty" tf:"push_config,omitempty"` // Indicates whether to retain acknowledged messages. If true, then // messages are not expunged from the subscription's backlog, even if // they are acknowledged, until they fall out of the // messageRetentionDuration window. RetainAckedMessages *bool `json:"retainAckedMessages,omitempty" tf:"retain_acked_messages,omitempty"` // A policy that specifies how Pub/Sub retries message delivery for this subscription. // If not set, the default retry policy is applied. This generally implies that messages will be retried as soon as possible for healthy subscribers. // RetryPolicy will be triggered on NACKs or acknowledgement deadline exceeded events for a given message // Structure is documented below. RetryPolicy []RetryPolicyInitParameters `json:"retryPolicy,omitempty" tf:"retry_policy,omitempty"` // A reference to a Topic resource, of the form projects/{project}/topics/{{name}} // (as in the id property of a google_pubsub_topic), or just a topic name if // the topic is in the same project as the subscription. // +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/pubsub/v1beta1.Topic Topic *string `json:"topic,omitempty" tf:"topic,omitempty"` // Reference to a Topic in pubsub to populate topic. // +kubebuilder:validation:Optional TopicRef *v1.Reference `json:"topicRef,omitempty" tf:"-"` // Selector for a Topic in pubsub to populate topic. // +kubebuilder:validation:Optional TopicSelector *v1.Selector `json:"topicSelector,omitempty" tf:"-"` }
func (*SubscriptionInitParameters) DeepCopy ¶ added in v0.35.0
func (in *SubscriptionInitParameters) DeepCopy() *SubscriptionInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionInitParameters.
func (*SubscriptionInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *SubscriptionInitParameters) DeepCopyInto(out *SubscriptionInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SubscriptionList ¶
type SubscriptionList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Subscription `json:"items"` }
SubscriptionList contains a list of Subscriptions
func (*SubscriptionList) DeepCopy ¶
func (in *SubscriptionList) DeepCopy() *SubscriptionList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionList.
func (*SubscriptionList) DeepCopyInto ¶
func (in *SubscriptionList) DeepCopyInto(out *SubscriptionList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SubscriptionList) DeepCopyObject ¶
func (in *SubscriptionList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*SubscriptionList) GetItems ¶
func (l *SubscriptionList) GetItems() []resource.Managed
GetItems of this SubscriptionList.
type SubscriptionObservation ¶
type SubscriptionObservation struct { // This value is the maximum time after a subscriber receives a message // before the subscriber should acknowledge the message. After message // delivery but before the ack deadline expires and before the message is // acknowledged, it is an outstanding message and will not be delivered // again during that time (on a best-effort basis). // For pull subscriptions, this value is used as the initial value for // the ack deadline. To override this value for a given message, call // subscriptions.modifyAckDeadline with the corresponding ackId if using // pull. The minimum custom deadline you can specify is 10 seconds. The // maximum custom deadline you can specify is 600 seconds (10 minutes). // If this parameter is 0, a default value of 10 seconds is used. // For push delivery, this value is also used to set the request timeout // for the call to the push endpoint. // If the subscriber never acknowledges the message, the Pub/Sub system // will eventually redeliver the message. AckDeadlineSeconds *float64 `json:"ackDeadlineSeconds,omitempty" tf:"ack_deadline_seconds,omitempty"` // If delivery to BigQuery is used with this subscription, this field is used to configure it. // Either pushConfig, bigQueryConfig or cloudStorageConfig can be set, but not combined. // If all three are empty, then the subscriber will pull and ack messages using API methods. // Structure is documented below. BigqueryConfig []BigqueryConfigObservation `json:"bigqueryConfig,omitempty" tf:"bigquery_config,omitempty"` // If delivery to Cloud Storage is used with this subscription, this field is used to configure it. // Either pushConfig, bigQueryConfig or cloudStorageConfig can be set, but not combined. // If all three are empty, then the subscriber will pull and ack messages using API methods. // Structure is documented below. CloudStorageConfig []CloudStorageConfigObservation `json:"cloudStorageConfig,omitempty" tf:"cloud_storage_config,omitempty"` // A policy that specifies the conditions for dead lettering messages in // this subscription. If dead_letter_policy is not set, dead lettering // is disabled. // The Cloud Pub/Sub service account associated with this subscription's // parent project (i.e., // service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have // permission to Acknowledge() messages on this subscription. // Structure is documented below. DeadLetterPolicy []DeadLetterPolicyObservation `json:"deadLetterPolicy,omitempty" tf:"dead_letter_policy,omitempty"` // for all of the labels present on the resource. // +mapType=granular EffectiveLabels map[string]*string `json:"effectiveLabels,omitempty" tf:"effective_labels,omitempty"` // If true, Pub/Sub provides the following guarantees for the delivery // of a message with a given value of messageId on this Subscriptions': EnableExactlyOnceDelivery *bool `json:"enableExactlyOnceDelivery,omitempty" tf:"enable_exactly_once_delivery,omitempty"` // If true, messages published with the same orderingKey in PubsubMessage will be delivered to // the subscribers in the order in which they are received by the Pub/Sub system. Otherwise, they // may be delivered in any order. EnableMessageOrdering *bool `json:"enableMessageOrdering,omitempty" tf:"enable_message_ordering,omitempty"` // A policy that specifies the conditions for this subscription's expiration. // A subscription is considered active as long as any connected subscriber // is successfully consuming messages from the subscription or is issuing // operations on the subscription. If expirationPolicy is not set, a default // policy with ttl of 31 days will be used. If it is set but ttl is "", the // resource never expires. The minimum allowed value for expirationPolicy.ttl // is 1 day. // Structure is documented below. ExpirationPolicy []ExpirationPolicyObservation `json:"expirationPolicy,omitempty" tf:"expiration_policy,omitempty"` // The subscription only delivers the messages that match the filter. // Pub/Sub automatically acknowledges the messages that don't match the filter. You can filter messages // by their attributes. The maximum length of a filter is 256 bytes. After creating the subscription, // you can't modify the filter. Filter *string `json:"filter,omitempty" tf:"filter,omitempty"` // an identifier for the resource with format projects/{{project}}/subscriptions/{{name}} ID *string `json:"id,omitempty" tf:"id,omitempty"` // A set of key/value label pairs to assign to this Subscription. // +mapType=granular Labels map[string]*string `json:"labels,omitempty" tf:"labels,omitempty"` // How long to retain unacknowledged messages in the subscription's // backlog, from the moment a message is published. If // retain_acked_messages is true, then this also configures the retention // of acknowledged messages, and thus configures how far back in time a // subscriptions.seek can be done. Defaults to 7 days. Cannot be more // than 7 days ("604800s") or less than 10 minutes ("600s"). // A duration in seconds with up to nine fractional digits, terminated // by 's'. Example: "600.5s". MessageRetentionDuration *string `json:"messageRetentionDuration,omitempty" tf:"message_retention_duration,omitempty"` // The ID of the project in which the resource belongs. // If it is not provided, the provider project is used. Project *string `json:"project,omitempty" tf:"project,omitempty"` // If push delivery is used with this subscription, this field is used to // configure it. An empty pushConfig signifies that the subscriber will // pull and ack messages using API methods. // Structure is documented below. PushConfig []PushConfigObservation `json:"pushConfig,omitempty" tf:"push_config,omitempty"` // Indicates whether to retain acknowledged messages. If true, then // messages are not expunged from the subscription's backlog, even if // they are acknowledged, until they fall out of the // messageRetentionDuration window. RetainAckedMessages *bool `json:"retainAckedMessages,omitempty" tf:"retain_acked_messages,omitempty"` // A policy that specifies how Pub/Sub retries message delivery for this subscription. // If not set, the default retry policy is applied. This generally implies that messages will be retried as soon as possible for healthy subscribers. // RetryPolicy will be triggered on NACKs or acknowledgement deadline exceeded events for a given message // Structure is documented below. RetryPolicy []RetryPolicyObservation `json:"retryPolicy,omitempty" tf:"retry_policy,omitempty"` // The combination of labels configured directly on the resource // and default labels configured on the provider. // +mapType=granular TerraformLabels map[string]*string `json:"terraformLabels,omitempty" tf:"terraform_labels,omitempty"` // A reference to a Topic resource, of the form projects/{project}/topics/{{name}} // (as in the id property of a google_pubsub_topic), or just a topic name if // the topic is in the same project as the subscription. Topic *string `json:"topic,omitempty" tf:"topic,omitempty"` }
func (*SubscriptionObservation) DeepCopy ¶
func (in *SubscriptionObservation) DeepCopy() *SubscriptionObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionObservation.
func (*SubscriptionObservation) DeepCopyInto ¶
func (in *SubscriptionObservation) DeepCopyInto(out *SubscriptionObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SubscriptionParameters ¶
type SubscriptionParameters struct { // This value is the maximum time after a subscriber receives a message // before the subscriber should acknowledge the message. After message // delivery but before the ack deadline expires and before the message is // acknowledged, it is an outstanding message and will not be delivered // again during that time (on a best-effort basis). // For pull subscriptions, this value is used as the initial value for // the ack deadline. To override this value for a given message, call // subscriptions.modifyAckDeadline with the corresponding ackId if using // pull. The minimum custom deadline you can specify is 10 seconds. The // maximum custom deadline you can specify is 600 seconds (10 minutes). // If this parameter is 0, a default value of 10 seconds is used. // For push delivery, this value is also used to set the request timeout // for the call to the push endpoint. // If the subscriber never acknowledges the message, the Pub/Sub system // will eventually redeliver the message. // +kubebuilder:validation:Optional AckDeadlineSeconds *float64 `json:"ackDeadlineSeconds,omitempty" tf:"ack_deadline_seconds,omitempty"` // If delivery to BigQuery is used with this subscription, this field is used to configure it. // Either pushConfig, bigQueryConfig or cloudStorageConfig can be set, but not combined. // If all three are empty, then the subscriber will pull and ack messages using API methods. // Structure is documented below. // +kubebuilder:validation:Optional BigqueryConfig []BigqueryConfigParameters `json:"bigqueryConfig,omitempty" tf:"bigquery_config,omitempty"` // If delivery to Cloud Storage is used with this subscription, this field is used to configure it. // Either pushConfig, bigQueryConfig or cloudStorageConfig can be set, but not combined. // If all three are empty, then the subscriber will pull and ack messages using API methods. // Structure is documented below. // +kubebuilder:validation:Optional CloudStorageConfig []CloudStorageConfigParameters `json:"cloudStorageConfig,omitempty" tf:"cloud_storage_config,omitempty"` // A policy that specifies the conditions for dead lettering messages in // this subscription. If dead_letter_policy is not set, dead lettering // is disabled. // The Cloud Pub/Sub service account associated with this subscription's // parent project (i.e., // service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have // permission to Acknowledge() messages on this subscription. // Structure is documented below. // +kubebuilder:validation:Optional DeadLetterPolicy []DeadLetterPolicyParameters `json:"deadLetterPolicy,omitempty" tf:"dead_letter_policy,omitempty"` // If true, Pub/Sub provides the following guarantees for the delivery // of a message with a given value of messageId on this Subscriptions': // +kubebuilder:validation:Optional EnableExactlyOnceDelivery *bool `json:"enableExactlyOnceDelivery,omitempty" tf:"enable_exactly_once_delivery,omitempty"` // If true, messages published with the same orderingKey in PubsubMessage will be delivered to // the subscribers in the order in which they are received by the Pub/Sub system. Otherwise, they // may be delivered in any order. // +kubebuilder:validation:Optional EnableMessageOrdering *bool `json:"enableMessageOrdering,omitempty" tf:"enable_message_ordering,omitempty"` // A policy that specifies the conditions for this subscription's expiration. // A subscription is considered active as long as any connected subscriber // is successfully consuming messages from the subscription or is issuing // operations on the subscription. If expirationPolicy is not set, a default // policy with ttl of 31 days will be used. If it is set but ttl is "", the // resource never expires. The minimum allowed value for expirationPolicy.ttl // is 1 day. // Structure is documented below. // +kubebuilder:validation:Optional ExpirationPolicy []ExpirationPolicyParameters `json:"expirationPolicy,omitempty" tf:"expiration_policy,omitempty"` // The subscription only delivers the messages that match the filter. // Pub/Sub automatically acknowledges the messages that don't match the filter. You can filter messages // by their attributes. The maximum length of a filter is 256 bytes. After creating the subscription, // you can't modify the filter. // +kubebuilder:validation:Optional Filter *string `json:"filter,omitempty" tf:"filter,omitempty"` // A set of key/value label pairs to assign to this Subscription. // +kubebuilder:validation:Optional // +mapType=granular Labels map[string]*string `json:"labels,omitempty" tf:"labels,omitempty"` // How long to retain unacknowledged messages in the subscription's // backlog, from the moment a message is published. If // retain_acked_messages is true, then this also configures the retention // of acknowledged messages, and thus configures how far back in time a // subscriptions.seek can be done. Defaults to 7 days. Cannot be more // than 7 days ("604800s") or less than 10 minutes ("600s"). // A duration in seconds with up to nine fractional digits, terminated // by 's'. Example: "600.5s". // +kubebuilder:validation:Optional MessageRetentionDuration *string `json:"messageRetentionDuration,omitempty" tf:"message_retention_duration,omitempty"` // The ID of the project in which the resource belongs. // If it is not provided, the provider project is used. // +kubebuilder:validation:Optional Project *string `json:"project,omitempty" tf:"project,omitempty"` // If push delivery is used with this subscription, this field is used to // configure it. An empty pushConfig signifies that the subscriber will // pull and ack messages using API methods. // Structure is documented below. // +kubebuilder:validation:Optional PushConfig []PushConfigParameters `json:"pushConfig,omitempty" tf:"push_config,omitempty"` // Indicates whether to retain acknowledged messages. If true, then // messages are not expunged from the subscription's backlog, even if // they are acknowledged, until they fall out of the // messageRetentionDuration window. // +kubebuilder:validation:Optional RetainAckedMessages *bool `json:"retainAckedMessages,omitempty" tf:"retain_acked_messages,omitempty"` // A policy that specifies how Pub/Sub retries message delivery for this subscription. // If not set, the default retry policy is applied. This generally implies that messages will be retried as soon as possible for healthy subscribers. // RetryPolicy will be triggered on NACKs or acknowledgement deadline exceeded events for a given message // Structure is documented below. // +kubebuilder:validation:Optional RetryPolicy []RetryPolicyParameters `json:"retryPolicy,omitempty" tf:"retry_policy,omitempty"` // A reference to a Topic resource, of the form projects/{project}/topics/{{name}} // (as in the id property of a google_pubsub_topic), or just a topic name if // the topic is in the same project as the subscription. // +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/pubsub/v1beta1.Topic // +kubebuilder:validation:Optional Topic *string `json:"topic,omitempty" tf:"topic,omitempty"` // Reference to a Topic in pubsub to populate topic. // +kubebuilder:validation:Optional TopicRef *v1.Reference `json:"topicRef,omitempty" tf:"-"` // Selector for a Topic in pubsub to populate topic. // +kubebuilder:validation:Optional TopicSelector *v1.Selector `json:"topicSelector,omitempty" tf:"-"` }
func (*SubscriptionParameters) DeepCopy ¶
func (in *SubscriptionParameters) DeepCopy() *SubscriptionParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionParameters.
func (*SubscriptionParameters) DeepCopyInto ¶
func (in *SubscriptionParameters) DeepCopyInto(out *SubscriptionParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SubscriptionSpec ¶
type SubscriptionSpec struct { v1.ResourceSpec `json:",inline"` ForProvider SubscriptionParameters `json:"forProvider"` // THIS IS A BETA FIELD. It will be honored // unless the Management Policies feature flag is disabled. // InitProvider holds the same fields as ForProvider, with the exception // of Identifier and other resource reference fields. The fields that are // in InitProvider are merged into ForProvider when the resource is created. // The same fields are also added to the terraform ignore_changes hook, to // avoid updating them after creation. This is useful for fields that are // required on creation, but we do not desire to update them after creation, // for example because of an external controller is managing them, like an // autoscaler. InitProvider SubscriptionInitParameters `json:"initProvider,omitempty"` }
SubscriptionSpec defines the desired state of Subscription
func (*SubscriptionSpec) DeepCopy ¶
func (in *SubscriptionSpec) DeepCopy() *SubscriptionSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionSpec.
func (*SubscriptionSpec) DeepCopyInto ¶
func (in *SubscriptionSpec) DeepCopyInto(out *SubscriptionSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SubscriptionStatus ¶
type SubscriptionStatus struct { v1.ResourceStatus `json:",inline"` AtProvider SubscriptionObservation `json:"atProvider,omitempty"` }
SubscriptionStatus defines the observed state of Subscription.
func (*SubscriptionStatus) DeepCopy ¶
func (in *SubscriptionStatus) DeepCopy() *SubscriptionStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionStatus.
func (*SubscriptionStatus) DeepCopyInto ¶
func (in *SubscriptionStatus) DeepCopyInto(out *SubscriptionStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Topic ¶
type Topic struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec TopicSpec `json:"spec"` Status TopicStatus `json:"status,omitempty"` }
Topic is the Schema for the Topics API. A named resource to which messages are sent by publishers. +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcp}
func (*Topic) ConvertFrom ¶ added in v1.2.0
func (tr *Topic) ConvertFrom(srcRaw conversion.Hub) error
ConvertFrom converts from the hub type to the Topic type.
func (*Topic) ConvertTo ¶ added in v1.2.0
func (tr *Topic) ConvertTo(dstRaw conversion.Hub) error
ConvertTo converts this Topic to the hub type.
func (*Topic) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Topic.
func (*Topic) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Topic) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Topic) GetCondition ¶
func (mg *Topic) GetCondition(ct xpv1.ConditionType) xpv1.Condition
GetCondition of this Topic.
func (*Topic) GetConnectionDetailsMapping ¶
GetConnectionDetailsMapping for this Topic
func (*Topic) GetDeletionPolicy ¶
func (mg *Topic) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this Topic.
func (*Topic) GetInitParameters ¶ added in v0.35.0
GetInitParameters of this Topic
func (*Topic) GetManagementPolicies ¶ added in v0.35.0
func (mg *Topic) GetManagementPolicies() xpv1.ManagementPolicies
GetManagementPolicies of this Topic.
func (*Topic) GetMergedParameters ¶ added in v0.40.0
GetInitParameters of this Topic
func (*Topic) GetObservation ¶
GetObservation of this Topic
func (*Topic) GetParameters ¶
GetParameters of this Topic
func (*Topic) GetProviderConfigReference ¶
GetProviderConfigReference of this Topic.
func (*Topic) GetPublishConnectionDetailsTo ¶
func (mg *Topic) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this Topic.
func (*Topic) GetTerraformResourceType ¶
GetTerraformResourceType returns Terraform resource type for this Topic
func (*Topic) GetTerraformSchemaVersion ¶
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*Topic) GetWriteConnectionSecretToReference ¶
func (mg *Topic) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this Topic.
func (*Topic) LateInitialize ¶
LateInitialize this Topic using its observed tfState. returns True if there are any spec changes for the resource.
func (*Topic) ResolveReferences ¶
ResolveReferences of this Topic.
func (*Topic) SetConditions ¶
SetConditions of this Topic.
func (*Topic) SetDeletionPolicy ¶
func (mg *Topic) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this Topic.
func (*Topic) SetManagementPolicies ¶ added in v0.35.0
func (mg *Topic) SetManagementPolicies(r xpv1.ManagementPolicies)
SetManagementPolicies of this Topic.
func (*Topic) SetObservation ¶
SetObservation for this Topic
func (*Topic) SetParameters ¶
SetParameters for this Topic
func (*Topic) SetProviderConfigReference ¶
SetProviderConfigReference of this Topic.
func (*Topic) SetPublishConnectionDetailsTo ¶
func (mg *Topic) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
SetPublishConnectionDetailsTo of this Topic.
func (*Topic) SetWriteConnectionSecretToReference ¶
func (mg *Topic) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
SetWriteConnectionSecretToReference of this Topic.
type TopicIAMMember ¶
type TopicIAMMember struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` // +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.member) || (has(self.initProvider) && has(self.initProvider.member))",message="spec.forProvider.member is a required parameter" // +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.role) || (has(self.initProvider) && has(self.initProvider.role))",message="spec.forProvider.role is a required parameter" Spec TopicIAMMemberSpec `json:"spec"` Status TopicIAMMemberStatus `json:"status,omitempty"` }
TopicIAMMember is the Schema for the TopicIAMMembers API. <no value> +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcp}
func (*TopicIAMMember) ConvertFrom ¶ added in v1.2.0
func (tr *TopicIAMMember) ConvertFrom(srcRaw conversion.Hub) error
ConvertFrom converts from the hub type to the TopicIAMMember type.
func (*TopicIAMMember) ConvertTo ¶ added in v1.2.0
func (tr *TopicIAMMember) ConvertTo(dstRaw conversion.Hub) error
ConvertTo converts this TopicIAMMember to the hub type.
func (*TopicIAMMember) DeepCopy ¶
func (in *TopicIAMMember) DeepCopy() *TopicIAMMember
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicIAMMember.
func (*TopicIAMMember) DeepCopyInto ¶
func (in *TopicIAMMember) DeepCopyInto(out *TopicIAMMember)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*TopicIAMMember) DeepCopyObject ¶
func (in *TopicIAMMember) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*TopicIAMMember) GetCondition ¶
func (mg *TopicIAMMember) GetCondition(ct xpv1.ConditionType) xpv1.Condition
GetCondition of this TopicIAMMember.
func (*TopicIAMMember) GetConnectionDetailsMapping ¶
func (tr *TopicIAMMember) GetConnectionDetailsMapping() map[string]string
GetConnectionDetailsMapping for this TopicIAMMember
func (*TopicIAMMember) GetDeletionPolicy ¶
func (mg *TopicIAMMember) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this TopicIAMMember.
func (*TopicIAMMember) GetID ¶
func (tr *TopicIAMMember) GetID() string
GetID returns ID of underlying Terraform resource of this TopicIAMMember
func (*TopicIAMMember) GetInitParameters ¶ added in v0.35.0
func (tr *TopicIAMMember) GetInitParameters() (map[string]any, error)
GetInitParameters of this TopicIAMMember
func (*TopicIAMMember) GetManagementPolicies ¶ added in v0.35.0
func (mg *TopicIAMMember) GetManagementPolicies() xpv1.ManagementPolicies
GetManagementPolicies of this TopicIAMMember.
func (*TopicIAMMember) GetMergedParameters ¶ added in v0.40.0
func (tr *TopicIAMMember) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)
GetInitParameters of this TopicIAMMember
func (*TopicIAMMember) GetObservation ¶
func (tr *TopicIAMMember) GetObservation() (map[string]any, error)
GetObservation of this TopicIAMMember
func (*TopicIAMMember) GetParameters ¶
func (tr *TopicIAMMember) GetParameters() (map[string]any, error)
GetParameters of this TopicIAMMember
func (*TopicIAMMember) GetProviderConfigReference ¶
func (mg *TopicIAMMember) GetProviderConfigReference() *xpv1.Reference
GetProviderConfigReference of this TopicIAMMember.
func (*TopicIAMMember) GetPublishConnectionDetailsTo ¶
func (mg *TopicIAMMember) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this TopicIAMMember.
func (*TopicIAMMember) GetTerraformResourceType ¶
func (mg *TopicIAMMember) GetTerraformResourceType() string
GetTerraformResourceType returns Terraform resource type for this TopicIAMMember
func (*TopicIAMMember) GetTerraformSchemaVersion ¶
func (tr *TopicIAMMember) GetTerraformSchemaVersion() int
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*TopicIAMMember) GetWriteConnectionSecretToReference ¶
func (mg *TopicIAMMember) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this TopicIAMMember.
func (*TopicIAMMember) LateInitialize ¶
func (tr *TopicIAMMember) LateInitialize(attrs []byte) (bool, error)
LateInitialize this TopicIAMMember using its observed tfState. returns True if there are any spec changes for the resource.
func (*TopicIAMMember) ResolveReferences ¶
ResolveReferences of this TopicIAMMember.
func (*TopicIAMMember) SetConditions ¶
func (mg *TopicIAMMember) SetConditions(c ...xpv1.Condition)
SetConditions of this TopicIAMMember.
func (*TopicIAMMember) SetDeletionPolicy ¶
func (mg *TopicIAMMember) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this TopicIAMMember.
func (*TopicIAMMember) SetManagementPolicies ¶ added in v0.35.0
func (mg *TopicIAMMember) SetManagementPolicies(r xpv1.ManagementPolicies)
SetManagementPolicies of this TopicIAMMember.
func (*TopicIAMMember) SetObservation ¶
func (tr *TopicIAMMember) SetObservation(obs map[string]any) error
SetObservation for this TopicIAMMember
func (*TopicIAMMember) SetParameters ¶
func (tr *TopicIAMMember) SetParameters(params map[string]any) error
SetParameters for this TopicIAMMember
func (*TopicIAMMember) SetProviderConfigReference ¶
func (mg *TopicIAMMember) SetProviderConfigReference(r *xpv1.Reference)
SetProviderConfigReference of this TopicIAMMember.
func (*TopicIAMMember) SetPublishConnectionDetailsTo ¶
func (mg *TopicIAMMember) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
SetPublishConnectionDetailsTo of this TopicIAMMember.
func (*TopicIAMMember) SetWriteConnectionSecretToReference ¶
func (mg *TopicIAMMember) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
SetWriteConnectionSecretToReference of this TopicIAMMember.
type TopicIAMMemberConditionInitParameters ¶ added in v0.35.0
type TopicIAMMemberConditionInitParameters struct { Description *string `json:"description,omitempty" tf:"description,omitempty"` Expression *string `json:"expression,omitempty" tf:"expression,omitempty"` Title *string `json:"title,omitempty" tf:"title,omitempty"` }
func (*TopicIAMMemberConditionInitParameters) DeepCopy ¶ added in v0.35.0
func (in *TopicIAMMemberConditionInitParameters) DeepCopy() *TopicIAMMemberConditionInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicIAMMemberConditionInitParameters.
func (*TopicIAMMemberConditionInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *TopicIAMMemberConditionInitParameters) DeepCopyInto(out *TopicIAMMemberConditionInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TopicIAMMemberConditionObservation ¶
type TopicIAMMemberConditionObservation struct { Description *string `json:"description,omitempty" tf:"description,omitempty"` Expression *string `json:"expression,omitempty" tf:"expression,omitempty"` Title *string `json:"title,omitempty" tf:"title,omitempty"` }
func (*TopicIAMMemberConditionObservation) DeepCopy ¶
func (in *TopicIAMMemberConditionObservation) DeepCopy() *TopicIAMMemberConditionObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicIAMMemberConditionObservation.
func (*TopicIAMMemberConditionObservation) DeepCopyInto ¶
func (in *TopicIAMMemberConditionObservation) DeepCopyInto(out *TopicIAMMemberConditionObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TopicIAMMemberConditionParameters ¶
type TopicIAMMemberConditionParameters struct { // +kubebuilder:validation:Optional Description *string `json:"description,omitempty" tf:"description,omitempty"` // +kubebuilder:validation:Optional Expression *string `json:"expression" tf:"expression,omitempty"` // +kubebuilder:validation:Optional Title *string `json:"title" tf:"title,omitempty"` }
func (*TopicIAMMemberConditionParameters) DeepCopy ¶
func (in *TopicIAMMemberConditionParameters) DeepCopy() *TopicIAMMemberConditionParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicIAMMemberConditionParameters.
func (*TopicIAMMemberConditionParameters) DeepCopyInto ¶
func (in *TopicIAMMemberConditionParameters) DeepCopyInto(out *TopicIAMMemberConditionParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TopicIAMMemberInitParameters ¶ added in v0.35.0
type TopicIAMMemberInitParameters struct { Condition []TopicIAMMemberConditionInitParameters `json:"condition,omitempty" tf:"condition,omitempty"` Member *string `json:"member,omitempty" tf:"member,omitempty"` Project *string `json:"project,omitempty" tf:"project,omitempty"` Role *string `json:"role,omitempty" tf:"role,omitempty"` // +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/pubsub/v1beta1.Topic Topic *string `json:"topic,omitempty" tf:"topic,omitempty"` // Reference to a Topic in pubsub to populate topic. // +kubebuilder:validation:Optional TopicRef *v1.Reference `json:"topicRef,omitempty" tf:"-"` // Selector for a Topic in pubsub to populate topic. // +kubebuilder:validation:Optional TopicSelector *v1.Selector `json:"topicSelector,omitempty" tf:"-"` }
func (*TopicIAMMemberInitParameters) DeepCopy ¶ added in v0.35.0
func (in *TopicIAMMemberInitParameters) DeepCopy() *TopicIAMMemberInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicIAMMemberInitParameters.
func (*TopicIAMMemberInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *TopicIAMMemberInitParameters) DeepCopyInto(out *TopicIAMMemberInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TopicIAMMemberList ¶
type TopicIAMMemberList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []TopicIAMMember `json:"items"` }
TopicIAMMemberList contains a list of TopicIAMMembers
func (*TopicIAMMemberList) DeepCopy ¶
func (in *TopicIAMMemberList) DeepCopy() *TopicIAMMemberList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicIAMMemberList.
func (*TopicIAMMemberList) DeepCopyInto ¶
func (in *TopicIAMMemberList) DeepCopyInto(out *TopicIAMMemberList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*TopicIAMMemberList) DeepCopyObject ¶
func (in *TopicIAMMemberList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*TopicIAMMemberList) GetItems ¶
func (l *TopicIAMMemberList) GetItems() []resource.Managed
GetItems of this TopicIAMMemberList.
type TopicIAMMemberObservation ¶
type TopicIAMMemberObservation struct { Condition []TopicIAMMemberConditionObservation `json:"condition,omitempty" tf:"condition,omitempty"` Etag *string `json:"etag,omitempty" tf:"etag,omitempty"` ID *string `json:"id,omitempty" tf:"id,omitempty"` Member *string `json:"member,omitempty" tf:"member,omitempty"` Project *string `json:"project,omitempty" tf:"project,omitempty"` Role *string `json:"role,omitempty" tf:"role,omitempty"` Topic *string `json:"topic,omitempty" tf:"topic,omitempty"` }
func (*TopicIAMMemberObservation) DeepCopy ¶
func (in *TopicIAMMemberObservation) DeepCopy() *TopicIAMMemberObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicIAMMemberObservation.
func (*TopicIAMMemberObservation) DeepCopyInto ¶
func (in *TopicIAMMemberObservation) DeepCopyInto(out *TopicIAMMemberObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TopicIAMMemberParameters ¶
type TopicIAMMemberParameters struct { // +kubebuilder:validation:Optional Condition []TopicIAMMemberConditionParameters `json:"condition,omitempty" tf:"condition,omitempty"` // +kubebuilder:validation:Optional Member *string `json:"member,omitempty" tf:"member,omitempty"` // +kubebuilder:validation:Optional Project *string `json:"project,omitempty" tf:"project,omitempty"` // +kubebuilder:validation:Optional Role *string `json:"role,omitempty" tf:"role,omitempty"` // +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/pubsub/v1beta1.Topic // +kubebuilder:validation:Optional Topic *string `json:"topic,omitempty" tf:"topic,omitempty"` // Reference to a Topic in pubsub to populate topic. // +kubebuilder:validation:Optional TopicRef *v1.Reference `json:"topicRef,omitempty" tf:"-"` // Selector for a Topic in pubsub to populate topic. // +kubebuilder:validation:Optional TopicSelector *v1.Selector `json:"topicSelector,omitempty" tf:"-"` }
func (*TopicIAMMemberParameters) DeepCopy ¶
func (in *TopicIAMMemberParameters) DeepCopy() *TopicIAMMemberParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicIAMMemberParameters.
func (*TopicIAMMemberParameters) DeepCopyInto ¶
func (in *TopicIAMMemberParameters) DeepCopyInto(out *TopicIAMMemberParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TopicIAMMemberSpec ¶
type TopicIAMMemberSpec struct { v1.ResourceSpec `json:",inline"` ForProvider TopicIAMMemberParameters `json:"forProvider"` // THIS IS A BETA FIELD. It will be honored // unless the Management Policies feature flag is disabled. // InitProvider holds the same fields as ForProvider, with the exception // of Identifier and other resource reference fields. The fields that are // in InitProvider are merged into ForProvider when the resource is created. // The same fields are also added to the terraform ignore_changes hook, to // avoid updating them after creation. This is useful for fields that are // required on creation, but we do not desire to update them after creation, // for example because of an external controller is managing them, like an // autoscaler. InitProvider TopicIAMMemberInitParameters `json:"initProvider,omitempty"` }
TopicIAMMemberSpec defines the desired state of TopicIAMMember
func (*TopicIAMMemberSpec) DeepCopy ¶
func (in *TopicIAMMemberSpec) DeepCopy() *TopicIAMMemberSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicIAMMemberSpec.
func (*TopicIAMMemberSpec) DeepCopyInto ¶
func (in *TopicIAMMemberSpec) DeepCopyInto(out *TopicIAMMemberSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TopicIAMMemberStatus ¶
type TopicIAMMemberStatus struct { v1.ResourceStatus `json:",inline"` AtProvider TopicIAMMemberObservation `json:"atProvider,omitempty"` }
TopicIAMMemberStatus defines the observed state of TopicIAMMember.
func (*TopicIAMMemberStatus) DeepCopy ¶
func (in *TopicIAMMemberStatus) DeepCopy() *TopicIAMMemberStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicIAMMemberStatus.
func (*TopicIAMMemberStatus) DeepCopyInto ¶
func (in *TopicIAMMemberStatus) DeepCopyInto(out *TopicIAMMemberStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TopicInitParameters ¶ added in v0.35.0
type TopicInitParameters struct { // The resource name of the Cloud KMS CryptoKey to be used to protect access // to messages published on this topic. Your project's PubSub service account // (service-{{PROJECT_NUMBER}}@gcp-sa-pubsub.iam.gserviceaccount.com) must have // roles/cloudkms.cryptoKeyEncrypterDecrypter to use this feature. // The expected format is projects/*/locations/*/keyRings/*/cryptoKeys/* // +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/kms/v1beta1.CryptoKey // +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractResourceID() KMSKeyName *string `json:"kmsKeyName,omitempty" tf:"kms_key_name,omitempty"` // Reference to a CryptoKey in kms to populate kmsKeyName. // +kubebuilder:validation:Optional KMSKeyNameRef *v1.Reference `json:"kmsKeyNameRef,omitempty" tf:"-"` // Selector for a CryptoKey in kms to populate kmsKeyName. // +kubebuilder:validation:Optional KMSKeyNameSelector *v1.Selector `json:"kmsKeyNameSelector,omitempty" tf:"-"` // A set of key/value label pairs to assign to this Topic. // +mapType=granular Labels map[string]*string `json:"labels,omitempty" tf:"labels,omitempty"` // Indicates the minimum duration to retain a message after it is published // to the topic. If this field is set, messages published to the topic in // the last messageRetentionDuration are always available to subscribers. // For instance, it allows any attached subscription to seek to a timestamp // that is up to messageRetentionDuration in the past. If this field is not // set, message retention is controlled by settings on individual subscriptions. // The rotation period has the format of a decimal number, followed by the // letter s (seconds). Cannot be more than 31 days or less than 10 minutes. MessageRetentionDuration *string `json:"messageRetentionDuration,omitempty" tf:"message_retention_duration,omitempty"` // Policy constraining the set of Google Cloud Platform regions where // messages published to the topic may be stored. If not present, then no // constraints are in effect. // Structure is documented below. MessageStoragePolicy []MessageStoragePolicyInitParameters `json:"messageStoragePolicy,omitempty" tf:"message_storage_policy,omitempty"` // The ID of the project in which the resource belongs. // If it is not provided, the provider project is used. Project *string `json:"project,omitempty" tf:"project,omitempty"` // Settings for validating messages published against a schema. // Structure is documented below. SchemaSettings []SchemaSettingsInitParameters `json:"schemaSettings,omitempty" tf:"schema_settings,omitempty"` }
func (*TopicInitParameters) DeepCopy ¶ added in v0.35.0
func (in *TopicInitParameters) DeepCopy() *TopicInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicInitParameters.
func (*TopicInitParameters) DeepCopyInto ¶ added in v0.35.0
func (in *TopicInitParameters) DeepCopyInto(out *TopicInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TopicList ¶
type TopicList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Topic `json:"items"` }
TopicList contains a list of Topics
func (*TopicList) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicList.
func (*TopicList) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*TopicList) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type TopicObservation ¶
type TopicObservation struct { // for all of the labels present on the resource. // +mapType=granular EffectiveLabels map[string]*string `json:"effectiveLabels,omitempty" tf:"effective_labels,omitempty"` // an identifier for the resource with format projects/{{project}}/topics/{{name}} ID *string `json:"id,omitempty" tf:"id,omitempty"` // The resource name of the Cloud KMS CryptoKey to be used to protect access // to messages published on this topic. Your project's PubSub service account // (service-{{PROJECT_NUMBER}}@gcp-sa-pubsub.iam.gserviceaccount.com) must have // roles/cloudkms.cryptoKeyEncrypterDecrypter to use this feature. // The expected format is projects/*/locations/*/keyRings/*/cryptoKeys/* KMSKeyName *string `json:"kmsKeyName,omitempty" tf:"kms_key_name,omitempty"` // A set of key/value label pairs to assign to this Topic. // +mapType=granular Labels map[string]*string `json:"labels,omitempty" tf:"labels,omitempty"` // Indicates the minimum duration to retain a message after it is published // to the topic. If this field is set, messages published to the topic in // the last messageRetentionDuration are always available to subscribers. // For instance, it allows any attached subscription to seek to a timestamp // that is up to messageRetentionDuration in the past. If this field is not // set, message retention is controlled by settings on individual subscriptions. // The rotation period has the format of a decimal number, followed by the // letter s (seconds). Cannot be more than 31 days or less than 10 minutes. MessageRetentionDuration *string `json:"messageRetentionDuration,omitempty" tf:"message_retention_duration,omitempty"` // Policy constraining the set of Google Cloud Platform regions where // messages published to the topic may be stored. If not present, then no // constraints are in effect. // Structure is documented below. MessageStoragePolicy []MessageStoragePolicyObservation `json:"messageStoragePolicy,omitempty" tf:"message_storage_policy,omitempty"` // The ID of the project in which the resource belongs. // If it is not provided, the provider project is used. Project *string `json:"project,omitempty" tf:"project,omitempty"` // Settings for validating messages published against a schema. // Structure is documented below. SchemaSettings []SchemaSettingsObservation `json:"schemaSettings,omitempty" tf:"schema_settings,omitempty"` // The combination of labels configured directly on the resource // and default labels configured on the provider. // +mapType=granular TerraformLabels map[string]*string `json:"terraformLabels,omitempty" tf:"terraform_labels,omitempty"` }
func (*TopicObservation) DeepCopy ¶
func (in *TopicObservation) DeepCopy() *TopicObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicObservation.
func (*TopicObservation) DeepCopyInto ¶
func (in *TopicObservation) DeepCopyInto(out *TopicObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TopicParameters ¶
type TopicParameters struct { // The resource name of the Cloud KMS CryptoKey to be used to protect access // to messages published on this topic. Your project's PubSub service account // (service-{{PROJECT_NUMBER}}@gcp-sa-pubsub.iam.gserviceaccount.com) must have // roles/cloudkms.cryptoKeyEncrypterDecrypter to use this feature. // The expected format is projects/*/locations/*/keyRings/*/cryptoKeys/* // +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/kms/v1beta1.CryptoKey // +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractResourceID() // +kubebuilder:validation:Optional KMSKeyName *string `json:"kmsKeyName,omitempty" tf:"kms_key_name,omitempty"` // Reference to a CryptoKey in kms to populate kmsKeyName. // +kubebuilder:validation:Optional KMSKeyNameRef *v1.Reference `json:"kmsKeyNameRef,omitempty" tf:"-"` // Selector for a CryptoKey in kms to populate kmsKeyName. // +kubebuilder:validation:Optional KMSKeyNameSelector *v1.Selector `json:"kmsKeyNameSelector,omitempty" tf:"-"` // A set of key/value label pairs to assign to this Topic. // +kubebuilder:validation:Optional // +mapType=granular Labels map[string]*string `json:"labels,omitempty" tf:"labels,omitempty"` // Indicates the minimum duration to retain a message after it is published // to the topic. If this field is set, messages published to the topic in // the last messageRetentionDuration are always available to subscribers. // For instance, it allows any attached subscription to seek to a timestamp // that is up to messageRetentionDuration in the past. If this field is not // set, message retention is controlled by settings on individual subscriptions. // The rotation period has the format of a decimal number, followed by the // letter s (seconds). Cannot be more than 31 days or less than 10 minutes. // +kubebuilder:validation:Optional MessageRetentionDuration *string `json:"messageRetentionDuration,omitempty" tf:"message_retention_duration,omitempty"` // Policy constraining the set of Google Cloud Platform regions where // messages published to the topic may be stored. If not present, then no // constraints are in effect. // Structure is documented below. // +kubebuilder:validation:Optional MessageStoragePolicy []MessageStoragePolicyParameters `json:"messageStoragePolicy,omitempty" tf:"message_storage_policy,omitempty"` // The ID of the project in which the resource belongs. // If it is not provided, the provider project is used. // +kubebuilder:validation:Optional Project *string `json:"project,omitempty" tf:"project,omitempty"` // Settings for validating messages published against a schema. // Structure is documented below. // +kubebuilder:validation:Optional SchemaSettings []SchemaSettingsParameters `json:"schemaSettings,omitempty" tf:"schema_settings,omitempty"` }
func (*TopicParameters) DeepCopy ¶
func (in *TopicParameters) DeepCopy() *TopicParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicParameters.
func (*TopicParameters) DeepCopyInto ¶
func (in *TopicParameters) DeepCopyInto(out *TopicParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TopicSpec ¶
type TopicSpec struct { v1.ResourceSpec `json:",inline"` ForProvider TopicParameters `json:"forProvider"` // THIS IS A BETA FIELD. It will be honored // unless the Management Policies feature flag is disabled. // InitProvider holds the same fields as ForProvider, with the exception // of Identifier and other resource reference fields. The fields that are // in InitProvider are merged into ForProvider when the resource is created. // The same fields are also added to the terraform ignore_changes hook, to // avoid updating them after creation. This is useful for fields that are // required on creation, but we do not desire to update them after creation, // for example because of an external controller is managing them, like an // autoscaler. InitProvider TopicInitParameters `json:"initProvider,omitempty"` }
TopicSpec defines the desired state of Topic
func (*TopicSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicSpec.
func (*TopicSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TopicStatus ¶
type TopicStatus struct { v1.ResourceStatus `json:",inline"` AtProvider TopicObservation `json:"atProvider,omitempty"` }
TopicStatus defines the observed state of Topic.
func (*TopicStatus) DeepCopy ¶
func (in *TopicStatus) DeepCopy() *TopicStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicStatus.
func (*TopicStatus) DeepCopyInto ¶
func (in *TopicStatus) DeepCopyInto(out *TopicStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
Source Files ¶
- zz_generated.conversion_hubs.go
- zz_generated.conversion_spokes.go
- zz_generated.deepcopy.go
- zz_generated.managed.go
- zz_generated.managedlist.go
- zz_generated.resolvers.go
- zz_groupversion_info.go
- zz_litereservation_terraformed.go
- zz_litereservation_types.go
- zz_litesubscription_terraformed.go
- zz_litesubscription_types.go
- zz_litetopic_terraformed.go
- zz_litetopic_types.go
- zz_schema_terraformed.go
- zz_schema_types.go
- zz_subscription_terraformed.go
- zz_subscription_types.go
- zz_subscriptioniammember_terraformed.go
- zz_subscriptioniammember_types.go
- zz_topic_terraformed.go
- zz_topic_types.go
- zz_topiciammember_terraformed.go
- zz_topiciammember_types.go