Search Options

Results per page
Sort
Preferred Languages
Advance

Results 321 - 330 of 829 for timme (0.04 sec)

  1. cmd/xl-storage.go

    func (s *xlStorage) readMetadataWithDMTime(ctx context.Context, itemPath string) ([]byte, time.Time, error) {
    	if contextCanceled(ctx) {
    		return nil, time.Time{}, ctx.Err()
    	}
    
    	if err := checkPathLength(itemPath); err != nil {
    		return nil, time.Time{}, err
    	}
    
    	f, err := OpenFile(itemPath, readMode, 0o666)
    	if err != nil {
    		return nil, time.Time{}, err
    	}
    	defer f.Close()
    	stat, err := f.Stat()
    	if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (2)
  2. internal/s3select/sql/funceval.go

    	return "", errCastFailure(fmt.Sprintf("cannot cast %v to string type", v.GetTypeString()))
    }
    
    func timestampCast(v *Value) (t time.Time, _ error) {
    	switch x := v.value.(type) {
    	case string:
    		return parseSQLTimestamp(x)
    	case []byte:
    		return parseSQLTimestamp(string(x))
    	case time.Time:
    		return x, nil
    	default:
    		return t, errCastFailure(fmt.Sprintf("cannot cast %v to Timestamp type", v.GetTypeString()))
    	}
    }
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 13.2K bytes
    - Viewed (0)
  3. cmd/xl-storage-format-v2_test.go

    	restored := make(map[string]string)
    	restored[xhttp.AmzRestore] = completedRestoreObj(time.Now().UTC().Add(time.Hour)).String()
    
    	restoredExpired := make(map[string]string)
    	restoredExpired[xhttp.AmzRestore] = completedRestoreObj(time.Now().UTC().Add(-time.Hour)).String()
    
    	testCases := []struct {
    		xlmeta xlMetaV2Object
    		uses   bool
    	}{
    		{ // transitioned object version
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Mar 08 17:50:48 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  4. cmd/erasure-sets.go

    func (s *erasureSets) monitorAndConnectEndpoints(ctx context.Context, monitorInterval time.Duration) {
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	time.Sleep(time.Duration(r.Float64() * float64(time.Second)))
    
    	// Pre-emptively connect the disks if possible.
    	s.connectDisks(false)
    
    	monitor := time.NewTimer(monitorInterval)
    	defer monitor.Stop()
    
    	for {
    		select {
    		case <-ctx.Done():
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (0)
  5. cmd/storage-interface.go

    	// of this function is to know if the "drive" has "format.json" or not
    	// if it has a "format.json" then is it correct "format.json" or not.
    	IsOnline() bool
    
    	// Returns the last time this disk (re)-connected
    	LastConn() time.Time
    
    	// Indicates if disk is local or not.
    	IsLocal() bool
    
    	// Returns hostname if disk is remote.
    	Hostname() string
    
    	// Returns the entire endpoint.
    	Endpoint() Endpoint
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  6. internal/handlers/forwarder.go

    package handlers
    
    import (
    	"context"
    	"net"
    	"net/http"
    	"net/http/httputil"
    	"net/url"
    	"strings"
    	"sync"
    	"time"
    )
    
    const defaultFlushInterval = time.Duration(100) * time.Millisecond
    
    // Forwarder forwards all incoming HTTP requests to configured transport.
    type Forwarder struct {
    	RoundTripper http.RoundTripper
    	PassHost     bool
    	Logger       func(error)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Apr 07 05:42:10 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  7. src/archive/tar/writer_test.go

    				Uname:    "dsymonds",
    				Gname:    "eng",
    				ModTime:  time.Unix(1246508266, 0),
    			}, nil},
    			testWrite{"Kilts", 5, nil},
    
    			testHeader{Header{
    				Typeflag: TypeReg,
    				Name:     "small2.txt",
    				Size:     11,
    				Mode:     0640,
    				Uid:      73025,
    				Uname:    "dsymonds",
    				Gname:    "eng",
    				Gid:      5000,
    				ModTime:  time.Unix(1245217492, 0),
    			}, nil},
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Mon Sep 23 14:32:33 UTC 2024
    - 39.4K bytes
    - Viewed (0)
  8. internal/config/etcd/etcd.go

    	"go.uber.org/zap"
    )
    
    const (
    	// Default values used while communicating with etcd.
    	defaultDialTimeout   = 5 * time.Second
    	defaultDialKeepAlive = 30 * time.Second
    )
    
    // etcd environment values
    const (
    	Endpoints     = "endpoints"
    	PathPrefix    = "path_prefix"
    	CoreDNSPath   = "coredns_path"
    	ClientCert    = "client_cert"
    	ClientCertKey = "client_cert_key"
    
    	EnvEtcdEndpoints     = "MINIO_ETCD_ENDPOINTS"
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 28 23:17:22 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  9. src/test/java/org/codelibs/fess/helper/IntervalControlHelperTest.java

            assertEquals(4000, intervalControlHelper.getDelay());
        }
    
        private IntervalControlHelper createHelper(final String time, final int day) throws ParseException {
            final Date date = new SimpleDateFormat("HH:mm").parse(time);
            return new IntervalControlHelper() {
                @Override
                protected Calendar getCurrentCal() {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  10. cmd/admin-handlers-site-replication.go

    	operation := madmin.BktOp(vars["operation"])
    
    	var err error
    	switch operation {
    	default:
    		err = errSRInvalidRequest(errInvalidArgument)
    	case madmin.MakeWithVersioningBktOp:
    		createdAt, cerr := time.Parse(time.RFC3339Nano, strings.TrimSpace(r.Form.Get("createdAt")))
    		if cerr != nil {
    			createdAt = timeSentinel
    		}
    
    		opts := MakeBucketOptions{
    			LockEnabled:       r.Form.Get("lockEnabled") == "true",
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 19.4K bytes
    - Viewed (0)
Back to top