Search Options

Results per page
Sort
Preferred Languages
Advance

Results 901 - 910 of 1,178 for rsync (0.02 sec)

  1. cmd/data-scanner_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"encoding/xml"
    	"fmt"
    	"strings"
    	"sync"
    	"testing"
    	"time"
    
    	"github.com/google/uuid"
    	"github.com/minio/minio/internal/bucket/lifecycle"
    	"github.com/minio/minio/internal/bucket/object/lock"
    	"github.com/minio/minio/internal/bucket/versioning"
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 03 11:18:58 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  2. docs/ko/docs/tutorial/background-tasks.md

    **FastAPI** 는 `BackgroundTasks` 개체를 생성하고, 매개 변수로 전달합니다.
    
    ## 작업 함수 생성
    
    백그라운드 작업으로 실행할 함수를 정의합니다.
    
    이것은 단순히 매개변수를 받을 수 있는 표준 함수일 뿐입니다.
    
    **FastAPI**는 이것이 `async def` 함수이든, 일반 `def` 함수이든 내부적으로 이를 올바르게 처리합니다.
    
    이 경우, 아래 작업은 파일에 쓰는 함수입니다. (이메일 보내기 시물레이션)
    
    그리고 이 작업은 `async`와 `await`를 사용하지 않으므로 일반 `def` 함수로 선언합니다.
    
    ```Python hl_lines="6-9"
    {!../../docs_src/background_tasks/tutorial001.py!}
    ```
    
    ## 백그라운드 작업 추가
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  3. .idea/scopes/Gradle_public_API.xml

    <component name="DependencyValidationManager">
        <!-- The source of truth for this pattern is `build-logic/basics/src/main/kotlin/gradlebuild/basics/PublicApi.kt` file, please keep them in sync -->
        <scope name="Gradle public API"
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Thu Jul 18 15:08:47 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  4. .teamcity/src/main/kotlin/configurations/SmokeIdeTests.kt

    class SmokeIdeTests(model: CIBuildModel, stage: Stage) : OsAwareBaseGradleBuildType(os = Os.LINUX, stage = stage, init = {
        id(buildTypeId(model))
        name = "Smoke Ide Tests"
        description = "Tests against IDE sync process"
    
        requirements {
            // These tests are usually heavy and the build time is twice on EC2 agents
            requiresNotEc2Agent()
        }
    
        applyTestDefaults(
            model = model,
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Sep 25 07:23:49 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  5. cmd/peer-s3-server.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"errors"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/pkg/v3/sync/errgroup"
    )
    
    const (
    	peerS3Bucket            = "bucket"
    	peerS3BucketDeleted     = "bucket-deleted"
    	peerS3BucketForceCreate = "force-create"
    	peerS3BucketForceDelete = "force-delete"
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  6. src/cmd/api/api_test.go

    			for _, name := range w.stdPackages {
    				pkg, _ := w.import_(name)
    				w.export(pkg)
    			}
    			w.Features()
    		}
    	}
    }
    
    var warmupCache = sync.OnceFunc(func() {
    	// Warm up the import cache in parallel.
    	var wg sync.WaitGroup
    	for _, context := range contexts {
    		context := context
    		wg.Add(1)
    		go func() {
    			defer wg.Done()
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jan 04 17:31:12 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  7. fastapi/security/oauth2.py

                flows=cast(OAuthFlowsModel, flows), description=description
            )
            self.scheme_name = scheme_name or self.__class__.__name__
            self.auto_error = auto_error
    
        async def __call__(self, request: Request) -> Optional[str]:
            authorization = request.headers.get("Authorization")
            if not authorization:
                if self.auto_error:
                    raise HTTPException(
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Oct 23 18:30:18 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  8. cmd/bucket-metadata-sys.go

    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/policy"
    	"github.com/minio/pkg/v3/sync/errgroup"
    	"golang.org/x/sync/singleflight"
    )
    
    // BucketMetadataSys captures all bucket metadata for a given cluster.
    type BucketMetadataSys struct {
    	objAPI ObjectLayer
    
    	sync.RWMutex
    	initialized bool
    	group       *singleflight.Group
    	metadataMap map[string]BucketMetadata
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  9. cmd/bucket-targets.go

    }
    
    // BucketTargetSys represents bucket targets subsystem
    type BucketTargetSys struct {
    	sync.RWMutex
    	arnRemotesMap map[string]arnTarget
    	targetsMap    map[string][]madmin.BucketTarget
    	hMutex        sync.RWMutex
    	hc            map[string]epHealth
    	hcClient      *madmin.AnonymousClient
    	aMutex        sync.RWMutex
    	arnErrsMap    map[string]arnErrs // map of ARN to error count of failures to get target
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  10. internal/ioutil/append-file_windows.go

    package ioutil
    
    import (
    	"io"
    	"os"
    
    	"github.com/minio/minio/internal/lock"
    )
    
    // AppendFile - appends the file "src" to the file "dst"
    func AppendFile(dst string, src string, osync bool) error {
    	appendFile, err := lock.Open(dst, os.O_WRONLY|os.O_APPEND|os.O_CREATE, 0o666)
    	if err != nil {
    		return err
    	}
    	defer appendFile.Close()
    
    	srcFile, err := lock.Open(src, os.O_RDONLY, 0o666)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 1.2K bytes
    - Viewed (0)
Back to top