v1beta1

package
v0.1.2 Latest Latest
Warning

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

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

Documentation

Overview

Package v1beta1 contains API Schema definitions for the clusters v1beta1 API group +kubebuilder:object:generate=true +groupName=clusters.instaclustr.com

Index

Constants

This section is empty.

Variables

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

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

func GetDefaultPgUserSecret added in v0.1.2 

func GetDefaultPgUserSecret(
	ctx context.Context,
	name string,
	ns string,
	k8sClient client.Client,
) (*k8sCore.Secret, error)

Types

type AWSArchival 

type AWSArchival struct {
	ArchivalS3URI            string `json:"archivalS3Uri"`
	ArchivalS3Region         string `json:"archivalS3Region"`
	AccessKeySecretNamespace string `json:"awsAccessKeySecretNamespace"`
	AccessKeySecretName      string `json:"awsAccessKeySecretName"`
}

func (*AWSArchival) DeepCopy 

func (in *AWSArchival) DeepCopy() *AWSArchival

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

func (*AWSArchival) DeepCopyInto 

func (in *AWSArchival) DeepCopyInto(out *AWSArchival)

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

type AWSConnectorSettings 

type AWSConnectorSettings struct {
	// AWS Identity Access Management role that is used for accessing your specified S3 bucket for Kafka Connect custom connector.
	S3RoleArn string `json:"s3RoleArn"`

	// AWS Secret Key associated with the Access Key id that can access your specified S3 bucket for Kafka Connect custom connector.
	SecretKey string `json:"secretKey,omitempty"`

	// AWS Access Key id that can access your specified S3 bucket for Kafka Connect custom connector.
	AccessKey string `json:"accessKey,omitempty"`

	// S3 bucket name for Kafka Connect custom connector.
	S3BucketName string `json:"s3BucketName"`
}

func (*AWSConnectorSettings) DeepCopy 

func (in *AWSConnectorSettings) DeepCopy() *AWSConnectorSettings

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

func (*AWSConnectorSettings) DeepCopyInto 

func (in *AWSConnectorSettings) DeepCopyInto(out *AWSConnectorSettings)

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

type AdvancedVisibility 

type AdvancedVisibility struct {
	TargetKafka      *TargetKafka      `json:"targetKafka"`
	TargetOpenSearch *TargetOpenSearch `json:"targetOpenSearch"`
}

func (*AdvancedVisibility) DeepCopy 

func (in *AdvancedVisibility) DeepCopy() *AdvancedVisibility

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

func (*AdvancedVisibility) DeepCopyInto 

func (in *AdvancedVisibility) DeepCopyInto(out *AdvancedVisibility)

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

type AzureConnectorSettings 

type AzureConnectorSettings struct {
	// Azure storage container name for Kafka Connect custom connector.
	StorageContainerName string `json:"storageContainerName"`

	// Azure storage account name to access your Azure bucket for Kafka Connect custom connector.
	StorageAccountName string `json:"storageAccountName"`

	// Azure storage account key to access your Azure bucket for Kafka Connect custom connector.
	StorageAccountKey string `json:"storageAccountKey"`
}

func (*AzureConnectorSettings) DeepCopy 

func (in *AzureConnectorSettings) DeepCopy() *AzureConnectorSettings

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

func (*AzureConnectorSettings) DeepCopyInto 

func (in *AzureConnectorSettings) DeepCopyInto(out *AzureConnectorSettings)

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

type BundledCassandraSpec 

type BundledCassandraSpec struct {
	NodeSize                       string `json:"nodeSize"`
	NodesNumber                    int    `json:"nodesNumber"`
	ReplicationFactor              int    `json:"replicationFactor"`
	Network                        string `json:"network"`
	PrivateIPBroadcastForDiscovery bool   `json:"privateIPBroadcastForDiscovery"`
	PasswordAndUserAuth            bool   `json:"passwordAndUserAuth"`
}

func (*BundledCassandraSpec) DeepCopy 

func (in *BundledCassandraSpec) DeepCopy() *BundledCassandraSpec

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

func (*BundledCassandraSpec) DeepCopyInto 

func (in *BundledCassandraSpec) DeepCopyInto(out *BundledCassandraSpec)

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

type BundledKafkaSpec 

type BundledKafkaSpec struct {
	NodeSize          string `json:"nodeSize"`
	NodesNumber       int    `json:"nodesNumber"`
	Network           string `json:"network"`
	ReplicationFactor int    `json:"replicationFactor"`
	PartitionsNumber  int    `json:"partitionsNumber"`
}

func (*BundledKafkaSpec) DeepCopy 

func (in *BundledKafkaSpec) DeepCopy() *BundledKafkaSpec

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

func (*BundledKafkaSpec) DeepCopyInto 

func (in *BundledKafkaSpec) DeepCopyInto(out *BundledKafkaSpec)

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

type BundledOpenSearchSpec 

type BundledOpenSearchSpec struct {
	NodeSize          string `json:"nodeSize"`
	ReplicationFactor int    `json:"replicationFactor"`
	Network           string `json:"network"`
}

func (*BundledOpenSearchSpec) DeepCopy 

func (in *BundledOpenSearchSpec) DeepCopy() *BundledOpenSearchSpec

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

func (*BundledOpenSearchSpec) DeepCopyInto 

func (in *BundledOpenSearchSpec) DeepCopyInto(out *BundledOpenSearchSpec)

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

type Cadence 

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

	Spec   CadenceSpec   `json:"spec,omitempty"`
	Status CadenceStatus `json:"status,omitempty"`
}

Cadence is the Schema for the cadences API

func (*Cadence) DeepCopy 

func (in *Cadence) DeepCopy() *Cadence

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

func (*Cadence) DeepCopyInto 

func (in *Cadence) DeepCopyInto(out *Cadence)

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

func (*Cadence) DeepCopyObject 

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

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

func (*Cadence) Default 

func (c *Cadence) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*Cadence) FromInstAPI 

func (c *Cadence) FromInstAPI(iData []byte) (*Cadence, error)

func (*Cadence) GetJobID 

func (c *Cadence) GetJobID(jobName string) string

func (*Cadence) NewPatch 

func (c *Cadence) NewPatch() client.Patch

func (*Cadence) SetupWebhookWithManager 

func (c *Cadence) SetupWebhookWithManager(mgr ctrl.Manager, api validation.Validation) error

type CadenceDataCentre 

type CadenceDataCentre struct {
	DataCentre       `json:",inline"`
	ClientEncryption bool           `json:"clientEncryption,omitempty"`
	PrivateLink      []*PrivateLink `json:"privateLink,omitempty"`
}

func (*CadenceDataCentre) DeepCopy 

func (in *CadenceDataCentre) DeepCopy() *CadenceDataCentre

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

func (*CadenceDataCentre) DeepCopyInto 

func (in *CadenceDataCentre) DeepCopyInto(out *CadenceDataCentre)

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

func (*CadenceDataCentre) ToInstAPI 

func (cdc *CadenceDataCentre) ToInstAPI() *models.CadenceDataCentre

type CadenceList 

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

CadenceList contains a list of Cadence

func (*CadenceList) DeepCopy 

func (in *CadenceList) DeepCopy() *CadenceList

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

func (*CadenceList) DeepCopyInto 

func (in *CadenceList) DeepCopyInto(out *CadenceList)

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

func (*CadenceList) DeepCopyObject 

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

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

type CadenceSpec 

type CadenceSpec struct {
	Cluster `json:",inline"`
	//+kubebuilder:validation:MinItems:=1
	//+kubebuilder:validation:MaxItems:=1
	DataCentres          []*CadenceDataCentre    `json:"dataCentres"`
	Description          string                  `json:"description,omitempty"`
	UseCadenceWebAuth    bool                    `json:"useCadenceWebAuth"`
	AWSArchival          []*AWSArchival          `json:"awsArchival,omitempty"`
	StandardProvisioning []*StandardProvisioning `json:"standardProvisioning,omitempty"`
	SharedProvisioning   []*SharedProvisioning   `json:"sharedProvisioning,omitempty"`
	PackagedProvisioning []*PackagedProvisioning `json:"packagedProvisioning,omitempty"`
	TargetPrimaryCadence []*TargetCadence        `json:"targetPrimaryCadence,omitempty"`
}

CadenceSpec defines the desired state of Cadence

func (*CadenceSpec) ArchivalToInstAPI 

func (cs *CadenceSpec) ArchivalToInstAPI(ctx context.Context, k8sClient client.Client) ([]*models.AWSArchival, error)

func (*CadenceSpec) AreDCsEqual 

func (cs *CadenceSpec) AreDCsEqual(dcs []*CadenceDataCentre) bool

func (*CadenceSpec) DCsFromInstAPI 

func (cs *CadenceSpec) DCsFromInstAPI(iDCs []*models.CadenceDataCentre) (dcs []*CadenceDataCentre)

func (*CadenceSpec) DCsToInstAPI 

func (cs *CadenceSpec) DCsToInstAPI() (iDCs []*models.CadenceDataCentre)

func (*CadenceSpec) DeepCopy 

func (in *CadenceSpec) DeepCopy() *CadenceSpec

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

func (*CadenceSpec) DeepCopyInto 

func (in *CadenceSpec) DeepCopyInto(out *CadenceSpec)

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

func (*CadenceSpec) FromInstAPI 

func (cs *CadenceSpec) FromInstAPI(iCad *models.CadenceCluster) (spec CadenceSpec)

func (*CadenceSpec) IsEqual 

func (cs *CadenceSpec) IsEqual(spec CadenceSpec) bool

func (*CadenceSpec) NewDCsUpdate 

func (cs *CadenceSpec) NewDCsUpdate() models.CadenceClusterAPIUpdate

func (*CadenceSpec) PrivateLinkFromInstAPI added in v0.1.1 

func (cs *CadenceSpec) PrivateLinkFromInstAPI(iPLs []*models.PrivateLink) (pls []*PrivateLink)

func (*CadenceSpec) SharedProvisioningToInstAPI 

func (cs *CadenceSpec) SharedProvisioningToInstAPI() []*models.CadenceSharedProvisioning

func (*CadenceSpec) StandardProvisioningToInstAPI 

func (cs *CadenceSpec) StandardProvisioningToInstAPI() []*models.CadenceStandardProvisioning

func (*CadenceSpec) TargetCadenceToInstAPI added in v0.1.2 

func (cs *CadenceSpec) TargetCadenceToInstAPI() []*models.TargetCadence

func (*CadenceSpec) ToInstAPI 

func (cs *CadenceSpec) ToInstAPI(ctx context.Context, k8sClient client.Client) (*models.CadenceCluster, error)

type CadenceStatus 

type CadenceStatus struct {
	ClusterStatus          `json:",inline"`
	TargetSecondaryCadence []*TargetCadence `json:"targetSecondaryCadence,omitempty"`
}

CadenceStatus defines the observed state of Cadence

func (*CadenceStatus) DCsFromInstAPI 

func (cs *CadenceStatus) DCsFromInstAPI(iDCs []*models.CadenceDataCentre) (dcs []*DataCentreStatus)

func (*CadenceStatus) DeepCopy 

func (in *CadenceStatus) DeepCopy() *CadenceStatus

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

func (*CadenceStatus) DeepCopyInto 

func (in *CadenceStatus) DeepCopyInto(out *CadenceStatus)

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

func (*CadenceStatus) FromInstAPI 

func (cs *CadenceStatus) FromInstAPI(iCad *models.CadenceCluster) CadenceStatus

func (*CadenceStatus) SecondaryTargetsFromInstAPI added in v0.1.2 

func (cs *CadenceStatus) SecondaryTargetsFromInstAPI(iCad *models.CadenceCluster) []*TargetCadence

type Cassandra 

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

	Spec   CassandraSpec   `json:"spec,omitempty"`
	Status CassandraStatus `json:"status,omitempty"`
}

Cassandra is the Schema for the cassandras API

func (*Cassandra) DeepCopy 

func (in *Cassandra) DeepCopy() *Cassandra

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

func (*Cassandra) DeepCopyInto 

func (in *Cassandra) DeepCopyInto(out *Cassandra)

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

func (*Cassandra) DeepCopyObject 

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

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

func (*Cassandra) Default 

func (c *Cassandra) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*Cassandra) FromInstAPI 

func (c *Cassandra) FromInstAPI(iData []byte) (*Cassandra, error)

func (*Cassandra) GetJobID 

func (c *Cassandra) GetJobID(jobName string) string

func (*Cassandra) NewBackupSpec 

func (c *Cassandra) NewBackupSpec(startTimestamp int) *clusterresourcesv1beta1.ClusterBackup

func (*Cassandra) NewPatch 

func (c *Cassandra) NewPatch() client.Patch

func (*Cassandra) SetupWebhookWithManager 

func (r *Cassandra) SetupWebhookWithManager(mgr ctrl.Manager, api validation.Validation) error

type CassandraDataCentre 

type CassandraDataCentre struct {
	DataCentre                     `json:",inline"`
	ContinuousBackup               bool `json:"continuousBackup"`
	PrivateIPBroadcastForDiscovery bool `json:"privateIpBroadcastForDiscovery"`
	ClientToClusterEncryption      bool `json:"clientToClusterEncryption"`
	ReplicationFactor              int  `json:"replicationFactor"`
}

func (*CassandraDataCentre) DeepCopy 

func (in *CassandraDataCentre) DeepCopy() *CassandraDataCentre

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

func (*CassandraDataCentre) DeepCopyInto 

func (in *CassandraDataCentre) DeepCopyInto(out *CassandraDataCentre)

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

func (*CassandraDataCentre) ToInstAPI 

func (cdc *CassandraDataCentre) ToInstAPI() *models.CassandraDataCentre

type CassandraList 

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

CassandraList contains a list of Cassandra

func (*CassandraList) DeepCopy 

func (in *CassandraList) DeepCopy() *CassandraList

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

func (*CassandraList) DeepCopyInto 

func (in *CassandraList) DeepCopyInto(out *CassandraList)

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

func (*CassandraList) DeepCopyObject 

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

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

type CassandraRestoreDC 

type CassandraRestoreDC struct {
	CDCID            string `json:"cdcId,omitempty"`
	RestoreToSameVPC bool   `json:"restoreToSameVpc,omitempty"`
	CustomVPCID      string `json:"customVpcId,omitempty"`
	CustomVPCNetwork string `json:"customVpcNetwork,omitempty"`
}

func (*CassandraRestoreDC) DeepCopy 

func (in *CassandraRestoreDC) DeepCopy() *CassandraRestoreDC

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

func (*CassandraRestoreDC) DeepCopyInto 

func (in *CassandraRestoreDC) DeepCopyInto(out *CassandraRestoreDC)

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

type CassandraRestoreFrom 

type CassandraRestoreFrom struct {
	// Original cluster ID. Backup from that cluster will be used for restore
	ClusterID string `json:"clusterID"`

	// The display name of the restored cluster.
	ClusterNameOverride string `json:"clusterNameOverride,omitempty"`

	// An optional list of cluster data centres for which custom VPC settings will be used.
	CDCInfos []CassandraRestoreDC `json:"cdcInfos,omitempty"`

	// Timestamp in milliseconds since epoch. All backed up data will be restored for this point in time.
	PointInTime int64 `json:"pointInTime,omitempty"`

	// Only data for the specified tables will be restored, for the point in time.
	KeyspaceTables string `json:"keyspaceTables,omitempty"`

	// The cluster network for this cluster to be restored to.
	ClusterNetwork string `json:"clusterNetwork,omitempty"`
}

func (*CassandraRestoreFrom) DeepCopy 

func (in *CassandraRestoreFrom) DeepCopy() *CassandraRestoreFrom

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

func (*CassandraRestoreFrom) DeepCopyInto 

func (in *CassandraRestoreFrom) DeepCopyInto(out *CassandraRestoreFrom)

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

type CassandraSpec 

type CassandraSpec struct {
	RestoreFrom         *CassandraRestoreFrom `json:"restoreFrom,omitempty"`
	Cluster             `json:",inline"`
	DataCentres         []*CassandraDataCentre `json:"dataCentres,omitempty"`
	LuceneEnabled       bool                   `json:"luceneEnabled,omitempty"`
	PasswordAndUserAuth bool                   `json:"passwordAndUserAuth,omitempty"`
	Spark               []*Spark               `json:"spark,omitempty"`
	BundledUseOnly      bool                   `json:"bundledUseOnly,omitempty"`
	UserRefs            []*UserReference       `json:"userRefs,omitempty"`
}

CassandraSpec defines the desired state of Cassandra

func (*CassandraSpec) AreDCsEqual 

func (cs *CassandraSpec) AreDCsEqual(dcs []*CassandraDataCentre) bool

func (*CassandraSpec) DCsFromInstAPI 

func (cs *CassandraSpec) DCsFromInstAPI(iDCs []*models.CassandraDataCentre) (dcs []*CassandraDataCentre)

func (*CassandraSpec) DCsToInstAPI 

func (cs *CassandraSpec) DCsToInstAPI() (iDCs []*models.CassandraDataCentre)

func (*CassandraSpec) DeepCopy 

func (in *CassandraSpec) DeepCopy() *CassandraSpec

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

func (*CassandraSpec) DeepCopyInto 

func (in *CassandraSpec) DeepCopyInto(out *CassandraSpec)

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

func (*CassandraSpec) FromInstAPI 

func (cs *CassandraSpec) FromInstAPI(iCass *models.CassandraCluster) CassandraSpec

func (*CassandraSpec) HasRestore 

func (cs *CassandraSpec) HasRestore() bool

func (*CassandraSpec) IsEqual 

func (cs *CassandraSpec) IsEqual(spec CassandraSpec) bool

func (*CassandraSpec) IsSparkEqual 

func (cs *CassandraSpec) IsSparkEqual(sparks []*Spark) bool

func (*CassandraSpec) NewDCsUpdate 

func (cs *CassandraSpec) NewDCsUpdate() models.CassandraClusterAPIUpdate

func (*CassandraSpec) SparkFromInstAPI 

func (cs *CassandraSpec) SparkFromInstAPI(iSparks []*models.Spark) (sparks []*Spark)

func (*CassandraSpec) SparkToInstAPI 

func (cs *CassandraSpec) SparkToInstAPI() (iSparks []*models.Spark)

func (*CassandraSpec) ToInstAPI 

func (cs *CassandraSpec) ToInstAPI() *models.CassandraCluster

type CassandraStatus 

type CassandraStatus struct {
	ClusterStatus `json:",inline"`
}

CassandraStatus defines the observed state of Cassandra

func (*CassandraStatus) DCsFromInstAPI 

func (cs *CassandraStatus) DCsFromInstAPI(iDCs []*models.CassandraDataCentre) (dcs []*DataCentreStatus)

func (*CassandraStatus) DeepCopy 

func (in *CassandraStatus) DeepCopy() *CassandraStatus

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

func (*CassandraStatus) DeepCopyInto 

func (in *CassandraStatus) DeepCopyInto(out *CassandraStatus)

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

func (*CassandraStatus) FromInstAPI 

func (cs *CassandraStatus) FromInstAPI(iCass *models.CassandraCluster) CassandraStatus

type CloudProviderSettings 

type CloudProviderSettings struct {
	CustomVirtualNetworkID string `json:"customVirtualNetworkId,omitempty"`
	ResourceGroup          string `json:"resourceGroup,omitempty"`
	DiskEncryptionKey      string `json:"diskEncryptionKey,omitempty"`
}

func (*CloudProviderSettings) AWSToInstAPI 

func (cps *CloudProviderSettings) AWSToInstAPI() *models.AWSSetting

func (*CloudProviderSettings) AzureToInstAPI 

func (cps *CloudProviderSettings) AzureToInstAPI() *models.AzureSetting

func (*CloudProviderSettings) DeepCopy 

func (in *CloudProviderSettings) DeepCopy() *CloudProviderSettings

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

func (*CloudProviderSettings) DeepCopyInto 

func (in *CloudProviderSettings) DeepCopyInto(out *CloudProviderSettings)

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

func (*CloudProviderSettings) GCPToInstAPI 

func (cps *CloudProviderSettings) GCPToInstAPI() *models.GCPSetting

func (*CloudProviderSettings) ValidateCreation 

func (cps *CloudProviderSettings) ValidateCreation() error

type Cluster 

type Cluster struct {
	// Name [ 3 .. 32 ] characters.
	Name string `json:"name,omitempty"`

	Version string `json:"version,omitempty"`

	// The PCI compliance standards relate to the security of user data and transactional information.
	// Can only be applied clusters provisioned on AWS_VPC, running Cassandra, Kafka, Elasticsearch and Redis.
	// PCI compliance cannot be enabled if the cluster has Spark.
	PCICompliance bool `json:"pciCompliance,omitempty"`

	PrivateNetworkCluster bool `json:"privateNetworkCluster,omitempty"`

	// Non-production clusters may receive lower priority support and reduced SLAs.
	// Production tier is not available when using Developer class nodes. See SLA Tier for more information.
	// Enum: "PRODUCTION" "NON_PRODUCTION".
	SLATier string `json:"slaTier,omitempty"`

	TwoFactorDelete []*TwoFactorDelete `json:"twoFactorDelete,omitempty"`

	Description string `json:"description,omitempty"`
}

func (*Cluster) CloudProviderSettingsFromInstAPI 

func (c *Cluster) CloudProviderSettingsFromInstAPI(iDC models.DataCentre) (settings []*CloudProviderSettings)

func (*Cluster) ClusterSettingsUpdateToInstAPI added in v0.1.2 

func (c *Cluster) ClusterSettingsUpdateToInstAPI() (*models.ClusterSettings, error)

func (*Cluster) DCFromInstAPI 

func (c *Cluster) DCFromInstAPI(iDC models.DataCentre) DataCentre

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

func (c *Cluster) IsEqual(cluster Cluster) bool

func (*Cluster) IsTwoFactorDeleteEqual 

func (c *Cluster) IsTwoFactorDeleteEqual(tfds []*TwoFactorDelete) bool

func (*Cluster) TagsFromInstAPI 

func (c *Cluster) TagsFromInstAPI(iTags []*models.Tag) map[string]string

func (*Cluster) TwoFactorDeleteFromInstAPI 

func (c *Cluster) TwoFactorDeleteFromInstAPI(iTFDs []*models.TwoFactorDelete) (tfd []*TwoFactorDelete)

func (*Cluster) TwoFactorDeleteToInstAPIv1 

func (c *Cluster) TwoFactorDeleteToInstAPIv1() *models.TwoFactorDeleteV1

func (*Cluster) TwoFactorDeletesToInstAPI 

func (c *Cluster) TwoFactorDeletesToInstAPI() (TFDs []*models.TwoFactorDelete)

func (*Cluster) ValidateCreation 

func (c *Cluster) ValidateCreation() error

type ClusterManagerNodes 

type ClusterManagerNodes struct {
	NodeSize         string `json:"nodeSize"`
	DedicatedManager bool   `json:"dedicatedManager"`
}

func (*ClusterManagerNodes) DeepCopy 

func (in *ClusterManagerNodes) DeepCopy() *ClusterManagerNodes

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

func (*ClusterManagerNodes) DeepCopyInto 

func (in *ClusterManagerNodes) DeepCopyInto(out *ClusterManagerNodes)

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

type ClusterStatus 

type ClusterStatus struct {
	ID                            string                                             `json:"id,omitempty"`
	State                         string                                             `json:"state,omitempty"`
	DataCentres                   []*DataCentreStatus                                `json:"dataCentres,omitempty"`
	CDCID                         string                                             `json:"cdcid,omitempty"`
	TwoFactorDeleteEnabled        bool                                               `json:"twoFactorDeleteEnabled,omitempty"`
	Options                       *Options                                           `json:"options,omitempty"`
	CurrentClusterOperationStatus string                                             `json:"currentClusterOperationStatus,omitempty"`
	MaintenanceEvents             []*clusterresource.ClusteredMaintenanceEventStatus `json:"maintenanceEvents,omitempty"`
}

func (*ClusterStatus) AreMaintenanceEventStatusesEqual added in v0.1.2 

func (cs *ClusterStatus) AreMaintenanceEventStatusesEqual(
	iEventStatuses []*clusterresource.ClusteredMaintenanceEventStatus,
) bool

func (*ClusterStatus) DCFromInstAPI 

func (cs *ClusterStatus) DCFromInstAPI(iDC models.DataCentre) *DataCentreStatus

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.

func (*ClusterStatus) NodesFromInstAPI 

func (cs *ClusterStatus) NodesFromInstAPI(iNodes []*models.Node) (nodes []*Node)

func (*ClusterStatus) NodesFromInstAPIv1 

func (cs *ClusterStatus) NodesFromInstAPIv1(iNodes []*models.NodeStatusV1) (nodes []*Node)

func (*ClusterStatus) PrivateLinkStatusesEqual added in v0.1.2 

func (cs *ClusterStatus) PrivateLinkStatusesEqual(iStatus *ClusterStatus) bool

type ClusteredMaintenanceEvent added in v0.1.2 

type ClusteredMaintenanceEvent struct {
	InProgress []*clusterresource.MaintenanceEventStatus `json:"inProgress"`
	Past       []*clusterresource.MaintenanceEventStatus `json:"past"`
	Upcoming   []*clusterresource.MaintenanceEventStatus `json:"upcoming"`
}

func (*ClusteredMaintenanceEvent) DeepCopy added in v0.1.2 

func (in *ClusteredMaintenanceEvent) DeepCopy() *ClusteredMaintenanceEvent

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

func (*ClusteredMaintenanceEvent) DeepCopyInto added in v0.1.2 

func (in *ClusteredMaintenanceEvent) DeepCopyInto(out *ClusteredMaintenanceEvent)

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

type CustomConnectors 

type CustomConnectors struct {
	// Settings to access custom connectors located in an azure storage container.
	AzureConnectorSettings []*AzureConnectorSettings `json:"azureConnectorSettings,omitempty"`

	// Settings to access custom connectors located in a S3 bucket.
	AWSConnectorSettings []*AWSConnectorSettings `json:"awsConnectorSettings,omitempty"`

	// Settings to access custom connectors located in a gcp storage container.
	GCPConnectorSettings []*GCPConnectorSettings `json:"gcpConnectorSettings,omitempty"`
}

func (*CustomConnectors) AWSConnectorSettingsToInstAPI 

func (cc *CustomConnectors) AWSConnectorSettingsToInstAPI() (iSettings []*models.AWSConnectorSettings)

func (*CustomConnectors) AreAWSConnectorSettingsEqual 

func (cc *CustomConnectors) AreAWSConnectorSettingsEqual(aSettings []*AWSConnectorSettings) bool

func (*CustomConnectors) AreAzureConnectorSettingsEqual 

func (cc *CustomConnectors) AreAzureConnectorSettingsEqual(aSettings []*AzureConnectorSettings) bool

func (*CustomConnectors) AreGCPConnectorSettingsEqual 

func (cc *CustomConnectors) AreGCPConnectorSettingsEqual(gSettings []*GCPConnectorSettings) bool

func (*CustomConnectors) AzureConnectorSettingsToInstAPI 

func (cc *CustomConnectors) AzureConnectorSettingsToInstAPI() (iSettings []*models.AzureConnectorSettings)

func (*CustomConnectors) DeepCopy 

func (in *CustomConnectors) DeepCopy() *CustomConnectors

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

func (*CustomConnectors) DeepCopyInto 

func (in *CustomConnectors) DeepCopyInto(out *CustomConnectors)

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

func (*CustomConnectors) GCPConnectorSettingsToInstAPI 

func (cc *CustomConnectors) GCPConnectorSettingsToInstAPI() (iSettings []*models.GCPConnectorSettings)

func (*CustomConnectors) ToInstAPI 

func (cc *CustomConnectors) ToInstAPI() *models.CustomConnectors

type DataCentre 

type DataCentre struct {
	Name                  string                   `json:"name,omitempty"`
	Region                string                   `json:"region"`
	CloudProvider         string                   `json:"cloudProvider"`
	ProviderAccountName   string                   `json:"accountName,omitempty"`
	CloudProviderSettings []*CloudProviderSettings `json:"cloudProviderSettings,omitempty"`
	Network               string                   `json:"network"`
	NodeSize              string                   `json:"nodeSize"`
	NodesNumber           int                      `json:"nodesNumber"`
	Tags                  map[string]string        `json:"tags,omitempty"`
}

func (*DataCentre) AreCloudProviderSettingsEqual 

func (dc *DataCentre) AreCloudProviderSettingsEqual(settings []*CloudProviderSettings) bool

func (*DataCentre) AreTagsEqual 

func (dc *DataCentre) AreTagsEqual(tags map[string]string) bool

func (*DataCentre) CloudProviderSettingsToInstAPI 

func (dc *DataCentre) CloudProviderSettingsToInstAPI() *models.CloudProviderSettings

func (*DataCentre) DeepCopy 

func (in *DataCentre) DeepCopy() *DataCentre

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

func (*DataCentre) DeepCopyInto 

func (in *DataCentre) DeepCopyInto(out *DataCentre)

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

func (*DataCentre) IsEqual 

func (dc *DataCentre) IsEqual(iDC DataCentre) bool

func (*DataCentre) IsNetworkOverlaps 

func (dc *DataCentre) IsNetworkOverlaps(networkToCheck string) (bool, error)

func (*DataCentre) SetDefaultValues 

func (dc *DataCentre) SetDefaultValues()

func (*DataCentre) TagsToInstAPI 

func (dc *DataCentre) TagsToInstAPI() (tags []*models.Tag)

func (*DataCentre) ToInstAPI 

func (dc *DataCentre) ToInstAPI() models.DataCentre

func (*DataCentre) ValidateCreation 

func (dc *DataCentre) ValidateCreation() error

type DataCentreStatus 

type DataCentreStatus struct {
	ID              string              `json:"id,omitempty"`
	Status          string              `json:"status,omitempty"`
	Nodes           []*Node             `json:"nodes,omitempty"`
	NodeNumber      int                 `json:"nodeNumber,omitempty"`
	EncryptionKeyID string              `json:"encryptionKeyId,omitempty"`
	PrivateLink     PrivateLinkStatuses `json:"privateLink,omitempty"`
}

func (*DataCentreStatus) DeepCopy 

func (in *DataCentreStatus) DeepCopy() *DataCentreStatus

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

func (*DataCentreStatus) DeepCopyInto 

func (in *DataCentreStatus) DeepCopyInto(out *DataCentreStatus)

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

type DedicatedZookeeper 

type DedicatedZookeeper struct {
	// Size of the nodes provisioned as dedicated Zookeeper nodes.
	NodeSize string `json:"nodeSize"`

	// Number of dedicated Zookeeper node count, it must be 3 or 5.
	NodesNumber int32 `json:"nodesNumber"`
}

func (*DedicatedZookeeper) DeepCopy 

func (in *DedicatedZookeeper) DeepCopy() *DedicatedZookeeper

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

func (*DedicatedZookeeper) DeepCopyInto 

func (in *DedicatedZookeeper) DeepCopyInto(out *DedicatedZookeeper)

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

type ExternalCluster 

type ExternalCluster struct {
	SecurityProtocol      string `json:"securityProtocol,omitempty"`
	SSLTruststorePassword string `json:"sslTruststorePassword,omitempty"`
	BootstrapServers      string `json:"bootstrapServers,omitempty"`
	SASLJAASConfig        string `json:"saslJaasConfig,omitempty"`
	SASLMechanism         string `json:"saslMechanism,omitempty"`
	SSLProtocol           string `json:"sslProtocol,omitempty"`
	SSLEnabledProtocols   string `json:"sslEnabledProtocols,omitempty"`
	Truststore            string `json:"truststore,omitempty"`
}

func (*ExternalCluster) DeepCopy 

func (in *ExternalCluster) DeepCopy() *ExternalCluster

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

func (*ExternalCluster) DeepCopyInto 

func (in *ExternalCluster) DeepCopyInto(out *ExternalCluster)

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

type GCPConnectorSettings 

type GCPConnectorSettings struct {
	PrivateKey        string `json:"privateKey"`
	ClientID          string `json:"clientId"`
	ClientEmail       string `json:"clientEmail"`
	ProjectID         string `json:"projectId"`
	StorageBucketName string `json:"storageBucketName"`
	PrivateKeyID      string `json:"privateKeyId"`
}

func (*GCPConnectorSettings) DeepCopy 

func (in *GCPConnectorSettings) DeepCopy() *GCPConnectorSettings

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

func (*GCPConnectorSettings) DeepCopyInto 

func (in *GCPConnectorSettings) DeepCopyInto(out *GCPConnectorSettings)

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

type InterDataCentreReplication 

type InterDataCentreReplication struct {
	IsPrimaryDataCentre bool `json:"isPrimaryDataCentre"`
}

func (*InterDataCentreReplication) DeepCopy 

func (in *InterDataCentreReplication) DeepCopy() *InterDataCentreReplication

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

func (*InterDataCentreReplication) DeepCopyInto 

func (in *InterDataCentreReplication) DeepCopyInto(out *InterDataCentreReplication)

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

type IntraDataCentreReplication 

type IntraDataCentreReplication struct {
	ReplicationMode string `json:"replicationMode"`
}

func (*IntraDataCentreReplication) DeepCopy 

func (in *IntraDataCentreReplication) DeepCopy() *IntraDataCentreReplication

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

func (*IntraDataCentreReplication) DeepCopyInto 

func (in *IntraDataCentreReplication) DeepCopyInto(out *IntraDataCentreReplication)

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

type Kafka 

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

	Spec   KafkaSpec   `json:"spec,omitempty"`
	Status KafkaStatus `json:"status,omitempty"`
}

Kafka is the Schema for the kafkas API

func (*Kafka) DeepCopy 

func (in *Kafka) DeepCopy() *Kafka

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

func (*Kafka) DeepCopyInto 

func (in *Kafka) DeepCopyInto(out *Kafka)

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

func (*Kafka) DeepCopyObject 

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

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

func (*Kafka) Default 

func (k *Kafka) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*Kafka) FromInstAPI 

func (k *Kafka) FromInstAPI(iData []byte) (*Kafka, error)

func (*Kafka) GetJobID 

func (k *Kafka) GetJobID(jobName string) string

func (*Kafka) NewPatch 

func (k *Kafka) NewPatch() client.Patch

func (*Kafka) SetupWebhookWithManager 

func (r *Kafka) SetupWebhookWithManager(mgr ctrl.Manager, api validation.Validation) error

type KafkaAddons 

type KafkaAddons interface {
	SchemaRegistry | RestProxy | KarapaceSchemaRegistry | KarapaceRestProxy | DedicatedZookeeper | PrivateLink | Kraft
}

+kubebuilder:object:generate:=false

type KafkaConnect 

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

	Spec   KafkaConnectSpec   `json:"spec,omitempty"`
	Status KafkaConnectStatus `json:"status,omitempty"`
}

KafkaConnect is the Schema for the kafkaconnects API

func (*KafkaConnect) DeepCopy 

func (in *KafkaConnect) DeepCopy() *KafkaConnect

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

func (*KafkaConnect) DeepCopyInto 

func (in *KafkaConnect) DeepCopyInto(out *KafkaConnect)

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

func (*KafkaConnect) DeepCopyObject 

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

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

func (*KafkaConnect) Default 

func (r *KafkaConnect) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*KafkaConnect) FromInst 

func (k *KafkaConnect) FromInst(iKCData []byte) (*KafkaConnect, error)

func (*KafkaConnect) GetJobID 

func (k *KafkaConnect) GetJobID(jobName string) string

func (*KafkaConnect) NewDefaultUserSecret added in v0.1.1 

func (k *KafkaConnect) NewDefaultUserSecret(username, password string) *v1.Secret

func (*KafkaConnect) NewPatch 

func (k *KafkaConnect) NewPatch() client.Patch

func (*KafkaConnect) SetupWebhookWithManager 

func (r *KafkaConnect) SetupWebhookWithManager(mgr ctrl.Manager, api validation.Validation) error

type KafkaConnectDataCentre 

type KafkaConnectDataCentre struct {
	DataCentre        `json:",inline"`
	ReplicationFactor int `json:"replicationFactor"`
}

func (*KafkaConnectDataCentre) DeepCopy 

func (in *KafkaConnectDataCentre) DeepCopy() *KafkaConnectDataCentre

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

func (*KafkaConnectDataCentre) DeepCopyInto 

func (in *KafkaConnectDataCentre) DeepCopyInto(out *KafkaConnectDataCentre)

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

func (*KafkaConnectDataCentre) ToInstAPI 

func (kdc *KafkaConnectDataCentre) ToInstAPI() *models.KafkaConnectDataCentre

type KafkaConnectList 

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

KafkaConnectList contains a list of KafkaConnect

func (*KafkaConnectList) DeepCopy 

func (in *KafkaConnectList) DeepCopy() *KafkaConnectList

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

func (*KafkaConnectList) DeepCopyInto 

func (in *KafkaConnectList) DeepCopyInto(out *KafkaConnectList)

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

func (*KafkaConnectList) DeepCopyObject 

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

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

type KafkaConnectSpec 

type KafkaConnectSpec struct {
	Cluster       `json:",inline"`
	DataCentres   []*KafkaConnectDataCentre `json:"dataCentres"`
	TargetCluster []*TargetCluster          `json:"targetCluster"`

	// CustomConnectors defines the location for custom connector storage and access info.
	CustomConnectors []*CustomConnectors `json:"customConnectors,omitempty"`
}

KafkaConnectSpec defines the desired state of KafkaConnect

func (*KafkaConnectSpec) AWSConnectorSettingsFromInstAPI 

func (ks *KafkaConnectSpec) AWSConnectorSettingsFromInstAPI(iSettings []*models.AWSConnectorSettings) (settings []*AWSConnectorSettings)

func (*KafkaConnectSpec) AreCustomConnectorsEqual 

func (ks *KafkaConnectSpec) AreCustomConnectorsEqual(cConns []*CustomConnectors) bool

func (*KafkaConnectSpec) AreDataCentresEqual 

func (ks *KafkaConnectSpec) AreDataCentresEqual(dcs []*KafkaConnectDataCentre) bool

func (*KafkaConnectSpec) AreTargetClustersEqual 

func (ks *KafkaConnectSpec) AreTargetClustersEqual(tClusters []*TargetCluster) bool

func (*KafkaConnectSpec) AzureConnectorSettingsFromInstAPI 

func (ks *KafkaConnectSpec) AzureConnectorSettingsFromInstAPI(iSettings []*models.AzureConnectorSettings) (settings []*AzureConnectorSettings)

func (*KafkaConnectSpec) CustomConnectorsFromInstAPI 

func (ks *KafkaConnectSpec) CustomConnectorsFromInstAPI(iConns []*models.CustomConnectors) (conns []*CustomConnectors)

func (*KafkaConnectSpec) CustomConnectorsToInstAPI 

func (ks *KafkaConnectSpec) CustomConnectorsToInstAPI() (iConns []*models.CustomConnectors)

func (*KafkaConnectSpec) DCsFromInstAPI 

func (ks *KafkaConnectSpec) DCsFromInstAPI(iDCs []*models.KafkaConnectDataCentre) (dcs []*KafkaConnectDataCentre)

func (*KafkaConnectSpec) DCsToInstAPI 

func (ks *KafkaConnectSpec) DCsToInstAPI() (iDCs []*models.KafkaConnectDataCentre)

func (*KafkaConnectSpec) DeepCopy 

func (in *KafkaConnectSpec) DeepCopy() *KafkaConnectSpec

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

func (*KafkaConnectSpec) DeepCopyInto 

func (in *KafkaConnectSpec) DeepCopyInto(out *KafkaConnectSpec)

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

func (*KafkaConnectSpec) ExternalClustersFromInstAPI 

func (ks *KafkaConnectSpec) ExternalClustersFromInstAPI(iClusters []*models.ExternalCluster) (clusters []*ExternalCluster)

func (*KafkaConnectSpec) FromInstAPI 

func (ks *KafkaConnectSpec) FromInstAPI(iKC *models.KafkaConnectCluster) KafkaConnectSpec

func (*KafkaConnectSpec) GCPConnectorSettingsFromInstAPI 

func (ks *KafkaConnectSpec) GCPConnectorSettingsFromInstAPI(iSettings []*models.GCPConnectorSettings) (settings []*GCPConnectorSettings)

func (*KafkaConnectSpec) IsEqual 

func (ks *KafkaConnectSpec) IsEqual(kc KafkaConnectSpec) bool

func (*KafkaConnectSpec) ManagedClustersFromInstAPI 

func (ks *KafkaConnectSpec) ManagedClustersFromInstAPI(iClusters []*models.ManagedCluster) (clusters []*ManagedCluster)

func (*KafkaConnectSpec) NewDCsUpdate 

func (ks *KafkaConnectSpec) NewDCsUpdate() models.KafkaConnectAPIUpdate

func (*KafkaConnectSpec) TargetClustersFromInstAPI 

func (ks *KafkaConnectSpec) TargetClustersFromInstAPI(iClusters []*models.TargetCluster) (clusters []*TargetCluster)

func (*KafkaConnectSpec) TargetClustersToInstAPI 

func (ks *KafkaConnectSpec) TargetClustersToInstAPI() (iClusters []*models.TargetCluster)

func (*KafkaConnectSpec) ToInstAPI 

func (ks *KafkaConnectSpec) ToInstAPI() models.KafkaConnectCluster

type KafkaConnectStatus 

type KafkaConnectStatus struct {
	ClusterStatus `json:",inline"`
}

KafkaConnectStatus defines the observed state of KafkaConnect

func (*KafkaConnectStatus) DCsFromInstAPI 

func (ks *KafkaConnectStatus) DCsFromInstAPI(iDCs []*models.KafkaConnectDataCentre) (dcs []*DataCentreStatus)

func (*KafkaConnectStatus) DeepCopy 

func (in *KafkaConnectStatus) DeepCopy() *KafkaConnectStatus

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

func (*KafkaConnectStatus) DeepCopyInto 

func (in *KafkaConnectStatus) DeepCopyInto(out *KafkaConnectStatus)

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

func (*KafkaConnectStatus) FromInstAPI 

func (ks *KafkaConnectStatus) FromInstAPI(iKC *models.KafkaConnectCluster) KafkaConnectStatus

type KafkaDataCentre 

type KafkaDataCentre struct {
	DataCentre  `json:",inline"`
	PrivateLink []*PrivateLink `json:"privateLink,omitempty"`
}

func (*KafkaDataCentre) DeepCopy 

func (in *KafkaDataCentre) DeepCopy() *KafkaDataCentre

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

func (*KafkaDataCentre) DeepCopyInto 

func (in *KafkaDataCentre) DeepCopyInto(out *KafkaDataCentre)

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

type KafkaList 

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

KafkaList contains a list of Kafka

func (*KafkaList) DeepCopy 

func (in *KafkaList) DeepCopy() *KafkaList

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

func (*KafkaList) DeepCopyInto 

func (in *KafkaList) DeepCopyInto(out *KafkaList)

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

func (*KafkaList) DeepCopyObject 

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

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

type KafkaSpec 

type KafkaSpec struct {
	Cluster        `json:",inline"`
	SchemaRegistry []*SchemaRegistry `json:"schemaRegistry,omitempty"`

	// ReplicationFactor to use for new topic.
	// Also represents the number of racks to use when allocating nodes.
	ReplicationFactor int `json:"replicationFactor"`

	// PartitionsNumber number of partitions to use when created new topics.
	PartitionsNumber          int          `json:"partitionsNumber"`
	RestProxy                 []*RestProxy `json:"restProxy,omitempty"`
	AllowDeleteTopics         bool         `json:"allowDeleteTopics"`
	AutoCreateTopics          bool         `json:"autoCreateTopics"`
	ClientToClusterEncryption bool         `json:"clientToClusterEncryption"`
	//+kubebuilder:validation:MinItems:=1
	//+kubebuilder:validation:MaxItems:=1
	DataCentres []*KafkaDataCentre `json:"dataCentres"`

	// Provision additional dedicated nodes for Apache Zookeeper to run on.
	// Zookeeper nodes will be co-located with Kafka if this is not provided
	DedicatedZookeeper       []*DedicatedZookeeper     `json:"dedicatedZookeeper,omitempty"`
	ClientBrokerAuthWithMTLS bool                      `json:"clientBrokerAuthWithMtls,omitempty"`
	KarapaceRestProxy        []*KarapaceRestProxy      `json:"karapaceRestProxy,omitempty"`
	KarapaceSchemaRegistry   []*KarapaceSchemaRegistry `json:"karapaceSchemaRegistry,omitempty"`
	BundledUseOnly           bool                      `json:"bundledUseOnly,omitempty"`
	UserRefs                 []*UserReference          `json:"userRefs,omitempty"`
	Kraft                    []*Kraft                  `json:"kraft,omitempty"`
}

KafkaSpec defines the desired state of Kafka

func (*KafkaSpec) DCsFromInstAPI 

func (ks *KafkaSpec) DCsFromInstAPI(iDCs []*models.KafkaDataCentre) (dcs []*KafkaDataCentre)

func (*KafkaSpec) DedicatedZookeeperFromInstAPI 

func (ks *KafkaSpec) DedicatedZookeeperFromInstAPI(iDZs []*models.DedicatedZookeeper) (dzs []*DedicatedZookeeper)

func (*KafkaSpec) DeepCopy 

func (in *KafkaSpec) DeepCopy() *KafkaSpec

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

func (*KafkaSpec) DeepCopyInto 

func (in *KafkaSpec) DeepCopyInto(out *KafkaSpec)

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

func (*KafkaSpec) FromInstAPI 

func (ks *KafkaSpec) FromInstAPI(iKafka *models.KafkaCluster) KafkaSpec

func (*KafkaSpec) IsEqual 

func (a *KafkaSpec) IsEqual(b KafkaSpec) bool

func (*KafkaSpec) KarapaceRestProxyFromInstAPI 

func (ks *KafkaSpec) KarapaceRestProxyFromInstAPI(iKRPs []*models.KarapaceRestProxy) (krps []*KarapaceRestProxy)

func (*KafkaSpec) KarapaceSchemaRegistryFromInstAPI 

func (ks *KafkaSpec) KarapaceSchemaRegistryFromInstAPI(iKSRs []*models.KarapaceSchemaRegistry) (ksrs []*KarapaceSchemaRegistry)

func (*KafkaSpec) PrivateLinkFromInstAPI 

func (ks *KafkaSpec) PrivateLinkFromInstAPI(iPLs []*models.PrivateLink) (pls []*PrivateLink)

func (*KafkaSpec) RestProxyFromInstAPI 

func (ks *KafkaSpec) RestProxyFromInstAPI(iRPs []*models.RestProxy) (rps []*RestProxy)

func (*KafkaSpec) SchemaRegistryFromInstAPI 

func (ks *KafkaSpec) SchemaRegistryFromInstAPI(iSRs []*models.SchemaRegistry) (srs []*SchemaRegistry)

func (*KafkaSpec) ToInstAPI 

func (k *KafkaSpec) ToInstAPI() *models.KafkaCluster

func (*KafkaSpec) ToInstAPIUpdate 

func (k *KafkaSpec) ToInstAPIUpdate() *models.KafkaInstAPIUpdateRequest

type KafkaStatus 

type KafkaStatus struct {
	ClusterStatus `json:",inline"`
}

KafkaStatus defines the observed state of Kafka

func (*KafkaStatus) DCsFromInstAPI 

func (ks *KafkaStatus) DCsFromInstAPI(iDCs []*models.KafkaDataCentre) (dcs []*DataCentreStatus)

func (*KafkaStatus) DeepCopy 

func (in *KafkaStatus) DeepCopy() *KafkaStatus

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

func (*KafkaStatus) DeepCopyInto 

func (in *KafkaStatus) DeepCopyInto(out *KafkaStatus)

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

func (*KafkaStatus) FromInstAPI 

func (ks *KafkaStatus) FromInstAPI(iKafka *models.KafkaCluster) KafkaStatus

type KarapaceRestProxy 

type KarapaceRestProxy struct {
	IntegrateRestProxyWithSchemaRegistry bool   `json:"integrateRestProxyWithSchemaRegistry"`
	Version                              string `json:"version"`
}

func (*KarapaceRestProxy) DeepCopy 

func (in *KarapaceRestProxy) DeepCopy() *KarapaceRestProxy

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

func (*KarapaceRestProxy) DeepCopyInto 

func (in *KarapaceRestProxy) DeepCopyInto(out *KarapaceRestProxy)

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

type KarapaceSchemaRegistry 

type KarapaceSchemaRegistry struct {
	Version string `json:"version"`
}

func (*KarapaceSchemaRegistry) DeepCopy 

func (in *KarapaceSchemaRegistry) DeepCopy() *KarapaceSchemaRegistry

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

func (*KarapaceSchemaRegistry) DeepCopyInto 

func (in *KarapaceSchemaRegistry) DeepCopyInto(out *KarapaceSchemaRegistry)

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

type Kraft added in v0.1.2 

type Kraft struct {
	ControllerNodeCount int `json:"controllerNodeCount"`
}

func (*Kraft) DeepCopy added in v0.1.2 

func (in *Kraft) DeepCopy() *Kraft

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

func (*Kraft) DeepCopyInto added in v0.1.2 

func (in *Kraft) DeepCopyInto(out *Kraft)

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

type ManagedCluster 

type ManagedCluster struct {
	TargetKafkaClusterID string `json:"targetKafkaClusterId"`

	// 	Available options are KAFKA_VPC, VPC_PEERED, SEPARATE_VPC
	KafkaConnectVPCType string `json:"kafkaConnectVpcType"`
}

func (*ManagedCluster) DeepCopy 

func (in *ManagedCluster) DeepCopy() *ManagedCluster

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

func (*ManagedCluster) DeepCopyInto 

func (in *ManagedCluster) DeepCopyInto(out *ManagedCluster)

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

type Node 

type Node struct {
	ID             string   `json:"id,omitempty"`
	Size           string   `json:"size,omitempty"`
	PublicAddress  string   `json:"publicAddress,omitempty"`
	PrivateAddress string   `json:"privateAddress,omitempty"`
	Status         string   `json:"status,omitempty"`
	Roles          []string `json:"roles,omitempty"`
	Rack           string   `json:"rack,omitempty"`
}

func (*Node) DeepCopy 

func (in *Node) DeepCopy() *Node

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

func (*Node) DeepCopyInto 

func (in *Node) DeepCopyInto(out *Node)

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

type OpenSearch 

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

	Spec   OpenSearchSpec   `json:"spec,omitempty"`
	Status OpenSearchStatus `json:"status,omitempty"`
}

OpenSearch is the Schema for the opensearches API

func (*OpenSearch) DeepCopy 

func (in *OpenSearch) DeepCopy() *OpenSearch

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

func (*OpenSearch) DeepCopyInto 

func (in *OpenSearch) DeepCopyInto(out *OpenSearch)

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

func (*OpenSearch) DeepCopyObject 

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

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

func (*OpenSearch) Default 

func (os *OpenSearch) Default()

func (*OpenSearch) FromInstAPI 

func (oss *OpenSearch) FromInstAPI(iData []byte) (*OpenSearch, error)

func (*OpenSearch) GetJobID 

func (os *OpenSearch) GetJobID(jobName string) string

func (*OpenSearch) NewBackupSpec 

func (os *OpenSearch) NewBackupSpec(startTimestamp int) *clusterresourcesv1beta1.ClusterBackup

func (*OpenSearch) NewPatch 

func (os *OpenSearch) NewPatch() client.Patch

func (*OpenSearch) SetupWebhookWithManager 

func (r *OpenSearch) SetupWebhookWithManager(mgr ctrl.Manager, api validation.Validation) error

type OpenSearchDashboards 

type OpenSearchDashboards struct {
	NodeSize     string `json:"nodeSize"`
	OIDCProvider string `json:"oidcProvider,omitempty"`
	Version      string `json:"version"`
}

func (*OpenSearchDashboards) DeepCopy 

func (in *OpenSearchDashboards) DeepCopy() *OpenSearchDashboards

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

func (*OpenSearchDashboards) DeepCopyInto 

func (in *OpenSearchDashboards) DeepCopyInto(out *OpenSearchDashboards)

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

type OpenSearchDataCentre 

type OpenSearchDataCentre struct {
	PrivateLink           bool                     `json:"privateLink,omitempty"`
	Name                  string                   `json:"name,omitempty"`
	Region                string                   `json:"region"`
	CloudProvider         string                   `json:"cloudProvider"`
	ProviderAccountName   string                   `json:"accountName,omitempty"`
	CloudProviderSettings []*CloudProviderSettings `json:"cloudProviderSettings,omitempty"`
	Network               string                   `json:"network"`
	Tags                  map[string]string        `json:"tags,omitempty"`

	// ReplicationFactor is a number of racks to use when allocating data nodes.
	ReplicationFactor int `json:"replicationFactor"`
}

func (*OpenSearchDataCentre) DeepCopy 

func (in *OpenSearchDataCentre) DeepCopy() *OpenSearchDataCentre

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

func (*OpenSearchDataCentre) DeepCopyInto 

func (in *OpenSearchDataCentre) DeepCopyInto(out *OpenSearchDataCentre)

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

type OpenSearchDataNodes 

type OpenSearchDataNodes struct {
	NodeSize    string `json:"nodeSize"`
	NodesNumber int    `json:"nodesNumber"`
}

func (*OpenSearchDataNodes) DeepCopy 

func (in *OpenSearchDataNodes) DeepCopy() *OpenSearchDataNodes

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

func (*OpenSearchDataNodes) DeepCopyInto 

func (in *OpenSearchDataNodes) DeepCopyInto(out *OpenSearchDataNodes)

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

type OpenSearchList 

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

OpenSearchList contains a list of OpenSearch

func (*OpenSearchList) DeepCopy 

func (in *OpenSearchList) DeepCopy() *OpenSearchList

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

func (*OpenSearchList) DeepCopyInto 

func (in *OpenSearchList) DeepCopyInto(out *OpenSearchList)

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

func (*OpenSearchList) DeepCopyObject 

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

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

type OpenSearchNodeTypes 

type OpenSearchNodeTypes interface {
	OpenSearchDataNodes | OpenSearchDashboards | ClusterManagerNodes
}

+kubebuilder:object:generate:=false

type OpenSearchRestoreCDCInfo 

type OpenSearchRestoreCDCInfo struct {
	CDCID            string `json:"cdcId,omitempty"`
	RestoreToSameVPC bool   `json:"restoreToSameVpc,omitempty"`
	CustomVPCID      string `json:"customVpcId,omitempty"`
	CustomVPCNetwork string `json:"customVpcNetwork,omitempty"`
}

func (*OpenSearchRestoreCDCInfo) DeepCopy 

func (in *OpenSearchRestoreCDCInfo) DeepCopy() *OpenSearchRestoreCDCInfo

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

func (*OpenSearchRestoreCDCInfo) DeepCopyInto 

func (in *OpenSearchRestoreCDCInfo) DeepCopyInto(out *OpenSearchRestoreCDCInfo)

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

type OpenSearchRestoreFrom 

type OpenSearchRestoreFrom struct {
	// Original cluster ID. Backup from that cluster will be used for restore
	ClusterID string `json:"clusterId"`

	// The display name of the restored cluster.
	ClusterNameOverride string `json:"clusterNameOverride,omitempty"`

	// An optional list of cluster data centres for which custom VPC settings will be used.
	CDCInfos []*OpenSearchRestoreCDCInfo `json:"cdcInfos,omitempty"`

	// Timestamp in milliseconds since epoch. All backed up data will be restored for this point in time.
	PointInTime int64 `json:"pointInTime,omitempty"`

	// Only data for the specified indices will be restored, for the point in time.
	IndexNames string `json:"indexNames,omitempty"`

	// The cluster network for this cluster to be restored to.
	ClusterNetwork string `json:"clusterNetwork,omitempty"`
}

func (*OpenSearchRestoreFrom) DeepCopy 

func (in *OpenSearchRestoreFrom) DeepCopy() *OpenSearchRestoreFrom

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

func (*OpenSearchRestoreFrom) DeepCopyInto 

func (in *OpenSearchRestoreFrom) DeepCopyInto(out *OpenSearchRestoreFrom)

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

type OpenSearchSpec 

type OpenSearchSpec struct {
	RestoreFrom              *OpenSearchRestoreFrom `json:"restoreFrom,omitempty"`
	Cluster                  `json:",inline"`
	DataCentres              []*OpenSearchDataCentre `json:"dataCentres,omitempty"`
	DataNodes                []*OpenSearchDataNodes  `json:"dataNodes,omitempty"`
	ICUPlugin                bool                    `json:"icuPlugin,omitempty"`
	AsynchronousSearchPlugin bool                    `json:"asynchronousSearchPlugin,omitempty"`
	KNNPlugin                bool                    `json:"knnPlugin,omitempty"`
	Dashboards               []*OpenSearchDashboards `json:"dashboards,omitempty"`
	ReportingPlugin          bool                    `json:"reportingPlugin,omitempty"`
	SQLPlugin                bool                    `json:"sqlPlugin,omitempty"`
	NotificationsPlugin      bool                    `json:"notificationsPlugin,omitempty"`
	AnomalyDetectionPlugin   bool                    `json:"anomalyDetectionPlugin,omitempty"`
	LoadBalancer             bool                    `json:"loadBalancer,omitempty"`
	ClusterManagerNodes      []*ClusterManagerNodes  `json:"clusterManagerNodes,omitempty"`
	IndexManagementPlugin    bool                    `json:"indexManagementPlugin,omitempty"`
	AlertingPlugin           bool                    `json:"alertingPlugin,omitempty"`
	BundledUseOnly           bool                    `json:"bundledUseOnly,omitempty"`
	UserRefs                 []*UserReference        `json:"userRefs,omitempty"`
}

OpenSearchSpec defines the desired state of OpenSearch

func (*OpenSearchSpec) ClusterManagerNodesFromInstAPI 

func (oss *OpenSearchSpec) ClusterManagerNodesFromInstAPI(iManagerNodes []*models.ClusterManagerNodes) (managerNodes []*ClusterManagerNodes)

func (*OpenSearchSpec) DCsFromInstAPI 

func (oss *OpenSearchSpec) DCsFromInstAPI(iDCs []*models.OpenSearchDataCentre) (dcs []*OpenSearchDataCentre)

func (*OpenSearchSpec) DashboardsFromInstAPI 

func (oss *OpenSearchSpec) DashboardsFromInstAPI(iDashboards []*models.OpenSearchDashboards) (dashboards []*OpenSearchDashboards)

func (*OpenSearchSpec) DataNodesFromInstAPI 

func (oss *OpenSearchSpec) DataNodesFromInstAPI(iDataNodes []*models.OpenSearchDataNodes) (dataNodes []*OpenSearchDataNodes)

func (*OpenSearchSpec) DeepCopy 

func (in *OpenSearchSpec) DeepCopy() *OpenSearchSpec

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

func (*OpenSearchSpec) DeepCopyInto 

func (in *OpenSearchSpec) DeepCopyInto(out *OpenSearchSpec)

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

func (*OpenSearchSpec) FromInstAPI 

func (oss *OpenSearchSpec) FromInstAPI(iOpenSearch *models.OpenSearchCluster) OpenSearchSpec

func (*OpenSearchSpec) HasRestore 

func (oss *OpenSearchSpec) HasRestore() bool

func (*OpenSearchSpec) IsEqual 

func (a *OpenSearchSpec) IsEqual(b OpenSearchSpec) bool

func (*OpenSearchSpec) ToInstAPI 

func (oss *OpenSearchSpec) ToInstAPI() *models.OpenSearchCluster

func (*OpenSearchSpec) ToInstAPIUpdate 

func (oss *OpenSearchSpec) ToInstAPIUpdate() models.OpenSearchInstAPIUpdateRequest

type OpenSearchStatus 

type OpenSearchStatus struct {
	ClusterStatus `json:",inline"`
}

OpenSearchStatus defines the observed state of OpenSearch

func (*OpenSearchStatus) DCsFromInstAPI 

func (oss *OpenSearchStatus) DCsFromInstAPI(iDCs []*models.OpenSearchDataCentre) (dcs []*DataCentreStatus)

func (*OpenSearchStatus) DeepCopy 

func (in *OpenSearchStatus) DeepCopy() *OpenSearchStatus

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

func (*OpenSearchStatus) DeepCopyInto 

func (in *OpenSearchStatus) DeepCopyInto(out *OpenSearchStatus)

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

func (*OpenSearchStatus) FromInstAPI 

func (oss *OpenSearchStatus) FromInstAPI(iOpenSearch *models.OpenSearchCluster) OpenSearchStatus

type Options 

type Options struct {
	DataNodeSize                 string `json:"dataNodeSize,omitempty"`
	MasterNodeSize               string `json:"masterNodeSize,omitempty"`
	OpenSearchDashboardsNodeSize string `json:"openSearchDashboardsNodeSize,omitempty"`
}

func (*Options) DeepCopy 

func (in *Options) DeepCopy() *Options

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

func (*Options) DeepCopyInto 

func (in *Options) DeepCopyInto(out *Options)

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

type PackagedProvisioning 

type PackagedProvisioning struct {
	UseAdvancedVisibility bool                   `json:"useAdvancedVisibility"`
	BundledKafkaSpec      *BundledKafkaSpec      `json:"bundledKafkaSpec,omitempty"`
	BundledOpenSearchSpec *BundledOpenSearchSpec `json:"bundledOpenSearchSpec,omitempty"`
	BundledCassandraSpec  *BundledCassandraSpec  `json:"bundledCassandraSpec"`
}

func (*PackagedProvisioning) DeepCopy 

func (in *PackagedProvisioning) DeepCopy() *PackagedProvisioning

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

func (*PackagedProvisioning) DeepCopyInto 

func (in *PackagedProvisioning) DeepCopyInto(out *PackagedProvisioning)

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

type PatchRequest 

type PatchRequest struct {
	Operation string          `json:"op"`
	Path      string          `json:"path"`
	Value     json.RawMessage `json:"value"`
}

func (*PatchRequest) DeepCopy 

func (in *PatchRequest) DeepCopy() *PatchRequest

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

func (*PatchRequest) DeepCopyInto 

func (in *PatchRequest) DeepCopyInto(out *PatchRequest)

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

type PgBouncer 

type PgBouncer struct {
	PGBouncerVersion string `json:"pgBouncerVersion"`
	PoolMode         string `json:"poolMode"`
}

func (*PgBouncer) DeepCopy 

func (in *PgBouncer) DeepCopy() *PgBouncer

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

func (*PgBouncer) DeepCopyInto 

func (in *PgBouncer) DeepCopyInto(out *PgBouncer)

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

type PgDataCentre 

type PgDataCentre struct {
	DataCentre `json:",inline"`
	// PostgreSQL options
	ClientEncryption           bool                          `json:"clientEncryption"`
	InterDataCentreReplication []*InterDataCentreReplication `json:"interDataCentreReplication,omitempty"`
	IntraDataCentreReplication []*IntraDataCentreReplication `json:"intraDataCentreReplication"`
	PGBouncer                  []*PgBouncer                  `json:"pgBouncer,omitempty"`
}

func (*PgDataCentre) AreInterDCReplicationsEqual 

func (pdc *PgDataCentre) AreInterDCReplicationsEqual(iIRs []*InterDataCentreReplication) bool

func (*PgDataCentre) AreIntraDCReplicationsEqual 

func (pdc *PgDataCentre) AreIntraDCReplicationsEqual(iIRs []*IntraDataCentreReplication) bool

func (*PgDataCentre) ArePGBouncersEqual 

func (pdc *PgDataCentre) ArePGBouncersEqual(iPGBs []*PgBouncer) bool

func (*PgDataCentre) DeepCopy 

func (in *PgDataCentre) DeepCopy() *PgDataCentre

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

func (*PgDataCentre) DeepCopyInto 

func (in *PgDataCentre) DeepCopyInto(out *PgDataCentre)

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

func (*PgDataCentre) InterDCReplicationToInstAPI 

func (pdc *PgDataCentre) InterDCReplicationToInstAPI() (iIRs []*models.PGInterDCReplication)

func (*PgDataCentre) IntraDCReplicationToInstAPI 

func (pdc *PgDataCentre) IntraDCReplicationToInstAPI() (iIRs []*models.PGIntraDCReplication)

func (*PgDataCentre) PGBouncerToInstAPI 

func (pdc *PgDataCentre) PGBouncerToInstAPI() (iPgB []*models.PGBouncer)

func (*PgDataCentre) ToInstAPI 

func (pdc *PgDataCentre) ToInstAPI() *models.PGDataCentre

func (*PgDataCentre) ValidatePGBouncer 

func (pdc *PgDataCentre) ValidatePGBouncer() error

type PgRestoreCDCInfo 

type PgRestoreCDCInfo struct {
	CDCID            string `json:"cdcId,omitempty"`
	RestoreToSameVPC bool   `json:"restoreToSameVpc,omitempty"`
	CustomVPCID      string `json:"customVpcId,omitempty"`
	CustomVPCNetwork string `json:"customVpcNetwork,omitempty"`
}

func (*PgRestoreCDCInfo) DeepCopy 

func (in *PgRestoreCDCInfo) DeepCopy() *PgRestoreCDCInfo

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

func (*PgRestoreCDCInfo) DeepCopyInto 

func (in *PgRestoreCDCInfo) DeepCopyInto(out *PgRestoreCDCInfo)

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

type PgRestoreFrom 

type PgRestoreFrom struct {
	// Original cluster ID. Backup from that cluster will be used for restore
	ClusterID string `json:"clusterId"`

	// The display name of the restored cluster.
	ClusterNameOverride string `json:"clusterNameOverride,omitempty"`

	// An optional list of cluster data centres for which custom VPC settings will be used.
	CDCInfos []*PgRestoreCDCInfo `json:"cdcInfos,omitempty"`

	// Timestamp in milliseconds since epoch. All backed up data will be restored for this point in time.
	PointInTime int64 `json:"pointInTime,omitempty"`

	// The cluster network for this cluster to be restored to.
	ClusterNetwork string `json:"clusterNetwork,omitempty"`
}

func (*PgRestoreFrom) DeepCopy 

func (in *PgRestoreFrom) DeepCopy() *PgRestoreFrom

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

func (*PgRestoreFrom) DeepCopyInto 

func (in *PgRestoreFrom) DeepCopyInto(out *PgRestoreFrom)

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

type PgSpec 

type PgSpec struct {
	PgRestoreFrom         *PgRestoreFrom `json:"pgRestoreFrom,omitempty"`
	Cluster               `json:",inline"`
	DataCentres           []*PgDataCentre   `json:"dataCentres,omitempty"`
	ClusterConfigurations map[string]string `json:"clusterConfigurations,omitempty"`
	Description           string            `json:"description,omitempty"`
	SynchronousModeStrict bool              `json:"synchronousModeStrict,omitempty"`
	UserRefs              []*UserReference  `json:"userRefs,omitempty"`
}

PgSpec defines the desired state of PostgreSQL

func (*PgSpec) AreDCsEqual 

func (pgs *PgSpec) AreDCsEqual(iDCs []*PgDataCentre) bool

func (*PgSpec) DCsFromInstAPI 

func (pgs *PgSpec) DCsFromInstAPI(iDCs []*models.PGDataCentre) (dcs []*PgDataCentre)

func (*PgSpec) DCsToInstAPI 

func (pgs *PgSpec) DCsToInstAPI() (iDCs []*models.PGDataCentre)

func (*PgSpec) DeepCopy 

func (in *PgSpec) DeepCopy() *PgSpec

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

func (*PgSpec) DeepCopyInto 

func (in *PgSpec) DeepCopyInto(out *PgSpec)

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

func (*PgSpec) FromInstAPI 

func (pgs *PgSpec) FromInstAPI(iPg *models.PGCluster) PgSpec

func (*PgSpec) HasRestore 

func (pgs *PgSpec) HasRestore() bool

func (*PgSpec) InterDCReplicationsFromInstAPI 

func (pgs *PgSpec) InterDCReplicationsFromInstAPI(iIRs []*models.PGInterDCReplication) (irs []*InterDataCentreReplication)

func (*PgSpec) IntraDCReplicationsFromInstAPI 

func (pgs *PgSpec) IntraDCReplicationsFromInstAPI(iIRs []*models.PGIntraDCReplication) (irs []*IntraDataCentreReplication)

func (*PgSpec) IsEqual 

func (pgs *PgSpec) IsEqual(iPG PgSpec) bool

func (*PgSpec) PGBouncerFromInstAPI 

func (pgs *PgSpec) PGBouncerFromInstAPI(iPgBs []*models.PGBouncer) (pgbs []*PgBouncer)

func (*PgSpec) ToInstAPI 

func (pgs *PgSpec) ToInstAPI() *models.PGCluster

func (*PgSpec) ValidateImmutableFieldsUpdate 

func (pgs *PgSpec) ValidateImmutableFieldsUpdate(oldSpec PgSpec) error

type PgStatus 

type PgStatus struct {
	ClusterStatus `json:",inline"`
}

PgStatus defines the observed state of PostgreSQL

func (*PgStatus) DCsFromInstAPI 

func (pgs *PgStatus) DCsFromInstAPI(iDCs []*models.PGDataCentre) (dcs []*DataCentreStatus)

func (*PgStatus) DeepCopy 

func (in *PgStatus) DeepCopy() *PgStatus

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

func (*PgStatus) DeepCopyInto 

func (in *PgStatus) DeepCopyInto(out *PgStatus)

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

func (*PgStatus) FromInstAPI 

func (pgs *PgStatus) FromInstAPI(iPg *models.PGCluster) PgStatus

type PostgreSQL 

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

	Spec   PgSpec   `json:"spec,omitempty"`
	Status PgStatus `json:"status,omitempty"`
}

PostgreSQL is the Schema for the postgresqls API

func (*PostgreSQL) DeepCopy 

func (in *PostgreSQL) DeepCopy() *PostgreSQL

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

func (*PostgreSQL) DeepCopyInto 

func (in *PostgreSQL) DeepCopyInto(out *PostgreSQL)

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

func (*PostgreSQL) DeepCopyObject 

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

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

func (*PostgreSQL) Default 

func (pg *PostgreSQL) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*PostgreSQL) DefaultPasswordFromInstAPI 

func (pg *PostgreSQL) DefaultPasswordFromInstAPI(iData []byte) (string, error)

func (*PostgreSQL) FromInstAPI 

func (pg *PostgreSQL) FromInstAPI(iData []byte) (*PostgreSQL, error)

func (*PostgreSQL) GetJobID 

func (pg *PostgreSQL) GetJobID(jobName string) string

func (*PostgreSQL) GetUserSecretName 

func (pg *PostgreSQL) GetUserSecretName(ctx context.Context, k8sClient client.Client) (string, error)

func (*PostgreSQL) NewBackupSpec 

func (pg *PostgreSQL) NewBackupSpec(startTimestamp int) *clusterresourcesv1beta1.ClusterBackup

func (*PostgreSQL) NewPatch 

func (pg *PostgreSQL) NewPatch() client.Patch

func (*PostgreSQL) NewUserSecret 

func (pg *PostgreSQL) NewUserSecret(defaultUserPassword string) *k8sCore.Secret

func (*PostgreSQL) SetupWebhookWithManager 

func (r *PostgreSQL) SetupWebhookWithManager(mgr ctrl.Manager, api validation.Validation) error

func (*PostgreSQL) ValidateDefaultUserPassword 

func (pg *PostgreSQL) ValidateDefaultUserPassword(password string) bool

type PostgreSQLList 

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

PostgreSQLList contains a list of PostgreSQL

func (*PostgreSQLList) DeepCopy 

func (in *PostgreSQLList) DeepCopy() *PostgreSQLList

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

func (*PostgreSQLList) DeepCopyInto 

func (in *PostgreSQLList) DeepCopyInto(out *PostgreSQLList)

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

func (*PostgreSQLList) DeepCopyObject 

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

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

type PrivateLink struct {
	//+kubebuilder:validation:MinLength:=3
	AdvertisedHostname string `json:"advertisedHostname"`
}

func (*PrivateLink) DeepCopy 

func (in *PrivateLink) DeepCopy() *PrivateLink

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

func (*PrivateLink) DeepCopyInto 

func (in *PrivateLink) DeepCopyInto(out *PrivateLink)

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

type PrivateLinkStatuses added in v0.1.2 

type PrivateLinkStatuses []*privateLinkStatus

func (PrivateLinkStatuses) DeepCopy added in v0.1.2 

func (in PrivateLinkStatuses) DeepCopy() PrivateLinkStatuses

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

func (PrivateLinkStatuses) DeepCopyInto added in v0.1.2 

func (in PrivateLinkStatuses) DeepCopyInto(out *PrivateLinkStatuses)

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

func (PrivateLinkStatuses) Equal added in v0.1.2 

func (p1 PrivateLinkStatuses) Equal(p2 PrivateLinkStatuses) bool

type PrivateLinkV1 

type PrivateLinkV1 struct {
	IAMPrincipalARNs []string `json:"iamPrincipalARNs"`
}

func (*PrivateLinkV1) DeepCopy 

func (in *PrivateLinkV1) DeepCopy() *PrivateLinkV1

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

func (*PrivateLinkV1) DeepCopyInto 

func (in *PrivateLinkV1) DeepCopyInto(out *PrivateLinkV1)

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

type Redis 

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

	Spec   RedisSpec   `json:"spec,omitempty"`
	Status RedisStatus `json:"status,omitempty"`
}

Redis is the Schema for the redis API

func (*Redis) DeepCopy 

func (in *Redis) DeepCopy() *Redis

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

func (*Redis) DeepCopyInto 

func (in *Redis) DeepCopyInto(out *Redis)

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

func (*Redis) DeepCopyObject 

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

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

func (*Redis) Default 

func (r *Redis) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*Redis) FromInstAPI 

func (r *Redis) FromInstAPI(iData []byte) (*Redis, error)

func (*Redis) GetJobID 

func (r *Redis) GetJobID(jobName string) string

func (*Redis) NewBackupSpec 

func (r *Redis) NewBackupSpec(startTimestamp int) *clusterresourcesv1beta1.ClusterBackup

func (*Redis) NewPatch 

func (r *Redis) NewPatch() client.Patch

func (*Redis) SetupWebhookWithManager 

func (r *Redis) SetupWebhookWithManager(mgr ctrl.Manager, api validation.Validation) error

type RedisDataCentre 

type RedisDataCentre struct {
	DataCentre  `json:",inline"`
	MasterNodes int `json:"masterNodes"`

	//+kubebuilder:validation:Minimum:=0
	//+kubebuilder:validation:Maximum:=5
	ReplicationFactor int `json:"replicationFactor,omitempty"`

	//+kubebuilder:validation:MaxItems:=1
	PrivateLink []*PrivateLink `json:"privateLink,omitempty"`
}

func (*RedisDataCentre) DeepCopy 

func (in *RedisDataCentre) DeepCopy() *RedisDataCentre

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

func (*RedisDataCentre) DeepCopyInto 

func (in *RedisDataCentre) DeepCopyInto(out *RedisDataCentre)

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

func (*RedisDataCentre) ValidateCreate 

func (rdc *RedisDataCentre) ValidateCreate() error

func (*RedisDataCentre) ValidateNodesNumber 

func (rdc *RedisDataCentre) ValidateNodesNumber() error
func (rdc *RedisDataCentre) ValidatePrivateLink() error

func (*RedisDataCentre) ValidateUpdate 

func (rdc *RedisDataCentre) ValidateUpdate() error

type RedisList 

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

RedisList contains a list of Redis

func (*RedisList) DeepCopy 

func (in *RedisList) DeepCopy() *RedisList

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

func (*RedisList) DeepCopyInto 

func (in *RedisList) DeepCopyInto(out *RedisList)

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

func (*RedisList) DeepCopyObject 

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

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

type RedisRestoreCDCInfo 

type RedisRestoreCDCInfo struct {
	CDCID            string `json:"cdcId,omitempty"`
	RestoreToSameVPC bool   `json:"restoreToSameVpc,omitempty"`
	CustomVPCID      string `json:"customVpcId,omitempty"`
	CustomVPCNetwork string `json:"customVpcNetwork,omitempty"`
}

func (*RedisRestoreCDCInfo) DeepCopy 

func (in *RedisRestoreCDCInfo) DeepCopy() *RedisRestoreCDCInfo

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

func (*RedisRestoreCDCInfo) DeepCopyInto 

func (in *RedisRestoreCDCInfo) DeepCopyInto(out *RedisRestoreCDCInfo)

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

type RedisRestoreFrom 

type RedisRestoreFrom struct {
	// Original cluster ID. Backup from that cluster will be used for restore
	ClusterID string `json:"clusterId"`

	// The display name of the restored cluster.
	ClusterNameOverride string `json:"clusterNameOverride,omitempty"`

	// An optional list of cluster data centres for which custom VPC settings will be used.
	CDCInfos []*RedisRestoreCDCInfo `json:"cdcInfos,omitempty"`

	// Timestamp in milliseconds since epoch. All backed up data will be restored for this point in time.
	PointInTime int64 `json:"pointInTime,omitempty"`

	// Only data for the specified indices will be restored, for the point in time.
	IndexNames string `json:"indexNames,omitempty"`

	// The cluster network for this cluster to be restored to.
	ClusterNetwork string `json:"clusterNetwork,omitempty"`
}

func (*RedisRestoreFrom) DeepCopy 

func (in *RedisRestoreFrom) DeepCopy() *RedisRestoreFrom

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

func (*RedisRestoreFrom) DeepCopyInto 

func (in *RedisRestoreFrom) DeepCopyInto(out *RedisRestoreFrom)

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

type RedisSpec 

type RedisSpec struct {
	RestoreFrom *RedisRestoreFrom `json:"restoreFrom,omitempty"`
	Cluster     `json:",inline"`

	// Enables client to node encryption
	ClientEncryption    bool `json:"clientEncryption,omitempty"`
	PasswordAndUserAuth bool `json:"passwordAndUserAuth,omitempty"`
	//+kubebuilder:validation:MaxItems:=2
	DataCentres []*RedisDataCentre `json:"dataCentres,omitempty"`
	Description string             `json:"description,omitempty"`
	UserRefs    []*UserReference   `json:"userRefs,omitempty"`
}

RedisSpec defines the desired state of Redis

func (*RedisSpec) AreDCsEqual 

func (rs *RedisSpec) AreDCsEqual(iDCs []*RedisDataCentre) bool

func (*RedisSpec) DCsFromInstAPI 

func (rs *RedisSpec) DCsFromInstAPI(iDCs []*models.RedisDataCentre) (dcs []*RedisDataCentre)

func (*RedisSpec) DCsToInstAPI 

func (rs *RedisSpec) DCsToInstAPI() (iDCs []*models.RedisDataCentre)

func (*RedisSpec) DCsToInstAPIUpdate 

func (rs *RedisSpec) DCsToInstAPIUpdate() *models.RedisDataCentreUpdate

func (*RedisSpec) DeepCopy 

func (in *RedisSpec) DeepCopy() *RedisSpec

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

func (*RedisSpec) DeepCopyInto 

func (in *RedisSpec) DeepCopyInto(out *RedisSpec)

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

func (*RedisSpec) FromInstAPI 

func (rs *RedisSpec) FromInstAPI(iRedis *models.RedisCluster) RedisSpec

func (*RedisSpec) HasRestore 

func (rs *RedisSpec) HasRestore() bool

func (*RedisSpec) IsEqual 

func (rs *RedisSpec) IsEqual(iRedis RedisSpec) bool

func (*RedisSpec) ToInstAPI 

func (rs *RedisSpec) ToInstAPI() *models.RedisCluster
func (rs *RedisSpec) ValidatePrivateLink() error

func (*RedisSpec) ValidateUpdate 

func (rs *RedisSpec) ValidateUpdate(oldSpec RedisSpec) error

type RedisStatus 

type RedisStatus struct {
	ClusterStatus `json:",inline"`
}

RedisStatus defines the observed state of Redis

func (*RedisStatus) DCsFromInstAPI 

func (rs *RedisStatus) DCsFromInstAPI(iDCs []*models.RedisDataCentre) (dcs []*DataCentreStatus)

func (*RedisStatus) DeepCopy 

func (in *RedisStatus) DeepCopy() *RedisStatus

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

func (*RedisStatus) DeepCopyInto 

func (in *RedisStatus) DeepCopyInto(out *RedisStatus)

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

func (*RedisStatus) FromInstAPI 

func (rs *RedisStatus) FromInstAPI(iRedis *models.RedisCluster) RedisStatus

type RestProxy 

type RestProxy struct {
	IntegrateRestProxyWithSchemaRegistry bool   `json:"integrateRestProxyWithSchemaRegistry"`
	UseLocalSchemaRegistry               bool   `json:"useLocalSchemaRegistry,omitempty"`
	SchemaRegistryServerURL              string `json:"schemaRegistryServerUrl,omitempty"`
	SchemaRegistryUsername               string `json:"schemaRegistryUsername,omitempty"`
	SchemaRegistryPassword               string `json:"schemaRegistryPassword,omitempty"`
	Version                              string `json:"version"`
}

func (*RestProxy) DeepCopy 

func (in *RestProxy) DeepCopy() *RestProxy

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

func (*RestProxy) DeepCopyInto 

func (in *RestProxy) DeepCopyInto(out *RestProxy)

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

type SchemaRegistry 

type SchemaRegistry struct {
	Version string `json:"version"`
}

func (*SchemaRegistry) DeepCopy 

func (in *SchemaRegistry) DeepCopy() *SchemaRegistry

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

func (*SchemaRegistry) DeepCopyInto 

func (in *SchemaRegistry) DeepCopyInto(out *SchemaRegistry)

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

type SharedProvisioning 

type SharedProvisioning struct {
	UseAdvancedVisibility bool `json:"useAdvancedVisibility"`
}

func (*SharedProvisioning) DeepCopy 

func (in *SharedProvisioning) DeepCopy() *SharedProvisioning

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

func (*SharedProvisioning) DeepCopyInto 

func (in *SharedProvisioning) DeepCopyInto(out *SharedProvisioning)

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

type Spark 

type Spark struct {
	Version string `json:"version"`
}

func (*Spark) DeepCopy 

func (in *Spark) DeepCopy() *Spark

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

func (*Spark) DeepCopyInto 

func (in *Spark) DeepCopyInto(out *Spark)

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

type StandardProvisioning 

type StandardProvisioning struct {
	AdvancedVisibility []*AdvancedVisibility `json:"advancedVisibility,omitempty"`
	TargetCassandra    *TargetCassandra      `json:"targetCassandra"`
}

func (*StandardProvisioning) DeepCopy 

func (in *StandardProvisioning) DeepCopy() *StandardProvisioning

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

func (*StandardProvisioning) DeepCopyInto 

func (in *StandardProvisioning) DeepCopyInto(out *StandardProvisioning)

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

type TargetCadence added in v0.1.2 

type TargetCadence struct {
	DependencyCDCID   string `json:"dependencyCdcId"`
	DependencyVPCType string `json:"dependencyVpcType"`
}

func (*TargetCadence) DeepCopy added in v0.1.2 

func (in *TargetCadence) DeepCopy() *TargetCadence

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

func (*TargetCadence) DeepCopyInto added in v0.1.2 

func (in *TargetCadence) DeepCopyInto(out *TargetCadence)

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

type TargetCassandra 

type TargetCassandra struct {
	DependencyCDCID   string `json:"dependencyCdcId"`
	DependencyVPCType string `json:"dependencyVpcType"`
}

func (*TargetCassandra) DeepCopy 

func (in *TargetCassandra) DeepCopy() *TargetCassandra

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

func (*TargetCassandra) DeepCopyInto 

func (in *TargetCassandra) DeepCopyInto(out *TargetCassandra)

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

type TargetCluster 

type TargetCluster struct {
	// Details to connect to a Non-Instaclustr managed cluster. Cannot be provided if targeting an Instaclustr managed cluster.
	ExternalCluster []*ExternalCluster `json:"externalCluster,omitempty"`

	// Details to connect to an Instaclustr managed cluster. Cannot be provided if targeting an external cluster.
	ManagedCluster []*ManagedCluster `json:"managedCluster,omitempty"`
}

func (*TargetCluster) AreExternalClustersEqual 

func (tc *TargetCluster) AreExternalClustersEqual(eClusters []*ExternalCluster) bool

func (*TargetCluster) AreManagedClustersEqual 

func (tc *TargetCluster) AreManagedClustersEqual(mClusters []*ManagedCluster) bool

func (*TargetCluster) DeepCopy 

func (in *TargetCluster) DeepCopy() *TargetCluster

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

func (*TargetCluster) DeepCopyInto 

func (in *TargetCluster) DeepCopyInto(out *TargetCluster)

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

func (*TargetCluster) ExternalClustersToInstAPI 

func (tc *TargetCluster) ExternalClustersToInstAPI() (iClusters []*models.ExternalCluster)

func (*TargetCluster) ManagedClustersToInstAPI 

func (tc *TargetCluster) ManagedClustersToInstAPI() (iClusters []*models.ManagedCluster)

func (*TargetCluster) ToInstAPI 

func (tc *TargetCluster) ToInstAPI() *models.TargetCluster

type TargetKafka 

type TargetKafka struct {
	DependencyCDCID   string `json:"dependencyCdcId"`
	DependencyVPCType string `json:"dependencyVpcType"`
}

func (*TargetKafka) DeepCopy 

func (in *TargetKafka) DeepCopy() *TargetKafka

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

func (*TargetKafka) DeepCopyInto 

func (in *TargetKafka) DeepCopyInto(out *TargetKafka)

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

type TargetOpenSearch 

type TargetOpenSearch struct {
	DependencyCDCID   string `json:"dependencyCdcId"`
	DependencyVPCType string `json:"dependencyVpcType"`
}

func (*TargetOpenSearch) DeepCopy 

func (in *TargetOpenSearch) DeepCopy() *TargetOpenSearch

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

func (*TargetOpenSearch) DeepCopyInto 

func (in *TargetOpenSearch) DeepCopyInto(out *TargetOpenSearch)

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

type TwoFactorDelete 

type TwoFactorDelete struct {
	// Email address which will be contacted when the cluster is requested to be deleted.
	Email string `json:"email"`

	Phone string `json:"phone,omitempty"`
}

func (*TwoFactorDelete) DeepCopy 

func (in *TwoFactorDelete) DeepCopy() *TwoFactorDelete

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

func (*TwoFactorDelete) DeepCopyInto 

func (in *TwoFactorDelete) DeepCopyInto(out *TwoFactorDelete)

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

func (*TwoFactorDelete) ToInstAPI 

func (tfd *TwoFactorDelete) ToInstAPI() *models.TwoFactorDelete

type UserReference 

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

func (*UserReference) DeepCopy 

func (in *UserReference) DeepCopy() *UserReference

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

func (*UserReference) DeepCopyInto 

func (in *UserReference) DeepCopyInto(out *UserReference)

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

type Zookeeper 

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

	Spec   ZookeeperSpec   `json:"spec,omitempty"`
	Status ZookeeperStatus `json:"status,omitempty"`
}

Zookeeper is the Schema for the zookeepers API

func (*Zookeeper) DeepCopy 

func (in *Zookeeper) DeepCopy() *Zookeeper

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

func (*Zookeeper) DeepCopyInto 

func (in *Zookeeper) DeepCopyInto(out *Zookeeper)

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

func (*Zookeeper) DeepCopyObject 

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

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

func (*Zookeeper) Default 

func (z *Zookeeper) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*Zookeeper) FromInstAPI 

func (z *Zookeeper) FromInstAPI(iData []byte) (*Zookeeper, error)

func (*Zookeeper) GetJobID 

func (z *Zookeeper) GetJobID(jobName string) string

func (*Zookeeper) NewDefaultUserSecret added in v0.1.2 

func (a *Zookeeper) NewDefaultUserSecret(username, password string) *v1.Secret

func (*Zookeeper) NewPatch 

func (z *Zookeeper) NewPatch() client.Patch

func (*Zookeeper) SetupWebhookWithManager 

func (z *Zookeeper) SetupWebhookWithManager(mgr ctrl.Manager, api validation.Validation) error

type ZookeeperDataCentre 

type ZookeeperDataCentre struct {
	DataCentre               `json:",inline"`
	ClientToServerEncryption bool     `json:"clientToServerEncryption"`
	EnforceAuthSchemes       []string `json:"enforceAuthSchemes,omitempty"`
	EnforceAuthEnabled       bool     `json:"enforceAuthEnabled,omitempty"`
}

func (*ZookeeperDataCentre) DeepCopy 

func (in *ZookeeperDataCentre) DeepCopy() *ZookeeperDataCentre

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

func (*ZookeeperDataCentre) DeepCopyInto 

func (in *ZookeeperDataCentre) DeepCopyInto(out *ZookeeperDataCentre)

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

func (*ZookeeperDataCentre) ToInstAPI 

func (zdc *ZookeeperDataCentre) ToInstAPI() *models.ZookeeperDataCentre

type ZookeeperList 

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

ZookeeperList contains a list of Zookeeper

func (*ZookeeperList) DeepCopy 

func (in *ZookeeperList) DeepCopy() *ZookeeperList

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

func (*ZookeeperList) DeepCopyInto 

func (in *ZookeeperList) DeepCopyInto(out *ZookeeperList)

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

func (*ZookeeperList) DeepCopyObject 

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

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

type ZookeeperSpec 

type ZookeeperSpec struct {
	Cluster     `json:",inline"`
	DataCentres []*ZookeeperDataCentre `json:"dataCentres"`
}

ZookeeperSpec defines the desired state of Zookeeper

func (*ZookeeperSpec) DCsFromInstAPI 

func (zs *ZookeeperSpec) DCsFromInstAPI(iDCs []*models.ZookeeperDataCentre) (dcs []*ZookeeperDataCentre)

func (*ZookeeperSpec) DCsToInstAPI 

func (zs *ZookeeperSpec) DCsToInstAPI() (dcs []*models.ZookeeperDataCentre)

func (*ZookeeperSpec) DeepCopy 

func (in *ZookeeperSpec) DeepCopy() *ZookeeperSpec

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

func (*ZookeeperSpec) DeepCopyInto 

func (in *ZookeeperSpec) DeepCopyInto(out *ZookeeperSpec)

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

func (*ZookeeperSpec) FromInstAPI 

func (zs *ZookeeperSpec) FromInstAPI(iZook *models.ZookeeperCluster) ZookeeperSpec

func (*ZookeeperSpec) IsEqual 

func (a *ZookeeperSpec) IsEqual(b ZookeeperSpec) bool

func (*ZookeeperSpec) ToInstAPI 

func (zs *ZookeeperSpec) ToInstAPI() *models.ZookeeperCluster

type ZookeeperStatus 

type ZookeeperStatus struct {
	ClusterStatus `json:",inline"`
}

ZookeeperStatus defines the observed state of Zookeeper

func (*ZookeeperStatus) DCsFromInstAPI 

func (zs *ZookeeperStatus) DCsFromInstAPI(iDCs []*models.ZookeeperDataCentre) (dcs []*DataCentreStatus)

func (*ZookeeperStatus) DeepCopy 

func (in *ZookeeperStatus) DeepCopy() *ZookeeperStatus

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

func (*ZookeeperStatus) DeepCopyInto 

func (in *ZookeeperStatus) DeepCopyInto(out *ZookeeperStatus)

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

func (*ZookeeperStatus) FromInstAPI 

func (zs *ZookeeperStatus) FromInstAPI(iZook *models.ZookeeperCluster) ZookeeperStatus

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.