Search Options

Results per page
Sort
Preferred Languages
Advance

Results 861 - 870 of 938 for Nil$ (0.02 sec)

  1. cmd/kms-router.go

    	kmsRouter := router.PathPrefix(kmsPathPrefix).Subrouter()
    
    	KMSVersions := []string{
    		kmsAPIVersionPrefix,
    	}
    
    	gz, err := gzhttp.NewWrapper(gzhttp.MinSize(1000), gzhttp.CompressionLevel(gzip.BestSpeed))
    	if err != nil {
    		// Static params, so this is very unlikely.
    		logger.Fatal(err, "Unable to initialize server")
    	}
    
    	for _, version := range KMSVersions {
    		// KMS Status APIs
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  2. internal/rest/rpc-stats.go

    		},
    		ConnectStart: func(network, addr string) {
    			atomic.StoreInt64(&dialStart, time.Now().UnixNano())
    		},
    		ConnectDone: func(network, addr string, err error) {
    			if err == nil {
    				atomic.StoreInt64(&dialEnd, time.Now().UnixNano())
    			}
    		},
    	}
    
    	return req.WithContext(httptrace.WithClientTrace(req.Context(), trace)), func() {
    		if ds := atomic.LoadInt64(&dialStart); ds > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 18:21:34 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  3. internal/event/target/nsq_test.go

    		t.Run(tt.name, func(t *testing.T) {
    			n := NSQArgs{
    				Enable:      tt.fields.Enable,
    				NSQDAddress: tt.fields.NSQDAddress,
    				Topic:       tt.fields.Topic,
    			}
    			if err := n.Validate(); (err != nil) != tt.wantErr {
    				t.Errorf("NSQArgs.Validate() error = %v, wantErr %v", err, tt.wantErr)
    			}
    		})
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  4. docs/lambda/README.md

    )
    
    func main() {
    	s3Client, err := minio.New("localhost:9000", &minio.Options{
    		Creds:  credentials.NewStaticV4("minioadmin", "minioadmin", ""),
    		Secure: false,
    	})
    	if err != nil {
    		log.Fatalln(err)
    	}
    
    	// Set lambda function target via `lambdaArn`
    	reqParams := make(url.Values)
    	reqParams.Set("lambdaArn", "arn:minio:s3-object-lambda::function:webhook")
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Apr 04 19:15:28 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  5. tests/sql_builder_test.go

    	user3 := User{Name: "RowUser3", Age: 20}
    	DB.Save(&user1).Save(&user2).Save(&user3)
    
    	row := DB.Table("users").Where("name = ?", user2.Name).Select("age").Row()
    
    	var age int64
    	if err := row.Scan(&age); err != nil {
    		t.Fatalf("Failed to scan age, got %v", err)
    	}
    
    	if age != 10 {
    		t.Errorf("Scan with Row, age expects: %v, got %v", user2.Age, age)
    	}
    
    	table := "gorm.users"
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Jan 12 08:42:21 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  6. cmd/bucket-replication-metrics.go

    	r.Register("replication.active_workers", h)
    	return &ActiveWorkerStat{
    		hist: h,
    	}
    }
    
    // update curr and max workers;
    func (a *ActiveWorkerStat) update() {
    	if a == nil {
    		return
    	}
    	a.Curr = globalReplicationPool.Get().ActiveWorkers()
    	a.hist.Update(int64(a.Curr))
    	a.Avg = float32(a.hist.Mean())
    	a.Max = int(a.hist.Max())
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  7. cmd/bucket-stats.go

    			ReplicatedCount:                  st.ReplicatedCount,
    			Failed:                           st.Failed,
    			FailStats:                        st.FailStats,
    		}
    		if s.Failed.ErrCounts == nil {
    			s.Failed.ErrCounts = make(map[string]int)
    			for k, v := range st.Failed.ErrCounts {
    				s.Failed.ErrCounts[k] = v
    			}
    		}
    		c.Stats[arn] = &s
    	}
    	return c
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 11:39:51 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  8. cmd/os-dirent_namelen_linux.go

    	nameLen := bytes.IndexByte(nameBuf[:limit], 0)
    	if nameLen < 0 {
    		return 0, fmt.Errorf("failed to find terminating 0 byte in dirent")
    	}
    	return uint64(nameLen), nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 1.5K bytes
    - Viewed (0)
  9. cmd/api-datatypes.go

    }
    
    // MarshalXML encodes expiration date if it is non-zero and encodes
    // empty string otherwise
    func (t DeleteMarkerMTime) MarshalXML(e *xml.Encoder, startElement xml.StartElement) error {
    	if t.Time.IsZero() {
    		return nil
    	}
    	return e.EncodeElement(t.Time.Format(time.RFC3339), startElement)
    }
    
    // ObjectV object version key/versionId
    type ObjectV struct {
    	ObjectName string `xml:"Key"`
    	VersionID  string `xml:"VersionId"`
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 14 07:26:50 UTC 2024
    - 3K bytes
    - Viewed (0)
  10. internal/s3select/jstream/scanner.go

    			close(sr.fillReady)
    		}()
    
    		for range sr.fillReq {
    		scan:
    			n, err := r.Read(sr.nbuf[:])
    
    			if n == 0 {
    				switch err {
    				case io.EOF: // reader is exhausted
    					return
    				case nil: // no data and no error, retry fill
    					goto scan
    				default: // unexpected reader error
    					sr.readerErr = err
    					return
    				}
    			}
    
    			rpos += int64(n)
    			sr.fillReady <- int64(n)
    		}
    	}()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 2.5K bytes
    - Viewed (0)
Back to top