- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 25 for newCerts (0.31 sec)
-
cmd/kubeadm/app/phases/certs/renewal/readwriter.go
return certs[0], nil } // Write a certificate to files in the K8s pki managed by kubeadm func (rw *pkiCertificateReadWriter) Write(newCert *x509.Certificate, newKey crypto.Signer) error { if err := pkiutil.WriteCertAndKey(rw.certificateDir, rw.baseName, newCert, newKey); err != nil { return errors.Wrapf(err, "failed to write new certificate %s", rw.baseName) } return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 01 03:09:53 UTC 2024 - 8.4K bytes - Viewed (0) -
operator/pkg/util/errs_test.go
if got, want := ToString(testErrs, defaultSeparator), wantStr; got != want { t.Errorf("got: %s, want: %s", got, want) } } func TestNewErrs(t *testing.T) { errs := NewErrs(nil) if errs != nil { t.Errorf("got: %s, want: nil", errs) } errs = NewErrs(fmt.Errorf("err1")) if got, want := errs.String(), "err1"; got != want { t.Errorf("got: %s, want: %s", got, want) } } func TestAppendErr(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 29 20:42:01 UTC 2020 - 3K bytes - Viewed (0) -
src/crypto/tls/cache.go
cc.Delete(string(e.cert.Raw)) } // newCert returns a x509.Certificate parsed from der. If there is already a copy // of the certificate in the cache, a reference to the existing certificate will // be returned. Otherwise, a fresh certificate will be added to the cache, and // the reference returned. The returned reference should not be mutated. func (cc *certCache) newCert(der []byte) (*activeCert, error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 24 23:56:41 UTC 2023 - 3.4K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/mod/modfile/work.go
if d.Path == path { d.Syntax.markRemoved() *d = Use{} } } return nil } func (f *WorkFile) AddReplace(oldPath, oldVers, newPath, newVers string) error { return addReplace(f.Syntax, &f.Replace, oldPath, oldVers, newPath, newVers) } func (f *WorkFile) DropReplace(oldPath, oldVers string) error { for _, r := range f.Replace { if r.Old.Path == oldPath && r.Old.Version == oldVers {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 18:34:56 UTC 2024 - 7.7K bytes - Viewed (0) -
operator/pkg/patch/patch.go
bo := make(map[any]any) by, err := base.YAML() if err != nil { return "", util.NewErrs(err) } // Use yaml2 specifically to allow interface{} as key which WritePathContext treats specially err = yaml2.Unmarshal(by, &bo) if err != nil { return "", util.NewErrs(err) } for _, p := range patches { v := p.Value.AsInterface() if strings.TrimSpace(p.Path) == "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Aug 10 15:35:03 UTC 2023 - 6.2K bytes - Viewed (0) -
operator/pkg/apis/istio/v1alpha1/validation/validation.go
validators := []FeatureValidator{ CheckServicePorts, CheckAutoScaleAndReplicaCount, } for _, validator := range validators { newErrs, newWarnings := validator(values, spec) errs = util.AppendErrs(errs, newErrs) warnings = append(warnings, newWarnings...) } return } // CheckAutoScaleAndReplicaCount warns when autoscaleEnabled is true and k8s replicaCount is set.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 20:02:28 UTC 2024 - 14.9K bytes - Viewed (0) -
pkg/kubelet/cm/cgroup_manager_linux.go
if len(cgroupName) == 0 || (len(cgroupName) == 1 && cgroupName[0] == "") { return "/" } newparts := []string{} for _, part := range cgroupName { part = escapeSystemdCgroupName(part) newparts = append(newparts, part) } result, err := cgroupsystemd.ExpandSlice(strings.Join(newparts, "-") + systemdSuffix) if err != nil { // Should never happen...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 26.5K bytes - Viewed (0) -
operator/pkg/controlplane/control_plane.go
return nil } // RenderManifest returns a manifest rendered against func (i *IstioControlPlane) RenderManifest() (manifests name.ManifestMap, errsOut util.Errors) { if !i.started { return nil, util.NewErrs(fmt.Errorf("istioControlPlane must be Run before calling RenderManifest")) } manifests = make(name.ManifestMap) for _, c := range i.components { ms, err := c.RenderManifest()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 23 02:26:59 UTC 2022 - 4K bytes - Viewed (0) -
src/crypto/tls/ticket.go
case 0: ss.EarlyData = false case 1: ss.EarlyData = true default: return nil, errors.New("tls: invalid session encoding") } for _, cert := range cert.Certificate { c, err := globalCertCache.newCert(cert) if err != nil { return nil, err } ss.activeCertHandles = append(ss.activeCertHandles, c) ss.peerCertificates = append(ss.peerCertificates, c.cert) } ss.ocspResponse = cert.OCSPStaple
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 17:23:54 UTC 2024 - 12.6K bytes - Viewed (0) -
pkg/registry/core/service/strategy.go
out.Insert(int(svc.Spec.Ports[i].NodePort)) } } return out } oldPorts := allNodePorts(oldSvc) newPorts := allNodePorts(newSvc) // Users can add, remove, or modify ports, as long as they don't add any // net-new NodePorts. return oldPorts.IsSuperset(newPorts) } func needsHCNodePort(svc *api.Service) bool { if svc.Spec.Type != api.ServiceTypeLoadBalancer { return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 13:09:36 UTC 2024 - 14.1K bytes - Viewed (0)