etcdenvvar

package
v0.0.0-alpha.0....-ec243c9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 4, 2024 License: Apache-2.0 Imports: 37 Imported by: 0

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

func GibibytesToBytesString(dbSize int64) string

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL