v1alpha1

package
v0.22.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 10, 2022 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Overview

Package v1alpha1 contains managed resources, such as Topic. +kubebuilder:object:generate=true +groupName=pubsub.gcp.crossplane.io +versionName=v1alpha1

Index

Constants

View Source 
const (
	Group   = "pubsub.gcp.crossplane.io"
	Version = "v1alpha1"
)

Package type metadata.

View Source 
const (
	ConnectionSecretKeyTopic       = "topic"
	ConnectionSecretKeyProjectName = "projectName"
)

Keys used in connection secret.

Variables

View Source 
var (
	// SchemeGroupVersion is group version used to register these objects
	SchemeGroupVersion = schema.GroupVersion{Group: Group, Version: Version}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion}
)
View Source 
var (
	TopicKind             = reflect.TypeOf(Topic{}).Name()
	TopicGroupKind        = schema.GroupKind{Group: Group, Kind: TopicKind}.String()
	TopicKindAPIVersion   = TopicKind + "." + SchemeGroupVersion.String()
	TopicGroupVersionKind = SchemeGroupVersion.WithKind(TopicKind)
)

Topic type metadata.

View Source 
var (
	SubscriptionKind             = reflect.TypeOf(Subscription{}).Name()
	SubscriptionGroupKind        = schema.GroupKind{Group: Group, Kind: SubscriptionKind}.String()
	SubscriptionKindAPIVersion   = SubscriptionKind + "." + SchemeGroupVersion.String()
	SubscriptionGroupVersionKind = SchemeGroupVersion.WithKind(SubscriptionKind)
)

Subscription type metadata.

Functions

This section is empty.

Types

type DeadLetterPolicy 

type DeadLetterPolicy struct {
	// DeadLetterTopic is the name of the topic to which dead letter messages
	// should be published. Format is `projects/{project}/topics/{topic}`.
	DeadLetterTopic string `json:"deadLetterTopic,omitempty"`

	// MaxDeliveryAttempts is the maximum number of delivery attempts for any
	// message. The value must be between 5 and 100.
	// +optional
	MaxDeliveryAttempts int64 `json:"maxDeliveryAttempts,omitempty"`
}

DeadLetterPolicy contains configuration for dead letter policy.

func (*DeadLetterPolicy) DeepCopy 

func (in *DeadLetterPolicy) DeepCopy() *DeadLetterPolicy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeadLetterPolicy.

func (*DeadLetterPolicy) DeepCopyInto 

func (in *DeadLetterPolicy) DeepCopyInto(out *DeadLetterPolicy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ExpirationPolicy 

type ExpirationPolicy struct {
	// TTL is the duration of "time-to-live" for an associated resource.
	// The resource expires if it is not active for a period of `ttl`.
	// +kubebuilder:validation:Pattern=^[0-9]*s$
	TTL string `json:"ttl,omitempty"`
}

ExpirationPolicy contains configuration for resource expiration.

func (*ExpirationPolicy) DeepCopy 

func (in *ExpirationPolicy) DeepCopy() *ExpirationPolicy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExpirationPolicy.

func (*ExpirationPolicy) DeepCopyInto 

func (in *ExpirationPolicy) DeepCopyInto(out *ExpirationPolicy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type MessageStoragePolicy 

type MessageStoragePolicy struct {
	// AllowedPersistenceRegions is the 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"`
}

MessageStoragePolicy contains configuration for message storage policy.

func (*MessageStoragePolicy) DeepCopy 

func (in *MessageStoragePolicy) DeepCopy() *MessageStoragePolicy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MessageStoragePolicy.

func (*MessageStoragePolicy) DeepCopyInto 

func (in *MessageStoragePolicy) DeepCopyInto(out *MessageStoragePolicy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OidcToken 

type OidcToken struct {
	// Audience is the "audience" to be used when generating OIDC token.
	Audience string `json:"audience,omitempty"`

	// ServiceAccountEmail is the email to be used for generating the OIDC token
	ServiceAccountEmail string `json:"serviceAccountEmail,omitempty"`
}

OidcToken contains information needed for generating an OpenID Connect token

func (*OidcToken) DeepCopy 

func (in *OidcToken) DeepCopy() *OidcToken

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OidcToken.

func (*OidcToken) DeepCopyInto 

func (in *OidcToken) DeepCopyInto(out *OidcToken)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PushConfig 

type PushConfig struct {
	// Attributes is the map of endpoint configuration attributes that can be used to
	// control different aspects of the message delivery.
	Attributes map[string]string `json:"attributes,omitempty"`

	// OidcToken is a set of parameters to attach OIDC JWT
	// token as an `Authorization` header in the HTTP request for every
	// pushed message.
	OidcToken *OidcToken `json:"oidcToken,omitempty"`

	// PushEndpoint is a URL locating the endpoint to which messages should be
	// pushed.
	PushEndpoint string `json:"pushEndpoint,omitempty"`
}

PushConfig contains configuration for a push delivery endpoint.

func (*PushConfig) DeepCopy 

func (in *PushConfig) DeepCopy() *PushConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PushConfig.

func (*PushConfig) DeepCopyInto 

func (in *PushConfig) DeepCopyInto(out *PushConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type RetryPolicy 

type RetryPolicy struct {
	// MaximumBackoff is the maximum delay between consecutive deliveries of a
	// given message. Value should be between 0 and 600 seconds. Defaults to
	// 600 seconds.
	MaximumBackoff string `json:"maximumBackoff,omitempty"`

	// MinimumBackoff is the minimum delay between consecutive deliveries of a
	// given message. Value should be between 0 and 600 seconds. Defaults to
	// 10 seconds.
	MinimumBackoff string `json:"minimumBackoff,omitempty"`
}

RetryPolicy is the policy that specifies how Cloud Pub/Sub retries message delivery. Retry delay will be exponential based on provided minimum and maximum backoffs.

func (*RetryPolicy) DeepCopy 

func (in *RetryPolicy) DeepCopy() *RetryPolicy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RetryPolicy.

func (*RetryPolicy) DeepCopyInto 

func (in *RetryPolicy) DeepCopyInto(out *RetryPolicy)

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 a managed resource that represents a Google PubSub Subscription. +kubebuilder:subresource:status +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:resource:scope=Cluster

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

func (mg *Subscription) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this Subscription.

func (*Subscription) GetProviderConfigReference 

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

GetProviderConfigReference of this Subscription.

func (*Subscription) GetProviderReference 

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

GetProviderReference of this Subscription. Deprecated: Use GetProviderConfigReference.

func (*Subscription) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this Subscription.

func (*Subscription) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference 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) SetProviderConfigReference 

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

SetProviderConfigReference of this Subscription.

func (*Subscription) SetProviderReference 

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

SetProviderReference of this Subscription. Deprecated: Use SetProviderConfigReference.

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 SubscriptionList 

type SubscriptionList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Subscription `json:"items"`
}

SubscriptionList contains a list of Subscription types

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 SubscriptionParameters 

type SubscriptionParameters struct {
	// AckDeadlineSeconds is the approximate amount of time Pub/Sub waits for
	// the subscriber to acknowledge receipt before resending the message.
	// 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.
	// +optional
	AckDeadlineSeconds int64 `json:"ackDeadlineSeconds,omitempty"`

	// DeadLetterPolicy is the policy that specifies the conditions for dead
	// lettering messages in this subscription. If dead_letter_policy is not
	// set, dead lettering is disabled.
	// +optional
	DeadLetterPolicy *DeadLetterPolicy `json:"deadLetterPolicy,omitempty"`

	// Detached is the flag which indicates whether the subscription is detached from its
	// topic. Detached subscriptions don't receive messages from their topic
	// and don't retain any backlog.
	// +optional
	Detached bool `json:"detached,omitempty"`

	// EnableMessageOrdering is the flag which controls message delivery order
	// to subscribers. When it is true, messages published with the same
	// `ordering_key` 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.
	// +optional
	EnableMessageOrdering bool `json:"enableMessageOrdering,omitempty"`

	// ExpirationPolicy is the policy that specifies the conditions for this
	// subscription's expiration. If `expiration_policy` is not set, a
	// *default policy* with `ttl` of 31 days will be used. The minimum allowed value
	// for `expiration_policy.ttl` is 1 day.
	// +optional
	ExpirationPolicy *ExpirationPolicy `json:"expirationPolicy,omitempty"`

	// Filter is an expression written in the Pub/Sub filter language
	// (https://cloud.google.com/pubsub/docs/filtering). If non-empty, then
	// only `PubsubMessage`s whose `attributes` field matches the filter are
	// delivered on this subscription. If empty, then no messages are
	// filtered out.
	// +optional
	Filter string `json:"filter,omitempty"`

	// Labels are used as additional metadata on Subscription.
	// +optional
	Labels map[string]string `json:"labels,omitempty"`

	// MessageRetentionDuration is a parameter which defines 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 `Seek` can be done. Defaults to 7
	// days. Cannot be more than 7 days or less than 10 minutes.
	// +optional
	// +kubebuilder:validation:Pattern=^[0-9]*s$
	MessageRetentionDuration string `json:"messageRetentionDuration,omitempty"`

	// PushConfig is a parameter which configures push delivery. An empty
	// `pushConfig` signifies that the subscriber will pull and ack messages
	// using API methods.
	// +optional
	PushConfig *PushConfig `json:"pushConfig,omitempty"`

	// RetainAckedMessages is a message which 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 `message_retention_duration` window.
	// +optional
	RetainAckedMessages bool `json:"retainAckedMessages,omitempty"`

	// RetryPolicy is the 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.
	// +optional
	RetryPolicy *RetryPolicy `json:"retryPolicy,omitempty"`

	// TODO: Add referencer & selector for Topic resource.
	// Topic is the name of the topic from which this subscription
	// is receiving messages. Format is `projects/{project}/topics/{topic}`.
	Topic string `json:"topic,omitempty"`
}

SubscriptionParameters defines parameters for a desired Subscription.

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 {
	xpv1.ResourceSpec `json:",inline"`
	ForProvider       SubscriptionParameters `json:"forProvider"`
}

SubscriptionSpec defines the desired state of a 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 {
	xpv1.ResourceStatus `json:",inline"`
}

SubscriptionStatus represents the observed state of a 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 a managed resource that represents a Google PubSub Topic. +kubebuilder:subresource:status +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcp}

func (*Topic) DeepCopy 

func (in *Topic) DeepCopy() *Topic

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Topic.

func (*Topic) DeepCopyInto 

func (in *Topic) DeepCopyInto(out *Topic)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Topic) DeepCopyObject 

func (in *Topic) DeepCopyObject() runtime.Object

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

func (mg *Topic) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this Topic.

func (*Topic) GetProviderConfigReference 

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

GetProviderConfigReference of this Topic.

func (*Topic) GetProviderReference 

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

GetProviderReference of this Topic. Deprecated: Use GetProviderConfigReference.

func (*Topic) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this Topic.

func (*Topic) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this Topic.

func (*Topic) ResolveReferences 

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

ResolveReferences of this Topic.

func (*Topic) SetConditions 

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

SetConditions of this Topic.

func (*Topic) SetDeletionPolicy 

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

SetDeletionPolicy of this Topic.

func (*Topic) SetProviderConfigReference 

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

SetProviderConfigReference of this Topic.

func (*Topic) SetProviderReference 

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

SetProviderReference of this Topic. Deprecated: Use SetProviderConfigReference.

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 TopicList 

type TopicList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Topic `json:"items"`
}

TopicList contains a list of Topic types

func (*TopicList) DeepCopy 

func (in *TopicList) DeepCopy() *TopicList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicList.

func (*TopicList) DeepCopyInto 

func (in *TopicList) DeepCopyInto(out *TopicList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TopicList) DeepCopyObject 

func (in *TopicList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*TopicList) GetItems 

func (l *TopicList) GetItems() []resource.Managed

GetItems of this TopicList.

type TopicParameters 

type TopicParameters struct {
	// Labels are used as additional metadata on Topic.
	// +optional
	Labels map[string]string `json:"labels,omitempty"`
	// MessageStoragePolicy is the 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.
	// +optional
	MessageStoragePolicy *MessageStoragePolicy `json:"messageStoragePolicy,omitempty"`

	// MessageRetentionDuration: 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
	// `message_retention_duration` are always available to subscribers. For
	// instance, it allows any attached subscription to seek to a timestamp
	// (https://cloud.google.com/pubsub/docs/replay-overview#seek_to_a_time)
	// that is up to `message_retention_duration` in the past. If this field
	// is not set, message retention is controlled by settings on individual
	// subscriptions. Cannot be more than 31 days or less than 10 minutes.
	//
	// The duration must be in seconds, terminated by 's'. Example: "1200s".
	// Avoid using fractional digits.
	//
	// +kubebuilder:validation:Pattern=[0-9]+s$
	// +optional
	MessageRetentionDuration *string `json:"messageRetentionDuration,omitempty"`

	// KmsKeyName is the resource name of the Cloud KMS CryptoKey to be used to
	// protect access to messages published on this topic.
	//
	// The expected format is `projects/*/locations/*/keyRings/*/cryptoKeys/*`.
	// +optional
	// +immutable
	// +crossplane:generate:reference:type=github.com/crossplane-contrib/provider-gcp/apis/kms/v1alpha1.CryptoKey
	// +crossplane:generate:reference:extractor=github.com/crossplane-contrib/provider-gcp/apis/kms/v1alpha1.CryptoKeyRRN()
	KmsKeyName *string `json:"kmsKeyName,omitempty"`

	// KmsKeyNameRef allows you to specify custom resource name of the KMS Key
	// to fill KmsKeyName field.
	KmsKeyNameRef *xpv1.Reference `json:"kmsKeyNameRef,omitempty"`

	// KmsKeyNameSelector allows you to use selector constraints to select a
	// KMS Key.
	KmsKeyNameSelector *xpv1.Selector `json:"kmsKeyNameSelector,omitempty"`
}

TopicParameters defines parameters for a desired PubSub Topic.

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 {
	xpv1.ResourceSpec `json:",inline"`
	ForProvider       TopicParameters `json:"forProvider"`
}

TopicSpec defines the desired state of a Topic.

func (*TopicSpec) DeepCopy 

func (in *TopicSpec) DeepCopy() *TopicSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicSpec.

func (*TopicSpec) DeepCopyInto 

func (in *TopicSpec) DeepCopyInto(out *TopicSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TopicStatus 

type TopicStatus struct {
	xpv1.ResourceStatus `json:",inline"`
}

TopicStatus represents the observed state of a 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

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.