Documentation
¶
Index ¶
Constants ¶
View Source
const ( SparkRoleLabel = "spark-role" SparkRoleDriverValue = "driver" SparkRoleExecutorValue = "executor" )
Variables ¶
This section is empty.
Functions ¶
Types ¶
type AdmissionController ¶
type AdmissionController struct {
// contains filtered or unexported fields
}
func NewAdmissionController ¶
func NewAdmissionController(client kubernetes.Interface, provider cloudstorage.CloudStorageProvider, instanceTypeManager instances.InstanceTypeManager, log logr.Logger) *AdmissionController
func (*AdmissionController) GetHandlerFunc ¶
func (ac *AdmissionController) GetHandlerFunc(m Mutator) func(http.ResponseWriter, *http.Request)
type ConfigMapMutator ¶
type ConfigMapMutator struct {
// contains filtered or unexported fields
}
func NewConfigMapMutator ¶
func NewConfigMapMutator(log logr.Logger, client kubernetes.Interface, provider cloudstorage.CloudStorageProvider) ConfigMapMutator
func (ConfigMapMutator) Mutate ¶
func (m ConfigMapMutator) Mutate(req *admissionv1.AdmissionRequest) (*admissionv1.AdmissionResponse, error)
type Mutator ¶
type Mutator interface {
Mutate(admissionSpec *admissionv1.AdmissionRequest) (*admissionv1.AdmissionResponse, error)
}
type PodMutator ¶
type PodMutator struct {
// contains filtered or unexported fields
}
func NewPodMutator ¶
func NewPodMutator(log logr.Logger, storageProvider cloudstorage.CloudStorageProvider, instanceTypeManager instances.InstanceTypeManager) PodMutator
func (PodMutator) Mutate ¶
func (m PodMutator) Mutate(req *admissionv1.AdmissionRequest) (*admissionv1.AdmissionResponse, error)
Source Files
Click to show internal directories.
Click to hide internal directories.