transform

type Batch interface {
	Transform

	GetSize() uint
}

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"`
}

type Chunk interface {
	Transform

	GetMaxChunkSize() uint

	GetMaxIdleTime() *pkl.Duration
}

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

	MaxChunkSize uint `pkl:"maxChunkSize"`

	MaxIdleTime *pkl.Duration `pkl:"maxIdleTime"`

	Name string `pkl:"name"`

	Inputs []string `pkl:"inputs"`

	Threads uint `pkl:"threads"`

	OutputBufferSize uint `pkl:"outputBufferSize"`
}

type Debounce interface {
	Transform

	GetInterval() *pkl.Duration
}

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"`
}

type Filter interface {
	Transform

	GetCode() string
}

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"`
}

type Remap interface {
	Transform

	GetCode() string
}

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"`
}

type Throttling interface {
	Transform

	GetInterval() *pkl.Duration
}

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"`
}

type Transform interface {
	GetName() string

	GetSourceName() string

	GetInputs() []string

	GetThreads() uint

	GetOutputBufferSize() uint
}

type Transforms struct {
}