testing

Documentation

Index

• Constants
• 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, ...) *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 AssertEqualsKind = "assertEquals"

Types

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