utils

type CancelFunction func() error

type CmdTransformerBase struct {
	Name                     string
	Cmd                      *exec.Cmd
	ExpectedExitCode         int
	Driver                   *toolkit.Driver
	Api                      toolkit.InteractionApi
	ProcessedLines           int
	RowTransformationTimeout time.Duration

	StdoutReader *bufio.Reader
	StderrReader *bufio.Reader
	StdinWriter  io.Writer
	Cancel       CancelFunction
	// contains filtered or unexported fields
}

type MetaKey string

type NewTransformerFunc func(ctx context.Context, driver *toolkit.Driver, parameters map[string]toolkit.Parameterizer) (
	Transformer, toolkit.ValidationWarnings, error,
)

type SchemaValidationFunc func(ctx context.Context, table *toolkit.Driver, properties *TransformerProperties, parameters map[string]*toolkit.StaticParameter) (toolkit.ValidationWarnings, error)

type Transformer interface {
	Init(ctx context.Context) error
	Done(ctx context.Context) error
	Transform(ctx context.Context, r *toolkit.Record) (*toolkit.Record, error)
	GetAffectedColumns() map[int]string
}

type TransformerContext struct {
	Transformer       Transformer
	StaticParameters  map[string]*toolkit.StaticParameter
	DynamicParameters map[string]*toolkit.DynamicParameter
	When              *toolkit.WhenCond
}

type TransformerDefinition struct {
	Properties      *TransformerProperties         `json:"properties"`
	New             NewTransformerFunc             `json:"-"`
	Parameters      []*toolkit.ParameterDefinition `json:"parameters"`
	SchemaValidator SchemaValidationFunc           `json:"-"`
}

type TransformerProperties struct {
	Name        string          `json:"name"`
	Description string          `json:"description"`
	IsCustom    bool            `json:"is_custom"`
	Meta        map[MetaKey]any `json:"meta"`
}

type TransformerRegistry struct {
	M map[string]*TransformerDefinition
}