Documentation ¶
Index ¶
- func MakeFactory(ctor Ctor) Factory
- func NewChannel(name, namespace string, so ...ChannelOption) *v1alpha1.Channel
- func NewChannelWithoutNamespace(name string, so ...ChannelOption) *v1alpha1.Channel
- func NewDeployment(name, namespace string, do ...DeploymentOption) *appsv1.Deployment
- func NewNamespace(name string, o ...NamespaceOption) *corev1.Namespace
- func NewPullSubscription(name, namespace string, so ...PullSubscriptionOption) *v1alpha1.PullSubscription
- func NewPullSubscriptionWithoutNamespace(name string, so ...PullSubscriptionOption) *v1alpha1.PullSubscription
- func NewService(name, namespace string, so ...ServiceOption) *corev1.Service
- func NewTopic(name, namespace string, so ...TopicOption) *v1alpha1.Topic
- func NewUnstructured(gvk metav1.GroupVersionKind, name, namespace string, uo ...UnstructuredOption) *unstructured.Unstructured
- func WithChannelDefaults(s *v1alpha1.Channel)
- func WithChannelDeleted(s *v1alpha1.Channel)
- func WithInitChannelConditions(s *v1alpha1.Channel)
- func WithInitPullSubscriptionConditions(s *v1alpha1.PullSubscription)
- func WithInitTopicConditions(s *v1alpha1.Topic)
- func WithNamespaceDeleted(n *corev1.Namespace)
- func WithPullSubscriptionDeleted(s *v1alpha1.PullSubscription)
- func WithTopicDeleted(s *v1alpha1.Topic)
- func WithTopicDeployed(s *v1alpha1.Topic)
- type ChannelOption
- func WithChannelAddress(url string) ChannelOption
- func WithChannelGenerateName(generateName string) ChannelOption
- func WithChannelLabels(labels map[string]string) ChannelOption
- func WithChannelMarkTopicCreating(topicID string) ChannelOption
- func WithChannelOwnerReferences(ownerReferences []metav1.OwnerReference) ChannelOption
- func WithChannelReady(topicID string) ChannelOption
- func WithChannelSpec(spec v1alpha1.ChannelSpec) ChannelOption
- func WithChannelSubscribers(subscribers []duckv1alpha1.SubscriberSpec) ChannelOption
- func WithChannelSubscribersStatus(subscribers []duckv1alpha1.SubscriberStatus) ChannelOption
- func WithChannelTopic(topicID string) ChannelOption
- func WithChannelUID(uid types.UID) ChannelOption
- type Ctor
- type DeploymentOption
- func WithDeploymentAnnotations(annotations map[string]string) DeploymentOption
- func WithDeploymentContainer(name, image string, envVars []corev1.EnvVar, ...) DeploymentOption
- func WithDeploymentLabels(labels map[string]string) DeploymentOption
- func WithDeploymentOwnerReferences(ownerReferences []metav1.OwnerReference) DeploymentOption
- func WithDeploymentServiceAccount(serviceAccountName string) DeploymentOption
- type Listers
- func (l *Listers) GetAllObjects() []runtime.Object
- func (l *Listers) GetChannelLister() eventslisters.ChannelLister
- func (l *Listers) GetConfigMapLister() corev1listers.ConfigMapLister
- func (l *Listers) GetDeploymentLister() appsv1listers.DeploymentLister
- func (l *Listers) GetEndpointsLister() corev1listers.EndpointsLister
- func (l *Listers) GetEventsObjects() []runtime.Object
- func (l *Listers) GetK8sServiceLister() corev1listers.ServiceLister
- func (l *Listers) GetKubeObjects() []runtime.Object
- func (l *Listers) GetNamespaceLister() corev1listers.NamespaceLister
- func (l *Listers) GetPullSubscriptionLister() pubsublisters.PullSubscriptionLister
- func (l *Listers) GetRoleBindingLister() rbacv1listers.RoleBindingLister
- func (l *Listers) GetServiceAccountLister() corev1listers.ServiceAccountLister
- func (l *Listers) GetServingObjects() []runtime.Object
- func (l *Listers) GetSharedObjects() []runtime.Object
- func (l *Listers) GetSinkObjects() []runtime.Object
- func (l *Listers) GetTopicLister() pubsublisters.TopicLister
- func (l *Listers) GetV1alpha1ServiceLister() servingv1alpha1listers.ServiceLister
- func (l *Listers) GetV1beta1ServiceLister() servingv1beta1listers.ServiceLister
- type NamespaceOption
- type PullSubscriptionOption
- func WithPullSubscriptionFinalizers(finalizers ...string) PullSubscriptionOption
- func WithPullSubscriptionGenerateName(generateName string) PullSubscriptionOption
- func WithPullSubscriptionLabels(labels map[string]string) PullSubscriptionOption
- func WithPullSubscriptionMarkNoSubscription(subscriptionID string) PullSubscriptionOption
- func WithPullSubscriptionMarkSink(uri string) PullSubscriptionOption
- func WithPullSubscriptionMarkSubscribing(subscriptionID string) PullSubscriptionOption
- func WithPullSubscriptionMarkUnsubscribing(subscriptionID string) PullSubscriptionOption
- func WithPullSubscriptionOwnerReferences(ownerReferences []metav1.OwnerReference) PullSubscriptionOption
- func WithPullSubscriptionReady(sink string) PullSubscriptionOption
- func WithPullSubscriptionSink(gvk metav1.GroupVersionKind, name string) PullSubscriptionOption
- func WithPullSubscriptionSinkNotFound() PullSubscriptionOption
- func WithPullSubscriptionSpec(spec v1alpha1.PullSubscriptionSpec) PullSubscriptionOption
- func WithPullSubscriptionSubscription(subscriptionID string) PullSubscriptionOption
- func WithPullSubscriptionUID(uid types.UID) PullSubscriptionOption
- type ServiceOption
- type TopicOption
- func WithTopicAddress(uri string) TopicOption
- func WithTopicFinalizers(finalizers ...string) TopicOption
- func WithTopicLabels(labels map[string]string) TopicOption
- func WithTopicMarkTopicCreating(topicID string) TopicOption
- func WithTopicMarkTopicVerifying(topicID string) TopicOption
- func WithTopicOwnerReferences(ownerReferences []metav1.OwnerReference) TopicOption
- func WithTopicPropagationPolicy(policy string) TopicOption
- func WithTopicReady(topicID string) TopicOption
- func WithTopicSpec(spec v1alpha1.TopicSpec) TopicOption
- func WithTopicTopicDeleted(topicID string) TopicOption
- func WithTopicTopicDeleting(topicID string) TopicOption
- func WithTopicTopicID(topicID string) TopicOption
- func WithTopicUID(uid types.UID) TopicOption
- type UnstructuredOption
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MakeFactory ¶
func MakeFactory(ctor Ctor) Factory
MakeFactory creates a reconciler factory with fake clients and controller created by `ctor`.
func NewChannel ¶
func NewChannel(name, namespace string, so ...ChannelOption) *v1alpha1.Channel
NewChannel creates a Channel with ChannelOptions
func NewChannelWithoutNamespace ¶
func NewChannelWithoutNamespace(name string, so ...ChannelOption) *v1alpha1.Channel
NewChannelWithoutNamespace creates a Channel with ChannelOptions but without a specific namespace
func NewDeployment ¶
func NewDeployment(name, namespace string, do ...DeploymentOption) *appsv1.Deployment
NewDeployment creates a Deployment with DeploymentOptions.
func NewNamespace ¶
func NewNamespace(name string, o ...NamespaceOption) *corev1.Namespace
NewNamespace creates a Namespace with NamespaceOptions
func NewPullSubscription ¶
func NewPullSubscription(name, namespace string, so ...PullSubscriptionOption) *v1alpha1.PullSubscription
NewPullSubscription creates a PullSubscription with PullSubscriptionOptions
func NewPullSubscriptionWithoutNamespace ¶
func NewPullSubscriptionWithoutNamespace(name string, so ...PullSubscriptionOption) *v1alpha1.PullSubscription
NewPullSubscriptionWithoutNamespace creates a PullSubscription with PullSubscriptionOptions but without a specific namespace
func NewService ¶
func NewService(name, namespace string, so ...ServiceOption) *corev1.Service
NewService creates a Service with ServiceOptions
func NewTopic ¶
func NewTopic(name, namespace string, so ...TopicOption) *v1alpha1.Topic
NewTopic creates a Topic with TopicOptions
func NewUnstructured ¶
func NewUnstructured(gvk metav1.GroupVersionKind, name, namespace string, uo ...UnstructuredOption) *unstructured.Unstructured
NewUnstructured creates a unstructured.Unstructured with UnstructuredOption
func WithChannelDefaults ¶
func WithChannelDeleted ¶
func WithInitChannelConditions ¶
WithInitChannelConditions initializes the Channels's conditions.
func WithInitPullSubscriptionConditions ¶
func WithInitPullSubscriptionConditions(s *v1alpha1.PullSubscription)
WithInitPullSubscriptionConditions initializes the PullSubscriptions's conditions.
func WithInitTopicConditions ¶
WithInitTopicConditions initializes the Topics's conditions.
func WithNamespaceDeleted ¶
func WithPullSubscriptionDeleted ¶
func WithPullSubscriptionDeleted(s *v1alpha1.PullSubscription)
func WithTopicDeleted ¶
func WithTopicDeployed ¶
Types ¶
type ChannelOption ¶
ChannelOption enables further configuration of a Channel.
func WithChannelAddress ¶
func WithChannelAddress(url string) ChannelOption
func WithChannelGenerateName ¶
func WithChannelGenerateName(generateName string) ChannelOption
func WithChannelLabels ¶
func WithChannelLabels(labels map[string]string) ChannelOption
func WithChannelMarkTopicCreating ¶
func WithChannelMarkTopicCreating(topicID string) ChannelOption
func WithChannelOwnerReferences ¶
func WithChannelOwnerReferences(ownerReferences []metav1.OwnerReference) ChannelOption
func WithChannelReady ¶
func WithChannelReady(topicID string) ChannelOption
func WithChannelSpec ¶
func WithChannelSpec(spec v1alpha1.ChannelSpec) ChannelOption
func WithChannelSubscribers ¶
func WithChannelSubscribers(subscribers []duckv1alpha1.SubscriberSpec) ChannelOption
func WithChannelSubscribersStatus ¶
func WithChannelSubscribersStatus(subscribers []duckv1alpha1.SubscriberStatus) ChannelOption
func WithChannelTopic ¶
func WithChannelTopic(topicID string) ChannelOption
func WithChannelUID ¶
func WithChannelUID(uid types.UID) ChannelOption
type Ctor ¶
type Ctor func(context.Context, *Listers, configmap.Watcher) controller.Reconciler
Ctor functions create a k8s controller with given params.
type DeploymentOption ¶
type DeploymentOption func(*appsv1.Deployment)
DeploymentOption enables further configuration of a Deployment.
func WithDeploymentAnnotations ¶
func WithDeploymentAnnotations(annotations map[string]string) DeploymentOption
func WithDeploymentContainer ¶
func WithDeploymentContainer(name, image string, envVars []corev1.EnvVar, containerPorts []corev1.ContainerPort) DeploymentOption
func WithDeploymentLabels ¶
func WithDeploymentLabels(labels map[string]string) DeploymentOption
func WithDeploymentOwnerReferences ¶
func WithDeploymentOwnerReferences(ownerReferences []metav1.OwnerReference) DeploymentOption
func WithDeploymentServiceAccount ¶
func WithDeploymentServiceAccount(serviceAccountName string) DeploymentOption
type Listers ¶
type Listers struct { servingv1alpha1listers.ConfigurationLister // contains filtered or unexported fields }
func NewListers ¶
func (*Listers) GetAllObjects ¶
func (*Listers) GetChannelLister ¶
func (l *Listers) GetChannelLister() eventslisters.ChannelLister
func (*Listers) GetConfigMapLister ¶
func (l *Listers) GetConfigMapLister() corev1listers.ConfigMapLister
func (*Listers) GetDeploymentLister ¶
func (l *Listers) GetDeploymentLister() appsv1listers.DeploymentLister
func (*Listers) GetEndpointsLister ¶
func (l *Listers) GetEndpointsLister() corev1listers.EndpointsLister
func (*Listers) GetEventsObjects ¶
func (*Listers) GetK8sServiceLister ¶
func (l *Listers) GetK8sServiceLister() corev1listers.ServiceLister
func (*Listers) GetKubeObjects ¶
func (*Listers) GetNamespaceLister ¶
func (l *Listers) GetNamespaceLister() corev1listers.NamespaceLister
func (*Listers) GetPullSubscriptionLister ¶
func (l *Listers) GetPullSubscriptionLister() pubsublisters.PullSubscriptionLister
func (*Listers) GetRoleBindingLister ¶
func (l *Listers) GetRoleBindingLister() rbacv1listers.RoleBindingLister
func (*Listers) GetServiceAccountLister ¶
func (l *Listers) GetServiceAccountLister() corev1listers.ServiceAccountLister
func (*Listers) GetServingObjects ¶
func (*Listers) GetSharedObjects ¶
func (*Listers) GetSinkObjects ¶
func (*Listers) GetTopicLister ¶
func (l *Listers) GetTopicLister() pubsublisters.TopicLister
func (*Listers) GetV1alpha1ServiceLister ¶
func (l *Listers) GetV1alpha1ServiceLister() servingv1alpha1listers.ServiceLister
func (*Listers) GetV1beta1ServiceLister ¶
func (l *Listers) GetV1beta1ServiceLister() servingv1beta1listers.ServiceLister
type NamespaceOption ¶
NamespaceOption enables further configuration of a Namespace.
func WithNamespaceLabeled ¶
func WithNamespaceLabeled(labels map[string]string) NamespaceOption
type PullSubscriptionOption ¶
type PullSubscriptionOption func(*v1alpha1.PullSubscription)
PullSubscriptionOption enables further configuration of a PullSubscription.
func WithPullSubscriptionFinalizers ¶
func WithPullSubscriptionFinalizers(finalizers ...string) PullSubscriptionOption
func WithPullSubscriptionGenerateName ¶
func WithPullSubscriptionGenerateName(generateName string) PullSubscriptionOption
func WithPullSubscriptionLabels ¶
func WithPullSubscriptionLabels(labels map[string]string) PullSubscriptionOption
func WithPullSubscriptionMarkNoSubscription ¶
func WithPullSubscriptionMarkNoSubscription(subscriptionID string) PullSubscriptionOption
func WithPullSubscriptionMarkSink ¶
func WithPullSubscriptionMarkSink(uri string) PullSubscriptionOption
func WithPullSubscriptionMarkSubscribing ¶
func WithPullSubscriptionMarkSubscribing(subscriptionID string) PullSubscriptionOption
func WithPullSubscriptionMarkUnsubscribing ¶
func WithPullSubscriptionMarkUnsubscribing(subscriptionID string) PullSubscriptionOption
func WithPullSubscriptionOwnerReferences ¶
func WithPullSubscriptionOwnerReferences(ownerReferences []metav1.OwnerReference) PullSubscriptionOption
func WithPullSubscriptionReady ¶
func WithPullSubscriptionReady(sink string) PullSubscriptionOption
func WithPullSubscriptionSink ¶
func WithPullSubscriptionSink(gvk metav1.GroupVersionKind, name string) PullSubscriptionOption
func WithPullSubscriptionSinkNotFound ¶
func WithPullSubscriptionSinkNotFound() PullSubscriptionOption
func WithPullSubscriptionSpec ¶
func WithPullSubscriptionSpec(spec v1alpha1.PullSubscriptionSpec) PullSubscriptionOption
func WithPullSubscriptionSubscription ¶
func WithPullSubscriptionSubscription(subscriptionID string) PullSubscriptionOption
func WithPullSubscriptionUID ¶
func WithPullSubscriptionUID(uid types.UID) PullSubscriptionOption
type ServiceOption ¶
ServiceOption enables further configuration of a Service.
func WithServiceLabels ¶
func WithServiceLabels(labels map[string]string) ServiceOption
func WithServiceOwnerReferences ¶
func WithServiceOwnerReferences(ownerReferences []metav1.OwnerReference) ServiceOption
func WithServicePorts ¶
func WithServicePorts(ports []corev1.ServicePort) ServiceOption
type TopicOption ¶
TopicOption enables further configuration of a Topic.
func WithTopicAddress ¶
func WithTopicAddress(uri string) TopicOption
func WithTopicFinalizers ¶
func WithTopicFinalizers(finalizers ...string) TopicOption
func WithTopicLabels ¶
func WithTopicLabels(labels map[string]string) TopicOption
func WithTopicMarkTopicCreating ¶
func WithTopicMarkTopicCreating(topicID string) TopicOption
func WithTopicMarkTopicVerifying ¶
func WithTopicMarkTopicVerifying(topicID string) TopicOption
func WithTopicOwnerReferences ¶
func WithTopicOwnerReferences(ownerReferences []metav1.OwnerReference) TopicOption
func WithTopicPropagationPolicy ¶
func WithTopicPropagationPolicy(policy string) TopicOption
func WithTopicReady ¶
func WithTopicReady(topicID string) TopicOption
func WithTopicSpec ¶
func WithTopicSpec(spec v1alpha1.TopicSpec) TopicOption
func WithTopicTopicDeleted ¶
func WithTopicTopicDeleted(topicID string) TopicOption
func WithTopicTopicDeleting ¶
func WithTopicTopicDeleting(topicID string) TopicOption
func WithTopicTopicID ¶
func WithTopicTopicID(topicID string) TopicOption
func WithTopicUID ¶
func WithTopicUID(uid types.UID) TopicOption
type UnstructuredOption ¶
type UnstructuredOption func(*unstructured.Unstructured)
UnstructuredOption enables further configuration of a Unstructured.
func WithUnstructuredAddressable ¶
func WithUnstructuredAddressable(hostname string) UnstructuredOption