db

Jan 14, 2021

Changes in this version

+ func Setup(db *gorm.DB) error

type Instance

+ func (i *Instance) CreateSubscriptions(addresses []blockatlas.Subscription) error

+ func (i *Instance) CreateSubscriptionsAssets(associations []models.SubscriptionsAssetAssociation) error

+ func (i *Instance) GetAsset(assetId string) (models.Asset, error)

+ func (i *Instance) GetSubscriptionsByAddressIDs(ids []string, from time.Time) ([]models.SubscriptionsAssetAssociation, error)

Nov 24, 2020

Changes in this version

type Instance

+ MemoryCache *gocache.Cache

+ func (i *Instance) AddNewAssets(assets []models.Asset, ctx context.Context) error

+ func (i *Instance) GetAssetsByIDs(ids []string, ctx context.Context) ([]models.Asset, error)

+ func (i *Instance) GetAssetsFrom(from time.Time, coin int, ctx context.Context) ([]models.Asset, error)

+ func (i *Instance) MemoryGet(key string, ctx context.Context) ([]byte, error)

+ func (i *Instance) MemorySet(key string, data []byte, exp time.Duration, ctx context.Context) error

+ func (i *Instance) RestoreConnectionWorker(ctx context.Context, timeout time.Duration, uri string)

Sep 3, 2020

Changes in this version

+ func BulkInsert(db *gorm.DB, dbModels interface{}) error

type Instance

+ GormRead *gorm.DB

+ func (i *Instance) AddAssociationsForAddress(address string, assets []string, ctx context.Context) error

+ func (i *Instance) AddSubscriptionsForNotifications(addresses []string, ctx context.Context) error

+ func (i *Instance) DeleteSubscriptionsForNotifications(addresses []string, ctx context.Context) error

+ func (i *Instance) GetAssociationsByAddresses(addresses []string, ctx context.Context) ([]models.AddressToAssetAssociation, error)

+ func (i *Instance) GetAssociationsByAddressesFromTime(addresses []string, from time.Time, ctx context.Context) ([]models.AddressToAssetAssociation, error)

+ func (i *Instance) GetSubscriptionsForNotifications(addresses []string, ctx context.Context) ([]models.NotificationSubscription, error)

+ func (i *Instance) UpdateAssociationsForExistingAddresses(associations map[string][]string, ctx context.Context) error

+ func (i Instance) GetAssetsMapByAddresses(addresses []string, ctx context.Context) (map[string][]string, error)

+ func (i Instance) GetAssetsMapByAddressesFromTime(addresses []string, from time.Time, ctx context.Context) (map[string][]string, error)

+ func (i Instance) GetSubscribedAddressesForAssets(ctx context.Context, addresses []string) ([]models.Address, error)

Jul 10, 2020

Changes in this version

type Instance

+ func (i *Instance) GetSubscriptions(coin uint, addresses []string, ctx context.Context) ([]models.Subscription, error)

May 16, 2020

Changes in this version

+ func RestoreConnectionWorker(database *Instance, timeout time.Duration, uri string)

+ type Instance struct

+ Gorm *gorm.DB

+ func New(uri string) (*Instance, error)

+ func (i *Instance) AddSubscriptions(id uint, subscriptions []models.SubscriptionData) error

+ func (i *Instance) AddToExistingSubscription(id uint, subscriptions []models.SubscriptionData) error

+ func (i *Instance) BulkCreate(dataList []models.SubscriptionData) error

+ func (i *Instance) DeleteAllSubscriptions(id uint) error

+ func (i *Instance) DeleteSubscriptions(subscriptions []models.SubscriptionData) error

+ func (i *Instance) GetLastParsedBlockNumber(coin string) (int64, error)

+ func (i *Instance) GetSubscriptionData(coin uint, addresses []string) ([]models.SubscriptionData, error)

+ func (i *Instance) SetLastParsedBlockNumber(coin string, num int64) error