Class BlobStore

Hierarchy

  • TypedEmitter
    • BlobStore

Constructors

constructor

Accessors

isArchiveDevice writerDriveId

Methods

clear close createEntriesReadStream createReadStream createReadStreamFromEntry createWriteStream entry get getBlobFilter getEntryBlob put setIsArchiveDevice

Constructors

constructor

  • new BlobStore(options): BlobStore

  • Parameters

    • options: {
          coreManager: CoreManager;
          isArchiveDevice: undefined | boolean;
          logger: undefined | Logger;
      }
      • coreManager: CoreManager
      • isArchiveDevice: undefined | boolean

        Set to true if this is an archive device which should download all blobs, or just a selection of blobs

      • logger: undefined | Logger

    Returns BlobStore

Accessors

isArchiveDevice

  • get isArchiveDevice(): boolean

  • Returns boolean

writerDriveId

  • get writerDriveId(): string

  • Returns string

Methods

clear

  • clear(blobId, options?): Promise<null | {
        blocks: number;
    }>

  • Parameters

    • blobId: BlobApi.BlobId
    • Optionaloptions: {
          diff: undefined | boolean;
      } = {}
      • diff: undefined | boolean

        Enable to return an object with a block property with number of bytes removed

    Returns Promise<null | {
        blocks: number;
    }>

close

  • close(): void

  • Returns void

createEntriesReadStream

  • createEntriesReadStream(opts?): BlobStoreEntriesStream

  • This is a low-level method to create a stream of entries from all drives. It includes entries for unknown blob types and variants.

    Parameters

    • opts: {
          filter: undefined | null | GenericBlobFilter;
          live: undefined | boolean;
      } = {}
      • filter: undefined | null | GenericBlobFilter

        Filter blob types and/or variants in returned entries. Filter is { [BlobType]: BlobVariants[] }.

      • live: undefined | boolean

        Set to true to get a live stream of entries

    Returns BlobStoreEntriesStream

createReadStream

  • createReadStream(blobId, options?): Readable

  • Parameters

    • blobId: BlobApi.BlobId
    • Optionaloptions: {
          timeout: undefined | number;
          wait: undefined | boolean;
      } = ...
      • timeout: undefined | number

        Optional timeout to wait for a blob to download

      • wait: undefined | boolean

        Set to true to wait for a blob to download, otherwise will throw if blob is not available locally

    Returns Readable

createReadStreamFromEntry

  • createReadStreamFromEntry(driveId, entry, options?): Promise<Readable>

  • Optimization for creating the blobs read stream when you have previously read the entry from Hyperdrive using drive.entry

    Parameters

    • driveId: string

      Hyperdrive drive discovery id

    • entry: HyperdriveEntry

      Hyperdrive entry

    • Optionaloptions: {
          wait: undefined | boolean;
      } = ...
      • wait: undefined | boolean

        Set to true to wait for a blob to download, otherwise will throw if blob is not available locally

    Returns Promise<Readable>

createWriteStream

  • createWriteStream(blobId, options?): Writable<any, any, any, false, true, WritableEvents<any>> & {
        driveId: string;
    }

  • Parameters

    • blobId: Omit<BlobApi.BlobId, "driveId">
    • Optionaloptions: {
          metadata: undefined | JsonObject;
      }
      • metadata: undefined | JsonObject

        Metadata to store with the blob

    Returns Writable<any, any, any, false, true, WritableEvents<any>> & {
        driveId: string;
    }

entry

  • entry(blobId, options?): Promise<null | HyperdriveEntry>

  • Parameters

    • blobId: BlobApi.BlobId
    • Optionaloptions: {
          follow: undefined | boolean;
          timeout: undefined;
          wait: undefined | false;
      } = ...
      • follow: undefined | boolean

        Set to true to follow symlinks (16 max or throws an error)

      • timeout: undefined

        Optional timeout to wait for a blob to download

      • wait: undefined | false

        Set to true to wait for a blob to download, otherwise will throw if blob is not available locally

    Returns Promise<null | HyperdriveEntry>

get

  • get(blobId, opts?): Promise<Uint8Array>

  • Parameters

    • blobId: BlobApi.BlobId
    • opts: {
          timeout: undefined;
          wait: undefined | false;
      } = {}
      • timeout: undefined

        Optional timeout to wait for a blob to download

      • wait: undefined | false

        Set to true to wait for a blob to download, otherwise will throw if blob is not available locally

    Returns Promise<Uint8Array>

getBlobFilter

getEntryBlob

  • getEntryBlob(driveId, entry, opts?): Promise<null | Buffer>

  • Parameters

    • driveId: string

      Hyperdrive drive id

    • entry: HyperdriveEntry

      Hyperdrive entry

    • Optionalopts: {
          length: undefined | number;
      } = {}
      • length: undefined | number

    Returns Promise<null | Buffer>

put

  • put(blobId, blob, options?): Promise<string>

  • Parameters

    • blobId: Omit<BlobApi.BlobId, "driveId">
    • blob: Buffer
    • Optionaloptions: {
          metadata: undefined | JsonObject;
      }
      • metadata: undefined | JsonObject

        Metadata to store with the blob

    Returns Promise<string>

    discovery key as hex string of hyperdrive where blob is stored

setIsArchiveDevice

  • setIsArchiveDevice(isArchiveDevice): Promise<void>

  • Parameters

    • isArchiveDevice: boolean

    Returns Promise<void>

Settings

Member Visibility

On This Page

Constructors
Accessors
Methods