download

Documentation

Index

• type DownloadConsumer
  • func NewConsumer(cfg *config.Dendrite, feddomains *common.FedDomains, ...) *DownloadConsumer
  • func (p *DownloadConsumer) AddReq(domain, netdiskID string)
  • func (p *DownloadConsumer) OnMessage(ctx context.Context, topic string, partition int32, data []byte, ...)
  • func (p *DownloadConsumer) Start() error
• type DownloadInfo

Types

type DownloadConsumer

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

func NewConsumer

func NewConsumer(
	cfg *config.Dendrite,
	feddomains *common.FedDomains,
	fedClient *client.FedClientWrap,
	db model.ContentDatabase,
	repo *repos.DownloadStateRepo,
) *DownloadConsumer

func (*DownloadConsumer) AddReq

func (p *DownloadConsumer) AddReq(domain, netdiskID string)

AddReq 不会保存到数据库

func (*DownloadConsumer) OnMessage

func (p *DownloadConsumer) OnMessage(ctx context.Context, topic string, partition int32, data []byte, rawMsg interface{})

func (*DownloadConsumer) Start

func (p *DownloadConsumer) Start() error

type DownloadInfo

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