- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 25 for apirequest (0.28 sec)
-
pkg/kubelet/kuberuntime/kuberuntime_container_linux.go
// set linux container resources var cpuRequest *resource.Quantity if _, cpuRequestExists := container.Resources.Requests[v1.ResourceCPU]; cpuRequestExists { cpuRequest = container.Resources.Requests.Cpu() } lcr := m.calculateLinuxResources(cpuRequest, container.Resources.Limits.Cpu(), container.Resources.Limits.Memory())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 17.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/RoleQueryHelper.java
} return roleSet; } protected boolean processAccessToken(final HttpServletRequest request, final Set<String> roleSet, final boolean isApiRequest) { if (isApiRequest) { return ComponentUtil.getComponent(AccessTokenService.class).getPermissions(request).map(p -> { p.forEach(roleSet::add); return true;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 11.5K bytes - Viewed (0) -
cluster/gce/manifests/kube-proxy.manifest
containers: - name: kube-proxy image: {{pillar['kube_docker_registry']}}/kube-proxy-{{pillar['host_arch']}}:{{pillar['kube-proxy_docker_tag']}} resources: requests: cpu: {{ cpurequest }} memory: {{ memoryrequest }} command: - /bin/sh - -c - exec kube-proxy {{api_servers_with_port}} {{kubeconfig}} {{cluster_cidr}} --oom-score-adj=-998 {{params}} 1>>/var/log/kube-proxy.log 2>&1
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 11:08:30 UTC 2024 - 2.2K bytes - Viewed (0) -
cluster/gce/manifests/cloud-controller-manager.manifest
"hostNetwork": true, "containers":[ { "name": "cloud-controller-manager", "image": "gcr.io/k8s-staging-cloud-provider-gcp/cloud-controller-manager:v30.0.0", "resources": { "requests": { "cpu": "{{cpurequest}}" } }, "args": [ "--log-file=/var/log/cloud-controller-manager.log", "--also-stdout=false", "--redirect-stderr=true", "/cloud-controller-manager", {{params}}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 08:50:12 UTC 2024 - 4K bytes - Viewed (0) -
pkg/istio-agent/tap_proxy.go
timeout := time.Second * 15 req, err := downstream.Recv() if err != nil { log.Errorf("failed to recv: %v", err) return err } if strings.HasPrefix(req.TypeUrl, TypeDebugPrefix) { if resp, err := p.xdsProxy.tapRequest(req, timeout); err == nil { err := downstream.Send(resp) if err != nil { log.Errorf("failed to send: %v", err) return err } } else { log.Errorf("failed to call tap request: %v", err)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 1.9K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager.go
} if kubeContainerStatus.Resources.CPULimit != nil { currentCPULimit = kubeContainerStatus.Resources.CPULimit.MilliValue() } if kubeContainerStatus.Resources.CPURequest != nil { currentCPURequest = kubeContainerStatus.Resources.CPURequest.MilliValue() } } // Note: cgroup doesn't support memory request today, so we don't compare that. If canAdmitPod called during
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 02:01:31 UTC 2024 - 64.7K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy.go
Cert: cert, ServerAddress: agent.proxyConfig.DiscoveryAddress, SAN: p.istiodSAN, }, nil } // tapRequest() sends "req" to Istiod, and returns a matching response, or `nil` on timeout. // Requests are serialized -- only one may be in-flight at a time. func (p *XdsProxy) tapRequest(req *discovery.DiscoveryRequest, timeout time.Duration) (*discovery.DiscoveryResponse, error) { p.connectedMutex.Lock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 27.9K bytes - Viewed (0) -
internal/grid/muxclient.go
func (m *muxClient) roundtrip(h HandlerID, req []byte) ([]byte, error) { if m.init { return nil, errors.New("mux client already used") } m.init = true m.singleResp = true msg := message{ Op: OpRequest, MuxID: m.MuxID, Handler: h, Flags: m.BaseFlags | FlagEOF, Payload: req, DeadlineMS: uint32(m.deadline.Milliseconds()), } if m.subroute != nil { msg.Flags |= FlagSubroute }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager_test.go
cpuRequest: tc.apiSpecResources[idx].Requests.Cpu().MilliValue(), }, currentContainerResources: &containerResources{ memoryLimit: tc.apiStatusResources[idx].Limits.Memory().Value(), memoryRequest: tc.apiStatusResources[idx].Requests.Memory().Value(), cpuLimit: tc.apiStatusResources[idx].Limits.Cpu().MilliValue(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 96K bytes - Viewed (0) -
pkg/kubelet/container/runtime.go
TimeStamp time.Time } // ContainerResources represents the Resources allocated to the running container. type ContainerResources struct { // CPU capacity reserved for the container CPURequest *resource.Quantity // CPU limit enforced on the container CPULimit *resource.Quantity // Memory capaacity reserved for the container MemoryRequest *resource.Quantity // Memory limit enforced on the container
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 27.8K bytes - Viewed (0)