repo

Documentation

Index

• Variables
• type BlobHashRepository
  • func NewBlobHashRepository(db DB) (*BlobHashRepository, error)
  • func (r *BlobHashRepository) DeleteAllAfterBlockID(blockID uint64) error
  • func (r *BlobHashRepository) FindLatestBlockID() (uint64, error)
  • func (r *BlobHashRepository) FirstByBlobHash(blobHash string) (*blobstorage.BlobHash, error)
  • func (r *BlobHashRepository) Save(opts blobstorage.SaveBlobHashOpts) error
• type DB

Variables

var (
	ErrNoDB = errors.Validation.NewWithKeyAndDetail("ERR_NO_DB", "no db")
)

Types

type BlobHashRepository

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

func NewBlobHashRepository

func NewBlobHashRepository(db DB) (*BlobHashRepository, error)

func (*BlobHashRepository) DeleteAllAfterBlockID

func (r *BlobHashRepository) DeleteAllAfterBlockID(blockID uint64) error

DeleteAllAfterBlockID is used when a reorg is detected

func (*BlobHashRepository) FindLatestBlockID

func (r *BlobHashRepository) FindLatestBlockID() (uint64, error)

func (*BlobHashRepository) FirstByBlobHash

func (r *BlobHashRepository) FirstByBlobHash(blobHash string) (*blobstorage.BlobHash, error)

func (*BlobHashRepository) Save

func (r *BlobHashRepository) Save(opts blobstorage.SaveBlobHashOpts) error

type DB

type DB interface {
	DB() (*sql.DB, error)
	GormDB() *gorm.DB
}