payoutdb

package
v0.0.0-...-b634e5d Latest Latest
Warning

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

 Go to latest Published: Oct 2, 2024 License: AGPL-3.0 Imports: 13 Imported by: 0

Documentation

Overview

Package payoutdb provides generated database code for the payouts database

Index

Constants

This section is empty.

Variables

View Source 
var (
	WrapErr = func(err *Error) error { return err }
	Logger  func(format string, args ...interface{})
)

Functions

func DeleteAll 

func DeleteAll(ctx context.Context, db *DB) (int64, error)

Types

type DB 

type DB struct {
	*sql.DB

	Hooks struct {
		Now func() time.Time
	}
	// contains filtered or unexported fields
}

func Open 

func Open(driver, source string) (db *DB, err error)

func (*DB) Close 

func (obj *DB) Close() (err error)

func (*DB) CountUnfinishedUnattachedPayoutGroup 

func (db *DB) CountUnfinishedUnattachedPayoutGroup(ctx context.Context) (int64, error)

func (*DB) FirstUnfinishedUnattachedPayoutGroup 

func (db *DB) FirstUnfinishedUnattachedPayoutGroup(ctx context.Context) (*PayoutGroup, error)

func (*DB) NewRx 

func (obj *DB) NewRx() *Rx

func (*DB) Open 

func (obj *DB) Open(ctx context.Context) (*Tx, error)

func (*DB) WithTx 

func (db *DB) WithTx(ctx context.Context, fn func(*Tx) error) (err error)

type DBMethods 

type DBMethods interface {
	Methods

	Schema() string
	Rebind(sql string) string
}

type Error 

type Error struct {
	Err         error
	Code        ErrorCode
	Driver      string
	Constraint  string
	QuerySuffix string
}

func (*Error) Error 

func (e *Error) Error() string

type ErrorCode 

type ErrorCode int
const (
	ErrorCode_Unknown ErrorCode = iota
	ErrorCode_UnsupportedDriver
	ErrorCode_NoRows
	ErrorCode_TxDone
	ErrorCode_TooManyRows
	ErrorCode_ConstraintViolation
	ErrorCode_EmptyUpdate
)

type Metadata 

type Metadata struct {
	Pk        int64
	CreatedAt time.Time
	UpdatedAt time.Time
	Version   int
	Attempts  int
	Spender   *string
	Owner     *string
}

type Metadata_Attempts_Field 

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

func Metadata_Attempts 

func Metadata_Attempts(v int) Metadata_Attempts_Field

type Metadata_Create_Fields 

type Metadata_Create_Fields struct {
	Spender Metadata_Spender_Field
	Owner   Metadata_Owner_Field
}

type Metadata_CreatedAt_Field 

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

func Metadata_CreatedAt 

func Metadata_CreatedAt(v time.Time) Metadata_CreatedAt_Field

type Metadata_Owner_Field 

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

func Metadata_Owner 

func Metadata_Owner(v string) Metadata_Owner_Field

func Metadata_Owner_Null 

func Metadata_Owner_Null() Metadata_Owner_Field

func Metadata_Owner_Raw 

func Metadata_Owner_Raw(v *string) Metadata_Owner_Field

type Metadata_Pk_Field 

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

func Metadata_Pk 

func Metadata_Pk(v int64) Metadata_Pk_Field

type Metadata_Spender_Field 

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

func Metadata_Spender 

func Metadata_Spender(v string) Metadata_Spender_Field

func Metadata_Spender_Null 

func Metadata_Spender_Null() Metadata_Spender_Field

func Metadata_Spender_Raw 

func Metadata_Spender_Raw(v *string) Metadata_Spender_Field

type Metadata_Update_Fields 

type Metadata_Update_Fields struct {
	Attempts Metadata_Attempts_Field
	Spender  Metadata_Spender_Field
	Owner    Metadata_Owner_Field
}

type Metadata_UpdatedAt_Field 

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

func Metadata_UpdatedAt 

func Metadata_UpdatedAt(v time.Time) Metadata_UpdatedAt_Field

type Metadata_Version_Field 

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

func Metadata_Version 

func Metadata_Version(v int) Metadata_Version_Field

type Methods 

type Methods interface {
	All_Payout(ctx context.Context) (
		rows []*Payout, err error)

	All_Payout_By_PayoutGroupId(ctx context.Context,
		payout_payout_group_id Payout_PayoutGroupId_Field) (
		rows []*Payout, err error)

	All_Payout_By_PayoutGroup_FinalTxHash_Is_Null(ctx context.Context) (
		rows []*Payout, err error)

	All_Transaction(ctx context.Context) (
		rows []*Transaction, err error)

	All_Transaction_By_PayoutGroupId(ctx context.Context,
		transaction_payout_group_id Transaction_PayoutGroupId_Field) (
		rows []*Transaction, err error)

	All_Transaction_By_State_OrderBy_Asc_Nonce(ctx context.Context,
		transaction_state Transaction_State_Field) (
		rows []*Transaction, err error)

	Count_PayoutGroup(ctx context.Context) (
		count int64, err error)

	Count_PayoutGroup_By_FinalTxHash_Is_Null(ctx context.Context) (
		count int64, err error)

	Count_Payout_By_PayoutGroupId(ctx context.Context,
		payout_payout_group_id Payout_PayoutGroupId_Field) (
		count int64, err error)

	Count_Transaction(ctx context.Context) (
		count int64, err error)

	Count_Transaction_By_State(ctx context.Context,
		transaction_state Transaction_State_Field) (
		count int64, err error)

	CreateNoReturn_Metadata(ctx context.Context,
		metadata_version Metadata_Version_Field,
		metadata_attempts Metadata_Attempts_Field,
		optional Metadata_Create_Fields) (
		err error)

	CreateNoReturn_Payout(ctx context.Context,
		payout_csv_line Payout_CsvLine_Field,
		payout_payee Payout_Payee_Field,
		payout_usd Payout_Usd_Field,
		payout_payout_group_id Payout_PayoutGroupId_Field) (
		err error)

	CreateNoReturn_PayoutGroup(ctx context.Context,
		payout_group_id PayoutGroup_Id_Field,
		optional PayoutGroup_Create_Fields) (
		err error)

	Create_Transaction(ctx context.Context,
		transaction_hash Transaction_Hash_Field,
		transaction_owner Transaction_Owner_Field,
		transaction_spender Transaction_Spender_Field,
		transaction_nonce Transaction_Nonce_Field,
		transaction_estimated_gas_price Transaction_EstimatedGasPrice_Field,
		transaction_storj_price Transaction_StorjPrice_Field,
		transaction_storj_tokens Transaction_StorjTokens_Field,
		transaction_payout_group_id Transaction_PayoutGroupId_Field,
		transaction_raw Transaction_Raw_Field,
		transaction_state Transaction_State_Field,
		optional Transaction_Create_Fields) (
		transaction *Transaction, err error)

	Find_PayoutGroup_By_Id(ctx context.Context,
		payout_group_id PayoutGroup_Id_Field) (
		payout_group *PayoutGroup, err error)

	Find_Transaction_By_Hash(ctx context.Context,
		transaction_hash Transaction_Hash_Field) (
		transaction *Transaction, err error)

	First_Metadata(ctx context.Context) (
		metadata *Metadata, err error)

	First_Metadata_Version(ctx context.Context) (
		row *Version_Row, err error)

	Get_PayoutGroup_By_Pk(ctx context.Context,
		payout_group_pk PayoutGroup_Pk_Field) (
		payout_group *PayoutGroup, err error)

	UpdateNoReturn_Metadata_By_Pk(ctx context.Context,
		metadata_pk Metadata_Pk_Field,
		update Metadata_Update_Fields) (
		err error)

	UpdateNoReturn_PayoutGroup_By_Id(ctx context.Context,
		payout_group_id PayoutGroup_Id_Field,
		update PayoutGroup_Update_Fields) (
		err error)

	UpdateNoReturn_Transaction_By_Hash(ctx context.Context,
		transaction_hash Transaction_Hash_Field,
		update Transaction_Update_Fields) (
		err error)
}

type Payout 

type Payout struct {
	Pk            int64
	CreatedAt     time.Time
	CsvLine       int
	Payee         string
	Usd           string
	PayoutGroupId int64
}

type PayoutGroup 

type PayoutGroup struct {
	Pk          int64
	CreatedAt   time.Time
	UpdatedAt   time.Time
	Id          int64
	FinalTxHash *string
}

type PayoutGroup_Create_Fields 

type PayoutGroup_Create_Fields struct {
	FinalTxHash PayoutGroup_FinalTxHash_Field
}

type PayoutGroup_CreatedAt_Field 

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

func PayoutGroup_CreatedAt 

func PayoutGroup_CreatedAt(v time.Time) PayoutGroup_CreatedAt_Field

type PayoutGroup_FinalTxHash_Field 

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

func PayoutGroup_FinalTxHash 

func PayoutGroup_FinalTxHash(v string) PayoutGroup_FinalTxHash_Field

func PayoutGroup_FinalTxHash_Null 

func PayoutGroup_FinalTxHash_Null() PayoutGroup_FinalTxHash_Field

func PayoutGroup_FinalTxHash_Raw 

func PayoutGroup_FinalTxHash_Raw(v *string) PayoutGroup_FinalTxHash_Field

type PayoutGroup_Id_Field 

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

func PayoutGroup_Id 

func PayoutGroup_Id(v int64) PayoutGroup_Id_Field

type PayoutGroup_Pk_Field 

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

func PayoutGroup_Pk 

func PayoutGroup_Pk(v int64) PayoutGroup_Pk_Field

type PayoutGroup_Update_Fields 

type PayoutGroup_Update_Fields struct {
	FinalTxHash PayoutGroup_FinalTxHash_Field
}

type PayoutGroup_UpdatedAt_Field 

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

func PayoutGroup_UpdatedAt 

func PayoutGroup_UpdatedAt(v time.Time) PayoutGroup_UpdatedAt_Field

type Payout_CreatedAt_Field 

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

func Payout_CreatedAt 

func Payout_CreatedAt(v time.Time) Payout_CreatedAt_Field

type Payout_CsvLine_Field 

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

func Payout_CsvLine 

func Payout_CsvLine(v int) Payout_CsvLine_Field

type Payout_Payee_Field 

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

func Payout_Payee 

func Payout_Payee(v string) Payout_Payee_Field

type Payout_PayoutGroupId_Field 

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

func Payout_PayoutGroupId 

func Payout_PayoutGroupId(v int64) Payout_PayoutGroupId_Field

type Payout_Pk_Field 

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

func Payout_Pk 

func Payout_Pk(v int64) Payout_Pk_Field

type Payout_Update_Fields 

type Payout_Update_Fields struct {
}

type Payout_Usd_Field 

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

func Payout_Usd 

func Payout_Usd(v string) Payout_Usd_Field

type Rx 

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

func (*Rx) All_Payout 

func (rx *Rx) All_Payout(ctx context.Context) (
	rows []*Payout, err error)

func (*Rx) All_Payout_By_PayoutGroupId 

func (rx *Rx) All_Payout_By_PayoutGroupId(ctx context.Context,
	payout_payout_group_id Payout_PayoutGroupId_Field) (
	rows []*Payout, err error)

func (*Rx) All_Payout_By_PayoutGroup_FinalTxHash_Is_Null 

func (rx *Rx) All_Payout_By_PayoutGroup_FinalTxHash_Is_Null(ctx context.Context) (
	rows []*Payout, err error)

func (*Rx) All_Transaction 

func (rx *Rx) All_Transaction(ctx context.Context) (
	rows []*Transaction, err error)

func (*Rx) All_Transaction_By_PayoutGroupId 

func (rx *Rx) All_Transaction_By_PayoutGroupId(ctx context.Context,
	transaction_payout_group_id Transaction_PayoutGroupId_Field) (
	rows []*Transaction, err error)

func (*Rx) All_Transaction_By_State_OrderBy_Asc_Nonce 

func (rx *Rx) All_Transaction_By_State_OrderBy_Asc_Nonce(ctx context.Context,
	transaction_state Transaction_State_Field) (
	rows []*Transaction, err error)

func (*Rx) Commit 

func (rx *Rx) Commit() (err error)

func (*Rx) Count_PayoutGroup 

func (rx *Rx) Count_PayoutGroup(ctx context.Context) (
	count int64, err error)

func (*Rx) Count_PayoutGroup_By_FinalTxHash_Is_Null 

func (rx *Rx) Count_PayoutGroup_By_FinalTxHash_Is_Null(ctx context.Context) (
	count int64, err error)

func (*Rx) Count_Payout_By_PayoutGroupId 

func (rx *Rx) Count_Payout_By_PayoutGroupId(ctx context.Context,
	payout_payout_group_id Payout_PayoutGroupId_Field) (
	count int64, err error)

func (*Rx) Count_Transaction 

func (rx *Rx) Count_Transaction(ctx context.Context) (
	count int64, err error)

func (*Rx) Count_Transaction_By_State 

func (rx *Rx) Count_Transaction_By_State(ctx context.Context,
	transaction_state Transaction_State_Field) (
	count int64, err error)

func (*Rx) CreateNoReturn_Metadata 

func (rx *Rx) CreateNoReturn_Metadata(ctx context.Context,
	metadata_version Metadata_Version_Field,
	metadata_attempts Metadata_Attempts_Field,
	optional Metadata_Create_Fields) (
	err error)

func (*Rx) CreateNoReturn_Payout 

func (rx *Rx) CreateNoReturn_Payout(ctx context.Context,
	payout_csv_line Payout_CsvLine_Field,
	payout_payee Payout_Payee_Field,
	payout_usd Payout_Usd_Field,
	payout_payout_group_id Payout_PayoutGroupId_Field) (
	err error)

func (*Rx) CreateNoReturn_PayoutGroup 

func (rx *Rx) CreateNoReturn_PayoutGroup(ctx context.Context,
	payout_group_id PayoutGroup_Id_Field,
	optional PayoutGroup_Create_Fields) (
	err error)

func (*Rx) Create_Transaction 

func (rx *Rx) Create_Transaction(ctx context.Context,
	transaction_hash Transaction_Hash_Field,
	transaction_owner Transaction_Owner_Field,
	transaction_spender Transaction_Spender_Field,
	transaction_nonce Transaction_Nonce_Field,
	transaction_estimated_gas_price Transaction_EstimatedGasPrice_Field,
	transaction_storj_price Transaction_StorjPrice_Field,
	transaction_storj_tokens Transaction_StorjTokens_Field,
	transaction_payout_group_id Transaction_PayoutGroupId_Field,
	transaction_raw Transaction_Raw_Field,
	transaction_state Transaction_State_Field,
	optional Transaction_Create_Fields) (
	transaction *Transaction, err error)

func (*Rx) Find_PayoutGroup_By_Id 

func (rx *Rx) Find_PayoutGroup_By_Id(ctx context.Context,
	payout_group_id PayoutGroup_Id_Field) (
	payout_group *PayoutGroup, err error)

func (*Rx) Find_Transaction_By_Hash 

func (rx *Rx) Find_Transaction_By_Hash(ctx context.Context,
	transaction_hash Transaction_Hash_Field) (
	transaction *Transaction, err error)

func (*Rx) First_Metadata 

func (rx *Rx) First_Metadata(ctx context.Context) (
	metadata *Metadata, err error)

func (*Rx) First_Metadata_Version 

func (rx *Rx) First_Metadata_Version(ctx context.Context) (
	row *Version_Row, err error)

func (*Rx) Get_PayoutGroup_By_Pk 

func (rx *Rx) Get_PayoutGroup_By_Pk(ctx context.Context,
	payout_group_pk PayoutGroup_Pk_Field) (
	payout_group *PayoutGroup, err error)

func (*Rx) Rebind 

func (rx *Rx) Rebind(s string) string

func (*Rx) Rollback 

func (rx *Rx) Rollback() (err error)

func (*Rx) UnsafeTx 

func (rx *Rx) UnsafeTx(ctx context.Context) (unsafe_tx *sql.Tx, err error)

func (*Rx) UpdateNoReturn_Metadata_By_Pk 

func (rx *Rx) UpdateNoReturn_Metadata_By_Pk(ctx context.Context,
	metadata_pk Metadata_Pk_Field,
	update Metadata_Update_Fields) (
	err error)

func (*Rx) UpdateNoReturn_PayoutGroup_By_Id 

func (rx *Rx) UpdateNoReturn_PayoutGroup_By_Id(ctx context.Context,
	payout_group_id PayoutGroup_Id_Field,
	update PayoutGroup_Update_Fields) (
	err error)

func (*Rx) UpdateNoReturn_Transaction_By_Hash 

func (rx *Rx) UpdateNoReturn_Transaction_By_Hash(ctx context.Context,
	transaction_hash Transaction_Hash_Field,
	update Transaction_Update_Fields) (
	err error)

type Transaction 

type Transaction struct {
	Pk                int64
	CreatedAt         time.Time
	UpdatedAt         time.Time
	Hash              string
	Owner             string
	Spender           string
	Nonce             uint64
	EstimatedGasPrice string
	StorjPrice        string
	StorjTokens       string
	PayoutGroupId     int64
	Raw               string
	State             string
	Receipt           *string
}

type Transaction_Create_Fields 

type Transaction_Create_Fields struct {
	Receipt Transaction_Receipt_Field
}

type Transaction_CreatedAt_Field 

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

func Transaction_CreatedAt 

func Transaction_CreatedAt(v time.Time) Transaction_CreatedAt_Field

type Transaction_EstimatedGasPrice_Field 

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

func Transaction_EstimatedGasPrice 

func Transaction_EstimatedGasPrice(v string) Transaction_EstimatedGasPrice_Field

type Transaction_Hash_Field 

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

func Transaction_Hash 

func Transaction_Hash(v string) Transaction_Hash_Field

type Transaction_Nonce_Field 

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

func Transaction_Nonce 

func Transaction_Nonce(v uint64) Transaction_Nonce_Field

type Transaction_Owner_Field 

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

func Transaction_Owner 

func Transaction_Owner(v string) Transaction_Owner_Field

type Transaction_PayoutGroupId_Field 

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

func Transaction_PayoutGroupId 

func Transaction_PayoutGroupId(v int64) Transaction_PayoutGroupId_Field

type Transaction_Pk_Field 

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

func Transaction_Pk 

func Transaction_Pk(v int64) Transaction_Pk_Field

type Transaction_Raw_Field 

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

func Transaction_Raw 

func Transaction_Raw(v string) Transaction_Raw_Field

type Transaction_Receipt_Field 

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

func Transaction_Receipt 

func Transaction_Receipt(v string) Transaction_Receipt_Field

func Transaction_Receipt_Null 

func Transaction_Receipt_Null() Transaction_Receipt_Field

func Transaction_Receipt_Raw 

func Transaction_Receipt_Raw(v *string) Transaction_Receipt_Field

type Transaction_Spender_Field 

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

func Transaction_Spender 

func Transaction_Spender(v string) Transaction_Spender_Field

type Transaction_State_Field 

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

func Transaction_State 

func Transaction_State(v string) Transaction_State_Field

type Transaction_StorjPrice_Field 

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

func Transaction_StorjPrice 

func Transaction_StorjPrice(v string) Transaction_StorjPrice_Field

type Transaction_StorjTokens_Field 

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

func Transaction_StorjTokens 

func Transaction_StorjTokens(v string) Transaction_StorjTokens_Field

type Transaction_Update_Fields 

type Transaction_Update_Fields struct {
	State   Transaction_State_Field
	Receipt Transaction_Receipt_Field
}

type Transaction_UpdatedAt_Field 

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

func Transaction_UpdatedAt 

func Transaction_UpdatedAt(v time.Time) Transaction_UpdatedAt_Field

type Tx 

type Tx struct {
	Tx *sql.Tx
	// contains filtered or unexported fields
}

type TxMethods 

type TxMethods interface {
	Methods

	Rebind(s string) string
	Commit() error
	Rollback() error
}

type Version_Row 

type Version_Row struct {
	Version int
}

Source Files

View all Source files

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.