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}