Search Options

Results per page
Sort
Preferred Languages
Advance

Results 351 - 360 of 1,214 for Func (0.02 sec)

  1. cmd/metrics-resource.go

    }
    
    // Describe sends the super-set of all possible descriptors of metrics
    func (c *minioResourceCollector) Describe(ch chan<- *prometheus.Desc) {
    	ch <- c.desc
    }
    
    // Collect is called by the Prometheus registry when collecting metrics.
    func (c *minioResourceCollector) Collect(out chan<- prometheus.Metric) {
    	var wg sync.WaitGroup
    	publish := func(in <-chan MetricV2) {
    		defer wg.Done()
    		for metric := range in {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 23:30:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  2. cmd/jwt.go

    		}
    
    		groups = ucred.Groups
    	}
    
    	return claims, groups, owner, nil
    }
    
    // newCachedAuthToken returns the cached token.
    func newCachedAuthToken() func() string {
    	return func() string {
    		return globalNodeAuthToken
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  3. internal/event/target/elasticsearch.go

    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *ElasticsearchTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    func (target *ElasticsearchTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *ElasticsearchTarget) Store() event.TargetStore {
    	return target.store
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  4. internal/bucket/lifecycle/prefix.go

    }
    
    // UnmarshalXML - decodes XML data.
    func (p *Prefix) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) {
    	var s string
    	if err = d.DecodeElement(&s, &start); err != nil {
    		return err
    	}
    	*p = Prefix{string: s, set: true}
    	return nil
    }
    
    // MarshalXML - decodes XML data.
    func (p Prefix) MarshalXML(e *xml.Encoder, startElement xml.StartElement) error {
    	if !p.set {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 15 14:45:25 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  5. internal/config/dns/store.go

    type ErrInvalidBucketName Error
    
    func (e ErrInvalidBucketName) Error() string {
    	return e.Bucket + " invalid bucket name error: " + e.Err.Error()
    }
    
    func (e Error) Error() string {
    	return "dns related error: " + e.Err.Error()
    }
    
    // ErrBucketConflict for buckets that already exist
    type ErrBucketConflict Error
    
    func (e ErrBucketConflict) Error() string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.6K bytes
    - Viewed (0)
  6. clause/returning.go

    package clause
    
    type Returning struct {
    	Columns []Column
    }
    
    // Name where clause name
    func (returning Returning) Name() string {
    	return "RETURNING"
    }
    
    // Build build where clause
    func (returning Returning) Build(builder Builder) {
    	if len(returning.Columns) > 0 {
    		for idx, column := range returning.Columns {
    			if idx > 0 {
    				builder.WriteByte(',')
    			}
    
    			builder.WriteQuoted(column)
    		}
    	} else {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Oct 27 23:56:55 UTC 2021
    - 681 bytes
    - Viewed (0)
  7. cmd/erasure-metadata-utils_test.go

    	if err != nil {
    		removeRoots(disks)
    		t.Fatal(err)
    	}
    	defer removeRoots(disks)
    	z := objLayer.(*erasureServerPools)
    	testShuffleDisks(t, z)
    }
    
    func Test_hashOrder(t *testing.T) {
    	for x := 1; x < 17; x++ {
    		t.Run(fmt.Sprintf("%d", x), func(t *testing.T) {
    			var first [17]int
    			rng := rand.New(rand.NewSource(0))
    			var tmp [16]byte
    			rng.Read(tmp[:])
    			prefix := hex.EncodeToString(tmp[:])
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  8. cmd/api-headers.go

    	xxml "github.com/minio/xxml"
    )
    
    // Returns a hexadecimal representation of time at the
    // time response is sent to the client.
    func mustGetRequestID(t time.Time) string {
    	return fmt.Sprintf("%X", t.UnixNano())
    }
    
    // setEventStreamHeaders to allow proxies to avoid buffering proxy responses
    func setEventStreamHeaders(w http.ResponseWriter) {
    	w.Header().Set(xhttp.ContentType, "text/event-stream")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 28 04:44:00 UTC 2024
    - 7K bytes
    - Viewed (0)
  9. internal/once/init.go

    }
    
    // Do is similar to sync.Once.Do - makes one successful
    // call to the function. ie, it invokes the function
    // if it is not successful yet.
    func (l *Init) Do(f func() error) error {
    	if atomic.LoadUint32(&l.done) == 0 {
    		return l.do(f)
    	}
    	return nil
    }
    
    func (l *Init) do(f func() error) error {
    	l.m.Lock()
    	defer l.m.Unlock()
    	if atomic.LoadUint32(&l.done) == 0 {
    		if err := f(); err != nil {
    			return err
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 09 04:20:31 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  10. clause/locking.go

    	LockingOptionsNoWait     = "NOWAIT"
    )
    
    type Locking struct {
    	Strength string
    	Table    Table
    	Options  string
    }
    
    // Name where clause name
    func (locking Locking) Name() string {
    	return "FOR"
    }
    
    // Build build where clause
    func (locking Locking) Build(builder Builder) {
    	builder.WriteString(locking.Strength)
    	if locking.Table.Name != "" {
    		builder.WriteString(" OF ")
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Dec 15 08:32:56 UTC 2023
    - 773 bytes
    - Viewed (0)
Back to top