kafkatopic

package
v0.39.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 15, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GVR

func HasNumPartitions added in v0.37.0

func HasNumPartitions(name string, numPartitions int, timings ...time.Duration) feature.StepFn

HasReplicationFactor asserts that the Topic has the given replication factor.

func HasReplicationFactor added in v0.37.0

func HasReplicationFactor(name string, replicationFactor int, timings ...time.Duration) feature.StepFn

HasReplicationFactor asserts that the Topic has the given replication factor.

func Install

func Install(name string, opts ...manifest.CfgFn) feature.StepFn

Install will create a Kafka Topic via the Strimzi topic CRD,, augmented with the config fn options.

func IsReady

func IsReady(name string, timings ...time.Duration) feature.StepFn

IsReady tests to see if a KafkaTopic becomes ready within the time given.

func WithClusterName

func WithClusterName(name string) manifest.CfgFn

WithClusterName overrides the Kafka cluster names where to create the topic (default: my-cluster)

func WithClusterNamespace

func WithClusterNamespace(namespace string) manifest.CfgFn

WithClusterNamespace overrides the Kafka cluster namespace where to create the topic (default: kafka)

func WithPartitions

func WithPartitions(partitions string) manifest.CfgFn

WithPartitions overrides the number of partitions (default: 10).

Types

This section is empty.

Jump to

Keyboard shortcuts

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