Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 228 for rslave (0.15 sec)

  1. internal/logger/console.go

    	// and freely move in the screen.
    	for _, line := range strings.Split(errMsg, "\n") {
    		if len(line) == 0 {
    			// No more text to print, just quit.
    			break
    		}
    
    		for {
    			// Save the attributes of the current cursor helps
    			// us save the text color of the passed error message
    			ansiSaveAttributes()
    			// Print banner with or without the log tag
    			if !tagPrinted {
    				fmt.Fprint(Output, logBanner)
    				tagPrinted = true
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  2. cmd/handler-utils.go

    		}
    	}
    
    	if contentEncoding, ok := metadata[strings.ToLower(xhttp.ContentEncoding)]; ok {
    		contentEncoding = trimAwsChunkedContentEncoding(contentEncoding)
    		if contentEncoding != "" {
    			// Make sure to trim and save the content-encoding
    			// parameter for a streaming signature which is set
    			// to a custom value for example: "aws-chunked,gzip".
    			metadata[strings.ToLower(xhttp.ContentEncoding)] = contentEncoding
    		} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  3. cmd/tier.go

    	}
    	// Copy over the new tier configs
    	for tier, cfg := range newConfig.Tiers {
    		config.Tiers[tier] = cfg
    	}
    	config.lastRefreshedAt = UTCNow()
    	return nil
    }
    
    // Save saves tier configuration onto objAPI
    func (config *TierConfigMgr) Save(ctx context.Context, objAPI ObjectLayer) error {
    	if objAPI == nil {
    		return errServerNotInitialized
    	}
    
    	pr, opts, err := globalTierConfigMgr.configReader(ctx)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  4. tests/multi_primary_keys_test.go

    	}
    
    	blog := Blog{
    		Locale:  "ZH",
    		Subject: "subject",
    		Body:    "body",
    		Tags: []Tag{
    			{Locale: "ZH", Value: "tag1"},
    			{Locale: "ZH", Value: "tag2"},
    		},
    	}
    
    	DB.Save(&blog)
    	if !compareTags(blog.Tags, []string{"tag1", "tag2"}) {
    		t.Fatalf("Blog should has two tags")
    	}
    
    	// Append
    	tag3 := &Tag{Locale: "ZH", Value: "tag3"}
    	DB.Model(&blog).Association("Tags").Append([]*Tag{tag3})
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jan 06 07:02:53 UTC 2022
    - 12.8K bytes
    - Viewed (0)
  5. cni/pkg/plugin/testdata/tproxy.txt.golden

    -A ISTIO_INBOUND -p tcp --dport 15090 -j RETURN
    -A ISTIO_INBOUND -p tcp -m conntrack --ctstate RELATED,ESTABLISHED -j ISTIO_DIVERT
    -A ISTIO_INBOUND -p tcp -j ISTIO_TPROXY
    -A PREROUTING -p tcp -m mark --mark 1337 -j CONNMARK --save-mark
    -A OUTPUT -p tcp -o lo -m mark --mark 1337 -j RETURN
    -A OUTPUT ! -d 127.0.0.1/32 -p tcp -o lo -m owner --uid-owner 1337 -j MARK --set-mark 1338
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Feb 16 22:54:20 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  6. cmd/batch-rotate.go

    		JobType:   string(job.Type()),
    		StartTime: job.Started,
    	}
    	if err := ri.loadOrInit(ctx, api, job); err != nil {
    		return err
    	}
    	if ri.Complete {
    		return nil
    	}
    
    	globalBatchJobsMetrics.save(job.ID, ri)
    	lastObject := ri.Object
    
    	retryAttempts := job.KeyRotate.Flags.Retry.Attempts
    	if retryAttempts <= 0 {
    		retryAttempts = batchKeyRotateJobDefaultRetries
    	}
    	delay := job.KeyRotate.Flags.Retry.Delay
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  7. impl/maven-core/src/main/java/org/apache/maven/artifact/repository/RepositoryCache.java

    // this here, possibly indefinitely.
    //
    public interface RepositoryCache {
    
        /**
         * Puts the specified data into the cache. <strong>Warning:</strong> The cache will directly save the provided
         * reference. If the cached data is mutable, i.e. could be modified after being put into the cache, the caller is
         * responsible for creating a copy of the original data and store the copy in the cache.
         *
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/app/web/base/FessAdminAction.java

        /**
         * {@inheritDoc} <br>
         * Application Origin Methods:
         * <pre>
         * <span style="font-size: 130%; color: #553000">[Small Helper]</span>
         * o saveInfo() <span style="color: #3F7E5E">// save messages to session</span>
         * o write() <span style="color: #3F7E5E">// write text to specified file</span>
         * o copyBeanToBean() <span style="color: #3F7E5E">// copy bean to bean by BeanUtil</span>
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb1/util/MD4.java

            byte[] tail = new byte[padLen + 8];
            tail[0] = (byte)0x80;
    
            // append length before final transform:
            // save number of bits, casting the long to an array of 8 bytes
            // save low-order byte first.
            for (int i = 0; i < 8; i++)
                tail[padLen + i] = (byte)((count * 8) >>> (8 * i));
    
            engineUpdate(tail, 0, tail.length);
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 9.3K bytes
    - Viewed (0)
  10. internal/event/target/amqp.go

    		if !confirmed.Ack {
    			return fmt.Errorf("failed delivery of delivery tag: %d", confirmed.DeliveryTag)
    		}
    	}
    
    	return nil
    }
    
    // Save - saves the events to the store which will be replayed when the amqp connection is active.
    func (target *AMQPTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    	if err := target.init(); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
Back to top