- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 192 for isActive (0.14 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/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) -
subprojects/core/src/main/java/org/gradle/api/internal/FeaturePreviews.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Sep 14 08:15:13 UTC 2022 - 2.5K bytes - Viewed (0) -
src/main/java/jcifs/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; this.isDataFromNodeStatus = true; } /** * {@inheritDoc} *
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 15.2K 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) -
subprojects/core/src/testFixtures/groovy/org/gradle/api/internal/FeaturePreviewsActivationFixture.groovy
static def activeFeatures() { EnumSet<FeaturePreviews.Feature> active = EnumSet.noneOf(FeaturePreviews.Feature) for (FeaturePreviews.Feature feature : FeaturePreviews.Feature.values()) { if (feature.isActive()) { active.add(feature) } } active } static def inactiveFeatures() { def features = EnumSet.allOf(FeaturePreviews.Feature)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 13 13:23:50 UTC 2020 - 1.2K bytes - Viewed (0) -
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;
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Nov 22 13:26:01 UTC 2022 - 1.1K bytes - Viewed (0) -
maven-model-builder/src/main/java/org/apache/maven/model/profile/activation/PackagingProfileActivator.java
/** * Determines profile activation based on the project's packaging. */ @Named("packaging") @Singleton public class PackagingProfileActivator implements ProfileActivator { @Override public boolean isActive( org.apache.maven.model.Profile profile, ProfileActivationContext context, ModelProblemCollector problems) { return getActivationPackaging(profile).map(p -> isPackaging(context, p)).orElse(false); }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu Feb 15 08:42:00 UTC 2024 - 2.4K bytes - Viewed (0)