db

package
v3.2.5+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 27, 2021 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source
const Error1045 = "Access denied for user"
View Source
const Error3159 = "Error 3159:"

Variables

View Source
var (
	EmptyArgs  []interface{}
	ErrNoMatch = errors.New("no match")
)

Functions

func ExecOrchestrator

func ExecOrchestrator(query string, args ...interface{}) (sql.Result, error)

ExecOrchestrator will execute given query on the orchestrator backend database.

func IsSQLite

func IsSQLite() bool

func OpenDiscovery

func OpenDiscovery(host string, port int) (*sql.DB, error)

OpenDiscovery returns a DB instance to access a topology instance. It has lower read timeout than OpenTopology and is intended to be used with low-latency discovery queries.

func OpenOrchestrator

func OpenOrchestrator() (db *sql.DB, err error)

OpenTopology returns the DB instance for the orchestrator backed database

func OpenTopology

func OpenTopology(host string, port int) (*sql.DB, error)

OpenTopology returns a DB instance to access a topology instance.

func QueryOrchestrator

func QueryOrchestrator(query string, argsArray []interface{}, on_row func(sqlutils.RowMap) error) error

QueryOrchestrator

func QueryOrchestratorBuffered

func QueryOrchestratorBuffered(query string, argsArray []interface{}, on_row func(sqlutils.RowMap) error) error

QueryOrchestratorBuffered

func QueryOrchestratorRowsMap

func QueryOrchestratorRowsMap(query string, on_row func(sqlutils.RowMap) error) error

QueryRowsMapOrchestrator

func QueryOrchestratorRowsMapBuffered

func QueryOrchestratorRowsMapBuffered(query string, on_row func(sqlutils.RowMap) error) error

QueryOrchestratorRowsMapBuffered

func ReadTimeNow

func ReadTimeNow() (timeNow string, err error)

ReadTimeNow reads and returns the current timestamp as string. This is an unfortunate workaround to support both MySQL and SQLite in all possible timezones. SQLite only speaks UTC where MySQL has timezone support. By reading the time as string we get the database's de-facto notion of the time, which we can then feed back to it.

func SetupMySQLOrchestratorTLS

func SetupMySQLOrchestratorTLS(uri string) (string, error)

Create a TLS configuration from the config supplied CA, Certificate, and Private key. Register the TLS config with the mysql drivers as the "orchestrator" config Modify the supplied URI to call the TLS config

func SetupMySQLTopologyTLS

func SetupMySQLTopologyTLS(uri string) (string, error)

Create a TLS configuration from the config supplied CA, Certificate, and Private key. Register the TLS config with the mysql drivers as the "topology" config Modify the supplied URI to call the TLS config

Types

type DummySqlResult

type DummySqlResult struct {
}

func (DummySqlResult) LastInsertId

func (this DummySqlResult) LastInsertId() (int64, error)

func (DummySqlResult) RowsAffected

func (this DummySqlResult) RowsAffected() (int64, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL