- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for fetchSome (0.29 sec)
-
src/cmd/go/internal/modfetch/codehost/git.go
// Both Gerrit and GitHub expose every CL/PR as a named ref, // and we don't want those commits masquerading as being real // pseudo-versions in the main repo. if r.fetchLevel <= fetchSome && ref != "" && hash != "" && !r.local { r.fetchLevel = fetchSome var refspec string if ref == "HEAD" { // Fetch the hash but give it a local name (refs/dummy), // because that triggers the fetch behavior of creating any
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 11 22:10:38 UTC 2024 - 27.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/policies.go
AuthzDerivedPolicies := krt.NewCollection(AuthzPolicies, func(ctx krt.HandlerContext, i *securityclient.AuthorizationPolicy) *model.WorkloadAuthorization { meshCfg := krt.FetchOne(ctx, MeshConfig.AsCollection()) pol := convertAuthorizationPolicy(meshCfg.GetRootNamespace(), i) if pol == nil { return nil } return &model.WorkloadAuthorization{ Authorization: pol,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 16:51:29 UTC 2024 - 5.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/meshconfig.go
cms := []*v1.ConfigMap{} if features.SharedMeshConfig != "" { cms = AppendNonNil(cms, krt.FetchOne(ctx, ConfigMaps, krt.FilterObjectName(types.NamespacedName{Name: features.SharedMeshConfig, Namespace: options.SystemNamespace}))) } cms = AppendNonNil(cms, krt.FetchOne(ctx, ConfigMaps, krt.FilterObjectName(types.NamespacedName{Name: cmName, Namespace: options.SystemNamespace})))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 2.2K bytes - Viewed (0) -
src/main/java/jcifs/smb/DirFileEntryEnumIterator2.java
} return n; } /** * {@inheritDoc} * * @see jcifs.smb.DirFileEntryEnumIteratorBase#fetchMore() */ @SuppressWarnings ( "resource" ) @Override protected boolean fetchMore () throws CIFSException { FileEntry[] results = this.response.getResults(); SmbTreeHandleImpl th = getTreeHandle();
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Dec 20 16:15:08 UTC 2020 - 5.7K bytes - Viewed (0) -
pkg/kube/krt/fetch.go
// limitations under the License. package krt import ( "istio.io/istio/pkg/slices" ) func FetchOne[T any](ctx HandlerContext, c Collection[T], opts ...FetchOption) *T { res := Fetch[T](ctx, c, opts...) switch len(res) { case 0: return nil case 1: return &res[0] default: panic("FetchOne found for more than 1 item") } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 2.6K bytes - Viewed (0) -
src/main/java/jcifs/smb/DirFileEntryEnumIterator1.java
} /** * {@inheritDoc} * * @throws CIFSException * * @see jcifs.smb.DirFileEntryEnumIteratorBase#fetchMore() */ @Override protected boolean fetchMore () throws CIFSException { this.nextRequest.reset(this.response.getResumeKey(), this.response.getLastName()); this.response.reset(); try {
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sat Nov 13 15:13:49 UTC 2021 - 5.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/waypoints.go
// goes from having a waypoint to having no waypoint and then eventually gets a waypoint back return krt.FetchOne[Waypoint](ctx, Waypoints, krt.FilterKey(wp.ResourceName())) } // try fetching the namespace-defined waypoint namespace := ptr.OrEmpty[*v1.Namespace](krt.FetchOne[*v1.Namespace](ctx, Namespaces, krt.FilterKey(o.Namespace)))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:28 UTC 2024 - 11.1K bytes - Viewed (0) -
src/main/java/jcifs/smb/DirFileEntryEnumIteratorBase.java
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 5.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/workloads.go
) krt.TransformationSingle[*networkingclient.WorkloadEntry, model.WorkloadInfo] { return func(ctx krt.HandlerContext, wle *networkingclient.WorkloadEntry) *model.WorkloadInfo { meshCfg := krt.FetchOne(ctx, MeshConfig.AsCollection()) policies := a.buildWorkloadPolicies(ctx, AuthorizationPolicies, PeerAuths, meshCfg, wle.Labels, wle.Namespace) var waypoint *Waypoint
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 16:51:29 UTC 2024 - 20.9K bytes - Viewed (0) -
pilot/pkg/controllers/untaint/nodeuntainter.go
// it means we are ok scheduling pods to it. readyCniNodes := krt.NewCollection(readyCniPods, func(ctx krt.HandlerContext, p v1.Pod) *v1.Node { pnode := krt.FetchOne(ctx, nodes, krt.FilterKey(p.Spec.NodeName)) if pnode == nil { return nil } node := *pnode if !hasTaint(node) { return nil } return node }, krt.WithStop(stop))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 00:50:31 UTC 2024 - 6.9K bytes - Viewed (0)