channel

package

v0.42.2 Latest Latest Go to latest Published: Sep 23, 2024 License: Apache-2.0 Imports: 53 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/knative/eventing

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func AsDeadLetterSink(createSubscriberFn func(ref *duckv1.KReference, uri string) manifest.CfgFn) *feature.Feature
func ChannelChain(length int, ...) *feature.Feature
func ChannelDeadLetterSinkExtensions(createSubscriberFn func(ref *duckv1.KReference, uri string) manifest.CfgFn) *feature.FeatureSet
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 DispatcherAuthenticatesRequestsWithOIDC() *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 RotateDispatcherTLSCertificate() *feature.Feature
func ServiceAccountSubjectAccessReviewAllowedOrFail(ctx context.Context, t feature.T, gvr schema.GroupVersionResource, ...)
func ShouldNotUpdateVersion(ctx context.Context, t feature.T)
func SingleEventWithEncoding(encoding binding.Encoding) *feature.Feature
func SubscriptionGoesReady(name string, cfg ...manifest.CfgFn) *feature.Feature
func SubscriptionTLS() *feature.Feature
func SubscriptionTLSTrustBundle() *feature.Feature
type EventingClient
- func Client(ctx context.Context) *EventingClient

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

Source Files ¶

View all Source files

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