database

Documentation

Index

• type ConnectionConfig
  • func (c ConnectionConfig) DSN() (string, error)
• type Database
• type DatabaseType

Types

type ConnectionConfig

type ConnectionConfig struct {
	DBType   DatabaseType
	Host     string
	Port     string
	Username string
	Password string
	Database string
}

func (ConnectionConfig) DSN

func (c ConnectionConfig) DSN() (string, error)

type Database

type Database interface {
	BatchWrite(ctx context.Context, tableName string, chunks []any) error
	Connection() any
}

type DatabaseType

type DatabaseType string

const (
	Postgres   DatabaseType = "POSTGRES"
	ClickHouse DatabaseType = "CLICKHOUSE"
	MySQL      DatabaseType = "MYSQL"
)