- Sort Score
- Result 10 results
- Languages All
Results 971 - 980 of 1,178 for rsync (0.04 sec)
-
internal/config/identity/openid/jwt.go
import ( "context" "encoding/json" "errors" "fmt" "io" "net/http" "sync" "time" jwtgo "github.com/golang-jwt/jwt/v4" "github.com/minio/minio/internal/arn" "github.com/minio/minio/internal/auth" xnet "github.com/minio/pkg/v3/net" "github.com/minio/pkg/v3/policy" ) type publicKeys struct { *sync.RWMutex // map of kid to public key pkMap map[string]interface{} }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 02:46:36 UTC 2024 - 8.4K bytes - Viewed (0) -
cmd/erasure-coding.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "bytes" "context" "encoding/hex" "fmt" "os" "reflect" "sync" "github.com/cespare/xxhash/v2" "github.com/klauspost/reedsolomon" "github.com/minio/minio/internal/logger" ) // Erasure - erasure encoding details. type Erasure struct {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jan 31 02:11:45 UTC 2024 - 8.6K bytes - Viewed (0) -
go.sum
golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20210220032951-036812b2e83c/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Nov 06 06:23:25 UTC 2024 - 62.2K bytes - Viewed (0) -
cmd/admin-handlers_test.go
package cmd import ( "bytes" "context" "encoding/json" "fmt" "io" "net/http" "net/http/httptest" "net/url" "sort" "sync" "testing" "time" "github.com/minio/madmin-go/v3" "github.com/minio/minio/internal/auth" "github.com/minio/mux" ) // adminErasureTestBed - encapsulates subsystems that need to be setup for
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 24 10:24:01 UTC 2024 - 13.9K bytes - Viewed (0) -
docs/en/docs/advanced/custom-response.md
```Python hl_lines="2 7 9" {!../../docs_src/custom_response/tutorial006c.py!} ``` ### `StreamingResponse` Takes an async generator or a normal generator/iterator and streams the response body. ```Python hl_lines="2 14" {!../../docs_src/custom_response/tutorial007.py!} ``` #### Using `StreamingResponse` with file-like objects
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 12K bytes - Viewed (0) -
internal/s3select/jstream/scanner_test.go
package jstream import ( "bufio" "bytes" "fmt" "io" "sync/atomic" "testing" ) var ( smallInput = make([]byte, 1024*12) // 12K mediumInput = make([]byte, 1024*1024*12) // 12MB largeInput = make([]byte, 1024*1024*128) // 128MB ) func TestScanner(t *testing.T) { data := []byte("abcdefghijklmnopqrstuvwxyz0123456789") var i int r := bytes.NewReader(data) scanner := newScanner(r)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 3.2K bytes - Viewed (0) -
cmd/os_other.go
remaining-- } } } return entries, nil } func globalSync() { // no-op not sure about plan9/solaris support for syscall support defer globalOSMetrics.time(osMetricSync)() syscall.Sync()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 13 15:14:36 UTC 2023 - 4K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
// See the License for the specific language governing permissions and // limitations under the License. package nodeagent import ( "context" "errors" "fmt" "net/netip" "os" "path/filepath" "sync/atomic" "golang.org/x/sys/unix" corev1 "k8s.io/api/core/v1" "k8s.io/client-go/kubernetes" "k8s.io/client-go/rest" pconstants "istio.io/istio/cni/pkg/constants" "istio.io/istio/cni/pkg/ipset"
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Sep 25 20:54:34 UTC 2024 - 13.4K bytes - Viewed (0) -
docs/zh/docs/tutorial/dependencies/sub-dependencies.md
在高级使用场景中,如果不想使用「缓存」值,而是为需要在同一请求的每一步操作(多次)中都实际调用依赖项,可以把 `Depends` 的参数 `use_cache` 的值设置为 `False` : ```Python hl_lines="1" async def needy_dependency(fresh_value: str = Depends(get_value, use_cache=False)): return {"fresh_value": fresh_value} ``` ## 小结 千万别被本章里这些花里胡哨的词藻吓倒了,其实**依赖注入**系统非常简单。 依赖注入无非是与*路径操作函数*一样的函数罢了。
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 3.2K bytes - Viewed (0) -
docs/uk/docs/tutorial/first-steps.md
У даному випадку це асинхронна функція. --- Ви також можете визначити її як звичайну функцію замість `async def`: ```Python hl_lines="7" {!../../docs_src/first_steps/tutorial003.py!} ``` /// note | "Примітка" Якщо не знаєте в чому різниця, подивіться [Конкурентність: *"Поспішаєш?"*](../async.md#in-a-hurry){.internal-link target=_blank}. /// ### Крок 5: поверніть результат
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 15.6K bytes - Viewed (0)