Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type KafkaTopicInterface ¶
type KafkaTopicInterface = v1beta2.KafkaTopicInterface
type TopicDeployer ¶
type TopicDeployer interface {
Deploy(ctx context.Context, topic v1beta2.KafkaTopic) error
Undeploy(ctx context.Context, namespace string, name string) error
}
func NewTopicDeployer ¶
func NewTopicDeployer( clientset versioned.Interface, ) TopicDeployer
Directories
¶
| Path | Synopsis |
|---|---|
|
k8s
|
|
|
apis/kafka.strimzi.io/v1beta2
Package v1beta2 is the v1beta2 version of the API.
|
Package v1beta2 is the v1beta2 version of the API. |
|
client/clientset/versioned/fake
This package has the automatically generated fake clientset.
|
This package has the automatically generated fake clientset. |
|
client/clientset/versioned/scheme
This package contains the scheme of the automatically generated clientset.
|
This package contains the scheme of the automatically generated clientset. |
|
client/clientset/versioned/typed/kafka.strimzi.io/v1beta2
This package has the automatically generated typed clients.
|
This package has the automatically generated typed clients. |
|
client/clientset/versioned/typed/kafka.strimzi.io/v1beta2/fake
Package fake has the automatically generated clients.
|
Package fake has the automatically generated clients. |
|
Code generated by counterfeiter.
|
Code generated by counterfeiter. |
Click to show internal directories.
Click to hide internal directories.