Documentation
¶
Index ¶
- type IMinioService
- type Manager
- func (m *Manager) AddAssetToView(ctx context.Context, root cid.Cid) error
- func (m *Manager) AssetCount() (int, error)
- func (m *Manager) AssetExists(root cid.Cid) (bool, error)
- func (m *Manager) DeleteAsset(root cid.Cid) error
- func (m *Manager) DeleteBlockCount(ctx context.Context, root cid.Cid) error
- func (m *Manager) DeletePuller(c cid.Cid) error
- func (m *Manager) GetAsset(root cid.Cid) (io.ReadSeekCloser, error)
- func (m *Manager) GetAssetHashesForSyncData(ctx context.Context) ([]string, error)
- func (m *Manager) GetAssetsInBucket(ctx context.Context, bucketID uint32) ([]cid.Cid, error)
- func (m *Manager) GetBlockCount(ctx context.Context, root cid.Cid) (uint32, error)
- func (m *Manager) GetBucketHashes(ctx context.Context) (map[uint32]string, error)
- func (m *Manager) GetDiskUsageStat() (totalSpace, usage float64)
- func (m *Manager) GetFileSystemType() string
- func (m *Manager) GetPuller(c cid.Cid) ([]byte, error)
- func (m *Manager) GetTopHash(ctx context.Context) (string, error)
- func (m *Manager) GetWaitList() ([]byte, error)
- func (m *Manager) PullerExists(c cid.Cid) (bool, error)
- func (m *Manager) RemoveAssetFromView(ctx context.Context, root cid.Cid) error
- func (m *Manager) SetBlockCount(ctx context.Context, root cid.Cid, count uint32) error
- func (m *Manager) StoreBlocks(ctx context.Context, root cid.Cid, blks []blocks.Block) error
- func (m *Manager) StoreBlocksToCar(ctx context.Context, root cid.Cid) error
- func (m *Manager) StorePuller(c cid.Cid, data []byte) error
- func (m *Manager) StoreUserAsset(ctx context.Context, userID string, root cid.Cid, assetSize int64, r io.Reader) error
- func (m *Manager) StoreWaitList(data []byte) error
- type ManagerOptions
- type Storage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IMinioService ¶ added in v0.1.11
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 ¶
AddAssetToView adds an asset to the assets view
func (*Manager) AssetCount ¶
AssetCount returns the number of assets
func (*Manager) AssetExists ¶
AssetExists checks if an asset exists
func (*Manager) DeleteAsset ¶
DeleteAsset removes an asset
func (*Manager) DeleteBlockCount ¶ added in v0.1.16
DeleteBlockCount delete the blcok count of asset
func (*Manager) DeletePuller ¶
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) GetAssetHashesForSyncData ¶ added in v0.1.16
func (*Manager) GetAssetsInBucket ¶
GetAssetsInBucket retrieves the assets in a specific bucket
func (*Manager) GetBlockCount ¶
GetBlockCount retrieves the block count of an asset
func (*Manager) GetBucketHashes ¶
GetBucketHashes retrieves the hashes for each bucket
func (*Manager) GetDiskUsageStat ¶
GetDiskUsageStat retrieves the disk usage statistics
func (*Manager) GetFileSystemType ¶
GetFileSystemType retrieves the type of the file system
func (*Manager) GetTopHash ¶
AssetsView API GetTopHash retrieves the top hash of assets
func (*Manager) GetWaitList ¶
GetWaitList retrieves the waitlist data
func (*Manager) PullerExists ¶
PullerExists checks if an puller exist in storage
func (*Manager) RemoveAssetFromView ¶
RemoveAssetFromView removes an asset from the assets view
func (*Manager) SetBlockCount ¶
SetBlockCount sets the block count of an asset
func (*Manager) StoreBlocks ¶
asset api StoreBlocks stores multiple blocks for an asset
func (*Manager) StoreBlocksToCar ¶ added in v0.1.10
StoreBlocksToCar stores a single asset
func (*Manager) StorePuller ¶
StorePuller stores puller data in storage
func (*Manager) StoreUserAsset ¶ added in v0.1.13
func (*Manager) StoreWaitList ¶
StoreWaitList stores the waitlist data
type ManagerOptions ¶
type ManagerOptions struct {
MetaDataPath string
AssetsPaths []string
MinioConfig *config.MinioConfig
SchedulerAPI api.Scheduler
}
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
StoreBlocksToCar(ctx context.Context, root cid.Cid) error
StoreUserAsset(ctx context.Context, userID string, root cid.Cid, assetSize int64, r io.Reader) error
GetAsset(root cid.Cid) (io.ReadSeekCloser, error)
GetAssetHashesForSyncData(ctx context.Context) ([]string, 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
DeleteBlockCount(ctx context.Context, root cid.Cid) 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