INNER CODE UNIT · Go

defaultCanaryGRPCPort

cadence-workflow/cadence · cmd/sharddistributor-canary/main.go:33

	defaultCanaryGRPCPort           = 7953 // Port for canary to receive ping requests
	defaultNumExecutors             = 1

	shardDistributorServiceName = "cadence-shard-distributor"
)

func runApp(c *cli.Context) {
	endpoint := c.String("endpoint")
	fixedNamespace := c.String("fixed-namespace")
	ephemeralNamespace := c.String("ephemeral-namespace")
	canaryGRPCPort := c.Int("canary-grpc-port")

	numFixedExecutors := c.Int("num-fixed-executors")
	numEphemeralExecutors := c.Int("num-ephemeral-executors")

	if c.IsSet("num-executors") {
		numExecutors := c.Int("num-executors")
		numFixedExecutors = numExecutors

View source record →