Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 101 - 110 of 1,037 for score (0.02 seconds)

  1. internal/event/target/nsq.go

    			return nil, fmt.Errorf("unable to initialize the queue store of NSQ `%s`: %w", id, err)
    		}
    	}
    
    	target := &NSQTarget{
    		id:         event.TargetID{ID: id, Name: "nsq"},
    		args:       args,
    		loggerOnce: loggerOnce,
    		store:      queueStore,
    		quitCh:     make(chan struct{}),
    	}
    
    	if target.store != nil {
    		store.StreamItems(target.store, target, target.quitCh, target.loggerOnce)
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  2. internal/event/target/postgresql.go

    }
    
    // Name - returns the Name of the target.
    func (target *PostgreSQLTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 13.3K bytes
    - Click Count (0)
  3. internal/event/target/redis.go

    // Name - returns the Name of the target.
    func (target *RedisTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    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
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 9.1K bytes
    - Click Count (0)
  4. compat/maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/scopes/Maven4ScopeManagerConfiguration.java

    import org.eclipse.aether.impl.scope.BuildScopeMatrixSource;
    import org.eclipse.aether.impl.scope.BuildScopeSource;
    import org.eclipse.aether.impl.scope.CommonBuilds;
    import org.eclipse.aether.impl.scope.InternalScopeManager;
    import org.eclipse.aether.impl.scope.ScopeManagerConfiguration;
    import org.eclipse.aether.internal.impl.scope.ScopeManagerDump;
    
    import static org.eclipse.aether.impl.scope.BuildScopeQuery.all;
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 9.2K bytes
    - Click Count (0)
  5. compat/maven-compat/src/test/resources/local-repo/snapshot-test/poms/maven-test-snapshot-resolving-1.0.pom

          <version>1.0-SNAPSHOT</version>
          <type>jar</type>
          <scope>compile</scope>
        </dependency>
        <dependency>
          <groupId>snapshot-test</groupId>
          <artifactId>maven-snapshot-b</artifactId>
          <version>1.0-SNAPSHOT</version>
          <type>jar</type>
          <scope>compile</scope>
        </dependency>
        <dependency>
          <groupId>snapshot-test</groupId>
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 1.4K bytes
    - Click Count (0)
  6. compat/maven-compat/src/test/resources/projects/scope/transitive-compile-dep.xml

        </dependency>
    
        <dependency>
          <groupId>maven-test-compile</groupId>
          <artifactId>scope-runtime</artifactId>
          <version>1.0</version>
          <scope>runtime</scope>
        </dependency>
    
        <dependency>
          <groupId>maven-test-compile</groupId>
          <artifactId>scope-compile</artifactId>
          <version>1.0</version>
          <scope>compile</scope>
        </dependency>
      </dependencies>
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 1.7K bytes
    - Click Count (0)
  7. impl/maven-core/src/main/java/org/apache/maven/session/scope/internal/SessionScopeModule.java

    public class SessionScopeModule extends AbstractModule {
        private final SessionScope scope;
    
        @Inject
        public SessionScopeModule() {
            this(new SessionScope());
        }
    
        public SessionScopeModule(SessionScope scope) {
            this.scope = scope;
        }
    
        @Override
        protected void configure() {
            bindScope(SessionScoped.class, scope);
            // bindScope(org.apache.maven.api.di.SessionScoped.class, scope);
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 2.1K bytes
    - Click Count (0)
  8. internal/event/target/amqp.go

    	connMutex  sync.Mutex
    	store      store.Store[event.Event]
    	loggerOnce logger.LogOnce
    
    	quitCh chan struct{}
    }
    
    // ID - returns TargetID.
    func (target *AMQPTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    func (target *AMQPTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 21 04:25:07 GMT 2025
    - 10K bytes
    - Click Count (0)
  9. tests/test_dependency_yield_scope_websockets.py

    
    def test_broken_scope() -> None:
        with pytest.raises(
            FastAPIError,
            match='The dependency "get_named_func_session" has a scope of "request", it cannot depend on dependencies with scope "function"',
        ):
    
            @app.websocket("/broken-scope")
            async def get_broken(
                websocket: WebSocket, sessions: BrokenSessionsDep
            ) -> Any:  # pragma: no cover
                pass
    
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 21:25:59 GMT 2025
    - 6K bytes
    - Click Count (0)
  10. compat/maven-artifact/src/main/java/org/apache/maven/artifact/DefaultArtifact.java

        }
    
        @Override
        public void setDependencyTrail(List<String> dependencyTrail) {
            this.dependencyTrail = dependencyTrail;
        }
    
        @Override
        public void setScope(String scope) {
            this.scope = scope;
        }
    
        @Override
        public VersionRange getVersionRange() {
            return versionRange;
        }
    
        @Override
        public void setVersionRange(VersionRange versionRange) {
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Jul 23 17:27:08 GMT 2025
    - 14.6K bytes
    - Click Count (0)
Back to Top