v1beta1

Jun 13, 2024

Changes in this version

type OutputFunctionInitParameters

+ APIKeySecretRef v1.SecretKeySelector

type OutputMSSQLInitParameters

+ PasswordSecretRef *v1.SecretKeySelector

type OutputSynapseInitParameters

+ PasswordSecretRef v1.SecretKeySelector

type OutputTableInitParameters

+ StorageAccountKeySecretRef v1.SecretKeySelector

type ReferenceInputMSSQLInitParameters

+ PasswordSecretRef v1.SecretKeySelector

May 22, 2024

Changes in this version

type FunctionJavascriptUda

+ func (tr *FunctionJavascriptUda) ConvertFrom(srcRaw conversion.Hub) error

+ func (tr *FunctionJavascriptUda) ConvertTo(dstRaw conversion.Hub) error

type Job

+ func (tr *Job) ConvertFrom(srcRaw conversion.Hub) error

+ func (tr *Job) ConvertTo(dstRaw conversion.Hub) error

type OutputBlob

+ func (tr *OutputBlob) ConvertFrom(srcRaw conversion.Hub) error

+ func (tr *OutputBlob) ConvertTo(dstRaw conversion.Hub) error

type OutputEventHub

+ func (tr *OutputEventHub) ConvertFrom(srcRaw conversion.Hub) error

+ func (tr *OutputEventHub) ConvertTo(dstRaw conversion.Hub) error

type OutputServiceBusQueue

+ func (tr *OutputServiceBusQueue) ConvertFrom(srcRaw conversion.Hub) error

+ func (tr *OutputServiceBusQueue) ConvertTo(dstRaw conversion.Hub) error

type OutputServiceBusTopic

+ func (tr *OutputServiceBusTopic) ConvertFrom(srcRaw conversion.Hub) error

+ func (tr *OutputServiceBusTopic) ConvertTo(dstRaw conversion.Hub) error

type ReferenceInputBlob

+ func (tr *ReferenceInputBlob) ConvertFrom(srcRaw conversion.Hub) error

+ func (tr *ReferenceInputBlob) ConvertTo(dstRaw conversion.Hub) error

type StreamInputBlob

+ func (tr *StreamInputBlob) ConvertFrom(srcRaw conversion.Hub) error

+ func (tr *StreamInputBlob) ConvertTo(dstRaw conversion.Hub) error

type StreamInputEventHub

+ func (tr *StreamInputEventHub) ConvertFrom(srcRaw conversion.Hub) error

+ func (tr *StreamInputEventHub) ConvertTo(dstRaw conversion.Hub) error

type StreamInputIOTHub

+ func (tr *StreamInputIOTHub) ConvertFrom(srcRaw conversion.Hub) error

+ func (tr *StreamInputIOTHub) ConvertTo(dstRaw conversion.Hub) error

Mar 21, 2024

Changes in this version

type IdentityInitParameters

+ IdentityIds []*string

type IdentityObservation

+ IdentityIds []*string

type IdentityParameters

+ IdentityIds []*string

type JobInitParameters

+ SkuName *string

type JobObservation

+ SkuName *string

type JobParameters

+ SkuName *string

type OutputBlobInitParameters

+ BlobWriteMode *string

type OutputBlobObservation

+ BlobWriteMode *string

type OutputBlobParameters

+ BlobWriteMode *string

Feb 22, 2024

Changes in this version

type Cluster

+ func (tr *Cluster) Hub()

type FunctionJavascriptUda

+ func (tr *FunctionJavascriptUda) Hub()

type Job

+ func (tr *Job) Hub()

type ManagedPrivateEndpoint

+ func (tr *ManagedPrivateEndpoint) Hub()

type OutputBlob

+ func (tr *OutputBlob) Hub()

type OutputEventHub

+ func (tr *OutputEventHub) Hub()

type OutputFunction

+ func (tr *OutputFunction) Hub()

type OutputMSSQL

+ func (tr *OutputMSSQL) Hub()

type OutputPowerBI

+ func (tr *OutputPowerBI) Hub()

type OutputServiceBusQueue

+ func (tr *OutputServiceBusQueue) Hub()

type OutputServiceBusTopic

+ func (tr *OutputServiceBusTopic) Hub()

type OutputSynapse

+ func (tr *OutputSynapse) Hub()

type OutputTable

+ func (tr *OutputTable) Hub()

type ReferenceInputBlob

+ func (tr *ReferenceInputBlob) Hub()

type ReferenceInputMSSQL

+ func (tr *ReferenceInputMSSQL) Hub()

type StreamInputBlob

+ func (tr *StreamInputBlob) Hub()

type StreamInputEventHub

+ func (tr *StreamInputEventHub) Hub()

type StreamInputIOTHub

+ func (tr *StreamInputIOTHub) Hub()

Dec 28, 2023

Changes in this version

type Cluster

+ func (tr *Cluster) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type FunctionJavascriptUda

+ func (tr *FunctionJavascriptUda) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type FunctionJavascriptUdaInitParameters

+ StreamAnalyticsJobID *string

+ StreamAnalyticsJobIDRef *v1.Reference

+ StreamAnalyticsJobIDSelector *v1.Selector

type Job

+ func (tr *Job) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type ManagedPrivateEndpoint

+ func (tr *ManagedPrivateEndpoint) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type ManagedPrivateEndpointInitParameters

+ TargetResourceID *string

+ TargetResourceIDRef *v1.Reference

+ TargetResourceIDSelector *v1.Selector

type OutputBlob

+ func (tr *OutputBlob) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type OutputBlobInitParameters

+ StorageAccountName *string

+ StorageAccountNameRef *v1.Reference

+ StorageAccountNameSelector *v1.Selector

+ StorageContainerName *string

+ StorageContainerNameRef *v1.Reference

+ StorageContainerNameSelector *v1.Selector

+ StreamAnalyticsJobName *string

+ StreamAnalyticsJobNameRef *v1.Reference

+ StreamAnalyticsJobNameSelector *v1.Selector

type OutputEventHub

+ func (tr *OutputEventHub) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type OutputEventHubInitParameters

+ EventHubName *string

+ EventHubNameRef *v1.Reference

+ EventHubNameSelector *v1.Selector

+ ServiceBusNamespace *string

+ ServiceBusNamespaceRef *v1.Reference

+ ServiceBusNamespaceSelector *v1.Selector

type OutputFunction

+ func (tr *OutputFunction) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type OutputFunctionInitParameters

+ FunctionApp *string

+ FunctionAppRef *v1.Reference

+ FunctionAppSelector *v1.Selector

+ StreamAnalyticsJobName *string

+ StreamAnalyticsJobNameRef *v1.Reference

+ StreamAnalyticsJobNameSelector *v1.Selector

type OutputMSSQL

+ func (tr *OutputMSSQL) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type OutputMSSQLInitParameters

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ Server *string

+ ServerRef *v1.Reference

+ ServerSelector *v1.Selector

+ StreamAnalyticsJobName *string

+ StreamAnalyticsJobNameRef *v1.Reference

+ StreamAnalyticsJobNameSelector *v1.Selector

+ Table *string

+ TableRef *v1.Reference

+ TableSelector *v1.Selector

type OutputPowerBI

+ func (tr *OutputPowerBI) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type OutputPowerBIInitParameters

+ StreamAnalyticsJobID *string

+ StreamAnalyticsJobIDRef *v1.Reference

+ StreamAnalyticsJobIDSelector *v1.Selector

type OutputServiceBusQueue

+ func (tr *OutputServiceBusQueue) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type OutputServiceBusQueueInitParameters

+ QueueName *string

+ QueueNameRef *v1.Reference

+ QueueNameSelector *v1.Selector

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ ServiceBusNamespace *string

+ ServiceBusNamespaceRef *v1.Reference

+ ServiceBusNamespaceSelector *v1.Selector

+ StreamAnalyticsJobName *string

+ StreamAnalyticsJobNameRef *v1.Reference

+ StreamAnalyticsJobNameSelector *v1.Selector

type OutputServiceBusTopic

+ func (tr *OutputServiceBusTopic) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type OutputServiceBusTopicInitParameters

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ ServiceBusNamespace *string

+ ServiceBusNamespaceRef *v1.Reference

+ ServiceBusNamespaceSelector *v1.Selector

+ StreamAnalyticsJobName *string

+ StreamAnalyticsJobNameRef *v1.Reference

+ StreamAnalyticsJobNameSelector *v1.Selector

+ TopicName *string

+ TopicNameRef *v1.Reference

+ TopicNameSelector *v1.Selector

type OutputSynapse

+ func (tr *OutputSynapse) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type OutputSynapseInitParameters

+ User *string

+ UserRef *v1.Reference

+ UserSelector *v1.Selector

type OutputTable

+ func (tr *OutputTable) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type OutputTableInitParameters

+ StorageAccountName *string

+ StorageAccountNameRef *v1.Reference

+ StorageAccountNameSelector *v1.Selector

+ Table *string

+ TableRef *v1.Reference

+ TableSelector *v1.Selector

type ReferenceInputBlob

+ func (tr *ReferenceInputBlob) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type ReferenceInputBlobInitParameters

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ StorageAccountName *string

+ StorageAccountNameRef *v1.Reference

+ StorageAccountNameSelector *v1.Selector

+ StorageContainerName *string

+ StorageContainerNameRef *v1.Reference

+ StorageContainerNameSelector *v1.Selector

+ StreamAnalyticsJobName *string

+ StreamAnalyticsJobNameRef *v1.Reference

+ StreamAnalyticsJobNameSelector *v1.Selector

type ReferenceInputMSSQL

+ func (tr *ReferenceInputMSSQL) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type ReferenceInputMSSQLInitParameters

+ Database *string

+ DatabaseRef *v1.Reference

+ DatabaseSelector *v1.Selector

+ Server *string

+ ServerRef *v1.Reference

+ ServerSelector *v1.Selector

type StreamInputBlob

+ func (tr *StreamInputBlob) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type StreamInputBlobInitParameters

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ StorageAccountName *string

+ StorageAccountNameRef *v1.Reference

+ StorageAccountNameSelector *v1.Selector

+ StorageContainerName *string

+ StorageContainerNameRef *v1.Reference

+ StorageContainerNameSelector *v1.Selector

+ StreamAnalyticsJobName *string

+ StreamAnalyticsJobNameRef *v1.Reference

+ StreamAnalyticsJobNameSelector *v1.Selector

type StreamInputEventHub

+ func (tr *StreamInputEventHub) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type StreamInputEventHubInitParameters

+ EventHubConsumerGroupName *string

+ EventHubConsumerGroupNameRef *v1.Reference

+ EventHubConsumerGroupNameSelector *v1.Selector

+ EventHubName *string

+ EventHubNameRef *v1.Reference

+ EventHubNameSelector *v1.Selector

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ ServiceBusNamespace *string

+ ServiceBusNamespaceRef *v1.Reference

+ ServiceBusNamespaceSelector *v1.Selector

+ StreamAnalyticsJobName *string

+ StreamAnalyticsJobNameRef *v1.Reference

+ StreamAnalyticsJobNameSelector *v1.Selector

type StreamInputIOTHub

+ func (tr *StreamInputIOTHub) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type StreamInputIOTHubInitParameters

+ EventHubConsumerGroupName *string

+ EventHubConsumerGroupNameRef *v1.Reference

+ EventHubConsumerGroupNameSelector *v1.Selector

+ IOTHubNamespace *string

+ IOTHubNamespaceRef *v1.Reference

+ IOTHubNamespaceSelector *v1.Selector

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ StreamAnalyticsJobName *string

+ StreamAnalyticsJobNameRef *v1.Reference

+ StreamAnalyticsJobNameSelector *v1.Selector

Aug 1, 2023

Changes in this version

type Cluster

+ func (mg *Cluster) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *Cluster) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *Cluster) GetInitParameters() (map[string]any, error)

+ type ClusterInitParameters struct

+ Location *string

+ StreamingCapacity *float64

+ Tags map[string]*string

+ func (in *ClusterInitParameters) DeepCopy() *ClusterInitParameters

+ func (in *ClusterInitParameters) DeepCopyInto(out *ClusterInitParameters)

type ClusterSpec

+ InitProvider ClusterInitParameters

type FunctionJavascriptUda

+ func (mg *FunctionJavascriptUda) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *FunctionJavascriptUda) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *FunctionJavascriptUda) GetInitParameters() (map[string]any, error)

+ type FunctionJavascriptUdaInitParameters struct

+ Input []InputInitParameters

+ Output []OutputInitParameters

+ Script *string

+ func (in *FunctionJavascriptUdaInitParameters) DeepCopy() *FunctionJavascriptUdaInitParameters

+ func (in *FunctionJavascriptUdaInitParameters) DeepCopyInto(out *FunctionJavascriptUdaInitParameters)

type FunctionJavascriptUdaSpec

+ InitProvider FunctionJavascriptUdaInitParameters

+ type IdentityInitParameters struct

+ Type *string

+ func (in *IdentityInitParameters) DeepCopy() *IdentityInitParameters

+ func (in *IdentityInitParameters) DeepCopyInto(out *IdentityInitParameters)

+ type InputInitParameters struct

+ ConfigurationParameter *bool

+ Type *string

+ func (in *InputInitParameters) DeepCopy() *InputInitParameters

+ func (in *InputInitParameters) DeepCopyInto(out *InputInitParameters)

type Job

+ func (mg *Job) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *Job) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *Job) GetInitParameters() (map[string]any, error)

+ type JobInitParameters struct

+ CompatibilityLevel *string

+ ContentStoragePolicy *string

+ DataLocale *string

+ EventsLateArrivalMaxDelayInSeconds *float64

+ EventsOutOfOrderMaxDelayInSeconds *float64

+ EventsOutOfOrderPolicy *string

+ Identity []IdentityInitParameters

+ JobStorageAccount []JobStorageAccountInitParameters

+ Location *string

+ OutputErrorPolicy *string

+ StreamAnalyticsClusterID *string

+ StreamingUnits *float64

+ Tags map[string]*string

+ TransformationQuery *string

+ Type *string

+ func (in *JobInitParameters) DeepCopy() *JobInitParameters

+ func (in *JobInitParameters) DeepCopyInto(out *JobInitParameters)

type JobSpec

+ InitProvider JobInitParameters

+ type JobStorageAccountInitParameters struct

+ AccountName *string

+ AuthenticationMode *string

+ func (in *JobStorageAccountInitParameters) DeepCopy() *JobStorageAccountInitParameters

+ func (in *JobStorageAccountInitParameters) DeepCopyInto(out *JobStorageAccountInitParameters)

type ManagedPrivateEndpoint

+ func (mg *ManagedPrivateEndpoint) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *ManagedPrivateEndpoint) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *ManagedPrivateEndpoint) GetInitParameters() (map[string]any, error)

+ type ManagedPrivateEndpointInitParameters struct

+ SubresourceName *string

+ func (in *ManagedPrivateEndpointInitParameters) DeepCopy() *ManagedPrivateEndpointInitParameters

+ func (in *ManagedPrivateEndpointInitParameters) DeepCopyInto(out *ManagedPrivateEndpointInitParameters)

type ManagedPrivateEndpointSpec

+ InitProvider ManagedPrivateEndpointInitParameters

type OutputBlob

+ func (mg *OutputBlob) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *OutputBlob) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *OutputBlob) GetInitParameters() (map[string]any, error)

+ type OutputBlobInitParameters struct

+ AuthenticationMode *string

+ BatchMaxWaitTime *string

+ BatchMinRows *float64

+ DateFormat *string

+ PathPattern *string

+ Serialization []SerializationInitParameters

+ TimeFormat *string

+ func (in *OutputBlobInitParameters) DeepCopy() *OutputBlobInitParameters

+ func (in *OutputBlobInitParameters) DeepCopyInto(out *OutputBlobInitParameters)

type OutputBlobSpec

+ InitProvider OutputBlobInitParameters

type OutputEventHub

+ func (mg *OutputEventHub) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *OutputEventHub) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *OutputEventHub) GetInitParameters() (map[string]any, error)

+ type OutputEventHubInitParameters struct

+ AuthenticationMode *string

+ PartitionKey *string

+ PropertyColumns []*string

+ Serialization []OutputEventHubSerializationInitParameters

+ SharedAccessPolicyName *string

+ func (in *OutputEventHubInitParameters) DeepCopy() *OutputEventHubInitParameters

+ func (in *OutputEventHubInitParameters) DeepCopyInto(out *OutputEventHubInitParameters)

+ type OutputEventHubSerializationInitParameters struct

+ Encoding *string

+ FieldDelimiter *string

+ Format *string

+ Type *string

+ func (in *OutputEventHubSerializationInitParameters) DeepCopy() *OutputEventHubSerializationInitParameters

+ func (in *OutputEventHubSerializationInitParameters) DeepCopyInto(out *OutputEventHubSerializationInitParameters)

type OutputEventHubSpec

+ InitProvider OutputEventHubInitParameters

type OutputFunction

+ func (mg *OutputFunction) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *OutputFunction) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *OutputFunction) GetInitParameters() (map[string]any, error)

+ type OutputFunctionInitParameters struct

+ BatchMaxCount *float64

+ BatchMaxInBytes *float64

+ FunctionName *string

+ func (in *OutputFunctionInitParameters) DeepCopy() *OutputFunctionInitParameters

+ func (in *OutputFunctionInitParameters) DeepCopyInto(out *OutputFunctionInitParameters)

type OutputFunctionSpec

+ InitProvider OutputFunctionInitParameters

+ type OutputInitParameters struct

+ Type *string

+ func (in *OutputInitParameters) DeepCopy() *OutputInitParameters

+ func (in *OutputInitParameters) DeepCopyInto(out *OutputInitParameters)

type OutputMSSQL

+ func (mg *OutputMSSQL) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *OutputMSSQL) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *OutputMSSQL) GetInitParameters() (map[string]any, error)

+ type OutputMSSQLInitParameters struct

+ AuthenticationMode *string

+ Database *string

+ MaxBatchCount *float64

+ MaxWriterCount *float64

+ Name *string

+ User *string

+ func (in *OutputMSSQLInitParameters) DeepCopy() *OutputMSSQLInitParameters

+ func (in *OutputMSSQLInitParameters) DeepCopyInto(out *OutputMSSQLInitParameters)

type OutputMSSQLSpec

+ InitProvider OutputMSSQLInitParameters

type OutputPowerBI

+ func (mg *OutputPowerBI) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *OutputPowerBI) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *OutputPowerBI) GetInitParameters() (map[string]any, error)

+ type OutputPowerBIInitParameters struct

+ DataSet *string

+ GroupID *string

+ GroupName *string

+ Table *string

+ TokenUserDisplayName *string

+ TokenUserPrincipalName *string

+ func (in *OutputPowerBIInitParameters) DeepCopy() *OutputPowerBIInitParameters

+ func (in *OutputPowerBIInitParameters) DeepCopyInto(out *OutputPowerBIInitParameters)

type OutputPowerBISpec

+ InitProvider OutputPowerBIInitParameters

type OutputServiceBusQueue

+ func (mg *OutputServiceBusQueue) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *OutputServiceBusQueue) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *OutputServiceBusQueue) GetInitParameters() (map[string]any, error)

+ type OutputServiceBusQueueInitParameters struct

+ AuthenticationMode *string

+ Name *string

+ PropertyColumns []*string

+ Serialization []OutputServiceBusQueueSerializationInitParameters

+ SharedAccessPolicyName *string

+ SystemPropertyColumns map[string]*string

+ func (in *OutputServiceBusQueueInitParameters) DeepCopy() *OutputServiceBusQueueInitParameters

+ func (in *OutputServiceBusQueueInitParameters) DeepCopyInto(out *OutputServiceBusQueueInitParameters)

+ type OutputServiceBusQueueSerializationInitParameters struct

+ Encoding *string

+ FieldDelimiter *string

+ Format *string

+ Type *string

+ func (in *OutputServiceBusQueueSerializationInitParameters) DeepCopy() *OutputServiceBusQueueSerializationInitParameters

+ func (in *OutputServiceBusQueueSerializationInitParameters) DeepCopyInto(out *OutputServiceBusQueueSerializationInitParameters)

type OutputServiceBusQueueSpec

+ InitProvider OutputServiceBusQueueInitParameters

type OutputServiceBusTopic

+ func (mg *OutputServiceBusTopic) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *OutputServiceBusTopic) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *OutputServiceBusTopic) GetInitParameters() (map[string]any, error)

+ type OutputServiceBusTopicInitParameters struct

+ AuthenticationMode *string

+ Name *string

+ PropertyColumns []*string

+ Serialization []OutputServiceBusTopicSerializationInitParameters

+ SharedAccessPolicyName *string

+ SystemPropertyColumns map[string]*string

+ func (in *OutputServiceBusTopicInitParameters) DeepCopy() *OutputServiceBusTopicInitParameters

+ func (in *OutputServiceBusTopicInitParameters) DeepCopyInto(out *OutputServiceBusTopicInitParameters)

+ type OutputServiceBusTopicSerializationInitParameters struct

+ Encoding *string

+ FieldDelimiter *string

+ Format *string

+ Type *string

+ func (in *OutputServiceBusTopicSerializationInitParameters) DeepCopy() *OutputServiceBusTopicSerializationInitParameters

+ func (in *OutputServiceBusTopicSerializationInitParameters) DeepCopyInto(out *OutputServiceBusTopicSerializationInitParameters)

type OutputServiceBusTopicSpec

+ InitProvider OutputServiceBusTopicInitParameters

type OutputSynapse

+ func (mg *OutputSynapse) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *OutputSynapse) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *OutputSynapse) GetInitParameters() (map[string]any, error)

+ type OutputSynapseInitParameters struct

+ Database *string

+ Server *string

+ Table *string

+ func (in *OutputSynapseInitParameters) DeepCopy() *OutputSynapseInitParameters

+ func (in *OutputSynapseInitParameters) DeepCopyInto(out *OutputSynapseInitParameters)

type OutputSynapseSpec

+ InitProvider OutputSynapseInitParameters

type OutputTable

+ func (mg *OutputTable) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *OutputTable) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *OutputTable) GetInitParameters() (map[string]any, error)

+ type OutputTableInitParameters struct

+ BatchSize *float64

+ ColumnsToRemove []*string

+ PartitionKey *string

+ RowKey *string

+ func (in *OutputTableInitParameters) DeepCopy() *OutputTableInitParameters

+ func (in *OutputTableInitParameters) DeepCopyInto(out *OutputTableInitParameters)

type OutputTableSpec

+ InitProvider OutputTableInitParameters

type ReferenceInputBlob

+ func (mg *ReferenceInputBlob) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *ReferenceInputBlob) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *ReferenceInputBlob) GetInitParameters() (map[string]any, error)

+ type ReferenceInputBlobInitParameters struct

+ AuthenticationMode *string

+ DateFormat *string

+ Name *string

+ PathPattern *string

+ Serialization []ReferenceInputBlobSerializationInitParameters

+ TimeFormat *string

+ func (in *ReferenceInputBlobInitParameters) DeepCopy() *ReferenceInputBlobInitParameters

+ func (in *ReferenceInputBlobInitParameters) DeepCopyInto(out *ReferenceInputBlobInitParameters)

+ type ReferenceInputBlobSerializationInitParameters struct

+ Encoding *string

+ FieldDelimiter *string

+ Type *string

+ func (in *ReferenceInputBlobSerializationInitParameters) DeepCopy() *ReferenceInputBlobSerializationInitParameters

+ func (in *ReferenceInputBlobSerializationInitParameters) DeepCopyInto(out *ReferenceInputBlobSerializationInitParameters)

type ReferenceInputBlobSpec

+ InitProvider ReferenceInputBlobInitParameters

type ReferenceInputMSSQL

+ func (mg *ReferenceInputMSSQL) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *ReferenceInputMSSQL) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *ReferenceInputMSSQL) GetInitParameters() (map[string]any, error)

+ type ReferenceInputMSSQLInitParameters struct

+ DeltaSnapshotQuery *string

+ FullSnapshotQuery *string

+ RefreshIntervalDuration *string

+ RefreshType *string

+ Table *string

+ Username *string

+ func (in *ReferenceInputMSSQLInitParameters) DeepCopy() *ReferenceInputMSSQLInitParameters

+ func (in *ReferenceInputMSSQLInitParameters) DeepCopyInto(out *ReferenceInputMSSQLInitParameters)

type ReferenceInputMSSQLSpec

+ InitProvider ReferenceInputMSSQLInitParameters

+ type SerializationInitParameters struct

+ Encoding *string

+ FieldDelimiter *string

+ Format *string

+ Type *string

+ func (in *SerializationInitParameters) DeepCopy() *SerializationInitParameters

+ func (in *SerializationInitParameters) DeepCopyInto(out *SerializationInitParameters)

type StreamInputBlob

+ func (mg *StreamInputBlob) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *StreamInputBlob) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *StreamInputBlob) GetInitParameters() (map[string]any, error)

+ type StreamInputBlobInitParameters struct

+ DateFormat *string

+ Name *string

+ PathPattern *string

+ Serialization []StreamInputBlobSerializationInitParameters

+ TimeFormat *string

+ func (in *StreamInputBlobInitParameters) DeepCopy() *StreamInputBlobInitParameters

+ func (in *StreamInputBlobInitParameters) DeepCopyInto(out *StreamInputBlobInitParameters)

+ type StreamInputBlobSerializationInitParameters struct

+ Encoding *string

+ FieldDelimiter *string

+ Type *string

+ func (in *StreamInputBlobSerializationInitParameters) DeepCopy() *StreamInputBlobSerializationInitParameters

+ func (in *StreamInputBlobSerializationInitParameters) DeepCopyInto(out *StreamInputBlobSerializationInitParameters)

type StreamInputBlobSpec

+ InitProvider StreamInputBlobInitParameters

type StreamInputEventHub

+ func (mg *StreamInputEventHub) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *StreamInputEventHub) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *StreamInputEventHub) GetInitParameters() (map[string]any, error)

+ type StreamInputEventHubInitParameters struct

+ AuthenticationMode *string

+ Name *string

+ PartitionKey *string

+ Serialization []StreamInputEventHubSerializationInitParameters

+ SharedAccessPolicyName *string

+ func (in *StreamInputEventHubInitParameters) DeepCopy() *StreamInputEventHubInitParameters

+ func (in *StreamInputEventHubInitParameters) DeepCopyInto(out *StreamInputEventHubInitParameters)

+ type StreamInputEventHubSerializationInitParameters struct

+ Encoding *string

+ FieldDelimiter *string

+ Type *string

+ func (in *StreamInputEventHubSerializationInitParameters) DeepCopy() *StreamInputEventHubSerializationInitParameters

+ func (in *StreamInputEventHubSerializationInitParameters) DeepCopyInto(out *StreamInputEventHubSerializationInitParameters)

type StreamInputEventHubSpec

+ InitProvider StreamInputEventHubInitParameters

type StreamInputIOTHub

+ func (mg *StreamInputIOTHub) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *StreamInputIOTHub) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *StreamInputIOTHub) GetInitParameters() (map[string]any, error)

+ type StreamInputIOTHubInitParameters struct

+ Endpoint *string

+ Name *string

+ Serialization []StreamInputIOTHubSerializationInitParameters

+ SharedAccessPolicyName *string

+ func (in *StreamInputIOTHubInitParameters) DeepCopy() *StreamInputIOTHubInitParameters

+ func (in *StreamInputIOTHubInitParameters) DeepCopyInto(out *StreamInputIOTHubInitParameters)

+ type StreamInputIOTHubSerializationInitParameters struct

+ Encoding *string

+ FieldDelimiter *string

+ Type *string

+ func (in *StreamInputIOTHubSerializationInitParameters) DeepCopy() *StreamInputIOTHubSerializationInitParameters

+ func (in *StreamInputIOTHubSerializationInitParameters) DeepCopyInto(out *StreamInputIOTHubSerializationInitParameters)

type StreamInputIOTHubSpec

+ InitProvider StreamInputIOTHubInitParameters

Jun 9, 2023

Changes in this version

+ var OutputPowerBI_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: OutputPowerBI_Kind}.String()

+ var OutputPowerBI_GroupVersionKind = CRDGroupVersion.WithKind(OutputPowerBI_Kind)

+ var OutputPowerBI_Kind = "OutputPowerBI"

+ var OutputPowerBI_KindAPIVersion = OutputPowerBI_Kind + "." + CRDGroupVersion.String()

+ var OutputTable_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: OutputTable_Kind}.String()

+ var OutputTable_GroupVersionKind = CRDGroupVersion.WithKind(OutputTable_Kind)

+ var OutputTable_Kind = "OutputTable"

+ var OutputTable_KindAPIVersion = OutputTable_Kind + "." + CRDGroupVersion.String()

+ type OutputPowerBI struct

+ Spec OutputPowerBISpec

+ Status OutputPowerBIStatus

+ func (in *OutputPowerBI) DeepCopy() *OutputPowerBI

+ func (in *OutputPowerBI) DeepCopyInto(out *OutputPowerBI)

+ func (in *OutputPowerBI) DeepCopyObject() runtime.Object

+ func (mg *OutputPowerBI) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *OutputPowerBI) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *OutputPowerBI) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *OutputPowerBI) GetProviderConfigReference() *xpv1.Reference

+ func (mg *OutputPowerBI) GetProviderReference() *xpv1.Reference

+ func (mg *OutputPowerBI) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *OutputPowerBI) GetTerraformResourceType() string

+ func (mg *OutputPowerBI) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *OutputPowerBI) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *OutputPowerBI) SetConditions(c ...xpv1.Condition)

+ func (mg *OutputPowerBI) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *OutputPowerBI) SetManagementPolicy(r xpv1.ManagementPolicy)

+ func (mg *OutputPowerBI) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *OutputPowerBI) SetProviderReference(r *xpv1.Reference)

+ func (mg *OutputPowerBI) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *OutputPowerBI) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *OutputPowerBI) GetConnectionDetailsMapping() map[string]string

+ func (tr *OutputPowerBI) GetID() string

+ func (tr *OutputPowerBI) GetObservation() (map[string]any, error)

+ func (tr *OutputPowerBI) GetParameters() (map[string]any, error)

+ func (tr *OutputPowerBI) GetTerraformSchemaVersion() int

+ func (tr *OutputPowerBI) LateInitialize(attrs []byte) (bool, error)

+ func (tr *OutputPowerBI) SetObservation(obs map[string]any) error

+ func (tr *OutputPowerBI) SetParameters(params map[string]any) error

+ type OutputPowerBIList struct

+ Items []OutputPowerBI

+ func (in *OutputPowerBIList) DeepCopy() *OutputPowerBIList

+ func (in *OutputPowerBIList) DeepCopyInto(out *OutputPowerBIList)

+ func (in *OutputPowerBIList) DeepCopyObject() runtime.Object

+ func (l *OutputPowerBIList) GetItems() []resource.Managed

+ type OutputPowerBIObservation struct

+ DataSet *string

+ GroupID *string

+ GroupName *string

+ ID *string

+ StreamAnalyticsJobID *string

+ Table *string

+ TokenUserDisplayName *string

+ TokenUserPrincipalName *string

+ func (in *OutputPowerBIObservation) DeepCopy() *OutputPowerBIObservation

+ func (in *OutputPowerBIObservation) DeepCopyInto(out *OutputPowerBIObservation)

+ type OutputPowerBIParameters struct

+ DataSet *string

+ GroupID *string

+ GroupName *string

+ StreamAnalyticsJobID *string

+ StreamAnalyticsJobIDRef *v1.Reference

+ StreamAnalyticsJobIDSelector *v1.Selector

+ Table *string

+ TokenUserDisplayName *string

+ TokenUserPrincipalName *string

+ func (in *OutputPowerBIParameters) DeepCopy() *OutputPowerBIParameters

+ func (in *OutputPowerBIParameters) DeepCopyInto(out *OutputPowerBIParameters)

+ type OutputPowerBISpec struct

+ ForProvider OutputPowerBIParameters

+ func (in *OutputPowerBISpec) DeepCopy() *OutputPowerBISpec

+ func (in *OutputPowerBISpec) DeepCopyInto(out *OutputPowerBISpec)

+ type OutputPowerBIStatus struct

+ AtProvider OutputPowerBIObservation

+ func (in *OutputPowerBIStatus) DeepCopy() *OutputPowerBIStatus

+ func (in *OutputPowerBIStatus) DeepCopyInto(out *OutputPowerBIStatus)

+ type OutputTable struct

+ Spec OutputTableSpec

+ Status OutputTableStatus

+ func (in *OutputTable) DeepCopy() *OutputTable

+ func (in *OutputTable) DeepCopyInto(out *OutputTable)

+ func (in *OutputTable) DeepCopyObject() runtime.Object

+ func (mg *OutputTable) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *OutputTable) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *OutputTable) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *OutputTable) GetProviderConfigReference() *xpv1.Reference

+ func (mg *OutputTable) GetProviderReference() *xpv1.Reference

+ func (mg *OutputTable) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *OutputTable) GetTerraformResourceType() string

+ func (mg *OutputTable) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *OutputTable) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *OutputTable) SetConditions(c ...xpv1.Condition)

+ func (mg *OutputTable) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *OutputTable) SetManagementPolicy(r xpv1.ManagementPolicy)

+ func (mg *OutputTable) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *OutputTable) SetProviderReference(r *xpv1.Reference)

+ func (mg *OutputTable) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *OutputTable) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *OutputTable) GetConnectionDetailsMapping() map[string]string

+ func (tr *OutputTable) GetID() string

+ func (tr *OutputTable) GetObservation() (map[string]any, error)

+ func (tr *OutputTable) GetParameters() (map[string]any, error)

+ func (tr *OutputTable) GetTerraformSchemaVersion() int

+ func (tr *OutputTable) LateInitialize(attrs []byte) (bool, error)

+ func (tr *OutputTable) SetObservation(obs map[string]any) error

+ func (tr *OutputTable) SetParameters(params map[string]any) error

+ type OutputTableList struct

+ Items []OutputTable

+ func (in *OutputTableList) DeepCopy() *OutputTableList

+ func (in *OutputTableList) DeepCopyInto(out *OutputTableList)

+ func (in *OutputTableList) DeepCopyObject() runtime.Object

+ func (l *OutputTableList) GetItems() []resource.Managed

+ type OutputTableObservation struct

+ BatchSize *float64

+ ColumnsToRemove []*string

+ ID *string

+ PartitionKey *string

+ ResourceGroupName *string

+ RowKey *string

+ StorageAccountName *string

+ StreamAnalyticsJobName *string

+ Table *string

+ func (in *OutputTableObservation) DeepCopy() *OutputTableObservation

+ func (in *OutputTableObservation) DeepCopyInto(out *OutputTableObservation)

+ type OutputTableParameters struct

+ BatchSize *float64

+ ColumnsToRemove []*string

+ PartitionKey *string

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ RowKey *string

+ StorageAccountKeySecretRef v1.SecretKeySelector

+ StorageAccountName *string

+ StorageAccountNameRef *v1.Reference

+ StorageAccountNameSelector *v1.Selector

+ StreamAnalyticsJobName *string

+ Table *string

+ TableRef *v1.Reference

+ TableSelector *v1.Selector

+ func (in *OutputTableParameters) DeepCopy() *OutputTableParameters

+ func (in *OutputTableParameters) DeepCopyInto(out *OutputTableParameters)

+ type OutputTableSpec struct

+ ForProvider OutputTableParameters

+ func (in *OutputTableSpec) DeepCopy() *OutputTableSpec

+ func (in *OutputTableSpec) DeepCopyInto(out *OutputTableSpec)

+ type OutputTableStatus struct

+ AtProvider OutputTableObservation

+ func (in *OutputTableStatus) DeepCopy() *OutputTableStatus

+ func (in *OutputTableStatus) DeepCopyInto(out *OutputTableStatus)

Apr 26, 2023

Changes in this version

type Cluster

+ func (mg *Cluster) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *Cluster) SetManagementPolicy(r xpv1.ManagementPolicy)

type ClusterObservation

+ Location *string

+ ResourceGroupName *string

+ StreamingCapacity *float64

+ Tags map[string]*string

type FunctionJavascriptUda

+ func (mg *FunctionJavascriptUda) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *FunctionJavascriptUda) SetManagementPolicy(r xpv1.ManagementPolicy)

type FunctionJavascriptUdaObservation

+ Input []InputObservation

+ Output []OutputObservation

+ Script *string

+ StreamAnalyticsJobID *string

type IdentityObservation

+ Type *string

type InputObservation

+ ConfigurationParameter *bool

+ Type *string

type Job

+ func (mg *Job) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *Job) SetManagementPolicy(r xpv1.ManagementPolicy)

type JobObservation

+ CompatibilityLevel *string

+ ContentStoragePolicy *string

+ DataLocale *string

+ EventsLateArrivalMaxDelayInSeconds *float64

+ EventsOutOfOrderMaxDelayInSeconds *float64

+ EventsOutOfOrderPolicy *string

+ JobStorageAccount []JobStorageAccountObservation

+ Location *string

+ OutputErrorPolicy *string

+ ResourceGroupName *string

+ StreamAnalyticsClusterID *string

+ StreamingUnits *float64

+ Tags map[string]*string

+ TransformationQuery *string

+ Type *string

type JobStorageAccountObservation

+ AccountName *string

+ AuthenticationMode *string

type ManagedPrivateEndpoint

+ func (mg *ManagedPrivateEndpoint) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *ManagedPrivateEndpoint) SetManagementPolicy(r xpv1.ManagementPolicy)

type ManagedPrivateEndpointObservation

+ ResourceGroupName *string

+ StreamAnalyticsClusterName *string

+ SubresourceName *string

+ TargetResourceID *string

type OutputBlob

+ func (mg *OutputBlob) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *OutputBlob) SetManagementPolicy(r xpv1.ManagementPolicy)

type OutputBlobObservation

+ AuthenticationMode *string

+ BatchMaxWaitTime *string

+ BatchMinRows *float64

+ DateFormat *string

+ PathPattern *string

+ ResourceGroupName *string

+ Serialization []SerializationObservation

+ StorageAccountName *string

+ StorageContainerName *string

+ StreamAnalyticsJobName *string

+ TimeFormat *string

type OutputEventHub

+ func (mg *OutputEventHub) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *OutputEventHub) SetManagementPolicy(r xpv1.ManagementPolicy)

type OutputEventHubObservation

+ AuthenticationMode *string

+ EventHubName *string

+ PartitionKey *string

+ PropertyColumns []*string

+ ResourceGroupName *string

+ Serialization []OutputEventHubSerializationObservation

+ ServiceBusNamespace *string

+ SharedAccessPolicyName *string

+ StreamAnalyticsJobName *string

type OutputEventHubSerializationObservation

+ Encoding *string

+ FieldDelimiter *string

+ Format *string

+ Type *string

type OutputFunction

+ func (mg *OutputFunction) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *OutputFunction) SetManagementPolicy(r xpv1.ManagementPolicy)

type OutputFunctionObservation

+ BatchMaxCount *float64

+ BatchMaxInBytes *float64

+ FunctionApp *string

+ FunctionName *string

+ ResourceGroupName *string

+ StreamAnalyticsJobName *string

type OutputMSSQL

+ func (mg *OutputMSSQL) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *OutputMSSQL) SetManagementPolicy(r xpv1.ManagementPolicy)

type OutputMSSQLObservation

+ AuthenticationMode *string

+ Database *string

+ MaxBatchCount *float64

+ MaxWriterCount *float64

+ Name *string

+ ResourceGroupName *string

+ Server *string

+ StreamAnalyticsJobName *string

+ Table *string

+ User *string

type OutputObservation

+ Type *string

type OutputServiceBusQueue

+ func (mg *OutputServiceBusQueue) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *OutputServiceBusQueue) SetManagementPolicy(r xpv1.ManagementPolicy)

type OutputServiceBusQueueObservation

+ AuthenticationMode *string

+ Name *string

+ PropertyColumns []*string

+ QueueName *string

+ ResourceGroupName *string

+ Serialization []OutputServiceBusQueueSerializationObservation

+ ServiceBusNamespace *string

+ SharedAccessPolicyName *string

+ StreamAnalyticsJobName *string

+ SystemPropertyColumns map[string]*string

type OutputServiceBusQueueSerializationObservation

+ Encoding *string

+ FieldDelimiter *string

+ Format *string

+ Type *string

type OutputServiceBusTopic

+ func (mg *OutputServiceBusTopic) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *OutputServiceBusTopic) SetManagementPolicy(r xpv1.ManagementPolicy)

type OutputServiceBusTopicObservation

+ AuthenticationMode *string

+ Name *string

+ PropertyColumns []*string

+ ResourceGroupName *string

+ Serialization []OutputServiceBusTopicSerializationObservation

+ ServiceBusNamespace *string

+ SharedAccessPolicyName *string

+ StreamAnalyticsJobName *string

+ SystemPropertyColumns map[string]*string

+ TopicName *string

type OutputServiceBusTopicSerializationObservation

+ Encoding *string

+ FieldDelimiter *string

+ Format *string

+ Type *string

type OutputSynapse

+ func (mg *OutputSynapse) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *OutputSynapse) SetManagementPolicy(r xpv1.ManagementPolicy)

type OutputSynapseObservation

+ Database *string

+ ResourceGroupName *string

+ Server *string

+ StreamAnalyticsJobName *string

+ Table *string

+ User *string

type ReferenceInputBlob

+ func (mg *ReferenceInputBlob) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *ReferenceInputBlob) SetManagementPolicy(r xpv1.ManagementPolicy)

type ReferenceInputBlobObservation

+ AuthenticationMode *string

+ DateFormat *string

+ Name *string

+ PathPattern *string

+ ResourceGroupName *string

+ Serialization []ReferenceInputBlobSerializationObservation

+ StorageAccountName *string

+ StorageContainerName *string

+ StreamAnalyticsJobName *string

+ TimeFormat *string

type ReferenceInputBlobSerializationObservation

+ Encoding *string

+ FieldDelimiter *string

+ Type *string

type ReferenceInputMSSQL

+ func (mg *ReferenceInputMSSQL) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *ReferenceInputMSSQL) SetManagementPolicy(r xpv1.ManagementPolicy)

type ReferenceInputMSSQLObservation

+ Database *string

+ DeltaSnapshotQuery *string

+ FullSnapshotQuery *string

+ RefreshIntervalDuration *string

+ RefreshType *string

+ ResourceGroupName *string

+ Server *string

+ StreamAnalyticsJobName *string

+ Table *string

+ Username *string

type SerializationObservation

+ Encoding *string

+ FieldDelimiter *string

+ Format *string

+ Type *string

type StreamInputBlob

+ func (mg *StreamInputBlob) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *StreamInputBlob) SetManagementPolicy(r xpv1.ManagementPolicy)

type StreamInputBlobObservation

+ DateFormat *string

+ Name *string

+ PathPattern *string

+ ResourceGroupName *string

+ Serialization []StreamInputBlobSerializationObservation

+ StorageAccountName *string

+ StorageContainerName *string

+ StreamAnalyticsJobName *string

+ TimeFormat *string

type StreamInputBlobSerializationObservation

+ Encoding *string

+ FieldDelimiter *string

+ Type *string

type StreamInputEventHub

+ func (mg *StreamInputEventHub) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *StreamInputEventHub) SetManagementPolicy(r xpv1.ManagementPolicy)

type StreamInputEventHubObservation

+ AuthenticationMode *string

+ EventHubConsumerGroupName *string

+ EventHubName *string

+ Name *string

+ PartitionKey *string

+ ResourceGroupName *string

+ Serialization []StreamInputEventHubSerializationObservation

+ ServiceBusNamespace *string

+ SharedAccessPolicyName *string

+ StreamAnalyticsJobName *string

type StreamInputEventHubSerializationObservation

+ Encoding *string

+ FieldDelimiter *string

+ Type *string

type StreamInputIOTHub

+ func (mg *StreamInputIOTHub) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *StreamInputIOTHub) SetManagementPolicy(r xpv1.ManagementPolicy)

type StreamInputIOTHubObservation

+ Endpoint *string

+ EventHubConsumerGroupName *string

+ IOTHubNamespace *string

+ Name *string

+ ResourceGroupName *string

+ Serialization []StreamInputIOTHubSerializationObservation

+ SharedAccessPolicyName *string

+ StreamAnalyticsJobName *string

type StreamInputIOTHubSerializationObservation

+ Encoding *string

+ FieldDelimiter *string

+ Type *string

Feb 20, 2023

Changes in this version

+ var OutputEventHub_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: OutputEventHub_Kind}.String()

+ var OutputEventHub_GroupVersionKind = CRDGroupVersion.WithKind(OutputEventHub_Kind)

+ var OutputEventHub_Kind = "OutputEventHub"

+ var OutputEventHub_KindAPIVersion = OutputEventHub_Kind + "." + CRDGroupVersion.String()

+ var ReferenceInputMSSQL_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: ReferenceInputMSSQL_Kind}.String()

+ var ReferenceInputMSSQL_GroupVersionKind = CRDGroupVersion.WithKind(ReferenceInputMSSQL_Kind)

+ var ReferenceInputMSSQL_Kind = "ReferenceInputMSSQL"

+ var ReferenceInputMSSQL_KindAPIVersion = ReferenceInputMSSQL_Kind + "." + CRDGroupVersion.String()

+ type OutputEventHub struct

+ Spec OutputEventHubSpec

+ Status OutputEventHubStatus

+ func (in *OutputEventHub) DeepCopy() *OutputEventHub

+ func (in *OutputEventHub) DeepCopyInto(out *OutputEventHub)

+ func (in *OutputEventHub) DeepCopyObject() runtime.Object

+ func (mg *OutputEventHub) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *OutputEventHub) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *OutputEventHub) GetProviderConfigReference() *xpv1.Reference

+ func (mg *OutputEventHub) GetProviderReference() *xpv1.Reference

+ func (mg *OutputEventHub) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *OutputEventHub) GetTerraformResourceType() string

+ func (mg *OutputEventHub) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *OutputEventHub) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *OutputEventHub) SetConditions(c ...xpv1.Condition)

+ func (mg *OutputEventHub) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *OutputEventHub) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *OutputEventHub) SetProviderReference(r *xpv1.Reference)

+ func (mg *OutputEventHub) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *OutputEventHub) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *OutputEventHub) GetConnectionDetailsMapping() map[string]string

+ func (tr *OutputEventHub) GetID() string

+ func (tr *OutputEventHub) GetObservation() (map[string]any, error)

+ func (tr *OutputEventHub) GetParameters() (map[string]any, error)

+ func (tr *OutputEventHub) GetTerraformSchemaVersion() int

+ func (tr *OutputEventHub) LateInitialize(attrs []byte) (bool, error)

+ func (tr *OutputEventHub) SetObservation(obs map[string]any) error

+ func (tr *OutputEventHub) SetParameters(params map[string]any) error

+ type OutputEventHubList struct

+ Items []OutputEventHub

+ func (in *OutputEventHubList) DeepCopy() *OutputEventHubList

+ func (in *OutputEventHubList) DeepCopyInto(out *OutputEventHubList)

+ func (in *OutputEventHubList) DeepCopyObject() runtime.Object

+ func (l *OutputEventHubList) GetItems() []resource.Managed

+ type OutputEventHubObservation struct

+ ID *string

+ func (in *OutputEventHubObservation) DeepCopy() *OutputEventHubObservation

+ func (in *OutputEventHubObservation) DeepCopyInto(out *OutputEventHubObservation)

+ type OutputEventHubParameters struct

+ AuthenticationMode *string

+ EventHubName *string

+ EventHubNameRef *v1.Reference

+ EventHubNameSelector *v1.Selector

+ PartitionKey *string

+ PropertyColumns []*string

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ Serialization []OutputEventHubSerializationParameters

+ ServiceBusNamespace *string

+ ServiceBusNamespaceRef *v1.Reference

+ ServiceBusNamespaceSelector *v1.Selector

+ SharedAccessPolicyKeySecretRef *v1.SecretKeySelector

+ SharedAccessPolicyName *string

+ StreamAnalyticsJobName *string

+ func (in *OutputEventHubParameters) DeepCopy() *OutputEventHubParameters

+ func (in *OutputEventHubParameters) DeepCopyInto(out *OutputEventHubParameters)

+ type OutputEventHubSerializationObservation struct

+ func (in *OutputEventHubSerializationObservation) DeepCopy() *OutputEventHubSerializationObservation

+ func (in *OutputEventHubSerializationObservation) DeepCopyInto(out *OutputEventHubSerializationObservation)

+ type OutputEventHubSerializationParameters struct

+ Encoding *string

+ FieldDelimiter *string

+ Format *string

+ Type *string

+ func (in *OutputEventHubSerializationParameters) DeepCopy() *OutputEventHubSerializationParameters

+ func (in *OutputEventHubSerializationParameters) DeepCopyInto(out *OutputEventHubSerializationParameters)

+ type OutputEventHubSpec struct

+ ForProvider OutputEventHubParameters

+ func (in *OutputEventHubSpec) DeepCopy() *OutputEventHubSpec

+ func (in *OutputEventHubSpec) DeepCopyInto(out *OutputEventHubSpec)

+ type OutputEventHubStatus struct

+ AtProvider OutputEventHubObservation

+ func (in *OutputEventHubStatus) DeepCopy() *OutputEventHubStatus

+ func (in *OutputEventHubStatus) DeepCopyInto(out *OutputEventHubStatus)

+ type ReferenceInputMSSQL struct

+ Spec ReferenceInputMSSQLSpec

+ Status ReferenceInputMSSQLStatus

+ func (in *ReferenceInputMSSQL) DeepCopy() *ReferenceInputMSSQL

+ func (in *ReferenceInputMSSQL) DeepCopyInto(out *ReferenceInputMSSQL)

+ func (in *ReferenceInputMSSQL) DeepCopyObject() runtime.Object

+ func (mg *ReferenceInputMSSQL) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *ReferenceInputMSSQL) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *ReferenceInputMSSQL) GetProviderConfigReference() *xpv1.Reference

+ func (mg *ReferenceInputMSSQL) GetProviderReference() *xpv1.Reference

+ func (mg *ReferenceInputMSSQL) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *ReferenceInputMSSQL) GetTerraformResourceType() string

+ func (mg *ReferenceInputMSSQL) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *ReferenceInputMSSQL) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *ReferenceInputMSSQL) SetConditions(c ...xpv1.Condition)

+ func (mg *ReferenceInputMSSQL) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *ReferenceInputMSSQL) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *ReferenceInputMSSQL) SetProviderReference(r *xpv1.Reference)

+ func (mg *ReferenceInputMSSQL) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *ReferenceInputMSSQL) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *ReferenceInputMSSQL) GetConnectionDetailsMapping() map[string]string

+ func (tr *ReferenceInputMSSQL) GetID() string

+ func (tr *ReferenceInputMSSQL) GetObservation() (map[string]any, error)

+ func (tr *ReferenceInputMSSQL) GetParameters() (map[string]any, error)

+ func (tr *ReferenceInputMSSQL) GetTerraformSchemaVersion() int

+ func (tr *ReferenceInputMSSQL) LateInitialize(attrs []byte) (bool, error)

+ func (tr *ReferenceInputMSSQL) SetObservation(obs map[string]any) error

+ func (tr *ReferenceInputMSSQL) SetParameters(params map[string]any) error

+ type ReferenceInputMSSQLList struct

+ Items []ReferenceInputMSSQL

+ func (in *ReferenceInputMSSQLList) DeepCopy() *ReferenceInputMSSQLList

+ func (in *ReferenceInputMSSQLList) DeepCopyInto(out *ReferenceInputMSSQLList)

+ func (in *ReferenceInputMSSQLList) DeepCopyObject() runtime.Object

+ func (l *ReferenceInputMSSQLList) GetItems() []resource.Managed

+ type ReferenceInputMSSQLObservation struct

+ ID *string

+ func (in *ReferenceInputMSSQLObservation) DeepCopy() *ReferenceInputMSSQLObservation

+ func (in *ReferenceInputMSSQLObservation) DeepCopyInto(out *ReferenceInputMSSQLObservation)

+ type ReferenceInputMSSQLParameters struct

+ Database *string

+ DatabaseRef *v1.Reference

+ DatabaseSelector *v1.Selector

+ DeltaSnapshotQuery *string

+ FullSnapshotQuery *string

+ PasswordSecretRef v1.SecretKeySelector

+ RefreshIntervalDuration *string

+ RefreshType *string

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ Server *string

+ ServerRef *v1.Reference

+ ServerSelector *v1.Selector

+ StreamAnalyticsJobName *string

+ Table *string

+ Username *string

+ func (in *ReferenceInputMSSQLParameters) DeepCopy() *ReferenceInputMSSQLParameters

+ func (in *ReferenceInputMSSQLParameters) DeepCopyInto(out *ReferenceInputMSSQLParameters)

+ type ReferenceInputMSSQLSpec struct

+ ForProvider ReferenceInputMSSQLParameters

+ func (in *ReferenceInputMSSQLSpec) DeepCopy() *ReferenceInputMSSQLSpec

+ func (in *ReferenceInputMSSQLSpec) DeepCopyInto(out *ReferenceInputMSSQLSpec)

+ type ReferenceInputMSSQLStatus struct

+ AtProvider ReferenceInputMSSQLObservation

+ func (in *ReferenceInputMSSQLStatus) DeepCopy() *ReferenceInputMSSQLStatus

+ func (in *ReferenceInputMSSQLStatus) DeepCopyInto(out *ReferenceInputMSSQLStatus)

Feb 7, 2023

Changes in this version

+ var OutputMSSQL_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: OutputMSSQL_Kind}.String()

+ var OutputMSSQL_GroupVersionKind = CRDGroupVersion.WithKind(OutputMSSQL_Kind)

+ var OutputMSSQL_Kind = "OutputMSSQL"

+ var OutputMSSQL_KindAPIVersion = OutputMSSQL_Kind + "." + CRDGroupVersion.String()

+ var OutputServiceBusQueue_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: OutputServiceBusQueue_Kind}.String()

+ var OutputServiceBusQueue_GroupVersionKind = CRDGroupVersion.WithKind(OutputServiceBusQueue_Kind)

+ var OutputServiceBusQueue_Kind = "OutputServiceBusQueue"

+ var OutputServiceBusQueue_KindAPIVersion = OutputServiceBusQueue_Kind + "." + CRDGroupVersion.String()

+ var OutputServiceBusTopic_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: OutputServiceBusTopic_Kind}.String()

+ var OutputServiceBusTopic_GroupVersionKind = CRDGroupVersion.WithKind(OutputServiceBusTopic_Kind)

+ var OutputServiceBusTopic_Kind = "OutputServiceBusTopic"

+ var OutputServiceBusTopic_KindAPIVersion = OutputServiceBusTopic_Kind + "." + CRDGroupVersion.String()

+ var ReferenceInputBlob_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: ReferenceInputBlob_Kind}.String()

+ var ReferenceInputBlob_GroupVersionKind = CRDGroupVersion.WithKind(ReferenceInputBlob_Kind)

+ var ReferenceInputBlob_Kind = "ReferenceInputBlob"

+ var ReferenceInputBlob_KindAPIVersion = ReferenceInputBlob_Kind + "." + CRDGroupVersion.String()

+ var StreamInputBlob_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: StreamInputBlob_Kind}.String()

+ var StreamInputBlob_GroupVersionKind = CRDGroupVersion.WithKind(StreamInputBlob_Kind)

+ var StreamInputBlob_Kind = "StreamInputBlob"

+ var StreamInputBlob_KindAPIVersion = StreamInputBlob_Kind + "." + CRDGroupVersion.String()

+ var StreamInputEventHub_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: StreamInputEventHub_Kind}.String()

+ var StreamInputEventHub_GroupVersionKind = CRDGroupVersion.WithKind(StreamInputEventHub_Kind)

+ var StreamInputEventHub_Kind = "StreamInputEventHub"

+ var StreamInputEventHub_KindAPIVersion = StreamInputEventHub_Kind + "." + CRDGroupVersion.String()

+ var StreamInputIOTHub_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: StreamInputIOTHub_Kind}.String()

+ var StreamInputIOTHub_GroupVersionKind = CRDGroupVersion.WithKind(StreamInputIOTHub_Kind)

+ var StreamInputIOTHub_Kind = "StreamInputIOTHub"

+ var StreamInputIOTHub_KindAPIVersion = StreamInputIOTHub_Kind + "." + CRDGroupVersion.String()

type OutputFunctionParameters

+ FunctionAppRef *v1.Reference

+ FunctionAppSelector *v1.Selector

+ type OutputMSSQL struct

+ Spec OutputMSSQLSpec

+ Status OutputMSSQLStatus

+ func (in *OutputMSSQL) DeepCopy() *OutputMSSQL

+ func (in *OutputMSSQL) DeepCopyInto(out *OutputMSSQL)

+ func (in *OutputMSSQL) DeepCopyObject() runtime.Object

+ func (mg *OutputMSSQL) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *OutputMSSQL) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *OutputMSSQL) GetProviderConfigReference() *xpv1.Reference

+ func (mg *OutputMSSQL) GetProviderReference() *xpv1.Reference

+ func (mg *OutputMSSQL) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *OutputMSSQL) GetTerraformResourceType() string

+ func (mg *OutputMSSQL) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *OutputMSSQL) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *OutputMSSQL) SetConditions(c ...xpv1.Condition)

+ func (mg *OutputMSSQL) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *OutputMSSQL) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *OutputMSSQL) SetProviderReference(r *xpv1.Reference)

+ func (mg *OutputMSSQL) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *OutputMSSQL) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *OutputMSSQL) GetConnectionDetailsMapping() map[string]string

+ func (tr *OutputMSSQL) GetID() string

+ func (tr *OutputMSSQL) GetObservation() (map[string]any, error)

+ func (tr *OutputMSSQL) GetParameters() (map[string]any, error)

+ func (tr *OutputMSSQL) GetTerraformSchemaVersion() int

+ func (tr *OutputMSSQL) LateInitialize(attrs []byte) (bool, error)

+ func (tr *OutputMSSQL) SetObservation(obs map[string]any) error

+ func (tr *OutputMSSQL) SetParameters(params map[string]any) error

+ type OutputMSSQLList struct

+ Items []OutputMSSQL

+ func (in *OutputMSSQLList) DeepCopy() *OutputMSSQLList

+ func (in *OutputMSSQLList) DeepCopyInto(out *OutputMSSQLList)

+ func (in *OutputMSSQLList) DeepCopyObject() runtime.Object

+ func (l *OutputMSSQLList) GetItems() []resource.Managed

+ type OutputMSSQLObservation struct

+ ID *string

+ func (in *OutputMSSQLObservation) DeepCopy() *OutputMSSQLObservation

+ func (in *OutputMSSQLObservation) DeepCopyInto(out *OutputMSSQLObservation)

+ type OutputMSSQLParameters struct

+ AuthenticationMode *string

+ Database *string

+ MaxBatchCount *float64

+ MaxWriterCount *float64

+ Name *string

+ PasswordSecretRef *v1.SecretKeySelector

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ Server *string

+ ServerRef *v1.Reference

+ ServerSelector *v1.Selector

+ StreamAnalyticsJobName *string

+ StreamAnalyticsJobNameRef *v1.Reference

+ StreamAnalyticsJobNameSelector *v1.Selector

+ Table *string

+ TableRef *v1.Reference

+ TableSelector *v1.Selector

+ User *string

+ func (in *OutputMSSQLParameters) DeepCopy() *OutputMSSQLParameters

+ func (in *OutputMSSQLParameters) DeepCopyInto(out *OutputMSSQLParameters)

+ type OutputMSSQLSpec struct

+ ForProvider OutputMSSQLParameters

+ func (in *OutputMSSQLSpec) DeepCopy() *OutputMSSQLSpec

+ func (in *OutputMSSQLSpec) DeepCopyInto(out *OutputMSSQLSpec)

+ type OutputMSSQLStatus struct

+ AtProvider OutputMSSQLObservation

+ func (in *OutputMSSQLStatus) DeepCopy() *OutputMSSQLStatus

+ func (in *OutputMSSQLStatus) DeepCopyInto(out *OutputMSSQLStatus)

+ type OutputServiceBusQueue struct

+ Spec OutputServiceBusQueueSpec

+ Status OutputServiceBusQueueStatus

+ func (in *OutputServiceBusQueue) DeepCopy() *OutputServiceBusQueue

+ func (in *OutputServiceBusQueue) DeepCopyInto(out *OutputServiceBusQueue)

+ func (in *OutputServiceBusQueue) DeepCopyObject() runtime.Object

+ func (mg *OutputServiceBusQueue) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *OutputServiceBusQueue) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *OutputServiceBusQueue) GetProviderConfigReference() *xpv1.Reference

+ func (mg *OutputServiceBusQueue) GetProviderReference() *xpv1.Reference

+ func (mg *OutputServiceBusQueue) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *OutputServiceBusQueue) GetTerraformResourceType() string

+ func (mg *OutputServiceBusQueue) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *OutputServiceBusQueue) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *OutputServiceBusQueue) SetConditions(c ...xpv1.Condition)

+ func (mg *OutputServiceBusQueue) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *OutputServiceBusQueue) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *OutputServiceBusQueue) SetProviderReference(r *xpv1.Reference)

+ func (mg *OutputServiceBusQueue) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *OutputServiceBusQueue) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *OutputServiceBusQueue) GetConnectionDetailsMapping() map[string]string

+ func (tr *OutputServiceBusQueue) GetID() string

+ func (tr *OutputServiceBusQueue) GetObservation() (map[string]any, error)

+ func (tr *OutputServiceBusQueue) GetParameters() (map[string]any, error)

+ func (tr *OutputServiceBusQueue) GetTerraformSchemaVersion() int

+ func (tr *OutputServiceBusQueue) LateInitialize(attrs []byte) (bool, error)

+ func (tr *OutputServiceBusQueue) SetObservation(obs map[string]any) error

+ func (tr *OutputServiceBusQueue) SetParameters(params map[string]any) error

+ type OutputServiceBusQueueList struct

+ Items []OutputServiceBusQueue

+ func (in *OutputServiceBusQueueList) DeepCopy() *OutputServiceBusQueueList

+ func (in *OutputServiceBusQueueList) DeepCopyInto(out *OutputServiceBusQueueList)

+ func (in *OutputServiceBusQueueList) DeepCopyObject() runtime.Object

+ func (l *OutputServiceBusQueueList) GetItems() []resource.Managed

+ type OutputServiceBusQueueObservation struct

+ ID *string

+ func (in *OutputServiceBusQueueObservation) DeepCopy() *OutputServiceBusQueueObservation

+ func (in *OutputServiceBusQueueObservation) DeepCopyInto(out *OutputServiceBusQueueObservation)

+ type OutputServiceBusQueueParameters struct

+ AuthenticationMode *string

+ Name *string

+ PropertyColumns []*string

+ QueueName *string

+ QueueNameRef *v1.Reference

+ QueueNameSelector *v1.Selector

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ Serialization []OutputServiceBusQueueSerializationParameters

+ ServiceBusNamespace *string

+ ServiceBusNamespaceRef *v1.Reference

+ ServiceBusNamespaceSelector *v1.Selector

+ SharedAccessPolicyKeySecretRef *v1.SecretKeySelector

+ SharedAccessPolicyName *string

+ StreamAnalyticsJobName *string

+ StreamAnalyticsJobNameRef *v1.Reference

+ StreamAnalyticsJobNameSelector *v1.Selector

+ SystemPropertyColumns map[string]*string

+ func (in *OutputServiceBusQueueParameters) DeepCopy() *OutputServiceBusQueueParameters

+ func (in *OutputServiceBusQueueParameters) DeepCopyInto(out *OutputServiceBusQueueParameters)

+ type OutputServiceBusQueueSerializationObservation struct

+ func (in *OutputServiceBusQueueSerializationObservation) DeepCopy() *OutputServiceBusQueueSerializationObservation

+ func (in *OutputServiceBusQueueSerializationObservation) DeepCopyInto(out *OutputServiceBusQueueSerializationObservation)

+ type OutputServiceBusQueueSerializationParameters struct

+ Encoding *string

+ FieldDelimiter *string

+ Format *string

+ Type *string

+ func (in *OutputServiceBusQueueSerializationParameters) DeepCopy() *OutputServiceBusQueueSerializationParameters

+ func (in *OutputServiceBusQueueSerializationParameters) DeepCopyInto(out *OutputServiceBusQueueSerializationParameters)

+ type OutputServiceBusQueueSpec struct

+ ForProvider OutputServiceBusQueueParameters

+ func (in *OutputServiceBusQueueSpec) DeepCopy() *OutputServiceBusQueueSpec

+ func (in *OutputServiceBusQueueSpec) DeepCopyInto(out *OutputServiceBusQueueSpec)

+ type OutputServiceBusQueueStatus struct

+ AtProvider OutputServiceBusQueueObservation

+ func (in *OutputServiceBusQueueStatus) DeepCopy() *OutputServiceBusQueueStatus

+ func (in *OutputServiceBusQueueStatus) DeepCopyInto(out *OutputServiceBusQueueStatus)

+ type OutputServiceBusTopic struct

+ Spec OutputServiceBusTopicSpec

+ Status OutputServiceBusTopicStatus

+ func (in *OutputServiceBusTopic) DeepCopy() *OutputServiceBusTopic

+ func (in *OutputServiceBusTopic) DeepCopyInto(out *OutputServiceBusTopic)

+ func (in *OutputServiceBusTopic) DeepCopyObject() runtime.Object

+ func (mg *OutputServiceBusTopic) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *OutputServiceBusTopic) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *OutputServiceBusTopic) GetProviderConfigReference() *xpv1.Reference

+ func (mg *OutputServiceBusTopic) GetProviderReference() *xpv1.Reference

+ func (mg *OutputServiceBusTopic) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *OutputServiceBusTopic) GetTerraformResourceType() string

+ func (mg *OutputServiceBusTopic) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *OutputServiceBusTopic) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *OutputServiceBusTopic) SetConditions(c ...xpv1.Condition)

+ func (mg *OutputServiceBusTopic) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *OutputServiceBusTopic) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *OutputServiceBusTopic) SetProviderReference(r *xpv1.Reference)

+ func (mg *OutputServiceBusTopic) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *OutputServiceBusTopic) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *OutputServiceBusTopic) GetConnectionDetailsMapping() map[string]string

+ func (tr *OutputServiceBusTopic) GetID() string

+ func (tr *OutputServiceBusTopic) GetObservation() (map[string]any, error)

+ func (tr *OutputServiceBusTopic) GetParameters() (map[string]any, error)

+ func (tr *OutputServiceBusTopic) GetTerraformSchemaVersion() int

+ func (tr *OutputServiceBusTopic) LateInitialize(attrs []byte) (bool, error)

+ func (tr *OutputServiceBusTopic) SetObservation(obs map[string]any) error

+ func (tr *OutputServiceBusTopic) SetParameters(params map[string]any) error

+ type OutputServiceBusTopicList struct

+ Items []OutputServiceBusTopic

+ func (in *OutputServiceBusTopicList) DeepCopy() *OutputServiceBusTopicList

+ func (in *OutputServiceBusTopicList) DeepCopyInto(out *OutputServiceBusTopicList)

+ func (in *OutputServiceBusTopicList) DeepCopyObject() runtime.Object

+ func (l *OutputServiceBusTopicList) GetItems() []resource.Managed

+ type OutputServiceBusTopicObservation struct

+ ID *string

+ func (in *OutputServiceBusTopicObservation) DeepCopy() *OutputServiceBusTopicObservation

+ func (in *OutputServiceBusTopicObservation) DeepCopyInto(out *OutputServiceBusTopicObservation)

+ type OutputServiceBusTopicParameters struct

+ AuthenticationMode *string

+ Name *string

+ PropertyColumns []*string

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ Serialization []OutputServiceBusTopicSerializationParameters

+ ServiceBusNamespace *string

+ ServiceBusNamespaceRef *v1.Reference

+ ServiceBusNamespaceSelector *v1.Selector

+ SharedAccessPolicyKeySecretRef *v1.SecretKeySelector

+ SharedAccessPolicyName *string

+ StreamAnalyticsJobName *string

+ StreamAnalyticsJobNameRef *v1.Reference

+ StreamAnalyticsJobNameSelector *v1.Selector

+ SystemPropertyColumns map[string]*string

+ TopicName *string

+ TopicNameRef *v1.Reference

+ TopicNameSelector *v1.Selector

+ func (in *OutputServiceBusTopicParameters) DeepCopy() *OutputServiceBusTopicParameters

+ func (in *OutputServiceBusTopicParameters) DeepCopyInto(out *OutputServiceBusTopicParameters)

+ type OutputServiceBusTopicSerializationObservation struct

+ func (in *OutputServiceBusTopicSerializationObservation) DeepCopy() *OutputServiceBusTopicSerializationObservation

+ func (in *OutputServiceBusTopicSerializationObservation) DeepCopyInto(out *OutputServiceBusTopicSerializationObservation)

+ type OutputServiceBusTopicSerializationParameters struct

+ Encoding *string

+ FieldDelimiter *string

+ Format *string

+ Type *string

+ func (in *OutputServiceBusTopicSerializationParameters) DeepCopy() *OutputServiceBusTopicSerializationParameters

+ func (in *OutputServiceBusTopicSerializationParameters) DeepCopyInto(out *OutputServiceBusTopicSerializationParameters)

+ type OutputServiceBusTopicSpec struct

+ ForProvider OutputServiceBusTopicParameters

+ func (in *OutputServiceBusTopicSpec) DeepCopy() *OutputServiceBusTopicSpec

+ func (in *OutputServiceBusTopicSpec) DeepCopyInto(out *OutputServiceBusTopicSpec)

+ type OutputServiceBusTopicStatus struct

+ AtProvider OutputServiceBusTopicObservation

+ func (in *OutputServiceBusTopicStatus) DeepCopy() *OutputServiceBusTopicStatus

+ func (in *OutputServiceBusTopicStatus) DeepCopyInto(out *OutputServiceBusTopicStatus)

type OutputSynapseParameters

+ UserRef *v1.Reference

+ UserSelector *v1.Selector

+ type ReferenceInputBlob struct

+ Spec ReferenceInputBlobSpec

+ Status ReferenceInputBlobStatus

+ func (in *ReferenceInputBlob) DeepCopy() *ReferenceInputBlob

+ func (in *ReferenceInputBlob) DeepCopyInto(out *ReferenceInputBlob)

+ func (in *ReferenceInputBlob) DeepCopyObject() runtime.Object

+ func (mg *ReferenceInputBlob) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *ReferenceInputBlob) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *ReferenceInputBlob) GetProviderConfigReference() *xpv1.Reference

+ func (mg *ReferenceInputBlob) GetProviderReference() *xpv1.Reference

+ func (mg *ReferenceInputBlob) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *ReferenceInputBlob) GetTerraformResourceType() string

+ func (mg *ReferenceInputBlob) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *ReferenceInputBlob) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *ReferenceInputBlob) SetConditions(c ...xpv1.Condition)

+ func (mg *ReferenceInputBlob) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *ReferenceInputBlob) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *ReferenceInputBlob) SetProviderReference(r *xpv1.Reference)

+ func (mg *ReferenceInputBlob) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *ReferenceInputBlob) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *ReferenceInputBlob) GetConnectionDetailsMapping() map[string]string

+ func (tr *ReferenceInputBlob) GetID() string

+ func (tr *ReferenceInputBlob) GetObservation() (map[string]any, error)

+ func (tr *ReferenceInputBlob) GetParameters() (map[string]any, error)

+ func (tr *ReferenceInputBlob) GetTerraformSchemaVersion() int

+ func (tr *ReferenceInputBlob) LateInitialize(attrs []byte) (bool, error)

+ func (tr *ReferenceInputBlob) SetObservation(obs map[string]any) error

+ func (tr *ReferenceInputBlob) SetParameters(params map[string]any) error

+ type ReferenceInputBlobList struct

+ Items []ReferenceInputBlob

+ func (in *ReferenceInputBlobList) DeepCopy() *ReferenceInputBlobList

+ func (in *ReferenceInputBlobList) DeepCopyInto(out *ReferenceInputBlobList)

+ func (in *ReferenceInputBlobList) DeepCopyObject() runtime.Object

+ func (l *ReferenceInputBlobList) GetItems() []resource.Managed

+ type ReferenceInputBlobObservation struct

+ ID *string

+ func (in *ReferenceInputBlobObservation) DeepCopy() *ReferenceInputBlobObservation

+ func (in *ReferenceInputBlobObservation) DeepCopyInto(out *ReferenceInputBlobObservation)

+ type ReferenceInputBlobParameters struct

+ AuthenticationMode *string

+ DateFormat *string

+ Name *string

+ PathPattern *string

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ Serialization []ReferenceInputBlobSerializationParameters

+ StorageAccountKeySecretRef *v1.SecretKeySelector

+ StorageAccountName *string

+ StorageAccountNameRef *v1.Reference

+ StorageAccountNameSelector *v1.Selector

+ StorageContainerName *string

+ StorageContainerNameRef *v1.Reference

+ StorageContainerNameSelector *v1.Selector

+ StreamAnalyticsJobName *string

+ StreamAnalyticsJobNameRef *v1.Reference

+ StreamAnalyticsJobNameSelector *v1.Selector

+ TimeFormat *string

+ func (in *ReferenceInputBlobParameters) DeepCopy() *ReferenceInputBlobParameters

+ func (in *ReferenceInputBlobParameters) DeepCopyInto(out *ReferenceInputBlobParameters)

+ type ReferenceInputBlobSerializationObservation struct

+ func (in *ReferenceInputBlobSerializationObservation) DeepCopy() *ReferenceInputBlobSerializationObservation

+ func (in *ReferenceInputBlobSerializationObservation) DeepCopyInto(out *ReferenceInputBlobSerializationObservation)

+ type ReferenceInputBlobSerializationParameters struct

+ Encoding *string

+ FieldDelimiter *string

+ Type *string

+ func (in *ReferenceInputBlobSerializationParameters) DeepCopy() *ReferenceInputBlobSerializationParameters

+ func (in *ReferenceInputBlobSerializationParameters) DeepCopyInto(out *ReferenceInputBlobSerializationParameters)

+ type ReferenceInputBlobSpec struct

+ ForProvider ReferenceInputBlobParameters

+ func (in *ReferenceInputBlobSpec) DeepCopy() *ReferenceInputBlobSpec

+ func (in *ReferenceInputBlobSpec) DeepCopyInto(out *ReferenceInputBlobSpec)

+ type ReferenceInputBlobStatus struct

+ AtProvider ReferenceInputBlobObservation

+ func (in *ReferenceInputBlobStatus) DeepCopy() *ReferenceInputBlobStatus

+ func (in *ReferenceInputBlobStatus) DeepCopyInto(out *ReferenceInputBlobStatus)

+ type StreamInputBlob struct

+ Spec StreamInputBlobSpec

+ Status StreamInputBlobStatus

+ func (in *StreamInputBlob) DeepCopy() *StreamInputBlob

+ func (in *StreamInputBlob) DeepCopyInto(out *StreamInputBlob)

+ func (in *StreamInputBlob) DeepCopyObject() runtime.Object

+ func (mg *StreamInputBlob) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *StreamInputBlob) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *StreamInputBlob) GetProviderConfigReference() *xpv1.Reference

+ func (mg *StreamInputBlob) GetProviderReference() *xpv1.Reference

+ func (mg *StreamInputBlob) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *StreamInputBlob) GetTerraformResourceType() string

+ func (mg *StreamInputBlob) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *StreamInputBlob) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *StreamInputBlob) SetConditions(c ...xpv1.Condition)

+ func (mg *StreamInputBlob) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *StreamInputBlob) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *StreamInputBlob) SetProviderReference(r *xpv1.Reference)

+ func (mg *StreamInputBlob) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *StreamInputBlob) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *StreamInputBlob) GetConnectionDetailsMapping() map[string]string

+ func (tr *StreamInputBlob) GetID() string

+ func (tr *StreamInputBlob) GetObservation() (map[string]any, error)

+ func (tr *StreamInputBlob) GetParameters() (map[string]any, error)

+ func (tr *StreamInputBlob) GetTerraformSchemaVersion() int

+ func (tr *StreamInputBlob) LateInitialize(attrs []byte) (bool, error)

+ func (tr *StreamInputBlob) SetObservation(obs map[string]any) error

+ func (tr *StreamInputBlob) SetParameters(params map[string]any) error

+ type StreamInputBlobList struct

+ Items []StreamInputBlob

+ func (in *StreamInputBlobList) DeepCopy() *StreamInputBlobList

+ func (in *StreamInputBlobList) DeepCopyInto(out *StreamInputBlobList)

+ func (in *StreamInputBlobList) DeepCopyObject() runtime.Object

+ func (l *StreamInputBlobList) GetItems() []resource.Managed

+ type StreamInputBlobObservation struct

+ ID *string

+ func (in *StreamInputBlobObservation) DeepCopy() *StreamInputBlobObservation

+ func (in *StreamInputBlobObservation) DeepCopyInto(out *StreamInputBlobObservation)

+ type StreamInputBlobParameters struct

+ DateFormat *string

+ Name *string

+ PathPattern *string

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ Serialization []StreamInputBlobSerializationParameters

+ StorageAccountKeySecretRef v1.SecretKeySelector

+ StorageAccountName *string

+ StorageAccountNameRef *v1.Reference

+ StorageAccountNameSelector *v1.Selector

+ StorageContainerName *string

+ StorageContainerNameRef *v1.Reference

+ StorageContainerNameSelector *v1.Selector

+ StreamAnalyticsJobName *string

+ StreamAnalyticsJobNameRef *v1.Reference

+ StreamAnalyticsJobNameSelector *v1.Selector

+ TimeFormat *string

+ func (in *StreamInputBlobParameters) DeepCopy() *StreamInputBlobParameters

+ func (in *StreamInputBlobParameters) DeepCopyInto(out *StreamInputBlobParameters)

+ type StreamInputBlobSerializationObservation struct

+ func (in *StreamInputBlobSerializationObservation) DeepCopy() *StreamInputBlobSerializationObservation

+ func (in *StreamInputBlobSerializationObservation) DeepCopyInto(out *StreamInputBlobSerializationObservation)

+ type StreamInputBlobSerializationParameters struct

+ Encoding *string

+ FieldDelimiter *string

+ Type *string

+ func (in *StreamInputBlobSerializationParameters) DeepCopy() *StreamInputBlobSerializationParameters

+ func (in *StreamInputBlobSerializationParameters) DeepCopyInto(out *StreamInputBlobSerializationParameters)

+ type StreamInputBlobSpec struct

+ ForProvider StreamInputBlobParameters

+ func (in *StreamInputBlobSpec) DeepCopy() *StreamInputBlobSpec

+ func (in *StreamInputBlobSpec) DeepCopyInto(out *StreamInputBlobSpec)

+ type StreamInputBlobStatus struct

+ AtProvider StreamInputBlobObservation

+ func (in *StreamInputBlobStatus) DeepCopy() *StreamInputBlobStatus

+ func (in *StreamInputBlobStatus) DeepCopyInto(out *StreamInputBlobStatus)

+ type StreamInputEventHub struct

+ Spec StreamInputEventHubSpec

+ Status StreamInputEventHubStatus

+ func (in *StreamInputEventHub) DeepCopy() *StreamInputEventHub

+ func (in *StreamInputEventHub) DeepCopyInto(out *StreamInputEventHub)

+ func (in *StreamInputEventHub) DeepCopyObject() runtime.Object

+ func (mg *StreamInputEventHub) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *StreamInputEventHub) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *StreamInputEventHub) GetProviderConfigReference() *xpv1.Reference

+ func (mg *StreamInputEventHub) GetProviderReference() *xpv1.Reference

+ func (mg *StreamInputEventHub) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *StreamInputEventHub) GetTerraformResourceType() string

+ func (mg *StreamInputEventHub) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *StreamInputEventHub) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *StreamInputEventHub) SetConditions(c ...xpv1.Condition)

+ func (mg *StreamInputEventHub) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *StreamInputEventHub) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *StreamInputEventHub) SetProviderReference(r *xpv1.Reference)

+ func (mg *StreamInputEventHub) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *StreamInputEventHub) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *StreamInputEventHub) GetConnectionDetailsMapping() map[string]string

+ func (tr *StreamInputEventHub) GetID() string

+ func (tr *StreamInputEventHub) GetObservation() (map[string]any, error)

+ func (tr *StreamInputEventHub) GetParameters() (map[string]any, error)

+ func (tr *StreamInputEventHub) GetTerraformSchemaVersion() int

+ func (tr *StreamInputEventHub) LateInitialize(attrs []byte) (bool, error)

+ func (tr *StreamInputEventHub) SetObservation(obs map[string]any) error

+ func (tr *StreamInputEventHub) SetParameters(params map[string]any) error

+ type StreamInputEventHubList struct

+ Items []StreamInputEventHub

+ func (in *StreamInputEventHubList) DeepCopy() *StreamInputEventHubList

+ func (in *StreamInputEventHubList) DeepCopyInto(out *StreamInputEventHubList)

+ func (in *StreamInputEventHubList) DeepCopyObject() runtime.Object

+ func (l *StreamInputEventHubList) GetItems() []resource.Managed

+ type StreamInputEventHubObservation struct

+ ID *string

+ func (in *StreamInputEventHubObservation) DeepCopy() *StreamInputEventHubObservation

+ func (in *StreamInputEventHubObservation) DeepCopyInto(out *StreamInputEventHubObservation)

+ type StreamInputEventHubParameters struct

+ AuthenticationMode *string

+ EventHubConsumerGroupName *string

+ EventHubConsumerGroupNameRef *v1.Reference

+ EventHubConsumerGroupNameSelector *v1.Selector

+ EventHubName *string

+ EventHubNameRef *v1.Reference

+ EventHubNameSelector *v1.Selector

+ Name *string

+ PartitionKey *string

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ Serialization []StreamInputEventHubSerializationParameters

+ ServiceBusNamespace *string

+ ServiceBusNamespaceRef *v1.Reference

+ ServiceBusNamespaceSelector *v1.Selector

+ SharedAccessPolicyKeySecretRef *v1.SecretKeySelector

+ SharedAccessPolicyName *string

+ StreamAnalyticsJobName *string

+ StreamAnalyticsJobNameRef *v1.Reference

+ StreamAnalyticsJobNameSelector *v1.Selector

+ func (in *StreamInputEventHubParameters) DeepCopy() *StreamInputEventHubParameters

+ func (in *StreamInputEventHubParameters) DeepCopyInto(out *StreamInputEventHubParameters)

+ type StreamInputEventHubSerializationObservation struct

+ func (in *StreamInputEventHubSerializationObservation) DeepCopy() *StreamInputEventHubSerializationObservation

+ func (in *StreamInputEventHubSerializationObservation) DeepCopyInto(out *StreamInputEventHubSerializationObservation)

+ type StreamInputEventHubSerializationParameters struct

+ Encoding *string

+ FieldDelimiter *string

+ Type *string

+ func (in *StreamInputEventHubSerializationParameters) DeepCopy() *StreamInputEventHubSerializationParameters

+ func (in *StreamInputEventHubSerializationParameters) DeepCopyInto(out *StreamInputEventHubSerializationParameters)

+ type StreamInputEventHubSpec struct

+ ForProvider StreamInputEventHubParameters

+ func (in *StreamInputEventHubSpec) DeepCopy() *StreamInputEventHubSpec

+ func (in *StreamInputEventHubSpec) DeepCopyInto(out *StreamInputEventHubSpec)

+ type StreamInputEventHubStatus struct

+ AtProvider StreamInputEventHubObservation

+ func (in *StreamInputEventHubStatus) DeepCopy() *StreamInputEventHubStatus

+ func (in *StreamInputEventHubStatus) DeepCopyInto(out *StreamInputEventHubStatus)

+ type StreamInputIOTHub struct

+ Spec StreamInputIOTHubSpec

+ Status StreamInputIOTHubStatus

+ func (in *StreamInputIOTHub) DeepCopy() *StreamInputIOTHub

+ func (in *StreamInputIOTHub) DeepCopyInto(out *StreamInputIOTHub)

+ func (in *StreamInputIOTHub) DeepCopyObject() runtime.Object

+ func (mg *StreamInputIOTHub) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *StreamInputIOTHub) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *StreamInputIOTHub) GetProviderConfigReference() *xpv1.Reference

+ func (mg *StreamInputIOTHub) GetProviderReference() *xpv1.Reference

+ func (mg *StreamInputIOTHub) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *StreamInputIOTHub) GetTerraformResourceType() string

+ func (mg *StreamInputIOTHub) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *StreamInputIOTHub) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *StreamInputIOTHub) SetConditions(c ...xpv1.Condition)

+ func (mg *StreamInputIOTHub) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *StreamInputIOTHub) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *StreamInputIOTHub) SetProviderReference(r *xpv1.Reference)

+ func (mg *StreamInputIOTHub) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *StreamInputIOTHub) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *StreamInputIOTHub) GetConnectionDetailsMapping() map[string]string

+ func (tr *StreamInputIOTHub) GetID() string

+ func (tr *StreamInputIOTHub) GetObservation() (map[string]any, error)

+ func (tr *StreamInputIOTHub) GetParameters() (map[string]any, error)

+ func (tr *StreamInputIOTHub) GetTerraformSchemaVersion() int

+ func (tr *StreamInputIOTHub) LateInitialize(attrs []byte) (bool, error)

+ func (tr *StreamInputIOTHub) SetObservation(obs map[string]any) error

+ func (tr *StreamInputIOTHub) SetParameters(params map[string]any) error

+ type StreamInputIOTHubList struct

+ Items []StreamInputIOTHub

+ func (in *StreamInputIOTHubList) DeepCopy() *StreamInputIOTHubList

+ func (in *StreamInputIOTHubList) DeepCopyInto(out *StreamInputIOTHubList)

+ func (in *StreamInputIOTHubList) DeepCopyObject() runtime.Object

+ func (l *StreamInputIOTHubList) GetItems() []resource.Managed

+ type StreamInputIOTHubObservation struct

+ ID *string

+ func (in *StreamInputIOTHubObservation) DeepCopy() *StreamInputIOTHubObservation

+ func (in *StreamInputIOTHubObservation) DeepCopyInto(out *StreamInputIOTHubObservation)

+ type StreamInputIOTHubParameters struct

+ Endpoint *string

+ EventHubConsumerGroupName *string

+ EventHubConsumerGroupNameRef *v1.Reference

+ EventHubConsumerGroupNameSelector *v1.Selector

+ IOTHubNamespace *string

+ IOTHubNamespaceRef *v1.Reference

+ IOTHubNamespaceSelector *v1.Selector

+ Name *string

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ Serialization []StreamInputIOTHubSerializationParameters

+ SharedAccessPolicyKeySecretRef v1.SecretKeySelector

+ SharedAccessPolicyName *string

+ StreamAnalyticsJobName *string

+ StreamAnalyticsJobNameRef *v1.Reference

+ StreamAnalyticsJobNameSelector *v1.Selector

+ func (in *StreamInputIOTHubParameters) DeepCopy() *StreamInputIOTHubParameters

+ func (in *StreamInputIOTHubParameters) DeepCopyInto(out *StreamInputIOTHubParameters)

+ type StreamInputIOTHubSerializationObservation struct

+ func (in *StreamInputIOTHubSerializationObservation) DeepCopy() *StreamInputIOTHubSerializationObservation

+ func (in *StreamInputIOTHubSerializationObservation) DeepCopyInto(out *StreamInputIOTHubSerializationObservation)

+ type StreamInputIOTHubSerializationParameters struct

+ Encoding *string

+ FieldDelimiter *string

+ Type *string

+ func (in *StreamInputIOTHubSerializationParameters) DeepCopy() *StreamInputIOTHubSerializationParameters

+ func (in *StreamInputIOTHubSerializationParameters) DeepCopyInto(out *StreamInputIOTHubSerializationParameters)

+ type StreamInputIOTHubSpec struct

+ ForProvider StreamInputIOTHubParameters

+ func (in *StreamInputIOTHubSpec) DeepCopy() *StreamInputIOTHubSpec

+ func (in *StreamInputIOTHubSpec) DeepCopyInto(out *StreamInputIOTHubSpec)

+ type StreamInputIOTHubStatus struct

+ AtProvider StreamInputIOTHubObservation

+ func (in *StreamInputIOTHubStatus) DeepCopy() *StreamInputIOTHubStatus

+ func (in *StreamInputIOTHubStatus) DeepCopyInto(out *StreamInputIOTHubStatus)

Jan 24, 2023

Changes in this version

type FunctionJavascriptUda

+ func (mg *FunctionJavascriptUda) ResolveReferences(ctx context.Context, c client.Reader) error

type FunctionJavascriptUdaParameters

+ StreamAnalyticsJobIDRef *v1.Reference

+ StreamAnalyticsJobIDSelector *v1.Selector

type JobParameters

+ ContentStoragePolicy *string

+ JobStorageAccount []JobStorageAccountParameters

+ type JobStorageAccountObservation struct

+ func (in *JobStorageAccountObservation) DeepCopy() *JobStorageAccountObservation

+ func (in *JobStorageAccountObservation) DeepCopyInto(out *JobStorageAccountObservation)

+ type JobStorageAccountParameters struct

+ AccountKeySecretRef v1.SecretKeySelector

+ AccountName *string

+ AuthenticationMode *string

+ func (in *JobStorageAccountParameters) DeepCopy() *JobStorageAccountParameters

+ func (in *JobStorageAccountParameters) DeepCopyInto(out *JobStorageAccountParameters)

type OutputBlobParameters

+ AuthenticationMode *string

+ StreamAnalyticsJobNameRef *v1.Reference

+ StreamAnalyticsJobNameSelector *v1.Selector

Oct 17, 2022

Changes in this version

+ const CRDGroup

+ const CRDVersion

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var CRDGroupVersion = schema.GroupVersion

+ var Cluster_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: Cluster_Kind}.String()

+ var Cluster_GroupVersionKind = CRDGroupVersion.WithKind(Cluster_Kind)

+ var Cluster_Kind = "Cluster"

+ var Cluster_KindAPIVersion = Cluster_Kind + "." + CRDGroupVersion.String()

+ var FunctionJavascriptUda_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: FunctionJavascriptUda_Kind}.String()

+ var FunctionJavascriptUda_GroupVersionKind = CRDGroupVersion.WithKind(FunctionJavascriptUda_Kind)

+ var FunctionJavascriptUda_Kind = "FunctionJavascriptUda"

+ var FunctionJavascriptUda_KindAPIVersion = FunctionJavascriptUda_Kind + "." + CRDGroupVersion.String()

+ var Job_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: Job_Kind}.String()

+ var Job_GroupVersionKind = CRDGroupVersion.WithKind(Job_Kind)

+ var Job_Kind = "Job"

+ var Job_KindAPIVersion = Job_Kind + "." + CRDGroupVersion.String()

+ var ManagedPrivateEndpoint_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: ManagedPrivateEndpoint_Kind}.String()

+ var ManagedPrivateEndpoint_GroupVersionKind = CRDGroupVersion.WithKind(ManagedPrivateEndpoint_Kind)

+ var ManagedPrivateEndpoint_Kind = "ManagedPrivateEndpoint"

+ var ManagedPrivateEndpoint_KindAPIVersion = ManagedPrivateEndpoint_Kind + "." + CRDGroupVersion.String()

+ var OutputBlob_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: OutputBlob_Kind}.String()

+ var OutputBlob_GroupVersionKind = CRDGroupVersion.WithKind(OutputBlob_Kind)

+ var OutputBlob_Kind = "OutputBlob"

+ var OutputBlob_KindAPIVersion = OutputBlob_Kind + "." + CRDGroupVersion.String()

+ var OutputFunction_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: OutputFunction_Kind}.String()

+ var OutputFunction_GroupVersionKind = CRDGroupVersion.WithKind(OutputFunction_Kind)

+ var OutputFunction_Kind = "OutputFunction"

+ var OutputFunction_KindAPIVersion = OutputFunction_Kind + "." + CRDGroupVersion.String()

+ var OutputSynapse_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: OutputSynapse_Kind}.String()

+ var OutputSynapse_GroupVersionKind = CRDGroupVersion.WithKind(OutputSynapse_Kind)

+ var OutputSynapse_Kind = "OutputSynapse"

+ var OutputSynapse_KindAPIVersion = OutputSynapse_Kind + "." + CRDGroupVersion.String()

+ var SchemeBuilder = &scheme.Builder

+ type Cluster struct

+ Spec ClusterSpec

+ Status ClusterStatus

+ func (in *Cluster) DeepCopy() *Cluster

+ func (in *Cluster) DeepCopyInto(out *Cluster)

+ func (in *Cluster) DeepCopyObject() runtime.Object

+ func (mg *Cluster) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *Cluster) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *Cluster) GetProviderConfigReference() *xpv1.Reference

+ func (mg *Cluster) GetProviderReference() *xpv1.Reference

+ func (mg *Cluster) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *Cluster) GetTerraformResourceType() string

+ func (mg *Cluster) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *Cluster) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *Cluster) SetConditions(c ...xpv1.Condition)

+ func (mg *Cluster) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *Cluster) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *Cluster) SetProviderReference(r *xpv1.Reference)

+ func (mg *Cluster) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *Cluster) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *Cluster) GetConnectionDetailsMapping() map[string]string

+ func (tr *Cluster) GetID() string

+ func (tr *Cluster) GetObservation() (map[string]any, error)

+ func (tr *Cluster) GetParameters() (map[string]any, error)

+ func (tr *Cluster) GetTerraformSchemaVersion() int

+ func (tr *Cluster) LateInitialize(attrs []byte) (bool, error)

+ func (tr *Cluster) SetObservation(obs map[string]any) error

+ func (tr *Cluster) SetParameters(params map[string]any) error

+ type ClusterList struct

+ Items []Cluster

+ func (in *ClusterList) DeepCopy() *ClusterList

+ func (in *ClusterList) DeepCopyInto(out *ClusterList)

+ func (in *ClusterList) DeepCopyObject() runtime.Object

+ func (l *ClusterList) GetItems() []resource.Managed

+ type ClusterObservation struct

+ ID *string

+ func (in *ClusterObservation) DeepCopy() *ClusterObservation

+ func (in *ClusterObservation) DeepCopyInto(out *ClusterObservation)

+ type ClusterParameters struct

+ Location *string

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ StreamingCapacity *float64

+ Tags map[string]*string

+ func (in *ClusterParameters) DeepCopy() *ClusterParameters

+ func (in *ClusterParameters) DeepCopyInto(out *ClusterParameters)

+ type ClusterSpec struct

+ ForProvider ClusterParameters

+ func (in *ClusterSpec) DeepCopy() *ClusterSpec

+ func (in *ClusterSpec) DeepCopyInto(out *ClusterSpec)

+ type ClusterStatus struct

+ AtProvider ClusterObservation

+ func (in *ClusterStatus) DeepCopy() *ClusterStatus

+ func (in *ClusterStatus) DeepCopyInto(out *ClusterStatus)

+ type FunctionJavascriptUda struct

+ Spec FunctionJavascriptUdaSpec

+ Status FunctionJavascriptUdaStatus

+ func (in *FunctionJavascriptUda) DeepCopy() *FunctionJavascriptUda

+ func (in *FunctionJavascriptUda) DeepCopyInto(out *FunctionJavascriptUda)

+ func (in *FunctionJavascriptUda) DeepCopyObject() runtime.Object

+ func (mg *FunctionJavascriptUda) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *FunctionJavascriptUda) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *FunctionJavascriptUda) GetProviderConfigReference() *xpv1.Reference

+ func (mg *FunctionJavascriptUda) GetProviderReference() *xpv1.Reference

+ func (mg *FunctionJavascriptUda) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *FunctionJavascriptUda) GetTerraformResourceType() string

+ func (mg *FunctionJavascriptUda) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *FunctionJavascriptUda) SetConditions(c ...xpv1.Condition)

+ func (mg *FunctionJavascriptUda) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *FunctionJavascriptUda) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *FunctionJavascriptUda) SetProviderReference(r *xpv1.Reference)

+ func (mg *FunctionJavascriptUda) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *FunctionJavascriptUda) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *FunctionJavascriptUda) GetConnectionDetailsMapping() map[string]string

+ func (tr *FunctionJavascriptUda) GetID() string

+ func (tr *FunctionJavascriptUda) GetObservation() (map[string]any, error)

+ func (tr *FunctionJavascriptUda) GetParameters() (map[string]any, error)

+ func (tr *FunctionJavascriptUda) GetTerraformSchemaVersion() int

+ func (tr *FunctionJavascriptUda) LateInitialize(attrs []byte) (bool, error)

+ func (tr *FunctionJavascriptUda) SetObservation(obs map[string]any) error

+ func (tr *FunctionJavascriptUda) SetParameters(params map[string]any) error

+ type FunctionJavascriptUdaList struct

+ Items []FunctionJavascriptUda

+ func (in *FunctionJavascriptUdaList) DeepCopy() *FunctionJavascriptUdaList

+ func (in *FunctionJavascriptUdaList) DeepCopyInto(out *FunctionJavascriptUdaList)

+ func (in *FunctionJavascriptUdaList) DeepCopyObject() runtime.Object

+ func (l *FunctionJavascriptUdaList) GetItems() []resource.Managed

+ type FunctionJavascriptUdaObservation struct

+ ID *string

+ func (in *FunctionJavascriptUdaObservation) DeepCopy() *FunctionJavascriptUdaObservation

+ func (in *FunctionJavascriptUdaObservation) DeepCopyInto(out *FunctionJavascriptUdaObservation)

+ type FunctionJavascriptUdaParameters struct

+ Input []InputParameters

+ Output []OutputParameters

+ Script *string

+ StreamAnalyticsJobID *string

+ func (in *FunctionJavascriptUdaParameters) DeepCopy() *FunctionJavascriptUdaParameters

+ func (in *FunctionJavascriptUdaParameters) DeepCopyInto(out *FunctionJavascriptUdaParameters)

+ type FunctionJavascriptUdaSpec struct

+ ForProvider FunctionJavascriptUdaParameters

+ func (in *FunctionJavascriptUdaSpec) DeepCopy() *FunctionJavascriptUdaSpec

+ func (in *FunctionJavascriptUdaSpec) DeepCopyInto(out *FunctionJavascriptUdaSpec)

+ type FunctionJavascriptUdaStatus struct

+ AtProvider FunctionJavascriptUdaObservation

+ func (in *FunctionJavascriptUdaStatus) DeepCopy() *FunctionJavascriptUdaStatus

+ func (in *FunctionJavascriptUdaStatus) DeepCopyInto(out *FunctionJavascriptUdaStatus)

+ type IdentityObservation struct

+ PrincipalID *string

+ TenantID *string

+ func (in *IdentityObservation) DeepCopy() *IdentityObservation

+ func (in *IdentityObservation) DeepCopyInto(out *IdentityObservation)

+ type IdentityParameters struct

+ Type *string

+ func (in *IdentityParameters) DeepCopy() *IdentityParameters

+ func (in *IdentityParameters) DeepCopyInto(out *IdentityParameters)

+ type InputObservation struct

+ func (in *InputObservation) DeepCopy() *InputObservation

+ func (in *InputObservation) DeepCopyInto(out *InputObservation)

+ type InputParameters struct

+ ConfigurationParameter *bool

+ Type *string

+ func (in *InputParameters) DeepCopy() *InputParameters

+ func (in *InputParameters) DeepCopyInto(out *InputParameters)

+ type Job struct

+ Spec JobSpec

+ Status JobStatus

+ func (in *Job) DeepCopy() *Job

+ func (in *Job) DeepCopyInto(out *Job)

+ func (in *Job) DeepCopyObject() runtime.Object

+ func (mg *Job) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *Job) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *Job) GetProviderConfigReference() *xpv1.Reference

+ func (mg *Job) GetProviderReference() *xpv1.Reference

+ func (mg *Job) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *Job) GetTerraformResourceType() string

+ func (mg *Job) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *Job) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *Job) SetConditions(c ...xpv1.Condition)

+ func (mg *Job) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *Job) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *Job) SetProviderReference(r *xpv1.Reference)

+ func (mg *Job) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *Job) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *Job) GetConnectionDetailsMapping() map[string]string

+ func (tr *Job) GetID() string

+ func (tr *Job) GetObservation() (map[string]any, error)

+ func (tr *Job) GetParameters() (map[string]any, error)

+ func (tr *Job) GetTerraformSchemaVersion() int

+ func (tr *Job) LateInitialize(attrs []byte) (bool, error)

+ func (tr *Job) SetObservation(obs map[string]any) error

+ func (tr *Job) SetParameters(params map[string]any) error

+ type JobList struct

+ Items []Job

+ func (in *JobList) DeepCopy() *JobList

+ func (in *JobList) DeepCopyInto(out *JobList)

+ func (in *JobList) DeepCopyObject() runtime.Object

+ func (l *JobList) GetItems() []resource.Managed

+ type JobObservation struct

+ ID *string

+ Identity []IdentityObservation

+ JobID *string

+ func (in *JobObservation) DeepCopy() *JobObservation

+ func (in *JobObservation) DeepCopyInto(out *JobObservation)

+ type JobParameters struct

+ CompatibilityLevel *string

+ DataLocale *string

+ EventsLateArrivalMaxDelayInSeconds *float64

+ EventsOutOfOrderMaxDelayInSeconds *float64

+ EventsOutOfOrderPolicy *string

+ Identity []IdentityParameters

+ Location *string

+ OutputErrorPolicy *string

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ StreamAnalyticsClusterID *string

+ StreamingUnits *float64

+ Tags map[string]*string

+ TransformationQuery *string

+ Type *string

+ func (in *JobParameters) DeepCopy() *JobParameters

+ func (in *JobParameters) DeepCopyInto(out *JobParameters)

+ type JobSpec struct

+ ForProvider JobParameters

+ func (in *JobSpec) DeepCopy() *JobSpec

+ func (in *JobSpec) DeepCopyInto(out *JobSpec)

+ type JobStatus struct

+ AtProvider JobObservation

+ func (in *JobStatus) DeepCopy() *JobStatus

+ func (in *JobStatus) DeepCopyInto(out *JobStatus)

+ type ManagedPrivateEndpoint struct

+ Spec ManagedPrivateEndpointSpec

+ Status ManagedPrivateEndpointStatus

+ func (in *ManagedPrivateEndpoint) DeepCopy() *ManagedPrivateEndpoint

+ func (in *ManagedPrivateEndpoint) DeepCopyInto(out *ManagedPrivateEndpoint)

+ func (in *ManagedPrivateEndpoint) DeepCopyObject() runtime.Object

+ func (mg *ManagedPrivateEndpoint) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *ManagedPrivateEndpoint) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *ManagedPrivateEndpoint) GetProviderConfigReference() *xpv1.Reference

+ func (mg *ManagedPrivateEndpoint) GetProviderReference() *xpv1.Reference

+ func (mg *ManagedPrivateEndpoint) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *ManagedPrivateEndpoint) GetTerraformResourceType() string

+ func (mg *ManagedPrivateEndpoint) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *ManagedPrivateEndpoint) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *ManagedPrivateEndpoint) SetConditions(c ...xpv1.Condition)

+ func (mg *ManagedPrivateEndpoint) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *ManagedPrivateEndpoint) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *ManagedPrivateEndpoint) SetProviderReference(r *xpv1.Reference)

+ func (mg *ManagedPrivateEndpoint) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *ManagedPrivateEndpoint) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *ManagedPrivateEndpoint) GetConnectionDetailsMapping() map[string]string

+ func (tr *ManagedPrivateEndpoint) GetID() string

+ func (tr *ManagedPrivateEndpoint) GetObservation() (map[string]any, error)

+ func (tr *ManagedPrivateEndpoint) GetParameters() (map[string]any, error)

+ func (tr *ManagedPrivateEndpoint) GetTerraformSchemaVersion() int

+ func (tr *ManagedPrivateEndpoint) LateInitialize(attrs []byte) (bool, error)

+ func (tr *ManagedPrivateEndpoint) SetObservation(obs map[string]any) error

+ func (tr *ManagedPrivateEndpoint) SetParameters(params map[string]any) error

+ type ManagedPrivateEndpointList struct

+ Items []ManagedPrivateEndpoint

+ func (in *ManagedPrivateEndpointList) DeepCopy() *ManagedPrivateEndpointList

+ func (in *ManagedPrivateEndpointList) DeepCopyInto(out *ManagedPrivateEndpointList)

+ func (in *ManagedPrivateEndpointList) DeepCopyObject() runtime.Object

+ func (l *ManagedPrivateEndpointList) GetItems() []resource.Managed

+ type ManagedPrivateEndpointObservation struct

+ ID *string

+ func (in *ManagedPrivateEndpointObservation) DeepCopy() *ManagedPrivateEndpointObservation

+ func (in *ManagedPrivateEndpointObservation) DeepCopyInto(out *ManagedPrivateEndpointObservation)

+ type ManagedPrivateEndpointParameters struct

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ StreamAnalyticsClusterName *string

+ StreamAnalyticsClusterNameRef *v1.Reference

+ StreamAnalyticsClusterNameSelector *v1.Selector

+ SubresourceName *string

+ TargetResourceID *string

+ TargetResourceIDRef *v1.Reference

+ TargetResourceIDSelector *v1.Selector

+ func (in *ManagedPrivateEndpointParameters) DeepCopy() *ManagedPrivateEndpointParameters

+ func (in *ManagedPrivateEndpointParameters) DeepCopyInto(out *ManagedPrivateEndpointParameters)

+ type ManagedPrivateEndpointSpec struct

+ ForProvider ManagedPrivateEndpointParameters

+ func (in *ManagedPrivateEndpointSpec) DeepCopy() *ManagedPrivateEndpointSpec

+ func (in *ManagedPrivateEndpointSpec) DeepCopyInto(out *ManagedPrivateEndpointSpec)

+ type ManagedPrivateEndpointStatus struct

+ AtProvider ManagedPrivateEndpointObservation

+ func (in *ManagedPrivateEndpointStatus) DeepCopy() *ManagedPrivateEndpointStatus

+ func (in *ManagedPrivateEndpointStatus) DeepCopyInto(out *ManagedPrivateEndpointStatus)

+ type OutputBlob struct

+ Spec OutputBlobSpec

+ Status OutputBlobStatus

+ func (in *OutputBlob) DeepCopy() *OutputBlob

+ func (in *OutputBlob) DeepCopyInto(out *OutputBlob)

+ func (in *OutputBlob) DeepCopyObject() runtime.Object

+ func (mg *OutputBlob) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *OutputBlob) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *OutputBlob) GetProviderConfigReference() *xpv1.Reference

+ func (mg *OutputBlob) GetProviderReference() *xpv1.Reference

+ func (mg *OutputBlob) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *OutputBlob) GetTerraformResourceType() string

+ func (mg *OutputBlob) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *OutputBlob) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *OutputBlob) SetConditions(c ...xpv1.Condition)

+ func (mg *OutputBlob) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *OutputBlob) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *OutputBlob) SetProviderReference(r *xpv1.Reference)

+ func (mg *OutputBlob) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *OutputBlob) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *OutputBlob) GetConnectionDetailsMapping() map[string]string

+ func (tr *OutputBlob) GetID() string

+ func (tr *OutputBlob) GetObservation() (map[string]any, error)

+ func (tr *OutputBlob) GetParameters() (map[string]any, error)

+ func (tr *OutputBlob) GetTerraformSchemaVersion() int

+ func (tr *OutputBlob) LateInitialize(attrs []byte) (bool, error)

+ func (tr *OutputBlob) SetObservation(obs map[string]any) error

+ func (tr *OutputBlob) SetParameters(params map[string]any) error

+ type OutputBlobList struct

+ Items []OutputBlob

+ func (in *OutputBlobList) DeepCopy() *OutputBlobList

+ func (in *OutputBlobList) DeepCopyInto(out *OutputBlobList)

+ func (in *OutputBlobList) DeepCopyObject() runtime.Object

+ func (l *OutputBlobList) GetItems() []resource.Managed

+ type OutputBlobObservation struct

+ ID *string

+ func (in *OutputBlobObservation) DeepCopy() *OutputBlobObservation

+ func (in *OutputBlobObservation) DeepCopyInto(out *OutputBlobObservation)

+ type OutputBlobParameters struct

+ BatchMaxWaitTime *string

+ BatchMinRows *float64

+ DateFormat *string

+ PathPattern *string

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ Serialization []SerializationParameters

+ StorageAccountKeySecretRef v1.SecretKeySelector

+ StorageAccountName *string

+ StorageAccountNameRef *v1.Reference

+ StorageAccountNameSelector *v1.Selector

+ StorageContainerName *string

+ StorageContainerNameRef *v1.Reference

+ StorageContainerNameSelector *v1.Selector

+ StreamAnalyticsJobName *string

+ TimeFormat *string

+ func (in *OutputBlobParameters) DeepCopy() *OutputBlobParameters

+ func (in *OutputBlobParameters) DeepCopyInto(out *OutputBlobParameters)

+ type OutputBlobSpec struct

+ ForProvider OutputBlobParameters

+ func (in *OutputBlobSpec) DeepCopy() *OutputBlobSpec

+ func (in *OutputBlobSpec) DeepCopyInto(out *OutputBlobSpec)

+ type OutputBlobStatus struct

+ AtProvider OutputBlobObservation

+ func (in *OutputBlobStatus) DeepCopy() *OutputBlobStatus

+ func (in *OutputBlobStatus) DeepCopyInto(out *OutputBlobStatus)

+ type OutputFunction struct

+ Spec OutputFunctionSpec

+ Status OutputFunctionStatus

+ func (in *OutputFunction) DeepCopy() *OutputFunction

+ func (in *OutputFunction) DeepCopyInto(out *OutputFunction)

+ func (in *OutputFunction) DeepCopyObject() runtime.Object

+ func (mg *OutputFunction) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *OutputFunction) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *OutputFunction) GetProviderConfigReference() *xpv1.Reference

+ func (mg *OutputFunction) GetProviderReference() *xpv1.Reference

+ func (mg *OutputFunction) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *OutputFunction) GetTerraformResourceType() string

+ func (mg *OutputFunction) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *OutputFunction) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *OutputFunction) SetConditions(c ...xpv1.Condition)

+ func (mg *OutputFunction) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *OutputFunction) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *OutputFunction) SetProviderReference(r *xpv1.Reference)

+ func (mg *OutputFunction) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *OutputFunction) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *OutputFunction) GetConnectionDetailsMapping() map[string]string

+ func (tr *OutputFunction) GetID() string

+ func (tr *OutputFunction) GetObservation() (map[string]any, error)

+ func (tr *OutputFunction) GetParameters() (map[string]any, error)

+ func (tr *OutputFunction) GetTerraformSchemaVersion() int

+ func (tr *OutputFunction) LateInitialize(attrs []byte) (bool, error)

+ func (tr *OutputFunction) SetObservation(obs map[string]any) error

+ func (tr *OutputFunction) SetParameters(params map[string]any) error

+ type OutputFunctionList struct

+ Items []OutputFunction

+ func (in *OutputFunctionList) DeepCopy() *OutputFunctionList

+ func (in *OutputFunctionList) DeepCopyInto(out *OutputFunctionList)

+ func (in *OutputFunctionList) DeepCopyObject() runtime.Object

+ func (l *OutputFunctionList) GetItems() []resource.Managed

+ type OutputFunctionObservation struct

+ ID *string

+ func (in *OutputFunctionObservation) DeepCopy() *OutputFunctionObservation

+ func (in *OutputFunctionObservation) DeepCopyInto(out *OutputFunctionObservation)

+ type OutputFunctionParameters struct

+ APIKeySecretRef v1.SecretKeySelector

+ BatchMaxCount *float64

+ BatchMaxInBytes *float64

+ FunctionApp *string

+ FunctionName *string

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ StreamAnalyticsJobName *string

+ StreamAnalyticsJobNameRef *v1.Reference

+ StreamAnalyticsJobNameSelector *v1.Selector

+ func (in *OutputFunctionParameters) DeepCopy() *OutputFunctionParameters

+ func (in *OutputFunctionParameters) DeepCopyInto(out *OutputFunctionParameters)

+ type OutputFunctionSpec struct

+ ForProvider OutputFunctionParameters

+ func (in *OutputFunctionSpec) DeepCopy() *OutputFunctionSpec

+ func (in *OutputFunctionSpec) DeepCopyInto(out *OutputFunctionSpec)

+ type OutputFunctionStatus struct

+ AtProvider OutputFunctionObservation

+ func (in *OutputFunctionStatus) DeepCopy() *OutputFunctionStatus

+ func (in *OutputFunctionStatus) DeepCopyInto(out *OutputFunctionStatus)

+ type OutputObservation struct

+ func (in *OutputObservation) DeepCopy() *OutputObservation

+ func (in *OutputObservation) DeepCopyInto(out *OutputObservation)

+ type OutputParameters struct

+ Type *string

+ func (in *OutputParameters) DeepCopy() *OutputParameters

+ func (in *OutputParameters) DeepCopyInto(out *OutputParameters)

+ type OutputSynapse struct

+ Spec OutputSynapseSpec

+ Status OutputSynapseStatus

+ func (in *OutputSynapse) DeepCopy() *OutputSynapse

+ func (in *OutputSynapse) DeepCopyInto(out *OutputSynapse)

+ func (in *OutputSynapse) DeepCopyObject() runtime.Object

+ func (mg *OutputSynapse) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *OutputSynapse) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *OutputSynapse) GetProviderConfigReference() *xpv1.Reference

+ func (mg *OutputSynapse) GetProviderReference() *xpv1.Reference

+ func (mg *OutputSynapse) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *OutputSynapse) GetTerraformResourceType() string

+ func (mg *OutputSynapse) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *OutputSynapse) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *OutputSynapse) SetConditions(c ...xpv1.Condition)

+ func (mg *OutputSynapse) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *OutputSynapse) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *OutputSynapse) SetProviderReference(r *xpv1.Reference)

+ func (mg *OutputSynapse) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *OutputSynapse) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *OutputSynapse) GetConnectionDetailsMapping() map[string]string

+ func (tr *OutputSynapse) GetID() string

+ func (tr *OutputSynapse) GetObservation() (map[string]any, error)

+ func (tr *OutputSynapse) GetParameters() (map[string]any, error)

+ func (tr *OutputSynapse) GetTerraformSchemaVersion() int

+ func (tr *OutputSynapse) LateInitialize(attrs []byte) (bool, error)

+ func (tr *OutputSynapse) SetObservation(obs map[string]any) error

+ func (tr *OutputSynapse) SetParameters(params map[string]any) error

+ type OutputSynapseList struct

+ Items []OutputSynapse

+ func (in *OutputSynapseList) DeepCopy() *OutputSynapseList

+ func (in *OutputSynapseList) DeepCopyInto(out *OutputSynapseList)

+ func (in *OutputSynapseList) DeepCopyObject() runtime.Object

+ func (l *OutputSynapseList) GetItems() []resource.Managed

+ type OutputSynapseObservation struct

+ ID *string

+ func (in *OutputSynapseObservation) DeepCopy() *OutputSynapseObservation

+ func (in *OutputSynapseObservation) DeepCopyInto(out *OutputSynapseObservation)

+ type OutputSynapseParameters struct

+ Database *string

+ PasswordSecretRef v1.SecretKeySelector

+ ResourceGroupName *string

+ ResourceGroupNameRef *v1.Reference

+ ResourceGroupNameSelector *v1.Selector

+ Server *string

+ StreamAnalyticsJobName *string

+ StreamAnalyticsJobNameRef *v1.Reference

+ StreamAnalyticsJobNameSelector *v1.Selector

+ Table *string

+ User *string

+ func (in *OutputSynapseParameters) DeepCopy() *OutputSynapseParameters

+ func (in *OutputSynapseParameters) DeepCopyInto(out *OutputSynapseParameters)

+ type OutputSynapseSpec struct

+ ForProvider OutputSynapseParameters

+ func (in *OutputSynapseSpec) DeepCopy() *OutputSynapseSpec

+ func (in *OutputSynapseSpec) DeepCopyInto(out *OutputSynapseSpec)

+ type OutputSynapseStatus struct

+ AtProvider OutputSynapseObservation

+ func (in *OutputSynapseStatus) DeepCopy() *OutputSynapseStatus

+ func (in *OutputSynapseStatus) DeepCopyInto(out *OutputSynapseStatus)

+ type SerializationObservation struct

+ func (in *SerializationObservation) DeepCopy() *SerializationObservation

+ func (in *SerializationObservation) DeepCopyInto(out *SerializationObservation)

+ type SerializationParameters struct

+ Encoding *string

+ FieldDelimiter *string

+ Format *string

+ Type *string

+ func (in *SerializationParameters) DeepCopy() *SerializationParameters

+ func (in *SerializationParameters) DeepCopyInto(out *SerializationParameters)