offchain

package

v0.61.0 Latest Latest Go to latest Published: Jun 30, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

func EnsurePointers(
	ctx context.Context,
	db *gorm.DB,
	now time.Time,
) (int, error)

EnsurePointers adds pending off-chain metadata cache rows for every currently known on-chain URL/hash pointer.

func FetchBatch(
	ctx context.Context,
	db *gorm.DB,
	limit int,
	now time.Time,
) ([]models.OffchainMetadata, error)

FetchBatch claims and returns pending or failed cache rows that are due for another fetch attempt.

func Get(
	db *gorm.DB,
	sourceType string,
	url string,
	hash []byte,
) (*models.OffchainMetadata, error)

Get retrieves one cached off-chain metadata document by source and on-chain URL/hash pointer. It returns nil when no cache row exists yet.

func SetFetchResult(
	ctx context.Context,
	db *gorm.DB,
	doc *models.OffchainMetadata,
) error

SetFetchResult persists the worker's latest fetch status for an existing off-chain metadata cache row.

This section is empty.