sync

Documentation

Index

• func Dump() ([]byte, error)
• func Restore()
• func Sync(ctx context.Context, deferConstraints bool, tasks []Task, ...) error
• type SafeBuffer
  • func NewSafeBuffer(buffer io.ReadWriter) *SafeBuffer
  • func (b *SafeBuffer) Read(p []byte) (n int, err error)
  • func (b *SafeBuffer) SetDone()
  • func (b *SafeBuffer) Write(p []byte) (n int, err error)
• type TableSync
  • func NewTableSync(source *datasource.ReaderDataSource, dest *datasource.ReadWriteDatasource) *TableSync
  • func (t *TableSync) Sync(ctx context.Context, task *Task) error
• type Task
  • func (t *Task) GetDestPKs() []string
  • func (t *Task) GetSharedColumnNames() []string
• type TaskResolver
  • func NewTaskResolver(source *datasource.ReaderDataSource, ...) *TaskResolver
  • func (tr *TaskResolver) Resolve(ctx context.Context, groupArgs []string, tableArgs []string) ([]Task, error)

Functions

func Dump

func Dump() ([]byte, error)

func Restore

func Restore()

func Sync

func Sync(ctx context.Context, deferConstraints bool, tasks []Task, source *datasource.ReaderDataSource, dest *datasource.ReadWriteDatasource) error

Types

type SafeBuffer

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

func NewSafeBuffer

func NewSafeBuffer(buffer io.ReadWriter) *SafeBuffer

func (*SafeBuffer) Read

func (b *SafeBuffer) Read(p []byte) (n int, err error)

func (*SafeBuffer) SetDone

func (b *SafeBuffer) SetDone()

func (*SafeBuffer) Write

func (b *SafeBuffer) Write(p []byte) (n int, err error)

type TableSync

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

func NewTableSync

func NewTableSync(source *datasource.ReaderDataSource, dest *datasource.ReadWriteDatasource) *TableSync

func (*TableSync) Sync

func (t *TableSync) Sync(ctx context.Context, task *Task) error

type Task

type Task struct {
	db.Table
	DestColumns      []db.Column
	SourceColumns    []db.Column
	DestPK           []db.PrimaryKey
	SourceSequences  []db.Sequence
	DestSequences    []db.Sequence
	Filter           string
	Preserve         bool
	Truncate         bool
	DeferConstraints bool
}

func (*Task) GetDestPKs

func (t *Task) GetDestPKs() []string

func (*Task) GetSharedColumnNames

func (t *Task) GetSharedColumnNames() []string

type TaskResolver

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

func NewTaskResolver

func NewTaskResolver(source *datasource.ReaderDataSource, destination *datasource.ReadWriteDatasource, groups map[string]map[string]string, truncate bool, preserve bool, deferConstraints bool, excluded []db.Table) *TaskResolver

func (*TaskResolver) Resolve

func (tr *TaskResolver) Resolve(ctx context.Context, groupArgs []string, tableArgs []string) ([]Task, error)