snapshot

Documentation

Index

• Variables
• func UpdateContinuousAggregateDataFromHighWaterMark(ctx context.Context, conn *pgxpool.Pool, toHeight int64) error
• type Config
  • func NewDefaultConfig() Config
• type ContinuousAggregateMetaData
• type DatabaseMetadata
  • func NewDatabaseMetaData(ctx context.Context, connPool *pgxpool.Pool) (DatabaseMetadata, error)
  • func (d DatabaseMetadata) GetHistoryTableNames() []string
• type FileWorker
  • func NewFileWorker() *FileWorker
  • func (fw *FileWorker) Add(buf *bytes.Buffer, path string)
  • func (fw *FileWorker) AddLockFile(path string)
  • func (fw *FileWorker) Consume() error
  • func (fw *FileWorker) Empty() bool
• type HistoryStore
• type HypertablePartitionColumns
• type IndexInfo
• type LoadLog
• type LoadResult
• type Service
  • func NewSnapshotService(log *logging.Logger, config Config, connPool *pgxpool.Pool, ...) (*Service, error)
  • func (b *Service) CreateSnapshot(ctx context.Context, chainID string, toHeight int64) (segment.Unpublished, error)
  • func (b *Service) CreateSnapshotAsynchronously(ctx context.Context, chainID string, toHeight int64) (segment.Unpublished, error)
  • func (b *Service) Flush()
  • func (b *Service) GetUnpublishedSnapshots() ([]segment.Unpublished, error)
  • func (b *Service) LoadSnapshotData(ctx context.Context, log LoadLog, ch segment.ContiguousHistory[segment.Full], ...) (LoadResult, error)
  • func (b *Service) RollbackToSegment(ctx context.Context, log LoadLog, rollbackToSegment segment.Full) error
  • func (b *Service) SnapshotData(ctx context.Context, chainID string, toHeight int64) error
• type Span
• type TableCopySql
• type TableMetadata

Variables

var (
	ErrSnapshotExists = errors.New("snapshot exists")
	ErrNoLastSnapshot = errors.New("no last snapshot")
)

Functions

func UpdateContinuousAggregateDataFromHighWaterMark

func UpdateContinuousAggregateDataFromHighWaterMark(ctx context.Context, conn *pgxpool.Pool, toHeight int64) error

Types

type Config

type Config struct {
	WaitForCreationLockTimeout encoding.Duration `` /* 140-byte string literal not displayed */
}

func NewDefaultConfig

func NewDefaultConfig() Config

NewDefaultConfig creates an instance of the package specific configuration, given a pointer to a logger instance to be used for logging within the package.

type ContinuousAggregateMetaData

type ContinuousAggregateMetaData struct {
	ID             int
	Name           string
	BucketInterval time.Duration
}

type DatabaseMetadata

type DatabaseMetadata struct {
	TableNameToMetaData                    map[string]TableMetadata
	ContinuousAggregatesMetaData           []ContinuousAggregateMetaData
	DatabaseVersion                        int64
	CurrentStateTablesCreateConstraintsSql []string
	CurrentStateTablesDropConstraintsSql   []string
	HistoryStateTablesCreateConstraintsSql []string
	HistoryStateTablesDropConstraintsSql   []string

	AllTablesEnableAutoVacuumSql  []string
	AllTablesDisableAutoVacuumSql []string
}

func NewDatabaseMetaData

func NewDatabaseMetaData(ctx context.Context, connPool *pgxpool.Pool) (DatabaseMetadata, error)

func (DatabaseMetadata) GetHistoryTableNames

func (d DatabaseMetadata) GetHistoryTableNames() []string

type FileWorker

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

func NewFileWorker

func NewFileWorker() *FileWorker

func (*FileWorker) Add

func (fw *FileWorker) Add(buf *bytes.Buffer, path string)

func (*FileWorker) AddLockFile

func (fw *FileWorker) AddLockFile(path string)

func (*FileWorker) Consume

func (fw *FileWorker) Consume() error

func (*FileWorker) Empty

func (fw *FileWorker) Empty() bool

type HistoryStore

type HistoryStore interface {
	StagedSegment(ctx context.Context, s segment.Full) (segment.Staged, error)
}

type HypertablePartitionColumns

type HypertablePartitionColumns struct {
	HypertableName string
	ColumnName     string
}

type IndexInfo

type IndexInfo struct {
	Tablename string
	Indexname string
	Indexdef  string
}

type LoadLog

type LoadLog interface {
	Infof(s string, args ...interface{})
	Info(msg string, fields ...zap.Field)
	Error(msg string, fields ...zap.Field)
}

type LoadResult

type LoadResult struct {
	LoadedFromHeight int64
	LoadedToHeight   int64
	RowsLoaded       int64
}

type Service

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

func NewSnapshotService

func NewSnapshotService(log *logging.Logger, config Config, connPool *pgxpool.Pool,
	historyStore HistoryStore,
	snapshotsCopyToPath string,
	migrateDatabaseToVersion func(version int64) error,
	migrateSchemaDownToVersion func(version int64) error,
) (*Service, error)

func (*Service) CreateSnapshot

func (b *Service) CreateSnapshot(ctx context.Context, chainID string, toHeight int64) (segment.Unpublished, error)

func (*Service) CreateSnapshotAsynchronously

func (b *Service) CreateSnapshotAsynchronously(ctx context.Context, chainID string, toHeight int64) (segment.Unpublished, error)

func (*Service) Flush

func (b *Service) Flush()

func (*Service) GetUnpublishedSnapshots

func (b *Service) GetUnpublishedSnapshots() ([]segment.Unpublished, error)

func (*Service) LoadSnapshotData

func (b *Service) LoadSnapshotData(
	ctx context.Context,
	log LoadLog,
	ch segment.ContiguousHistory[segment.Full],
	connConfig sqlstore.ConnectionConfig,
	optimiseForAppend,
	verbose bool,
) (LoadResult, error)

func (*Service) RollbackToSegment

func (b *Service) RollbackToSegment(ctx context.Context, log LoadLog, rollbackToSegment segment.Full) error

func (*Service) SnapshotData

func (b *Service) SnapshotData(ctx context.Context, chainID string, toHeight int64) error

type Span

type Span struct {
	FromHeight int64
	ToHeight   int64
}

type TableCopySql

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

type TableMetadata

type TableMetadata struct {
	Name            string
	SortOrder       string
	Hypertable      bool
	PartitionColumn string
}