Aiven

Pulumi Official
Package maintained by Pulumi
v5.2.0 published on Wednesday, Jul 20, 2022 by Pulumi

getMirrorMakerReplicationFlow

The MirrorMaker 2 Replication Flow data source provides information about the existing MirrorMaker 2 Replication Flow on Aiven Cloud.

Example Usage

using Pulumi;
using Aiven = Pulumi.Aiven;

class MyStack : Stack
{
    public MyStack()
    {
        var f1 = Output.Create(Aiven.GetMirrorMakerReplicationFlow.InvokeAsync(new Aiven.GetMirrorMakerReplicationFlowArgs
        {
            Project = aiven_project.Kafka_mm_project1.Project,
            ServiceName = aiven_service.Mm.Service_name,
            SourceCluster = aiven_service.Source.Service_name,
            TargetCluster = aiven_service.Target.Service_name,
        }));
    }

}
package main

import (
	"github.com/pulumi/pulumi-aiven/sdk/v5/go/aiven"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := aiven.LookupMirrorMakerReplicationFlow(ctx, &GetMirrorMakerReplicationFlowArgs{
			Project:       aiven_project.Kafka - mm - project1.Project,
			ServiceName:   aiven_service.Mm.Service_name,
			SourceCluster: aiven_service.Source.Service_name,
			TargetCluster: aiven_service.Target.Service_name,
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}
package generated_program;

import java.util.*;
import java.io.*;
import java.nio.*;
import com.pulumi.*;

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

    public static void stack(Context ctx) {
        final var f1 = Output.of(AivenFunctions.getMirrorMakerReplicationFlow(GetMirrorMakerReplicationFlowArgs.builder()
            .project(aiven_project.kafka-mm-project1().project())
            .serviceName(aiven_service.mm().service_name())
            .sourceCluster(aiven_service.source().service_name())
            .targetCluster(aiven_service.target().service_name())
            .build()));

    }
}
import pulumi
import pulumi_aiven as aiven

f1 = aiven.get_mirror_maker_replication_flow(project=aiven_project["kafka-mm-project1"]["project"],
    service_name=aiven_service["mm"]["service_name"],
    source_cluster=aiven_service["source"]["service_name"],
    target_cluster=aiven_service["target"]["service_name"])
import * as pulumi from "@pulumi/pulumi";
import * as aiven from "@pulumi/aiven";

const f1 = aiven.getMirrorMakerReplicationFlow({
    project: aiven_project["kafka-mm-project1"].project,
    serviceName: aiven_service.mm.service_name,
    sourceCluster: aiven_service.source.service_name,
    targetCluster: aiven_service.target.service_name,
});
variables:
  f1:
    Fn::Invoke:
      Function: aiven:getMirrorMakerReplicationFlow
      Arguments:
        project: ${aiven_project"kafka-mm-project1"[%!s(MISSING)].project}
        serviceName: ${aiven_service.mm.service_name}
        sourceCluster: ${aiven_service.source.service_name}
        targetCluster: ${aiven_service.target.service_name}

Using getMirrorMakerReplicationFlow

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 getMirrorMakerReplicationFlow(args: GetMirrorMakerReplicationFlowArgs, opts?: InvokeOptions): Promise<GetMirrorMakerReplicationFlowResult>
function getMirrorMakerReplicationFlowOutput(args: GetMirrorMakerReplicationFlowOutputArgs, opts?: InvokeOptions): Output<GetMirrorMakerReplicationFlowResult>
def get_mirror_maker_replication_flow(project: Optional[str] = None,
                                      service_name: Optional[str] = None,
                                      source_cluster: Optional[str] = None,
                                      target_cluster: Optional[str] = None,
                                      opts: Optional[InvokeOptions] = None) -> GetMirrorMakerReplicationFlowResult
def get_mirror_maker_replication_flow_output(project: Optional[pulumi.Input[str]] = None,
                                      service_name: Optional[pulumi.Input[str]] = None,
                                      source_cluster: Optional[pulumi.Input[str]] = None,
                                      target_cluster: Optional[pulumi.Input[str]] = None,
                                      opts: Optional[InvokeOptions] = None) -> Output[GetMirrorMakerReplicationFlowResult]
func LookupMirrorMakerReplicationFlow(ctx *Context, args *LookupMirrorMakerReplicationFlowArgs, opts ...InvokeOption) (*LookupMirrorMakerReplicationFlowResult, error)
func LookupMirrorMakerReplicationFlowOutput(ctx *Context, args *LookupMirrorMakerReplicationFlowOutputArgs, opts ...InvokeOption) LookupMirrorMakerReplicationFlowResultOutput

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

public static class GetMirrorMakerReplicationFlow 
{
    public static Task<GetMirrorMakerReplicationFlowResult> InvokeAsync(GetMirrorMakerReplicationFlowArgs args, InvokeOptions? opts = null)
    public static Output<GetMirrorMakerReplicationFlowResult> Invoke(GetMirrorMakerReplicationFlowInvokeArgs args, InvokeOptions? opts = null)
}
public static CompletableFuture<GetMirrorMakerReplicationFlowResult> getMirrorMakerReplicationFlow(GetMirrorMakerReplicationFlowArgs args, InvokeOptions options)
// Output-based functions aren't available in Java yet
Fn::Invoke:
  Function: aiven:index/getMirrorMakerReplicationFlow:getMirrorMakerReplicationFlow
  Arguments:
    # Arguments dictionary

The following arguments are supported:

getMirrorMakerReplicationFlow Result

The following output properties are available:

EmitHeartbeatsEnabled bool
Enable bool
Id string

The provider-assigned unique ID for this managed resource.

Project string
ReplicationPolicyClass string
ServiceName string
SourceCluster string
SyncGroupOffsetsEnabled bool
SyncGroupOffsetsIntervalSeconds int
TargetCluster string
Topics List<string>
TopicsBlacklists List<string>
EmitHeartbeatsEnabled bool
Enable bool
Id string

The provider-assigned unique ID for this managed resource.

Project string
ReplicationPolicyClass string
ServiceName string
SourceCluster string
SyncGroupOffsetsEnabled bool
SyncGroupOffsetsIntervalSeconds int
TargetCluster string
Topics []string
TopicsBlacklists []string
emitHeartbeatsEnabled Boolean
enable Boolean
id String

The provider-assigned unique ID for this managed resource.

project String
replicationPolicyClass String
serviceName String
sourceCluster String
syncGroupOffsetsEnabled Boolean
syncGroupOffsetsIntervalSeconds Integer
targetCluster String
topics List<String>
topicsBlacklists List<String>
emitHeartbeatsEnabled boolean
enable boolean
id string

The provider-assigned unique ID for this managed resource.

project string
replicationPolicyClass string
serviceName string
sourceCluster string
syncGroupOffsetsEnabled boolean
syncGroupOffsetsIntervalSeconds number
targetCluster string
topics string[]
topicsBlacklists string[]
emit_heartbeats_enabled bool
enable bool
id str

The provider-assigned unique ID for this managed resource.

project str
replication_policy_class str
service_name str
source_cluster str
sync_group_offsets_enabled bool
sync_group_offsets_interval_seconds int
target_cluster str
topics Sequence[str]
topics_blacklists Sequence[str]
emitHeartbeatsEnabled Boolean
enable Boolean
id String

The provider-assigned unique ID for this managed resource.

project String
replicationPolicyClass String
serviceName String
sourceCluster String
syncGroupOffsetsEnabled Boolean
syncGroupOffsetsIntervalSeconds Number
targetCluster String
topics List<String>
topicsBlacklists List<String>

Package Details

Repository
https://github.com/pulumi/pulumi-aiven
License
Apache-2.0
Notes

This Pulumi package is based on the aiven Terraform Provider.