initializer

Documentation

Index

• type SparkPodInitializer
  • func New(kubeClient clientset.Interface) *SparkPodInitializer
  • func (ic *SparkPodInitializer) Run(workers int, stopCh <-chan struct{}, errCh chan<- error)

Types

type SparkPodInitializer

type SparkPodInitializer struct {
	// contains filtered or unexported fields
}

SparkPodInitializer watches uninitialized Spark driver and executor pods and modifies pod specs based on certain annotations on the pods. For example, it is responsible for mounting user-specified secrets and ConfigMaps into the driver and executor pods.

func New

func New(kubeClient clientset.Interface) *SparkPodInitializer

New creates a new instance of Initializer.

func (*SparkPodInitializer) Run

func (ic *SparkPodInitializer) Run(workers int, stopCh <-chan struct{}, errCh chan<- error)

Run runs the initializer controller.