task

Documentation

Index

• type ActivityResult
  • func NewActivityResult() *ActivityResult
  • func (r *ActivityResult) Merge(that *ActivityResult)
• type ActivityRunParams
• type ActivityRunner
• type CompositeActivityRunner
  • func NewCompositeActivityRunner(exportRunner *ExportActivityRunner, importRunner *ImportActivityRunner) *CompositeActivityRunner
  • func (r *CompositeActivityRunner) Run(ctx context.Context, expParams *ActivityRunParams) (*ActivityResult, error)
• type ExportActivityResult
  • func (r *ExportActivityResult) GetFiles() []fs.FileInfo
• type ExportActivityRunner
  • func NewExportActivityRunner(fs fs.Driver, renderer *template.Renderer, ...) *ExportActivityRunner
  • func (r *ExportActivityRunner) Run(ctx context.Context, expParams *ActivityRunParams) (*ActivityResult, error)
• type ImportActivityResult
  • func (r *ImportActivityResult) GetFiles() []exporter.ImportedFile
  • func (r *ImportActivityResult) GetTableRowCountMap() map[string]int64
• type ImportActivityRunner
  • func NewImportActivityRunner(fs fs.Driver, importers map[config.ImporterName]exporter.Importer) *ImportActivityRunner
  • func (a *ImportActivityRunner) Run(ctx context.Context, params *ActivityRunParams) (*ActivityResult, error)

Types

type ActivityResult

type ActivityResult struct {
	Import *ImportActivityResult
	Export *ExportActivityResult
}

func NewActivityResult

func NewActivityResult() *ActivityResult

func (*ActivityResult) Merge

func (r *ActivityResult) Merge(that *ActivityResult)

type ActivityRunParams

type ActivityRunParams struct {
	Activity config.Activity
	Schema   *schema.Schema
	Conn     *conn.Connection
}

type ActivityRunner

type ActivityRunner interface {
	Run(ctx context.Context, params *ActivityRunParams) (*ActivityResult, error)
}

type CompositeActivityRunner

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

func NewCompositeActivityRunner

func NewCompositeActivityRunner(
	exportRunner *ExportActivityRunner,
	importRunner *ImportActivityRunner,
) *CompositeActivityRunner

func (*CompositeActivityRunner) Run

func (r *CompositeActivityRunner) Run(ctx context.Context, expParams *ActivityRunParams) (*ActivityResult, error)

type ExportActivityResult

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

func (*ExportActivityResult) GetFiles

func (r *ExportActivityResult) GetFiles() []fs.FileInfo

type ExportActivityRunner

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

func NewExportActivityRunner

func NewExportActivityRunner(
	fs fs.Driver,
	renderer *template.Renderer,
	exporters map[config.ExporterName]exporter.Exporter,
) *ExportActivityRunner

func (*ExportActivityRunner) Run

func (r *ExportActivityRunner) Run(ctx context.Context, expParams *ActivityRunParams) (*ActivityResult, error)

type ImportActivityResult

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

func (*ImportActivityResult) GetFiles

func (r *ImportActivityResult) GetFiles() []exporter.ImportedFile

func (*ImportActivityResult) GetTableRowCountMap

func (r *ImportActivityResult) GetTableRowCountMap() map[string]int64

type ImportActivityRunner

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

func NewImportActivityRunner

func NewImportActivityRunner(fs fs.Driver, importers map[config.ImporterName]exporter.Importer) *ImportActivityRunner

func (*ImportActivityRunner) Run

func (a *ImportActivityRunner) Run(ctx context.Context, params *ActivityRunParams) (*ActivityResult, error)