db

Documentation

Index

• type BigQuery
  • func (bq *BigQuery) Init(config map[string]interface{}) (err error)
  • func (bq *BigQuery) Run(ctx context.Context, query string) (result []byte, err error)
• type DB
  • func GetDb(name string) (DB, error)
• type PostgreSQL
  • func (psql *PostgreSQL) Init(config map[string]interface{}) (err error)
  • func (psql *PostgreSQL) Run(ctx context.Context, query string) (result []byte, err error)
• type SQLite
  • func (sqlt *SQLite) Init(config map[string]interface{}) (err error)
  • func (sqlt *SQLite) Run(ctx context.Context, query string) (result []byte, err error)

Types

type BigQuery

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

BigQuery DB

func (*BigQuery) Init

func (bq *BigQuery) Init(config map[string]interface{}) (err error)

Init DB interface implementation.

func (*BigQuery) Run

func (bq *BigQuery) Run(ctx context.Context, query string) (result []byte, err error)

Run DB interface implementation.

type DB

type DB interface {
	// Init makes the DB backend ready to query by create the connection, etc.
	Init(config map[string]interface{}) error
	// Run executes the query in the DB then returns with a JSON (byte slice) for the HTTP response or an error.
	Run(ctx context.Context, query string) (result []byte, err error)
}

DB interface defines that a database backend have to implement.

func GetDb

func GetDb(name string) (DB, error)

GetDb returns the DB with the given name or an error if not found.

type PostgreSQL

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

PostgreSQL struct

func (*PostgreSQL) Init

func (psql *PostgreSQL) Init(config map[string]interface{}) (err error)

Init DB interface implementation.

func (*PostgreSQL) Run

func (psql *PostgreSQL) Run(ctx context.Context, query string) (result []byte, err error)

Run DB interface implementation.

type SQLite

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

SQLite struct

func (*SQLite) Init

func (sqlt *SQLite) Init(config map[string]interface{}) (err error)

Init DB interface implementation.

func (*SQLite) Run

func (sqlt *SQLite) Run(ctx context.Context, query string) (result []byte, err error)

Run DB interface implementation.