webhook

Documentation

Index

• Variables
• type Admitter
  • func NewAdmitter() (*Admitter, error)
  • func (a *Admitter) AdmitPVC(ar admissionv1.AdmissionReview) *admissionv1.AdmissionResponse
  • func (a *Admitter) DecidePVC(ctx context.Context, pvc ReqInfo) *admissionv1.AdmissionResponse
• type CertWatcher
  • func NewCertWatcher(certPath, keyPath string) (*CertWatcher, error)
  • func (cw *CertWatcher) GetCertificate(_ *tls.ClientHelloInfo) (*tls.Certificate, error)
  • func (cw *CertWatcher) ReadCertificate() error
  • func (cw *CertWatcher) Start(ctx context.Context) error
  • func (cw *CertWatcher) Watch()
• type PVCAdmitter
  • func NewAdmitterWithClient(client client.Client) PVCAdmitter
• type ReqInfo
  • func NewPVCReqInfo(name string, namespace string, storageClassName string, ...) ReqInfo

Variables

var CmdWebhook = &cobra.Command{
	Use:  "storageClass-webhook",
	Args: cobra.MaximumNArgs(0),
	Run:  main,
}

CmdWebhook is user by Cobra

Types

type Admitter

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

func NewAdmitter

func NewAdmitter() (*Admitter, error)

func (*Admitter) AdmitPVC

func (a *Admitter) AdmitPVC(ar admissionv1.AdmissionReview) *admissionv1.AdmissionResponse

func (*Admitter) DecidePVC

func (a *Admitter) DecidePVC(ctx context.Context, pvc ReqInfo) *admissionv1.AdmissionResponse

type CertWatcher

type CertWatcher struct {
	sync.Mutex
	// contains filtered or unexported fields
}

CertWatcher watches certificate and key files for changes. When either file changes, it reads and parses both and calls an optional callback with the new certificate.

func NewCertWatcher

func NewCertWatcher(certPath, keyPath string) (*CertWatcher, error)

NewCertWatcher returns a new CertWatcher watching the given certificate and key.

func (*CertWatcher) GetCertificate

func (cw *CertWatcher) GetCertificate(_ *tls.ClientHelloInfo) (*tls.Certificate, error)

GetCertificate fetches the currently loaded certificate, which may be nil.

func (*CertWatcher) ReadCertificate

func (cw *CertWatcher) ReadCertificate() error

ReadCertificate reads the certificate and key files from disk, parses them, and updates the current certificate on the watcher. If a callback is set, it is invoked with the new certificate.

func (*CertWatcher) Start

func (cw *CertWatcher) Start(ctx context.Context) error

Start starts the watch on the certificate and key files.

func (*CertWatcher) Watch

func (cw *CertWatcher) Watch()

Watch reads events from the watcher's channel and reacts to changes.

type PVCAdmitter

type PVCAdmitter interface {
	AdmitPVC(ar admissionv1.AdmissionReview) *admissionv1.AdmissionResponse
	DecidePVC(ctx context.Context, pvc ReqInfo) *admissionv1.AdmissionResponse
}

func NewAdmitterWithClient

func NewAdmitterWithClient(client client.Client) PVCAdmitter

type ReqInfo

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

func NewPVCReqInfo

func NewPVCReqInfo(name string, namespace string, storageClassName string, operation admissionv1.Operation) ReqInfo