- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for supplied (0.18 sec)
-
internal/ioutil/wait_pipe.go
} // CloseWithError close with supplied error the writer end. func (w *PipeWriter) CloseWithError(err error) error { err = w.PipeWriter.CloseWithError(err) w.once.Do(func() { w.done() }) return err } // PipeReader is similar to io.PipeReader with wait group type PipeReader struct { *io.PipeReader wait func() } // CloseWithError close with supplied error the reader end
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 27 14:55:36 GMT 2023 - 1.7K bytes - Viewed (0) -
cmd/admin-handler-utils.go
"github.com/minio/minio/internal/auth" "github.com/minio/minio/internal/config" "github.com/minio/pkg/v2/policy" ) // validateAdminReq will validate request against and return whether it is allowed. // If any of the supplied actions are allowed it will be successful. // If nil ObjectLayer is returned, the operation is not permitted. // When nil ObjectLayer has been returned an error has always been sent to w.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 8.2K bytes - Viewed (0) -
cmd/sts-errors.go
Code: "MissingParameter", Description: "A required parameter for the specified action is not supplied.", HTTPStatusCode: http.StatusBadRequest, }, ErrSTSInvalidParameterValue: { Code: "InvalidParameterValue", Description: "An invalid or out-of-range value was supplied for the input parameter.", HTTPStatusCode: http.StatusBadRequest, }, ErrSTSWebIdentityExpiredToken: {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.8K bytes - Viewed (0) -
docs/debugging/xattr/main.go
data := make([]byte, 8) binary.LittleEndian.PutUint64(data, value) return xattr.LSet(path, name, data) } func main() { flag.StringVar(&path, "path", "", "path name where the attribute shall be applied") flag.StringVar(&name, "name", "", "attribute name or it can be a wildcard if '.' is specified") flag.Uint64Var(&value, "value", 0, "attribute value expects the value to be uint64")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 29 23:52:41 GMT 2023 - 3.2K bytes - Viewed (0) -
cmd/storage-errors.go
var errLessData = StorageErr("less data available than what was requested") // errMoreData = returned when more data was sent by the caller than what it was supposed to. var errMoreData = StorageErr("more data was sent than what was advertised") // indicates readDirFn to return without further applying the fn() var errDoneForNow = errors.New("done for now")
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) -
cmd/typed-errors.go
var errNoSuchGroup = errors.New("Specified group does not exist") // error returned in IAM subsystem when a policy attach/detach request has no // net effect, i.e. it is already applied. var errNoPolicyToAttachOrDetach = errors.New("Specified policy update has no net effect") // error returned in IAM subsystem when a non-empty group needs to be // deleted.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.3K bytes - Viewed (0) -
cmd/bitrot-streaming.go
if b.canClose != nil { b.canClose.Wait() } return err } // newStreamingBitrotWriterBuffer returns streaming bitrot writer implementation. // The output is written to the supplied writer w. func newStreamingBitrotWriterBuffer(w io.Writer, algo BitrotAlgorithm, shardSize int64) io.Writer {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/erasure-decode.go
} // Decode reads from readers, reconstructs data if needed and writes the data to the writer. // A set of preferred drives can be supplied. In that case they will be used and the data reconstructed. func (e Erasure) Decode(ctx context.Context, writer io.Writer, readers []io.ReaderAt, offset, length, totalLength int64, prefer []bool) (written int64, derr error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0) -
internal/bucket/replication/replication.go
} // regular object/metadata replication return rule.MetadataReplicate(obj) } return false } // HasActiveRules - returns whether replication policy has active rules // Optionally a prefix can be supplied. // If recursive is specified the function will also return true if any level below the // prefix has active rules. If no prefix is specified recursive is effectively true.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 8.9K bytes - Viewed (0) -
cmd/routers.go
registerLockRESTHandlers() // Add grid to router router.Handle(grid.RoutePath, adminMiddleware(globalGrid.Load().Handler(), noGZFlag, noObjLayerFlag)) } // List of some generic middlewares which are applied for all incoming requests. var globalMiddlewares = []mux.MiddlewareFunc{ // set x-amz-request-id header and others addCustomHeadersMiddleware, // The generic tracer needs to be the first middleware to catch all requests
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 3.6K bytes - Viewed (1)