Documentation ¶
Index ¶
Constants ¶
View Source
const (
TransferModeInsert = "insert"
)
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Server ¶
func (*Server) StopOnSiginals ¶
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func New ¶
func New(interactive bool, callback func(task *TransferTask)) *Service
func (*Service) Task ¶
func (s *Service) Task(id int, writer http.ResponseWriter) *TransferTask
func (*Service) Tasks ¶
func (s *Service) Tasks() *TasksResponse
func (*Service) Transfer ¶
func (s *Service) Transfer(request *TransferRequest) *TransferResponse
type Tasks ¶
type Tasks []*TransferTask
type TransferRequest ¶
type TransferRequest struct { Source *Source Dest *Dest BatchSize int WriterThreads int `description:"number of writer go routines"` Mode string `description:"supported values: insert or persist"` OmitEmpty bool `description:"if set set null for any 0 or empty values"` }
TransferRequest represents transfer request
func (*TransferRequest) Init ¶
func (r *TransferRequest) Init() error
func (*TransferRequest) Validate ¶
func (r *TransferRequest) Validate() error
Validate validates request
type TransferResponse ¶
TransferResponse transfer response
func (*TransferResponse) SetError ¶
func (r *TransferResponse) SetError(err error)
type TransferTask ¶
type TransferTask struct { ID int Request *TransferRequest StartTime time.Time EndTime *time.Time Error string Status string ReadCount int WriteCount uint64 TimeTakenMs int // contains filtered or unexported fields }
TransferTask represents a transfer tasks
func NewTransferTask ¶
func NewTransferTask(request *TransferRequest) (*TransferTask, error)
func (*TransferTask) CanEvict ¶
func (t *TransferTask) CanEvict() bool
func (*TransferTask) HasError ¶
func (t *TransferTask) HasError() bool
IsReading returns true if error occured
func (*TransferTask) IsReading ¶
func (t *TransferTask) IsReading() bool
IsReading returns true if transfer read data from the source
func (*TransferTask) SetError ¶
func (t *TransferTask) SetError(err error)
Click to show internal directories.
Click to hide internal directories.