func NewRoutine() Routine {
	return &defaultRoutine{}
}
NewRoutine creates a new
package ts
import (
	"fmt"
	"log"
	"github.com/jackc/pgx"
	"github.com/timescale/outflux/internal/connections"
	"github.com/timescale/outflux/internal/idrf"
	"github.com/timescale/outflux/internal/ingestion/config"
	"github.com/timescale/outflux/internal/utils"
)
type ingestDataArgs struct {
	ingestorID string
	errChan chan error
	ackChannel chan bool
	dataChannel chan idrf.Row
	batchSize uint16
	rollbackOnExternalError bool
	dbConn connections.PgxWrap
	colNames []string
	tableName string
	schemaName string
	commitStrategy config.CommitStrategy
}
type Routine interface {
	ingest(args *ingestDataArgs) error
}