Aiven
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:
- Project string
- Service
Name string - Source
Cluster string - Target
Cluster string
- Project string
- Service
Name string - Source
Cluster string - Target
Cluster string
- project String
- service
Name String - source
Cluster String - target
Cluster String
- project string
- service
Name string - source
Cluster string - target
Cluster string
- project str
- service_
name str - source_
cluster str - target_
cluster str
- project String
- service
Name String - source
Cluster String - target
Cluster String
getMirrorMakerReplicationFlow Result
The following output properties are available:
- Emit
Heartbeats boolEnabled - Enable bool
- Id string
The provider-assigned unique ID for this managed resource.
- Project string
- Replication
Policy stringClass - Service
Name string - Source
Cluster string - Sync
Group boolOffsets Enabled - Sync
Group intOffsets Interval Seconds - Target
Cluster string - Topics List<string>
- Topics
Blacklists List<string>
- Emit
Heartbeats boolEnabled - Enable bool
- Id string
The provider-assigned unique ID for this managed resource.
- Project string
- Replication
Policy stringClass - Service
Name string - Source
Cluster string - Sync
Group boolOffsets Enabled - Sync
Group intOffsets Interval Seconds - Target
Cluster string - Topics []string
- Topics
Blacklists []string
- emit
Heartbeats BooleanEnabled - enable Boolean
- id String
The provider-assigned unique ID for this managed resource.
- project String
- replication
Policy StringClass - service
Name String - source
Cluster String - sync
Group BooleanOffsets Enabled - sync
Group IntegerOffsets Interval Seconds - target
Cluster String - topics List<String>
- topics
Blacklists List<String>
- emit
Heartbeats booleanEnabled - enable boolean
- id string
The provider-assigned unique ID for this managed resource.
- project string
- replication
Policy stringClass - service
Name string - source
Cluster string - sync
Group booleanOffsets Enabled - sync
Group numberOffsets Interval Seconds - target
Cluster string - topics string[]
- topics
Blacklists string[]
- emit_
heartbeats_ boolenabled - enable bool
- id str
The provider-assigned unique ID for this managed resource.
- project str
- replication_
policy_ strclass - service_
name str - source_
cluster str - sync_
group_ booloffsets_ enabled - sync_
group_ intoffsets_ interval_ seconds - target_
cluster str - topics Sequence[str]
- topics_
blacklists Sequence[str]
- emit
Heartbeats BooleanEnabled - enable Boolean
- id String
The provider-assigned unique ID for this managed resource.
- project String
- replication
Policy StringClass - service
Name String - source
Cluster String - sync
Group BooleanOffsets Enabled - sync
Group NumberOffsets Interval Seconds - target
Cluster String - topics List<String>
- topics
Blacklists 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.