package testing

import "github.com/influxdata/flux/stdlib/testing"

Index ¶

• Constants
• type AssertEmptyOpSpec
• func (s *AssertEmptyOpSpec) Kind() flux.OperationKind
• type AssertEmptyProcedureSpec
• func (s *AssertEmptyProcedureSpec) Copy() plan.ProcedureSpec
• func (s *AssertEmptyProcedureSpec) Kind() plan.ProcedureKind
• type AssertEmptyTransformation
• func NewAssertEmptyTransformation(d execute.Dataset, cache execute.TableBuilderCache) *AssertEmptyTransformation
• func (t *AssertEmptyTransformation) Finish(id execute.DatasetID, err error)
• func (t *AssertEmptyTransformation) Process(id execute.DatasetID, tbl flux.Table) error
• func (t *AssertEmptyTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error
• func (t *AssertEmptyTransformation) UpdateProcessingTime(id execute.DatasetID, mark execute.Time) error
• func (t *AssertEmptyTransformation) UpdateWatermark(id execute.DatasetID, mark execute.Time) error
• type AssertEqualsError
• func (e *AssertEqualsError) Assertion() bool
• func (e *AssertEqualsError) Error() string
• type AssertEqualsOpSpec
• func (s *AssertEqualsOpSpec) Kind() flux.OperationKind
• type AssertEqualsProcedureSpec
• func (s *AssertEqualsProcedureSpec) Copy() plan.ProcedureSpec
• func (s *AssertEqualsProcedureSpec) Kind() plan.ProcedureKind
• type AssertEqualsTransformation
• func NewAssertEqualsTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *AssertEqualsProcedureSpec, gotID, wantID execute.DatasetID, a memory.Allocator) *AssertEqualsTransformation
• func (t *AssertEqualsTransformation) Finish(id execute.DatasetID, err error)
• func (t *AssertEqualsTransformation) Process(id execute.DatasetID, tbl flux.Table) error
• func (t *AssertEqualsTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error
• func (t *AssertEqualsTransformation) UpdateProcessingTime(id execute.DatasetID, pt execute.Time) error
• func (t *AssertEqualsTransformation) UpdateWatermark(id execute.DatasetID, mark execute.Time) error

Constants ¶

const AssertEmptyKind = "assertEmpty"

const AssertEqualsKind = "assertEquals"

Types ¶

type AssertEmptyOpSpec ¶

type AssertEmptyOpSpec struct{}

func (*AssertEmptyOpSpec) Kind ¶

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

type AssertEmptyProcedureSpec ¶

type AssertEmptyProcedureSpec struct {
	plan.DefaultCost
}

func (*AssertEmptyProcedureSpec) Copy ¶

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

func (*AssertEmptyProcedureSpec) Kind ¶

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

type AssertEmptyTransformation ¶

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

func NewAssertEmptyTransformation ¶

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

func (*AssertEmptyTransformation) Finish ¶

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

func (*AssertEmptyTransformation) Process ¶

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

func (*AssertEmptyTransformation) RetractTable ¶

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

func (*AssertEmptyTransformation) UpdateProcessingTime ¶

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

func (*AssertEmptyTransformation) UpdateWatermark ¶

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 {
	execute.ExecutionNode
	// 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

Source Files ¶

assert_empty.go assert_equals.go

Directories ¶