- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 923 for read1 (0.07 sec)
-
src/cmd/vendor/golang.org/x/telemetry/internal/mmap/mmap_other.go
//go:build (js && wasm) || wasip1 || plan9 || (solaris && !go1.20) package mmap import ( "io" "os" ) // mmapFile on other systems doesn't mmap the file. It just reads everything. func mmapFile(f *os.File, _ *Data) (Data, error) { b, err := io.ReadAll(f) if err != nil { return Data{}, err } return Data{f, b, nil}, nil } func munmapFile(d Data) error { return nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jan 30 21:40:49 UTC 2024 - 540 bytes - Viewed (0) -
pkg/kube/kclient/clienttest/direct.go
} // NewDirectClient returns a new client for the given type. Reads are directly to the API server. // Any errors will call t.Fatal. // Typically, clienttest.WrapReadWriter should be used to simply wrap an existing client when testing an informer. // However, NewDirectClient can be useful if we do not need/want an informer and need direct reads. // Generic parameters represent the type with and without a pointer, and the list type.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 3K bytes - Viewed (0) -
cmd/kubeadm/app/phases/certs/renewal/readwriter_test.go
pkiReadWriter := newPKICertificateReadWriter(dir, "test") // Reads the certificate readCert, err := pkiReadWriter.Read() if err != nil { t.Fatalf("couldn't read certificate: %v", err) } // Check if the certificate read from disk is equal to the original one if !cert.Equal(readCert) { t.Errorf("read cert does not match with expected cert") } // Create a new cert
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 15:17:24 UTC 2024 - 9.5K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/artifact/repository/metadata/io/MetadataReader.java
* @throws IOException If the metadata could not be deserialized. * @throws MetadataParseException If the input format could not be parsed. */ Metadata read(File input, Map<String, ?> options) throws IOException, MetadataParseException; /** * Reads the metadata from the specified character reader. The reader will be automatically closed before the method * returns. *
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 08:39:32 UTC 2023 - 3.3K bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/HEAD/core.v1.PodStatusResult.json
"message": "messageValue", "startedAt": "2005-01-01T01:01:01Z", "finishedAt": "2006-01-01T01:01:01Z", "containerID": "containerIDValue" } }, "ready": true, "restartCount": 5, "image": "imageValue", "imageID": "imageIDValue", "containerID": "containerIDValue", "started": true, "allocatedResources": {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 8.1K bytes - Viewed (0) -
pkg/credentialprovider/provider.go
// credentials; implementations are safe to ignore the image. Provide(image string) DockerConfig } // A DockerConfigProvider that simply reads the .dockercfg file type defaultDockerConfigProvider struct{} // init registers our default provider, which simply reads the .dockercfg file. func init() { RegisterCredentialProvider(".dockercfg", &CachingDockerConfigProvider{ Provider: &defaultDockerConfigProvider{},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 02 00:08:54 UTC 2021 - 3.3K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
err := s.dataplane.ConstructInitialSnapshot(pods) if err != nil { log.Warnf("failed to construct initial snapshot: %v", err) } log.Info("CNI ambient server marking ready") s.Ready() s.dataplane.Start(s.ctx) s.handlers.Start() } func (s *Server) Stop() { log.Info("CNI ambient server terminating, cleaning up node net rules") s.cniServerStopFunc() s.dataplane.Stop()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:18 UTC 2024 - 7.2K bytes - Viewed (0) -
pkg/test/echo/server/instance.go
if err := ep.Start(onEndpointReady); err != nil { return err } } // Wait for all the servers to start. wg.Wait() // Indicate that the server is now ready. atomic.StoreUint32(&s.ready, 1) log.Info("Echo server is now ready") return nil } func (s *Instance) validate() error { for _, port := range s.Ports { switch port.Protocol { case protocol.TCP: case protocol.UDP:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 09 07:54:01 UTC 2023 - 7.1K bytes - Viewed (0) -
src/os/pipe2_unix.go
// license that can be found in the LICENSE file. //go:build dragonfly || freebsd || linux || netbsd || openbsd || solaris package os import "syscall" // Pipe returns a connected pair of Files; reads from r return bytes written to w. // It returns the files and an error, if any. func Pipe() (r *File, w *File, err error) { var p [2]int e := syscall.Pipe2(p[0:], syscall.O_CLOEXEC) if e != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 19 11:47:23 UTC 2024 - 654 bytes - Viewed (0) -
pkg/controller/daemon/update_test.go
logger.Info("marked pod ready", "pod", pod.Name, "ready", ready) count-- } if count > 0 { t.Fatalf("could not mark %d pods ready=%t", count, ready) } } func currentDSHash(dsc *daemonSetsController, ds *apps.DaemonSet) (string, error) { // Construct histories of the DaemonSet, and get the hash of current history cur, _, err := dsc.constructHistory(context.TODO(), ds) if err != nil { return "", err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Feb 10 21:10:35 UTC 2024 - 28.9K bytes - Viewed (0)