- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 61 for proxyEnv (0.13 sec)
-
pkg/istio-agent/agent.go
cfg *AgentOptions secOpts *security.Options envoyOpts envoy.ProxyConfig envoyAgent *envoy.Agent sdsServer SDSService secretCache *cache.SecretManagerClient // Used when proxying envoy xds via istio-agent is enabled. xdsProxy *XdsProxy fileWatcher filewatcher.FileWatcher // local DNS Server that processes DNS requests locally and forwards to upstream DNS if needed.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 10:02:56 UTC 2024 - 26.7K bytes - Viewed (0) -
cmd/handler-utils.go
func proxyRequest(ctx context.Context, w http.ResponseWriter, r *http.Request, ep ProxyEndpoint) (success bool) { success = true // Make sure we remove any existing headers before // proxying the request to another node. for k := range w.Header() { w.Header().Del(k) } f := handlers.NewForwarder(&handlers.Forwarder{ PassHost: true, RoundTripper: ep.Transport,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 15.5K bytes - Viewed (0) -
cmd/bucket-replication-metrics.go
removeObjectTaggingAPI replProxyAPI = "RemoveObjectTagging" headObjectAPI replProxyAPI = "HeadObject" getObjectAPI replProxyAPI = "GetObject" ) // ProxyMetric holds stats for replication proxying type ProxyMetric struct { PutTagTotal uint64 `json:"putTaggingProxyTotal" msg:"ptc"` GetTagTotal uint64 `json:"getTaggingProxyTotal" msg:"gtc"`
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 14.2K bytes - Viewed (0) -
architecture/ambient/ztunnel.md
To make ztunnel more transparent, the original source IP address will be spoofed. Additionally, `splice` will be used to make this proxying more efficient when possible. For traffic in the mesh, things are a bit more complex: 1. If the destination has a waypoint proxy, we must send to it to the waypoint (using HBONE).
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 22:35:16 UTC 2024 - 16.6K bytes - Viewed (0) -
cmd/bucket-replication.go
if rs != nil { h, err := rs.ToHeader() if err != nil { return nil, proxy, err } gopts.Set(xhttp.Range, h) } // Make sure to match ETag when proxying. if err = gopts.SetMatchETag(oi.ETag); err != nil { return nil, proxy, err } c := minio.Core{Client: tgt.Client} obj, _, h, err := c.GetObject(ctx, tgt.Bucket, object, gopts) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy.go
type adsStream interface { Send(*discovery.DiscoveryResponse) error Recv() (*discovery.DiscoveryRequest, error) Context() context.Context } // StreamAggregatedResources is an implementation of XDS API used for proxying between Istiod and Envoy. // Every time envoy makes a fresh connection to the agent, we reestablish a new connection to the upstream xds
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 27.9K bytes - Viewed (0) -
cmd/server-main.go
// DriveOPTimeout: globalDriveConfig.GetOPTimeout, Interface: ctxt.Interface, SendBufSize: ctxt.SendBufSize, RecvBufSize: ctxt.RecvBufSize, } // allow transport to be HTTP/1.1 for proxying. globalProxyEndpoints = GetProxyEndpoints(globalEndpoints) globalInternodeTransport = NewInternodeHTTPTransport(ctxt.MaxIdleConnsPerHost)() globalRemoteTargetTransport = NewRemoteTargetHTTPTransport(false)()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 04 15:12:57 UTC 2024 - 34.5K bytes - Viewed (1) -
pkg/proxy/ipvs/proxier.go
// proxier.kubeServiceAccessSet.activeEntries.Insert(entry.String()) // If we are proxying globally, we need to masquerade in case we cross nodes. // If we are proxying only locally, we can retain the source IP. if valid := proxier.ipsetList[kubeLoadBalancerSet].validateEntry(entry); !valid {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0) -
pkg/kubelet/server/server.go
podUID: types.UID(req.PathParameter("uid")), } } type responder struct{} func (r *responder) Error(w http.ResponseWriter, req *http.Request, err error) { klog.ErrorS(err, "Error while proxying request") http.Error(w, err.Error(), http.StatusInternalServerError) } // proxyStream proxies stream to url. func proxyStream(w http.ResponseWriter, r *http.Request, url *url.URL) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 40.1K bytes - Viewed (0) -
cmd/object-handlers.go
var proxy proxyResult gr, err := getObjectNInfo(ctx, bucket, object, rs, r.Header, opts) if err != nil { var ( reader *GetObjectReader perr error ) // avoid proxying if version is a delete marker if !isErrMethodNotAllowed(err) && !(gr != nil && gr.ObjInfo.DeleteMarker) { proxytgts := getProxyTargets(ctx, bucket, object, opts) if !proxytgts.Empty() {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 124.2K bytes - Viewed (0)