Documentation
¶
Index ¶
- Constants
- type Connector
- type ConnectorApacheKafkaCluster
- type ConnectorApacheKafkaClusterArgs
- func (ConnectorApacheKafkaClusterArgs) ElementType() reflect.Type
- func (i ConnectorApacheKafkaClusterArgs) ToConnectorApacheKafkaClusterOutput() ConnectorApacheKafkaClusterOutput
- func (i ConnectorApacheKafkaClusterArgs) ToConnectorApacheKafkaClusterOutputWithContext(ctx context.Context) ConnectorApacheKafkaClusterOutput
- type ConnectorApacheKafkaClusterInput
- type ConnectorApacheKafkaClusterOutput
- func (o ConnectorApacheKafkaClusterOutput) BootstrapServers() pulumi.StringOutput
- func (ConnectorApacheKafkaClusterOutput) ElementType() reflect.Type
- func (o ConnectorApacheKafkaClusterOutput) ToConnectorApacheKafkaClusterOutput() ConnectorApacheKafkaClusterOutput
- func (o ConnectorApacheKafkaClusterOutput) ToConnectorApacheKafkaClusterOutputWithContext(ctx context.Context) ConnectorApacheKafkaClusterOutput
- func (o ConnectorApacheKafkaClusterOutput) Vpc() ConnectorVpcOutput
- type ConnectorArgs
- type ConnectorAutoScaling
- type ConnectorAutoScalingArgs
- func (ConnectorAutoScalingArgs) ElementType() reflect.Type
- func (i ConnectorAutoScalingArgs) ToConnectorAutoScalingOutput() ConnectorAutoScalingOutput
- func (i ConnectorAutoScalingArgs) ToConnectorAutoScalingOutputWithContext(ctx context.Context) ConnectorAutoScalingOutput
- func (i ConnectorAutoScalingArgs) ToConnectorAutoScalingPtrOutput() ConnectorAutoScalingPtrOutput
- func (i ConnectorAutoScalingArgs) ToConnectorAutoScalingPtrOutputWithContext(ctx context.Context) ConnectorAutoScalingPtrOutput
- type ConnectorAutoScalingInput
- type ConnectorAutoScalingOutput
- func (ConnectorAutoScalingOutput) ElementType() reflect.Type
- func (o ConnectorAutoScalingOutput) MaxWorkerCount() pulumi.IntOutput
- func (o ConnectorAutoScalingOutput) McuCount() pulumi.IntOutput
- func (o ConnectorAutoScalingOutput) MinWorkerCount() pulumi.IntOutput
- func (o ConnectorAutoScalingOutput) ScaleInPolicy() ConnectorScaleInPolicyOutput
- func (o ConnectorAutoScalingOutput) ScaleOutPolicy() ConnectorScaleOutPolicyOutput
- func (o ConnectorAutoScalingOutput) ToConnectorAutoScalingOutput() ConnectorAutoScalingOutput
- func (o ConnectorAutoScalingOutput) ToConnectorAutoScalingOutputWithContext(ctx context.Context) ConnectorAutoScalingOutput
- func (o ConnectorAutoScalingOutput) ToConnectorAutoScalingPtrOutput() ConnectorAutoScalingPtrOutput
- func (o ConnectorAutoScalingOutput) ToConnectorAutoScalingPtrOutputWithContext(ctx context.Context) ConnectorAutoScalingPtrOutput
- type ConnectorAutoScalingPtrInput
- type ConnectorAutoScalingPtrOutput
- func (o ConnectorAutoScalingPtrOutput) Elem() ConnectorAutoScalingOutput
- func (ConnectorAutoScalingPtrOutput) ElementType() reflect.Type
- func (o ConnectorAutoScalingPtrOutput) MaxWorkerCount() pulumi.IntPtrOutput
- func (o ConnectorAutoScalingPtrOutput) McuCount() pulumi.IntPtrOutput
- func (o ConnectorAutoScalingPtrOutput) MinWorkerCount() pulumi.IntPtrOutput
- func (o ConnectorAutoScalingPtrOutput) ScaleInPolicy() ConnectorScaleInPolicyPtrOutput
- func (o ConnectorAutoScalingPtrOutput) ScaleOutPolicy() ConnectorScaleOutPolicyPtrOutput
- func (o ConnectorAutoScalingPtrOutput) ToConnectorAutoScalingPtrOutput() ConnectorAutoScalingPtrOutput
- func (o ConnectorAutoScalingPtrOutput) ToConnectorAutoScalingPtrOutputWithContext(ctx context.Context) ConnectorAutoScalingPtrOutput
- type ConnectorCapacity
- type ConnectorCapacityArgs
- type ConnectorCapacityInput
- type ConnectorCapacityOutput
- func (o ConnectorCapacityOutput) AutoScaling() ConnectorAutoScalingPtrOutput
- func (ConnectorCapacityOutput) ElementType() reflect.Type
- func (o ConnectorCapacityOutput) ProvisionedCapacity() ConnectorProvisionedCapacityPtrOutput
- func (o ConnectorCapacityOutput) ToConnectorCapacityOutput() ConnectorCapacityOutput
- func (o ConnectorCapacityOutput) ToConnectorCapacityOutputWithContext(ctx context.Context) ConnectorCapacityOutput
- type ConnectorCapacityPtrOutput
- func (o ConnectorCapacityPtrOutput) AutoScaling() ConnectorAutoScalingPtrOutput
- func (o ConnectorCapacityPtrOutput) Elem() ConnectorCapacityOutput
- func (ConnectorCapacityPtrOutput) ElementType() reflect.Type
- func (o ConnectorCapacityPtrOutput) ProvisionedCapacity() ConnectorProvisionedCapacityPtrOutput
- func (o ConnectorCapacityPtrOutput) ToConnectorCapacityPtrOutput() ConnectorCapacityPtrOutput
- func (o ConnectorCapacityPtrOutput) ToConnectorCapacityPtrOutputWithContext(ctx context.Context) ConnectorCapacityPtrOutput
- type ConnectorCloudWatchLogsLogDelivery
- type ConnectorCloudWatchLogsLogDeliveryArgs
- func (ConnectorCloudWatchLogsLogDeliveryArgs) ElementType() reflect.Type
- func (i ConnectorCloudWatchLogsLogDeliveryArgs) ToConnectorCloudWatchLogsLogDeliveryOutput() ConnectorCloudWatchLogsLogDeliveryOutput
- func (i ConnectorCloudWatchLogsLogDeliveryArgs) ToConnectorCloudWatchLogsLogDeliveryOutputWithContext(ctx context.Context) ConnectorCloudWatchLogsLogDeliveryOutput
- func (i ConnectorCloudWatchLogsLogDeliveryArgs) ToConnectorCloudWatchLogsLogDeliveryPtrOutput() ConnectorCloudWatchLogsLogDeliveryPtrOutput
- func (i ConnectorCloudWatchLogsLogDeliveryArgs) ToConnectorCloudWatchLogsLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorCloudWatchLogsLogDeliveryPtrOutput
- type ConnectorCloudWatchLogsLogDeliveryInput
- type ConnectorCloudWatchLogsLogDeliveryOutput
- func (ConnectorCloudWatchLogsLogDeliveryOutput) ElementType() reflect.Type
- func (o ConnectorCloudWatchLogsLogDeliveryOutput) Enabled() pulumi.BoolOutput
- func (o ConnectorCloudWatchLogsLogDeliveryOutput) LogGroup() pulumi.StringPtrOutput
- func (o ConnectorCloudWatchLogsLogDeliveryOutput) ToConnectorCloudWatchLogsLogDeliveryOutput() ConnectorCloudWatchLogsLogDeliveryOutput
- func (o ConnectorCloudWatchLogsLogDeliveryOutput) ToConnectorCloudWatchLogsLogDeliveryOutputWithContext(ctx context.Context) ConnectorCloudWatchLogsLogDeliveryOutput
- func (o ConnectorCloudWatchLogsLogDeliveryOutput) ToConnectorCloudWatchLogsLogDeliveryPtrOutput() ConnectorCloudWatchLogsLogDeliveryPtrOutput
- func (o ConnectorCloudWatchLogsLogDeliveryOutput) ToConnectorCloudWatchLogsLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorCloudWatchLogsLogDeliveryPtrOutput
- type ConnectorCloudWatchLogsLogDeliveryPtrInput
- type ConnectorCloudWatchLogsLogDeliveryPtrOutput
- func (o ConnectorCloudWatchLogsLogDeliveryPtrOutput) Elem() ConnectorCloudWatchLogsLogDeliveryOutput
- func (ConnectorCloudWatchLogsLogDeliveryPtrOutput) ElementType() reflect.Type
- func (o ConnectorCloudWatchLogsLogDeliveryPtrOutput) Enabled() pulumi.BoolPtrOutput
- func (o ConnectorCloudWatchLogsLogDeliveryPtrOutput) LogGroup() pulumi.StringPtrOutput
- func (o ConnectorCloudWatchLogsLogDeliveryPtrOutput) ToConnectorCloudWatchLogsLogDeliveryPtrOutput() ConnectorCloudWatchLogsLogDeliveryPtrOutput
- func (o ConnectorCloudWatchLogsLogDeliveryPtrOutput) ToConnectorCloudWatchLogsLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorCloudWatchLogsLogDeliveryPtrOutput
- type ConnectorCustomPlugin
- type ConnectorCustomPluginArgs
- type ConnectorCustomPluginInput
- type ConnectorCustomPluginOutput
- func (o ConnectorCustomPluginOutput) CustomPluginArn() pulumi.StringOutput
- func (ConnectorCustomPluginOutput) ElementType() reflect.Type
- func (o ConnectorCustomPluginOutput) Revision() pulumi.IntOutput
- func (o ConnectorCustomPluginOutput) ToConnectorCustomPluginOutput() ConnectorCustomPluginOutput
- func (o ConnectorCustomPluginOutput) ToConnectorCustomPluginOutputWithContext(ctx context.Context) ConnectorCustomPluginOutput
- type ConnectorFirehoseLogDelivery
- type ConnectorFirehoseLogDeliveryArgs
- func (ConnectorFirehoseLogDeliveryArgs) ElementType() reflect.Type
- func (i ConnectorFirehoseLogDeliveryArgs) ToConnectorFirehoseLogDeliveryOutput() ConnectorFirehoseLogDeliveryOutput
- func (i ConnectorFirehoseLogDeliveryArgs) ToConnectorFirehoseLogDeliveryOutputWithContext(ctx context.Context) ConnectorFirehoseLogDeliveryOutput
- func (i ConnectorFirehoseLogDeliveryArgs) ToConnectorFirehoseLogDeliveryPtrOutput() ConnectorFirehoseLogDeliveryPtrOutput
- func (i ConnectorFirehoseLogDeliveryArgs) ToConnectorFirehoseLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorFirehoseLogDeliveryPtrOutput
- type ConnectorFirehoseLogDeliveryInput
- type ConnectorFirehoseLogDeliveryOutput
- func (o ConnectorFirehoseLogDeliveryOutput) DeliveryStream() pulumi.StringPtrOutput
- func (ConnectorFirehoseLogDeliveryOutput) ElementType() reflect.Type
- func (o ConnectorFirehoseLogDeliveryOutput) Enabled() pulumi.BoolOutput
- func (o ConnectorFirehoseLogDeliveryOutput) ToConnectorFirehoseLogDeliveryOutput() ConnectorFirehoseLogDeliveryOutput
- func (o ConnectorFirehoseLogDeliveryOutput) ToConnectorFirehoseLogDeliveryOutputWithContext(ctx context.Context) ConnectorFirehoseLogDeliveryOutput
- func (o ConnectorFirehoseLogDeliveryOutput) ToConnectorFirehoseLogDeliveryPtrOutput() ConnectorFirehoseLogDeliveryPtrOutput
- func (o ConnectorFirehoseLogDeliveryOutput) ToConnectorFirehoseLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorFirehoseLogDeliveryPtrOutput
- type ConnectorFirehoseLogDeliveryPtrInput
- type ConnectorFirehoseLogDeliveryPtrOutput
- func (o ConnectorFirehoseLogDeliveryPtrOutput) DeliveryStream() pulumi.StringPtrOutput
- func (o ConnectorFirehoseLogDeliveryPtrOutput) Elem() ConnectorFirehoseLogDeliveryOutput
- func (ConnectorFirehoseLogDeliveryPtrOutput) ElementType() reflect.Type
- func (o ConnectorFirehoseLogDeliveryPtrOutput) Enabled() pulumi.BoolPtrOutput
- func (o ConnectorFirehoseLogDeliveryPtrOutput) ToConnectorFirehoseLogDeliveryPtrOutput() ConnectorFirehoseLogDeliveryPtrOutput
- func (o ConnectorFirehoseLogDeliveryPtrOutput) ToConnectorFirehoseLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorFirehoseLogDeliveryPtrOutput
- type ConnectorInput
- type ConnectorKafkaCluster
- type ConnectorKafkaClusterArgs
- type ConnectorKafkaClusterClientAuthentication
- type ConnectorKafkaClusterClientAuthenticationArgs
- func (ConnectorKafkaClusterClientAuthenticationArgs) ElementType() reflect.Type
- func (i ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationOutput() ConnectorKafkaClusterClientAuthenticationOutput
- func (i ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationOutput
- type ConnectorKafkaClusterClientAuthenticationInput
- type ConnectorKafkaClusterClientAuthenticationOutput
- func (o ConnectorKafkaClusterClientAuthenticationOutput) AuthenticationType() ConnectorKafkaClusterClientAuthenticationTypeOutput
- func (ConnectorKafkaClusterClientAuthenticationOutput) ElementType() reflect.Type
- func (o ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationOutput() ConnectorKafkaClusterClientAuthenticationOutput
- func (o ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationOutput
- type ConnectorKafkaClusterClientAuthenticationType
- func (ConnectorKafkaClusterClientAuthenticationType) ElementType() reflect.Type
- func (e ConnectorKafkaClusterClientAuthenticationType) ToConnectorKafkaClusterClientAuthenticationTypeOutput() ConnectorKafkaClusterClientAuthenticationTypeOutput
- func (e ConnectorKafkaClusterClientAuthenticationType) ToConnectorKafkaClusterClientAuthenticationTypeOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationTypeOutput
- func (e ConnectorKafkaClusterClientAuthenticationType) ToConnectorKafkaClusterClientAuthenticationTypePtrOutput() ConnectorKafkaClusterClientAuthenticationTypePtrOutput
- func (e ConnectorKafkaClusterClientAuthenticationType) ToConnectorKafkaClusterClientAuthenticationTypePtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationTypePtrOutput
- func (e ConnectorKafkaClusterClientAuthenticationType) ToStringOutput() pulumi.StringOutput
- func (e ConnectorKafkaClusterClientAuthenticationType) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput
- func (e ConnectorKafkaClusterClientAuthenticationType) ToStringPtrOutput() pulumi.StringPtrOutput
- func (e ConnectorKafkaClusterClientAuthenticationType) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput
- type ConnectorKafkaClusterClientAuthenticationTypeInput
- type ConnectorKafkaClusterClientAuthenticationTypeOutput
- func (ConnectorKafkaClusterClientAuthenticationTypeOutput) ElementType() reflect.Type
- func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToConnectorKafkaClusterClientAuthenticationTypeOutput() ConnectorKafkaClusterClientAuthenticationTypeOutput
- func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToConnectorKafkaClusterClientAuthenticationTypeOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationTypeOutput
- func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToConnectorKafkaClusterClientAuthenticationTypePtrOutput() ConnectorKafkaClusterClientAuthenticationTypePtrOutput
- func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToConnectorKafkaClusterClientAuthenticationTypePtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationTypePtrOutput
- func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToStringOutput() pulumi.StringOutput
- func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput
- func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToStringPtrOutput() pulumi.StringPtrOutput
- func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput
- type ConnectorKafkaClusterClientAuthenticationTypePtrInput
- type ConnectorKafkaClusterClientAuthenticationTypePtrOutput
- func (o ConnectorKafkaClusterClientAuthenticationTypePtrOutput) Elem() ConnectorKafkaClusterClientAuthenticationTypeOutput
- func (ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ElementType() reflect.Type
- func (o ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ToConnectorKafkaClusterClientAuthenticationTypePtrOutput() ConnectorKafkaClusterClientAuthenticationTypePtrOutput
- func (o ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ToConnectorKafkaClusterClientAuthenticationTypePtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationTypePtrOutput
- func (o ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ToStringPtrOutput() pulumi.StringPtrOutput
- func (o ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput
- type ConnectorKafkaClusterEncryptionInTransit
- type ConnectorKafkaClusterEncryptionInTransitArgs
- func (ConnectorKafkaClusterEncryptionInTransitArgs) ElementType() reflect.Type
- func (i ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitOutput() ConnectorKafkaClusterEncryptionInTransitOutput
- func (i ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitOutput
- type ConnectorKafkaClusterEncryptionInTransitInput
- type ConnectorKafkaClusterEncryptionInTransitOutput
- func (ConnectorKafkaClusterEncryptionInTransitOutput) ElementType() reflect.Type
- func (o ConnectorKafkaClusterEncryptionInTransitOutput) EncryptionType() ConnectorKafkaClusterEncryptionInTransitTypeOutput
- func (o ConnectorKafkaClusterEncryptionInTransitOutput) ToConnectorKafkaClusterEncryptionInTransitOutput() ConnectorKafkaClusterEncryptionInTransitOutput
- func (o ConnectorKafkaClusterEncryptionInTransitOutput) ToConnectorKafkaClusterEncryptionInTransitOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitOutput
- type ConnectorKafkaClusterEncryptionInTransitType
- func (ConnectorKafkaClusterEncryptionInTransitType) ElementType() reflect.Type
- func (e ConnectorKafkaClusterEncryptionInTransitType) ToConnectorKafkaClusterEncryptionInTransitTypeOutput() ConnectorKafkaClusterEncryptionInTransitTypeOutput
- func (e ConnectorKafkaClusterEncryptionInTransitType) ToConnectorKafkaClusterEncryptionInTransitTypeOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitTypeOutput
- func (e ConnectorKafkaClusterEncryptionInTransitType) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutput() ConnectorKafkaClusterEncryptionInTransitTypePtrOutput
- func (e ConnectorKafkaClusterEncryptionInTransitType) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitTypePtrOutput
- func (e ConnectorKafkaClusterEncryptionInTransitType) ToStringOutput() pulumi.StringOutput
- func (e ConnectorKafkaClusterEncryptionInTransitType) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput
- func (e ConnectorKafkaClusterEncryptionInTransitType) ToStringPtrOutput() pulumi.StringPtrOutput
- func (e ConnectorKafkaClusterEncryptionInTransitType) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput
- type ConnectorKafkaClusterEncryptionInTransitTypeInput
- type ConnectorKafkaClusterEncryptionInTransitTypeOutput
- func (ConnectorKafkaClusterEncryptionInTransitTypeOutput) ElementType() reflect.Type
- func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToConnectorKafkaClusterEncryptionInTransitTypeOutput() ConnectorKafkaClusterEncryptionInTransitTypeOutput
- func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToConnectorKafkaClusterEncryptionInTransitTypeOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitTypeOutput
- func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutput() ConnectorKafkaClusterEncryptionInTransitTypePtrOutput
- func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitTypePtrOutput
- func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToStringOutput() pulumi.StringOutput
- func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput
- func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToStringPtrOutput() pulumi.StringPtrOutput
- func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput
- type ConnectorKafkaClusterEncryptionInTransitTypePtrInput
- type ConnectorKafkaClusterEncryptionInTransitTypePtrOutput
- func (o ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) Elem() ConnectorKafkaClusterEncryptionInTransitTypeOutput
- func (ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ElementType() reflect.Type
- func (o ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutput() ConnectorKafkaClusterEncryptionInTransitTypePtrOutput
- func (o ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitTypePtrOutput
- func (o ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ToStringPtrOutput() pulumi.StringPtrOutput
- func (o ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput
- type ConnectorKafkaClusterInput
- type ConnectorKafkaClusterOutput
- func (o ConnectorKafkaClusterOutput) ApacheKafkaCluster() ConnectorApacheKafkaClusterOutput
- func (ConnectorKafkaClusterOutput) ElementType() reflect.Type
- func (o ConnectorKafkaClusterOutput) ToConnectorKafkaClusterOutput() ConnectorKafkaClusterOutput
- func (o ConnectorKafkaClusterOutput) ToConnectorKafkaClusterOutputWithContext(ctx context.Context) ConnectorKafkaClusterOutput
- type ConnectorLogDelivery
- type ConnectorLogDeliveryArgs
- func (ConnectorLogDeliveryArgs) ElementType() reflect.Type
- func (i ConnectorLogDeliveryArgs) ToConnectorLogDeliveryOutput() ConnectorLogDeliveryOutput
- func (i ConnectorLogDeliveryArgs) ToConnectorLogDeliveryOutputWithContext(ctx context.Context) ConnectorLogDeliveryOutput
- func (i ConnectorLogDeliveryArgs) ToConnectorLogDeliveryPtrOutput() ConnectorLogDeliveryPtrOutput
- func (i ConnectorLogDeliveryArgs) ToConnectorLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorLogDeliveryPtrOutput
- type ConnectorLogDeliveryInput
- type ConnectorLogDeliveryOutput
- func (ConnectorLogDeliveryOutput) ElementType() reflect.Type
- func (o ConnectorLogDeliveryOutput) ToConnectorLogDeliveryOutput() ConnectorLogDeliveryOutput
- func (o ConnectorLogDeliveryOutput) ToConnectorLogDeliveryOutputWithContext(ctx context.Context) ConnectorLogDeliveryOutput
- func (o ConnectorLogDeliveryOutput) ToConnectorLogDeliveryPtrOutput() ConnectorLogDeliveryPtrOutput
- func (o ConnectorLogDeliveryOutput) ToConnectorLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorLogDeliveryPtrOutput
- func (o ConnectorLogDeliveryOutput) WorkerLogDelivery() ConnectorWorkerLogDeliveryOutput
- type ConnectorLogDeliveryPtrInput
- type ConnectorLogDeliveryPtrOutput
- func (o ConnectorLogDeliveryPtrOutput) Elem() ConnectorLogDeliveryOutput
- func (ConnectorLogDeliveryPtrOutput) ElementType() reflect.Type
- func (o ConnectorLogDeliveryPtrOutput) ToConnectorLogDeliveryPtrOutput() ConnectorLogDeliveryPtrOutput
- func (o ConnectorLogDeliveryPtrOutput) ToConnectorLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorLogDeliveryPtrOutput
- func (o ConnectorLogDeliveryPtrOutput) WorkerLogDelivery() ConnectorWorkerLogDeliveryPtrOutput
- type ConnectorOutput
- type ConnectorPlugin
- type ConnectorPluginArgs
- type ConnectorPluginArray
- type ConnectorPluginArrayInput
- type ConnectorPluginArrayOutput
- func (ConnectorPluginArrayOutput) ElementType() reflect.Type
- func (o ConnectorPluginArrayOutput) Index(i pulumi.IntInput) ConnectorPluginOutput
- func (o ConnectorPluginArrayOutput) ToConnectorPluginArrayOutput() ConnectorPluginArrayOutput
- func (o ConnectorPluginArrayOutput) ToConnectorPluginArrayOutputWithContext(ctx context.Context) ConnectorPluginArrayOutput
- type ConnectorPluginInput
- type ConnectorPluginOutput
- func (o ConnectorPluginOutput) CustomPlugin() ConnectorCustomPluginOutput
- func (ConnectorPluginOutput) ElementType() reflect.Type
- func (o ConnectorPluginOutput) ToConnectorPluginOutput() ConnectorPluginOutput
- func (o ConnectorPluginOutput) ToConnectorPluginOutputWithContext(ctx context.Context) ConnectorPluginOutput
- type ConnectorProvisionedCapacity
- type ConnectorProvisionedCapacityArgs
- func (ConnectorProvisionedCapacityArgs) ElementType() reflect.Type
- func (i ConnectorProvisionedCapacityArgs) ToConnectorProvisionedCapacityOutput() ConnectorProvisionedCapacityOutput
- func (i ConnectorProvisionedCapacityArgs) ToConnectorProvisionedCapacityOutputWithContext(ctx context.Context) ConnectorProvisionedCapacityOutput
- func (i ConnectorProvisionedCapacityArgs) ToConnectorProvisionedCapacityPtrOutput() ConnectorProvisionedCapacityPtrOutput
- func (i ConnectorProvisionedCapacityArgs) ToConnectorProvisionedCapacityPtrOutputWithContext(ctx context.Context) ConnectorProvisionedCapacityPtrOutput
- type ConnectorProvisionedCapacityInput
- type ConnectorProvisionedCapacityOutput
- func (ConnectorProvisionedCapacityOutput) ElementType() reflect.Type
- func (o ConnectorProvisionedCapacityOutput) McuCount() pulumi.IntPtrOutput
- func (o ConnectorProvisionedCapacityOutput) ToConnectorProvisionedCapacityOutput() ConnectorProvisionedCapacityOutput
- func (o ConnectorProvisionedCapacityOutput) ToConnectorProvisionedCapacityOutputWithContext(ctx context.Context) ConnectorProvisionedCapacityOutput
- func (o ConnectorProvisionedCapacityOutput) ToConnectorProvisionedCapacityPtrOutput() ConnectorProvisionedCapacityPtrOutput
- func (o ConnectorProvisionedCapacityOutput) ToConnectorProvisionedCapacityPtrOutputWithContext(ctx context.Context) ConnectorProvisionedCapacityPtrOutput
- func (o ConnectorProvisionedCapacityOutput) WorkerCount() pulumi.IntOutput
- type ConnectorProvisionedCapacityPtrInput
- type ConnectorProvisionedCapacityPtrOutput
- func (o ConnectorProvisionedCapacityPtrOutput) Elem() ConnectorProvisionedCapacityOutput
- func (ConnectorProvisionedCapacityPtrOutput) ElementType() reflect.Type
- func (o ConnectorProvisionedCapacityPtrOutput) McuCount() pulumi.IntPtrOutput
- func (o ConnectorProvisionedCapacityPtrOutput) ToConnectorProvisionedCapacityPtrOutput() ConnectorProvisionedCapacityPtrOutput
- func (o ConnectorProvisionedCapacityPtrOutput) ToConnectorProvisionedCapacityPtrOutputWithContext(ctx context.Context) ConnectorProvisionedCapacityPtrOutput
- func (o ConnectorProvisionedCapacityPtrOutput) WorkerCount() pulumi.IntPtrOutput
- type ConnectorS3LogDelivery
- type ConnectorS3LogDeliveryArgs
- func (ConnectorS3LogDeliveryArgs) ElementType() reflect.Type
- func (i ConnectorS3LogDeliveryArgs) ToConnectorS3LogDeliveryOutput() ConnectorS3LogDeliveryOutput
- func (i ConnectorS3LogDeliveryArgs) ToConnectorS3LogDeliveryOutputWithContext(ctx context.Context) ConnectorS3LogDeliveryOutput
- func (i ConnectorS3LogDeliveryArgs) ToConnectorS3LogDeliveryPtrOutput() ConnectorS3LogDeliveryPtrOutput
- func (i ConnectorS3LogDeliveryArgs) ToConnectorS3LogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorS3LogDeliveryPtrOutput
- type ConnectorS3LogDeliveryInput
- type ConnectorS3LogDeliveryOutput
- func (o ConnectorS3LogDeliveryOutput) Bucket() pulumi.StringPtrOutput
- func (ConnectorS3LogDeliveryOutput) ElementType() reflect.Type
- func (o ConnectorS3LogDeliveryOutput) Enabled() pulumi.BoolOutput
- func (o ConnectorS3LogDeliveryOutput) Prefix() pulumi.StringPtrOutput
- func (o ConnectorS3LogDeliveryOutput) ToConnectorS3LogDeliveryOutput() ConnectorS3LogDeliveryOutput
- func (o ConnectorS3LogDeliveryOutput) ToConnectorS3LogDeliveryOutputWithContext(ctx context.Context) ConnectorS3LogDeliveryOutput
- func (o ConnectorS3LogDeliveryOutput) ToConnectorS3LogDeliveryPtrOutput() ConnectorS3LogDeliveryPtrOutput
- func (o ConnectorS3LogDeliveryOutput) ToConnectorS3LogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorS3LogDeliveryPtrOutput
- type ConnectorS3LogDeliveryPtrInput
- type ConnectorS3LogDeliveryPtrOutput
- func (o ConnectorS3LogDeliveryPtrOutput) Bucket() pulumi.StringPtrOutput
- func (o ConnectorS3LogDeliveryPtrOutput) Elem() ConnectorS3LogDeliveryOutput
- func (ConnectorS3LogDeliveryPtrOutput) ElementType() reflect.Type
- func (o ConnectorS3LogDeliveryPtrOutput) Enabled() pulumi.BoolPtrOutput
- func (o ConnectorS3LogDeliveryPtrOutput) Prefix() pulumi.StringPtrOutput
- func (o ConnectorS3LogDeliveryPtrOutput) ToConnectorS3LogDeliveryPtrOutput() ConnectorS3LogDeliveryPtrOutput
- func (o ConnectorS3LogDeliveryPtrOutput) ToConnectorS3LogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorS3LogDeliveryPtrOutput
- type ConnectorScaleInPolicy
- type ConnectorScaleInPolicyArgs
- func (ConnectorScaleInPolicyArgs) ElementType() reflect.Type
- func (i ConnectorScaleInPolicyArgs) ToConnectorScaleInPolicyOutput() ConnectorScaleInPolicyOutput
- func (i ConnectorScaleInPolicyArgs) ToConnectorScaleInPolicyOutputWithContext(ctx context.Context) ConnectorScaleInPolicyOutput
- func (i ConnectorScaleInPolicyArgs) ToConnectorScaleInPolicyPtrOutput() ConnectorScaleInPolicyPtrOutput
- func (i ConnectorScaleInPolicyArgs) ToConnectorScaleInPolicyPtrOutputWithContext(ctx context.Context) ConnectorScaleInPolicyPtrOutput
- type ConnectorScaleInPolicyInput
- type ConnectorScaleInPolicyOutput
- func (o ConnectorScaleInPolicyOutput) CpuUtilizationPercentage() pulumi.IntOutput
- func (ConnectorScaleInPolicyOutput) ElementType() reflect.Type
- func (o ConnectorScaleInPolicyOutput) ToConnectorScaleInPolicyOutput() ConnectorScaleInPolicyOutput
- func (o ConnectorScaleInPolicyOutput) ToConnectorScaleInPolicyOutputWithContext(ctx context.Context) ConnectorScaleInPolicyOutput
- func (o ConnectorScaleInPolicyOutput) ToConnectorScaleInPolicyPtrOutput() ConnectorScaleInPolicyPtrOutput
- func (o ConnectorScaleInPolicyOutput) ToConnectorScaleInPolicyPtrOutputWithContext(ctx context.Context) ConnectorScaleInPolicyPtrOutput
- type ConnectorScaleInPolicyPtrInput
- type ConnectorScaleInPolicyPtrOutput
- func (o ConnectorScaleInPolicyPtrOutput) CpuUtilizationPercentage() pulumi.IntPtrOutput
- func (o ConnectorScaleInPolicyPtrOutput) Elem() ConnectorScaleInPolicyOutput
- func (ConnectorScaleInPolicyPtrOutput) ElementType() reflect.Type
- func (o ConnectorScaleInPolicyPtrOutput) ToConnectorScaleInPolicyPtrOutput() ConnectorScaleInPolicyPtrOutput
- func (o ConnectorScaleInPolicyPtrOutput) ToConnectorScaleInPolicyPtrOutputWithContext(ctx context.Context) ConnectorScaleInPolicyPtrOutput
- type ConnectorScaleOutPolicy
- type ConnectorScaleOutPolicyArgs
- func (ConnectorScaleOutPolicyArgs) ElementType() reflect.Type
- func (i ConnectorScaleOutPolicyArgs) ToConnectorScaleOutPolicyOutput() ConnectorScaleOutPolicyOutput
- func (i ConnectorScaleOutPolicyArgs) ToConnectorScaleOutPolicyOutputWithContext(ctx context.Context) ConnectorScaleOutPolicyOutput
- func (i ConnectorScaleOutPolicyArgs) ToConnectorScaleOutPolicyPtrOutput() ConnectorScaleOutPolicyPtrOutput
- func (i ConnectorScaleOutPolicyArgs) ToConnectorScaleOutPolicyPtrOutputWithContext(ctx context.Context) ConnectorScaleOutPolicyPtrOutput
- type ConnectorScaleOutPolicyInput
- type ConnectorScaleOutPolicyOutput
- func (o ConnectorScaleOutPolicyOutput) CpuUtilizationPercentage() pulumi.IntOutput
- func (ConnectorScaleOutPolicyOutput) ElementType() reflect.Type
- func (o ConnectorScaleOutPolicyOutput) ToConnectorScaleOutPolicyOutput() ConnectorScaleOutPolicyOutput
- func (o ConnectorScaleOutPolicyOutput) ToConnectorScaleOutPolicyOutputWithContext(ctx context.Context) ConnectorScaleOutPolicyOutput
- func (o ConnectorScaleOutPolicyOutput) ToConnectorScaleOutPolicyPtrOutput() ConnectorScaleOutPolicyPtrOutput
- func (o ConnectorScaleOutPolicyOutput) ToConnectorScaleOutPolicyPtrOutputWithContext(ctx context.Context) ConnectorScaleOutPolicyPtrOutput
- type ConnectorScaleOutPolicyPtrInput
- type ConnectorScaleOutPolicyPtrOutput
- func (o ConnectorScaleOutPolicyPtrOutput) CpuUtilizationPercentage() pulumi.IntPtrOutput
- func (o ConnectorScaleOutPolicyPtrOutput) Elem() ConnectorScaleOutPolicyOutput
- func (ConnectorScaleOutPolicyPtrOutput) ElementType() reflect.Type
- func (o ConnectorScaleOutPolicyPtrOutput) ToConnectorScaleOutPolicyPtrOutput() ConnectorScaleOutPolicyPtrOutput
- func (o ConnectorScaleOutPolicyPtrOutput) ToConnectorScaleOutPolicyPtrOutputWithContext(ctx context.Context) ConnectorScaleOutPolicyPtrOutput
- type ConnectorState
- type ConnectorVpc
- type ConnectorVpcArgs
- type ConnectorVpcInput
- type ConnectorVpcOutput
- func (ConnectorVpcOutput) ElementType() reflect.Type
- func (o ConnectorVpcOutput) SecurityGroups() pulumi.StringArrayOutput
- func (o ConnectorVpcOutput) Subnets() pulumi.StringArrayOutput
- func (o ConnectorVpcOutput) ToConnectorVpcOutput() ConnectorVpcOutput
- func (o ConnectorVpcOutput) ToConnectorVpcOutputWithContext(ctx context.Context) ConnectorVpcOutput
- type ConnectorWorkerConfiguration
- type ConnectorWorkerConfigurationArgs
- func (ConnectorWorkerConfigurationArgs) ElementType() reflect.Type
- func (i ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationOutput() ConnectorWorkerConfigurationOutput
- func (i ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationOutputWithContext(ctx context.Context) ConnectorWorkerConfigurationOutput
- func (i ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationPtrOutput() ConnectorWorkerConfigurationPtrOutput
- func (i ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationPtrOutputWithContext(ctx context.Context) ConnectorWorkerConfigurationPtrOutput
- type ConnectorWorkerConfigurationInput
- type ConnectorWorkerConfigurationOutput
- func (ConnectorWorkerConfigurationOutput) ElementType() reflect.Type
- func (o ConnectorWorkerConfigurationOutput) Revision() pulumi.IntOutput
- func (o ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationOutput() ConnectorWorkerConfigurationOutput
- func (o ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationOutputWithContext(ctx context.Context) ConnectorWorkerConfigurationOutput
- func (o ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationPtrOutput() ConnectorWorkerConfigurationPtrOutput
- func (o ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationPtrOutputWithContext(ctx context.Context) ConnectorWorkerConfigurationPtrOutput
- func (o ConnectorWorkerConfigurationOutput) WorkerConfigurationArn() pulumi.StringOutput
- type ConnectorWorkerConfigurationPtrInput
- type ConnectorWorkerConfigurationPtrOutput
- func (o ConnectorWorkerConfigurationPtrOutput) Elem() ConnectorWorkerConfigurationOutput
- func (ConnectorWorkerConfigurationPtrOutput) ElementType() reflect.Type
- func (o ConnectorWorkerConfigurationPtrOutput) Revision() pulumi.IntPtrOutput
- func (o ConnectorWorkerConfigurationPtrOutput) ToConnectorWorkerConfigurationPtrOutput() ConnectorWorkerConfigurationPtrOutput
- func (o ConnectorWorkerConfigurationPtrOutput) ToConnectorWorkerConfigurationPtrOutputWithContext(ctx context.Context) ConnectorWorkerConfigurationPtrOutput
- func (o ConnectorWorkerConfigurationPtrOutput) WorkerConfigurationArn() pulumi.StringPtrOutput
- type ConnectorWorkerLogDelivery
- type ConnectorWorkerLogDeliveryArgs
- func (ConnectorWorkerLogDeliveryArgs) ElementType() reflect.Type
- func (i ConnectorWorkerLogDeliveryArgs) ToConnectorWorkerLogDeliveryOutput() ConnectorWorkerLogDeliveryOutput
- func (i ConnectorWorkerLogDeliveryArgs) ToConnectorWorkerLogDeliveryOutputWithContext(ctx context.Context) ConnectorWorkerLogDeliveryOutput
- func (i ConnectorWorkerLogDeliveryArgs) ToConnectorWorkerLogDeliveryPtrOutput() ConnectorWorkerLogDeliveryPtrOutput
- func (i ConnectorWorkerLogDeliveryArgs) ToConnectorWorkerLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorWorkerLogDeliveryPtrOutput
- type ConnectorWorkerLogDeliveryInput
- type ConnectorWorkerLogDeliveryOutput
- func (o ConnectorWorkerLogDeliveryOutput) CloudWatchLogs() ConnectorCloudWatchLogsLogDeliveryPtrOutput
- func (ConnectorWorkerLogDeliveryOutput) ElementType() reflect.Type
- func (o ConnectorWorkerLogDeliveryOutput) Firehose() ConnectorFirehoseLogDeliveryPtrOutput
- func (o ConnectorWorkerLogDeliveryOutput) S3() ConnectorS3LogDeliveryPtrOutput
- func (o ConnectorWorkerLogDeliveryOutput) ToConnectorWorkerLogDeliveryOutput() ConnectorWorkerLogDeliveryOutput
- func (o ConnectorWorkerLogDeliveryOutput) ToConnectorWorkerLogDeliveryOutputWithContext(ctx context.Context) ConnectorWorkerLogDeliveryOutput
- func (o ConnectorWorkerLogDeliveryOutput) ToConnectorWorkerLogDeliveryPtrOutput() ConnectorWorkerLogDeliveryPtrOutput
- func (o ConnectorWorkerLogDeliveryOutput) ToConnectorWorkerLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorWorkerLogDeliveryPtrOutput
- type ConnectorWorkerLogDeliveryPtrInput
- type ConnectorWorkerLogDeliveryPtrOutput
- func (o ConnectorWorkerLogDeliveryPtrOutput) CloudWatchLogs() ConnectorCloudWatchLogsLogDeliveryPtrOutput
- func (o ConnectorWorkerLogDeliveryPtrOutput) Elem() ConnectorWorkerLogDeliveryOutput
- func (ConnectorWorkerLogDeliveryPtrOutput) ElementType() reflect.Type
- func (o ConnectorWorkerLogDeliveryPtrOutput) Firehose() ConnectorFirehoseLogDeliveryPtrOutput
- func (o ConnectorWorkerLogDeliveryPtrOutput) S3() ConnectorS3LogDeliveryPtrOutput
- func (o ConnectorWorkerLogDeliveryPtrOutput) ToConnectorWorkerLogDeliveryPtrOutput() ConnectorWorkerLogDeliveryPtrOutput
- func (o ConnectorWorkerLogDeliveryPtrOutput) ToConnectorWorkerLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorWorkerLogDeliveryPtrOutput
- type LookupConnectorArgs
- type LookupConnectorOutputArgs
- type LookupConnectorResult
- type LookupConnectorResultOutput
- func (o LookupConnectorResultOutput) Capacity() ConnectorCapacityPtrOutput
- func (o LookupConnectorResultOutput) ConnectorArn() pulumi.StringPtrOutput
- func (LookupConnectorResultOutput) ElementType() reflect.Type
- func (o LookupConnectorResultOutput) ToLookupConnectorResultOutput() LookupConnectorResultOutput
- func (o LookupConnectorResultOutput) ToLookupConnectorResultOutputWithContext(ctx context.Context) LookupConnectorResultOutput
Constants ¶
const ( ConnectorKafkaClusterClientAuthenticationTypeNone = ConnectorKafkaClusterClientAuthenticationType("NONE") ConnectorKafkaClusterClientAuthenticationTypeIam = ConnectorKafkaClusterClientAuthenticationType("IAM") )
const ( ConnectorKafkaClusterEncryptionInTransitTypePlaintext = ConnectorKafkaClusterEncryptionInTransitType("PLAINTEXT") ConnectorKafkaClusterEncryptionInTransitTypeTls = ConnectorKafkaClusterEncryptionInTransitType("TLS") )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connector ¶
type Connector struct { pulumi.CustomResourceState Capacity ConnectorCapacityOutput `pulumi:"capacity"` // Amazon Resource Name for the created Connector. ConnectorArn pulumi.StringOutput `pulumi:"connectorArn"` // The configuration for the connector. ConnectorConfiguration pulumi.AnyOutput `pulumi:"connectorConfiguration"` // A summary description of the connector. ConnectorDescription pulumi.StringPtrOutput `pulumi:"connectorDescription"` // The name of the connector. ConnectorName pulumi.StringOutput `pulumi:"connectorName"` KafkaCluster ConnectorKafkaClusterOutput `pulumi:"kafkaCluster"` KafkaClusterClientAuthentication ConnectorKafkaClusterClientAuthenticationOutput `pulumi:"kafkaClusterClientAuthentication"` KafkaClusterEncryptionInTransit ConnectorKafkaClusterEncryptionInTransitOutput `pulumi:"kafkaClusterEncryptionInTransit"` // The version of Kafka Connect. It has to be compatible with both the Kafka cluster's version and the plugins. KafkaConnectVersion pulumi.StringOutput `pulumi:"kafkaConnectVersion"` LogDelivery ConnectorLogDeliveryPtrOutput `pulumi:"logDelivery"` // List of plugins to use with the connector. Plugins ConnectorPluginArrayOutput `pulumi:"plugins"` // The Amazon Resource Name (ARN) of the IAM role used by the connector to access Amazon S3 objects and other external resources. ServiceExecutionRoleArn pulumi.StringOutput `pulumi:"serviceExecutionRoleArn"` WorkerConfiguration ConnectorWorkerConfigurationPtrOutput `pulumi:"workerConfiguration"` }
Resource Type definition for AWS::KafkaConnect::Connector
func GetConnector ¶
func GetConnector(ctx *pulumi.Context, name string, id pulumi.IDInput, state *ConnectorState, opts ...pulumi.ResourceOption) (*Connector, error)
GetConnector gets an existing Connector resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).
func NewConnector ¶
func NewConnector(ctx *pulumi.Context, name string, args *ConnectorArgs, opts ...pulumi.ResourceOption) (*Connector, error)
NewConnector registers a new resource with the given unique name, arguments, and options.
func (*Connector) ElementType ¶
func (*Connector) ToConnectorOutput ¶
func (i *Connector) ToConnectorOutput() ConnectorOutput
func (*Connector) ToConnectorOutputWithContext ¶
func (i *Connector) ToConnectorOutputWithContext(ctx context.Context) ConnectorOutput
type ConnectorApacheKafkaCluster ¶
type ConnectorApacheKafkaCluster struct { // The bootstrap servers string of the Apache Kafka cluster. BootstrapServers string `pulumi:"bootstrapServers"` Vpc ConnectorVpc `pulumi:"vpc"` }
Details of how to connect to an Apache Kafka cluster.
type ConnectorApacheKafkaClusterArgs ¶
type ConnectorApacheKafkaClusterArgs struct { // The bootstrap servers string of the Apache Kafka cluster. BootstrapServers pulumi.StringInput `pulumi:"bootstrapServers"` Vpc ConnectorVpcInput `pulumi:"vpc"` }
Details of how to connect to an Apache Kafka cluster.
func (ConnectorApacheKafkaClusterArgs) ElementType ¶
func (ConnectorApacheKafkaClusterArgs) ElementType() reflect.Type
func (ConnectorApacheKafkaClusterArgs) ToConnectorApacheKafkaClusterOutput ¶
func (i ConnectorApacheKafkaClusterArgs) ToConnectorApacheKafkaClusterOutput() ConnectorApacheKafkaClusterOutput
func (ConnectorApacheKafkaClusterArgs) ToConnectorApacheKafkaClusterOutputWithContext ¶
func (i ConnectorApacheKafkaClusterArgs) ToConnectorApacheKafkaClusterOutputWithContext(ctx context.Context) ConnectorApacheKafkaClusterOutput
type ConnectorApacheKafkaClusterInput ¶
type ConnectorApacheKafkaClusterInput interface { pulumi.Input ToConnectorApacheKafkaClusterOutput() ConnectorApacheKafkaClusterOutput ToConnectorApacheKafkaClusterOutputWithContext(context.Context) ConnectorApacheKafkaClusterOutput }
ConnectorApacheKafkaClusterInput is an input type that accepts ConnectorApacheKafkaClusterArgs and ConnectorApacheKafkaClusterOutput values. You can construct a concrete instance of `ConnectorApacheKafkaClusterInput` via:
ConnectorApacheKafkaClusterArgs{...}
type ConnectorApacheKafkaClusterOutput ¶
type ConnectorApacheKafkaClusterOutput struct{ *pulumi.OutputState }
Details of how to connect to an Apache Kafka cluster.
func (ConnectorApacheKafkaClusterOutput) BootstrapServers ¶
func (o ConnectorApacheKafkaClusterOutput) BootstrapServers() pulumi.StringOutput
The bootstrap servers string of the Apache Kafka cluster.
func (ConnectorApacheKafkaClusterOutput) ElementType ¶
func (ConnectorApacheKafkaClusterOutput) ElementType() reflect.Type
func (ConnectorApacheKafkaClusterOutput) ToConnectorApacheKafkaClusterOutput ¶
func (o ConnectorApacheKafkaClusterOutput) ToConnectorApacheKafkaClusterOutput() ConnectorApacheKafkaClusterOutput
func (ConnectorApacheKafkaClusterOutput) ToConnectorApacheKafkaClusterOutputWithContext ¶
func (o ConnectorApacheKafkaClusterOutput) ToConnectorApacheKafkaClusterOutputWithContext(ctx context.Context) ConnectorApacheKafkaClusterOutput
func (ConnectorApacheKafkaClusterOutput) Vpc ¶
func (o ConnectorApacheKafkaClusterOutput) Vpc() ConnectorVpcOutput
type ConnectorArgs ¶
type ConnectorArgs struct { Capacity ConnectorCapacityInput // The configuration for the connector. ConnectorConfiguration pulumi.Input // A summary description of the connector. ConnectorDescription pulumi.StringPtrInput // The name of the connector. ConnectorName pulumi.StringPtrInput KafkaCluster ConnectorKafkaClusterInput KafkaClusterClientAuthentication ConnectorKafkaClusterClientAuthenticationInput KafkaClusterEncryptionInTransit ConnectorKafkaClusterEncryptionInTransitInput // The version of Kafka Connect. It has to be compatible with both the Kafka cluster's version and the plugins. KafkaConnectVersion pulumi.StringInput LogDelivery ConnectorLogDeliveryPtrInput // List of plugins to use with the connector. Plugins ConnectorPluginArrayInput // The Amazon Resource Name (ARN) of the IAM role used by the connector to access Amazon S3 objects and other external resources. ServiceExecutionRoleArn pulumi.StringInput WorkerConfiguration ConnectorWorkerConfigurationPtrInput }
The set of arguments for constructing a Connector resource.
func (ConnectorArgs) ElementType ¶
func (ConnectorArgs) ElementType() reflect.Type
type ConnectorAutoScaling ¶
type ConnectorAutoScaling struct { // The maximum number of workers for a connector. MaxWorkerCount int `pulumi:"maxWorkerCount"` // Specifies how many MSK Connect Units (MCU) as the minimum scaling unit. McuCount int `pulumi:"mcuCount"` // The minimum number of workers for a connector. MinWorkerCount int `pulumi:"minWorkerCount"` ScaleInPolicy ConnectorScaleInPolicy `pulumi:"scaleInPolicy"` ScaleOutPolicy ConnectorScaleOutPolicy `pulumi:"scaleOutPolicy"` }
Details about auto scaling of a connector.
type ConnectorAutoScalingArgs ¶
type ConnectorAutoScalingArgs struct { // The maximum number of workers for a connector. MaxWorkerCount pulumi.IntInput `pulumi:"maxWorkerCount"` // Specifies how many MSK Connect Units (MCU) as the minimum scaling unit. McuCount pulumi.IntInput `pulumi:"mcuCount"` // The minimum number of workers for a connector. MinWorkerCount pulumi.IntInput `pulumi:"minWorkerCount"` ScaleInPolicy ConnectorScaleInPolicyInput `pulumi:"scaleInPolicy"` ScaleOutPolicy ConnectorScaleOutPolicyInput `pulumi:"scaleOutPolicy"` }
Details about auto scaling of a connector.
func (ConnectorAutoScalingArgs) ElementType ¶
func (ConnectorAutoScalingArgs) ElementType() reflect.Type
func (ConnectorAutoScalingArgs) ToConnectorAutoScalingOutput ¶
func (i ConnectorAutoScalingArgs) ToConnectorAutoScalingOutput() ConnectorAutoScalingOutput
func (ConnectorAutoScalingArgs) ToConnectorAutoScalingOutputWithContext ¶
func (i ConnectorAutoScalingArgs) ToConnectorAutoScalingOutputWithContext(ctx context.Context) ConnectorAutoScalingOutput
func (ConnectorAutoScalingArgs) ToConnectorAutoScalingPtrOutput ¶
func (i ConnectorAutoScalingArgs) ToConnectorAutoScalingPtrOutput() ConnectorAutoScalingPtrOutput
func (ConnectorAutoScalingArgs) ToConnectorAutoScalingPtrOutputWithContext ¶
func (i ConnectorAutoScalingArgs) ToConnectorAutoScalingPtrOutputWithContext(ctx context.Context) ConnectorAutoScalingPtrOutput
type ConnectorAutoScalingInput ¶
type ConnectorAutoScalingInput interface { pulumi.Input ToConnectorAutoScalingOutput() ConnectorAutoScalingOutput ToConnectorAutoScalingOutputWithContext(context.Context) ConnectorAutoScalingOutput }
ConnectorAutoScalingInput is an input type that accepts ConnectorAutoScalingArgs and ConnectorAutoScalingOutput values. You can construct a concrete instance of `ConnectorAutoScalingInput` via:
ConnectorAutoScalingArgs{...}
type ConnectorAutoScalingOutput ¶
type ConnectorAutoScalingOutput struct{ *pulumi.OutputState }
Details about auto scaling of a connector.
func (ConnectorAutoScalingOutput) ElementType ¶
func (ConnectorAutoScalingOutput) ElementType() reflect.Type
func (ConnectorAutoScalingOutput) MaxWorkerCount ¶
func (o ConnectorAutoScalingOutput) MaxWorkerCount() pulumi.IntOutput
The maximum number of workers for a connector.
func (ConnectorAutoScalingOutput) McuCount ¶
func (o ConnectorAutoScalingOutput) McuCount() pulumi.IntOutput
Specifies how many MSK Connect Units (MCU) as the minimum scaling unit.
func (ConnectorAutoScalingOutput) MinWorkerCount ¶
func (o ConnectorAutoScalingOutput) MinWorkerCount() pulumi.IntOutput
The minimum number of workers for a connector.
func (ConnectorAutoScalingOutput) ScaleInPolicy ¶
func (o ConnectorAutoScalingOutput) ScaleInPolicy() ConnectorScaleInPolicyOutput
func (ConnectorAutoScalingOutput) ScaleOutPolicy ¶
func (o ConnectorAutoScalingOutput) ScaleOutPolicy() ConnectorScaleOutPolicyOutput
func (ConnectorAutoScalingOutput) ToConnectorAutoScalingOutput ¶
func (o ConnectorAutoScalingOutput) ToConnectorAutoScalingOutput() ConnectorAutoScalingOutput
func (ConnectorAutoScalingOutput) ToConnectorAutoScalingOutputWithContext ¶
func (o ConnectorAutoScalingOutput) ToConnectorAutoScalingOutputWithContext(ctx context.Context) ConnectorAutoScalingOutput
func (ConnectorAutoScalingOutput) ToConnectorAutoScalingPtrOutput ¶
func (o ConnectorAutoScalingOutput) ToConnectorAutoScalingPtrOutput() ConnectorAutoScalingPtrOutput
func (ConnectorAutoScalingOutput) ToConnectorAutoScalingPtrOutputWithContext ¶
func (o ConnectorAutoScalingOutput) ToConnectorAutoScalingPtrOutputWithContext(ctx context.Context) ConnectorAutoScalingPtrOutput
type ConnectorAutoScalingPtrInput ¶
type ConnectorAutoScalingPtrInput interface { pulumi.Input ToConnectorAutoScalingPtrOutput() ConnectorAutoScalingPtrOutput ToConnectorAutoScalingPtrOutputWithContext(context.Context) ConnectorAutoScalingPtrOutput }
ConnectorAutoScalingPtrInput is an input type that accepts ConnectorAutoScalingArgs, ConnectorAutoScalingPtr and ConnectorAutoScalingPtrOutput values. You can construct a concrete instance of `ConnectorAutoScalingPtrInput` via:
ConnectorAutoScalingArgs{...} or: nil
func ConnectorAutoScalingPtr ¶
func ConnectorAutoScalingPtr(v *ConnectorAutoScalingArgs) ConnectorAutoScalingPtrInput
type ConnectorAutoScalingPtrOutput ¶
type ConnectorAutoScalingPtrOutput struct{ *pulumi.OutputState }
func (ConnectorAutoScalingPtrOutput) Elem ¶
func (o ConnectorAutoScalingPtrOutput) Elem() ConnectorAutoScalingOutput
func (ConnectorAutoScalingPtrOutput) ElementType ¶
func (ConnectorAutoScalingPtrOutput) ElementType() reflect.Type
func (ConnectorAutoScalingPtrOutput) MaxWorkerCount ¶
func (o ConnectorAutoScalingPtrOutput) MaxWorkerCount() pulumi.IntPtrOutput
The maximum number of workers for a connector.
func (ConnectorAutoScalingPtrOutput) McuCount ¶
func (o ConnectorAutoScalingPtrOutput) McuCount() pulumi.IntPtrOutput
Specifies how many MSK Connect Units (MCU) as the minimum scaling unit.
func (ConnectorAutoScalingPtrOutput) MinWorkerCount ¶
func (o ConnectorAutoScalingPtrOutput) MinWorkerCount() pulumi.IntPtrOutput
The minimum number of workers for a connector.
func (ConnectorAutoScalingPtrOutput) ScaleInPolicy ¶
func (o ConnectorAutoScalingPtrOutput) ScaleInPolicy() ConnectorScaleInPolicyPtrOutput
func (ConnectorAutoScalingPtrOutput) ScaleOutPolicy ¶
func (o ConnectorAutoScalingPtrOutput) ScaleOutPolicy() ConnectorScaleOutPolicyPtrOutput
func (ConnectorAutoScalingPtrOutput) ToConnectorAutoScalingPtrOutput ¶
func (o ConnectorAutoScalingPtrOutput) ToConnectorAutoScalingPtrOutput() ConnectorAutoScalingPtrOutput
func (ConnectorAutoScalingPtrOutput) ToConnectorAutoScalingPtrOutputWithContext ¶
func (o ConnectorAutoScalingPtrOutput) ToConnectorAutoScalingPtrOutputWithContext(ctx context.Context) ConnectorAutoScalingPtrOutput
type ConnectorCapacity ¶
type ConnectorCapacity struct { AutoScaling *ConnectorAutoScaling `pulumi:"autoScaling"` ProvisionedCapacity *ConnectorProvisionedCapacity `pulumi:"provisionedCapacity"` }
Information about the capacity allocated to the connector.
type ConnectorCapacityArgs ¶
type ConnectorCapacityArgs struct { AutoScaling ConnectorAutoScalingPtrInput `pulumi:"autoScaling"` ProvisionedCapacity ConnectorProvisionedCapacityPtrInput `pulumi:"provisionedCapacity"` }
Information about the capacity allocated to the connector.
func (ConnectorCapacityArgs) ElementType ¶
func (ConnectorCapacityArgs) ElementType() reflect.Type
func (ConnectorCapacityArgs) ToConnectorCapacityOutput ¶
func (i ConnectorCapacityArgs) ToConnectorCapacityOutput() ConnectorCapacityOutput
func (ConnectorCapacityArgs) ToConnectorCapacityOutputWithContext ¶
func (i ConnectorCapacityArgs) ToConnectorCapacityOutputWithContext(ctx context.Context) ConnectorCapacityOutput
type ConnectorCapacityInput ¶
type ConnectorCapacityInput interface { pulumi.Input ToConnectorCapacityOutput() ConnectorCapacityOutput ToConnectorCapacityOutputWithContext(context.Context) ConnectorCapacityOutput }
ConnectorCapacityInput is an input type that accepts ConnectorCapacityArgs and ConnectorCapacityOutput values. You can construct a concrete instance of `ConnectorCapacityInput` via:
ConnectorCapacityArgs{...}
type ConnectorCapacityOutput ¶
type ConnectorCapacityOutput struct{ *pulumi.OutputState }
Information about the capacity allocated to the connector.
func (ConnectorCapacityOutput) AutoScaling ¶
func (o ConnectorCapacityOutput) AutoScaling() ConnectorAutoScalingPtrOutput
func (ConnectorCapacityOutput) ElementType ¶
func (ConnectorCapacityOutput) ElementType() reflect.Type
func (ConnectorCapacityOutput) ProvisionedCapacity ¶
func (o ConnectorCapacityOutput) ProvisionedCapacity() ConnectorProvisionedCapacityPtrOutput
func (ConnectorCapacityOutput) ToConnectorCapacityOutput ¶
func (o ConnectorCapacityOutput) ToConnectorCapacityOutput() ConnectorCapacityOutput
func (ConnectorCapacityOutput) ToConnectorCapacityOutputWithContext ¶
func (o ConnectorCapacityOutput) ToConnectorCapacityOutputWithContext(ctx context.Context) ConnectorCapacityOutput
type ConnectorCapacityPtrOutput ¶
type ConnectorCapacityPtrOutput struct{ *pulumi.OutputState }
func (ConnectorCapacityPtrOutput) AutoScaling ¶
func (o ConnectorCapacityPtrOutput) AutoScaling() ConnectorAutoScalingPtrOutput
func (ConnectorCapacityPtrOutput) Elem ¶
func (o ConnectorCapacityPtrOutput) Elem() ConnectorCapacityOutput
func (ConnectorCapacityPtrOutput) ElementType ¶
func (ConnectorCapacityPtrOutput) ElementType() reflect.Type
func (ConnectorCapacityPtrOutput) ProvisionedCapacity ¶
func (o ConnectorCapacityPtrOutput) ProvisionedCapacity() ConnectorProvisionedCapacityPtrOutput
func (ConnectorCapacityPtrOutput) ToConnectorCapacityPtrOutput ¶
func (o ConnectorCapacityPtrOutput) ToConnectorCapacityPtrOutput() ConnectorCapacityPtrOutput
func (ConnectorCapacityPtrOutput) ToConnectorCapacityPtrOutputWithContext ¶
func (o ConnectorCapacityPtrOutput) ToConnectorCapacityPtrOutputWithContext(ctx context.Context) ConnectorCapacityPtrOutput
type ConnectorCloudWatchLogsLogDelivery ¶
type ConnectorCloudWatchLogsLogDelivery struct { // Specifies whether the logs get sent to the specified CloudWatch Logs destination. Enabled bool `pulumi:"enabled"` // The CloudWatch log group that is the destination for log delivery. LogGroup *string `pulumi:"logGroup"` }
Details about delivering logs to Amazon CloudWatch Logs.
type ConnectorCloudWatchLogsLogDeliveryArgs ¶
type ConnectorCloudWatchLogsLogDeliveryArgs struct { // Specifies whether the logs get sent to the specified CloudWatch Logs destination. Enabled pulumi.BoolInput `pulumi:"enabled"` // The CloudWatch log group that is the destination for log delivery. LogGroup pulumi.StringPtrInput `pulumi:"logGroup"` }
Details about delivering logs to Amazon CloudWatch Logs.
func (ConnectorCloudWatchLogsLogDeliveryArgs) ElementType ¶
func (ConnectorCloudWatchLogsLogDeliveryArgs) ElementType() reflect.Type
func (ConnectorCloudWatchLogsLogDeliveryArgs) ToConnectorCloudWatchLogsLogDeliveryOutput ¶
func (i ConnectorCloudWatchLogsLogDeliveryArgs) ToConnectorCloudWatchLogsLogDeliveryOutput() ConnectorCloudWatchLogsLogDeliveryOutput
func (ConnectorCloudWatchLogsLogDeliveryArgs) ToConnectorCloudWatchLogsLogDeliveryOutputWithContext ¶
func (i ConnectorCloudWatchLogsLogDeliveryArgs) ToConnectorCloudWatchLogsLogDeliveryOutputWithContext(ctx context.Context) ConnectorCloudWatchLogsLogDeliveryOutput
func (ConnectorCloudWatchLogsLogDeliveryArgs) ToConnectorCloudWatchLogsLogDeliveryPtrOutput ¶
func (i ConnectorCloudWatchLogsLogDeliveryArgs) ToConnectorCloudWatchLogsLogDeliveryPtrOutput() ConnectorCloudWatchLogsLogDeliveryPtrOutput
func (ConnectorCloudWatchLogsLogDeliveryArgs) ToConnectorCloudWatchLogsLogDeliveryPtrOutputWithContext ¶
func (i ConnectorCloudWatchLogsLogDeliveryArgs) ToConnectorCloudWatchLogsLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorCloudWatchLogsLogDeliveryPtrOutput
type ConnectorCloudWatchLogsLogDeliveryInput ¶
type ConnectorCloudWatchLogsLogDeliveryInput interface { pulumi.Input ToConnectorCloudWatchLogsLogDeliveryOutput() ConnectorCloudWatchLogsLogDeliveryOutput ToConnectorCloudWatchLogsLogDeliveryOutputWithContext(context.Context) ConnectorCloudWatchLogsLogDeliveryOutput }
ConnectorCloudWatchLogsLogDeliveryInput is an input type that accepts ConnectorCloudWatchLogsLogDeliveryArgs and ConnectorCloudWatchLogsLogDeliveryOutput values. You can construct a concrete instance of `ConnectorCloudWatchLogsLogDeliveryInput` via:
ConnectorCloudWatchLogsLogDeliveryArgs{...}
type ConnectorCloudWatchLogsLogDeliveryOutput ¶
type ConnectorCloudWatchLogsLogDeliveryOutput struct{ *pulumi.OutputState }
Details about delivering logs to Amazon CloudWatch Logs.
func (ConnectorCloudWatchLogsLogDeliveryOutput) ElementType ¶
func (ConnectorCloudWatchLogsLogDeliveryOutput) ElementType() reflect.Type
func (ConnectorCloudWatchLogsLogDeliveryOutput) Enabled ¶
func (o ConnectorCloudWatchLogsLogDeliveryOutput) Enabled() pulumi.BoolOutput
Specifies whether the logs get sent to the specified CloudWatch Logs destination.
func (ConnectorCloudWatchLogsLogDeliveryOutput) LogGroup ¶
func (o ConnectorCloudWatchLogsLogDeliveryOutput) LogGroup() pulumi.StringPtrOutput
The CloudWatch log group that is the destination for log delivery.
func (ConnectorCloudWatchLogsLogDeliveryOutput) ToConnectorCloudWatchLogsLogDeliveryOutput ¶
func (o ConnectorCloudWatchLogsLogDeliveryOutput) ToConnectorCloudWatchLogsLogDeliveryOutput() ConnectorCloudWatchLogsLogDeliveryOutput
func (ConnectorCloudWatchLogsLogDeliveryOutput) ToConnectorCloudWatchLogsLogDeliveryOutputWithContext ¶
func (o ConnectorCloudWatchLogsLogDeliveryOutput) ToConnectorCloudWatchLogsLogDeliveryOutputWithContext(ctx context.Context) ConnectorCloudWatchLogsLogDeliveryOutput
func (ConnectorCloudWatchLogsLogDeliveryOutput) ToConnectorCloudWatchLogsLogDeliveryPtrOutput ¶
func (o ConnectorCloudWatchLogsLogDeliveryOutput) ToConnectorCloudWatchLogsLogDeliveryPtrOutput() ConnectorCloudWatchLogsLogDeliveryPtrOutput
func (ConnectorCloudWatchLogsLogDeliveryOutput) ToConnectorCloudWatchLogsLogDeliveryPtrOutputWithContext ¶
func (o ConnectorCloudWatchLogsLogDeliveryOutput) ToConnectorCloudWatchLogsLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorCloudWatchLogsLogDeliveryPtrOutput
type ConnectorCloudWatchLogsLogDeliveryPtrInput ¶
type ConnectorCloudWatchLogsLogDeliveryPtrInput interface { pulumi.Input ToConnectorCloudWatchLogsLogDeliveryPtrOutput() ConnectorCloudWatchLogsLogDeliveryPtrOutput ToConnectorCloudWatchLogsLogDeliveryPtrOutputWithContext(context.Context) ConnectorCloudWatchLogsLogDeliveryPtrOutput }
ConnectorCloudWatchLogsLogDeliveryPtrInput is an input type that accepts ConnectorCloudWatchLogsLogDeliveryArgs, ConnectorCloudWatchLogsLogDeliveryPtr and ConnectorCloudWatchLogsLogDeliveryPtrOutput values. You can construct a concrete instance of `ConnectorCloudWatchLogsLogDeliveryPtrInput` via:
ConnectorCloudWatchLogsLogDeliveryArgs{...} or: nil
func ConnectorCloudWatchLogsLogDeliveryPtr ¶
func ConnectorCloudWatchLogsLogDeliveryPtr(v *ConnectorCloudWatchLogsLogDeliveryArgs) ConnectorCloudWatchLogsLogDeliveryPtrInput
type ConnectorCloudWatchLogsLogDeliveryPtrOutput ¶
type ConnectorCloudWatchLogsLogDeliveryPtrOutput struct{ *pulumi.OutputState }
func (ConnectorCloudWatchLogsLogDeliveryPtrOutput) ElementType ¶
func (ConnectorCloudWatchLogsLogDeliveryPtrOutput) ElementType() reflect.Type
func (ConnectorCloudWatchLogsLogDeliveryPtrOutput) Enabled ¶
func (o ConnectorCloudWatchLogsLogDeliveryPtrOutput) Enabled() pulumi.BoolPtrOutput
Specifies whether the logs get sent to the specified CloudWatch Logs destination.
func (ConnectorCloudWatchLogsLogDeliveryPtrOutput) LogGroup ¶
func (o ConnectorCloudWatchLogsLogDeliveryPtrOutput) LogGroup() pulumi.StringPtrOutput
The CloudWatch log group that is the destination for log delivery.
func (ConnectorCloudWatchLogsLogDeliveryPtrOutput) ToConnectorCloudWatchLogsLogDeliveryPtrOutput ¶
func (o ConnectorCloudWatchLogsLogDeliveryPtrOutput) ToConnectorCloudWatchLogsLogDeliveryPtrOutput() ConnectorCloudWatchLogsLogDeliveryPtrOutput
func (ConnectorCloudWatchLogsLogDeliveryPtrOutput) ToConnectorCloudWatchLogsLogDeliveryPtrOutputWithContext ¶
func (o ConnectorCloudWatchLogsLogDeliveryPtrOutput) ToConnectorCloudWatchLogsLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorCloudWatchLogsLogDeliveryPtrOutput
type ConnectorCustomPlugin ¶
type ConnectorCustomPlugin struct { // The Amazon Resource Name (ARN) of the custom plugin to use. CustomPluginArn string `pulumi:"customPluginArn"` // The revision of the custom plugin to use. Revision int `pulumi:"revision"` }
Details about a custom plugin.
type ConnectorCustomPluginArgs ¶
type ConnectorCustomPluginArgs struct { // The Amazon Resource Name (ARN) of the custom plugin to use. CustomPluginArn pulumi.StringInput `pulumi:"customPluginArn"` // The revision of the custom plugin to use. Revision pulumi.IntInput `pulumi:"revision"` }
Details about a custom plugin.
func (ConnectorCustomPluginArgs) ElementType ¶
func (ConnectorCustomPluginArgs) ElementType() reflect.Type
func (ConnectorCustomPluginArgs) ToConnectorCustomPluginOutput ¶
func (i ConnectorCustomPluginArgs) ToConnectorCustomPluginOutput() ConnectorCustomPluginOutput
func (ConnectorCustomPluginArgs) ToConnectorCustomPluginOutputWithContext ¶
func (i ConnectorCustomPluginArgs) ToConnectorCustomPluginOutputWithContext(ctx context.Context) ConnectorCustomPluginOutput
type ConnectorCustomPluginInput ¶
type ConnectorCustomPluginInput interface { pulumi.Input ToConnectorCustomPluginOutput() ConnectorCustomPluginOutput ToConnectorCustomPluginOutputWithContext(context.Context) ConnectorCustomPluginOutput }
ConnectorCustomPluginInput is an input type that accepts ConnectorCustomPluginArgs and ConnectorCustomPluginOutput values. You can construct a concrete instance of `ConnectorCustomPluginInput` via:
ConnectorCustomPluginArgs{...}
type ConnectorCustomPluginOutput ¶
type ConnectorCustomPluginOutput struct{ *pulumi.OutputState }
Details about a custom plugin.
func (ConnectorCustomPluginOutput) CustomPluginArn ¶
func (o ConnectorCustomPluginOutput) CustomPluginArn() pulumi.StringOutput
The Amazon Resource Name (ARN) of the custom plugin to use.
func (ConnectorCustomPluginOutput) ElementType ¶
func (ConnectorCustomPluginOutput) ElementType() reflect.Type
func (ConnectorCustomPluginOutput) Revision ¶
func (o ConnectorCustomPluginOutput) Revision() pulumi.IntOutput
The revision of the custom plugin to use.
func (ConnectorCustomPluginOutput) ToConnectorCustomPluginOutput ¶
func (o ConnectorCustomPluginOutput) ToConnectorCustomPluginOutput() ConnectorCustomPluginOutput
func (ConnectorCustomPluginOutput) ToConnectorCustomPluginOutputWithContext ¶
func (o ConnectorCustomPluginOutput) ToConnectorCustomPluginOutputWithContext(ctx context.Context) ConnectorCustomPluginOutput
type ConnectorFirehoseLogDelivery ¶
type ConnectorFirehoseLogDelivery struct { // The Kinesis Data Firehose delivery stream that is the destination for log delivery. DeliveryStream *string `pulumi:"deliveryStream"` // Specifies whether the logs get sent to the specified Kinesis Data Firehose delivery stream. Enabled bool `pulumi:"enabled"` }
Details about delivering logs to Amazon Kinesis Data Firehose.
type ConnectorFirehoseLogDeliveryArgs ¶
type ConnectorFirehoseLogDeliveryArgs struct { // The Kinesis Data Firehose delivery stream that is the destination for log delivery. DeliveryStream pulumi.StringPtrInput `pulumi:"deliveryStream"` // Specifies whether the logs get sent to the specified Kinesis Data Firehose delivery stream. Enabled pulumi.BoolInput `pulumi:"enabled"` }
Details about delivering logs to Amazon Kinesis Data Firehose.
func (ConnectorFirehoseLogDeliveryArgs) ElementType ¶
func (ConnectorFirehoseLogDeliveryArgs) ElementType() reflect.Type
func (ConnectorFirehoseLogDeliveryArgs) ToConnectorFirehoseLogDeliveryOutput ¶
func (i ConnectorFirehoseLogDeliveryArgs) ToConnectorFirehoseLogDeliveryOutput() ConnectorFirehoseLogDeliveryOutput
func (ConnectorFirehoseLogDeliveryArgs) ToConnectorFirehoseLogDeliveryOutputWithContext ¶
func (i ConnectorFirehoseLogDeliveryArgs) ToConnectorFirehoseLogDeliveryOutputWithContext(ctx context.Context) ConnectorFirehoseLogDeliveryOutput
func (ConnectorFirehoseLogDeliveryArgs) ToConnectorFirehoseLogDeliveryPtrOutput ¶
func (i ConnectorFirehoseLogDeliveryArgs) ToConnectorFirehoseLogDeliveryPtrOutput() ConnectorFirehoseLogDeliveryPtrOutput
func (ConnectorFirehoseLogDeliveryArgs) ToConnectorFirehoseLogDeliveryPtrOutputWithContext ¶
func (i ConnectorFirehoseLogDeliveryArgs) ToConnectorFirehoseLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorFirehoseLogDeliveryPtrOutput
type ConnectorFirehoseLogDeliveryInput ¶
type ConnectorFirehoseLogDeliveryInput interface { pulumi.Input ToConnectorFirehoseLogDeliveryOutput() ConnectorFirehoseLogDeliveryOutput ToConnectorFirehoseLogDeliveryOutputWithContext(context.Context) ConnectorFirehoseLogDeliveryOutput }
ConnectorFirehoseLogDeliveryInput is an input type that accepts ConnectorFirehoseLogDeliveryArgs and ConnectorFirehoseLogDeliveryOutput values. You can construct a concrete instance of `ConnectorFirehoseLogDeliveryInput` via:
ConnectorFirehoseLogDeliveryArgs{...}
type ConnectorFirehoseLogDeliveryOutput ¶
type ConnectorFirehoseLogDeliveryOutput struct{ *pulumi.OutputState }
Details about delivering logs to Amazon Kinesis Data Firehose.
func (ConnectorFirehoseLogDeliveryOutput) DeliveryStream ¶
func (o ConnectorFirehoseLogDeliveryOutput) DeliveryStream() pulumi.StringPtrOutput
The Kinesis Data Firehose delivery stream that is the destination for log delivery.
func (ConnectorFirehoseLogDeliveryOutput) ElementType ¶
func (ConnectorFirehoseLogDeliveryOutput) ElementType() reflect.Type
func (ConnectorFirehoseLogDeliveryOutput) Enabled ¶
func (o ConnectorFirehoseLogDeliveryOutput) Enabled() pulumi.BoolOutput
Specifies whether the logs get sent to the specified Kinesis Data Firehose delivery stream.
func (ConnectorFirehoseLogDeliveryOutput) ToConnectorFirehoseLogDeliveryOutput ¶
func (o ConnectorFirehoseLogDeliveryOutput) ToConnectorFirehoseLogDeliveryOutput() ConnectorFirehoseLogDeliveryOutput
func (ConnectorFirehoseLogDeliveryOutput) ToConnectorFirehoseLogDeliveryOutputWithContext ¶
func (o ConnectorFirehoseLogDeliveryOutput) ToConnectorFirehoseLogDeliveryOutputWithContext(ctx context.Context) ConnectorFirehoseLogDeliveryOutput
func (ConnectorFirehoseLogDeliveryOutput) ToConnectorFirehoseLogDeliveryPtrOutput ¶
func (o ConnectorFirehoseLogDeliveryOutput) ToConnectorFirehoseLogDeliveryPtrOutput() ConnectorFirehoseLogDeliveryPtrOutput
func (ConnectorFirehoseLogDeliveryOutput) ToConnectorFirehoseLogDeliveryPtrOutputWithContext ¶
func (o ConnectorFirehoseLogDeliveryOutput) ToConnectorFirehoseLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorFirehoseLogDeliveryPtrOutput
type ConnectorFirehoseLogDeliveryPtrInput ¶
type ConnectorFirehoseLogDeliveryPtrInput interface { pulumi.Input ToConnectorFirehoseLogDeliveryPtrOutput() ConnectorFirehoseLogDeliveryPtrOutput ToConnectorFirehoseLogDeliveryPtrOutputWithContext(context.Context) ConnectorFirehoseLogDeliveryPtrOutput }
ConnectorFirehoseLogDeliveryPtrInput is an input type that accepts ConnectorFirehoseLogDeliveryArgs, ConnectorFirehoseLogDeliveryPtr and ConnectorFirehoseLogDeliveryPtrOutput values. You can construct a concrete instance of `ConnectorFirehoseLogDeliveryPtrInput` via:
ConnectorFirehoseLogDeliveryArgs{...} or: nil
func ConnectorFirehoseLogDeliveryPtr ¶
func ConnectorFirehoseLogDeliveryPtr(v *ConnectorFirehoseLogDeliveryArgs) ConnectorFirehoseLogDeliveryPtrInput
type ConnectorFirehoseLogDeliveryPtrOutput ¶
type ConnectorFirehoseLogDeliveryPtrOutput struct{ *pulumi.OutputState }
func (ConnectorFirehoseLogDeliveryPtrOutput) DeliveryStream ¶
func (o ConnectorFirehoseLogDeliveryPtrOutput) DeliveryStream() pulumi.StringPtrOutput
The Kinesis Data Firehose delivery stream that is the destination for log delivery.
func (ConnectorFirehoseLogDeliveryPtrOutput) ElementType ¶
func (ConnectorFirehoseLogDeliveryPtrOutput) ElementType() reflect.Type
func (ConnectorFirehoseLogDeliveryPtrOutput) Enabled ¶
func (o ConnectorFirehoseLogDeliveryPtrOutput) Enabled() pulumi.BoolPtrOutput
Specifies whether the logs get sent to the specified Kinesis Data Firehose delivery stream.
func (ConnectorFirehoseLogDeliveryPtrOutput) ToConnectorFirehoseLogDeliveryPtrOutput ¶
func (o ConnectorFirehoseLogDeliveryPtrOutput) ToConnectorFirehoseLogDeliveryPtrOutput() ConnectorFirehoseLogDeliveryPtrOutput
func (ConnectorFirehoseLogDeliveryPtrOutput) ToConnectorFirehoseLogDeliveryPtrOutputWithContext ¶
func (o ConnectorFirehoseLogDeliveryPtrOutput) ToConnectorFirehoseLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorFirehoseLogDeliveryPtrOutput
type ConnectorInput ¶
type ConnectorInput interface { pulumi.Input ToConnectorOutput() ConnectorOutput ToConnectorOutputWithContext(ctx context.Context) ConnectorOutput }
type ConnectorKafkaCluster ¶
type ConnectorKafkaCluster struct {
ApacheKafkaCluster ConnectorApacheKafkaCluster `pulumi:"apacheKafkaCluster"`
}
Details of how to connect to the Kafka cluster.
type ConnectorKafkaClusterArgs ¶
type ConnectorKafkaClusterArgs struct {
ApacheKafkaCluster ConnectorApacheKafkaClusterInput `pulumi:"apacheKafkaCluster"`
}
Details of how to connect to the Kafka cluster.
func (ConnectorKafkaClusterArgs) ElementType ¶
func (ConnectorKafkaClusterArgs) ElementType() reflect.Type
func (ConnectorKafkaClusterArgs) ToConnectorKafkaClusterOutput ¶
func (i ConnectorKafkaClusterArgs) ToConnectorKafkaClusterOutput() ConnectorKafkaClusterOutput
func (ConnectorKafkaClusterArgs) ToConnectorKafkaClusterOutputWithContext ¶
func (i ConnectorKafkaClusterArgs) ToConnectorKafkaClusterOutputWithContext(ctx context.Context) ConnectorKafkaClusterOutput
type ConnectorKafkaClusterClientAuthentication ¶
type ConnectorKafkaClusterClientAuthentication struct {
AuthenticationType ConnectorKafkaClusterClientAuthenticationType `pulumi:"authenticationType"`
}
Details of the client authentication used by the Kafka cluster.
type ConnectorKafkaClusterClientAuthenticationArgs ¶
type ConnectorKafkaClusterClientAuthenticationArgs struct {
AuthenticationType ConnectorKafkaClusterClientAuthenticationTypeInput `pulumi:"authenticationType"`
}
Details of the client authentication used by the Kafka cluster.
func (ConnectorKafkaClusterClientAuthenticationArgs) ElementType ¶
func (ConnectorKafkaClusterClientAuthenticationArgs) ElementType() reflect.Type
func (ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationOutput ¶
func (i ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationOutput() ConnectorKafkaClusterClientAuthenticationOutput
func (ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationOutputWithContext ¶
func (i ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationOutput
type ConnectorKafkaClusterClientAuthenticationInput ¶
type ConnectorKafkaClusterClientAuthenticationInput interface { pulumi.Input ToConnectorKafkaClusterClientAuthenticationOutput() ConnectorKafkaClusterClientAuthenticationOutput ToConnectorKafkaClusterClientAuthenticationOutputWithContext(context.Context) ConnectorKafkaClusterClientAuthenticationOutput }
ConnectorKafkaClusterClientAuthenticationInput is an input type that accepts ConnectorKafkaClusterClientAuthenticationArgs and ConnectorKafkaClusterClientAuthenticationOutput values. You can construct a concrete instance of `ConnectorKafkaClusterClientAuthenticationInput` via:
ConnectorKafkaClusterClientAuthenticationArgs{...}
type ConnectorKafkaClusterClientAuthenticationOutput ¶
type ConnectorKafkaClusterClientAuthenticationOutput struct{ *pulumi.OutputState }
Details of the client authentication used by the Kafka cluster.
func (ConnectorKafkaClusterClientAuthenticationOutput) AuthenticationType ¶
func (o ConnectorKafkaClusterClientAuthenticationOutput) AuthenticationType() ConnectorKafkaClusterClientAuthenticationTypeOutput
func (ConnectorKafkaClusterClientAuthenticationOutput) ElementType ¶
func (ConnectorKafkaClusterClientAuthenticationOutput) ElementType() reflect.Type
func (ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationOutput ¶
func (o ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationOutput() ConnectorKafkaClusterClientAuthenticationOutput
func (ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationOutputWithContext ¶
func (o ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationOutput
type ConnectorKafkaClusterClientAuthenticationType ¶
type ConnectorKafkaClusterClientAuthenticationType string
The type of client authentication used to connect to the Kafka cluster. Value NONE means that no client authentication is used.
func (ConnectorKafkaClusterClientAuthenticationType) ElementType ¶
func (ConnectorKafkaClusterClientAuthenticationType) ElementType() reflect.Type
func (ConnectorKafkaClusterClientAuthenticationType) ToConnectorKafkaClusterClientAuthenticationTypeOutput ¶
func (e ConnectorKafkaClusterClientAuthenticationType) ToConnectorKafkaClusterClientAuthenticationTypeOutput() ConnectorKafkaClusterClientAuthenticationTypeOutput
func (ConnectorKafkaClusterClientAuthenticationType) ToConnectorKafkaClusterClientAuthenticationTypeOutputWithContext ¶
func (e ConnectorKafkaClusterClientAuthenticationType) ToConnectorKafkaClusterClientAuthenticationTypeOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationTypeOutput
func (ConnectorKafkaClusterClientAuthenticationType) ToConnectorKafkaClusterClientAuthenticationTypePtrOutput ¶
func (e ConnectorKafkaClusterClientAuthenticationType) ToConnectorKafkaClusterClientAuthenticationTypePtrOutput() ConnectorKafkaClusterClientAuthenticationTypePtrOutput
func (ConnectorKafkaClusterClientAuthenticationType) ToConnectorKafkaClusterClientAuthenticationTypePtrOutputWithContext ¶
func (e ConnectorKafkaClusterClientAuthenticationType) ToConnectorKafkaClusterClientAuthenticationTypePtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationTypePtrOutput
func (ConnectorKafkaClusterClientAuthenticationType) ToStringOutput ¶
func (e ConnectorKafkaClusterClientAuthenticationType) ToStringOutput() pulumi.StringOutput
func (ConnectorKafkaClusterClientAuthenticationType) ToStringOutputWithContext ¶
func (e ConnectorKafkaClusterClientAuthenticationType) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput
func (ConnectorKafkaClusterClientAuthenticationType) ToStringPtrOutput ¶
func (e ConnectorKafkaClusterClientAuthenticationType) ToStringPtrOutput() pulumi.StringPtrOutput
func (ConnectorKafkaClusterClientAuthenticationType) ToStringPtrOutputWithContext ¶
func (e ConnectorKafkaClusterClientAuthenticationType) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput
type ConnectorKafkaClusterClientAuthenticationTypeInput ¶
type ConnectorKafkaClusterClientAuthenticationTypeInput interface { pulumi.Input ToConnectorKafkaClusterClientAuthenticationTypeOutput() ConnectorKafkaClusterClientAuthenticationTypeOutput ToConnectorKafkaClusterClientAuthenticationTypeOutputWithContext(context.Context) ConnectorKafkaClusterClientAuthenticationTypeOutput }
ConnectorKafkaClusterClientAuthenticationTypeInput is an input type that accepts ConnectorKafkaClusterClientAuthenticationTypeArgs and ConnectorKafkaClusterClientAuthenticationTypeOutput values. You can construct a concrete instance of `ConnectorKafkaClusterClientAuthenticationTypeInput` via:
ConnectorKafkaClusterClientAuthenticationTypeArgs{...}
type ConnectorKafkaClusterClientAuthenticationTypeOutput ¶
type ConnectorKafkaClusterClientAuthenticationTypeOutput struct{ *pulumi.OutputState }
func (ConnectorKafkaClusterClientAuthenticationTypeOutput) ElementType ¶
func (ConnectorKafkaClusterClientAuthenticationTypeOutput) ElementType() reflect.Type
func (ConnectorKafkaClusterClientAuthenticationTypeOutput) ToConnectorKafkaClusterClientAuthenticationTypeOutput ¶
func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToConnectorKafkaClusterClientAuthenticationTypeOutput() ConnectorKafkaClusterClientAuthenticationTypeOutput
func (ConnectorKafkaClusterClientAuthenticationTypeOutput) ToConnectorKafkaClusterClientAuthenticationTypeOutputWithContext ¶
func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToConnectorKafkaClusterClientAuthenticationTypeOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationTypeOutput
func (ConnectorKafkaClusterClientAuthenticationTypeOutput) ToConnectorKafkaClusterClientAuthenticationTypePtrOutput ¶
func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToConnectorKafkaClusterClientAuthenticationTypePtrOutput() ConnectorKafkaClusterClientAuthenticationTypePtrOutput
func (ConnectorKafkaClusterClientAuthenticationTypeOutput) ToConnectorKafkaClusterClientAuthenticationTypePtrOutputWithContext ¶
func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToConnectorKafkaClusterClientAuthenticationTypePtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationTypePtrOutput
func (ConnectorKafkaClusterClientAuthenticationTypeOutput) ToStringOutput ¶
func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToStringOutput() pulumi.StringOutput
func (ConnectorKafkaClusterClientAuthenticationTypeOutput) ToStringOutputWithContext ¶
func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput
func (ConnectorKafkaClusterClientAuthenticationTypeOutput) ToStringPtrOutput ¶
func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToStringPtrOutput() pulumi.StringPtrOutput
func (ConnectorKafkaClusterClientAuthenticationTypeOutput) ToStringPtrOutputWithContext ¶
func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput
type ConnectorKafkaClusterClientAuthenticationTypePtrInput ¶
type ConnectorKafkaClusterClientAuthenticationTypePtrInput interface { pulumi.Input ToConnectorKafkaClusterClientAuthenticationTypePtrOutput() ConnectorKafkaClusterClientAuthenticationTypePtrOutput ToConnectorKafkaClusterClientAuthenticationTypePtrOutputWithContext(context.Context) ConnectorKafkaClusterClientAuthenticationTypePtrOutput }
func ConnectorKafkaClusterClientAuthenticationTypePtr ¶
func ConnectorKafkaClusterClientAuthenticationTypePtr(v string) ConnectorKafkaClusterClientAuthenticationTypePtrInput
type ConnectorKafkaClusterClientAuthenticationTypePtrOutput ¶
type ConnectorKafkaClusterClientAuthenticationTypePtrOutput struct{ *pulumi.OutputState }
func (ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ElementType ¶
func (ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ElementType() reflect.Type
func (ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ToConnectorKafkaClusterClientAuthenticationTypePtrOutput ¶
func (o ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ToConnectorKafkaClusterClientAuthenticationTypePtrOutput() ConnectorKafkaClusterClientAuthenticationTypePtrOutput
func (ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ToConnectorKafkaClusterClientAuthenticationTypePtrOutputWithContext ¶
func (o ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ToConnectorKafkaClusterClientAuthenticationTypePtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationTypePtrOutput
func (ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ToStringPtrOutput ¶
func (o ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ToStringPtrOutput() pulumi.StringPtrOutput
func (ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ToStringPtrOutputWithContext ¶
func (o ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput
type ConnectorKafkaClusterEncryptionInTransit ¶
type ConnectorKafkaClusterEncryptionInTransit struct {
EncryptionType ConnectorKafkaClusterEncryptionInTransitType `pulumi:"encryptionType"`
}
Details of encryption in transit to the Kafka cluster.
type ConnectorKafkaClusterEncryptionInTransitArgs ¶
type ConnectorKafkaClusterEncryptionInTransitArgs struct {
EncryptionType ConnectorKafkaClusterEncryptionInTransitTypeInput `pulumi:"encryptionType"`
}
Details of encryption in transit to the Kafka cluster.
func (ConnectorKafkaClusterEncryptionInTransitArgs) ElementType ¶
func (ConnectorKafkaClusterEncryptionInTransitArgs) ElementType() reflect.Type
func (ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitOutput ¶
func (i ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitOutput() ConnectorKafkaClusterEncryptionInTransitOutput
func (ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitOutputWithContext ¶
func (i ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitOutput
type ConnectorKafkaClusterEncryptionInTransitInput ¶
type ConnectorKafkaClusterEncryptionInTransitInput interface { pulumi.Input ToConnectorKafkaClusterEncryptionInTransitOutput() ConnectorKafkaClusterEncryptionInTransitOutput ToConnectorKafkaClusterEncryptionInTransitOutputWithContext(context.Context) ConnectorKafkaClusterEncryptionInTransitOutput }
ConnectorKafkaClusterEncryptionInTransitInput is an input type that accepts ConnectorKafkaClusterEncryptionInTransitArgs and ConnectorKafkaClusterEncryptionInTransitOutput values. You can construct a concrete instance of `ConnectorKafkaClusterEncryptionInTransitInput` via:
ConnectorKafkaClusterEncryptionInTransitArgs{...}
type ConnectorKafkaClusterEncryptionInTransitOutput ¶
type ConnectorKafkaClusterEncryptionInTransitOutput struct{ *pulumi.OutputState }
Details of encryption in transit to the Kafka cluster.
func (ConnectorKafkaClusterEncryptionInTransitOutput) ElementType ¶
func (ConnectorKafkaClusterEncryptionInTransitOutput) ElementType() reflect.Type
func (ConnectorKafkaClusterEncryptionInTransitOutput) EncryptionType ¶
func (o ConnectorKafkaClusterEncryptionInTransitOutput) EncryptionType() ConnectorKafkaClusterEncryptionInTransitTypeOutput
func (ConnectorKafkaClusterEncryptionInTransitOutput) ToConnectorKafkaClusterEncryptionInTransitOutput ¶
func (o ConnectorKafkaClusterEncryptionInTransitOutput) ToConnectorKafkaClusterEncryptionInTransitOutput() ConnectorKafkaClusterEncryptionInTransitOutput
func (ConnectorKafkaClusterEncryptionInTransitOutput) ToConnectorKafkaClusterEncryptionInTransitOutputWithContext ¶
func (o ConnectorKafkaClusterEncryptionInTransitOutput) ToConnectorKafkaClusterEncryptionInTransitOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitOutput
type ConnectorKafkaClusterEncryptionInTransitType ¶
type ConnectorKafkaClusterEncryptionInTransitType string
The type of encryption in transit to the Kafka cluster.
func (ConnectorKafkaClusterEncryptionInTransitType) ElementType ¶
func (ConnectorKafkaClusterEncryptionInTransitType) ElementType() reflect.Type
func (ConnectorKafkaClusterEncryptionInTransitType) ToConnectorKafkaClusterEncryptionInTransitTypeOutput ¶
func (e ConnectorKafkaClusterEncryptionInTransitType) ToConnectorKafkaClusterEncryptionInTransitTypeOutput() ConnectorKafkaClusterEncryptionInTransitTypeOutput
func (ConnectorKafkaClusterEncryptionInTransitType) ToConnectorKafkaClusterEncryptionInTransitTypeOutputWithContext ¶
func (e ConnectorKafkaClusterEncryptionInTransitType) ToConnectorKafkaClusterEncryptionInTransitTypeOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitTypeOutput
func (ConnectorKafkaClusterEncryptionInTransitType) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutput ¶
func (e ConnectorKafkaClusterEncryptionInTransitType) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutput() ConnectorKafkaClusterEncryptionInTransitTypePtrOutput
func (ConnectorKafkaClusterEncryptionInTransitType) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutputWithContext ¶
func (e ConnectorKafkaClusterEncryptionInTransitType) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitTypePtrOutput
func (ConnectorKafkaClusterEncryptionInTransitType) ToStringOutput ¶
func (e ConnectorKafkaClusterEncryptionInTransitType) ToStringOutput() pulumi.StringOutput
func (ConnectorKafkaClusterEncryptionInTransitType) ToStringOutputWithContext ¶
func (e ConnectorKafkaClusterEncryptionInTransitType) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput
func (ConnectorKafkaClusterEncryptionInTransitType) ToStringPtrOutput ¶
func (e ConnectorKafkaClusterEncryptionInTransitType) ToStringPtrOutput() pulumi.StringPtrOutput
func (ConnectorKafkaClusterEncryptionInTransitType) ToStringPtrOutputWithContext ¶
func (e ConnectorKafkaClusterEncryptionInTransitType) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput
type ConnectorKafkaClusterEncryptionInTransitTypeInput ¶
type ConnectorKafkaClusterEncryptionInTransitTypeInput interface { pulumi.Input ToConnectorKafkaClusterEncryptionInTransitTypeOutput() ConnectorKafkaClusterEncryptionInTransitTypeOutput ToConnectorKafkaClusterEncryptionInTransitTypeOutputWithContext(context.Context) ConnectorKafkaClusterEncryptionInTransitTypeOutput }
ConnectorKafkaClusterEncryptionInTransitTypeInput is an input type that accepts ConnectorKafkaClusterEncryptionInTransitTypeArgs and ConnectorKafkaClusterEncryptionInTransitTypeOutput values. You can construct a concrete instance of `ConnectorKafkaClusterEncryptionInTransitTypeInput` via:
ConnectorKafkaClusterEncryptionInTransitTypeArgs{...}
type ConnectorKafkaClusterEncryptionInTransitTypeOutput ¶
type ConnectorKafkaClusterEncryptionInTransitTypeOutput struct{ *pulumi.OutputState }
func (ConnectorKafkaClusterEncryptionInTransitTypeOutput) ElementType ¶
func (ConnectorKafkaClusterEncryptionInTransitTypeOutput) ElementType() reflect.Type
func (ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToConnectorKafkaClusterEncryptionInTransitTypeOutput ¶
func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToConnectorKafkaClusterEncryptionInTransitTypeOutput() ConnectorKafkaClusterEncryptionInTransitTypeOutput
func (ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToConnectorKafkaClusterEncryptionInTransitTypeOutputWithContext ¶
func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToConnectorKafkaClusterEncryptionInTransitTypeOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitTypeOutput
func (ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutput ¶
func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutput() ConnectorKafkaClusterEncryptionInTransitTypePtrOutput
func (ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutputWithContext ¶
func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitTypePtrOutput
func (ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToStringOutput ¶
func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToStringOutput() pulumi.StringOutput
func (ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToStringOutputWithContext ¶
func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput
func (ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToStringPtrOutput ¶
func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToStringPtrOutput() pulumi.StringPtrOutput
func (ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToStringPtrOutputWithContext ¶
func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput
type ConnectorKafkaClusterEncryptionInTransitTypePtrInput ¶
type ConnectorKafkaClusterEncryptionInTransitTypePtrInput interface { pulumi.Input ToConnectorKafkaClusterEncryptionInTransitTypePtrOutput() ConnectorKafkaClusterEncryptionInTransitTypePtrOutput ToConnectorKafkaClusterEncryptionInTransitTypePtrOutputWithContext(context.Context) ConnectorKafkaClusterEncryptionInTransitTypePtrOutput }
func ConnectorKafkaClusterEncryptionInTransitTypePtr ¶
func ConnectorKafkaClusterEncryptionInTransitTypePtr(v string) ConnectorKafkaClusterEncryptionInTransitTypePtrInput
type ConnectorKafkaClusterEncryptionInTransitTypePtrOutput ¶
type ConnectorKafkaClusterEncryptionInTransitTypePtrOutput struct{ *pulumi.OutputState }
func (ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ElementType ¶
func (ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ElementType() reflect.Type
func (ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutput ¶
func (o ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutput() ConnectorKafkaClusterEncryptionInTransitTypePtrOutput
func (ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutputWithContext ¶
func (o ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitTypePtrOutput
func (ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ToStringPtrOutput ¶
func (o ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ToStringPtrOutput() pulumi.StringPtrOutput
func (ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ToStringPtrOutputWithContext ¶
func (o ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput
type ConnectorKafkaClusterInput ¶
type ConnectorKafkaClusterInput interface { pulumi.Input ToConnectorKafkaClusterOutput() ConnectorKafkaClusterOutput ToConnectorKafkaClusterOutputWithContext(context.Context) ConnectorKafkaClusterOutput }
ConnectorKafkaClusterInput is an input type that accepts ConnectorKafkaClusterArgs and ConnectorKafkaClusterOutput values. You can construct a concrete instance of `ConnectorKafkaClusterInput` via:
ConnectorKafkaClusterArgs{...}
type ConnectorKafkaClusterOutput ¶
type ConnectorKafkaClusterOutput struct{ *pulumi.OutputState }
Details of how to connect to the Kafka cluster.
func (ConnectorKafkaClusterOutput) ApacheKafkaCluster ¶
func (o ConnectorKafkaClusterOutput) ApacheKafkaCluster() ConnectorApacheKafkaClusterOutput
func (ConnectorKafkaClusterOutput) ElementType ¶
func (ConnectorKafkaClusterOutput) ElementType() reflect.Type
func (ConnectorKafkaClusterOutput) ToConnectorKafkaClusterOutput ¶
func (o ConnectorKafkaClusterOutput) ToConnectorKafkaClusterOutput() ConnectorKafkaClusterOutput
func (ConnectorKafkaClusterOutput) ToConnectorKafkaClusterOutputWithContext ¶
func (o ConnectorKafkaClusterOutput) ToConnectorKafkaClusterOutputWithContext(ctx context.Context) ConnectorKafkaClusterOutput
type ConnectorLogDelivery ¶
type ConnectorLogDelivery struct {
WorkerLogDelivery ConnectorWorkerLogDelivery `pulumi:"workerLogDelivery"`
}
Details of what logs are delivered and where they are delivered.
type ConnectorLogDeliveryArgs ¶
type ConnectorLogDeliveryArgs struct {
WorkerLogDelivery ConnectorWorkerLogDeliveryInput `pulumi:"workerLogDelivery"`
}
Details of what logs are delivered and where they are delivered.
func (ConnectorLogDeliveryArgs) ElementType ¶
func (ConnectorLogDeliveryArgs) ElementType() reflect.Type
func (ConnectorLogDeliveryArgs) ToConnectorLogDeliveryOutput ¶
func (i ConnectorLogDeliveryArgs) ToConnectorLogDeliveryOutput() ConnectorLogDeliveryOutput
func (ConnectorLogDeliveryArgs) ToConnectorLogDeliveryOutputWithContext ¶
func (i ConnectorLogDeliveryArgs) ToConnectorLogDeliveryOutputWithContext(ctx context.Context) ConnectorLogDeliveryOutput
func (ConnectorLogDeliveryArgs) ToConnectorLogDeliveryPtrOutput ¶
func (i ConnectorLogDeliveryArgs) ToConnectorLogDeliveryPtrOutput() ConnectorLogDeliveryPtrOutput
func (ConnectorLogDeliveryArgs) ToConnectorLogDeliveryPtrOutputWithContext ¶
func (i ConnectorLogDeliveryArgs) ToConnectorLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorLogDeliveryPtrOutput
type ConnectorLogDeliveryInput ¶
type ConnectorLogDeliveryInput interface { pulumi.Input ToConnectorLogDeliveryOutput() ConnectorLogDeliveryOutput ToConnectorLogDeliveryOutputWithContext(context.Context) ConnectorLogDeliveryOutput }
ConnectorLogDeliveryInput is an input type that accepts ConnectorLogDeliveryArgs and ConnectorLogDeliveryOutput values. You can construct a concrete instance of `ConnectorLogDeliveryInput` via:
ConnectorLogDeliveryArgs{...}
type ConnectorLogDeliveryOutput ¶
type ConnectorLogDeliveryOutput struct{ *pulumi.OutputState }
Details of what logs are delivered and where they are delivered.
func (ConnectorLogDeliveryOutput) ElementType ¶
func (ConnectorLogDeliveryOutput) ElementType() reflect.Type
func (ConnectorLogDeliveryOutput) ToConnectorLogDeliveryOutput ¶
func (o ConnectorLogDeliveryOutput) ToConnectorLogDeliveryOutput() ConnectorLogDeliveryOutput
func (ConnectorLogDeliveryOutput) ToConnectorLogDeliveryOutputWithContext ¶
func (o ConnectorLogDeliveryOutput) ToConnectorLogDeliveryOutputWithContext(ctx context.Context) ConnectorLogDeliveryOutput
func (ConnectorLogDeliveryOutput) ToConnectorLogDeliveryPtrOutput ¶
func (o ConnectorLogDeliveryOutput) ToConnectorLogDeliveryPtrOutput() ConnectorLogDeliveryPtrOutput
func (ConnectorLogDeliveryOutput) ToConnectorLogDeliveryPtrOutputWithContext ¶
func (o ConnectorLogDeliveryOutput) ToConnectorLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorLogDeliveryPtrOutput
func (ConnectorLogDeliveryOutput) WorkerLogDelivery ¶
func (o ConnectorLogDeliveryOutput) WorkerLogDelivery() ConnectorWorkerLogDeliveryOutput
type ConnectorLogDeliveryPtrInput ¶
type ConnectorLogDeliveryPtrInput interface { pulumi.Input ToConnectorLogDeliveryPtrOutput() ConnectorLogDeliveryPtrOutput ToConnectorLogDeliveryPtrOutputWithContext(context.Context) ConnectorLogDeliveryPtrOutput }
ConnectorLogDeliveryPtrInput is an input type that accepts ConnectorLogDeliveryArgs, ConnectorLogDeliveryPtr and ConnectorLogDeliveryPtrOutput values. You can construct a concrete instance of `ConnectorLogDeliveryPtrInput` via:
ConnectorLogDeliveryArgs{...} or: nil
func ConnectorLogDeliveryPtr ¶
func ConnectorLogDeliveryPtr(v *ConnectorLogDeliveryArgs) ConnectorLogDeliveryPtrInput
type ConnectorLogDeliveryPtrOutput ¶
type ConnectorLogDeliveryPtrOutput struct{ *pulumi.OutputState }
func (ConnectorLogDeliveryPtrOutput) Elem ¶
func (o ConnectorLogDeliveryPtrOutput) Elem() ConnectorLogDeliveryOutput
func (ConnectorLogDeliveryPtrOutput) ElementType ¶
func (ConnectorLogDeliveryPtrOutput) ElementType() reflect.Type
func (ConnectorLogDeliveryPtrOutput) ToConnectorLogDeliveryPtrOutput ¶
func (o ConnectorLogDeliveryPtrOutput) ToConnectorLogDeliveryPtrOutput() ConnectorLogDeliveryPtrOutput
func (ConnectorLogDeliveryPtrOutput) ToConnectorLogDeliveryPtrOutputWithContext ¶
func (o ConnectorLogDeliveryPtrOutput) ToConnectorLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorLogDeliveryPtrOutput
func (ConnectorLogDeliveryPtrOutput) WorkerLogDelivery ¶
func (o ConnectorLogDeliveryPtrOutput) WorkerLogDelivery() ConnectorWorkerLogDeliveryPtrOutput
type ConnectorOutput ¶
type ConnectorOutput struct{ *pulumi.OutputState }
func (ConnectorOutput) ElementType ¶
func (ConnectorOutput) ElementType() reflect.Type
func (ConnectorOutput) ToConnectorOutput ¶
func (o ConnectorOutput) ToConnectorOutput() ConnectorOutput
func (ConnectorOutput) ToConnectorOutputWithContext ¶
func (o ConnectorOutput) ToConnectorOutputWithContext(ctx context.Context) ConnectorOutput
type ConnectorPlugin ¶
type ConnectorPlugin struct {
CustomPlugin ConnectorCustomPlugin `pulumi:"customPlugin"`
}
Details about a Kafka Connect plugin which will be used with the connector.
type ConnectorPluginArgs ¶
type ConnectorPluginArgs struct {
CustomPlugin ConnectorCustomPluginInput `pulumi:"customPlugin"`
}
Details about a Kafka Connect plugin which will be used with the connector.
func (ConnectorPluginArgs) ElementType ¶
func (ConnectorPluginArgs) ElementType() reflect.Type
func (ConnectorPluginArgs) ToConnectorPluginOutput ¶
func (i ConnectorPluginArgs) ToConnectorPluginOutput() ConnectorPluginOutput
func (ConnectorPluginArgs) ToConnectorPluginOutputWithContext ¶
func (i ConnectorPluginArgs) ToConnectorPluginOutputWithContext(ctx context.Context) ConnectorPluginOutput
type ConnectorPluginArray ¶
type ConnectorPluginArray []ConnectorPluginInput
func (ConnectorPluginArray) ElementType ¶
func (ConnectorPluginArray) ElementType() reflect.Type
func (ConnectorPluginArray) ToConnectorPluginArrayOutput ¶
func (i ConnectorPluginArray) ToConnectorPluginArrayOutput() ConnectorPluginArrayOutput
func (ConnectorPluginArray) ToConnectorPluginArrayOutputWithContext ¶
func (i ConnectorPluginArray) ToConnectorPluginArrayOutputWithContext(ctx context.Context) ConnectorPluginArrayOutput
type ConnectorPluginArrayInput ¶
type ConnectorPluginArrayInput interface { pulumi.Input ToConnectorPluginArrayOutput() ConnectorPluginArrayOutput ToConnectorPluginArrayOutputWithContext(context.Context) ConnectorPluginArrayOutput }
ConnectorPluginArrayInput is an input type that accepts ConnectorPluginArray and ConnectorPluginArrayOutput values. You can construct a concrete instance of `ConnectorPluginArrayInput` via:
ConnectorPluginArray{ ConnectorPluginArgs{...} }
type ConnectorPluginArrayOutput ¶
type ConnectorPluginArrayOutput struct{ *pulumi.OutputState }
func (ConnectorPluginArrayOutput) ElementType ¶
func (ConnectorPluginArrayOutput) ElementType() reflect.Type
func (ConnectorPluginArrayOutput) Index ¶
func (o ConnectorPluginArrayOutput) Index(i pulumi.IntInput) ConnectorPluginOutput
func (ConnectorPluginArrayOutput) ToConnectorPluginArrayOutput ¶
func (o ConnectorPluginArrayOutput) ToConnectorPluginArrayOutput() ConnectorPluginArrayOutput
func (ConnectorPluginArrayOutput) ToConnectorPluginArrayOutputWithContext ¶
func (o ConnectorPluginArrayOutput) ToConnectorPluginArrayOutputWithContext(ctx context.Context) ConnectorPluginArrayOutput
type ConnectorPluginInput ¶
type ConnectorPluginInput interface { pulumi.Input ToConnectorPluginOutput() ConnectorPluginOutput ToConnectorPluginOutputWithContext(context.Context) ConnectorPluginOutput }
ConnectorPluginInput is an input type that accepts ConnectorPluginArgs and ConnectorPluginOutput values. You can construct a concrete instance of `ConnectorPluginInput` via:
ConnectorPluginArgs{...}
type ConnectorPluginOutput ¶
type ConnectorPluginOutput struct{ *pulumi.OutputState }
Details about a Kafka Connect plugin which will be used with the connector.
func (ConnectorPluginOutput) CustomPlugin ¶
func (o ConnectorPluginOutput) CustomPlugin() ConnectorCustomPluginOutput
func (ConnectorPluginOutput) ElementType ¶
func (ConnectorPluginOutput) ElementType() reflect.Type
func (ConnectorPluginOutput) ToConnectorPluginOutput ¶
func (o ConnectorPluginOutput) ToConnectorPluginOutput() ConnectorPluginOutput
func (ConnectorPluginOutput) ToConnectorPluginOutputWithContext ¶
func (o ConnectorPluginOutput) ToConnectorPluginOutputWithContext(ctx context.Context) ConnectorPluginOutput
type ConnectorProvisionedCapacity ¶
type ConnectorProvisionedCapacity struct { // Specifies how many MSK Connect Units (MCU) are allocated to the connector. McuCount *int `pulumi:"mcuCount"` // Number of workers for a connector. WorkerCount int `pulumi:"workerCount"` }
Details about a fixed capacity allocated to a connector.
type ConnectorProvisionedCapacityArgs ¶
type ConnectorProvisionedCapacityArgs struct { // Specifies how many MSK Connect Units (MCU) are allocated to the connector. McuCount pulumi.IntPtrInput `pulumi:"mcuCount"` // Number of workers for a connector. WorkerCount pulumi.IntInput `pulumi:"workerCount"` }
Details about a fixed capacity allocated to a connector.
func (ConnectorProvisionedCapacityArgs) ElementType ¶
func (ConnectorProvisionedCapacityArgs) ElementType() reflect.Type
func (ConnectorProvisionedCapacityArgs) ToConnectorProvisionedCapacityOutput ¶
func (i ConnectorProvisionedCapacityArgs) ToConnectorProvisionedCapacityOutput() ConnectorProvisionedCapacityOutput
func (ConnectorProvisionedCapacityArgs) ToConnectorProvisionedCapacityOutputWithContext ¶
func (i ConnectorProvisionedCapacityArgs) ToConnectorProvisionedCapacityOutputWithContext(ctx context.Context) ConnectorProvisionedCapacityOutput
func (ConnectorProvisionedCapacityArgs) ToConnectorProvisionedCapacityPtrOutput ¶
func (i ConnectorProvisionedCapacityArgs) ToConnectorProvisionedCapacityPtrOutput() ConnectorProvisionedCapacityPtrOutput
func (ConnectorProvisionedCapacityArgs) ToConnectorProvisionedCapacityPtrOutputWithContext ¶
func (i ConnectorProvisionedCapacityArgs) ToConnectorProvisionedCapacityPtrOutputWithContext(ctx context.Context) ConnectorProvisionedCapacityPtrOutput
type ConnectorProvisionedCapacityInput ¶
type ConnectorProvisionedCapacityInput interface { pulumi.Input ToConnectorProvisionedCapacityOutput() ConnectorProvisionedCapacityOutput ToConnectorProvisionedCapacityOutputWithContext(context.Context) ConnectorProvisionedCapacityOutput }
ConnectorProvisionedCapacityInput is an input type that accepts ConnectorProvisionedCapacityArgs and ConnectorProvisionedCapacityOutput values. You can construct a concrete instance of `ConnectorProvisionedCapacityInput` via:
ConnectorProvisionedCapacityArgs{...}
type ConnectorProvisionedCapacityOutput ¶
type ConnectorProvisionedCapacityOutput struct{ *pulumi.OutputState }
Details about a fixed capacity allocated to a connector.
func (ConnectorProvisionedCapacityOutput) ElementType ¶
func (ConnectorProvisionedCapacityOutput) ElementType() reflect.Type
func (ConnectorProvisionedCapacityOutput) McuCount ¶
func (o ConnectorProvisionedCapacityOutput) McuCount() pulumi.IntPtrOutput
Specifies how many MSK Connect Units (MCU) are allocated to the connector.
func (ConnectorProvisionedCapacityOutput) ToConnectorProvisionedCapacityOutput ¶
func (o ConnectorProvisionedCapacityOutput) ToConnectorProvisionedCapacityOutput() ConnectorProvisionedCapacityOutput
func (ConnectorProvisionedCapacityOutput) ToConnectorProvisionedCapacityOutputWithContext ¶
func (o ConnectorProvisionedCapacityOutput) ToConnectorProvisionedCapacityOutputWithContext(ctx context.Context) ConnectorProvisionedCapacityOutput
func (ConnectorProvisionedCapacityOutput) ToConnectorProvisionedCapacityPtrOutput ¶
func (o ConnectorProvisionedCapacityOutput) ToConnectorProvisionedCapacityPtrOutput() ConnectorProvisionedCapacityPtrOutput
func (ConnectorProvisionedCapacityOutput) ToConnectorProvisionedCapacityPtrOutputWithContext ¶
func (o ConnectorProvisionedCapacityOutput) ToConnectorProvisionedCapacityPtrOutputWithContext(ctx context.Context) ConnectorProvisionedCapacityPtrOutput
func (ConnectorProvisionedCapacityOutput) WorkerCount ¶
func (o ConnectorProvisionedCapacityOutput) WorkerCount() pulumi.IntOutput
Number of workers for a connector.
type ConnectorProvisionedCapacityPtrInput ¶
type ConnectorProvisionedCapacityPtrInput interface { pulumi.Input ToConnectorProvisionedCapacityPtrOutput() ConnectorProvisionedCapacityPtrOutput ToConnectorProvisionedCapacityPtrOutputWithContext(context.Context) ConnectorProvisionedCapacityPtrOutput }
ConnectorProvisionedCapacityPtrInput is an input type that accepts ConnectorProvisionedCapacityArgs, ConnectorProvisionedCapacityPtr and ConnectorProvisionedCapacityPtrOutput values. You can construct a concrete instance of `ConnectorProvisionedCapacityPtrInput` via:
ConnectorProvisionedCapacityArgs{...} or: nil
func ConnectorProvisionedCapacityPtr ¶
func ConnectorProvisionedCapacityPtr(v *ConnectorProvisionedCapacityArgs) ConnectorProvisionedCapacityPtrInput
type ConnectorProvisionedCapacityPtrOutput ¶
type ConnectorProvisionedCapacityPtrOutput struct{ *pulumi.OutputState }
func (ConnectorProvisionedCapacityPtrOutput) ElementType ¶
func (ConnectorProvisionedCapacityPtrOutput) ElementType() reflect.Type
func (ConnectorProvisionedCapacityPtrOutput) McuCount ¶
func (o ConnectorProvisionedCapacityPtrOutput) McuCount() pulumi.IntPtrOutput
Specifies how many MSK Connect Units (MCU) are allocated to the connector.
func (ConnectorProvisionedCapacityPtrOutput) ToConnectorProvisionedCapacityPtrOutput ¶
func (o ConnectorProvisionedCapacityPtrOutput) ToConnectorProvisionedCapacityPtrOutput() ConnectorProvisionedCapacityPtrOutput
func (ConnectorProvisionedCapacityPtrOutput) ToConnectorProvisionedCapacityPtrOutputWithContext ¶
func (o ConnectorProvisionedCapacityPtrOutput) ToConnectorProvisionedCapacityPtrOutputWithContext(ctx context.Context) ConnectorProvisionedCapacityPtrOutput
func (ConnectorProvisionedCapacityPtrOutput) WorkerCount ¶
func (o ConnectorProvisionedCapacityPtrOutput) WorkerCount() pulumi.IntPtrOutput
Number of workers for a connector.
type ConnectorS3LogDelivery ¶
type ConnectorS3LogDelivery struct { // The name of the S3 bucket that is the destination for log delivery. Bucket *string `pulumi:"bucket"` // Specifies whether the logs get sent to the specified Amazon S3 destination. Enabled bool `pulumi:"enabled"` // The S3 prefix that is the destination for log delivery. Prefix *string `pulumi:"prefix"` }
Details about delivering logs to Amazon S3.
type ConnectorS3LogDeliveryArgs ¶
type ConnectorS3LogDeliveryArgs struct { // The name of the S3 bucket that is the destination for log delivery. Bucket pulumi.StringPtrInput `pulumi:"bucket"` // Specifies whether the logs get sent to the specified Amazon S3 destination. Enabled pulumi.BoolInput `pulumi:"enabled"` // The S3 prefix that is the destination for log delivery. Prefix pulumi.StringPtrInput `pulumi:"prefix"` }
Details about delivering logs to Amazon S3.
func (ConnectorS3LogDeliveryArgs) ElementType ¶
func (ConnectorS3LogDeliveryArgs) ElementType() reflect.Type
func (ConnectorS3LogDeliveryArgs) ToConnectorS3LogDeliveryOutput ¶
func (i ConnectorS3LogDeliveryArgs) ToConnectorS3LogDeliveryOutput() ConnectorS3LogDeliveryOutput
func (ConnectorS3LogDeliveryArgs) ToConnectorS3LogDeliveryOutputWithContext ¶
func (i ConnectorS3LogDeliveryArgs) ToConnectorS3LogDeliveryOutputWithContext(ctx context.Context) ConnectorS3LogDeliveryOutput
func (ConnectorS3LogDeliveryArgs) ToConnectorS3LogDeliveryPtrOutput ¶
func (i ConnectorS3LogDeliveryArgs) ToConnectorS3LogDeliveryPtrOutput() ConnectorS3LogDeliveryPtrOutput
func (ConnectorS3LogDeliveryArgs) ToConnectorS3LogDeliveryPtrOutputWithContext ¶
func (i ConnectorS3LogDeliveryArgs) ToConnectorS3LogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorS3LogDeliveryPtrOutput
type ConnectorS3LogDeliveryInput ¶
type ConnectorS3LogDeliveryInput interface { pulumi.Input ToConnectorS3LogDeliveryOutput() ConnectorS3LogDeliveryOutput ToConnectorS3LogDeliveryOutputWithContext(context.Context) ConnectorS3LogDeliveryOutput }
ConnectorS3LogDeliveryInput is an input type that accepts ConnectorS3LogDeliveryArgs and ConnectorS3LogDeliveryOutput values. You can construct a concrete instance of `ConnectorS3LogDeliveryInput` via:
ConnectorS3LogDeliveryArgs{...}
type ConnectorS3LogDeliveryOutput ¶
type ConnectorS3LogDeliveryOutput struct{ *pulumi.OutputState }
Details about delivering logs to Amazon S3.
func (ConnectorS3LogDeliveryOutput) Bucket ¶
func (o ConnectorS3LogDeliveryOutput) Bucket() pulumi.StringPtrOutput
The name of the S3 bucket that is the destination for log delivery.
func (ConnectorS3LogDeliveryOutput) ElementType ¶
func (ConnectorS3LogDeliveryOutput) ElementType() reflect.Type
func (ConnectorS3LogDeliveryOutput) Enabled ¶
func (o ConnectorS3LogDeliveryOutput) Enabled() pulumi.BoolOutput
Specifies whether the logs get sent to the specified Amazon S3 destination.
func (ConnectorS3LogDeliveryOutput) Prefix ¶
func (o ConnectorS3LogDeliveryOutput) Prefix() pulumi.StringPtrOutput
The S3 prefix that is the destination for log delivery.
func (ConnectorS3LogDeliveryOutput) ToConnectorS3LogDeliveryOutput ¶
func (o ConnectorS3LogDeliveryOutput) ToConnectorS3LogDeliveryOutput() ConnectorS3LogDeliveryOutput
func (ConnectorS3LogDeliveryOutput) ToConnectorS3LogDeliveryOutputWithContext ¶
func (o ConnectorS3LogDeliveryOutput) ToConnectorS3LogDeliveryOutputWithContext(ctx context.Context) ConnectorS3LogDeliveryOutput
func (ConnectorS3LogDeliveryOutput) ToConnectorS3LogDeliveryPtrOutput ¶
func (o ConnectorS3LogDeliveryOutput) ToConnectorS3LogDeliveryPtrOutput() ConnectorS3LogDeliveryPtrOutput
func (ConnectorS3LogDeliveryOutput) ToConnectorS3LogDeliveryPtrOutputWithContext ¶
func (o ConnectorS3LogDeliveryOutput) ToConnectorS3LogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorS3LogDeliveryPtrOutput
type ConnectorS3LogDeliveryPtrInput ¶
type ConnectorS3LogDeliveryPtrInput interface { pulumi.Input ToConnectorS3LogDeliveryPtrOutput() ConnectorS3LogDeliveryPtrOutput ToConnectorS3LogDeliveryPtrOutputWithContext(context.Context) ConnectorS3LogDeliveryPtrOutput }
ConnectorS3LogDeliveryPtrInput is an input type that accepts ConnectorS3LogDeliveryArgs, ConnectorS3LogDeliveryPtr and ConnectorS3LogDeliveryPtrOutput values. You can construct a concrete instance of `ConnectorS3LogDeliveryPtrInput` via:
ConnectorS3LogDeliveryArgs{...} or: nil
func ConnectorS3LogDeliveryPtr ¶
func ConnectorS3LogDeliveryPtr(v *ConnectorS3LogDeliveryArgs) ConnectorS3LogDeliveryPtrInput
type ConnectorS3LogDeliveryPtrOutput ¶
type ConnectorS3LogDeliveryPtrOutput struct{ *pulumi.OutputState }
func (ConnectorS3LogDeliveryPtrOutput) Bucket ¶
func (o ConnectorS3LogDeliveryPtrOutput) Bucket() pulumi.StringPtrOutput
The name of the S3 bucket that is the destination for log delivery.
func (ConnectorS3LogDeliveryPtrOutput) Elem ¶
func (o ConnectorS3LogDeliveryPtrOutput) Elem() ConnectorS3LogDeliveryOutput
func (ConnectorS3LogDeliveryPtrOutput) ElementType ¶
func (ConnectorS3LogDeliveryPtrOutput) ElementType() reflect.Type
func (ConnectorS3LogDeliveryPtrOutput) Enabled ¶
func (o ConnectorS3LogDeliveryPtrOutput) Enabled() pulumi.BoolPtrOutput
Specifies whether the logs get sent to the specified Amazon S3 destination.
func (ConnectorS3LogDeliveryPtrOutput) Prefix ¶
func (o ConnectorS3LogDeliveryPtrOutput) Prefix() pulumi.StringPtrOutput
The S3 prefix that is the destination for log delivery.
func (ConnectorS3LogDeliveryPtrOutput) ToConnectorS3LogDeliveryPtrOutput ¶
func (o ConnectorS3LogDeliveryPtrOutput) ToConnectorS3LogDeliveryPtrOutput() ConnectorS3LogDeliveryPtrOutput
func (ConnectorS3LogDeliveryPtrOutput) ToConnectorS3LogDeliveryPtrOutputWithContext ¶
func (o ConnectorS3LogDeliveryPtrOutput) ToConnectorS3LogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorS3LogDeliveryPtrOutput
type ConnectorScaleInPolicy ¶
type ConnectorScaleInPolicy struct { // Specifies the CPU utilization percentage threshold at which connector scale in should trigger. CpuUtilizationPercentage int `pulumi:"cpuUtilizationPercentage"` }
Information about the scale in policy of the connector.
type ConnectorScaleInPolicyArgs ¶
type ConnectorScaleInPolicyArgs struct { // Specifies the CPU utilization percentage threshold at which connector scale in should trigger. CpuUtilizationPercentage pulumi.IntInput `pulumi:"cpuUtilizationPercentage"` }
Information about the scale in policy of the connector.
func (ConnectorScaleInPolicyArgs) ElementType ¶
func (ConnectorScaleInPolicyArgs) ElementType() reflect.Type
func (ConnectorScaleInPolicyArgs) ToConnectorScaleInPolicyOutput ¶
func (i ConnectorScaleInPolicyArgs) ToConnectorScaleInPolicyOutput() ConnectorScaleInPolicyOutput
func (ConnectorScaleInPolicyArgs) ToConnectorScaleInPolicyOutputWithContext ¶
func (i ConnectorScaleInPolicyArgs) ToConnectorScaleInPolicyOutputWithContext(ctx context.Context) ConnectorScaleInPolicyOutput
func (ConnectorScaleInPolicyArgs) ToConnectorScaleInPolicyPtrOutput ¶
func (i ConnectorScaleInPolicyArgs) ToConnectorScaleInPolicyPtrOutput() ConnectorScaleInPolicyPtrOutput
func (ConnectorScaleInPolicyArgs) ToConnectorScaleInPolicyPtrOutputWithContext ¶
func (i ConnectorScaleInPolicyArgs) ToConnectorScaleInPolicyPtrOutputWithContext(ctx context.Context) ConnectorScaleInPolicyPtrOutput
type ConnectorScaleInPolicyInput ¶
type ConnectorScaleInPolicyInput interface { pulumi.Input ToConnectorScaleInPolicyOutput() ConnectorScaleInPolicyOutput ToConnectorScaleInPolicyOutputWithContext(context.Context) ConnectorScaleInPolicyOutput }
ConnectorScaleInPolicyInput is an input type that accepts ConnectorScaleInPolicyArgs and ConnectorScaleInPolicyOutput values. You can construct a concrete instance of `ConnectorScaleInPolicyInput` via:
ConnectorScaleInPolicyArgs{...}
type ConnectorScaleInPolicyOutput ¶
type ConnectorScaleInPolicyOutput struct{ *pulumi.OutputState }
Information about the scale in policy of the connector.
func (ConnectorScaleInPolicyOutput) CpuUtilizationPercentage ¶
func (o ConnectorScaleInPolicyOutput) CpuUtilizationPercentage() pulumi.IntOutput
Specifies the CPU utilization percentage threshold at which connector scale in should trigger.
func (ConnectorScaleInPolicyOutput) ElementType ¶
func (ConnectorScaleInPolicyOutput) ElementType() reflect.Type
func (ConnectorScaleInPolicyOutput) ToConnectorScaleInPolicyOutput ¶
func (o ConnectorScaleInPolicyOutput) ToConnectorScaleInPolicyOutput() ConnectorScaleInPolicyOutput
func (ConnectorScaleInPolicyOutput) ToConnectorScaleInPolicyOutputWithContext ¶
func (o ConnectorScaleInPolicyOutput) ToConnectorScaleInPolicyOutputWithContext(ctx context.Context) ConnectorScaleInPolicyOutput
func (ConnectorScaleInPolicyOutput) ToConnectorScaleInPolicyPtrOutput ¶
func (o ConnectorScaleInPolicyOutput) ToConnectorScaleInPolicyPtrOutput() ConnectorScaleInPolicyPtrOutput
func (ConnectorScaleInPolicyOutput) ToConnectorScaleInPolicyPtrOutputWithContext ¶
func (o ConnectorScaleInPolicyOutput) ToConnectorScaleInPolicyPtrOutputWithContext(ctx context.Context) ConnectorScaleInPolicyPtrOutput
type ConnectorScaleInPolicyPtrInput ¶
type ConnectorScaleInPolicyPtrInput interface { pulumi.Input ToConnectorScaleInPolicyPtrOutput() ConnectorScaleInPolicyPtrOutput ToConnectorScaleInPolicyPtrOutputWithContext(context.Context) ConnectorScaleInPolicyPtrOutput }
ConnectorScaleInPolicyPtrInput is an input type that accepts ConnectorScaleInPolicyArgs, ConnectorScaleInPolicyPtr and ConnectorScaleInPolicyPtrOutput values. You can construct a concrete instance of `ConnectorScaleInPolicyPtrInput` via:
ConnectorScaleInPolicyArgs{...} or: nil
func ConnectorScaleInPolicyPtr ¶
func ConnectorScaleInPolicyPtr(v *ConnectorScaleInPolicyArgs) ConnectorScaleInPolicyPtrInput
type ConnectorScaleInPolicyPtrOutput ¶
type ConnectorScaleInPolicyPtrOutput struct{ *pulumi.OutputState }
func (ConnectorScaleInPolicyPtrOutput) CpuUtilizationPercentage ¶
func (o ConnectorScaleInPolicyPtrOutput) CpuUtilizationPercentage() pulumi.IntPtrOutput
Specifies the CPU utilization percentage threshold at which connector scale in should trigger.
func (ConnectorScaleInPolicyPtrOutput) Elem ¶
func (o ConnectorScaleInPolicyPtrOutput) Elem() ConnectorScaleInPolicyOutput
func (ConnectorScaleInPolicyPtrOutput) ElementType ¶
func (ConnectorScaleInPolicyPtrOutput) ElementType() reflect.Type
func (ConnectorScaleInPolicyPtrOutput) ToConnectorScaleInPolicyPtrOutput ¶
func (o ConnectorScaleInPolicyPtrOutput) ToConnectorScaleInPolicyPtrOutput() ConnectorScaleInPolicyPtrOutput
func (ConnectorScaleInPolicyPtrOutput) ToConnectorScaleInPolicyPtrOutputWithContext ¶
func (o ConnectorScaleInPolicyPtrOutput) ToConnectorScaleInPolicyPtrOutputWithContext(ctx context.Context) ConnectorScaleInPolicyPtrOutput
type ConnectorScaleOutPolicy ¶
type ConnectorScaleOutPolicy struct { // Specifies the CPU utilization percentage threshold at which connector scale out should trigger. CpuUtilizationPercentage int `pulumi:"cpuUtilizationPercentage"` }
Information about the scale out policy of the connector.
type ConnectorScaleOutPolicyArgs ¶
type ConnectorScaleOutPolicyArgs struct { // Specifies the CPU utilization percentage threshold at which connector scale out should trigger. CpuUtilizationPercentage pulumi.IntInput `pulumi:"cpuUtilizationPercentage"` }
Information about the scale out policy of the connector.
func (ConnectorScaleOutPolicyArgs) ElementType ¶
func (ConnectorScaleOutPolicyArgs) ElementType() reflect.Type
func (ConnectorScaleOutPolicyArgs) ToConnectorScaleOutPolicyOutput ¶
func (i ConnectorScaleOutPolicyArgs) ToConnectorScaleOutPolicyOutput() ConnectorScaleOutPolicyOutput
func (ConnectorScaleOutPolicyArgs) ToConnectorScaleOutPolicyOutputWithContext ¶
func (i ConnectorScaleOutPolicyArgs) ToConnectorScaleOutPolicyOutputWithContext(ctx context.Context) ConnectorScaleOutPolicyOutput
func (ConnectorScaleOutPolicyArgs) ToConnectorScaleOutPolicyPtrOutput ¶
func (i ConnectorScaleOutPolicyArgs) ToConnectorScaleOutPolicyPtrOutput() ConnectorScaleOutPolicyPtrOutput
func (ConnectorScaleOutPolicyArgs) ToConnectorScaleOutPolicyPtrOutputWithContext ¶
func (i ConnectorScaleOutPolicyArgs) ToConnectorScaleOutPolicyPtrOutputWithContext(ctx context.Context) ConnectorScaleOutPolicyPtrOutput
type ConnectorScaleOutPolicyInput ¶
type ConnectorScaleOutPolicyInput interface { pulumi.Input ToConnectorScaleOutPolicyOutput() ConnectorScaleOutPolicyOutput ToConnectorScaleOutPolicyOutputWithContext(context.Context) ConnectorScaleOutPolicyOutput }
ConnectorScaleOutPolicyInput is an input type that accepts ConnectorScaleOutPolicyArgs and ConnectorScaleOutPolicyOutput values. You can construct a concrete instance of `ConnectorScaleOutPolicyInput` via:
ConnectorScaleOutPolicyArgs{...}
type ConnectorScaleOutPolicyOutput ¶
type ConnectorScaleOutPolicyOutput struct{ *pulumi.OutputState }
Information about the scale out policy of the connector.
func (ConnectorScaleOutPolicyOutput) CpuUtilizationPercentage ¶
func (o ConnectorScaleOutPolicyOutput) CpuUtilizationPercentage() pulumi.IntOutput
Specifies the CPU utilization percentage threshold at which connector scale out should trigger.
func (ConnectorScaleOutPolicyOutput) ElementType ¶
func (ConnectorScaleOutPolicyOutput) ElementType() reflect.Type
func (ConnectorScaleOutPolicyOutput) ToConnectorScaleOutPolicyOutput ¶
func (o ConnectorScaleOutPolicyOutput) ToConnectorScaleOutPolicyOutput() ConnectorScaleOutPolicyOutput
func (ConnectorScaleOutPolicyOutput) ToConnectorScaleOutPolicyOutputWithContext ¶
func (o ConnectorScaleOutPolicyOutput) ToConnectorScaleOutPolicyOutputWithContext(ctx context.Context) ConnectorScaleOutPolicyOutput
func (ConnectorScaleOutPolicyOutput) ToConnectorScaleOutPolicyPtrOutput ¶
func (o ConnectorScaleOutPolicyOutput) ToConnectorScaleOutPolicyPtrOutput() ConnectorScaleOutPolicyPtrOutput
func (ConnectorScaleOutPolicyOutput) ToConnectorScaleOutPolicyPtrOutputWithContext ¶
func (o ConnectorScaleOutPolicyOutput) ToConnectorScaleOutPolicyPtrOutputWithContext(ctx context.Context) ConnectorScaleOutPolicyPtrOutput
type ConnectorScaleOutPolicyPtrInput ¶
type ConnectorScaleOutPolicyPtrInput interface { pulumi.Input ToConnectorScaleOutPolicyPtrOutput() ConnectorScaleOutPolicyPtrOutput ToConnectorScaleOutPolicyPtrOutputWithContext(context.Context) ConnectorScaleOutPolicyPtrOutput }
ConnectorScaleOutPolicyPtrInput is an input type that accepts ConnectorScaleOutPolicyArgs, ConnectorScaleOutPolicyPtr and ConnectorScaleOutPolicyPtrOutput values. You can construct a concrete instance of `ConnectorScaleOutPolicyPtrInput` via:
ConnectorScaleOutPolicyArgs{...} or: nil
func ConnectorScaleOutPolicyPtr ¶
func ConnectorScaleOutPolicyPtr(v *ConnectorScaleOutPolicyArgs) ConnectorScaleOutPolicyPtrInput
type ConnectorScaleOutPolicyPtrOutput ¶
type ConnectorScaleOutPolicyPtrOutput struct{ *pulumi.OutputState }
func (ConnectorScaleOutPolicyPtrOutput) CpuUtilizationPercentage ¶
func (o ConnectorScaleOutPolicyPtrOutput) CpuUtilizationPercentage() pulumi.IntPtrOutput
Specifies the CPU utilization percentage threshold at which connector scale out should trigger.
func (ConnectorScaleOutPolicyPtrOutput) Elem ¶
func (o ConnectorScaleOutPolicyPtrOutput) Elem() ConnectorScaleOutPolicyOutput
func (ConnectorScaleOutPolicyPtrOutput) ElementType ¶
func (ConnectorScaleOutPolicyPtrOutput) ElementType() reflect.Type
func (ConnectorScaleOutPolicyPtrOutput) ToConnectorScaleOutPolicyPtrOutput ¶
func (o ConnectorScaleOutPolicyPtrOutput) ToConnectorScaleOutPolicyPtrOutput() ConnectorScaleOutPolicyPtrOutput
func (ConnectorScaleOutPolicyPtrOutput) ToConnectorScaleOutPolicyPtrOutputWithContext ¶
func (o ConnectorScaleOutPolicyPtrOutput) ToConnectorScaleOutPolicyPtrOutputWithContext(ctx context.Context) ConnectorScaleOutPolicyPtrOutput
type ConnectorState ¶
type ConnectorState struct { }
func (ConnectorState) ElementType ¶
func (ConnectorState) ElementType() reflect.Type
type ConnectorVpc ¶
type ConnectorVpc struct { // The AWS security groups to associate with the elastic network interfaces in order to specify what the connector has access to. SecurityGroups []string `pulumi:"securityGroups"` // The list of subnets to connect to in the virtual private cloud (VPC). AWS creates elastic network interfaces inside these subnets. Subnets []string `pulumi:"subnets"` }
Information about a VPC used with the connector.
type ConnectorVpcArgs ¶
type ConnectorVpcArgs struct { // The AWS security groups to associate with the elastic network interfaces in order to specify what the connector has access to. SecurityGroups pulumi.StringArrayInput `pulumi:"securityGroups"` // The list of subnets to connect to in the virtual private cloud (VPC). AWS creates elastic network interfaces inside these subnets. Subnets pulumi.StringArrayInput `pulumi:"subnets"` }
Information about a VPC used with the connector.
func (ConnectorVpcArgs) ElementType ¶
func (ConnectorVpcArgs) ElementType() reflect.Type
func (ConnectorVpcArgs) ToConnectorVpcOutput ¶
func (i ConnectorVpcArgs) ToConnectorVpcOutput() ConnectorVpcOutput
func (ConnectorVpcArgs) ToConnectorVpcOutputWithContext ¶
func (i ConnectorVpcArgs) ToConnectorVpcOutputWithContext(ctx context.Context) ConnectorVpcOutput
type ConnectorVpcInput ¶
type ConnectorVpcInput interface { pulumi.Input ToConnectorVpcOutput() ConnectorVpcOutput ToConnectorVpcOutputWithContext(context.Context) ConnectorVpcOutput }
ConnectorVpcInput is an input type that accepts ConnectorVpcArgs and ConnectorVpcOutput values. You can construct a concrete instance of `ConnectorVpcInput` via:
ConnectorVpcArgs{...}
type ConnectorVpcOutput ¶
type ConnectorVpcOutput struct{ *pulumi.OutputState }
Information about a VPC used with the connector.
func (ConnectorVpcOutput) ElementType ¶
func (ConnectorVpcOutput) ElementType() reflect.Type
func (ConnectorVpcOutput) SecurityGroups ¶
func (o ConnectorVpcOutput) SecurityGroups() pulumi.StringArrayOutput
The AWS security groups to associate with the elastic network interfaces in order to specify what the connector has access to.
func (ConnectorVpcOutput) Subnets ¶
func (o ConnectorVpcOutput) Subnets() pulumi.StringArrayOutput
The list of subnets to connect to in the virtual private cloud (VPC). AWS creates elastic network interfaces inside these subnets.
func (ConnectorVpcOutput) ToConnectorVpcOutput ¶
func (o ConnectorVpcOutput) ToConnectorVpcOutput() ConnectorVpcOutput
func (ConnectorVpcOutput) ToConnectorVpcOutputWithContext ¶
func (o ConnectorVpcOutput) ToConnectorVpcOutputWithContext(ctx context.Context) ConnectorVpcOutput
type ConnectorWorkerConfiguration ¶
type ConnectorWorkerConfiguration struct { // The revision of the worker configuration to use. Revision int `pulumi:"revision"` // The Amazon Resource Name (ARN) of the worker configuration to use. WorkerConfigurationArn string `pulumi:"workerConfigurationArn"` }
Specifies the worker configuration to use with the connector.
type ConnectorWorkerConfigurationArgs ¶
type ConnectorWorkerConfigurationArgs struct { // The revision of the worker configuration to use. Revision pulumi.IntInput `pulumi:"revision"` // The Amazon Resource Name (ARN) of the worker configuration to use. WorkerConfigurationArn pulumi.StringInput `pulumi:"workerConfigurationArn"` }
Specifies the worker configuration to use with the connector.
func (ConnectorWorkerConfigurationArgs) ElementType ¶
func (ConnectorWorkerConfigurationArgs) ElementType() reflect.Type
func (ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationOutput ¶
func (i ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationOutput() ConnectorWorkerConfigurationOutput
func (ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationOutputWithContext ¶
func (i ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationOutputWithContext(ctx context.Context) ConnectorWorkerConfigurationOutput
func (ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationPtrOutput ¶
func (i ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationPtrOutput() ConnectorWorkerConfigurationPtrOutput
func (ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationPtrOutputWithContext ¶
func (i ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationPtrOutputWithContext(ctx context.Context) ConnectorWorkerConfigurationPtrOutput
type ConnectorWorkerConfigurationInput ¶
type ConnectorWorkerConfigurationInput interface { pulumi.Input ToConnectorWorkerConfigurationOutput() ConnectorWorkerConfigurationOutput ToConnectorWorkerConfigurationOutputWithContext(context.Context) ConnectorWorkerConfigurationOutput }
ConnectorWorkerConfigurationInput is an input type that accepts ConnectorWorkerConfigurationArgs and ConnectorWorkerConfigurationOutput values. You can construct a concrete instance of `ConnectorWorkerConfigurationInput` via:
ConnectorWorkerConfigurationArgs{...}
type ConnectorWorkerConfigurationOutput ¶
type ConnectorWorkerConfigurationOutput struct{ *pulumi.OutputState }
Specifies the worker configuration to use with the connector.
func (ConnectorWorkerConfigurationOutput) ElementType ¶
func (ConnectorWorkerConfigurationOutput) ElementType() reflect.Type
func (ConnectorWorkerConfigurationOutput) Revision ¶
func (o ConnectorWorkerConfigurationOutput) Revision() pulumi.IntOutput
The revision of the worker configuration to use.
func (ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationOutput ¶
func (o ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationOutput() ConnectorWorkerConfigurationOutput
func (ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationOutputWithContext ¶
func (o ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationOutputWithContext(ctx context.Context) ConnectorWorkerConfigurationOutput
func (ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationPtrOutput ¶
func (o ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationPtrOutput() ConnectorWorkerConfigurationPtrOutput
func (ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationPtrOutputWithContext ¶
func (o ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationPtrOutputWithContext(ctx context.Context) ConnectorWorkerConfigurationPtrOutput
func (ConnectorWorkerConfigurationOutput) WorkerConfigurationArn ¶
func (o ConnectorWorkerConfigurationOutput) WorkerConfigurationArn() pulumi.StringOutput
The Amazon Resource Name (ARN) of the worker configuration to use.
type ConnectorWorkerConfigurationPtrInput ¶
type ConnectorWorkerConfigurationPtrInput interface { pulumi.Input ToConnectorWorkerConfigurationPtrOutput() ConnectorWorkerConfigurationPtrOutput ToConnectorWorkerConfigurationPtrOutputWithContext(context.Context) ConnectorWorkerConfigurationPtrOutput }
ConnectorWorkerConfigurationPtrInput is an input type that accepts ConnectorWorkerConfigurationArgs, ConnectorWorkerConfigurationPtr and ConnectorWorkerConfigurationPtrOutput values. You can construct a concrete instance of `ConnectorWorkerConfigurationPtrInput` via:
ConnectorWorkerConfigurationArgs{...} or: nil
func ConnectorWorkerConfigurationPtr ¶
func ConnectorWorkerConfigurationPtr(v *ConnectorWorkerConfigurationArgs) ConnectorWorkerConfigurationPtrInput
type ConnectorWorkerConfigurationPtrOutput ¶
type ConnectorWorkerConfigurationPtrOutput struct{ *pulumi.OutputState }
func (ConnectorWorkerConfigurationPtrOutput) ElementType ¶
func (ConnectorWorkerConfigurationPtrOutput) ElementType() reflect.Type
func (ConnectorWorkerConfigurationPtrOutput) Revision ¶
func (o ConnectorWorkerConfigurationPtrOutput) Revision() pulumi.IntPtrOutput
The revision of the worker configuration to use.
func (ConnectorWorkerConfigurationPtrOutput) ToConnectorWorkerConfigurationPtrOutput ¶
func (o ConnectorWorkerConfigurationPtrOutput) ToConnectorWorkerConfigurationPtrOutput() ConnectorWorkerConfigurationPtrOutput
func (ConnectorWorkerConfigurationPtrOutput) ToConnectorWorkerConfigurationPtrOutputWithContext ¶
func (o ConnectorWorkerConfigurationPtrOutput) ToConnectorWorkerConfigurationPtrOutputWithContext(ctx context.Context) ConnectorWorkerConfigurationPtrOutput
func (ConnectorWorkerConfigurationPtrOutput) WorkerConfigurationArn ¶
func (o ConnectorWorkerConfigurationPtrOutput) WorkerConfigurationArn() pulumi.StringPtrOutput
The Amazon Resource Name (ARN) of the worker configuration to use.
type ConnectorWorkerLogDelivery ¶
type ConnectorWorkerLogDelivery struct { CloudWatchLogs *ConnectorCloudWatchLogsLogDelivery `pulumi:"cloudWatchLogs"` Firehose *ConnectorFirehoseLogDelivery `pulumi:"firehose"` S3 *ConnectorS3LogDelivery `pulumi:"s3"` }
Specifies where worker logs are delivered.
type ConnectorWorkerLogDeliveryArgs ¶
type ConnectorWorkerLogDeliveryArgs struct { CloudWatchLogs ConnectorCloudWatchLogsLogDeliveryPtrInput `pulumi:"cloudWatchLogs"` Firehose ConnectorFirehoseLogDeliveryPtrInput `pulumi:"firehose"` S3 ConnectorS3LogDeliveryPtrInput `pulumi:"s3"` }
Specifies where worker logs are delivered.
func (ConnectorWorkerLogDeliveryArgs) ElementType ¶
func (ConnectorWorkerLogDeliveryArgs) ElementType() reflect.Type
func (ConnectorWorkerLogDeliveryArgs) ToConnectorWorkerLogDeliveryOutput ¶
func (i ConnectorWorkerLogDeliveryArgs) ToConnectorWorkerLogDeliveryOutput() ConnectorWorkerLogDeliveryOutput
func (ConnectorWorkerLogDeliveryArgs) ToConnectorWorkerLogDeliveryOutputWithContext ¶
func (i ConnectorWorkerLogDeliveryArgs) ToConnectorWorkerLogDeliveryOutputWithContext(ctx context.Context) ConnectorWorkerLogDeliveryOutput
func (ConnectorWorkerLogDeliveryArgs) ToConnectorWorkerLogDeliveryPtrOutput ¶
func (i ConnectorWorkerLogDeliveryArgs) ToConnectorWorkerLogDeliveryPtrOutput() ConnectorWorkerLogDeliveryPtrOutput
func (ConnectorWorkerLogDeliveryArgs) ToConnectorWorkerLogDeliveryPtrOutputWithContext ¶
func (i ConnectorWorkerLogDeliveryArgs) ToConnectorWorkerLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorWorkerLogDeliveryPtrOutput
type ConnectorWorkerLogDeliveryInput ¶
type ConnectorWorkerLogDeliveryInput interface { pulumi.Input ToConnectorWorkerLogDeliveryOutput() ConnectorWorkerLogDeliveryOutput ToConnectorWorkerLogDeliveryOutputWithContext(context.Context) ConnectorWorkerLogDeliveryOutput }
ConnectorWorkerLogDeliveryInput is an input type that accepts ConnectorWorkerLogDeliveryArgs and ConnectorWorkerLogDeliveryOutput values. You can construct a concrete instance of `ConnectorWorkerLogDeliveryInput` via:
ConnectorWorkerLogDeliveryArgs{...}
type ConnectorWorkerLogDeliveryOutput ¶
type ConnectorWorkerLogDeliveryOutput struct{ *pulumi.OutputState }
Specifies where worker logs are delivered.
func (ConnectorWorkerLogDeliveryOutput) CloudWatchLogs ¶
func (o ConnectorWorkerLogDeliveryOutput) CloudWatchLogs() ConnectorCloudWatchLogsLogDeliveryPtrOutput
func (ConnectorWorkerLogDeliveryOutput) ElementType ¶
func (ConnectorWorkerLogDeliveryOutput) ElementType() reflect.Type
func (ConnectorWorkerLogDeliveryOutput) Firehose ¶
func (o ConnectorWorkerLogDeliveryOutput) Firehose() ConnectorFirehoseLogDeliveryPtrOutput
func (ConnectorWorkerLogDeliveryOutput) ToConnectorWorkerLogDeliveryOutput ¶
func (o ConnectorWorkerLogDeliveryOutput) ToConnectorWorkerLogDeliveryOutput() ConnectorWorkerLogDeliveryOutput
func (ConnectorWorkerLogDeliveryOutput) ToConnectorWorkerLogDeliveryOutputWithContext ¶
func (o ConnectorWorkerLogDeliveryOutput) ToConnectorWorkerLogDeliveryOutputWithContext(ctx context.Context) ConnectorWorkerLogDeliveryOutput
func (ConnectorWorkerLogDeliveryOutput) ToConnectorWorkerLogDeliveryPtrOutput ¶
func (o ConnectorWorkerLogDeliveryOutput) ToConnectorWorkerLogDeliveryPtrOutput() ConnectorWorkerLogDeliveryPtrOutput
func (ConnectorWorkerLogDeliveryOutput) ToConnectorWorkerLogDeliveryPtrOutputWithContext ¶
func (o ConnectorWorkerLogDeliveryOutput) ToConnectorWorkerLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorWorkerLogDeliveryPtrOutput
type ConnectorWorkerLogDeliveryPtrInput ¶
type ConnectorWorkerLogDeliveryPtrInput interface { pulumi.Input ToConnectorWorkerLogDeliveryPtrOutput() ConnectorWorkerLogDeliveryPtrOutput ToConnectorWorkerLogDeliveryPtrOutputWithContext(context.Context) ConnectorWorkerLogDeliveryPtrOutput }
ConnectorWorkerLogDeliveryPtrInput is an input type that accepts ConnectorWorkerLogDeliveryArgs, ConnectorWorkerLogDeliveryPtr and ConnectorWorkerLogDeliveryPtrOutput values. You can construct a concrete instance of `ConnectorWorkerLogDeliveryPtrInput` via:
ConnectorWorkerLogDeliveryArgs{...} or: nil
func ConnectorWorkerLogDeliveryPtr ¶
func ConnectorWorkerLogDeliveryPtr(v *ConnectorWorkerLogDeliveryArgs) ConnectorWorkerLogDeliveryPtrInput
type ConnectorWorkerLogDeliveryPtrOutput ¶
type ConnectorWorkerLogDeliveryPtrOutput struct{ *pulumi.OutputState }
func (ConnectorWorkerLogDeliveryPtrOutput) CloudWatchLogs ¶
func (o ConnectorWorkerLogDeliveryPtrOutput) CloudWatchLogs() ConnectorCloudWatchLogsLogDeliveryPtrOutput
func (ConnectorWorkerLogDeliveryPtrOutput) Elem ¶
func (o ConnectorWorkerLogDeliveryPtrOutput) Elem() ConnectorWorkerLogDeliveryOutput
func (ConnectorWorkerLogDeliveryPtrOutput) ElementType ¶
func (ConnectorWorkerLogDeliveryPtrOutput) ElementType() reflect.Type
func (ConnectorWorkerLogDeliveryPtrOutput) Firehose ¶
func (o ConnectorWorkerLogDeliveryPtrOutput) Firehose() ConnectorFirehoseLogDeliveryPtrOutput
func (ConnectorWorkerLogDeliveryPtrOutput) ToConnectorWorkerLogDeliveryPtrOutput ¶
func (o ConnectorWorkerLogDeliveryPtrOutput) ToConnectorWorkerLogDeliveryPtrOutput() ConnectorWorkerLogDeliveryPtrOutput
func (ConnectorWorkerLogDeliveryPtrOutput) ToConnectorWorkerLogDeliveryPtrOutputWithContext ¶
func (o ConnectorWorkerLogDeliveryPtrOutput) ToConnectorWorkerLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorWorkerLogDeliveryPtrOutput
type LookupConnectorArgs ¶ added in v0.12.0
type LookupConnectorArgs struct { // Amazon Resource Name for the created Connector. ConnectorArn string `pulumi:"connectorArn"` }
type LookupConnectorOutputArgs ¶ added in v0.12.0
type LookupConnectorOutputArgs struct { // Amazon Resource Name for the created Connector. ConnectorArn pulumi.StringInput `pulumi:"connectorArn"` }
func (LookupConnectorOutputArgs) ElementType ¶ added in v0.12.0
func (LookupConnectorOutputArgs) ElementType() reflect.Type
type LookupConnectorResult ¶ added in v0.12.0
type LookupConnectorResult struct { Capacity *ConnectorCapacity `pulumi:"capacity"` // Amazon Resource Name for the created Connector. ConnectorArn *string `pulumi:"connectorArn"` }
func LookupConnector ¶ added in v0.12.0
func LookupConnector(ctx *pulumi.Context, args *LookupConnectorArgs, opts ...pulumi.InvokeOption) (*LookupConnectorResult, error)
Resource Type definition for AWS::KafkaConnect::Connector
type LookupConnectorResultOutput ¶ added in v0.12.0
type LookupConnectorResultOutput struct{ *pulumi.OutputState }
func LookupConnectorOutput ¶ added in v0.12.0
func LookupConnectorOutput(ctx *pulumi.Context, args LookupConnectorOutputArgs, opts ...pulumi.InvokeOption) LookupConnectorResultOutput
func (LookupConnectorResultOutput) Capacity ¶ added in v0.12.0
func (o LookupConnectorResultOutput) Capacity() ConnectorCapacityPtrOutput
func (LookupConnectorResultOutput) ConnectorArn ¶ added in v0.12.0
func (o LookupConnectorResultOutput) ConnectorArn() pulumi.StringPtrOutput
Amazon Resource Name for the created Connector.
func (LookupConnectorResultOutput) ElementType ¶ added in v0.12.0
func (LookupConnectorResultOutput) ElementType() reflect.Type
func (LookupConnectorResultOutput) ToLookupConnectorResultOutput ¶ added in v0.12.0
func (o LookupConnectorResultOutput) ToLookupConnectorResultOutput() LookupConnectorResultOutput
func (LookupConnectorResultOutput) ToLookupConnectorResultOutputWithContext ¶ added in v0.12.0
func (o LookupConnectorResultOutput) ToLookupConnectorResultOutputWithContext(ctx context.Context) LookupConnectorResultOutput