restorers

Documentation

Index

• Constants
• type BlobsRestorer
  • func NewBlobsRestorer(entry *toc.Entry, st storages.Storager) *BlobsRestorer
  • func (td *BlobsRestorer) DebugInfo() string
  • func (td *BlobsRestorer) Execute(ctx context.Context, tx pgx.Tx) error
• type RestoreTask
• type SequenceRestorer
  • func NewSequenceRestorer(entry *toc.Entry) *SequenceRestorer
  • func (td *SequenceRestorer) DebugInfo() string
  • func (td *SequenceRestorer) Execute(ctx context.Context, tx pgx.Tx) error
• type TableRestorer
  • func NewTableRestorer(entry *toc.Entry, st storages.Storager) *TableRestorer
  • func (td *TableRestorer) DebugInfo() string
  • func (td *TableRestorer) Execute(ctx context.Context, tx pgx.Tx) error

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) *BlobsRestorer

func (*BlobsRestorer) DebugInfo

func (td *BlobsRestorer) DebugInfo() string

func (*BlobsRestorer) Execute

func (td *BlobsRestorer) Execute(ctx context.Context, tx pgx.Tx) error

type RestoreTask

type RestoreTask interface {
	Execute(ctx context.Context, tx pgx.Tx) error
	DebugInfo() string
}

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, tx pgx.Tx) error

type TableRestorer

type TableRestorer struct {
	Entry *toc.Entry
	St    storages.Storager
}

func NewTableRestorer

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

func (*TableRestorer) DebugInfo

func (td *TableRestorer) DebugInfo() string

func (*TableRestorer) Execute

func (td *TableRestorer) Execute(ctx context.Context, tx pgx.Tx) error