Function NewObject

runtime/vcache/object.go:28–44

NewObject creates a new in-memory Object corresponding to a CSUP object residing in storage. The CSUP header and metadata section are read and the metadata is deserialized so that vectors can be loaded into the cache on demand only as needed and retained in memory for future use.

(ctx context.Context, engine storage.Engine, uri *storage.URI)

// the metadata is deserialized so that vectors can be loaded into the cache
// on demand only as needed and retained in memory for future use.
func NewObject(ctx context.Context, engine storage.Engine, uri *storage.URI) (*Object, error) {
	// XXX currently we open a storage.Reader for every object and never close it.
	// We should either close after a timeout and reopen when needed or change the
	// storage API to have a more reasonable semantics around the Put/Get not leaving
	// a file descriptor open for every long Get.  Perhaps there should be another
	// method for intermittent random access.
	// XXX maybe open the reader inside Fetch if needed?
	reader, err := engine.Get(ctx, uri)
	if err != nil {
		return nil, err
	}
	object, err := csup.NewObject(reader)
	if err != nil {
		return nil, err
	}
	return NewObjectFromCSUP(object), nil
}

func NewObjectFromCSUP(object *csup.Object) *Object {
	return &Object{object: object}