admission

Documentation

Index

• Constants
• func GetJsonPatch(original, modified runtime.Object) ([]byte, error)
• type AdmissionController
  • func NewAdmissionController(client kubernetes.Interface, provider cloudstorage.CloudStorageProvider, ...) *AdmissionController
  • func (ac *AdmissionController) GetHandlerFunc(m Mutator) func(http.ResponseWriter, *http.Request)
  • func (ac *AdmissionController) Start(ctx context.Context) error
• type ConfigMapMutator
  • func NewConfigMapMutator(log logr.Logger, client kubernetes.Interface, ...) ConfigMapMutator
  • func (m ConfigMapMutator) Mutate(req *admissionv1.AdmissionRequest) (*admissionv1.AdmissionResponse, error)
• type Mutator
• type PodMutator
  • func NewPodMutator(log logr.Logger, storageProvider cloudstorage.CloudStorageProvider, ...) PodMutator
  • func (m PodMutator) Mutate(req *admissionv1.AdmissionRequest) (*admissionv1.AdmissionResponse, error)

Constants

const (
	SparkRoleLabel         = "spark-role"
	SparkRoleDriverValue   = "driver"
	SparkRoleExecutorValue = "executor"
)

Functions

func GetJsonPatch

func GetJsonPatch(original, modified runtime.Object) ([]byte, error)

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)

func (*AdmissionController) Start

func (ac *AdmissionController) Start(ctx context.Context) error

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)