- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 109 for Chan (0.12 sec)
-
cmd/data-scanner_test.go
globalBucketObjectLockSys = &BucketObjectLockSys{} globalBucketVersioningSys = &BucketVersioningSys{} es := newExpiryState(context.Background(), objAPI, 0) workers := []chan expiryOp{make(chan expiryOp)} es.workers.Store(&workers) globalExpiryState = es var wg sync.WaitGroup wg.Add(1) expired := make([]ObjectToDelete, 0, 5) go func() { defer wg.Done()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 6.9K bytes - Viewed (0) -
internal/event/target/mqtt.go
} // MQTTTarget - MQTT target. type MQTTTarget struct { initOnce once.Init id event.TargetID args MQTTArgs client mqtt.Client store store.Store[event.Event] quitCh chan struct{} loggerOnce logger.LogOnce } // ID - returns target ID. func (target *MQTTTarget) ID() event.TargetID { return target.id } // Name - returns the Name of the target.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 8.2K bytes - Viewed (0) -
internal/event/targetlist.go
currentSendCalls atomic.Int64 totalEvents atomic.Int64 eventsSkipped atomic.Int64 eventsErrorsTotal atomic.Int64 sync.RWMutex targets map[TargetID]Target queue chan asyncEvent ctx context.Context statLock sync.RWMutex targetStats map[TargetID]targetStat } type targetStat struct { // The number of concurrent async Send calls per targets currentSendCalls int64
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) -
cni/pkg/monitoring/monitoring.go
package monitoring import ( "fmt" "net" "net/http" "istio.io/istio/pkg/log" "istio.io/istio/pkg/monitoring" "istio.io/istio/pkg/network" ) func SetupMonitoring(port int, path string, stop <-chan struct{}) { if port <= 0 { return } mux := http.NewServeMux() var listener net.Listener var err error if listener, err = net.Listen("tcp", fmt.Sprintf(":%d", port)); err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jun 09 07:54:01 GMT 2023 - 1.5K bytes - Viewed (0) -
cni/pkg/log/uds.go
} l.loggingServer = loggingServer return l } // StartUDSLogServer starts up a UDS server which receives log reported from CNI network plugin. func (l *UDSLogger) StartUDSLogServer(sockAddress string, stop <-chan struct{}) error { if sockAddress == "" { return nil } log.Info("Start a UDS server for CNI plugin logs") unixListener, err := uds.NewListener(sockAddress) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 01:05:12 GMT 2023 - 3.3K bytes - Viewed (0) -
cmd/naughty-disk_test.go
return d.disk.GetDiskID() } func (d *naughtyDisk) SetDiskID(id string) { d.disk.SetDiskID(id) } func (d *naughtyDisk) NSScanner(ctx context.Context, cache dataUsageCache, updates chan<- dataUsageEntry, scanMode madmin.HealScanMode, weSleep func() bool) (info dataUsageCache, err error) { if err := d.calcError(); err != nil { return info, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 9.3K bytes - Viewed (0) -
internal/store/store.go
type Key struct { Name string IsLast bool } // replayItems - Reads the items from the store and replays. func replayItems[I any](store Store[I], doneCh <-chan struct{}, log logger, id string) <-chan Key { keyCh := make(chan Key) go func() { defer xioutil.SafeClose(keyCh) retryTicker := time.NewTicker(retryInterval) defer retryTicker.Stop() for { names, err := store.List()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 3.5K bytes - Viewed (0) -
cmd/data-usage.go
dataUsageCacheName = ".usage-cache.bin" ) // storeDataUsageInBackend will store all objects sent on the dui channel until closed. func storeDataUsageInBackend(ctx context.Context, objAPI ObjectLayer, dui <-chan DataUsageInfo) { attempts := 1 for dataUsageInfo := range dui { json := jsoniter.ConfigCompatibleWithStandardLibrary dataUsageJSON, err := json.Marshal(dataUsageInfo) if err != nil { scannerLogIf(ctx, err)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.6K bytes - Viewed (0) -
cmd/mrf.go
setIndex, poolIndex int queued time.Time scanMode madmin.HealScanMode } // mrfState sncapsulates all the information // related to the global background MRF. type mrfState struct { opCh chan partialOperation } // Add a partial S3 operation (put/delete) when one or more disks are offline. func (m *mrfState) addPartialOp(op partialOperation) { if m == nil { return } select {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 3.2K bytes - Viewed (0) -
internal/pubsub/pubsub.go
select { case sub.ch <- item: default: } } } } // Subscribe - Adds a subscriber to pubsub system func (ps *PubSub[T, M]) Subscribe(mask M, subCh chan T, doneCh <-chan struct{}, filter func(entry T) bool) error { totalSubs := atomic.AddInt32(&ps.numSubscribers, 1) if ps.maxSubscribers > 0 && totalSubs > ps.maxSubscribers { atomic.AddInt32(&ps.numSubscribers, -1)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 16:57:30 GMT 2024 - 5.2K bytes - Viewed (0)