transfer

README

Transfer

MongoDB driver

https://github.com/mongodb/mongo-go-driver

Documentation

Index

• type Configuration
• type Logger
• type Source
  • func GenerateSourceTransfer(args *database.Options) (source Source, err error)
• type Target
  • func GenerateTargetTransfer(args *database.Options) (target Target, err error)
• type Task
  • func NewTask(config Configuration) (task *Task, err error)
  • func (task *Task) Run() (err error)

Types

type Configuration

type Configuration struct {
	Source database.Driver `mapstructure:"source"`
	Target database.Driver `mapstructure:"target"`

	Mapping database.Mapping `mapstructure:"mapping"`
	Query   database.Query   `mapstructure:"query"`
}

Configuration task configuration

type Logger

type Logger interface {
	Print(v ...interface{})
}

Logger is used to log critical error messages.

type Source

type Source interface {
	Reader(query database.Query) (database.Packet, error)
}

Source for transfer

func GenerateSourceTransfer

func GenerateSourceTransfer(args *database.Options) (source Source, err error)

GenerateSourceTransfer return source transfer

type Target

type Target interface {
	Writer(packet database.Packet) error
}

Target for transfer

func GenerateTargetTransfer

func GenerateTargetTransfer(args *database.Options) (target Target, err error)

GenerateTargetTransfer return target transfer

type Task

type Task struct {
	Query  database.Query
	Source Source
	Target Target
	// contains filtered or unexported fields
}

Task for transfer

func NewTask

func NewTask(config Configuration) (task *Task, err error)

NewTask return task

func (*Task) Run

func (task *Task) Run() (err error)

Run task