v1beta2

package
v1.9.0 Latest Latest
Warning

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

 Go to latest Published: Nov 20, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Overview

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

Index

Constants

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

Package type metadata.

Variables

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 (
	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 (
	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 (
	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 (
	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 FunctionJavascriptUda 

type FunctionJavascriptUda struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.input) || (has(self.initProvider) && has(self.initProvider.input))",message="spec.forProvider.input is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.output) || (has(self.initProvider) && has(self.initProvider.output))",message="spec.forProvider.output is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.script) || (has(self.initProvider) && has(self.initProvider.script))",message="spec.forProvider.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="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].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:resource:scope=Cluster,categories={crossplane,managed,azure},path=functionjavascriptudas

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) GetInitParameters 

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

GetInitParameters of this FunctionJavascriptUda

func (*FunctionJavascriptUda) GetManagementPolicies 

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

GetManagementPolicies of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) GetMergedParameters 

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

GetInitParameters 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) 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) Hub 

func (tr *FunctionJavascriptUda) Hub()

Hub marks this type as a conversion hub.

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 

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

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) SetManagementPolicies 

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

SetManagementPolicies 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) 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 FunctionJavascriptUdaInitParameters 

type FunctionJavascriptUdaInitParameters struct {

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

	// An output block as defined below.
	Output *OutputInitParameters `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.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/streamanalytics/v1beta2.Job
	// +crossplane:generate:reference:extractor=github.com/upbound/provider-azure/apis/rconfig.ExtractResourceID()
	StreamAnalyticsJobID *string `json:"streamAnalyticsJobId,omitempty" tf:"stream_analytics_job_id,omitempty"`

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

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

func (*FunctionJavascriptUdaInitParameters) DeepCopy 

func (in *FunctionJavascriptUdaInitParameters) DeepCopy() *FunctionJavascriptUdaInitParameters

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

func (*FunctionJavascriptUdaInitParameters) DeepCopyInto 

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

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

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=github.com/upbound/provider-azure/apis/streamanalytics/v1beta2.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 in streamanalytics to populate streamAnalyticsJobId.
	// +kubebuilder:validation:Optional
	StreamAnalyticsJobIDRef *v1.Reference `json:"streamAnalyticsJobIdRef,omitempty" tf:"-"`

	// Selector for a Job in streamanalytics 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"`
	// THIS IS A BETA FIELD. It will be honored
	// unless the Management Policies feature flag is disabled.
	// InitProvider holds the same fields as ForProvider, with the exception
	// of Identifier and other resource reference fields. The fields that are
	// in InitProvider are merged into ForProvider when the resource is created.
	// The same fields are also added to the terraform ignore_changes hook, to
	// avoid updating them after creation. This is useful for fields that are
	// required on creation, but we do not desire to update them after creation,
	// for example because of an external controller is managing them, like an
	// autoscaler.
	InitProvider FunctionJavascriptUdaInitParameters `json:"initProvider,omitempty"`
}

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 IdentityInitParameters 

type IdentityInitParameters struct {

	// The identity id of the user assigned identity to use when type is UserAssigned
	// +listType=set
	IdentityIds []*string `json:"identityIds,omitempty" tf:"identity_ids,omitempty"`

	// Specifies the type of Managed Service Identity that should be configured on this Stream Analytics Job. Possible values are SystemAssigned and UserAssigned.
	Type *string `json:"type,omitempty" tf:"type,omitempty"`
}

func (*IdentityInitParameters) DeepCopy 

func (in *IdentityInitParameters) DeepCopy() *IdentityInitParameters

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

func (*IdentityInitParameters) DeepCopyInto 

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

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

type IdentityObservation 

type IdentityObservation struct {

	// The identity id of the user assigned identity to use when type is UserAssigned
	// +listType=set
	IdentityIds []*string `json:"identityIds,omitempty" tf:"identity_ids,omitempty"`

	// 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. Possible values are SystemAssigned and UserAssigned.
	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 {

	// The identity id of the user assigned identity to use when type is UserAssigned
	// +kubebuilder:validation:Optional
	// +listType=set
	IdentityIds []*string `json:"identityIds,omitempty" tf:"identity_ids,omitempty"`

	// Specifies the type of Managed Service Identity that should be configured on this Stream Analytics Job. Possible values are SystemAssigned and UserAssigned.
	// +kubebuilder:validation:Optional
	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 InputInitParameters 

type InputInitParameters 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 (*InputInitParameters) DeepCopy 

func (in *InputInitParameters) DeepCopy() *InputInitParameters

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

func (*InputInitParameters) DeepCopyInto 

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

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:Optional
	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="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.location) || (has(self.initProvider) && has(self.initProvider.location))",message="spec.forProvider.location is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.transformationQuery) || (has(self.initProvider) && has(self.initProvider.transformationQuery))",message="spec.forProvider.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="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].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: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) GetInitParameters 

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

GetInitParameters of this Job

func (*Job) GetManagementPolicies 

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

GetManagementPolicies of this Job.

func (*Job) GetMergedParameters 

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

GetInitParameters 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) 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) Hub 

func (tr *Job) Hub()

Hub marks this type as a conversion hub.

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) SetManagementPolicies 

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

SetManagementPolicies 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) 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 JobInitParameters 

type JobInitParameters 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. Defaults to 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 5.
	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 0.
	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"`

	// An identity block as defined below.
	Identity *IdentityInitParameters `json:"identity,omitempty" tf:"identity,omitempty"`

	// The details of the job storage account. A job_storage_account block as defined below.
	JobStorageAccount []JobStorageAccountInitParameters `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 SKU Name to use for the Stream Analytics Job. Possible values are Standard, StandardV2. Defaults to Standard.
	SkuName *string `json:"skuName,omitempty" tf:"sku_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.
	// +mapType=granular
	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 (*JobInitParameters) DeepCopy 

func (in *JobInitParameters) DeepCopy() *JobInitParameters

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

func (*JobInitParameters) DeepCopyInto 

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

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

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. Defaults to 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 5.
	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 0.
	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 SKU Name to use for the Stream Analytics Job. Possible values are Standard, StandardV2. Defaults to Standard.
	SkuName *string `json:"skuName,omitempty" tf:"sku_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.
	// +mapType=granular
	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. Defaults to 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 5.
	// +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 0.
	// +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 SKU Name to use for the Stream Analytics Job. Possible values are Standard, StandardV2. Defaults to Standard.
	// +kubebuilder:validation:Optional
	SkuName *string `json:"skuName,omitempty" tf:"sku_name,omitempty"`

	// 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
	// +mapType=granular
	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"`
	// THIS IS A BETA FIELD. It will be honored
	// unless the Management Policies feature flag is disabled.
	// InitProvider holds the same fields as ForProvider, with the exception
	// of Identifier and other resource reference fields. The fields that are
	// in InitProvider are merged into ForProvider when the resource is created.
	// The same fields are also added to the terraform ignore_changes hook, to
	// avoid updating them after creation. This is useful for fields that are
	// required on creation, but we do not desire to update them after creation,
	// for example because of an external controller is managing them, like an
	// autoscaler.
	InitProvider JobInitParameters `json:"initProvider,omitempty"`
}

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 JobStorageAccountInitParameters 

type JobStorageAccountInitParameters struct {

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

	// 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 (*JobStorageAccountInitParameters) DeepCopy 

func (in *JobStorageAccountInitParameters) DeepCopy() *JobStorageAccountInitParameters

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

func (*JobStorageAccountInitParameters) DeepCopyInto 

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

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

type JobStorageAccountObservation 

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 

func (in *JobStorageAccountObservation) DeepCopy() *JobStorageAccountObservation

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

func (*JobStorageAccountObservation) DeepCopyInto 

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 

type JobStorageAccountParameters struct {

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

	// The name of the Azure storage account.
	// +kubebuilder:validation:Optional
	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 

func (in *JobStorageAccountParameters) DeepCopy() *JobStorageAccountParameters

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

func (*JobStorageAccountParameters) DeepCopyInto 

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

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="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.dateFormat) || (has(self.initProvider) && has(self.initProvider.dateFormat))",message="spec.forProvider.dateFormat is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.pathPattern) || (has(self.initProvider) && has(self.initProvider.pathPattern))",message="spec.forProvider.pathPattern is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.serialization) || (has(self.initProvider) && has(self.initProvider.serialization))",message="spec.forProvider.serialization is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.timeFormat) || (has(self.initProvider) && has(self.initProvider.timeFormat))",message="spec.forProvider.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="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].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: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) GetInitParameters 

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

GetInitParameters of this OutputBlob

func (*OutputBlob) GetManagementPolicies 

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

GetManagementPolicies of this OutputBlob.

func (*OutputBlob) GetMergedParameters 

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

GetInitParameters 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) 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) Hub 

func (tr *OutputBlob) Hub()

Hub marks this type as a conversion hub.

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) SetManagementPolicies 

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

SetManagementPolicies 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) 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 OutputBlobInitParameters 

type OutputBlobInitParameters 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 1000000).
	BatchMinRows *float64 `json:"batchMinRows,omitempty" tf:"batch_min_rows,omitempty"`

	// Determines whether blob blocks are either committed automatically or appended. Possible values are Append and Once. Defaults to Append.
	BlobWriteMode *string `json:"blobWriteMode,omitempty" tf:"blob_write_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 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"`

	// A serialization block as defined below.
	Serialization *SerializationInitParameters `json:"serialization,omitempty" tf:"serialization,omitempty"`

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

	// The name of the Storage Account.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/storage/v1beta2.Account
	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
	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=github.com/upbound/provider-azure/apis/streamanalytics/v1beta2.Job
	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:"-"`

	// 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 (*OutputBlobInitParameters) DeepCopy 

func (in *OutputBlobInitParameters) DeepCopy() *OutputBlobInitParameters

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

func (*OutputBlobInitParameters) DeepCopyInto 

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

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

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 1000000).
	BatchMinRows *float64 `json:"batchMinRows,omitempty" tf:"batch_min_rows,omitempty"`

	// Determines whether blob blocks are either committed automatically or appended. Possible values are Append and Once. Defaults to Append.
	BlobWriteMode *string `json:"blobWriteMode,omitempty" tf:"blob_write_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 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 1000000).
	// +kubebuilder:validation:Optional
	BatchMinRows *float64 `json:"batchMinRows,omitempty" tf:"batch_min_rows,omitempty"`

	// Determines whether blob blocks are either committed automatically or appended. Possible values are Append and Once. Defaults to Append.
	// +kubebuilder:validation:Optional
	BlobWriteMode *string `json:"blobWriteMode,omitempty" tf:"blob_write_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 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/v1beta2.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=github.com/upbound/provider-azure/apis/streamanalytics/v1beta2.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:"-"`

	// 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"`
	// THIS IS A BETA FIELD. It will be honored
	// unless the Management Policies feature flag is disabled.
	// InitProvider holds the same fields as ForProvider, with the exception
	// of Identifier and other resource reference fields. The fields that are
	// in InitProvider are merged into ForProvider when the resource is created.
	// The same fields are also added to the terraform ignore_changes hook, to
	// avoid updating them after creation. This is useful for fields that are
	// required on creation, but we do not desire to update them after creation,
	// for example because of an external controller is managing them, like an
	// autoscaler.
	InitProvider OutputBlobInitParameters `json:"initProvider,omitempty"`
}

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 

type OutputEventHub struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.serialization) || (has(self.initProvider) && has(self.initProvider.serialization))",message="spec.forProvider.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="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].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:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*OutputEventHub) DeepCopy 

func (in *OutputEventHub) DeepCopy() *OutputEventHub

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

func (*OutputEventHub) DeepCopyInto 

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 

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

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

func (*OutputEventHub) GetCondition 

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

GetCondition of this OutputEventHub.

func (*OutputEventHub) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this OutputEventHub

func (*OutputEventHub) GetDeletionPolicy 

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

GetDeletionPolicy of this OutputEventHub.

func (*OutputEventHub) GetID 

func (tr *OutputEventHub) GetID() string

GetID returns ID of underlying Terraform resource of this OutputEventHub

func (*OutputEventHub) GetInitParameters 

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

GetInitParameters of this OutputEventHub

func (*OutputEventHub) GetManagementPolicies 

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

GetManagementPolicies of this OutputEventHub.

func (*OutputEventHub) GetMergedParameters 

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

GetInitParameters of this OutputEventHub

func (*OutputEventHub) GetObservation 

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

GetObservation of this OutputEventHub

func (*OutputEventHub) GetParameters 

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

GetParameters of this OutputEventHub

func (*OutputEventHub) GetProviderConfigReference 

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

GetProviderConfigReference of this OutputEventHub.

func (*OutputEventHub) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this OutputEventHub.

func (*OutputEventHub) GetTerraformResourceType 

func (mg *OutputEventHub) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this OutputEventHub

func (*OutputEventHub) GetTerraformSchemaVersion 

func (tr *OutputEventHub) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*OutputEventHub) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this OutputEventHub.

func (*OutputEventHub) Hub 

func (tr *OutputEventHub) Hub()

Hub marks this type as a conversion hub.

func (*OutputEventHub) LateInitialize 

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 

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

ResolveReferences of this OutputEventHub.

func (*OutputEventHub) SetConditions 

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

SetConditions of this OutputEventHub.

func (*OutputEventHub) SetDeletionPolicy 

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

SetDeletionPolicy of this OutputEventHub.

func (*OutputEventHub) SetManagementPolicies 

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

SetManagementPolicies of this OutputEventHub.

func (*OutputEventHub) SetObservation 

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

SetObservation for this OutputEventHub

func (*OutputEventHub) SetParameters 

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

SetParameters for this OutputEventHub

func (*OutputEventHub) SetProviderConfigReference 

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

SetProviderConfigReference of this OutputEventHub.

func (*OutputEventHub) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this OutputEventHub.

func (*OutputEventHub) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this OutputEventHub.

type OutputEventHubInitParameters 

type OutputEventHubInitParameters 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.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/eventhub/v1beta2.EventHub
	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.
	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"`

	// A serialization block as defined below.
	Serialization *OutputEventHubSerializationInitParameters `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/v1beta2.EventHubNamespace
	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.
	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.
	SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty" tf:"shared_access_policy_name,omitempty"`
}

func (*OutputEventHubInitParameters) DeepCopy 

func (in *OutputEventHubInitParameters) DeepCopy() *OutputEventHubInitParameters

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

func (*OutputEventHubInitParameters) DeepCopyInto 

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

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

type OutputEventHubList 

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 

func (in *OutputEventHubList) DeepCopy() *OutputEventHubList

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

func (*OutputEventHubList) DeepCopyInto 

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 

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

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

func (*OutputEventHubList) GetItems 

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

GetItems of this OutputEventHubList.

type OutputEventHubObservation 

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 

func (in *OutputEventHubObservation) DeepCopy() *OutputEventHubObservation

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

func (*OutputEventHubObservation) DeepCopyInto 

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 

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/v1beta2.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/v1beta2.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 

func (in *OutputEventHubParameters) DeepCopy() *OutputEventHubParameters

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

func (*OutputEventHubParameters) DeepCopyInto 

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

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

type OutputEventHubSerializationInitParameters 

type OutputEventHubSerializationInitParameters 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 (*OutputEventHubSerializationInitParameters) DeepCopy 

func (in *OutputEventHubSerializationInitParameters) DeepCopy() *OutputEventHubSerializationInitParameters

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

func (*OutputEventHubSerializationInitParameters) DeepCopyInto 

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

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

type OutputEventHubSerializationObservation 

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 

func (in *OutputEventHubSerializationObservation) DeepCopy() *OutputEventHubSerializationObservation

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

func (*OutputEventHubSerializationObservation) DeepCopyInto 

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 

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:Optional
	Type *string `json:"type" tf:"type,omitempty"`
}

func (*OutputEventHubSerializationParameters) DeepCopy 

func (in *OutputEventHubSerializationParameters) DeepCopy() *OutputEventHubSerializationParameters

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

func (*OutputEventHubSerializationParameters) DeepCopyInto 

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 

type OutputEventHubSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     OutputEventHubParameters `json:"forProvider"`
	// THIS IS A BETA FIELD. It will be honored
	// unless the Management Policies feature flag is disabled.
	// InitProvider holds the same fields as ForProvider, with the exception
	// of Identifier and other resource reference fields. The fields that are
	// in InitProvider are merged into ForProvider when the resource is created.
	// The same fields are also added to the terraform ignore_changes hook, to
	// avoid updating them after creation. This is useful for fields that are
	// required on creation, but we do not desire to update them after creation,
	// for example because of an external controller is managing them, like an
	// autoscaler.
	InitProvider OutputEventHubInitParameters `json:"initProvider,omitempty"`
}

OutputEventHubSpec defines the desired state of OutputEventHub

func (*OutputEventHubSpec) DeepCopy 

func (in *OutputEventHubSpec) DeepCopy() *OutputEventHubSpec

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

func (*OutputEventHubSpec) DeepCopyInto 

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 

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

OutputEventHubStatus defines the observed state of OutputEventHub.

func (*OutputEventHubStatus) DeepCopy 

func (in *OutputEventHubStatus) DeepCopy() *OutputEventHubStatus

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

func (*OutputEventHubStatus) DeepCopyInto 

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

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

type OutputInitParameters 

type OutputInitParameters 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 (*OutputInitParameters) DeepCopy 

func (in *OutputInitParameters) DeepCopy() *OutputInitParameters

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

func (*OutputInitParameters) DeepCopyInto 

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

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:Optional
	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 OutputServiceBusQueue 

type OutputServiceBusQueue struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.name) || (has(self.initProvider) && has(self.initProvider.name))",message="spec.forProvider.name is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.serialization) || (has(self.initProvider) && has(self.initProvider.serialization))",message="spec.forProvider.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="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].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:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*OutputServiceBusQueue) DeepCopy 

func (in *OutputServiceBusQueue) DeepCopy() *OutputServiceBusQueue

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

func (*OutputServiceBusQueue) DeepCopyInto 

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 

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

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

func (*OutputServiceBusQueue) GetCondition 

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

GetCondition of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this OutputServiceBusQueue

func (*OutputServiceBusQueue) GetDeletionPolicy 

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

GetDeletionPolicy of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) GetID 

func (tr *OutputServiceBusQueue) GetID() string

GetID returns ID of underlying Terraform resource of this OutputServiceBusQueue

func (*OutputServiceBusQueue) GetInitParameters 

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

GetInitParameters of this OutputServiceBusQueue

func (*OutputServiceBusQueue) GetManagementPolicies 

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

GetManagementPolicies of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) GetMergedParameters 

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

GetInitParameters of this OutputServiceBusQueue

func (*OutputServiceBusQueue) GetObservation 

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

GetObservation of this OutputServiceBusQueue

func (*OutputServiceBusQueue) GetParameters 

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

GetParameters of this OutputServiceBusQueue

func (*OutputServiceBusQueue) GetProviderConfigReference 

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

GetProviderConfigReference of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) GetTerraformResourceType 

func (mg *OutputServiceBusQueue) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this OutputServiceBusQueue

func (*OutputServiceBusQueue) GetTerraformSchemaVersion 

func (tr *OutputServiceBusQueue) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*OutputServiceBusQueue) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) Hub 

func (tr *OutputServiceBusQueue) Hub()

Hub marks this type as a conversion hub.

func (*OutputServiceBusQueue) LateInitialize 

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 

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

ResolveReferences of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) SetConditions 

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

SetConditions of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) SetDeletionPolicy 

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

SetDeletionPolicy of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) SetManagementPolicies 

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

SetManagementPolicies of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) SetObservation 

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

SetObservation for this OutputServiceBusQueue

func (*OutputServiceBusQueue) SetParameters 

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

SetParameters for this OutputServiceBusQueue

func (*OutputServiceBusQueue) SetProviderConfigReference 

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

SetProviderConfigReference of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this OutputServiceBusQueue.

func (*OutputServiceBusQueue) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this OutputServiceBusQueue.

type OutputServiceBusQueueInitParameters 

type OutputServiceBusQueueInitParameters 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 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.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/servicebus/v1beta1.Queue
	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
	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.
	Serialization *OutputServiceBusQueueSerializationInitParameters `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/v1beta2.ServiceBusNamespace
	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.
	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.
	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=github.com/upbound/provider-azure/apis/streamanalytics/v1beta2.Job
	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:"-"`

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

func (*OutputServiceBusQueueInitParameters) DeepCopy 

func (in *OutputServiceBusQueueInitParameters) DeepCopy() *OutputServiceBusQueueInitParameters

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

func (*OutputServiceBusQueueInitParameters) DeepCopyInto 

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

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

type OutputServiceBusQueueList 

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 

func (in *OutputServiceBusQueueList) DeepCopy() *OutputServiceBusQueueList

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

func (*OutputServiceBusQueueList) DeepCopyInto 

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 

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

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

func (*OutputServiceBusQueueList) GetItems 

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

GetItems of this OutputServiceBusQueueList.

type OutputServiceBusQueueObservation 

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.
	// +mapType=granular
	SystemPropertyColumns map[string]*string `json:"systemPropertyColumns,omitempty" tf:"system_property_columns,omitempty"`
}

func (*OutputServiceBusQueueObservation) DeepCopy 

func (in *OutputServiceBusQueueObservation) DeepCopy() *OutputServiceBusQueueObservation

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

func (*OutputServiceBusQueueObservation) DeepCopyInto 

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 

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/v1beta2.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=github.com/upbound/provider-azure/apis/streamanalytics/v1beta2.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:"-"`

	// 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
	// +mapType=granular
	SystemPropertyColumns map[string]*string `json:"systemPropertyColumns,omitempty" tf:"system_property_columns,omitempty"`
}

func (*OutputServiceBusQueueParameters) DeepCopy 

func (in *OutputServiceBusQueueParameters) DeepCopy() *OutputServiceBusQueueParameters

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

func (*OutputServiceBusQueueParameters) DeepCopyInto 

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

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

type OutputServiceBusQueueSerializationInitParameters 

type OutputServiceBusQueueSerializationInitParameters 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 (*OutputServiceBusQueueSerializationInitParameters) DeepCopy 

func (in *OutputServiceBusQueueSerializationInitParameters) DeepCopy() *OutputServiceBusQueueSerializationInitParameters

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

func (*OutputServiceBusQueueSerializationInitParameters) DeepCopyInto 

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

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

type OutputServiceBusQueueSerializationObservation 

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 

func (in *OutputServiceBusQueueSerializationObservation) DeepCopy() *OutputServiceBusQueueSerializationObservation

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

func (*OutputServiceBusQueueSerializationObservation) DeepCopyInto 

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 

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:Optional
	Type *string `json:"type" tf:"type,omitempty"`
}

func (*OutputServiceBusQueueSerializationParameters) DeepCopy 

func (in *OutputServiceBusQueueSerializationParameters) DeepCopy() *OutputServiceBusQueueSerializationParameters

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

func (*OutputServiceBusQueueSerializationParameters) DeepCopyInto 

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 

type OutputServiceBusQueueSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     OutputServiceBusQueueParameters `json:"forProvider"`
	// THIS IS A BETA FIELD. It will be honored
	// unless the Management Policies feature flag is disabled.
	// InitProvider holds the same fields as ForProvider, with the exception
	// of Identifier and other resource reference fields. The fields that are
	// in InitProvider are merged into ForProvider when the resource is created.
	// The same fields are also added to the terraform ignore_changes hook, to
	// avoid updating them after creation. This is useful for fields that are
	// required on creation, but we do not desire to update them after creation,
	// for example because of an external controller is managing them, like an
	// autoscaler.
	InitProvider OutputServiceBusQueueInitParameters `json:"initProvider,omitempty"`
}

OutputServiceBusQueueSpec defines the desired state of OutputServiceBusQueue

func (*OutputServiceBusQueueSpec) DeepCopy 

func (in *OutputServiceBusQueueSpec) DeepCopy() *OutputServiceBusQueueSpec

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

func (*OutputServiceBusQueueSpec) DeepCopyInto 

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 

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

OutputServiceBusQueueStatus defines the observed state of OutputServiceBusQueue.

func (*OutputServiceBusQueueStatus) DeepCopy 

func (in *OutputServiceBusQueueStatus) DeepCopy() *OutputServiceBusQueueStatus

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

func (*OutputServiceBusQueueStatus) DeepCopyInto 

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 

type OutputServiceBusTopic struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.name) || (has(self.initProvider) && has(self.initProvider.name))",message="spec.forProvider.name is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.serialization) || (has(self.initProvider) && has(self.initProvider.serialization))",message="spec.forProvider.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="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].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:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*OutputServiceBusTopic) DeepCopy 

func (in *OutputServiceBusTopic) DeepCopy() *OutputServiceBusTopic

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

func (*OutputServiceBusTopic) DeepCopyInto 

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 

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

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

func (*OutputServiceBusTopic) GetCondition 

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

GetCondition of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this OutputServiceBusTopic

func (*OutputServiceBusTopic) GetDeletionPolicy 

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

GetDeletionPolicy of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) GetID 

func (tr *OutputServiceBusTopic) GetID() string

GetID returns ID of underlying Terraform resource of this OutputServiceBusTopic

func (*OutputServiceBusTopic) GetInitParameters 

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

GetInitParameters of this OutputServiceBusTopic

func (*OutputServiceBusTopic) GetManagementPolicies 

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

GetManagementPolicies of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) GetMergedParameters 

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

GetInitParameters of this OutputServiceBusTopic

func (*OutputServiceBusTopic) GetObservation 

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

GetObservation of this OutputServiceBusTopic

func (*OutputServiceBusTopic) GetParameters 

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

GetParameters of this OutputServiceBusTopic

func (*OutputServiceBusTopic) GetProviderConfigReference 

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

GetProviderConfigReference of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) GetTerraformResourceType 

func (mg *OutputServiceBusTopic) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this OutputServiceBusTopic

func (*OutputServiceBusTopic) GetTerraformSchemaVersion 

func (tr *OutputServiceBusTopic) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*OutputServiceBusTopic) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) Hub 

func (tr *OutputServiceBusTopic) Hub()

Hub marks this type as a conversion hub.

func (*OutputServiceBusTopic) LateInitialize 

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 

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

ResolveReferences of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) SetConditions 

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

SetConditions of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) SetDeletionPolicy 

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

SetDeletionPolicy of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) SetManagementPolicies 

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

SetManagementPolicies of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) SetObservation 

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

SetObservation for this OutputServiceBusTopic

func (*OutputServiceBusTopic) SetParameters 

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

SetParameters for this OutputServiceBusTopic

func (*OutputServiceBusTopic) SetProviderConfigReference 

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

SetProviderConfigReference of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this OutputServiceBusTopic.

func (*OutputServiceBusTopic) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this OutputServiceBusTopic.

type OutputServiceBusTopicInitParameters 

type OutputServiceBusTopicInitParameters 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 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.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/azure/v1beta1.ResourceGroup
	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.
	Serialization *OutputServiceBusTopicSerializationInitParameters `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/v1beta2.ServiceBusNamespace
	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.
	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.
	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=github.com/upbound/provider-azure/apis/streamanalytics/v1beta2.Job
	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:"-"`

	// A key-value pair of system property columns that will be attached to the outgoing messages for the Service Bus Topic Output.
	// +mapType=granular
	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
	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 (*OutputServiceBusTopicInitParameters) DeepCopy 

func (in *OutputServiceBusTopicInitParameters) DeepCopy() *OutputServiceBusTopicInitParameters

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

func (*OutputServiceBusTopicInitParameters) DeepCopyInto 

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

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

type OutputServiceBusTopicList 

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 

func (in *OutputServiceBusTopicList) DeepCopy() *OutputServiceBusTopicList

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

func (*OutputServiceBusTopicList) DeepCopyInto 

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 

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

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

func (*OutputServiceBusTopicList) GetItems 

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

GetItems of this OutputServiceBusTopicList.

type OutputServiceBusTopicObservation 

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.
	// +mapType=granular
	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 

func (in *OutputServiceBusTopicObservation) DeepCopy() *OutputServiceBusTopicObservation

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

func (*OutputServiceBusTopicObservation) DeepCopyInto 

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 

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/v1beta2.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=github.com/upbound/provider-azure/apis/streamanalytics/v1beta2.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:"-"`

	// 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
	// +mapType=granular
	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 

func (in *OutputServiceBusTopicParameters) DeepCopy() *OutputServiceBusTopicParameters

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

func (*OutputServiceBusTopicParameters) DeepCopyInto 

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

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

type OutputServiceBusTopicSerializationInitParameters 

type OutputServiceBusTopicSerializationInitParameters 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 (*OutputServiceBusTopicSerializationInitParameters) DeepCopy 

func (in *OutputServiceBusTopicSerializationInitParameters) DeepCopy() *OutputServiceBusTopicSerializationInitParameters

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

func (*OutputServiceBusTopicSerializationInitParameters) DeepCopyInto 

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

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

type OutputServiceBusTopicSerializationObservation 

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 

func (in *OutputServiceBusTopicSerializationObservation) DeepCopy() *OutputServiceBusTopicSerializationObservation

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

func (*OutputServiceBusTopicSerializationObservation) DeepCopyInto 

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 

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:Optional
	Type *string `json:"type" tf:"type,omitempty"`
}

func (*OutputServiceBusTopicSerializationParameters) DeepCopy 

func (in *OutputServiceBusTopicSerializationParameters) DeepCopy() *OutputServiceBusTopicSerializationParameters

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

func (*OutputServiceBusTopicSerializationParameters) DeepCopyInto 

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 

type OutputServiceBusTopicSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     OutputServiceBusTopicParameters `json:"forProvider"`
	// THIS IS A BETA FIELD. It will be honored
	// unless the Management Policies feature flag is disabled.
	// InitProvider holds the same fields as ForProvider, with the exception
	// of Identifier and other resource reference fields. The fields that are
	// in InitProvider are merged into ForProvider when the resource is created.
	// The same fields are also added to the terraform ignore_changes hook, to
	// avoid updating them after creation. This is useful for fields that are
	// required on creation, but we do not desire to update them after creation,
	// for example because of an external controller is managing them, like an
	// autoscaler.
	InitProvider OutputServiceBusTopicInitParameters `json:"initProvider,omitempty"`
}

OutputServiceBusTopicSpec defines the desired state of OutputServiceBusTopic

func (*OutputServiceBusTopicSpec) DeepCopy 

func (in *OutputServiceBusTopicSpec) DeepCopy() *OutputServiceBusTopicSpec

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

func (*OutputServiceBusTopicSpec) DeepCopyInto 

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 

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

OutputServiceBusTopicStatus defines the observed state of OutputServiceBusTopic.

func (*OutputServiceBusTopicStatus) DeepCopy 

func (in *OutputServiceBusTopicStatus) DeepCopy() *OutputServiceBusTopicStatus

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

func (*OutputServiceBusTopicStatus) DeepCopyInto 

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

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

type ReferenceInputBlob 

type ReferenceInputBlob struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.dateFormat) || (has(self.initProvider) && has(self.initProvider.dateFormat))",message="spec.forProvider.dateFormat is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.name) || (has(self.initProvider) && has(self.initProvider.name))",message="spec.forProvider.name is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.pathPattern) || (has(self.initProvider) && has(self.initProvider.pathPattern))",message="spec.forProvider.pathPattern is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.serialization) || (has(self.initProvider) && has(self.initProvider.serialization))",message="spec.forProvider.serialization is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.timeFormat) || (has(self.initProvider) && has(self.initProvider.timeFormat))",message="spec.forProvider.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="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].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:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*ReferenceInputBlob) DeepCopy 

func (in *ReferenceInputBlob) DeepCopy() *ReferenceInputBlob

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

func (*ReferenceInputBlob) DeepCopyInto 

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 

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

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

func (*ReferenceInputBlob) GetCondition 

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

GetCondition of this ReferenceInputBlob.

func (*ReferenceInputBlob) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this ReferenceInputBlob

func (*ReferenceInputBlob) GetDeletionPolicy 

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

GetDeletionPolicy of this ReferenceInputBlob.

func (*ReferenceInputBlob) GetID 

func (tr *ReferenceInputBlob) GetID() string

GetID returns ID of underlying Terraform resource of this ReferenceInputBlob

func (*ReferenceInputBlob) GetInitParameters 

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

GetInitParameters of this ReferenceInputBlob

func (*ReferenceInputBlob) GetManagementPolicies 

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

GetManagementPolicies of this ReferenceInputBlob.

func (*ReferenceInputBlob) GetMergedParameters 

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

GetInitParameters of this ReferenceInputBlob

func (*ReferenceInputBlob) GetObservation 

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

GetObservation of this ReferenceInputBlob

func (*ReferenceInputBlob) GetParameters 

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

GetParameters of this ReferenceInputBlob

func (*ReferenceInputBlob) GetProviderConfigReference 

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

GetProviderConfigReference of this ReferenceInputBlob.

func (*ReferenceInputBlob) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this ReferenceInputBlob.

func (*ReferenceInputBlob) GetTerraformResourceType 

func (mg *ReferenceInputBlob) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this ReferenceInputBlob

func (*ReferenceInputBlob) GetTerraformSchemaVersion 

func (tr *ReferenceInputBlob) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*ReferenceInputBlob) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this ReferenceInputBlob.

func (*ReferenceInputBlob) Hub 

func (tr *ReferenceInputBlob) Hub()

Hub marks this type as a conversion hub.

func (*ReferenceInputBlob) LateInitialize 

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 

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

ResolveReferences of this ReferenceInputBlob.

func (*ReferenceInputBlob) SetConditions 

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

SetConditions of this ReferenceInputBlob.

func (*ReferenceInputBlob) SetDeletionPolicy 

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

SetDeletionPolicy of this ReferenceInputBlob.

func (*ReferenceInputBlob) SetManagementPolicies 

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

SetManagementPolicies of this ReferenceInputBlob.

func (*ReferenceInputBlob) SetObservation 

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

SetObservation for this ReferenceInputBlob

func (*ReferenceInputBlob) SetParameters 

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

SetParameters for this ReferenceInputBlob

func (*ReferenceInputBlob) SetProviderConfigReference 

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

SetProviderConfigReference of this ReferenceInputBlob.

func (*ReferenceInputBlob) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this ReferenceInputBlob.

func (*ReferenceInputBlob) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this ReferenceInputBlob.

type ReferenceInputBlobInitParameters 

type ReferenceInputBlobInitParameters 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 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.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/azure/v1beta1.ResourceGroup
	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.
	Serialization *ReferenceInputBlobSerializationInitParameters `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.
	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/v1beta2.Account
	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
	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=github.com/upbound/provider-azure/apis/streamanalytics/v1beta2.Job
	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:"-"`

	// 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 (*ReferenceInputBlobInitParameters) DeepCopy 

func (in *ReferenceInputBlobInitParameters) DeepCopy() *ReferenceInputBlobInitParameters

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

func (*ReferenceInputBlobInitParameters) DeepCopyInto 

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

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

type ReferenceInputBlobList 

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 

func (in *ReferenceInputBlobList) DeepCopy() *ReferenceInputBlobList

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

func (*ReferenceInputBlobList) DeepCopyInto 

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 

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

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

func (*ReferenceInputBlobList) GetItems 

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

GetItems of this ReferenceInputBlobList.

type ReferenceInputBlobObservation 

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 

func (in *ReferenceInputBlobObservation) DeepCopy() *ReferenceInputBlobObservation

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

func (*ReferenceInputBlobObservation) DeepCopyInto 

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 

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/v1beta2.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=github.com/upbound/provider-azure/apis/streamanalytics/v1beta2.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:"-"`

	// 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 

func (in *ReferenceInputBlobParameters) DeepCopy() *ReferenceInputBlobParameters

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

func (*ReferenceInputBlobParameters) DeepCopyInto 

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

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

type ReferenceInputBlobSerializationInitParameters 

type ReferenceInputBlobSerializationInitParameters 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 (*ReferenceInputBlobSerializationInitParameters) DeepCopy 

func (in *ReferenceInputBlobSerializationInitParameters) DeepCopy() *ReferenceInputBlobSerializationInitParameters

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

func (*ReferenceInputBlobSerializationInitParameters) DeepCopyInto 

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

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

type ReferenceInputBlobSerializationObservation 

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 

func (in *ReferenceInputBlobSerializationObservation) DeepCopy() *ReferenceInputBlobSerializationObservation

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

func (*ReferenceInputBlobSerializationObservation) DeepCopyInto 

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 

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:Optional
	Type *string `json:"type" tf:"type,omitempty"`
}

func (*ReferenceInputBlobSerializationParameters) DeepCopy 

func (in *ReferenceInputBlobSerializationParameters) DeepCopy() *ReferenceInputBlobSerializationParameters

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

func (*ReferenceInputBlobSerializationParameters) DeepCopyInto 

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 

type ReferenceInputBlobSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     ReferenceInputBlobParameters `json:"forProvider"`
	// THIS IS A BETA FIELD. It will be honored
	// unless the Management Policies feature flag is disabled.
	// InitProvider holds the same fields as ForProvider, with the exception
	// of Identifier and other resource reference fields. The fields that are
	// in InitProvider are merged into ForProvider when the resource is created.
	// The same fields are also added to the terraform ignore_changes hook, to
	// avoid updating them after creation. This is useful for fields that are
	// required on creation, but we do not desire to update them after creation,
	// for example because of an external controller is managing them, like an
	// autoscaler.
	InitProvider ReferenceInputBlobInitParameters `json:"initProvider,omitempty"`
}

ReferenceInputBlobSpec defines the desired state of ReferenceInputBlob

func (*ReferenceInputBlobSpec) DeepCopy 

func (in *ReferenceInputBlobSpec) DeepCopy() *ReferenceInputBlobSpec

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

func (*ReferenceInputBlobSpec) DeepCopyInto 

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 

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

ReferenceInputBlobStatus defines the observed state of ReferenceInputBlob.

func (*ReferenceInputBlobStatus) DeepCopy 

func (in *ReferenceInputBlobStatus) DeepCopy() *ReferenceInputBlobStatus

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

func (*ReferenceInputBlobStatus) DeepCopyInto 

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

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

type SerializationInitParameters 

type SerializationInitParameters 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 (*SerializationInitParameters) DeepCopy 

func (in *SerializationInitParameters) DeepCopy() *SerializationInitParameters

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

func (*SerializationInitParameters) DeepCopyInto 

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

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:Optional
	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 

type StreamInputBlob struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.dateFormat) || (has(self.initProvider) && has(self.initProvider.dateFormat))",message="spec.forProvider.dateFormat is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.name) || (has(self.initProvider) && has(self.initProvider.name))",message="spec.forProvider.name is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.pathPattern) || (has(self.initProvider) && has(self.initProvider.pathPattern))",message="spec.forProvider.pathPattern is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.serialization) || (has(self.initProvider) && has(self.initProvider.serialization))",message="spec.forProvider.serialization is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.storageAccountKeySecretRef)",message="spec.forProvider.storageAccountKeySecretRef is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.timeFormat) || (has(self.initProvider) && has(self.initProvider.timeFormat))",message="spec.forProvider.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="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].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:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*StreamInputBlob) DeepCopy 

func (in *StreamInputBlob) DeepCopy() *StreamInputBlob

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

func (*StreamInputBlob) DeepCopyInto 

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 

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

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

func (*StreamInputBlob) GetCondition 

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

GetCondition of this StreamInputBlob.

func (*StreamInputBlob) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this StreamInputBlob

func (*StreamInputBlob) GetDeletionPolicy 

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

GetDeletionPolicy of this StreamInputBlob.

func (*StreamInputBlob) GetID 

func (tr *StreamInputBlob) GetID() string

GetID returns ID of underlying Terraform resource of this StreamInputBlob

func (*StreamInputBlob) GetInitParameters 

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

GetInitParameters of this StreamInputBlob

func (*StreamInputBlob) GetManagementPolicies 

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

GetManagementPolicies of this StreamInputBlob.

func (*StreamInputBlob) GetMergedParameters 

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

GetInitParameters of this StreamInputBlob

func (*StreamInputBlob) GetObservation 

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

GetObservation of this StreamInputBlob

func (*StreamInputBlob) GetParameters 

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

GetParameters of this StreamInputBlob

func (*StreamInputBlob) GetProviderConfigReference 

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

GetProviderConfigReference of this StreamInputBlob.

func (*StreamInputBlob) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this StreamInputBlob.

func (*StreamInputBlob) GetTerraformResourceType 

func (mg *StreamInputBlob) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this StreamInputBlob

func (*StreamInputBlob) GetTerraformSchemaVersion 

func (tr *StreamInputBlob) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*StreamInputBlob) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this StreamInputBlob.

func (*StreamInputBlob) Hub 

func (tr *StreamInputBlob) Hub()

Hub marks this type as a conversion hub.

func (*StreamInputBlob) LateInitialize 

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 

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

ResolveReferences of this StreamInputBlob.

func (*StreamInputBlob) SetConditions 

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

SetConditions of this StreamInputBlob.

func (*StreamInputBlob) SetDeletionPolicy 

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

SetDeletionPolicy of this StreamInputBlob.

func (*StreamInputBlob) SetManagementPolicies 

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

SetManagementPolicies of this StreamInputBlob.

func (*StreamInputBlob) SetObservation 

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

SetObservation for this StreamInputBlob

func (*StreamInputBlob) SetParameters 

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

SetParameters for this StreamInputBlob

func (*StreamInputBlob) SetProviderConfigReference 

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

SetProviderConfigReference of this StreamInputBlob.

func (*StreamInputBlob) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this StreamInputBlob.

func (*StreamInputBlob) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this StreamInputBlob.

type StreamInputBlobInitParameters 

type StreamInputBlobInitParameters 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 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.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/azure/v1beta1.ResourceGroup
	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.
	Serialization *StreamInputBlobSerializationInitParameters `json:"serialization,omitempty" tf:"serialization,omitempty"`

	// The Access Key which should be used to connect to this Storage Account.
	StorageAccountKeySecretRef v1.SecretKeySelector `json:"storageAccountKeySecretRef" tf:"-"`

	// The name of the Storage Account.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/storage/v1beta2.Account
	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
	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=github.com/upbound/provider-azure/apis/streamanalytics/v1beta2.Job
	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:"-"`

	// 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 (*StreamInputBlobInitParameters) DeepCopy 

func (in *StreamInputBlobInitParameters) DeepCopy() *StreamInputBlobInitParameters

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

func (*StreamInputBlobInitParameters) DeepCopyInto 

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

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

type StreamInputBlobList 

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 

func (in *StreamInputBlobList) DeepCopy() *StreamInputBlobList

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

func (*StreamInputBlobList) DeepCopyInto 

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 

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

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

func (*StreamInputBlobList) GetItems 

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

GetItems of this StreamInputBlobList.

type StreamInputBlobObservation 

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 

func (in *StreamInputBlobObservation) DeepCopy() *StreamInputBlobObservation

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

func (*StreamInputBlobObservation) DeepCopyInto 

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 

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/v1beta2.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=github.com/upbound/provider-azure/apis/streamanalytics/v1beta2.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:"-"`

	// 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 

func (in *StreamInputBlobParameters) DeepCopy() *StreamInputBlobParameters

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

func (*StreamInputBlobParameters) DeepCopyInto 

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

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

type StreamInputBlobSerializationInitParameters 

type StreamInputBlobSerializationInitParameters 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 (*StreamInputBlobSerializationInitParameters) DeepCopy 

func (in *StreamInputBlobSerializationInitParameters) DeepCopy() *StreamInputBlobSerializationInitParameters

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

func (*StreamInputBlobSerializationInitParameters) DeepCopyInto 

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

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

type StreamInputBlobSerializationObservation 

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 

func (in *StreamInputBlobSerializationObservation) DeepCopy() *StreamInputBlobSerializationObservation

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

func (*StreamInputBlobSerializationObservation) DeepCopyInto 

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 

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:Optional
	Type *string `json:"type" tf:"type,omitempty"`
}

func (*StreamInputBlobSerializationParameters) DeepCopy 

func (in *StreamInputBlobSerializationParameters) DeepCopy() *StreamInputBlobSerializationParameters

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

func (*StreamInputBlobSerializationParameters) DeepCopyInto 

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 

type StreamInputBlobSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     StreamInputBlobParameters `json:"forProvider"`
	// THIS IS A BETA FIELD. It will be honored
	// unless the Management Policies feature flag is disabled.
	// InitProvider holds the same fields as ForProvider, with the exception
	// of Identifier and other resource reference fields. The fields that are
	// in InitProvider are merged into ForProvider when the resource is created.
	// The same fields are also added to the terraform ignore_changes hook, to
	// avoid updating them after creation. This is useful for fields that are
	// required on creation, but we do not desire to update them after creation,
	// for example because of an external controller is managing them, like an
	// autoscaler.
	InitProvider StreamInputBlobInitParameters `json:"initProvider,omitempty"`
}

StreamInputBlobSpec defines the desired state of StreamInputBlob

func (*StreamInputBlobSpec) DeepCopy 

func (in *StreamInputBlobSpec) DeepCopy() *StreamInputBlobSpec

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

func (*StreamInputBlobSpec) DeepCopyInto 

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 

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

StreamInputBlobStatus defines the observed state of StreamInputBlob.

func (*StreamInputBlobStatus) DeepCopy 

func (in *StreamInputBlobStatus) DeepCopy() *StreamInputBlobStatus

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

func (*StreamInputBlobStatus) DeepCopyInto 

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 

type StreamInputEventHub struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.name) || (has(self.initProvider) && has(self.initProvider.name))",message="spec.forProvider.name is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.serialization) || (has(self.initProvider) && has(self.initProvider.serialization))",message="spec.forProvider.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="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].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:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*StreamInputEventHub) DeepCopy 

func (in *StreamInputEventHub) DeepCopy() *StreamInputEventHub

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

func (*StreamInputEventHub) DeepCopyInto 

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 

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

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

func (*StreamInputEventHub) GetCondition 

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

GetCondition of this StreamInputEventHub.

func (*StreamInputEventHub) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this StreamInputEventHub

func (*StreamInputEventHub) GetDeletionPolicy 

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

GetDeletionPolicy of this StreamInputEventHub.

func (*StreamInputEventHub) GetID 

func (tr *StreamInputEventHub) GetID() string

GetID returns ID of underlying Terraform resource of this StreamInputEventHub

func (*StreamInputEventHub) GetInitParameters 

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

GetInitParameters of this StreamInputEventHub

func (*StreamInputEventHub) GetManagementPolicies 

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

GetManagementPolicies of this StreamInputEventHub.

func (*StreamInputEventHub) GetMergedParameters 

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

GetInitParameters of this StreamInputEventHub

func (*StreamInputEventHub) GetObservation 

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

GetObservation of this StreamInputEventHub

func (*StreamInputEventHub) GetParameters 

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

GetParameters of this StreamInputEventHub

func (*StreamInputEventHub) GetProviderConfigReference 

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

GetProviderConfigReference of this StreamInputEventHub.

func (*StreamInputEventHub) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this StreamInputEventHub.

func (*StreamInputEventHub) GetTerraformResourceType 

func (mg *StreamInputEventHub) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this StreamInputEventHub

func (*StreamInputEventHub) GetTerraformSchemaVersion 

func (tr *StreamInputEventHub) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*StreamInputEventHub) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this StreamInputEventHub.

func (*StreamInputEventHub) Hub 

func (tr *StreamInputEventHub) Hub()

Hub marks this type as a conversion hub.

func (*StreamInputEventHub) LateInitialize 

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 

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

ResolveReferences of this StreamInputEventHub.

func (*StreamInputEventHub) SetConditions 

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

SetConditions of this StreamInputEventHub.

func (*StreamInputEventHub) SetDeletionPolicy 

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

SetDeletionPolicy of this StreamInputEventHub.

func (*StreamInputEventHub) SetManagementPolicies 

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

SetManagementPolicies of this StreamInputEventHub.

func (*StreamInputEventHub) SetObservation 

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

SetObservation for this StreamInputEventHub

func (*StreamInputEventHub) SetParameters 

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

SetParameters for this StreamInputEventHub

func (*StreamInputEventHub) SetProviderConfigReference 

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

SetProviderConfigReference of this StreamInputEventHub.

func (*StreamInputEventHub) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this StreamInputEventHub.

func (*StreamInputEventHub) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this StreamInputEventHub.

type StreamInputEventHubInitParameters 

type StreamInputEventHubInitParameters 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.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/eventhub/v1beta1.ConsumerGroup
	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/v1beta2.EventHub
	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.
	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.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/azure/v1beta1.ResourceGroup
	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.
	Serialization *StreamInputEventHubSerializationInitParameters `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/v1beta2.EventHubNamespace
	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.
	SharedAccessPolicyKeySecretRef *v1.SecretKeySelector `json:"sharedAccessPolicyKeySecretRef,omitempty" tf:"-"`

	// 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.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/streamanalytics/v1beta2.Job
	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 (*StreamInputEventHubInitParameters) DeepCopy 

func (in *StreamInputEventHubInitParameters) DeepCopy() *StreamInputEventHubInitParameters

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

func (*StreamInputEventHubInitParameters) DeepCopyInto 

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

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

type StreamInputEventHubList 

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 

func (in *StreamInputEventHubList) DeepCopy() *StreamInputEventHubList

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

func (*StreamInputEventHubList) DeepCopyInto 

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 

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

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

func (*StreamInputEventHubList) GetItems 

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

GetItems of this StreamInputEventHubList.

type StreamInputEventHubObservation 

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 

func (in *StreamInputEventHubObservation) DeepCopy() *StreamInputEventHubObservation

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

func (*StreamInputEventHubObservation) DeepCopyInto 

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 

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/v1beta2.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/v1beta2.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=github.com/upbound/provider-azure/apis/streamanalytics/v1beta2.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 (*StreamInputEventHubParameters) DeepCopy 

func (in *StreamInputEventHubParameters) DeepCopy() *StreamInputEventHubParameters

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

func (*StreamInputEventHubParameters) DeepCopyInto 

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

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

type StreamInputEventHubSerializationInitParameters 

type StreamInputEventHubSerializationInitParameters 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 (*StreamInputEventHubSerializationInitParameters) DeepCopy 

func (in *StreamInputEventHubSerializationInitParameters) DeepCopy() *StreamInputEventHubSerializationInitParameters

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

func (*StreamInputEventHubSerializationInitParameters) DeepCopyInto 

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

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

type StreamInputEventHubSerializationObservation 

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 

func (in *StreamInputEventHubSerializationObservation) DeepCopy() *StreamInputEventHubSerializationObservation

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

func (*StreamInputEventHubSerializationObservation) DeepCopyInto 

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 

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:Optional
	Type *string `json:"type" tf:"type,omitempty"`
}

func (*StreamInputEventHubSerializationParameters) DeepCopy 

func (in *StreamInputEventHubSerializationParameters) DeepCopy() *StreamInputEventHubSerializationParameters

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

func (*StreamInputEventHubSerializationParameters) DeepCopyInto 

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 

type StreamInputEventHubSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     StreamInputEventHubParameters `json:"forProvider"`
	// THIS IS A BETA FIELD. It will be honored
	// unless the Management Policies feature flag is disabled.
	// InitProvider holds the same fields as ForProvider, with the exception
	// of Identifier and other resource reference fields. The fields that are
	// in InitProvider are merged into ForProvider when the resource is created.
	// The same fields are also added to the terraform ignore_changes hook, to
	// avoid updating them after creation. This is useful for fields that are
	// required on creation, but we do not desire to update them after creation,
	// for example because of an external controller is managing them, like an
	// autoscaler.
	InitProvider StreamInputEventHubInitParameters `json:"initProvider,omitempty"`
}

StreamInputEventHubSpec defines the desired state of StreamInputEventHub

func (*StreamInputEventHubSpec) DeepCopy 

func (in *StreamInputEventHubSpec) DeepCopy() *StreamInputEventHubSpec

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

func (*StreamInputEventHubSpec) DeepCopyInto 

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 

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

StreamInputEventHubStatus defines the observed state of StreamInputEventHub.

func (*StreamInputEventHubStatus) DeepCopy 

func (in *StreamInputEventHubStatus) DeepCopy() *StreamInputEventHubStatus

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

func (*StreamInputEventHubStatus) DeepCopyInto 

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 

type StreamInputIOTHub struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.endpoint) || (has(self.initProvider) && has(self.initProvider.endpoint))",message="spec.forProvider.endpoint is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.name) || (has(self.initProvider) && has(self.initProvider.name))",message="spec.forProvider.name is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.serialization) || (has(self.initProvider) && has(self.initProvider.serialization))",message="spec.forProvider.serialization is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.sharedAccessPolicyKeySecretRef)",message="spec.forProvider.sharedAccessPolicyKeySecretRef is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.sharedAccessPolicyName) || (has(self.initProvider) && has(self.initProvider.sharedAccessPolicyName))",message="spec.forProvider.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="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].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:resource:scope=Cluster,categories={crossplane,managed,azure}

func (*StreamInputIOTHub) DeepCopy 

func (in *StreamInputIOTHub) DeepCopy() *StreamInputIOTHub

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

func (*StreamInputIOTHub) DeepCopyInto 

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 

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

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

func (*StreamInputIOTHub) GetCondition 

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

GetCondition of this StreamInputIOTHub.

func (*StreamInputIOTHub) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this StreamInputIOTHub

func (*StreamInputIOTHub) GetDeletionPolicy 

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

GetDeletionPolicy of this StreamInputIOTHub.

func (*StreamInputIOTHub) GetID 

func (tr *StreamInputIOTHub) GetID() string

GetID returns ID of underlying Terraform resource of this StreamInputIOTHub

func (*StreamInputIOTHub) GetInitParameters 

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

GetInitParameters of this StreamInputIOTHub

func (*StreamInputIOTHub) GetManagementPolicies 

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

GetManagementPolicies of this StreamInputIOTHub.

func (*StreamInputIOTHub) GetMergedParameters 

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

GetInitParameters of this StreamInputIOTHub

func (*StreamInputIOTHub) GetObservation 

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

GetObservation of this StreamInputIOTHub

func (*StreamInputIOTHub) GetParameters 

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

GetParameters of this StreamInputIOTHub

func (*StreamInputIOTHub) GetProviderConfigReference 

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

GetProviderConfigReference of this StreamInputIOTHub.

func (*StreamInputIOTHub) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this StreamInputIOTHub.

func (*StreamInputIOTHub) GetTerraformResourceType 

func (mg *StreamInputIOTHub) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this StreamInputIOTHub

func (*StreamInputIOTHub) GetTerraformSchemaVersion 

func (tr *StreamInputIOTHub) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*StreamInputIOTHub) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this StreamInputIOTHub.

func (*StreamInputIOTHub) Hub 

func (tr *StreamInputIOTHub) Hub()

Hub marks this type as a conversion hub.

func (*StreamInputIOTHub) LateInitialize 

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 

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

ResolveReferences of this StreamInputIOTHub.

func (*StreamInputIOTHub) SetConditions 

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

SetConditions of this StreamInputIOTHub.

func (*StreamInputIOTHub) SetDeletionPolicy 

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

SetDeletionPolicy of this StreamInputIOTHub.

func (*StreamInputIOTHub) SetManagementPolicies 

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

SetManagementPolicies of this StreamInputIOTHub.

func (*StreamInputIOTHub) SetObservation 

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

SetObservation for this StreamInputIOTHub

func (*StreamInputIOTHub) SetParameters 

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

SetParameters for this StreamInputIOTHub

func (*StreamInputIOTHub) SetProviderConfigReference 

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

SetProviderConfigReference of this StreamInputIOTHub.

func (*StreamInputIOTHub) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this StreamInputIOTHub.

func (*StreamInputIOTHub) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this StreamInputIOTHub.

type StreamInputIOTHubInitParameters 

type StreamInputIOTHubInitParameters 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.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/eventhub/v1beta1.ConsumerGroup
	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/v1beta2.IOTHub
	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.
	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
	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.
	Serialization *StreamInputIOTHubSerializationInitParameters `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.
	SharedAccessPolicyKeySecretRef v1.SecretKeySelector `json:"sharedAccessPolicyKeySecretRef" tf:"-"`

	// 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.
	// +crossplane:generate:reference:type=github.com/upbound/provider-azure/apis/streamanalytics/v1beta2.Job
	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 (*StreamInputIOTHubInitParameters) DeepCopy 

func (in *StreamInputIOTHubInitParameters) DeepCopy() *StreamInputIOTHubInitParameters

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

func (*StreamInputIOTHubInitParameters) DeepCopyInto 

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

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

type StreamInputIOTHubList 

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 

func (in *StreamInputIOTHubList) DeepCopy() *StreamInputIOTHubList

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

func (*StreamInputIOTHubList) DeepCopyInto 

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 

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

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

func (*StreamInputIOTHubList) GetItems 

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

GetItems of this StreamInputIOTHubList.

type StreamInputIOTHubObservation 

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 

func (in *StreamInputIOTHubObservation) DeepCopy() *StreamInputIOTHubObservation

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

func (*StreamInputIOTHubObservation) DeepCopyInto 

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 

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/v1beta2.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=github.com/upbound/provider-azure/apis/streamanalytics/v1beta2.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 (*StreamInputIOTHubParameters) DeepCopy 

func (in *StreamInputIOTHubParameters) DeepCopy() *StreamInputIOTHubParameters

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

func (*StreamInputIOTHubParameters) DeepCopyInto 

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

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

type StreamInputIOTHubSerializationInitParameters 

type StreamInputIOTHubSerializationInitParameters 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 (*StreamInputIOTHubSerializationInitParameters) DeepCopy 

func (in *StreamInputIOTHubSerializationInitParameters) DeepCopy() *StreamInputIOTHubSerializationInitParameters

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

func (*StreamInputIOTHubSerializationInitParameters) DeepCopyInto 

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

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

type StreamInputIOTHubSerializationObservation 

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 

func (in *StreamInputIOTHubSerializationObservation) DeepCopy() *StreamInputIOTHubSerializationObservation

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

func (*StreamInputIOTHubSerializationObservation) DeepCopyInto 

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 

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:Optional
	Type *string `json:"type" tf:"type,omitempty"`
}

func (*StreamInputIOTHubSerializationParameters) DeepCopy 

func (in *StreamInputIOTHubSerializationParameters) DeepCopy() *StreamInputIOTHubSerializationParameters

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

func (*StreamInputIOTHubSerializationParameters) DeepCopyInto 

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 

type StreamInputIOTHubSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     StreamInputIOTHubParameters `json:"forProvider"`
	// THIS IS A BETA FIELD. It will be honored
	// unless the Management Policies feature flag is disabled.
	// InitProvider holds the same fields as ForProvider, with the exception
	// of Identifier and other resource reference fields. The fields that are
	// in InitProvider are merged into ForProvider when the resource is created.
	// The same fields are also added to the terraform ignore_changes hook, to
	// avoid updating them after creation. This is useful for fields that are
	// required on creation, but we do not desire to update them after creation,
	// for example because of an external controller is managing them, like an
	// autoscaler.
	InitProvider StreamInputIOTHubInitParameters `json:"initProvider,omitempty"`
}

StreamInputIOTHubSpec defines the desired state of StreamInputIOTHub

func (*StreamInputIOTHubSpec) DeepCopy 

func (in *StreamInputIOTHubSpec) DeepCopy() *StreamInputIOTHubSpec

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

func (*StreamInputIOTHubSpec) DeepCopyInto 

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 

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

StreamInputIOTHubStatus defines the observed state of StreamInputIOTHub.

func (*StreamInputIOTHubStatus) DeepCopy 

func (in *StreamInputIOTHubStatus) DeepCopy() *StreamInputIOTHubStatus

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

func (*StreamInputIOTHubStatus) DeepCopyInto 

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.