- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 150 for inactive (0.41 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/isolated/IsolatedProjectsBuildFeatureIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 4K bytes - Viewed (0) -
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) -
.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)