v1beta1

package
v0.27.0-rc.0 Latest Latest
Warning

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

 Go to latest Published: Jan 24, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Overview

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

Index

Constants

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

Package type metadata.

Variables

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

Repository type metadata.

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

Repository type metadata.

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

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

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

Repository type metadata.

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

Repository type metadata.

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

Repository type metadata.

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

Repository type metadata.

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

Repository type metadata.

Functions

This section is empty.

Types

type Cluster 

type Cluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ClusterSpec   `json:"spec"`
	Status            ClusterStatus `json:"status,omitempty"`
}

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

func (*Cluster) DeepCopy 

func (in *Cluster) DeepCopy() *Cluster

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

func (*Cluster) DeepCopyInto 

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

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

func (*Cluster) DeepCopyObject 

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

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

func (*Cluster) GetCondition 

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

GetCondition of this Cluster.

func (*Cluster) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this Cluster

func (*Cluster) GetDeletionPolicy 

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

GetDeletionPolicy of this Cluster.

func (*Cluster) GetID 

func (tr *Cluster) GetID() string

GetID returns ID of underlying Terraform resource of this Cluster

func (*Cluster) GetObservation 

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

GetObservation of this Cluster

func (*Cluster) GetParameters 

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

GetParameters of this Cluster

func (*Cluster) GetProviderConfigReference 

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

GetProviderConfigReference of this Cluster.

func (*Cluster) GetProviderReference 

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

GetProviderReference of this Cluster. Deprecated: Use GetProviderConfigReference.

func (*Cluster) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this Cluster.

func (*Cluster) GetTerraformResourceType 

func (mg *Cluster) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Cluster

func (*Cluster) GetTerraformSchemaVersion 

func (tr *Cluster) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Cluster) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this Cluster.

func (*Cluster) LateInitialize 

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

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

func (*Cluster) ResolveReferences 

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

ResolveReferences of this Cluster.

func (*Cluster) SetConditions 

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

SetConditions of this Cluster.

func (*Cluster) SetDeletionPolicy 

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

SetDeletionPolicy of this Cluster.

func (*Cluster) SetObservation 

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

SetObservation for this Cluster

func (*Cluster) SetParameters 

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

SetParameters for this Cluster

func (*Cluster) SetProviderConfigReference 

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

SetProviderConfigReference of this Cluster.

func (*Cluster) SetProviderReference 

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

SetProviderReference of this Cluster. Deprecated: Use SetProviderConfigReference.

func (*Cluster) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this Cluster.

func (*Cluster) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this Cluster.

type ClusterList 

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

ClusterList contains a list of Clusters

func (*ClusterList) DeepCopy 

func (in *ClusterList) DeepCopy() *ClusterList

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

func (*ClusterList) DeepCopyInto 

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

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

func (*ClusterList) DeepCopyObject 

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

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

func (*ClusterList) GetItems 

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

GetItems of this ClusterList.

type ClusterObservation 

type ClusterObservation struct {

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

func (*ClusterObservation) DeepCopy 

func (in *ClusterObservation) DeepCopy() *ClusterObservation

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

func (*ClusterObservation) DeepCopyInto 

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

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

type ClusterParameters 

type ClusterParameters struct {

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

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

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

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

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

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

func (*ClusterParameters) DeepCopy 

func (in *ClusterParameters) DeepCopy() *ClusterParameters

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

func (*ClusterParameters) DeepCopyInto 

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

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

type ClusterSpec 

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

ClusterSpec defines the desired state of Cluster

func (*ClusterSpec) DeepCopy 

func (in *ClusterSpec) DeepCopy() *ClusterSpec

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

func (*ClusterSpec) DeepCopyInto 

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

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

type ClusterStatus 

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

ClusterStatus defines the observed state of Cluster.

func (*ClusterStatus) DeepCopy 

func (in *ClusterStatus) DeepCopy() *ClusterStatus

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

func (*ClusterStatus) DeepCopyInto 

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

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

type FunctionJavascriptUda 

type FunctionJavascriptUda struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              FunctionJavascriptUdaSpec   `json:"spec"`
	Status            FunctionJavascriptUdaStatus `json:"status,omitempty"`
}

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

func (*FunctionJavascriptUda) DeepCopy 

func (in *FunctionJavascriptUda) DeepCopy() *FunctionJavascriptUda

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

func (*FunctionJavascriptUda) DeepCopyInto 

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

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

func (*FunctionJavascriptUda) DeepCopyObject 

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

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

func (*FunctionJavascriptUda) GetCondition 

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

GetCondition of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this FunctionJavascriptUda

func (*FunctionJavascriptUda) GetDeletionPolicy 

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

GetDeletionPolicy of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) GetID 

func (tr *FunctionJavascriptUda) GetID() string

GetID returns ID of underlying Terraform resource of this FunctionJavascriptUda

func (*FunctionJavascriptUda) GetObservation 

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

GetObservation of this FunctionJavascriptUda

func (*FunctionJavascriptUda) GetParameters 

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

GetParameters of this FunctionJavascriptUda

func (*FunctionJavascriptUda) GetProviderConfigReference 

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

GetProviderConfigReference of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) GetProviderReference 

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

GetProviderReference of this FunctionJavascriptUda. Deprecated: Use GetProviderConfigReference.

func (*FunctionJavascriptUda) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) GetTerraformResourceType 

func (mg *FunctionJavascriptUda) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this FunctionJavascriptUda

func (*FunctionJavascriptUda) GetTerraformSchemaVersion 

func (tr *FunctionJavascriptUda) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*FunctionJavascriptUda) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) LateInitialize 

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

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

func (*FunctionJavascriptUda) ResolveReferences added in v0.26.0 

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

ResolveReferences of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) SetConditions 

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

SetConditions of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) SetDeletionPolicy 

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

SetDeletionPolicy of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) SetObservation 

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

SetObservation for this FunctionJavascriptUda

func (*FunctionJavascriptUda) SetParameters 

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

SetParameters for this FunctionJavascriptUda

func (*FunctionJavascriptUda) SetProviderConfigReference 

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

SetProviderConfigReference of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) SetProviderReference 

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

SetProviderReference of this FunctionJavascriptUda. Deprecated: Use SetProviderConfigReference.

func (*FunctionJavascriptUda) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this FunctionJavascriptUda.

func (*FunctionJavascriptUda) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this FunctionJavascriptUda.

type FunctionJavascriptUdaList 

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

FunctionJavascriptUdaList contains a list of FunctionJavascriptUdas

func (*FunctionJavascriptUdaList) DeepCopy 

func (in *FunctionJavascriptUdaList) DeepCopy() *FunctionJavascriptUdaList

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

func (*FunctionJavascriptUdaList) DeepCopyInto 

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

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

func (*FunctionJavascriptUdaList) DeepCopyObject 

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

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

func (*FunctionJavascriptUdaList) GetItems 

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

GetItems of this FunctionJavascriptUdaList.

type FunctionJavascriptUdaObservation 

type FunctionJavascriptUdaObservation struct {

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

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:Required
	Input []InputParameters `json:"input" tf:"input,omitempty"`

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

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

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

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

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

func (*FunctionJavascriptUdaParameters) DeepCopy 

func (in *FunctionJavascriptUdaParameters) DeepCopy() *FunctionJavascriptUdaParameters

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

func (*FunctionJavascriptUdaParameters) DeepCopyInto 

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

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

type FunctionJavascriptUdaSpec 

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

FunctionJavascriptUdaSpec defines the desired state of FunctionJavascriptUda

func (*FunctionJavascriptUdaSpec) DeepCopy 

func (in *FunctionJavascriptUdaSpec) DeepCopy() *FunctionJavascriptUdaSpec

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

func (*FunctionJavascriptUdaSpec) DeepCopyInto 

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

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

type FunctionJavascriptUdaStatus 

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

FunctionJavascriptUdaStatus defines the observed state of FunctionJavascriptUda.

func (*FunctionJavascriptUdaStatus) DeepCopy 

func (in *FunctionJavascriptUdaStatus) DeepCopy() *FunctionJavascriptUdaStatus

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

func (*FunctionJavascriptUdaStatus) DeepCopyInto 

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

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

type IdentityObservation 

type IdentityObservation struct {

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

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

func (*IdentityObservation) DeepCopy 

func (in *IdentityObservation) DeepCopy() *IdentityObservation

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

func (*IdentityObservation) DeepCopyInto 

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

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

type IdentityParameters 

type IdentityParameters struct {

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

func (*IdentityParameters) DeepCopy 

func (in *IdentityParameters) DeepCopy() *IdentityParameters

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

func (*IdentityParameters) DeepCopyInto 

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

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

type InputObservation 

type InputObservation struct {
}

func (*InputObservation) DeepCopy 

func (in *InputObservation) DeepCopy() *InputObservation

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

func (*InputObservation) DeepCopyInto 

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

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

type InputParameters 

type InputParameters struct {

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

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

func (*InputParameters) DeepCopy 

func (in *InputParameters) DeepCopy() *InputParameters

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

func (*InputParameters) DeepCopyInto 

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

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

type Job 

type Job struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              JobSpec   `json:"spec"`
	Status            JobStatus `json:"status,omitempty"`
}

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

func (*Job) DeepCopy 

func (in *Job) DeepCopy() *Job

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

func (*Job) DeepCopyInto 

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

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

func (*Job) DeepCopyObject 

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

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

func (*Job) GetCondition 

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

GetCondition of this Job.

func (*Job) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this Job

func (*Job) GetDeletionPolicy 

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

GetDeletionPolicy of this Job.

func (*Job) GetID 

func (tr *Job) GetID() string

GetID returns ID of underlying Terraform resource of this Job

func (*Job) GetObservation 

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

GetObservation of this Job

func (*Job) GetParameters 

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

GetParameters of this Job

func (*Job) GetProviderConfigReference 

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

GetProviderConfigReference of this Job.

func (*Job) GetProviderReference 

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

GetProviderReference of this Job. Deprecated: Use GetProviderConfigReference.

func (*Job) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this Job.

func (*Job) GetTerraformResourceType 

func (mg *Job) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Job

func (*Job) GetTerraformSchemaVersion 

func (tr *Job) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Job) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this Job.

func (*Job) LateInitialize 

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

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

func (*Job) ResolveReferences 

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

ResolveReferences of this Job.

func (*Job) SetConditions 

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

SetConditions of this Job.

func (*Job) SetDeletionPolicy 

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

SetDeletionPolicy of this Job.

func (*Job) SetObservation 

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

SetObservation for this Job

func (*Job) SetParameters 

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

SetParameters for this Job

func (*Job) SetProviderConfigReference 

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

SetProviderConfigReference of this Job.

func (*Job) SetProviderReference 

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

SetProviderReference of this Job. Deprecated: Use SetProviderConfigReference.

func (*Job) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this Job.

func (*Job) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this Job.

type JobList 

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

JobList contains a list of Jobs

func (*JobList) DeepCopy 

func (in *JobList) DeepCopy() *JobList

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

func (*JobList) DeepCopyInto 

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

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

func (*JobList) DeepCopyObject 

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

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

func (*JobList) GetItems 

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

GetItems of this JobList.

type JobObservation 

type JobObservation struct {

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

	// An identity block as defined below.
	// +kubebuilder:validation:Optional
	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"`
}

func (*JobObservation) DeepCopy 

func (in *JobObservation) DeepCopy() *JobObservation

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

func (*JobObservation) DeepCopyInto 

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

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

type JobParameters 

type JobParameters struct {

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

func (*JobParameters) DeepCopy 

func (in *JobParameters) DeepCopy() *JobParameters

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

func (*JobParameters) DeepCopyInto 

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

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

type JobSpec 

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

JobSpec defines the desired state of Job

func (*JobSpec) DeepCopy 

func (in *JobSpec) DeepCopy() *JobSpec

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

func (*JobSpec) DeepCopyInto 

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

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

type JobStatus 

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

JobStatus defines the observed state of Job.

func (*JobStatus) DeepCopy 

func (in *JobStatus) DeepCopy() *JobStatus

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

func (*JobStatus) DeepCopyInto 

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

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

type JobStorageAccountObservation added in v0.26.0 

type JobStorageAccountObservation struct {
}

func (*JobStorageAccountObservation) DeepCopy added in v0.26.0 

func (in *JobStorageAccountObservation) DeepCopy() *JobStorageAccountObservation

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

func (*JobStorageAccountObservation) DeepCopyInto added in v0.26.0 

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

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

type JobStorageAccountParameters added in v0.26.0 

type JobStorageAccountParameters struct {

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

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

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

func (*JobStorageAccountParameters) DeepCopy added in v0.26.0 

func (in *JobStorageAccountParameters) DeepCopy() *JobStorageAccountParameters

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

func (*JobStorageAccountParameters) DeepCopyInto added in v0.26.0 

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

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

type ManagedPrivateEndpoint 

type ManagedPrivateEndpoint struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ManagedPrivateEndpointSpec   `json:"spec"`
	Status            ManagedPrivateEndpointStatus `json:"status,omitempty"`
}

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

func (*ManagedPrivateEndpoint) DeepCopy 

func (in *ManagedPrivateEndpoint) DeepCopy() *ManagedPrivateEndpoint

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

func (*ManagedPrivateEndpoint) DeepCopyInto 

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

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

func (*ManagedPrivateEndpoint) DeepCopyObject 

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

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

func (*ManagedPrivateEndpoint) GetCondition 

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

GetCondition of this ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this ManagedPrivateEndpoint

func (*ManagedPrivateEndpoint) GetDeletionPolicy 

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

GetDeletionPolicy of this ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) GetID 

func (tr *ManagedPrivateEndpoint) GetID() string

GetID returns ID of underlying Terraform resource of this ManagedPrivateEndpoint

func (*ManagedPrivateEndpoint) GetObservation 

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

GetObservation of this ManagedPrivateEndpoint

func (*ManagedPrivateEndpoint) GetParameters 

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

GetParameters of this ManagedPrivateEndpoint

func (*ManagedPrivateEndpoint) GetProviderConfigReference 

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

GetProviderConfigReference of this ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) GetProviderReference 

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

GetProviderReference of this ManagedPrivateEndpoint. Deprecated: Use GetProviderConfigReference.

func (*ManagedPrivateEndpoint) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) GetTerraformResourceType 

func (mg *ManagedPrivateEndpoint) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this ManagedPrivateEndpoint

func (*ManagedPrivateEndpoint) GetTerraformSchemaVersion 

func (tr *ManagedPrivateEndpoint) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*ManagedPrivateEndpoint) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) LateInitialize 

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

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

func (*ManagedPrivateEndpoint) ResolveReferences 

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

ResolveReferences of this ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) SetConditions 

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

SetConditions of this ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) SetDeletionPolicy 

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

SetDeletionPolicy of this ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) SetObservation 

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

SetObservation for this ManagedPrivateEndpoint

func (*ManagedPrivateEndpoint) SetParameters 

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

SetParameters for this ManagedPrivateEndpoint

func (*ManagedPrivateEndpoint) SetProviderConfigReference 

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

SetProviderConfigReference of this ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) SetProviderReference 

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

SetProviderReference of this ManagedPrivateEndpoint. Deprecated: Use SetProviderConfigReference.

func (*ManagedPrivateEndpoint) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this ManagedPrivateEndpoint.

type ManagedPrivateEndpointList 

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

ManagedPrivateEndpointList contains a list of ManagedPrivateEndpoints

func (*ManagedPrivateEndpointList) DeepCopy 

func (in *ManagedPrivateEndpointList) DeepCopy() *ManagedPrivateEndpointList

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

func (*ManagedPrivateEndpointList) DeepCopyInto 

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

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

func (*ManagedPrivateEndpointList) DeepCopyObject 

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

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

func (*ManagedPrivateEndpointList) GetItems 

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

GetItems of this ManagedPrivateEndpointList.

type ManagedPrivateEndpointObservation 

type ManagedPrivateEndpointObservation struct {

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

func (*ManagedPrivateEndpointObservation) DeepCopy 

func (in *ManagedPrivateEndpointObservation) DeepCopy() *ManagedPrivateEndpointObservation

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

func (*ManagedPrivateEndpointObservation) DeepCopyInto 

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

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

type ManagedPrivateEndpointParameters 

type ManagedPrivateEndpointParameters struct {

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

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

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

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

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

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

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

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

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

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

func (*ManagedPrivateEndpointParameters) DeepCopy 

func (in *ManagedPrivateEndpointParameters) DeepCopy() *ManagedPrivateEndpointParameters

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

func (*ManagedPrivateEndpointParameters) DeepCopyInto 

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

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

type ManagedPrivateEndpointSpec 

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

ManagedPrivateEndpointSpec defines the desired state of ManagedPrivateEndpoint

func (*ManagedPrivateEndpointSpec) DeepCopy 

func (in *ManagedPrivateEndpointSpec) DeepCopy() *ManagedPrivateEndpointSpec

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

func (*ManagedPrivateEndpointSpec) DeepCopyInto 

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

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

type ManagedPrivateEndpointStatus 

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

ManagedPrivateEndpointStatus defines the observed state of ManagedPrivateEndpoint.

func (*ManagedPrivateEndpointStatus) DeepCopy 

func (in *ManagedPrivateEndpointStatus) DeepCopy() *ManagedPrivateEndpointStatus

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

func (*ManagedPrivateEndpointStatus) DeepCopyInto 

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

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

type OutputBlob 

type OutputBlob struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              OutputBlobSpec   `json:"spec"`
	Status            OutputBlobStatus `json:"status,omitempty"`
}

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

func (*OutputBlob) DeepCopy 

func (in *OutputBlob) DeepCopy() *OutputBlob

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

func (*OutputBlob) DeepCopyInto 

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

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

func (*OutputBlob) DeepCopyObject 

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

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

func (*OutputBlob) GetCondition 

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

GetCondition of this OutputBlob.

func (*OutputBlob) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this OutputBlob

func (*OutputBlob) GetDeletionPolicy 

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

GetDeletionPolicy of this OutputBlob.

func (*OutputBlob) GetID 

func (tr *OutputBlob) GetID() string

GetID returns ID of underlying Terraform resource of this OutputBlob

func (*OutputBlob) GetObservation 

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

GetObservation of this OutputBlob

func (*OutputBlob) GetParameters 

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

GetParameters of this OutputBlob

func (*OutputBlob) GetProviderConfigReference 

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

GetProviderConfigReference of this OutputBlob.

func (*OutputBlob) GetProviderReference 

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

GetProviderReference of this OutputBlob. Deprecated: Use GetProviderConfigReference.

func (*OutputBlob) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this OutputBlob.

func (*OutputBlob) GetTerraformResourceType 

func (mg *OutputBlob) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this OutputBlob

func (*OutputBlob) GetTerraformSchemaVersion 

func (tr *OutputBlob) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*OutputBlob) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this OutputBlob.

func (*OutputBlob) LateInitialize 

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

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

func (*OutputBlob) ResolveReferences 

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

ResolveReferences of this OutputBlob.

func (*OutputBlob) SetConditions 

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

SetConditions of this OutputBlob.

func (*OutputBlob) SetDeletionPolicy 

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

SetDeletionPolicy of this OutputBlob.

func (*OutputBlob) SetObservation 

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

SetObservation for this OutputBlob

func (*OutputBlob) SetParameters 

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

SetParameters for this OutputBlob

func (*OutputBlob) SetProviderConfigReference 

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

SetProviderConfigReference of this OutputBlob.

func (*OutputBlob) SetProviderReference 

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

SetProviderReference of this OutputBlob. Deprecated: Use SetProviderConfigReference.

func (*OutputBlob) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this OutputBlob.

func (*OutputBlob) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this OutputBlob.

type OutputBlobList 

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

OutputBlobList contains a list of OutputBlobs

func (*OutputBlobList) DeepCopy 

func (in *OutputBlobList) DeepCopy() *OutputBlobList

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

func (*OutputBlobList) DeepCopyInto 

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

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

func (*OutputBlobList) DeepCopyObject 

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

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

func (*OutputBlobList) GetItems 

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

GetItems of this OutputBlobList.

type OutputBlobObservation 

type OutputBlobObservation struct {

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

func (*OutputBlobObservation) DeepCopy 

func (in *OutputBlobObservation) DeepCopy() *OutputBlobObservation

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

func (*OutputBlobObservation) DeepCopyInto 

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

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

type OutputBlobParameters 

type OutputBlobParameters struct {

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

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

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

	// The date format. Wherever {date} appears in path_pattern, the value of this property is used as the date format instead.
	// +kubebuilder:validation:Required
	DateFormat *string `json:"dateFormat" 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:Required
	PathPattern *string `json:"pathPattern" 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:Required
	Serialization []SerializationParameters `json:"serialization" tf:"serialization,omitempty"`

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

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

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

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

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

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

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

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

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

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

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

func (*OutputBlobParameters) DeepCopy 

func (in *OutputBlobParameters) DeepCopy() *OutputBlobParameters

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

func (*OutputBlobParameters) DeepCopyInto 

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

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

type OutputBlobSpec 

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

OutputBlobSpec defines the desired state of OutputBlob

func (*OutputBlobSpec) DeepCopy 

func (in *OutputBlobSpec) DeepCopy() *OutputBlobSpec

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

func (*OutputBlobSpec) DeepCopyInto 

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

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

type OutputBlobStatus 

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

OutputBlobStatus defines the observed state of OutputBlob.

func (*OutputBlobStatus) DeepCopy 

func (in *OutputBlobStatus) DeepCopy() *OutputBlobStatus

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

func (*OutputBlobStatus) DeepCopyInto 

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

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

type OutputFunction 

type OutputFunction struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              OutputFunctionSpec   `json:"spec"`
	Status            OutputFunctionStatus `json:"status,omitempty"`
}

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

func (*OutputFunction) DeepCopy 

func (in *OutputFunction) DeepCopy() *OutputFunction

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

func (*OutputFunction) DeepCopyInto 

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

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

func (*OutputFunction) DeepCopyObject 

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

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

func (*OutputFunction) GetCondition 

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

GetCondition of this OutputFunction.

func (*OutputFunction) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this OutputFunction

func (*OutputFunction) GetDeletionPolicy 

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

GetDeletionPolicy of this OutputFunction.

func (*OutputFunction) GetID 

func (tr *OutputFunction) GetID() string

GetID returns ID of underlying Terraform resource of this OutputFunction

func (*OutputFunction) GetObservation 

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

GetObservation of this OutputFunction

func (*OutputFunction) GetParameters 

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

GetParameters of this OutputFunction

func (*OutputFunction) GetProviderConfigReference 

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

GetProviderConfigReference of this OutputFunction.

func (*OutputFunction) GetProviderReference 

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

GetProviderReference of this OutputFunction. Deprecated: Use GetProviderConfigReference.

func (*OutputFunction) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this OutputFunction.

func (*OutputFunction) GetTerraformResourceType 

func (mg *OutputFunction) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this OutputFunction

func (*OutputFunction) GetTerraformSchemaVersion 

func (tr *OutputFunction) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*OutputFunction) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this OutputFunction.

func (*OutputFunction) LateInitialize 

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

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

func (*OutputFunction) ResolveReferences 

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

ResolveReferences of this OutputFunction.

func (*OutputFunction) SetConditions 

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

SetConditions of this OutputFunction.

func (*OutputFunction) SetDeletionPolicy 

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

SetDeletionPolicy of this OutputFunction.

func (*OutputFunction) SetObservation 

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

SetObservation for this OutputFunction

func (*OutputFunction) SetParameters 

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

SetParameters for this OutputFunction

func (*OutputFunction) SetProviderConfigReference 

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

SetProviderConfigReference of this OutputFunction.

func (*OutputFunction) SetProviderReference 

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

SetProviderReference of this OutputFunction. Deprecated: Use SetProviderConfigReference.

func (*OutputFunction) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this OutputFunction.

func (*OutputFunction) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this OutputFunction.

type OutputFunctionList 

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

OutputFunctionList contains a list of OutputFunctions

func (*OutputFunctionList) DeepCopy 

func (in *OutputFunctionList) DeepCopy() *OutputFunctionList

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

func (*OutputFunctionList) DeepCopyInto 

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

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

func (*OutputFunctionList) DeepCopyObject 

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

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

func (*OutputFunctionList) GetItems 

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

GetItems of this OutputFunctionList.

type OutputFunctionObservation 

type OutputFunctionObservation struct {

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

func (*OutputFunctionObservation) DeepCopy 

func (in *OutputFunctionObservation) DeepCopy() *OutputFunctionObservation

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

func (*OutputFunctionObservation) DeepCopyInto 

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

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

type OutputFunctionParameters 

type OutputFunctionParameters struct {

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

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

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

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

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

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

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

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

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

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

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

func (*OutputFunctionParameters) DeepCopy 

func (in *OutputFunctionParameters) DeepCopy() *OutputFunctionParameters

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

func (*OutputFunctionParameters) DeepCopyInto 

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

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

type OutputFunctionSpec 

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

OutputFunctionSpec defines the desired state of OutputFunction

func (*OutputFunctionSpec) DeepCopy 

func (in *OutputFunctionSpec) DeepCopy() *OutputFunctionSpec

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

func (*OutputFunctionSpec) DeepCopyInto 

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

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

type OutputFunctionStatus 

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

OutputFunctionStatus defines the observed state of OutputFunction.

func (*OutputFunctionStatus) DeepCopy 

func (in *OutputFunctionStatus) DeepCopy() *OutputFunctionStatus

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

func (*OutputFunctionStatus) DeepCopyInto 

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

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

type OutputObservation 

type OutputObservation struct {
}

func (*OutputObservation) DeepCopy 

func (in *OutputObservation) DeepCopy() *OutputObservation

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

func (*OutputObservation) DeepCopyInto 

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

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

type OutputParameters 

type OutputParameters struct {

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

func (*OutputParameters) DeepCopy 

func (in *OutputParameters) DeepCopy() *OutputParameters

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

func (*OutputParameters) DeepCopyInto 

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

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

type OutputSynapse 

type OutputSynapse struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              OutputSynapseSpec   `json:"spec"`
	Status            OutputSynapseStatus `json:"status,omitempty"`
}

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

func (*OutputSynapse) DeepCopy 

func (in *OutputSynapse) DeepCopy() *OutputSynapse

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

func (*OutputSynapse) DeepCopyInto 

func (in *OutputSynapse) DeepCopyInto(out *OutputSynapse)

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

func (*OutputSynapse) DeepCopyObject 

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

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

func (*OutputSynapse) GetCondition 

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

GetCondition of this OutputSynapse.

func (*OutputSynapse) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this OutputSynapse

func (*OutputSynapse) GetDeletionPolicy 

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

GetDeletionPolicy of this OutputSynapse.

func (*OutputSynapse) GetID 

func (tr *OutputSynapse) GetID() string

GetID returns ID of underlying Terraform resource of this OutputSynapse

func (*OutputSynapse) GetObservation 

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

GetObservation of this OutputSynapse

func (*OutputSynapse) GetParameters 

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

GetParameters of this OutputSynapse

func (*OutputSynapse) GetProviderConfigReference 

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

GetProviderConfigReference of this OutputSynapse.

func (*OutputSynapse) GetProviderReference 

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

GetProviderReference of this OutputSynapse. Deprecated: Use GetProviderConfigReference.

func (*OutputSynapse) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this OutputSynapse.

func (*OutputSynapse) GetTerraformResourceType 

func (mg *OutputSynapse) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this OutputSynapse

func (*OutputSynapse) GetTerraformSchemaVersion 

func (tr *OutputSynapse) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*OutputSynapse) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this OutputSynapse.

func (*OutputSynapse) LateInitialize 

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

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

func (*OutputSynapse) ResolveReferences 

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

ResolveReferences of this OutputSynapse.

func (*OutputSynapse) SetConditions 

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

SetConditions of this OutputSynapse.

func (*OutputSynapse) SetDeletionPolicy 

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

SetDeletionPolicy of this OutputSynapse.

func (*OutputSynapse) SetObservation 

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

SetObservation for this OutputSynapse

func (*OutputSynapse) SetParameters 

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

SetParameters for this OutputSynapse

func (*OutputSynapse) SetProviderConfigReference 

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

SetProviderConfigReference of this OutputSynapse.

func (*OutputSynapse) SetProviderReference 

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

SetProviderReference of this OutputSynapse. Deprecated: Use SetProviderConfigReference.

func (*OutputSynapse) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this OutputSynapse.

func (*OutputSynapse) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this OutputSynapse.

type OutputSynapseList 

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

OutputSynapseList contains a list of OutputSynapses

func (*OutputSynapseList) DeepCopy 

func (in *OutputSynapseList) DeepCopy() *OutputSynapseList

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

func (*OutputSynapseList) DeepCopyInto 

func (in *OutputSynapseList) DeepCopyInto(out *OutputSynapseList)

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

func (*OutputSynapseList) DeepCopyObject 

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

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

func (*OutputSynapseList) GetItems 

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

GetItems of this OutputSynapseList.

type OutputSynapseObservation 

type OutputSynapseObservation struct {

	// The ID of the Stream Analytics Output to an Azure Synapse Analytics Workspace.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`
}

func (*OutputSynapseObservation) DeepCopy 

func (in *OutputSynapseObservation) DeepCopy() *OutputSynapseObservation

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

func (*OutputSynapseObservation) DeepCopyInto 

func (in *OutputSynapseObservation) DeepCopyInto(out *OutputSynapseObservation)

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

type OutputSynapseParameters 

type OutputSynapseParameters struct {

	// The name of the Azure SQL database. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Required
	Database *string `json:"database" tf:"database,omitempty"`

	// The password that will be used to connect to the Azure SQL database.
	// +kubebuilder:validation:Required
	PasswordSecretRef v1.SecretKeySelector `json:"passwordSecretRef" tf:"-"`

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

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

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

	// The name of the SQL server containing the Azure SQL database. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Required
	Server *string `json:"server" tf:"server,omitempty"`

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

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

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

	// The name of the table in the Azure SQL database. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Required
	Table *string `json:"table" tf:"table,omitempty"`

	// The user name that will be used to connect to the Azure SQL database. Changing this forces a new resource to be created.
	// +kubebuilder:validation:Required
	User *string `json:"user" tf:"user,omitempty"`
}

func (*OutputSynapseParameters) DeepCopy 

func (in *OutputSynapseParameters) DeepCopy() *OutputSynapseParameters

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

func (*OutputSynapseParameters) DeepCopyInto 

func (in *OutputSynapseParameters) DeepCopyInto(out *OutputSynapseParameters)

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

type OutputSynapseSpec 

type OutputSynapseSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     OutputSynapseParameters `json:"forProvider"`
}

OutputSynapseSpec defines the desired state of OutputSynapse

func (*OutputSynapseSpec) DeepCopy 

func (in *OutputSynapseSpec) DeepCopy() *OutputSynapseSpec

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

func (*OutputSynapseSpec) DeepCopyInto 

func (in *OutputSynapseSpec) DeepCopyInto(out *OutputSynapseSpec)

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

type OutputSynapseStatus 

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

OutputSynapseStatus defines the observed state of OutputSynapse.

func (*OutputSynapseStatus) DeepCopy 

func (in *OutputSynapseStatus) DeepCopy() *OutputSynapseStatus

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

func (*OutputSynapseStatus) DeepCopyInto 

func (in *OutputSynapseStatus) DeepCopyInto(out *OutputSynapseStatus)

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

type SerializationObservation 

type SerializationObservation struct {
}

func (*SerializationObservation) DeepCopy 

func (in *SerializationObservation) DeepCopy() *SerializationObservation

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

func (*SerializationObservation) DeepCopyInto 

func (in *SerializationObservation) DeepCopyInto(out *SerializationObservation)

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

type SerializationParameters 

type SerializationParameters struct {

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

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

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

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

func (*SerializationParameters) DeepCopy 

func (in *SerializationParameters) DeepCopy() *SerializationParameters

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

func (*SerializationParameters) DeepCopyInto 

func (in *SerializationParameters) DeepCopyInto(out *SerializationParameters)

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

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.