- Sort Score
- Result 10 results
- Languages All
Results 561 - 570 of 1,423 for Func (0.05 sec)
-
internal/grid/grid_test.go
} // local to remote, unbuffered t.Run("unbuffered", func(t *testing.T) { testHandler(t, handlerTest, false) }) t.Run("buffered", func(t *testing.T) { testHandler(t, handlerTest2, false) }) t.Run("buffered", func(t *testing.T) { testHandler(t, handlerTest2, true) }) } // testStreamDeadline will test if server func testStreamDeadline(t *testing.T, local, remote *Manager) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 36.4K bytes - Viewed (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) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 12.7K bytes - Viewed (0) -
api/go1.3.txt
pkg sync, type Pool struct pkg sync, type Pool struct, New func() interface{} pkg syscall (darwin-386), func FcntlFlock(uintptr, int, *Flock_t) error pkg syscall (darwin-386), func Mlock([]uint8) error pkg syscall (darwin-386), func Mlockall(int) error pkg syscall (darwin-386), func Mprotect([]uint8, int) error pkg syscall (darwin-386), func Munlock([]uint8) error pkg syscall (darwin-386), func Munlockall() error
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Jun 02 02:45:00 UTC 2014 - 117K bytes - Viewed (0) -
internal/s3select/select_benchmark_test.go
return buf.Bytes() } type nullResponseWriter struct{} func (w *nullResponseWriter) Header() http.Header { return nil } func (w *nullResponseWriter) Write(p []byte) (int, error) { return len(p), nil } func (w *nullResponseWriter) WriteHeader(statusCode int) { } func (w *nullResponseWriter) Flush() { } func benchmarkSelect(b *testing.B, count int, query string) { requestXML := []byte(`
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Apr 14 13:54:47 UTC 2022 - 5K bytes - Viewed (0) -
cmd/xl-storage-format-v1.go
// format version and erasure coding information. func (m *xlMetaV1Object) valid() bool { return isXLMetaFormatValid(m.Version, m.Format) && isXLMetaErasureInfoValid(m.Erasure.DataBlocks, m.Erasure.ParityBlocks) } // Verifies if the backend format metadata is sane by validating // the version string and format style. func isXLMetaFormatValid(version, format string) bool { return ((version == xlMetaVersion101 ||
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 15:30:50 UTC 2024 - 8.4K bytes - Viewed (0) -
cni/pkg/iptables/iptables_unspecified.go
package iptables import ( "errors" ) func AddInpodMarkIPRule(cfg *Config) error { return errors.New("not implemented on this platform") } func DelInpodMarkIPRule(cfg *Config) error { return errors.New("not implemented on this platform") } func AddLoopbackRoutes(cfg *Config) error { return errors.New("not implemented on this platform") } func DelLoopbackRoutes(cfg *Config) error {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 1K bytes - Viewed (0) -
cmd/endpoint_contrib_test.go
*/ package cmd import ( "testing" "github.com/minio/minio-go/v7/pkg/set" ) func TestUpdateDomainIPs(t *testing.T) { tempGlobalMinioPort := globalMinioPort defer func() { globalMinioPort = tempGlobalMinioPort }() globalMinioPort = "9000" tempGlobalDomainIPs := globalDomainIPs defer func() { globalDomainIPs = tempGlobalDomainIPs }() ipv4TestCases := []struct {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Apr 30 15:50:39 UTC 2021 - 2.2K bytes - Viewed (0) -
internal/disk/directio_darwin.go
const ODirectPlatform = true // OpenFileDirectIO - bypass kernel cache. func OpenFileDirectIO(filePath string, flag int, perm os.FileMode) (*os.File, error) { return directio.OpenFile(filePath, flag, perm) } // DisableDirectIO - disables directio mode. func DisableDirectIO(f *os.File) error { fd := f.Fd() _, err := unix.FcntlInt(fd, unix.F_NOCACHE, 0) return err }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Jun 17 14:31:36 UTC 2023 - 1.4K bytes - Viewed (0) -
cmd/xl-storage_windows_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "bytes" "context" "fmt" "testing" ) // Test if various paths work as expected when converted to UNC form func TestUNCPaths(t *testing.T) { testCases := []struct { objName string pass bool }{ {"/abcdef", true}, {"/a/b/c/d/e/f/g", true}, {string(bytes.Repeat([]byte("界"), 85)), true},
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Nov 29 06:35:16 UTC 2023 - 2.8K bytes - Viewed (0) -
cmd/bucket-lifecycle_test.go
import ( "bytes" "net/http" "testing" "time" "github.com/minio/minio/internal/bucket/lifecycle" xhttp "github.com/minio/minio/internal/http" ) // TestParseRestoreObjStatus tests parseRestoreObjStatus func TestParseRestoreObjStatus(t *testing.T) { testCases := []struct { restoreHdr string expectedStatus restoreObjStatus expectedErr error }{ { // valid: represents a restored object, 'pending' expiry.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 31 09:57:57 UTC 2022 - 7K bytes - Viewed (0)