postgres

package

Go to main page

Versions in this module

v1

v1.0.0

Dec 3, 2025

v0

v0.1.27

Feb 8, 2026

v0.1.26

Feb 8, 2026

v0.1.25

Feb 8, 2026

v0.1.24

Feb 7, 2026

v0.1.23

Feb 6, 2026

v0.1.22

Feb 6, 2026

v0.1.21

Feb 6, 2026

v0.1.20

Feb 6, 2026

Changes in this version

+ func EnrichPluginsWithImages(plugins []itypes.Plugin, imageRecords []itypes.PluginImageRecord, ...)

+ type ListPluginImagesParams struct

+ ImageType *itypes.PluginImageType

+ IncludeDeleted bool

+ IncludeHidden bool

+ PluginID types.PluginID

type PostgresBackend

+ func (p *PostgresBackend) ConfirmPluginImage(ctx context.Context, tx pgx.Tx, pluginID types.PluginID, imageID uuid.UUID) (*itypes.PluginImageRecord, error)

+ func (p *PostgresBackend) CountVisibleMediaImages(ctx context.Context, tx pgx.Tx, pluginID types.PluginID) (int, error)

+ func (p *PostgresBackend) CreatePendingPluginImage(ctx context.Context, tx pgx.Tx, params itypes.PluginImageCreateParams) (*itypes.PluginImageRecord, error)

+ func (p *PostgresBackend) CreatePluginImage(ctx context.Context, params itypes.PluginImageCreateParams) (*itypes.PluginImageRecord, error)

+ func (p *PostgresBackend) GetNextMediaOrder(ctx context.Context, pluginID types.PluginID) (int, error)

+ func (p *PostgresBackend) GetNextMediaOrderTx(ctx context.Context, tx pgx.Tx, pluginID types.PluginID) (int, error)

+ func (p *PostgresBackend) GetPluginImageByID(ctx context.Context, pluginID types.PluginID, imageID uuid.UUID) (*itypes.PluginImageRecord, error)

+ func (p *PostgresBackend) GetPluginImageByType(ctx context.Context, pluginID types.PluginID, imageType itypes.PluginImageType) (*itypes.PluginImageRecord, error)

+ func (p *PostgresBackend) GetPluginImagesByPluginIDs(ctx context.Context, pluginIDs []types.PluginID) ([]itypes.PluginImageRecord, error)

+ func (p *PostgresBackend) ListPluginImages(ctx context.Context, params ListPluginImagesParams) ([]itypes.PluginImageRecord, error)

+ func (p *PostgresBackend) LockPluginForUpdate(ctx context.Context, tx pgx.Tx, pluginID types.PluginID) error

+ func (p *PostgresBackend) ReorderMediaImages(ctx context.Context, tx pgx.Tx, pluginID types.PluginID, imageIDs []uuid.UUID) error

+ func (p *PostgresBackend) ReplacePluginImage(ctx context.Context, pluginID types.PluginID, imageType itypes.PluginImageType, ...) (*itypes.PluginImageRecord, error)

+ func (p *PostgresBackend) SoftDeletePluginImage(ctx context.Context, pluginID types.PluginID, imageID uuid.UUID) (string, error)

+ func (p *PostgresBackend) SoftDeletePluginImageTx(ctx context.Context, tx pgx.Tx, pluginID types.PluginID, imageID uuid.UUID) (string, error)

+ func (p *PostgresBackend) UpdatePluginImage(ctx context.Context, pluginID types.PluginID, imageID uuid.UUID, visible *bool, ...) (*itypes.PluginImageRecord, error)

v0.1.19

Jan 29, 2026

v0.1.17

Jan 23, 2026

v0.1.16

Jan 20, 2026

Changes in this version

+ const PLUGIN_PAUSE_HISTORY_TABLE

+ const PLUGIN_REPORTS_TABLE

type PostgresBackend

+ func (p *PostgresBackend) AddOwner(ctx context.Context, pluginID types.PluginID, publicKey string, ...) error

+ func (p *PostgresBackend) CountInstallations(ctx context.Context, pluginID types.PluginID) (int, error)

+ func (p *PostgresBackend) CountReportsInWindow(ctx context.Context, pluginID types.PluginID, window time.Duration) (int, error)

+ func (p *PostgresBackend) DeactivateOwner(ctx context.Context, pluginID types.PluginID, publicKey string) error

+ func (p *PostgresBackend) GetControlFlags(ctx context.Context, k1, k2 string) (map[string]bool, error)

+ func (p *PostgresBackend) GetFeesByPluginID(ctx context.Context, pluginID types.PluginID, publicKey string, ...) ([]itypes.FeeWithStatus, uint32, error)

+ func (p *PostgresBackend) GetPluginBillingSummary(ctx context.Context, publicKey string) ([]itypes.PluginBillingSummaryRow, error)

+ func (p *PostgresBackend) GetPluginTitlesByIDs(ctx context.Context, ids []string) (map[string]string, error)

+ func (p *PostgresBackend) GetPluginsByOwner(ctx context.Context, publicKey string) ([]types.PluginID, error)

+ func (p *PostgresBackend) GetPricingsByPluginIDs(ctx context.Context, pluginIDs []string) (map[string][]itypes.PricingInfo, error)

+ func (p *PostgresBackend) GetReport(ctx context.Context, pluginID types.PluginID, publicKey string) (*itypes.PluginReport, error)

+ func (p *PostgresBackend) HasInstallation(ctx context.Context, pluginID types.PluginID, publicKey string) (bool, error)

+ func (p *PostgresBackend) IsOwner(ctx context.Context, pluginID types.PluginID, publicKey string) (bool, error)

+ func (p *PostgresBackend) IsPluginPaused(ctx context.Context, pluginID types.PluginID) (bool, error)

+ func (p *PostgresBackend) IsTrialActive(ctx context.Context, dbTx pgx.Tx, pubKey string) (bool, time.Duration, error)

+ func (p *PostgresBackend) PausePlugin(ctx context.Context, pluginID types.PluginID, record itypes.PauseHistoryRecord) error

+ func (p *PostgresBackend) SyncPluginsFromYAML(yamlPath string) error

+ func (p *PostgresBackend) UpsertReport(ctx context.Context, pluginID types.PluginID, publicKey, reason string, ...) error

+ type ProposedYAML struct

+ Plugins []itypes.Plugin

v0.1.1

Dec 4, 2025

v0.1.0

Dec 3, 2025

Changes in this version

+ const PLUGINS_TABLE

+ const PLUGIN_INSTALLATIONS_TABLE

+ const PLUGIN_RATING_TABLE

+ const PLUGIN_TAGS_TABLE

+ const REVIEWS_TABLE

+ const TAGS_TABLE

+ type MigrationOptions struct

+ RunSystemMigrations bool

+ RunVerifierMigrations bool

+ type PostgresBackend struct

+ func NewPostgresBackend(dsn string, opts *MigrationOptions) (*PostgresBackend, error)

+ func (p *PostgresBackend) AddPluginPolicySync(ctx context.Context, dbTx pgx.Tx, policy itypes.PluginPolicySync) error

+ func (p *PostgresBackend) ChangeRatingForPlugin(ctx context.Context, dbTx pgx.Tx, pluginId string, oldRating int, ...) error

+ func (p *PostgresBackend) Close() error

+ func (p *PostgresBackend) CreatePricing(ctx context.Context, pricingDto types.PricingCreateDto) (*types.Pricing, error)

+ func (p *PostgresBackend) CreateRatingForPlugin(ctx context.Context, dbTx pgx.Tx, pluginId string) error

+ func (p *PostgresBackend) CreateReview(ctx context.Context, dbTx pgx.Tx, reviewDto itypes.ReviewCreateDto, ...) (string, error)

+ func (p *PostgresBackend) CreateVaultToken(ctx context.Context, token types.VaultTokenCreate) (*types.VaultToken, error)

+ func (p *PostgresBackend) DeleteAllPolicies(ctx context.Context, dbTx pgx.Tx, pluginID types.PluginID, publicKey string) error

+ func (p *PostgresBackend) DeletePluginPolicySync(ctx context.Context, id uuid.UUID) error

+ func (p *PostgresBackend) DeletePluginPolicyTx(ctx context.Context, dbTx pgx.Tx, id uuid.UUID) error

+ func (p *PostgresBackend) DeletePricingById(ctx context.Context, id uuid.UUID) error

+ func (p *PostgresBackend) FindAvgRatingByPluginID(ctx context.Context, pluginID string) (types.PluginAvgRatingDto, error)

+ func (p *PostgresBackend) FindPluginById(ctx context.Context, dbTx pgx.Tx, id types.PluginID) (*itypes.Plugin, error)

+ func (p *PostgresBackend) FindPlugins(ctx context.Context, filters itypes.PluginFilters, take int, skip int, ...) (*itypes.PluginsPaginatedList, error)

+ func (p *PostgresBackend) FindPricingById(ctx context.Context, id uuid.UUID) (*types.Pricing, error)

+ func (p *PostgresBackend) FindRatingByPluginId(ctx context.Context, dbTx pgx.Tx, pluginId string) ([]types.PluginRatingDto, error)

+ func (p *PostgresBackend) FindReviewById(ctx context.Context, db pgx.Tx, id string) (*itypes.ReviewDto, error)

+ func (p *PostgresBackend) FindReviewByUserAndPlugin(ctx context.Context, dbTx pgx.Tx, pluginId string, userAddress string) (*itypes.ReviewDto, error)

+ func (p *PostgresBackend) FindReviews(ctx context.Context, pluginId string, skip int, take int, sort string) (itypes.ReviewsDto, error)

+ func (p *PostgresBackend) FindTagById(ctx context.Context, id string) (*types.Tag, error)

+ func (p *PostgresBackend) FindTagByName(ctx context.Context, name string) (*types.Tag, error)

+ func (p *PostgresBackend) FindTags(ctx context.Context) ([]types.Tag, error)

+ func (p *PostgresBackend) GetAPIKey(ctx context.Context, apiKey string) (*types.APIKey, error)

+ func (p *PostgresBackend) GetAPIKeyByPluginId(ctx context.Context, pluginId string) (*types.APIKey, error)

+ func (p *PostgresBackend) GetActiveVaultTokens(ctx context.Context, publicKey string) ([]types.VaultToken, error)

+ func (p *PostgresBackend) GetAllPluginPolicies(ctx context.Context, publicKey string, pluginID types.PluginID, take int, ...) (*itypes.PluginPolicyPaginatedList, error)

+ func (p *PostgresBackend) GetFeeById(ctx context.Context, id uint64) (*types.Fee, error)

+ func (p *PostgresBackend) GetFeesByPublicKey(ctx context.Context, publicKey string) ([]*types.Fee, error)

+ func (p *PostgresBackend) GetPluginInstallationsCount(ctx context.Context, pluginID types.PluginID) (itypes.PluginTotalCount, error)

+ func (p *PostgresBackend) GetPluginPolicies(ctx context.Context, publicKey string, pluginIds []types.PluginID, ...) ([]types.PluginPolicy, error)

+ func (p *PostgresBackend) GetPluginPolicy(ctx context.Context, id uuid.UUID) (*types.PluginPolicy, error)

+ func (p *PostgresBackend) GetPluginPolicySync(ctx context.Context, id uuid.UUID) (*itypes.PluginPolicySync, error)

+ func (p *PostgresBackend) GetPricingByPluginId(ctx context.Context, pluginId ptypes.PluginID) ([]types.Pricing, error)

+ func (p *PostgresBackend) GetUnFinishedPluginPolicySyncs(ctx context.Context) ([]itypes.PluginPolicySync, error)

+ func (p *PostgresBackend) GetUserFees(ctx context.Context, publicKey string) (*types.UserFeeStatus, error)

+ func (p *PostgresBackend) GetVaultToken(ctx context.Context, tokenID string) (*types.VaultToken, error)

+ func (p *PostgresBackend) InsertFee(ctx context.Context, dbTx pgx.Tx, fee *types.Fee) (uint64, error)

+ func (p *PostgresBackend) InsertPluginInstallation(ctx context.Context, dbTx pgx.Tx, pluginID types.PluginID, publicKey string) error

+ func (p *PostgresBackend) InsertPluginPolicyTx(ctx context.Context, dbTx pgx.Tx, policy types.PluginPolicy) (*types.PluginPolicy, error)

+ func (p *PostgresBackend) MarkFeesCollected(ctx context.Context, dbTx pgx.Tx, feeIDs []uint64, txHash string, ...) error

+ func (p *PostgresBackend) Migrate(opts *MigrationOptions) error

+ func (p *PostgresBackend) Pool() *pgxpool.Pool

+ func (p *PostgresBackend) RevokeAllVaultTokens(ctx context.Context, publicKey string) error

+ func (p *PostgresBackend) RevokeVaultToken(ctx context.Context, tokenID string) error

+ func (p *PostgresBackend) UpdateBatchStatus(ctx context.Context, dbTx pgx.Tx, txHash string, status *rpc.TxOnChainStatus) error

+ func (p *PostgresBackend) UpdatePluginPolicySync(ctx context.Context, dbTx pgx.Tx, policy itypes.PluginPolicySync) error

+ func (p *PostgresBackend) UpdatePluginPolicyTx(ctx context.Context, dbTx pgx.Tx, policy types.PluginPolicy) (*types.PluginPolicy, error)

+ func (p *PostgresBackend) UpdateRatingForPlugin(ctx context.Context, dbTx pgx.Tx, pluginId string, reviewRating int) error

+ func (p *PostgresBackend) UpdateReview(ctx context.Context, dbTx pgx.Tx, reviewId string, ...) error

+ func (p *PostgresBackend) UpdateVaultTokenLastUsed(ctx context.Context, tokenID string) error

+ func (p *PostgresBackend) WithTransaction(ctx context.Context, fn func(ctx context.Context, tx pgx.Tx) error) error

+ type SystemMigrationManager struct

+ func NewSystemMigrationManager(pool *pgxpool.Pool) *SystemMigrationManager

+ func (s *SystemMigrationManager) Migrate() error

+ type VerifierMigrationManager struct

+ func NewVerifierMigrationManager(pool *pgxpool.Pool) *VerifierMigrationManager

+ func (v *VerifierMigrationManager) Migrate() error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL