migrations

type Accounts interface {
	GetBlockSpends() []*accounts.Spend
}

type BlockSpends struct {
	Spends []*accounts.Spend
}

type ChangesetMetadata struct {
	Height     int64   `json:"height"`
	Chunks     int64   `json:"chunks"`
	ChunkSizes []int64 `json:"chunk_sizes"`
}

type Database interface {
	sql.TxMaker
	sql.ReadTxMaker
	sql.SnapshotTxMaker
}

type MigrationConfig struct {
	// StartHeight is the block height at which the migration started on the old chain.
	StartHeight uint64

	// End height is the block height at which the migration ended on the old chain.
	EndHeight uint64

	// ListenAddress is the address of the kwild server to receive changesets from.
	ListenAddress string
}

type MigrationDeclaration struct {
	// ActivationPeriod is the amount of blocks before the migration is activated.
	// It starts after the migration is approved via the voting system.
	// The intention is to allow validators to prepare for the migration.
	ActivationPeriod uint64
	// Duration is the amount of blocks the migration will take to complete.
	Duration uint64
	// Timestamp is the time the migration was created. It is set by the migration
	// creator. The primary purpose of it is to guarantee uniqueness of the serialized
	// MigrationDeclaration, since that is a requirement for the voting system.
	Timestamp string
}

type Migrator struct {
	DB Database

	Logger log.Logger
	// contains filtered or unexported fields
}

type NamespaceManager interface {
	ListPostgresSchemasToDump() ([]string, error)
}

type Snapshotter interface {
	CreateSnapshot(ctx context.Context, height uint64, snapshotID string, schemas, excludedTables []string, excludedTableData []string) error
	LoadSnapshotChunk(height uint64, format uint32, chunkIdx uint32) ([]byte, error)
	ListSnapshots() []*snapshotter.Snapshot
}

type Validators interface {
	GetValidators() []*types.Validator
}