Documentation
¶
Index ¶
Constants ¶
View Source
const ( FilterAudience = "mt-broker-filter" ScopeName = "knative.dev/pkg/broker/filter" )
Variables ¶
This section is empty.
Functions ¶
func NewServerManager ¶ added in v0.38.0
func NewServerManager( ctx context.Context, logger *zap.Logger, cmw configmap.Watcher, httpPort, httpsPort int, meterProvider metric.MeterProvider, traceProvider trace.TracerProvider, handler *Handler, ) (*eventingtls.ServerManager, error)
Types ¶
type Handler ¶
type Handler struct {
EventTypeCreator *eventtype.EventTypeAutoHandler
// contains filtered or unexported fields
}
Handler parses Cloud Events, determines if they pass a filter, and sends them to a subscriber.
func NewHandler ¶
func NewHandler( logger *zap.Logger, tokenVerifier *auth.Verifier, oidcTokenProvider *auth.OIDCTokenProvider, triggerInformer v1.TriggerInformer, brokerInformer v1.BrokerInformer, subscriptionInformer messaginginformers.SubscriptionInformer, trustBundleConfigMapLister corev1listers.ConfigMapNamespaceLister, wc func(ctx context.Context) context.Context, meterProvider metric.MeterProvider, traceProvider trace.TracerProvider, ) (*Handler, error)
NewHandler creates a new Handler and its associated EventReceiver.
Source Files
Click to show internal directories.
Click to hide internal directories.