- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for ekvs (0.42 sec)
-
pkg/kubelet/container/helpers.go
// of env vars. func envVarsToMap(envs []EnvVar) map[string]string { result := map[string]string{} for _, env := range envs { result[env.Name] = env.Value } return result } // v1EnvVarsToMap constructs a map of environment name to value from a slice // of env vars. func v1EnvVarsToMap(envs []v1.EnvVar) map[string]string { result := map[string]string{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.3K bytes - Viewed (0) -
pilot/cmd/pilot-agent/options/agent.go
// Unlike ISTIO_META, where we need JSON and advanced features - this is just for small string headers. func extractXDSHeadersFromEnv(o *istioagent.AgentOptions) { envs := os.Environ() for _, e := range envs { if strings.HasPrefix(e, xdsHeaderPrefix) { parts := strings.SplitN(e, "=", 2) if len(parts) != 2 { continue } o.XDSHeaders[parts[0][len(xdsHeaderPrefix):]] = parts[1] }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 10:02:56 UTC 2024 - 3.4K bytes - Viewed (0) -
cmd/iam-etcd-store.go
err = p.parseJSON(data) if err != nil { return err } m[policy] = p return nil } func (ies *IAMEtcdStore) getPolicyDocKV(ctx context.Context, kvs *mvccpb.KeyValue, m map[string]PolicyDoc) error { data, err := decryptData(kvs.Value, string(kvs.Key)) if err != nil { if err == errConfigNotFound { return errNoSuchPolicy } return err } var p PolicyDoc err = p.parseJSON(data)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 13.6K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
return func(b *containerAllocateResponseBuilder) { b.mounts = mounts } } // withEnvs sets the envs for the containerAllocateResponseBuilder func withEnvs(envs map[string]string) containerAllocateResponseBuilderOption { return func(b *containerAllocateResponseBuilder) { b.envs = envs } } // withCDIDevices sets the cdiDevices for the containerAllocateResponseBuilder
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0) -
pilot/pkg/features/pilot.go
"If disabled, Gateway API gateways will ignore workloadSelector policies, only"+ "applying policies that select the gateway with a targetRef.").Get() // Useful for IPv6-only EKS clusters. See https://aws.github.io/aws-eks-best-practices/networking/ipv6/ why it assigns an additional IPv4 NAT address. // Also see https://github.com/istio/istio/issues/46719 why this flag is required
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 54.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go
if err != nil { t.Fatalf("etcdClient.KV.Get failed: %v", err) } if len(getResp.Kvs) == 0 { t.Fatalf("expecting non empty result on key: %s", key) } decoded, err := runtime.Decode(codec, getResp.Kvs[0].Value[len(defaultTestPrefix):]) if err != nil { t.Fatalf("expecting successful decode of object from %v\n%v", err, string(getResp.Kvs[0].Value)) } obj := decoded.(*example.Pod) if obj.ResourceVersion != "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 26.5K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
if err != nil { return nil, nil, err } opts.Devices = append(opts.Devices, blkVolumes...) envs, err := kl.makeEnvironmentVariables(pod, container, podIP, podIPs) if err != nil { return nil, nil, err } opts.Envs = append(opts.Envs, envs...) // only podIPs is sent to makeMounts, as podIPs is populated even if dual-stack feature flag is not enabled.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_test.go
} func (ls testServiceLister) List(labels.Selector) ([]*v1.Service, error) { return ls.services, nil } type envs []kubecontainer.EnvVar func (e envs) Len() int { return len(e) } func (e envs) Swap(i, j int) { e[i], e[j] = e[j], e[i] } func (e envs) Less(i, j int) bool { return e[i].Name < e[j].Name } func buildService(name, namespace, clusterIP, protocol string, port int) *v1.Service {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0) -
pkg/istio-agent/agent.go
} if credentialSocketExists { log.Info("Credential SDS socket found") } return bootstrap.GetNodeMetaData(bootstrap.MetadataOptions{ ID: a.cfg.ServiceNode, Envs: os.Environ(), Platform: a.cfg.Platform, InstanceIPs: a.cfg.ProxyIPAddresses, StsPort: a.secOpts.STSPort,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 10:02:56 UTC 2024 - 26.7K bytes - Viewed (0)