List all transcoder jobs on specified pipeline.

@param request The request object containing all options for list jobs.

@return The list of job IDs.
963490
public ListTranscodingJobsResponse listTranscodingJobs(ListTranscodingJobsRequest request) {
        checkNotNull(request, "The parameter request should NOT be null.");
        checkStringNotEmpty(request.getPipelineName(),
                "The parameter pipelineName should NOT be null or empty string.");
        InternalRequest internalRequest = createRequest(HttpMethodName.GET, request, TRANSCODE_JOB);
        internalRequest.addParameter("pipelineName", request.getPipelineName());
        return invokeHttpClient(internalRequest, ListTranscodingJobsResponse.class);
    }
821158
public GetTranscodingJobResponse getTranscodingJob(String jobId) {
        GetTranscodingJobRequest request = new GetTranscodingJobRequest();
        request.setJobId(jobId);
        return getTranscodingJob(request);
    }
860094
public List<GitlabJob> getPipelineJobs(GitlabProject project, Integer pipelineId) {
        return getPipelineJobs(project.getId(), pipelineId);
    }
701627
@RequestMapping("/job-queue/load-add")
    public RestfulResponse loadJob(JobQueueReq request) {
        RestfulResponse response = new RestfulResponse();

        String nodeGroup = request.getTaskTrackerNodeGroup();

        HttpCmd httpCmd = new DefaultHttpCmd();
        httpCmd.setCommand(HttpCmdNames.HTTP_CMD_LOAD_JOB);
        httpCmd.addParam("nodeGroup", nodeGroup);

        List<Node> jobTrackerNodeList = appContext.getNodeMemCacheAccess().getNodeByNodeType(NodeType.JOB_TRACKER);
        if (CollectionUtils.isEmpty(jobTrackerNodeList)) {
            response.setMsg(I18nManager.getMessage("job.tracker.not.found"));
            response.setSuccess(false);
            return response;
        }

        boolean success = false;
        HttpCmdResponse cmdResponse = null;
        for (Node node : jobTrackerNodeList) {
            // 所有的JobTracker都load一遍
            httpCmd.setNodeIdentity(node.getIdentity());
            cmdResponse = HttpCmdClient.doGet(node.getIp(), node.getHttpCmdPort(), httpCmd);
            if (cmdResponse.isSuccess()) {
                success = true;
            }
        }
        if (success) {
            response.setMsg("Load success");
        } else {
            response.setMsg("Load failed");
        }
        response.setSuccess(success);
        return response;
    }
1065733
public static List<String> getRemoteAddresses(HttpServletRequest request) {
        List<String> addresses = new ArrayList<String>();
        addresses.add(request.getRemoteHost());
        if (!request.getRemoteAddr().equals(request.getRemoteHost())) {
            // Store both remote host and remote address 
            addresses.add(request.getRemoteAddr());
        }
        final String forwardedFor = request.getHeader("X-Forwarded-For");
        if (forwardedFor != null) {
            // Also store address this request was forwarded for.
            final String[] parts = forwardedFor.split(",");
            for (String part : parts) {
                addresses.add(part);
            }
        }
        final String httpVia = request.getHeader("Via");
        if (httpVia != null) {
            // Also store address this request was forwarded for.
            final String[] parts = httpVia.split(",");
            for (String part : parts) {
                addresses.add(part);
            }
        }
        return Collections.unmodifiableList(addresses);
    }
1301842
private Map<String, Set<String>> getParameters(HttpServletRequest request) {
        Map<String, String[]> params = request.getParameterMap();

        Map<String, Set<String>> queryParameters = new HashMap<>(params.size());
        for (Map.Entry<String, String[]> entry : params.entrySet()) {
            queryParameters.put(entry.getKey(), new HashSet<>(Arrays.asList(entry.getValue())));
        }
        return queryParameters;
    }
1333762
public static Map<String, String[]> getRequestParameters(final HttpServletRequest request) {
		if (request.getAttribute(REQUEST_PROCESSED_KEY) == null) {
			setupRequestParameters(request);
		}
		return (Map<String, String[]>) request.getAttribute(REQUEST_PARAMETERS_KEY);
	}
1065163
public List<Flow<Job<T>>> getAllFlow()
   {
      List<Flow<Job<T>>> list = new ArrayList<Flow<Job<T>>>();
      List<Node> nodeList = childNode.get("flow");
      for(Node node: nodeList)
      {
         Flow<Job<T>>  type = new FlowImpl<Job<T>>(this, "flow", childNode, node);
         list.add(type);
      }
      return list;
   }
684631
public List<Future<JobReport>> submitAll(List<Job> jobs) {
        try {
            return executorService.invokeAll(jobs);
        } catch (InterruptedException e) {
            throw new RuntimeException("Unable to execute jobs", e);
        }
    }
120537
public ListPipelinesResponse listPipelines(ListPipelinesRequest request) {
        checkNotNull(request, "The parameter request should NOT be null.");
        InternalRequest internalRequest = createRequest(HttpMethodName.GET, request, PIPELINE);
        return invokeHttpClient(internalRequest, ListPipelinesResponse.class);
    }
636331
public List<Flow<JobXMLDescriptor>> getAllFlow()
   {
      List<Flow<JobXMLDescriptor>> list = new ArrayList<Flow<JobXMLDescriptor>>();
      List<Node> nodeList = model.get("flow");
      for(Node node: nodeList)
      {
         Flow<JobXMLDescriptor>  type = new FlowImpl<JobXMLDescriptor>(this, "flow", model, node);
         list.add(type);
      }
      return list;
   }
723013
public static Map<String, List<StringValue>> getPageParametersMap(final Request request)
	{
		final Map<String, List<StringValue>> map = new HashMap<>();
		addToParameters(request.getRequestParameters(), map);
		addToParameters(request.getQueryParameters(), map);
		addToParameters(request.getPostParameters(), map);
		return map;
	}
947085
private List<OrderSpecifier> getOrderByList(HttpServletRequest request) throws Exception {
		String[] orderByStrings = request.getParameterValues("orderBy");
		if( null == orderByStrings ) {
			return null;
		}
		if( 0 == orderByStrings.length ) {
			return null;
		}
		
		List<OrderSpecifier> result = new Vector<OrderSpecifier>();
		
		for(String orderByString : orderByStrings) {
			OrderSpecifier orderSpecifier = parseOrderSpecifier(orderByString);
			result.add(orderSpecifier);
		}

		return result;
	}
1369826
public CreatePipelineResponse createPipeline(CreatePipelineRequest request) {
        checkNotNull(request, "The parameter request should NOT be null.");
        checkStringNotEmpty(request.getPipelineName(), 
                "The parameter pipelineName should NOT be null or empty string.");
        checkStringNotEmpty(request.getSourceBucket(), 
                "The parameter sourceBucket should NOT be null or empty string.");
        checkStringNotEmpty(request.getTargetBucket(), 
                "The parameter targetBucket should NOT be null or empty string.");
        if (request.getConfig() == null || request.getConfig().getCapacity() == null) {
            PipelineConfig config = new PipelineConfig();
            config.setCapacity(DEFAULT_PIPELINE_CAPACITY);
            request.setConfig(config);
        }
        InternalRequest internalRequest = createRequest(HttpMethodName.POST, request, PIPELINE);
        
        return invokeHttpClient(internalRequest, CreatePipelineResponse.class);
    }
689642
@Override
    public List<JobDef> getJobDefinitions()
    {
        try
        {
            return target.path("jd").request().get(new GenericType<List<JobDef>>()
            {
            });
        }
        catch (Exception e)
        {
            throw new JqmClientException(e);
        }
    }
262687
public ListTranscodingJobsResponse listTranscodingJobs(String pipelineName) {
        ListTranscodingJobsRequest request = new ListTranscodingJobsRequest();
        request.setPipelineName(pipelineName);
        return listTranscodingJobs(request);
    }
1318745
public ListWaterMarkResponse listWaterMark(ListWaterMarkRequest request) {
        InternalRequest internalRequest = createRequest(HttpMethodName.GET, request, WATER_MARK);
        
        return invokeHttpClient(internalRequest, ListWaterMarkResponse.class);
    }