Search Options

Results per page
Sort
Preferred Languages
Advance

Results 211 - 220 of 1,066 for readOp (0.09 sec)

  1. cmd/healthcheck-router.go

    import (
    	"net/http"
    
    	"github.com/minio/mux"
    )
    
    const (
    	healthCheckPath            = "/health"
    	healthCheckLivenessPath    = "/live"
    	healthCheckReadinessPath   = "/ready"
    	healthCheckClusterPath     = "/cluster"
    	healthCheckClusterReadPath = "/cluster/read"
    	healthCheckPathPrefix      = minioReservedBucketPath + healthCheckPath
    )
    
    // registerHealthCheckRouter - add handler functions for liveness and readiness routes.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jan 23 11:12:47 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  2. cmd/object-handlers.go

    		compressMetadata[ReservedMetadataPrefix+"actual-size"] = strconv.FormatInt(actualSize, 10)
    
    		reader = etag.NewReader(ctx, reader, nil, nil)
    		wantEncryption := crypto.Requested(r.Header)
    		s2c, cb := newS2CompressReader(reader, actualSize, wantEncryption)
    		dstOpts.IndexCB = cb
    		defer s2c.Close()
    		reader = etag.Wrap(s2c, reader)
    		length = -1
    	} else {
    		delete(srcInfo.UserDefined, ReservedMetadataPrefix+"compression")
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
  3. internal/rest/client.go

    				r := bytes.NewReader(buf)
    				return io.NopCloser(r), nil
    			}
    		case *bytes.Reader:
    			req.ContentLength = int64(v.Len())
    			snapshot := *v
    			req.GetBody = func() (io.ReadCloser, error) {
    				r := snapshot
    				return io.NopCloser(&r), nil
    			}
    		case *strings.Reader:
    			req.ContentLength = int64(v.Len())
    			snapshot := *v
    			req.GetBody = func() (io.ReadCloser, error) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  4. istioctl/pkg/kubeinject/kubeinject.go

    			if err = validateFlags(); err != nil {
    				return err
    			}
    			var reader io.Reader
    
    			if inFilename == "-" {
    				reader = os.Stdin
    			} else {
    				var in *os.File
    				if in, err = os.Open(inFilename); err != nil {
    					return err
    				}
    				reader = in
    				defer func() {
    					if errClose := in.Close(); errClose != nil {
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 21K bytes
    - Viewed (0)
  5. api/go1.5.txt

    pkg mime, type WordDecoder struct
    pkg mime, type WordDecoder struct, CharsetReader func(string, io.Reader) (io.Reader, error)
    pkg mime, type WordEncoder uint8
    pkg mime/quotedprintable, func NewReader(io.Reader) *Reader
    pkg mime/quotedprintable, func NewWriter(io.Writer) *Writer
    pkg mime/quotedprintable, method (*Reader) Read([]uint8) (int, error)
    pkg mime/quotedprintable, method (*Writer) Close() error
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Thu Jul 30 21:14:09 UTC 2015
    - 46.6K bytes
    - Viewed (0)
  6. CONTRIBUTING.md

    This will build the whole documentation locally in [platforms/documentation](./platforms/documentation).
    For more commands and examples, including local development,
    see [this guide](./platforms/documentation/docs/README.md).
    
    ### Creating commits and writing commit messages
    
    The commit messages that accompany your code changes are an important piece of documentation. Please follow these guidelines when creating commits:
    
    Registered: Wed Oct 30 11:36:09 UTC 2024
    - Last Modified: Tue Jun 18 08:01:25 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  7. istioctl/pkg/describe/describe_test.go

    							},
    						},
    					},
    					Status: corev1.PodStatus{
    						Phase: corev1.PodRunning,
    						ContainerStatuses: []corev1.ContainerStatus{
    							{
    								Name:  "istio-proxy",
    								Ready: true,
    							},
    						},
    					},
    				},
    				&corev1.Pod{
    					ObjectMeta: metav1.ObjectMeta{
    						Name:      "ingress",
    						Namespace: "default",
    						Labels: map[string]string{
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 20:04:20 UTC 2024
    - 30.8K bytes
    - Viewed (0)
  8. common-protos/k8s.io/api/extensions/v1beta1/generated.proto

      optional DaemonSetUpdateStrategy updateStrategy = 3;
    
      // The minimum number of seconds for which a newly created DaemonSet pod should
      // be ready without any of its container crashing, for it to be considered
      // available. Defaults to 0 (pod will be considered available as soon as it
      // is ready).
      // +optional
      optional int32 minReadySeconds = 4;
    
      // DEPRECATED.
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 45.6K bytes
    - Viewed (0)
  9. internal/etag/etag_test.go

    	},
    }
    
    func TestReader(t *testing.T) {
    	for i, test := range readerTests {
    		reader := NewReader(context.Background(), strings.NewReader(test.Content), test.ETag, nil)
    		if _, err := io.Copy(io.Discard, reader); err != nil {
    			t.Fatalf("Test %d: read failed: %v", i, err)
    		}
    		if ETag := reader.ETag(); !Equal(ETag, test.ETag) {
    			t.Fatalf("Test %d: ETag mismatch: got %q - want %q", i, ETag, test.ETag)
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 18 17:00:54 UTC 2023
    - 12.6K bytes
    - Viewed (0)
  10. internal/mountinfo/mountinfo_linux_test.go

    	// Failure case mounts path doesn't exist, if not fail.
    	{
    		if _, err = readProcMounts(filepath.Join(dir, "non-existent")); err != nil && !os.IsNotExist(err) {
    			t.Fatal(err)
    		}
    	}
    }
    
    // Tests read proc mounts reader.
    func TestReadProcMountFrom(t *testing.T) {
    	successCase := `/dev/0 /path/to/0 type0 flags 0 0
    		/dev/1    /path/to/1   type1	flags 1 1
    		/dev/2 /path/to/2 type2 flags,1,2=3 2 2
    		`
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 7.3K bytes
    - Viewed (0)
Back to top