db

Documentation

Index

• func RestoreConnectionWorker(database *Instance, timeout time.Duration, uri string)
• type Instance
  • func New(uri, env string) (*Instance, error)
  • func (i *Instance) AddSubscriptions(subscriptions []models.Subscription, ctx context.Context) error
  • func (i *Instance) DeleteSubscriptions(subscriptions []models.Subscription, ctx context.Context) error
  • func (i *Instance) GetLastParsedBlockNumber(coin string, ctx context.Context) (int64, error)
  • func (i *Instance) GetSubscriptions(coin uint, addresses []string, ctx context.Context) ([]models.Subscription, error)
  • func (i *Instance) SetLastParsedBlockNumber(coin string, num int64, ctx context.Context) 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, env string) (*Instance, error)

func (*Instance) AddSubscriptions

func (i *Instance) AddSubscriptions(subscriptions []models.Subscription, ctx context.Context) error

func (*Instance) DeleteSubscriptions

func (i *Instance) DeleteSubscriptions(subscriptions []models.Subscription, ctx context.Context) error

func (*Instance) GetLastParsedBlockNumber

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

func (*Instance) GetSubscriptions

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

func (*Instance) SetLastParsedBlockNumber

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