Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for Observer (0.17 sec)

  1. cmd/server_test.go

    // Setting up the test suite.
    // Starting the Test server with temporary backend.
    func (s *TestSuiteCommon) SetUpSuite(c *check) {
    	if s.secure {
    		cert, key, err := generateTLSCertKey("127.0.0.1")
    		c.Assert(err, nil)
    
    		s.testServer = StartTestTLSServer(c, s.serverType, cert, key)
    	} else {
    		s.testServer = StartTestServer(c, s.serverType)
    	}
    
    	s.client = s.testServer.Server.Client()
    	s.endPoint = s.testServer.Server.URL
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 108K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/CallTest.kt

        callback.await(server.url("/a")).assertBody("abc")
        client.newCall(Request.Builder().url(server.url("/b")).build()).enqueue(callback)
        callback.await(server.url("/b")).assertBody("def")
        client.newCall(Request.Builder().url(server.url("/c")).build()).enqueue(callback)
        callback.await(server.url("/c")).assertBody("ghi")
        assertThat(server.takeRequest().sequenceNumber).isEqualTo(0)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 10 19:46:48 GMT 2024
    - 142.5K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/CacheTest.kt

        )
        server.enqueue(
          MockResponse.Builder()
            .body("B")
            .build(),
        )
        assertThat(get(server.url("/a")).body.string()).isEqualTo("A")
        assertThat(get(server.url("/a")).body.string()).isEqualTo("A")
        assertThat(get(server.url("/b")).body.string()).isEqualTo("B")
        assertThat(server.takeRequest().sequenceNumber).isEqualTo(0)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 10 19:46:48 GMT 2024
    - 108.6K bytes
    - Viewed (0)
  4. cmd/admin-handlers.go

    			for _, server := range infoMessage.Servers {
    				anonEndpoint := anonAddr(server.Endpoint)
    				servers = append(servers, madmin.ServerInfo{
    					State:    server.State,
    					Endpoint: anonEndpoint,
    					Uptime:   server.Uptime,
    					Version:  server.Version,
    					CommitID: server.CommitID,
    					Network:  anonymizeNetwork(server.Network),
    					Drives:   anonymizeDrives(server.Disks),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
  5. CHANGELOG/CHANGELOG-1.30.md

    ### Server Binaries
    
    filename | sha512 hash
    -------- | -----------
    [kubernetes-server-linux-amd64.tar.gz](https://dl.k8s.io/v1.30.0/kubernetes-server-linux-amd64.tar.gz) | `320c934728b8720b08da5a2d4c95cea111e4bc2efa508a8e48393f45037b0cb3c5331e3ec1f744f83dd57644c6fdd684bdcad9c2fa01108ed2cca6b1046cb821`
    Plain Text
    - Registered: Fri May 03 09:05:14 GMT 2024
    - Last Modified: Wed Apr 17 17:56:15 GMT 2024
    - 227.9K bytes
    - Viewed (0)
  6. cmd/metrics-v2.go

    		Help:      "Total number of drive timeout errors since server start",
    		Type:      counterMetric,
    	}
    }
    
    func getNodeDriveIOErrorsMD() MetricDescription {
    	return MetricDescription{
    		Namespace: nodeMetricNamespace,
    		Subsystem: driveSubsystem,
    		Name:      "errors_ioerror",
    		Help:      "Total number of drive I/O errors since server start",
    		Type:      counterMetric,
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
  7. tensorflow/c/c_api.cc

    // TF_Server functions ----------------------------------------------
    
    #if !defined(IS_MOBILE_PLATFORM) && !defined(IS_SLIM_BUILD)
    TF_Server::TF_Server(std::unique_ptr<tensorflow::ServerInterface> server)
        : target(server->target()), server(std::move(server)) {}
    #endif  // !defined(IS_MOBILE_PLATFORM) && !defined(IS_SLIM_BUILD)
    
    TF_Server* TF_NewServer(const void* proto, size_t proto_len,
    C++
    - Registered: Tue Apr 30 12:39:09 GMT 2024
    - Last Modified: Mon Apr 15 03:35:10 GMT 2024
    - 102.3K bytes
    - Viewed (0)
  8. fastapi/applications.py

        def setup(self) -> None:
            if self.openapi_url:
                urls = (server_data.get("url") for server_data in self.servers)
                server_urls = {url for url in urls if url}
    
                async def openapi(req: Request) -> JSONResponse:
                    root_path = req.scope.get("root_path", "").rstrip("/")
                    if root_path not in server_urls:
                        if root_path and self.root_path_in_servers:
    Python
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Tue Apr 02 02:48:51 GMT 2024
    - 172.2K bytes
    - Viewed (0)
  9. cmd/object-handlers.go

    // the handler should ensure to remove these keys before sending them to the object layer.
    // Currently these keys are:
    //   - X-Amz-Server-Side-Encryption-Customer-Key
    //   - X-Amz-Copy-Source-Server-Side-Encryption-Customer-Key
    func (api objectAPIHandlers) CopyObjectHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "CopyObject")
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  10. fastapi/routing.py

                        so it's an error from the API developer. So, FastAPI will raise an
                        error and return a 500 error code (Internal Server Error).
    
                    Read more about it in the
                    [FastAPI docs for Response Model](https://fastapi.tiangolo.com/tutorial/response-model/).
                    """
                ),
    Python
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Tue Apr 02 02:48:51 GMT 2024
    - 170.1K bytes
    - Viewed (0)
Back to top