Function jobDebugGetOutputRun

cmd/wsh/cmd/wshcmd-jobdebug.go:348–381

(cmd *cobra.Command, args []string)

}

func jobDebugGetOutputRun(cmd *cobra.Command, args []string) error {
	broker := RpcClient.StreamBroker
	if broker == nil {
		return fmt.Errorf("stream broker not available")
	}

	readerRouteId, err := wshclient.ControlGetRouteIdCommand(RpcClient, &wshrpc.RpcOpts{Route: wshutil.ControlRoute})
	if err != nil {
		return fmt.Errorf("getting route id: %w", err)
	}
	if readerRouteId == "" {
		return fmt.Errorf("no route to receive data")
	}
	writerRouteId := "" // main server route
	reader, streamMeta := broker.CreateStreamReader(readerRouteId, writerRouteId, 64*1024)
	defer reader.Close()

	data := wshrpc.CommandWaveFileReadStreamData{
		ZoneId:     jobIdFlag,
		Name:       "term",
		StreamMeta: *streamMeta,
	}

	_, err = wshclient.WaveFileReadStreamCommand(RpcClient, data, nil)
	if err != nil {
		return fmt.Errorf("starting stream read: %w", err)
	}

	_, err = io.Copy(os.Stdout, reader)
	if err != nil {
		return fmt.Errorf("reading stream: %w", err)
	}
	return nil
}

func jobDebugStartRun(cmd *cobra.Command, args []string) error {
	cmdToRun := args[0]