backends

Documentation

Overview

Package backends provides interfaces to write backends for SQL Jobber that take and store results from executed SQL jobs.

Index

• type Opt
• type ResultBackend
  • func NewSQLBackend(db *sql.DB, opt Opt, l *log.Logger) (ResultBackend, error)
• type ResultSet

Types

type Opt

type Opt struct {
	DBType         string
	ResultsTable   string
	UnloggedTables bool
}

Opt represents SQL DB backend's options.

type ResultBackend

type ResultBackend interface {
	NewResultSet(dbName, taskName string, ttl time.Duration) (ResultSet, error)
}

ResultBackend represents a result backend to which results from an executed SQL job are written.

func NewSQLBackend

func NewSQLBackend(db *sql.DB, opt Opt, l *log.Logger) (ResultBackend, error)

NewSQLBackend returns a new sqlDB result backend instance. It accepts an *sql.DB connection

type ResultSet

type ResultSet interface {
	RegisterColTypes([]string, []*sql.ColumnType) error
	IsColTypesRegistered() bool
	WriteCols([]string) error
	WriteRow([]interface{}) error
	Flush() error
	Close() error
}

ResultSet represents the set of results from an individual job that's executed.