- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 113 for sargument (0.17 sec)
-
cmd/bucket-lifecycle.go
} } func initBackgroundExpiry(ctx context.Context, objectAPI ObjectLayer) { globalExpiryState = newExpiryState(ctx, objectAPI, globalILMConfig.getExpirationWorkers()) } // newerNoncurrentTask encapsulates arguments required by worker to expire objects // by NewerNoncurrentVersions type newerNoncurrentTask struct { bucket string versions []ObjectToDelete event lifecycle.Event } type transitionTask struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
internal/once/init.go
return err } // Mark as done only when f() is successful atomic.StoreUint32(&l.done, 1) } return nil } // DoWithContext is similar to Do except that it accepts a context as an argument to be passed. func (l *Init) DoWithContext(ctx context.Context, f func(context.Context) error) error { if atomic.LoadUint32(&l.done) == 0 { return l.doWithContext(ctx, f) } return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue May 09 04:20:31 GMT 2023 - 2.1K bytes - Viewed (0) -
src/cmd/asm/internal/flags/flags.go
"os" "path/filepath" "strings" ) var ( Debug = flag.Bool("debug", false, "dump instructions as they are parsed") OutputFile = flag.String("o", "", "output file; default foo.o for /a/b/c/foo.s as first argument") TrimPath = flag.String("trimpath", "", "remove prefix from recorded source file paths") Shared = flag.Bool("shared", false, "generate code that can be linked into a shared library")
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Aug 22 19:18:23 GMT 2023 - 2.8K bytes - Viewed (0) -
internal/s3select/sql/stringfuncs.go
package sql import ( "errors" "strings" ) var ( errMalformedEscapeSequence = errors.New("Malformed escape sequence in LIKE clause") errInvalidTrimArg = errors.New("Trim argument is invalid - this should not happen") errInvalidSubstringIndexLen = errors.New("Substring start index or length falls outside the string") ) const ( percent rune = '%' underscore rune = '_'
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 4.2K bytes - Viewed (0) -
internal/s3select/sql/value.go
errArithDivideByZero = errors.New("cannot divide by 0") errCmpMismatchedTypes = errors.New("cannot compare values of different types") errCmpInvalidBoolOperator = errors.New("invalid comparison operator for boolean arguments") ) // Value represents a value of restricted type reduced from an // expression represented by an ASTNode. Only one of the fields is // non-nil. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 25 20:31:19 GMT 2022 - 20.2K bytes - Viewed (0) -
cmd/xl-storage.go
if err = Access(volumeDir); err != nil { return convertAccessError(err, errVolumeAccessDenied) } } // Following code is needed so that we retain SlashSeparator suffix if any in // path argument. filePath := pathJoin(volumeDir, path) if err = checkPathLength(filePath); err != nil { return err } // Delete file and delete parent directory as well if it's empty.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
internal/config/dns/operator_dns.go
} } // NewOperatorDNS - initialize a new K8S Operator DNS set/unset values. func NewOperatorDNS(endpoint string, setters ...OperatorOption) (Store, error) { if endpoint == "" { return nil, errors.New("invalid argument") } args := &OperatorDNS{ Endpoint: endpoint, } for _, setter := range setters { setter(args) } args.httpClient = &http.Client{ Transport: &http.Transport{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 6.6K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
if ns1 != ns2 { return fmt.Errorf("Expected number of endpoints %d, seen %d", ns1, ns2) } for i, cmdLine := range s1.CmdLines { if cmdLine != s2.CmdLines[i] { return fmt.Errorf("Expected command line argument %s, seen %s", cmdLine, s2.CmdLines[i]) } } if reflect.DeepEqual(s1.MinioEnv, s2.MinioEnv) { return nil } // Report differences in environment variables. var missing []string
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) -
docs/debugging/reorder-disks/main.go
return "", errors.New("format.json is corrupted") } func main() { var node, args string flag.StringVar(&node, "local-node-name", "", "the name of the local node") flag.StringVar(&args, "args", "", "arguments passed to MinIO server") flag.Parse() localDisks, err := filterLocalDisks(node, args) if err != nil { log.Fatal(err) } if len(localDisks) == 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.4K bytes - Viewed (0) -
internal/http/server.go
} // UseTCPOptions use custom TCP options on raw socket func (srv *Server) UseTCPOptions(opts TCPOptions) *Server { srv.TCPOptions = opts return srv } // NewServer - creates new HTTP server using given arguments. func NewServer(addrs []string) *Server { httpServer := &Server{ Addrs: addrs, } // This is not configurable for now. httpServer.MaxHeaderBytes = DefaultMaxHeaderBytes return httpServer }
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)