Documentation ¶
Index ¶
- func ExtractUIDFromSubscriptionName(name string) string
- func GeneratePublisherName(channel *v1alpha1.Channel) string
- func GenerateSubscriptionName(UID types.UID) string
- func GenerateTopicID(UID types.UID) string
- func GetLabelSelector(controller, channel, uid string) labels.Selector
- func GetLabels(controller, channel, uid string) map[string]string
- func GetPullSubscriptionAnnotations(channel string) map[string]string
- func GetPullSubscriptionLabelSelector(controller, source, subscriber, uid string) labels.Selector
- func GetPullSubscriptionLabels(controller, channel, subscriber, uid string) map[string]string
- func MakePullSubscription(args *PullSubscriptionArgs) *v1alpha1.PullSubscription
- func MakeTopic(args *TopicArgs) *v1alpha1.Topic
- type PullSubscriptionArgs
- type TopicArgs
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ExtractUIDFromSubscriptionName ¶ added in v0.8.1
func GeneratePublisherName ¶ added in v0.8.1
func GenerateTopicID ¶ added in v0.8.1
func GetLabelSelector ¶
func GetPullSubscriptionAnnotations ¶ added in v0.9.0
func MakePullSubscription ¶
func MakePullSubscription(args *PullSubscriptionArgs) *v1alpha1.PullSubscription
MakePullSubscription generates (but does not insert into K8s) the PullSubscription for Channels.
Types ¶
type PullSubscriptionArgs ¶
type PullSubscriptionArgs struct { Owner kmeta.OwnerRefable Name string Project string Topic string Secret *corev1.SecretKeySelector Labels map[string]string Annotations map[string]string Subscriber duckv1alpha1.SubscriberSpec }
PullSubscriptionArgs are the arguments needed to create a Channel Subscriber. Every field is required.
Click to show internal directories.
Click to hide internal directories.