Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for WithNPeers (0.19 sec)

  1. cmd/notification.go

    type NotificationGroup struct {
    	workers    *workers.Workers
    	errs       []NotificationPeerErr
    	retryCount int
    }
    
    // WithNPeers returns a new NotificationGroup with length of errs slice upto nerrs,
    // upon Wait() errors are returned collected from all tasks.
    func WithNPeers(nerrs int) *NotificationGroup {
    	if nerrs <= 0 {
    		nerrs = 1
    	}
    	wk, _ := workers.New(nerrs)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  2. cmd/admin-handlers.go

    			Host:           local,
    			Err:            fmt.Sprintf("server is already running the latest version: %s", Version),
    			CurrentVersion: Version,
    		}
    	}
    
    	if !dryRun {
    		if globalIsDistErasure {
    			ng := WithNPeers(len(globalNotificationSys.peerClients))
    			for idx, client := range globalNotificationSys.peerClients {
    				_, ok := failedClients[idx]
    				if ok {
    					continue
    				}
    				client := client
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 97.3K bytes
    - Viewed (2)
Back to top