db

Documentation

Index

• func Setup(db *gorm.DB) error
• type Instance
  • func New(url string, log bool) (*Instance, error)
  • func (i *Instance) AddNewAssets(assets []models.Asset) error
  • func (i *Instance) CreateSubscriptions(addresses []blockatlas.Subscription) error
  • func (i *Instance) CreateSubscriptionsAssets(associations []models.SubscriptionsAssetAssociation) error
  • func (i *Instance) DeleteSubscriptions(addresses []string) error
  • func (i *Instance) GetAsset(assetId string) (models.Asset, error)
  • func (i *Instance) GetAssetsByIDs(ids []string) ([]models.Asset, error)
  • func (i *Instance) GetAssetsFrom(from time.Time) ([]models.Asset, error)
  • func (i *Instance) GetLastParsedBlockNumber(coin string) (int64, error)
  • func (i *Instance) GetSubscriptions(addresses []string) ([]models.Subscription, error)
  • func (i *Instance) GetSubscriptionsByAddressIDs(ids []string, from time.Time) ([]models.SubscriptionsAssetAssociation, error)
  • func (i *Instance) MemoryGet(key string) ([]byte, error)
  • func (i *Instance) MemorySet(key string, data []byte, exp time.Duration) error
  • func (i *Instance) RestoreConnectionWorker(timeout time.Duration, uri string)
  • func (i *Instance) SetLastParsedBlockNumber(coin string, num int64) error

Functions

func Setup

func Setup(db *gorm.DB) error

Types

type Instance

type Instance struct {
	Gorm        *gorm.DB
	MemoryCache *gocache.Cache
}

func New

func New(url string, log bool) (*Instance, error)

func (*Instance) AddNewAssets

func (i *Instance) AddNewAssets(assets []models.Asset) error

func (*Instance) CreateSubscriptions

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

func (*Instance) CreateSubscriptionsAssets

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

func (*Instance) DeleteSubscriptions

func (i *Instance) DeleteSubscriptions(addresses []string) error

func (*Instance) GetAsset

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

func (*Instance) GetAssetsByIDs

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

func (*Instance) GetAssetsFrom

func (i *Instance) GetAssetsFrom(from time.Time) ([]models.Asset, error)

func (*Instance) GetLastParsedBlockNumber

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

func (*Instance) GetSubscriptions

func (i *Instance) GetSubscriptions(addresses []string) ([]models.Subscription, error)

func (*Instance) GetSubscriptionsByAddressIDs

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

func (*Instance) MemoryGet

func (i *Instance) MemoryGet(key string) ([]byte, error)

func (*Instance) MemorySet

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

func (*Instance) RestoreConnectionWorker

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

func (*Instance) SetLastParsedBlockNumber

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