- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for STARTING (0.17 sec)
-
pilot/pkg/bootstrap/server.go
func (s *Server) Start(stop <-chan struct{}) error { log.Infof("Starting Istiod Server with primary cluster %s", s.clusterID) if features.UnsafeFeaturesEnabled() { log.Warn("Server is starting with unsafe features enabled") } // Now start all of the components. if err := s.server.Start(stop); err != nil { return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
if err != nil { return nil, fmt.Errorf("while starting informer-based ClusterTrustBundle manager: %w", err) } kubeInformers.Start(wait.NeverStop) klog.InfoS("Started ClusterTrustBundle informer") } else { // In static kubelet mode, use a no-op manager. clusterTrustBundleManager = &clustertrustbundle.NoopManager{} klog.InfoS("Not starting ClusterTrustBundle informer because we are in static kubelet mode") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client.go
func (cl *Client) Run(stop <-chan struct{}) { if cl.started.Swap(true) { // was already started by other thread return } t0 := time.Now() cl.logger.Infof("Starting Pilot K8S CRD controller") if !kube.WaitForCacheSync("crdclient", stop, cl.informerSynced) { cl.logger.Errorf("Failed to sync Pilot K8S CRD controller cache") return }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0) -
pilot/pkg/bootstrap/istio_ca.go
iss := trustedIssuer.Get() aud := audience.Get() token, err := os.ReadFile(securityModel.ThirdPartyJwtPath) if err == nil { tok, err := detectAuthEnv(string(token)) if err != nil { log.Warnf("Starting with invalid K8S JWT token: %v", err) } else { if iss == "" { iss = tok.Iss } if len(tok.Aud) > 0 && len(aud) == 0 { aud = tok.Aud[0] } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 20.6K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster.go
if !sidecarScope.HasIngressListener() { // We should not create inbound listeners in NONE mode based on the service instances // Doing so will prevent the workloads from starting as they would be listening on the same port // Users are required to provide the sidecar config to define the inbound listeners if noneMode { return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_inbound.go
if !lb.node.SidecarScope.HasIngressListener() { // We should not create inbound listeners in NONE mode based on the service instances // Doing so will prevent the workloads from starting as they would be listening on the same port // Users are required to provide the sidecar config to define the inbound listeners if lb.node.GetInterceptionMode() == model.InterceptionNone { return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 35.1K bytes - Viewed (0) -
cmd/encryption-v1.go
if endEncOffset > encCumulativeSum+int64(lastPartSize) { endEncOffset = encCumulativeSum + int64(lastPartSize) } encLength = endEncOffset - encOff // Set the sequence number as the starting package number of // the requested block seqNumber = uint32(startPkgNum) return encOff, encLength, skipLen, seqNumber, partStart, nil } // EncryptedSize returns the size of the object after encryption.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 37.1K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
// because some service changed.) // // Note that there is a race between Kubelet seeing the pod and kubelet seeing the service. // To avoid this users can: (1) wait between starting a service and starting; or (2) detect // missing service env var and exit and be restarted; or (3) use DNS instead of env vars // and keep trying to resolve the DNS name of the service (recommended).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
cmd/bucket-replication.go
}, UserAgent: "Internal: [Replication]", Host: globalLocalNodeName, EventName: event.ObjectReplicationNotTracked, }) return } // Lock the object name before starting replication operation. // Use separate lock that doesn't collide with regular objects. lk := objectAPI.NewNSLock(bucket, "/[replicate]/"+dobj.ObjectName) lkctx, err := lk.GetLock(ctx, globalOperationTimeout)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0)