filter

Documentation

Index

• func NewAdapter(string) pkgadapter.AdapterConstructor
• func NewController(component string) pkgadapter.ControllerConstructor
• func NewEnvConfig() env.ConfigAccessor
• type Handler
  • func (h *Handler) ServeHTTP(writer http.ResponseWriter, request *http.Request)
  • func (h *Handler) Start(ctx context.Context) error
• type Reconciler
  • func (r *Reconciler) ReconcileKind(ctx context.Context, s *v1alpha1.Filter) reconciler.Event

Functions

func NewAdapter

func NewAdapter(string) pkgadapter.AdapterConstructor

NewAdapter returns a constructor for the source's adapter.

func NewController

func NewController(component string) pkgadapter.ControllerConstructor

NewController returns a constructor for the Router's Reconciler.

NOTE(antoineco): although the returned controller doesn't do anything, it is necessary to return a valid implementation in order to trigger the Informer injection in Knative's sharedmain.Main.

func NewEnvConfig

func NewEnvConfig() env.ConfigAccessor

NewEnvConfig satisfies env.ConfigConstructor.

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 (*Handler) ServeHTTP

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

func (*Handler) Start

func (h *Handler) Start(ctx context.Context) error

Start begins to receive messages for the handler.

HTTP POST requests to the root path (/) are accepted.

This method will block until ctx is done.

type Reconciler

type Reconciler struct{}

Reconciler implements controller.Reconciler for the event source type.

func (*Reconciler) ReconcileKind

func (r *Reconciler) ReconcileKind(ctx context.Context, s *v1alpha1.Filter) reconciler.Event

ReconcileKind implements reconcilerv1alpha1.Interface.