GetFailedTestClientCreateFunc returns a pubsub client creation function that will fail when the invoke time reaches maxCallTime.

GetTestClientCreateFunc returns a client creation function with same type as pubsub.NewClient.

MakeFactory creates a reconciler factory with fake clients and controller created by `ctor`.

NewBroker creates a Broker with BrokerOptions.

NewBrokerCell creates a BrokerCell with BrokerCellOptions.

NewBrokerDeliveryConfigMapFromDeliverySpec creates a new cluster defaulted broker delivery configuration map from a given delivery spec.

NewChannel creates a Channel with ChannelOptions.

NewChannelWithoutNamespace creates a Channel with ChannelOptions but without a specific namespace.

NewConfigMap creates a ConfigMap with ConfigMapOptions.

NewDataresidencyConfigMapFromRegions Create new data residency configuration map from list of allowed persistence regions.

NewDeployment creates a Deployment with DeploymentOptions.

NewEndpoints creates a Endpoints with EndpointsOptions.

NewNamespace creates a Namespace with NamespaceOptions.

NewSecret creates a Secret.

NewService creates a Service with ServiceOptions.

NewServiceAccount creates a ServiceAccount.

NewTrigger creates a Trigger with TriggerOptions.

NewUnstructured creates a unstructured.Unstructured with UnstructuredOption.

WithBrokerAddress sets the Broker's address.

WithBrokerAddressURI sets the Broker's address as URI.

WithBrokerDeliverySpec sets the Broker's delivery spec.

WithBrokerReadyURI is a convenience function that sets all ready conditions to true.

WithBrokerReadyURI is a convenience function that sets all ready conditions to true.

WithDeploymentAvailable marks the Deployment as available.

WithDeploymentMinimumReplicasUnavailable marks the Deployment as unavailable for minimal replica unavailable.

WithInitBrokerCellConditions initializes the BrokerCell's conditions.

WithInitBrokerConditions initializes the Broker's conditions.

WithInitChannelConditions initializes the Channels's conditions.

WithInitTriggerConditions initializes the Triggers's conditions.

WithTriggerBrokerFailed marks the Broker as failed.

WithTriggerBrokerReady initializes the Triggers's conditions as if its Broker were ready.

WithTriggerBrokerUnknown marks the Broker as unknown.

BrokerCellOption enables further configuration of a BrokerCell.

BrokerOption enables further configuration of a Broker.

ChannelOption enables further configuration of a Channel.

ConfigMapOption enables further configuration of a ConfigMap.

Ctor functions create a k8s controller with given params.

DeploymentOption enables further configuration of a Deployment.

EndpointsOption enables further configuration of a Endpoints.

NamespaceOption enables further configuration of a Namespace.

ServiceOption enables further configuration of a Service.

TriggerOption enables further configuration of a Trigger.

UnstructuredOption enables further configuration of a Unstructured.