forwarder

Documentation

Index

• type Forwarder
  • func NewFromEnv(ctx context.Context, eventLogs *eventshub.EventLogs, ...) *Forwarder
  • func (o *Forwarder) ServeHTTP(writer http.ResponseWriter, request *http.Request)
  • func (o *Forwarder) Start(ctx context.Context) error

Types

type Forwarder

type Forwarder struct {
	// Name is the name of this Forwarder.
	Name string

	// The current namespace.
	Namespace string `envconfig:"NAMESPACE" required:"true"`

	// Sink
	Sink string

	// EventLogs is the list of EventLogger implementors to vent observed events.
	EventLogs *eventshub.EventLogs
	// contains filtered or unexported fields
}

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

func NewFromEnv

func NewFromEnv(ctx context.Context, eventLogs *eventshub.EventLogs, handlerFuncs []eventshub.HandlerFunc, clientOpts []eventshub.ClientOption) *Forwarder

func (*Forwarder) ServeHTTP

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

func (*Forwarder) Start

func (o *Forwarder) Start(ctx context.Context) error

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