grpc-xds/greeter-go/cmd/cmd.go

// Copyright 2023 Google LLC
//
// Licensed 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.

package cmd

import (
	"context"
	"flag"
	"fmt"

	"github.com/googlecloudplatform/solutions-workshops/grpc-xds/greeter-go/pkg/config"
	"github.com/googlecloudplatform/solutions-workshops/grpc-xds/greeter-go/pkg/logging"
	"github.com/googlecloudplatform/solutions-workshops/grpc-xds/greeter-go/pkg/server"
	"github.com/googlecloudplatform/solutions-workshops/grpc-xds/greeter-go/pkg/signals"
)

func Run(ctx context.Context, flagset *flag.FlagSet, args []string) error {
	ctx = signals.SetupSignalHandler(ctx)
	logging.InitFlags(flagset)
	if err := flagset.Parse(args); err != nil {
		return fmt.Errorf("could not parse command line flags args=%+v: %w", args, err)
	}
	logger := logging.NewLogger()
	logging.SetGRPCLogger(logger)
	ctx = logging.NewContext(ctx, logger)
	servingPort, err := config.ServingPort()
	if err != nil {
		return fmt.Errorf("could not configure greeter server listening port: %w", err)
	}
	healthPort, err := config.HealthPort()
	if err != nil {
		return fmt.Errorf("could not configure greeter server gRPC health check port: %w", err)
	}
	httpHealthPort, err := config.HTTPHealthPort()
	if err != nil {
		return fmt.Errorf("could not configure greeter server HTTP health check port: %w", err)
	}
	serverConfig := server.Config{
		ServingPort:    servingPort,
		HealthPort:     healthPort,
		HTTPHealthPort: httpHealthPort,
		GreeterName:    config.GreeterName(ctx),
		NextHop:        config.NextHop(),
		UseXDS:         config.UseXDS(),
	}
	return server.Run(ctx, serverConfig)
}