Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 41 for global (0.14 sec)

  1. cmd/global-heal.go

    		healedItemsMap:     make(map[madmin.HealItemType]int64),
    		healFailedItemsMap: make(map[string]int64),
    	}
    }
    
    // getLocalBackgroundHealStatus will return the heal status of the local node
    func getLocalBackgroundHealStatus(ctx context.Context, o ObjectLayer) (madmin.BgHealState, bool) {
    	if globalBackgroundHealState == nil {
    		return madmin.BgHealState{}, false
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 15K bytes
    - Viewed (1)
  2. cmd/globals.go

    	globalNodes []Node
    
    	// The name of this local node, fetched from arguments
    	globalLocalNodeName    string
    	globalLocalNodeNameHex string
    	globalNodeNamesHex     = make(map[string]struct{})
    
    	// The global subnet config
    	globalSubnetConfig subnet.Config
    
    	// The global callhome config
    	globalCallhomeConfig callhome.Config
    
    	// The global drive config
    	globalDriveConfig drive.Config
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 16.5K bytes
    - Viewed (0)
  3. cmd/config-current.go

    				}
    			}
    		}
    	}
    
    	// Bucket federation is 'true' only when IAM assets are not namespaced
    	// per tenant and all tenants interested in globally available users
    	// if namespace was requested such as specifying etcdPathPrefix then
    	// we assume that users are interested in global bucket support
    	// but not federation.
    	globalBucketFederation = etcdCfg.PathPrefix == "" && etcdCfg.Enabled
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 30.8K bytes
    - Viewed (0)
  4. cmd/admin-heal-ops.go

    	//    true: the disk is currently healing
    	healLocalDisks map[Endpoint]bool
    	healStatus     map[string]healingTracker // Indexed by disk ID
    }
    
    // newHealState - initialize global heal state management
    func newHealState(ctx context.Context, cleanup bool) *allHealState {
    	hstate := &allHealState{
    		healSeqMap:     make(map[string]*healSequence),
    		healLocalDisks: make(map[Endpoint]bool),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  5. cmd/common-main.go

    		}
    		globalActiveCred = cred
    		globalCredViaEnv = true
    	} else {
    		globalActiveCred = auth.DefaultCredentials
    	}
    }
    
    // Initialize KMS global variable after valiadating and loading the configuration.
    // It depends on KMS env variables and global cli flags.
    func handleKMSConfig() {
    	if env.IsSet(kms.EnvKMSSecretKey) && env.IsSet(kms.EnvKESEndpoint) {
    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)
  6. internal/config/storageclass/storage-class.go

    			Value:         "",
    			HiddenIfEmpty: true,
    		},
    	}
    )
    
    // StorageClass - holds storage class information
    type StorageClass struct {
    	Parity int
    }
    
    // ConfigLock is a global lock for storage-class config
    var ConfigLock sync.RWMutex
    
    // Config storage class configuration
    type Config struct {
    	Standard    StorageClass `json:"standard"`
    	RRS         StorageClass `json:"rrs"`
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 11.8K bytes
    - Viewed (0)
  7. istioctl/pkg/workload/workload.go

    		return "", err
    	}
    	v, f, err := tpath.GetFromStructPath(injectedCMValues, "global.multiCluster.clusterName")
    	if err != nil {
    		return "", err
    	}
    	vs, ok := v.(string)
    	if !f || !ok {
    		return "", fmt.Errorf("could not retrieve global.multiCluster.clusterName from injection config")
    	}
    	return vs, nil
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Apr 17 20:06:41 GMT 2024
    - 25.5K bytes
    - Viewed (0)
  8. chainable_api.go

    // [FirstOrInit]: https://gorm.io/docs/advanced_query.html#FirstOrInit
    func (db *DB) Assign(attrs ...interface{}) (tx *DB) {
    	tx = db.getInstance()
    	tx.Statement.assigns = attrs
    	return
    }
    
    // Unscoped disables the global scope of soft deletion in a query.
    // By default, GORM uses soft deletion, marking records as "deleted"
    // by setting a timestamp on a specific field (e.g., `deleted_at`).
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Wed Apr 17 03:38:55 GMT 2024
    - 14.3K bytes
    - Viewed (1)
  9. cni/pkg/plugin/plugin_test.go

    	return nil
    }
    
    // returns the test server URL and a dispose func for the test server
    func setupCNIEventClientWithMockServer(serverErr bool) (string, func() bool) {
    	cniAddServerCalled := false
    	// replace the global CNI client with mock
    	newCNIClient = func(address, path string) CNIEventClient {
    		c := http.DefaultClient
    
    		eventC := CNIEventClient{
    			client: c,
    			url:    address + path,
    		}
    		return eventC
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 15:58:51 GMT 2024
    - 17.5K bytes
    - Viewed (0)
  10. operator/cmd/mesh/manifest-generate_test.go

    }
    
    func TestManifestGenerateFlagsSetValues(t *testing.T) {
    	g := NewWithT(t)
    	m, _, err := generateManifest("default", "-s values.global.proxy.image=myproxy -s values.global.proxy.includeIPRanges=172.30.0.0/16,172.21.0.0/16", liveCharts,
    		[]string{"templates/deployment.yaml", "templates/istiod-injector-configmap.yaml"})
    	if err != nil {
    		t.Fatal(err)
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Apr 18 18:16:49 GMT 2024
    - 43.5K bytes
    - Viewed (0)
Back to top