Search Options

Results per page
Sort
Preferred Languages
Advance

Results 531 - 540 of 1,214 for Func (0.02 sec)

  1. cmd/batch-replicate_gen.go

    func (z BatchJobReplicateCredentials) Msgsize() (s int) {
    	s = 1 + 10 + msgp.StringPrefixSize + len(z.AccessKey) + 10 + msgp.StringPrefixSize + len(z.SecretKey) + 13 + msgp.StringPrefixSize + len(z.SessionToken)
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *BatchJobReplicateFlags) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 40.7K bytes
    - Viewed (0)
  2. internal/s3select/select_benchmark_test.go

    	return buf.Bytes()
    }
    
    type nullResponseWriter struct{}
    
    func (w *nullResponseWriter) Header() http.Header {
    	return nil
    }
    
    func (w *nullResponseWriter) Write(p []byte) (int, error) {
    	return len(p), nil
    }
    
    func (w *nullResponseWriter) WriteHeader(statusCode int) {
    }
    
    func (w *nullResponseWriter) Flush() {
    }
    
    func benchmarkSelect(b *testing.B, count int, query string) {
    	requestXML := []byte(`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 14 13:54:47 UTC 2022
    - 5K bytes
    - Viewed (0)
  3. cmd/erasure-decode.go

    		stashBuffer:   b,
    	}
    }
    
    // Done will release any resources used by the parallelReader.
    func (p *parallelReader) Done() {
    	if p.stashBuffer != nil {
    		globalBytePoolCap.Load().Put(p.stashBuffer)
    		p.stashBuffer = nil
    	}
    }
    
    // preferReaders can mark readers as preferred.
    // These will be chosen before others.
    func (p *parallelReader) preferReaders(prefer []bool) {
    	if len(prefer) != len(p.orgReaders) {
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  4. cmd/bootstrap-messages.go

    	mu   sync.RWMutex
    	info []madmin.TraceInfo
    }
    
    var globalBootstrapTracer = &bootstrapTracer{}
    
    func (bs *bootstrapTracer) Record(info madmin.TraceInfo) {
    	bs.mu.Lock()
    	defer bs.mu.Unlock()
    
    	if len(bs.info) > bootstrapTraceLimit {
    		return
    	}
    	bs.info = append(bs.info, info)
    }
    
    func (bs *bootstrapTracer) Events() []madmin.TraceInfo {
    	traceInfo := make([]madmin.TraceInfo, 0, bootstrapTraceLimit)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 23 10:07:06 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  5. clause/from.go

    package clause
    
    // From from clause
    type From struct {
    	Tables []Table
    	Joins  []Join
    }
    
    // Name from clause name
    func (from From) Name() string {
    	return "FROM"
    }
    
    // Build build from clause
    func (from From) Build(builder Builder) {
    	if len(from.Tables) > 0 {
    		for idx, table := range from.Tables {
    			if idx > 0 {
    				builder.WriteByte(',')
    			}
    
    			builder.WriteQuoted(table)
    		}
    	} else {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jul 15 02:25:10 UTC 2020
    - 630 bytes
    - Viewed (0)
  6. cmd/benchmark-utils_test.go

    func getRandomByte() []byte {
    	const letterBytes = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ"
    	// seeding the random number generator.
    	rand.Seed(UTCNow().UnixNano())
    	// pick a character randomly.
    	return []byte{letterBytes[rand.Intn(len(letterBytes))]}
    }
    
    // picks a random byte and repeats it to size bytes.
    func generateBytesData(size int) []byte {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Dec 23 15:46:00 UTC 2022
    - 8.2K bytes
    - Viewed (0)
  7. cmd/storage-datatypes_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"bytes"
    	"encoding/gob"
    	"io"
    	"testing"
    	"time"
    
    	"github.com/tinylib/msgp/msgp"
    )
    
    func BenchmarkDecodeVolInfoMsgp(b *testing.B) {
    	v := VolInfo{
    		Name:    "uuid",
    		Created: time.Now(),
    	}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 9.4K bytes
    - Viewed (0)
  8. internal/event/name_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package event
    
    import (
    	"encoding/json"
    	"encoding/xml"
    	"reflect"
    	"testing"
    )
    
    func TestNameExpand(t *testing.T) {
    	testCases := []struct {
    		name           Name
    		expectedResult []Name
    	}{
    		{BucketCreated, []Name{BucketCreated}},
    		{BucketRemoved, []Name{BucketRemoved}},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 01:11:10 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  9. cmd/bucket-object-lock.go

    	"github.com/minio/pkg/v3/policy"
    )
    
    // BucketObjectLockSys - map of bucket and retention configuration.
    type BucketObjectLockSys struct{}
    
    // Get - Get retention configuration.
    func (sys *BucketObjectLockSys) Get(bucketName string) (r objectlock.Retention, err error) {
    	config, _, err := globalBucketMetadataSys.GetObjectLockConfig(bucketName)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  10. cmd/erasure-object.go

    // Read(Closer). When err != nil, the returned reader is always nil.
    func (er erasureObjects) GetObjectNInfo(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, h http.Header, opts ObjectOptions) (gr *GetObjectReader, err error) {
    	if !opts.NoAuditLog {
    		auditObjectErasureSet(ctx, "GetObject", object, &er)
    	}
    
    	var unlockOnDefer bool
    	nsUnlocker := func() {}
    	defer func() {
    		if unlockOnDefer {
    			nsUnlocker()
    		}
    	}()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
Back to top