Versions in this module Expand all Collapse all v1 v1.0.0 Oct 23, 2023 Changes in this version + type ApprovalQ struct + func (q *ApprovalQ) ApprovalsByTransferIndexCtx(ctx context.Context, transferIndex []byte, isForUpdate bool) ([]data.Approval, error) + func (q *ApprovalQ) InsertBatchCtx(ctx context.Context, approvals ...data.Approval) error + type CollectionChainMappingQ struct + func (q *CollectionChainMappingQ) CollectionChainMappingByCollectionNetworkCtx(ctx context.Context, collection int64, network int, isForUpdate bool) (*data.CollectionChainMapping, error) + func (q *CollectionChainMappingQ) DeleteByCollectionCtx(ctx context.Context, collection int64) error + func (q *CollectionChainMappingQ) DeleteCtx(ctx context.Context, ccm *data.CollectionChainMapping) error + func (q *CollectionChainMappingQ) InsertBatchCtx(ctx context.Context, chainMappings ...data.CollectionChainMapping) error + func (q *CollectionChainMappingQ) InsertCtx(ctx context.Context, ccm *data.CollectionChainMapping) error + func (q *CollectionChainMappingQ) UpsertCtx(ctx context.Context, ccm *data.CollectionChainMapping) error + type CollectionQ struct + func (q *CollectionQ) CollectionByIndexCtx(ctx context.Context, index []byte, isForUpdate bool) (*data.Collection, error) + func (q *CollectionQ) DeleteCtx(ctx context.Context, c *data.Collection) error + func (q *CollectionQ) InsertCtx(ctx context.Context, c *data.Collection) error + type ConfirmationsQ struct + func (q *ConfirmationsQ) ConfirmationsByTransferIndexCtx(ctx context.Context, transferIndex []byte, isForUpdate bool) ([]data.Confirmation, error) + func (q *ConfirmationsQ) InsertBatchCtx(ctx context.Context, confirmations ...data.Confirmation) error + type ItemChainMappingQ struct + func (q *ItemChainMappingQ) DeleteByItemCtx(ctx context.Context, item int64) error + func (q *ItemChainMappingQ) DeleteCtx(ctx context.Context, icm *data.ItemChainMapping) error + func (q *ItemChainMappingQ) InsertBatchCtx(ctx context.Context, chainMappings ...data.ItemChainMapping) error + func (q *ItemChainMappingQ) InsertCtx(ctx context.Context, icm *data.ItemChainMapping) error + func (q *ItemChainMappingQ) ItemChainMappingByItemNetworkCtx(ctx context.Context, item int64, network int, isForUpdate bool) (*data.ItemChainMapping, error) + func (q *ItemChainMappingQ) ItemChainMappingsByNetworkCtx(ctx context.Context, network int, isForUpdate bool) ([]data.ItemChainMapping, error) + type ItemQ struct + func (q *ItemQ) DeleteCtx(ctx context.Context, i *data.Item) error + func (q *ItemQ) InsertCtx(ctx context.Context, i *data.Item) error + func (q *ItemQ) ItemByIDCtx(ctx context.Context, id int64, isForUpdate bool) (*data.Item, error) + func (q *ItemQ) ItemByIndexCtx(ctx context.Context, index []byte, isForUpdate bool) (*data.Item, error) + func (q *ItemQ) UpdateCtx(ctx context.Context, i *data.Item) error + type RejectionQ struct + func (q *RejectionQ) InsertBatchCtx(ctx context.Context, rejections ...data.Rejection) error + func (q *RejectionQ) RejectionsByTransferIndexCtx(ctx context.Context, transferIndex []byte, isForUpdate bool) ([]data.Rejection, error) + type Storage struct + func NewStorage(log *logan.Entry, raw data.Storage, redisClient *redis.Client) *Storage + func (s *Storage) ApprovalQ() data.ApprovalQ + func (s *Storage) CollectionChainMappingQ() data.CollectionChainMappingQ + func (s *Storage) CollectionQ() data.CollectionQ + func (s *Storage) ConfirmationQ() data.ConfirmationQ + func (s *Storage) ItemChainMappingQ() data.ItemChainMappingQ + func (s *Storage) ItemQ() data.ItemQ + func (s *Storage) RejectionQ() data.RejectionQ + func (s *Storage) Transaction(f func() error) error + func (s *Storage) TransactionQ() data.TransactionQ + func (s *Storage) TransferQ() data.TransferQ + func (s *Storage) VoteQ() data.VoteQ + type TransfersQ struct + func (q *TransfersQ) SelectCtx(ctx context.Context, selector data.TransferSelector) ([]data.Transfer, error) + func (q *TransfersQ) SetStatusByIndexCtx(ctx context.Context, status int, indexes ...string) error + func (q *TransfersQ) TransferByIndexCtx(ctx context.Context, index []byte, isForUpdate bool) (*data.Transfer, error) + func (q *TransfersQ) UpsertBatchCtx(ctx context.Context, transfers ...data.Transfer) error + type VoteQ struct + func (q *VoteQ) InsertBatchCtx(ctx context.Context, votes ...data.Vote) error + func (q *VoteQ) VotesByTransferIndexCtx(ctx context.Context, transferIndex []byte, isForUpdate bool) ([]data.Vote, error)
Go to main page