sink

type Clickhouse interface {
	Sink

	GetAddress() string

	GetPassword() string

	GetDatabase() string

	GetMigrationEngine() string

	GetMigrationsPathClickhouse() string

	GetMaxExecutionTime() string
}

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

	Address string `pkl:"address"`

	Password string `pkl:"password"`

	Database string `pkl:"database"`

	MigrationEngine string `pkl:"migrationEngine"`

	MigrationsPathClickhouse string `pkl:"migrationsPathClickhouse"`

	MaxExecutionTime string `pkl:"maxExecutionTime"`

	Name string `pkl:"name"`

	Inputs []string `pkl:"inputs"`

	Threads int `pkl:"threads"`
}

type Console interface {
	Sink
}

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

	Name string `pkl:"name"`

	Inputs []string `pkl:"inputs"`

	Threads int `pkl:"threads"`
}

type Sink interface {
	GetName() string

	GetSourceName() string

	GetInputs() []string

	GetThreads() int
}

type Sinks struct {
}