Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 677 for Contexto (0.2 sec)

  1. tests/connpool_test.go

    	c.conn.got = append(c.conn.got, query)
    	return c.Tx.ExecContext(ctx, query, args...)
    }
    
    func (c *wrapperTx) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error) {
    	c.conn.got = append(c.conn.got, query)
    	return c.Tx.QueryContext(ctx, query, args...)
    }
    
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Tue Feb 06 02:54:40 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  2. tensorflow/c/eager/parallel_device/parallel_device_lib_test.cc

      }
      std::unique_ptr<TFE_Op, decltype(&TFE_DeleteOp)> read_op(
          TFE_NewOp(context.get(), "ReadVariableOp", status.get()), TFE_DeleteOp);
      ASSERT_TRUE(TF_GetCode(status.get()) == TF_OK) << TF_Message(status.get());
      TFE_OpSetAttrType(read_op.get(), "dtype", TF_FLOAT);
      parallel_device.Execute(context.get(), handle_inputs, "ReadVariableOp",
                              TFE_OpGetAttrs(read_op.get()),
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Mon Oct 21 04:14:14 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  3. internal/logger/targets.go

    //
    //	e.g. Send the log to a http server
    type Target interface {
    	String() string
    	Endpoint() string
    	Stats() types.TargetStats
    	Init(ctx context.Context) error
    	IsOnline(ctx context.Context) bool
    	Cancel()
    	Send(ctx context.Context, entry interface{}) error
    	Type() types.TargetType
    }
    
    type targetsList struct {
    	list []Target
    	mu   sync.RWMutex
    }
    
    func newTargetsList() *targetsList {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 03 15:44:50 UTC 2024
    - 6K bytes
    - Viewed (0)
  4. internal/grid/README.md

    The handler function has this signature.
    
    Sample handler:
    ```go
        handler :=  func(ctx context.Context, payload []byte, in <-chan []byte, out chan<- []byte) *RemoteErr {
            fmt.Println("Got request with initial payload", p, "from", GetCaller(ctx context.Context))
            fmt.Println("Subroute:", GetSubroute(ctx))
            for {
                select {
                case <-ctx.Done():
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  5. internal/grid/stream.go

    	// Canceling the context will cause the context cancellation error to be returned.
    	responses <-chan Response
    	cancel    context.CancelCauseFunc
    
    	// Requests sent to the server.
    	// If the handler is defined with 0 incoming capacity this will be nil.
    	// Channel *must* be closed to signal the end of the stream.
    	// If the request context is canceled, the stream will no longer process requests.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  6. internal/config/dns/etcd_dns.go

    			key := msgPath(fmt.Sprintf("%s.%s", bucket, domainName), c.prefixPath)
    			key = key + etcdPathSeparator + ip
    			ctx, cancel := context.WithTimeout(context.Background(), defaultContextTimeout)
    			_, err = c.etcdClient.Put(ctx, key, string(bucketMsg))
    			cancel()
    			if err != nil {
    				ctx, cancel = context.WithTimeout(context.Background(), defaultContextTimeout)
    				c.etcdClient.Delete(ctx, key)
    				cancel()
    				return err
    			}
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 26 15:03:08 UTC 2024
    - 8K bytes
    - Viewed (0)
  7. cmd/etcd.go

    	return etcdErrToErr(err, client.Endpoints())
    }
    
    func deleteKeyEtcd(ctx context.Context, client *etcd.Client, key string) error {
    	timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout)
    	defer cancel()
    
    	_, err := client.Delete(timeoutCtx, key)
    	etcdLogIf(ctx, err)
    	return etcdErrToErr(err, client.Endpoints())
    }
    
    func readKeyEtcd(ctx context.Context, client *etcd.Client, key string) ([]byte, error) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  8. api/go1.9.txt

    pkg runtime/pprof, func Do(context.Context, LabelSet, func(context.Context))
    pkg runtime/pprof, func ForLabels(context.Context, func(string, string) bool)
    pkg runtime/pprof, func Label(context.Context, string) (string, bool)
    pkg runtime/pprof, func Labels(...string) LabelSet
    pkg runtime/pprof, func SetGoroutineLabels(context.Context)
    pkg runtime/pprof, func WithLabels(context.Context, LabelSet) context.Context
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Mon Oct 04 20:20:20 UTC 2021
    - 10.7K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/query/WildcardQueryCommand.java

            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            final String field = getSearchField(context.getDefaultField(), wildcardQuery.getField());
            if (Constants.DEFAULT_FIELD.equals(field)) {
                final String text = wildcardQuery.getTerm().text();
                context.addFieldLog(field, text);
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  10. internal/once/init.go

    	return nil
    }
    
    // DoWithContext is similar to Do except that it accepts a context as an argument to be passed.
    func (l *Init) DoWithContext(ctx context.Context, f func(context.Context) error) error {
    	if atomic.LoadUint32(&l.done) == 0 {
    		return l.doWithContext(ctx, f)
    	}
    	return nil
    }
    
    func (l *Init) doWithContext(ctx context.Context, f func(context.Context) error) error {
    	l.m.Lock()
    	defer l.m.Unlock()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue May 09 04:20:31 UTC 2023
    - 2.1K bytes
    - Viewed (0)
Back to top