export

var ExportCmd = &cobra.Command{
	Use:   "export",
	Short: "Export Otterize intents from the kafka mapper",
	Args:  cobra.NoArgs,
	RunE: func(cmd *cobra.Command, args []string) error {
		ctxTimeout, cancel := context.WithTimeout(context.Background(), config.DefaultTimeout)
		defer cancel()

		podName := viper.GetString(PodKey)
		namespace := viper.GetString(NamespacesKey)

		m, err := kafkamapper.NewMapper()
		if err != nil {
			return err
		}

		intents, err := m.LoadIntents(ctxTimeout, podName, namespace)
		if err != nil {
			return err
		}

		exporter, err := intentsexporter.NewExporter()
		if err != nil {
			return err
		}

		if err := exporter.ExportIntents(intents); err != nil {
			return err
		}

		return nil
	},
}