Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ViewConfig = map[string]struct { Type any Display string }{ "duckdb": { Type: duckdb.DuckDBServer{}, Display: "DuckDB", }, "redshift": { Type: redshift.RedshiftServer{}, Display: "Redshift", }, "bigquery": { Type: bigquery.BigQueryServer{}, Display: "BigQuery", }, "clickhouse": { Type: clickhouse.ClickhouseServer{}, Display: "Clickhouse", }, "postgres": { Type: postgres.PostgresServer{}, Display: "PostgreSQL", }, }
Functions ¶
This section is empty.
Types ¶
type Destination ¶ added in v1.0.3
type Destination interface {
QueryNDJson(query string, writer io.Writer) error
QueryJSON(query string, writer io.Writer) error
QueryCSV(query string, writer io.Writer) error
Tables() ([]string, error)
Columns(table string) ([]models.Column, error)
CreateEmptyTable(name string) error
CreateColumns(table string, filePath string) error
InsertFromNDJsonFile(table string, filePath string) error
Close() error
}
type DestinationManager ¶ added in v1.0.3
type DestinationManager struct {
// contains filtered or unexported fields
}
func NewDestinationManager ¶ added in v1.0.3
func NewDestinationManager(storage *storage.Services) *DestinationManager
func (*DestinationManager) CloseAll ¶ added in v1.0.3
func (m *DestinationManager) CloseAll()
func (*DestinationManager) Destination ¶ added in v1.0.3
func (m *DestinationManager) Destination(ctx context.Context, databaseID int64) (Destination, error)
func (*DestinationManager) TestCredentials ¶ added in v1.0.8
func (m *DestinationManager) TestCredentials(creds config.Destination) error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.