resources

Documentation

Index

• func GenerateSubscriptionName(UID types.UID) string
• func GenerateTopicName(UID types.UID) string
• func GetLabelSelector(controller, channel string) labels.Selector
• func GetLabels(controller, channel string) map[string]string
• func GetPullSubscriptionLabelSelector(controller, source, subscriber string) labels.Selector
• func GetPullSubscriptionLabels(controller, channel, subscriber string) map[string]string
• func MakePullSubscription(args *PullSubscriptionArgs) *v1alpha1.PullSubscription
• func MakeTopic(args *TopicArgs) *v1alpha1.Topic
• type PullSubscriptionArgs
• type TopicArgs

Functions

func GenerateSubscriptionName

func GenerateSubscriptionName(UID types.UID) string

func GenerateTopicName

func GenerateTopicName(UID types.UID) string

func GetLabelSelector

func GetLabelSelector(controller, channel string) labels.Selector

func GetLabels

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

func GetPullSubscriptionLabelSelector

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

func GetPullSubscriptionLabels

func GetPullSubscriptionLabels(controller, channel, subscriber 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
	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.