execute

type MigrationExecutor struct {
	// contains filtered or unexported fields
}

type MigrationExecutorOpts struct {
	MigrationStateFile    string
	MigrationState        types.MigrationState
	MigrationConfig       types.MigrationConfig
	LagThreshold          int64
	ClusterApiKey         string
	ClusterApiSecret      string
	ClusterBootstrap      string
	SourceBootstrap       string
	AWSRegion             string
	AuthType              types.AuthType
	SaslScramUsername     string
	SaslScramPassword     string
	SaslPlainUsername     string
	SaslPlainPassword     string
	TlsCaCert             string
	TlsClientCert         string
	TlsClientKey          string
	InsecureSkipTLSVerify bool
}