Versions in this module Expand all Collapse all v0 v0.1.2 Mar 7, 2019 Changes in this version type TransferRequest + OmitEmpty bool + WriterThreads int v0.1.0 Jun 15, 2018 Changes in this version + const TransferModeInsert + func NewRouter(dummyService *Service) http.Handler + type Dest struct + Table string + func (s *Dest) Validate() error + type Router struct + type Server struct + func NewServer(service *Service, port int) *Server + func (s *Server) Stop() + func (s *Server) StopOnSiginals(siginals ...os.Signal) + type Service struct + func New() *Service + func (s *Service) Task(id int, writer http.ResponseWriter) *TransferTask + func (s *Service) Tasks() *TasksResponse + func (s *Service) Transfer(request *TransferRequest) *TransferResponse + type Source struct + Query string + func (s *Source) Validate() error + type Tasks []*TransferTask + func (a Tasks) Len() int + func (a Tasks) Less(i, j int) bool + func (a Tasks) Swap(i, j int) + type TasksResponse struct + Tasks Tasks + type TransferRequest struct + BatchSize int + Dest *Dest + Mode string + QueueBufferFactor float32 + Source *Source + WriterCount int + func (r *TransferRequest) Clone() *TransferRequest + func (r *TransferRequest) Init() error + func (r *TransferRequest) Validate() error + type TransferResponse struct + Error string + Status string + TaskId int + func (r *TransferResponse) SetError(err error) + type TransferTask struct + EndTime *time.Time + Error string + ID int + ReadCount int + Request *TransferRequest + StartTime time.Time + Status string + TimeTakenMs int + WriteCount uint64 + func NewTransferTask(request *TransferRequest) (*TransferTask, error) + func (t *TransferTask) CanEvict() bool + func (t *TransferTask) HasError() bool + func (t *TransferTask) IsReading() bool + func (t *TransferTask) SetError(err error)