v1alpha1

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: May 27, 2022 License: MIT Imports: 4 Imported by: 0

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the kusto v1alpha1 API group +kubebuilder:object:generate=true +groupName=dbschema.microsoft.com

Index

Constants

View Source 
const (
	// DBTypeSQLServer SQL Server enum entry
	DBTypeSQLServer DBTypeEnum = "sqlServer"
	// DBTypeKusto Kusto enum entry
	DBTypeKusto DBTypeEnum = "kusto"
	// DBTypeEventhub eventhub schema registry enum entry
	DBTypeEventhub DBTypeEnum = "eventhub"
	// ConditionExecution execution condition status
	ConditionExecution string = "Execution"
)

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "dbschema.microsoft.com", Version: "v1alpha1"}

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

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

This section is empty.

Types

type ClusterExecuter 

type ClusterExecuter struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   ClusterExecuterSpec   `json:"spec,omitempty"`
	Status ClusterExecuterStatus `json:"status,omitempty"`
}

+kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:printcolumn:name="TYPE",type="string",JSONPath=".spec.type" +kubebuilder:printcolumn:name="Executed",type="string",JSONPath=".status.conditions[?(@.type=='Execution')].status" +kubebuilder:printcolumn:name="CompletedPCT",type="string",JSONPath=".status.completedPct" ClusterExecuter is the Schema for the clusterexecuters API

func (*ClusterExecuter) DeepCopy 

func (in *ClusterExecuter) DeepCopy() *ClusterExecuter

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

func (*ClusterExecuter) DeepCopyInto 

func (in *ClusterExecuter) DeepCopyInto(out *ClusterExecuter)

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

func (*ClusterExecuter) DeepCopyObject 

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

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

func (*ClusterExecuter) IsExecuted 

func (t *ClusterExecuter) IsExecuted() bool

IsExecuted checks if the cluster executer already executed.

type ClusterExecuterList 

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

ClusterExecuterList contains a list of ClusterExecuter

func (*ClusterExecuterList) DeepCopy 

func (in *ClusterExecuterList) DeepCopy() *ClusterExecuterList

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

func (*ClusterExecuterList) DeepCopyInto 

func (in *ClusterExecuterList) DeepCopyInto(out *ClusterExecuterList)

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

func (*ClusterExecuterList) DeepCopyObject 

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

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

type ClusterExecuterSpec 

type ClusterExecuterSpec struct {
	ClusterUri     string         `json:"clusterUri,omitempty"`
	ApplyTo        TargetFilter   `json:"applyTo"`
	Type           DBTypeEnum     `json:"type"`
	ConfigMapName  NamespacedName `json:"configMapName"`
	FailIfDataLoss bool           `json:"failIfDataLoss"`
	Revision       int32          `json:"revision"`
}

ClusterExecuterSpec defines the desired state of ClusterExecuter

func (*ClusterExecuterSpec) DeepCopy 

func (in *ClusterExecuterSpec) DeepCopy() *ClusterExecuterSpec

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

func (*ClusterExecuterSpec) DeepCopyInto 

func (in *ClusterExecuterSpec) DeepCopyInto(out *ClusterExecuterSpec)

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

type ClusterExecuterStatus 

type ClusterExecuterStatus struct {
	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
	// Important: Run "make" to regenerate code after modifying this file
	Executed     bool                   `json:"executed"`
	Running      bool                   `json:"running"`
	Failed       bool                   `json:"failed"`
	Targets      ClusterTargets         `json:"targets"`
	DoneTargets  ClusterTargets         `json:"done"`
	Config       ExecutionConfiguration `json:"config,omitempty"`
	NumFailures  int                    `json:"numFailures,omitempty"`
	CompletedPCT int                    `json:"completedPct,omitempty"`
	// Conditions is an array of conditions.
	// Known .status.conditions.type are: "Execution"
	//+patchMergeKey=type
	//+patchStrategy=merge
	//+listType=map
	//+listMapKey=type
	Conditions []metav1.Condition `json:"conditions,omitempty"`
}

ClusterExecuterStatus defines the observed state of ClusterExecuter

func (*ClusterExecuterStatus) DeepCopy 

func (in *ClusterExecuterStatus) DeepCopy() *ClusterExecuterStatus

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

func (*ClusterExecuterStatus) DeepCopyInto 

func (in *ClusterExecuterStatus) DeepCopyInto(out *ClusterExecuterStatus)

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

type ClusterTargets 

type ClusterTargets struct {
	DBs     []string `json:"dbs,omitempty"`
	Schemas []string `json:"schemas,omitempty"`
}

ClusterTargets contains DB and Schema arrays to run the change on.

func (*ClusterTargets) DeepCopy 

func (in *ClusterTargets) DeepCopy() *ClusterTargets

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

func (*ClusterTargets) DeepCopyInto 

func (in *ClusterTargets) DeepCopyInto(out *ClusterTargets)

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

type DBTypeEnum 

type DBTypeEnum string

DBTypeEnum Enum for the supported DB types

type ExecutionConfiguration 

type ExecutionConfiguration struct {
	KQLFile      string            `json:"kqlfile,omitempty"`
	JobFile      string            `json:"jobfile,omitempty"`
	DacPac       string            `json:"dacpac,omitempty"`
	TemplateName string            `json:"templatename,omitempty"`
	Schema       string            `json:"schema,omitempty"`
	Group        string            `json:"group,omitempty"`
	Properties   map[string]string `json:"properties,omitempty"`
}

ExecutionConfiguration contains the required configuration for execution

func (*ExecutionConfiguration) DeepCopy 

func (in *ExecutionConfiguration) DeepCopy() *ExecutionConfiguration

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

func (*ExecutionConfiguration) DeepCopyInto 

func (in *ExecutionConfiguration) DeepCopyInto(out *ExecutionConfiguration)

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

type FailurePolicyEnum 

type FailurePolicyEnum string

FailurePolicyEnum Enum for the different failure policies +kubebuilder:validation:Enum=abort;ignore;rollback 

const (
	// FailurePolicyAbort abort policy stops the execution in failed state
	FailurePolicyAbort FailurePolicyEnum = "abort"
	// FailurePolicyIgnore ignore policy ignores the errors and finish the execution successfully.
	FailurePolicyIgnore FailurePolicyEnum = "ignore"
	// FailurePolicyRollback rollback policy rolls back the configuration to a previous one.
	FailurePolicyRollback FailurePolicyEnum = "rollback"
)

type NamespacedName 

type NamespacedName struct {
	Namespace string `json:"namespace"`
	Name      string `json:"name"`
}

NamespacedName is an object identifier

func (*NamespacedName) DeepCopy 

func (in *NamespacedName) DeepCopy() *NamespacedName

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

func (*NamespacedName) DeepCopyInto 

func (in *NamespacedName) DeepCopyInto(out *NamespacedName)

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

type SchemaDeployment 

type SchemaDeployment struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   SchemaDeploymentSpec   `json:"spec,omitempty"`
	Status SchemaDeploymentStatus `json:"status,omitempty"`
}

+kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:printcolumn:name="TYPE",type="string",JSONPath=".spec.type" +kubebuilder:printcolumn:name="Executed",type="string",JSONPath=".status.conditions[?(@.type=='Execution')].status" SchemaDeployment is the Schema for the templates API

func (*SchemaDeployment) DeepCopy 

func (in *SchemaDeployment) DeepCopy() *SchemaDeployment

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

func (*SchemaDeployment) DeepCopyInto 

func (in *SchemaDeployment) DeepCopyInto(out *SchemaDeployment)

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

func (*SchemaDeployment) DeepCopyObject 

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

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

func (*SchemaDeployment) IsExecuted 

func (t *SchemaDeployment) IsExecuted() bool

IsExecuted checks if the schema deployment object was executed.

type SchemaDeploymentList 

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

SchemaDeploymentList contains a list of SchemaDeployment

func (*SchemaDeploymentList) DeepCopy 

func (in *SchemaDeploymentList) DeepCopy() *SchemaDeploymentList

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

func (*SchemaDeploymentList) DeepCopyInto 

func (in *SchemaDeploymentList) DeepCopyInto(out *SchemaDeploymentList)

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

func (*SchemaDeploymentList) DeepCopyObject 

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

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

type SchemaDeploymentSpec 

type SchemaDeploymentSpec struct {
	ApplyTo TargetFilter   `json:"applyTo"`
	Type    DBTypeEnum     `json:"type"`
	Source  NamespacedName `json:"source,omitempty"`
	// +kubebuilder:validation:Optional
	// +kubebuilder:default:=rollback
	FailurePolicy FailurePolicyEnum `json:"failurePolicy"`
	// +kubebuilder:default:=true
	FailIfDataLoss bool `json:"failIfDataLoss"`
}

SchemaDeploymentSpec defines the desired state of SchemaDeployment

func (*SchemaDeploymentSpec) DeepCopy 

func (in *SchemaDeploymentSpec) DeepCopy() *SchemaDeploymentSpec

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

func (*SchemaDeploymentSpec) DeepCopyInto 

func (in *SchemaDeploymentSpec) DeepCopyInto(out *SchemaDeploymentSpec)

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

type SchemaDeploymentStatus 

type SchemaDeploymentStatus struct {
	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
	// Important: Run "make" to regenerate code after modifying this file
	Executed               bool             `json:"executed"`
	DesiredNumberScheduled int32            `json:"desiredNumberScheduled"`
	CurrentConfigMap       NamespacedName   `json:"currentConfigMap"`
	LastConfigMap          string           `json:"lastConfigMap"`
	CurrentRevision        int32            `json:"currentRevision"`
	LastSuccessfulRevision int32            `json:"lastSuccessfulRevision"`
	CurrentVerDeployment   NamespacedName   `json:"currentVerDeployment"`
	OldVerDeployment       []NamespacedName `json:"oldVerDeployment,omitempty"`
	// Conditions is an array of conditions.
	// Known .status.conditions.type are: "Execution"
	//+patchMergeKey=type
	//+patchStrategy=merge
	//+listType=map
	//+listMapKey=type
	Conditions []metav1.Condition `json:"conditions,omitempty"`
}

SchemaDeploymentStatus defines the observed state of SchemaDeployment

func (*SchemaDeploymentStatus) DeepCopy 

func (in *SchemaDeploymentStatus) DeepCopy() *SchemaDeploymentStatus

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

func (*SchemaDeploymentStatus) DeepCopyInto 

func (in *SchemaDeploymentStatus) DeepCopyInto(out *SchemaDeploymentStatus)

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

type TargetFilter 

type TargetFilter struct {
	// +kubebuilder:validation:MinItems:=1
	ClusterUris []string `json:"clusterUris"`
	Schema      string   `json:"schema,omitempty"`
	DB          string   `json:"db"`
	// +kubebuilder:validation:Optional
	Webhook string `json:"webhook,omitempty"`
	// +kubebuilder:validation:Optional
	Label string `json:"label,omitempty"`
	// +kubebuilder:validation:Optional
	DBS    []string `json:"dbs,omitempty"`
	Create bool     `json:"create,omitempty"`
	Regexp bool     `json:"regexp,omitempty"`
}

TargetFilter contains target filter configuration

func (*TargetFilter) DeepCopy 

func (in *TargetFilter) DeepCopy() *TargetFilter

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

func (*TargetFilter) DeepCopyInto 

func (in *TargetFilter) DeepCopyInto(out *TargetFilter)

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

type VersionedDeplyment 

type VersionedDeplyment struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   VersionedDeplymentSpec   `json:"spec,omitempty"`
	Status VersionedDeplymentStatus `json:"status,omitempty"`
}

+kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:printcolumn:name="CompletedPCT",type="string",JSONPath=".status.completedPct" VersionedDeplyment is the Schema for the versioneddeplyments API

func (*VersionedDeplyment) DeepCopy 

func (in *VersionedDeplyment) DeepCopy() *VersionedDeplyment

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

func (*VersionedDeplyment) DeepCopyInto 

func (in *VersionedDeplyment) DeepCopyInto(out *VersionedDeplyment)

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

func (*VersionedDeplyment) DeepCopyObject 

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

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

func (*VersionedDeplyment) IsExecuted 

func (t *VersionedDeplyment) IsExecuted() bool

IsExecuted checks the executed status

func (*VersionedDeplyment) IsFailed 

func (t *VersionedDeplyment) IsFailed() bool

IsFailed checks the failed status

func (*VersionedDeplyment) IsRunning 

func (t *VersionedDeplyment) IsRunning() bool

IsRunning checks the running status

type VersionedDeplymentList 

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

VersionedDeplymentList contains a list of VersionedDeplyment

func (*VersionedDeplymentList) DeepCopy 

func (in *VersionedDeplymentList) DeepCopy() *VersionedDeplymentList

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

func (*VersionedDeplymentList) DeepCopyInto 

func (in *VersionedDeplymentList) DeepCopyInto(out *VersionedDeplymentList)

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

func (*VersionedDeplymentList) DeepCopyObject 

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

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

type VersionedDeplymentSpec 

type VersionedDeplymentSpec struct {

	// Foo is an example field of VersionedDeplyment. Edit versioneddeplyment_types.go to remove/update
	Revision       int32          `json:"revision"`
	ConfigMapName  NamespacedName `json:"configMapName"`
	ApplyTo        TargetFilter   `json:"applyTo"`
	Type           DBTypeEnum     `json:"type"`
	FailIfDataLoss bool           `json:"failIfDataLoss"`
}

VersionedDeplymentSpec defines the desired state of VersionedDeplyment

func (*VersionedDeplymentSpec) DeepCopy 

func (in *VersionedDeplymentSpec) DeepCopy() *VersionedDeplymentSpec

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

func (*VersionedDeplymentSpec) DeepCopyInto 

func (in *VersionedDeplymentSpec) DeepCopyInto(out *VersionedDeplymentSpec)

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

type VersionedDeplymentStatus 

type VersionedDeplymentStatus struct {
	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
	// Important: Run "make" to regenerate code after modifying this file
	Executers    []NamespacedName `json:"executers"`
	Executed     bool             `json:"executed"`
	Failed       int32            `json:"failed"`
	Running      int32            `json:"running"`
	Succeeded    int32            `json:"succeeded"`
	CompletedPCT int              `json:"completedPct,omitempty"`
	// Conditions is an array of conditions.
	// Known .status.conditions.type are: "Execution"
	//+patchMergeKey=type
	//+patchStrategy=merge
	//+listType=map
	//+listMapKey=type
	Conditions []metav1.Condition `json:"conditions,omitempty"`
}

VersionedDeplymentStatus defines the observed state of VersionedDeplyment

func (*VersionedDeplymentStatus) DeepCopy 

func (in *VersionedDeplymentStatus) DeepCopy() *VersionedDeplymentStatus

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

func (*VersionedDeplymentStatus) DeepCopyInto 

func (in *VersionedDeplymentStatus) DeepCopyInto(out *VersionedDeplymentStatus)

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.