testpipeline

package
Version: v2.25.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 20, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

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

Constants

This section is empty.

Variables

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL