testpipeline

Documentation

Overview

Package testpipeline exports small test pipelines for testing the vet runner. Shims must be generated for this package in order for tests to run correctly. These shims should be regenerated if changes are made to this package or to the shim generator.

Index

• func FunctionReg(s beam.Scope)
• func KvEmitFn(k string, v int, emit func(string, int))
• func KvFn(k string, v int) (string, int)
• func Performant(s beam.Scope)
• func ShimNeeded(s beam.Scope)
• func TypeReg(s beam.Scope)
• func VFloat64Fn(v float64) (string, int)
• func VFn(v int) (string, int)
• type SCombine
  • func (s *SCombine) MergeAccumulators(a, b int) int

Functions

func FunctionReg

func FunctionReg(s beam.Scope)

FunctionReg constructs a sub optimal pipeline that needs function registration.

func KvEmitFn

func KvEmitFn(k string, v int, emit func(string, int))

KvEmitFn is a do nothing example function with a k and v that uses an emit instead of a return.

func KvFn

func KvFn(k string, v int) (string, int)

KvFn is a do nothing example function with a k and v.

func Performant

func Performant(s beam.Scope)

Performant constructs a performant pipeline.

func ShimNeeded

func ShimNeeded(s beam.Scope)

ShimNeeded constructs a sub optimal pipeline that needs a function shim registration.

func TypeReg

func TypeReg(s beam.Scope)

TypeReg constructs a sub optimal pipeline that needs type registration.

func VFloat64Fn

func VFloat64Fn(v float64) (string, int)

VFloat64Fn is an unregistered function without type shims.

func VFn

func VFn(v int) (string, int)

VFn is a do nothing example function with a k and v.

Types

type SCombine

type SCombine struct{}

SCombine is a Do Nothing structural doFn to ensure that generating things for combinefn structs works.

func (*SCombine) MergeAccumulators

func (s *SCombine) MergeAccumulators(a, b int) int

MergeAccumulators lifecycle method.