plg

Documentation

Index

• func NewDownload() aqua.MiddleManager
• func NewFetch() aqua.MiddleManager
• func NewMiddleware() aqua.MiddleManager
• func NewStorage() aqua.MiddleManager
• func NewTransfer() aqua.MiddleManager
• type Download
  • func (m *Download) Instance(c *aqua.Carrior) Downloader
  • func (m *Download) Run(grt_idx int)
  • func (m *Download) Template(d Downloader)
• type Downloader
• type Fetch
  • func (m *Fetch) Instance(c *aqua.Carrior) Fetcher
  • func (m *Fetch) Run(grt_idx int)
  • func (m *Fetch) Template(f Fetcher)
• type Fetcher
• type Middleware
  • func (m *Middleware) Close()
  • func (m *Middleware) GetInChan() *aqua.Chan
  • func (m *Middleware) GetOutChan() *aqua.Chan
  • func (m *Middleware) Pop(f func(*aqua.Carrior))
  • func (m *Middleware) Run(i int)
  • func (m *Middleware) SetInChan(c *aqua.Chan)
  • func (m *Middleware) SetMWNode(mwn *aqua.MWNode)
  • func (m *Middleware) SetOutChan(c *aqua.Chan)
• type Storage
  • func (m *Storage) Instance(c *aqua.Carrior) Storager
  • func (m *Storage) Run(grt_idx int)
  • func (m *Storage) Template(d Storager)
• type Storager
• type Transfer
  • func (m *Transfer) Instance(c *aqua.Carrior) Transferer
  • func (m *Transfer) Run(grt_idx int)
  • func (m *Transfer) Template(d Transferer)
• type Transferer

Functions

func NewDownload

func NewDownload() aqua.MiddleManager

func NewFetch

func NewFetch() aqua.MiddleManager

func NewMiddleware

func NewMiddleware() aqua.MiddleManager

func NewStorage

func NewStorage() aqua.MiddleManager

func NewTransfer

func NewTransfer() aqua.MiddleManager

Types

type Download

type Download struct {
	Middleware
}

func (*Download) Instance

func (m *Download) Instance(c *aqua.Carrior) Downloader

func (*Download) Run

func (m *Download) Run(grt_idx int)

func (*Download) Template

func (m *Download) Template(d Downloader)

中间件处理的业务

type Downloader

type Downloader interface {
	DownloadCover()
	DownloadVideo()
}

type Fetch

type Fetch struct {
	Middleware
}

func (*Fetch) Instance

func (m *Fetch) Instance(c *aqua.Carrior) Fetcher

func (*Fetch) Run

func (m *Fetch) Run(grt_idx int)

func (*Fetch) Template

func (m *Fetch) Template(f Fetcher)

中间件处理的业务

type Fetcher

type Fetcher interface {
	GetData() []int
}

type Middleware

type Middleware struct {
	Name    string
	Node    *aqua.MWNode
	InChan  *aqua.Chan
	OutChan *aqua.Chan
}

中间件

func (*Middleware) Close

func (m *Middleware) Close()

func (*Middleware) GetInChan

func (m *Middleware) GetInChan() *aqua.Chan

func (*Middleware) GetOutChan

func (m *Middleware) GetOutChan() *aqua.Chan

func (*Middleware) Pop

func (m *Middleware) Pop(f func(*aqua.Carrior))

func (*Middleware) Run

func (m *Middleware) Run(i int)

func (*Middleware) SetInChan

func (m *Middleware) SetInChan(c *aqua.Chan)

func (*Middleware) SetMWNode

func (m *Middleware) SetMWNode(mwn *aqua.MWNode)

func (*Middleware) SetOutChan

func (m *Middleware) SetOutChan(c *aqua.Chan)

type Storage

type Storage struct {
	Middleware
}

func (*Storage) Instance

func (m *Storage) Instance(c *aqua.Carrior) Storager

func (*Storage) Run

func (m *Storage) Run(grt_idx int)

func (*Storage) Template

func (m *Storage) Template(d Storager)

中间件处理的业务

type Storager

type Storager interface {
	StorageCover()
	StorageVideo()
}

type Transfer

type Transfer struct {
	Middleware
}

func (*Transfer) Instance

func (m *Transfer) Instance(c *aqua.Carrior) Transferer

func (*Transfer) Run

func (m *Transfer) Run(grt_idx int)

func (*Transfer) Template

func (m *Transfer) Template(d Transferer)

中间件处理的业务

type Transferer

type Transferer interface {
	TransferCover()
	TransferVideo()
}