receiver

Documentation

Index

• func NoOpReply(_ context.Context, writer http.ResponseWriter, _ eventshub.EventInfo)
• func ReplyTransformerFunc(replyEventType string, replyEventSource string, replyEventData string, ...) func(context.Context, http.ResponseWriter, eventshub.EventInfo)
• type Receiver
  • func NewFromEnv(ctx context.Context, eventLogs *eventshub.EventLogs) *Receiver
  • func (o *Receiver) ServeHTTP(writer http.ResponseWriter, request *http.Request)
  • func (o *Receiver) Start(ctx context.Context, handlerFuncs ...func(handler http.Handler) http.Handler) error

Functions

func NoOpReply

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

func ReplyTransformerFunc

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

Types

type Receiver

type Receiver struct {
	// Name is the name of this Receiver, used to filter if multiple observers.
	Name string
	// EventLogs is the list of EventLogger implementors to vent observed events.
	EventLogs *eventshub.EventLogs

	EnforceTLS bool
	// contains filtered or unexported fields
}

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

func NewFromEnv

func NewFromEnv(ctx context.Context, eventLogs *eventshub.EventLogs) *Receiver

func (*Receiver) ServeHTTP

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

func (*Receiver) Start

func (o *Receiver) 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.