simple

Documentation

Index

• type HttpWgetLoader
  • func NewHttpWgetLoader(url string, resultCollector chan int64) *HttpWgetLoader
  • func (h *HttpWgetLoader) Load(ctx context.Context)
  • func (h *HttpWgetLoader) Prepare(ctx context.Context) error
• type LoadManager
  • func (s *LoadManager) LoadAll(ctx context.Context) error
  • func (s *LoadManager) Register(loader concurrentload.Loader)

Types

type HttpWgetLoader

type HttpWgetLoader struct {
	Url string

	Error error
	// contains filtered or unexported fields
}

func NewHttpWgetLoader

func NewHttpWgetLoader(url string, resultCollector chan int64) *HttpWgetLoader

func (*HttpWgetLoader) Load

func (h *HttpWgetLoader) Load(ctx context.Context)

func (*HttpWgetLoader) Prepare

func (h *HttpWgetLoader) Prepare(ctx context.Context) error

type LoadManager

type LoadManager struct {
	Loaders []concurrentload.Loader
}

func (*LoadManager) LoadAll

func (s *LoadManager) LoadAll(ctx context.Context) error

func (*LoadManager) Register

func (s *LoadManager) Register(loader concurrentload.Loader)