Search Options

Results per page
Sort
Preferred Languages
Advance

Results 451 - 460 of 532 for Configure (0.18 sec)

  1. internal/event/target/mqtt.go

    	}
    
    	if err = target.send(eventData); err != nil {
    		return err
    	}
    
    	// Delete the event from store.
    	return target.store.Del(key)
    }
    
    // Save - saves the events to the store if queuestore is configured, which will
    // be replayed when the mqtt connection is active.
    func (target *MQTTTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  2. cmd/bucket-lifecycle.go

    		ctx:          ctx,
    		killCh:       make(chan struct{}),
    		lastDayStats: make(map[string]*lastDayTierStats),
    	}
    }
    
    // Init initializes t with given objAPI and instantiates the configured number
    // of transition workers.
    func (t *transitionState) Init(objAPI ObjectLayer) {
    	n := globalAPIConfig.getTransitionWorkers()
    	// Prefer ilm.transition_workers over now deprecated api.transition_workers
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  3. internal/event/target/redis.go

    		if xnet.IsConnRefusedErr(pingErr) {
    			return false, store.ErrNotConnected
    		}
    		return false, pingErr
    	}
    	return true, nil
    }
    
    // Save - saves the events to the store if questore is configured, which will be replayed when the redis connection is active.
    func (target *RedisTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  4. compat/maven-compat/src/main/java/org/apache/maven/project/DefaultMavenProjectBuilder.java

                 * resolution failures, in particular when using the enhanced local repo which guards access to local files
                 * based on the configured remote repos.
                 */
                MavenSession session = legacySupport.getSession();
                if (session != null) {
                    MavenExecutionRequest req = session.getRequest();
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  5. compat/maven-compat/src/main/java/org/apache/maven/project/artifact/DefaultMavenMetadataCache.java

                    if (pomFile.canRead()) {
                        return length != pomFile.length() || timestamp != pomFile.lastModified();
                    } else {
                        // if the POM didn't exist, retry if any repo is configured to always update
                        boolean snapshot = pomArtifact.isSnapshot();
                        for (ArtifactRepository repository : remoteRepositories) {
                            ArtifactRepositoryPolicy policy =
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  6. cmd/metrics-v2.go

    	for k, v := range m.VariableLabels {
    		metric.VariableLabels[k] = v
    	}
    	for k, v := range m.Histogram {
    		metric.Histogram[k] = v
    	}
    	return metric
    }
    
    // Get - returns cached value always upton the configured TTL,
    // once the TTL expires "read()" registered function is called
    // to return the new values and updated.
    func (g *MetricsGroupV2) Get() (metrics []MetricV2) {
    	m, _ := g.metricsCache.Get()
    	if len(m) == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
  7. cmd/batch-expire.go

    	err := val.Decode(&tmp)
    	if err != nil {
    		return err
    	}
    
    	*r = BatchJobExpire(tmp)
    	r.line, r.col = val.Line, val.Column
    	return nil
    }
    
    // Notify notifies notification endpoint if configured regarding job failure or success.
    func (r BatchJobExpire) Notify(ctx context.Context, body io.Reader) error {
    	if r.NotificationCfg.Endpoint == "" {
    		return nil
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  8. api/maven-api-core/src/main/java/org/apache/maven/api/package-info.java

     * <li>Check Local Repository: Maven first checks if the artifact is available in the local repository.</li>
     * <li>Check Remote Repositories: If the artifact is not found locally, Maven queries the configured remote repositories in the order they are listed.</li>
     * <li>Download and Cache: If Maven finds the artifact in a remote repository, it downloads it and stores it in the local repository for future use.</li>
     * </ol>
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Tue Aug 27 21:13:34 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  9. compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/AbstractMojo.java

         * </p>
         * <strong>Note:</strong>
         * The logger returned by this method must not be cached in an instance field during the construction of the mojo.
         * This would cause the mojo to use a wrongly configured default logger when being run by Maven. The proper logger
         * gets injected by the Plexus container after the mojo has been constructed. Therefore, simply call this
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  10. cmd/bootstrap-peer-server.go

    	envs := env.List("MINIO_")
    	envValues := make(map[string]string, len(envs))
    	for _, envK := range envs {
    		// skip certain environment variables as part
    		// of the whitelist and could be configured
    		// differently on each nodes, update skipEnvs()
    		// map if there are such environment values
    		if _, ok := skipEnvs[envK]; ok {
    			continue
    		}
    		envValues[envK] = logger.HashString(env.Get(envK, ""))
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
Back to top