- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 387 for connectat (0.17 sec)
-
maven-api-impl/src/main/java/org/apache/maven/internal/impl/DefaultTransport.java
import java.nio.file.Files; import java.nio.file.Path; import java.util.Optional; import org.apache.maven.api.services.Transport; import org.eclipse.aether.spi.connector.transport.GetTask; import org.eclipse.aether.spi.connector.transport.PutTask; import org.eclipse.aether.spi.connector.transport.Transporter; import static java.util.Objects.requireNonNull; public class DefaultTransport implements Transport { private final URI baseURI;
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu May 02 16:33:18 UTC 2024 - 5.3K bytes - Viewed (0) -
platforms/software/resources-s3/src/main/java/org/gradle/internal/resource/transport/aws/s3/S3ResourcesServices.java
import org.gradle.authentication.aws.AwsImAuthentication; import org.gradle.internal.authentication.AuthenticationSchemeRegistry; import org.gradle.internal.authentication.DefaultAwsImAuthentication; import org.gradle.internal.resource.connector.ResourceConnectorFactory; import org.gradle.internal.service.Provides; import org.gradle.internal.service.ServiceRegistration; import org.gradle.internal.service.ServiceRegistrationProvider;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 2.1K bytes - Viewed (0) -
cmd/kube-apiserver/app/server.go
if err != nil { return err } prepared, err := server.PrepareRun() if err != nil { return err } return prepared.Run(ctx) } // CreateServerChain creates the apiservers connected via delegation. func CreateServerChain(config CompletedConfig) (*aggregatorapiserver.APIAggregator, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 17:44:20 UTC 2024 - 10.2K bytes - Viewed (0) -
cni/pkg/pluginlistener/listener_test.go
f := filepath.Join(t.TempDir(), "test") l, err := NewListener(f) if err != nil { t.Fatalf("unexpected error %v", err) } defer l.Close() conn, err := connect(f) if err != nil { t.Fatalf("failed to connect %v", err) } conn.Close() } func connect(socket string) (*grpc.ClientConn, error) { var opts []grpc.DialOption
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 08 21:58:32 UTC 2024 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/SingleUseDaemonClient.java
private static final Logger LOGGER = Logging.getLogger(SingleUseDaemonClient.class); private final DocumentationRegistry documentationRegistry; public SingleUseDaemonClient( DaemonConnector connector, OutputEventListener outputEventListener, ExplainingSpec<DaemonContext> compatibilitySpec, InputStream buildStandardInput, GlobalUserInputReceiver userInput,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 3.1K bytes - Viewed (0) -
pilot/pkg/networking/core/waypoint.go
// ConnectTerminate is the name for the resources associated with the termination of HTTP CONNECT. ConnectTerminate = "connect_terminate" // MainInternalName is the name for the resources associated with the main (non-tunnel) internal listener. MainInternalName = "main_internal" // ConnectOriginate is the name for the resources associated with the origination of HTTP CONNECT. ConnectOriginate = "connect_originate"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 3.8K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/repositories/transport/RepositoryTransportFactory.java
import org.gradle.internal.resource.ExternalResourceName; import org.gradle.internal.resource.cached.CachedExternalResourceIndex; import org.gradle.internal.resource.connector.ResourceConnectorFactory; import org.gradle.internal.resource.connector.ResourceConnectorSpecification; import org.gradle.internal.resource.local.FileResourceRepository; import org.gradle.internal.resource.transfer.ExternalResourceConnector;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Mar 25 14:54:57 UTC 2024 - 11.4K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r56/TestLauncherDebugTestsCrossVersionTest.groovy
org.junit.Assert.assertEquals(1, 1); } } """ } def "build fails if debugger is not ready"() { setup: // port is assigned but not connected def port = jdwpClient.port when: withConnection { connection -> connection.newTestLauncher() .withJvmTestClasses("example.MyTest")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 16 10:10:39 UTC 2024 - 3.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/CallConnectionUser.kt
} override fun removePlanToCancel(connectPlan: ConnectPlan) { call.plansToCancel -= connectPlan } override fun updateRouteDatabaseAfterSuccess(route: Route) { call.client.routeDatabase.connected(route) } override fun connectStart(route: Route) { eventListener.connectStart(call, route.socketAddress, route.proxy) poolConnectionListener.connectStart(route, call) }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Mar 06 17:33:38 UTC 2024 - 3.6K bytes - Viewed (0) -
internal/event/target/nats.go
if !filepath.IsAbs(n.QueueDir) { return errors.New("queueDir path should be absolute") } } return nil } // To obtain a nats connection from args. func (n NATSArgs) connectNats() (*nats.Conn, error) { connOpts := []nats.Option{nats.Name("Minio Notification"), nats.MaxReconnects(-1)} if n.Username != "" && n.Password != "" { connOpts = append(connOpts, nats.UserInfo(n.Username, n.Password)) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 12.8K bytes - Viewed (0)