Function main

flow/main.go:26–320

()

)

func main() {
	appCtx, appClose := signal.NotifyContext(context.Background(), syscall.SIGINT, syscall.SIGTERM)
	defer appClose()

	slog.SetDefault(slog.New(shared.NewSlogHandler(slog.NewJSONHandler(os.Stdout, shared.NewSlogHandlerOptions()))))

	temporalHostPortFlag := &cli.StringFlag{
		Name:    "temporal-host-port",
		Value:   "localhost:7233",
		Sources: cli.EnvVars("TEMPORAL_HOST_PORT"),
	}

	profilingFlag := &cli.BoolFlag{
		Name:    "enable-profiling",
		Value:   false, // Default is off
		Usage:   "Enable profiling for the application",
		Sources: cli.EnvVars("ENABLE_PROFILING"),
	}
	otelMetricsFlag := &cli.BoolFlag{
		Name:    "enable-otel-metrics",
		Value:   false, // Default is off
		Usage:   "Enable OpenTelemetry metrics for the application",
		Sources: cli.EnvVars("ENABLE_OTEL_METRICS"),
	}
	otelTracesFlag := &cli.BoolFlag{
		Name:    "enable-otel-traces",
		Value:   false,
		Usage:   "Enable OpenTelemetry traces for the application",
		Sources: cli.EnvVars("ENABLE_OTEL_TRACES"),
	}

	pprofPortFlag := &cli.Uint16Flag{
		Name:    "pprof-port",
		Value:   6060,
		Usage:   "Port for pprof HTTP server",
		Sources: cli.EnvVars("PPROF_PORT"),
	}

	temporalNamespaceFlag := &cli.StringFlag{
		Name:    "temporal-namespace",
		Value:   "default",
		Usage:   "Temporal namespace to use for workflow orchestration",
		Sources: cli.EnvVars("PEERDB_TEMPORAL_NAMESPACE"),
	}

	temporalMaxConcurrentActivitiesFlag := &cli.IntFlag{
		Name:    "temporal-max-concurrent-activities",
		Value:   1000,
		Usage:   "Temporal: maximum number of concurrent activities",
		Sources: cli.EnvVars("TEMPORAL_MAX_CONCURRENT_ACTIVITIES"),
	}

	temporalMaxConcurrentWorkflowTasksFlag := &cli.IntFlag{
		Name:    "temporal-max-concurrent-workflow-tasks",
		Value:   1000,
		Usage:   "Temporal: maximum number of concurrent workflows",
		Sources: cli.EnvVars("TEMPORAL_MAX_CONCURRENT_WORKFLOW_TASKS"),
	}