Documentation
¶
Overview ¶
The idea behing this is that you might not always want to generate db models after each go generate invocation, mainly because model generation requires a running and up-to-date database instance. By default go generate will try to create/update DB models.
Index ¶
- func AddColumnRefundRequested() *gormigrate.Migration
- func AddContractFieldsToSwapOut() *gormigrate.Migration
- func AddIsAutoSwapToSwapOut() *gormigrate.Migration
- func AddLockTxIdToSwapIn() *gormigrate.Migration
- func AddPreimageTxIdTimeoutBlockHeightToSwapOut() *gormigrate.Migration
- func ChangeNameClaimPubkey() *gormigrate.Migration
- func CreateSwapsTables() *gormigrate.Migration
- func DropClaimTxForSwapIns() *gormigrate.Migration
- func RemoveNotNullInOutcome() *gormigrate.Migration
- func RemoveNotNullSwapOut() *gormigrate.Migration
- func RenameOnchainFeeSatsAndAddCreatedAndUpdatedAt() *gormigrate.Migration
- type Database
- func (d *Database) Generate(path string) error
- func (d *Database) GetConnectionURL() string
- func (d *Database) GetPendingAutoSwapOuts(ctx context.Context) ([]*models.SwapOut, error)
- func (d *Database) GetPendingSwapIns(ctx context.Context) ([]*models.SwapIn, error)
- func (d *Database) GetPendingSwapOuts(ctx context.Context) ([]*models.SwapOut, error)
- func (d *Database) GetSwapIn(ctx context.Context, swapID string) (*models.SwapIn, error)
- func (d *Database) GetSwapInByClaimAddress(ctx context.Context, address string) (*models.SwapIn, error)
- func (d *Database) GetSwapOut(ctx context.Context, swapID string) (*models.SwapOut, error)
- func (d *Database) MigrateDatabase() error
- func (d *Database) MigrateTo(to string) error
- func (d *Database) ORM() *gorm.DB
- func (d *Database) Reset() error
- func (d *Database) Rollback() error
- func (d *Database) SaveSwapIn(ctx context.Context, swapIn *models.SwapIn) error
- func (d *Database) SaveSwapOut(ctx context.Context, swapOut *models.SwapOut) error
- func (d *Database) UpdateAutoSwap(ctx context.Context, swapID string, isAutoSwap bool) error
- type Migrator
- type SwapInRepository
- type SwapOutRepository
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddColumnRefundRequested ¶
func AddColumnRefundRequested() *gormigrate.Migration
This migration adds the `RefundRequestedAt` column to the `SwapIn` table
func AddContractFieldsToSwapOut ¶
func AddContractFieldsToSwapOut() *gormigrate.Migration
func AddIsAutoSwapToSwapOut ¶
func AddIsAutoSwapToSwapOut() *gormigrate.Migration
func AddLockTxIdToSwapIn ¶
func AddLockTxIdToSwapIn() *gormigrate.Migration
func AddPreimageTxIdTimeoutBlockHeightToSwapOut ¶
func AddPreimageTxIdTimeoutBlockHeightToSwapOut() *gormigrate.Migration
func ChangeNameClaimPubkey ¶
func ChangeNameClaimPubkey() *gormigrate.Migration
func CreateSwapsTables ¶
func CreateSwapsTables() *gormigrate.Migration
func DropClaimTxForSwapIns ¶
func DropClaimTxForSwapIns() *gormigrate.Migration
func RemoveNotNullInOutcome ¶
func RemoveNotNullInOutcome() *gormigrate.Migration
This migration removes the `not null` from the `Outcome` field
func RemoveNotNullSwapOut ¶
func RemoveNotNullSwapOut() *gormigrate.Migration
func RenameOnchainFeeSatsAndAddCreatedAndUpdatedAt ¶
func RenameOnchainFeeSatsAndAddCreatedAndUpdatedAt() *gormigrate.Migration
Types ¶
type Database ¶
type Database struct {
// contains filtered or unexported fields
}
func (*Database) GetConnectionURL ¶
func (*Database) GetPendingAutoSwapOuts ¶
func (*Database) GetPendingSwapIns ¶
func (*Database) GetPendingSwapOuts ¶
func (*Database) GetSwapInByClaimAddress ¶
func (*Database) GetSwapOut ¶
func (*Database) MigrateDatabase ¶
func (*Database) SaveSwapIn ¶
func (*Database) SaveSwapOut ¶
type Migrator ¶
type Migrator struct {
// contains filtered or unexported fields
}
func NewMigrator ¶
type SwapInRepository ¶
type SwapInRepository interface {
SaveSwapIn(ctx context.Context, swapIn *models.SwapIn) error
GetPendingSwapIns(ctx context.Context) ([]*models.SwapIn, error)
GetSwapIn(ctx context.Context, swapID string) (*models.SwapIn, error)
GetSwapInByClaimAddress(ctx context.Context, address string) (*models.SwapIn, error)
}
type SwapOutRepository ¶
type SwapOutRepository interface {
SaveSwapOut(ctx context.Context, swapOut *models.SwapOut) error
GetPendingSwapOuts(ctx context.Context) ([]*models.SwapOut, error)
GetSwapOut(ctx context.Context, swapID string) (*models.SwapOut, error)
GetPendingAutoSwapOuts(ctx context.Context) ([]*models.SwapOut, error)
UpdateAutoSwap(ctx context.Context, swapID string, isAutoSwap bool) error
}
Source Files
¶
Click to show internal directories.
Click to hide internal directories.