Method execute

commandline/command_builder.go:412–442

(ctx executor.ExecutionContext, outputFormat string, query string, outputWriter output.OutputWriter)

}

func (b CommandBuilder) execute(ctx executor.ExecutionContext, outputFormat string, query string, outputWriter output.OutputWriter) error {
	var wg sync.WaitGroup
	wg.Add(3)
	reader, writer := io.Pipe()
	go func() {
		defer wg.Done()
		defer func() { _ = reader.Close() }()
		_, _ = io.Copy(b.StdOut, reader)
	}()
	errorReader, errorWriter := io.Pipe()
	go func() {
		defer wg.Done()
		defer func() { _ = errorReader.Close() }()
		_, _ = io.Copy(b.StdErr, errorReader)
	}()

	var err error
	go func() {
		defer wg.Done()
		defer func() { _ = writer.Close() }()
		defer func() { _ = errorWriter.Close() }()
		if outputWriter == nil {
			outputWriter = b.outputWriter(writer, outputFormat, query)
		}
		logger := b.logger(ctx.Debug, errorWriter)
		err = b.executeCommand(ctx, outputWriter, logger)
	}()

	wg.Wait()
	return err
}

func (b CommandBuilder) createCategoryCommand(operation parser.Operation) *CommandDefinition {
	flags := NewFlagBuilder().