Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1051 - 1060 of 1,178 for rsync (0.05 sec)

  1. cmd/config-current.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"bytes"
    	"context"
    	"errors"
    	"fmt"
    	"strings"
    	"sync"
    
    	"github.com/minio/kms-go/kes"
    	"github.com/minio/minio/internal/auth"
    	"github.com/minio/minio/internal/config/browser"
    	"github.com/minio/minio/internal/kms"
    
    	"github.com/minio/madmin-go/v3"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 30.1K bytes
    - Viewed (0)
  2. cni/pkg/install/install_test.go

    // See the License for the specific language governing permissions and
    // limitations under the License.
    
    package install
    
    import (
    	"context"
    	"os"
    	"path/filepath"
    	"sync/atomic"
    	"testing"
    	"time"
    
    	"istio.io/istio/cni/pkg/config"
    	testutils "istio.io/istio/pilot/test/util"
    	"istio.io/istio/pkg/file"
    	"istio.io/istio/pkg/test/util/assert"
    	"istio.io/istio/pkg/util/sets"
    )
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  3. cmd/erasure-object.go

    		Healing:          false,
    	}
    
    	mrfCheck := make(chan FileInfo)
    	defer xioutil.SafeClose(mrfCheck)
    
    	var rw sync.Mutex
    
    	// Ask for all disks first;
    	go func() {
    		ctx, cancel := context.WithCancel(ctx)
    		defer cancel()
    
    		wg := sync.WaitGroup{}
    		for i, disk := range disks {
    			if disk == nil {
    				done <- false
    				continue
    			}
    			if !disk.IsOnline() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  4. statement.go

    package gorm
    
    import (
    	"context"
    	"database/sql"
    	"database/sql/driver"
    	"fmt"
    	"reflect"
    	"regexp"
    	"sort"
    	"strconv"
    	"strings"
    	"sync"
    
    	"gorm.io/gorm/clause"
    	"gorm.io/gorm/logger"
    	"gorm.io/gorm/schema"
    	"gorm.io/gorm/utils"
    )
    
    // Statement statement
    type Statement struct {
    	*DB
    	TableExpr            *clause.Expr
    	Table                string
    	Model                interface{}
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Jun 24 09:42:59 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  5. cmd/bucket-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 cmd
    
    import (
    	"fmt"
    	"math"
    	"sync/atomic"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    )
    
    //go:generate msgp -file $GOFILE
    
    // ReplicationLatency holds information of bucket operations latency, such us uploads
    type ReplicationLatency struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 11:39:51 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  6. cni/pkg/plugin/sidecar_redirect.go

    	if valErr != nil {
    		return nil, fmt.Errorf("annotation value error for value %s; annotationFound = %t: %v",
    			"includeOutboundPorts", isFound, valErr)
    	}
    	// Add 15090 to sync with non-cni injection template
    	// TODO: Revert below once https://github.com/istio/istio/pull/23037 or its follow up is merged.
    	redir.excludeInboundPorts = strings.TrimSpace(redir.excludeInboundPorts)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

          get() = originalRequest.url.host
    
        val request: Request
          get() = originalRequest
    
        val call: RealCall
          get() = this@RealCall
    
        /**
         * Attempt to enqueue this async call on [executorService]. This will attempt to clean up
         * if the executor has been shut down by reporting the call as failed.
         */
        fun executeOn(executorService: ExecutorService) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/net_test.go

    // See the License for the specific language governing permissions and
    // limitations under the License.
    
    package nodeagent
    
    import (
    	"context"
    	"errors"
    	"net/netip"
    	"runtime"
    	"sync/atomic"
    	"testing"
    	"time"
    
    	corev1 "k8s.io/api/core/v1"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/apimachinery/pkg/types"
    	"k8s.io/apimachinery/pkg/util/intstr"
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jul 25 16:13:38 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  9. cmd/iam.go

    package cmd
    
    import (
    	"bytes"
    	"context"
    	"encoding/base64"
    	"encoding/json"
    	"errors"
    	"fmt"
    	"math/rand"
    	"path"
    	"sort"
    	"strings"
    	"sync"
    	"sync/atomic"
    	"time"
    
    	libldap "github.com/go-ldap/ldap/v3"
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio-go/v7/pkg/set"
    	"github.com/minio/minio/internal/arn"
    	"github.com/minio/minio/internal/auth"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  10. docs/de/docs/advanced/custom-response.md

    /// tip | "Tipp"
    
    Beachten Sie, dass wir, da wir Standard-`open()` verwenden, welches `async` und `await` nicht unterstützt, hier die Pfadoperation mit normalen `def` deklarieren.
    
    ///
    
    ### `FileResponse`
    
    Streamt eine Datei asynchron als Response.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 13.5K bytes
    - Viewed (0)
Back to top