export

Documentation

Index

• type ConceptWriter
• type CsvExporter
  • func NewCsvExporter() *CsvExporter
  • func (e *CsvExporter) GetBytes(conceptType string) []byte
  • func (e *CsvExporter) GetFileName(conceptType string) string
  • func (e *CsvExporter) Prepare(conceptTypes []string) error
  • func (e *CsvExporter) Write(c db.Concept, conceptType, tid string) error
• type FullExporter
  • func NewFullExporter(nrOfWorkers int, exporter concept.Updater, inquirer concept.Inquirer, ...) *FullExporter
  • func (fe *FullExporter) CreateJob(candidates []string, errMsg string) Job
  • func (fe *FullExporter) GetCurrentJob() Job
  • func (fe *FullExporter) IsRunningJob() bool
  • func (fe *FullExporter) RunFullExport(tid string)
• type Job

Types

type ConceptWriter

type ConceptWriter struct {
	Buffer *bytes.Buffer
	Writer *csv.Writer
}

type CsvExporter

type CsvExporter struct {
	Writer map[string]*ConceptWriter
}

func NewCsvExporter

func NewCsvExporter() *CsvExporter

func (*CsvExporter) GetBytes

func (e *CsvExporter) GetBytes(conceptType string) []byte

func (*CsvExporter) GetFileName

func (e *CsvExporter) GetFileName(conceptType string) string

func (*CsvExporter) Prepare

func (e *CsvExporter) Prepare(conceptTypes []string) error

func (*CsvExporter) Write

func (e *CsvExporter) Write(c db.Concept, conceptType, tid string) error

type FullExporter

type FullExporter struct {
	sync.RWMutex

	NrOfConcurrentWorkers int
	Updater               concept.Updater
	Inquirer              concept.Inquirer
	Exporter              *CsvExporter
	Log                   *logger.UPPLogger
	// contains filtered or unexported fields
}

func NewFullExporter

func NewFullExporter(nrOfWorkers int, exporter concept.Updater, inquirer concept.Inquirer, csvExporter *CsvExporter, log *logger.UPPLogger) *FullExporter

func (*FullExporter) CreateJob

func (fe *FullExporter) CreateJob(candidates []string, errMsg string) Job

func (*FullExporter) GetCurrentJob

func (fe *FullExporter) GetCurrentJob() Job

func (*FullExporter) IsRunningJob

func (fe *FullExporter) IsRunningJob() bool

func (*FullExporter) RunFullExport

func (fe *FullExporter) RunFullExport(tid string)

type Job

type Job struct {
	sync.RWMutex
	NrWorker     int               `json:"-"`
	Workers      []*concept.Worker `json:"ConceptWorkers,omitempty"`
	ID           string            `json:"ID"`
	Concepts     []string          `json:"Concepts,omitempty"`
	Progress     []string          `json:"Progress,omitempty"`
	Failed       []string          `json:"Failed,omitempty"`
	Status       concept.State     `json:"Status"`
	ErrorMessage string            `json:"ErrorMessage,omitempty"`
}