- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 127 for Writer (0.34 sec)
-
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 May 05 19:28:20 GMT 2024 - Last Modified: Mon Jul 04 21:02:54 GMT 2022 - 26.7K bytes - Viewed (0) -
internal/event/target/postgresql.go
"context" "database/sql" "encoding/json" "errors" "fmt" "net/url" "os" "path/filepath" "regexp" "strconv" "strings" "time" "unicode" _ "github.com/lib/pq" // Register postgres driver "github.com/minio/minio/internal/event" "github.com/minio/minio/internal/logger" "github.com/minio/minio/internal/once" "github.com/minio/minio/internal/store" xnet "github.com/minio/pkg/v2/net" )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:51:07 GMT 2024 - 13.3K bytes - Viewed (0) -
cmd/tier.go
config.Lock() defer config.Unlock() var ok bool // Lookup in-memory drivercache d, ok = config.drivercache[tierName] if ok { return d, nil } // Initialize driver from tier config matching tierName t, ok := config.Tiers[tierName] if !ok { return nil, errTierNotFound } d, err = newWarmBackend(ctx, t, false) if err != nil { return nil, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 15.5K 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 May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 15:56:18 GMT 2024 - 4.8K 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 May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 02 10:51:33 GMT 2023 - 19.8K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
h.QueuedBuckets = append(h.QueuedBuckets, b.Name) } } } func (h *healingTracker) printTo(writer io.Writer) { h.mu.RLock() defer h.mu.RUnlock() b, err := json.MarshalIndent(h, "", " ") if err != nil { writer.Write([]byte(err.Error())) return } writer.Write(b) } // toHealingDisk converts the information to madmin.HealingDisk
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.7K 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 May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.8K bytes - Viewed (0) -
internal/dsync/lock-args_gen.go
return } // EncodeMsg implements msgp.Encodable func (z *LockArgs) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 5 // write "UID" err = en.Append(0x85, 0xa3, 0x55, 0x49, 0x44) if err != nil { return } err = en.WriteString(z.UID) if err != nil { err = msgp.WrapError(err, "UID") return } // write "Resources" err = en.Append(0xa9, 0x52, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 9.5K bytes - Viewed (0) -
cmd/bucket-replication-metrics_gen.go
} // EncodeMsg implements msgp.Encodable func (z ActiveWorkerStat) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 3 // write "Curr" err = en.Append(0x83, 0xa4, 0x43, 0x75, 0x72, 0x72) if err != nil { return } err = en.WriteInt(z.Curr) if err != nil { err = msgp.WrapError(err, "Curr") return } // write "Avg" err = en.Append(0xa3, 0x41, 0x76, 0x67) if err != nil { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 33.3K bytes - Viewed (0) -
cmd/erasure-encode_test.go
} writers := make([]io.Writer, len(disks)) for i, disk := range disks { if disk == nil { continue } writers[i] = newBitrotWriter(disk, "", "testbucket", "object2", erasure.ShardFileSize(int64(len(data[test.offset:]))), test.algorithm, erasure.ShardSize()) } for j := range disks[:test.offDisks] { switch w := writers[j].(type) { case *wholeBitrotWriter:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 11.9K bytes - Viewed (0)