- Sort Score
- Num 10 results
- Language All
Results 101 - 110 of 1,037 for score (0.04 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)