Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 1,840 for caClient (0.05 sec)

  1. cmd/lock-rest-client.go

    	"context"
    	"errors"
    
    	"github.com/minio/minio/internal/dsync"
    	"github.com/minio/minio/internal/grid"
    )
    
    // lockRESTClient is authenticable lock REST client
    type lockRESTClient struct {
    	connection *grid.Connection
    }
    
    // IsOnline - returns whether REST client failed to connect or not.
    func (c *lockRESTClient) IsOnline() bool {
    	return c.connection.State() == grid.StateConnected
    }
    
    // Not a local locker
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  2. cmd/peer-rest-client.go

    }
    
    // Stringer provides a canonicalized representation of node.
    func (client *peerRESTClient) String() string {
    	return client.host.String()
    }
    
    // IsOnline returns true if the peer client is online.
    func (client *peerRESTClient) IsOnline() bool {
    	conn := client.gridConn()
    	if conn == nil {
    		return false
    	}
    	return client.restClient.IsOnline() || conn.State() == grid.StateConnected
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  3. istioctl/pkg/xds/client.go

    Xiaopeng Han <******@****.***> 1703025762 +0800
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Dec 19 22:42:42 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt

        assertThat(client.processNextFrame()).isFalse()
        client.listener.assertClosing(1000, "Goodbye!")
        client.webSocket!!.finishReader()
        server.listener.assertClosed(1000, "Hello!")
        client.listener.assertClosed(1000, "Goodbye!")
      }
    
      @Test
      fun clientCloseThenMethodsReturnFalse() {
        client.webSocket!!.close(1000, "Hello!")
        assertThat(client.webSocket!!.close(1000, "Hello!")).isFalse()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 01:59:58 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  5. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/CrawlerClientFactoryTest.java

            url = "smb1:/home/hoge";
            client = clientFactory.getClient(url);
            assertNotNull(client);
            assertTrue(client instanceof org.codelibs.fess.crawler.client.smb1.SmbClient);
    
            url = "ftp:/home/hoge";
            client = clientFactory.getClient(url);
            assertNotNull(client);
            assertTrue(client instanceof FtpClient);
    
            url = "storage:/home/hoge";
            client = clientFactory.getClient(url);
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/DispatcherTest.kt

        client.newWebSocket(newRequest("http://a/2"), webSocketListener)
        client.newWebSocket(newRequest("http://a/3"), webSocketListener)
        executor.assertJobs("http://a/1", "http://a/2", "http://a/3")
      }
    
      @Test
      fun increasingMaxRequestsPromotesJobsImmediately() {
        dispatcher.maxRequests = 2
        client.newCall(newRequest("http://a/1")).enqueue(callback)
        client.newCall(newRequest("http://b/1")).enqueue(callback)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Fri Apr 05 03:30:42 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  7. tests/test_default_response_class.py

        with client:
            response = client.get("/a/override")
        assert response.content == b"Hello A"
        assert response.headers["content-type"] == text_type
    
    
    def test_router_a_a():
        with client:
            response = client.get("/a/a")
        assert response.json() == {"msg": "Hello A A"}
        assert response.headers["content-type"] == orjson_type
    
    
    def test_router_a_a_override():
        with client:
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Mar 01 20:49:20 UTC 2020
    - 5.2K bytes
    - Viewed (0)
  8. tests/test_tutorial/test_bigger_applications/test_main.py

    import pytest
    from dirty_equals import IsDict
    from fastapi.testclient import TestClient
    
    
    @pytest.fixture(name="client")
    def get_client():
        from docs_src.bigger_applications.app.main import app
    
        client = TestClient(app)
        return client
    
    
    def test_users_token_jessica(client: TestClient):
        response = client.get("/users?token=jessica")
        assert response.status_code == 200
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:40:57 UTC 2024
    - 24.6K bytes
    - Viewed (0)
  9. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/AbstractCrawlerClientTest.java

            };
            ResponseData responseData = new ResponseData();
            responseData.setUrl("http://test.com/");
            client.setMaxContentLength(1000000L);
    
            client.checkMaxContentLength(responseData);
    
            responseData.setContentLength(-1);
            client.checkMaxContentLength(responseData);
    
            responseData.setContentLength(1000L);
            client.checkMaxContentLength(responseData);
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 3K bytes
    - Viewed (0)
  10. cmd/etcd.go

    }
    
    func saveKeyEtcd(ctx context.Context, client *etcd.Client, key string, data []byte, opts ...options) error {
    	timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout)
    	defer cancel()
    	if len(opts) > 0 {
    		return saveKeyEtcdWithTTL(ctx, client, key, data, opts[0].ttl)
    	}
    	_, err := client.Put(timeoutCtx, key, string(data))
    	etcdLogIf(ctx, err)
    	return etcdErrToErr(err, client.Endpoints())
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 2.9K bytes
    - Viewed (0)
Back to top