- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 5,978 for sever (0.07 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/testing/v2/kms_plugin_mock.go
func NewBase64Plugin(t testing.TB, socketPath string) *Base64Plugin { server := grpc.NewServer() result := &Base64Plugin{ grpcServer: server, mu: &sync.Mutex{}, ver: kmsapiVersion, socketPath: socketPath, keyID: "1", } kmsapi.RegisterKeyManagementServiceServer(server, result) if err := result.start(); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 21 19:25:52 UTC 2023 - 6.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/testing/v1beta1/kms_plugin_mock.go
func NewBase64Plugin(t *testing.T, socketPath string) *Base64Plugin { server := grpc.NewServer() result := &Base64Plugin{ grpcServer: server, mu: &sync.Mutex{}, ver: kmsapiVersion, socketPath: socketPath, } kmsapi.RegisterKeyManagementServiceServer(server, result) if err := result.start(); err != nil { t.Fatalf("failed to start KMS plugin, err: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 29 05:36:41 UTC 2023 - 5.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/responsewriter/wrapper.go
// - The inner ResponseWriter implements `http.CloseNotifier`, `http.Flusher`, // and `http.Hijacker` (an HTTP/1.1 sever provides such a ResponseWriter). // - The inner ResponseWriter implements `http.CloseNotifier` and `http.Flusher` // but not `http.Hijacker` (an HTTP/2 server provides such a ResponseWriter). // - All the other cases collapse to this one, in which the given ResponseWriter is returned. //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/maxinflight_test.go
// These should hang waiting on block... go func() { if err := expectHTTPPost(server.URL+"/foo/bar", http.StatusOK); err != nil { t.Error(err) } responses.Done() }() } // We wait for all calls to be received by the server calls.Wait() // Disable calls notifications in the server // Disable calls notifications in the server waitForCallsMutex.Lock() waitForCalls = false waitForCallsMutex.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 10.2K bytes - Viewed (0) -
src/crypto/tls/ticket.go
// decline to offer 0-RTT even if supported. EarlyData bool version uint16 isClient bool cipherSuite uint16 // createdAt is the generation time of the secret on the sever (which for // TLS 1.0–1.2 might be earlier than the current session) and the time at // which the ticket was received on the client. createdAt uint64 // seconds since UNIX epoch
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 17:23:54 UTC 2024 - 12.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/types.go
// StatusReasonServerTimeout means the server can be reached and understood the request, // but cannot complete the action in a reasonable time. The client should retry the request. // This is may be due to temporary server load or a transient communication issue with // another server. Status code 500 is used because the HTTP spec provides no suitable // server-requested client retry and the 5xx class represents actionable errors.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 10:52:25 UTC 2024 - 79.2K bytes - Viewed (1) -
src/net/http/server.go
) // A conn represents the server side of an HTTP connection. type conn struct { // server is the server on which the connection arrived. // Immutable; never nil. server *Server // cancelCtx cancels the connection-level context. cancelCtx context.CancelFunc // rwc is the underlying network connection. // This is never wrapped by other types and is the value given out
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
src/net/http/httptest/server.go
// The caller should call Close when finished, to shut it down. func NewUnstartedServer(handler http.Handler) *Server { return &Server{ Listener: newLocalListener(), Config: &http.Server{Handler: handler}, } } // Start starts a server from NewUnstartedServer. func (s *Server) Start() { if s.URL != "" { panic("Server already started") } if s.client == nil { s.client = &http.Client{Transport: &http.Transport{}}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 17:26:10 UTC 2024 - 10.7K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/mod/sumdb/server.go
} // A Server is the checksum database HTTP server, // which implements http.Handler and should be invoked // to serve the paths listed in [ServerPaths]. type Server struct { ops ServerOps } // NewServer returns a new Server using the given operations. func NewServer(ops ServerOps) *Server { return &Server{ops: ops} }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jul 12 20:38:21 UTC 2023 - 4.9K bytes - Viewed (0) -
cmd/kube-apiserver/app/server.go
"k8s.io/apiserver/pkg/admission" genericapifilters "k8s.io/apiserver/pkg/endpoints/filters" genericapiserver "k8s.io/apiserver/pkg/server" "k8s.io/apiserver/pkg/server/egressselector" serverstorage "k8s.io/apiserver/pkg/server/storage" utilfeature "k8s.io/apiserver/pkg/util/feature" "k8s.io/apiserver/pkg/util/notfoundhandler" "k8s.io/apiserver/pkg/util/webhook"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 17:44:20 UTC 2024 - 10.2K bytes - Viewed (0)