Method GetObject

api-get-object.go:32–267

GetObject wrapper function that accepts a request context

(ctx context.Context, bucketName, objectName string, opts GetObjectOptions)

// GetObject wrapper function that accepts a request context
func (c *Client) GetObject(ctx context.Context, bucketName, objectName string, opts GetObjectOptions) (*Object, error) {
	// Input validation.
	if err := s3utils.CheckValidBucketName(bucketName); err != nil {
		return nil, ErrorResponse{
			StatusCode: http.StatusBadRequest,
			Code:       InvalidBucketName,
			Message:    err.Error(),
		}
	}
	if err := s3utils.CheckValidObjectName(objectName); err != nil {
		return nil, ErrorResponse{
			StatusCode: http.StatusBadRequest,
			Code:       XMinioInvalidObjectName,
			Message:    err.Error(),
		}
	}

	if opts.RDMABuffer != nil && c.rdmaEnabled {
		n, err := c.getObjectRDMA(ctx, bucketName, objectName, opts)
		if err != nil {
			return nil, err
		}
		return &Object{
			mutex:    &sync.Mutex{},
			isClosed: true,
			objectInfo: ObjectInfo{
				Key:  objectName,
				Size: n,
			},
			objectInfoSet: true,
		}, nil
	}

	gctx, cancel := context.WithCancel(ctx)

	// Detect if snowball is server location we are talking to.
	var snowball bool
	if location, ok := c.bucketLocCache.Get(bucketName); ok {
		snowball = location == "snowball"
	}

	var (
		err        error
		httpReader io.ReadCloser
		objectInfo ObjectInfo
		totalRead  int
	)

	// Create request channel.
	reqCh := make(chan getRequest)
	// Create response channel.
	resCh := make(chan getResponse)

	// This routine feeds partial object data as and when the caller reads.
	go func() {
		defer close(resCh)
		defer func() {
			// Close the http response body before returning.