kafkatopic

Documentation

Index

• func GVR() schema.GroupVersionResource
• 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 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).