Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 51 for Writer (0.16 sec)

  1. cmd/object-api-interface.go

    // tests are adjusted to use GetObjectNInfo this function can be removed.
    func GetObject(ctx context.Context, api ObjectLayer, bucket, object string, startOffset int64, length int64, writer io.Writer, etag string, opts ObjectOptions) (err error) {
    	var header http.Header
    	if etag != "" {
    		header.Set("ETag", etag)
    	}
    	Range := &HTTPRangeSpec{Start: startOffset, End: startOffset + length}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 17K bytes
    - Viewed (0)
  2. cmd/storage-rest-server.go

    				// concurrently, check for it before we
    				// write the filler byte.
    				select {
    				case err := <-doneCh:
    					if err != nil {
    						write([]byte{1})
    						write([]byte(err.Error()))
    					} else {
    						write([]byte{0})
    					}
    					return
    				default:
    				}
    
    				// Response not ready, write a filler byte.
    				write([]byte{32})
    				if canWrite {
    					w.(http.Flusher).Flush()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  3. cmd/storage-interface.go

    	DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error)
    
    	// WalkDir will walk a directory on disk and return a metacache stream on wr.
    	WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) error
    
    	// Metadata operations
    	DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) error
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  4. istioctl/pkg/waypoint/waypoint.go

    				List(context.Background(), metav1.ListOptions{})
    			if err != nil {
    				return err
    			}
    			if len(gws.Items) == 0 {
    				fmt.Fprintln(writer, "No waypoints found.")
    				return nil
    			}
    			w := new(tabwriter.Writer).Init(writer, 0, 8, 5, ' ', 0)
    			slices.SortFunc(gws.Items, func(i, j gateway.Gateway) int {
    				if r := cmp.Compare(i.Namespace, j.Namespace); r != 0 {
    					return r
    				}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 19:45:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  5. cmd/main.go

    			for _, cmd := range closestCommands {
    				console.Printf("\t‘%s’\n", cmd)
    			}
    		}
    
    		os.Exit(1)
    	}
    
    	return app
    }
    
    func startupBanner(banner io.Writer) {
    	CopyrightYear = strconv.Itoa(time.Now().Year())
    	fmt.Fprintln(banner, color.Blue("Copyright:")+color.Bold(" 2015-%s MinIO, Inc.", CopyrightYear))
    	fmt.Fprintln(banner, color.Blue("License:")+color.Bold(" "+MinioLicense))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  6. internal/logger/logger.go

    	InfoKind    = madmin.LogKindInfo
    )
    
    var (
    	// DisableErrorLog avoids printing error/event/info kind of logs
    	DisableErrorLog = false
    	// Output allows configuring custom writer, defaults to os.Stderr
    	Output io.Writer = os.Stderr
    )
    
    var trimStrings []string
    
    // TimeFormat - logging time format.
    const TimeFormat string = "15:04:05 MST 01/02/2006"
    
    var matchingFuncNames = [...]string{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  7. cmd/object-handlers_test.go

    		},
    	}
    
    	// Iterating over the cases, fetching the object validating the response.
    	for i, testCase := range testCases {
    		// initialize HTTP NewRecorder, this records any mutations to response writer inside the handler.
    		rec := httptest.NewRecorder()
    		// construct HTTP request for Get Object end point.
    		req, err := newTestSignedRequestV4(http.MethodHead, getHeadObjectURL("", testCase.bucketName, testCase.objectName),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 160K bytes
    - Viewed (0)
  8. utils/utils.go

    	yval := reflect.ValueOf(y)
    	if xval.Kind() == reflect.Ptr && xval.IsNil() ||
    		yval.Kind() == reflect.Ptr && yval.IsNil() {
    		return false
    	}
    
    	if valuer, ok := x.(driver.Valuer); ok {
    		x, _ = valuer.Value()
    	}
    	if valuer, ok := y.(driver.Valuer); ok {
    		y, _ = valuer.Value()
    	}
    	return reflect.DeepEqual(x, y)
    }
    
    func ToString(value interface{}) string {
    	switch v := value.(type) {
    	case string:
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Mon Apr 22 06:43:02 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  9. istioctl/pkg/writer/ztunnel/configdump/services.go

    	"cmp"
    	"encoding/json"
    	"fmt"
    	"strings"
    
    	"sigs.k8s.io/yaml"
    
    	"istio.io/istio/pkg/maps"
    	"istio.io/istio/pkg/slices"
    )
    
    // ServiceFilter is used to pass filter information into service based config writer print functions
    type ServiceFilter struct {
    	Namespace string
    }
    
    // Verify returns true if the passed workload matches the filter fields
    func (wf *ServiceFilter) Verify(svc *ZtunnelService) bool {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  10. cmd/object-handlers.go

    	}
    
    	setHeadGetRespHeaders(w, r.Form)
    
    	var iw io.Writer
    	iw = w
    	if buf != nil {
    		iw = io.MultiWriter(w, buf)
    	}
    
    	statusCodeWritten := false
    	httpWriter := xioutil.WriteOnClose(iw)
    	if rs != nil || opts.PartNumber > 0 {
    		statusCodeWritten = true
    		w.WriteHeader(http.StatusPartialContent)
    	}
    
    	// Write object content to response body
    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)
Back to top