kafkachannel

Documentation

Index

• func Address(ctx context.Context, name string, timings ...time.Duration) (*duckv1.Addressable, error)
• func AsDestinationRef(name string) *duckv1.Destination
• func AsRef(name string) *duckv1.KReference
• func GVK() schema.GroupVersionKind
• func GVR() schema.GroupVersionResource
• func Install(name string, opts ...manifest.CfgFn) feature.StepFn
• func IsReady(name string, timings ...time.Duration) feature.StepFn
• func ValidateAddress(name string, validate addressable.ValidateAddressFn, 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
• type EnvConfig

Functions

func Address

func Address(ctx context.Context, name string, timings ...time.Duration) (*duckv1.Addressable, error)

Address returns a Channel's address.

func AsDestinationRef

func AsDestinationRef(name string) *duckv1.Destination

AsRef returns a KRef for a Channel without namespace.

func AsRef

func AsRef(name string) *duckv1.KReference

AsRef returns a KRef for a Channel without namespace.

func GVK

func GVK() schema.GroupVersionKind

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 ValidateAddress

func ValidateAddress(name string, validate addressable.ValidateAddressFn, timings ...time.Duration) feature.StepFn

ValidateAddress validates the address retured by Address

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

Types

type EnvConfig

type EnvConfig struct {
	ChannelGK string `envconfig:"CHANNEL_GROUP_KIND" default:"KafkaChannel.messaging.knative.dev" required:"true"`
	ChannelV  string `envconfig:"CHANNEL_VERSION" default:"v1beta1" required:"true"`
}

var EnvCfg EnvConfig