- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 178 for rawbuffer (0.2 sec)
-
internal/s3select/sql/parser_test.go
} // repr.Println(fex, repr.Indent(" "), repr.OmitEmpty(true)) } } func TestSqlLexer(t *testing.T) { // s := bytes.NewBuffer([]byte("s.['name'].*.[*].abc.[\"abc\"]")) s := bytes.NewBuffer([]byte("S3Object.words.*.id")) // s := bytes.NewBuffer([]byte("COUNT(Id)")) lex, err := sqlLexer.Lex(s) if err != nil { t.Fatal(err) } tokens, err := lexer.ConsumeAll(lex) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 9.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/swagger_doc_generator.go
return jsonTag } // A buffer of lines that will be written. type bufferedLine struct { line string indentation int } type buffer struct { lines []bufferedLine } func newBuffer() *buffer { return &buffer{ lines: make([]bufferedLine, 0), } } func (b *buffer) addLine(line string, indent int) { b.lines = append(b.lines, bufferedLine{line, indent}) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 03 07:33:58 UTC 2017 - 7K bytes - Viewed (0) -
src/test/java/org/codelibs/opensearch/extension/analysis/NGramSynonymTokenizer.java
int readCharFromBuffer() throws IOException { if (readBufferIndex >= readBufferLen) { readBufferLen = input.read(readBuffer); if (readBufferLen == -1) { return -1; } readBufferIndex = 0; } final int c = readBuffer[readBufferIndex++]; nextBlkStart++; return c; } boolean isDelimiter(final int c) {
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 17K bytes - Viewed (0) -
src/cmd/vendor/github.com/google/pprof/internal/binutils/disasm.go
// The symbols to return. var symbols []*plugin.Sym // The current group of symbol names, and the address they are all at. names, start := []string{}, uint64(0) buf := bytes.NewBuffer(syms) for { symAddr, name, err := nextSymbol(buf) if err == io.EOF { // Done. If there was an unfinished group, append it. if len(names) != 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 15 16:39:48 UTC 2023 - 5.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/config.go
if pluginCfg.Configuration != nil { return bytes.NewBuffer(pluginCfg.Configuration.Raw), nil } // there is nothing nested, so we delegate to path if pluginCfg.Path != "" { content, err := os.ReadFile(pluginCfg.Path) if err != nil { klog.Fatalf("Couldn't open admission plugin configuration %s: %#v", pluginCfg.Path, err) return nil, err } return bytes.NewBuffer(content), nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 5.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/framer/framer_test.go
data := []byte{ 0x00, 0x00, 0x00, 0x04, 0x01, 0x02, 0x03, 0x04, 0x00, 0x00, 0x00, 0x03, 0x05, 0x06, 0x07, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, 0x08, } b := bytes.NewBuffer(data) r := NewLengthDelimitedFrameReader(io.NopCloser(b)) buf := make([]byte, 1) if n, err := r.Read(buf); err != io.ErrShortBuffer && n != 1 && bytes.Equal(buf, []byte{0x01}) { t.Fatalf("unexpected: %v %d %v", err, n, buf)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 13:33:12 UTC 2024 - 6.3K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/genericclioptions/template_flags_test.go
t.Errorf("expecting error %q, got %v", tc.expectedError, err) } return } if err != nil { t.Fatalf("unexpected error: %v", err) } out := bytes.NewBuffer([]byte{}) err = p.PrintObj(testObject, out) if err != nil { t.Errorf("unexpected error: %v", err) } if len(out.String()) != len(tc.expectedOutput) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 02 09:47:52 UTC 2023 - 5.9K bytes - Viewed (0) -
istioctl/pkg/authz/testdata/configdump.yaml
"address": "0.0.0.0", "port_value": 9080 } }, "filter_chains": [ { "filter_chain_match": { "transport_protocol": "raw_buffer", "application_protocols": [ "http/1.1", "h2c" ] }, "filters": [ {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 21 14:20:23 UTC 2023 - 206.7K bytes - Viewed (1) -
src/encoding/gob/example_encdec_test.go
return b.Bytes(), nil } // UnmarshalBinary modifies the receiver so it must take a pointer receiver. func (v *Vector) UnmarshalBinary(data []byte) error { // A simple encoding: plain text. b := bytes.NewBuffer(data) _, err := fmt.Fscanln(b, &v.x, &v.y, &v.z) return err } // This example transmits a value that implements the custom encoding and decoding methods. func Example_encodeDecode() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 08 04:08:51 UTC 2014 - 1.5K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/inet/SocketConnection.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 11.8K bytes - Viewed (0)