kafkatopic

Documentation

Overview

Example (Full)

images := map[string]string{}
cfg := map[string]interface{}{
	"name": "foo",
}

WithClusterName("other-cluster")(cfg)
WithClusterNamespace("here")(cfg)
WithPartitions("100")(cfg)

files, err := manifest.ExecuteLocalYAML(images, cfg)
if err != nil {
	panic(err)
}

manifest.OutputYAML(os.Stdout, files)

Output:

apiVersion: kafka.strimzi.io/v1beta1
kind: KafkaTopic
metadata:
  name: foo
  namespace: here
  labels:
    strimzi.io/cluster: other-cluster
spec:
  partitions: 100
  replicas: 1

Example (Min)

images := map[string]string{}
cfg := map[string]interface{}{
	"name":             "foo",
	"partitions":       10,
	"clusterName":      "my-cluster",
	"clusterNamespace": "there",
}

files, err := manifest.ExecuteLocalYAML(images, cfg)
if err != nil {
	panic(err)
}

manifest.OutputYAML(os.Stdout, files)

Output:

apiVersion: kafka.strimzi.io/v1beta1
kind: KafkaTopic
metadata:
  name: foo
  namespace: there
  labels:
    strimzi.io/cluster: my-cluster
spec:
  partitions: 10
  replicas: 1

Index

• func GVR() schema.GroupVersionResource
• func Install(name string, opts ...CfgFn) feature.StepFn
• func IsReady(name string, timings ...time.Duration) feature.StepFn
• type CfgFn
  • func WithClusterName(name string) CfgFn
  • func WithClusterNamespace(namespace string) CfgFn
  • func WithPartitions(partitions string) CfgFn

Examples

• Package (Full)
• Package (Min)

Functions

func GVR

func GVR() schema.GroupVersionResource

func Install

func Install(name string, opts ...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.

Types

type CfgFn

type CfgFn func(map[string]interface{})

func WithClusterName

func WithClusterName(name string) CfgFn

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

func WithClusterNamespace

func WithClusterNamespace(namespace string) CfgFn

WithClusterName overrides the Kakfa cluster namespace where to create the topic (default: kafka)

func WithPartitions

func WithPartitions(partitions string) CfgFn

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