Search Options

Results per page
Sort
Preferred Languages
Advance

Results 961 - 970 of 1,181 for rsync (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. docs/debugging/s3-verify/main.go

    package main
    
    import (
    	"bytes"
    	"context"
    	"crypto/sha256"
    	"flag"
    	"fmt"
    	"hash"
    	"io"
    	"log"
    	"net/url"
    	"os"
    	"strings"
    	"sync"
    	"time"
    
    	"github.com/minio/minio-go/v7"
    	"github.com/minio/minio-go/v7/pkg/credentials"
    )
    
    var (
    	sourceEndpoint, sourceAccessKey, sourceSecretKey string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 22 15:12:47 UTC 2022
    - 8.4K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top