handler

Documentation

Index

• Constants
• func Register(mgr manager.Manager, client *k8sclient.K8sClient)
• type PVHandler
  • func NewPVHandler(client *k8sclient.K8sClient) *PVHandler
  • func (s *PVHandler) Handle(ctx context.Context, request admission.Request) admission.Response
  • func (s *PVHandler) InjectDecoder(d *admission.Decoder) error
• type SecretHandler
  • func NewSecretHandler(client *k8sclient.K8sClient) *SecretHandler
  • func (s *SecretHandler) Handle(ctx context.Context, request admission.Request) admission.Response
  • func (s *SecretHandler) InjectDecoder(d *admission.Decoder) error
• type SidecarHandler
  • func NewSidecarHandler(client *k8sclient.K8sClient, serverless bool) *SidecarHandler
  • func (s *SidecarHandler) Handle(ctx context.Context, request admission.Request) admission.Response
  • func (s *SidecarHandler) InjectDecoder(d *admission.Decoder) error

Constants

const (
	SidecarPath    = "/juicefs/inject-v1-pod"
	ServerlessPath = "/juicefs/serverless/inject-v1-pod"
	SecretPath     = "/juicefs/validate-secret"
	PVPath         = "/juicefs/validate-pv"
)

Functions

func Register

func Register(mgr manager.Manager, client *k8sclient.K8sClient)

Register registers the handlers to the manager

Types

type PVHandler

type PVHandler struct {
	Client *k8sclient.K8sClient
	// contains filtered or unexported fields
}

func NewPVHandler

func NewPVHandler(client *k8sclient.K8sClient) *PVHandler

func (*PVHandler) Handle

func (s *PVHandler) Handle(ctx context.Context, request admission.Request) admission.Response

func (*PVHandler) InjectDecoder

func (s *PVHandler) InjectDecoder(d *admission.Decoder) error

InjectDecoder injects the decoder.

type SecretHandler

type SecretHandler struct {
	Client *k8sclient.K8sClient
	// contains filtered or unexported fields
}

func NewSecretHandler

func NewSecretHandler(client *k8sclient.K8sClient) *SecretHandler

func (*SecretHandler) Handle

func (s *SecretHandler) Handle(ctx context.Context, request admission.Request) admission.Response

func (*SecretHandler) InjectDecoder

func (s *SecretHandler) InjectDecoder(d *admission.Decoder) error

InjectDecoder injects the decoder.

type SidecarHandler

type SidecarHandler struct {
	Client *k8sclient.K8sClient
	// contains filtered or unexported fields
}

func NewSidecarHandler

func NewSidecarHandler(client *k8sclient.K8sClient, serverless bool) *SidecarHandler

func (*SidecarHandler) Handle

func (s *SidecarHandler) Handle(ctx context.Context, request admission.Request) admission.Response

func (*SidecarHandler) InjectDecoder

func (s *SidecarHandler) InjectDecoder(d *admission.Decoder) error

InjectDecoder injects the decoder.