kafka

package

v0.17.4 Latest Latest Go to latest Published: Sep 28, 2020 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

Repository URL not available.

Links

Open Source Insights

README ¶

Apache Kafka Components for Knative

Apache Kafka Components for Knative support the KafkaChannel and the KafkaSource implementation, which offer ways to integrate Knative with the Apache Kafka broker.

Overview

For details about the KafkaChannel or the KafkaSource, click on the links below:

Documentation ¶

Index ¶

func NewConfig(ctx context.Context) ([]string, *sarama.Config, error)
func NewProducer(ctx context.Context) (sarama.Client, error)
type AdapterNet
type AdapterSASL
type AdapterTLS

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewConfig ¶

func NewConfig(ctx context.Context) ([]string, *sarama.Config, error)

NewConfig extracts the Kafka configuration from the environment.

func NewProducer ¶

func NewProducer(ctx context.Context) (sarama.Client, error)

NewProducer is a helper method for constructing a client for producing kafka methods.

Types ¶

type AdapterNet ¶

type AdapterNet struct {
	SASL AdapterSASL
	TLS  AdapterTLS
}

type AdapterSASL ¶

type AdapterSASL struct {
	Enable   bool   `envconfig:"KAFKA_NET_SASL_ENABLE" required:"false"`
	User     string `envconfig:"KAFKA_NET_SASL_USER" required:"false"`
	Password string `envconfig:"KAFKA_NET_SASL_PASSWORD" required:"false"`
}

type AdapterTLS ¶

type AdapterTLS struct {
	Enable bool   `envconfig:"KAFKA_NET_TLS_ENABLE" required:"false"`
	Cert   string `envconfig:"KAFKA_NET_TLS_CERT" required:"false"`
	Key    string `envconfig:"KAFKA_NET_TLS_KEY" required:"false"`
	CACert string `envconfig:"KAFKA_NET_TLS_CA_CERT" required:"false"`
}

Source Files ¶

client.go

Directories ¶

Path	Synopsis
channel
cmd/channel_controller command
cmd/channel_dispatcher command
cmd/webhook command
config Package config is a placeholder that allows us to pull in config files via go mod vendor.	Package config is a placeholder that allows us to pull in config files via go mod vendor.
pkg/apis/messaging
pkg/apis/messaging/v1alpha1 Package v1alpha1 is the v1alpha1 version of the API.	Package v1alpha1 is the v1alpha1 version of the API.
pkg/apis/messaging/v1beta1 Package v1beta1 is the v1beta1 version of the API.	Package v1beta1 is the v1beta1 version of the API.
pkg/client/clientset/versioned This package has the automatically generated clientset.	This package has the automatically generated clientset.
pkg/client/clientset/versioned/fake This package has the automatically generated fake clientset.	This package has the automatically generated fake clientset.
pkg/client/clientset/versioned/scheme This package contains the scheme of the automatically generated clientset.	This package contains the scheme of the automatically generated clientset.
pkg/client/clientset/versioned/typed/messaging/v1alpha1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
pkg/client/clientset/versioned/typed/messaging/v1alpha1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
pkg/client/clientset/versioned/typed/messaging/v1beta1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
pkg/client/clientset/versioned/typed/messaging/v1beta1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
pkg/client/informers/externalversions
pkg/client/informers/externalversions/internalinterfaces
pkg/client/informers/externalversions/messaging
pkg/client/informers/externalversions/messaging/v1alpha1
pkg/client/informers/externalversions/messaging/v1beta1
pkg/client/injection/client
pkg/client/injection/client/fake
pkg/client/injection/informers/factory
pkg/client/injection/informers/factory/fake
pkg/client/injection/informers/messaging/v1alpha1/kafkachannel
pkg/client/injection/informers/messaging/v1alpha1/kafkachannel/fake
pkg/client/injection/informers/messaging/v1beta1/kafkachannel
pkg/client/injection/informers/messaging/v1beta1/kafkachannel/fake
pkg/client/injection/reconciler/messaging/v1alpha1/kafkachannel
pkg/client/injection/reconciler/messaging/v1alpha1/kafkachannel/stub
pkg/client/injection/reconciler/messaging/v1beta1/kafkachannel
pkg/client/injection/reconciler/messaging/v1beta1/kafkachannel/stub
pkg/client/listers/messaging/v1alpha1
pkg/client/listers/messaging/v1beta1
pkg/dispatcher
pkg/reconciler
pkg/reconciler/controller
pkg/reconciler/controller/resources
pkg/reconciler/dispatcher
pkg/reconciler/testing
pkg/utils
common
pkg/kafka
source
cmd/controller command
cmd/receive_adapter command
config Package config is a placeholder that allows us to pull in config files via go mod vendor.	Package config is a placeholder that allows us to pull in config files via go mod vendor.
pkg/adapter
pkg/apis/bindings Package bindings contains bindings API versions	Package bindings contains bindings API versions
pkg/apis/bindings/v1alpha1 Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=bindings.knative.dev Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev	Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=bindings.knative.dev Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev
pkg/apis/bindings/v1beta1 Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=bindings.knative.dev Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev	Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=bindings.knative.dev Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev
pkg/apis/sources Package sources contains sources API versions	Package sources contains sources API versions
pkg/apis/sources/v1alpha1 Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev	Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev
pkg/apis/sources/v1beta1 Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev	Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev
pkg/client/clientset/versioned This package has the automatically generated clientset.	This package has the automatically generated clientset.
pkg/client/clientset/versioned/fake This package has the automatically generated fake clientset.	This package has the automatically generated fake clientset.
pkg/client/clientset/versioned/scheme This package contains the scheme of the automatically generated clientset.	This package contains the scheme of the automatically generated clientset.
pkg/client/clientset/versioned/typed/bindings/v1alpha1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
pkg/client/clientset/versioned/typed/bindings/v1alpha1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
pkg/client/clientset/versioned/typed/bindings/v1beta1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
pkg/client/clientset/versioned/typed/bindings/v1beta1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
pkg/client/clientset/versioned/typed/sources/v1alpha1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
pkg/client/clientset/versioned/typed/sources/v1alpha1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
pkg/client/clientset/versioned/typed/sources/v1beta1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
pkg/client/clientset/versioned/typed/sources/v1beta1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
pkg/client/informers/externalversions
pkg/client/informers/externalversions/bindings
pkg/client/informers/externalversions/bindings/v1alpha1
pkg/client/informers/externalversions/bindings/v1beta1
pkg/client/informers/externalversions/internalinterfaces
pkg/client/informers/externalversions/sources
pkg/client/informers/externalversions/sources/v1alpha1
pkg/client/informers/externalversions/sources/v1beta1
pkg/client/injection/client
pkg/client/injection/client/fake
pkg/client/injection/informers/bindings/v1alpha1/kafkabinding
pkg/client/injection/informers/bindings/v1alpha1/kafkabinding/fake
pkg/client/injection/informers/bindings/v1beta1/kafkabinding
pkg/client/injection/informers/bindings/v1beta1/kafkabinding/fake
pkg/client/injection/informers/factory
pkg/client/injection/informers/factory/fake
pkg/client/injection/informers/sources/v1alpha1/kafkasource
pkg/client/injection/informers/sources/v1alpha1/kafkasource/fake
pkg/client/injection/informers/sources/v1beta1/kafkasource
pkg/client/injection/informers/sources/v1beta1/kafkasource/fake
pkg/client/injection/reconciler/bindings/v1alpha1/kafkabinding
pkg/client/injection/reconciler/bindings/v1alpha1/kafkabinding/stub
pkg/client/injection/reconciler/bindings/v1beta1/kafkabinding
pkg/client/injection/reconciler/bindings/v1beta1/kafkabinding/stub
pkg/client/injection/reconciler/sources/v1alpha1/kafkasource
pkg/client/injection/reconciler/sources/v1alpha1/kafkasource/stub
pkg/client/injection/reconciler/sources/v1beta1/kafkasource
pkg/client/injection/reconciler/sources/v1beta1/kafkasource/stub
pkg/client/listers/bindings/v1alpha1
pkg/client/listers/bindings/v1beta1
pkg/client/listers/sources/v1alpha1
pkg/client/listers/sources/v1beta1
pkg/reconciler/binding
pkg/reconciler/source Package source implements the KafkaSource controller.	Package source implements the KafkaSource controller.
pkg/reconciler/source/resources

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL