Function main

cmd/repositoryembedder/main.go:80–239

()

}

func main() {
	// Define flags
	var storageId string
	var repositoryId string
	var modelId string

	flag.StringVar(&storageId, "storageId", "", "Storage ID")
	flag.StringVar(&repositoryId, "repositoryId", "", "Repository ID")
	flag.StringVar(&modelId, "modelId", "", "Model ID")

	// Parse flags
	flag.Parse()

	// Example usage of flags in the application logic
	fmt.Printf("Using storage ID: %s\n", storageId)
	fmt.Printf("Using repository ID: %s\n", repositoryId)
	fmt.Printf("Using model ID: %s\n", modelId)

	// Check if all required arguments are provided
	if storageId == "" || repositoryId == "" || modelId == "" {
		Warning("All arguments (storageId, repositoryId, modelId) are required.")
		os.Exit(1)
	}

	// Get the kubernetes client.
	c, err := defaultClient()
	if err != nil {
		CheckIfError(err)

	}

	// Get the namespace from the service account.
	ns, err := namespace()
	if err != nil {
		CheckIfError(err)
	}

	// Get the repository by name.
	repo := &v1alpha1.Repository{}
	if err := c.Get(context.TODO(), client.ObjectKey{Name: repositoryId, Namespace: ns}, repo); err != nil {
		CheckIfError(err)
	}

	// Get the storage by name.
	st := &v1alpha1.Storage{}
	if err := c.Get(context.TODO(), client.ObjectKey{Name: storageId, Namespace: ns}, st); err != nil {
		CheckIfError(err)
	}
	// Initialize embClient
	embClient := embedder.NewClient(modelId, ns)

	// Repository URL for remote git repository
	var url string
	var branch string
	switch repo.Spec.Type {
	case v1alpha1.RepositoryTypeGithub:
		url = repo.Spec.Github.URL
		branch = repo.Spec.Github.Branch