seq

Documentation

Overview

Package seq implements a simple Sequential Uploader. Upload jobs are processed sequentially in-order.

Index

• type Logger
• type Uploader
  • func New(logger Logger, filecopyUploader, s3Uploader, dockerUploader upload.Uploader, ...) *Uploader
  • func (u *Uploader) Add(job scheduler.Job)
  • func (u *Uploader) Start()
  • func (u *Uploader) Stop()

Types

type Logger

type Logger interface {
	Debugf(format string, v ...interface{})
}

Logger defines the logger interface

type Uploader

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

Uploader is a sequential uploader

func New

func New(logger Logger, filecopyUploader, s3Uploader, dockerUploader upload.Uploader, status chan<- *scheduler.Result) *Uploader

New initializes a sequential uploader Status chan must have a buffer count > 1 otherwise a deadlock occurs

func (*Uploader) Add

func (u *Uploader) Add(job scheduler.Job)

Add adds a new upload job, can be called after Start()

func (*Uploader) Start

func (u *Uploader) Start()

Start starts uploading jobs in the queue. If the statusChan buffer is full, uploading will be blocked.

func (*Uploader) Stop

func (u *Uploader) Stop()

Stop stops the uploader