- Sort Score
- Result 10 results
- Languages All
Results 491 - 500 of 1,214 for Func (0.03 sec)
-
cmd/auth-handler_test.go
"net/url" "os" "testing" "time" "github.com/minio/minio/internal/auth" "github.com/minio/pkg/v3/policy" ) type nullReader struct{} func (r *nullReader) Read(b []byte) (int, error) { return len(b), nil } // Test get request auth type. func TestGetRequestAuthType(t *testing.T) { type testCase struct { req *http.Request authT authType }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.4K bytes - Viewed (0) -
cmd/object-lambda-handlers.go
// if the text is unknown. func StatusCode(text string) int { if code, ok := statusTextToCode[text]; ok { return code } return -1 } func fwdHeadersToS3(h http.Header, w http.ResponseWriter) { const trim = "x-amz-fwd-header-" for k, v := range h { if stringsHasPrefixFold(k, trim) { w.Header()[k[len(trim):]] = v } } } func fwdStatusToAPIError(resp *http.Response) *APIError {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 22 07:04:48 UTC 2024 - 10.3K bytes - Viewed (0) -
cmd/site-replication.go
Code: ErrSiteReplicationInvalidRequest, } ) func errSRInvalidRequest(err error) SRError { return SRError{ Cause: err, Code: ErrSiteReplicationInvalidRequest, } } func errSRPeerResp(err error) SRError { return SRError{ Cause: err, Code: ErrSiteReplicationPeerResp, } } func errSRBackendIssue(err error) SRError { return SRError{ Cause: err,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 185.1K bytes - Viewed (0) -
cmd/metacache-bucket.go
} } func (b *bucketMetacache) debugf(format string, data ...interface{}) { if serverDebugLog { console.Debugf(format+"\n", data...) } } // findCache will attempt to find a matching cache for the provided options. // If a cache with the same ID exists already it will be returned. // If none can be found a new is created with the provided ID.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6.6K bytes - Viewed (0) -
internal/event/targetidset_test.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 event import ( "reflect" "testing" ) func TestTargetIDSetClone(t *testing.T) { testCases := []struct { set TargetIDSet targetIDToAdd TargetID }{ {NewTargetIDSet(), TargetID{"1", "webhook"}},
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jun 01 21:59:40 UTC 2021 - 3.9K 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) -
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) -
src/arena/arena_test.go
n int } type T2 [1 << 20]byte // 1MiB func TestSmoke(t *testing.T) { a := arena.NewArena() defer a.Free() tt := arena.New[T1](a) tt.n = 1 ts := arena.MakeSlice[T1](a, 99, 100) if len(ts) != 99 { t.Errorf("Slice() len = %d, want 99", len(ts)) } if cap(ts) != 100 { t.Errorf("Slice() cap = %d, want 100", cap(ts)) } ts[1].n = 42 } func TestSmokeLarge(t *testing.T) { a := arena.NewArena()
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed Oct 12 20:23:36 UTC 2022 - 742 bytes - Viewed (0) -
internal/etag/etag_test.go
}, } func TestDecrypt(t *testing.T) { for i, test := range decryptTests { etag, err := Decrypt(test.Key, test.ETag) if err != nil { t.Fatalf("Test %d: failed to decrypt ETag: %v", i, err) } if !Equal(etag, test.Plaintext) { t.Fatalf("Test %d: got '%v' - want '%v'", i, etag, test.Plaintext) } } } func must(s string) ETag { t, err := Parse(s)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 18 17:00:54 UTC 2023 - 12.6K bytes - Viewed (0) -
cmd/admin-handlers-pools.go
errDecommissionRebalanceAlreadyRunning = errors.New("Decommission cannot be started, rebalance is already in progress") ) func (a adminAPIHandlers) StartDecommission(w http.ResponseWriter, r *http.Request) { ctx := r.Context() objectAPI, _ := validateAdminReq(ctx, w, r, policy.DecommissionAdminAction) if objectAPI == nil { return }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 28 00:22:30 UTC 2024 - 10.9K bytes - Viewed (0)