downloader

Documentation

Index

• type Downloader
  • func New(dataNs, dataName, podName, downloadRootDir, localRootDir string, ...) (*Downloader, error)
  • func (d *Downloader) Run(ctx context.Context)
• type Interface
• type PluginFactory
• type Registry
  • func (r Registry) Get(name string) (PluginFactory, error)
  • func (r Registry) Register(name string, factory PluginFactory)
  • func (r Registry) Unregister(name string) error

Types

type Downloader

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

func New

func New(dataNs, dataName, podName, downloadRootDir, localRootDir string, taskCh, noticeCh chan *v1alpha1.Task, registry Registry) (*Downloader, error)

func (*Downloader) Run

func (d *Downloader) Run(ctx context.Context)

type Interface

type Interface interface {
	Download(ctx context.Context, subTask *v1alpha1.SubTask) error
}

type PluginFactory

type PluginFactory = func(downloadRootDir string) Interface

type Registry

type Registry map[string]PluginFactory

func (Registry) Get

func (r Registry) Get(name string) (PluginFactory, error)

func (Registry) Register

func (r Registry) Register(name string, factory PluginFactory)

func (Registry) Unregister

func (r Registry) Unregister(name string) error

Unregister removes an existing plugins from the registry. If no plugins with the provided name exists, it returns an error.