- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 101 for pcall (0.15 sec)
-
cmd/os-instrumented.go
// Stat captures time taken to call os.Stat func Stat(name string) (info os.FileInfo, err error) { defer updateOSMetrics(osMetricStat, name)(err) return os.Stat(name) } // Create captures time taken to call os.Create func Create(name string) (f *os.File, err error) { defer updateOSMetrics(osMetricCreate, name)(err) return os.Create(name) } // Fdatasync captures time taken to call Fdatasync
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 15 01:09:38 GMT 2024 - 6.3K bytes - Viewed (0) -
internal/grid/README.md
// Do something with payload return []byte("response"), nil } err := manager.RegisterSingleHandler(grid.HandlerDiskInfo, handler) ``` Sample call: ```go // Get a connection to the remote host conn := manager.Connection(host) payload := []byte("request") response, err := conn.SingleRequest(ctx, grid.HandlerDiskInfo, payload) ```
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0) -
cmd/bucket-policy-handlers.go
return } updatedAt, err := globalBucketMetadataSys.Update(ctx, bucket, bucketPolicyConfig, configData) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } // Call site replication hook. replLogIf(ctx, globalSiteReplicationSys.BucketMetaHook(ctx, madmin.SRBucketMeta{ Type: madmin.SRBucketMetaTypePolicy, Bucket: bucket, Policy: bucketPolicyBytes,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.1K bytes - Viewed (0) -
cmd/os-rename_nolinux.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 ( "os" ) // RenameSys is low level call in case of non-Linux this just uses os.Rename() func RenameSys(src, dst string) (err error) { return os.Rename(src, dst)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 15 01:09:38 GMT 2024 - 985 bytes - Viewed (0) -
docs/sts/web-identity.md
a `RoleArn` API request parameter in the STS AssumeRoleWithWebIdentity API call. When using Role Policies, multiple OpenID providers and/or client applications (with unique client IDs) may be configured with independent role policies. Each configuration is assigned a unique RoleARN by the MinIO server and this is used to select the policies to apply to temporary credentials generated in the AssumeRoleWithWebIdentity call. 2. `id_token` claims: When the role policy is not configured, MinIO...
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 19.2K bytes - Viewed (1) -
cmd/naughty-disk_test.go
// Programmed errors are stored in errors field. type naughtyDisk struct { // The real disk disk StorageAPI // Programmed errors: API call number => error to return errors map[int]error // The error to return when no error value is programmed defaultErr error // The current API call number callNR int // Data protection mu sync.Mutex }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
func (e *lockedLastMinuteLatency) add(value time.Duration) { e.addSize(value, 0) } // addSize will add a duration and size. func (e *lockedLastMinuteLatency) addSize(value time.Duration, sz int64) { // alloc on every call, so we have a clean entry to swap in. t := time.Now().Unix() e.init.Do(func() { e.cached.Store(&AccElem{}) atomic.StoreInt64(&e.cachedSec, t) }) acc := e.cached.Load()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
internal/grid/trace.go
TimeToFirstByte: end.Sub(start), }, }, } // If the context contains a TraceParamsKey, add it to the trace path. v := ctx.Value(TraceParamsKey{}) // Should match SingleHandler.Call checks. switch typed := v.(type) { case *MSS: trace.Path += typed.ToQuery() case map[string]string: m := MSS(typed) trace.Path += m.ToQuery() case *URLValues:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 02 22:54:54 GMT 2024 - 4K bytes - Viewed (0) -
docs/sts/assume-role.go
} func main() { flag.Parse() if minioUsername == "" || minioPassword == "" { flag.PrintDefaults() return } // The credentials package in minio-go provides an interface to call the // STS API. // Initialize credential options var stsOpts cr.STSAssumeRoleOptions stsOpts.AccessKey = minioUsername stsOpts.SecretKey = minioPassword if sessionPolicyFile != "" { var policy string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 16:09:55 GMT 2024 - 4K bytes - Viewed (1) -
cmd/storage-errors.go
// errXLBackend XL drive mode requires fresh deployment. var errXLBackend = errors.New("XL backend requires fresh drive") // StorageErr represents error generated by xlStorage call. type StorageErr string func (h StorageErr) Error() string { return string(h) } // Collection of basic errors. var baseErrs = []error{ errDiskNotFound, errFaultyDisk,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.4K bytes - Viewed (0)