storage

package

v0.1.9 Latest Latest Go to latest Published: Jun 5, 2023 License: MIT Imports: 25 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/Filecoin-Titan/titan

Links

Open Source Insights

Documentation ¶

Index ¶

type Manager
- func NewManager(opts *ManagerOptions) (*Manager, error)
type ManagerOptions
type Storage

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Manager ¶

type Manager struct {
	// contains filtered or unexported fields
}

Manager handles storage operations

func NewManager ¶

func NewManager(opts *ManagerOptions) (*Manager, error)

NewManager creates a new Manager instance

func (*Manager) AddAssetToView ¶

func (m *Manager) AddAssetToView(ctx context.Context, root cid.Cid) error

AddAssetToView adds an asset to the assets view

func (*Manager) AssetCount ¶

func (m *Manager) AssetCount() (int, error)

AssetCount returns the number of assets

func (*Manager) AssetExists ¶

func (m *Manager) AssetExists(root cid.Cid) (bool, error)

AssetExists checks if an asset exists

func (*Manager) DeleteAsset ¶

func (m *Manager) DeleteAsset(root cid.Cid) error

DeleteAsset removes an asset

func (*Manager) DeletePuller ¶

func (m *Manager) DeletePuller(c cid.Cid) error

DeletePuller removes an puller from storage

func (*Manager) GetAsset ¶

func (m *Manager) GetAsset(root cid.Cid) (io.ReadSeekCloser, error)

GetAsset retrieves an asset

func (*Manager) GetAssetsInBucket ¶

func (m *Manager) GetAssetsInBucket(ctx context.Context, bucketID uint32) ([]cid.Cid, error)

GetAssetsInBucket retrieves the assets in a specific bucket

func (*Manager) GetBlockCount ¶

func (m *Manager) GetBlockCount(ctx context.Context, root cid.Cid) (uint32, error)

GetBlockCount retrieves the block count of an asset

func (*Manager) GetBucketHashes ¶

func (m *Manager) GetBucketHashes(ctx context.Context) (map[uint32]string, error)

GetBucketHashes retrieves the hashes for each bucket

func (*Manager) GetDiskUsageStat ¶

func (m *Manager) GetDiskUsageStat() (totalSpace, usage float64)

GetDiskUsageStat retrieves the disk usage statistics

func (*Manager) GetFileSystemType ¶

func (m *Manager) GetFileSystemType() string

GetFileSystemType retrieves the type of the file system

func (*Manager) GetPuller ¶

func (m *Manager) GetPuller(c cid.Cid) ([]byte, error)

GetPuller retrieves puller from storage

func (*Manager) GetTopHash ¶

func (m *Manager) GetTopHash(ctx context.Context) (string, error)

AssetsView API GetTopHash retrieves the top hash of assets

func (*Manager) GetWaitList ¶

func (m *Manager) GetWaitList() ([]byte, error)

GetWaitList retrieves the waitlist data

func (*Manager) PullerExists ¶

func (m *Manager) PullerExists(c cid.Cid) (bool, error)

PullerExists checks if an puller exist in storage

func (*Manager) RemoveAssetFromView ¶

func (m *Manager) RemoveAssetFromView(ctx context.Context, root cid.Cid) error

RemoveAssetFromView removes an asset from the assets view

func (*Manager) SetBlockCount ¶

func (m *Manager) SetBlockCount(ctx context.Context, root cid.Cid, count uint32) error

SetBlockCount sets the block count of an asset

func (*Manager) StoreAsset ¶

func (m *Manager) StoreAsset(ctx context.Context, root cid.Cid) error

StoreAsset stores a single asset

func (*Manager) StoreBlocks ¶

func (m *Manager) StoreBlocks(ctx context.Context, root cid.Cid, blks []blocks.Block) error

asset api StoreBlocks stores multiple blocks for an asset

func (*Manager) StorePuller ¶

func (m *Manager) StorePuller(c cid.Cid, data []byte) error

StorePuller stores puller data in storage

func (*Manager) StoreWaitList ¶

func (m *Manager) StoreWaitList(data []byte) error

StoreWaitList stores the waitlist data

type ManagerOptions ¶

type ManagerOptions struct {
	MetaDataPath string
	AssetsPaths  []string
}

ManagerOptions contains configuration options for the Manager

type Storage ¶

type Storage interface {
	StorePuller(c cid.Cid, data []byte) error
	GetPuller(c cid.Cid) ([]byte, error)
	PullerExists(c cid.Cid) (bool, error)
	DeletePuller(c cid.Cid) error

	StoreBlocks(ctx context.Context, root cid.Cid, blks []blocks.Block) error

	StoreAsset(ctx context.Context, root cid.Cid) error
	GetAsset(root cid.Cid) (io.ReadSeekCloser, error)
	AssetExists(root cid.Cid) (bool, error)
	DeleteAsset(root cid.Cid) error
	AssetCount() (int, error)
	GetBlockCount(ctx context.Context, root cid.Cid) (uint32, error)
	SetBlockCount(ctx context.Context, root cid.Cid, count uint32) error

	// assets view
	GetTopHash(ctx context.Context) (string, error)
	GetBucketHashes(ctx context.Context) (map[uint32]string, error)
	GetAssetsInBucket(ctx context.Context, bucketID uint32) ([]cid.Cid, error)
	AddAssetToView(ctx context.Context, root cid.Cid) error
	RemoveAssetFromView(ctx context.Context, root cid.Cid) error

	StoreWaitList(data []byte) error
	GetWaitList() ([]byte, error)

	GetDiskUsageStat() (totalSpace, usage float64)
	GetFileSystemType() string
}

Storage is an interface for handling storage operations related to assets.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL