Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 150 for inactive (0.41 sec)

  1. internal/event/target/redis.go

    func (target *RedisTarget) Store() event.TargetStore {
    	return target.store
    }
    
    // IsActive - Return true if target is up and active
    func (target *RedisTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    		return false, err
    	}
    	return target.isActive()
    }
    
    func (target *RedisTarget) isActive() (bool, error) {
    	conn := target.pool.Get()
    	defer conn.Close()
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  2. 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) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  3. internal/event/target/webhook.go

    func (target *WebhookTarget) Name() string {
    	return target.ID().String()
    }
    
    // IsActive - Return true if target is up and active
    func (target *WebhookTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    		return false, err
    	}
    	return target.isActive()
    }
    
    // Store returns any underlying store if set.
    func (target *WebhookTarget) Store() event.TargetStore {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  4. 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
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sat Jun 01 15:02:59 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  5. internal/event/target/amqp.go

    func (target *AMQPTarget) Store() event.TargetStore {
    	return target.store
    }
    
    // IsActive - Return true if target is up and active
    func (target *AMQPTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    		return false, err
    	}
    
    	return target.isActive()
    }
    
    func (target *AMQPTarget) isActive() (bool, error) {
    	ch, _, err := target.channel()
    	if err != nil {
    		return false, err
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 10K bytes
    - Viewed (0)
  6. 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)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15K bytes
    - Viewed (0)
  7. maven-model-builder/src/test/java/org/apache/maven/model/profile/DefaultProfileSelectorTest.java

            DefaultProfileActivationContext context = new DefaultProfileActivationContext();
            SimpleProblemCollector problems = new SimpleProblemCollector();
            List<Profile> active = selector.getActiveProfiles(profiles, context, problems);
            assertTrue(active.isEmpty());
            assertEquals(1, problems.getErrors().size());
            assertEquals(
                    "Failed to determine activation for profile one: BOOM",
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Thu Jun 06 16:51:39 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  8. platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/isolated/IsolatedProjectsBuildFeatureIntegrationTest.groovy

                        println "configurationCache.active=" + buildFeatures.configurationCache.active.get()
                        println "isolatedProjects.requested=" + buildFeatures.isolatedProjects.requested.getOrNull()
                        println "isolatedProjects.active=" + buildFeatures.isolatedProjects.active.get()
                    }
                }
            """
    
            when:
            run "something"
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sat Jun 08 11:29:25 UTC 2024
    - 4K bytes
    - Viewed (0)
  9. guava/src/com/google/common/cache/LocalCache.java

        /**
         * Returns true if this reference contains an active value, meaning one that is still considered
         * present in the cache. Active values consist of live values, which are returned by cache
         * lookups, and dead values, which have been evicted but awaiting removal. Non-active values
         * consist strictly of loading values, though during refresh a value may be both active and
         * loading.
         */
        boolean isActive();
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Sat May 18 03:24:34 UTC 2024
    - 149.2K bytes
    - Viewed (0)
  10. .space/CODEOWNERS

    /kotlin-native/backend.native/tests/**.gradle "Kotlin Native"
    /kotlin-native/backend.native/tests/**/*.gradle.kts "Kotlin Native"
    /kotlin-native/tools/**/*.gradle "Kotlin Native"
    /kotlin-native/tools/**/*.gradle.kts "Kotlin Native"
    /kotlin-native/performance/**/*.gradle "Kotlin Native"
    /kotlin-native/performance/**/*.gradle.kts "Kotlin Native"
    /native/native.tests/*.gradle.kts "Kotlin Native"
    Registered: Wed Jun 12 09:53:16 UTC 2024
    - Last Modified: Wed May 29 17:55:49 UTC 2024
    - 24K bytes
    - Viewed (2)
Back to top