- Sort Score
- Result 10 results
- Languages All
Results 961 - 970 of 1,181 for rsync (0.05 sec)
-
internal/kms/kes.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 kms import ( "context" "errors" "net/http" "sync" "time" "github.com/minio/kms-go/kes" "github.com/minio/madmin-go/v3" ) type kesConn struct { defaultKeyID string client *kes.Client }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Aug 18 06:43:03 UTC 2024 - 7.3K bytes - Viewed (0) -
internal/rest/rpc-stats.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 rest import ( "net/http" "net/http/httptrace" "sync/atomic" "time" ) var globalStats = struct { errs uint64 tcpDialErrs uint64 tcpDialCount uint64 tcpDialTotalDur uint64 tcpTimeForFirstByteTotalDur uint64
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 18:21:34 UTC 2024 - 2.6K bytes - Viewed (0) -
docs/metrics/v3.md
|-----------------------------------------------|-------------------------------------------------------------------------------------------------------|----------| | `minio_notification_current_send_in_progress` | Number of concurrent async Send calls active to all targets. <br><br>Type: counter | `server` |
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Aug 02 22:30:11 UTC 2024 - 45.2K bytes - Viewed (0) -
fastapi/routing.py
original_context: Lifespan[Any], nested_context: Lifespan[Any] ) -> Lifespan[Any]: @asynccontextmanager async def merged_lifespan( app: AppType, ) -> AsyncIterator[Optional[Mapping[str, Any]]]: async with original_context(app) as maybe_original_state: async with nested_context(app) as maybe_nested_state: if maybe_nested_state is None and maybe_original_state is None:
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sat Oct 12 09:44:57 UTC 2024 - 172.1K bytes - Viewed (0) -
docs/em/docs/tutorial/dependencies/sub-dependencies.md
đ§ đ đâ đ đ đ đĒ đ đ¤ đ đ (đ˛ đ đ°) đ đ¨ âŠī¸ âī¸ "đž" đ˛, đ đĒ â đĸ `use_cache=False` đâ âī¸ `Depends`: ```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.3K 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/debugging/s3-verify/main.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 22 15:12:47 UTC 2022 - 8.4K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.4.md
If this happens to you, you can wait at most 10 minutes for the replication controller to start a resync, the extra pods will then be deleted. Or, you can manually trigger a resync by change the replicas in the spec of the replication controller. ### kubectl delete: < v1.4.0 client vs >=v1.4.0 cluster
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Thu Dec 24 02:28:26 UTC 2020 - 133.5K bytes - Viewed (0) -
cmd/format-erasure.go
"encoding/json" "errors" "fmt" "io/fs" "os" "sync" "github.com/dustin/go-humanize" "github.com/minio/minio/internal/color" "github.com/minio/minio/internal/config" "github.com/minio/minio/internal/config/storageclass" xioutil "github.com/minio/minio/internal/ioutil" "github.com/minio/minio/internal/logger" "github.com/minio/pkg/v3/sync/errgroup" ) const ( // Represents Erasure backend.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 23.2K bytes - Viewed (0) -
internal/s3select/jstream/scanner.go
package jstream import ( "io" "sync/atomic" ) const ( chunk = 4095 // ~4k maxUint = ^uint(0) maxInt = int64(maxUint >> 1) nullByte = byte(0) ) type scanner struct { pos int64 // position in reader ipos int64 // internal buffer position ifill int64 // internal buffer fill end int64 buf [chunk + 1]byte // internal buffer (with a lookback size of 1)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 2.5K bytes - Viewed (0)