payoutdb

package
v0.0.0-...-d7b061b Latest Latest
Warning

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

Go to latest
Published: Apr 4, 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
}

Jump to

Keyboard shortcuts

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