Help us shape the future of Go! Take the 2026 Go Developer Survey

testing

package
v0.176.0 Latest Latest
Warning

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

Go to latest
Published: Jul 25, 2022 License: MIT Imports: 15 Imported by: 1

Documentation

Index

Constants

View Source
const AssertEmptyKind = "assertEmpty"
View Source
const AssertEqualsKind = "assertEquals"
View Source
const DefaultEpsilon = 1e-6
View Source
const DefaultNaNsEqual = false
View Source
const DiffKind = "diff"

Variables

This section is empty.

Functions

This section is empty.

Types

type AssertEmptyOpSpec added in v0.18.0

type AssertEmptyOpSpec struct{}

func (*AssertEmptyOpSpec) Kind added in v0.18.0

type AssertEmptyProcedureSpec added in v0.18.0

type AssertEmptyProcedureSpec struct {
	plan.DefaultCost
}

func (*AssertEmptyProcedureSpec) Copy added in v0.18.0

func (*AssertEmptyProcedureSpec) Kind added in v0.18.0

type AssertEmptyTransformation added in v0.18.0

type AssertEmptyTransformation struct {
	execute.ExecutionNode
	// contains filtered or unexported fields
}

func NewAssertEmptyTransformation added in v0.18.0

func NewAssertEmptyTransformation(d execute.Dataset, cache execute.TableBuilderCache) *AssertEmptyTransformation

func (*AssertEmptyTransformation) Finish added in v0.18.0

func (t *AssertEmptyTransformation) Finish(id execute.DatasetID, err error)

func (*AssertEmptyTransformation) Process added in v0.18.0

func (*AssertEmptyTransformation) RetractTable added in v0.18.0

func (t *AssertEmptyTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error

func (*AssertEmptyTransformation) UpdateProcessingTime added in v0.18.0

func (t *AssertEmptyTransformation) UpdateProcessingTime(id execute.DatasetID, mark execute.Time) error

func (*AssertEmptyTransformation) UpdateWatermark added in v0.18.0

func (t *AssertEmptyTransformation) UpdateWatermark(id execute.DatasetID, mark execute.Time) error

type AssertEqualsError

type AssertEqualsError struct {
	// contains filtered or unexported fields
}

func (*AssertEqualsError) Assertion

func (e *AssertEqualsError) Assertion() bool

func (*AssertEqualsError) Error

func (e *AssertEqualsError) Error() string

type AssertEqualsOpSpec

type AssertEqualsOpSpec struct {
	Name string `json:"name"`
}

func (*AssertEqualsOpSpec) Kind

type AssertEqualsProcedureSpec

type AssertEqualsProcedureSpec struct {
	plan.DefaultCost
	Name string
}

func (*AssertEqualsProcedureSpec) Copy

func (*AssertEqualsProcedureSpec) Kind

type AssertEqualsTransformation

type AssertEqualsTransformation struct {
	execute.ExecutionNode
	// contains filtered or unexported fields
}

func (*AssertEqualsTransformation) Finish

func (*AssertEqualsTransformation) Process

func (*AssertEqualsTransformation) RetractTable

func (*AssertEqualsTransformation) UpdateProcessingTime

func (t *AssertEqualsTransformation) UpdateProcessingTime(id execute.DatasetID, pt execute.Time) error

func (*AssertEqualsTransformation) UpdateWatermark

func (t *AssertEqualsTransformation) UpdateWatermark(id execute.DatasetID, mark execute.Time) error

type DiffOpSpec added in v0.18.0

type DiffOpSpec struct {
	Verbose   bool    `json:"verbose,omitempty"`
	Epsilon   float64 `json:"epsilon"`
	NaNsEqual bool    `json:"nansEqual,omitempty"`
}

func (*DiffOpSpec) Kind added in v0.18.0

func (s *DiffOpSpec) Kind() flux.OperationKind

type DiffProcedureSpec added in v0.18.0

type DiffProcedureSpec struct {
	plan.DefaultCost
	Verbose bool
	Epsilon float64
}

func (*DiffProcedureSpec) Copy added in v0.18.0

func (*DiffProcedureSpec) Kind added in v0.18.0

type DiffTransformation added in v0.18.0

type DiffTransformation struct {
	execute.ExecutionNode
	// contains filtered or unexported fields
}

func NewDiffTransformation added in v0.18.0

func NewDiffTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *DiffProcedureSpec, wantID, gotID execute.DatasetID, a memory.Allocator) *DiffTransformation

func (*DiffTransformation) Finish added in v0.18.0

func (t *DiffTransformation) Finish(id execute.DatasetID, err error)

func (*DiffTransformation) Process added in v0.18.0

func (t *DiffTransformation) Process(id execute.DatasetID, tbl flux.Table) error

func (*DiffTransformation) RetractTable added in v0.18.0

func (t *DiffTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error

func (*DiffTransformation) UpdateProcessingTime added in v0.18.0

func (t *DiffTransformation) UpdateProcessingTime(id execute.DatasetID, mark execute.Time) error

func (*DiffTransformation) UpdateWatermark added in v0.18.0

func (t *DiffTransformation) UpdateWatermark(id execute.DatasetID, mark execute.Time) error

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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