webhook

Documentation

Index

• type Config
  • func LoadConfig(file string) (*Config, error)
• type PodInjector
  • func NewPodInjector(config *Config, client client.Client) *PodInjector
  • func (p *PodInjector) Handle(ctx context.Context, req admission.Request) admission.Response
  • func (p *PodInjector) InjectDecoder(d *admission.Decoder) error

Types

type Config

type Config struct {
	RuntimeImage      string `yaml:"runtimeImage"`
	HostPath          string `yaml:"hostPath"`
	DataPathPrefix    string `yaml:"dataPathPrefix"`
	EnableAffinity    bool   `yaml:"enableAffinity"`
	RuntimeServerPort uint   `yaml:"runtimeServerPort"`
}

Config defines fields for webhook.

func LoadConfig

func LoadConfig(file string) (*Config, error)

LoadConfig returns config from the file.

type PodInjector

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

PodInjector defines fields for the sidecar container injected to the pod.

func NewPodInjector

func NewPodInjector(config *Config, client client.Client) *PodInjector

NewPodInjector returns PodInjector object by the config and client.

func (*PodInjector) Handle

func (p *PodInjector) Handle(ctx context.Context, req admission.Request) admission.Response

Handle handles an pod creation request, and mutates the pod spec if the dataset is exist.

func (*PodInjector) InjectDecoder

func (p *PodInjector) InjectDecoder(d *admission.Decoder) error

InjectDecoder injects the decoder.