transform

package
v1.3.4 Latest Latest
Warning

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

 Go to latest Published: Nov 13, 2025 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Overview

Code generated from Pkl module `com.pipelaner.source.transforms`. DO NOT EDIT.

Code generated from Pkl module `com.pipelaner.source.transforms`. DO NOT EDIT.

Code generated from Pkl module `com.pipelaner.source.transforms`. DO NOT EDIT.

Code generated from Pkl module `com.pipelaner.source.transforms`. DO NOT EDIT.

Code generated from Pkl module `com.pipelaner.source.transforms`. DO NOT EDIT.

Code generated from Pkl module `com.pipelaner.source.transforms`. DO NOT EDIT.

Code generated from Pkl module `com.pipelaner.source.transforms`. DO NOT EDIT.

Code generated from Pkl module `com.pipelaner.source.transforms`. DO NOT EDIT.

Code generated from Pkl module `com.pipelaner.source.transforms`. DO NOT EDIT.

Code generated from Pkl module `com.pipelaner.source.transforms`. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Batch 

type Batch interface {
	Transform

	GetSize() uint
}

type BatchImpl 

type BatchImpl struct {
	SourceName string `pkl:"sourceName"`

	Size uint `pkl:"size"`

	Name string `pkl:"name"`

	Inputs []string `pkl:"inputs"`

	Threads uint `pkl:"threads"`

	OutputBufferSize uint `pkl:"outputBufferSize"`
}

func (BatchImpl) GetInputs 

func (rcv BatchImpl) GetInputs() []string

func (BatchImpl) GetName 

func (rcv BatchImpl) GetName() string

func (BatchImpl) GetOutputBufferSize 

func (rcv BatchImpl) GetOutputBufferSize() uint

func (BatchImpl) GetSize 

func (rcv BatchImpl) GetSize() uint

func (BatchImpl) GetSourceName 

func (rcv BatchImpl) GetSourceName() string

func (BatchImpl) GetThreads 

func (rcv BatchImpl) GetThreads() uint

type Chunk 

type Chunk interface {
	Transform

	GetMaxChunkSize() uint

	GetMaxIdleTime() pkl.Duration

	GetFlushTimerStrategy() flushtimerstrategy.FlushTimerStrategy
}

type ChunkImpl 

type ChunkImpl struct {
	SourceName string `pkl:"sourceName"`

	MaxChunkSize uint `pkl:"maxChunkSize"`

	MaxIdleTime pkl.Duration `pkl:"maxIdleTime"`

	FlushTimerStrategy flushtimerstrategy.FlushTimerStrategy `pkl:"flushTimerStrategy"`

	Name string `pkl:"name"`

	Inputs []string `pkl:"inputs"`

	Threads uint `pkl:"threads"`

	OutputBufferSize uint `pkl:"outputBufferSize"`
}

func (ChunkImpl) GetFlushTimerStrategy added in v1.3.4 

func (rcv ChunkImpl) GetFlushTimerStrategy() flushtimerstrategy.FlushTimerStrategy

func (ChunkImpl) GetInputs 

func (rcv ChunkImpl) GetInputs() []string

func (ChunkImpl) GetMaxChunkSize 

func (rcv ChunkImpl) GetMaxChunkSize() uint

func (ChunkImpl) GetMaxIdleTime 

func (rcv ChunkImpl) GetMaxIdleTime() pkl.Duration

func (ChunkImpl) GetName 

func (rcv ChunkImpl) GetName() string

func (ChunkImpl) GetOutputBufferSize 

func (rcv ChunkImpl) GetOutputBufferSize() uint

func (ChunkImpl) GetSourceName 

func (rcv ChunkImpl) GetSourceName() string

func (ChunkImpl) GetThreads 

func (rcv ChunkImpl) GetThreads() uint

type Debounce 

type Debounce interface {
	Transform

	GetInterval() pkl.Duration
}

type DebounceImpl 

type DebounceImpl struct {
	SourceName string `pkl:"sourceName"`

	Interval pkl.Duration `pkl:"interval"`

	Name string `pkl:"name"`

	Inputs []string `pkl:"inputs"`

	Threads uint `pkl:"threads"`

	OutputBufferSize uint `pkl:"outputBufferSize"`
}

func (DebounceImpl) GetInputs 

func (rcv DebounceImpl) GetInputs() []string

func (DebounceImpl) GetInterval 

func (rcv DebounceImpl) GetInterval() pkl.Duration

func (DebounceImpl) GetName 

func (rcv DebounceImpl) GetName() string

func (DebounceImpl) GetOutputBufferSize 

func (rcv DebounceImpl) GetOutputBufferSize() uint

func (DebounceImpl) GetSourceName 

func (rcv DebounceImpl) GetSourceName() string

func (DebounceImpl) GetThreads 

func (rcv DebounceImpl) GetThreads() uint

type Filter 

type Filter interface {
	Transform

	GetCode() string
}

type FilterImpl 

type FilterImpl struct {
	SourceName string `pkl:"sourceName"`

	Code string `pkl:"code"`

	Name string `pkl:"name"`

	Inputs []string `pkl:"inputs"`

	Threads uint `pkl:"threads"`

	OutputBufferSize uint `pkl:"outputBufferSize"`
}

func (FilterImpl) GetCode 

func (rcv FilterImpl) GetCode() string

func (FilterImpl) GetInputs 

func (rcv FilterImpl) GetInputs() []string

func (FilterImpl) GetName 

func (rcv FilterImpl) GetName() string

func (FilterImpl) GetOutputBufferSize 

func (rcv FilterImpl) GetOutputBufferSize() uint

func (FilterImpl) GetSourceName 

func (rcv FilterImpl) GetSourceName() string

func (FilterImpl) GetThreads 

func (rcv FilterImpl) GetThreads() uint

type Remap 

type Remap interface {
	Transform

	GetCode() string
}

type RemapImpl 

type RemapImpl struct {
	SourceName string `pkl:"sourceName"`

	Code string `pkl:"code"`

	Name string `pkl:"name"`

	Inputs []string `pkl:"inputs"`

	Threads uint `pkl:"threads"`

	OutputBufferSize uint `pkl:"outputBufferSize"`
}

func (RemapImpl) GetCode 

func (rcv RemapImpl) GetCode() string

func (RemapImpl) GetInputs 

func (rcv RemapImpl) GetInputs() []string

func (RemapImpl) GetName 

func (rcv RemapImpl) GetName() string

func (RemapImpl) GetOutputBufferSize 

func (rcv RemapImpl) GetOutputBufferSize() uint

func (RemapImpl) GetSourceName 

func (rcv RemapImpl) GetSourceName() string

func (RemapImpl) GetThreads 

func (rcv RemapImpl) GetThreads() uint

type Sequencer added in v1.2.0 

type Sequencer interface {
	Transform

	GetIsSequencer() bool
}

type SequencerImpl added in v1.2.0 

type SequencerImpl struct {
	SourceName string `pkl:"sourceName"`

	IsSequencer bool `pkl:"isSequencer"`

	Name string `pkl:"name"`

	Inputs []string `pkl:"inputs"`

	Threads uint `pkl:"threads"`

	OutputBufferSize uint `pkl:"outputBufferSize"`
}

func (SequencerImpl) GetInputs added in v1.2.0 

func (rcv SequencerImpl) GetInputs() []string

func (SequencerImpl) GetIsSequencer added in v1.2.0 

func (rcv SequencerImpl) GetIsSequencer() bool

func (SequencerImpl) GetName added in v1.2.0 

func (rcv SequencerImpl) GetName() string

func (SequencerImpl) GetOutputBufferSize added in v1.2.0 

func (rcv SequencerImpl) GetOutputBufferSize() uint

func (SequencerImpl) GetSourceName added in v1.2.0 

func (rcv SequencerImpl) GetSourceName() string

func (SequencerImpl) GetThreads added in v1.2.0 

func (rcv SequencerImpl) GetThreads() uint

type Throttling 

type Throttling interface {
	Transform

	GetInterval() pkl.Duration
}

type ThrottlingImpl 

type ThrottlingImpl struct {
	SourceName string `pkl:"sourceName"`

	Interval pkl.Duration `pkl:"interval"`

	Name string `pkl:"name"`

	Inputs []string `pkl:"inputs"`

	Threads uint `pkl:"threads"`

	OutputBufferSize uint `pkl:"outputBufferSize"`
}

func (ThrottlingImpl) GetInputs 

func (rcv ThrottlingImpl) GetInputs() []string

func (ThrottlingImpl) GetInterval 

func (rcv ThrottlingImpl) GetInterval() pkl.Duration

func (ThrottlingImpl) GetName 

func (rcv ThrottlingImpl) GetName() string

func (ThrottlingImpl) GetOutputBufferSize 

func (rcv ThrottlingImpl) GetOutputBufferSize() uint

func (ThrottlingImpl) GetSourceName 

func (rcv ThrottlingImpl) GetSourceName() string

func (ThrottlingImpl) GetThreads 

func (rcv ThrottlingImpl) GetThreads() uint

type Transform 

type Transform interface {
	GetName() string

	GetSourceName() string

	GetInputs() []string

	GetThreads() uint

	GetOutputBufferSize() uint
}

type Transforms 

type Transforms struct {
}

func Load 

func Load(ctx context.Context, evaluator pkl.Evaluator, source *pkl.ModuleSource) (Transforms, error)

Load loads the pkl module at the given source and evaluates it with the given evaluator into a Transforms

func LoadFromPath 

func LoadFromPath(ctx context.Context, path string) (ret Transforms, err error)

LoadFromPath loads the pkl module at the given path and evaluates it into a Transforms

Source Files

View all Source files

Directories

Path Synopsis
Code generated from Pkl module `com.pipelaner.source.transforms`.
 Code generated from Pkl module `com.pipelaner.source.transforms`.

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.