apimachinery: kubedb.dev/apimachinery/apis/kubedb/v1alpha1 Index | Files

package v1alpha1

import "kubedb.dev/apimachinery/apis/kubedb/v1alpha1"

+groupName=kubedb.com

Index

Package Files

constants.go doc.go elasticsearch_helpers.go elasticsearch_types.go etcd_helpers.go etcd_types.go generated.pb.go mariadb_helpers.go mariadb_types.go memcached_helpers.go memcached_types.go mongodb_helpers.go mongodb_types.go mysql_helpers.go mysql_types.go openapi_generated.go perconaxtradb_helpers.go perconaxtradb_types.go pgbouncer_helpers.go pgbouncer_types.go postgres_helpers.go postgres_types.go proxysql_helpers.go proxysql_types.go redis_helpers.go redis_types.go register.go types.go zz_generated.deepcopy.go

Constants

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"
)
const (
    ResourceCodeElasticsearch     = "es"
    ResourceKindElasticsearch     = "Elasticsearch"
    ResourceSingularElasticsearch = "elasticsearch"
    ResourcePluralElasticsearch   = "elasticsearches"
)
const (
    ResourceCodeEtcd     = "etc"
    ResourceKindEtcd     = "Etcd"
    ResourceSingularEtcd = "etcd"
    ResourcePluralEtcd   = "etcds"
)
const (
    ResourceCodeMariaDB     = "md"
    ResourceKindMariaDB     = "MariaDB"
    ResourceSingularMariaDB = "mariadb"
    ResourcePluralMariaDB   = "mariadbs"
)
const (
    ResourceCodeMemcached     = "mc"
    ResourceKindMemcached     = "Memcached"
    ResourceSingularMemcached = "memcached"
    ResourcePluralMemcached   = "memcacheds"
)
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"
)
const (
    ResourceCodeMongoDB     = "mg"
    ResourceKindMongoDB     = "MongoDB"
    ResourceSingularMongoDB = "mongodb"
    ResourcePluralMongoDB   = "mongodbs"

    MongoDBInitInstallContainerName   = "copy-config"
    MongoDBInitBootstrapContainerName = "bootstrap"
    MongoDBConfigDirectoryName        = "configdir"
    MongoDBContainerName              = ResourceSingularMongoDB
)
const (
    ResourceCodeMySQL     = "my"
    ResourceKindMySQL     = "MySQL"
    ResourceSingularMySQL = "mysql"
    ResourcePluralMySQL   = "mysqls"
)
const (
    ResourceCodePerconaXtraDB     = "px"
    ResourceKindPerconaXtraDB     = "PerconaXtraDB"
    ResourceSingularPerconaXtraDB = "perconaxtradb"
    ResourcePluralPerconaXtraDB   = "perconaxtradbs"
)
const (
    ResourceCodePgBouncer     = "pb"
    ResourceKindPgBouncer     = "PgBouncer"
    ResourceSingularPgBouncer = "pgbouncer"
    ResourcePluralPgBouncer   = "pgbouncers"
)
const (
    ResourceCodePostgres     = "pg"
    ResourceKindPostgres     = "Postgres"
    ResourceSingularPostgres = "postgres"
    ResourcePluralPostgres   = "postgreses"
)
const (
    ResourceCodeProxySQL     = "psql"
    ResourceKindProxySQL     = "ProxySQL"
    ResourceSingularProxySQL = "proxysql"
    ResourcePluralProxySQL   = "proxysqls"
)
const (
    ResourceCodeRedis     = "rd"
    ResourceKindRedis     = "Redis"
    ResourceSingularRedis = "redis"
    ResourcePluralRedis   = "redises"
)
const (
    ElasticsearchNodeAffinityTemplateVar = "NODE_ROLE"
)
const (
    RedisShardAffinityTemplateVar = "SHARD_INDEX"
)

Variables

var (
    ErrInvalidLengthGenerated        = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowGenerated          = fmt.Errorf("proto: integer overflow")
    ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")
)
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
)
var SchemeGroupVersion = schema.GroupVersion{Group: kubedb.GroupName, Version: "v1alpha1"}

func GetOpenAPIDefinitions Uses

func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition

func Kind Uses

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns a Group qualified GroupKind

func Resource Uses

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

type ClusterAuthMode Uses

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 Uses

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 Uses

func (in *ConnectionPoolConfig) DeepCopy() *ConnectionPoolConfig

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

func (*ConnectionPoolConfig) DeepCopyInto Uses

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 Uses

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

func (*ConnectionPoolConfig) Marshal Uses

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

func (*ConnectionPoolConfig) MarshalTo Uses

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

func (*ConnectionPoolConfig) MarshalToSizedBuffer Uses

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

func (*ConnectionPoolConfig) ProtoMessage Uses

func (*ConnectionPoolConfig) ProtoMessage()

func (*ConnectionPoolConfig) Reset Uses

func (m *ConnectionPoolConfig) Reset()

func (*ConnectionPoolConfig) Size Uses

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

func (*ConnectionPoolConfig) String Uses

func (this *ConnectionPoolConfig) String() string

func (*ConnectionPoolConfig) Unmarshal Uses

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

func (*ConnectionPoolConfig) XXX_DiscardUnknown Uses

func (m *ConnectionPoolConfig) XXX_DiscardUnknown()

func (*ConnectionPoolConfig) XXX_Marshal Uses

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

func (*ConnectionPoolConfig) XXX_Merge Uses

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

func (*ConnectionPoolConfig) XXX_Size Uses

func (m *ConnectionPoolConfig) XXX_Size() int

func (*ConnectionPoolConfig) XXX_Unmarshal Uses

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

type DatabasePhase Uses

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 Uses

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 Uses

func (in *Databases) DeepCopy() *Databases

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

func (*Databases) DeepCopyInto Uses

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 Uses

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

func (*Databases) Marshal Uses

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

func (*Databases) MarshalTo Uses

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

func (*Databases) MarshalToSizedBuffer Uses

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

func (*Databases) ProtoMessage Uses

func (*Databases) ProtoMessage()

func (*Databases) Reset Uses

func (m *Databases) Reset()

func (*Databases) Size Uses

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

func (*Databases) String Uses

func (this *Databases) String() string

func (*Databases) Unmarshal Uses

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

func (*Databases) XXX_DiscardUnknown Uses

func (m *Databases) XXX_DiscardUnknown()

func (*Databases) XXX_Marshal Uses

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

func (*Databases) XXX_Merge Uses

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

func (*Databases) XXX_Size Uses

func (m *Databases) XXX_Size() int

func (*Databases) XXX_Unmarshal Uses

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

type Elasticsearch Uses

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 Uses

func (e Elasticsearch) AppBindingMeta() appcat.AppBindingMeta

func (*Elasticsearch) CertSecretVolumeMountPath Uses

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 Uses

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 Uses

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 Uses

func (e *Elasticsearch) ConfigSecretName() string

returns the secret name for the default elasticsearch configuration

func (Elasticsearch) CustomResourceDefinition Uses

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

func (*Elasticsearch) DeepCopy Uses

func (in *Elasticsearch) DeepCopy() *Elasticsearch

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

func (*Elasticsearch) DeepCopyInto Uses

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 Uses

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

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

func (*Elasticsearch) Descriptor Uses

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

func (*Elasticsearch) GetConnectionScheme Uses

func (e *Elasticsearch) GetConnectionScheme() string

func (*Elasticsearch) GetConnectionURL Uses

func (e *Elasticsearch) GetConnectionURL() string

func (*Elasticsearch) GetMatchExpressions Uses

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

func (*Elasticsearch) GetMonitoringVendor Uses

func (e *Elasticsearch) GetMonitoringVendor() string

func (Elasticsearch) GvrSvcName Uses

func (e Elasticsearch) GvrSvcName() string

Governing Service Name

func (*Elasticsearch) Marshal Uses

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

func (*Elasticsearch) MarshalTo Uses

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

func (*Elasticsearch) MarshalToSizedBuffer Uses

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

func (*Elasticsearch) MasterServiceName Uses

func (e *Elasticsearch) MasterServiceName() string

func (*Elasticsearch) MustCertSecretName Uses

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

MustCertSecretName returns the secret name for a certificate alias

func (Elasticsearch) OffshootLabels Uses

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

func (Elasticsearch) OffshootName Uses

func (e Elasticsearch) OffshootName() string

func (Elasticsearch) OffshootSelectors Uses

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

func (*Elasticsearch) ProtoMessage Uses

func (*Elasticsearch) ProtoMessage()

func (*Elasticsearch) Reset Uses

func (m *Elasticsearch) Reset()

func (Elasticsearch) ResourceKind Uses

func (e Elasticsearch) ResourceKind() string

func (Elasticsearch) ResourcePlural Uses

func (e Elasticsearch) ResourcePlural() string

func (Elasticsearch) ResourceShortCode Uses

func (e Elasticsearch) ResourceShortCode() string

func (Elasticsearch) ResourceSingular Uses

func (e Elasticsearch) ResourceSingular() string

func (Elasticsearch) ServiceName Uses

func (e Elasticsearch) ServiceName() string

func (*Elasticsearch) SetDefaults Uses

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

func (*Elasticsearch) Size Uses

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

func (Elasticsearch) StatsService Uses

func (e Elasticsearch) StatsService() mona.StatsAccessor

func (Elasticsearch) StatsServiceLabels Uses

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

func (*Elasticsearch) String Uses

func (this *Elasticsearch) String() string

func (*Elasticsearch) Unmarshal Uses

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

func (*Elasticsearch) UserCredSecretName Uses

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 Uses

func (m *Elasticsearch) XXX_DiscardUnknown()

func (*Elasticsearch) XXX_Marshal Uses

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

func (*Elasticsearch) XXX_Merge Uses

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

func (*Elasticsearch) XXX_Size Uses

func (m *Elasticsearch) XXX_Size() int

func (*Elasticsearch) XXX_Unmarshal Uses

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

type ElasticsearchCertificateAlias Uses

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 Uses

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 Uses

func (in *ElasticsearchClusterTopology) DeepCopy() *ElasticsearchClusterTopology

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

func (*ElasticsearchClusterTopology) DeepCopyInto Uses

func (in *ElasticsearchClusterTopology) DeepCopyInto(out *ElasticsearchClusterTopology)

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

func (*ElasticsearchClusterTopology) Descriptor Uses

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

func (*ElasticsearchClusterTopology) Marshal Uses

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

func (*ElasticsearchClusterTopology) MarshalTo Uses

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

func (*ElasticsearchClusterTopology) MarshalToSizedBuffer Uses

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

func (*ElasticsearchClusterTopology) ProtoMessage Uses

func (*ElasticsearchClusterTopology) ProtoMessage()

func (*ElasticsearchClusterTopology) Reset Uses

func (m *ElasticsearchClusterTopology) Reset()

func (*ElasticsearchClusterTopology) Size Uses

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

func (*ElasticsearchClusterTopology) String Uses

func (this *ElasticsearchClusterTopology) String() string

func (*ElasticsearchClusterTopology) Unmarshal Uses

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

func (*ElasticsearchClusterTopology) XXX_DiscardUnknown Uses

func (m *ElasticsearchClusterTopology) XXX_DiscardUnknown()

func (*ElasticsearchClusterTopology) XXX_Marshal Uses

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

func (*ElasticsearchClusterTopology) XXX_Merge Uses

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

func (*ElasticsearchClusterTopology) XXX_Size Uses

func (m *ElasticsearchClusterTopology) XXX_Size() int

func (*ElasticsearchClusterTopology) XXX_Unmarshal Uses

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

type ElasticsearchInternalUser Uses

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 Uses

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 Uses

func (in *ElasticsearchList) DeepCopy() *ElasticsearchList

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

func (*ElasticsearchList) DeepCopyInto Uses

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 Uses

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

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

func (*ElasticsearchList) Descriptor Uses

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

func (*ElasticsearchList) Marshal Uses

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

func (*ElasticsearchList) MarshalTo Uses

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

func (*ElasticsearchList) MarshalToSizedBuffer Uses

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

func (*ElasticsearchList) ProtoMessage Uses

func (*ElasticsearchList) ProtoMessage()

func (*ElasticsearchList) Reset Uses

func (m *ElasticsearchList) Reset()

func (*ElasticsearchList) Size Uses

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

func (*ElasticsearchList) String Uses

func (this *ElasticsearchList) String() string

func (*ElasticsearchList) Unmarshal Uses

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

func (*ElasticsearchList) XXX_DiscardUnknown Uses

func (m *ElasticsearchList) XXX_DiscardUnknown()

func (*ElasticsearchList) XXX_Marshal Uses

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

func (*ElasticsearchList) XXX_Merge Uses

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

func (*ElasticsearchList) XXX_Size Uses

func (m *ElasticsearchList) XXX_Size() int

func (*ElasticsearchList) XXX_Unmarshal Uses

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

type ElasticsearchNode Uses

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 Uses

func (in *ElasticsearchNode) DeepCopy() *ElasticsearchNode

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

func (*ElasticsearchNode) DeepCopyInto Uses

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 Uses

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

func (*ElasticsearchNode) Marshal Uses

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

func (*ElasticsearchNode) MarshalTo Uses

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

func (*ElasticsearchNode) MarshalToSizedBuffer Uses

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

func (*ElasticsearchNode) ProtoMessage Uses

func (*ElasticsearchNode) ProtoMessage()

func (*ElasticsearchNode) Reset Uses

func (m *ElasticsearchNode) Reset()

func (*ElasticsearchNode) Size Uses

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

func (*ElasticsearchNode) String Uses

func (this *ElasticsearchNode) String() string

func (*ElasticsearchNode) Unmarshal Uses

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

func (*ElasticsearchNode) XXX_DiscardUnknown Uses

func (m *ElasticsearchNode) XXX_DiscardUnknown()

func (*ElasticsearchNode) XXX_Marshal Uses

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

func (*ElasticsearchNode) XXX_Merge Uses

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

func (*ElasticsearchNode) XXX_Size Uses

func (m *ElasticsearchNode) XXX_Size() int

func (*ElasticsearchNode) XXX_Unmarshal Uses

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

type ElasticsearchRoleMapSpec Uses

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 Uses

func (in *ElasticsearchRoleMapSpec) DeepCopy() *ElasticsearchRoleMapSpec

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

func (*ElasticsearchRoleMapSpec) DeepCopyInto Uses

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 Uses

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

func (*ElasticsearchRoleMapSpec) Marshal Uses

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

func (*ElasticsearchRoleMapSpec) MarshalTo Uses

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

func (*ElasticsearchRoleMapSpec) MarshalToSizedBuffer Uses

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

func (*ElasticsearchRoleMapSpec) ProtoMessage Uses

func (*ElasticsearchRoleMapSpec) ProtoMessage()

func (*ElasticsearchRoleMapSpec) Reset Uses

func (m *ElasticsearchRoleMapSpec) Reset()

func (*ElasticsearchRoleMapSpec) Size Uses

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

func (*ElasticsearchRoleMapSpec) String Uses

func (this *ElasticsearchRoleMapSpec) String() string

func (*ElasticsearchRoleMapSpec) Unmarshal Uses

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

func (*ElasticsearchRoleMapSpec) XXX_DiscardUnknown Uses

func (m *ElasticsearchRoleMapSpec) XXX_DiscardUnknown()

func (*ElasticsearchRoleMapSpec) XXX_Marshal Uses

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

func (*ElasticsearchRoleMapSpec) XXX_Merge Uses

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

func (*ElasticsearchRoleMapSpec) XXX_Size Uses

func (m *ElasticsearchRoleMapSpec) XXX_Size() int

func (*ElasticsearchRoleMapSpec) XXX_Unmarshal Uses

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

type ElasticsearchSpec Uses

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 `json:"authPlugin,omitempty" protobuf:"bytes,7,opt,name=authPlugin,casttype=kubedb.dev/apimachinery/apis/catalog/v1alpha1.ElasticsearchAuthPlugin"`

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

func (in *ElasticsearchSpec) DeepCopy() *ElasticsearchSpec

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

func (*ElasticsearchSpec) DeepCopyInto Uses

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 Uses

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

func (*ElasticsearchSpec) GetSecrets Uses

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

func (*ElasticsearchSpec) Marshal Uses

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

func (*ElasticsearchSpec) MarshalTo Uses

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

func (*ElasticsearchSpec) MarshalToSizedBuffer Uses

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

func (*ElasticsearchSpec) ProtoMessage Uses

func (*ElasticsearchSpec) ProtoMessage()

func (*ElasticsearchSpec) Reset Uses

func (m *ElasticsearchSpec) Reset()

func (*ElasticsearchSpec) Size Uses

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

func (*ElasticsearchSpec) String Uses

func (this *ElasticsearchSpec) String() string

func (*ElasticsearchSpec) Unmarshal Uses

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

func (*ElasticsearchSpec) XXX_DiscardUnknown Uses

func (m *ElasticsearchSpec) XXX_DiscardUnknown()

func (*ElasticsearchSpec) XXX_Marshal Uses

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

func (*ElasticsearchSpec) XXX_Merge Uses

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

func (*ElasticsearchSpec) XXX_Size Uses

func (m *ElasticsearchSpec) XXX_Size() int

func (*ElasticsearchSpec) XXX_Unmarshal Uses

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

type ElasticsearchStatus Uses

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 Uses

func (in *ElasticsearchStatus) DeepCopy() *ElasticsearchStatus

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

func (*ElasticsearchStatus) DeepCopyInto Uses

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 Uses

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

func (*ElasticsearchStatus) Marshal Uses

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

func (*ElasticsearchStatus) MarshalTo Uses

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

func (*ElasticsearchStatus) MarshalToSizedBuffer Uses

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

func (*ElasticsearchStatus) ProtoMessage Uses

func (*ElasticsearchStatus) ProtoMessage()

func (*ElasticsearchStatus) Reset Uses

func (m *ElasticsearchStatus) Reset()

func (*ElasticsearchStatus) Size Uses

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

func (*ElasticsearchStatus) String Uses

func (this *ElasticsearchStatus) String() string

func (*ElasticsearchStatus) Unmarshal Uses

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

func (*ElasticsearchStatus) XXX_DiscardUnknown Uses

func (m *ElasticsearchStatus) XXX_DiscardUnknown()

func (*ElasticsearchStatus) XXX_Marshal Uses

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

func (*ElasticsearchStatus) XXX_Merge Uses

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

func (*ElasticsearchStatus) XXX_Size Uses

func (m *ElasticsearchStatus) XXX_Size() int

func (*ElasticsearchStatus) XXX_Unmarshal Uses

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

type ElasticsearchUserSpec Uses

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 `json:"opendistroSecurityRoles,omitempty" yaml:"opendistro_security_roles,omitempty" protobuf:"bytes,6,opt,name=opendistroSecurityRoles"`

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

func (in *ElasticsearchUserSpec) DeepCopy() *ElasticsearchUserSpec

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

func (*ElasticsearchUserSpec) DeepCopyInto Uses

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 Uses

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

func (*ElasticsearchUserSpec) Marshal Uses

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

func (*ElasticsearchUserSpec) MarshalTo Uses

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

func (*ElasticsearchUserSpec) MarshalToSizedBuffer Uses

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

func (*ElasticsearchUserSpec) ProtoMessage Uses

func (*ElasticsearchUserSpec) ProtoMessage()

func (*ElasticsearchUserSpec) Reset Uses

func (m *ElasticsearchUserSpec) Reset()

func (*ElasticsearchUserSpec) Size Uses

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

func (*ElasticsearchUserSpec) String Uses

func (this *ElasticsearchUserSpec) String() string

func (*ElasticsearchUserSpec) Unmarshal Uses

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

func (*ElasticsearchUserSpec) XXX_DiscardUnknown Uses

func (m *ElasticsearchUserSpec) XXX_DiscardUnknown()

func (*ElasticsearchUserSpec) XXX_Marshal Uses

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

func (*ElasticsearchUserSpec) XXX_Merge Uses

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

func (*ElasticsearchUserSpec) XXX_Size Uses

func (m *ElasticsearchUserSpec) XXX_Size() int

func (*ElasticsearchUserSpec) XXX_Unmarshal Uses

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

type Etcd Uses

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 Uses

func (r Etcd) AppBindingMeta() appcat.AppBindingMeta

func (Etcd) ClientServiceName Uses

func (e Etcd) ClientServiceName() string

func (Etcd) CustomResourceDefinition Uses

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

func (*Etcd) DeepCopy Uses

func (in *Etcd) DeepCopy() *Etcd

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

func (*Etcd) DeepCopyInto Uses

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 Uses

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

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

func (*Etcd) Descriptor Uses

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

func (*Etcd) GetMonitoringVendor Uses

func (e *Etcd) GetMonitoringVendor() string

func (*Etcd) Marshal Uses

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

func (*Etcd) MarshalTo Uses

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

func (*Etcd) MarshalToSizedBuffer Uses

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

func (Etcd) OffshootLabels Uses

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

func (Etcd) OffshootName Uses

func (e Etcd) OffshootName() string

func (Etcd) OffshootSelectors Uses

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

func (Etcd) PeerServiceName Uses

func (e Etcd) PeerServiceName() string

func (*Etcd) ProtoMessage Uses

func (*Etcd) ProtoMessage()

func (*Etcd) Reset Uses

func (m *Etcd) Reset()

func (Etcd) ResourceKind Uses

func (e Etcd) ResourceKind() string

func (Etcd) ResourcePlural Uses

func (e Etcd) ResourcePlural() string

func (Etcd) ResourceShortCode Uses

func (e Etcd) ResourceShortCode() string

func (Etcd) ResourceSingular Uses

func (e Etcd) ResourceSingular() string

func (*Etcd) SetDefaults Uses

func (e *Etcd) SetDefaults()

func (*Etcd) Size Uses

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

func (Etcd) StatsService Uses

func (e Etcd) StatsService() mona.StatsAccessor

func (Etcd) StatsServiceLabels Uses

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

func (*Etcd) String Uses

func (this *Etcd) String() string

func (*Etcd) Unmarshal Uses

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

func (*Etcd) XXX_DiscardUnknown Uses

func (m *Etcd) XXX_DiscardUnknown()

func (*Etcd) XXX_Marshal Uses

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

func (*Etcd) XXX_Merge Uses

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

func (*Etcd) XXX_Size Uses

func (m *Etcd) XXX_Size() int

func (*Etcd) XXX_Unmarshal Uses

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

type EtcdList Uses

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 Uses

func (in *EtcdList) DeepCopy() *EtcdList

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

func (*EtcdList) DeepCopyInto Uses

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 Uses

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

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

func (*EtcdList) Descriptor Uses

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

func (*EtcdList) Marshal Uses

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

func (*EtcdList) MarshalTo Uses

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

func (*EtcdList) MarshalToSizedBuffer Uses

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

func (*EtcdList) ProtoMessage Uses

func (*EtcdList) ProtoMessage()

func (*EtcdList) Reset Uses

func (m *EtcdList) Reset()

func (*EtcdList) Size Uses

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

func (*EtcdList) String Uses

func (this *EtcdList) String() string

func (*EtcdList) Unmarshal Uses

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

func (*EtcdList) XXX_DiscardUnknown Uses

func (m *EtcdList) XXX_DiscardUnknown()

func (*EtcdList) XXX_Marshal Uses

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

func (*EtcdList) XXX_Merge Uses

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

func (*EtcdList) XXX_Size Uses

func (m *EtcdList) XXX_Size() int

func (*EtcdList) XXX_Unmarshal Uses

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

type EtcdSpec Uses

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 Uses

func (in *EtcdSpec) DeepCopy() *EtcdSpec

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

func (*EtcdSpec) DeepCopyInto Uses

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 Uses

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

func (*EtcdSpec) GetSecrets Uses

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

func (*EtcdSpec) Marshal Uses

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

func (*EtcdSpec) MarshalTo Uses

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

func (*EtcdSpec) MarshalToSizedBuffer Uses

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

func (*EtcdSpec) ProtoMessage Uses

func (*EtcdSpec) ProtoMessage()

func (*EtcdSpec) Reset Uses

func (m *EtcdSpec) Reset()

func (*EtcdSpec) Size Uses

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

func (*EtcdSpec) String Uses

func (this *EtcdSpec) String() string

func (*EtcdSpec) Unmarshal Uses

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

func (*EtcdSpec) XXX_DiscardUnknown Uses

func (m *EtcdSpec) XXX_DiscardUnknown()

func (*EtcdSpec) XXX_Marshal Uses

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

func (*EtcdSpec) XXX_Merge Uses

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

func (*EtcdSpec) XXX_Size Uses

func (m *EtcdSpec) XXX_Size() int

func (*EtcdSpec) XXX_Unmarshal Uses

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

type EtcdStatus Uses

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 Uses

func (in *EtcdStatus) DeepCopy() *EtcdStatus

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

func (*EtcdStatus) DeepCopyInto Uses

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 Uses

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

func (*EtcdStatus) Marshal Uses

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

func (*EtcdStatus) MarshalTo Uses

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

func (*EtcdStatus) MarshalToSizedBuffer Uses

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

func (*EtcdStatus) ProtoMessage Uses

func (*EtcdStatus) ProtoMessage()

func (*EtcdStatus) Reset Uses

func (m *EtcdStatus) Reset()

func (*EtcdStatus) Size Uses

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

func (*EtcdStatus) String Uses

func (this *EtcdStatus) String() string

func (*EtcdStatus) Unmarshal Uses

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

func (*EtcdStatus) XXX_DiscardUnknown Uses

func (m *EtcdStatus) XXX_DiscardUnknown()

func (*EtcdStatus) XXX_Marshal Uses

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

func (*EtcdStatus) XXX_Merge Uses

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

func (*EtcdStatus) XXX_Size Uses

func (m *EtcdStatus) XXX_Size() int

func (*EtcdStatus) XXX_Unmarshal Uses

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

type InitSpec Uses

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 Uses

func (in *InitSpec) DeepCopy() *InitSpec

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

func (*InitSpec) DeepCopyInto Uses

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 Uses

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

func (*InitSpec) Marshal Uses

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

func (*InitSpec) MarshalTo Uses

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

func (*InitSpec) MarshalToSizedBuffer Uses

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

func (*InitSpec) ProtoMessage Uses

func (*InitSpec) ProtoMessage()

func (*InitSpec) Reset Uses

func (m *InitSpec) Reset()

func (*InitSpec) Size Uses

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

func (*InitSpec) String Uses

func (this *InitSpec) String() string

func (*InitSpec) Unmarshal Uses

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

func (*InitSpec) XXX_DiscardUnknown Uses

func (m *InitSpec) XXX_DiscardUnknown()

func (*InitSpec) XXX_Marshal Uses

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

func (*InitSpec) XXX_Merge Uses

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

func (*InitSpec) XXX_Size Uses

func (m *InitSpec) XXX_Size() int

func (*InitSpec) XXX_Unmarshal Uses

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

type LeaderElectionConfig Uses

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 Uses

func (in *LeaderElectionConfig) DeepCopy() *LeaderElectionConfig

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

func (*LeaderElectionConfig) DeepCopyInto Uses

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 Uses

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

func (*LeaderElectionConfig) Marshal Uses

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

func (*LeaderElectionConfig) MarshalTo Uses

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

func (*LeaderElectionConfig) MarshalToSizedBuffer Uses

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

func (*LeaderElectionConfig) ProtoMessage Uses

func (*LeaderElectionConfig) ProtoMessage()

func (*LeaderElectionConfig) Reset Uses

func (m *LeaderElectionConfig) Reset()

func (*LeaderElectionConfig) Size Uses

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

func (*LeaderElectionConfig) String Uses

func (this *LeaderElectionConfig) String() string

func (*LeaderElectionConfig) Unmarshal Uses

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

func (*LeaderElectionConfig) XXX_DiscardUnknown Uses

func (m *LeaderElectionConfig) XXX_DiscardUnknown()

func (*LeaderElectionConfig) XXX_Marshal Uses

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

func (*LeaderElectionConfig) XXX_Merge Uses

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

func (*LeaderElectionConfig) XXX_Size Uses

func (m *LeaderElectionConfig) XXX_Size() int

func (*LeaderElectionConfig) XXX_Unmarshal Uses

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

type LoadBalanceMode Uses

type LoadBalanceMode string

+kubebuilder:validation:Enum=Galera;GroupReplication

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

type MariaDB Uses

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 Uses

func (m MariaDB) AppBindingMeta() appcat.AppBindingMeta

func (MariaDB) CustomResourceDefinition Uses

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

func (*MariaDB) DeepCopy Uses

func (in *MariaDB) DeepCopy() *MariaDB

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

func (*MariaDB) DeepCopyInto Uses

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 Uses

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

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

func (*MariaDB) Descriptor Uses

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

func (*MariaDB) GetMonitoringVendor Uses

func (m *MariaDB) GetMonitoringVendor() string

func (MariaDB) GoverningServiceName Uses

func (m MariaDB) GoverningServiceName() string

func (*MariaDB) Marshal Uses

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

func (*MariaDB) MarshalTo Uses

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

func (*MariaDB) MarshalToSizedBuffer Uses

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

func (MariaDB) OffshootLabels Uses

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

func (MariaDB) OffshootName Uses

func (m MariaDB) OffshootName() string

func (MariaDB) OffshootSelectors Uses

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

func (*MariaDB) ProtoMessage Uses

func (*MariaDB) ProtoMessage()

func (*MariaDB) Reset Uses

func (m *MariaDB) Reset()

func (MariaDB) ResourceKind Uses

func (m MariaDB) ResourceKind() string

func (MariaDB) ResourcePlural Uses

func (m MariaDB) ResourcePlural() string

func (MariaDB) ResourceShortCode Uses

func (m MariaDB) ResourceShortCode() string

func (MariaDB) ResourceSingular Uses

func (m MariaDB) ResourceSingular() string

func (MariaDB) ServiceName Uses

func (m MariaDB) ServiceName() string

func (*MariaDB) SetDefaults Uses

func (m *MariaDB) SetDefaults()

func (*MariaDB) Size Uses

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

func (MariaDB) StatsService Uses

func (m MariaDB) StatsService() mona.StatsAccessor

func (MariaDB) StatsServiceLabels Uses

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

func (*MariaDB) String Uses

func (this *MariaDB) String() string

func (*MariaDB) Unmarshal Uses

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

func (*MariaDB) XXX_DiscardUnknown Uses

func (m *MariaDB) XXX_DiscardUnknown()

func (*MariaDB) XXX_Marshal Uses

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

func (*MariaDB) XXX_Merge Uses

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

func (*MariaDB) XXX_Size Uses

func (m *MariaDB) XXX_Size() int

func (*MariaDB) XXX_Unmarshal Uses

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

type MariaDBCertificateAlias Uses

type MariaDBCertificateAlias string

+kubebuilder:validation:Enum=server;archiver;metrics-exporter

const (
    MariaDBServerCert          MariaDBCertificateAlias = "server"
    MariaDBArchiverCert        MariaDBCertificateAlias = "archiver"
    MariaDBMetricsExporterCert MariaDBCertificateAlias = "metrics-exporter"
)

type MariaDBList Uses

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

func (*MariaDBList) DeepCopy Uses

func (in *MariaDBList) DeepCopy() *MariaDBList

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

func (*MariaDBList) DeepCopyInto Uses

func (in *MariaDBList) DeepCopyInto(out *MariaDBList)

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

func (*MariaDBList) DeepCopyObject Uses

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

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

func (*MariaDBList) Descriptor Uses

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

func (*MariaDBList) Marshal Uses

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

func (*MariaDBList) MarshalTo Uses

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

func (*MariaDBList) MarshalToSizedBuffer Uses

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

func (*MariaDBList) ProtoMessage Uses

func (*MariaDBList) ProtoMessage()

func (*MariaDBList) Reset Uses

func (m *MariaDBList) Reset()

func (*MariaDBList) Size Uses

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

func (*MariaDBList) String Uses

func (this *MariaDBList) String() string

func (*MariaDBList) Unmarshal Uses

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

func (*MariaDBList) XXX_DiscardUnknown Uses

func (m *MariaDBList) XXX_DiscardUnknown()

func (*MariaDBList) XXX_Marshal Uses

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

func (*MariaDBList) XXX_Merge Uses

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

func (*MariaDBList) XXX_Size Uses

func (m *MariaDBList) XXX_Size() int

func (*MariaDBList) XXX_Unmarshal Uses

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

type MariaDBSpec Uses

type MariaDBSpec struct {
    // Version of MariaDB to be deployed.
    Version string `json:"version" protobuf:"bytes,1,opt,name=version"`

    // Number of instances to deploy for a MariaDB 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,7,opt,name=monitor"`

    // ConfigSource is an optional field to provide custom configuration file for database (i.e custom-mysql.cnf).
    // 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,8,opt,name=configSource"`

    // PodTemplate is an optional configuration for pods used to expose database
    // +optional
    PodTemplate ofst.PodTemplateSpec `json:"podTemplate,omitempty" protobuf:"bytes,9,opt,name=podTemplate"`

    // ServiceTemplate is an optional configuration for service used to expose database
    // +optional
    ServiceTemplate ofst.ServiceTemplateSpec `json:"serviceTemplate,omitempty" protobuf:"bytes,10,opt,name=serviceTemplate"`

    // TLS contains tls configurations
    // +optional
    TLS *kmapi.TLSConfig `json:"tls,omitempty" protobuf:"bytes,11,opt,name=tls"`

    // 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 (*MariaDBSpec) DeepCopy Uses

func (in *MariaDBSpec) DeepCopy() *MariaDBSpec

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

func (*MariaDBSpec) DeepCopyInto Uses

func (in *MariaDBSpec) DeepCopyInto(out *MariaDBSpec)

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

func (*MariaDBSpec) Descriptor Uses

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

func (*MariaDBSpec) GetSecrets Uses

func (m *MariaDBSpec) GetSecrets() []string

func (*MariaDBSpec) Marshal Uses

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

func (*MariaDBSpec) MarshalTo Uses

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

func (*MariaDBSpec) MarshalToSizedBuffer Uses

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

func (*MariaDBSpec) ProtoMessage Uses

func (*MariaDBSpec) ProtoMessage()

func (*MariaDBSpec) Reset Uses

func (m *MariaDBSpec) Reset()

func (*MariaDBSpec) Size Uses

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

func (*MariaDBSpec) String Uses

func (this *MariaDBSpec) String() string

func (*MariaDBSpec) Unmarshal Uses

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

func (*MariaDBSpec) XXX_DiscardUnknown Uses

func (m *MariaDBSpec) XXX_DiscardUnknown()

func (*MariaDBSpec) XXX_Marshal Uses

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

func (*MariaDBSpec) XXX_Merge Uses

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

func (*MariaDBSpec) XXX_Size Uses

func (m *MariaDBSpec) XXX_Size() int

func (*MariaDBSpec) XXX_Unmarshal Uses

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

type MariaDBStatus Uses

type MariaDBStatus 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 (*MariaDBStatus) DeepCopy Uses

func (in *MariaDBStatus) DeepCopy() *MariaDBStatus

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

func (*MariaDBStatus) DeepCopyInto Uses

func (in *MariaDBStatus) DeepCopyInto(out *MariaDBStatus)

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

func (*MariaDBStatus) Descriptor Uses

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

func (*MariaDBStatus) Marshal Uses

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

func (*MariaDBStatus) MarshalTo Uses

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

func (*MariaDBStatus) MarshalToSizedBuffer Uses

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

func (*MariaDBStatus) ProtoMessage Uses

func (*MariaDBStatus) ProtoMessage()

func (*MariaDBStatus) Reset Uses

func (m *MariaDBStatus) Reset()

func (*MariaDBStatus) Size Uses

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

func (*MariaDBStatus) String Uses

func (this *MariaDBStatus) String() string

func (*MariaDBStatus) Unmarshal Uses

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

func (*MariaDBStatus) XXX_DiscardUnknown Uses

func (m *MariaDBStatus) XXX_DiscardUnknown()

func (*MariaDBStatus) XXX_Marshal Uses

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

func (*MariaDBStatus) XXX_Merge Uses

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

func (*MariaDBStatus) XXX_Size Uses

func (m *MariaDBStatus) XXX_Size() int

func (*MariaDBStatus) XXX_Unmarshal Uses

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

type MemberSecret Uses

type MemberSecret struct {
    // PeerSecret is the secret containing TLS certs used by each etcd member pod
    // for the communication between etcd peers.
    PeerSecret string `json:"peerSecret,omitempty" protobuf:"bytes,1,opt,name=peerSecret"`
    // ServerSecret is the secret containing TLS certs used by each etcd member pod
    // for the communication between etcd server and its clients.
    ServerSecret string `json:"serverSecret,omitempty" protobuf:"bytes,2,opt,name=serverSecret"`
}

func (*MemberSecret) DeepCopy Uses

func (in *MemberSecret) DeepCopy() *MemberSecret

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

func (*MemberSecret) DeepCopyInto Uses

func (in *MemberSecret) DeepCopyInto(out *MemberSecret)

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

func (*MemberSecret) Descriptor Uses

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

func (*MemberSecret) Marshal Uses

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

func (*MemberSecret) MarshalTo Uses

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

func (*MemberSecret) MarshalToSizedBuffer Uses

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

func (*MemberSecret) ProtoMessage Uses

func (*MemberSecret) ProtoMessage()

func (*MemberSecret) Reset Uses

func (m *MemberSecret) Reset()

func (*MemberSecret) Size Uses

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

func (*MemberSecret) String Uses

func (this *MemberSecret) String() string

func (*MemberSecret) Unmarshal Uses

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

func (*MemberSecret) XXX_DiscardUnknown Uses

func (m *MemberSecret) XXX_DiscardUnknown()

func (*MemberSecret) XXX_Marshal Uses

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

func (*MemberSecret) XXX_Merge Uses

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

func (*MemberSecret) XXX_Size Uses

func (m *MemberSecret) XXX_Size() int

func (*MemberSecret) XXX_Unmarshal Uses

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

type Memcached Uses

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

+kubebuilder:object:root=true +kubebuilder:resource:path=memcacheds,singular=memcached,shortName=mc,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 (Memcached) AppBindingMeta Uses

func (m Memcached) AppBindingMeta() appcat.AppBindingMeta

func (Memcached) CustomResourceDefinition Uses

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

func (*Memcached) DeepCopy Uses

func (in *Memcached) DeepCopy() *Memcached

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

func (*Memcached) DeepCopyInto Uses

func (in *Memcached) DeepCopyInto(out *Memcached)

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

func (*Memcached) DeepCopyObject Uses

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

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

func (*Memcached) Descriptor Uses

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

func (*Memcached) GetMonitoringVendor Uses

func (m *Memcached) GetMonitoringVendor() string

func (*Memcached) Marshal Uses

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

func (*Memcached) MarshalTo Uses

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

func (*Memcached) MarshalToSizedBuffer Uses

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

func (Memcached) OffshootLabels Uses

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

func (Memcached) OffshootName Uses

func (m Memcached) OffshootName() string

func (Memcached) OffshootSelectors Uses

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

func (*Memcached) ProtoMessage Uses

func (*Memcached) ProtoMessage()

func (*Memcached) Reset Uses

func (m *Memcached) Reset()

func (Memcached) ResourceKind Uses

func (m Memcached) ResourceKind() string

func (Memcached) ResourcePlural Uses

func (m Memcached) ResourcePlural() string

func (Memcached) ResourceShortCode Uses

func (m Memcached) ResourceShortCode() string

func (Memcached) ResourceSingular Uses

func (m Memcached) ResourceSingular() string

func (Memcached) ServiceName Uses

func (m Memcached) ServiceName() string

func (*Memcached) SetDefaults Uses

func (m *Memcached) SetDefaults()

func (*Memcached) Size Uses

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

func (Memcached) StatsService Uses

func (m Memcached) StatsService() mona.StatsAccessor

func (Memcached) StatsServiceLabels Uses

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

func (*Memcached) String Uses

func (this *Memcached) String() string

func (*Memcached) Unmarshal Uses

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

func (*Memcached) XXX_DiscardUnknown Uses

func (m *Memcached) XXX_DiscardUnknown()

func (*Memcached) XXX_Marshal Uses

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

func (*Memcached) XXX_Merge Uses

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

func (*Memcached) XXX_Size Uses

func (m *Memcached) XXX_Size() int

func (*Memcached) XXX_Unmarshal Uses

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

type MemcachedCertificateAlias Uses

type MemcachedCertificateAlias string

+kubebuilder:validation:Enum=server;metrics-exporter

const (
    MemcachedServerCert          MemcachedCertificateAlias = "server"
    MemcachedMetricsExporterCert MemcachedCertificateAlias = "metrics-exporter"
)

type MemcachedList Uses

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

func (*MemcachedList) DeepCopy Uses

func (in *MemcachedList) DeepCopy() *MemcachedList

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

func (*MemcachedList) DeepCopyInto Uses

func (in *MemcachedList) DeepCopyInto(out *MemcachedList)

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

func (*MemcachedList) DeepCopyObject Uses

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

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

func (*MemcachedList) Descriptor Uses

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

func (*MemcachedList) Marshal Uses

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

func (*MemcachedList) MarshalTo Uses

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

func (*MemcachedList) MarshalToSizedBuffer Uses

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

func (*MemcachedList) ProtoMessage Uses

func (*MemcachedList) ProtoMessage()

func (*MemcachedList) Reset Uses

func (m *MemcachedList) Reset()

func (*MemcachedList) Size Uses

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

func (*MemcachedList) String Uses

func (this *MemcachedList) String() string

func (*MemcachedList) Unmarshal Uses

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

func (*MemcachedList) XXX_DiscardUnknown Uses

func (m *MemcachedList) XXX_DiscardUnknown()

func (*MemcachedList) XXX_Marshal Uses

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

func (*MemcachedList) XXX_Merge Uses

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

func (*MemcachedList) XXX_Size Uses

func (m *MemcachedList) XXX_Size() int

func (*MemcachedList) XXX_Unmarshal Uses

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

type MemcachedSpec Uses

type MemcachedSpec struct {
    // Version of Memcached to be deployed.
    Version string `json:"version" protobuf:"bytes,5,opt,name=version"`

    // Number of instances to deploy for a Memcached database.
    Replicas *int32 `json:"replicas,omitempty" protobuf:"varint,6,opt,name=replicas"`

    // Monitor is used monitor database instance
    // +optional
    Monitor *mona.AgentSpec `json:"monitor,omitempty" protobuf:"bytes,7,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,8,opt,name=configSource"`

    // DataVolume is an optional field to add one volume to each
    // memcached pod.  The volume will be made available under
    // /data and owned by the memcached user.
    //
    // While not mandated by the API and not configured
    // automatically, the intended purpose is to use that volume
    // for memcached's persistent memory support
    // (https://memcached.org/blog/persistent-memory/) by adding
    // the memory-file and memory-limit options to the config
    // (https://github.com/memcached/memcached/wiki/WarmRestart).
    //
    // For that purpose, a CSI inline volume provided by PMEM-CSI
    // can be used, in which case each pod will get its own, empty
    // volume. Warm restarts are not supported.
    //
    // For testing, an empty dir can be used instead.
    DataVolume *core.VolumeSource `json:"dataVolume,omitempty" protobuf:"bytes,9,opt,name=dataVolume"`

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

    // TLS contains tls configurations
    // +optional
    TLS *kmapi.TLSConfig `json:"tls,omitempty" protobuf:"bytes,12,opt,name=tls"`

    // 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,13,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,14,opt,name=halted"`

    // TerminationPolicy controls the delete operation for database
    // +optional
    TerminationPolicy TerminationPolicy `json:"terminationPolicy,omitempty" protobuf:"bytes,15,opt,name=terminationPolicy,casttype=TerminationPolicy"`
}

func (*MemcachedSpec) DeepCopy Uses

func (in *MemcachedSpec) DeepCopy() *MemcachedSpec

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

func (*MemcachedSpec) DeepCopyInto Uses

func (in *MemcachedSpec) DeepCopyInto(out *MemcachedSpec)

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

func (*MemcachedSpec) Descriptor Uses

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

func (*MemcachedSpec) GetSecrets Uses

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

func (*MemcachedSpec) Marshal Uses

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

func (*MemcachedSpec) MarshalTo Uses

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

func (*MemcachedSpec) MarshalToSizedBuffer Uses

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

func (*MemcachedSpec) ProtoMessage Uses

func (*MemcachedSpec) ProtoMessage()

func (*MemcachedSpec) Reset Uses

func (m *MemcachedSpec) Reset()

func (*MemcachedSpec) Size Uses

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

func (*MemcachedSpec) String Uses

func (this *MemcachedSpec) String() string

func (*MemcachedSpec) Unmarshal Uses

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

func (*MemcachedSpec) XXX_DiscardUnknown Uses

func (m *MemcachedSpec) XXX_DiscardUnknown()

func (*MemcachedSpec) XXX_Marshal Uses

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

func (*MemcachedSpec) XXX_Merge Uses

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

func (*MemcachedSpec) XXX_Size Uses

func (m *MemcachedSpec) XXX_Size() int

func (*MemcachedSpec) XXX_Unmarshal Uses

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

type MemcachedStatus Uses

type MemcachedStatus 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 (*MemcachedStatus) DeepCopy Uses

func (in *MemcachedStatus) DeepCopy() *MemcachedStatus

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

func (*MemcachedStatus) DeepCopyInto Uses

func (in *MemcachedStatus) DeepCopyInto(out *MemcachedStatus)

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

func (*MemcachedStatus) Descriptor Uses

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

func (*MemcachedStatus) Marshal Uses

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

func (*MemcachedStatus) MarshalTo Uses

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

func (*MemcachedStatus) MarshalToSizedBuffer Uses

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

func (*MemcachedStatus) ProtoMessage Uses

func (*MemcachedStatus) ProtoMessage()

func (*MemcachedStatus) Reset Uses

func (m *MemcachedStatus) Reset()

func (*MemcachedStatus) Size Uses

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

func (*MemcachedStatus) String Uses

func (this *MemcachedStatus) String() string

func (*MemcachedStatus) Unmarshal Uses

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

func (*MemcachedStatus) XXX_DiscardUnknown Uses

func (m *MemcachedStatus) XXX_DiscardUnknown()

func (*MemcachedStatus) XXX_Marshal Uses

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

func (*MemcachedStatus) XXX_Merge Uses

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

func (*MemcachedStatus) XXX_Size Uses

func (m *MemcachedStatus) XXX_Size() int

func (*MemcachedStatus) XXX_Unmarshal Uses

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

type MongoDB Uses

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

+kubebuilder:object:root=true +kubebuilder:resource:path=mongodbs,singular=mongodb,shortName=mg,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 (MongoDB) AppBindingMeta Uses

func (m MongoDB) AppBindingMeta() appcat.AppBindingMeta

func (*MongoDB) CertificateName Uses

func (m *MongoDB) CertificateName(alias MongoDBCertificateAlias, stsName string) string

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

func (MongoDB) ConfigSvrDSN Uses

func (m MongoDB) ConfigSvrDSN() string

ConfigSvrDSN = <configSvrReplName>/<host1:port>,<host2:port>,<host3:port> // Here, host1 = <pod-name>.<governing-serviceName>.svc

func (MongoDB) ConfigSvrLabels Uses

func (m MongoDB) ConfigSvrLabels() map[string]string

func (MongoDB) ConfigSvrNodeName Uses

func (m MongoDB) ConfigSvrNodeName() string

func (MongoDB) ConfigSvrRepSetName Uses

func (m MongoDB) ConfigSvrRepSetName() string

func (MongoDB) ConfigSvrSelectors Uses

func (m MongoDB) ConfigSvrSelectors() map[string]string

func (MongoDB) CustomResourceDefinition Uses

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

func (*MongoDB) DeepCopy Uses

func (in *MongoDB) DeepCopy() *MongoDB

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

func (*MongoDB) DeepCopyInto Uses

func (in *MongoDB) DeepCopyInto(out *MongoDB)

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

func (*MongoDB) DeepCopyObject Uses

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

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

func (*MongoDB) Descriptor Uses

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

func (*MongoDB) GetDefaultLivenessProbeSpec Uses

func (m *MongoDB) GetDefaultLivenessProbeSpec(mgVersion *v1alpha1.MongoDBVersion) *core.Probe

func (*MongoDB) GetDefaultReadinessProbeSpec Uses

func (m *MongoDB) GetDefaultReadinessProbeSpec(mgVersion *v1alpha1.MongoDBVersion) *core.Probe

func (*MongoDB) GetMonitoringVendor Uses

func (m *MongoDB) GetMonitoringVendor() string

func (MongoDB) GvrSvcName Uses

func (m MongoDB) GvrSvcName(name string) string

Governing Service Name. Here, name parameter is either OffshootName, ShardNodeName or ConfigSvrNodeName

func (MongoDB) HostAddress Uses

func (m MongoDB) HostAddress() string

HostAddress returns serviceName for standalone mongodb. and, for replica set = <replName>/<host1>,<host2>,<host3> Here, host1 = <pod-name>.<governing-serviceName> Governing service name is used for replica host because, we used governing service name as part of host while adding members to replicaset.

func (*MongoDB) KeyFileRequired Uses

func (m *MongoDB) KeyFileRequired() bool

func (*MongoDB) Marshal Uses

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

func (*MongoDB) MarshalTo Uses

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

func (*MongoDB) MarshalToSizedBuffer Uses

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

func (MongoDB) MongosLabels Uses

func (m MongoDB) MongosLabels() map[string]string

func (MongoDB) MongosNodeName Uses

func (m MongoDB) MongosNodeName() string

func (MongoDB) MongosSelectors Uses

func (m MongoDB) MongosSelectors() map[string]string

func (*MongoDB) MustCertSecretName Uses

func (m *MongoDB) MustCertSecretName(alias MongoDBCertificateAlias, stsName string) string

MustCertSecretName returns the secret name for a certificate alias

func (MongoDB) OffshootLabels Uses

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

func (MongoDB) OffshootName Uses

func (m MongoDB) OffshootName() string

func (MongoDB) OffshootSelectors Uses

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

func (*MongoDB) ProtoMessage Uses

func (*MongoDB) ProtoMessage()

func (MongoDB) RepSetName Uses

func (m MongoDB) RepSetName() string

RepSetName returns Replicaset name only for spec.replicaset

func (*MongoDB) Reset Uses

func (m *MongoDB) Reset()

func (MongoDB) ResourceKind Uses

func (m MongoDB) ResourceKind() string

func (MongoDB) ResourcePlural Uses

func (m MongoDB) ResourcePlural() string

func (MongoDB) ResourceShortCode Uses

func (m MongoDB) ResourceShortCode() string

func (MongoDB) ResourceSingular Uses

func (m MongoDB) ResourceSingular() string

func (MongoDB) ServiceName Uses

func (m MongoDB) ServiceName() string

func (*MongoDB) SetDefaults Uses

func (m *MongoDB) SetDefaults(mgVersion *v1alpha1.MongoDBVersion, topology *core_util.Topology)

func (MongoDB) ShardCommonNodeName Uses

func (m MongoDB) ShardCommonNodeName() string

func (MongoDB) ShardDSN Uses

func (m MongoDB) ShardDSN(nodeNum int32) string

ShardDSN = <shardReplName>/<host1:port>,<host2:port>,<host3:port> // Here, host1 = <pod-name>.<governing-serviceName>.svc

func (MongoDB) ShardLabels Uses

func (m MongoDB) ShardLabels(nodeNum int32) map[string]string

func (MongoDB) ShardNodeName Uses

func (m MongoDB) ShardNodeName(nodeNum int32) string

func (MongoDB) ShardNodeTemplate Uses

func (m MongoDB) ShardNodeTemplate() string

func (MongoDB) ShardRepSetName Uses

func (m MongoDB) ShardRepSetName(nodeNum int32) string

func (MongoDB) ShardSelectors Uses

func (m MongoDB) ShardSelectors(nodeNum int32) map[string]string

func (*MongoDB) Size Uses

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

func (MongoDB) StatsService Uses

func (m MongoDB) StatsService() mona.StatsAccessor

func (MongoDB) StatsServiceLabels Uses

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

func (*MongoDB) String Uses

func (this *MongoDB) String() string

func (*MongoDB) Unmarshal Uses

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

func (*MongoDB) XXX_DiscardUnknown Uses

func (m *MongoDB) XXX_DiscardUnknown()

func (*MongoDB) XXX_Marshal Uses

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

func (*MongoDB) XXX_Merge Uses

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

func (*MongoDB) XXX_Size Uses

func (m *MongoDB) XXX_Size() int

func (*MongoDB) XXX_Unmarshal Uses

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

type MongoDBCertificateAlias Uses

type MongoDBCertificateAlias string

+kubebuilder:validation:Enum=server;client;metrics-exporter

const (
    MongoDBServerCert          MongoDBCertificateAlias = "server"
    MongoDBClientCert          MongoDBCertificateAlias = "client"
    MongoDBMetricsExporterCert MongoDBCertificateAlias = "metrics-exporter"
)

type MongoDBConfigNode Uses

type MongoDBConfigNode struct {
    // MongoDB config server node configs
    MongoDBNode `json:",inline" protobuf:"bytes,1,opt,name=mongoDBNode"`

    // Storage to specify how storage shall be used.
    Storage *core.PersistentVolumeClaimSpec `json:"storage,omitempty" protobuf:"bytes,2,opt,name=storage"`
}

func (*MongoDBConfigNode) DeepCopy Uses

func (in *MongoDBConfigNode) DeepCopy() *MongoDBConfigNode

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

func (*MongoDBConfigNode) DeepCopyInto Uses

func (in *MongoDBConfigNode) DeepCopyInto(out *MongoDBConfigNode)

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

func (*MongoDBConfigNode) Descriptor Uses

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

func (*MongoDBConfigNode) Marshal Uses

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

func (*MongoDBConfigNode) MarshalTo Uses

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

func (*MongoDBConfigNode) MarshalToSizedBuffer Uses

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

func (*MongoDBConfigNode) ProtoMessage Uses

func (*MongoDBConfigNode) ProtoMessage()

func (*MongoDBConfigNode) Reset Uses

func (m *MongoDBConfigNode) Reset()

func (*MongoDBConfigNode) Size Uses

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

func (*MongoDBConfigNode) String Uses

func (this *MongoDBConfigNode) String() string

func (*MongoDBConfigNode) Unmarshal Uses

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

func (*MongoDBConfigNode) XXX_DiscardUnknown Uses

func (m *MongoDBConfigNode) XXX_DiscardUnknown()

func (*MongoDBConfigNode) XXX_Marshal Uses

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

func (*MongoDBConfigNode) XXX_Merge Uses

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

func (*MongoDBConfigNode) XXX_Size Uses

func (m *MongoDBConfigNode) XXX_Size() int

func (*MongoDBConfigNode) XXX_Unmarshal Uses

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

type MongoDBList Uses

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

func (*MongoDBList) DeepCopy Uses

func (in *MongoDBList) DeepCopy() *MongoDBList

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

func (*MongoDBList) DeepCopyInto Uses

func (in *MongoDBList) DeepCopyInto(out *MongoDBList)

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

func (*MongoDBList) DeepCopyObject Uses

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

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

func (*MongoDBList) Descriptor Uses

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

func (*MongoDBList) Marshal Uses

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

func (*MongoDBList) MarshalTo Uses

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

func (*MongoDBList) MarshalToSizedBuffer Uses

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

func (*MongoDBList) ProtoMessage Uses

func (*MongoDBList) ProtoMessage()

func (*MongoDBList) Reset Uses

func (m *MongoDBList) Reset()

func (*MongoDBList) Size Uses

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

func (*MongoDBList) String Uses

func (this *MongoDBList) String() string

func (*MongoDBList) Unmarshal Uses

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

func (*MongoDBList) XXX_DiscardUnknown Uses

func (m *MongoDBList) XXX_DiscardUnknown()

func (*MongoDBList) XXX_Marshal Uses

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

func (*MongoDBList) XXX_Merge Uses

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

func (*MongoDBList) XXX_Size Uses

func (m *MongoDBList) XXX_Size() int

func (*MongoDBList) XXX_Unmarshal Uses

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

type MongoDBMongosNode Uses

type MongoDBMongosNode struct {
    // MongoDB mongos node configs
    MongoDBNode `json:",inline" protobuf:"bytes,5,opt,name=mongoDBNode"`

    // The deployment strategy to use to replace existing pods with new ones.
    // Deprecated: Deployment has been Replaced by StatefulSet. MongosNode now uses spec.updateStrategy
    Strategy apps.DeploymentStrategy `json:"strategy,omitempty" protobuf:"bytes,4,opt,name=strategy"`
}

func (*MongoDBMongosNode) DeepCopy Uses

func (in *MongoDBMongosNode) DeepCopy() *MongoDBMongosNode

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

func (*MongoDBMongosNode) DeepCopyInto Uses

func (in *MongoDBMongosNode) DeepCopyInto(out *MongoDBMongosNode)

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

func (*MongoDBMongosNode) Descriptor Uses

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

func (*MongoDBMongosNode) Marshal Uses

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

func (*MongoDBMongosNode) MarshalTo Uses

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

func (*MongoDBMongosNode) MarshalToSizedBuffer Uses

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

func (*MongoDBMongosNode) ProtoMessage Uses

func (*MongoDBMongosNode) ProtoMessage()

func (*MongoDBMongosNode) Reset Uses

func (m *MongoDBMongosNode) Reset()

func (*MongoDBMongosNode) Size Uses

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

func (*MongoDBMongosNode) String Uses

func (this *MongoDBMongosNode) String() string

func (*MongoDBMongosNode) Unmarshal Uses

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

func (*MongoDBMongosNode) XXX_DiscardUnknown Uses

func (m *MongoDBMongosNode) XXX_DiscardUnknown()

func (*MongoDBMongosNode) XXX_Marshal Uses

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

func (*MongoDBMongosNode) XXX_Merge Uses

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

func (*MongoDBMongosNode) XXX_Size Uses

func (m *MongoDBMongosNode) XXX_Size() int

func (*MongoDBMongosNode) XXX_Unmarshal Uses

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

type MongoDBNode Uses

type MongoDBNode struct {
    // Replicas represents number of replicas of this specific node.
    // If current node has replicaset enabled, then replicas is the amount of replicaset nodes.
    Replicas int32 `json:"replicas" protobuf:"varint,1,opt,name=replicas"`

    // Prefix is the name prefix of this node.
    Prefix string `json:"prefix,omitempty" protobuf:"bytes,2,opt,name=prefix"`

    // ConfigSource is an optional field to provide custom configuration file for database (i.e mongod.cnf).
    // 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,3,opt,name=configSource"`

    // PodTemplate is an optional configuration for pods used to expose database
    // +optional
    PodTemplate ofst.PodTemplateSpec `json:"podTemplate,omitempty" protobuf:"bytes,4,opt,name=podTemplate"`
}

func (*MongoDBNode) DeepCopy Uses

func (in *MongoDBNode) DeepCopy() *MongoDBNode

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

func (*MongoDBNode) DeepCopyInto Uses

func (in *MongoDBNode) DeepCopyInto(out *MongoDBNode)

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

func (*MongoDBNode) Descriptor Uses

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

func (*MongoDBNode) Marshal Uses

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

func (*MongoDBNode) MarshalTo Uses

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

func (*MongoDBNode) MarshalToSizedBuffer Uses

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

func (*MongoDBNode) ProtoMessage Uses

func (*MongoDBNode) ProtoMessage()

func (*MongoDBNode) Reset Uses

func (m *MongoDBNode) Reset()

func (*MongoDBNode) Size Uses

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

func (*MongoDBNode) String Uses

func (this *MongoDBNode) String() string

func (*MongoDBNode) Unmarshal Uses

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

func (*MongoDBNode) XXX_DiscardUnknown Uses

func (m *MongoDBNode) XXX_DiscardUnknown()

func (*MongoDBNode) XXX_Marshal Uses

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

func (*MongoDBNode) XXX_Merge Uses

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

func (*MongoDBNode) XXX_Size Uses

func (m *MongoDBNode) XXX_Size() int

func (*MongoDBNode) XXX_Unmarshal Uses

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

type MongoDBReplicaSet Uses

type MongoDBReplicaSet struct {
    // Name of replicaset
    Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
}

func (*MongoDBReplicaSet) DeepCopy Uses

func (in *MongoDBReplicaSet) DeepCopy() *MongoDBReplicaSet

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

func (*MongoDBReplicaSet) DeepCopyInto Uses

func (in *MongoDBReplicaSet) DeepCopyInto(out *MongoDBReplicaSet)

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

func (*MongoDBReplicaSet) Descriptor Uses

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

func (*MongoDBReplicaSet) Marshal Uses

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

func (*MongoDBReplicaSet) MarshalTo Uses

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

func (*MongoDBReplicaSet) MarshalToSizedBuffer Uses

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

func (*MongoDBReplicaSet) ProtoMessage Uses

func (*MongoDBReplicaSet) ProtoMessage()

func (*MongoDBReplicaSet) Reset Uses

func (m *MongoDBReplicaSet) Reset()

func (*MongoDBReplicaSet) Size Uses

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

func (*MongoDBReplicaSet) String Uses

func (this *MongoDBReplicaSet) String() string

func (*MongoDBReplicaSet) Unmarshal Uses

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

func (*MongoDBReplicaSet) XXX_DiscardUnknown Uses

func (m *MongoDBReplicaSet) XXX_DiscardUnknown()

func (*MongoDBReplicaSet) XXX_Marshal Uses

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

func (*MongoDBReplicaSet) XXX_Merge Uses

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

func (*MongoDBReplicaSet) XXX_Size Uses

func (m *MongoDBReplicaSet) XXX_Size() int

func (*MongoDBReplicaSet) XXX_Unmarshal Uses

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

type MongoDBShardNode Uses

type MongoDBShardNode struct {
    // Shards represents number of shards for shard type of node
    // More info: https://docs.mongodb.com/manual/core/sharded-cluster-shards/
    Shards int32 `json:"shards" protobuf:"varint,1,opt,name=shards"`

    // MongoDB sharding node configs
    MongoDBNode `json:",inline" protobuf:"bytes,2,opt,name=mongoDBNode"`

    // Storage to specify how storage shall be used.
    Storage *core.PersistentVolumeClaimSpec `json:"storage,omitempty" protobuf:"bytes,3,opt,name=storage"`
}

func (*MongoDBShardNode) DeepCopy Uses

func (in *MongoDBShardNode) DeepCopy() *MongoDBShardNode

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

func (*MongoDBShardNode) DeepCopyInto Uses

func (in *MongoDBShardNode) DeepCopyInto(out *MongoDBShardNode)

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

func (*MongoDBShardNode) Descriptor Uses

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

func (*MongoDBShardNode) Marshal Uses

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

func (*MongoDBShardNode) MarshalTo Uses

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

func (*MongoDBShardNode) MarshalToSizedBuffer Uses

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

func (*MongoDBShardNode) ProtoMessage Uses

func (*MongoDBShardNode) ProtoMessage()

func (*MongoDBShardNode) Reset Uses

func (m *MongoDBShardNode) Reset()

func (*MongoDBShardNode) Size Uses

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

func (*MongoDBShardNode) String Uses

func (this *MongoDBShardNode) String() string

func (*MongoDBShardNode) Unmarshal Uses

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

func (*MongoDBShardNode) XXX_DiscardUnknown Uses

func (m *MongoDBShardNode) XXX_DiscardUnknown()

func (*MongoDBShardNode) XXX_Marshal Uses

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

func (*MongoDBShardNode) XXX_Merge Uses

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

func (*MongoDBShardNode) XXX_Size Uses

func (m *MongoDBShardNode) XXX_Size() int

func (*MongoDBShardNode) XXX_Unmarshal Uses

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

type MongoDBShardingTopology Uses

type MongoDBShardingTopology struct {
    // Shard component of mongodb.
    // More info: https://docs.mongodb.com/manual/core/sharded-cluster-shards/
    Shard MongoDBShardNode `json:"shard" protobuf:"bytes,1,opt,name=shard"`

    // Config Server (metadata) component of mongodb.
    // More info: https://docs.mongodb.com/manual/core/sharded-cluster-config-servers/
    ConfigServer MongoDBConfigNode `json:"configServer" protobuf:"bytes,2,opt,name=configServer"`

    // Mongos (router) component of mongodb.
    // More info: https://docs.mongodb.com/manual/core/sharded-cluster-query-router/
    Mongos MongoDBMongosNode `json:"mongos" protobuf:"bytes,3,opt,name=mongos"`
}

func (*MongoDBShardingTopology) DeepCopy Uses

func (in *MongoDBShardingTopology) DeepCopy() *MongoDBShardingTopology

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

func (*MongoDBShardingTopology) DeepCopyInto Uses

func (in *MongoDBShardingTopology) DeepCopyInto(out *MongoDBShardingTopology)

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

func (*MongoDBShardingTopology) Descriptor Uses

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

func (*MongoDBShardingTopology) Marshal Uses

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

func (*MongoDBShardingTopology) MarshalTo Uses

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

func (*MongoDBShardingTopology) MarshalToSizedBuffer Uses

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

func (*MongoDBShardingTopology) ProtoMessage Uses

func (*MongoDBShardingTopology) ProtoMessage()

func (*MongoDBShardingTopology) Reset Uses

func (m *MongoDBShardingTopology) Reset()

func (*MongoDBShardingTopology) Size Uses

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

func (*MongoDBShardingTopology) String Uses

func (this *MongoDBShardingTopology) String() string

func (*MongoDBShardingTopology) Unmarshal Uses

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

func (*MongoDBShardingTopology) XXX_DiscardUnknown Uses

func (m *MongoDBShardingTopology) XXX_DiscardUnknown()

func (*MongoDBShardingTopology) XXX_Marshal Uses

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

func (*MongoDBShardingTopology) XXX_Merge Uses

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

func (*MongoDBShardingTopology) XXX_Size Uses

func (m *MongoDBShardingTopology) XXX_Size() int

func (*MongoDBShardingTopology) XXX_Unmarshal Uses

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

type MongoDBSpec Uses

type MongoDBSpec struct {
    // Version of MongoDB to be deployed.
    Version string `json:"version" protobuf:"bytes,1,opt,name=version"`

    // Number of instances to deploy for a MongoDB database.
    Replicas *int32 `json:"replicas,omitempty" protobuf:"varint,2,opt,name=replicas"`

    // MongoDB replica set
    ReplicaSet *MongoDBReplicaSet `json:"replicaSet,omitempty" protobuf:"bytes,3,opt,name=replicaSet"`

    // MongoDB sharding topology.
    ShardTopology *MongoDBShardingTopology `json:"shardTopology,omitempty" protobuf:"bytes,4,opt,name=shardTopology"`

    // StorageType can be durable (default) or ephemeral
    StorageType StorageType `json:"storageType,omitempty" protobuf:"bytes,5,opt,name=storageType,casttype=StorageType"`

    // Storage spec to specify how storage shall be used.
    Storage *core.PersistentVolumeClaimSpec `json:"storage,omitempty" protobuf:"bytes,6,opt,name=storage"`

    // Database authentication secret
    DatabaseSecret *core.SecretVolumeSource `json:"databaseSecret,omitempty" protobuf:"bytes,7,opt,name=databaseSecret"`

    // ClusterAuthMode for replicaset or sharding. (default will be x509 if sslmode is not `disabled`.)
    // See available ClusterAuthMode: https://docs.mongodb.com/manual/reference/program/mongod/#cmdoption-mongod-clusterauthmode
    ClusterAuthMode ClusterAuthMode `json:"clusterAuthMode,omitempty" protobuf:"bytes,8,opt,name=clusterAuthMode,casttype=ClusterAuthMode"`

    // SSLMode for both standalone and clusters. (default, disabled.)
    // See more options: https://docs.mongodb.com/manual/reference/program/mongod/#cmdoption-mongod-sslmode
    SSLMode SSLMode `json:"sslMode,omitempty" protobuf:"bytes,9,opt,name=sslMode,casttype=SSLMode"`

    // Init is used to initialize database
    // +optional
    Init *InitSpec `json:"init,omitempty" protobuf:"bytes,10,opt,name=init"`

    // Monitor is used monitor database instance
    // +optional
    Monitor *mona.AgentSpec `json:"monitor,omitempty" protobuf:"bytes,11,opt,name=monitor"`

    // ConfigSource is an optional field to provide custom configuration file for database (i.e mongod.cnf).
    // 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,12,opt,name=configSource"`

    // PodTemplate is an optional configuration for pods used to expose database
    // +optional
    PodTemplate *ofst.PodTemplateSpec `json:"podTemplate,omitempty" protobuf:"bytes,13,opt,name=podTemplate"`

    // ServiceTemplate is an optional configuration for service used to expose database
    // +optional
    ServiceTemplate ofst.ServiceTemplateSpec `json:"serviceTemplate,omitempty" protobuf:"bytes,14,opt,name=serviceTemplate"`

    // TLS contains tls configurations for client and server.
    // +optional
    TLS *kmapi.TLSConfig `json:"tls,omitempty" protobuf:"bytes,15,opt,name=tls"`

    // Secret for KeyFile. Contains keyfile `key.txt` if spec.clusterAuthMode == keyFile || sendKeyFile
    KeyFile *core.SecretVolumeSource `json:"keyFile,omitempty" protobuf:"bytes,16,opt,name=keyFile"`

    // 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,17,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,18,opt,name=halted"`

    // TerminationPolicy controls the delete operation for database
    // +optional
    TerminationPolicy TerminationPolicy `json:"terminationPolicy,omitempty" protobuf:"bytes,19,opt,name=terminationPolicy,casttype=TerminationPolicy"`

    // StorageEngine can be wiredTiger (default) or inMemory
    // See available StorageEngine: https://docs.mongodb.com/manual/core/storage-engines/
    StorageEngine StorageEngine `json:"storageEngine,omitempty" protobuf:"bytes,20,opt,name=storageEngine,casttype=StorageEngine"`
}

func (*MongoDBSpec) DeepCopy Uses

func (in *MongoDBSpec) DeepCopy() *MongoDBSpec

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

func (*MongoDBSpec) DeepCopyInto Uses

func (in *MongoDBSpec) DeepCopyInto(out *MongoDBSpec)

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

func (*MongoDBSpec) Descriptor Uses

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

func (*MongoDBSpec) GetSecrets Uses

func (m *MongoDBSpec) GetSecrets() []string

func (*MongoDBSpec) Marshal Uses

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

func (*MongoDBSpec) MarshalTo Uses

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

func (*MongoDBSpec) MarshalToSizedBuffer Uses

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

func (*MongoDBSpec) ProtoMessage Uses

func (*MongoDBSpec) ProtoMessage()

func (*MongoDBSpec) Reset Uses

func (m *MongoDBSpec) Reset()

func (*MongoDBSpec) SetSecurityContext Uses

func (m *MongoDBSpec) SetSecurityContext(podTemplate *ofst.PodTemplateSpec)

setSecurityContext will set default PodSecurityContext. These values will be applied only to newly created objects. These defaultings should not be applied to DBs or dormantDBs, that is managed by previous operators,

func (*MongoDBSpec) Size Uses

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

func (*MongoDBSpec) String Uses

func (this *MongoDBSpec) String() string

func (*MongoDBSpec) Unmarshal Uses

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

func (*MongoDBSpec) XXX_DiscardUnknown Uses

func (m *MongoDBSpec) XXX_DiscardUnknown()

func (*MongoDBSpec) XXX_Marshal Uses

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

func (*MongoDBSpec) XXX_Merge Uses

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

func (*MongoDBSpec) XXX_Size Uses

func (m *MongoDBSpec) XXX_Size() int

func (*MongoDBSpec) XXX_Unmarshal Uses

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

type MongoDBStatus Uses

type MongoDBStatus 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 (*MongoDBStatus) DeepCopy Uses

func (in *MongoDBStatus) DeepCopy() *MongoDBStatus

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

func (*MongoDBStatus) DeepCopyInto Uses

func (in *MongoDBStatus) DeepCopyInto(out *MongoDBStatus)

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

func (*MongoDBStatus) Descriptor Uses

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

func (*MongoDBStatus) Marshal Uses

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

func (*MongoDBStatus) MarshalTo Uses

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

func (*MongoDBStatus) MarshalToSizedBuffer Uses

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

func (*MongoDBStatus) ProtoMessage Uses

func (*MongoDBStatus) ProtoMessage()

func (*MongoDBStatus) Reset Uses

func (m *MongoDBStatus) Reset()

func (*MongoDBStatus) Size Uses

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

func (*MongoDBStatus) String Uses

func (this *MongoDBStatus) String() string

func (*MongoDBStatus) Unmarshal Uses

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

func (*MongoDBStatus) XXX_DiscardUnknown Uses

func (m *MongoDBStatus) XXX_DiscardUnknown()

func (*MongoDBStatus) XXX_Marshal Uses

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

func (*MongoDBStatus) XXX_Merge Uses

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

func (*MongoDBStatus) XXX_Size Uses

func (m *MongoDBStatus) XXX_Size() int

func (*MongoDBStatus) XXX_Unmarshal Uses

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

type MySQL Uses

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

+kubebuilder:object:root=true +kubebuilder:resource:path=mysqls,singular=mysql,shortName=my,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 (MySQL) AppBindingMeta Uses

func (m MySQL) AppBindingMeta() appcat.AppBindingMeta

func (*MySQL) CertificateName Uses

func (m *MySQL) CertificateName(alias MySQLCertificateAlias) string

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

func (MySQL) CustomResourceDefinition Uses

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

func (*MySQL) DeepCopy Uses

func (in *MySQL) DeepCopy() *MySQL

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

func (*MySQL) DeepCopyInto Uses

func (in *MySQL) DeepCopyInto(out *MySQL)

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

func (*MySQL) DeepCopyObject Uses

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

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

func (*MySQL) Descriptor Uses

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

func (MySQL) GetDatabaseSecretName Uses

func (m MySQL) GetDatabaseSecretName() string

func (*MySQL) GetMonitoringVendor Uses

func (m *MySQL) GetMonitoringVendor() string

func (MySQL) GoverningServiceName Uses

func (m MySQL) GoverningServiceName() string

func (*MySQL) Marshal Uses

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

func (*MySQL) MarshalTo Uses

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

func (*MySQL) MarshalToSizedBuffer Uses

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

func (*MySQL) MustCertSecretName Uses

func (m *MySQL) MustCertSecretName(alias MySQLCertificateAlias) string

MustCertSecretName returns the secret name for a certificate alias

func (MySQL) OffshootLabels Uses

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

func (MySQL) OffshootName Uses

func (m MySQL) OffshootName() string

func (MySQL) OffshootSelectors Uses

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

func (MySQL) PeerName Uses

func (m MySQL) PeerName(idx int) string

func (*MySQL) ProtoMessage Uses

func (*MySQL) ProtoMessage()

func (*MySQL) Reset Uses

func (m *MySQL) Reset()

func (MySQL) ResourceKind Uses

func (m MySQL) ResourceKind() string

func (MySQL) ResourcePlural Uses

func (m MySQL) ResourcePlural() string

func (MySQL) ResourceShortCode Uses

func (m MySQL) ResourceShortCode() string

func (MySQL) ResourceSingular Uses

func (m MySQL) ResourceSingular() string

func (MySQL) ServiceName Uses

func (m MySQL) ServiceName() string

func (*MySQL) SetDefaults Uses

func (m *MySQL) SetDefaults()

func (*MySQL) Size Uses

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

func (MySQL) StatsService Uses

func (m MySQL) StatsService() mona.StatsAccessor

func (MySQL) StatsServiceLabels Uses

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

func (*MySQL) String Uses

func (this *MySQL) String() string

func (*MySQL) Unmarshal Uses

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

func (*MySQL) XXX_DiscardUnknown Uses

func (m *MySQL) XXX_DiscardUnknown()

func (*MySQL) XXX_Marshal Uses

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

func (*MySQL) XXX_Merge Uses

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

func (*MySQL) XXX_Size Uses

func (m *MySQL) XXX_Size() int

func (*MySQL) XXX_Unmarshal Uses

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

type MySQLCertificateAlias Uses

type MySQLCertificateAlias string

+kubebuilder:validation:Enum=server;archiver;metrics-exporter

const (
    MySQLServerCert          MySQLCertificateAlias = "server"
    MySQLClientCert          MySQLCertificateAlias = "client"
    MySQLMetricsExporterCert MySQLCertificateAlias = "metrics-exporter"
)

type MySQLClusterMode Uses

type MySQLClusterMode string

+kubebuilder:validation:Enum=GroupReplication

const (
    MySQLClusterModeGroup MySQLClusterMode = "GroupReplication"
)

type MySQLClusterTopology Uses

type MySQLClusterTopology struct {
    // If set to -
    // "GroupReplication", GroupSpec is required and MySQL servers will start  a replication group
    Mode *MySQLClusterMode `json:"mode,omitempty" protobuf:"bytes,1,opt,name=mode,casttype=MySQLClusterMode"`

    // Group replication info for MySQL
    Group *MySQLGroupSpec `json:"group,omitempty" protobuf:"bytes,2,opt,name=group"`
}

func (*MySQLClusterTopology) DeepCopy Uses

func (in *MySQLClusterTopology) DeepCopy() *MySQLClusterTopology

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

func (*MySQLClusterTopology) DeepCopyInto Uses

func (in *MySQLClusterTopology) DeepCopyInto(out *MySQLClusterTopology)

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

func (*MySQLClusterTopology) Descriptor Uses

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

func (*MySQLClusterTopology) Marshal Uses

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

func (*MySQLClusterTopology) MarshalTo Uses

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

func (*MySQLClusterTopology) MarshalToSizedBuffer Uses

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

func (*MySQLClusterTopology) ProtoMessage Uses

func (*MySQLClusterTopology) ProtoMessage()

func (*MySQLClusterTopology) Reset Uses

func (m *MySQLClusterTopology) Reset()

func (*MySQLClusterTopology) Size Uses

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

func (*MySQLClusterTopology) String Uses

func (this *MySQLClusterTopology) String() string

func (*MySQLClusterTopology) Unmarshal Uses

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

func (*MySQLClusterTopology) XXX_DiscardUnknown Uses

func (m *MySQLClusterTopology) XXX_DiscardUnknown()

func (*MySQLClusterTopology) XXX_Marshal Uses

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

func (*MySQLClusterTopology) XXX_Merge Uses

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

func (*MySQLClusterTopology) XXX_Size Uses

func (m *MySQLClusterTopology) XXX_Size() int

func (*MySQLClusterTopology) XXX_Unmarshal Uses

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

type MySQLGroupMode Uses

type MySQLGroupMode string

+kubebuilder:validation:Enum=Single-Primary;Multi-Primary

const (
    MySQLGroupModeSinglePrimary MySQLGroupMode = "Single-Primary"
    MySQLGroupModeMultiPrimary  MySQLGroupMode = "Multi-Primary"
)

type MySQLGroupSpec Uses

type MySQLGroupSpec struct {
    // TODO: "Multi-Primary" needs to be implemented
    // Group Replication can be deployed in either "Single-Primary" or "Multi-Primary" mode
    Mode *MySQLGroupMode `json:"mode,omitempty" protobuf:"bytes,1,opt,name=mode,casttype=MySQLGroupMode"`

    // Group name is a version 4 UUID
    // ref: https://dev.mysql.com/doc/refman/5.7/en/group-replication-options.html#sysvar_group_replication_group_name
    Name string `json:"name,omitempty" protobuf:"bytes,2,opt,name=name"`

    // On a replication master and each replication slave, the --server-id
    // option must be specified to establish a unique replication ID in the
    // range from 1 to 2^32 − 1. “Unique”, means that each ID must be different
    // from every other ID in use by any other replication master or slave.
    // ref: https://dev.mysql.com/doc/refman/5.7/en/server-system-variables.html#sysvar_server_id
    //
    // So, BaseServerID is needed to calculate a unique server_id for each member.
    BaseServerID *int64 `json:"baseServerID,omitempty" protobuf:"varint,3,opt,name=baseServerID"`
}

func (*MySQLGroupSpec) DeepCopy Uses

func (in *MySQLGroupSpec) DeepCopy() *MySQLGroupSpec

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

func (*MySQLGroupSpec) DeepCopyInto Uses

func (in *MySQLGroupSpec) DeepCopyInto(out *MySQLGroupSpec)

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

func (*MySQLGroupSpec) Descriptor Uses

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

func (*MySQLGroupSpec) Marshal Uses

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

func (*MySQLGroupSpec) MarshalTo Uses

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

func (*MySQLGroupSpec) MarshalToSizedBuffer Uses

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

func (*MySQLGroupSpec) ProtoMessage Uses

func (*MySQLGroupSpec) ProtoMessage()

func (*MySQLGroupSpec) Reset Uses

func (m *MySQLGroupSpec) Reset()

func (*MySQLGroupSpec) Size Uses

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

func (*MySQLGroupSpec) String Uses

func (this *MySQLGroupSpec) String() string

func (*MySQLGroupSpec) Unmarshal Uses

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

func (*MySQLGroupSpec) XXX_DiscardUnknown Uses

func (m *MySQLGroupSpec) XXX_DiscardUnknown()

func (*MySQLGroupSpec) XXX_Marshal Uses

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

func (*MySQLGroupSpec) XXX_Merge Uses

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

func (*MySQLGroupSpec) XXX_Size Uses

func (m *MySQLGroupSpec) XXX_Size() int

func (*MySQLGroupSpec) XXX_Unmarshal Uses

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

type MySQLList Uses

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

func (*MySQLList) DeepCopy Uses

func (in *MySQLList) DeepCopy() *MySQLList

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

func (*MySQLList) DeepCopyInto Uses

func (in *MySQLList) DeepCopyInto(out *MySQLList)

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

func (*MySQLList) DeepCopyObject Uses

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

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

func (*MySQLList) Descriptor Uses

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

func (*MySQLList) Marshal Uses

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

func (*MySQLList) MarshalTo Uses

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

func (*MySQLList) MarshalToSizedBuffer Uses

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

func (*MySQLList) ProtoMessage Uses

func (*MySQLList) ProtoMessage()

func (*MySQLList) Reset Uses

func (m *MySQLList) Reset()

func (*MySQLList) Size Uses

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

func (*MySQLList) String Uses

func (this *MySQLList) String() string

func (*MySQLList) Unmarshal Uses

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

func (*MySQLList) XXX_DiscardUnknown Uses

func (m *MySQLList) XXX_DiscardUnknown()

func (*MySQLList) XXX_Marshal Uses

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

func (*MySQLList) XXX_Merge Uses

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

func (*MySQLList) XXX_Size Uses

func (m *MySQLList) XXX_Size() int

func (*MySQLList) XXX_Unmarshal Uses

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

type MySQLSpec Uses

type MySQLSpec struct {
    // Version of MySQL to be deployed.
    Version string `json:"version" protobuf:"bytes,1,opt,name=version"`

    // Number of instances to deploy for a MySQL database. In case of MySQL group
    // replication, max allowed value is 9 (default 3).
    // (see ref: https://dev.mysql.com/doc/refman/5.7/en/group-replication-frequently-asked-questions.html)
    Replicas *int32 `json:"replicas,omitempty" protobuf:"varint,2,opt,name=replicas"`

    // MySQL cluster topology
    Topology *MySQLClusterTopology `json:"topology,omitempty" protobuf:"bytes,3,opt,name=topology"`

    // StorageType can be durable (default) or ephemeral
    StorageType StorageType `json:"storageType,omitempty" protobuf:"bytes,4,opt,name=storageType,casttype=StorageType"`

    // Storage spec to specify how storage shall be used.
    Storage *core.PersistentVolumeClaimSpec `json:"storage,omitempty" protobuf:"bytes,5,opt,name=storage"`

    // Database authentication secret
    DatabaseSecret *core.SecretVolumeSource `json:"databaseSecret,omitempty" protobuf:"bytes,6,opt,name=databaseSecret"`

    // Init is used to initialize database
    // +optional
    Init *InitSpec `json:"init,omitempty" protobuf:"bytes,7,opt,name=init"`

    // Monitor is used monitor database instance
    // +optional
    Monitor *mona.AgentSpec `json:"monitor,omitempty" protobuf:"bytes,9,opt,name=monitor"`

    // ConfigSource is an optional field to provide custom configuration file for database (i.e custom-mysql.cnf).
    // 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,10,opt,name=configSource"`

    // PodTemplate is an optional configuration for pods used to expose database
    // +optional
    PodTemplate ofst.PodTemplateSpec `json:"podTemplate,omitempty" protobuf:"bytes,11,opt,name=podTemplate"`

    // ServiceTemplate is an optional configuration for service used to expose database
    // +optional
    ServiceTemplate ofst.ServiceTemplateSpec `json:"serviceTemplate,omitempty" protobuf:"bytes,12,opt,name=serviceTemplate"`

    // Indicates that the database server need to be encrypted connections(ssl)
    // +optional
    RequireSSL bool `json:"requireSSL,omitempty" protobuf:"varint,13,opt,name=requireSSL"`

    // TLS contains tls configurations for client and server.
    // +optional
    TLS *kmapi.TLSConfig `json:"tls,omitempty" protobuf:"bytes,14,opt,name=tls"`

    // 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,15,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,16,opt,name=halted"`

    // TerminationPolicy controls the delete operation for database
    // +optional
    TerminationPolicy TerminationPolicy `json:"terminationPolicy,omitempty" protobuf:"bytes,17,opt,name=terminationPolicy,casttype=TerminationPolicy"`
}

func (*MySQLSpec) DeepCopy Uses

func (in *MySQLSpec) DeepCopy() *MySQLSpec

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

func (*MySQLSpec) DeepCopyInto Uses

func (in *MySQLSpec) DeepCopyInto(out *MySQLSpec)

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

func (*MySQLSpec) Descriptor Uses

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

func (*MySQLSpec) GetSecrets Uses

func (m *MySQLSpec) GetSecrets() []string

func (*MySQLSpec) Marshal Uses

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

func (*MySQLSpec) MarshalTo Uses

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

func (*MySQLSpec) MarshalToSizedBuffer Uses

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

func (*MySQLSpec) ProtoMessage Uses

func (*MySQLSpec) ProtoMessage()

func (*MySQLSpec) Reset Uses

func (m *MySQLSpec) Reset()

func (*MySQLSpec) Size Uses

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

func (*MySQLSpec) String Uses

func (this *MySQLSpec) String() string

func (*MySQLSpec) Unmarshal Uses

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

func (*MySQLSpec) XXX_DiscardUnknown Uses

func (m *MySQLSpec) XXX_DiscardUnknown()

func (*MySQLSpec) XXX_Marshal Uses

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

func (*MySQLSpec) XXX_Merge Uses

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

func (*MySQLSpec) XXX_Size Uses

func (m *MySQLSpec) XXX_Size() int

func (*MySQLSpec) XXX_Unmarshal Uses

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

type MySQLStatus Uses

type MySQLStatus 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 (*MySQLStatus) DeepCopy Uses

func (in *MySQLStatus) DeepCopy() *MySQLStatus

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

func (*MySQLStatus) DeepCopyInto Uses

func (in *MySQLStatus) DeepCopyInto(out *MySQLStatus)

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

func (*MySQLStatus) Descriptor Uses

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

func (*MySQLStatus) Marshal Uses

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

func (*MySQLStatus) MarshalTo Uses

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

func (*MySQLStatus) MarshalToSizedBuffer Uses

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

func (*MySQLStatus) ProtoMessage Uses

func (*MySQLStatus) ProtoMessage()

func (*MySQLStatus) Reset Uses

func (m *MySQLStatus) Reset()

func (*MySQLStatus) Size Uses

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

func (*MySQLStatus) String Uses

func (this *MySQLStatus) String() string

func (*MySQLStatus) Unmarshal Uses

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

func (*MySQLStatus) XXX_DiscardUnknown Uses

func (m *MySQLStatus) XXX_DiscardUnknown()

func (*MySQLStatus) XXX_Marshal Uses

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

func (*MySQLStatus) XXX_Merge Uses

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

func (*MySQLStatus) XXX_Size Uses

func (m *MySQLStatus) XXX_Size() int

func (*MySQLStatus) XXX_Unmarshal Uses

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

type PerconaXtraDB Uses

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

+kubebuilder:object:root=true +kubebuilder:resource:path=perconaxtradbs,singular=perconaxtradb,shortName=px,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 (PerconaXtraDB) AppBindingMeta Uses

func (p PerconaXtraDB) AppBindingMeta() appcat.AppBindingMeta

func (PerconaXtraDB) ClusterName Uses

func (p PerconaXtraDB) ClusterName() string

func (PerconaXtraDB) CustomResourceDefinition Uses

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

func (*PerconaXtraDB) DeepCopy Uses

func (in *PerconaXtraDB) DeepCopy() *PerconaXtraDB

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

func (*PerconaXtraDB) DeepCopyInto Uses

func (in *PerconaXtraDB) DeepCopyInto(out *PerconaXtraDB)

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

func (*PerconaXtraDB) DeepCopyObject Uses

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

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

func (*PerconaXtraDB) Descriptor Uses

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

func (PerconaXtraDB) GetDatabaseSecretName Uses

func (p PerconaXtraDB) GetDatabaseSecretName() string

func (*PerconaXtraDB) GetMonitoringVendor Uses

func (p *PerconaXtraDB) GetMonitoringVendor() string

func (PerconaXtraDB) GoverningServiceName Uses

func (p PerconaXtraDB) GoverningServiceName() string

func (PerconaXtraDB) IsCluster Uses

func (p PerconaXtraDB) IsCluster() bool

func (*PerconaXtraDB) Marshal Uses

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

func (*PerconaXtraDB) MarshalTo Uses

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

func (*PerconaXtraDB) MarshalToSizedBuffer Uses

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

func (PerconaXtraDB) OffshootLabels Uses

func (p PerconaXtraDB) OffshootLabels() map[string]string

func (PerconaXtraDB) OffshootName Uses

func (p PerconaXtraDB) OffshootName() string

func (PerconaXtraDB) OffshootSelectors Uses

func (p PerconaXtraDB) OffshootSelectors() map[string]string

func (PerconaXtraDB) PeerName Uses

func (p PerconaXtraDB) PeerName(idx int) string

func (*PerconaXtraDB) ProtoMessage Uses

func (*PerconaXtraDB) ProtoMessage()

func (*PerconaXtraDB) Reset Uses

func (m *PerconaXtraDB) Reset()

func (PerconaXtraDB) ResourceKind Uses

func (p PerconaXtraDB) ResourceKind() string

func (PerconaXtraDB) ResourcePlural Uses

func (p PerconaXtraDB) ResourcePlural() string

func (PerconaXtraDB) ResourceShortCode Uses

func (p PerconaXtraDB) ResourceShortCode() string

func (PerconaXtraDB) ResourceSingular Uses

func (p PerconaXtraDB) ResourceSingular() string

func (PerconaXtraDB) ServiceName Uses

func (p PerconaXtraDB) ServiceName() string

func (*PerconaXtraDB) SetDefaults Uses

func (p *PerconaXtraDB) SetDefaults()

func (*PerconaXtraDB) Size Uses

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

func (PerconaXtraDB) StatsService Uses

func (p PerconaXtraDB) StatsService() mona.StatsAccessor

func (PerconaXtraDB) StatsServiceLabels Uses

func (p PerconaXtraDB) StatsServiceLabels() map[string]string

func (*PerconaXtraDB) String Uses

func (this *PerconaXtraDB) String() string

func (*PerconaXtraDB) Unmarshal Uses

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

func (*PerconaXtraDB) XXX_DiscardUnknown Uses

func (m *PerconaXtraDB) XXX_DiscardUnknown()

func (*PerconaXtraDB) XXX_Marshal Uses

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

func (*PerconaXtraDB) XXX_Merge Uses

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

func (*PerconaXtraDB) XXX_Size Uses

func (m *PerconaXtraDB) XXX_Size() int

func (*PerconaXtraDB) XXX_Unmarshal Uses

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

type PerconaXtraDBCertificateAlias Uses

type PerconaXtraDBCertificateAlias string

+kubebuilder:validation:Enum=server;archiver;metrics-exporter

const (
    PerconaXtraDBServerCert          PerconaXtraDBCertificateAlias = "server"
    PerconaXtraDBArchiverCert        PerconaXtraDBCertificateAlias = "archiver"
    PerconaXtraDBMetricsExporterCert PerconaXtraDBCertificateAlias = "metrics-exporter"
)

type PerconaXtraDBList Uses

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

func (*PerconaXtraDBList) DeepCopy Uses

func (in *PerconaXtraDBList) DeepCopy() *PerconaXtraDBList

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

func (*PerconaXtraDBList) DeepCopyInto Uses

func (in *PerconaXtraDBList) DeepCopyInto(out *PerconaXtraDBList)

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

func (*PerconaXtraDBList) DeepCopyObject Uses

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

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

func (*PerconaXtraDBList) Descriptor Uses

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

func (*PerconaXtraDBList) Marshal Uses