- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for thereby (0.13 sec)
-
pilot/pkg/model/gateway.go
// When we are using legacy gateway label selection, we should bind to the port as-is if there is // no matching ServiceInstance. return []uint32{number} } // For cases where we are directly referencing a Service, we know that they port *must* be in the Service, // so we have no fallback. If there was no match, the Gateway is a no-op. return ret }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 26K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/example.go
return &examples{ client: c.RESTClient(), ns: namespace, } } // Get takes name of the example, and returns the corresponding example object, and an error if there is any. func (c *examples) Get(ctx context.Context, name string, options metav1.GetOptions) (result *v1.Example, err error) { result = &v1.Example{} err = c.client.Get(). Namespace(c.ns). Resource("examples").
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 10:52:54 UTC 2024 - 8.6K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
go s.receiveDelta(con, ids) // Wait for the proxy to be fully initialized before we start serving traffic. Because // initialization doesn't have dependencies that will block, there is no need to add any timeout // here. Prior to this explicit wait, we were implicitly waiting by receive() not sending to // reqChannel and the connection not being enqueued for pushes to pushChannel until the
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/conversion.go
// If there is an IP, we will set the `loadBalancerIP` type. // While there is no defined standard for this in the API yet, it is tracked in https://github.com/kubernetes-sigs/gateway-api/issues/892. // So far, this mirrors how out of clusters work (address set means to use existing IP, unset means to provision one), // and there has been growing consensus on this model for in cluster deployments. //
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 84.7K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_waypoint.go
weighted := make([]*route.WeightedCluster_ClusterWeight, 0) for _, dst := range in.Route { weight := &wrappers.UInt32Value{Value: uint32(dst.Weight)} if dst.Weight == 0 { // Ignore 0 weighted clusters if there are other clusters in the route. // But if this is the only cluster in the route, then add it as a cluster with weight 100 if len(in.Route) == 1 { weight.Value = uint32(100) } else { continue }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 27.6K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
// If the tool is not installed, or there are no IDs configured, the default mapping is returned. // The default mapping includes the entire IDs range except IDs below 65536. func (kl *Kubelet) getKubeletMappings() (uint32, uint32, error) { // default mappings to return if there is no specific configuration const defaultFirstID = 1 << 16 const defaultLen = 1<<32 - defaultFirstID
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client.go
return "", err } return meta.GetResourceVersion(), nil } // Patch applies only the modifications made in the PatchFunc rather than doing a full replace. Useful to avoid // read-modify-write conflicts when there are many concurrent-writers to the same resource. func (cl *Client) Patch(orig config.Config, patchFn config.PatchFunc) (string, error) { modified, patchType := patchFn(orig.DeepCopy())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0) -
cmd/bucket-handlers.go
bucketReplicationConfig = "replication.xml" xMinIOErrCodeHeader = "x-minio-error-code" xMinIOErrDescHeader = "x-minio-error-desc" postPolicyBucketTagging = "tagging" ) // Check if there are buckets on server without corresponding entry in etcd backend and // make entries. Here is the general flow // - Range over all the available buckets // - Check if a bucket has an entry in etcd backend
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 61.2K bytes - Viewed (0) -
docs/en/docs/release-notes.md
* 🔧 Add FastAPI Trove Classifier for PyPI as now there's one 🤷😁. PR [#4386](https://github.com/tiangolo/fastapi/pull/4386) by [@tiangolo](https://github.com/tiangolo). * ⬆ Upgrade MkDocs Material and configs. PR [#4385](https://github.com/tiangolo/fastapi/pull/4385) by [@tiangolo](https://github.com/tiangolo). ## 0.70.1
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Fri Jun 14 15:07:37 UTC 2024 - 395.4K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
ExitCode: 1, ContainerID: emptyContainerID, }}, }, }, // For terminated container: // * If there is no recent start error record, State should be Terminated, LastTerminationState should be retrieved from // second latest terminated status; // * If there is recent start error record, State should be Waiting, LastTerminationState should be retrieved from latest // terminated status;
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0)