db

Documentation

Index

• func RestoreConnectionWorker(database *Instance, timeout time.Duration, uri string)
• type Instance
  • 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

Functions

func RestoreConnectionWorker

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

Types

type Instance

type Instance struct {
	Gorm *gorm.DB
}

func New

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

func (*Instance) AddSubscriptions

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

func (*Instance) AddToExistingSubscription

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

func (*Instance) BulkCreate

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

func (*Instance) DeleteAllSubscriptions

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

func (*Instance) DeleteSubscriptions

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

func (*Instance) GetLastParsedBlockNumber

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

func (*Instance) GetSubscriptionData

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

func (*Instance) SetLastParsedBlockNumber

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