- Sort Score
- Result 10 results
- Languages All
Results 211 - 220 of 900 for makeAs (0.08 sec)
-
docs/en/docs/tutorial/security/oauth2-jwt.md
Many packages that simplify it a lot have to make many compromises with the data model, database, and available features. And some of these packages that simplify things too much actually have security flaws underneath. --- **FastAPI** doesn't make any compromise with any database, data model or tool.
Registered: Sun Oct 27 07:19:11 UTC 2024 - Last Modified: Sat Oct 26 11:45:10 UTC 2024 - 12.8K bytes - Viewed (0) -
cmd/metrics-v3-types.go
) []prometheus.Metric { metrics := make([]prometheus.Metric, 0, len(m.values)) for metricName, mv := range m.values { desc := m.descriptors[metricName] promDesc := desc.toPromDesc(namePrefix, extraLabels) for _, v := range mv { // labelValues is in the same order as the variable labels in the // descriptor. labelValues := make([]string, 0, len(v.Labels)) for _, k := range desc.VariableLabels {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Jul 30 22:28:46 UTC 2024 - 15.6K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer_test.go
}) testCancel(func() { rb.Write(make([]byte, sz)) rb.WriteByte(0) }) testCancel(func() { rb.Read([]byte{10: 1}) }) testCancel(func() { rb.ReadByte() }) testCancel(func() { rb.Write(make([]byte, sz)) rb.Flush() }) } func TestWriteAfterWriterClose(t *testing.T) { rb := New(100).SetBlocking(true) done := make(chan error) go func() { defer close(done)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 26.8K bytes - Viewed (0) -
cmd/erasure-decode_test.go
} writers := make([]io.Writer, len(disks)) for i, disk := range disks { if disk == nil { continue } writers[i] = newBitrotWriter(disk, "", "testbucket", "object", erasure.ShardFileSize(size), DefaultBitrotAlgorithm, erasure.ShardSize()) } content := make([]byte, size) buffer := make([]byte, blockSizeV2, 2*blockSizeV2)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 21.1K bytes - Viewed (0) -
cmd/xl-storage-format-v2_test.go
func TestUsesDataDir(t *testing.T) { vID := uuid.New() dataDir := uuid.New() transitioned := make(map[string][]byte) transitioned[ReservedMetadataPrefixLower+TransitionStatus] = []byte(lifecycle.TransitionComplete) toBeRestored := make(map[string]string) toBeRestored[xhttp.AmzRestore] = ongoingRestoreObj().String() restored := make(map[string]string)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Mar 08 17:50:48 UTC 2024 - 36.4K bytes - Viewed (0) -
internal/grid/connection_test.go
remote.debugMsg(debugShutdown) remoteServer.Close() localServer.Close() remote.debugMsg(debugWaitForExit) local.debugMsg(debugWaitForExit) }() cleanReqs := make(chan struct{}) gotCall := make(chan struct{}) defer close(cleanReqs) // 1: Block forever h1 := func(payload []byte) ([]byte, *RemoteErr) { gotCall <- struct{}{} <-cleanReqs return nil, nil }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jul 08 21:44:00 UTC 2024 - 5.9K bytes - Viewed (0) -
src/all.bat
reserved. L2::: Use of this source code is governed by a BSD-style L3::: license that can be found in the LICENSE file. L4: L5:@echo off L6: L7:setlocal L8: L9:if exist make.bat goto ok L10:echo all.bat must be run from go\src L11::: cannot exit: would kill parent command interpreter L12:goto end L13::ok L14: L15:call .\make.bat --no-banner --no-local L16:if %GOBUILDFAIL%==1 goto end L17:call .\run.bat --no-rebuild --no-local L18:if %GOBUILDFAIL%==1 goto end L19:"%GOTOOLDIR%/dist" banner ...
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Wed Apr 19 14:36:22 UTC 2023 - 543 bytes - Viewed (0) -
internal/grid/connection.go
} var requests chan []byte var responses chan Response if handler.InCapacity > 0 { requests = make(chan []byte, handler.InCapacity) } if handler.OutCapacity > 0 { responses = make(chan Response, handler.OutCapacity) } else { responses = make(chan Response, 1) } cl, err := c.newMuxClient(ctx) if err != nil { return nil, err }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 46.7K bytes - Viewed (0) -
internal/lsync/lrwmutex_test.go
} } // Borrowed from rwmutex_test.go func doTestParallelReaders(numReaders, gomaxprocs int) { runtime.GOMAXPROCS(gomaxprocs) m := NewLRWMutex() clocked := make(chan bool) cunlock := make(chan bool) cdone := make(chan bool) for i := 0; i < numReaders; i++ { go parallelReader(context.Background(), m, clocked, cunlock, cdone) } // Wait for all parallel RLock()s to succeed.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Mar 05 04:57:35 UTC 2023 - 7.9K bytes - Viewed (0) -
cmd/data-scanner_test.go
globalBucketVersioningSys = &BucketVersioningSys{} es := newExpiryState(context.Background(), objAPI, 0) workers := []chan expiryOp{make(chan expiryOp)} es.workers.Store(&workers) globalExpiryState = es var wg sync.WaitGroup wg.Add(1) expired := make([]ObjectToDelete, 0, 5) go func() { defer wg.Done() workers := globalExpiryState.workers.Load() for t := range (*workers)[0] {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 03 11:18:58 UTC 2024 - 6.9K bytes - Viewed (0)