fanout

Documentation

Index

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

Types

type Processor

type Processor struct {
	processors.BaseProcessor

	// MaxConcurrency is the max number of goroutine it will spawn
	// for each event.
	MaxConcurrency int

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

Processor fanouts an event based on the broker key in the context.

func (*Processor) Process

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

Process fanouts the given event.