Broker - Create Or Update

Service:

IoT Operations

API Version:

2024-11-01

Create a BrokerResource

PUT https://management.azure.com/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.IoTOperations/instances/{instanceName}/brokers/{brokerName}?api-version=2024-11-01

URI Parameters

Name	In	Required	Type	Description
brokerName	path	True	string	Name of broker. Regex pattern: ^[a-z0-9][a-z0-9-]*[a-z0-9]$
instanceName	path	True	string	Name of instance. Regex pattern: ^[a-z0-9][a-z0-9-]*[a-z0-9]$
resourceGroupName	path	True	string	The name of the resource group. The name is case insensitive.
subscriptionId	path	True	string uuid	The ID of the target subscription. The value must be an UUID.
api-version	query	True	string	The API version to use for this operation.

Request Body

Name	Required	Type	Description
extendedLocation	True	ExtendedLocation	Edge location of the resource.
properties		BrokerProperties	The resource-specific properties for this resource.

Responses

Name	Type	Description
200 OK	BrokerResource	Resource 'BrokerResource' update operation succeeded
201 Created	BrokerResource	Resource 'BrokerResource' create operation succeeded Headers Azure-AsyncOperation: string Retry-After: integer
Other Status Codes	ErrorResponse	An unexpected error response.

Security

azure_auth

Azure Active Directory OAuth2 Flow.

Type: oauth2
Flow: implicit
Authorization URL: https://login.microsoftonline.com/common/oauth2/authorize

Scopes

Name	Description
user_impersonation	impersonate your user account

Examples

Broker_CreateOrUpdate

Broker_CreateOrUpdate_Complex

Broker_CreateOrUpdate_Minimal

Broker_CreateOrUpdate_Simple

Broker_CreateOrUpdate

Sample request

HTTP

PUT https://management.azure.com/subscriptions/F8C729F9-DF9C-4743-848F-96EE433D8E53/resourceGroups/rgiotoperations/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123?api-version=2024-11-01

{
  "properties": {
    "advanced": {
      "clients": {
        "maxSessionExpirySeconds": 3859,
        "maxMessageExpirySeconds": 3263,
        "maxPacketSizeBytes": 3029,
        "subscriberQueueLimit": {
          "length": 6,
          "strategy": "None"
        },
        "maxReceiveMaximum": 2365,
        "maxKeepAliveSeconds": 3744
      },
      "encryptInternalTraffic": "Enabled",
      "internalCerts": {
        "duration": "bchrc",
        "renewBefore": "xkafmpgjfifkwwrhkswtopdnne",
        "privateKey": {
          "algorithm": "Ec256",
          "rotationPolicy": "Always"
        }
      }
    },
    "cardinality": {
      "backendChain": {
        "partitions": 11,
        "redundancyFactor": 5,
        "workers": 15
      },
      "frontend": {
        "replicas": 2,
        "workers": 6
      }
    },
    "diagnostics": {
      "logs": {
        "level": "rnmwokumdmebpmfxxxzvvjfdywotav"
      },
      "metrics": {
        "prometheusPort": 7581
      },
      "selfCheck": {
        "mode": "Enabled",
        "intervalSeconds": 158,
        "timeoutSeconds": 14
      },
      "traces": {
        "mode": "Enabled",
        "cacheSizeMegabytes": 28,
        "selfTracing": {
          "mode": "Enabled",
          "intervalSeconds": 22
        },
        "spanChannelCapacity": 1000
      }
    },
    "diskBackedMessageBuffer": {
      "maxSize": "500M",
      "ephemeralVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      },
      "persistentVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      }
    },
    "generateResourceLimits": {
      "cpu": "Enabled"
    },
    "memoryProfile": "Tiny"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  }
}

Java

import com.azure.resourcemanager.iotoperations.models.AdvancedSettings;
import com.azure.resourcemanager.iotoperations.models.BackendChain;
import com.azure.resourcemanager.iotoperations.models.BrokerDiagnostics;
import com.azure.resourcemanager.iotoperations.models.BrokerMemoryProfile;
import com.azure.resourcemanager.iotoperations.models.BrokerProperties;
import com.azure.resourcemanager.iotoperations.models.Cardinality;
import com.azure.resourcemanager.iotoperations.models.CertManagerCertOptions;
import com.azure.resourcemanager.iotoperations.models.CertManagerPrivateKey;
import com.azure.resourcemanager.iotoperations.models.ClientConfig;
import com.azure.resourcemanager.iotoperations.models.DiagnosticsLogs;
import com.azure.resourcemanager.iotoperations.models.DiskBackedMessageBuffer;
import com.azure.resourcemanager.iotoperations.models.ExtendedLocation;
import com.azure.resourcemanager.iotoperations.models.ExtendedLocationType;
import com.azure.resourcemanager.iotoperations.models.Frontend;
import com.azure.resourcemanager.iotoperations.models.GenerateResourceLimits;
import com.azure.resourcemanager.iotoperations.models.KubernetesReference;
import com.azure.resourcemanager.iotoperations.models.LocalKubernetesReference;
import com.azure.resourcemanager.iotoperations.models.Metrics;
import com.azure.resourcemanager.iotoperations.models.OperationalMode;
import com.azure.resourcemanager.iotoperations.models.OperatorValues;
import com.azure.resourcemanager.iotoperations.models.PrivateKeyAlgorithm;
import com.azure.resourcemanager.iotoperations.models.PrivateKeyRotationPolicy;
import com.azure.resourcemanager.iotoperations.models.SelfCheck;
import com.azure.resourcemanager.iotoperations.models.SelfTracing;
import com.azure.resourcemanager.iotoperations.models.SubscriberMessageDropStrategy;
import com.azure.resourcemanager.iotoperations.models.SubscriberQueueLimit;
import com.azure.resourcemanager.iotoperations.models.Traces;
import com.azure.resourcemanager.iotoperations.models.VolumeClaimResourceRequirements;
import com.azure.resourcemanager.iotoperations.models.VolumeClaimSpec;
import com.azure.resourcemanager.iotoperations.models.VolumeClaimSpecSelector;
import com.azure.resourcemanager.iotoperations.models.VolumeClaimSpecSelectorMatchExpressions;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;

/**
 * Samples for Broker CreateOrUpdate.
 */
public final class Main {
    /*
     * x-ms-original-file: 2024-11-01/Broker_CreateOrUpdate_MaximumSet_Gen.json
     */
    /**
     * Sample code: Broker_CreateOrUpdate.
     * 
     * @param manager Entry point to IoTOperationsManager.
     */
    public static void brokerCreateOrUpdate(com.azure.resourcemanager.iotoperations.IoTOperationsManager manager) {
        manager
            .brokers().define("resource-name123").withExistingInstance("rgiotoperations",
                "resource-name123")
            .withExtendedLocation(new ExtendedLocation().withName(
                "qmbrfwcpwwhggszhrdjv").withType(
                    ExtendedLocationType.CUSTOM_LOCATION))
            .withProperties(
                new BrokerProperties()
                    .withAdvanced(new AdvancedSettings()
                        .withClients(new ClientConfig().withMaxSessionExpirySeconds(3859)
                            .withMaxMessageExpirySeconds(3263).withMaxPacketSizeBytes(3029)
                            .withSubscriberQueueLimit(new SubscriberQueueLimit()
                                .withLength(6L).withStrategy(SubscriberMessageDropStrategy.NONE))
                            .withMaxReceiveMaximum(2365).withMaxKeepAliveSeconds(3744))
                        .withEncryptInternalTraffic(OperationalMode.ENABLED)
                        .withInternalCerts(new CertManagerCertOptions().withDuration("bchrc")
                            .withRenewBefore("xkafmpgjfifkwwrhkswtopdnne")
                            .withPrivateKey(new CertManagerPrivateKey().withAlgorithm(PrivateKeyAlgorithm.EC256)
                                .withRotationPolicy(PrivateKeyRotationPolicy.ALWAYS))))
                    .withCardinality(new Cardinality().withBackendChain(
                        new BackendChain().withPartitions(11).withRedundancyFactor(5).withWorkers(15))
                        .withFrontend(new Frontend().withReplicas(2).withWorkers(6)))
                    .withDiagnostics(new BrokerDiagnostics().withLogs(
                        new DiagnosticsLogs().withLevel("rnmwokumdmebpmfxxxzvvjfdywotav"))
                        .withMetrics(new Metrics().withPrometheusPort(7581))
                        .withSelfCheck(new SelfCheck().withMode(OperationalMode.ENABLED).withIntervalSeconds(158)
                            .withTimeoutSeconds(14))
                        .withTraces(new Traces().withMode(OperationalMode.ENABLED).withCacheSizeMegabytes(28)
                            .withSelfTracing(new SelfTracing()
                                .withMode(OperationalMode.ENABLED).withIntervalSeconds(22))
                            .withSpanChannelCapacity(1000)))
                    .withDiskBackedMessageBuffer(new DiskBackedMessageBuffer().withMaxSize("500M")
                        .withEphemeralVolumeClaimSpec(
                            new VolumeClaimSpec().withVolumeName("c").withVolumeMode("rxvpksjuuugqnqzeiprocknbn")
                                .withStorageClassName("sseyhrjptkhrqvpdpjmornkqvon")
                                .withAccessModes(Arrays.asList("nuluhigrbb"))
                                .withDataSource(new LocalKubernetesReference().withApiGroup("npqapyksvvpkohujx")
                                    .withKind("wazgyb").withName("cwhsgxxcxsyppoefm"))
                                .withDataSourceRef(new KubernetesReference()
                                    .withApiGroup("mnfnykznjjsoqpfsgdqioupt").withKind("odynqzekfzsnawrctaxg")
                                    .withName("envszivbbmixbyddzg").withNamespace("etcfzvxqd"))
                                .withResources(new VolumeClaimResourceRequirements()
                                    .withLimits(mapOf("key2719", "fakeTokenPlaceholder"))
                                    .withRequests(mapOf("key2909", "fakeTokenPlaceholder")))
                                .withSelector(new VolumeClaimSpecSelector()
                                    .withMatchExpressions(Arrays.asList(new VolumeClaimSpecSelectorMatchExpressions()
                                        .withKey("fakeTokenPlaceholder").withOperator(OperatorValues.IN)
                                        .withValues(Arrays.asList("slmpajlywqvuyknipgztsonqyybt"))))
                                    .withMatchLabels(mapOf("key6673", "fakeTokenPlaceholder"))))
                        .withPersistentVolumeClaimSpec(
                            new VolumeClaimSpec().withVolumeName("c").withVolumeMode("rxvpksjuuugqnqzeiprocknbn")
                                .withStorageClassName("sseyhrjptkhrqvpdpjmornkqvon")
                                .withAccessModes(Arrays.asList("nuluhigrbb"))
                                .withDataSource(new LocalKubernetesReference().withApiGroup("npqapyksvvpkohujx")
                                    .withKind("wazgyb").withName("cwhsgxxcxsyppoefm"))
                                .withDataSourceRef(new KubernetesReference()
                                    .withApiGroup("mnfnykznjjsoqpfsgdqioupt").withKind("odynqzekfzsnawrctaxg")
                                    .withName("envszivbbmixbyddzg").withNamespace("etcfzvxqd"))
                                .withResources(new VolumeClaimResourceRequirements()
                                    .withLimits(mapOf("key2719", "fakeTokenPlaceholder"))
                                    .withRequests(mapOf("key2909", "fakeTokenPlaceholder")))
                                .withSelector(new VolumeClaimSpecSelector()
                                    .withMatchExpressions(Arrays.asList(new VolumeClaimSpecSelectorMatchExpressions()
                                        .withKey("fakeTokenPlaceholder").withOperator(OperatorValues.IN)
                                        .withValues(Arrays.asList("slmpajlywqvuyknipgztsonqyybt"))))
                                    .withMatchLabels(mapOf("key6673", "fakeTokenPlaceholder")))))
                    .withGenerateResourceLimits(new GenerateResourceLimits().withCpu(OperationalMode.ENABLED))
                    .withMemoryProfile(BrokerMemoryProfile.TINY))
            .create();
    }

    // Use "Map.of" if available
    @SuppressWarnings("unchecked")
    private static <T> Map<String, T> mapOf(Object... inputs) {
        Map<String, T> map = new HashMap<>();
        for (int i = 0; i < inputs.length; i += 2) {
            String key = (String) inputs[i];
            T value = (T) inputs[i + 1];
            map.put(key, value);
        }
        return map;
    }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Python

from azure.identity import DefaultAzureCredential

from azure.mgmt.iotoperations import IoTOperationsMgmtClient

"""
# PREREQUISITES
    pip install azure-identity
    pip install azure-mgmt-iotoperations
# USAGE
    python broker_create_or_update_maximum_set_gen.py

    Before run the sample, please set the values of the client ID, tenant ID and client secret
    of the AAD application as environment variables: AZURE_CLIENT_ID, AZURE_TENANT_ID,
    AZURE_CLIENT_SECRET. For more info about how to get the value, please see:
    https://docs.microsoft.com/azure/active-directory/develop/howto-create-service-principal-portal
"""


def main():
    client = IoTOperationsMgmtClient(
        credential=DefaultAzureCredential(),
        subscription_id="SUBSCRIPTION_ID",
    )

    response = client.broker.begin_create_or_update(
        resource_group_name="rgiotoperations",
        instance_name="resource-name123",
        broker_name="resource-name123",
        resource={
            "extendedLocation": {"name": "qmbrfwcpwwhggszhrdjv", "type": "CustomLocation"},
            "properties": {
                "advanced": {
                    "clients": {
                        "maxKeepAliveSeconds": 3744,
                        "maxMessageExpirySeconds": 3263,
                        "maxPacketSizeBytes": 3029,
                        "maxReceiveMaximum": 2365,
                        "maxSessionExpirySeconds": 3859,
                        "subscriberQueueLimit": {"length": 6, "strategy": "None"},
                    },
                    "encryptInternalTraffic": "Enabled",
                    "internalCerts": {
                        "duration": "bchrc",
                        "privateKey": {"algorithm": "Ec256", "rotationPolicy": "Always"},
                        "renewBefore": "xkafmpgjfifkwwrhkswtopdnne",
                    },
                },
                "cardinality": {
                    "backendChain": {"partitions": 11, "redundancyFactor": 5, "workers": 15},
                    "frontend": {"replicas": 2, "workers": 6},
                },
                "diagnostics": {
                    "logs": {"level": "rnmwokumdmebpmfxxxzvvjfdywotav"},
                    "metrics": {"prometheusPort": 7581},
                    "selfCheck": {"intervalSeconds": 158, "mode": "Enabled", "timeoutSeconds": 14},
                    "traces": {
                        "cacheSizeMegabytes": 28,
                        "mode": "Enabled",
                        "selfTracing": {"intervalSeconds": 22, "mode": "Enabled"},
                        "spanChannelCapacity": 1000,
                    },
                },
                "diskBackedMessageBuffer": {
                    "ephemeralVolumeClaimSpec": {
                        "accessModes": ["nuluhigrbb"],
                        "dataSource": {"apiGroup": "npqapyksvvpkohujx", "kind": "wazgyb", "name": "cwhsgxxcxsyppoefm"},
                        "dataSourceRef": {
                            "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
                            "kind": "odynqzekfzsnawrctaxg",
                            "name": "envszivbbmixbyddzg",
                            "namespace": "etcfzvxqd",
                        },
                        "resources": {"limits": {"key2719": "hmphcrgctu"}, "requests": {"key2909": "txocprnyrsgvhfrg"}},
                        "selector": {
                            "matchExpressions": [
                                {"key": "e", "operator": "In", "values": ["slmpajlywqvuyknipgztsonqyybt"]}
                            ],
                            "matchLabels": {"key6673": "wlngfalznwxnurzpgxomcxhbqefpr"},
                        },
                        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
                        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
                        "volumeName": "c",
                    },
                    "maxSize": "500M",
                    "persistentVolumeClaimSpec": {
                        "accessModes": ["nuluhigrbb"],
                        "dataSource": {"apiGroup": "npqapyksvvpkohujx", "kind": "wazgyb", "name": "cwhsgxxcxsyppoefm"},
                        "dataSourceRef": {
                            "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
                            "kind": "odynqzekfzsnawrctaxg",
                            "name": "envszivbbmixbyddzg",
                            "namespace": "etcfzvxqd",
                        },
                        "resources": {"limits": {"key2719": "hmphcrgctu"}, "requests": {"key2909": "txocprnyrsgvhfrg"}},
                        "selector": {
                            "matchExpressions": [
                                {"key": "e", "operator": "In", "values": ["slmpajlywqvuyknipgztsonqyybt"]}
                            ],
                            "matchLabels": {"key6673": "wlngfalznwxnurzpgxomcxhbqefpr"},
                        },
                        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
                        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
                        "volumeName": "c",
                    },
                },
                "generateResourceLimits": {"cpu": "Enabled"},
                "memoryProfile": "Tiny",
            },
        },
    ).result()
    print(response)


# x-ms-original-file: 2024-11-01/Broker_CreateOrUpdate_MaximumSet_Gen.json
if __name__ == "__main__":
    main()

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Go

package armiotoperations_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/iotoperations/armiotoperations"
)

// Generated from example definition: 2024-11-01/Broker_CreateOrUpdate_MaximumSet_Gen.json
func ExampleBrokerClient_BeginCreateOrUpdate_brokerCreateOrUpdate() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armiotoperations.NewClientFactory("F8C729F9-DF9C-4743-848F-96EE433D8E53", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	poller, err := clientFactory.NewBrokerClient().BeginCreateOrUpdate(ctx, "rgiotoperations", "resource-name123", "resource-name123", armiotoperations.BrokerResource{
		Properties: &armiotoperations.BrokerProperties{
			Advanced: &armiotoperations.AdvancedSettings{
				Clients: &armiotoperations.ClientConfig{
					MaxSessionExpirySeconds: to.Ptr[int32](3859),
					MaxMessageExpirySeconds: to.Ptr[int32](3263),
					MaxPacketSizeBytes:      to.Ptr[int32](3029),
					SubscriberQueueLimit: &armiotoperations.SubscriberQueueLimit{
						Length:   to.Ptr[int64](6),
						Strategy: to.Ptr(armiotoperations.SubscriberMessageDropStrategyNone),
					},
					MaxReceiveMaximum:   to.Ptr[int32](2365),
					MaxKeepAliveSeconds: to.Ptr[int32](3744),
				},
				EncryptInternalTraffic: to.Ptr(armiotoperations.OperationalModeEnabled),
				InternalCerts: &armiotoperations.CertManagerCertOptions{
					Duration:    to.Ptr("bchrc"),
					RenewBefore: to.Ptr("xkafmpgjfifkwwrhkswtopdnne"),
					PrivateKey: &armiotoperations.CertManagerPrivateKey{
						Algorithm:      to.Ptr(armiotoperations.PrivateKeyAlgorithmEc256),
						RotationPolicy: to.Ptr(armiotoperations.PrivateKeyRotationPolicyAlways),
					},
				},
			},
			Cardinality: &armiotoperations.Cardinality{
				BackendChain: &armiotoperations.BackendChain{
					Partitions:       to.Ptr[int32](11),
					RedundancyFactor: to.Ptr[int32](5),
					Workers:          to.Ptr[int32](15),
				},
				Frontend: &armiotoperations.Frontend{
					Replicas: to.Ptr[int32](2),
					Workers:  to.Ptr[int32](6),
				},
			},
			Diagnostics: &armiotoperations.BrokerDiagnostics{
				Logs: &armiotoperations.DiagnosticsLogs{
					Level: to.Ptr("rnmwokumdmebpmfxxxzvvjfdywotav"),
				},
				Metrics: &armiotoperations.Metrics{
					PrometheusPort: to.Ptr[int32](7581),
				},
				SelfCheck: &armiotoperations.SelfCheck{
					Mode:            to.Ptr(armiotoperations.OperationalModeEnabled),
					IntervalSeconds: to.Ptr[int32](158),
					TimeoutSeconds:  to.Ptr[int32](14),
				},
				Traces: &armiotoperations.Traces{
					Mode:               to.Ptr(armiotoperations.OperationalModeEnabled),
					CacheSizeMegabytes: to.Ptr[int32](28),
					SelfTracing: &armiotoperations.SelfTracing{
						Mode:            to.Ptr(armiotoperations.OperationalModeEnabled),
						IntervalSeconds: to.Ptr[int32](22),
					},
					SpanChannelCapacity: to.Ptr[int32](1000),
				},
			},
			DiskBackedMessageBuffer: &armiotoperations.DiskBackedMessageBuffer{
				MaxSize: to.Ptr("500M"),
				EphemeralVolumeClaimSpec: &armiotoperations.VolumeClaimSpec{
					VolumeName:       to.Ptr("c"),
					VolumeMode:       to.Ptr("rxvpksjuuugqnqzeiprocknbn"),
					StorageClassName: to.Ptr("sseyhrjptkhrqvpdpjmornkqvon"),
					AccessModes: []*string{
						to.Ptr("nuluhigrbb"),
					},
					DataSource: &armiotoperations.LocalKubernetesReference{
						APIGroup: to.Ptr("npqapyksvvpkohujx"),
						Kind:     to.Ptr("wazgyb"),
						Name:     to.Ptr("cwhsgxxcxsyppoefm"),
					},
					DataSourceRef: &armiotoperations.KubernetesReference{
						APIGroup:  to.Ptr("mnfnykznjjsoqpfsgdqioupt"),
						Kind:      to.Ptr("odynqzekfzsnawrctaxg"),
						Name:      to.Ptr("envszivbbmixbyddzg"),
						Namespace: to.Ptr("etcfzvxqd"),
					},
					Resources: &armiotoperations.VolumeClaimResourceRequirements{
						Limits: map[string]*string{
							"key2719": to.Ptr("hmphcrgctu"),
						},
						Requests: map[string]*string{
							"key2909": to.Ptr("txocprnyrsgvhfrg"),
						},
					},
					Selector: &armiotoperations.VolumeClaimSpecSelector{
						MatchExpressions: []*armiotoperations.VolumeClaimSpecSelectorMatchExpressions{
							{
								Key:      to.Ptr("e"),
								Operator: to.Ptr(armiotoperations.OperatorValuesIn),
								Values: []*string{
									to.Ptr("slmpajlywqvuyknipgztsonqyybt"),
								},
							},
						},
						MatchLabels: map[string]*string{
							"key6673": to.Ptr("wlngfalznwxnurzpgxomcxhbqefpr"),
						},
					},
				},
				PersistentVolumeClaimSpec: &armiotoperations.VolumeClaimSpec{
					VolumeName:       to.Ptr("c"),
					VolumeMode:       to.Ptr("rxvpksjuuugqnqzeiprocknbn"),
					StorageClassName: to.Ptr("sseyhrjptkhrqvpdpjmornkqvon"),
					AccessModes: []*string{
						to.Ptr("nuluhigrbb"),
					},
					DataSource: &armiotoperations.LocalKubernetesReference{
						APIGroup: to.Ptr("npqapyksvvpkohujx"),
						Kind:     to.Ptr("wazgyb"),
						Name:     to.Ptr("cwhsgxxcxsyppoefm"),
					},
					DataSourceRef: &armiotoperations.KubernetesReference{
						APIGroup:  to.Ptr("mnfnykznjjsoqpfsgdqioupt"),
						Kind:      to.Ptr("odynqzekfzsnawrctaxg"),
						Name:      to.Ptr("envszivbbmixbyddzg"),
						Namespace: to.Ptr("etcfzvxqd"),
					},
					Resources: &armiotoperations.VolumeClaimResourceRequirements{
						Limits: map[string]*string{
							"key2719": to.Ptr("hmphcrgctu"),
						},
						Requests: map[string]*string{
							"key2909": to.Ptr("txocprnyrsgvhfrg"),
						},
					},
					Selector: &armiotoperations.VolumeClaimSpecSelector{
						MatchExpressions: []*armiotoperations.VolumeClaimSpecSelectorMatchExpressions{
							{
								Key:      to.Ptr("e"),
								Operator: to.Ptr(armiotoperations.OperatorValuesIn),
								Values: []*string{
									to.Ptr("slmpajlywqvuyknipgztsonqyybt"),
								},
							},
						},
						MatchLabels: map[string]*string{
							"key6673": to.Ptr("wlngfalznwxnurzpgxomcxhbqefpr"),
						},
					},
				},
			},
			GenerateResourceLimits: &armiotoperations.GenerateResourceLimits{
				CPU: to.Ptr(armiotoperations.OperationalModeEnabled),
			},
			MemoryProfile: to.Ptr(armiotoperations.BrokerMemoryProfileTiny),
		},
		ExtendedLocation: &armiotoperations.ExtendedLocation{
			Name: to.Ptr("qmbrfwcpwwhggszhrdjv"),
			Type: to.Ptr(armiotoperations.ExtendedLocationTypeCustomLocation),
		},
	}, nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	res, err := poller.PollUntilDone(ctx, nil)
	if err != nil {
		log.Fatalf("failed to pull the result: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res = armiotoperations.BrokerClientCreateOrUpdateResponse{
	// 	BrokerResource: &armiotoperations.BrokerResource{
	// 		Properties: &armiotoperations.BrokerProperties{
	// 			Advanced: &armiotoperations.AdvancedSettings{
	// 				Clients: &armiotoperations.ClientConfig{
	// 					MaxSessionExpirySeconds: to.Ptr[int32](3859),
	// 					MaxMessageExpirySeconds: to.Ptr[int32](3263),
	// 					MaxPacketSizeBytes: to.Ptr[int32](3029),
	// 					SubscriberQueueLimit: &armiotoperations.SubscriberQueueLimit{
	// 						Length: to.Ptr[int64](6),
	// 						Strategy: to.Ptr(armiotoperations.SubscriberMessageDropStrategyNone),
	// 					},
	// 					MaxReceiveMaximum: to.Ptr[int32](2365),
	// 					MaxKeepAliveSeconds: to.Ptr[int32](3744),
	// 				},
	// 				EncryptInternalTraffic: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 				InternalCerts: &armiotoperations.CertManagerCertOptions{
	// 					Duration: to.Ptr("bchrc"),
	// 					RenewBefore: to.Ptr("xkafmpgjfifkwwrhkswtopdnne"),
	// 					PrivateKey: &armiotoperations.CertManagerPrivateKey{
	// 						Algorithm: to.Ptr(armiotoperations.PrivateKeyAlgorithmEc256),
	// 						RotationPolicy: to.Ptr(armiotoperations.PrivateKeyRotationPolicyAlways),
	// 					},
	// 				},
	// 			},
	// 			Cardinality: &armiotoperations.Cardinality{
	// 				BackendChain: &armiotoperations.BackendChain{
	// 					Partitions: to.Ptr[int32](11),
	// 					RedundancyFactor: to.Ptr[int32](5),
	// 					Workers: to.Ptr[int32](15),
	// 				},
	// 				Frontend: &armiotoperations.Frontend{
	// 					Replicas: to.Ptr[int32](2),
	// 					Workers: to.Ptr[int32](6),
	// 				},
	// 			},
	// 			Diagnostics: &armiotoperations.BrokerDiagnostics{
	// 				Logs: &armiotoperations.DiagnosticsLogs{
	// 					Level: to.Ptr("rnmwokumdmebpmfxxxzvvjfdywotav"),
	// 				},
	// 				Metrics: &armiotoperations.Metrics{
	// 					PrometheusPort: to.Ptr[int32](7581),
	// 				},
	// 				SelfCheck: &armiotoperations.SelfCheck{
	// 					Mode: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 					IntervalSeconds: to.Ptr[int32](158),
	// 					TimeoutSeconds: to.Ptr[int32](14),
	// 				},
	// 				Traces: &armiotoperations.Traces{
	// 					Mode: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 					CacheSizeMegabytes: to.Ptr[int32](28),
	// 					SelfTracing: &armiotoperations.SelfTracing{
	// 						Mode: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 						IntervalSeconds: to.Ptr[int32](22),
	// 					},
	// 					SpanChannelCapacity: to.Ptr[int32](1000),
	// 				},
	// 			},
	// 			DiskBackedMessageBuffer: &armiotoperations.DiskBackedMessageBuffer{
	// 				MaxSize: to.Ptr("500M"),
	// 				EphemeralVolumeClaimSpec: &armiotoperations.VolumeClaimSpec{
	// 					VolumeName: to.Ptr("c"),
	// 					VolumeMode: to.Ptr("rxvpksjuuugqnqzeiprocknbn"),
	// 					StorageClassName: to.Ptr("sseyhrjptkhrqvpdpjmornkqvon"),
	// 					AccessModes: []*string{
	// 						to.Ptr("nuluhigrbb"),
	// 					},
	// 					DataSource: &armiotoperations.LocalKubernetesReference{
	// 						APIGroup: to.Ptr("npqapyksvvpkohujx"),
	// 						Kind: to.Ptr("wazgyb"),
	// 						Name: to.Ptr("cwhsgxxcxsyppoefm"),
	// 					},
	// 					DataSourceRef: &armiotoperations.KubernetesReference{
	// 						APIGroup: to.Ptr("mnfnykznjjsoqpfsgdqioupt"),
	// 						Kind: to.Ptr("odynqzekfzsnawrctaxg"),
	// 						Name: to.Ptr("envszivbbmixbyddzg"),
	// 						Namespace: to.Ptr("etcfzvxqd"),
	// 					},
	// 					Resources: &armiotoperations.VolumeClaimResourceRequirements{
	// 						Limits: map[string]*string{
	// 							"key2719": to.Ptr("hmphcrgctu"),
	// 						},
	// 						Requests: map[string]*string{
	// 							"key2909": to.Ptr("txocprnyrsgvhfrg"),
	// 						},
	// 					},
	// 					Selector: &armiotoperations.VolumeClaimSpecSelector{
	// 						MatchExpressions: []*armiotoperations.VolumeClaimSpecSelectorMatchExpressions{
	// 							{
	// 								Key: to.Ptr("e"),
	// 								Operator: to.Ptr(armiotoperations.OperatorValuesIn),
	// 								Values: []*string{
	// 									to.Ptr("slmpajlywqvuyknipgztsonqyybt"),
	// 								},
	// 							},
	// 						},
	// 						MatchLabels: map[string]*string{
	// 							"key6673": to.Ptr("wlngfalznwxnurzpgxomcxhbqefpr"),
	// 						},
	// 					},
	// 				},
	// 				PersistentVolumeClaimSpec: &armiotoperations.VolumeClaimSpec{
	// 					VolumeName: to.Ptr("c"),
	// 					VolumeMode: to.Ptr("rxvpksjuuugqnqzeiprocknbn"),
	// 					StorageClassName: to.Ptr("sseyhrjptkhrqvpdpjmornkqvon"),
	// 					AccessModes: []*string{
	// 						to.Ptr("nuluhigrbb"),
	// 					},
	// 					DataSource: &armiotoperations.LocalKubernetesReference{
	// 						APIGroup: to.Ptr("npqapyksvvpkohujx"),
	// 						Kind: to.Ptr("wazgyb"),
	// 						Name: to.Ptr("cwhsgxxcxsyppoefm"),
	// 					},
	// 					DataSourceRef: &armiotoperations.KubernetesReference{
	// 						APIGroup: to.Ptr("mnfnykznjjsoqpfsgdqioupt"),
	// 						Kind: to.Ptr("odynqzekfzsnawrctaxg"),
	// 						Name: to.Ptr("envszivbbmixbyddzg"),
	// 						Namespace: to.Ptr("etcfzvxqd"),
	// 					},
	// 					Resources: &armiotoperations.VolumeClaimResourceRequirements{
	// 						Limits: map[string]*string{
	// 							"key2719": to.Ptr("hmphcrgctu"),
	// 						},
	// 						Requests: map[string]*string{
	// 							"key2909": to.Ptr("txocprnyrsgvhfrg"),
	// 						},
	// 					},
	// 					Selector: &armiotoperations.VolumeClaimSpecSelector{
	// 						MatchExpressions: []*armiotoperations.VolumeClaimSpecSelectorMatchExpressions{
	// 							{
	// 								Key: to.Ptr("e"),
	// 								Operator: to.Ptr(armiotoperations.OperatorValuesIn),
	// 								Values: []*string{
	// 									to.Ptr("slmpajlywqvuyknipgztsonqyybt"),
	// 								},
	// 							},
	// 						},
	// 						MatchLabels: map[string]*string{
	// 							"key6673": to.Ptr("wlngfalznwxnurzpgxomcxhbqefpr"),
	// 						},
	// 					},
	// 				},
	// 			},
	// 			GenerateResourceLimits: &armiotoperations.GenerateResourceLimits{
	// 				CPU: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 			},
	// 			MemoryProfile: to.Ptr(armiotoperations.BrokerMemoryProfileTiny),
	// 			ProvisioningState: to.Ptr(armiotoperations.ProvisioningStateSucceeded),
	// 		},
	// 		ExtendedLocation: &armiotoperations.ExtendedLocation{
	// 			Name: to.Ptr("qmbrfwcpwwhggszhrdjv"),
	// 			Type: to.Ptr(armiotoperations.ExtendedLocationTypeCustomLocation),
	// 		},
	// 		ID: to.Ptr("/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123"),
	// 		Name: to.Ptr("dowrkel"),
	// 		Type: to.Ptr("xshjnsdgadygb"),
	// 		SystemData: &armiotoperations.SystemData{
	// 			CreatedBy: to.Ptr("ssvaslsmudloholronopqyxjcu"),
	// 			CreatedByType: to.Ptr(armiotoperations.CreatedByTypeUser),
	// 			CreatedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2024-08-09T18:13:29.389Z"); return t}()),
	// 			LastModifiedBy: to.Ptr("gnicpuszwd"),
	// 			LastModifiedByType: to.Ptr(armiotoperations.CreatedByTypeUser),
	// 			LastModifiedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2024-08-09T18:13:29.389Z"); return t}()),
	// 		},
	// 	},
	// }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

dotnet

using Azure;
using Azure.ResourceManager;
using System;
using System.Threading.Tasks;
using Azure.Core;
using Azure.Identity;
using Azure.ResourceManager.IotOperations.Models;
using Azure.ResourceManager.IotOperations;

// Generated from example definition: 2024-11-01/Broker_CreateOrUpdate_MaximumSet_Gen.json
// this example is just showing the usage of "BrokerResource_CreateOrUpdate" operation, for the dependent resources, they will have to be created separately.

// get your azure access token, for more details of how Azure SDK get your access token, please refer to https://learn.microsoft.com/en-us/dotnet/azure/sdk/authentication?tabs=command-line
TokenCredential cred = new DefaultAzureCredential();
// authenticate your client
ArmClient client = new ArmClient(cred);

// this example assumes you already have this IotOperationsBrokerResource created on azure
// for more information of creating IotOperationsBrokerResource, please refer to the document of IotOperationsBrokerResource
string subscriptionId = "F8C729F9-DF9C-4743-848F-96EE433D8E53";
string resourceGroupName = "rgiotoperations";
string instanceName = "resource-name123";
string brokerName = "resource-name123";
ResourceIdentifier iotOperationsBrokerResourceId = IotOperationsBrokerResource.CreateResourceIdentifier(subscriptionId, resourceGroupName, instanceName, brokerName);
IotOperationsBrokerResource iotOperationsBroker = client.GetIotOperationsBrokerResource(iotOperationsBrokerResourceId);

// invoke the operation
IotOperationsBrokerData data = new IotOperationsBrokerData(new IotOperationsExtendedLocation("qmbrfwcpwwhggszhrdjv", IotOperationsExtendedLocationType.CustomLocation))
{
    Properties = new IotOperationsBrokerProperties
    {
        Advanced = new BrokerAdvancedSettings
        {
            Clients = new BrokerClientConfig
            {
                MaxSessionExpirySeconds = 3859,
                MaxMessageExpirySeconds = 3263,
                MaxPacketSizeBytes = 3029,
                SubscriberQueueLimit = new SubscriberQueueLimit
                {
                    Length = 6L,
                    Strategy = SubscriberMessageDropStrategy.None,
                },
                MaxReceiveMaximum = 2365,
                MaxKeepAliveSeconds = 3744,
            },
            EncryptInternalTraffic = IotOperationsOperationalMode.Enabled,
            InternalCerts = new CertManagerCertConfig("bchrc", "xkafmpgjfifkwwrhkswtopdnne", new CertManagerPrivateKey(PrivateKeyAlgorithm.Ec256, PrivateKeyRotationPolicy.Always)),
        },
        Cardinality = new BrokerCardinality(new BrokerBackendChain(11, 5)
        {
            Workers = 15,
        }, new BrokerFrontend(2)
        {
            Workers = 6,
        }),
        Diagnostics = new BrokerDiagnostics
        {
            LogsLevel = "rnmwokumdmebpmfxxxzvvjfdywotav",
            MetricsPrometheusPort = 7581,
            SelfCheck = new BrokerDiagnosticSelfCheck
            {
                Mode = IotOperationsOperationalMode.Enabled,
                IntervalSeconds = 158,
                TimeoutSeconds = 14,
            },
            Traces = new BrokerDiagnosticTraces
            {
                Mode = IotOperationsOperationalMode.Enabled,
                CacheSizeMegabytes = 28,
                SelfTracing = new DiagnosticSelfTracing
                {
                    Mode = IotOperationsOperationalMode.Enabled,
                    IntervalSeconds = 22,
                },
                SpanChannelCapacity = 1000,
            },
        },
        DiskBackedMessageBuffer = new DiskBackedMessageBuffer("500M")
        {
            EphemeralVolumeClaimSpec = new VolumeClaimSpec
            {
                VolumeName = "c",
                VolumeMode = "rxvpksjuuugqnqzeiprocknbn",
                StorageClassName = "sseyhrjptkhrqvpdpjmornkqvon",
                AccessModes = { "nuluhigrbb" },
                DataSource = new LocalKubernetesReference("wazgyb", "cwhsgxxcxsyppoefm")
                {
                    ApiGroup = "npqapyksvvpkohujx",
                },
                DataSourceRef = new KubernetesReference("odynqzekfzsnawrctaxg", "envszivbbmixbyddzg")
                {
                    ApiGroup = "mnfnykznjjsoqpfsgdqioupt",
                    Namespace = "etcfzvxqd",
                },
                Resources = new VolumeClaimResourceRequirements
                {
                    Limits =
                    {
                    ["key2719"] = "hmphcrgctu"
                    },
                    Requests =
                    {
                    ["key2909"] = "txocprnyrsgvhfrg"
                    },
                },
                Selector = new VolumeClaimSpecSelector
                {
                    MatchExpressions = {new VolumeClaimSpecSelectorMatchExpressions("e", BrokerOperatorValue.In)
                    {
                    Values = {"slmpajlywqvuyknipgztsonqyybt"},
                    }},
                    MatchLabels =
                    {
                    ["key6673"] = "wlngfalznwxnurzpgxomcxhbqefpr"
                    },
                },
            },
            PersistentVolumeClaimSpec = new VolumeClaimSpec
            {
                VolumeName = "c",
                VolumeMode = "rxvpksjuuugqnqzeiprocknbn",
                StorageClassName = "sseyhrjptkhrqvpdpjmornkqvon",
                AccessModes = { "nuluhigrbb" },
                DataSource = new LocalKubernetesReference("wazgyb", "cwhsgxxcxsyppoefm")
                {
                    ApiGroup = "npqapyksvvpkohujx",
                },
                DataSourceRef = new KubernetesReference("odynqzekfzsnawrctaxg", "envszivbbmixbyddzg")
                {
                    ApiGroup = "mnfnykznjjsoqpfsgdqioupt",
                    Namespace = "etcfzvxqd",
                },
                Resources = new VolumeClaimResourceRequirements
                {
                    Limits =
                    {
                    ["key2719"] = "hmphcrgctu"
                    },
                    Requests =
                    {
                    ["key2909"] = "txocprnyrsgvhfrg"
                    },
                },
                Selector = new VolumeClaimSpecSelector
                {
                    MatchExpressions = {new VolumeClaimSpecSelectorMatchExpressions("e", BrokerOperatorValue.In)
                    {
                    Values = {"slmpajlywqvuyknipgztsonqyybt"},
                    }},
                    MatchLabels =
                    {
                    ["key6673"] = "wlngfalznwxnurzpgxomcxhbqefpr"
                    },
                },
            },
        },
        GenerateResourceLimitsCpu = IotOperationsOperationalMode.Enabled,
        MemoryProfile = BrokerMemoryProfile.Tiny,
    },
};
ArmOperation<IotOperationsBrokerResource> lro = await iotOperationsBroker.UpdateAsync(WaitUntil.Completed, data);
IotOperationsBrokerResource result = lro.Value;

// the variable result is a resource, you could call other operations on this instance as well
// but just for demo, we get its data from this resource instance
IotOperationsBrokerData resourceData = result.Data;
// for demo we just print out the id
Console.WriteLine($"Succeeded on id: {resourceData.Id}");

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Sample response

Status code:

200

{
  "properties": {
    "advanced": {
      "clients": {
        "maxSessionExpirySeconds": 3859,
        "maxMessageExpirySeconds": 3263,
        "maxPacketSizeBytes": 3029,
        "subscriberQueueLimit": {
          "length": 6,
          "strategy": "None"
        },
        "maxReceiveMaximum": 2365,
        "maxKeepAliveSeconds": 3744
      },
      "encryptInternalTraffic": "Enabled",
      "internalCerts": {
        "duration": "bchrc",
        "renewBefore": "xkafmpgjfifkwwrhkswtopdnne",
        "privateKey": {
          "algorithm": "Ec256",
          "rotationPolicy": "Always"
        }
      }
    },
    "cardinality": {
      "backendChain": {
        "partitions": 11,
        "redundancyFactor": 5,
        "workers": 15
      },
      "frontend": {
        "replicas": 2,
        "workers": 6
      }
    },
    "diagnostics": {
      "logs": {
        "level": "rnmwokumdmebpmfxxxzvvjfdywotav"
      },
      "metrics": {
        "prometheusPort": 7581
      },
      "selfCheck": {
        "mode": "Enabled",
        "intervalSeconds": 158,
        "timeoutSeconds": 14
      },
      "traces": {
        "mode": "Enabled",
        "cacheSizeMegabytes": 28,
        "selfTracing": {
          "mode": "Enabled",
          "intervalSeconds": 22
        },
        "spanChannelCapacity": 1000
      }
    },
    "diskBackedMessageBuffer": {
      "maxSize": "500M",
      "ephemeralVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      },
      "persistentVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      }
    },
    "generateResourceLimits": {
      "cpu": "Enabled"
    },
    "memoryProfile": "Tiny",
    "provisioningState": "Succeeded"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  },
  "id": "/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123",
  "name": "dowrkel",
  "type": "xshjnsdgadygb",
  "systemData": {
    "createdBy": "ssvaslsmudloholronopqyxjcu",
    "createdByType": "User",
    "createdAt": "2024-08-09T18:13:29.389Z",
    "lastModifiedBy": "gnicpuszwd",
    "lastModifiedByType": "User",
    "lastModifiedAt": "2024-08-09T18:13:29.389Z"
  }
}

Status code:

201

Azure-AsyncOperation: https://contoso.com/operationstatus

{
  "properties": {
    "advanced": {
      "clients": {
        "maxSessionExpirySeconds": 3859,
        "maxMessageExpirySeconds": 3263,
        "maxPacketSizeBytes": 3029,
        "subscriberQueueLimit": {
          "length": 6,
          "strategy": "None"
        },
        "maxReceiveMaximum": 2365,
        "maxKeepAliveSeconds": 3744
      },
      "encryptInternalTraffic": "Enabled",
      "internalCerts": {
        "duration": "bchrc",
        "renewBefore": "xkafmpgjfifkwwrhkswtopdnne",
        "privateKey": {
          "algorithm": "Ec256",
          "rotationPolicy": "Always"
        }
      }
    },
    "cardinality": {
      "backendChain": {
        "partitions": 11,
        "redundancyFactor": 5,
        "workers": 15
      },
      "frontend": {
        "replicas": 2,
        "workers": 6
      }
    },
    "diagnostics": {
      "logs": {
        "level": "rnmwokumdmebpmfxxxzvvjfdywotav"
      },
      "metrics": {
        "prometheusPort": 7581
      },
      "selfCheck": {
        "mode": "Enabled",
        "intervalSeconds": 158,
        "timeoutSeconds": 14
      },
      "traces": {
        "mode": "Enabled",
        "cacheSizeMegabytes": 28,
        "selfTracing": {
          "mode": "Enabled",
          "intervalSeconds": 22
        },
        "spanChannelCapacity": 1000
      }
    },
    "diskBackedMessageBuffer": {
      "maxSize": "500M",
      "ephemeralVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      },
      "persistentVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      }
    },
    "generateResourceLimits": {
      "cpu": "Enabled"
    },
    "memoryProfile": "Tiny",
    "provisioningState": "Succeeded"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  },
  "id": "/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123",
  "name": "dowrkel",
  "type": "xshjnsdgadygb",
  "systemData": {
    "createdBy": "ssvaslsmudloholronopqyxjcu",
    "createdByType": "User",
    "createdAt": "2024-08-09T18:13:29.389Z",
    "lastModifiedBy": "gnicpuszwd",
    "lastModifiedByType": "User",
    "lastModifiedAt": "2024-08-09T18:13:29.389Z"
  }
}

Broker_CreateOrUpdate_Complex

Sample request

HTTP

PUT https://management.azure.com/subscriptions/F8C729F9-DF9C-4743-848F-96EE433D8E53/resourceGroups/rgiotoperations/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123?api-version=2024-11-01

{
  "properties": {
    "cardinality": {
      "backendChain": {
        "partitions": 2,
        "redundancyFactor": 2,
        "workers": 2
      },
      "frontend": {
        "replicas": 2,
        "workers": 2
      }
    },
    "diskBackedMessageBuffer": {
      "maxSize": "50M"
    },
    "generateResourceLimits": {
      "cpu": "Enabled"
    },
    "memoryProfile": "Medium"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  }
}

Java

import com.azure.resourcemanager.iotoperations.models.BackendChain;
import com.azure.resourcemanager.iotoperations.models.BrokerMemoryProfile;
import com.azure.resourcemanager.iotoperations.models.BrokerProperties;
import com.azure.resourcemanager.iotoperations.models.Cardinality;
import com.azure.resourcemanager.iotoperations.models.DiskBackedMessageBuffer;
import com.azure.resourcemanager.iotoperations.models.ExtendedLocation;
import com.azure.resourcemanager.iotoperations.models.ExtendedLocationType;
import com.azure.resourcemanager.iotoperations.models.Frontend;
import com.azure.resourcemanager.iotoperations.models.GenerateResourceLimits;
import com.azure.resourcemanager.iotoperations.models.OperationalMode;
import java.util.HashMap;
import java.util.Map;

/**
 * Samples for Broker CreateOrUpdate.
 */
public final class Main {
    /*
     * x-ms-original-file: 2024-11-01/Broker_CreateOrUpdate_Complex.json
     */
    /**
     * Sample code: Broker_CreateOrUpdate_Complex.
     * 
     * @param manager Entry point to IoTOperationsManager.
     */
    public static void
        brokerCreateOrUpdateComplex(com.azure.resourcemanager.iotoperations.IoTOperationsManager manager) {
        manager
            .brokers().define(
                "resource-name123")
            .withExistingInstance("rgiotoperations", "resource-name123")
            .withExtendedLocation(new ExtendedLocation().withName("qmbrfwcpwwhggszhrdjv")
                .withType(ExtendedLocationType.CUSTOM_LOCATION))
            .withProperties(new BrokerProperties()
                .withCardinality(new Cardinality()
                    .withBackendChain(new BackendChain().withPartitions(2).withRedundancyFactor(2).withWorkers(2))
                    .withFrontend(new Frontend().withReplicas(2).withWorkers(2)))
                .withDiskBackedMessageBuffer(new DiskBackedMessageBuffer().withMaxSize("50M"))
                .withGenerateResourceLimits(new GenerateResourceLimits().withCpu(OperationalMode.ENABLED))
                .withMemoryProfile(BrokerMemoryProfile.MEDIUM))
            .create();
    }

    // Use "Map.of" if available
    @SuppressWarnings("unchecked")
    private static <T> Map<String, T> mapOf(Object... inputs) {
        Map<String, T> map = new HashMap<>();
        for (int i = 0; i < inputs.length; i += 2) {
            String key = (String) inputs[i];
            T value = (T) inputs[i + 1];
            map.put(key, value);
        }
        return map;
    }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Python

from azure.identity import DefaultAzureCredential

from azure.mgmt.iotoperations import IoTOperationsMgmtClient

"""
# PREREQUISITES
    pip install azure-identity
    pip install azure-mgmt-iotoperations
# USAGE
    python broker_create_or_update_complex.py

    Before run the sample, please set the values of the client ID, tenant ID and client secret
    of the AAD application as environment variables: AZURE_CLIENT_ID, AZURE_TENANT_ID,
    AZURE_CLIENT_SECRET. For more info about how to get the value, please see:
    https://docs.microsoft.com/azure/active-directory/develop/howto-create-service-principal-portal
"""


def main():
    client = IoTOperationsMgmtClient(
        credential=DefaultAzureCredential(),
        subscription_id="SUBSCRIPTION_ID",
    )

    response = client.broker.begin_create_or_update(
        resource_group_name="rgiotoperations",
        instance_name="resource-name123",
        broker_name="resource-name123",
        resource={
            "extendedLocation": {"name": "qmbrfwcpwwhggszhrdjv", "type": "CustomLocation"},
            "properties": {
                "cardinality": {
                    "backendChain": {"partitions": 2, "redundancyFactor": 2, "workers": 2},
                    "frontend": {"replicas": 2, "workers": 2},
                },
                "diskBackedMessageBuffer": {"maxSize": "50M"},
                "generateResourceLimits": {"cpu": "Enabled"},
                "memoryProfile": "Medium",
            },
        },
    ).result()
    print(response)


# x-ms-original-file: 2024-11-01/Broker_CreateOrUpdate_Complex.json
if __name__ == "__main__":
    main()

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Go

package armiotoperations_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/iotoperations/armiotoperations"
)

// Generated from example definition: 2024-11-01/Broker_CreateOrUpdate_Complex.json
func ExampleBrokerClient_BeginCreateOrUpdate_brokerCreateOrUpdateComplex() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armiotoperations.NewClientFactory("F8C729F9-DF9C-4743-848F-96EE433D8E53", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	poller, err := clientFactory.NewBrokerClient().BeginCreateOrUpdate(ctx, "rgiotoperations", "resource-name123", "resource-name123", armiotoperations.BrokerResource{
		Properties: &armiotoperations.BrokerProperties{
			Cardinality: &armiotoperations.Cardinality{
				BackendChain: &armiotoperations.BackendChain{
					Partitions:       to.Ptr[int32](2),
					RedundancyFactor: to.Ptr[int32](2),
					Workers:          to.Ptr[int32](2),
				},
				Frontend: &armiotoperations.Frontend{
					Replicas: to.Ptr[int32](2),
					Workers:  to.Ptr[int32](2),
				},
			},
			DiskBackedMessageBuffer: &armiotoperations.DiskBackedMessageBuffer{
				MaxSize: to.Ptr("50M"),
			},
			GenerateResourceLimits: &armiotoperations.GenerateResourceLimits{
				CPU: to.Ptr(armiotoperations.OperationalModeEnabled),
			},
			MemoryProfile: to.Ptr(armiotoperations.BrokerMemoryProfileMedium),
		},
		ExtendedLocation: &armiotoperations.ExtendedLocation{
			Name: to.Ptr("qmbrfwcpwwhggszhrdjv"),
			Type: to.Ptr(armiotoperations.ExtendedLocationTypeCustomLocation),
		},
	}, nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	res, err := poller.PollUntilDone(ctx, nil)
	if err != nil {
		log.Fatalf("failed to pull the result: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res = armiotoperations.BrokerClientCreateOrUpdateResponse{
	// 	BrokerResource: &armiotoperations.BrokerResource{
	// 		Properties: &armiotoperations.BrokerProperties{
	// 			Cardinality: &armiotoperations.Cardinality{
	// 				BackendChain: &armiotoperations.BackendChain{
	// 					Partitions: to.Ptr[int32](2),
	// 					RedundancyFactor: to.Ptr[int32](2),
	// 					Workers: to.Ptr[int32](2),
	// 				},
	// 				Frontend: &armiotoperations.Frontend{
	// 					Replicas: to.Ptr[int32](2),
	// 					Workers: to.Ptr[int32](2),
	// 				},
	// 			},
	// 			DiskBackedMessageBuffer: &armiotoperations.DiskBackedMessageBuffer{
	// 				MaxSize: to.Ptr("50M"),
	// 			},
	// 			GenerateResourceLimits: &armiotoperations.GenerateResourceLimits{
	// 				CPU: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 			},
	// 			MemoryProfile: to.Ptr(armiotoperations.BrokerMemoryProfileMedium),
	// 			ProvisioningState: to.Ptr(armiotoperations.ProvisioningStateSucceeded),
	// 		},
	// 		ExtendedLocation: &armiotoperations.ExtendedLocation{
	// 			Name: to.Ptr("qmbrfwcpwwhggszhrdjv"),
	// 			Type: to.Ptr(armiotoperations.ExtendedLocationTypeCustomLocation),
	// 		},
	// 		ID: to.Ptr("/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123"),
	// 		Name: to.Ptr("llptmlifnqqwairx"),
	// 		Type: to.Ptr("qwrfzxjfxvismlqvigot"),
	// 		SystemData: &armiotoperations.SystemData{
	// 			CreatedBy: to.Ptr("ssvaslsmudloholronopqyxjcu"),
	// 			CreatedByType: to.Ptr(armiotoperations.CreatedByTypeUser),
	// 			CreatedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2024-08-09T18:13:29.389Z"); return t}()),
	// 			LastModifiedBy: to.Ptr("gnicpuszwd"),
	// 			LastModifiedByType: to.Ptr(armiotoperations.CreatedByTypeUser),
	// 			LastModifiedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2024-08-09T18:13:29.389Z"); return t}()),
	// 		},
	// 	},
	// }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

dotnet

using Azure;
using Azure.ResourceManager;
using System;
using System.Threading.Tasks;
using Azure.Core;
using Azure.Identity;
using Azure.ResourceManager.IotOperations.Models;
using Azure.ResourceManager.IotOperations;

// Generated from example definition: 2024-11-01/Broker_CreateOrUpdate_Complex.json
// this example is just showing the usage of "BrokerResource_CreateOrUpdate" operation, for the dependent resources, they will have to be created separately.

// get your azure access token, for more details of how Azure SDK get your access token, please refer to https://learn.microsoft.com/en-us/dotnet/azure/sdk/authentication?tabs=command-line
TokenCredential cred = new DefaultAzureCredential();
// authenticate your client
ArmClient client = new ArmClient(cred);

// this example assumes you already have this IotOperationsBrokerResource created on azure
// for more information of creating IotOperationsBrokerResource, please refer to the document of IotOperationsBrokerResource
string subscriptionId = "F8C729F9-DF9C-4743-848F-96EE433D8E53";
string resourceGroupName = "rgiotoperations";
string instanceName = "resource-name123";
string brokerName = "resource-name123";
ResourceIdentifier iotOperationsBrokerResourceId = IotOperationsBrokerResource.CreateResourceIdentifier(subscriptionId, resourceGroupName, instanceName, brokerName);
IotOperationsBrokerResource iotOperationsBroker = client.GetIotOperationsBrokerResource(iotOperationsBrokerResourceId);

// invoke the operation
IotOperationsBrokerData data = new IotOperationsBrokerData(new IotOperationsExtendedLocation("qmbrfwcpwwhggszhrdjv", IotOperationsExtendedLocationType.CustomLocation))
{
    Properties = new IotOperationsBrokerProperties
    {
        Cardinality = new BrokerCardinality(new BrokerBackendChain(2, 2)
        {
            Workers = 2,
        }, new BrokerFrontend(2)
        {
            Workers = 2,
        }),
        DiskBackedMessageBuffer = new DiskBackedMessageBuffer("50M"),
        GenerateResourceLimitsCpu = IotOperationsOperationalMode.Enabled,
        MemoryProfile = BrokerMemoryProfile.Medium,
    },
};
ArmOperation<IotOperationsBrokerResource> lro = await iotOperationsBroker.UpdateAsync(WaitUntil.Completed, data);
IotOperationsBrokerResource result = lro.Value;

// the variable result is a resource, you could call other operations on this instance as well
// but just for demo, we get its data from this resource instance
IotOperationsBrokerData resourceData = result.Data;
// for demo we just print out the id
Console.WriteLine($"Succeeded on id: {resourceData.Id}");

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Sample response

Status code:

200

{
  "properties": {
    "cardinality": {
      "backendChain": {
        "partitions": 2,
        "redundancyFactor": 2,
        "workers": 2
      },
      "frontend": {
        "replicas": 2,
        "workers": 2
      }
    },
    "diskBackedMessageBuffer": {
      "maxSize": "50M"
    },
    "generateResourceLimits": {
      "cpu": "Enabled"
    },
    "memoryProfile": "Medium",
    "provisioningState": "Succeeded"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  },
  "id": "/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123",
  "name": "llptmlifnqqwairx",
  "type": "qwrfzxjfxvismlqvigot",
  "systemData": {
    "createdBy": "ssvaslsmudloholronopqyxjcu",
    "createdByType": "User",
    "createdAt": "2024-08-09T18:13:29.389Z",
    "lastModifiedBy": "gnicpuszwd",
    "lastModifiedByType": "User",
    "lastModifiedAt": "2024-08-09T18:13:29.389Z"
  }
}

Status code:

201

Azure-AsyncOperation: https://contoso.com/operationstatus

{
  "properties": {
    "cardinality": {
      "backendChain": {
        "partitions": 2,
        "redundancyFactor": 2,
        "workers": 2
      },
      "frontend": {
        "replicas": 2,
        "workers": 2
      }
    },
    "diskBackedMessageBuffer": {
      "maxSize": "50M"
    },
    "generateResourceLimits": {
      "cpu": "Enabled"
    },
    "memoryProfile": "Medium",
    "provisioningState": "Accepted"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  },
  "id": "/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123",
  "name": "llptmlifnqqwairx",
  "type": "qwrfzxjfxvismlqvigot",
  "systemData": {
    "createdBy": "ssvaslsmudloholronopqyxjcu",
    "createdByType": "User",
    "createdAt": "2024-08-09T18:13:29.389Z",
    "lastModifiedBy": "gnicpuszwd",
    "lastModifiedByType": "User",
    "lastModifiedAt": "2024-08-09T18:13:29.389Z"
  }
}

Broker_CreateOrUpdate_Minimal

Sample request

HTTP

PUT https://management.azure.com/subscriptions/F8C729F9-DF9C-4743-848F-96EE433D8E53/resourceGroups/rgiotoperations/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123?api-version=2024-11-01

{
  "properties": {
    "memoryProfile": "Tiny"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  }
}

Java

import com.azure.resourcemanager.iotoperations.models.BrokerMemoryProfile;
import com.azure.resourcemanager.iotoperations.models.BrokerProperties;
import com.azure.resourcemanager.iotoperations.models.ExtendedLocation;
import com.azure.resourcemanager.iotoperations.models.ExtendedLocationType;
import java.util.HashMap;
import java.util.Map;

/**
 * Samples for Broker CreateOrUpdate.
 */
public final class Main {
    /*
     * x-ms-original-file: 2024-11-01/Broker_CreateOrUpdate_Minimal.json
     */
    /**
     * Sample code: Broker_CreateOrUpdate_Minimal.
     * 
     * @param manager Entry point to IoTOperationsManager.
     */
    public static void
        brokerCreateOrUpdateMinimal(com.azure.resourcemanager.iotoperations.IoTOperationsManager manager) {
        manager.brokers().define("resource-name123").withExistingInstance("rgiotoperations", "resource-name123")
            .withExtendedLocation(
                new ExtendedLocation().withName("qmbrfwcpwwhggszhrdjv").withType(ExtendedLocationType.CUSTOM_LOCATION))
            .withProperties(new BrokerProperties().withMemoryProfile(BrokerMemoryProfile.TINY)).create();
    }

    // Use "Map.of" if available
    @SuppressWarnings("unchecked")
    private static <T> Map<String, T> mapOf(Object... inputs) {
        Map<String, T> map = new HashMap<>();
        for (int i = 0; i < inputs.length; i += 2) {
            String key = (String) inputs[i];
            T value = (T) inputs[i + 1];
            map.put(key, value);
        }
        return map;
    }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Python

from azure.identity import DefaultAzureCredential

from azure.mgmt.iotoperations import IoTOperationsMgmtClient

"""
# PREREQUISITES
    pip install azure-identity
    pip install azure-mgmt-iotoperations
# USAGE
    python broker_create_or_update_minimal.py

    Before run the sample, please set the values of the client ID, tenant ID and client secret
    of the AAD application as environment variables: AZURE_CLIENT_ID, AZURE_TENANT_ID,
    AZURE_CLIENT_SECRET. For more info about how to get the value, please see:
    https://docs.microsoft.com/azure/active-directory/develop/howto-create-service-principal-portal
"""


def main():
    client = IoTOperationsMgmtClient(
        credential=DefaultAzureCredential(),
        subscription_id="SUBSCRIPTION_ID",
    )

    response = client.broker.begin_create_or_update(
        resource_group_name="rgiotoperations",
        instance_name="resource-name123",
        broker_name="resource-name123",
        resource={
            "extendedLocation": {"name": "qmbrfwcpwwhggszhrdjv", "type": "CustomLocation"},
            "properties": {"memoryProfile": "Tiny"},
        },
    ).result()
    print(response)


# x-ms-original-file: 2024-11-01/Broker_CreateOrUpdate_Minimal.json
if __name__ == "__main__":
    main()

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Go

package armiotoperations_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/iotoperations/armiotoperations"
)

// Generated from example definition: 2024-11-01/Broker_CreateOrUpdate_Minimal.json
func ExampleBrokerClient_BeginCreateOrUpdate_brokerCreateOrUpdateMinimal() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armiotoperations.NewClientFactory("F8C729F9-DF9C-4743-848F-96EE433D8E53", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	poller, err := clientFactory.NewBrokerClient().BeginCreateOrUpdate(ctx, "rgiotoperations", "resource-name123", "resource-name123", armiotoperations.BrokerResource{
		Properties: &armiotoperations.BrokerProperties{
			MemoryProfile: to.Ptr(armiotoperations.BrokerMemoryProfileTiny),
		},
		ExtendedLocation: &armiotoperations.ExtendedLocation{
			Name: to.Ptr("qmbrfwcpwwhggszhrdjv"),
			Type: to.Ptr(armiotoperations.ExtendedLocationTypeCustomLocation),
		},
	}, nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	res, err := poller.PollUntilDone(ctx, nil)
	if err != nil {
		log.Fatalf("failed to pull the result: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res = armiotoperations.BrokerClientCreateOrUpdateResponse{
	// 	BrokerResource: &armiotoperations.BrokerResource{
	// 		Properties: &armiotoperations.BrokerProperties{
	// 			Advanced: &armiotoperations.AdvancedSettings{
	// 				Clients: &armiotoperations.ClientConfig{
	// 					MaxSessionExpirySeconds: to.Ptr[int32](3859),
	// 					MaxMessageExpirySeconds: to.Ptr[int32](3263),
	// 					MaxPacketSizeBytes: to.Ptr[int32](3029),
	// 					SubscriberQueueLimit: &armiotoperations.SubscriberQueueLimit{
	// 						Length: to.Ptr[int64](6),
	// 						Strategy: to.Ptr(armiotoperations.SubscriberMessageDropStrategyNone),
	// 					},
	// 					MaxReceiveMaximum: to.Ptr[int32](2365),
	// 					MaxKeepAliveSeconds: to.Ptr[int32](3744),
	// 				},
	// 				EncryptInternalTraffic: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 				InternalCerts: &armiotoperations.CertManagerCertOptions{
	// 					Duration: to.Ptr("bchrc"),
	// 					RenewBefore: to.Ptr("xkafmpgjfifkwwrhkswtopdnne"),
	// 					PrivateKey: &armiotoperations.CertManagerPrivateKey{
	// 						Algorithm: to.Ptr(armiotoperations.PrivateKeyAlgorithmEc256),
	// 						RotationPolicy: to.Ptr(armiotoperations.PrivateKeyRotationPolicyAlways),
	// 					},
	// 				},
	// 			},
	// 			Cardinality: &armiotoperations.Cardinality{
	// 				BackendChain: &armiotoperations.BackendChain{
	// 					Partitions: to.Ptr[int32](11),
	// 					RedundancyFactor: to.Ptr[int32](5),
	// 					Workers: to.Ptr[int32](15),
	// 				},
	// 				Frontend: &armiotoperations.Frontend{
	// 					Replicas: to.Ptr[int32](2),
	// 					Workers: to.Ptr[int32](6),
	// 				},
	// 			},
	// 			Diagnostics: &armiotoperations.BrokerDiagnostics{
	// 				Logs: &armiotoperations.DiagnosticsLogs{
	// 					Level: to.Ptr("rnmwokumdmebpmfxxxzvvjfdywotav"),
	// 				},
	// 				Metrics: &armiotoperations.Metrics{
	// 					PrometheusPort: to.Ptr[int32](7581),
	// 				},
	// 				SelfCheck: &armiotoperations.SelfCheck{
	// 					Mode: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 					IntervalSeconds: to.Ptr[int32](158),
	// 					TimeoutSeconds: to.Ptr[int32](14),
	// 				},
	// 				Traces: &armiotoperations.Traces{
	// 					Mode: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 					CacheSizeMegabytes: to.Ptr[int32](28),
	// 					SelfTracing: &armiotoperations.SelfTracing{
	// 						Mode: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 						IntervalSeconds: to.Ptr[int32](22),
	// 					},
	// 					SpanChannelCapacity: to.Ptr[int32](1000),
	// 				},
	// 			},
	// 			DiskBackedMessageBuffer: &armiotoperations.DiskBackedMessageBuffer{
	// 				MaxSize: to.Ptr("500M"),
	// 				EphemeralVolumeClaimSpec: &armiotoperations.VolumeClaimSpec{
	// 					VolumeName: to.Ptr("c"),
	// 					VolumeMode: to.Ptr("rxvpksjuuugqnqzeiprocknbn"),
	// 					StorageClassName: to.Ptr("sseyhrjptkhrqvpdpjmornkqvon"),
	// 					AccessModes: []*string{
	// 						to.Ptr("nuluhigrbb"),
	// 					},
	// 					DataSource: &armiotoperations.LocalKubernetesReference{
	// 						APIGroup: to.Ptr("npqapyksvvpkohujx"),
	// 						Kind: to.Ptr("wazgyb"),
	// 						Name: to.Ptr("cwhsgxxcxsyppoefm"),
	// 					},
	// 					DataSourceRef: &armiotoperations.KubernetesReference{
	// 						APIGroup: to.Ptr("mnfnykznjjsoqpfsgdqioupt"),
	// 						Kind: to.Ptr("odynqzekfzsnawrctaxg"),
	// 						Name: to.Ptr("envszivbbmixbyddzg"),
	// 						Namespace: to.Ptr("etcfzvxqd"),
	// 					},
	// 					Resources: &armiotoperations.VolumeClaimResourceRequirements{
	// 						Limits: map[string]*string{
	// 							"key2719": to.Ptr("hmphcrgctu"),
	// 						},
	// 						Requests: map[string]*string{
	// 							"key2909": to.Ptr("txocprnyrsgvhfrg"),
	// 						},
	// 					},
	// 					Selector: &armiotoperations.VolumeClaimSpecSelector{
	// 						MatchExpressions: []*armiotoperations.VolumeClaimSpecSelectorMatchExpressions{
	// 							{
	// 								Key: to.Ptr("e"),
	// 								Operator: to.Ptr(armiotoperations.OperatorValuesIn),
	// 								Values: []*string{
	// 									to.Ptr("slmpajlywqvuyknipgztsonqyybt"),
	// 								},
	// 							},
	// 						},
	// 						MatchLabels: map[string]*string{
	// 							"key6673": to.Ptr("wlngfalznwxnurzpgxomcxhbqefpr"),
	// 						},
	// 					},
	// 				},
	// 				PersistentVolumeClaimSpec: &armiotoperations.VolumeClaimSpec{
	// 					VolumeName: to.Ptr("c"),
	// 					VolumeMode: to.Ptr("rxvpksjuuugqnqzeiprocknbn"),
	// 					StorageClassName: to.Ptr("sseyhrjptkhrqvpdpjmornkqvon"),
	// 					AccessModes: []*string{
	// 						to.Ptr("nuluhigrbb"),
	// 					},
	// 					DataSource: &armiotoperations.LocalKubernetesReference{
	// 						APIGroup: to.Ptr("npqapyksvvpkohujx"),
	// 						Kind: to.Ptr("wazgyb"),
	// 						Name: to.Ptr("cwhsgxxcxsyppoefm"),
	// 					},
	// 					DataSourceRef: &armiotoperations.KubernetesReference{
	// 						APIGroup: to.Ptr("mnfnykznjjsoqpfsgdqioupt"),
	// 						Kind: to.Ptr("odynqzekfzsnawrctaxg"),
	// 						Name: to.Ptr("envszivbbmixbyddzg"),
	// 						Namespace: to.Ptr("etcfzvxqd"),
	// 					},
	// 					Resources: &armiotoperations.VolumeClaimResourceRequirements{
	// 						Limits: map[string]*string{
	// 							"key2719": to.Ptr("hmphcrgctu"),
	// 						},
	// 						Requests: map[string]*string{
	// 							"key2909": to.Ptr("txocprnyrsgvhfrg"),
	// 						},
	// 					},
	// 					Selector: &armiotoperations.VolumeClaimSpecSelector{
	// 						MatchExpressions: []*armiotoperations.VolumeClaimSpecSelectorMatchExpressions{
	// 							{
	// 								Key: to.Ptr("e"),
	// 								Operator: to.Ptr(armiotoperations.OperatorValuesIn),
	// 								Values: []*string{
	// 									to.Ptr("slmpajlywqvuyknipgztsonqyybt"),
	// 								},
	// 							},
	// 						},
	// 						MatchLabels: map[string]*string{
	// 							"key6673": to.Ptr("wlngfalznwxnurzpgxomcxhbqefpr"),
	// 						},
	// 					},
	// 				},
	// 			},
	// 			GenerateResourceLimits: &armiotoperations.GenerateResourceLimits{
	// 				CPU: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 			},
	// 			MemoryProfile: to.Ptr(armiotoperations.BrokerMemoryProfileTiny),
	// 			ProvisioningState: to.Ptr(armiotoperations.ProvisioningStateSucceeded),
	// 		},
	// 		ExtendedLocation: &armiotoperations.ExtendedLocation{
	// 			Name: to.Ptr("qmbrfwcpwwhggszhrdjv"),
	// 			Type: to.Ptr(armiotoperations.ExtendedLocationTypeCustomLocation),
	// 		},
	// 		ID: to.Ptr("/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123"),
	// 		Name: to.Ptr("dowrkel"),
	// 		Type: to.Ptr("xshjnsdgadygb"),
	// 		SystemData: &armiotoperations.SystemData{
	// 			CreatedBy: to.Ptr("ssvaslsmudloholronopqyxjcu"),
	// 			CreatedByType: to.Ptr(armiotoperations.CreatedByTypeUser),
	// 			CreatedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2024-08-09T18:13:29.389Z"); return t}()),
	// 			LastModifiedBy: to.Ptr("gnicpuszwd"),
	// 			LastModifiedByType: to.Ptr(armiotoperations.CreatedByTypeUser),
	// 			LastModifiedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2024-08-09T18:13:29.389Z"); return t}()),
	// 		},
	// 	},
	// }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

dotnet

using Azure;
using Azure.ResourceManager;
using System;
using System.Threading.Tasks;
using Azure.Core;
using Azure.Identity;
using Azure.ResourceManager.IotOperations.Models;
using Azure.ResourceManager.IotOperations;

// Generated from example definition: 2024-11-01/Broker_CreateOrUpdate_Minimal.json
// this example is just showing the usage of "BrokerResource_CreateOrUpdate" operation, for the dependent resources, they will have to be created separately.

// get your azure access token, for more details of how Azure SDK get your access token, please refer to https://learn.microsoft.com/en-us/dotnet/azure/sdk/authentication?tabs=command-line
TokenCredential cred = new DefaultAzureCredential();
// authenticate your client
ArmClient client = new ArmClient(cred);

// this example assumes you already have this IotOperationsBrokerResource created on azure
// for more information of creating IotOperationsBrokerResource, please refer to the document of IotOperationsBrokerResource
string subscriptionId = "F8C729F9-DF9C-4743-848F-96EE433D8E53";
string resourceGroupName = "rgiotoperations";
string instanceName = "resource-name123";
string brokerName = "resource-name123";
ResourceIdentifier iotOperationsBrokerResourceId = IotOperationsBrokerResource.CreateResourceIdentifier(subscriptionId, resourceGroupName, instanceName, brokerName);
IotOperationsBrokerResource iotOperationsBroker = client.GetIotOperationsBrokerResource(iotOperationsBrokerResourceId);

// invoke the operation
IotOperationsBrokerData data = new IotOperationsBrokerData(new IotOperationsExtendedLocation("qmbrfwcpwwhggszhrdjv", IotOperationsExtendedLocationType.CustomLocation))
{
    Properties = new IotOperationsBrokerProperties
    {
        MemoryProfile = BrokerMemoryProfile.Tiny,
    },
};
ArmOperation<IotOperationsBrokerResource> lro = await iotOperationsBroker.UpdateAsync(WaitUntil.Completed, data);
IotOperationsBrokerResource result = lro.Value;

// the variable result is a resource, you could call other operations on this instance as well
// but just for demo, we get its data from this resource instance
IotOperationsBrokerData resourceData = result.Data;
// for demo we just print out the id
Console.WriteLine($"Succeeded on id: {resourceData.Id}");

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Sample response

Status code:

200

{
  "properties": {
    "advanced": {
      "clients": {
        "maxSessionExpirySeconds": 3859,
        "maxMessageExpirySeconds": 3263,
        "maxPacketSizeBytes": 3029,
        "subscriberQueueLimit": {
          "length": 6,
          "strategy": "None"
        },
        "maxReceiveMaximum": 2365,
        "maxKeepAliveSeconds": 3744
      },
      "encryptInternalTraffic": "Enabled",
      "internalCerts": {
        "duration": "bchrc",
        "renewBefore": "xkafmpgjfifkwwrhkswtopdnne",
        "privateKey": {
          "algorithm": "Ec256",
          "rotationPolicy": "Always"
        }
      }
    },
    "cardinality": {
      "backendChain": {
        "partitions": 11,
        "redundancyFactor": 5,
        "workers": 15
      },
      "frontend": {
        "replicas": 2,
        "workers": 6
      }
    },
    "diagnostics": {
      "logs": {
        "level": "rnmwokumdmebpmfxxxzvvjfdywotav"
      },
      "metrics": {
        "prometheusPort": 7581
      },
      "selfCheck": {
        "mode": "Enabled",
        "intervalSeconds": 158,
        "timeoutSeconds": 14
      },
      "traces": {
        "mode": "Enabled",
        "cacheSizeMegabytes": 28,
        "selfTracing": {
          "mode": "Enabled",
          "intervalSeconds": 22
        },
        "spanChannelCapacity": 1000
      }
    },
    "diskBackedMessageBuffer": {
      "maxSize": "500M",
      "ephemeralVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      },
      "persistentVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      }
    },
    "generateResourceLimits": {
      "cpu": "Enabled"
    },
    "memoryProfile": "Tiny",
    "provisioningState": "Succeeded"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  },
  "id": "/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123",
  "name": "dowrkel",
  "type": "xshjnsdgadygb",
  "systemData": {
    "createdBy": "ssvaslsmudloholronopqyxjcu",
    "createdByType": "User",
    "createdAt": "2024-08-09T18:13:29.389Z",
    "lastModifiedBy": "gnicpuszwd",
    "lastModifiedByType": "User",
    "lastModifiedAt": "2024-08-09T18:13:29.389Z"
  }
}

Status code:

201

Azure-AsyncOperation: https://contoso.com/operationstatus

{
  "properties": {
    "advanced": {
      "clients": {
        "maxSessionExpirySeconds": 3859,
        "maxMessageExpirySeconds": 3263,
        "maxPacketSizeBytes": 3029,
        "subscriberQueueLimit": {
          "length": 6,
          "strategy": "None"
        },
        "maxReceiveMaximum": 2365,
        "maxKeepAliveSeconds": 3744
      },
      "encryptInternalTraffic": "Enabled",
      "internalCerts": {
        "duration": "bchrc",
        "renewBefore": "xkafmpgjfifkwwrhkswtopdnne",
        "privateKey": {
          "algorithm": "Ec256",
          "rotationPolicy": "Always"
        }
      }
    },
    "cardinality": {
      "backendChain": {
        "partitions": 11,
        "redundancyFactor": 5,
        "workers": 15
      },
      "frontend": {
        "replicas": 2,
        "workers": 6
      }
    },
    "diagnostics": {
      "logs": {
        "level": "rnmwokumdmebpmfxxxzvvjfdywotav"
      },
      "metrics": {
        "prometheusPort": 7581
      },
      "selfCheck": {
        "mode": "Enabled",
        "intervalSeconds": 158,
        "timeoutSeconds": 14
      },
      "traces": {
        "mode": "Enabled",
        "cacheSizeMegabytes": 28,
        "selfTracing": {
          "mode": "Enabled",
          "intervalSeconds": 22
        },
        "spanChannelCapacity": 1000
      }
    },
    "diskBackedMessageBuffer": {
      "maxSize": "500M",
      "ephemeralVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      },
      "persistentVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      }
    },
    "generateResourceLimits": {
      "cpu": "Enabled"
    },
    "memoryProfile": "Tiny",
    "provisioningState": "Succeeded"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  },
  "id": "/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123",
  "name": "dowrkel",
  "type": "xshjnsdgadygb",
  "systemData": {
    "createdBy": "ssvaslsmudloholronopqyxjcu",
    "createdByType": "User",
    "createdAt": "2024-08-09T18:13:29.389Z",
    "lastModifiedBy": "gnicpuszwd",
    "lastModifiedByType": "User",
    "lastModifiedAt": "2024-08-09T18:13:29.389Z"
  }
}

Broker_CreateOrUpdate_Simple

Sample request

HTTP

PUT https://management.azure.com/subscriptions/F8C729F9-DF9C-4743-848F-96EE433D8E53/resourceGroups/rgiotoperations/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123?api-version=2024-11-01

{
  "properties": {
    "cardinality": {
      "backendChain": {
        "partitions": 2,
        "redundancyFactor": 2,
        "workers": 2
      },
      "frontend": {
        "replicas": 2,
        "workers": 2
      }
    },
    "generateResourceLimits": {
      "cpu": "Enabled"
    },
    "memoryProfile": "Low"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  }
}

Java

import com.azure.resourcemanager.iotoperations.models.BackendChain;
import com.azure.resourcemanager.iotoperations.models.BrokerMemoryProfile;
import com.azure.resourcemanager.iotoperations.models.BrokerProperties;
import com.azure.resourcemanager.iotoperations.models.Cardinality;
import com.azure.resourcemanager.iotoperations.models.ExtendedLocation;
import com.azure.resourcemanager.iotoperations.models.ExtendedLocationType;
import com.azure.resourcemanager.iotoperations.models.Frontend;
import com.azure.resourcemanager.iotoperations.models.GenerateResourceLimits;
import com.azure.resourcemanager.iotoperations.models.OperationalMode;
import java.util.HashMap;
import java.util.Map;

/**
 * Samples for Broker CreateOrUpdate.
 */
public final class Main {
    /*
     * x-ms-original-file: 2024-11-01/Broker_CreateOrUpdate_Simple.json
     */
    /**
     * Sample code: Broker_CreateOrUpdate_Simple.
     * 
     * @param manager Entry point to IoTOperationsManager.
     */
    public static void
        brokerCreateOrUpdateSimple(com.azure.resourcemanager.iotoperations.IoTOperationsManager manager) {
        manager
            .brokers().define(
                "resource-name123")
            .withExistingInstance("rgiotoperations", "resource-name123")
            .withExtendedLocation(new ExtendedLocation().withName("qmbrfwcpwwhggszhrdjv")
                .withType(ExtendedLocationType.CUSTOM_LOCATION))
            .withProperties(new BrokerProperties()
                .withCardinality(new Cardinality()
                    .withBackendChain(new BackendChain().withPartitions(2).withRedundancyFactor(2).withWorkers(2))
                    .withFrontend(new Frontend().withReplicas(2).withWorkers(2)))
                .withGenerateResourceLimits(new GenerateResourceLimits().withCpu(OperationalMode.ENABLED))
                .withMemoryProfile(BrokerMemoryProfile.LOW))
            .create();
    }

    // Use "Map.of" if available
    @SuppressWarnings("unchecked")
    private static <T> Map<String, T> mapOf(Object... inputs) {
        Map<String, T> map = new HashMap<>();
        for (int i = 0; i < inputs.length; i += 2) {
            String key = (String) inputs[i];
            T value = (T) inputs[i + 1];
            map.put(key, value);
        }
        return map;
    }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Python

from azure.identity import DefaultAzureCredential

from azure.mgmt.iotoperations import IoTOperationsMgmtClient

"""
# PREREQUISITES
    pip install azure-identity
    pip install azure-mgmt-iotoperations
# USAGE
    python broker_create_or_update_simple.py

    Before run the sample, please set the values of the client ID, tenant ID and client secret
    of the AAD application as environment variables: AZURE_CLIENT_ID, AZURE_TENANT_ID,
    AZURE_CLIENT_SECRET. For more info about how to get the value, please see:
    https://docs.microsoft.com/azure/active-directory/develop/howto-create-service-principal-portal
"""


def main():
    client = IoTOperationsMgmtClient(
        credential=DefaultAzureCredential(),
        subscription_id="SUBSCRIPTION_ID",
    )

    response = client.broker.begin_create_or_update(
        resource_group_name="rgiotoperations",
        instance_name="resource-name123",
        broker_name="resource-name123",
        resource={
            "extendedLocation": {"name": "qmbrfwcpwwhggszhrdjv", "type": "CustomLocation"},
            "properties": {
                "cardinality": {
                    "backendChain": {"partitions": 2, "redundancyFactor": 2, "workers": 2},
                    "frontend": {"replicas": 2, "workers": 2},
                },
                "generateResourceLimits": {"cpu": "Enabled"},
                "memoryProfile": "Low",
            },
        },
    ).result()
    print(response)


# x-ms-original-file: 2024-11-01/Broker_CreateOrUpdate_Simple.json
if __name__ == "__main__":
    main()

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Go

package armiotoperations_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/iotoperations/armiotoperations"
)

// Generated from example definition: 2024-11-01/Broker_CreateOrUpdate_Simple.json
func ExampleBrokerClient_BeginCreateOrUpdate_brokerCreateOrUpdateSimple() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armiotoperations.NewClientFactory("F8C729F9-DF9C-4743-848F-96EE433D8E53", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	poller, err := clientFactory.NewBrokerClient().BeginCreateOrUpdate(ctx, "rgiotoperations", "resource-name123", "resource-name123", armiotoperations.BrokerResource{
		Properties: &armiotoperations.BrokerProperties{
			Cardinality: &armiotoperations.Cardinality{
				BackendChain: &armiotoperations.BackendChain{
					Partitions:       to.Ptr[int32](2),
					RedundancyFactor: to.Ptr[int32](2),
					Workers:          to.Ptr[int32](2),
				},
				Frontend: &armiotoperations.Frontend{
					Replicas: to.Ptr[int32](2),
					Workers:  to.Ptr[int32](2),
				},
			},
			GenerateResourceLimits: &armiotoperations.GenerateResourceLimits{
				CPU: to.Ptr(armiotoperations.OperationalModeEnabled),
			},
			MemoryProfile: to.Ptr(armiotoperations.BrokerMemoryProfileLow),
		},
		ExtendedLocation: &armiotoperations.ExtendedLocation{
			Name: to.Ptr("qmbrfwcpwwhggszhrdjv"),
			Type: to.Ptr(armiotoperations.ExtendedLocationTypeCustomLocation),
		},
	}, nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	res, err := poller.PollUntilDone(ctx, nil)
	if err != nil {
		log.Fatalf("failed to pull the result: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res = armiotoperations.BrokerClientCreateOrUpdateResponse{
	// 	BrokerResource: &armiotoperations.BrokerResource{
	// 		Properties: &armiotoperations.BrokerProperties{
	// 			Advanced: &armiotoperations.AdvancedSettings{
	// 				Clients: &armiotoperations.ClientConfig{
	// 					MaxSessionExpirySeconds: to.Ptr[int32](3859),
	// 					MaxMessageExpirySeconds: to.Ptr[int32](3263),
	// 					MaxPacketSizeBytes: to.Ptr[int32](3029),
	// 					SubscriberQueueLimit: &armiotoperations.SubscriberQueueLimit{
	// 						Length: to.Ptr[int64](6),
	// 						Strategy: to.Ptr(armiotoperations.SubscriberMessageDropStrategyNone),
	// 					},
	// 					MaxReceiveMaximum: to.Ptr[int32](2365),
	// 					MaxKeepAliveSeconds: to.Ptr[int32](3744),
	// 				},
	// 				EncryptInternalTraffic: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 				InternalCerts: &armiotoperations.CertManagerCertOptions{
	// 					Duration: to.Ptr("bchrc"),
	// 					RenewBefore: to.Ptr("xkafmpgjfifkwwrhkswtopdnne"),
	// 					PrivateKey: &armiotoperations.CertManagerPrivateKey{
	// 						Algorithm: to.Ptr(armiotoperations.PrivateKeyAlgorithmEc256),
	// 						RotationPolicy: to.Ptr(armiotoperations.PrivateKeyRotationPolicyAlways),
	// 					},
	// 				},
	// 			},
	// 			Cardinality: &armiotoperations.Cardinality{
	// 				BackendChain: &armiotoperations.BackendChain{
	// 					Partitions: to.Ptr[int32](11),
	// 					RedundancyFactor: to.Ptr[int32](5),
	// 					Workers: to.Ptr[int32](15),
	// 				},
	// 				Frontend: &armiotoperations.Frontend{
	// 					Replicas: to.Ptr[int32](2),
	// 					Workers: to.Ptr[int32](6),
	// 				},
	// 			},
	// 			Diagnostics: &armiotoperations.BrokerDiagnostics{
	// 				Logs: &armiotoperations.DiagnosticsLogs{
	// 					Level: to.Ptr("rnmwokumdmebpmfxxxzvvjfdywotav"),
	// 				},
	// 				Metrics: &armiotoperations.Metrics{
	// 					PrometheusPort: to.Ptr[int32](7581),
	// 				},
	// 				SelfCheck: &armiotoperations.SelfCheck{
	// 					Mode: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 					IntervalSeconds: to.Ptr[int32](158),
	// 					TimeoutSeconds: to.Ptr[int32](14),
	// 				},
	// 				Traces: &armiotoperations.Traces{
	// 					Mode: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 					CacheSizeMegabytes: to.Ptr[int32](28),
	// 					SelfTracing: &armiotoperations.SelfTracing{
	// 						Mode: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 						IntervalSeconds: to.Ptr[int32](22),
	// 					},
	// 					SpanChannelCapacity: to.Ptr[int32](1000),
	// 				},
	// 			},
	// 			DiskBackedMessageBuffer: &armiotoperations.DiskBackedMessageBuffer{
	// 				MaxSize: to.Ptr("500M"),
	// 				EphemeralVolumeClaimSpec: &armiotoperations.VolumeClaimSpec{
	// 					VolumeName: to.Ptr("c"),
	// 					VolumeMode: to.Ptr("rxvpksjuuugqnqzeiprocknbn"),
	// 					StorageClassName: to.Ptr("sseyhrjptkhrqvpdpjmornkqvon"),
	// 					AccessModes: []*string{
	// 						to.Ptr("nuluhigrbb"),
	// 					},
	// 					DataSource: &armiotoperations.LocalKubernetesReference{
	// 						APIGroup: to.Ptr("npqapyksvvpkohujx"),
	// 						Kind: to.Ptr("wazgyb"),
	// 						Name: to.Ptr("cwhsgxxcxsyppoefm"),
	// 					},
	// 					DataSourceRef: &armiotoperations.KubernetesReference{
	// 						APIGroup: to.Ptr("mnfnykznjjsoqpfsgdqioupt"),
	// 						Kind: to.Ptr("odynqzekfzsnawrctaxg"),
	// 						Name: to.Ptr("envszivbbmixbyddzg"),
	// 						Namespace: to.Ptr("etcfzvxqd"),
	// 					},
	// 					Resources: &armiotoperations.VolumeClaimResourceRequirements{
	// 						Limits: map[string]*string{
	// 							"key2719": to.Ptr("hmphcrgctu"),
	// 						},
	// 						Requests: map[string]*string{
	// 							"key2909": to.Ptr("txocprnyrsgvhfrg"),
	// 						},
	// 					},
	// 					Selector: &armiotoperations.VolumeClaimSpecSelector{
	// 						MatchExpressions: []*armiotoperations.VolumeClaimSpecSelectorMatchExpressions{
	// 							{
	// 								Key: to.Ptr("e"),
	// 								Operator: to.Ptr(armiotoperations.OperatorValuesIn),
	// 								Values: []*string{
	// 									to.Ptr("slmpajlywqvuyknipgztsonqyybt"),
	// 								},
	// 							},
	// 						},
	// 						MatchLabels: map[string]*string{
	// 							"key6673": to.Ptr("wlngfalznwxnurzpgxomcxhbqefpr"),
	// 						},
	// 					},
	// 				},
	// 				PersistentVolumeClaimSpec: &armiotoperations.VolumeClaimSpec{
	// 					VolumeName: to.Ptr("c"),
	// 					VolumeMode: to.Ptr("rxvpksjuuugqnqzeiprocknbn"),
	// 					StorageClassName: to.Ptr("sseyhrjptkhrqvpdpjmornkqvon"),
	// 					AccessModes: []*string{
	// 						to.Ptr("nuluhigrbb"),
	// 					},
	// 					DataSource: &armiotoperations.LocalKubernetesReference{
	// 						APIGroup: to.Ptr("npqapyksvvpkohujx"),
	// 						Kind: to.Ptr("wazgyb"),
	// 						Name: to.Ptr("cwhsgxxcxsyppoefm"),
	// 					},
	// 					DataSourceRef: &armiotoperations.KubernetesReference{
	// 						APIGroup: to.Ptr("mnfnykznjjsoqpfsgdqioupt"),
	// 						Kind: to.Ptr("odynqzekfzsnawrctaxg"),
	// 						Name: to.Ptr("envszivbbmixbyddzg"),
	// 						Namespace: to.Ptr("etcfzvxqd"),
	// 					},
	// 					Resources: &armiotoperations.VolumeClaimResourceRequirements{
	// 						Limits: map[string]*string{
	// 							"key2719": to.Ptr("hmphcrgctu"),
	// 						},
	// 						Requests: map[string]*string{
	// 							"key2909": to.Ptr("txocprnyrsgvhfrg"),
	// 						},
	// 					},
	// 					Selector: &armiotoperations.VolumeClaimSpecSelector{
	// 						MatchExpressions: []*armiotoperations.VolumeClaimSpecSelectorMatchExpressions{
	// 							{
	// 								Key: to.Ptr("e"),
	// 								Operator: to.Ptr(armiotoperations.OperatorValuesIn),
	// 								Values: []*string{
	// 									to.Ptr("slmpajlywqvuyknipgztsonqyybt"),
	// 								},
	// 							},
	// 						},
	// 						MatchLabels: map[string]*string{
	// 							"key6673": to.Ptr("wlngfalznwxnurzpgxomcxhbqefpr"),
	// 						},
	// 					},
	// 				},
	// 			},
	// 			GenerateResourceLimits: &armiotoperations.GenerateResourceLimits{
	// 				CPU: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 			},
	// 			MemoryProfile: to.Ptr(armiotoperations.BrokerMemoryProfileTiny),
	// 			ProvisioningState: to.Ptr(armiotoperations.ProvisioningStateSucceeded),
	// 		},
	// 		ExtendedLocation: &armiotoperations.ExtendedLocation{
	// 			Name: to.Ptr("qmbrfwcpwwhggszhrdjv"),
	// 			Type: to.Ptr(armiotoperations.ExtendedLocationTypeCustomLocation),
	// 		},
	// 		ID: to.Ptr("/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123"),
	// 		Name: to.Ptr("dowrkel"),
	// 		Type: to.Ptr("xshjnsdgadygb"),
	// 		SystemData: &armiotoperations.SystemData{
	// 			CreatedBy: to.Ptr("ssvaslsmudloholronopqyxjcu"),
	// 			CreatedByType: to.Ptr(armiotoperations.CreatedByTypeUser),
	// 			CreatedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2024-08-09T18:13:29.389Z"); return t}()),
	// 			LastModifiedBy: to.Ptr("gnicpuszwd"),
	// 			LastModifiedByType: to.Ptr(armiotoperations.CreatedByTypeUser),
	// 			LastModifiedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2024-08-09T18:13:29.389Z"); return t}()),
	// 		},
	// 	},
	// }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

dotnet

using Azure;
using Azure.ResourceManager;
using System;
using System.Threading.Tasks;
using Azure.Core;
using Azure.Identity;
using Azure.ResourceManager.IotOperations.Models;
using Azure.ResourceManager.IotOperations;

// Generated from example definition: 2024-11-01/Broker_CreateOrUpdate_Simple.json
// this example is just showing the usage of "BrokerResource_CreateOrUpdate" operation, for the dependent resources, they will have to be created separately.

// get your azure access token, for more details of how Azure SDK get your access token, please refer to https://learn.microsoft.com/en-us/dotnet/azure/sdk/authentication?tabs=command-line
TokenCredential cred = new DefaultAzureCredential();
// authenticate your client
ArmClient client = new ArmClient(cred);

// this example assumes you already have this IotOperationsBrokerResource created on azure
// for more information of creating IotOperationsBrokerResource, please refer to the document of IotOperationsBrokerResource
string subscriptionId = "F8C729F9-DF9C-4743-848F-96EE433D8E53";
string resourceGroupName = "rgiotoperations";
string instanceName = "resource-name123";
string brokerName = "resource-name123";
ResourceIdentifier iotOperationsBrokerResourceId = IotOperationsBrokerResource.CreateResourceIdentifier(subscriptionId, resourceGroupName, instanceName, brokerName);
IotOperationsBrokerResource iotOperationsBroker = client.GetIotOperationsBrokerResource(iotOperationsBrokerResourceId);

// invoke the operation
IotOperationsBrokerData data = new IotOperationsBrokerData(new IotOperationsExtendedLocation("qmbrfwcpwwhggszhrdjv", IotOperationsExtendedLocationType.CustomLocation))
{
    Properties = new IotOperationsBrokerProperties
    {
        Cardinality = new BrokerCardinality(new BrokerBackendChain(2, 2)
        {
            Workers = 2,
        }, new BrokerFrontend(2)
        {
            Workers = 2,
        }),
        GenerateResourceLimitsCpu = IotOperationsOperationalMode.Enabled,
        MemoryProfile = BrokerMemoryProfile.Low,
    },
};
ArmOperation<IotOperationsBrokerResource> lro = await iotOperationsBroker.UpdateAsync(WaitUntil.Completed, data);
IotOperationsBrokerResource result = lro.Value;

// the variable result is a resource, you could call other operations on this instance as well
// but just for demo, we get its data from this resource instance
IotOperationsBrokerData resourceData = result.Data;
// for demo we just print out the id
Console.WriteLine($"Succeeded on id: {resourceData.Id}");

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Sample response

Status code:

200

{
  "properties": {
    "advanced": {
      "clients": {
        "maxSessionExpirySeconds": 3859,
        "maxMessageExpirySeconds": 3263,
        "maxPacketSizeBytes": 3029,
        "subscriberQueueLimit": {
          "length": 6,
          "strategy": "None"
        },
        "maxReceiveMaximum": 2365,
        "maxKeepAliveSeconds": 3744
      },
      "encryptInternalTraffic": "Enabled",
      "internalCerts": {
        "duration": "bchrc",
        "renewBefore": "xkafmpgjfifkwwrhkswtopdnne",
        "privateKey": {
          "algorithm": "Ec256",
          "rotationPolicy": "Always"
        }
      }
    },
    "cardinality": {
      "backendChain": {
        "partitions": 11,
        "redundancyFactor": 5,
        "workers": 15
      },
      "frontend": {
        "replicas": 2,
        "workers": 6
      }
    },
    "diagnostics": {
      "logs": {
        "level": "rnmwokumdmebpmfxxxzvvjfdywotav"
      },
      "metrics": {
        "prometheusPort": 7581
      },
      "selfCheck": {
        "mode": "Enabled",
        "intervalSeconds": 158,
        "timeoutSeconds": 14
      },
      "traces": {
        "mode": "Enabled",
        "cacheSizeMegabytes": 28,
        "selfTracing": {
          "mode": "Enabled",
          "intervalSeconds": 22
        },
        "spanChannelCapacity": 1000
      }
    },
    "diskBackedMessageBuffer": {
      "maxSize": "500M",
      "ephemeralVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      },
      "persistentVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      }
    },
    "generateResourceLimits": {
      "cpu": "Enabled"
    },
    "memoryProfile": "Tiny",
    "provisioningState": "Succeeded"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  },
  "id": "/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123",
  "name": "dowrkel",
  "type": "xshjnsdgadygb",
  "systemData": {
    "createdBy": "ssvaslsmudloholronopqyxjcu",
    "createdByType": "User",
    "createdAt": "2024-08-09T18:13:29.389Z",
    "lastModifiedBy": "gnicpuszwd",
    "lastModifiedByType": "User",
    "lastModifiedAt": "2024-08-09T18:13:29.389Z"
  }
}

Status code:

201

Azure-AsyncOperation: https://contoso.com/operationstatus

{
  "properties": {
    "advanced": {
      "clients": {
        "maxSessionExpirySeconds": 3859,
        "maxMessageExpirySeconds": 3263,
        "maxPacketSizeBytes": 3029,
        "subscriberQueueLimit": {
          "length": 6,
          "strategy": "None"
        },
        "maxReceiveMaximum": 2365,
        "maxKeepAliveSeconds": 3744
      },
      "encryptInternalTraffic": "Enabled",
      "internalCerts": {
        "duration": "bchrc",
        "renewBefore": "xkafmpgjfifkwwrhkswtopdnne",
        "privateKey": {
          "algorithm": "Ec256",
          "rotationPolicy": "Always"
        }
      }
    },
    "cardinality": {
      "backendChain": {
        "partitions": 11,
        "redundancyFactor": 5,
        "workers": 15
      },
      "frontend": {
        "replicas": 2,
        "workers": 6
      }
    },
    "diagnostics": {
      "logs": {
        "level": "rnmwokumdmebpmfxxxzvvjfdywotav"
      },
      "metrics": {
        "prometheusPort": 7581
      },
      "selfCheck": {
        "mode": "Enabled",
        "intervalSeconds": 158,
        "timeoutSeconds": 14
      },
      "traces": {
        "mode": "Enabled",
        "cacheSizeMegabytes": 28,
        "selfTracing": {
          "mode": "Enabled",
          "intervalSeconds": 22
        },
        "spanChannelCapacity": 1000
      }
    },
    "diskBackedMessageBuffer": {
      "maxSize": "500M",
      "ephemeralVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      },
      "persistentVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      }
    },
    "generateResourceLimits": {
      "cpu": "Enabled"
    },
    "memoryProfile": "Tiny",
    "provisioningState": "Succeeded"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  },
  "id": "/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123",
  "name": "dowrkel",
  "type": "xshjnsdgadygb",
  "systemData": {
    "createdBy": "ssvaslsmudloholronopqyxjcu",
    "createdByType": "User",
    "createdAt": "2024-08-09T18:13:29.389Z",
    "lastModifiedBy": "gnicpuszwd",
    "lastModifiedByType": "User",
    "lastModifiedAt": "2024-08-09T18:13:29.389Z"
  }
}

Definitions

Name	Description
AdvancedSettings	Broker Advanced Settings
BackendChain	Desired properties of the backend instances of the broker
BrokerDiagnostics	Broker Diagnostic Setting properties
BrokerMemoryProfile	The memory profile settings of the Broker
BrokerProperties	Broker Resource properties
BrokerResource	Instance broker resource
Cardinality	Cardinality properties
CertManagerCertOptions	Cert Manager Cert properties
CertManagerPrivateKey	Cert Manager private key properties
ClientConfig	The settings of Client Config.
createdByType	The type of identity that created the resource.
DiagnosticsLogs	Diagnostic Log properties
DiskBackedMessageBuffer	DiskBackedMessageBuffer properties
ErrorAdditionalInfo	The resource management error additional info.
ErrorDetail	The error detail.
ErrorResponse	Error response
ExtendedLocation	Extended location is an extension of Azure locations. They provide a way to use their Azure ARC enabled Kubernetes clusters as target locations for deploying Azure services instances.
ExtendedLocationType	The enum defining type of ExtendedLocation accepted.
Frontend	The desired properties of the frontend instances of the Broker
GenerateResourceLimits	GenerateResourceLimits properties
KubernetesReference	Kubernetes reference
LocalKubernetesReference	Kubernetes reference
Metrics	Diagnostic Metrics properties
OperationalMode	Mode properties
OperatorValues	Valid operators are In, NotIn, Exists and DoesNotExist.
PrivateKeyAlgorithm	Private key algorithm types.
PrivateKeyRotationPolicy	Private key rotation policy.
ProvisioningState	The enum defining status of resource.
SelfCheck	Broker Diagnostic Self check properties
SelfTracing	Diagnostic Self tracing properties
SubscriberMessageDropStrategy	The enum defining strategies for dropping messages from the subscriber queue.
SubscriberQueueLimit	The settings of Subscriber Queue Limit.
systemData	Metadata pertaining to creation and last modification of the resource.
Traces	Broker Diagnostic Trace properties
VolumeClaimResourceRequirements	VolumeClaimResourceRequirements properties
VolumeClaimSpec	VolumeClaimSpec properties
VolumeClaimSpecSelector	VolumeClaimSpecSelector properties
VolumeClaimSpecSelectorMatchExpressions	VolumeClaimSpecSelectorMatchExpressions properties

AdvancedSettings

Object

Broker Advanced Settings

Name	Type	Default value	Description
clients	ClientConfig		Configurations related to All Clients.
encryptInternalTraffic	OperationalMode	Enabled	The setting to enable or disable encryption of internal Traffic.
internalCerts	CertManagerCertOptions		Certificate rotation and private key configuration.

BackendChain

Object

Desired properties of the backend instances of the broker

Name	Type	Default value	Description
partitions	integer		The desired number of physical backend partitions.
redundancyFactor	integer		The desired numbers of backend replicas (pods) in a physical partition.
workers	integer	1	Number of logical backend workers per replica (pod).

BrokerDiagnostics

Object

Broker Diagnostic Setting properties

Name	Type	Description
logs	DiagnosticsLogs	Diagnostic log settings for the resource.
metrics	Metrics	The metrics settings for the resource.
selfCheck	SelfCheck	The self check properties.
traces	Traces	The trace properties.

BrokerMemoryProfile

Enumeration

The memory profile settings of the Broker

Value	Description
High	High memory profile.
Low	Low memory profile.
Medium	Medium memory profile.
Tiny	Tiny memory profile.

BrokerProperties

Object

Broker Resource properties

Name	Type	Default value	Description
advanced	AdvancedSettings		Advanced settings of Broker.
cardinality	Cardinality		The cardinality details of the broker.
diagnostics	BrokerDiagnostics		Spec defines the desired identities of Broker diagnostics settings.
diskBackedMessageBuffer	DiskBackedMessageBuffer		Settings of Disk Backed Message Buffer.
generateResourceLimits	GenerateResourceLimits		This setting controls whether Kubernetes CPU resource limits are requested. Increasing the number of replicas or workers proportionally increases the amount of CPU resources requested. If this setting is enabled and there are insufficient CPU resources, an error will be emitted.
memoryProfile	BrokerMemoryProfile	Medium	Memory profile of Broker.
provisioningState	ProvisioningState		The status of the last operation.

BrokerResource

Object

Instance broker resource

Name	Type	Description
extendedLocation	ExtendedLocation	Edge location of the resource.
id	string	Fully qualified resource ID for the resource. E.g. "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}"
name	string	The name of the resource
properties	BrokerProperties	The resource-specific properties for this resource.
systemData	systemData	Azure Resource Manager metadata containing createdBy and modifiedBy information.
type	string	The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"

Cardinality

Object

Cardinality properties

Name	Type	Description
backendChain	BackendChain	The backend broker desired properties
frontend	Frontend	The frontend desired properties

CertManagerCertOptions

Object

Cert Manager Cert properties

Name	Type	Description
duration	string	Lifetime of certificate. Must be specified using a Go time.Duration format (h|m|s). E.g. 240h for 240 hours and 45m for 45 minutes.
privateKey	CertManagerPrivateKey	Configuration of certificate private key.
renewBefore	string	When to begin renewing certificate. Must be specified using a Go time.Duration format (h|m|s). E.g. 240h for 240 hours and 45m for 45 minutes.

CertManagerPrivateKey

Object

Cert Manager private key properties

Name	Type	Description
algorithm	PrivateKeyAlgorithm	algorithm for private key.
rotationPolicy	PrivateKeyRotationPolicy	cert-manager private key rotationPolicy.

ClientConfig

Object

The settings of Client Config.

Name	Type	Description
maxKeepAliveSeconds	integer	Upper bound of a client's Keep Alive, in seconds.
maxMessageExpirySeconds	integer	Upper bound of Message Expiry Interval, in seconds.
maxPacketSizeBytes	integer	Max message size for a packet in Bytes.
maxReceiveMaximum	integer	Upper bound of Receive Maximum that a client can request in the CONNECT packet.
maxSessionExpirySeconds	integer	Upper bound of Session Expiry Interval, in seconds.
subscriberQueueLimit	SubscriberQueueLimit	The limit on the number of queued messages for a subscriber.

createdByType

Enumeration

The type of identity that created the resource.

Value	Description
Application
Key
ManagedIdentity
User

DiagnosticsLogs

Object

Diagnostic Log properties

Name	Type	Default value	Description
level	string	info	The log level. Examples - 'debug', 'info', 'warn', 'error', 'trace'.

DiskBackedMessageBuffer

Object

DiskBackedMessageBuffer properties

Name	Type	Description
ephemeralVolumeClaimSpec	VolumeClaimSpec	Use the specified persistent volume claim template to mount a "generic ephemeral volume" for the message buffer. See https://kubernetes.io/docs/concepts/storage/ephemeral-volumes/#generic-ephemeral-volumes for details.
maxSize	string	The max size of the message buffer on disk. If a PVC template is specified using one of ephemeralVolumeClaimSpec or persistentVolumeClaimSpec, then this size is used as the request and limit sizes of that template. If neither ephemeralVolumeClaimSpec nor persistentVolumeClaimSpec are specified, then an emptyDir volume is mounted with this size as its limit. See https://kubernetes.io/docs/concepts/storage/volumes/#emptydir for details.
persistentVolumeClaimSpec	VolumeClaimSpec	Use the specified persistent volume claim template to mount a persistent volume for the message buffer.

ErrorAdditionalInfo

Object

The resource management error additional info.

Name	Type	Description
info	object	The additional info.
type	string	The additional info type.

ErrorDetail

Object

The error detail.

Name	Type	Description
additionalInfo	ErrorAdditionalInfo[]	The error additional info.
code	string	The error code.
details	ErrorDetail[]	The error details.
message	string	The error message.
target	string	The error target.

ErrorResponse

Object

Error response

Name	Type	Description
error	ErrorDetail	The error object.

ExtendedLocation

Object

Extended location is an extension of Azure locations. They provide a way to use their Azure ARC enabled Kubernetes clusters as target locations for deploying Azure services instances.

Name	Type	Description
name	string	The name of the extended location.
type	ExtendedLocationType	Type of ExtendedLocation.

ExtendedLocationType

Enumeration

The enum defining type of ExtendedLocation accepted.

Value	Description
CustomLocation	CustomLocation type

Frontend

Object

The desired properties of the frontend instances of the Broker

Name	Type	Default value	Description
replicas	integer		The desired number of frontend instances (pods).
workers	integer	2	Number of logical frontend workers per instance (pod).

GenerateResourceLimits

Object

GenerateResourceLimits properties

Name	Type	Default value	Description
cpu	OperationalMode	Enabled	The toggle to enable/disable cpu resource limits.

KubernetesReference

Object

Kubernetes reference

Name	Type	Description
apiGroup	string	APIGroup is the group for the resource being referenced. If APIGroup is not specified, the specified Kind must be in the core API group. For any other third-party types, APIGroup is required.
kind	string	Kind is the type of resource being referenced
name	string	Name is the name of resource being referenced
namespace	string	Namespace is the namespace of the resource being referenced. This field is required when the resource has a namespace.

LocalKubernetesReference

Object

Kubernetes reference

Name	Type	Description
apiGroup	string	APIGroup is the group for the resource being referenced. If APIGroup is not specified, the specified Kind must be in the core API group. For any other third-party types, APIGroup is required.
kind	string	Kind is the type of resource being referenced
name	string	Name is the name of resource being referenced

Metrics

Object

Diagnostic Metrics properties

Name	Type	Default value	Description
prometheusPort	integer	9600	The prometheus port to expose the metrics.

OperationalMode

Enumeration

Mode properties

Value	Description
Disabled	Disabled is equivalent to False.
Enabled	Enabled is equivalent to True

OperatorValues

Enumeration

Valid operators are In, NotIn, Exists and DoesNotExist.

Value	Description
DoesNotExist	DoesNotExist operator.
Exists	Exists operator.
In	In operator.
NotIn	NotIn operator.

PrivateKeyAlgorithm

Enumeration

Private key algorithm types.

Value	Description
Ec256	Algorithm - ec256.
Ec384	Algorithm - ec384.
Ec521	Algorithm - ec521.
Ed25519	Algorithm - ed25519.
Rsa2048	Algorithm - rsa2048.
Rsa4096	Algorithm - rsa4096.
Rsa8192	Algorithm - rsa8192.

PrivateKeyRotationPolicy

Enumeration

Private key rotation policy.

Value	Description
Always	Rotation Policy - Always.
Never	Rotation Policy - Never.

ProvisioningState

Enumeration

The enum defining status of resource.

Value	Description
Accepted	Resource has been Accepted.
Canceled	Resource creation was canceled.
Deleting	Resource is Deleting.
Failed	Resource creation failed.
Provisioning	Resource is getting provisioned.
Succeeded	Resource has been created.
Updating	Resource is Updating.

SelfCheck

Object

Broker Diagnostic Self check properties

Name	Type	Default value	Description
intervalSeconds	integer	30	The self check interval.
mode	OperationalMode	Enabled	The toggle to enable/disable self check.
timeoutSeconds	integer	15	The timeout for self check.

SelfTracing

Object

Diagnostic Self tracing properties

Name	Type	Default value	Description
intervalSeconds	integer	30	The self tracing interval.
mode	OperationalMode	Enabled	The toggle to enable/disable self tracing.

SubscriberMessageDropStrategy

Enumeration

The enum defining strategies for dropping messages from the subscriber queue.

Value	Description
DropOldest	The oldest message is dropped.
None	Messages are never dropped.

SubscriberQueueLimit

Object

The settings of Subscriber Queue Limit.

Name	Type	Default value	Description
length	integer		The maximum length of the queue before messages start getting dropped.
strategy	SubscriberMessageDropStrategy	None	The strategy to use for dropping messages from the queue.

systemData

Object

Metadata pertaining to creation and last modification of the resource.

Name	Type	Description
createdAt	string	The timestamp of resource creation (UTC).
createdBy	string	The identity that created the resource.
createdByType	createdByType	The type of identity that created the resource.
lastModifiedAt	string	The timestamp of resource last modification (UTC)
lastModifiedBy	string	The identity that last modified the resource.
lastModifiedByType	createdByType	The type of identity that last modified the resource.

Traces

Object

Broker Diagnostic Trace properties

Name	Type	Default value	Description
cacheSizeMegabytes	integer	16	The cache size in megabytes.
mode	OperationalMode	Enabled	The toggle to enable/disable traces.
selfTracing	SelfTracing		The self tracing properties.
spanChannelCapacity	integer	1000	The span channel capacity.

VolumeClaimResourceRequirements

Object

VolumeClaimResourceRequirements properties

Name	Type	Description
limits	object	Limits describes the maximum amount of compute resources allowed. More info: https://kubernetes.io/docs/concepts/configuration/manage-resources-containers/
requests	object	Requests describes the minimum amount of compute resources required. If Requests is omitted for a container, it defaults to Limits if that is explicitly specified, otherwise to an implementation-defined value. More info: https://kubernetes.io/docs/concepts/configuration/manage-resources-containers/

VolumeClaimSpec

Object

VolumeClaimSpec properties

Name	Type	Description
accessModes	string[]	AccessModes contains the desired access modes the volume should have. More info: https://kubernetes.io/docs/concepts/storage/persistent-volumes#access-modes-1
dataSource	LocalKubernetesReference	This field can be used to specify either: * An existing VolumeSnapshot object (snapshot.storage.k8s.io/VolumeSnapshot) * An existing PVC (PersistentVolumeClaim) If the provisioner or an external controller can support the specified data source, it will create a new volume based on the contents of the specified data source. If the AnyVolumeDataSource feature gate is enabled, this field will always have the same contents as the DataSourceRef field.
dataSourceRef	KubernetesReference	Specifies the object from which to populate the volume with data, if a non-empty volume is desired. This may be any local object from a non-empty API group (non core object) or a PersistentVolumeClaim object. When this field is specified, volume binding will only succeed if the type of the specified object matches some installed volume populator or dynamic provisioner. This field will replace the functionality of the DataSource field and as such if both fields are non-empty, they must have the same value. For backwards compatibility, both fields (DataSource and DataSourceRef) will be set to the same value automatically if one of them is empty and the other is non-empty. There are two important differences between DataSource and DataSourceRef: * While DataSource only allows two specific types of objects, DataSourceRef allows any non-core object, as well as PersistentVolumeClaim objects. * While DataSource ignores disallowed values (dropping them), DataSourceRef preserves all values, and generates an error if a disallowed value is specified. (Beta) Using this field requires the AnyVolumeDataSource feature gate to be enabled.
resources	VolumeClaimResourceRequirements	Resources represents the minimum resources the volume should have. If RecoverVolumeExpansionFailure feature is enabled users are allowed to specify resource requirements that are lower than previous value but must still be higher than capacity recorded in the status field of the claim. More info: https://kubernetes.io/docs/concepts/storage/persistent-volumes#resources
selector	VolumeClaimSpecSelector	A label query over volumes to consider for binding.
storageClassName	string	Name of the StorageClass required by the claim. More info: https://kubernetes.io/docs/concepts/storage/persistent-volumes#class-1
volumeMode	string	volumeMode defines what type of volume is required by the claim. Value of Filesystem is implied when not included in claim spec. This is a beta feature.
volumeName	string	VolumeName is the binding reference to the PersistentVolume backing this claim.

VolumeClaimSpecSelector

Object

VolumeClaimSpecSelector properties

Name	Type	Description
matchExpressions	VolumeClaimSpecSelectorMatchExpressions[]	MatchExpressions is a list of label selector requirements. The requirements are ANDed.
matchLabels	object	MatchLabels is a map of {key,value} pairs. A single {key,value} in the matchLabels map is equivalent to an element of matchExpressions, whose key field is "key", the operator is "In", and the values array contains only "value". The requirements are ANDed.

VolumeClaimSpecSelectorMatchExpressions

Object

VolumeClaimSpecSelectorMatchExpressions properties

Name	Type	Description
key	string	key is the label key that the selector applies to.
operator	OperatorValues	operator represents a key's relationship to a set of values. Valid operators are In, NotIn, Exists and DoesNotExist.
values	string[]	values is an array of string values. If the operator is In or NotIn, the values array must be non-empty. If the operator is Exists or DoesNotExist, the values array must be empty. This array is replaced during a strategic merge patch.