ontology

Documentation

Index

• Variables
• func LoadCommand(dbname, path string) []string
• func RefreshCommand() []string

Variables

var LoadOntoCmd = &cobra.Command{
	Use:   "load-ontology",
	Short: "run ontology load command as a kubernetes job in the cluster",
	Args:  cobra.NoArgs,
	RunE: func(cmd *cobra.Command, args []string) error {
		labels := cliJob.MetaLabel()
		labels["subcommand"] = "load-ontology"
		for _, dbname := range viper.GetStringSlice("databases") {
			bucketPath, _ := cmd.Flags().GetString("s3-bucket-path-prefix")
			job, err := cliJob.Run(
				cmd,
				labels,
				LoadCommand(dbname, fmt.Sprintf("%s/%s", bucketPath, dbname)),
			)
			if err != nil {
				return errors.Errorf("error in running job %s in database %s", err, dbname)
			}
			registry.GetLogger().Infof("deployed job %s in database %s", job.Name, dbname)
		}

		return nil
	},
}

var RefreshCmd = &cobra.Command{
	Use:   "refresh-ontology",
	Short: "run ontology refresh command as a kubernetes job in the cluster",
	Args:  cobra.NoArgs,
	RunE: func(cmd *cobra.Command, args []string) error {
		labels := cliJob.MetaLabel()
		labels["subcommand"] = "refresh-ontology"
		job, err := cliJob.Run(cmd, labels, RefreshCommand())
		if err != nil {
			return errors.Errorf("error in running job %s", err)
		}
		registry.GetLogger().Infof("deployed job %s", job.Name)
		return nil
	},
}

Functions

func LoadCommand

func LoadCommand(dbname, path string) []string

func RefreshCommand

func RefreshCommand() []string