pkg

Documentation

Index

• func ReadDataFromFile(inputFile string, creator Creator) ([]interface{}, error)
• func Start(creator Creator, inputs []interface{}, semaphoreSize int, logFileName string)
• type Creator
• type Current
• type Status
  • func (s *Status) Set(status Current)

Functions

func ReadDataFromFile

func ReadDataFromFile(inputFile string, creator Creator) ([]interface{}, error)

func Start

func Start(creator Creator, inputs []interface{}, semaphoreSize int, logFileName string)

Creator is an interface that needs to be implemented by the user of the library

import "github.com/vbauerster/mpb/v8" <- progress bar library

type Creator interface {
	CreateFromInput(input interface{}, bar *mpb.Bar, progress chan<- int, cancel <-chan struct{}, statusChan chan<- Status, status *Status)
	ConvertToInput(data []string) interface{}
}

Inputs is any csv file that can be converted to a slice of strings SemaphoreSize is the number of goroutines/csv lines that can run in parallel LogFileName is the name of the log file

Types

type Creator

type Creator interface {
	CreateFromInput(input interface{}, bar *mpb.Bar, progress chan<- int, cancel <-chan struct{}, statusChan chan<- Status, status *Status)
	ConvertToInput(data []string) interface{}
}

type Current

type Current string

const (
	Starting  Current = "starting"
	Working   Current = "working"
	Error     Current = "error"
	Retrying  Current = "retrying"
	Completed Current = "completed"
	Failed    Current = "failed"
)

type Status

type Status struct {
	Current Current
}

func (*Status) Set

func (s *Status) Set(status Current)