Versions in this module Expand all Collapse all v0 v0.1.3 Nov 23, 2023 v0.1.2 Apr 17, 2023 Changes in this version + const STATUS_DONE + const STATUS_FAILED + const STATUS_PENDING + const STATUS_PROCESSED + const STATUS_PROCESSING + func MustConnectDatabase(dbConfig *Database, testing bool) (*gorm.DB, error) + func MustConnectDatabaseWithName(dbConfig *Database, dbName string, testing bool) (*gorm.DB, error) + func NewEventStore(db *gorm.DB) *eventStore + func NewJobStore(db *gorm.DB) *jobStore + func NewProcessedBlockStore(db *gorm.DB) *processedBlockStore + type Database struct + ConnMaxLifetime int + DBName string + Host string + MaxIdleConns int + MaxOpenConns int + Password string + Port int + User string + type EventStore interface + Count func() int64 + DeleteEvents func(uint64) error + Save func(event *models.Event) error + type JobStore interface + Count func() int64 + DeleteJobs func([]string, uint64) error + GetPendingJobs func() ([]*models.Job, error) + Save func(job *models.Job) error + SearchJobs func(req *SearchJobs) ([]*models.Job, error) + Update func(job *models.Job) error + type MainStore interface + GetDB func() *gorm.DB + GetEventStore func() EventStore + GetJobStore func() JobStore + GetProcessedBlockStore func() ProcessedBlockStore + func NewMainStore(db *gorm.DB) MainStore + type ProcessedBlockStore interface + GetLatestBlock func(chainId string) (int64, error) + Save func(chainId string, height int64) error + type SearchJobs struct + Limit int + Listeners []string + MaxCreatedAt int64 + Status string v0.1.1 Oct 17, 2022 v0.0.1 Aug 3, 2022