Method submit

pkg/webhook/admission/resource.go:122–147

(ctx context.Context, conf *v1.ValidatingWebhookConfiguration)

}

func (w *ValidatingWebhookResource) submit(ctx context.Context, conf *v1.ValidatingWebhookConfiguration) error {
	client := w.opts.KubeClient.AdmissionregistrationV1().ValidatingWebhookConfigurations()
	listOpts := metav1.ListOptions{
		FieldSelector: "metadata.name=" + conf.Name,
	}

	return retry.WithBackoff(ctx, submitRetryConfig, w.logger.With(slog.String(pkg.LogKeyName, conf.Name)),
		"ValidatingWebhookConfiguration/submit", func() error {
			list, err := client.List(ctx, listOpts)
			if err != nil {
				return fmt.Errorf("list ValidatingWebhookConfiguration: %w", err)
			}
			if len(list.Items) == 0 {
				if _, err := client.Create(ctx, conf, pkg.DefaultCreateOptions()); err != nil {
					return fmt.Errorf("create ValidatingWebhookConfiguration: %w", err)
				}
			} else {
				newConf := list.Items[0]
				newConf.Webhooks = conf.Webhooks
				if _, err := client.Update(ctx, &newConf, pkg.DefaultUpdateOptions()); err != nil {
					return fmt.Errorf("update ValidatingWebhookConfiguration: %w", err)
				}
			}
			return nil
		})
}

type MutatingWebhookResource struct {
	hooks map[string]*MutatingWebhookConfig