Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 147 for rawbuffer (0.28 sec)

  1. pilot/pkg/networking/util/internal_upstream.go

    		TransportSocket: &core.TransportSocket{
    			Name:       "raw_buffer",
    			ConfigType: &core.TransportSocket_TypedConfig{TypedConfig: protoconv.MessageToAny(&rawbuffer.RawBuffer{})},
    		},
    	})},
    }
    
    var TunnelHostInternalUpstreamTransportSocket = &core.TransportSocket{
    	Name: "internal_upstream",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Sep 22 21:35:52 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  2. src/encoding/csv/reader.go

    func (r *Reader) readLine() ([]byte, error) {
    	line, err := r.r.ReadSlice('\n')
    	if err == bufio.ErrBufferFull {
    		r.rawBuffer = append(r.rawBuffer[:0], line...)
    		for err == bufio.ErrBufferFull {
    			line, err = r.r.ReadSlice('\n')
    			r.rawBuffer = append(r.rawBuffer, line...)
    		}
    		line = r.rawBuffer
    	}
    	readSize := len(line)
    	if readSize > 0 && err == io.EOF {
    		err = nil
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 13 21:32:28 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  3. pilot/pkg/xds/filters/filters.go

    		},
    	}
    	RawBufferTransportSocket = &core.TransportSocket{
    		Name: wellknown.TransportSocketRawBuffer,
    		ConfigType: &core.TransportSocket_TypedConfig{
    			TypedConfig: protoconv.MessageToAny(&rawbuffer.RawBuffer{}),
    		},
    	}
    	Cors = &hcm.HttpFilter{
    		Name: wellknown.CORS,
    		ConfigType: &hcm.HttpFilter_TypedConfig{
    			TypedConfig: protoconv.MessageToAny(&cors.Cors{}),
    		},
    	}
    	Fault = &hcm.HttpFilter{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 09 09:24:25 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  4. pkg/wellknown/wellknown.go

    	// HTTPGRPCAccessLog sink for the HTTP gRPC access log service
    	HTTPGRPCAccessLog = "envoy.access_loggers.http_grpc"
    )
    
    // Transport socket names
    const (
    	// TransportSocket RawBuffer
    	TransportSocketRawBuffer = "envoy.transport_sockets.raw_buffer"
    	// TransportSocketTLS labels the "envoy.transport_sockets.tls" filter.
    	TransportSocketTLS = "envoy.transport_sockets.tls"
    	// TransportSocket Quic
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Sep 11 15:29:30 UTC 2023
    - 4K bytes
    - Viewed (0)
  5. istioctl/pkg/describe/testdata/describe/http_config.json

                    "match": {},
                    "transport_socket": {
                      "name": "envoy.transport_sockets.raw_buffer",
                      "typed_config": {
                        "@type": "type.googleapis.com/envoy.extensions.transport_sockets.raw_buffer.v3.RawBuffer"
                      }
                    }
                  }
                ]
              }
            }
          ]
        },
        {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 13.7K bytes
    - Viewed (0)
  6. istioctl/pkg/proxyconfig/testdata/config_dump.json

                      }
                    ],
                    "transport_socket": {
                      "name": "raw_buffer",
                      "typed_config": {
                        "@type": "type.googleapis.com/envoy.extensions.transport_sockets.raw_buffer.v3.RawBuffer"
                      }
                    }
                  }
                },
                "metadata": {
                  "filter_metadata": {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jan 03 23:08:06 UTC 2024
    - 54.8K bytes
    - Viewed (0)
  7. istioctl/pkg/writer/compare/testdata/configdump_diff.json

                      }
                    ],
                    "transport_socket": {
                      "name": "raw_buffer",
                      "typed_config": {
                        "@type": "type.googleapis.com/envoy.extensions.transport_sockets.raw_buffer.v3.RawBuffer"
                      }
                    }
                  }
                },
                "metadata": {
                  "filter_metadata": {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Mar 12 10:02:09 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  8. istioctl/pkg/writer/compare/testdata/configdump.json

                      }
                    ],
                    "transport_socket": {
                      "name": "raw_buffer",
                      "typed_config": {
                        "@type": "type.googleapis.com/envoy.extensions.transport_sockets.raw_buffer.v3.RawBuffer"
                      }
                    }
                  }
                },
                "metadata": {
                  "filter_metadata": {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Mar 12 10:02:09 UTC 2024
    - 52K bytes
    - Viewed (0)
  9. test/fixedbugs/issue7921.go

    }
    
    func bufferNoEscape2(xs []string) int { // ERROR "xs does not escape$"
    	b := bytes.NewBuffer(make([]byte, 0, 64)) // ERROR "&bytes.Buffer{...} does not escape$" "make\(\[\]byte, 0, 64\) does not escape$" "inlining call to bytes.NewBuffer$"
    	for _, x := range xs {
    		b.WriteString(x)
    	}
    	return b.Len() // ERROR "inlining call to bytes.\(\*Buffer\).Len$"
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Sep 14 19:43:26 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  10. pkg/test/echo/server/forwarder/tcp.go

    		return msgBuilder.String(), err
    	}
    	var resBuffer bytes.Buffer
    	buf := make([]byte, 1024+len(message))
    	for {
    		n, err := conn.Read(buf)
    		if err != nil && err != io.EOF {
    			fwLog.Warnf("TCP read failed (already read %d bytes): %v", len(resBuffer.String()), err)
    			return msgBuilder.String(), err
    		}
    		resBuffer.Write(buf[:n])
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jul 20 19:13:32 UTC 2023
    - 4.9K bytes
    - Viewed (0)
Back to top