Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var FixedEtcdEnvVars = map[string]string{
"ETCD_DATA_DIR": "/var/lib/etcd",
"ETCD_INITIAL_CLUSTER_STATE": "existing",
"ETCD_ENABLE_PPROF": "true",
"ETCD_EXPERIMENTAL_WATCH_PROGRESS_NOTIFY_INTERVAL": "5s",
"ETCD_SOCKET_REUSE_ADDRESS": "true",
"ETCD_EXPERIMENTAL_WARNING_APPLY_DURATION": "200ms",
}
Functions ¶
func GibibytesToBytesString ¶
Types ¶
type Enqueueable ¶
type Enqueueable interface {
Enqueue()
}
type EnvVar ¶
type EnvVar interface { AddListener(listener Enqueueable) GetEnvVars() map[string]string }
type EnvVarController ¶
type EnvVarController struct {
// contains filtered or unexported fields
}
func NewEnvVarController ¶
func NewEnvVarController( targetImagePullSpec string, operatorClient v1helpers.StaticPodOperatorClient, kubeInformersForNamespaces v1helpers.KubeInformersForNamespaces, masterNodeInformer cache.SharedIndexInformer, masterNodeLister corev1listers.NodeLister, masterNodeLabelSelector labels.Selector, infrastructureInformer configv1informers.InfrastructureInformer, networkInformer configv1informers.NetworkInformer, eventRecorder events.Recorder, etcdsInformer operatorv1informers.EtcdInformer, featureGateAccessor featuregates.FeatureGateAccess, ) *EnvVarController
func (*EnvVarController) AddListener ¶
func (c *EnvVarController) AddListener(listener Enqueueable)
func (*EnvVarController) GetEnvVars ¶
func (c *EnvVarController) GetEnvVars() map[string]string
func (*EnvVarController) Run ¶
func (c *EnvVarController) Run(_ int, stopCh <-chan struct{})
Run starts the etcd and blocks until stopCh is closed.
type FakeEnvVar ¶
type FakeEnvVar struct { EnvVars map[string]string Listeners []Enqueueable }
func (FakeEnvVar) AddListener ¶
func (f FakeEnvVar) AddListener(listener Enqueueable)
func (FakeEnvVar) GetEnvVars ¶
func (f FakeEnvVar) GetEnvVars() map[string]string
Click to show internal directories.
Click to hide internal directories.