- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 132 for Writer (0.21 sec)
-
cmd/batch-rotate_gen.go
// EncodeMsg implements msgp.Encodable func (z BatchJobKeyRotateEncryption) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 3 // write "Type" err = en.Append(0x83, 0xa4, 0x54, 0x79, 0x70, 0x65) if err != nil { return } err = en.WriteString(string(z.Type)) if err != nil { err = msgp.WrapError(err, "Type") return } // write "Key" err = en.Append(0xa3, 0x4b, 0x65, 0x79) if err != nil { return }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Dec 02 10:51:33 GMT 2023 - 27.1K bytes - Viewed (0) -
cmd/lock-rest-server-common_test.go
defer os.RemoveAll(testPath) lockRequesterInfo1 := lockRequesterInfo{ Owner: "owner", Writer: true, UID: "0123-4567", Timestamp: UTCNow(), TimeLastRefresh: UTCNow(), } lockRequesterInfo2 := lockRequesterInfo{ Owner: "owner", Writer: true, UID: "89ab-cdef", Timestamp: UTCNow(), TimeLastRefresh: UTCNow(), }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Mar 23 17:26:21 GMT 2023 - 3.1K bytes - Viewed (0) -
cmd/batch-expire_gen.go
func (z *BatchJobExpire) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 6 // write "APIVersion" err = en.Append(0x86, 0xaa, 0x41, 0x50, 0x49, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e) if err != nil { return } err = en.WriteString(z.APIVersion) if err != nil { err = msgp.WrapError(err, "APIVersion") return } // write "Bucket" err = en.Append(0xa6, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Dec 02 10:51:33 GMT 2023 - 19.8K bytes - Viewed (0) -
cmd/admin-handlers_test.go
Addr: owner, Locks: locksHeld, }) } var exp madmin.LockEntries for _, lri := range lris { lockType := func(lri lockRequesterInfo) string { if lri.Writer { return "WRITE" } return "READ" } exp = append(exp, madmin.LockEntry{ Resource: lri.Name, Type: lockType(lri), ServerList: owners, Owner: lri.Owner,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.8K bytes - Viewed (0) -
internal/s3select/json/args.go
// WriterArgs - represents elements inside <OutputSerialization><JSON/> in request XML. type WriterArgs struct { RecordDelimiter string `xml:"RecordDelimiter"` unmarshaled bool } // IsEmpty - returns whether writer args is empty or not. func (args *WriterArgs) IsEmpty() bool { return !args.unmarshaled } // UnmarshalXML - decodes XML data. func (args *WriterArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 2.7K bytes - Viewed (0) -
cmd/erasure-server-pool-decom_gen.go
// EncodeMsg implements msgp.Encodable func (z *PoolDecommissionInfo) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 16 // write "st" err = en.Append(0xde, 0x0, 0x10, 0xa2, 0x73, 0x74) if err != nil { return } err = en.WriteTime(z.StartTime) if err != nil { err = msgp.WrapError(err, "StartTime") return } // write "ss" err = en.Append(0xa2, 0x73, 0x73) if err != nil { return }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Jul 04 21:02:54 GMT 2022 - 26.7K bytes - Viewed (0) -
cmd/storage-interface.go
DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) // WalkDir will walk a directory on disk and return a metacache stream on wr. WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) error // Metadata operations DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) error
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 4.9K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance_gen.go
func (z rebalanceInfo) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 3 // write "startTs" err = en.Append(0x83, 0xa7, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x73) if err != nil { return } err = en.WriteTime(z.StartTime) if err != nil { err = msgp.WrapError(err, "StartTime") return } // write "stopTs" err = en.Append(0xa6, 0x73, 0x74, 0x6f, 0x70, 0x54, 0x73)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 26.8K bytes - Viewed (0) -
internal/s3select/csv/args.go
QuoteCharacter string `xml:"QuoteCharacter"` QuoteEscapeCharacter string `xml:"QuoteEscapeCharacter"` unmarshaled bool } // IsEmpty - returns whether writer args is empty or not. func (args *WriterArgs) IsEmpty() bool { return !args.unmarshaled } // UnmarshalXML - decodes XML data. func (args *WriterArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 5.4K bytes - Viewed (0) -
internal/grid/grid.go
ctx context.Context } func (w *writerWrapper) Write(p []byte) (n int, err error) { buf := GetByteBufferCap(len(p)) buf = buf[:len(p)] copy(buf, p) select { case w.ch <- buf: return len(p), nil case <-w.ctx.Done(): return 0, context.Cause(w.ctx) } } // WriterToChannel will return an io.Writer that writes to the given channel.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 02 15:56:18 GMT 2024 - 4.8K bytes - Viewed (0)