- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 150 for inactive (0.16 sec)
-
pkg/controller/deployment/deployment_controller_test.go
// Add a Pod that has matching labels, but no ControllerRef. pod3 := generatePodFromRS(rs1) pod3.Name = "pod3" pod3.OwnerReferences = nil // Add a Pod that has matching labels and ControllerRef, but is inactive. pod4 := generatePodFromRS(rs1) pod4.Name = "pod4" pod4.Status.Phase = v1.PodFailed f.dLister = append(f.dLister, d) f.rsLister = append(f.rsLister, rs1, rs2)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.5K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
// TODO: Do the List and Filter in a single pass, or use an index. allPods, err := rsc.podLister.Pods(rs.Namespace).List(labels.Everything()) if err != nil { return err } // Ignore inactive pods. filteredPods := controller.FilterActivePods(logger, allPods) // NOTE: filteredPods are pointing to objects from cache - if you need to // modify them, you need to copy it first.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
maven-model-builder/src/main/java/org/apache/maven/model/profile/DefaultProfileSelector.java
} private boolean isActive(Profile profile, ProfileActivationContext context, ModelProblemCollector problems) { boolean isActive = false; for (ProfileActivator activator : activators) { if (activator.presentInConfig(profile, context, problems)) { isActive = true; try { if (!activator.isActive(profile, context, problems)) {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu Jun 06 16:51:39 UTC 2024 - 5.2K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/model/DefaultProfileSelector.java
} private boolean isActive(Profile profile, ProfileActivationContext context, ModelProblemCollector problems) { boolean isActive = false; for (ProfileActivator activator : activators) { if (activator.presentInConfig(profile, context, problems)) { isActive = true; try { if (!activator.isActive(profile, context, problems)) {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu Jun 06 16:51:39 UTC 2024 - 4.6K bytes - Viewed (0) -
internal/event/target/nsq.go
func (target *NSQTarget) Store() event.TargetStore { return target.store } // IsActive - Return true if target is up and active func (target *NSQTarget) IsActive() (bool, error) { if err := target.init(); err != nil { return false, err } return target.isActive() } func (target *NSQTarget) isActive() (bool, error) { if target.producer == nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 7.1K bytes - Viewed (0) -
internal/event/target/mqtt.go
func (target *MQTTTarget) Store() event.TargetStore { return target.store } // IsActive - Return true if target is up and active func (target *MQTTTarget) IsActive() (bool, error) { if err := target.init(); err != nil { return false, err } return target.isActive() } func (target *MQTTTarget) isActive() (bool, error) { if !target.client.IsConnectionOpen() { return false, store.ErrNotConnected }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.2K bytes - Viewed (0) -
maven-model-builder/src/main/java/org/apache/maven/model/profile/activation/OperatingSystemProfileActivator.java
} if (active && os.getName() != null) { active = determineNameMatch(os.getName(), actualOsName); } if (active && os.getArch() != null) { active = determineArchMatch(os.getArch(), actualOsArch); } if (active && os.getVersion() != null) { active = determineVersionMatch(os.getVersion(), actualOsVersion); }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Jun 05 14:16:41 UTC 2024 - 4.9K bytes - Viewed (0) -
internal/config/lambda/target/webhook.go
func (target *WebhookTarget) ID() event.TargetID { return target.id } // 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() } // errNotConnected - indicates that the target connection is not active. var errNotConnected = errors.New("not connected to target server/service")
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6.7K 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)