channel

package
v0.42.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 21, 2024 License: Apache-2.0 Imports: 53 Imported by: 1

Documentation

Index

Constants

View Source
const (
	ChannelableNameKey = "channelableName"
)

Variables

This section is empty.

Functions

func AsDeadLetterSink added in v0.31.0

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

func ChannelChain added in v0.23.0

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

func ChannelDeadLetterSinkExtensions added in v0.36.0

func ChannelDeadLetterSinkExtensions(createSubscriberFn func(ref *duckv1.KReference, uri string) manifest.CfgFn) *feature.FeatureSet

func ChannelPreferHeaderCheck added in v0.35.0

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 added in v0.23.0

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

func DeadLetterSinkGenericChannel added in v0.27.4

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

func DispatcherAuthenticatesRequestsWithOIDC added in v0.40.2

func DispatcherAuthenticatesRequestsWithOIDC() *feature.Feature

func EventTransformation added in v0.24.0

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 RotateDispatcherTLSCertificate added in v0.38.5

func RotateDispatcherTLSCertificate() *feature.Feature

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 ShouldNotUpdateVersion added in v0.41.0

func ShouldNotUpdateVersion(ctx context.Context, t feature.T)

func SingleEventWithEncoding added in v0.24.0

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.

func SubscriptionTLS added in v0.40.0

func SubscriptionTLS() *feature.Feature

func SubscriptionTLSTrustBundle added in v0.40.0

func SubscriptionTLSTrustBundle() *feature.Feature

Types

type EventingClient

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

func Client

func Client(ctx context.Context) *EventingClient

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL