getServiceIntegration

# Service Integration Data Source

The Service Integration data source provides information about the existing Aiven Service Integration.

Service Integration defines an integration between two Aiven services or between Aiven service and an external integration endpoint. Integration could be for example sending metrics from Kafka service to an InfluxDB service, getting metrics from an InfluxDB service to a Grafana service to show dashboards, sending logs from any service to Elasticsearch, etc.

Example Usage

using Pulumi;
using Aiven = Pulumi.Aiven;

class MyStack : Stack
{
    public MyStack()
    {
        var myintegration = Output.Create(Aiven.GetServiceIntegration.InvokeAsync(new Aiven.GetServiceIntegrationArgs
        {
            DestinationServiceName = "<DESTINATION_SERVICE_NAME>",
            IntegrationType = "datadog",
            Project = aiven_project.Myproject.Project,
            SourceServiceName = "<SOURCE_SERVICE_NAME>",
        }));
    }

}

package main

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

func main() {
    pulumi.Run(func(ctx *pulumi.Context) error {
        _, err := aiven.LookupServiceIntegration(ctx, &aiven.LookupServiceIntegrationArgs{
            DestinationServiceName: "<DESTINATION_SERVICE_NAME>",
            IntegrationType:        "datadog",
            Project:                aiven_project.Myproject.Project,
            SourceServiceName:      "<SOURCE_SERVICE_NAME>",
        }, nil)
        if err != nil {
            return err
        }
        return nil
    })
}

import pulumi
import pulumi_aiven as aiven

myintegration = aiven.get_service_integration(destination_service_name="<DESTINATION_SERVICE_NAME>",
    integration_type="datadog",
    project=aiven_project["myproject"]["project"],
    source_service_name="<SOURCE_SERVICE_NAME>")

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

const myintegration = aiven_project_myproject.project.apply(project => aiven.getServiceIntegration({
    destinationServiceName: "<DESTINATION_SERVICE_NAME>",
    integrationType: "datadog",
    project: project,
    sourceServiceName: "<SOURCE_SERVICE_NAME>",
}, { async: true }));

Using getServiceIntegration

function getServiceIntegration(args: GetServiceIntegrationArgs, opts?: InvokeOptions): Promise<GetServiceIntegrationResult>

def get_service_integration(dashboard_user_config: Optional[GetServiceIntegrationDashboardUserConfigArgs] = None, datadog_user_config: Optional[GetServiceIntegrationDatadogUserConfigArgs] = None, destination_endpoint_id: Optional[str] = None, destination_service_name: Optional[str] = None, external_aws_cloudwatch_logs_user_config: Optional[GetServiceIntegrationExternalAwsCloudwatchLogsUserConfigArgs] = None, external_elasticsearch_logs_user_config: Optional[GetServiceIntegrationExternalElasticsearchLogsUserConfigArgs] = None, external_google_cloud_logging_user_config: Optional[GetServiceIntegrationExternalGoogleCloudLoggingUserConfigArgs] = None, integration_type: Optional[str] = None, kafka_connect_user_config: Optional[GetServiceIntegrationKafkaConnectUserConfigArgs] = None, kafka_logs_user_config: Optional[GetServiceIntegrationKafkaLogsUserConfigArgs] = None, kafka_mirrormaker_user_config: Optional[GetServiceIntegrationKafkaMirrormakerUserConfigArgs] = None, logs_user_config: Optional[GetServiceIntegrationLogsUserConfigArgs] = None, m3aggregator_user_config: Optional[GetServiceIntegrationM3aggregatorUserConfigArgs] = None, m3coordinator_user_config: Optional[GetServiceIntegrationM3coordinatorUserConfigArgs] = None, metrics_user_config: Optional[GetServiceIntegrationMetricsUserConfigArgs] = None, mirrormaker_user_config: Optional[GetServiceIntegrationMirrormakerUserConfigArgs] = None, project: Optional[str] = None, prometheus_user_config: Optional[GetServiceIntegrationPrometheusUserConfigArgs] = None, read_replica_user_config: Optional[GetServiceIntegrationReadReplicaUserConfigArgs] = None, rsyslog_user_config: Optional[GetServiceIntegrationRsyslogUserConfigArgs] = None, schema_registry_proxy_user_config: Optional[GetServiceIntegrationSchemaRegistryProxyUserConfigArgs] = None, signalfx_user_config: Optional[GetServiceIntegrationSignalfxUserConfigArgs] = None, source_endpoint_id: Optional[str] = None, source_service_name: Optional[str] = None, opts: Optional[InvokeOptions] = None) -> GetServiceIntegrationResult

func LookupServiceIntegration(ctx *Context, args *LookupServiceIntegrationArgs, opts ...InvokeOption) (*LookupServiceIntegrationResult, error)

Note: This function is named LookupServiceIntegration in the Go SDK.

public static class GetServiceIntegration {
    public static Task<GetServiceIntegrationResult> InvokeAsync(GetServiceIntegrationArgs args, InvokeOptions? opts = null)
}