Search Options

Results per page
Sort
Preferred Languages
Advance

Results 591 - 600 of 908 for Base (0.09 sec)

  1. cmd/bucket-replication-metrics.go

    	if !ok {
    		v = ProxyMetric{}
    	}
    	switch api {
    	case putObjectTaggingAPI:
    		if !isErr {
    			atomic.AddUint64(&v.PutTagTotal, 1)
    			atomic.AddUint64(&p.srProxyStats.PutTagTotal, 1)
    		} else {
    			atomic.AddUint64(&v.PutTagFailedTotal, 1)
    			atomic.AddUint64(&p.srProxyStats.PutTagFailedTotal, 1)
    		}
    	case getObjectTaggingAPI:
    		if !isErr {
    			atomic.AddUint64(&v.GetTagTotal, 1)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  2. internal/once/singleton.go

    // GetNonBlocking will return the singleton value or nil if not set yet.
    func (s *Singleton[T]) GetNonBlocking() *T {
    	select {
    	case <-s.set:
    		return s.v
    	default:
    		return nil
    	}
    }
    
    // IsSet will return whether the singleton has been set.
    func (s *Singleton[T]) IsSet() bool {
    	select {
    	case <-s.set:
    		return true
    	default:
    		return false
    	}
    }
    
    // Set the value and unblock all Get requests.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 952 bytes
    - Viewed (0)
  3. dbflute_fess/dfprop/sequenceMap.dfprop

    # sequenceMap: (NotRequired - Default map:{})
    # 
    # The relation mappings between sequence and table.
    # If you don't specify the mappings, you cannot insert a record of the table by sequence. 
    # The table names are treated as case insensitive.
    # 
    # Example:
    # map:{
    #     ; PURCHASE     = SEQ_PURCHASE
    #     ; MEMBER       = SEQ_MEMBER
    #     ; MEMBER_LOGIN = SEQ_MEMBER_LOGIN
    #     ; PRODUCT      = SEQ_PRODUCT
    # }
    #
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Sat Oct 31 23:35:14 UTC 2015
    - 717 bytes
    - Viewed (0)
  4. cmd/admin-handlers_test.go

    func (c cmdType) toServiceSignal() serviceSignal {
    	switch c {
    	case restartCmd:
    		return serviceRestart
    	case stopCmd:
    		return serviceStop
    	}
    	return serviceRestart
    }
    
    func (c cmdType) toServiceAction() madmin.ServiceAction {
    	switch c {
    	case restartCmd:
    		return madmin.ServiceActionRestart
    	case stopCmd:
    		return madmin.ServiceActionStop
    	}
    	return madmin.ServiceActionRestart
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  5. internal/grid/grid_test.go

    			}
    			for {
    				select {
    				case <-nowBlocking:
    					return
    				case <-st.Done():
    				case st.Requests <- []byte{1}:
    					time.Sleep(10 * time.Millisecond)
    				}
    			}
    		}()
    	}
    	// Check that local returned.
    	err = st.Results(func(b []byte) error {
    		<-st.Done()
    		return ctx.Err()
    	})
    	mu.Lock()
    	select {
    	case <-nowBlocking:
    	default:
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  6. internal/bucket/lifecycle/tag.go

    			var s string
    			if err = d.DecodeElement(&s, &se); err != nil {
    				return err
    			}
    			switch se.Name.Local {
    			case "Key":
    				if keyAlreadyParsed {
    					return errDuplicatedXMLTag
    				}
    				tag.Key = s
    				keyAlreadyParsed = true
    			case "Value":
    				if valueAlreadyParsed {
    					return errDuplicatedXMLTag
    				}
    				tag.Value = s
    				valueAlreadyParsed = true
    			default:
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  7. docs/en/docs/reference/openapi/index.md

    # OpenAPI
    
    There are several utilities to handle OpenAPI.
    
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Wed Oct 18 12:36:40 UTC 2023
    - 158 bytes
    - Viewed (0)
  8. cmd/tier_gen.go

    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		switch msgp.UnsafeString(field) {
    		case "Tiers":
    			var zb0002 uint32
    			zb0002, err = dc.ReadMapHeader()
    			if err != nil {
    				err = msgp.WrapError(err, "Tiers")
    				return
    			}
    			if z.Tiers == nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jun 20 00:53:08 UTC 2023
    - 4K bytes
    - Viewed (0)
  9. clause/delete_test.go

    		},
    		{
    			[]clause.Interface{clause.Delete{Modifier: "LOW_PRIORITY"}, clause.From{}},
    			"DELETE LOW_PRIORITY FROM `users`", nil,
    		},
    	}
    
    	for idx, result := range results {
    		t.Run(fmt.Sprintf("case #%v", idx), func(t *testing.T) {
    			checkBuildClauses(t, result.Clauses, result.Result, result.Vars)
    		})
    	}
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Tue Jun 02 01:18:01 UTC 2020
    - 608 bytes
    - Viewed (0)
  10. internal/bucket/replication/filter.go

    func (f Filter) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
    	if err := e.EncodeToken(start); err != nil {
    		return err
    	}
    
    	switch {
    	case !f.And.isEmpty():
    		if err := e.EncodeElement(f.And, xml.StartElement{Name: xml.Name{Local: "And"}}); err != nil {
    			return err
    		}
    	case !f.Tag.IsEmpty():
    		if err := e.EncodeElement(f.Tag, xml.StartElement{Name: xml.Name{Local: "Tag"}}); err != nil {
    			return err
    		}
    	default:
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Sep 28 18:25:46 UTC 2022
    - 3.5K bytes
    - Viewed (0)
Back to top