controller

Documentation

Index

• type SparkApplicationController
  • func New(crdClient crd.ClientInterface, kubeClient clientset.Interface, ...) *SparkApplicationController
  • func (s *SparkApplicationController) Run(stopCh <-chan struct{}, errCh chan<- error)

Types

type SparkApplicationController

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

SparkApplicationController manages instances of SparkApplication.

func New

func New(
	crdClient crd.ClientInterface,
	kubeClient clientset.Interface,
	extensionsClient apiextensionsclient.Interface,
	submissionRunnerWorkers int) *SparkApplicationController

New creates a new SparkApplicationController.

func (*SparkApplicationController) Run

func (s *SparkApplicationController) Run(stopCh <-chan struct{}, errCh chan<- error)

Run starts the SparkApplicationController by registering a watcher for SparkApplication objects.