- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 35 for grand (0.19 sec)
-
internal/dsync/locked_rand.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package dsync import ( "math/rand" "sync" ) // lockedRandSource provides protected rand source, implements rand.Source interface. type lockedRandSource struct { lk sync.Mutex src rand.Source } // Int63 returns a non-negative pseudo-random 63-bit integer as an int64. func (r *lockedRandSource) Int63() (n int64) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Oct 18 15:39:59 GMT 2021 - 1.3K bytes - Viewed (0) -
internal/dsync/utils.go
package dsync import ( "math/rand" "time" ) func backoffWait(min, unit, cap time.Duration) func(*rand.Rand, uint) time.Duration { if unit > time.Hour { // Protect against integer overflow panic("unit cannot exceed one hour") } return func(r *rand.Rand, attempt uint) time.Duration { sleep := min sleep += unit * time.Duration(attempt)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 13 15:42:21 GMT 2023 - 1.2K bytes - Viewed (0) -
cmd/erasure-common.go
package cmd import ( "context" "fmt" "io" "math/rand" "sync" "time" "github.com/minio/pkg/v2/sync/errgroup" ) func (er erasureObjects) getOnlineDisks() (newDisks []StorageAPI) { disks := er.getDisks() var wg sync.WaitGroup var mu sync.Mutex r := rand.New(rand.NewSource(time.Now().UnixNano())) for _, i := range r.Perm(len(disks)) { i := i wg.Add(1)
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) -
cmd/acl-handlers.go
URI string `xml:"URI,omitempty"` } type grant struct { Grantee grantee `xml:"Grantee"` Permission string `xml:"Permission"` } type accessControlPolicy struct { XMLName xml.Name `xml:"AccessControlPolicy"` Owner Owner `xml:"Owner"` AccessControlList struct { Grants []grant `xml:"Grant"` } `xml:"AccessControlList"` } // PutBucketACLHandler - PUT Bucket ACL
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 8.4K bytes - Viewed (0) -
cmd/license-update.go
import ( "context" "fmt" "math/rand" "time" "github.com/tidwall/gjson" ) const ( licUpdateCycle = 24 * time.Hour * 30 licRenewPath = "/api/cluster/renew-license" ) // initlicenseUpdateJob start the periodic license update job in the background. func initLicenseUpdateJob(ctx context.Context, objAPI ObjectLayer) { go func() { r := rand.New(rand.NewSource(time.Now().UnixNano()))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "errors" "fmt" "math/rand" "reflect" "strings" "sync" "time" "github.com/minio/minio-go/v7/pkg/set" "github.com/minio/minio/internal/grid" "github.com/minio/minio/internal/logger" "github.com/minio/pkg/v2/env" )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.5K bytes - Viewed (0) -
cmd/erasure-heal_test.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "bytes" "context" "crypto/rand" "io" "os" "testing" ) var erasureHealTests = []struct { dataBlocks, disks int // number of offline disks is also number of staleDisks for // erasure reconstruction in this test offDisks int
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 7.9K bytes - Viewed (0) -
internal/http/server.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package http import ( "context" "crypto/tls" "errors" "log" "math/rand" "net" "net/http" "os" "runtime/pprof" "sync" "sync/atomic" "time" "github.com/dustin/go-humanize" ) var ( // GlobalMinIOVersion - is sent in the header to all http targets
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
docs/sts/client_grants/__init__.py
basic_auth='%s:%s' % (self.cid, self.csec))['authorization'] response = self._http.urlopen('POST', self.idp_ep, body="grant_type=client_credentials", headers=headers, preload_content=True, )
Python - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 4.6K bytes - Viewed (1) -
internal/config/identity/openid/provider/keycloak.go
func (k *KeycloakProvider) LoginWithClientID(clientID, clientSecret string) error { values := url.Values{} values.Set("client_id", clientID) values.Set("client_secret", clientSecret) values.Set("grant_type", "client_credentials") req, err := http.NewRequest(http.MethodPost, k.oeConfig.TokenEndpoint, strings.NewReader(values.Encode())) if err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 29 01:27:09 GMT 2022 - 4.6K bytes - Viewed (0)