- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 70 for Writer (0.65 sec)
-
cmd/metacache-set_gen.go
// EncodeMsg implements msgp.Encodable func (z *listPathOptions) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 19 // write "ID" err = en.Append(0xde, 0x0, 0x13, 0xa2, 0x49, 0x44) if err != nil { return } err = en.WriteString(z.ID) if err != nil { err = msgp.WrapError(err, "ID") return } // write "Bucket" err = en.Append(0xa6, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 20:23:12 GMT 2024 - 13.8K 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) -
cmd/storage-datatypes_gen.go
// EncodeMsg implements msgp.Encodable func (z *CheckPartsHandlerParams) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 4 // write "id" err = en.Append(0x84, 0xa2, 0x69, 0x64) if err != nil { return } err = en.WriteString(z.DiskID) if err != nil { err = msgp.WrapError(err, "DiskID") return } // write "v" err = en.Append(0xa1, 0x76) if err != nil { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 127.5K 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) -
cmd/object-api-datatypes.go
// User-Defined object tags UserTags string // List of individual parts, maximum size of upto 10,000 Parts []ObjectPartInfo `json:"-"` // Implements writer and reader used by CopyObject API Writer io.WriteCloser `json:"-" msg:"-"` Reader *hash.Reader `json:"-" msg:"-"` PutObjReader *PutObjReader `json:"-" msg:"-"` metadataOnly bool
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 20.8K bytes - Viewed (0) -
cmd/tier-last-day-stats_gen.go
func (z DailyAllTierStats) EncodeMsg(en *msgp.Writer) (err error) { err = en.WriteMapHeader(uint32(len(z))) if err != nil { err = msgp.WrapError(err) return } for zb0007, zb0008 := range z { err = en.WriteString(zb0007) if err != nil { err = msgp.WrapError(err) return } // map header, size 2 // write "Bins" err = en.Append(0x82, 0xa4, 0x42, 0x69, 0x6e, 0x73)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/consolelogger.go
nodeName string logBuf *ring.Ring } // NewConsoleLogger - creates new HTTPConsoleLoggerSys with all nodes subscribed to // the console logging pub sub system func NewConsoleLogger(ctx context.Context, w io.Writer) *HTTPConsoleLoggerSys { return &HTTPConsoleLoggerSys{ pubsub: pubsub.New[log.Info, madmin.LogMask](8), console: console.New(w), logBuf: ring.New(defaultLogBufferCount), } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.5K bytes - Viewed (0) -
internal/rest/client.go
MaxErrResponseSize int64 // Avoid metrics update if set to true NoMetrics bool // TraceOutput will print debug information on non-200 calls if set. TraceOutput io.Writer // Debug trace output httpClient *http.Client url *url.URL newAuthToken func(audience string) string sync.RWMutex // mutex for lastErr lastErr error lastErrTime time.Time }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
cmd/object-handlers.go
} setHeadGetRespHeaders(w, r.Form) var iw io.Writer iw = w if buf != nil { iw = io.MultiWriter(w, buf) } statusCodeWritten := false httpWriter := xioutil.WriteOnClose(iw) if rs != nil || opts.PartNumber > 0 { statusCodeWritten = true w.WriteHeader(http.StatusPartialContent) } // Write object content to response body
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
docs/orchestration/docker-compose/docker-compose.yaml
ports: - "9000:9000" - "9001:9001" depends_on: - minio1 - minio2 - minio3 - minio4 ## By default this config uses default local driver, ## For custom volumes replace with volume driver configuration. volumes: data1-1: data1-2: data2-1: data2-2: data3-1: data3-2: data4-1:
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 02:45:52 GMT 2024 - 1.5K bytes - Viewed (1)