tests

package

v0.0.3 Latest Latest Go to latest Published: Dec 6, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func (i *IntGenerator) Generate(ctx *pipelaner.Context, input chan<- any)

func (i *IntGenerator) Init(_ *pipelaner.Context) error

type IntStruct struct {
	Counter uint64
}

type IntTransform struct {
}

func (i *IntTransform) Init(_ *pipelaner.Context) error

func (i *IntTransform) Map(_ *pipelaner.Context, val any) any

func (i *IntTransform) New() pipelaner.Map

type IntTransformEmpty struct {
}

func (i *IntTransformEmpty) Init(_ *pipelaner.Context) error

func (i *IntTransformEmpty) Map(_ *pipelaner.Context, val any) any

func (i *IntTransformEmpty) New() pipelaner.Map

type IntTwoGenerator struct {
}

func (i *IntTwoGenerator) Generate(ctx *pipelaner.Context, input chan<- any)

func (i *IntTwoGenerator) Init(_ *pipelaner.Context) error

type MapGenerator struct {
}

func (i *MapGenerator) Generate(ctx *pipelaner.Context, input chan<- any)

func (i *MapGenerator) Init(_ *pipelaner.Context) error