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 NewPullSubscriptionWithNoDefaults(name, namespace string, so ...PullSubscriptionOption) *v1alpha1.PullSubscription
- func NewPullSubscriptionWithoutNamespace(name string, so ...PullSubscriptionOption) *v1alpha1.PullSubscription
- func NewScheduler(name, namespace string, so ...SchedulerOption) *v1alpha1.Scheduler
- func NewService(name, namespace string, so ...ServiceOption) *corev1.Service
- func NewStorage(name, namespace string, so ...StorageOption) *v1alpha1.Storage
- 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 WithInitSchedulerConditions(s *v1alpha1.Scheduler)
- func WithInitStorageConditions(s *v1alpha1.Storage)
- 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() messaginglisters.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) GetJobLister() batchv1listers.JobLister
- 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) GetSchedulerLister() eventslisters.SchedulerLister
- 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) GetStorageLister() eventslisters.StorageLister
- func (l *Listers) GetTopicLister() pubsublisters.TopicLister
- func (l *Listers) GetV1alpha1ServiceLister() servingv1alpha1listers.ServiceLister
- func (l *Listers) GetV1beta1ServiceLister() servingv1beta1listers.ServiceLister
- type NamespaceOption
- type PullSubscriptionOption
- func WithPullSubscriptionAnnotations(annotations map[string]string) 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 WithPullSubscriptionSpecWithNoDefaults(spec v1alpha1.PullSubscriptionSpec) PullSubscriptionOption
- func WithPullSubscriptionSubscription(subscriptionID string) PullSubscriptionOption
- func WithPullSubscriptionUID(uid types.UID) PullSubscriptionOption
- type SchedulerOption
- func WithSchedulerData(data string) SchedulerOption
- func WithSchedulerFinalizers(finalizers ...string) SchedulerOption
- func WithSchedulerJobNotReady(reason, message string) SchedulerOption
- func WithSchedulerJobReady(jobName string) SchedulerOption
- func WithSchedulerLocation(location string) SchedulerOption
- func WithSchedulerPullSubscriptionNotReady(reason, message string) SchedulerOption
- func WithSchedulerPullSubscriptionReady() SchedulerOption
- func WithSchedulerSchedule(schedule string) SchedulerOption
- func WithSchedulerSink(gvk metav1.GroupVersionKind, name string) SchedulerOption
- func WithSchedulerSinkURI(url *apis.URL) SchedulerOption
- func WithSchedulerTopicNotReady(reason, message string) SchedulerOption
- func WithSchedulerTopicReady(topicID, projectID string) SchedulerOption
- type ServiceOption
- type StorageOption
- func WithStorageBucket(bucket string) StorageOption
- func WithStorageEventTypes(eventTypes []string) StorageOption
- func WithStorageFinalizers(finalizers ...string) StorageOption
- func WithStorageNotificationID(notificationID string) StorageOption
- func WithStorageNotificationNotReady(reason, message string) StorageOption
- func WithStorageNotificationReady() StorageOption
- func WithStorageProjectID(notificationID string) StorageOption
- func WithStoragePullSubscriptionNotReady(reason, message string) StorageOption
- func WithStoragePullSubscriptionReady() StorageOption
- func WithStorageSink(gvk metav1.GroupVersionKind, name string) StorageOption
- func WithStorageSinkURI(url *apis.URL) StorageOption
- func WithStorageTopicNotReady(reason, message string) StorageOption
- func WithStorageTopicReady(topicID string) StorageOption
- 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 WithTopicProjectID(projectID string) 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 NewPullSubscriptionWithNoDefaults ¶ added in v0.9.0
func NewPullSubscriptionWithNoDefaults(name, namespace string, so ...PullSubscriptionOption) *v1alpha1.PullSubscription
NewPullSubscriptionWithNoDefaults creates a PullSubscription with PullSubscriptionOptions but does not set defaults.
func NewPullSubscriptionWithoutNamespace ¶
func NewPullSubscriptionWithoutNamespace(name string, so ...PullSubscriptionOption) *v1alpha1.PullSubscription
NewPullSubscriptionWithoutNamespace creates a PullSubscription with PullSubscriptionOptions but without a specific namespace
func NewScheduler ¶ added in v0.9.0
func NewScheduler(name, namespace string, so ...SchedulerOption) *v1alpha1.Scheduler
NewScheduler creates a Scheduler with SchedulerOptions
func NewService ¶
func NewService(name, namespace string, so ...ServiceOption) *corev1.Service
NewService creates a Service with ServiceOptions
func NewStorage ¶ added in v0.9.0
func NewStorage(name, namespace string, so ...StorageOption) *v1alpha1.Storage
NewStorage creates a Storage with StorageOptions
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 WithInitSchedulerConditions ¶ added in v0.9.0
WithInitSchedulerConditions initializes the Schedulers's conditions.
func WithInitStorageConditions ¶ added in v0.9.0
WithInitStorageConditions initializes the Storages'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() messaginglisters.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) GetJobLister ¶ added in v0.9.0
func (l *Listers) GetJobLister() batchv1listers.JobLister
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) GetSchedulerLister ¶ added in v0.9.0
func (l *Listers) GetSchedulerLister() eventslisters.SchedulerLister
func (*Listers) GetServiceAccountLister ¶
func (l *Listers) GetServiceAccountLister() corev1listers.ServiceAccountLister
func (*Listers) GetServingObjects ¶
func (*Listers) GetSharedObjects ¶
func (*Listers) GetSinkObjects ¶
func (*Listers) GetStorageLister ¶ added in v0.9.0
func (l *Listers) GetStorageLister() eventslisters.StorageLister
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 WithPullSubscriptionAnnotations ¶ added in v0.9.0
func WithPullSubscriptionAnnotations(annotations map[string]string) PullSubscriptionOption
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 WithPullSubscriptionSpecWithNoDefaults ¶ added in v0.9.0
func WithPullSubscriptionSpecWithNoDefaults(spec v1alpha1.PullSubscriptionSpec) PullSubscriptionOption
Same as withPullSubscriptionSpec but does not set defaults
func WithPullSubscriptionSubscription ¶
func WithPullSubscriptionSubscription(subscriptionID string) PullSubscriptionOption
func WithPullSubscriptionUID ¶
func WithPullSubscriptionUID(uid types.UID) PullSubscriptionOption
type SchedulerOption ¶ added in v0.9.0
SchedulerOption enables further configuration of a Scheduler.
func WithSchedulerData ¶ added in v0.9.0
func WithSchedulerData(data string) SchedulerOption
func WithSchedulerFinalizers ¶ added in v0.9.0
func WithSchedulerFinalizers(finalizers ...string) SchedulerOption
func WithSchedulerJobNotReady ¶ added in v0.9.0
func WithSchedulerJobNotReady(reason, message string) SchedulerOption
WithSchedulerJobNotReady marks the condition that the Scheduler Job is not ready.
func WithSchedulerJobReady ¶ added in v0.9.0
func WithSchedulerJobReady(jobName string) SchedulerOption
WithSchedulerJobReady marks the condition that the Scheduler Job is ready and sets Status.JobName to jobName.
func WithSchedulerLocation ¶ added in v0.9.0
func WithSchedulerLocation(location string) SchedulerOption
func WithSchedulerPullSubscriptionNotReady ¶ added in v0.9.0
func WithSchedulerPullSubscriptionNotReady(reason, message string) SchedulerOption
WithSchedulerPullSubscriptionNotReady marks the condition that the topic is not ready
func WithSchedulerPullSubscriptionReady ¶ added in v0.9.0
func WithSchedulerPullSubscriptionReady() SchedulerOption
WithSchedulerPullSubscriptionNotReady marks the condition that the topic is not ready
func WithSchedulerSchedule ¶ added in v0.9.0
func WithSchedulerSchedule(schedule string) SchedulerOption
func WithSchedulerSink ¶ added in v0.9.0
func WithSchedulerSink(gvk metav1.GroupVersionKind, name string) SchedulerOption
func WithSchedulerSinkURI ¶ added in v0.9.0
func WithSchedulerSinkURI(url *apis.URL) SchedulerOption
WithSchedulerSinkURI sets the status for sink URI
func WithSchedulerTopicNotReady ¶ added in v0.9.0
func WithSchedulerTopicNotReady(reason, message string) SchedulerOption
WithSchedulerTopicNotReady marks the condition that the topic is not ready
func WithSchedulerTopicReady ¶ added in v0.9.0
func WithSchedulerTopicReady(topicID, projectID string) SchedulerOption
WithSchedulerTopicNotReady marks the condition that the topic is not ready
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 StorageOption ¶ added in v0.9.0
StorageOption enables further configuration of a Storage.
func WithStorageBucket ¶ added in v0.9.0
func WithStorageBucket(bucket string) StorageOption
func WithStorageEventTypes ¶ added in v0.9.0
func WithStorageEventTypes(eventTypes []string) StorageOption
func WithStorageFinalizers ¶ added in v0.9.0
func WithStorageFinalizers(finalizers ...string) StorageOption
func WithStorageNotificationID ¶ added in v0.9.0
func WithStorageNotificationID(notificationID string) StorageOption
WithStorageNotificationId sets the status for Notification ID
func WithStorageNotificationNotReady ¶ added in v0.9.0
func WithStorageNotificationNotReady(reason, message string) StorageOption
WithStorageNotificationNotReady marks the condition that the GCS Notification is not ready.
func WithStorageNotificationReady ¶ added in v0.9.0
func WithStorageNotificationReady() StorageOption
WithStorageNotificationReady marks the condition that the GCS Notification is ready.
func WithStorageProjectID ¶ added in v0.9.0
func WithStorageProjectID(notificationID string) StorageOption
WithStorageProjectId sets the status for Project ID
func WithStoragePullSubscriptionNotReady ¶ added in v0.9.0
func WithStoragePullSubscriptionNotReady(reason, message string) StorageOption
WithStoragePullSubscriptionNotReady marks the condition that the topic is not ready
func WithStoragePullSubscriptionReady ¶ added in v0.9.0
func WithStoragePullSubscriptionReady() StorageOption
WithStoragePullSubscriptionNotReady marks the condition that the topic is not ready
func WithStorageSink ¶ added in v0.9.0
func WithStorageSink(gvk metav1.GroupVersionKind, name string) StorageOption
func WithStorageSinkURI ¶ added in v0.9.0
func WithStorageSinkURI(url *apis.URL) StorageOption
WithStorageSinkURI sets the status for sink URI
func WithStorageTopicNotReady ¶ added in v0.9.0
func WithStorageTopicNotReady(reason, message string) StorageOption
WithStorageTopicNotReady marks the condition that the topic is not ready
func WithStorageTopicReady ¶ added in v0.9.0
func WithStorageTopicReady(topicID string) StorageOption
WithStorageTopicNotReady marks the condition that the topic is not ready
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 WithTopicProjectID ¶ added in v0.9.0
func WithTopicProjectID(projectID string) 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