Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for WithNPeersThrottled (0.12 sec)

  1. cmd/notification.go

    	return &NotificationGroup{errs: make([]NotificationPeerErr, nerrs), workers: wk, retryCount: 3}
    }
    
    // WithNPeersThrottled returns a new NotificationGroup with length of errs slice upto nerrs,
    // upon Wait() errors are returned collected from all tasks, optionally allows for X workers
    // only "per" parallel task.
    func WithNPeersThrottled(nerrs, wks int) *NotificationGroup {
    	if nerrs <= 0 {
    		nerrs = 1
    	}
    	if wks > nerrs {
    		wks = nerrs
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
Back to top