Broker

class Broker : KotlinCustomResource

Instance broker resource Uses Azure REST API version 2024-07-01-preview. Other available API versions: 2024-08-15-preview, 2024-09-15-preview, 2024-11-01, 2025-04-01.

Example Usage

Broker_CreateOrUpdate

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AzureNative = Pulumi.AzureNative;
return await Deployment.RunAsync(() =>
{
var broker = new AzureNative.IoTOperations.Broker("broker", new()
{
BrokerName = "aio-broker",
ExtendedLocation = new AzureNative.IoTOperations.Inputs.ExtendedLocationArgs
{
Name = "ycsyubcxttlusbhfdqaynmkaatnbyv",
Type = AzureNative.IoTOperations.ExtendedLocationType.CustomLocation,
},
InstanceName = "aio-instance",
Properties = new AzureNative.IoTOperations.Inputs.BrokerPropertiesArgs
{
Advanced = new AzureNative.IoTOperations.Inputs.AdvancedSettingsArgs
{
EncryptInternalTraffic = AzureNative.IoTOperations.OperationalMode.Enabled,
},
Cardinality = new AzureNative.IoTOperations.Inputs.CardinalityArgs
{
BackendChain = new AzureNative.IoTOperations.Inputs.BackendChainArgs
{
Partitions = 2,
RedundancyFactor = 2,
Workers = 2,
},
Frontend = new AzureNative.IoTOperations.Inputs.FrontendArgs
{
Replicas = 2,
Workers = 2,
},
},
Diagnostics = new AzureNative.IoTOperations.Inputs.BrokerDiagnosticsArgs
{
Logs = new AzureNative.IoTOperations.Inputs.DiagnosticsLogsArgs
{
Level = "info",
},
Metrics = new AzureNative.IoTOperations.Inputs.MetricsArgs
{
PrometheusPort = 9600,
},
SelfCheck = new AzureNative.IoTOperations.Inputs.SelfCheckArgs
{
IntervalSeconds = 30,
Mode = AzureNative.IoTOperations.OperationalMode.Enabled,
TimeoutSeconds = 15,
},
Traces = new AzureNative.IoTOperations.Inputs.TracesArgs
{
CacheSizeMegabytes = 16,
Mode = AzureNative.IoTOperations.OperationalMode.Enabled,
SelfTracing = new AzureNative.IoTOperations.Inputs.SelfTracingArgs
{
IntervalSeconds = 30,
Mode = AzureNative.IoTOperations.OperationalMode.Enabled,
},
SpanChannelCapacity = 1000,
},
},
GenerateResourceLimits = new AzureNative.IoTOperations.Inputs.GenerateResourceLimitsArgs
{
Cpu = AzureNative.IoTOperations.OperationalMode.Disabled,
},
MemoryProfile = AzureNative.IoTOperations.BrokerMemoryProfile.Medium,
},
ResourceGroupName = "rgiotoperations",
});
});
package main
import (
iotoperations "github.com/pulumi/pulumi-azure-native-sdk/iotoperations/v2"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := iotoperations.NewBroker(ctx, "broker", &iotoperations.BrokerArgs{
BrokerName: pulumi.String("aio-broker"),
ExtendedLocation: &iotoperations.ExtendedLocationArgs{
Name: pulumi.String("ycsyubcxttlusbhfdqaynmkaatnbyv"),
Type: pulumi.String(iotoperations.ExtendedLocationTypeCustomLocation),
},
InstanceName: pulumi.String("aio-instance"),
Properties: &iotoperations.BrokerPropertiesArgs{
Advanced: &iotoperations.AdvancedSettingsArgs{
EncryptInternalTraffic: pulumi.String(iotoperations.OperationalModeEnabled),
},
Cardinality: &iotoperations.CardinalityArgs{
BackendChain: &iotoperations.BackendChainArgs{
Partitions: pulumi.Int(2),
RedundancyFactor: pulumi.Int(2),
Workers: pulumi.Int(2),
},
Frontend: &iotoperations.FrontendArgs{
Replicas: pulumi.Int(2),
Workers: pulumi.Int(2),
},
},
Diagnostics: &iotoperations.BrokerDiagnosticsArgs{
Logs: &iotoperations.DiagnosticsLogsArgs{
Level: pulumi.String("info"),
},
Metrics: &iotoperations.MetricsArgs{
PrometheusPort: pulumi.Int(9600),
},
SelfCheck: &iotoperations.SelfCheckArgs{
IntervalSeconds: pulumi.Int(30),
Mode: pulumi.String(iotoperations.OperationalModeEnabled),
TimeoutSeconds: pulumi.Int(15),
},
Traces: &iotoperations.TracesArgs{
CacheSizeMegabytes: pulumi.Int(16),
Mode: pulumi.String(iotoperations.OperationalModeEnabled),
SelfTracing: &iotoperations.SelfTracingArgs{
IntervalSeconds: pulumi.Int(30),
Mode: pulumi.String(iotoperations.OperationalModeEnabled),
},
SpanChannelCapacity: pulumi.Int(1000),
},
},
GenerateResourceLimits: &iotoperations.GenerateResourceLimitsArgs{
Cpu: pulumi.String(iotoperations.OperationalModeDisabled),
},
MemoryProfile: pulumi.String(iotoperations.BrokerMemoryProfileMedium),
},
ResourceGroupName: pulumi.String("rgiotoperations"),
})
if err != nil {
return err
}
return nil
})
}
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azurenative.iotoperations.Broker;
import com.pulumi.azurenative.iotoperations.BrokerArgs;
import com.pulumi.azurenative.iotoperations.inputs.ExtendedLocationArgs;
import com.pulumi.azurenative.iotoperations.inputs.BrokerPropertiesArgs;
import com.pulumi.azurenative.iotoperations.inputs.AdvancedSettingsArgs;
import com.pulumi.azurenative.iotoperations.inputs.CardinalityArgs;
import com.pulumi.azurenative.iotoperations.inputs.BackendChainArgs;
import com.pulumi.azurenative.iotoperations.inputs.FrontendArgs;
import com.pulumi.azurenative.iotoperations.inputs.BrokerDiagnosticsArgs;
import com.pulumi.azurenative.iotoperations.inputs.DiagnosticsLogsArgs;
import com.pulumi.azurenative.iotoperations.inputs.MetricsArgs;
import com.pulumi.azurenative.iotoperations.inputs.SelfCheckArgs;
import com.pulumi.azurenative.iotoperations.inputs.TracesArgs;
import com.pulumi.azurenative.iotoperations.inputs.SelfTracingArgs;
import com.pulumi.azurenative.iotoperations.inputs.GenerateResourceLimitsArgs;
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) {
var broker = new Broker("broker", BrokerArgs.builder()
.brokerName("aio-broker")
.extendedLocation(ExtendedLocationArgs.builder()
.name("ycsyubcxttlusbhfdqaynmkaatnbyv")
.type("CustomLocation")
.build())
.instanceName("aio-instance")
.properties(BrokerPropertiesArgs.builder()
.advanced(AdvancedSettingsArgs.builder()
.encryptInternalTraffic("Enabled")
.build())
.cardinality(CardinalityArgs.builder()
.backendChain(BackendChainArgs.builder()
.partitions(2)
.redundancyFactor(2)
.workers(2)
.build())
.frontend(FrontendArgs.builder()
.replicas(2)
.workers(2)
.build())
.build())
.diagnostics(BrokerDiagnosticsArgs.builder()
.logs(DiagnosticsLogsArgs.builder()
.level("info")
.build())
.metrics(MetricsArgs.builder()
.prometheusPort(9600)
.build())
.selfCheck(SelfCheckArgs.builder()
.intervalSeconds(30)
.mode("Enabled")
.timeoutSeconds(15)
.build())
.traces(TracesArgs.builder()
.cacheSizeMegabytes(16)
.mode("Enabled")
.selfTracing(SelfTracingArgs.builder()
.intervalSeconds(30)
.mode("Enabled")
.build())
.spanChannelCapacity(1000)
.build())
.build())
.generateResourceLimits(GenerateResourceLimitsArgs.builder()
.cpu("Disabled")
.build())
.memoryProfile("Medium")
.build())
.resourceGroupName("rgiotoperations")
.build());
}
}

Import

An existing resource can be imported using its type token, name, and identifier, e.g.

$ pulumi import azure-native:iotoperations:Broker dnpky /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.IoTOperations/instances/{instanceName}/brokers/{brokerName}

Properties

Link copied to clipboard

Edge location of the resource.

Link copied to clipboard
val id: Output<String>
Link copied to clipboard
val name: Output<String>

The name of the resource

Link copied to clipboard

The resource-specific properties for this resource.

Link copied to clipboard
val pulumiChildResources: Set<KotlinResource>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard

Azure Resource Manager metadata containing createdBy and modifiedBy information.

Link copied to clipboard
val type: Output<String>

The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"

Link copied to clipboard
val urn: Output<String>