- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 65 for Heller (0.19 sec)
-
cmd/admin-handlers-users_test.go
c.Helper() ui, err := admClnt.GetUserInfo(ctx, accessKey) if err != nil { c.Fatalf("should be able to get user info: %v", err) } return ui } func (c *check) mustNotCreateIAMUser(ctx context.Context, admClnt *madmin.AdminClient) { c.Helper() randUser := mustGetUUID() randPass := mustGetUUID()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 12 16:36:16 GMT 2024 - 45.7K bytes - Viewed (0) -
cmd/admin-handlers_test.go
// admin-handler unit tests. type adminErasureTestBed struct { erasureDirs []string objLayer ObjectLayer router *mux.Router done context.CancelFunc } // prepareAdminErasureTestBed - helper function that setups a single-node // Erasure backend for admin-handler tests. func prepareAdminErasureTestBed(ctx context.Context) (*adminErasureTestBed, error) { ctx, cancel := context.WithCancel(ctx)
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/drwmutex.go
noQuorum, err := refreshLock(ctx, dm.clnt, id, source, quorum) if err == nil && noQuorum { // Clean the lock locally and in remote nodes forceUnlock(ctx, dm.clnt, id) // Execute the caller lock loss callback if lockLossCallback != nil { lockLossCallback() } return } refreshTimer.Reset(dm.refreshInterval) } } }() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
src/archive/zip/writer.go
} return nil } // CreateHeader adds a file to the zip archive using the provided [FileHeader] // for the file metadata. [Writer] takes ownership of fh and may mutate // its fields. The caller must not modify fh after calling [Writer.CreateHeader]. // // This returns a [Writer] to which the file contents should be written. // The file's contents must be written to the io.Writer before the next
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Apr 04 14:28:57 GMT 2024 - 19.3K bytes - Viewed (0) -
internal/logger/logger.go
f = strings.TrimPrefix(filepath.ToSlash(f), filepath.ToSlash(trimString)) } return filepath.FromSlash(f) } func getSource(level int) string { pc, file, lineNumber, ok := runtime.Caller(level) if ok { // Clean up the common prefixes file = trimTrace(file) _, funcName := filepath.Split(runtime.FuncForPC(pc).Name()) return fmt.Sprintf("%v:%v:%v()", file, lineNumber, funcName) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/xl-storage-format-v2_test.go
_, err = readXLMetaNoData(bytes.NewReader(buf), int64(len(buf))) if err == nil { t.Fatal("expected error but returned success") } } func TestXLV2FormatData(t *testing.T) { failOnErr := func(err error) { t.Helper() if err != nil { t.Fatal(err) } } data := []byte("some object data") data2 := []byte("some other object data") xl := xlMetaV2{} fi := FileInfo{ Volume: "volume",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 17:50:48 GMT 2024 - 36.4K bytes - Viewed (0) -
internal/etag/etag.go
// In this case, the caller has to decrypt the ETag first // before calling Format. // S3 clients expect that the ETag of an SSE-S3 encrypted // single-part object is equal to the object's content MD5. // Formatting the SSE-S3 ETag before decryption will result // in a random-looking ETag which an S3 client will not accept. // // Hence, a caller has to check: // // if method == SSE-S3 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 13.3K bytes - Viewed (0) -
cmd/signature-v4.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. // Package cmd This file implements helper functions to validate AWS // Signature Version '4' authorization header. // // This package provides comprehensive helpers for following signature // types. // - Based on Authorization header.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 12.3K bytes - Viewed (0) -
cmd/metacache-walk.go
if err != nil { return toStorageErr(err) } return toStorageErr(st.Results(func(in []byte) error { _, err := wr.Write(in) return err })) } // WalkDirHandler - remote caller to list files and folders in a requested directory path. func (s *storageRESTServer) WalkDirHandler(ctx context.Context, payload []byte, _ <-chan []byte, out chan<- []byte) (gerr *grid.RemoteErr) { var opts WalkDirOptions
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K bytes - Viewed (0) -
cni/pkg/install/install.go
return err } } } return nil } // sleepWatchInstall blocks until any file change for the binaries or config are detected. // At that point, the func yields so the caller can recheck the validity of the install. // If an error occurs or context is canceled, the function will return an error. func (in *Installer) sleepWatchInstall(ctx context.Context, installedBinFiles sets.String) error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 10.8K bytes - Viewed (0)