Rename field to make it clearer

Signed-off-by: Albert Callarisa <[email protected]>

Author: acroca

README.md

@@ -158,12 +158,12 @@ You can install Dapr runtime by pulling docker images from a given private regis
 dapr init --image-registry example.io/<username>
 ```
 
-#### Install with a custom scheduler host
+#### Install with a custom scheduler host and port
 
-You can install Dapr runtime with a custom scheduler host by using `--scheduler-host` flag.
+You can install Dapr runtime with a custom scheduler host and port by using `--scheduler-override-broadcast-host-port` flag.
 
 ```bash
-dapr init --scheduler-host 192.168.42.42
+dapr init --scheduler-override-broadcast-host-port 192.168.42.42:50006
 ```
 
 > Note: The default host is `localhost`.

cmd/init.go

@@ -29,24 +29,24 @@ import (
 )
 
 var (
-	kubernetesMode    bool
-	wait              bool
-	timeout           uint
-	slimMode          bool
-	devMode           bool
-	runtimeVersion    string
-	dashboardVersion  string
-	allNamespaces     bool
-	initNamespace     string
-	resourceNamespace string
-	enableMTLS        bool
-	enableHA          bool
-	values            []string
-	fromDir           string
-	containerRuntime  string
-	imageVariant      string
-	schedulerVolume   string
-	schedulerHost     string
+	kubernetesMode                     bool
+	wait                               bool
+	timeout                            uint
+	slimMode                           bool
+	devMode                            bool
+	runtimeVersion                     string
+	dashboardVersion                   string
+	allNamespaces                      bool
+	initNamespace                      string
+	resourceNamespace                  string
+	enableMTLS                         bool
+	enableHA                           bool
+	values                             []string
+	fromDir                            string
+	containerRuntime                   string
+	imageVariant                       string
+	schedulerVolume                    string
+	schedulerOverrideBroadcastHostPort string
 )
 
 var InitCmd = &cobra.Command{
@@ -172,7 +172,7 @@ dapr init --runtime-path <path-to-install-directory>
 				print.FailureStatusEvent(os.Stdout, "Invalid container runtime. Supported values are docker and podman.")
 				os.Exit(1)
 			}
-			err := standalone.Init(runtimeVersion, dashboardVersion, dockerNetwork, slimMode, imageRegistryURI, fromDir, containerRuntime, imageVariant, daprRuntimePath, &schedulerVolume, schedulerHost)
+			err := standalone.Init(runtimeVersion, dashboardVersion, dockerNetwork, slimMode, imageRegistryURI, fromDir, containerRuntime, imageVariant, daprRuntimePath, &schedulerVolume, schedulerOverrideBroadcastHostPort)
 			if err != nil {
 				print.FailureStatusEvent(os.Stderr, err.Error())
 				os.Exit(1)
@@ -222,7 +222,7 @@ func init() {
 	InitCmd.Flags().StringVarP(&fromDir, "from-dir", "", "", "Use Dapr artifacts from local directory for self-hosted installation")
 	InitCmd.Flags().StringVarP(&imageVariant, "image-variant", "", "", "The image variant to use for the Dapr runtime, for example: mariner")
 	InitCmd.Flags().StringVarP(&schedulerVolume, "scheduler-volume", "", "dapr_scheduler", "Self-hosted only. Specify a volume for the scheduler service data directory.")
-	InitCmd.Flags().StringVarP(&schedulerHost, "scheduler-host", "", "localhost", "Self-hosted only. Specify the host address for the scheduler service. If not specified, it uses localhost.")
+	InitCmd.Flags().StringVarP(&schedulerOverrideBroadcastHostPort, "scheduler-override-broadcast-host-port", "", "", "Self-hosted only. Specify the scheduler broadcast host and port, for example: 192.168.42.42:50006. If not specified, it uses localhost:50006 (6060 for Windows).")
 	InitCmd.Flags().BoolP("help", "h", false, "Print this help message")
 	InitCmd.Flags().StringArrayVar(&values, "set", []string{}, "set values on the command line (can specify multiple or separate values with commas: key1=val1,key2=val2)")
 	InitCmd.Flags().String("image-registry", "", "Custom/private docker image repository URL")

pkg/standalone/standalone.go

@@ -133,18 +133,18 @@ type componentMetadataItem struct {
 }
 
 type initInfo struct {
-	fromDir          string
-	installDir       string
-	bundleDet        *bundleDetails
-	slimMode         bool
-	runtimeVersion   string
-	dashboardVersion string
-	dockerNetwork    string
-	imageRegistryURL string
-	containerRuntime string
-	imageVariant     string
-	schedulerVolume  *string
-	schedulerHost    string
+	fromDir                            string
+	installDir                         string
+	bundleDet                          *bundleDetails
+	slimMode                           bool
+	runtimeVersion                     string
+	dashboardVersion                   string
+	dockerNetwork                      string
+	imageRegistryURL                   string
+	containerRuntime                   string
+	imageVariant                       string
+	schedulerVolume                    *string
+	schedulerOverrideBroadcastHostPort *string
 }
 
 type daprImageInfo struct {
@@ -186,7 +186,7 @@ func isSchedulerIncluded(runtimeVersion string) (bool, error) {
 }
 
 // Init installs Dapr on a local machine using the supplied runtimeVersion.
-func Init(runtimeVersion, dashboardVersion string, dockerNetwork string, slimMode bool, imageRegistryURL string, fromDir string, containerRuntime string, imageVariant string, daprInstallPath string, schedulerVolume *string, schedulerHost string) error {
+func Init(runtimeVersion, dashboardVersion string, dockerNetwork string, slimMode bool, imageRegistryURL string, fromDir string, containerRuntime string, imageVariant string, daprInstallPath string, schedulerVolume *string, schedulerOverrideBroadcastHostPort *string) error {
 	var err error
 	var bundleDet bundleDetails
 	containerRuntime = strings.TrimSpace(containerRuntime)
@@ -297,18 +297,18 @@ func Init(runtimeVersion, dashboardVersion string, dockerNetwork string, slimMod
 
 	info := initInfo{
 		// values in bundleDet can be nil if fromDir is empty, so must be used in conjunction with fromDir.
-		bundleDet:        &bundleDet,
-		fromDir:          fromDir,
-		installDir:       installDir,
-		slimMode:         slimMode,
-		runtimeVersion:   runtimeVersion,
-		dashboardVersion: dashboardVersion,
-		dockerNetwork:    dockerNetwork,
-		imageRegistryURL: imageRegistryURL,
-		containerRuntime: containerRuntime,
-		imageVariant:     imageVariant,
-		schedulerVolume:  schedulerVolume,
-		schedulerHost:    schedulerHost,
+		bundleDet:                          &bundleDet,
+		fromDir:                            fromDir,
+		installDir:                         installDir,
+		slimMode:                           slimMode,
+		runtimeVersion:                     runtimeVersion,
+		dashboardVersion:                   dashboardVersion,
+		dockerNetwork:                      dockerNetwork,
+		imageRegistryURL:                   imageRegistryURL,
+		containerRuntime:                   containerRuntime,
+		imageVariant:                       imageVariant,
+		schedulerVolume:                    schedulerVolume,
+		schedulerOverrideBroadcastHostPort: schedulerOverrideBroadcastHostPort,
 	}
 	for _, step := range initSteps {
 		// Run init on the configurations and containers.
@@ -686,7 +686,11 @@ func runSchedulerService(wg *sync.WaitGroup, errorChan chan<- error, info initIn
 	}
 
 	if schedulerOverrideHostPort(info) {
-		args = append(args, fmt.Sprintf("--override-broadcast-host-port=%s:%v", info.schedulerHost, osPort))
+		if info.schedulerOverrideBroadcastHostPort != nil {
+			args = append(args, fmt.Sprintf("--override-broadcast-host-port=%s", *info.schedulerOverrideBroadcastHostPort))
+		} else {
+			args = append(args, fmt.Sprintf("--override-broadcast-host-port=localhost:%v", osPort))
+		}
 	}
 
 	_, err = utils.RunCmdAndWait(runtimeCmd, args...)

pkg/standalone/standalone_test.go

@@ -20,6 +20,7 @@ import (
 	"github.com/stretchr/testify/assert"
 
 	"github.com/dapr/cli/utils"
+	"github.com/dapr/kit/ptr"
 )
 
 func TestStandaloneConfig(t *testing.T) {
@@ -325,7 +326,7 @@ func TestInitLogActualContainerRuntimeName(t *testing.T) {
 				t.Skip("Skipping test as container runtime is available")
 			}
 
-			err := Init(latestVersion, latestVersion, "", false, "", "", test.containerRuntime, "", "", nil, "localhost")
+			err := Init(latestVersion, latestVersion, "", false, "", "", test.containerRuntime, "", "", nil, ptr.Of("localhost:50006"))
 			assert.Error(t, err)
 			assert.Contains(t, err.Error(), test.containerRuntime)
 		})

tests/e2e/standalone/init_test.go

@@ -218,16 +218,16 @@ func TestStandaloneInit(t *testing.T) {
 		// Ensure a clean environment
 		must(t, cmdUninstall, "failed to uninstall Dapr")
 
-		customHost := "192.168.42.42"
+		customBroadcastHostPort := "192.168.42.42:50006"
 		args := []string{
-			"--scheduler-host", customHost,
+			"--scheduler-override-broadcast-host-port", customBroadcastHostPort,
 		}
 		output, err := cmdInit(args...)
 		t.Log(output)
 		require.NoError(t, err, "init failed")
 		assert.Contains(t, output, "Success! Dapr is up and running.")
 
-		verifySchedulerHost(t, customHost)
+		verifySchedulerBroadcastHostPort(t, customBroadcastHostPort)
 	})
 
 	t.Run("init without runtime-version flag with mariner images", func(t *testing.T) {
@@ -461,8 +461,8 @@ func verifyTCPLocalhost(t *testing.T, port int) {
 	}, time.Second*10, time.Millisecond*10)
 }
 
-// verifySchedulerHost verifies that the scheduler container was started with the correct host.
-func verifySchedulerHost(t *testing.T, expectedHost string) {
+// verifySchedulerBroadcastHostPort verifies that the scheduler container was started with the correct broadcast host and port.
+func verifySchedulerBroadcastHostPort(t *testing.T, expectedBroadcastHostPort string) {
 	t.Helper()
 
 	cli, err := dockerClient.NewClientWithOpts(dockerClient.FromEnv)
@@ -471,11 +471,6 @@ func verifySchedulerHost(t *testing.T, expectedHost string) {
 	containerInfo, err := cli.ContainerInspect(context.Background(), "dapr_scheduler")
 	require.NoError(t, err)
 
-	expectedPort := 50006
-	if runtime.GOOS == "windows" {
-		expectedPort = 6060
-	}
-
-	expectedArg := "--override-broadcast-host-port=" + expectedHost + ":" + strconv.Itoa(expectedPort)
+	expectedArg := "--override-broadcast-host-port=" + expectedBroadcastHostPort
 	assert.Contains(t, containerInfo.Args, expectedArg, "Expected scheduler argument %s not found in container args: %v", expectedArg, containerInfo.Args)
 }