- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 62 for Langen (0.14 sec)
-
cmd/admin-bucket-handlers.go
bucketSSEConfig, bucketTaggingConfig, bucketQuotaConfigFile, objectLockConfig, bucketVersioningConfig, bucketReplicationConfig, bucketTargetsFile, } for _, bi := range buckets { for _, cfgFile := range cfgFiles { cfgPath := pathJoin(bi.Name, cfgFile) bucket := bi.Name switch cfgFile { case bucketNotificationConfig: config, err := globalBucketMetadataSys.GetNotificationConfig(bucket)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 32.5K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
if cfg.cfg.EnableIPv6 { iptablesVariant = append(iptablesVariant, cfg.ipt6V) } for _, iptVer := range iptablesVariant { for _, cmd := range deleteCmds { delErrs = append(delErrs, cfg.ext.Run(iptablesconstants.IPTables, &iptVer, nil, cmd...)) } for _, cmd := range optionalDeleteCmds { err := cfg.ext.Run(iptablesconstants.IPTables, &iptVer, nil, cmd...) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 07 19:54:50 GMT 2024 - 19.7K bytes - Viewed (0) -
internal/logger/target/console/console.go
// Add a sequence number and formatting for each stack trace // No formatting is required for the first entry for i, element := range entry.Trace.Source { trace[i] = fmt.Sprintf("%8v: %s", traceLength-i, element) } tagString := "" for key, value := range entry.Trace.Variables { if value != "" { if tagString != "" { tagString += ", " } tagString += fmt.Sprintf("%s=%#v", key, value) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 3.9K bytes - Viewed (0) -
internal/grid/manager.go
func (m *Manager) Targets() []string { var res []string for k := range m.targets { res = append(res, k) } return res } // debugMsg should *only* be used by tests. // //lint:ignore U1000 This is used by tests. func (m *Manager) debugMsg(d debugMsg, args ...any) { for _, c := range m.targets { c.debugMsg(d, args...) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
cmd/admin-handlers-config-kv.go
return } cfg := globalServerConfig.Clone() var s strings.Builder hkvs := config.HelpSubSysMap[""] for _, hkv := range hkvs { // We ignore the error below, as we cannot get one. cfgSubsysItems, _ := cfg.GetSubsysInfo(hkv.Key, "", false) for _, item := range cfgSubsysItems { off := item.Config.Get(config.Enable) == config.EnableOff switch hkv.Key { case config.EtcdSubSys:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.7K bytes - Viewed (0) -
cmd/object-api-listobjects_test.go
testBuckets := []string{ // This bucket is used for testing ListObject operations. "test-bucket-folders", // This bucket has file delete marker. "test-bucket-files", } for _, bucket := range testBuckets { err := obj.MakeBucket(context.Background(), bucket, MakeBucketOptions{ VersioningEnabled: true, }) if err != nil { t.Fatalf("%s : %s", instanceType, err.Error()) } } var err error
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 11:07:40 GMT 2024 - 73.1K bytes - Viewed (0) -
cmd/storage-rest-server.go
for pool := range globalLocalSetDrives { globalLocalSetDrives[pool] = make([][]StorageAPI, endpointServerPools[pool].SetCount) for set := range globalLocalSetDrives[pool] { globalLocalSetDrives[pool][set] = make([]StorageAPI, endpointServerPools[pool].DrivesPerSet) } } for _, serverPool := range endpointServerPools { for _, endpoint := range serverPool.Endpoints { if !endpoint.IsLocal {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
kconfig Config config *sarama.Config } func (h *Target) validate() error { if len(h.kconfig.Brokers) == 0 { return errors.New("no broker address found") } for _, b := range h.kconfig.Brokers { if _, err := xnet.ParseHost(b.String()); err != nil { return err } } return nil } // Name returns the name of the target func (h *Target) Name() string {
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/storage-rest-client.go
if err != nil { for i := range errs { errs[i] = toStorageErr(err) } return errs } dErrResp := &DeleteVersionsErrsResp{} if err = gob.NewDecoder(reader).Decode(dErrResp); err != nil { for i := range errs { errs[i] = toStorageErr(err) } return errs } for i, dErr := range dErrResp.Errs { errs[i] = toStorageErr(dErr) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
operator/cmd/mesh/profile-list.go
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 1.9K bytes - Viewed (0)