connect

func Athena ¶

func Athena(ctx context.Context, t *agentdwhv1.AthenaConf) (*scrapperathena.AthenaScrapper, error)

Athena builds an AthenaScrapper for the on-prem agent. AllowDefaultChain is true here so the agent host's instance role / env vars / shared config are usable when the customer leaves explicit auth fields empty. The cloud-side translator MUST construct AthenaConf without AllowDefaultChain so a misconfigured customer integration cannot inherit SYNQ's AWS identity.

func BigQuery ¶

func BigQuery(ctx context.Context, t *agentdwhv1.BigQueryConf) (*scrapperbigquery.BigQueryScrapper, error)

func Clickhouse ¶

func Clickhouse(ctx context.Context, t *agentdwhv1.ClickhouseConf) (*scrapperclickhouse.ClickhouseScrapper, error)

func Connect ¶ added in v0.1.6

func Connect(ctx context.Context, conf *agentdwhv1.Connection) (scrapper.Scrapper, error)

func Databricks ¶

func Databricks(ctx context.Context, t *agentdwhv1.DatabricksConf) (*scrapperdatabricks.DatabricksScrapper, error)

func DuckDB ¶ added in v0.12.0

func DuckDB(ctx context.Context, conf *agentdwhv1.DuckDBConf) (scrapper.Scrapper, error)

func MSSQL ¶ added in v0.12.0

func MSSQL(ctx context.Context, t *agentdwhv1.MSSQLConf) (*scrappermssql.MSSQLScrapper, error)

func MySQL ¶

func MySQL(ctx context.Context, t *agentdwhv1.MySQLConf) (*scrappermysql.MySQLScrapper, error)

func Oracle ¶ added in v0.12.0

func Oracle(ctx context.Context, t *agentdwhv1.OracleConf) (*scrapperoracle.OracleScrapper, error)

func Postgres ¶

func Postgres(ctx context.Context, t *agentdwhv1.PostgresConf) (*scrapperpostgres.PostgresScrapper, error)

func Redshift ¶

func Redshift(ctx context.Context, t *agentdwhv1.RedshiftConf) (*scrapperredshift.RedshiftScrapper, error)

func Snowflake ¶

func Snowflake(ctx context.Context, t *agentdwhv1.SnowflakeConf) (*scrappersnowflake.SnowflakeScrapper, error)

func Trino ¶ added in v0.4.3

func Trino(ctx context.Context, trino *agentdwhv1.TrinoConf) (scrapper.Scrapper, error)