Documentation ¶ Index ¶ func MergeErrors(ctx context.Context, errChans ...<-chan error) <-chan error func PanicIfErr(err error) func WaitForPipeline(ctx context.Context, errs ...<-chan error) error type Table func QueryReadAll(ctx context.Context, conn *sql.DB, sqlText string, database string, ...) (*Table, error) Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ func MergeErrors ¶ func MergeErrors(ctx context.Context, errChans ...<-chan error) <-chan error func PanicIfErr ¶ func PanicIfErr(err error) func WaitForPipeline ¶ func WaitForPipeline(ctx context.Context, errs ...<-chan error) error Types ¶ type Table ¶ type Table struct { ColumnNames []string ColumnDBTypes []string RowValues [][]interface{} } func QueryReadAll ¶ func QueryReadAll(ctx context.Context, conn *sql.DB, sqlText string, database string, schema string) (*Table, error) Source Files ¶ View all Source files panic_if_err.gopipeline.gotest_helpers.go Click to show internal directories. Click to hide internal directories.