- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 118 for global (0.27 sec)
-
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 Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 15K bytes - Viewed (1) -
src/archive/tar/writer_test.go
// // GNU tar v1.27.1 applies global headers to subsequent records, // but does not do the following properly: // * It does not treat an empty record as deletion. // * It does not use subsequent global headers to update previous ones. // // $ gnutar -tvf pax-global-records.tar // ---------- 0/0 0 2017-07-13 19:40 global1 // ---------- 0/0 0 2017-07-13 19:40 file2
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Feb 27 16:39:23 GMT 2024 - 38.7K bytes - Viewed (0) -
internal/color/color.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package color import ( "fmt" "github.com/fatih/color" ) // global colors. var ( // Check if we stderr, stdout are dumb terminals, we do not apply // ansi coloring on dumb terminals. IsTerminal = func() bool { return !color.NoColor }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Dec 13 16:27:40 GMT 2022 - 3.7K bytes - Viewed (0) -
cmd/server-main.go
// Check and load Root CAs. globalRootCAs, err = certs.GetRootCAs(globalCertsCADir.Get()) logger.FatalIf(err, "Failed to read root CAs (%v)", err) // Add the global public crts as part of global root CAs for _, publicCrt := range globalPublicCerts { globalRootCAs.AddCert(publicCrt) } // Register root CAs for remote ENVs env.RegisterGlobalCAs(globalRootCAs)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 33K bytes - Viewed (1) -
cmd/service.go
serviceFreeze // Freeze all S3 API calls. serviceUnFreeze // Un-Freeze previously frozen S3 API calls. // Add new service requests here. ) // Global service signal channel. var globalServiceSignalCh = make(chan serviceSignal) // GlobalContext context that is canceled when server is requested to shut down. // cancelGlobalContext can be used to indicate server shutdown.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Feb 28 07:02:14 GMT 2024 - 3.8K bytes - Viewed (0) -
internal/logger/target/http/http.go
atomic.AddInt64(&h.workers, 1) defer atomic.AddInt64(&h.workers, -1) h.wg.Add(1) defer h.wg.Done() entries := make([]interface{}, 0) name := h.Name() defer func() { // re-load the global buffer pointer // in case it was modified by a new target. logChLock.Lock() currentGlobalBuffer, ok := logChBuffers[name] logChLock.Unlock() if !ok { return }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor.go
"sync" "time" "golang.org/x/time/rate" ) //msgp:ignore bucketThrottle Monitor type bucketThrottle struct { *rate.Limiter NodeBandwidthPerSec int64 } // Monitor holds the state of the global bucket monitor type Monitor struct { tlock sync.RWMutex // mutex for bucket throttling mlock sync.RWMutex // mutex for bucket measurement bucketsThrottle map[BucketOptions]*bucketThrottle
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 6K bytes - Viewed (0) -
gorm.go
// IgnoreRelationshipsWhenMigrating IgnoreRelationshipsWhenMigrating bool // DisableNestedTransaction disable nested transaction DisableNestedTransaction bool // AllowGlobalUpdate allow global update AllowGlobalUpdate bool // QueryFields executes the SQL query with all fields of the table QueryFields bool // CreateBatchSize default create batch size CreateBatchSize int
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Sun Aug 20 11:46:56 GMT 2023 - 11.6K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig.go
if err != nil { return "", err } var values struct { SidecarInjectorWebhook struct { Global struct { Proxy struct { LogLevel string `json:"logLevel"` } `json:"proxy"` } `json:"global"` } `json:"sidecarInjectorWebhook"` } if err := yaml.Unmarshal([]byte(valuesConfig), &values); err != nil {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 16 03:28:36 GMT 2024 - 48K bytes - Viewed (0) -
internal/s3select/json/preader.go
recordsRead int // number of records read in current slice input chan *queueItem // input for workers queue chan *queueItem // output from workers in order err error // global error state, only touched by Reader.Read bufferPool sync.Pool // pool of []byte objects for input kvDstPool sync.Pool // pool of []jstream.KV used for output
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 6.4K bytes - Viewed (0)