- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for unwrap (0.17 sec)
-
cmd/object-api-errors.go
} // Unwrap the error. func (e InsufficientWriteQuorum) Unwrap() error { return errErasureWriteQuorum } // GenericError - generic object layer error. type GenericError struct { Bucket string Object string VersionID string Err error } // Unwrap the error to its underlying error. func (e GenericError) Unwrap() error { return e.Err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 21.3K bytes - Viewed (0) -
internal/rest/client.go
type NetworkError struct { Err error } func (n *NetworkError) Error() string { return n.Err.Error() } // Unwrap returns the error wrapped in NetworkError. func (n *NetworkError) Unwrap() error { return n.Err } // Client - http based RPC client. type Client struct { connected int32 // ref: https://golang.org/pkg/sync/atomic/#pkg-note-BUG
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
cmd/site-replication.go
}, configureReplication, ) if err := errors.Unwrap(makeBucketConcErr); err != nil { return err } if err := errors.Unwrap(makeRemotesConcErr); err != nil { return err } return nil } // DeleteBucketHook - called during a regular delete bucket call when cluster
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
cmd/api-errors.go
// This way downstream context.Canceled will still report ErrRequestTimedout if contextCanceled(ctx) && errors.Is(ctx.Err(), context.Canceled) { return ErrClientDisconnected } // Unwrap the error first err = unwrapAll(err) switch err { case errInvalidArgument: apiErr = ErrAdminInvalidArgument case errNoSuchPolicy: apiErr = ErrAdminNoSuchPolicy case errNoSuchUser:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 91.4K bytes - Viewed (7) -
cmd/iam-store.go
now := UTCNow().Round(time.Millisecond) return PolicyDoc{ Version: 1, Policy: p, CreateDate: now, UpdateDate: now, } } // defaultPolicyDoc - used to wrap a default policy as PolicyDoc. func defaultPolicyDoc(p policy.Policy) PolicyDoc { return PolicyDoc{ Version: 1, Policy: p, } } func (d *PolicyDoc) update(p policy.Policy) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
cmd/utils.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 31.4K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
func diskHealthReader(ctx context.Context, r io.Reader) io.Reader { // Check if context has a disk health check. tracker, ok := ctx.Value(healthDiskCtxKey{}).(*healthDiskCtxValue) if !ok { // No need to wrap return r } return &diskHealthWrapper{r: r, tracker: tracker} } // diskHealthWriter provides a wrapper that will update disk health on // ctx, on every successful write.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/object-handlers.go
wantEncryption := crypto.Requested(r.Header) s2c, cb := newS2CompressReader(reader, actualSize, wantEncryption) dstOpts.IndexCB = cb defer s2c.Close() reader = etag.Wrap(s2c, reader) length = -1 } else { delete(srcInfo.UserDefined, ReservedMetadataPrefix+"compression") delete(srcInfo.UserDefined, ReservedMetadataPrefix+"actual-size") reader = gr }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
cni/pkg/ipset/ipset.go
ipToInsert := ip.Unmap() // We have already Unmap'd, so we can do a simple IsV6 y/n check now if ipToInsert.Is6() { return m.Deps.addIP(m.V6Name, ipToInsert, ipProto, comment, replace) } return m.Deps.addIP(m.V4Name, ipToInsert, ipProto, comment, replace) } func (m *IPSet) DeleteIP(ip netip.Addr, ipProto uint8) error { ipToDel := ip.Unmap()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 3.9K bytes - Viewed (0) -
cmd/server-main.go
return fmt.Errorf("Unable to initialize sub-systems: %w", err) } } func initConfigSubsystem(ctx context.Context, newObject ObjectLayer) error { // %w is used by all error returns here to make sure // we wrap the underlying error, make sure when you // are modifying this code that you do so, if and when // you want to add extra context to your error. This // ensures top level retry works accordingly.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 34.9K bytes - Viewed (1)