- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 398 for durable (0.09 sec)
-
internal/event/target/amqp.go
ExchangeType string `json:"exchangeType"` DeliveryMode uint8 `json:"deliveryMode"` Mandatory bool `json:"mandatory"` Immediate bool `json:"immediate"` Durable bool `json:"durable"` Internal bool `json:"internal"` NoWait bool `json:"noWait"` AutoDeleted bool `json:"autoDeleted"` PublisherConfirms bool `json:"publisherConfirms"`
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 10K bytes - Viewed (0) -
internal/config/notify/parse.go
Mandatory: env.Get(mandatoryEnv, kv.Get(target.AmqpMandatory)) == config.EnableOn, Immediate: env.Get(immediateEnv, kv.Get(target.AmqpImmediate)) == config.EnableOn, Durable: env.Get(durableEnv, kv.Get(target.AmqpDurable)) == config.EnableOn, Internal: env.Get(internalEnv, kv.Get(target.AmqpInternal)) == config.EnableOn,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 47K bytes - Viewed (0) -
CREDITS
in one of these ways: a) Convey the object code in, or embodied in, a physical product (including a physical distribution medium), accompanied by the Corresponding Source fixed on a durable physical medium customarily used for software interchange. b) Convey the object code in, or embodied in, a physical product (including a physical distribution medium), accompanied by a
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 26 15:03:08 UTC 2024 - 1.6M bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/ResolutionNode.java
for (ResolutionNode node : children) { node.enable(); } } } public void disable() { active = false; if (children != null) { for (ResolutionNode node : children) { node.disable(); } } } public boolean filterTrail(ArtifactFilter filter) throws OverConstrainedVersionException {
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 6.6K bytes - Viewed (0) -
internal/config/errors.go
$ minio server /data-{1...4}/minio # Single Node Multi Drive`, ) ErrUnsupportedBackend = newErrFn( "Unable to write to the backend", "Please ensure your drive supports O_DIRECT", "", ) ErrUnableToWriteInBackend = newErrFn( "Unable to write to the backend", "Please ensure MinIO binary has write permissions for the backend",
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 10 16:57:01 UTC 2024 - 9.3K bytes - Viewed (0) -
common/config/.golangci.yml
- prefix(istio.io/) # Groups all imports with the specified Prefix. gocritic: # Disable all checks. # Default: false disable-all: true # Which checks should be enabled in addition to default checks. Since we don't want # all of the default checks, we do the disable-all first. enabled-checks: - appendCombine - argOrder - assignOp - badCond
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Oct 24 17:36:49 UTC 2024 - 11.7K bytes - Viewed (0) -
cmd/config-current.go
configLogIf(ctx, fmt.Errorf("Unable to load drive config: %w", err)) } else { if err = globalDriveConfig.Update(driveConfig); err != nil { configLogIf(ctx, fmt.Errorf("Unable to update drive config: %v", err)) } } case config.BrowserSubSys: browserCfg, err := browser.LookupConfig(s[config.BrowserSubSys][config.Default]) if err != nil { errs = append(errs, fmt.Errorf("Unable to apply browser config: %w", err))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 03 18:23:41 UTC 2024 - 30.1K bytes - Viewed (0) -
cmd/admin-handlers-users_test.go
Policies: []string{policy1}, User: accessKey, }) if err != nil { c.Fatalf("unable to detach policy: %v", err) } // 3.2 associate policy to user _, err = s.adm.AttachPolicy(ctx, madmin.PolicyAssociationReq{ Policies: []string{policy2}, User: accessKey, }) if err != nil { c.Fatalf("unable to attach policy: %v", err) } // 3.3 check user can create service account implicitly.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 22 00:33:43 UTC 2024 - 47.3K bytes - Viewed (0) -
cmd/common-main.go
if err != nil { logger.FatalIf(err, "Unable to get free port for Console UI on the host") } // hold the port l, err := net.Listen("TCP", fmt.Sprintf(":%s", p.String())) if err == nil { defer l.Close() } consoleAddr = net.JoinHostPort("", p.String()) } if _, _, err := net.SplitHostPort(consoleAddr); err != nil { logger.FatalIf(err, "Unable to start listening on console port") }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 24 21:50:11 UTC 2024 - 31.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/ImmutableRangeSetTest.java
assertEquals(mutable, copy); } ImmutableRangeSet<Integer> built = builder.build(); assertEquals(mutable, built); assertEquals(ImmutableRangeSet.copyOf(mutable), built); assertEquals(mutable.complement(), built.complement()); for (int i = 0; i <= 11; i++) { assertEquals(mutable.contains(i), built.contains(i)); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jul 02 18:21:29 UTC 2024 - 21.5K bytes - Viewed (0)