filter

Documentation

Index

• func NewServerManager(ctx context.Context, logger *zap.Logger, cmw configmap.Watcher, ...) (*eventingtls.ServerManager, error)
• type Handler
  • func NewHandler(logger *zap.Logger, oidcTokenProvider *auth.OIDCTokenProvider, ...) (*Handler, error)
  • func (h *Handler) ServeHTTP(writer http.ResponseWriter, request *http.Request)
• type ReportArgs
• type StatsReporter
  • func NewStatsReporter(container, uniqueName string) StatsReporter

Functions

func NewServerManager

func NewServerManager(ctx context.Context, logger *zap.Logger, cmw configmap.Watcher, httpPort, httpsPort int, handler *Handler) (*eventingtls.ServerManager, error)

Types

type Handler

type Handler struct {
	// 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, oidcTokenProvider *auth.OIDCTokenProvider, triggerInformer v1.TriggerInformer, reporter StatsReporter, wc func(ctx context.Context) context.Context) (*Handler, error)

NewHandler creates a new Handler and its associated EventReceiver.

func (*Handler) ServeHTTP

func (h *Handler) ServeHTTP(writer http.ResponseWriter, request *http.Request)

1. validate request 2. extract event from request 3. get trigger from its trigger reference extracted from the request URI 4. filter event 5. send event to trigger's subscriber 6. write the response

type ReportArgs

type ReportArgs struct {
	// contains filtered or unexported fields
}

type StatsReporter

type StatsReporter interface {
	ReportEventCount(args *ReportArgs, responseCode int) error
	ReportEventDispatchTime(args *ReportArgs, responseCode int, d time.Duration) error
	ReportEventProcessingTime(args *ReportArgs, d time.Duration) error
}

StatsReporter defines the interface for sending filter metrics.

func NewStatsReporter

func NewStatsReporter(container, uniqueName string) StatsReporter

NewStatsReporter creates a reporter that collects and reports filter metrics.