Documentation ¶
Index ¶
- Variables
- func ApiVersion(gvk metav1.GroupVersionKind) string
- func AvailableEndpoints() *corev1.Endpoints
- func InjectPubsubClient(td map[string]interface{}, c *pubsub.Client)
- func MakeFactory(ctor Ctor) Factory
- func NewBroker(name, namespace string, o ...BrokerOption) *brokerv1beta1.Broker
- func NewBrokerCell(name, namespace string, o ...BrokerCellOption) *intv1alpha1.BrokerCell
- func NewChannel(name, namespace string, so ...ChannelOption) *v1beta1.Channel
- func NewChannelWithoutNamespace(name string, co ...ChannelOption) *v1beta1.Channel
- func NewConfigMap(name, namespace string, cmo ...ConfigMapOption) *corev1.ConfigMap
- func NewDeployment(name, namespace string, do ...DeploymentOption) *appsv1.Deployment
- func NewEndpoints(name, namespace string, so ...EndpointsOption) *corev1.Endpoints
- func NewGCPAuthTestStore(t *testing.T, config *corev1.ConfigMap) *gcpauth.Store
- func NewNamespace(name string, o ...NamespaceOption) *corev1.Namespace
- func NewService(name, namespace string, so ...ServiceOption) *corev1.Service
- func NewServiceAccount(name, namespace, gServiceAccount string, so ...ServiceAccountOption) *corev1.ServiceAccount
- func NewTrigger(name, namespace, broker string, to ...TriggerOption) *brokerv1beta1.Trigger
- func NewUnstructured(gvk metav1.GroupVersionKind, name, namespace string, uo ...UnstructuredOption) *unstructured.Unstructured
- func NoSubscriptionsExist() func(*testing.T, *rtesting.TableRow)
- func NoTopicsExist() func(*testing.T, *rtesting.TableRow)
- func OnlySubscriptions(ids ...string) func(*testing.T, *rtesting.TableRow)
- func OnlyTopics(ids ...string) func(*testing.T, *rtesting.TableRow)
- func SubscriptionExists(id string) func(*testing.T, *rtesting.TableRow)
- func SubscriptionHasDeadLetterPolicy(id string, wantPolicy *pubsub.DeadLetterPolicy) func(*testing.T, *rtesting.TableRow)
- func SubscriptionHasRetryPolicy(id string, wantPolicy *pubsub.RetryPolicy) func(*testing.T, *rtesting.TableRow)
- func TestPubsubClient(ctx context.Context, projectID string) (*pubsub.Client, func())
- func TopicExists(id string) func(*testing.T, *rtesting.TableRow)
- func WithBrokerBrokerCellReady(b *brokerv1beta1.Broker)
- func WithBrokerCellDeletionTimestamp(bc *intv1alpha1.BrokerCell)
- func WithBrokerCellReady(bc *intv1alpha1.BrokerCell)
- func WithBrokerCellSetDefaults(bc *intv1alpha1.BrokerCell)
- func WithBrokerDeletionTimestamp(b *brokerv1beta1.Broker)
- func WithBrokerSetDefaults(b *brokerv1beta1.Broker)
- func WithBrokerSubscriptionReady(b *brokerv1beta1.Broker)
- func WithBrokerTopicReady(b *brokerv1beta1.Broker)
- func WithChannelDeleted(s *v1beta1.Channel)
- func WithChannelDeletionTimestamp(c *v1beta1.Channel)
- func WithChannelSetDefaults(c *v1beta1.Channel)
- func WithInitBrokerCellConditions(bc *intv1alpha1.BrokerCell)
- func WithInitBrokerConditions(b *brokerv1beta1.Broker)
- func WithInitChannelConditions(c *v1beta1.Channel)
- func WithInitTriggerConditions(t *brokerv1beta1.Trigger)
- func WithNamespaceDeleted(n *corev1.Namespace)
- func WithTriggerBrokerReady(t *brokerv1beta1.Trigger)
- func WithTriggerDeletionTimestamp(t *brokerv1beta1.Trigger)
- func WithTriggerDependencyReady(t *brokerv1beta1.Trigger)
- func WithTriggerSetDefaults(t *brokerv1beta1.Trigger)
- func WithTriggerSubscriberResolvedSucceeded(t *brokerv1beta1.Trigger)
- func WithTriggerSubscriptionReady(t *brokerv1beta1.Trigger)
- func WithTriggerTopicReady(t *brokerv1beta1.Trigger)
- type BrokerCellOption
- func WithBrokerCellAnnotations(annotations map[string]string) BrokerCellOption
- func WithBrokerCellFanoutAvailable() BrokerCellOption
- func WithBrokerCellFanoutFailed(reason, msg string) BrokerCellOption
- func WithBrokerCellFanoutUnknown(reason, msg string) BrokerCellOption
- func WithBrokerCellFinalizers(finalizers ...string) BrokerCellOption
- func WithBrokerCellGeneration(gen int64) BrokerCellOption
- func WithBrokerCellIngressAvailable() BrokerCellOption
- func WithBrokerCellIngressFailed(reason, msg string) BrokerCellOption
- func WithBrokerCellRetryAvailable() BrokerCellOption
- func WithBrokerCellRetryFailed(reason, msg string) BrokerCellOption
- func WithBrokerCellRetryUnknown(reason, msg string) BrokerCellOption
- func WithBrokerCellStatusObservedGeneration(gen int64) BrokerCellOption
- func WithIngressTemplate(address string) BrokerCellOption
- func WithTargetsCofigFailed(reason, msg string) BrokerCellOption
- func WithTargetsCofigReady() BrokerCellOption
- type BrokerOption
- func WithBrokerAddress(address string) BrokerOption
- func WithBrokerAddressURI(uri *apis.URL) BrokerOption
- func WithBrokerBrokerCellFailed(reason, msg string) BrokerOption
- func WithBrokerBrokerCellUnknown(reason, msg string) BrokerOption
- func WithBrokerClass(bc string) BrokerOption
- func WithBrokerDeliverySpec(deliverySpec *eventingduckv1beta1.DeliverySpec) BrokerOption
- func WithBrokerFinalizers(finalizers ...string) BrokerOption
- func WithBrokerGeneration(gen int64) BrokerOption
- func WithBrokerReady(address string) BrokerOption
- func WithBrokerReadyURI(address *apis.URL) BrokerOption
- func WithBrokerResourceVersion(rv string) BrokerOption
- func WithBrokerStatusObservedGeneration(gen int64) BrokerOption
- func WithBrokerUID(uid string) BrokerOption
- type ChannelOption
- func WithChannelAddress(url string) ChannelOption
- func WithChannelAnnotations(Annotations map[string]string) ChannelOption
- func WithChannelGenerateName(generateName string) ChannelOption
- func WithChannelLabels(labels map[string]string) ChannelOption
- func WithChannelOwnerReferences(ownerReferences []metav1.OwnerReference) ChannelOption
- func WithChannelReady(topicID string) ChannelOption
- func WithChannelServiceAccount(kServiceAccount string) ChannelOption
- func WithChannelSpec(spec v1beta1.ChannelSpec) ChannelOption
- func WithChannelSubscribers(subscribers []duckv1beta1.SubscriberSpec) ChannelOption
- func WithChannelSubscribersStatus(subscribers []eventingduckv1beta1.SubscriberStatus) ChannelOption
- func WithChannelTopic(topicID string) ChannelOption
- func WithChannelTopicFailed(reason, message string) ChannelOption
- func WithChannelTopicID(topicID string) ChannelOption
- func WithChannelTopicUnknown(reason, message string) ChannelOption
- func WithChannelUID(uid types.UID) ChannelOption
- func WithChannelWorkloadIdentityFailed(reason, message string) ChannelOption
- type ConfigMapOption
- type Ctor
- type DeploymentOption
- func WithDeploymentAnnotations(annotations map[string]string) DeploymentOption
- func WithDeploymentAvailable() 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 EndpointsOption
- func WithEndpointsAddresses(addrs ...corev1.EndpointAddress) EndpointsOption
- func WithEndpointsAnnotations(annotations map[string]string) EndpointsOption
- func WithEndpointsLabels(labels map[string]string) EndpointsOption
- func WithEndpointsNotReadyAddresses(addrs ...corev1.EndpointAddress) EndpointsOption
- type Listers
- func (l *Listers) GetAllObjects() []runtime.Object
- func (l *Listers) GetBrokerCellLister() intlisters.BrokerCellLister
- func (l *Listers) GetBrokerLister() brokerlisters.BrokerLister
- func (l *Listers) GetChannelLister() messaginglisters.ChannelLister
- func (l *Listers) GetCloudAuditLogsSourceLister() eventslisters.CloudAuditLogsSourceLister
- func (l *Listers) GetCloudBuildSourceLister() eventsv1beta1listers.CloudBuildSourceLister
- func (l *Listers) GetCloudPubSubSourceLister() eventslisters.CloudPubSubSourceLister
- func (l *Listers) GetCloudSchedulerSourceLister() eventslisters.CloudSchedulerSourceLister
- func (l *Listers) GetCloudStorageSourceLister() eventslisters.CloudStorageSourceLister
- 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) GetHPALister() hpav2beta2listers.HorizontalPodAutoscalerLister
- 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) GetPodLister() corev1listers.PodLister
- func (l *Listers) GetPullSubscriptionLister() inteventslisters.PullSubscriptionLister
- func (l *Listers) GetRoleBindingLister() rbacv1listers.RoleBindingLister
- func (l *Listers) GetServiceAccountLister() corev1listers.ServiceAccountLister
- func (l *Listers) GetServingObjects() []runtime.Object
- func (l *Listers) GetSinkObjects() []runtime.Object
- func (l *Listers) GetTopicLister() inteventslisters.TopicLister
- func (l *Listers) GetTriggerLister() brokerlisters.TriggerLister
- func (l *Listers) GetV1ServiceLister() servingv1listers.ServiceLister
- func (l *Listers) GetV1alpha1ServiceLister() servingv1alpha1listers.ServiceLister
- func (l *Listers) GetV1beta1ServiceLister() servingv1beta1listers.ServiceLister
- func (l *Listers) GetV1beta1TopicLister() inteventsv1beta1listers.TopicLister
- type NamespaceOption
- type PubsubAction
- type ServiceAccountOption
- type ServiceOption
- type TriggerOption
- func WithDependencyAnnotation(dependencyAnnotation string) TriggerOption
- func WithInjectionAnnotation(injectionAnnotation string) TriggerOption
- func WithTriggerBrokerFailed(reason, message string) TriggerOption
- func WithTriggerBrokerUnknown(reason, message string) TriggerOption
- func WithTriggerDependencyFailed(reason, message string) TriggerOption
- func WithTriggerDependencyUnknown(reason, message string) TriggerOption
- func WithTriggerFinalizers(finalizers ...string) TriggerOption
- func WithTriggerGeneration(gen int64) TriggerOption
- func WithTriggerStatusObservedGeneration(gen int64) TriggerOption
- func WithTriggerStatusSubscriberURI(uri string) TriggerOption
- func WithTriggerSubscriberRef(gvk metav1.GroupVersionKind, name, namespace string) TriggerOption
- func WithTriggerSubscriberRefAndURIReference(gvk metav1.GroupVersionKind, name, namespace string, rawuri string) TriggerOption
- func WithTriggerSubscriberResolvedFailed(reason, message string) TriggerOption
- func WithTriggerSubscriberResolvedUnknown(reason, message string) TriggerOption
- func WithTriggerSubscriberURI(rawurl string) TriggerOption
- func WithTriggerUID(uid string) TriggerOption
- type UnstructuredOption
Constants ¶
This section is empty.
Variables ¶
var NoopIAMPolicyManager iam.IAMPolicyManager = noopManager(struct{}{})
Functions ¶
func ApiVersion ¶ added in v0.17.0
func ApiVersion(gvk metav1.GroupVersionKind) string
func AvailableEndpoints ¶ added in v0.15.0
func InjectPubsubClient ¶ added in v0.15.0
func MakeFactory ¶
func MakeFactory(ctor Ctor) Factory
MakeFactory creates a reconciler factory with fake clients and controller created by `ctor`.
func NewBroker ¶ added in v0.15.0
func NewBroker(name, namespace string, o ...BrokerOption) *brokerv1beta1.Broker
NewBroker creates a Broker with BrokerOptions. The Broker has the brokerv1beta1 broker class by default.
func NewBrokerCell ¶ added in v0.15.0
func NewBrokerCell(name, namespace string, o ...BrokerCellOption) *intv1alpha1.BrokerCell
NewBrokerCell creates a BrokerCell with BrokerCellOptions.
func NewChannel ¶
func NewChannel(name, namespace string, so ...ChannelOption) *v1beta1.Channel
NewChannel creates a Channel with ChannelOptions
func NewChannelWithoutNamespace ¶
func NewChannelWithoutNamespace(name string, co ...ChannelOption) *v1beta1.Channel
NewChannelWithoutNamespace creates a Channel with ChannelOptions but without a specific namespace
func NewConfigMap ¶ added in v0.15.0
func NewConfigMap(name, namespace string, cmo ...ConfigMapOption) *corev1.ConfigMap
NewConfigMap creates a ConfigMap with ConfigMapOptions.
func NewDeployment ¶
func NewDeployment(name, namespace string, do ...DeploymentOption) *appsv1.Deployment
NewDeployment creates a Deployment with DeploymentOptions.
func NewEndpoints ¶ added in v0.15.0
func NewEndpoints(name, namespace string, so ...EndpointsOption) *corev1.Endpoints
NewEndpoints creates a Endpoints with EndpointsOptions
func NewGCPAuthTestStore ¶ added in v0.16.0
func NewNamespace ¶
func NewNamespace(name string, o ...NamespaceOption) *corev1.Namespace
NewNamespace creates a Namespace with NamespaceOptions
func NewService ¶
func NewService(name, namespace string, so ...ServiceOption) *corev1.Service
NewService creates a Service with ServiceOptions
func NewServiceAccount ¶ added in v0.14.0
func NewServiceAccount(name, namespace, gServiceAccount string, so ...ServiceAccountOption) *corev1.ServiceAccount
NewServiceAccount creates a ServiceAccount
func NewTrigger ¶ added in v0.15.0
func NewTrigger(name, namespace, broker string, to ...TriggerOption) *brokerv1beta1.Trigger
NewTrigger creates a Trigger with TriggerOptions.
func NewUnstructured ¶
func NewUnstructured(gvk metav1.GroupVersionKind, name, namespace string, uo ...UnstructuredOption) *unstructured.Unstructured
NewUnstructured creates a unstructured.Unstructured with UnstructuredOption
func NoSubscriptionsExist ¶ added in v0.15.0
func OnlySubscriptions ¶ added in v0.15.0
func OnlyTopics ¶ added in v0.15.0
func SubscriptionExists ¶ added in v0.15.0
func SubscriptionHasDeadLetterPolicy ¶ added in v0.17.0
func SubscriptionHasRetryPolicy ¶ added in v0.17.0
func TestPubsubClient ¶ added in v0.15.0
func TopicExists ¶ added in v0.15.0
func WithBrokerBrokerCellReady ¶ added in v0.16.0
func WithBrokerBrokerCellReady(b *brokerv1beta1.Broker)
func WithBrokerCellDeletionTimestamp ¶ added in v0.15.0
func WithBrokerCellDeletionTimestamp(bc *intv1alpha1.BrokerCell)
func WithBrokerCellReady ¶ added in v0.15.0
func WithBrokerCellReady(bc *intv1alpha1.BrokerCell)
func WithBrokerCellSetDefaults ¶ added in v0.16.0
func WithBrokerCellSetDefaults(bc *intv1alpha1.BrokerCell)
func WithBrokerDeletionTimestamp ¶ added in v0.15.0
func WithBrokerDeletionTimestamp(b *brokerv1beta1.Broker)
func WithBrokerSetDefaults ¶ added in v0.16.0
func WithBrokerSetDefaults(b *brokerv1beta1.Broker)
func WithBrokerSubscriptionReady ¶ added in v0.15.0
func WithBrokerSubscriptionReady(b *brokerv1beta1.Broker)
func WithBrokerTopicReady ¶ added in v0.15.0
func WithBrokerTopicReady(b *brokerv1beta1.Broker)
func WithChannelDeleted ¶
func WithChannelDeletionTimestamp ¶ added in v0.14.0
func WithChannelSetDefaults ¶ added in v0.16.0
func WithInitBrokerCellConditions ¶ added in v0.15.0
func WithInitBrokerCellConditions(bc *intv1alpha1.BrokerCell)
WithInitBrokerCellConditions initializes the BrokerCell's conditions.
func WithInitBrokerConditions ¶ added in v0.15.0
func WithInitBrokerConditions(b *brokerv1beta1.Broker)
WithInitBrokerConditions initializes the Broker's conditions.
func WithInitChannelConditions ¶
WithInitChannelConditions initializes the Channels's conditions.
func WithInitTriggerConditions ¶ added in v0.15.0
func WithInitTriggerConditions(t *brokerv1beta1.Trigger)
WithInitTriggerConditions initializes the Triggers's conditions.
func WithNamespaceDeleted ¶
func WithTriggerBrokerReady ¶ added in v0.15.0
func WithTriggerBrokerReady(t *brokerv1beta1.Trigger)
WithTriggerBrokerReady initializes the Triggers's conditions as if its Broker were ready.
func WithTriggerDeletionTimestamp ¶ added in v0.15.0
func WithTriggerDeletionTimestamp(t *brokerv1beta1.Trigger)
func WithTriggerDependencyReady ¶ added in v0.15.0
func WithTriggerDependencyReady(t *brokerv1beta1.Trigger)
func WithTriggerSetDefaults ¶ added in v0.16.0
func WithTriggerSetDefaults(t *brokerv1beta1.Trigger)
func WithTriggerSubscriberResolvedSucceeded ¶ added in v0.15.0
func WithTriggerSubscriberResolvedSucceeded(t *brokerv1beta1.Trigger)
func WithTriggerSubscriptionReady ¶ added in v0.15.0
func WithTriggerSubscriptionReady(t *brokerv1beta1.Trigger)
func WithTriggerTopicReady ¶ added in v0.15.0
func WithTriggerTopicReady(t *brokerv1beta1.Trigger)
Types ¶
type BrokerCellOption ¶ added in v0.15.0
type BrokerCellOption func(*intv1alpha1.BrokerCell)
BrokerCellOption enables further configuration of a BrokerCell.
func WithBrokerCellAnnotations ¶ added in v0.16.0
func WithBrokerCellAnnotations(annotations map[string]string) BrokerCellOption
func WithBrokerCellFanoutAvailable ¶ added in v0.15.0
func WithBrokerCellFanoutAvailable() BrokerCellOption
func WithBrokerCellFanoutFailed ¶ added in v0.15.0
func WithBrokerCellFanoutFailed(reason, msg string) BrokerCellOption
func WithBrokerCellFanoutUnknown ¶ added in v0.16.0
func WithBrokerCellFanoutUnknown(reason, msg string) BrokerCellOption
func WithBrokerCellFinalizers ¶ added in v0.15.0
func WithBrokerCellFinalizers(finalizers ...string) BrokerCellOption
func WithBrokerCellGeneration ¶ added in v0.15.0
func WithBrokerCellGeneration(gen int64) BrokerCellOption
func WithBrokerCellIngressAvailable ¶ added in v0.15.0
func WithBrokerCellIngressAvailable() BrokerCellOption
func WithBrokerCellIngressFailed ¶ added in v0.15.0
func WithBrokerCellIngressFailed(reason, msg string) BrokerCellOption
func WithBrokerCellRetryAvailable ¶ added in v0.15.0
func WithBrokerCellRetryAvailable() BrokerCellOption
func WithBrokerCellRetryFailed ¶ added in v0.15.0
func WithBrokerCellRetryFailed(reason, msg string) BrokerCellOption
func WithBrokerCellRetryUnknown ¶ added in v0.16.0
func WithBrokerCellRetryUnknown(reason, msg string) BrokerCellOption
func WithBrokerCellStatusObservedGeneration ¶ added in v0.15.0
func WithBrokerCellStatusObservedGeneration(gen int64) BrokerCellOption
func WithIngressTemplate ¶ added in v0.15.0
func WithIngressTemplate(address string) BrokerCellOption
func WithTargetsCofigFailed ¶ added in v0.15.0
func WithTargetsCofigFailed(reason, msg string) BrokerCellOption
func WithTargetsCofigReady ¶ added in v0.15.0
func WithTargetsCofigReady() BrokerCellOption
type BrokerOption ¶ added in v0.15.0
type BrokerOption func(*brokerv1beta1.Broker)
BrokerOption enables further configuration of a Broker.
func WithBrokerAddress ¶ added in v0.15.0
func WithBrokerAddress(address string) BrokerOption
WithBrokerAddress sets the Broker's address.
func WithBrokerAddressURI ¶ added in v0.15.0
func WithBrokerAddressURI(uri *apis.URL) BrokerOption
WithBrokerAddressURI sets the Broker's address as URI.
func WithBrokerBrokerCellFailed ¶ added in v0.16.0
func WithBrokerBrokerCellFailed(reason, msg string) BrokerOption
func WithBrokerBrokerCellUnknown ¶ added in v0.16.0
func WithBrokerBrokerCellUnknown(reason, msg string) BrokerOption
func WithBrokerClass ¶ added in v0.15.0
func WithBrokerClass(bc string) BrokerOption
func WithBrokerDeliverySpec ¶ added in v0.17.0
func WithBrokerDeliverySpec(deliverySpec *eventingduckv1beta1.DeliverySpec) BrokerOption
WithBrokerDeliverySpec sets the Broker's delivery spec.
func WithBrokerFinalizers ¶ added in v0.15.0
func WithBrokerFinalizers(finalizers ...string) BrokerOption
func WithBrokerGeneration ¶ added in v0.15.0
func WithBrokerGeneration(gen int64) BrokerOption
func WithBrokerReady ¶ added in v0.15.0
func WithBrokerReady(address string) BrokerOption
func WithBrokerReadyURI ¶ added in v0.15.0
func WithBrokerReadyURI(address *apis.URL) BrokerOption
WithBrokerReadyURI is a convenience function that sets all ready conditions to true.
func WithBrokerResourceVersion ¶ added in v0.15.0
func WithBrokerResourceVersion(rv string) BrokerOption
func WithBrokerStatusObservedGeneration ¶ added in v0.15.0
func WithBrokerStatusObservedGeneration(gen int64) BrokerOption
func WithBrokerUID ¶ added in v0.15.0
func WithBrokerUID(uid string) BrokerOption
type ChannelOption ¶
ChannelOption enables further configuration of a Channel.
func WithChannelAddress ¶
func WithChannelAddress(url string) ChannelOption
func WithChannelAnnotations ¶ added in v0.15.0
func WithChannelAnnotations(Annotations map[string]string) ChannelOption
func WithChannelGenerateName ¶
func WithChannelGenerateName(generateName string) ChannelOption
func WithChannelLabels ¶
func WithChannelLabels(labels map[string]string) ChannelOption
func WithChannelOwnerReferences ¶
func WithChannelOwnerReferences(ownerReferences []metav1.OwnerReference) ChannelOption
func WithChannelReady ¶
func WithChannelReady(topicID string) ChannelOption
func WithChannelServiceAccount ¶ added in v0.16.0
func WithChannelServiceAccount(kServiceAccount string) ChannelOption
func WithChannelSpec ¶
func WithChannelSpec(spec v1beta1.ChannelSpec) ChannelOption
func WithChannelSubscribers ¶
func WithChannelSubscribers(subscribers []duckv1beta1.SubscriberSpec) ChannelOption
func WithChannelSubscribersStatus ¶
func WithChannelSubscribersStatus(subscribers []eventingduckv1beta1.SubscriberStatus) ChannelOption
func WithChannelTopic ¶
func WithChannelTopic(topicID string) ChannelOption
func WithChannelTopicFailed ¶ added in v0.12.0
func WithChannelTopicFailed(reason, message string) ChannelOption
func WithChannelTopicID ¶ added in v0.12.0
func WithChannelTopicID(topicID string) ChannelOption
func WithChannelTopicUnknown ¶ added in v0.12.0
func WithChannelTopicUnknown(reason, message string) ChannelOption
func WithChannelUID ¶
func WithChannelUID(uid types.UID) ChannelOption
func WithChannelWorkloadIdentityFailed ¶ added in v0.14.0
func WithChannelWorkloadIdentityFailed(reason, message string) ChannelOption
type ConfigMapOption ¶ added in v0.15.0
ConfigMapOption enables further configuration of a ConfigMap.
func WithConfigMapBinaryData ¶ added in v0.15.0
func WithConfigMapBinaryData(data map[string][]byte) ConfigMapOption
func WithConfigMapBinaryDataEntry ¶ added in v0.15.0
func WithConfigMapBinaryDataEntry(key string, value []byte) ConfigMapOption
func WithConfigMapData ¶ added in v0.15.0
func WithConfigMapData(data map[string]string) ConfigMapOption
func WithConfigMapDataEntry ¶ added in v0.15.0
func WithConfigMapDataEntry(key, value string) ConfigMapOption
type Ctor ¶
type Ctor func(context.Context, *Listers, configmap.Watcher, map[string]interface{}) 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 WithDeploymentAvailable ¶ added in v0.16.0
func WithDeploymentAvailable() DeploymentOption
WithDeploymentAvailable marks the Deployment as available.
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 EndpointsOption ¶ added in v0.15.0
EndpointsOption enables further configuration of a Endpoints.
func WithEndpointsAddresses ¶ added in v0.15.0
func WithEndpointsAddresses(addrs ...corev1.EndpointAddress) EndpointsOption
func WithEndpointsAnnotations ¶ added in v0.15.0
func WithEndpointsAnnotations(annotations map[string]string) EndpointsOption
func WithEndpointsLabels ¶ added in v0.15.0
func WithEndpointsLabels(labels map[string]string) EndpointsOption
func WithEndpointsNotReadyAddresses ¶ added in v0.15.0
func WithEndpointsNotReadyAddresses(addrs ...corev1.EndpointAddress) EndpointsOption
type Listers ¶
type Listers struct { servingv1alpha1listers.ConfigurationLister // contains filtered or unexported fields }
func NewListers ¶
func (*Listers) GetAllObjects ¶
func (*Listers) GetBrokerCellLister ¶ added in v0.15.0
func (l *Listers) GetBrokerCellLister() intlisters.BrokerCellLister
func (*Listers) GetBrokerLister ¶ added in v0.15.0
func (l *Listers) GetBrokerLister() brokerlisters.BrokerLister
func (*Listers) GetChannelLister ¶
func (l *Listers) GetChannelLister() messaginglisters.ChannelLister
func (*Listers) GetCloudAuditLogsSourceLister ¶ added in v0.12.0
func (l *Listers) GetCloudAuditLogsSourceLister() eventslisters.CloudAuditLogsSourceLister
func (*Listers) GetCloudBuildSourceLister ¶ added in v0.14.0
func (l *Listers) GetCloudBuildSourceLister() eventsv1beta1listers.CloudBuildSourceLister
func (*Listers) GetCloudPubSubSourceLister ¶ added in v0.12.0
func (l *Listers) GetCloudPubSubSourceLister() eventslisters.CloudPubSubSourceLister
func (*Listers) GetCloudSchedulerSourceLister ¶ added in v0.12.0
func (l *Listers) GetCloudSchedulerSourceLister() eventslisters.CloudSchedulerSourceLister
func (*Listers) GetCloudStorageSourceLister ¶ added in v0.12.0
func (l *Listers) GetCloudStorageSourceLister() eventslisters.CloudStorageSourceLister
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) GetHPALister ¶ added in v0.16.0
func (l *Listers) GetHPALister() hpav2beta2listers.HorizontalPodAutoscalerLister
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) GetPodLister ¶ added in v0.15.0
func (l *Listers) GetPodLister() corev1listers.PodLister
func (*Listers) GetPullSubscriptionLister ¶
func (l *Listers) GetPullSubscriptionLister() inteventslisters.PullSubscriptionLister
func (*Listers) GetRoleBindingLister ¶
func (l *Listers) GetRoleBindingLister() rbacv1listers.RoleBindingLister
func (*Listers) GetServiceAccountLister ¶
func (l *Listers) GetServiceAccountLister() corev1listers.ServiceAccountLister
func (*Listers) GetServingObjects ¶
func (*Listers) GetSinkObjects ¶
func (*Listers) GetTopicLister ¶
func (l *Listers) GetTopicLister() inteventslisters.TopicLister
func (*Listers) GetTriggerLister ¶ added in v0.15.0
func (l *Listers) GetTriggerLister() brokerlisters.TriggerLister
func (*Listers) GetV1ServiceLister ¶ added in v0.10.0
func (l *Listers) GetV1ServiceLister() servingv1listers.ServiceLister
func (*Listers) GetV1alpha1ServiceLister ¶
func (l *Listers) GetV1alpha1ServiceLister() servingv1alpha1listers.ServiceLister
func (*Listers) GetV1beta1ServiceLister ¶
func (l *Listers) GetV1beta1ServiceLister() servingv1beta1listers.ServiceLister
func (*Listers) GetV1beta1TopicLister ¶ added in v0.17.0
func (l *Listers) GetV1beta1TopicLister() inteventsv1beta1listers.TopicLister
type NamespaceOption ¶
NamespaceOption enables further configuration of a Namespace.
func WithNamespaceLabeled ¶
func WithNamespaceLabeled(labels map[string]string) NamespaceOption
type PubsubAction ¶ added in v0.15.0
func SubscriptionWithTopic ¶ added in v0.15.0
func SubscriptionWithTopic(id string, tid string) PubsubAction
func Topic ¶ added in v0.15.0
func Topic(id string) PubsubAction
func TopicAndSub ¶ added in v0.15.0
func TopicAndSub(tid, sid string) PubsubAction
type ServiceAccountOption ¶ added in v0.14.0
type ServiceAccountOption func(*corev1.ServiceAccount)
func WithServiceAccountOwnerReferences ¶ added in v0.14.0
func WithServiceAccountOwnerReferences(ownerReferences []metav1.OwnerReference) ServiceAccountOption
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 TriggerOption ¶ added in v0.15.0
type TriggerOption func(*brokerv1beta1.Trigger)
TriggerOption enables further configuration of a Trigger.
func WithDependencyAnnotation ¶ added in v0.15.0
func WithDependencyAnnotation(dependencyAnnotation string) TriggerOption
func WithInjectionAnnotation ¶ added in v0.15.0
func WithInjectionAnnotation(injectionAnnotation string) TriggerOption
func WithTriggerBrokerFailed ¶ added in v0.15.0
func WithTriggerBrokerFailed(reason, message string) TriggerOption
WithTriggerBrokerFailed marks the Broker as failed
func WithTriggerBrokerUnknown ¶ added in v0.15.0
func WithTriggerBrokerUnknown(reason, message string) TriggerOption
WithTriggerBrokerUnknown marks the Broker as unknown
func WithTriggerDependencyFailed ¶ added in v0.15.0
func WithTriggerDependencyFailed(reason, message string) TriggerOption
func WithTriggerDependencyUnknown ¶ added in v0.15.0
func WithTriggerDependencyUnknown(reason, message string) TriggerOption
func WithTriggerFinalizers ¶ added in v0.15.0
func WithTriggerFinalizers(finalizers ...string) TriggerOption
func WithTriggerGeneration ¶ added in v0.15.0
func WithTriggerGeneration(gen int64) TriggerOption
func WithTriggerStatusObservedGeneration ¶ added in v0.15.0
func WithTriggerStatusObservedGeneration(gen int64) TriggerOption
func WithTriggerStatusSubscriberURI ¶ added in v0.15.0
func WithTriggerStatusSubscriberURI(uri string) TriggerOption
func WithTriggerSubscriberRef ¶ added in v0.15.0
func WithTriggerSubscriberRef(gvk metav1.GroupVersionKind, name, namespace string) TriggerOption
func WithTriggerSubscriberRefAndURIReference ¶ added in v0.15.0
func WithTriggerSubscriberRefAndURIReference(gvk metav1.GroupVersionKind, name, namespace string, rawuri string) TriggerOption
func WithTriggerSubscriberResolvedFailed ¶ added in v0.15.0
func WithTriggerSubscriberResolvedFailed(reason, message string) TriggerOption
func WithTriggerSubscriberResolvedUnknown ¶ added in v0.15.0
func WithTriggerSubscriberResolvedUnknown(reason, message string) TriggerOption
func WithTriggerSubscriberURI ¶ added in v0.15.0
func WithTriggerSubscriberURI(rawurl string) TriggerOption
func WithTriggerUID ¶ added in v0.15.0
func WithTriggerUID(uid string) TriggerOption
type UnstructuredOption ¶
type UnstructuredOption func(*unstructured.Unstructured)
UnstructuredOption enables further configuration of a Unstructured.
func WithUnstructuredAddressable ¶
func WithUnstructuredAddressable(hostname string) UnstructuredOption
func WithUnstructuredAnnotations ¶ added in v0.14.0
func WithUnstructuredAnnotations(annotations map[string]interface{}) UnstructuredOption
func WithUnstructuredLabels ¶ added in v0.14.0
func WithUnstructuredLabels(labels map[string]interface{}) UnstructuredOption