channel

Documentation

Index

• Constants
• func AsDeadLetterSink(createSubscriberFn func(ref *duckv1.KReference, uri string) manifest.CfgFn) *feature.Feature
• func ChannelChain(length int, ...) *feature.Feature
• func ChannelPreferHeaderCheck(createSubscriberFn func(ref *duckv1.KReference, uri string) manifest.CfgFn) *feature.Feature
• func ControlPlaneChannel(channelName string) *feature.Feature
• func ControlPlaneConformance(channelName string) *feature.FeatureSet
• func DataPlaneChannel(channelName string) *feature.Feature
• func DataPlaneConformance(channelName string) *feature.FeatureSet
• func DeadLetterSink(createSubscriberFn func(ref *duckv1.KReference, uri string) manifest.CfgFn) *feature.Feature
• func DeadLetterSinkGenericChannel(createSubscriberFn func(ref *duckv1.KReference, uri string) manifest.CfgFn) *feature.Feature
• func EventTransformation() *feature.Feature
• func GoesReady(name string, cfg ...manifest.CfgFn) *feature.Feature
• func ImplGoesReady(name string, cfg ...manifest.CfgFn) *feature.Feature
• func ServiceAccountSubjectAccessReviewAllowedOrFail(ctx context.Context, t feature.T, gvr schema.GroupVersionResource, ...)
• func SingleEventWithEncoding(encoding binding.Encoding) *feature.Feature
• func SubscriptionGoesReady(name string, cfg ...manifest.CfgFn) *feature.Feature
• type EventingClient
  • func Client(ctx context.Context) *EventingClient

Constants

const (
	ChannelableNameKey = "channelableName"
)

Functions

func AsDeadLetterSink

func AsDeadLetterSink(createSubscriberFn func(ref *duckv1.KReference, uri string) manifest.CfgFn) *feature.Feature

func ChannelChain

func ChannelChain(length int, createSubscriberFn func(ref *duckv1.KReference, uri string) manifest.CfgFn) *feature.Feature

func ChannelPreferHeaderCheck

func ChannelPreferHeaderCheck(createSubscriberFn func(ref *duckv1.KReference, uri string) manifest.CfgFn) *feature.Feature

func ControlPlaneChannel

func ControlPlaneChannel(channelName string) *feature.Feature

func ControlPlaneConformance

func ControlPlaneConformance(channelName string) *feature.FeatureSet

func DataPlaneChannel

func DataPlaneChannel(channelName string) *feature.Feature

func DataPlaneConformance

func DataPlaneConformance(channelName string) *feature.FeatureSet

func DeadLetterSink

func DeadLetterSink(createSubscriberFn func(ref *duckv1.KReference, uri string) manifest.CfgFn) *feature.Feature

func DeadLetterSinkGenericChannel

func DeadLetterSinkGenericChannel(createSubscriberFn func(ref *duckv1.KReference, uri string) manifest.CfgFn) *feature.Feature

func EventTransformation

func EventTransformation() *feature.Feature

func GoesReady

func GoesReady(name string, cfg ...manifest.CfgFn) *feature.Feature

GoesReady returns a feature testing if a Channel becomes ready.

func ImplGoesReady

func ImplGoesReady(name string, cfg ...manifest.CfgFn) *feature.Feature

ImplGoesReady returns a feature testing if a channel impl becomes ready.

func ServiceAccountSubjectAccessReviewAllowedOrFail

func ServiceAccountSubjectAccessReviewAllowedOrFail(ctx context.Context, t feature.T, gvr schema.GroupVersionResource, subresource string, saName string, verb string)

TODO: move this to framework?

func SingleEventWithEncoding

func SingleEventWithEncoding(encoding binding.Encoding) *feature.Feature

func SubscriptionGoesReady

func SubscriptionGoesReady(name string, cfg ...manifest.CfgFn) *feature.Feature

SubscriptionGoesReady returns a feature testing if a Subscription becomes ready.

Types

type EventingClient

type EventingClient struct {
	Channels    messagingclientsetv1.ChannelInterface
	ChannelImpl dynamic.ResourceInterface
}

func Client

func Client(ctx context.Context) *EventingClient