splitter

package
v1.27.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 17, 2023 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewAdapter

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.Splitter) reconciler.Event

ReconcileKind implements reconcilerv1alpha1.Interface.

Jump to

Keyboard shortcuts

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