elasticsearch: kubedb.dev/elasticsearch/pkg/controller Index | Files

package controller

import "kubedb.dev/elasticsearch/pkg/controller"


Package Files

appbinding.go certificate.go config.go configmap.go controller.go dormant.go elasticsearch.go monitor.go rbac.go secret.go service.go statefulset.go workqueue.go


const (
    ConfigFileName          = "elasticsearch.yml"
    ConfigFileMountPathSG   = "/elasticsearch/config"
    ConfigFileMountPath     = "/usr/share/elasticsearch/config"
    TempConfigFileMountPath = "/elasticsearch/temp-config"
    DatabaseConfigMapSuffix = `config`
const (
    AdminUser          = "admin"
    ElasticUser        = "elastic"
    KeyAdminUserName   = "ADMIN_USERNAME"
    KeyAdminPassword   = "ADMIN_PASSWORD"
    ReadAllUser        = "readall"
    KeyReadAllUserName = "READALL_USERNAME"
    KeyReadAllPassword = "READALL_PASSWORD"
    ExporterSecretPath = "/var/run/secrets/kubedb.com/"
const (
    NodeRoleMaster = "node.role.master"
    NodeRoleClient = "node.role.client"
    NodeRoleData   = "node.role.data"
    NodeRoleSet    = "set"
const (
    CustomConfigMountPath         = "/elasticsearch/custom-config"
    ExporterCertDir               = "/usr/config/certs"
    ConfigMergerInitContainerName = "config-merger"

func NewSignedCert Uses

func NewSignedCert(cfg cert.Config, key *rsa.PrivateKey, caCert *x509.Certificate, caKey *rsa.PrivateKey) (*x509.Certificate, error)

NewSignedCert creates a signed certificate using the given CA certificate and key

type Controller Uses

type Controller struct {
    // contains filtered or unexported fields

func New Uses

func New(
    restConfig *restclient.Config,
    client kubernetes.Interface,
    crdClient crd_cs.Interface,
    extClient cs.Interface,
    stashClient scs.Interface,
    dc dynamic.Interface,
    appCatalogClient appcat_cs.Interface,
    promClient pcm.MonitoringV1Interface,
    opt amc.Config,
    topology *core_util.Topology,
    recorder record.EventRecorder,
) *Controller

func (*Controller) CheckStatefulSetPodStatus Uses

func (c *Controller) CheckStatefulSetPodStatus(statefulSet *apps.StatefulSet) error

func (*Controller) EnsureCustomResourceDefinitions Uses

func (c *Controller) EnsureCustomResourceDefinitions() error

Ensuring Custom Resources Definitions

func (*Controller) GetDatabase Uses

func (c *Controller) GetDatabase(meta metav1.ObjectMeta) (runtime.Object, error)

func (*Controller) Init Uses

func (c *Controller) Init() error

InitInformer initializes Elasticsearch, DormantDB amd Snapshot watcher

func (*Controller) Run Uses

func (c *Controller) Run(stopCh <-chan struct{})

Blocks caller. Intended to be called as a Go routine.

func (*Controller) RunControllers Uses

func (c *Controller) RunControllers(stopCh <-chan struct{})

RunControllers runs queue.worker

func (*Controller) SetDatabaseStatus Uses

func (c *Controller) SetDatabaseStatus(meta metav1.ObjectMeta, phase api.DatabasePhase, reason string) error

func (*Controller) StartAndRunControllers Uses

func (c *Controller) StartAndRunControllers(stopCh <-chan struct{})

StartAndRunControllers starts InformetFactory and runs queue.worker

func (*Controller) UpsertDatabaseAnnotation Uses

func (c *Controller) UpsertDatabaseAnnotation(meta metav1.ObjectMeta, annotation map[string]string) error

type OperatorConfig Uses

type OperatorConfig struct {

    ClientConfig     *rest.Config
    KubeClient       kubernetes.Interface
    CRDClient        crd_cs.Interface
    DBClient         cs.Interface
    DynamicClient    dynamic.Interface
    StashClient      scs.Interface
    AppCatalogClient appcat_cs.Interface
    PromClient       pcm.MonitoringV1Interface

func NewOperatorConfig Uses

func NewOperatorConfig(clientConfig *rest.Config) *OperatorConfig

func (*OperatorConfig) New Uses

func (c *OperatorConfig) New() (*Controller, error)

Package controller imports 73 packages (graph) and is imported by 8 packages. Updated 2020-07-09. Refresh now. Tools for package owners.