db

Documentation

Index

• type Instance
  • func New(uri, readUri string, logMode bool) (*Instance, error)
  • func (i *Instance) AddAssociationsForAddress(address string, assets []models.Asset, ctx context.Context) error
  • func (i *Instance) AddNewAssets(assets []models.Asset, 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) 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) GetAssetsMapByAddresses(addresses []string, ctx context.Context) (map[string][]models.Asset, error)
  • func (i Instance) GetAssetsMapByAddressesFromTime(addresses []string, from time.Time, ctx context.Context) (map[string][]models.Asset, 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) GetLastParsedBlockNumber(coin string, ctx context.Context) (int64, error)
  • func (i Instance) GetSubscribedAddressesForAssets(ctx context.Context, addresses []string) ([]models.Address, error)
  • func (i *Instance) GetSubscriptionsForNotifications(addresses []string, ctx context.Context) ([]models.NotificationSubscription, 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)
  • func (i *Instance) SetLastParsedBlockNumber(coin string, num int64, ctx context.Context) error
  • func (i *Instance) UpdateAssociationsForExistingAddresses(associations map[string][]models.Asset, ctx context.Context) error

Types

type Instance

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

func New

func New(uri, readUri string, logMode bool) (*Instance, error)

func (*Instance) AddAssociationsForAddress

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

func (*Instance) AddNewAssets

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

func (*Instance) AddSubscriptionsForNotifications

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

func (*Instance) DeleteSubscriptionsForNotifications

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

func (*Instance) GetAssetsByIDs

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

func (*Instance) GetAssetsFrom

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

func (Instance) GetAssetsMapByAddresses

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

func (Instance) GetAssetsMapByAddressesFromTime

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

func (*Instance) GetAssociationsByAddresses

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

func (*Instance) GetAssociationsByAddressesFromTime

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

func (*Instance) GetLastParsedBlockNumber

func (i *Instance) GetLastParsedBlockNumber(coin string, ctx context.Context) (int64, error)

func (Instance) GetSubscribedAddressesForAssets

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

func (*Instance) GetSubscriptionsForNotifications

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

func (*Instance) MemoryGet

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

func (*Instance) MemorySet

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

func (*Instance) RestoreConnectionWorker

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

func (*Instance) SetLastParsedBlockNumber

func (i *Instance) SetLastParsedBlockNumber(coin string, num int64, ctx context.Context) error

func (*Instance) UpdateAssociationsForExistingAddresses

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