Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 46 for isActive (0.14 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. api/maven-api-settings/src/main/mdo/settings.mdo

            if (activeProxy == null) {
                java.util.List<Proxy> proxies = getProxies();
                if (proxies != null && !proxies.isEmpty()) {
                    for (Proxy proxy : proxies) {
                        if (proxy.isActive()) {
                            activeProxy = proxy;
                            break;
                        }
                    }
                }
            }
            return activeProxy;
        }
    
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Sat Feb 17 18:40:11 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  8. 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)
  9. internal/config/notify/parse.go

    		if tgts[target.ID().ID] {
    			// When target set should be online
    			yes, err := target.IsActive()
    			if err == nil && !yes {
    				err = ErrTargetsOffline
    			}
    			if err != nil {
    				return fmt.Errorf("error (%s): %w", target.ID(), err)
    			}
    		} else {
    			// Just for call init.
    			// Ignore target is online or offline
    			_, _ = target.IsActive()
    		}
    	}
    
    	return nil
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 46.4K bytes
    - Viewed (0)
  10. docs/en/docs/tutorial/security/simple-oauth2.md

    ```JSON
    {
      "detail": "Not authenticated"
    }
    ```
    
    ### Inactive user
    
    Now try with an inactive user, authenticate with:
    
    User: `alice`
    
    Password: `secret2`
    
    And try to use the operation `GET` with the path `/users/me`.
    
    You will get an "Inactive user" error, like:
    
    ```JSON
    {
      "detail": "Inactive user"
    }
    ```
    
    ## Recap
    
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Thu Apr 18 19:53:19 UTC 2024
    - 12.5K bytes
    - Viewed (0)
Back to top