Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 333 for durable (0.14 sec)

  1. 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)
  2. LICENSE

    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: Fri Apr 23 18:58:53 UTC 2021
    - 33.7K bytes
    - Viewed (0)
  3. internal/config/notify/legacy.go

    		},
    		config.KV{
    			Key:   target.AmqpInternal,
    			Value: config.FormatBool(cfg.Immediate),
    		},
    		config.KV{
    			Key:   target.AmqpDurable,
    			Value: config.FormatBool(cfg.Durable),
    		},
    		config.KV{
    			Key:   target.AmqpNoWait,
    			Value: config.FormatBool(cfg.NoWait),
    		},
    		config.KV{
    			Key:   target.AmqpAutoDeleted,
    			Value: config.FormatBool(cfg.AutoDeleted),
    		},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 19 04:37:54 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/resolver/DefaultLegacyArtifactCollector.java

                                nearest.disable();
                                farthest.getArtifact()
                                        .setVersion(nearest.getArtifact().getVersion());
                                fireEvent(ResolutionListener.OMIT_FOR_NEARER, listeners, nearest, farthest.getArtifact());
                            } else {
                                farthest.disable();
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 36.7K bytes
    - Viewed (0)
Back to top