- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 54 for isActive (0.28 sec)
-
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/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) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.5K bytes - Viewed (0) -
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 {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 12.8K 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-compat/src/main/java/org/apache/maven/repository/legacy/resolver/DefaultLegacyArtifactCollector.java
resolvedArtifacts.put(key, previousNodes); } previousNodes.add(node); if (node.isActive()) { fireEvent(ResolutionListener.INCLUDE_ARTIFACT, listeners, node); } // don't pull in the transitive deps of a system-scoped dependency. if (node.isActive() && !Artifact.SCOPE_SYSTEM.equals(node.getArtifact().getScope())) {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 11:28:54 UTC 2023 - 36.7K bytes - Viewed (0) -
api/maven-api-settings/src/main/mdo/settings.mdo
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Sat Feb 17 18:40:11 UTC 2024 - 33.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/initialization/DefaultSettings.java
@Inject public abstract SourceControl getSourceControl(); @Override public void enableFeaturePreview(String name) { Feature feature = Feature.withName(name); if (feature.isActive()) { services.get(FeatureFlags.class).enable(feature); } else { DeprecationLogger .deprecate("enableFeaturePreview('" + feature.name() + "')")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 18:31:24 UTC 2023 - 14.3K bytes - Viewed (0) -
settings.gradle.kts
// Internal utility and verification projects unassigned { subproject("internal-build-reports") } rootProject.name = "gradle" FeaturePreviews.Feature.values().forEach { feature -> if (feature.isActive) { enableFeaturePreview(feature.name) } } fun remoteBuildCacheEnabled(settings: Settings) = settings.buildCache.remote?.isEnabled == true fun getBuildJavaHome() = System.getProperty("java.home")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:14 UTC 2024 - 16.4K bytes - Viewed (0)