Dataflow
data class DataflowEndpointMqttArgs(val authentication: Output<DataflowEndpointMqttAuthenticationArgs>, val clientIdPrefix: Output<String>? = null, val cloudEventAttributes: Output<Either<String, CloudEventAttributeType>>? = null, val host: Output<String>? = null, val keepAliveSeconds: Output<Int>? = null, val maxInflightMessages: Output<Int>? = null, val protocol: Output<Either<String, BrokerProtocolType>>? = null, val qos: Output<Int>? = null, val retain: Output<Either<String, MqttRetainType>>? = null, val sessionExpirySeconds: Output<Int>? = null, val tls: Output<TlsPropertiesArgs>? = null) : ConvertibleToJava<DataflowEndpointMqttArgs>
Broker endpoint properties
Constructors
Link copied to clipboard
constructor(authentication: Output<DataflowEndpointMqttAuthenticationArgs>, clientIdPrefix: Output<String>? = null, cloudEventAttributes: Output<Either<String, CloudEventAttributeType>>? = null, host: Output<String>? = null, keepAliveSeconds: Output<Int>? = null, maxInflightMessages: Output<Int>? = null, protocol: Output<Either<String, BrokerProtocolType>>? = null, qos: Output<Int>? = null, retain: Output<Either<String, MqttRetainType>>? = null, sessionExpirySeconds: Output<Int>? = null, tls: Output<TlsPropertiesArgs>? = null)
Properties
Link copied to clipboard
authentication properties. DEFAULT: kubernetes.audience=aio-internal. NOTE - Enum field only property is allowed
Link copied to clipboard
Client ID prefix. Client ID generated by the dataflow is
Link copied to clipboard
Cloud event mapping config.
Link copied to clipboard
Broker KeepAlive for connection in seconds.
Link copied to clipboard
The max number of messages to keep in flight. For subscribe, this is the receive maximum. For publish, this is the maximum number of messages to send before waiting for an ack.
Link copied to clipboard
Enable or disable websockets.
Link copied to clipboard
Whether or not to keep the retain setting.
Link copied to clipboard
Session expiry in seconds.
Link copied to clipboard
TLS configuration.