restorers

Documentation

Index

• 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, opt *pgrestore.DataSectionSettings) *TableRestorer
  • func (rb 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, ...) *TableRestorerInsertFormat
  • func (rb TableRestorerInsertFormat) DebugInfo() string
  • func (td *TableRestorerInsertFormat) Execute(ctx context.Context, conn *pgx.Conn) error
  • func (td *TableRestorerInsertFormat) GetEntry() *toc.Entry

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 {
	// contains filtered or unexported fields
}

func NewTableRestorer

func NewTableRestorer(
	entry *toc.Entry, st storages.Storager, opt *pgrestore.DataSectionSettings,
) *TableRestorer

func (TableRestorer) DebugInfo

func (rb 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 {
	Table *toolkit.Table
	// contains filtered or unexported fields
}

func NewTableRestorerInsertFormat

func NewTableRestorerInsertFormat(
	entry *toc.Entry, t *toolkit.Table, st storages.Storager, opt *pgrestore.DataSectionSettings,
	exclusions *domains.DataRestorationErrorExclusions,
) *TableRestorerInsertFormat

func (TableRestorerInsertFormat) DebugInfo

func (rb 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