transfer

Documentation

Index

• type Batch
  • func NewBatch(log logrus.FieldLogger, transfers []*Transfer, parallel int, output io.Writer) *Batch
  • func (b *Batch) Transfer(ctx context.Context, failFast bool) error
• type DownloadAsset
• type State
• type Step
• type Transfer
  • func NewTransfer(origin DownloadAsset, steps []Step, finalStatus io.Writer) *Transfer
  • func (w Transfer) Execute(ctx context.Context) error
  • func (w *Transfer) GetSubject() string
  • func (w *Transfer) Prepare(pb *mpb.Progress)

Types

type Batch

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

func NewBatch

func NewBatch(log logrus.FieldLogger, transfers []*Transfer, parallel int, output io.Writer) *Batch

func (*Batch) Transfer

func (b *Batch) Transfer(ctx context.Context, failFast bool) error

type DownloadAsset

type DownloadAsset interface {
	GetName() string
	GetSize() int64
	Open(ctx context.Context) (io.ReadCloser, error)
}

type State

type State struct {
	Bar           *mpb.Bar
	LocalFilePath string
	Results       []string
}

type Step

type Step interface {
	GetProgressParams() (int64, decor.Decorator)
	Execute(ctx context.Context, s *State) error
}

type Transfer

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

func NewTransfer

func NewTransfer(origin DownloadAsset, steps []Step, finalStatus io.Writer) *Transfer

func (Transfer) Execute

func (w Transfer) Execute(ctx context.Context) error

func (*Transfer) GetSubject

func (w *Transfer) GetSubject() string

func (*Transfer) Prepare

func (w *Transfer) Prepare(pb *mpb.Progress)