Package-level declarations

Types

Link copied to clipboard
data class AdvancedSettingsResponse(val clients: ClientConfigResponse? = null, val encryptInternalTraffic: String? = null, val internalCerts: CertManagerCertOptionsResponse? = null)

Broker Advanced Settings

Link copied to clipboard
data class AuthorizationConfigResponse(val cache: String? = null, val rules: List<AuthorizationRuleResponse>? = null)

Broker AuthorizationConfig properties

Link copied to clipboard
data class AuthorizationRuleResponse(val brokerResources: List<BrokerResourceRuleResponse>, val principals: PrincipalDefinitionResponse, val stateStoreResources: List<StateStoreResourceRuleResponse>? = null)

AuthorizationConfig Rule Properties

Link copied to clipboard
data class BackendChainResponse(val partitions: Int, val redundancyFactor: Int, val workers: Int? = null)

Desired properties of the backend instances of the broker

Link copied to clipboard
data class BatchingConfigurationResponse(val latencySeconds: Int? = null, val maxMessages: Int? = null)

Batching configuration

Link copied to clipboard
data class BrokerAuthenticationPropertiesResponse(val authenticationMethods: List<BrokerAuthenticatorMethodsResponse>, val provisioningState: String)

BrokerAuthentication Resource properties

Link copied to clipboard

Custom Authentication properties

Link copied to clipboard
data class BrokerAuthenticatorMethodCustomResponse(val auth: BrokerAuthenticatorCustomAuthResponse? = null, val caCertConfigMap: String? = null, val endpoint: String, val headers: Map<String, String>? = null)

Custom method for BrokerAuthentication

Link copied to clipboard

Service Account Token for BrokerAuthentication

Link copied to clipboard
data class BrokerAuthenticatorMethodsResponse(val customSettings: BrokerAuthenticatorMethodCustomResponse? = null, val method: String, val serviceAccountTokenSettings: BrokerAuthenticatorMethodSatResponse? = null, val x509Settings: BrokerAuthenticatorMethodX509Response? = null)

Set of broker authentication policies. Only one method is supported for each entry.

data class BrokerAuthenticatorMethodX509AttributesResponse(val attributes: Map<String, String>, val subject: String)

BrokerAuthenticatorMethodX509Attributes properties.

Link copied to clipboard
data class BrokerAuthenticatorMethodX509Response(val authorizationAttributes: Map<String, BrokerAuthenticatorMethodX509AttributesResponse>? = null, val trustedClientCaCert: String? = null)

X509 for BrokerAuthentication.

Link copied to clipboard
data class BrokerAuthorizationPropertiesResponse(val authorizationPolicies: AuthorizationConfigResponse, val provisioningState: String)

BrokerAuthorization Resource properties

Link copied to clipboard
data class BrokerDiagnosticsResponse(val logs: DiagnosticsLogsResponse? = null, val metrics: MetricsResponse? = null, val selfCheck: SelfCheckResponse? = null, val traces: TracesResponse? = null)

Broker Diagnostic Setting properties

Link copied to clipboard
data class BrokerListenerPropertiesResponse(val ports: List<ListenerPortResponse>, val provisioningState: String, val serviceName: String? = null, val serviceType: String? = null)

Defines a Broker listener. A listener is a collection of ports on which the broker accepts connections from clients.

Link copied to clipboard
data class BrokerPropertiesResponse(val advanced: AdvancedSettingsResponse? = null, val cardinality: CardinalityResponse? = null, val diagnostics: BrokerDiagnosticsResponse? = null, val diskBackedMessageBuffer: DiskBackedMessageBufferResponse? = null, val generateResourceLimits: GenerateResourceLimitsResponse? = null, val memoryProfile: String? = null, val provisioningState: String)

Broker Resource properties

Link copied to clipboard
data class BrokerResourceRuleResponse(val clientIds: List<String>? = null, val method: String, val topics: List<String>? = null)

Broker Resource Rule properties. This defines the objects that represent the actions or topics, such as - method.Connect, method.Publish, etc.

Link copied to clipboard
data class CardinalityResponse(val backendChain: BackendChainResponse, val frontend: FrontendResponse)

Cardinality properties

Link copied to clipboard
data class CertManagerCertificateSpecResponse(val duration: String? = null, val issuerRef: CertManagerIssuerRefResponse, val privateKey: CertManagerPrivateKeyResponse? = null, val renewBefore: String? = null, val san: SanForCertResponse? = null, val secretName: String? = null)

Automatic TLS server certificate management with cert-manager

Link copied to clipboard
data class CertManagerCertOptionsResponse(val duration: String, val privateKey: CertManagerPrivateKeyResponse, val renewBefore: String)

Cert Manager Cert properties

Link copied to clipboard
data class CertManagerIssuerRefResponse(val group: String, val kind: String, val name: String)

Cert-Manager issuerRef properties

Link copied to clipboard
data class CertManagerPrivateKeyResponse(val algorithm: String, val rotationPolicy: String)

Cert Manager private key properties

Link copied to clipboard
data class ClientConfigResponse(val maxKeepAliveSeconds: Int? = null, val maxMessageExpirySeconds: Int? = null, val maxPacketSizeBytes: Int? = null, val maxReceiveMaximum: Int? = null, val maxSessionExpirySeconds: Int? = null, val subscriberQueueLimit: SubscriberQueueLimitResponse? = null)

The settings of Client Config.

data class DataflowBuiltInTransformationDatasetResponse(val description: String? = null, val expression: String? = null, val inputs: List<String>, val key: String, val schemaRef: String? = null)

Dataflow BuiltIn Transformation dataset properties

data class DataflowBuiltInTransformationFilterResponse(val description: String? = null, val expression: String, val inputs: List<String>, val type: String? = null)

Dataflow BuiltIn Transformation filter properties

Link copied to clipboard
data class DataflowBuiltInTransformationMapResponse(val description: String? = null, val expression: String? = null, val inputs: List<String>, val output: String, val type: String? = null)

Dataflow BuiltIn Transformation map properties

data class DataflowBuiltInTransformationSettingsResponse(val datasets: List<DataflowBuiltInTransformationDatasetResponse>? = null, val filter: List<DataflowBuiltInTransformationFilterResponse>? = null, val map: List<DataflowBuiltInTransformationMapResponse>? = null, val schemaRef: String? = null, val serializationFormat: String? = null)

Dataflow BuiltIn Transformation properties

data class DataflowDestinationOperationSettingsResponse(val dataDestination: String, val endpointRef: String)

Dataflow Destination Operation properties

DataflowEndpoint Authentication Access Token properties

data class DataflowEndpointAuthenticationSaslResponse(val saslType: String, val secretRef: String)

DataflowEndpoint Authentication Sasl properties

Service Account Token for BrokerAuthentication

DataflowEndpoint Authentication SystemAssignedManagedIdentity properties

data class DataflowEndpointAuthenticationUserAssignedManagedIdentityResponse(val clientId: String, val scope: String? = null, val tenantId: String)

DataflowEndpoint Authentication UserAssignedManagedIdentity properties

DataflowEndpoint Authentication X509 properties

data class DataflowEndpointDataExplorerAuthenticationResponse(val method: Any, val systemAssignedManagedIdentitySettings: DataflowEndpointAuthenticationSystemAssignedManagedIdentityResponse? = null, val userAssignedManagedIdentitySettings: DataflowEndpointAuthenticationUserAssignedManagedIdentityResponse? = null)

Azure Data Explorer Authentication properties. NOTE - only authentication property is allowed per entry.

Link copied to clipboard
data class DataflowEndpointDataExplorerResponse(val authentication: DataflowEndpointDataExplorerAuthenticationResponse, val batching: BatchingConfigurationResponse? = null, val database: String, val host: String)

Azure Data Explorer endpoint properties

data class DataflowEndpointDataLakeStorageAuthenticationResponse(val accessTokenSettings: DataflowEndpointAuthenticationAccessTokenResponse? = null, val method: String, val systemAssignedManagedIdentitySettings: DataflowEndpointAuthenticationSystemAssignedManagedIdentityResponse? = null, val userAssignedManagedIdentitySettings: DataflowEndpointAuthenticationUserAssignedManagedIdentityResponse? = null)

Azure Data Lake endpoint Authentication properties. NOTE Enum - Only one method is supported for one entry

Link copied to clipboard

Azure Data Lake endpoint properties

data class DataflowEndpointFabricOneLakeAuthenticationResponse(val method: Any, val systemAssignedManagedIdentitySettings: DataflowEndpointAuthenticationSystemAssignedManagedIdentityResponse? = null, val userAssignedManagedIdentitySettings: DataflowEndpointAuthenticationUserAssignedManagedIdentityResponse? = null)

Microsoft Fabric endpoint. Authentication properties. NOTE - Only one method is supported for one entry

data class DataflowEndpointFabricOneLakeNamesResponse(val lakehouseName: String, val workspaceName: String)

Microsoft Fabric endpoint Names properties

Link copied to clipboard

Microsoft Fabric endpoint properties

data class DataflowEndpointKafkaAuthenticationResponse(val method: String, val saslSettings: DataflowEndpointAuthenticationSaslResponse? = null, val systemAssignedManagedIdentitySettings: DataflowEndpointAuthenticationSystemAssignedManagedIdentityResponse? = null, val userAssignedManagedIdentitySettings: DataflowEndpointAuthenticationUserAssignedManagedIdentityResponse? = null, val x509CertificateSettings: DataflowEndpointAuthenticationX509Response? = null)

Kafka endpoint Authentication properties. NOTE - only authentication property is allowed per entry

Link copied to clipboard
data class DataflowEndpointKafkaBatchingResponse(val latencyMs: Int? = null, val maxBytes: Int? = null, val maxMessages: Int? = null, val mode: String? = null)

Kafka endpoint Batching properties

Link copied to clipboard
data class DataflowEndpointKafkaResponse(val authentication: DataflowEndpointKafkaAuthenticationResponse, val batching: DataflowEndpointKafkaBatchingResponse? = null, val cloudEventAttributes: String? = null, val compression: String? = null, val consumerGroupId: String? = null, val copyMqttProperties: String? = null, val host: String, val kafkaAcks: String? = null, val partitionStrategy: String? = null, val tls: TlsPropertiesResponse? = null)

Kafka endpoint properties

Link copied to clipboard
data class DataflowEndpointLocalStorageResponse(val persistentVolumeClaimRef: String)

Local persistent volume endpoint properties

data class DataflowEndpointMqttAuthenticationResponse(val method: String, val serviceAccountTokenSettings: DataflowEndpointAuthenticationServiceAccountTokenResponse? = null, val systemAssignedManagedIdentitySettings: DataflowEndpointAuthenticationSystemAssignedManagedIdentityResponse? = null, val userAssignedManagedIdentitySettings: DataflowEndpointAuthenticationUserAssignedManagedIdentityResponse? = null, val x509CertificateSettings: DataflowEndpointAuthenticationX509Response? = null)

Mqtt endpoint Authentication properties. NOTE - only authentication property is allowed per entry.

Link copied to clipboard
data class DataflowEndpointMqttResponse(val authentication: DataflowEndpointMqttAuthenticationResponse, val clientIdPrefix: String? = null, val cloudEventAttributes: String? = null, val host: String? = null, val keepAliveSeconds: Int? = null, val maxInflightMessages: Int? = null, val protocol: String? = null, val qos: Int? = null, val retain: String? = null, val sessionExpirySeconds: Int? = null, val tls: TlsPropertiesResponse? = null)

Broker endpoint properties

Link copied to clipboard
data class DataflowEndpointPropertiesResponse(val dataExplorerSettings: DataflowEndpointDataExplorerResponse? = null, val dataLakeStorageSettings: DataflowEndpointDataLakeStorageResponse? = null, val endpointType: String, val fabricOneLakeSettings: DataflowEndpointFabricOneLakeResponse? = null, val kafkaSettings: DataflowEndpointKafkaResponse? = null, val localStorageSettings: DataflowEndpointLocalStorageResponse? = null, val mqttSettings: DataflowEndpointMqttResponse? = null, val provisioningState: String)

DataflowEndpoint Resource properties. NOTE - Only one type of endpoint is supported for one Resource

Link copied to clipboard
data class DataflowOperationResponse(val builtInTransformationSettings: DataflowBuiltInTransformationSettingsResponse? = null, val destinationSettings: DataflowDestinationOperationSettingsResponse? = null, val name: String? = null, val operationType: String, val sourceSettings: DataflowSourceOperationSettingsResponse? = null)

Dataflow Operation properties. NOTE - One only method is allowed to be used for one entry.

Link copied to clipboard
data class DataflowProfilePropertiesResponse(val diagnostics: ProfileDiagnosticsResponse? = null, val instanceCount: Int? = null, val provisioningState: String)

DataflowProfile Resource properties

Link copied to clipboard
data class DataflowPropertiesResponse(val mode: String? = null, val operations: List<DataflowOperationResponse>, val provisioningState: String)

Dataflow Resource properties

Link copied to clipboard
data class DataflowSourceOperationSettingsResponse(val assetRef: String? = null, val dataSources: List<String>, val endpointRef: String, val schemaRef: String? = null, val serializationFormat: String? = null)

Dataflow Source Operation properties

Link copied to clipboard
data class DiagnosticsLogsResponse(val level: String? = null)

Diagnostic Log properties

Link copied to clipboard
data class DiskBackedMessageBufferResponse(val ephemeralVolumeClaimSpec: VolumeClaimSpecResponse? = null, val maxSize: String, val persistentVolumeClaimSpec: VolumeClaimSpecResponse? = null)

DiskBackedMessageBuffer properties

Link copied to clipboard
data class ExtendedLocationResponse(val name: String, val type: String)

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.

Link copied to clipboard
data class FrontendResponse(val replicas: Int, val workers: Int? = null)

The desired properties of the frontend instances of the Broker

Link copied to clipboard
data class GenerateResourceLimitsResponse(val cpu: String? = null)

GenerateResourceLimits properties

Link copied to clipboard
data class GetBrokerAuthenticationResult(val azureApiVersion: String, val extendedLocation: ExtendedLocationResponse, val id: String, val name: String, val properties: BrokerAuthenticationPropertiesResponse, val systemData: SystemDataResponse, val type: String)

Instance broker authentication resource

Link copied to clipboard
data class GetBrokerAuthorizationResult(val azureApiVersion: String, val extendedLocation: ExtendedLocationResponse, val id: String, val name: String, val properties: BrokerAuthorizationPropertiesResponse, val systemData: SystemDataResponse, val type: String)

Instance broker authorizations resource

Link copied to clipboard
data class GetBrokerListenerResult(val azureApiVersion: String, val extendedLocation: ExtendedLocationResponse, val id: String, val name: String, val properties: BrokerListenerPropertiesResponse, val systemData: SystemDataResponse, val type: String)

Instance broker resource

Link copied to clipboard
data class GetBrokerResult(val azureApiVersion: String, val extendedLocation: ExtendedLocationResponse, val id: String, val name: String, val properties: BrokerPropertiesResponse, val systemData: SystemDataResponse, val type: String)

Instance broker resource

Link copied to clipboard
data class GetDataflowEndpointResult(val azureApiVersion: String, val extendedLocation: ExtendedLocationResponse, val id: String, val name: String, val properties: DataflowEndpointPropertiesResponse, val systemData: SystemDataResponse, val type: String)

Instance dataflowEndpoint resource

Link copied to clipboard
data class GetDataflowProfileResult(val azureApiVersion: String, val extendedLocation: ExtendedLocationResponse, val id: String, val name: String, val properties: DataflowProfilePropertiesResponse, val systemData: SystemDataResponse, val type: String)

Instance dataflowProfile resource

Link copied to clipboard
data class GetDataflowResult(val azureApiVersion: String, val extendedLocation: ExtendedLocationResponse, val id: String, val name: String, val properties: DataflowPropertiesResponse, val systemData: SystemDataResponse, val type: String)

Instance dataflowProfile dataflow resource

Link copied to clipboard
data class GetInstanceResult(val azureApiVersion: String, val extendedLocation: ExtendedLocationResponse, val id: String, val identity: ManagedServiceIdentityResponse? = null, val location: String, val name: String, val properties: InstancePropertiesResponse, val systemData: SystemDataResponse, val tags: Map<String, String>? = null, val type: String)

A Instance resource is a logical container for a set of child resources.

Link copied to clipboard
data class InstancePropertiesResponse(val description: String? = null, val provisioningState: String, val schemaRegistryRef: SchemaRegistryRefResponse, val version: String)

The properties of the Instance resource.

Link copied to clipboard
data class KubernetesReferenceResponse(val apiGroup: String? = null, val kind: String, val name: String, val namespace: String? = null)

Kubernetes reference

Link copied to clipboard
data class ListenerPortResponse(val authenticationRef: String? = null, val authorizationRef: String? = null, val nodePort: Int? = null, val port: Int, val protocol: String? = null, val tls: TlsCertMethodResponse? = null)

Defines a TCP port on which a BrokerListener listens.

Link copied to clipboard
data class LocalKubernetesReferenceResponse(val apiGroup: String? = null, val kind: String, val name: String)

Kubernetes reference

Link copied to clipboard
data class ManagedServiceIdentityResponse(val principalId: String, val tenantId: String, val type: String, val userAssignedIdentities: Map<String, UserAssignedIdentityResponse>? = null)

Managed service identity (system assigned and/or user assigned identities)

Link copied to clipboard
data class MetricsResponse(val prometheusPort: Int? = null)

Diagnostic Metrics properties

Link copied to clipboard
data class PrincipalDefinitionResponse(val attributes: List<Map<String, String>>? = null, val clientIds: List<String>? = null, val usernames: List<String>? = null)

PrincipalDefinition properties of Rule

Link copied to clipboard
data class ProfileDiagnosticsResponse(val logs: DiagnosticsLogsResponse? = null, val metrics: MetricsResponse? = null)

DataflowProfile Diagnostics properties

Link copied to clipboard
data class SanForCertResponse(val dns: List<String>, val ip: List<String>)

Subject Alternative Names (SANs) for certificate.

Link copied to clipboard
data class SchemaRegistryRefResponse(val resourceId: String)

The reference to the Schema Registry for this AIO Instance.

Link copied to clipboard
data class SelfCheckResponse(val intervalSeconds: Int? = null, val mode: String? = null, val timeoutSeconds: Int? = null)

Broker Diagnostic Self check properties

Link copied to clipboard
data class SelfTracingResponse(val intervalSeconds: Int? = null, val mode: String? = null)

Diagnostic Self tracing properties

Link copied to clipboard
data class StateStoreResourceRuleResponse(val keyType: String, val keys: List<String>, val method: String)

State Store Resource Rule properties.

Link copied to clipboard
data class SubscriberQueueLimitResponse(val length: Double? = null, val strategy: String? = null)

The settings of Subscriber Queue Limit.

Link copied to clipboard
data class SystemDataResponse(val createdAt: String? = null, val createdBy: String? = null, val createdByType: String? = null, val lastModifiedAt: String? = null, val lastModifiedBy: String? = null, val lastModifiedByType: String? = null)

Metadata pertaining to creation and last modification of the resource.

Link copied to clipboard
data class TlsCertMethodResponse(val certManagerCertificateSpec: CertManagerCertificateSpecResponse? = null, val manual: X509ManualCertificateResponse? = null, val mode: String)

Collection of different TLS types, NOTE- Enum at a time only one of them needs to be supported

Link copied to clipboard
data class TlsPropertiesResponse(val mode: String? = null, val trustedCaCertificateConfigMapRef: String? = null)

Tls properties

Link copied to clipboard
data class TracesResponse(val cacheSizeMegabytes: Int? = null, val mode: String? = null, val selfTracing: SelfTracingResponse? = null, val spanChannelCapacity: Int? = null)

Broker Diagnostic Trace properties

Link copied to clipboard
data class UserAssignedIdentityResponse(val clientId: String, val principalId: String)

User assigned identity properties

Link copied to clipboard
data class VolumeClaimResourceRequirementsResponse(val limits: Map<String, String>? = null, val requests: Map<String, String>? = null)

VolumeClaimResourceRequirements properties

Link copied to clipboard
data class VolumeClaimSpecResponse(val accessModes: List<String>? = null, val dataSource: LocalKubernetesReferenceResponse? = null, val dataSourceRef: KubernetesReferenceResponse? = null, val resources: VolumeClaimResourceRequirementsResponse? = null, val selector: VolumeClaimSpecSelectorResponse? = null, val storageClassName: String? = null, val volumeMode: String? = null, val volumeName: String? = null)

VolumeClaimSpec properties

data class VolumeClaimSpecSelectorMatchExpressionsResponse(val key: String, val operator: String, val values: List<String>? = null)

VolumeClaimSpecSelectorMatchExpressions properties

Link copied to clipboard
data class VolumeClaimSpecSelectorResponse(val matchExpressions: List<VolumeClaimSpecSelectorMatchExpressionsResponse>? = null, val matchLabels: Map<String, String>? = null)

VolumeClaimSpecSelector properties

Link copied to clipboard
data class X509ManualCertificateResponse(val secretRef: String)

X509 Certificate Authentication properties.