snapshots

Documentation

Index

• Constants
• func SaveNewSnapshots(ctx context.Context, unit UnitOfWork, provider SnapshotProvider) (count int, err error)
• func SaveSnapshotForCycle(ctx context.Context, cycle int64, unit UnitOfWork, provider SnapshotProvider, ...) error
• type BlocksRepo
• type RightsRepo
• type SnapshotProvider
• type UnitOfWork

Constants

const CyclesInAdvance = 6

const FirstCycleWithSnapshots = 7

Functions

func SaveNewSnapshots

func SaveNewSnapshots(ctx context.Context, unit UnitOfWork, provider SnapshotProvider) (count int, err error)

func SaveSnapshotForCycle

func SaveSnapshotForCycle(ctx context.Context, cycle int64, unit UnitOfWork, provider SnapshotProvider, isFromFuture bool) error

Types

type BlocksRepo

type BlocksRepo interface {
	Last() (block models.Block, err error)
}

type RightsRepo

type RightsRepo interface {
	List(limit, offset uint) (count int64, snaps []models.Snapshot, err error)
	Create(right models.Snapshot) error
}

type SnapshotProvider

type SnapshotProvider interface {
	SnapshotForCycle(ctx context.Context, cycle int64, useHead bool) (snap models.Snapshot, err error)
	RollsForBlock(ctx context.Context, blockLevel int64) (roll []models.Roll, err error)
}

type UnitOfWork

type UnitOfWork interface {
	Start(ctx context.Context)
	RollbackUnlessCommitted()
	Commit() error
	GetBlock() block.Repo
	GetSnapshots() snapshots.Repo
	GetRolls() rolls.Repo
}