testing

package
v0.58.0 Latest Latest
Warning

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

 Go to latest Published: Jan 6, 2020 License: MIT Imports: 14 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 

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

type AssertEmptyProcedureSpec added in v0.18.0 

type AssertEmptyProcedureSpec struct {
	plan.DefaultCost
}

func (*AssertEmptyProcedureSpec) Copy added in v0.18.0 

func (s *AssertEmptyProcedureSpec) Copy() plan.ProcedureSpec

func (*AssertEmptyProcedureSpec) Kind added in v0.18.0 

func (s *AssertEmptyProcedureSpec) Kind() plan.ProcedureKind

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 (t *AssertEmptyTransformation) Process(id execute.DatasetID, tbl flux.Table) error

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 

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

type AssertEqualsProcedureSpec 

type AssertEqualsProcedureSpec struct {
	plan.DefaultCost
	Name string
}

func (*AssertEqualsProcedureSpec) Copy 

func (s *AssertEqualsProcedureSpec) Copy() plan.ProcedureSpec

func (*AssertEqualsProcedureSpec) Kind 

func (s *AssertEqualsProcedureSpec) Kind() plan.ProcedureKind

type AssertEqualsTransformation 

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

func NewAssertEqualsTransformation 

func NewAssertEqualsTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *AssertEqualsProcedureSpec, gotID, wantID execute.DatasetID, a *memory.Allocator) *AssertEqualsTransformation

func (*AssertEqualsTransformation) Finish 

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

func (*AssertEqualsTransformation) Process 

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

func (*AssertEqualsTransformation) RetractTable 

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

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 (s *DiffProcedureSpec) Copy() plan.ProcedureSpec

func (*DiffProcedureSpec) Kind added in v0.18.0 

func (s *DiffProcedureSpec) Kind() plan.ProcedureKind

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.