main.go

//
// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements.  See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership.  The ASF licenses this file
// to you under the Apache License, Version 2.0 (the
// "License"); you may not use this file except in compliance
// with the License.  You may obtain a copy of the License at
//
//   http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing,
// software distributed under the License is distributed on an
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
// KIND, either express or implied.  See the License for the
// specific language governing permissions and limitations
// under the License.
//

// Small utility to synchronize CloudStack disk offerings to
// Kubernetes storage classes.
package main

import (
	"context"
	"flag"
	"fmt"
	"log"
	"os"
	"path"

	"github.com/cloudstack/cloudstack-csi-driver/pkg/syncer"
)

const agent = "cloudstack-csi-sc-syncer"

var (
	cloudstackconfig = flag.String("cloudstackconfig", "./cloud-config", "CloudStack configuration file")
	kubeconfig       = flag.String("kubeconfig", path.Join(os.Getenv("HOME"), ".kube/config"), "Kubernetes configuration file. Use \"-\" to use in-cluster configuration.")
	label            = flag.String("label", "app.kubernetes.io/managed-by="+agent, "")
	namePrefix       = flag.String("namePrefix", "cloudstack-", "")
	deleteUnused     = flag.Bool("delete", false, "Delete")
	volumeExpansion  = flag.Bool("volumeExpansion", false, "VolumeExpansion")
	showVersion      = flag.Bool("version", false, "Show version")

	// Version is set by the build process.
	version = ""
)

func main() {
	flag.Parse()

	if *showVersion {
		baseName := path.Base(os.Args[0])
		fmt.Println(baseName, version) //nolint:forbidigo

		return
	}

	s, err := syncer.New(syncer.Config{
		Agent:            agent,
		CloudStackConfig: *cloudstackconfig,
		KubeConfig:       *kubeconfig,
		Label:            *label,
		NamePrefix:       *namePrefix,
		Delete:           *deleteUnused,
		VolumeExpansion:  *volumeExpansion,
	})
	if err != nil {
		log.Fatalf("Error: %v", err)
	}
	err = s.Run(context.Background())
	if err != nil {
		log.Fatalf("Error: %v", err)
	}
	os.Exit(0)
}