1. Packages
  2. Oracle Cloud Infrastructure
  3. API Docs
  4. GoldenGate
  5. getPipelineRunningProcesses
Oracle Cloud Infrastructure v3.10.0 published on Wednesday, Nov 5, 2025 by Pulumi
pulumi/pulumi-oci

oci.GoldenGate.getPipelineRunningProcesses

Start a Neo task
Explain and create an oci.GoldenGate.getPipelineRunningProcesses resource
oci logo
Oracle Cloud Infrastructure v3.10.0 published on Wednesday, Nov 5, 2025 by Pulumi
pulumi/pulumi-oci

    This data source provides the list of Pipeline Running Processes in Oracle Cloud Infrastructure Golden Gate service.

    Retrieves a Pipeline’s running replication process’s status like Capture/Apply.

    Example Usage

    import * as pulumi from "@pulumi/pulumi";
import * as oci from "@pulumi/oci";

const testPipelineRunningProcesses = oci.GoldenGate.getPipelineRunningProcesses({
    pipelineId: testPipeline.id,
});

    import pulumi
import pulumi_oci as oci

test_pipeline_running_processes = oci.GoldenGate.get_pipeline_running_processes(pipeline_id=test_pipeline["id"])

    package main

import (
	"github.com/pulumi/pulumi-oci/sdk/v3/go/oci/goldengate"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := goldengate.GetPipelineRunningProcesses(ctx, &goldengate.GetPipelineRunningProcessesArgs{
			PipelineId: testPipeline.Id,
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

    using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Oci = Pulumi.Oci;

return await Deployment.RunAsync(() => 
{
    var testPipelineRunningProcesses = Oci.GoldenGate.GetPipelineRunningProcesses.Invoke(new()
    {
        PipelineId = testPipeline.Id,
    });

});

    package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.oci.GoldenGate.GoldenGateFunctions;
import com.pulumi.oci.GoldenGate.inputs.GetPipelineRunningProcessesArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        final var testPipelineRunningProcesses = GoldenGateFunctions.getPipelineRunningProcesses(GetPipelineRunningProcessesArgs.builder()
            .pipelineId(testPipeline.id())
            .build());

    }
}

    variables:
  testPipelineRunningProcesses:
    fn::invoke:
      function: oci:GoldenGate:getPipelineRunningProcesses
      arguments:
        pipelineId: ${testPipeline.id}

    Using getPipelineRunningProcesses

    Two invocation forms are available. The direct form accepts plain arguments and either blocks until the result value is available, or returns a Promise-wrapped result. The output form accepts Input-wrapped arguments and returns an Output-wrapped result.

    function getPipelineRunningProcesses(args: GetPipelineRunningProcessesArgs, opts?: InvokeOptions): Promise<GetPipelineRunningProcessesResult>
function getPipelineRunningProcessesOutput(args: GetPipelineRunningProcessesOutputArgs, opts?: InvokeOptions): Output<GetPipelineRunningProcessesResult>
    def get_pipeline_running_processes(filters: Optional[Sequence[GetPipelineRunningProcessesFilter]] = None,
                                   pipeline_id: Optional[str] = None,
                                   opts: Optional[InvokeOptions] = None) -> GetPipelineRunningProcessesResult
def get_pipeline_running_processes_output(filters: Optional[pulumi.Input[Sequence[pulumi.Input[GetPipelineRunningProcessesFilterArgs]]]] = None,
                                   pipeline_id: Optional[pulumi.Input[str]] = None,
                                   opts: Optional[InvokeOptions] = None) -> Output[GetPipelineRunningProcessesResult]
    func GetPipelineRunningProcesses(ctx *Context, args *GetPipelineRunningProcessesArgs, opts ...InvokeOption) (*GetPipelineRunningProcessesResult, error)
func GetPipelineRunningProcessesOutput(ctx *Context, args *GetPipelineRunningProcessesOutputArgs, opts ...InvokeOption) GetPipelineRunningProcessesResultOutput

    > Note: This function is named GetPipelineRunningProcesses in the Go SDK.

    public static class GetPipelineRunningProcesses 
{
    public static Task<GetPipelineRunningProcessesResult> InvokeAsync(GetPipelineRunningProcessesArgs args, InvokeOptions? opts = null)
    public static Output<GetPipelineRunningProcessesResult> Invoke(GetPipelineRunningProcessesInvokeArgs args, InvokeOptions? opts = null)
}
    public static CompletableFuture<GetPipelineRunningProcessesResult> getPipelineRunningProcesses(GetPipelineRunningProcessesArgs args, InvokeOptions options)
public static Output<GetPipelineRunningProcessesResult> getPipelineRunningProcesses(GetPipelineRunningProcessesArgs args, InvokeOptions options)

    fn::invoke:
  function: oci:GoldenGate/getPipelineRunningProcesses:getPipelineRunningProcesses
  arguments:
    # arguments dictionary

    The following arguments are supported:

    pipelineId String
    The OCID of the pipeline created.
    filters List<Property Map>

    getPipelineRunningProcesses Result

    The following output properties are available:

    Id string
    The provider-assigned unique ID for this managed resource.
    PipelineId string
    PipelineRunningProcessCollections List<GetPipelineRunningProcessesPipelineRunningProcessCollection>
    The list of pipeline_running_process_collection.
    Filters List<GetPipelineRunningProcessesFilter>
    Id string
    The provider-assigned unique ID for this managed resource.
    PipelineId string
    PipelineRunningProcessCollections []GetPipelineRunningProcessesPipelineRunningProcessCollection
    The list of pipeline_running_process_collection.
    Filters []GetPipelineRunningProcessesFilter
    id String
    The provider-assigned unique ID for this managed resource.
    pipelineId String
    pipelineRunningProcessCollections List<GetPipelineRunningProcessesPipelineRunningProcessCollection>
    The list of pipeline_running_process_collection.
    filters List<GetPipelineRunningProcessesFilter>
    id string
    The provider-assigned unique ID for this managed resource.
    pipelineId string
    pipelineRunningProcessCollections GetPipelineRunningProcessesPipelineRunningProcessCollection[]
    The list of pipeline_running_process_collection.
    filters GetPipelineRunningProcessesFilter[]
    id str
    The provider-assigned unique ID for this managed resource.
    pipeline_id str
    pipeline_running_process_collections Sequence[GetPipelineRunningProcessesPipelineRunningProcessCollection]
    The list of pipeline_running_process_collection.
    filters Sequence[GetPipelineRunningProcessesFilter]
    id String
    The provider-assigned unique ID for this managed resource.
    pipelineId String
    pipelineRunningProcessCollections List<Property Map>
    The list of pipeline_running_process_collection.
    filters List<Property Map>

    Supporting Types

    GetPipelineRunningProcessesFilter

    Name string
    An object's Display Name.
    Values List<string>
    Regex bool
    Name string
    An object's Display Name.
    Values []string
    Regex bool
    name String
    An object's Display Name.
    values List<String>
    regex Boolean
    name string
    An object's Display Name.
    values string[]
    regex boolean
    name str
    An object's Display Name.
    values Sequence[str]
    regex bool
    name String
    An object's Display Name.
    values List<String>
    regex Boolean

    GetPipelineRunningProcessesPipelineRunningProcessCollection

    Items List<GetPipelineRunningProcessesPipelineRunningProcessCollectionItem>
    The list of replication processes and their details.
    Items []GetPipelineRunningProcessesPipelineRunningProcessCollectionItem
    The list of replication processes and their details.
    items List<GetPipelineRunningProcessesPipelineRunningProcessCollectionItem>
    The list of replication processes and their details.
    items GetPipelineRunningProcessesPipelineRunningProcessCollectionItem[]
    The list of replication processes and their details.
    items Sequence[GetPipelineRunningProcessesPipelineRunningProcessCollectionItem]
    The list of replication processes and their details.
    items List<Property Map>
    The list of replication processes and their details.

    GetPipelineRunningProcessesPipelineRunningProcessCollectionItem

    LastRecordLagInSeconds double
    The latency, in seconds, of a process running in a replication. This option applies when retrieving running processes.
    Name string
    An object's Display Name.
    ProcessType string
    The type of process running in a replication. For example, Extract or Replicat. This option applies when retrieving running processes.
    Status string
    The status of the Extract or Replicat process. This option applies when retrieving running processes.
    TimeLastProcessed string
    The date and time the last record was processed by an Extract or Replicat. This option applies when retrieving running processes. The format is defined by RFC3339, such as 2024-07-25T21:10:29.600Z.
    LastRecordLagInSeconds float64
    The latency, in seconds, of a process running in a replication. This option applies when retrieving running processes.
    Name string
    An object's Display Name.
    ProcessType string
    The type of process running in a replication. For example, Extract or Replicat. This option applies when retrieving running processes.
    Status string
    The status of the Extract or Replicat process. This option applies when retrieving running processes.
    TimeLastProcessed string
    The date and time the last record was processed by an Extract or Replicat. This option applies when retrieving running processes. The format is defined by RFC3339, such as 2024-07-25T21:10:29.600Z.
    lastRecordLagInSeconds Double
    The latency, in seconds, of a process running in a replication. This option applies when retrieving running processes.
    name String
    An object's Display Name.
    processType String
    The type of process running in a replication. For example, Extract or Replicat. This option applies when retrieving running processes.
    status String
    The status of the Extract or Replicat process. This option applies when retrieving running processes.
    timeLastProcessed String
    The date and time the last record was processed by an Extract or Replicat. This option applies when retrieving running processes. The format is defined by RFC3339, such as 2024-07-25T21:10:29.600Z.
    lastRecordLagInSeconds number
    The latency, in seconds, of a process running in a replication. This option applies when retrieving running processes.
    name string
    An object's Display Name.
    processType string
    The type of process running in a replication. For example, Extract or Replicat. This option applies when retrieving running processes.
    status string
    The status of the Extract or Replicat process. This option applies when retrieving running processes.
    timeLastProcessed string
    The date and time the last record was processed by an Extract or Replicat. This option applies when retrieving running processes. The format is defined by RFC3339, such as 2024-07-25T21:10:29.600Z.
    last_record_lag_in_seconds float
    The latency, in seconds, of a process running in a replication. This option applies when retrieving running processes.
    name str
    An object's Display Name.
    process_type str
    The type of process running in a replication. For example, Extract or Replicat. This option applies when retrieving running processes.
    status str
    The status of the Extract or Replicat process. This option applies when retrieving running processes.
    time_last_processed str
    The date and time the last record was processed by an Extract or Replicat. This option applies when retrieving running processes. The format is defined by RFC3339, such as 2024-07-25T21:10:29.600Z.
    lastRecordLagInSeconds Number
    The latency, in seconds, of a process running in a replication. This option applies when retrieving running processes.
    name String
    An object's Display Name.
    processType String
    The type of process running in a replication. For example, Extract or Replicat. This option applies when retrieving running processes.
    status String
    The status of the Extract or Replicat process. This option applies when retrieving running processes.
    timeLastProcessed String
    The date and time the last record was processed by an Extract or Replicat. This option applies when retrieving running processes. The format is defined by RFC3339, such as 2024-07-25T21:10:29.600Z.

    Package Details

    Repository
    oci pulumi/pulumi-oci
    License
    Apache-2.0
    Notes
    This Pulumi package is based on the oci Terraform Provider.
    oci logo
    Oracle Cloud Infrastructure v3.10.0 published on Wednesday, Nov 5, 2025 by Pulumi
    pulumi/pulumi-oci
      Meet Neo: Your AI Platform Teammate