- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for bindon (0.2 sec)
-
internal/config/lambda/event/event.go
OutputToken string `json:"outputToken"` InputS3URL string `json:"inputS3Url"` } // Event represents lambda function event, this is undocumented in AWS S3. This // structure bases itself on this structure but there is no binding. // // { // "xAmzRequestId": "a2871150-1df5-4dc9-ad9f-3da283ca1bf3", // "getObjectContext": { // "outputRoute": "...", // "outputToken": "...", // "inputS3Url": "<presignedURL>" // },
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 2.6K bytes - Viewed (0) -
schema/schema.go
} // This unrolling is needed to show to the compiler the exact set of methods // that can be used on the modelType. // Prior to go1.22 any use of MethodByName would cause the linker to // abandon dead code elimination for the entire binary. // As of go1.22 the compiler supports one special case of a string constant // being passed to MethodByName. For enterprise customers or those building
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Tue Oct 10 06:50:29 GMT 2023 - 13.7K bytes - Viewed (0) -
cmd/data-usage-cache.go
func (d *dataUsageCache) load(ctx context.Context, store objectIO, name string) error { // By default, empty data usage cache *d = dataUsageCache{} load := func(name string, timeout time.Duration) (bool, error) { // Abandon if more than time.Minute, so we don't hold up scanner. // drive timeout by default is 2 minutes, we do not need to wait longer. ctx, cancel := context.WithTimeout(ctx, timeout) defer cancel()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.4K bytes - Viewed (1) -
internal/config/identity/ldap/ldap.go
} // Lookup user DN bindDN, err = l.LDAP.LookupUserDN(conn, username) if err != nil { errRet := fmt.Errorf("Unable to find user DN: %w", err) return "", nil, errRet } // Authenticate the user credentials. err = conn.Bind(bindDN, password) if err != nil { errRet := fmt.Errorf("LDAP auth failed for DN %s: %w", bindDN, err) return "", nil, errRet }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 9.9K bytes - Viewed (0) -
cni/pkg/install/install.go
// we shouldn't fire events for binaries that are not ours. var binPaths []string for _, bindir := range in.cfg.CNIBinTargetDirs { for _, binary := range installedBinFiles.UnsortedList() { binPaths = append(binPaths, filepath.Join(bindir, binary)) } } targets := append( binPaths, in.cfg.MountedCNINetDir, constants.ServiceAccountPath, )
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 10.8K bytes - Viewed (0) -
cmd/api-response_test.go
}, // Server binding to fqdn. { request: &http.Request{ Host: "s3.mybucket.org", Header: map[string][]string{ "X-Forwarded-Scheme": {httpScheme}, }, }, bucket: "mybucket", object: "test/1.txt", expectedLocation: "http://s3.mybucket.org/mybucket/test/1.txt", }, // Server binding to fqdn. { request: &http.Request{
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 3.5K bytes - Viewed (0) -
cni/test/install_cni.go
wg.Add(1) defer func() { cancel() wg.Wait() }() go func() { runInstall(ctx, tempCNIConfDir, tempCNIBinDir, tempK8sSvcAcctDir, envPreconf, filepath.Join(env.IstioSrc, "cni/test/testdata/bindir"), chainedCNIPlugin, t) wg.Done() }() resultFile := tempCNIConfDir + "/" + resultFileName if chainedCNIPlugin && delayedConfFile != "" { retry.UntilSuccessOrFail(t, func() error {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
cmd/peer-s3-client.go
}) return result, nil } // GetBucketInfo returns bucket stat info about bucket on disk across all peers func (sys *S3PeerSys) GetBucketInfo(ctx context.Context, bucket string, opts BucketOptions) (binfo BucketInfo, err error) { g := errgroup.WithNErrs(len(sys.peerClients)) bucketInfos := make([]BucketInfo, len(sys.peerClients)) for idx, client := range sys.peerClients { idx := idx client := client
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
cmd/common-main.go
if orchestrated { dnsTTL = 30 * time.Second } else { dnsTTL = 10 * time.Minute } } // Call to refresh will refresh names in cache. go func() { // Baremetal setups set DNS refresh window up to dnsTTL duration. t := time.NewTicker(dnsTTL) defer t.Stop() for { select { case <-t.C: globalDNSCache.Refresh() case <-GlobalContext.Done(): return } }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 35.5K bytes - Viewed (2) -
cmd/xl-storage-disk-id-check.go
) // if disk max timeout is smaller than checkEvery window // reduce checks by a second. if globalDriveConfig.GetMaxTimeout() <= checkEvery { checkEvery = globalDriveConfig.GetMaxTimeout() - time.Second if checkEvery <= 0 { checkEvery = globalDriveConfig.GetMaxTimeout() } } // if disk max timeout is smaller than skipIfSuccessBefore window // reduce the skipIfSuccessBefore by a second.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0)