Documentation
¶
Index ¶
- func CreateTlsConfig(minVersion uint16, rootCAs *string, host string, tlsHost string, ...) (*tls.Config, error)
- func CreateTlsConfigFromRootCAString(minVersion uint16, rootCAs string, host string, tlsHost string, ...) (*tls.Config, error)
- func HeartbeatRoutine(ctx context.Context, message func() string) func()
- func Interval(ctx context.Context, freq time.Duration, fn func()) func()
- func QuoteIdentifier(name string) string
- type QualifiedTable
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateTlsConfig ¶
func CreateTlsConfigFromRootCAString ¶
func CreateTlsConfigFromRootCAString(minVersion uint16, rootCAs string, host string, tlsHost string, skipCertVerification bool) (*tls.Config, error)
CreateTlsConfigFromRootCAString adapts CreateTlsConfig for callers that pass rootCAs as a string rather than *string (e.g. mongo ClientConfig). Empty string is treated as no custom CA.
func HeartbeatRoutine ¶
func QuoteIdentifier ¶
QuoteIdentifier quotes an "identifier" (e.g. a table or a column name) to be used as part of an SQL statement. For example:
tblname := "my_table"
data := "my_data"
quoted := common.QuoteIdentifier(tblname)
err := db.Exec(fmt.Sprintf("INSERT INTO %s VALUES ($1)", quoted), data)
Any double quotes in name will be escaped. The quoted identifier will be case-sensitive when used in a query. If the input string contains a zero byte, the result will be truncated immediately before it.
Types ¶
type QualifiedTable ¶
type QualifiedTable struct {
Namespace string // schema in PG, database in MySQL/Mongo
Table string // table or collection
}
func ParseTableIdentifier ¶
func ParseTableIdentifier(tableIdentifier string) (*QualifiedTable, error)
ParseTableIdentifier parses a table name into namespace and table name.
func (*QualifiedTable) MySQL ¶
func (t *QualifiedTable) MySQL() string
func (*QualifiedTable) String ¶
func (t *QualifiedTable) String() string
Click to show internal directories.
Click to hide internal directories.