resources

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

Functions

func ExtractUIDFromSubscriptionName

func ExtractUIDFromSubscriptionName(name string) string

func GeneratePublisherName

func GeneratePublisherName(channel *v1alpha1.Channel) string

func GenerateSubscriptionName

func GenerateSubscriptionName(UID types.UID) string

func GenerateTopicID

func GenerateTopicID(UID types.UID) string

func GetLabelSelector

func GetLabelSelector(controller, channel, uid string) labels.Selector

func GetLabels

func GetLabels(controller, channel, uid string) map[string]string

func GetPullSubscriptionAnnotations

func GetPullSubscriptionAnnotations(channel string) map[string]string

func GetPullSubscriptionLabelSelector

func GetPullSubscriptionLabelSelector(controller, source, subscriber, uid string) labels.Selector

func GetPullSubscriptionLabels

func GetPullSubscriptionLabels(controller, channel, subscriber, uid string) map[string]string

func MakePullSubscription

func MakePullSubscription(args *PullSubscriptionArgs) *v1alpha1.PullSubscription

MakePullSubscription generates (but does not insert into K8s) the PullSubscription for Channels.

func MakeTopic

func MakeTopic(args *TopicArgs) *v1alpha1.Topic

MakeInvoker generates (but does not insert into K8s) the Topic 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.

type TopicArgs

type TopicArgs struct {
	Owner   kmeta.OwnerRefable
	Name    string
	Project string
	Topic   string
	Secret  *corev1.SecretKeySelector
	Labels  map[string]string
}

TopicArgs are the arguments needed to create a Channel Topic. Every field is required.