observer

package
v0.18.4 Latest Latest
Warning

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

Go to latest
Published: Oct 30, 2020 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NoOpReply

func NoOpReply(_ context.Context, writer http.ResponseWriter, _ recordevents.EventInfo)

func ReplyTransformerFunc

func ReplyTransformerFunc(replyEventType string, replyEventSource string, replyEventData string, replyAppendData string) func(context.Context, http.ResponseWriter, recordevents.EventInfo)

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 NewFromEnv

func NewFromEnv(ctx context.Context, 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.

Jump to

Keyboard shortcuts

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