Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 714 for Contexto (0.19 sec)

  1. cmd/bucket-targets.go

    		return nil
    	}
    	clnt.SetCustomTransport(globalRemoteTargetTransport)
    	return clnt
    }
    
    // heartBeat performs liveness check on remote endpoints.
    func (sys *BucketTargetSys) heartBeat(ctx context.Context) {
    	hcTimer := time.NewTimer(defaultHealthCheckDuration)
    	defer hcTimer.Stop()
    	for {
    		select {
    		case <-hcTimer.C:
    			sys.hMutex.RLock()
    			eps := make([]madmin.ServerProperties, 0, len(sys.hc))
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/app/logic/AccessContextLogic.java

        //                                                                      ==============
        public AccessContext create(final AccessContextResource resource, final UserTypeSupplier userTypeSupplier,
                final UserBeanSupplier userBeanSupplier, final AppTypeSupplier appTypeSupplier) {
            final AccessContext context = new AccessContext();
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  3. cmd/test-utils_test.go

    	globalIAMSys.Init(ctx, obj, globalEtcdClient, 2*time.Second)
    	return obj, fsDirs[0], nil
    }
    
    func prepareErasureSets32(ctx context.Context) (ObjectLayer, []string, error) {
    	return prepareErasure(ctx, 32)
    }
    
    func prepareErasure(ctx context.Context, nDisks int) (ObjectLayer, []string, error) {
    	fsDirs, err := getRandomDisks(nDisks)
    	if err != nil {
    		return nil, nil, err
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  4. scripts/playwright/header_param_models/image01.py

    def run(playwright: Playwright) -> None:
        browser = playwright.chromium.launch(headless=False)
        # Update the viewport manually
        context = browser.new_context(viewport={"width": 960, "height": 1080})
        page = context.new_page()
        page.goto("http://localhost:8000/docs")
        page.get_by_role("button", name="GET /items/ Read Items").click()
        page.get_by_role("button", name="Try it out").click()
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Tue Sep 17 18:54:10 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  5. scripts/playwright/request_form_models/image01.py

    def run(playwright: Playwright) -> None:
        browser = playwright.chromium.launch(headless=False)
        # Update the viewport manually
        context = browser.new_context(viewport={"width": 960, "height": 1080})
        page = context.new_page()
        page.goto("http://localhost:8000/docs")
        page.get_by_role("button", name="POST /login/ Login").click()
        page.get_by_role("button", name="Try it out").click()
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Fri Sep 13 09:14:46 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  6. cmd/xl-storage_windows_test.go

    		t.Fatal(err)
    	}
    
    	// Create volume to use in conjunction with other StorageAPI's file API(s)
    	err = fs.MakeVol(context.Background(), "voldir")
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	for i, test := range testCases {
    		t.Run(fmt.Sprint(i), func(t *testing.T) {
    			err = fs.AppendFile(context.Background(), "voldir", test.objName, []byte("hello"))
    			if err != nil && test.pass {
    				t.Error(err)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Nov 29 06:35:16 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  7. cmd/background-heal-ops.go

    }
    
    func waitForLowHTTPReq() {
    	maxIO, maxWait, _ := globalHealConfig.Clone()
    	waitForLowIO(maxIO, maxWait, currentHTTPIO)
    }
    
    func initBackgroundHealing(ctx context.Context, objAPI ObjectLayer) {
    	bgSeq := newBgHealSequence()
    	// Run the background healer
    	for i := 0; i < globalBackgroundHealRoutine.workers; i++ {
    		go globalBackgroundHealRoutine.AddWorker(ctx, objAPI, bgSeq)
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  8. cmd/warm-backend-s3.go

    	}
    	return r, nil
    }
    
    func (s3 *warmBackendS3) Remove(ctx context.Context, object string, rv remoteVersionID) error {
    	ropts := minio.RemoveObjectOptions{}
    	if rv != "" {
    		ropts.VersionID = string(rv)
    	}
    	err := s3.client.RemoveObject(ctx, s3.Bucket, s3.getDest(object), ropts)
    	return s3.ToObjectError(err, object)
    }
    
    func (s3 *warmBackendS3) InUse(ctx context.Context) (bool, error) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Apr 21 11:43:18 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  9. cmd/erasure-object_test.go

    package cmd
    
    import (
    	"bytes"
    	"context"
    	"crypto/md5"
    	crand "crypto/rand"
    	"errors"
    	"fmt"
    	"io"
    	"os"
    	"path/filepath"
    	"runtime"
    	"strconv"
    	"testing"
    
    	"github.com/dustin/go-humanize"
    	"github.com/minio/minio/internal/config/storageclass"
    )
    
    func TestRepeatPutObjectPart(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  10. cmd/xl-storage.go

    }
    
    func (s *xlStorage) readMetadata(ctx context.Context, itemPath string) ([]byte, error) {
    	return xioutil.WithDeadline[[]byte](ctx, globalDriveConfig.GetMaxTimeout(), func(ctx context.Context) ([]byte, error) {
    		buf, _, err := s.readMetadataWithDMTime(ctx, itemPath)
    		return buf, err
    	})
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (2)
Back to top