observer

package

v0.18.2 Latest Latest Go to latest Published: Oct 9, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/knative/eventing

Links

Open Source Insights

Documentation ¶

Index ¶

type Observer
- func New(name string, eventLogs ...recordevents.EventLog) *Observer
- func NewFromEnv(eventLogs ...recordevents.EventLog) *Observer
- func (o *Observer) ServeHTTP(writer http.ResponseWriter, request *http.Request)
- func (o *Observer) Start(ctx context.Context, handlerFuncs ...func(handler http.Handler) http.Handler) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Observer ¶

type Observer struct {
	// Name is the name of this Observer, used to filter if multiple observers.
	Name string
	// EventLogs is the list of EventLog implementors to vent observed events.
	EventLogs recordevents.EventLogs
	// contains filtered or unexported fields
}

Observer is the entry point for sinking events into the event log.

func New ¶ added in v0.18.2

func New(name string, eventLogs ...recordevents.EventLog) *Observer

New returns an observer that will vent observations to the list of provided EventLog instances. It will listen on :8080.

func NewFromEnv ¶

func NewFromEnv(eventLogs ...recordevents.EventLog) *Observer

func (*Observer) ServeHTTP ¶

func (o *Observer) ServeHTTP(writer http.ResponseWriter, request *http.Request)

func (*Observer) Start ¶

func (o *Observer) Start(ctx context.Context, handlerFuncs ...func(handler http.Handler) http.Handler) error

Start will create the CloudEvents client and start listening for inbound HTTP requests. This is a is a blocking call.

Source Files ¶

View all Source files

observer.go

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