importer

Documentation

Index

• Constants
• func GetDataFromXls(file multipart.File) ([][]string, error)
• func GetDataFromXlsx(file multipart.File, sheetName string) ([][]string, error)
• func New(opt ...ImportOptions) *importer
• type ImportOptions
  • func WithCtx(ctx context.Context) ImportOptions
  • func WithExtFile(ext string) ImportOptions
  • func WithFile(file multipart.File) ImportOptions
  • func WithProcessFn(fn processFn) ImportOptions
  • func WithProcessName(processName string) ImportOptions
  • func WithSentNotifToSlack(sent bool, channel ...string) ImportOptions
  • func WithSheetName(sheetName string) ImportOptions
  • func WithStructDestination(structDestination interface{}) ImportOptions
  • func WithTransaction(trx database.Transactions) ImportOptions
  • func WithWorker(totalWorker int) ImportOptions
• type ImportResult

Constants

const (
	ExcelFileType         = "excel"
	ExcelWorkbookFileType = "excel_workbook"
	CSVFileType           = "csv"
	UndefinedFileType     = ""

	ExcelExt         = ".xls"
	ExcelWorkbookExt = ".xlsx"
	CSVExt           = ".csv"
)

Functions

func GetDataFromXls

func GetDataFromXls(file multipart.File) ([][]string, error)

func GetDataFromXlsx

func GetDataFromXlsx(file multipart.File, sheetName string) ([][]string, error)

func New

func New(opt ...ImportOptions) *importer

Types

type ImportOptions

type ImportOptions func(reader *importer)

func WithCtx

func WithCtx(ctx context.Context) ImportOptions

func WithExtFile

func WithExtFile(ext string) ImportOptions

func WithFile

func WithFile(file multipart.File) ImportOptions

func WithProcessFn

func WithProcessFn(fn processFn) ImportOptions

func WithProcessName

func WithProcessName(processName string) ImportOptions

func WithSentNotifToSlack

func WithSentNotifToSlack(sent bool, channel ...string) ImportOptions

func WithSheetName

func WithSheetName(sheetName string) ImportOptions

func WithStructDestination

func WithStructDestination(structDestination interface{}) ImportOptions

func WithTransaction

func WithTransaction(trx database.Transactions) ImportOptions

func WithWorker

func WithWorker(totalWorker int) ImportOptions

type ImportResult

type ImportResult struct {
	FailedList    map[string][]interface{} `json:"failed_list"`
	TotalData     int                      `json:"total_data"`
	TotalFailed   int                      `json:"total_failed"`
	ExecutionTime float64                  `json:"execution_time"`
}