controller

Documentation

Index

• type Config
  • func NewConfig(cfg *rest.Config, defaultResync time.Duration) Config
• type Controller
  • func New(cfg Config, kubernetesClient kubernetes.Interface, ...) Controller
• type RedisController
  • func (c *RedisController) Run(stopCh <-chan struct{})

Types

type Config

type Config struct {
	*rest.Config
	DefaultResync time.Duration
}

func NewConfig

func NewConfig(cfg *rest.Config,
	defaultResync time.Duration) Config

type Controller

type Controller interface {
	Run(<-chan struct{})
}

func New

func New(cfg Config,
	kubernetesClient kubernetes.Interface,
	redisClient redisclient.RedisesGetter,
	redisInformer redisinformer.RedisInformer,
	podInformer v1informer.PodInformer,
	deploymentInformer v1beta1informer.DeploymentInformer,
	serviceInformer v1informer.ServiceInformer,
	endpointsInformer v1informer.EndpointsInformer,
	configMapInformer v1informer.ConfigMapInformer,
	statefulSetInformer v1beta1informer.StatefulSetInformer) Controller

type RedisController

type RedisController struct {
	Config
	// contains filtered or unexported fields
}

func (*RedisController) Run

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