Documentation ¶
Index ¶
- func GenerateSubscription(projectID, name string, p v1alpha1.SubscriptionParameters) *pubsub.Subscription
- func GenerateUpdateRequest(name string, p v1alpha1.SubscriptionParameters, s pubsub.Subscription) *pubsub.UpdateSubscriptionRequest
- func GetFullyQualifiedName(project string, name string) string
- func IsUpToDate(projectID string, p v1alpha1.SubscriptionParameters, s pubsub.Subscription) bool
- func LateInitialize(p *v1alpha1.SubscriptionParameters, s pubsub.Subscription)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GenerateSubscription ¶
func GenerateSubscription(projectID, name string, p v1alpha1.SubscriptionParameters) *pubsub.Subscription
GenerateSubscription produces a Subscription that is configured via given SubscriptionParameters.
func GenerateUpdateRequest ¶
func GenerateUpdateRequest(name string, p v1alpha1.SubscriptionParameters, s pubsub.Subscription) *pubsub.UpdateSubscriptionRequest
GenerateUpdateRequest produces an UpdateSubscriptionRequest with the difference between SubscriptionParameters and Subscription. enableMessageOrdering, deadLetterPolicy, topic are not mutable
func GetFullyQualifiedName ¶
GetFullyQualifiedName builds the fully qualified name of the subscription.
func IsUpToDate ¶
func IsUpToDate(projectID string, p v1alpha1.SubscriptionParameters, s pubsub.Subscription) bool
IsUpToDate checks whether Subscription is configured with given SubscriptionParameters.
func LateInitialize ¶
func LateInitialize(p *v1alpha1.SubscriptionParameters, s pubsub.Subscription)
LateInitialize fills the empty fields of SubscriptionParameters if the corresponding fields are given in Subscription.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.