redis: Index | Files

package controller

import ""


Package Files

appbinding.go config.go controller.go dormant.go monitor.go rbac.go redis.go redis_config.go secret.go service.go statefulset.go workqueue.go


const (
    RedisConfigKey          = "redis.conf"
    RedisConfigRelativePath = "redis.conf"
const (
    CONFIG_MOUNT_PATH = "/usr/local/etc/redis/"

type Controller Uses

type Controller struct {
    // contains filtered or unexported fields

func New Uses

func New(
    clientConfig *rest.Config,
    client kubernetes.Interface,
    crdClient crd_cs.Interface,
    extClient cs.Interface,
    dynamicClient dynamic.Interface,
    appCatalogClient appcat_cs.Interface,
    promClient pcm.MonitoringV1Interface,
    opt amc.Config,
    topology *core_util.Topology,
    recorder record.EventRecorder,
) *Controller

func (*Controller) EnsureCustomResourceDefinitions Uses

func (c *Controller) EnsureCustomResourceDefinitions() error

EnsureCustomResourceDefinitions ensures CRD for Redis, DormantDatabase

func (*Controller) GetPrimaryServicePort Uses

func (c *Controller) GetPrimaryServicePort(db *api.Redis) (int32, error)

func (*Controller) GetRedisSecrets Uses

func (c *Controller) GetRedisSecrets(db *api.Redis) []string

func (*Controller) Init Uses

func (c *Controller) Init() error

InitInformer initializes Redis, DormantDB amd Snapshot watcher

func (*Controller) RedisForSecret Uses

func (c *Controller) RedisForSecret(s *core.Secret) cache.ExplicitKey

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) StartAndRunControllers Uses

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

StartAndRunControllers starts InformerFactory and runs queue.worker

type OperatorConfig Uses

type OperatorConfig struct {

    LicenseFile      string
    ClientConfig     *rest.Config
    KubeClient       kubernetes.Interface
    APIExtKubeClient crd_cs.Interface
    DBClient         cs.Interface
    DynamicClient    dynamic.Interface
    AppCatalogClient appcat_cs.Interface
    PromClient       pcm.MonitoringV1Interface
    Recorder         record.EventRecorder

func NewOperatorConfig Uses

func NewOperatorConfig(clientConfig *rest.Config) *OperatorConfig

func (*OperatorConfig) New Uses

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

Package controller imports 58 packages (graph) and is imported by 6 packages. Updated 2020-11-12. Refresh now. Tools for package owners.