db

Documentation

Index

• Variables
• func ExecOrchestrator(query string, args ...interface{}) (sql.Result, error)
• func OpenOrchestrator() (*sql.DB, 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 ResetInternalDeployment() 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 OpenOrchestrator

func OpenOrchestrator() (*sql.DB, 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 ResetInternalDeployment

func ResetInternalDeployment() error

ResetInternalDeployment will clear existing deployment history (and the effect will be a complete re-deployment the next run). This is made available for possible operational errors, a red button

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)