postgresql

package
v0.0.0-...-76fd6e2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 4, 2023 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FromInterfaceString2String 

func FromInterfaceString2String(bstr interface{}) string

Types

type PostgresqlRepository 

type PostgresqlRepository struct {
	// contains filtered or unexported fields
}

func NewPostgresqlRepository 

func NewPostgresqlRepository(
	ctx context.Context,
	dataSourceName string,
) (*PostgresqlRepository, error)

func (*PostgresqlRepository) Close 

func (r *PostgresqlRepository) Close() error

func (*PostgresqlRepository) CreateCollection 

func (r *PostgresqlRepository) CreateCollection(
	ctx context.Context,
	collection entities.Collection,
) (ec entities.Collection, err error)

func (*PostgresqlRepository) FindCollection 

func (r *PostgresqlRepository) FindCollection(
	ctx context.Context,
	query entities.Collection,
	offset int,
	limit int,
) ([]entities.Collection, error)

func (*PostgresqlRepository) FindEvent 

func (r *PostgresqlRepository) FindEvent(
	ctx context.Context,
	query entities.EventRead,
) (events []entities.Event, err error)

func (*PostgresqlRepository) FindExpiredOrder 

func (r *PostgresqlRepository) FindExpiredOrder(
	ctx context.Context,
) ([]entities.ExpiredOrder, error)

func (*PostgresqlRepository) FindNftsWithListings 

func (r *PostgresqlRepository) FindNftsWithListings(
	ctx context.Context,
	token common.Address,
	identifier *big.Int,
	owner common.Address,
	isHidden *bool,
	offset int32,
	limit int32,
	listingLimit int32,
) (
	[]infrastructure.NftWithListing,
	error,
)

func (*PostgresqlRepository) FindNotification 

func (r *PostgresqlRepository) FindNotification(
	ctx context.Context,
	address common.Address,
	isViewed *bool,
) (ns []entities.NotificationGet, err error)

func (*PostgresqlRepository) FindOneNft 

func (r *PostgresqlRepository) FindOneNft(
	ctx context.Context,
	token common.Address,
	identifier *big.Int,
) (entities.Nft, error)

func (*PostgresqlRepository) FindOrder 

func (r *PostgresqlRepository) FindOrder(
	ctx context.Context,
	offer infrastructure.FindOrderOffer,
	consideration infrastructure.FindOrderConsideration,
	orderHash common.Hash,
	offerer common.Address,
	IsFulfilled *bool,
	IsCancelled *bool,
	IsInvalid *bool,
) ([]entities.Order, error)

func (*PostgresqlRepository) FullTextSearch 

func (r *PostgresqlRepository) FullTextSearch(
	ctx context.Context,
	token common.Address,
	owner common.Address,
	q string,
	isHidden *bool,
	offset int32,
	limit int32,
) ([]*entities.NftRead, error)

func (*PostgresqlRepository) GetCollectionLastSyncBlock 

func (r *PostgresqlRepository) GetCollectionLastSyncBlock(
	ctx context.Context,
	token common.Address,
) (uint64, error)

func (*PostgresqlRepository) GetMarketplaceLastSyncBlock 

func (r *PostgresqlRepository) GetMarketplaceLastSyncBlock(
	ctx context.Context,
) (uint64, error)

func (*PostgresqlRepository) GetMarketplaceSettings 

func (r *PostgresqlRepository) GetMarketplaceSettings(
	ctx context.Context,
	marketplaceAddress common.Address,
) (*entities.MarketplaceSettings, error)

func (*PostgresqlRepository) GetOffer 

func (r *PostgresqlRepository) GetOffer(
	ctx context.Context,
	owner common.Address,
	from common.Address,
) (offers []entities.Event, err error)

func (*PostgresqlRepository) InsertEvent 

func (r *PostgresqlRepository) InsertEvent(
	ctx context.Context,
	event entities.Event,
) (ee entities.Event, err error)

func (*PostgresqlRepository) InsertNotification 

func (r *PostgresqlRepository) InsertNotification(
	ctx context.Context,
	notification entities.NotificationPost,
) error

func (*PostgresqlRepository) InsertOneOrder 

func (r *PostgresqlRepository) InsertOneOrder(
	ctx context.Context,
	order entities.Order,
) (o entities.Order, err error)

func (*PostgresqlRepository) UpdateCollectionLastSyncBlock 

func (r *PostgresqlRepository) UpdateCollectionLastSyncBlock(
	ctx context.Context,
	token common.Address,
	block uint64,
) error

func (*PostgresqlRepository) UpdateMarketplaceLastSyncBlock 

func (r *PostgresqlRepository) UpdateMarketplaceLastSyncBlock(
	ctx context.Context,
	block uint64,
) error

func (*PostgresqlRepository) UpdateMarketplaceSettings 

func (r *PostgresqlRepository) UpdateMarketplaceSettings(
	ctx context.Context,
	marketplace common.Address,
	beneficiary common.Address,
	royalty float64,
) (*entities.MarketplaceSettings, error)

func (*PostgresqlRepository) UpdateNft 

func (r *PostgresqlRepository) UpdateNft(
	ctx context.Context,
	token common.Address,
	identifier *big.Int,
	val infrastructure.UpdateNftNewValue,
) (entities.Nft, error)

func (*PostgresqlRepository) UpdateNotification 

func (r *PostgresqlRepository) UpdateNotification(
	ctx context.Context,
	notification entities.NotificationUpdate,
) error

func (*PostgresqlRepository) UpdateOrderStatus 

func (r *PostgresqlRepository) UpdateOrderStatus(
	ctx context.Context,
	condition infrastructure.UpdateOrderCondition,
	value infrastructure.UpdateOrderValue,
) error

func (*PostgresqlRepository) UpdateOrderStatusByOffer 

func (r *PostgresqlRepository) UpdateOrderStatusByOffer(
	ctx context.Context,
	condition infrastructure.UpdateOrderStatusByOfferCondition,
	value infrastructure.UpdateOrderValue,
) error

func (*PostgresqlRepository) UpsertNftLatest 

func (r *PostgresqlRepository) UpsertNftLatest(
	ctx context.Context,
	token common.Address,
	identifier *big.Int,
	owner common.Address,
	isBurned bool,
	blockNumber uint64,
	txIndex uint,
	token_uri string,
) (entities.Nft, error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.