streaming

Documentation

Index

• Constants
• 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
  • func (_m *MockStreamProvisionerClient) ProvisionStream(stream *v1alpha1.Stream, provisionerURL string) (*StreamAddress, error)
• type StreamAddress
• type StreamProvisionerClient
  • func NewStreamProvisionerClient(httpClient *http.Client, logger logr.Logger) StreamProvisionerClient

Constants

const (
	ProcessorImagesStashKey controllers.StashKey = "processor-images"
	InputStreamsStashKey    controllers.StashKey = "input-streams"
	OutputStreamsStashKey   controllers.StashKey = "output-streams"
)

Functions

func GatewayChildDeploymentReconciler

func GatewayChildDeploymentReconciler(c controllers.Config) controllers.SubReconciler

func GatewayChildServiceReconciler

func GatewayChildServiceReconciler(c controllers.Config) controllers.SubReconciler

func GatewayReconciler

func GatewayReconciler(c controllers.Config) *controllers.ParentReconciler

func InMemoryGatewayChildGatewayReconciler

func InMemoryGatewayChildGatewayReconciler(c controllers.Config) controllers.SubReconciler

func InMemoryGatewayReconciler

func InMemoryGatewayReconciler(c controllers.Config, namespace string) *controllers.ParentReconciler

func InMemoryGatewaySyncConfigReconciler

func InMemoryGatewaySyncConfigReconciler(c controllers.Config, namespace string) controllers.SubReconciler

func KafkaGatewayChildGatewayReconciler

func KafkaGatewayChildGatewayReconciler(c controllers.Config) controllers.SubReconciler

func KafkaGatewayReconciler

func KafkaGatewayReconciler(c controllers.Config, namespace string) *controllers.ParentReconciler

func KafkaGatewaySyncConfigReconciler

func KafkaGatewaySyncConfigReconciler(c controllers.Config, namespace string) controllers.SubReconciler

func ProcessorBuildRefReconciler

func ProcessorBuildRefReconciler(c controllers.Config) controllers.SubReconciler

func ProcessorChildDeploymentReconciler

func ProcessorChildDeploymentReconciler(c controllers.Config) controllers.SubReconciler

func ProcessorChildScaledObjectReconciler

func ProcessorChildScaledObjectReconciler(c controllers.Config) controllers.SubReconciler

func ProcessorReconciler

func ProcessorReconciler(c controllers.Config, namespace string) *controllers.ParentReconciler

func ProcessorResolveStreamsReconciler

func ProcessorResolveStreamsReconciler(c controllers.Config) controllers.SubReconciler

func ProcessorSyncProcessorImages

func ProcessorSyncProcessorImages(c controllers.Config, namespace string) controllers.SubReconciler

func PulsarGatewayChildGatewayReconciler

func PulsarGatewayChildGatewayReconciler(c controllers.Config) controllers.SubReconciler

func PulsarGatewayReconciler

func PulsarGatewayReconciler(c controllers.Config, namespace string) *controllers.ParentReconciler

func PulsarGatewaySyncConfigReconciler

func PulsarGatewaySyncConfigReconciler(c controllers.Config, namespace string) controllers.SubReconciler

func StreamChildBindingMetadataReconciler

func StreamChildBindingMetadataReconciler(c controllers.Config) controllers.SubReconciler

func StreamChildBindingSecretReconciler

func StreamChildBindingSecretReconciler(c controllers.Config) controllers.SubReconciler

func StreamProvisionReconciler

func StreamProvisionReconciler(c controllers.Config, provisioner StreamProvisionerClient) controllers.SubReconciler

func StreamReconciler

func StreamReconciler(c controllers.Config, provisioner StreamProvisionerClient) *controllers.ParentReconciler

func StreamSyncBindingCondition

func StreamSyncBindingCondition(c controllers.Config) controllers.SubReconciler

Types

type MockStreamProvisionerClient

type MockStreamProvisionerClient struct {
	mock.Mock
}

MockStreamProvisionerClient is an autogenerated mock type for the StreamProvisionerClient type

func (*MockStreamProvisionerClient) ProvisionStream

func (_m *MockStreamProvisionerClient) ProvisionStream(stream *v1alpha1.Stream, provisionerURL string) (*StreamAddress, error)

ProvisionStream provides a mock function with given fields: stream, provisionerURL

type StreamAddress

type StreamAddress struct {
	Gateway string `json:"gateway,omitempty"`
	Topic   string `json:"topic,omitempty"`
}

type StreamProvisionerClient

type StreamProvisionerClient interface {
	ProvisionStream(stream *streamingv1alpha1.Stream, provisionerURL string) (*StreamAddress, error)
}

func NewStreamProvisionerClient

func NewStreamProvisionerClient(httpClient *http.Client, logger logr.Logger) StreamProvisionerClient