Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for subs (0.12 sec)

  1. internal/pubsub/pubsub.go

    	go func() {
    		<-doneCh
    
    		ps.Lock()
    		defer ps.Unlock()
    		var remainTypes Mask
    		for i, s := range ps.subs {
    			if s == sub {
    				ps.subs = append(ps.subs[:i], ps.subs[i+1:]...)
    			} else {
    				remainTypes.Merge(s.types)
    			}
    		}
    		atomic.StoreUint64(&ps.types, uint64(remainTypes))
    		atomic.AddInt32(&ps.numSubscribers, -1)
    	}()
    
    	return nil
    }
    
    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("unexpected error: %v", err)
    	}
    	if err := ps.Subscribe(MaskAll, ch2, doneCh, nil); err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	ps.Lock()
    	defer ps.Unlock()
    
    	if len(ps.subs) != 2 || ps.NumSubscribers(MaskAll) != 2 || ps.Subscribers() != 2 {
    		t.Fatalf("expected 2 subscribers")
    	}
    }
    
    func TestNumSubscribersMask(t *testing.T) {
    	ps := New[Maskable, Mask](2)
    	ch1 := make(chan Maskable, 1)
    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. docs/config/README.md

    ```sh
    export MINIO_DOMAIN=mydomain.com
    minio server /data
    ```
    
    For advanced use cases `MINIO_DOMAIN` environment variable supports multiple-domains with comma separated values.
    
    ```sh
    export MINIO_DOMAIN=sub1.mydomain.com,sub2.mydomain.com
    minio server /data
    ```
    
    ## Explore Further
    
    * [MinIO Quickstart Guide](https://min.io/docs/minio/linux/index.html#quickstart-for-linux)
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 11 21:48:54 GMT 2023
    - 17.7K bytes
    - Viewed (0)
Back to top