subscription

Documentation

Index

• type Store
  • func NewWithDB(db DbOrTx) Store

Types

type Store

type Store interface {
	BatchInsert(ctx context.Context, subs []*model.Subscription) ([]common.Address, error)
	BatchUpdateBlockNumber(ctx context.Context, blockNumber int64, addrs [][]byte) error
	// FindOldSubscriptions find old subscriptions �by addresses
	FindOldSubscriptions(ctx context.Context, addrs [][]byte) (result []*model.Subscription, err error)
	Find(ctx context.Context, blockNumber int64, query *model.QueryParameters) (result []*model.Subscription, total uint64, err error)
	FindByGroup(ctx context.Context, groupID int64, query *model.QueryParameters) (result []*model.Subscription, total uint64, err error)
	ListOldSubscriptions(ctx context.Context, query *model.QueryParameters) (result []*model.Subscription, total uint64, err error)

	// Total balance
	InsertTotalBalance(ctx context.Context, data *model.TotalBalance) error
	FindTotalBalance(ctx context.Context, blockNumber int64, token common.Address, group int64) (result *model.TotalBalance, err error)

	Reset(ctx context.Context, from, to int64) error
}

func NewWithDB

func NewWithDB(db DbOrTx) Store