db

Documentation

Index

• Variables
• func ExecOrchestrator(query string, args ...interface{}) (sql.Result, error)
• func OpenDiscovery(host string, port int) (*sql.DB, error)
• func OpenOrchestrator() (db *sql.DB, err error)
• func OpenTopology(host string, port int) (*sql.DB, error)
• func QueryOrchestrator(query string, argsArray []interface{}, on_row func(sqlutils.RowMap) error) error
• func QueryOrchestratorBuffered(query string, argsArray []interface{}, on_row func(sqlutils.RowMap) error) error
• func QueryOrchestratorRowsMap(query string, on_row func(sqlutils.RowMap) error) error
• func QueryOrchestratorRowsMapBuffered(query string, on_row func(sqlutils.RowMap) error) error
• func SetupMySQLOrchestratorTLS(uri string) (string, error)
• func SetupMySQLTopologyTLS(uri string) (string, error)
• type DummySqlResult
  • func (this DummySqlResult) LastInsertId() (int64, error)
  • func (this DummySqlResult) RowsAffected() (int64, error)

Variables

var (
	EmptyArgs []interface{}
)

Functions

func ExecOrchestrator

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

ExecOrchestrator will execute given query on the orchestrator backend database.

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 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 TODO: Way to have password mixed with TLS for various nodes in the topology. Currently everything is TLS or everything is password

Types

type DummySqlResult

type DummySqlResult struct {
}

func (DummySqlResult) LastInsertId

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

func (DummySqlResult) RowsAffected

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