assets

package

Go to main page

Versions in this module

v0

v0.1.21

Jul 31, 2024

Changes in this version

type AssetForceState

+ DownloadSource *SourceDownloadInfo

+ SeedNodeIDs []string

type AssetPullingInfo

+ DownloadSource *SourceDownloadInfo

+ SeedNodeIDs []string

type AssetState

+ const SeedSync

+ const SyncFailed

type Manager

+ func (m *Manager) CreateSyncAssetTask(hash string, req *types.CreateSyncAssetReq) error

+ func (m *Manager) GenerateTokenForDownloadSource(nodeID, cid string) (*types.SourceDownloadInfo, error)

+ type SourceDownloadInfo struct

+ Address string

+ NodeID string

+ Tk *Token

+ func (state *SourceDownloadInfo) ToSourceDownloadInfo() *types.SourceDownloadInfo

+ func (t *SourceDownloadInfo) MarshalCBOR(w io.Writer) error

+ func (t *SourceDownloadInfo) UnmarshalCBOR(r io.Reader) (err error)

+ type Token struct

+ CipherText string

+ ID string

+ Sign string

+ func (t *Token) MarshalCBOR(w io.Writer) error

+ func (t *Token) UnmarshalCBOR(r io.Reader) (err error)

v0.1.20

Jun 27, 2024

v0.1.19

Jun 27, 2024

v0.1.19-b

Jun 27, 2024

v0.1.18

Apr 29, 2024

Changes in this version

+ var WaitTime = 5 * time.Second

type AssetPullingInfo

+ Source AssetSource

+ type AssetSource int64

+ const AssetSourceAWS

+ const AssetSourceIPFS

+ const AssetSourceMinio

+ const AssetSourceStorage

v0.1.16

Mar 29, 2024

v0.1.15

Mar 26, 2024

Changes in this version

type AssetPullingInfo

+ Note string

v0.1.14

Mar 21, 2024

Changes in this version

type AssetState

+ const Stop

type Manager

+ func (m *Manager) StopAsset(hashs []string) error

+ func (m *Manager) UpdateFillAssetResponseCount(bucket, cid, nodeID string)

v0.1.13

Mar 15, 2024

Changes in this version

type Manager

+ func (m *Manager) CreateBaseAsset(cid, nodeID string, size, replicas int64) error

+ func (m *Manager) StartFillDiskTimer()

+ func (m *Manager) StopFillDiskTimer()

v0.1.11

Mar 1, 2024

Changes in this version

type Manager

+ func (m *Manager) AssetRemoveDone(key string)

+ func (m *Manager) CandidateDeactivate(nodeID string) error

+ func (m *Manager) WaitAssetRemove(key string) *sync.WaitGroup

v0.1.10

Jun 28, 2023

Changes in this version

+ var ActiveStates = append(append([]string{ ... }, FailedStates), PullingStates)

type AssetForceState

+ Details string

+ Requester string

+ SeedNodeID string

type AssetPullingInfo

+ Bandwidth int64

+ CandidateWaitings int64

+ Details string

+ EdgeWaitings int64

+ Requester string

+ SeedNodeID string

type AssetRePull

+ func (evt AssetRePull) Ignore()

type AssetState

+ const SeedUploading

+ const UploadFailed

+ const UploadInit

type InfoUpdate

+ func (evt InfoUpdate) Ignore()

type Manager

+ func (m *Manager) CreateAssetUploadTask(hash string, req *types.CreateAssetReq) (*types.CreateAssetRsp, error)

+ func (m *Manager) GenerateToken(assetCID string, sources []*types.CandidateDownloadInfo, ...) (map[string][]*types.CandidateDownloadInfo, []*types.TokenPayload, error)

+ func (m *Manager) GetAssetCount() (int, error)

+ func (m *Manager) SaveTokenPayload(payloads []*types.TokenPayload) error

type PullFailed

+ func (evt PullFailed) Ignore()

type PullSucceed

+ func (evt PullSucceed) Ignore()

type PulledResult

+ BlocksCount int64

+ Size int64

+ func (evt PulledResult) Ignore()

v0.1.9

Jun 5, 2023

Changes in this version

+ var AllStates = []string

+ var FailedStates = []string

+ var MaxRetryCount = 3

+ var MinRetryTime = 1 * time.Minute

+ var PullingStates = []string

+ type AssetForceState struct

+ State AssetState

+ type AssetHash string

+ func (c AssetHash) String() string

+ type AssetPullingInfo struct

+ Blocks int64

+ CID string

+ CandidateReplicaFailures []string

+ CandidateReplicaSucceeds []string

+ CandidateReplicas int64

+ EdgeReplicaFailures []string

+ EdgeReplicaSucceeds []string

+ EdgeReplicas int64

+ Hash AssetHash

+ ReplenishReplicas int64

+ RetryCount int64

+ Size int64

+ State AssetState

+ func (state *AssetPullingInfo) ToAssetRecord() *types.AssetRecord

+ func (t *AssetPullingInfo) MarshalCBOR(w io.Writer) error

+ func (t *AssetPullingInfo) UnmarshalCBOR(r io.Reader) (err error)

+ type AssetRePull struct

+ type AssetRemove struct

+ type AssetStartPulls struct

+ CandidateReplicas int

+ Hash AssetHash

+ ID string

+ Replicas int64

+ type AssetState string

+ const CandidatesFailed

+ const CandidatesPulling

+ const CandidatesSelect

+ const EdgesFailed

+ const EdgesPulling

+ const EdgesSelect

+ const Remove

+ const SeedFailed

+ const SeedPulling

+ const SeedSelect

+ const Servicing

+ const UndefinedState

+ func (s AssetState) String() string

+ type Datastore struct

+ func NewDatastore(db *db.SQLDB, serverID dtypes.ServerID) *Datastore

+ func (d *Datastore) Batch(ctx context.Context) (datastore.Batch, error)

+ func (d *Datastore) Close() error

+ func (d *Datastore) Delete(ctx context.Context, key datastore.Key) error

+ func (d *Datastore) Get(ctx context.Context, key datastore.Key) (value []byte, err error)

+ func (d *Datastore) GetSize(ctx context.Context, key datastore.Key) (size int, err error)

+ func (d *Datastore) Has(ctx context.Context, key datastore.Key) (exists bool, err error)

+ func (d *Datastore) Put(ctx context.Context, key datastore.Key, value []byte) error

+ func (d *Datastore) Query(ctx context.Context, q query.Query) (query.Results, error)

+ func (d *Datastore) Sync(ctx context.Context, prefix datastore.Key) error

+ type Ignorable interface

+ Ignore func()

+ type InfoUpdate struct

+ Blocks int64

+ Size int64

+ type Manager struct

+ func NewManager(nodeManager *node.Manager, ds datastore.Batching, ...) *Manager

+ func (m *Manager) CreateAssetPullTask(info *types.PullAssetReq, userID string) error

+ func (m *Manager) GetAssetRecordInfo(cid string) (*types.AssetRecord, error)

+ func (m *Manager) GetCandidateReplicaCount() int

+ func (m *Manager) ListAssets() ([]AssetPullingInfo, error)

+ func (m *Manager) Plan(events []statemachine.Event, user interface{}) (interface{}, uint64, error)

+ func (m *Manager) RandomAsset(nodeID string, seed int64) (*cid.Cid, error)

+ func (m *Manager) RemoveAsset(cid, hash, userID string) error

+ func (m *Manager) RemoveReplica(cid, hash, nodeID, userID string) error

+ func (m *Manager) RestartPullAssets(hashes []types.AssetHash) error

+ func (m *Manager) Start(ctx context.Context)

+ func (m *Manager) Terminate(ctx context.Context) error

+ func (m *Manager) UpdateAssetExpiration(cid string, t time.Time) error

+ type NodePulledResult struct

+ BlocksCount int64

+ IsCandidate bool

+ NodeID string

+ Size int64

+ Status int64

+ func (t *NodePulledResult) MarshalCBOR(w io.Writer) error

+ func (t *NodePulledResult) UnmarshalCBOR(r io.Reader) (err error)

+ type PullAssetFatalError struct

+ func (evt PullAssetFatalError) FormatError(xerrors.Printer) (next error)

+ type PullAssetRestart struct

+ type PullFailed struct

+ func (evt PullFailed) FormatError(xerrors.Printer) (next error)

+ type PullRequestSent struct

+ type PullSucceed struct

+ type PulledResult struct

+ ResultInfo *NodePulledResult

+ type ReplenishReplicas struct

+ State AssetState

+ type SelectFailed struct

+ func (evt SelectFailed) FormatError(xerrors.Printer) (next error)

+ type SkipStep struct

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