Function StartClient

client/client.go:19–79

StartClient starts a client instance with a client config and a user agent

(config *config.ClientConfig, userAgent string)

// StartClient starts a client instance with a client config and a user agent
func StartClient(config *config.ClientConfig, userAgent string) {
	log.Infof("Initializing client")

	// Check if the config is valid
	err := validateConfig(config)

	if err != nil {
		log.Warnf("Configuration error: %v", err)
		os.Exit(1)
	}

	log.Infof("Configuring connection to %s for gRPC operations", config.GetDialAddr())

	// Configure connection
	// TODO: Use TLS for encrypting connection (with configurable certs and a sane default)
	conn, err := grpc.Dial(
		config.GetDialAddr(),
		grpc.WithBackoffConfig(grpc.DefaultBackoffConfig),
		grpc.WithInsecure(),
		grpc.WithUserAgent(userAgent+";"),
	)

	if err != nil {
		log.Warnf("Could not configure connection to host: %v", err)
		os.Exit(1)
	}

	defer conn.Close()

	// Create client from connection
	client := api.NewCertificateIssuerClient(conn)

	// Test connection
	_, err = client.Ping(context.Background(), &api.PingRequest{Msg: "ping"})

	if err != nil {
		log.Warnf("Could not test connection to %s: %v", config.GetDialAddr(), err)
		os.Exit(1)
	}

	log.Infof("Successfully pinged intercert host")

	// Create storage for saving/loading certs
	certStorage := NewCertStorage(config.GetCertStorage())

	// Configure cert workers
	for w := 1; w <= runtime.NumCPU(); w++ {
		go CertWorker(w, client, certStorage)
	}

	// Set up scheduled tasks
	tasks := configureTasks(client, config, certStorage)

	// Handle termination
	configureTermination(tasks)

	log.Infof("Client running - ready to work!")