- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 212 for newReader (0.07 sec)
-
internal/bucket/object/lock/lock.go
buf, err := io.ReadAll(io.LimitReader(reader, maxObjectLockConfigSize)) if err != nil { return nil, err } hold = &ObjectLegalHold{} if err = xml.NewDecoder(bytes.NewReader(buf)).Decode(hold); err != nil { return nil, err } if !hold.Status.Valid() { return nil, ErrMalformedXML } return }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Jun 29 01:20:27 UTC 2024 - 17.1K bytes - Viewed (0) -
istioctl/pkg/validate/validate.go
} func (v *validator) validateFile(path string, istioNamespace *string, defaultNamespace string, reader io.Reader, writer io.Writer, ) (validation.Warning, error) { yamlReader := kubeyaml.NewYAMLReader(bufio.NewReader(reader)) var errs error var warnings validation.Warning for { doc, err := yamlReader.Read() if err == io.EOF { return warnings, errs } if err != nil {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Aug 15 22:27:47 UTC 2024 - 14.3K bytes - Viewed (0) -
cmd/iam.go
if ptok && spok && pt == embeddedPolicyType { policyBytes, err := base64.StdEncoding.DecodeString(sp) if err != nil { return UserIdentity{}, nil, err } embeddedPolicy, err = policy.ParseConfig(bytes.NewReader(policyBytes)) if err != nil { return UserIdentity{}, nil, err } } return sa, embeddedPolicy, nil }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 29 16:01:48 UTC 2024 - 74.6K bytes - Viewed (0) -
cmd/metacache-set.go
if len(b.data) == 0 && b.n == 0 && o.Transient { return nil } o.debugln(color.Green("saveMetaCacheStream:")+" saving block", b.n, "to", o.objectPath(b.n)) r, err := hash.NewReader(ctx, bytes.NewReader(b.data), int64(len(b.data)), "", "", int64(len(b.data))) bugLogIf(ctx, err) custom := b.headerKV() _, err = er.putMetacacheObject(ctx, o.objectPath(b.n), NewPutObjReader(r), ObjectOptions{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 30.7K bytes - Viewed (0) -
src/archive/tar/reader.go
// ensure that this error is sticky. err error } type fileReader interface { io.Reader fileState WriteTo(io.Writer) (int64, error) } // NewReader creates a new [Reader] reading from r. func NewReader(r io.Reader) *Reader { return &Reader{r: r, curr: ®FileReader{r, 0}} } // Next advances to the next entry in the tar archive.
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Mar 08 01:59:14 UTC 2024 - 26.8K bytes - Viewed (0) -
internal/logger/target/http/http.go
h.status.Store(statusOnline) } }() ctx, cancel := context.WithTimeout(ctx, timeout) defer cancel() req, err := http.NewRequestWithContext(ctx, http.MethodPost, h.Endpoint(), bytes.NewReader(payload)) if err != nil { return fmt.Errorf("invalid configuration for '%s'; %v", h.Endpoint(), err) } if payloadType != "" { req.Header.Set(xhttp.ContentType, payloadType) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 11 22:20:42 UTC 2024 - 15.6K bytes - Viewed (0) -
cmd/s3-zip-handlers.go
return } defer gr.Close() rc, err = file.Open(gr) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } } else { rc = io.NopCloser(bytes.NewReader([]byte{})) } defer rc.Close() if err = setObjectHeaders(ctx, w, fileObjInfo, nil, opts); err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 15.8K bytes - Viewed (0) -
internal/rest/client.go
if body != nil { switch v := body.(type) { case *bytes.Buffer: req.ContentLength = int64(v.Len()) buf := v.Bytes() req.GetBody = func() (io.ReadCloser, error) { r := bytes.NewReader(buf) return io.NopCloser(r), nil } case *bytes.Reader: req.ContentLength = int64(v.Len()) snapshot := *v req.GetBody = func() (io.ReadCloser, error) { r := snapshot
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 26 12:55:01 UTC 2024 - 14.7K bytes - Viewed (0) -
cmd/metacache-stream_test.go
func loadMetacacheSample(t testing.TB) *metacacheReader { b, err := os.ReadFile("testdata/metacache.s2") if err != nil { t.Fatal(err) } return newMetacacheReader(bytes.NewReader(b)) } func loadMetacacheSampleEntries(t testing.TB) metaCacheEntriesSorted { r := loadMetacacheSample(t) defer r.Close() entries, err := r.readN(-1, false, true, false, "") if err != io.EOF { t.Fatal(err)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 15K bytes - Viewed (0) -
istioctl/pkg/tag/tag.go
sa := local.NewSourceAnalyzer(analysis.Combine("webhook", &webhook.Analyzer{}), "", resource.Namespace(istioNamespace), nil) if err := sa.AddReaderKubeSource([]local.ReaderSource{{Name: "", Reader: strings.NewReader(wh)}}); err != nil { return err } k, err := kube.NewClient(kube.NewClientConfigForRestConfig(config), "") if err != nil { return err } sa.AddRunningKubeSourceWithRevision(k, revision, false)
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Jul 22 15:40:30 UTC 2024 - 16.5K bytes - Viewed (0)