Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 391 for ctx_ (0.07 sec)

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

    	}
    }
    
    func loadProcFSMetrics(ctx context.Context, p procfs.Proc, m MetricValues) {
    	stat, err := p.Stat()
    	if err != nil {
    		metricsLogIf(ctx, err)
    	} else {
    		loadProcStatMetrics(ctx, stat, m)
    	}
    
    	io, err := p.IO()
    	if err != nil {
    		metricsLogIf(ctx, err)
    	} else {
    		loadProcIOMetrics(ctx, io, m)
    	}
    
    	l, err := p.Limits()
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jun 20 17:55:03 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  2. interfaces.go

    }
    
    type ParamsFilter interface {
    	ParamsFilter(ctx context.Context, sql string, params ...interface{}) (string, []interface{})
    }
    
    // ConnPool db conns pool interface
    type ConnPool interface {
    	PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
    	ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
    	QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Aug 19 13:33:31 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  3. internal/logger/audit.go

    func SetAuditEntry(ctx context.Context, audit *audit.Entry) context.Context {
    	if ctx == nil {
    		LogIf(context.Background(), "audit", fmt.Errorf("context is nil"))
    		return nil
    	}
    	return context.WithValue(ctx, contextAuditKey, audit)
    }
    
    // GetAuditEntry returns Audit entry if set.
    func GetAuditEntry(ctx context.Context) *audit.Entry {
    	if ctx != nil {
    		r, ok := ctx.Value(contextAuditKey).(*audit.Entry)
    		if ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  4. internal/logger/target/http/http.go

    // Init validate and initialize the http target
    func (h *Target) Init(ctx context.Context) (err error) {
    	if h.config.QueueDir != "" {
    		return h.initQueueOnce.DoWithContext(ctx, h.initDiskStore)
    	}
    	return h.initQueueOnce.DoWithContext(ctx, h.initMemoryStore)
    }
    
    func (h *Target) initDiskStore(ctx context.Context) (err error) {
    	ctx, cancel := context.WithCancel(ctx)
    	h.storeCtxCancel = cancel
    	h.lastStarted = time.Now()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  5. internal/cachevalue/cache.go

    func NewFromFunc[T any](ttl time.Duration, opts Opts, update func(ctx context.Context) (T, error)) *Cache[T] {
    	return &Cache[T]{
    		ttl:      ttl,
    		updateFn: update,
    		opts:     opts,
    	}
    }
    
    // InitOnce initializes the cache with a TTL and an update function. It is
    // guaranteed to be called only once.
    func (t *Cache[T]) InitOnce(ttl time.Duration, opts Opts, update func(ctx context.Context) (T, error)) {
    	t.Once.Do(func() {
    		t.ttl = ttl
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  6. cmd/admin-handlers_test.go

    }
    
    // prepareAdminErasureTestBed - helper function that setups a single-node
    // Erasure backend for admin-handler tests.
    func prepareAdminErasureTestBed(ctx context.Context) (*adminErasureTestBed, error) {
    	ctx, cancel := context.WithCancel(ctx)
    
    	// reset global variables to start afresh.
    	resetTestGlobals()
    
    	// Set globalIsErasure to indicate that the setup uses an erasure
    	// code backend.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  7. tests/test_tutorial/test_query_param_models/test_tutorial002.py

                            "input": "150",
                            "ctx": {"le": 100},
                        },
                        {
                            "type": "greater_than_equal",
                            "loc": ["query", "offset"],
                            "msg": "Input should be greater than or equal to 0",
                            "input": "-1",
                            "ctx": {"ge": 0},
                        },
                        {
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Sep 17 18:54:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  8. tensorflow/c/eager/gradients_test.cc

        AbstractContext* ctx, absl::Span<AbstractTensorHandle* const> inputs,
        absl::Span<AbstractTensorHandle*> outputs) {
      Tape tape(/*persistent=*/false);
      tape.Watch(inputs[0]);
      AbstractTensorHandle* neg_output;
      TF_RETURN_IF_ERROR(ops::Neg(ctx, inputs[0], &neg_output, "Neg"));
      tape.RecordOperation(inputs, {neg_output}, nullptr, "Neg");
      return tape.ComputeGradient(ctx,
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 7K bytes
    - Viewed (0)
  9. cmd/bucket-metadata.go

    func readBucketMetadata(ctx context.Context, api ObjectLayer, name string) (BucketMetadata, error) {
    	if name == "" {
    		internalLogIf(ctx, errors.New("bucket name cannot be empty"), logger.WarningKind)
    		return BucketMetadata{}, errInvalidArgument
    	}
    	b := newBucketMetadata(name)
    	configFile := path.Join(bucketMetaPrefix, name, bucketMetadataFile)
    	data, err := readConfig(ctx, api, configFile)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  10. internal/grid/handlers.go

    	}
    	switch any(req).(type) {
    	case *MSS, *URLValues:
    		ctx = context.WithValue(ctx, TraceParamsKey{}, req)
    	case *NoPayload, *Bytes:
    		// do not need to trace nopayload and bytes payload
    	default:
    		ctx = context.WithValue(ctx, TraceParamsKey{}, fmt.Sprintf("type=%T", req))
    	}
    	if h.callReuseReq {
    		defer h.recycleReq(req)
    	}
    	res, err := c.Request(ctx, h.id, payload)
    	PutByteBuffer(payload)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
Back to top