Versions in this module Expand all Collapse all v0 v0.5.0 Feb 7, 2020 Changes in this version + const InputStreamsStashKey + const OutputStreamsStashKey + const ProcessorImagesStashKey + func GatewayChildDeploymentReconciler(c controllers.Config) controllers.SubReconciler + func GatewayChildServiceReconciler(c controllers.Config) controllers.SubReconciler + func GatewayReconciler(c controllers.Config) *controllers.ParentReconciler + func InMemoryGatewayChildGatewayReconciler(c controllers.Config) controllers.SubReconciler + func InMemoryGatewayReconciler(c controllers.Config, namespace string) *controllers.ParentReconciler + func InMemoryGatewaySyncConfigReconciler(c controllers.Config, namespace string) controllers.SubReconciler + func KafkaGatewayChildGatewayReconciler(c controllers.Config) controllers.SubReconciler + func KafkaGatewayReconciler(c controllers.Config, namespace string) *controllers.ParentReconciler + func KafkaGatewaySyncConfigReconciler(c controllers.Config, namespace string) controllers.SubReconciler + func ProcessorBuildRefReconciler(c controllers.Config) controllers.SubReconciler + func ProcessorChildDeploymentReconciler(c controllers.Config) controllers.SubReconciler + func ProcessorChildScaledObjectReconciler(c controllers.Config) controllers.SubReconciler + func ProcessorReconciler(c controllers.Config, namespace string) *controllers.ParentReconciler + func ProcessorResolveStreamsReconciler(c controllers.Config) controllers.SubReconciler + func ProcessorSyncProcessorImages(c controllers.Config, namespace string) controllers.SubReconciler + func PulsarGatewayChildGatewayReconciler(c controllers.Config) controllers.SubReconciler + func PulsarGatewayReconciler(c controllers.Config, namespace string) *controllers.ParentReconciler + func PulsarGatewaySyncConfigReconciler(c controllers.Config, namespace string) controllers.SubReconciler + func StreamChildBindingMetadataReconciler(c controllers.Config) controllers.SubReconciler + func StreamChildBindingSecretReconciler(c controllers.Config) controllers.SubReconciler + func StreamProvisionReconciler(c controllers.Config, provisioner StreamProvisionerClient) controllers.SubReconciler + func StreamReconciler(c controllers.Config, provisioner StreamProvisionerClient) *controllers.ParentReconciler + func StreamSyncBindingCondition(c controllers.Config) controllers.SubReconciler + type MockStreamProvisionerClient struct + func (_m *MockStreamProvisionerClient) ProvisionStream(stream *v1alpha1.Stream, provisionerURL string) (*StreamAddress, error) + type StreamAddress struct + Gateway string + Topic string + type StreamProvisionerClient interface + ProvisionStream func(stream *streamingv1alpha1.Stream, provisionerURL string) (*StreamAddress, error) + func NewStreamProvisionerClient(httpClient *http.Client, logger logr.Logger) StreamProvisionerClient
Go to main page