channel

package

v0.43.2 Latest Latest Go to latest Published: Nov 19, 2024 License: Apache-2.0 Imports: 53 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
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 ChannelChainAssert(f *feature.Feature, sink, channel string)
func ChannelChainSetup(f *feature.Feature, length int, ...) (sink string, channel string)
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 ChannelChainAssert ¶ added in v0.43.0

func ChannelChainAssert(f *feature.Feature, sink, channel string)

func ChannelChainSetup ¶ added in v0.43.0

func ChannelChainSetup(f *feature.Feature, length int, createSubscriberFn func(ref *duckv1.KReference, uri string) manifest.CfgFn) (sink string, channel string)

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