in cmd/serve/serve.go [22:49]
func NewCmd() *cobra.Command {
return &cobra.Command{
Use: "serve",
Short: "Start the step-runner gRPC service",
Args: cobra.MaximumNArgs(1),
RunE: func(cmd *cobra.Command, args []string) error {
sigChan := make(chan os.Signal, 1)
diContainer := di.NewContainer()
stepRunnerService, err := diContainer.StepRunnerService()
if err != nil {
return fmt.Errorf("initializing step-runner: %w", err)
}
socketAddr, err := GetSocketAddr(args)
if err != nil {
return fmt.Errorf("initializing step-runner: %w", err)
}
if err := NewServeCmd(stepRunnerService, socketAddr, sigChan).Run(); err != nil {
return fmt.Errorf("serving step-runner: %w", err)
}
return nil
},
}
}