sqlclient

type Client struct {
	// Name used when creating the client.
	Name string

	// DB used for creating the client.
	DB *sql.DB
	// URL holds an enriched url.URL.
	URL *URL

	// A migration driver for the attached dialect.
	migrate.Driver

	// Marshal and Evaluator functions for decoding
	// and encoding the schema documents.
	schemahcl.Marshaler
	schemahcl.Evaluator

	// Ephemeral indicates that the database we connect to is "ephemeral"
	// (e.g., a temporary running container). This can be set by the driver
	// that opens the client to signal to its consumers that there is no need
	// to guard against race conditions with other Atlas clients.
	Ephemeral bool
	// contains filtered or unexported fields
}

type Hook struct {
	Conn struct {
		AfterOpen   func(context.Context, *Client) error
		BeforeClose func(*Client) error
	}
	Tx struct {
		AfterBegin func(context.Context, *TxClient) error
		BeforeCommit,
		BeforeRollback func(*TxClient) error
	}
}

type OpenOption func(*openOptions) error

type Opener interface {
	Open(ctx context.Context, u *url.URL) (*Client, error)
}

type OpenerFunc func(context.Context, *url.URL) (*Client, error)

type RegisterOption func(*registerOptions)

type SchemaChanger interface {
	ChangeSchema(*url.URL, string) *url.URL
}

type Tx struct {
	*sql.Tx
	CommitFn   func() error // override default commit behavior
	RollbackFn func() error // override default rollback behavior
}

type TxClient struct {
	*Client

	// The transaction this Client wraps.
	Tx *Tx
	// contains filtered or unexported fields
}

type TxOpener func(context.Context, *sql.DB, *sql.TxOptions) (*Tx, error)

type URL struct {
	*url.URL

	// The DSN used for opening the connection.
	DSN string `json:"-"`

	// The Schema this client is connected to.
	Schema string
}

type URLParser interface {
	ParseURL(*url.URL) *URL
}

type URLParserFunc func(*url.URL) *URL