Documentation

Overview

    +groupName=kubedb.com

    Index

    Constants

    View Source
    const (
    	DatabaseNamePrefix = "kubedb"
    
    	GenericKey = "kubedb.com"
    
    	LabelDatabaseKind = GenericKey + "/kind"
    	LabelDatabaseName = GenericKey + "/name"
    	LabelRole         = GenericKey + "/role"
    
    	ComponentDatabase = "database"
    	RoleStats         = "stats"
    	DefaultStatsPath  = "/metrics"
    
    	PostgresKey      = ResourceSingularPostgres + "." + GenericKey
    	ElasticsearchKey = ResourceSingularElasticsearch + "." + GenericKey
    	MySQLKey         = ResourceSingularMySQL + "." + GenericKey
    	PerconaXtraDBKey = ResourceSingularPerconaXtraDB + "." + GenericKey
    	MongoDBKey       = ResourceSingularMongoDB + "." + GenericKey
    	RedisKey         = ResourceSingularRedis + "." + GenericKey
    	MemcachedKey     = ResourceSingularMemcached + "." + GenericKey
    	EtcdKey          = ResourceSingularEtcd + "." + GenericKey
    	ProxySQLKey      = ResourceSingularProxySQL + "." + GenericKey
    
    	AnnotationInitialized = GenericKey + "/initialized"
    	AnnotationJobType     = GenericKey + "/job-type"
    
    	PrometheusExporterPortNumber = 56790
    	PrometheusExporterPortName   = "prom-http"
    
    	JobTypeBackup  = "backup"
    	JobTypeRestore = "restore"
    
    	ElasticsearchRestPort        = 9200
    	ElasticsearchRestPortName    = "http"
    	ElasticsearchNodePort        = 9300
    	ElasticsearchNodePortName    = "transport"
    	ElasticsearchMetricsPort     = 9600
    	ElasticsearchMetricsPortName = "metrics"
    
    	MongoDBShardPort           = 27017
    	MongoDBConfigdbPort        = 27017
    	MongoDBMongosPort          = 27017
    	MongoDBKeyFileSecretSuffix = "key"
    	MongoDBRootUsername        = "root"
    
    	MySQLMetricsExporterConfigSecretSuffix = "metrics-exporter-config"
    	MySQLNodePort                          = 3306
    	MySQLGroupComPort                      = 33060
    	MySQLMaxGroupMembers                   = 9
    	// The recommended MySQL server version for group replication (GR)
    	MySQLGRRecommendedVersion       = "5.7.25"
    	MySQLDefaultGroupSize           = 3
    	MySQLDefaultBaseServerID  int64 = 1
    	// The server id for each group member must be unique and in the range [1, 2^32 - 1]
    	// And the maximum group size is 9. So MySQLMaxBaseServerID is the maximum safe value
    	// for BaseServerID calculated as max MySQL server_id value - max Replication Group size.
    	// xref: https://dev.mysql.com/doc/refman/5.7/en/replication-options.html
    	MySQLMaxBaseServerID int64 = ((1 << 32) - 1) - 9
    
    	PerconaXtraDBClusterRecommendedVersion    = "5.7"
    	PerconaXtraDBMaxClusterNameLength         = 32
    	PerconaXtraDBStandaloneReplicas           = 1
    	PerconaXtraDBDefaultClusterSize           = 3
    	PerconaXtraDBDataMountPath                = "/var/lib/mysql"
    	PerconaXtraDBDataLostFoundPath            = PerconaXtraDBDataMountPath + "lost+found"
    	PerconaXtraDBInitDBMountPath              = "/docker-entrypoint-initdb.d"
    	PerconaXtraDBCustomConfigMountPath        = "/etc/percona-server.conf.d/"
    	PerconaXtraDBClusterCustomConfigMountPath = "/etc/percona-xtradb-cluster.conf.d/"
    
    	LabelProxySQLName        = ProxySQLKey + "/name"
    	LabelProxySQLLoadBalance = ProxySQLKey + "/load-balance"
    
    	ProxySQLMySQLNodePort         = 6033
    	ProxySQLAdminPort             = 6032
    	ProxySQLAdminPortName         = "admin"
    	ProxySQLDataMountPath         = "/var/lib/proxysql"
    	ProxySQLCustomConfigMountPath = "/etc/custom-config"
    
    	RedisShardKey   = RedisKey + "/shard"
    	RedisNodePort   = 6379
    	RedisGossipPort = 16379
    
    	RedisKeyFileSecretSuffix = "key"
    	RedisPEMSecretSuffix     = "pem"
    	RedisRootUsername        = "root"
    
    	PgBouncerUpstreamServerCA = "upstream-server-ca.crt"
    
    	MySQLContainerReplicationModeDetectorName = "replication-mode-detector"
    	MySQLPodPrimary                           = "primary"
    	MySQLPodSecondary                         = "secondary"
    	MySQLLabelRole                            = MySQLKey + "/role"
    
    	ContainerExporterName = "exporter"
    	LocalHost             = "localhost"
    	LocalHostIP           = "127.0.0.1"
    )
    View Source
    const (
    	ResourceCodeElasticsearch     = "es"
    	ResourceKindElasticsearch     = "Elasticsearch"
    	ResourceSingularElasticsearch = "elasticsearch"
    	ResourcePluralElasticsearch   = "elasticsearches"
    )
    View Source
    const (
    	ResourceCodeEtcd     = "etc"
    	ResourceKindEtcd     = "Etcd"
    	ResourceSingularEtcd = "etcd"
    	ResourcePluralEtcd   = "etcds"
    )
    View Source
    const (
    	ResourceCodeMariaDB     = "md"
    	ResourceKindMariaDB     = "MariaDB"
    	ResourceSingularMariaDB = "mariadb"
    	ResourcePluralMariaDB   = "mariadbs"
    )
    View Source
    const (
    	ResourceCodeMemcached     = "mc"
    	ResourceKindMemcached     = "Memcached"
    	ResourceSingularMemcached = "memcached"
    	ResourcePluralMemcached   = "memcacheds"
    )
    View Source
    const (
    	TLSCAKeyFileName    = "ca.key"
    	TLSCACertFileName   = "ca.crt"
    	MongoPemFileName    = "mongo.pem"
    	MongoClientFileName = "client.pem"
    	MongoCertDirectory  = "/var/run/mongodb/tls"
    
    	MongoDBShardLabelKey  = "mongodb.kubedb.com/node.shard"
    	MongoDBConfigLabelKey = "mongodb.kubedb.com/node.config"
    	MongoDBMongosLabelKey = "mongodb.kubedb.com/node.mongos"
    
    	MongoDBShardAffinityTemplateVar = "SHARD_INDEX"
    )
    View Source
    const (
    	ResourceCodeMongoDB     = "mg"
    	ResourceKindMongoDB     = "MongoDB"
    	ResourceSingularMongoDB = "mongodb"
    	ResourcePluralMongoDB   = "mongodbs"
    
    	MongoDBInitInstallContainerName   = "copy-config"
    	MongoDBInitBootstrapContainerName = "bootstrap"
    	MongoDBConfigDirectoryName        = "configdir"
    	MongoDBContainerName              = ResourceSingularMongoDB
    )
    View Source
    const (
    	ResourceCodeMySQL     = "my"
    	ResourceKindMySQL     = "MySQL"
    	ResourceSingularMySQL = "mysql"
    	ResourcePluralMySQL   = "mysqls"
    )
    View Source
    const (
    	ResourceCodePerconaXtraDB     = "px"
    	ResourceKindPerconaXtraDB     = "PerconaXtraDB"
    	ResourceSingularPerconaXtraDB = "perconaxtradb"
    	ResourcePluralPerconaXtraDB   = "perconaxtradbs"
    )
    View Source
    const (
    	ResourceCodePgBouncer     = "pb"
    	ResourceKindPgBouncer     = "PgBouncer"
    	ResourceSingularPgBouncer = "pgbouncer"
    	ResourcePluralPgBouncer   = "pgbouncers"
    )
    View Source
    const (
    	ResourceCodePostgres     = "pg"
    	ResourceKindPostgres     = "Postgres"
    	ResourceSingularPostgres = "postgres"
    	ResourcePluralPostgres   = "postgreses"
    )
    View Source
    const (
    	ResourceCodeProxySQL     = "psql"
    	ResourceKindProxySQL     = "ProxySQL"
    	ResourceSingularProxySQL = "proxysql"
    	ResourcePluralProxySQL   = "proxysqls"
    )
    View Source
    const (
    	ResourceCodeRedis     = "rd"
    	ResourceKindRedis     = "Redis"
    	ResourceSingularRedis = "redis"
    	ResourcePluralRedis   = "redises"
    )
    View Source
    const (
    	ElasticsearchNodeAffinityTemplateVar = "NODE_ROLE"
    )
    View Source
    const (
    	RedisShardAffinityTemplateVar = "SHARD_INDEX"
    )

    Variables

    View Source
    var (
    	ErrInvalidLengthGenerated        = fmt.Errorf("proto: negative length found during unmarshaling")
    	ErrIntOverflowGenerated          = fmt.Errorf("proto: integer overflow")
    	ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")
    )
    View Source
    var (
    	// TODO: move SchemeBuilder with zz_generated.deepcopy.go to k8s.io/api.
    	// localSchemeBuilder and AddToScheme will stay in k8s.io/kubernetes.
    	SchemeBuilder runtime.SchemeBuilder
    
    	AddToScheme = localSchemeBuilder.AddToScheme
    )
    View Source
    var SchemeGroupVersion = schema.GroupVersion{Group: kubedb.GroupName, Version: "v1alpha1"}

    Functions

    func Kind

    func Kind(kind string) schema.GroupKind

      Kind takes an unqualified kind and returns a Group qualified GroupKind

      func Resource

      func Resource(resource string) schema.GroupResource

        Resource takes an unqualified resource and returns a Group qualified GroupResource

        Types

        type ClusterAuthMode

        type ClusterAuthMode string

          ClusterAuthMode represents the clusterAuthMode of mongodb clusters ( replicaset or sharding) ref: https://docs.mongodb.com/manual/reference/program/mongod/#cmdoption-mongod-clusterauthmode +kubebuilder:validation:Enum=keyFile;sendKeyFile;sendX509;x509

          const (
          	// ClusterAuthModeKeyFile represents `keyFile` mongodb clusterAuthMode. In this mode, Use a keyfile for authentication. Accept only keyfiles.
          	ClusterAuthModeKeyFile ClusterAuthMode = "keyFile"
          
          	// ClusterAuthModeSendKeyFile represents `sendKeyFile` mongodb clusterAuthMode.
          	// This mode is for rolling upgrade purposes. Send a keyfile for authentication but can accept both keyfiles
          	// and x.509 certificates.
          	ClusterAuthModeSendKeyFile ClusterAuthMode = "sendKeyFile"
          
          	// ClusterAuthModeSendX509 represents `sendx509` mongodb clusterAuthMode. This mode is usually for rolling upgrade purposes.
          	// Send the x.509 certificate for authentication but can accept both keyfiles and x.509 certificates.
          	ClusterAuthModeSendX509 ClusterAuthMode = "sendX509"
          
          	// ClusterAuthModeX509 represents `x509` mongodb clusterAuthMode. This is the recommended clusterAuthMode.
          	// Send the x.509 certificate for authentication and accept only x.509 certificates.
          	ClusterAuthModeX509 ClusterAuthMode = "x509"
          )

          type ConnectionPoolConfig

          type ConnectionPoolConfig struct {
          	// Port is the port number on which PgBouncer listens to clients. Default: 5432.
          	// +optional
          	Port *int32 `json:"port,omitempty" protobuf:"varint,1,opt,name=port"`
          	// PoolMode is the pooling mechanism type. Default: session.
          	// +optional
          	PoolMode string `json:"poolMode,omitempty" protobuf:"bytes,2,opt,name=poolMode"`
          	// MaxClientConnections is the maximum number of allowed client connections. Default: 100.
          	// +optional
          	MaxClientConnections *int64 `json:"maxClientConnections,omitempty" protobuf:"varint,3,opt,name=maxClientConnections"`
          	// DefaultPoolSize specifies how many server connections to allow per user/database pair. Default: 20.
          	// +optional
          	DefaultPoolSize *int64 `json:"defaultPoolSize,omitempty" protobuf:"varint,4,opt,name=defaultPoolSize"`
          	// MinPoolSize is used to add more server connections to pool if below this number. Default: 0 (disabled).
          	// +optional
          	MinPoolSize *int64 `json:"minPoolSize,omitempty" protobuf:"varint,5,opt,name=minPoolSize"`
          	// ReservePoolSize specifies how many additional connections to allow to a pool. 0 disables. Default: 0 (disabled).
          	// +optional
          	ReservePoolSize *int64 `json:"reservePoolSize,omitempty" protobuf:"varint,6,opt,name=reservePoolSize"`
          	// ReservePoolTimeoutSeconds is the number of seconds in which if a client has not been serviced,
          	// pgbouncer enables use of additional connections from reserve pool. 0 disables. Default: 5.0.
          	// +optional
          	ReservePoolTimeoutSeconds *int64 `json:"reservePoolTimeoutSeconds,omitempty" protobuf:"varint,7,opt,name=reservePoolTimeoutSeconds"`
          	// MaxDBConnections is the maximum number of connections allowed per-database. Default: unlimited.
          	// +optional
          	MaxDBConnections *int64 `json:"maxDBConnections,omitempty" protobuf:"varint,8,opt,name=maxDBConnections"`
          	// MaxUserConnections is the maximum number of users allowed per-database. Default: unlimited.
          	// +optional
          	MaxUserConnections *int64 `json:"maxUserConnections,omitempty" protobuf:"varint,9,opt,name=maxUserConnections"`
          	// StatsPeriodSeconds sets how often the averages shown in various SHOW commands are updated
          	// and how often aggregated statistics are written to the log.
          	// +optional
          	StatsPeriodSeconds *int64 `json:"statsPeriodSeconds,omitempty" protobuf:"varint,10,opt,name=statsPeriodSeconds"`
          	// AdminUsers specifies an array of users who can act as PgBouncer administrators.
          	// +optional
          	AdminUsers []string `json:"adminUsers,omitempty" protobuf:"bytes,11,rep,name=adminUsers"`
          	// AuthType specifies how to authenticate users. Default: md5 (md5+plain text).
          	// +optional
          	AuthType string `json:"authType,omitempty" protobuf:"bytes,12,opt,name=authType"`
          	// AuthUser looks up any user not specified in auth_file from pg_shadow. Default: not set.
          	// +optional
          	AuthUser string `json:"authUser,omitempty" protobuf:"bytes,13,opt,name=authUser"`
          	// IgnoreStartupParameters specifies comma-separated startup parameters that
          	// pgbouncer knows are handled by admin and it can ignore them.
          	// +optional
          	IgnoreStartupParameters string `json:"ignoreStartupParameters,omitempty" protobuf:"bytes,14,opt,name=ignoreStartupParameters"`
          }

          func (*ConnectionPoolConfig) DeepCopy

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

            func (*ConnectionPoolConfig) DeepCopyInto

            func (in *ConnectionPoolConfig) DeepCopyInto(out *ConnectionPoolConfig)

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

              func (*ConnectionPoolConfig) Descriptor

              func (*ConnectionPoolConfig) Descriptor() ([]byte, []int)

              func (*ConnectionPoolConfig) Marshal

              func (m *ConnectionPoolConfig) Marshal() (dAtA []byte, err error)

              func (*ConnectionPoolConfig) MarshalTo

              func (m *ConnectionPoolConfig) MarshalTo(dAtA []byte) (int, error)

              func (*ConnectionPoolConfig) MarshalToSizedBuffer

              func (m *ConnectionPoolConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

              func (*ConnectionPoolConfig) ProtoMessage

              func (*ConnectionPoolConfig) ProtoMessage()

              func (*ConnectionPoolConfig) Reset

              func (m *ConnectionPoolConfig) Reset()

              func (*ConnectionPoolConfig) Size

              func (m *ConnectionPoolConfig) Size() (n int)

              func (*ConnectionPoolConfig) String

              func (this *ConnectionPoolConfig) String() string

              func (*ConnectionPoolConfig) Unmarshal

              func (m *ConnectionPoolConfig) Unmarshal(dAtA []byte) error

              func (*ConnectionPoolConfig) XXX_DiscardUnknown

              func (m *ConnectionPoolConfig) XXX_DiscardUnknown()

              func (*ConnectionPoolConfig) XXX_Marshal

              func (m *ConnectionPoolConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

              func (*ConnectionPoolConfig) XXX_Merge

              func (m *ConnectionPoolConfig) XXX_Merge(src proto.Message)

              func (*ConnectionPoolConfig) XXX_Size

              func (m *ConnectionPoolConfig) XXX_Size() int

              func (*ConnectionPoolConfig) XXX_Unmarshal

              func (m *ConnectionPoolConfig) XXX_Unmarshal(b []byte) error

              type DatabasePhase

              type DatabasePhase string

                +kubebuilder:validation:Enum=Running;Creating;Initializing;Paused;Halted;Failed

                const (
                	// used for Databases that are currently running
                	DatabasePhaseRunning DatabasePhase = "Running"
                	// used for Databases that are currently creating
                	DatabasePhaseCreating DatabasePhase = "Creating"
                	// used for Databases that are currently initializing
                	DatabasePhaseInitializing DatabasePhase = "Initializing"
                	// used for Databases that are paused
                	DatabasePhasePaused DatabasePhase = "Paused"
                	// used for Databases that are halted
                	DatabasePhaseHalted DatabasePhase = "Halted"
                	// used for Databases that are failed
                	DatabasePhaseFailed DatabasePhase = "Failed"
                )

                type Databases

                type Databases struct {
                	// Alias to uniquely identify a target database running inside a specific Postgres instance.
                	Alias string `json:"alias" protobuf:"bytes,1,opt,name=alias"`
                	// DatabaseRef specifies the database appbinding reference in any namespace.
                	DatabaseRef appcat.AppReference `json:"databaseRef" protobuf:"bytes,2,opt,name=databaseRef"`
                	// DatabaseName is the name of the target database inside a Postgres instance.
                	DatabaseName string `json:"databaseName" protobuf:"bytes,3,opt,name=databaseName"`
                	// DatabaseSecretRef points to a secret that contains the credentials
                	// (username and password) of an existing user of this database.
                	// It is used to bind a single user to this specific database connection.
                	// +optional
                	DatabaseSecretRef *core.LocalObjectReference `json:"databaseSecretRef,omitempty" protobuf:"bytes,4,opt,name=databaseSecretRef"`
                }

                func (*Databases) DeepCopy

                func (in *Databases) DeepCopy() *Databases

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

                  func (*Databases) DeepCopyInto

                  func (in *Databases) DeepCopyInto(out *Databases)

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

                    func (*Databases) Descriptor

                    func (*Databases) Descriptor() ([]byte, []int)

                    func (*Databases) Marshal

                    func (m *Databases) Marshal() (dAtA []byte, err error)

                    func (*Databases) MarshalTo

                    func (m *Databases) MarshalTo(dAtA []byte) (int, error)

                    func (*Databases) MarshalToSizedBuffer

                    func (m *Databases) MarshalToSizedBuffer(dAtA []byte) (int, error)

                    func (*Databases) ProtoMessage

                    func (*Databases) ProtoMessage()

                    func (*Databases) Reset

                    func (m *Databases) Reset()

                    func (*Databases) Size

                    func (m *Databases) Size() (n int)

                    func (*Databases) String

                    func (this *Databases) String() string

                    func (*Databases) Unmarshal

                    func (m *Databases) Unmarshal(dAtA []byte) error

                    func (*Databases) XXX_DiscardUnknown

                    func (m *Databases) XXX_DiscardUnknown()

                    func (*Databases) XXX_Marshal

                    func (m *Databases) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                    func (*Databases) XXX_Merge

                    func (m *Databases) XXX_Merge(src proto.Message)

                    func (*Databases) XXX_Size

                    func (m *Databases) XXX_Size() int

                    func (*Databases) XXX_Unmarshal

                    func (m *Databases) XXX_Unmarshal(b []byte) error

                    type Elasticsearch

                    type Elasticsearch struct {
                    	metav1.TypeMeta   `json:",inline,omitempty"`
                    	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
                    	Spec              ElasticsearchSpec   `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
                    	Status            ElasticsearchStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
                    }

                      +kubebuilder:object:root=true +kubebuilder:resource:path=elasticsearches,singular=elasticsearch,shortName=es,categories={datastore,kubedb,appscode,all} +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Version",type="string",JSONPath=".spec.version" +kubebuilder:printcolumn:name="Status",type="string",JSONPath=".status.phase" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp"

                      func (Elasticsearch) AppBindingMeta

                      func (e Elasticsearch) AppBindingMeta() appcat.AppBindingMeta

                      func (*Elasticsearch) CertSecretVolumeMountPath

                      func (e *Elasticsearch) CertSecretVolumeMountPath(configDir string, alias ElasticsearchCertificateAlias) string

                        returns the mountPath for certificate secrets. if configDir is "/usr/share/elasticsearch/config", mountPath will be, "/usr/share/elasticsearch/config/certs/<alias>".

                        func (*Elasticsearch) CertSecretVolumeName

                        func (e *Elasticsearch) CertSecretVolumeName(alias ElasticsearchCertificateAlias) string

                          returns the volume name for certificate secret. Values will be like: transport-certs, http-certs etc.

                          func (*Elasticsearch) CertificateName

                          func (e *Elasticsearch) CertificateName(alias ElasticsearchCertificateAlias) string

                            CertificateName returns the default certificate name and/or certificate secret name for a certificate alias

                            func (*Elasticsearch) ConfigSecretName

                            func (e *Elasticsearch) ConfigSecretName() string

                              returns the secret name for the default elasticsearch configuration

                              func (Elasticsearch) CustomResourceDefinition

                              func (_ Elasticsearch) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

                              func (*Elasticsearch) DeepCopy

                              func (in *Elasticsearch) DeepCopy() *Elasticsearch

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

                                func (*Elasticsearch) DeepCopyInto

                                func (in *Elasticsearch) DeepCopyInto(out *Elasticsearch)

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

                                  func (*Elasticsearch) DeepCopyObject

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

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

                                    func (*Elasticsearch) Descriptor

                                    func (*Elasticsearch) Descriptor() ([]byte, []int)

                                    func (*Elasticsearch) GetConnectionScheme

                                    func (e *Elasticsearch) GetConnectionScheme() string

                                    func (*Elasticsearch) GetConnectionURL

                                    func (e *Elasticsearch) GetConnectionURL() string

                                    func (*Elasticsearch) GetMatchExpressions

                                    func (e *Elasticsearch) GetMatchExpressions() []metav1.LabelSelectorRequirement

                                    func (*Elasticsearch) GetMonitoringVendor

                                    func (e *Elasticsearch) GetMonitoringVendor() string

                                    func (Elasticsearch) GvrSvcName

                                    func (e Elasticsearch) GvrSvcName() string

                                      Governing Service Name

                                      func (*Elasticsearch) Marshal

                                      func (m *Elasticsearch) Marshal() (dAtA []byte, err error)

                                      func (*Elasticsearch) MarshalTo

                                      func (m *Elasticsearch) MarshalTo(dAtA []byte) (int, error)

                                      func (*Elasticsearch) MarshalToSizedBuffer

                                      func (m *Elasticsearch) MarshalToSizedBuffer(dAtA []byte) (int, error)

                                      func (*Elasticsearch) MasterServiceName

                                      func (e *Elasticsearch) MasterServiceName() string

                                      func (*Elasticsearch) MustCertSecretName

                                      func (e *Elasticsearch) MustCertSecretName(alias ElasticsearchCertificateAlias) string

                                        MustCertSecretName returns the secret name for a certificate alias

                                        func (Elasticsearch) OffshootLabels

                                        func (e Elasticsearch) OffshootLabels() map[string]string

                                        func (Elasticsearch) OffshootName

                                        func (e Elasticsearch) OffshootName() string

                                        func (Elasticsearch) OffshootSelectors

                                        func (e Elasticsearch) OffshootSelectors() map[string]string

                                        func (*Elasticsearch) ProtoMessage

                                        func (*Elasticsearch) ProtoMessage()

                                        func (*Elasticsearch) Reset

                                        func (m *Elasticsearch) Reset()

                                        func (Elasticsearch) ResourceKind

                                        func (e Elasticsearch) ResourceKind() string

                                        func (Elasticsearch) ResourcePlural

                                        func (e Elasticsearch) ResourcePlural() string

                                        func (Elasticsearch) ResourceShortCode

                                        func (e Elasticsearch) ResourceShortCode() string

                                        func (Elasticsearch) ResourceSingular

                                        func (e Elasticsearch) ResourceSingular() string

                                        func (Elasticsearch) ServiceName

                                        func (e Elasticsearch) ServiceName() string

                                        func (*Elasticsearch) SetDefaults

                                        func (e *Elasticsearch) SetDefaults(topology *core_util.Topology)

                                        func (*Elasticsearch) Size

                                        func (m *Elasticsearch) Size() (n int)

                                        func (Elasticsearch) StatsService

                                        func (e Elasticsearch) StatsService() mona.StatsAccessor

                                        func (Elasticsearch) StatsServiceLabels

                                        func (e Elasticsearch) StatsServiceLabels() map[string]string

                                        func (*Elasticsearch) String

                                        func (this *Elasticsearch) String() string

                                        func (*Elasticsearch) Unmarshal

                                        func (m *Elasticsearch) Unmarshal(dAtA []byte) error

                                        func (*Elasticsearch) UserCredSecretName

                                        func (e *Elasticsearch) UserCredSecretName(userName string) string

                                          returns the secret name for the user credentials (ie. username, password) If username contains underscore (_), it will be replaced by hyphen (‐) for the Kubernetes naming convention.

                                          func (*Elasticsearch) XXX_DiscardUnknown

                                          func (m *Elasticsearch) XXX_DiscardUnknown()

                                          func (*Elasticsearch) XXX_Marshal

                                          func (m *Elasticsearch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                          func (*Elasticsearch) XXX_Merge

                                          func (m *Elasticsearch) XXX_Merge(src proto.Message)

                                          func (*Elasticsearch) XXX_Size

                                          func (m *Elasticsearch) XXX_Size() int

                                          func (*Elasticsearch) XXX_Unmarshal

                                          func (m *Elasticsearch) XXX_Unmarshal(b []byte) error

                                          type ElasticsearchCertificateAlias

                                          type ElasticsearchCertificateAlias string

                                            +kubebuilder:validation:Enum=root;transport;http;admin;archiver;metrics-exporter

                                            const (
                                            	ElasticsearchRootCert            ElasticsearchCertificateAlias = "root"
                                            	ElasticsearchTransportCert       ElasticsearchCertificateAlias = "transport"
                                            	ElasticsearchHTTPCert            ElasticsearchCertificateAlias = "http"
                                            	ElasticsearchAdminCert           ElasticsearchCertificateAlias = "admin"
                                            	ElasticsearchArchiverCert        ElasticsearchCertificateAlias = "archiver"
                                            	ElasticsearchMetricsExporterCert ElasticsearchCertificateAlias = "metrics-exporter"
                                            )

                                            type ElasticsearchClusterTopology

                                            type ElasticsearchClusterTopology struct {
                                            	Master ElasticsearchNode `json:"master" protobuf:"bytes,1,opt,name=master"`
                                            	Data   ElasticsearchNode `json:"data" protobuf:"bytes,2,opt,name=data"`
                                            	Client ElasticsearchNode `json:"client" protobuf:"bytes,3,opt,name=client"`
                                            }

                                            func (*ElasticsearchClusterTopology) DeepCopy

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

                                              func (*ElasticsearchClusterTopology) DeepCopyInto

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

                                                func (*ElasticsearchClusterTopology) Descriptor

                                                func (*ElasticsearchClusterTopology) Descriptor() ([]byte, []int)

                                                func (*ElasticsearchClusterTopology) Marshal

                                                func (m *ElasticsearchClusterTopology) Marshal() (dAtA []byte, err error)

                                                func (*ElasticsearchClusterTopology) MarshalTo

                                                func (m *ElasticsearchClusterTopology) MarshalTo(dAtA []byte) (int, error)

                                                func (*ElasticsearchClusterTopology) MarshalToSizedBuffer

                                                func (m *ElasticsearchClusterTopology) MarshalToSizedBuffer(dAtA []byte) (int, error)

                                                func (*ElasticsearchClusterTopology) ProtoMessage

                                                func (*ElasticsearchClusterTopology) ProtoMessage()

                                                func (*ElasticsearchClusterTopology) Reset

                                                func (m *ElasticsearchClusterTopology) Reset()

                                                func (*ElasticsearchClusterTopology) Size

                                                func (m *ElasticsearchClusterTopology) Size() (n int)

                                                func (*ElasticsearchClusterTopology) String

                                                func (this *ElasticsearchClusterTopology) String() string

                                                func (*ElasticsearchClusterTopology) Unmarshal

                                                func (m *ElasticsearchClusterTopology) Unmarshal(dAtA []byte) error

                                                func (*ElasticsearchClusterTopology) XXX_DiscardUnknown

                                                func (m *ElasticsearchClusterTopology) XXX_DiscardUnknown()

                                                func (*ElasticsearchClusterTopology) XXX_Marshal

                                                func (m *ElasticsearchClusterTopology) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                func (*ElasticsearchClusterTopology) XXX_Merge

                                                func (m *ElasticsearchClusterTopology) XXX_Merge(src proto.Message)

                                                func (*ElasticsearchClusterTopology) XXX_Size

                                                func (m *ElasticsearchClusterTopology) XXX_Size() int

                                                func (*ElasticsearchClusterTopology) XXX_Unmarshal

                                                func (m *ElasticsearchClusterTopology) XXX_Unmarshal(b []byte) error

                                                type ElasticsearchInternalUser

                                                type ElasticsearchInternalUser string
                                                const (
                                                	ElasticsearchInternalUserElastic         ElasticsearchInternalUser = "elastic"
                                                	ElasticsearchInternalUserAdmin           ElasticsearchInternalUser = "admin"
                                                	ElasticsearchInternalUserKibanaserver    ElasticsearchInternalUser = "kibanaserver"
                                                	ElasticsearchInternalUserKibanaro        ElasticsearchInternalUser = "kibanaro"
                                                	ElasticsearchInternalUserLogstash        ElasticsearchInternalUser = "logstash"
                                                	ElasticsearchInternalUserReadall         ElasticsearchInternalUser = "readall"
                                                	ElasticsearchInternalUserSnapshotrestore ElasticsearchInternalUser = "snapshotrestore"
                                                	ElasticsearchInternalUserMetricsExporter ElasticsearchInternalUser = "metrics_exporter"
                                                )

                                                type ElasticsearchList

                                                type ElasticsearchList struct {
                                                	metav1.TypeMeta `json:",inline"`
                                                	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
                                                	// Items is a list of Elasticsearch CRD objects
                                                	Items []Elasticsearch `json:"items,omitempty" protobuf:"bytes,2,rep,name=items"`
                                                }

                                                func (*ElasticsearchList) DeepCopy

                                                func (in *ElasticsearchList) DeepCopy() *ElasticsearchList

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

                                                  func (*ElasticsearchList) DeepCopyInto

                                                  func (in *ElasticsearchList) DeepCopyInto(out *ElasticsearchList)

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

                                                    func (*ElasticsearchList) DeepCopyObject

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

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

                                                      func (*ElasticsearchList) Descriptor

                                                      func (*ElasticsearchList) Descriptor() ([]byte, []int)

                                                      func (*ElasticsearchList) Marshal

                                                      func (m *ElasticsearchList) Marshal() (dAtA []byte, err error)

                                                      func (*ElasticsearchList) MarshalTo

                                                      func (m *ElasticsearchList) MarshalTo(dAtA []byte) (int, error)

                                                      func (*ElasticsearchList) MarshalToSizedBuffer

                                                      func (m *ElasticsearchList) MarshalToSizedBuffer(dAtA []byte) (int, error)

                                                      func (*ElasticsearchList) ProtoMessage

                                                      func (*ElasticsearchList) ProtoMessage()

                                                      func (*ElasticsearchList) Reset

                                                      func (m *ElasticsearchList) Reset()

                                                      func (*ElasticsearchList) Size

                                                      func (m *ElasticsearchList) Size() (n int)

                                                      func (*ElasticsearchList) String

                                                      func (this *ElasticsearchList) String() string

                                                      func (*ElasticsearchList) Unmarshal

                                                      func (m *ElasticsearchList) Unmarshal(dAtA []byte) error

                                                      func (*ElasticsearchList) XXX_DiscardUnknown

                                                      func (m *ElasticsearchList) XXX_DiscardUnknown()

                                                      func (*ElasticsearchList) XXX_Marshal

                                                      func (m *ElasticsearchList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                      func (*ElasticsearchList) XXX_Merge

                                                      func (m *ElasticsearchList) XXX_Merge(src proto.Message)

                                                      func (*ElasticsearchList) XXX_Size

                                                      func (m *ElasticsearchList) XXX_Size() int

                                                      func (*ElasticsearchList) XXX_Unmarshal

                                                      func (m *ElasticsearchList) XXX_Unmarshal(b []byte) error

                                                      type ElasticsearchNode

                                                      type ElasticsearchNode struct {
                                                      	// Replicas represents number of replica for this specific type of node
                                                      	Replicas *int32 `json:"replicas,omitempty" protobuf:"varint,1,opt,name=replicas"`
                                                      	Prefix   string `json:"prefix,omitempty" protobuf:"bytes,2,opt,name=prefix"`
                                                      	// Storage to specify how storage shall be used.
                                                      	Storage *core.PersistentVolumeClaimSpec `json:"storage,omitempty" protobuf:"bytes,3,opt,name=storage"`
                                                      	// Compute Resources required by the sidecar container.
                                                      	Resources core.ResourceRequirements `json:"resources,omitempty" protobuf:"bytes,4,opt,name=resources"`
                                                      	// An eviction is allowed if at most "maxUnavailable" pods selected by
                                                      	// "selector" are unavailable after the eviction, i.e. even in absence of
                                                      	// the evicted pod. For example, one can prevent all voluntary evictions
                                                      	// by specifying 0. This is a mutually exclusive setting with "minAvailable".
                                                      	// +optional
                                                      	MaxUnavailable *intstr.IntOrString `json:"maxUnavailable,omitempty" protobuf:"bytes,5,opt,name=maxUnavailable"`
                                                      }

                                                      func (*ElasticsearchNode) DeepCopy

                                                      func (in *ElasticsearchNode) DeepCopy() *ElasticsearchNode

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

                                                        func (*ElasticsearchNode) DeepCopyInto

                                                        func (in *ElasticsearchNode) DeepCopyInto(out *ElasticsearchNode)

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

                                                          func (*ElasticsearchNode) Descriptor

                                                          func (*ElasticsearchNode) Descriptor() ([]byte, []int)

                                                          func (*ElasticsearchNode) Marshal

                                                          func (m *ElasticsearchNode) Marshal() (dAtA []byte, err error)

                                                          func (*ElasticsearchNode) MarshalTo

                                                          func (m *ElasticsearchNode) MarshalTo(dAtA []byte) (int, error)

                                                          func (*ElasticsearchNode) MarshalToSizedBuffer

                                                          func (m *ElasticsearchNode) MarshalToSizedBuffer(dAtA []byte) (int, error)

                                                          func (*ElasticsearchNode) ProtoMessage

                                                          func (*ElasticsearchNode) ProtoMessage()

                                                          func (*ElasticsearchNode) Reset

                                                          func (m *ElasticsearchNode) Reset()

                                                          func (*ElasticsearchNode) Size

                                                          func (m *ElasticsearchNode) Size() (n int)

                                                          func (*ElasticsearchNode) String

                                                          func (this *ElasticsearchNode) String() string

                                                          func (*ElasticsearchNode) Unmarshal

                                                          func (m *ElasticsearchNode) Unmarshal(dAtA []byte) error

                                                          func (*ElasticsearchNode) XXX_DiscardUnknown

                                                          func (m *ElasticsearchNode) XXX_DiscardUnknown()

                                                          func (*ElasticsearchNode) XXX_Marshal

                                                          func (m *ElasticsearchNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                          func (*ElasticsearchNode) XXX_Merge

                                                          func (m *ElasticsearchNode) XXX_Merge(src proto.Message)

                                                          func (*ElasticsearchNode) XXX_Size

                                                          func (m *ElasticsearchNode) XXX_Size() int

                                                          func (*ElasticsearchNode) XXX_Unmarshal

                                                          func (m *ElasticsearchNode) XXX_Unmarshal(b []byte) error

                                                          type ElasticsearchRoleMapSpec

                                                          type ElasticsearchRoleMapSpec struct {
                                                          	// Specifies the reserved status.
                                                          	// Resources that have this set to true can’t be changed using the REST API or Kibana.
                                                          	// Default to "false".
                                                          	// +optional
                                                          	Reserved bool `json:"reserved,omitempty" yaml:"reserved,omitempty" protobuf:"bytes,1,opt,name=reserved"`
                                                          
                                                          	// Specifies the hidden status.
                                                          	// Resources that have this set to true are not returned by the REST API
                                                          	// and not visible in Kibana.
                                                          	// Default to "false".
                                                          	// +optional
                                                          	Hidden bool `json:"hidden,omitempty" yaml:"hidden,omitempty" protobuf:"bytes,2,opt,name=hidden"`
                                                          
                                                          	// Specifies a list of backend roles assigned to this role.
                                                          	// Backend roles can come from the internal user database,
                                                          	// LDAP groups, JSON web token claims or SAML assertions.
                                                          	// +optional
                                                          	BackendRoles []string `json:"backendRoles,omitempty" yaml:"backend_roles,omitempty" protobuf:"bytes,3,opt,name=backendRoles"`
                                                          
                                                          	// Specifies a list of hosts assigned to this role.
                                                          	// +optional
                                                          	Hosts []string `json:"hosts,omitempty" yaml:"hosts,omitempty" protobuf:"bytes,4,opt,name=hosts"`
                                                          
                                                          	// Specifies a list of users assigned to this role.
                                                          	// +optional
                                                          	Users []string `json:"users,omitempty" yaml:"users,omitempty" protobuf:"bytes,5,opt,name=users"`
                                                          
                                                          	// Specifies a list of backend roles (migrated from ES-version6) assigned to this role.
                                                          	AndBackendRoles []string `json:"andBackendRoles,omitempty" yaml:"and_backend_roles,omitempty" protobuf:"bytes,6,opt,name=andBackendRoles"`
                                                          }

                                                            Specifies the role mapping structure. Both 'json' and 'yaml' tags are used in structure metadata. The `json` tags (camel case) are used while taking input from users. The `yaml` tags (snake case) are used by the operator to generate roles_mapping.yml file.

                                                            func (*ElasticsearchRoleMapSpec) DeepCopy

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

                                                              func (*ElasticsearchRoleMapSpec) DeepCopyInto

                                                              func (in *ElasticsearchRoleMapSpec) DeepCopyInto(out *ElasticsearchRoleMapSpec)

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

                                                                func (*ElasticsearchRoleMapSpec) Descriptor

                                                                func (*ElasticsearchRoleMapSpec) Descriptor() ([]byte, []int)

                                                                func (*ElasticsearchRoleMapSpec) Marshal

                                                                func (m *ElasticsearchRoleMapSpec) Marshal() (dAtA []byte, err error)

                                                                func (*ElasticsearchRoleMapSpec) MarshalTo

                                                                func (m *ElasticsearchRoleMapSpec) MarshalTo(dAtA []byte) (int, error)

                                                                func (*ElasticsearchRoleMapSpec) MarshalToSizedBuffer

                                                                func (m *ElasticsearchRoleMapSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

                                                                func (*ElasticsearchRoleMapSpec) ProtoMessage

                                                                func (*ElasticsearchRoleMapSpec) ProtoMessage()

                                                                func (*ElasticsearchRoleMapSpec) Reset

                                                                func (m *ElasticsearchRoleMapSpec) Reset()

                                                                func (*ElasticsearchRoleMapSpec) Size

                                                                func (m *ElasticsearchRoleMapSpec) Size() (n int)

                                                                func (*ElasticsearchRoleMapSpec) String

                                                                func (this *ElasticsearchRoleMapSpec) String() string

                                                                func (*ElasticsearchRoleMapSpec) Unmarshal

                                                                func (m *ElasticsearchRoleMapSpec) Unmarshal(dAtA []byte) error

                                                                func (*ElasticsearchRoleMapSpec) XXX_DiscardUnknown

                                                                func (m *ElasticsearchRoleMapSpec) XXX_DiscardUnknown()

                                                                func (*ElasticsearchRoleMapSpec) XXX_Marshal

                                                                func (m *ElasticsearchRoleMapSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                func (*ElasticsearchRoleMapSpec) XXX_Merge

                                                                func (m *ElasticsearchRoleMapSpec) XXX_Merge(src proto.Message)

                                                                func (*ElasticsearchRoleMapSpec) XXX_Size

                                                                func (m *ElasticsearchRoleMapSpec) XXX_Size() int

                                                                func (*ElasticsearchRoleMapSpec) XXX_Unmarshal

                                                                func (m *ElasticsearchRoleMapSpec) XXX_Unmarshal(b []byte) error

                                                                type ElasticsearchSpec

                                                                type ElasticsearchSpec struct {
                                                                	// Version of Elasticsearch to be deployed.
                                                                	Version string `json:"version" protobuf:"bytes,1,opt,name=version"`
                                                                
                                                                	// Number of instances to deploy for a Elasticsearch database.
                                                                	Replicas *int32 `json:"replicas,omitempty" protobuf:"varint,2,opt,name=replicas"`
                                                                
                                                                	// Elasticsearch topology for node specification
                                                                	Topology *ElasticsearchClusterTopology `json:"topology,omitempty" protobuf:"bytes,3,opt,name=topology"`
                                                                
                                                                	// To enable ssl in transport & http layer
                                                                	EnableSSL bool `json:"enableSSL,omitempty" protobuf:"varint,4,opt,name=enableSSL"`
                                                                
                                                                	// Secret with SSL certificates
                                                                	// Deprecated: Use spec.tls instead
                                                                	CertificateSecret *core.SecretVolumeSource `json:"certificateSecret,omitempty" protobuf:"bytes,5,opt,name=certificateSecret"`
                                                                
                                                                	// disable security of authPlugin (ie, xpack or searchguard). It disables authentication security of user.
                                                                	// If unset, default is false
                                                                	DisableSecurity bool `json:"disableSecurity,omitempty" protobuf:"varint,6,opt,name=disableSecurity"`
                                                                
                                                                	// Authentication plugin used by Elasticsearch cluster. If unset, defaults to SearchGuard.
                                                                	// Deprecated: Use elasticsearchVersion.Spec.AuthPlugin instead
                                                                	AuthPlugin v1alpha1.ElasticsearchAuthPlugin `` /* 145-byte string literal not displayed */
                                                                
                                                                	// Database authentication secret
                                                                	DatabaseSecret *core.SecretVolumeSource `json:"databaseSecret,omitempty" protobuf:"bytes,8,opt,name=databaseSecret"`
                                                                
                                                                	// StorageType can be durable (default) or ephemeral
                                                                	StorageType StorageType `json:"storageType,omitempty" protobuf:"bytes,9,opt,name=storageType,casttype=StorageType"`
                                                                
                                                                	// Storage to specify how storage shall be used.
                                                                	Storage *core.PersistentVolumeClaimSpec `json:"storage,omitempty" protobuf:"bytes,10,opt,name=storage"`
                                                                
                                                                	// Init is used to initialize database
                                                                	// +optional
                                                                	Init *InitSpec `json:"init,omitempty" protobuf:"bytes,11,opt,name=init"`
                                                                
                                                                	// Monitor is used monitor database instance
                                                                	// +optional
                                                                	Monitor *mona.AgentSpec `json:"monitor,omitempty" protobuf:"bytes,12,opt,name=monitor"`
                                                                
                                                                	// ConfigSource is an optional field to provide custom configuration file for database.
                                                                	// If specified, this file will be used as configuration file otherwise default configuration file will be used.
                                                                	ConfigSource *core.VolumeSource `json:"configSource,omitempty" protobuf:"bytes,13,opt,name=configSource"`
                                                                
                                                                	// PodTemplate is an optional configuration for pods used to expose database
                                                                	// +optional
                                                                	PodTemplate ofst.PodTemplateSpec `json:"podTemplate,omitempty" protobuf:"bytes,14,opt,name=podTemplate"`
                                                                
                                                                	// ServiceTemplate is an optional configuration for service used to expose database
                                                                	// +optional
                                                                	ServiceTemplate ofst.ServiceTemplateSpec `json:"serviceTemplate,omitempty" protobuf:"bytes,15,opt,name=serviceTemplate"`
                                                                
                                                                	// An eviction is allowed if at most "maxUnavailable" pods selected by
                                                                	// "selector" are unavailable after the eviction, i.e. even in absence of
                                                                	// the evicted pod. For example, one can prevent all voluntary evictions
                                                                	// by specifying 0. This is a mutually exclusive setting with "minAvailable".
                                                                	// +optional
                                                                	MaxUnavailable *intstr.IntOrString `json:"maxUnavailable,omitempty" protobuf:"bytes,16,opt,name=maxUnavailable"`
                                                                
                                                                	// TLS contains tls configurations
                                                                	// +optional
                                                                	TLS *kmapi.TLSConfig `json:"tls,omitempty" protobuf:"bytes,17,opt,name=tls"`
                                                                
                                                                	// InternalUsers contains internal user configurations.
                                                                	// Expected Input format:
                                                                	// internalUsers:
                                                                	//   <username1>:
                                                                	//		...
                                                                	//   <username2>:
                                                                	//		...
                                                                	// +optional
                                                                	InternalUsers map[string]ElasticsearchUserSpec `json:"internalUsers,omitempty" protobuf:"bytes,18,rep,name=internalUsers"`
                                                                
                                                                	// RolesMapping contains roles mapping configurations.
                                                                	// Expected Input format:
                                                                	// rolesMapping:
                                                                	//   <role1>:
                                                                	//		...
                                                                	//   <role2>:
                                                                	//		...
                                                                	// +optional
                                                                	RolesMapping map[string]ElasticsearchRoleMapSpec `json:"rolesMapping,omitempty" protobuf:"bytes,19,rep,name=rolesMapping"`
                                                                
                                                                	// Indicates that the database is paused and controller will not sync any changes made to this spec.
                                                                	// +optional
                                                                	Paused bool `json:"paused,omitempty" protobuf:"varint,20,opt,name=paused"`
                                                                
                                                                	// Indicates that the database is halted and all offshoot Kubernetes resources except PVCs are deleted.
                                                                	// +optional
                                                                	Halted bool `json:"halted,omitempty" protobuf:"varint,21,opt,name=halted"`
                                                                
                                                                	// TerminationPolicy controls the delete operation for database
                                                                	// +optional
                                                                	TerminationPolicy TerminationPolicy `json:"terminationPolicy,omitempty" protobuf:"bytes,22,opt,name=terminationPolicy,casttype=TerminationPolicy"`
                                                                }

                                                                func (*ElasticsearchSpec) DeepCopy

                                                                func (in *ElasticsearchSpec) DeepCopy() *ElasticsearchSpec

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

                                                                  func (*ElasticsearchSpec) DeepCopyInto

                                                                  func (in *ElasticsearchSpec) DeepCopyInto(out *ElasticsearchSpec)

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

                                                                    func (*ElasticsearchSpec) Descriptor

                                                                    func (*ElasticsearchSpec) Descriptor() ([]byte, []int)

                                                                    func (*ElasticsearchSpec) GetSecrets

                                                                    func (e *ElasticsearchSpec) GetSecrets() []string

                                                                    func (*ElasticsearchSpec) Marshal

                                                                    func (m *ElasticsearchSpec) Marshal() (dAtA []byte, err error)

                                                                    func (*ElasticsearchSpec) MarshalTo

                                                                    func (m *ElasticsearchSpec) MarshalTo(dAtA []byte) (int, error)

                                                                    func (*ElasticsearchSpec) MarshalToSizedBuffer

                                                                    func (m *ElasticsearchSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

                                                                    func (*ElasticsearchSpec) ProtoMessage

                                                                    func (*ElasticsearchSpec) ProtoMessage()

                                                                    func (*ElasticsearchSpec) Reset

                                                                    func (m *ElasticsearchSpec) Reset()

                                                                    func (*ElasticsearchSpec) Size

                                                                    func (m *ElasticsearchSpec) Size() (n int)

                                                                    func (*ElasticsearchSpec) String

                                                                    func (this *ElasticsearchSpec) String() string

                                                                    func (*ElasticsearchSpec) Unmarshal

                                                                    func (m *ElasticsearchSpec) Unmarshal(dAtA []byte) error

                                                                    func (*ElasticsearchSpec) XXX_DiscardUnknown

                                                                    func (m *ElasticsearchSpec) XXX_DiscardUnknown()

                                                                    func (*ElasticsearchSpec) XXX_Marshal

                                                                    func (m *ElasticsearchSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                    func (*ElasticsearchSpec) XXX_Merge

                                                                    func (m *ElasticsearchSpec) XXX_Merge(src proto.Message)

                                                                    func (*ElasticsearchSpec) XXX_Size

                                                                    func (m *ElasticsearchSpec) XXX_Size() int

                                                                    func (*ElasticsearchSpec) XXX_Unmarshal

                                                                    func (m *ElasticsearchSpec) XXX_Unmarshal(b []byte) error

                                                                    type ElasticsearchStatus

                                                                    type ElasticsearchStatus struct {
                                                                    	Phase  DatabasePhase `json:"phase,omitempty" protobuf:"bytes,1,opt,name=phase,casttype=DatabasePhase"`
                                                                    	Reason string        `json:"reason,omitempty" protobuf:"bytes,2,opt,name=reason"`
                                                                    	// observedGeneration is the most recent generation observed for this resource. It corresponds to the
                                                                    	// resource's generation, which is updated on mutation by the API Server.
                                                                    	// +optional
                                                                    	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,3,opt,name=observedGeneration"`
                                                                    }

                                                                    func (*ElasticsearchStatus) DeepCopy

                                                                    func (in *ElasticsearchStatus) DeepCopy() *ElasticsearchStatus

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

                                                                      func (*ElasticsearchStatus) DeepCopyInto

                                                                      func (in *ElasticsearchStatus) DeepCopyInto(out *ElasticsearchStatus)

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

                                                                        func (*ElasticsearchStatus) Descriptor

                                                                        func (*ElasticsearchStatus) Descriptor() ([]byte, []int)

                                                                        func (*ElasticsearchStatus) Marshal

                                                                        func (m *ElasticsearchStatus) Marshal() (dAtA []byte, err error)

                                                                        func (*ElasticsearchStatus) MarshalTo

                                                                        func (m *ElasticsearchStatus) MarshalTo(dAtA []byte) (int, error)

                                                                        func (*ElasticsearchStatus) MarshalToSizedBuffer

                                                                        func (m *ElasticsearchStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

                                                                        func (*ElasticsearchStatus) ProtoMessage

                                                                        func (*ElasticsearchStatus) ProtoMessage()

                                                                        func (*ElasticsearchStatus) Reset

                                                                        func (m *ElasticsearchStatus) Reset()

                                                                        func (*ElasticsearchStatus) Size

                                                                        func (m *ElasticsearchStatus) Size() (n int)

                                                                        func (*ElasticsearchStatus) String

                                                                        func (this *ElasticsearchStatus) String() string

                                                                        func (*ElasticsearchStatus) Unmarshal

                                                                        func (m *ElasticsearchStatus) Unmarshal(dAtA []byte) error

                                                                        func (*ElasticsearchStatus) XXX_DiscardUnknown

                                                                        func (m *ElasticsearchStatus) XXX_DiscardUnknown()

                                                                        func (*ElasticsearchStatus) XXX_Marshal

                                                                        func (m *ElasticsearchStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                        func (*ElasticsearchStatus) XXX_Merge

                                                                        func (m *ElasticsearchStatus) XXX_Merge(src proto.Message)

                                                                        func (*ElasticsearchStatus) XXX_Size

                                                                        func (m *ElasticsearchStatus) XXX_Size() int

                                                                        func (*ElasticsearchStatus) XXX_Unmarshal

                                                                        func (m *ElasticsearchStatus) XXX_Unmarshal(b []byte) error

                                                                        type ElasticsearchUserSpec

                                                                        type ElasticsearchUserSpec struct {
                                                                        	// Specifies the hash of the password.
                                                                        	// +optional
                                                                        	Hash string `json:"-" yaml:"hash,omitempty" protobuf:"bytes,1,opt,name=hash"`
                                                                        
                                                                        	// Specifies the reserved status.
                                                                        	// Resources that have this set to true can’t be changed using the REST API or Kibana.
                                                                        	// Default to "false".
                                                                        	// +optional
                                                                        	Reserved bool `json:"reserved,omitempty" yaml:"reserved,omitempty" protobuf:"bytes,2,opt,name=reserved"`
                                                                        
                                                                        	// Specifies the hidden status.
                                                                        	// Resources that have this set to true are not returned by the REST API
                                                                        	// and not visible in Kibana.
                                                                        	// Default to "false".
                                                                        	// +optional
                                                                        	Hidden bool `json:"hidden,omitempty" yaml:"hidden,omitempty" protobuf:"bytes,3,opt,name=hidden"`
                                                                        
                                                                        	// Specifies a list of backend roles assigned to this user.
                                                                        	// Backend roles can come from the internal user database,
                                                                        	// LDAP groups, JSON web token claims or SAML assertions.
                                                                        	// +optional
                                                                        	BackendRoles []string `json:"backendRoles,omitempty" yaml:"backend_roles,omitempty" protobuf:"bytes,4,opt,name=backendRoles"`
                                                                        
                                                                        	// Specifies a list of searchguard security plugin roles assigned to this user.
                                                                        	// +optional
                                                                        	SearchGuardRoles []string `json:"searchGuardRoles,omitempty" yaml:"search_guard_roles,omitempty" protobuf:"bytes,5,opt,name=searchGuardRoles"`
                                                                        
                                                                        	// Specifies a list of opendistro security plugin roles assigned to this user.
                                                                        	// +optional
                                                                        	OpendistroSecurityRoles []string `` /* 135-byte string literal not displayed */
                                                                        
                                                                        	// Specifies one or more custom attributes,
                                                                        	// which can be used in index names and DLS queries.
                                                                        	// +optional
                                                                        	Attributes map[string]string `json:"attributes,omitempty" yaml:"attributes,omitempty" protobuf:"bytes,7,opt,name=attributes"`
                                                                        
                                                                        	// Specifies the description of the user
                                                                        	// +optional
                                                                        	Description string `json:"description,omitempty" yaml:"description,omitempty" protobuf:"bytes,8,opt,name=description"`
                                                                        }

                                                                          Specifies the security plugin internal user structure. Both 'json' and 'yaml' tags are used in structure metadata. The `json` tags (camel case) are used while taking input from users. The `yaml` tags (snake case) are used by the operator to generate internal_users.yml file.

                                                                          func (*ElasticsearchUserSpec) DeepCopy

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

                                                                            func (*ElasticsearchUserSpec) DeepCopyInto

                                                                            func (in *ElasticsearchUserSpec) DeepCopyInto(out *ElasticsearchUserSpec)

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

                                                                              func (*ElasticsearchUserSpec) Descriptor

                                                                              func (*ElasticsearchUserSpec) Descriptor() ([]byte, []int)

                                                                              func (*ElasticsearchUserSpec) Marshal

                                                                              func (m *ElasticsearchUserSpec) Marshal() (dAtA []byte, err error)

                                                                              func (*ElasticsearchUserSpec) MarshalTo

                                                                              func (m *ElasticsearchUserSpec) MarshalTo(dAtA []byte) (int, error)

                                                                              func (*ElasticsearchUserSpec) MarshalToSizedBuffer

                                                                              func (m *ElasticsearchUserSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

                                                                              func (*ElasticsearchUserSpec) ProtoMessage

                                                                              func (*ElasticsearchUserSpec) ProtoMessage()

                                                                              func (*ElasticsearchUserSpec) Reset

                                                                              func (m *ElasticsearchUserSpec) Reset()

                                                                              func (*ElasticsearchUserSpec) Size

                                                                              func (m *ElasticsearchUserSpec) Size() (n int)

                                                                              func (*ElasticsearchUserSpec) String

                                                                              func (this *ElasticsearchUserSpec) String() string

                                                                              func (*ElasticsearchUserSpec) Unmarshal

                                                                              func (m *ElasticsearchUserSpec) Unmarshal(dAtA []byte) error

                                                                              func (*ElasticsearchUserSpec) XXX_DiscardUnknown

                                                                              func (m *ElasticsearchUserSpec) XXX_DiscardUnknown()

                                                                              func (*ElasticsearchUserSpec) XXX_Marshal

                                                                              func (m *ElasticsearchUserSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                              func (*ElasticsearchUserSpec) XXX_Merge

                                                                              func (m *ElasticsearchUserSpec) XXX_Merge(src proto.Message)

                                                                              func (*ElasticsearchUserSpec) XXX_Size

                                                                              func (m *ElasticsearchUserSpec) XXX_Size() int

                                                                              func (*ElasticsearchUserSpec) XXX_Unmarshal

                                                                              func (m *ElasticsearchUserSpec) XXX_Unmarshal(b []byte) error

                                                                              type Etcd

                                                                              type Etcd struct {
                                                                              	metav1.TypeMeta   `json:",inline,omitempty"`
                                                                              	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
                                                                              	Spec              EtcdSpec   `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
                                                                              	Status            EtcdStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
                                                                              }

                                                                                +kubebuilder:object:root=true +kubebuilder:resource:path=etcds,singular=etcd,shortName=etc,categories={datastore,kubedb,appscode,all} +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Version",type="string",JSONPath=".spec.version" +kubebuilder:printcolumn:name="Status",type="string",JSONPath=".status.phase" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp"

                                                                                func (Etcd) AppBindingMeta

                                                                                func (r Etcd) AppBindingMeta() appcat.AppBindingMeta

                                                                                func (Etcd) ClientServiceName

                                                                                func (e Etcd) ClientServiceName() string

                                                                                func (Etcd) CustomResourceDefinition

                                                                                func (_ Etcd) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

                                                                                func (*Etcd) DeepCopy

                                                                                func (in *Etcd) DeepCopy() *Etcd

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

                                                                                  func (*Etcd) DeepCopyInto

                                                                                  func (in *Etcd) DeepCopyInto(out *Etcd)

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

                                                                                    func (*Etcd) DeepCopyObject

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

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

                                                                                      func (*Etcd) Descriptor

                                                                                      func (*Etcd) Descriptor() ([]byte, []int)

                                                                                      func (*Etcd) GetMonitoringVendor

                                                                                      func (e *Etcd) GetMonitoringVendor() string

                                                                                      func (*Etcd) Marshal

                                                                                      func (m *Etcd) Marshal() (dAtA []byte, err error)

                                                                                      func (*Etcd) MarshalTo

                                                                                      func (m *Etcd) MarshalTo(dAtA []byte) (int, error)

                                                                                      func (*Etcd) MarshalToSizedBuffer

                                                                                      func (m *Etcd) MarshalToSizedBuffer(dAtA []byte) (int, error)

                                                                                      func (Etcd) OffshootLabels

                                                                                      func (e Etcd) OffshootLabels() map[string]string

                                                                                      func (Etcd) OffshootName

                                                                                      func (e Etcd) OffshootName() string

                                                                                      func (Etcd) OffshootSelectors

                                                                                      func (e Etcd) OffshootSelectors() map[string]string

                                                                                      func (Etcd) PeerServiceName

                                                                                      func (e Etcd) PeerServiceName() string

                                                                                      func (*Etcd) ProtoMessage

                                                                                      func (*Etcd) ProtoMessage()

                                                                                      func (*Etcd) Reset

                                                                                      func (m *Etcd) Reset()

                                                                                      func (Etcd) ResourceKind

                                                                                      func (e Etcd) ResourceKind() string

                                                                                      func (Etcd) ResourcePlural

                                                                                      func (e Etcd) ResourcePlural() string

                                                                                      func (Etcd) ResourceShortCode

                                                                                      func (e Etcd) ResourceShortCode() string

                                                                                      func (Etcd) ResourceSingular

                                                                                      func (e Etcd) ResourceSingular() string

                                                                                      func (*Etcd) SetDefaults

                                                                                      func (e *Etcd) SetDefaults()

                                                                                      func (*Etcd) Size

                                                                                      func (m *Etcd) Size() (n int)

                                                                                      func (Etcd) StatsService

                                                                                      func (e Etcd) StatsService() mona.StatsAccessor

                                                                                      func (Etcd) StatsServiceLabels

                                                                                      func (e Etcd) StatsServiceLabels() map[string]string

                                                                                      func (*Etcd) String

                                                                                      func (this *Etcd) String() string

                                                                                      func (*Etcd) Unmarshal

                                                                                      func (m *Etcd) Unmarshal(dAtA []byte) error

                                                                                      func (*Etcd) XXX_DiscardUnknown

                                                                                      func (m *Etcd) XXX_DiscardUnknown()

                                                                                      func (*Etcd) XXX_Marshal

                                                                                      func (m *Etcd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                      func (*Etcd) XXX_Merge

                                                                                      func (m *Etcd) XXX_Merge(src proto.Message)

                                                                                      func (*Etcd) XXX_Size

                                                                                      func (m *Etcd) XXX_Size() int

                                                                                      func (*Etcd) XXX_Unmarshal

                                                                                      func (m *Etcd) XXX_Unmarshal(b []byte) error

                                                                                      type EtcdList

                                                                                      type EtcdList struct {
                                                                                      	metav1.TypeMeta `json:",inline"`
                                                                                      	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
                                                                                      	// Items is a list of Etcd TPR objects
                                                                                      	Items []Etcd `json:"items,omitempty" protobuf:"bytes,2,rep,name=items"`
                                                                                      }

                                                                                      func (*EtcdList) DeepCopy

                                                                                      func (in *EtcdList) DeepCopy() *EtcdList

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

                                                                                        func (*EtcdList) DeepCopyInto

                                                                                        func (in *EtcdList) DeepCopyInto(out *EtcdList)

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

                                                                                          func (*EtcdList) DeepCopyObject

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

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

                                                                                            func (*EtcdList) Descriptor

                                                                                            func (*EtcdList) Descriptor() ([]byte, []int)

                                                                                            func (*EtcdList) Marshal

                                                                                            func (m *EtcdList) Marshal() (dAtA []byte, err error)

                                                                                            func (*EtcdList) MarshalTo

                                                                                            func (m *EtcdList) MarshalTo(dAtA []byte) (int, error)

                                                                                            func (*EtcdList) MarshalToSizedBuffer

                                                                                            func (m *EtcdList) MarshalToSizedBuffer(dAtA []byte) (int, error)

                                                                                            func (*EtcdList) ProtoMessage

                                                                                            func (*EtcdList) ProtoMessage()

                                                                                            func (*EtcdList) Reset

                                                                                            func (m *EtcdList) Reset()

                                                                                            func (*EtcdList) Size

                                                                                            func (m *EtcdList) Size() (n int)

                                                                                            func (*EtcdList) String

                                                                                            func (this *EtcdList) String() string

                                                                                            func (*EtcdList) Unmarshal

                                                                                            func (m *EtcdList) Unmarshal(dAtA []byte) error

                                                                                            func (*EtcdList) XXX_DiscardUnknown

                                                                                            func (m *EtcdList) XXX_DiscardUnknown()

                                                                                            func (*EtcdList) XXX_Marshal

                                                                                            func (m *EtcdList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                            func (*EtcdList) XXX_Merge

                                                                                            func (m *EtcdList) XXX_Merge(src proto.Message)

                                                                                            func (*EtcdList) XXX_Size

                                                                                            func (m *EtcdList) XXX_Size() int

                                                                                            func (*EtcdList) XXX_Unmarshal

                                                                                            func (m *EtcdList) XXX_Unmarshal(b []byte) error

                                                                                            type EtcdSpec

                                                                                            type EtcdSpec struct {
                                                                                            	// Version of Etcd to be deployed.
                                                                                            	Version string `json:"version" protobuf:"bytes,1,opt,name=version"`
                                                                                            
                                                                                            	// Number of instances to deploy for a Etcd database.
                                                                                            	Replicas *int32 `json:"replicas,omitempty" protobuf:"varint,2,opt,name=replicas"`
                                                                                            
                                                                                            	// StorageType can be durable (default) or ephemeral
                                                                                            	StorageType StorageType `json:"storageType,omitempty" protobuf:"bytes,3,opt,name=storageType,casttype=StorageType"`
                                                                                            
                                                                                            	// Storage spec to specify how storage shall be used.
                                                                                            	Storage *core.PersistentVolumeClaimSpec `json:"storage,omitempty" protobuf:"bytes,4,opt,name=storage"`
                                                                                            
                                                                                            	// Database authentication secret
                                                                                            	DatabaseSecret *core.SecretVolumeSource `json:"databaseSecret,omitempty" protobuf:"bytes,5,opt,name=databaseSecret"`
                                                                                            
                                                                                            	// Init is used to initialize database
                                                                                            	// +optional
                                                                                            	Init *InitSpec `json:"init,omitempty" protobuf:"bytes,6,opt,name=init"`
                                                                                            
                                                                                            	// Monitor is used monitor database instance
                                                                                            	// +optional
                                                                                            	Monitor *mona.AgentSpec `json:"monitor,omitempty" protobuf:"bytes,8,opt,name=monitor"`
                                                                                            
                                                                                            	// etcd cluster TLS configuration
                                                                                            	TLS *TLSPolicy `json:"tls,omitempty" protobuf:"bytes,9,opt,name=tls"`
                                                                                            
                                                                                            	// PodTemplate is an optional configuration for pods used to expose database
                                                                                            	// +optional
                                                                                            	PodTemplate ofst.PodTemplateSpec `json:"podTemplate,omitempty" protobuf:"bytes,10,opt,name=podTemplate"`
                                                                                            
                                                                                            	// ServiceTemplate is an optional configuration for service used to expose database
                                                                                            	// +optional
                                                                                            	ServiceTemplate ofst.ServiceTemplateSpec `json:"serviceTemplate,omitempty" protobuf:"bytes,11,opt,name=serviceTemplate"`
                                                                                            
                                                                                            	// Indicates that the database is paused and controller will not sync any changes made to this spec.
                                                                                            	// +optional
                                                                                            	Paused bool `json:"paused,omitempty" protobuf:"varint,12,opt,name=paused"`
                                                                                            
                                                                                            	// Indicates that the database is halted and all offshoot Kubernetes resources except PVCs are deleted.
                                                                                            	// +optional
                                                                                            	Halted bool `json:"halted,omitempty" protobuf:"varint,13,opt,name=halted"`
                                                                                            
                                                                                            	// TerminationPolicy controls the delete operation for database
                                                                                            	// +optional
                                                                                            	TerminationPolicy TerminationPolicy `json:"terminationPolicy,omitempty" protobuf:"bytes,14,opt,name=terminationPolicy,casttype=TerminationPolicy"`
                                                                                            }

                                                                                            func (*EtcdSpec) DeepCopy

                                                                                            func (in *EtcdSpec) DeepCopy() *EtcdSpec

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

                                                                                              func (*EtcdSpec) DeepCopyInto

                                                                                              func (in *EtcdSpec) DeepCopyInto(out *EtcdSpec)

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

                                                                                                func (*EtcdSpec) Descriptor

                                                                                                func (*EtcdSpec) Descriptor() ([]byte, []int)

                                                                                                func (*EtcdSpec) GetSecrets

                                                                                                func (e *EtcdSpec) GetSecrets() []string

                                                                                                func (*EtcdSpec) Marshal

                                                                                                func (m *EtcdSpec) Marshal() (dAtA []byte, err error)

                                                                                                func (*EtcdSpec) MarshalTo

                                                                                                func (m *EtcdSpec) MarshalTo(dAtA []byte) (int, error)

                                                                                                func (*EtcdSpec) MarshalToSizedBuffer

                                                                                                func (m *EtcdSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

                                                                                                func (*EtcdSpec) ProtoMessage

                                                                                                func (*EtcdSpec) ProtoMessage()

                                                                                                func (*EtcdSpec) Reset

                                                                                                func (m *EtcdSpec) Reset()

                                                                                                func (*EtcdSpec) Size

                                                                                                func (m *EtcdSpec) Size() (n int)

                                                                                                func (*EtcdSpec) String

                                                                                                func (this *EtcdSpec) String() string

                                                                                                func (*EtcdSpec) Unmarshal

                                                                                                func (m *EtcdSpec) Unmarshal(dAtA []byte) error

                                                                                                func (*EtcdSpec) XXX_DiscardUnknown

                                                                                                func (m *EtcdSpec) XXX_DiscardUnknown()

                                                                                                func (*EtcdSpec) XXX_Marshal

                                                                                                func (m *EtcdSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                                func (*EtcdSpec) XXX_Merge

                                                                                                func (m *EtcdSpec) XXX_Merge(src proto.Message)

                                                                                                func (*EtcdSpec) XXX_Size

                                                                                                func (m *EtcdSpec) XXX_Size() int

                                                                                                func (*EtcdSpec) XXX_Unmarshal

                                                                                                func (m *EtcdSpec) XXX_Unmarshal(b []byte) error

                                                                                                type EtcdStatus

                                                                                                type EtcdStatus struct {
                                                                                                	Phase  DatabasePhase `json:"phase,omitempty" protobuf:"bytes,1,opt,name=phase,casttype=DatabasePhase"`
                                                                                                	Reason string        `json:"reason,omitempty" protobuf:"bytes,2,opt,name=reason"`
                                                                                                	// observedGeneration is the most recent generation observed for this resource. It corresponds to the
                                                                                                	// resource's generation, which is updated on mutation by the API Server.
                                                                                                	// +optional
                                                                                                	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,3,opt,name=observedGeneration"`
                                                                                                }

                                                                                                func (*EtcdStatus) DeepCopy

                                                                                                func (in *EtcdStatus) DeepCopy() *EtcdStatus

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

                                                                                                  func (*EtcdStatus) DeepCopyInto

                                                                                                  func (in *EtcdStatus) DeepCopyInto(out *EtcdStatus)

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

                                                                                                    func (*EtcdStatus) Descriptor

                                                                                                    func (*EtcdStatus) Descriptor() ([]byte, []int)

                                                                                                    func (*EtcdStatus) Marshal

                                                                                                    func (m *EtcdStatus) Marshal() (dAtA []byte, err error)

                                                                                                    func (*EtcdStatus) MarshalTo

                                                                                                    func (m *EtcdStatus) MarshalTo(dAtA []byte) (int, error)

                                                                                                    func (*EtcdStatus) MarshalToSizedBuffer

                                                                                                    func (m *EtcdStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

                                                                                                    func (*EtcdStatus) ProtoMessage

                                                                                                    func (*EtcdStatus) ProtoMessage()

                                                                                                    func (*EtcdStatus) Reset

                                                                                                    func (m *EtcdStatus) Reset()

                                                                                                    func (*EtcdStatus) Size

                                                                                                    func (m *EtcdStatus) Size() (n int)

                                                                                                    func (*EtcdStatus) String

                                                                                                    func (this *EtcdStatus) String() string

                                                                                                    func (*EtcdStatus) Unmarshal

                                                                                                    func (m *EtcdStatus) Unmarshal(dAtA []byte) error

                                                                                                    func (*EtcdStatus) XXX_DiscardUnknown

                                                                                                    func (m *EtcdStatus) XXX_DiscardUnknown()

                                                                                                    func (*EtcdStatus) XXX_Marshal

                                                                                                    func (m *EtcdStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                                    func (*EtcdStatus) XXX_Merge

                                                                                                    func (m *EtcdStatus) XXX_Merge(src proto.Message)

                                                                                                    func (*EtcdStatus) XXX_Size

                                                                                                    func (m *EtcdStatus) XXX_Size() int

                                                                                                    func (*EtcdStatus) XXX_Unmarshal

                                                                                                    func (m *EtcdStatus) XXX_Unmarshal(b []byte) error

                                                                                                    type InitSpec

                                                                                                    type InitSpec struct {
                                                                                                    	// Initializer object in same namespace of a KubeDB object.
                                                                                                    	// ref: https://github.com/stashed/stash/blob/09af5d319bb5be889186965afb04045781d6f926/apis/stash/v1beta1/restore_session_types.go#L22
                                                                                                    	Initializer *core.TypedLocalObjectReference `json:"initializer,omitempty" protobuf:"bytes,1,opt,name=initializer"`
                                                                                                    	Script      *ScriptSourceSpec               `json:"script,omitempty" protobuf:"bytes,2,opt,name=script"`
                                                                                                    	PostgresWAL *PostgresWALSourceSpec          `json:"postgresWAL,omitempty" protobuf:"bytes,3,opt,name=postgresWAL"`
                                                                                                    }

                                                                                                    func (*InitSpec) DeepCopy

                                                                                                    func (in *InitSpec) DeepCopy() *InitSpec

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

                                                                                                      func (*InitSpec) DeepCopyInto

                                                                                                      func (in *InitSpec) DeepCopyInto(out *InitSpec)

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

                                                                                                        func (*InitSpec) Descriptor

                                                                                                        func (*InitSpec) Descriptor() ([]byte, []int)

                                                                                                        func (*InitSpec) Marshal

                                                                                                        func (m *InitSpec) Marshal() (dAtA []byte, err error)

                                                                                                        func (*InitSpec) MarshalTo

                                                                                                        func (m *InitSpec) MarshalTo(dAtA []byte) (int, error)

                                                                                                        func (*InitSpec) MarshalToSizedBuffer

                                                                                                        func (m *InitSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

                                                                                                        func (*InitSpec) ProtoMessage

                                                                                                        func (*InitSpec) ProtoMessage()

                                                                                                        func (*InitSpec) Reset

                                                                                                        func (m *InitSpec) Reset()

                                                                                                        func (*InitSpec) Size

                                                                                                        func (m *InitSpec) Size() (n int)

                                                                                                        func (*InitSpec) String

                                                                                                        func (this *InitSpec) String() string

                                                                                                        func (*InitSpec) Unmarshal

                                                                                                        func (m *InitSpec) Unmarshal(dAtA []byte) error

                                                                                                        func (*InitSpec) XXX_DiscardUnknown

                                                                                                        func (m *InitSpec) XXX_DiscardUnknown()

                                                                                                        func (*InitSpec) XXX_Marshal

                                                                                                        func (m *InitSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                                        func (*InitSpec) XXX_Merge

                                                                                                        func (m *InitSpec) XXX_Merge(src proto.Message)

                                                                                                        func (*InitSpec) XXX_Size

                                                                                                        func (m *InitSpec) XXX_Size() int

                                                                                                        func (*InitSpec) XXX_Unmarshal

                                                                                                        func (m *InitSpec) XXX_Unmarshal(b []byte) error

                                                                                                        type LeaderElectionConfig

                                                                                                        type LeaderElectionConfig struct {
                                                                                                        	// LeaseDuration is the duration in second that non-leader candidates will
                                                                                                        	// wait to force acquire leadership. This is measured against time of
                                                                                                        	// last observed ack. Default 15
                                                                                                        	LeaseDurationSeconds int32 `json:"leaseDurationSeconds" protobuf:"varint,1,opt,name=leaseDurationSeconds"`
                                                                                                        	// RenewDeadline is the duration in second that the acting master will retry
                                                                                                        	// refreshing leadership before giving up. Normally, LeaseDuration * 2 / 3.
                                                                                                        	// Default 10
                                                                                                        	RenewDeadlineSeconds int32 `json:"renewDeadlineSeconds" protobuf:"varint,2,opt,name=renewDeadlineSeconds"`
                                                                                                        	// RetryPeriod is the duration in second the LeaderElector clients should wait
                                                                                                        	// between tries of actions. Normally, LeaseDuration / 3.
                                                                                                        	// Default 2
                                                                                                        	RetryPeriodSeconds int32 `json:"retryPeriodSeconds" protobuf:"varint,3,opt,name=retryPeriodSeconds"`
                                                                                                        }

                                                                                                          LeaderElectionConfig contains essential attributes of leader election. ref: https://github.com/kubernetes/client-go/blob/6134db91200ea474868bc6775e62cc294a74c6c6/tools/leaderelection/leaderelection.go#L105-L114

                                                                                                          func (*LeaderElectionConfig) DeepCopy

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

                                                                                                            func (*LeaderElectionConfig) DeepCopyInto

                                                                                                            func (in *LeaderElectionConfig) DeepCopyInto(out *LeaderElectionConfig)

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

                                                                                                              func (*LeaderElectionConfig) Descriptor

                                                                                                              func (*LeaderElectionConfig) Descriptor() ([]byte, []int)

                                                                                                              func (*LeaderElectionConfig) Marshal

                                                                                                              func (m *LeaderElectionConfig) Marshal() (dAtA []byte, err error)

                                                                                                              func (*LeaderElectionConfig) MarshalTo

                                                                                                              func (m *LeaderElectionConfig) MarshalTo(dAtA []byte) (int, error)

                                                                                                              func (*LeaderElectionConfig) MarshalToSizedBuffer

                                                                                                              func (m *LeaderElectionConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

                                                                                                              func (*LeaderElectionConfig) ProtoMessage

                                                                                                              func (*LeaderElectionConfig) ProtoMessage()

                                                                                                              func (*LeaderElectionConfig) Reset

                                                                                                              func (m *LeaderElectionConfig) Reset()

                                                                                                              func (*LeaderElectionConfig) Size

                                                                                                              func (m *LeaderElectionConfig) Size() (n int)

                                                                                                              func (*LeaderElectionConfig) String

                                                                                                              func (this *LeaderElectionConfig) String() string

                                                                                                              func (*LeaderElectionConfig) Unmarshal

                                                                                                              func (m *LeaderElectionConfig) Unmarshal(dAtA []byte) error

                                                                                                              func (*LeaderElectionConfig) XXX_DiscardUnknown

                                                                                                              func (m *LeaderElectionConfig) XXX_DiscardUnknown()

                                                                                                              func (*LeaderElectionConfig) XXX_Marshal

                                                                                                              func (m *LeaderElectionConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                                              func (*LeaderElectionConfig) XXX_Merge

                                                                                                              func (m *LeaderElectionConfig) XXX_Merge(src proto.Message)

                                                                                                              func (*LeaderElectionConfig) XXX_Size

                                                                                                              func (m *LeaderElectionConfig) XXX_Size() int

                                                                                                              func (*LeaderElectionConfig) XXX_Unmarshal

                                                                                                              func (m *LeaderElectionConfig) XXX_Unmarshal(b []byte) error

                                                                                                              type LoadBalanceMode

                                                                                                              type LoadBalanceMode string

                                                                                                                +kubebuilder:validation:Enum=Galera;GroupReplication

                                                                                                                const (
                                                                                                                	LoadBalanceModeGalera           LoadBalanceMode = "Galera"
                                                                                                                	LoadBalanceModeGroupReplication LoadBalanceMode = "GroupReplication"
                                                                                                                )

                                                                                                                type MariaDB

                                                                                                                type MariaDB struct {
                                                                                                                	metav1.TypeMeta   `json:",inline,omitempty"`
                                                                                                                	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
                                                                                                                	Spec              MariaDBSpec   `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
                                                                                                                	Status            MariaDBStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
                                                                                                                }

                                                                                                                  +kubebuilder:object:root=true +kubebuilder:resource:path=mariadbs,singular=mariadb,shortName=md,categories={datastore,kubedb,appscode,all} +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Version",type="string",JSONPath=".spec.version" +kubebuilder:printcolumn:name="Status",type="string",JSONPath=".status.phase" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp"

                                                                                                                  func (MariaDB) AppBindingMeta

                                                                                                                  func (m MariaDB) AppBindingMeta() appcat.AppBindingMeta

                                                                                                                  func (MariaDB) CustomResourceDefinition

                                                                                                                  func (_ MariaDB) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

                                                                                                                  func (*MariaDB) DeepCopy

                                                                                                                  func (in *MariaDB) DeepCopy() *MariaDB

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

                                                                                                                    func (*MariaDB) DeepCopyInto

                                                                                                                    func (in *MariaDB) DeepCopyInto(out *MariaDB)

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

                                                                                                                      func (*MariaDB) DeepCopyObject

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

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

                                                                                                                        func (*MariaDB) Descriptor

                                                                                                                        func (*MariaDB) Descriptor() ([]byte, []int)

                                                                                                                        func (*MariaDB) GetMonitoringVendor

                                                                                                                        func (m *MariaDB) GetMonitoringVendor() string

                                                                                                                        func (MariaDB) GoverningServiceName

                                                                                                                        func (m MariaDB) GoverningServiceName() string

                                                                                                                        func (*MariaDB) Marshal

                                                                                                                        func (m *MariaDB) Marshal() (dAtA []byte, err error)

                                                                                                                        func (*MariaDB) MarshalTo

                                                                                                                        func (m *MariaDB) MarshalTo(dAtA []byte) (int, error)

                                                                                                                        func (*MariaDB) MarshalToSizedBuffer

                                                                                                                        func (m *MariaDB) MarshalToSizedBuffer(dAtA []byte) (int, error)

                                                                                                                        func (MariaDB) OffshootLabels

                                                                                                                        func (m MariaDB) OffshootLabels() map[string]string

                                                                                                                        func (MariaDB) OffshootName

                                                                                                                        func (m MariaDB) OffshootName() string

                                                                                                                        func (MariaDB) OffshootSelectors

                                                                                                                        func (m MariaDB) OffshootSelectors() map[string]string

                                                                                                                        func (*MariaDB) ProtoMessage

                                                                                                                        func (*MariaDB) ProtoMessage()

                                                                                                                        func (*MariaDB) Reset

                                                                                                                        func (m *MariaDB) Reset()

                                                                                                                        func (MariaDB) ResourceKind

                                                                                                                        func (m MariaDB) ResourceKind() string

                                                                                                                        func (MariaDB) ResourcePlural

                                                                                                                        func (m MariaDB) ResourcePlural() string

                                                                                                                        func (MariaDB) ResourceShortCode

                                                                                                                        func (m MariaDB) ResourceShortCode() string

                                                                                                                        func (MariaDB) ResourceSingular

                                                                                                                        func (m MariaDB) ResourceSingular() string

                                                                                                                        func (MariaDB) ServiceName

                                                                                                                        func (m MariaDB) ServiceName() string

                                                                                                                        func (*MariaDB) SetDefaults

                                                                                                                        func (m *MariaDB) SetDefaults()

                                                                                                                        func (*MariaDB) Size

                                                                                                                        func (m *MariaDB) Size() (n int)

                                                                                                                        func (MariaDB) StatsService

                                                                                                                        func (m MariaDB) StatsService() mona.StatsAccessor

                                                                                                                        func (MariaDB) StatsServiceLabels

                                                                                                                        func (m MariaDB) StatsServiceLabels() map[string]string

                                                                                                                        func (*MariaDB) String

                                                                                                                        func (this *MariaDB) String() string

                                                                                                                        func (*MariaDB) Unmarshal

                                                                                                                        func (m *MariaDB) Unmarshal(dAtA []byte) error