Search Options

Results per page
Sort
Preferred Languages
Advance

Results 321 - 330 of 391 for ctx_ (0.04 sec)

  1. cmd/metrics-v3-system-network.go

    		"Total number of bytes received from other peer nodes")
    )
    
    // loadNetworkInternodeMetrics - reads internode network metrics.
    //
    // This is a `MetricsLoaderFn`.
    func loadNetworkInternodeMetrics(ctx context.Context, m MetricValues, _ *metricsCache) error {
    	connStats := globalConnStats.toServerConnStats()
    	rpcStats := rest.GetRPCStats()
    	if globalIsDistErasure {
    		m.Set(internodeErrorsTotal, float64(rpcStats.Errs))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 10 09:15:15 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  2. docs_src/sql_databases_peewee/sql_app/database.py

    from contextvars import ContextVar
    
    import peewee
    
    DATABASE_NAME = "test.db"
    db_state_default = {"closed": None, "conn": None, "ctx": None, "transactions": None}
    db_state = ContextVar("db_state", default=db_state_default.copy())
    
    
    class PeeweeConnectionState(peewee._ConnectionState):
        def __init__(self, **kwargs):
            super().__setattr__("_state", db_state)
            super().__init__(**kwargs)
    
        def __setattr__(self, name, value):
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Mar 26 19:09:53 UTC 2020
    - 662 bytes
    - Viewed (0)
  3. internal/grid/trace.go

    	TraceType madmin.TraceType
    	Prefix    string
    	Local     string
    	Remote    string
    	Subroute  string
    }
    
    const (
    	httpScheme  = "http://"
    	httpsScheme = "https://"
    )
    
    func (c *muxClient) traceRoundtrip(ctx context.Context, t *tracer, h HandlerID, req []byte) ([]byte, error) {
    	if t == nil || t.Publisher.NumSubscribers(t.TraceType) == 0 {
    		return c.roundtrip(h, req)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  4. gorm.go

    	}
    
    	if config.Initialized {
    		tx = tx.getInstance()
    	}
    
    	return tx
    }
    
    // WithContext change current instance db's context to ctx
    func (db *DB) WithContext(ctx context.Context) *DB {
    	return db.Session(&Session{Context: ctx})
    }
    
    // Debug start debug mode
    func (db *DB) Debug() (tx *DB) {
    	tx = db.getInstance()
    	return tx.Session(&Session{
    		Logger: db.Logger.LogMode(logger.Info),
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Oct 09 11:29:48 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  5. cmd/erasure-coding.go

    type Erasure struct {
    	encoder                  func() reedsolomon.Encoder
    	dataBlocks, parityBlocks int
    	blockSize                int64
    }
    
    // NewErasure creates a new ErasureStorage.
    func NewErasure(ctx context.Context, dataBlocks, parityBlocks int, blockSize int64) (e Erasure, err error) {
    	// Check the parameters for sanity now.
    	if dataBlocks <= 0 || parityBlocks < 0 {
    		return e, reedsolomon.ErrInvShardNum
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  6. tests/test_security_oauth2.py

                        "loc": ["body", "grant_type"],
                        "msg": "String should match pattern 'password'",
                        "input": "incorrect",
                        "ctx": {"pattern": "password"},
                    }
                ]
            }
        ) | IsDict(
            # TODO: remove when deprecating Pydantic v1
            {
                "detail": [
                    {
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:40:57 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  7. tests/test_security_oauth2_optional_description.py

                        "loc": ["body", "grant_type"],
                        "msg": "String should match pattern 'password'",
                        "input": "incorrect",
                        "ctx": {"pattern": "password"},
                    }
                ]
            }
        ) | IsDict(
            # TODO: remove when deprecating Pydantic v1
            {
                "detail": [
                    {
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:40:57 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  8. cmd/data-usage_test.go

    			sizeS.versions++
    			return sizeS, nil
    		}
    		return
    	}
    	xls := xlStorage{drivePath: base, diskInfoCache: cachevalue.New[DiskInfo]()}
    	xls.diskInfoCache.InitOnce(time.Second, cachevalue.Opts{}, func(ctx context.Context) (DiskInfo, error) {
    		return DiskInfo{Total: 1 << 40, Free: 1 << 40}, nil
    	})
    	weSleep := func() bool { return false }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/job/UpdateLabelJob.java

                        if (StringUtil.isNotBlank(url)) {
                            final Set<String> labelSet = labelTypeHelper.getMatchedLabelValueSet(url);
                            final Script script = languageHelper.createScript(doc, "ctx._source." + fessConfig.getIndexFieldLabel()
                                    + "=new String[]{" + labelSet.stream().map(s -> "\"" + s + "\"").collect(Collectors.joining(",")) + "}");
                            return builder.setScript(script);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  10. internal/kms/config.go

    		go func() {
    			timer := time.NewTicker(10 * time.Second)
    			defer timer.Stop()
    			defaultKey := env.Get(EnvKESDefaultKey, "")
    			for {
    				select {
    				case <-ctx.Done():
    					return
    				case <-timer.C:
    					client.DescribeKey(ctx, defaultKey)
    				}
    			}
    		}()
    
    		return &KMS{
    			Type:       MinKES,
    			DefaultKey: env.Get(EnvKESDefaultKey, ""),
    			conn: &kesConn{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 11:46:39 UTC 2024
    - 14.2K bytes
    - Viewed (0)
Back to top