postgres

type ColumnSchema struct {
	Name        string
	DataType    string
	TypePostfix string
	IsNullable  bool
}

type Conf struct {
	SchemaName string
	// applied per-table, and only for writing itself, without updating the schema
	WriteTimeout time.Duration

	// don't create any DB structure automatically
	// requires all the tables to be created beforehand, with exactly required fields
	SkipSchemaCreation bool

	LoadSchemaTimeout time.Duration
	// automatically created tables are declared as timescale hypertables
	UseTimescale bool
}

type Connection interface {
	ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
	QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
	BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
	// Close is called when the exporter no longer needs the connection
	Close() error
}

type Connector interface {
	GetConnection(ctx context.Context) (Connection, error)
	// Stop for cleanup, will be  called when tracer closes
	Stop(ctx context.Context) error
}

type ErrDescriptor struct {
	Table          string
	Span           *klogga.Span
	Column         ColumnSchema
	ExistingColumn ColumnSchema
}

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

type RecordSet struct {
	Schema *TableSchema
	Spans  []*klogga.Span
}

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