- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 90 for configured (0.15 sec)
-
internal/config/storageclass/storage-class.go
// returned. // // -- if input storage class is empty then standard is assumed // // -- if input is RRS but RRS is not configured/initialized '-1' parity // // for RRS is assumed, the caller is expected to choose the right parity // at that point. // // -- if input is STANDARD but STANDARD is not configured/initialized '-1' parity // // is returned, the caller is expected to choose the right parity // at that point.
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) -
internal/config/heal/heal.go
// Cached value from Bitrot field cache struct { // -1: bitrot enabled, 0: bitrot disabled, > 0: bitrot cycle bitrotCycle time.Duration } } // BitrotScanCycle returns the configured cycle for the scanner healing // -1 for not enabled // // 0 for contiunous bitrot scanning // // >0 interval duration between cycles func (opts Config) BitrotScanCycle() (d time.Duration) { configMutex.RLock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 4.9K bytes - Viewed (0) -
cni/pkg/log/uds_test.go
udsSock := filepath.Join(udsSockDir, "cni.sock") logger := NewUDSLogger() pluginLog.SetOutputLevel(log.DebugLevel) // this will be configured by global.logging.level stop := make(chan struct{}) defer close(stop) assert.NoError(t, logger.StartUDSLogServer(udsSock, stop)) // Configure log to tee to UDS server stdout := os.Stdout r, w, _ := os.Pipe() os.Stdout = w loggingOptions := log.DefaultOptions()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Mar 16 00:20:01 GMT 2024 - 2.5K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
"github.com/minio/minio/internal/logger/target/types" "github.com/minio/minio/internal/once" "github.com/minio/minio/internal/store" xnet "github.com/minio/pkg/v2/net" ) // the suffix for the configured queue dir where the logs will be persisted. const kafkaLoggerExtension = ".kafka.log" const ( statusClosed = iota statusOffline statusOnline ) // Config - kafka target arguments.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
cmd/config-current.go
if len(globalDomainNames) != 0 && !globalDomainIPs.IsEmpty() && globalEtcdClient != nil { if globalDNSConfig != nil { // if global DNS is already configured, indicate with a warning, in case // users are confused. configLogIf(ctx, fmt.Errorf("DNS store is already configured with %s, etcd is not used for DNS store", globalDNSConfig)) } else { globalDNSConfig, err = dns.NewCoreDNS(etcdCfg.Config,
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) -
internal/event/targetlist.go
"github.com/minio/minio/internal/store" "github.com/minio/pkg/v2/workers" ) const ( logSubsys = "notify" // The maximum allowed number of concurrent Send() calls to all configured notifications targets maxConcurrentAsyncSend = 50000 ) // Target - event target interface type Target interface { ID() TargetID IsActive() (bool, error) Save(Event) error SendFromStore(store.Key) error
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0) -
internal/config/identity/openid/providercfg.go
func (p *providerCfg) UserInfo(ctx context.Context, accessToken string, transport http.RoundTripper) (map[string]interface{}, error) { if p.JWKS.URL == nil || p.JWKS.URL.String() == "" { return nil, errors.New("openid not configured") } req, err := http.NewRequestWithContext(ctx, http.MethodPost, p.DiscoveryDoc.UserInfoEndpoint, nil) if err != nil { return nil, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 4.6K bytes - Viewed (0) -
cni/pkg/install/cniconfig.go
return cniConfigFilepath, err } cniConfigFilepath += "list" } installLog.Infof("Created CNI config %s", cniConfigFilepath) return cniConfigFilepath, nil } // If configured as chained CNI plugin, waits indefinitely for a main CNI config file to exist before returning // Or until cancelled by parent context func getCNIConfigFilepath(ctx context.Context, cfg pluginConfig) (string, error) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.4K bytes - Viewed (0) -
cmd/data-usage-utils.go
// Deprecated kept here for backward compatibility reasons. BucketSizes map[string]uint64 `json:"bucketsSizes"` // TierStats contains per-tier stats of all configured remote tiers TierStats *allTierStats `json:"tierStats,omitempty"` } func (dui DataUsageInfo) tierStats() []madmin.TierInfo { if dui.TierStats == nil { return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/typed-errors.go
// expected. var errTooManyPolicies = errors.New("Only a single policy may be specified here.") // error returned in IAM subsystem when an external users systems is configured. var errIAMActionNotAllowed = errors.New("Specified IAM action is not allowed") // error returned in IAM service account var errIAMServiceAccountNotAllowed = errors.New("Specified service account action is not allowed")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.3K bytes - Viewed (0)