dumps

package
v0.54.7 Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InterceptImportMessages 

func InterceptImportMessages(t *testing.T, args InterceptArgs) (int, chan ImportQueryError)

InterceptImportMessages sits between PSQL and Doltgres, returning all error messages that are encountered. As we rely on PSQL to handle the import process, we normally wouldn't be able to associate error messages with queries, as this information is not returned by PSQL itself. Therefore, we create our own connection to Doltgres, and a server that PSQL listens to. We then forward everything from PSQL to Doltgres, while inspecting the messages as they come and go.

Types

type ImportQueryError 

type ImportQueryError struct {
	Query string
	Error string
}

ImportQueryError contains both a query and its associated error.

type InterceptArgs 

type InterceptArgs struct {
	DoltgresPort      int
	SkippedQueries    []string
	BreakpointQueries []string
	TriggerBreakpoint func(string)
}

InterceptArgs are the arguments that are passed to InterceptImportMessages.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.