1. Packages
  2. Oracle Cloud Infrastructure
  3. API Docs
  4. GoldenGate
  5. getPipelineRunningProcesses
Oracle Cloud Infrastructure v2.29.0 published on Wednesday, Apr 9, 2025 by Pulumi

oci.GoldenGate.getPipelineRunningProcesses

Explore with Pulumi AI

Oracle Cloud Infrastructure v2.29.0 published on Wednesday, Apr 9, 2025 by Pulumi

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 extracts/replicats.

Example Usage

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

const testPipelineRunningProcesses = oci.GoldenGate.getPipelineRunningProcesses({
    pipelineId: testPipeline.id,
});
Copy
import pulumi
import pulumi_oci as oci

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

import (
	"github.com/pulumi/pulumi-oci/sdk/v2/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
	})
}
Copy
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,
    });

});
Copy
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());

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

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>
Copy
def get_pipeline_running_processes(filters: Optional[Sequence[_goldengate.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[_goldengate.GetPipelineRunningProcessesFilterArgs]]]] = None,
                                   pipeline_id: Optional[pulumi.Input[str]] = None,
                                   opts: Optional[InvokeOptions] = None) -> Output[GetPipelineRunningProcessesResult]
Copy
func GetPipelineRunningProcesses(ctx *Context, args *GetPipelineRunningProcessesArgs, opts ...InvokeOption) (*GetPipelineRunningProcessesResult, error)
func GetPipelineRunningProcessesOutput(ctx *Context, args *GetPipelineRunningProcessesOutputArgs, opts ...InvokeOption) GetPipelineRunningProcessesResultOutput
Copy

> 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)
}
Copy
public static CompletableFuture<GetPipelineRunningProcessesResult> getPipelineRunningProcesses(GetPipelineRunningProcessesArgs args, InvokeOptions options)
public static Output<GetPipelineRunningProcessesResult> getPipelineRunningProcesses(GetPipelineRunningProcessesArgs args, InvokeOptions options)
Copy
fn::invoke:
  function: oci:GoldenGate/getPipelineRunningProcesses:getPipelineRunningProcesses
  arguments:
    # arguments dictionary
Copy

The following arguments are supported:

PipelineId This property is required. string
The OCID of the pipeline created.
Filters Changes to this property will trigger replacement. List<GetPipelineRunningProcessesFilter>
PipelineId This property is required. string
The OCID of the pipeline created.
Filters Changes to this property will trigger replacement. []GetPipelineRunningProcessesFilter
pipelineId This property is required. String
The OCID of the pipeline created.
filters Changes to this property will trigger replacement. List<GetPipelineRunningProcessesFilter>
pipelineId This property is required. string
The OCID of the pipeline created.
filters Changes to this property will trigger replacement. GetPipelineRunningProcessesFilter[]
pipeline_id This property is required. str
The OCID of the pipeline created.
filters Changes to this property will trigger replacement. Sequence[goldengate.GetPipelineRunningProcessesFilter]
pipelineId This property is required. String
The OCID of the pipeline created.
filters Changes to this property will trigger replacement. 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 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 This property is required. string
An object's Display Name.
Values This property is required. List<string>
Regex bool
Name This property is required. string
An object's Display Name.
Values This property is required. []string
Regex bool
name This property is required. String
An object's Display Name.
values This property is required. List<String>
regex Boolean
name This property is required. string
An object's Display Name.
values This property is required. string[]
regex boolean
name This property is required. str
An object's Display Name.
values This property is required. Sequence[str]
regex bool
name This property is required. String
An object's Display Name.
values This property is required. List<String>
regex Boolean

GetPipelineRunningProcessesPipelineRunningProcessCollection

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

GetPipelineRunningProcessesPipelineRunningProcessCollectionItem

LastRecordLagInSeconds This property is required. double
The latency, in seconds, of a process running in a replication. This option applies when retrieving running processes.
Name This property is required. string
An object's Display Name.
ProcessType This property is required. string
The type of process running in a replication. For example, Extract or Replicat. This option applies when retrieving running processes.
Status This property is required. string
The status of the Extract or Replicat process. This option applies when retrieving running processes.
TimeLastProcessed This property is required. 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 This property is required. float64
The latency, in seconds, of a process running in a replication. This option applies when retrieving running processes.
Name This property is required. string
An object's Display Name.
ProcessType This property is required. string
The type of process running in a replication. For example, Extract or Replicat. This option applies when retrieving running processes.
Status This property is required. string
The status of the Extract or Replicat process. This option applies when retrieving running processes.
TimeLastProcessed This property is required. 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 This property is required. Double
The latency, in seconds, of a process running in a replication. This option applies when retrieving running processes.
name This property is required. String
An object's Display Name.
processType This property is required. String
The type of process running in a replication. For example, Extract or Replicat. This option applies when retrieving running processes.
status This property is required. String
The status of the Extract or Replicat process. This option applies when retrieving running processes.
timeLastProcessed This property is required. 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 This property is required. number
The latency, in seconds, of a process running in a replication. This option applies when retrieving running processes.
name This property is required. string
An object's Display Name.
processType This property is required. string
The type of process running in a replication. For example, Extract or Replicat. This option applies when retrieving running processes.
status This property is required. string
The status of the Extract or Replicat process. This option applies when retrieving running processes.
timeLastProcessed This property is required. 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 This property is required. float
The latency, in seconds, of a process running in a replication. This option applies when retrieving running processes.
name This property is required. str
An object's Display Name.
process_type This property is required. str
The type of process running in a replication. For example, Extract or Replicat. This option applies when retrieving running processes.
status This property is required. str
The status of the Extract or Replicat process. This option applies when retrieving running processes.
time_last_processed This property is required. 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 This property is required. Number
The latency, in seconds, of a process running in a replication. This option applies when retrieving running processes.
name This property is required. String
An object's Display Name.
processType This property is required. String
The type of process running in a replication. For example, Extract or Replicat. This option applies when retrieving running processes.
status This property is required. String
The status of the Extract or Replicat process. This option applies when retrieving running processes.
timeLastProcessed This property is required. 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.
Oracle Cloud Infrastructure v2.29.0 published on Wednesday, Apr 9, 2025 by Pulumi