Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for mock (0.29 sec)

  1. cmd/config-current.go

    // found, otherwise use default parameters
    func newSrvConfig(objAPI ObjectLayer) error {
    	// Initialize server config.
    	srvCfg := newServerConfig()
    
    	// hold the mutex lock before a new config is assigned.
    	globalServerConfigMu.Lock()
    	globalServerConfig = srvCfg
    	globalServerConfigMu.Unlock()
    
    	// Save config into file.
    	return saveServerConfig(GlobalContext, objAPI, srvCfg)
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 30.9K bytes
    - Viewed (0)
  2. cmd/server-main.go

    	// Create new lifecycle system.
    	globalLifecycleSys = NewLifecycleSys()
    
    	// Create new bucket encryption subsystem
    	globalBucketSSEConfigSys = NewBucketSSEConfigSys()
    
    	// Create new bucket object lock subsystem
    	globalBucketObjectLockSys = NewBucketObjectLockSys()
    
    	// Create new bucket quota subsystem
    	globalBucketQuotaSys = NewBucketQuotaSys()
    
    	// Create new bucket versioning subsystem
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 32.7K bytes
    - Viewed (1)
  3. cmd/object-api-interface.go

    	CreatedAt         time.Time // only for site replication
    	NoLock            bool      // does not lock the make bucket call if set to 'true'
    }
    
    // DeleteBucketOptions provides options for DeleteBucket calls.
    type DeleteBucketOptions struct {
    	NoLock     bool             // does not lock the delete bucket call if set to 'true'
    	NoRecreate bool             // do not recreate bucket on delete failures
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Apr 20 09:05:54 GMT 2024
    - 16.9K bytes
    - Viewed (0)
  4. cmd/admin-handlers.go

    	thisAddr, err := xnet.ParseHost(globalLocalNodeName)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	globalProfilerMu.Lock()
    	defer globalProfilerMu.Unlock()
    
    	if globalProfiler == nil {
    		globalProfiler = make(map[string]minioProfiler, 10)
    	}
    
    	// Stop profiler of all types if already running
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 97.3K bytes
    - Viewed (2)
  5. cmd/utils.go

    	return p.ext
    }
    
    // Returns current profile data, returns error if there is no active
    // profiling in progress. Stops an active profile.
    func getProfileData() (map[string][]byte, error) {
    	globalProfilerMu.Lock()
    	defer globalProfilerMu.Unlock()
    
    	if len(globalProfiler) == 0 {
    		return nil, errors.New("profiler not enabled")
    	}
    
    	dst := make(map[string][]byte, len(globalProfiler))
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 32K bytes
    - Viewed (0)
  6. istioctl/pkg/waypoint/waypoint.go

    				Delete(context.Background(), name, metav1.DeleteOptions{}); err != nil {
    				if errors.IsNotFound(err) {
    					fmt.Fprintf(cmd.OutOrStdout(), "waypoint %v/%v not found\n", namespace, name)
    				} else {
    					mu.Lock()
    					multiErr = multierror.Append(multiErr, err)
    					mu.Unlock()
    				}
    			} else {
    				fmt.Fprintf(cmd.OutOrStdout(), "waypoint %v/%v deleted\n", namespace, name)
    			}
    		}(name)
    	}
    
    	wg.Wait()
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Mon Apr 22 20:20:40 GMT 2024
    - 15K bytes
    - Viewed (0)
  7. cmd/globals.go

    	globalAuthPluginMutex.Lock()
    	defer globalAuthPluginMutex.Unlock()
    	return globalAuthNPlugin
    }
    
    func newGlobalAuthZPluginFn() *polplugin.AuthZPlugin {
    	globalAuthPluginMutex.Lock()
    	defer globalAuthPluginMutex.Unlock()
    	return globalAuthZPlugin
    }
    
    func setGlobalAuthNPlugin(authn *idplugin.AuthNPlugin) {
    	globalAuthPluginMutex.Lock()
    	globalAuthNPlugin = authn
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 16.5K bytes
    - Viewed (0)
  8. cmd/bucket-replication.go

    	}
    
    	// Compare only necessary headers
    	compareKeys := []string{
    		"Expires",
    		"Cache-Control",
    		"Content-Language",
    		"Content-Disposition",
    		"X-Amz-Object-Lock-Mode",
    		"X-Amz-Object-Lock-Retain-Until-Date",
    		"X-Amz-Object-Lock-Legal-Hold",
    		"X-Amz-Website-Redirect-Location",
    		"X-Amz-Meta-",
    	}
    
    	// compare metadata on both maps to see if meta is identical
    	compareMeta1 := make(map[string]string)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Apr 20 09:05:54 GMT 2024
    - 112K bytes
    - Viewed (1)
Back to top