v1beta1

package
v0.33.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 9, 2023 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Overview

+kubebuilder:object:generate=true +groupName=streamanalytics.azure.upbound.io +versionName=v1beta1

Index

Constants

View Source 
const (
	CRDGroup   = "streamanalytics.azure.upbound.io"
	CRDVersion = "v1beta1"
)

Package type metadata.

Variables

View Source 
var (
	Cluster_Kind             = "Cluster"
	Cluster_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: Cluster_Kind}.String()
	Cluster_KindAPIVersion   = Cluster_Kind + "." + CRDGroupVersion.String()
	Cluster_GroupVersionKind = CRDGroupVersion.WithKind(Cluster_Kind)
)

Repository type metadata.

View Source 
var (
	FunctionJavascriptUda_Kind             = "FunctionJavascriptUda"
	FunctionJavascriptUda_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: FunctionJavascriptUda_Kind}.String()
	FunctionJavascriptUda_KindAPIVersion   = FunctionJavascriptUda_Kind + "." + CRDGroupVersion.String()
	FunctionJavascriptUda_GroupVersionKind = CRDGroupVersion.WithKind(FunctionJavascriptUda_Kind)
)

Repository type metadata.

View Source 
var (
	// CRDGroupVersion is the API Group Version used to register the objects
	CRDGroupVersion = schema.GroupVersion{Group: CRDGroup, Version: CRDVersion}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: CRDGroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var (
	Job_Kind             = "Job"
	Job_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: Job_Kind}.String()
	Job_KindAPIVersion   = Job_Kind + "." + CRDGroupVersion.String()
	Job_GroupVersionKind = CRDGroupVersion.WithKind(Job_Kind)
)

Repository type metadata.

View Source 
var (
	ManagedPrivateEndpoint_Kind             = "ManagedPrivateEndpoint"
	ManagedPrivateEndpoint_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: ManagedPrivateEndpoint_Kind}.String()
	ManagedPrivateEndpoint_KindAPIVersion   = ManagedPrivateEndpoint_Kind + "." + CRDGroupVersion.String()
	ManagedPrivateEndpoint_GroupVersionKind = CRDGroupVersion.WithKind(ManagedPrivateEndpoint_Kind)
)

Repository type metadata.

View Source 
var (
	OutputBlob_Kind             = "OutputBlob"
	OutputBlob_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: OutputBlob_Kind}.String()
	OutputBlob_KindAPIVersion   = OutputBlob_Kind + "." + CRDGroupVersion.String()
	OutputBlob_GroupVersionKind = CRDGroupVersion.WithKind(OutputBlob_Kind)
)

Repository type metadata.

View Source 
var (
	OutputEventHub_Kind             = "OutputEventHub"
	OutputEventHub_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: OutputEventHub_Kind}.String()
	OutputEventHub_KindAPIVersion   = OutputEventHub_Kind + "." + CRDGroupVersion.String()
	OutputEventHub_GroupVersionKind = CRDGroupVersion.WithKind(OutputEventHub_Kind)
)

Repository type metadata.

View Source 
var (
	OutputFunction_Kind             = "OutputFunction"
	OutputFunction_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: OutputFunction_Kind}.String()
	OutputFunction_KindAPIVersion   = OutputFunction_Kind + "." + CRDGroupVersion.String()
	OutputFunction_GroupVersionKind = CRDGroupVersion.WithKind(OutputFunction_Kind)
)

Repository type metadata.

View Source 
var (
	OutputMSSQL_Kind             = "OutputMSSQL"
	OutputMSSQL_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: OutputMSSQL_Kind}.String()
	OutputMSSQL_KindAPIVersion   = OutputMSSQL_Kind + "." + CRDGroupVersion.String()
	OutputMSSQL_GroupVersionKind = CRDGroupVersion.WithKind(OutputMSSQL_Kind)
)

Repository type metadata.

View Source 
var (
	OutputPowerBI_Kind             = "OutputPowerBI"
	OutputPowerBI_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: OutputPowerBI_Kind}.String()
	OutputPowerBI_KindAPIVersion   = OutputPowerBI_Kind + "." + CRDGroupVersion.String()
	OutputPowerBI_GroupVersionKind = CRDGroupVersion.WithKind(OutputPowerBI_Kind)
)

Repository type metadata.

View Source 
var (
	OutputServiceBusQueue_Kind             = "OutputServiceBusQueue"
	OutputServiceBusQueue_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: OutputServiceBusQueue_Kind}.String()
	OutputServiceBusQueue_KindAPIVersion   = OutputServiceBusQueue_Kind + "." + CRDGroupVersion.String()
	OutputServiceBusQueue_GroupVersionKind = CRDGroupVersion.WithKind(OutputServiceBusQueue_Kind)
)

Repository type metadata.

View Source 
var (
	OutputServiceBusTopic_Kind             = "OutputServiceBusTopic"
	OutputServiceBusTopic_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: OutputServiceBusTopic_Kind}.String()
	OutputServiceBusTopic_KindAPIVersion   = OutputServiceBusTopic_Kind + "." + CRDGroupVersion.String()
	OutputServiceBusTopic_GroupVersionKind = CRDGroupVersion.WithKind(OutputServiceBusTopic_Kind)
)

Repository type metadata.

View Source 
var (
	OutputSynapse_Kind             = "OutputSynapse"
	OutputSynapse_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: OutputSynapse_Kind}.String()
	OutputSynapse_KindAPIVersion   = OutputSynapse_Kind + "." + CRDGroupVersion.String()
	OutputSynapse_GroupVersionKind = CRDGroupVersion.WithKind(OutputSynapse_Kind)
)

Repository type metadata.

View Source 
var (
	OutputTable_Kind             = "OutputTable"
	OutputTable_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: OutputTable_Kind}.String()
	OutputTable_KindAPIVersion   = OutputTable_Kind + "." + CRDGroupVersion.String()
	OutputTable_GroupVersionKind = CRDGroupVersion.WithKind(OutputTable_Kind)
)

Repository type metadata.

View Source 
var (
	ReferenceInputBlob_Kind             = "ReferenceInputBlob"
	ReferenceInputBlob_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: ReferenceInputBlob_Kind}.String()
	ReferenceInputBlob_KindAPIVersion   = ReferenceInputBlob_Kind + "." + CRDGroupVersion.String()
	ReferenceInputBlob_GroupVersionKind = CRDGroupVersion.WithKind(ReferenceInputBlob_Kind)
)

Repository type metadata.

View Source 
var (
	ReferenceInputMSSQL_Kind             = "ReferenceInputMSSQL"
	ReferenceInputMSSQL_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: ReferenceInputMSSQL_Kind}.String()
	ReferenceInputMSSQL_KindAPIVersion   = ReferenceInputMSSQL_Kind + "." + CRDGroupVersion.String()
	ReferenceInputMSSQL_GroupVersionKind = CRDGroupVersion.WithKind(ReferenceInputMSSQL_Kind)
)

Repository type metadata.

View Source 
var (
	StreamInputBlob_Kind             = "StreamInputBlob"
	StreamInputBlob_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: StreamInputBlob_Kind}.String()
	StreamInputBlob_KindAPIVersion   = StreamInputBlob_Kind + "." + CRDGroupVersion.String()
	StreamInputBlob_GroupVersionKind = CRDGroupVersion.WithKind(StreamInputBlob_Kind)
)

Repository type metadata.

View Source 
var (
	StreamInputEventHub_Kind             = "StreamInputEventHub"
	StreamInputEventHub_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: StreamInputEventHub_Kind}.String()
	StreamInputEventHub_KindAPIVersion   = StreamInputEventHub_Kind + "." + CRDGroupVersion.String()
	StreamInputEventHub_GroupVersionKind = CRDGroupVersion.WithKind(StreamInputEventHub_Kind)
)

Repository type metadata.

View Source 
var (
	StreamInputIOTHub_Kind             = "StreamInputIOTHub"
	StreamInputIOTHub_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: StreamInputIOTHub_Kind}.String()
	StreamInputIOTHub_KindAPIVersion   = StreamInputIOTHub_Kind + "." + CRDGroupVersion.String()
	StreamInputIOTHub_GroupVersionKind = CRDGroupVersion.WithKind(StreamInputIOTHub_Kind)
)

Repository type metadata.

Functions

This section is empty.

Types

type Cluster 

type Cluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.location)",message="location is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.streamingCapacity)",message="streamingCapacity is a required parameter"
	Spec   ClusterSpec   `json:"spec"`
	Status ClusterStatus `json:"status,omitempty"`
}

Cluster is the Schema for the Clusters API. Manages a Stream Analytics Cluster. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*Cluster) DeepCopy 

func (in *Cluster) DeepCopy() *Cluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Cluster.

func (*Cluster) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Cluster) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Cluster) GetCondition 

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

GetCondition of this Cluster.

func (*Cluster) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this Cluster

func (*Cluster) GetDeletionPolicy 

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

GetDeletionPolicy of this Cluster.

func (*Cluster) GetID 

func (tr *Cluster) GetID() string

GetID returns ID of underlying Terraform resource of this Cluster

func (*Cluster) GetManagementPolicy added in v0.31.0 

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

GetManagementPolicy of this Cluster.

func (*Cluster) GetObservation 

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

GetObservation of this Cluster

func (*Cluster) GetParameters 

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

GetParameters of this Cluster

func (*Cluster) GetProviderConfigReference 

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

GetProviderConfigReference of this Cluster.

func (*Cluster) GetProviderReference 

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

GetProviderReference of this Cluster. Deprecated: Use GetProviderConfigReference.

func (*Cluster) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this Cluster.

func (*Cluster) GetTerraformResourceType 

func (mg *Cluster) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Cluster

func (*Cluster) GetTerraformSchemaVersion 

func (tr *Cluster) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Cluster) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this Cluster.

func (*Cluster) LateInitialize 

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

LateInitialize this Cluster using its observed tfState. returns True if there are any spec changes for the resource.

func (*Cluster) ResolveReferences 

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

ResolveReferences of this Cluster.

func (*Cluster) SetConditions 

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

SetConditions of this Cluster.

func (*Cluster) SetDeletionPolicy 

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

SetDeletionPolicy of this Cluster.

func (*Cluster) SetManagementPolicy added in v0.31.0 

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

SetManagementPolicy of this Cluster.

func (*Cluster) SetObservation 

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

SetObservation for this Cluster

func (*Cluster) SetParameters 

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

SetParameters for this Cluster

func (*Cluster) SetProviderConfigReference 

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

SetProviderConfigReference of this Cluster.

func (*Cluster) SetProviderReference 

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

SetProviderReference of this Cluster. Deprecated: Use SetProviderConfigReference.

func (*Cluster) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this Cluster.

func (*Cluster) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this Cluster.

type ClusterList 

type ClusterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Cluster `json:"items"`
}

ClusterList contains a list of Clusters

func (*ClusterList) DeepCopy 

func (in *ClusterList) DeepCopy() *ClusterList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterList.

func (*ClusterList) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ClusterList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*ClusterList) GetItems 

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

GetItems of this ClusterList.

type ClusterObservation 

type ClusterObservation struct {

	// The ID of the Stream Analytics.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The Azure Region where the Stream Analytics Cluster should exist. Changing this forces a new resource to be created.
	Location *string `json:"location,omitempty" tf:"location,omitempty"`

	// The name of the Resource Group where the Stream Analytics Cluster should exist. Changing this forces a new resource to be created.
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// The number of streaming units supported by the Cluster. Accepted values are multiples of 36 in the range of 36 to 216.
	StreamingCapacity *float64 `json:"streamingCapacity,omitempty" tf:"streaming_capacity,omitempty"`

	// A mapping of tags which should be assigned to the Stream Analytics.
	Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`
}

func (*ClusterObservation) DeepCopy 

func (in *ClusterObservation) DeepCopy() *ClusterObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterObservation.

func (*ClusterObservation) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterParameters 

type ClusterParameters struct {

	// The Azure Region where the Stream Analytics Cluster should exist. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Optional
	Location *string `json:"location,omitempty" tf:"location,omitempty"`

	// The name of the Resource Group where the Stream Analytics Cluster should exist. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/azure/v1beta1.ResourceGroup
	// +kubebuilder:validation:Optional
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// Reference to a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameRef *v1.Reference `json:"resourceGroupNameRef,omitempty" tf:"-"`

	// Selector for a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameSelector *v1.Selector `json:"resourceGroupNameSelector,omitempty" tf:"-"`

	// The number of streaming units supported by the Cluster. Accepted values are multiples of 36 in the range of 36 to 216.
	// +kubebuilder:validation:Optional
	StreamingCapacity *float64 `json:"streamingCapacity,omitempty" tf:"streaming_capacity,omitempty"`

	// A mapping of tags which should be assigned to the Stream Analytics.
	// +kubebuilder:validation:Optional
	Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`
}

func (*ClusterParameters) DeepCopy 

func (in *ClusterParameters) DeepCopy() *ClusterParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterParameters.

func (*ClusterParameters) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterSpec 

type ClusterSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     ClusterParameters `json:"forProvider"`
}

ClusterSpec defines the desired state of Cluster

func (*ClusterSpec) DeepCopy 

func (in *ClusterSpec) DeepCopy() *ClusterSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpec.

func (*ClusterSpec) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterStatus 

type ClusterStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        ClusterObservation `json:"atProvider,omitempty"`
}

ClusterStatus defines the observed state of Cluster.

func (*ClusterStatus) DeepCopy 

func (in *ClusterStatus) DeepCopy() *ClusterStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterStatus.

func (*ClusterStatus) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FunctionJavascriptUda 

type FunctionJavascriptUda struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.input)",message="input is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.output)",message="output is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.script)",message="script is a required parameter"
	Spec   FunctionJavascriptUdaSpec   `json:"spec"`
	Status FunctionJavascriptUdaStatus `json:"status,omitempty"`
}

FunctionJavascriptUda is the Schema for the FunctionJavascriptUdas API. Manages a JavaScript UDA Function within a Stream Analytics Streaming Job. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*FunctionJavascriptUda) DeepCopy 

func (in *FunctionJavascriptUda) DeepCopy() *FunctionJavascriptUda

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FunctionJavascriptUda.

func (*FunctionJavascriptUda) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*FunctionJavascriptUda) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*FunctionJavascriptUda) GetCondition 

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

GetCondition of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this FunctionJavascriptUda

func (*FunctionJavascriptUda) GetDeletionPolicy 

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

GetDeletionPolicy of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) GetID 

func (tr *FunctionJavascriptUda) GetID() string

GetID returns ID of underlying Terraform resource of this FunctionJavascriptUda

func (*FunctionJavascriptUda) GetManagementPolicy added in v0.31.0 

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

GetManagementPolicy of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) GetObservation 

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

GetObservation of this FunctionJavascriptUda

func (*FunctionJavascriptUda) GetParameters 

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

GetParameters of this FunctionJavascriptUda

func (*FunctionJavascriptUda) GetProviderConfigReference 

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

GetProviderConfigReference of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) GetProviderReference 

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

GetProviderReference of this FunctionJavascriptUda. Deprecated: Use GetProviderConfigReference.

func (*FunctionJavascriptUda) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) GetTerraformResourceType 

func (mg *FunctionJavascriptUda) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this FunctionJavascriptUda

func (*FunctionJavascriptUda) GetTerraformSchemaVersion 

func (tr *FunctionJavascriptUda) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*FunctionJavascriptUda) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) LateInitialize 

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

LateInitialize this FunctionJavascriptUda using its observed tfState. returns True if there are any spec changes for the resource.

func (*FunctionJavascriptUda) ResolveReferences added in v0.26.0 

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

ResolveReferences of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) SetConditions 

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

SetConditions of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) SetDeletionPolicy 

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

SetDeletionPolicy of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) SetManagementPolicy added in v0.31.0 

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

SetManagementPolicy of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) SetObservation 

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

SetObservation for this FunctionJavascriptUda

func (*FunctionJavascriptUda) SetParameters 

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

SetParameters for this FunctionJavascriptUda

func (*FunctionJavascriptUda) SetProviderConfigReference 

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

SetProviderConfigReference of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) SetProviderReference 

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

SetProviderReference of this FunctionJavascriptUda. Deprecated: Use SetProviderConfigReference.

func (*FunctionJavascriptUda) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this FunctionJavascriptUda.

type FunctionJavascriptUdaList 

type FunctionJavascriptUdaList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []FunctionJavascriptUda `json:"items"`
}

FunctionJavascriptUdaList contains a list of FunctionJavascriptUdas

func (*FunctionJavascriptUdaList) DeepCopy 

func (in *FunctionJavascriptUdaList) DeepCopy() *FunctionJavascriptUdaList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FunctionJavascriptUdaList.

func (*FunctionJavascriptUdaList) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*FunctionJavascriptUdaList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*FunctionJavascriptUdaList) GetItems 

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

GetItems of this FunctionJavascriptUdaList.

type FunctionJavascriptUdaObservation 

type FunctionJavascriptUdaObservation struct {

	// The ID of the Stream Analytics JavaScript UDA Function.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// One or more input blocks as defined below.
	Input []InputObservation `json:"input,omitempty" tf:"input,omitempty"`

	// An output block as defined below.
	Output []OutputObservation `json:"output,omitempty" tf:"output,omitempty"`

	// The JavaScript of this UDA Function.
	Script *string `json:"script,omitempty" tf:"script,omitempty"`

	// The resource ID of the Stream Analytics Job where this Function should be created. Changing this forces a new resource to be created.
	StreamAnalyticsJobID *string `json:"streamAnalyticsJobId,omitempty" tf:"stream_analytics_job_id,omitempty"`
}

func (*FunctionJavascriptUdaObservation) DeepCopy 

func (in *FunctionJavascriptUdaObservation) DeepCopy() *FunctionJavascriptUdaObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FunctionJavascriptUdaObservation.

func (*FunctionJavascriptUdaObservation) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FunctionJavascriptUdaParameters 

type FunctionJavascriptUdaParameters struct {

	// One or more input blocks as defined below.
	// +kubebuilder:validation:Optional
	Input []InputParameters `json:"input,omitempty" tf:"input,omitempty"`

	// An output block as defined below.
	// +kubebuilder:validation:Optional
	Output []OutputParameters `json:"output,omitempty" tf:"output,omitempty"`

	// The JavaScript of this UDA Function.
	// +kubebuilder:validation:Optional
	Script *string `json:"script,omitempty" tf:"script,omitempty"`

	// The resource ID of the Stream Analytics Job where this Function should be created. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=Job
	// +crossplane:generate:reference:extractor=github.com/upbound/provider-azure/apis/rconfig.ExtractResourceID()
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobID *string `json:"streamAnalyticsJobId,omitempty" tf:"stream_analytics_job_id,omitempty"`

	// Reference to a Job to populate streamAnalyticsJobId.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobIDRef *v1.Reference `json:"streamAnalyticsJobIdRef,omitempty" tf:"-"`

	// Selector for a Job to populate streamAnalyticsJobId.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobIDSelector *v1.Selector `json:"streamAnalyticsJobIdSelector,omitempty" tf:"-"`
}

func (*FunctionJavascriptUdaParameters) DeepCopy 

func (in *FunctionJavascriptUdaParameters) DeepCopy() *FunctionJavascriptUdaParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FunctionJavascriptUdaParameters.

func (*FunctionJavascriptUdaParameters) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FunctionJavascriptUdaSpec 

type FunctionJavascriptUdaSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     FunctionJavascriptUdaParameters `json:"forProvider"`
}

FunctionJavascriptUdaSpec defines the desired state of FunctionJavascriptUda

func (*FunctionJavascriptUdaSpec) DeepCopy 

func (in *FunctionJavascriptUdaSpec) DeepCopy() *FunctionJavascriptUdaSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FunctionJavascriptUdaSpec.

func (*FunctionJavascriptUdaSpec) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FunctionJavascriptUdaStatus 

type FunctionJavascriptUdaStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        FunctionJavascriptUdaObservation `json:"atProvider,omitempty"`
}

FunctionJavascriptUdaStatus defines the observed state of FunctionJavascriptUda.

func (*FunctionJavascriptUdaStatus) DeepCopy 

func (in *FunctionJavascriptUdaStatus) DeepCopy() *FunctionJavascriptUdaStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FunctionJavascriptUdaStatus.

func (*FunctionJavascriptUdaStatus) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type IdentityObservation 

type IdentityObservation struct {

	// The Principal ID associated with this Managed Service Identity.
	PrincipalID *string `json:"principalId,omitempty" tf:"principal_id,omitempty"`

	// The Tenant ID associated with this Managed Service Identity.
	TenantID *string `json:"tenantId,omitempty" tf:"tenant_id,omitempty"`

	// Specifies the type of Managed Service Identity that should be configured on this Stream Analytics Job. The only possible value is SystemAssigned.
	Type *string `json:"type,omitempty" tf:"type,omitempty"`
}

func (*IdentityObservation) DeepCopy 

func (in *IdentityObservation) DeepCopy() *IdentityObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IdentityObservation.

func (*IdentityObservation) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type IdentityParameters 

type IdentityParameters struct {

	// Specifies the type of Managed Service Identity that should be configured on this Stream Analytics Job. The only possible value is SystemAssigned.
	// +kubebuilder:validation:Required
	Type *string `json:"type" tf:"type,omitempty"`
}

func (*IdentityParameters) DeepCopy 

func (in *IdentityParameters) DeepCopy() *IdentityParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IdentityParameters.

func (*IdentityParameters) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type InputObservation 

type InputObservation struct {

	// Is this input parameter a configuration parameter? Defaults to false.
	ConfigurationParameter *bool `json:"configurationParameter,omitempty" tf:"configuration_parameter,omitempty"`

	// The input data type of this JavaScript Function. Possible values include any, array, bigint, datetime, float, nvarchar(max) and record.
	Type *string `json:"type,omitempty" tf:"type,omitempty"`
}

func (*InputObservation) DeepCopy 

func (in *InputObservation) DeepCopy() *InputObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InputObservation.

func (*InputObservation) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type InputParameters 

type InputParameters struct {

	// Is this input parameter a configuration parameter? Defaults to false.
	// +kubebuilder:validation:Optional
	ConfigurationParameter *bool `json:"configurationParameter,omitempty" tf:"configuration_parameter,omitempty"`

	// The input data type of this JavaScript Function. Possible values include any, array, bigint, datetime, float, nvarchar(max) and record.
	// +kubebuilder:validation:Required
	Type *string `json:"type" tf:"type,omitempty"`
}

func (*InputParameters) DeepCopy 

func (in *InputParameters) DeepCopy() *InputParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InputParameters.

func (*InputParameters) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Job 

type Job struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.location)",message="location is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.transformationQuery)",message="transformationQuery is a required parameter"
	Spec   JobSpec   `json:"spec"`
	Status JobStatus `json:"status,omitempty"`
}

Job is the Schema for the Jobs API. Manages a Stream Analytics Job. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*Job) DeepCopy 

func (in *Job) DeepCopy() *Job

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Job.

func (*Job) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Job) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Job) GetCondition 

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

GetCondition of this Job.

func (*Job) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this Job

func (*Job) GetDeletionPolicy 

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

GetDeletionPolicy of this Job.

func (*Job) GetID 

func (tr *Job) GetID() string

GetID returns ID of underlying Terraform resource of this Job

func (*Job) GetManagementPolicy added in v0.31.0 

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

GetManagementPolicy of this Job.

func (*Job) GetObservation 

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

GetObservation of this Job

func (*Job) GetParameters 

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

GetParameters of this Job

func (*Job) GetProviderConfigReference 

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

GetProviderConfigReference of this Job.

func (*Job) GetProviderReference 

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

GetProviderReference of this Job. Deprecated: Use GetProviderConfigReference.

func (*Job) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this Job.

func (*Job) GetTerraformResourceType 

func (mg *Job) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Job

func (*Job) GetTerraformSchemaVersion 

func (tr *Job) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Job) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this Job.

func (*Job) LateInitialize 

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

LateInitialize this Job using its observed tfState. returns True if there are any spec changes for the resource.

func (*Job) ResolveReferences 

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

ResolveReferences of this Job.

func (*Job) SetConditions 

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

SetConditions of this Job.

func (*Job) SetDeletionPolicy 

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

SetDeletionPolicy of this Job.

func (*Job) SetManagementPolicy added in v0.31.0 

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

SetManagementPolicy of this Job.

func (*Job) SetObservation 

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

SetObservation for this Job

func (*Job) SetParameters 

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

SetParameters for this Job

func (*Job) SetProviderConfigReference 

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

SetProviderConfigReference of this Job.

func (*Job) SetProviderReference 

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

SetProviderReference of this Job. Deprecated: Use SetProviderConfigReference.

func (*Job) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this Job.

func (*Job) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this Job.

type JobList 

type JobList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Job `json:"items"`
}

JobList contains a list of Jobs

func (*JobList) DeepCopy 

func (in *JobList) DeepCopy() *JobList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobList.

func (*JobList) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*JobList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*JobList) GetItems 

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

GetItems of this JobList.

type JobObservation 

type JobObservation struct {

	// Specifies the compatibility level for this job - which controls certain runtime behaviours of the streaming job. Possible values are 1.0, 1.1 and 1.2.
	CompatibilityLevel *string `json:"compatibilityLevel,omitempty" tf:"compatibility_level,omitempty"`

	// The policy for storing stream analytics content. Possible values are JobStorageAccount, SystemAccount.
	ContentStoragePolicy *string `json:"contentStoragePolicy,omitempty" tf:"content_storage_policy,omitempty"`

	// Specifies the Data Locale of the Job, which should be a supported .NET Culture.
	DataLocale *string `json:"dataLocale,omitempty" tf:"data_locale,omitempty"`

	// Specifies the maximum tolerable delay in seconds where events arriving late could be included. Supported range is -1 (indefinite) to 1814399 (20d 23h 59m 59s). Default is 0.
	EventsLateArrivalMaxDelayInSeconds *float64 `json:"eventsLateArrivalMaxDelayInSeconds,omitempty" tf:"events_late_arrival_max_delay_in_seconds,omitempty"`

	// Specifies the maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order. Supported range is 0 to 599 (9m 59s). Default is 5.
	EventsOutOfOrderMaxDelayInSeconds *float64 `json:"eventsOutOfOrderMaxDelayInSeconds,omitempty" tf:"events_out_of_order_max_delay_in_seconds,omitempty"`

	// Specifies the policy which should be applied to events which arrive out of order in the input event stream. Possible values are Adjust and Drop. Default is Adjust.
	EventsOutOfOrderPolicy *string `json:"eventsOutOfOrderPolicy,omitempty" tf:"events_out_of_order_policy,omitempty"`

	// The ID of the Stream Analytics Job.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// An identity block as defined below.
	Identity []IdentityObservation `json:"identity,omitempty" tf:"identity,omitempty"`

	// The Job ID assigned by the Stream Analytics Job.
	JobID *string `json:"jobId,omitempty" tf:"job_id,omitempty"`

	// The details of the job storage account. A job_storage_account block as defined below.
	JobStorageAccount []JobStorageAccountObservation `json:"jobStorageAccount,omitempty" tf:"job_storage_account,omitempty"`

	// The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.
	Location *string `json:"location,omitempty" tf:"location,omitempty"`

	// Specifies the policy which should be applied to events which arrive at the output and cannot be written to the external storage due to being malformed (such as missing column values, column values of wrong type or size). Possible values are Drop and Stop. Default is Drop.
	OutputErrorPolicy *string `json:"outputErrorPolicy,omitempty" tf:"output_error_policy,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// The ID of an existing Stream Analytics Cluster where the Stream Analytics Job should run.
	StreamAnalyticsClusterID *string `json:"streamAnalyticsClusterId,omitempty" tf:"stream_analytics_cluster_id,omitempty"`

	// Specifies the number of streaming units that the streaming job uses. Supported values are 1, 3, 6 and multiples of 6 up to 120.
	StreamingUnits *float64 `json:"streamingUnits,omitempty" tf:"streaming_units,omitempty"`

	// A mapping of tags assigned to the resource.
	Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`

	// Specifies the query that will be run in the streaming job, written in Stream Analytics Query Language (SAQL).
	TransformationQuery *string `json:"transformationQuery,omitempty" tf:"transformation_query,omitempty"`

	// The type of the Stream Analytics Job. Possible values are Cloud and Edge. Defaults to Cloud. Changing this forces a new resource to be created.
	Type *string `json:"type,omitempty" tf:"type,omitempty"`
}

func (*JobObservation) DeepCopy 

func (in *JobObservation) DeepCopy() *JobObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobObservation.

func (*JobObservation) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type JobParameters 

type JobParameters struct {

	// Specifies the compatibility level for this job - which controls certain runtime behaviours of the streaming job. Possible values are 1.0, 1.1 and 1.2.
	// +kubebuilder:validation:Optional
	CompatibilityLevel *string `json:"compatibilityLevel,omitempty" tf:"compatibility_level,omitempty"`

	// The policy for storing stream analytics content. Possible values are JobStorageAccount, SystemAccount.
	// +kubebuilder:validation:Optional
	ContentStoragePolicy *string `json:"contentStoragePolicy,omitempty" tf:"content_storage_policy,omitempty"`

	// Specifies the Data Locale of the Job, which should be a supported .NET Culture.
	// +kubebuilder:validation:Optional
	DataLocale *string `json:"dataLocale,omitempty" tf:"data_locale,omitempty"`

	// Specifies the maximum tolerable delay in seconds where events arriving late could be included. Supported range is -1 (indefinite) to 1814399 (20d 23h 59m 59s). Default is 0.
	// +kubebuilder:validation:Optional
	EventsLateArrivalMaxDelayInSeconds *float64 `json:"eventsLateArrivalMaxDelayInSeconds,omitempty" tf:"events_late_arrival_max_delay_in_seconds,omitempty"`

	// Specifies the maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order. Supported range is 0 to 599 (9m 59s). Default is 5.
	// +kubebuilder:validation:Optional
	EventsOutOfOrderMaxDelayInSeconds *float64 `json:"eventsOutOfOrderMaxDelayInSeconds,omitempty" tf:"events_out_of_order_max_delay_in_seconds,omitempty"`

	// Specifies the policy which should be applied to events which arrive out of order in the input event stream. Possible values are Adjust and Drop. Default is Adjust.
	// +kubebuilder:validation:Optional
	EventsOutOfOrderPolicy *string `json:"eventsOutOfOrderPolicy,omitempty" tf:"events_out_of_order_policy,omitempty"`

	// An identity block as defined below.
	// +kubebuilder:validation:Optional
	Identity []IdentityParameters `json:"identity,omitempty" tf:"identity,omitempty"`

	// The details of the job storage account. A job_storage_account block as defined below.
	// +kubebuilder:validation:Optional
	JobStorageAccount []JobStorageAccountParameters `json:"jobStorageAccount,omitempty" tf:"job_storage_account,omitempty"`

	// The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Optional
	Location *string `json:"location,omitempty" tf:"location,omitempty"`

	// Specifies the policy which should be applied to events which arrive at the output and cannot be written to the external storage due to being malformed (such as missing column values, column values of wrong type or size). Possible values are Drop and Stop. Default is Drop.
	// +kubebuilder:validation:Optional
	OutputErrorPolicy *string `json:"outputErrorPolicy,omitempty" tf:"output_error_policy,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/azure/v1beta1.ResourceGroup
	// +kubebuilder:validation:Optional
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// Reference to a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameRef *v1.Reference `json:"resourceGroupNameRef,omitempty" tf:"-"`

	// Selector for a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameSelector *v1.Selector `json:"resourceGroupNameSelector,omitempty" tf:"-"`

	// The ID of an existing Stream Analytics Cluster where the Stream Analytics Job should run.
	// +kubebuilder:validation:Optional
	StreamAnalyticsClusterID *string `json:"streamAnalyticsClusterId,omitempty" tf:"stream_analytics_cluster_id,omitempty"`

	// Specifies the number of streaming units that the streaming job uses. Supported values are 1, 3, 6 and multiples of 6 up to 120.
	// +kubebuilder:validation:Optional
	StreamingUnits *float64 `json:"streamingUnits,omitempty" tf:"streaming_units,omitempty"`

	// A mapping of tags assigned to the resource.
	// +kubebuilder:validation:Optional
	Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`

	// Specifies the query that will be run in the streaming job, written in Stream Analytics Query Language (SAQL).
	// +kubebuilder:validation:Optional
	TransformationQuery *string `json:"transformationQuery,omitempty" tf:"transformation_query,omitempty"`

	// The type of the Stream Analytics Job. Possible values are Cloud and Edge. Defaults to Cloud. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Optional
	Type *string `json:"type,omitempty" tf:"type,omitempty"`
}

func (*JobParameters) DeepCopy 

func (in *JobParameters) DeepCopy() *JobParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobParameters.

func (*JobParameters) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type JobSpec 

type JobSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     JobParameters `json:"forProvider"`
}

JobSpec defines the desired state of Job

func (*JobSpec) DeepCopy 

func (in *JobSpec) DeepCopy() *JobSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobSpec.

func (*JobSpec) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type JobStatus 

type JobStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        JobObservation `json:"atProvider,omitempty"`
}

JobStatus defines the observed state of Job.

func (*JobStatus) DeepCopy 

func (in *JobStatus) DeepCopy() *JobStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobStatus.

func (*JobStatus) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type JobStorageAccountObservation added in v0.26.0 

type JobStorageAccountObservation struct {

	// The name of the Azure storage account.
	AccountName *string `json:"accountName,omitempty" tf:"account_name,omitempty"`

	// The authentication mode of the storage account. The only supported value is ConnectionString. Defaults to ConnectionString.
	AuthenticationMode *string `json:"authenticationMode,omitempty" tf:"authentication_mode,omitempty"`
}

func (*JobStorageAccountObservation) DeepCopy added in v0.26.0 

func (in *JobStorageAccountObservation) DeepCopy() *JobStorageAccountObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobStorageAccountObservation.

func (*JobStorageAccountObservation) DeepCopyInto added in v0.26.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type JobStorageAccountParameters added in v0.26.0 

type JobStorageAccountParameters struct {

	// The account key for the Azure storage account.
	// +kubebuilder:validation:Required
	AccountKeySecretRef v1.SecretKeySelector `json:"accountKeySecretRef" tf:"-"`

	// The name of the Azure storage account.
	// +kubebuilder:validation:Required
	AccountName *string `json:"accountName" tf:"account_name,omitempty"`

	// The authentication mode of the storage account. The only supported value is ConnectionString. Defaults to ConnectionString.
	// +kubebuilder:validation:Optional
	AuthenticationMode *string `json:"authenticationMode,omitempty" tf:"authentication_mode,omitempty"`
}

func (*JobStorageAccountParameters) DeepCopy added in v0.26.0 

func (in *JobStorageAccountParameters) DeepCopy() *JobStorageAccountParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobStorageAccountParameters.

func (*JobStorageAccountParameters) DeepCopyInto added in v0.26.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ManagedPrivateEndpoint 

type ManagedPrivateEndpoint struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.subresourceName)",message="subresourceName is a required parameter"
	Spec   ManagedPrivateEndpointSpec   `json:"spec"`
	Status ManagedPrivateEndpointStatus `json:"status,omitempty"`
}

ManagedPrivateEndpoint is the Schema for the ManagedPrivateEndpoints API. Manages a Stream Analytics Managed Private Endpoint. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*ManagedPrivateEndpoint) DeepCopy 

func (in *ManagedPrivateEndpoint) DeepCopy() *ManagedPrivateEndpoint

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ManagedPrivateEndpoint) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*ManagedPrivateEndpoint) GetCondition 

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

GetCondition of this ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this ManagedPrivateEndpoint

func (*ManagedPrivateEndpoint) GetDeletionPolicy 

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

GetDeletionPolicy of this ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) GetID 

func (tr *ManagedPrivateEndpoint) GetID() string

GetID returns ID of underlying Terraform resource of this ManagedPrivateEndpoint

func (*ManagedPrivateEndpoint) GetManagementPolicy added in v0.31.0 

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

GetManagementPolicy of this ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) GetObservation 

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

GetObservation of this ManagedPrivateEndpoint

func (*ManagedPrivateEndpoint) GetParameters 

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

GetParameters of this ManagedPrivateEndpoint

func (*ManagedPrivateEndpoint) GetProviderConfigReference 

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

GetProviderConfigReference of this ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) GetProviderReference 

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

GetProviderReference of this ManagedPrivateEndpoint. Deprecated: Use GetProviderConfigReference.

func (*ManagedPrivateEndpoint) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) GetTerraformResourceType 

func (mg *ManagedPrivateEndpoint) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this ManagedPrivateEndpoint

func (*ManagedPrivateEndpoint) GetTerraformSchemaVersion 

func (tr *ManagedPrivateEndpoint) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*ManagedPrivateEndpoint) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) LateInitialize 

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

LateInitialize this ManagedPrivateEndpoint using its observed tfState. returns True if there are any spec changes for the resource.

func (*ManagedPrivateEndpoint) ResolveReferences 

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

ResolveReferences of this ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) SetConditions 

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

SetConditions of this ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) SetDeletionPolicy 

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

SetDeletionPolicy of this ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) SetManagementPolicy added in v0.31.0 

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

SetManagementPolicy of this ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) SetObservation 

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

SetObservation for this ManagedPrivateEndpoint

func (*ManagedPrivateEndpoint) SetParameters 

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

SetParameters for this ManagedPrivateEndpoint

func (*ManagedPrivateEndpoint) SetProviderConfigReference 

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

SetProviderConfigReference of this ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) SetProviderReference 

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

SetProviderReference of this ManagedPrivateEndpoint. Deprecated: Use SetProviderConfigReference.

func (*ManagedPrivateEndpoint) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this ManagedPrivateEndpoint.

type ManagedPrivateEndpointList 

type ManagedPrivateEndpointList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []ManagedPrivateEndpoint `json:"items"`
}

ManagedPrivateEndpointList contains a list of ManagedPrivateEndpoints

func (*ManagedPrivateEndpointList) DeepCopy 

func (in *ManagedPrivateEndpointList) DeepCopy() *ManagedPrivateEndpointList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ManagedPrivateEndpointList.

func (*ManagedPrivateEndpointList) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ManagedPrivateEndpointList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*ManagedPrivateEndpointList) GetItems 

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

GetItems of this ManagedPrivateEndpointList.

type ManagedPrivateEndpointObservation 

type ManagedPrivateEndpointObservation struct {

	// The ID of the Stream Analytics.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The name of the Resource Group where the Stream Analytics Managed Private Endpoint should exist. Changing this forces a new resource to be created.
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// The name of the Stream Analytics Cluster where the Managed Private Endpoint should be created. Changing this forces a new resource to be created.
	StreamAnalyticsClusterName *string `json:"streamAnalyticsClusterName,omitempty" tf:"stream_analytics_cluster_name,omitempty"`

	// Specifies the sub resource name which the Stream Analytics Private Endpoint is able to connect to. Changing this forces a new resource to be created.
	SubresourceName *string `json:"subresourceName,omitempty" tf:"subresource_name,omitempty"`

	// The ID of the Private Link Enabled Remote Resource which this Stream Analytics Private endpoint should be connected to. Changing this forces a new resource to be created.
	TargetResourceID *string `json:"targetResourceId,omitempty" tf:"target_resource_id,omitempty"`
}

func (*ManagedPrivateEndpointObservation) DeepCopy 

func (in *ManagedPrivateEndpointObservation) DeepCopy() *ManagedPrivateEndpointObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ManagedPrivateEndpointObservation.

func (*ManagedPrivateEndpointObservation) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ManagedPrivateEndpointParameters 

type ManagedPrivateEndpointParameters struct {

	// The name of the Resource Group where the Stream Analytics Managed Private Endpoint should exist. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/azure/v1beta1.ResourceGroup
	// +kubebuilder:validation:Optional
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// Reference to a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameRef *v1.Reference `json:"resourceGroupNameRef,omitempty" tf:"-"`

	// Selector for a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameSelector *v1.Selector `json:"resourceGroupNameSelector,omitempty" tf:"-"`

	// The name of the Stream Analytics Cluster where the Managed Private Endpoint should be created. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/streamanalytics/v1beta1.Cluster
	// +kubebuilder:validation:Optional
	StreamAnalyticsClusterName *string `json:"streamAnalyticsClusterName,omitempty" tf:"stream_analytics_cluster_name,omitempty"`

	// Reference to a Cluster in streamanalytics to populate streamAnalyticsClusterName.
	// +kubebuilder:validation:Optional
	StreamAnalyticsClusterNameRef *v1.Reference `json:"streamAnalyticsClusterNameRef,omitempty" tf:"-"`

	// Selector for a Cluster in streamanalytics to populate streamAnalyticsClusterName.
	// +kubebuilder:validation:Optional
	StreamAnalyticsClusterNameSelector *v1.Selector `json:"streamAnalyticsClusterNameSelector,omitempty" tf:"-"`

	// Specifies the sub resource name which the Stream Analytics Private Endpoint is able to connect to. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Optional
	SubresourceName *string `json:"subresourceName,omitempty" tf:"subresource_name,omitempty"`

	// The ID of the Private Link Enabled Remote Resource which this Stream Analytics Private endpoint should be connected to. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/storage/v1beta1.Account
	// +crossplane:generate:reference:extractor=github.com/upbound/upjet/pkg/resource.ExtractResourceID()
	// +kubebuilder:validation:Optional
	TargetResourceID *string `json:"targetResourceId,omitempty" tf:"target_resource_id,omitempty"`

	// Reference to a Account in storage to populate targetResourceId.
	// +kubebuilder:validation:Optional
	TargetResourceIDRef *v1.Reference `json:"targetResourceIdRef,omitempty" tf:"-"`

	// Selector for a Account in storage to populate targetResourceId.
	// +kubebuilder:validation:Optional
	TargetResourceIDSelector *v1.Selector `json:"targetResourceIdSelector,omitempty" tf:"-"`
}

func (*ManagedPrivateEndpointParameters) DeepCopy 

func (in *ManagedPrivateEndpointParameters) DeepCopy() *ManagedPrivateEndpointParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ManagedPrivateEndpointParameters.

func (*ManagedPrivateEndpointParameters) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ManagedPrivateEndpointSpec 

type ManagedPrivateEndpointSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     ManagedPrivateEndpointParameters `json:"forProvider"`
}

ManagedPrivateEndpointSpec defines the desired state of ManagedPrivateEndpoint

func (*ManagedPrivateEndpointSpec) DeepCopy 

func (in *ManagedPrivateEndpointSpec) DeepCopy() *ManagedPrivateEndpointSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ManagedPrivateEndpointSpec.

func (*ManagedPrivateEndpointSpec) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ManagedPrivateEndpointStatus 

type ManagedPrivateEndpointStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        ManagedPrivateEndpointObservation `json:"atProvider,omitempty"`
}

ManagedPrivateEndpointStatus defines the observed state of ManagedPrivateEndpoint.

func (*ManagedPrivateEndpointStatus) DeepCopy 

func (in *ManagedPrivateEndpointStatus) DeepCopy() *ManagedPrivateEndpointStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ManagedPrivateEndpointStatus.

func (*ManagedPrivateEndpointStatus) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputBlob 

type OutputBlob struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.dateFormat)",message="dateFormat is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.pathPattern)",message="pathPattern is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.serialization)",message="serialization is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.timeFormat)",message="timeFormat is a required parameter"
	Spec   OutputBlobSpec   `json:"spec"`
	Status OutputBlobStatus `json:"status,omitempty"`
}

OutputBlob is the Schema for the OutputBlobs API. Manages a Stream Analytics Output to Blob Storage. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*OutputBlob) DeepCopy 

func (in *OutputBlob) DeepCopy() *OutputBlob

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputBlob.

func (*OutputBlob) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OutputBlob) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*OutputBlob) GetCondition 

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

GetCondition of this OutputBlob.

func (*OutputBlob) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this OutputBlob

func (*OutputBlob) GetDeletionPolicy 

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

GetDeletionPolicy of this OutputBlob.

func (*OutputBlob) GetID 

func (tr *OutputBlob) GetID() string

GetID returns ID of underlying Terraform resource of this OutputBlob

func (*OutputBlob) GetManagementPolicy added in v0.31.0 

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

GetManagementPolicy of this OutputBlob.

func (*OutputBlob) GetObservation 

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

GetObservation of this OutputBlob

func (*OutputBlob) GetParameters 

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

GetParameters of this OutputBlob

func (*OutputBlob) GetProviderConfigReference 

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

GetProviderConfigReference of this OutputBlob.

func (*OutputBlob) GetProviderReference 

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

GetProviderReference of this OutputBlob. Deprecated: Use GetProviderConfigReference.

func (*OutputBlob) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this OutputBlob.

func (*OutputBlob) GetTerraformResourceType 

func (mg *OutputBlob) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this OutputBlob

func (*OutputBlob) GetTerraformSchemaVersion 

func (tr *OutputBlob) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*OutputBlob) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this OutputBlob.

func (*OutputBlob) LateInitialize 

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

LateInitialize this OutputBlob using its observed tfState. returns True if there are any spec changes for the resource.

func (*OutputBlob) ResolveReferences 

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

ResolveReferences of this OutputBlob.

func (*OutputBlob) SetConditions 

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

SetConditions of this OutputBlob.

func (*OutputBlob) SetDeletionPolicy 

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

SetDeletionPolicy of this OutputBlob.

func (*OutputBlob) SetManagementPolicy added in v0.31.0 

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

SetManagementPolicy of this OutputBlob.

func (*OutputBlob) SetObservation 

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

SetObservation for this OutputBlob

func (*OutputBlob) SetParameters 

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

SetParameters for this OutputBlob

func (*OutputBlob) SetProviderConfigReference 

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

SetProviderConfigReference of this OutputBlob.

func (*OutputBlob) SetProviderReference 

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

SetProviderReference of this OutputBlob. Deprecated: Use SetProviderConfigReference.

func (*OutputBlob) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this OutputBlob.

func (*OutputBlob) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this OutputBlob.

type OutputBlobList 

type OutputBlobList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []OutputBlob `json:"items"`
}

OutputBlobList contains a list of OutputBlobs

func (*OutputBlobList) DeepCopy 

func (in *OutputBlobList) DeepCopy() *OutputBlobList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputBlobList.

func (*OutputBlobList) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OutputBlobList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*OutputBlobList) GetItems 

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

GetItems of this OutputBlobList.

type OutputBlobObservation 

type OutputBlobObservation struct {

	// The authentication mode for the Stream Output. Possible values are Msi and ConnectionString. Defaults to ConnectionString.
	AuthenticationMode *string `json:"authenticationMode,omitempty" tf:"authentication_mode,omitempty"`

	// The maximum wait time per batch in hh:mm:ss e.g. 00:02:00 for two minutes.
	BatchMaxWaitTime *string `json:"batchMaxWaitTime,omitempty" tf:"batch_max_wait_time,omitempty"`

	// The minimum number of rows per batch (must be between 0 and 10000).
	BatchMinRows *float64 `json:"batchMinRows,omitempty" tf:"batch_min_rows,omitempty"`

	// The date format. Wherever {date} appears in path_pattern, the value of this property is used as the date format instead.
	DateFormat *string `json:"dateFormat,omitempty" tf:"date_format,omitempty"`

	// The ID of the Stream Analytics Output Blob Storage.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.
	PathPattern *string `json:"pathPattern,omitempty" tf:"path_pattern,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// A serialization block as defined below.
	Serialization []SerializationObservation `json:"serialization,omitempty" tf:"serialization,omitempty"`

	// The name of the Storage Account.
	StorageAccountName *string `json:"storageAccountName,omitempty" tf:"storage_account_name,omitempty"`

	// The name of the Container within the Storage Account.
	StorageContainerName *string `json:"storageContainerName,omitempty" tf:"storage_container_name,omitempty"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`

	// The time format. Wherever {time} appears in path_pattern, the value of this property is used as the time format instead.
	TimeFormat *string `json:"timeFormat,omitempty" tf:"time_format,omitempty"`
}

func (*OutputBlobObservation) DeepCopy 

func (in *OutputBlobObservation) DeepCopy() *OutputBlobObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputBlobObservation.

func (*OutputBlobObservation) DeepCopyInto 

func (in *OutputBlobObservation) DeepCopyInto(out *OutputBlobObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputBlobParameters 

type OutputBlobParameters struct {

	// The authentication mode for the Stream Output. Possible values are Msi and ConnectionString. Defaults to ConnectionString.
	// +kubebuilder:validation:Optional
	AuthenticationMode *string `json:"authenticationMode,omitempty" tf:"authentication_mode,omitempty"`

	// The maximum wait time per batch in hh:mm:ss e.g. 00:02:00 for two minutes.
	// +kubebuilder:validation:Optional
	BatchMaxWaitTime *string `json:"batchMaxWaitTime,omitempty" tf:"batch_max_wait_time,omitempty"`

	// The minimum number of rows per batch (must be between 0 and 10000).
	// +kubebuilder:validation:Optional
	BatchMinRows *float64 `json:"batchMinRows,omitempty" tf:"batch_min_rows,omitempty"`

	// The date format. Wherever {date} appears in path_pattern, the value of this property is used as the date format instead.
	// +kubebuilder:validation:Optional
	DateFormat *string `json:"dateFormat,omitempty" tf:"date_format,omitempty"`

	// The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.
	// +kubebuilder:validation:Optional
	PathPattern *string `json:"pathPattern,omitempty" tf:"path_pattern,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/azure/v1beta1.ResourceGroup
	// +kubebuilder:validation:Optional
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// Reference to a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameRef *v1.Reference `json:"resourceGroupNameRef,omitempty" tf:"-"`

	// Selector for a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameSelector *v1.Selector `json:"resourceGroupNameSelector,omitempty" tf:"-"`

	// A serialization block as defined below.
	// +kubebuilder:validation:Optional
	Serialization []SerializationParameters `json:"serialization,omitempty" tf:"serialization,omitempty"`

	// The Access Key which should be used to connect to this Storage Account.
	// +kubebuilder:validation:Optional
	StorageAccountKeySecretRef *v1.SecretKeySelector `json:"storageAccountKeySecretRef,omitempty" tf:"-"`

	// The name of the Storage Account.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/storage/v1beta1.Account
	// +kubebuilder:validation:Optional
	StorageAccountName *string `json:"storageAccountName,omitempty" tf:"storage_account_name,omitempty"`

	// Reference to a Account in storage to populate storageAccountName.
	// +kubebuilder:validation:Optional
	StorageAccountNameRef *v1.Reference `json:"storageAccountNameRef,omitempty" tf:"-"`

	// Selector for a Account in storage to populate storageAccountName.
	// +kubebuilder:validation:Optional
	StorageAccountNameSelector *v1.Selector `json:"storageAccountNameSelector,omitempty" tf:"-"`

	// The name of the Container within the Storage Account.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/storage/v1beta1.Container
	// +kubebuilder:validation:Optional
	StorageContainerName *string `json:"storageContainerName,omitempty" tf:"storage_container_name,omitempty"`

	// Reference to a Container in storage to populate storageContainerName.
	// +kubebuilder:validation:Optional
	StorageContainerNameRef *v1.Reference `json:"storageContainerNameRef,omitempty" tf:"-"`

	// Selector for a Container in storage to populate storageContainerName.
	// +kubebuilder:validation:Optional
	StorageContainerNameSelector *v1.Selector `json:"storageContainerNameSelector,omitempty" tf:"-"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=Job
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`

	// Reference to a Job to populate streamAnalyticsJobName.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobNameRef *v1.Reference `json:"streamAnalyticsJobNameRef,omitempty" tf:"-"`

	// Selector for a Job to populate streamAnalyticsJobName.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobNameSelector *v1.Selector `json:"streamAnalyticsJobNameSelector,omitempty" tf:"-"`

	// The time format. Wherever {time} appears in path_pattern, the value of this property is used as the time format instead.
	// +kubebuilder:validation:Optional
	TimeFormat *string `json:"timeFormat,omitempty" tf:"time_format,omitempty"`
}

func (*OutputBlobParameters) DeepCopy 

func (in *OutputBlobParameters) DeepCopy() *OutputBlobParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputBlobParameters.

func (*OutputBlobParameters) DeepCopyInto 

func (in *OutputBlobParameters) DeepCopyInto(out *OutputBlobParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputBlobSpec 

type OutputBlobSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     OutputBlobParameters `json:"forProvider"`
}

OutputBlobSpec defines the desired state of OutputBlob

func (*OutputBlobSpec) DeepCopy 

func (in *OutputBlobSpec) DeepCopy() *OutputBlobSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputBlobSpec.

func (*OutputBlobSpec) DeepCopyInto 

func (in *OutputBlobSpec) DeepCopyInto(out *OutputBlobSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputBlobStatus 

type OutputBlobStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        OutputBlobObservation `json:"atProvider,omitempty"`
}

OutputBlobStatus defines the observed state of OutputBlob.

func (*OutputBlobStatus) DeepCopy 

func (in *OutputBlobStatus) DeepCopy() *OutputBlobStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputBlobStatus.

func (*OutputBlobStatus) DeepCopyInto 

func (in *OutputBlobStatus) DeepCopyInto(out *OutputBlobStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputEventHub added in v0.28.0 

type OutputEventHub struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.serialization)",message="serialization is a required parameter"
	Spec   OutputEventHubSpec   `json:"spec"`
	Status OutputEventHubStatus `json:"status,omitempty"`
}

OutputEventHub is the Schema for the OutputEventHubs API. Manages a Stream Analytics Output to an EventHub. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*OutputEventHub) DeepCopy added in v0.28.0 

func (in *OutputEventHub) DeepCopy() *OutputEventHub

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputEventHub.

func (*OutputEventHub) DeepCopyInto added in v0.28.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OutputEventHub) DeepCopyObject added in v0.28.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*OutputEventHub) GetCondition added in v0.28.0 

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

GetCondition of this OutputEventHub.

func (*OutputEventHub) GetConnectionDetailsMapping added in v0.28.0 

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

GetConnectionDetailsMapping for this OutputEventHub

func (*OutputEventHub) GetDeletionPolicy added in v0.28.0 

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

GetDeletionPolicy of this OutputEventHub.

func (*OutputEventHub) GetID added in v0.28.0 

func (tr *OutputEventHub) GetID() string

GetID returns ID of underlying Terraform resource of this OutputEventHub

func (*OutputEventHub) GetManagementPolicy added in v0.31.0 

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

GetManagementPolicy of this OutputEventHub.

func (*OutputEventHub) GetObservation added in v0.28.0 

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

GetObservation of this OutputEventHub

func (*OutputEventHub) GetParameters added in v0.28.0 

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

GetParameters of this OutputEventHub

func (*OutputEventHub) GetProviderConfigReference added in v0.28.0 

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

GetProviderConfigReference of this OutputEventHub.

func (*OutputEventHub) GetProviderReference added in v0.28.0 

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

GetProviderReference of this OutputEventHub. Deprecated: Use GetProviderConfigReference.

func (*OutputEventHub) GetPublishConnectionDetailsTo added in v0.28.0 

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

GetPublishConnectionDetailsTo of this OutputEventHub.

func (*OutputEventHub) GetTerraformResourceType added in v0.28.0 

func (mg *OutputEventHub) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this OutputEventHub

func (*OutputEventHub) GetTerraformSchemaVersion added in v0.28.0 

func (tr *OutputEventHub) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*OutputEventHub) GetWriteConnectionSecretToReference added in v0.28.0 

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

GetWriteConnectionSecretToReference of this OutputEventHub.

func (*OutputEventHub) LateInitialize added in v0.28.0 

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

LateInitialize this OutputEventHub using its observed tfState. returns True if there are any spec changes for the resource.

func (*OutputEventHub) ResolveReferences added in v0.28.0 

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

ResolveReferences of this OutputEventHub.

func (*OutputEventHub) SetConditions added in v0.28.0 

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

SetConditions of this OutputEventHub.

func (*OutputEventHub) SetDeletionPolicy added in v0.28.0 

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

SetDeletionPolicy of this OutputEventHub.

func (*OutputEventHub) SetManagementPolicy added in v0.31.0 

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

SetManagementPolicy of this OutputEventHub.

func (*OutputEventHub) SetObservation added in v0.28.0 

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

SetObservation for this OutputEventHub

func (*OutputEventHub) SetParameters added in v0.28.0 

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

SetParameters for this OutputEventHub

func (*OutputEventHub) SetProviderConfigReference added in v0.28.0 

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

SetProviderConfigReference of this OutputEventHub.

func (*OutputEventHub) SetProviderReference added in v0.28.0 

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

SetProviderReference of this OutputEventHub. Deprecated: Use SetProviderConfigReference.

func (*OutputEventHub) SetPublishConnectionDetailsTo added in v0.28.0 

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

SetPublishConnectionDetailsTo of this OutputEventHub.

func (*OutputEventHub) SetWriteConnectionSecretToReference added in v0.28.0 

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

SetWriteConnectionSecretToReference of this OutputEventHub.

type OutputEventHubList added in v0.28.0 

type OutputEventHubList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []OutputEventHub `json:"items"`
}

OutputEventHubList contains a list of OutputEventHubs

func (*OutputEventHubList) DeepCopy added in v0.28.0 

func (in *OutputEventHubList) DeepCopy() *OutputEventHubList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputEventHubList.

func (*OutputEventHubList) DeepCopyInto added in v0.28.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OutputEventHubList) DeepCopyObject added in v0.28.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*OutputEventHubList) GetItems added in v0.28.0 

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

GetItems of this OutputEventHubList.

type OutputEventHubObservation added in v0.28.0 

type OutputEventHubObservation struct {

	// The authentication mode for the Stream Output. Possible values are Msi and ConnectionString. Defaults to ConnectionString.
	AuthenticationMode *string `json:"authenticationMode,omitempty" tf:"authentication_mode,omitempty"`

	// The name of the Event Hub.
	EventHubName *string `json:"eventhubName,omitempty" tf:"eventhub_name,omitempty"`

	// The ID of the Stream Analytics Output EventHub.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The column that is used for the Event Hub partition key.
	PartitionKey *string `json:"partitionKey,omitempty" tf:"partition_key,omitempty"`

	// A list of property columns to add to the Event Hub output.
	PropertyColumns []*string `json:"propertyColumns,omitempty" tf:"property_columns,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// A serialization block as defined below.
	Serialization []OutputEventHubSerializationObservation `json:"serialization,omitempty" tf:"serialization,omitempty"`

	// The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
	ServiceBusNamespace *string `json:"servicebusNamespace,omitempty" tf:"servicebus_namespace,omitempty"`

	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required when authentication_mode is set to ConnectionString.
	SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty" tf:"shared_access_policy_name,omitempty"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`
}

func (*OutputEventHubObservation) DeepCopy added in v0.28.0 

func (in *OutputEventHubObservation) DeepCopy() *OutputEventHubObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputEventHubObservation.

func (*OutputEventHubObservation) DeepCopyInto added in v0.28.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputEventHubParameters added in v0.28.0 

type OutputEventHubParameters struct {

	// The authentication mode for the Stream Output. Possible values are Msi and ConnectionString. Defaults to ConnectionString.
	// +kubebuilder:validation:Optional
	AuthenticationMode *string `json:"authenticationMode,omitempty" tf:"authentication_mode,omitempty"`

	// The name of the Event Hub.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/eventhub/v1beta1.EventHub
	// +kubebuilder:validation:Optional
	EventHubName *string `json:"eventhubName,omitempty" tf:"eventhub_name,omitempty"`

	// Reference to a EventHub in eventhub to populate eventhubName.
	// +kubebuilder:validation:Optional
	EventHubNameRef *v1.Reference `json:"eventhubNameRef,omitempty" tf:"-"`

	// Selector for a EventHub in eventhub to populate eventhubName.
	// +kubebuilder:validation:Optional
	EventHubNameSelector *v1.Selector `json:"eventhubNameSelector,omitempty" tf:"-"`

	// The column that is used for the Event Hub partition key.
	// +kubebuilder:validation:Optional
	PartitionKey *string `json:"partitionKey,omitempty" tf:"partition_key,omitempty"`

	// A list of property columns to add to the Event Hub output.
	// +kubebuilder:validation:Optional
	PropertyColumns []*string `json:"propertyColumns,omitempty" tf:"property_columns,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/azure/v1beta1.ResourceGroup
	// +kubebuilder:validation:Optional
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// Reference to a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameRef *v1.Reference `json:"resourceGroupNameRef,omitempty" tf:"-"`

	// Selector for a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameSelector *v1.Selector `json:"resourceGroupNameSelector,omitempty" tf:"-"`

	// A serialization block as defined below.
	// +kubebuilder:validation:Optional
	Serialization []OutputEventHubSerializationParameters `json:"serialization,omitempty" tf:"serialization,omitempty"`

	// The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/eventhub/v1beta1.EventHubNamespace
	// +kubebuilder:validation:Optional
	ServiceBusNamespace *string `json:"servicebusNamespace,omitempty" tf:"servicebus_namespace,omitempty"`

	// Reference to a EventHubNamespace in eventhub to populate servicebusNamespace.
	// +kubebuilder:validation:Optional
	ServiceBusNamespaceRef *v1.Reference `json:"servicebusNamespaceRef,omitempty" tf:"-"`

	// Selector for a EventHubNamespace in eventhub to populate servicebusNamespace.
	// +kubebuilder:validation:Optional
	ServiceBusNamespaceSelector *v1.Selector `json:"servicebusNamespaceSelector,omitempty" tf:"-"`

	// The shared access policy key for the specified shared access policy. Required when authentication_mode is set to ConnectionString.
	// +kubebuilder:validation:Optional
	SharedAccessPolicyKeySecretRef *v1.SecretKeySelector `json:"sharedAccessPolicyKeySecretRef,omitempty" tf:"-"`

	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required when authentication_mode is set to ConnectionString.
	// +kubebuilder:validation:Optional
	SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty" tf:"shared_access_policy_name,omitempty"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Required
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName" tf:"stream_analytics_job_name,omitempty"`
}

func (*OutputEventHubParameters) DeepCopy added in v0.28.0 

func (in *OutputEventHubParameters) DeepCopy() *OutputEventHubParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputEventHubParameters.

func (*OutputEventHubParameters) DeepCopyInto added in v0.28.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputEventHubSerializationObservation added in v0.28.0 

type OutputEventHubSerializationObservation struct {

	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
	Encoding *string `json:"encoding,omitempty" tf:"encoding,omitempty"`

	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are   (space), , (comma), 	 (tab), | (pipe) and ;.
	FieldDelimiter *string `json:"fieldDelimiter,omitempty" tf:"field_delimiter,omitempty"`

	// Specifies the format of the JSON the output will be written in. Possible values are Array and LineSeparated.
	Format *string `json:"format,omitempty" tf:"format,omitempty"`

	// The serialization format used for outgoing data streams. Possible values are Avro, Csv, Json and Parquet.
	Type *string `json:"type,omitempty" tf:"type,omitempty"`
}

func (*OutputEventHubSerializationObservation) DeepCopy added in v0.28.0 

func (in *OutputEventHubSerializationObservation) DeepCopy() *OutputEventHubSerializationObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputEventHubSerializationObservation.

func (*OutputEventHubSerializationObservation) DeepCopyInto added in v0.28.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputEventHubSerializationParameters added in v0.28.0 

type OutputEventHubSerializationParameters struct {

	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
	// +kubebuilder:validation:Optional
	Encoding *string `json:"encoding,omitempty" tf:"encoding,omitempty"`

	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are   (space), , (comma), 	 (tab), | (pipe) and ;.
	// +kubebuilder:validation:Optional
	FieldDelimiter *string `json:"fieldDelimiter,omitempty" tf:"field_delimiter,omitempty"`

	// Specifies the format of the JSON the output will be written in. Possible values are Array and LineSeparated.
	// +kubebuilder:validation:Optional
	Format *string `json:"format,omitempty" tf:"format,omitempty"`

	// The serialization format used for outgoing data streams. Possible values are Avro, Csv, Json and Parquet.
	// +kubebuilder:validation:Required
	Type *string `json:"type" tf:"type,omitempty"`
}

func (*OutputEventHubSerializationParameters) DeepCopy added in v0.28.0 

func (in *OutputEventHubSerializationParameters) DeepCopy() *OutputEventHubSerializationParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputEventHubSerializationParameters.

func (*OutputEventHubSerializationParameters) DeepCopyInto added in v0.28.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputEventHubSpec added in v0.28.0 

type OutputEventHubSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     OutputEventHubParameters `json:"forProvider"`
}

OutputEventHubSpec defines the desired state of OutputEventHub

func (*OutputEventHubSpec) DeepCopy added in v0.28.0 

func (in *OutputEventHubSpec) DeepCopy() *OutputEventHubSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputEventHubSpec.

func (*OutputEventHubSpec) DeepCopyInto added in v0.28.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputEventHubStatus added in v0.28.0 

type OutputEventHubStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        OutputEventHubObservation `json:"atProvider,omitempty"`
}

OutputEventHubStatus defines the observed state of OutputEventHub.

func (*OutputEventHubStatus) DeepCopy added in v0.28.0 

func (in *OutputEventHubStatus) DeepCopy() *OutputEventHubStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputEventHubStatus.

func (*OutputEventHubStatus) DeepCopyInto added in v0.28.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputFunction 

type OutputFunction struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.apiKeySecretRef)",message="apiKeySecretRef is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.functionName)",message="functionName is a required parameter"
	Spec   OutputFunctionSpec   `json:"spec"`
	Status OutputFunctionStatus `json:"status,omitempty"`
}

OutputFunction is the Schema for the OutputFunctions API. Manages a Stream Analytics Output Function. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*OutputFunction) DeepCopy 

func (in *OutputFunction) DeepCopy() *OutputFunction

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputFunction.

func (*OutputFunction) DeepCopyInto 

func (in *OutputFunction) DeepCopyInto(out *OutputFunction)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OutputFunction) DeepCopyObject 

func (in *OutputFunction) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*OutputFunction) GetCondition 

func (mg *OutputFunction) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this OutputFunction.

func (*OutputFunction) GetConnectionDetailsMapping 

func (tr *OutputFunction) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this OutputFunction

func (*OutputFunction) GetDeletionPolicy 

func (mg *OutputFunction) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this OutputFunction.

func (*OutputFunction) GetID 

func (tr *OutputFunction) GetID() string

GetID returns ID of underlying Terraform resource of this OutputFunction

func (*OutputFunction) GetManagementPolicy added in v0.31.0 

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

GetManagementPolicy of this OutputFunction.

func (*OutputFunction) GetObservation 

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

GetObservation of this OutputFunction

func (*OutputFunction) GetParameters 

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

GetParameters of this OutputFunction

func (*OutputFunction) GetProviderConfigReference 

func (mg *OutputFunction) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this OutputFunction.

func (*OutputFunction) GetProviderReference 

func (mg *OutputFunction) GetProviderReference() *xpv1.Reference

GetProviderReference of this OutputFunction. Deprecated: Use GetProviderConfigReference.

func (*OutputFunction) GetPublishConnectionDetailsTo 

func (mg *OutputFunction) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this OutputFunction.

func (*OutputFunction) GetTerraformResourceType 

func (mg *OutputFunction) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this OutputFunction

func (*OutputFunction) GetTerraformSchemaVersion 

func (tr *OutputFunction) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*OutputFunction) GetWriteConnectionSecretToReference 

func (mg *OutputFunction) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this OutputFunction.

func (*OutputFunction) LateInitialize 

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

LateInitialize this OutputFunction using its observed tfState. returns True if there are any spec changes for the resource.

func (*OutputFunction) ResolveReferences 

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

ResolveReferences of this OutputFunction.

func (*OutputFunction) SetConditions 

func (mg *OutputFunction) SetConditions(c ...xpv1.Condition)

SetConditions of this OutputFunction.

func (*OutputFunction) SetDeletionPolicy 

func (mg *OutputFunction) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this OutputFunction.

func (*OutputFunction) SetManagementPolicy added in v0.31.0 

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

SetManagementPolicy of this OutputFunction.

func (*OutputFunction) SetObservation 

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

SetObservation for this OutputFunction

func (*OutputFunction) SetParameters 

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

SetParameters for this OutputFunction

func (*OutputFunction) SetProviderConfigReference 

func (mg *OutputFunction) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this OutputFunction.

func (*OutputFunction) SetProviderReference 

func (mg *OutputFunction) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this OutputFunction. Deprecated: Use SetProviderConfigReference.

func (*OutputFunction) SetPublishConnectionDetailsTo 

func (mg *OutputFunction) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this OutputFunction.

func (*OutputFunction) SetWriteConnectionSecretToReference 

func (mg *OutputFunction) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this OutputFunction.

type OutputFunctionList 

type OutputFunctionList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []OutputFunction `json:"items"`
}

OutputFunctionList contains a list of OutputFunctions

func (*OutputFunctionList) DeepCopy 

func (in *OutputFunctionList) DeepCopy() *OutputFunctionList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputFunctionList.

func (*OutputFunctionList) DeepCopyInto 

func (in *OutputFunctionList) DeepCopyInto(out *OutputFunctionList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OutputFunctionList) DeepCopyObject 

func (in *OutputFunctionList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*OutputFunctionList) GetItems 

func (l *OutputFunctionList) GetItems() []resource.Managed

GetItems of this OutputFunctionList.

type OutputFunctionObservation 

type OutputFunctionObservation struct {

	// The maximum number of events in each batch that's sent to the function. Defaults to 100.
	BatchMaxCount *float64 `json:"batchMaxCount,omitempty" tf:"batch_max_count,omitempty"`

	// The maximum batch size in bytes that's sent to the function. Defaults to 262144 (256 kB).
	BatchMaxInBytes *float64 `json:"batchMaxInBytes,omitempty" tf:"batch_max_in_bytes,omitempty"`

	// The name of the Function App.
	FunctionApp *string `json:"functionApp,omitempty" tf:"function_app,omitempty"`

	// The name of the function in the Function App.
	FunctionName *string `json:"functionName,omitempty" tf:"function_name,omitempty"`

	// The ID of the Stream Analytics Output Function.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The name of the Resource Group where the Stream Analytics Output should exist. Changing this forces a new resource to be created.
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`
}

func (*OutputFunctionObservation) DeepCopy 

func (in *OutputFunctionObservation) DeepCopy() *OutputFunctionObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputFunctionObservation.

func (*OutputFunctionObservation) DeepCopyInto 

func (in *OutputFunctionObservation) DeepCopyInto(out *OutputFunctionObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputFunctionParameters 

type OutputFunctionParameters struct {

	// The API key for the Function.
	// +kubebuilder:validation:Optional
	APIKeySecretRef v1.SecretKeySelector `json:"apiKeySecretRef" tf:"-"`

	// The maximum number of events in each batch that's sent to the function. Defaults to 100.
	// +kubebuilder:validation:Optional
	BatchMaxCount *float64 `json:"batchMaxCount,omitempty" tf:"batch_max_count,omitempty"`

	// The maximum batch size in bytes that's sent to the function. Defaults to 262144 (256 kB).
	// +kubebuilder:validation:Optional
	BatchMaxInBytes *float64 `json:"batchMaxInBytes,omitempty" tf:"batch_max_in_bytes,omitempty"`

	// The name of the Function App.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/web/v1beta1.FunctionApp
	// +crossplane:generate:reference:extractor=github.com/upbound/upjet/pkg/resource.ExtractParamPath("name",false)
	// +kubebuilder:validation:Optional
	FunctionApp *string `json:"functionApp,omitempty" tf:"function_app,omitempty"`

	// Reference to a FunctionApp in web to populate functionApp.
	// +kubebuilder:validation:Optional
	FunctionAppRef *v1.Reference `json:"functionAppRef,omitempty" tf:"-"`

	// Selector for a FunctionApp in web to populate functionApp.
	// +kubebuilder:validation:Optional
	FunctionAppSelector *v1.Selector `json:"functionAppSelector,omitempty" tf:"-"`

	// The name of the function in the Function App.
	// +kubebuilder:validation:Optional
	FunctionName *string `json:"functionName,omitempty" tf:"function_name,omitempty"`

	// The name of the Resource Group where the Stream Analytics Output should exist. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/azure/v1beta1.ResourceGroup
	// +kubebuilder:validation:Optional
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// Reference to a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameRef *v1.Reference `json:"resourceGroupNameRef,omitempty" tf:"-"`

	// Selector for a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameSelector *v1.Selector `json:"resourceGroupNameSelector,omitempty" tf:"-"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/streamanalytics/v1beta1.Job
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`

	// Reference to a Job in streamanalytics to populate streamAnalyticsJobName.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobNameRef *v1.Reference `json:"streamAnalyticsJobNameRef,omitempty" tf:"-"`

	// Selector for a Job in streamanalytics to populate streamAnalyticsJobName.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobNameSelector *v1.Selector `json:"streamAnalyticsJobNameSelector,omitempty" tf:"-"`
}

func (*OutputFunctionParameters) DeepCopy 

func (in *OutputFunctionParameters) DeepCopy() *OutputFunctionParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputFunctionParameters.

func (*OutputFunctionParameters) DeepCopyInto 

func (in *OutputFunctionParameters) DeepCopyInto(out *OutputFunctionParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputFunctionSpec 

type OutputFunctionSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     OutputFunctionParameters `json:"forProvider"`
}

OutputFunctionSpec defines the desired state of OutputFunction

func (*OutputFunctionSpec) DeepCopy 

func (in *OutputFunctionSpec) DeepCopy() *OutputFunctionSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputFunctionSpec.

func (*OutputFunctionSpec) DeepCopyInto 

func (in *OutputFunctionSpec) DeepCopyInto(out *OutputFunctionSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputFunctionStatus 

type OutputFunctionStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        OutputFunctionObservation `json:"atProvider,omitempty"`
}

OutputFunctionStatus defines the observed state of OutputFunction.

func (*OutputFunctionStatus) DeepCopy 

func (in *OutputFunctionStatus) DeepCopy() *OutputFunctionStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputFunctionStatus.

func (*OutputFunctionStatus) DeepCopyInto 

func (in *OutputFunctionStatus) DeepCopyInto(out *OutputFunctionStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputMSSQL added in v0.27.0 

type OutputMSSQL struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.database)",message="database is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.name)",message="name is a required parameter"
	Spec   OutputMSSQLSpec   `json:"spec"`
	Status OutputMSSQLStatus `json:"status,omitempty"`
}

OutputMSSQL is the Schema for the OutputMSSQLs API. Manages a Stream Analytics Output to Microsoft SQL Server Database. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*OutputMSSQL) DeepCopy added in v0.27.0 

func (in *OutputMSSQL) DeepCopy() *OutputMSSQL

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputMSSQL.

func (*OutputMSSQL) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OutputMSSQL) DeepCopyObject added in v0.27.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*OutputMSSQL) GetCondition added in v0.27.0 

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

GetCondition of this OutputMSSQL.

func (*OutputMSSQL) GetConnectionDetailsMapping added in v0.27.0 

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

GetConnectionDetailsMapping for this OutputMSSQL

func (*OutputMSSQL) GetDeletionPolicy added in v0.27.0 

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

GetDeletionPolicy of this OutputMSSQL.

func (*OutputMSSQL) GetID added in v0.27.0 

func (tr *OutputMSSQL) GetID() string

GetID returns ID of underlying Terraform resource of this OutputMSSQL

func (*OutputMSSQL) GetManagementPolicy added in v0.31.0 

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

GetManagementPolicy of this OutputMSSQL.

func (*OutputMSSQL) GetObservation added in v0.27.0 

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

GetObservation of this OutputMSSQL

func (*OutputMSSQL) GetParameters added in v0.27.0 

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

GetParameters of this OutputMSSQL

func (*OutputMSSQL) GetProviderConfigReference added in v0.27.0 

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

GetProviderConfigReference of this OutputMSSQL.

func (*OutputMSSQL) GetProviderReference added in v0.27.0 

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

GetProviderReference of this OutputMSSQL. Deprecated: Use GetProviderConfigReference.

func (*OutputMSSQL) GetPublishConnectionDetailsTo added in v0.27.0 

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

GetPublishConnectionDetailsTo of this OutputMSSQL.

func (*OutputMSSQL) GetTerraformResourceType added in v0.27.0 

func (mg *OutputMSSQL) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this OutputMSSQL

func (*OutputMSSQL) GetTerraformSchemaVersion added in v0.27.0 

func (tr *OutputMSSQL) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*OutputMSSQL) GetWriteConnectionSecretToReference added in v0.27.0 

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

GetWriteConnectionSecretToReference of this OutputMSSQL.

func (*OutputMSSQL) LateInitialize added in v0.27.0 

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

LateInitialize this OutputMSSQL using its observed tfState. returns True if there are any spec changes for the resource.

func (*OutputMSSQL) ResolveReferences added in v0.27.0 

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

ResolveReferences of this OutputMSSQL.

func (*OutputMSSQL) SetConditions added in v0.27.0 

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

SetConditions of this OutputMSSQL.

func (*OutputMSSQL) SetDeletionPolicy added in v0.27.0 

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

SetDeletionPolicy of this OutputMSSQL.

func (*OutputMSSQL) SetManagementPolicy added in v0.31.0 

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

SetManagementPolicy of this OutputMSSQL.

func (*OutputMSSQL) SetObservation added in v0.27.0 

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

SetObservation for this OutputMSSQL

func (*OutputMSSQL) SetParameters added in v0.27.0 

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

SetParameters for this OutputMSSQL

func (*OutputMSSQL) SetProviderConfigReference added in v0.27.0 

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

SetProviderConfigReference of this OutputMSSQL.

func (*OutputMSSQL) SetProviderReference added in v0.27.0 

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

SetProviderReference of this OutputMSSQL. Deprecated: Use SetProviderConfigReference.

func (*OutputMSSQL) SetPublishConnectionDetailsTo added in v0.27.0 

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

SetPublishConnectionDetailsTo of this OutputMSSQL.

func (*OutputMSSQL) SetWriteConnectionSecretToReference added in v0.27.0 

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

SetWriteConnectionSecretToReference of this OutputMSSQL.

type OutputMSSQLList added in v0.27.0 

type OutputMSSQLList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []OutputMSSQL `json:"items"`
}

OutputMSSQLList contains a list of OutputMSSQLs

func (*OutputMSSQLList) DeepCopy added in v0.27.0 

func (in *OutputMSSQLList) DeepCopy() *OutputMSSQLList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputMSSQLList.

func (*OutputMSSQLList) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OutputMSSQLList) DeepCopyObject added in v0.27.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*OutputMSSQLList) GetItems added in v0.27.0 

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

GetItems of this OutputMSSQLList.

type OutputMSSQLObservation added in v0.27.0 

type OutputMSSQLObservation struct {

	// The authentication mode for the Stream Output. Possible values are Msi and ConnectionString. Defaults to ConnectionString.
	AuthenticationMode *string `json:"authenticationMode,omitempty" tf:"authentication_mode,omitempty"`

	// The MS SQL database name where the reference table exists. Changing this forces a new resource to be created.
	Database *string `json:"database,omitempty" tf:"database,omitempty"`

	// The ID of the Stream Analytics Output Microsoft SQL Server Database.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The max batch count to write to the SQL Database. Defaults to 10000. Possible values are between 1 and 1073741824.
	MaxBatchCount *float64 `json:"maxBatchCount,omitempty" tf:"max_batch_count,omitempty"`

	// The max writer count for the SQL Database. Defaults to 1. Possible values are 0 which bases the writer count on the query partition and 1 which corresponds to a single writer.
	MaxWriterCount *float64 `json:"maxWriterCount,omitempty" tf:"max_writer_count,omitempty"`

	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// The SQL server url. Changing this forces a new resource to be created.
	Server *string `json:"server,omitempty" tf:"server,omitempty"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`

	// Table in the database that the output points to. Changing this forces a new resource to be created.
	Table *string `json:"table,omitempty" tf:"table,omitempty"`

	// Username used to login to the Microsoft SQL Server. Changing this forces a new resource to be created. Required if authentication_mode is ConnectionString.
	User *string `json:"user,omitempty" tf:"user,omitempty"`
}

func (*OutputMSSQLObservation) DeepCopy added in v0.27.0 

func (in *OutputMSSQLObservation) DeepCopy() *OutputMSSQLObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputMSSQLObservation.

func (*OutputMSSQLObservation) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputMSSQLParameters added in v0.27.0 

type OutputMSSQLParameters struct {

	// The authentication mode for the Stream Output. Possible values are Msi and ConnectionString. Defaults to ConnectionString.
	// +kubebuilder:validation:Optional
	AuthenticationMode *string `json:"authenticationMode,omitempty" tf:"authentication_mode,omitempty"`

	// The MS SQL database name where the reference table exists. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Optional
	Database *string `json:"database,omitempty" tf:"database,omitempty"`

	// The max batch count to write to the SQL Database. Defaults to 10000. Possible values are between 1 and 1073741824.
	// +kubebuilder:validation:Optional
	MaxBatchCount *float64 `json:"maxBatchCount,omitempty" tf:"max_batch_count,omitempty"`

	// The max writer count for the SQL Database. Defaults to 1. Possible values are 0 which bases the writer count on the query partition and 1 which corresponds to a single writer.
	// +kubebuilder:validation:Optional
	MaxWriterCount *float64 `json:"maxWriterCount,omitempty" tf:"max_writer_count,omitempty"`

	// The name of the Stream Output. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Optional
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// Password used together with username, to login to the Microsoft SQL Server. Required if authentication_mode is ConnectionString.
	// +kubebuilder:validation:Optional
	PasswordSecretRef *v1.SecretKeySelector `json:"passwordSecretRef,omitempty" tf:"-"`

	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/azure/v1beta1.ResourceGroup
	// +kubebuilder:validation:Optional
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// Reference to a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameRef *v1.Reference `json:"resourceGroupNameRef,omitempty" tf:"-"`

	// Selector for a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameSelector *v1.Selector `json:"resourceGroupNameSelector,omitempty" tf:"-"`

	// The SQL server url. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/sql/v1beta1.MSSQLServer
	// +kubebuilder:validation:Optional
	Server *string `json:"server,omitempty" tf:"server,omitempty"`

	// Reference to a MSSQLServer in sql to populate server.
	// +kubebuilder:validation:Optional
	ServerRef *v1.Reference `json:"serverRef,omitempty" tf:"-"`

	// Selector for a MSSQLServer in sql to populate server.
	// +kubebuilder:validation:Optional
	ServerSelector *v1.Selector `json:"serverSelector,omitempty" tf:"-"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=Job
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`

	// Reference to a Job to populate streamAnalyticsJobName.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobNameRef *v1.Reference `json:"streamAnalyticsJobNameRef,omitempty" tf:"-"`

	// Selector for a Job to populate streamAnalyticsJobName.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobNameSelector *v1.Selector `json:"streamAnalyticsJobNameSelector,omitempty" tf:"-"`

	// Table in the database that the output points to. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/storage/v1beta1.Table
	// +kubebuilder:validation:Optional
	Table *string `json:"table,omitempty" tf:"table,omitempty"`

	// Reference to a Table in storage to populate table.
	// +kubebuilder:validation:Optional
	TableRef *v1.Reference `json:"tableRef,omitempty" tf:"-"`

	// Selector for a Table in storage to populate table.
	// +kubebuilder:validation:Optional
	TableSelector *v1.Selector `json:"tableSelector,omitempty" tf:"-"`

	// Username used to login to the Microsoft SQL Server. Changing this forces a new resource to be created. Required if authentication_mode is ConnectionString.
	// +kubebuilder:validation:Optional
	User *string `json:"user,omitempty" tf:"user,omitempty"`
}

func (*OutputMSSQLParameters) DeepCopy added in v0.27.0 

func (in *OutputMSSQLParameters) DeepCopy() *OutputMSSQLParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputMSSQLParameters.

func (*OutputMSSQLParameters) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputMSSQLSpec added in v0.27.0 

type OutputMSSQLSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     OutputMSSQLParameters `json:"forProvider"`
}

OutputMSSQLSpec defines the desired state of OutputMSSQL

func (*OutputMSSQLSpec) DeepCopy added in v0.27.0 

func (in *OutputMSSQLSpec) DeepCopy() *OutputMSSQLSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputMSSQLSpec.

func (*OutputMSSQLSpec) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputMSSQLStatus added in v0.27.0 

type OutputMSSQLStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        OutputMSSQLObservation `json:"atProvider,omitempty"`
}

OutputMSSQLStatus defines the observed state of OutputMSSQL.

func (*OutputMSSQLStatus) DeepCopy added in v0.27.0 

func (in *OutputMSSQLStatus) DeepCopy() *OutputMSSQLStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputMSSQLStatus.

func (*OutputMSSQLStatus) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputObservation 

type OutputObservation struct {

	// The output data type from this JavaScript Function. Possible values include any, array, bigint, datetime, float, nvarchar(max) and record.
	Type *string `json:"type,omitempty" tf:"type,omitempty"`
}

func (*OutputObservation) DeepCopy 

func (in *OutputObservation) DeepCopy() *OutputObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputObservation.

func (*OutputObservation) DeepCopyInto 

func (in *OutputObservation) DeepCopyInto(out *OutputObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputParameters 

type OutputParameters struct {

	// The output data type from this JavaScript Function. Possible values include any, array, bigint, datetime, float, nvarchar(max) and record.
	// +kubebuilder:validation:Required
	Type *string `json:"type" tf:"type,omitempty"`
}

func (*OutputParameters) DeepCopy 

func (in *OutputParameters) DeepCopy() *OutputParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputParameters.

func (*OutputParameters) DeepCopyInto 

func (in *OutputParameters) DeepCopyInto(out *OutputParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputPowerBI added in v0.33.0 

type OutputPowerBI struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.dataset)",message="dataset is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.groupId)",message="groupId is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.groupName)",message="groupName is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.table)",message="table is a required parameter"
	Spec   OutputPowerBISpec   `json:"spec"`
	Status OutputPowerBIStatus `json:"status,omitempty"`
}

OutputPowerBI is the Schema for the OutputPowerBIs API. Manages a Stream Analytics Output powerBI. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*OutputPowerBI) DeepCopy added in v0.33.0 

func (in *OutputPowerBI) DeepCopy() *OutputPowerBI

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputPowerBI.

func (*OutputPowerBI) DeepCopyInto added in v0.33.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OutputPowerBI) DeepCopyObject added in v0.33.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*OutputPowerBI) GetCondition added in v0.33.0 

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

GetCondition of this OutputPowerBI.

func (*OutputPowerBI) GetConnectionDetailsMapping added in v0.33.0 

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

GetConnectionDetailsMapping for this OutputPowerBI

func (*OutputPowerBI) GetDeletionPolicy added in v0.33.0 

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

GetDeletionPolicy of this OutputPowerBI.

func (*OutputPowerBI) GetID added in v0.33.0 

func (tr *OutputPowerBI) GetID() string

GetID returns ID of underlying Terraform resource of this OutputPowerBI

func (*OutputPowerBI) GetManagementPolicy added in v0.33.0 

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

GetManagementPolicy of this OutputPowerBI.

func (*OutputPowerBI) GetObservation added in v0.33.0 

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

GetObservation of this OutputPowerBI

func (*OutputPowerBI) GetParameters added in v0.33.0 

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

GetParameters of this OutputPowerBI

func (*OutputPowerBI) GetProviderConfigReference added in v0.33.0 

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

GetProviderConfigReference of this OutputPowerBI.

func (*OutputPowerBI) GetProviderReference added in v0.33.0 

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

GetProviderReference of this OutputPowerBI. Deprecated: Use GetProviderConfigReference.

func (*OutputPowerBI) GetPublishConnectionDetailsTo added in v0.33.0 

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

GetPublishConnectionDetailsTo of this OutputPowerBI.

func (*OutputPowerBI) GetTerraformResourceType added in v0.33.0 

func (mg *OutputPowerBI) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this OutputPowerBI

func (*OutputPowerBI) GetTerraformSchemaVersion added in v0.33.0 

func (tr *OutputPowerBI) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*OutputPowerBI) GetWriteConnectionSecretToReference added in v0.33.0 

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

GetWriteConnectionSecretToReference of this OutputPowerBI.

func (*OutputPowerBI) LateInitialize added in v0.33.0 

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

LateInitialize this OutputPowerBI using its observed tfState. returns True if there are any spec changes for the resource.

func (*OutputPowerBI) ResolveReferences added in v0.33.0 

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

ResolveReferences of this OutputPowerBI.

func (*OutputPowerBI) SetConditions added in v0.33.0 

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

SetConditions of this OutputPowerBI.

func (*OutputPowerBI) SetDeletionPolicy added in v0.33.0 

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

SetDeletionPolicy of this OutputPowerBI.

func (*OutputPowerBI) SetManagementPolicy added in v0.33.0 

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

SetManagementPolicy of this OutputPowerBI.

func (*OutputPowerBI) SetObservation added in v0.33.0 

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

SetObservation for this OutputPowerBI

func (*OutputPowerBI) SetParameters added in v0.33.0 

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

SetParameters for this OutputPowerBI

func (*OutputPowerBI) SetProviderConfigReference added in v0.33.0 

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

SetProviderConfigReference of this OutputPowerBI.

func (*OutputPowerBI) SetProviderReference added in v0.33.0 

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

SetProviderReference of this OutputPowerBI. Deprecated: Use SetProviderConfigReference.

func (*OutputPowerBI) SetPublishConnectionDetailsTo added in v0.33.0 

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

SetPublishConnectionDetailsTo of this OutputPowerBI.

func (*OutputPowerBI) SetWriteConnectionSecretToReference added in v0.33.0 

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

SetWriteConnectionSecretToReference of this OutputPowerBI.

type OutputPowerBIList added in v0.33.0 

type OutputPowerBIList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []OutputPowerBI `json:"items"`
}

OutputPowerBIList contains a list of OutputPowerBIs

func (*OutputPowerBIList) DeepCopy added in v0.33.0 

func (in *OutputPowerBIList) DeepCopy() *OutputPowerBIList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputPowerBIList.

func (*OutputPowerBIList) DeepCopyInto added in v0.33.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OutputPowerBIList) DeepCopyObject added in v0.33.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*OutputPowerBIList) GetItems added in v0.33.0 

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

GetItems of this OutputPowerBIList.

type OutputPowerBIObservation added in v0.33.0 

type OutputPowerBIObservation struct {

	// The name of the Power BI dataset.
	DataSet *string `json:"dataset,omitempty" tf:"dataset,omitempty"`

	// The ID of the Power BI group, this must be a valid UUID.
	GroupID *string `json:"groupId,omitempty" tf:"group_id,omitempty"`

	// The name of the Power BI group. Use this property to help remember which specific Power BI group id was used.
	GroupName *string `json:"groupName,omitempty" tf:"group_name,omitempty"`

	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The ID of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobID *string `json:"streamAnalyticsJobId,omitempty" tf:"stream_analytics_job_id,omitempty"`

	// The name of the Power BI table under the specified dataset.
	Table *string `json:"table,omitempty" tf:"table,omitempty"`

	// The user display name of the user that was used to obtain the refresh token.
	TokenUserDisplayName *string `json:"tokenUserDisplayName,omitempty" tf:"token_user_display_name,omitempty"`

	// The user principal name (UPN) of the user that was used to obtain the refresh token.
	TokenUserPrincipalName *string `json:"tokenUserPrincipalName,omitempty" tf:"token_user_principal_name,omitempty"`
}

func (*OutputPowerBIObservation) DeepCopy added in v0.33.0 

func (in *OutputPowerBIObservation) DeepCopy() *OutputPowerBIObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputPowerBIObservation.

func (*OutputPowerBIObservation) DeepCopyInto added in v0.33.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputPowerBIParameters added in v0.33.0 

type OutputPowerBIParameters struct {

	// The name of the Power BI dataset.
	// +kubebuilder:validation:Optional
	DataSet *string `json:"dataset,omitempty" tf:"dataset,omitempty"`

	// The ID of the Power BI group, this must be a valid UUID.
	// +kubebuilder:validation:Optional
	GroupID *string `json:"groupId,omitempty" tf:"group_id,omitempty"`

	// The name of the Power BI group. Use this property to help remember which specific Power BI group id was used.
	// +kubebuilder:validation:Optional
	GroupName *string `json:"groupName,omitempty" tf:"group_name,omitempty"`

	// The ID of the Stream Analytics Job. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=Job
	// +crossplane:generate:reference:extractor=github.com/upbound/provider-azure/apis/rconfig.ExtractResourceID()
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobID *string `json:"streamAnalyticsJobId,omitempty" tf:"stream_analytics_job_id,omitempty"`

	// Reference to a Job to populate streamAnalyticsJobId.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobIDRef *v1.Reference `json:"streamAnalyticsJobIdRef,omitempty" tf:"-"`

	// Selector for a Job to populate streamAnalyticsJobId.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobIDSelector *v1.Selector `json:"streamAnalyticsJobIdSelector,omitempty" tf:"-"`

	// The name of the Power BI table under the specified dataset.
	// +kubebuilder:validation:Optional
	Table *string `json:"table,omitempty" tf:"table,omitempty"`

	// The user display name of the user that was used to obtain the refresh token.
	// +kubebuilder:validation:Optional
	TokenUserDisplayName *string `json:"tokenUserDisplayName,omitempty" tf:"token_user_display_name,omitempty"`

	// The user principal name (UPN) of the user that was used to obtain the refresh token.
	// +kubebuilder:validation:Optional
	TokenUserPrincipalName *string `json:"tokenUserPrincipalName,omitempty" tf:"token_user_principal_name,omitempty"`
}

func (*OutputPowerBIParameters) DeepCopy added in v0.33.0 

func (in *OutputPowerBIParameters) DeepCopy() *OutputPowerBIParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputPowerBIParameters.

func (*OutputPowerBIParameters) DeepCopyInto added in v0.33.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputPowerBISpec added in v0.33.0 

type OutputPowerBISpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     OutputPowerBIParameters `json:"forProvider"`
}

OutputPowerBISpec defines the desired state of OutputPowerBI

func (*OutputPowerBISpec) DeepCopy added in v0.33.0 

func (in *OutputPowerBISpec) DeepCopy() *OutputPowerBISpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputPowerBISpec.

func (*OutputPowerBISpec) DeepCopyInto added in v0.33.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputPowerBIStatus added in v0.33.0 

type OutputPowerBIStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        OutputPowerBIObservation `json:"atProvider,omitempty"`
}

OutputPowerBIStatus defines the observed state of OutputPowerBI.

func (*OutputPowerBIStatus) DeepCopy added in v0.33.0 

func (in *OutputPowerBIStatus) DeepCopy() *OutputPowerBIStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputPowerBIStatus.

func (*OutputPowerBIStatus) DeepCopyInto added in v0.33.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputServiceBusQueue added in v0.27.0 

type OutputServiceBusQueue struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.name)",message="name is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.serialization)",message="serialization is a required parameter"
	Spec   OutputServiceBusQueueSpec   `json:"spec"`
	Status OutputServiceBusQueueStatus `json:"status,omitempty"`
}

OutputServiceBusQueue is the Schema for the OutputServiceBusQueues API. Manages a Stream Analytics Output to a ServiceBus Queue. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*OutputServiceBusQueue) DeepCopy added in v0.27.0 

func (in *OutputServiceBusQueue) DeepCopy() *OutputServiceBusQueue

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputServiceBusQueue.

func (*OutputServiceBusQueue) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OutputServiceBusQueue) DeepCopyObject added in v0.27.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*OutputServiceBusQueue) GetCondition added in v0.27.0 

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

GetCondition of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) GetConnectionDetailsMapping added in v0.27.0 

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

GetConnectionDetailsMapping for this OutputServiceBusQueue

func (*OutputServiceBusQueue) GetDeletionPolicy added in v0.27.0 

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

GetDeletionPolicy of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) GetID added in v0.27.0 

func (tr *OutputServiceBusQueue) GetID() string

GetID returns ID of underlying Terraform resource of this OutputServiceBusQueue

func (*OutputServiceBusQueue) GetManagementPolicy added in v0.31.0 

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

GetManagementPolicy of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) GetObservation added in v0.27.0 

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

GetObservation of this OutputServiceBusQueue

func (*OutputServiceBusQueue) GetParameters added in v0.27.0 

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

GetParameters of this OutputServiceBusQueue

func (*OutputServiceBusQueue) GetProviderConfigReference added in v0.27.0 

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

GetProviderConfigReference of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) GetProviderReference added in v0.27.0 

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

GetProviderReference of this OutputServiceBusQueue. Deprecated: Use GetProviderConfigReference.

func (*OutputServiceBusQueue) GetPublishConnectionDetailsTo added in v0.27.0 

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

GetPublishConnectionDetailsTo of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) GetTerraformResourceType added in v0.27.0 

func (mg *OutputServiceBusQueue) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this OutputServiceBusQueue

func (*OutputServiceBusQueue) GetTerraformSchemaVersion added in v0.27.0 

func (tr *OutputServiceBusQueue) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*OutputServiceBusQueue) GetWriteConnectionSecretToReference added in v0.27.0 

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

GetWriteConnectionSecretToReference of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) LateInitialize added in v0.27.0 

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

LateInitialize this OutputServiceBusQueue using its observed tfState. returns True if there are any spec changes for the resource.

func (*OutputServiceBusQueue) ResolveReferences added in v0.27.0 

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

ResolveReferences of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) SetConditions added in v0.27.0 

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

SetConditions of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) SetDeletionPolicy added in v0.27.0 

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

SetDeletionPolicy of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) SetManagementPolicy added in v0.31.0 

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

SetManagementPolicy of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) SetObservation added in v0.27.0 

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

SetObservation for this OutputServiceBusQueue

func (*OutputServiceBusQueue) SetParameters added in v0.27.0 

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

SetParameters for this OutputServiceBusQueue

func (*OutputServiceBusQueue) SetProviderConfigReference added in v0.27.0 

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

SetProviderConfigReference of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) SetProviderReference added in v0.27.0 

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

SetProviderReference of this OutputServiceBusQueue. Deprecated: Use SetProviderConfigReference.

func (*OutputServiceBusQueue) SetPublishConnectionDetailsTo added in v0.27.0 

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

SetPublishConnectionDetailsTo of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) SetWriteConnectionSecretToReference added in v0.27.0 

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

SetWriteConnectionSecretToReference of this OutputServiceBusQueue.

type OutputServiceBusQueueList added in v0.27.0 

type OutputServiceBusQueueList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []OutputServiceBusQueue `json:"items"`
}

OutputServiceBusQueueList contains a list of OutputServiceBusQueues

func (*OutputServiceBusQueueList) DeepCopy added in v0.27.0 

func (in *OutputServiceBusQueueList) DeepCopy() *OutputServiceBusQueueList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputServiceBusQueueList.

func (*OutputServiceBusQueueList) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OutputServiceBusQueueList) DeepCopyObject added in v0.27.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*OutputServiceBusQueueList) GetItems added in v0.27.0 

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

GetItems of this OutputServiceBusQueueList.

type OutputServiceBusQueueObservation added in v0.27.0 

type OutputServiceBusQueueObservation struct {

	// The authentication mode for the Stream Output. Possible values are Msi and ConnectionString. Defaults to ConnectionString.
	AuthenticationMode *string `json:"authenticationMode,omitempty" tf:"authentication_mode,omitempty"`

	// The ID of the Stream Analytics Output ServiceBus Queue.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// A list of property columns to add to the Service Bus Queue output.
	PropertyColumns []*string `json:"propertyColumns,omitempty" tf:"property_columns,omitempty"`

	// The name of the Service Bus Queue.
	QueueName *string `json:"queueName,omitempty" tf:"queue_name,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// A serialization block as defined below.
	Serialization []OutputServiceBusQueueSerializationObservation `json:"serialization,omitempty" tf:"serialization,omitempty"`

	// The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
	ServiceBusNamespace *string `json:"servicebusNamespace,omitempty" tf:"servicebus_namespace,omitempty"`

	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required if authentication_mode is ConnectionString.
	SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty" tf:"shared_access_policy_name,omitempty"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`

	// A key-value pair of system property columns that will be attached to the outgoing messages for the Service Bus Queue Output.
	SystemPropertyColumns map[string]*string `json:"systemPropertyColumns,omitempty" tf:"system_property_columns,omitempty"`
}

func (*OutputServiceBusQueueObservation) DeepCopy added in v0.27.0 

func (in *OutputServiceBusQueueObservation) DeepCopy() *OutputServiceBusQueueObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputServiceBusQueueObservation.

func (*OutputServiceBusQueueObservation) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputServiceBusQueueParameters added in v0.27.0 

type OutputServiceBusQueueParameters struct {

	// The authentication mode for the Stream Output. Possible values are Msi and ConnectionString. Defaults to ConnectionString.
	// +kubebuilder:validation:Optional
	AuthenticationMode *string `json:"authenticationMode,omitempty" tf:"authentication_mode,omitempty"`

	// The name of the Stream Output. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Optional
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// A list of property columns to add to the Service Bus Queue output.
	// +kubebuilder:validation:Optional
	PropertyColumns []*string `json:"propertyColumns,omitempty" tf:"property_columns,omitempty"`

	// The name of the Service Bus Queue.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/servicebus/v1beta1.Queue
	// +kubebuilder:validation:Optional
	QueueName *string `json:"queueName,omitempty" tf:"queue_name,omitempty"`

	// Reference to a Queue in servicebus to populate queueName.
	// +kubebuilder:validation:Optional
	QueueNameRef *v1.Reference `json:"queueNameRef,omitempty" tf:"-"`

	// Selector for a Queue in servicebus to populate queueName.
	// +kubebuilder:validation:Optional
	QueueNameSelector *v1.Selector `json:"queueNameSelector,omitempty" tf:"-"`

	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/azure/v1beta1.ResourceGroup
	// +kubebuilder:validation:Optional
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// Reference to a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameRef *v1.Reference `json:"resourceGroupNameRef,omitempty" tf:"-"`

	// Selector for a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameSelector *v1.Selector `json:"resourceGroupNameSelector,omitempty" tf:"-"`

	// A serialization block as defined below.
	// +kubebuilder:validation:Optional
	Serialization []OutputServiceBusQueueSerializationParameters `json:"serialization,omitempty" tf:"serialization,omitempty"`

	// The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/servicebus/v1beta1.ServiceBusNamespace
	// +kubebuilder:validation:Optional
	ServiceBusNamespace *string `json:"servicebusNamespace,omitempty" tf:"servicebus_namespace,omitempty"`

	// Reference to a ServiceBusNamespace in servicebus to populate servicebusNamespace.
	// +kubebuilder:validation:Optional
	ServiceBusNamespaceRef *v1.Reference `json:"servicebusNamespaceRef,omitempty" tf:"-"`

	// Selector for a ServiceBusNamespace in servicebus to populate servicebusNamespace.
	// +kubebuilder:validation:Optional
	ServiceBusNamespaceSelector *v1.Selector `json:"servicebusNamespaceSelector,omitempty" tf:"-"`

	// The shared access policy key for the specified shared access policy. Required if authentication_mode is ConnectionString.
	// +kubebuilder:validation:Optional
	SharedAccessPolicyKeySecretRef *v1.SecretKeySelector `json:"sharedAccessPolicyKeySecretRef,omitempty" tf:"-"`

	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required if authentication_mode is ConnectionString.
	// +kubebuilder:validation:Optional
	SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty" tf:"shared_access_policy_name,omitempty"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=Job
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`

	// Reference to a Job to populate streamAnalyticsJobName.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobNameRef *v1.Reference `json:"streamAnalyticsJobNameRef,omitempty" tf:"-"`

	// Selector for a Job to populate streamAnalyticsJobName.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobNameSelector *v1.Selector `json:"streamAnalyticsJobNameSelector,omitempty" tf:"-"`

	// A key-value pair of system property columns that will be attached to the outgoing messages for the Service Bus Queue Output.
	// +kubebuilder:validation:Optional
	SystemPropertyColumns map[string]*string `json:"systemPropertyColumns,omitempty" tf:"system_property_columns,omitempty"`
}

func (*OutputServiceBusQueueParameters) DeepCopy added in v0.27.0 

func (in *OutputServiceBusQueueParameters) DeepCopy() *OutputServiceBusQueueParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputServiceBusQueueParameters.

func (*OutputServiceBusQueueParameters) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputServiceBusQueueSerializationObservation added in v0.27.0 

type OutputServiceBusQueueSerializationObservation struct {

	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
	Encoding *string `json:"encoding,omitempty" tf:"encoding,omitempty"`

	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are   (space), , (comma), 	 (tab), | (pipe) and ;.
	FieldDelimiter *string `json:"fieldDelimiter,omitempty" tf:"field_delimiter,omitempty"`

	// Specifies the format of the JSON the output will be written in. Possible values are Array and LineSeparated.
	Format *string `json:"format,omitempty" tf:"format,omitempty"`

	// The serialization format used for outgoing data streams. Possible values are Avro, Csv, Json and Parquet.
	Type *string `json:"type,omitempty" tf:"type,omitempty"`
}

func (*OutputServiceBusQueueSerializationObservation) DeepCopy added in v0.27.0 

func (in *OutputServiceBusQueueSerializationObservation) DeepCopy() *OutputServiceBusQueueSerializationObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputServiceBusQueueSerializationObservation.

func (*OutputServiceBusQueueSerializationObservation) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputServiceBusQueueSerializationParameters added in v0.27.0 

type OutputServiceBusQueueSerializationParameters struct {

	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
	// +kubebuilder:validation:Optional
	Encoding *string `json:"encoding,omitempty" tf:"encoding,omitempty"`

	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are   (space), , (comma), 	 (tab), | (pipe) and ;.
	// +kubebuilder:validation:Optional
	FieldDelimiter *string `json:"fieldDelimiter,omitempty" tf:"field_delimiter,omitempty"`

	// Specifies the format of the JSON the output will be written in. Possible values are Array and LineSeparated.
	// +kubebuilder:validation:Optional
	Format *string `json:"format,omitempty" tf:"format,omitempty"`

	// The serialization format used for outgoing data streams. Possible values are Avro, Csv, Json and Parquet.
	// +kubebuilder:validation:Required
	Type *string `json:"type" tf:"type,omitempty"`
}

func (*OutputServiceBusQueueSerializationParameters) DeepCopy added in v0.27.0 

func (in *OutputServiceBusQueueSerializationParameters) DeepCopy() *OutputServiceBusQueueSerializationParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputServiceBusQueueSerializationParameters.

func (*OutputServiceBusQueueSerializationParameters) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputServiceBusQueueSpec added in v0.27.0 

type OutputServiceBusQueueSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     OutputServiceBusQueueParameters `json:"forProvider"`
}

OutputServiceBusQueueSpec defines the desired state of OutputServiceBusQueue

func (*OutputServiceBusQueueSpec) DeepCopy added in v0.27.0 

func (in *OutputServiceBusQueueSpec) DeepCopy() *OutputServiceBusQueueSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputServiceBusQueueSpec.

func (*OutputServiceBusQueueSpec) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputServiceBusQueueStatus added in v0.27.0 

type OutputServiceBusQueueStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        OutputServiceBusQueueObservation `json:"atProvider,omitempty"`
}

OutputServiceBusQueueStatus defines the observed state of OutputServiceBusQueue.

func (*OutputServiceBusQueueStatus) DeepCopy added in v0.27.0 

func (in *OutputServiceBusQueueStatus) DeepCopy() *OutputServiceBusQueueStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputServiceBusQueueStatus.

func (*OutputServiceBusQueueStatus) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputServiceBusTopic added in v0.27.0 

type OutputServiceBusTopic struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.name)",message="name is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.serialization)",message="serialization is a required parameter"
	Spec   OutputServiceBusTopicSpec   `json:"spec"`
	Status OutputServiceBusTopicStatus `json:"status,omitempty"`
}

OutputServiceBusTopic is the Schema for the OutputServiceBusTopics API. Manages a Stream Analytics Output to a ServiceBus Topic. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*OutputServiceBusTopic) DeepCopy added in v0.27.0 

func (in *OutputServiceBusTopic) DeepCopy() *OutputServiceBusTopic

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputServiceBusTopic.

func (*OutputServiceBusTopic) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OutputServiceBusTopic) DeepCopyObject added in v0.27.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*OutputServiceBusTopic) GetCondition added in v0.27.0 

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

GetCondition of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) GetConnectionDetailsMapping added in v0.27.0 

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

GetConnectionDetailsMapping for this OutputServiceBusTopic

func (*OutputServiceBusTopic) GetDeletionPolicy added in v0.27.0 

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

GetDeletionPolicy of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) GetID added in v0.27.0 

func (tr *OutputServiceBusTopic) GetID() string

GetID returns ID of underlying Terraform resource of this OutputServiceBusTopic

func (*OutputServiceBusTopic) GetManagementPolicy added in v0.31.0 

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

GetManagementPolicy of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) GetObservation added in v0.27.0 

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

GetObservation of this OutputServiceBusTopic

func (*OutputServiceBusTopic) GetParameters added in v0.27.0 

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

GetParameters of this OutputServiceBusTopic

func (*OutputServiceBusTopic) GetProviderConfigReference added in v0.27.0 

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

GetProviderConfigReference of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) GetProviderReference added in v0.27.0 

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

GetProviderReference of this OutputServiceBusTopic. Deprecated: Use GetProviderConfigReference.

func (*OutputServiceBusTopic) GetPublishConnectionDetailsTo added in v0.27.0 

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

GetPublishConnectionDetailsTo of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) GetTerraformResourceType added in v0.27.0 

func (mg *OutputServiceBusTopic) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this OutputServiceBusTopic

func (*OutputServiceBusTopic) GetTerraformSchemaVersion added in v0.27.0 

func (tr *OutputServiceBusTopic) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*OutputServiceBusTopic) GetWriteConnectionSecretToReference added in v0.27.0 

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

GetWriteConnectionSecretToReference of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) LateInitialize added in v0.27.0 

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

LateInitialize this OutputServiceBusTopic using its observed tfState. returns True if there are any spec changes for the resource.

func (*OutputServiceBusTopic) ResolveReferences added in v0.27.0 

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

ResolveReferences of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) SetConditions added in v0.27.0 

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

SetConditions of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) SetDeletionPolicy added in v0.27.0 

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

SetDeletionPolicy of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) SetManagementPolicy added in v0.31.0 

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

SetManagementPolicy of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) SetObservation added in v0.27.0 

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

SetObservation for this OutputServiceBusTopic

func (*OutputServiceBusTopic) SetParameters added in v0.27.0 

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

SetParameters for this OutputServiceBusTopic

func (*OutputServiceBusTopic) SetProviderConfigReference added in v0.27.0 

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

SetProviderConfigReference of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) SetProviderReference added in v0.27.0 

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

SetProviderReference of this OutputServiceBusTopic. Deprecated: Use SetProviderConfigReference.

func (*OutputServiceBusTopic) SetPublishConnectionDetailsTo added in v0.27.0 

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

SetPublishConnectionDetailsTo of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) SetWriteConnectionSecretToReference added in v0.27.0 

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

SetWriteConnectionSecretToReference of this OutputServiceBusTopic.

type OutputServiceBusTopicList added in v0.27.0 

type OutputServiceBusTopicList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []OutputServiceBusTopic `json:"items"`
}

OutputServiceBusTopicList contains a list of OutputServiceBusTopics

func (*OutputServiceBusTopicList) DeepCopy added in v0.27.0 

func (in *OutputServiceBusTopicList) DeepCopy() *OutputServiceBusTopicList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputServiceBusTopicList.

func (*OutputServiceBusTopicList) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OutputServiceBusTopicList) DeepCopyObject added in v0.27.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*OutputServiceBusTopicList) GetItems added in v0.27.0 

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

GetItems of this OutputServiceBusTopicList.

type OutputServiceBusTopicObservation added in v0.27.0 

type OutputServiceBusTopicObservation struct {

	// The authentication mode for the Stream Output. Possible values are Msi and ConnectionString. Defaults to ConnectionString.
	AuthenticationMode *string `json:"authenticationMode,omitempty" tf:"authentication_mode,omitempty"`

	// The ID of the Stream Analytics Output ServiceBus Topic.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// A list of property columns to add to the Service Bus Topic output.
	PropertyColumns []*string `json:"propertyColumns,omitempty" tf:"property_columns,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// A serialization block as defined below.
	Serialization []OutputServiceBusTopicSerializationObservation `json:"serialization,omitempty" tf:"serialization,omitempty"`

	// The namespace that is associated with the desired Event Hub, Service Bus Topic, Service Bus Topic, etc.
	ServiceBusNamespace *string `json:"servicebusNamespace,omitempty" tf:"servicebus_namespace,omitempty"`

	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required if authentication_mode is ConnectionString.
	SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty" tf:"shared_access_policy_name,omitempty"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`

	// A key-value pair of system property columns that will be attached to the outgoing messages for the Service Bus Topic Output.
	SystemPropertyColumns map[string]*string `json:"systemPropertyColumns,omitempty" tf:"system_property_columns,omitempty"`

	// The name of the Service Bus Topic.
	TopicName *string `json:"topicName,omitempty" tf:"topic_name,omitempty"`
}

func (*OutputServiceBusTopicObservation) DeepCopy added in v0.27.0 

func (in *OutputServiceBusTopicObservation) DeepCopy() *OutputServiceBusTopicObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputServiceBusTopicObservation.

func (*OutputServiceBusTopicObservation) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputServiceBusTopicParameters added in v0.27.0 

type OutputServiceBusTopicParameters struct {

	// The authentication mode for the Stream Output. Possible values are Msi and ConnectionString. Defaults to ConnectionString.
	// +kubebuilder:validation:Optional
	AuthenticationMode *string `json:"authenticationMode,omitempty" tf:"authentication_mode,omitempty"`

	// The name of the Stream Output. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Optional
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// A list of property columns to add to the Service Bus Topic output.
	// +kubebuilder:validation:Optional
	PropertyColumns []*string `json:"propertyColumns,omitempty" tf:"property_columns,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/azure/v1beta1.ResourceGroup
	// +kubebuilder:validation:Optional
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// Reference to a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameRef *v1.Reference `json:"resourceGroupNameRef,omitempty" tf:"-"`

	// Selector for a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameSelector *v1.Selector `json:"resourceGroupNameSelector,omitempty" tf:"-"`

	// A serialization block as defined below.
	// +kubebuilder:validation:Optional
	Serialization []OutputServiceBusTopicSerializationParameters `json:"serialization,omitempty" tf:"serialization,omitempty"`

	// The namespace that is associated with the desired Event Hub, Service Bus Topic, Service Bus Topic, etc.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/servicebus/v1beta1.ServiceBusNamespace
	// +kubebuilder:validation:Optional
	ServiceBusNamespace *string `json:"servicebusNamespace,omitempty" tf:"servicebus_namespace,omitempty"`

	// Reference to a ServiceBusNamespace in servicebus to populate servicebusNamespace.
	// +kubebuilder:validation:Optional
	ServiceBusNamespaceRef *v1.Reference `json:"servicebusNamespaceRef,omitempty" tf:"-"`

	// Selector for a ServiceBusNamespace in servicebus to populate servicebusNamespace.
	// +kubebuilder:validation:Optional
	ServiceBusNamespaceSelector *v1.Selector `json:"servicebusNamespaceSelector,omitempty" tf:"-"`

	// The shared access policy key for the specified shared access policy. Required if authentication_mode is ConnectionString.
	// +kubebuilder:validation:Optional
	SharedAccessPolicyKeySecretRef *v1.SecretKeySelector `json:"sharedAccessPolicyKeySecretRef,omitempty" tf:"-"`

	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required if authentication_mode is ConnectionString.
	// +kubebuilder:validation:Optional
	SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty" tf:"shared_access_policy_name,omitempty"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=Job
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`

	// Reference to a Job to populate streamAnalyticsJobName.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobNameRef *v1.Reference `json:"streamAnalyticsJobNameRef,omitempty" tf:"-"`

	// Selector for a Job to populate streamAnalyticsJobName.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobNameSelector *v1.Selector `json:"streamAnalyticsJobNameSelector,omitempty" tf:"-"`

	// A key-value pair of system property columns that will be attached to the outgoing messages for the Service Bus Topic Output.
	// +kubebuilder:validation:Optional
	SystemPropertyColumns map[string]*string `json:"systemPropertyColumns,omitempty" tf:"system_property_columns,omitempty"`

	// The name of the Service Bus Topic.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/servicebus/v1beta1.Topic
	// +kubebuilder:validation:Optional
	TopicName *string `json:"topicName,omitempty" tf:"topic_name,omitempty"`

	// Reference to a Topic in servicebus to populate topicName.
	// +kubebuilder:validation:Optional
	TopicNameRef *v1.Reference `json:"topicNameRef,omitempty" tf:"-"`

	// Selector for a Topic in servicebus to populate topicName.
	// +kubebuilder:validation:Optional
	TopicNameSelector *v1.Selector `json:"topicNameSelector,omitempty" tf:"-"`
}

func (*OutputServiceBusTopicParameters) DeepCopy added in v0.27.0 

func (in *OutputServiceBusTopicParameters) DeepCopy() *OutputServiceBusTopicParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputServiceBusTopicParameters.

func (*OutputServiceBusTopicParameters) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputServiceBusTopicSerializationObservation added in v0.27.0 

type OutputServiceBusTopicSerializationObservation struct {

	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
	Encoding *string `json:"encoding,omitempty" tf:"encoding,omitempty"`

	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are   (space), , (comma), 	 (tab), | (pipe) and ;.
	FieldDelimiter *string `json:"fieldDelimiter,omitempty" tf:"field_delimiter,omitempty"`

	// Specifies the format of the JSON the output will be written in. Possible values are Array and LineSeparated.
	Format *string `json:"format,omitempty" tf:"format,omitempty"`

	// The serialization format used for outgoing data streams. Possible values are Avro, Csv, Json and Parquet.
	Type *string `json:"type,omitempty" tf:"type,omitempty"`
}

func (*OutputServiceBusTopicSerializationObservation) DeepCopy added in v0.27.0 

func (in *OutputServiceBusTopicSerializationObservation) DeepCopy() *OutputServiceBusTopicSerializationObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputServiceBusTopicSerializationObservation.

func (*OutputServiceBusTopicSerializationObservation) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputServiceBusTopicSerializationParameters added in v0.27.0 

type OutputServiceBusTopicSerializationParameters struct {

	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
	// +kubebuilder:validation:Optional
	Encoding *string `json:"encoding,omitempty" tf:"encoding,omitempty"`

	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are   (space), , (comma), 	 (tab), | (pipe) and ;.
	// +kubebuilder:validation:Optional
	FieldDelimiter *string `json:"fieldDelimiter,omitempty" tf:"field_delimiter,omitempty"`

	// Specifies the format of the JSON the output will be written in. Possible values are Array and LineSeparated.
	// +kubebuilder:validation:Optional
	Format *string `json:"format,omitempty" tf:"format,omitempty"`

	// The serialization format used for outgoing data streams. Possible values are Avro, Csv, Json and Parquet.
	// +kubebuilder:validation:Required
	Type *string `json:"type" tf:"type,omitempty"`
}

func (*OutputServiceBusTopicSerializationParameters) DeepCopy added in v0.27.0 

func (in *OutputServiceBusTopicSerializationParameters) DeepCopy() *OutputServiceBusTopicSerializationParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputServiceBusTopicSerializationParameters.

func (*OutputServiceBusTopicSerializationParameters) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputServiceBusTopicSpec added in v0.27.0 

type OutputServiceBusTopicSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     OutputServiceBusTopicParameters `json:"forProvider"`
}

OutputServiceBusTopicSpec defines the desired state of OutputServiceBusTopic

func (*OutputServiceBusTopicSpec) DeepCopy added in v0.27.0 

func (in *OutputServiceBusTopicSpec) DeepCopy() *OutputServiceBusTopicSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputServiceBusTopicSpec.

func (*OutputServiceBusTopicSpec) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputServiceBusTopicStatus added in v0.27.0 

type OutputServiceBusTopicStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        OutputServiceBusTopicObservation `json:"atProvider,omitempty"`
}

OutputServiceBusTopicStatus defines the observed state of OutputServiceBusTopic.

func (*OutputServiceBusTopicStatus) DeepCopy added in v0.27.0 

func (in *OutputServiceBusTopicStatus) DeepCopy() *OutputServiceBusTopicStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputServiceBusTopicStatus.

func (*OutputServiceBusTopicStatus) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputSynapse 

type OutputSynapse struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.database)",message="database is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.passwordSecretRef)",message="passwordSecretRef is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.server)",message="server is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.table)",message="table is a required parameter"
	Spec   OutputSynapseSpec   `json:"spec"`
	Status OutputSynapseStatus `json:"status,omitempty"`
}

OutputSynapse is the Schema for the OutputSynapses API. Manages a Stream Analytics Output to an Azure Synapse Analytics Workspace. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*OutputSynapse) DeepCopy 

func (in *OutputSynapse) DeepCopy() *OutputSynapse

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputSynapse.

func (*OutputSynapse) DeepCopyInto 

func (in *OutputSynapse) DeepCopyInto(out *OutputSynapse)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OutputSynapse) DeepCopyObject 

func (in *OutputSynapse) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*OutputSynapse) GetCondition 

func (mg *OutputSynapse) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this OutputSynapse.

func (*OutputSynapse) GetConnectionDetailsMapping 

func (tr *OutputSynapse) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this OutputSynapse

func (*OutputSynapse) GetDeletionPolicy 

func (mg *OutputSynapse) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this OutputSynapse.

func (*OutputSynapse) GetID 

func (tr *OutputSynapse) GetID() string

GetID returns ID of underlying Terraform resource of this OutputSynapse

func (*OutputSynapse) GetManagementPolicy added in v0.31.0 

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

GetManagementPolicy of this OutputSynapse.

func (*OutputSynapse) GetObservation 

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

GetObservation of this OutputSynapse

func (*OutputSynapse) GetParameters 

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

GetParameters of this OutputSynapse

func (*OutputSynapse) GetProviderConfigReference 

func (mg *OutputSynapse) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this OutputSynapse.

func (*OutputSynapse) GetProviderReference 

func (mg *OutputSynapse) GetProviderReference() *xpv1.Reference

GetProviderReference of this OutputSynapse. Deprecated: Use GetProviderConfigReference.

func (*OutputSynapse) GetPublishConnectionDetailsTo 

func (mg *OutputSynapse) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this OutputSynapse.

func (*OutputSynapse) GetTerraformResourceType 

func (mg *OutputSynapse) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this OutputSynapse

func (*OutputSynapse) GetTerraformSchemaVersion 

func (tr *OutputSynapse) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*OutputSynapse) GetWriteConnectionSecretToReference 

func (mg *OutputSynapse) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this OutputSynapse.

func (*OutputSynapse) LateInitialize 

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

LateInitialize this OutputSynapse using its observed tfState. returns True if there are any spec changes for the resource.

func (*OutputSynapse) ResolveReferences 

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

ResolveReferences of this OutputSynapse.

func (*OutputSynapse) SetConditions 

func (mg *OutputSynapse) SetConditions(c ...xpv1.Condition)

SetConditions of this OutputSynapse.

func (*OutputSynapse) SetDeletionPolicy 

func (mg *OutputSynapse) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this OutputSynapse.

func (*OutputSynapse) SetManagementPolicy added in v0.31.0 

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

SetManagementPolicy of this OutputSynapse.

func (*OutputSynapse) SetObservation 

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

SetObservation for this OutputSynapse

func (*OutputSynapse) SetParameters 

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

SetParameters for this OutputSynapse

func (*OutputSynapse) SetProviderConfigReference 

func (mg *OutputSynapse) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this OutputSynapse.

func (*OutputSynapse) SetProviderReference 

func (mg *OutputSynapse) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this OutputSynapse. Deprecated: Use SetProviderConfigReference.

func (*OutputSynapse) SetPublishConnectionDetailsTo 

func (mg *OutputSynapse) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this OutputSynapse.

func (*OutputSynapse) SetWriteConnectionSecretToReference 

func (mg *OutputSynapse) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this OutputSynapse.

type OutputSynapseList 

type OutputSynapseList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []OutputSynapse `json:"items"`
}

OutputSynapseList contains a list of OutputSynapses

func (*OutputSynapseList) DeepCopy 

func (in *OutputSynapseList) DeepCopy() *OutputSynapseList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputSynapseList.

func (*OutputSynapseList) DeepCopyInto 

func (in *OutputSynapseList) DeepCopyInto(out *OutputSynapseList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OutputSynapseList) DeepCopyObject 

func (in *OutputSynapseList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*OutputSynapseList) GetItems 

func (l *OutputSynapseList) GetItems() []resource.Managed

GetItems of this OutputSynapseList.

type OutputSynapseObservation 

type OutputSynapseObservation struct {

	// The name of the Azure SQL database. Changing this forces a new resource to be created.
	Database *string `json:"database,omitempty" tf:"database,omitempty"`

	// The ID of the Stream Analytics Output to an Azure Synapse Analytics Workspace.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// The name of the SQL server containing the Azure SQL database. Changing this forces a new resource to be created.
	Server *string `json:"server,omitempty" tf:"server,omitempty"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`

	// The name of the table in the Azure SQL database. Changing this forces a new resource to be created.
	Table *string `json:"table,omitempty" tf:"table,omitempty"`

	// The user name that will be used to connect to the Azure SQL database. Changing this forces a new resource to be created.
	User *string `json:"user,omitempty" tf:"user,omitempty"`
}

func (*OutputSynapseObservation) DeepCopy 

func (in *OutputSynapseObservation) DeepCopy() *OutputSynapseObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputSynapseObservation.

func (*OutputSynapseObservation) DeepCopyInto 

func (in *OutputSynapseObservation) DeepCopyInto(out *OutputSynapseObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputSynapseParameters 

type OutputSynapseParameters struct {

	// The name of the Azure SQL database. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Optional
	Database *string `json:"database,omitempty" tf:"database,omitempty"`

	// The password that will be used to connect to the Azure SQL database.
	// +kubebuilder:validation:Optional
	PasswordSecretRef v1.SecretKeySelector `json:"passwordSecretRef" tf:"-"`

	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/azure/v1beta1.ResourceGroup
	// +kubebuilder:validation:Optional
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// Reference to a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameRef *v1.Reference `json:"resourceGroupNameRef,omitempty" tf:"-"`

	// Selector for a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameSelector *v1.Selector `json:"resourceGroupNameSelector,omitempty" tf:"-"`

	// The name of the SQL server containing the Azure SQL database. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Optional
	Server *string `json:"server,omitempty" tf:"server,omitempty"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=Job
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`

	// Reference to a Job to populate streamAnalyticsJobName.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobNameRef *v1.Reference `json:"streamAnalyticsJobNameRef,omitempty" tf:"-"`

	// Selector for a Job to populate streamAnalyticsJobName.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobNameSelector *v1.Selector `json:"streamAnalyticsJobNameSelector,omitempty" tf:"-"`

	// The name of the table in the Azure SQL database. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Optional
	Table *string `json:"table,omitempty" tf:"table,omitempty"`

	// The user name that will be used to connect to the Azure SQL database. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/synapse/v1beta1.Workspace
	// +crossplane:generate:reference:extractor=github.com/upbound/upjet/pkg/resource.ExtractParamPath("sql_administrator_login",false)
	// +kubebuilder:validation:Optional
	User *string `json:"user,omitempty" tf:"user,omitempty"`

	// Reference to a Workspace in synapse to populate user.
	// +kubebuilder:validation:Optional
	UserRef *v1.Reference `json:"userRef,omitempty" tf:"-"`

	// Selector for a Workspace in synapse to populate user.
	// +kubebuilder:validation:Optional
	UserSelector *v1.Selector `json:"userSelector,omitempty" tf:"-"`
}

func (*OutputSynapseParameters) DeepCopy 

func (in *OutputSynapseParameters) DeepCopy() *OutputSynapseParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputSynapseParameters.

func (*OutputSynapseParameters) DeepCopyInto 

func (in *OutputSynapseParameters) DeepCopyInto(out *OutputSynapseParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputSynapseSpec 

type OutputSynapseSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     OutputSynapseParameters `json:"forProvider"`
}

OutputSynapseSpec defines the desired state of OutputSynapse

func (*OutputSynapseSpec) DeepCopy 

func (in *OutputSynapseSpec) DeepCopy() *OutputSynapseSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputSynapseSpec.

func (*OutputSynapseSpec) DeepCopyInto 

func (in *OutputSynapseSpec) DeepCopyInto(out *OutputSynapseSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputSynapseStatus 

type OutputSynapseStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        OutputSynapseObservation `json:"atProvider,omitempty"`
}

OutputSynapseStatus defines the observed state of OutputSynapse.

func (*OutputSynapseStatus) DeepCopy 

func (in *OutputSynapseStatus) DeepCopy() *OutputSynapseStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputSynapseStatus.

func (*OutputSynapseStatus) DeepCopyInto 

func (in *OutputSynapseStatus) DeepCopyInto(out *OutputSynapseStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputTable added in v0.33.0 

type OutputTable struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.batchSize)",message="batchSize is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.partitionKey)",message="partitionKey is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.rowKey)",message="rowKey is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.storageAccountKeySecretRef)",message="storageAccountKeySecretRef is a required parameter"
	Spec   OutputTableSpec   `json:"spec"`
	Status OutputTableStatus `json:"status,omitempty"`
}

OutputTable is the Schema for the OutputTables API. Manages a Stream Analytics Output Table. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*OutputTable) DeepCopy added in v0.33.0 

func (in *OutputTable) DeepCopy() *OutputTable

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputTable.

func (*OutputTable) DeepCopyInto added in v0.33.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OutputTable) DeepCopyObject added in v0.33.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*OutputTable) GetCondition added in v0.33.0 

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

GetCondition of this OutputTable.

func (*OutputTable) GetConnectionDetailsMapping added in v0.33.0 

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

GetConnectionDetailsMapping for this OutputTable

func (*OutputTable) GetDeletionPolicy added in v0.33.0 

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

GetDeletionPolicy of this OutputTable.

func (*OutputTable) GetID added in v0.33.0 

func (tr *OutputTable) GetID() string

GetID returns ID of underlying Terraform resource of this OutputTable

func (*OutputTable) GetManagementPolicy added in v0.33.0 

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

GetManagementPolicy of this OutputTable.

func (*OutputTable) GetObservation added in v0.33.0 

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

GetObservation of this OutputTable

func (*OutputTable) GetParameters added in v0.33.0 

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

GetParameters of this OutputTable

func (*OutputTable) GetProviderConfigReference added in v0.33.0 

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

GetProviderConfigReference of this OutputTable.

func (*OutputTable) GetProviderReference added in v0.33.0 

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

GetProviderReference of this OutputTable. Deprecated: Use GetProviderConfigReference.

func (*OutputTable) GetPublishConnectionDetailsTo added in v0.33.0 

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

GetPublishConnectionDetailsTo of this OutputTable.

func (*OutputTable) GetTerraformResourceType added in v0.33.0 

func (mg *OutputTable) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this OutputTable

func (*OutputTable) GetTerraformSchemaVersion added in v0.33.0 

func (tr *OutputTable) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*OutputTable) GetWriteConnectionSecretToReference added in v0.33.0 

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

GetWriteConnectionSecretToReference of this OutputTable.

func (*OutputTable) LateInitialize added in v0.33.0 

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

LateInitialize this OutputTable using its observed tfState. returns True if there are any spec changes for the resource.

func (*OutputTable) ResolveReferences added in v0.33.0 

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

ResolveReferences of this OutputTable.

func (*OutputTable) SetConditions added in v0.33.0 

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

SetConditions of this OutputTable.

func (*OutputTable) SetDeletionPolicy added in v0.33.0 

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

SetDeletionPolicy of this OutputTable.

func (*OutputTable) SetManagementPolicy added in v0.33.0 

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

SetManagementPolicy of this OutputTable.

func (*OutputTable) SetObservation added in v0.33.0 

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

SetObservation for this OutputTable

func (*OutputTable) SetParameters added in v0.33.0 

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

SetParameters for this OutputTable

func (*OutputTable) SetProviderConfigReference added in v0.33.0 

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

SetProviderConfigReference of this OutputTable.

func (*OutputTable) SetProviderReference added in v0.33.0 

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

SetProviderReference of this OutputTable. Deprecated: Use SetProviderConfigReference.

func (*OutputTable) SetPublishConnectionDetailsTo added in v0.33.0 

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

SetPublishConnectionDetailsTo of this OutputTable.

func (*OutputTable) SetWriteConnectionSecretToReference added in v0.33.0 

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

SetWriteConnectionSecretToReference of this OutputTable.

type OutputTableList added in v0.33.0 

type OutputTableList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []OutputTable `json:"items"`
}

OutputTableList contains a list of OutputTables

func (*OutputTableList) DeepCopy added in v0.33.0 

func (in *OutputTableList) DeepCopy() *OutputTableList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputTableList.

func (*OutputTableList) DeepCopyInto added in v0.33.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OutputTableList) DeepCopyObject added in v0.33.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*OutputTableList) GetItems added in v0.33.0 

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

GetItems of this OutputTableList.

type OutputTableObservation added in v0.33.0 

type OutputTableObservation struct {

	// The number of records for a batch operation. Must be between 1 and 100.
	BatchSize *float64 `json:"batchSize,omitempty" tf:"batch_size,omitempty"`

	// A list of the column names to be removed from output event entities.
	ColumnsToRemove []*string `json:"columnsToRemove,omitempty" tf:"columns_to_remove,omitempty"`

	// The ID of the Stream Analytics Output Table.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The name of the output column that contains the partition key.
	PartitionKey *string `json:"partitionKey,omitempty" tf:"partition_key,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// The name of the output column that contains the row key.
	RowKey *string `json:"rowKey,omitempty" tf:"row_key,omitempty"`

	// The name of the Storage Account.
	StorageAccountName *string `json:"storageAccountName,omitempty" tf:"storage_account_name,omitempty"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`

	// The name of the table where the stream should be output to.
	Table *string `json:"table,omitempty" tf:"table,omitempty"`
}

func (*OutputTableObservation) DeepCopy added in v0.33.0 

func (in *OutputTableObservation) DeepCopy() *OutputTableObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputTableObservation.

func (*OutputTableObservation) DeepCopyInto added in v0.33.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputTableParameters added in v0.33.0 

type OutputTableParameters struct {

	// The number of records for a batch operation. Must be between 1 and 100.
	// +kubebuilder:validation:Optional
	BatchSize *float64 `json:"batchSize,omitempty" tf:"batch_size,omitempty"`

	// A list of the column names to be removed from output event entities.
	// +kubebuilder:validation:Optional
	ColumnsToRemove []*string `json:"columnsToRemove,omitempty" tf:"columns_to_remove,omitempty"`

	// The name of the output column that contains the partition key.
	// +kubebuilder:validation:Optional
	PartitionKey *string `json:"partitionKey,omitempty" tf:"partition_key,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/azure/v1beta1.ResourceGroup
	// +kubebuilder:validation:Optional
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// Reference to a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameRef *v1.Reference `json:"resourceGroupNameRef,omitempty" tf:"-"`

	// Selector for a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameSelector *v1.Selector `json:"resourceGroupNameSelector,omitempty" tf:"-"`

	// The name of the output column that contains the row key.
	// +kubebuilder:validation:Optional
	RowKey *string `json:"rowKey,omitempty" tf:"row_key,omitempty"`

	// The Access Key which should be used to connect to this Storage Account.
	// +kubebuilder:validation:Optional
	StorageAccountKeySecretRef v1.SecretKeySelector `json:"storageAccountKeySecretRef" tf:"-"`

	// The name of the Storage Account.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/storage/v1beta1.Account
	// +kubebuilder:validation:Optional
	StorageAccountName *string `json:"storageAccountName,omitempty" tf:"storage_account_name,omitempty"`

	// Reference to a Account in storage to populate storageAccountName.
	// +kubebuilder:validation:Optional
	StorageAccountNameRef *v1.Reference `json:"storageAccountNameRef,omitempty" tf:"-"`

	// Selector for a Account in storage to populate storageAccountName.
	// +kubebuilder:validation:Optional
	StorageAccountNameSelector *v1.Selector `json:"storageAccountNameSelector,omitempty" tf:"-"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Required
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName" tf:"stream_analytics_job_name,omitempty"`

	// The name of the table where the stream should be output to.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/storage/v1beta1.Table
	// +crossplane:generate:reference:extractor=github.com/upbound/upjet/pkg/resource.ExtractParamPath("name",false)
	// +kubebuilder:validation:Optional
	Table *string `json:"table,omitempty" tf:"table,omitempty"`

	// Reference to a Table in storage to populate table.
	// +kubebuilder:validation:Optional
	TableRef *v1.Reference `json:"tableRef,omitempty" tf:"-"`

	// Selector for a Table in storage to populate table.
	// +kubebuilder:validation:Optional
	TableSelector *v1.Selector `json:"tableSelector,omitempty" tf:"-"`
}

func (*OutputTableParameters) DeepCopy added in v0.33.0 

func (in *OutputTableParameters) DeepCopy() *OutputTableParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputTableParameters.

func (*OutputTableParameters) DeepCopyInto added in v0.33.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputTableSpec added in v0.33.0 

type OutputTableSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     OutputTableParameters `json:"forProvider"`
}

OutputTableSpec defines the desired state of OutputTable

func (*OutputTableSpec) DeepCopy added in v0.33.0 

func (in *OutputTableSpec) DeepCopy() *OutputTableSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputTableSpec.

func (*OutputTableSpec) DeepCopyInto added in v0.33.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputTableStatus added in v0.33.0 

type OutputTableStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        OutputTableObservation `json:"atProvider,omitempty"`
}

OutputTableStatus defines the observed state of OutputTable.

func (*OutputTableStatus) DeepCopy added in v0.33.0 

func (in *OutputTableStatus) DeepCopy() *OutputTableStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputTableStatus.

func (*OutputTableStatus) DeepCopyInto added in v0.33.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReferenceInputBlob added in v0.27.0 

type ReferenceInputBlob struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.dateFormat)",message="dateFormat is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.name)",message="name is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.pathPattern)",message="pathPattern is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.serialization)",message="serialization is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.timeFormat)",message="timeFormat is a required parameter"
	Spec   ReferenceInputBlobSpec   `json:"spec"`
	Status ReferenceInputBlobStatus `json:"status,omitempty"`
}

ReferenceInputBlob is the Schema for the ReferenceInputBlobs API. Manages a Stream Analytics Reference Input Blob. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*ReferenceInputBlob) DeepCopy added in v0.27.0 

func (in *ReferenceInputBlob) DeepCopy() *ReferenceInputBlob

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReferenceInputBlob.

func (*ReferenceInputBlob) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ReferenceInputBlob) DeepCopyObject added in v0.27.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*ReferenceInputBlob) GetCondition added in v0.27.0 

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

GetCondition of this ReferenceInputBlob.

func (*ReferenceInputBlob) GetConnectionDetailsMapping added in v0.27.0 

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

GetConnectionDetailsMapping for this ReferenceInputBlob

func (*ReferenceInputBlob) GetDeletionPolicy added in v0.27.0 

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

GetDeletionPolicy of this ReferenceInputBlob.

func (*ReferenceInputBlob) GetID added in v0.27.0 

func (tr *ReferenceInputBlob) GetID() string

GetID returns ID of underlying Terraform resource of this ReferenceInputBlob

func (*ReferenceInputBlob) GetManagementPolicy added in v0.31.0 

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

GetManagementPolicy of this ReferenceInputBlob.

func (*ReferenceInputBlob) GetObservation added in v0.27.0 

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

GetObservation of this ReferenceInputBlob

func (*ReferenceInputBlob) GetParameters added in v0.27.0 

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

GetParameters of this ReferenceInputBlob

func (*ReferenceInputBlob) GetProviderConfigReference added in v0.27.0 

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

GetProviderConfigReference of this ReferenceInputBlob.

func (*ReferenceInputBlob) GetProviderReference added in v0.27.0 

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

GetProviderReference of this ReferenceInputBlob. Deprecated: Use GetProviderConfigReference.

func (*ReferenceInputBlob) GetPublishConnectionDetailsTo added in v0.27.0 

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

GetPublishConnectionDetailsTo of this ReferenceInputBlob.

func (*ReferenceInputBlob) GetTerraformResourceType added in v0.27.0 

func (mg *ReferenceInputBlob) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this ReferenceInputBlob

func (*ReferenceInputBlob) GetTerraformSchemaVersion added in v0.27.0 

func (tr *ReferenceInputBlob) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*ReferenceInputBlob) GetWriteConnectionSecretToReference added in v0.27.0 

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

GetWriteConnectionSecretToReference of this ReferenceInputBlob.

func (*ReferenceInputBlob) LateInitialize added in v0.27.0 

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

LateInitialize this ReferenceInputBlob using its observed tfState. returns True if there are any spec changes for the resource.

func (*ReferenceInputBlob) ResolveReferences added in v0.27.0 

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

ResolveReferences of this ReferenceInputBlob.

func (*ReferenceInputBlob) SetConditions added in v0.27.0 

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

SetConditions of this ReferenceInputBlob.

func (*ReferenceInputBlob) SetDeletionPolicy added in v0.27.0 

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

SetDeletionPolicy of this ReferenceInputBlob.

func (*ReferenceInputBlob) SetManagementPolicy added in v0.31.0 

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

SetManagementPolicy of this ReferenceInputBlob.

func (*ReferenceInputBlob) SetObservation added in v0.27.0 

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

SetObservation for this ReferenceInputBlob

func (*ReferenceInputBlob) SetParameters added in v0.27.0 

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

SetParameters for this ReferenceInputBlob

func (*ReferenceInputBlob) SetProviderConfigReference added in v0.27.0 

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

SetProviderConfigReference of this ReferenceInputBlob.

func (*ReferenceInputBlob) SetProviderReference added in v0.27.0 

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

SetProviderReference of this ReferenceInputBlob. Deprecated: Use SetProviderConfigReference.

func (*ReferenceInputBlob) SetPublishConnectionDetailsTo added in v0.27.0 

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

SetPublishConnectionDetailsTo of this ReferenceInputBlob.

func (*ReferenceInputBlob) SetWriteConnectionSecretToReference added in v0.27.0 

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

SetWriteConnectionSecretToReference of this ReferenceInputBlob.

type ReferenceInputBlobList added in v0.27.0 

type ReferenceInputBlobList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []ReferenceInputBlob `json:"items"`
}

ReferenceInputBlobList contains a list of ReferenceInputBlobs

func (*ReferenceInputBlobList) DeepCopy added in v0.27.0 

func (in *ReferenceInputBlobList) DeepCopy() *ReferenceInputBlobList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReferenceInputBlobList.

func (*ReferenceInputBlobList) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ReferenceInputBlobList) DeepCopyObject added in v0.27.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*ReferenceInputBlobList) GetItems added in v0.27.0 

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

GetItems of this ReferenceInputBlobList.

type ReferenceInputBlobObservation added in v0.27.0 

type ReferenceInputBlobObservation struct {

	// The authentication mode for the Stream Analytics Reference Input. Possible values are Msi and ConnectionString. Defaults to ConnectionString.
	AuthenticationMode *string `json:"authenticationMode,omitempty" tf:"authentication_mode,omitempty"`

	// The date format. Wherever {date} appears in path_pattern, the value of this property is used as the date format instead.
	DateFormat *string `json:"dateFormat,omitempty" tf:"date_format,omitempty"`

	// The ID of the Stream Analytics Reference Input Blob.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The name of the Reference Input Blob. Changing this forces a new resource to be created.
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.
	PathPattern *string `json:"pathPattern,omitempty" tf:"path_pattern,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// A serialization block as defined below.
	Serialization []ReferenceInputBlobSerializationObservation `json:"serialization,omitempty" tf:"serialization,omitempty"`

	// The name of the Storage Account that has the blob container with reference data.
	StorageAccountName *string `json:"storageAccountName,omitempty" tf:"storage_account_name,omitempty"`

	// The name of the Container within the Storage Account.
	StorageContainerName *string `json:"storageContainerName,omitempty" tf:"storage_container_name,omitempty"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`

	// The time format. Wherever {time} appears in path_pattern, the value of this property is used as the time format instead.
	TimeFormat *string `json:"timeFormat,omitempty" tf:"time_format,omitempty"`
}

func (*ReferenceInputBlobObservation) DeepCopy added in v0.27.0 

func (in *ReferenceInputBlobObservation) DeepCopy() *ReferenceInputBlobObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReferenceInputBlobObservation.

func (*ReferenceInputBlobObservation) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReferenceInputBlobParameters added in v0.27.0 

type ReferenceInputBlobParameters struct {

	// The authentication mode for the Stream Analytics Reference Input. Possible values are Msi and ConnectionString. Defaults to ConnectionString.
	// +kubebuilder:validation:Optional
	AuthenticationMode *string `json:"authenticationMode,omitempty" tf:"authentication_mode,omitempty"`

	// The date format. Wherever {date} appears in path_pattern, the value of this property is used as the date format instead.
	// +kubebuilder:validation:Optional
	DateFormat *string `json:"dateFormat,omitempty" tf:"date_format,omitempty"`

	// The name of the Reference Input Blob. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Optional
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.
	// +kubebuilder:validation:Optional
	PathPattern *string `json:"pathPattern,omitempty" tf:"path_pattern,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/azure/v1beta1.ResourceGroup
	// +kubebuilder:validation:Optional
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// Reference to a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameRef *v1.Reference `json:"resourceGroupNameRef,omitempty" tf:"-"`

	// Selector for a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameSelector *v1.Selector `json:"resourceGroupNameSelector,omitempty" tf:"-"`

	// A serialization block as defined below.
	// +kubebuilder:validation:Optional
	Serialization []ReferenceInputBlobSerializationParameters `json:"serialization,omitempty" tf:"serialization,omitempty"`

	// The Access Key which should be used to connect to this Storage Account. Required if authentication_mode is ConnectionString.
	// +kubebuilder:validation:Optional
	StorageAccountKeySecretRef *v1.SecretKeySelector `json:"storageAccountKeySecretRef,omitempty" tf:"-"`

	// The name of the Storage Account that has the blob container with reference data.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/storage/v1beta1.Account
	// +kubebuilder:validation:Optional
	StorageAccountName *string `json:"storageAccountName,omitempty" tf:"storage_account_name,omitempty"`

	// Reference to a Account in storage to populate storageAccountName.
	// +kubebuilder:validation:Optional
	StorageAccountNameRef *v1.Reference `json:"storageAccountNameRef,omitempty" tf:"-"`

	// Selector for a Account in storage to populate storageAccountName.
	// +kubebuilder:validation:Optional
	StorageAccountNameSelector *v1.Selector `json:"storageAccountNameSelector,omitempty" tf:"-"`

	// The name of the Container within the Storage Account.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/storage/v1beta1.Container
	// +kubebuilder:validation:Optional
	StorageContainerName *string `json:"storageContainerName,omitempty" tf:"storage_container_name,omitempty"`

	// Reference to a Container in storage to populate storageContainerName.
	// +kubebuilder:validation:Optional
	StorageContainerNameRef *v1.Reference `json:"storageContainerNameRef,omitempty" tf:"-"`

	// Selector for a Container in storage to populate storageContainerName.
	// +kubebuilder:validation:Optional
	StorageContainerNameSelector *v1.Selector `json:"storageContainerNameSelector,omitempty" tf:"-"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=Job
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`

	// Reference to a Job to populate streamAnalyticsJobName.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobNameRef *v1.Reference `json:"streamAnalyticsJobNameRef,omitempty" tf:"-"`

	// Selector for a Job to populate streamAnalyticsJobName.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobNameSelector *v1.Selector `json:"streamAnalyticsJobNameSelector,omitempty" tf:"-"`

	// The time format. Wherever {time} appears in path_pattern, the value of this property is used as the time format instead.
	// +kubebuilder:validation:Optional
	TimeFormat *string `json:"timeFormat,omitempty" tf:"time_format,omitempty"`
}

func (*ReferenceInputBlobParameters) DeepCopy added in v0.27.0 

func (in *ReferenceInputBlobParameters) DeepCopy() *ReferenceInputBlobParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReferenceInputBlobParameters.

func (*ReferenceInputBlobParameters) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReferenceInputBlobSerializationObservation added in v0.27.0 

type ReferenceInputBlobSerializationObservation struct {

	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
	Encoding *string `json:"encoding,omitempty" tf:"encoding,omitempty"`

	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are   (space), , (comma), 	 (tab), | (pipe) and ;.
	FieldDelimiter *string `json:"fieldDelimiter,omitempty" tf:"field_delimiter,omitempty"`

	// The serialization format used for the reference data. Possible values are Avro, Csv and Json.
	Type *string `json:"type,omitempty" tf:"type,omitempty"`
}

func (*ReferenceInputBlobSerializationObservation) DeepCopy added in v0.27.0 

func (in *ReferenceInputBlobSerializationObservation) DeepCopy() *ReferenceInputBlobSerializationObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReferenceInputBlobSerializationObservation.

func (*ReferenceInputBlobSerializationObservation) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReferenceInputBlobSerializationParameters added in v0.27.0 

type ReferenceInputBlobSerializationParameters struct {

	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
	// +kubebuilder:validation:Optional
	Encoding *string `json:"encoding,omitempty" tf:"encoding,omitempty"`

	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are   (space), , (comma), 	 (tab), | (pipe) and ;.
	// +kubebuilder:validation:Optional
	FieldDelimiter *string `json:"fieldDelimiter,omitempty" tf:"field_delimiter,omitempty"`

	// The serialization format used for the reference data. Possible values are Avro, Csv and Json.
	// +kubebuilder:validation:Required
	Type *string `json:"type" tf:"type,omitempty"`
}

func (*ReferenceInputBlobSerializationParameters) DeepCopy added in v0.27.0 

func (in *ReferenceInputBlobSerializationParameters) DeepCopy() *ReferenceInputBlobSerializationParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReferenceInputBlobSerializationParameters.

func (*ReferenceInputBlobSerializationParameters) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReferenceInputBlobSpec added in v0.27.0 

type ReferenceInputBlobSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     ReferenceInputBlobParameters `json:"forProvider"`
}

ReferenceInputBlobSpec defines the desired state of ReferenceInputBlob

func (*ReferenceInputBlobSpec) DeepCopy added in v0.27.0 

func (in *ReferenceInputBlobSpec) DeepCopy() *ReferenceInputBlobSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReferenceInputBlobSpec.

func (*ReferenceInputBlobSpec) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReferenceInputBlobStatus added in v0.27.0 

type ReferenceInputBlobStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        ReferenceInputBlobObservation `json:"atProvider,omitempty"`
}

ReferenceInputBlobStatus defines the observed state of ReferenceInputBlob.

func (*ReferenceInputBlobStatus) DeepCopy added in v0.27.0 

func (in *ReferenceInputBlobStatus) DeepCopy() *ReferenceInputBlobStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReferenceInputBlobStatus.

func (*ReferenceInputBlobStatus) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReferenceInputMSSQL added in v0.28.0 

type ReferenceInputMSSQL struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.fullSnapshotQuery)",message="fullSnapshotQuery is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.passwordSecretRef)",message="passwordSecretRef is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.refreshType)",message="refreshType is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.username)",message="username is a required parameter"
	Spec   ReferenceInputMSSQLSpec   `json:"spec"`
	Status ReferenceInputMSSQLStatus `json:"status,omitempty"`
}

ReferenceInputMSSQL is the Schema for the ReferenceInputMSSQLs API. Manages a Stream Analytics Reference Input from MS SQL. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*ReferenceInputMSSQL) DeepCopy added in v0.28.0 

func (in *ReferenceInputMSSQL) DeepCopy() *ReferenceInputMSSQL

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReferenceInputMSSQL.

func (*ReferenceInputMSSQL) DeepCopyInto added in v0.28.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ReferenceInputMSSQL) DeepCopyObject added in v0.28.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*ReferenceInputMSSQL) GetCondition added in v0.28.0 

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

GetCondition of this ReferenceInputMSSQL.

func (*ReferenceInputMSSQL) GetConnectionDetailsMapping added in v0.28.0 

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

GetConnectionDetailsMapping for this ReferenceInputMSSQL

func (*ReferenceInputMSSQL) GetDeletionPolicy added in v0.28.0 

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

GetDeletionPolicy of this ReferenceInputMSSQL.

func (*ReferenceInputMSSQL) GetID added in v0.28.0 

func (tr *ReferenceInputMSSQL) GetID() string

GetID returns ID of underlying Terraform resource of this ReferenceInputMSSQL

func (*ReferenceInputMSSQL) GetManagementPolicy added in v0.31.0 

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

GetManagementPolicy of this ReferenceInputMSSQL.

func (*ReferenceInputMSSQL) GetObservation added in v0.28.0 

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

GetObservation of this ReferenceInputMSSQL

func (*ReferenceInputMSSQL) GetParameters added in v0.28.0 

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

GetParameters of this ReferenceInputMSSQL

func (*ReferenceInputMSSQL) GetProviderConfigReference added in v0.28.0 

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

GetProviderConfigReference of this ReferenceInputMSSQL.

func (*ReferenceInputMSSQL) GetProviderReference added in v0.28.0 

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

GetProviderReference of this ReferenceInputMSSQL. Deprecated: Use GetProviderConfigReference.

func (*ReferenceInputMSSQL) GetPublishConnectionDetailsTo added in v0.28.0 

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

GetPublishConnectionDetailsTo of this ReferenceInputMSSQL.

func (*ReferenceInputMSSQL) GetTerraformResourceType added in v0.28.0 

func (mg *ReferenceInputMSSQL) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this ReferenceInputMSSQL

func (*ReferenceInputMSSQL) GetTerraformSchemaVersion added in v0.28.0 

func (tr *ReferenceInputMSSQL) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*ReferenceInputMSSQL) GetWriteConnectionSecretToReference added in v0.28.0 

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

GetWriteConnectionSecretToReference of this ReferenceInputMSSQL.

func (*ReferenceInputMSSQL) LateInitialize added in v0.28.0 

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

LateInitialize this ReferenceInputMSSQL using its observed tfState. returns True if there are any spec changes for the resource.

func (*ReferenceInputMSSQL) ResolveReferences added in v0.28.0 

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

ResolveReferences of this ReferenceInputMSSQL.

func (*ReferenceInputMSSQL) SetConditions added in v0.28.0 

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

SetConditions of this ReferenceInputMSSQL.

func (*ReferenceInputMSSQL) SetDeletionPolicy added in v0.28.0 

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

SetDeletionPolicy of this ReferenceInputMSSQL.

func (*ReferenceInputMSSQL) SetManagementPolicy added in v0.31.0 

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

SetManagementPolicy of this ReferenceInputMSSQL.

func (*ReferenceInputMSSQL) SetObservation added in v0.28.0 

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

SetObservation for this ReferenceInputMSSQL

func (*ReferenceInputMSSQL) SetParameters added in v0.28.0 

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

SetParameters for this ReferenceInputMSSQL

func (*ReferenceInputMSSQL) SetProviderConfigReference added in v0.28.0 

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

SetProviderConfigReference of this ReferenceInputMSSQL.

func (*ReferenceInputMSSQL) SetProviderReference added in v0.28.0 

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

SetProviderReference of this ReferenceInputMSSQL. Deprecated: Use SetProviderConfigReference.

func (*ReferenceInputMSSQL) SetPublishConnectionDetailsTo added in v0.28.0 

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

SetPublishConnectionDetailsTo of this ReferenceInputMSSQL.

func (*ReferenceInputMSSQL) SetWriteConnectionSecretToReference added in v0.28.0 

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

SetWriteConnectionSecretToReference of this ReferenceInputMSSQL.

type ReferenceInputMSSQLList added in v0.28.0 

type ReferenceInputMSSQLList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []ReferenceInputMSSQL `json:"items"`
}

ReferenceInputMSSQLList contains a list of ReferenceInputMSSQLs

func (*ReferenceInputMSSQLList) DeepCopy added in v0.28.0 

func (in *ReferenceInputMSSQLList) DeepCopy() *ReferenceInputMSSQLList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReferenceInputMSSQLList.

func (*ReferenceInputMSSQLList) DeepCopyInto added in v0.28.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ReferenceInputMSSQLList) DeepCopyObject added in v0.28.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*ReferenceInputMSSQLList) GetItems added in v0.28.0 

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

GetItems of this ReferenceInputMSSQLList.

type ReferenceInputMSSQLObservation added in v0.28.0 

type ReferenceInputMSSQLObservation struct {

	// The MS SQL database name where the reference data exists.
	Database *string `json:"database,omitempty" tf:"database,omitempty"`

	// The query used to retrieve incremental changes in the reference data from the MS SQL database. Cannot be set when refresh_type is Static.
	DeltaSnapshotQuery *string `json:"deltaSnapshotQuery,omitempty" tf:"delta_snapshot_query,omitempty"`

	// The query used to retrieve the reference data from the MS SQL database.
	FullSnapshotQuery *string `json:"fullSnapshotQuery,omitempty" tf:"full_snapshot_query,omitempty"`

	// The ID of the Stream Analytics.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The frequency in hh:mm:ss with which the reference data should be retrieved from the MS SQL database e.g. 00:20:00 for every 20 minutes. Must be set when refresh_type is RefreshPeriodicallyWithFull or RefreshPeriodicallyWithDelta.
	RefreshIntervalDuration *string `json:"refreshIntervalDuration,omitempty" tf:"refresh_interval_duration,omitempty"`

	// Defines whether and how the reference data should be refreshed. Accepted values are Static, RefreshPeriodicallyWithFull and RefreshPeriodicallyWithDelta.
	RefreshType *string `json:"refreshType,omitempty" tf:"refresh_type,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// The fully qualified domain name of the MS SQL server.
	Server *string `json:"server,omitempty" tf:"server,omitempty"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`

	// The name of the table in the Azure SQL database.
	Table *string `json:"table,omitempty" tf:"table,omitempty"`

	// The username to connect to the MS SQL database.
	Username *string `json:"username,omitempty" tf:"username,omitempty"`
}

func (*ReferenceInputMSSQLObservation) DeepCopy added in v0.28.0 

func (in *ReferenceInputMSSQLObservation) DeepCopy() *ReferenceInputMSSQLObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReferenceInputMSSQLObservation.

func (*ReferenceInputMSSQLObservation) DeepCopyInto added in v0.28.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReferenceInputMSSQLParameters added in v0.28.0 

type ReferenceInputMSSQLParameters struct {

	// The MS SQL database name where the reference data exists.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/sql/v1beta1.MSSQLDatabase
	// +kubebuilder:validation:Optional
	Database *string `json:"database,omitempty" tf:"database,omitempty"`

	// Reference to a MSSQLDatabase in sql to populate database.
	// +kubebuilder:validation:Optional
	DatabaseRef *v1.Reference `json:"databaseRef,omitempty" tf:"-"`

	// Selector for a MSSQLDatabase in sql to populate database.
	// +kubebuilder:validation:Optional
	DatabaseSelector *v1.Selector `json:"databaseSelector,omitempty" tf:"-"`

	// The query used to retrieve incremental changes in the reference data from the MS SQL database. Cannot be set when refresh_type is Static.
	// +kubebuilder:validation:Optional
	DeltaSnapshotQuery *string `json:"deltaSnapshotQuery,omitempty" tf:"delta_snapshot_query,omitempty"`

	// The query used to retrieve the reference data from the MS SQL database.
	// +kubebuilder:validation:Optional
	FullSnapshotQuery *string `json:"fullSnapshotQuery,omitempty" tf:"full_snapshot_query,omitempty"`

	// The password to connect to the MS SQL database.
	// +kubebuilder:validation:Optional
	PasswordSecretRef v1.SecretKeySelector `json:"passwordSecretRef" tf:"-"`

	// The frequency in hh:mm:ss with which the reference data should be retrieved from the MS SQL database e.g. 00:20:00 for every 20 minutes. Must be set when refresh_type is RefreshPeriodicallyWithFull or RefreshPeriodicallyWithDelta.
	// +kubebuilder:validation:Optional
	RefreshIntervalDuration *string `json:"refreshIntervalDuration,omitempty" tf:"refresh_interval_duration,omitempty"`

	// Defines whether and how the reference data should be refreshed. Accepted values are Static, RefreshPeriodicallyWithFull and RefreshPeriodicallyWithDelta.
	// +kubebuilder:validation:Optional
	RefreshType *string `json:"refreshType,omitempty" tf:"refresh_type,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/azure/v1beta1.ResourceGroup
	// +kubebuilder:validation:Optional
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// Reference to a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameRef *v1.Reference `json:"resourceGroupNameRef,omitempty" tf:"-"`

	// Selector for a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameSelector *v1.Selector `json:"resourceGroupNameSelector,omitempty" tf:"-"`

	// The fully qualified domain name of the MS SQL server.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/sql/v1beta1.MSSQLServer
	// +crossplane:generate:reference:extractor=github.com/upbound/upjet/pkg/resource.ExtractParamPath("fully_qualified_domain_name",true)
	// +kubebuilder:validation:Optional
	Server *string `json:"server,omitempty" tf:"server,omitempty"`

	// Reference to a MSSQLServer in sql to populate server.
	// +kubebuilder:validation:Optional
	ServerRef *v1.Reference `json:"serverRef,omitempty" tf:"-"`

	// Selector for a MSSQLServer in sql to populate server.
	// +kubebuilder:validation:Optional
	ServerSelector *v1.Selector `json:"serverSelector,omitempty" tf:"-"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Required
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName" tf:"stream_analytics_job_name,omitempty"`

	// The name of the table in the Azure SQL database.
	// +kubebuilder:validation:Optional
	Table *string `json:"table,omitempty" tf:"table,omitempty"`

	// The username to connect to the MS SQL database.
	// +kubebuilder:validation:Optional
	Username *string `json:"username,omitempty" tf:"username,omitempty"`
}

func (*ReferenceInputMSSQLParameters) DeepCopy added in v0.28.0 

func (in *ReferenceInputMSSQLParameters) DeepCopy() *ReferenceInputMSSQLParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReferenceInputMSSQLParameters.

func (*ReferenceInputMSSQLParameters) DeepCopyInto added in v0.28.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReferenceInputMSSQLSpec added in v0.28.0 

type ReferenceInputMSSQLSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     ReferenceInputMSSQLParameters `json:"forProvider"`
}

ReferenceInputMSSQLSpec defines the desired state of ReferenceInputMSSQL

func (*ReferenceInputMSSQLSpec) DeepCopy added in v0.28.0 

func (in *ReferenceInputMSSQLSpec) DeepCopy() *ReferenceInputMSSQLSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReferenceInputMSSQLSpec.

func (*ReferenceInputMSSQLSpec) DeepCopyInto added in v0.28.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReferenceInputMSSQLStatus added in v0.28.0 

type ReferenceInputMSSQLStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        ReferenceInputMSSQLObservation `json:"atProvider,omitempty"`
}

ReferenceInputMSSQLStatus defines the observed state of ReferenceInputMSSQL.

func (*ReferenceInputMSSQLStatus) DeepCopy added in v0.28.0 

func (in *ReferenceInputMSSQLStatus) DeepCopy() *ReferenceInputMSSQLStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReferenceInputMSSQLStatus.

func (*ReferenceInputMSSQLStatus) DeepCopyInto added in v0.28.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SerializationObservation 

type SerializationObservation struct {

	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
	Encoding *string `json:"encoding,omitempty" tf:"encoding,omitempty"`

	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are   (space), , (comma), 	 (tab), | (pipe) and ;.
	FieldDelimiter *string `json:"fieldDelimiter,omitempty" tf:"field_delimiter,omitempty"`

	// Specifies the format of the JSON the output will be written in. Possible values are Array and LineSeparated.
	Format *string `json:"format,omitempty" tf:"format,omitempty"`

	// The serialization format used for outgoing data streams. Possible values are Avro, Csv, Json and Parquet.
	Type *string `json:"type,omitempty" tf:"type,omitempty"`
}

func (*SerializationObservation) DeepCopy 

func (in *SerializationObservation) DeepCopy() *SerializationObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SerializationObservation.

func (*SerializationObservation) DeepCopyInto 

func (in *SerializationObservation) DeepCopyInto(out *SerializationObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SerializationParameters 

type SerializationParameters struct {

	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
	// +kubebuilder:validation:Optional
	Encoding *string `json:"encoding,omitempty" tf:"encoding,omitempty"`

	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are   (space), , (comma), 	 (tab), | (pipe) and ;.
	// +kubebuilder:validation:Optional
	FieldDelimiter *string `json:"fieldDelimiter,omitempty" tf:"field_delimiter,omitempty"`

	// Specifies the format of the JSON the output will be written in. Possible values are Array and LineSeparated.
	// +kubebuilder:validation:Optional
	Format *string `json:"format,omitempty" tf:"format,omitempty"`

	// The serialization format used for outgoing data streams. Possible values are Avro, Csv, Json and Parquet.
	// +kubebuilder:validation:Required
	Type *string `json:"type" tf:"type,omitempty"`
}

func (*SerializationParameters) DeepCopy 

func (in *SerializationParameters) DeepCopy() *SerializationParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SerializationParameters.

func (*SerializationParameters) DeepCopyInto 

func (in *SerializationParameters) DeepCopyInto(out *SerializationParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamInputBlob added in v0.27.0 

type StreamInputBlob struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.dateFormat)",message="dateFormat is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.name)",message="name is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.pathPattern)",message="pathPattern is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.serialization)",message="serialization is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.storageAccountKeySecretRef)",message="storageAccountKeySecretRef is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.timeFormat)",message="timeFormat is a required parameter"
	Spec   StreamInputBlobSpec   `json:"spec"`
	Status StreamInputBlobStatus `json:"status,omitempty"`
}

StreamInputBlob is the Schema for the StreamInputBlobs API. Manages a Stream Analytics Stream Input Blob. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*StreamInputBlob) DeepCopy added in v0.27.0 

func (in *StreamInputBlob) DeepCopy() *StreamInputBlob

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputBlob.

func (*StreamInputBlob) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*StreamInputBlob) DeepCopyObject added in v0.27.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*StreamInputBlob) GetCondition added in v0.27.0 

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

GetCondition of this StreamInputBlob.

func (*StreamInputBlob) GetConnectionDetailsMapping added in v0.27.0 

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

GetConnectionDetailsMapping for this StreamInputBlob

func (*StreamInputBlob) GetDeletionPolicy added in v0.27.0 

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

GetDeletionPolicy of this StreamInputBlob.

func (*StreamInputBlob) GetID added in v0.27.0 

func (tr *StreamInputBlob) GetID() string

GetID returns ID of underlying Terraform resource of this StreamInputBlob

func (*StreamInputBlob) GetManagementPolicy added in v0.31.0 

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

GetManagementPolicy of this StreamInputBlob.

func (*StreamInputBlob) GetObservation added in v0.27.0 

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

GetObservation of this StreamInputBlob

func (*StreamInputBlob) GetParameters added in v0.27.0 

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

GetParameters of this StreamInputBlob

func (*StreamInputBlob) GetProviderConfigReference added in v0.27.0 

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

GetProviderConfigReference of this StreamInputBlob.

func (*StreamInputBlob) GetProviderReference added in v0.27.0 

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

GetProviderReference of this StreamInputBlob. Deprecated: Use GetProviderConfigReference.

func (*StreamInputBlob) GetPublishConnectionDetailsTo added in v0.27.0 

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

GetPublishConnectionDetailsTo of this StreamInputBlob.

func (*StreamInputBlob) GetTerraformResourceType added in v0.27.0 

func (mg *StreamInputBlob) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this StreamInputBlob

func (*StreamInputBlob) GetTerraformSchemaVersion added in v0.27.0 

func (tr *StreamInputBlob) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*StreamInputBlob) GetWriteConnectionSecretToReference added in v0.27.0 

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

GetWriteConnectionSecretToReference of this StreamInputBlob.

func (*StreamInputBlob) LateInitialize added in v0.27.0 

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

LateInitialize this StreamInputBlob using its observed tfState. returns True if there are any spec changes for the resource.

func (*StreamInputBlob) ResolveReferences added in v0.27.0 

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

ResolveReferences of this StreamInputBlob.

func (*StreamInputBlob) SetConditions added in v0.27.0 

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

SetConditions of this StreamInputBlob.

func (*StreamInputBlob) SetDeletionPolicy added in v0.27.0 

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

SetDeletionPolicy of this StreamInputBlob.

func (*StreamInputBlob) SetManagementPolicy added in v0.31.0 

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

SetManagementPolicy of this StreamInputBlob.

func (*StreamInputBlob) SetObservation added in v0.27.0 

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

SetObservation for this StreamInputBlob

func (*StreamInputBlob) SetParameters added in v0.27.0 

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

SetParameters for this StreamInputBlob

func (*StreamInputBlob) SetProviderConfigReference added in v0.27.0 

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

SetProviderConfigReference of this StreamInputBlob.

func (*StreamInputBlob) SetProviderReference added in v0.27.0 

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

SetProviderReference of this StreamInputBlob. Deprecated: Use SetProviderConfigReference.

func (*StreamInputBlob) SetPublishConnectionDetailsTo added in v0.27.0 

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

SetPublishConnectionDetailsTo of this StreamInputBlob.

func (*StreamInputBlob) SetWriteConnectionSecretToReference added in v0.27.0 

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

SetWriteConnectionSecretToReference of this StreamInputBlob.

type StreamInputBlobList added in v0.27.0 

type StreamInputBlobList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []StreamInputBlob `json:"items"`
}

StreamInputBlobList contains a list of StreamInputBlobs

func (*StreamInputBlobList) DeepCopy added in v0.27.0 

func (in *StreamInputBlobList) DeepCopy() *StreamInputBlobList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputBlobList.

func (*StreamInputBlobList) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*StreamInputBlobList) DeepCopyObject added in v0.27.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*StreamInputBlobList) GetItems added in v0.27.0 

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

GetItems of this StreamInputBlobList.

type StreamInputBlobObservation added in v0.27.0 

type StreamInputBlobObservation struct {

	// The date format. Wherever {date} appears in path_pattern, the value of this property is used as the date format instead.
	DateFormat *string `json:"dateFormat,omitempty" tf:"date_format,omitempty"`

	// The ID of the Stream Analytics Stream Input Blob.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The name of the Stream Input Blob. Changing this forces a new resource to be created.
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.
	PathPattern *string `json:"pathPattern,omitempty" tf:"path_pattern,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// A serialization block as defined below.
	Serialization []StreamInputBlobSerializationObservation `json:"serialization,omitempty" tf:"serialization,omitempty"`

	// The name of the Storage Account.
	StorageAccountName *string `json:"storageAccountName,omitempty" tf:"storage_account_name,omitempty"`

	// The name of the Container within the Storage Account.
	StorageContainerName *string `json:"storageContainerName,omitempty" tf:"storage_container_name,omitempty"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`

	// The time format. Wherever {time} appears in path_pattern, the value of this property is used as the time format instead.
	TimeFormat *string `json:"timeFormat,omitempty" tf:"time_format,omitempty"`
}

func (*StreamInputBlobObservation) DeepCopy added in v0.27.0 

func (in *StreamInputBlobObservation) DeepCopy() *StreamInputBlobObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputBlobObservation.

func (*StreamInputBlobObservation) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamInputBlobParameters added in v0.27.0 

type StreamInputBlobParameters struct {

	// The date format. Wherever {date} appears in path_pattern, the value of this property is used as the date format instead.
	// +kubebuilder:validation:Optional
	DateFormat *string `json:"dateFormat,omitempty" tf:"date_format,omitempty"`

	// The name of the Stream Input Blob. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Optional
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.
	// +kubebuilder:validation:Optional
	PathPattern *string `json:"pathPattern,omitempty" tf:"path_pattern,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/azure/v1beta1.ResourceGroup
	// +kubebuilder:validation:Optional
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// Reference to a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameRef *v1.Reference `json:"resourceGroupNameRef,omitempty" tf:"-"`

	// Selector for a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameSelector *v1.Selector `json:"resourceGroupNameSelector,omitempty" tf:"-"`

	// A serialization block as defined below.
	// +kubebuilder:validation:Optional
	Serialization []StreamInputBlobSerializationParameters `json:"serialization,omitempty" tf:"serialization,omitempty"`

	// The Access Key which should be used to connect to this Storage Account.
	// +kubebuilder:validation:Optional
	StorageAccountKeySecretRef v1.SecretKeySelector `json:"storageAccountKeySecretRef" tf:"-"`

	// The name of the Storage Account.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/storage/v1beta1.Account
	// +kubebuilder:validation:Optional
	StorageAccountName *string `json:"storageAccountName,omitempty" tf:"storage_account_name,omitempty"`

	// Reference to a Account in storage to populate storageAccountName.
	// +kubebuilder:validation:Optional
	StorageAccountNameRef *v1.Reference `json:"storageAccountNameRef,omitempty" tf:"-"`

	// Selector for a Account in storage to populate storageAccountName.
	// +kubebuilder:validation:Optional
	StorageAccountNameSelector *v1.Selector `json:"storageAccountNameSelector,omitempty" tf:"-"`

	// The name of the Container within the Storage Account.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/storage/v1beta1.Container
	// +kubebuilder:validation:Optional
	StorageContainerName *string `json:"storageContainerName,omitempty" tf:"storage_container_name,omitempty"`

	// Reference to a Container in storage to populate storageContainerName.
	// +kubebuilder:validation:Optional
	StorageContainerNameRef *v1.Reference `json:"storageContainerNameRef,omitempty" tf:"-"`

	// Selector for a Container in storage to populate storageContainerName.
	// +kubebuilder:validation:Optional
	StorageContainerNameSelector *v1.Selector `json:"storageContainerNameSelector,omitempty" tf:"-"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=Job
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`

	// Reference to a Job to populate streamAnalyticsJobName.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobNameRef *v1.Reference `json:"streamAnalyticsJobNameRef,omitempty" tf:"-"`

	// Selector for a Job to populate streamAnalyticsJobName.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobNameSelector *v1.Selector `json:"streamAnalyticsJobNameSelector,omitempty" tf:"-"`

	// The time format. Wherever {time} appears in path_pattern, the value of this property is used as the time format instead.
	// +kubebuilder:validation:Optional
	TimeFormat *string `json:"timeFormat,omitempty" tf:"time_format,omitempty"`
}

func (*StreamInputBlobParameters) DeepCopy added in v0.27.0 

func (in *StreamInputBlobParameters) DeepCopy() *StreamInputBlobParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputBlobParameters.

func (*StreamInputBlobParameters) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamInputBlobSerializationObservation added in v0.27.0 

type StreamInputBlobSerializationObservation struct {

	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
	Encoding *string `json:"encoding,omitempty" tf:"encoding,omitempty"`

	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are   (space), , (comma), 	 (tab), | (pipe) and ;.
	FieldDelimiter *string `json:"fieldDelimiter,omitempty" tf:"field_delimiter,omitempty"`

	// The serialization format used for incoming data streams. Possible values are Avro, Csv and Json.
	Type *string `json:"type,omitempty" tf:"type,omitempty"`
}

func (*StreamInputBlobSerializationObservation) DeepCopy added in v0.27.0 

func (in *StreamInputBlobSerializationObservation) DeepCopy() *StreamInputBlobSerializationObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputBlobSerializationObservation.

func (*StreamInputBlobSerializationObservation) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamInputBlobSerializationParameters added in v0.27.0 

type StreamInputBlobSerializationParameters struct {

	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
	// +kubebuilder:validation:Optional
	Encoding *string `json:"encoding,omitempty" tf:"encoding,omitempty"`

	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are   (space), , (comma), 	 (tab), | (pipe) and ;.
	// +kubebuilder:validation:Optional
	FieldDelimiter *string `json:"fieldDelimiter,omitempty" tf:"field_delimiter,omitempty"`

	// The serialization format used for incoming data streams. Possible values are Avro, Csv and Json.
	// +kubebuilder:validation:Required
	Type *string `json:"type" tf:"type,omitempty"`
}

func (*StreamInputBlobSerializationParameters) DeepCopy added in v0.27.0 

func (in *StreamInputBlobSerializationParameters) DeepCopy() *StreamInputBlobSerializationParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputBlobSerializationParameters.

func (*StreamInputBlobSerializationParameters) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamInputBlobSpec added in v0.27.0 

type StreamInputBlobSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     StreamInputBlobParameters `json:"forProvider"`
}

StreamInputBlobSpec defines the desired state of StreamInputBlob

func (*StreamInputBlobSpec) DeepCopy added in v0.27.0 

func (in *StreamInputBlobSpec) DeepCopy() *StreamInputBlobSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputBlobSpec.

func (*StreamInputBlobSpec) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamInputBlobStatus added in v0.27.0 

type StreamInputBlobStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        StreamInputBlobObservation `json:"atProvider,omitempty"`
}

StreamInputBlobStatus defines the observed state of StreamInputBlob.

func (*StreamInputBlobStatus) DeepCopy added in v0.27.0 

func (in *StreamInputBlobStatus) DeepCopy() *StreamInputBlobStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputBlobStatus.

func (*StreamInputBlobStatus) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamInputEventHub added in v0.27.0 

type StreamInputEventHub struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.name)",message="name is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.serialization)",message="serialization is a required parameter"
	Spec   StreamInputEventHubSpec   `json:"spec"`
	Status StreamInputEventHubStatus `json:"status,omitempty"`
}

StreamInputEventHub is the Schema for the StreamInputEventHubs API. Manages a Stream Analytics Stream Input EventHub. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*StreamInputEventHub) DeepCopy added in v0.27.0 

func (in *StreamInputEventHub) DeepCopy() *StreamInputEventHub

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputEventHub.

func (*StreamInputEventHub) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*StreamInputEventHub) DeepCopyObject added in v0.27.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*StreamInputEventHub) GetCondition added in v0.27.0 

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

GetCondition of this StreamInputEventHub.

func (*StreamInputEventHub) GetConnectionDetailsMapping added in v0.27.0 

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

GetConnectionDetailsMapping for this StreamInputEventHub

func (*StreamInputEventHub) GetDeletionPolicy added in v0.27.0 

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

GetDeletionPolicy of this StreamInputEventHub.

func (*StreamInputEventHub) GetID added in v0.27.0 

func (tr *StreamInputEventHub) GetID() string

GetID returns ID of underlying Terraform resource of this StreamInputEventHub

func (*StreamInputEventHub) GetManagementPolicy added in v0.31.0 

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

GetManagementPolicy of this StreamInputEventHub.

func (*StreamInputEventHub) GetObservation added in v0.27.0 

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

GetObservation of this StreamInputEventHub

func (*StreamInputEventHub) GetParameters added in v0.27.0 

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

GetParameters of this StreamInputEventHub

func (*StreamInputEventHub) GetProviderConfigReference added in v0.27.0 

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

GetProviderConfigReference of this StreamInputEventHub.

func (*StreamInputEventHub) GetProviderReference added in v0.27.0 

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

GetProviderReference of this StreamInputEventHub. Deprecated: Use GetProviderConfigReference.

func (*StreamInputEventHub) GetPublishConnectionDetailsTo added in v0.27.0 

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

GetPublishConnectionDetailsTo of this StreamInputEventHub.

func (*StreamInputEventHub) GetTerraformResourceType added in v0.27.0 

func (mg *StreamInputEventHub) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this StreamInputEventHub

func (*StreamInputEventHub) GetTerraformSchemaVersion added in v0.27.0 

func (tr *StreamInputEventHub) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*StreamInputEventHub) GetWriteConnectionSecretToReference added in v0.27.0 

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

GetWriteConnectionSecretToReference of this StreamInputEventHub.

func (*StreamInputEventHub) LateInitialize added in v0.27.0 

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

LateInitialize this StreamInputEventHub using its observed tfState. returns True if there are any spec changes for the resource.

func (*StreamInputEventHub) ResolveReferences added in v0.27.0 

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

ResolveReferences of this StreamInputEventHub.

func (*StreamInputEventHub) SetConditions added in v0.27.0 

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

SetConditions of this StreamInputEventHub.

func (*StreamInputEventHub) SetDeletionPolicy added in v0.27.0 

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

SetDeletionPolicy of this StreamInputEventHub.

func (*StreamInputEventHub) SetManagementPolicy added in v0.31.0 

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

SetManagementPolicy of this StreamInputEventHub.

func (*StreamInputEventHub) SetObservation added in v0.27.0 

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

SetObservation for this StreamInputEventHub

func (*StreamInputEventHub) SetParameters added in v0.27.0 

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

SetParameters for this StreamInputEventHub

func (*StreamInputEventHub) SetProviderConfigReference added in v0.27.0 

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

SetProviderConfigReference of this StreamInputEventHub.

func (*StreamInputEventHub) SetProviderReference added in v0.27.0 

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

SetProviderReference of this StreamInputEventHub. Deprecated: Use SetProviderConfigReference.

func (*StreamInputEventHub) SetPublishConnectionDetailsTo added in v0.27.0 

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

SetPublishConnectionDetailsTo of this StreamInputEventHub.

func (*StreamInputEventHub) SetWriteConnectionSecretToReference added in v0.27.0 

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

SetWriteConnectionSecretToReference of this StreamInputEventHub.

type StreamInputEventHubList added in v0.27.0 

type StreamInputEventHubList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []StreamInputEventHub `json:"items"`
}

StreamInputEventHubList contains a list of StreamInputEventHubs

func (*StreamInputEventHubList) DeepCopy added in v0.27.0 

func (in *StreamInputEventHubList) DeepCopy() *StreamInputEventHubList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputEventHubList.

func (*StreamInputEventHubList) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*StreamInputEventHubList) DeepCopyObject added in v0.27.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*StreamInputEventHubList) GetItems added in v0.27.0 

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

GetItems of this StreamInputEventHubList.

type StreamInputEventHubObservation added in v0.27.0 

type StreamInputEventHubObservation struct {

	// The authentication mode for the Stream Output. Possible values are Msi and ConnectionString. Defaults to ConnectionString.
	AuthenticationMode *string `json:"authenticationMode,omitempty" tf:"authentication_mode,omitempty"`

	// The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub. If not set the input will use the Event Hub's default consumer group.
	EventHubConsumerGroupName *string `json:"eventhubConsumerGroupName,omitempty" tf:"eventhub_consumer_group_name,omitempty"`

	// The name of the Event Hub.
	EventHubName *string `json:"eventhubName,omitempty" tf:"eventhub_name,omitempty"`

	// The ID of the Stream Analytics Stream Input EventHub.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The name of the Stream Input EventHub. Changing this forces a new resource to be created.
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// The property the input Event Hub has been partitioned by.
	PartitionKey *string `json:"partitionKey,omitempty" tf:"partition_key,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// A serialization block as defined below.
	Serialization []StreamInputEventHubSerializationObservation `json:"serialization,omitempty" tf:"serialization,omitempty"`

	// The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
	ServiceBusNamespace *string `json:"servicebusNamespace,omitempty" tf:"servicebus_namespace,omitempty"`

	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty" tf:"shared_access_policy_name,omitempty"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`
}

func (*StreamInputEventHubObservation) DeepCopy added in v0.27.0 

func (in *StreamInputEventHubObservation) DeepCopy() *StreamInputEventHubObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputEventHubObservation.

func (*StreamInputEventHubObservation) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamInputEventHubParameters added in v0.27.0 

type StreamInputEventHubParameters struct {

	// The authentication mode for the Stream Output. Possible values are Msi and ConnectionString. Defaults to ConnectionString.
	// +kubebuilder:validation:Optional
	AuthenticationMode *string `json:"authenticationMode,omitempty" tf:"authentication_mode,omitempty"`

	// The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub. If not set the input will use the Event Hub's default consumer group.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/eventhub/v1beta1.ConsumerGroup
	// +kubebuilder:validation:Optional
	EventHubConsumerGroupName *string `json:"eventhubConsumerGroupName,omitempty" tf:"eventhub_consumer_group_name,omitempty"`

	// Reference to a ConsumerGroup in eventhub to populate eventhubConsumerGroupName.
	// +kubebuilder:validation:Optional
	EventHubConsumerGroupNameRef *v1.Reference `json:"eventhubConsumerGroupNameRef,omitempty" tf:"-"`

	// Selector for a ConsumerGroup in eventhub to populate eventhubConsumerGroupName.
	// +kubebuilder:validation:Optional
	EventHubConsumerGroupNameSelector *v1.Selector `json:"eventhubConsumerGroupNameSelector,omitempty" tf:"-"`

	// The name of the Event Hub.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/eventhub/v1beta1.EventHub
	// +kubebuilder:validation:Optional
	EventHubName *string `json:"eventhubName,omitempty" tf:"eventhub_name,omitempty"`

	// Reference to a EventHub in eventhub to populate eventhubName.
	// +kubebuilder:validation:Optional
	EventHubNameRef *v1.Reference `json:"eventhubNameRef,omitempty" tf:"-"`

	// Selector for a EventHub in eventhub to populate eventhubName.
	// +kubebuilder:validation:Optional
	EventHubNameSelector *v1.Selector `json:"eventhubNameSelector,omitempty" tf:"-"`

	// The name of the Stream Input EventHub. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Optional
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// The property the input Event Hub has been partitioned by.
	// +kubebuilder:validation:Optional
	PartitionKey *string `json:"partitionKey,omitempty" tf:"partition_key,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/azure/v1beta1.ResourceGroup
	// +kubebuilder:validation:Optional
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// Reference to a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameRef *v1.Reference `json:"resourceGroupNameRef,omitempty" tf:"-"`

	// Selector for a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameSelector *v1.Selector `json:"resourceGroupNameSelector,omitempty" tf:"-"`

	// A serialization block as defined below.
	// +kubebuilder:validation:Optional
	Serialization []StreamInputEventHubSerializationParameters `json:"serialization,omitempty" tf:"serialization,omitempty"`

	// The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/eventhub/v1beta1.EventHubNamespace
	// +kubebuilder:validation:Optional
	ServiceBusNamespace *string `json:"servicebusNamespace,omitempty" tf:"servicebus_namespace,omitempty"`

	// Reference to a EventHubNamespace in eventhub to populate servicebusNamespace.
	// +kubebuilder:validation:Optional
	ServiceBusNamespaceRef *v1.Reference `json:"servicebusNamespaceRef,omitempty" tf:"-"`

	// Selector for a EventHubNamespace in eventhub to populate servicebusNamespace.
	// +kubebuilder:validation:Optional
	ServiceBusNamespaceSelector *v1.Selector `json:"servicebusNamespaceSelector,omitempty" tf:"-"`

	// The shared access policy key for the specified shared access policy.
	// +kubebuilder:validation:Optional
	SharedAccessPolicyKeySecretRef *v1.SecretKeySelector `json:"sharedAccessPolicyKeySecretRef,omitempty" tf:"-"`

	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	// +kubebuilder:validation:Optional
	SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty" tf:"shared_access_policy_name,omitempty"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=Job
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`

	// Reference to a Job to populate streamAnalyticsJobName.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobNameRef *v1.Reference `json:"streamAnalyticsJobNameRef,omitempty" tf:"-"`

	// Selector for a Job to populate streamAnalyticsJobName.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobNameSelector *v1.Selector `json:"streamAnalyticsJobNameSelector,omitempty" tf:"-"`
}

func (*StreamInputEventHubParameters) DeepCopy added in v0.27.0 

func (in *StreamInputEventHubParameters) DeepCopy() *StreamInputEventHubParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputEventHubParameters.

func (*StreamInputEventHubParameters) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamInputEventHubSerializationObservation added in v0.27.0 

type StreamInputEventHubSerializationObservation struct {

	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
	Encoding *string `json:"encoding,omitempty" tf:"encoding,omitempty"`

	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are   (space), , (comma), 	 (tab), | (pipe) and ;.
	FieldDelimiter *string `json:"fieldDelimiter,omitempty" tf:"field_delimiter,omitempty"`

	// The serialization format used for incoming data streams. Possible values are Avro, Csv and Json.
	Type *string `json:"type,omitempty" tf:"type,omitempty"`
}

func (*StreamInputEventHubSerializationObservation) DeepCopy added in v0.27.0 

func (in *StreamInputEventHubSerializationObservation) DeepCopy() *StreamInputEventHubSerializationObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputEventHubSerializationObservation.

func (*StreamInputEventHubSerializationObservation) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamInputEventHubSerializationParameters added in v0.27.0 

type StreamInputEventHubSerializationParameters struct {

	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
	// +kubebuilder:validation:Optional
	Encoding *string `json:"encoding,omitempty" tf:"encoding,omitempty"`

	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are   (space), , (comma), 	 (tab), | (pipe) and ;.
	// +kubebuilder:validation:Optional
	FieldDelimiter *string `json:"fieldDelimiter,omitempty" tf:"field_delimiter,omitempty"`

	// The serialization format used for incoming data streams. Possible values are Avro, Csv and Json.
	// +kubebuilder:validation:Required
	Type *string `json:"type" tf:"type,omitempty"`
}

func (*StreamInputEventHubSerializationParameters) DeepCopy added in v0.27.0 

func (in *StreamInputEventHubSerializationParameters) DeepCopy() *StreamInputEventHubSerializationParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputEventHubSerializationParameters.

func (*StreamInputEventHubSerializationParameters) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamInputEventHubSpec added in v0.27.0 

type StreamInputEventHubSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     StreamInputEventHubParameters `json:"forProvider"`
}

StreamInputEventHubSpec defines the desired state of StreamInputEventHub

func (*StreamInputEventHubSpec) DeepCopy added in v0.27.0 

func (in *StreamInputEventHubSpec) DeepCopy() *StreamInputEventHubSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputEventHubSpec.

func (*StreamInputEventHubSpec) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamInputEventHubStatus added in v0.27.0 

type StreamInputEventHubStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        StreamInputEventHubObservation `json:"atProvider,omitempty"`
}

StreamInputEventHubStatus defines the observed state of StreamInputEventHub.

func (*StreamInputEventHubStatus) DeepCopy added in v0.27.0 

func (in *StreamInputEventHubStatus) DeepCopy() *StreamInputEventHubStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputEventHubStatus.

func (*StreamInputEventHubStatus) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamInputIOTHub added in v0.27.0 

type StreamInputIOTHub struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.endpoint)",message="endpoint is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.name)",message="name is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.serialization)",message="serialization is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.sharedAccessPolicyKeySecretRef)",message="sharedAccessPolicyKeySecretRef is a required parameter"
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.sharedAccessPolicyName)",message="sharedAccessPolicyName is a required parameter"
	Spec   StreamInputIOTHubSpec   `json:"spec"`
	Status StreamInputIOTHubStatus `json:"status,omitempty"`
}

StreamInputIOTHub is the Schema for the StreamInputIOTHubs API. Manages a Stream Analytics Stream Input IoTHub. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*StreamInputIOTHub) DeepCopy added in v0.27.0 

func (in *StreamInputIOTHub) DeepCopy() *StreamInputIOTHub

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputIOTHub.

func (*StreamInputIOTHub) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*StreamInputIOTHub) DeepCopyObject added in v0.27.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*StreamInputIOTHub) GetCondition added in v0.27.0 

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

GetCondition of this StreamInputIOTHub.

func (*StreamInputIOTHub) GetConnectionDetailsMapping added in v0.27.0 

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

GetConnectionDetailsMapping for this StreamInputIOTHub

func (*StreamInputIOTHub) GetDeletionPolicy added in v0.27.0 

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

GetDeletionPolicy of this StreamInputIOTHub.

func (*StreamInputIOTHub) GetID added in v0.27.0 

func (tr *StreamInputIOTHub) GetID() string

GetID returns ID of underlying Terraform resource of this StreamInputIOTHub

func (*StreamInputIOTHub) GetManagementPolicy added in v0.31.0 

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

GetManagementPolicy of this StreamInputIOTHub.

func (*StreamInputIOTHub) GetObservation added in v0.27.0 

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

GetObservation of this StreamInputIOTHub

func (*StreamInputIOTHub) GetParameters added in v0.27.0 

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

GetParameters of this StreamInputIOTHub

func (*StreamInputIOTHub) GetProviderConfigReference added in v0.27.0 

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

GetProviderConfigReference of this StreamInputIOTHub.

func (*StreamInputIOTHub) GetProviderReference added in v0.27.0 

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

GetProviderReference of this StreamInputIOTHub. Deprecated: Use GetProviderConfigReference.

func (*StreamInputIOTHub) GetPublishConnectionDetailsTo added in v0.27.0 

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

GetPublishConnectionDetailsTo of this StreamInputIOTHub.

func (*StreamInputIOTHub) GetTerraformResourceType added in v0.27.0 

func (mg *StreamInputIOTHub) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this StreamInputIOTHub

func (*StreamInputIOTHub) GetTerraformSchemaVersion added in v0.27.0 

func (tr *StreamInputIOTHub) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*StreamInputIOTHub) GetWriteConnectionSecretToReference added in v0.27.0 

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

GetWriteConnectionSecretToReference of this StreamInputIOTHub.

func (*StreamInputIOTHub) LateInitialize added in v0.27.0 

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

LateInitialize this StreamInputIOTHub using its observed tfState. returns True if there are any spec changes for the resource.

func (*StreamInputIOTHub) ResolveReferences added in v0.27.0 

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

ResolveReferences of this StreamInputIOTHub.

func (*StreamInputIOTHub) SetConditions added in v0.27.0 

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

SetConditions of this StreamInputIOTHub.

func (*StreamInputIOTHub) SetDeletionPolicy added in v0.27.0 

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

SetDeletionPolicy of this StreamInputIOTHub.

func (*StreamInputIOTHub) SetManagementPolicy added in v0.31.0 

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

SetManagementPolicy of this StreamInputIOTHub.

func (*StreamInputIOTHub) SetObservation added in v0.27.0 

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

SetObservation for this StreamInputIOTHub

func (*StreamInputIOTHub) SetParameters added in v0.27.0 

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

SetParameters for this StreamInputIOTHub

func (*StreamInputIOTHub) SetProviderConfigReference added in v0.27.0 

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

SetProviderConfigReference of this StreamInputIOTHub.

func (*StreamInputIOTHub) SetProviderReference added in v0.27.0 

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

SetProviderReference of this StreamInputIOTHub. Deprecated: Use SetProviderConfigReference.

func (*StreamInputIOTHub) SetPublishConnectionDetailsTo added in v0.27.0 

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

SetPublishConnectionDetailsTo of this StreamInputIOTHub.

func (*StreamInputIOTHub) SetWriteConnectionSecretToReference added in v0.27.0 

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

SetWriteConnectionSecretToReference of this StreamInputIOTHub.

type StreamInputIOTHubList added in v0.27.0 

type StreamInputIOTHubList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []StreamInputIOTHub `json:"items"`
}

StreamInputIOTHubList contains a list of StreamInputIOTHubs

func (*StreamInputIOTHubList) DeepCopy added in v0.27.0 

func (in *StreamInputIOTHubList) DeepCopy() *StreamInputIOTHubList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputIOTHubList.

func (*StreamInputIOTHubList) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*StreamInputIOTHubList) DeepCopyObject added in v0.27.0 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*StreamInputIOTHubList) GetItems added in v0.27.0 

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

GetItems of this StreamInputIOTHubList.

type StreamInputIOTHubObservation added in v0.27.0 

type StreamInputIOTHubObservation struct {

	// The IoT Hub endpoint to connect to (ie. messages/events, messages/operationsMonitoringEvents, etc.).
	Endpoint *string `json:"endpoint,omitempty" tf:"endpoint,omitempty"`

	// The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub.
	EventHubConsumerGroupName *string `json:"eventhubConsumerGroupName,omitempty" tf:"eventhub_consumer_group_name,omitempty"`

	// The ID of the Stream Analytics Stream Input IoTHub.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The name or the URI of the IoT Hub.
	IOTHubNamespace *string `json:"iothubNamespace,omitempty" tf:"iothub_namespace,omitempty"`

	// The name of the Stream Input IoTHub. Changing this forces a new resource to be created.
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// A serialization block as defined below.
	Serialization []StreamInputIOTHubSerializationObservation `json:"serialization,omitempty" tf:"serialization,omitempty"`

	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty" tf:"shared_access_policy_name,omitempty"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`
}

func (*StreamInputIOTHubObservation) DeepCopy added in v0.27.0 

func (in *StreamInputIOTHubObservation) DeepCopy() *StreamInputIOTHubObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputIOTHubObservation.

func (*StreamInputIOTHubObservation) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamInputIOTHubParameters added in v0.27.0 

type StreamInputIOTHubParameters struct {

	// The IoT Hub endpoint to connect to (ie. messages/events, messages/operationsMonitoringEvents, etc.).
	// +kubebuilder:validation:Optional
	Endpoint *string `json:"endpoint,omitempty" tf:"endpoint,omitempty"`

	// The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/eventhub/v1beta1.ConsumerGroup
	// +kubebuilder:validation:Optional
	EventHubConsumerGroupName *string `json:"eventhubConsumerGroupName,omitempty" tf:"eventhub_consumer_group_name,omitempty"`

	// Reference to a ConsumerGroup in eventhub to populate eventhubConsumerGroupName.
	// +kubebuilder:validation:Optional
	EventHubConsumerGroupNameRef *v1.Reference `json:"eventhubConsumerGroupNameRef,omitempty" tf:"-"`

	// Selector for a ConsumerGroup in eventhub to populate eventhubConsumerGroupName.
	// +kubebuilder:validation:Optional
	EventHubConsumerGroupNameSelector *v1.Selector `json:"eventhubConsumerGroupNameSelector,omitempty" tf:"-"`

	// The name or the URI of the IoT Hub.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/devices/v1beta1.IOTHub
	// +kubebuilder:validation:Optional
	IOTHubNamespace *string `json:"iothubNamespace,omitempty" tf:"iothub_namespace,omitempty"`

	// Reference to a IOTHub in devices to populate iothubNamespace.
	// +kubebuilder:validation:Optional
	IOTHubNamespaceRef *v1.Reference `json:"iothubNamespaceRef,omitempty" tf:"-"`

	// Selector for a IOTHub in devices to populate iothubNamespace.
	// +kubebuilder:validation:Optional
	IOTHubNamespaceSelector *v1.Selector `json:"iothubNamespaceSelector,omitempty" tf:"-"`

	// The name of the Stream Input IoTHub. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Optional
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/azure/v1beta1.ResourceGroup
	// +kubebuilder:validation:Optional
	ResourceGroupName *string `json:"resourceGroupName,omitempty" tf:"resource_group_name,omitempty"`

	// Reference to a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameRef *v1.Reference `json:"resourceGroupNameRef,omitempty" tf:"-"`

	// Selector for a ResourceGroup in azure to populate resourceGroupName.
	// +kubebuilder:validation:Optional
	ResourceGroupNameSelector *v1.Selector `json:"resourceGroupNameSelector,omitempty" tf:"-"`

	// A serialization block as defined below.
	// +kubebuilder:validation:Optional
	Serialization []StreamInputIOTHubSerializationParameters `json:"serialization,omitempty" tf:"serialization,omitempty"`

	// The shared access policy key for the specified shared access policy. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Optional
	SharedAccessPolicyKeySecretRef v1.SecretKeySelector `json:"sharedAccessPolicyKeySecretRef" tf:"-"`

	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	// +kubebuilder:validation:Optional
	SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty" tf:"shared_access_policy_name,omitempty"`

	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	// +crossplane:generate:reference:type=Job
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobName *string `json:"streamAnalyticsJobName,omitempty" tf:"stream_analytics_job_name,omitempty"`

	// Reference to a Job to populate streamAnalyticsJobName.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobNameRef *v1.Reference `json:"streamAnalyticsJobNameRef,omitempty" tf:"-"`

	// Selector for a Job to populate streamAnalyticsJobName.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobNameSelector *v1.Selector `json:"streamAnalyticsJobNameSelector,omitempty" tf:"-"`
}

func (*StreamInputIOTHubParameters) DeepCopy added in v0.27.0 

func (in *StreamInputIOTHubParameters) DeepCopy() *StreamInputIOTHubParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputIOTHubParameters.

func (*StreamInputIOTHubParameters) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamInputIOTHubSerializationObservation added in v0.27.0 

type StreamInputIOTHubSerializationObservation struct {

	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
	Encoding *string `json:"encoding,omitempty" tf:"encoding,omitempty"`

	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are   (space), , (comma), 	 (tab), | (pipe) and ;.
	FieldDelimiter *string `json:"fieldDelimiter,omitempty" tf:"field_delimiter,omitempty"`

	// The serialization format used for incoming data streams. Possible values are Avro, Csv and Json.
	Type *string `json:"type,omitempty" tf:"type,omitempty"`
}

func (*StreamInputIOTHubSerializationObservation) DeepCopy added in v0.27.0 

func (in *StreamInputIOTHubSerializationObservation) DeepCopy() *StreamInputIOTHubSerializationObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputIOTHubSerializationObservation.

func (*StreamInputIOTHubSerializationObservation) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamInputIOTHubSerializationParameters added in v0.27.0 

type StreamInputIOTHubSerializationParameters struct {

	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
	// +kubebuilder:validation:Optional
	Encoding *string `json:"encoding,omitempty" tf:"encoding,omitempty"`

	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are   (space), , (comma), 	 (tab), | (pipe) and ;.
	// +kubebuilder:validation:Optional
	FieldDelimiter *string `json:"fieldDelimiter,omitempty" tf:"field_delimiter,omitempty"`

	// The serialization format used for incoming data streams. Possible values are Avro, Csv and Json.
	// +kubebuilder:validation:Required
	Type *string `json:"type" tf:"type,omitempty"`
}

func (*StreamInputIOTHubSerializationParameters) DeepCopy added in v0.27.0 

func (in *StreamInputIOTHubSerializationParameters) DeepCopy() *StreamInputIOTHubSerializationParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputIOTHubSerializationParameters.

func (*StreamInputIOTHubSerializationParameters) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamInputIOTHubSpec added in v0.27.0 

type StreamInputIOTHubSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     StreamInputIOTHubParameters `json:"forProvider"`
}

StreamInputIOTHubSpec defines the desired state of StreamInputIOTHub

func (*StreamInputIOTHubSpec) DeepCopy added in v0.27.0 

func (in *StreamInputIOTHubSpec) DeepCopy() *StreamInputIOTHubSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputIOTHubSpec.

func (*StreamInputIOTHubSpec) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamInputIOTHubStatus added in v0.27.0 

type StreamInputIOTHubStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        StreamInputIOTHubObservation `json:"atProvider,omitempty"`
}

StreamInputIOTHubStatus defines the observed state of StreamInputIOTHub.

func (*StreamInputIOTHubStatus) DeepCopy added in v0.27.0 

func (in *StreamInputIOTHubStatus) DeepCopy() *StreamInputIOTHubStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInputIOTHubStatus.

func (*StreamInputIOTHubStatus) DeepCopyInto added in v0.27.0 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.