Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 823 for syncAt (0.32 sec)

  1. pkg/kube/multicluster/cluster.go

    	switch a {
    	case Add:
    		return "Add"
    	case Update:
    		return "Update"
    	}
    	return "Unknown"
    }
    
    // Run starts the cluster's informers and waits for caches to sync. Once caches are synced, we mark the cluster synced.
    // This should be called after each of the handlers have registered informers, and should be run in a goroutine.
    func (c *Cluster) Run(mesh mesh.Watcher, handlers []handler, action ACTION) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 06 02:13:10 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  2. src/internal/trace/summary.go

    	name string
    }
    
    // Event feeds a single event into the stats summarizer.
    func (s *Summarizer) Event(ev *Event) {
    	if s.syncTs == 0 {
    		s.syncTs = ev.Time()
    	}
    	s.lastTs = ev.Time()
    
    	switch ev.Kind() {
    	// Record sync time for the RangeActive events.
    	case EventSync:
    		s.syncTs = ev.Time()
    
    	// Handle state transitions.
    	case EventStateTransition:
    		st := ev.StateTransition()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 20.7K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_source.go

    See the License for the specific language governing permissions and
    limitations under the License.
    */
    
    package generic
    
    import (
    	"context"
    	goerrors "errors"
    	"fmt"
    	"sync"
    	"sync/atomic"
    	"time"
    
    	corev1 "k8s.io/api/core/v1"
    	"k8s.io/apimachinery/pkg/api/errors"
    	"k8s.io/apimachinery/pkg/api/meta"
    	"k8s.io/apimachinery/pkg/labels"
    	"k8s.io/apimachinery/pkg/runtime"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 21 23:07:34 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  4. cmd/kube-controller-manager/app/options/hpacontroller.go

    	fs.DurationVar(&o.HorizontalPodAutoscalerSyncPeriod.Duration, "horizontal-pod-autoscaler-sync-period", o.HorizontalPodAutoscalerSyncPeriod.Duration, "The period for syncing...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun May 19 09:49:23 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  5. cmd/metrics-v3-cluster-iam.go

    	syncFailuresMD                           = NewCounterMD(syncFailures, "Number of failed IAM data syncs since server start.")
    	syncSuccessesMD                          = NewCounterMD(syncSuccesses, "Number of successful IAM data syncs since server start.")
    )
    
    // loadClusterIAMMetrics - `MetricsLoaderFn` for cluster IAM metrics.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 02 08:20:42 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  6. hack/_update-generated-proto-bindings-dockerized.sh

    if [ "$#" == 0 ]; then
        echo "usage: $0 <api_dir>..."
        exit 1
    fi
    
    kube::protoc::check_protoc
    
    for api; do
        # This can't use `git ls-files` because it runs in a container without the
        # .git dir synced.
        protos=()
        kube::util::read-array protos < <( \
            find "${api}" -type f -name "api.proto")
    
        if [ "${#protos[@]}" == 0 ]; then
            echo "ERROR: no 'api.proto' files under '${api}'"
            exit 1
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:07:04 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  7. platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/ivyresolve/strategy/Version.java

     */
    
    package org.gradle.api.internal.artifacts.ivyservice.ivyresolve.strategy;
    
    import org.gradle.util.internal.VersionNumber;
    
    /**
     * A parsed version.
     *
     * This should be synced with {@link VersionNumber} and {@link org.gradle.util.GradleVersion} at some point.
     */
    public interface Version {
        /**
         * Returns the original {@link String} representation of the version.
         */
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Oct 10 21:10:11 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  8. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex.go

    }
    
    func (a *index) SyncAll() {
    	a.networkUpdateTrigger.TriggerRecomputation()
    }
    
    func (a *index) HasSynced() bool {
    	return a.services.Synced().HasSynced() &&
    		a.workloads.Synced().HasSynced() &&
    		a.waypoints.Synced().HasSynced() &&
    		a.authorizationPolicies.Synced().HasSynced()
    }
    
    type LookupNetwork func(endpointIP string, labels labels.Instance) network.ID
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 19 17:19:41 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  9. pkg/kubelet/kubelet.go

    //   - plegCh: update the runtime cache; sync pod
    //   - syncCh: sync all pods waiting for sync
    //   - housekeepingCh: trigger cleanup of pods
    //   - health manager: sync pods that have failed or in which one or more
    //     containers have failed health checks
    func (kl *Kubelet) syncLoopIteration(ctx context.Context, configCh <-chan kubetypes.PodUpdate, handler SyncHandler,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  10. pkg/kube/kclient/crdwatcher.go

    	if fv.LessThan(mv) {
    		log.Infof("CRD %v version %v is below minimum version %v, ignoring", crd.Name, fv, mv)
    		return false
    	}
    	return true
    }
    
    // HasSynced returns whether the underlying cache has synced and the callback has been called at least once.
    func (c *crdWatcher) HasSynced() bool {
    	return c.queue.HasSynced()
    }
    
    // Run starts the controller. This must be called.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 25 14:44:17 UTC 2024
    - 5.7K bytes
    - Viewed (0)
Back to top