export

package

v0.0.0-...-d841f61 Latest Latest Go to latest Published: Jun 11, 2021 License: AGPL-3.0 Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

git.canopsis.net/canopsis/go-engines

Documentation ¶

Index ¶

Constants
func ConvertToMap(data interface{}, fields []string, timeFormat string, location *time.Location) ([]map[string]string, error)
func ExportCsv(ctx context.Context, exportFields []string, separator rune, ...) (resFileName string, resErr error)
type DataFetcher
type Task
type TaskExecutor
- func NewTaskExecutor(client mongo.DbClient, logger zerolog.Logger) TaskExecutor
type TaskStatus

Constants ¶

View Source

const (
	TaskStatusRunning = iota
	TaskStatusSucceeded
	TaskStatusFailed
)

Variables ¶

This section is empty.

Functions ¶

func ConvertToMap ¶

func ConvertToMap(
	data interface{},
	fields []string,
	timeFormat string,
	location *time.Location,
) ([]map[string]string, error)

ConvertToMap converts array of structs to array of maps with flatten keys.

func ExportCsv ¶

func ExportCsv(
	ctx context.Context,
	exportFields []string,
	separator rune,
	dataFetcher DataFetcher,
) (resFileName string, resErr error)

ExportCsv fetches data by page and saves it in csv file.

Types ¶

type DataFetcher ¶

type DataFetcher func(ctx context.Context, page, limit int64) ([]map[string]string, int64, error)

type Task ¶

type Task struct {
	ExportFields []string
	Separator    rune
	DataFetcher  DataFetcher
}

type TaskExecutor ¶

type TaskExecutor interface {
	// StartExecute creates new export task.
	StartExecute(ctx context.Context, t Task) (string, error)
	// Execute receives tasks from channel and save its result to storage.
	Execute(ctx context.Context)
	// GetStatus returns export task status.
	GetStatus(ctx context.Context, id string) (*TaskStatus, error)
}

TaskExecutor is used to implement export task executor.

func NewTaskExecutor ¶

func NewTaskExecutor(
	client mongo.DbClient,
	logger zerolog.Logger,
) TaskExecutor

type TaskStatus ¶

type TaskStatus struct {
	Status int    `bson:"status"`
	File   string `bson:"file"`
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL