carstore

Sep 15, 2022

Changes in this version

+ var ErrDownloadTooLarge = errors.New("download is too large")

Aug 26, 2022

Changes in this version

type CarStore

+ func (cs *CarStore) Stop() error

Jul 27, 2022

Changes in this version

+ var ErrNotFound = errors.New("CAR not found")

+ func NewGatewayAPI(baseURL string, sApi station.StationAPI) *gatewayAPI

+ type CarStore struct

+ func New(rootDir string, gwAPI GatewayAPI, cfg Config, logger *logs.SaturnLogger) (*CarStore, error)

+ func (cs *CarStore) Close() error

+ func (cs *CarStore) FetchAndWriteCAR(reqID uuid.UUID, root cid.Cid, writer func(bstore.Blockstore) error) error

+ func (cs *CarStore) IsIndexed(ctx context.Context, root cid.Cid) (bool, error)

+ func (cs *CarStore) Start(ctx context.Context) error

+ func (cs *CarStore) Stat() (station.StorageStats, error)

+ type Config struct

+ DownloadTimeout time.Duration

+ MaxCARFilesDiskSpace int64

+ type GatewayAPI interface

+ Fetch func(ctx context.Context, rootCID cid.Cid) (mount.Reader, error)

+ type GatewayMount struct

+ API GatewayAPI

+ RootCID cid.Cid

+ func (g *GatewayMount) Close() error

+ func (g *GatewayMount) Deserialize(u *url.URL) error

+ func (g *GatewayMount) Fetch(ctx context.Context) (mount.Reader, error)

+ func (g *GatewayMount) Info() mount.Info

+ func (g *GatewayMount) Serialize() *url.URL

+ func (l *GatewayMount) Stat(ctx context.Context) (mount.Stat, error)

+ type GatewayReader struct

+ func (gw *GatewayReader) Close() error

+ func (gw *GatewayReader) Read(p []byte) (int, error)