restorers

Documentation

Index

• Constants
• type BlobsRestorer
  • func NewBlobsRestorer(entry *toc.Entry, st storages.Storager, usePgzip bool) *BlobsRestorer
  • func (td *BlobsRestorer) DebugInfo() string
  • func (td *BlobsRestorer) Execute(ctx context.Context, conn *pgx.Conn) error
  • func (td *BlobsRestorer) GetEntry() *toc.Entry
• type RestoreTask
• type SequenceRestorer
  • func NewSequenceRestorer(entry *toc.Entry) *SequenceRestorer
  • func (td *SequenceRestorer) DebugInfo() string
  • func (td *SequenceRestorer) Execute(ctx context.Context, conn *pgx.Conn) error
  • func (td *SequenceRestorer) GetEntry() *toc.Entry
• type TableRestorer
  • func NewTableRestorer(entry *toc.Entry, st storages.Storager, exitOnError bool, usePgzip bool, ...) *TableRestorer
  • func (td *TableRestorer) DebugInfo() string
  • func (td *TableRestorer) Execute(ctx context.Context, conn *pgx.Conn) error
  • func (td *TableRestorer) GetEntry() *toc.Entry
• type TableRestorerInsertFormat
  • func NewTableRestorerInsertFormat(entry *toc.Entry, t *toolkit.Table, st storages.Storager, exitOnError bool, ...) *TableRestorerInsertFormat
  • func (td *TableRestorerInsertFormat) DebugInfo() string
  • func (td *TableRestorerInsertFormat) Execute(ctx context.Context, conn *pgx.Conn) error
  • func (td *TableRestorerInsertFormat) GetEntry() *toc.Entry

Constants

const DefaultBufferSize = 1024 * 1024

Types

type BlobsRestorer

type BlobsRestorer struct {
	Entry *toc.Entry
	St    storages.Storager
	// contains filtered or unexported fields
}

func NewBlobsRestorer

func NewBlobsRestorer(entry *toc.Entry, st storages.Storager, usePgzip bool) *BlobsRestorer

func (*BlobsRestorer) DebugInfo

func (td *BlobsRestorer) DebugInfo() string

func (*BlobsRestorer) Execute

func (td *BlobsRestorer) Execute(ctx context.Context, conn *pgx.Conn) error

func (*BlobsRestorer) GetEntry

func (td *BlobsRestorer) GetEntry() *toc.Entry

type RestoreTask

type RestoreTask interface {
	Execute(ctx context.Context, conn *pgx.Conn) error
	DebugInfo() string
	GetEntry() *toc.Entry
}

type SequenceRestorer

type SequenceRestorer struct {
	Entry *toc.Entry
}

func NewSequenceRestorer

func NewSequenceRestorer(entry *toc.Entry) *SequenceRestorer

func (*SequenceRestorer) DebugInfo

func (td *SequenceRestorer) DebugInfo() string

func (*SequenceRestorer) Execute

func (td *SequenceRestorer) Execute(ctx context.Context, conn *pgx.Conn) error

func (*SequenceRestorer) GetEntry

func (td *SequenceRestorer) GetEntry() *toc.Entry

type TableRestorer

type TableRestorer struct {
	Entry *toc.Entry
	St    storages.Storager
	// contains filtered or unexported fields
}

func NewTableRestorer

func NewTableRestorer(
	entry *toc.Entry, st storages.Storager, exitOnError bool, usePgzip bool, batchSize int64,
) *TableRestorer

func (*TableRestorer) DebugInfo

func (td *TableRestorer) DebugInfo() string

func (*TableRestorer) Execute

func (td *TableRestorer) Execute(ctx context.Context, conn *pgx.Conn) error

func (*TableRestorer) GetEntry

func (td *TableRestorer) GetEntry() *toc.Entry

type TableRestorerInsertFormat

type TableRestorerInsertFormat struct {
	Entry *toc.Entry
	Table *toolkit.Table
	St    storages.Storager
	// contains filtered or unexported fields
}

func NewTableRestorerInsertFormat

func NewTableRestorerInsertFormat(
	entry *toc.Entry, t *toolkit.Table, st storages.Storager, exitOnError bool,
	doNothing bool, exclusions *domains.DataRestorationErrorExclusions,
	usePgzip bool, overridingSystemValue bool,
) *TableRestorerInsertFormat

func (*TableRestorerInsertFormat) DebugInfo

func (td *TableRestorerInsertFormat) DebugInfo() string

func (*TableRestorerInsertFormat) Execute

func (td *TableRestorerInsertFormat) Execute(ctx context.Context, conn *pgx.Conn) error

func (*TableRestorerInsertFormat) GetEntry

func (td *TableRestorerInsertFormat) GetEntry() *toc.Entry