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
	TlsCaCert          string
	TlsClientCert      string
	TlsClientKey       string
}