- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for nodeclient (0.19 sec)
-
pkg/volume/csi/csi_client_test.go
client := &csiDriverClient{ driverName: "Fake Driver Name", nodeV1ClientCreator: func(addr csiAddr, m *MetricsManager) (csipbv1.NodeClient, io.Closer, error) { nodeClient := fake.NewNodeClient(false /* stagingCapable */) nodeClient.SetNextError(tc.err) nodeClient.SetNodeGetInfoResp(&csipbv1.NodeGetInfoResponse{ NodeId: tc.expectedNodeID, MaxVolumesPerNode: tc.expectedMaxVolumePerNode,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 33.9K bytes - Viewed (0) -
pkg/volume/csi/fake/fake_client.go
func NewNodeClient(stageUnstageSet bool) *NodeClient { return &NodeClient{ nodePublishedVolumes: make(map[string]CSIVolume), nodeStagedVolumes: make(map[string]CSIVolume), stageUnstageSet: stageUnstageSet, volumeStatsSet: true, } } func NewNodeClientWithExpansion(stageUnstageSet bool, expansionSet bool) *NodeClient { return &NodeClient{ nodePublishedVolumes: make(map[string]CSIVolume),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 14:49:03 UTC 2023 - 16K bytes - Viewed (0) -
pkg/volume/csi/csi_client.go
// This is the default implementation for the nodeV1ClientCreator, used in // newCsiDriverClient. func newV1NodeClient(addr csiAddr, metricsManager *MetricsManager) (nodeClient csipbv1.NodeClient, closer io.Closer, err error) { var conn *grpc.ClientConn conn, err = newGrpcConn(addr, metricsManager) if err != nil { return nil, nil, err } nodeClient = csipbv1.NewNodeClient(conn)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 20 10:15:36 UTC 2022 - 22.1K bytes - Viewed (0) -
pkg/volume/csi/csi_block_test.go
pubs := csiUnmapper.csiClient.(*fakeCsiDriverClient).nodeClient.GetNodePublishedVolumes() if _, ok := pubs[csiUnmapper.volumeID]; ok { t.Error("csi server may not have received NodeUnpublishVolume call") } // ensure csi client call and node unstaged vols := csiUnmapper.csiClient.(*fakeCsiDriverClient).nodeClient.GetNodeStagedVolumes() if _, ok := vols[csiUnmapper.volumeID]; ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 11 06:07:40 UTC 2023 - 26.5K bytes - Viewed (0) -
pkg/volume/csi/nodeinfomanager/nodeinfomanager.go
// existing changes are not overwritten. kubeClient := nim.volumeHost.GetKubeClient() if kubeClient == nil { return fmt.Errorf("error getting kube client") } nodeClient := kubeClient.CoreV1().Nodes() originalNode, err := nodeClient.Get(context.TODO(), string(nim.nodeName), metav1.GetOptions{}) if err != nil { return err } node := originalNode.DeepCopy() needUpdate := false
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 20.1K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/rbac/bootstrappolicy/testdata/cluster-roles.yaml
name: system:certificates.k8s.io:certificatesigningrequests:nodeclient rules: - apiGroups: - certificates.k8s.io resources: - certificatesigningrequests/nodeclient verbs: - create - apiVersion: rbac.authorization.k8s.io/v1 kind: ClusterRole metadata: annotations: rbac.authorization.kubernetes.io/autoupdate: "true" creationTimestamp: null
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 08:11:08 UTC 2023 - 24.1K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/rbac/bootstrappolicy/policy.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 19:25:10 UTC 2024 - 34.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod_test.go
got := c.pods.getPodsByIP("128.0.0.1") assert.Equal(t, got != nil, true) assert.Equal(t, map[string]string{"app": "test", "foo": "bar"}, got[0].Labels) pod.Labels["foo"] = "not-bar" clienttest.Wrap(t, c.podsClient).CreateOrUpdate(pod) fx.StrictMatchOrFail(t, xdsfake.Event{ Type: "proxy", ID: "128.0.0.1", }, xdsfake.Event{ Type: "xds", ID: "ratings.nsa.svc.company.com", })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 18:27:40 UTC 2024 - 12.3K bytes - Viewed (0) -
src/crypto/tls/handshake_client.go
return nil, nil, nil, errors.New("tls: NextProtos values too large") } supportedVersions := config.supportedVersions(roleClient) if len(supportedVersions) == 0 { return nil, nil, nil, errors.New("tls: no supported versions satisfy MinVersion and MaxVersion") } maxVersion := config.maxSupportedVersion(roleClient) hello := &clientHelloMsg{ vers: maxVersion,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 38.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
registerHandlers[*v1.Node](c, c.nodes, "Nodes", c.onNodeEvent, nil) c.podsClient = kclient.NewFiltered[*v1.Pod](kubeClient, kclient.Filter{ ObjectFilter: kubeClient.ObjectFilter(), ObjectTransform: kubelib.StripPodUnusedFields, }) c.pods = newPodCache(c, c.podsClient, func(key types.NamespacedName) { c.queue.Push(func() error { return c.endpoints.podArrived(key.Name, key.Namespace)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0)