Interface PipelineExecutionApi

    • Method Detail

      • getCurrent

        @NotNull
        @NotNull Optional<PipelineExecution> getCurrent​(@NotNull
                                                        @NotNull String programId,
                                                        @NotNull
                                                        @NotNull String pipelineId)
                                                 throws CloudManagerApiException
        Get the current execution of the specified pipeline, if one exists.
        Parameters:
        programId - the program id context of the pipeline
        pipelineId - the pipeline id of to find the execution
        Returns:
        An optional containing the execution details of the pipeline
        Throws:
        CloudManagerApiException - when any error occurs
      • start

        @NotNull
        @NotNull PipelineExecution start​(@NotNull
                                         @NotNull String programId,
                                         @NotNull
                                         @NotNull String pipelineId)
                                  throws CloudManagerApiException
        Start the specified pipeline.

        Note: This API call may return before the requested action takes effect. i.e. The Pipelines are scheduled to start once called. However, an immediate subsequent call to getCurrent(String, String) may not return a result.

        Parameters:
        programId - the program id context of the pipeline
        pipelineId - the id of the pipeline
        Returns:
        the new execution
        Throws:
        CloudManagerApiException - when any error occurs
      • get

        @NotNull
        @NotNull PipelineExecution get​(@NotNull
                                       @NotNull String programId,
                                       @NotNull
                                       @NotNull String pipelineId,
                                       @NotNull
                                       @NotNull String executionId)
                                throws CloudManagerApiException
        Get the specified execution of the pipeline.
        Parameters:
        programId - the program id context of the pipeline
        pipelineId - the pipeline id
        executionId - the id of the execution to retrieve
        Returns:
        the execution details
        Throws:
        CloudManagerApiException - when any error occurs
      • get

        @NotNull
        @NotNull PipelineExecution get​(@NotNull
                                       @NotNull Pipeline pipeline,
                                       @NotNull
                                       @NotNull String executionId)
                                throws CloudManagerApiException
        Returns the specified execution of the pipeline.
        Parameters:
        pipeline - the pipeline context for the execution
        executionId - the id of the execution to retrieve
        Returns:
        the execution details
        Throws:
        CloudManagerApiException - when any error occurs
      • advance

        void advance​(@NotNull
                     @NotNull String programId,
                     @NotNull
                     @NotNull String pipelineId,
                     @NotNull
                     @NotNull String executionId)
              throws CloudManagerApiException
        Advance the execution of the specified pipeline execution, if in an appropriate state.
        Parameters:
        programId - the program id context of the pipeline
        pipelineId - the id of the pipeline to cancel
        executionId - the execution id to be advanced
        Throws:
        CloudManagerApiException - when any error occurs
      • cancel

        void cancel​(@NotNull
                    @NotNull String programId,
                    @NotNull
                    @NotNull String pipelineId,
                    @NotNull
                    @NotNull String executionId)
             throws CloudManagerApiException
        Cancel the execution of the specified pipeline execution, if in an appropriate state.
        Parameters:
        programId - the program id context of the pipeline
        pipelineId - the id of the pipeline to cancel
        executionId - the execution id to be canceled
        Throws:
        CloudManagerApiException - when any error occurs
      • getStepLogDownloadUrl

        String getStepLogDownloadUrl​(@NotNull
                                     @NotNull String programId,
                                     @NotNull
                                     @NotNull String pipelineId,
                                     @NotNull
                                     @NotNull String executionId,
                                     @NotNull
                                     @NotNull StepAction action)
                              throws CloudManagerApiException
        Get the fully qualified URL to the specified step's log file.
        Parameters:
        programId - the program id of the pipeline context
        pipelineId - the pipeline id for the execution context
        executionId - the execution id
        action - the execution step action for the log
        Returns:
        the log file URL
        Throws:
        CloudManagerApiException - when any error occurs
      • getStepLogDownloadUrl

        String getStepLogDownloadUrl​(@NotNull
                                     @NotNull String programId,
                                     @NotNull
                                     @NotNull String pipelineId,
                                     @NotNull
                                     @NotNull String executionId,
                                     @NotNull
                                     @NotNull StepAction action,
                                     @NotNull
                                     @NotNull String name)
                              throws CloudManagerApiException
        Get the fully qualified URL to the specified step's log file.
        Parameters:
        programId - the program id of the pipeline context
        pipelineId - the pipeline id for the execution context
        executionId - the execution id
        action - the execution step action context
        name - custom log file name
        Returns:
        the log file URL
        Throws:
        CloudManagerApiException - when any error occurs
      • getStepLogDownloadUrl

        String getStepLogDownloadUrl​(@NotNull
                                     @NotNull PipelineExecution execution,
                                     @NotNull
                                     @NotNull StepAction action)
                              throws CloudManagerApiException
        Get the fully qualified URL to the specified step's log file.
        Parameters:
        execution - the execution context
        action - the execution step action context
        Returns:
        the log file download URL
        Throws:
        CloudManagerApiException - when any error occurs
      • getStepLogDownloadUrl

        String getStepLogDownloadUrl​(@NotNull
                                     @NotNull PipelineExecution execution,
                                     @NotNull
                                     @NotNull StepAction action,
                                     @NotNull
                                     @NotNull String name)
                              throws CloudManagerApiException
        Get the fully qualified URL to the specified log file referenced by name, within the step.
        Parameters:
        execution - the execution context
        action - the execution step action context
        name - custom log file name
        Returns:
        the log file download URL
        Throws:
        CloudManagerApiException - when any error occurs
      • list

        @NotNull
        @NotNull Collection<PipelineExecution> list​(@NotNull
                                                    @NotNull String programId,
                                                    @NotNull
                                                    @NotNull String pipelineId,
                                                    int limit)
                                             throws CloudManagerApiException
        List executions of the specified pipeline, using the specified limit and starting at 0.
        Parameters:
        programId - the program id context of the pipeline
        pipelineId - the pipeline id
        limit - the number of executions to return
        Returns:
        list of executions
        Throws:
        CloudManagerApiException - when any error occurs
      • list

        @NotNull
        @NotNull Collection<PipelineExecution> list​(@NotNull
                                                    @NotNull String programId,
                                                    @NotNull
                                                    @NotNull String pipelineId,
                                                    int start,
                                                    int limit)
                                             throws CloudManagerApiException
        List executions of the specified pipeline, using the specified limit and starting at the specified position.
        Parameters:
        programId - the program id context of the pipeline
        pipelineId - the pipeline id
        start - the starting position of the results
        limit - the number of executions to return
        Returns:
        list of executions
        Throws:
        CloudManagerApiException - when any error occurs
      • list

        @NotNull
        @NotNull Collection<PipelineExecution> list​(@NotNull
                                                    @NotNull Pipeline pipeline,
                                                    int start,
                                                    int limit)
                                             throws CloudManagerApiException
        List executions of the specified pipeline, using the specified limit and starting at the specified position.
        Parameters:
        pipeline - the pipeline context
        start - the starting position of the results
        limit - the number of executions to return
        Returns:
        list of executions
        Throws:
        CloudManagerApiException - when any error occurs