- Sort Score
- Num 10 results
- Language All
Results 551 - 560 of 1,207 for func_ (0.02 seconds)
-
cmd/sts-handlers_test.go
etcdStr = " (with etcd backend)" } t.Run( fmt.Sprintf("Test: %d, ServerType: %s%s", i+1, testCase.serverType, etcdStr), func(t *testing.T) { runAllIAMSTSTests(testCase, &check{t, testCase.serverType}) }, ) } } func (s *TestSuiteIAM) TestSTSServiceAccountsWithUsername(c *check) { ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second) defer cancel()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Oct 15 17:00:45 GMT 2025 - 103.4K bytes - Click Count (1) -
cmd/erasure-common.go
package cmd import ( "context" "math/rand" "sync" "time" ) func (er erasureObjects) getOnlineDisks() (newDisks []StorageAPI) { disks := er.getDisks() var wg sync.WaitGroup var mu sync.Mutex r := rand.New(rand.NewSource(time.Now().UnixNano())) for _, i := range r.Perm(len(disks)) { wg.Add(1) go func() { defer wg.Done() if disks[i] == nil { return }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 2.3K bytes - Click Count (0) -
internal/s3select/json/args.go
type ReaderArgs struct { ContentType string `xml:"Type"` unmarshaled bool } // IsEmpty - returns whether reader args is empty or not. func (args *ReaderArgs) IsEmpty() bool { return !args.unmarshaled } // UnmarshalXML - decodes XML data. func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error { // Make subtype to avoid recursive UnmarshalXML(). type subReaderArgs ReaderArgsCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 2.7K bytes - Click Count (0) -
tests/update_test.go
sort.Slice(result.Pets, func(i, j int) bool { return result.Pets[i].ID < result.Pets[j].ID }) sort.Slice(result.Team, func(i, j int) bool { return result.Team[i].ID < result.Team[j].ID }) sort.Slice(result.Friends, func(i, j int) bool { return result.Friends[i].ID < result.Friends[j].ID }) sort.Slice(result2.Pets, func(i, j int) bool { return result2.Pets[i].ID < result2.Pets[j].ID
Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Mon Jul 21 02:46:58 GMT 2025 - 30.4K bytes - Click Count (0) -
cmd/metacache_test.go
prefix: "prefix/prefix2/", want: "prefix/prefix2/", }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { if got := baseDirFromPrefix(tt.prefix); got != tt.want { t.Errorf("baseDirFromPrefix() = %v, want %v", got, tt.want) } }) } } func Test_metacache_finished(t *testing.T) {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Sep 08 18:06:45 GMT 2021 - 6.8K bytes - Click Count (0) -
cmd/metacache-stream_test.go
func loadMetacacheSample(t testing.TB) *metacacheReader { b, err := os.ReadFile("testdata/metacache.s2") if err != nil { t.Fatal(err) } return newMetacacheReader(bytes.NewReader(b)) } func loadMetacacheSampleEntries(t testing.TB) metaCacheEntriesSorted { r := loadMetacacheSample(t) defer r.Close()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 15K bytes - Click Count (0) -
cmd/metacache-set.go
dataVersion: metacacheStreamVersion, filter: o.FilterPrefix, } } func (o *listPathOptions) debugf(format string, data ...any) { if serverDebugLog { console.Debugf(format+"\n", data...) } } func (o *listPathOptions) debugln(data ...any) { if serverDebugLog { console.Debugln(data...) } } func (o *listPathOptions) shouldSkip(ctx context.Context, entry metaCacheEntry) (yes bool) {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 30.7K bytes - Click Count (0) -
cmd/endpoint_test.go
} } } func TestCreateEndpoints(t *testing.T) { tempGlobalMinioPort := globalMinioPort defer func() { globalMinioPort = tempGlobalMinioPort }() globalMinioPort = "9000" // Filter ipList by IPs those do not start with '127.'. nonLoopBackIPs := localIP4.FuncMatch(func(ip string, matchString string) bool { return !net.ParseIP(ip).IsLoopback() }, "")
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 18.9K bytes - Click Count (0) -
cmd/update.go
// with RFC3339 (in UTC) - e.g. `2017-09-29T19:16:56Z` func minioVersionToReleaseTime(version string) (releaseTime time.Time, err error) { return time.Parse(time.RFC3339, version) } // releaseTimeToReleaseTag - converts a time to a string formatted as // an official MinIO release tag. // // An official minio release tag looks like: // `RELEASE.2017-09-29T19-16-56Z` func releaseTimeToReleaseTag(releaseTime time.Time) string {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 18.9K bytes - Click Count (0) -
cmd/admin-handlers-idp-config.go
// // POST <admin-prefix>/idp-cfg/openid/_ -> update (default) named config `_` func (a adminAPIHandlers) UpdateIdentityProviderCfg(w http.ResponseWriter, r *http.Request) { ctx := r.Context() addOrUpdateIDPHandler(ctx, w, r, true) } // ListIdentityProviderCfg: // // GET <admin-prefix>/idp-cfg/openid -> lists openid provider configs. func (a adminAPIHandlers) ListIdentityProviderCfg(w http.ResponseWriter, r *http.Request) {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 12.7K bytes - Click Count (0)