httpserver

package
v0.1.10 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 28, 2023 License: MIT Imports: 46 Imported by: 0

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 Handler

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

func (*Handler) ServeHTTP

func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP checks if the request path starts with the IPFS path prefix and delegates to the appropriate handler

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
}

func (*ProgressReader) Read added in v0.1.10

func (pr *ProgressReader) Read(p []byte) (n int, err error)

type Validation

type Validation interface {
	SetFunc(func() string)
}

Jump to

Keyboard shortcuts

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