processor

Documentation

Overview

Package processor contains several implementations of the batch.Processor interface.

Index

• type Error
  • func (p *Error) Process(ctx context.Context, ps *batch.PipelineStage)
• type Nil
  • func (p *Nil) Process(ctx context.Context, ps *batch.PipelineStage)

Types

type Error

type Error struct {
	Err error
}

Error returns a Processor that returns an error while processing.

func (*Error) Process

func (p *Error) Process(ctx context.Context, ps *batch.PipelineStage)

Process discards all data sent to it after a certain amount of time.

type Nil

type Nil struct {
	Duration time.Duration
}

Nil is a Processor that discards all data after a specified duration. It can be used as a mock Processor.

func (*Nil) Process

func (p *Nil) Process(ctx context.Context, ps *batch.PipelineStage)

Process discards all data sent to it after a certain amount of time.