- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 26 for establishKeys (0.39 sec)
-
cmd/kubeadm/app/util/runtime/runtime.go
criSocket: criSocket, } } // SetImpl can be used to set the internal implementation for testing purposes. func (runtime *CRIRuntime) SetImpl(impl impl) { runtime.impl = impl } // Connect establishes a connection with the CRI runtime. func (runtime *CRIRuntime) Connect() error { runtimeService, err := runtime.impl.NewRemoteRuntimeService(runtime.criSocket, defaultTimeout) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 06:33:22 UTC 2024 - 8.4K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/example.go
err = c.client.Get(). Namespace(c.ns). Resource("examples"). VersionedParams(&opts, scheme.ParameterCodec). Timeout(timeout). Do(ctx). Into(result) return } // watchList establishes a watch stream with the server and returns the list of Examples func (c *examples) watchList(ctx context.Context, opts metav1.ListOptions) (result *v1.ExampleList, err error) { var timeout time.Duration
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 10:52:54 UTC 2024 - 8.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1/customresourcedefinition.go
err = c.client.Get(). Resource("customresourcedefinitions"). VersionedParams(&opts, scheme.ParameterCodec). Timeout(timeout). Do(ctx). Into(result) return } // watchList establishes a watch stream with the server and returns the list of CustomResourceDefinitions func (c *customResourceDefinitions) watchList(ctx context.Context, opts metav1.ListOptions) (result *v1.CustomResourceDefinitionList, err error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 10:52:54 UTC 2024 - 12K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1beta1/customresourcedefinition.go
err = c.client.Get(). Resource("customresourcedefinitions"). VersionedParams(&opts, scheme.ParameterCodec). Timeout(timeout). Do(ctx). Into(result) return } // watchList establishes a watch stream with the server and returns the list of CustomResourceDefinitions func (c *customResourceDefinitions) watchList(ctx context.Context, opts v1.ListOptions) (result *v1beta1.CustomResourceDefinitionList, err error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 10:52:54 UTC 2024 - 12.1K bytes - Viewed (0) -
pkg/model/proxy.go
// // This field is intended for use in those scenarios where a user needs to // onboard a workload from a VM without relying on auto-registration. // // At runtime, when a proxy establishes an ADS connection to the istiod, // istiod will treat a non-empty value of this field as an indicator // that proxy corresponds to a VM and must be represented by a WorkloadEntry // with a given name.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 17:18:17 UTC 2024 - 18.7K bytes - Viewed (0) -
src/net/rpc/server.go
typically it will create a network listener and call [Accept] or, for an HTTP listener, [HandleHTTP] and [http.Serve]. A client wishing to use the service establishes a connection and then invokes [NewClient] on the connection. The convenience function [Dial] ([DialHTTP]) performs both steps for a raw network connection (an HTTP connection). The resulting
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 21.6K bytes - Viewed (0) -
src/encoding/json/decode.go
// the additional JSON array elements are discarded. // If the JSON array is smaller than the Go array, // the additional Go array elements are set to zero values. // // To unmarshal a JSON object into a map, Unmarshal first establishes a map to // use. If the map is nil, Unmarshal allocates a new map. Otherwise Unmarshal // reuses the existing map, keeping existing entries. Unmarshal then stores
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 00:18:55 UTC 2024 - 35.3K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world_test.go
verifyVolumeExistsInUnmountedVolumes(t, generatedVolumeName, asw) verifyVolumeDoesntExistInGloballyMountedVolumes(t, generatedVolumeName, asw) } // Calls MarkVolumeAsAttached() once to add volume, specifying a name -- // establishes that the supplied volume name is used to register the volume // rather than the generated one. // Verifies newly added volume exists in GetUnmountedVolumes()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 46.3K bytes - Viewed (0) -
src/cmd/compile/internal/staticinit/sched.go
// MapInitToVar is the inverse of VarToMapInit; it maintains a mapping // from a compiler-generated init function to the map the function is // initializing. var MapInitToVar map[*ir.Func]*ir.Name // recordFuncForVar establishes a mapping between global map var "v" and // outlined init function "fn" (and vice versa); so that we can use // the mappings later on to update relocations. func recordFuncForVar(v *ir.Name, fn *ir.Func) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 17:16:14 UTC 2024 - 30.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go
// those two operations the last old server crashes and // recovers. The chosen solution is making this controller // insist on maintaining the particular state that it // establishes. if !(apiequality.Semantic.DeepEqual(oldFS.Spec, newFS.Spec) && apiequality.Semantic.DeepEqual(oldFS.Status, newFS.Status)) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 48.8K bytes - Viewed (0)