task

type ActivityResult struct {
	Export *ExportActivityResult
}

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

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

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

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