kafkatopic

Documentation

Index

• func GVR() schema.GroupVersionResource
• func HasNumPartitions(name string, numPartitions int, timings ...time.Duration) feature.StepFn
• func HasReplicationFactor(name string, replicationFactor int, timings ...time.Duration) feature.StepFn
• func Install(name string, opts ...manifest.CfgFn) feature.StepFn
• func IsReady(name string, timings ...time.Duration) feature.StepFn
• func WithClusterName(name string) manifest.CfgFn
• func WithClusterNamespace(namespace string) manifest.CfgFn
• func WithPartitions(partitions string) manifest.CfgFn

Functions

func GVR

func GVR() schema.GroupVersionResource

func HasNumPartitions

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

HasReplicationFactor asserts that the Topic has the given replication factor.

func HasReplicationFactor

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).