Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for Subscriber (0.2 sec)

  1. internal/pubsub/pubsub.go

    			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)
    		return fmt.Errorf("the limit of `%d` subscribers is reached", ps.maxSubscribers)
    	}
    	ps.Lock()
    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)
  2. internal/pubsub/pubsub_test.go

    		t.Fatalf("want %d subscribers, got %d", want, got)
    	}
    	if want, got := int32(2), ps.NumSubscribers(Mask(2)); got != want {
    		t.Fatalf("want %d subscribers, got %d", want, got)
    	}
    	if want, got := int32(2), ps.NumSubscribers(Mask(1|2)); got != want {
    		t.Fatalf("want %d subscribers, got %d", want, got)
    	}
    	if want, got := int32(2), ps.NumSubscribers(MaskAll); got != want {
    		t.Fatalf("want %d subscribers, got %d", want, got)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  3. internal/event/target/testdata/contrib/nats_tls_client_cert.conf

        key_file:   "./testdata/contrib/certs/nats_server_key.pem"
        ca_file:   "./testdata/contrib/certs/root_ca_cert.pem"
        verify_and_map: true
    }
    authorization {
        ADMIN = {
            publish = ">"
            subscribe = ">"
        }
        users = [
            {user: "CN=localhost,OU=Client,O=MinIO,C=CA", permissions: $ADMIN}
        ]
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 426 bytes
    - Viewed (0)
  4. .github/ISSUE_TEMPLATE.md

    For urgent issues (e.g. production down, etc.), subscribe to [SUBNET](https://min.io/pricing?jmp=github) for direct to engineering support.
     
    <!--- Provide a general summary of the issue in the Title above -->
    
    ## Expected Behavior
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Jan 29 00:04:16 GMT 2022
    - 2K bytes
    - Viewed (0)
  5. cmd/listen-notification-handlers.go

    			case <-ctx.Done():
    				grid.PutByteBuffer(buf.Bytes())
    				return
    			}
    		}
    	}()
    	peers, _ := newPeerRestClients(globalEndpoints)
    	err := globalHTTPListen.Subscribe(mask, localCh, ctx.Done(), func(ev event.Event) bool {
    		if ev.S3.Bucket.Name != "" && bucketName != "" {
    			if ev.S3.Bucket.Name != bucketName {
    				return false
    			}
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  6. cmd/consolelogger.go

    // for this node or peers
    func (sys *HTTPConsoleLoggerSys) HasLogListeners() bool {
    	return sys != nil && sys.pubsub.Subscribers() > 0
    }
    
    // Subscribe starts console logging for this node.
    func (sys *HTTPConsoleLoggerSys) Subscribe(subCh chan log.Info, doneCh <-chan struct{}, node string, last int, logKind madmin.LogMask, filter func(entry log.Info) bool) error {
    	// Enable console logging for remote client.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  7. .github/ISSUE_TEMPLATE/bug_report.md

    ---
    name: Bug report
    about: Create a report to help us improve
    title: ''
    labels: community, triage
    assignees: ''
    
    ---
    
    ## NOTE
    If this case is urgent, please subscribe to [Subnet](https://min.io/pricing) so that our 24/7 support team may help you faster.
    
    <!--- Provide a general summary of the issue in the Title above -->
    
    ## Expected Behavior
    <!--- If you're describing a bug, tell us what should happen -->
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 20 17:37:40 GMT 2022
    - 1.7K bytes
    - Viewed (0)
  8. cmd/http-tracer.go

    		reqStartTime := time.Now().UTC()
    		h.ServeHTTP(respRecorder, r)
    		reqEndTime := time.Now().UTC()
    
    		if globalTrace.NumSubscribers(madmin.TraceS3|madmin.TraceInternal) == 0 {
    			// no subscribers nothing to trace.
    			return
    		}
    
    		tt := madmin.TraceInternal
    		if strings.HasPrefix(tc.FuncName, "s3.") {
    			tt = madmin.TraceS3
    		}
    
    		// Calculate input body size with headers
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 5.9K bytes
    - Viewed (0)
  9. cmd/background-heal-ops.go

    }
    
    func activeListeners() int {
    	// Bucket notification and http trace are not costly, it is okay to ignore them
    	// while counting the number of concurrent connections
    	return int(globalHTTPListen.Subscribers()) + int(globalTrace.Subscribers())
    }
    
    func waitForLowIO(maxIO int, maxWait time.Duration, currentIO func() int) {
    	// No need to wait run at full speed.
    	if maxIO <= 0 {
    		return
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 4.6K bytes
    - Viewed (0)
Back to top