deliver

Documentation

Index

• type Processor
  • func (p *Processor) Process(ctx context.Context, e *event.Event) error

Types

type Processor

type Processor struct {
	processors.BaseProcessor

	// DeliverClient is the cloudevents client to send events.
	DeliverClient *http.Client

	// Targets is the targets from config.
	Targets config.ReadonlyTargets

	// RetryOnFailure if set to true, the processor will send the event
	// to the retry topic if the delivery fails.
	RetryOnFailure bool

	// DeliverRetryClient is the cloudevents client to send events
	// to the retry topic.
	DeliverRetryClient ceclient.Client

	// DeliverTimeout is the timeout applied to cancel delivery.
	// If zero, not additional timeout is applied.
	DeliverTimeout time.Duration

	// StatsReporter is used to report delivery metrics.
	StatsReporter *metrics.DeliveryReporter
}

Processor delivers events based on the broker/target in the context.

func (*Processor) Process

func (p *Processor) Process(ctx context.Context, e *event.Event) error

Process delivers the event based on the broker/target in the context.