v1beta1

package
v0.1.5 Latest Latest
Warning

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

 Go to latest Published: Jan 24, 2024 License: Apache-2.0 Imports: 25 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 ContainsKubeVirtAddon added in v0.1.5 

func ContainsKubeVirtAddon(ctx context.Context, client client.Client) (bool, error)

func GetDefaultPgUserSecret added in v0.1.2 

func GetDefaultPgUserSecret(
	ctx context.Context,
	name string,
	ns string,
	k8sClient client.Client,
) (*k8scorev1.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) GetClusterID added in v0.1.4 

func (c *Cadence) GetClusterID() string

func (*Cadence) GetDataCentreID added in v0.1.4 

func (c *Cadence) GetDataCentreID(cdcName string) string

func (*Cadence) GetExposePorts added in v0.1.4 

func (c *Cadence) GetExposePorts() []k8scorev1.ServicePort

func (*Cadence) GetHeadlessPorts added in v0.1.4 

func (c *Cadence) GetHeadlessPorts() []k8scorev1.ServicePort

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"`
	OnPremisesSpec *OnPremisesSpec `json:"onPremisesSpec,omitempty"`
	//+kubebuilder:validation:MinItems:=1
	//+kubebuilder:validation:MaxItems:=1
	DataCentres          []*CadenceDataCentre    `json:"dataCentres"`
	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"`
	ResizeSettings       []*ResizeSettings       `json:"resizeSettings,omitempty"`
	UseHTTPAPI           bool                    `json:"useHttpApi,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) GetAvailableUsers added in v0.1.3 

func (c *Cassandra) GetAvailableUsers() References

func (*Cassandra) GetClusterID added in v0.1.3 

func (c *Cassandra) GetClusterID() string

func (*Cassandra) GetDataCentreID added in v0.1.4 

func (c *Cassandra) GetDataCentreID(cdcName string) string

func (*Cassandra) GetExposePorts added in v0.1.4 

func (c *Cassandra) GetExposePorts() []k8scorev1.ServicePort

func (*Cassandra) GetHeadlessPorts added in v0.1.4 

func (c *Cassandra) GetHeadlessPorts() []k8scorev1.ServicePort

func (*Cassandra) GetJobID 

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

func (*Cassandra) GetUserRefs added in v0.1.3 

func (c *Cassandra) GetUserRefs() References

func (*Cassandra) NewBackupSpec 

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

func (*Cassandra) NewPatch 

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

func (*Cassandra) RestoreInfoToInstAPI added in v0.1.3 

func (c *Cassandra) RestoreInfoToInstAPI(restoreData *CassandraRestoreFrom) any

func (*Cassandra) SetAvailableUsers added in v0.1.3 

func (c *Cassandra) SetAvailableUsers(users References)

func (*Cassandra) SetClusterID added in v0.1.3 

func (c *Cassandra) SetClusterID(id string)

func (*Cassandra) SetUserRefs added in v0.1.3 

func (c *Cassandra) SetUserRefs(refs References)

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"`

	// Adds the specified version of Debezium Connector Cassandra to the Cassandra cluster
	// +kubebuilder:validation:MaxItems=1
	Debezium []DebeziumCassandraSpec `json:"debezium,omitempty"`
}

func (*CassandraDataCentre) DebeziumEquals added in v0.1.3 

func (d *CassandraDataCentre) DebeziumEquals(new *CassandraDataCentre) bool

func (*CassandraDataCentre) DebeziumToInstAPI added in v0.1.3 

func (d *CassandraDataCentre) DebeziumToInstAPI() []*models.Debezium

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 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.
	RestoredClusterName string `json:"restoredClusterName,omitempty"`

	// An optional list of cluster data centres for which custom VPC settings will be used.
	CDCConfigs []*RestoreCDCConfig `json:"cdcConfigs,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"`
	OnPremisesSpec      *OnPremisesSpec       `json:"onPremisesSpec,omitempty"`
	Cluster             `json:",inline"`
	DataCentres         []*CassandraDataCentre `json:"dataCentres,omitempty"`
	LuceneEnabled       bool                   `json:"luceneEnabled,omitempty"`
	PasswordAndUserAuth bool                   `json:"passwordAndUserAuth,omitempty"`
	BundledUseOnly      bool                   `json:"bundledUseOnly,omitempty"`
	UserRefs            References             `json:"userRefs,omitempty"`
	//+kubebuilder:validate:MaxItems:=1
	ResizeSettings []*ResizeSettings `json:"resizeSettings,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) DCsUpdateToInstAPI added in v0.1.3 

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

func (*CassandraSpec) DebeziumFromInstAPI added in v0.1.3 

func (cs *CassandraSpec) DebeziumFromInstAPI(iDebeziums []*models.Debezium) (dcs []DebeziumCassandraSpec)

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

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

type CassandraStatus 

type CassandraStatus struct {
	ClusterStatus  `json:",inline"`
	AvailableUsers References `json:"availableUsers,omitempty"`
}

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.
	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) ClusterSettingsNeedUpdate added in v0.1.3 

func (c *Cluster) ClusterSettingsNeedUpdate(iCluster Cluster) bool

func (*Cluster) ClusterSettingsUpdateToInstAPI added in v0.1.2 

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

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

func (*DataCentre) ValidateOnPremisesCreation added in v0.1.4 

func (dc *DataCentre) ValidateOnPremisesCreation() error

type DataCentreStatus 

type DataCentreStatus struct {
	Name             string              `json:"name,omitempty"`
	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"`
	ResizeOperations []*ResizeOperation  `json:"resizeOperations,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 DebeziumCassandraSpec added in v0.1.3 

type DebeziumCassandraSpec struct {
	// KafkaVPCType with only VPC_PEERED supported
	KafkaVPCType      string                              `json:"kafkaVpcType"`
	KafkaTopicPrefix  string                              `json:"kafkaTopicPrefix"`
	KafkaDataCentreID string                              `json:"kafkaCdcId,omitempty"`
	ClusterRef        *clusterresourcesv1beta1.ClusterRef `json:"clusterRef,omitempty"`
	Version           string                              `json:"version"`
}

func (*DebeziumCassandraSpec) DeepCopy added in v0.1.3 

func (in *DebeziumCassandraSpec) DeepCopy() *DebeziumCassandraSpec

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

func (*DebeziumCassandraSpec) DeepCopyInto added in v0.1.3 

func (in *DebeziumCassandraSpec) DeepCopyInto(out *DebeziumCassandraSpec)

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) GetAvailableUsers added in v0.1.3 

func (k *Kafka) GetAvailableUsers() References

func (*Kafka) GetClusterID added in v0.1.3 

func (k *Kafka) GetClusterID() string

func (*Kafka) GetDataCentreID added in v0.1.4 

func (k *Kafka) GetDataCentreID(cdcName string) string

func (*Kafka) GetExposePorts added in v0.1.4 

func (k *Kafka) GetExposePorts() []k8scorev1.ServicePort

func (*Kafka) GetHeadlessPorts added in v0.1.4 

func (k *Kafka) GetHeadlessPorts() []k8scorev1.ServicePort

func (*Kafka) GetJobID 

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

func (*Kafka) GetUserRefs added in v0.1.3 

func (k *Kafka) GetUserRefs() References

func (*Kafka) NewPatch 

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

func (*Kafka) SetAvailableUsers added in v0.1.3 

func (k *Kafka) SetAvailableUsers(users References)

func (*Kafka) SetClusterID added in v0.1.3 

func (k *Kafka) SetClusterID(id string)

func (*Kafka) SetUserRefs added in v0.1.3 

func (k *Kafka) SetUserRefs(refs References)

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) GetClusterID added in v0.1.4 

func (k *KafkaConnect) GetClusterID() string

func (*KafkaConnect) GetDataCentreID added in v0.1.4 

func (k *KafkaConnect) GetDataCentreID(cdcName string) string

func (*KafkaConnect) GetExposePorts added in v0.1.4 

func (k *KafkaConnect) GetExposePorts() []k8scorev1.ServicePort

func (*KafkaConnect) GetHeadlessPorts added in v0.1.4 

func (k *KafkaConnect) GetHeadlessPorts() []k8scorev1.ServicePort

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) *k8scorev1.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"`
	OnPremisesSpec *OnPremisesSpec           `json:"onPremisesSpec,omitempty"`
	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"`
	TargetKafkaClusterID string `json:"targetKafkaClusterId,omitempty"`
}

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"`
	OnPremisesSpec *OnPremisesSpec   `json:"onPremisesSpec,omitempty"`
	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"`
	//+kubebuilder:validation:MaxItems:=1
	ResizeSettings []*ResizeSettings `json:"resizeSettings,omitempty"`

	// 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                 References                `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"`
	AvailableUsers References `json:"availableUsers,omitempty"`
}

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,omitempty"`
	ClusterRef           *clusterresource.ClusterRef `json:"clusterRef,omitempty"`

	// 	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 OnPremisesSpec added in v0.1.4 

type OnPremisesSpec struct {
	EnableAutomation   bool       `json:"enableAutomation"`
	StorageClassName   string     `json:"storageClassName"`
	OSDiskSize         string     `json:"osDiskSize"`
	DataDiskSize       string     `json:"dataDiskSize"`
	SSHGatewayCPU      int64      `json:"sshGatewayCPU,omitempty"`
	SSHGatewayMemory   string     `json:"sshGatewayMemory,omitempty"`
	NodeCPU            int64      `json:"nodeCPU"`
	NodeMemory         string     `json:"nodeMemory"`
	OSImageURL         string     `json:"osImageURL"`
	CloudInitScriptRef *Reference `json:"cloudInitScriptRef"`
}

func (*OnPremisesSpec) DeepCopy added in v0.1.4 

func (in *OnPremisesSpec) DeepCopy() *OnPremisesSpec

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

func (*OnPremisesSpec) DeepCopyInto added in v0.1.4 

func (in *OnPremisesSpec) DeepCopyInto(out *OnPremisesSpec)

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

func (*OnPremisesSpec) ValidateCreation added in v0.1.4 

func (ops *OnPremisesSpec) ValidateCreation() error

func (*OnPremisesSpec) ValidateSSHGatewayCreation added in v0.1.4 

func (ops *OnPremisesSpec) ValidateSSHGatewayCreation() error

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) GetAvailableUsers added in v0.1.3 

func (oss *OpenSearch) GetAvailableUsers() References

func (*OpenSearch) GetClusterID added in v0.1.3 

func (oss *OpenSearch) GetClusterID() string

func (*OpenSearch) GetDataCentreID added in v0.1.4 

func (oss *OpenSearch) GetDataCentreID(cdcName string) string

func (*OpenSearch) GetJobID 

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

func (*OpenSearch) GetUserRefs added in v0.1.3 

func (oss *OpenSearch) GetUserRefs() References

func (*OpenSearch) NewBackupSpec 

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

func (*OpenSearch) NewPatch 

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

func (*OpenSearch) RestoreInfoToInstAPI added in v0.1.3 

func (oss *OpenSearch) RestoreInfoToInstAPI(restoreData *OpenSearchRestoreFrom) any

func (*OpenSearch) SetAvailableUsers added in v0.1.3 

func (oss *OpenSearch) SetAvailableUsers(users References)

func (*OpenSearch) SetClusterID added in v0.1.3 

func (oss *OpenSearch) SetClusterID(id string)

func (*OpenSearch) SetUserRefs added in v0.1.3 

func (oss *OpenSearch) SetUserRefs(refs References)

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. 

func (dc *OpenSearchDataCentre) ValidatePrivateLink() error

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 OpenSearchIngestNodes added in v0.1.3 

type OpenSearchIngestNodes struct {
	NodeSize  string `json:"nodeSize"`
	NodeCount int    `json:"nodeCount"`
}

func (*OpenSearchIngestNodes) DeepCopy added in v0.1.3 

func (in *OpenSearchIngestNodes) DeepCopy() *OpenSearchIngestNodes

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

func (*OpenSearchIngestNodes) DeepCopyInto added in v0.1.3 

func (in *OpenSearchIngestNodes) DeepCopyInto(out *OpenSearchIngestNodes)

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 | OpenSearchIngestNodes
}

+kubebuilder:object:generate:=false

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.
	RestoredClusterName string `json:"restoredClusterName,omitempty"`

	// An optional list of cluster data centres for which custom VPC settings will be used.
	CDCConfigs []*RestoreCDCConfig `json:"cdcConfigs,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"`
}

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:"opensearchDashboards,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                 References              `json:"userRefs,omitempty"`
	//+kubuilder:validation:MaxItems:=1
	ResizeSettings []*ResizeSettings `json:"resizeSettings,omitempty"`
	//+kubuilder:validation:MaxItems:=1
	IngestNodes []*OpenSearchIngestNodes `json:"ingestNodes,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) IngestNodesFromInstAPI added in v0.1.3 

func (oss *OpenSearchSpec) IngestNodesFromInstAPI(iIngestNodes []*models.OpenSearchIngestNodes) (ingestNodes []*OpenSearchIngestNodes)

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"`
	AvailableUsers References `json:"availableUsers,omitempty"`
}

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 PgExtension added in v0.1.5 

type PgExtension struct {
	Name    string `json:"name"`
	Enabled bool   `json:"enabled"`
}

PgExtension defines desired state of an extension

func (*PgExtension) DeepCopy added in v0.1.5 

func (in *PgExtension) DeepCopy() *PgExtension

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

func (*PgExtension) DeepCopyInto added in v0.1.5 

func (in *PgExtension) DeepCopyInto(out *PgExtension)

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

type PgExtensions added in v0.1.5 

type PgExtensions []PgExtension

PgExtensions defines desired state of extensions

func (PgExtensions) DeepCopy added in v0.1.5 

func (in PgExtensions) DeepCopy() PgExtensions

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

func (PgExtensions) DeepCopyInto added in v0.1.5 

func (in PgExtensions) DeepCopyInto(out *PgExtensions)

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

func (PgExtensions) ToInstAPI added in v0.1.5 

func (p PgExtensions) ToInstAPI() []*models.PGExtension

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.
	RestoredClusterName string `json:"restoredClusterName,omitempty"`

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

	// Timestamp in milliseconds since epoch. All backed up data will be restored for this point in time.
	PointInTime int64 `json:"pointInTime,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"`
	OnPremisesSpec        *OnPremisesSpec   `json:"onPremisesSpec,omitempty"`
	DataCentres           []*PgDataCentre   `json:"dataCentres,omitempty"`
	ClusterConfigurations map[string]string `json:"clusterConfigurations,omitempty"`
	SynchronousModeStrict bool              `json:"synchronousModeStrict,omitempty"`
	UserRefs              []*Reference      `json:"userRefs,omitempty"`
	//+kubebuilder:validate:MaxItems:=1
	ResizeSettings []*ResizeSettings `json:"resizeSettings,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="extensions cannot be changed after it is set"
	Extensions PgExtensions `json:"extensions,omitempty"`
}

PgSpec defines the desired state of PostgreSQL +kubebuilder:validation:XValidation:rule="has(self.extensions) == has(oldSelf.extensions)",message="extensions cannot be changed after it is set"

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) ToClusterUpdate added in v0.1.3 

func (pgs *PgSpec) ToClusterUpdate() *models.PGClusterUpdate

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) GetClusterID added in v0.1.4 

func (pg *PostgreSQL) GetClusterID() string

func (*PostgreSQL) GetDataCentreID added in v0.1.4 

func (pg *PostgreSQL) GetDataCentreID(cdcName string) string

func (*PostgreSQL) GetExposePorts added in v0.1.4 

func (pg *PostgreSQL) GetExposePorts() []k8scorev1.ServicePort

func (*PostgreSQL) GetHeadlessPorts added in v0.1.4 

func (pg *PostgreSQL) GetHeadlessPorts() []k8scorev1.ServicePort

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) *k8scorev1.Secret

func (*PostgreSQL) RestoreInfoToInstAPI added in v0.1.3 

func (pg *PostgreSQL) RestoreInfoToInstAPI(restoreData *PgRestoreFrom) any

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) GetAvailableUsers added in v0.1.3 

func (r *Redis) GetAvailableUsers() References

func (*Redis) GetClusterID added in v0.1.3 

func (r *Redis) GetClusterID() string

func (*Redis) GetDataCentreID added in v0.1.4 

func (r *Redis) GetDataCentreID(cdcName string) string

func (*Redis) GetExposePorts added in v0.1.4 

func (r *Redis) GetExposePorts() []k8scorev1.ServicePort

func (*Redis) GetHeadlessPorts added in v0.1.4 

func (r *Redis) GetHeadlessPorts() []k8scorev1.ServicePort

func (*Redis) GetJobID 

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

func (*Redis) GetUserRefs added in v0.1.3 

func (r *Redis) GetUserRefs() References

func (*Redis) NewBackupSpec 

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

func (*Redis) NewPatch 

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

func (*Redis) RestoreInfoToInstAPI added in v0.1.3 

func (r *Redis) RestoreInfoToInstAPI(restoreData *RedisRestoreFrom) any

func (*Redis) SetAvailableUsers added in v0.1.3 

func (r *Redis) SetAvailableUsers(users References)

func (*Redis) SetClusterID added in v0.1.3 

func (r *Redis) SetClusterID(id string)

func (*Redis) SetUserRefs added in v0.1.3 

func (r *Redis) SetUserRefs(refs References)

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 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.
	RestoredClusterName string `json:"restoredClusterName,omitempty"`

	// An optional list of cluster data centres for which custom VPC settings will be used.
	CDCConfigs []*RestoreCDCConfig `json:"cdcConfigs,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"`
}

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"`
	OnPremisesSpec *OnPremisesSpec `json:"onPremisesSpec,omitempty"`

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

	UserRefs References `json:"userRefs,omitempty"`
	//+kubebuilder:validation:MaxItems:=1
	ResizeSettings []*ResizeSettings `json:"resizeSettings,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) DCsUpdateToInstAPI added in v0.1.3 

func (rs *RedisSpec) DCsUpdateToInstAPI() *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"`
	AvailableUsers References `json:"availableUsers,omitempty"`
}

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 Reference added in v0.1.3 

type Reference = apiextensions.ObjectReference

+kubebuilder:object:generate:=false

type References added in v0.1.3 

type References []*apiextensions.ObjectReference

func (References) DeepCopy added in v0.1.3 

func (in References) DeepCopy() References

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

func (References) DeepCopyInto added in v0.1.3 

func (in References) DeepCopyInto(out *References)

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

func (References) Diff added in v0.1.3 

func (old References) Diff(new References) (added, deleted References)

Diff returns difference between two References. Added stores elements which are presented in new References, but aren't presented in old. Deleted stores elements which aren't presented in new References, but are presented in old.

type ReplaceOperation added in v0.1.3 

type ReplaceOperation struct {
	// ID of the new node in the replacement operation
	NewNodeID string `json:"newNodeId,omitempty"`
	// Timestamp of the creation of the node replacement operation
	Created string `json:"created,omitempty"`
	// ID of the node replacement operation
	ID string `json:"id,omitempty"`
	// ID of the node being replaced
	NodeID string `json:"nodeId,omitempty"`
	// Status of the node replacement operation
	Status string `json:"status,omitempty"`
}

func (*ReplaceOperation) DeepCopy added in v0.1.3 

func (in *ReplaceOperation) DeepCopy() *ReplaceOperation

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

func (*ReplaceOperation) DeepCopyInto added in v0.1.3 

func (in *ReplaceOperation) DeepCopyInto(out *ReplaceOperation)

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

type ResizeOperation added in v0.1.3 

type ResizeOperation struct {
	// Number of nodes that can be concurrently resized at a given time
	ConcurrentResizes int `json:"concurrentResizes,omitempty"`
	// Replace operations
	ReplaceOperations []*ReplaceOperation `json:"replaceOperations,omitempty"`
	// Timestamp of the creation of the operation
	Created string `json:"created,omitempty"`
	// Timestamp of the completion of the operation
	Completed string `json:"completed,omitempty"`
	// ID of the operation
	ID string `json:"id,omitempty"`
	// New size of the node
	NewNodeSize string `json:"newNodeSize,omitempty"`
	// Timestamp of when Instaclustr Support has been alerted to the resize operation.
	InstaclustrSupportAlerted string `json:"instaclustrSupportAlerted,omitempty"`
	// Purpose of the node
	NodePurpose string `json:"nodePurpose,omitempty"`
	// Status of the operation
	Status string `json:"status,omitempty"`
}

func (*ResizeOperation) DeepCopy added in v0.1.3 

func (in *ResizeOperation) DeepCopy() *ResizeOperation

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

func (*ResizeOperation) DeepCopyInto added in v0.1.3 

func (in *ResizeOperation) DeepCopyInto(out *ResizeOperation)

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

type ResizeSettings added in v0.1.3 

type ResizeSettings struct {
	NotifySupportContacts bool `json:"notifySupportContacts,omitempty"`
	Concurrency           int  `json:"concurrency,omitempty"`
}

func (*ResizeSettings) DeepCopy added in v0.1.3 

func (in *ResizeSettings) DeepCopy() *ResizeSettings

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

func (*ResizeSettings) DeepCopyInto added in v0.1.3 

func (in *ResizeSettings) DeepCopyInto(out *ResizeSettings)

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

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 RestoreCDCConfig added in v0.1.3 

type RestoreCDCConfig struct {
	CustomVPCSettings *RestoreCustomVPCSettings `json:"customVpcSettings"`
	RestoreMode       string                    `json:"restoreMode"`
	CDCID             string                    `json:"cdcId"`
}

func (*RestoreCDCConfig) DeepCopy added in v0.1.3 

func (in *RestoreCDCConfig) DeepCopy() *RestoreCDCConfig

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

func (*RestoreCDCConfig) DeepCopyInto added in v0.1.3 

func (in *RestoreCDCConfig) DeepCopyInto(out *RestoreCDCConfig)

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

type RestoreCustomVPCSettings added in v0.1.3 

type RestoreCustomVPCSettings struct {
	VpcID   string `json:"vpcId"`
	Network string `json:"network"`
}

func (*RestoreCustomVPCSettings) DeepCopy added in v0.1.3 

func (in *RestoreCustomVPCSettings) DeepCopy() *RestoreCustomVPCSettings

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

func (*RestoreCustomVPCSettings) DeepCopyInto added in v0.1.3 

func (in *RestoreCustomVPCSettings) DeepCopyInto(out *RestoreCustomVPCSettings)

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 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 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) GetClusterID added in v0.1.4 

func (z *Zookeeper) GetClusterID() string

func (*Zookeeper) GetDataCentreID added in v0.1.4 

func (z *Zookeeper) GetDataCentreID(cdcName string) string

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.