- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 150 for isActive (0.13 sec)
-
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) -
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) -
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/profiles/activation/JdkPrefixProfileActivator.java
* JdkPrefixProfileActivator */ @Deprecated public class JdkPrefixProfileActivator extends DetectedProfileActivator { private static final String JDK_VERSION = System.getProperty("java.version"); public boolean isActive(Profile profile) throws ProfileActivationException { Activation activation = profile.getActivation(); String jdk = activation.getJdk();
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu Sep 14 11:48:15 UTC 2023 - 3K bytes - Viewed (0) -
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(
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu Jun 06 16:51:39 UTC 2024 - 2.8K bytes - Viewed (0) -
maven-model-builder/src/test/java/org/apache/maven/model/profile/activation/AbstractProfileActivatorTest.java
} protected void assertActivation(boolean active, Profile profile, ProfileActivationContext context) { SimpleProblemCollector problems = new SimpleProblemCollector(); assertEquals(active, activator.isActive(new org.apache.maven.model.Profile(profile), context, problems)); assertEquals(0, problems.getErrors().size(), problems.getErrors().toString());
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 08:39:32 UTC 2023 - 2.4K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/model/profile/PackagingProfileActivator.java
/** * Determines profile activation based on the project's packaging. */ @Named("packaging") @Singleton public class PackagingProfileActivator implements ProfileActivator { @Override public boolean isActive(Profile profile, ProfileActivationContext context, ModelProblemCollector problems) { return getActivationPackaging(profile).map(p -> isPackaging(context, p)).orElse(false); } @Override
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Apr 12 10:50:18 UTC 2024 - 2.3K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/profiles/activation/OperatingSystemProfileActivator.java
public boolean canDetermineActivation(Profile profile) { Activation activation = profile.getActivation(); return activation != null && activation.getOs() != null; } public boolean isActive(Profile profile) { Activation activation = profile.getActivation(); ActivationOS os = activation.getOs(); boolean result = ensureAtLeastOneNonNull(os);
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Sep 22 06:01:36 UTC 2023 - 3.7K bytes - Viewed (0)