- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for GetConfigMap (0.12 sec)
-
pkg/volume/configmap/configmap.go
volume.NewCachedMetrics(volume.NewMetricsDu(getPath(pod.UID, spec.Name(), plugin.host))), }, source: *spec.Volume.ConfigMap, pod: *pod, opts: &opts, getConfigMap: plugin.getConfigMap, }, nil } func (plugin *configMapPlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) { return &configMapVolumeUnmounter{ &configMapVolume{ volName,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 10K bytes - Viewed (0) -
pkg/test/framework/components/istio/configmap.go
} func (ic *injectConfig) InjectConfig() (*inject.Config, error) { ic.mu.Lock() myic := ic.injectConfig ic.mu.Unlock() if myic == nil { c := ic.ctx.AllClusters().Configs()[0] cfgMap, err := ic.getConfigMap(c, ic.configMapName()) if err != nil { return nil, err } // Get the MeshConfig yaml from the config map. icYAML, err := getInjectConfigYaml(cfgMap, "config") if err != nil { return nil, err
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 12.8K bytes - Viewed (0) -
pkg/volume/projected/projected.go
) type projectedPlugin struct { host volume.VolumeHost kvHost volume.KubeletVolumeHost getSecret func(namespace, name string) (*v1.Secret, error) getConfigMap func(namespace, name string) (*v1.ConfigMap, error) getServiceAccountToken func(namespace, name string, tr *authenticationv1.TokenRequest) (*authenticationv1.TokenRequest, error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 12.8K bytes - Viewed (0) -
pkg/kubelet/volume_host.go
} } func (kvh *kubeletVolumeHost) GetConfigMapFunc() func(namespace, name string) (*v1.ConfigMap, error) { if kvh.configMapManager != nil { return kvh.configMapManager.GetConfigMap } return func(namespace, name string) (*v1.ConfigMap, error) { return nil, fmt.Errorf("not supported due to running kubelet in standalone mode") } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 10K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
} } func (expc *expandController) GetConfigMapFunc() func(namespace, name string) (*v1.ConfigMap, error) { return func(_, _ string) (*v1.ConfigMap, error) { return nil, fmt.Errorf("GetConfigMap unsupported in expandController") } } func (expc *expandController) GetAttachedVolumesFromNodeStatus() (map[v1.UniqueVolumeName]string, error) { return map[v1.UniqueVolumeName]string{}, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
} } func (adc *attachDetachController) GetConfigMapFunc() func(namespace, name string) (*v1.ConfigMap, error) { return func(_, _ string) (*v1.ConfigMap, error) { return nil, fmt.Errorf("GetConfigMap unsupported in attachDetachController") } } func (adc *attachDetachController) GetServiceAccountTokenFunc() func(_, _ string, _ *authenticationv1.TokenRequest) (*authenticationv1.TokenRequest, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/volume/projected/projected_test.go
var myVolumeMounter = projectedVolumeMounter{ projectedVolume: &projectedVolume{ sources: source.Sources, podUID: pod.UID, plugin: &projectedPlugin{ host: host, getConfigMap: host.GetConfigMapFunc(), }, }, source: *source, pod: pod, } actualPayload, err := myVolumeMounter.collectData(volume.MounterArgs{}) if err != nil && tc.success {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 40.5K bytes - Viewed (0)