- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 103 for CON (0.14 sec)
-
pkg/config/analysis/analyzers/testdata/pod-con-sec-uid.yaml
apiVersion: v1 kind: Pod metadata: name: con-sec-uid labels: app: helloworld version: v1 spec: containers: - name: helloworld image: docker.io/istio/examples-helloworld-v1 securityContext: runAsUser: 1337 resources: requests: cpu: "100m" imagePullPolicy: IfNotPresent #Always ports:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Nov 17 12:28:05 UTC 2021 - 364 bytes - Viewed (0) -
pkg/config/analysis/analyzers/testdata/deployment-con-sec-uid.yaml
apiVersion: apps/v1 kind: Deployment metadata: name: deploy-con-sec-uid labels: app: helloworld version: v1 spec: replicas: 1 selector: matchLabels: app: helloworld version: v1 template: metadata: labels: app: helloworld version: v1 spec: securityContext: runAsUser: 1337 containers: - name: helloworld
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Nov 17 12:28:05 UTC 2021 - 651 bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_delta.go
defer log.Debugf("disconnected from delta XDS server: %s", p.istiodAddress) con.upstreamDeltas = deltaUpstream // handle responses from istiod go func() { for { resp, err := con.upstreamDeltas.Recv() if err != nil { upstreamErr(con, err) return } select { case con.deltaResponsesChan <- resp: case <-con.stopChan: } } }() go p.handleUpstreamDeltaRequest(con)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 11.7K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
defer func() { close(con.deltaReqChan) close(con.ErrorCh()) // Close the initialized channel, if its not already closed, to prevent blocking the stream select { case <-con.InitializedCh(): default: close(con.InitializedCh()) } }() firstRequest := true for { req, err := con.deltaStream.Recv() if err != nil { if istiogrpc.IsExpectedGRPCError(err) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
pilot/pkg/xds/pushqueue.go
return nil, nil, true } con = p.queue[0] // The underlying array will still exist, despite the slice changing, so the object may not GC without this // See https://github.com/grpc/grpc-go/issues/4758 p.queue[0] = nil p.queue = p.queue[1:] request = p.pending[con] delete(p.pending, con) // Mark the connection as in progress p.processing[con] = nil return con, request, false }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Sep 16 01:37:15 UTC 2021 - 3.8K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
return s.pushXds(con, &model.WatchedResource{TypeUrl: req.TypeUrl, ResourceNames: req.ResourceNames}, &model.PushRequest{Full: true, Push: con.proxy.LastPushContext}) } if s.StatusReporter != nil { s.StatusReporter.RegisterEvent(con.ID(), req.TypeUrl, req.ResponseNonce) } shouldRespond, delta := xds.ShouldRespond(con.proxy, con.ID(), req) if !shouldRespond { return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
pilot/pkg/xds/debug.go
ClusterSent: con.NonceSent(v3.ClusterType), ClusterAcked: con.NonceAcked(v3.ClusterType), ListenerSent: con.NonceSent(v3.ListenerType), ListenerAcked: con.NonceAcked(v3.ListenerType), RouteSent: con.NonceSent(v3.RouteType), RouteAcked: con.NonceAcked(v3.RouteType), EndpointSent: con.NonceSent(v3.EndpointType),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 39.5K bytes - Viewed (0) -
pkg/xds/server.go
func Receive(ctx ConnectionContext) { con := ctx.XdsConnection() defer func() { close(con.errorChan) close(con.reqChan) // Close the initialized channel, if its not already closed, to prevent blocking the stream. select { case <-con.initialized: default: close(con.initialized) } }() firstRequest := true for { req, err := con.stream.Recv() if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
pilot/pkg/xds/statusgen.go
// isSidecar ad-hoc method to see if connection represents a sidecar func isProxy(con *Connection) bool { return con != nil && con.proxy != nil && con.proxy.Metadata != nil && con.proxy.Metadata.ProxyConfig != nil } func isZtunnel(con *Connection) bool { return con != nil && con.proxy != nil && con.proxy.Metadata != nil && con.proxy.Type == model.Ztunnel }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jan 10 23:30:28 UTC 2024 - 5.6K bytes - Viewed (0) -
pkg/kubelet/stats/cadvisor_stats_provider_test.go
assert.Nil(t, con.UserDefinedMetrics) con = indexCon[cName01] assert.EqualValues(t, testTime(creationTime, seedPod0Container1).Unix(), con.StartTime.Time.Unix()) checkCPUStats(t, "Pod0Container1", seedPod0Container1, con.CPU) checkMemoryStats(t, "Pod0Container1", seedPod0Container1, infos["/pod0-c1"], con.Memory) assert.Nil(t, con.Rootfs) assert.Nil(t, con.Logs) assert.Nil(t, con.Accelerators)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 30.2K bytes - Viewed (0)