cdn

Documentation

Index

• func NewManager(cfg *config.Config, cacheStore *store.Store, progressManager mgr.ProgressMgr, ...) (mgr.CDNMgr, error)
• type Manager
  • func (cm *Manager) CheckFile(ctx context.Context, taskID string) bool
  • func (cm *Manager) Delete(ctx context.Context, taskID string, force bool) error
  • func (cm *Manager) GetGCTaskIDs(ctx context.Context, taskMgr mgr.TaskMgr) ([]string, error)
  • func (cm *Manager) GetHTTPPath(ctx context.Context, taskInfo *types.TaskInfo) (string, error)
  • func (cm *Manager) GetPieceMD5(ctx context.Context, taskID string, pieceNum int, pieceRange, source string) (pieceMd5 string, err error)
  • func (cm *Manager) GetStatus(ctx context.Context, taskID string) (cdnStatus string, err error)
  • func (cm *Manager) TriggerCDN(ctx context.Context, task *types.TaskInfo) (*types.TaskInfo, error)

Functions

func NewManager

func NewManager(cfg *config.Config, cacheStore *store.Store, progressManager mgr.ProgressMgr,
	originClient httpclient.OriginHTTPClient, register prometheus.Registerer) (mgr.CDNMgr, error)

NewManager returns a new Manager.

Types

type Manager

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

Manager is an implementation of the interface of CDNMgr which use source as CDN node.

func (*Manager) CheckFile

func (cm *Manager) CheckFile(ctx context.Context, taskID string) bool

CheckFile checks the file whether exists.

func (*Manager) Delete

func (cm *Manager) Delete(ctx context.Context, taskID string, force bool) error

Delete the cdn meta with specified taskID. It will also delete the files on the disk when the force equals true.

func (*Manager) GetGCTaskIDs

func (cm *Manager) GetGCTaskIDs(ctx context.Context, taskMgr mgr.TaskMgr) ([]string, error)

func (*Manager) GetHTTPPath

func (cm *Manager) GetHTTPPath(ctx context.Context, taskInfo *types.TaskInfo) (string, error)

GetHTTPPath returns the http download path of taskID.

func (*Manager) GetPieceMD5

func (cm *Manager) GetPieceMD5(ctx context.Context, taskID string, pieceNum int, pieceRange, source string) (pieceMd5 string, err error)

GetPieceMD5 gets the piece Md5 accorrding to the specified taskID and pieceNum.

func (*Manager) GetStatus

func (cm *Manager) GetStatus(ctx context.Context, taskID string) (cdnStatus string, err error)

GetStatus gets the status of the file.

func (*Manager) TriggerCDN

func (cm *Manager) TriggerCDN(ctx context.Context, task *types.TaskInfo) (*types.TaskInfo, error)

TriggerCDN will trigger CDN to download the file from sourceUrl.