httpserver

Documentation

Index

• type Asset
• type DirectoryResult
• type FileList
• type FileProperty
• type Handler
  • func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type HttpServer
  • func NewHttpServer(opts *HttpServerOptions) *HttpServer
  • func (hs *HttpServer) FirstToken() string
  • func (hs *HttpServer) NewHandler(handler http.Handler) http.Handler
• type HttpServerOptions
• type ProgressReader
  • func (pr *ProgressReader) Read(p []byte) (n int, err error)
• type SpeedCountWriter
  • func (w *SpeedCountWriter) CostTime() float64
  • func (w *SpeedCountWriter) Header() http.Header
  • func (w *SpeedCountWriter) Write(bytes []byte) (int, error)
  • func (w *SpeedCountWriter) WriteHeader(statusCode int)
• type Validation

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 DirectoryResult

type DirectoryResult struct {
	Data FileList `json:"data"`
	Code int      `json:"code"`
	Msg  string   `json:"msg"`
}

type FileList

type FileList struct {
	FileProperties []FileProperty
	Name           string
	Size           int64
	Total          int
}

type FileProperty

type FileProperty struct {
	FileName string
	CID      string
	Size     int64
	Link     string
}

SubAsset the content of directory

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

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

type HttpServerOptions

type HttpServerOptions struct {
	Asset               Asset
	Scheduler           api.Scheduler
	PrivateKey          *rsa.PrivateKey
	Validation          Validation
	APISecret           *jwt.HMACSHA
	MaxSizeOfUploadFile int
	WebRedirect         string
	RateLimiter         *types.RateLimiter
}

type ProgressReader

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

func (*ProgressReader) Read

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

type SpeedCountWriter

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

func (*SpeedCountWriter) CostTime

func (w *SpeedCountWriter) CostTime() float64

ms

func (*SpeedCountWriter) Header

func (w *SpeedCountWriter) Header() http.Header

func (*SpeedCountWriter) Write

func (w *SpeedCountWriter) Write(bytes []byte) (int, error)

func (*SpeedCountWriter) WriteHeader

func (w *SpeedCountWriter) WriteHeader(statusCode int)

type Validation

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