- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for eres (0.12 sec)
-
internal/logger/targets.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 22:56:14 GMT 2024 - 6.1K bytes - Viewed (0) -
internal/rest/rpc-stats.go
import ( "net/http" "net/http/httptrace" "sync/atomic" "time" ) var globalStats = struct { errs uint64 tcpDialErrs uint64 tcpDialCount uint64 tcpDialTotalDur uint64 }{} // RPCStats holds information about the DHCP/TCP metrics and errors type RPCStats struct { Errs uint64 DialAvgDuration uint64 DialErrs uint64 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 29 16:27:58 GMT 2022 - 2.3K bytes - Viewed (0) -
cmd/naughty-disk_test.go
func (d *naughtyDisk) DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) []error { if err := d.calcError(); err != nil { errs := make([]error, len(versions)) for i := range errs { errs[i] = err } return errs } return d.disk.DeleteVersions(ctx, volume, versions, opts) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/erasure-common.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 4.6K bytes - Viewed (0) -
cmd/post-policy-fan-out.go
} hr, err := hash.NewReaderWithOpts(ctx, bytes.NewReader(fanOutBuf), hopts) if err != nil { errs[idx] = err return } reader := NewPutObjReader(hr) defer func() { if err := reader.Close(); err != nil { errs[idx] = err } if err := hr.Close(); err != nil { errs[idx] = err } }() userDefined := make(map[string]string, len(req.UserMetadata))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 3.5K bytes - Viewed (0) -
internal/grid/msg.go
res = append(res, fmt.Sprintf("Op: %v", m.Op)) } res = append(res, fmt.Sprintf("Flags: %s", m.Flags.String())) if len(m.Payload) != 0 { res = append(res, fmt.Sprintf("Payload: %v", bytesOrLength(m.Payload))) } return "{" + strings.Join(res, ", ") + "}" } func (f Flags) String() string { var res []string if f&FlagCRCxxh3 != 0 { res = append(res, "CRC") } if f&FlagEOF != 0 { res = append(res, "EOF")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 28 19:22:29 GMT 2023 - 7.3K bytes - Viewed (0) -
internal/bucket/replication/rule.go
// Make subtype to avoid recursive UnmarshalXML(). type existingObjectReplication ExistingObjectReplication erep := existingObjectReplication{} if err := dec.DecodeElement(&erep, &start); err != nil { return err } if len(erep.Status) == 0 { erep.Status = Disabled } e.Status = erep.Status return nil } // Rule - a rule for replication configuration. type Rule struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jan 24 23:22:20 GMT 2022 - 8.3K bytes - Viewed (0) -
docs/iam/access-manager-plugin.go
var res Result if accountValue == "minio" { res.Result = true } else { // All other users may not perform any `s3:Put*` operations. res.Result = true if strings.HasPrefix(actionValue, "s3:Put") { res.Result = false } } fmt.Printf("account: %v | action: %v | allowed: %v\n", accountValue, actionValue, res.Result) json.NewEncoder(w).Encode(res) return } func main() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 08 17:15:20 GMT 2024 - 2.7K bytes - Viewed (0) -
internal/handlers/proxy_test.go
} for _, v := range headers { req := &http.Request{ Header: http.Header{ v.key: []string{v.val}, }, } res := GetSourceScheme(req) if res != v.expected { t.Errorf("wrong header for %s: got %s want %s", v.key, res, v.expected) } } } // TestGetSourceIP - check the source ip of a request is parsed correctly. func TestGetSourceIP(t *testing.T) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 22 00:56:55 GMT 2023 - 3.2K bytes - Viewed (0) -
internal/s3select/sql/stringfuncs_contrib_test.go
{"", 999, 999, "", nil}, {"测试abc", 1, 1, "测", nil}, {"测试abc", 5, 5, "c", nil}, } for i, tc := range evalCases { res, err := evalSQLSubstring(tc.s, tc.startIdx, tc.length) if res != tc.resExpected || err != tc.errExpected { t.Errorf("Eval Case %d failed: %v %v", i, res, err) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 1.2K bytes - Viewed (0)