Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for initialization (0.22 sec)

  1. cmd/test-utils_test.go

    	resetTestGlobals()
    
    	objLayer, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatalf("Initialization of object layer failed for single node setup: %s", err)
    	}
    
    	bucketFS, fsAPIRouter, err := initAPIHandlerTest(ctx, objLayer, endpoints)
    	if err != nil {
    		t.Fatalf("Initialization of API handler tests failed: <ERROR> %s", err)
    	}
    
    	// initialize the server and obtain the credentials and root.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  2. internal/cachevalue/cache.go

    	// Should be set before calling Get().
    	updateFn func() (T, error)
    
    	// ttl for a cached value.
    	ttl time.Duration
    
    	opts Opts
    
    	// Once can be used to initialize values for lazy initialization.
    	// Should be set before calling Get().
    	Once sync.Once
    
    	// Managed values.
    	valErr atomic.Pointer[struct {
    		v T
    		e error
    	}]
    	lastUpdateMs atomic.Int64
    	updating     sync.Mutex
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  3. cmd/peer-s3-client.go

    func newPeerS3Client(node Node) peerS3Client {
    	var gridConn atomic.Pointer[grid.Connection]
    
    	return &remotePeerS3Client{
    		node: node,
    		gridConn: func() *grid.Connection {
    			// Lazy initialization of grid connection.
    			// When we create this peer client, the grid connection is likely not yet initialized.
    			if node.GridHost == "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.8K bytes
    - Viewed (0)
  4. cmd/iam.go

    }
    
    // Init - initializes config system by reading entries from config/iam
    func (sys *IAMSys) Init(ctx context.Context, objAPI ObjectLayer, etcdClient *etcd.Client, iamRefreshInterval time.Duration) {
    	bootstrapTraceMsg("IAM initialization started")
    	globalServerConfigMu.RLock()
    	s := globalServerConfig
    	globalServerConfigMu.RUnlock()
    
    	openidConfig, err := openid.LookupConfig(s,
    		NewHTTPTransport(), xhttp.DrainBody, globalSite.Region)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  5. cmd/peer-rest-client.go

    		return !isNetworkError(err)
    	}
    	var gridConn atomic.Pointer[grid.Connection]
    
    	return &peerRESTClient{
    		host: peer, restClient: restClient, gridHost: gridHost,
    		gridConn: func() *grid.Connection {
    			// Lazy initialization of grid connection.
    			// When we create this peer client, the grid connection is likely not yet initialized.
    			if gridHost == "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.8K bytes
    - Viewed (0)
  6. cmd/common-main.go

    		Path: globalCertsDir.Get(),
    	}
    	consoleCerts.GlobalCertsCADir = &consoleCerts.ConfigDir{
    		Path: globalCertsCADir.Get(),
    	}
    
    	// set certs before other console initialization
    	consoleapi.GlobalRootCAs, consoleapi.GlobalPublicCerts, consoleapi.GlobalTLSCertsManager = globalRootCAs, globalPublicCerts, globalTLSCerts
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 35.8K bytes
    - Viewed (2)
  7. cmd/warm-backend-s3.go

    		return nil, errors.New("AWS Role cannot be activated with static credentials or the web identity token file")
    	case conf.Bucket == "":
    		return nil, errors.New("no bucket name was provided")
    	}
    
    	// Credentials initialization
    	var creds *credentials.Credentials
    	switch {
    	case conf.AWSRole:
    		creds = credentials.New(&credentials.IAM{
    			Client: &http.Client{
    				Transport: NewHTTPTransport(),
    			},
    		})
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  8. cmd/local-locker.go

    	Writer          bool      // Bool whether write or read lock.
    	UID             string    // UID to uniquely identify request of client.
    	Timestamp       time.Time // Timestamp set at the time of initialization.
    	TimeLastRefresh time.Time // Timestamp for last lock refresh.
    	Source          string    // Contains line, function and filename requesting the lock.
    	Group           bool      // indicates if it was a group lock.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  9. cmd/prepare-storage.go

    		return nil, nil, errInvalidArgument
    	}
    
    	globalDeploymentIDPtr.Store(&format.ID)
    	return storageDisks, format, nil
    }
    
    // Format disks before initialization of object layer.
    func waitForFormatErasure(firstDisk bool, endpoints Endpoints, poolCount, setCount, setDriveCount int, deploymentID string) ([]StorageAPI, *formatErasureV3, error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 11.1K bytes
    - Viewed (0)
  10. cmd/xl-storage_test.go

    			}
    		}
    	}
    }
    
    // TestNewXLStorage all the cases handled in xlStorage storage layer initialization.
    func TestNewXLStorage(t *testing.T) {
    	// Temporary dir name.
    	tmpDirName := globalTestTmpDir + SlashSeparator + "minio-" + nextSuffix()
    	// Temporary file name.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 11 17:45:28 GMT 2024
    - 66.7K bytes
    - Viewed (0)
Back to top