kafkachannel

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 WithNumPartitions(numPartitions string) manifest.CfgFn
• func WithReplicationFactor(replicationFactor string) manifest.CfgFn
• func WithRetentionDuration(retentionDuration string) manifest.CfgFn
• func WithVersion(version 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 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