Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Asset ¶
type Asset interface {
// GetAsset fetches the asset data for a given CID and returns an io.ReadSeekCloser.
GetAsset(root cid.Cid) (io.ReadSeekCloser, error)
// AssetExists checks whether the asset data for a given CID exists or not.
AssetExists(root cid.Cid) (bool, error)
// HasBlock checks if a block with the given CID is present in the asset data for a given root CID.
HasBlock(ctx context.Context, root, block cid.Cid) (bool, error)
// GetBlock retrieves a block with the given CID from the asset data for a given root CID.
GetBlock(ctx context.Context, root, block cid.Cid) (blocks.Block, error)
// SaveUserAsset save user asset to local
SaveUserAsset(ctx context.Context, userID string, root cid.Cid, assetSize int64, r io.Reader) error
// SetAssetUploadProgress set progress of upload for asset
SetAssetUploadProgress(ctx context.Context, root cid.Cid, progress *types.UploadProgress) error
// GetUploadingAsset get asset which uploading
GetUploadingAsset(ctx context.Context, root cid.Cid) (*types.UploadingAsset, error)
}
Asset represents an interface for fetching and checking asset data.
type HttpServer ¶
type HttpServer struct {
// contains filtered or unexported fields
}
func NewHttpServer ¶
func NewHttpServer(opts *HttpServerOptions) *HttpServer
NewHttpServer creates a new HttpServer with the given Asset, Scheduler, and RSA private key.
func (*HttpServer) FirstToken ¶ added in v0.1.10
func (hs *HttpServer) FirstToken() string
GetDownloadThreadCount get download thread count of httpserver
func (*HttpServer) NewHandler ¶
func (hs *HttpServer) NewHandler(handler http.Handler) http.Handler
NewHandler creates a new Handler with the given HTTP handler
func (*HttpServer) UpdateSchedulerPublicKey ¶
func (hs *HttpServer) UpdateSchedulerPublicKey() error
SetSchedulerPublicKey sets the public key of the scheduler.
type HttpServerOptions ¶ added in v0.1.10
type HttpServerOptions struct {
Asset Asset
Scheduler api.Scheduler
PrivateKey *rsa.PrivateKey
Validation Validation
APISecret *jwt.HMACSHA
}
type ProgressReader ¶ added in v0.1.10
type ProgressReader struct {
// contains filtered or unexported fields
}
type Validation ¶
type Validation interface {
SetFunc(func() string)
}
Source Files
¶
Click to show internal directories.
Click to hide internal directories.