kafkachannel

Documentation

Overview

Example

images := map[string]string{}

cfg := map[string]interface{}{
	"name":      "foo",
	"namespace": "bar",
	"version":   "v1beta1",
}
WithNumPartitions("10")(cfg)
WithReplicationFactor("3")(cfg)
WithRetentionDuration("P1D")

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

manifest.OutputYAML(os.Stdout, files)

Output:

apiVersion: messaging.knative.dev/v1beta1
kind: KafkaChannel
metadata:
  name: foo
  namespace: bar
spec:
  numPartitions: 10
  replicationFactor: 3

Index

• func GVR() schema.GroupVersionResource
• func Install(name string, opts ...manifest.CfgFn) feature.StepFn
• func IsReady(name string, timings ...time.Duration) feature.StepFn
• func WithNumPartitions(numPartitions string) manifest.CfgFn
• func WithReplicationFactor(replicationFactor string) manifest.CfgFn
• func WithRetentionDuration(retentionDuration string) manifest.CfgFn
• func WithVersion(version string) manifest.CfgFn

Examples

• Package

Functions

func GVR

func GVR() schema.GroupVersionResource

func Install

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

Install will create a KafkaChannel resource, using the latest version, augmented with the config fn options.

func IsReady

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

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

func WithNumPartitions

func WithNumPartitions(numPartitions string) manifest.CfgFn

WithNumPartitions adds the numPartitions config to a KafkaChannel spec.

func WithReplicationFactor

func WithReplicationFactor(replicationFactor string) manifest.CfgFn

WithReplicationFactor adds the replicationFactor config to a KafkaChannel spec.

func WithRetentionDuration

func WithRetentionDuration(retentionDuration string) manifest.CfgFn

WithRetentionDuration adds the retentionDuration config to a KafkaChannel spec.

func WithVersion

func WithVersion(version string) manifest.CfgFn

WithVersion overrides the default API version