Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 98 for isActive (0.06 seconds)

  1. internal/event/target/postgresql.go

    func (target *PostgreSQLTarget) Store() event.TargetStore {
    	return target.store
    }
    
    // IsActive - Return true if target is up and active
    func (target *PostgreSQLTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    		return false, err
    	}
    	return target.isActive()
    }
    
    func (target *PostgreSQLTarget) isActive() (bool, error) {
    	if err := target.db.Ping(); err != nil {
    		if IsConnErr(err) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 13.3K bytes
    - Click Count (0)
  2. internal/event/target/kafka.go

    func (target *KafkaTarget) Store() event.TargetStore {
    	return target.store
    }
    
    // IsActive - Return true if target is up and active
    func (target *KafkaTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    		return false, err
    	}
    	return target.isActive()
    }
    
    func (target *KafkaTarget) isActive() (bool, error) {
    	// Refer https://github.com/IBM/sarama/issues/1341
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 13.6K bytes
    - Click Count (0)
  3. internal/event/target/elasticsearch.go

    func (target *ElasticsearchTarget) Store() event.TargetStore {
    	return target.store
    }
    
    // IsActive - Return true if target is up and active
    func (target *ElasticsearchTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    		return false, err
    	}
    	return target.isActive()
    }
    
    func (target *ElasticsearchTarget) isActive() (bool, error) {
    	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15K bytes
    - Click Count (0)
  4. compat/maven-compat/src/main/java/org/apache/maven/profiles/activation/JdkPrefixProfileActivator.java

     */
    @Deprecated
    public class JdkPrefixProfileActivator extends DetectedProfileActivator {
        private static final String JDK_VERSION = System.getProperty("java.version");
    
        @Override
        public boolean isActive(Profile profile) throws ProfileActivationException {
            Activation activation = profile.getActivation();
    
            String jdk = activation.getJdk();
    
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 3K bytes
    - Click Count (0)
  5. compat/maven-model-builder/src/test/java/org/apache/maven/model/profile/DefaultProfileSelectorTest.java

        void testThrowingActivator() {
            DefaultProfileSelector selector = new DefaultProfileSelector();
            selector.addProfileActivator(new ProfileActivator() {
                @Override
                public boolean isActive(Profile profile, ProfileActivationContext context, ModelProblemCollector problems) {
                    throw new RuntimeException("BOOM");
                }
    
                @Override
                public boolean presentInConfig(
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Sep 17 10:01:14 GMT 2025
    - 2.9K bytes
    - Click Count (0)
  6. internal/event/target/mysql.go

    func (target *MySQLTarget) Store() event.TargetStore {
    	return target.store
    }
    
    // IsActive - Return true if target is up and active
    func (target *MySQLTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    		return false, err
    	}
    	return target.isActive()
    }
    
    func (target *MySQLTarget) isActive() (bool, error) {
    	if err := target.db.Ping(); err != nil {
    		if IsConnErr(err) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  7. compat/maven-model-builder/src/main/java/org/apache/maven/model/profile/activation/PropertyProfileActivator.java

     */
    @Named("property")
    @Singleton
    @Deprecated(since = "4.0.0")
    public class PropertyProfileActivator implements ProfileActivator {
    
        @Override
        public boolean isActive(Profile profile, ProfileActivationContext context, ModelProblemCollector problems) {
            Activation activation = profile.getActivation();
    
            if (activation == null) {
                return false;
            }
    
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Feb 25 08:27:34 GMT 2025
    - 3.8K bytes
    - Click Count (0)
  8. internal/event/target/nats.go

    func (target *NATSTarget) Store() event.TargetStore {
    	return target.store
    }
    
    // IsActive - Return true if target is up and active
    func (target *NATSTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    		return false, err
    	}
    	return target.isActive()
    }
    
    func (target *NATSTarget) isActive() (bool, error) {
    	var connErr error
    	if target.args.Streaming.Enable {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Apr 27 04:30:57 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  9. compat/maven-compat/src/main/java/org/apache/maven/profiles/activation/ProfileActivator.java

    /**
     * ProfileActivator
     */
    @Deprecated
    public interface ProfileActivator {
    
        String ROLE = ProfileActivator.class.getName();
    
        boolean canDetermineActivation(Profile profile);
    
        boolean isActive(Profile profile) throws ProfileActivationException;
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 1.1K bytes
    - Click Count (0)
  10. src/main/java/jcifs/smb1/netbios/NbtAddress.java

            this.address = address;
            this.groupName = groupName;
            this.nodeType = nodeType;
            this.isBeingDeleted = isBeingDeleted;
            this.isInConflict = isInConflict;
            this.isActive = isActive;
            this.isPermanent = isPermanent;
            this.macAddress = macAddress;
            isDataFromNodeStatus = true;
        }
    
        /* Guess next called name to try for session establishment. These
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 31.7K bytes
    - Click Count (0)
Back to Top