connectors

Documentation

Index

• func NewClickhouseDbqConnector(cnn driver.Conn, logger *slog.Logger) dbqcore.DbqConnector
• func NewMysqlDbqConnector(db *sql.DB, logger *slog.Logger) dbqcore.DbqConnector
• func NewPostgresqlDbqConnector(db *sql.DB, logger *slog.Logger) dbqcore.DbqConnector
• type ClickhouseDbqConnector
  • func (c *ClickhouseDbqConnector) ImportDatasets(ctx context.Context, filter string) ([]string, error)
  • func (c *ClickhouseDbqConnector) Ping(ctx context.Context) (string, error)
• type MysqlDbqConnector
  • func (c *MysqlDbqConnector) ImportDatasets(ctx context.Context, filter string) ([]string, error)
  • func (c *MysqlDbqConnector) Ping(ctx context.Context) (string, error)
• type PostgresqlDbqConnector
  • func (c *PostgresqlDbqConnector) ImportDatasets(ctx context.Context, filter string) ([]string, error)
  • func (c *PostgresqlDbqConnector) Ping(ctx context.Context) (string, error)

Functions

func NewClickhouseDbqConnector

func NewClickhouseDbqConnector(cnn driver.Conn, logger *slog.Logger) dbqcore.DbqConnector

func NewMysqlDbqConnector

func NewMysqlDbqConnector(db *sql.DB, logger *slog.Logger) dbqcore.DbqConnector

func NewPostgresqlDbqConnector

func NewPostgresqlDbqConnector(db *sql.DB, logger *slog.Logger) dbqcore.DbqConnector

Types

type ClickhouseDbqConnector

type ClickhouseDbqConnector struct {
	// contains filtered or unexported fields
}

func (*ClickhouseDbqConnector) ImportDatasets

func (c *ClickhouseDbqConnector) ImportDatasets(ctx context.Context, filter string) ([]string, error)

func (*ClickhouseDbqConnector) Ping

func (c *ClickhouseDbqConnector) Ping(ctx context.Context) (string, error)

type MysqlDbqConnector

type MysqlDbqConnector struct {
	// contains filtered or unexported fields
}

func (*MysqlDbqConnector) ImportDatasets

func (c *MysqlDbqConnector) ImportDatasets(ctx context.Context, filter string) ([]string, error)

func (*MysqlDbqConnector) Ping

func (c *MysqlDbqConnector) Ping(ctx context.Context) (string, error)

type PostgresqlDbqConnector

type PostgresqlDbqConnector struct {
	// contains filtered or unexported fields
}

func (*PostgresqlDbqConnector) ImportDatasets

func (c *PostgresqlDbqConnector) ImportDatasets(ctx context.Context, filter string) ([]string, error)

func (*PostgresqlDbqConnector) Ping

func (c *PostgresqlDbqConnector) Ping(ctx context.Context) (string, error)