db

Documentation

Index

• func BulkInsert(db *gorm.DB, dbModels interface{}) error
• func RestoreConnectionWorker(database *Instance, timeout time.Duration, uri string)
• type Instance
  • func New(uri, readURI, env string, mode bool) (*Instance, error)
  • 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) 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) 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) SetLastParsedBlockNumber(coin string, num int64, ctx context.Context) error
  • func (i *Instance) UpdateAssociationsForExistingAddresses(associations map[string][]string, ctx context.Context) error

Functions

func BulkInsert

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

Example: postgres.BulkInsert(DBWrite, []models.User{...})

func RestoreConnectionWorker

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

Types

type Instance

type Instance struct {
	Gorm     *gorm.DB
	GormRead *gorm.DB
}

func New

func New(uri, readURI, env string, mode bool) (*Instance, error)

func (*Instance) AddAssociationsForAddress

func (i *Instance) AddAssociationsForAddress(address string, assets []string, 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) GetAssetsMapByAddresses

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

func (Instance) GetAssetsMapByAddressesFromTime

func (i Instance) GetAssetsMapByAddressesFromTime(addresses []string, from time.Time, ctx context.Context) (map[string][]string, 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) SetLastParsedBlockNumber

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

func (*Instance) UpdateAssociationsForExistingAddresses

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