- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 62 for Writer (0.24 sec)
-
cmd/bitrot.go
br.Close() } } } } // Close all the writers. func closeBitrotWriters(ws []io.Writer) { for _, w := range ws { if w != nil { if bw, ok := w.(io.Closer); ok { bw.Close() } } } } // Returns hash sum for whole-bitrot, nil for streaming-bitrot. func bitrotWriterSum(w io.Writer) []byte { if bw, ok := w.(*wholeBitrotWriter); ok { return bw.Sum(nil) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 7.6K bytes - Viewed (0) -
internal/config/subnet/subnet.go
} var body bytes.Buffer writer := multipart.NewWriter(&body) part, e := writer.CreateFormFile("file", filename) if e != nil { return "", e } if _, e = part.Write(payload); e != nil { return "", e } writer.Close() r, e := http.NewRequest(http.MethodPost, reqURL, &body) if e != nil { return "", e } r.Header.Add("Content-Type", writer.FormDataContentType()) return c.submitPost(r)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 27 16:35:36 GMT 2023 - 2.9K bytes - Viewed (0) -
internal/logger/target/console/console.go
"github.com/minio/pkg/v2/logger/message/log" ) // Target implements loggerTarget to send log // in plain or json format to the standard output. type Target struct { output io.Writer } // Validate - validate if the tty can be written to func (c *Target) Validate() error { return nil } // Endpoint returns the backend endpoint func (c *Target) Endpoint() string { return "" }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 3.9K bytes - Viewed (0) -
internal/ioutil/discard.go
// implementation which is buggy on NUMA systems, we have to use a simpler // io.Writer implementation alone avoids also unnecessary buffer copies, // and as such incurred latencies. var Discard io.Writer = discard{} // discard is /dev/null for Golang. type discard struct{} func (discard) Write(p []byte) (int, error) { return len(p), nil } // DiscardReader discarded reader
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 1.3K bytes - Viewed (0) -
cmd/tier-journal_gen.go
return } // EncodeMsg implements msgp.Encodable func (z jentry) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 3 // write "obj" err = en.Append(0x83, 0xa3, 0x6f, 0x62, 0x6a) if err != nil { return } err = en.WriteString(z.ObjName) if err != nil { err = msgp.WrapError(err, "ObjName") return } // write "vid" err = en.Append(0xa3, 0x76, 0x69, 0x64) if err != nil { return }
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jun 03 21:26:51 GMT 2021 - 6.1K bytes - Viewed (0) -
internal/bucket/replication/datatypes_gen.go
if err != nil { err = msgp.WrapError(err) return } (*z) = StatusType(zb0001) } return } // EncodeMsg implements msgp.Encodable func (z StatusType) EncodeMsg(en *msgp.Writer) (err error) { err = en.WriteString(string(z)) if err != nil { err = msgp.WrapError(err) return } return } // MarshalMsg implements msgp.Marshaler
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 2.3K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor_gen.go
if err != nil { err = msgp.WrapError(err) return } } } return } // EncodeMsg implements msgp.Encodable func (z Details) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 2 // write "LimitInBytesPerSecond" err = en.Append(0x82, 0xb5, 0x4c, 0x69, 0x6d, 0x69, 0x74, 0x49, 0x6e, 0x42, 0x79, 0x74, 0x65, 0x73, 0x50, 0x65, 0x72, 0x53, 0x65, 0x63, 0x6f, 0x6e, 0x64) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 5.4K bytes - Viewed (0) -
docs/debugging/inspect/decrypt-v1.go
package main import ( "encoding/binary" "encoding/hex" "fmt" "hash/crc32" "io" "github.com/secure-io/sio-go" ) func extractInspectV1(keyHex string, r io.Reader, w io.Writer, okMsg string) error { id, err := hex.DecodeString(keyHex[:8]) if err != nil { return err } key, err := hex.DecodeString(keyHex[8:]) if err != nil { return err } // Verify that CRC is ok.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 21:22:47 GMT 2024 - 1.6K bytes - Viewed (0) -
internal/ioutil/wait_pipe.go
import ( "io" "sync" ) // PipeWriter is similar to io.PipeWriter with wait group type PipeWriter struct { *io.PipeWriter once sync.Once done func() } // CloseWithError close with supplied error the writer end. func (w *PipeWriter) CloseWithError(err error) error { err = w.PipeWriter.CloseWithError(err) w.once.Do(func() { w.done() }) return err } // PipeReader is similar to io.PipeReader with wait group
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 27 14:55:36 GMT 2023 - 1.7K bytes - Viewed (0) -
cmd/storage-rest-common_gen.go
} // EncodeMsg implements msgp.Encodable func (z *nsScannerOptions) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 3 // write "id" err = en.Append(0x83, 0xa2, 0x69, 0x64) if err != nil { return } err = en.WriteString(z.DiskID) if err != nil { err = msgp.WrapError(err, "DiskID") return } // write "m" err = en.Append(0xa1, 0x6d) if err != nil { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 7.9K bytes - Viewed (0)