mysql

func (*Engine) ConnectionString ¶

func (e *Engine) ConnectionString(conn engine.ConnectionConfig) string

func (*Engine) ContainerImage ¶

func (e *Engine) ContainerImage() string

func (*Engine) ContainerPort ¶ added in v0.2.0

func (e *Engine) ContainerPort() int

func (*Engine) ContainerSpec ¶ added in v0.2.0

func (e *Engine) ContainerSpec(copy engine.CopyBootstrap) engine.ContainerSpec

func (*Engine) Dump ¶

func (e *Engine) Dump(
	ctx context.Context,
	docker *client.Client,
	clientImage string,
	src engine.SourceConfig,
	destPath string,
	opts engine.DumpOptions,
) error

Dump runs mysqldump inside a short-lived helper container, then compresses the resulting SQL dump to destPath. When opts.SchemaOnly is true, --no-data is passed so only DDL is captured.

func (*Engine) DumpFromContainer ¶

func (e *Engine) DumpFromContainer(ctx context.Context, docker *client.Client, containerName string, destPath string, copy engine.CopyBootstrap, opts engine.DumpOptions) error

DumpFromContainer creates a gzip-compressed mysqldump of the ditto database running inside containerName and writes it to destPath on the host. The container must have its dump directory mounted at /dump (read-write). When opts.SchemaOnly is true, --no-data is passed to mysqldump.

func (*Engine) Name ¶

func (e *Engine) Name() string

func (*Engine) Restore ¶

func (e *Engine) Restore(ctx context.Context, docker *client.Client, dumpPath string, containerName string, copy engine.CopyBootstrap) error

Restore calls mysql inside the container to load the dump file. containerName is the Docker container name (e.g. "ditto-<id>") as set by the copy manager. The manager calls WaitReady before Restore, so readiness is already guaranteed when this method is invoked.

func (*Engine) WaitReady ¶

func (e *Engine) WaitReady(conn engine.ConnectionConfig, timeout time.Duration) error

WaitReady polls port until MySQL is accepting connections.