Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 1,087 for contextos (0.07 sec)

  1. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  2. association.go

    			relValuesMap, _ := schema.GetIdentityFieldValuesMapFromValues(association.DB.Statement.Context, values, rel.FieldSchema.PrimaryFields)
    
    			cleanUpDeletedRelations := func(data reflect.Value) {
    				if _, zero := rel.Field.ValueOf(association.DB.Statement.Context, data); !zero {
    					fieldValue := reflect.Indirect(rel.Field.ReflectValueOf(association.DB.Statement.Context, data))
    					primaryValues := make([]interface{}, len(rel.FieldSchema.PrimaryFields))
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jun 12 10:49:45 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  3. internal/event/targetlist_test.go

    	return nil
    }
    
    func TestTargetListAdd(t *testing.T) {
    	targetListCase1 := NewTargetList(context.Background())
    
    	targetListCase2 := NewTargetList(context.Background())
    	if err := targetListCase2.Add(&ExampleTarget{TargetID{"2", "testcase"}, false, false}); err != nil {
    		panic(err)
    	}
    
    	targetListCase3 := NewTargetList(context.Background())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Dec 05 10:16:33 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  4. internal/config/crypto_test.go

    )
    
    var encryptDecryptTests = []struct {
    	Data    []byte
    	Context kms.Context
    }{
    	{
    		Data:    nil,
    		Context: nil,
    	},
    	{
    		Data:    []byte{1},
    		Context: nil,
    	},
    	{
    		Data:    []byte{1},
    		Context: kms.Context{"key": "value"},
    	},
    	{
    		Data:    make([]byte, 1<<20),
    		Context: kms.Context{"key": "value", "a": "b"},
    	},
    }
    
    func TestEncryptDecrypt(t *testing.T) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/query/PrefixQueryCommand.java

            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            final String field = getSearchField(context.getDefaultField(), prefixQuery.getField());
            final String text = prefixQuery.getPrefix().text();
    
            if (Constants.DEFAULT_FIELD.equals(field)) {
                context.addFieldLog(field, text + "*");
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  6. cmd/site-replication-utils.go

    }
    
    func newSiteResyncMetrics(ctx context.Context) *siteResyncMetrics {
    	s := siteResyncMetrics{
    		resyncStatus:  make(map[string]SiteResyncStatus),
    		peerResyncMap: make(map[string]resyncState),
    	}
    	go s.save(ctx)
    	go s.init(ctx)
    	return &s
    }
    
    // init site resync metrics
    func (sm *siteResyncMetrics) init(ctx context.Context) {
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/ntlmssp/Type2Message.java

         *
         * @param context The local security context.
         */
        public void setContext(byte[] context) {
            this.context = context;
        }
    
        public byte[] toByteArray() {
            try {
                String targetName = getTarget();
                byte[] challenge = getChallenge();
                byte[] context = getContext();
                byte[] targetInformation = getTargetInformation();
                int flags = getFlags();
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 12.6K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/base/package-info.java

     * the License.
     */
    
    /**
     * Basic utility libraries and interfaces.
     *
     * <p>This package is a part of the open-source <a href="https://github.com/google/guava">Guava</a>
     * library.
     *
     * <h2>Contents</h2>
     *
     * The classes in this package that are most commonly useful are:
     *
     * <h3>String utilities</h3>
     *
     * <ul>
     *   <li>{@link Ascii}
     *   <li>{@link CaseFormat}
     *   <li>{@link CharMatcher}
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 16:48:06 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  9. cmd/data-usage.go

    		cachevalue.Opts{ReturnLastGood: true, NoWait: true},
    		func(ctx context.Context) (map[string]uint64, error) {
    			m := make(map[string]uint64)
    			for _, pool := range z.serverPools {
    				for _, er := range pool.sets {
    					// Load bucket usage prefixes
    					ctx, done := context.WithTimeout(ctx, 2*time.Second)
    					ok := cache.load(ctx, er, bucket+slashSeparator+dataUsageCacheName) == nil
    					done()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 5.6K 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 09 04:20:31 UTC 2023
    - 2.1K bytes
    - Viewed (0)
Back to top