v1alpha1

package
v0.0.1 Latest Latest
Warning

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

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

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the clusters v1alpha1 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: "v1alpha1"}

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

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

Functions

func Contains 

func Contains(str string, s []string) bool

Types

type AWSConnectorSettings 

type AWSConnectorSettings struct {
	// 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"`

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

	// 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 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,omitempty"`
	NodesNumber                    int    `json:"nodesNumber,omitempty"`
	ReplicationFactor              int    `json:"replicationFactor,omitempty"`
	Network                        string `json:"network,omitempty"`
	PrivateIPBroadcastForDiscovery bool   `json:"privateIPBroadcastForDiscovery,omitempty"`
	PasswordAndUserAuth            bool   `json:"passwordAndUserAuth,omitempty"`
}

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,omitempty"`
	NodesNumber       int    `json:"nodesNumber,omitempty"`
	Network           string `json:"network"`
	ReplicationFactor int    `json:"replicationFactor,omitempty"`
	PartitionsNumber  int    `json:"partitionsNumber,omitempty"`
}

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,omitempty"`
	ReplicationFactor         int    `json:"replicationFactor,omitempty"`
	NodesPerReplicationFactor int    `json:"nodesPerReplicationFactor,omitempty"`
	Network                   string `json:"network,omitempty"`
}

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

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

func (*Cadence) NewClusterMetadataPatch 

func (cadence *Cadence) NewClusterMetadataPatch() (client.Patch, error)

func (*Cadence) NewPatch 

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

type CadenceDataCentre 

type CadenceDataCentre struct {
	DataCentre       `json:",inline"`
	CadenceNodeCount int  `json:"cadenceNodeCount"`
	ClientEncryption bool `json:"clientEncryption,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) ToAPIv2 

func (cdc *CadenceDataCentre) ToAPIv2() *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"`
	DataCentres                 []*CadenceDataCentre  `json:"dataCentres,omitempty"`
	ConcurrentResizes           int                   `json:"concurrentResizes,omitempty"`
	NotifySupportContacts       bool                  `json:"notifySupportContacts,omitempty"`
	Description                 string                `json:"description,omitempty"`
	ProvisioningType            string                `json:"provisioningType"`
	BundledCassandraSpec        BundledCassandraSpec  `json:"bundledCassandraSpec,omitempty"`
	UseAdvancedVisibility       bool                  `json:"useAdvancedVisibility,omitempty"`
	BundledKafkaSpec            BundledKafkaSpec      `json:"bundledKafkaSpec,omitempty"`
	BundledOpenSearchSpec       BundledOpenSearchSpec `json:"bundledOpenSearchSpec,omitempty"`
	UseCadenceWebAuth           bool                  `json:"useCadenceWebAuth,omitempty"`
	ArchivalS3URI               string                `json:"archivalS3Uri,omitempty"`
	ArchivalS3Region            string                `json:"archivalS3Region,omitempty"`
	AWSAccessKeySecretNamespace string                `json:"awsAccessKeySecretNamespace,omitempty"`
	AWSAccessKeySecretName      string                `json:"awsAccessKeySecretName,omitempty"`
	EnableArchival              bool                  `json:"enableArchival,omitempty"`
	TargetCassandraCDCID        string                `json:"targetCassandraCdcId,omitempty"`
	TargetCassandraVPCType      string                `json:"targetCassandraVpcType,omitempty"`
	TargetKafkaCDCID            string                `json:"targetKafkaCdcId,omitempty"`
	TargetKafkaVPCType          string                `json:"targetKafkaVpcType,omitempty"`
	TargetOpenSearchCDCID       string                `json:"targetOpenSearchCdcId,omitempty"`
	TargetOpenSearchVPCType     string                `json:"targetOpenSearchVpcType,omitempty"`
}

CadenceSpec defines the desired state of Cadence

func (*CadenceSpec) ArchivalToAPIv2 

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

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

func (cs *CadenceSpec) GetSecret(ctx context.Context, k8sClient client.Client) (string, string, error)

func (*CadenceSpec) GetUpdatedFields 

func (cs *CadenceSpec) GetUpdatedFields(oldSpec *CadenceSpec) models.CadenceUpdatedFields

func (*CadenceSpec) SharedProvisioningToAPIv2 

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

func (*CadenceSpec) StandardProvisioningToAPIv2 

func (cs *CadenceSpec) StandardProvisioningToAPIv2() ([]*models.CadenceStandardProvisioning, error)

func (*CadenceSpec) ToInstAPIv1 

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

func (*CadenceSpec) ToInstAPIv2 

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

func (*CadenceSpec) TwoFactorDeleteToAPIv2 

func (cs *CadenceSpec) TwoFactorDeleteToAPIv2() []*modelsv2.TwoFactorDelete

type CadenceStatus 

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

CadenceSpec defines the observed state of Cadence

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.

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

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

func (*Cassandra) NewBackupSpec 

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

func (*Cassandra) NewPatch 

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

func (*Cassandra) SetupWebhookWithManager 

func (r *Cassandra) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Cassandra) ValidateCreate 

func (c *Cassandra) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*Cassandra) ValidateDelete 

func (c *Cassandra) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*Cassandra) ValidateUpdate 

func (c *Cassandra) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type CassandraDataCentre 

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

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.

type CassandraList 

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

CassandraList contains a list of Cassandra

func (*CassandraList) DeepCopy 

func (in *CassandraList) DeepCopy() *CassandraList

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

func (*CassandraList) DeepCopyInto 

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

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

func (*CassandraList) DeepCopyObject 

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

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

type CassandraRestoreDC 

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

func (*CassandraRestoreDC) DeepCopy 

func (in *CassandraRestoreDC) DeepCopy() *CassandraRestoreDC

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

func (*CassandraRestoreDC) DeepCopyInto 

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

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

type CassandraRestoreFrom 

type CassandraRestoreFrom struct {
	ClusterID           string               `json:"clusterID"`
	ClusterNameOverride string               `json:"clusterNameOverride,omitempty"`
	CDCInfos            []CassandraRestoreDC `json:"cdcInfos,omitempty"`
	PointInTime         int64                `json:"pointInTime,omitempty"`
	KeyspaceTables      string               `json:"keyspaceTables,omitempty"`
}

func (*CassandraRestoreFrom) DeepCopy 

func (in *CassandraRestoreFrom) DeepCopy() *CassandraRestoreFrom

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

func (*CassandraRestoreFrom) DeepCopyInto 

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

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

type CassandraSpec 

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

CassandraSpec defines the desired state of Cassandra

func (*CassandraSpec) AreDataCentresEqual 

func (cs *CassandraSpec) AreDataCentresEqual(instDataCentres []*modelsv2.CassandraDataCentre) bool

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

func (cs *CassandraSpec) HasRestore() bool

func (*CassandraSpec) IsSparkEqual 

func (cs *CassandraSpec) IsSparkEqual(instSparks []*modelsv2.Spark) bool

func (*CassandraSpec) IsSpecEqual 

func (cs *CassandraSpec) IsSpecEqual(instSpec *modelsv2.CassandraCluster) bool

func (*CassandraSpec) SetSpecFromInst 

func (cs *CassandraSpec) SetSpecFromInst(instSpec *modelsv2.CassandraCluster)

type CassandraStatus 

type CassandraStatus struct {
	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
	// Important: Run "make" to regenerate code after modifying this file
	ClusterStatus `json:",inline"`
}

CassandraStatus defines the observed state of Cassandra

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.

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() *modelsv2.AWSSetting

func (*CloudProviderSettings) AzureToInstAPI 

func (cps *CloudProviderSettings) AzureToInstAPI() *modelsv2.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() *modelsv2.GCPSetting

func (*CloudProviderSettings) Validate 

func (cps *CloudProviderSettings) Validate() error

type Cluster 

type Cluster struct {
	// Name [ 3 .. 32 ] characters.
	// APIv2 : "name", APIv1 : "clusterName".
	Name    string `json:"name,omitempty"`
	Version string `json:"version,omitempty"`
	// The PCI compliance standards relate to the security of user data and transactional information.
	// Can only be applied clusters provisioned on AWS_VPC, running Cassandra, Kafka, Elasticsearch and Redis.
	// PCI compliance cannot be enabled if the cluster has Spark.
	//
	// APIv1 : "pciCompliantCluster,omitempty"; APIv2 : pciComplianceMode.
	PCICompliance bool `json:"pciCompliance,omitempty"`
	// Required for APIv2, but for APIv1 set "false" as a default.
	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".
	// Required for APIv2, but for APIv1 set "NON_PRODUCTION" as a default.
	SLATier string `json:"slaTier,omitempty"`

	// APIv2, unlike AP1, receives an array of TwoFactorDelete (<= 1 items);
	TwoFactorDelete []*TwoFactorDelete `json:"twoFactorDelete,omitempty"`
}

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

func (c *Cluster) IsTwoFactorDeleteEqual(instTwoFactorDeletes []*modelsv2.TwoFactorDelete) bool

func (*Cluster) SetTwoFactorDeletesFromInstAPI 

func (c *Cluster) SetTwoFactorDeletesFromInstAPI(instTFDs []*modelsv2.TwoFactorDelete)

func (*Cluster) TwoFactorDeletesToInstAPI 

func (c *Cluster) TwoFactorDeletesToInstAPI() []*modelsv2.TwoFactorDelete

func (*Cluster) Validate 

func (c *Cluster) Validate(availableVersions []string) error

type ClusterStatus 

type ClusterStatus struct {
	ID                            string              `json:"id,omitempty"`
	Status                        string              `json:"status,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"`
}

func (*ClusterStatus) DeepCopy 

func (in *ClusterStatus) DeepCopy() *ClusterStatus

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

func (*ClusterStatus) DeepCopyInto 

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

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

type 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) 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.

type DataCentre 

type DataCentre struct {
	// When use one data centre name of field is dataCentreCustomName for APIv1
	Name string `json:"name,omitempty"`

	// Region. APIv1 : "dataCentre"
	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"`

	// APIv2: replicationFactor; APIv1: numberOfRacks
	RacksNumber int32 `json:"racksNumber"`

	// APIv2: numberOfNodes; APIv1: nodesPerRack.
	NodesNumber int32 `json:"nodesNumber"`

	Tags map[string]string `json:"tags,omitempty"`
}

func (*DataCentre) AreCloudProviderSettingsEqual 

func (dc *DataCentre) AreCloudProviderSettingsEqual(
	awsSettings []*modelsv2.AWSSetting,
	gcpSettings []*modelsv2.GCPSetting,
	azureSettings []*modelsv2.AzureSetting) bool

func (*DataCentre) AreTagsEqual 

func (dc *DataCentre) AreTagsEqual(instTags []*modelsv2.Tag) bool

func (*DataCentre) CloudProviderSettingsToInstAPI 

func (dc *DataCentre) CloudProviderSettingsToInstAPI(instDC *modelsv2.DataCentre)

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

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

func (*DataCentre) SetCloudProviderSettingsAPIv1 

func (dc *DataCentre) SetCloudProviderSettingsAPIv1(instProviderSettings []*models.ClusterProvider)

func (*DataCentre) SetCloudProviderSettingsFromInstAPI 

func (dc *DataCentre) SetCloudProviderSettingsFromInstAPI(instDC *modelsv2.DataCentre)

func (*DataCentre) SetTagsFromInstAPI 

func (dc *DataCentre) SetTagsFromInstAPI(instTags []*modelsv2.Tag)

func (DataCentre) TagsToInstAPI 

func (dc DataCentre) TagsToInstAPI(instDC *modelsv2.DataCentre)

func (*DataCentre) Validate 

func (dc *DataCentre) Validate() error

type DataCentreStatus 

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

func (*DataCentreStatus) AreNodesEqual 

func (dcs *DataCentreStatus) AreNodesEqual(instNodes []*models.NodeStatusV2) bool

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.

func (*DataCentreStatus) SetNodesStatusFromInstAPI 

func (dcs *DataCentreStatus) SetNodesStatusFromInstAPI(instNodes []*models.NodeStatusV2)

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.

func (*InterDataCentreReplication) SetInterDCReplicationFromInstAPI 

func (ir *InterDataCentreReplication) SetInterDCReplicationFromInstAPI(instIR *models.PGInterDCReplication)

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.

func (*IntraDataCentreReplication) SetIntraDCReplicationFromInstAPI 

func (ir *IntraDataCentreReplication) SetIntraDCReplicationFromInstAPI(instIR *models.PGIntraDCReplication)

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

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

func (*Kafka) NewPatch 

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

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

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

func (*KafkaConnect) NewPatch 

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

type KafkaConnectList 

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

KafkaConnectList contains a list of KafkaConnect

func (*KafkaConnectList) DeepCopy 

func (in *KafkaConnectList) DeepCopy() *KafkaConnectList

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

func (*KafkaConnectList) DeepCopyInto 

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

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

func (*KafkaConnectList) DeepCopyObject 

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

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

type KafkaConnectSpec 

type KafkaConnectSpec struct {
	Cluster       `json:",inline"`
	DataCentres   []*DataCentre    `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) 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.

type KafkaConnectStatus 

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

KafkaConnectStatus defines the observed state of KafkaConnect

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.

type KafkaDataCentre 

type KafkaDataCentre 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           int32                    `json:"nodesNumber"`
	Tags                  map[string]string        `json:"tags,omitempty"`
}

func (*KafkaDataCentre) DeepCopy 

func (in *KafkaDataCentre) DeepCopy() *KafkaDataCentre

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

func (*KafkaDataCentre) DeepCopyInto 

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

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

type KafkaList 

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

KafkaList contains a list of Kafka

func (*KafkaList) DeepCopy 

func (in *KafkaList) DeepCopy() *KafkaList

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

func (*KafkaList) DeepCopyInto 

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

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

func (*KafkaList) DeepCopyObject 

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

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

type KafkaSpec 

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

	// ReplicationFactorNumber to use for new topic.
	// Also represents the number of racks to use when allocating nodes.
	ReplicationFactorNumber int32 `json:"replicationFactorNumber"`

	// PartitionsNumber number of partitions to use when created new topics.
	PartitionsNumber          int32              `json:"partitionsNumber"`
	RestProxy                 []*RestProxy       `json:"restProxy,omitempty"`
	AllowDeleteTopics         bool               `json:"allowDeleteTopics"`
	AutoCreateTopics          bool               `json:"autoCreateTopics"`
	ClientToClusterEncryption bool               `json:"clientToClusterEncryption"`
	DataCentres               []*KafkaDataCentre `json:"dataCentres"`

	// Provision additional dedicated nodes for Apache Zookeeper to run on.
	// Zookeeper nodes will be co-located with Kafka if this is not provided
	DedicatedZookeeper                []*DedicatedZookeeper     `json:"dedicatedZookeeper,omitempty"`
	ClientBrokerAuthWithMTLS          bool                      `json:"clientBrokerAuthWithMtls,omitempty"`
	ClientAuthBrokerWithoutEncryption bool                      `json:"clientAuthBrokerWithoutEncryption,omitempty"`
	ClientAuthBrokerWithEncryption    bool                      `json:"clientAuthBrokerWithEncryption,omitempty"`
	KarapaceRestProxy                 []*KarapaceRestProxy      `json:"karapaceRestProxy,omitempty"`
	KarapaceSchemaRegistry            []*KarapaceSchemaRegistry `json:"karapaceSchemaRegistry,omitempty"`
}

KafkaSpec defines the desired state of Kafka

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.

type KafkaStatus 

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

	// +optional
	// CurrentClusterOperation indicates if the cluster is currently performing any restructuring operation
	// such as being created or resized. Enum: "NO_OPERATION" "OPERATION_IN_PROGRESS" "OPERATION_FAILED"
	CurrentClusterOperation string `json:"currentClusterOperationStatus"`
}

KafkaStatus defines the observed state of Kafka

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.

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 ManagedCluster 

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

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

func (*ManagedCluster) DeepCopy 

func (in *ManagedCluster) DeepCopy() *ManagedCluster

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

func (*ManagedCluster) DeepCopyInto 

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

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

type Node 

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

func (*Node) DeepCopy 

func (in *Node) DeepCopy() *Node

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

func (*Node) DeepCopyInto 

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

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

func (*Node) IsNodeEqual 

func (n *Node) IsNodeEqual(instNode *models.NodeStatusV2) bool

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

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

func (*OpenSearch) NewBackupSpec 

func (r *OpenSearch) NewBackupSpec(startTimestamp int) *clusterresourcesv1alpha1.ClusterBackup

func (*OpenSearch) NewPatch 

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

type OpenSearchDataCentre 

type OpenSearchDataCentre struct {
	DataCentre                   `json:",inline"`
	DedicatedMasterNodes         bool   `json:"dedicatedMasterNodes,omitempty"`
	MasterNodeSize               string `json:"masterNodeSize,omitempty"`
	OpenSearchDashboardsNodeSize string `json:"openSearchDashboardsNodeSize,omitempty"`
	IndexManagementPlugin        bool   `json:"indexManagementPlugin,omitempty"`
	AlertingPlugin               bool   `json:"alertingPlugin,omitempty"`
	ICUPlugin                    bool   `json:"icuPlugin,omitempty"`
	KNNPlugin                    bool   `json:"knnPlugin,omitempty"`
	NotificationsPlugin          bool   `json:"notificationsPlugin,omitempty"`
	ReportsPlugin                bool   `json:"reportsPlugin,omitempty"`
}

func (*OpenSearchDataCentre) AreOptionsEqual 

func (odc *OpenSearchDataCentre) AreOptionsEqual(instOptions models.BundleOptions) bool

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 (*OpenSearchDataCentre) IsClusterProviderEqual 

func (odc *OpenSearchDataCentre) IsClusterProviderEqual(instClusterProvider []*models.ClusterProvider) bool

func (*OpenSearchDataCentre) IsDataCentreEqual 

func (odc *OpenSearchDataCentre) IsDataCentreEqual(instDC *models.DataCentreSpec, privateLink *PrivateLink) bool

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 OpenSearchRestoreCDCInfo 

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

func (*OpenSearchRestoreCDCInfo) DeepCopy 

func (in *OpenSearchRestoreCDCInfo) DeepCopy() *OpenSearchRestoreCDCInfo

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

func (*OpenSearchRestoreCDCInfo) DeepCopyInto 

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

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

type OpenSearchRestoreFrom 

type OpenSearchRestoreFrom struct {
	ClusterID           string                      `json:"clusterId"`
	ClusterNameOverride string                      `json:"clusterNameOverride,omitempty"`
	CDCInfos            []*OpenSearchRestoreCDCInfo `json:"cdcInfos,omitempty"`
	PointInTime         int64                       `json:"pointInTime,omitempty"`
	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"`
	ConcurrentResizes     int                     `json:"concurrentResizes,omitempty"`
	NotifySupportContacts bool                    `json:"notifySupportContacts,omitempty"`
	Description           string                  `json:"description,omitempty"`
	PrivateLink           *PrivateLink            `json:"privateLink,omitempty"`
}

OpenSearchSpec defines the desired state of OpenSearch

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

func (oss *OpenSearchSpec) HasRestore() bool

func (*OpenSearchSpec) IsSpecEqual 

func (oss *OpenSearchSpec) IsSpecEqual(instSpec *models.ClusterSpec) bool

func (*OpenSearchSpec) SetSpecFromInst 

func (oss *OpenSearchSpec) SetSpecFromInst(instSpec *models.ClusterSpec) bool

type OpenSearchStatus 

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

OpenSearchStatus defines the observed state of OpenSearch

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.

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

type PgDataCentre struct {
	DataCentre `json:",inline"`
	// PostgreSQL options
	ClientEncryption           bool                          `json:"clientEncryption"`
	PostgresqlNodeCount        int32                         `json:"postgresqlNodeCount"`
	InterDataCentreReplication []*InterDataCentreReplication `json:"interDataCentreReplication,omitempty"`
	IntraDataCentreReplication []*IntraDataCentreReplication `json:"intraDataCentreReplication"`
	// PGBouncer options
	PGBouncerVersion string `json:"pgBouncerVersion,omitempty"`
	PoolMode         string `json:"poolMode,omitempty"`
}

func (*PgDataCentre) AreInterDCReplicationsEqual 

func (pdc *PgDataCentre) AreInterDCReplicationsEqual(instIRs []*models.PGInterDCReplication) bool

func (*PgDataCentre) AreIntraDCReplicationsEqual 

func (pdc *PgDataCentre) AreIntraDCReplicationsEqual(instIRs []*models.PGIntraDCReplication) bool

func (*PgDataCentre) ArePGBouncersEqual 

func (pdc *PgDataCentre) ArePGBouncersEqual(instPGBs []*models.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(instDC *models.PGDataCentre)

func (*PgDataCentre) IntraDCReplicationToInstAPI 

func (pdc *PgDataCentre) IntraDCReplicationToInstAPI(instDC *models.PGDataCentre)

func (*PgDataCentre) PGBouncerToInstAPI 

func (pdc *PgDataCentre) PGBouncerToInstAPI(instDC *models.PGDataCentre)

func (*PgDataCentre) SetDCFromInstAPI 

func (pdc *PgDataCentre) SetDCFromInstAPI(instDC *models.PGDataCentre)

func (*PgDataCentre) SetInterDCReplicationsFromInstAPI 

func (pdc *PgDataCentre) SetInterDCReplicationsFromInstAPI(instIRs []*models.PGInterDCReplication)

func (*PgDataCentre) SetIntraDCReplicationsFromInstAPI 

func (pdc *PgDataCentre) SetIntraDCReplicationsFromInstAPI(instIRs []*models.PGIntraDCReplication)

func (*PgDataCentre) SetPGBouncerFromInstAPI 

func (pdc *PgDataCentre) SetPGBouncerFromInstAPI(instPGBs []*models.PGBouncer)

func (*PgDataCentre) ToInstAPI 

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

func (*PgDataCentre) ValidatePGBouncer 

func (pdc *PgDataCentre) ValidatePGBouncer() error

type PgRestoreCDCInfo 

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

func (*PgRestoreCDCInfo) DeepCopy 

func (in *PgRestoreCDCInfo) DeepCopy() *PgRestoreCDCInfo

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

func (*PgRestoreCDCInfo) DeepCopyInto 

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

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

type PgRestoreFrom 

type PgRestoreFrom struct {
	ClusterID           string              `json:"clusterId"`
	ClusterNameOverride string              `json:"clusterNameOverride,omitempty"`
	CDCInfos            []*PgRestoreCDCInfo `json:"cdcInfos,omitempty"`
	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"`
	DataCentres           []*PgDataCentre   `json:"dataCentres,omitempty"`
	ClusterConfigurations map[string]string `json:"clusterConfigurations,omitempty"`
	Description           string            `json:"description,omitempty"`
	SynchronousModeStrict bool              `json:"synchronousModeStrict,omitempty"`
}

PgSpec defines the desired state of PostgreSQL

func (*PgSpec) AreDCsEqual 

func (pgs *PgSpec) AreDCsEqual(instDCs []*models.PGDataCentre) bool

func (*PgSpec) AreSpecsEqual 

func (pgs *PgSpec) AreSpecsEqual(instCluster *models.PGStatus) bool

func (*PgSpec) DataCentresToInstAPI 

func (pgs *PgSpec) DataCentresToInstAPI() []*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) HasRestore 

func (pgs *PgSpec) HasRestore() bool

func (*PgSpec) SetDCsFromInstAPI 

func (pgs *PgSpec) SetDCsFromInstAPI(instDCs []*models.PGDataCentre)

func (*PgSpec) SetDefaultValues 

func (pgs *PgSpec) SetDefaultValues()

SetDefaultValues should be implemented using validation webhook TODO https://github.com/instaclustr/operator/issues/219

func (*PgSpec) SetSpecFromInstAPI 

func (pgs *PgSpec) SetSpecFromInstAPI(instCluster *models.PGStatus)

func (*PgSpec) ToInstAPI 

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

type PgStatus 

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

PgStatus defines the observed state of PostgreSQL

func (*PgStatus) AreDCsEqual 

func (ps *PgStatus) AreDCsEqual(instDCs []*models.PGDataCentre) bool

func (*PgStatus) AreStatusesEqual 

func (ps *PgStatus) AreStatusesEqual(instStatus *models.PGStatus) bool

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

func (ps *PgStatus) SetDCsFromInstAPI(instDCs []*models.PGDataCentre)

func (*PgStatus) SetStatusFromInstAPI 

func (ps *PgStatus) SetStatusFromInstAPI(instCluster *models.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) GetJobID 

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

func (*PostgreSQL) NewBackupSpec 

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

func (*PostgreSQL) NewPatch 

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

func (*PostgreSQL) SetupWebhookWithManager 

func (r *PostgreSQL) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*PostgreSQL) ValidateCreate 

func (pg *PostgreSQL) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*PostgreSQL) ValidateDelete 

func (r *PostgreSQL) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*PostgreSQL) ValidateUpdate 

func (r *PostgreSQL) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

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 {
	IAMPrincipalARNs []string `json:"iamPrincipalARNs"`
}

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

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

func (*Redis) NewBackupSpec 

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

func (*Redis) NewPatch 

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

func (*Redis) SetupWebhookWithManager 

func (r *Redis) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Redis) ValidateCreate 

func (r *Redis) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*Redis) ValidateDelete 

func (r *Redis) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*Redis) ValidateUpdate 

func (r *Redis) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type RedisDataCentre 

type RedisDataCentre struct {
	DataCentre   `json:",inline"`
	MasterNodes  int32 `json:"masterNodes"`
	ReplicaNodes int32 `json:"replicaNodes"`
	PasswordAuth bool  `json:"passwordAuth,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.

type RedisList 

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

RedisList contains a list of Redis

func (*RedisList) DeepCopy 

func (in *RedisList) DeepCopy() *RedisList

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

func (*RedisList) DeepCopyInto 

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

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

func (*RedisList) DeepCopyObject 

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

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

type RedisRestoreCDCInfo 

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

func (*RedisRestoreCDCInfo) DeepCopy 

func (in *RedisRestoreCDCInfo) DeepCopy() *RedisRestoreCDCInfo

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

func (*RedisRestoreCDCInfo) DeepCopyInto 

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

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

type RedisRestoreFrom 

type RedisRestoreFrom struct {
	ClusterID           string                 `json:"clusterId"`
	ClusterNameOverride string                 `json:"clusterNameOverride,omitempty"`
	CDCInfos            []*RedisRestoreCDCInfo `json:"cdcInfos,omitempty"`
	PointInTime         int64                  `json:"pointInTime,omitempty"`
	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"`

	// Enables client to node encryption
	ClientEncryption      bool               `json:"clientEncryption,omitempty"`
	PasswordAndUserAuth   bool               `json:"passwordAndUserAuth,omitempty"`
	DataCentres           []*RedisDataCentre `json:"dataCentres,omitempty"`
	ConcurrentResizes     int                `json:"concurrentResizes,omitempty"`
	NotifySupportContacts bool               `json:"notifySupportContacts,omitempty"`
	Description           string             `json:"description,omitempty"`
}

RedisSpec defines the desired state of Redis

func (*RedisSpec) AreDataCentresEqual 

func (rs *RedisSpec) AreDataCentresEqual(instDCs []*models.RedisDataCentre) bool

func (*RedisSpec) DataCentresToInstAPIv2 

func (rs *RedisSpec) DataCentresToInstAPIv2() []*models.RedisDataCentre

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

func (rs *RedisSpec) HasRestore() bool

func (*RedisSpec) IsSpecEqual 

func (rs *RedisSpec) IsSpecEqual(instSpec *models.RedisCluster) bool

func (*RedisSpec) SetDCsFromInst 

func (rs *RedisSpec) SetDCsFromInst(instDCs []*models.RedisDataCentre)

func (*RedisSpec) SetSpecFromInst 

func (rs *RedisSpec) SetSpecFromInst(instSpec *models.RedisCluster)

func (*RedisSpec) ToInstAPIv2 

func (rs *RedisSpec) ToInstAPIv2() *models.RedisCluster

type RedisStatus 

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

RedisStatus defines the observed state of Redis

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.

type ResizedDataCentre 

type ResizedDataCentre struct {
	CurrentNodeSize      string
	NewNodeSize          string
	DataCentreID         string
	Provider             string
	MasterNewNodeSize    string
	DashboardNewNodeSize string
}

func (*ResizedDataCentre) DeepCopy 

func (in *ResizedDataCentre) DeepCopy() *ResizedDataCentre

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

func (*ResizedDataCentre) DeepCopyInto 

func (in *ResizedDataCentre) DeepCopyInto(out *ResizedDataCentre)

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

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

func (*Spark) DeepCopy 

func (in *Spark) DeepCopy() *Spark

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

func (*Spark) DeepCopyInto 

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

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

type 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 a Instaclustr managed cluster. Cannot be provided if targeting an external cluster.
	ManagedCluster []*ManagedCluster `json:"managedCluster,omitempty"`
}

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.

type TwoFactorDelete 

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

	// APIv1: deleteVerifyPhone; APIv2: confirmationPhoneNumber.
	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() *modelsv2.TwoFactorDelete

func (*TwoFactorDelete) ToInstAPIv1 

func (twoFactorDelete *TwoFactorDelete) ToInstAPIv1() *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) GetJobID 

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

func (*Zookeeper) NewPatch 

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

type ZookeeperDataCentre 

type ZookeeperDataCentre struct {
	Name                     string                   `json:"name,omitempty"`
	Region                   string                   `json:"region"`
	CloudProvider            string                   `json:"cloudProvider"`
	ProviderAccountName      string                   `json:"providerAccountName,omitempty"`
	CloudProviderSettings    []*CloudProviderSettings `json:"cloudProviderSettings,omitempty"`
	Network                  string                   `json:"network"`
	NodeSize                 string                   `json:"nodeSize"`
	NodesNumber              int32                    `json:"nodesNumber"`
	Tags                     map[string]string        `json:"tags,omitempty"`
	ClientToServerEncryption bool                     `json:"clientToServerEncryption"`
}

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.

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 {
	Name                  string                 `json:"name"`
	Version               string                 `json:"version"`
	SLATier               string                 `json:"slaTier"`
	TwoFactorDelete       []*TwoFactorDelete     `json:"twoFactorDelete,omitempty"`
	PrivateNetworkCluster bool                   `json:"privateNetworkCluster,omitempty"`
	DataCentres           []*ZookeeperDataCentre `json:"dataCentres"`
}

ZookeeperSpec defines the desired state of Zookeeper

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.

type ZookeeperStatus 

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

ZookeeperStatus defines the observed state of Zookeeper

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.

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.