testing

package
v0.34.2 Latest Latest
Warning

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

Go to latest
Published: Jun 27, 2019 License: MIT Imports: 13 Imported by: 1

Documentation

Index

Constants

View Source
const AssertEmptyKind = "assertEmpty"
View Source
const AssertEqualsKind = "assertEquals"
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 {
	// 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 {
	// 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"`
}

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
}

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 {
	// 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