testing

package
v0.195.1 Latest Latest
Warning

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

Go to latest
Published: Jun 7, 2024 License: MIT Imports: 9 Imported by: 1

Documentation

Index

Constants

View Source
const AssertEmptyKind = "assertEmpty"
View Source
const AssertEqualsKind = "assertEquals"

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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