tapdb

package

Go to main page

Versions in this module

v0

v0.5.0

Dec 19, 2024

Changes in this version

type ActiveAssetsStore

+ FetchAssetProofsSizes func(ctx context.Context) ([]AssetProofSize, error)

+ InsertBurn func(ctx context.Context, arg sqlc.InsertBurnParams) (int64, error)

+ QueryBurns func(ctx context.Context, arg sqlc.QueryBurnsParams) ([]sqlc.QueryBurnsRow, error)

+ SetTransferOutputProofDeliveryStatus func(ctx context.Context, arg OutputProofDeliveryStatus) error

type AddrBook

+ FetchAssetMetaByHash func(ctx context.Context, metaDataHash []byte) (sqlc.FetchAssetMetaByHashRow, error)

+ FetchAssetMetaForAsset func(ctx context.Context, assetID []byte) (AssetMeta, error)

+ type AssetMeta = sqlc.FetchAssetMetaForAssetRow

+ type AssetProofSize = sqlc.FetchAssetProofsSizesRow

type AssetStore

+ func (a *AssetStore) AssetsDBSize(ctx context.Context) (int64, error)

+ func (a *AssetStore) ConfirmProofDelivery(ctx context.Context, anchorOutpoint wire.OutPoint, outputPosition uint64) error

+ func (a *AssetStore) FetchAssetProofsSizes(ctx context.Context) ([]AssetProofSize, error)

+ func (a *AssetStore) LogAnchorTxConfirm(ctx context.Context, conf *tapfreighter.AssetConfirmEvent, ...) error

+ func (a *AssetStore) QueryBurns(ctx context.Context, filters QueryBurnsFilters) ([]*tapfreighter.AssetBurn, error)

+ type BatchedMetaStore interface

+ type MetaStore interface

+ AssetsDBSizePostgres func(ctx context.Context) (int64, error)

+ AssetsDBSizeSqlite func(ctx context.Context) (int32, error)

+ type MultiverseCacheConfig struct

+ LeavesNumCachedUniverses uint64

+ LeavesPerUniverse uint64

+ ProofsPerUniverse uint64

+ RootNodePageCacheSize uint64

+ SyncerCacheEnabled bool

+ SyncerCachePreAllocSize uint64

+ func DefaultMultiverseCacheConfig() MultiverseCacheConfig

+ type MultiverseStoreConfig struct

+ Caches MultiverseCacheConfig

+ func DefaultMultiverseStoreConfig() *MultiverseStoreConfig

+ type OutputProofDeliveryStatus = sqlc.SetTransferOutputProofDeliveryStatusParams

+ type QueryAssetBalancesByAssetFilters = sqlc.QueryAssetBalancesByAssetParams

+ type QueryAssetBalancesByGroupFilters = sqlc.QueryAssetBalancesByGroupParams

+ type QueryBurnsFilters = sqlc.QueryBurnsParams

type TapAddressBook

+ func (t *TapAddressBook) FetchAssetMetaByHash(ctx context.Context, metaHash [asset.MetaHashLen]byte) (*proof.MetaReveal, error)

+ func (t *TapAddressBook) FetchAssetMetaForAsset(ctx context.Context, assetID asset.ID) (*proof.MetaReveal, error)

v0.5.0-rc2

Dec 11, 2024

v0.5.0-rc1

Nov 27, 2024

v0.4.1

Jul 25, 2024

v0.4.0

Jul 23, 2024

Changes in this version

+ const LatestMigrationVersion

+ var ErrBatchParsing = errors.New("unable to parse batch")

+ var ErrBindBatchTx = errors.New("unable to bind batch tx")

+ var ErrEncodeGenesisPoint = errors.New("unable to encode genesis point")

+ var ErrEncodePsbt = errors.New("unable to encode psbt")

+ var ErrFetchGenesisID = errors.New("unable to fetch genesis asset")

+ var ErrFetchMintingBatches = errors.New("unable to fetch minting batches")

+ var ErrGroupGenesisInfo = errors.New("unable to fetch group genesis info")

+ var ErrMigrationDowngrade = errors.New("database downgrade detected")

+ var ErrNoAssetGroup = errors.New("no matching asset group")

+ var ErrNoMultiverseRoot = errors.New("no multiverse root found")

+ var ErrReadOutpoint = errors.New("unable to read outpoint")

+ var ErrTapscriptRootSize = errors.New("tapscript root invalid: wrong size")

+ var ErrUpsertGenesisPoint = errors.New("unable to upsert genesis point")

+ var ErrUpsertGroupKey = errors.New("unable to upsert group key")

+ var ErrUpsertInternalKey = errors.New("unable to upsert internal key")

+ var ErrUpsertScriptKey = errors.New("unable to upsert script key")

+ var TargetLatest = func(mig *migrate.Migrate, _ int, _ uint) error

+ var TargetVersion = func(version uint) MigrationTarget

+ func InsertTestdata(t *testing.T, db *BaseDB, fileName string)

+ func IsDeadlockError(err error) bool

+ func IsSchemaError(err error) bool

+ func IsSerializationOrDeadlockError(err error) bool

type ActiveAssetsStore

+ FetchAssetID func(ctx context.Context, arg FetchAssetID) ([]int64, error)

type AddrBook

+ FetchAddrEventByAddrKeyAndOutpoint func(ctx context.Context, arg FetchAddrEventByOutpoint) (AddrEventByOutpoint, error)

+ FetchInternalKeyLocator func(ctx context.Context, rawKey []byte) (KeyLocator, error)

+ type AddrEventByOutpoint = sqlc.FetchAddrEventByAddrKeyAndOutpointRow

type AssetMintingStore

+ func (a *AssetMintingStore) AddSeedlingGroups(ctx context.Context, genesisOutpoint wire.OutPoint, ...) error

+ func (a *AssetMintingStore) CommitBatchTapSibling(ctx context.Context, batchKey *btcec.PublicKey, batchSibling *chainhash.Hash) error

+ func (a *AssetMintingStore) CommitBatchTx(ctx context.Context, batchKey *btcec.PublicKey, ...) error

+ func (a *AssetMintingStore) DeleteTapscriptTree(ctx context.Context, rootHash chainhash.Hash) error

+ func (a *AssetMintingStore) FetchAssetMeta(ctx context.Context, ID asset.ID) (*proof.MetaReveal, error)

+ func (a *AssetMintingStore) FetchScriptKeyByTweakedKey(ctx context.Context, tweakedKey *btcec.PublicKey) (*asset.TweakedScriptKey, error)

+ func (a *AssetMintingStore) FetchSeedlingGroups(ctx context.Context, genPoint wire.OutPoint, anchorOutputIndex uint32, ...) ([]*asset.AssetGroup, error)

+ func (a *AssetMintingStore) LoadTapscriptTree(ctx context.Context, rootHash chainhash.Hash) (*asset.TapscriptTreeNodes, error)

+ func (a *AssetMintingStore) StoreTapscriptTree(ctx context.Context, treeNodes asset.TapscriptTreeNodes) (*chainhash.Hash, error)

type AssetStore

+ func (a *AssetStore) FetchIssuanceProof(ctx context.Context, id asset.ID, anchorOutpoint wire.OutPoint) (proof.Blob, error)

+ func (a *AssetStore) TxHeight(ctx context.Context, txid chainhash.Hash) (uint32, error)

type BaseMultiverseStore

+ FetchMultiverseRoot func(ctx context.Context, proofNamespace string) (MultiverseRoot, error)

+ QueryMultiverseLeaves func(ctx context.Context, arg QueryMultiverseLeaves) ([]MultiverseLeaf, error)

type BaseUniverseStore

+ DeleteMultiverseLeaf func(ctx context.Context, arg DeleteMultiverseLeaf) error

+ UpsertMultiverseLeaf func(ctx context.Context, arg UpsertMultiverseLeaf) (int64, error)

+ UpsertMultiverseRoot func(ctx context.Context, arg UpsertMultiverseRoot) (int64, error)

+ type BatchTapSiblingUpdate = sqlc.BindMintingBatchWithTapSiblingParams

+ type DeleteMultiverseLeaf = sqlc.DeleteMultiverseLeafParams

+ type ErrDeadlockError struct

+ DbError error

+ func (e ErrDeadlockError) Error() string

+ func (e ErrDeadlockError) Unwrap() error

+ type ErrSchemaError struct

+ DbError error

+ func (e ErrSchemaError) Error() string

+ func (e ErrSchemaError) Unwrap() error

+ type FetchAddrEventByOutpoint = sqlc.FetchAddrEventByAddrKeyAndOutpointParams

+ type FetchAssetID = sqlc.FetchAssetIDParams

+ type FetchScriptKeyStore interface

+ FetchScriptKeyByTweakedKey func(ctx context.Context, tweakedScriptKey []byte) (ScriptKey, error)

+ type KeyLocator = sqlc.FetchInternalKeyLocatorRow

type ManagedUTXO

+ LeaseExpiry time.Time

+ LeaseOwner []byte

+ type MigrateOpt func(*migrateOptions)

+ func WithLatestVersion(version uint) MigrateOpt

+ type MigrationTarget func(mig *migrate.Migrate, currentDbVersion int, maxMigrationVersion uint) error

+ type MultiverseLeaf = sqlc.QueryMultiverseLeavesRow

+ type MultiverseRoot = sqlc.FetchMultiverseRootRow

type MultiverseStore

+ func (b *MultiverseStore) FetchLeaves(ctx context.Context, universeTargets []universe.MultiverseLeafDesc, ...) ([]universe.MultiverseLeaf, error)

+ func (b *MultiverseStore) MultiverseRootNode(ctx context.Context, proofType universe.ProofType) (fn.Option[universe.MultiverseRoot], error)

+ type OptionalSeedlingFields struct

+ GroupAnchorID sql.NullInt64

+ GroupGenesisID sql.NullInt64

+ GroupInternalKeyID sql.NullInt64

type PendingAssetStore

+ BindMintingBatchWithTapSibling func(ctx context.Context, arg BatchTapSiblingUpdate) error

+ FetchAssetID func(ctx context.Context, arg FetchAssetID) ([]int64, error)

+ UpsertAssetProofByID func(ctx context.Context, arg ProofUpdateByID) error

type PostgresStore

+ func NewTestPostgresDBWithVersion(t *testing.T, version uint) *PostgresStore

+ func (s *PostgresStore) ExecuteMigrations(target MigrationTarget, optFuncs ...MigrateOpt) error

+ type QueryMultiverseLeaves = sqlc.QueryMultiverseLeavesParams

type SqliteConfig

+ SkipMigrationDbBackup bool

type SqliteStore

+ func NewTestDBWithVersion(t *testing.T, version uint) *SqliteStore

+ func NewTestDbHandleFromPath(t *testing.T, dbPath string) *SqliteStore

+ func NewTestSqliteDBWithVersion(t *testing.T, version uint) *SqliteStore

+ func NewTestSqliteDbHandleFromPath(t *testing.T, dbPath string) *SqliteStore

+ func (s *SqliteStore) ExecuteMigrations(target MigrationTarget, optFuncs ...MigrateOpt) error

type TapAddressBook

+ func (t *TapAddressBook) FetchInternalKeyLocator(ctx context.Context, rawKey *btcec.PublicKey) (keychain.KeyLocator, error)

+ func (t *TapAddressBook) QueryEvent(ctx context.Context, addr *address.AddrWithKeyInfo, outpoint wire.OutPoint) (*address.Event, error)

+ type TapscriptTreeEdge = sqlc.UpsertTapscriptTreeEdgeParams

+ type TapscriptTreeNode = sqlc.FetchTapscriptTreeRow

+ type TapscriptTreeRootHash = sqlc.UpsertTapscriptTreeRootHashParams

+ type TapscriptTreeStore interface

+ DeleteTapscriptTreeEdges func(ctx context.Context, rootHash []byte) error

+ DeleteTapscriptTreeNodes func(ctx context.Context) error

+ DeleteTapscriptTreeRoot func(ctx context.Context, rootHash []byte) error

+ FetchTapscriptTree func(ctx context.Context, rootHash []byte) ([]TapscriptTreeNode, error)

+ UpsertTapscriptTreeEdge func(ctx context.Context, edge TapscriptTreeEdge) (int64, error)

+ UpsertTapscriptTreeNode func(ctx context.Context, node []byte) (int64, error)

+ UpsertTapscriptTreeRootHash func(ctx context.Context, rootHash TapscriptTreeRootHash) (int64, error)

type UpsertAssetStore

+ UpsertAsset func(ctx context.Context, arg sqlc.UpsertAssetParams) (int64, error)

+ type UpsertMultiverseLeaf = sqlc.UpsertMultiverseLeafParams

+ type UpsertMultiverseRoot = sqlc.UpsertMultiverseRootParams

v0.4.0-rc4

Jul 12, 2024

v0.4.0-rc1

Jun 27, 2024

v0.4.0-alpha.rc3

Jul 10, 2024

v0.4.0-alpha.rc2

Jul 3, 2024

v0.4.0-alpha.rc1

Jun 27, 2024

v0.3.3

Feb 7, 2024

Changes in this version

type ActiveAssetsStore

+ HasAssetProof func(ctx context.Context, scriptKey []byte) (bool, error)

+ UpsertAssetProofByID func(ctx context.Context, arg ProofUpdateByID) error

+ UpsertAssetWitness func(context.Context, PrevInput) error

type AssetStore

+ func (a *AssetStore) HasProof(ctx context.Context, locator proof.Locator) (bool, error)

+ type DeleteFedProofSyncLogParams = sqlc.DeleteFederationProofSyncLogParams

+ type FederationProofSyncLogStore interface

+ DeleteFederationProofSyncLog func(ctx context.Context, arg DeleteFedProofSyncLogParams) error

+ QueryFederationProofSyncLog func(ctx context.Context, arg QueryFedProofSyncLogParams) ([]ProofSyncLogEntry, error)

+ UpsertFederationProofSyncLog func(ctx context.Context, arg UpsertFedProofSyncLogParams) (int64, error)

+ type FetchAssetProof = sqlc.FetchAssetProofParams

type MultiverseStore

+ func (b *MultiverseStore) FetchProof(ctx context.Context, originLocator proof.Locator) (proof.Blob, error)

+ func (b *MultiverseStore) RegisterSubscriber(receiver *fn.EventReceiver[proof.Blob], deliverExisting bool, ...) error

+ func (b *MultiverseStore) RemoveSubscriber(subscriber *fn.EventReceiver[proof.Blob]) error

+ type ProofSyncLogEntry = sqlc.QueryFederationProofSyncLogRow

+ type ProofUpdateByID = sqlc.UpsertAssetProofByIDParams

+ type QueryFedProofSyncLogParams = sqlc.QueryFederationProofSyncLogParams

+ type QueryUniServersParams = sqlc.QueryUniverseServersParams

type UniverseFederationDB

+ func (u *UniverseFederationDB) DeleteProofsSyncLogEntries(ctx context.Context, servers ...universe.ServerAddr) error

+ func (u *UniverseFederationDB) FetchPendingProofsSyncLog(ctx context.Context, syncDirection *universe.SyncDirection) ([]*universe.ProofSyncLogEntry, error)

+ func (u *UniverseFederationDB) QueryFederationProofSyncLog(ctx context.Context, uniID universe.Identifier, leafKey universe.LeafKey, ...) ([]*universe.ProofSyncLogEntry, error)

+ func (u *UniverseFederationDB) UpsertFederationProofSyncLog(ctx context.Context, uniID universe.Identifier, leafKey universe.LeafKey, ...) (int64, error)

type UniverseServerStore

+ QueryUniverseServers func(ctx context.Context, arg sqlc.QueryUniverseServersParams) ([]sqlc.UniverseServer, error)

+ type UpsertFedProofSyncLogParams = sqlc.UpsertFederationProofSyncLogParams

v0.3.3-alpha.rc3

Feb 6, 2024

v0.3.3-alpha.rc2

Feb 6, 2024

v0.3.3-alpha.rc1

Jan 26, 2024

v0.3.2

Dec 5, 2023

Changes in this version

type UpsertAssetStore

+ QueryAssets func(context.Context, QueryAssetFilters) ([]ConfirmedAsset, error)

v0.3.2-rc2

Nov 28, 2023

v0.3.2-beta.rc2

Nov 28, 2023

v0.3.2-beta.rc1

Nov 21, 2023

v0.3.1

Nov 9, 2023

Changes in this version

+ const StatsCacheDuration

type ActiveAssetsStore

+ LogProofTransferAttempt func(ctx context.Context, arg LogProofTransAttemptParams) error

+ QueryProofTransferAttempts func(ctx context.Context, arg QueryProofTransAttemptsParams) ([]time.Time, error)

type AssetStore

+ func (a *AssetStore) LogProofTransferAttempt(ctx context.Context, locator proof.Locator, transferType proof.TransferType) error

+ func (a *AssetStore) QueryProofTransferLog(ctx context.Context, locator proof.Locator, transferType proof.TransferType) ([]time.Time, error)

+ type LogProofTransAttemptParams = sqlc.LogProofTransferAttemptParams

type MultiverseStore

+ func (b *MultiverseStore) DeleteUniverse(ctx context.Context, id universe.Identifier) (string, error)

+ func (b *MultiverseStore) UniverseLeafKeys(ctx context.Context, q universe.UniverseLeafKeysQuery) ([]universe.LeafKey, error)

+ func (b *MultiverseStore) UniverseRootNode(ctx context.Context, id universe.Identifier) (universe.Root, error)

+ func (b *MultiverseStore) UpsertProofLeafBatch(ctx context.Context, items []*universe.Item) error

type PostgresConfig

+ ConnMaxIdleTime time.Duration

+ ConnMaxLifetime time.Duration

+ MaxIdleConnections int

+ type ProofKey [32]byte

+ func NewProofKey(id universe.Identifier, key universe.LeafKey) ProofKey

+ type QueryProofTransAttemptsParams = sqlc.QueryProofTransferAttemptsParams

+ type UniverseLeafKeysQuery = sqlc.FetchUniverseKeysParams

+ type UniverseRootsParams = sqlc.UniverseRootsParams

+ type UniverseStatsOption func(*statsOpts)

+ func WithStatsCacheDuration(d time.Duration) UniverseStatsOption

v0.3.1-alpha.rc2

Nov 7, 2023

v0.3.1-alpha.rc1

Nov 3, 2023

v0.3.0

Oct 18, 2023

Changes in this version

+ const DefaultInitialRetryDelay

+ const DefaultMaxRetryDelay

type ActiveAssetsStore

+ DeleteExpiredUTXOLeases func(ctx context.Context, now sql.NullTime) error

+ DeleteUTXOLease func(ctx context.Context, outpoint []byte) error

+ FetchAssetProofsByAssetID func(ctx context.Context, assetID []byte) ([]AssetProofByIDRow, error)

+ UpdateUTXOLease func(ctx context.Context, arg UpdateUTXOLease) error

+ type AssetGroupWitness = sqlc.UpsertAssetGroupWitnessParams

type AssetHumanReadable

+ Version asset.Version

+ type AssetProofByIDRow = sqlc.FetchAssetProofsByAssetIDRow

type AssetQueryFilters

+ MinAnchorHeight int32

type AssetStore

+ func (a *AssetStore) DeleteExpiredLeases(ctx context.Context) error

+ func (a *AssetStore) FetchProofs(ctx context.Context, id asset.ID) ([]*proof.AnnotatedProof, error)

+ func (a *AssetStore) LeaseCoins(ctx context.Context, leaseOwner [32]byte, expiry time.Time, ...) error

+ func (a *AssetStore) ReleaseCoins(ctx context.Context, utxoOutpoints ...wire.OutPoint) error

+ type BaseMultiverseOptions struct

+ func NewBaseMultiverseReadTx() BaseMultiverseOptions

+ func (b *BaseMultiverseOptions) ReadOnly() bool

+ type BaseMultiverseStore interface

+ UniverseRoots func(ctx context.Context) ([]BaseUniverseRoot, error)

type BaseUniverseStore

+ UpsertUniverseLeaf func(ctx context.Context, arg UpsertUniverseLeaf) error

+ type BatchedMultiverse interface

type ChainAsset

+ AnchorLeaseExpiry *time.Time

+ AnchorLeaseOwner [32]byte

+ type FedGlobalSyncConfig = sqlc.FederationGlobalSyncConfig

+ type FedUniSyncConfigs = sqlc.FederationUniSyncConfig

+ type FederationSyncConfigStore interface

+ QueryFederationGlobalSyncConfigs func(ctx context.Context) ([]FedGlobalSyncConfig, error)

+ QueryFederationUniSyncConfigs func(ctx context.Context) ([]FedUniSyncConfigs, error)

+ UpsertFederationGlobalSyncConfig func(ctx context.Context, arg UpsertFedGlobalSyncConfigParams) error

+ UpsertFederationUniSyncConfig func(ctx context.Context, arg UpsertFedUniSyncConfigParams) error

+ type MultiverseStore struct

+ func NewMultiverseStore(db BatchedMultiverse) *MultiverseStore

+ func (b *MultiverseStore) FetchProofLeaf(ctx context.Context, id universe.Identifier, universeKey universe.LeafKey) ([]*universe.Proof, error)

+ func (b *MultiverseStore) RegisterBatchIssuance(ctx context.Context, items []*universe.IssuanceItem) error

+ func (b *MultiverseStore) RootNode(ctx context.Context, proofType universe.ProofType) (*universe.MultiverseRoot, error)

+ func (b *MultiverseStore) RootNodes(ctx context.Context) ([]universe.BaseRoot, error)

+ func (b *MultiverseStore) UpsertProofLeaf(ctx context.Context, id universe.Identifier, key universe.LeafKey, ...) (*universe.Proof, error)

type UniverseFederationDB

+ func (u *UniverseFederationDB) QueryFederationSyncConfigs(ctx context.Context) ([]*universe.FedGlobalSyncConfig, []*universe.FedUniSyncConfig, error)

+ func (u *UniverseFederationDB) UpsertFederationSyncConfig(ctx context.Context, globalSyncConfigs []*universe.FedGlobalSyncConfig, ...) error

type UniverseStats

+ func (u *UniverseStats) LogNewProofEvents(ctx context.Context, uniIDs ...universe.Identifier) error

+ func (u *UniverseStats) LogSyncEvents(ctx context.Context, uniIDs ...universe.Identifier) error

+ type UpdateUTXOLease = sqlc.UpdateUTXOLeaseParams

type UpsertAssetStore

+ UpsertAssetGroupWitness func(ctx context.Context, arg AssetGroupWitness) (int64, error)

+ type UpsertFedGlobalSyncConfigParams = sqlc.UpsertFederationGlobalSyncConfigParams

+ type UpsertFedUniSyncConfigParams = sqlc.UpsertFederationUniSyncConfigParams

+ type UpsertUniverseLeaf = sqlc.UpsertUniverseLeafParams

v0.3.0-alpha.rc3

Oct 18, 2023

v0.3.0-alpha.rc2

Oct 14, 2023

v0.3.0-alpha.rc1

Oct 12, 2023

v0.2.3

Jul 19, 2023

Changes in this version

+ type AssetStatsPerDay = sqlc.QueryAssetStatsPerDaySqliteRow

+ type AssetStatsPerDayPg = sqlc.QueryAssetStatsPerDayPostgresRow

+ type AssetStatsPerDayQuery = sqlc.QueryAssetStatsPerDaySqliteParams

+ type AssetStatsPerDayQueryPg = sqlc.QueryAssetStatsPerDayPostgresParams

type BaseDB

+ func (s *BaseDB) Backend() sqlc.BackendType

type BatchedQuerier

+ Backend func() sqlc.BackendType

type BatchedTx

+ Backend func() sqlc.BackendType

type ChainAsset

+ AnchorBlockHeight uint32

type TransactionExecutor

+ func (t *TransactionExecutor[Q]) Backend() sqlc.BackendType

type UniverseStats

+ func (u *UniverseStats) QueryAssetStatsPerDay(ctx context.Context, q universe.GroupedStatsQuery) ([]*universe.GroupedStats, error)

type UniverseStatsStore

+ QueryAssetStatsPerDayPostgres func(ctx context.Context, q AssetStatsPerDayQueryPg) ([]AssetStatsPerDayPg, error)

+ QueryAssetStatsPerDaySqlite func(ctx context.Context, q AssetStatsPerDayQuery) ([]AssetStatsPerDay, error)

type UpsertAssetStore

+ AnchorGenesisPoint func(ctx context.Context, arg GenesisPointAnchor) error

+ UpsertChainTx func(ctx context.Context, arg ChainTxParams) (int32, error)

v0.2.2

Jun 23, 2023

v0.2.1

Jun 22, 2023

Changes in this version

+ const DefaultNumTxRetries

+ const DefaultRetryDelay

+ var ErrRetriesExceeded = errors.New("db tx retries exceeded")

+ func IsSerializationError(err error) bool

type BaseUniverseStore

+ DeleteUniverseEvents func(ctx context.Context, namespace string) error

+ DeleteUniverseLeaves func(ctx context.Context, namespace string) error

+ DeleteUniverseRoot func(ctx context.Context, namespace string) error

type BaseUniverseTree

+ func (b *BaseUniverseTree) DeleteUniverse(ctx context.Context) (string, error)

+ type ErrSerializationError struct

+ DbError error

+ func (e ErrSerializationError) Error() string

+ func (e ErrSerializationError) Unwrap() error

type TreeStore

+ DeleteAllNodes func(ctx context.Context, namespace string) (int64, error)

+ DeleteRoot func(ctx context.Context, namespace string) (int64, error)

+ type TxExecutorOption func(*txExecutorOptions)

+ func WithTxRetries(numRetries int) TxExecutorOption

+ func WithTxRetryDelay(delay time.Duration) TxExecutorOption

v0.2.0

May 16, 2023

Changes in this version

+ const PostgresTag

+ const Subsystem

+ var DefaultPostgresFixtureLifetime = 10 * time.Minute

+ var DefaultStoreTimeout = time.Second * 10

+ var ErrAssetMetaNotFound = fmt.Errorf("asset meta not found")

+ var ErrNoUniverseProofFound = fmt.Errorf("no universe proof found")

+ var MaxValidSQLTime = time.Date(9999, 12, 31, 23, 59, 59, 999999, time.UTC)

+ func DisableLog()

+ func MapSQLError(err error) error

+ func UseLogger(logger btclog.Logger)

+ type ActiveAssetsStore interface

+ ApplyPendingOutput func(ctx context.Context, arg ApplyPendingOutput) (int32, error)

+ ConfirmChainAnchorTx func(ctx context.Context, arg AnchorTxConf) error

+ DeleteAssetWitnesses func(ctx context.Context, assetID int32) error

+ DeleteManagedUTXO func(ctx context.Context, outpoint []byte) error

+ FetchAssetMetaByHash func(ctx context.Context, metaDataHash []byte) (sqlc.FetchAssetMetaByHashRow, error)

+ FetchAssetMetaForAsset func(ctx context.Context, assetID []byte) (sqlc.FetchAssetMetaForAssetRow, error)

+ FetchAssetProof func(ctx context.Context, scriptKey []byte) (AssetProofI, error)

+ FetchAssetProofs func(ctx context.Context) ([]AssetProof, error)

+ FetchAssetWitnesses func(context.Context, sql.NullInt32) ([]AssetWitness, error)

+ FetchChainTx func(ctx context.Context, txid []byte) (ChainTx, error)

+ FetchGroupedAssets func(context.Context) ([]RawGroupedAsset, error)

+ FetchManagedUTXO func(context.Context, UtxoQuery) (AnchorPoint, error)

+ FetchManagedUTXOs func(context.Context) ([]ManagedUTXORow, error)

+ FetchTransferInputs func(ctx context.Context, transferID int32) ([]TransferInputRow, error)

+ FetchTransferOutputs func(ctx context.Context, transferID int32) ([]TransferOutputRow, error)

+ InsertAssetTransfer func(ctx context.Context, arg NewAssetTransfer) (int32, error)

+ InsertAssetTransferInput func(ctx context.Context, arg NewTransferInput) error

+ InsertAssetTransferOutput func(ctx context.Context, arg NewTransferOutput) error

+ InsertAssetWitness func(context.Context, PrevInput) error

+ InsertPassiveAsset func(ctx context.Context, arg NewPassiveAsset) error

+ InsertReceiverProofTransferAttempt func(ctx context.Context, arg InsertRecvProofTxAttemptParams) error

+ QueryAssetBalancesByAsset func(context.Context, []byte) ([]RawAssetBalance, error)

+ QueryAssetBalancesByGroup func(context.Context, []byte) ([]RawAssetGroupBalance, error)

+ QueryAssetTransfers func(ctx context.Context, query sqlc.QueryAssetTransfersParams) ([]AssetTransferRow, error)

+ QueryAssets func(context.Context, QueryAssetFilters) ([]ConfirmedAsset, error)

+ QueryPassiveAssets func(ctx context.Context, transferID int32) ([]PassiveAsset, error)

+ QueryReceiverProofTransferAttempt func(ctx context.Context, proofLocatorHash []byte) ([]time.Time, error)

+ ReAnchorPassiveAssets func(ctx context.Context, arg ReAnchorParams) error

+ UpsertAssetProof func(ctx context.Context, arg sqlc.UpsertAssetProofParams) error

+ UpsertChainTx func(ctx context.Context, arg ChainTxParams) (int32, error)

+ UpsertManagedUTXO func(ctx context.Context, arg RawManagedUTXO) (int32, error)

+ type AddrBook interface

+ FetchAddrByTaprootOutputKey func(ctx context.Context, arg []byte) (AddrByTaprootOutput, error)

+ FetchAddrEvent func(ctx context.Context, id int32) (AddrEvent, error)

+ FetchAddrs func(ctx context.Context, arg AddrQuery) ([]Addresses, error)

+ FetchAssetProof func(ctx context.Context, scriptKey []byte) (AssetProofI, error)

+ FetchGenesisByAssetID func(ctx context.Context, assetID []byte) (sqlc.GenesisInfoView, error)

+ FetchScriptKeyByTweakedKey func(ctx context.Context, tweakedScriptKey []byte) (ScriptKey, error)

+ InsertAddr func(ctx context.Context, arg NewAddr) (int32, error)

+ QueryEventIDs func(ctx context.Context, query AddrEventQuery) ([]AddrEventID, error)

+ SetAddrManaged func(ctx context.Context, arg AddrManaged) error

+ UpsertAddrEvent func(ctx context.Context, arg UpsertAddrEvent) (int32, error)

+ UpsertChainTx func(ctx context.Context, arg ChainTxParams) (int32, error)

+ UpsertInternalKey func(ctx context.Context, arg InternalKey) (int32, error)

+ UpsertManagedUTXO func(ctx context.Context, arg RawManagedUTXO) (int32, error)

+ UpsertScriptKey func(context.Context, NewScriptKey) (int32, error)

+ type AddrBookTxOptions struct

+ func (a *AddrBookTxOptions) ReadOnly() bool

+ type AddrByTaprootOutput = sqlc.FetchAddrByTaprootOutputKeyRow

+ type AddrEvent = sqlc.FetchAddrEventRow

+ type AddrEventID = sqlc.QueryEventIDsRow

+ type AddrEventQuery = sqlc.QueryEventIDsParams

+ type AddrManaged = sqlc.SetAddrManagedParams

+ type AddrQuery = sqlc.FetchAddrsParams

+ type Addresses = sqlc.FetchAddrsRow

+ type AggregateStats = sqlc.QueryUniverseStatsRow

+ type AnchorPoint = sqlc.FetchManagedUTXORow

+ type AnchorTxConf = sqlc.ConfirmChainAnchorTxParams

+ type ApplyPendingOutput = sqlc.ApplyPendingOutputParams

+ type AssetAnchor = sqlc.AnchorPendingAssetsParams

+ type AssetBalance struct

+ Balance uint64

+ GenesisPoint wire.OutPoint

+ ID asset.ID

+ MetaHash [asset.MetaHashLen]byte

+ OutputIndex uint32

+ Tag string

+ Type asset.Type

+ Version int32

+ type AssetGroupBalance struct

+ Balance uint64

+ GroupKey *btcec.PublicKey

+ type AssetGroupKey = sqlc.UpsertAssetGroupKeyParams

+ type AssetGroupSig = sqlc.UpsertAssetGroupSigParams

+ type AssetHumanReadable struct

+ Amount uint64

+ GroupKey *btcec.PublicKey

+ ID asset.ID

+ LockTime uint64

+ MetaHash [asset.MetaHashLen]byte

+ RelativeLockTime uint64

+ Tag string

+ Type asset.Type

+ type AssetMintingStore struct

+ func NewAssetMintingStore(db BatchedPendingAssetStore) *AssetMintingStore

+ func (a *AssetMintingStore) AddSeedlingsToBatch(ctx context.Context, batchKey *btcec.PublicKey, ...) error

+ func (a *AssetMintingStore) AddSproutsToBatch(ctx context.Context, batchKey *btcec.PublicKey, ...) error

+ func (a *AssetMintingStore) CommitMintingBatch(ctx context.Context, newBatch *tapgarden.MintingBatch) error

+ func (a *AssetMintingStore) CommitSignedGenesisTx(ctx context.Context, batchKey *btcec.PublicKey, ...) error

+ func (a *AssetMintingStore) FetchAllBatches(ctx context.Context) ([]*tapgarden.MintingBatch, error)

+ func (a *AssetMintingStore) FetchGroupByGenesis(ctx context.Context, genesisID int32) (*asset.AssetGroup, error)

+ func (a *AssetMintingStore) FetchGroupByGroupKey(ctx context.Context, groupKey *btcec.PublicKey) (*asset.AssetGroup, error)

+ func (a *AssetMintingStore) FetchMintingBatch(ctx context.Context, batchKey *btcec.PublicKey) (*tapgarden.MintingBatch, error)

+ func (a *AssetMintingStore) FetchNonFinalBatches(ctx context.Context) ([]*tapgarden.MintingBatch, error)

+ func (a *AssetMintingStore) MarkBatchConfirmed(ctx context.Context, batchKey *btcec.PublicKey, blockHash *chainhash.Hash, ...) error

+ func (a *AssetMintingStore) UpdateBatchState(ctx context.Context, batchKey *btcec.PublicKey, newState tapgarden.BatchState) error

+ type AssetProof = sqlc.FetchAssetProofsRow

+ type AssetProofI = sqlc.FetchAssetProofRow

+ type AssetQueryFilters struct

+ type AssetSeedling = sqlc.AssetSeedling

+ type AssetSeedlingItem = sqlc.InsertAssetSeedlingIntoBatchParams

+ type AssetSeedlingShell = sqlc.InsertAssetSeedlingParams

+ type AssetSeedlingTuple = sqlc.FetchSeedlingIDParams

+ type AssetSprout = sqlc.FetchAssetsForBatchRow

+ type AssetStore struct

+ func NewAssetStore(db BatchedAssetStore) *AssetStore

+ func (a *AssetStore) ConfirmParcelDelivery(ctx context.Context, conf *tapfreighter.AssetConfirmEvent) error

+ func (a *AssetStore) FetchAllAssets(ctx context.Context, includeSpent bool, query *AssetQueryFilters) ([]*ChainAsset, error)

+ func (a *AssetStore) FetchAssetMetaByHash(ctx context.Context, metaHash [asset.MetaHashLen]byte) (*proof.MetaReveal, error)

+ func (a *AssetStore) FetchAssetMetaForAsset(ctx context.Context, assetID asset.ID) (*proof.MetaReveal, error)

+ func (a *AssetStore) FetchAssetProofs(ctx context.Context, targetAssets ...*btcec.PublicKey) (proof.AssetBlobs, error)

+ func (a *AssetStore) FetchCommitment(ctx context.Context, id asset.ID, anchorPoint wire.OutPoint, ...) (*tapfreighter.AnchoredCommitment, error)

+ func (a *AssetStore) FetchGroupedAssets(ctx context.Context) ([]*AssetHumanReadable, error)

+ func (a *AssetStore) FetchManagedUTXOs(ctx context.Context) ([]*ManagedUTXO, error)

+ func (a *AssetStore) FetchProof(ctx context.Context, locator proof.Locator) (proof.Blob, error)

+ func (a *AssetStore) ImportProofs(ctx context.Context, headerVerifier proof.HeaderVerifier, ...) error

+ func (a *AssetStore) ListEligibleCoins(ctx context.Context, constraints tapfreighter.CommitmentConstraints) ([]*tapfreighter.AnchoredCommitment, error)

+ func (a *AssetStore) LogPendingParcel(ctx context.Context, spend *tapfreighter.OutboundParcel) error

+ func (a *AssetStore) PendingParcels(ctx context.Context) ([]*tapfreighter.OutboundParcel, error)

+ func (a *AssetStore) QueryAssetBalancesByGroup(ctx context.Context, groupKey *btcec.PublicKey) (map[asset.SerializedKey]AssetGroupBalance, error)

+ func (a *AssetStore) QueryBalancesByAsset(ctx context.Context, assetID *asset.ID) (map[asset.ID]AssetBalance, error)

+ func (a *AssetStore) QueryParcels(ctx context.Context, pending bool) ([]*tapfreighter.OutboundParcel, error)

+ func (a *AssetStore) QueryProofDeliveryLog(ctx context.Context, locator proof.Locator) ([]time.Time, error)

+ func (a *AssetStore) RegisterSubscriber(receiver *chanutils.EventReceiver[proof.Blob], deliverExisting bool, ...) error

+ func (a *AssetStore) RemoveSubscriber(subscriber *chanutils.EventReceiver[proof.Blob]) error

+ func (a *AssetStore) StoreProofDeliveryAttempt(ctx context.Context, locator proof.Locator) error

+ type AssetStoreTxOptions struct

+ func NewAddrBookReadTx() AssetStoreTxOptions

+ func NewAssetStoreReadTx() AssetStoreTxOptions

+ func (r *AssetStoreTxOptions) ReadOnly() bool

+ type AssetTransfer = sqlc.AssetTransfer

+ type AssetTransferRow = sqlc.QueryAssetTransfersRow

+ type AssetWitness = sqlc.FetchAssetWitnessesRow

+ type BaseDB struct

+ func (s *BaseDB) BeginTx(ctx context.Context, opts TxOptions) (*sql.Tx, error)

+ type BaseUniverseForest struct

+ func NewBaseUniverseForest(db BatchedUniverseForest) *BaseUniverseForest

+ func (b *BaseUniverseForest) RootNodes(ctx context.Context) ([]universe.BaseRoot, error)

+ type BaseUniverseForestOptions struct

+ func NewBaseUniverseForestReadTx() BaseUniverseForestOptions

+ func (b *BaseUniverseForestOptions) ReadOnly() bool

+ type BaseUniverseForestStore interface

+ UniverseRoots func(ctx context.Context) ([]BaseUniverseRoot, error)

+ type BaseUniverseRoot = sqlc.UniverseRootsRow

+ type BaseUniverseStore interface

+ FetchUniverseKeys func(ctx context.Context, namespace string) ([]UniverseKeys, error)

+ FetchUniverseRoot func(ctx context.Context, namespace string) (UniverseRoot, error)

+ InsertUniverseLeaf func(ctx context.Context, arg NewUniverseLeaf) error

+ QueryUniverseLeaves func(ctx context.Context, arg UniverseLeafQuery) ([]UniverseLeaf, error)

+ UpsertUniverseRoot func(ctx context.Context, arg NewUniverseRoot) (int32, error)

+ type BaseUniverseStoreOptions struct

+ func NewBaseUniverseReadTx() BaseUniverseStoreOptions

+ func (b *BaseUniverseStoreOptions) ReadOnly() bool

+ type BaseUniverseTree struct

+ func NewBaseUniverseTree(db BatchedUniverseTree, id universe.Identifier) *BaseUniverseTree

+ func (b *BaseUniverseTree) FetchIssuanceProof(ctx context.Context, universeKey universe.BaseKey) ([]*universe.IssuanceProof, error)

+ func (b *BaseUniverseTree) MintingKeys(ctx context.Context) ([]universe.BaseKey, error)

+ func (b *BaseUniverseTree) MintingLeaves(ctx context.Context) ([]universe.MintingLeaf, error)

+ func (b *BaseUniverseTree) RegisterIssuance(ctx context.Context, key universe.BaseKey, leaf *universe.MintingLeaf, ...) (*universe.IssuanceProof, error)

+ func (b *BaseUniverseTree) RootNode(ctx context.Context) (mssmt.Node, string, error)

+ type BatchChainUpdate = sqlc.BindMintingBatchWithTxParams

+ type BatchStateUpdate = sqlc.UpdateMintingBatchStateParams

+ type BatchedAddrBook interface

+ type BatchedAssetStore interface

+ type BatchedKeyStore interface

+ type BatchedPendingAssetStore interface

+ type BatchedQuerier interface

+ BeginTx func(ctx context.Context, options TxOptions) (*sql.Tx, error)

+ type BatchedTreeStore interface

+ type BatchedTx interface

+ ExecTx func(ctx context.Context, txOptions TxOptions, txBody func(Q) error) error

+ type BatchedUniverseForest interface

+ type BatchedUniverseServerStore interface

+ type BatchedUniverseStats interface

+ type BatchedUniverseTree interface

+ type ChainAsset struct

+ AnchorBlockHash chainhash.Hash

+ AnchorInternalKey *btcec.PublicKey

+ AnchorMerkleRoot []byte

+ AnchorOutpoint wire.OutPoint

+ AnchorTapscriptSibling []byte

+ AnchorTx *wire.MsgTx

+ AnchorTxid chainhash.Hash

+ IsSpent bool

+ type ChainTx = sqlc.ChainTxn

+ type ChainTxConf = sqlc.ConfirmChainTxParams

+ type ChainTxParams = sqlc.UpsertChainTxParams

+ type ChildQuery = sqlc.FetchChildrenParams

+ type ConfirmedAsset = sqlc.QueryAssetsRow

+ type DelNode = sqlc.DeleteNodeParams

+ type DelUniverseServer = sqlc.DeleteUniverseServerParams

+ type ErrSqlUniqueConstraintViolation struct

+ DbError error

+ func (e ErrSqlUniqueConstraintViolation) Error() string

+ type FetchGenesisStore interface

+ FetchGenesisByID func(ctx context.Context, assetID int32) (Genesis, error)

+ type Genesis = sqlc.FetchGenesisByIDRow

+ type GenesisAsset = sqlc.UpsertGenesisAssetParams

+ type GenesisPointAnchor = sqlc.AnchorGenesisPointParams

+ type GenesisTxUpdate = sqlc.UpdateBatchGenesisTxParams

+ type GroupStore interface

+ FetchGroupByGenesis func(ctx context.Context, genesisID int32) (sqlc.FetchGroupByGenesisRow, error)

+ FetchGroupByGroupKey func(ctx context.Context, groupKey []byte) (sqlc.FetchGroupByGroupKeyRow, error)

+ type InsertRecvProofTxAttemptParams = sqlc.InsertReceiverProofTransferAttemptParams

+ type InternalKey = sqlc.UpsertInternalKeyParams

+ type KeyStore interface

+ GetRootKey func(ctx context.Context, id []byte) (MacaroonRootKey, error)

+ InsertRootKey func(ctx context.Context, arg MacaroonID) error

+ type KeyStoreTxOptions struct

+ func NewKeyStoreReadOpts() *KeyStoreTxOptions

+ func (r *KeyStoreTxOptions) ReadOnly() bool

+ type MacaroonID = sqlc.InsertRootKeyParams

+ type MacaroonRootKey = sqlc.Macaroon

+ type ManagedUTXO struct

+ InternalKey keychain.KeyDescriptor

+ MerkleRoot []byte

+ OutPoint wire.OutPoint

+ OutputValue btcutil.Amount

+ TaprootAssetRoot []byte

+ TapscriptSibling []byte

+ type ManagedUTXORow = sqlc.FetchManagedUTXOsRow

+ type MintingBatchA = sqlc.AllMintingBatchesRow

+ type MintingBatchF = sqlc.FetchMintingBatchRow

+ type MintingBatchI = sqlc.FetchMintingBatchesByInverseStateRow

+ type MintingBatchInit = sqlc.NewMintingBatchParams

+ type MintingBatchTuple = sqlc.UpdateMintingBatchStateParams

+ type NewAddr = sqlc.InsertAddrParams

+ type NewAssetMeta = sqlc.UpsertAssetMetaParams

+ type NewAssetTransfer = sqlc.InsertAssetTransferParams

+ type NewBranch = sqlc.InsertBranchParams

+ type NewCompactedLeaf = sqlc.InsertCompactedLeafParams

+ type NewLeaf = sqlc.InsertLeafParams

+ type NewPassiveAsset = sqlc.InsertPassiveAssetParams

+ type NewProofEvent = sqlc.InsertNewProofEventParams

+ type NewScriptKey = sqlc.UpsertScriptKeyParams

+ type NewSyncEvent = sqlc.InsertNewSyncEventParams

+ type NewTransferInput = sqlc.InsertAssetTransferInputParams

+ type NewTransferOutput = sqlc.InsertAssetTransferOutputParams

+ type NewUniverseLeaf = sqlc.InsertUniverseLeafParams

+ type NewUniverseRoot = sqlc.UpsertUniverseRootParams

+ type NewUniverseServer = sqlc.InsertUniverseServerParams

+ type PassiveAsset = sqlc.QueryPassiveAssetsRow

+ type PendingAssetStore interface

+ AllMintingBatches func(ctx context.Context) ([]MintingBatchA, error)

+ AnchorGenesisPoint func(ctx context.Context, arg GenesisPointAnchor) error

+ AnchorPendingAssets func(ctx context.Context, arg AssetAnchor) error

+ BindMintingBatchWithTx func(ctx context.Context, arg BatchChainUpdate) error

+ ConfirmChainTx func(ctx context.Context, arg ChainTxConf) error

+ FetchAssetMetaForAsset func(ctx context.Context, assetID []byte) (sqlc.FetchAssetMetaForAssetRow, error)

+ FetchAssetsForBatch func(ctx context.Context, rawKey []byte) ([]AssetSprout, error)

+ FetchMintingBatch func(ctx context.Context, rawKey []byte) (MintingBatchF, error)

+ FetchMintingBatchesByInverseState func(ctx context.Context, batchState int16) ([]MintingBatchI, error)

+ FetchSeedlingByID func(ctx context.Context, seedlingID int32) (AssetSeedling, error)

+ FetchSeedlingID func(ctx context.Context, arg AssetSeedlingTuple) (int32, error)

+ FetchSeedlingsForBatch func(ctx context.Context, rawKey []byte) ([]sqlc.FetchSeedlingsForBatchRow, error)

+ InsertAssetSeedling func(ctx context.Context, arg AssetSeedlingShell) error

+ InsertAssetSeedlingIntoBatch func(ctx context.Context, arg AssetSeedlingItem) error

+ NewMintingBatch func(ctx context.Context, arg MintingBatchInit) error

+ UpdateBatchGenesisTx func(ctx context.Context, arg GenesisTxUpdate) error

+ UpdateMintingBatchState func(ctx context.Context, arg BatchStateUpdate) error

+ UpsertAssetProof func(ctx context.Context, arg sqlc.UpsertAssetProofParams) error

+ UpsertChainTx func(ctx context.Context, arg ChainTxParams) (int32, error)

+ UpsertManagedUTXO func(ctx context.Context, arg RawManagedUTXO) (int32, error)

+ type PostgresConfig struct

+ DBName string

+ Host string

+ MaxOpenConnections int32

+ Password string

+ Port int

+ RequireSSL bool

+ SkipMigrations bool

+ User string

+ func (s *PostgresConfig) DSN(hidePassword bool) string

+ type PostgresStore struct

+ func NewPostgresStore(cfg *PostgresConfig) (*PostgresStore, error)

+ func NewTestPostgresDB(t *testing.T) *PostgresStore

+ type PrevInput = sqlc.InsertAssetWitnessParams

+ type ProofUpdate = sqlc.UpsertAssetProofParams

+ type QueryAssetFilters = sqlc.QueryAssetsParams

+ type QueryCreator func(*sql.Tx) Q

+ type RawAssetBalance = sqlc.QueryAssetBalancesByAssetRow

+ type RawAssetGroupBalance = sqlc.QueryAssetBalancesByGroupRow

+ type RawGroupedAsset = sqlc.FetchGroupedAssetsRow

+ type RawManagedUTXO = sqlc.UpsertManagedUTXOParams

+ type ReAnchorParams = sqlc.ReAnchorPassiveAssetsParams

+ type RootKeyStore struct

+ func NewRootKeyStore(db BatchedKeyStore) *RootKeyStore

+ func (r *RootKeyStore) Get(ctx context.Context, id []byte) ([]byte, error)

+ func (r *RootKeyStore) RootKey(ctx context.Context) ([]byte, []byte, error)

+ type ScriptKey = sqlc.FetchScriptKeyByTweakedKeyRow

+ type SetAssetSpentParams = sqlc.SetAssetSpentParams

+ type SqliteConfig struct

+ DatabaseFileName string

+ SkipMigrations bool

+ type SqliteStore struct

+ func NewSqliteStore(cfg *SqliteConfig) (*SqliteStore, error)

+ func NewTestDB(t *testing.T) *SqliteStore

+ func NewTestSqliteDB(t *testing.T) *SqliteStore

+ type StoredNode = sqlc.FetchChildrenRow

+ type TapAddressBook struct

+ func NewTapAddressBook(db BatchedAddrBook, params *address.ChainParams) *TapAddressBook

+ func (a *TapAddressBook) CompleteEvent(ctx context.Context, event *address.Event, status address.Status, ...) error

+ func (a *TapAddressBook) QueryAssetGroup(ctx context.Context, assetID asset.ID) (*asset.AssetGroup, error)

+ func (t *TapAddressBook) AddrByTaprootOutput(ctx context.Context, key *btcec.PublicKey) (*address.AddrWithKeyInfo, error)

+ func (t *TapAddressBook) FetchScriptKey(ctx context.Context, tweakedScriptKey *btcec.PublicKey) (*asset.TweakedScriptKey, error)

+ func (t *TapAddressBook) GetOrCreateEvent(ctx context.Context, status address.Status, addr *address.AddrWithKeyInfo, ...) (*address.Event, error)

+ func (t *TapAddressBook) InsertAddrs(ctx context.Context, addrs ...address.AddrWithKeyInfo) error

+ func (t *TapAddressBook) InsertAssetGen(ctx context.Context, gen *asset.Genesis, group *asset.GroupKey) error

+ func (t *TapAddressBook) InsertInternalKey(ctx context.Context, keyDesc keychain.KeyDescriptor) error

+ func (t *TapAddressBook) InsertScriptKey(ctx context.Context, scriptKey asset.ScriptKey) error

+ func (t *TapAddressBook) QueryAddrEvents(ctx context.Context, params address.EventQueryParams) ([]*address.Event, error)

+ func (t *TapAddressBook) QueryAddrs(ctx context.Context, params address.QueryParams) ([]address.AddrWithKeyInfo, error)

+ func (t *TapAddressBook) SetAddrManaged(ctx context.Context, addr *address.AddrWithKeyInfo, managedFrom time.Time) error

+ type TaprootAssetTreeStore struct

+ func NewTaprootAssetTreeStore(db BatchedTreeStore, namespace string) *TaprootAssetTreeStore

+ func (t *TaprootAssetTreeStore) Update(ctx context.Context, update func(tx mssmt.TreeStoreUpdateTx) error) error

+ func (t *TaprootAssetTreeStore) View(ctx context.Context, update func(tx mssmt.TreeStoreViewTx) error) error

+ type TestPgFixture struct

+ func NewTestPgFixture(t *testing.T, expiry time.Duration) *TestPgFixture

+ func (f *TestPgFixture) ClearDB(t *testing.T)

+ func (f *TestPgFixture) GetConfig() *PostgresConfig

+ func (f *TestPgFixture) GetDSN() string

+ func (f *TestPgFixture) TearDown(t *testing.T)

+ type TransactionExecutor struct

+ func NewTransactionExecutor(db BatchedQuerier, createQuery QueryCreator[Querier]) *TransactionExecutor[Querier]

+ func (t *TransactionExecutor[Q]) ExecTx(ctx context.Context, txOptions TxOptions, txBody func(Q) error) error

+ type TransferInput = sqlc.AssetTransferInput

+ type TransferInputRow = sqlc.FetchTransferInputsRow

+ type TransferOutput = sqlc.AssetTransferOutput

+ type TransferOutputRow = sqlc.FetchTransferOutputsRow

+ type TransferQuery = sqlc.QueryAssetTransfersParams

+ type TreeStore interface

+ DeleteNode func(ctx context.Context, n DelNode) (int64, error)

+ FetchChildren func(ctx context.Context, c ChildQuery) ([]StoredNode, error)

+ FetchRootNode func(ctx context.Context, namespace string) (sqlc.MssmtNode, error)

+ InsertBranch func(ctx context.Context, newNode NewBranch) error

+ InsertCompactedLeaf func(ctx context.Context, newNode NewCompactedLeaf) error

+ InsertLeaf func(ctx context.Context, newNode NewLeaf) error

+ UpsertRootNode func(ctx context.Context, arg UpdateRoot) error

+ type TreeStoreTxOptions struct

+ func NewTreeStoreReadTx() TreeStoreTxOptions

+ func (t *TreeStoreTxOptions) ReadOnly() bool

+ type Tx interface

+ Commit func() error

+ Rollback func() error

+ type TxOptions interface

+ ReadOnly func() bool

+ type UniverseFederationDB struct

+ func NewUniverseFederationDB(db BatchedUniverseServerStore) *UniverseFederationDB

+ func (u *UniverseFederationDB) AddServers(ctx context.Context, addrs ...universe.ServerAddr) error

+ func (u *UniverseFederationDB) LogNewSyncs(ctx context.Context, addrs ...universe.ServerAddr) error

+ func (u *UniverseFederationDB) RemoveServers(ctx context.Context, addrs ...universe.ServerAddr) error

+ func (u *UniverseFederationDB) UniverseServers(ctx context.Context) ([]universe.ServerAddr, error)

+ type UniverseFederationOptions struct

+ func NewUniverseFederationReadTx() UniverseFederationOptions

+ func (b *UniverseFederationOptions) ReadOnly() bool

+ type UniverseKeys = sqlc.FetchUniverseKeysRow

+ type UniverseLeaf = sqlc.QueryUniverseLeavesRow

+ type UniverseLeafQuery = sqlc.QueryUniverseLeavesParams

+ type UniverseRoot = sqlc.FetchUniverseRootRow

+ type UniverseServerStore interface

+ DeleteUniverseServer func(ctx context.Context, r DelUniverseServer) error

+ InsertUniverseServer func(ctx context.Context, arg NewUniverseServer) error

+ ListUniverseServers func(ctx context.Context) ([]sqlc.UniverseServer, error)

+ LogServerSync func(ctx context.Context, arg sqlc.LogServerSyncParams) error

+ type UniverseStats struct

+ func NewUniverseStats(db BatchedUniverseStats) *UniverseStats

+ func (u *UniverseStats) AggregateSyncStats(ctx context.Context) (universe.AggregateStats, error)

+ func (u *UniverseStats) LogNewProofEvent(ctx context.Context, uniID universe.Identifier, key universe.BaseKey) error

+ func (u *UniverseStats) LogSyncEvent(ctx context.Context, uniID universe.Identifier, key universe.BaseKey) error

+ func (u *UniverseStats) QuerySyncStats(ctx context.Context, q universe.SyncStatsQuery) (*universe.AssetSyncStats, error)

+ type UniverseStatsOptions struct

+ func NewUniverseStatsReadTx() UniverseStatsOptions

+ func (u *UniverseStatsOptions) ReadOnly() bool

+ type UniverseStatsQuery = sqlc.QueryUniverseAssetStatsParams

+ type UniverseStatsResp = sqlc.QueryUniverseAssetStatsRow

+ type UniverseStatsStore interface

+ InsertNewProofEvent func(ctx context.Context, arg NewProofEvent) error

+ InsertNewSyncEvent func(ctx context.Context, arg NewSyncEvent) error

+ QueryUniverseAssetStats func(ctx context.Context, arg UniverseStatsQuery) ([]UniverseStatsResp, error)

+ QueryUniverseStats func(ctx context.Context) (AggregateStats, error)

+ type UpdateRoot = sqlc.UpsertRootNodeParams

+ type UpsertAddrEvent = sqlc.UpsertAddrEventParams

+ type UpsertAssetStore interface

+ FetchGenesisID func(ctx context.Context, arg sqlc.FetchGenesisIDParams) (int32, error)

+ FetchScriptKeyIDByTweakedKey func(ctx context.Context, tweakedScriptKey []byte) (int32, error)

+ InsertNewAsset func(ctx context.Context, arg sqlc.InsertNewAssetParams) (int32, error)

+ SetAssetSpent func(ctx context.Context, arg SetAssetSpentParams) (int32, error)

+ UpsertAssetGroupKey func(ctx context.Context, arg AssetGroupKey) (int32, error)

+ UpsertAssetGroupSig func(ctx context.Context, arg AssetGroupSig) (int32, error)

+ UpsertAssetMeta func(ctx context.Context, arg NewAssetMeta) (int32, error)

+ UpsertGenesisAsset func(ctx context.Context, arg GenesisAsset) (int32, error)

+ UpsertGenesisPoint func(ctx context.Context, prevOut []byte) (int32, error)

+ UpsertInternalKey func(ctx context.Context, arg InternalKey) (int32, error)

+ UpsertScriptKey func(context.Context, NewScriptKey) (int32, error)

+ type UtxoQuery = sqlc.FetchManagedUTXOParams

v0.2.0-lit-0

Jun 12, 2023

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