- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 228 for rslave (0.15 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)