- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 492 for fetches (0.26 sec)
-
pkg/wasm/cache.go
} wasmLog.Debugf("fetching oci image from %s with options: %v", key.downloadURL, imgFetcherOps) fetcher := NewImageFetcher(ctx, imgFetcherOps) binaryFetcher, dChecksum, err = fetcher.PrepareFetch(u.Host + u.Path) if err != nil { wasmRemoteFetchCount.With(resultTag.Value(manifestFailure)).Increment() return nil, fmt.Errorf("could not fetch Wasm OCI image: %v", err) } default:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 13.3K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/ivy/IvyJvmLibraryArtifactResolutionIntegrationTest.groovy
when: module1.ivy.expectGet() then: checkArtifactsResolvedAndCached() } def "fetches missing artifacts for module #condition"() { fixture.requestingSource() .expectSourceArtifactNotFound("my-sources") .prepare() buildFile << """
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 14.2K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/mod/sumdb/client.go
"strings" "sync" "sync/atomic" "golang.org/x/mod/module" "golang.org/x/mod/sumdb/note" "golang.org/x/mod/sumdb/tlog" ) // A ClientOps provides the external operations // (file caching, HTTP fetches, and so on) needed by the [Client]. // The methods must be safe for concurrent use by multiple goroutines. type ClientOps interface { // ReadRemote reads and returns the content served at the given path
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 08 17:50:49 UTC 2024 - 19.1K bytes - Viewed (0) -
cmd/kubeadm/app/util/config/cluster.go
"k8s.io/kubernetes/cmd/kubeadm/app/util/apiclient" "k8s.io/kubernetes/cmd/kubeadm/app/util/config/strict" "k8s.io/kubernetes/cmd/kubeadm/app/util/output" ) // FetchInitConfigurationFromCluster fetches configuration from a ConfigMap in the cluster func FetchInitConfigurationFromCluster(client clientset.Interface, printer output.Printer, logPrefix string, newControlPlane, skipComponentConfigs bool) (*kubeadmapi.InitConfiguration, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 11:04:08 UTC 2024 - 11K bytes - Viewed (0) -
src/cmd/vendor/github.com/google/pprof/internal/driver/config.go
func (cfg *config) fieldPtr(f configField) interface{} { // reflect.ValueOf: converts to reflect.Value // Elem: dereferences cfg to make *cfg // FieldByIndex: fetches the field // Addr: takes address of field // Interface: converts back from reflect.Value to a regular value return reflect.ValueOf(cfg).Elem().FieldByIndex(f.field.Index).Addr().Interface() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 16 15:19:53 UTC 2024 - 10.5K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go
if pvc.Spec.VolumeName == "" { return nil, errors.New("PVC has empty pvc.Spec.VolumeName") } return pvc, nil } // getPVSpec fetches the PV object with the given name from the API server // and returns a volume.Spec representing it. // An error is returned if the call to fetch the PV object fails. func (dswp *desiredStateOfWorldPopulator) getPVSpec( name string, pvcReadOnly bool,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 23.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/filtering.go
pair := topologyPair{key: k, value: v} s.TpPairToMatchNum[pair] += delta s.TpKeyToCriticalPaths[k].update(v, s.TpPairToMatchNum[pair]) } } // getPreFilterState fetches a pre-computed preFilterState. func getPreFilterState(cycleState *framework.CycleState) (*preFilterState, error) { c, err := cycleState.Read(preFilterStateKey) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 10:42:29 UTC 2024 - 12.4K bytes - Viewed (1) -
cluster/images/etcd-version-monitor/etcd-version-monitor.go
}).Set(0) *lastSeenBinaryVersion = version.BinaryVersion return nil } // Periodically fetches etcd version info. func getVersionPeriodically(stopCh <-chan struct{}) { lastSeenBinaryVersion := "" for { if err := getVersion(&lastSeenBinaryVersion); err != nil { klog.Errorf("Failed to fetch etcd version: %v", err) } select { case <-stopCh: return case <-time.After(scrapeTimeout):
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 16 06:50:02 UTC 2023 - 11.5K bytes - Viewed (0) -
pkg/kube/krt/collection_test.go
lblFoo := map[string]string{"app": "foo"} lblBar := map[string]string{"app": "bar"} // Setup a simple collection that fetches the same dependency twice Results := krt.NewCollection(pods, func(ctx krt.HandlerContext, i *corev1.Pod) *Result { foos := krt.Fetch(ctx, configMaps, krt.FilterLabel(lblFoo)) bars := krt.Fetch(ctx, configMaps, krt.FilterLabel(lblBar)) names := slices.Map(foos, func(f *corev1.ConfigMap) string { return f.Name })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 04:22:19 UTC 2024 - 14.6K bytes - Viewed (0) -
pilot/test/xdstest/extract.go
for _, s := range tl.GetCommonTlsContext().GetTlsCertificateSdsSecretConfigs() { resourceNames.Insert(s.GetName()) } } return resourceNames.UnsortedList() } // ExtractSecretResources fetches all referenced SDS resource names from a list of clusters and listeners func ExtractSecretResources(t test.Failer, rs []*anypb.Any) []string { resourceNames := sets.New[string]() for _, r := range rs { switch r.TypeUrl {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 13.9K bytes - Viewed (0)