Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 149 for Chan (0.18 sec)

  1. cmd/metrics.go

    	desc *prometheus.Desc
    }
    
    // Describe sends the super-set of all possible descriptors of metrics
    func (c *minioCollector) Describe(ch chan<- *prometheus.Desc) {
    	ch <- c.desc
    }
    
    // Collect is called by the Prometheus registry when collecting metrics.
    func (c *minioCollector) Collect(ch chan<- prometheus.Metric) {
    	// Expose MinIO's version information
    	minioVersionInfo.WithLabelValues(Version, CommitID).Set(1.0)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 02 06:48:36 GMT 2024
    - 16.9K bytes
    - Viewed (0)
  2. cmd/listen-notification-handlers.go

    	// Use buffered channel to take care of burst sends or slow w.Write()
    	mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames()))
    	localCh := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())
    
    	// Convert local messages to JSON and send to mergeCh
    	go func() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  3. cmd/erasure-common.go

    func readMultipleFiles(ctx context.Context, disks []StorageAPI, req ReadMultipleReq, readQuorum int) ([]ReadMultipleResp, error) {
    	resps := make([]chan ReadMultipleResp, len(disks))
    	for i := range resps {
    		resps[i] = make(chan ReadMultipleResp, len(req.Files))
    	}
    	g := errgroup.WithNErrs(len(disks))
    	// Read files in parallel across disks.
    	for index := range disks {
    		index := index
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. cmd/globals.go

    	globalIsTLS bool
    
    	globalTLSCerts *certs.Manager
    
    	globalHTTPServer        *xhttp.Server
    	globalTCPOptions        xhttp.TCPOptions
    	globalHTTPServerErrorCh = make(chan error)
    	globalOSSignalCh        = make(chan os.Signal, 1)
    
    	// global Trace system to send HTTP request/response
    	// and Storage/OS calls info to registered listeners.
    	globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8)
    
    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)
  7. internal/grid/grid_test.go

    	remoteHost := remote.HostName()
    
    	// 1: Echo
    	serverSent := make(chan struct{})
    	serverCanceled := make(chan struct{})
    	register := func(manager *Manager) {
    		errFatal(manager.RegisterStreamingHandler(handlerTest, StreamHandler{
    			Handle: func(ctx context.Context, payload []byte, _ <-chan []byte, resp chan<- []byte) *RemoteErr {
    				// Send many responses.
    				// Test that this doesn't block.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 30 15:03:35 GMT 2024
    - 30.1K bytes
    - Viewed (0)
  8. 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)
  9. internal/grid/muxclient.go

    func (m *muxClient) handleTwowayResponses(responseCh chan<- Response, internalResp <-chan Response) {
    	defer m.parent.deleteMux(false, m.MuxID)
    	defer xioutil.SafeClose(responseCh)
    	for resp := range internalResp {
    		responseCh <- resp
    		m.send(message{Op: OpUnblockSrvMux, MuxID: m.MuxID})
    	}
    }
    
    func (m *muxClient) handleTwowayRequests(internalResp chan<- Response, requests <-chan []byte) {
    	var errState bool
    	if debugPrint {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  10. cmd/metrics-v2.go

    func (c *minioBucketCollector) Describe(ch chan<- *prometheus.Desc) {
    	ch <- c.desc
    }
    
    // Collect is called by the Prometheus registry when collecting metrics.
    func (c *minioBucketCollector) Collect(out chan<- prometheus.Metric) {
    	var wg sync.WaitGroup
    	publish := func(in <-chan MetricV2) {
    		defer wg.Done()
    		for metric := range in {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
Back to top