sources

Documentation

Index

• type EventForwarder
  • func NewEventForwarder(target string) *EventForwarder
  • func (p *EventForwarder) PostEvent(ctx cloudevents.EventContext, message []byte) error

Types

type EventForwarder

type EventForwarder struct {
	// contains filtered or unexported fields
}

EventForwarder is a wrapper for an HTTP client in the context of sending events safely in a durable manner.

func NewEventForwarder

func NewEventForwarder(target string) *EventForwarder

NewEventForwarder creates a wrapped HTTP client, that can be used to safely send events to a sink, correctly handling enveloping the event and handling possible error scenarios.

func (*EventForwarder) PostEvent

func (p *EventForwarder) PostEvent(ctx cloudevents.EventContext, message []byte) error

PostEvent sends the event to the defined sink.