blocks

Documentation

Index

• func LatestProcessedHeight(ctx context.Context, db *sql.DB) (int32, string, error)
• func MarkBlockProcessed(ctx context.Context, db *sql.DB, height int32, hash string) error
• func WipeProcessedBlocks(ctx context.Context, db *sql.DB) error
• type ProcessedBlock
  • func GetProcessedBlock(ctx context.Context, db *sql.DB, height int32) (ProcessedBlock, error)

Functions

func LatestProcessedHeight

func LatestProcessedHeight(ctx context.Context, db *sql.DB) (int32, string, error)

func MarkBlockProcessed

func MarkBlockProcessed(ctx context.Context, db *sql.DB, height int32, hash string) error

func WipeProcessedBlocks

func WipeProcessedBlocks(ctx context.Context, db *sql.DB) error

Types

type ProcessedBlock

type ProcessedBlock struct {
	Height      int32
	Hash        string
	ProcessedAt time.Time
}

func GetProcessedBlock

func GetProcessedBlock(ctx context.Context, db *sql.DB, height int32) (ProcessedBlock, error)