resources

Documentation

Index

• func ExtractUIDFromPullSubscriptionName(name string) string
• func GeneratePublisherName(channel *v1beta1.Channel) string
• func GeneratePullSubscriptionName(UID types.UID) string
• func GenerateTopicID(channel *v1beta1.Channel) string
• func GetLabelSelector(controller, channel, uid string) labels.Selector
• func GetLabels(controller, channel, uid string) map[string]string
• func GetPullSubscriptionAnnotations(channel, clusterName string) map[string]string
• func GetPullSubscriptionLabelSelector(controller, source, subscriber, uid string) labels.Selector
• func GetPullSubscriptionLabels(controller, channel, subscriber, uid string) map[string]string
• func GetTopicAnnotations(clusterName string) map[string]string
• func MakePullSubscription(args *PullSubscriptionArgs) *v1beta1.PullSubscription
• func MakeTopic(args *TopicArgs) *v1beta1.Topic
• type PullSubscriptionArgs
• type TopicArgs

Functions

func ExtractUIDFromPullSubscriptionName

func ExtractUIDFromPullSubscriptionName(name string) string

ExtractUIDFromPullSubscriptionName extracts the subscriber's UID from the PullSubscription name.

func GeneratePublisherName

func GeneratePublisherName(channel *v1beta1.Channel) string

func GeneratePullSubscriptionName

func GeneratePullSubscriptionName(UID types.UID) string

GeneratePullSubscriptionName generates the name of the PullSubscription resource using the subscriber's UID.

func GenerateTopicID

func GenerateTopicID(channel *v1beta1.Channel) string

GenerateTopicID generates the name of the Pub/Sub topic, not our Topic resource.

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, clusterName 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 GetTopicAnnotations

func GetTopicAnnotations(clusterName string) map[string]string

func MakePullSubscription

func MakePullSubscription(args *PullSubscriptionArgs) *v1beta1.PullSubscription

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

func MakeTopic

func MakeTopic(args *TopicArgs) *v1beta1.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
	ServiceAccount     string
	ServiceAccountName string
	Secret             *corev1.SecretKeySelector
	Labels             map[string]string
	Annotations        map[string]string
	Subscriber         duckv1beta1.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
	ServiceAccount     string
	ServiceAccountName string
	Secret             *corev1.SecretKeySelector
	Labels             map[string]string
	Annotations        map[string]string
}

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